Merge remote-tracking branch 'origin/develop_tzs_register' into develop_tzs_register

amos-boot-system-tzs/amos-boot-module-jg/amos-boot-module-jg-biz/src/main/java/com/yeejoin/amos/boot/module/jg/biz/init/ApplicationRunnerImpl.java

 package com.yeejoin.amos.boot.module.jg.biz.init;
 
 import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
-import com.yeejoin.amos.boot.module.jg.api.entity.JgInstallationNotice;
-import com.yeejoin.amos.boot.module.jg.api.entity.JgUseRegistration;
-import com.yeejoin.amos.boot.module.jg.biz.service.impl.CommonServiceImpl;
-import com.yeejoin.amos.boot.module.jg.biz.service.impl.JgInstallationNoticeServiceImpl;
-import com.yeejoin.amos.boot.module.jg.biz.service.impl.JgUseRegistrationServiceImpl;
+import com.yeejoin.amos.boot.module.jg.api.entity.*;
+import com.yeejoin.amos.boot.module.jg.biz.service.impl.*;
 import com.yeejoin.amos.boot.module.ymt.api.enums.FlowStatusEnum;
 import org.springframework.boot.ApplicationArguments;
 import org.springframework.boot.ApplicationRunner;
@@ -24,12 +21,34 @@ public class ApplicationRunnerImpl implements ApplicationRunner {
 
     private JgInstallationNoticeServiceImpl installationNoticeService;
 
+    private JgMaintainNoticeServiceImpl jgMaintainNoticeService;
+
+    private JgReformNoticeServiceImpl jgReformNoticeService;
+
+    private JgTransferNoticeServiceImpl jgTransferNoticeService;
+
+    private JgEquipTransferServiceImpl jgEquipTransferService;
+
     public ApplicationRunnerImpl(JgUseRegistrationServiceImpl useRegistrationService,
                                  CommonServiceImpl commonService,
-                                 JgInstallationNoticeServiceImpl installationNoticeService) {
+                                 JgInstallationNoticeServiceImpl installationNoticeService,
+                                 JgMaintainNoticeServiceImpl jgMaintainNoticeService,
+                                 JgReformNoticeServiceImpl jgReformNoticeService,
+                                 JgTransferNoticeServiceImpl jgTransferNoticeService,
+                                 JgEquipTransferServiceImpl jgEquipTransferService) {
         this.commonService = commonService;
+
         this.useRegistrationService = useRegistrationService;
+
         this.installationNoticeService = installationNoticeService;
+
+        this.jgMaintainNoticeService = jgMaintainNoticeService;
+
+        this.jgReformNoticeService = jgReformNoticeService;
+
+        this.jgTransferNoticeService = jgTransferNoticeService;
+
+        this.jgEquipTransferService =jgEquipTransferService;
     }
 
 
@@ -46,5 +65,25 @@ public class ApplicationRunnerImpl implements ApplicationRunner {
         jgInstallationNotices.forEach(jgInstallation -> {
             commonService.saveExecuteFlowData2Redis(jgInstallation.getInstanceId(), installationNoticeService.buildInstanceRuntimeData(jgInstallation));
         });
+        // 维修告知数据初始化
+        List<JgMaintainNotice> jgMaintainNotices = jgMaintainNoticeService.list(new LambdaQueryWrapper<JgMaintainNotice>().ne(JgMaintainNotice::getNoticeStatus, FlowStatusEnum.TO_BE_FINISHED.getCode()));
+        jgMaintainNotices.forEach(jgInstallation -> {
+            commonService.saveExecuteFlowData2Redis(jgInstallation.getInstanceId(), jgMaintainNoticeService.buildInstanceRuntimeData(jgInstallation));
+        });
+        // 改造告知数据初始化
+        List<JgReformNotice> jgReformNotices = jgReformNoticeService.list(new LambdaQueryWrapper<JgReformNotice>().ne(JgReformNotice::getNoticeStatus, FlowStatusEnum.TO_BE_FINISHED.getCode()));
+        jgReformNotices.forEach(jgInstallation -> {
+            commonService.saveExecuteFlowData2Redis(jgInstallation.getInstanceId(), jgReformNoticeService.buildInstanceRuntimeData(jgInstallation));
+        });
+        // 移装告知数据初始化
+        List<JgTransferNotice> jgTransferNotices = jgTransferNoticeService.list(new LambdaQueryWrapper<JgTransferNotice>().ne(JgTransferNotice::getNoticeStatus, FlowStatusEnum.TO_BE_FINISHED.getCode()));
+        jgTransferNotices.forEach(jgInstallation -> {
+            commonService.saveExecuteFlowData2Redis(jgInstallation.getInstanceId(), jgTransferNoticeService.buildInstanceRuntimeData(jgInstallation));
+        });
+        // 设备移交数据初始化
+        List<JgEquipTransfer> jgEquipTransfers = jgEquipTransferService.list(new LambdaQueryWrapper<JgEquipTransfer>().ne(JgEquipTransfer::getApplyStatus, FlowStatusEnum.TO_BE_FINISHED.getCode()));
+        jgEquipTransfers.forEach(jgInstallation -> {
+            commonService.saveExecuteFlowData2Redis(jgInstallation.getInstanceId(), jgEquipTransferService.buildInstanceRuntimeData(jgInstallation));
+        });
     }
 }