Other/hb_roma
2
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

first

Browse Source
This commit is contained in:
cdf
2024-07-05 11:40:30 +08:00
parent 26951dcbab
commit 1879f41b9f
6 changed files with 17176 additions and 143 deletions
Download Patch File Download Diff File Expand all files Collapse all files

21
src/main/java/com/njcn/roma/client/ClientHandler.java
View File

@@ -27,12 +27,17 @@ import java.util.Map;
@RestController
@RequiredArgsConstructor
public class ClientHandler extends Thread {
public String topicMsg = "{\"HRPhV_H14_phsC\":\"0\",\"HRPhV_H14_phsB\":\"0.000\",\"HRPhV_H14_phsA\":\"0.000\",\"HRPhV_H2_phsB\":\"0.000\",\"HRPhV_H2_phsA\":\"0.000\",\"HRPhV_H2_phsC\":\"0.000\",\"HRPhV_H15_phsA\":\"0.000\",\"TotW\":\"0.000\",\"HRPhV_H15_phsB\":\"0.000\",\"HRPhV_H15_phsC\":\"0\",\"FreqDev\":\"0.000\",\"PPV_phsAB\":\"0.000\",\"A_phsC\":\"0.006\",\"TotPF\":\"1.000\",\"A_phsA\":\"0.005\",\"A_phsB\":\"0.005\",\"PPV_phsBC\":\"0.000\",\"HRPhV_H25_phsB\":\"0.000\",\"HRPhV_H25_phsC\":\"0\",\"HRPhV_H25_phsA\":\"0.000\",\"DataTag\":\"1.000\",\"HRPhV_H20_phsA\":\"0.000\",\"HRPhV_H20_phsB\":\"0.000\",\"HRPhV_H20_phsC\":\"0\",\"PPV_phsCA\":\"0.000\",\"HRPhV_H3_phsB\":\"0.000\",\"HRPhV_H3_phsC\":\"0.000\",\"HRPhV_H9_phsC\":\"0\",\"ThdPhV_phsA\":\"0.000\",\"HRPhV_H9_phsB\":\"0.000\",\"HRPhV_H9_phsA\":\"0.000\",\"ThdPhV_phsB\":\"0.000\",\"ThdPhV_phsC\":\"0.000\",\"HRPhV_H19_phsC\":\"0\",\"HRPhV_H19_phsB\":\"0.000\",\"HRPhV_H19_phsA\":\"0.000\",\"HRPhV_H16_phsA\":\"0.000\",\"HRPhV_H13_phsA\":\"0.000\",\"HRPhV_H16_phsC\":\"0\",\"HRPhV_H13_phsB\":\"0.000\",\"HRPhV_H16_phsB\":\"0.000\",\"TotVA\":\"0.000\",\"HRPhV_H13_phsC\":\"0\",\"HRPhV_H6_phsB\":\"0.000\",\"HRPhV_H3_phsA\":\"0.000\",\"HRPhV_H6_phsA\":\"0.000\",\"HRPhV_H10_phsA\":\"0.000\",\"HRPhV_H10_phsB\":\"0.000\",\"HRPhV_H6_phsC\":\"0.000\",\"HRPhV_H10_phsC\":\"0\",\"ImbNgV\":\"0.000\",\"TotVar\":\"0.000\",\"HRPhV_H7_phsC\":\"0.000\",\"HRPhV_H7_phsB\":\"0.000\",\"HRPhV_H22_phsC\":\"0\",\"HRPhV_H22_phsB\":\"0.000\",\"ImbZroV\":\"0.000\",\"HRPhV_H22_phsA\":\"0.000\",\"HRPhV_H7_phsA\":\"0.000\",\"HRPhV_H8_phsA\":\"0.000\",\"HRPhV_H23_phsB\":\"0.000\",\"PhV_phsA\":\"0.002\",\"HRPhV_H8_phsB\":\"0.000\",\"HRPhV_H23_phsC\":\"0\",\"HRPhV_H8_phsC\":\"0\",\"PhV_phsB\":\"0.360\",\"PhV_phsC\":\"0.001\",\"HRPhV_H23_phsA\":\"0.000\",\"PstPhV_phsC\":\"0.000\",\"PstPhV_phsA\":\"0.000\",\"PstPhV_phsB\":\"0.000\",\"Freq\":\"50.000\",\"HRPhV_H11_phsA\":\"0.000\",\"HRPhV_H11_phsB\":\"0.000\",\"HRPhV_H17_phsC\":\"0\",\"HRPhV_H11_phsC\":\"0\",\"HRPhV_H17_phsB\":\"0.000\",\"HRPhV_H17_phsA\":\"0.000\",\"SeqV_C2\":\"0.001\",\"HRPhV_H4_phsB\":\"0.000\",\"SeqV_C1\":\"0.001\",\"HRPhV_H4_phsA\":\"0.000\",\"SeqV_C0\":\"0.006\",\"PhVDev_phsC\":\"0.000\",\"HRPhV_H5_phsA\":\"0.000\",\"HRPhV_H5_phsB\":\"0.000\",\"HRPhV_H5_phsC\":\"0.000\",\"PhVDev_phsB\":\"0.000\",\"HRPhV_H12_phsC\":\"0\",\"PltPhV_phsA\":\"0.000\",\"PhVDev_phsA\":\"0.000\",\"HRPhV_H12_phsB\":\"0.000\",\"HRPhV_H4_phsC\":\"0.000\",\"HRPhV_H18_phsB\":\"0.000\",\"HRPhV_H18_phsC\":\"0\",\"HRPhV_H12_phsA\":\"0.000\",\"HRPhV_H18_phsA\":\"0.000\",\"HFundPhV_phsC\":\"0.008\",\"HRPhV_H21_phsC\":\"0\",\"HRPhV_H21_phsB\":\"0.000\",\"HRPhV_H24_phsC\":\"0\",\"HFundPhV_phsA\":\"0.007\",\"HRPhV_H21_phsA\":\"0.000\",\"HFundPhV_phsB\":\"0.007\",\"HRPhV_H24_phsB\":\"0.000\",\"PltPhV_phsC\":\"0.000\",\"HRPhV_H24_phsA\":\"0.000\",\"PltPhV_phsB\":\"0.000\",\"time\":\"20240702T160000Z\"}";;
public String topicMsg = "{\"HRPhV_H14_phsC\":\"0.0000\",\"HRPhV_H14_phsB\":\"0.0000\",\"HRPhV_H14_phsA\":\"0.0000\",\"HRPhV_H2_phsB\":\"0.0100\",\"HRPhV_H2_phsA\":\"0.0100\",\"HRPhV_H2_phsC\":\"0.0100\",\"HRPhV_H15_phsA\":\"0.0120\",\"TotW\":\"19771.1367\",\"HRPhV_H15_phsB\":\"0.0120\",\"HRPhV_H15_phsC\":\"0.0120\",\"FreqDev\":\"0.0000\",\"PPV_phsAB\":\"384.0318\",\"A_phsC\":\"60.7116\",\"TotPF\":\"0.4946\",\"A_phsA\":\"60.7123\",\"A_phsB\":\"60.7111\",\"PPV_phsBC\":\"383.3656\",\"HRPhV_H25_phsB\":\"0.0080\",\"HRPhV_H25_phsC\":\"0.0080\",\"HRPhV_H25_phsA\":\"0.0080\",\"DataTag\":\"0\",\"HRPhV_H20_phsA\":\"0.0000\",\"HRPhV_H20_phsB\":\"0.0000\",\"HRPhV_H20_phsC\":\"0.0000\",\"PPV_phsCA\":\"383.3637\",\"HRPhV_H3_phsB\":\"0.0640\",\"HRPhV_H3_phsC\":\"0.0640\",\"HRPhV_H9_phsC\":\"0.0220\",\"ThdPhV_phsA\":\"0.0913\",\"HRPhV_H9_phsB\":\"0.0220\",\"HRPhV_H9_phsA\":\"0.0220\",\"ThdPhV_phsB\":\"0.0913\",\"ThdPhV_phsC\":\"0.0913\",\"HRPhV_H19_phsC\":\"0.0100\",\"HRPhV_H19_phsB\":\"0.0100\",\"HRPhV_H19_phsA\":\"0.0100\",\"HRPhV_H16_phsA\":\"0.0000\",\"HRPhV_H13_phsA\":\"0.0140\",\"HRPhV_H16_phsC\":\"0.0000\",\"HRPhV_H13_phsB\":\"0.0140\",\"HRPhV_H16_phsB\":\"0.0000\",\"TotVA\":\"39977.2305\",\"HRPhV_H13_phsC\":\"0.0140\",\"HRPhV_H6_phsB\":\"0.0026\",\"HRPhV_H3_phsA\":\"0.0640\",\"HRPhV_H6_phsA\":\"0.0026\",\"HRPhV_H10_phsA\":\"0.0026\",\"HRPhV_H10_phsB\":\"0.0026\",\"HRPhV_H6_phsC\":\"0.0026\",\"HRPhV_H10_phsC\":\"0.0026\",\"ImbNgV\":\"0.0012\",\"TotVar\":\"34745.9492\",\"HRPhV_H7_phsC\":\"0.0280\",\"HRPhV_H7_phsB\":\"0.0280\",\"HRPhV_H22_phsC\":\"0.0000\",\"HRPhV_H22_phsB\":\"0.0000\",\"ImbZroV\":\"0.0012\",\"HRPhV_H22_phsA\":\"0.0000\",\"HRPhV_H7_phsA\":\"0.0280\",\"HRPhV_H8_phsA\":\"0.0026\",\"HRPhV_H23_phsB\":\"0.0080\",\"PhV_phsA\":\"221.9935\",\"HRPhV_H8_phsB\":\"0.0026\",\"HRPhV_H23_phsC\":\"0.0080\",\"HRPhV_H8_phsC\":\"0.0026\",\"PhV_phsB\":\"221.9947\",\"PhV_phsC\":\"221.9979\",\"HRPhV_H23_phsA\":\"0.0080\",\"PstPhV_phsC\":\"3.2942\",\"PstPhV_phsA\":\"3.3086\",\"PstPhV_phsB\":\"3.2987\",\"Freq\":\"50.0000\",\"HRPhV_H11_phsA\":\"0.0180\",\"HRPhV_H11_phsB\":\"0.0180\",\"HRPhV_H17_phsC\":\"0.0100\",\"HRPhV_H11_phsC\":\"0.0180\",\"HRPhV_H17_phsB\":\"0.0100\",\"HRPhV_H17_phsA\":\"0.0100\",\"SeqV_C2\":\"0.0715\",\"HRPhV_H4_phsB\":\"0.0050\",\"SeqV_C1\":\"60.4601\",\"HRPhV_H4_phsA\":\"0.0050\",\"SeqV_C0\":\"0.0714\",\"PhVDev_phsC\":\"0.0119\",\"HRPhV_H5_phsA\":\"0.0400\",\"HRPhV_H5_phsB\":\"0.0400\",\"HRPhV_H5_phsC\":\"0.0400\",\"PhVDev_phsB\":\"0.0119\",\"HRPhV_H12_phsC\":\"0.0010\",\"PltPhV_phsA\":\"0.0000\",\"PhVDev_phsA\":\"0.0119\",\"HRPhV_H12_phsB\":\"0.0010\",\"HRPhV_H4_phsC\":\"0.0050\",\"HRPhV_H18_phsB\":\"0.0000\",\"HRPhV_H18_phsC\":\"0.0000\",\"HRPhV_H12_phsA\":\"0.0010\",\"HRPhV_H18_phsA\":\"0.0000\",\"HFundPhV_phsC\":\"220.8052\",\"HRPhV_H21_phsC\":\"0.0080\",\"HRPhV_H21_phsB\":\"0.0080\",\"HRPhV_H24_phsC\":\"0.0000\",\"HFundPhV_phsA\":\"220.8056\",\"HRPhV_H21_phsA\":\"0.0080\",\"HFundPhV_phsB\":\"220.8055\",\"HRPhV_H24_phsB\":\"0.0000\",\"PltPhV_phsC\":\"0.0000\",\"HRPhV_H24_phsA\":\"0.0000\",\"PltPhV_phsB\":\"0.0000\",\"time\":\"20240704T152745Z\"}";
public String devId;
private Consumer consumer;
@GetMapping("message")
private Map<String,String> message() {
MessageBodyDTO messageBodyDTO = new MessageBodyDTO();
Map<String,String> map = JSONObject.parseObject(topicMsg, Map.class);
return map;
}
@@ -54,11 +59,13 @@ public class ClientHandler extends Thread {
public ConsumeStatus consume(Message message) {
// 消费消息的业务逻辑
try {
String msg = new String(message.getBody(), "UTF-8");
topicMsg = msg;
System.out.println("Receive: " + msg);
} catch (UnsupportedEncodingException e) {
System.out.println("收到新的一轮数据：******************");
topicMsg = new String(message.getBody(), "UTF-8");
System.out.println("装置信息：========="+message.getProperties());
devId = message.getProperties().get("deviceId")+"#"+message.getProperties().get("deviceIdentifier");
System.out.println("Receive>>>>>>>>>>>>: " + topicMsg);
} catch (Exception e) {
System.out.println("帮忙拍个照这个是接收消息的报错------------------------------------------------------------");
e.printStackTrace();
}
// 正常接收到消息后，请务必返回 CONSUME_SUCCESS，只有在业务处理失败才返回RECONSUME_LATER

2
src/main/java/com/njcn/roma/controller/TestController.java
View File

@@ -91,7 +91,7 @@ public class TestController {
@GetMapping("show")
public String show() {
return clientHandler.topicMsg;
return clientHandler.topicMsg +" >>>>>>> "+ clientHandler.devId;
}
}

1
src/main/java/com/njcn/roma/listener/ClientListener.java
View File

@@ -26,5 +26,6 @@ public class ClientListener {
log.info("启动时自动执行 @EventListener 注解方法");
clientHandler.start();
}
}