drone-service/drone-gd/src/main/java/org/sxkj/gd/workorder/scheduler/GdXingtuDeviceScheduler.java
New file @@ -0,0 +1,28 @@ package org.sxkj.gd.workorder.scheduler; import lombok.AllArgsConstructor; import lombok.extern.slf4j.Slf4j; import org.springframework.scheduling.annotation.Scheduled; import org.springframework.stereotype.Component; import org.sxkj.gd.workorder.service.IGdManageDeviceService; /** * 星图设备同步定时器 */ @Component @Slf4j @AllArgsConstructor public class GdXingtuDeviceScheduler { private final IGdManageDeviceService gdManageDeviceService; @Scheduled(cron = "0 0 0 * * ?") // 每天凌晨0点执行 public void syncXingtuDevice() { try { int total = gdManageDeviceService.syncXingtuDevice(); log.info("星图设备同步完成,共更新或新增 {} 条设备", total); } catch (Exception e) { log.error("星图设备同步任务执行失败", e); } } } drone-service/drone-gd/src/main/java/org/sxkj/gd/workorder/service/impl/GdManageDeviceServiceImpl.java
@@ -21,8 +21,6 @@ import com.alibaba.fastjson.JSONObject; import com.baomidou.mybatisplus.core.toolkit.Wrappers; import lombok.extern.slf4j.Slf4j; import org.springframework.scheduling.annotation.Async; import org.springframework.scheduling.annotation.Scheduled; import org.sxkj.gd.utils.GdGeoAddressUtil; import org.sxkj.gd.utils.GeomUtils; import org.sxkj.gd.workorder.dto.GdXingtuAirportListDTO; @@ -105,8 +103,6 @@ * @return 同步数量 */ @Override @Scheduled(cron = "0 0 0 * * ?") // @Scheduled(cron = "*/10 * * * * ?") public int syncXingtuDevice() throws Exception { int total = 0; // 2.同步机巢设备