1.PHOU qlm

src/main/java/com/zx/dataservice/service/impl/ChoiceTempIndexServiceImpl.java

@@ -472,13 +472,13 @@ public class ChoiceTempIndexServiceImpl implements ChoiceTempIndexService {
 
                         for (String key2 : WSOptions.keySet()){  // 所有的需要推送的客户
                             // 如果该股票需要风控
-                            if(DataOptions.get("keyall").contains((WSOptions.get(key2).split("_")[0]+entry.getKey().toUpperCase()))){  // 存在该用户的该股票的风控 记录
+                            if(DataOptions.get("keyall").contains((WSOptions.get(key2).split("_")[0]+"_"+entry.getKey().toUpperCase()))){  // 存在该用户的该股票的风控 记录
                                 for (String key : DataOptions.keySet()) {  // 所有的需要风控的 客户  BTC_BTC_hy  LTC_hy  000001.SZ_hy  LTC_test  test_BTC_BTC
                                     // 风控 逻辑
                                     if("keyall".equals(key)){
                                         continue;
                                     }
-                                    if (key.contains(entry.getKey())) {// 存在该股票的风控  LTC_hy . contains (LTC)
+                                    if (key.contains((WSOptions.get(key2).split("_")[0]+"_"+entry.getKey().toUpperCase()))) {// 存在该股票的风控  LTC_hy . contains (LTC)
                                         StockRestPojo stockRestPojoRisk = getRiskNow(stockRestPojo, key, DataOptions.get(key)); // 风控后的数据 //tocode & mini & risk & multiples & status
                                         stockRestPojoList.add(stockRestPojoRisk);
                                         stockRestRedisVO = new StockRestRedisVO();
@@ -512,7 +512,6 @@ public class ChoiceTempIndexServiceImpl implements ChoiceTempIndexService {
                                         stockRestRedisVO.setSell3_num(stockRestPojo.getSellvolume3());
                                         stockRestRedisVO.setSell4_num(stockRestPojo.getSellvolume4());
                                         stockRestRedisVO.setSell5_num(stockRestPojo.getSellvolume5());
-
                                         mapws.get("stockRestRedisVO_" + WSOptions.get(key2).split("_")[0]).add(stockRestRedisVO);   //  stockRestRedisVO_hy
                                     }
                                 }