Showing
1 changed file
with
9 additions
and
8 deletions
... | ... | @@ -310,15 +310,16 @@ public class EdgeGrpcService extends EdgeRpcServiceGrpc.EdgeRpcServiceImplBase i |
310 | 310 | if (consumer != null) { |
311 | 311 | log.trace("[{}] timeout for processing sync edge request.", requestId); |
312 | 312 | consumer.accept(new FromEdgeSyncResponse(requestId, request.getTenantId(), request.getEdgeId(), false)); |
313 | + //thingskit code 修改数据库边端状态 | |
314 | + Edge edge=ctx.getEdgeService().findEdgeById(TenantId.SYS_TENANT_ID,request.getEdgeId()); | |
315 | + if(edge!=null){ | |
316 | + TenantId tenantId = edge.getTenantId(); | |
317 | + save(tenantId, edge.getId(), DefaultDeviceStateService.ACTIVITY_STATE, false); | |
318 | + long lastDisconnectTs = System.currentTimeMillis(); | |
319 | + save(tenantId, edge.getId(), DefaultDeviceStateService.LAST_DISCONNECT_TIME, lastDisconnectTs); | |
320 | + } | |
313 | 321 | } |
314 | - //thingskit code 修改数据库边端状态 | |
315 | - Edge edge=ctx.getEdgeService().findEdgeById(TenantId.SYS_TENANT_ID,request.getEdgeId()); | |
316 | - if(edge!=null){ | |
317 | - TenantId tenantId = edge.getTenantId(); | |
318 | - save(tenantId, edge.getId(), DefaultDeviceStateService.ACTIVITY_STATE, false); | |
319 | - long lastDisconnectTs = System.currentTimeMillis(); | |
320 | - save(tenantId, edge.getId(), DefaultDeviceStateService.LAST_DISCONNECT_TIME, lastDisconnectTs); | |
321 | - } | |
322 | + | |
322 | 323 | }, 20, TimeUnit.SECONDS); |
323 | 324 | } |
324 | 325 | ... | ... |