Commit 85fdd0546e91ae00f4855dca69ca4b4041c13a86

Authored by xp.Huang
1 parent d2f7e211

fix:调整日志记录位置,与设备上下线保持一致(原因:http udp不会触发disconnect)

... ... @@ -176,9 +176,6 @@ public class DefaultDeviceStateService extends AbstractPartitionBasedService<Dev
176 176 save(deviceId, LAST_CONNECT_TIME, ts);
177 177 pushRuleEngineMessage(stateData, CONNECT_EVENT);
178 178 checkAndUpdateState(deviceId, stateData);
179   - //ThingsKit
180   - saveDeviceStateLog(tenantId.toString(),deviceId.toString(), FastIotConstants.StateValue.ONLINE);
181   -
182 179 }
183 180
184 181 @Override
... ... @@ -204,8 +201,12 @@ public class DefaultDeviceStateService extends AbstractPartitionBasedService<Dev
204 201 save(deviceId, ACTIVITY_STATE, true);
205 202 pushRuleEngineMessage(stateData, ACTIVITY_EVENT);
206 203 //thingkit function
207   - tkDeviceService.updateDeviceStateByTbDeviceId(stateData.getTenantId().getId().toString(),deviceId.getId().toString(),
  204 + String tenantId = stateData.getTenantId().getId().toString();
  205 + String tbDeviceId = deviceId.getId().toString();
  206 + tkDeviceService.updateDeviceStateByTbDeviceId(tenantId,tbDeviceId,
208 207 org.thingsboard.server.common.data.yunteng.enums.DeviceState.ONLINE);
  208 + //ThingsKit
  209 + saveDeviceStateLog(tenantId,tbDeviceId, FastIotConstants.StateValue.ONLINE);
209 210 }
210 211 } else {
211 212 log.debug("updateActivityState - fetched state IN NULL for device {}, lastReportedActivity {}", deviceId, lastReportedActivity);
... ... @@ -223,8 +224,6 @@ public class DefaultDeviceStateService extends AbstractPartitionBasedService<Dev
223 224 stateData.getState().setLastDisconnectTime(ts);
224 225 save(deviceId, LAST_DISCONNECT_TIME, ts);
225 226 pushRuleEngineMessage(stateData, DISCONNECT_EVENT);
226   - //ThingsKit
227   - saveDeviceStateLog(tenantId.toString(),deviceId.toString(), FastIotConstants.StateValue.OFFLINE);
228 227 }
229 228
230 229 @Override
... ... @@ -422,8 +421,11 @@ public class DefaultDeviceStateService extends AbstractPartitionBasedService<Dev
422 421 pushRuleEngineMessage(stateData, INACTIVITY_EVENT);
423 422 //thingskit update tkDevice state
424 423 if(stateData.getState().getLastActivityTime()>0){
425   - tkDeviceService.updateDeviceStateByTbDeviceId(stateData.getTenantId().getId().toString(),
426   - deviceId.getId().toString(),org.thingsboard.server.common.data.yunteng.enums.DeviceState.OFFLINE);
  424 + String tenantId = stateData.getTenantId().getId().toString();
  425 + String tbDeviceId = deviceId.getId().toString();
  426 + tkDeviceService.updateDeviceStateByTbDeviceId(tenantId,tbDeviceId,
  427 + org.thingsboard.server.common.data.yunteng.enums.DeviceState.OFFLINE);
  428 + saveDeviceStateLog(tenantId,tbDeviceId, FastIotConstants.StateValue.OFFLINE);
427 429 }
428 430 } else {
429 431 cleanupEntity(deviceId);
... ...