From d1263c5f0cf0f9643b9d1d16584fd09f8bbf2b33 Mon Sep 17 00:00:00 2001
From: zyy <zyy@email.com>
Date: Thu, 16 Oct 2025 17:22:10 +0800
Subject: [PATCH] C2C
---
trading-order-service/src/main/java/com/yami/trading/service/chat/otc/OtcOnlineChatMessageServiceImpl.java | 22 ++++++++++++++++++----
1 files changed, 18 insertions(+), 4 deletions(-)
diff --git a/trading-order-service/src/main/java/com/yami/trading/service/chat/otc/OtcOnlineChatMessageServiceImpl.java b/trading-order-service/src/main/java/com/yami/trading/service/chat/otc/OtcOnlineChatMessageServiceImpl.java
index 04015fa..5f8f6cf 100644
--- a/trading-order-service/src/main/java/com/yami/trading/service/chat/otc/OtcOnlineChatMessageServiceImpl.java
+++ b/trading-order-service/src/main/java/com/yami/trading/service/chat/otc/OtcOnlineChatMessageServiceImpl.java
@@ -194,7 +194,13 @@
saveCreateByOrderNo(orderNo);
messageUser = cahce_user.get(orderNo);
}
- C2cOrder c2cOrder = c2cOrderService.get(orderNo);
+ if ("read".equals(type)) {
+ messageUser.setUserUnreadmsg(0);
+ } else if ("write".equals(type)) {
+ messageUser.setCustomerUnreadmsg(messageUser.getCustomerUnreadmsg() + 1);
+ messageUser.setDeleteStatus(0);
+ }
+ /*C2cOrder c2cOrder = c2cOrderService.get(orderNo);
// 承兑商ID
String c2cUserId = c2cOrder.getC2cUserPartyId();
// 下单用户ID
@@ -216,7 +222,7 @@
messageUser.setCustomerUnreadmsg(messageUser.getCustomerUnreadmsg() + 1);
messageUser.setDeleteStatus(0);
}
- }
+ }*/
updateMessageUser(messageUser);
}
@@ -231,7 +237,15 @@
saveCreateByOrderNo(orderNo);
messageUser = cahce_user.get(orderNo);
}
- C2cOrder c2cOrder = c2cOrderService.get(orderNo);
+ if ("read".equals(type)) {
+ messageUser.setCustomerUnreadmsg(0);
+ removeTips(messageUser.getOrderNo(), 0);
+ } else if ("write".equals(type)) {
+ messageUser.setUserUnreadmsg(messageUser.getUserUnreadmsg() + 1);
+ messageUser.setDeleteStatus(0);
+ }
+
+ /*C2cOrder c2cOrder = c2cOrderService.get(orderNo);
// 承兑商ID
String c2cUserId = c2cOrder.getC2cUserPartyId();
// 下单用户ID
@@ -256,7 +270,7 @@
messageUser.setUserUnreadmsg(messageUser.getUserUnreadmsg() + 1);
messageUser.setDeleteStatus(0);
}
- }
+ }*/
updateMessageUser(messageUser);
}
--
Gitblit v1.9.3