szcollect_admin/application/api/controller/Order.php

<?php
namespace app\api\controller;
use app\common\library\AliPay;
use think\cache\driver\Redis;
use think\Db;
use think\Exception;
use EasyWeChat\Factory;
use think\Session;
use function Sodium\add;

/**
 * @title 订单
 * @controller GoodsOrder
 * @group base
 */
class Order extends Base
{
    public function initialize()
    {
        parent::initialize();
        parent::check_login();
    }

    /**
     * @title 生成订单（立即购买 ）
     * @desc  生成订单（立即购买 ）
     * @author  Gavin
     * @url /api/Order/createOrder
     * @method POST
     * @header name:Authorization require:1 desc:Token
     * @param name:id type:int require:1 default:-- desc:藏品id
     * @return  name:order_id type:int require:0 default:0 desc:成功时返回订单id
     */
    public function createOrder()
    {
        $id = input('id');
        $num = input('num');
        $pay_type = input('pay_type','wx');
        if (!$id || !$num) $this->error('参数错误');
        $user = getMemberInfoHash($this->uid); //获取用户信息
        if ($user['is_auth']==0) $this->error('请实名认证后购买!');
        $coll_info = getCollectionInfoHash($id);
        if ($coll_info['is_deleted']==1 || $coll_info['status']==0) $this->error('藏品已下架');
        if ($user['vip']==2){
            $advance_minutes = getAdvanceMinutes(); //获取vip提前抢购分钟
            $sell_time = strtotime($coll_info['sell_time'])-($advance_minutes*60);
           // if ($sell_time>time()) $this->error('商品还未开始售卖！请耐心等待');
        }
        $snap_card = getMembercard($this->uid);  //获取用户抢购卡数量
        if ($snap_card<1) $this->error('抢购卡不足，无法抢购');
        if ($coll_info['buy_count']<$num) $this->error('每人限购'.$coll_info['buy_count'].'个');
        $inventory = getCollectionInventory($id);
        if ($inventory<1) $this->error('已售罄');
        //先减掉库存
        loseCollectionInventory($id,$num);
        $com = true;
        Db::startTrans();
        try {
            $order_no = get_order_sn();
            $total_fee = bcmul($coll_info['price'],$num,2);
            $order_int =[
                'mid'           => $this->uid,
                'c_id'          => $id,
                'inventory'     => $coll_info['inventory'],
                'order_no'      => $order_no,
                'num'           => $num,
                'pro_info'      => json_encode($coll_info),
                'pay_type'      => $pay_type,
                'pay_price'     => $total_fee
            ];
            Db::name('store_order')->insert($order_int);
//            $retrun_data['order_no'] = $order_no;
//            $retrun_data['pay'] = 1;
//            Db::commit();
            $body = '象寻购买藏品';
            switch ($pay_type){
                case 'wx':
                    $config = retrunWxConfig();
                    $total_fee = $total_fee * 100;
                    $config['notify_url'] = $this->request->root(true).'/api/Pay/WxOrderNotify';
                    $app = Factory::payment($config);
                    $order = $app->order->unify([
                        'body' =>$body,
                        'out_trade_no' => $order_no,
                        'total_fee' => $total_fee,
                        'trade_type' => "APP", // JSAPI--JSAPI支付（或小程序支付）、NATIVE--Native支付、APP--app支付，MWEB--H5支付
                    ]);
                    if ($order['return_msg']=='OK'){
                        if ($order['result_code']=='FAIL'){
                            $com=false;
                            Db::rollback();
                        }else{
                            $order1 = $app->jssdk->bridgeConfig($order['prepay_id']);//执行二次签名返回参数
                            Db::name('store_order')->where('order_no',$order_no)->update(['wx_order'=>$order1]);
                            $retrun_data['order_no'] = $order_no;
                            $retrun_data['pay'] = json_decode($order1,true);
                            //减少数据库库存
                            Db::name('store_collection')->where('id',$id)->setDec('now_inventory',$num);
                            Db::commit();
                        }
                    }else{
                        $com=false;
                        Db::rollback();
                    }

                    break;
                case 'zfb':
                    $zfb = new AliPay();
                    $notify_url = $this->request->root(true).'/api/Pay/alipayOrderNotify';//回调地址
                    $order = $zfb->aliPay($body, $total_fee, $order_no, $notify_url);//调用支付宝支付的方法
                    $retrun_data['order_no'] = $order_no;
                    $retrun_data['pay'] = $order;
                    //减少数据库库存
                    Db::name('store_collection')->where('id',$id)->setDec('now_inventory',$num);
                    Db::commit();
                    break;
            }

        }catch (\Exception $e){
            $com=false;
            Db::rollback();
        }
        if ($com){
           // $this->savetest($order_no);
            $this->success('成功',$retrun_data);
        }else{
            //加上库存
            addCollectionInventory($id,$num);
            $this->error('抢购失败，请稍后重试');
        }

    }

    /**
     * @title 我的订单-待支付、已购买
     * @desc  我的订单-待支付、已购买
     * @author  Gavin
     * @url /api/Order/getMyOrderList
     * @method POST
     * @header name:Authorization require:1 desc:Token
     * @param  name:page type:int  : default:1 desc:页数
     * @param  name:page_num type:int  : default:20 desc:每页数
     *
     * @return  name:order_no type:string default:-- desc:订单号
     * @return  name:num type:int default:-- desc:数量
     * @return  name:status type:int default:-- desc:类型0：待支付1：已支付
     * @return  name:cancel_time type:string default:-- desc:待支付自动取消时间
     * @return name:pro_info@name type:string default:-- desc:藏品名称
     * @return name:pro_info@price type:string default:-- desc:藏品价格
     * @return name:pro_info@cover type:string default:-- desc:藏品图片
     */
    public function getMyOrderList(){
        $status = input('status',0);
        $where = [
            'is_deleted'=>0,
            'status'=>$status,
            'mid'=>$this->uid
        ];
        $count = Db::name('store_order')->where($where)->count();
        $list = Db::name('store_order')
            ->where($where)
            ->field('id,c_id,order_no,num,pro_info,status,create_at')
            ->order('id desc')
            ->limit($this->off_set,$this->page_num)
            ->select();
        //自动取消分钟数
        $cancel_time = getCancelTime();
        foreach ($list as &$v){
            $v['pro_info'] = json_decode($v['pro_info'],true);
            if ($v['status']==0){
                $v['cancel_time'] = date('Y-m-d H:i:s',strtotime($v['create_at'])+($cancel_time*60));
            }
        }
        $this->success('成功',compact('count','list'));
    }

    /**
     * @title 我的订单-转赠
     * @desc  我的订单-转赠
     * @author  Gavin
     * @url /api/Order/getMySendList
     * @method POST
     * @header name:Authorization require:1 desc:Token
     * @param  name:page type:int  : default:1 desc:页数
     * @param  name:page_num type:int  : default:20 desc:每页数
     *
     * @return  name:order_no type:string default:-- desc:订单号
     * @return name:over_time type:string default:-- desc:转赠时间
     * @return name:status type:int default:-- desc:类型2：赠出3：获赠
     * @return name:pro_info@name type:string default:-- desc:藏品名称
     * @return name:pro_info@price type:string default:-- desc:藏品价格
     * @return name:pro_info@cover type:string default:-- desc:藏品图片
     */
    public function getMySendList(){
        $where = [
            'mid'=>$this->uid,
        ];
        $count = Db::name('store_order_info')->where($where)->whereIn('status','2,3')->count();
        $list = Db::name('store_order_info')
            ->where($where)
            ->whereIn('status','2,3')
            ->field('id,order_no,pro_info,over_time,create_at,status')
            ->order('id desc')
            ->limit($this->off_set,$this->page_num)
            ->select();
        foreach ($list as &$v){
            $v['pro_info'] = json_decode($v['pro_info'],true);
        }
        $this->success('成功',compact('count','list'));
    }











    function savetest($order_no){

        $result['out_trade_no'] = $order_no;
        $order = Db::name('store_order')->where('order_no',$result['out_trade_no'])->find();
        if ($order['status']==0){
            Db::startTrans();
            try {
                Db::name('store_order')
                    ->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)]);

                $array = [];
                for ($i=0;$i<$order['num'];$i++){
                    //获取排名
                    $rank = getRanking($order['c_id'])+1;
                    $tag = getTag($order['c_id'],$rank,$order['inventory']);
                    saveRanking($order['c_id']);
                    $company = '象寻数字科技（上海）有限公司';
                    $company_hash = '';
                    $company_hash_time = '';
                    $collectors_hash = '';
                    $date = [
                        'order_id'=>$order['id'],
                        'order_no'=>get_order_sn(),
                        'tag'=>$tag,
                        'mid'=>$order['mid'],
                        'pro_info'=>$order['pro_info'],
                        'company'=>$company,
                        'company_hash'=>$company_hash,
                        'company_hash_time'=>$company_hash_time,
                        'collectors_hash'=>$collectors_hash,
                        'collectors_hash_time'=>date('Y-m-d H:i:s')
                    ];
                    $array[] = $date;
                }
                Db::name('store_order_info')->insertAll($array);
                Db::commit();
                // return true;
            } catch (\Exception $e){
                Db::rollback();
                //return false;
            }
        }
    }



}