package com.mes.job; import cn.hutool.json.JSONObject; import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; 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.opctask.entity.LoadGlassDeviceTask; import com.mes.opctask.service.LoadGlassDeviceTaskService; import com.mes.pp.service.OptimizeProjectService; import com.mes.rawglassdetails.entity.RawGlassStorageDetails; import com.mes.rawglassstation.service.RawGlassStorageStationService; import com.mes.tools.WebSocketUtils; import com.mes.uppattenusage.entity.UpPattenUsage; import com.mes.uppattenusage.service.UpPattenUsageService; import com.mes.utils.RedisUtil; 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 javax.annotation.Resource; import java.util.List; import java.util.stream.Collectors; /** * @author SNG-010 */ @Component @Slf4j public class PlcLoadGlassTask { @Autowired private UpWorkstationService upWorkstationService; @Autowired private EngineeringService engineeringService; @Autowired private UpPattenUsageService upPattenUsageService; @Autowired private OptimizeProjectService optimizeProjectService; @Autowired RedisUtil redisUtil; @Resource private LoadGlassDeviceTaskService loadGlassDeviceTaskService; @Resource private RawGlassStorageStationService rawGlassStorageStationService; PlcParameterObject plcParameterObject = S7object.getinstance().PlcMesObject; private static final String LOAD_GLASS_DEVICE_ONE_TASK = "load_glass_device_one_task"; private static final String LOAD_GLASS_DEVICE_TWO_TASK = "load_glass_device_two_task"; @Resource private WebSocketUtils webSocketUtils; /** * 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 = 10000) public void loadOneGlass() { loadGlassChild("loadGlassRequestOne", 5, LOAD_GLASS_DEVICE_ONE_TASK, "loadGlassOne"); } @Scheduled(fixedDelay = 10000) public void loadTwoGlass() { loadGlassChild("loadGlassRequestTwo", 6, LOAD_GLASS_DEVICE_TWO_TASK, "loadGlassTwo"); } public String loadGlassChild(String redisRequest, int stationCell, String tableName, String webSocketName) { try { JSONObject jsonObject = new JSONObject(); //当前线路正在执行的工程 Engineering engineering = engineeringService.getOne(new LambdaQueryWrapper().eq(Engineering::getStationCell, stationCell) .eq(Engineering::getState, 1).last("limit 1")); if (null != engineering) { jsonObject.append("engineering", engineering); } //获取当前线路正在执行的工程原片信息 Engineering request = redisUtil.getCacheObject(redisRequest); if (request == null) { request = new Engineering(); request.setStationCell(stationCell); } List upPattenUsages = upPattenUsageService.selectLoadTask(request); jsonObject.append("upPattenUsages", upPattenUsages); //联机状态 LoadGlassDeviceTask LoadTask = loadGlassDeviceTaskService.queryTaskMessage(tableName); jsonObject.append("inkageState", LoadTask.getInkageState()); //工位信息 List rawGlassStorageDetailList = rawGlassStorageStationService.listRawGlassDetails(); List stationList = rawGlassStorageDetailList.stream().filter(item -> item.getDeviceId() == stationCell).collect(Collectors.toList()); jsonObject.append("stationList", stationList); webSocketUtils.sendToWeb(webSocketName, jsonObject); } catch (Exception e) { e.printStackTrace(); } return "success"; } // @Scheduled(fixedDelay = 5000) public void loadGlassStatus() { JSONObject jsonObject = new JSONObject(); //正在进行的任务 String inkageStatus = plcParameterObject.getPlcParameter("InkageStatus").getValue(); // String inkageStatus ="1"; jsonObject.append("InkageStatus", inkageStatus); webSocketUtils.sendToWeb("loadGlass", jsonObject); } 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); } }