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

1、多条指令下发用定时器，保持1s间隔

Browse Source
This commit is contained in:
weidong 2025-09-02 18:00:27 +08:00
parent bc1e20c287
commit 4942c23200
2 changed files with 33 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

36
sec-beidou/src/main/java/com/imdroid/beidou/controller/APIController.java
View File

@ -13,6 +13,8 @@ import org.springframework.web.bind.annotation.ResponseBody;
import java.text.SimpleDateFormat;
import java.time.LocalDateTime;
import java.util.List;
import java.util.Timer;
import java.util.TimerTask;
@Controller
public class APIController extends BasicController {
@ -170,12 +172,21 @@ public class APIController extends BasicController {
GnssDevice device = deviceMapper.queryByDeviceId(deviceId);
if (device == null) return null;
Timer timerSyn = new Timer();
int delay = 500;
if (!device.getSyn()) {
GnssGroup gnssGroup = groupMapper.selectById(device.getGroup_id());
if (gnssGroup != null) {
String config = gnssGroup.getConfigCmd(device);
if (config != null) {
rtcmClient.config(deviceId, config);
timerSyn.schedule(new TimerTask() {
@Override
public void run() {
rtcmClient.config(deviceId, config);
}
},delay);
delay += 1000;
// 保存
saveMsg(deviceId, tenantId, 0xd311, config, true);
}
@ -183,7 +194,13 @@ public class APIController extends BasicController {
}
List<String> deviceCmds = device.getConfigCmd();
for(String deviceCmd:deviceCmds){
rtcmClient.config(deviceId, deviceCmd);
timerSyn.schedule(new TimerTask() {
@Override
public void run() {
rtcmClient.config(deviceId, deviceCmd);
}
},delay);
delay += 1000;
// 保存
saveMsg(deviceId, tenantId, 0xd312, deviceCmd, true);
@ -196,7 +213,13 @@ public class APIController extends BasicController {
queryWrapper.last("limit 1");
DeviceCacheCmd cacheCmd = cacheCmdMapper.selectOne(queryWrapper);
if (cacheCmd != null) {
rtcmClient.config(deviceId, cacheCmd.getCmd());
timerSyn.schedule(new TimerTask() {
@Override
public void run() {
rtcmClient.config(deviceId, cacheCmd.getCmd());
}
},delay);
delay += 1000;
cacheCmd.setSyn(true);
cacheCmd.setUpdatetime(LocalDateTime.now());
cacheCmdMapper.updateById(cacheCmd);
@ -205,7 +228,12 @@ public class APIController extends BasicController {
}
// 检查iccid
checkAndAskICCID(device);
timerSyn.schedule(new TimerTask() {
@Override
public void run() {
checkAndAskICCID(device);
}
},delay);
return null;
}

1
sec-beidou/src/main/java/com/imdroid/beidou/controller/GnssDeviceController.java
View File

@ -253,6 +253,7 @@ public class GnssDeviceController extends BasicController{
device.setUpdateuser(getLoginUser(session));
device.setUpdatetime(old_device.getUpdatetime());
device.setSyn(old_device.getSyn());
device.setChange_flag(old_device.getChange_flag());
String diff=ObjUtil.compare(old_device,device);
if(!diff.isEmpty()) {
opLogManager.addLog(getLoginUser(session), getTenantId(session),