modify

Helius

2021-05-31 018f6f9b1ab486697d624f493a7ed5c02d29dd10

 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
@@ -54,7 +54,7 @@
            OtcMsgUserListEntity from = new OtcMsgUserListEntity();
            from.setMemberId(fromId);
            from.setTargetId(toId);
            from.setIsRead(OtcMsgUserListEntity.ISREAD_ONE);
            from.setIsRead(OtcMsgUserListEntity.ISREAD_TWO);
            from.setLastMsgTime(new Date());
            otcMsgUserListDao.insert(from);
        }
@@ -65,7 +65,7 @@
            OtcMsgUserListEntity from = new OtcMsgUserListEntity();
            from.setMemberId(toId);
            from.setTargetId(fromId);
            from.setIsRead(OtcMsgUserListEntity.ISREAD_TWO);
            from.setIsRead(OtcMsgUserListEntity.ISREAD_ONE);
            from.setLastMsgTime(new Date());
            otcMsgUserListDao.insert(from);
        } else {