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.WebSocketServer;
|
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.ArrayList;
|
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";
|
|
/**
|
* 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");
|
}
|
|
|
private void loadGlassChild(String redisRequest, int stationCell, String tableName, String webSocketName) {
|
try {
|
JSONObject jsonObject = new JSONObject();
|
//当前线路正在执行的工程
|
Engineering engineering = engineeringService.getOne(new LambdaQueryWrapper<Engineering>().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<UpPattenUsage> upPattenUsages = upPattenUsageService.selectLoadTask(request);
|
jsonObject.append("upPattenUsages", upPattenUsages);
|
|
//联机状态
|
LoadGlassDeviceTask LoadTask = loadGlassDeviceTaskService.queryTaskMessage(tableName);
|
jsonObject.append("inkageState", LoadTask.getInkageState());
|
//工位信息
|
List<RawGlassStorageDetails> rawGlassStorageDetailList = rawGlassStorageStationService.listRawGlassDetails();
|
List<RawGlassStorageDetails> stationList = rawGlassStorageDetailList.stream().filter(item -> item.getDeviceId() == stationCell).collect(Collectors.toList());
|
jsonObject.append("stationList", stationList);
|
|
ArrayList<WebSocketServer> sendwServer = WebSocketServer.sessionMap.get(webSocketName);
|
if (sendwServer != null) {
|
for (WebSocketServer webserver : sendwServer) {
|
if (webserver != null) {
|
webserver.sendMessage(jsonObject.toString());
|
} else {
|
log.info("loadGlass is closed");
|
}
|
}
|
}
|
} catch (Exception e) {
|
e.printStackTrace();
|
}
|
}
|
|
|
// @Scheduled(fixedDelay = 5000)
|
public void loadGlassStatus() {
|
JSONObject jsonObject = new JSONObject();
|
//正在进行的任务
|
String inkageStatus = plcParameterObject.getPlcParameter("InkageStatus").getValue();
|
// String inkageStatus ="1";
|
jsonObject.append("InkageStatus", inkageStatus);
|
|
ArrayList<WebSocketServer> sendwServer = WebSocketServer.sessionMap.get("loadGlass");
|
if (sendwServer != null) {
|
for (WebSocketServer webserver : sendwServer) {
|
if (webserver != null) {
|
webserver.sendMessage(jsonObject.toString());
|
} else {
|
log.info("loadGlass 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);
|
}
|
|
}
|
