CanadaMes.git - Gitblit

New file
			@@ -0,0 +1,213 @@
			package com.example.springboot.component;

			import cn.hutool.json.JSONArray;
			import cn.hutool.json.JSONObject;
			import com.example.springboot.service.StorageCageService;

			import org.springframework.beans.factory.annotation.Autowired;
			import com.example.springboot.entity.device.PlcParameterObject;
			import com.example.springboot.entity.device.PlcBitObject;

			import org.springframework.stereotype.Component;

			import java.util.ArrayList;
			import java.util.Arrays;
			import java.util.List;

			@Component
			public class PLCAutomaticParameterSettingReview extends Thread {

			private StorageCageService storageCageService = new StorageCageService();
			private final PlcParameterObject plcParameterObject;
			private final PlcBitObject plcBitObject;
			MessageHandler customS7Control = new MessageHandler();
			@Autowired
			public PLCAutomaticParameterSettingReview() {
			this.storageCageService = storageCageService;
			this.plcParameterObject = new PlcParameterObject();
			this.plcBitObject = new PlcBitObject();
			String jsonFilePath = "JsonFile/PlcParameter.json";
			InitUtil.initword(jsonFilePath); // 初始化 PlcParameterObject
			String jsonFilePath2 = "JsonFile/PlcSign.json";
			InitUtil.initbit(jsonFilePath2); // 初始化 PlcSign


			}

			// 单例模式线程安全
			public static PLCAutomaticParameterSettingReview getInstance(StorageCageService storageCageService) {
			return new PLCAutomaticParameterSettingReview();
			}

			@Override
			public void run() {
			while (!Thread.currentThread().isInterrupted()) {
			try {
			Thread.sleep(1000);
			} catch (InterruptedException e) {
			Thread.currentThread().interrupt();
			e.printStackTrace();
			}




			List<String> addresses = new ArrayList<>();
			addresses.add("A01turnAngle1");
			addresses.add("A01turnAngle2");
			addresses.add("A01turnAngle3");
			addresses.add("A01turnAngle4");
			addresses.add("A02turnAngle2");
			addresses.add("A02turnAngle3");
			addresses.add("A02turnAngle4");
			addresses.add("Minimumglasslength");


			//Auto.addresses=DB100.0,DB100.2,DB100.4,DB100.6,DB100.26,DB100.28,DB100.30,DB100.32,DB100.34,DB100.36,DB100.38,DB100.40
			List<String> Autoaddresses = new ArrayList<>();
			Autoaddresses.add("conveyorVelocity(Max)");
			Autoaddresses.add("conveyorVelocity(AutoFAST)");
			Autoaddresses.add("conveyorVelocity(AutoSLOW)");
			Autoaddresses.add("conveyorVelocity(Manual)");
			Autoaddresses.add("A01A02conveyorVelocity(Max)");
			Autoaddresses.add("A01A02conveyorVelocity(AutoFAST)");
			Autoaddresses.add("A01A02conveyorVelocity(AutoSLOW)");
			Autoaddresses.add("B01B02conveyorVelocity(Manual)");

			Autoaddresses.add("B01B02conveyorVelocity(Max)");
			Autoaddresses.add("B01B02conveyorVelocity(AutoFAST)");
			Autoaddresses.add("B01B02conveyorVelocity(AutoSLOW)");
			Autoaddresses.add("B01B02conveyorVelocity(Manual)");







			String addressList1 = "DB100.120";
			String addressList2 = "DB100.18";
			String addressList3 = "DB100.22";
			String addressList4 = "DB100.14";







			// List<Short> dache1 = S7control.getinstance().ReadWord("DB100.18", 1);
			// List<Short> xiaoche1 = S7control.getinstance().ReadWord("DB100.22", 1);
			// List<Short> fanzhuan1 = S7control.getinstance().ReadWord("DB100.14", 1);
			// List<String> addresses = Arrays.asList(config.getProperty("Auto.addresses").split(","));
			// List<Short> arraylist2 = S7control.getinstance().readWords(addresses);
			//System.out.println("lastMessage：" + arraylist2);
			//翻转
			//List<Short> fanzhuan2 = S7control.getinstance().ReadWord("DB100.8", 1);
			// List<Short> xiaoche2 = S7control.getinstance().ReadWord("DB100.12", 1);
			JSONObject jsonObject = new JSONObject();
			// new short[]{1,1, 1, 1, 1, 1, 2, 33, 2,3, 4, 5}
			// new short[]{0,0, 0, 0, 0, 0, 0, 0, 0, 0}
			System.out.println(plcParameterObject.getPlcParameterValues(addresses));
			jsonObject.append("params", plcParameterObject.getPlcParameterValues(addresses));
			jsonObject.append("dache1", plcParameterObject.getPlcParameter("A01A02TRAVELPOSVelocityAUTO").getValue());
			jsonObject.append("xiaoche", plcParameterObject.getPlcParameter("B01B02TRAVELPOSVelocityAUTO").getValue());
			jsonObject.append("fanzhuan", plcParameterObject.getPlcParameter("A01A02TURNPOSVelocityAUTO").getValue());
			jsonObject.append("params2", plcParameterObject.getPlcParameterValues(Autoaddresses));
			jsonObject.append("fanzhuan2", plcParameterObject.getPlcParameter("A01A02TURNJOGVelocity").getValue());
			jsonObject.append("xiaoche2", plcParameterObject.getPlcParameter("B01B02TRAVELJOGVelocity").getValue());

			ArrayList<WebSocketServer> sendwServer = WebSocketServer.sessionMap.get("AutomaticParameterSetting");
			if (sendwServer != null) {
			for (WebSocketServer webserver : sendwServer) {
			webserver.sendMessage(jsonObject.toString());

			// WebSocketServer webSocketServer = WebSocketServer.sessionMap.get("AutomaticParameterSetting");
			if (webserver != null) {
			List<String> messages = webserver.getMessages();


			if (!messages.isEmpty()) {
			// 将最后一个消息转换为 short 类型的列表
			String lastMessage = messages.get(messages.size() - 1);
			// System.out.println("lastMessage：" + lastMessage);
			JSONArray messageArray = new JSONArray(lastMessage);

			// 整合第 1 到 2 个数组并去掉 null 元素
			List<Short> mergedList = new ArrayList<>();
			for (int i = 0; i < 2; i++) {
			JSONArray sublist = messageArray.getJSONArray(i);
			for (int j = 0; j < sublist.size(); j++) {
			Object value = sublist.get(j);
			if (value != null && !value.toString().equals("null")) {
			try {
			String cleanedValue = value.toString().replaceAll("[^0-9-]", "");
			short sValue = Short.parseShort(cleanedValue.trim());
			mergedList.add(sValue);
			} catch (NumberFormatException e) {
			// 如果无法解析为 short 类型，则忽略该部分
			System.err.println("Could not parse value: " + value);
			}
			}
			}
			}
			System.out.println(messageArray);
			// 写入第一个地址
			customS7Control.WriteWordsToPLC(messageArray, addressList2,2);
			// 写入第二个地址
			customS7Control.WriteWordsToPLC(messageArray, addressList3,3);
			// 写入第三个地址
			customS7Control.WriteWordsToPLC(messageArray, addressList4,4);
			// 写入第四个地址
			if (!mergedList.isEmpty()) {
			S7control.getinstance().WriteWord(addressList1, mergedList);
			System.out.println("messageValue：" + mergedList + " written to PLC at address " + addressList1);
			}

			//List<String> waddresses1 = Arrays.asList(config.getProperty("Auto.shusong").split(","));
			String addressList22 = "DB100.8";
			String addressList33 = "DB100.12";
			if (!messages.isEmpty()) {
			// 将最后一个消息转换为 short 类型的列表
			// 整合第 1 到 3 个数组并去掉 null 元素
			List<Short> mergedList2 = new ArrayList<>();
			for (int i = 5; i < 8; i++) {
			JSONArray sublist = messageArray.getJSONArray(i);
			for (int j = 0; j < sublist.size(); j++) {
			Object value = sublist.get(j);
			if (value != null && !value.toString().equals("null")) {
			try {
			String cleanedValue = value.toString().replaceAll("[^0-9-]", "");
			short sValue = Short.parseShort(cleanedValue.trim());
			mergedList2.add(sValue);
			} catch (NumberFormatException e) {
			// 如果无法解析为 short 类型，则忽略该部分
			System.err.println("Could not parse value: " + value);
			}
			}
			}
			}

			// 写入第伍个地址
			customS7Control.WriteWordsToPLC(messageArray, addressList22,8);
			// 写入第六个地址
			customS7Control.WriteWordsToPLC(messageArray, addressList33,9);
			// 写入第七个地址
			// plcParameterObject.getPlcParameter("conveyorVelocity(AutoFAST)").getAddress(index)
			if (!mergedList2.isEmpty()) {
			//S7control.getinstance().WriteWord(plcParameterObject.getPlcParameter(Autoaddresses), mergedList2);
			// System.out.println("messageValue：" + mergedList2 + " written to PLC at address " + waddresses1);
			}
			// 清空消息列表
			webserver.clearMessages();
			}
			}
			}

			}
			}


			}
			}
			}