参数包装

byit-myth-core/myth-admin-core/src/main/java/com/byit/service/mapservice/impl/RunRecordingAndJobTaskServiceImpl.java

@@ -135,6 +135,24 @@ public class RunRecordingAndJobTaskServiceImpl implements RunRecordingAndJobTask
             runRecording.setOperator(jobTask.getOperator());
             runRecording.setScheduleType(jobTask.getScheduleType());
         }
+
+        //开始执行生命周期 开始的
+        Map<String, InstanceRunTheLifeCycleCallback> beansOfType = SpringUtil.getBeansOfType(InstanceRunTheLifeCycleCallback.class);
+        try {
+            List<BeanStrategyPackage<InstanceRunTheLifeCycleCallback>> beanStrategyPackages = ClassSortUtil.objectSort(beansOfType);
+            //回调生命周期
+            for (BeanStrategyPackage<InstanceRunTheLifeCycleCallback> beanStrategyPackage : beanStrategyPackages) {
+                log.info("-------------【开始回调周期{}前置】---------------",beanStrategyPackage.getBeanName());
+                beanStrategyPackage.getBean().postProcessAfterInitialization(runRecording);
+            }
+        }catch (Exception e) {
+            String format = String.format(RedisKeyNameEnum.REDIS_FLOW_ERROR_MSG_KEY.getKeyName(), runRecording.getRunId(), runRecording.getFlowName());
+            stringRedisTemplate.opsForValue().set(format, MythLogUtils.getMessage(e));
+            runRecording.setFailFast(RunRecordingEnum.FAIL_FAST_YES.getCode());
+            runRecording.setStartTime(new Date());
+            runRecording.setEndTime(new Date());
+        }
+
         runRecordingService.saveRunRecording(runRecording);
         log.info("-----------【虚节点对应节点保存到任务表】--------------");
         //获取所有的节点，开始将所有节点保存到任务表