116 lines
4.4 KiB
PHP
116 lines
4.4 KiB
PHP
<?php
|
|
|
|
namespace app\queue\redis;
|
|
|
|
use app\admin\logic\store_product\StoreProductLogic;
|
|
use app\common\model\store_branch_product\StoreBranchProduct;
|
|
use app\common\model\store_branch_product_attr_value\StoreBranchProductAttrValue;
|
|
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 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'];
|
|
$admin_id = $data['admin_id'];
|
|
Log::error('StoreStorageSend: ' . json_encode($data));
|
|
$find = StoreProduct::where('id', $product_arr['id'])->findOrEmpty()->toArray();
|
|
$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 {
|
|
$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'],
|
|
'unit' => $find['unit'],
|
|
'cost' => $find['cost'],
|
|
'store_id' => $store_id,
|
|
'sales' => 0,
|
|
'stock' => 0,
|
|
];
|
|
$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);
|
|
}
|
|
StoreProductLogic::updateGoodsclass($find['cate_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);
|
|
}
|
|
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)
|
|
{
|
|
$storage = [
|
|
'product_id' => $product_arr['id'],
|
|
'store_id' => $store_id,
|
|
'nums' => $product_arr['stock'],
|
|
'admin_id' => $admin_id,
|
|
];
|
|
if ($find['stock'] < $product_arr['stock']) {
|
|
$storage['status'] = -1;
|
|
$storage['mark'] = '库存不足,主库存为:' . $find['stock'];
|
|
SystemStoreStorage::create($storage);
|
|
} else {
|
|
SystemStoreStorage::create($storage);
|
|
StoreProduct::where('id', $product_arr['id'])->dec('stock', $product_arr['stock'])->update();
|
|
}
|
|
}
|
|
|
|
public function onConsumeFailure(\Throwable $e, $package)
|
|
{
|
|
$package['max_attempts'] = 0;
|
|
Log::error('store-storage队列消费失败: ' . $e->getMessage() . ',line:' . $e->getLine() . ',file:' . $e->getFile());
|
|
return $package;
|
|
}
|
|
}
|