erp/core/CoreApp/models/Model_job_gethualeiwaybillid.php

<?php
class Model_job_gethualeiwaybillid extends Lin_Model {
    function __construct(){
            parent::__construct();
            $this->load->_model("Model_hualei","hualei");
            $this->load->_model("Model_fullorder","fullorder");
            $this->load->_model("Model_fullordersmt","fullordersmt");
            $this->load->_model("Model_fullordertt","fullordertt");
            $this->load->_model("Model_fullorderamz","fullorderamz");
            $this->load->_model("Model_logic_ding","logic_ding");
    }
    public function do_job(){
        $end_time = time() -  10* 3600 * 24;
        $start_time = time() -  3600 * 24;
        // 目前只处理惠城的usps 73
        // 出库时间十天前   waybillid 不能为空
        $where = "express = 73 and librarytime >= ".$end_time ." and librarytime <= ".$start_time."  ";
        //$where = "express = 76  and librarytime <= ".$start_time." ";
        $fields = "id,number,waybill,waybillid,librarytime,express";
        echo "<pre>";
        var_dump(date("Y-m-d H:i:s",time()));
        $this->do_dlz($where,$fields);
        $this->do_tt($where,$fields);
        $this->do_amz($where,$fields);
        $this->do_smt($where,$fields);
        var_dump(date("Y-m-d H:i:s",time()));
    }
    //执行对立站的代码
    private function do_dlz($where,$fields){
        $list = $this->fullorder->find_all($where,$fields);
       
        foreach($list as $item){
            if(empty($item['waybillid'])){
                $this->do_final($item,"fullorder");
            }else{
                continue;
            }
        }
    }

    private  function do_tt($where,$fields){
        $list = $this->fullordertt->find_all($where,$fields);
        foreach($list as $item){
            if(empty($item['waybillid'])){
                $this->do_final($item,"fullordertt");
            }else{
                continue;
            }
        }
    }

    private function do_amz($where,$fields){
        $list = $this->fullorderamz->find_all($where,$fields);
       
        foreach($list as $item){
            if(empty($item['waybillid'])){
                $this->do_final($item,"fullorderamz");
            }else{
                continue;
            }
        }
    }
    private function do_smt($where,$fields){
        $list = $this->fullordersmt->find_all($where,$fields);
       
        foreach($list as $item){
            if(empty($item['waybillid'])){
                $this->do_final($item,"fullordersmt");
            }else{
                continue;
            }
        }
    }

    private function do_final($info,$table_name){
        sleep(1);
        $res = $this->hualei->getDetail($info['number']);
        // var_dump($table_name);
        // var_dump($res);
        $res = json_decode($res,true);
        
        if(isset($res['msg_code']) && $res['msg_code'] == 200){
            if(isset($res['data'])){
                if(isset($res['data']['order_serveinvoicecode'])){
                    if(strpos($res['data']['order_serveinvoicecode'],"HC") === false){
                        if(!empty($res['data']['order_serveinvoicecode']) && $res['data']['order_serveinvoicecode'] != $info['waybill']){
               
                            $this->$table_name->save(['waybillid' => $res['data']['order_serveinvoicecode']],$info['id']);
                            $this->logic_ding->sendToDing("惠城转单号更新信息【".$info['waybill']."】"."转单号：".$res['data']['order_serveinvoicecode']." 平台：".$table_name."订单详细信息：{".json_encode($info)."}");
                        }
                    }
                   
                }
            }
            
        }
    }
}