diff --git a/fw-nifi/src/main/java/com/hzya/frame/nifiapi/operation/INifiBaseOperation.java b/fw-nifi/src/main/java/com/hzya/frame/nifiapi/operation/INifiBaseOperation.java
index 134a4ead..7fa242b7 100644
--- a/fw-nifi/src/main/java/com/hzya/frame/nifiapi/operation/INifiBaseOperation.java
+++ b/fw-nifi/src/main/java/com/hzya/frame/nifiapi/operation/INifiBaseOperation.java
@@ -76,7 +76,7 @@ public interface INifiBaseOperation {
      * @param processGroupId 流程组id
      * @param mark           接口修改标记字符串，如果为null，则不进行过滤
      */
-    List<Processors>  getFindStateClearMarkProcessor(String processGroupId, String mark) throws Exception;
+    List<Processors> getFindStateClearMarkProcessor(String processGroupId, String mark) throws Exception;
 
     /**
      * 查找某个流程组(应用app)内,带有"修改标记"的控制器服务，并更新控制器，从而达到实例化要求
@@ -105,7 +105,7 @@ public interface INifiBaseOperation {
     /**
      * 清理掉拷贝后新的流程组中的老鼠屎
      *
-     * @param processGroupId 流程组id
+     * @param processGroupIdList 流程组id集合
      */
-    void clearProcessGroupState(List<String> processGroupId) throws Exception;
+    void clearProcessGroupState(List<String> processGroupIdList) throws Exception;
 }
\ No newline at end of file
diff --git a/fw-nifi/src/main/java/com/hzya/frame/nifiapi/operation/impl/NifiAppOperationImpl.java b/fw-nifi/src/main/java/com/hzya/frame/nifiapi/operation/impl/NifiAppOperationImpl.java
index 13824ba7..31505252 100644
--- a/fw-nifi/src/main/java/com/hzya/frame/nifiapi/operation/impl/NifiAppOperationImpl.java
+++ b/fw-nifi/src/main/java/com/hzya/frame/nifiapi/operation/impl/NifiAppOperationImpl.java
@@ -19,6 +19,7 @@ import org.slf4j.LoggerFactory;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Repository;
 
+import java.util.ArrayList;
 import java.util.List;
 
 /**
@@ -79,8 +80,15 @@ public class NifiAppOperationImpl implements INifiAppOperation {
                 }
 
                 findNeedModifyController.setProcessGroupId(newProcessGroupId);
-                baseOperation.findNeedModifyControllerAndChangesOccur(findNeedModifyController, true, true);
+                baseOperation.findNeedModifyControllerAndChangesOccur(findNeedModifyController, true, false);
             }
+            //4.激活当前流程组内的所有控制器服务
+            String controllerStatus = "ENABLED";
+            baseOperation.batchEnabledControllerServices(newProcessGroupId, controllerStatus);
+            //5.清理state状态
+            List<String> processGroupIdList = new ArrayList<>();
+            processGroupIdList.add(newProcessGroupId);
+            baseOperation.clearProcessGroupState(processGroupIdList);
 
             createAppInstanceResult.setNewProcessGroupId(newProcessGroupId);
         } catch (Exception e) {
diff --git a/fw-nifi/src/main/java/com/hzya/frame/nifiapi/operation/impl/NifiBaseOperationImpl.java b/fw-nifi/src/main/java/com/hzya/frame/nifiapi/operation/impl/NifiBaseOperationImpl.java
index 5eaaa80a..44365099 100644
--- a/fw-nifi/src/main/java/com/hzya/frame/nifiapi/operation/impl/NifiBaseOperationImpl.java
+++ b/fw-nifi/src/main/java/com/hzya/frame/nifiapi/operation/impl/NifiBaseOperationImpl.java
@@ -13,6 +13,7 @@ import com.hzya.frame.nifiapi.model.joincreateconnections.CreateConnections18;
 import com.hzya.frame.nifiapi.model.joincreateprocessconnection.CreateProcessorConnections;
 import com.hzya.frame.nifiapi.model.joincreparamcontext.CreateParamContextJoin;
 import com.hzya.frame.nifiapi.model.joinfindneedmodifycontroller.FindNeedModifyController;
+import com.hzya.frame.nifiapi.model.joingetallcontrollerservice.Component19;
 import com.hzya.frame.nifiapi.model.joingetallcontrollerservice.ControllerServices19;
 import com.hzya.frame.nifiapi.model.joingetallcontrollerservice.GetAllController19;
 import com.hzya.frame.nifiapi.model.joingetcontroller.ControllerService12;
@@ -251,11 +252,7 @@ public class NifiBaseOperationImpl implements INifiBaseOperation {
                 List<Processors> processors = flow.getProcessors();
 
                 // 过滤 comments 包含 mark 的 Processors
-                filteredProcessors = processors.stream().filter(processor ->
-                        processor.getComponent() != null
-                                && processor.getComponent().getConfig() != null
-                                && processor.getComponent().getConfig().getComments() != null
-                                && processor.getComponent().getConfig().getComments().contains(mark)).collect(Collectors.toList());
+                filteredProcessors = processors.stream().filter(processor -> processor.getComponent() != null && processor.getComponent().getConfig() != null && processor.getComponent().getConfig().getComments() != null && processor.getComponent().getConfig().getComments().contains(mark)).collect(Collectors.toList());
             }
         } catch (Exception e) {
             throw new Exception("未能筛选带有标记的处理器：" + mark, e);
@@ -323,20 +320,22 @@ public class NifiBaseOperationImpl implements INifiBaseOperation {
             if (allControllerServices != null && allControllerServices.getControllerServices() != null) {
                 List<ControllerServices19> controllerServices = allControllerServices.getControllerServices();
                 for (ControllerServices19 controllerService : controllerServices) {
+                    Component19 component = controllerService.getComponent();
                     String controllerServicesId = controllerService.getId();
+                    if (controllerServicesId != null && component != null && !status.equals(component.getState())) {
+                        //得到控制器服务当前版本
+                        ControllerService12 controllerService12 = nifiApiService.getControllerServices(controllerServicesId);
+                        Revision12 revision = controllerService12.getRevision();
 
-                    //得到控制器服务当前版本
-                    ControllerService12 controllerService12 = nifiApiService.getControllerServices(controllerServicesId);
-                    Revision12 revision = controllerService12.getRevision();
+                        Revision13 revision13 = new Revision13();
+                        revision13.setVersion(revision.getVersion());
 
-                    Revision13 revision13 = new Revision13();
-                    revision13.setVersion(revision.getVersion());
-
-                    EnOrDiControllerServices12 enOrDiControllerServices = new EnOrDiControllerServices12();
-                    enOrDiControllerServices.setState(status);
-                    enOrDiControllerServices.setRevision(revision13);
-                    ControllerService12 controllerService121 = nifiApiService.enabledOrDisabledControllerServices(controllerServicesId, enOrDiControllerServices);
-                    logger.info("控制器服务id：{}", controllerService121.getId());
+                        EnOrDiControllerServices12 enOrDiControllerServices = new EnOrDiControllerServices12();
+                        enOrDiControllerServices.setState(status);
+                        enOrDiControllerServices.setRevision(revision13);
+                        ControllerService12 controllerService121 = nifiApiService.enabledOrDisabledControllerServices(controllerServicesId, enOrDiControllerServices);
+                        logger.info("控制器服务id：{}", controllerService121.getId());
+                    }
                 }
             }
         } catch (Exception e) {
@@ -345,11 +344,11 @@ public class NifiBaseOperationImpl implements INifiBaseOperation {
     }
 
     @Override
-    public void clearProcessGroupState(List<String> processGroupId) throws Exception {
-        if (processGroupId != null && processGroupId.size() > 0) {
-            for (String processGroupIdIndex : processGroupId) {
+    public void clearProcessGroupState(List<String> processGroupIdList) throws Exception {
+        if (processGroupIdList != null && processGroupIdList.size() > 0) {
+            for (String processGroupIdIndex : processGroupIdList) {
                 //根据流程组id+标识名称，查找需要清理的state处理器
-                String relationshipMark = nifiServiceConfig.getRelationshipMark();
+                String relationshipMark = nifiServiceConfig.getStateClearMark();
                 List<Processors> findStateClearMarkProcessor = getFindStateClearMarkProcessor(processGroupIdIndex, relationshipMark);
                 for (Processors processors : findStateClearMarkProcessor) {
                     Component2 component = processors.getComponent();