erp/core/CoreApp/models/Model_express_tt.php

<?php
class Model_express_tt extends Lin_Model {
    function __construct(){
        parent::__construct();
        $this->load->_model("Model_apitt","apitt");
    }

    
    public function get_data($info,$type = 'CBT'){
        if(empty($info)){
            return  [
               'x'=>0,
               'Description'=>'订单信息不存在',
           ];
       }
       if(is_numeric($info['shop'])){
         $shopid = $info['shop'];
       }else{
         $shopid = $info['tmp_shop_id'];
       }
       $shop_info = $this->db->from('shop')->where('id', $shopid)->get()->result_array();
       
       if(empty($shop_info)){
           return  [
               'x'=>0,
               'Description'=>'该商铺不存在',
           ];
       }
        if($type == 'CBT'){
           if($info['merge'] == $info['id']){
                $extra_text = json_decode($info['extra_text'],true);
                if(is_string($extra_text)){
                    $extra_text = json_decode($extra_text,true);
                }
                if(empty($extra_text['label_info'])){
                    $res = $this->getDetail($info,$shop_info[0]);
                    if($res['x'] == 0){
                        return $res;
                    }
                    $info = $res['data'];
                }
                return $this->downloadCbtConbinLabel($info,$shop_info[0]);
           }else{
                //获取快递服务信息
                $res = $this->getExpressCompany($info,$shop_info[0]);
                if($res['x'] == 0){
                    return $res;
                }
                $res1 = $this->createExpressLabel($res['data'],$shop_info[0]);
                if($res1['x'] == 0){
                    return $res1;
                }
                if(is_string($info['extra_text'])){
                    $info['extra_text'] = json_decode($info['extra_text'],true);
                }
                if(empty($info['extra_text']['label_info'])){
                    sleep(2);
                }
                $res2 = $this->downloadExpressLabel($res1['data'],$shop_info[0]);
                return $res2;
           }
           
          
        }else if($type == 'FBT'){
            $extra_text = json_decode($info['extra_text'],true);
            if(empty($extra_text)){
                return $this->getFBTOrderDetail($info,$shop_info);
            }
            if(empty($extra_text['packages'])){
                return $this->getFBTOrderDetail($info,$shop_info);
            }
            $info['extra_text'] = $extra_text;
            return $this->getFBTPackage($info,$shop_info);
            
        }else{
            return  [
                'x'=>0,
                'Description'=>'暂不支持该快递类型',    
            ];
        }
        
    }
    private function getFBTOrderDetail($info,$shop_info){
        $res = $this->apitt->get_data([$info['orderinfo']],$shop_info[0]);
        if($res['code'] != 0){
            return [
                'x'=>0,
                'Description'=>$res['message'],  
            ];
        }
        if(!isset($res['data']['orders'])){
            return [
                'x'=>0,
                'Description'=>"获取TT订单信息异常",  
            ];
        }
        if(empty($res['data']['orders'])){
            return [
                'x'=>0,
                'Description'=>"获取TT订单信息异常",  
            ];
        }
        if(empty($res['data']['orders'][0]['packages'])){
            return [
                'x'=>0,
                'Description'=>"获取TT订单的快递信息",  
            ];
        }
        $packages = $res['data']['orders'][0]['packages'];

        if(!is_array($info['extra_text'])){
            $extra_text = json_decode($info['extra_text'],true);
        }else{
            $extra_text = $info['extra_text'];
        }
        $extra_text['packages'] = $packages;
        
        $this->db->update('fullordertt', [
            'extra_text' => json_encode($extra_text,JSON_UNESCAPED_UNICODE)
        ], ['id' => $info['id']]) ;


        $packageid = $packages[0]['id'];
        $rr = $this->apitt->downloadLabel($packageid,$shop_info[0],$info);
        if($rr['code']!=0){
            return [
                'x'=>0,
                'Description'=>$rr['message'],  
            ];
        }else{
            return  [
                'x'=>1,
                'msg'=>'获取成功',
                'waybill'=>$rr['data']['tracking_number'],
                'label'=>$rr['data']['doc_url'],
            ];
        }
    }
    private function getFBTPackage($info,$shop_info){
        
        $extra_text = $info['extra_text'];
        if(is_string($extra_text)){
            $extra_text = json_decode($extra_text,true);
        }
        $packages = $extra_text['packages'];
        $packageid = $packages[0]['id'];
        if(!isset($extra_text['is_send'])){
            $rr1 = $this->apitt->ShipByTiktok($packageid,$shop_info[0],$info);
            if(!isset($rr1['code'])){
                //避免因为网络原因获取信息失败，再次尝试获取
                usleep(100);
                $rr1 = $this->apitt->ShipByTiktok($packageid,$shop_info[0],$info);
                if(!isset($rr1['code'])){
                    return [
                        'x'=>0,
                        'Description'=>"Tiktok接口异常,请重试",  
                    ];
                }
            }
            if(($rr1['code'] == 0) && ($rr1['message'] == 'Success')){
                $extra_text['is_send'] = 1;
                $this->db->update('fullordertt', [
                    'extra_text' => json_encode($extra_text,JSON_UNESCAPED_UNICODE)
                ], ['id' => $info['id']]) ;
            }else{
               
                return [
                    'x'=>0,
                    'Description'=>$rr1['message'],  
                ];
            }
        }
        // if(!isset($extra_text['server_info'])){
        //     $rr1 = $this->getExpressCompany($info,$shop_info[0]);
        //     if($rr1['x'] == 0){
        //         return $rr1;
        //     }
        //     $info = $rr1['data'];
        //     if(is_string($info['extra_text'])){
        //         $info['extra_text'] = json_decode($info['extra_text'],true);
        //     }
        // }
        // 确定没有多包裹的情况 就不再写循环了 直接获取第一个包裹
        // foreach($packages as $package){
        //     $rr = $this->apitt->downloadLabel($package['id'],$shop_info[0],$info);
        //     if($rr['code']!=0){
        //         $flag_status = 1;
        //         $err_arr[] = $rr['message'];
        //     }else{
        //         $label_list[] = [
        //             'waybill'=>$rr['data']['tracking_number'],
        //             'label'=>$rr['data']['doc_url'],
        //         ];
        //     }
        // }

        $rr = $this->apitt->downloadLabel($packageid,$shop_info[0],$info);
        if(!isset($rr['code'])){
            usleep(100);
            $rr = $this->apitt->downloadLabel($packageid,$shop_info[0],$info);
            if(!isset($rr['code'])){
                return [
                    'x'=>0,
                    'Description'=>"tiktok获取快递面单异常,请重试",  
                ];
            }
        }
        if($rr['code']!=0){
            return [
                'x'=>0,
                'Description'=>$rr['message'],  
            ];
        }else{
            return  [
                'x'=>1,
                'msg'=>'获取成功',
                'waybill'=>$rr['data']['tracking_number'],
                'label'=>$rr['data']['doc_url'],
            ];
        }
    }
    private function getOrderDetail($info,$shop_info){

    }
   
    //获取订单承运的快递商
    private function getExpressCompany($info,$shop_info){
        if(is_string($info['extra_text'])){
            $extra_text = json_decode($info['extra_text'],true);
        }else{
            $extra_text = $info['extra_text'];
        }
        if(isset($extra_text['server_info'])){
            return  [
                'x'=>1,
                'msg'=>'获取成功1',
                'data'=>$info
            ];
        }
        $res = $this->apitt->getExpressCompany($info,$shop_info);
        if(empty($res)){
            return  [
                'x'=>0,
                'Description'=>"返回信息为空",
            ];
        }
        if($res['code'] != 0){
            return  [
                'x'=>0,
                'Description'=>$res['message'],
            ];
        }
        $extra_text = json_decode($info['extra_text'],true);
        $extra_text['server_info'] = $res['data'];
        $info['extra_text'] = json_encode($extra_text,JSON_UNESCAPED_UNICODE);
        if($info['ttsp_status'] == 0){
            $this->db->update('fullordertt', [
                'extra_text' => $info['extra_text'],
                'ttsp_status' => 1
            ], ['id' => $info['id']]) ;
        }else{
            $this->db->update('fullordertt', [
                'extra_text' => $info['extra_text']
            ], ['id' => $info['id']]) ;
        }
       
        return  [
            'x'=>1,
            'msg'=>'获取成功1',
            'data'=>$info
        ];
    }

    //创建发货单和运单标签
    public function createExpressLabel($info,$shop_info){
        if(is_string($info['extra_text'])){
            $extra_text = json_decode($info['extra_text'],true);
        }else{
            $extra_text = $info['extra_text'];
        }
        if(isset($extra_text['label_info'])){
            return  [
                'x'=>1,
                'msg'=>'获取成功2',
                'data'=>$info
            ];
        }
        $res = $this->apitt->createLabel($info,$shop_info);
        if(empty($res)){
            return  [
                'x'=>0,
                'Description'=>"返回信息为空",
            ];
        }
        if(strpos($res['message'],'These orders are already shipped.')!== false){
            return  $this->getDetail($info,$shop_info);
        }
        if($res['code'] != 0){
            return  [
                'x'=>0,
                'Description'=>$res['message'],
            ];      
        }
        $extra_text = json_decode($info['extra_text'],true);
        $extra_text['label_info'] = $res['data'];
        $info['extra_text'] = json_encode($extra_text,JSON_UNESCAPED_UNICODE);
        $this->db->update('fullordertt', [
            'extra_text' => $info['extra_text']
        ], ['id' => $info['id']]) ;
        return  [
            'x'=>1,
            'msg'=>'获取成功2',
            'data'=>$info
        ];
        

    }

    private function getDetail($info,$shop_info){
        if(is_string($info['extra_text'])){
            $extra_text = json_decode($info['extra_text'],true);
        }else{
            $extra_text = $info['extra_text'];
        }
        $ret_info = $this->apitt->get_detail($info['orderinfo'],$shop_info);
        if(empty($ret_info)){
            return  [
                'x'=>0,
                'Description'=>"获取订单详细信息失败1",
            ];
        }
        if($ret_info['code'] != 0){
            return [
                'x'=>0,
                'Description'=>"获取订单详细信息失败2",
            ];
        }
        if(empty($ret_info['data']['orders'])){
            return [
                'x'=>0,
                'Description'=>"获取订单详细信息失败3",
            ];
        }
        $packages = $ret_info['data']['orders'][0]['packages'];
        if(empty($packages)){
            return [
                'x'=>0,
                'Description'=>"包裹信息异常不存在",
            ];
        }
        $package_id = $packages[0]['id'];
        $extra_text['label_info'] = ['package_id'=>$package_id];
        $info['extra_text'] = json_encode($extra_text,JSON_UNESCAPED_UNICODE);
        $this->db->update('fullordertt', [
            'extra_text' => $info['extra_text']
        ], ['id' => $info['id']]) ;
        return  [
            'x'=>1,
            'msg'=>'获取成功2',
            'data'=>$info
        ];
    }
    
    public function downloadCbtConbinLabel($info,$shop){
        if(is_string($info['extra_text'])){
            $extra_text = json_decode($info['extra_text'],true);
        }else{
            $extra_text = $info['extra_text'];
        }
        $packageid = $extra_text['label_info']['package_id'];
        $res = $this->apitt->downloadLabel($packageid,$shop,$info);
        //允许二次请求吧  tiktok接口有时候会返回很奇葩的错误
        if( empty($res) || $res['code'] != 0){
            $res = $this->apitt->downloadLabel($packageid,$shop,$info);
            usleep(100);
            if(empty($res) || $res['code'] != 0){
                return  [
                    'x'=>0,
                    'Description'=>$res['message'],
                ]; 
            }
                
        } 
        $extra_text = json_decode($info['extra_text'],true);
        $extra_text['express_info'] = $res['data'];
        $info['extra_text'] = json_encode($extra_text,JSON_UNESCAPED_UNICODE);
        $this->db->update('fullordertt', [
            'extra_text' => $info['extra_text']
        ], ['id' => $info['id']]) ;
        return  [
            'x'=>1,
            'msg'=>'获取成功3',
            'waybill'=>$res['data']['tracking_number'],
            'label'=>$res['data']['doc_url'],
        ];
        
    }
    //下载快递面单
    public function downloadExpressLabel($info,$shop){
        if(is_string($info['extra_text'])){
            $extra_text = json_decode($info['extra_text'],true);
        }else{
            $extra_text = $info['extra_text'];
        }
        $packageid = $extra_text['label_info']['package_id'];
        $res = $this->apitt->downloadLabel($packageid,$shop,$info);
        //允许二次请求吧  tiktok接口有时候会返回很奇葩的错误
        if( empty($res) || $res['code'] != 0){
            $res = $this->apitt->downloadLabel($packageid,$shop,$info);
            usleep(100);
            if(empty($res) || $res['code'] != 0){
                return  [
                    'x'=>0,
                    'Description'=>$res['message'],
                ]; 
            }
                
        } 
        $extra_text = json_decode($info['extra_text'],true);
        $extra_text['express_info'] = $res['data'];
        $info['extra_text'] = json_encode($extra_text,JSON_UNESCAPED_UNICODE);
        $this->db->update('fullordertt', [
            'extra_text' => $info['extra_text']
        ], ['id' => $info['id']]) ;
        return  [
            'x'=>1,
            'msg'=>'获取成功3',
            'waybill'=>$res['data']['tracking_number'],
            'label'=>$res['data']['doc_url'],
        ];
        
    }

    /**
     * 创建CBT发货单和运单标签
     */
    public function doCreateCBTLabel($info,$shop_info){
        if($info['merge'] == $info['id']){
            $extra_text = json_decode($info['extra_text'],true);
            if(is_string($extra_text)){
                $extra_text = json_decode($extra_text,true);
            }
            if(empty($extra_text['label_info'])){
                $res = $this->getDetail($info,$shop_info);
                if($res['x'] == 0){
                    return $res;
                }
                return [
                    'x'=>1,
                    'msg'=>"OK",
                    'data'=>$res['data']
                ];
            }else{
                return [
                    'x'=>1,
                    'msg'=>"OK",
                    'data'=>$info
                ];
            }
        }else{
            //获取快递服务信息
            $res = $this->getExpressCompany($info,$shop_info);
            if($res['x'] == 0){
                return $res;
            }
            $res1 = $this->createExpressLabel($res['data'],$shop_info);
            if($res1['x'] == 0){
                return $res1;
            }
            return $res1;
        }
        
    }
    /**
     * 获取快递承运商
     */
    public function getExpressInfo($info,$shop_info){
        $res = $this->getExpressCompany($info,$shop_info);
        if($res['x'] == 0){
            return $res;
        }
        return $res;
    }

}