fix(大编辑) ：es顺序

amos-boot-system-tzs/amos-boot-module-common/amos-boot-module-common-biz/src/main/java/com/yeejoin/amos/boot/module/common/biz/refresh/dispatch/DataRefreshDispatcher.java

@@ -26,7 +26,7 @@ public class DataRefreshDispatcher implements IDataRefreshDispatch {
     public void doDispatch(List<IDataRefreshHandler> dataRefreshHandlers, List<TzsDataRefreshMessage> messages) {
         int total = dataRefreshHandlers.size();
         dataRefreshHandlers.forEach(dataRefreshHandler -> {
-            messages.forEach(message -> {
+            messages.parallelStream().forEach(message -> {
                 try {
                     message.setDistributions(total);
                     dataRefreshHandler.doRefresh(message);

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/DataDockServiceImpl.java

@@ -2048,6 +2048,7 @@ public class DataDockServiceImpl {
                     equipmentCategoryDto.setSEQUENCE_NBR(record);
                     return equipmentCategoryDto;
                 }).collect(Collectors.toList());
+                log.error("导入失败,开始回滚删除数据:{}", JSONObject.toJSONString(dtoList));
                 esEquipmentCategory.deleteAll(dtoList);
             }
             throw e;

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/IdxBizJgRegisterInfoServiceImpl.java

@@ -4832,6 +4832,7 @@ public class IdxBizJgRegisterInfoServiceImpl extends BaseService<IdxBizJgRegiste
             eventPublisher.publish(new EquipCreateOrEditEvent(this, BusinessTypeEnum.JG_NEW_EQUIP.name(), recordSet, EquipCreateOrEditEvent.EquipType.equip));
         } catch (Exception e) {
             if(!esEquipmentCategoryList.isEmpty()){
+                log.error("导入失败,开始回滚删除数据:{}", JSONObject.toJSONString(esEquipmentCategoryList));
                 esEquipmentCategory.deleteAll(esEquipmentCategoryList);
             }
             throw e;

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/JgUseRegistrationServiceImpl.java

@@ -3526,9 +3526,11 @@ public class JgUseRegistrationServiceImpl extends BaseService<JgUseRegistrationD
                 } catch (Exception e) {
                     // 报错时回滚
                     if(equipmentCategoryDtosSnapshot.iterator().hasNext()){
+                        log.error("使用登记作废报错开始按照快照恢复老索引设备数据:{}", JSONObject.toJSONString(equipmentCategoryDtosSnapshot));
                         esEquipmentCategory.saveAll(equipmentCategoryDtosSnapshot);
                     }
                     if(esEquipmentInfosSnapshot.iterator().hasNext()){
+                        log.error("使用登记作废报错开始按照快照恢复新索引设备数据:{}", JSONObject.toJSONString(esEquipmentInfosSnapshot));
                         esEquipmentDao.saveAll(esEquipmentInfosSnapshot);
                     }
                     throw new RuntimeException(e);
@@ -3765,9 +3767,11 @@ public class JgUseRegistrationServiceImpl extends BaseService<JgUseRegistrationD
                             esEquipmentDao.saveAll(esEquipmentInfoDtoMap.values());
                         } catch (Exception e) {
                             if(!equipmentCategoryDtosSnapshot.isEmpty()){
+                                log.error("使用登记作废报错开始按照快照恢复老索引设备数据:{}", JSONObject.toJSONString(equipmentCategoryDtosSnapshot));
                                 esEquipmentCategory.saveAll(equipmentCategoryDtosSnapshot);
                             }
                             if(!esEquipmentInfosSnapshot.isEmpty()){
+                                log.error("使用登记作废报错开始按照快照恢复新索引设备数据:{}", JSONObject.toJSONString(esEquipmentInfosSnapshot));
                                 esEquipmentDao.saveAll(esEquipmentInfosSnapshot);
                             }
                             throw new RuntimeException(e);
@@ -3814,9 +3818,11 @@ public class JgUseRegistrationServiceImpl extends BaseService<JgUseRegistrationD
                             // 报错时按照快照数据恢复
                             if(oldStatus.equals(FlowStatusEnum.TO_BE_FINISHED.getName())) {
                                 if(equipmentCategoryDtosSnapshot.iterator().hasNext()){
+                                    log.error("使用登记作废报错开始按照快照恢复老索引设备数据:{}", JSONObject.toJSONString(equipmentCategoryDtosSnapshot));
                                     esEquipmentCategory.saveAll(equipmentCategoryDtosSnapshot);
                                 }
                                 if(esEquipmentInfosSnapshot.iterator().hasNext()){
+                                    log.error("使用登记作废报错开始按照快照恢复新索引设备数据:{}", JSONObject.toJSONString(esEquipmentInfosSnapshot));
                                     esEquipmentDao.saveAll(esEquipmentInfosSnapshot);
                                 }
                             }
@@ -3851,9 +3857,11 @@ public class JgUseRegistrationServiceImpl extends BaseService<JgUseRegistrationD
                 // 报错时按照快照数据恢复
                 if(oldStatus.equals(FlowStatusEnum.TO_BE_FINISHED.getName())) {
                     if(equipmentCategoryDtosSnapshot.iterator().hasNext()){
+                        log.error("使用登记作废报错开始按照快照恢复老索引设备数据:{}", JSONObject.toJSONString(equipmentCategoryDtosSnapshot));
                         esEquipmentCategory.saveAll(equipmentCategoryDtosSnapshot);
                     }
                     if(equipmentCategoryDtosSnapshot.iterator().hasNext()){
+                        log.error("使用登记作废报错开始按照快照恢复新索引设备数据:{}", JSONObject.toJSONString(equipmentCategoryDtosSnapshot));
                         esEquipmentDao.saveAll(esEquipmentInfosSnapshot);
                     }
                 }