1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
| package com.example.springboot.component;
|
| import cn.hutool.json.JSONObject;
|
| import java.util.ArrayList;
| import java.util.List;
|
| import com.example.springboot.mapper.AlarmMapper;
|
| public class Plcalarm extends Thread {
| private AlarmMapper alarmMapper;
|
| @Override
| public void run() {
| while (this != null) {
| try {
| Thread.sleep(10000);
| } catch (InterruptedException e) {
| e.printStackTrace();
| }
|
| List<Short> paramlist = S7control.getinstance().ReadWord("DB100.DBW", 12);
|
| // JSONObject jsonObject = new JSONObject();
| // // jsonObject.append("params", paramlist);
| // jsonObject.append("params", new short[] { 0, 1, 2, 3, 4, 5, 6, 7, 8, 9, 10,
| // 11, });
| // WebSocketServer sendwServer = WebSocketServer.sessionMap.get("Parameter");
| // if (sendwServer != null) {
| // sendwServer.sendMessage(jsonObject.toString());
| // }
|
| JSONObject jsonObject = new JSONObject();
|
| jsonObject.append("arm",
| new short[] { 1, 0, 1, 0, 1, 0, 1, 0, 1, 0, 1, 0, 1, 0, 1, 0, 1, 0, 1, 0, 1, 0, 1, 0, 1, 0, 1, 0, 1, 0, 0,
| 1, 0, 1, 0, 1, 0, 1, 0, 1, });
| WebSocketServer sendwServer = WebSocketServer.sessionMap.get("alarm");
| if (sendwServer != null) {
| sendwServer.sendMessage(jsonObject.toString());
| }
|
| Short[] shuzu1 = {
| 1, 0, 1, 0, 1, 0, 1, 0, 1, 0, 1, 0, 1, 0, 1, 0, 1, 0, 1, 0, 1, 0, 1, 0, 1, 0, 1, 0, 1, 0, 0,
| 1, 0, 1, 0, 1, 0, 1, 0, 1,
| };
|
| String[] shuzu = {
| "D01 VFD error",
| "D02 VFD error",
| "D03 VFD error",
| "D04 VFD error",
| "D05 VFD error",
| "D06 VFD error",
| "B01 VFD error",
| "B02 VFD error",
| "A01 VFD error",
| "A02 VFD error",
| "A01 servo turn error",
| "A02 servo turn error",
| "A01 servo travel error",
| "A02 servo travel error",
| "B01 servo travel error",
| "B02 servo travel error",
| "D01 DEC error",
| "D01 pos error",
| "D02 DEC error",
| "D02 pos error",
| "D03 DEC error",
| "D03 pos error",
| "D04 DEC error",
| "D04 pos error",
| "D05 DEC error",
| "D05 pos error",
| "D06 DEC error",
| "D06 pos error",
| "A01 DEC error",
| "A01 pos error",
| "A02 DEC error",
| "A02 pos error",
| "B01 IN DEC error",
| "B01 IN pos error",
| "B01 OUT DEC error",
| "B01 OUT pos error",
| "B02 IN DEC error",
| "B02 IN pos error",
| "B02 OUT DEC error",
| "B02 OUT pos error",
| };
| alarmMapper = WebSocketServer.applicationContext.getBean(AlarmMapper.class);
| for (short i = 0; i < shuzu1.length; i++) {
| short result = alarmMapper.selectnullti(shuzu[i]);
| if (shuzu1[i] == 1 && result == 0) {
| alarmMapper.Insertalarm(shuzu[i]);
| } else if (shuzu1[i] == 0 && result > 0) {
| alarmMapper.updatealarm(shuzu[i]);
| }
| }
|
| // 写
| WebSocketServer webSocketServer = WebSocketServer.sessionMap.get("alarm");
| if (webSocketServer != null) {
| List<String> messages = webSocketServer.getMessages();
|
| String addressList = "DB100.DBW0";
| // addressList.add("DB100.DBW0");
| // addressList.add("DB100.DBW2");
| // addressList.add("DB100.DBW4");
| // addressList.add("DB100.DBW6");
| // addressList.add("DB100.DBW8");
| // addressList.add("DB100.DBW10");
| // addressList.add("DB100.DBW12");
| // addressList.add("DB100.DBW14");
| // addressList.add("DB100.DBW16");
| // addressList.add("DB100.DBW18");
| // addressList.add("DB100.DBW20");
| // addressList.add("DB100.DBW22");
|
| if (!messages.isEmpty()) {
| // 将最后一个消息转换为 short 类型的列表
| String lastMessage = messages.get(messages.size() - 1);
| System.out.println("messages：" + messages);
| String[] parts = lastMessage.split(",");
| List<Short> messageValues = new ArrayList<>();
| for (String part : parts) {
| try {
| // 使用正则表达式清除非数字字符
| String cleanedPart = part.replaceAll("[^0-9-]", "");
| short value = Short.parseShort(cleanedPart.trim());
| messageValues.add(value);
| } catch (NumberFormatException e) {
| // 如果无法解析为 short 类型，则忽略该部分
|
| e.printStackTrace();
| }
| }
|
| // 将消息值写入 PLC
| // S7control.getinstance().WriteWord(addressList, messageValues);
| System.out.println("messageValues：" + messageValues);
| System.out.println("addressList：" + addressList);
| // 清空消息列表
| webSocketServer.clearMessages();
| }
| }
| }
| }
| }
|
|
