20210729添加插件

common/src/main/java/com/ccsens/common/service/IPluginService.java

@@ -2,10 +2,12 @@ package com.ccsens.common.service;
 
 import com.ccsens.common.bean.dto.CPluginDto;
 
+import java.util.List;
+
 public interface IPluginService {
     /**
      * 配置任务插件关联信息
      */
-    void updateTaskPlugin(CPluginDto.UpdateTaskPlugin updateTaskPlugin);
+    void updateTaskPlugin(List<CPluginDto.UpdateTaskPlugin> updateTaskPlugins);
 
 }

common/src/main/java/com/ccsens/common/service/ITaskService.java

@@ -46,5 +46,5 @@ public interface ITaskService {
      * 添加任务上下工序
      * @param updateTaskProcesses 任务信息
      */
-    void updateTaskStartTime(List<CTaskDto.UpdateTaskProcess> updateTaskProcesses);
+    void updateTaskProcess(List<CTaskDto.UpdateTaskProcess> updateTaskProcesses);
 }

common/src/main/java/com/ccsens/common/service/PluginService.java

@@ -31,50 +31,52 @@ public class PluginService implements IPluginService{
     private PluginDao pluginDao;
 
     @Override
-    public void updateTaskPlugin(CPluginDto.UpdateTaskPlugin updateTaskPlugin) {
+    public void updateTaskPlugin(List<CPluginDto.UpdateTaskPlugin> updateTaskPlugins) {
-        //查询插件信息
+        if(CollectionUtil.isNotEmpty(updateTaskPlugins)){
-        Long pluginId = pluginDao.getPluginIdByName(updateTaskPlugin.getPluginName());
+            updateTaskPlugins.forEach(updateTaskPlugin -> {
-        if(ObjectUtil.isNull(pluginId)){
+                //查询插件信息
-            throw new BaseException(CommonCodeError.PLUGIN_NAME_ERROR);
+                Long pluginId = pluginDao.getPluginIdByName(updateTaskPlugin.getPluginName());
-        }
+                if(ObjectUtil.isNull(pluginId)){
-        //根据任务id和插件id查找以前的关联信息
+                    throw new BaseException(CommonCodeError.PLUGIN_NAME_ERROR);
-        ProTaskPluginExample taskPluginExample = new ProTaskPluginExample();
-        taskPluginExample.createCriteria().andTaskDetailIdEqualTo(updateTaskPlugin.getTaskDetailId())
-                .andPluginIdEqualTo(pluginId);
-        List<ProTaskPlugin> proTaskPlugins = proTaskPluginDao.selectByExample(taskPluginExample);
-        if(CollectionUtil.isNotEmpty(proTaskPlugins)){
-            //有则修改
-            proTaskPlugins.forEach(proTaskPlugin -> {
-                if(StrUtil.isNotEmpty(updateTaskPlugin.getParam())){
-                    proTaskPlugin.setParam(updateTaskPlugin.getParam());
                 }
-                if(ObjectUtil.isNotNull(updateTaskPlugin.getRow()) && updateTaskPlugin.getRow() != 0){
+                //根据任务id和插件id查找以前的关联信息
+                ProTaskPluginExample taskPluginExample = new ProTaskPluginExample();
+                taskPluginExample.createCriteria().andTaskDetailIdEqualTo(updateTaskPlugin.getTaskDetailId())
+                        .andPluginIdEqualTo(pluginId);
+                List<ProTaskPlugin> proTaskPlugins = proTaskPluginDao.selectByExample(taskPluginExample);
+                if(CollectionUtil.isNotEmpty(proTaskPlugins)){
+                    //有则修改
+                    proTaskPlugins.forEach(proTaskPlugin -> {
+                        if(StrUtil.isNotEmpty(updateTaskPlugin.getParam())){
+                            proTaskPlugin.setParam(updateTaskPlugin.getParam());
+                        }
+                        if(ObjectUtil.isNotNull(updateTaskPlugin.getRow()) && updateTaskPlugin.getRow() != 0){
+                            proTaskPlugin.setPlginRow(updateTaskPlugin.getRow());
+                        }
+                        if(ObjectUtil.isNotNull(updateTaskPlugin.getCol()) && updateTaskPlugin.getCol() != 0){
+                            proTaskPlugin.setPlginCol(updateTaskPlugin.getCol());
+                        }
+                        if(ObjectUtil.isNotNull(updateTaskPlugin.getRowspan())){
+                            proTaskPlugin.setRowspan(updateTaskPlugin.getRowspan());
+                        }
+                        if(ObjectUtil.isNotNull(updateTaskPlugin.getColspan())){
+                            proTaskPlugin.setColspan(updateTaskPlugin.getColspan());
+                        }
+                    });
+                }else {
+                    //无则添加
+                    ProTaskPlugin proTaskPlugin = new ProTaskPlugin();
+                    proTaskPlugin.setId(snowflake.nextId());
+                    proTaskPlugin.setTaskDetailId(updateTaskPlugin.getTaskDetailId());
+                    proTaskPlugin.setPluginId(pluginId);
                     proTaskPlugin.setPlginRow(updateTaskPlugin.getRow());
-                }
-                if(ObjectUtil.isNotNull(updateTaskPlugin.getCol()) && updateTaskPlugin.getCol() != 0){
                     proTaskPlugin.setPlginCol(updateTaskPlugin.getCol());
-                }
-                if(ObjectUtil.isNotNull(updateTaskPlugin.getRowspan())){
                     proTaskPlugin.setRowspan(updateTaskPlugin.getRowspan());
-                }
-                if(ObjectUtil.isNotNull(updateTaskPlugin.getColspan())){
                     proTaskPlugin.setColspan(updateTaskPlugin.getColspan());
+                    proTaskPlugin.setParam(updateTaskPlugin.getParam());
+                    proTaskPluginDao.insertSelective(proTaskPlugin);
                 }
             });
-        }else {
-            //无则添加
-            ProTaskPlugin proTaskPlugin = new ProTaskPlugin();
-            proTaskPlugin.setId(snowflake.nextId());
-            proTaskPlugin.setTaskDetailId(updateTaskPlugin.getTaskDetailId());
-            proTaskPlugin.setPluginId(pluginId);
-            proTaskPlugin.setPlginRow(updateTaskPlugin.getRow());
-            proTaskPlugin.setPlginCol(updateTaskPlugin.getCol());
-            proTaskPlugin.setRowspan(updateTaskPlugin.getRowspan());
-            proTaskPlugin.setColspan(updateTaskPlugin.getColspan());
-            proTaskPlugin.setParam(updateTaskPlugin.getParam());
-            proTaskPluginDao.insertSelective(proTaskPlugin);
         }
-
-
     }
 }

common/src/main/java/com/ccsens/common/service/TaskService.java

@@ -546,7 +546,7 @@ public class TaskService implements ITaskService {
 
 
     @Override
-    public void updateTaskStartTime(List<CTaskDto.UpdateTaskProcess> updateTaskProcesses) {
+    public void updateTaskProcess(List<CTaskDto.UpdateTaskProcess> updateTaskProcesses) {
         if(CollectionUtil.isNotEmpty(updateTaskProcesses) && updateTaskProcesses.size() > 1){
             Long task1;
             Long task2;