1

zj

2024-08-08 a9e9e1207ce417388b1d8f03df5833cea24939b7

 websocketSerivce/src/main/java/org/example/websocket/server/WsServer.java

@@ -239,8 +239,9 @@
                    .collect(Collectors.toList());
        }
        //自选标记
        if(null != wsBo.getIsMarker()){
            List<String> list = Arrays.asList(wsBo.getIsMarker().split(","));
        String mark = RedisUtil.get(wsBo.getUserId() + "_mark");
        if(StringUtils.isNoneEmpty(mark)){
            List<String> list = Arrays.asList(mark.split(","));
            redisValueMap.stream()
                    .filter(data -> list.contains(data.getBuyAndSell()))
                    .forEach(data -> data.setMarker(true));