xianglian_test_api/application/api/controller/Notify.php

<?php
namespace app\api\controller;
use llianpay\accp\security\LLianPayAccpSignature;
use think\Controller;
use think\Db;
use llianpay\accp\client\LLianPayClient;
use llianpay\accp\params\TradeCreateParams;
use llianpay\accp\params\TradeCreateOrderInfo;
use llianpay\accp\params\TradeCreatePayeeInfo;
use llianpay\accp\params\GetRandomParams;
use llianpay\accp\params\TradeCreatePayerInfo;
require env('root_path').'application/common/library/llp/src/security/LLianPayAccpSignature.php';
require env('root_path').'application/common/library/llp/src/cfg.php';
require env('root_path').'application/common/library/llp/src/client/LLianPayClient.php';
require env('root_path').'application/common/library/llp/src/params/TradeCreateParams.php';
require env('root_path').'application/common/library/llp/src/params/TradeCreateOrderInfo.php';
require env('root_path').'application/common/library/llp/src/params/TradeCreatePayeeInfo.php';
require env('root_path').'application/common/library/llp/src/params/TradeCreatePayerInfo.php';
require env('root_path').'application/common/library/llp/src/params/GetRandomParams.php';
/**
 * 连连异步回调
 * Class Notify
 */
class Notify extends Controller
{

    protected $prefix = 'xl_';
    public function __construct()
    {
        $data   = input('post.');
        $header   =  app()->request->header();
        $notify_ip = request()->ip();
        file_put_contents("lianLianNotify.txt", json_encode($data,JSON_UNESCAPED_UNICODE) . "\n" . "\n", FILE_APPEND);
        file_put_contents("lianLianNotify.txt", json_encode($header) . "\n" . "\n", FILE_APPEND);
        file_put_contents("lianLianNotify.txt", json_encode(['ip'=>$notify_ip]) . "\n" . "\n", FILE_APPEND);
    }

    // 连连充值异步回调
    public function lianLianNotify()
    {
        $header   =  app()->request->header();
        $result = input('post.');
        if($result['txn_status'] == 'TRADE_SUCCESS') {
            // 验签
            $check_sign = LLianPayAccpSignature::checkSign(json_encode($result,JSON_UNESCAPED_UNICODE),$header['signature-data']);
            if(!$check_sign) return false;
            $orderNo = $result['orderInfo']['txn_seqno'];
            $order = Db::name('store_recharge_order')->where('order_no',$orderNo)->find();
            if (!$order) return false;
            if ($order['status']==1) return 'Success';
            Db::name('store_recharge_order')->where('order_no',$orderNo)->update(['status'=>1,'pay_at'=>date('Y-m-d H:i:s')]);
            memberMoneyChange($order['total_price'],3,$order['mid'],'余额充值',1,$order['id'],5);
            return 'Success';
        }
    }

    // 开户回调
    public function openAcctApplyNotify()
    {
        $result = input('post.');
        $result['openAcctApplyNotify'] = 'openAcctApplyNotify';
        if($result['user_status'] == 'NORMAL') {
             Db::name('store_member')->where('id',trim($result['user_id'],$this->prefix))->update(['cloud_wallet'=>1]);
        }

    }




}