| | |
|---|
| | | @PostMapping(path = "receive", consumes = MediaType.APPLICATION_JSON_VALUE) |
|---|
| | | public BaseResponse<Boolean> receive(@RequestBody List<JSONObject> list, HttpServletRequest req, HttpServletResponse rep) { |
|---|
| | | //通信中间件传过来的机构tag，以用于查找数据源 |
|---|
| | | String token = req.getHeader(Constant.UserTokenKeyInHeader); |
|---|
| | | DataSourceContext.set(token); |
|---|
| | | String orgTag = req.getHeader(Constant.TokenKeyInHeader); |
|---|
| | | DataSourceContext.set(orgTag); |
|---|
| | | |
|---|
| | | if(list != null && list.size() > 0){ |
|---|
| | | for (JSONObject jo : list) { |
|---|
| | |
|---|
| | | } |
|---|
| | | } |
|---|
| | | } |
|---|
| | | sendByWebSocket(list) ; |
|---|
| | | sendByWebSocket(orgTag, list) ; |
|---|
| | | } |
|---|
| | | return null ; |
|---|
| | | } |
|---|
| | |
|---|
| | | * 通过websocket把消息推送出去，当前接收方是前端的大屏展示模块 |
|---|
| | | * @param list |
|---|
| | | */ |
|---|
| | | private void sendByWebSocket(List<JSONObject> list){ |
|---|
| | | private void sendByWebSocket(String orgTag, List<JSONObject> list){ |
|---|
| | | WebSocketMessage vo = new WebSocketMessage() ; |
|---|
| | | vo.type = WebSocketMessage.TYPE_JSON ; |
|---|
| | | vo.content = list ; |
|---|
| | | try { |
|---|
| | | WebSocketServer.sendAllMessage(JSON.toJSONString(vo)); |
|---|
| | | WebSocketServer.sendMessage2AllClient(orgTag, JSON.toJSONString(vo)); |
|---|
| | | }catch (Exception e){ |
|---|
| | | log.error("推送消息失败", e) ; |
|---|
| | | } |
|---|
