| | |
| | | import nPagination from "@/components/nPagination.vue"; |
| | | import * as api from "@/axios/api"; |
| | | import { Toast } from "vant"; |
| | | import { WhrWebSocket } from "@/utils/WhrWebSocket"; |
| | | export default { |
| | | name: "stock_list", |
| | | components: { |
| | |
| | | pageNum: 1, |
| | | pageSize: 10, |
| | | total: 1, |
| | | stockList: [] |
| | | stockList: [], |
| | | }; |
| | | }, |
| | | props: { |
| | |
| | | }, |
| | | mounted() { |
| | | this.getStockList(); |
| | | this.initWebSocket(); |
| | | }, |
| | | methods: { |
| | | // 获取数据 |
| | |
| | | } else { |
| | | Toast.fail(data.msg); |
| | | } |
| | | }, |
| | | // 连接ws实时监控变动 |
| | | initWebSocket() { |
| | | console.log("initWebSocket"); |
| | | this.Trade = new WhrWebSocket({ |
| | | path: `wss://ws.acapl.net/websocket-server `, |
| | | onmessage: this.getTradeMessage |
| | | }); |
| | | |
| | | this.Trade.init(); |
| | | }, |
| | | getTradeMessage({ data }) { |
| | | let result = JSON.parse(data); |
| | | let pid = result.pid; |
| | | let userToUpdate = this.stockList.find(item => item.code == pid); |
| | | if (userToUpdate) { |
| | | // 更新对象数据 |
| | | userToUpdate.nowPrice = result.last; |
| | | userToUpdate.hcrateP = result.pcp; |
| | | } |
| | | } |
| | | }, |
| | | beforeDestroy() { |
| | | if (this.Trade) { |
| | | this.Trade.close(); |
| | | console.log("WebSocket disconnected"); |
| | | } |
| | | } |
| | | }; |