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'){
           
           //获取快递服务信息
           $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;
           }
           $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($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);
        $this->db->update('fullordertt', [
            'extra_text' => $info['extra_text']
        ], ['id' => $info['id']]) ;
        return  [
            'x'=>1,
            'msg'=>'获取成功1',
            'data'=>$info
        ];
    }

    //创建发货单和运单标签
    private 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($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 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);
        if($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'],
        ];
        
    }


}