feat:添加测试接口

recommend-server-service/src/main/java/com/tzld/piaoquan/recommend/server/model/FilterVideoRequest.java

@@ -0,0 +1,27 @@
+package com.tzld.piaoquan.recommend.server.model;
+
+import lombok.AllArgsConstructor;
+import lombok.Data;
+import lombok.NoArgsConstructor;
+
+import java.util.List;
+
+@Data
+@NoArgsConstructor
+@AllArgsConstructor
+public class FilterVideoRequest {
+
+    private List<Long> videoIds;
+
+    private String uid;
+
+    private String mid;
+
+    private Long hotSceneType;
+
+    private String cityCode;
+
+    private String clientIP;
+
+    private Integer appType;
+}

recommend-server-service/src/main/java/com/tzld/piaoquan/recommend/server/service/filter/strategy/BlacklistContainer.java

@@ -346,6 +346,10 @@ public class BlacklistContainer {
 
     private void filterLogUpload(String uid, String cityCode, Long hotSceneType, String clientIp, String fullUserType, String blacklistType, String mid, String usedScene, Integer appType) {
         try {
+            // 开发测试使用的场景，不上传日志
+            if ("devtest".equals(usedScene)){
+                return;
+            }
             String[] split = fullUserType.split(CONNECTOR_STR);
             Map<String, String> logMap = new HashMap<>();
             logMap.put("uid", StringUtils.isNotBlank(uid) ? uid : "");

recommend-server-service/src/main/java/com/tzld/piaoquan/recommend/server/web/RecommendV2Controller.java

@@ -4,14 +4,19 @@ import com.google.protobuf.InvalidProtocolBufferException;
 import com.tzld.piaoquan.recommend.server.client.ProtobufUtils;
 import com.tzld.piaoquan.recommend.server.gen.recommend.RecommendRequest;
 import com.tzld.piaoquan.recommend.server.gen.recommend.RecommendResponse;
+import com.tzld.piaoquan.recommend.server.model.FilterVideoRequest;
 import com.tzld.piaoquan.recommend.server.service.VideoRecommendService;
+import com.tzld.piaoquan.recommend.server.service.filter.strategy.BlacklistContainer;
 import lombok.extern.slf4j.Slf4j;
 import org.slf4j.MDC;
 import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.web.bind.annotation.PostMapping;
 import org.springframework.web.bind.annotation.RequestBody;
 import org.springframework.web.bind.annotation.RequestMapping;
 import org.springframework.web.bind.annotation.RestController;
 
+import java.util.Map;
+
 /**
  * @author dyp
  */
@@ -20,6 +25,8 @@ import org.springframework.web.bind.annotation.RestController;
 public class RecommendV2Controller {
     @Autowired
     private VideoRecommendService videoRecommendService;
+    @Autowired
+    private BlacklistContainer blacklistContainer;
 //
 //    @Resource
 //    TopRecommendPipeline topRecommendPipeline;
@@ -54,6 +61,21 @@ public class RecommendV2Controller {
         return result;
     }
 
+    @PostMapping("/filterVideos")
+    public String filterVideos(@RequestBody FilterVideoRequest request){
+        blacklistContainer.filterUnsafeVideoByUser(
+                request.getVideoIds(),
+                request.getUid(),
+                request.getHotSceneType(),
+                request.getCityCode(),
+                request.getClientIP(),
+                request.getMid(),
+                "devtest",
+                request.getAppType()
+        );
+        return null;
+    }
+
 //    @RequestMapping("/test/feedByRec")
 //    public String feedByRec(@RequestBody RecommendRequest httpRequest) {
 //        MDC.put("appType", String.valueOf(httpRequest.getAppType()));