From e9b82575bf16026c60bbf5ee4e42ca74358eb36c Mon Sep 17 00:00:00 2001 From: Helius <wangdoubleone@gmail.com> Date: Wed, 02 Jun 2021 11:27:46 +0800 Subject: [PATCH] modify --- src/main/java/com/xcong/excoin/rabbit/consumer/ChatConsumer.java | 5 ++++- 1 files changed, 4 insertions(+), 1 deletions(-) diff --git a/src/main/java/com/xcong/excoin/rabbit/consumer/ChatConsumer.java b/src/main/java/com/xcong/excoin/rabbit/consumer/ChatConsumer.java index 9a2c634..770af5c 100644 --- a/src/main/java/com/xcong/excoin/rabbit/consumer/ChatConsumer.java +++ b/src/main/java/com/xcong/excoin/rabbit/consumer/ChatConsumer.java @@ -24,7 +24,7 @@ @Slf4j @Component -//@ConditionalOnProperty(prefix = "app", name = "rabbit-consumer", havingValue = "true") +@ConditionalOnProperty(prefix = "app", name = "websocket-job", havingValue = "true") public class ChatConsumer { @Autowired @@ -57,6 +57,9 @@ from.setIsRead(OtcMsgUserListEntity.ISREAD_TWO); from.setLastMsgTime(new Date()); otcMsgUserListDao.insert(from); + } else { + fromList.setLastMsgTime(new Date()); + otcMsgUserListDao.updateById(fromList); } // 收件人是否存在聊天框 -- Gitblit v1.9.1