monitoringPanels.js 62 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970971972973974975976977978979980981982983984985986987988989990991992993994995996997998999100010011002100310041005100610071008100910101011101210131014101510161017101810191020102110221023102410251026102710281029103010311032103310341035103610371038103910401041104210431044104510461047104810491050105110521053105410551056105710581059106010611062106310641065106610671068106910701071107210731074107510761077107810791080108110821083108410851086108710881089109010911092109310941095109610971098109911001101110211031104110511061107110811091110111111121113111411151116111711181119
  1. /**
  2. * 运行监测模式四个二级面板的**领域与视图层**(票 18)。
  3. *
  4. * 四块面板:监测概览 `monitoringOverview` / 监测分布 `monitoringDistribution` /
  5. * 运行概况 `operationOverview` / 监测点台账 `monitoringPointLedger`。
  6. *
  7. * 分工与票 17 完全一致(本票沿用同一形状,不造第二套):
  8. * 1. **契约适配**:后端三个面板级聚合读模型的载荷 → 领域对象(字段改名、缺失记账、码翻人话);
  9. * 2. **视图计划**:领域对象 → 组件可以直接画的块。
  10. * 块的构造与码表在 `domain/panelBlocks.js`(票 18 从票 17 提出来共用),本文件只写"放哪些块"。
  11. *
  12. * 纯函数:不 import service、不碰 DOM、不自己发请求。
  13. *
  14. * 「入库时间」只认 createdAt(源记录 create_time),不使用 updatedAt 或 sampledAt 兜底。
  15. * 全部时间类措辞取自 `fields.js` 的 `TIME_LABELS`(票 62 的唯一词表),本文件不另写一版。
  16. * 点位状态中文来自 pointStatus;片区只消费正式 district 编码,空值显未分区。
  17. * 监测概览/运行概况不接收片区筛选,监测分布接收 district。
  18. *
  19. * 后端形状依据(`E:\pipe-ner-server`,逐类读过响应类、控制器与服务):
  20. * `CockpitMonitoringOverviewResponse` / `...DistributionResponse` / `...SituationResponse`、
  21. * `CockpitMonitoringOverviewController` / `...DistributionController` / `...SituationController`、
  22. * 服务 `CockpitMonitoring{Overview,Distribution,Situation}Service`,
  23. * 演示载荷 `docs/cockpit/monitoring-{overview,distribution,operating-situation}-demo.html`。
  24. * BigDecimal 在线上是字符串(`"0.32"`),所以走 `panelBlocks.js` 的 `numberish`。
  25. */
  26. import { fieldReader, TIME_LABELS } from './fields.js'
  27. import { DETAIL_PLACEHOLDER } from './detailFlow.js'
  28. import { valueText } from './equipmentDetailView.js'
  29. import { industryLabel, normalizeDistrict, districtLabel, districtFilterLabel } from './filterOptions.js'
  30. import { legendVisuals, visualForStatus } from './pointStatus.js'
  31. import { planStatusPie } from './statusPie.js'
  32. import { abnormalCountRows } from './abnormalCounts.js'
  33. import {
  34. barsBlock,
  35. CARD_ACTION,
  36. codeText,
  37. donutBlock,
  38. kpiBlock,
  39. listBlock,
  40. numberish,
  41. panelMissingNote,
  42. ratioText,
  43. regionText,
  44. rowsBlock,
  45. stackedBlock,
  46. supplementalBlock,
  47. sectionHasContent,
  48. sectionPlaceholder,
  49. sortByCountDesc,
  50. trendBlock,
  51. } from './panelBlocks.js'
  52. /** 运行监测模式的四个 panelId(与 `domain/panelCatalog.js` 的目录一致,顺序即界面顺序)。 */
  53. export const MONITORING_PANEL_IDS = [
  54. 'monitoringOverview',
  55. 'monitoringDistribution',
  56. 'operationOverview',
  57. 'monitoringPointLedger',
  58. ]
  59. /**
  60. * 指标状态码 → 人话(契约手册第 2 节冻结的六态:NORMAL/WARNING/ALARM/EXPIRED/OFFLINE/UNKNOWN)。
  61. *
  62. * 为什么自带一张而不是并进 `CODE_TEXT`:这六个词是**运行监测专用**的指标状态字典
  63. * (手册原句「运行监测专用,`EXPIRED` 不与 `OFFLINE` 合并」),而 `CODE_TEXT` 里
  64. * `EXPIRED` 属于新鲜度字典。两张字典在契约里就是两张,合成一张会让「指标过期」与
  65. * 「数据过期」共用措辞而看不出区别。六个取值**全部**登记,认不出的回原码。
  66. */
  67. export const METRIC_STATUS_TEXT = {
  68. NORMAL: '正常',
  69. WARNING: '预警',
  70. ALARM: '报警',
  71. EXPIRED: '过期',
  72. OFFLINE: '离线',
  73. UNKNOWN: '未发布',
  74. }
  75. /** 后端 `abnormalType` 与 `status` 在响应里取的是同一个值(服务逐行读过),所以只翻一份。 */
  76. export function metricStatusText(code) {
  77. const value = typeof code === 'string' ? code.trim() : ''
  78. if (!value) return '未知'
  79. return METRIC_STATUS_TEXT[value] || value
  80. }
  81. /** 入库时间与设备采样时间的语义说明(票 62:随唯一词表改名,措辞同步)。三种时间彼此不同:入库时间(createdAt,源记录写库时刻)/采样时间(sampledAt,设备采集时刻)/快照时间(信封 updatedAt,后端快照生成时刻)。 */
  82. export const METRIC_FRESHNESS_GAP =
  83. `${TIME_LABELS.latestIngested}=源记录写库时刻,不是设备采样时刻;缺失时显示占位符「—」,不使用接口响应或快照时间代替`
  84. /**
  85. * 全局状态分布**未取到**时的如实说明(票 14;决策 02:状态栏与饼图共用同一份
  86. * 全局未筛分布,数据源是 `map-snapshot` 的八桶全局计数)。缺失时不伪造全零饼图。
  87. */
  88. export const STATUS_DISTRIBUTION_UNPUBLISHED =
  89. '全局状态分布未取到(后端尚未发布八桶全局计数);顶部状态栏与本饼图共用同一份数据,发布前两者都不显示计数'
  90. /** 八桶 → 人话(来自票 09 的唯一一张表;含 UNKNOWN「状态未发布」与 UNASSOCIATED「无关联设备」)。 */
  91. const POINT_STATUS_FILTER_LABELS = Object.fromEntries(legendVisuals().map((visual) => [visual.key, visual.label]))
  92. /** 范围(区域)筛选的落点说明:三个端点里只有监测分布收 `region`。 */
  93. export const REGION_SCOPE_NOTE = '片区筛选按后端片区编码作用于监测分布'
  94. // 井盖(`MANHOLE`)**已可筛选**(票 18 实施时的缺口已由后端关闭):
  95. // 它现已是第四个正式行业,且全部 11 个 cockpit 服务都收(含 `map-snapshot`)。
  96. // 映射已接上(`domain/filterOptions.js` 的 `INDUSTRY_CODES.manhole`),
  97. // 因此本模块**不再有**「井盖无契约位」这条缺口常量 —— 曾用名 `MANHOLE_INDUSTRY_GAP` 已删除。
  98. // ================================================================ 契约适配
  99. /**
  100. * 监测概览(`/monitoring/overview`)→ 领域对象。
  101. * 票 18 验收第 1 条:监测点/设备规模、在线率、类型分布和最近采集时间。
  102. *
  103. * 端点入参只有 `industry` 与 `deviceType`(控制器逐行读过)——
  104. * **不收 `region`,也不收 `pointStatus`**,所以本面板的筛选面就是行业 + 类型。
  105. *
  106. * 票 62 追加需求:本端点还回出**逐设备台账** `devices[]`(与 `counts.equipmentCount`
  107. * 同源同口径,行数恒等于该计数)。运行概况面板的「设备台账」清单读的就是这一份 ——
  108. * 它替代了原先借用 `/monitoring/situation`「异常设备清单」的做法:那张清单只装异常四态
  109. * 设备(WARNING/ALARM/EXPIRED/OFFLINE),既不是台账、条数也与设备总数对不上。
  110. */
  111. export function toMonitoringOverview(raw) {
  112. const reader = fieldReader(raw, 'monitoringOverview')
  113. const counts = fieldReader(reader.raw.counts, 'monitoringOverview.counts')
  114. const status = fieldReader(reader.raw.status, 'monitoringOverview.status')
  115. const onlineRate = fieldReader(reader.raw.onlineRate, 'monitoringOverview.onlineRate')
  116. const freshness = fieldReader(reader.raw.freshness, 'monitoringOverview.freshness')
  117. const mapFilter = reader.optionalObj('mapFilter') || {}
  118. return {
  119. createdAt: reader.optionalStr('createdAt'),
  120. updatedAt: reader.optionalStr('updatedAt'),
  121. rangeType: (reader.optionalObj('range') || {}).type || '',
  122. // 规模
  123. monitoringPointCount: numberish(counts.raw.monitoringPointCount),
  124. equipmentCount: numberish(counts.raw.equipmentCount),
  125. facilityCount: numberish(counts.raw.facilityCount),
  126. infrastructureFacilityCount: numberish(counts.raw.infrastructureFacilityCount),
  127. // 在线率:`value` 是 0–1 的小数(后端 BigDecimal),`state` 为 EMPTY 时表示分母为 0。
  128. onlineRate: numberish(onlineRate.raw.value),
  129. onlineCount: numberish(onlineRate.raw.numerator),
  130. onlineDenominator: numberish(onlineRate.raw.denominator),
  131. onlineState: onlineRate.optionalStr('state'),
  132. // 设备在线/离线/滞后/未知四态 + 口径分母(后端 `Status`)。
  133. deviceStatus: {
  134. online: numberish(status.raw.onlineCount),
  135. offline: numberish(status.raw.offlineCount),
  136. stale: numberish(status.raw.staleCount),
  137. unknownOrMissing: numberish(status.raw.unknownOrMissingCount),
  138. denominator: numberish(status.raw.denominator),
  139. },
  140. // 类型分布:后端已按 deviceCount 降序排好(服务里排序),本层不重排。
  141. typeDistribution: reader.optionalList('typeDistribution').map((item) => {
  142. const row = fieldReader(item, 'typeDistribution')
  143. const type = fieldReader(row.raw.deviceType, 'typeDistribution.deviceType')
  144. return {
  145. code: type.optionalStr('code'),
  146. name: type.optionalStr('name') || type.optionalStr('code'),
  147. industry: row.optionalStr('industry'),
  148. deviceCount: numberish(row.raw.deviceCount),
  149. onlineCount: numberish(row.raw.onlineCount),
  150. offlineCount: numberish(row.raw.offlineCount),
  151. staleCount: numberish(row.raw.staleCount),
  152. }
  153. }),
  154. // 票 62 追加需求:逐设备台账(行数恒等于 `equipmentCount`,与上面那个计数同源)。
  155. devices: reader.optionalList('devices').map(toLedgerDevice),
  156. // 新鲜度:本端点只有信封级(见文件头第 ① 条)。
  157. freshness: freshness.optionalStr('status'),
  158. freshUpdatedAt: freshness.optionalStr('updatedAt'),
  159. serverUpdatedAt: freshness.optionalStr('serverUpdatedAt'),
  160. selectedIndustry: mapFilter.industry || '',
  161. selectedDeviceType: mapFilter.deviceType || '',
  162. // 口径剔除(后端解释"为什么这些设备没算进来",界面照实说明)。
  163. excluded: {
  164. unknownTypeCount: numberish((reader.raw.excluded || {}).unknownTypeCount),
  165. typeKindMismatchCount: numberish((reader.raw.excluded || {}).typeKindMismatchCount),
  166. nonFormalIndustryCount: numberish((reader.raw.excluded || {}).nonFormalIndustryCount),
  167. },
  168. missing: reader.missing,
  169. }
  170. }
  171. /** 分布行(区域/行业/设备类型三族共用同一个 `StatusCounts` 结构)→ 领域行。 */
  172. function toStatusCounts(raw) {
  173. const reader = fieldReader(raw, 'statusCounts')
  174. return {
  175. alarm: numberish(reader.raw.alarm),
  176. warning: numberish(reader.raw.warning),
  177. workOrder: numberish(reader.raw.workOrder),
  178. normal: numberish(reader.raw.normal),
  179. offline: numberish(reader.raw.offline),
  180. empty: numberish(reader.raw.empty),
  181. }
  182. }
  183. /**
  184. * 监测分布的一个地图标记 → 领域行。
  185. *
  186. * **注意本端点不给设备编码列表**(那是 `/map-snapshot` 的 `CockpitMonitoringPointSummary.deviceCodes`),
  187. * 所以台账卡片的设备徽标只能逐点位拉详情(票 18 的 Q10 裁定),不由本层伪造。
  188. */
  189. function toDistributionMarker(raw, kind) {
  190. const reader = fieldReader(raw, kind)
  191. const type = fieldReader(reader.raw.deviceType, `${kind}.deviceType`)
  192. return {
  193. kind,
  194. code: reader.optionalStr('pointCode') || reader.optionalStr('deviceCode'),
  195. name: reader.optionalStr('pointName') || reader.optionalStr('deviceName') || reader.optionalStr('deviceCode'),
  196. district: normalizeDistrict(reader.raw.district),
  197. createdAt: reader.optionalStr('createdAt'),
  198. industry: reader.optionalStr('industry'),
  199. typeCode: type.optionalStr('code'),
  200. typeName: type.optionalStr('name'),
  201. status: reader.optionalStr('pointStatus'),
  202. statusReasons: reader.optionalList('statusReasons').map((item) => String(item)),
  203. longitude: numberish(reader.raw.longitude),
  204. latitude: numberish(reader.raw.latitude),
  205. missing: reader.missing,
  206. }
  207. }
  208. /**
  209. * 监测分布(`/monitoring/distribution`)→ 领域对象。
  210. * 票 18 验收第 2 条:覆盖情况、状态分布和地图筛选。
  211. * 验收第 4 条的台账**共用这一次取数**(Q4 裁定)——它读同一个响应的 `monitoringPoints` 与 `pagination`。
  212. *
  213. * 三处后端语义(逐行读服务确认,不是猜的):
  214. * · 三份分布与状态计数是**全量口径**(服务先把全部 marker 聚合完再切片分页),
  215. * 所以它们不随翻页跳动 —— 面板报的是全城分布,不是"这一页的分布";
  216. * · 分页窗口横跨「监测点 + 未关联设备」一条总序列(与 `map-snapshot` 同一套语义);
  217. * · `region` 空值在响应里归一为字面量 `未分区`(是真实取值,不是空值)。
  218. */
  219. export function toMonitoringDistribution(raw) {
  220. const reader = fieldReader(raw, 'monitoringDistribution')
  221. const pagination = fieldReader(reader.raw.pagination, 'monitoringDistribution.pagination')
  222. const freshness = fieldReader(reader.raw.freshness, 'monitoringDistribution.freshness')
  223. const mapFilter = reader.optionalObj('mapFilter') || {}
  224. const regionRows = reader.optionalList('districtDistribution').map((item) => {
  225. const row = fieldReader(item, 'districtDistribution')
  226. return {
  227. code: normalizeDistrict(row.raw.district),
  228. pointCount: numberish(row.raw.pointCount) || 0,
  229. deviceCount: numberish(row.raw.deviceCount) || 0,
  230. statusCounts: toStatusCounts(row.raw.statusCounts),
  231. }
  232. })
  233. const industryRows = reader.optionalList('industryDistribution').map((item) => {
  234. const row = fieldReader(item, 'industryDistribution')
  235. return {
  236. code: row.optionalStr('industry'),
  237. pointCount: numberish(row.raw.pointCount) || 0,
  238. deviceCount: numberish(row.raw.deviceCount) || 0,
  239. statusCounts: toStatusCounts(row.raw.statusCounts),
  240. }
  241. })
  242. const typeRows = reader.optionalList('deviceTypeDistribution').map((item) => {
  243. const row = fieldReader(item, 'deviceTypeDistribution')
  244. const type = fieldReader(row.raw.deviceType, 'deviceTypeDistribution.deviceType')
  245. return {
  246. code: type.optionalStr('code'),
  247. name: type.optionalStr('name') || type.optionalStr('code'),
  248. industry: row.optionalStr('industry'),
  249. pointCount: numberish(row.raw.pointCount) || 0,
  250. deviceCount: numberish(row.raw.deviceCount) || 0,
  251. statusCounts: toStatusCounts(row.raw.statusCounts),
  252. }
  253. })
  254. return {
  255. createdAt: reader.optionalStr('createdAt'),
  256. updatedAt: reader.optionalStr('updatedAt'),
  257. // 票 62:快照标记(执行票同期由后端补齐回显)。台账自动链第 2 页起必须原样回带它,
  258. // 否则后端 400;token 只认后端回显,不由前端挑时间戳去猜。
  259. snapshotAt: reader.optionalStr('snapshotAt'),
  260. freshUpdatedAt: freshness.optionalStr('updatedAt'),
  261. freshness: freshness.optionalStr('status'),
  262. regions: regionRows,
  263. industries: industryRows,
  264. deviceTypes: typeRows,
  265. // 状态分布:后端按字典顺序给全部六个状态(含计数为 0 的,界面据此不丢行)。
  266. pointStatuses: reader.optionalList('pointStatusDistribution').map((item) => {
  267. const row = fieldReader(item, 'pointStatusDistribution')
  268. return { status: row.optionalStr('status'), count: numberish(row.raw.count) || 0 }
  269. }),
  270. // 台账(Q4:与分布共用这次取数)
  271. points: reader.optionalList('monitoringPoints').map((item) => toDistributionMarker(item, 'monitoringPoint')),
  272. equipment: reader.optionalList('unassociatedEquipment').map((item) => toDistributionMarker(item, 'unassociatedEquipment')),
  273. pagination: {
  274. page: numberish(pagination.raw.page),
  275. pageSize: numberish(pagination.raw.pageSize),
  276. total: numberish(pagination.raw.total),
  277. totalPages: numberish(pagination.raw.totalPages),
  278. hasMore: pagination.bool('hasMore', false),
  279. },
  280. // 生效范围回显(Q3:筛选入口只有全局筛选条,面板靠这段回显,不自己存一份筛选状态)。
  281. selectedIndustry: mapFilter.industry || '',
  282. selectedDeviceType: mapFilter.deviceType || '',
  283. selectedPointStatus: mapFilter.pointStatus || '',
  284. selectedDistrict: normalizeDistrict(mapFilter.district),
  285. districtFilter: mapFilter.districtFilter || '',
  286. excluded: {
  287. unknownTypeCount: numberish((reader.raw.excluded || {}).unknownTypeCount),
  288. typeKindMismatchCount: numberish((reader.raw.excluded || {}).typeKindMismatchCount),
  289. nonFormalIndustryCount: numberish((reader.raw.excluded || {}).nonFormalIndustryCount),
  290. invalidCoordinateCount: numberish((reader.raw.excluded || {}).invalidCoordinateCount),
  291. },
  292. missing: reader.missing,
  293. }
  294. }
  295. /** 一个异常设备 → 领域行(`abnormalType` 与 `status` 后端取同值,只留一个)。 */
  296. function toAbnormalEquipment(raw) {
  297. const reader = fieldReader(raw, 'abnormalEquipment')
  298. const type = fieldReader(reader.raw.deviceType, 'abnormalEquipment.deviceType')
  299. return {
  300. // 设备编码(不是点位编码):本端点逐行给的是设备维度。
  301. code: reader.optionalStr('deviceCode'),
  302. name: reader.optionalStr('deviceName') || reader.optionalStr('deviceCode'),
  303. typeCode: type.optionalStr('code'),
  304. typeName: type.optionalStr('name'),
  305. industry: reader.optionalStr('industry'),
  306. district: normalizeDistrict(reader.raw.district),
  307. createdAt: reader.optionalStr('createdAt'),
  308. status: reader.optionalStr('status'),
  309. statusReasons: reader.optionalList('statusReasons').map((item) => String(item)),
  310. longitude: numberish(reader.raw.longitude),
  311. latitude: numberish(reader.raw.latitude),
  312. missing: reader.missing,
  313. }
  314. }
  315. /** 趋势点 → 领域行;桶标签由 `bucketLabel()` 给人话,原始值留在 `key` 里供断言。 */
  316. function toTrendPoint(raw) {
  317. const reader = fieldReader(raw, 'trendPoint')
  318. return { bucket: reader.optionalStr('bucketStart'), count: numberish(reader.raw.count) || 0 }
  319. }
  320. /**
  321. * ISO 时间戳 → 趋势桶的短标签(给人读;解析不了就回原串,不丢桶)。
  322. *
  323. * 后端桶是业务时区(Asia/Shanghai)的整点/整日 ISO 串,含偏移量。
  324. * 本函数**只做截断显示**,不改桶的粒度、不重采样、不补点 —— 那是后端语义。
  325. * @param {string} bucketStart ISO-8601 时间戳
  326. * @param {boolean} daily 桶是否为「日」粒度(7 天窗口用)
  327. */
  328. export function bucketLabel(bucketStart, daily = false) {
  329. const value = typeof bucketStart === 'string' ? bucketStart : ''
  330. const matched = /^(\d{4})-(\d{2})-(\d{2})T(\d{2}):(\d{2})/.exec(value)
  331. if (!matched) return value
  332. const [, , month, day, hour, minute] = matched
  333. if (daily) return `${Number(month)}/${Number(day)}`
  334. return `${hour}:${minute}`
  335. }
  336. /**
  337. * 运行概况(`/monitoring/situation`)→ 领域对象。
  338. * 票 18 验收第 3 条:事件趋势、离线设备和异常态势。
  339. *
  340. * 端点语义(逐行读服务确认):
  341. * · 不传 `startTime`/`endTime` 时后端默认**最近 24 小时**、按小时分桶,上限 31 天;
  342. * · **预警与报警两条趋势永不混合**(服务注释原句:warnings feed warningTrend only,
  343. * alarms feed alarmTrend only),所以本层给两块,不自己加总成一条;
  344. * · `abnormalEquipment` 是**异常设备清单**(服务定义:WARNING/ALARM/EXPIRED/OFFLINE 四态),
  345. * 离线设备是它的一个子集 —— 界面据此分开说"离线多少台"与"异常清单里有什么"。
  346. */
  347. export function toMonitoringSituation(raw) {
  348. const reader = fieldReader(raw, 'monitoringSituation')
  349. const pagination = fieldReader(reader.raw.pagination, 'monitoringSituation.pagination')
  350. const freshness = fieldReader(reader.raw.freshness, 'monitoringSituation.freshness')
  351. const range = reader.optionalObj('range') || {}
  352. // 指标状态分布:后端按固定字典顺序给六态(含 0),本层不重排、不丢行。
  353. // 票 92:「整个分布没取到」≠「某一桶是 0」——前者六档全缺(count 为 null,界面画占位符),
  354. // 后者该档照实计 0(六态全铺是既有口径)。混在一起就是「没数据」被画成「0 台设备」。
  355. const distributionProvided = Array.isArray(reader.raw.metricStatusDistribution)
  356. const metricStatusMap = new Map(reader.optionalList('metricStatusDistribution').map((item) => {
  357. const row = fieldReader(item, 'metricStatusDistribution')
  358. return [row.optionalStr('status'), numberish(row.raw.count) ?? 0]
  359. }))
  360. const metricStatuses = ['NORMAL', 'WARNING', 'ALARM', 'EXPIRED', 'OFFLINE', 'UNKNOWN']
  361. .map((status) => ({ status, count: distributionProvided ? (metricStatusMap.get(status) ?? 0) : null }))
  362. const coverage = reader.optionalList('industryCoverage').map((item) => {
  363. const row = fieldReader(item, 'industryCoverage')
  364. return {
  365. code: row.optionalStr('industry'),
  366. deviceCount: numberish(row.raw.deviceCount) || 0,
  367. abnormalCount: numberish(row.raw.abnormalCount) || 0,
  368. statusCounts: toStatusCounts(row.raw.statusCounts),
  369. }
  370. })
  371. return {
  372. createdAt: reader.optionalStr('createdAt'),
  373. updatedAt: reader.optionalStr('updatedAt'),
  374. freshUpdatedAt: freshness.optionalStr('updatedAt'),
  375. freshness: freshness.optionalStr('status'),
  376. // 窗口:后端回显实际生效区间(不传时是最近 24 小时,`type` 为 `TREND_WINDOW`)。
  377. rangeType: range.type || '',
  378. rangeStart: range.startTime || '',
  379. rangeEnd: range.endTime || '',
  380. metricStatuses,
  381. warningTrend: reader.optionalList('warningTrend').map(toTrendPoint),
  382. alarmTrend: reader.optionalList('alarmTrend').map(toTrendPoint),
  383. coverage,
  384. abnormalEquipment: reader.optionalList('abnormalEquipment').map(toAbnormalEquipment),
  385. pagination: {
  386. page: numberish(pagination.raw.page),
  387. pageSize: numberish(pagination.raw.pageSize),
  388. total: numberish(pagination.raw.total),
  389. totalPages: numberish(pagination.raw.totalPages),
  390. hasMore: pagination.bool('hasMore', false),
  391. },
  392. selectedIndustry: (reader.optionalObj('mapFilter') || {}).industry || '',
  393. selectedDeviceType: (reader.optionalObj('mapFilter') || {}).deviceType || '',
  394. excluded: {
  395. unknownTypeCount: numberish((reader.raw.excluded || {}).unknownTypeCount),
  396. typeKindMismatchCount: numberish((reader.raw.excluded || {}).typeKindMismatchCount),
  397. nonFormalIndustryCount: numberish((reader.raw.excluded || {}).nonFormalIndustryCount),
  398. invalidCoordinateCount: numberish((reader.raw.excluded || {}).invalidCoordinateCount),
  399. },
  400. missing: reader.missing,
  401. }
  402. }
  403. // ================================================================ 视图计划
  404. /**
  405. * 逐设备台账行(`/monitoring/overview` 的 `devices[]`)→ 领域行(票 62 追加需求)。
  406. * 与 `toAbnormalEquipment` 刻意分开:那张是**异常口径**(四态 + 阈值事由),
  407. * 这张是**设备台账**(全部智能设备 + 监测状态 + 所属点位),两者不可互换。
  408. */
  409. function toLedgerDevice(raw) {
  410. const reader = fieldReader(raw, 'overviewDevice')
  411. const type = fieldReader(reader.raw.deviceType, 'overviewDevice.deviceType')
  412. return {
  413. // 设备编码(不是点位编码):本清单是**设备**台账。
  414. code: reader.optionalStr('deviceCode'),
  415. name: reader.optionalStr('deviceName'),
  416. typeCode: type.optionalStr('code'),
  417. typeName: type.optionalStr('name'),
  418. industry: reader.optionalStr('industry'),
  419. // 监测状态(后端五态之一);缺失留空,视图层按「未发布」如实说(不猜成正常)。
  420. status: reader.optionalStr('monitoringState'),
  421. pointCode: reader.optionalStr('monitoringPointCode'),
  422. sampledAt: reader.optionalStr('sampledAt'),
  423. createdAt: reader.optionalStr('createdAt'),
  424. missing: reader.missing,
  425. }
  426. }
  427. /** 该状态在指标状态分布里的计数。 */
  428. function metricCount(statuses, code) {
  429. const found = (statuses || []).find((row) => row.status === code)
  430. return found ? found.count : null
  431. }
  432. /**
  433. * 设备状态四态 → 环形图行(票 39 第 7 条)。
  434. *
  435. * **只保留读得出的计数**:`numberish` 认不出回 `null`(字段缺失/载荷形状不对),
  436. * 而 `donutBlock` 内部按 `Number(count) || 0` 建扇区与图例——把 `null` 交出去就是
  437. * 画一个「在线 0 台」的假读数(票 27 修的是同一类缺陷:`undefined` 冒充有效值)。
  438. * 真实的 `0` 是有效读数,照旧保留(图例行在、不产扇区)。
  439. * 四态一个都没读出来时 `rows` 为空、`total=0`,渲染层走既有空态(`data-donut-empty`),
  440. * **不会**画一个「合计 0」的空环——「后端没给状态」与「状态全是 0」在界面上分得开。
  441. * 顺序固定为在线→离线→滞后→未知,**不套 `sortByCountDesc`**(四态是语义字典序,
  442. * 非排名类别;同异常桶 t44 的 FIXED 立场)。
  443. */
  444. function deviceStatusRows(deviceStatus) {
  445. const source = deviceStatus || {}
  446. return [
  447. { code: 'online', label: '在线', count: numberish(source.online) },
  448. { code: 'offline', label: '离线', count: numberish(source.offline) },
  449. { code: 'stale', label: '数据滞后', count: numberish(source.stale) },
  450. { code: 'unknownOrMissing', label: '未知/缺失', count: numberish(source.unknownOrMissing) },
  451. ].filter((row) => row.count !== null)
  452. }
  453. /* 票 92:旧「数据入库时间」KPI(createdAtKpi)已随概览/运行概况的 KPI 改版退役 —— 两处消费点
  454. 都不再展示时间类读数(票面 6 张清单里没有时间卡),按「无消费点不提交」纪律删除。 */
  455. /**
  456. * 监测概览面板视图。
  457. * 验收四项:监测点/设备规模、在线率、类型分布、最近采集时间。
  458. */
  459. export function monitoringOverviewPanel(data, section) {
  460. const current = data || {}
  461. const deviceStatus = current.deviceStatus || {}
  462. // 在线率:分母为 0 时后端回 `state: EMPTY` + `value: 0`,那个 0 是**没有分母时的占位**,
  463. // 不是"在线率确实是 0"——照它画成 0.0% 就是票 16 明令禁止的虚假零值。所以先按 state 收口。
  464. const rateAvailable = current.onlineState !== 'EMPTY' && current.onlineDenominator !== null && current.onlineDenominator > 0
  465. const rate = rateAvailable ? current.onlineRate : null
  466. const blocks = [
  467. kpiBlock([
  468. { key: 'monitoringPointCount', label: '监测点', value: valueText(current.monitoringPointCount), unit: '个' },
  469. { key: 'equipmentCount', label: '监测设备', value: valueText(current.equipmentCount), unit: '台' },
  470. {
  471. key: 'onlineRate',
  472. label: '在线率',
  473. value: ratioText(rate),
  474. // 在线率的分母是后端给的「已解析设备数」,把分子分母摊开说,免得读者自己猜口径;
  475. // 后端明说没有分母(`EMPTY`)时如实说"没有可算的设备",不算出一个 0。
  476. hint: rateAvailable
  477. ? `在线 ${valueText(current.onlineCount)} / 设备 ${valueText(current.onlineDenominator)}`
  478. : '当前范围内没有可参与计算的设备,在线率不适用',
  479. },
  480. // 离线设备:取**本端点自己的设备状态**(status.offlineCount),与运行概况那张卡
  481. // (来自 /monitoring/situation 的**指标**状态 OFFLINE 档)不是同一口径——
  482. // 同名词不同义,所以各自卡上把口径说清(维护者 2026-10-27 裁定:第 4 张卡取离线设备)。
  483. {
  484. key: 'offline',
  485. label: '离线设备',
  486. value: valueText(deviceStatus.offline),
  487. unit: '台',
  488. hint: '按设备在线状态统计(本端点口径)',
  489. },
  490. ], { layout: 'two-by-two' }),
  491. // 票 39(第 7 条):设备状态由纯键值行改**环形图**(复用既有块,不新造渲染分支)。
  492. // · 选型按仓库自己记录的图表选型表(`donutBlock` 头注):「类别占比、类别少」
  493. // → 环形图;四态=4 个互斥类别,且本面板已有一条横条(类型分布)、维护者
  494. // 2026-10-13 明说「条形图太多易疲劳」——堆叠条仍是一条横条,形态不解疲劳。
  495. // · **四态照实**:在线/离线/数据滞后/未知缺失各一行图例带读数,不折算成
  496. // 「故障」(后端逐设备走 ONLINE/OFFLINE/STALE 判定链,其余落 unknownOrMissing,
  497. // 四桶互斥且穷尽——`CockpitMonitoringOverviewService` 第 165–175 行,服务逐行读过)。
  498. // · 0 计数态**保留图例行不画扇区**(`donutBlock` 既有语义):「确实没有离线设备」
  499. // 与「没这项数据」在图上分得开,读数为 0 是真实值。
  500. // · 「在线率分母」不再是独立一行:环形合计含「未知/缺失」,而后端在线率
  501. // 分母=在线+离线+滞后(**不含**未知/缺失,服务第 185 行)。分母摊在 KPI 的
  502. // hint(`在线 X / 设备 Y`)上与在线率同口径;画进图例就是制造第二个口径的数。
  503. // · 缺值仍是占位符纪律:四态计数经 `numberish` 认不出回 null → 该行**整行不出**
  504. // (见 `deviceStatusRows`),绝不把 null 交给 `donutBlock` 补成假 0(票 27 同类)。
  505. donutBlock('设备状态分布(按设备数)', deviceStatusRows(deviceStatus), { layout: 'compact' }),
  506. barsBlock(
  507. '设备类型分布',
  508. // 票 37:按设备数**从多到少**降序;并列时保持后端给的次序(后端已排好则是恒等变换)。
  509. sortByCountDesc(
  510. (current.typeDistribution || []).map((row) => ({
  511. code: row.code,
  512. label: row.name || codeText(row.code),
  513. count: row.deviceCount || 0,
  514. // 当前生效的类型行:渲染层画选中态,用户据此知道"再点一下就取消"。
  515. selected: Boolean(row.code) && row.code === current.selectedDeviceType,
  516. })),
  517. (row) => row.count,
  518. ),
  519. // 行可点 → 写全局类型筛选(复用票 20 立的 `panel-action` 接缝)。
  520. // 只带得出后端类型码的行才可点:`code` 为空时 `barsBlock` 不给 `actionKey`,
  521. // 那一行在渲染层就不是按钮 —— 不拿展示名冒充筛选码去换后端 400。
  522. { action: 'deviceType', variant: 'rank' },
  523. ),
  524. supplementalBlock(donutBlock('各类型在线设备', (current.typeDistribution || [])
  525. .filter((row) => numberish(row.onlineCount) !== null)
  526. .map((row) => ({ code: row.code, label: row.name || codeText(row.code), count: row.onlineCount })), { layout: 'compact' })),
  527. supplementalBlock(barsBlock('各类型离线设备', sortByCountDesc((current.typeDistribution || [])
  528. .filter((row) => numberish(row.offlineCount) !== null)
  529. .map((row) => ({ code: row.code, label: row.name || codeText(row.code), count: row.offlineCount })), (row) => row.count), { variant: 'rank' })),
  530. ]
  531. return {
  532. name: 'monitoringOverview',
  533. label: '监测概览',
  534. section,
  535. hasContent: sectionHasContent(section),
  536. blocks,
  537. // 概览是聚合口径(后端只给分类型计数,不给逐点位坐标),没有可定位对象。
  538. locate: [],
  539. locateNote: '监测概览是分类型聚合口径(后端不返回逐点位坐标),本面板没有可定位对象',
  540. // 入库时间与采样时间的区别如实说明(文件头第 ① 条 + `TIME_LABELS`)。
  541. gap: METRIC_FRESHNESS_GAP,
  542. industryNote: current.selectedIndustry ? `当前行业:${industryLabel(current.selectedIndustry) || current.selectedIndustry}` : '当前行业:全部',
  543. // 票 37:生效类型必须看得见 —— 否则读者只会看到"类型分布少了几行",
  544. // 不知道该条件从哪来、也不知道怎么撤(同一条行再点一次)。
  545. typeNote: current.selectedDeviceType
  546. ? `当前类型:${deviceTypeLabel(current.typeDistribution, current.selectedDeviceType)}(再点同一行取消)`
  547. : '当前类型:全部',
  548. missing: panelMissingNote(current),
  549. placeholder: sectionPlaceholder(section),
  550. }
  551. }
  552. /**
  553. * 类型码 → 展示名(票 37)。名字优先取自**本端点返回的类型分布**(同一份数据里带着 name,
  554. * 不另建一份类型词典);分布里没有该码时用 `codeText` 的既有口径——**数据值照原样带出**,
  555. * 因为空白会被读成"没有数据",而"没见过的类型码"是真实数据。
  556. * @param {Array} rows 类型分布行(含 `code`/`name`)
  557. * @param {string} code 生效的类型码
  558. */
  559. function deviceTypeLabel(rows, code) {
  560. if (!code) return ''
  561. const found = (rows || []).find((row) => row.code === code)
  562. return (found && found.name) || codeText(code)
  563. }
  564. /**
  565. * 监测分布面板视图。
  566. * 验收三项:覆盖情况、状态分布、地图筛选(本票的筛选入口是全局筛选条,面板只回显生效范围)。
  567. *
  568. * **票 14 改写**:状态统计从「可点状态条」改为**饼图**(决策 02 的 Q12/Q19)——
  569. * · 数据源是**全局未筛分布**(`extra.statusDistribution`,与地图顶部状态栏共用同一份,
  570. * 来自 `map-snapshot` 的八桶全局计数;不是本端点随筛选变的那份);
  571. * · 饼图只**高亮当前选中**,不再是筛选入口——全局条件只有一个可操作面(顶部状态栏),
  572. * 面板自带筛选正是票 07 点名的「入口分散且重复」缺陷;
  573. * · 全局分布未取到时如实说明(不伪造全零饼图)。
  574. *
  575. * @param {object} data `toMonitoringDistribution()` 的结果
  576. * @param {object} section 分区
  577. * @param {object} [extra] `{ statusDistribution, selectedStatuses }`(外壳给的共用数据与当前选中)
  578. */
  579. export function monitoringDistributionPanel(data, section, extra = {}) {
  580. const current = data || {}
  581. // 覆盖情况(Q11 裁定):用**本端点自己的**区域/行业/设备类型分布 ——
  582. // 票 24 指向的 `overview/monitoring` 的 `formalScope` 不在本端点上,拿不到也不去拉。
  583. // 票 37 走查扩展(维护者 2026-10-14):三块都是排名类别,统一按计数降序(并列保序);
  584. // 环形图(行业)与条形(片区/类型)同口径。
  585. const regionRows = sortByCountDesc(
  586. (current.regions || []).map((row) => ({
  587. code: row.code,
  588. label: districtLabel(row.code),
  589. count: row.pointCount || 0,
  590. // 每一行带上设备数与状态明细,但主条长按**点位数**归一(图与数同源:口径写在标题里)。
  591. hint: `设备 ${valueText(row.deviceCount)}`,
  592. })),
  593. (row) => row.count,
  594. )
  595. const industryRows = sortByCountDesc(
  596. (current.industries || []).map((row) => ({
  597. code: row.code,
  598. label: industryLabel(row.code) || regionText(row.code),
  599. count: row.pointCount || 0,
  600. hint: `设备 ${valueText(row.deviceCount)}`,
  601. })),
  602. (row) => row.count,
  603. )
  604. const typeRows = sortByCountDesc(
  605. (current.deviceTypes || []).map((row) => ({
  606. code: row.code || row.name,
  607. label: row.name || codeText(row.code),
  608. count: row.pointCount || 0,
  609. hint: `设备 ${valueText(row.deviceCount)}`,
  610. })),
  611. (row) => row.count,
  612. )
  613. // 票 14:饼图切片(几何与高亮判定都在 `domain/statusPie.js`,本层只搬运)。
  614. const pie = planStatusPie({
  615. distribution: extra.statusDistribution || null,
  616. rows: legendVisuals(),
  617. selected: Array.isArray(extra.selectedStatuses) ? extra.selectedStatuses : [],
  618. })
  619. const blocks = [
  620. // 票 39(第 8 条):每块标题 = **「分节 · 维度(条长口径)」**。
  621. // 维护者反馈第 8 条的原话是「图与数据指代对象不明确」——同一个面板里既有按
  622. // **点位数**排的覆盖分布、又有**全局未筛**的状态分布,三种口径混在一屏而不写在
  623. // 标题上,读者无从判断每张图数的是什么、数的是点位还是设备。
  624. // 分节词(覆盖情况 / 状态分布 / 口径)让三族各自成节,括号里的口径说明
  625. // 「这条长度量的是什么」;悬停行的 hint 仍给设备数(图与数同源,不另算一份)。
  626. // 条形/环形的分工沿用 2026-10-13 的既有结论(行业=类别少→环形;
  627. // 片区/类型=多类别排名→横条),本票不动图形形态,只把指代写清楚。
  628. donutBlock('覆盖情况 · 行业(按点位数)', industryRows, { layout: 'compact' }),
  629. barsBlock('覆盖情况 · 片区(按点位数)', regionRows, { variant: 'rank' }),
  630. barsBlock('覆盖情况 · 设备类型(按点位数)', typeRows, { variant: 'rank' }),
  631. // 维护者 2026-10-29:类型构成用堆叠条(占比一眼看完),与上面的排名称互补。
  632. stackedBlock('设备类型构成(按点位数)', typeRows),
  633. ...(extra.statusDistribution && extra.statusDistribution.available
  634. ? [barsBlock('状态分布 · 异常监测点(全局未筛)', abnormalCountRows(
  635. Object.entries(extra.statusDistribution.counts || {}).map(([status, count]) => ({ status, count })), 'point'))]
  636. : []),
  637. // 状态分布饼图:消费全局未筛分布并高亮当前选中;**不可点**(筛选入口只在顶部状态栏)。
  638. {
  639. kind: 'pie',
  640. label: '状态分布 · 点位状态(全局未筛)',
  641. ready: pie.ready,
  642. hasSelection: pie.hasSelection,
  643. total: pie.total,
  644. slices: pie.slices,
  645. rows: pie.rows,
  646. note: pie.ready ? '' : STATUS_DISTRIBUTION_UNPUBLISHED,
  647. },
  648. rowsBlock('口径 · 生效范围与总数', [
  649. { key: 'pointTotal', label: '监测点总数', value: valueText(current.pagination && current.pagination.total) },
  650. { key: 'industry', label: '生效行业', value: current.selectedIndustry ? industryLabel(current.selectedIndustry) || current.selectedIndustry : '全部' },
  651. { key: 'district', label: '生效片区', value: districtFilterLabel({ district: current.selectedDistrict, districtFilter: current.districtFilter }) },
  652. // 票 37:类型是全局筛选条件之一,生效范围必须与本模式其它条件一样看得见
  653. // (否则读者只看到"类型分布少了几行",不知道条件从哪来、怎么撤)。
  654. { key: 'deviceType', label: '生效类型', value: current.selectedDeviceType ? deviceTypeLabel(current.deviceTypes, current.selectedDeviceType) : '全部' },
  655. { key: 'createdAt', label: TIME_LABELS.latestIngested, value: valueText(current.createdAt) },
  656. // 票 14:状态多值化——回显是逗号串,逐桶翻人话;空 = 全部。
  657. {
  658. key: 'pointStatus',
  659. label: '生效状态',
  660. value: current.selectedPointStatus
  661. ? String(current.selectedPointStatus)
  662. .split(',')
  663. .map((code) => POINT_STATUS_FILTER_LABELS[code] || code)
  664. .filter(Boolean)
  665. .join('、')
  666. : '全部',
  667. },
  668. // 坐标准入被拦下的对象数:分布口径只统计可上图对象,这个数解释差值(票 07 的口径)。
  669. { key: 'invalidCoordinate', label: '坐标未通过校验', value: valueText(current.excluded && current.excluded.invalidCoordinateCount) },
  670. ]),
  671. ]
  672. return {
  673. name: 'monitoringDistribution',
  674. label: '监测分布',
  675. section,
  676. hasContent: sectionHasContent(section),
  677. blocks,
  678. locate: [],
  679. locateNote: '监测分布是聚合分布口径(后端不返回逐点位坐标),本面板没有可定位对象',
  680. // 范围筛选落点说明保留;「状态筛选不作用到一张图」的缺口说明已随票 14 的契约修订删除。
  681. gap: REGION_SCOPE_NOTE,
  682. missing: panelMissingNote(current),
  683. placeholder: sectionPlaceholder(section),
  684. }
  685. }
  686. /**
  687. * 运行概况面板视图。
  688. * 验收三项:事件趋势、离线设备、异常态势。
  689. *
  690. * **票 62 追加需求(2026-10-22 维护者)**:本面板不再展示「异常设备清单」,改展示
  691. * **设备台账**——按当前数据应列出全部 9 台监测设备,而不是只列异常四态的 8 台。
  692. * 台账数据来自 `/monitoring/overview` 的 `devices[]`(与那边的 `counts.equipmentCount`
  693. * 同源同口径),由外壳作为 `extra.devices` 搬进来;本面板自己的分区
  694. * (`/monitoring/situation`)继续供趋势、指标状态与异常统计——**异常口径不丢,只是
  695. * 不再用它当台账**。两者不是一回事:异常清单只装 WARNING/ALARM/EXPIRED/OFFLINE 四态设备。
  696. * @param {object} data `toMonitoringSituation()` 的结果
  697. * @param {object} section 分区
  698. * @param {object} [extra] `{ devices }`(`toMonitoringOverview().devices`,外壳给)
  699. */
  700. /**
  701. * 预警 / 报警两条趋势合并成**同轴双线**(维护者 2026-10-29)。
  702. *
  703. * 为什么要在这里合并:两个端点序列的桶起点可能不完全一致(一侧少一个桶、或粒度不同),
  704. * 直接按数组下标配对会在图上画出错位的对照 —— 这是**假数据**,不是排版问题。
  705. * 所以按桶键求并集、缺失一侧记 null(**不补 0**:没这个桶 ≠ 这个桶是 0),
  706. * 序列里出现 null 时该点不画点、不计入折线(渲染层按 filter(Boolean) 处理)。
  707. *
  708. * @param {Array} warningRows `warningTrend` 行(`bucket`/`count`)
  709. * @param {Array} alarmRows `alarmTrend` 行
  710. * @returns {{points: Array, warningCounts: Array, alarmCounts: Array}}
  711. */
  712. export function mergeTrendSeries(warningRows, alarmRows) {
  713. const warning = Array.isArray(warningRows) ? warningRows : []
  714. const alarm = Array.isArray(alarmRows) ? alarmRows : []
  715. const buckets = []
  716. const seen = new Set()
  717. for (const row of [...warning, ...alarm]) {
  718. const key = String((row && row.bucket) || '')
  719. if (!key || seen.has(key)) continue
  720. seen.add(key)
  721. buckets.push(key)
  722. }
  723. buckets.sort()
  724. const index = (rows) => {
  725. const map = new Map()
  726. for (const row of rows) map.set(String((row && row.bucket) || ''), numberish(row && row.count))
  727. return map
  728. }
  729. const warningMap = index(warning)
  730. const alarmMap = index(alarm)
  731. return {
  732. points: buckets.map((bucket) => ({ bucket })),
  733. warningCounts: buckets.map((bucket) => warningMap.get(bucket) ?? null),
  734. alarmCounts: buckets.map((bucket) => alarmMap.get(bucket) ?? null),
  735. }
  736. }
  737. export function operationOverviewPanel(data, section, extra = {}) {
  738. const current = data || {}
  739. // 7 天窗口的桶是「日」粒度,标签按日期显示(只影响显示,不改桶)。
  740. const daily = isDailyWindow(current)
  741. const trendPoints = (list) =>
  742. (list || []).map((row) => ({
  743. key: row.bucket,
  744. label: bucketLabel(row.bucket, daily),
  745. count: row.count,
  746. }))
  747. // 维护者 2026-10-29:两条趋势合成一张双线图(按桶键求并集,缺失不补 0)。
  748. const mergedTrend = mergeTrendSeries(current.warningTrend, current.alarmTrend)
  749. const offlineCount = metricCount(current.metricStatuses, 'OFFLINE')
  750. // 离线设备:从异常清单里挑出离线的那一档。**只挑,不推断**——状态来自后端 `status`。
  751. // 票 62:这段只服务 `offlineNote`(顶部摘要那行),**不再画成清单**。
  752. const offlineDevices = (current.abnormalEquipment || []).filter((item) => item.status === 'OFFLINE')
  753. // 票 62:设备台账数据源(与 `counts.equipmentCount` 同源,行数恒等于它)。
  754. const devices = Array.isArray(extra.devices) ? extra.devices : []
  755. // 票 92(维护者 2026-10-27):KPI 改为 6 张、3×2 排版。全部取自本面板自己的分区
  756. // `/monitoring/situation`(不跨面板取数),数值真实且分区独立:
  757. // · 设备总数 = 六档指标状态计数之和(后端按设备粒度给,总和 = 设备台数);
  758. // · 在线设备 = 正常 + 预警 + 报警(正在上报的设备;与监测概览设备轴「在线」口径一致,已实测比对);
  759. // · 离线设备 = 指标状态 OFFLINE 档(沿用既有取数);
  760. // · 预警/报警设备 = WARNING / ALARM 档(沿用既有取数,改名);
  761. // · 总异常设备 = 异常设备清单总数(pagination.total = 预警+报警+离线+过期)。
  762. // 旧「数据入库时间」卡退役(不在 6 张清单里)。
  763. // 分布没取到时(六档 count 全 null)→ 总数/在线/离线/预警/报警全走占位符,绝不画 0(票 16)。
  764. const distributionProvided = (current.metricStatuses || []).some((row) => row.count !== null)
  765. const deviceTotal = distributionProvided
  766. ? current.metricStatuses.reduce((sum, row) => sum + (row.count || 0), 0)
  767. : null
  768. const onlineCount = distributionProvided
  769. ? metricCount(current.metricStatuses, 'NORMAL')
  770. + metricCount(current.metricStatuses, 'WARNING')
  771. + metricCount(current.metricStatuses, 'ALARM')
  772. : null
  773. const blocks = [
  774. kpiBlock([
  775. { key: 'deviceCount', label: '设备总数', value: valueText(deviceTotal), unit: '台', hint: '按指标状态统计(六档之和)' },
  776. { key: 'online', label: '在线设备', value: valueText(onlineCount), unit: '台', hint: '正常 + 预警 + 报警的设备(正在上报)' },
  777. { key: 'offlineCount', label: '离线设备', value: valueText(offlineCount), unit: '台' },
  778. { key: 'warningCount', label: '预警设备', value: valueText(metricCount(current.metricStatuses, 'WARNING')), unit: '台' },
  779. { key: 'alarmCount', label: '报警设备', value: valueText(metricCount(current.metricStatuses, 'ALARM')), unit: '台' },
  780. { key: 'abnormalCount', label: '总异常设备', value: valueText(current.pagination && current.pagination.total), unit: '台', hint: '预警 + 报警 + 离线 + 过期' },
  781. ], { layout: 'three', emphasis: true }),
  782. barsBlock('设备/指标异常统计', abnormalCountRows(current.metricStatuses, 'metric'), { variant: 'rank' }),
  783. // 维护者 2026-10-29:预警与报警合成**一张双线折线**(同一时间窗、同一量纲),并给块顶留出
  784. // 呼吸空间(compact 版式),避免与块标题/点顶数值重叠。两条线仍是两个独立数据源,
  785. // 只共享坐标轴与图例 —— 不改变任何统计口径。
  786. trendBlock('预警与报警趋势', mergedTrend.points.map((row) => ({
  787. key: row.bucket,
  788. label: bucketLabel(row.bucket, daily),
  789. count: 0,
  790. hint: row.bucket,
  791. })), {
  792. chart: 'line',
  793. compact: true,
  794. aside: '双线对照:预警 / 报警',
  795. series: [
  796. { key: 'warning', label: '预警', tone: 'lv2', counts: mergedTrend.warningCounts },
  797. { key: 'alarm', label: '报警', tone: 'lv1', counts: mergedTrend.alarmCounts },
  798. ],
  799. }),
  800. barsBlock(
  801. '异常态势 · 指标状态分布',
  802. (current.metricStatuses || []).map((row) => ({
  803. code: row.status,
  804. label: metricStatusText(row.status),
  805. count: row.count || 0,
  806. })),
  807. ),
  808. deviceLedgerBlock(devices),
  809. ]
  810. return {
  811. name: 'operationOverview',
  812. label: '运行概况',
  813. section,
  814. hasContent: sectionHasContent(section),
  815. blocks,
  816. // 维护者 2026-10-29:定位入口与监测点台账对齐 —— **整卡点击**即定位并进详情,
  817. // 不再额外画一排「定位」按钮(两条路径会让同一件事有两种手感)。
  818. // 三种"点不动"仍由 `domain/mapLocate.js` 分开,由 locateCode 如实反馈。
  819. locate: [],
  820. locateNote: '点击设备卡片即定位并进入设备详情(与监测点台账同一交互);设备坐标由一张图回联,未加载到的设备不下发飞行',
  821. // 窗口口径:后端回显的实际生效区间(本面板的 24 小时 / 7 天切换写在界面上,见票面 Q8)。
  822. rangeNote: current.rangeStart && current.rangeEnd ? `统计窗口:${current.rangeStart} 至 ${current.rangeEnd}` : '',
  823. offlineNote: offlineDevices.length
  824. ? `离线 ${offlineDevices.length} 台:${offlineDevices.map((item) => item.name).join('、')}`
  825. : '当前窗口没有离线设备',
  826. missing: panelMissingNote(current),
  827. placeholder: sectionPlaceholder(section),
  828. }
  829. }
  830. /** 7 天窗口的桶按日显示(判据是后端回显的区间长度,不是前端自己记的开关)。 */
  831. function isDailyWindow(current) {
  832. const start = Date.parse((current && current.rangeStart) || '')
  833. const end = Date.parse((current && current.rangeEnd) || '')
  834. if (!Number.isFinite(start) || !Number.isFinite(end)) return false
  835. return end - start > 36 * 3600 * 1000
  836. }
  837. /**
  838. * 异常状态 → 色键(报警最重、其次预警、离线与过期走中性)。
  839. * 票 62:异常清单已从运行概况撤下(改展示设备台账),本函数仍服务于
  840. * `offlineNote` 的语义与 `toAbnormalEquipment` 的既有消费点,故保留。
  841. */
  842. function abnormalTone(status) {
  843. if (status === 'ALARM') return 'lv1'
  844. if (status === 'WARNING') return 'lv2'
  845. if (status === 'OFFLINE' || status === 'EXPIRED') return 'neutral'
  846. return 'neutral'
  847. }
  848. /** 设备台账行的展示名:有名称用名称,没名称用编码(**不编造**,也不留空行)。 */
  849. function deviceLabel(item) {
  850. return (item && (item.name || item.code)) || DETAIL_PLACEHOLDER
  851. }
  852. /**
  853. * 设备监测状态 → 色键(票 62)。按语义分档,与 `abnormalTone` 同一套色;
  854. * 在线/正常走成功色,滞后走关注色,离线/未发布走中性(**不把"没状态"画成正常**)。
  855. */
  856. function deviceStateTone(status) {
  857. if (status === 'ALARM') return 'lv1'
  858. if (status === 'WARNING' || status === 'STALE') return 'lv2'
  859. if (status === 'ONLINE' || status === 'NORMAL') return 'lv4'
  860. return 'neutral'
  861. }
  862. /**
  863. * 设备监测状态码 → 人话(票 62)。
  864. * `ONLINE` 是设备轴上的补充取值(指标状态字典里没有它);其余复用六态字典,
  865. * 认不出的回原码、空值如实说「状态未发布」——不猜成正常。
  866. */
  867. function deviceStateText(status) {
  868. const value = typeof status === 'string' ? status.trim() : ''
  869. if (!value) return '状态未发布'
  870. if (value === 'ONLINE') return '在线'
  871. return metricStatusText(value)
  872. }
  873. /**
  874. * 运行概况的**设备台账**清单块(票 62 追加需求,2026-10-22 维护者)。
  875. *
  876. * 与原先「异常设备清单」是**结构性差别**,不只是换个标题:
  877. * · **数据源**:`/monitoring/overview` 的 `devices[]`(全部智能设备,行数 ≡ `counts.equipmentCount`),
  878. * 不是 `/monitoring/situation` 的 `abnormalEquipment[]`(只装 WARNING/ALARM/EXPIRED/OFFLINE);
  879. * · **每行内容**:名称(主键展示)+ 设备编码、类型、行业、监测状态、所属点位、数据入库时间;
  880. * · **总数口径**:读设备台账行数本身(= `equipmentCount`),页脚明说「共 N 台监测设备」;
  881. * · 仍是前端集合分页 10/页(规范三分法),翻页**零请求**。
  882. * @param {Array} devices 领域设备行(`toMonitoringOverview().devices`)
  883. */
  884. function deviceLedgerBlock(devices) {
  885. const rows = (devices || []).map((item) => ({
  886. key: item.code || `${item.typeCode}|${item.pointCode}`,
  887. title: deviceLabel(item),
  888. identityKind: CARD_ACTION.DEVICE,
  889. identityCode: item.code,
  890. identityReason: item.code ? '' : '缺少设备编码,无法展开',
  891. dataTime: valueText(item.createdAt),
  892. // 标签由 domain 给(`TIME_LABELS` 单点词表):渲染层不认「时间」这个词,更不自己拼。
  893. dataTimeLabel: TIME_LABELS.ingested,
  894. tone: deviceStateTone(item.status),
  895. // 色键必带文字(票 06):状态词认不出也回原码,不留空标签、不猜成正常。
  896. toneLabel: deviceStateText(item.status),
  897. meta: [
  898. item.code,
  899. item.typeName,
  900. industryLabel(item.industry) || codeText(item.industry),
  901. item.pointCode ? `点位 ${item.pointCode}` : '未关联点位',
  902. ].filter(Boolean),
  903. // 维护者 2026-10-29:设备卡**不再单独画「定位」小按钮**,改为与监测点台账一致 ——
  904. // 整卡点击 = 定位 + 进详情(一个动作,不是"先点小按钮定位、再点卡进详情"两条路径)。
  905. // 定位本身仍走既有设备维度接缝 `monitoringStore.locateCode`(判定→相机→详情),
  906. // 三种"点不动"由 `domain/mapLocate.js` 分开,不在这里另造一套。
  907. points: [],
  908. }))
  909. return listBlock('设备台账', rows, '当前范围内没有监测设备', {
  910. paginate: true,
  911. // 页码归属键:只看设备全集的身份(行数)——换筛选导致集合变化时自然复位。
  912. // 标量键,不接受对象身份(票 43 教训:视图计划每次重算都是新对象)。
  913. pageScope: `devices|${rows.length}`,
  914. pageNote: rows.length ? `共 ${rows.length} 台监测设备(当前筛选范围)` : '',
  915. })
  916. }
  917. /**
  918. * 监测点台账面板视图。
  919. * 验收第 4 条:以滚动卡片列出当前行业筛选内的监测点;点击卡片走与地图相同的两级详情。
  920. *
  921. * **票 62 改写(批次四)**:数据不再取「分布这一次响应的第 1 页切片」,而是 store 的
  922. * **自动渐进装载链**(`domain/ledgerLoader.js`)已经装好的**完整序列**;
  923. * · 装载与一张图点位数据同款(条件变化 → 新快照 → 自动连翻到 settled);
  924. * · 界面只对**已装载集合**做统一页码分页(10/页、页码直达),翻页是**纯视图动作**;
  925. * · 「加载下一页监测点」按钮与 `ledger-more` 接缝**退役**(自动链自己会翻完);
  926. * · 页脚如实给「已装载 M · 共 N 条(含未关联设备)」+ 装载中/失败标注。
  927. *
  928. * **设备徽标仍走 N+1**(Q10/Q14 不变):本端点不给设备编码,徽标由 store 逐点位取。
  929. * 票 62 的改进是**只为当前页窗口内的卡片补拉**——窗口化之后一屏最多 10 张卡,
  930. * 不再"一页 500 张卡进视口就打出 500 个请求"。
  931. * @param {object} data `toMonitoringDistribution()`/装载链条目(读 `points`/`equipment`/`pagination`)
  932. * @param {object} section 分区
  933. * @param {object} [badges] `{ [pointCode]: { state, total, alarm, warning, offline } }`(store 给)
  934. */
  935. export function monitoringPointLedgerPanel(data, section, badges = {}) {
  936. const current = data || {}
  937. const pagination = current.pagination || {}
  938. // 分母认不出就**整句不出**(作者本意),且绝不用 `undefined` 冒充读数:
  939. // `data` 为 null(真实空态/失败态,见 `sectionFromResult()` 的 `isEmpty` 分支)时
  940. // `pagination` 是 `{}`,`total` 是 `undefined` 而不是 `null` —— 只判 `=== null` 会把
  941. // 它漏进模板串。`numberish()` 是仓库里「数字/数字串→数字,认不出回 null」的唯一口径。
  942. const total = numberish(pagination.total)
  943. const cards = (current.points || []).map((point) => {
  944. const visual = visualForStatus(point.status)
  945. const badge = badges[point.code] || null
  946. return {
  947. key: point.code,
  948. code: point.code,
  949. name: point.name,
  950. identityKind: CARD_ACTION.POINT,
  951. identityCode: point.code,
  952. identityReason: point.code ? '' : '缺少点位编码,无法展开',
  953. dataTime: valueText(point.createdAt),
  954. // 同上:标签由 domain 给,渲染层只拼值。
  955. dataTimeLabel: TIME_LABELS.ingested,
  956. // 状态词与色键来自票 09 的唯一一张表(认不出的状态落「状态未发布」,不猜成正常)。
  957. status: visual.key,
  958. tone: visual.tone,
  959. shape: visual.shape,
  960. statusLabel: visual.label,
  961. meta: [
  962. industryLabel(point.industry) || codeText(point.industry),
  963. districtLabel(point.district),
  964. point.typeName,
  965. ].filter(Boolean),
  966. reason: (point.statusReasons || []).join(';'),
  967. // 徽标:还没取到就**不给 0**(0 是"确实没有设备",与"还没问过"是两件事)。
  968. badge: badge && badge.state === 'success'
  969. ? {
  970. total: valueText(badge.total),
  971. alarm: valueText(badge.alarm),
  972. warning: valueText(badge.warning),
  973. offline: valueText(badge.offline),
  974. }
  975. : null,
  976. badgePending: !badge || badge.state === 'pending',
  977. }
  978. })
  979. // 票 62:页脚口径由 store 的装载链给(它才知道「已装载多少 / 总数多少 / 还在不在装」);
  980. // 装载链没给(走查注入的裸载荷)时退回既有措辞,保持 t27 的防回归判据不变。
  981. const pageNote = typeof current.ledgerNote === 'string' && current.ledgerNote
  982. ? current.ledgerNote
  983. : total === null
  984. ? ''
  985. : `已列出 ${cards.length} 个点位 · 本端点序列共 ${total} 条(含未关联设备)`
  986. const blocks = [
  987. listBlock('监测点', cards, '当前筛选范围内没有监测点', {
  988. // 票 62:已装载集合做前端集合分页(翻页零请求)。
  989. paginate: true,
  990. // 页码归属键只用条件(换筛选/换快照即复位);装载链继续往集合里追加时**不复位**
  991. // ——用户停在第 3 页读台账,自动链补完后面的批次不该把人弹回第 1 页(条文 6)。
  992. pageScope: `${current.snapshotAt || ''}|${pagination.pageSize || ''}`,
  993. }),
  994. ]
  995. return {
  996. name: 'monitoringPointLedger',
  997. label: '监测点台账',
  998. section,
  999. hasContent: sectionHasContent(section),
  1000. blocks,
  1001. // 卡片本身就是可定位/可详情的对象,所以这里不再另给一批按钮:
  1002. // 点击卡片走**与地图相同**的两级详情入口(`detailStore.openPoint`),不隐式移动相机
  1003. // —— 与"点地图标记"的行为一致(票 10 的既有语义)。
  1004. locate: [],
  1005. locateNote: '点击卡片进入与地图一致的两级详情(点位摘要 → 设备卡片);本面板不移动相机',
  1006. // 分页口径:本端点分页窗口横跨「监测点 + 未关联设备」,所以 total 含设备,
  1007. // 卡片数会小于 total —— 这个差值说明白,免得读成"还有一些点没列出来"。
  1008. pageNote,
  1009. // 票 62:「加载下一页」按钮退役(自动链负责装载),`hasMore` 恒 false 让渲染层不画按钮。
  1010. hasMore: false,
  1011. page: pagination.page,
  1012. missing: panelMissingNote(current),
  1013. placeholder: sectionPlaceholder(section),
  1014. }
  1015. }
  1016. /** panelId → 视图构造函数(本模式自己的四块)。 */
  1017. export const MONITORING_PANEL_BUILDERS = {
  1018. monitoringOverview: monitoringOverviewPanel,
  1019. monitoringDistribution: monitoringDistributionPanel,
  1020. operationOverview: operationOverviewPanel,
  1021. // 台账签名多一个 `badges`(N+1 徽标);注册表调用时给 undefined 即为「还没取到」。
  1022. monitoringPointLedger: (data, section, badges) => monitoringPointLedgerPanel(data, section, badges),
  1023. }
  1024. /**
  1025. * 一个面板的视图。`data` 为 null(失败/空)时仍返回结构完整的视图(块为空),
  1026. * 组件据此画占位说明 —— 「失败」不该让整块面板消失,那会连面板标题都没了。
  1027. */
  1028. export function monitoringPanelView(panelId, data, section, badges) {
  1029. const build = MONITORING_PANEL_BUILDERS[panelId]
  1030. if (!build) return null
  1031. return build(data, section, badges)
  1032. }
  1033. /**
  1034. * 台账当前该请求的下一页(`null` = 不用再翻)。纯函数,断言与旧调用共用。
  1035. *
  1036. * 票 62:装载链的推进已收进 `domain/ledgerLoader.js`(它同时管快照锁定与失败纪律);
  1037. * 本函数保留为**载荷层面的只读判据**(「这份响应还有没有下一页」),不再被 store 用作
  1038. * 推进手段 —— 两处各推一次会把「谁决定下一页」变成两个答案。
  1039. */
  1040. export function nextLedgerPage(data) {
  1041. const pagination = (data && data.pagination) || null
  1042. if (!pagination || pagination.page === null) return 1
  1043. if (pagination.hasMore !== true) return null
  1044. return pagination.page + 1
  1045. }
  1046. /** 该点位是否需要补拉徽标(已被要求过就不重复发请求)。纯函数,便于断言。 */
  1047. export function shouldLoadBadge(badges, pointCode) {
  1048. if (!pointCode) return false
  1049. return !(badges && badges[pointCode])
  1050. }
  1051. /** 台账卡片的状态分布(走查与人工排查读它,不读中文)。 */
  1052. export function ledgerStatusCounts(data) {
  1053. const counts = {}
  1054. for (const point of (data && data.points) || []) {
  1055. const key = visualForStatus(point.status).key
  1056. counts[key] = (counts[key] || 0) + 1
  1057. }
  1058. return counts
  1059. }
  1060. /** 缺失值占位符(组件与本模块共用同一个词,免得两处各写一个字面量)。 */
  1061. export const LEDGER_PLACEHOLDER = DETAIL_PLACEHOLDER