no message

src/main/java/com/jz/dmp/modules/controller/DataIntegration/OfflineSynchController.java

@@ -183,4 +183,16 @@ public class OfflineSynchController {
         JsonResult list = offlineSynchService.addSyncTask(syncDmpTaskAddReq);
         return list;
     }
+
+    /**
+     * 编辑离线任务数据
+     *
+     * @return
+     */
+    @ApiOperation(value = "编辑离线任务数据", notes = "编辑离线任务数据")
+    @PostMapping(value = "/addSyncTask")
+    public JsonResult updateSyncTask(@RequestBody @Validated SyncDmpTaskAddReq syncDmpTaskAddReq) throws Exception {
+        JsonResult list = offlineSynchService.updateSyncTask(syncDmpTaskAddReq);
+        return list;
+    }
 }

src/main/java/com/jz/dmp/modules/service/OfflineSynchService.java

@@ -37,4 +37,6 @@ public interface OfflineSynchService {
     PageInfoResponse<DvRuleTDto> queryJyRuleListPage(BasePageBean basePageBean, HttpServletRequest httpRequest) throws Exception;
 
     JsonResult addSyncTask(SyncDmpTaskAddReq syncDmpTaskAddReq) throws Exception;
+
+    JsonResult updateSyncTask(SyncDmpTaskAddReq syncDmpTaskAddReq) throws Exception;
 }

src/main/java/com/jz/dmp/modules/service/impl/OfflineSynchServiceImpl.java

@@ -242,6 +242,8 @@ public class OfflineSynchServiceImpl implements OfflineSynchService {
 
     /**
      * 任务状态查看，异步调用azkaban服务
+     * @Author Bellamy
+     * @Date 2020/12/20
      */
     @Override
     public JsonResult<List<CheckTaskStatusPageDto>> queryCheckTaskStatusListPage(CheckTaskStatusPageReq checkTaskStatusPageReq) throws Exception {
@@ -428,7 +430,8 @@ public class OfflineSynchServiceImpl implements OfflineSynchService {
 
     /**
      * 添加保存dmp数据(包含校验数据)
-     *
+     * @Author Bellamy
+     * @Date 2020/12/20
      * @param syncDmpTaskAddReq
      * @return
      */
@@ -445,6 +448,24 @@ public class OfflineSynchServiceImpl implements OfflineSynchService {
         return new JsonResult(ResultCode.SUCCESS, result);
     }
 
+    /*
+     *编辑离线任务数据
+     * @Author Bellamy
+     * @Date 2020/12/30
+     * */
+    @Override
+    @Transactional(rollbackFor = Exception.class, propagation = Propagation.REQUIRES_NEW)
+    public JsonResult updateSyncTask(SyncDmpTaskAddReq syncDmpTaskAddReq) throws Exception {
+        List<Map<String, Object>> result = new ArrayList<>();
+        Map<String, Object> reqParam = syncDmpTaskAddReq.getParams();
+        if (reqParam.size() > 0 && reqParam != null) {
+            JsonResult jsonResult = addSyncing(reqParam);
+            DmpDevelopTask data = (DmpDevelopTask) jsonResult.getData();
+            saveRuleInfo(result, reqParam, jsonResult, String.valueOf(data.getId()));
+        }
+        return new JsonResult(ResultCode.SUCCESS, result);
+    }
+
     /**
      * 添加保存离线任务dmp数据
      *
@@ -452,7 +473,7 @@ public class OfflineSynchServiceImpl implements OfflineSynchService {
      * @return
      */
     public JsonResult addSyncing(Map<String, Object> body) throws Exception {
-        Integer projectId = Integer.valueOf(body.get("projectId").toString()) ;
+        Integer projectId = Integer.valueOf(body.get("projectId").toString());
         Integer parentId = Integer.valueOf(body.get("parentId").toString()); //父节点ID
         String taskName = (String) body.get("taskName"); //任务名称 业务节点名称 一对一
         Integer treeId = Integer.valueOf(body.get("treeId").toString()); //树节点ID