From d85033771c1dcdd07eacf6c1dcd2c9feceba7798 Mon Sep 17 00:00:00 2001
From: wangfei <3597712270@qq.com>
Date: 星期四, 19 九月 2024 15:08:25 +0800
Subject: [PATCH] 查询使用websockect实时推送数据
---
hangzhoumesParent/moduleService/GlassStorageModule/src/main/java/com/mes/job/push.java | 28 ++++++++++++++++++++--------
1 files changed, 20 insertions(+), 8 deletions(-)
diff --git a/hangzhoumesParent/moduleService/GlassStorageModule/src/main/java/com/mes/job/push.java b/hangzhoumesParent/moduleService/GlassStorageModule/src/main/java/com/mes/job/push.java
index 934155a..df39184 100644
--- a/hangzhoumesParent/moduleService/GlassStorageModule/src/main/java/com/mes/job/push.java
+++ b/hangzhoumesParent/moduleService/GlassStorageModule/src/main/java/com/mes/job/push.java
@@ -1,18 +1,22 @@
package com.mes.job;
import cn.hutool.json.JSONObject;
-
+import com.mes.rawglassdetails.entity.RawGlassStorageDetails;
+import com.mes.rawglassdetails.service.RawGlassStorageDetailsService;
+import com.mes.rawglassstation.entity.RawGlassStorageStation;
+import com.mes.rawglassstation.service.RawGlassStorageStationService;
+import com.mes.rawglasstask.entity.RawGlassStorageTask;
+import com.mes.rawglasstask.service.RawGlassStorageTaskService;
import com.mes.shelfrack.service.ShelfRackService;
import com.mes.storagetask.service.StorageTaskService;
import com.mes.tools.WebSocketServer;
import org.springframework.beans.factory.annotation.Autowired;
-import org.springframework.scheduling.annotation.Scheduled;
import lombok.extern.slf4j.Slf4j;
+import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Component;
import java.util.ArrayList;
import java.util.List;
-import java.util.Map;
@Slf4j
@Component
@@ -22,24 +26,32 @@
private StorageTaskService storageTaskService;
@Autowired
private ShelfRackService shelfRackService;
+ @Autowired
+ private RawGlassStorageDetailsService rawGlassStorageDetailsService;
+ @Autowired
+ private RawGlassStorageStationService rawGlassStorageStationService;
+ @Autowired
+ private RawGlassStorageTaskService rawGlassStorageTaskService;
@Scheduled(fixedDelay = 2000)
public void sendDownWorkstations() {
log.info("鍙戦�佷换鍔′俊鎭拰鏋跺瓙淇℃伅");
JSONObject jsonObject = new JSONObject();
-
- List<Map<String, Object>> rack = shelfRackService.selectshelf_rack();
- List<Map<String, Object>> tasks = storageTaskService.Tasks();
+ List<RawGlassStorageDetails> rack = rawGlassStorageDetailsService.list();
+ List<RawGlassStorageStation> state = rawGlassStorageStationService.list();
+ //List<RawGlassStorageTask> tasks = rawGlassStorageTaskService.list();
+ List<RawGlassStorageTask> tasks = rawGlassStorageTaskService.findAll();
jsonObject.append("rack",rack);
+ jsonObject.append("state",state);
jsonObject.append("tasks",tasks);
log.info(jsonObject.toString());
- ArrayList<WebSocketServer> sendwServer = WebSocketServer.sessionMap.get("storageTask");
+ ArrayList<WebSocketServer> sendwServer = WebSocketServer.sessionMap.get("rawGlass");
if (sendwServer != null) {
for (WebSocketServer webserver : sendwServer) {
if (webserver != null&&webserver.session.isOpen()) {
log.info("宸插彂閫�");
- webserver.sendMessage(jsonObject.toString());
+ webserver.sendMessage(String.valueOf(jsonObject));
}
}
}
--
Gitblit v1.8.0