cmhi
/
dispose
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

OCT 

REM:
1. 修正设备缓存与数据库同步逻辑
This commit is contained in:
HuangXin 2021-02-02 19:01:58 +08:00
parent f649ac0207
commit 11b93e1ce2
1 changed files with 8 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

17
src/main/java/com/dispose/service/impl/DisposeAbilityRouterServiceImpl.java
View File

@ -206,15 +206,10 @@ public class DisposeAbilityRouterServiceImpl implements DisposeAbilityRouterServ
for (AbilityInfo v : getAllAbilityDevices()) { for (AbilityInfo v : getAllAbilityDevices()) {
DisposeDevice dev = disposeDeviceManager.getDisposeDeviceById(v.getDev().getId()); DisposeDevice dev = disposeDeviceManager.getDisposeDeviceById(v.getDev().getId());
if (dev != null && !dev.getStatus().equals(ObjectStatus.NORMAL)) { if (dev == null || !dev.getStatus().equals(ObjectStatus.NORMAL)) {
// 更新设备状态 // 如果数据库中设备不存在，那么删除该设备
v.getDev().setStatus(dev.getStatus()); v.getDev().setStatus(ObjectStatus.DELETED);
} else {
v.getDb().periodTaskRuntime();
// 同步最新处置平台业务信息到设备
v.getDb().upgradeServiceGroup(serviceGroupMapper.selectAll());
// 数据库中的设备信息和缓存中的设备信息同步 // 数据库中的设备信息和缓存中的设备信息同步
v.getDev().getDevCapacity().forEach(k -> dev.getDevCapacity().forEach(m -> { v.getDev().getDevCapacity().forEach(k -> dev.getDevCapacity().forEach(m -> {
if (k.getId().equals(m.getId())) { if (k.getId().equals(m.getId())) {
@ -239,6 +234,10 @@ public class DisposeAbilityRouterServiceImpl implements DisposeAbilityRouterServ
} }
} }
})); }));
v.getDb().periodTaskRuntime();
// 同步最新处置平台业务信息到设备
v.getDb().upgradeServiceGroup(serviceGroupMapper.selectAll());
} }
} }
} }