package com.mes.common;
|
import cn.hutool.json.JSONObject;
|
import java.util.ArrayList;
|
import java.util.List;
|
|
|
public class PlcHomeEdg extends Thread {
|
@Override
|
public void run() {
|
while (this != null) {
|
JSONObject jsonObject = new JSONObject();
|
try {
|
Thread.sleep(1000);
|
// 注入mapper
|
// HomeService = WebSocketServer.applicationContext.getBean(HomeService.class);
|
// QueueMapper = WebSocketServer.applicationContext.getBean(QueueMapper.class);
|
|
|
// //读取DB105区文件
|
// PlcParameterObject plcmes=PLCAutoMes.PlcMesObject;
|
//
|
// String PlcRequest=plcmes.getPlcParameter("GaToMES").getValue();//请求
|
// String MesSend=plcmes.getPlcParameter("MESToGaStatus").getValue();//发送
|
// double width=Double.valueOf(plcmes.getPlcParameter("width").getValue());//宽
|
// double height=Double.valueOf(plcmes.getPlcParameter("Height").getValue());//高
|
|
//获取测量的长，宽
|
boolean istest = true;
|
// String PlcRequest = "1";
|
// String MesSend = "0";
|
// double width = 516;
|
// double height = 507;
|
//System.out.println(111);
|
// //查询当前订单任务
|
//List<FlowCard> OrderTask = storageCageService.SelectOrderTask();
|
//jsonObject.append("OrderTask", OrderTask);
|
|
} catch (InterruptedException e) {
|
e.printStackTrace();
|
}
|
|
// jsonObject.append("params", new short[] { 30, 40, });
|
ArrayList<WebSocketServer> sendwServer = WebSocketServer.sessionMap.get("Home");
|
if (sendwServer != null) {
|
for (WebSocketServer webserver : sendwServer) {
|
webserver.sendMessage(jsonObject.toString());
|
if (webserver != null) {
|
|
List<String> messages = webserver.getMessages();
|
|
if (!messages.isEmpty()) {
|
// // 将最后一个消息转换为整数类型的列表
|
webserver.clearMessages();
|
}
|
}
|
|
}
|
}
|
}
|
}
|
}
|
