CanadaMes.git - Gitblit

			@@ -3,7 +3,10 @@
			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;
			@@ -13,12 +16,12 @@


			public class PlcParameter2 extends Thread {

			// 用于存储应用程序的配置信息
			private Configuration config;

			@Autowired
			StorageCageService storageCageService;
			// 创建一个自定义的 S7 控制器消息处理器对象
			MessageHandler customS7Control = new MessageHandler();
			// 用于存储应用程序的配置信息
			private Configuration config;


			public PlcParameter2() throws IOException {
			@@ -34,23 +37,16 @@
			} catch (InterruptedException e) {
			e.printStackTrace();
			}

			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(","));
			@@ -60,19 +56,13 @@
			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);

			@@ -94,19 +84,22 @@
			// 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();
			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;
			}

			jsonObject.append("params", params);
			jsonObject.append("params", paramlist);
			jsonObject.append("params", data);
			@@ -122,7 +115,7 @@
			// 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) {
			@@ -132,16 +125,15 @@

			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);
			// customS7Control.writeBitToPLC(messageArray, addressList0, 0);


			try {
			@@ -167,51 +159,55 @@
			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);
			if (value) {
			switch (i) {
			case 1:
			HomeController.UpdateTask(0, 0, paramlist.get(i));
			break;
			case 2:
			case 3:
			case 4:
			case 5:
			HomeController.UpdateTask(1, 0, paramlist.get(i));
			break;
			default:
			// 处理索引值不在范围内的情况
			break;
			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);
			}
			}

			// 检查布尔值列表是否为空
			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());
			}





			//急停
			@@ -246,31 +242,29 @@
			}
			}
			}

			// 终止进片任务
			boolean Value1 = sValue.get(0);
			boolean Value2 = sValue.get(1);

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

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

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

			// 调用 S7control.getinstance().WriteBit 方法将布尔值列表写入地址列表
			S7control.getinstance().WriteBit(addressList0, sValue);
			System.out.println("Values " + sValue + " written to PLC at address " + addressList0);
			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());
			}




			//存片等待延迟