feat: good

2025-01-13 17:59:16 +08:00
parent 99b95b76e9
commit d2aca0e5a9
4 changed files with 275 additions and 11 deletions
--- a/app/Service/Common/Pay/Wx/WxJsRechargeBaseService.php
+++ b/app/Service/Common/Pay/Wx/WxJsRechargeBaseService.php
@@ -0,0 +1,154 @@
+<?php
+
+namespace App\Service\Common\Pay\Wx;
+
+use App\Exception\ErrException;
+use App\Lib\Log;
+use App\Service\Common\Pay\ThirdPayInterface;
+use Exception;
+use Hyperf\Di\Annotation\Inject;
+use Hyperf\HttpServer\Contract\RequestInterface;
+use Psr\Container\ContainerExceptionInterface;
+use Psr\Container\NotFoundExceptionInterface;
+use Psr\Http\Message\ResponseInterface;
+use Yansongda\Artful\Rocket;
+use Yansongda\HyperfPay\Pay;
+use Yansongda\Supports\Collection;
+use function Hyperf\Config\config;
+
+abstract class WxJsRechargeBaseService implements ThirdPayInterface
+{
+    /**
+     * 回调地址
+     * @var string
+     */
+    protected string $notifyUrl = '';
+
+    /**
+     * @var Pay $ysdPay
+     */
+    #[Inject]
+    protected Pay $ysdPay;
+
+    /**
+     * @var Log
+     */
+    #[Inject]
+    protected Log $log;
+
+    /**
+     * 注入
+     * @var RequestInterface
+     */
+    #[Inject]
+    protected RequestInterface $request;
+
+    /**
+     * 配置项
+     * @var array
+     */
+    protected array $config = [];
+
+    /**
+     * 返回数据
+     * @var array
+     */
+    protected array $callbackData = [];
+
+    /**
+     * 充值回调
+     */
+    abstract public function callBackHandle();
+
+    /**
+     * 设置回调地址
+     */
+    abstract public function setNotify();
+
+//    /**
+//     * 设置商户号id
+//     */
+//    abstract public function setMchId();
+
+
+//    /**
+//     * 获取返回数据
+//     * @return void
+//     * @throws ContainerExceptionInterface
+//     * @throws NotFoundExceptionInterface
+//     * @throws ContainerException
+//     * @throws InvalidParamsException
+//     */
+//    public function getWechatData(): void
+//    {
+//        $params = $this->request->all();
+//        $this->log->callbackLog(__CLASS__.'微信支付回调'.json_encode($params));
+//
+//        $this->setConfig();
+//        $result = $this->pay->wechat($this->config)->callback($params);
+//        $this->callbackData = $result['resource']['ciphertext'];
+//
+//        if (empty($this->callbackData)) {
+//            $this->log->error(__CLASS__.'获取回调失败'.json_encode($params));
+//            throw new ErrException('获取回调失败');
+//        }
+//
+//        $this->log->info(__CLASS__.'微信支付完成回调'.json_encode($this->callbackData));
+//    }
+
+
+    /**
+     * 确认回调
+     * @return ResponseInterface
+     */
+    protected function returnSuccess(): ResponseInterface
+    {
+        $this->setConfig();
+        return $this->ysdPay->wechat($this->config)->success();
+    }
+
+    /**
+     * @return void
+     */
+    private function setConfig(): void
+    {
+        $this->config = config('ysdPay');
+    }
+
+    /**
+     * @param float $money
+     * @param int $orderId
+     * @param int $orderType
+     * @param string $outTradeNo
+     * @param int $userId
+     * @return Collection|Rocket
+     * @throws ContainerExceptionInterface
+     * @throws NotFoundExceptionInterface
+     */
+    public function pay(float $money, int $orderId, int $orderType, string $outTradeNo, int $userId): Collection|Rocket
+    {
+        if (empty($this->config)) throw new ErrException('调起支付失败-微信支付配置项不存在');
+        $userOpenId = '123';
+        try {
+            $wxOrder = [
+                'out_trade_no' => $outTradeNo,
+                'description' => '测试订单',
+                'amount' => [
+                    'total' => (int)bcmul((string)$money, "100"),
+                    'currency' => 'CNY'
+                ],
+                'payer' => [
+                    'openid' => $userOpenId,
+                ]
+            ];
+
+            $result = $this->ysdPay->wechat($this->config)->mini($wxOrder);
+
+            $this->log->callbackLog(__CLASS__.'微信支付调起数据|回调地址:'. json_encode($this->config['wechat']['default']).'|回调数据:'.json_encode($result).'|请求数据:'.json_encode($wxOrder));
+            return $result;
+        } catch (Exception $e) {
+            $this->log->error(__CLASS__.'微信支付调起失败。reason:'.$e->getMessage());
+            throw new ErrException($e->getMessage());
+        }
+    }
+}