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.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; import com.mes.workstation.service.UpWorkstationService; import lombok.extern.slf4j.Slf4j; 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 */ @Component @Slf4j public class PlcLoadGlassTask { @Autowired private UpWorkstationService upWorkstationService; @Autowired private EngineeringService engineeringService; @Autowired private UpPattenUsageService upPattenUsageService; @Autowired private OptimizeProjectService optimizeProjectService; PlcParameterObject plcParameterObject = S7object.getinstance().PlcMesObject; /** * fixedRate : 上一个调用开始后再次调用的延时（不用等待上一次调用完成） * fixedDelay : 上一个调用结束后再次调用的延时 */ @Scheduled(fixedDelay = 300) public void plcLoadGlassTask() throws InterruptedException { try { //获取联机状态 String inkageStatus = plcParameterObject.getPlcParameter("InkageStatus").getValue(); //获取是否有上片请求 String loadRequest = plcParameterObject.getPlcParameter("loadRequest").getValue(); //mes状态 String mesToPlc = plcParameterObject.getPlcParameter("MesToPlc").getValue(); if ("1".equals(inkageStatus) && "1".equals(loadRequest)) { //判断开始上片的工程号 Engineering engineering = engineeringService.selectInitiate(1); if (engineering != null) { log.info("开始上片任务"); UpPattenUsage upPattenUsage = upWorkstationService.selectPriority(engineering); log.info("当有请求时查询当前上片顺序的玻璃信息{}", upPattenUsage); UpWorkstation upwork = upWorkstationService.selectWorkstation(upPattenUsage); log.info("符合的尺寸的工位玻璃：{}", upwork); if (upwork != null) { int workId = upwork.getWorkstationId();//工位id double width = upwork.getPatternWidth();//宽度 double height = upwork.getPatternHeight();//高度 S7object.getinstance().plccontrol.writeWord(plcParameterObject.getPlcParameter("WorkId").getAddress(), workId); S7object.getinstance().plccontrol.writeWord(plcParameterObject.getPlcParameter("GlassWidth").getAddress(), (int) width); S7object.getinstance().plccontrol.writeWord(plcParameterObject.getPlcParameter("GlassHeight").getAddress(), (int) height); S7object.getinstance().plccontrol.writeWord(plcParameterObject.getPlcParameter("MesToPlc").getAddress(), 1); //更改上片表状态 upPattenUsageService.updateUpPattenUsageState(upPattenUsage, workId); } } } if ("1".equals(mesToPlc) && "0".equals(loadRequest)) { //请求字为零时，任务字清零 S7object.getinstance().plccontrol.writeWord(plcParameterObject.getPlcParameter("MesToPlc").getAddress(), 0); } //执行后休眠300毫秒 //Thread.sleep(300); } catch (Exception e) { e.printStackTrace(); } } @Scheduled(fixedDelay = 300) public void plcLoadGlassReport() { //获取是否有汇报 String loadStatus = plcParameterObject.getPlcParameter("PlcStatus").getValue(); if (loadStatus != null) { log.info(loadStatus); switch (loadStatus) { case "1": log.info("收到汇报任务完成"); //减少工位数量,完成任务状态 overTask(loadStatus, 100); break; case "2": log.info("收到汇报未完成任务"); //减少工位数量,恢复任务状态 overTask(loadStatus, 0); break; case "3": log.info("收到汇报玻璃破损"); overTask(loadStatus, 0); break; case "0": S7object.getinstance().plccontrol.writeWord(plcParameterObject.getPlcParameter("MesToPlcStatus").getAddress(), 0); break; } } } @Scheduled(fixedDelay = 1000) public void loadGlassHome() { JSONObject jsonObject = new JSONObject(); //正在进行的任务 List upPattenUsages = upPattenUsageService.prioritylist(); if(upPattenUsages!=null){ jsonObject.append("prioritylist", upPattenUsages); } //工位信息 List upWorkstations = upWorkstationService.list(); jsonObject.append("list", upWorkstations); //是否开始工程 Engineering engineering = engineeringService.selectInitiate(1); jsonObject.append("engineering", engineering); ArrayList sendwServer = WebSocketServer.sessionMap.get("loadGlass"); if (sendwServer != null) { for (WebSocketServer webserver : sendwServer) { if (webserver != null) { webserver.sendMessage(jsonObject.toString()); // List messages = webserver.getMessages(); // if (!messages.isEmpty()) { // // // 将最后一个消息转换为整数类型的列表 // webserver.clearMessages(); // } } else { log.info("Home is closed"); } } } } @Scheduled(fixedDelay = 5000) public void loadGlassStatus() { JSONObject jsonObject = new JSONObject(); //正在进行的任务 String inkageStatus =plcParameterObject.getPlcParameter("InkageStatus").getValue(); // String inkageStatus ="1"; jsonObject.append("InkageStatus", inkageStatus); ArrayList sendwServer = WebSocketServer.sessionMap.get("loadGlass"); if (sendwServer != null) { for (WebSocketServer webserver : sendwServer) { if (webserver != null) { webserver.sendMessage(jsonObject.toString()); } else { log.info("Home is closed"); } } } } @Scheduled(fixedDelay = 1000) public void loadGlassIsRun() { JSONObject jsonObject = new JSONObject(); //是否开始工程 Engineering engineering = engineeringService.selectInitiate(1); jsonObject.append("engineering", engineering); //工位信息 List upWorkstations = upWorkstationService.list(); jsonObject.append("list", upWorkstations); ArrayList sendwServer = WebSocketServer.sessionMap.get("loadGlassIsRun"); if (sendwServer != null) { for (WebSocketServer webserver : sendwServer) { if (webserver != null) { webserver.sendMessage(jsonObject.toString()); } else { log.info("Home is closed"); } } } } public void overTask(String loadStatus, int state) { UpPattenUsage upPattenUsage = upPattenUsageService.selectOverTask(); if (upPattenUsage != null) { log.info("收到汇报清{}状态", loadStatus); //减少工位数量 upWorkstationService.reduceWorkstationNumber(upPattenUsage.getState()); //完成上片表状态 upPattenUsageService.updateUpPattenUsageState(upPattenUsage, state); //判断是否是最后一块玻璃 UpPattenUsage sequence = upPattenUsageService.selectSequence(upPattenUsage); //如果是最后一块时完成工程任务 optimizeProjectService.overTask(sequence, 300); } S7object.getinstance().plccontrol.writeWord(plcParameterObject.getPlcParameter("MesToPlcStatus").getAddress(), 1); } }