优化用户下单方法-进行中

app/controller/api/store/order/StoreOrder.php

@@ -24,6 +24,9 @@ use app\common\repositories\store\order\StoreGroupOrderRepository;
 use app\common\repositories\store\order\StoreOrderRepository;
 use crmeb\services\ExpressService;
 use think\App;
+use think\db\exception\DataNotFoundException;
+use think\db\exception\DbException;
+use think\db\exception\ModelNotFoundException;
 use think\facade\Cache;
 use think\facade\Db;
 use think\facade\Request;
@@ -689,6 +692,322 @@ class StoreOrder extends BaseController
     }
 
     /**
+     * @param StoreCartRepository $cartRepository
+     * @return mixed
+     * @author xaboy
+     * @day 2020/6/10
+     */
+    public function createOrderNew(StoreCartRepository $cartRepository)
+    {
+        // 1、接收参数
+        $allParams = input();
+        \think\facade\Log::info("createOrder params" . json_encode($allParams));
+        $cartId = $allParams['cart_id'] ?? null;
+        if (is_null($cartId)) {
+            return app('json')->fail("缺少购物车ID参数!");
+        }
+        $fzonePayType = $allParams['fzone_paytype'] ?? '[]';
+        if (is_null($fzonePayType) || strstr($fzonePayType, "type") === false) {
+            return app('json')->fail("请选择支付方式!");
+        }
+        $fzonePayTypeMap = json_decode($fzonePayType, true);
+        $addressId = (int)($allParams['address_id'] ?? 0); // 地址ID
+
+        $payType = $this->request->param('pay_type');// 5积分 6京豆
+        $share_id = $this->request->param('share_id', '');//分享id
+        $mer_id = $this->request->param('mer_id', '');//分享id
+        $uid = $this->request->uid();
+
+
+        // 2、加锁，他之前加的锁好像在锁狗屎，毛线都没锁住, 而且为什么要锁用户
+        // 增加锁，防止同一用户重读点击
+        $redisHandler = Cache::store('redis')->handler();
+        $isSet = $redisHandler->set('createOrder' . $uid . '-' . $cartId, 1, ['nx', 'ex' => 30]);
+        if ($isSet) {
+            return app('json')->fail('请勿重复下单');
+        }
+
+        // 3、验证购物车内商品 是否已下架，是否无货，是否支持发货 是否满足数量
+        // 处理购物车 按照之前需求的意思，应该 每次下单 只能购买 一个SPU 的 一个SKU，而且只能买一件
+        //在提交订单之前会产出购物车cartid，其中会产生购买的数量，现在默认会员专区是只让购买一个商品，需要修改值为1
+        try {
+            $storeCartDataList = Db::name('store_cart')
+                ->where('cart_id', $cartId)
+                ->select()
+                ->toArray();
+        } catch (\Exception $e) {
+            return app('json')->fail('获取购物车内容失败');
+        }
+        // 这块 限制还 欠完善考虑
+        if (count($storeCartDataList) > 1 || $storeCartDataList[0]['cart_num'] > 1) {
+            return app('json')->fail('购买数量默认为一件，请修改购买数量!');
+        }
+        // 确认购物车内 微唯宝 的商品 是否满足发货
+        /** @var ProductAttrValueRepository $productAttrValueRepository */
+        $productAttrValueRepository = app()->make(ProductAttrValueRepository::class);
+        foreach ($storeCartDataList as $k => $item) {
+            // 检查库存 查看 此商品已下架 此商品规格无货 此商品不支持该地区
+            // （按照代码中所写的逻辑来推理：从微唯宝拉取过来，从而上架到商品表的商品，都有SPUId，所以去走微唯宝提供的接口验证，而会员专区和商贸区的商品可能是商户自己加的，没有SPUId，所以也就不用走微唯宝的验证）
+            $checkGong = $productAttrValueRepository->checkGong($item['product_id'], $item['product_attr_unique'], $item['cart_num'], $uid, $addressId);
+            if (isset($checkGong['code']) && $checkGong['code'] == -1){
+                return app('json')->fail($checkGong['message']);
+            }
+        }
+
+        // 获取 用户收货地址
+        /** @var UserAddressRepository $userAddressRepository */
+        $userAddressRepository = app()->make(UserAddressRepository::class);
+        try {
+            $addressData = $userAddressRepository->getWhere(['uid' => $uid, 'address_id' => $addressId]);
+        } catch (\Exception $e) {
+            return app('json')->fail('获取用户收货地址失败');
+        }
+        // 如果不是会员专区的商品，则一定要用户完善的收货地址
+        if ($mer_id != 496) {
+            if (!$addressData['city_id']) {
+                return app('json')->fail('请选择正确的收货地址');
+            }
+            if ($addressData['code_list'] == '') {
+                return app('json')->fail('地址需要选择4级地址！请修改地址！');
+            }
+        }
+
+        // 判断组合支付逻辑，积分、VR、京豆
+        try {
+            $userData = Db::name("user")
+                ->where("uid", $uid)
+                ->find();
+        } catch (\Exception $e) {
+            return app('json')->fail('获取当前用户信息失败');
+        }
+        $array_fzone_paytype_all = [
+            'fzone_pay_jingdou' => 0,
+            'fzone_pay_vr' => 0,
+            'fzone_pay_jifen' => 0,
+            'fzone_pay_price' => 0,
+            'fzone_pay_other' => $fzonePayTypeMap['other'],
+            'fzone_pay_note' => $fzonePayTypeMap['note'],
+            'fzone_pay_type' => $fzonePayTypeMap['type'],
+        ];
+
+        //会员专区升级产生的user_of_goods订单ID赋值
+        $getuserofgoodsid = 1;
+
+        if (!empty($fzonePayTypeMap['type'])) {
+            if (!empty($fzonePayTypeMap['type'] == 'b1')) {
+                //精彩生活VR+积分
+                //vr+积分
+                $vrpri = $userData['vr'] - $fzonePayTypeMap['price'];
+                $pricepri = $userData['score'] - $fzonePayTypeMap['other'];
+                //vr+积分
+                if ($vrpri < 0 || $pricepri < 0) {
+                    return app('json')->fail("支付失败,VR或积分不足!");
+                }
+                $array_fzone_paytype_all['fzone_pay_vr'] = $fzonePayTypeMap['price'];
+                $array_fzone_paytype_all['fzone_pay_jifen'] = $fzonePayTypeMap['other'];
+
+            } else if (!empty($fzonePayTypeMap['type'] == 'b2')) {
+                //精彩生活现金+积分
+                //商贸区：现金+积分
+
+                $vrpri = $userData['score'] - $fzonePayTypeMap['other'];
+
+                // //现金+积分
+                if ($vrpri < 0) {
+                    return app('json')->fail("支付失败,积分不足!");
+                }
+                $array_fzone_paytype_all['fzone_pay_price'] = $fzonePayTypeMap['price'];
+                $array_fzone_paytype_all['fzone_pay_jifen'] = $fzonePayTypeMap['other'];
+
+            } else if (!empty($fzonePayTypeMap['type'] == 'b3')) {
+                //精彩生活区 VR+京豆
+                $vrpri = $userData['vr'] - $fzonePayTypeMap['price'];
+                $pricepri = $userData['jingdou'] - $fzonePayTypeMap['other'];
+                //vr+积分
+                if ($vrpri < 0 || $pricepri < 0) {
+                    return app('json')->fail("支付失败,VR或京豆不足!");
+                }
+                $array_fzone_paytype_all['fzone_pay_vr'] = $fzonePayTypeMap['price'];
+                $array_fzone_paytype_all['fzone_pay_jingdou'] = $fzonePayTypeMap['other'];
+            } else if (!empty($fzonePayTypeMap['type'] == 'b4')) {
+                //精彩生活区 现金+京豆
+                $pricepri = $userData['jingdou'] - $fzonePayTypeMap['other'];
+
+                // //现金+积分
+                if ($pricepri < 0) {
+                    return app('json')->fail("支付失败,京豆不足!");
+                }
+                $array_fzone_paytype_all['fzone_pay_price'] = $fzonePayTypeMap['price'];
+                $array_fzone_paytype_all['fzone_pay_jingdou'] = $fzonePayTypeMap['other'];
+                //                return app('json')->fail("开发中升级中！");
+
+            } else if (!empty($fzonePayTypeMap['type'] == 'b5')) {
+                //精彩生活 VR支付
+
+                $vrpri = $userData['vr'] - $fzonePayTypeMap['price'];
+
+                if ($vrpri < 0) {
+                    return app('json')->fail("支付失败,VR不足!");
+                }
+                $array_fzone_paytype_all['fzone_pay_vr'] = $fzonePayTypeMap['price'];
+            } else if (!empty($fzonePayTypeMap['type'] == 'a1')) {
+                //生活 VR支付
+
+                $vrpri = $userData['vr'] - $fzonePayTypeMap['price'];
+
+
+                if ($vrpri < 0) {
+                    return app('json')->fail("支付失败,VR不足!");
+                }
+                $array_fzone_paytype_all['fzone_pay_vr'] = $fzonePayTypeMap['price'];
+                // return app('json')->fail($userdatas['spread_old']);
+                //检查在旧表中是否有上级
+                if ($userData['spread_old'] != 0) {
+
+
+                    //查询当前用户的上级在1.0中是有数据的，那么老用户介绍新用户。
+                    $sf = Db::name('old_user_jbp')->where('id', $userData['uid'])->find();//父级在旧表有注册
+
+                    // $sf1 = Db::name('old_user_jbp')->where('id',$userdatas['id'])->find();
+
+                    // 当前用户是在2.0注册的新用户，父级是在1.0
+
+                    //当前用户在1.0中没有注册，但是父级在1.0系统中注册过。
+                    if (!empty($sf)) {
+
+                        //检查用户在旧表中是否与上级，有的话就是升级权限，要新增一个user_of_goods的表
+                        $data1['user_id'] = $uid;
+                        $data1['goods_list_id'] = 0;
+                        $data1['status'] = 0;
+                        $data1['spread_id'] = $sf['invite_id'];
+                        $data1['node_id'] = $sf['spread'];
+                        $data1['money'] = $fzonePayTypeMap['price'];
+                        $data1['order_id'] = 10;
+                        $data1['server_id'] = $userData['server_id_old'];
+                        $data1['pay_gb'] = 0;
+                        $data1['pay_vr'] = $fzonePayTypeMap['price'];
+                        $data1['pay_bt'] = 0;
+
+                        //return app('json')->fail("333");
+
+                        $sfe = Db::name('old_user_of_goods')->insertGetId($data1);
+
+                        if ($sfe) {
+                            $getuserofgoodsid = $sfe;
+                        }
+                    }
+
+
+                }
+
+
+                //Db::getLastInsID();
+
+            } else if (!empty($fzonePayTypeMap['type'] == 'a3')) {
+                //生活 现金 + VR支付
+
+
+                //检查在旧表中是否有上级
+                if ($userData['spread_old'] != 0) {
+
+
+                    //查询当前用户的上级在1.0中是有数据的，那么老用户介绍新用户。
+                    $sf = Db::name('old_user_jbp')->where('id', $userData['uid'])->find();//父级在旧表有注册
+                    //如果组合支付中，没有现金，只是用VR支付的情况下
+
+                    if ($fzonePayTypeMap['price'] <= 0.01) {
+                        return app('json')->fail("现金不足");
+                    }
+
+                    // 当前用户是在2.0注册的新用户，父级是在1.0
+
+                    //当前用户在1.0中没有注册，但是父级在1.0系统中注册过。
+                    if (!empty($sf)) {
+
+                        //检查用户在旧表中是否与上级，有的话就是升级权限，要新增一个user_of_goods的表
+                        $data1['user_id'] = $uid;
+                        $data1['goods_list_id'] = 0;
+                        $data1['status'] = 0;
+                        $data1['spread_id'] = $sf['invite_id'];
+                        $data1['node_id'] = $sf['spread'];
+                        $data1['money'] = $fzonePayTypeMap['price'];
+                        $data1['order_id'] = 10;
+                        $data1['server_id'] = $userData['server_id_old'];
+                        $data1['pay_gb'] = 0;
+                        $data1['pay_vr'] = $fzonePayTypeMap['price'];
+                        $data1['pay_bt'] = 0;
+
+                        //return app('json')->fail("333");
+
+                        $sfe = Db::name('old_user_of_goods')->insertGetId($data1);
+
+                        if ($sfe) {
+                            $getuserofgoodsid = $sfe;
+                        }
+                    }
+
+
+                }
+                $array_fzone_paytype_all['fzone_pay_price'] = $fzonePayTypeMap['price'];
+                $array_fzone_paytype_all['fzone_pay_vr'] = $fzonePayTypeMap['other'];
+
+            } else if (!empty($fzonePayTypeMap['type'] == 'c1')) {
+                //复购区 复购金支付
+                $fugoupri = $userData['fugou'] - $fzonePayTypeMap['price'];
+
+                if ($fugoupri < 0) {
+                    return app('json')->fail("支付失败,复购金不足!");
+                }
+                $array_fzone_paytype_all['fzone_pay_other'] = $fzonePayTypeMap['price'];
+            } else {
+                $array_fzone_paytype_all['fzone_pay_price'] = $fzonePayTypeMap['price'];
+            }
+        }
+
+
+        //end
+        //$getuserofgoodsid= 1;
+
+        makeLock()->lock();
+        try {
+            $groupOrder = $this->repository->createOrder($this->request->userInfo(), $payType, [$cartId], $addressId, 0, 0, 0, 0, 0, $share_id, 0, $mer_id, 0, 0, 0, 0, 0, 0, $fzonePayType, $getuserofgoodsid, $array_fzone_paytype_all);
+            //var_dump($groupOrder);
+        } catch (\Throwable $e) {
+            makeLock()->unlock();
+            throw $e;
+        }
+        makeLock()->unlock();
+
+
+        //删除缓存的优惠价格
+        // Cache::delete($uid.'_youhui_price_'.$product_type_id);
+
+        //return app('json')->status('success', '支付成功1', ['order_id' => $groupOrder['group_order_id']]);
+        //利润
+
+
+        if ($groupOrder['pay_price'] == 0) {
+            $this->repository->paySuccess($groupOrder);
+            return app('json')->status('success', '支付成功2', ['order_id' => $groupOrder['group_order_id']]);
+        }
+        try {
+            $groupOrder['pay_price'] = set_price_rtrim($groupOrder['pay_price']);
+            //
+            if ($groupOrder['er'] == 0) {
+
+                return app('json')->success(['order_id' => $groupOrder->group_order_id, "groupOrder" => $groupOrder]);
+            } else {
+                return json_encode(array("status" => 400, "message" => $groupOrder['er1']));
+            }
+
+
+            //            return $this->repository->pay($payType, $this->request->userInfo(), $groupOrder);
+        } catch (\Exception $e) {
+            return app('json')->status('error', $e->getMessage(), ['order_id' => $groupOrder->group_order_id]);
+        }
+    }
+
+    /**
      *
      * @remarks 年费订单创建
      * @author Tang