CanadaMes.git - Gitblit

			@@ -2,7 +2,11 @@

			import cn.hutool.json.JSONArray;
			import cn.hutool.json.JSONObject;
			import com.example.springboot.controller.HomeController;
			import com.example.springboot.mapper.HomeMapper;
			import org.apache.commons.io.FileUtils;
			import org.springframework.beans.factory.annotation.Autowired;
			import com.example.springboot.service.StorageCageService;

			import java.io.*;
			import java.util.ArrayList;
			@@ -11,219 +15,267 @@
			import java.util.List;

			public class PlcParameter2 extends Thread {
			String name = "";
			Integer count = 0;
			@Autowired
			StorageCageService storageCageService;
			// 创建一个自定义的 S7 控制器消息处理器对象
			MessageHandler customS7Control = new MessageHandler();
			// 用于存储应用程序的配置信息
			private Configuration config;

			public static String readFileToString(String filePath) throws IOException {
			File file = new File(filePath);
			return FileUtils.readFileToString(file, "UTF-8");
			}

			public void readValue() {
			String str = "";
			BufferedReader bufferedReader = null;
			FileInputStream fileInputStream;
			try {
			// 从文件中读取字节数据存入 fileInputStream
			fileInputStream = new FileInputStream("CanadaMes-ui/src/configuration/address.json");
			// 读取 fileInputStream 中字节并将其解码为字符
			InputStreamReader inputStreamReader = new InputStreamReader(fileInputStream, "utf-8");
			// 提高读取效率，在 BufferedReader 内包装 InputStreamReader
			bufferedReader = new BufferedReader(inputStreamReader);
			String line = null;
			// 将 bufferedReader 内容一行一行赋值给str
			while ((line = bufferedReader.readLine()) != null) {
			str += line;
			}

			// 将str字符串格式转为json
			JSONObject jsonObject = new JSONObject(str);

			// 获取json中的值
			JSONArray address = jsonObject.getJSONArray("Positioning1");
			for (int i = 0; i < address.size(); i++) {
			JSONObject ress = (JSONObject) address.get(i);

			this.name = ress.getStr("name");
			this.count = ress.getInt("count");

			}

			} catch (FileNotFoundException e) {
			e.printStackTrace();
			} catch (UnsupportedEncodingException e) {
			e.printStackTrace();
			} catch (IOException e) {
			e.printStackTrace();
			public PlcParameter2() throws IOException {
			config = new Configuration("config.properties");
			}
			}

			@Override
			public void run() {
			while (this != null) {
			try {
			Thread.sleep(1000);

			} catch (InterruptedException e) {
			e.printStackTrace();
			}

			// 手动状态地址
			List<String> addressList1 = new ArrayList<>();

			addressList1.add("DB103.44");//D01
			addressList1.add("DB103.58");//D02
			addressList1.add("DB103.72");//D03
			addressList1.add("DB103.86");//D04
			addressList1.add("DB103.100");//D05
			addressList1.add("DB103.114");//D06
			addressList1.add("DB103.128");//A01
			addressList1.add("DB103.142");//A01 2
			addressList1.add("DB103.156");//A02
			addressList1.add("DB103.184");//B01
			addressList1.add("DB103.212");//B02


			List<String> paramlist = S7control.getinstance().readStrings(addressList1);


			//清除ID地址
			List<String> addresses = new ArrayList<>();
			addresses.add("DB103.0");
			addresses.add("DB103.2");
			addresses.add("DB103.12");
			addresses.add("DB103.14");
			addresses.add("DB103.16");
			addresses.add("DB103.18");
			addresses.add("DB103.8");
			addresses.add("DB103.10");
			addresses.add("DB103.4");
			addresses.add("DB103.6");
			List<Short> data = S7control.getinstance().readWords(addresses);


			//id
			List<String> addressList0 = new ArrayList<>();

			addressList0.add("DB101.9.2");
			addressList0.add("DB101.9.3");
			addressList0.add("DB101.9.4");
			addressList0.add("DB101.9.5");
			addressList0.add("DB101.9.6");
			addressList0.add("DB101.9.7");

			addressList0.add("DB101.10.0");
			addressList0.add("DB101.10.1");
			addressList0.add("DB101.10.2");
			addressList0.add("DB101.10.3");


			List<Boolean> data2 = S7control.getinstance().readBits(addressList0);
			List<String> addressList3 = new ArrayList<>();
			addressList3.add("DB103.256");
			addressList3.add("DB103.270");
			List<String> data3 = S7control.getinstance().readStrings(addressList3);

			List<String> addresses4 = new ArrayList<>();
			addresses4.add("DB103.52");
			addresses4.add("DB103.54");
			addresses4.add("DB103.56");
			addresses4.add("DB103.60");

			List<Short> data4 = S7control.getinstance().readWords(addresses4);

			// List<Long> TIME2 = Collections.singletonList(S7control.getinstance().readtime("DB100.194"));
			// System.out.println("addressList：" + TIME2);


			//




			// String[] values6 = { ".x1 ","x2 ","x3",";;x4","x5","x6","x7","x8","x9","x10","x11"};
			// List<String> paramlist = new ArrayList<>(Arrays.asList(values6));
			// Short[] values1 = { 1, 1, 1, 1, 1, 1, 1, 1, 1, 1};
			// List<Short> data = new ArrayList<>(Arrays.asList(values1));
			// Boolean[] value4 = { true, true, true, true, true, true, true, true, true,
			// true};
			// List<Boolean> data2 = new ArrayList<>(Arrays.asList(value4));
			// String[] values3 = { ".x11 ","x21 "};
			// List<String> data3 = new ArrayList<>(Arrays.asList(values3));
			// Short[] values4 = { 2,2,3,4};
			// List<Short> data4 = new ArrayList<>(Arrays.asList(values4));
			//
			//
			JSONObject jsonObject = new JSONObject();
			short[] params = new short[data2.size()];
			for (int i = 0; i < data2.size(); i++) {
			boolean value = data2.get(i);
			params[i] = value ? (short) 1 : (short) 0;
			}

			jsonObject.append("params", params);
			jsonObject.append("params", paramlist);
			jsonObject.append("params", data);
			jsonObject.append("params", data3);
			jsonObject.append("params", data4);


			WebSocketServer sendwServer = WebSocketServer.sessionMap.get("Parameter2");
			if (sendwServer != null) {
			sendwServer.sendMessage(jsonObject.toString());
			}

			WebSocketServer webSocketServer = WebSocketServer.sessionMap.get("Parameter2");
			if (webSocketServer != null) {

			List<String> messages = webSocketServer.getMessages();
			List<String> addressList = new ArrayList<>();

			addressList.add("DB101.9.2");
			addressList.add("DB101.9.3");
			addressList.add("DB101.9.4");
			addressList.add("DB101.9.5");
			addressList.add("DB101.9.6");
			addressList.add("DB101.9.7");
			addressList.add("DB101.10.0");
			addressList.add("DB101.10.1");
			addressList.add("DB101.10.2");
			addressList.add("DB101.10.3");



			if (!messages.isEmpty()) {
			// 将最后一个消息转换为整数类型的列表
			String lastMessage = messages.get(messages.size() - 1);
			System.out.println("messages：" + messages);
			String[] parts = lastMessage.split(",");
			List<Integer> messageValues = new ArrayList<>();
			for (String part : parts) {
			@Override
			public void run() {
			while (this != null) {
			try {
			// 使用正则表达式清除非数字字符
			String cleanedPart = part.replaceAll("[^0-9-]", "");
			Integer value = Integer.parseInt(cleanedPart.trim());
			messageValues.add(value);
			} catch (NumberFormatException e) {
			// 如果无法解析为整数类型，则忽略该部分
			// e.printStackTrace();
			Thread.sleep(1000);
			storageCageService = WebSocketServer.applicationContext.getBean(StorageCageService.class);
			// id
			List<String> addressList1 = Arrays.asList(config.getProperty("Parameter2.id").split(","));
			List<String> paramlist = S7control.getinstance().readStrings(addressList1);
			// System.out.println(paramlist);
			// 手动状态
			List<String> addresses = Arrays.asList(config.getProperty("Parameter2.state").split(","));
			List<Short> data = S7control.getinstance().readWords(addresses);
			// 清除id
			List<String> addressList0 = Arrays.asList(config.getProperty("Parameter2.cleanid").split(","));
			// 扫码枪
			List<Boolean> data2 = S7control.getinstance().readBits(addressList0);
			List<String> addressList3 = Arrays.asList(config.getProperty("Parameter2.scanner").split(","));

			// 急停按钮
			List<String> niuanaddressList3 = Arrays.asList(config.getProperty("Parameter2.stop").split(","));
			List<String> timeout = Arrays.asList(config.getProperty("Parameter2.timeout").split(","));
			String timeout2 = config.getProperty("Parameter2.timeout");

			Long readtimeout = S7control.getinstance().readtime(timeout2);
			List<Boolean> anniuread = S7control.getinstance().readBits(niuanaddressList3);
			List<String> data3 = S7control.getinstance().readStrings(addressList3);
			// A01 A02 B01 B02
			List<String> addresses4 = Arrays.asList(config.getProperty("Parameter2.Currentcell").split(","));
			List<Short> data4 = S7control.getinstance().readWords(addresses4);
			// System.out.println(data);
			// List<Long> TIME2 =
			// Collections.singletonList(S7control.getinstance().readtime("DB100.194"));
			// System.out.println("addressList：" + TIME2);

			//

			//
			// String[] values6 = { ".x1 ","x2
			// ","x3",";;x4","x5","x6","x7","x8","x9","x10","x11"};
			// List<String> paramlist = new ArrayList<>(Arrays.asList(values6));
			// Short[] values1 = { 0, 1, 1, 1, 1, 1, 1, 1, 1, 1};
			// List<Short> data = new ArrayList<>(Arrays.asList(values1));
			// Boolean[] value4 = { false, false, false, false, false, false, false, false,
			// false,
			// false};
			// List<Boolean> data2 = new ArrayList<>(Arrays.asList(value4));
			// String[] values3 = { ".x11 ","x21 "};
			// List<String> data3 = new ArrayList<>(Arrays.asList(values3));
			// Short[] values4 = { 2,2,3,4};
			// List<Short> data4 = new ArrayList<>(Arrays.asList(values4));
			//
			//
			// JSONObject jsonObject = new JSONObject();
			// short[] params = new short[data2.size()];
			// for (int i = 0; i < data2.size(); i++) {
			// boolean value = data2.get(i);
			// params[i] = value ? (short) 1 : (short) 0;
			// }
			////
			// short[] anniuparams = new short[anniuread.size()];
			// for (int i = 0; i < anniuread.size(); i++) {
			// boolean value = anniuread.get(i);
			// anniuparams[i] = value ? (short) 1 : (short) 0;
			// }
			// boolean转为0 1
			short[] params = customS7Control.convertBooleanListToShortArray(data2);
			short[] anniuparams = customS7Control.convertBooleanListToShortArray(anniuread);
			JSONObject jsonObject = new JSONObject();
			jsonObject.append("params", params);
			jsonObject.append("params", paramlist);
			jsonObject.append("params", data);
			jsonObject.append("params", data3);
			jsonObject.append("params", data4);
			jsonObject.append("jiting", anniuparams);
			jsonObject.append("timeout", readtimeout);

			// WebSocketServer sendwServer =
			// WebSocketServer.getWebSocketServer("Parameter2");
			// if (sendwServer != null) {
			// JSONObject jsonObject = new JSONObject();
			// jsonObject.set("message", "Hello, Parameter2!");
			// sendwServer.sendMessage(jsonObject.toString());
			// }
			// HomeController controller = new HomeController();
			ArrayList<WebSocketServer> sendwServer = WebSocketServer.sessionMap.get("Parameter2");
			if (sendwServer != null) {
			for (WebSocketServer webserver : sendwServer) {

			webserver.sendMessage(jsonObject.toString());

			if (webserver != null) {

			List<String> messages = webserver.getMessages();

			if (!messages.isEmpty()) {
			// 将最后一个消息转换为整数类型的列表
			String lastMessage = messages.get(messages.size() - 1);
			// System.out.println("lastMessage：" + lastMessage);
			JSONArray messageArray = new JSONArray(lastMessage);
			// 清除ID
			// customS7Control.writeBitToPLC(messageArray, addressList0, 0);

			try {
			// 检查索引是否有效
			if (messageArray.getJSONArray(0).size() > 0) {
			// 获取消息数组
			JSONArray jsonArray = messageArray.getJSONArray(0);
			// 创建一个布尔值列表
			List<Boolean> sValue = new ArrayList<>();
			// 遍历消息数组
			for (int i = 0; i < jsonArray.size(); i++) {
			// 获取消息数组中的值
			Object value = jsonArray.get(i);
			// 检查值是否有效
			if (value != null && !value.toString().equals("null")) {
			try {
			// 移除非数字和数字字符
			String cleanedValue = value.toString().replaceAll("[^0-9-]", "");
			// 解析为布尔值
			boolean val = "1".equals(cleanedValue.trim());
			// 将布尔值添加到布尔值列表中
			sValue.add(val);
			System.out.println(
			"messageValue: " + Arrays.asList(val)
			+ " added to the list");

			} catch (NumberFormatException e) {
			// 如果无法解析为 boolean 类型，则忽略该部分
			System.err.println("Could not parse value: " + value);
			}
			}
			}
			// 完成出片
			boolean containsOne = data.stream().anyMatch(number -> number == 1);
			for (int i = 1; i <= 5; i++) {
			boolean value = sValue.get(i);
			String id = paramlist.get(i);
			// 判断是否自动状态
			if (!containsOne) {
			// 判断id是否包含数字
			if (id.matches(".\\d.")) {
			// 判断清除id是否true
			if (value) {
			System.out.println(id);
			switch (i) {
			case 1:
			storageCageService.UpdateTask(2, 0, paramlist.get(i));
			break;
			case 2:
			case 3:
			case 4:
			case 5:
			storageCageService.UpdateTask(3, 0, paramlist.get(i));
			break;
			default:
			// 处理索引值不在范围内的情况
			break;
			}
			}
			}

			// 检查布尔值列表是否为空
			if (!sValue.isEmpty()) {

			// 调用 S7control.getinstance().WriteBit 方法将布尔值列表写入地址列表
			S7control.getinstance().WriteBit(addressList0, sValue);
			System.out
			.println("Values " + sValue + " written to PLC at address "
			+ addressList0);
			}
			}
			}
			}
			} catch (Exception e) {
			System.err.println("An error occurred while writing bit to PLC: " + e.getMessage());
			}

			// 急停
			// customS7Control.writeBitToPLC(messageArray, niuanaddressList3, 1);

			try {
			// 检查索引是否有效
			if (messageArray.getJSONArray(1).size() > 0) {
			// 获取消息数组
			JSONArray jsonArray = messageArray.getJSONArray(1);
			// 创建一个布尔值列表
			List<Boolean> sValue = new ArrayList<>();
			// 遍历消息数组
			for (int i = 0; i < jsonArray.size(); i++) {
			// 获取消息数组中的值
			Object value = jsonArray.get(i);
			// 检查值是否有效
			if (value != null && !value.toString().equals("null")) {
			try {
			// 移除非数字和数字字符
			String cleanedValue = value.toString().replaceAll("[^0-9-]", "");
			// 解析为布尔值
			boolean val = "1".equals(cleanedValue.trim());
			// 将布尔值添加到布尔值列表中
			sValue.add(val);
			System.out.println(
			"messageValue: " + Arrays.asList(val)
			+ " added to the list");

			} catch (NumberFormatException e) {
			// 如果无法解析为 boolean 类型，则忽略该部分
			System.err.println("Could not parse value: " + value);
			}
			}
			}
			// 终止进片任务
			boolean Value1 = sValue.get(0);
			boolean Value2 = sValue.get(1);

			if (Value1) {
			storageCageService.EndTask(0);

			}
			if (Value2) {
			storageCageService.EndTask(1);

			}
			// 检查布尔值列表是否为空
			if (!sValue.isEmpty()) {

			// 调用 S7control.getinstance().WriteBit 方法将布尔值列表写入地址列表
			S7control.getinstance().WriteBit(niuanaddressList3, sValue);
			System.out.println(
			"Values " + sValue + " written to PLC at address "
			+ niuanaddressList3);
			}
			}
			} catch (Exception e) {
			System.err.println("An error occurred while writing bit to PLC: " + e.getMessage());
			}

			// 存片等待延迟
			customS7Control.Writetime(messageArray, timeout2, 2);

			// 清空消息列表
			webserver.clearMessages();
			}
			}
			}
			}
			} catch (InterruptedException e) {
			e.printStackTrace();
			}
			}

			// 将消息值转换为布尔列表
			List<Boolean> messageBooleans = new ArrayList<>();
			for (Integer value : messageValues) {
			messageBooleans.add(value == 1 ? true : false);
			}

			// 将布尔列表写入 PLC
			// S7control.getinstance().WriteBit(addressList, messageBooleans);
			System.out.println("messageValues：" + messageBooleans);
			System.out.println("addressList：" + addressList);
			// 清空消息列表
			webSocketServer.clearMessages();
			}
			}
			}
			}
			}