diff --git a/mallinkCallback/src/main/java/com/iformall/controller/device/KwBoxV1Controller.java b/mallinkCallback/src/main/java/com/iformall/controller/device/KwBoxV1Controller.java index 7858fd69b..ad7caaf65 100644 --- a/mallinkCallback/src/main/java/com/iformall/controller/device/KwBoxV1Controller.java +++ b/mallinkCallback/src/main/java/com/iformall/controller/device/KwBoxV1Controller.java @@ -83,7 +83,8 @@ public class KwBoxV1Controller extends BaseController { record.setStatus(EnumBoxStatus.REGISTERED.getCode()); kwBoxService.saveOrUpdate(record); Map data = new HashMap<>(); - data.put("config",kwBox.getConfig()); + if (kwBox.getConfig() != null) + data.put("config",kwBox.getConfig() ); List meters = kwBoxService.findMeters(kwBox); data.put("meters",meters); return new ResultData(data); diff --git a/mallinkService/src/main/java/com/iformall/service/kw/impl/KwBoxServiceImpl.java b/mallinkService/src/main/java/com/iformall/service/kw/impl/KwBoxServiceImpl.java index b57c707aa..e621c59ad 100644 --- a/mallinkService/src/main/java/com/iformall/service/kw/impl/KwBoxServiceImpl.java +++ b/mallinkService/src/main/java/com/iformall/service/kw/impl/KwBoxServiceImpl.java @@ -117,11 +117,23 @@ public class KwBoxServiceImpl implements KwBoxService { List kwBoxMeters = kwBoxMeterService.findList(kwBoxMeter); + if (kwBoxMeters.isEmpty()) { + logger.info("没找到盒子表关联项: boxId="+kwBoxMeter.getBoxId()); + return null; + } KwMeter kwMeter = new KwMeter(); kwMeter.setIds(kwBoxMeters.stream().map(KwBoxMeter::getMeterId).collect(Collectors.toList())); + if (kwMeter.getIds().isEmpty()) { + logger.info("没找到盒子关联的表: boxId="+kwBoxMeter.getBoxId()); + return null; + } List kwMeters = kwMeterService.findList(kwMeter); + if (kwMeter.getIds().isEmpty()) { + logger.info("没找到盒子关联的表: ids=" + kwBoxMeter.getIds()); + return null; + } return kwMeters.stream().map(KwMeter::getAddress).collect(Collectors.toList()); } @@ -134,17 +146,21 @@ public class KwBoxServiceImpl implements KwBoxService { List kwBoxMeters = kwBoxMeterService.findList(kwBoxMeter); + if (kwBoxMeters.isEmpty()) { + logger.info("没找到盒子表关联项: boxId="+kwBoxMeter.getBoxId()); + return null; + } + KwMeter kwMeter = new KwMeter(); kwMeter.setAddress(addr); kwMeter.setIds(kwBoxMeters.stream().map(KwBoxMeter::getMeterId).collect(Collectors.toList())); List kwMeters = kwMeterService.findList(kwMeter); - - - if (kwMeters.size() > 0) - return kwMeters.get(0); - else + if (kwMeters.isEmpty()) { + logger.info("没找到盒子关联的表: ids="+kwBoxMeter.getIds() +",addr=",kwMeter.getAddress()); return null; + } + return kwMeters.get(0); } }