dendi-wang/thingsboard
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

connectivity upgrade fix

Browse Source
This commit is contained in:
YevhenBondarenko 2023-11-01 11:37:36 +01:00
parent 7fc04e4b24
commit 41ec20aa6f
1 changed files with 7 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
application/src/main/java/org/thingsboard/server/service/install/update/DefaultDataUpdateService.java
View File

@ -223,7 +223,6 @@ public class DefaultDataUpdateService implements DataUpdateService {
case "3.5.1": case "3.5.1":
log.info("Updating data from version 3.5.1 to 3.6.0 ..."); log.info("Updating data from version 3.5.1 to 3.6.0 ...");
migrateEdgeEvents("Starting edge events migration - adding seq_id column. "); migrateEdgeEvents("Starting edge events migration - adding seq_id column. ");
migrateDeviceConnectivity();
break; break;
case "3.6.0": case "3.6.0":
log.info("Updating data from version 3.6.0 to 3.6.1 ..."); log.info("Updating data from version 3.6.0 to 3.6.1 ...");
@ -245,12 +244,14 @@ public class DefaultDataUpdateService implements DataUpdateService {
} }
private void migrateDeviceConnectivity() { private void migrateDeviceConnectivity() {
if (adminSettingsService.findAdminSettingsByKey(TenantId.SYS_TENANT_ID, "connectivity") == null) {
AdminSettings connectivitySettings = new AdminSettings(); AdminSettings connectivitySettings = new AdminSettings();
connectivitySettings.setTenantId(TenantId.SYS_TENANT_ID); connectivitySettings.setTenantId(TenantId.SYS_TENANT_ID);
connectivitySettings.setKey("connectivity"); connectivitySettings.setKey("connectivity");
connectivitySettings.setJsonValue(JacksonUtil.valueToTree(connectivityConfiguration.getConnectivity())); connectivitySettings.setJsonValue(JacksonUtil.valueToTree(connectivityConfiguration.getConnectivity()));
adminSettingsService.saveAdminSettings(TenantId.SYS_TENANT_ID, connectivitySettings); adminSettingsService.saveAdminSettings(TenantId.SYS_TENANT_ID, connectivitySettings);
} }
}
@Override @Override
public void upgradeRuleNodes() { public void upgradeRuleNodes() {