yudao-dev/src/views/dashboard/utils/wsInterface.js

import { connectWebsocket, closeWebsocket } from './websocket'
import store from "@/store";

// 创建dcs链接
export const getDcsMsg = () => {
  const userId = 'dcsmsg' + new Date().getTime()
  connectWebsocket(
    // 测试地址
    'ws://10.70.180.10:8081/xc-screen/websocket/'+userId,
    // 传递给后台的数据
    '',
    // 成功拿到后台返回的数据的回调函数
    (data) => {
      console.log('dcs成功的回调函数, 接收到的data数据: ', data)
      let msgData = JSON.parse(data)
      if (msgData == null) return;
      switch (msgData?.type) {
        case "FanFrequencyInfo": {
          store.dispatch({type: "websocket/setFanFrequencyInfo", payload:msgData.data.FanFrequencyInfo})
          break;
        }
        case "KilnInfo": {
          store.dispatch({type: "websocket/setKilnInfo", payload: msgData.data.kilnInfo})
          break;
        }
        case "GasInfo": {
          store.dispatch({type: "websocket/setGasInfo", payload: msgData.data})
          break;
        }
        case "SumGasInfo": {
          store.dispatch({type: "websocket/setSumGasInfo", payload: msgData.data})
          break;
        }
        default:
      }
    },
    // websocket连接失败的回调函数
    (err) => {
      console.log('失败的回调函数', err)
    }
  )
}

// 创建mes链接
export const getMesMsg = () => {
  const sj = new Date().getTime()
  // ISRA
  // connectWebsocket(
  //   // 测试地址
  //   'ws://10.70.2.2:8080/websocket/message?userId=KI'+sj,
  //   // 传递给后台的数据
  //   '',
  //   // 成功拿到后台返回的数据的回调函数
  //   (data) => {
  //     console.log('mes ISRA成功的回调函数, 接收到的data数据: ', data)
  //     let msgData = JSON.parse(data)
  //     if (msgData == null) return;
  //     switch (msgData?.type) {
  //       case "israKiln": {
  //         store.dispatch({type: "websocket/setIsraKiln", payload:msgData.detData.dayStatistic})
  //         break;
  //       }
  //       // case "KilnInfo": {
  //       //   // store.dispatch({type: "websocket/setKilnInfo", payload: msgData.data.kilnInfo})
  //       //   break;
  //       // }
  //       default:
  //     }
  //   },
  //   // websocket连接失败的回调函数
  //   (err) => {
  //     console.log('失败的回调函数', err)
  //   }
  // )

  // // 原料 MA
  // connectWebsocket(
  //   // 测试地址
  //   'ws://10.70.2.2:8080/websocket/message?userId=MA'+sj,
  //   // 传递给后台的数据
  //   '',
  //   // 成功拿到后台返回的数据的回调函数
  //   (data) => {
  //     console.log('mes 原料成功的回调函数, 接收到的data数据: ', data)
  //     let msgData = JSON.parse(data)
  //     if (msgData == null) return;
  //     switch (msgData?.type) {
  //       case "material": {
  //         store.dispatch({type: "websocket/setMaterial", payload:msgData.data})
  //         break;
  //       }
  //       // case "KilnInfo": {
  //       //   // store.dispatch({type: "websocket/setKilnInfo", payload: msgData.data.kilnInfo})
  //       //   break;
  //       // }
  //       default:
  //     }
  //   },
  //   // websocket连接失败的回调函数
  //   (err) => {
  //     console.log('失败的回调函数', err)
  //   }
  // )

   // 能耗 EN
  //  connectWebsocket(
  //   // 测试地址
  //   'ws://10.70.2.2:8080/websocket/message?userId=ENERGY'+sj,
  //   // 传递给后台的数据
  //   '',
  //   // 成功拿到后台返回的数据的回调函数
  //   (data) => {
  //     console.log('mes 能耗成功的回调函数, 接收到的data数据: ', data)
  //     let msgData = JSON.parse(data)
  //     if (msgData == null) return;
  //     switch (msgData?.type) {
  //       case "EnergyInfo": {
  //         store.dispatch({type: "websocket/setEnergyInfo", payload:msgData.data})
  //         break;
  //       }
  //       default:
  //     }
  //   },
  //   // websocket连接失败的回调函数
  //   (err) => {
  //     console.log('失败的回调函数', err)
  //   }
  // )

  // 烟气 GAS
  connectWebsocket(
    // 测试地址
    'ws://10.70.2.2:8080/websocket/message?userId=GAS'+sj,
    // 传递给后台的数据
    '',
    // 成功拿到后台返回的数据的回调函数
    (data) => {
      console.log('mes 烟气成功的回调函数, 接收到的data数据: ', data)
      let msgData = JSON.parse(data)
      if (msgData == null) return;
      switch (msgData?.type) {
        case "exhaustGas": {
          store.dispatch({type: "websocket/setExhaustGasInfo", payload:msgData.realtime})
          store.dispatch({type: "websocket/setExhaustGasChart", payload:{
            dayTrend: msgData.dayTrend,
            weekTrend: msgData.weekTrend,
            monthTrend: msgData.monthTrend,
            yearTrend: msgData.yearTrend,
          }})
          break;
        }
        default:
      }
    },
    // websocket连接失败的回调函数
    (err) => {
      console.log('失败的回调函数', err)
    }
  )
}