You can not select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
379 lines
15 KiB
379 lines
15 KiB
<?php
|
|
|
|
namespace App\Service\v3\Implementations;
|
|
|
|
use App\Commons\Log;
|
|
use App\Constants\v3\ErrorCode;
|
|
use App\Constants\v3\LogLabel;
|
|
use App\Constants\v3\OrderState;
|
|
use App\Constants\v3\OrderType;
|
|
use App\Exception\ErrorCodeException;
|
|
use App\Model\v3\Coupon;
|
|
use App\Model\v3\CouponRec;
|
|
use App\Model\v3\CouponUse;
|
|
use App\Model\v3\Goods;
|
|
use App\Model\v3\GoodsActivity;
|
|
use App\Model\v3\Order;
|
|
use App\Model\v3\OrderGoods;
|
|
use App\Model\v3\OrderMain;
|
|
use App\Model\v3\ShoppingCart;
|
|
use App\Model\v3\Store;
|
|
use App\Model\v3\UserAddress;
|
|
use App\Service\v3\Interfaces\CouponRecServiceInterface;
|
|
use App\Service\v3\Interfaces\CouponServiceInterface;
|
|
use App\Service\v3\Interfaces\DeliveryMoneyServiceInterface;
|
|
use App\Service\v3\Interfaces\GoodsActivityServiceInterface;
|
|
use App\Service\v3\Interfaces\GoodsServiceInterface;
|
|
use App\Service\v3\Interfaces\PaymentServiceInterface;
|
|
use Hyperf\DbConnection\Db;
|
|
use Hyperf\Di\Annotation\Inject;
|
|
use App\Service\v3\Interfaces\OrderOnlineServiceInterface;
|
|
use Hyperf\Snowflake\IdGeneratorInterface;
|
|
use Hyperf\Utils\ApplicationContext;
|
|
|
|
class OrderOnlineService implements OrderOnlineServiceInterface
|
|
{
|
|
|
|
/**
|
|
* @Inject
|
|
* @var Log
|
|
*/
|
|
protected $log;
|
|
|
|
/**
|
|
* @Inject
|
|
* @var DeliveryMoneyServiceInterface
|
|
*/
|
|
protected $deliveryService;
|
|
|
|
/**
|
|
* @Inject
|
|
* @var CouponRecServiceInterface
|
|
*/
|
|
protected $couponRecService;
|
|
|
|
/**
|
|
* @Inject
|
|
* @var CouponServiceInterface
|
|
*/
|
|
protected $couponService;
|
|
|
|
/**
|
|
* @Inject
|
|
* @var GoodsActivityServiceInterface
|
|
*/
|
|
protected $goodsActivityService;
|
|
|
|
/**
|
|
* @Inject
|
|
* @var GoodsServiceInterface
|
|
*/
|
|
protected $goodsService;
|
|
|
|
/**
|
|
* @Inject
|
|
* @var PaymentServiceInterface
|
|
*/
|
|
protected $paymentService;
|
|
|
|
/**
|
|
* 下单
|
|
* @param $marketId
|
|
* @param $userId
|
|
* @param $userAddrId
|
|
* @param $storeList
|
|
* @param $totalMoney
|
|
* @param string $deliveryTimeNote
|
|
* @param int $serviceMoney
|
|
* @param null $receiveCouponIds
|
|
* @param string $plat
|
|
* @return array[]
|
|
*/
|
|
public function do($marketId, $userId, $userAddrId, $storeList, $totalMoney, $deliveryTimeNote='尽快送达', $serviceMoney=0, $receiveCouponIds=null, $plat=''){
|
|
|
|
Db::beginTransaction();
|
|
try {
|
|
|
|
$currentTime = time();
|
|
bcscale(6);
|
|
// 用户收货地址
|
|
$userAddr = UserAddress::query()->find($userAddrId);
|
|
// 获取配送费用
|
|
$deliveryAmount = $this->deliveryService->do($userAddr->lat, $userAddr->lng);
|
|
|
|
// 处理购物车数据，计算订单金额、子订单数据处理等
|
|
$totalAmount = 0; # 实付金额
|
|
$orderAmount = 0; # 订单金额
|
|
$dataMain = []; # 主订单
|
|
$dataChildren = []; # 子订单
|
|
$dataOrderGoods = []; # 订单商品
|
|
$storeTypeIds = []; # 订单中的商户类型，用于校验红包
|
|
|
|
foreach ($storeList as $key => &$storeItem) {
|
|
|
|
$storeId = $storeItem->store_id;
|
|
|
|
// 子订单金额
|
|
$subAmount = 0;
|
|
|
|
// 店铺分类
|
|
$storeType = Store::query()->where(['id' => $storeId])->value('category_id');
|
|
$storeTypeIds[] = (string)$storeType;
|
|
// 店铺今天的订单数
|
|
$count = Order::query()
|
|
->where(['store_id' => $storeId])
|
|
->whereBetween('created_at', [strtotime(date('Y-m-d 00:00:00')), strtotime(date('Y-m-d 23:59:59'))])
|
|
->count();
|
|
|
|
// 用户购物车数据
|
|
$cartIds = explode(',', $storeItem->cart_ids);
|
|
$carts = ShoppingCart::query()->whereIn('id', $cartIds)->where(['market_id' => $marketId])->get();
|
|
foreach ($carts as $k => &$cart) {
|
|
|
|
// 查个商品
|
|
$goods = [];
|
|
if ($cart->activity_type == 1) {
|
|
$goods = Goods::query()->lockForUpdate()->find($cart->goods_id);
|
|
$check = $this->goodsService->check($goods->id, $cart->num);
|
|
if (true !== $check) {
|
|
throw new ErrorCodeException($check, '[商品失效]'.$cart->goods_id);
|
|
}
|
|
} elseif ($cart->activity_type == 2) {
|
|
$goods = GoodsActivity::query()->lockForUpdate()->find($cart->goods_id);
|
|
$check = $this->goodsActivityService->check($goods->id, $cart->num, $userId);
|
|
if (true !== $check) {
|
|
throw new ErrorCodeException($check, '[商品失效]'.$cart->goods_id);
|
|
}
|
|
|
|
if ($goods->can_use_coupon!=1 && $receiveCouponIds) {
|
|
throw new ErrorCodeException(ErrorCode::GOODS_ACTIVITY_CANNOT_USE_COUPON, '[商品失效]'.$cart->goods_id);
|
|
}
|
|
}
|
|
|
|
if (empty($goods)) {
|
|
throw new ErrorCodeException(ErrorCode::ORDER_GOODS_NOT_AVAILABLE);
|
|
}
|
|
|
|
// 库存判断
|
|
if ($goods->is_infinite !=1 && $goods->inventory < $cart->num) {
|
|
throw new ErrorCodeException(ErrorCode::ORDER_GOODS_INVENTORY_LIMIT);
|
|
}
|
|
|
|
// 算金额
|
|
$goodsAmount = bcmul((string)$goods->price, (string)$cart->num); # 当前商品的金额
|
|
$subAmount = bcadd((string)$subAmount, (string)$goodsAmount); # 当前店铺子订单的金额
|
|
|
|
// 订单商品数据
|
|
$dataOrderGoods[$storeId][] = [
|
|
'order_id' => 0,
|
|
'goods_id' => $cart->goods_id,
|
|
'activity_type' => $cart->activity_type,
|
|
'number' => $cart->num,
|
|
'price' => $goods->price,
|
|
'original_price' => $goods->original_price,
|
|
'vip_price' => $goods->vip_price,
|
|
'name' => $goods->name,
|
|
'goods_unit' => $goods->goods_unit,
|
|
'cover_img' => $goods->cover_img,
|
|
'spec' => $goods->spec,
|
|
];
|
|
}
|
|
|
|
// 子订单数据
|
|
$dataChildren[] = [
|
|
'order_main_id' => 0,
|
|
'user_id' => $userId,
|
|
'store_id' => $storeId,
|
|
'money' => bcadd((string)$subAmount, '0', 2),
|
|
'oid' => $count + 1,
|
|
'order_num' => date('YmdHis').mt_rand(1000, 9999),
|
|
'note' => $storeItem->note
|
|
];
|
|
|
|
// 订单金额
|
|
$orderAmount = bcadd((string)$orderAmount, (string)$subAmount);
|
|
}
|
|
|
|
// 优惠券的使用
|
|
$couponMoney = 0;
|
|
// 优惠券数据
|
|
$couponRec = CouponRec::query()->lockForUpdate()->whereIn('id', $receiveCouponIds)->get()->toArray();
|
|
if (!empty($couponRec)) {
|
|
$couponsCanUse = $this->couponRecService->allForOrderOlAvailable($totalAmount, $userId, $marketId, 2, $storeTypeIds);
|
|
$couponCanUseIds = array_column($couponsCanUse, 'id');
|
|
$couponCanUseIds = array_intersect($couponCanUseIds, $receiveCouponIds);
|
|
$couponCannotUseIds = array_diff($receiveCouponIds, $couponCanUseIds);
|
|
|
|
if (empty($couponCanUseIds)||!empty($couponCannotUseIds)) {
|
|
throw new ErrorCodeException(ErrorCode::COUPON_NOT_AVAILABLE);
|
|
}
|
|
|
|
// 计算红包折扣金额
|
|
foreach ($couponsCanUse as $key => $coupon) {
|
|
if (!in_array($coupon->id, $receiveCouponIds)) {
|
|
continue;
|
|
}
|
|
|
|
if ($coupon->discount_type == Coupon::DISCOUNT_TYPE_CASH) {
|
|
$couponMoney = bcadd($couponMoney, $coupon->discounts, 2);
|
|
} elseif ($coupon->discount_type == Coupon::DISCOUNT_TYPE_RATE) {
|
|
$discountRate = bcdiv($coupon->discounts,10);
|
|
$discountRate = bcsub(1,$discountRate);
|
|
$discountMoney = bcmul($orderAmount, $discountRate);
|
|
$couponMoney = bcadd($couponMoney, $discountMoney, 2);
|
|
}
|
|
}
|
|
}
|
|
|
|
// 获取分布式全局ID
|
|
$generator = ApplicationContext::getContainer()->get(IdGeneratorInterface::class);
|
|
$globalOrderId = $generator->generate();
|
|
|
|
$orderAmount = bcadd((string)$orderAmount, '0', 2);
|
|
$totalAmount = bcadd((string)$totalAmount, (string)$orderAmount);
|
|
$totalAmount = bcadd((string)$totalAmount, (string)$deliveryAmount);
|
|
$totalAmount = bcadd((string)$totalAmount, (string)$serviceMoney);
|
|
$totalAmount = bcsub((string)$totalAmount, (string)$couponMoney, 2);
|
|
|
|
// 校验订单总金额
|
|
if ($totalAmount != $totalMoney) {
|
|
throw new ErrorCodeException(ErrorCode::ORDER_TOTAL_AMOUNT_ERROR);
|
|
}
|
|
|
|
$dataMain = [
|
|
'market_id' => $marketId,
|
|
'order_num' => $globalOrderId,
|
|
'global_order_id' => $globalOrderId,
|
|
'user_id' => $userId,
|
|
'type' => OrderType::ONLINE,
|
|
'money' => $totalAmount,
|
|
'total_money' => $orderAmount,
|
|
'services_money' => $serviceMoney,
|
|
'coupon_money' => $couponMoney,
|
|
'delivery_money' => $deliveryAmount,
|
|
'state' => OrderState::UNPAID,
|
|
'tel' => $userAddr->tel,
|
|
'address' => $userAddr->address.$userAddr->doorplate,
|
|
'lat' => $userAddr->lat,
|
|
'lng' => $userAddr->lng,
|
|
'name' => $userAddr->user_name,
|
|
'plat' => $plat,
|
|
'delivery_time_note' => $deliveryTimeNote
|
|
];
|
|
|
|
// 生成主订单
|
|
$orderMain = OrderMain::query()->create($dataMain);
|
|
$orderMainId = $orderMain->id;
|
|
|
|
// 处理子订单
|
|
foreach ($dataChildren as $key => &$child) {
|
|
$child['order_main_id'] = $orderMainId;
|
|
$orderChild = Order::query()->create($child);
|
|
$orderChildId = $orderChild->id;
|
|
|
|
foreach ($dataOrderGoods[$child['store_id']] as $k => &$orderGoods) {
|
|
$orderGoods['order_id'] = $orderChildId;
|
|
$orderGoods['created_at'] = $currentTime;
|
|
$orderGoods['updated_at'] = $currentTime;
|
|
}
|
|
OrderGoods::query()->insert($dataOrderGoods[$child['store_id']]);
|
|
}
|
|
|
|
// 判断是否有购买多个特价商品
|
|
$check = $this->goodsActivityService->checkOrderActivityCount($dataOrderGoods);
|
|
if(!$check){
|
|
throw new ErrorCodeException(ErrorCode::GOODS_ACTIVITY_RESTRICT_LIMIT, '[同一订单同种类型活动商品]'.json_encode($dataOrderGoods));
|
|
}
|
|
|
|
// 订单成功，做一些处理
|
|
// 活动商品购买记录
|
|
foreach ($dataOrderGoods as $key => &$goods) {
|
|
foreach ($goods as $k => &$goodsItem)
|
|
if ($goodsItem['activity_type'] == 2) {
|
|
$this->goodsActivityService->cacheRecord($goodsItem['goods_id'], $goodsItem['number'], $userId);
|
|
}
|
|
}
|
|
|
|
// 优惠券红包使用记录
|
|
if (is_array($couponRec)&&!empty($couponRec)) {
|
|
# 使用记录、更新当前优惠券
|
|
foreach ($couponRec as $key => &$coupon) {
|
|
|
|
$couponUse = [
|
|
'user_id' => $coupon['user_id'],
|
|
'user_receive_id' => $coupon['id'],
|
|
'coupon_id' => $coupon['coupon_id'],
|
|
'order_main_id' => $orderMainId,
|
|
'use_time' => $currentTime,
|
|
'return_time' => 0,
|
|
'number' => 1,
|
|
'status' => 1,
|
|
'update_time' => 0,
|
|
];
|
|
|
|
$insertRes = CouponUse::query()->insert($couponUse);
|
|
if ($insertRes) {
|
|
$numberRemain = $coupon['number_remain'] - 1;
|
|
if ($numberRemain == 0) {
|
|
$status = 2;
|
|
} elseif ($numberRemain > 0 && $numberRemain < $coupon['number']) {
|
|
$status = 1;
|
|
} elseif ($numberRemain == $coupon['number']) {
|
|
$status = 0;
|
|
}
|
|
|
|
$upRes = CouponRec::query()->where(['id' => $coupon['id']])->update(['number_remain' => $numberRemain, 'status' => $status]);
|
|
if (!$upRes) {
|
|
Db::rollBack();
|
|
throw new ErrorCodeException(ErrorCode::COUPON_USE_FAILURE);
|
|
}
|
|
// 缓存使用记录
|
|
$usedRes = $this->couponService->cacheTodayCouponUsed($coupon['user_id'], $coupon['coupon_id'], $coupon['id']);
|
|
if (!$usedRes) {
|
|
Db::rollBack();
|
|
throw new ErrorCodeException(ErrorCode::COUPON_USE_FAILURE);
|
|
}
|
|
} else {
|
|
Db::rollBack();
|
|
throw new ErrorCodeException(ErrorCode::COUPON_USE_FAILURE);
|
|
}
|
|
|
|
}
|
|
}
|
|
|
|
Db::commit();
|
|
|
|
// 支付
|
|
return $this->paymentService->do($globalOrderId, $totalAmount, $userId, config('site_host') . '/wechat/notify/wxminionline');
|
|
} catch (\Exception $e) {
|
|
Db::rollBack();
|
|
$this->log->event(LogLabel::ORDER_ONLINE_LOG, ['exception_msg' => $e->getMessage()]);
|
|
throw new ErrorCodeException(ErrorCode::ORDER_ONLINE_FAIL);
|
|
}
|
|
}
|
|
|
|
public function check()
|
|
{
|
|
// TODO: Implement check() method.
|
|
}
|
|
|
|
public function undo()
|
|
{
|
|
// TODO: Implement undo() method.
|
|
}
|
|
|
|
public function detailByUser($orderMainId, $userId)
|
|
{
|
|
|
|
$orderMain = OrderMain::with(['market'])->find($orderMainId);
|
|
$orders = Order::query()
|
|
->where(['order_main_id' => $orderMainId, 'user_id' => $userId])
|
|
->with([
|
|
'orderGoods',
|
|
'store'
|
|
])
|
|
->get()->toArray();
|
|
|
|
return ['order_main' => $orderMain, 'orders' => $orders];
|
|
}
|
|
}
|