src/main/java/com/xcong/excoin/rabbit/consumer/ChatConsumer.java
@@ -24,7 +24,7 @@ @Slf4j @Component @ConditionalOnProperty(prefix = "app", name = "websocekt-job", 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); } // 收件人是否存在聊天框