1

app/api/controller/v1/Weixin.php

@@ -73,15 +73,16 @@ class Weixin extends BaseController
         if (!$code)
             return app('json')->fail('授权失败,参数有误');
         try {
-            $appid = "wxb4c2433f398a6a48";
-            $secret = "3fb376e8197f3fb9670644adbcabae59";
-            $c= file_get_contents("https://api.weixin.qq.com/sns/jscode2session?appid=".$appid."&secret=".$secret."&js_code=".$code."&grant_type=authorization_code");
-            dump(json_encode($c));//对JSON格式的字符串进行编码
+//            $appid = "wxb4c2433f398a6a48";
+//            $secret = "3fb376e8197f3fb9670644adbcabae59";
+//            $c= file_get_contents("https://api.weixin.qq.com/sns/jscode2session?appid=".$appid."&secret=".$secret."&js_code=".$code."&grant_type=authorization_code");
+//            dump(json_encode($c));//对JSON格式的字符串进行编码
 
-//            $userInfoCong = MiniProgramService::getUserInfo($code);
-//            $session_key = $userInfoCong['session_key'];
-//            $openid = $userInfoCong['openid'];
-//            $unionid = $userInfoCong['unionid'];
+            $userInfoCong = MiniProgramService::getUserInfo($code);
+            dump($userInfoCong);die;
+            $session_key = $userInfoCong['session_key'];
+            $openid = $userInfoCong['openid'];
+            $unionid = $userInfoCong['unionid'];
         } catch (\Exception $e) {
             return app('json')->fail('获取session_key失败，请检查您的配置！', ['line' => $e->getLine(), 'message' => $e->getMessage()]);
         }

library/services/MiniProgramService.php

@@ -0,0 +1,326 @@
+<?php
+
+namespace library\services;
+
+use EasyWeChat\Foundation\Application;
+use think\facade\Route as Url;
+
+/**微信小程序接口
+ * Class WechatMinService
+ * @package service
+ */
+class MiniProgramService
+{
+    private static $instance = null;
+
+    public function register($config)
+    {
+        return ['mini_program', new self()];
+    }
+
+    public static function options()
+    {
+        $config = [];
+        $config['mini_program'] = [
+            'app_id' => 'wxb4c2433f398a6a48',
+            'secret' => '3fb376e8197f3fb9670644adbcabae59',
+            'token' => '',
+            'aes_key' => ''
+        ];
+        return $config;
+    }
+
+    public static function application($cache = false)
+    {
+        (self::$instance === null || $cache === true) && (self::$instance = new Application(self::options()));
+        return self::$instance;
+    }
+
+    /**
+     * 小程序接口
+     * @return \EasyWeChat\MiniProgram\MiniProgram
+     */
+    public static function miniprogram()
+    {
+        return self::application()->mini_program;
+    }
+
+    /**
+     * 获得用户信息 根据code 获取session_key
+     * @param array|string $openid
+     * @return $userInfo
+     */
+    public static function getUserInfo($code)
+    {
+        $userInfo = self::miniprogram()->sns->getSessionKey($code);
+        return $userInfo;
+    }
+
+    /**
+     * 加密数据解密
+     * @param $sessionKey
+     * @param $iv
+     * @param $encryptData
+     * @return $userInfo
+     */
+    public static function encryptor($sessionKey, $iv, $encryptData)
+    {
+        return self::miniprogram()->encryptor->decryptData($sessionKey, $iv, $encryptData);
+    }
+
+    /**
+     * 上传临时素材接口
+     * @return \EasyWeChat\Material\Temporary
+     */
+    public static function materialTemporaryService()
+    {
+        return self::miniprogram()->material_temporary;
+    }
+
+    /**
+     * 客服消息接口
+     * @param null $to
+     * @param null $message
+     */
+    public static function staffService()
+    {
+        return self::miniprogram()->staff;
+    }
+
+    /**
+     * 微信小程序二维码生成接口
+     * @return \EasyWeChat\QRCode\QRCode
+     */
+    public static function qrcodeService()
+    {
+        return self::miniprogram()->qrcode;
+    }
+
+    /**微信小程序二维码生成接口不限量永久
+     * @param $scene
+     * @param null $page
+     * @param null $width
+     * @param null $autoColor
+     * @param array $lineColor
+     * @return \Psr\Http\Message\StreamInterface
+     */
+    public static function appCodeUnlimitService($scene, $page = null, $width = 430, $autoColor = false, $lineColor = ['r' => 0, 'g' => 0, 'b' => 0])
+    {
+        return self::qrcodeService()->appCodeUnlimit($scene, $page, $width, $autoColor, $lineColor);
+    }
+
+
+    /**
+     * 模板消息接口
+     * @return \EasyWeChat\Notice\Notice
+     */
+    public static function noticeService()
+    {
+        return self::miniprogram()->notice;
+    }
+
+    /**
+     * 订阅模板消息接口
+     * @return \crmeb\services\subscribe\ProgramSubscribe
+     */
+    public static function SubscribenoticeService()
+    {
+        return self::miniprogram()->now_notice;
+    }
+
+    /**
+     * 发送订阅消息
+     * @param string $touser 接收者（用户）的 openid
+     * @param string $templateId 所需下发的订阅模板id
+     * @param array $data 模板内容，格式形如 { "key1": { "value": any }, "key2": { "value": any } }
+     * @param string $link 击模板卡片后的跳转页面，仅限本小程序内的页面。支持带参数,（示例index?foo=bar）。该字段不填则模板无跳转。
+     * @return \EasyWeChat\Support\Collection|null
+     * @throws \EasyWeChat\Core\Exceptions\HttpException
+     * @throws \EasyWeChat\Core\Exceptions\InvalidArgumentException
+     */
+    public static function sendSubscribeTemlate(string $touser, string $templateId, array $data, string $link = '')
+    {
+        return self::SubscribenoticeService()->to($touser)->template($templateId)->andData($data)->withUrl($link)->send();
+    }
+
+    /**
+     * 支付
+     * @return \EasyWeChat\Payment\Payment
+     */
+    public static function paymentService()
+    {
+        return self::application()->payment;
+    }
+
+    /**
+     * 生成支付订单对象
+     * @param $openid
+     * @param $out_trade_no
+     * @param $total_fee
+     * @param $attach
+     * @param $body
+     * @param string $detail
+     * @param string $trade_type
+     * @param array $options
+     * @return Order
+     */
+    protected static function paymentOrder($openid, $out_trade_no, $total_fee, $attach, $body, $detail = '', $trade_type = 'JSAPI', $options = [])
+    {
+        $total_fee = bcmul($total_fee, 100, 0);
+        $order = array_merge(compact('openid', 'out_trade_no', 'total_fee', 'attach', 'body', 'detail', 'trade_type'), $options);
+        if ($order['detail'] == '') unset($order['detail']);
+        return new Order($order);
+    }
+
+    /**
+     * 获得下单ID
+     * @param $openid
+     * @param $out_trade_no
+     * @param $total_fee
+     * @param $attach
+     * @param $body
+     * @param string $detail
+     * @param string $trade_type
+     * @param array $options
+     * @return mixed
+     */
+    public static function paymentPrepare($openid, $out_trade_no, $total_fee, $attach, $body, $detail = '', $trade_type = 'JSAPI', $options = [])
+    {
+        $order = self::paymentOrder($openid, $out_trade_no, $total_fee, $attach, $body, $detail, $trade_type, $options);
+        $result = self::paymentService()->prepare($order);
+        if ($result->return_code == 'SUCCESS' && $result->result_code == 'SUCCESS') {
+            try {
+                PaymentRepositories::wechatPaymentPrepareProgram($order, $result->prepay_id);
+            } catch (\Exception $e) {
+            }
+            return $result->prepay_id;
+        } else {
+            if ($result->return_code == 'FAIL') {
+                exception('微信支付错误返回：' . $result->return_msg);
+            } else if (isset($result->err_code)) {
+                exception('微信支付错误返回：' . $result->err_code_des);
+            } else {
+                exception('没有获取微信支付的预支付ID，请重新发起支付!');
+            }
+            exit;
+        }
+
+    }
+
+    /**
+     * 获得jsSdk支付参数
+     * @param $openid
+     * @param $out_trade_no
+     * @param $total_fee
+     * @param $attach
+     * @param $body
+     * @param string $detail
+     * @param string $trade_type
+     * @param array $options
+     * @return array|string
+     */
+    public static function jsPay($openid, $out_trade_no, $total_fee, $attach, $body, $detail = '', $trade_type = 'JSAPI', $options = [])
+    {
+        return self::paymentService()->configForJSSDKPayment(self::paymentPrepare($openid, $out_trade_no, $total_fee, $attach, $body, $detail, $trade_type, $options));
+    }
+
+    /**
+     * 使用商户订单号退款
+     * @param $orderNo
+     * @param $refundNo
+     * @param $totalFee
+     * @param null $refundFee
+     * @param null $opUserId
+     * @param string $refundReason
+     * @param string $type
+     * @param string $refundAccount
+     */
+    public static function refund($orderNo, $refundNo, $totalFee, $refundFee = null, $opUserId = null, $refundReason = '', $type = 'out_trade_no', $refundAccount = 'REFUND_SOURCE_UNSETTLED_FUNDS')
+    {
+        $totalFee = floatval($totalFee);
+        $refundFee = floatval($refundFee);
+        return self::paymentService()->refund($orderNo, $refundNo, $totalFee, $refundFee, $opUserId, $type, $refundAccount, $refundReason);
+    }
+
+    /** 根据订单号退款
+     * @param $orderNo
+     * @param array $opt
+     * @return bool
+     */
+    public static function payOrderRefund($orderNo, array $opt)
+    {
+        if (!isset($opt['pay_price'])) throw new AdminException('缺少pay_price');
+        $totalFee = floatval(bcmul($opt['pay_price'], 100, 0));
+        $refundFee = isset($opt['refund_price']) ? floatval(bcmul($opt['refund_price'], 100, 0)) : null;
+        $refundReason = isset($opt['desc']) ? $opt['desc'] : '';
+        $refundNo = isset($opt['refund_id']) ? $opt['refund_id'] : $orderNo;
+        $opUserId = isset($opt['op_user_id']) ? $opt['op_user_id'] : null;
+        $type = isset($opt['type']) ? $opt['type'] : 'out_trade_no';
+        /*仅针对老资金流商户使用
+        REFUND_SOURCE_UNSETTLED_FUNDS---未结算资金退款（默认使用未结算资金退款）
+        REFUND_SOURCE_RECHARGE_FUNDS---可用余额退款*/
+        $refundAccount = isset($opt['refund_account']) ? $opt['refund_account'] : 'REFUND_SOURCE_UNSETTLED_FUNDS';
+        try {
+            $res = (self::refund($orderNo, $refundNo, $totalFee, $refundFee, $opUserId, $refundReason, $type, $refundAccount));
+            if ($res->return_code == 'FAIL') throw new AdminException('退款失败:' . $res->return_msg);
+            if (isset($res->err_code)) throw new AdminException('退款失败:' . $res->err_code_des);
+        } catch (\Exception $e) {
+            throw new AdminException($e->getMessage());
+        }
+        return true;
+    }
+
+    /**
+     * 微信支付成功回调接口
+     */
+    public static function handleNotify()
+    {
+        self::paymentService()->handleNotify(function ($notify, $successful) {
+            if ($successful && isset($notify->out_trade_no)) {
+                if (isset($notify->attach) && $notify->attach) {
+                    if (($count = strpos($notify->out_trade_no, '_')) !== false) {
+                        $notify->out_trade_no = substr($notify->out_trade_no, $count + 1);
+                    }
+                    (new Hook(PaymentRepositories::class, 'wechat'))->listen($notify->attach, $notify->out_trade_no);
+                }
+                return false;
+            }
+        });
+    }
+
+    /**
+     * 作为客服消息发送
+     * @param $to
+     * @param $message
+     * @return bool
+     */
+    public static function staffTo($to, $message)
+    {
+        $staff = self::staffService();
+        $staff = is_callable($message) ? $staff->message($message()) : $staff->message($message);
+        $res = $staff->to($to)->send();
+        return $res;
+    }
+
+
+    /**
+     * 获取直播列表
+     * @param int $page
+     * @param int $limit
+     * @return array
+     */
+    public static function getLiveInfo(int $page = 1, $limit = 10)
+    {
+        try {
+            $res = self::miniprogram()->wechat_live->getLiveInfo($page, $limit);
+            if (isset($res['errcode']) && $res['errcode'] == 0 && isset($res['room_info']) && $res['room_info']) {
+                return $res['room_info'];
+            } else {
+                return [];
+            }
+        } catch (\Throwable $e) {
+            return [];
+        }
+    }
+
+}