diff --git a/src/main/java/neatlogic/module/process/service/ProcessServiceImpl.java b/src/main/java/neatlogic/module/process/service/ProcessServiceImpl.java index 770709b12373b8e0035a42bbc1f73ae5a217cd8e..dfb59904022791f61442db45825ccac43bd37943 100644 --- a/src/main/java/neatlogic/module/process/service/ProcessServiceImpl.java +++ b/src/main/java/neatlogic/module/process/service/ProcessServiceImpl.java @@ -25,6 +25,7 @@ import neatlogic.framework.form.exception.FormNotFoundException; import neatlogic.framework.integration.dao.mapper.IntegrationMapper; import neatlogic.framework.notify.crossover.INotifyServiceCrossoverService; import neatlogic.framework.notify.dto.InvokeNotifyPolicyConfigVo; +import neatlogic.framework.process.crossover.IProcessCrossoverService; import neatlogic.framework.process.dto.*; import neatlogic.framework.process.exception.process.ProcessNameRepeatException; import neatlogic.framework.process.exception.sla.SlaCalculateHandlerNotFoundException; @@ -44,7 +45,7 @@ import java.util.List; import java.util.Objects; @Service -public class ProcessServiceImpl implements ProcessService { +public class ProcessServiceImpl implements ProcessService, IProcessCrossoverService { @Resource private ProcessMapper processMapper; diff --git a/src/main/java/neatlogic/module/process/stephandler/regulatehandler/SlaListRegulateHandler.java b/src/main/java/neatlogic/module/process/stephandler/regulatehandler/SlaListRegulateHandler.java index 5d98f7e8cb32f6308d45851788b8fe497817c099..873415b69813c7ab0e673c5d217459f38a4a84e1 100644 --- a/src/main/java/neatlogic/module/process/stephandler/regulatehandler/SlaListRegulateHandler.java +++ b/src/main/java/neatlogic/module/process/stephandler/regulatehandler/SlaListRegulateHandler.java @@ -19,6 +19,7 @@ package neatlogic.module.process.stephandler.regulatehandler; import com.alibaba.fastjson.JSONArray; import com.alibaba.fastjson.JSONObject; +import neatlogic.framework.notify.dto.InvokeNotifyPolicyConfigVo; import neatlogic.framework.process.dto.processconfig.SlaCalculatePolicyVo; import neatlogic.framework.process.dto.processconfig.SlaNotifyPolicyVo; import neatlogic.framework.process.dto.processconfig.SlaTransferPolicyVo; @@ -27,6 +28,7 @@ import neatlogic.framework.process.stephandler.core.IProcessStepInternalHandler; import neatlogic.framework.process.stephandler.core.IRegulateHandler; import neatlogic.framework.process.stephandler.core.ProcessMessageManager; import neatlogic.framework.restful.constvalue.OperationTypeEnum; +import neatlogic.module.process.notify.handler.SlaNotifyPolicyHandler; import org.apache.commons.collections4.CollectionUtils; import org.apache.commons.collections4.ListUtils; import org.apache.commons.collections4.MapUtils; @@ -99,6 +101,8 @@ public class SlaListRegulateHandler implements IRegulateHandler { for (int j = 0; j < notifyPolicyList.size(); j++) { SlaNotifyPolicyVo slaNotifyPolicyVo = notifyPolicyList.getObject(j, SlaNotifyPolicyVo.class); if (slaNotifyPolicyVo != null) { + InvokeNotifyPolicyConfigVo invokeNotifyPolicyConfigVo = slaNotifyPolicyVo.getNotifyPolicyConfig(); + invokeNotifyPolicyConfigVo.setHandler(SlaNotifyPolicyHandler.class.getName()); notifyPolicyArray.add(slaNotifyPolicyVo); } }