erp/core/CoreApp/models/Model_logic_u9mgwx.php

<?php
/**
 * 系统自动处理在途库存的香港问题
 */
class Model_logic_u9mgwx extends Lin_Model {
   
    //切记要修改token_120的token真正的token！！！！
    function __construct(){
        parent::__construct();
        $this->load->_model('Model_settingtest','settingtest');
        $this->load->_model("Model_apiyyv1","apiyyv1");
        $this->load->_model("Model_zzquque_u9","zzquque_u9");
    }
    public function getToken($type){
        $name = "get_yytoken_".$type;
        $token = $this->settingtest->$name();
        return $token;
    }
   
    /**
     * 工厂加工生产外销的订单
     */
    public function doaction(){
        $this->_add_xsd();
        sleep(2);
        $list = $this->zzquque_u9->find_all("( xs_status > 0 ) and ( bzch_status = 0 )");
        foreach($list as $k=>$v){
            $this->_cx_xsdandbzch($v);
        }
    }
    // 第一步 创建销售单
    private function _add_xsd(){
        $start_time = strtotime(date('Y-m-d',time()));
        $list = $this->db->select("id,orderinfo")->where(
           ['scantime >=' => $start_time,]
        )->from('whlabel_bh_scan')->group_by('orderinfo')->get();
        $list= $list->result_array();
        if(empty($list)){
            exit('没有需要处理的数据');
        }
        echo "<pre>";
        foreach($list as $k=>$v){
            $this->_mgxxdo_one($v,$start_time);
        }
    }

    private function _mgxxdo_one($info,$start_time){
        $tmp_list =  $this->db->get_where('whlabel_bh_scan', [
            'orderinfo' => $info['orderinfo'],
            'scantime >=' => $start_time,
        ])->result_array();
        $goods_list = [];
        foreach($tmp_list as $k=>$v){
            if(isset($goods_list[$v['jm']])){
                $goods_list[$v['jm']]['dcsl'] += 1;
            }else{
                $goods_list[$v['jm']] = [
                    'jm'=>$v['jm'],
                    'pm'=>$v['pm'],
                    'dcsl'=>1,
                    'final_price'=>1,//让财务录入价格
                ];
            }
        }
        $final_list = array_values($goods_list);
        //避免一天内的东西被多次推送
        $order_number = $info['orderinfo']."_".date("md",time());
        $num = $this->db->where('order_no',$order_number)->from('zzquque_u9')->count_all_results();
        //如果已经存在，则不再处理
        if($num > 0){
            return ;
        }
        $this->db->insert('zzquque_u9',[
            'type'=>22,
            'order_no'=>$order_number,
            'create_time'=>time(),
            'update_time'=>time(),
        ]);
        //获取到相关信息的id
        $zzquque_u9_id = $this->db->insert_id();

        $this->db->where([
			'orderinfo'=>$info['orderinfo'],
			'scantime >= ' => $start_time,
            'status'=>0,
            'zzquque_u9_id'=>0,
		])->update("whlabel_bh_scan",[
			'status'=>1,
			'update_time'=>time(),
            'zzquque_u9_id'=>$zzquque_u9_id,
		]);
        //创建要执行的队列信息
        $params = [
            'yyid'=>'02031',
            'number'=>$order_number,
            'time'=>time(),
            'list'=>$final_list,
        ];
        $xsd_res  = $this->apiyyv1->xsdCreate($params,$this->getToken(130));
        if(empty($xsd_res[0]['Data'][0]['m_code'])){
            $this->editData($zzquque_u9_id,['xs_status'=>-1,'update_time'=>time()],$order_number,2,1,'xs',$xsd_res[1],$xsd_res[0]);
            return ;
        }
        //更新销售单数据
        $xs_no = $xsd_res[0]['Data'][0]["m_code"];
        $this->editData($zzquque_u9_id,['xs_no'=>$xs_no,'xs_status'=>1,'update_time'=>time()],$order_number,2,1,'xs',$xsd_res[1],$xsd_res[0]);
        
    }

    public function _cx_xsdandbzch($info){
        $res = $this->apiyyv1->xsdCxByNo($info['xs_no'],$this->getToken(130));
         //如果没审核 那么就不管
         if(empty($res[0]['Data'])){
            return ;
        }
        // 审核了 
        $list = $res[0]['Data'];
       
        if($list[0]['status'] < 3){
            return ;
        }
        foreach($list as $k=>$v){
            $list[$k]['dcsl'] = $v['shipplanqtypu'];
        }
        $tmp_info = [
            'zq_u9_id'=>$info['id'],
            'drckbm'=> '13001',
            'number'=>$info['order_no'],
            'order_no'=>$info['order_no'],
            'xs_no'=>$info['xs_no'],
            'xs_two_no'=>$info['xs_no'],
            'list'=>$list
        ];
        $res = $this->apiyyv1->bzchCreate($tmp_info,$this->getToken(130));
        if($res[0]['Data'][0]['m_isSucess'] != 1){
            $this->editData($info['id'],['bzch_status'=>-1,'update_time'=>time()],$info['order_no'],5,1,'bzch',$res[1],$res[0]);
            return $this->logic_tools->ret_arr(-1,"标准出库的信息异常，请查看");
        }else{
            $this->editData($info['id'],['bzch_no'=>$res[0]['Data'][0]['m_code'],'bzch_status'=>1,'xs_status'=>3,'update_time'=>time()],$info['order_no'],5,1,'bzch',$res[1],$res[0]);
            return $this->logic_tools->ret_arr(1,"标准出库创建成功");
        }

    }
    

   
    //对标准出货单进行审核
    public function checkBzch($info){
        $res = $this->apiyyv1->bzchSubmitAndApprove(['number'=>$info['bzch_no']],$this->getToken(120));
        // print_r($res[0]);
        // print_r($res[1]);
        if($res[0]['Data'][0]['m_isSucess'] != 1){
            $this->editData($info['id'],['bzch_status'=>-2,'update_time'=>time()],$info['order_no'],5,2,'bzch_sh',$res[1],$res[0]);
        }else{
            $this->editData($info['id'],['bzch_no'=>$res[0]['Data'][0]['m_code'],'bzch_status'=>3,'update_time'=>time()],$info['order_no'],5,2,'bzch_sh',$res[1],$res[0]);
        }
    }



    protected function editData($zq_u9_id,$z_qu_arr,$number,$one_type,$two_type,$apply_api,$apply_data,$ret_data){
        $this->zzquque_u9->save($z_qu_arr,$zq_u9_id);
        $this->zzququeu9_logs->insert([
            'oid'=>$zq_u9_id,
            'number'=>$number,
            'one_type'=>$one_type,
            'two_type'=>$two_type,
            'apply_api'=>$apply_api,
            'apply_data'=>json_encode($apply_data,JSON_UNESCAPED_UNICODE),
            'ret_data'=>json_encode($ret_data,JSON_UNESCAPED_UNICODE),
            'create_time'=>time(),
            'read_time'=>date("Y-m-d H:i:s")
        ]);
    }
}