修改代码

This commit is contained in:
孙小云 2026-01-17 16:41:22 +08:00
parent aa333a1271
commit b5281c0858
1 changed files with 17 additions and 3 deletions

View File

@ -395,6 +395,8 @@ public class SynService {
* @param deviceName 设备名称
*/
private void syncDock(Long deviceId, String deviceName) {
log.info("开始同步机场: deviceId={}, deviceName={}", deviceId, deviceName);
// 查询机场是否已存在
Dock existingDock = dockDomain.selectDockByDeviceId(deviceId);
@ -405,8 +407,12 @@ public class SynService {
newDock.setDeviceId(deviceId);
newDock.setCreateBy("system");
log.info("准备插入新机场: deviceId={}, dockName={}", deviceId, deviceName);
dockDomain.insertDock(newDock);
log.info("插入新机场: deviceId={}, dockName={}", deviceId, deviceName);
log.info("插入新机场成功: deviceId={}, dockName={}, dockId={}",
deviceId, deviceName, newDock.getDockId());
} else {
log.info("机场已存在,跳过插入: deviceId={}, dockName={}", deviceId, deviceName);
}
// 机场已存在无需更新
}
@ -419,6 +425,8 @@ public class SynService {
* @return 无人机主键ID
*/
private Long syncAircraft(Long deviceId, String deviceName) {
log.info("开始同步无人机: deviceId={}, deviceName={}", deviceId, deviceName);
// 查询无人机是否已存在
Aircraft existingAircraft = aircraftDomain.selectAircraftByDeviceId(deviceId);
@ -429,9 +437,15 @@ public class SynService {
newAircraft.setDeviceId(deviceId);
newAircraft.setCreateBy("system");
log.info("准备插入新无人机: deviceId={}, aircraftName={}", deviceId, deviceName);
aircraftDomain.insertAircraft(newAircraft);
log.info("插入新无人机: deviceId={}, aircraftName={}", deviceId, deviceName);
return newAircraft.getAircraftId();
Long aircraftId = newAircraft.getAircraftId();
log.info("插入新无人机成功: deviceId={}, aircraftName={}, aircraftId={}",
deviceId, deviceName, aircraftId);
return aircraftId;
} else {
log.info("无人机已存在,跳过插入: deviceId={}, aircraftName={}", deviceId, deviceName);
}
// 无人机已存在无需更新
return existingAircraft.getAircraftId();