jh-admin/app/model/stock/GoodsStock.php

567 lines
24 KiB
PHP

<?php
/**
* SaaSMall商城系统 - 团队十年电商经验汇集巨献!
* =========================================================
* Copy right 2019-2029 上海牛之云网络科技有限公司, 保留所有权利。
* ----------------------------------------------
* 官方网址: https://www.gobuysaas.com
* =========================================================
*/
namespace app\model\stock;
use addon\stock\model\stock\Stock;
use app\model\BaseModel;
use app\model\store\Store;
use app\model\storegoods\StoreGoods;
use think\facade\Db;
/**
* 库存model (公共的库存相关改动和查询)
* @author Administrator
*
*/
class GoodsStock extends BaseModel
{
public function addStoreGoods($store_ids, $goods_id, $params)
{
$is_exist = addon_is_exit('stock');//独立库存系统
if ($is_exist) {
$stock_model = new Stock();
}
$goods_sku_list = $params['goods_sku_list'] ?? [];
$goods_sku_list_1 = [];
$goods_sku_list_2 = [];
if (!empty($goods_sku_list)) {
foreach ($goods_sku_list as $k => $v) {
if ($is_exist && $v['goods_class'] == 1) { //实物库存
$goods_sku_list_1[] = $v;
} else {
if (in_array($v['goods_class'], [1, 2, 3, 4, 5, 6])) {
$goods_sku_list_2[] = $v;
}
}
}
if (!empty($goods_sku_list_1)) {//库存独立插件目前未使用
$params['goods_sku_list'] = $goods_sku_list_1;
$result = $stock_model->setGoodsStock($params);
if ($result['code'] < 0) {
return $result;
}
}
if (!empty($goods_sku_list_2)) { //无库存插件
$sku_infos = model('goods_sku')->getList([['sku_id', 'in', array_column($goods_sku_list, 'sku_id')]], 'sku_id, goods_id,stock,sku_name,price,cost_price');
$goodsInfo = model('goods')->getInfo([['goods_id', '=', $goods_id]], 'price,goods_stock,goods_state');
$store_goods = [];
$store_sku_goods = [];
foreach ($store_ids as $store_id) {
$goodsArr = [
'goods_id' => $goods_id,
'store_id' => $store_id,
'price' => $goodsInfo['price'],
'status' => $goodsInfo['goods_state'],
'stock' => $goodsInfo['goods_stock'],
'create_time' => time()
];
$store_goods[] = $goodsArr;
foreach ($sku_infos as $items) {
$goods_sku = [
'sku_id' => $items['sku_id'],
'price' => $items['price'],
'stock' => $items['stock'],
'cost_price' => $items['cost_price']
];
$store_sku_goods[] = array_merge($goods_sku, $goodsArr);
}
}
model('store_goods')->addList($store_goods);//添加门店商品
model('store_goods_sku')->addList($store_sku_goods);//添加门店商品
}
}
return $this->success();
}
/**
* 商品直接设置库存权重最高(只允许商品数据发生变动时调用)
* @param $params
* @return array|int
*/
public function changeGoodsStock($params)
{
$store_id = $params['store_id'] ?? 0;
$site_id = $params['site_id'];
$goods_sku_list = $params['goods_sku_list'] ?? [];
//没有传递仓库id的话,就选取默认
if ($store_id == 0 || !addon_is_exit('store')) {
$store_model = new Store();
$store_info = $store_model->getDefaultStore($site_id)['data'] ?? [];
if (empty($store_info)) return $this->error(-1, '请添加默认门店');
$store_id = $store_info['store_id'];
$params['store_id'] = $store_id;
}
$is_exist = addon_is_exit('stock');//独立库存系统
if ($is_exist) {
$stock_model = new Stock();
}
if (!empty($goods_sku_list)) {
$goods_sku_list_1 = [];
$goods_sku_list_2 = [];
foreach ($goods_sku_list as $k => $v) {
if ($is_exist && $v['goods_class'] == 1) { //实物库存
$goods_sku_list_1[] = $v;
} else {
if (in_array($v['goods_class'], [1, 2, 3, 4, 5, 6])) {
$goods_sku_list_2[] = $v;
}
}
}
if (!empty($goods_sku_list_1)) {//库存独立插件
$params['goods_sku_list'] = $goods_sku_list_1;
$result = $stock_model->setGoodsStock($params);
if ($result['code'] < 0) {
return $result;
}
}
if (!empty($goods_sku_list_2)) { //无库存插件
$params['goods_sku_list'] = $goods_sku_list_2;
$result = $this->setGoodsStock($params);
if ($result['code'] < 0) {
return $result;
}
}
} else {
$goods_class = $params['goods_class'];
//如果存在进销存的话生成入库单据
if ($is_exist && $goods_class == 1) {
$result = $stock_model->setGoodsStock($params);
} else {//没有的话直接生成支付单据
$result = $this->setGoodsStock($params);
}
}
return $result ?? $this->success();
}
/**
* 商品库存设置(主体永远是sku)
* @param $params
* @return array
* @throws \think\db\exception\DbException
*/
public function setGoodsStock($params)
{
$goods_sku_list = $params['goods_sku_list'] ?? [];
$store_id = $params['store_id'] ?? 0;
if ($store_id > 0 && addon_is_exit('store')) {
if (empty($goods_sku_list)) { //如果无库存
$goods_id = $params['goods_id'] ?? 0;
$sku_id = $params['sku_id'];
$temp_stock = $params['stock'];
$site_id = $params['site_id'];
$goods_sku_list = [
[
'stock' => $temp_stock,
'goods_id' => $goods_id,
'sku_id' => $sku_id,
'site_id' => $site_id
]
];
}
$sku_infos = model('goods_sku')->getColumn([['sku_id', 'in', array_column($goods_sku_list, 'sku_id')]], 'sku_id, goods_id,stock,sku_name,price,discount_price', 'sku_id');
foreach ($goods_sku_list as $k => $v) {
$goods_id = $v['goods_id'] ?? 0;
$sku_id = $v['sku_id'];
$temp_stock = $v['stock'];//设置的新库存
if ($temp_stock < 0) return $this->error([], '库存不能小于0');
$condition = array(
['store_id', '=', $store_id],
['sku_id', '=', $sku_id]
);
$data = array(
'stock' => $temp_stock
);
if (!isset($sku_infos[$sku_id])) {
return $this->error([], '找不到商品');
} else {
$sku_info = $sku_infos[$sku_id];
}
if ($goods_id == 0) {
$goods_id = $sku_info['goods_id'];
}
//验证门店SKU商品库存
$return_info = $this->isNotExistCreateStoreStock([
'store_id' => $store_id,
'sku_id' => $sku_id,
'goods_id' => $goods_id
])['data'] ?? [];
$stock_goods_sku_info = $return_info['sku_info'];
$before_stock = $stock_goods_sku_info['stock']; //当前门店产品库存
$before_real_stock = $stock_goods_sku_info['real_stock'];//实际库存比较特殊,只算差值
$diff_stock = $temp_stock - $before_stock; //库存差值
$sku_real_stock = $before_real_stock + $diff_stock;
$data['real_stock'] = $sku_real_stock > 0 ? $sku_real_stock : 0;
model('store_goods_sku')->update($data, $condition);
$goods_condition = array(
['goods_id', '=', $goods_id],
['store_id', '=', $store_id]
);
if ($diff_stock > 0) {
Db::name('store_goods')->where($goods_condition)->update(
[
'stock' => Db::raw('stock+' . abs($diff_stock)),
'real_stock' => Db::raw('real_stock+' . abs($diff_stock))
]);
} else {
$stock_goods_info = $return_info['goods_info'];
$before_goods_real_stock = $stock_goods_info['real_stock'];
if (abs($diff_stock) > $before_goods_real_stock) {
$diff_stock = $before_goods_real_stock;
}
Db::name('store_goods')->where($goods_condition)->update(
[
'stock' => Db::raw('stock-' . abs($diff_stock)),
'real_stock' => Db::raw('real_stock-' . abs($diff_stock))
]);
}
// //维护商品和sku表中库存的统计数据
// $this->setCommonGoodsSkuStock([
// 'sku_id' => $sku_id,
// 'diff' => $diff_stock,
// 'store_id' => $store_id,
// 'site_id' => $params['site_id']
// ]);
}
}
return $this->success();
}
/**
* 减少库存(存在已经)
* @param $params
*/
public function decGoodsStock($params)
{
$store_id = $params['store_id'] ?? 0;
$goods_sku_list = $params['goods_sku_list'] ?? [];
if ($store_id > 0 && addon_is_exit('store')) {
$is_out_stock = $params['is_out_stock'] ?? 0;//是否扣除销售库存(销售状态下一般销售库存已经被扣除了)
if (empty($goods_sku_list)) {
$goods_id = $params['goods_id'] ?? 0;
$sku_id = $params['sku_id'];
$temp_stock = $params['stock'] ?? $params['num'];
$goods_sku_list = [
[
'site_id' => $params['site_id'],
'stock' => $temp_stock,
'goods_id' => $goods_id,
'sku_id' => $sku_id
]
];
}
$sku_infos = model('goods_sku')->getColumn([['sku_id', 'in', array_column($goods_sku_list, 'sku_id')]], 'sku_id, goods_id,stock,sku_name', 'sku_id');
foreach ($goods_sku_list as $k => $v) {
$goods_id = $v['goods_id'] ?? 0;
$sku_id = $v['sku_id'];
$temp_stock = $v['stock'] ?? $v['num'];
$sku_info = $sku_infos[$v['sku_id']] ?? null;
if (empty($sku_info)) {
return $this->error([], '找不到商品');
}
if ($goods_id == 0) {
$goods_id = $sku_info['goods_id'];
}
$sku_name = $sku_info['sku_name'];
$return_info = $this->isNotExistCreateStoreStock(['store_id' => $store_id, 'sku_id' => $sku_id, 'goods_id' => $goods_id])['data'] ?? [];
$sku_info = $return_info['sku_info'];
$store_sku_stock = $sku_info['real_stock'];
if ($store_sku_stock < $temp_stock) {
return $this->error([], '产品' . $sku_name . '库存不足');
}
$before_stock = $sku_info['stock'];
$sku_condition = array(
['sku_id', '=', $sku_id],
['store_id', '=', $store_id]
);
model('store_goods_sku')->setDec($sku_condition, 'real_stock', $temp_stock);
if ($is_out_stock) {
model('store_goods_sku')->setDec($sku_condition, 'stock', $temp_stock > $before_stock ? $before_stock : $temp_stock);
}
$goods_condition = array(
['goods_id', '=', $goods_id],
['store_id', '=', $store_id]
);
model('store_goods')->setDec($goods_condition, 'real_stock', $temp_stock);
if ($is_out_stock) {
$goods_info = $return_info['goods_info'];
$before_goods_stock = $goods_info['stock'];
model('store_goods')->setDec($goods_condition, 'stock', $temp_stock > $before_goods_stock ? $before_goods_stock : $temp_stock);
}
//维护商品和sku表中库存的统计数据
// $this->setCommonGoodsSkuStock(['sku_id' => $sku_id, 'diff' => -$temp_stock, 'store_id' => $store_id, 'site_id' => $params['site_id']]);
}
}
return $this->success();
}
/**
* 增加库存
* @param $params
* @return array
*/
public function incGoodsStock($params)
{
$goods_sku_list = $params['goods_sku_list'] ?? [];
$store_id = $params['store_id'] ?? 0;
if ($store_id > 0 && addon_is_exit('store')) {
if (empty($goods_sku_list)) {
$goods_id = $params['goods_id'] ?? 0;
$sku_id = $params['sku_id'];
$temp_stock = $params['stock'] ?? $params['num'];
$goods_sku_list = [
[
'stock' => $temp_stock,
'goods_id' => $goods_id,
'site_id' => $params['site_id'],
'sku_id' => $sku_id
]
];
}
foreach ($goods_sku_list as $k => $v) {
$goods_id = $v['goods_id'] ?? 0;
$sku_id = $v['sku_id'];
$temp_stock = $v['stock'] ?? $v['num'];
if ($goods_id == 0) {
$sku_info = model('goods_sku')->getInfo([['sku_id', '=', $sku_id]], 'goods_id');
if (empty($sku_info)) {
return $this->error([], '找不到商品');
}
$goods_id = $sku_info['goods_id'];
}
$this->isNotExistCreateStoreStock(['store_id' => $store_id, 'sku_id' => $sku_id, 'goods_id' => $goods_id])['data'] ?? [];
$sku_condition = array(
['sku_id', '=', $sku_id],
['store_id', '=', $store_id]
);
Db::name('store_goods_sku')->where($sku_condition)->update(
[
'stock' => Db::raw('stock+' . abs($temp_stock)),
'real_stock' => Db::raw('real_stock+' . abs($temp_stock))
]);
$goods_condition = array(
['goods_id', '=', $goods_id],
['store_id', '=', $store_id]
);
Db::name('store_goods')->where($goods_condition)->update(
[
'stock' => Db::raw('stock+' . abs($temp_stock)),
'real_stock' => Db::raw('real_stock+' . abs($temp_stock))
]);
}
} else {
if (empty($goods_sku_list)) {
$goods_id = $params['goods_id'] ?? 0;
$sku_id = $params['sku_id'];
$temp_stock = $params['stock'] ?? $params['num'];
$sku_condition = array(['sku_id', '=', $sku_id]);
Db::name('goods_sku')->where($sku_condition)->update(
[
'stock' => Db::raw('stock+' . abs($temp_stock)),
'real_stock' => Db::raw('real_stock+' . abs($temp_stock))
]);
$goods_condition = array(
['goods_id', '=', $goods_id]
);
Db::name('goods')->where($goods_condition)->update(
[
'stock' => Db::raw('stock+' . abs($temp_stock)),
'real_stock' => Db::raw('real_stock+' . abs($temp_stock))
]);
}
}
return $this->success();
}
/**
* 设置总的商品库存(维护商品数据)
* 默认库存与默认店铺店铺一致
* @param $params
*/
public function setCommonGoodsSkuStock($params)
{
$sku_id = $params['sku_id'];
$store_model = new Store();
$store_info = $store_model->getDefaultStore($params['site_id'])['data'] ?? [];
$default_store_id = $store_info['store_id']; //当前默认店铺
$store_id = $params['store_id'];
if ($store_id == $default_store_id) {
$condition = array(
['site_id', '=', $params['site_id']],
['sku_id', '=', $sku_id],
);
$sku_info = model('goods_sku')->getInfo($condition, 'goods_id');
if (empty($sku_info)) return $this->error();
$goods_id = $sku_info['goods_id'];
$goods_condition = array(
['goods_id', '=', $goods_id]
);
$store_good_model = new StoreGoods();
$store_goods_info = $store_good_model->getStoreGoodsInfo([['goods_id', '=', $goods_id], ['store_id', '=', $store_id]])['data'] ?? [];
$store_sku_goods_info = $store_good_model->getStoreGoodsSkuInfo([['sku_id', '=', $sku_id], ['store_id', '=', $store_id]])['data'] ?? [];
model('goods')->update(['goods_stock' => $store_goods_info['stock'] ?? 0, 'real_stock' => $store_goods_info['real_stock'] ?? 0], $goods_condition);
model('goods_sku')->update(['stock' => $store_sku_goods_info['stock'] ?? 0, 'real_stock' => $store_sku_goods_info['real_stock'] ?? 0], $condition);
}
return $this->success();
}
/**
* 检查门店库存数据
* 不存在则创建
* @param $params
*/
public function isNotExistCreateStoreStock($params)
{
$sku_id = $params['sku_id'];
$store_id = $params['store_id'];
$goods_id = $params['goods_id'];//经过校验的数据,无需再验
$sku_store_condition = array(
['sku_id', '=', $sku_id],
['store_id', '=', $store_id]
);
$sku_info = model('store_goods_sku')->getInfo($sku_store_condition);
//不存在就创建
if (empty($sku_info)) {
$data = array(
'goods_id' => $goods_id,
'sku_id' => $sku_id,
'store_id' => $store_id,
'create_time' => time()
);
model('store_goods_sku')->add($data);
$sku_info = model('store_goods_sku')->getInfo($sku_store_condition);
}
$sku_store_condition = array(
['goods_id', '=', $goods_id],
['store_id', '=', $store_id]
);
$goods_info = model('store_goods')->getInfo($sku_store_condition);
//不存在就创建
if (empty($goods_info)) {
$data = array(
'goods_id' => $goods_id,
'store_id' => $store_id,
'create_time' => time()
);
model('store_goods')->add($data);
$goods_info = model('store_goods')->getInfo($sku_store_condition);
}
if (!empty($sku_info)) {
if (isset($sku_info['stock'])) {
$sku_info['stock'] = numberFormat($sku_info['stock']);
}
if (isset($sku_info['sale_num'])) {
$sku_info['sale_num'] = numberFormat($sku_info['sale_num']);
}
if (isset($sku_info['real_stock'])) {
$sku_info['real_stock'] = numberFormat($sku_info['real_stock']);
}
}
if (!empty($goods_info)) {
if (isset($goods_info['stock'])) {
$goods_info['stock'] = numberFormat($goods_info['stock']);
}
if (isset($goods_info['sale_num'])) {
$goods_info['sale_num'] = numberFormat($goods_info['sale_num']);
}
if (isset($goods_info['real_stock'])) {
$goods_info['real_stock'] = numberFormat($goods_info['real_stock']);
}
}
return $this->success(['sku_info' => $sku_info, 'goods_info' => $goods_info]);
}
/**
* 修改商品后调用商品库存变更
* @param array $data
*/
public function editGoodsChangeStock(array $param)
{
$sku_list = model('goods_sku')->getList([['goods_id', '=', $param['goods_id']], ['site_id', '=', $param['site_id']]], 'goods_id,sku_id,stock,site_id,goods_class');
if (empty($sku_list)) return $this->error();
foreach ($sku_list as $sku_item) {
$sku_item['stock'] = numberFormat($sku_item['stock']);
$sku_item['user_info'] = $param['user_info'] ?? [];
$this->changeGoodsStock($sku_item);
}
return $this->success();
}
/**
* 核验可能不存在的sku门店数据,
* 并校正数据(单个商品解决方案)
* @param $params
*/
public function checkExistGoodsSku($params)
{
$goods_id = $params['goods_id'];
$goods_condition = array(
['goods_id', '=', $goods_id]
);
$sku_ids = model('goods_sku')->getColumn($goods_condition, 'sku_id');
$store_sku_condition = array(
['goods_id', '=', $goods_id],
['sku_id', 'not in', $sku_ids]
);
//被废弃的门店sku
$store_sku_list = model('store_goods_sku')
->getList($store_sku_condition, 'store_id, sum(stock) as stock, sum(real_stock) as real_stock', '', '', [], 'store_id');
if (empty($store_sku_list)) return $this->success();
$stock = 0;
$real_stock = 0;
foreach ($store_sku_list as $k => $v) {
$store_id = $v['store_id'];
$item_stock = numberFormat($v['stock']);
$item_real_stock = numberFormat($v['real_stock']);
$item_store_goods_condition = $goods_condition;
$item_store_goods_condition[] = ['store_id', '=', $store_id];
$item_store_goods_info = model('store_goods')->getInfo($item_store_goods_condition, 'stock, real_stock');
$new_item_stock = $item_store_goods_info['stock'] - $item_stock;
$new_item_real_stock = $item_store_goods_info['real_stock'] - $item_real_stock;
model('store_goods')->update([
'stock' => $new_item_stock < 0 ? 0 : $new_item_stock,
'real_stock' => $new_item_real_stock < 0 ? 0 : $new_item_real_stock
], $item_store_goods_condition);
$stock += $item_stock;
$real_stock += $item_real_stock;
}
model('store_goods_sku')->delete($store_sku_condition);
$goods_info = model('goods')->getInfo($goods_condition, 'goods_stock, real_stock');
$goods_stock = $goods_info['goods_stock'] - $stock;
$goods_real_stock = $goods_info['real_stock'] - $real_stock;
model('goods')->update([
'stock' => $goods_stock < 0 ? 0 : $goods_stock,
'real_stock' => $goods_real_stock < 0 ? 0 : $goods_real_stock
], $goods_condition);
return $this->success();
}
/***
* 验证商品sku库存总结
* @param $params
* @return void
*/
public function checkGoodsSkuStock($params)
{
$goods_id = $params['goods_id'];
$goods_condition = array(
['goods_id', '=', $goods_id]
);
$sku_list = model('goods_sku')
->getList($goods_condition, 'sum(stock) as stock, sum(real_stock) as real_stock', '', '', [], 'goods_id');
if (!empty($sku_list)) {
model('goods')->update(['goods_stock' => $sku_list[0]['stock'] ?? 0, 'real_stock' => $sku_list[0]['real_stock'] ?? 0], $goods_condition);
}
}
}