Job Queue for file read , commission calculation , BDS entry
This commit is contained in:
parent
7d34374c75
commit
5b6564dd1c
@ -51,14 +51,14 @@ class Jobs extends BaseController
|
|||||||
$uuid = generate_uuid();
|
$uuid = generate_uuid();
|
||||||
$jobid = $jobModel->insert(['name' => $payload['job_name'],'uuid' => $uuid,'payload' => json_encode($payload['payload']), 'status' => isset($payload['status']) ? $payload['status'] : 'queued']);
|
$jobid = $jobModel->insert(['name' => $payload['job_name'],'uuid' => $uuid,'payload' => json_encode($payload['payload']), 'status' => isset($payload['status']) ? $payload['status'] : 'queued']);
|
||||||
// echo $jobid;
|
// echo $jobid;
|
||||||
$myLogger->logme('error','new job {jobid} added to queue',['jobid' => $jobid]);
|
log_message('error','new job {jobid} added to queue',['jobid' => $jobid]);
|
||||||
return ['id' => $jobid,'uuid' => $uuid,'job_name' => $payload['job_name']];
|
return ['id' => $jobid,'uuid' => $uuid,'job_name' => $payload['job_name']];
|
||||||
}
|
}
|
||||||
catch(\Exception $e)
|
catch(\Exception $e)
|
||||||
{
|
{
|
||||||
$message = $e->getMessage();
|
$message = $e->getMessage();
|
||||||
return $message;
|
return $message;
|
||||||
$myLogger->logme('error','{messgae}',['messgae' => $message]);
|
log_message('error','{messgae}',['messgae' => $message]);
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
Loading…
Reference in New Issue
Block a user