316 lines
14 KiB
PHP
Executable File
316 lines
14 KiB
PHP
Executable File
<?php
|
|
|
|
namespace App\Models;
|
|
|
|
use CodeIgniter\Model;
|
|
|
|
class EmployeeModel extends Model
|
|
{
|
|
protected $table = 'employees';
|
|
protected $primaryKey = 'id';
|
|
protected $allowedFields = [
|
|
"id",
|
|
"client_id",
|
|
"employee_id",
|
|
"change_event",
|
|
"relationship",
|
|
"relationship_code",
|
|
"relationship_id",
|
|
"relationship",
|
|
"batch_id",
|
|
"emp_code",
|
|
"name",
|
|
"email_personal",
|
|
"email_corporate",
|
|
"mobile",
|
|
"gender",
|
|
"dob",
|
|
"doj",
|
|
"basic_pay",
|
|
"band","designation",
|
|
"otp",
|
|
"family_floater_key",
|
|
"emp_status",
|
|
"created_by",
|
|
"updated_by",
|
|
"updated_at",
|
|
"is_active",
|
|
"file_id",
|
|
"is_addon_value",
|
|
"is_createdby_hr",
|
|
"client_branch_id",
|
|
"token_time_out",
|
|
"emp_type",
|
|
"unit",
|
|
"mpin",
|
|
"is_mpin_skipped",
|
|
"is_biometric_enabled",
|
|
"password",
|
|
];
|
|
|
|
// Callbacks
|
|
protected $allowCallbacks = true;
|
|
protected $beforeInsert = ["checkAndADDCreatedByValue"];
|
|
protected $afterInsert = [];
|
|
protected $beforeUpdate = ["checkAndUpdateUpdatedByValue"];
|
|
protected $afterUpdate = [];
|
|
protected $beforeFind = [];
|
|
protected $afterFind = [];
|
|
protected $beforeDelete = [];
|
|
protected $afterDelete = [];
|
|
|
|
protected function checkAndADDCreatedByValue(array $data)
|
|
{
|
|
// Check if 'updated_by' value is null or empty
|
|
if (empty($data['data']['created_by'])) {
|
|
// Set 'updated_by' value to the current session user ID
|
|
$data['data']['created_by'] = get_session_userid();
|
|
}
|
|
|
|
return $data;
|
|
}
|
|
|
|
protected function checkAndUpdateUpdatedByValue(array $data)
|
|
{
|
|
// Check if 'updated_by' value is null or empty
|
|
if (empty($data['data']['updated_by'])) {
|
|
// Set 'updated_by' value to the current session user ID
|
|
$data['data']['updated_by'] = get_session_userid();
|
|
}
|
|
|
|
return $data;
|
|
}
|
|
|
|
|
|
|
|
// for emp onboard process do not change
|
|
public function checkExistingEmp($arr,$client_branch_id)
|
|
{
|
|
|
|
if($arr['temp']['emp_id'] == null)
|
|
{
|
|
return $this->where('emp_code',$arr['emp_code'])
|
|
->where('name',$arr['name'])
|
|
->where('client_id',$arr['client_id'])
|
|
->where('client_branch_id',$client_branch_id)
|
|
->where('is_active',1)
|
|
->where('gender',$arr['gender'])
|
|
->where('dob',$arr['dob'])
|
|
->where('is_active',1)
|
|
->where('emp_status','active')
|
|
->find();
|
|
}
|
|
else
|
|
{
|
|
return $this->where('id',$arr['temp']['emp_id'])->find();
|
|
}
|
|
}
|
|
|
|
|
|
public function getEmpFamilybyEmpCode(string $client_policy_id = null,string $emp_code = null,string $client_id = null,array $emp_status = [],array $policy_status = [],array $relationship = [],array $client_branch_id = [],array $policy_type_id = [])
|
|
{
|
|
$result = $this->select(['employees.id as emp_id', 'employees.client_id','employees.client_branch_id', 'employees.relationship', 'employees.relationship_code', 'employees.change_event', 'employees.emp_code', 'employees.name', 'employees.email_personal', 'employees.email_corporate', 'employees.mobile', 'employees.gender', 'employees.dob', 'employees.doj', 'employees.basic_pay', 'employees.band', 'employees.designation', 'employees.emp_status','employees.unit','employees.file_id','employee_polices.id as emp_policy_id', 'employee_polices.employee_id', 'employee_polices.client_policy_id', 'employee_polices.tpa_id', 'employee_polices.uhid', 'employee_polices.batch_code', 'employee_polices.status', 'employee_polices.pre_existing_alignments', 'employee_polices.basic_cover_si', 'employee_polices.date_coverage', 'employee_polices.policy_end_date', 'employee_polices.days', 'employee_polices.premium', 'employee_polices.rata_premimum', 'employee_polices.gst', 'employee_polices.date_of_exit', 'employee_polices.reason_for_exit','policy_type.long_name as policy_name','client_policy.policy_type_id','client_policy.is_addon', 'employee_polices.payable_employee','employee_polices.rand_string','employee_polices.claim_status'])
|
|
->join('employee_polices', 'employee_polices.employee_id = employees.id')
|
|
->join('client_policy', 'client_policy.id = employee_polices.client_policy_id')
|
|
->join('policy_type', 'policy_type.id = client_policy.policy_type_id','left')
|
|
->where('employees.is_active',1)
|
|
->when($client_policy_id, function($query) use ($client_policy_id){
|
|
return $query->where('employee_polices.client_policy_id',$client_policy_id);
|
|
})
|
|
|
|
->where('employee_polices.is_active',1)
|
|
->where('employees.is_active',1)
|
|
// ->where('employees.emp_code',$emp_code)
|
|
->when($emp_code, function($query) use ($emp_code){
|
|
return $query->where('employees.emp_code',$emp_code);
|
|
|
|
})
|
|
->when(count($emp_status), function($query) use ($emp_status){
|
|
return $query->whereIn('employees.emp_status', $emp_status);
|
|
})
|
|
->when(count($client_branch_id), function($query) use ($client_branch_id){
|
|
return $query->whereIn('employees.client_branch_id', $client_branch_id);
|
|
})
|
|
->when(count($relationship), function($query) use ($relationship){
|
|
return $query->whereIn('employees.relationship', $relationship);
|
|
})
|
|
->when(count($policy_status), function($query) use ($policy_status){
|
|
return $query->whereIn('employee_polices.status', $policy_status);
|
|
})
|
|
->when(count($policy_type_id), function($query) use ($policy_type_id){
|
|
return $query->whereIn('client_policy.policy_type_id', $policy_type_id);
|
|
})
|
|
->when($client_id, function($query) use ($client_id){
|
|
return $query->where('employees.client_id',$client_id);
|
|
})
|
|
->findAll();
|
|
// dd($this->db->getLastQuery());
|
|
|
|
return ($result);
|
|
}
|
|
|
|
|
|
|
|
public function getEmployeePolicy($id)
|
|
{
|
|
|
|
return $this->db->table('employee_polices')
|
|
->select('
|
|
policy_type.long_name as Policy_Name ,
|
|
client_policy.policy_terms as Policy_Terms,
|
|
client_policy.client_id as ClientId,
|
|
client_policy.policy_id as PolicyId,
|
|
client_policy.id as ClientPolicyId,
|
|
CASE
|
|
WHEN client_policy.open_for_enrollment IS NULL THEN 0
|
|
ELSE client_policy.open_for_enrollment
|
|
END AS OpenForEnrollment,
|
|
client_policy.disclaimer,
|
|
client_policy.policy_type_id ,
|
|
employee_polices.tpa_id as tpa_id ,
|
|
employee_polices.rand_string as rand_string
|
|
', FALSE) // Select all columns from both tables
|
|
->join('client_policy', 'client_policy.id = employee_polices.client_policy_id')
|
|
->join('policy_type', 'policy_type.id = client_policy.policy_type_id')
|
|
->where('client_policy.policy_status', 1)
|
|
->where('employee_polices.status !=', 'truncated')
|
|
->where('employee_polices.is_active', 1)
|
|
->where('employee_polices.employee_id', $id)
|
|
->get()
|
|
->getResult();
|
|
}
|
|
|
|
// for EMP rest API process do not change
|
|
public function checkExistingEmployee($arr,$client_branch_id)
|
|
{
|
|
return $this->where('emp_code',$arr['emp_code'])->where('name',$arr['name'])->where('client_id', $arr['client_id'])->where('client_branch_id', $client_branch_id)->where('emp_status !=', 'truncated')->first();
|
|
}
|
|
|
|
|
|
public function getEmpListByFileId(int $file_id,array $emp_status = [],array $policy_status = [])
|
|
{
|
|
$result = $this->select(['employees.id as emp_id', 'employees.client_id', 'employees.relationship', 'employees.relationship_code', 'employees.change_event', 'employees.emp_code', 'employees.name', 'employees.email_personal', 'employees.email_corporate', 'employees.mobile', 'employees.gender', 'employees.dob', 'employees.doj', 'employees.basic_pay', 'employees.band', 'employees.designation', 'employees.emp_status','employee_polices.id as emp_policy_id', 'employee_polices.employee_id', 'employee_polices.client_policy_id', 'employee_polices.tpa_id', 'employee_polices.uhid', 'employee_polices.batch_code', 'employee_polices.status', 'employee_polices.pre_existing_alignments', 'employee_polices.basic_cover_si', 'employee_polices.date_coverage', 'employee_polices.policy_end_date', 'employee_polices.days', 'employee_polices.premium', 'employee_polices.rata_premimum', 'employee_polices.gst', 'employee_polices.date_of_exit', 'employee_polices.reason_for_exit'])
|
|
->join('employee_polices', 'employee_polices.employee_id = employees.id')
|
|
->where('employees.is_active',1)
|
|
->where('employees.file_id',$file_id)
|
|
->where('employee_polices.is_active',1)
|
|
// ->where('employee_polices.uhid is not null')
|
|
// ->where('employee_polices.tpa_id is not null')
|
|
->groupStart()
|
|
->orWhere('employee_polices.uhid is not null')
|
|
->orWhere('employee_polices.tpa_id is not null')
|
|
->groupEnd()
|
|
->when(count($emp_status), function($query) use ($emp_status){
|
|
return $query->whereIn('employees.emp_status', $emp_status);
|
|
})
|
|
->when(count($policy_status), function($query) use ($policy_status){
|
|
return $query->whereIn('employee_polices.status', $policy_status);
|
|
})
|
|
->findAll();
|
|
// ~dd($this->db->getLastQuery());
|
|
|
|
return ($result);
|
|
}
|
|
|
|
|
|
public function getFamiliyCountAndMaxage(string $emp_code)
|
|
{
|
|
$query = "
|
|
SELECT emp_code,family_member_count,max_age
|
|
FROM
|
|
(
|
|
SELECT
|
|
emp_code,
|
|
COUNT(*) AS family_member_count,
|
|
MAX(TIMESTAMPDIFF(YEAR, dob, CURDATE())) AS max_age
|
|
FROM employees where emp_code = '{$emp_code}'
|
|
GROUP BY emp_code
|
|
) AS family_stats
|
|
ORDER BY family_member_count DESC, max_age DESC
|
|
LIMIT 1;";
|
|
$results = $this->db->query($query)->getResultArray();
|
|
return $results;
|
|
}
|
|
|
|
public function getTestEmployeeData(){
|
|
$query = "
|
|
SELECT
|
|
e.*,
|
|
(
|
|
SELECT
|
|
COUNT(ep.client_policy_id)
|
|
FROM
|
|
employee_polices ep
|
|
WHERE
|
|
ep.employee_id = e.id
|
|
) AS policy_count
|
|
FROM
|
|
employees e
|
|
WHERE
|
|
e.emp_code LIKE 'TEST%'
|
|
ORDER BY
|
|
e.emp_code,
|
|
CASE
|
|
WHEN e.relationship = 'self' THEN 1
|
|
WHEN e.relationship = 'spouse' THEN 2
|
|
ELSE 3
|
|
END;
|
|
";
|
|
$results = $this->db->query($query)->getResultArray();
|
|
return $results;
|
|
}
|
|
|
|
public function getEmployeeByEmployeeCode($emp_code, $client_policy_id = null, $client_id = null)
|
|
{
|
|
$query = $this->select("
|
|
employees.id AS emp_id,
|
|
employees.name AS emp_name,
|
|
employees.emp_code,
|
|
employees.mobile AS emp_mobile,
|
|
employees.email_corporate AS emp_email,
|
|
employees.relationship AS emp_relationship,
|
|
employee_polices.uhid AS policy_no,
|
|
employee_polices.tpa_id AS tpa_no
|
|
")
|
|
->join('employee_polices', 'employees.id = employee_polices.employee_id', 'left')
|
|
->where('employees.is_active', 1)
|
|
->where('employee_polices.is_active', 1)
|
|
->where('employees.emp_status', "active")
|
|
->where('employee_polices.status', "active")
|
|
->where('employees.emp_code', $emp_code);
|
|
|
|
if(!empty($client_id)){
|
|
$query->where('employees.client_id', $client_id);
|
|
}
|
|
|
|
if(!empty($client_policy_id)){
|
|
$query->where('employee_polices.client_policy_id', $client_policy_id);
|
|
}
|
|
|
|
$query->groupBy('employees.id');
|
|
$data = $query->findAll();
|
|
|
|
return $data;
|
|
|
|
|
|
}
|
|
|
|
public function getAcmUsingClientID($client_id)
|
|
{
|
|
return $this->db->table('client_rm')
|
|
->select('user_profiles.id, user_profiles.first_name')
|
|
->join('user_profiles', 'client_rm.user_id = user_profiles.id')
|
|
->where([
|
|
'client_rm.level' => 3,
|
|
'user_profiles.role' => 3,
|
|
'client_rm.is_active' => 1,
|
|
'user_profiles.is_active' => 1,
|
|
'client_rm.client_id' => $client_id
|
|
])
|
|
->get()
|
|
->getResultArray();
|
|
}
|
|
|
|
}
|
|
|