C2C

zyy

2025-10-16 d1263c5f0cf0f9643b9d1d16584fd09f8bbf2b33

 trading-order-service/src/main/java/com/yami/trading/service/chat/otc/OtcOnlineChatMessageServiceImpl.java

@@ -56,7 +56,8 @@
        if (cache == null) {
            return new LinkedList<OtcOnlineChatMessage>();
        }
        List<OtcOnlineChatMessage> result = new ArrayList<OtcOnlineChatMessage>(cache);
        return cache;
        /*List<OtcOnlineChatMessage> result = new ArrayList<OtcOnlineChatMessage>(cache);
        int start = cacheIndex(messageId, result);
//      start = start == 0 ? start : start + 1;// 空消息则表示首页，消息索引的后一条为起始
        int end = start + pageSize;
@@ -71,7 +72,7 @@
//      result.addAll(cache);
        List<OtcOnlineChatMessage> list = result.subList(start, end);

        return list;
        return list;*/
    }

    public List<OtcOnlineChatMessage> cacheGetList(String messageId, int pageSize, String orderNo, String clicentType) {
@@ -193,7 +194,13 @@
            saveCreateByOrderNo(orderNo);
            messageUser = cahce_user.get(orderNo);
        }
        C2cOrder c2cOrder = c2cOrderService.get(orderNo);
        if ("read".equals(type)) {
            messageUser.setUserUnreadmsg(0);
        } else if ("write".equals(type)) {
            messageUser.setCustomerUnreadmsg(messageUser.getCustomerUnreadmsg() + 1);
            messageUser.setDeleteStatus(0);
        }
        /*C2cOrder c2cOrder = c2cOrderService.get(orderNo);
        // 承兑商ID
        String c2cUserId = c2cOrder.getC2cUserPartyId();
        // 下单用户ID
@@ -215,7 +222,7 @@
                messageUser.setCustomerUnreadmsg(messageUser.getCustomerUnreadmsg() + 1);
                messageUser.setDeleteStatus(0);
            }
        }
        }*/
        updateMessageUser(messageUser);
    }

@@ -230,7 +237,15 @@
            saveCreateByOrderNo(orderNo);
            messageUser = cahce_user.get(orderNo);
        }
        C2cOrder c2cOrder = c2cOrderService.get(orderNo);
        if ("read".equals(type)) {
            messageUser.setCustomerUnreadmsg(0);
            removeTips(messageUser.getOrderNo(), 0);
        } else if ("write".equals(type)) {
            messageUser.setUserUnreadmsg(messageUser.getUserUnreadmsg() + 1);
            messageUser.setDeleteStatus(0);
        }

        /*C2cOrder c2cOrder = c2cOrderService.get(orderNo);
        // 承兑商ID
        String c2cUserId = c2cOrder.getC2cUserPartyId();
        // 下单用户ID
@@ -255,7 +270,7 @@
                messageUser.setUserUnreadmsg(messageUser.getUserUnreadmsg() + 1);
                messageUser.setDeleteStatus(0);
            }
        }
        }*/
        updateMessageUser(messageUser);
    }

@@ -271,7 +286,9 @@
        for (OtcOnlineChatMessage m : list) {
            ids.add(m.getUuid().toString());
        }
        tipService.deleteTip(ids);
        if (!ids.isEmpty()) {
            tipService.deleteTip(ids);
        }
    }

    public void updateMessageUser(OtcMessageUser messageUser) {