|
|
@@ -76,25 +76,12 @@ class BillHandler(BaseHandler[dict]):
|
|
|
|
|
|
# ========== 转账通知(企业码扩展) ==========
|
|
|
elif data.consume_type == "TRANSFER":
|
|
|
- from app.plugin.module_payment.account.enums import TransferStatusEnum
|
|
|
-
|
|
|
- reason = (data.notify_reason or "").upper()
|
|
|
- if "SUCCESS" in reason:
|
|
|
- status = TransferStatusEnum.SUCCESS.value
|
|
|
- await AccountService.update_transfer_status_service(
|
|
|
- auth, data.pay_no, status, data.model_dump(exclude_none=True)
|
|
|
- )
|
|
|
- elif "FAIL" in reason:
|
|
|
- status = TransferStatusEnum.FAIL.value
|
|
|
- await AccountService.update_transfer_status_service(
|
|
|
- auth, data.pay_no, status, data.model_dump(exclude_none=True)
|
|
|
- )
|
|
|
- else:
|
|
|
- log.warning(f"转账状态无法判断,跳过更新: pay_no={data.pay_no}, notify_reason={data.notify_reason}")
|
|
|
-
|
|
|
- # 无论是否更新状态,都回调商户通知状态变化
|
|
|
+ await AccountService.update_transfer_status_service(
|
|
|
+ auth, data.pay_no, "SUCCESS", data.model_dump(exclude_none=True)
|
|
|
+ )
|
|
|
await OpenTransferService.open_return_service(auth, data.pay_no)
|
|
|
|
|
|
+
|
|
|
else:
|
|
|
log.info(f"未知账单类型: consume_type={data.consume_type}, pay_no={data.pay_no}")
|
|
|
|