update properties

supply-demand-engine-core/src/main/java/com/tzld/piaoquan/sde/model/dto/SdExecutionTaskPropertiesDTO.java

@@ -0,0 +1,11 @@
+package com.tzld.piaoquan.sde.model.dto;
+
+import lombok.Data;
+
+@Data
+public class SdExecutionTaskPropertiesDTO {
+    /**
+     * 内容范围
+     */
+    private String contentScope;
+}

supply-demand-engine-core/src/main/java/com/tzld/piaoquan/sde/model/entity/SdExecutionTask.java

@@ -30,10 +30,11 @@ public class SdExecutionTask {
      * @see com.tzld.piaoquan.sde.common.enums.ContentTypeEnum
      */
     private Integer contentType;
-//    /**
-//     * 内容ID，videoId等
-//     */
-//    private String contentId;
+    /**
+     * 属性配置等：JSON
+     * @see com.tzld.piaoquan.sde.model.dto.SdExecutionTaskPropertiesDTO
+     */
+    private String properties;
     /**
      * 执行任务编号：1 DECONSTRUCT(解构), 2 CLUSTER(聚类)
      *

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

@@ -1,5 +1,6 @@
 package com.tzld.piaoquan.sde.service.impl;
 
+import com.alibaba.fastjson.JSONObject;
 import com.aliyun.odps.data.Record;
 import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
 import com.baomidou.mybatisplus.core.toolkit.Wrappers;
@@ -10,6 +11,7 @@ import com.tzld.piaoquan.sde.common.enums.deconstruction.DeconstructionTaskStatu
 import com.tzld.piaoquan.sde.common.exception.HttpServiceException;
 import com.tzld.piaoquan.sde.integration.ContentDeconstructionClusterClient;
 import com.tzld.piaoquan.sde.mapper.*;
+import com.tzld.piaoquan.sde.model.dto.SdExecutionTaskPropertiesDTO;
 import com.tzld.piaoquan.sde.model.dto.deconstruction.QueryResponseDataDTO;
 import com.tzld.piaoquan.sde.model.entity.SdExecutionTask;
 import com.tzld.piaoquan.sde.model.entity.SdExecutionTaskContent;
@@ -53,6 +55,8 @@ public class ExecutionTaskServiceImpl implements ExecutionTaskService {
     @Autowired
     private SdExecutionTaskContentMapper sdExecutionTaskContentMapper;
 
+    private static final String YESTERDAY_RETURN_TOP10_VIDEO_SCOPE = "yesterday_return_top10_video_scope";
+
     @Value("${yesterday.return.video.table:loghubods.lastday_return}")
     private String yesterdayReturnVideoTable;
 
@@ -305,7 +309,9 @@ public class ExecutionTaskServiceImpl implements ExecutionTaskService {
                 sdExecutionTask.setTaskType(TaskTypeEnum.DECONSTRUCT.getValue());
                 sdExecutionTask.setTaskStatus(ExecutionTaskStatusEnum.INIT.getValue());
                 sdExecutionTask.setContentType(ContentTypeEnum.VIDEO.getValue());
-//                sdExecutionTask.setContentId(videoId);
+                SdExecutionTaskPropertiesDTO propertiesDTO = new SdExecutionTaskPropertiesDTO();
+                propertiesDTO.setContentScope(YESTERDAY_RETURN_TOP10_VIDEO_SCOPE);
+                sdExecutionTask.setProperties(JSONObject.toJSONString(propertiesDTO));
                 SdExecutionTaskContent sdExecutionTaskContent = new SdExecutionTaskContent();
                 sdExecutionTaskContent.setContentType(ContentTypeEnum.VIDEO.getValue());
                 sdExecutionTaskContent.setContentId(videoId);