php/app/controller/api/merchant/order/OrderMerchant.php

<?php
/**
 * @package merchant
 * @Author: Qinii
 * @Date: 2020/5/27
 */
namespace app\controller\api\merchant\order;

use AdaPaySdk\AdapayTools;
use app\common\repositories\merchant\MerchantRepository;
use app\traits\HaikeApiRequest;
use app\traits\HuiPay;
use think\App;
use think\Exception;
use crmeb\basic\BaseController;
use app\common\repositories\merchant\order\OrderMerchantRepository as repository;
use think\facade\Cache;
use think\facade\Db;
use think\facade\Log;

class OrderMerchant extends BaseController
{
    use HaikeApiRequest;
    use HuiPay;
    /**
     * @var \Redis
     */
    protected $redis;

    /**
     * @var repository
     */
    protected $repository;

    /**
     * StoreBrand constructor.
     * @param App $app
     * @param repository $repository
     */
    public function __construct(App $app, repository $repository)
    {
        parent::__construct($app);
        $this->repository = $repository;
        $this->redis = Cache::store('redis')->handler();
    }
    /**
     * 订单列表
     * @return mixed
     * @author php迷途小书童
     * @created 2021/1/16 10:49
     */
    public function lst()
    {
        $uid = $this->request->uid();
        [$page, $limit] = $this->getPage();
        return app('json')->success($this->repository->getMerchantList($uid, [
            'paid' => 1,
        ], $page, $limit));
    }
    /**
     * 订单列表
     * @return mixed
     * @author php迷途小书童
     * @created 2021/1/16 10:49
     */
    public function del()
    {
        $time=time();
        $end=$time-60*5;
        $stat=date('Y-m-d H:i:s',$end);

        Db::name('order_merchant')
            ->where('is_broadcast',0)
            ->whereNotNull('pay_time')
            ->whereTime('pay_time','<',$stat)
            ->update(['is_broadcast'=>1]);
    }
//    /**
//     * 订单列表
//     * @return mixed
//     * @author php迷途小书童
//     * @created 2021/1/16 10:49
//     */
//    public function lst()
//    {
//        $merId = $this->request->userInfo()->mer_id;
//        [$page, $limit] = $this->getPage();
//        return app('json')->success($this->repository->getMerchantList($merId, [
//            'paid' => 1,
//        ], $page, $limit));
//    }

    /**
     * 修改语音播报状态
     * @return mixed
     * @author php迷途小书童
     * @created 2021/3/8 18:08
     */
    public function broadcast()
    {
        $orderId = (int)$this->request->param('order_id', 0);
        $order = $this->repository->getOneById($orderId);
        if (!$order)
            return app('json')->fail('订单不存在');
        $order->is_broadcast = 1;
        $order->save();
        return app('json')->success('修改成功');
    }

    /**
     * 创建订单
     * @return mixed
     * @author php迷途小书童
     * @created 2021/1/16 10:52
     */
    public function createOrder(MerchantRepository $merchantRepository)
    {
        $merchantUserId = (int)$this->request->param('user_id', 0);
        $merId = $this->request->param('mer_id', 0);
        if($merId==496){
            return app('json')->fail('该商户暂不支持该支付方式');
        }

        if(strpos($merId,'_') !== false){
            $mer_ = explode("_",$merId);
            $merId=$mer_[0];
        }
        log::info($merId);
        $payUserId = $this->request->param('pay_user_id', null);
//        Db::name('log')->insert(['data'=>json_encode($payUserId)]);
        $nickname = $this->request->param('nickname', null);
        $avatar = $this->request->param('avatar', null);
        $money = (float)$this->request->param('money', 0);
        $tradeType = $this->request->param('trade_type');
        $mer = $merchantRepository->getWhere(['mer_id' => $merId]);

        if (!$mer)
            return app('json')->fail('商户不存在');

        if (!in_array($tradeType, explode(',', $mer['trade_type'])))
            return app('json')->fail('该商户暂不支持该支付方式');

        if ($mer['mer_id'] == 324 && !in_array($money,[300,1000,3000]))
            return app('json')->fail('支付金额不正确，请支付300、1000、3000元的档位');

        $this->redis->set('create_order' . $payUserId, 1, 5);
        $merchant_type=Db::name('merchant')->where('mer_id',$merId)->value('merchant_type');
        try {
            if($merchant_type==2){
                $order = $this->repository->createOrder_276(
                    [
                        'merchant_user_id' => $merchantUserId,
                        'mer_id' => $merId,
                        'merch_no' => $mer['merch_no'],
                        'pay_user_id' => $payUserId,
                        'nickname' => $nickname,
                        'avatar' => $avatar,
                        'money' => $money,
                        'trade_type' => $tradeType,
                        'qr_num' => $mer_[1]??0,
                    ]
                );
            }else{
                $order = $this->repository->createOrder(
                    [
                        'merchant_user_id' => $merchantUserId,
                        'mer_id' => $merId,
                        'merch_no' => $mer['merch_no'],
                        'pay_user_id' => $payUserId,
                        'nickname' => $nickname,
                        'avatar' => $avatar,
                        'money' => $money,
                        'trade_type' => $tradeType,
                        'qr_num' => $mer_[1]??0,
                    ]
                );
            }
        } catch (\Throwable $e) {
            $this->redis->del('create_order' . $payUserId);
            return app('json')->fail($e->getMessage());
        }
        $this->redis->del('create_order' . $payUserId);
        try {
            return app('json')->success($order);
        } catch (\Throwable $e) {
            return app('json')->status('error', $e->getMessage(), ['out_trade_no' => $order->out_trade_no]);
        }
    }
    /**
     * 聚合公众号支付API
     * @return mixed
     * @author php迷途小书童
     * @created 2021/1/16 10:02
     */
    public function jsapiPay(){
        try {


        $type = (string)$this->request->param("type", '');
        $out_trade_no = (string)$this->request->param("out_trade_no", '');
        $order = $this->repository->getOne($out_trade_no);
        if (!$order)
            return app('json')->fail('订单不存在');
        $merchant=Db::name('merchant')->where('mer_id',$order['mer_id'])->find();
//        Db::name('log')->insert(['data'=>'商户信息---'.json_encode($merchant)]);
        if($type=='HF'){
            //这个不用管他。这两商户关了
            if($merchant['hf_type']==2) {
//                Db::name('log')->insert(['data'=>'单独付款进来了']);
                if($merchant['mer_id']==290){
                    $data=$this->HF_DANDU_290($order);
                }elseif($merchant['mer_id']==276){
                    $data=$this->HF_DANDU_276($order);
                }
            }else{
//                if($merchant['merchant_type']==2){
//                    $data=$this->HF_276($order);
//                }else{
                    $data=$this->HF($order);
//                }
            }

        }else{
            $data = $this->getJsapiPayGateway($order);
        }
        }catch (\Throwable $e){
            Db::name('log')->insert(['data'=>'支付错误：'.$e->getFile().'：'.$e->getLine().'【'.$e->getMessage().'】']);
        }
        log::info('聚合公众号支付API'.json_encode($data));
        try {
            if ($data['return_code'] === 10000) {
                $params = [
                    'trade_no' => $data['trade_no'],
                    'channel_trade_no' => $data['channel_trade_no'],
                ];
                if ($order->trade_type == "ALI")
                    $params['alipay_no'] = $data['alipay_no'];

                $this->repository->updateOrder($order, $params);
                return app('json')->success($data);
            } elseif($data['code']=='1000'){
                $params = [
                    'trade_no' => $data['order_no'],
                    'channel_trade_no' => $data['party_order_id'],
                    'hf_pay_id' => $data['id'],
                ];
////
//                $this->repository->updateOrder($order, $params);
                Db::name('order_merchant')->where(['out_trade_no'=>$out_trade_no])->update($params);
                return app('json')->success($data);
            }else {
                return app('json')->fail($data['return_msg']);
            }
        } catch (\Throwable $e) {
            return app('json')->status('error', $e->getMessage(), ['out_trade_no' => $order->out_trade_no]);
        }
    }

    public function HF($order)
    {
//        $amt = $order['service_money'] + $order['pension'] + $order['swipe_fee']; //总可分佣金额
        $amt = $order['service_money'] + $order['pension']; //总可分佣金额 手续费由商家出
        $amt=sprintf("%01.2f",$amt);    //保留2位数字。
        $mouny=$order['money']-$amt;            //商户货款
        $mouny=sprintf("%01.2f",$mouny); //保留2位小时。

        $goods_title=Db::name('merchant')->where('mer_id',$order['mer_id'])->find();

        if($order['trade_type']=='WX'){

            $pay_wx = systemConfig('pay_wx');

            //微信
            if($pay_wx == 3){
                $member_id=Db::name('merchant_member')->where('mer_id',$order['mer_id']) ->where("type",3)->value('member_id');
                $key='api_live_b0a687ec-5450-4ada-a0e4-65bac0f46871';
                $app_id='app_383a75dd-c03d-44ab-8f58-92c60fe9b9d0';
                $member_70 = 'jsdk_member_wx21689817115207';
                $member_20 = 'jsdk_member_wx21689817115207';
            }else{
                $member_id=Db::name('merchant_member')->where('mer_id',$order['mer_id']) ->where("type",2)->value('member_id');
                $key='api_live_90ef02e4-54ac-41ee-adf1-e4927d23d58f';
                $app_id='app_0827b960-b932-45ec-b800-4e850091b419';
                $member_70 = 'jsdk_member_wx1689758980590';
                $member_20 = 'jsdk_member_wx1689758980590';
            }


//            $member_id=$goods_title['hf_member_id_wx'];
//            $app_id='app_0827b960-b932-45ec-b800-4e850091b419';
            $type='2';
            $pay_channel='wx_pub';
//            $key='api_live_90ef02e4-54ac-41ee-adf1-e4927d23d58f';
            $expend=[
                'open_id'=>$order['pay_user_id']
            ];



        }elseif($order['trade_type']=='ALI'){
            $member_id=$goods_title['hf_member_id'];
            $app_id='app_44108546-d27a-48ee-88c1-84b45b75114f';
            $type='1';
            $pay_channel='alipay_pub';
            $expend=[
                'buyer_id'=>$order['pay_user_id']
            ];
            $key='api_live_b23537ed-64b8-45d6-832e-fb228aa9e0a9';
            $member_70 = 'jsdk_member_ali1689817119448';
            $member_20 = 'jsdk_member_ali1689817119448';
            // 天地博爱通道
//            $app_id='app_0827b960-b932-45ec-b800-4e850091b419';
//            $key='api_live_90ef02e4-54ac-41ee-adf1-e4927d23d58f';
        }


        if($order['mer_id']==324 ){
            $div_members = [
                [
                    'member_id' => $member_id,
                    'amount'    => bcmul($order['money'], 0.3, 2),
                    'fee_flag'  => 'N'
                ],
                [
                    'member_id' => $member_70,
                    'amount'    => bcmul($order['money'], 0.7, 2),
                    'fee_flag'  => 'Y'
                ]
            ];
        }else if($order['mer_id']==496 ){
            $amt = $order['pension'] ; //只给养老金
            $amt=sprintf("%01.2f",$amt);    //保留2位数字。
            $mouny=$order['money']-$amt;            //商户货款
            $mouny=sprintf("%01.2f",$mouny); //保留2位小时。
            $div_members = [
                [
                    'member_id' => $member_id,
                    'amount'    => $mouny,
                    'fee_flag'  => 'Y'
                ],
                [
                    'member_id' => $member_20,
                    'amount'    => $amt,
                    'fee_flag'  => 'N'
                ]
            ];

        }else if($order['mer_id']==321 ){
            $div_members = [
                [
                    'member_id' => $member_id,
                    'amount'    => bcmul($order['money'], 1, 2),
                    'fee_flag'  => 'Y'
                ]
            ];
        }else{
            if($amt=='0.00'){
                $div_members=[
                    [
                        'member_id'=>$member_id,
                        'amount'=>$mouny,
                        'fee_flag'=>'Y'
                    ]
                ];
            }else{
                $div_members= [
                    [
                        'member_id'=>$member_id,
                        'amount'=>$mouny,
                        'fee_flag'=>'Y'
                    ],
                    [
                        'member_id'=>$member_20,
                        'amount'=>$amt,
                        'fee_flag'=>'N'
                    ]
                ];
            }
        }
        if($order['trade_type']=='WX'){
            $params=[
                'order_no'=>$order['out_trade_no'].'_'.rand(000,999),
                'app_id'=>$app_id,
                'pay_channel'=>$pay_channel,
                'pay_amt'=>(string)$order['money'],
                'goods_title'=>$goods_title['mer_name'],
                'goods_desc'=>$goods_title['mer_name'],
                'device_info'=>[
                'device_ip'=>app('request')->ip()
//                    'device_ip'=>'115.171.134.68'
                ],

                'expend'=>json_encode($expend),
                'div_members'=>json_encode($div_members),
                'fee_mode'=>'I',
                'notify_url'=>env('APP_URL')."/api/jsapiPay/notify/HF"
            ];
        }elseif($order['trade_type']=='ALI'){
            $params=[
                'order_no'=>$order['out_trade_no'].'_'.rand(000,999),
                'app_id'=>$app_id,
                'pay_channel'=>$pay_channel,
                'pay_amt'=>(string)$order['money'],
                'goods_title'=>$goods_title['mer_name'],
                'goods_desc'=>$goods_title['mer_name'],
                'device_info'=>[
                'device_ip'=>app('request')->ip()
//                    'device_ip'=>'115.171.134.68'
                ],

            'expend'=>json_encode($expend),
                'div_members'=>json_encode($div_members),
                'fee_mode'=>'I',
                'notify_url'=>env('APP_URL')."/api/jsapiPay/notify/HF"
            ];
        }
//        dump($type);return ;
        $res=$this->Payment_create_traits($params,$type,$key);
//        Db::name('log')->insert(['data'=>'发起支付参数：'.json_encode($params,true)]);
//        Db::name('log')->insert(['data'=>'支付返回：'.json_encode($res,true)]);
        if(!empty($res['error_code'])){
            $res1['code']='1000';
            $res1['return_msg']=$res['error_msg'];
            $res1['return_code']=1200;
            return $res1;
        }
        $res['code']='1000';
        $res['return_code']='999';
        return $res;
    }

    public function HF_DANDU_290($order)
    {
        $merchant=Db::name('merchant_intention')->where('mer_id',$order['mer_id'])->find();
        $goods_title=Db::name('merchant')->where('mer_id',$order['mer_id'])->find();
        if($order['trade_type']=='WX'){
            $fenyongmember_id=$goods_title['hf_dimension_id_wx'];
            $ingtaimember_id=$goods_title['hf_pingtai_id_wx'];
            $app_id=$merchant['app_id_wx'];
            $type='2';
            $pay_channel='wx_pub';
            $key=$merchant['hf_api_key_wx'];
            $expend=[
                'open_id'=>$order['pay_user_id']
            ];
        }elseif($order['trade_type']=='ALI'){
            $fenyongmember_id=$goods_title['hf_dimension_id_al'];
            $ingtaimember_id=$goods_title['hf_pingtai_id_al'];
            $app_id=$merchant['app_id'];
            $type='1';
            $pay_channel='alipay_pub';
            $expend=[
                'buyer_id'=>$order['pay_user_id']
            ];
            $key=$merchant['hf_api_key'];
        }
        $merchant_money=bcmul($order['money'],'0.4',2);
        $fenyongjine=bcmul($order['money'],'0.5',2);
        $pingtai_money=bcmul($order['money'],'0.1',2);

            $div_members= [
                [
                    'member_id'=>$fenyongmember_id,
                    'amount'=>$fenyongjine,
                    'fee_flag'=>'N'
                ],
                [
                    'member_id'=>0,
                    'amount'=>$merchant_money,
                    'fee_flag'=>'Y'
                ],
                [
                    'member_id'=>$ingtaimember_id,
                    'amount'=>$pingtai_money,
                    'fee_flag'=>'N'
                ]
            ];
        if($order['trade_type']=='WX'){
            $params=[
                'order_no'=>$order['out_trade_no'].'_'.rand(000,999),
                'app_id'=>$app_id,
                'pay_channel'=>$pay_channel,
                'pay_amt'=>(string)$order['money'],
                'goods_title'=>$goods_title['mer_name'],
                'goods_desc'=>$goods_title['mer_name'],
                'device_info'=>[
                    'device_ip'=>app('request')->ip()
                ],

                'expend'=>json_encode($expend),
                'div_members'=>json_encode($div_members),
                'fee_mode'=>'I',
                'notify_url'=>env('APP_URL')."/api/jsapiPay/notify/HF"
            ];
        }elseif($order['trade_type']=='ALI'){
            $params=[
                'order_no'=>$order['out_trade_no'].'_'.rand(000,999),
                'app_id'=>$app_id,
                'pay_channel'=>$pay_channel,
                'pay_amt'=>(string)$order['money'],
                'goods_title'=>$goods_title['mer_name'],
                'goods_desc'=>$goods_title['mer_name'],
                'device_info'=>[
                    'device_ip'=>app('request')->ip()
                ],

                'expend'=>json_encode($expend),
                'div_members'=>json_encode($div_members),
                'fee_mode'=>'I',
                'notify_url'=>env('APP_URL')."/api/jsapiPay/notify/HF"
            ];
        }
        $res=$this->Payment_create_traits($params,$type,$key);
        if(!empty($res['error_code'])){
            $res1['code']='1000';
            $res1['return_msg']=$res['error_msg'];
            $res1['return_code']=1200;
            return $res1;
        }
        $res['code']='1000';
        $res['return_code']='999';
        return $res;
    }
    public function HF_DANDU_276($order)
    {
        $merchant=Db::name('merchant_intention')->where('mer_id',$order['mer_id'])->find();
        $goods_title=Db::name('merchant')->where('mer_id',$order['mer_id'])->find();
        if($order['trade_type']=='WX'){

            $ingtaimember_id=$goods_title['hf_pingtai_id_wx'];
            $app_id=$merchant['app_id_wx'];
            $type='2';
            $pay_channel='wx_pub';
            $key=$merchant['hf_api_key_wx'];
            $expend=[
                'open_id'=>$order['pay_user_id']
            ];
        }elseif($order['trade_type']=='ALI'){

            $ingtaimember_id=$goods_title['hf_pingtai_id_al'];
            $app_id=$merchant['app_id'];
            $type='1';
            $pay_channel='alipay_pub';
            $expend=[
                'buyer_id'=>$order['pay_user_id']
            ];
            $key=$merchant['hf_api_key'];
        }
        $merchant_money=bcmul($order['money'],'0.62',2);
        $pingtai_money=bcmul($order['money'],'0.38',2);
            $div_members= [
                [
                    'member_id'=>0,
                    'amount'=>$merchant_money,
                    'fee_flag'=>'Y'
                ],
                [
                    'member_id'=>$ingtaimember_id,
                    'amount'=>$pingtai_money,
                    'fee_flag'=>'N'
                ]
            ];
        if($order['trade_type']=='WX'){
            $params=[
                'order_no'=>$order['out_trade_no'].'_'.rand(000,999),
                'app_id'=>$app_id,
                'pay_channel'=>$pay_channel,
                'pay_amt'=>(string)$order['money'],
                'goods_title'=>$goods_title['mer_name'],
                'goods_desc'=>$goods_title['mer_name'],
                'device_info'=>[
                    'device_ip'=>app('request')->ip()
                ],

                'expend'=>json_encode($expend),
                'div_members'=>json_encode($div_members),
                'fee_mode'=>'I',
                'notify_url'=>env('APP_URL')."/api/jsapiPay/notify/HF"
            ];
        }elseif($order['trade_type']=='ALI'){
            $params=[
                'order_no'=>$order['out_trade_no'].'_'.rand(000,999),
                'app_id'=>$app_id,
                'pay_channel'=>$pay_channel,
                'pay_amt'=>(string)$order['money'],
                'goods_title'=>$goods_title['mer_name'],
                'goods_desc'=>$goods_title['mer_name'],
                'device_info'=>[
                    'device_ip'=>app('request')->ip()
                ],

                'expend'=>json_encode($expend),
                'div_members'=>json_encode($div_members),
                'fee_mode'=>'I',
                'notify_url'=>env('APP_URL')."/api/jsapiPay/notify/HF"
            ];
        }
        $res=$this->Payment_create_traits($params,$type,$key);
        if(!empty($res['error_code'])){
            $res1['code']='1000';
            $res1['return_msg']=$res['error_msg'];
            $res1['return_code']=1200;
            return $res1;
        }
        $res['code']='1000';
        $res['return_code']='999';
        return $res;
    }
    public function HF_276($order)
    {
        $goods_title=Db::name('merchant')->where('mer_id',$order['mer_id'])->find();
        if($order['trade_type']=='WX'){
            $member_id=$goods_title['hf_member_id_wx'];
            $app_id='app_0827b960-b932-45ec-b800-4e850091b419';
            $type='2';
            $pay_channel='wx_pub';
            $key='api_live_90ef02e4-54ac-41ee-adf1-e4927d23d58f';
            $expend=[
                'open_id'=>$order['pay_user_id']
            ];
        }elseif($order['trade_type']=='ALI'){
            $member_id=$goods_title['hf_member_id'];
            $app_id='app_44108546-d27a-48ee-88c1-84b45b75114f';
            $type='1';
            $pay_channel='alipay_pub';
            $expend=[
                'buyer_id'=>$order['pay_user_id']
            ];
            $key='api_live_b23537ed-64b8-45d6-832e-fb228aa9e0a9';
        }

        $amt = $order['service_money'] + $order['pension'];
        $amt=sprintf("%01.2f",$amt);
        $mouny=$order['money']-$amt;
        $mouny=sprintf("%01.2f",$mouny);
        if($amt=='0.00'){
            $div_members=[
                [
                    'member_id'=>$member_id,
                    'amount'=>$mouny,
                    'fee_flag'=>'Y'
                ]
            ];
        }else{
            $div_members= [
                [
                    'member_id'=>$member_id,
                    'amount'=>$mouny,
                    'fee_flag'=>'Y'
                ],
                [
                    'member_id'=>0,
                    'amount'=>$amt,
                    'fee_flag'=>'N'
                ]
            ];
        }
        if($order['trade_type']=='WX'){
            $params=[
                'order_no'=>$order['out_trade_no'].'_'.rand(000,999),
                'app_id'=>$app_id,
                'pay_channel'=>$pay_channel,
                'pay_amt'=>(string)$order['money'],
                'goods_title'=>$goods_title['mer_name'],
                'goods_desc'=>$goods_title['mer_name'],
                'device_info'=>[
                'device_ip'=>app('request')->ip()
//                    'device_ip'=>'115.171.134.68'
                ],

                'expend'=>json_encode($expend),
                'div_members'=>json_encode($div_members),
                'fee_mode'=>'I',
                'notify_url'=>env('APP_URL')."/api/jsapiPay/notify/HF"
            ];
        }elseif($order['trade_type']=='ALI'){
            $params=[
                'order_no'=>$order['out_trade_no'].'_'.rand(000,999),
                'app_id'=>$app_id,
                'pay_channel'=>$pay_channel,
                'pay_amt'=>(string)$order['money'],
                'goods_title'=>$goods_title['mer_name'],
                'goods_desc'=>$goods_title['mer_name'],
                'device_info'=>[
                'device_ip'=>app('request')->ip()
//                    'device_ip'=>'115.171.134.68'
                ],

//            'expend'=>json_encode($expend),
                'div_members'=>json_encode($div_members),
                'fee_mode'=>'I',
                'notify_url'=>env('APP_URL')."/api/jsapiPay/notify/HF"
            ];
        }
//        dump($type);return ;
        $res=$this->Payment_create_traits($params,$type,$key);
        if(!empty($res['error_code'])){
            $res1['code']='1000';
            $res1['return_msg']=$res['error_msg'];
            $res1['return_code']=1200;
            return $res1;
        }
        $res['code']='1000';
        $res['return_code']='999';
        return $res;
    }
    /**
     * 支付后回调处理
     * @return mixed
     * @author php迷途小书童
     * @created 2021/1/16 14:41
     */
    public function notify($type){
        if($type=='HK'){
            try {
                $post = $this->request->post();
                Log::info($post);
                $bool = $this->doNotify($post);
                if (!$bool)
                    return app('json')->success(['result' => 'ERROR']);
                $bool = $this->repository->doNotify($post);
                if (!$bool)
                    return app('json')->success(['result' => 'ERROR']);
                return app('json')->success(['result' => 'SUCCESS']);
            } catch (\Throwable $e) {
                Log::info($e->getMessage());
                return app('json')->status('error', $e->getMessage());
            }
        }elseif ($type=='HF'){
            $post=$this->request->param();
            Db::name("log")->insert(array('data'=>'【异步接受到的参数】'.json_encode($post),));//日志记录
            $post_data_str = isset($post['data']) ? $post['data']: '';
            $post_sign_str = isset($post['sign']) ? $post['sign']: '';

            if (!empty($post['id'])) {
                $requestId = $post['id'];
                $redisKey = 'api-merchant-order-OrderMerchant-HF-request-id:' . $requestId;
                $ttl = 60;
                $redisHandler = Cache::store('redis')->handler();
                $isSet = $redisHandler->set($redisKey, 1, ['nx', 'ex' => $ttl]);
                if ($isSet) {
                    Db::name("log")->insert([
                        'data' => '汇付回调处理成功 (ID: ' . $requestId . ')'
                    ]);
                } else {
                    // 重复回调
                    Db::name("log")->insert([
                        'data' => '汇付回调错误：重复回调 (ID: ' . $requestId . ')'
                    ]);
                    return app('json')->success(['result' => 'ERROR']);
                }
            } else {
                Db::name("log")->insert([
                    'data' => '汇付回调错误：' . $type . '缺少必要参数（id）'
                ]);
                return app('json')->success(['result' => 'ERROR']);
            }

            # 先校验签名和返回的数据的签名的数据是否一致
            $adapay_tools=new AdapayTools();
            AdapayTools::setRsaPrivateKey('MIICdQIBADANBgkqhkiG9w0BAQEFAASCAl8wggJbAgEAAoGBALFOkwRKx2HKMpAL7LUb755cIS7mleort++Rkl25tJMJCf9Ezeyg4xwLBN6RQsLERTAzRKc/EUtxm4/9rzDzvNZ4BegEI8mXWBUrgpn7e1ar8Ek8IRPdXLrozuld9cv56R3yB/Yta0R+kmgCfn2C5V+xtM6njimkOStvdK5cNwqFAgMBAAECgYA5pn+87IeJr1Hjbk0n0g6GYhRUCJuECXUEC0QY/3HMQSsj+f4uy10s2BRcPcUESQbqFjFjY+k+q5DWL7kP5KBoXGnFyflAyRhWGTkSC3VhGixh6ro3EcUJSrFDjGaThGaPrc8Zfcp5JhL5Thi0GaBXSnRH1Cmn4h8gkAEJxIM7PQJBAOq2+oVPtqkj99YRs0eewkZAM7bKRzSwI7OFU6YWsCYVkqNE7Lr3KKGekehuWwkOvrCBR+NEGQfAb557g2CHmzMCQQDBYtgQ5wvl9fD8BWAVKuPoxoleH+9wUQ65Rnt/Ebkx+g8kP37JRun81duLDULTKr/3ak42goE00TfnfeXl0gNnAkA0wuUVypF4/AjeKiRu2RU6zXvSfy36fg3IcRQYpcj7BqZr5TaB4MVVb1vFL+lu482hx63tPIWT5IIy0fj6XgFZAkBinlKLRBgIPISZMPCPuuCg22ZADs8fGucEStI9ub8Uom3IUW0JndVDb5fW8HtMjrd4p8ic+a6ETdFRhx2PNqsvAkAzDvlve56sZnLYx9t/MPkJTK3ZhgVETS0H2FUyJGVOSfjv68bNsUshyPfzJrdbCeLzjMLq8TpyOmiIUAeQ5YCX');
//        $adapay_tools->SetParams();
            $sign_flag = $adapay_tools->verifySign($post_data_str, $post_sign_str);
            $post_data_str=json_decode($post_data_str,true);
            if ($sign_flag){
                try {
                    if(empty($post_data_str['error_msg'])){
                        Db::name("log")->insert(array('data'=>'【验签通过-支付】:时间：'.date('Y-m-d H:i:s',time()),));//日志记录
                        $bool = $this->repository->doNotifyHF($post_data_str);
                    }else{
                        Db::name('order_merchant')->where('out_trade_no', explode('/', $post_data_str['payment_order_no'][0]))->update(['status'=>5]);
                    }
                    if (!$bool)
                        return app('json')->success(['result' => 'ERROR']);
                    return app('json')->success(['result' => 'SUCCESS']);
                }catch (Exception $exception){
                    Db::name("log")->insert(array('data'=>'【汇付错误日志】'));//日志记录
                    Db::name("log")->insert(array('data'=>$exception->getFile().'：'.$exception->getLine().'【'.$exception->getMessage().'】'));
                    return app('json')->fail('错误2');
                }
            }else{
                Db::name("log")->insert(array('data'=>'【签名验证失败】'.json_encode($sign_flag).json_encode($post_data_str),));//日志记录
            }
        }elseif ($type == 'HF_pay_user_annual'){
            $post=$this->request->param();
            Db::name("log")->insert(array('data'=>'【异步接受到的参数】'.json_encode($post),));//日志记录
            $post_data_str = isset($post['data']) ? $post['data']: '';
            $post_sign_str = isset($post['sign']) ? $post['sign']: '';

            if (!empty($post['id'])) {
                $requestId = $post['id'];
                $redisKey = 'api-merchant-order-OrderMerchant-HF_pay_user_annual-request-id:' . $requestId;
                $ttl = 60;
                $redisHandler = Cache::store('redis')->handler();
                $isSet = $redisHandler->set($redisKey, 1, ['nx', 'ex' => $ttl]);
                if ($isSet) {
                    Db::name("log")->insert([
                        'data' => '汇付回调处理成功 (ID: ' . $requestId . ')'
                    ]);
                } else {
                    // 重复回调
                    Db::name("log")->insert([
                        'data' => '汇付回调错误：重复回调 (ID: ' . $requestId . ')'
                    ]);
                    return app('json')->success(['result' => 'ERROR']);
                }
            } else {
                Db::name("log")->insert([
                    'data' => '汇付回调错误：' . $type . '缺少必要参数（id）'
                ]);
                return app('json')->success(['result' => 'ERROR']);
            }

            # 先校验签名和返回的数据的签名的数据是否一致
            $adapay_tools=new AdapayTools();
            AdapayTools::setRsaPrivateKey('MIICdQIBADANBgkqhkiG9w0BAQEFAASCAl8wggJbAgEAAoGBALFOkwRKx2HKMpAL7LUb755cIS7mleort++Rkl25tJMJCf9Ezeyg4xwLBN6RQsLERTAzRKc/EUtxm4/9rzDzvNZ4BegEI8mXWBUrgpn7e1ar8Ek8IRPdXLrozuld9cv56R3yB/Yta0R+kmgCfn2C5V+xtM6njimkOStvdK5cNwqFAgMBAAECgYA5pn+87IeJr1Hjbk0n0g6GYhRUCJuECXUEC0QY/3HMQSsj+f4uy10s2BRcPcUESQbqFjFjY+k+q5DWL7kP5KBoXGnFyflAyRhWGTkSC3VhGixh6ro3EcUJSrFDjGaThGaPrc8Zfcp5JhL5Thi0GaBXSnRH1Cmn4h8gkAEJxIM7PQJBAOq2+oVPtqkj99YRs0eewkZAM7bKRzSwI7OFU6YWsCYVkqNE7Lr3KKGekehuWwkOvrCBR+NEGQfAb557g2CHmzMCQQDBYtgQ5wvl9fD8BWAVKuPoxoleH+9wUQ65Rnt/Ebkx+g8kP37JRun81duLDULTKr/3ak42goE00TfnfeXl0gNnAkA0wuUVypF4/AjeKiRu2RU6zXvSfy36fg3IcRQYpcj7BqZr5TaB4MVVb1vFL+lu482hx63tPIWT5IIy0fj6XgFZAkBinlKLRBgIPISZMPCPuuCg22ZADs8fGucEStI9ub8Uom3IUW0JndVDb5fW8HtMjrd4p8ic+a6ETdFRhx2PNqsvAkAzDvlve56sZnLYx9t/MPkJTK3ZhgVETS0H2FUyJGVOSfjv68bNsUshyPfzJrdbCeLzjMLq8TpyOmiIUAeQ5YCX');
//        $adapay_tools->SetParams();
            $sign_flag = $adapay_tools->verifySign($post_data_str, $post_sign_str);
            $post_data_str=json_decode($post_data_str,true);
            if ($sign_flag){
                try {
                    if(empty($post_data_str['error_msg'])){
                        Db::name("log")->insert(array('data'=>'【验签通过-支付】:时间：'.date('Y-m-d H:i:s',time()),));//日志记录
                        if(strpos($post_data_str['order_no'],'_') !== false){
                            $order_no = explode("_",$post_data_str['order_no'])[0];
                        }else{
                            $order_no = $post_data_str['order_no'];
                        }
                        $user_pension_account_order=Db::name('user_pension_account_order')-> where('order_no',$order_no)->find();
                        if (!$user_pension_account_order){
                            return app('json')->success(['result' => 'fail']);
                        }
                        if($user_pension_account_order['status']==1){
                            return app('json')->success(['result' => 'SUCCESS']);
                        }

                        Db::startTrans();
                        try {
                            $pay_type = $post_data_str['pay_channel'] == "wx_pub" ? "WX" : "ALI";
                            $uid = $user_pension_account_order['uid'];
                            Db::name('user_pension_account_order')-> where('order_no',$order_no) -> update(['status'=>1,'pay_time'=>date('Y-m-d H:i:s'),'pay_type'=>$pay_type]);
                            $check = Db::name("user_pension_account") -> where("uid",$uid) -> find();
                            $start_time = date('Y-m-d');
                            $end_time = date("Y-m-d 23:59:59",strtotime("+1 year", strtotime($start_time)));
                            $give = 0;
                            //存在既续费
                            if ($check){
                                Db::name("user_pension_account") -> where("uid",$uid) -> update(['start_time'=>$start_time,'end_time'=>$end_time]);
                            }else{
                                //新用户订单
                                Db::name("user_pension_account") -> insert([
                                    "uid" => $uid,
                                    "start_time" => $start_time,
                                    "end_time" => $end_time,
                                    "status" => 1,
                                ]);
                            }
                            Db::name("user_pension_account") -> where("uid",$uid) -> update(['give' => 1]);
                            if ($user_pension_account_order['type'] > 1){
                                $mark = "购买大礼包补贴养老金";
                                $ylj=sprintf("%01.2f",bcmul($user_pension_account_order['pay_price'],'0.1',5));//10%的养老金
                                $billData=[
                                    'uid'=>$uid,
                                    'pm'=>1,
                                    'title'=>'养老金',
                                    'category'=>'now_money',
                                    'type'=>'commission',
                                    'number'=>$ylj,
                                    'balance'=>0,
                                    'mark'=>$mark,
                                    'create_time'=>date("Y-m-d H:i:s",time()),
                                    'status'=>1,
                                    'order_sn'=>'',
                                    'type_shop'=>0,
                                    'commission_type'=>5,
                                    'order_type'=>1,
                                    'gzc'=>0
                                ];
                                Db::name('user_bill')->insert($billData);
                                Db::name("user")->where("uid",$uid)->inc('annuity', $ylj) ->update();
                                Db::name("user")->where("uid",$uid)->inc('annuity_num', 1) ->update();

                                //上级佣金
                                $spread_uid = Db::name('user') -> where('uid',$uid) -> value('spread_uid');
                                //上级给佣金10%
                                $commission=sprintf("%01.2f",bcmul($user_pension_account_order['pay_price'],'0.1',5));//10%的佣金
                                $spreadTitle='用户购买大礼包获得佣金';
                                $spreadMark = "用户购买大礼包获得佣金";
                                $spreadBillData=[
                                    'uid'=>$spread_uid,
                                    'link_id'=>0,
                                    'pm'=>1,
                                    'title'=>$spreadTitle,
                                    'category'=>'now_money',
                                    'type'=>'commission',
                                    'number'=>$commission,
                                    'balance'=>0,
                                    'mark'=>$spreadMark,
                                    'create_time'=>date("Y-m-d H:i:s",time()),
                                    'status'=>1,
                                    'order_sn'=>$user_pension_account_order['order_no'],
                                    'type_shop'=>0,
                                    'commission_type'=>3,
                                    'order_type'=>1
                                ];
                                Db::name('user_bill')->insert($spreadBillData);
                                Db::name('user')->where('uid',$spread_uid)->inc('brokerage_price',$commission)->update();
                            }

                            // 提交事务
                            Db::commit();
                            return true;
                        } catch (\Exception $e) {
                            // 回滚事务
                            Db::rollback();
                            Log::error($e->getMessage());
                        }

                    }

                    return app('json')->success(['result' => 'SUCCESS']);
                }catch (\Exception $exception){
                    return app('json')->fail('错误2');
                }
            }
        }

    }
    /**
     * 查询订单API
     * @return mixed
     * @author php迷途小书童
     * @created 2021/1/16 10:05
     */
    public function queryOrder(){
        $out_trade_no = (string)$this->request->param('out_trade_no');
        $data = $this->doQueryOrder($out_trade_no);
        return app('json')->success($data);
    }
    /**
     * 关闭订单API
     * @return bool|string
     * @author php迷途小书童
     * @created 2021/1/16 10:05
     */
    public function closeOrder(){
        $out_trade_no = (string)$this->request->param('out_trade_no');
        $data = $this->doCloseOrder($out_trade_no);
        return app('json')->success($data);
    }
    /**
     * 申请退款API
     * @return bool|string
     * @author php迷途小书童
     * @created 2021/1/16 10:05
     */
    public function refundApply(){
        $out_trade_no = (string)$this->request->param('out_trade_no');
        $order = $this->repository->getOne($out_trade_no);
        if (!$order)
            return app('json')->fail('订单不存在');
        makeLock()->lock();
        try {
            $refund_no=$this->repository->getNewOrderId($order->trade_type);
            $this->repository->updateOrder($order,
                [
                    'refund_no' => $refund_no,
                    'status' => 2,
                ]
            );
        } catch (\Throwable $e) {
            makeLock()->unlock();
            return app('json')->fail($e->getMessage());
        }
        makeLock()->unlock();
        try {

//            $data = $this->doRefundApply(['out_trade_no'=>$order['out_trade_no'],'refund_no'=>$refund_no,'money'=>$order['money']]);
                $data=$this->hf_refund($order,$refund_no);
            return app('json')->success($data);
        } catch (\Throwable $e) {
            return app('json')->status('error', $e->getMessage(), ['out_trade_no' => $order->out_trade_no]);
        }
    }

    public function hf_refund($order,$refund_no)
    {
        $goods_title=Db::name('merchant')->where('mer_id',$order['mer_id'])->find();
        if($order['trade_type']=='WX'){
            $member_id=$goods_title['hf_member_id_wx'];
            $key='api_live_90ef02e4-54ac-41ee-adf1-e4927d23d58f';
        }elseif($order['trade_type']=='ALI'){
            $member_id=$goods_title['hf_member_id'];
            $key='api_live_b23537ed-64b8-45d6-832e-fb228aa9e0a9';
        }
        $amt = $order['service_money'] + $order['pension']+$order['swipe_fee'];
        $amt=sprintf("%01.2f",$amt);
        $mouny=$order['money']-$amt;
        $mouny=sprintf("%01.2f",$mouny);
        if($amt=='0.00'){
            $div_members=[
                [
                    'member_id'=>$member_id,
                    'amount'=>$mouny,
                    'fee_flag'=>'Y'
                ]
            ];
        }else{
            $div_members= [
                [
                    'member_id'=>$member_id,
                    'amount'=>$mouny,
                    'fee_flag'=>'Y'
                ],
                [
                    'member_id'=>0,
                    'amount'=>$amt,
                    'fee_flag'=>'N'
                ]
            ];
        }
        return $this->Payment_refund_traits(['id'=>$order['hf_pay_id'],'refund_order_no'=>$refund_no,'refund_amt'=>$order['money'],'div_members'=>$div_members,'notify_url'=>env('APP_URL')."/api/jsapiPay/refund_notify/HF"],$key);
    }
    /**
     * 申请退款API回调
     * @return bool|string
     * @author php迷途小书童
     * @created 2021/1/16 10:05
     */
    public function refundNotify($type){
        try {
            if($type=='HF'){
                $post=$this->request->param();
                Db::name("log")->insert(array('data'=>'【异步接受到的参数】'.json_encode($post),));//日志记录
                $post_data_str = isset($post['data']) ? $post['data']: '';
                $post_sign_str = isset($post['sign']) ? $post['sign']: '';
                # 先校验签名和返回的数据的签名的数据是否一致
                $adapay_tools=new AdapayTools();
                AdapayTools::setRsaPrivateKey('MIICdQIBADANBgkqhkiG9w0BAQEFAASCAl8wggJbAgEAAoGBALFOkwRKx2HKMpAL7LUb755cIS7mleort++Rkl25tJMJCf9Ezeyg4xwLBN6RQsLERTAzRKc/EUtxm4/9rzDzvNZ4BegEI8mXWBUrgpn7e1ar8Ek8IRPdXLrozuld9cv56R3yB/Yta0R+kmgCfn2C5V+xtM6njimkOStvdK5cNwqFAgMBAAECgYA5pn+87IeJr1Hjbk0n0g6GYhRUCJuECXUEC0QY/3HMQSsj+f4uy10s2BRcPcUESQbqFjFjY+k+q5DWL7kP5KBoXGnFyflAyRhWGTkSC3VhGixh6ro3EcUJSrFDjGaThGaPrc8Zfcp5JhL5Thi0GaBXSnRH1Cmn4h8gkAEJxIM7PQJBAOq2+oVPtqkj99YRs0eewkZAM7bKRzSwI7OFU6YWsCYVkqNE7Lr3KKGekehuWwkOvrCBR+NEGQfAb557g2CHmzMCQQDBYtgQ5wvl9fD8BWAVKuPoxoleH+9wUQ65Rnt/Ebkx+g8kP37JRun81duLDULTKr/3ak42goE00TfnfeXl0gNnAkA0wuUVypF4/AjeKiRu2RU6zXvSfy36fg3IcRQYpcj7BqZr5TaB4MVVb1vFL+lu482hx63tPIWT5IIy0fj6XgFZAkBinlKLRBgIPISZMPCPuuCg22ZADs8fGucEStI9ub8Uom3IUW0JndVDb5fW8HtMjrd4p8ic+a6ETdFRhx2PNqsvAkAzDvlve56sZnLYx9t/MPkJTK3ZhgVETS0H2FUyJGVOSfjv68bNsUshyPfzJrdbCeLzjMLq8TpyOmiIUAeQ5YCX');
    //        $adapay_tools->SetParams();
                $sign_flag = $adapay_tools->verifySign($post_data_str, $post_sign_str);
                $post_data_str=json_decode($post_data_str,true);
                if ($sign_flag){
                    if(empty($post_data_str['error_code'])){
                        Db::name("log")->insert(array('data'=>'【退款验签通过 时间：】'.date('Y-m-d H:i:s',time())));
                        $bool = $this->repository->doRefundNotify( $post_data_str['refund_order_no']);
                    }
                    if (!$bool)
                        return app('json')->success(['result' => 'ERROR']);
                    return app('json')->success(['result' => 'SUCCESS']);
                }




            }

                $post = $this->request->post();
                $bool = $this->doNotify($post);
                if (!$bool)
                    return app('json')->success(['result' => 'ERROR']);
                $bool = $this->repository->doRefundNotify($post);
                if (!$bool)
                    return app('json')->success(['result' => 'ERROR']);
                return app('json')->success(['result' => 'SUCCESS']);
        } catch (\Throwable $e) {
            return app('json')->status('error', $e->getMessage());
        }
    }

    /**
     * 退款查询API
     * @return bool|string
     * @author php迷途小书童
     * @created 2021/1/16 10:04
     */
    public function refundQuery(){
        $refund_no = (string)$this->request->param('refund_no');
        $data = $this->doRefundQuery($refund_no);
        return app('json')->success($data);
    }
    /**
     * 账户余额查询
     * @return mixed
     * @author php迷途小书童
     * @created 2021/1/16 10:04
     */
    public function balanceQuery(){
        $merch_no = env('JSAPI.MERCH_NO');//海科商户编号
        $data = $this->dobalanceQuery($merch_no);
        return app('json')->success($data);
    }

    public function queryOrders(){
        $out_trade_no = (string)$this->request->param('out_trade_no');
        $data = Db::name("order_merchant")
            -> alias("om")
            -> join("merchant m","om.mer_id = m.mer_id")
            -> where("out_trade_no",$out_trade_no) -> field("om.money,om.status,om.out_trade_no,om.pension,om.pay_time,m.mer_name") -> find();
        return app('json')->success($data);
    }
}