Bladeren bron

屏蔽过滤

zhangbo 1 jaar geleden
bovenliggende
commit
b223776bcc

+ 18 - 4
recommend-server-service/src/main/java/com/tzld/piaoquan/recommend/server/service/RecommendService.java

@@ -272,11 +272,26 @@ public class RecommendService {
         }
 
         // 风险过滤
-        String RISK_SHIELD_FILTER_RULE_V1_JSON = redisTemplate.opsForValue().get("RISK_SHIELD_FILTER_RULE_V1_JSON");
+        List<String> keysRisk = new ArrayList<>();
+        keysRisk.add("RISK_SHIELD_FILTER_RULE_V1_JSON");
+        keysRisk.add("RISK_SHIELD_FILTER_VIDEO_V1_STR");
+        keysRisk.add("RISK_SHIELD_FILTER_EXPANSION_FACTOR_INT");
+        keysRisk.add("RISK_SHIELD_FILTER_FLAG_BOOL");
+        List<String> valuesRisk = redisTemplate.opsForValue().multiGet(keysRisk);
+        String RISK_SHIELD_FILTER_RULE_V1_JSON = "";
+        String RISK_SHIELD_FILTER_VIDEO_V1_STR = "";
+        String RISK_SHIELD_FILTER_EXPANSION_FACTOR_INT = "";
+        String RISK_SHIELD_FILTER_FLAG_BOOL = "";
+        if (valuesRisk != null && valuesRisk.size() == 4){
+            RISK_SHIELD_FILTER_RULE_V1_JSON = valuesRisk.get(0);
+            RISK_SHIELD_FILTER_VIDEO_V1_STR = valuesRisk.get(1);
+            RISK_SHIELD_FILTER_EXPANSION_FACTOR_INT = valuesRisk.get(2);
+            RISK_SHIELD_FILTER_FLAG_BOOL = valuesRisk.get(3);
+        }else{
+            log.error("risk rule read redis is wrong");
+        }
         Map<Integer, List<String>> appRegionFiltered = ParserUtils.parseJsonForRiskRule(RISK_SHIELD_FILTER_RULE_V1_JSON);
-        String RISK_SHIELD_FILTER_VIDEO_V1_STR = redisTemplate.opsForValue().get("RISK_SHIELD_FILTER_VIDEO_V1_STR");
         List<Long> videosWithRisk = ParserUtils.parseJsonForRiskVideos(RISK_SHIELD_FILTER_VIDEO_V1_STR);
-        String RISK_SHIELD_FILTER_EXPANSION_FACTOR_INT = redisTemplate.opsForValue().get("RISK_SHIELD_FILTER_EXPANSION_FACTOR_INT");
         int expansionFactor = 5;
         if (RISK_SHIELD_FILTER_EXPANSION_FACTOR_INT != null) {
             try {
@@ -291,7 +306,6 @@ public class RecommendService {
         } else if (expansionFactor > 25) {
             expansionFactor = 25;
         }
-        String RISK_SHIELD_FILTER_FLAG_BOOL = redisTemplate.opsForValue().get("RISK_SHIELD_FILTER_FLAG_BOOL");
         Boolean riskFilterFlag = false;
         if (RISK_SHIELD_FILTER_FLAG_BOOL != null) {
             try {