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 | 31 ++++++++++++++++++++++++-------
1 files changed, 24 insertions(+), 7 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 f307044..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
@@ -56,7 +56,8 @@
if (cache == null) {
return new LinkedList<OtcOnlineChatMessage>();
}
- List<OtcOnlineChatMessage> result = new ArrayList<OtcOnlineChatMessage>(cache);
+ return cache;
+ /*List<OtcOnlineChatMessage> result = new ArrayList<OtcOnlineChatMessage>(cache);
int start = cacheIndex(messageId, result);
// start = start == 0 ? start : start + 1;// 空消息则表示首页，消息索引的后一条为起始
int end = start + pageSize;
@@ -71,7 +72,7 @@
// result.addAll(cache);
List<OtcOnlineChatMessage> list = result.subList(start, end);
- return list;
+ return list;*/
}
public List<OtcOnlineChatMessage> cacheGetList(String messageId, int pageSize, String orderNo, String clicentType) {
@@ -193,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
@@ -215,7 +222,7 @@
messageUser.setCustomerUnreadmsg(messageUser.getCustomerUnreadmsg() + 1);
messageUser.setDeleteStatus(0);
}
- }
+ }*/
updateMessageUser(messageUser);
}
@@ -230,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
@@ -255,7 +270,7 @@
messageUser.setUserUnreadmsg(messageUser.getUserUnreadmsg() + 1);
messageUser.setDeleteStatus(0);
}
- }
+ }*/
updateMessageUser(messageUser);
}
@@ -271,7 +286,9 @@
for (OtcOnlineChatMessage m : list) {
ids.add(m.getUuid().toString());
}
- tipService.deleteTip(ids);
+ if (!ids.isEmpty()) {
+ tipService.deleteTip(ids);
+ }
}
public void updateMessageUser(OtcMessageUser messageUser) {
--
Gitblit v1.9.3