231 lines
9.4 KiB
PHP
231 lines
9.4 KiB
PHP
<?php
|
|
|
|
namespace app\queue\redis;
|
|
|
|
use app\admin\logic\store_product\StoreProductLogic;
|
|
use app\admin\logic\warehouse_product\WarehouseProductLogic;
|
|
use app\common\model\store_branch_product\StoreBranchProduct;
|
|
use app\common\model\store_branch_product_attr_value\StoreBranchProductAttrValue;
|
|
use app\common\model\store_branch_product_exchange\StoreBranchProductExchange;
|
|
use app\common\model\store_product\StoreProduct;
|
|
use app\common\model\store_product_attr_value\StoreProductAttrValue;
|
|
use app\common\model\system_store_storage\SystemStoreStorage;
|
|
use app\common\model\warehouse_product_storege\WarehouseProductStorege;
|
|
use Webman\RedisQueue\Consumer;
|
|
use support\Log;
|
|
use think\facade\Db;
|
|
|
|
/**
|
|
* 门店库存记录商品
|
|
*/
|
|
class StoreStorageSend implements Consumer
|
|
{
|
|
// 要消费的队列名
|
|
public $queue = 'store-storage';
|
|
|
|
// 连接名，对应 plugin/webman/redis-queue/redis.php 里的连接`
|
|
public $connection = 'default';
|
|
|
|
// 消费
|
|
public function consume($data)
|
|
{
|
|
$product_arr = $data['product_arr'];
|
|
$store_id = $data['store_id'];
|
|
$stock_type = $data['stock_type'];
|
|
$admin_id = $data['admin_id'];
|
|
$warehouse_id = $data['warehouse_id']??0;
|
|
$find = StoreProduct::where('id', $product_arr['id'])->findOrEmpty()->toArray();
|
|
if($stock_type == 1){
|
|
$this->ordinary($product_arr,$store_id,$admin_id,$find,$warehouse_id);
|
|
}elseif($stock_type == 2){
|
|
$this->exchange($product_arr,$store_id,$admin_id,$find,$warehouse_id);
|
|
}
|
|
}
|
|
|
|
/**普通 */
|
|
public function ordinary($product_arr,$store_id,$admin_id,$find,$warehouse_id){
|
|
$store_find = StoreBranchProduct::where(['product_id' => $product_arr['id'], 'store_id' => $store_id])->findOrEmpty()->toArray();
|
|
if ($find && !$store_find) {
|
|
$attr_value = StoreProductAttrValue::where('product_id', $product_arr['id'])->findOrEmpty();
|
|
Db::startTrans();
|
|
try {
|
|
$dealCate = self::dealChangeCate($find['cate_id']);
|
|
$product = [
|
|
'product_id' => $find['id'],
|
|
'image' => $find['image'],
|
|
'store_name' => $find['store_name'],
|
|
'store_info' => $find['store_info'],
|
|
'keyword' => $find['keyword'],
|
|
'bar_code' => $find['bar_code'],
|
|
'cate_id' => $find['cate_id'],
|
|
'top_cate_id' => $dealCate['top_cate_id'],
|
|
'two_cate_id' => $dealCate['two_cate_id'],
|
|
'price' => $find['price'],
|
|
// 'cost' => $find['cost'], //v1.0
|
|
'cost' => $find['cost'],
|
|
'purchase' => $find['purchase'],
|
|
'vip_price' => $find['vip_price'],
|
|
'manufacturer_information' => $find['manufacturer_information']??'',
|
|
'unit' => $find['unit'],
|
|
'batch' => $find['batch'],
|
|
'store_id' => $store_id,
|
|
'sales' => 0,
|
|
'product_type' => $find['product_type'],
|
|
'stock' => 0,
|
|
'rose' => $find['rose'],
|
|
];
|
|
$branch = StoreBranchProduct::create($product);
|
|
$arr = [
|
|
'product_id' => $product_arr['id'],
|
|
'store_id' => $store_id,
|
|
'unique' => setUnique($branch['id'], '', 0),
|
|
'sales' => 0,
|
|
'type' => 0,
|
|
'bar_code' => $attr_value['bar_code']
|
|
];
|
|
StoreBranchProductAttrValue::create($arr);
|
|
if ($product_arr['stock'] > 0) {
|
|
$this->storage($find, $store_id, $admin_id, $product_arr,$warehouse_id);
|
|
}
|
|
StoreProductLogic::updateGoodsclass($find['cate_id'],$store_id);
|
|
Db::commit();
|
|
return true;
|
|
} catch (\Exception $e) {
|
|
Db::rollback();
|
|
Log::error('store-storage队列消费失败: ' . $e->getMessage() . ',line:' . $e->getLine() . ',file:' . $e->getFile());
|
|
return false;
|
|
}
|
|
} else {
|
|
Db::startTrans();
|
|
try {
|
|
if ($product_arr['stock'] > 0) {
|
|
$this->storage($find, $store_id, $admin_id, $product_arr,1,$warehouse_id);
|
|
}
|
|
Db::commit();
|
|
return true;
|
|
} catch (\Exception $e) {
|
|
Db::rollback();
|
|
Log::error('store-storage队列消费失败: ' . $e->getMessage() . ',line:' . $e->getLine() . ',file:' . $e->getFile());
|
|
return false;
|
|
}
|
|
}
|
|
}
|
|
|
|
/**兑换 */
|
|
public function exchange($product_arr,$store_id,$admin_id,$find,$warehouse_id){
|
|
$store_find = StoreBranchProductExchange::where(['product_id' => $product_arr['id'], 'store_id' => $store_id])->findOrEmpty()->toArray();
|
|
if ($find && !$store_find) {
|
|
Db::startTrans();
|
|
try {
|
|
$product = [
|
|
'product_id' => $find['id'],
|
|
'image' => $find['image'],
|
|
'store_name' => $find['store_name'],
|
|
'store_info' => $find['store_info'],
|
|
'keyword' => $find['keyword'],
|
|
'bar_code' => $find['bar_code'],
|
|
'cate_id' => $find['cate_id'],
|
|
'price' => $find['price'],
|
|
'cost' => $find['cost'],
|
|
'purchase' => $find['purchase'],
|
|
'vip_price' => $find['vip_price'],
|
|
'unit' => $find['unit'],
|
|
'store_id' => $store_id,
|
|
'sales' => 0,
|
|
'stock' => 0,
|
|
];
|
|
StoreBranchProductExchange::create($product);
|
|
if ($product_arr['stock'] > 0) {
|
|
$this->storage($find, $store_id, $admin_id, $product_arr,$warehouse_id);
|
|
}
|
|
// StoreProductLogic::updateGoodsclass($find['cate_id'],$store_id);
|
|
Db::commit();
|
|
return true;
|
|
} catch (\Exception $e) {
|
|
Db::rollback();
|
|
Log::error('store-storage队列消费失败: ' . $e->getMessage() . ',line:' . $e->getLine() . ',file:' . $e->getFile());
|
|
return false;
|
|
}
|
|
} else {
|
|
Db::startTrans();
|
|
try {
|
|
if ($product_arr['stock'] > 0) {
|
|
$this->storage($find, $store_id, $admin_id, $product_arr,2,$warehouse_id);
|
|
}
|
|
Db::commit();
|
|
return true;
|
|
} catch (\Exception $e) {
|
|
Db::rollback();
|
|
Log::error('store-storage队列消费失败: ' . $e->getMessage() . ',line:' . $e->getLine() . ',file:' . $e->getFile());
|
|
return false;
|
|
}
|
|
}
|
|
}
|
|
public function storage($find, $store_id, $admin_id, $product_arr,$stock_type=1,$warehouse_id=0)
|
|
{
|
|
$storage = [
|
|
'product_id' => $product_arr['id'],
|
|
'store_id' => $store_id,
|
|
'nums' => $product_arr['stock'],
|
|
'admin_id' => $admin_id,
|
|
'type' => $stock_type,
|
|
];
|
|
$data=[
|
|
'warehouse_id'=>$warehouse_id,
|
|
'product_id' => $product_arr['id'],
|
|
'financial_pm' => 0,
|
|
'batch' => $product_arr['batch']??1,
|
|
'nums' => $product_arr['stock'],
|
|
'status' =>1,
|
|
'admin_id' =>$admin_id,
|
|
];
|
|
$warehouse=WarehouseProductStorege::where('warehouse_id',$warehouse_id)->where('product_id',$product_arr['id'])->find();
|
|
if ($warehouse) {
|
|
if($warehouse['nums']< $product_arr['stock']){
|
|
$storage['status'] = -1;
|
|
$storage['mark'] = '库存不足,分库存为:' .$warehouse['nums'];
|
|
$data['mark'] = '库存不足,分库存为:' .$warehouse['nums'].' 总仓库存为:'.$find['stock'];
|
|
}
|
|
SystemStoreStorage::create($storage);
|
|
WarehouseProductLogic::add($data);
|
|
} else {
|
|
SystemStoreStorage::create($storage);
|
|
WarehouseProductLogic::add($data);
|
|
}
|
|
}
|
|
|
|
public function onConsumeFailure(\Throwable $e, $package)
|
|
{
|
|
$package['max_attempts'] = 0;
|
|
Log::error('store-storage队列消费失败: ' . $e->getMessage() . ',line:' . $e->getLine() . ',file:' . $e->getFile());
|
|
return $package;
|
|
}
|
|
|
|
/*
|
|
* 传入三级或者二级分类返还上级分类 一级那全是相同
|
|
*/
|
|
public static function dealChangeCate($cate_id)
|
|
{
|
|
$value =[];
|
|
$last_cate = Db::name('store_category')->where('id',$cate_id)->value('pid');
|
|
if(!empty($last_cate)){
|
|
//2
|
|
$value['two_cate_id'] = $last_cate;
|
|
//1
|
|
$first_cate = Db::name('store_category')->where('id',$value['two_cate_id'])->value('pid');
|
|
if(empty($first_cate)){//顶级了
|
|
$value['two_cate_id'] = $cate_id;
|
|
$value['top_cate_id'] = $last_cate;
|
|
}else{
|
|
$value['top_cate_id'] = $first_cate;
|
|
}
|
|
|
|
}else{
|
|
//1-2 选的1级目录
|
|
$value['two_cate_id'] = $cate_id;
|
|
$value['top_cate_id'] = $cate_id;
|
|
}
|
|
return $value;
|
|
}
|
|
}
|