| | |
| | | @Component |
| | | public class MapDataWsScheduler { |
| | | |
| | | public static final int WEBSOCKET_BROADCAST_INTERVAL = 300; |
| | | public static final int WEBSOCKET_BROADCAST_INTERVAL = 30; |
| | | |
| | | private ExecutorService singleThreadExecutor; |
| | | |
| | |
| | | |
| | | private Integer getBackpack(Long agvId, String backpackJson) { |
| | | if (null == agvId || Cools.isEmpty(backpackJson)) { |
| | | return null; |
| | | return 0; |
| | | } |
| | | List<BackpackDto> backpackDtoList = JSON.parseArray(backpackJson, BackpackDto.class); |
| | | int jsonCount = (int) backpackDtoList.stream().filter(BackpackDto::getLoaded).count(); |