diff --git a/cs-harmonic/cs-harmonic-boot/src/main/java/com/njcn/csharmonic/service/impl/DataServiceImpl.java b/cs-harmonic/cs-harmonic-boot/src/main/java/com/njcn/csharmonic/service/impl/DataServiceImpl.java index 0af297e..dfa7714 100644 --- a/cs-harmonic/cs-harmonic-boot/src/main/java/com/njcn/csharmonic/service/impl/DataServiceImpl.java +++ b/cs-harmonic/cs-harmonic-boot/src/main/java/com/njcn/csharmonic/service/impl/DataServiceImpl.java @@ -348,7 +348,16 @@ public class DataServiceImpl implements IDataService { Double value = Double.parseDouble(redisUtilObjectByKey.toString()); moduleVO.setModuleState(channelState(value)); } else { - moduleVO.setModuleState("离线"); + //再询问一次 + publisher.send("/Pfm/DevCmd/" + version + "/" + nDid, new Gson().toJson(dto), 1, false); + Thread.sleep(800); + Object redisUtilObjectByKey2 = redisUtil.getObjectByKey("ApfRtData:" + mid); + if (ObjectUtil.isNotNull(redisUtilObjectByKey2)) { + Double value = Double.parseDouble(redisUtilObjectByKey2.toString()); + moduleVO.setModuleState(channelState(value)); + } else { + moduleVO.setModuleState("离线"); + } } mid = mid + 1; if (mid > 10000) {