浏览代码

feat:CONSUME与REFUND类型处理

alphah 2 周之前
父节点
当前提交
43f8bdf4a3
共有 1 个文件被更改,包括 12 次插入24 次删除
  1. 12 24
      backend/app/plugin/module_payment/notification/handlers/bill_handler.py

+ 12 - 24
backend/app/plugin/module_payment/notification/handlers/bill_handler.py

@@ -55,30 +55,18 @@ class BillHandler(BaseHandler[dict]):
             f"notify_reason={data.notify_reason}"
         )
 
-        # 1. 保存账单基础数据
-        # await self._save_bill_base(data, auth)
-
-        # 2. 调用支付宝查询详情
-        # try:
-        #     detail = await self._query_bill_detail(data.pay_no, auth)
-        # except Exception as e:
-        #     log.warning(f"查询账单详情失败: {e}")
-        #     return True
-
-        # 3. 保存账单和凭证详情数据
-        # if detail:
-        #     await self._save_bill_detail(detail, auth)
-
-        # ========== 标准消费通知 ==========
-        if data.consume_type == "CONSUME":
-            log.info(f"消费账单通知: pay_no={data.pay_no}, amount={data.consume_amount}, reason={data.notify_reason}")
-
-        elif data.consume_type == "REFUND":
-            log.info(
-                f"退款账单通知: pay_no={data.pay_no}, "
-                f"related_pay_no={data.related_pay_no}, "
-                f"amount={data.consume_amount}"
-            )
+        # ========== 标准消费/退款通知:落库 ==========
+        if data.consume_type in ("CONSUME", "REFUND"):
+            await self._save_bill_base(data, auth)
+
+            try:
+                detail = await self._query_bill_detail(data.pay_no, data.enterprise_id, auth)
+            except Exception as e:
+                log.warning(f"查询账单详情失败(不影响主流程): {e}")
+                detail = None
+
+            if detail:
+                await self._save_bill_detail(detail, auth)
 
         # ========== 转账通知(企业码扩展) ==========
         elif data.consume_type == "TRANSFER":