@@ -7,5 +7,5 @@ import org.springframework.web.bind.annotation.GetMapping;
@FeignClient(contextId = "RemotecdiTaskService", value = "service-cdi", fallbackFactory = RemotecdiTaskFactory.class)
public interface RemotecdiTaskService {
@GetMapping("/synchronizeDeviceData")
- void synchronizeDeviceData();
+ void synchronizeDeviceData(Integer tenantId, Long engineeringId);
}
@@ -16,7 +16,7 @@ public class RemotecdiTaskFactory implements FallbackFactory<RemotecdiTaskServic
log.error("用户服务调用失败:{}", throwable.getMessage());
return new RemotecdiTaskService() {
@Override
- public void synchronizeDeviceData() {
+ public void synchronizeDeviceData(Integer tenantId, Long engineeringId) {
throw new FeignBadRequestException(500, "人防设备数据定时推送异常" + throwable.getMessage());
@@ -19,9 +19,7 @@ public class RemotecdiTaskApi implements RemotecdiTaskService {
private IotDataTransferService iotDataTransferService;
- Integer tenantId = 1;
- Long engineeringId = 1L;
iotDataTransferService.synchronizeDeviceData(tenantId, engineeringId);
@@ -26,7 +26,7 @@ public class DeviceDataSyncService {
* fixedDelay:任务执行完成后固定延迟29分钟执行下一次
* initialDelay:初始化后立即执行第一次任务
*/
- @Scheduled(fixedDelay = 29 * 60 * 1000, initialDelay = 0)
+ //@Scheduled(fixedDelay = 29 * 60 * 1000, initialDelay = 0)
public void scheduledDeviceDataSync() {
Integer tenantId = 1208;
Long engineeringId = 3101130019L;