payment/app/Controller/Recharge/RechargeController.php

<?php

declare(strict_types=1);

namespace App\Controller\Recharge;

use App\Exception\BusinessException;
use App\Exception\UnauthorizedException;
use App\Helper\Redis;
use App\Helper\StringHelper;
use App\Model\App;
use App\Model\BankCard;
use App\Model\Order;
use App\Model\PrePayLog;
use App\Model\User;
use App\Service\PaymentService;
use Hyperf\HttpServer\Contract\RequestInterface;

class RechargeController extends AbstractController
{
    private PaymentService $paymentService;
    
    public function __construct(PaymentService $paymentService)
    {
        $this->paymentService = $paymentService;
    }

    public function getMemberInfo(RequestInterface $request) {
        [$app, $prePayLog] = $this->checkToken($request->input('stoken', ''));
        $user = User::where('out_member_id', $prePayLog->out_member_id)->first();
        $bankCard = null;
        $userInfo = null;
        if ($user) {
            $bankCard = BankCard::where('member_id', $user->member_id)->where('status', BankCard::STATUS_ACTIVE)->first();
            $userInfo = [
                'name' => $user->real_name ?? '',
                'cardNo' => $user->card_no ?? '',
                'mobile' => $user->mobile ?? '',
                'bankCardNo' => $bankCard->bank_card_no ?? '',
            ];
        }
        return $this->success([
            'user' => $userInfo,
            'amount' => intval($prePayLog->amount / 100),
        ]);
    }

    public function recharge(RequestInterface $request) {
        [$app, $prePayLog] = $this->checkToken($request->input('stoken', ''));
        $name = $request->input('name');
        if (empty($name)) {
            throw new BusinessException('请输入姓名');
        }
        $amount = $request->input('amount');
        if ($prePayLog->amount == 0) {
            $amount = $request->input('amount');
            if (empty($amount)) {
                throw new BusinessException('请输入金额');
            }
            if (!is_numeric($amount)) {
                throw new BusinessException('请输入金额');
            }
            if ($amount <= 0) {
                throw new BusinessException('金额需大于0');
            }
        }
        
        $cardNo = $request->input('cardNo');
        if (empty($cardNo)) {
            throw new BusinessException('请输入身份证号');
        }
        $mobile = $request->input('mobile');
        if (empty($mobile)) {
            throw new BusinessException('请输入手机号');
        }
        $bankCardNo = $request->input('bankCardNo');
        if (empty($bankCardNo)) {
            throw new BusinessException('请输入银行卡号');
        }
        $memberId = $this->paymentService->generateMemberId($app->app_key, $cardNo);
        $user = User::where('member_id', $memberId)->first();
        $bankCard = null;
        if ($user) {
            if (empty($user->out_member_id)) {
                $user->out_member_id = $prePayLog->out_member_id;
                $user->save();
            }
            $bankCard = BankCard::where('member_id', $user->member_id)->where('bank_card_no', $bankCardNo)->where('status', BankCard::STATUS_ACTIVE)->first();
        }
        
        if ($bankCard) {
            $outOrderNo = $prePayLog->out_order_no;
            $nextStep = 'confirm-pay';
            $amount = $prePayLog->amount > 0 ? $prePayLog->amount :  intval($amount * 100);
            $bizData = $this->paymentService->protocolPayPreRequest($this->buildPrepayParams($prePayLog->out_member_id, $outOrderNo, $bankCard->protocol, $amount, $prePayLog->notify_url, $app));
        } else {
            $mchOrderNo = StringHelper::generateBankCardOrderNo();
            $nextStep = 'confirm-bind';
            $bizData = $this->paymentService->bindCard($this->buildBindCardParams(
                $mchOrderNo, $prePayLog->out_member_id, $name, $cardNo, $mobile, $bankCardNo, $app
            ));
        }
        return $this->success([
            'nextStep' => $nextStep,
            'outMemberId' => $prePayLog->out_member_id,
            'bizData' => $bizData
        ]);
    }

    public function confirmBindCard(RequestInterface $request) {
        [$app, $prePayLog] = $this->checkToken($request->input('stoken', ''));
        $smsNo = $request->input('smsNo');
        $smsCode = $request->input('smsCode');
        $bizData = $this->paymentService->bindCardConfirm($this->buildComfirmBindCardParams($prePayLog->out_member_id, $smsNo, $smsCode, $app));
        return $this->success([
            'outMemberId' => $prePayLog->out_member_id,
            'bizData' => $bizData
        ]);
    }

    public function confirmPay(RequestInterface $request) {
        [$app, $prePayLog] = $this->checkToken($request->input('stoken', ''));
        $token = $request->input('token');
        $protocol = $request->input('protocol');
        $smsCode = $request->input('smsCode');
        $bizData = $this->paymentService->protocolPayConfirm($this->buildConfirmPayParams($token, $protocol, $smsCode, $app));
        return $this->success([
            'outMemberId' => $prePayLog->out_member_id,
            'bizData' => ['outOrderNo' => $prePayLog->out_order_no]
        ]);
    }

    private function buildBindCardParams($mchOrderNo, $outMemberId, $name, $cardNo, $mobile, $bankCardNo, $app)
    {
        $params = [
            'app_id' => $app->app_id,
            'timestamp' => time(),
            'nonce_str' => StringHelper::getRandomString(32),
            'data' => json_encode([
                'mchtOrderNo' => $mchOrderNo,
                'outMemberId' => $outMemberId,
                'userName' => $name,
                'phoneNum' => $mobile,
                'bankCardNo' => $bankCardNo,
                'bankCardType' => 'debit',
                'certificatesNo' => $cardNo,
            ]),
        ];
        $sign = \App\Helper\Platform\Signer::sign($params, $app->app_key);
        $params['sign'] = $sign;
        return $params;
    }

    private function buildPrepayParams($outMemberId, $outOrderNo, $protocol, $amount, $notifyUrl, $app)
    {
        $params = [
            'app_id' => $app->app_id,
            'timestamp' => time(),
            'nonce_str' => StringHelper::getRandomString(32),
            'data' => json_encode([
                'outMemberId' => $outMemberId,
                'outOrderNo' => $outOrderNo,
                'protocol' => $protocol,
                'payAmount' => $amount,
                'notifyUrl' => $notifyUrl,
            ]),
        ];
        $sign = \App\Helper\Platform\Signer::sign($params, $app->app_key);
        $params['sign'] = $sign;
        return $params;
    }

    private function buildConfirmPayParams($token, $protocol, $smsCode, $app)
    {
        $params = [
            'app_id' => $app->app_id,
            'timestamp' => time(),
            'nonce_str' => StringHelper::getRandomString(32),
            'data' => json_encode([
                'token' => $token,
                'protocol' => $protocol,
                'smsCode' => $smsCode,
            ]),
        ];
        $sign = \App\Helper\Platform\Signer::sign($params, $app->app_key);
        $params['sign'] = $sign;
        return $params;
    }

    private function buildComfirmBindCardParams($outMemberId, $smsNo, $smsCode, $app)
    {
        $params = [
            'app_id' => $app->app_id,
            'timestamp' => time(),
            'nonce_str' => StringHelper::getRandomString(32),
            'data' => json_encode([
                'outMemberId' => $outMemberId,
                'smsNo' => $smsNo,
                'smsCode' => $smsCode,
            ]),
        ];
        $sign = \App\Helper\Platform\Signer::sign($params, $app->app_key);
        $params['sign'] = $sign;
        return $params;
    }

    public function orders(RequestInterface $request)
    {
        $page = $request->input('page', 1);
        $pageSize = $request->input('pageSize', 20);
        $status = $request->input('status', 0);
        $timeRange = $request->input('timeRange', null);
        $token = $request->input('token');
        $mobile = $request->input('mobile', '');
        $cardNo = $request->input('cardNo', '');
        $orderNo = $request->input('orderNo', '');
        $outOrderNo = $request->input('outOrderNo', '');
        $bankCardNo = $request->input('bankCardNo', '');

        $appId = Redis::get('token:' . $token);
        if (empty($appId)) {
            throw new UnauthorizedException();
        }

        $offset = ($page - 1) * $pageSize;
        $query = Order::query()->where('app_id', $appId);
        if ($status) {
            $query->where('status', $status);
        }
        if ($mobile) {
            $memberIds = User::where('app_id', $appId)->where('mobile', $mobile)->get(['member_id'])->pluck('member_id')->toArray();
            $query->whereIn('member_id', $memberIds);
        }
        if ($cardNo) {
            $memberIds = User::where('app_id', $appId)->where('card_no', $cardNo)->get(['member_id'])->pluck('member_id')->toArray();
            $query->whereIn('member_id', $memberIds);
        }
        if ($bankCardNo) {
            $protocols = BankCard::where('app_id', $appId)->where('bank_card_no', $bankCardNo)->get(['protocol'])->pluck('protocol')->toArray();
            $query->whereIn('protocol', $protocols);
        }
        if ($orderNo) {
            $query->where('order_no', $orderNo);
        }
        if ($outOrderNo) {
            $query->where('out_order_no', $outOrderNo);
        }
        if ($timeRange) {
            $timeRange[0] .= ' 00:00:00';
            $timeRange[1] .= ' 23:59:59';
            $query->whereBetween('created_at', $timeRange);
        }

        $countQuery = clone $query;
        $sumQuery = clone $query;

        $orders = $query->orderBy('id', 'desc')->offset($offset)->limit($pageSize)->get();
        $protocols = $orders->pluck('protocol');
        $bankCards = BankCard::where('app_id', $appId)->whereIn('protocol', $protocols)->get();
        $bankCards = $bankCards->keyBy('protocol');

        $records = [];
        foreach ($orders as $order) {
            $bankCard = $bankCards[$order->protocol] ?? null;
            $records[] = [
                'out_order_no' => $order->out_order_no,
                'payed_at' => $order->payed_at,
                'status' => $order->status,
                'amount' => number_format($order->amount / 100, 2, '.', ''),
                'real_name' => $bankCard ? $bankCard->real_name : '',
                'bank_card_no' => $bankCard ? $bankCard->bank_card_no : '',
                'mobile' => $bankCard ? $bankCard->mobile : '',
                'card_no' => $bankCard ? $bankCard->card_no : '',
                'status_text' => $order->getStatusText(),
            ];
        }

        $total = $countQuery->count();
        $amount = $sumQuery->sum('amount');
        return $this->success([
            'records' => $records,
            'total' => $total,
            'amount' => $amount / 100,
        ]);
    }

    public function login(RequestInterface $request)
    {
        $username = $request->input('username');
        $password = $request->input('password');

        if (empty($username) || empty($password)) {
            throw new BusinessException('账号或密码错误');
        }

        $user = $this->getUser($username);
        if (!$user) {
            throw new BusinessException('账号或密码错误');
        }

        if ($user['password'] !== $password) {
            throw new BusinessException('账号或密码错误');
        }

        $token = md5(microtime() . $username . $password);
        Redis::set('token:' . $token, $user['app_id']);
        Redis::expire('token:' . $token, 60*60);
        return $this->success(['token' => $token]);
    }

    private function getUser($username) {
        $users = [
            'owx0tlx' => ['password' => 'lSoLW28NxtMlxUazC8p', 'app_id' => '202304270000004'],
            'ioexlp2' => ['password' => 'wwU8Ir3Xp0rxXssA9NV', 'app_id' => '202305270000001'],
            'lix73nxIN' => ['password' => 'a01@lWl3dfNmT', 'app_id' => '202306140000001'],
        ];
        return $users[$username] ?? null;
    }

    private function checkToken($token) {
        if (empty($token)) {
            throw new BusinessException('token异常');
        }
        $log = PrePayLog::where('token', $token)->first();
        if (empty($log)) {
            throw new BusinessException('预支付记录不存在');
        }
        // if ($log->created_at->timestamp < time() - 5*60) {
        //     throw new BusinessException('支付超时，请重新请求');
        // }
        $app = App::where('app_id', $log->app_id)->first();
        if (empty($app)) {
            throw new BusinessException('应用异常');
        }
        return [$app, $log];
    }
}