|
|
@@ -1,14 +1,12 @@
|
|
|
package org.jetlinks.community.device.service;
|
|
|
|
|
|
import cn.hutool.core.util.StrUtil;
|
|
|
-import cn.hutool.cron.CronUtil;
|
|
|
import lombok.AllArgsConstructor;
|
|
|
import lombok.extern.slf4j.Slf4j;
|
|
|
import org.hswebframework.ezorm.rdb.mapping.ReactiveUpdate;
|
|
|
import org.hswebframework.web.crud.service.GenericReactiveCrudService;
|
|
|
import org.jetlinks.community.device.entity.DeviceFirmwareEntity;
|
|
|
import org.jetlinks.community.device.entity.DeviceFirmwareTaskEntity;
|
|
|
-import org.jetlinks.community.device.entity.DeviceInstanceEntity;
|
|
|
import org.jetlinks.community.device.entity.DeviceUpgradeHistoryEntity;
|
|
|
import org.jetlinks.community.device.enums.FirmwareUpgradeState;
|
|
|
import org.jetlinks.community.device.enums.TaskMode;
|
|
|
@@ -18,13 +16,8 @@ import org.jetlinks.core.device.DeviceOperator;
|
|
|
import org.jetlinks.core.device.DeviceRegistry;
|
|
|
import org.jetlinks.core.message.firmware.*;
|
|
|
import org.springframework.stereotype.Service;
|
|
|
-import reactor.core.publisher.Flux;
|
|
|
import reactor.core.publisher.Mono;
|
|
|
-
|
|
|
-import javax.management.Query;
|
|
|
-import java.util.HashMap;
|
|
|
import java.util.Map;
|
|
|
-import java.util.Objects;
|
|
|
import java.util.concurrent.ConcurrentHashMap;
|
|
|
import java.util.concurrent.Executors;
|
|
|
import java.util.concurrent.ScheduledFuture;
|