feat:添加保存结果URL的逻辑

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

@@ -1,5 +1,6 @@
 package com.tzld.piaoquan.sde.model.dto.deconstruction;
 
+import com.alibaba.fastjson.JSONObject;
 import lombok.Data;
 
 @Data
@@ -11,4 +12,5 @@ public class QueryResponseDataDTO {
     private Integer status;
     private String result;
     private String reason;
+    private String url;
 }

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

@@ -28,6 +28,10 @@ public class SdExecutionTaskRawResult {
      * 原始结果数据
      */
     private String rawResult;
+    /**
+     * URL信息
+     */
+    private String urlInfo;
     /**
      * 记录创建时间，由数据库自动生成
      */

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

@@ -237,6 +237,7 @@ public class ExecutionTaskServiceImpl implements ExecutionTaskService {
                 ExecutionTaskStatusEnum executionTaskStatusEnum = null;
                 String rawResult = null;
                 String errorMsg = null;
+                String urlInfo = null;
                 switch (deconstructionTaskStatusEnum) {
                     case PENDING:
                         log.info("executionTask is pending, id:{}", sdExecutionTask.getId());
@@ -247,6 +248,7 @@ public class ExecutionTaskServiceImpl implements ExecutionTaskService {
                     case SUCCESS:
                         executionTaskStatusEnum = ExecutionTaskStatusEnum.SUCCESS;
                         rawResult = queryResponseDataDTO.getResult();
+                        urlInfo = queryResponseDataDTO.getUrl();
                         break;
                     case FAILED:
                         executionTaskStatusEnum = ExecutionTaskStatusEnum.FAILED;
@@ -269,6 +271,7 @@ public class ExecutionTaskServiceImpl implements ExecutionTaskService {
                     SdExecutionTaskRawResult sdExecutionTaskRawResult = new SdExecutionTaskRawResult();
                     sdExecutionTaskRawResult.setExecutionTaskId(sdExecutionTask.getId());
                     sdExecutionTaskRawResult.setRawResult(rawResult);
+                    sdExecutionTaskRawResult.setUrlInfo(urlInfo);
                     int insertRows = sdExecutionTaskRawResultMapper.insert(sdExecutionTaskRawResult);
                     log.info("executionTask result insertRows success, id:{} rows = {}", sdExecutionTask.getId(), insertRows);
                 }

supply-demand-engine-job/src/test/java/com/tzld/piaoquan/sde/ContentDeconstructionClusterClientTest.java

@@ -1,5 +1,6 @@
 package com.tzld.piaoquan.sde;
 
+import com.alibaba.fastjson.JSON;
 import com.tzld.piaoquan.sde.integration.ContentDeconstructionClusterClient;
 import com.tzld.piaoquan.sde.mapper.SdExecutionTaskMapper;
 import com.tzld.piaoquan.sde.model.entity.SdExecutionTask;
@@ -20,4 +21,8 @@ public class ContentDeconstructionClusterClientTest extends BaseTest {
         contentDeconstructionClusterClient.submitDeconstructionTask(sdExecutionTask);
     }
 
+    @Test
+    public void testGetTaskResult(){
+        System.out.println(contentDeconstructionClusterClient.getTaskResult("20260203155046614410956151c94dda99db"));
+    }
 }