1.空指针处理

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

@@ -46,6 +46,7 @@ public class ChangeUnitEquipUsedCheckImpl extends BaseEquipUsedCheckService {
     public void init() {
         // 初始化在流程中设备数据
         List<CompanyEquipCountDto> companyEquipCountDtos = changeRegistrationUnitMapper.queryForFlowingEquipList();
+        companyEquipCountDtos.remove(null);
         companyEquipCountDtos.forEach(c -> {
             RBucket<Set<String>> rBucket = redissonClient.getBucket(getFlowingEquipRedisKey(c.getCompanyCode(), bizType));
             rBucket.set(Arrays.stream(c.getRecords().split(",")).collect(Collectors.toSet()));

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

@@ -46,6 +46,7 @@ public class EquipTransferEquipUsedCheckImpl extends BaseEquipUsedCheckService {
     public void init() {
         // 初始化在流程中的设备数据
         List<CompanyEquipCountDto> companyEquipCountDtos = equipTransferMapper.queryForFlowingEquipList();
+        companyEquipCountDtos.remove(null);
         companyEquipCountDtos.forEach(c -> {
             RBucket<Set<String>> rBucket = redissonClient.getBucket(getFlowingEquipRedisKey(c.getCompanyCode(), bizType));
             rBucket.set(Arrays.stream(c.getRecords().split(",")).collect(Collectors.toSet()));

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

@@ -46,6 +46,7 @@ public class InstallNoticeEquipUsedCheckImpl extends BaseEquipUsedCheckService {
     public void init() {
         // 初始化已经完成或者在流程中安装告知的设备数据
         List<CompanyEquipCountDto> companyEquipCountDtos = installationNoticeMapper.queryForFlowingEquipList();
+        companyEquipCountDtos.remove(null);
         companyEquipCountDtos.forEach(c -> {
             RBucket<Set<String>> rBucket = redissonClient.getBucket(getFlowingEquipRedisKey(c.getCompanyCode(), bizType));
             rBucket.set(Arrays.stream(c.getRecords().split(",")).collect(Collectors.toSet()));

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

@@ -48,6 +48,7 @@ public class JgChangeRegistrationEquipUsedCheckImpl extends BaseEquipUsedCheckSe
     public void init() {
         // 初始化已经完成或者在流程中使用登记的设备数据
         List<CompanyEquipCountDto> companyEquipCountDtos = mapper.queryForFlowingEquipList();
+        companyEquipCountDtos.remove(null);
         companyEquipCountDtos.forEach(c -> {
             RBucket<Set<String>> rBucket = redissonClient.getBucket(this.getFlowingEquipRedisKey(c.getCompanyCode(), bizType));
             rBucket.set(Arrays.stream(c.getRecords().split(",")).collect(Collectors.toSet()));

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

@@ -47,6 +47,7 @@ public class JgChangeRegistrationNameRegistrationUsedCheckImpl extends BaseEquip
     public void init() {
         // 初始化在流程中设备数据
         List<CompanyEquipCountDto> companyEquipCountDtos = mapper.queryForFlowingEquipList();
+        companyEquipCountDtos.remove(null);
         companyEquipCountDtos.forEach(c -> {
             RBucket<Set<String>> rBucket = redissonClient.getBucket(getFlowingEquipRedisKey(c.getCompanyCode(), bizType));
             rBucket.set(Arrays.stream(c.getRecords().split(",")).collect(Collectors.toSet()));

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

@@ -47,6 +47,7 @@ public class JgChangeVehicleRegistrationUnitEquipUsedCheckImpl extends BaseEquip
     public void init() {
         // 初始化已经完成或者在流程中安装告知的设备数据
         List<CompanyEquipCountDto> companyEquipCountDtos = mapper.queryForFlowingEquipList();
+        companyEquipCountDtos.remove(null);
         companyEquipCountDtos.forEach(c -> {
             RBucket<Set<String>> rBucket = redissonClient.getBucket(getFlowingEquipRedisKey(c.getCompanyCode(), bizType));
             rBucket.set(Arrays.stream(c.getRecords().split(",")).collect(Collectors.toSet()));

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

@@ -47,6 +47,7 @@ public class JgEnableDisableEquipUsedCheckImpl extends BaseEquipUsedCheckService
     public void init() {
         // 初始化已经完成或者在流程中安装告知的设备数据
         List<CompanyEquipCountDto> companyEquipCountDtos = mapper.queryForFlowingEquipList();
+        companyEquipCountDtos.remove(null);
         companyEquipCountDtos.forEach(c -> {
             RBucket<Set<String>> rBucket = redissonClient.getBucket(getFlowingEquipRedisKey(c.getCompanyCode(), bizType));
             rBucket.set(Arrays.stream(c.getRecords().split(",")).collect(Collectors.toSet()));

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

@@ -46,6 +46,7 @@ public class JgScrapCancelEquipUsedCheckImpl extends BaseEquipUsedCheckService {
     public void init() {
         // 初始化已经完成或者在流程中安装告知的设备数据
         List<CompanyEquipCountDto> companyEquipCountDtos = mapper.queryForFlowingEquipList();
+        companyEquipCountDtos.remove(null);
         companyEquipCountDtos.forEach(c -> {
             RBucket<Set<String>> rBucket = redissonClient.getBucket(getFlowingEquipRedisKey(c.getCompanyCode(), bizType));
             rBucket.set(Arrays.stream(c.getRecords().split(",")).collect(Collectors.toSet()));

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

@@ -47,6 +47,7 @@ public class JgVehicleInformationEquipUsedCheckImpl extends BaseEquipUsedCheckSe
     public void init() {
         // 初始化已经完成或者在流程中安装告知的设备数据
         List<CompanyEquipCountDto> companyEquipCountDtos = mapper.queryForFlowingEquipList();
+        companyEquipCountDtos.remove(null);
         companyEquipCountDtos.forEach(c -> {
             RBucket<Set<String>> rBucket = redissonClient.getBucket(getFlowingEquipRedisKey(c.getCompanyCode(), bizType));
             rBucket.set(Arrays.stream(c.getRecords().split(",")).collect(Collectors.toSet()));

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

@@ -46,6 +46,7 @@ public class MaintainNoticeEquipUsedCheckImpl extends BaseEquipUsedCheckService
     public void init() {
         // 初始化已经完成或者在流程中安装告知的设备数据
         List<CompanyEquipCountDto> companyEquipCountDtos = maintainNoticeMapper.queryForFlowingEquipList();
+        companyEquipCountDtos.remove(null);
         companyEquipCountDtos.forEach(c -> {
             RBucket<Set<String>> rBucket = redissonClient.getBucket(getFlowingEquipRedisKey(c.getCompanyCode(), bizType));
             rBucket.set(Arrays.stream(c.getRecords().split(",")).collect(Collectors.toSet()));

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

@@ -46,6 +46,7 @@ public class MaintenanceContractEquipUsedCheckImpl extends BaseEquipUsedCheckSer
     public void init() {
         // 初始化在流程中的设备数据
         List<CompanyEquipCountDto> companyEquipCountDtos = maintenanceContractMapper.queryForFlowingEquipList();
+        companyEquipCountDtos.remove(null);
         companyEquipCountDtos.forEach(c -> {
             RBucket<Set<String>> rBucket = redissonClient.getBucket(getFlowingEquipRedisKey(c.getCompanyCode(), bizType));
             rBucket.set(Arrays.stream(c.getRecords().split(",")).collect(Collectors.toSet()));

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

@@ -46,6 +46,7 @@ public class ReformNoticeEquipUsedCheckImpl extends BaseEquipUsedCheckService {
     public void init() {
         // 初始化已经完成或者在流程中安装告知的设备数据
         List<CompanyEquipCountDto> companyEquipCountDtos = reformNoticeMapper.queryForFlowingEquipList();
+        companyEquipCountDtos.remove(null);
         companyEquipCountDtos.forEach(c -> {
             RBucket<Set<String>> rBucket = redissonClient.getBucket(getFlowingEquipRedisKey(c.getCompanyCode(), bizType));
             rBucket.set(Arrays.stream(c.getRecords().split(",")).collect(Collectors.toSet()));

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

@@ -47,6 +47,7 @@ public class TransferNoticeEquipUsedCheckImpl extends BaseEquipUsedCheckService
     public void init() {
         // 初始化已经完成或者在流程中安装告知的设备数据
         List<CompanyEquipCountDto> companyEquipCountDtos = noticeMapper.queryForFlowingEquipList();
+        companyEquipCountDtos.remove(null);
         companyEquipCountDtos.forEach(c -> {
             RBucket<Set<String>> rBucket = redissonClient.getBucket(getFlowingEquipRedisKey(c.getCompanyCode(), bizType));
             rBucket.set(Arrays.stream(c.getRecords().split(",")).collect(Collectors.toSet()));

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

@@ -46,6 +46,7 @@ public class UseRegisterEquipUsedCheckImpl extends BaseEquipUsedCheckService {
     public void init() {
         // 初始化已经完成或者在流程中使用登记的设备数据
         List<CompanyEquipCountDto> companyEquipCountDtos = useRegistrationMapper.queryForFlowingEquipList();
+        companyEquipCountDtos.remove(null);
         companyEquipCountDtos.forEach(c -> {
             RBucket<Set<String>> rBucket = redissonClient.getBucket(this.getFlowingEquipRedisKey(c.getCompanyCode(), bizType));
             rBucket.set(Arrays.stream(c.getRecords().split(",")).collect(Collectors.toSet()));