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

进件标识

Browse Source
This commit is contained in:
wangw
2026-01-09 16:55:40 +08:00
parent 504e9b131c
commit e203d7275a
1 changed files with 3 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -65,7 +65,7 @@ public class EntryManagerMqListener {
channel.basicNack(deliveryTag, false, false); channel.basicNack(deliveryTag, false, false);
return; return;
} }
if (hasMessageId(String.valueOf(shopId))) { if (hasMessageId(msg)) {
return; return;
} }
try { try {
@@ -102,14 +102,14 @@ public class EntryManagerMqListener {
} catch (Exception e) { } catch (Exception e) {
log.error("进件MQ对接业务异常shopId:{}", msg, e); log.error("进件MQ对接业务异常shopId:{}", msg, e);
ShopDirectMerchant merchant = new ShopDirectMerchant(); ShopDirectMerchant merchant = new ShopDirectMerchant();
merchant.setShopId(Long.valueOf(msg)); merchant.setShopId(shopId);
merchant.setWechatStatus(PayCst.EntryStatus.REJECTED); merchant.setWechatStatus(PayCst.EntryStatus.REJECTED);
merchant.setAlipayStatus(PayCst.EntryStatus.REJECTED); merchant.setAlipayStatus(PayCst.EntryStatus.REJECTED);
merchant.setErrorMsg("系统错误，请联系管理员后重试。"); merchant.setErrorMsg("系统错误，请联系管理员后重试。");
shopDirectMerchantService.updateById(merchant); shopDirectMerchantService.updateById(merchant);
channel.basicNack(deliveryTag, false, false); channel.basicNack(deliveryTag, false, false);
} finally { } finally {
delMessageId(String.valueOf(shopId)); delMessageId(msg);
// 清除日志上下文信息 // 清除日志上下文信息
ThreadContext.remove("messageId"); ThreadContext.remove("messageId");
} }