菜单消息提示

zyy

2025-10-11 5b51b9fb6eaaa148a8c981ae17ce98683db3ae63

 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);
            }
        }
@@ -236,9 +240,7 @@
            if ("read".equals(type)) {
                int removeTipNum = 0;
                messageUser.setCustomerUnreadmsg(0);
                if (removeTipNum > 0) {
                    removeTips(messageUser.getOrderNo(), removeTipNum);
                }
                removeTips(messageUser.getOrderNo(), removeTipNum);
            } else if ("write".equals(type)) {
                messageUser.setUserUnreadmsg(messageUser.getUserUnreadmsg() + 1);
                messageUser.setDeleteStatus(0);
@@ -247,9 +249,10 @@
        // 下单用户发送
        else if (partyId.equals(orderUserId)) {
            if ("read".equals(type)) {
                messageUser.setUserUnreadmsg(0);
                messageUser.setCustomerUnreadmsg(0);
                removeTips(messageUser.getOrderNo(), 0);
            } else if ("write".equals(type)) {
                messageUser.setCustomerUnreadmsg(messageUser.getUserUnreadmsg() + 1);
                messageUser.setUserUnreadmsg(messageUser.getUserUnreadmsg() + 1);
                messageUser.setDeleteStatus(0);
            }
        }