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