|
@@ -1,326 +0,0 @@
|
|
|
-<?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 [];
|
|
|
- }
|
|
|
- }
|
|
|
-
|
|
|
-}
|