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 java.io.BufferedReader;
|
import java.io.FileReader;
|
import java.io.IOException;
|
import java.util.ArrayList;
|
import java.util.Arrays;
|
import java.util.List;
|
import com.example.springboot.entity.device.PlcParameterObject;
|
import com.example.springboot.entity.device.PlcParameterInfo;
|
import org.springframework.core.io.ResourceLoader;
|
|
|
public class PlcParameter2Review extends Thread {
|
|
@Autowired
|
|
StorageCageService storageCageService;
|
private ResourceLoader resourceLoader;
|
private volatile static PlcParameter2Review instance = null;
|
|
private PlcParameter2Review() {
|
init();
|
}
|
|
// 单例模式 线程安全
|
public static PlcParameter2Review getInstance() {
|
if (instance == null) {
|
synchronized (PlcParameter1Review.class) {
|
if (instance == null) {
|
instance = new PlcParameter2Review();
|
}
|
}
|
}
|
return instance;
|
}
|
|
PlcParameterObject plcParameterObject = new PlcParameterObject();//该DB区数据实例
|
|
private void init() {
|
try {
|
String jsonfilename = PlcParameter1Review.class.getResource("/JsonFile/PlcParameter.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");
|
plcParameterObject.setPlcAddressBegin(jsonfileobj.getStr("plcAddressBegin"));//设置起始位地址
|
plcParameterObject.setPlcAddressLength(Integer.valueOf(jsonfileobj.getStr("plcAddressLenght")));//设置地址长度
|
|
|
for (int i = 0; i < jsonArray.size(); i++) {
|
JSONObject parameterObj = jsonArray.getJSONObject(i);
|
|
PlcParameterInfo plcParameterInfo = new PlcParameterInfo(jsonfileobj.getStr("plcAddressBegin")); //参数实例
|
String codeid = parameterObj.getStr("codeId");
|
plcParameterInfo.setCodeId(codeid);
|
plcParameterInfo.setAddressIndex(Integer.valueOf(parameterObj.getStr("addressIndex")));
|
plcParameterInfo.setRatio(Integer.valueOf(parameterObj.getStr("ratio")));
|
plcParameterInfo.setAddressLength(Integer.valueOf(parameterObj.getStr("addressLenght")));
|
plcParameterInfo.setUnit(parameterObj.getStr("unit"));
|
plcParameterObject.addPlcParameter(plcParameterInfo);
|
}
|
System.out.println("");
|
} catch (IOException e) {
|
e.printStackTrace();
|
}
|
|
}
|
@Override
|
public void run() {
|
while (this != null) {
|
try {
|
Thread.sleep(1000);
|
|
} catch (InterruptedException e) {
|
e.printStackTrace();
|
}
|
storageCageService = WebSocketServer.applicationContext.getBean(StorageCageService.class);
|
|
byte[] getplcvlues = S7control.getinstance().ReadByte(plcParameterObject.getPlcAddressBegin(), plcParameterObject.getPlcAddressLength());
|
plcParameterObject.setPlcParameterList(getplcvlues);
|
int index = plcParameterObject.getPlcParameter("conveyorVelocity(AutoFAST)").getAddressIndex();
|
S7control.getinstance().WriteWord(plcParameterObject.getPlcParameter("conveyorVelocity(AutoFAST)").getAddress(index), (short) 100);
|
|
List<String> addresses = new ArrayList<>();
|
addresses.add("conveyorVelocity(AutoFAST)");
|
addresses.add("conveyorVelocity(AutoSLOW)");
|
addresses.add("conveyorVelocity(Manual)");
|
addresses.add("A01A02TURNJOGVelocity");
|
addresses.add("A01A02TRAVELJOGVelocity");
|
// 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);
|
|
|
|
//
|
|
|
//
|
// 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();
|
// }
|
// }
|
// }
|
// }
|
}
|
}
|
}
|
