推送订单接口对接

application/api/controller/Test.php

@@ -0,0 +1,44 @@
+<?php
+
+namespace app\api\controller;
+
+use app\common\controller\Api;
+use app\common\service\ZopOrderService;
+
+/**
+ * 测试接口
+ */
+class Test extends Api
+{
+    protected $noNeedLogin = ['*'];
+    protected $noNeedRight = ['*'];
+
+    /**
+     * 测试方法
+     *
+     * @return void
+     */
+    public function index()
+    {
+        common_log('aaa');
+
+        $data = array("key1", "key2", "key3", "key4", "key5", "key6", "key7", "key8", "key9", "key10", "key11", "key12", "key13", "key14", "key15", "key16");
+
+        dd(array_chunk($data, 5), array_column(array_chunk($data, 5), 0));
+
+        $params = [
+            'channel' => '08-2278-ae1q-9999',
+            'goodsId' => '982012220836',
+            'resourceContents' => [
+                [
+                    'content' => 'aaa',
+                    'sort' => 1
+                ]
+            ]
+        ];
+
+        $result = ZopOrderService::resourceUpload($params);
+
+        dd($result);
+    }
+}

application/common.php

@@ -12,6 +12,7 @@ use Elastic\Elasticsearch\ClientBuilder;
 use Symfony\Component\VarExporter\VarExporter;
 use think\Cache;
 use think\exception\HttpResponseException;
+use think\Log;
 use think\Response;
 
 if (!function_exists('__')) {
@@ -710,3 +711,39 @@ function httpCurlPost($url, $data, $times = 1) {
     return $tmpInfo;
     // 返回数据
 }
+
+/**
+ * 获取指定key的值
+ *
+ * @param [type] $array
+ * @param [type] $keys
+ * @return void
+ */
+function array_only($array, $keys)
+{
+    return array_intersect_key($array, array_flip((array)$keys));
+}
+
+/**
+ * 写入日志
+ *
+ * @param mixed $data
+ *
+ * @return void
+ */
+function common_log($data = '', Throwable $e = null, $channel = 'message')
+{
+    if ($e && is_string($data)) {
+        if ($e instanceof HttpResponseException) {
+            $str = $e->getResponse()->getContent();
+            $arr = json_decode($str, true);
+
+            $message = $arr['msg'] ?? '';
+        } else {
+            $message = $e->getMessage();
+        }
+        $data .= ' 错误原因为: ' . $message . ' | 错误位置在 ' . $e->getFile() . ' 第' . $e->getLine() . '行';
+    }
+
+    Log::write($data, $channel);
+}

application/common/service/ZopBaseService.php

@@ -0,0 +1,234 @@
+<?php
+
+namespace app\common\service;
+
+use think\Log;
+
+/**
+ * 订单推送基础服务类
+ */
+class ZopBaseService
+{
+    // const ZOP_URL = 'https://demo.mall.10010.com:8104/zop';
+    const ZOP_URL = 'https://cd.10010.com/zop';
+
+    const ZOP_KEY = [
+        // 'appCode' => '36F4FB0764884970939A8962AAAED993',
+        // 'HMACMD5' => 'RIgp8DurFh1hIUOmqHTCcuK7G7GuoUQc0SP1WhasUh5ZwNHFGBPpc7ZvinlSzNAqeqMOc1Nf+FrVh2hMJEszeQ==',
+        // 'AES' => 'M5E1i/s1u4BWsocqG7zC3Q==',
+        'appCode' => '1A2715D230724895AFB318FE8919244A',
+        'HMACMD5' => 'wi/iBAuOWhfn63nEw8/yi2g1kypvdc1X7qt901z1G+uZN2JzdW0SwsxBwYDGYBDW+etr2i4V/rLpXp5yQb9BBg==',
+        'AES' => 'uH6eH0iGoFsgsfOHOF/kUw=='
+    ];
+
+    /**
+     * 正确返回
+     *
+     * @param array $data
+     * @param string $message
+     * @param integer $code
+     * @return void
+     */
+    public static function success($data = [], $message = '', $code = 0)
+    {
+        $result = compact('code', 'message', 'data');
+
+        return $result;
+    }
+
+    /**
+     * 错误返回
+     *
+     * @param string $message
+     * @param integer $code
+     * @param array $data
+     * @return void
+     */
+    public static function error($message = '', $code = 1, $data = [])
+    {
+        $result = compact('code', 'message', 'data');
+
+        return $result;
+    }
+
+    /**
+     * uuid 唯一序列码
+     * @param string $prefix
+     * 
+     * @return string
+     */
+    public static function uuid($prefix = '')
+    {
+        $chars = md5(uniqid(mt_rand(), true));
+
+        $uuid = substr($chars, 0, 8) . '-';
+        $uuid .= substr($chars, 8, 4) . '-';
+        $uuid .= substr($chars, 12, 4) . '-';
+        $uuid .= substr($chars, 16, 4) . '-';
+        $uuid .= substr($chars, 20, 12);
+
+        return $prefix . $uuid;
+    }
+
+    /**
+     * 获取当前时间毫秒
+     *
+     * @return float
+     */
+    public static function msectime()
+    {
+        list($msec, $sec) = explode(' ', microtime());
+        $msectime = (float)sprintf('%.0f', (floatval($msec) + floatval($sec)) * 1000);
+
+        return $msectime;
+    }
+
+    /**
+     * 获取时间戳
+     *
+     * @return string
+     */
+    public static function getTimestamp()
+    {
+        date_default_timezone_set('PRC');
+        $time = self::msectime();
+
+        return date('Y-m-d H:i:s.') . substr($time, -3);
+    }
+
+    /**
+     * 生成签名
+     *
+     * @param string $uuid
+     * @param string $timestamp
+     * @return string
+     */
+    public static function genSign($uuid, $timestamp)
+    {
+        $appCode = self::ZOP_KEY['appCode'] ?? '';
+        $hmacMd5 = self::ZOP_KEY['HMACMD5'] ?? '';
+
+        $dataStr = 'appCode' . $appCode . 'timestamp' . $timestamp . 'uuid' . $uuid . $hmacMd5;
+
+        return self::sign($hmacMd5, $dataStr);
+    }
+
+    /**
+     * 签名
+     * @param key 密钥  平台侧提供的HmacMD5
+     * @param dataStr appCode+appCode值+timestamp+timestamp值*+uuid+uuid值+HmacMD5密钥值
+     * 
+     * @return string
+     */
+    public static function sign($key, $dataStr)
+    {
+        return base64_encode(hash_hmac("md5", $dataStr, base64_decode($key), true));
+    }
+
+    /**
+     * AES加密
+     *
+     * @param string $params
+     * @param string $key
+     * 
+     * @return string
+     */
+    public static function encrypt($params, $key)
+    {
+        if (is_array($params)) {
+            $params = json_encode($params);
+        }
+
+        $data = openssl_encrypt($params, 'aes-128-ecb', base64_decode($key), OPENSSL_RAW_DATA);
+
+        return base64_encode($data);
+    }
+
+    /**
+     * 发送请求
+     *
+     * @param string $url
+     * @param array $postData
+     * @param boolean $isPost
+     * 
+     * @return string
+     */
+    public static function sendRequest($url, $postData, $isPost = true)
+    {
+        $optData = json_encode($postData);
+
+        $header = array();
+        $header[] = 'Accept:application/json';
+        $header[] = 'Content-Type:application/json;charset=utf-8';
+
+        $curl = curl_init();  //初始化
+        curl_setopt($curl, CURLOPT_URL, $url);  //设置url
+        curl_setopt($curl, CURLOPT_HTTPHEADER, $header);
+        curl_setopt($curl, CURLOPT_POSTFIELDS, $optData);
+        curl_setopt($curl, CURLOPT_RETURNTRANSFER, true);
+        if ($isPost) {
+            curl_setopt($curl, CURLOPT_POST, 1);
+        }
+        // 判断地址是不是https
+        if (stripos($url, 'https://') !== FALSE) {
+            curl_setopt($curl, CURLOPT_SSL_VERIFYPEER, FALSE);
+            curl_setopt($curl, CURLOPT_SSL_VERIFYHOST, 2);
+        }
+
+        $result = curl_exec($curl);
+        if($result === false){
+            common_log('发起请求失败, 失败地址为: ' . $url . ', 失败原因为: ' . curl_error($curl) . ', 失败参数为: ' . json_encode($postData, JSON_UNESCAPED_UNICODE));
+
+            return false;
+        }
+        curl_close($curl);
+
+        return $result;
+    }
+    
+    /**
+     * 发送请求
+     *
+     * @param string $urlPath
+     * @param array $params
+     * @return string
+     */
+    public static function send($urlPath = '', $params = [])
+    {
+        // 数据获取
+        $baseUrl = self::ZOP_URL;
+        $aes = self::ZOP_KEY['AES'] ?? '';
+        $appCode = self::ZOP_KEY['appCode'] ?? '';
+        
+        // 准备参数
+        $url = $baseUrl . $urlPath;
+
+        // uuid
+        $uuid = self::uuid();
+        // 生成时间戳
+        $timestamp = self::getTimestamp();
+
+        dd($timestamp);
+
+        $head = [
+            'sign' => self::genSign($uuid, $timestamp),
+            'timestamp' => $timestamp,
+            'uuid' => $uuid
+        ];
+
+        $reqObj = [
+            'head' => $head,
+            'body' => $params
+        ];
+
+        $reqObj = self::encrypt($reqObj, $aes);
+
+        $reqParam = [
+            'appCode' => $appCode,
+            'reqObj' => $reqObj
+        ];
+        $result = self::sendRequest($url, $reqParam);
+
+        return $result;
+    }
+}

application/common/service/ZopOrderService.php

@@ -0,0 +1,199 @@
+<?php
+
+namespace app\common\service;
+
+/**
+ * 联通商城zop订单统一接入文档
+ */
+class ZopOrderService extends ZopBaseService
+{
+    /**
+     * 资源上传
+     *
+     * @param array $params [channel: 渠道, goodsId: 商品ID, resourceContents: [content: 资源内容, sort: 排序]]]
+     * @return array
+     */
+    public static function resourceUpload($params = [])
+    {
+        $url = '/link/king/resource/upload/v1';
+
+        $data = array_only($params, [
+            'channel',
+            'goodsId',
+            'resourceContents'
+        ]);
+
+        $result = self::send($url, $data);
+        if (empty($result)) {
+            return self::error('请求失败');
+        }
+
+        $resArr = json_decode($result, true);
+
+        if ($resArr['rspCode'] != '0000') {
+            return self::error($resArr['rspDesc']);
+        }
+
+        $body = $resArr['body'];
+
+        return self::success($body);
+    }
+
+    /**
+     * 客户资料校验
+     *
+     * @param array $params [province: 省份编码, city.地市编码, certName. 证件姓名, certNum. 证件编码]
+     * @return array
+     */
+    public static function identityCust($params = [])
+    {
+        $url = '/link/king/identity/cust/v2';
+
+        $data = array_only($params, [
+            'province',
+            'city',
+            'certName',
+            'certNum'
+        ]);
+
+        $result = self::send($url, $data);
+        if (empty($result)) {
+            return self::error('请求失败');
+        }
+        $resArr = json_decode($result, true);
+
+        if ($resArr['aCode'] != '0000') {
+            return self::error($resArr['aDesc']);
+        }
+        if ($resArr['bCode'] != '0000') {
+            return self::error($resArr['bDesc']);
+        }
+
+        $uuid = $resArr['uuid'] ?? '';
+
+        return self::success(['uuid' => $uuid]);
+    }
+
+    /**
+     * 选号后置-意向单同步
+     *
+     * @param array $params [orderId: 订单ID, goodsId: 商品ID, certName: 证件姓名, certNo: 证件编码, contactNum: 联系电话, postProvinceCode: 省份编码, postCityCode: 地市编码, postDistrictCode: 区县编码, postAddr: 详细地址, channel: 渠道, createTime: 创建时间, updateTime: 更新时间, orderTotalFee: 订单总金额, pageUrl: 页面地址, resourceId: 资源ID]
+     * @return array
+     */
+    public static function preOrdersync($params = [])
+    {
+        $url = '/link/king/card/preOrder/preOrdersync';
+
+        $data = array_only($params, [
+            'orderId',
+            'goodsId',
+            'certName',
+            'certNo',
+            'contactNum',
+            'postProvinceCode',
+            'postCityCode',
+            'postDistrictCode',
+            'postAddr',
+            'channel',
+            'createTime',
+            'updateTime',
+            'orderTotalFee',
+            'pageUrl',
+            'resourceId'
+        ]);
+
+        $result = self::send($url, $data);
+        if (empty($result)) {
+            return self::error('请求失败');
+        }
+        $resArr = json_decode($result, true);
+
+        if ($resArr['rspCode'] != '0000') {
+            return self::error($resArr['rspDesc']);
+        }
+
+        $body = $resArr['body'] ?? '';
+        if (is_string($body)) {
+            $body = json_decode($body, true);
+        }
+
+        return self::success($body);
+    }
+
+    /**
+     * 选号服务
+     *
+     * @param array $params [goodsId: 商品ID, provinceCode: 省份编码, cityCode: 地市编码, searchCategory: 搜索类别: 1、普通选号 2、靓号选号 3、全部（普通、靓号都包括）]
+     * @return array
+     */
+    public static function linkNumSelect($params = [])
+    {
+        $url = '/link/num/select/v1';
+
+        $data = array_only($params ,[
+            'goodsId',
+            'provinceCode',
+            'cityCode',
+            'searchCategory',
+        ]);
+        $data['qryType'] = '02';
+
+        $result = self::send($url, $data);
+        if (empty($result)) {
+            return self::error('请求失败');
+        }
+        $resArr = json_decode($result, true);
+
+        if ($resArr['rspCode'] != 'M0') {
+            return self::error($resArr['rspDesc']);
+        }
+
+        $body = $resArr['body'] ?? '';
+        $numArray = $body['numArray'] ?? [];
+        $splitLen = $body['splitLen'] ?? 12;
+        if (!empty($numArray)) {
+            $numArray = array_column(array_chunk($numArray, $splitLen), 0);
+        }
+
+        return self::success($numArray);
+    }
+
+    /**
+     * 选号后置-正式单同步(非提前预占版)
+     *
+     * @param array $params
+     * @return array
+     */
+    public static function ordersync($params = [])
+    {
+        $url = '/link/king/card/preOrder/ordersync/v2';
+
+        $data = array_only($params, [
+            'goodsId',
+            'provinceCode',
+            'cityCode',
+            'phoneNum',
+            'token',
+            'createTime',
+            'isOpenCF'
+        ]);
+
+        $result = self::send($url, $data);
+        if (empty($result)) {
+            return self::error('请求失败');
+        }
+
+        $resArr = json_decode($result, true);
+
+        if ($resArr['rspCode'] != '0000') {
+            return self::error($resArr['rspDesc']);
+        }
+
+        $body = $resArr['body'] ?? '';
+        if (is_string($body)) {
+            $body = json_decode($body, true);
+        }
+
+        return self::success($body);
+    }
+}

application/config.php

@@ -167,7 +167,7 @@ return [
         'path'  => LOG_PATH,
         // 日志记录级别
         'level' => [],
-        'apart_level'=>['sql','error']
+        'apart_level'=>['sql','error', 'message']
     ],
     // +----------------------------------------------------------------------
     // | Trace设置 开启 app_trace 后 有效