From 7f120fc7a05d560db1e47b3ef243fde19a0c56b4 Mon Sep 17 00:00:00 2001
From: wu <731351411@qq.com>
Date: 星期二, 28 五月 2024 09:01:19 +0800
Subject: [PATCH] 更改开始上片和暂停接口,选择工程增加信息预览

---
 hangzhoumesParent/moduleService/LoadGlassModule/src/main/java/com/mes/job/PlcLoadGlassTask.java |   54 +++++++++++++++++++++++++++++++++++++++++++++++-------
 1 files changed, 47 insertions(+), 7 deletions(-)

diff --git a/hangzhoumesParent/moduleService/LoadGlassModule/src/main/java/com/mes/job/PlcLoadGlassTask.java b/hangzhoumesParent/moduleService/LoadGlassModule/src/main/java/com/mes/job/PlcLoadGlassTask.java
index 3fd3a87..2e4c02d 100644
--- a/hangzhoumesParent/moduleService/LoadGlassModule/src/main/java/com/mes/job/PlcLoadGlassTask.java
+++ b/hangzhoumesParent/moduleService/LoadGlassModule/src/main/java/com/mes/job/PlcLoadGlassTask.java
@@ -1,9 +1,13 @@
 package com.mes.job;
 
+import cn.hutool.json.JSONObject;
 import com.mes.common.S7object;
+import com.mes.common.WebSocketServer;
 import com.mes.device.PlcParameterObject;
 import com.mes.engineering.entity.Engineering;
 import com.mes.engineering.service.EngineeringService;
+import com.mes.pp.entity.OptimizeProject;
+import com.mes.pp.service.OptimizeProjectService;
 import com.mes.uppattenusage.entity.UpPattenUsage;
 import com.mes.uppattenusage.service.UpPattenUsageService;
 import com.mes.workstation.entity.UpWorkstation;
@@ -12,6 +16,9 @@
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.scheduling.annotation.Scheduled;
 import org.springframework.stereotype.Component;
+
+import java.util.ArrayList;
+import java.util.List;
 
 /**
  * @author SNG-010
@@ -26,6 +33,9 @@
     private EngineeringService engineeringService;
     @Autowired
     private UpPattenUsageService upPattenUsageService;
+    @Autowired
+    private OptimizeProjectService optimizeProjectService;
+
 
     PlcParameterObject plcParameterObject = S7object.getinstance().PlcMesObject;
 
@@ -34,7 +44,7 @@
      * fixedDelay : 涓婁竴涓皟鐢ㄧ粨鏉熷悗鍐嶆璋冪敤鐨勫欢鏃�
      */
 
-    @Scheduled(fixedDelay = 300)
+    @Scheduled(fixedDelay = 30000000)
     public void plcLoadGlassTask() throws InterruptedException {
         try {
             //鑾峰彇鏄惁鏈変笂鐗囪姹�
@@ -72,7 +82,7 @@
         }
     }
 
-    @Scheduled(fixedDelay = 300)
+    @Scheduled(fixedDelay = 30000000)
     public void plcLoadGlassReport(){
         //鑾峰彇鏄惁鏈夋眹鎶�
         String loadStatus = plcParameterObject.getPlcParameter("PlcStatus").getValue();
@@ -81,7 +91,8 @@
             switch (loadStatus) {
                 case "1":
                     log.info("鏀跺埌姹囨姤浠诲姟瀹屾垚");
-                    S7object.getinstance().plccontrol.writetime(plcParameterObject.getPlcParameter("MesToPlcStatus").getAddress(), 1);
+                    //鍑忓皯宸ヤ綅鏁伴噺,瀹屾垚浠诲姟鐘舵��
+                    overTask(loadStatus, 100);
                     break;
                 case "2":
                     log.info("鏀跺埌姹囨姤鏈畬鎴愪换鍔�");
@@ -93,15 +104,40 @@
                     overTask(loadStatus, 0);
                     break;
                 case "0":
-                    log.info("鏀跺埌姹囨姤娓�0鐘舵��");
-                    //鍑忓皯宸ヤ綅鏁伴噺,瀹屾垚浠诲姟鐘舵��
-                    overTask(loadStatus, 100);
+                    S7object.getinstance().plccontrol.writetime(plcParameterObject.getPlcParameter("MesToPlcStatus").getAddress(), 0);
                     break;
             }
         }
     }
 
+//    @Scheduled(fixedDelay = 300)
+//    public void loadGlassHome(){
+//        JSONObject jsonObject = new JSONObject();
+//        //姝e湪杩涜鐨勪换鍔�
+//        List<UpPattenUsage> upPattenUsages = upPattenUsageService.prioritylist();
+//        jsonObject.append("prioritylist", upPattenUsages);
+//        //宸ヤ綅淇℃伅
+//        List<UpWorkstation> upWorkstations = upWorkstationService.list();
+//        jsonObject.append("list", upWorkstations);
+//        ArrayList<WebSocketServer> sendwServer = WebSocketServer.sessionMap.get("returns");
+//        if (sendwServer != null) {
+//            for (WebSocketServer webserver : sendwServer) {
+//                if (webserver != null) {
+//                    webserver.sendMessage(jsonObject.toString());
+//                    List<String> messages = webserver.getMessages();
+//                    if (!messages.isEmpty()) {
+//                        // // 灏嗘渶鍚庝竴涓秷鎭浆鎹负鏁存暟绫诲瀷鐨勫垪琛�
+//                        webserver.clearMessages();
+//                    }
+//                } else {
+//                    log.info("Home is closed");
+//                }
+//            }
+//        }
+//    }
+
     public void overTask(String loadStatus, int state)  {
+
         UpPattenUsage upPattenUsage = upPattenUsageService.selectOverTask();
         if (upPattenUsage != null) {
             log.info("鏀跺埌姹囨姤娓厈}鐘舵��", loadStatus);
@@ -109,8 +145,12 @@
             upWorkstationService.reduceWorkstationNumber(upPattenUsage.getState());
             //瀹屾垚涓婄墖琛ㄧ姸鎬�
             upPattenUsageService.updateUpPattenUsageState(upPattenUsage, state);
-            S7object.getinstance().plccontrol.writetime(plcParameterObject.getPlcParameter("MesToPlcStatus").getAddress(), 0);
+            //鍒ゆ柇鏄惁鏄渶鍚庝竴鍧楃幓鐠�
+            UpPattenUsage sequence=upPattenUsageService.selectSequence(upPattenUsage);
+            //濡傛灉鏄渶鍚庝竴鍧楁椂瀹屾垚宸ョ▼浠诲姟
+            optimizeProjectService.overTask(sequence,300);
         }
+        S7object.getinstance().plccontrol.writetime(plcParameterObject.getPlcParameter("MesToPlcStatus").getAddress(), 1);
     }
 
 }
\ No newline at end of file

--
Gitblit v1.8.0