<?php
|
|
namespace app\common\service\product\factory;
|
|
use app\common\enum\product\DeductStockTypeEnum;
|
use app\common\model\plus\advance\AdvanceSku as AdvanceProductSkuModel;
|
use app\common\model\plus\advance\Product as AdvanceProductModel;
|
use app\common\model\product\Product as ProductModel;
|
use app\common\model\product\ProductSku as ProductSkuModel;
|
|
/**
|
* 商品来源-普通商品扩展类
|
*/
|
class AdvanceProductService extends ProductService
|
{
|
/**
|
* 更新商品库存 (针对下单减库存的商品)
|
*/
|
public function updateAdvanceProductStock($productList)
|
{
|
foreach ($productList as $product) {
|
// 下单减库存
|
if ($product['deduct_stock_type'] == DeductStockTypeEnum::CREATE) {
|
$sku = AdvanceProductSkuModel::detail($product['sku_source_id']);
|
try{
|
// 主库存减少
|
(new AdvanceProductModel)->where('advance_product_id', '=', $sku['advance_product_id'])->dec('stock', $product['total_num'])->update();
|
// 下单减库存
|
(new AdvanceProductSkuModel)->where('advance_product_sku_id', '=', $sku['advance_product_sku_id'])->dec('advance_stock', $product['total_num'])->update();
|
}catch (\Exception $e){
|
log_write('advance updateProductStock'. $e->getMessage());
|
}
|
}
|
}
|
}
|
|
/**
|
* 更新商品库存销量（订单付款后）
|
*/
|
public function updateAdvanceStockSales($productList)
|
{
|
foreach ($productList as $product) {
|
$sku = AdvanceProductSkuModel::detail($product['sku_source_id']);
|
// 记录商品的销量
|
(new AdvanceProductModel)->where('advance_product_id', '=', $sku['advance_product_id'])->inc('total_sales', $product['total_num'])->update();
|
// 付款减库存
|
if ($product['deduct_stock_type'] == DeductStockTypeEnum::PAYMENT) {
|
try{
|
// 主库存减少
|
(new AdvanceProductModel)->where('advance_product_id', '=', $sku['advance_product_id'])->dec('stock', $product['total_num'])->update();
|
// 付款减库存
|
(new AdvanceProductSkuModel)->where('advance_product_sku_id', '=', $sku['advance_product_sku_id'])->dec('advance_stock', $product['total_num'])->update();
|
}catch (\Exception $e){
|
log_write('advance updateStockSales'. $e->getMessage());
|
}
|
}
|
}
|
return true;
|
}
|
|
/**
|
* 更新商品库存 (针对下单减库存的商品)
|
*/
|
public function updateProductStock($productList)
|
{
|
$productData = [];
|
$productSkuData = [];
|
foreach ($productList as $product) {
|
// 下单减库存
|
if ($product['deduct_stock_type'] == DeductStockTypeEnum::CREATE) {
|
// 总库存
|
$productData[] = [
|
'data' => ['product_stock' => ['dec', $product['total_num']]],
|
'where' => [
|
'product_id' => $product['product_id'],
|
],
|
];
|
$productSkuData[] = [
|
'data' => ['stock_num' => ['dec', $product['total_num']]],
|
'where' => [
|
'product_id' => $product['product_id'],
|
'spec_sku_id' => $product['spec_sku_id'],
|
],
|
];
|
}
|
}
|
// 更新商品销量
|
!empty($productData) && $this->updateProduct($productData);
|
// 更新商品sku库存
|
!empty($productSkuData) && $this->updateProductSku($productSkuData);
|
return true;
|
}
|
|
/**
|
* 更新商品库存销量（订单付款后）
|
*/
|
public function updateStockSales($productList)
|
{
|
$productData = [];
|
$productSkuData = [];
|
foreach ($productList as $product) {
|
// 记录商品的销量
|
$product_data = [
|
'data' => ['sales_actual' => ['inc', $product['total_num']]],
|
'where' => [
|
'product_id' => $product['product_id']
|
],
|
];
|
// 付款减库存
|
if ($product['deduct_stock_type'] == DeductStockTypeEnum::PAYMENT) {
|
//总库存
|
$product_data['data']['product_stock'] = ['dec', $product['total_num']];
|
//sku库存
|
$productSkuData[] = [
|
'data' => ['stock_num' => ['dec', $product['total_num']]],
|
'where' => [
|
'product_id' => $product['product_id'],
|
'spec_sku_id' => $product['spec_sku_id'],
|
],
|
];
|
}
|
$productData[] = $product_data;
|
}
|
// 更新商品销量
|
!empty($productData) && $this->updateProduct($productData);
|
// 更新商品sku库存
|
!empty($productSkuData) && $this->updateProductSku($productSkuData);
|
return true;
|
}
|
|
/**
|
* 回退商品库存
|
*/
|
public function backProductStock($productList, $isPayOrder = false)
|
{
|
$productData = [];
|
$productSkuData = [];
|
foreach ($productList as $product) {
|
$product_item = [
|
'where' => [
|
'product_id' => $product['product_id'],
|
],
|
'data' => ['product_stock' => ['inc', $product['total_num']]],
|
];
|
$sku_item = [
|
'where' => [
|
'product_id' => $product['product_id'],
|
'spec_sku_id' => $product['spec_sku_id'],
|
],
|
'data' => ['stock_num' => ['inc', $product['total_num']]],
|
];
|
if ($isPayOrder == true) {
|
// 付款订单全部库存
|
$productData[] = $product_item;
|
$productSkuData[] = $sku_item;
|
} else {
|
// 未付款订单，判断必须为下单减库存时才回退
|
$product['deduct_stock_type'] == DeductStockTypeEnum::CREATE && $productData[] = $product_item;
|
$product['deduct_stock_type'] == DeductStockTypeEnum::CREATE && $productSkuData[] = $sku_item;
|
}
|
|
$sku = AdvanceProductSkuModel::detail($product['sku_source_id']);
|
// 回退主库存
|
(new AdvanceProductModel)->where('advance_product_id', '=', $sku['advance_product_id'])->inc('stock', $product['total_num'])->update();
|
// 回退sku库存
|
(new AdvanceProductSkuModel)->where('advance_product_sku_id', '=', $sku['advance_product_sku_id'])->inc('advance_stock', $product['total_num'])->update();
|
}
|
// 更新商品库存
|
!empty($productData) && $this->updateProduct($productData);
|
// 更新商品sku库存
|
!empty($productSkuData) && $this->updateProductSku($productSkuData);
|
return true;
|
}
|
|
/**
|
* 更新商品信息
|
*/
|
private function updateProduct($data)
|
{
|
return (new ProductModel)->updateAll($data);
|
}
|
|
/**
|
* 更新商品sku信息
|
*/
|
private function updateProductSku($data)
|
{
|
return (new ProductSkuModel)->updateAll($data);
|
}
|
|
}
|
