|
|
@@ -0,0 +1,786 @@
|
|
|
+<?php
|
|
|
+
|
|
|
+namespace app\common\service;
|
|
|
+
|
|
|
+use app\api\services\ExpressServices;
|
|
|
+use app\common\model\ShopCartModel;
|
|
|
+use app\common\model\ShopGoods;
|
|
|
+use app\common\model\ShopGoodsModel;
|
|
|
+use app\common\model\ShopGoodsSpec;
|
|
|
+use app\common\model\ShopOrder;
|
|
|
+use app\common\model\ShopOrderGoodsModel;
|
|
|
+use app\common\model\ShopOrderShippingModel;
|
|
|
+use app\common\model\UserAddressModel;
|
|
|
+use jobs\ShopOrderJob;
|
|
|
+use think\Exception;
|
|
|
+use think\facade\Db;
|
|
|
+use utils\Queue;
|
|
|
+use utils\RedisCache;
|
|
|
+
|
|
|
+/**
|
|
|
+ * 商城订单服务 by wes
|
|
|
+ * Class ShopOrderService
|
|
|
+ * @package app\common\service
|
|
|
+ */
|
|
|
+class ShopOrderService
|
|
|
+{
|
|
|
+ protected static $instance = null;
|
|
|
+ protected $model = null;
|
|
|
+
|
|
|
+ public function __construct()
|
|
|
+ {
|
|
|
+ $this->model = new ShopOrder();
|
|
|
+ }
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 静态化入口
|
|
|
+ * @return static|null
|
|
|
+ */
|
|
|
+ public static function make()
|
|
|
+ {
|
|
|
+ if (!self::$instance) {
|
|
|
+ self::$instance = new static();
|
|
|
+ }
|
|
|
+
|
|
|
+ return self::$instance;
|
|
|
+ }
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 商城下单
|
|
|
+ * @param $uid 用户ID
|
|
|
+ * @param $buyGoods 购买的商品数组
|
|
|
+ * @param $payType 支付方式
|
|
|
+ * @param $request 请求数据
|
|
|
+ * @param int $cartIds 购物车ID数组
|
|
|
+ * @param int $cls 赠送月卡功能开关
|
|
|
+ * @return array
|
|
|
+ * @throws Exception
|
|
|
+ */
|
|
|
+ public function createOrder($uid, $buyGoods, $payType, $request, $cartIds = 0, $cls = 0)
|
|
|
+ {
|
|
|
+ // 获取收货地址信息
|
|
|
+ $orderType = 1; // 订单类型 1商城订单 2积分订单 3.兑换券 4.锁定积分兑换 5.福袋发货订单
|
|
|
+ $addressId = $request->post('address', '');
|
|
|
+ $remark = $request->post('order_remark', '');
|
|
|
+ if (!$addressId || !$userAddress = UserAddressModel::getAddressIdDetails((int)$addressId)) {
|
|
|
+ throw new Exception('获取收货地址失败');
|
|
|
+ }
|
|
|
+
|
|
|
+ $addressUid = isset($userAddress['uid']) ? $userAddress['uid'] : 0;
|
|
|
+ if ($addressUid != $uid) {
|
|
|
+ throw new Exception('收货地址信息异常');
|
|
|
+ }
|
|
|
+
|
|
|
+ if (empty($buyGoods)) {
|
|
|
+ throw new Exception('商品参数错误');
|
|
|
+ }
|
|
|
+
|
|
|
+ // 未支付订单数量验证
|
|
|
+ $count = ShopOrderService::make()->checkBuyCountByTime($uid, 1, 0);
|
|
|
+ $noPayLimit = env('common.ORDER_NO_PAY_LIMIT', 5);
|
|
|
+ if ($count >= $noPayLimit) {
|
|
|
+ throw new Exception("2小时内未支付的订单不能超过{$noPayLimit}个，下单失败");
|
|
|
+ }
|
|
|
+
|
|
|
+ // 订单商品数据处理
|
|
|
+ $i = 0;
|
|
|
+ $nowTime = time();
|
|
|
+ $orderId = $this->model->max('order_id') + 1;
|
|
|
+ $orderDatas = $orderGoods = $orders = $shippingList = [];
|
|
|
+ $expireTime = time() + intval(env('common.ORDER_EXPIRES_TIME'));
|
|
|
+ Db::startTrans();
|
|
|
+ try {
|
|
|
+ foreach ($buyGoods as $k => $v) {
|
|
|
+ $goodsSn = isset($v['goods_sn']) ? trim($v['goods_sn']) : 0;
|
|
|
+ $specId = isset($v['spec_id']) ? trim($v['spec_id']) : 0;
|
|
|
+ $num = isset($v['num']) ? intval($v['num']) : 0;
|
|
|
+ if ($num < 1) {
|
|
|
+ throw new Exception('请先选择商品数量哦');
|
|
|
+ }
|
|
|
+
|
|
|
+ // 商品信息验证
|
|
|
+ $goodsInfo = ShopGoodsService::make()->getCacheInfo($v['goods_sn']);
|
|
|
+ if (!$goodsInfo) {
|
|
|
+ throw new Exception('商品参数错误或已下架,请返回刷新列表');
|
|
|
+ }
|
|
|
+ if ($goodsInfo['goods_type'] == 2) {
|
|
|
+ throw new Exception('商福袋商品不能购买');
|
|
|
+ }
|
|
|
+
|
|
|
+ // 商品限购验证
|
|
|
+ if ($goodsInfo['restrictions_num'] > 0) {
|
|
|
+ $count = ShopOrderGoodsService::make()->getCountByUserAndGoods($uid, $goodsSn);
|
|
|
+
|
|
|
+ if ($count > $goodsInfo['restrictions_num']) {
|
|
|
+ throw new Exception('超过限购');
|
|
|
+ }
|
|
|
+ if ($v['num'] + $count > $goodsInfo['restrictions_num']) {
|
|
|
+ throw new Exception('超过限购数量，还可购买：' . ($goodsInfo['restrictions_num'] - $count) . '件');
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ // 商品库存验证
|
|
|
+ if ($goodsSn && $specId && $num > 0) {
|
|
|
+ $stock = ShopGoodsSpecService::make()->getStock($goodsSn, $specId);
|
|
|
+ if ($num > $stock) {
|
|
|
+ throw new Exception('下单失败，所选商品含有库存不足的商品：SN-' . $goodsSn);
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ // 是否赠送月卡
|
|
|
+ $giveVip = 0;
|
|
|
+ $goodsGiveVip = isset($goodsInfo['give_vip']) ? $goodsInfo['give_vip'] : 0;
|
|
|
+ if ($cls == 1 && $goodsGiveVip) {
|
|
|
+ $giveVip = $goodsGiveVip;
|
|
|
+ }
|
|
|
+
|
|
|
+ // 同商品订单数据
|
|
|
+ if (!isset($orderDatas[$goodsSn]) || empty($orderDatas[$goodsSn])) {
|
|
|
+ $orderSn = createdOrderSn();
|
|
|
+ $orders[] = $orderSn;
|
|
|
+ $orderId = $orderId + $i;
|
|
|
+ $orderDatas[$goodsSn] = [
|
|
|
+ 'order_id' => $orderId,
|
|
|
+ 'order_sn' => $orderSn,
|
|
|
+ 'total_price' => 0,
|
|
|
+ 'payment' => 0,
|
|
|
+ 'user_id' => $uid,
|
|
|
+ 'status' => 0, // 待付款
|
|
|
+ 'ship_postfee' => 0,
|
|
|
+ 'rebate_score' => 0, //总返利积分
|
|
|
+ 'created_time' => date('Y-m-d H:i:s', $nowTime + $i),
|
|
|
+ 'updated_time' => date('Y-m-d H:i:s', $nowTime + $i),
|
|
|
+ 'give_vip' => $giveVip,
|
|
|
+ 'order_remark' => $remark,
|
|
|
+ 'pay_type' => $payType,
|
|
|
+ 'order_type' => $orderType,
|
|
|
+ 'coupon_number' => '',
|
|
|
+ 'expires_time' => sr_getcurtime($expireTime + $i),
|
|
|
+ 'supplier_name' => isset($goodsInfo['supplier_name']) ? $goodsInfo['supplier_name'] : '',
|
|
|
+ ];
|
|
|
+
|
|
|
+ // 构建订单配送数据
|
|
|
+ $shippingList[$orderSn] = [
|
|
|
+ 'order_id' => $orderId,
|
|
|
+ 'sp_name' => $userAddress['name'],
|
|
|
+ 'sp_mobile' => $userAddress['mobile'],
|
|
|
+ 'sp_province' => $userAddress['sp_province'],
|
|
|
+ 'sp_city' => $userAddress['sp_city'],
|
|
|
+ 'sp_county' => $userAddress['sp_county'],
|
|
|
+ 'sp_remark' => $userAddress['remark'],
|
|
|
+ 'sp_mergename' => $userAddress['mergename'],
|
|
|
+ 'created_time' => date('Y-m-d H:i:s', $nowTime + $i),
|
|
|
+ 'updated_time' => date('Y-m-d H:i:s', $nowTime + $i),
|
|
|
+ ];
|
|
|
+
|
|
|
+ $i++;
|
|
|
+ }
|
|
|
+
|
|
|
+
|
|
|
+ // 订单商品规格数据
|
|
|
+ $goodsSpec = ShopGoodsSpecService::make()->getDataByGoods($goodsInfo['goods_id'], $specId);
|
|
|
+ $goodsSpecId = isset($goodsSpec['goods_spec_id']) ? $goodsSpec['goods_spec_id'] : 0;
|
|
|
+ $weight = isset($goodsSpec['weight']) ? $goodsSpec['weight'] : 0;
|
|
|
+ $price = isset($goodsSpec['price']) ? $goodsSpec['price'] : 0;
|
|
|
+
|
|
|
+ // 同一个商品数据合计
|
|
|
+ $totalFee = bcmul($num, $price, 3);
|
|
|
+ $totalWeight = bcmul($num, $weight, 3);
|
|
|
+ $orderDatas[$goodsSn]['total_weight'] = isset($orderDatas[$goodsSn]['total_weight']) ? bcadd($orderDatas[$goodsSn]['total_weight'], $totalWeight, 3) : $totalWeight;
|
|
|
+ $orderDatas[$goodsSn]['total_price'] = isset($orderDatas[$goodsSn]['total_price']) ? bcadd($orderDatas[$goodsSn]['total_price'], $totalFee, 3) : $totalFee;
|
|
|
+ $orderDatas[$goodsSn]['num'] = isset($orderDatas[$goodsSn]['num']) ? intval($orderDatas[$goodsSn]['num'] + $num) : $num;
|
|
|
+
|
|
|
+ // 返还积分/金额合计
|
|
|
+ $rebateScore = isset($goodsInfo['rebate_score']) ? bcmul($num, $goodsInfo['rebate_score'], 3) : 0;
|
|
|
+ $rebateMoney = isset($goodsInfo['rebate_money']) ? bcmul($num, $goodsInfo['rebate_money'], 3) : 0;
|
|
|
+ $orderDatas[$goodsSn]['rebate_score'] = isset($orderDatas[$goodsSn]['rebate_score']) ? bcadd($orderDatas[$goodsSn]['rebate_score'], $rebateScore, 3) : $rebateScore;
|
|
|
+ $orderDatas[$goodsSn]['rebate_money'] = isset($orderDatas[$goodsSn]['rebate_money']) ? bcadd($orderDatas[$goodsSn]['rebate_money'], $rebateScore, 3) : $rebateMoney;
|
|
|
+ $orderDatas[$goodsSn]['rebate_money'] = 0; // 临时覆盖值
|
|
|
+
|
|
|
+ // 邮费计算合计
|
|
|
+ $postFee = 0;
|
|
|
+ $costPostFee = true;
|
|
|
+ if ($costPostFee) {
|
|
|
+ $city = isset($userAddress['city']) ? $userAddress['city'] : '';
|
|
|
+ $postData = [
|
|
|
+ 'goods_sn' => $goodsInfo['goods_sn'],
|
|
|
+ 'num' => $orderDatas[$goodsSn]['num'],
|
|
|
+ 'total_price' => $orderDatas[$goodsSn]['total_price'],
|
|
|
+ 'total_weight' => $orderDatas[$goodsSn]['total_weight'],
|
|
|
+ ];
|
|
|
+ $postTemplateId = isset($goodsInfo['post_template_id']) ? $goodsInfo['post_template_id'] : 0;
|
|
|
+ $postFee = ShopOrderService::make()->postFee($city, $postData, $postTemplateId); // 邮费
|
|
|
+ }
|
|
|
+
|
|
|
+ $orderDatas[$goodsSn]['ship_postfee'] = $postFee;
|
|
|
+ $orderDatas[$goodsSn]['payment'] = bcadd($orderDatas[$goodsSn]['total_price'], $postFee, 3);
|
|
|
+
|
|
|
+ // 订单商品
|
|
|
+ $orderGoods[] = [
|
|
|
+ 'order_id' => $orderDatas[$goodsSn]['order_id'],
|
|
|
+ 'goods_id' => $goodsInfo['goods_id'],
|
|
|
+ 'goods_name' => $goodsInfo['goods_name'],
|
|
|
+ 'goods_category' => $goodsInfo['category'],
|
|
|
+ 'goods_img' => isset($goodsSpec['picture']) && $goodsSpec['picture'] ? $goodsSpec['picture'] : $goodsInfo['goods_img'],
|
|
|
+ 'num' => $num,
|
|
|
+ 'price' => $price,
|
|
|
+ 'total_fee' => $totalFee,
|
|
|
+ 'goods_spec_id' => $goodsSpecId,
|
|
|
+ 'spec_ids' => isset($goodsSpec['spec_ids']) ? $goodsSpec['spec_ids'] : '',
|
|
|
+ 'spec_text' => isset($goodsSpec['spec_text']) ? $goodsSpec['spec_text'] : '',
|
|
|
+ 'rebate_score' => isset($goodsSpec['rebate_score']) ? $goodsSpec['rebate_score'] : 0,
|
|
|
+ 'total_rebate_score' => $orderDatas[$goodsSn]['rebate_score'],
|
|
|
+ 'uid' => $uid
|
|
|
+ ];
|
|
|
+
|
|
|
+ // 扣库存
|
|
|
+ if (!ShopGoodsSpec::where(['goods_spec_id' => $goodsSpecId])->dec('stock', $num)->update()) {
|
|
|
+ throw new Exception('商品库存处理失败');
|
|
|
+ }
|
|
|
+
|
|
|
+ // 扣除商品总库存
|
|
|
+ if (!ShopGoods::where(['goods_id' => $goodsInfo['goods_id']])->dec('inventory', $num)->update()) {
|
|
|
+ throw new Exception('商品库存处理失败');
|
|
|
+ }
|
|
|
+
|
|
|
+ // 增加销量
|
|
|
+ if (in_array($orderType, [3, 4, 5])) {
|
|
|
+ if (!ShopGoodsModel::where(['goods_id' => $goodsInfo['goods_id']])
|
|
|
+ ->inc('sales_volume', $num)
|
|
|
+ ->inc('real_sales_volume', $num)
|
|
|
+ ->update()) {
|
|
|
+ throw new Exception('商品销量处理失败');
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ // 清除商品相关实时数据缓存
|
|
|
+ RedisCache::keyDel('caches:goods:list_*');
|
|
|
+ RedisCache::keyDel('caches:goodsSpec:list_*');
|
|
|
+
|
|
|
+ }
|
|
|
+
|
|
|
+ if (empty($orders) || empty($orderGoods)) {
|
|
|
+ throw new Exception('订单数据错误，下单失败');
|
|
|
+ }
|
|
|
+
|
|
|
+ // 批量写入订单数据
|
|
|
+ $data = array_values($orderDatas);
|
|
|
+ if (!$this->model->insertAll($data)) {
|
|
|
+ Db::rollback();
|
|
|
+ throw new Exception('下单失败');
|
|
|
+ }
|
|
|
+
|
|
|
+ // 批量写入订单商品数据
|
|
|
+ $data = array_values($orderGoods);
|
|
|
+ if (!ShopOrderGoodsModel::insertAll($data)) {
|
|
|
+ Db::rollback();
|
|
|
+ throw new Exception('下单失败，订单商品处理错误');
|
|
|
+ }
|
|
|
+
|
|
|
+ // 写入配送单数据
|
|
|
+ $data = array_values($shippingList);
|
|
|
+ if (!ShopOrderShippingModel::insertAll($data)) {
|
|
|
+ Db::rollback();
|
|
|
+ throw new Exception('下单失败，订单配送数据处理错误');
|
|
|
+ }
|
|
|
+
|
|
|
+ // 超时过期订单队列任务处理
|
|
|
+ if (in_array($orderType, [1, 3]) && $orders) {
|
|
|
+ $ex_time = intval(env('common.ORDER_EXPIRES_TIME', 60 * 60));
|
|
|
+ Queue::instance()->log('订单过期执行成功')
|
|
|
+ ->job(ShopOrderJob::class)
|
|
|
+ ->do('ShopOrderExpired')
|
|
|
+ ->secs($ex_time)
|
|
|
+ ->push([$orders[0]]);
|
|
|
+ }
|
|
|
+
|
|
|
+ // 验证检查购物车数据
|
|
|
+ if ($cartIds && is_array($cartIds)) {
|
|
|
+ ShopCartModel::where('id', 'in', $cartIds)->where(['user_id' => $uid])->delete();
|
|
|
+ }
|
|
|
+
|
|
|
+ // 清除单一购物车数据
|
|
|
+ $cartId = $request->post('cart_id', 0);
|
|
|
+ if ($cartId) {
|
|
|
+ ShopCartModel::where('id', $cartId)->delete();
|
|
|
+ }
|
|
|
+
|
|
|
+ $cacheKey = "caches:orders:u_{$uid}_{$orderType}:create_{$payType}_" . date('YmdHis') . rand(10, 99);
|
|
|
+ RedisCache::set($cacheKey, ['uid' => $uid, 'orderDatas' => $orderDatas, 'shipping' => $shippingList, 'orderGoods' => $orderGoods, 'post' => $request->post()], 7200);
|
|
|
+
|
|
|
+ Db::commit();
|
|
|
+ return $orders;
|
|
|
+ } catch (\Exception $e) {
|
|
|
+ throw new Exception($e->getMessage());
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 下单数据
|
|
|
+ * @param $buyGoods 购买商品
|
|
|
+ * @param $request
|
|
|
+ * @return array
|
|
|
+ * @throws Exception
|
|
|
+ * @throws \think\db\exception\DataNotFoundException
|
|
|
+ * @throws \think\db\exception\DbException
|
|
|
+ * @throws \think\db\exception\ModelNotFoundException
|
|
|
+ */
|
|
|
+ public function buyDetail($buyGoods, $request)
|
|
|
+ {
|
|
|
+ $addressId = $request->post('address_id', 0);
|
|
|
+ if (!$address = UserAddressModel::getAddressIdDetails($addressId, $request->uid, 1)) {
|
|
|
+ throw new Exception('订单地址错误');
|
|
|
+ }
|
|
|
+
|
|
|
+ $details = $goodsSnArr = [];
|
|
|
+ $paymentTotal = 0; // 总订单金额
|
|
|
+ $totalRebateScore = 0; // 总返还积分
|
|
|
+ $totalNum = 0; // 商品总数量
|
|
|
+ $curXzmoney = SystemConfigService::make()->getConfigByName('xz_cur_money', '', 'xzconfig');
|
|
|
+ foreach ($buyGoods as $k => $v) {
|
|
|
+ $goodsSn = isset($v['goods_sn']) ? $v['goods_sn'] : '';
|
|
|
+ $specId = isset($v['spec_id']) ? $v['spec_id'] : 0;
|
|
|
+ $num = isset($v['num']) ? intval($v['num']) : 0;
|
|
|
+ $totalNum += $num;
|
|
|
+ if ($num <= 0) {
|
|
|
+ throw new Exception('下单失败,请先选择商品数量');
|
|
|
+ }
|
|
|
+
|
|
|
+ // 商品信息
|
|
|
+ if (!$goodsSn || !$goodsInfo = ShopGoodsService::make()->getCacheInfo($goodsSn)) {
|
|
|
+ throw new Exception('下单失败,商品参数错误');
|
|
|
+ }
|
|
|
+
|
|
|
+ // 订单商品规格数据
|
|
|
+ $goodsSnArr[] = $goodsSn;
|
|
|
+ $goodsSpec = ShopGoodsSpecService::make()->getDataByGoods($goodsInfo['goods_id'], $specId);
|
|
|
+ $weight = isset($goodsSpec['weight']) ? $goodsSpec['weight'] : 0;
|
|
|
+ $price = isset($goodsSpec['price']) ? $goodsSpec['price'] : 0;
|
|
|
+ if (empty($goodsSpec)) {
|
|
|
+ throw new Exception('下单失败,存在无效商品');
|
|
|
+ }
|
|
|
+
|
|
|
+ // 商品数据
|
|
|
+ $postFee = '0.00';
|
|
|
+ $rebateScore = bcmul($num, $goodsSpec['rebate_score'], 2);
|
|
|
+ $totalFee = bcmul($num, $price, 2);
|
|
|
+ $totalWeight = bcmul($num, $weight, 3);
|
|
|
+
|
|
|
+ // 组装订单商品数据
|
|
|
+ $details[$goodsSn]['total_rebate_score'] = isset($details[$goodsSn]['total_rebate_score']) ? bcadd($details[$goodsSn]['total_rebate_score'], $rebateScore, 3) : $rebateScore; //总返利积分
|
|
|
+ $details[$goodsSn]['total_num'] = isset($details[$goodsSn]['total_num']) ? bcadd($details[$goodsSn]['total_num'], $num, 3) : $num; //总数量
|
|
|
+ $details[$goodsSn]['total_price'] = isset($details[$goodsSn]['total_price']) ? bcadd($details[$goodsSn]['total_price'], $totalFee, 3) : $totalFee; // 总金额
|
|
|
+ $details[$goodsSn]['total_weight'] = isset($details[$goodsSn]['total_weight']) ? bcadd($details[$goodsSn]['total_weight'], $totalWeight, 3) : $totalWeight; // 总重量
|
|
|
+ $details[$goodsSn]['post_fee'] = $postFee;
|
|
|
+ $details[$goodsSn]['payment'] = bcadd($details[$goodsSn]['total_price'], $details[$goodsSn]['post_fee'], 2);
|
|
|
+ $details[$goodsSn]['supplier_name'] = $goodsInfo['supplier_name'];
|
|
|
+
|
|
|
+ $goodsName = isset($goodsInfo['goods_name']) ? $goodsInfo['goods_name'] : '';
|
|
|
+ $goodsName = $goodsName ? str_replace(' ', '', $goodsName) : '';
|
|
|
+ $goodsName = mb_strlen($goodsName, 'utf-8') > 20 ? mb_substr($goodsName, 0, 19, 'utf-8') : $goodsName;
|
|
|
+ $goodsType = isset($goodsInfo['goods_type']) ? $goodsInfo['goods_type'] : 0;
|
|
|
+ if ($goodsType == 5) {
|
|
|
+ $price = getXzPirceWithPrice($curXzmoney, $price);
|
|
|
+ $totalFee = getXzPirceWithPrice($curXzmoney, $totalFee);
|
|
|
+ }
|
|
|
+ $goods = [
|
|
|
+ 'goods_sn' => $goodsInfo['goods_sn'],
|
|
|
+ 'goods_id' => $goodsInfo['goods_id'],
|
|
|
+ 'goods_type' => $goodsType,
|
|
|
+ 'goods_name' => $goodsName,
|
|
|
+ 'picture' => $goodsSpec['picture'] ?: $goodsInfo['goods_img'],
|
|
|
+ 'num' => $num, //数量
|
|
|
+ 'price' => $price,//单价
|
|
|
+ 'weight' => $goodsSpec['weight'], //重量
|
|
|
+ 'total_fee' => $totalFee, //总价
|
|
|
+ 'rebate_score' => $goodsSpec['rebate_score'],//单个返利积分
|
|
|
+ 'total_items_rebate_score' => $rebateScore,//总返利积分
|
|
|
+ 'spec_ids' => $goodsSpec['spec_ids'],
|
|
|
+ 'spec_text' => $goodsSpec['spec_text'],
|
|
|
+ 'post_template_id' => $goodsInfo['post_template_id'], //是否包邮，否就是运费模板ID
|
|
|
+ 'stock' => $goodsSpec['stock'],
|
|
|
+ 'supplier_name' => $goodsInfo['supplier_name']
|
|
|
+ ];
|
|
|
+
|
|
|
+ // 参数合计
|
|
|
+ $totalNum += $num;
|
|
|
+ $paymentTotal += bcadd($totalFee, $postFee, 3);
|
|
|
+ $totalRebateScore = bcadd($totalRebateScore, $rebateScore, 3);
|
|
|
+ $details[$goodsSn]['goods'][] = $goods;
|
|
|
+
|
|
|
+ }
|
|
|
+
|
|
|
+ $total = [
|
|
|
+ 'count_payment' => sprintf("%.2f", $paymentTotal),
|
|
|
+ 'count_rebate_score' => $totalRebateScore,
|
|
|
+ 'count_num' => $totalNum,
|
|
|
+ ];
|
|
|
+
|
|
|
+ return ['address' => $address, 'buyDetail' => array_values($details), 'total' => $total];
|
|
|
+ }
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 取消订单
|
|
|
+ */
|
|
|
+ public function cancelOrder($data, $userId)
|
|
|
+ {
|
|
|
+ $nowTime = date('Y-m-d H:i:s', time());
|
|
|
+ $data = $this->model->where(['order_sn' => $data['order_sn'], 'user_id' => $userId])->field('order_id,status,order_sn')->findOrEmpty();
|
|
|
+ if (empty($data)) {
|
|
|
+ throw new Exception('参数错误');
|
|
|
+ }
|
|
|
+ if ($data['status'] != 0) {
|
|
|
+ throw new Exception('订单状态错误');
|
|
|
+ }
|
|
|
+
|
|
|
+ Db::startTrans();
|
|
|
+ if (!$this->model->where(['order_sn' => $data['order_sn']])->save(['status' => 3, 'updated_time' => $nowTime])) {
|
|
|
+ Db::rollback();
|
|
|
+ throw new Exception('取消失败');
|
|
|
+ }
|
|
|
+
|
|
|
+ // 恢复库存
|
|
|
+ $updateStock = $this->model->alias('a')->where(['a.order_sn' => $data['order_sn'], 'a.user_id' => $userId])
|
|
|
+ ->leftJoin('shop_order_goods og', 'og.order_id=a.order_id')
|
|
|
+ ->leftJoin('shop_goods_spec gs', 'gs.goods_spec_id=og.goods_spec_id')
|
|
|
+ ->leftJoin('shop_goods g', 'g.goods_id=og.goods_id')
|
|
|
+ ->update([
|
|
|
+ 'g.inventory'=> Db::raw('g.inventory + og.num'),
|
|
|
+ 'gs.stock'=> Db::raw('gs.stock + og.num'),
|
|
|
+ ]);
|
|
|
+ if (!$updateStock) {
|
|
|
+ Db::rollback();
|
|
|
+ throw new Exception('取消失败，库存处理错误');
|
|
|
+ }
|
|
|
+
|
|
|
+ Db::commit();
|
|
|
+ return true;
|
|
|
+ }
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 确定订单
|
|
|
+ */
|
|
|
+ public function receiveOrder($data, $userId)
|
|
|
+ {
|
|
|
+ $nowTime = date('Y-m-d H:i:s', time());
|
|
|
+ $data = $this->model->where(['order_sn' => $data['order_sn'], 'user_id' => $userId])->findOrEmpty()->toArray();
|
|
|
+ if (empty($data)) {
|
|
|
+ throw new Exception('参数错误');
|
|
|
+ }
|
|
|
+ if ($data['status'] != 2) {
|
|
|
+ throw new Exception('订单状态错误');
|
|
|
+ }
|
|
|
+
|
|
|
+ return $this->model->where(['order_sn' => $data['order_sn']])->save(['status' => 4, 'updated_time' => $nowTime]);
|
|
|
+ }
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 计算运费
|
|
|
+ * @param $address 用户地址
|
|
|
+ * @param $data 商品数据
|
|
|
+ * @param $express_template_id 模板ID
|
|
|
+ * 获取运费
|
|
|
+ */
|
|
|
+ public function postFee($address, $data, $express_template_id)
|
|
|
+ {
|
|
|
+ //获取运费模板
|
|
|
+ $expressDelivery = ExpressDeliveryService::make()->getDataByTemplate($express_template_id);
|
|
|
+ //获取运费模板列表
|
|
|
+ $expressDeliveryItems = ExpressShippingMethodService::make()->getListByTemplate($express_template_id);
|
|
|
+
|
|
|
+ $price_method_field = '';
|
|
|
+ switch ($expressDelivery['price_method']) {
|
|
|
+ case 1:
|
|
|
+ $price_method_field = $data['total_price']; //按金额
|
|
|
+ break;
|
|
|
+ case 2:
|
|
|
+ $price_method_field = $data['num']; //按件数
|
|
|
+ break;
|
|
|
+ case 3:
|
|
|
+ $price_method_field = $data['total_weight']; //按重量
|
|
|
+ break;
|
|
|
+ default:
|
|
|
+ break;
|
|
|
+ }
|
|
|
+
|
|
|
+ if ($expressDelivery['price_method'] == 1) {
|
|
|
+
|
|
|
+ //计算默认运费 【配送区域、免运费金额、达标时运费、未达标时运费；】
|
|
|
+ if ($price_method_field < $expressDelivery['default_free_price']) {
|
|
|
+ $default_postfee = $expressDelivery['default_fastandard_price'];
|
|
|
+ } else {
|
|
|
+ //达标时运费
|
|
|
+ $default_postfee = $expressDelivery['default_price'];
|
|
|
+ }
|
|
|
+
|
|
|
+ if (empty($expressDeliveryItems)) {
|
|
|
+ return $default_postfee;
|
|
|
+ }
|
|
|
+
|
|
|
+ //按指定地区计算邮费
|
|
|
+ foreach ($expressDeliveryItems as $k => $node) {
|
|
|
+ if (in_array($address, explode(',', $node['address_items_ids']))) {
|
|
|
+ //未达标运费
|
|
|
+ if ($price_method_field < $node['free_price']) {
|
|
|
+ return $node['fastandard_price'];
|
|
|
+ } else {
|
|
|
+ //达标时运费
|
|
|
+ return $node['price'];
|
|
|
+ }
|
|
|
+ } else {
|
|
|
+ return $default_postfee;
|
|
|
+ }
|
|
|
+ }
|
|
|
+ } else {
|
|
|
+ //按件数 重量计费 【配送区域、首件、达标时运费、续件、未达标时运费】
|
|
|
+ //计算默认运费
|
|
|
+ if ($price_method_field <= $expressDelivery['default_pieces']) {
|
|
|
+ $default_postfee = $expressDelivery['default_price'];
|
|
|
+ } else {
|
|
|
+ //达到续件条件时的运费
|
|
|
+ if ($expressDelivery['add_pieces']) {
|
|
|
+ //配置过续件费用
|
|
|
+ //续件数 = (下单件数 - 首件) /续件数
|
|
|
+ //总运费 = 首件运费 + (续件数 * 续件费用)
|
|
|
+ $add_pieces = bcdiv(($price_method_field - $expressDelivery['default_pieces']), $expressDelivery['add_pieces'], 2);
|
|
|
+ $default_postfee = bcadd($expressDelivery['default_price'], bcmul($add_pieces, $expressDelivery['add_price'], 2), 2);
|
|
|
+ } else {
|
|
|
+ //未配置过续件，按首件价格
|
|
|
+ $default_postfee = $expressDelivery['default_price'];
|
|
|
+ }
|
|
|
+ }
|
|
|
+ if (empty($expressDeliveryItems)) {
|
|
|
+ return $default_postfee;
|
|
|
+ }
|
|
|
+ //按指定地区计算邮费
|
|
|
+ foreach ($expressDeliveryItems as $k => $node) {
|
|
|
+ if (in_array($address, explode(',', $node['address_items_ids']))) {
|
|
|
+ //未达到续件条件时的运费
|
|
|
+ if ($price_method_field <= $node['pieces']) {
|
|
|
+ return $node['price'];
|
|
|
+ } else {
|
|
|
+ //达到续件条件时的运费
|
|
|
+ if ($node['add_pieces']) {
|
|
|
+ //配置过续件费用
|
|
|
+ //续件数 = (下单件数 - 首件) /续件数
|
|
|
+ //总运费 = 首件运费 + (续件数 * 续件费用)
|
|
|
+ $add_pieces = bcdiv(($price_method_field - $node['pieces']), $node['add_pieces'], 2);
|
|
|
+ return bcadd($node['price'], bcmul($add_pieces, $node['add_price'], 2), 2);
|
|
|
+ } else {
|
|
|
+ //未配置过续件，按首件价格
|
|
|
+ return $node['price'];
|
|
|
+ }
|
|
|
+ }
|
|
|
+ } else {
|
|
|
+ return $default_postfee;
|
|
|
+ }
|
|
|
+ }
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 验证商品库存
|
|
|
+ * @param $data
|
|
|
+ * @return bool
|
|
|
+ */
|
|
|
+ public function checkStock($data)
|
|
|
+ {
|
|
|
+ foreach ($data as $key => $value) {
|
|
|
+ $num = array_sum(array_column($value, 'num'));
|
|
|
+ $goodsSn = isset($value[0]['goods_sn']) ? $value[0]['goods_sn'] : 0;
|
|
|
+ $specId = isset($value[0]['spec_id']) ? $value[0]['spec_id'] : 0;
|
|
|
+ if ($goodsSn && $specId && $num > 0) {
|
|
|
+ $stock = ShopGoodsSpecService::make()->getStock($goodsSn, $specId);
|
|
|
+ if ($num > $stock) {
|
|
|
+ return false;
|
|
|
+ }
|
|
|
+ } else {
|
|
|
+ return false;
|
|
|
+ }
|
|
|
+
|
|
|
+ }
|
|
|
+
|
|
|
+ return true;
|
|
|
+ }
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 2小时内未付款订单数
|
|
|
+ * @param $uid
|
|
|
+ * @param int $orderType
|
|
|
+ * @param int $status
|
|
|
+ * @return array|int|mixed
|
|
|
+ * @throws \think\db\exception\DbException
|
|
|
+ */
|
|
|
+ public function checkBuyCountByTime($uid, $orderType = 1, $status = 0)
|
|
|
+ {
|
|
|
+ $cacheKey = "caches:orders:unpayCount:{$uid}_{$orderType}_{$status}";
|
|
|
+ $data = RedisCache::get($cacheKey);
|
|
|
+ if ($data) {
|
|
|
+ return $data;
|
|
|
+ }
|
|
|
+
|
|
|
+ $data = $this->model->where(['user_id' => $uid, 'order_type' => $orderType, 'status' => $status])
|
|
|
+ ->whereTime('created_time', '-2 hours')
|
|
|
+ ->count('order_id');
|
|
|
+ if ($data) {
|
|
|
+ RedisCache::set($cacheKey, $data, rand(3, 5));
|
|
|
+ }
|
|
|
+
|
|
|
+ return $data;
|
|
|
+ }
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 根据单号获取订单信息（有缓存）
|
|
|
+ * @param $orderSn 订单号
|
|
|
+ * @param int $uid 所属用户ID
|
|
|
+ * @param int $status 状态
|
|
|
+ * @param string $field 返沪字段
|
|
|
+ * @param bool $cache 是否缓存，默认是
|
|
|
+ * @return array|mixed
|
|
|
+ */
|
|
|
+ public function getInfoBySn($orderSn, $uid=0, $status=0, $field='', $cache=false)
|
|
|
+ {
|
|
|
+ $cacheKey = "caches:orders:info:sn{$orderSn}_{$uid}".($field? '_'.md5($field):'');
|
|
|
+ $data = RedisCache::get($cacheKey);
|
|
|
+ if($data && $cache){
|
|
|
+ return $data;
|
|
|
+ }
|
|
|
+ $where = ['order_sn'=> $orderSn];
|
|
|
+ if($uid>0){
|
|
|
+ $where['user_id'] = $uid;
|
|
|
+ }
|
|
|
+
|
|
|
+ if($status>0){
|
|
|
+ $where['status'] = $status;
|
|
|
+ }
|
|
|
+
|
|
|
+ $field = $field? $field : 'order_id,order_sn,user_id,payment,total_price,status,pay_type,rebate_score,rebate_money,num,order_type,give_vip';
|
|
|
+ $data = $this->model->where($where)->field($field)->findOrEmpty();
|
|
|
+ $data = $data? $data->toArray() : [];
|
|
|
+ if($data && $cache){
|
|
|
+ RedisCache::set($cacheKey, $data, rand(5,10));
|
|
|
+ }
|
|
|
+
|
|
|
+ return $data;
|
|
|
+ }
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 根据单号获取订单信息（有缓存）
|
|
|
+ * @param $orderSn 订单号
|
|
|
+ * @param int $uid 所属用户ID
|
|
|
+ * @param string $field 返沪字段
|
|
|
+ * @param bool $cache 是否缓存，默认是
|
|
|
+ * @return array|mixed
|
|
|
+ */
|
|
|
+ public function getInfoById($orderId, $uid=0, $field='', $cache=true)
|
|
|
+ {
|
|
|
+ $cacheKey = "caches:orders:info:id{$orderId}_{$uid}".($field? '_'.md5($field):'');
|
|
|
+ $data = RedisCache::get($cacheKey);
|
|
|
+ if($data && $cache){
|
|
|
+ return $data;
|
|
|
+ }
|
|
|
+ $where = ['order_id'=> $orderId,'user_id'=> 0,'status'=>1];
|
|
|
+ if($uid>0){
|
|
|
+ $where['user_id'] = $uid;
|
|
|
+ }else{
|
|
|
+ unset($where['user_id']);
|
|
|
+ }
|
|
|
+
|
|
|
+ $field = $field? $field : 'order_id,order_sn,user_id,payment,total_price,status,pay_type,rebate_score,rebate_money,num,order_type,give_vip,coupon_number,hg_status,hg_enable';
|
|
|
+ $data = $this->model->where($where)->field($field)->findOrEmpty();
|
|
|
+ $data = $data? $data->toArray() : [];
|
|
|
+ if($data && $cache){
|
|
|
+ RedisCache::set($cacheKey, $data, rand(5,10));
|
|
|
+ }
|
|
|
+
|
|
|
+ return $data;
|
|
|
+ }
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 订单列表
|
|
|
+ */
|
|
|
+ public function getList ($params, $pageSize, $field = '')
|
|
|
+ {
|
|
|
+ $page = request()->post('page', 1);
|
|
|
+ $userId = isset($params['user_id'])? $params['user_id'] : 0;
|
|
|
+ $cacheKey = "caches:orders:list:{$userId}_{$page}_{$pageSize}".($field? '_'.md5($field):'');
|
|
|
+ $data = RedisCache::get($cacheKey);
|
|
|
+ if($data){
|
|
|
+ return $data;
|
|
|
+ }
|
|
|
+
|
|
|
+
|
|
|
+ $where['user_id'] = $userId;
|
|
|
+ $status = isset($params['status'])? $params['status'] : '-1';
|
|
|
+ if($status>=0){
|
|
|
+ $where['status'] = $status;
|
|
|
+ }
|
|
|
+ $orderType = isset($params['order_type'])? $params['order_type'] : 0;
|
|
|
+ if($orderType){
|
|
|
+ $where['order_type'] = $orderType;
|
|
|
+ }
|
|
|
+ $field = $field? $field:'order_id,status,order_sn,order_type,coupon_number,created_time,order_remark,payment,ship_postfee,rebate_score,ship_name,ship_code,ship_number,expires_time,rebate_lock_score';
|
|
|
+ $data = $this->model->where($where)
|
|
|
+ ->whereNotIn('status', [3])
|
|
|
+ ->relation(['withOrderGoods'])
|
|
|
+ ->field($field)
|
|
|
+ ->order('order_id desc')
|
|
|
+ ->paginate($pageSize)
|
|
|
+ ->each(function($v, $k){
|
|
|
+ foreach ($v['withOrderGoods'] as $key=>$val){
|
|
|
+ $goods_sn = ShopGoods::where('goods_id', $val['goods_id'])->value('goods_sn');
|
|
|
+ $v['withOrderGoods'][$key]['goods_sn'] = $goods_sn;
|
|
|
+ }
|
|
|
+
|
|
|
+ $v['withOrderShipping'] = ShopOrderShippingService::make()->getInfo($v['order_id']);
|
|
|
+ $v['withOrderExpress'] = ExpressServices::instance()->orderId($v['order_id'])
|
|
|
+ ->code($v['ship_code'])
|
|
|
+ ->number($v['ship_number'])
|
|
|
+ ->find();
|
|
|
+
|
|
|
+ if (intval($v['status']) == 2){
|
|
|
+ $v['express_url'] = "https://m.kuaidi100.com/result.jsp?nu=".$v['ship_number'];
|
|
|
+ }else{
|
|
|
+ $v['express_url'] = "";
|
|
|
+ }
|
|
|
+
|
|
|
+ if ($v['status'] == 1){
|
|
|
+ if ($v['order_type'] == 1){
|
|
|
+ $v['can_hg'] = 1;
|
|
|
+ }
|
|
|
+ }else{
|
|
|
+ $v['can_hg'] = 2;
|
|
|
+ }
|
|
|
+
|
|
|
+ switch ($v['status']){
|
|
|
+ case 0:
|
|
|
+ $v['status_title'] = '待付款';
|
|
|
+ break;
|
|
|
+ case 1:
|
|
|
+ $v['status_title'] = '待发货';
|
|
|
+ break;
|
|
|
+ case 2:
|
|
|
+ $v['status_title'] = '已发货';
|
|
|
+ break;
|
|
|
+ case 3:
|
|
|
+ $v['status_title'] = '已过期';
|
|
|
+ break;
|
|
|
+ case 4:
|
|
|
+ $v['status_title'] = '已完成';
|
|
|
+ break;
|
|
|
+ case 5:
|
|
|
+ $v['status_title'] = '已完成';
|
|
|
+ break;
|
|
|
+ case 6:
|
|
|
+ $v['status_title'] = '已完成';
|
|
|
+ break;
|
|
|
+ }
|
|
|
+ });
|
|
|
+
|
|
|
+ $data = $data? $data->toArray() : [];
|
|
|
+ if($data['data']){
|
|
|
+ RedisCache::set($cacheKey, $data['data'], rand(2,3));
|
|
|
+ }
|
|
|
+ return $data['data'];
|
|
|
+ }
|
|
|
+}
|
