feat:添加内容库

supply-demand-engine-core/src/main/java/com/tzld/piaoquan/sde/service/ExecutionTaskService.java

@@ -53,4 +53,7 @@ public interface ExecutionTaskService {
      * 聚类
      */
     void manualClusterExecutionTaskCreateHandler(String params);
+
+    void batchCreateDeconstructTask(String dtList, String contentScope);
+
 }

supply-demand-engine-core/src/main/java/com/tzld/piaoquan/sde/service/impl/ExecutionTaskServiceImpl.java

@@ -534,4 +534,18 @@ public class ExecutionTaskServiceImpl implements ExecutionTaskService {
         log.info("manualClusterExecutionTaskCreateHandler finish cost = {}ms", costMs);
     }
 
+    @Override
+    public void batchCreateDeconstructTask(String dtList, String contentScope) {
+        if (StringUtils.isEmpty(dtList)) {
+            return;
+        }
+        for (String dt : dtList.split(",")) {
+            JSONObject paramJson = new JSONObject();
+            paramJson.put("table", "loghubods.supply_demand_task_video_collect_exp_top");
+            paramJson.put("contentScope", contentScope);
+            paramJson.put("dt", dt);
+            this.videoExecutionTaskCreateHandler(paramJson.toJSONString());
+        }
+    }
+
 }

supply-demand-engine-service/src/main/java/com/tzld/piaoquan/sde/controller/ExecutionTaskController.java

@@ -11,10 +11,7 @@ import com.tzld.piaoquan.sde.service.ExecutionTaskService;
 import io.swagger.v3.oas.annotations.Operation;
 import lombok.extern.slf4j.Slf4j;
 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 org.springframework.web.bind.annotation.*;
 
 /**
  * @author supeng
@@ -44,4 +41,11 @@ public class ExecutionTaskController {
     public CommonResponse<SdExecutionTask> get(@RequestBody CommonRequest<ExecutionTaskGetParam> request) {
         return CommonResponse.create(executionTaskService.get(request));
     }
+
+    @Operation(summary = "批量创建解构任务")
+    @GetMapping("/batchCreateDeconstructTask")
+    public CommonResponse<Void> batchCreateDeconstructTask(@RequestParam(value = "dtList") String dtList, @RequestParam(value = "contentScope") String contentScope) {
+        executionTaskService.batchCreateDeconstructTask(dtList, contentScope);
+        return CommonResponse.create();
+    }
 }