szcollect_admin/application/index/controller/Index.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\index\controller;

use app\common\library\AliPay;
use EasyWeChat\Factory;
use library\Controller;
use think\Db;

/**
 * 应用入口
 * Class Index
 * @package app\index\controller
 */
class Index extends Controller
{
    /**
     * 入口跳转链接
     */
    public function index()
    {
        $this->redirect('@admin/login');
    }

    public function tiaokuan(){
        $privacy=  Db::name('system_config')->where('name','privacy')->value('value');

        $this->assign('info',$privacy);
        $this->fetch('index');
    }





    /**
     * @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
     * @param name:num type:int require:1 default:1 desc:数量
     * @param name:pay_type type:string require:1 default:wx desc:wx:微信zfb:支付宝
     *
     * @return  name:order_no type:int require:0 default:0 desc:订单号
     * @return  name:pay type:string require:0 default:0 desc:支付信息
     */
    public function createOrder()
    {
        //  $redis = new \think\cache\driver\Redis();
//        $info = Db::name('store_collection')->where('id',30)->find();
//        $info['is_deleted'] = 0;
//        $info['sell_time'] = '2022-04-21 15:53:04';
//        $info['buy_count'] = '10000';
//        $array = ['collection30'=>json_encode($info)];
//        $redis->hMSet('collectionInfo',$array);
      //  $redis->set('collection_count_30',5000);
       // dump($info);die;
    //   die;
//        $redis->set('is_buy_30',1);
//       die;


        $this->uid = '100000';
        $id = input('id');
        $num = input('num',1);
        $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('藏品已下架');

        $inventory = getCollectionInventory($id);
        if ($inventory<1) $this->error('已售罄');

        if ($user['vip']==2){
            $advance_minutes = getAdvanceMinutes(); //获取vip提前抢购分钟
            $sell_time = strtotime($coll_info['sell_time'])-($advance_minutes*60);
        }else{
            $sell_time = strtotime($coll_info['sell_time']);
        }

        if ($sell_time>time()) $this->error('商品还未开始售卖！请耐心等待');

        $snap_card = getMembercard($this->uid);  //获取用户抢购卡数量
        if ($snap_card<1) $this->error('抢购卡不足，无法抢购');

        //获取用户已经购买数量
        $userByCount = getByCount($this->uid,$id);
        if ($coll_info['buy_count']<($userByCount+$num)) $this->error('每人限购'.$coll_info['buy_count'].'个');

        //获取是否已经铸造hash
        $hashCount = getLenCollection($id);
      //  if (!$hashCount || $hashCount<$num) $this->error('hash未铸造,无法购买');

        $redis2 = new \think\cache\driver\Redis();
        $max = $redis2->get('max_30');
        if ($max>100){
            $this->error('排队中...');
        }
        $redis2->Incr('max_30');

        //先减掉库存
        loseCollectionInventory($id,$num);
        //先减掉抢购卡数量
        loseMembercard($this->uid);
        //先增加购买数量
        IncrByCount($this->uid,$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_order2')->insert($order_int);
            $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);

                    $result = $app->order->unify([
                        'body' => $body,
                        'out_trade_no' => $order_no,
                        'total_fee' => $total_fee,
                        'trade_type' => 'APP', // 请对应换成你的支付方式对应的值类型
                    ]);
                    if ($result['return_code']=='SUCCESS'){
                        $jssdk      =   $app->jssdk;
                        $order1 = $jssdk->appConfig($result['prepay_id']);
                        Db::name('store_order2')->where('order_no',$order_no)->update(['wx_order'=>json_encode($order1,true)]);
                        $retrun_data['order_no'] = $order_no;
                        $retrun_data['pay'] = $order1;
                        //减少数据库库存
                        Db::name('store_collection')->where('id',$id)->setDec('now_inventory',$num);
                        //减少用户抢购卡数量
                        Db::name('store_member')->where('id',$this->uid)->setDec('snap_card');
                        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::name('store_member')->where('id',$this->uid)->setDec('snap_card');
                    Db::commit();
                    break;
            }

        }catch (\Exception $e){
            $com=false;
            Db::rollback();
        }
        if ($com){
            $redis2->Decr('max_30');
            // $this->savetest($order_no);
            $this->success('成功',$retrun_data);
        }else{

            $redis2->Decr('max_30');
            //加上库存
            addCollectionInventory($id,$num);
            //加上抢购卡数量
            addMembercard($this->uid);
            //减少用户购买数量
            DecrByCount($this->uid,$id,$num);

            $this->error('抢购失败，请稍后重试');
        }

    }







}