modify

Helius

2021-05-28 fbdc2d590860fc73b4db79e67c5928a16e632886

modify

 src/main/java/com/xcong/excoin/rabbit/consumer/ChatConsumer.java

@@ -48,13 +48,12 @@
        Long toId = chat.getTargetId();
        Long fromId = chat.getFromMemberId();

        log.info("--->{}, {}", toId, fromId);
        // 发送人是否存在聊天框
        OtcMsgUserListEntity fromList = otcMsgUserListDao.selectChatListByToAndFrom(toId, fromId);
        if (fromList == null) {
            OtcMsgUserListEntity from = new OtcMsgUserListEntity();
            from.setMemberId(toId);
            from.setTargetId(fromId);
            from.setMemberId(fromId);
            from.setTargetId(toId);
            from.setIsRead(OtcMsgUserListEntity.ISREAD_ONE);
            from.setLastMsgTime(new Date());
            otcMsgUserListDao.insert(from);

 src/main/resources/application.yml

@@ -79,6 +79,10 @@
    port: 5672
    username: ct_rabbit
    password: 123456
#    host: 154.91.195.170
#    port: 5672
#    username: yunding
#    password: yunding123
    publisher-confirm-type: correlated