920 lines
38 KiB
PHP
920 lines
38 KiB
PHP
<?php
|
|
use App\Controllers\PlanController;
|
|
use App\Models\OrganizationModel;
|
|
use App\Models\UserModel;
|
|
use App\Models\GroupModel;
|
|
use App\Models\PolicyModel;
|
|
use App\Models\PolicyDetailsModel;
|
|
use App\Models\ServiceModel;
|
|
use App\Models\PlanStatusModel;
|
|
use App\Models\PlanModel;
|
|
|
|
|
|
if (!function_exists('palnStatusHandler')) {
|
|
function palnStatusHandler($plan_id , $is_data_edited)
|
|
{
|
|
log_message('info', "palnStatusHandler() called for plan_id: {$plan_id}, is_data_edited: {$is_data_edited}");
|
|
|
|
$planModel = new PlanModel();
|
|
$planStatusModel = new PlanStatusModel();
|
|
$userModel = new UserModel();
|
|
$groupModel = new GroupModel();
|
|
$policyModel = new PolicyModel();
|
|
$policyDetailsModel = new PolicyDetailsModel();
|
|
$planController = new PlanController();
|
|
|
|
$planData = $planController->find($plan_id, 'internal');
|
|
if (!$planData) {
|
|
log_message('error', "No plan data found for plan_id: {$plan_id}");
|
|
return false;
|
|
}
|
|
|
|
$planServices = [];
|
|
if (count($planData['flight'])) { array_push($planServices, 1); }
|
|
if (count($planData['train'])) { array_push($planServices, 2); }
|
|
if (count($planData['bus'])) { array_push($planServices, 3); }
|
|
if (count($planData['taxi'])) { array_push($planServices, 4); }
|
|
if (count($planData['accomodation'])) { array_push($planServices, 5); }
|
|
if (count($planData['forex'])) { array_push($planServices, 6); }
|
|
if (count($planData['insurance'])) { array_push($planServices, 7); }
|
|
if (count($planData['visa'])) { array_push($planServices, 8); }
|
|
if (count($planData['miscellaneous'])) { array_push($planServices, 9); }
|
|
|
|
log_message('debug', "Plan services found: " . json_encode($planServices));
|
|
|
|
// $userId = $planData['user_id'] ?? $planData['traveller_id'];
|
|
$userId = !empty($planData['user_id']) ? $planData['user_id'] : $planData['created_by'];
|
|
$userData = $userModel->where('user_id', $userId)->first();
|
|
if (!$userData) {
|
|
log_message('error', "User data not found for user_id: {$userId}");
|
|
return false;
|
|
}
|
|
|
|
$groupId = $userData['group_id'];
|
|
$a1Id = $userData['first_approver'];
|
|
$a2Id = $userData['second_approver'];
|
|
$a3Id = $userData['third_approver'];
|
|
$a4Id = $userData['fourth_approver'];
|
|
|
|
$groupData = $groupModel->where('group_id', $groupId)->first();
|
|
if (!$groupData) {
|
|
log_message('error', "Group data not found for group_id: {$groupId}");
|
|
return false;
|
|
}
|
|
|
|
$tripType = $planData['trip_type'];
|
|
$policyId = ($tripType == 1) ? $groupData['domestic_policy_id'] : $groupData['international_policy_id'];
|
|
|
|
$policyData = $policyModel->where('policy_id', $policyId)->first();
|
|
if (!$policyData) {
|
|
log_message('error', "Policy data not found for policy_id: {$policyId}");
|
|
return false;
|
|
}
|
|
|
|
$priorityOrderOfService = json_decode($policyData['services_ids'], true);
|
|
if (!is_array($priorityOrderOfService)) {
|
|
log_message('error', "Invalid service priority list in policy_id: {$policyId}");
|
|
return false;
|
|
}
|
|
|
|
foreach ($priorityOrderOfService as $key => &$value) {
|
|
$value['priority'] = $key + 1;
|
|
}
|
|
unset($value);
|
|
|
|
log_message('debug', "Service priority list: " . json_encode($priorityOrderOfService));
|
|
|
|
// Step 1: Filter only services present in current plan
|
|
$filtered = array_filter($priorityOrderOfService, function ($item) use ($planServices) {
|
|
return in_array($item['service_id'], $planServices);
|
|
});
|
|
|
|
// Step 2: Sort by priority
|
|
usort($filtered, function ($a, $b) {
|
|
return $a['priority'] <=> $b['priority'];
|
|
});
|
|
|
|
$topPriorityService = reset($filtered);
|
|
if (!$topPriorityService) {
|
|
log_message('error', "No matching service found for plan_id: {$plan_id}");
|
|
return false;
|
|
}
|
|
|
|
log_message('info', "Top priority service identified: " . json_encode($topPriorityService));
|
|
|
|
$policyServiceDetails = $policyDetailsModel
|
|
->where('policy_id', $policyId)
|
|
->where('service_id', $topPriorityService['service_id'])
|
|
->where('is_active', 1)
|
|
->first();
|
|
|
|
if (!$policyServiceDetails) {
|
|
log_message('error', "Policy service details not found for service_id: {$topPriorityService['service_id']}, policy_id: {$policyId}");
|
|
return false;
|
|
}
|
|
// dd($policyServiceDetails);
|
|
|
|
|
|
$isExceptional = $planData['exceptional_plan_reason'] !== null && $planData['exceptional_plan_reason'] !== '';
|
|
// dd($isExceptional);
|
|
|
|
if ($isExceptional) {
|
|
$policyA1Action = $policyServiceDetails['a1_exceptional_action'];
|
|
$policyA2Action = $policyServiceDetails['a2_exceptional_action'];
|
|
$policyA3Action = $policyServiceDetails['a3_exceptional_action'];
|
|
$policyA4Action = $policyServiceDetails['a4_exceptional_action'];
|
|
$policyParallelAction = $policyServiceDetails['exceptional_parallel_process_from'];
|
|
$policyAction = 'Exceptional';
|
|
} else if ($is_data_edited) {
|
|
$policyA1Action = $policyServiceDetails['a1_amendment_action'];
|
|
$policyA2Action = $policyServiceDetails['a2_amendment_action'];
|
|
$policyA3Action = $policyServiceDetails['a3_amendment_action'];
|
|
$policyA4Action = $policyServiceDetails['a4_amendment_action'];
|
|
$policyParallelAction = $policyServiceDetails['amendment_parallel_process_from'];
|
|
$policyAction = 'Amendment';
|
|
} else {
|
|
$policyA1Action = $policyServiceDetails['a1_action'];
|
|
$policyA2Action = $policyServiceDetails['a2_action'];
|
|
$policyA3Action = $policyServiceDetails['a3_action'];
|
|
$policyA4Action = 'None';
|
|
$policyParallelAction = $policyServiceDetails['parallel_process_from'];
|
|
$policyAction = 'Normal';
|
|
}
|
|
|
|
|
|
$data = [
|
|
'plan_id' => $plan_id,
|
|
'service_id' => $topPriorityService['service_id'],
|
|
'a1_id' => $a1Id,
|
|
'a1_action' => $policyA1Action,
|
|
'is_a1_action_done' => ($policyA1Action == 'None') ? 1 : 0,
|
|
'a2_id' => $a2Id,
|
|
'a2_action' => $policyA2Action,
|
|
'is_a2_action_done' => ($policyA2Action == 'None') ? 1 : 0,
|
|
'a3_id' => $a3Id,
|
|
'a3_action' => $policyA3Action,
|
|
'is_a3_action_done' => ($policyA3Action == 'None') ? 1 : 0,
|
|
'a4_id' => $a4Id,
|
|
'a4_action' => $policyA4Action,
|
|
'is_a4_action_done' => ($policyA4Action == 'None') ? 1 : 0,
|
|
'parallel_process_from' => $policyParallelAction,
|
|
'policy_action' => $policyAction,
|
|
'group_id'=> $groupId,
|
|
'policy_id'=> $policyId,
|
|
];
|
|
|
|
// dd($data);
|
|
|
|
if ($is_data_edited == false) {
|
|
log_message('info', "Creating new plan status for plan_id: {$plan_id}");
|
|
$planStatusModel->insert($data);
|
|
} else {
|
|
$oldStatusData = $planStatusModel->where('plan_id', $plan_id)->where('is_active', 1)->first();
|
|
if ($oldStatusData) {
|
|
if ($oldStatusData['service_id'] == $topPriorityService['service_id']) {
|
|
log_message('info', "No status update needed; service_id unchanged for plan_id: {$plan_id}");
|
|
} else {
|
|
log_message('info', "Updating plan status for edited plan_id: {$plan_id}. New service_id: {$topPriorityService['service_id']}, Old service_id: {$oldStatusData['service_id']}");
|
|
$planStatusModel->insert($data);
|
|
$planStatusModel->set(['is_active' => 0])
|
|
->where('plan_id', $plan_id)
|
|
->where('service_id', $oldStatusData['service_id'])
|
|
->update();
|
|
}
|
|
} else {
|
|
log_message('warning', "Old status data not found for edited plan_id: {$plan_id}");
|
|
$planStatusModel->insert($data);
|
|
}
|
|
}
|
|
|
|
log_message('info', "palnStatusHandler() completed for plan_id: {$plan_id}");
|
|
}
|
|
}
|
|
|
|
|
|
// if (!function_exists('palnStatusHandler')) {
|
|
// function palnStatusHandler($plan_id , $is_data_edited)
|
|
// {
|
|
|
|
// $planModel = new PlanModel();
|
|
// $planStatusModel = new PlanStatusModel();
|
|
// $userModel = new UserModel();
|
|
// $groupModel = new GroupModel();
|
|
// $policyModel = new PolicyModel();
|
|
// $policyDetailsModel = new PolicyDetailsModel();
|
|
// $planController = new PlanController();
|
|
|
|
// $planData = $planController->find($plan_id, 'internal');
|
|
|
|
// $planServices = [];
|
|
// if($planData)
|
|
// {
|
|
// if(count($planData['flight'])){ array_push($planServices,1); }
|
|
// if(count($planData['train'])){ array_push($planServices,2); }
|
|
// if(count($planData['bus'])){ array_push($planServices,3); }
|
|
// if(count($planData['taxi'])){ array_push($planServices,4); }
|
|
// if(count($planData['accomodation'])){ array_push($planServices,5); }
|
|
// if(count($planData['forex'])){ array_push($planServices,6); }
|
|
// if(count($planData['insurance'])){ array_push($planServices,7); }
|
|
// if(count($planData['visa'])){ array_push($planServices,8); }
|
|
// if(count($planData['miscellaneous'])){ array_push($planServices,9); }
|
|
|
|
// }
|
|
// echo '<pre>';
|
|
// print_r($planServices);
|
|
|
|
|
|
// // Fetch plan data
|
|
// if (!$planData) { return false; }
|
|
// $userId = $planData['user_id'] ?? $planData['traveller_id'];
|
|
|
|
// // Fetch user data
|
|
// $userData = $userModel->where('user_id', $userId)->first();
|
|
// if (!$userData) { return false; }
|
|
// $groupId = $userData['group_id'];
|
|
// $a1Id = $userData['first_approver'];
|
|
// $a2Id = $userData['second_approver'];
|
|
// $a3Id = $userData['third_approver'];
|
|
|
|
|
|
// // Fetch group data
|
|
// $groupData = $groupModel->where('group_id', $groupId)->first();
|
|
// if (!$groupData) { return false; }
|
|
// $policyId = ($planData['trip_type'] == 1) ? $groupData['domestic_policy_id'] : $groupData['international_policy_id'];
|
|
|
|
// // Fetch policy service data
|
|
// $policyData = $policyModel->where('policy_id', $policyId)->first();
|
|
// if (!$policyData) {return false; }
|
|
|
|
// $priorityOrderOfService = json_decode($policyData['services_ids'],true);
|
|
// if (is_array($priorityOrderOfService)) {
|
|
// foreach ($priorityOrderOfService as $key => &$value) {
|
|
// $value['priority'] = $key + 1;
|
|
// }
|
|
// unset($value); // always break reference after loop
|
|
// }
|
|
// echo '<pre>';
|
|
// print_r($priorityOrderOfService);
|
|
|
|
// // Step 1: Filter only services you currently have
|
|
// $filtered = array_filter($priorityOrderOfService, function($item) use ($planServices) {
|
|
// return in_array($item['service_id'], $planServices);
|
|
// });
|
|
|
|
// // Step 2: Sort by priority ascending
|
|
// usort($filtered, function($a, $b) {
|
|
// return $a['priority'] <=> $b['priority'];
|
|
// });
|
|
|
|
// // Step 3: Get the top priority service
|
|
// $topPriorityService = reset($filtered);
|
|
// echo '<pre>';
|
|
// print_r($topPriorityService); die;
|
|
|
|
// $policyServiceDetails = $policyDetailsModel->where('policy_id',$policyId)->where('service_id',$topPriorityService['service_id'])->where('is_active',1)->first();
|
|
// if (!$policyServiceDetails) { return false; }
|
|
// $policyA1Action = $policyServiceDetails['a1_action'];
|
|
// $policyA2Action = $policyServiceDetails['a2_action'];
|
|
// $policyA3Action = $policyServiceDetails['a3_action'];
|
|
// $policyParallelAction = $policyServiceDetails['parallel_process_from'];
|
|
|
|
|
|
|
|
|
|
// if($is_data_edited == false)//plan Creation
|
|
// {
|
|
// $data['plan_id'] = $plan_id;
|
|
// $data['service_id'] = $topPriorityService['service_id'];
|
|
// $data['a1_id'] = $a1Id;
|
|
// $data['a1_action'] = $policyA1Action;
|
|
// $data['a2_id'] = $a2Id;
|
|
// $data['a2_action'] = $policyA2Action;
|
|
// $data['a3_id'] = $a3Id;
|
|
// $data['a3_action'] = $policyA3Action;
|
|
// $data['parallel_process_from'] = $policyParallelAction;
|
|
// // Insert Status
|
|
// $planStatusModel->insert($data);
|
|
|
|
// }else{
|
|
|
|
// $oldStatusData = $planStatusModel->where('plan_id',$plan_id)->where('is_active', 1)->first();
|
|
|
|
// if($oldStatusData['service_id'] == $topPriorityService['service_id']){ // skip the process
|
|
|
|
// }else{ // insert new data
|
|
|
|
// //insert new service data
|
|
// $data['plan_id'] = $plan_id;
|
|
// $data['service_id'] = $topPriorityService['service_id'];
|
|
// $data['a1_id'] = $a1Id;
|
|
// $data['a1_action'] = $policyA1Action;
|
|
// $data['a2_id'] = $a2Id;
|
|
// $data['a2_action'] = $policyA2Action;
|
|
// $data['a3_id'] = $a3Id;
|
|
// $data['a3_action'] = $policyA3Action;
|
|
// $data['parallel_process_from'] = $policyParallelAction;
|
|
// // Insert Status
|
|
// $planStatusModel->insert($data);
|
|
|
|
// //update old service data is_active = 0
|
|
// $planStatusModel->set(['is_active'=>0])->where('plan_id',$plan_id)->where('service_id',$oldStatusData['service_id'])->update();
|
|
|
|
// }
|
|
|
|
// }
|
|
|
|
|
|
// }
|
|
// }
|
|
|
|
if (!function_exists('updatePlanStatus')) {
|
|
function updatePlanStatus($plan_id,$updated_by)
|
|
{
|
|
|
|
$planStatusModel = new PlanStatusModel();
|
|
$planModel = new PlanModel();
|
|
|
|
$a1 = $planStatusModel->where('plan_id',$plan_id)->where('a1_action','Approval')->where('is_active',1)->findAll();
|
|
$a1ApproveSum = 0;
|
|
$a1ApproveCount = 0;
|
|
if(count($a1))
|
|
{
|
|
$a1ApproveSum = array_sum(array_column($a1, 'is_a1_action_done'));
|
|
$a1ApproveCount = count($a1);
|
|
}
|
|
|
|
$a2 = $planStatusModel->where('plan_id',$plan_id)->where('a2_action','Approval')->where('is_active',1)->findAll();
|
|
$a2ApproveSum = 0;
|
|
$a2ApproveCount = 0;
|
|
if(count($a2))
|
|
{
|
|
$a2ApproveSum = array_sum(array_column($a2, 'is_a2_action_done'));
|
|
$a2ApproveCount = count($a2);
|
|
}
|
|
|
|
|
|
$a3 = $planStatusModel->where('plan_id',$plan_id)->where('a3_action','Approval')->where('is_active',1)->findAll();
|
|
$a3ApproveSum = 0;
|
|
$a3ApproveCount = 0;
|
|
if(count($a3))
|
|
{
|
|
$a3ApproveSum = array_sum(array_column($a3, 'is_a3_action_done'));
|
|
$a3ApproveCount = count($a3);
|
|
}
|
|
|
|
$a4 = $planStatusModel->where('plan_id',$plan_id)->where('a4_action','Approval')->where('is_active',1)->findAll();
|
|
$a4ApproveSum = 0;
|
|
$a4ApproveCount = 0;
|
|
if(count($a4))
|
|
{
|
|
$a4ApproveSum = array_sum(array_column($a4, 'is_a4_action_done'));
|
|
$a4ApproveCount = count($a4);
|
|
}
|
|
|
|
|
|
|
|
$count = ( $a1ApproveCount + $a2ApproveCount + $a3ApproveCount + $a4ApproveCount);
|
|
$sum = ( $a1ApproveSum + $a2ApproveSum + $a3ApproveSum + $a4ApproveSum);
|
|
|
|
// dd($a1,$a2,$a3,$a4,$count,$sum);
|
|
if($count == $sum)
|
|
{
|
|
// Approved
|
|
$planModel->set(['status'=>3,'updated_by'=>$updated_by])->where('plan_id',$plan_id)->update();
|
|
|
|
}else if($count != $sum && $sum > 0)
|
|
{
|
|
//Partially Approved
|
|
$planModel->set(['status'=>2,'updated_by'=>$updated_by])->where('plan_id',$plan_id)->update();
|
|
// $planModel->updatePlan($plan_id, ['status'=>2]);
|
|
// $db = \Config\Database::connect();
|
|
// $db->table('m_plan')->where('plan_id', $plan_id)->update(['status' => 2]);
|
|
}
|
|
|
|
return true;
|
|
|
|
}
|
|
}
|
|
|
|
if (!function_exists('getCurrentPlanStatus')) {
|
|
function getCurrentPlanStatus($plan_id)
|
|
{
|
|
|
|
$planStatusModel = new PlanStatusModel();
|
|
$userModel = new UserModel();
|
|
$currentStatus = [];
|
|
|
|
$a1 = $planStatusModel->where('plan_id',$plan_id)->where('a1_action','Approval')->where('is_active',1)->findAll();
|
|
|
|
if(count($a1))
|
|
{
|
|
|
|
$user1 = $userModel->where('user_id', $a1[0]['a1_action_done_by'])->first();
|
|
if(!$user1){
|
|
$user1 = $userModel->where('user_id', $a1[0]['a1_id'])->first();
|
|
}
|
|
|
|
$hasRejectReason = !empty(array_filter($a1, fn($row) => !empty($row['a1_reject_reason'])));
|
|
if($user1)
|
|
{
|
|
|
|
$userId = $user1['user_id'];
|
|
|
|
$a1ApproveSum = array_sum(array_column($a1, 'is_a1_action_done'));
|
|
$a1ApproveCount = count($a1);
|
|
|
|
$a1Status['a1_id'] = $userId;
|
|
if($a1ApproveSum == $a1ApproveCount)
|
|
{
|
|
$a1Status['a1_status'] = 'Plan approved by '.$user1['first_name'].' '.$user1['last_name'];
|
|
}else if($hasRejectReason){
|
|
$a1Status['a1_status'] = 'Plan rejected by '.$user1['first_name'].' '.$user1['last_name'].', Reason-'.$a1[0]['a1_reject_reason'];
|
|
}else{
|
|
$a1Status['a1_status'] = 'Plan approval pending from '.$user1['first_name'].' '.$user1['last_name'];
|
|
}
|
|
array_push($currentStatus,$a1Status);
|
|
}
|
|
|
|
}
|
|
|
|
|
|
$a2 = $planStatusModel->where('plan_id',$plan_id)->where('a2_action','Approval')->where('is_active',1)->findAll();
|
|
if(count($a2))
|
|
{
|
|
$user2 = $userModel->where('user_id', $a2[0]['a2_action_done_by'])->first();
|
|
if(!$user2){
|
|
$user2 = $userModel->where('user_id', $a2[0]['a2_id'])->first();
|
|
}
|
|
$hasRejectReason = !empty(array_filter($a2, fn($row) => !empty($row['a2_reject_reason'])));
|
|
if($user2)
|
|
{
|
|
$userId = $user2['user_id'];
|
|
|
|
$a2ApproveSum = array_sum(array_column($a2, 'is_a2_action_done'));
|
|
$a2ApproveCount = count($a2);
|
|
|
|
$a2Status['a2_id'] = $userId;
|
|
if($a2ApproveSum == $a2ApproveCount)
|
|
{
|
|
$a2Status['a2_status'] = 'Plan approved by '.$user2['first_name'].' '.$user2['last_name'];
|
|
}else if($hasRejectReason){
|
|
$a2Status['a2_status'] = 'Plan rejected by '.$user2['first_name'].' '.$user2['last_name'].', Reason-'.$a2[0]['a2_reject_reason'];
|
|
}else{
|
|
$a2Status['a2_status'] = 'Plan approval pending from '.$user2['first_name'].' '.$user2['last_name'];
|
|
}
|
|
array_push($currentStatus,$a2Status);
|
|
}
|
|
}
|
|
|
|
|
|
$a3 = $planStatusModel->where('plan_id',$plan_id)->where('a3_action','Approval')->where('is_active',1)->findAll();
|
|
if(count($a3))
|
|
{
|
|
$user3 = $userModel->where('user_id', $a3[0]['a3_action_done_by'])->first();
|
|
if(!$user3){
|
|
$user3 = $userModel->where('user_id', $a3[0]['a3_id'])->first();
|
|
}
|
|
$hasRejectReason = !empty(array_filter($a3, fn($row) => !empty($row['a3_reject_reason'])));
|
|
if($user3)
|
|
{
|
|
$userId = $user3['user_id'];
|
|
|
|
$a3ApproveSum = array_sum(array_column($a3, 'is_a3_action_done'));
|
|
$a3ApproveCount = count($a3);
|
|
|
|
$a3Status['a3_id'] = $userId;
|
|
if($a3ApproveSum == $a3ApproveCount)
|
|
{
|
|
$a3Status['a3_status'] = 'Plan approved by '.$user3['first_name'].' '.$user3['last_name'];
|
|
}else if($hasRejectReason){
|
|
$a3Status['a3_status'] = 'Plan rejected by '.$user3['first_name'].' '.$user3['last_name'].', Reason-'.$a3[0]['a3_reject_reason'];
|
|
}else{
|
|
$a3Status['a3_status'] = 'Plan approval pending from '.$user3['first_name'].' '.$user3['last_name'];
|
|
}
|
|
array_push($currentStatus,$a3Status);
|
|
}
|
|
}
|
|
|
|
$a4 = $planStatusModel->where('plan_id',$plan_id)->where('a4_action','Approval')->where('is_active',1)->findAll();
|
|
if(count($a4))
|
|
{
|
|
$user4 = $userModel->where('user_id', $a4[0]['a4_action_done_by'])->first();
|
|
if(!$user4){
|
|
$user4 = $userModel->where('user_id', $a4[0]['a4_id'])->first();
|
|
}
|
|
$hasRejectReason = !empty(array_filter($a4, fn($row) => !empty($row['a4_reject_reason'])));
|
|
if($user4)
|
|
{
|
|
$userId = $user4['user_id'];
|
|
|
|
$a4ApproveSum = array_sum(array_column($a4, 'is_a4_action_done'));
|
|
$a4ApproveCount = count($a4);
|
|
|
|
$a4Status['a4_id'] = $userId;
|
|
if($a4ApproveSum == $a4ApproveCount)
|
|
{
|
|
$a4Status['a4_status'] = 'Plan approved by '.$user4['first_name'].' '.$user4['last_name'];
|
|
}else if($hasRejectReason){
|
|
$a4Status['a4_status'] = 'Plan rejected by '.$user4['first_name'].' '.$user4['last_name'].', Reason-'.$a4[0]['a4_reject_reason'];
|
|
}else{
|
|
$a4Status['a4_status'] = 'Plan approval pending from '.$user4['first_name'].' '.$user4['last_name'];
|
|
}
|
|
array_push($currentStatus,$a4Status);
|
|
}
|
|
}
|
|
|
|
|
|
return $currentStatus;
|
|
|
|
}
|
|
}
|
|
|
|
if (!function_exists('getPlanApproverAction')) {
|
|
// initially written code without parallel , sequential
|
|
// function getPlanApproverAction($plan_id , )
|
|
// {
|
|
|
|
// $planStatusModel = new PlanStatusModel();
|
|
// $userModel = new UserModel();
|
|
// $result['approver_data'] = [];
|
|
// $serviceIds = [];
|
|
|
|
// $a1 = $planStatusModel->where('plan_id',$plan_id)->whereIn('a1_action',['Approval','Notification'])->where('is_active',1)->findAll();
|
|
// if(count($a1))
|
|
// {
|
|
// $serviceId = array_column($a1, 'service_id');
|
|
// $serviceIds = array_merge($serviceIds, $serviceId);
|
|
// $user = $userModel->where('user_id', $a1[0]['a1_id'])->first();
|
|
// if($user)
|
|
// {
|
|
// $approvalCount = 0;
|
|
// $notificationCount = 0;
|
|
|
|
// foreach ($a1 as $item) {
|
|
// if ($item['a1_action'] === 'Approval') {
|
|
// $approvalCount++;
|
|
// } elseif ($item['a1_action'] === 'Notification') {
|
|
// $notificationCount++;
|
|
// }
|
|
// }
|
|
|
|
// if($approvalCount != 0)
|
|
// {
|
|
// array_push($result['approver_data'] , ['approver'=>1, 'user_id'=>$a1[0]['a1_id'], 'email'=> $user['email'], 'action'=>'Approval', 'is_action_done'=>$a1[0]['is_a1_action_done']] );
|
|
// }else if($notificationCount != 0){
|
|
// array_push($result['approver_data'] , ['approver'=>1, 'user_id'=>$a1[0]['a1_id'], 'email'=> $user['email'], 'action'=>'Notification', 'is_action_done'=>$a1[0]['is_a1_action_done']] );
|
|
// }
|
|
// }
|
|
|
|
// }
|
|
|
|
|
|
|
|
// $a2 = $planStatusModel->where('plan_id',$plan_id)->whereIn('a2_action',['Approval','Notification'])->where('is_active',1)->findAll();
|
|
// if(count($a2))
|
|
// {
|
|
// $serviceId = array_column($a2, 'service_id');
|
|
// $serviceIds = array_merge($serviceIds, $serviceId);
|
|
// $user = $userModel->where('user_id', $a1[0]['a2_id'])->first();
|
|
// if($user)
|
|
// {
|
|
// $approvalCount = 0;
|
|
// $notificationCount = 0;
|
|
|
|
// foreach ($a1 as $item) {
|
|
// if ($item['a2_action'] === 'Approval') {
|
|
// $approvalCount++;
|
|
// } elseif ($item['a2_action'] === 'Notification') {
|
|
// $notificationCount++;
|
|
// }
|
|
// }
|
|
|
|
// if($approvalCount != 0)
|
|
// {
|
|
// array_push($result['approver_data'] , ['approver'=>2, 'user_id'=>$a1[0]['a2_id'], 'email'=> $user['email'], 'action'=>'Approval', 'is_action_done'=>$a2[0]['is_a2_action_done']] );
|
|
// }else if($notificationCount != 0){
|
|
// array_push($result['approver_data'] , ['approver'=>2, 'user_id'=>$a1[0]['a2_id'], 'email'=> $user['email'], 'action'=>'Notification', 'is_action_done'=>$a2[0]['is_a2_action_done']] );
|
|
// }
|
|
// }
|
|
|
|
// }
|
|
|
|
// $a3 = $planStatusModel->where('plan_id',$plan_id)->whereIn('a3_action',['Approval','Notification'])->where('is_active',1)->findAll();
|
|
// if(count($a3))
|
|
// {
|
|
// $serviceId = array_column($a3, 'service_id');
|
|
// $serviceIds = array_merge($serviceIds, $serviceId);
|
|
// $user = $userModel->where('user_id', $a1[0]['a3_id'])->first();
|
|
// if($user)
|
|
// {
|
|
// $approvalCount = 0;
|
|
// $notificationCount = 0;
|
|
|
|
// foreach ($a1 as $item) {
|
|
// if ($item['a3_action'] === 'Approval') {
|
|
// $approvalCount++;
|
|
// } elseif ($item['a3_action'] === 'Notification') {
|
|
// $notificationCount++;
|
|
// }
|
|
// }
|
|
|
|
// if($approvalCount != 0)
|
|
// {
|
|
// array_push($result['approver_data'] , ['approver'=>3, 'user_id'=>$a1[0]['a3_id'], 'email'=> $user['email'], 'action'=>'Approval', 'is_action_done'=>$a3[0]['is_a3_action_done']] );
|
|
// }else if($notificationCount != 0){
|
|
// array_push($result['approver_data'] , ['approver'=>3, 'user_id'=>$a1[0]['a3_id'], 'email'=> $user['email'], 'action'=>'Notification', 'is_action_done'=>$a3[0]['is_a3_action_done']] );
|
|
// }
|
|
// }
|
|
|
|
// }
|
|
|
|
|
|
// $statusData = $planStatusModel->where('plan_id',$plan_id)->where('is_active',1)->first();
|
|
// $result['parallel_process_from'] = $statusData['parallel_process_from'];
|
|
|
|
// return $result;
|
|
|
|
// }
|
|
|
|
// 3 level of parallel , sequential
|
|
// function getPlanApproverAction($plan_id)
|
|
// {
|
|
// $planStatusModel = new PlanStatusModel();
|
|
// $userModel = new UserModel();
|
|
// $result = ['approver_data' => []];
|
|
// $serviceIds = [];
|
|
|
|
// // A1, A2, A3 - handle all same way
|
|
// $approverAction = [
|
|
// ['key' => 'a1', 'approver' => 1],
|
|
// ['key' => 'a2', 'approver' => 2],
|
|
// ['key' => 'a3', 'approver' => 3],
|
|
// ];
|
|
|
|
// foreach ($approverAction as $stage) {
|
|
// $field = $stage['key'];
|
|
// $approverNumber = $stage['approver'];
|
|
// $actionField = "{$field}_action";
|
|
// $idField = "{$field}_id";
|
|
// $doneField = "is_{$field}_action_done";
|
|
|
|
// $record = $planStatusModel->where('plan_id', $plan_id)
|
|
// ->whereIn($actionField, ['Approval', 'Notification', 'None'])
|
|
// ->where('is_active', 1)
|
|
// ->first();
|
|
|
|
// if ($record) {
|
|
// $user = $userModel->where('user_id', $record[$idField])->first();
|
|
// if ($user) {
|
|
// $result['approver_data'][] = [
|
|
// 'approver' => $approverNumber,
|
|
// 'user_id' => $record[$idField],
|
|
// 'email' => $user['email'],
|
|
// 'action' => $record[$actionField],
|
|
// 'is_action_done' => $record[$doneField],
|
|
// 'where_key' => $idField,
|
|
// 'action_key' => $actionField,
|
|
// 'action_done_key' => $doneField,
|
|
// ];
|
|
// }
|
|
// }
|
|
// }
|
|
|
|
// // Get parallel process value
|
|
// $statusData = $planStatusModel->where('plan_id', $plan_id)->where('is_active', 1)->first();
|
|
// $result['parallel_process_from'] = $statusData['parallel_process_from'] ?? null;
|
|
|
|
|
|
// $parallelFrom = (int) $result['parallel_process_from'];
|
|
|
|
// foreach ($result['approver_data'] as $key => &$approver) {
|
|
// $approver['status'] = 'pending'; // default
|
|
|
|
// if ($parallelFrom === 1) {
|
|
// // All parallel
|
|
// $approver['status'] = 'active';
|
|
// } elseif ($parallelFrom === 2) {
|
|
// if ($approver['approver'] === 1) {
|
|
// $approver['status'] = 'active';
|
|
// } elseif (in_array($approver['approver'], [2, 3])) {
|
|
// // Check if approver 1 is done
|
|
// $a1Done = false;
|
|
// foreach ($result['approver_data'] as $a) {
|
|
// if ($a['approver'] === 1 && $a['is_action_done']) {
|
|
// $a1Done = true;
|
|
// break;
|
|
// }
|
|
// }
|
|
// $approver['status'] = $a1Done ? 'active' : 'waiting';
|
|
// }
|
|
// } elseif ($parallelFrom === 3) {
|
|
// // Sequential: 1 -> 2 -> 3
|
|
// $a1Done = false;
|
|
// $a2Done = false;
|
|
|
|
// foreach ($result['approver_data'] as $a) {
|
|
// if ($a['approver'] === 1 && $a['is_action_done']) $a1Done = true;
|
|
// if ($a['approver'] === 2 && $a['is_action_done']) $a2Done = true;
|
|
// }
|
|
|
|
// if ($approver['approver'] === 1) {
|
|
// $approver['status'] = 'active';
|
|
// } elseif ($approver['approver'] === 2) {
|
|
// $approver['status'] = $a1Done ? 'active' : 'waiting';
|
|
// } elseif ($approver['approver'] === 3) {
|
|
// $approver['status'] = ($a1Done && $a2Done) ? 'active' : 'waiting';
|
|
// }
|
|
// }
|
|
// }
|
|
// unset($approver); // best practice when using & reference in foreach
|
|
|
|
|
|
// return $result;
|
|
// }
|
|
|
|
|
|
// latest 4 level of parallel , sequential
|
|
function getPlanApproverAction($plan_id)
|
|
{
|
|
$planStatusModel = new PlanStatusModel();
|
|
$userModel = new UserModel();
|
|
$result = ['approver_data' => []];
|
|
|
|
$approverAction = [
|
|
['key' => 'a1', 'approver' => 1],
|
|
['key' => 'a2', 'approver' => 2],
|
|
['key' => 'a3', 'approver' => 3],
|
|
['key' => 'a4', 'approver' => 4],
|
|
];
|
|
|
|
foreach ($approverAction as $stage) {
|
|
$field = $stage['key'];
|
|
$approverNumber = $stage['approver'];
|
|
$actionField = "{$field}_action";
|
|
$idField = "{$field}_id";
|
|
$doneField = "is_{$field}_action_done";
|
|
$mailField = "is_{$field}_mail_send";
|
|
|
|
$record = $planStatusModel->where('plan_id', $plan_id)
|
|
->whereIn($actionField, ['Approval', 'Notification', 'None'])
|
|
->where('is_active', 1)
|
|
->first();
|
|
if ($record) {
|
|
$user = $userModel->where('user_id', $record[$idField])->first();
|
|
if ($user) {
|
|
$result['approver_data'][] = [
|
|
'approver' => $approverNumber,
|
|
'user_id' => $record[$idField],
|
|
'email' => $user['email'],
|
|
'action' => $record[$actionField],
|
|
'is_action_done' => $record[$doneField],
|
|
'where_key' => $idField,
|
|
'action_key' => $actionField,
|
|
'action_done_key' => $doneField,
|
|
'mail_send_key' => $mailField,
|
|
'is_mail_send' => $record[$mailField],
|
|
];
|
|
}
|
|
}
|
|
}
|
|
|
|
$statusData = $planStatusModel->where('plan_id', $plan_id)->where('is_active', 1)->first();
|
|
$result['parallel_process_from'] = $statusData['parallel_process_from'] ?? null;
|
|
|
|
$parallelFrom = (int) $result['parallel_process_from'];
|
|
|
|
foreach ($result['approver_data'] as &$approver) {
|
|
$approver['status'] = 'pending'; // default
|
|
|
|
// Flags
|
|
$a1Done = $a2Done = $a3Done = false;
|
|
foreach ($result['approver_data'] as $a) {
|
|
if ($a['approver'] === 1 && $a['is_action_done']) $a1Done = true;
|
|
if ($a['approver'] === 2 && $a['is_action_done']) $a2Done = true;
|
|
if ($a['approver'] === 3 && $a['is_action_done']) $a3Done = true;
|
|
}
|
|
|
|
if ($parallelFrom === 1) {
|
|
// All approvers active
|
|
$approver['status'] = 'active';
|
|
|
|
} elseif ($parallelFrom === 2) {
|
|
if ($approver['approver'] === 1) {
|
|
$approver['status'] = 'active';
|
|
} elseif (in_array($approver['approver'], [2, 3, 4])) {
|
|
$approver['status'] = $a1Done ? 'active' : 'waiting';
|
|
}
|
|
|
|
} elseif ($parallelFrom === 3) {
|
|
if ($approver['approver'] === 1) {
|
|
$approver['status'] = 'active';
|
|
} elseif ($approver['approver'] === 2) {
|
|
$approver['status'] = $a1Done ? 'active' : 'waiting';
|
|
} elseif (in_array($approver['approver'], [3, 4])) {
|
|
$approver['status'] = ($a1Done && $a2Done) ? 'active' : 'waiting';
|
|
}
|
|
|
|
} elseif ($parallelFrom === 4) {
|
|
if ($approver['approver'] === 1) {
|
|
$approver['status'] = 'active';
|
|
} elseif ($approver['approver'] === 2) {
|
|
$approver['status'] = $a1Done ? 'active' : 'waiting';
|
|
} elseif ($approver['approver'] === 3) {
|
|
$approver['status'] = ($a1Done && $a2Done) ? 'active' : 'waiting';
|
|
} elseif ($approver['approver'] === 4) {
|
|
$approver['status'] = ($a1Done && $a2Done && $a3Done) ? 'active' : 'waiting';
|
|
}
|
|
} else {
|
|
$approver['status'] = 'pending'; // fallback
|
|
}
|
|
}
|
|
unset($approver); // clean reference
|
|
|
|
return $result;
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
}
|
|
|
|
if (!function_exists('getApproverCurrentAction')) {
|
|
function getApproverCurrentAction($plan_id,$user_id)
|
|
{
|
|
|
|
$planStatusModel = new PlanStatusModel();
|
|
$userModel = new UserModel();
|
|
|
|
$a1 = $planStatusModel->where('plan_id',$plan_id)->where('a1_id',$user_id)->where('a1_action','Approval')->where('is_active',1)->findAll();
|
|
if(count($a1))
|
|
{
|
|
$hasRejectReason = !empty(array_filter($a1, fn($row) => !empty($row['a1_reject_reason'])));
|
|
$a1ApproveSum = array_sum(array_column($a1, 'is_a1_action_done'));
|
|
$a1ApproveCount = count($a1);
|
|
|
|
if($a1ApproveSum == $a1ApproveCount)
|
|
{
|
|
return 'Approved';
|
|
}else if($hasRejectReason){
|
|
return 'Rejected';
|
|
}else{
|
|
return 'Approval pending';
|
|
}
|
|
}
|
|
|
|
$a2 = $planStatusModel->where('plan_id',$plan_id)->where('a2_id',$user_id)->where('a2_action','Approval')->where('is_active',1)->findAll();
|
|
if(count($a2))
|
|
{
|
|
$hasRejectReason = !empty(array_filter($a2, fn($row) => !empty($row['a2_reject_reason'])));
|
|
$a2ApproveSum = array_sum(array_column($a2, 'is_a2_action_done'));
|
|
$a2ApproveCount = count($a2);
|
|
|
|
if($a2ApproveSum == $a2ApproveCount)
|
|
{
|
|
return 'Approved';
|
|
}else if($hasRejectReason){
|
|
return 'Rejected';
|
|
}else{
|
|
return 'Approval pending';
|
|
}
|
|
}
|
|
|
|
$a3 = $planStatusModel->where('plan_id',$plan_id)->where('a3_id',$user_id)->where('a3_action','Approval')->where('is_active',1)->findAll();
|
|
if(count($a3))
|
|
{
|
|
$hasRejectReason = !empty(array_filter($a3, fn($row) => !empty($row['a3_reject_reason'])));
|
|
$a3ApproveSum = array_sum(array_column($a3, 'is_a3_action_done'));
|
|
$a3ApproveCount = count($a3);
|
|
|
|
if($a3ApproveSum == $a3ApproveCount)
|
|
{
|
|
return 'Approved';
|
|
}else if($hasRejectReason){
|
|
return 'Rejected';
|
|
}else{
|
|
return 'Approval pending';
|
|
}
|
|
}
|
|
|
|
$a4 = $planStatusModel->where('plan_id',$plan_id)->where('a4_id',$user_id)->where('a4_action','Approval')->where('is_active',1)->findAll();
|
|
if(count($a4))
|
|
{
|
|
$hasRejectReason = !empty(array_filter($a4, fn($row) => !empty($row['a4_reject_reason'])));
|
|
$a4ApproveSum = array_sum(array_column($a4, 'is_a4_action_done'));
|
|
$a4ApproveCount = count($a4);
|
|
|
|
if($a4ApproveSum == $a4ApproveCount)
|
|
{
|
|
return 'Approved';
|
|
}else if($hasRejectReason){
|
|
return 'Rejected';
|
|
}else{
|
|
return 'Approval pending';
|
|
}
|
|
}
|
|
|
|
}
|
|
}
|
|
|