beauti-nof/application/service/GantanhaoService.php

<?php
namespace app\service;

use app\common\model\Mobile;
use app\common\model\MobileOrder;
use think\App;
use think\helper\Str;
use fast\Http;
use GuzzleHttp\Client;

class GantanhaoService{
    static $shareId = 310481;
    static $apiToken = 'emNApNcAmvGJu6H7HkWBD8OkmelQ4IgiLDLHqFDk8nHyr26Jah';

    /**
     * 订单同步
     */
    public static function orderPurchase(MobileOrder $order){
//        $url = 'http://notify.91haoka.cn/api/plan-market/order/purchase';
        //敢探号提单V2
        $url = 'https://notify.91haoka.cn/api/plan-market/order/purchase/v2';

        $mobile = $order['info']['mobile'];
        // $data = [
        //     'sku' => $mobile['product_no'],
        //     'source_id' => $order['order_no'],
        //     'share_id' => self::$shareId,
        //     'id_name' => $order['name'],
        //     'id_num' => $order['id_no'],
        //     'mobile' => $order['phone'],
        //     'name' => $order['name'],
        //     'address' => $order['address'],
        //     'sign' => self::orderSign($mobile['product_no'], $order['order_no'])
        // ];
        // if($mobile['card_status']){
        //     $open_idcard_face_img = parse_url($order['open_idcard_face_img']);
        //     $open_idcard_back_img = parse_url($order['open_idcard_back_img']);
        //     $open_face_img = parse_url($order['open_face_img']);
        //     $data['pic']['face'] = '@'.ROOT_PATH . 'public' .$open_idcard_face_img['path'];
        //     $data['pic']['back'] = '@'.ROOT_PATH . 'public' .$open_idcard_back_img['path'];
        //     $data['pic']['hand'] = '@'.ROOT_PATH . 'public' .$open_face_img['path'];
        // }

        $data = [
            'multipart' => [
                [
                    'name' => 'sku',
                    'contents' => $mobile['product_no']
                ],
                [
                    'name' => 'source_id',
                    'contents' => $order['order_no']
                ],
                [
                    'name' => 'share_id',
                    'contents' => self::$shareId
                ],
                [
                    'name' => 'id_name',
                    'contents' => self::encrypt($order['name'])
                ],
                [
                    'name' => 'id_num',
                    'contents' => self::encrypt($order['id_no'])
                ],
                [
                    'name' => 'mobile',
                    'contents' => self::encrypt($order['phone'])
                ],
                [
                    'name' => 'name',
                    'contents' => self::encrypt($order['name'])
                ],
                [
                    'name' => 'address',
                    'contents' => self::encrypt($order['address'])
                ],
                [
                    'name' => 'pretty_number',
                    'contents' => $order['no']
                ],
                [
                    'name' => 'sign',
                    'contents' => self::orderSign($mobile['product_no'], $order['order_no'])
                ],
            ]
        ];

        if($mobile['card_status']){
            $i = 10;
            $open_idcard_face_img = parse_url($order['open_idcard_face_img']);
            $open_idcard_back_img = parse_url($order['open_idcard_back_img']);
            $open_face_img = parse_url($order['open_face_img']);

            // $data['multipart'][9]['name'] = 'pic';
            // $data['multipart'][9]['contents'] = [
            //     'face' => fopen(ROOT_PATH . 'public' .$open_idcard_face_img['path'], 'r'),
            //     'back' => fopen(ROOT_PATH . 'public' .$open_idcard_back_img['path'], 'r'),
            //     'hand' => fopen(ROOT_PATH . 'public' .$open_face_img['path'], 'r'),
            // ];
            $data['multipart'][$i]['name'] = 'pic[face]';
            $data['multipart'][$i]['contents'] = fopen(ROOT_PATH . 'public' .$open_idcard_face_img['path'], 'r');
            $data['multipart'][$i+1]['name'] = 'pic[back]';
            $data['multipart'][$i+1]['contents'] = fopen(ROOT_PATH . 'public' .$open_idcard_back_img['path'], 'r');
            $data['multipart'][$i+2]['name'] = 'pic[hand]';
            $data['multipart'][$i+2]['contents'] = fopen(ROOT_PATH . 'public' .$open_face_img['path'], 'r');
        }

        user_log('gantanhaoService', $data);

        try{
            // $result = Http::post($url, http_build_query($data));
            $result = (new Client())->request('post', $url, $data);
            $rs = json_decode($result->getBody()->getContents(), true);
            user_log('gantanhaoService', '订单推送结果:'.json_encode($rs));

            if(is_null($rs) || $rs['msg']['code'] != 0) throw new \Exception($rs['msg']['info'] ?? '订单推送错误');

            $order['gantanhao_data'] = json_encode($rs['data']);
            if($rs['data']['status'] == 120){
                $order['status'] = 20; 
            }
            $order->save();
        }
        catch(\Exception $e){

            user_log('gantanhaoService', '订单推送:'.$e->getMessage());
            throw new \Exception($e->getMessage());
        }
    }

    /**
     * 重传身份证
     */
    public static function orderPhotos($str_rand, $data){
        $url = 'http://notify.91haoka.cn/api/plan-market/order/photos';

        $open_idcard_face_img = parse_url($data['idcard_face_img']);
        $open_idcard_back_img = parse_url($data['idcard_back_img']);
        $open_face_img = parse_url($data['face_img']);

        $body = [
            'multipart' => [
                [
                    'name' => 'str_rand',
                    'contents' => $str_rand
                ],
                [
                    'name' => 'pic[face]',
                    'contents' => fopen(ROOT_PATH . 'public' .$open_idcard_face_img['path'], 'r')
                ],
                [
                    'name' => 'pic[back]',
                    'contents' => fopen(ROOT_PATH . 'public' .$open_idcard_back_img['path'], 'r')
                ],
                [
                    'name' => 'pic[hand]',
                    'contents' => fopen(ROOT_PATH . 'public' .$open_face_img['path'], 'r')
                ],
            ]
        ];
        try{
            // $result = Http::post($url, http_build_query($data));
            $result = (new Client())->request('post', $url, $body);
            $rs = json_decode($result->getBody()->getContents(), true);
            if(is_null($rs) || $rs['msg']['code'] != 0) throw new \Exception($rs['msg']['info'] ?? '身份证推送错误');

            return true;
        }
        catch(\Exception $e){

            user_log('gantanhaoService', '身份证推送:'.$e->getMessage());
            throw new \Exception($e->getMessage());
        }
        
    }

    /**
     * 获取上传照片密钥
     */
    public static function orderPhotoEncryption(MobileOrder $order){
        $url = 'http://notify.91haoka.cn/api/plan-market/order/photo/encryption';
 
        try{
            $sign = md5('order_id='.$order['order_no'].'&share_id='.self::$shareId .self::$apiToken);

            
            if(!$order['gantanhao_data']) throw new \Exception('订单未提单');

            $gantanhao = json_decode($order['gantanhao_data'], true);
            $data = [
                'share_id' => self::$shareId,
                'order_id' => $gantanhao['data']['id'],
                'sign' => $sign
            ];

            $result = Http::post($url, http_build_query($data));
            $rs = json_decode($result, true);
            if(is_null($rs) || $rs['msg']['code'] != 0) throw new \Exception($rs['msg']['info'] ?? '获取上传照片密钥错误');

            return $rs['data']['str_rand'];
        }
        catch(\Exception $e){

            user_log('gantanhaoService', '获取上传照片密钥推送:'.$e->getMessage());
            throw new \Exception($e->getMessage());
        }
    }

    /**
     * 生成签名
     */
    public static function orderSign($sku = '', $sourceId = ''){
        if(!$sku || !$sourceId) return false;

        $str = 'share_id='.self::$shareId .'&sku='.$sku.'&source_id='.$sourceId.self::$apiToken;

        return md5($str);
    }

    /**
     * 回调验签
     */
    public static function checkSignNotify($data = []){
        if(!$data) return false;

        $str = 'outer_id='.$data['outer_id'].'&plan_mobile_produced='.$data['plan_mobile_produced'].'&status='.$data['status'].self::$apiToken;

        if(md5($str) != $data['sign']){
            return false;
        }

        return true;
    }

    /**
     * 获取选号信息
     */
    public static function getSelectNum($product_sku){
        $url = 'http://notify.91haoka.cn/api/plan-market/upstream/num/select';

        try{
            $data = [
                'product_sku' => $product_sku
            ];

            $result = Http::post($url, http_build_query($data));
            $rs = json_decode($result, true);
            if(is_null($rs) || $rs['msg']['code'] != 0) throw new \Exception($rs['msg']['info'] ?? '获取选号信息错误');

            return $rs['data'];
        }
        catch(\Exception $e){

            user_log('gantanhaoService', '获取选号信息:'.$e->getMessage());
            throw new \Exception($e->getMessage());
        }
    }

    /**
     *敢探号提单V2
     */
    public static function encrypt($data)
    {
        $aes_key = '121';
        return base64_encode(openssl_encrypt($data, 'aes-256-ecb', $aes_key, OPENSSL_RAW_DATA));
    }

    /**
     * 解密
     */
    public static function jiemi($data){
        $aes_key = '121';
        $data = base64_decode($data);
        $data = openssl_decrypt($data, 'aes-256-ecb', $aes_key, OPENSSL_RAW_DATA);
        return $data;
    }
}