init commit

addons/wdsxh/library/Wxapp.php

@@ -0,0 +1,468 @@
+<?php
+
+namespace addons\wdsxh\library;
+
+use app\admin\model\wdsxh\Config;
+use app\admin\model\wdsxh\mall\Order;
+use EasyWeChat\Factory;
+use think\Exception;
+use think\Log;
+use GuzzleHttp\Client;
+use GuzzleHttp\Psr7\Request;
+use GuzzleHttp\Pool;
+use GuzzleHttp\Exception\ClientException;
+
+/**
+ * 微信处理类
+ */
+class Wxapp
+{
+    public static function wxappInit($type = 0)
+    {
+        try {
+            $site = (new \app\admin\model\wdsxh\Config())->where('id',1)->find();
+
+            if ($type == 1) {
+                if (empty($site['mch_id'])) {
+                    throw new \think\Exception('微信支付商户号未配置');
+                }
+                if (empty($site['key'])) {
+                    throw new \think\Exception('微信支付秘钥未配置');
+                }
+            }
+            $appid = trim($site['applet_appid']);
+            $secret = trim($site['applet_secret']);
+            if ($type == 2) {
+                $appid = trim($site['wananchi_appid']);
+                $secret = trim($site['wananchi_secret']);
+            }
+
+            $config = [
+                'app_id' => $appid,
+                'secret' => $secret,
+                'mch_id' => empty($site['mch_id']) ? '' : trim($site['mch_id']),
+                'key' => empty($site['key']) ? '' : trim($site['key']),
+                'cert_path' => empty($site['cert_path']) ? '' : ROOT_PATH . 'public' . trim($site['cert_path']),
+                'key_path' => empty($site['key_path']) ? '' : ROOT_PATH . 'public' . trim($site['key_path']),
+                'notify_url' => '',
+                'response_type' => 'array',
+                'log' => [
+                    'level' => 'debug',
+                    'file' => RUNTIME_PATH . 'wechat.log',
+                ],
+            ];
+            if ($type == 0) {
+                return Factory::miniProgram($config);
+            } else {
+                return Factory::payment($config);
+            }
+        } catch (Exception $e) {
+            die($e->getMessage());
+        }
+    }
+
+    public static function getApp()
+    {
+        return self::wxappInit();
+    }
+
+    public static function getPay()
+    {
+        return self::wxappInit(1);
+    }
+
+    public static function getPayWxofficial()
+    {
+        return self::wxappInit(2);
+    }
+
+    public static function wxlogin($code)
+    {
+        return self::getApp()->auth->session($code);
+    }
+
+    public static function unify($body, $sn, $money, $openid, $notify_url)
+    {
+        $pay = self::getPay();
+        $result = $pay->order->unify([
+            'body' => $body,
+            'out_trade_no' => $sn,
+            'total_fee' => $money * 100,
+            'notify_url' => $notify_url,
+            'trade_type' => 'JSAPI',
+            'openid' => $openid,
+        ]);
+        if ($result && $result['return_code'] == 'SUCCESS' && $result['result_code'] == 'SUCCESS' && isset($result['prepay_id'])) {
+            return $pay->jssdk->bridgeConfig($result['prepay_id'], false);
+        } else {
+            Log::record([
+                'body' => $body,
+                'out_trade_no' => $sn,
+                'total_fee' => $money * 100,
+                'notify_url' => $notify_url,
+                'trade_type' => 'JSAPI',
+                'openid' => $openid,
+            ], 'info');
+            Log::record($result, 'info');
+            throw new \think\Exception(isset($result['return_msg']) ? $result['return_msg'] : '统一下单发生错误');
+        }
+    }
+
+    public static function unify_wxofficial($body, $sn, $money, $openid, $notify_url)
+    {
+        $pay = self::getPayWxofficial();
+        $result = $pay->order->unify([
+            'body' => $body,
+            'out_trade_no' => $sn,
+            'total_fee' => $money * 100,
+            'notify_url' => $notify_url,
+            'trade_type' => 'JSAPI',
+            'openid' => $openid,
+        ]);
+
+        if ($result && $result['return_code'] == 'SUCCESS' && $result['result_code'] == 'SUCCESS' && isset($result['prepay_id'])) {
+            return $pay->jssdk->bridgeConfig($result['prepay_id'], false);
+        } else {
+            Log::record([
+                'body' => $body,
+                'out_trade_no' => $sn,
+                'total_fee' => $money * 100,
+                'notify_url' => $notify_url,
+                'trade_type' => 'JSAPI',
+                'openid' => $openid,
+            ], 'info');
+            Log::record($result, 'info');
+            throw new \think\Exception(isset($result['err_code_des']) ? $result['err_code_des'] : '统一下单发生错误');
+        }
+    }
+
+    public static function weixinunify($body, $sn, $money, $openid, $notify_url)
+    {
+        $pay = self::getPay();
+        $result = $pay->order->unify([
+            'body' => $body,
+            'out_trade_no' => $sn,
+            'total_fee' => $money * 100,
+            'notify_url' => $notify_url,
+            'trade_type' => 'MWEB',
+            'openid' => $openid,
+        ]);
+        p($result);
+        if ($result && $result['return_code'] == 'SUCCESS' && $result['result_code'] == 'SUCCESS' && isset($result['prepay_id'])) {
+            return $pay->jssdk->bridgeConfig($result['prepay_id'], false);
+        } else {
+            Log::record([
+                'body' => $body,
+                'out_trade_no' => $sn,
+                'total_fee' => $money * 100,
+                'notify_url' => $notify_url,
+                'trade_type' => 'JSAPI',
+                'openid' => $openid,
+            ], 'info');
+            Log::record($result, 'info');
+            throw new \think\Exception(isset($result['return_msg']) ? $result['return_msg'] : '统一下单发生错误');
+        }
+    }
+
+    /*
+     * 退款操作
+     */
+    public static function payRefund($number, $refundNumber, $refundFee, $config = null)
+    {
+        $pay = self::getPay();
+        try {
+            $result = $pay->refund->byOutTradeNumber($number, $refundNumber, intval($refundFee * 100), intval($refundFee * 100), $config ? $config : [
+                'refund_desc' => '支付后退款',
+            ]);
+        } catch (\Exception $e) {
+            die($e->getMessage());
+        }
+        return $result;
+    }
+
+    public static function phone($code, $iv, $encryptedData)
+    {
+        $app = self::getApp();
+        $openid = $app->auth->session($code);
+        if (empty($openid['openid']) || empty($openid['session_key'])) {
+            throw new \think\Exception('小程序登录失败');
+        }
+        return $app->encryptor->decryptData($openid['session_key'], $iv, $encryptedData);
+    }
+
+    public static function getQrcode($path)
+    {
+        $app = self::getApp();
+        $response = $app->app_code->get($path, array('width' => 280, 'is_hyaline' => true));
+        //$response = $app->app_code->getQrCode($path,280);
+        if ($response instanceof \EasyWeChat\Kernel\Http\StreamResponse) {
+            $savePath = ROOT_PATH . 'public' . DS . 'uploads'.DS.'wdsxh'.DS.'qrcode' . DS;
+            if (!is_dir($savePath)) {
+                mkdir($savePath, 0777, true);
+            }
+            $filename = time() . mt_rand(1000, 9999) . '.png';
+            $response->saveAs($savePath, $filename);
+            return $savePath . $filename;
+        }
+        return false;
+    }
+
+    public static function subscribeMessage($template_id, $openid, $page, $data)
+    {
+        if(empty($template_id) || empty($openid) || empty($data)){
+            return false;
+        }
+        $app = self::getApp();
+        $accessToken = $app->access_token;
+        $token = $accessToken->getToken(true);
+        $url = "https://api.weixin.qq.com/cgi-bin/message/subscribe/send?access_token={$token['access_token']}";
+        $content = [
+            'template_id' => trim($template_id),
+            'touser' => '',
+            'page' => trim($page),
+            'data' => $data,
+        ];
+        //$response=$app->subscribe_message->send($data);
+        $client = new Client();
+        $openids = [];
+        if (is_string($openid)) {
+            $openids[] = $openid;
+        } elseif (is_array($openid)) {
+            $openids = $openid;
+        } else {
+            throw new Exception('openid类型错误');
+        }
+        try {
+            $requests = function ($total) use ($client, $url, $content, $openids) {
+                foreach ($openids as $row) {
+                    $content['touser'] = $row;
+                    yield function () use ($client, $url, $content) {
+                        $options = [
+                            'headers' => ['Content-Type' => 'application/json'],
+                            'body' => json_encode($content)
+                        ];
+                        return $client->postAsync($url, $options);
+                    };
+                }
+            };
+            $res = [];
+            $pool = new Pool($client, $requests(count($openids)), [
+                'concurrency' => count($openids),
+                'fulfilled' => function ($response, $index) use (&$res) {
+                    $res[$index] = json_decode($response->getBody()->getContents(), true);
+                },
+                'rejected' => function ($reason, $index) use (&$res) {
+                    $res[$index] = $reason;
+                },
+            ]);
+            $promise = $pool->promise();
+            $promise->wait();
+        } catch (Exception $e) {
+            throw new Exception($e->getMessage());
+        } catch (ClientException $e) {
+            throw new Exception($e->getMessage());
+        }
+        return $res;
+    }
+
+    public static function uniformSend($openid, $mp_template_msg)
+    {
+        $app = self::getApp();
+        $accessToken = $app->access_token;
+        $token = $accessToken->getToken();
+        $url = 'https://api.weixin.qq.com/cgi-bin/message/wxopen/template/uniform_send?access_token=' . $token['access_token'];
+        $data = [
+            'touser' => $openid,
+            'mp_template_msg' => $mp_template_msg
+        ];
+        $response = self::httpPost($url, $data);
+
+    }
+
+    private static function httpPost($url, $data)
+    {
+        $curlPost = json_encode($data);
+        $curl = curl_init();
+        curl_setopt($curl, CURLOPT_URL, $url);
+        curl_setopt($curl, CURLOPT_HEADER, false);
+        curl_setopt($curl, CURLOPT_RETURNTRANSFER, true);
+        curl_setopt($curl, CURLOPT_NOBODY, true);
+        curl_setopt($curl, CURLOPT_POST, true);
+        curl_setopt($curl, CURLOPT_POSTFIELDS, $curlPost);
+        $return_str = curl_exec($curl);
+        curl_close($curl);
+        return $return_str;
+    }
+
+    public static function checkSecurityText($openId,$content)
+    {
+        $app = self::getApp();
+        $accessToken = $app->access_token;
+        $token = $accessToken->getToken();
+        $url = "https://api.weixin.qq.com/wxa/msg_sec_check?access_token=".$token['access_token'];
+        $data = [
+            'openid' => $openId,
+            'scene' => 2,
+            'version' => 2,
+            'content' => $content,
+        ];
+        $response = self::httpPostCheckText($url, $data);
+
+        $result = json_decode($response,true);
+        if ($result['errcode'] != 0) {
+            if ($result['errcode'] == 40001) {
+                $token = $accessToken->getToken(true);
+                $url = "https://api.weixin.qq.com/wxa/msg_sec_check?access_token=".$token['access_token'];
+                $fileType = mb_detect_encoding($content, array('UTF-8','GBK','LATIN1','BIG5'));
+                if($fileType != 'UTF-8') {
+                    $content = mb_convert_encoding($content ,'utf-8', $fileType);
+                }
+                $data = [
+                    'openid' => $openId,
+                    'scene' => 2,
+                    'version' => 2,
+                    'content' => $content,
+                ];
+                $response = self::httpPostCheckText($url, $data);
+                $result = json_decode($response,true);
+            }
+            return $result;
+        }
+        if (isset($result['errcode']) && $result['errcode'] == 0 && isset($result['result']) && $result['result']['suggest']=='pass') {
+            return 1;
+        } else {
+            return 2;
+        }
+    }
+
+    private static function httpPostCheckText($url, $data)
+    {
+        $curlPost = json_encode($data, JSON_UNESCAPED_UNICODE);
+        $curl = curl_init();
+        curl_setopt($curl, CURLOPT_URL, $url);
+        curl_setopt($curl, CURLOPT_HEADER, false);
+        curl_setopt($curl, CURLOPT_RETURNTRANSFER, true);
+        curl_setopt($curl, CURLOPT_NOBODY, true);
+        curl_setopt($curl, CURLOPT_POST, true);
+        curl_setopt($curl, CURLOPT_POSTFIELDS, $curlPost);
+        $return_str = curl_exec($curl);
+        curl_close($curl);
+        return $return_str;
+    }
+
+    //订单发货
+    //$order_number_type = 订单单号类型，用于确认需要上传详情的订单。枚举值1，使用下单商户号和商户侧单号；枚举值2，使用微信支付单号
+    //transaction_id = 原支付交易对应的微信订单号
+    //delivery_mode = 发货模式，发货模式枚举值：1、UNIFIED_DELIVERY（统一发货）2、SPLIT_DELIVERY（分拆发货） 示例值: UNIFIED_DELIVERY
+    //logistics_type = 物流模式，发货方式枚举值：1、实体物流配送采用快递公司进行实体物流配送形式 2、同城配送 3、虚拟商品，虚拟商品，例如话费充值，点卡等，无实体配送形式 4、用户自提
+    //tracking_no = 物流单号，物流快递发货时必填，示例值: 323244567777 字符字节限制: [1, 128]
+    //express_company = 物流公司编码，快递公司ID，参见「查询物流公司编码列表」，物流快递发货时必填， 示例值: DHL 字符字节限制: [1, 128]
+    //item_desc = 商品信息，例如：微信红包抱枕*1个，限120个字以内
+    //consignor_contact = 寄件人联系方式，寄件人联系方式，采用掩码传输，最后4位数字不能打掩码 示例值: `189****1234, 021-****1234, ****1234, 0**2-***1234, 0**2-******23-10, ****123-8008` 值限制: 0 ≤ value ≤ 1024
+    //upload_time =  上传时间，用于标识请求的先后顺序 示例值: `2022-12-15T13:29:35.120+08:00`
+    //openid =  用户标识，用户在小程序appid下的唯一标识。 下单前需获取到用户的Openid 示例值: oUpF8uMuAJO_M2pxb1Q9zNjWeS6o 字符字节限制: [1, 128]
+    public static function upload_shipping_info($order_number_type,$transaction_id,$delivery_mode,$logistics_type,$tracking_no,$express_company,$item_desc,$consignor_contact,$openid)
+    {
+        $app = self::getApp();
+        $accessToken = $app->access_token;
+        $token = $accessToken->getToken();
+        $url = 'https://api.weixin.qq.com/wxa/sec/order/upload_shipping_info?access_token='.$token['access_token'];
+        $data = [
+            'order_key' => [
+                'order_number_type' => $order_number_type,
+                'transaction_id' => $transaction_id,
+            ],
+            'delivery_mode' => $delivery_mode,
+            'logistics_type' => $logistics_type,
+            'shipping_list' => [
+                [
+                    'tracking_no' => $tracking_no,
+                    'express_company' => $express_company,
+                    'item_desc' => $item_desc,
+                    'contact' => [
+                        'consignor_contact' => '+86-'.$consignor_contact,
+                    ],
+                ],
+            ],
+            'upload_time' => date('Y-m-d',time()).'T'.date('h:i:s',time()).'.120+08:00',
+            'payer' => [
+                'openid' => $openid,
+            ],
+        ];
+        Log::record($data,'delivery_data');
+        $response = self::httpPosts($url, $data);
+        $response = json_decode($response, true);
+        if ($response['errcode'] == 0){
+            $data = [
+                'code' => $response['errcode'],
+                'errmsg' => $response['errmsg'],
+            ];;
+            return $data;
+        }else{
+            $data = [
+                'code' => $response['errcode'],
+                'errmsg' => $response['errmsg'],
+            ];
+        }
+        return $data;
+    }
+
+
+
+
+    public static function get_order($transaction_id)
+    {
+        $app = self::getApp();
+        $accessToken = $app->access_token;
+        $token = $accessToken->getToken();
+        $url = 'https://api.weixin.qq.com/wxa/sec/order/get_order?access_token='.$token['access_token'];
+        $data = [
+            'transaction_id' => $transaction_id,
+            "merchant_id"=> (new Config())->where('id',1)->value('mch_id'),
+            "merchant_trade_no"=> (new Order())->where('trade_no',$transaction_id)->value('order_no'),
+        ];
+        Log::record($data,'get_order');
+        $response = self::httpPosts($url, $data);
+        $response = json_decode($response, true);
+        if ($response['errcode'] == 0){
+            $data = [
+                'code' => $response['errcode'],
+                'errmsg' => $response['errmsg'],
+                'order'=>isset($response['order']) ? $response['order'] : [],
+            ];;
+            return $data;
+        }else{
+            $data = [
+                'code' => $response['errcode'],
+                'errmsg' => $response['errmsg'],
+            ];
+        }
+        return $data;
+    }
+
+    private static function httpPosts($url, $data)
+    {
+        $curlPost = json_encode($data, JSON_UNESCAPED_UNICODE); // 确保以 UTF-8 编码发送数据
+        $curl = curl_init();
+        curl_setopt($curl, CURLOPT_URL, $url);
+        curl_setopt($curl, CURLOPT_HEADER, false);
+        curl_setopt($curl, CURLOPT_RETURNTRANSFER, true); // 允许获取返回内容
+        curl_setopt($curl, CURLOPT_POST, true);
+        curl_setopt($curl, CURLOPT_POSTFIELDS, $curlPost);
+
+        // 设置 HTTP 头信息，确保是 UTF-8 编码
+        curl_setopt($curl, CURLOPT_HTTPHEADER, [
+            'Content-Type: application/json; charset=UTF-8',
+        ]);
+        $return_str = curl_exec($curl);
+        // 错误检查
+        if(curl_errno($curl)) {
+            // 错误处理
+            echo 'Curl error: ' . curl_error($curl);
+        }
+        curl_close($curl);
+        // 返回响应结果
+        return $return_str;
+    }
+
+}