123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120 |
- <?php
- namespace huo\controller\queue;
- use huo\controller\common\Base;
- use huolib\queue\constant\ClassConst;
- use huolib\queue\constant\JobConst;
- use huolib\status\CommonStatus;
- use think\Queue;
- class CpaReversalQueue extends Base {
- protected $param = [];
- protected $job_class = '';
- protected $job_name = '';
- public function __construct($s_data = []) {
- $this->job_class = ClassConst::CLASS_CPA_REVERSAL_FIRE;
- $this->job_name = JobConst::JOB_CPA_REVERSAL;
- $this->param = $s_data;
- $this->param['ts'] = time();
- }
-
- protected function retSucMsg($code = CommonStatus::NO_ERROR, $data = []) {
-
- $this->param['queue'] = '1';
- return $this->huoSuccess($code, CommonStatus::getMsg($code), $data);
- }
-
- protected function retErrMsg($code = CommonStatus::PUSH_QUEUE_ERROR) {
-
- $this->param['queue'] = '0';
- return $this->huoError($code, CommonStatus::getMsg($code));
- }
-
- public function pushQueue() {
- if (class_exists('think\\Queue')) {
- $_is_pushed = Queue::push($this->job_class, $this->param, $this->job_name);
- if ($_is_pushed === false) {
- return $this->retErrMsg();
- }
- }
- return $this->retSucMsg();
- }
-
- public function getParam() {
- return $this->param;
- }
-
- public function setParam($param) {
- $this->param = $param;
- }
-
- public function getJobClass() {
- return $this->job_class;
- }
-
- public function setJobClass($job_class) {
- $this->job_class = $job_class;
- }
-
- public function getJobName() {
- return $this->job_name;
- }
-
- public function setJobName($job_name) {
- $this->job_name = $job_name;
- }
- }
|