feat(commandCenter): 新增天气

ai-coding

2026-07-01 ab488021bc18fe01f7190f662753ce565f1562e8

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
import { local } from '@/utils'
import { useCommandCenterStore } from '@/store/commandCenter'
import { createCommandCenterSocket, destroyCommandCenterSocket } from '@/utils/socket'
import { ONLINE_TIMEOUT_MS, SOCKET_EMIT_EVENT, SOCKET_ON_EVENT } from '@/views/businessOperations/commandCenter/command-center.constants'
import type { CommandCenterKpiVo, CommandCenterVehicleDetailVo, PassengerCallVo, VehicleMonitorVo, WeatherVo } from '@/views/businessOperations/commandCenter/command-center.types'
 
/**
 * 指挥中心 WebSocket 连接管理 composable
 * @returns isOnline - 是否在线；connect/disconnect - 连接/断开方法；subscribeCity/unsubscribeCity - 订阅/取消订阅城市
 */
export function useCommandCenterSocket() {
  const store = useCommandCenterStore()
  const socket = createCommandCenterSocket()
 
  /** 判断是否在线（已连接且 5 秒内有推送） */
  const isOnline = computed(() => {
    return store.socketStatus.connected && (Date.now() - store.socketStatus.lastPushAt < ONLINE_TIMEOUT_MS)
  })
 
  /** 建立 WebSocket 连接并监听事件 */
  const connect = () => {
    socket.connect()
    console.log('[CC-Socket] connecting...')
 
    socket.on('connect', () => {
      console.log('[CC-Socket] ✅ connected, sid:', socket.id)
      store.socketStatus.connected = true
      const token = local.get('accessToken')
      console.log('[CC-Socket] ⬆ emit auth, token:', token ? `${token.slice(0, 10)}...` : 'null')
      socket.emit(SOCKET_EMIT_EVENT.AUTH, { token })
    })
 
    socket.on('disconnect', (reason) => {
      console.warn('[CC-Socket] ❌ disconnected, reason:', reason)
      store.socketStatus.connected = false
    })
 
    socket.on(SOCKET_ON_EVENT.AUTH_SUCCESS, (payload) => {
      console.log('[CC-Socket] ⬇ auth_success', payload)
      console.log('[CC-Socket] ⬆ emit subscribe, cityCode:', store.cityCode)
      socket.emit(SOCKET_EMIT_EVENT.SUBSCRIBE, { cityCode: store.cityCode })
    })
 
    socket.on(SOCKET_ON_EVENT.AUTH_FAILED, (payload: { message: string }) => {
      console.error('[CC-Socket] ⬇ auth_failed', payload)
      window.$message?.error(`鉴权失败：${payload.message}`)
      socket.disconnect()
    })
 
    socket.on(SOCKET_ON_EVENT.VEHICLES, (list: VehicleMonitorVo[]) => {
      console.log('[CC-Socket] ⬇ vehicles :', list)
      store.vehicles = list
      store.socketStatus.lastPushAt = Date.now()
    })
 
    socket.on(SOCKET_ON_EVENT.VEHICLE_DETAIL, (data: CommandCenterVehicleDetailVo) => {
      console.log('[CC-Socket] ⬇ vehicle_detail :', data)
      if (data.vehicleId === store.selectedVehicleId) {
        store.vehicleDetail = data
      }
      store.socketStatus.lastPushAt = Date.now()
    })
 
    socket.on(SOCKET_ON_EVENT.KPI, (data: CommandCenterKpiVo) => {
      console.log('[CC-Socket] ⬇ kpi', data)
      store.kpi = data
      store.socketStatus.lastPushAt = Date.now()
    })
 
    socket.on(SOCKET_ON_EVENT.PASSENGER_CALLS, (list: PassengerCallVo[]) => {
      console.log('[CC-Socket] ⬇ passenger_calls,:', list)
      store.passengerCalls = list
      store.socketStatus.lastPushAt = Date.now()
    })
 
    socket.on(SOCKET_ON_EVENT.WEATHER, (data: WeatherVo) => {
      console.log('[CC-Socket] ⬇ weather:', data)
      store.weather = data
    })
  }
 
  /** 断开连接并清理监听 */
  const disconnect = () => {
    socket.removeAllListeners()
    destroyCommandCenterSocket()
    store.socketStatus.connected = false
  }
 
  /**
   * 订阅指定城市的数据推送
   * @param cityCode - 城市编码
   */
  const subscribeCity = (cityCode: string) => {
    console.log('[CC-Socket] ⬆ emit subscribe, cityCode:', cityCode)
    socket.emit(SOCKET_EMIT_EVENT.SUBSCRIBE, { cityCode })
  }
 
  /**
   * 取消订阅指定城市的数据推送
   * @param cityCode - 城市编码
   */
  const unsubscribeCity = (cityCode: string) => {
    console.log('[CC-Socket] ⬆ emit unsubscribe, cityCode:', cityCode)
    socket.emit(SOCKET_EMIT_EVENT.UNSUBSCRIBE, { cityCode })
  }
 
  const subscribeVehicleDetail = (vehicleId: number) => {
    console.log('[CC-Socket] ⬆ emit subscribe_vehicle_detail, vehicleId:', vehicleId)
    socket.emit(SOCKET_EMIT_EVENT.SUBSCRIBE_VEHICLE_DETAIL, { vehicleId })
  }
 
  const unsubscribeVehicleDetail = (vehicleId?: number) => {
    const payload = vehicleId ? { vehicleId } : {}
    console.log('[CC-Socket] ⬆ emit unsubscribe_vehicle_detail', payload)
    socket.emit(SOCKET_EMIT_EVENT.UNSUBSCRIBE_VEHICLE_DETAIL, payload)
  }
 
  return {
    isOnline,
    connect,
    disconnect,
    subscribeCity,
    unsubscribeCity,
    subscribeVehicleDetail,
    unsubscribeVehicleDetail,
  }
}