xianglian_test_api/application/api/controller/Pay.php

<?php

// +----------------------------------------------------------------------
// | ThinkAdmin
// +----------------------------------------------------------------------
// | 版权所有 2014~2019 广州楚才信息科技有限公司 [ http://www.cuci.cc ]
// +----------------------------------------------------------------------
// | 官方网站: http://demo.thinkadmin.top
// +----------------------------------------------------------------------
// | 开源协议 ( https://mit-license.org )
// +----------------------------------------------------------------------
// | gitee 代码仓库：https://gitee.com/zoujingli/ThinkAdmin
// | github 代码仓库：https://github.com/zoujingli/ThinkAdmin
// +----------------------------------------------------------------------

namespace app\api\controller;
use think\cache\driver\Redis;
use EasyWeChat\Factory;
use think\Controller;
use think\Db;
use think\Exception;


use AlibabaCloud\Client\AlibabaCloud;
use AlibabaCloud\Client\Exception\ClientException;
use AlibabaCloud\Client\Exception\ServerException;
use function AlibabaCloud\Client\value;

/**
 * 支付管理类
 * Class Refund
 * @package app\api\controller\Refund
 */
class Pay extends Controller
{
    /**
     * 微信支付--商品支付成功回调订单
     */
    public function WxOrderNotify(){
        $payXml = file_get_contents("php://input");
        //将xml格式转化为json格式
        $jsonXml = json_encode(simplexml_load_string($payXml, 'SimpleXMLElement', LIBXML_NOCDATA));
        //将json格式转成数组格式 $result['out_trade_no']
        $result = json_decode($jsonXml, true);
        file_put_contents("wx_pay_return.txt", json_encode($result) . "\n" . "\n", FILE_APPEND);
        if ($result['return_code'] == 'SUCCESS' && $result['result_code'] == 'SUCCESS') {
            $return = $this->dealData($result);
            if ($return){
                $arr = array(
                    'return_code' => 'SUCCESS',
                    'return_msg'  => 'OK',
                );
                return $this->arrayToXml($arr);
            }else{
                file_put_contents("order_pay_error.txt", file_get_contents("php://input") . "\n" . json_encode($result) . "\n" . "\n", FILE_APPEND);
            }
        }
    }

    /**
     * 支付宝支付--支付成功回调订单
     */
    public function alipayOrderNotify(){
        $result    = input('post.');
        file_put_contents("ali_pay_return.txt", json_encode($result) . "\n" . "\n", FILE_APPEND);
        if ($result['trade_status'] == 'TRADE_SUCCESS' || $result['trade_status'] == 'TRADE_FINISHED') {
            $return = $this->dealData($result);
            if ($return){
                echo 'success';
                return $return;
            }else{
                file_put_contents("order_alipay_error.txt", file_get_contents("php://input") . "\n" . json_encode($result) . "\n" . "\n", FILE_APPEND);
            }
        }
    }

    /**
     * 杉德支付--支付成功回调订单
     */
    public function shandeOrderNotify(){
        $data   = stripslashes($_POST['data']); //支付数据
        //debug($data);
        file_put_contents("shandepay.txt", $data . "\n" , FILE_APPEND);
        $data = json_decode($data,true);
        if ($data['body']['orderStatus']==1){
            $return = $this->dealData($data,'sd');
            if ($return){
                return 'respCode=000000';
            }else{
                file_put_contents("shandepay_error.txt", $data . "\n" . json_encode($data) . "\n" . "\n", FILE_APPEND);
            }
        }
    }


    /**
     * 处理数据库信息
     * @param $result
     * @return bool
     */
    function dealData($result,$from=''){
        Db::startTrans();
        $redis = new Redis();
        if($from=='sd'){
            $orderCode = $result['body']['orderCode'];
            $orderCode_arr = explode('S',$orderCode);
            $result['out_trade_no'] = $orderCode_arr[0];
            $key = 'order_not_pay_'.$orderCode_arr[1];
        }else{
            $key = 'order_not_pay_'.$result['attach'];
        }
        $com = true;
        try {
            $order = $redis->hGet($key,$result['out_trade_no']);
            if (!$order) return false;
            $order = json_decode($order,true);

            $is_order = Db::name('store_order')->where('order_no',$result['out_trade_no'])->find();

            if (isset($is_order) && $is_order['status']==1) return false;

            $order['status'] = 1;
            $order['pay_at'] = date('Y-m-d H:i:s');
            $order['return_success_info'] = json_encode($result,true);
            $order_id = Db::name('store_order')->insertGetId($order);

            $array = [];
            $pro_info = json_decode($order['pro_info'],true);
            for ($i=0;$i<$order['num'];$i++){
                //获取排名
                $rank = getRanking($order['c_id']);
                $tag = getTag($order['c_id'],$rank,$order['inventory']);
                saveRanking($order['c_id']);

                $company = '象链数藏';
                $hash = getCompanyHash($order['c_id']);
                $company_hash = $hash['hash'];
                $company_hash_time = $hash['create_at'];
                $tokenid = $hash['tokenid'];
                Db::name('hash')->where('hash',$hash['hash'])->update(['status'=>1]);
                $collectors_hash = '';
                $type = Db::name('store_collection')->where('id',$order['c_id'])->value('type');
                $date = [
                    'order_id'=>$order_id,
                    'order_no'=>get_order_sn(),
                    'tag'=>$tag,
                    'mid'=>$order['mid'],
                    'c_id'=>$order['c_id'],
                    'name'=>$pro_info['name'],
                    'cover'=>$pro_info['cover'],
                    'pro_info'=>$order['pro_info'],
                    'company'=>$company,
                    'type' => $type,
                    'company_hash'=>$company_hash ? $company_hash:'',
                    'ddcid'=>$tokenid,
                    'company_hash_time'=>$company_hash_time,
                    'collectors_hash'=>$collectors_hash ? $collectors_hash : '',
                ];
                $array[] = $date;
            }
            $res = Db::name('store_order_info')->insertAll($array);
            Db::commit();
        } catch (\Exception $e){
            $com = false;
            Db::rollback();
        }
        if ($com){
            $redis->hdel($key,$result['out_trade_no']);
            return true;
        }else{
            return false;
        }
    }


    /**
     * 微信支付--充值盲盒成功回调订单
     */
    public function BlindRechargeNotify(){
        $payXml = file_get_contents("php://input");
        //将xml格式转化为json格式
        $jsonXml = json_encode(simplexml_load_string($payXml, 'SimpleXMLElement', LIBXML_NOCDATA));
        //将json格式转成数组格式 $result['out_trade_no']
        $result = json_decode($jsonXml, true);
        if ($result['return_code'] == 'SUCCESS' && $result['result_code'] == 'SUCCESS') {
            $return = $this->dealBox($result);
            if ($return){
                $arr = array(
                    'return_code' => 'SUCCESS',
                    'return_msg'  => 'OK',
                );
                return $this->arrayToXml($arr);
            }else{
                file_put_contents("order_pay_error.txt", file_get_contents("php://input") . "\n" . json_encode($result) . "\n" . "\n", FILE_APPEND);
            }
        }
    }

    /**
     * 支付宝支付--充值盲盒回调订单
     */
    public function alipayBlindRechargeNotify(){
        $result    = input('post.');
        if ($result['trade_status'] == 'TRADE_SUCCESS' || $result['trade_status'] == 'TRADE_FINISHED') {
            $return = $this->dealBox($result);
            if ($return){
                echo 'success';
            }else{
                file_put_contents("order_alipay_error.txt", file_get_contents("php://input") . "\n" . json_encode($result) . "\n" . "\n", FILE_APPEND);
            }
        }
    }


    /**
     * 盲盒充值次数处理数据库信息
     * @param $result
     * @return bool
     */
    function dealBox($result,$from=''){
        $com = true;
        Db::startTrans();
        try {
            $order = Db::name('store_blind_recharge')->where('order_no',$result['out_trade_no'])->find();
            if ($order['status']==1) return true;
            Db::name('store_blind_recharge')
                ->where('order_no',$result['out_trade_no'])
                ->update(['status'=>1,'pay_at'=>date('Y-m-d H:i:s'),'return_success_info'=>json_encode($result,true)]);
            //用户加次数
            Db::name('store_member')->where('id',$order['m_id'])->setInc('lottery_number',$order['num']);
            Db::commit();
        } catch (\Exception $e){
            $com = false;
            Db::rollback();
        }
        if ($com){
            setMemberInfoHash($order['m_id']);
            return true;
        }else{
            return false;
        }
    }






    /**
     * 微信支付--二级市场回调订单
     */
    public function SecondaryWxOrderNotify(){
        $payXml = file_get_contents("php://input");
        //将xml格式转化为json格式
        $jsonXml = json_encode(simplexml_load_string($payXml, 'SimpleXMLElement', LIBXML_NOCDATA));
        //将json格式转成数组格式 $result['out_trade_no']
        $result = json_decode($jsonXml, true);
        if ($result['return_code'] == 'SUCCESS' && $result['result_code'] == 'SUCCESS') {
            $return = $this->dealSecondary($result);
            if ($return){
                $arr = array(
                    'return_code' => 'SUCCESS',
                    'return_msg'  => 'OK',
                );
                return $this->arrayToXml($arr);
            }else{
                file_put_contents("order_pay_error.txt", file_get_contents("php://input") . "\n" . json_encode($result) . "\n" . "\n", FILE_APPEND);
            }
        }
    }

    /**
     * 支付宝支付--二级市场回调订单
     */
    public function alipaySecondaryNotify(){
        $result    = input('post.');
        if ($result['trade_status'] == 'TRADE_SUCCESS' || $result['trade_status'] == 'TRADE_FINISHED') {
            $return = $this->dealSecondary($result);
            if ($return){
                echo 'success';
            }else{
                file_put_contents("order_alipay_error.txt", file_get_contents("php://input") . "\n" . json_encode($result) . "\n" . "\n", FILE_APPEND);
            }
        }
    }

    /**
     * 杉德支付--二级市场回调订单
     */
    public function shandeSecondaryNotify(){
        $data   = stripslashes($_POST['data']); //支付数据
        //debug($data);
        file_put_contents("shandepay.txt", $data . "\n" , FILE_APPEND);
        $data = json_decode($data,true);
        if ($data['body']['orderStatus']==1){
            //$data['body']['orderCode']
            $return = $this->dealSecondary($data,'sd');
            if ($return){
                return 'respCode=000000';
            }else{
                file_put_contents("shandepay_error.txt", $data . "\n" . json_encode($data) . "\n" . "\n", FILE_APPEND);
            }
        }
    }


    public function walletNotify()
    {
        $data = stripslashes($_POST['data']); //支付数据
        //debug($data);
        file_put_contents("walletNotify.txt", $data . "\n" , FILE_APPEND);
        $data = json_decode($data,true);
        if ($data['body']['orderStatus']==1){
            Db::startTrans();
            try {
                $out_trade_no = $data['body']['orderCode'];
                $order = Db::name('store_recharge_order')->where('order_no',$out_trade_no)->find();
                if (!$order) return false;
                if ($order['status']==1) return 'respCode=000000';
                Db::name('store_recharge_order')->where('order_no',$out_trade_no)->update(['status'=>1,'pay_at'=>date('Y-m-d H:i:s')]);
                memberMoneyChange($order['total_price'],3,$order['mid'],'余额充值',1,$order['id'],5);
                Db::commit();
                return 'respCode=000000';
            } catch (\Exception $e){
                Db::rollback();
                file_put_contents("walletNotify_error.txt", $data . "\n" . json_encode($data) . "\n" . "\n", FILE_APPEND);
                return false;
            }

        }
    }



    /**
     * 二级市场处理数据库信息
     * @param $result
     * @return bool
     */
    function dealSecondary($result,$from=''){
        $com = true;
        Db::startTrans();
        try {
            if ($from=='sd'){
                $out_trade_no = $result['body']['orderCode'];
            }else{
                $out_trade_no = $result['out_trade_no'];
            }
            $order = Db::name('store_order_info_order')->where('order_no',$out_trade_no)->find();
            if ($order['status']==1) return false;

            if (!$order) return false;

            $resale_status = Db::name('store_order_info')->where('id',$order['info_id'])->value('resale_status');
            if ($resale_status!=2){

            }else{
                Db::name('store_order_info_order')
                    ->where('order_no',$out_trade_no)
                    ->update(['status'=>1,'pay_at'=>date('Y-m-d H:i:s'),'return_success_info'=>json_encode($result,true)]);
                //藏品修改状态
                Db::name('store_order_info')->where('id',$order['info_id'])->update([
                    'status'=>2,
                    'resale_status'=>3,
                    'selling_time'=>date('Y-m-d H:i:s')
                ]);
                $info = Db::name('store_order_info')->where('id',$order['info_id'])->find();
                //增加一条记录
                $to_date = [
                    'order_id'=>$order['id'],
                    'order_no'=>get_order_sn(),
                    'tag'=>$info['tag'],
                    'mid'=>$order['mid'],
                    'c_id'=>$info['c_id'],
                    'name'=>$info['name'],
                    'cover'=>$info['cover'],
                    'pro_info'=>$info['pro_info'],
                    'type'=>$info['type'],
                    'from'=>2,
                    'to_mid'=>$info['mid'],
                    'over_time'=>date('Y-m-d H:i:s'),
                    'company'=>'象链数藏',
                    'company_hash'=>$info['company_hash'] ? $info['company_hash']: '',
                    'company_hash_time'=>$info['company_hash_time'],
                    'ddcid'=>$info['ddcid'],
                    'collectors_hash'=>'',
                    'collectors_hash_time'=>date('Y-m-d H:i:s')
                ];
                Db::name('store_order_info')->insert($to_date);
                //增加用户余额
                memberMoneyChange($order['to_account'],3,$info['mid'],'出售藏品',1,$order['id'],1);
                Db::commit();
            }
        } catch (\Exception $e){
            $com = false;
            Db::rollback();
        }
        if ($com){
            setMemberInfoHash($order['mid']);
            //商品信息
            $pro_info = json_decode($info['pro_info'],true);

            return true;
        }else{
            return false;
        }
    }


    /**
     * 数组转xml
     * @ApiInternal
     */
    public function arrayToXml($arr)
    {
        $xml = "<xml>";
        foreach ($arr as $key => $val) {
            if (is_numeric($val)) {
                $xml .= "<" . $key . ">" . $val . "</" . $key . ">";
            } else
                $xml .= "<" . $key . "><![CDATA[" . $val . "]]></" . $key . ">";
        }
        $xml .= "</xml>";
        return $xml;
    }




}