";
        $list = $this->zzjobs->find_all("status = 0 and quque = 'ysgjcx'", "*",null, 0, 1);
        $ids = array_column($list, 'id');
        $this->db->query("update crowd_zzjobs set status = 10 where id  in (" . implode(",", $ids) . ")");
        foreach ($list as $v) {
            $this->doAction($v);
            sleep(2);
        }
    }
    private function doAction($v)
    {
        $param = json_decode($v['payload'], true);
        
        
        $info = $param['v'];
       
        $notice_id = $param['id'];
        
        $notice_info = $this->notice->read($notice_id);

        $rr = $this->cne->get_logistics_yskx(
            [
                [
                    'TrackNumber' => $info['waybill']
                ]
            ]
        );
        var_dump($rr);
        if($rr['code'] != 1){
            return  $this->zzjobs->save(['status'=>20,'last_time'=>time(),'result'=>json_encode($rr,JSON_UNESCAPED_UNICODE)],$v['id']);;
        }
        $fs = $rr['data'][0];

        $wlfs = [];
        if (!isset($fs['f'])) {
            $this->fullorder->save(array('wlerror' => $fs['content']),  $info['id']);
        } else {
            if ($fs['f'] == '1') {
                if ($fs['exstate'] > $info['expressstate'] || isset($fs['webhookregister'])) {
                    $this->fullorder->save(array('expressstate' => $fs['exstate'], 'excontent' => $fs['data'], 'webhookregister' => 0, 'wlerror' => ''), $info['id']);
                }
                if ($fs['exstate'] == $notice_info['logisticstatus'] && $info['wlyc'] == '0' && $info['wltype'] != '1' && $info['source'] != '1') //获取快递状态等于模板状态、订单状态等于模板状态、出库时间大于-、未加入物流异常、允许发送邮件状态、非线下单
                {
                    if ($info['shop'] < '7') // && $v['shouldmoney'] > 100)
                    {
                        $wlfs[] = array('v' => $info, 'id' => $notice_id );
                        //$go = $this->_sdfs($v,$var['id']);//更新顺带发送
                    }
                }
            } else {
                $this->fullorder->save(array('wlerror' => $fs['content']), $v['id']);
            }
        }
        $this->zzjobs->save(['status'=>30,'last_time'=>time(),'result'=>json_encode($fs,JSON_UNESCAPED_UNICODE)],$v['id']);
        // if(!empty($wlfs)){
        //     $this->_sdfs($v['v'],$v['id']);
        // }
        // @$this->allocation->insert(array('title'=>$shopid.'-'.json_encode($csck)));
		// if($wlfs)
		// {
		//     foreach ($wlfs as $k=>$v)
		//     {
		// 		$t1 = microtime(true);
        //         $this->_sdfs($v['v'],$v['id']);
        //         $t2 = microtime(true);
		// 		$t3 = (40-($t2-$t1) < 1)?1:round(40-($t2-$t1));
		// 	    sleep($t3);
		//     }
		// }
    }

    public function _sdfs($fullorder,$id)//手动发送信息
	{
		$time = time();
		$notice = $this->notice->read($id);//无条件同模板匹配
		$notice['email'] = $this->emaildata->read($notice['email']);
		$shop = $this->shop->read($fullorder['shop']);
		$express = $this->express->read($fullorder['express']);
		if($notice['type'] == '1')
		{
			$fslx = 'tab';
			$content = '自动发送';
			$stripos = '1-';
		}
		else if ($notice['type'] == '2')
		{
			$fslx = 'logisticstatus';
			$content = $notice['title'];
			$stripos = $notice['type'].'-'.$notice[$fslx].'|';
		}
        $this->logic_ding->sendToDing("云尚轨迹获取快递信息暂时中断");
        return ;
		if(stripos($fullorder['zdstate'],$stripos) === false && $fullorder['wltype'] == '0')//如果没发送过并且允许发送
		{
		    $go = $this->notice->get_god($fullorder,$shop,$express,$notice);
            $this->logic_ding->sendToDing("云尚轨迹获取快递信息".json_encode($go,JSON_UNESCAPED_UNICODE));
		    if($go == 1)
		    {
				if($notice['type'] == '1')
				{
			       $this->fullorder->save(array('content'=>$fullorder['content'].$content.'-成功;','zdstate'=>$fullorder['zdstate'].$notice['type'].'-'.$notice[$fslx].'|','exstateerror'=>'','wlerror'=>''),$fullorder['id']);
				}
				else if ($notice['type'] == '2')
				{
					$this->fullorder->save(array('wlcontent'=>$fullorder['wlcontent'].$content.'-成功;','wlfstime'=>time(),'zdstate'=>$fullorder['zdstate'].$notice['type'].'-'.$notice[$fslx].'|','exstateerror'=>'','wlerror'=>''),$fullorder['id']);
				}
			     return 1;
		    }
		    else
		    {
				if($notice['type'] == '1')
				{
			        $this->fullorder->save(array('exstateerror'=>$content.'发送失败1：'.date('Y-m-d H',time()).'-'.$go.'('.$notice['type'].'-'.$notice[$fslx].')'),$fullorder['id']);
				}
				else if ($notice['type'] == '2')
				{
					$this->fullorder->save(array('wlerror'=>$content.'发送失败2：'.date('Y-m-d H',time()).'-'.$go.'('.$notice['type'].'-'.$notice[$fslx].')'),$fullorder['id']);
				}
		    }
		}
	}

}