ZY2025010601/app/Services/CregisPayService.php

<?php
// +----------------------------------------------------------------------
// | LARAVEL8.0 框架 [ LARAVEL ][ RXThinkCMF ]
// +----------------------------------------------------------------------
// | 版权所有 2017~2021 LARAVEL研发中心
// +----------------------------------------------------------------------
// | 官方网站: http://www.laravel.cn
// +----------------------------------------------------------------------
// | Author: laravel开发员 <laravel.qq.com>
// +----------------------------------------------------------------------

namespace App\Services;

use App\Models\AccountLogModel;
use App\Models\BalanceLogModel;
use App\Models\MemberModel;
use App\Models\WalletLogModel;
use App\Services\Api\FinanceService;
use Cregis\Dispatch\CregisDispatch;
use Illuminate\Support\Facades\DB;

/**
 * Cregis U盾钱包服务管理-服务类
 * @author laravel开发员
 * @since 2020/11/11
 * @package App\Services
 */
class CregisPayService extends BaseService
{
    // 静态对象
    protected static $instance = null;

    protected $dispatch = null;

    protected static $config = [];

    protected static $rechargeNotifyUrl = '/api/v1/wallet-api/rechargeCallback';

    public function __construct()
    {
        $config = ConfigService::make()->getConfigByGroup(7);
        $notifyUrl = isset($config['cregis_callback_url']['value']) ? $config['cregis_callback_url']['value'] : '';
        $notifyUrl = $notifyUrl ? $notifyUrl : '/api/v1/wallet-api/cregisCallback';
        self::$config = [
            'project_no' => isset($config['cregis_project_no']['value']) ? $config['cregis_project_no']['value'] : '', //商户号
            'api_key' => isset($config['cregis_api_key']['value']) ? $config['cregis_api_key']['value'] : '', //apikey
            'endpoint' => isset($config['cregis_endpoint']['value']) ? $config['cregis_endpoint']['value'] : '', //节点
            'callUrl' => env('APP_URL').'/'.trim($notifyUrl,'/'), //回调地址
            'debug' => false  //调试模式
        ];

        $this->dispatch = new CregisDispatch(self::$config);
    }

    /**
     * @return static|null
     */
    public static function make()
    {
        if (!self::$instance) {
            self::$instance = new static();
        }

        return self::$instance;
    }

    /**
     * 获取支持的币种
     * @param bool $showBalance 是否返回余额
     * @return mixed
     */
    public function supportCoins($showBalance = true)
    {
        try{
            return $this->dispatch->coinslist($showBalance);
        } catch (\Exception $exception) {
            $this->error = $exception->getMessage();
            return false;
        }

    }

    /**
     * HTTP 接口签名
     * @param array $params 参数数组
     * @return false|string
     */
    public function makeSign(array $params)
    {
        if(empty($params)){
            return false;
        }
        ksort($params);
        $signStr = '';
        foreach ($params as $key => $val){
            $signStr .= "{$key}{$val}";
        }

        $sign = md5(self::$config['api_key'].$signStr);
        return $sign;
    }


    /**
     * 创建钱包地址
     * @param string $mainCoinType 主链编号，1000-solana，195-波场
     * @return mixed
     */
    public function createAddress($mainCoinType = '1000')
    {
        try {
            $callback = env('APP_URL').'/'.trim(self::$rechargeNotifyUrl,'/');
            $result = $this->dispatch->createAddress(self::$config['project_no'], $mainCoinType, '', $callback);
            $code = isset($result['code']) ? trim($result['code']) : 0;
            $address = isset($result['data']['address']) ? trim($result['data']['address']) : '';
            if ($code == '00000' && $address) {
                return $address;
            } else {
                RedisService::set("caches:cregisPay:createAddress:error_" . date('YmdHis'), ['mainCoinType' => $mainCoinType, 'result' => $result], 7200);
                return '';
            }
        }catch (\Exception $exception){
            RedisService::set("caches:cregisPay:createAddress:error_" . date('YmdHis'), ['error'=>$exception->getMessage(),'mainCoinType' => $mainCoinType, 'result' => $result], 7200);
            return '';
        }

    }

    /**
     * 验证钱包地址合法性
     * @param $address 地址
     * @param string $mainCoinType 主链编号，1000-solana，195-波场
     * @return mixed
     */
    public function checkAddress($address, $mainCoinType = '1000')
    {
        try {
            return $this->dispatch->addressLegal(self::$config['project_no'], $mainCoinType, $address);
        } catch (\Exception $exception) {
            RedisService::set("caches:cregisPay:check_{$address}", ['error'=> $exception->getMessage(),'address'=>$address,'mainType'=>$mainCoinType],7200);
            $this->error = $exception->getMessage();
            return false;
        }
    }

    /**
     * 查询地址是否存在
     * @param $address 地址
     * @param string $mainCoinType 主链编号，1000-solana，195-波场
     * @return mixed
     */
    public function existAddress($address, $mainCoinType = '1000')
    {
        return $this->dispatch->addressInner(self::$config['project_no'], $mainCoinType, $address);
    }

    /**
     * 提币
     * @param $address 地址
     * @param $amount 金额
     * @param $orderNo 单号
     * @param string $mainCoinType 主链编号 波场-195，solana-1000
     * @param string $coinType 子链或代币合约地址
     * @param string $remark 备注
     * @return false
     */
    public function withdraw($address, $amount, $orderNo, $mainCoinType = '1000', $coinType = '', $remark = '')
    {
        try {
            $callback = self::$config['callUrl'];
            $tokenAddress = ConfigService::make()->getConfigByCode('solana_usdt_token', 'Es9vMFrzaCERmJfrF4H2FYD4KCoNkY11McCe8BenwNYB');
            $coinType = $coinType ? $coinType : $tokenAddress;
            RedisService::set("caches:cregisPay:{$orderNo}:withdraw", ['callback'=> $callback,'order_no'=>$orderNo,'amount'=>$amount,'remark'=>$remark,'address'=>$address,'mainType'=>$mainCoinType,'coinType'=>$coinType],7200);
            return $this->dispatch->payout(self::$config['project_no'], $mainCoinType . '@' . $coinType, $address, $amount, $callback, $orderNo, $remark);
        } catch (\Exception $exception) {
            $this->error = $exception->getMessage();
            RedisService::set("caches:cregisPay:{$orderNo}:withdraw_error", ['order_no'=>$orderNo,'amount'=>$amount,'remark'=>$remark,'address'=>$address,'mainType'=>$mainCoinType],7200);
            return false;
        }
    }

    /**
     * 查询订单
     * @param $orderNo 交易单号
     * @return mixed
     */
    public function queryOrder($tradeOutNo)
    {
        try {
            return $this->dispatch->payoutQuery(self::$config['project_no'], $tradeOutNo);
        } catch (\Exception $exception) {
            $this->error = $exception->getMessage();
            return false;
        }
    }

    /**
     * 充值回调
     * @return mixed
     */
    public function rechargeCallBack()
    {
        $data = file_get_contents('php://input');
        RedisService::set("caches:cregisPay:recharge_callback", ['params' => request()->all(), 'result' => $data], 7200);
        $params = $data?json_decode($data, true) : [];
        $params = empty($params)? request()->all() : $params;
        if(empty($params)){
            RedisService::set("caches:cregisPay:recharge_data_".date('YmdHis'),['params'=> $params,'data'=> $data], 3600);
            return 'Recharge callback data error';
        }
        $getSign = $params['sign'];
        $tradeCid = isset($params['cid'])? trim($params['cid']) : '';
        $cacheKey = "caches:cregisPay:recharge_{$tradeCid}";
        RedisService::set("{$cacheKey}:callback", ['params' => request()->all(), 'result' => $params], 7200);
        $sgin = $this->dispatch->generateSign(self::$config['api_key'], $params);
        if($getSign!=$sgin){
            RedisService::set("{$cacheKey}:sign",['params'=> request()->all(),'result'=> $params], 3600);
//            return 'Sign error';
        }

        $address = isset($params['address'])? trim($params['address']) : '';
        $txid = isset($params['txid'])? trim($params['txid']) : '';
        $amount = isset($params['amount'])? floatval($params['amount']) : 0;
        $currency = isset($params['currency'])? trim($params['currency']) : '';
        $currency = $currency=='USDT-Solana'? 'USDT': 'Solana';
        // 验证金额
        if($amount<=0){
            RedisService::set("{$cacheKey}:error",['error'=>'交易金额错误','result'=> $params], 7200);
            return 'Amount error';
        }

        if($params['status'] != 1){
            RedisService::set("{$cacheKey}:error",['error'=>'充值交易未成功','result'=> $params], 7200);
            return 'Trade failed';
        }

        // 交易Hash验证
        $count = 0;
        $tradeData = [];
        while($count < 3){
            $tradeData = WalletService::make()->getTradeDetail($txid);
            if(empty($tradeData)){
                $count++;
                sleep(1);
            }else {
                break;
            }
        }

        $ownerAddress = isset($tradeData['source_owner'])? $tradeData['source_owner'] : '';
        $toAddress = isset($tradeData['destination_owner'])? $tradeData['destination_owner'] : '';
        $tokenAddress = isset($tradeData['token']['address'])? $tradeData['token']['address'] : '';
        $tradeAmount = isset($tradeData['amount'])? floatval($tradeData['amount']) : 0;
        $symbol = isset($tradeData['token']['symbol']) && $tradeData['token']['symbol']? strtoupper($tradeData['token']['symbol']) : 'USDT';
        $decimals = isset($tradeData['token']['decimals']) && $tradeData['token']['decimals']? intval($tradeData['token']['decimals']) : 6;
        $realAmount = moneyFormat($tradeAmount/pow(10, $decimals), 6);
        if(empty($tradeData) || empty($ownerAddress) || empty($toAddress) || $tradeAmount<=0 || empty($symbol)){
            RedisService::set("{$cacheKey}:error",['error'=>'交易hash验证错误','tradeData'=>$tradeData,'result'=> $params], 7200);
            return 'Trade hash verify failed';
        }

        // 处理交易记录
        if (!WalletLogModel::checkExists($txid)) {
            $log = [
                'owner_address' => $ownerAddress,  // 来源地址
                'to_address' => $toAddress,  // 入账地址
                'token_address' => $tokenAddress,
                'source' => isset($tradeData['source'])? $tradeData['source'] : '',
                'destination' => isset($tradeData['destination'])? $tradeData['destination'] : '',
                'token_type' => $symbol=='USDT'? 1: 2,
                'hash' => $txid,
                'amount' => $amount,
                'create_time' => time(),
                'update_time' => time(),
                'status' => 1,
                'mark' => 1,
            ];
            WalletLogModel::insert($log);
        }

        if(strtoupper($currency) != $symbol){
            RedisService::set("{$cacheKey}:error",['error'=>'回调币种和交易币种不一致','tradeData'=>$tradeData,'result'=> $params], 7200);
            return 'Currency error';
        }

        // hash 验证金额和账户
        if(intval($realAmount) != intval($amount)){
            RedisService::set("{$cacheKey}:error",['error'=>'交易金额验证错误','tradeData'=>$tradeData,'result'=> $params], 7200);
            return 'Trade amount error';
        }

        // 交易账户和回调账户是否一致
        if($address != $toAddress){
            RedisService::set("{$cacheKey}:error",['error'=>'充值到账地址错误','tradeData'=>$tradeData,'result'=> $params], 7200);
            return 'Address error';
        }

        // USDT 充值
        if($symbol == 'USDT'){
            // 最低充值验证
            $coinInMin = ConfigService::make()->getConfigByCode('recharge_min_money');
            $coinInMin = $coinInMin > 0 ? $coinInMin : 0;
            if ($amount < $coinInMin) {
                RedisService::set("{$cacheKey}:error", ['error' => '金额较小不处理', 'min' => $coinInMin,'tradeData'=>$tradeData,'params'=>$params], 7200);
                return 'Amount limit';
            }

            // 充值回调是否已经处理过
            if (BalanceLogModel::checkExists($txid)) {
                RedisService::set("{$cacheKey}:error", ['error' => '该笔回调已处理过', 'min' => $coinInMin,'tradeData'=>$tradeData,'params'=>$params], 7200);
                return 'The callback has been processed';
            }

            // 查找充值地址绑定用户信息
            $rechargeType = ConfigService::make()->getConfigByCode('recharge_limit_type',1);
            $rechargeType = $rechargeType==1? $rechargeType : 2;
            $where = ['wallet_url' => $ownerAddress,'recharge_url'=> $toAddress, 'mark' => 1];
            if($rechargeType == 2){
                unset($where['wallet_url']); // 不限制充值来源地址
            }
            $memberInfo = MemberModel::where($where)
                ->select(['id', 'nickname', 'wallet_url', 'usdt', 'sbt'])
                ->orderBy('id', 'asc')
                ->first();
            $walleturl = isset($memberInfo['wallet_url']) ? trim($memberInfo['wallet_url']) : '';
            $userUsdt = isset($memberInfo['usdt']) ? floatval($memberInfo['usdt']) : 0;
            $userId = isset($memberInfo['id']) ? intval($memberInfo['id']) : 0;
            if (empty($memberInfo) || $userId<=0 || empty($walleturl)) {
                RedisService::set("{$cacheKey}:error", ['error' => '该笔回调地址未绑定用户信息或账户错误', 'min' => $coinInMin,'info'=>$memberInfo,'tradeData'=>$tradeData,'params'=>$params], 7200);
                return 'Account info no bind';
            }

            try {
                DB::beginTransaction();
                $amount = moneyFormat($realAmount, 2);
                $updateData = ['update_time' => time()];
                $updateData['usdt'] = DB::raw("usdt + {$amount}");
                if (!MemberModel::where(['id' => $userId])->update($updateData)) {
                    DB::rollBack();
                    RedisService::set("{$cacheKey}:error", ['error' => '该笔回调入账处理失败', 'min' => $coinInMin,'userUsdt'=>$userUsdt,'update'=>$updateData,'tradeData'=>$tradeData,'params'=>$params], 7200);
                    return 'Account processing failed';
                }

                // 充值明细
                $data = [
                    'user_id' => $userId,
                    'order_no' => get_order_num('SR'),
                    'type' => 1,
                    'coin_type' => 1,
                    'money' => $amount,
                    'actual_money' => $amount,
                    'pay_type' => 20,
                    'pay_status' => 20,
                    'pay_at' => date('Y-m-d H:i:s'),
                    'hash' => $txid,
                    'wallet_url' => $walleturl,
                    'pt_wallet_url' => $address,
                    'trade_cid' => $tradeCid,
                    'date' => date('Y-m-d'),
                    'create_time' => time(),
                    'update_time' => time(),
                    'status' => 2,
                    'mark' => 1,
                ];
                if (!BalanceLogModel::insert($data)) {
                    DB::rollBack();
                    RedisService::set("{$cacheKey}:error", ['error' => '该笔回调入账明细处理失败', 'min' => $coinInMin,'log'=>$data,'tradeData'=>$tradeData,'params'=>$params], 7200);
                    return 'Account log processing failed';
                }

                // 用户账户明细
                $log = [
                    'user_id' => $userId,
                    'order_no' => $data['order_no'],
                    'user_type' => 1,
                    'type' => 3,
                    'coin_type' => 1,
                    'hash' => $txid,
                    'money' => $amount,
                    'before_money' => $userUsdt,
                    'create_time' => time(),
                    'update_time' => date('Y-m-d H:i:s'),
                    'remark' => 'USDT充值',
                    'status' => 1,
                    'mark' => 1,
                ];

                if (!AccountLogModel::insert($log)) {
                    DB::rollBack();
                    RedisService::set("{$cacheKey}:error", ['error' => '该笔回调账户明细处理失败', 'min' => $coinInMin,'log'=>$log,'tradeData'=>$tradeData,'params'=>$params], 7200);
                    return 'Account bill processing failed';
                }

                // 平台进账
                FinanceService::make()->saveLog(0, $amount, 1);

                DB::commit();
                RedisService::set("{$cacheKey}:success", ['error' => '成功回调处理成功', 'min' => $coinInMin,'log'=>$log,'tradeData'=>$tradeData,'params'=>$params], 7200);
                return 'success';
            } catch (\Exception $exception){
                DB::rollBack();
                RedisService::set("{$cacheKey}:error", ['error' => '回调处理异常：'.$exception->getMessage(), 'tradeData'=>$tradeData,'params'=>$params], 7200);
                return 'exception';
            }
        }

        RedisService::set("caches:cregisPay:recharge_{$tradeCid}:failed", ['error'=>'回调未处理','params' => $params,'tradeData'=>$tradeData], 7200);
        return '';
    }

    /**
     * 提现回调
     * @return mixed
     */
    public function withdrawCallBack()
    {
        $data = file_get_contents('php://input');
        RedisService::set("caches:cregisPay:withdraw_callback", ['params' => request()->all(), 'result' => $data], 7200);
        $params = $data?json_decode($data, true) : [];
        $params = empty($params)? request()->all() : $params;
        if(empty($params)){
            RedisService::set("caches:cregisPay:withdraw_data_".date('YmdHis'),['params'=> $params,'data'=> $data], 3600);
            return 'Callback data error';
        }
        $getSign = $params['sign'];
        $orderNo = isset($params['third_party_id'])? trim($params['third_party_id']) : '';
        $tradeCid = isset($params['cid'])? trim($params['cid']) : '';
        $orderNo = $orderNo? $orderNo : $tradeCid;
        $sgin = $this->dispatch->generateSign(self::$config['api_key'], $params);
        RedisService::set("caches:cregisPay:withdraw_{$orderNo}:callback", ['params' => request()->all(), 'result' => $params], 7200);
        if($getSign!=$sgin){
            RedisService::set("caches:cregisPay:withdraw_{$orderNo}:sign",['params'=> request()->all(),'result'=> $params], 3600);
            return 'Withdraw sign error';
        }
        $payStatus = $params['status'] == 0 || $params['status'] == 6? 20 : 30;
        $remark = '交易回调成功';
        if ($params['status'] == 2) {
            $remark = '签名驳回';
        } else if ($params['status'] == 4) {
            $remark = '审批驳回';
        } else if ($params['status'] == 7) {
            $remark = '交易失败';
        }


        $txid = isset($params['txid'])? trim($params['txid']) : '';
        $updateData = ['pay_status'=> $payStatus,'hash'=>$txid,'remark'=> $remark];
        if($payStatus == 20){
            $updateData['pay_at'] = date('Y-m-d H:i:s');
        }
        if(!BalanceLogModel::where(['order_no'=> $orderNo,'trade_cid'=> $tradeCid,'mark'=>1])->update($updateData)){
            RedisService::set("caches:cregisPay:withdraw_{$orderNo}:failed", ['params' => request()->all(),'data'=>$updateData, 'result' => $params], 7200);
            $this->error = 2034;
            return 'Account catch error';
        }

        RedisService::set("caches:cregisPay:withdraw_{$orderNo}:success", ['params' => request()->all(),'data'=>$updateData, 'result' => $params], 7200);
        return 'success';
    }

    /**
     * 回调处理
     * @param $params
     */
    public function catchNotify($params)
    {
        RedisService::set('caches:cregisPay:notify', $params);
    }


}