12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970 |
- <?php
- namespace huolib\queue\job;
- use huolib\queue\constant\EventConst;
- use huomp\controller\cpa_reversal\Quhulian;
- use think\queue\Job;
- class CpaReversalFire extends Fire {
- static $g_i = 0;
-
- public function fire(Job $job, $data) {
- if ($job->attempts() > 1) {
- $job->delete();
- }
- self::$g_i++;
- $_is_job_done = $this->doJob($data);
- $runtime = round(microtime(true) - THINK_START_TIME, 10);
- echo $runtime.' '.self::$g_i;
- if ($_is_job_done) {
-
- $job->delete();
- } else {
- if ($job->attempts() > 3) {
-
- $job->delete();
-
-
- }
- }
- }
-
- public function doJob($data) {
- switch ($data['event']) {
- case EventConst::EVENT_CPA_REVERSAL_QUHULIAN:
- $_rs = (new Quhulian())->QuhulianNotify($data);
- break;
- default:
- $_rs = false;
- }
- return $_rs;
- }
- }
|