| | |
| | | String session_token = sessionTokenService.savePut(partyId); |
| | | data.put("session_token", session_token); |
| | | data.put("fee", sysparaService.find("exchange_apply_order_sell_fee").getSvalue()); |
| | | /*Item item = itemService.findCurrBySymbol(symbol); |
| | | data.put("status", item.getStatus() == null || item.getStatus() == 1 ? 1 :0);*/ |
| | | data.put("status", 1); |
| | | Item item = itemService.findCurrBySymbol(symbol); |
| | | data.put("status", item.getStatus() == null || item.getStatus() == 1 ? 1 :0); |
| | | } |
| | | return Result.succeed(data); |
| | | } |
| | |
| | | public void onOpen(@PathParam(value = "type") String type, |
| | | @PathParam(value = "param") String param, Session session) { |
| | | //停牌断开连接 |
| | | if (WebSocketEnum.SOCKET_ENUM_DEPTH.getCode().equals(type)) { |
| | | /*if (WebSocketEnum.SOCKET_ENUM_DEPTH.getCode().equals(type)) { |
| | | List<Item> items = ApplicationContextUtils.getApplicationContext().getBean(ItemService.class).list(); |
| | | if (CollectionUtil.isNotEmpty(items)) { |
| | | Item item = items.stream().filter(i -> param.equalsIgnoreCase(i.getSymbol())).findFirst().orElse(null); |
| | |
| | | } |
| | | } |
| | | |
| | | } |
| | | }*/ |
| | | |
| | | WebSocketSession webSocketSession = new WebSocketSession(session, getTimeInMillis(), type, param); |
| | | // 加入set中 |