1.田博登记数据redis预热

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

@@ -29,13 +29,34 @@ public class ApplicationRunnerImpl implements ApplicationRunner {
 
     private JgEquipTransferServiceImpl jgEquipTransferService;
 
+    private JgChangeRegistrationTransferServiceImpl changeRegistrationTransferService;
+
+    private JgChangeRegistrationReformServiceImpl changeRegistrationReformService;
+
+    private JgChangeRegistrationUnitServiceImpl changeRegistrationUnitService;
+
+    private JgEnableDisableServiceImpl jgEnableDisableService;
+
+    private JgMaintenanceContractServiceImpl maintenanceContractService;
+
+    private JgScrapCancelServiceImpl scrapCancelService;
+
+    private JgChangeRegistrationNameServiceImpl changeRegistrationNameService;
+
     public ApplicationRunnerImpl(JgUseRegistrationServiceImpl useRegistrationService,
                                  CommonServiceImpl commonService,
                                  JgInstallationNoticeServiceImpl installationNoticeService,
                                  JgMaintainNoticeServiceImpl jgMaintainNoticeService,
                                  JgReformNoticeServiceImpl jgReformNoticeService,
                                  JgTransferNoticeServiceImpl jgTransferNoticeService,
-                                 JgEquipTransferServiceImpl jgEquipTransferService) {
+                                 JgEquipTransferServiceImpl jgEquipTransferService,
+                                 JgChangeRegistrationTransferServiceImpl changeRegistrationTransferService,
+                                 JgChangeRegistrationReformServiceImpl changeRegistrationReformService,
+                                 JgChangeRegistrationUnitServiceImpl changeRegistrationUnitService,
+                                 JgEnableDisableServiceImpl jgEnableDisableService,
+                                 JgMaintenanceContractServiceImpl maintenanceContractService,
+                                 JgScrapCancelServiceImpl scrapCancelService,
+                                 JgChangeRegistrationNameServiceImpl changeRegistrationNameService) {
         this.commonService = commonService;
 
         this.useRegistrationService = useRegistrationService;
@@ -48,7 +69,21 @@ public class ApplicationRunnerImpl implements ApplicationRunner {
 
         this.jgTransferNoticeService = jgTransferNoticeService;
 
-        this.jgEquipTransferService =jgEquipTransferService;
+        this.jgEquipTransferService = jgEquipTransferService;
+
+        this.changeRegistrationTransferService = changeRegistrationTransferService;
+
+        this.changeRegistrationReformService = changeRegistrationReformService;
+
+        this.changeRegistrationUnitService = changeRegistrationUnitService;
+
+        this.jgEnableDisableService = jgEnableDisableService;
+
+        this.maintenanceContractService = maintenanceContractService;
+
+        this.scrapCancelService = scrapCancelService;
+
+        this.changeRegistrationNameService =changeRegistrationNameService;
     }
 
 
@@ -85,5 +120,47 @@ public class ApplicationRunnerImpl implements ApplicationRunner {
         jgEquipTransfers.forEach(jgInstallation -> {
             commonService.saveExecuteFlowData2Redis(jgInstallation.getInstanceId(), jgEquipTransferService.buildInstanceRuntimeData(jgInstallation));
         });
+
+        // 移转变更登记数据初始化
+        List<JgChangeRegistrationTransfer> jgChangeRegistrationTransfers = changeRegistrationTransferService.list(new LambdaQueryWrapper<JgChangeRegistrationTransfer>().ne(JgChangeRegistrationTransfer::getAuditStatus, FlowStatusEnum.TO_BE_FINISHED.getName()));
+        jgChangeRegistrationTransfers.forEach(jgChangeRegistrationTransfer -> {
+            commonService.saveExecuteFlowData2Redis(jgChangeRegistrationTransfer.getInstanceId(), changeRegistrationTransferService.buildInstanceRuntimeData(jgChangeRegistrationTransfer));
+        });
+
+        // 改造变更登记数据初始化
+        List<JgChangeRegistrationReform> jgChangeRegistrationReforms = changeRegistrationReformService.list(new LambdaQueryWrapper<JgChangeRegistrationReform>().ne(JgChangeRegistrationReform::getAuditStatus, FlowStatusEnum.TO_BE_FINISHED.getName()));
+        jgChangeRegistrationReforms.forEach(jgInstallation -> {
+            commonService.saveExecuteFlowData2Redis(jgInstallation.getInstanceId(), changeRegistrationReformService.buildInstanceRuntimeData(jgInstallation));
+        });
+
+        // 单位变更登记数据初始化
+        List<JgChangeRegistrationUnit> jgChangeRegistrationUnits = changeRegistrationUnitService.list(new LambdaQueryWrapper<JgChangeRegistrationUnit>().ne(JgChangeRegistrationUnit::getAuditStatus, FlowStatusEnum.TO_BE_FINISHED.getName()));
+        jgChangeRegistrationUnits.forEach(jgInstallation -> {
+            commonService.saveExecuteFlowData2Redis(jgInstallation.getInstanceId(), changeRegistrationUnitService.buildInstanceRuntimeData(jgInstallation));
+        });
+
+        // 启用停用登记数据初始化
+        List<JgEnableDisable> jgEnableDisables = jgEnableDisableService.list(new LambdaQueryWrapper<JgEnableDisable>().ne(JgEnableDisable::getAuditStatus, FlowStatusEnum.TO_BE_FINISHED.getName()));
+        jgEnableDisables.forEach(jgEnableDisable -> {
+            commonService.saveExecuteFlowData2Redis(jgEnableDisable.getInstanceId(), jgEnableDisableService.buildInstanceRuntimeData(jgEnableDisable));
+        });
+
+        // 维保备案登记数据初始化
+        List<JgMaintenanceContract> jgMaintenanceContracts = maintenanceContractService.list(new LambdaQueryWrapper<JgMaintenanceContract>().ne(JgMaintenanceContract::getApplyStatus, FlowStatusEnum.TO_BE_FINISHED.getName()));
+        jgMaintenanceContracts.forEach(jgInstallation -> {
+            commonService.saveExecuteFlowData2Redis(jgInstallation.getInstanceId(), maintenanceContractService.buildInstanceRuntimeData(jgInstallation));
+        });
+
+        // 注销报废登记数据初始化
+        List<JgScrapCancel> jgScrapCancels = scrapCancelService.list(new LambdaQueryWrapper<JgScrapCancel>().ne(JgScrapCancel::getAuditStatus, FlowStatusEnum.TO_BE_FINISHED.getName()));
+        jgScrapCancels.forEach(jgScrapCancel -> {
+            commonService.saveExecuteFlowData2Redis(jgScrapCancel.getInstanceId(), scrapCancelService.buildInstanceRuntimeData(jgScrapCancel));
+        });
+
+        // 单位名称变更数据初始化
+        List<JgChangeRegistrationName> jgChangeRegistrationNames = changeRegistrationNameService.list(new LambdaQueryWrapper<JgChangeRegistrationName>().ne(JgChangeRegistrationName::getAuditStatus, FlowStatusEnum.TO_BE_FINISHED.getName()));
+        jgChangeRegistrationNames.forEach(registrationName -> {
+            commonService.saveExecuteFlowData2Redis(registrationName.getInstanceId(), changeRegistrationNameService.buildInstanceRuntimeData(registrationName));
+        });
     }
 }

amos-boot-system-tzs/amos-boot-module-jg/amos-boot-module-jg-biz/src/main/java/com/yeejoin/amos/boot/module/jg/biz/service/impl/JgChangeRegistrationNameServiceImpl.java

@@ -631,7 +631,7 @@ public class JgChangeRegistrationNameServiceImpl extends BaseService<JgChangeReg
         this.getBaseMapper().updateById(jgChangeRegistrationName);
     }
 
-    private InstanceRuntimeData buildInstanceRuntimeData(JgChangeRegistrationName jgChangeRegistrationName) {
+    public InstanceRuntimeData buildInstanceRuntimeData(JgChangeRegistrationName jgChangeRegistrationName) {
         return InstanceRuntimeData.builder()
                 .nextExecuteUserIds(jgChangeRegistrationName.getNextExecuteUserIds())
                 .promoter(jgChangeRegistrationName.getPromoter())

amos-boot-system-tzs/amos-boot-module-jg/amos-boot-module-jg-biz/src/main/java/com/yeejoin/amos/boot/module/jg/biz/service/impl/JgChangeRegistrationReformServiceImpl.java

@@ -371,7 +371,7 @@ public class JgChangeRegistrationReformServiceImpl extends BaseService<JgChangeR
         this.getBaseMapper().updateById(jgChangeRegistrationReform);
     }
 
-    private InstanceRuntimeData buildInstanceRuntimeData(JgChangeRegistrationReform jgChangeRegistrationReform) {
+    public InstanceRuntimeData buildInstanceRuntimeData(JgChangeRegistrationReform jgChangeRegistrationReform) {
         return InstanceRuntimeData.builder()
                 .nextExecuteUserIds(jgChangeRegistrationReform.getNextExecuteUserIds())
                 .promoter(jgChangeRegistrationReform.getPromoter())