提交
This commit is contained in:
hzj
@@ -1,17 +1,20 @@
|
||||
package com.njcn.roma.client;
|
||||
|
||||
import com.alibaba.fastjson.JSON;
|
||||
import com.alibaba.fastjson.JSONObject;
|
||||
import com.fasterxml.jackson.annotation.JsonFormat;
|
||||
import com.huawei.it.eip.ump.client.consumer.ConsumeStatus;
|
||||
import com.huawei.it.eip.ump.client.consumer.Consumer;
|
||||
import com.huawei.it.eip.ump.client.listener.MessageListener;
|
||||
import com.huawei.it.eip.ump.common.exception.UmpException;
|
||||
import com.huawei.it.eip.ump.common.message.Message;
|
||||
import com.njcn.roma.pojo.MessageBodyDTO;
|
||||
import lombok.RequiredArgsConstructor;
|
||||
import org.springframework.stereotype.Component;
|
||||
import org.springframework.web.bind.annotation.*;
|
||||
|
||||
import java.io.FileWriter;
|
||||
import java.io.IOException;
|
||||
import java.io.UnsupportedEncodingException;
|
||||
import java.io.*;
|
||||
import java.nio.charset.StandardCharsets;
|
||||
|
||||
/**
|
||||
* roma
|
||||
@@ -19,13 +22,20 @@ import java.io.UnsupportedEncodingException;
|
||||
* @author cdf
|
||||
* @date 2024/6/20
|
||||
*/
|
||||
@Component
|
||||
|
||||
@RestController
|
||||
@RequiredArgsConstructor
|
||||
public class ClientHandler extends Thread {
|
||||
|
||||
private Consumer consumer;
|
||||
@GetMapping("message")
|
||||
private MessageBodyDTO message(){
|
||||
String jsonString ="{\"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\"}";
|
||||
MessageBodyDTO messageBodyDTO = new MessageBodyDTO();
|
||||
|
||||
public String topicMsg = "暂无数据";
|
||||
|
||||
messageBodyDTO =JSONObject.parseObject(jsonString,MessageBodyDTO.class);
|
||||
|
||||
@Override
|
||||
public void run() {
|
||||
@@ -69,4 +79,7 @@ public class ClientHandler extends Thread {
|
||||
}
|
||||
|
||||
|
||||
return messageBodyDTO;
|
||||
}
|
||||
|
||||
}
|
||||
|
||||
198
src/main/java/com/njcn/roma/pojo/MessageBodyDTO.java
Normal file
198
src/main/java/com/njcn/roma/pojo/MessageBodyDTO.java
Normal file
@@ -0,0 +1,198 @@
|
||||
package com.njcn.roma.pojo;
|
||||
|
||||
import com.fasterxml.jackson.annotation.JsonProperty;
|
||||
import lombok.Data;
|
||||
|
||||
/**
|
||||
* Description:
|
||||
* Date: 2024/7/2 8:51【需求编号】
|
||||
*
|
||||
* @author clam
|
||||
* @version V1.0.0
|
||||
*/
|
||||
@Data
|
||||
public class MessageBodyDTO {
|
||||
|
||||
@JsonProperty("HRPhV_H14_phsC")
|
||||
private String HRPhV_H14_phsC;
|
||||
@JsonProperty("HRPhV_H14_phsB")
|
||||
private String HRPhV_H14_phsB;
|
||||
@JsonProperty("HRPhV_H14_phsA")
|
||||
private String HRPhV_H14_phsA;
|
||||
@JsonProperty("HRPhV_H2_phsB")
|
||||
private String HRPhV_H2_phsB;
|
||||
@JsonProperty("HRPhV_H2_phsA")
|
||||
private String HRPhV_H2_phsA;
|
||||
@JsonProperty("HRPhV_H2_phsC")
|
||||
private String HRPhV_H2_phsC;
|
||||
@JsonProperty("HRPhV_H15_phsA")
|
||||
private String HRPhV_H15_phsA;
|
||||
@JsonProperty("TotW")
|
||||
private String TotW;
|
||||
@JsonProperty("HRPhV_H15_phsB")
|
||||
private String HRPhV_H15_phsB;
|
||||
@JsonProperty("HRPhV_H15_phsC")
|
||||
private String HRPhV_H15_phsC;
|
||||
@JsonProperty("FreqDev")
|
||||
private String FreqDev;
|
||||
@JsonProperty("PPV_phsAB")
|
||||
private String PPV_phsAB;
|
||||
@JsonProperty("A_phsC")
|
||||
private String A_phsC;
|
||||
@JsonProperty("TotPF")
|
||||
private String TotPF;
|
||||
@JsonProperty("A_phsA")
|
||||
private String A_phsA;
|
||||
@JsonProperty("A_phsB")
|
||||
private String A_phsB;
|
||||
@JsonProperty("PPV_phsBC")
|
||||
private String PPV_phsBC;
|
||||
@JsonProperty("HRPhV_H25_phsB")
|
||||
private String HRPhV_H25_phsB;
|
||||
@JsonProperty("HRPhV_H25_phsC")
|
||||
private String HRPhV_H25_phsC;
|
||||
@JsonProperty("HRPhV_H25_phsA")
|
||||
private String HRPhV_H25_phsA;
|
||||
@JsonProperty("DataTag")
|
||||
private String DataTag;
|
||||
@JsonProperty("HRPhV_H20_phsA")
|
||||
private String HRPhV_H20_phsA;
|
||||
@JsonProperty("HRPhV_H20_phsB")
|
||||
private String HRPhV_H20_phsB;
|
||||
@JsonProperty("HRPhV_H20_phsC")
|
||||
private String HRPhV_H20_phsC;
|
||||
@JsonProperty("PPV_phsCA")
|
||||
private String PPV_phsCA;
|
||||
@JsonProperty("HRPhV_H3_phsB")
|
||||
private String HRPhV_H3_phsB;
|
||||
@JsonProperty("HRPhV_H3_phsC")
|
||||
private String HRPhV_H3_phsC;
|
||||
@JsonProperty("HRPhV_H9_phsC")
|
||||
private String HRPhV_H9_phsC;
|
||||
@JsonProperty("ThdPhV_phsA")
|
||||
private String ThdPhV_phsA;
|
||||
@JsonProperty("HRPhV_H9_phsB")
|
||||
private String HRPhV_H9_phsB;
|
||||
@JsonProperty("HRPhV_H9_phsA")
|
||||
private String HRPhV_H9_phsA;
|
||||
@JsonProperty("ThdPhV_phsB")
|
||||
private String ThdPhV_phsB;
|
||||
@JsonProperty("ThdPhV_phsC")
|
||||
private String ThdPhV_phsC;
|
||||
@JsonProperty("HRPhV_H19_phsC")
|
||||
private String HRPhV_H19_phsC;
|
||||
@JsonProperty("HRPhV_H19_phsB")
|
||||
private String HRPhV_H19_phsB;
|
||||
@JsonProperty("HRPhV_H19_phsA")
|
||||
private String HRPhV_H19_phsA;
|
||||
@JsonProperty("HRPhV_H16_phsA")
|
||||
private String HRPhV_H16_phsA;
|
||||
@JsonProperty("HRPhV_H13_phsA")
|
||||
private String HRPhV_H13_phsA;
|
||||
@JsonProperty("HRPhV_H16_phsC")
|
||||
private String HRPhV_H16_phsC;
|
||||
@JsonProperty("HRPhV_H13_phsB")
|
||||
private String HRPhV_H13_phsB;
|
||||
@JsonProperty("HRPhV_H16_phsB")
|
||||
private String HRPhV_H16_phsB;
|
||||
@JsonProperty("TotVA")
|
||||
private String TotVA;
|
||||
@JsonProperty("HRPhV_H13_phsC")
|
||||
private String HRPhV_H13_phsC;
|
||||
@JsonProperty("HRPhV_H6_phsB")
|
||||
private String HRPhV_H6_phsB;
|
||||
@JsonProperty("HRPhV_H3_phsA")
|
||||
private String HRPhV_H3_phsA;
|
||||
@JsonProperty("HRPhV_H6_phsA")
|
||||
private String HRPhV_H6_phsA;
|
||||
@JsonProperty("HRPhV_H10_phsA")
|
||||
private String HRPhV_H10_phsA;
|
||||
@JsonProperty("HRPhV_H10_phsB")
|
||||
private String HRPhV_H10_phsB;
|
||||
@JsonProperty("HRPhV_H6_phsC")
|
||||
private String HRPhV_H6_phsC;
|
||||
@JsonProperty("HRPhV_H10_phsC")
|
||||
private String HRPhV_H10_phsC;
|
||||
@JsonProperty("ImbNgV")
|
||||
private String ImbNgV;
|
||||
@JsonProperty("TotVar")
|
||||
private String TotVar;
|
||||
@JsonProperty("HRPhV_H7_phsC")
|
||||
private String HRPhV_H7_phsC;
|
||||
@JsonProperty("HRPhV_H7_phsB")
|
||||
private String HRPhV_H7_phsB;
|
||||
@JsonProperty("HRPhV_H22_phsC")
|
||||
private String HRPhV_H22_phsC;
|
||||
@JsonProperty("HRPhV_H22_phsB")
|
||||
private String HRPhV_H22_phsB;
|
||||
@JsonProperty("ImbZroV")
|
||||
private String ImbZroV;
|
||||
@JsonProperty("HRPhV_H22_phsA")
|
||||
private String HRPhV_H22_phsA;
|
||||
@JsonProperty("HRPhV_H7_phsA")
|
||||
private String HRPhV_H7_phsA;
|
||||
@JsonProperty("HRPhV_H8_phsA")
|
||||
private String HRPhV_H8_phsA;
|
||||
@JsonProperty("HRPhV_H23_phsB")
|
||||
private String HRPhV_H23_phsB;
|
||||
@JsonProperty("PhV_phsA")
|
||||
private String PhV_phsA;
|
||||
@JsonProperty("HRPhV_H8_phsB")
|
||||
private String HRPhV_H8_phsB;
|
||||
@JsonProperty("HRPhV_H23_phsC")
|
||||
private String HRPhV_H23_phsC;
|
||||
@JsonProperty("HRPhV_H8_phsC")
|
||||
private String HRPhV_H8_phsC;
|
||||
@JsonProperty("PhV_phsB")
|
||||
private String PhV_phsB;
|
||||
@JsonProperty("PhV_phsC")
|
||||
private String PhV_phsC;
|
||||
@JsonProperty("HRPhV_H23_phsA")
|
||||
private String HRPhV_H23_phsA;
|
||||
@JsonProperty("PstPhV_phsC")
|
||||
private String PstPhV_phsC;
|
||||
@JsonProperty("PstPhV_phsA")
|
||||
private String PstPhV_phsA;
|
||||
@JsonProperty("PstPhV_phsB")
|
||||
private String PstPhV_phsB;
|
||||
@JsonProperty("Freq")
|
||||
private String Freq;
|
||||
@JsonProperty("HRPhV_H11_phsA")
|
||||
private String HRPhV_H11_phsA;
|
||||
@JsonProperty("HRPhV_H11_phsB")
|
||||
private String HRPhV_H11_phsB;
|
||||
@JsonProperty("HRPhV_H17_phsC")
|
||||
private String HRPhV_H17_phsC;
|
||||
@JsonProperty("HRPhV_H11_phsC")
|
||||
private String HRPhV_H11_phsC;
|
||||
@JsonProperty("HRPhV_H17_phsB")
|
||||
private String HRPhV_H17_phsB;
|
||||
@JsonProperty("HRPhV_H17_phsA")
|
||||
private String HRPhV_H17_phsA;
|
||||
@JsonProperty("SeqV_C2")
|
||||
private String SeqV_C2;
|
||||
@JsonProperty("HRPhV_H4_phsB")
|
||||
private String HRPhV_H4_phsB;
|
||||
@JsonProperty("SeqV_C1")
|
||||
private String SeqV_C1;
|
||||
@JsonProperty("HRPhV_H4_phsA")
|
||||
private String HRPhV_H4_phsA;
|
||||
@JsonProperty("SeqV_C0")
|
||||
private String SeqV_C0;
|
||||
@JsonProperty("PhVDev_phsC")
|
||||
private String PhVDev_phsC;
|
||||
@JsonProperty("HRPhV_H5_phsA")
|
||||
private String HRPhV_H5_phsA;
|
||||
@JsonProperty("HRPhV_H5_phsB")
|
||||
private String HRPhV_H5_phsB;
|
||||
@JsonProperty("HRPhV_H5_phsC")
|
||||
private String HRPhV_H5_phsC;
|
||||
@JsonProperty("PhVDev_phsB")
|
||||
private String PhVDev_phsB;
|
||||
@JsonProperty("HRPhV_H12_phsC")
|
||||
private String HRPhV_H12_phsC;
|
||||
@JsonProperty("PltPhV_phsA")
|
||||
private String PltPhV_phsA;
|
||||
@JsonProperty("PhVDev_phsA")
|
||||
private String PhVDev_phsA;
|
||||
}
|
||||
Reference in New Issue
Block a user