| | |
| | |
|
| | | import cn.hutool.json.JSONArray;
|
| | | import cn.hutool.json.JSONObject;
|
| | | import lombok.extern.slf4j.Slf4j;
|
| | |
|
| | | import java.util.ArrayList;
|
| | | import java.util.List;
|
| | |
| | | import java.io.UnsupportedEncodingException;
|
| | |
|
| | | import org.apache.commons.io.FileUtils;
|
| | |
|
| | | @Slf4j
|
| | |
|
| | | public class PlcPositioning1 extends Thread {
|
| | |
|
| | |
| | | ArrayList<WebSocketServer> sendwServer = WebSocketServer.sessionMap.get("Positioning1");
|
| | | if (sendwServer != null) {
|
| | | for (WebSocketServer webserver : sendwServer) {
|
| | | webserver.sendMessage(jsonObject.toString());
|
| | |
|
| | | if (webserver != null) {
|
| | |
|
| | | if (webserver != null&&webserver.session.isOpen()) {
|
| | | webserver.sendMessage(jsonObject.toString());
|
| | | List<String> messages = webserver.getMessages();
|
| | | // 存片格 出片格地址
|
| | |
|
| | |
| | | // 清空消息列表
|
| | | webserver.clearMessages();
|
| | | }
|
| | | }else{
|
| | | log.info("Positioning1 is closed");
|
| | | }
|
| | | }
|
| | |
|