Browse Source

fix thingsboard issue #6008

pull/7707/head
Peter Chen 4 years ago
committed by Andrii Shvaika
parent
commit
cc3372d963
  1. 16
      application/src/main/java/org/thingsboard/server/service/ota/DefaultOtaPackageStateService.java

16
application/src/main/java/org/thingsboard/server/service/ota/DefaultOtaPackageStateService.java

@ -181,10 +181,22 @@ public class DefaultOtaPackageStateService implements OtaPackageStateService {
private void update(TenantId tenantId, DeviceProfile deviceProfile, OtaPackageType otaPackageType) { private void update(TenantId tenantId, DeviceProfile deviceProfile, OtaPackageType otaPackageType) {
Consumer<Device> updateConsumer; Consumer<Device> updateConsumer;
OtaPackageId packageId = null;
if (otaPackageType.equals(FIRMWARE)) {
if (deviceProfile.getFirmwareId() != null) {
packageId = deviceProfile.getFirmwareId();
}
}
else if (otaPackageType.equals(SOFTWARE)) {
if (deviceProfile.getSoftwareId() != null) {
packageId = deviceProfile.getSoftwareId();
}
}
if (deviceProfile.getFirmwareId() != null) { if (packageId != null) {
long ts = System.currentTimeMillis(); long ts = System.currentTimeMillis();
updateConsumer = d -> send(d.getTenantId(), d.getId(), deviceProfile.getFirmwareId(), ts, otaPackageType); OtaPackageId finalPackageId = packageId;
updateConsumer = d -> send(d.getTenantId(), d.getId(), finalPackageId, ts, otaPackageType);
} else { } else {
updateConsumer = d -> remove(d, otaPackageType); updateConsumer = d -> remove(d, otaPackageType);
} }

Loading…
Cancel
Save