370 lines
12 KiB
PHP
370 lines
12 KiB
PHP
<?php
|
|
|
|
namespace App\Services\Dealer;
|
|
|
|
use App\Enums\DealerLvl;
|
|
use App\Enums\DealerOrderStatus;
|
|
use App\Exceptions\BizException;
|
|
use App\Models\DealerOrder;
|
|
use App\Models\DealerOrderAllocateLog;
|
|
use App\Models\DealerProduct;
|
|
use App\Models\DealerUserProductLog;
|
|
use App\Models\ShippingAddress;
|
|
use App\Models\User;
|
|
use App\Models\UserInfo;
|
|
use Illuminate\Database\QueryException;
|
|
|
|
class OrderService
|
|
{
|
|
/**
|
|
* 计算订单价格
|
|
*
|
|
* @param DealerProduct $product
|
|
* @param integer $number
|
|
* @return string
|
|
*/
|
|
public function totalAmount(User $user, DealerProduct $product, int $number = 0)
|
|
{
|
|
//获取等级规则，判断当前用户等级是否配置等级价格
|
|
$salePrice = $product->price;
|
|
if ($user->dealer) {
|
|
foreach ($product->lvlRules as $rule) {
|
|
if ($rule->lvl == $user->dealer->lvl->value) {
|
|
$salePrice = $rule->sale_price;
|
|
break;
|
|
}
|
|
}
|
|
}
|
|
//获取销售规则，判断当前用户购买数量价格
|
|
foreach ($product->saleRules as $rule) {
|
|
if ($number >= $rule->qty) {
|
|
if ($salePrice > $rule->price) {
|
|
$salePrice = $rule->price;
|
|
}
|
|
break;
|
|
}
|
|
}
|
|
// dd($salePrice, $number);
|
|
|
|
return bcmul($salePrice, $number, 2);
|
|
}
|
|
|
|
/**
|
|
* 创建订单
|
|
*
|
|
* @param User $user
|
|
* @param DealerProduct $product
|
|
* @param integer $number
|
|
* @param integer $shippingAddressId
|
|
* @return DealerOrder $order
|
|
*/
|
|
public function createOrder(User $user, DealerProduct $product, int $number = 0, int $shippingAddressId)
|
|
{
|
|
//判断是否满足当前等级最低补货价
|
|
$totalAmount = $this->totalAmount($user, $product, $number);
|
|
foreach ($product->lvlRules as $rule) {
|
|
if ($user->dealer && $rule->lvl == $user->dealer->lvl->value && $totalAmount < $rule->min_order_amount) {
|
|
throw new BizException('当前单次补货价格不能低于'.$rule->min_order_amount.'元');
|
|
}
|
|
}
|
|
|
|
//找到发货人
|
|
$consignor = $this->getConsignor($user, $totalAmount);
|
|
|
|
//找到收货地址
|
|
$shippingAddress = $this->getShippingAddress($user, $shippingAddressId);
|
|
|
|
//保存订单
|
|
$order = new DealerOrder();
|
|
do {
|
|
try {
|
|
$order->sn = serial_number();
|
|
$order->user_id = $user->id;
|
|
$order->consignor_id = $consignor?->user_id;
|
|
$order->total_amount = $totalAmount;
|
|
$order->consignee_name = $shippingAddress->consignee;
|
|
$order->consignee_telephone = $shippingAddress->telephone;
|
|
$order->consignee_zone = $shippingAddress->zone;
|
|
$order->consignee_address = $shippingAddress->address;
|
|
$order->allocated_at = now();//记录分配时间
|
|
$order->save();
|
|
break;
|
|
} catch (QueryException $e) {
|
|
if (strpos($e->getMessage(), 'Duplicate entry') === false) {
|
|
throw $e;
|
|
}
|
|
}
|
|
} while (true);
|
|
|
|
//保存订单商品-----一个订单对应一个商品
|
|
$order->products()->create([
|
|
'order_id' => $order->id,
|
|
'product_id'=> $product->id,
|
|
'name'=> $product->name,
|
|
'subtitle'=> $product->subtitle,
|
|
'cover'=> $product->cover,
|
|
'price' => $product->price,
|
|
'sale_price'=> bcdiv($totalAmount, $number, 2),
|
|
'qty'=> $number,
|
|
]);
|
|
|
|
if (!$order->consignor) {//如果订单分配给公司，则直接确认
|
|
$this->confirmOrder($order);
|
|
}
|
|
|
|
return $order;
|
|
}
|
|
|
|
/**
|
|
* 确认接单
|
|
*
|
|
* @param DealerOrder $order
|
|
* @return void
|
|
*/
|
|
public function confirmOrder(DealerOrder $order)
|
|
{
|
|
if (!$order->isPending()) {
|
|
throw new BizException('订单状态异常，请刷新后再试');
|
|
}
|
|
$order->update([
|
|
'status' => DealerOrderStatus::Paying,
|
|
]);
|
|
}
|
|
|
|
/**
|
|
* 确认打款
|
|
*
|
|
* @return void
|
|
*/
|
|
public function payOrder(DealerOrder $order, string $payImage)
|
|
{
|
|
if (!$order->isPendinged()) {
|
|
throw new BizException('订单状态异常，请刷新后再试');
|
|
}
|
|
$order->update([
|
|
'status' => DealerOrderStatus::Confirming,
|
|
'pay_image' => $payImage,
|
|
'pay_info' => $order->getConsignorPayInfo()??null,
|
|
'pay_time' => now(),
|
|
]);
|
|
}
|
|
|
|
/**
|
|
* 确认收款
|
|
*
|
|
* @param DealerOrder $order
|
|
* @return void
|
|
*/
|
|
public function paidOrder(DealerOrder $order)
|
|
{
|
|
if (!$order->isPay()) {
|
|
throw new BizException('订单状态异常，请刷新后再试');
|
|
}
|
|
$order->update([
|
|
'status' => DealerOrderStatus::Paid,
|
|
'paied_time' => now(),
|
|
]);
|
|
}
|
|
|
|
/**
|
|
* 确认发货
|
|
*
|
|
* @param DealerOrder $order
|
|
* @return void
|
|
*/
|
|
public function shippingOrder(DealerOrder $order)
|
|
{
|
|
if (!$order->isPaid()) {
|
|
throw new BizException('订单状态异常，请刷新后再试');
|
|
}
|
|
//扣减发货人库存
|
|
if ($order->consignor) {
|
|
$this->orderOutQty($order);
|
|
}
|
|
|
|
$order->update([
|
|
'status' => DealerOrderStatus::Shipped,
|
|
'shipping_time' => now(),
|
|
]);
|
|
}
|
|
|
|
public function shippingedOrder(DealerOrder $order)
|
|
{
|
|
if (!$order->isShipping()) {
|
|
throw new BizException('订单状态异常，请刷新后再试');
|
|
}
|
|
//增加自己的库存
|
|
$this->orderInQty($order);
|
|
|
|
$order->update([
|
|
'status' => DealerOrderStatus::Completed,
|
|
'shippinged_time' => now(),
|
|
]);
|
|
}
|
|
|
|
public function cancelOrder(DealerOrder $order)
|
|
{
|
|
if (!($order->isPending() || $order->isPendinged() || $order->isPay())) {
|
|
throw new BizException('订单状态异常，请刷新后再试');
|
|
}
|
|
$order->update([
|
|
'status' => DealerOrderStatus::Cancelled,
|
|
]);
|
|
}
|
|
|
|
/**
|
|
* 更新订单发货人
|
|
*
|
|
* @return void
|
|
*/
|
|
public function updateOrderConsignor(DealerOrder $order)
|
|
{
|
|
//只处理当前订单有发货人的情况
|
|
if ($order->consignor) {
|
|
$consignor = $this->getConsignor($order->user, $order->totalAmount, $order->consignor);
|
|
$oldConsignor = $order->consignor;
|
|
$order->update([
|
|
'allocated_at' => now(),
|
|
'consignor_id' => $consignor?->user_id,
|
|
]);
|
|
//记录分配日志
|
|
DealerOrderAllocateLog::create([
|
|
'order_id'=>$order->id,
|
|
'last_consignor_id'=>$oldConsignor->id,
|
|
'new_consignor_id' =>$order->consignor_id,
|
|
]);
|
|
}
|
|
}
|
|
|
|
/**
|
|
* 获取收货地址
|
|
*
|
|
* @param \App\Models\User $user
|
|
* @param int|null $shippingAddressId
|
|
* @return \App\Models\ShippingAddress|null
|
|
*
|
|
* @throws \Illuminate\Database\Eloquent\ModelNotFoundException
|
|
*/
|
|
protected function getShippingAddress(User $user, ?int $shippingAddressId = null): ?ShippingAddress
|
|
{
|
|
if ($shippingAddressId) {
|
|
return $user->shippingAddresses()->findOrFail($shippingAddressId);
|
|
}
|
|
|
|
return $user->shippingAddresses()->where('is_default', true)->first();
|
|
}
|
|
|
|
/**
|
|
* 用户通过下单新增库存
|
|
*
|
|
* @return void
|
|
*/
|
|
protected function orderInQty(DealerOrder $order)
|
|
{
|
|
foreach ($order->products as $product) {
|
|
$userProduct = $order->user->dealerProducts()->firstOrCreate([
|
|
'product_id'=> $product->product_id,
|
|
]);
|
|
$userProduct->increment('stock', $product->qty);
|
|
|
|
DealerUserProductLog::create([
|
|
'user_id'=> $order->user_id,
|
|
'product_id'=> $product->product_id,
|
|
'type' => DealerUserProductLog::TYPE_ORDER_IN,
|
|
'qty'=>$product->qty,
|
|
'remark'=>'订单：'.$order->sn,
|
|
]);
|
|
}
|
|
}
|
|
|
|
/**
|
|
* 用户通过订单扣减库存
|
|
*
|
|
* @return void
|
|
*/
|
|
protected function orderOutQty(DealerOrder $order)
|
|
{
|
|
foreach ($order->products as $product) {
|
|
$userProduct = $order->consignor->dealerProducts()->firstOrCreate([
|
|
'product_id'=> $product->product_id,
|
|
]);
|
|
$userProduct->decrement('stock', $product->qty);
|
|
|
|
DealerUserProductLog::create([
|
|
'user_id'=> $order->consignor_id,
|
|
'product_id'=> $product->product_id,
|
|
'type' => DealerUserProductLog::TYPE_ORDER_OUT,
|
|
'qty'=>$product->qty,
|
|
'remark' =>'订单：'.$order->sn,
|
|
]);
|
|
}
|
|
}
|
|
|
|
private function getConsignor(User $user, $totalAmount, ?User $lastConsignor = null)
|
|
{
|
|
$rules = [
|
|
[
|
|
'amount' => app_settings('dealer.upgrade_amount_'.DealerLvl::Contracted->value),
|
|
'lvl' => DealerLvl::Contracted,
|
|
],
|
|
[
|
|
'amount' => app_settings('dealer.upgrade_amount_'.DealerLvl::Special->value),
|
|
'lvl' => DealerLvl::Special,
|
|
],
|
|
[
|
|
'amount' => app_settings('dealer.upgrade_amount_'.DealerLvl::Gold->value),
|
|
'lvl' => DealerLvl::Gold,
|
|
],
|
|
];
|
|
$lvl = $user->dealer->lvl;
|
|
//计算通过这个订单可能升级成为的身份
|
|
foreach ($rules as $rule) {
|
|
if ($totalAmount >= $rule['amount'] && $lvl->value < $rule['lvl']->value) {
|
|
$lvl = $rule['lvl'];
|
|
}
|
|
}
|
|
//如果是签约单，直接抛到公司后台发货
|
|
if ($lvl->value >= DealerLvl::Contracted->value) {
|
|
return null;
|
|
}
|
|
// //老逻辑；
|
|
// $query = UserInfo::with('dealer');
|
|
// if ($lastConsignor) {
|
|
// $query->whereIn('user_id', $lastConsignor->userInfo->real_parent_ids);//上个发货人的上级
|
|
// } else {
|
|
// $query->whereIn('user_id', $user->userInfo->real_parent_ids);//自己的上级
|
|
// }
|
|
// $consignor = $query->whereHas('dealer', function ($q) use ($lvl) {
|
|
// return $q->where('is_sale', true)->where('lvl', '>', $lvl);//可销售的经销商，且身份大于自己的
|
|
// })->orderBy('depth', 'desc')->first();//深度逆序第一个
|
|
// if (!$consignor) {
|
|
// $consignor = $lastConsignor;
|
|
// }
|
|
//新逻辑
|
|
$consignor = null;
|
|
$_lastConsignor = $lastConsignor;
|
|
do {
|
|
$query = User::with(['userInfo', 'dealer']);
|
|
if ($_lastConsignor) {
|
|
$query->where('id', $_lastConsignor->userInfo->real_inviter_id);
|
|
} else {
|
|
$query->where('id', $user->userInfo->real_inviter_id);
|
|
}
|
|
$consignor = $query->first();
|
|
if ($consignor) {//找到老上级
|
|
if ($consignor->dealer->is_sale == true && $consignor->dealer->lvl->value > $lvl->value) {
|
|
break;
|
|
} else {
|
|
$_lastConsignor = $consignor;
|
|
$consignor = null;
|
|
}
|
|
} else {//如果找不到人了
|
|
$consignor = $lastConsignor;
|
|
break;
|
|
}
|
|
} while (empty($consignor));
|
|
|
|
return $consignor?->userInfo;
|
|
}
|
|
}
|