bot-28/app/Services/Payment/SanJinService.php

<?php 

namespace App\Services\Payment;

use GuzzleHttp\Client;
use GuzzleHttp\Exception\RequestException;
use GuzzleHttp\Psr7\Response;
use App\Services\BaseService;
use Illuminate\Support\Facades\Lang;
use App\Models\RechargeChannel;
use App\Models\RechargeChannelGroup;

class SanJinService extends BaseService
{
    const REQUEST_URL = 'https://jkapi-sanjin.jkcbb.com/';

    
    const PRODUCT_TEST = 'T888'; // 测试支付通道

    public static $CHANNEL = [
        'wxsm' => '微信扫码',
        'zfbsm' => '支付宝扫码',
        'zfbge' => '支付宝固额',
        'zfbzk' => '支付宝转卡',
        'ylsm' => '银联扫码',
        'szrmb' => '数字人民币',
        'sdjt' => '手动金条',
    ];

    /**
     * @description: 获取支付频道
     * @return {*}
     */    
    public static function getChannel($type = '', ?int $groupId = null)
    {
        if ($type) {
            if ($groupId && RechargeChannel::checkRechargeChannel($type, $groupId) === false) return '';
            $name = RechargeChannel::where('data_type', 1)->where('from', 1)
                ->where('status', 1)->where('type', $type)->value('name');
            return Lang($name);
        } else {
            $query = RechargeChannel::query()->where('status', 1)->where('data_type', 1)->where('from', 1);
            if ($groupId) {
                $group = RechargeChannelGroup::query()->find($groupId);
                $query->whereIn('type', $group ? (array)$group->recharge_type : []);
            }
            return $query->orderBy('sort')->get(['type', 'name'])
                ->mapWithKeys(fn ($row) => [(string)$row->type => lang($row->name)])->all();
        }
    }

    // public static $PRODUCT = [
    //     // 'T888' => [
    //     //     'type' => 'test',
    //     //     'rate' => 0.02,
    //     //     'max' => 5000,
    //     //     'min' => 10
    //     // ],
    //     'WX002' => [
    //         'type' => 'wxsm',
    //         'rate' => 0.095,
    //         'max' => 3000,
    //         'min' => 100
    //     ],
    //     'YL001' => [
    //         'type' => 'ylsm',
    //         'rate' => 0.05,
    //         'max' => 500,
    //         'min' => 50
    //     ],
    //     'SZ002' => [
    //         'type' => 'szrmb',
    //         'rate' => 0.05,
    //         'max' => 100,
    //         'min' => 10
    //     ],
    //     'SZ001' => [
    //         'type' => 'szrmb',
    //         'rate' => 0.048,
    //         'max' => 5000,
    //         'min' => 100
    //     ],
    //     'ZFB001' => [
    //         'type' => 'zfbsm',
    //         'rate' => 0.085,
    //         'max' => 200,
    //         'min' => 100
    //     ],
    //     'ZFB002' => [
    //         'type' => 'zfbsm',
    //         'rate' => 0.057,
    //         'max' => 1000,
    //         'min' => 200
    //     ],
    //     'ZFB003' => [
    //         'type' => 'zfbsm',
    //         'rate' => 0.052,
    //         'max' => 3000,
    //         'min' => 1000
    //     ],
    //     'ZFB004' => [
    //         'type' => 'zfbsm',
    //         'rate' => 0.042,
    //         'max' => 20000,
    //         'min' => 3000
    //     ],
    //     'ZFB005' => [
    //         'type' => 'zfbge',
    //         'rate' => 0.027,
    //         'fixed' => [945 ,988 ,990]
    //     ],
    //     'ZFBZK001' => [
    //         'type' => 'zfbzk',
    //         'rate' => 0.05,
    //         'max' => 2000,
    //         'min' => 200
    //     ],
    //     'JT000' => [
    //         'type' => 'sdjt',
    //         'rate' => 0.08,
    //         'max' => 300,
    //         'min' => 100
    //     ],
    //     'JT001' => [
    //         'type' => 'sdjt',
    //         'rate' => 0.08,
    //         'max' => 3000,
    //         'min' => 300
    //     ],
    //     'JT002' => [
    //         'type' => 'sdjt',
    //         'rate' => 0.08,
    //         'max' => 5000,
    //         'min' => 500
    //     ],
    // ];
    public static function product(?int $groupId = null)
    {
        $product = RechargeChannel::product(1);
        if (!$groupId) return $product;
        $group = RechargeChannelGroup::query()->find($groupId);
        $types = $group ? (array)$group->recharge_type : [];
        return array_filter($product, fn ($row) => in_array((string)$row['type'], $types, true));
    }

    // 获取商户ID
    public static function getMerchantId()
    {
        return config('app.tree_pay_mch_id');
    }
    // 获取商户秘钥
    public static function getSecret()
    {
        return config('app.tree_pay_key');
    }

    // 获取异步的通知地址
    public static function getNotifyUrl()
    {
        $host = config('app.url');
        return $host.'/api/pay/harvest';
    }


    /**
     * @description: 获取请求客户端
     * @return {*}
     */
    public static function getClient(): Client
    {
        return new Client([
            'base_uri' => self::REQUEST_URL,
            'timeout' => 5.0,
        ]);
    }

    // 签名
    public static function signature($params = [],$must = [])
    {
        if($must){
            foreach($params as $k => $v){
                if(!in_array($k,$must)){
                    unset($params[$k]);
                }
            }
        }
        ksort($params, SORT_STRING);
     

        $parts = [];
        foreach($params as $k => $v){
            array_push($parts,$k.'='.$v);
        }
        $mch_key = self::getSecret();
        $parts[] = "key=".$mch_key;

        $sign = md5(implode('&',$parts));
        return $sign;
    }

    /**
     * @description: 发起支付订单
     * @param {*} $amount 金额单位分
     * @param {*} $orderNo  订单号
     * @param {*} $type 支付通道
     * @return {*}
     */    
    public static function pay($amount,$orderNo,$type = self::PRODUCT_TEST)
    {

        $must = ['mchId','productId','outTradeNo','amount','reqTime','notifyUrl'];
        $mch_id = self::getMerchantId();

        
        
        $data = [];
        $data['mchId'] = $mch_id;
        $data['amount'] = $amount;
        $data['outTradeNo'] = $orderNo;
        $data['notifyUrl'] = self::getNotifyUrl();
        $data['reqTime'] = time() * 1000;
        $data['productId'] = $type;

        
        $data['sign'] = self::signature($data,$must);
        $client = self::getClient();
        $response = $client->post('api/v1/pay/unifiedOrder', [
            'json' => $data,
            'headers' => [
                'Content-Type' => 'application/json',
            ]
        ]);

        $body = $response->getBody();
        return json_decode($body->getContents(), true);
    }

    /**
     * @description: 查询订单
     * @param {*} $orderNo  订单号
     * @return {*}
     */    
    public static function queryOrder($orderNo)
    {

        $must = ['mchId','outTradeNo','reqTime'];
        $mch_id = self::getMerchantId();

        
        
        $data = [];
        $data['mchId'] = $mch_id;
        $data['outTradeNo'] = $orderNo;
        $data['reqTime'] = time() * 1000;
        
        $data['sign'] = self::signature($data,$must);
        $client = self::getClient();
        $response = $client->post('api/v1/pay/queryOrder', [
            'json' => $data,
            'headers' => [
                'Content-Type' => 'application/json',
            ]
        ]);

        $body = $response->getBody();
        return json_decode($body->getContents(), true);
    }

    public static function getWhere(array $search = []): array
    {
        return [];
    }

}