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_once env('root_path').'application/common/library/llp/src/security/LLianPayAccpSignature.php';
require_once env('root_path').'application/common/library/llp/src/cfg.php';
require_once env('root_path').'application/common/library/llp/src/client/LLianPayClient.php';
require_once env('root_path').'application/common/library/llp/src/params/TradeCreateParams.php';
require_once env('root_path').'application/common/library/llp/src/params/TradeCreateOrderInfo.php';
require_once env('root_path').'application/common/library/llp/src/params/TradeCreatePayeeInfo.php';
require_once env('root_path').'application/common/library/llp/src/params/TradeCreatePayerInfo.php';
require_once 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 cloudWalletNotify()
    {
        $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);
        $result = $data;
        if($result['txn_status'] == 'TRADE_SUCCESS') {
            // 验签
            $check_sign = LLianPayAccpSignature::checkSign(json_encode($data,JSON_UNESCAPED_UNICODE),$header['signature-data']);
            if(!$check_sign) return false;
            $orderNo = $result['orderInfo']['txn_seqno'];
            $order = Db::name('cloud_wallet_order')->where('order_no',$orderNo)->find();
            if (!$order) return false;
            if ($order['status']==1) return 'Success';
            Db::name('cloud_wallet_order')->where('order_no',$orderNo)->update(['status'=>1,'pay_at'=>date('Y-m-d H:i:s')]);
            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]);
        }

    }


    //连连云钱包提现回调
    public function withdrawalNotify()
    {
        $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);
        $result = $data;
        $orderNo = $result['txn_seqno'];
        $withdraw_info =  Db::name('cloud_wallet_withdraw')->where('order_no',$orderNo)->find();
        if(empty($withdraw_info)) return false;
        if($withdraw_info['is_over']) return 'Success';
        // 提现成功
        if($result['ret_code'] == '0000') {
            $check_sign = LLianPayAccpSignature::checkSign(json_encode($data,JSON_UNESCAPED_UNICODE),$header['signature-data']);
            if(!$check_sign) return false;
            Db::name('cloud_wallet_withdraw')->where('order_no',$orderNo)->update(['paid'=>1,'pay_time'=>time(),'is_over'=>1,'return_info'=>json_encode($result,JSON_UNESCAPED_UNICODE)]);
        }else{// 提现失败
            Db::name('cloud_wallet_withdraw')->where('id',$withdraw_info['id'])->update(['is_over'=>1,'return_info'=>json_encode($result,JSON_UNESCAPED_UNICODE)]);
        }
        return 'Success';
    }






}