You've already forked pruchase_jhw
条件修改
This commit is contained in:
@@ -50,7 +50,7 @@ class SurugayaTradeMonitorTask(BasePurchaseTask):
|
|||||||
raise Exception(f"交易单号 '{trade_code}' 未解析到订单详情。")
|
raise Exception(f"交易单号 '{trade_code}' 未解析到订单详情。")
|
||||||
|
|
||||||
new_trade_status = order_detail_model.status.trade_status or ""
|
new_trade_status = order_detail_model.status.trade_status or ""
|
||||||
trade_number = order_detail_model.summary.trade_number or None
|
inquiry_number = order_detail_model.summary.inquiry_number or None
|
||||||
|
|
||||||
redis_client = get_redis_client()
|
redis_client = get_redis_client()
|
||||||
|
|
||||||
@@ -79,9 +79,9 @@ class SurugayaTradeMonitorTask(BasePurchaseTask):
|
|||||||
)
|
)
|
||||||
|
|
||||||
enqueue = True # 是否需要再次入队
|
enqueue = True # 是否需要再次入队
|
||||||
if trade_number is not None:
|
if inquiry_number is not None:
|
||||||
logger.warning(
|
logger.warning(
|
||||||
f"[任务 {self.task_id}] 订单物流单号已获取到 '{trade_number}',放弃再次入队。"
|
f"[任务 {self.task_id}] 订单物流单号已获取到 '{inquiry_number}',放弃再次入队。"
|
||||||
)
|
)
|
||||||
enqueue = False
|
enqueue = False
|
||||||
elif new_trade_status == "発送済み" or new_trade_status == "取引終了":
|
elif new_trade_status == "発送済み" or new_trade_status == "取引終了":
|
||||||
|
|||||||
Reference in New Issue
Block a user