From 9a0dd8244282d90b08b16d2c239683bbac62fab2 Mon Sep 17 00:00:00 2001 From: ZengTao <2773468879@qq.com> Date: 星期二, 16 一月 2024 15:02:21 +0800 Subject: [PATCH] Merge branch 'master' of http://10.153.19.25:10101/r/CanadaMes --- springboot-vue3/src/main/java/com/example/springboot/component/PlcsignReview.java | 133 ++++++++++++++++++++++++++++++++++++++++++++ 1 files changed, 133 insertions(+), 0 deletions(-) diff --git a/springboot-vue3/src/main/java/com/example/springboot/component/PlcsignReview.java b/springboot-vue3/src/main/java/com/example/springboot/component/PlcsignReview.java new file mode 100644 index 0000000..7e9549e --- /dev/null +++ b/springboot-vue3/src/main/java/com/example/springboot/component/PlcsignReview.java @@ -0,0 +1,133 @@ +package com.example.springboot.component; + +import cn.hutool.json.JSONArray; +import cn.hutool.json.JSONObject; + +import java.io.BufferedReader; +import java.io.FileReader; +import java.io.IOException; +import java.util.ArrayList; +import java.util.List; + +import com.example.springboot.entity.device.PlcBitObject; +import com.example.springboot.entity.device.PlcBitInfo; + +public class PlcsignReview extends Thread { + String name = ""; + Integer count = 0; + private volatile static PlcsignReview instance = null; + + private PlcsignReview() { + init(); + } + + // 鍗曚緥妯″紡 绾跨▼瀹夊叏 + public static PlcsignReview getInstance() { + if (instance == null) { + synchronized (PlcsignReview.class) { + if (instance == null) { + instance = new PlcsignReview(); + } + } + } + return instance; + } + + PlcBitObject plcBitObject = new PlcBitObject();//璇B鍖烘暟鎹疄渚� + + private void init() { + try { + String jsonfilename = PlcsignReview.class.getResource("/JsonFile/PlcSign.json").getFile(); + FileReader fileReader = new FileReader(jsonfilename); + BufferedReader bufferedReader = new BufferedReader(fileReader); + + StringBuilder content = new StringBuilder(); + String line; + + while ((line = bufferedReader.readLine()) != null) { + content.append(line); + } + + bufferedReader.close(); + fileReader.close(); + + JSONObject jsonfileobj = new JSONObject(content.toString()); + JSONArray jsonArray = jsonfileobj.getJSONArray("parameteInfor"); + plcBitObject.setPlcAddressBegin(jsonfileobj.getStr("plcAddressBegin"));//璁剧疆璧峰浣嶅湴鍧� + plcBitObject.setPlcAddressLength(Integer.valueOf(jsonfileobj.getStr("plcAddressLenght")));//璁剧疆鍦板潃闀垮害 + + + for (int i = 0; i < jsonArray.size(); i++) { + JSONObject parameterObj = jsonArray.getJSONObject(i); + + PlcBitInfo plcBitInfo = new PlcBitInfo(jsonfileobj.getStr("plcAddressBegin")); //鍙傛暟瀹炰緥 + String codeid = parameterObj.getStr("codeId"); + plcBitInfo.setCodeId(codeid); + plcBitInfo.setAddressIndex(Integer.valueOf(parameterObj.getStr("addressIndex"))); + + plcBitObject.addPlcBit(plcBitInfo); + } + System.out.println(""); + } catch (IOException e) { + e.printStackTrace(); + } + } + + + @Override + public void run() { + while (this != null) { + try { + Thread.sleep(1000); + } catch (InterruptedException e) { + e.printStackTrace(); + } + List<Boolean> getplcbits = S7control.getinstance().ReadBits(plcBitObject.getPlcAddressBegin(), plcBitObject.getPlcAddressLength()); + plcBitObject.setPlcBitList(getplcbits); +// this.readValue(); +// String PlcAddress = this.name; +// Integer Plccount = this.count; + // System.out.println(PlcAddress); + +// List<Boolean> plclist = S7control.getinstance().ReadBits(PlcAddress, Plccount); + List<Boolean> plclist = S7control.getinstance().ReadBits("DB102.0.0", 64); + +// Boolean[] values = { true, true, true, true, true, false, true, false, +// true, false, true, false, true, false, +// true, false, true, false, true, false, true, false, true, false, true, false, +// true, false, true, false, true, +// false, true, false, true, false, +// true, false, true, false, true, false, true, false, null, +// true, false, +// true, false, true, false, true, false, +// true, false, true, false, true, }; +// List<Boolean> plclist = new ArrayList<>(Arrays.asList(values)); + + if (plclist != null) { + // 灏嗚幏鍙栫殑甯冨皵绫诲瀷杞崲涓烘暣鏁扮被鍨� + List<Integer> Intlist = new ArrayList<>(); + for (Boolean value : plclist) { + if (value != null) { + Intlist.add(value == true ? 0 : 1); + } + + } + JSONObject jsonObject = new JSONObject(); + jsonObject.append("sig", Intlist); + ArrayList<WebSocketServer> sendwServer = WebSocketServer.sessionMap.get("Parameter1"); + if (sendwServer != null) { + for (WebSocketServer webserver : sendwServer) { + + webserver.sendMessage(jsonObject.toString()); + + + if (webserver != null) { + webserver.sendMessage(jsonObject.toString()); + } + } + + } + } + } + } +} -- Gitblit v1.8.0