bot-28/app/Services/PaymentOrderService.php

<?php

namespace App\Services;

use App\Constants\HttpStatus;
use App\Models\PaymentOrder;
use Exception;
use Illuminate\Support\Facades\DB;
use Illuminate\Support\Facades\Log;
use App\Services\Payment\QianBaoService;
use App\Services\Payment\SanJinService;

/**
 * 投注
 */
class PaymentOrderService extends BaseService
{
    const TYPE_PAY = 1; // 代收
    const TYPE_PAYOUT = 2; // 代付

    const STATUS_STAY = 0;  // 待处理
    const STATUS_PROCESS = 1; // 处理中
    const STATUS_SUCCESS = 2; // 成功
    const STATUS_FAIL = 3; // 失败

    /**
     * @description: 模型
     * @return {string}
     */
    public static function model(): string
    {
        return PaymentOrder::class;
    }

    /**
     * @description: 枚举
     * @return {*}
     */
    public static function enum(): string
    {
        return '';
    }

    /**
     * @description: 获取查询条件
     * @param {array} $search 查询内容
     * @return {array}
     */
    public static function getWhere(array $search = []): array
    {
        $where = [];
        if (isset($search['member_id']) && !empty($search['member_id'])) {
            $where[] = ['member_id', '=', $search['member_id']];
        }
        if (isset($search['type']) && !empty($search['type'])) {
            $where[] = ['type', '=', $search['type']];
        }
        if (isset($search['channel']) && !empty($search['channel'])) {
            $where[] = ['channel', '=', $search['channel']];
        }
        if (isset($search['order_no']) && !empty($search['order_no'])) {
            $where[] = ['order_no', '=', $search['order_no']];
        }
        if (isset($search['id']) && !empty($search['id'])) {
            $where[] = ['id', '=', $search['id']];
        }
        if (isset($search['status']) && $search['status'] != '') {
            $where[] = ['status', '=', $search['status']];
        }
        return $where;
    }

    /**
     * @description: 查询单条数据
     * @param array $search
     * @return \App\Models\Coin|null
     */
    public static function findOne(array $search): ?PaymentOrder
    {
        return self::model()::where(self::getWhere($search))->first();
    }

    /**
     * @description: 查询所有数据
     * @param array $search
     * @return \Illuminate\Database\Eloquent\Collection
     */
    public static function findAll(array $search = [])
    {
        return self::model()::where(self::getWhere($search))->get();
    }

    /**
     * @description: 分页查询
     * @param array $search
     * @return \Illuminate\Contracts\Pagination\LengthAwarePaginator
     */
    public static function paginate(array $search = [])
    {
        $limit = isset($search['limit']) ? $search['limit'] : 15;
        $paginator = self::model()::where(self::getWhere($search))
            ->with(['userInfo'])
            ->orderByDesc('created_at')
            ->paginate($limit);
        return ['total' => $paginator->total(), 'data' => $paginator->items()];
    }

    /**
     * @description:
     * @param {*} $params
     * @return {*}
     */
    public static function submit($params = [])
    {
        $result = false;
        $msg['code'] = self::NOT;
        $msg['msg'] = '';

        // 2. 判断是否是更新
        if (!empty($params['id'])) {
            // 更新
            $info = self::findOne(['id' => $params['id']]);
            if (!$info) {
                $msg['msg'] = '数据不存在！';
            } else {
                $result = $info->update($params);
                $id = $params['id'];
            }
        } else {
            // 创建
            $result = $info = self::model()::create($params);
            $id = $result->id;
        }


        if ($result) {
            $msg['code'] = self::YES;
            $msg['msg'] = '设置成功';
            $msg['key'] = $id;
        } else {
            $msg['msg'] = empty($msg['msg']) ? '操作失败' : $msg['msg'];
        }

        return $msg;
    }

    /**
     * @description: 创建代收订单
     * @param {*} $memberId
     * @param {*} $amount
     * @param {*} $paymentType 支付类型：支付宝、数字人民币
     * @return {*}
     */
    public static function createPay($memberId, $amount, $paymentType)
    {
        $result = [];
        $result['chat_id'] = $memberId;
        $channel = ''; // 支付的通道
        $product = SanJinService::$PRODUCT;
        $max = 0;
        $min = 0;
        $rate = 0;

        $geText = '';
        foreach ($product as $k => $v) {
            if ($v['type'] == $paymentType) {
                if ($v['type'] == 'zfbge') {
                    if (in_array($amount, $v['fixed'])) {
                        $channel = $k;

                    } else {
                        $geText .= "❌ 此充值通道固定充值金额为" . implode('，', $v['fixed']) . "请务必输入区间金额！";
                    }
                } else {
                    if ($amount >= $v['min'] && $amount <= $v['max']) {
                        $channel = $k;
                        $rate = $v['rate'];

                    }
                    if ($min == 0) {
                        $min = $v['min'];
                    }
                    if ($max == 0) {
                        $max = $v['max'];
                    }
                    if ($min > $v['min']) {
                        $min = $v['min'];
                    }
                    if ($max < $v['max']) {
                        $max = $v['max'];
                    }
                }

            }
        }

        // 没有找到支付通道
        if (empty($channel)) {
            // $text = "发起充值失败 \n";
            // $text .= "最低充值：" . $min . " \n";
            // $text .= "最高充值：" . $max . " \n";
            // $text .= "请重新填写充值的金额！";
            $text = "❌ 此充值通道充值金额{$min}-{$max}请务必输入区间金额！";
            $result['text'] = $text;
            if ($geText) {
                $result['text'] = $geText;
            }
            return $result;
        }

        $data = [];
        $data['type'] = self::TYPE_PAY;
        $data['member_id'] = $memberId;
        $data['amount'] = $amount;
        $data['channel'] = $channel;
        $data['fee'] = $amount * $rate;
        $data['bank_name'] = SanJinService::getChannel($paymentType) ?? '';
        $order_no = self::createOrderNo('sj' . $data['type'] . '_', $memberId);
        $data['order_no'] = $order_no;
        $data['callback_url'] = SanJinService::getNotifyUrl();
        $data['remark'] = '充值费率：' . $rate;
        $data['status'] = self::STATUS_STAY;
        $ret = SanJinService::pay(($amount * 100), $order_no, $channel);
        Log::error('三斤支付发起：', $ret);
        if ($ret['code'] == 0) {

            $qrCode = asset(self::createPaymentQrCode($ret['data']['payUrl']));
            $result['image'] = $qrCode;
            $item = $ret['data'];
            $data['status'] = self::STATUS_PROCESS;
            $data['pay_no'] = $item['tradeNo'];
            $data['pay_url'] = $item['payUrl'];
            $data['pay_data'] = json_encode($ret, JSON_UNESCAPED_UNICODE);
            $info = self::model()::create($data);
            // $text = "✅ 支付提示 \n";
            $text = "{$data['bank_name']}充值确认";
            // $text .= "支付方式：{$data['bank_name']} \n";
            $text .= "请使用浏览器扫码 \n";
            $text .= "支付金额：" . $amount . " RMB \n";
            $text .= "请按实际支付金额进行付款，否则影响到账 \n";
            $text .= "支付完成后请耐心等待，支付到账会第一时间通知您！ \n";
            $result['text'] = $text;
        } else {
            $result['text'] = $ret['message'];
        }
        return $result;
    }

    /**
     * @description: 接收支付的通知
     * @param {*} $params
     * @return {*}
     */
    public static function receivePay($params)
    {
        // 判断商户号
        if ($params['mchId'] == SanJinService::getMerchantId()) {
            $must = ['mchId', 'productId', 'tradeNo', 'outTradeNo', 'amount', 'payAmount', 'state', 'createTime', 'payTime'];


            $info = self::findOne(['order_no' => $params['outTradeNo']]);
            if ($info) {
                // 平台以分计算转成元
                $payAmount = $params['payAmount'] / 100;
                // 判断金额是不是正确认
                if ($info->amount != $payAmount) {
                    $text = '❌ 支付失败提醒 \n';
                    $text .= "订单金额：{$info->amount} \n";
                    $text .= "实际支付：{$payAmount} \n";
                    $text .= "订单号：{$params['outTradeNo']} \n";
                    $text .= "失败原因：支付金额与订单金额不一致 \n";
                    $text .= "请联系客服处理！";
                    self::sendMessage($info->member_id, $text);
                    return false;
                }

                if ($params['sign'] != SanJinService::signature($params, $must)) {
                    return false;
                }

                if ($info->status != self::STATUS_PROCESS) {
                    return false;
                }

                // 付款
                if ($info->type == self::TYPE_PAY) {
                    $info->state = $params['state'];
                    if ($params['state'] == 1) {
                        $info->status = self::STATUS_SUCCESS;
                        $wallet = WalletService::findOne(['member_id' => $info->member_id]);
                        $balance = $wallet->available_balance;
                        $available_balance = bcadd($balance, $payAmount, 10);
                        $wallet->available_balance = $available_balance;
                        $wallet->save();

                        // 记录余额变动日志
                        BalanceLogService::addLog(
                            $info->member_id,
                            $payAmount,
                            $balance,
                            $available_balance,
                            '三方充值',
                            $info->id,
                            ''
                        );

                        $text = "✅ 支付成功 \n";
                        $text .= "充值金额：{$payAmount} RMB \n";
                        $text .= "订单号：{$params['outTradeNo']} \n";
                        $text .= "您充值的金额已到账，请注意查收！";
                        self::sendMessage($info->member_id, $text);
                    } else {
                        $info->status = self::STATUS_FAIL;
                        $text = "❌ 支付失败 \n";
                        $text .= "充值金额：{$payAmount} RMB \n";
                        $text .= "订单号：{$params['outTradeNo']} \n";
                    }
                    $info->save();
                    return true;
                }
            }
        }
    }

    /**
     * @description: 创建代付订单 (根据 orderId 将钱转到用户指定账户)
     * @param int $orderId PaymentOrder 表的ID
     */
    public static function createPayout(int $orderId)
    {
        DB::beginTransaction();
        try {
            $order = PaymentOrder::where('id', $orderId)->first();
            $amount = $order->amount;
            $amount = number_format($amount, 2, '.', '');
            $ret = QianBaoService::payout($amount, $order->order_no, $order->bank_name, $order->account, $order->card_no);
            Log::error('第三方代付接口调用：' . json_encode($ret, JSON_UNESCAPED_UNICODE));
            if ($ret['code'] != 200) throw new Exception($ret['msg'], HttpStatus::CUSTOM_ERROR);
            $order->status = self::STATUS_PROCESS;
            $order->save();
            DB::commit();
        } catch (Exception $e) {
            DB::rollBack();
            return ['code' => HttpStatus::CUSTOM_ERROR, 'msg' => $e->getMessage()];
        }
        return ['code' => 0, 'msg' => 'ok'];
    }

    /**
     * @description: 创建代付订单 (自动直接到账，包括用户钱包的扣款和提现记录的生成以及余额日志的创建)
     * @param {*} $memberId 会员ID
     * @param {*} $amount   代付金额
     * @param {*} $channel  提现通道 DF001 支付宝转卡/DF002 支付宝转支付宝
     * @param {*} $bank_name  银行名称/支付宝
     * @param {*} $account  姓名
     * @param {*} $card_no  银行卡号/支付宝账号
     * @return {*}
     */
    public static function autoCreatePayout($memberId, $amount, $channel, $bank_name, $account, $card_no)
    {
        $default_amount = $amount;
        $result = [];
        $result['chat_id'] = $memberId;

        if ($amount < 100) {
            $result['text'] = '提现金额最少100';
            return $result;
        }
        if ($amount > 49999) {
            $result['text'] = '提现金额最多49999';
            return $result;
        }

        // 在调用三方支付前开始事务
        DB::beginTransaction();

        try {
            $wallet = WalletService::findOne(['member_id' => $memberId]);
            if (!$wallet) {
                $result['text'] = '钱包不存在！';
                return $result;
            }

            $balance = $wallet->available_balance;
            if (bccomp($balance, $amount, 2) < 0) {
                $result['text'] = '您的钱包余额不足！';
                return $result;
            }

            $available_balance = bcsub($balance, $amount, 10);

            $data = [];
            $data['type'] = self::TYPE_PAYOUT;
            $order_no = self::createOrderNo('sj' . $data['type'] . '_', $memberId);
            $data['order_no'] = $order_no;
            $data['member_id'] = $memberId;
            $data['fee'] = $amount * 0.002 + 2;
            $amount = number_format($amount, 2, '.', '');
            $data['amount'] = $amount;
            $data['channel'] = $channel;
            $data['bank_name'] = $bank_name;
            $data['account'] = $account;
            $data['card_no'] = $card_no;
            $data['callback_url'] = QianBaoService::getNotifyUrl();
            $data['status'] = self::STATUS_STAY;
            $data['remark'] = '提现费率：0.2%+2';

            // 先预扣款（锁定资金）
            $wallet->available_balance = $available_balance;
            if (!$wallet->save()) {
                DB::rollBack();
                $result['text'] = '钱包更新失败！';
                return $result;
            }

            // 创建待处理状态的提现记录
            $info = self::model()::create($data);
            $id = $info->id;

            // 记录余额变动日志
            BalanceLogService::addLog(
                $memberId,
                $default_amount,
                $balance,
                $available_balance,
                '三方提现',
                $id,
                '钱宝提现费率：0.2%+2'
            );

            // 提交事务，确保预扣款成功
            DB::commit();

        } //
        catch (Exception $e) {
            // 预扣款失败，回滚事务
            DB::rollBack();
            $result['text'] = '系统繁忙，请稍后重试！';
            Log::error('提现预扣款失败: ' . $e->getMessage(), [
                'member_id' => $memberId,
                'amount' => $amount
            ]);
            return $result;
        }

        // 调用三方支付接口（在事务外）
        $ret = QianBaoService::payout($amount, $order_no, $bank_name, $account, $card_no);
        Log::error('第三方代付接口调用：' . json_encode($ret, JSON_UNESCAPED_UNICODE));
        if ($ret['code'] == 200) {
            // 更新提现记录状态为处理中
            DB::beginTransaction();
            try {
                $info->status = self::STATUS_PROCESS;
                $info->save();
                DB::commit();

                $text = "✅ 提现申请已提交！\n\n";
                $text .= "钱包余额：{$available_balance} RMB\n";
                $text .= "提现金额：{$default_amount} RMB\n";
                $text .= "⌛️请等待系统处理, 到账时间可能需要几分钟!\n";

                $result['text'] = $text;

            } catch (Exception $e) {
                DB::rollBack();
                // 状态更新失败，但资金已扣款且三方支付已成功
                // 这里可以记录告警，需要人工干预
                Log::error('提现状态更新失败: ' . $e->getMessage(), [
                    'member_id' => $memberId,
                    'order_no' => $order_no
                ]);
                $result['text'] = '提现申请已提交，系统处理中...';
            }

        } //
        else {
            // 三方支付失败，需要回滚之前的预扣款
            DB::beginTransaction();
            try {
                // 恢复钱包余额
                $wallet->available_balance = $balance;
                $wallet->save();

                // 更新提现记录状态为失败
                $info->status = self::STATUS_FAIL;
                $info->remark = $ret['msg'];
                $info->save();

                // 记录退款日志
                BalanceLogService::addLog(
                    $memberId,
                    $default_amount,
                    $available_balance,
                    $balance,
                    '三方提现',
                    $id,
                    '提现失败退款'
                );

                DB::commit();
                $result['text'] = $ret['msg'];

            } catch (Exception $e) {
                DB::rollBack();
                // 回滚失败，需要记录告警，人工干预
                Log::error('提现失败回滚异常: ' . $e->getMessage(), [
                    'member_id' => $memberId,
                    'order_no' => $order_no,
                    'amount' => $amount
                ]);
                $result['text'] = '提现失败，请联系客服处理退款！';
            }
        }

        return $result;
    }

    /**
     * @description: 接收三方订单
     * @param {*} $params
     * @return {*}
     */
    public static function receiveOrder($params)
    {
        // 判断商户号是否一致
        if ($params['merchantNum'] == QianBaoService::getMerchantId()) {

            $info = self::findOne(['order_no' => $params['orderNo']]);
            if ($info) {
                // 判断金额是不是正确认
                if ($info->amount != $params['amount']) {
                    return false;
                }

                // 验证签名
                $sign = QianBaoService::verifyNotifySign($params['state'], $params['orderNo'], $params['amount']);
                if ($params['sign'] != $sign) {
                    return false;
                }
                // 代付
                if ($info->type == self::TYPE_PAYOUT) {
                    self::onSubmitPayout($params, $info);
                }
                // 代收
                if ($info->type == self::TYPE_PAY) {

                }
            }

        }

    }

    /**
     * @description: 处理代付订单
     * @param {*} $params
     * @return {*}
     */
    public static function onSubmitPayout($params, $info)
    {
        $memberId = $info->member_id;
        $amount = $params['amount'];
        $data = [];
        $result = [];
        $chat_id = $info->member_id;
        $data['callback_data'] = json_encode($params, JSON_UNESCAPED_UNICODE);
        DB::beginTransaction();
        try {
            if ($params['state'] == 1) {
                $data['status'] = self::STATUS_SUCCESS;
                $res = self::model()::where(['order_no' => $params['orderNo']])->update($data);
                if ($res) {
                    DB::commit();
                    $text = "✅ 提现通知 \n";
                    $text .= "提现平台：{$info->bank_name} \n";
                    $text .= "收款人：{$info->account} \n";
                    $text .= "收款卡号：{$info->card_no} \n";
                    $text .= "提现金额：{$info->amount} \n";
                    $text .= "提现成功，金额已到账，请注意查收！";
                    self::sendMessage($chat_id, $text);
                }
            } else {
                $data['status'] = self::STATUS_FAIL;
                $res = self::model()::where(['order_no' => $params['orderNo']])->update($data);

                $wallet = WalletService::findOne(['member_id' => $info->member_id]);

                $balance = $wallet->available_balance; // 钱包当前余额

                $available_balance = bcadd($balance, $params['amount'], 10);
                $wallet->available_balance = $available_balance;
                $wallet->save();
                // 记录退款日志
                BalanceLogService::addLog(
                    $memberId,
                    $amount,
                    $balance,
                    $available_balance,
                    '三方提现',
                    $info->id,
                    '提现失败退款'
                );
                if ($res) {
                    DB::commit();
                    $text = "❌ 提现通知 \n";
                    $text .= "提现平台：{$info->bank_name} \n";
                    $text .= "收款人：{$info->account} \n";
                    $text .= "收款卡号：{$info->card_no} \n";
                    $text .= "提现金额：{$info->amount} \n";
                    $text .= "提现失败，金额已返回钱包，请注意查收！";
                    self::sendMessage($chat_id, $text);
                }
            }
        } catch (Exception $e) {
            DB::rollBack();
            // 回滚失败，需要记录告警，人工干预
            Log::error('提现失败回滚异常: ' . $e->getMessage(), $params);
        }


    }

    /**
     * @description: 查询支付订单
     * @param {*} $id
     * @return {*}
     */
    public static function singlePayOrder($id)
    {
        $msg = [];
        $msg['code'] = self::NOT;
        $info = self::findOne(['id' => $id]);
        if ($info && $info->status == self::STATUS_PROCESS) {
            $ret = SanJinService::queryOrder($info->order_no);
            Log::error('三斤支付查询订单：', $ret);
            if ($ret['code'] == 0) {
                $item = [];
                $item['state'] = $ret['data']['state'];
                if ($ret['data']['state'] == 1) {
                    $item['status'] = self::STATUS_SUCCESS;
                    $info->update($item);

                    $wallet = WalletService::findOne(['member_id' => $info->member_id]);
                    $balance = $wallet->available_balance;
                    $available_balance = bcadd($balance, $info->amount, 10);
                    $wallet->available_balance = $available_balance;
                    $wallet->save();

                    // 记录余额变动日志
                    BalanceLogService::addLog(
                        $info->member_id,
                        $info->amount,
                        $balance,
                        $available_balance,
                        '三方充值',
                        $info->id,
                        ''
                    );

                    $msg['code'] = self::YES;
                    $msg['msg'] = '支付成功';
                } else {
                    $msg['msg'] = '支付中';
                }

            } else {
                $msg['msg'] = '查询失败：' . $ret['message'];
            }
        } else {
            $msg['msg'] = '该状态无法查询';
        }

        return $msg;

    }

    public static function syncPayOrder()
    {
        $list = self::model()::where('state', 0)->where('type', self::TYPE_PAY)->take(100)->get();
        // foreach($list->toArray() as $k => $v){
        //      $item= [];
        //     if($v['status'] == self::STATUS_SUCCESS){
        //         $item['state'] = 1;
        //         self::model()::where(['id'=>$v['id']])->update($item);
        //     }else{
        //         $ret = SanJinService::queryOrder($v['order_no']);
        //         var_dump($ret);
        //         if($ret['code'] == 0){

        //             $item['state'] = $ret['data']['state'];
        //             self::model()::where(['id'=>$v['id']])->update($item);
        //         }
        //     }

        // }
    }

}