Nhances/nhance_partner_be
Nhances/nhance_partner_be
5
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Job Queue for file read , commission calculation , BDS entry

Browse Source
This commit is contained in:
Gowtham M 2025-11-25 18:04:10 +05:30
parent 5b6564dd1c
commit d59694c3ee
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
app/Controllers/JobWorker.php
View File

@ -115,7 +115,7 @@ class JobWorker extends BaseController
$start = microtime(true); $start = microtime(true);
$runtime = null; $runtime = null;
$job_status = self::STATUS_RUNNING; $job_status = self::STATUS_RUNNING;
$db->query("UPDATE jobs SET status=? WHERE id=? AND uuid=?", [$job_status, $job->id,$job->uuid]); $db->query("UPDATE partner_jobs SET status=? WHERE id=? AND uuid=?", [$job_status, $job->id,$job->uuid]);
if (!array_key_exists($job->name,SELF::$event_class_mapping)) if (!array_key_exists($job->name,SELF::$event_class_mapping))
{ {
@ -194,7 +194,7 @@ class JobWorker extends BaseController
$response = ['file_name' => $e->getFile(),'error' => $e->getMessage(),'line_no' => $e->getLine(),'info' => $e->getTraceAsString(),'scope' => 'worker failed']; $response = ['file_name' => $e->getFile(),'error' => $e->getMessage(),'line_no' => $e->getLine(),'info' => $e->getTraceAsString(),'scope' => 'worker failed'];
} }
$db->query("UPDATE jobs SET status=?, run_time=?, response=? WHERE id=? AND uuid=?", [ $db->query("UPDATE partner_jobs SET status=?, run_time=?, response=? WHERE id=? AND uuid=?", [
$job_status, $job_status,
$runtime, $runtime,
json_encode($response), json_encode($response),