From 5b51b9fb6eaaa148a8c981ae17ce98683db3ae63 Mon Sep 17 00:00:00 2001
From: zyy <zyy@email.com>
Date: Sat, 11 Oct 2025 14:45:51 +0800
Subject: [PATCH] 菜单消息提示
---
trading-order-service/src/main/java/com/yami/trading/service/chat/otc/OtcOnlineChatMessageServiceImpl.java | 17 ++++++++++-------
1 files changed, 10 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 47df90d..f307044 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
@@ -6,6 +6,7 @@
import com.yami.trading.bean.chat.domain.OtcOnlineChatMessage;
import com.yami.trading.bean.model.User;
import com.yami.trading.bean.model.UserRecom;
+import com.yami.trading.common.constants.RedisKeys;
import com.yami.trading.common.constants.TipConstants;
import com.yami.trading.common.exception.BusinessException;
import com.yami.trading.common.util.DateUtils;
@@ -20,6 +21,7 @@
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.context.event.ContextRefreshedEvent;
import org.springframework.context.event.EventListener;
+import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.stereotype.Service;
import java.net.URLDecoder;
@@ -43,6 +45,8 @@
private C2cOrderService c2cOrderService;
@Autowired
private OtcMessageUserService otcMessageUserService;
+ @Autowired
+ RedisTemplate redisTemplate;
private Map<String, List<OtcOnlineChatMessage>> cahce_chat = new ConcurrentHashMap<String, List<OtcOnlineChatMessage>>();
private Map<String, OtcMessageUser> cahce_user = new ConcurrentHashMap<String, OtcMessageUser>();
@@ -199,7 +203,7 @@
if ("read".equals(type)) {
messageUser.setCustomerUnreadmsg(0);
} else if ("write".equals(type)) {
- messageUser.setUserUnreadmsg(messageUser.getCustomerUnreadmsg() + 1);
+ messageUser.setUserUnreadmsg(messageUser.getUserUnreadmsg() + 1);
messageUser.setDeleteStatus(0);
}
}
@@ -208,7 +212,7 @@
if ("read".equals(type)) {
messageUser.setUserUnreadmsg(0);
} else if ("write".equals(type)) {
- messageUser.setCustomerUnreadmsg(messageUser.getUserUnreadmsg() + 1);
+ messageUser.setCustomerUnreadmsg(messageUser.getCustomerUnreadmsg() + 1);
messageUser.setDeleteStatus(0);
}
}
@@ -236,9 +240,7 @@
if ("read".equals(type)) {
int removeTipNum = 0;
messageUser.setCustomerUnreadmsg(0);
- if (removeTipNum > 0) {
- removeTips(messageUser.getOrderNo(), removeTipNum);
- }
+ removeTips(messageUser.getOrderNo(), removeTipNum);
} else if ("write".equals(type)) {
messageUser.setUserUnreadmsg(messageUser.getUserUnreadmsg() + 1);
messageUser.setDeleteStatus(0);
@@ -247,9 +249,10 @@
// 下单用户发送
else if (partyId.equals(orderUserId)) {
if ("read".equals(type)) {
- messageUser.setUserUnreadmsg(0);
+ messageUser.setCustomerUnreadmsg(0);
+ removeTips(messageUser.getOrderNo(), 0);
} else if ("write".equals(type)) {
- messageUser.setCustomerUnreadmsg(messageUser.getUserUnreadmsg() + 1);
+ messageUser.setUserUnreadmsg(messageUser.getUserUnreadmsg() + 1);
messageUser.setDeleteStatus(0);
}
}
--
Gitblit v1.9.3