szz
/
ShiShiYiBan
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

update:订单执行修改

This commit is contained in:
Damonny 2025-02-21 22:23:21 +08:00
parent c8559a5451
commit 0b0f69a454
1 changed files with 14 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

21
yudao-module-haoka/yudao-module-haoka-biz/src/main/java/cn/iocoder/yudao/module/haoka/service/orderCatch/DouDianOrderCatchServiceImpl.java
View File

@ -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_TradeCanceled.param.TradeTradeCanceledParam;
import com.doudian.open.msg.trade_TradePaid.param.TradeTradePaidParam; import com.doudian.open.msg.trade_TradePaid.param.TradeTradePaidParam;
import com.doudian.open.msg.trade_TradePending.param.TradeTradePendingParam; import com.doudian.open.msg.trade_TradePending.param.TradeTradePendingParam;
import com.doudian.open.utils.JsonUtil;
import jakarta.annotation.Resource; import jakarta.annotation.Resource;
import lombok.extern.slf4j.Slf4j; import lombok.extern.slf4j.Slf4j;
import org.apache.commons.lang3.StringUtils; import org.apache.commons.lang3.StringUtils;
@ -98,7 +99,7 @@ public class DouDianOrderCatchServiceImpl implements OrderCatchService {
public void catchOrders(List<Message> catchRepVO) { public void catchOrders(List<Message> catchRepVO) {
// 插入日志 // 插入日志
log.info("抖音消息推送订单，抓取/更新 订单"); log.info("抖音消息推送订单，抓取/更新 订单");
log.error("抖音订单推送:{}", catchRepVO); log.error("抖音订单推送:{}", JsonUtil.toJson(catchRepVO));
try { try {
Gson gson = new Gson(); Gson gson = new Gson();
for (Message message : catchRepVO) { for (Message message : catchRepVO) {
@ -106,16 +107,20 @@ public class DouDianOrderCatchServiceImpl implements OrderCatchService {
String msgId = message.getMsgId(); String msgId = message.getMsgId();
Object data = message.getData(); 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); 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); 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); 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); TradeTradePaidParam tradeTradePaidParam = gson.fromJson(message.getData()+"", TradeTradePaidParam.class);
// 订单id // 订单id
@ -293,10 +298,12 @@ public class DouDianOrderCatchServiceImpl implements OrderCatchService {
for (List<OrdersDO> ordersDOS : GroupListUtil.groupList(orderListAll, 50)) { for (List<OrdersDO> ordersDOS : GroupListUtil.groupList(orderListAll, 50)) {
batchDecryptOrderAndUpdate(ordersDOS); 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); 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); TradeTradePendingParam tradeTradePendingParam = gson.fromJson(message.getData()+"", TradeTradePendingParam.class);
} else { } else {