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 OrderTask = storageCageService.SelectOrderTask(); //jsonObject.append("OrderTask", OrderTask); } catch (InterruptedException e) { e.printStackTrace(); } // jsonObject.append("params", new short[] { 30, 40, }); ArrayList sendwServer = WebSocketServer.sessionMap.get("Home"); if (sendwServer != null) { for (WebSocketServer webserver : sendwServer) { webserver.sendMessage(jsonObject.toString()); if (webserver != null) { List messages = webserver.getMessages(); if (!messages.isEmpty()) { // // 将最后一个消息转换为整数类型的列表 webserver.clearMessages(); } } } } } } }