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

1、增加广西交科推送

Browse Source 
2、规范推送设备ID、设备别名、设备名的编码
This commit is contained in:
weidong 2024-07-22 21:14:01 +08:00
parent 8fc19d9e71
commit 3916b89920
1 changed files with 14 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
sec-beidou-fwd/src/main/java/com/imdroid/beidou_fwd/task/SaasForwarder.java
View File

@ -28,6 +28,9 @@ public class SaasForwarder extends Forwarder{
@Value("${sass.server.port}") @Value("${sass.server.port}")
private int port; private int port;
@Value("${sass.server.enabled}")
boolean enabled;
private TCPClient tcpClient; private TCPClient tcpClient;
static class MyTCPListener implements TCPListener { static class MyTCPListener implements TCPListener {
@ -59,22 +62,28 @@ public class SaasForwarder extends Forwarder{
@PostConstruct @PostConstruct
void registerMe(){ void registerMe(){
init(FORWARDER_NAME, "TCP "+host+":"+port,0,FWD_DEVICE_ID,30); init(FORWARDER_NAME, "TCP "+host+":"+port,0,FWD_DEVICE_ID,30);
if(enabled) {
tcpClient = new TCPClient(); tcpClient = new TCPClient();
tcpClient.init(host, port, listener); tcpClient.init(host, port, listener);
tcpClient.start(); tcpClient.start();
} }
}
/** /**
* 每半小时转发GNSS解算结果 * 每半小时转发GNSS解算结果
*/ */
@Scheduled(cron = "0 20,50 * * * ?") // 每30分钟执行一次 @Scheduled(cron = "0 20,50 * * * ?") // 每30分钟执行一次
private void forwardGnss() { private void forwardGnss() {
if(enabled) {
logger.info("saas forwardGnss"); logger.info("saas forwardGnss");
forwardCurrentGnss(); forwardCurrentGnss();
} }
}
@Override @Override
int send(String projectId, List<GnssCalcData> records, LocalDateTime sentTime){ int send(String projectId, List<GnssCalcData> records, LocalDateTime sentTime){
if(!enabled) return 0;
int sendNum = 0; int sendNum = 0;
if(records.size() == 0) return 0; if(records.size() == 0) return 0;