czg_team/cashier_server
7
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

MQ

Browse Source
This commit is contained in:
wangw
2026-01-09 15:59:37 +08:00
parent 423423ca0b
commit 7ac540dfa9
1 changed files with 10 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

16
cash-api/order-server/src/main/java/com/czg/mq/EntryManagerMqListener.java
View File

@@ -48,20 +48,24 @@ public class EntryManagerMqListener {
) )
@RabbitHandler @RabbitHandler
public void handle(Message message, Channel channel, String msg) throws IOException { public void handle(Message message, Channel channel, String msg) throws IOException {
log.info("进件1MQ对接开始shopId:{}", msg);
String messageId = message.getMessageProperties().getMessageId(); String messageId = message.getMessageProperties().getMessageId();
if (hasMessageId(messageId)) { log.info("进件0MQ对接开始shopId:{}messageId:{}", msg, messageId);
return; // if (hasMessageId(messageId)) {
} // return;
// }
try { try {
Long shopId = Long.valueOf(msg); Long shopId = Long.valueOf(msg);
// 将唯一标识添加到日志上下文 // 将唯一标识添加到日志上下文
ThreadContext.put("traceId", messageId); // ThreadContext.put("traceId", messageId);
log.info("进件2MQ对接开始shopId:{}", msg);
// 安全转换shopId // 安全转换shopId
if (shopId == null) { if (shopId == null) {
channel.basicNack(message.getMessageProperties().getDeliveryTag(), false, false); channel.basicNack(message.getMessageProperties().getDeliveryTag(), false, false);
return; return;
} }
AggregateMerchantVO entry = shopDirectMerchantService.getEntry(Long.valueOf(msg)); AggregateMerchantVO entry = shopDirectMerchantService.getEntry(Long.valueOf(msg));
log.info("进件3MQ对接开始shopId:{}", msg);
if (entry != null) { if (entry != null) {
EntryManager.uploadParamImage(entry); EntryManager.uploadParamImage(entry);
List<String> platform = new ArrayList<>(); List<String> platform = new ArrayList<>();
@@ -97,9 +101,9 @@ public class EntryManagerMqListener {
channel.basicNack(message.getMessageProperties().getDeliveryTag(), false, false); channel.basicNack(message.getMessageProperties().getDeliveryTag(), false, false);
} finally { } finally {
delMessageId(messageId); // delMessageId(messageId);
// 清除日志上下文信息 // 清除日志上下文信息
ThreadContext.remove("messageId"); // ThreadContext.remove("messageId");
} }
} }