| | |
| | | @Configuration |
| | | public class WsClientConfig { |
| | | |
| | | private static final String SERVER_URL = PropertiesUtil.getProperty("JS_IN_HTTP_API"); |
| | | private static final String AUTH_KEY = PropertiesUtil.getProperty("JS_IN_KEY"); |
| | | private static final String SERVER_URL = PropertiesUtil.getProperty("JP_HTTP_API"); |
| | | private static final String AUTH_KEY = PropertiesUtil.getProperty("JP_KEY"); |
| | | private static final String ROOM_ID = "14"; |
| | | private static Socket socket; |
| | | |
| | |
| | | ApplicationContext act = ApplicationContextRegisterUtil.getApplicationContext(); |
| | | MandatoryLiquidationService liquidationService = (MandatoryLiquidationService) act.getBean(IMandatoryLiquidationService.class); |
| | | StockRealTimeBean stockDetailBean = new Gson().fromJson(args[0].toString(), StockRealTimeBean.class); |
| | | liquidationService.RealTimeDataProcess(EStockType.IN,stockDetailBean); |
| | | liquidationService.RealTimeDataProcess(EStockType.JP,stockDetailBean); |
| | | }catch (Exception e){ |
| | | log.error("socket数据存入缓存错误:", e.getMessage()); |
| | | } |