From 7d21b822449ea2b791fa9db414f50a5a171c79db Mon Sep 17 00:00:00 2001
From: zyy <zyy@email.com>
Date: Fri, 10 Oct 2025 16:17:43 +0800
Subject: [PATCH] 联系卖家消息提示
---
trading-order-service/src/main/java/com/yami/trading/service/chat/otc/OtcOnlineChatMessageServiceImpl.java | 12 ++++++++----
1 files changed, 8 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 47df90d..6c7a6c8 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);
}
}
@@ -247,9 +251,9 @@
// 下单用户发送
else if (partyId.equals(orderUserId)) {
if ("read".equals(type)) {
- messageUser.setUserUnreadmsg(0);
+ messageUser.setCustomerUnreadmsg(0);
} else if ("write".equals(type)) {
- messageUser.setCustomerUnreadmsg(messageUser.getUserUnreadmsg() + 1);
+ messageUser.setUserUnreadmsg(messageUser.getUserUnreadmsg() + 1);
messageUser.setDeleteStatus(0);
}
}
--
Gitblit v1.9.3