From e36bb1819459d1bda945b9068b0a8dfb987c25b7 Mon Sep 17 00:00:00 2001
From: wangfei <3597712270@qq.com>
Date: 星期五, 20 九月 2024 15:46:08 +0800
Subject: [PATCH] 入库新增

---
 hangzhoumesParent/moduleService/GlassStorageModule/src/main/java/com/mes/job/push.java |   31 +++++++++++++++++++------------
 1 files changed, 19 insertions(+), 12 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 700a1c1..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,22 +1,22 @@
 package com.mes.job;
 
 import cn.hutool.json.JSONObject;
-
-import com.mes.shelfrack.entity.request.RawUsageAndShelfRack;
+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.entity.request.StorageTaskRequest;
 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.text.SimpleDateFormat;
 import java.util.ArrayList;
-import java.util.Date;
 import java.util.List;
-import java.util.Map;
 
 @Slf4j
 @Component
@@ -26,20 +26,27 @@
     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<RawUsageAndShelfRack> rack =  shelfRackService.selectshelf_rack();
-        List<StorageTaskRequest>  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()) {

--
Gitblit v1.8.0