| | |
|---|
| | | public void hollowGlassTask() { |
|---|
| | | List<HollowGlassOutRelationInfo> taskList = hollowGlassOutRelationInfoService.list(new LambdaQueryWrapper<HollowGlassOutRelationInfo>() |
|---|
| | | .in(HollowGlassOutRelationInfo::getState, Const.HOLLOW_FLOW_CARD_START, Const.HOLLOW_FLOW_CARD_PAUSE)); |
|---|
| | | if (CollectionUtil.isEmpty(taskList)){ |
|---|
| | | if (CollectionUtil.isEmpty(taskList)) { |
|---|
| | | return; |
|---|
| | | } |
|---|
| | | JSONObject jsonObject = new JSONObject(); |
|---|
| | | List<String> flowCardIdList = taskList.stream().map(HollowGlassOutRelationInfo::getFlowCardId).collect(Collectors.toList()); |
|---|
| | | List<HollowGlassQueueInfo> list = hollowGlassQueueInfoService.list(new LambdaQueryWrapper<HollowGlassQueueInfo>().in(HollowGlassQueueInfo::getFlowCardId, flowCardIdList)); |
|---|
| | | Map<Integer, List<HollowGlassQueueInfo>> listMap = list.stream().collect(Collectors.groupingBy(HollowGlassQueueInfo::getCell)); |
|---|
| | | jsonObject.append("930",listMap.get(930)); |
|---|
| | | jsonObject.append("931",listMap.get(931)); |
|---|
| | | jsonObject.append("932",listMap.get(932)); |
|---|
| | | jsonObject.append("930", listMap.get(930)); |
|---|
| | | jsonObject.append("931", listMap.get(931)); |
|---|
| | | jsonObject.append("932", listMap.get(932)); |
|---|
| | | List<WebSocketServer> sendwServer = WebSocketServer.sessionMap.get("HollowGlass"); |
|---|
| | | if (CollectionUtil.isNotEmpty(sendwServer)) { |
|---|
| | | WebSocketServer socketServer = sendwServer.get(0); |
|---|
| | | for (WebSocketServer socketServer : sendwServer) { |
|---|
| | | if (socketServer != null && socketServer.session.isOpen()) { |
|---|
| | | socketServer.sendMessage(jsonObject.toString()); |
|---|
| | | } |
|---|
| | | } |
|---|
| | | } |
|---|
| | | } |
|---|
| | | } |
|---|
