erp/core/CoreApp/controllers/Queue.php

<?php defined('BASEPATH') OR exit('No direct script access allowed');
/**
 * 该类执行队列使用
 */
class Queue extends Start_Controller {
	public function __construct(){
		parent::__construct();
		$this->load->_model("Model_zztmpdata",'zztmpdata');
        $this->load->_model("Model_logic_crm",'logic_crm');
	}

    //定义方法的调用规则 获取URI第二段值
    public function _remap($arg,$arg_array)
    {
		if($arg == 'coq')//
        {
             $this->_crm_order_queue();
        }
		
		else 
        {
             return ;
        }
    }
    //通知向crm 同步订单出库 订单派送 订单
    protected function _crm_order_queue(){
       
        $time =time()-24*3600 *3;
        $list = $this->zztmpdata->find_all("act_name = 'crm_order' and create_time > ".$time,"*","id asc",0,100);
        //$list = $this->zztmpdata->find_all("id = 181","*","id desc",0,50);
        foreach($list as $v){
            
            $order_info = json_decode($v['content'],true);
            // if($order_info['shop'] != 4){
            //     $this->zztmpdata->remove($v['id']);
            // }
            $this->logic_crm->panduan($order_info,$v['type'],[]);
            $this->zztmpdata->remove($v['id']);
            usleep(10);
        }
    }
}