root/xinFengTianNeng
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

opt:获取设备数量加日志

Browse Source
This commit is contained in:
gongbaoxiong
2024-11-22 22:13:11 +08:00
parent 41b19dc097
commit 4b32fcb1d1
2 changed files with 9 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
lms/nladmin-system/nlsso-server/src/main/java/org/nl/wms/cockpit/service/impl/CockpitServiceImpl.java
View File

@@ -912,9 +912,11 @@ public class CockpitServiceImpl implements CockpitService {
// 固化室详情
CompletableFuture<JSONArray> task1 = CompletableFuture.supplyAsync(() -> {
JSONArray result = cockpitMapper.getGHSInteriorList();
log.info("读取固化室详情信息数量: {}", result.size());
if (ObjectUtil.isNotEmpty(result)) {
JSONObject ghsDetailInfo = new JSONObject();
JSONArray guHuaShi = (JSONArray) redisUtils.get("guhuashi");
log.info("读取acs缓存固化室数量: {}", guHuaShi.size());
if(ObjectUtil.isNotEmpty(guHuaShi)) {
//todo 待补充信号逻辑
for (Object object : guHuaShi) {
@@ -942,13 +944,10 @@ public class CockpitServiceImpl implements CockpitService {
log.error("读取设备缓存信息: {}", e.getMessage(), e);
return null;
});
task1.exceptionally((e) -> {
log.error("读取设备缓存信息: {}", e.getMessage(), e);
return null;
});
//查询保湿间信息
CompletableFuture<List<Map<String, Object>>> task2 = CompletableFuture.supplyAsync(() -> {
JSONArray baoShiJian = (JSONArray) redisUtils.get("baoshijian");
log.info("读取acs缓存保湿间数量: {}", baoShiJian.size());
//todo 设备状态待补充信号逻辑
if (ObjectUtil.isNotEmpty(baoShiJian)) {
for (Object object : baoShiJian) {
@@ -970,6 +969,7 @@ public class CockpitServiceImpl implements CockpitService {
//查询检测站点数据
CompletableFuture<List<Map<String, Object>>> task3 = CompletableFuture.supplyAsync(() -> {
JSONArray site = (JSONArray) redisUtils.get("site");
log.info("读取acs缓存检测站点数量: {}", site.size());
//todo 待补充信号逻辑
if (ObjectUtil.isNotEmpty(site)) {
for (Object object : site) {
@@ -992,6 +992,7 @@ public class CockpitServiceImpl implements CockpitService {
//查询AGV数据
CompletableFuture<List<Map<String, Object>>> task4 = CompletableFuture.supplyAsync(() -> {
JSONArray agv = (JSONArray) redisUtils.get("agv");
log.info("读取acs缓存agv数量: {}", agv.size());
if (ObjectUtil.isNotEmpty(agv)) {
//todo 待补充信号逻辑
for (Object object : agv) {
@@ -1020,6 +1021,7 @@ public class CockpitServiceImpl implements CockpitService {
//查询RGV设备信息
CompletableFuture<List<Map<String, Object>>> task5 = CompletableFuture.supplyAsync(() -> {
JSONArray rgv = (JSONArray) redisUtils.get("rgv");
log.info("读取acs缓存rgv数量: {}", rgv.size());
if (ObjectUtil.isNotEmpty(rgv)) {
//todo 待补充信号逻辑
for (Object object : rgv) {