Imdroid/security-monitor
2
0
Fork 0
Code Issues Pull Requests 1 Actions Packages Projects Releases Wiki Activity

1、中南院MQTT推送，时间到毫秒

Browse Source
This commit is contained in:
weidong 2025-06-20 16:20:18 +08:00
parent d53d2510df
commit 108bf78bfe
1 changed files with 5 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
sec-beidou-fwd/src/main/java/com/imdroid/beidou_fwd/task/ZNYMQTTForwarder.java
View File

@ -18,6 +18,7 @@ import org.springframework.stereotype.Component;
import javax.annotation.PostConstruct; import javax.annotation.PostConstruct;
import java.time.LocalDateTime; import java.time.LocalDateTime;
import java.time.format.DateTimeFormatter;
import java.util.List; import java.util.List;
@Component @Component
@ -25,6 +26,8 @@ import java.util.List;
@EnableScheduling @EnableScheduling
public class ZNYMQTTForwarder extends Forwarder { public class ZNYMQTTForwarder extends Forwarder {
static final String FORWARDER_NAME = "中南院MQTT"; static final String FORWARDER_NAME = "中南院MQTT";
final DateTimeFormatter formatterMs = DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss.SSS");
static byte[] key = new byte[] { (byte) 0x8c, (byte) 0xc7, 0x2b, 0x05, 0x70, 0x5d, 0x5c, 0x46, (byte) 0xf4, 0x12, (byte) 0xaf, (byte) 0x8c, (byte) 0xbe, static byte[] key = new byte[] { (byte) 0x8c, (byte) 0xc7, 0x2b, 0x05, 0x70, 0x5d, 0x5c, 0x46, (byte) 0xf4, 0x12, (byte) 0xaf, (byte) 0x8c, (byte) 0xbe,
(byte) 0xd5, 0x5a, (byte) 0xad, (byte) 0x8c, (byte) 0xc7, 0x2b, 0x05, 0x70, 0x5d, 0x5c, 0x46 }; (byte) 0xd5, 0x5a, (byte) 0xad, (byte) 0x8c, (byte) 0xc7, 0x2b, 0x05, 0x70, 0x5d, 0x5c, 0x46 };
static byte[] iv = new byte[] { 0x66, 0x7b, 0x02, (byte) 0xa8, 0x5c, 0x61, (byte) 0xc7, (byte) 0x86 }; static byte[] iv = new byte[] { 0x66, 0x7b, 0x02, (byte) 0xa8, 0x5c, 0x61, (byte) 0xc7, (byte) 0x86 };
@ -66,7 +69,7 @@ public class ZNYMQTTForwarder extends Forwarder {
for (GnssCalcData locationRecord : records) { for (GnssCalcData locationRecord : records) {
ZNYMQTTData tranData = new ZNYMQTTData(); ZNYMQTTData tranData = new ZNYMQTTData();
tranData.setTimestamp(locationRecord.getCreatetime().format(formatter)); tranData.setTimestamp(locationRecord.getCreatetime().format(formatterMs));
double n = NumberUtils.scale(locationRecord.getRposn(), 2); double n = NumberUtils.scale(locationRecord.getRposn(), 2);
double e = NumberUtils.scale(locationRecord.getRpose(), 2); double e = NumberUtils.scale(locationRecord.getRpose(), 2);
double d = NumberUtils.scale(locationRecord.getRposd(), 2); double d = NumberUtils.scale(locationRecord.getRposd(), 2);
@ -75,7 +78,7 @@ public class ZNYMQTTForwarder extends Forwarder {
tranData.setRposu(d); tranData.setRposu(d);
String json = GsonUtil.toJson(tranData); String json = GsonUtil.toJson(tranData);
String cryptJson = Des3Utils.encrypt(json,key,iv); String cryptJson = Des3Utils.encrypt(json,key,iv);
logger.info("forward to ZNY mqtt: {}, {}",json, cryptJson); logger.debug("forward to ZNY mqtt: {}, {}",json, cryptJson);
String topic = "/GnssData/"+locationRecord.getDeviceid()+"/Increment"; String topic = "/GnssData/"+locationRecord.getDeviceid()+"/Increment";
try { try {
if(!mqttClient.publish(topic, cryptJson)) break; if(!mqttClient.publish(topic, cryptJson)) break;