fix:(jg):管道补证功能修改

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

@@ -577,11 +577,15 @@ public class JgCertificateReplenishServiceImpl extends BaseService<JgCertificate
         List<JgCertificateReplenishEq> replenishEqs = certificateReplenishEqService.getBaseMapper().selectList(new LambdaQueryWrapper<JgCertificateReplenishEq>()
                 .eq(JgCertificateReplenishEq::getCertificateReplenishId, certRep.getSequenceNbr()));
         replenishEqs.forEach(eq -> {
-            IdxBizJgFactoryInfo factoryInfo = idxBizJgFactoryInfoService.getOne(new LambdaQueryWrapper<IdxBizJgFactoryInfo>().eq(IdxBizJgFactoryInfo::getRecord, eq.getEquId()));
+            IdxBizJgFactoryInfo factoryInfo = idxBizJgFactoryInfoService.getOne(new LambdaQueryWrapper<IdxBizJgFactoryInfo>()
+                    .eq(IdxBizJgFactoryInfo::getRecord, eq.getEquId()));
+            String productCode = Optional.ofNullable(factoryInfo)
+                    .map(IdxBizJgFactoryInfo::getFactoryNum)
+                    .orElse(null);
             JgCertificateChangeRecordEq changeRecordEq = new JgCertificateChangeRecordEq()
                     .setChangeRecordId(String.valueOf(certChangeRecordSeq))// 登记证记录主键
-                    .setEquId(eq.getEquId())// 设备主键
-                    .setProductCode(factoryInfo.getFactoryNum());
+                    .setEquId(eq.getEquId())
+                    .setProductCode(productCode);
             certificateChangeRecordEqService.save(changeRecordEq);
         });
     }