From 0b0f69a4545fbb030e2a5bdb7a60d88ebdbc6226 Mon Sep 17 00:00:00 2001 From: Damonny <826010988@qq.com> Date: Fri, 21 Feb 2025 22:23:21 +0800 Subject: [PATCH] =?UTF-8?q?update:=E8=AE=A2=E5=8D=95=E6=89=A7=E8=A1=8C?= =?UTF-8?q?=E4=BF=AE=E6=94=B9?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../DouDianOrderCatchServiceImpl.java | 21 ++++++++++++------- 1 file changed, 14 insertions(+), 7 deletions(-) diff --git a/yudao-module-haoka/yudao-module-haoka-biz/src/main/java/cn/iocoder/yudao/module/haoka/service/orderCatch/DouDianOrderCatchServiceImpl.java b/yudao-module-haoka/yudao-module-haoka-biz/src/main/java/cn/iocoder/yudao/module/haoka/service/orderCatch/DouDianOrderCatchServiceImpl.java index 3d14e188e3..6213d99ded 100644 --- a/yudao-module-haoka/yudao-module-haoka-biz/src/main/java/cn/iocoder/yudao/module/haoka/service/orderCatch/DouDianOrderCatchServiceImpl.java +++ b/yudao-module-haoka/yudao-module-haoka-biz/src/main/java/cn/iocoder/yudao/module/haoka/service/orderCatch/DouDianOrderCatchServiceImpl.java @@ -47,6 +47,7 @@ import com.doudian.open.msg.refund_ReturnApplyAgreed.param.RefundReturnApplyAgre import com.doudian.open.msg.trade_TradeCanceled.param.TradeTradeCanceledParam; import com.doudian.open.msg.trade_TradePaid.param.TradeTradePaidParam; import com.doudian.open.msg.trade_TradePending.param.TradeTradePendingParam; +import com.doudian.open.utils.JsonUtil; import jakarta.annotation.Resource; import lombok.extern.slf4j.Slf4j; import org.apache.commons.lang3.StringUtils; @@ -98,7 +99,7 @@ public class DouDianOrderCatchServiceImpl implements OrderCatchService { public void catchOrders(List catchRepVO) { // 插入日志 log.info("抖音消息推送订单,抓取/更新 订单"); - log.error("抖音订单推送:{}", catchRepVO); + log.error("抖音订单推送:{}", JsonUtil.toJson(catchRepVO)); try { Gson gson = new Gson(); for (Message message : catchRepVO) { @@ -106,16 +107,20 @@ public class DouDianOrderCatchServiceImpl implements OrderCatchService { String msgId = message.getMsgId(); Object data = message.getData(); // 插入日志 - if("doudian_refund_RefundCreated".equals(tag)){ + if("200".equals(tag)){ +// 200 doudian_refund_RefundCreated // 买家发起售后申请消息 RefundRefundCreatedParam refundRefundCreatedParam = gson.fromJson(message.getData()+"", RefundRefundCreatedParam.class); - } else if("doudian_refund_RefundAgreed".equals(tag)) { + } else if("201".equals(tag)) { +// 201 doudian_refund_RefundAgreed // 同意退款消息 RefundRefundAgreedParam refundRefundAgreedParam = gson.fromJson(message.getData()+"", RefundRefundAgreedParam.class); - } else if("doudian_refund_ReturnApplyAgreed".equals(tag)) { + } else if("202".equals(tag)) { +// 202 doudian_refund_ReturnApplyAgreed // 同意退货申请消息 RefundReturnApplyAgreedParam refundReturnApplyAgreedParam = gson.fromJson(message.getData()+"", RefundReturnApplyAgreedParam.class); - } else if("doudian_trade_TradePaid".equals(tag)) { + } else if("101".equals(tag)) { +// 101 doudian_trade_TradePaid // 订单支付/确认消息 抓取订单 TradeTradePaidParam tradeTradePaidParam = gson.fromJson(message.getData()+"", TradeTradePaidParam.class); // 订单id @@ -293,10 +298,12 @@ public class DouDianOrderCatchServiceImpl implements OrderCatchService { for (List ordersDOS : GroupListUtil.groupList(orderListAll, 50)) { batchDecryptOrderAndUpdate(ordersDOS); } - } else if("doudian_trade_TradeCanceled".equals(tag)) { + } else if("106".equals(tag)) { +// 106 doudian_trade_TradeCanceled // 订单取消消息 TradeTradeCanceledParam tradeTradeCanceledParam = gson.fromJson(message.getData()+"", TradeTradeCanceledParam.class); - } else if("doudian_trade_TradePending".equals(tag)) { + } else if("110".equals(tag)) { +// 110 doudian_trade_TradePending // 订单已支付待处理 TradeTradePendingParam tradeTradePendingParam = gson.fromJson(message.getData()+"", TradeTradePendingParam.class); } else {