| | |
|---|
| | | import org.springframework.web.socket.WebSocketSession; |
|---|
| | | |
|---|
| | | @Component |
|---|
| | | /* loaded from: blade-api.jar:BOOT-INF/classes/org/springblade/common/websocket/realtime/RealTimeDataJsonMessageHandler.class */ |
|---|
| | | public class RealTimeDataJsonMessageHandler implements JsonMessageHandler<RealTimeDataRequestJsonWebSocketMessage> { |
|---|
| | | private final IOrderWorkstationService orderWorkstationService; |
|---|
| | | |
|---|
| | |
|---|
| | | |
|---|
| | | public void handle(WebSocketSession session, RealTimeDataRequestJsonWebSocketMessage message) { |
|---|
| | | List<String> workstationIdList = message.getWorkstationIdList(); |
|---|
| | | List<OrderWorkstation> workstationInProcess = this.orderWorkstationService.getWorkstationInProcess((Set) workstationIdList.stream().map(Long::valueOf).collect(Collectors.toSet())); |
|---|
| | | List<OrderWorkstation> workstationInProcess = this.orderWorkstationService.getWorkstationInProcess(workstationIdList.stream().map(Long::valueOf).collect(Collectors.toSet())); |
|---|
| | | Map<Long, String> orderWorkstationMap = (Map) workstationInProcess.stream().collect(Collectors.toMap((v0) -> { |
|---|
| | | return v0.getWorkstationId(); |
|---|
| | | }, (v0) -> { |
|---|
