Commit 2f89640fe25996ca4d60c6254666fe0bab911404
Merge branch 'fix/edge-state' into 'master_dev'
fix:边端已离线,当云端主动连接边端报错时,修改边端状态为离线 See merge request yunteng/thingskit!449
Showing
1 changed file
with
8 additions
and
0 deletions
@@ -311,6 +311,14 @@ public class EdgeGrpcService extends EdgeRpcServiceGrpc.EdgeRpcServiceImplBase i | @@ -311,6 +311,14 @@ public class EdgeGrpcService extends EdgeRpcServiceGrpc.EdgeRpcServiceImplBase i | ||
311 | log.trace("[{}] timeout for processing sync edge request.", requestId); | 311 | log.trace("[{}] timeout for processing sync edge request.", requestId); |
312 | consumer.accept(new FromEdgeSyncResponse(requestId, request.getTenantId(), request.getEdgeId(), false)); | 312 | consumer.accept(new FromEdgeSyncResponse(requestId, request.getTenantId(), request.getEdgeId(), false)); |
313 | } | 313 | } |
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 | + } | ||
314 | }, 20, TimeUnit.SECONDS); | 322 | }, 20, TimeUnit.SECONDS); |
315 | } | 323 | } |
316 | 324 |