| | |
| | | @Component |
| | | public class MapDataWsScheduler { |
| | | |
| | | public static final int WEBSOCKET_BROADCAST_INTERVAL = 200; |
| | | public static final int WEBSOCKET_BROADCAST_INTERVAL = 800; |
| | | |
| | | private ExecutorService singleThreadExecutor; |
| | | |
| | |
| | | MapWsVo mapWsVo = new MapWsVo(); |
| | | mapWsVo.setAgvVos(syncAgv()); |
| | | MapWebSocket.broadcast(GsonUtils.toJson(mapWsVo)); |
| | | Thread.sleep(WEBSOCKET_BROADCAST_INTERVAL); |
| | | Thread.sleep(WEBSOCKET_BROADCAST_INTERVAL / 3); |
| | | } catch (Exception e) { |
| | | log.error("MapDataWsScheduler.init", e); |
| | | } |
| | |
| | | vo.setDirection(agvDetail.getAgvAngle()); |
| | | vo.setBackpack(GsonUtils.fromJsonToList(agvDetail.getBackpack(), BackpackDto.class)); |
| | | vo.setBattery(agvDetail.getSoc()); |
| | | vo.setError(agvDetail.getError()); |
| | | vo.setError(agvDetail.realError()); |
| | | |
| | | vo.setDynamicRoute(mapDataDispatcher.queryCodeListFromDynamicNode(null, agv.getUuid())); |
| | | |