1

zyy

2026-03-24 513e5442723f501525bf9ca6210b16561e5d3a2b

 trading-order-admin/src/main/java/com/yami/trading/admin/controller/chat/NewAdminOnlineChatController.java

@@ -1,6 +1,8 @@
package com.yami.trading.admin.controller.chat;


import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.baomidou.mybatisplus.core.toolkit.CollectionUtils;
import com.yami.trading.bean.chat.domain.MessageUser;
import com.yami.trading.bean.chat.domain.OnlineChatMessage;
import com.yami.trading.bean.model.Customer;
@@ -10,6 +12,7 @@
import com.yami.trading.common.util.DateUtils;
import com.yami.trading.common.util.StringUtils;
import com.yami.trading.common.web.ResultObject;
import com.yami.trading.dao.chat.OnlinechatMessageMapper;
import com.yami.trading.security.common.util.SecurityUtils;
import com.yami.trading.service.AwsS3OSSFileService;
import com.yami.trading.service.chat.online.OnlineChatMessageService;
@@ -46,6 +49,9 @@

    @Autowired
    AwsS3OSSFileService awsS3OSSFileService;

    @Autowired
    OnlinechatMessageMapper onlinechatMessageMapper;

    /**
     * 在线聊天-人员列表
@@ -165,6 +171,16 @@
                        onlineChatVisitorMessageService.updateUnread(partyid, "customer", "read");
                    }
                } else {
                    // 修复：缓存空时，直接查询数据库兜底
                    if (CollectionUtils.isEmpty(list)) {
                        QueryWrapper<OnlineChatMessage> wrapper = new QueryWrapper<>();
                        wrapper.eq("party_id", partyid)
                                .orderByDesc("create_time")
                                .last("limit 30");
                        list = onlinechatMessageMapper.selectList(wrapper);
                        onlineChatMessageService.putMessage(partyid, list);
                    }

                    if (cacheMessageUser != null && cacheMessageUser.getCustomerUnreadmsg() > 0) {
                        onlineChatMessageService.updateUnread(partyid, "customer", "read");
                    }