tba-waves/src/utils/tdInstruction/operate.ts

import Bus from "@/utils/bus";
import bus from "@/utils/bus";
import {useAppStore} from '@/stores/app'
import {useTimeScrollbarStore} from '@/stores/timeScrollbar'
import {useStationStore} from "@/stores/station";
import {extractList} from "../list";
import {stationList} from "@/assets/js/station";
import {slopeCalculation} from "@/utils/slopeCalculation";
import {getYuyanDataList} from "@/api/yuyan";
import {convertDate} from "@/utils/date";
import {useTyphoonStore} from "@/stores/typhoon";
import {getRainfallForecastRadarMap, getRainfallForecastRadarMapList} from "@/api/typhoon";
import {Layer} from "@/utils/tdInstruction/index";
import {formatd} from "@/utils/ruoyi";

let waterLevel = "";
let waterSpeed = "";

/**
 * 设置测站水位
 * @param stcd 测站编码
 * @param value 水位
 */
export async function setWaterLevel(stcd: any, value: any = waterLevel, speed: any = waterSpeed) {
  if (value) {
    waterLevel = value + ""
  } else {
    if (!waterLevel) {
      const store = useStationStore()
      store.setStcd(stcd)
      waterLevel = await store.getZ() + ''
    }
  }
  if (speed) {
    waterSpeed = speed + ""
  }
  let descriptor = {
    "command": "WaterLevel",
    "data": {
      "ID": stcd,
      "code": waterLevel,
      "wave": waterSpeed
    }
  }
  Bus.emit('emitUIInteraction', descriptor)
  console.log("-- 设置测站水位,流速", JSON.stringify(descriptor));
}


export async function setUnderwaterState(stcd: any, show = true) {
  let value = "-5"
  if (!show) {
    const store = useStationStore()
    value = waterLevel ? waterLevel : await store.getZ() + ''
  }
  let descriptor = {
    "command": "WaterLevel",
    "data": {
      "ID": stcd,
      "code": value,
    }
  }
  Bus.emit('emitUIInteraction', descriptor)
  console.log("-- 水下地形：", JSON.stringify(descriptor));
}

/**
 * 设置测站流速
 * @param stcd 测站编码
 * @param value 水位
 */
export function setWaterSpeed(stcd: any, speed: any = waterSpeed) {
  let descriptor = {
    "command": "WaterLevel",
    "data": {
      "ID": stcd,
      "speed": speed
    }
  }
  Bus.emit('emitUIInteraction', descriptor)
  console.log("-- 设置测站流速", JSON.stringify(descriptor));
}

/**
 * 测验模拟
 * @param type 播放、暂停、继续、结束
 * @param stcd 测站编码
 */
export function testSimulation(stcd: any, type: any = '播放') {
  let descriptor = {
    "command": "InstrumentMovie",
    "data": {
      "Type": type,
      "ID": stcd
    }
  }
  Bus.emit('emitUIInteraction', descriptor)
  console.log("-- 测验模拟:" + type, JSON.stringify(descriptor));
}

/**
 * 流量比对
 * @param type 播放、暂停、继续、结束
 * @param stcd 测站编码
 */
export function flowComparative(stcd: any, type: any = '播放') {
  let descriptor = {
    "command": "ADCPship",
    "data": {
      "Type": type,
      "ID": stcd
    }
  }
  Bus.emit('emitUIInteraction', descriptor)
  console.log("-- 流量比对:" + type, JSON.stringify(descriptor));
}

/**
 * 漫游(太师桥)
 * @param type 远：河道；近：测站
 * @param operate 播放、暂停、继续、结束
 */
export function roam(type: any = 'river', operate: any = 'play') {
  let descriptor = {
    "command": "Roaming",
    "data": {
      "tag": type === 'river' ? "太师桥远" : "太师桥近",
      "Type": operate
    }
  }
  Bus.emit('emitUIInteraction', descriptor)
  console.log("-- 漫游:" + (type === 'river' ? "河道" : "测站"), JSON.stringify(descriptor));
}

export function setPointState(stcd: any, name: string, type: string) {
  let descriptor = {
    "command": "POIwarning",
    "data": {
      "ID": stcd,
      "Name": name,
      "type": type
    }
  }
  Bus.emit('emitUIInteraction', descriptor);
  console.log("-- 设置设备告警:", JSON.stringify(descriptor));
}

export async function addTyphoonTrack(tfid: string) {
  const typhoonStore = useTyphoonStore()
  let yuyanData: any[] = await getYuyanDataList("2025041714054696095")
    .then(res => {
      return res.data.map(item => {
        return {
          ...item,
          YMDHM: convertDate(item.YMDHM)
        }
      })
    })

  const appStore = useAppStore()
  const timeScrollbarStore = useTimeScrollbarStore()
  appStore.changeCurrentView("Globe")

  // 获取台风数据
  const typhoonData = await import(`@/assets/json/typhoon/${tfid}.json`).then(res => res.default);
  typhoonData.points.length

  timeScrollbarStore.setTimeScrollbarShow(true)
  timeScrollbarStore.setMax(typhoonData.points.length)

  const timeList = typhoonData.points.map((element: any) => element.time);
  const timeObj = extractList(timeList, 4)
  for (let key in timeObj) {
    timeObj[key] = {
      style: {
        color: '#00c7e3',
        'text-shadow': '0 0 4px #32003C'
      },
      label: timeObj[key].substring(0, 10) + '\n' + timeObj[key].substring(11)
    }
  }
  timeScrollbarStore.setMarks(timeObj)

  let time = ''
  timeScrollbarStore.sliderlTooltip = (value: number) => {
    if (typhoonStore.isRadar) {
      getRainfallForecastRadarMap(timeList[value]).then(res => {
        Layer.radarMap(res)
      })
    }

    const date = new Date(timeList[value])
    const list = yuyanData.filter(y => y.YMDHM.getTime() === date.getTime())
    const data = list.map(d => {
      let station: any = stationList.find(s => s.id === d.STCD)

      if (!station) {
        console.log(`未找到${d.STCD}`)
      }

      return {
        value: `${(d.DATA).toFixed(2)}`,
        name: station.name,
        x: station.lgtd,
        y: station.lttd
      }
    })

    if (data && data.length > 0) {
      const res: any = slopeCalculation(data);
      taihuUI(res.direction, res.slope, res.max, res.min);
    }

    if (timeList[value].substring(0, 10) != time) {
      time = timeList[value].substring(0, 10)
      bus.emit('chat', `汇报当前时间 ${time} 台风情况，太湖局应该如何响应，回复内容简单明了，条理清晰，通俗易懂，字数限制200字。如果没有信息就返回null。 台风信息如下：${JSON.stringify(typhoonData.points[value])}`)
    }

    setTyphoonTrack(tfid, timeList[value])
    return timeList[value]
  }

  let descriptor = {
    "command": "AddTyphoonTrack",
    "data": {
      "tfid": tfid
    }
  }
  Bus.emit('emitUIInteraction', descriptor);
  console.log("-- 台风路径:", JSON.stringify(descriptor));

  timeScrollbarStore.play()

  typhoonStore.setTyphoon(true)
}


export function setTyphoonTrack(tfid: string, time: string) {
  let descriptor = {
    "command": "TyphoonTime",
    "data": {
      "tfid": tfid,
      "time": time
    }
  }
  Bus.emit('emitUIInteraction', descriptor);
  console.log("-- 设置台风时间点:", JSON.stringify(descriptor));
}

/**
 * 删除台风路径
 * @param tfid
 */
export function deleteTyphoonTrack(tfid: string) {
  const timeScrollbarStore = useTimeScrollbarStore()
  timeScrollbarStore.close()
  let descriptor = {
    "command": "DelLevel",
    "data": {
      "tfid": 'TyphoonTrack',
      // "tfid": tfid,
      "type": "3"
    }
  }
  Bus.emit('emitUIInteraction', descriptor);
  console.log("-- 删除台风路径:", JSON.stringify(descriptor));

  taihuUI('', '', '', '', false);
  const store = useTyphoonStore()
  store.setTyphoon(false)
}

/**
 * 实时台风
 */
export function realTimeTyphoon(show = true) {
  let descriptor = {
    "command": "RuntimeTyphoon",
    "data": {
      "Display": show ? "true" : "false"
    }
  }
  Bus.emit('emitUIInteraction', descriptor);
  console.log("-- 实时台风:", JSON.stringify(descriptor));
}


/**
 * 设置站点基础数据
 * @param data
 */
export function setStationData(data: any) {
  let descriptor = {
    "command": "SetScene",
    "data": {
      "id": data.name,
      "堤顶高程": data.damel,
      "保证水位": data.grz,
      "青坎线": data.qingkang,
      "警戒水位": data.wrz,
      "当前水位": data.z,
    }
  }
  Bus.emit('emitUIInteraction', descriptor);
  console.log("-- 设置站点基础数据:", JSON.stringify(descriptor));
}

let strategyMapState = false

/**
 * 设置太湖湖面图层
 * @param direction
 * @param slope
 * @param show
 */
export function strategyMap(direction: string, slope: string, show = true) {
  let descriptor = {
    "command": "InclinedAngle",
    "data": {
      "Direction": direction,
      "Slope": slope,
      "Display": show ? 'true' : 'false'
    }
  }
  Bus.emit('emitUIInteraction', descriptor);
  console.log("-- 太湖湖面图层:", JSON.stringify(descriptor));
}


export function taihuUI(direction: string, slope: string, max: string, min: string, show = true) {
  let descriptor = {
    "command": "TaihuUI",
    "data": {
      "Direction": direction,
      "Slope": slope,
      "Max": max,
      "Min": min,
      "Display": show ? "true" : "false"
    }
  }
  Bus.emit('emitUIInteraction', descriptor);
  console.log("-- 台风太湖UI:", JSON.stringify(descriptor));
}

export async function addRadar(type: any) {
  let radarList: any = await getRainfallForecastRadarMapList(formatd(new Date(), 'yyyy-MM-dd'), formatd(new Date(), 'yyyy-MM-dd'), type)
    .then(res => res)

  const appStore = useAppStore()
  const timeScrollbarStore = useTimeScrollbarStore()
  appStore.changeCurrentView('Globe')

  timeScrollbarStore.setTimeScrollbarShow(true)
  timeScrollbarStore.setMax(radarList.length)
  timeScrollbarStore.setStep(3)

  const timeList = radarList.map((element: any) => element.TBA_GETDATE);
  const timeObj = extractList(timeList, 4)
  for (let key in timeObj) {
    timeObj[key] = {
      style: {
        color: '#00c7e3',
        'text-shadow': '0 0 4px #32003C'
      },
      label: timeObj[key].substring(0, 10) + '\n' + timeObj[key].substring(11)
    }
  }
  timeScrollbarStore.setMarks(timeObj)

  timeScrollbarStore.sliderlTooltip = (value: number) => {
    Layer.radarMap(radarList[value].TBA_FILENAME)
    return timeList[value]
  }
}


/**
 * 删除台风路径
 */
export function deleteRadar() {
  const timeScrollbarStore = useTimeScrollbarStore()
  timeScrollbarStore.close()
  Layer.radarMap("", false)
}