| | |
| | | </view> |
| | | </view> |
| | | </view> |
| | | <customer-index v-if="roleType == 1" |
| | | <customer-index v-if="roleType == 1||roleType == 4" |
| | | ref="customerIndexRef" |
| | | :orderPlanDataStore="orderPlanDataStore"></customer-index> |
| | | <freight-forwarder-index v-if="roleType == 2" |
| | |
| | | import freightForwarderIndex from '@/pages/freight-forwarder-page/freightForwarder-index/freightForwarder-index.vue'; |
| | | import { mapState, mapMutations } from 'vuex'; |
| | | import { webSocketUrl } from '@/api/request.js'; |
| | | |
| | | let socket = null; |
| | | export default { |
| | | components: { |
| | |
| | | //首页下拉刷新 |
| | | onPullDownRefresh() { |
| | | uni.showLoading({ title: '加载中...' }); |
| | | // 获取历史提煤单 |
| | | // 获取历史通知单 |
| | | if (this.roleType == 1 || this.roleType == 2) { |
| | | this.$reqGet('getJhOrderPlanDataPage', { current: 1, size: 10 }).then(res => { |
| | | if (res.data.records) { |
| | |
| | | }); |
| | | } |
| | | // 客户获取日计划 |
| | | if (this.roleType == 1) { |
| | | if (this.roleType == 1 || this.roleType == 4) { |
| | | this.$reqGet('GetOrderPlan').then(res => { |
| | | if (res.data) { |
| | | this.orderPlanDataStore = res.data; |
| | |
| | | }, |
| | | isconnect: false, |
| | | dotShow: false, |
| | | appHide: false |
| | | appHide: false, |
| | | phone: '' |
| | | }; |
| | | }, |
| | | watch: { |
| | |
| | | if (nowWeighObj.eqInfraredStatus) { |
| | | this.changeinfraredStatus(true); |
| | | this.changeWeigh(nowWeighObj.weigh); |
| | | let warningState = nowWeighObj.warning == 1 |
| | | this.changeWarning(warningState) |
| | | } else { |
| | | this.changeinfraredStatus(false); |
| | | this.changeWeigh(nowWeighObj.weigh); |
| | | let warningState = nowWeighObj.warning == 1 |
| | | this.changeWarning(warningState) |
| | | } |
| | | } |
| | | } else if (v.startsWith('msg')) { |
| | |
| | | }, |
| | | onShow() { |
| | | this.init(); |
| | | console.log(this.globalisconnect); |
| | | if (this.globalisconnect) { |
| | | this.$store.dispatch('websocketInit') |
| | | this.changeisconnect(false) |
| | | console.log(this.globalisconnect, 'index的ws心事’'); |
| | | this.changeisLogin(true) |
| | | console.log(this.globalisconnect, 'index的ws数据’'); |
| | | } |
| | | this.userAuthorization(); |
| | | this.messageReq(); |
| | | }, |
| | | onHide() { |
| | | console.log('页面隐藏') |
| | | }, |
| | | onUnload() { |
| | | console.log('页面卸载'); |
| | |
| | | this.changeisconnect(true) |
| | | }, |
| | | methods: { |
| | | ...mapMutations(['pushMessage', 'changeWeigh', 'changeinfraredStatus', 'changeisconnect', 'websocketInit']), |
| | | ...mapMutations(['pushMessage', 'changeWeigh', 'changeinfraredStatus', 'changeisconnect', 'websocketInit', |
| | | 'changeisLogin', 'changeWarning' |
| | | ]), |
| | | messagePage() { |
| | | uni.navigateTo({ |
| | | url: '/pages/public-page/message/message' |
| | |
| | | console.log('driverIndexRef'); |
| | | this.$nextTick(() => { |
| | | this.$refs.driverIndexRef.init(); |
| | | }); |
| | | break; |
| | | case 4: |
| | | console.log('customerIndexRef'); |
| | | this.$nextTick(() => { |
| | | this.$refs.customerIndexRef.init(); |
| | | }); |
| | | break; |
| | | default: |
| | |
| | | } |
| | | }); |
| | | }, |
| | | // 初始化websocket |
| | | initWebsocket() { |
| | | let wsUrl = `${webSocketUrl}?access_token=${uni.getStorageSync('token')}`; |
| | | socket = uni.connectSocket({ |
| | | url: wsUrl, |
| | | header: { |
| | | CLIENT_TOC: 'Y' |
| | | }, |
| | | complete: res => { |
| | | console.log(res, 'socket结果'); |
| | | if (res.errMsg == 'connectSocket:ok') { |
| | | this.changeisconnect(true); |
| | | this.isconnect = true; |
| | | } |
| | | } |
| | | }); |
| | | socket.onOpen(() => { |
| | | console.log('onOpen'); |
| | | this.intervalId = setInterval(() => { |
| | | socket.send({ |
| | | data: JSON.stringify({ type: 'ping' }), |
| | | success(e) { |
| | | console.log(e, '发送心跳成功'); |
| | | } |
| | | }); |
| | | }, 30000); |
| | | }); |
| | | |
| | | // 获取服务器传来的数据,做相应处理 |
| | | socket.onMessage(res => { |
| | | console.log('message', res); |
| | | if (res.data.startsWith('weigh')) { |
| | | let nowWeighObj = JSON.parse(res.data.slice(7)); |
| | | if (this.globalweighHouseCode && nowWeighObj.eqCode == this.globalweighHouseCode) { |
| | | if (nowWeighObj.eqInfraredStatus) { |
| | | this.changeinfraredStatus(true); |
| | | this.changeWeigh(nowWeighObj.weigh); |
| | | } else { |
| | | this.changeinfraredStatus(false); |
| | | this.changeWeigh(nowWeighObj.weigh); |
| | | } |
| | | } |
| | | } else if (res.data.startsWith('msg')) { |
| | | this.messageList = JSON.parse(res.data.slice(5)); |
| | | this.messagePushShow = true; |
| | | } else {} |
| | | }); |
| | | socket.onClose(e => { |
| | | console.log('webSocketClose', e); |
| | | this.isconnect = false; |
| | | this.changeisconnect(false); |
| | | }); |
| | | socket.onError(err => { |
| | | console.log('socket报错', err); |
| | | this.$u.toast('出现错误,请重新进入该页面,重试!!'); |
| | | }); |
| | | }, |
| | | messageconfirm() { |
| | | this.messagePushShow = false; |
| | | uni.navigateTo({ |
| | |
| | | this.dotShow = filtermessage.length > 0; |
| | | } |
| | | }); |
| | | } |
| | | }, |
| | | } |
| | | }; |
| | | </script> |