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.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 PlcUpGlassTask {
|
|
@Autowired
|
private UpPattenUsageService upPattenUsageService;
|
@Autowired
|
private UpWorkstationService upWorkstationService;
|
@Autowired
|
private EngineeringService engineeringService;
|
|
PlcParameterObject plcParameterObject = S7object.getinstance().PlcMesObject;
|
|
/**
|
* fixedRate : 上一个调用开始后再次调用的延时（不用等待上一次调用完成）
|
* fixedDelay : 上一个调用结束后再次调用的延时
|
*/
|
|
// @Scheduled(fixedDelay = 300)
|
public void plcLoadGlassTask() throws InterruptedException {
|
try {
|
//先判断是否有正在开始的工程
|
Engineering engineering = engineeringService.selectInitiate(1, 1);
|
//获取是否有上片请求
|
String loadRequest1 = plcParameterObject.getPlcParameter("loadRequest").getValue();
|
//当同时有上片请求和有正在开始的工程时进入上片判断
|
if (loadRequest1.equals(1) && engineering != null) {
|
//获取当前开始的工程号
|
UpPattenUsage upPattenUsage = upWorkstationService.selectPriority(engineering);
|
//用工程号查询本次上片的尺寸信息获取工位位置
|
//UpWorkstation upwork = upWorkstationService.selectWorkstation(upPattenUsage);
|
|
}
|
//执行后休眠300毫秒
|
//Thread.sleep(300);
|
} catch (Exception e) {
|
e.printStackTrace();
|
}
|
}
|
|
// @Scheduled(fixedDelay = 300)
|
public void plcLoadGlassTask2() throws InterruptedException {
|
try {
|
//先判断是否有正在开始的工程
|
Engineering engineering = engineeringService.selectInitiate(2, 1);
|
//获取是否有上片请求
|
String loadRequest2 = plcParameterObject.getPlcParameter("loadRequest").getValue();
|
//当同时有上片请求和有正在开始的工程时进入上片判断
|
if (loadRequest2.equals(1) && engineering != null) {
|
//获取当前开始的工程号
|
UpPattenUsage upPattenUsage = upWorkstationService.selectPriority(engineering);
|
//用工程号查询本次上片的尺寸信息获取工位位置
|
//UpWorkstation upwork = upWorkstationService.selectWorkstation(upPattenUsage);
|
|
}
|
//执行后休眠300毫秒
|
//Thread.sleep(300);
|
} catch (Exception e) {
|
e.printStackTrace();
|
}
|
}
|
|
@Scheduled(fixedDelay = 3000)
|
public void loadGlassHome() {
|
JSONObject jsonObject = new JSONObject();
|
//正在进行的任务
|
//工位信息
|
List<UpWorkstation> upWorkstations = upWorkstationService.list();
|
jsonObject.append("list", upWorkstations);
|
ArrayList<WebSocketServer> sendwServer = WebSocketServer.sessionMap.get("uploadGlass");
|
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");
|
}
|
}
|
}
|
}
|
|
|
}
|
