222 lines
9.0 KiB
PHP
222 lines
9.0 KiB
PHP
<?php
|
|
|
|
declare(strict_types=1);
|
|
|
|
namespace App\Command;
|
|
|
|
use App\Model\Product;
|
|
use App\Model\ProductAmountRecord;
|
|
use App\Model\ProductPlatformAmount;
|
|
use App\Utils\Log;
|
|
use Extend\Prescription\Prescription;
|
|
use Hyperf\Command\Command as HyperfCommand;
|
|
use Hyperf\Command\Annotation\Command;
|
|
use Hyperf\DbConnection\Db;
|
|
use Psr\Container\ContainerInterface;
|
|
|
|
/**
|
|
* 更新商品库存
|
|
*/
|
|
#[Command]
|
|
class getProductStockCommand extends HyperfCommand
|
|
{
|
|
public function __construct(protected ContainerInterface $container)
|
|
{
|
|
parent::__construct('getProductStock:command');
|
|
}
|
|
|
|
public function configure()
|
|
{
|
|
parent::configure();
|
|
$this->setDescription('获取处方平台商品库存数据');
|
|
}
|
|
|
|
protected function logInfo(string $message): void
|
|
{
|
|
$this->line(date('Y-m-d H:i:s') . ' [INFO] ' . $message);
|
|
Log::getInstance('getProductStockCommand')->info($message);
|
|
}
|
|
|
|
protected function logWarn(string $message): void
|
|
{
|
|
$this->warn(date('Y-m-d H:i:s') . ' [WARN] ' . $message);
|
|
Log::getInstance('getProductStockCommand')->warning($message);
|
|
}
|
|
|
|
protected function logError(string $message): void
|
|
{
|
|
$this->error(date('Y-m-d H:i:s') . ' [ERROR] ' . $message);
|
|
Log::getInstance('getProductStockCommand')->error($message);
|
|
}
|
|
|
|
public function handle()
|
|
{
|
|
$startTime = microtime(true);
|
|
$this->logInfo("================== [getProductStockCommand] 商品库存更新开始 ==================");
|
|
|
|
$stats = [
|
|
'total' => 0,
|
|
'success' => 0,
|
|
'stock_changed' => 0,
|
|
'stock_unchanged' => 0,
|
|
'skipped' => 0,
|
|
'failed' => 0,
|
|
];
|
|
|
|
try {
|
|
$pageSize = 20;
|
|
$params = array();
|
|
$params['product_status'] = 1;
|
|
$product = Product::getPage($params, ['*'], 1, $pageSize);
|
|
if (empty($product['data'])) {
|
|
$this->logInfo("当前无可更新库存的在架商品，任务结束");
|
|
return;
|
|
}
|
|
|
|
$totalCount = (int)($product['total'] ?? count($product['data']));
|
|
$lastPage = (int)($product['last_page'] ?? 1);
|
|
$this->logInfo("在架商品总数: {$totalCount} 件，共 {$lastPage} 页，每页批次: {$pageSize} 件");
|
|
|
|
$prescription = new Prescription();
|
|
|
|
for ($page = 1; $page <= $lastPage; $page++) {
|
|
if ($page > 1) {
|
|
$product = Product::getPage($params, ['*'], $page, $pageSize);
|
|
if (empty($product['data'])) {
|
|
break;
|
|
}
|
|
}
|
|
|
|
$this->logInfo(">>> 正在处理第 {$page}/{$lastPage} 页商品库存 (当前页 " . count($product['data']) . " 件)...");
|
|
|
|
foreach ($product['data'] as $item) {
|
|
$stats['total']++;
|
|
|
|
if (empty($item['product_pharmacy_code'])) {
|
|
$this->logWarn("【跳过】商品 [{$item['product_name']}] (ID: {$item['product_id']}) 未配置第三方药品编码(product_pharmacy_code)");
|
|
$stats['skipped']++;
|
|
continue;
|
|
}
|
|
|
|
$pharmacy_code = $item['pharmacy_code'] ?? '';
|
|
try {
|
|
$result = $prescription->getProdStock($item['product_pharmacy_code'], $pharmacy_code);
|
|
if (empty($result) || !isset($result[0])) {
|
|
$this->logWarn("【库存响应空】商品 [{$item['product_name']}] 药房 [{$pharmacy_code}] 平台未返回库存数据");
|
|
$stats['failed']++;
|
|
continue;
|
|
}
|
|
|
|
$res = $this->handleData($item, $result[0], $stats);
|
|
if ($res) {
|
|
$stats['success']++;
|
|
} else {
|
|
$stats['failed']++;
|
|
}
|
|
} catch (\Throwable $e) {
|
|
$this->logError("【查询库存失败】商品 [{$item['product_name']}] (药店编码: {$item['product_pharmacy_code']}, 药房: {$pharmacy_code}) 异常: " . $e->getMessage());
|
|
$stats['failed']++;
|
|
}
|
|
}
|
|
}
|
|
} catch (\Throwable $e) {
|
|
$this->logError("商品库存更新全局异常：" . $e->getMessage());
|
|
}
|
|
|
|
$duration = round(microtime(true) - $startTime, 2);
|
|
$this->logInfo("================== [getProductStockCommand] 商品库存更新完成 ==================");
|
|
$this->logInfo("总耗时: {$duration}s | 检查总数: {$stats['total']} | 成功: {$stats['success']} (变动: {$stats['stock_changed']}, 未变: {$stats['stock_unchanged']}) | 跳过: {$stats['skipped']} | 失败: {$stats['failed']}");
|
|
}
|
|
|
|
/**
|
|
* 入库
|
|
* @param Product|array $item
|
|
* @param array $resultData
|
|
* @param array $stats
|
|
* @return bool
|
|
*/
|
|
public function handleData(Product|array $item, array $resultData, array &$stats = []): bool
|
|
{
|
|
$quantity = (int)($resultData['quantity'] ?? 0);
|
|
$product_platform_id = (string)$item['product_platform_id'];
|
|
$product_platform_code = (string)$item['product_platform_code'];
|
|
$product_name = (string)($item['product_name'] ?? '');
|
|
$pharmacy_code = (string)($item['pharmacy_code'] ?? '');
|
|
|
|
try {
|
|
Db::beginTransaction();
|
|
|
|
$params = array();
|
|
$params['product_platform_id'] = $product_platform_id;
|
|
$params['product_platform_code'] = $product_platform_code;
|
|
$product_platform_amount = ProductPlatformAmount::getSharedLockOne($params);
|
|
|
|
$old_stock = 0;
|
|
if (empty($product_platform_amount)) {
|
|
// 无库存数据，新增
|
|
$data = array();
|
|
$data['product_platform_id'] = $product_platform_id;
|
|
$data['product_platform_code'] = $product_platform_code;
|
|
$data['stock'] = $quantity;
|
|
$product_platform_amount = ProductPlatformAmount::addProductPlatformAmount($data);
|
|
if (empty($product_platform_amount)) {
|
|
Db::rollBack();
|
|
$this->logError("商品 [{$product_name}] 新增库存数据失败: " . json_encode($data, JSON_UNESCAPED_UNICODE));
|
|
return false;
|
|
}
|
|
$this->logInfo("【初始化库存】商品 [{$product_name}] 药房 [{$pharmacy_code}] 初始库存: {$quantity}");
|
|
$stats['stock_changed']++;
|
|
} else {
|
|
$old_stock = (int)$product_platform_amount['stock'];
|
|
|
|
// 存在库存数据，修改
|
|
$data = array();
|
|
$data['stock'] = $quantity;
|
|
|
|
$params = array();
|
|
$params['amount_id'] = $product_platform_amount['amount_id'];
|
|
ProductPlatformAmount::edit($params, $data);
|
|
|
|
if ($old_stock !== $quantity) {
|
|
$diff = $quantity - $old_stock;
|
|
$diffStr = ($diff > 0 ? "+{$diff}" : "{$diff}");
|
|
$this->logInfo("【库存变动】商品 [{$product_name}] 药房 [{$pharmacy_code}] 原库存: {$old_stock} -> 最新库存: {$quantity} (变动: {$diffStr})");
|
|
$stats['stock_changed']++;
|
|
} else {
|
|
$this->logInfo("【库存无变化】商品 [{$product_name}] 药房 [{$pharmacy_code}] 当前库存: {$quantity}");
|
|
$stats['stock_unchanged']++;
|
|
}
|
|
}
|
|
|
|
// 增加库存记录（仅在库存发生变动或首次初始化时记录）
|
|
if ($old_stock !== $quantity || empty($product_platform_amount)) {
|
|
$params = array();
|
|
$params['product_platform_id'] = $product_platform_id;
|
|
$product = Product::getOne($params);
|
|
if (!empty($product)) {
|
|
$data = array();
|
|
$data['product_id'] = $product['product_id'];
|
|
$data['change_quantity'] = $quantity - $old_stock;
|
|
$data['quantity'] = $quantity;
|
|
$data['change_time'] = date('Y-m-d H:i:s', time());
|
|
$data['remark'] = "处方平台库存定时同步";
|
|
$product_amount_record = ProductAmountRecord::addProductAmountRecord($data);
|
|
if (empty($product_amount_record)) {
|
|
Db::rollBack();
|
|
$this->logError("商品 [{$product_name}] 增加库存流水记录失败: " . json_encode($data, JSON_UNESCAPED_UNICODE));
|
|
return false;
|
|
}
|
|
}
|
|
}
|
|
|
|
Db::commit();
|
|
} catch (\Throwable $e) {
|
|
Db::rollBack();
|
|
$this->logError("商品 [{$product_name}] 更新库存事务异常: " . $e->getMessage());
|
|
return false;
|
|
}
|
|
|
|
return true;
|
|
}
|
|
}
|