Microservice/govern
3
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

APF模块询问逻辑调整

Browse Source
This commit is contained in:
xy
2025-07-11 13:27:40 +08:00
parent cb76943f0f
commit 40588c6cd4
1 changed files with 10 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

9
cs-harmonic/cs-harmonic-boot/src/main/java/com/njcn/csharmonic/service/impl/DataServiceImpl.java
View File

@@ -347,9 +347,18 @@ public class DataServiceImpl implements IDataService {
if (ObjectUtil.isNotNull(redisUtilObjectByKey)) { if (ObjectUtil.isNotNull(redisUtilObjectByKey)) {
Double value = Double.parseDouble(redisUtilObjectByKey.toString()); Double value = Double.parseDouble(redisUtilObjectByKey.toString());
moduleVO.setModuleState(channelState(value)); moduleVO.setModuleState(channelState(value));
} else {
//再询问一次
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 { } else {
moduleVO.setModuleState("离线"); moduleVO.setModuleState("离线");
} }
}
mid = mid + 1; mid = mid + 1;
if (mid > 10000) { if (mid > 10000) {
mid = 1; mid = 1;