优化otaId

iot-common/iot-common-dao/iot-common-model/src/main/java/cc/iotkit/model/ota/OtaDevice.java

@@ -15,9 +15,9 @@ import lombok.NoArgsConstructor;
 @Builder
 @NoArgsConstructor
 @AllArgsConstructor
-public class OtaDevice implements Id<String> {
+public class OtaDevice implements Id<Long> {
 
-    private String id;
+    private Long id;
 
     private String deviceName;
 

iot-common/iot-common-dao/iot-data-service/src/main/java/cc/iotkit/data/manager/IOtaDeviceData.java

@@ -8,5 +8,5 @@ import cc.iotkit.model.ota.OtaDevice;
  * @Date: 2023/5/25 23:40
  * @Description:
  */
-public interface IOtaDeviceData  extends ICommonData<OtaDevice, String> {
+public interface IOtaDeviceData  extends ICommonData<OtaDevice, Long> {
 }

iot-common/iot-common-dao/iot-data-service/src/main/java/cc/iotkit/data/manager/IOtaPackageData.java

@@ -12,6 +12,4 @@ import java.util.List;
  */
 public interface IOtaPackageData extends ICommonData<OtaPackage, Long> {
 
-    List<OtaPackage> findByVersionGreaterThan(String version);
-
 }

iot-common/iot-common-dao/iot-data-serviceImpl-rdb/src/main/java/cc/iotkit/data/model/TbOtaDevice.java

@@ -21,7 +21,7 @@ public class TbOtaDevice {
     @Id
     @GeneratedValue(generator = "SnowflakeIdGenerator")
     @GenericGenerator(name = "SnowflakeIdGenerator", strategy = "cc.iotkit.data.config.id.SnowflakeIdGenerator")
-    private String id;
+    private Long id;
 
     private String deviceName;
 

iot-common/iot-common-dao/iot-data-serviceImpl-rdb/src/main/java/cc/iotkit/data/service/IOtaDeviceDataImpl.java

@@ -28,7 +28,7 @@ import java.util.stream.Collectors;
  */
 @Primary
 @Service
-public class IOtaDeviceDataImpl implements IOtaDeviceData, IJPACommData<OtaDevice, String> {
+public class IOtaDeviceDataImpl implements IOtaDeviceData, IJPACommData<OtaDevice, Long> {
 
     @Resource
     private IOtaDeviceRepository iOtaDeviceRepository;
@@ -47,45 +47,4 @@ public class IOtaDeviceDataImpl implements IOtaDeviceData, IJPACommData<OtaDevic
     public Class getTClass() {
         return OtaDevice.class;
     }
-
-    @Override
-    public OtaDevice save(OtaDevice data) {
-        if (StringUtils.isBlank(data.getId())) {
-            data.setId(UUID.randomUUID().toString());
-        }
-        iOtaDeviceRepository.save(MapstructUtils.convert(data, TbOtaDevice.class));
-        return data;
-    }
-
-    @Override
-    public OtaDevice findById(String id) {
-        return MapstructUtils.convert(iOtaDeviceRepository.findById(id).orElse(null), OtaDevice.class);
-    }
-
-    @Override
-    public void deleteById(String id) {
-        iOtaDeviceRepository.deleteById(id);
-    }
-
-    @Override
-    public long count() {
-        return iOtaDeviceRepository.count();
-    }
-
-    @Override
-    public List<OtaDevice> findAll() {
-        return iOtaDeviceRepository.findAll().stream().map(e -> MapstructUtils.convert(e, OtaDevice.class))
-                .collect(Collectors.toList());
-    }
-
-    @Override
-    public Paging<OtaDevice> findAll(PageRequest<OtaDevice> pageRequest) {
-        Page<TbOtaDevice> tbOtaPackages = iOtaDeviceRepository.findAll(Pageable.ofSize(pageRequest.getPageSize()).withPage(pageRequest.getPageNum() - 1));
-        return new Paging<>(
-                tbOtaPackages.getTotalElements(),
-                tbOtaPackages.getContent()
-                        .stream().map(e -> MapstructUtils.convert(e, OtaDevice.class))
-                        .collect(Collectors.toList())
-        );
-    }
 }

iot-common/iot-common-dao/iot-data-serviceImpl-rdb/src/main/java/cc/iotkit/data/service/IOtaPackageDataImpl.java

@@ -35,11 +35,6 @@ public class IOtaPackageDataImpl implements IOtaPackageData, IJPACommData<OtaPac
 
     private final IOtaPackageRepository iOtaPackageRepository;
 
-    @Override
-    public List<OtaPackage> findByVersionGreaterThan(String version) {
-        return null;
-    }
-
     @Override
     public JpaRepository getBaseRepository() {
         return iOtaPackageRepository;
@@ -55,11 +50,6 @@ public class IOtaPackageDataImpl implements IOtaPackageData, IJPACommData<OtaPac
         return OtaPackage.class;
     }
 
-    @Override
-    public long count() {
-        return iOtaPackageRepository.count();
-    }
-
     @Override
     public List<OtaPackage> findAll() {
         return iOtaPackageRepository.findAll().stream().map(e -> MapstructUtils.convert(e, OtaPackage.class)).collect(Collectors.toList());

iot-module/iot-manager/src/main/java/cc/iotkit/manager/controller/OtaController.java

@@ -69,10 +69,10 @@ public class OtaController {
         return otaService.getOtaPackagePageList(request);
     }
 
-    @ApiOperation("设备升级")
+    @ApiOperation("OTA升级")
     @PostMapping("/device/upgrade")
-    public String deviceUpgrade(@RequestBody Request<DeviceUpgradeBo> request) {
-        return otaService.startUpgrade(request.getData().getOtaId(), request.getData().getDeviceId());
+    public void deviceUpgrade(@RequestBody Request<DeviceUpgradeBo> request) {
+        otaService.startUpgrade(request.getData().getOtaId(), request.getData().getDeviceIds());
     }
 
     @ApiOperation("设备升级结果查询")
@@ -81,11 +81,4 @@ public class OtaController {
         return otaService.otaResult(request);
     }
 
-    @ApiOperation("OTA升级")
-    @PostMapping("/down")
-    public void ota(@RequestBody PageRequest<DeviceOtaInfoBo> request) {
-        otaService.startUpgrade(1L, "16870054884740abcd123456000000103");
-    }
-
-
 }

iot-module/iot-manager/src/main/java/cc/iotkit/manager/dto/bo/ota/DeviceUpgradeBo.java

@@ -6,6 +6,8 @@ import io.swagger.annotations.ApiModel;
 import lombok.Data;
 import lombok.EqualsAndHashCode;
 
+import java.util.List;
+
 /**
  * @Author: 石恒
  * @Date: 2023/6/16 21:13
@@ -17,6 +19,6 @@ import lombok.EqualsAndHashCode;
 @AutoMapper(target = DeviceUpgradeBo.class, reverseConvertGenerate = false)
 public class DeviceUpgradeBo extends BaseDto {
     private static final long serialVersionUID = -1L;
-    private String deviceId;
+    private List<String> deviceIds;
     private Long otaId;
 }

iot-module/iot-manager/src/main/java/cc/iotkit/manager/service/OtaService.java

@@ -23,6 +23,7 @@ import org.springframework.stereotype.Service;
 import org.springframework.web.bind.annotation.RequestBody;
 
 import java.io.InputStream;
+import java.util.List;
 import java.util.UUID;
 
 /**
@@ -60,10 +61,6 @@ public class OtaService {
         return Boolean.TRUE;
     }
 
-    public void findByVersionGreaterThan(String version, String deviceId) {
-        iOtaPackageData.findByVersionGreaterThan(version);
-    }
-
     public Paging<OtaPackage> getOtaPackagePageList(PageRequest<OtaPackage> request) {
         return iOtaPackageData.findAll(request);
     }
@@ -71,10 +68,11 @@ public class OtaService {
     /**
      * 开始升级
      */
-    public String startUpgrade(Long otaId, String deviceId) {
+    public void startUpgrade(Long otaId, List<String> deviceIds) {
         OtaPackage otaPackage = iOtaPackageData.findById(otaId);
-        //构建升级包
-        return deviceService.otaUpgrade(deviceId, true, otaPackage);
+        deviceIds.forEach(deviceId -> {
+            deviceService.otaUpgrade(deviceId, true, otaPackage);
+        });
     }
 
     public Paging<DeviceOtaInfoVO> otaResult(PageRequest<DeviceOtaInfoBo> request) {