diff --git a/app/Controllers/PolicyController.php b/app/Controllers/PolicyController.php index c7729a5..7fdd806 100644 --- a/app/Controllers/PolicyController.php +++ b/app/Controllers/PolicyController.php @@ -299,6 +299,9 @@ class PolicyController extends ResourceController $this->EnquiryModel->update($quotationData['enquiry_id'], $enquiryArray ); } + Jobs::addJob(['job_name' => 'readFileAndCalculateCommission','payload' => ['policy_id' => $policyId]]); + log_message("info",'readFileAndCalculateCommission job pushed'); + }else{ $updateData = [ @@ -311,20 +314,8 @@ class PolicyController extends ResourceController } - $readDoc = $this->checkPolicyDoc($policyId); - if($readDoc['status'] == 'failed'){ - - $result = ['policy_id'=>$policyId, 'file_read_data'=>[ 'value'=> [] , 'message' => $readDoc['message'] ] ]; - - }else{ - $result = ['policy_id'=>$policyId, 'file_read_data'=>[ 'value'=> $readDoc['data'] , 'message' => $readDoc['message'] ] ]; - } - - - - - return $this->respond(['status' => 'success', 'code' => 200, 'data' => $result ], 200); + return $this->respond(['status' => 'success', 'code' => 200, 'data' => $policyId ], 200); } catch (\Exception $e) { @@ -455,7 +446,7 @@ class PolicyController extends ResourceController return ['checkPolicyDoc' => $readDoc['status'] , 'calculateCommission' => $calculateCommission['status'] , 'createBDS' => 'Started , check log for more details.' ]; } - public function checkPolicyDoc($policyId = null) + public function checkPolicyDoc($policyId = null , $return = null) { try diff --git a/app/Controllers/QuotationController.php b/app/Controllers/QuotationController.php index 424e10d..f507ed9 100644 --- a/app/Controllers/QuotationController.php +++ b/app/Controllers/QuotationController.php @@ -515,7 +515,7 @@ class QuotationController extends ResourceController { try { - $quotationData = $this->request->getPost(); + $quotationData = $this->request->getJSON(true); if (empty($quotationData['quotation_id'])) { return $this->respond([