|
@@ -574,6 +574,7 @@ class ProductClass extends BaseClass
|
|
|
// 用 RabbitMQ 延迟消息在到期时清空订单项限购字段
|
|
// 用 RabbitMQ 延迟消息在到期时清空订单项限购字段
|
|
|
$message = [
|
|
$message = [
|
|
|
'type' => 'limit_buy_clear',
|
|
'type' => 'limit_buy_clear',
|
|
|
|
|
+ 'ptType' => 'hd',
|
|
|
'productId' => $productId,
|
|
'productId' => $productId,
|
|
|
'clearAt' => $clearAt,
|
|
'clearAt' => $clearAt,
|
|
|
];
|
|
];
|
|
@@ -590,8 +591,7 @@ class ProductClass extends BaseClass
|
|
|
'type' => 'limit_buy_clear',
|
|
'type' => 'limit_buy_clear',
|
|
|
'ptType' => 'hd',
|
|
'ptType' => 'hd',
|
|
|
'productId' => intval($productId),
|
|
'productId' => intval($productId),
|
|
|
- 'clearAt' => intval($clearAt),
|
|
|
|
|
- 'delayMs' => intval($seconds * 1000),
|
|
|
|
|
|
|
+ 'clearAt' => intval($clearAt)
|
|
|
], JSON_UNESCAPED_UNICODE), __METHOD__);
|
|
], JSON_UNESCAPED_UNICODE), __METHOD__);
|
|
|
} else {
|
|
} else {
|
|
|
Yii::$app->redis->executeCommand('DEL', [$clearMarkKey]);
|
|
Yii::$app->redis->executeCommand('DEL', [$clearMarkKey]);
|