新版仿ok交易所-后端
C2C
zyy
2025-10-16 d1263c5f0cf0f9643b9d1d16584fd09f8bbf2b33
C2C
1 files modified
22 ■■■■ changed files
trading-order-service/src/main/java/com/yami/trading/service/chat/otc/OtcOnlineChatMessageServiceImpl.java 22 ●●●● patch | view | raw | blame | history
trading-order-service/src/main/java/com/yami/trading/service/chat/otc/OtcOnlineChatMessageServiceImpl.java
@@ -194,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
@@ -216,7 +222,7 @@
                messageUser.setCustomerUnreadmsg(messageUser.getCustomerUnreadmsg() + 1);
                messageUser.setDeleteStatus(0);
            }
        }
        }*/
        updateMessageUser(messageUser);
    }
@@ -231,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
@@ -256,7 +270,7 @@
                messageUser.setUserUnreadmsg(messageUser.getUserUnreadmsg() + 1);
                messageUser.setDeleteStatus(0);
            }
        }
        }*/
        updateMessageUser(messageUser);
    }