From bd2f54cccfcbe5a1b41c516e1146c0c335856274 Mon Sep 17 00:00:00 2001 From: wang <3597712270@qq.com> Date: 星期三, 29 五月 2024 09:25:20 +0800 Subject: [PATCH] Merge branch 'master' of http://10.153.19.25:10101/r/HangZhouMes --- hangzhoumesParent/moduleService/LoadGlassModule/src/main/java/com/mes/job/PlcLoadGlassTask.java | 64 ++++++++++++++++++++++++++------ 1 files changed, 52 insertions(+), 12 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 a019c7c..c05fbee 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.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.tools.WebSocketServer; 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; @@ -52,16 +62,16 @@ int workId = upwork.getWorkstationId();//宸ヤ綅id double width = upwork.getPatternWidth();//瀹藉害 double height = upwork.getPatternHeight();//楂樺害 - S7object.getinstance().plccontrol.writeWord(plcParameterObject.getPlcParameter("WorkId").getAddress(), (short) workId); - S7object.getinstance().plccontrol.writeWord(plcParameterObject.getPlcParameter("GlassWidth").getAddress(), (short) width); - S7object.getinstance().plccontrol.writeWord(plcParameterObject.getPlcParameter("GlassHeight").getAddress(), (short) height); - S7object.getinstance().plccontrol.writeWord(plcParameterObject.getPlcParameter("MesToPlc").getAddress(), (short) 1); + S7object.getinstance().plccontrol.writetime(plcParameterObject.getPlcParameter("WorkId").getAddress(), workId); + S7object.getinstance().plccontrol.writetime(plcParameterObject.getPlcParameter("GlassWidth").getAddress(), (long) width); + S7object.getinstance().plccontrol.writetime(plcParameterObject.getPlcParameter("GlassHeight").getAddress(), (long) height); + S7object.getinstance().plccontrol.writetime(plcParameterObject.getPlcParameter("MesToPlc").getAddress(), 1); //鏇存敼涓婄墖琛ㄧ姸鎬� upPattenUsageService.updateUpPattenUsageState(upPattenUsage, workId); } } - if ("1".equals(mesToPlc) && "0".equals(loadRequest)) { + if("1".equals(mesToPlc)&& "0".equals(loadRequest)){ //璇锋眰瀛椾负闆舵椂锛屼换鍔″瓧娓呴浂 S7object.getinstance().plccontrol.writetime(plcParameterObject.getPlcParameter("MesToPlc").getAddress(), 0); } @@ -73,7 +83,7 @@ } @Scheduled(fixedDelay = 300) - public void plcLoadGlassReport() { + public void plcLoadGlassReport(){ //鑾峰彇鏄惁鏈夋眹鎶� String loadStatus = plcParameterObject.getPlcParameter("PlcStatus").getValue(); if (loadStatus != null) { @@ -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; } } } - public void overTask(String loadStatus, int state) { + @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("loadGlass"); + 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