unishop的支付与回调

addons/unishop/controller/Product.php

@@ -108,6 +108,7 @@ class Product extends Base
                 $data->evaluate_list = collection($evaluate)->append(['createtime_text'])->toArray();
             }
             $data = $data->append(['images_text','videothumb', 'spec_list', 'spec_table_list'])->toArray();
+            unset($data['switch']);
         } catch (Exception $e) {
             $this->error($e->getMessage());
         }

application/api/controller/Unishop.php

@@ -0,0 +1,227 @@
+<?php
+
+namespace app\api\controller;
+
+use app\common\controller\Api;
+use fast\Random;
+use think\Db;
+use addons\epay\library\Service;
+use think\Exception;
+use addons\unishop\extend\Hashids;
+/**
+ * 支付订单，回调订单
+ */
+class Unishop extends Api
+{
+    protected $noNeedLogin = ['order_notify_base'];
+    protected $noNeedRight = ['*'];
+
+    //支付订单
+    //微信小程序、微信app下单使用。
+    public function pay_order(){
+        $pay_type = input('pay_type','alipay');
+        $platform = input('platform','wap');
+        $orderid = input('order_id',0);
+        if(empty($orderid)){
+            $this->error();
+        }
+        $orderid = Hashids::decodeHex($orderid);
+
+        $uid = $this->auth->id;
+
+        $map = [
+            'id'       => $orderid,
+            'user_id'  => $uid,
+            'status'   => 1,
+            'have_paid'=> 0,
+        ];
+        $orderinfo = Db::name('unishop_order')->where($map)->find();
+        if(empty($orderinfo)){
+            $this->error('请刷新重试');
+        }
+
+        //银行卡特殊处理
+        if($pay_type == 'bank'){
+            Db::name('unishop_order')->where('id',$orderid)->update(['pay_type'=>2,'updatetime'=>time()]);
+            $this->success('请从银行卡打款');
+        }
+
+        //创建订单
+        $data['user_id'] = $uid;
+        $data['out_trade_no'] = createUniqueNo('P',$uid); // 数据库订单号加密
+        $data['order_amount'] = $orderinfo['total_price'];
+        $data['createtime'] = time();
+
+        $data['pay_type'] = $pay_type;
+        $data['platform'] = $platform;
+        $data['order_status'] = 0;
+        $data['table_name'] = 'unishop_order';
+        $data['table_id'] = $orderid;
+
+        $orderid = Db::name('pay_order')->insertGetId($data);
+
+        //下单
+        $params = [
+            'type'         => $pay_type,
+            'orderid'      => $data['out_trade_no'],
+            'title'        => '支付订单',
+            'amount'       => $data['order_amount'],
+//            'amount'       => 0.01,
+            'method'       => $platform,
+            'notifyurl' => config('pay_notify_url').'/api/pay/order_notify_base/paytype/'.$pay_type,
+            'returnurl' => config('h5_url').'/#/pages/order/order?status=0',
+        ];
+
+        $res = Service::submitOrder($params);
+
+        if($pay_type == 'wechat'){
+            $this->success('success',json_decode($res,true));
+        }else{
+            $this->success('success',$res);
+        }
+    }
+
+    //异步回调对外方法
+    public function order_notify_base(){
+
+        //验签
+        $paytype = input('paytype','alipay');
+        $notify_file = $this->notify_log_start($paytype);
+        $pay = Service::checkNotify($paytype);
+        if (!$pay) {
+            echo '签名错误';
+            exit;
+        }
+
+        //验证，拿订单号等信息
+        $data = $pay->verify();
+        $out_trade_no = $data['out_trade_no'];
+        //订单查询
+        $info = Db::name('pay_order')->where('out_trade_no',$out_trade_no)->find();
+
+        if(empty($info)){
+            return $pay->success()->send();
+            exit;
+        }
+
+        if($info['order_status'] != 0)
+        {
+            return $pay->success()->send();
+            exit;
+        }
+        //你可以在此编写订单逻辑
+        $rs = $this->order_notify_do($out_trade_no,$paytype);
+        if($rs === false){
+            //不论结果都应返回success
+            return $pay->success()->send();
+            exit;
+        }else{
+            //不论结果都应返回success
+            return $pay->success()->send();
+            exit;
+        }
+
+        //默认
+        return $pay->success()->send();
+        exit;
+    }
+
+    //异步逻辑
+    private function order_notify_do($out_trade_no,$paytype){
+
+        Db::startTrans();
+        $orderInfo = Db::name('pay_order')->where(['out_trade_no' => $out_trade_no])->lock(true)->find();
+        if (empty($orderInfo)) {
+            Db::rollback();
+            return false;
+        }
+
+        if($orderInfo['order_status'] != 0){
+            Db::rollback();
+            return false;
+        }
+
+        //逻辑开始
+        $nowtime = time();
+//        $nowtime = jiesuan_tendays_ago()-1; //仅测试用
+
+        $paytype_enum = [
+            'wechat' => 3,
+            'alipay' => 4,
+        ];
+
+        $update = [
+            'have_paid'=>$nowtime,
+            'pay_type' =>$paytype_enum[$paytype]
+        ];
+        $rs_order = Db::name('unishop_order')->where('id',$orderInfo['table_id'])->update($update);
+        if($rs_order === false){
+            Db::rollback();
+            return false;
+        }
+
+        //修改用户活跃,自动滑落用
+        Db::name('user')->where('id',$orderInfo['user_id'])->update(['last_paytime'=>$nowtime]);
+        //逻辑结束
+
+        //状态
+        $ros = Db::name('pay_order')->where(['out_trade_no' => $out_trade_no])->update(['order_status'=>1,'notifytime'=>time()]);
+        if($ros === false) {
+            Db::rollback();
+            return false;
+        }
+
+        //默认提交
+        Db::commit();
+        return true;
+
+
+    }
+
+
+
+    //异步日志
+    private function notify_log_start($paytype = 'wechat'){
+        //记录支付回调数据
+        ignore_user_abort(); // run script in background
+        set_time_limit(30);
+        // 日志文件 start
+        $log_base_dir = '../paylog/'.$paytype.'/';
+        if (!is_dir($log_base_dir))
+        {
+            mkdir($log_base_dir, 0770, true);
+            @chmod($log_base_dir, 0770);
+        }
+        $notify_file = $log_base_dir.'notify.txt';
+        if(!file_exists($notify_file)) {
+            @touch($notify_file);
+            @chmod($notify_file, 0770);
+        }
+        if(filesize($notify_file)>5242880)//大于5M自动切换
+        {
+            rename($notify_file, $log_base_dir.'notify_'.date('Y_m_d_H_i_s').'.txt');
+        }
+        if(!file_exists($notify_file)) {
+            @touch($notify_file);
+            @chmod($notify_file, 0770);
+        }
+        // 日志文件 end
+        //开始写入
+        $_REQUEST = isset($_REQUEST) ? $_REQUEST : array();
+        if($_REQUEST && $paytype == 'alipay') {
+            file_put_contents($notify_file, "\r\n\r\n".date('Y-m-d H:i:s')." [notify][入口接收request]".json_encode($_REQUEST), FILE_APPEND);
+        } else {
+            $xml = file_get_contents("php://input");
+            file_put_contents($notify_file, "\r\n\r\n".date('Y-m-d H:i:s')." [notify][入口接收php://input流原始数据] \n".$xml, FILE_APPEND);
+            $xmlObj = simplexml_load_string($xml, 'SimpleXMLElement', LIBXML_NOCDATA);
+            file_put_contents($notify_file, "\r\n\r\n".date('Y-m-d H:i:s')." [notify][入口接收php://input流] ".json_encode($xmlObj), FILE_APPEND);
+        }
+
+        ini_set('display_errors','On');
+
+        return $notify_file;
+
+    }
+
+
+}