monitoringPanels.js 64 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495969798991001011021031041051061071081091101111121131141151161171181191201211221231241251261271281291301311321331341351361371381391401411421431441451461471481491501511521531541551561571581591601611621631641651661671681691701711721731741751761771781791801811821831841851861871881891901911921931941951961971981992002012022032042052062072082092102112122132142152162172182192202212222232242252262272282292302312322332342352362372382392402412422432442452462472482492502512522532542552562572582592602612622632642652662672682692702712722732742752762772782792802812822832842852862872882892902912922932942952962972982993003013023033043053063073083093103113123133143153163173183193203213223233243253263273283293303313323333343353363373383393403413423433443453463473483493503513523533543553563573583593603613623633643653663673683693703713723733743753763773783793803813823833843853863873883893903913923933943953963973983994004014024034044054064074084094104114124134144154164174184194204214224234244254264274284294304314324334344354364374384394404414424434444454464474484494504514524534544554564574584594604614624634644654664674684694704714724734744754764774784794804814824834844854864874884894904914924934944954964974984995005015025035045055065075085095105115125135145155165175185195205215225235245255265275285295305315325335345355365375385395405415425435445455465475485495505515525535545555565575585595605615625635645655665675685695705715725735745755765775785795805815825835845855865875885895905915925935945955965975985996006016026036046056066076086096106116126136146156166176186196206216226236246256266276286296306316326336346356366376386396406416426436446456466476486496506516526536546556566576586596606616626636646656666676686696706716726736746756766776786796806816826836846856866876886896906916926936946956966976986997007017027037047057067077087097107117127137147157167177187197207217227237247257267277287297307317327337347357367377387397407417427437447457467477487497507517527537547557567577587597607617627637647657667677687697707717727737747757767777787797807817827837847857867877887897907917927937947957967977987998008018028038048058068078088098108118128138148158168178188198208218228238248258268278288298308318328338348358368378388398408418428438448458468478488498508518528538548558568578588598608618628638648658668678688698708718728738748758768778788798808818828838848858868878888898908918928938948958968978988999009019029039049059069079089099109119129139149159169179189199209219229239249259269279289299309319329339349359369379389399409419429439449459469479489499509519529539549559569579589599609619629639649659669679689699709719729739749759769779789799809819829839849859869879889899909919929939949959969979989991000100110021003100410051006100710081009101010111012101310141015101610171018101910201021102210231024102510261027102810291030103110321033103410351036103710381039104010411042104310441045104610471048104910501051105210531054105510561057105810591060106110621063106410651066106710681069107010711072107310741075107610771078107910801081108210831084108510861087108810891090109110921093109410951096109710981099110011011102110311041105110611071108110911101111111211131114111511161117111811191120112111221123112411251126112711281129113011311132113311341135113611371138113911401141114211431144114511461147114811491150115111521153115411551156115711581159116011611162
  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. // 维护者第 15 轮:排行用得太多 —— 设备类型分布改**堆叠条**(一条读出八类各多少与占比),
  507. // 与下方「各类型在线 / 离线」两张环图形成"总量 → 分状态"的层级。
  508. stackedBlock(
  509. '设备类型分布',
  510. sortByCountDesc(
  511. (current.typeDistribution || []).map((row) => ({
  512. code: row.code,
  513. label: row.name || codeText(row.code),
  514. count: row.deviceCount || 0,
  515. })),
  516. (row) => row.count,
  517. ),
  518. ),
  519. supplementalBlock(donutBlock('各类型在线设备', (current.typeDistribution || [])
  520. .filter((row) => numberish(row.onlineCount) !== null)
  521. .map((row) => ({ code: row.code, label: row.name || codeText(row.code), count: row.onlineCount })), { layout: 'compact' })),
  522. // 与「各类型在线设备」同形态:两张环图并排读"在线 / 离线"的对照(排行反而看不出对照)。
  523. supplementalBlock(donutBlock('各类型离线设备', (current.typeDistribution || [])
  524. .filter((row) => numberish(row.offlineCount) !== null)
  525. .map((row) => ({ code: row.code, label: row.name || codeText(row.code), count: row.offlineCount })), { layout: 'compact' })),
  526. ]
  527. return {
  528. name: 'monitoringOverview',
  529. label: '监测概览',
  530. section,
  531. hasContent: sectionHasContent(section),
  532. blocks,
  533. // 概览是聚合口径(后端只给分类型计数,不给逐点位坐标),没有可定位对象。
  534. locate: [],
  535. locateNote: '监测概览是分类型聚合口径(后端不返回逐点位坐标),本面板没有可定位对象',
  536. // 入库时间与采样时间的区别如实说明(文件头第 ① 条 + `TIME_LABELS`)。
  537. gap: METRIC_FRESHNESS_GAP,
  538. industryNote: current.selectedIndustry ? `当前行业:${industryLabel(current.selectedIndustry) || current.selectedIndustry}` : '当前行业:全部',
  539. // 票 37:生效类型必须看得见 —— 否则读者只会看到"类型分布少了几行",
  540. // 不知道该条件从哪来、也不知道怎么撤(同一条行再点一次)。
  541. typeNote: current.selectedDeviceType
  542. ? `当前类型:${deviceTypeLabel(current.typeDistribution, current.selectedDeviceType)}(再点同一行取消)`
  543. : '当前类型:全部',
  544. missing: panelMissingNote(current),
  545. placeholder: sectionPlaceholder(section),
  546. }
  547. }
  548. /**
  549. * 类型码 → 展示名(票 37)。名字优先取自**本端点返回的类型分布**(同一份数据里带着 name,
  550. * 不另建一份类型词典);分布里没有该码时用 `codeText` 的既有口径——**数据值照原样带出**,
  551. * 因为空白会被读成"没有数据",而"没见过的类型码"是真实数据。
  552. * @param {Array} rows 类型分布行(含 `code`/`name`)
  553. * @param {string} code 生效的类型码
  554. */
  555. function deviceTypeLabel(rows, code) {
  556. if (!code) return ''
  557. const found = (rows || []).find((row) => row.code === code)
  558. return (found && found.name) || codeText(code)
  559. }
  560. /**
  561. * 监测分布面板视图。
  562. * 验收三项:覆盖情况、状态分布、地图筛选(本票的筛选入口是全局筛选条,面板只回显生效范围)。
  563. *
  564. * **票 14 改写**:状态统计从「可点状态条」改为**饼图**(决策 02 的 Q12/Q19)——
  565. * · 数据源是**全局未筛分布**(`extra.statusDistribution`,与地图顶部状态栏共用同一份,
  566. * 来自 `map-snapshot` 的八桶全局计数;不是本端点随筛选变的那份);
  567. * · 饼图只**高亮当前选中**,不再是筛选入口——全局条件只有一个可操作面(顶部状态栏),
  568. * 面板自带筛选正是票 07 点名的「入口分散且重复」缺陷;
  569. * · 全局分布未取到时如实说明(不伪造全零饼图)。
  570. *
  571. * @param {object} data `toMonitoringDistribution()` 的结果
  572. * @param {object} section 分区
  573. * @param {object} [extra] `{ statusDistribution, selectedStatuses }`(外壳给的共用数据与当前选中)
  574. */
  575. /**
  576. * 异常监测点 → **指标卡 2×2**(维护者第 15 轮)。
  577. *
  578. * 为什么不再用横条:这组读数是「当前有多少个异常点位」的**结论型数字**,值班人员要的是
  579. * 一眼读出四类各多少,而不是比条长;而且它原本挂在面板中段,被上面的覆盖分布压住了。
  580. * 卡片顺序固定为 报警 / 预警 / 工单处置 / 离线(与地图顶部状态栏同一套语义顺序)。
  581. *
  582. * 缺值纪律不变:`extra.statusDistribution` 不可用时整块不出(调用点已判 available),
  583. * 单个桶缺失按「未知」画占位符 —— 不把「没给」画成 0 个异常点。
  584. */
  585. export function abnormalPointCards(counts) {
  586. const source = counts && typeof counts === 'object' ? counts : {}
  587. const rows = [
  588. { key: 'ALARM', label: '报警', tone: 'lv1' },
  589. { key: 'WARNING', label: '预警', tone: 'lv2' },
  590. { key: 'WORK_ORDER', label: '工单处置', tone: 'lv3' },
  591. { key: 'OFFLINE', label: '离线', tone: 'neutral' },
  592. ]
  593. const countOf = (key) => {
  594. const raw = source[key]
  595. if (raw === null || raw === undefined || raw === '') return null
  596. const value = numberish(raw)
  597. return value === null ? null : value
  598. }
  599. return rows.map((row) => ({
  600. key: row.key,
  601. label: row.label,
  602. value: valueText(countOf(row.key)),
  603. unit: '个',
  604. valueTone: row.tone,
  605. accent: row.tone,
  606. caption: '全局未筛',
  607. }))
  608. }
  609. /**
  610. * 「口径 · 生效范围与总数」→ 面板摘要文案(维护者第 15 轮:并入摘要)。
  611. *
  612. * 为什么搬到摘要:这六条是**抬头读数**(现在按什么条件在看),不是图表,占一整块把面板撑长;
  613. * 做过期/空态说明也已经在摘要里,同一族信息收在一处更好读。
  614. * 措辞纪律不变:只说范围与口径,不出现接口字段名;缺值照占位符(不编「全部」)。
  615. */
  616. function distributionScopeNote(current) {
  617. const total = valueText(current.pagination && current.pagination.total)
  618. const industry = current.selectedIndustry
  619. ? industryLabel(current.selectedIndustry) || current.selectedIndustry
  620. : '全部'
  621. const district = districtFilterLabel({ district: current.selectedDistrict, districtFilter: current.districtFilter })
  622. const deviceType = current.selectedDeviceType
  623. ? deviceTypeLabel(current.deviceTypes, current.selectedDeviceType)
  624. : '全部'
  625. const pointStatus = current.selectedPointStatus
  626. ? String(current.selectedPointStatus)
  627. .split(',')
  628. .map((code) => POINT_STATUS_FILTER_LABELS[code] || code)
  629. .filter(Boolean)
  630. .join('、')
  631. : '全部'
  632. const invalid = valueText(current.excluded && current.excluded.invalidCoordinateCount)
  633. return [
  634. '监测点总数 ' + total,
  635. '生效行业 ' + industry,
  636. '生效片区 ' + district,
  637. '生效类型 ' + deviceType,
  638. '生效状态 ' + pointStatus,
  639. '坐标未通过校验 ' + invalid,
  640. ].join(' · ')
  641. }
  642. export function monitoringDistributionPanel(data, section, extra = {}) {
  643. const current = data || {}
  644. // 覆盖情况(Q11 裁定):用**本端点自己的**区域/行业/设备类型分布 ——
  645. // 票 24 指向的 `overview/monitoring` 的 `formalScope` 不在本端点上,拿不到也不去拉。
  646. // 票 37 走查扩展(维护者 2026-10-14):三块都是排名类别,统一按计数降序(并列保序);
  647. // 环形图(行业)与条形(片区/类型)同口径。
  648. const regionRows = sortByCountDesc(
  649. (current.regions || []).map((row) => ({
  650. code: row.code,
  651. label: districtLabel(row.code),
  652. count: row.pointCount || 0,
  653. // 每一行带上设备数与状态明细,但主条长按**点位数**归一(图与数同源:口径写在标题里)。
  654. hint: `设备 ${valueText(row.deviceCount)}`,
  655. })),
  656. (row) => row.count,
  657. )
  658. const industryRows = sortByCountDesc(
  659. (current.industries || []).map((row) => ({
  660. code: row.code,
  661. label: industryLabel(row.code) || regionText(row.code),
  662. count: row.pointCount || 0,
  663. hint: `设备 ${valueText(row.deviceCount)}`,
  664. })),
  665. (row) => row.count,
  666. )
  667. const typeRows = sortByCountDesc(
  668. (current.deviceTypes || []).map((row) => ({
  669. code: row.code || row.name,
  670. label: row.name || codeText(row.code),
  671. count: row.pointCount || 0,
  672. hint: `设备 ${valueText(row.deviceCount)}`,
  673. })),
  674. (row) => row.count,
  675. )
  676. // 票 14:饼图切片(几何与高亮判定都在 `domain/statusPie.js`,本层只搬运)。
  677. const pie = planStatusPie({
  678. distribution: extra.statusDistribution || null,
  679. rows: legendVisuals(),
  680. selected: Array.isArray(extra.selectedStatuses) ? extra.selectedStatuses : [],
  681. })
  682. const blocks = [
  683. // 票 39(第 8 条):每块标题 = **「分节 · 维度(条长口径)」**。
  684. // 维护者反馈第 8 条的原话是「图与数据指代对象不明确」——同一个面板里既有按
  685. // **点位数**排的覆盖分布、又有**全局未筛**的状态分布,三种口径混在一屏而不写在
  686. // 标题上,读者无从判断每张图数的是什么、数的是点位还是设备。
  687. // 分节词(覆盖情况 / 状态分布 / 口径)让三族各自成节,括号里的口径说明
  688. // 「这条长度量的是什么」;悬停行的 hint 仍给设备数(图与数同源,不另算一份)。
  689. // 条形/环形的分工沿用 2026-10-13 的既有结论(行业=类别少→环形;
  690. // 片区/类型=多类别排名→横条),本票不动图形形态,只把指代写清楚。
  691. // 维护者第 15 轮:① 覆盖情况 · 片区与覆盖情况 · 行业统一成饼图(同族对照,形态一致才好比);
  692. // ② 覆盖情况 · 设备类型与下面的「设备类型构成(按点位数)」内容重叠、意义也不清楚 —— 整块删除;
  693. // ③「异常监测点」从横条改**指标卡 2×2**,并提到面板最顶部(它是值班人员最先要看的一组读数)。
  694. ...(extra.statusDistribution && extra.statusDistribution.available
  695. ? [kpiBlock(abnormalPointCards(extra.statusDistribution.counts || {}), { layout: 'two-by-two' })]
  696. : []),
  697. donutBlock('覆盖情况 · 行业(按点位数)', industryRows, { layout: 'compact' }),
  698. donutBlock('覆盖情况 · 片区(按点位数)', regionRows, { layout: 'compact' }),
  699. stackedBlock('设备类型构成(按点位数)', typeRows),
  700. // 状态分布饼图:消费全局未筛分布并高亮当前选中;**不可点**(筛选入口只在顶部状态栏)。
  701. {
  702. kind: 'pie',
  703. label: '状态分布 · 点位状态(全局未筛)',
  704. ready: pie.ready,
  705. hasSelection: pie.hasSelection,
  706. total: pie.total,
  707. slices: pie.slices,
  708. rows: pie.rows,
  709. note: pie.ready ? '' : STATUS_DISTRIBUTION_UNPUBLISHED,
  710. },
  711. ]
  712. return {
  713. name: 'monitoringDistribution',
  714. label: '监测分布',
  715. section,
  716. hasContent: sectionHasContent(section),
  717. blocks,
  718. locate: [],
  719. locateNote: '监测分布是聚合分布口径(后端不返回逐点位坐标),本面板没有可定位对象',
  720. // 范围筛选落点说明保留;「状态筛选不作用到一张图」的缺口说明已随票 14 的契约修订删除。
  721. gap: REGION_SCOPE_NOTE,
  722. // 维护者第 15 轮:原「口径 · 生效范围与总数」块并入摘要(数据时间仍在,见下)。
  723. note: distributionScopeNote(current) + (current.createdAt ? ' · ' + TIME_LABELS.latestIngested + ' ' + valueText(current.createdAt) : ''),
  724. // 数据时间是唯一带「测量含义」的读数,单独留在摘要尾巴上,不丢。
  725. rangeNote: '',
  726. missing: panelMissingNote(current),
  727. placeholder: sectionPlaceholder(section),
  728. }
  729. }
  730. /**
  731. * 运行概况面板视图。
  732. * 验收三项:事件趋势、离线设备、异常态势。
  733. *
  734. * **票 62 追加需求(2026-10-22 维护者)**:本面板不再展示「异常设备清单」,改展示
  735. * **设备台账**——按当前数据应列出全部 9 台监测设备,而不是只列异常四态的 8 台。
  736. * 台账数据来自 `/monitoring/overview` 的 `devices[]`(与那边的 `counts.equipmentCount`
  737. * 同源同口径),由外壳作为 `extra.devices` 搬进来;本面板自己的分区
  738. * (`/monitoring/situation`)继续供趋势、指标状态与异常统计——**异常口径不丢,只是
  739. * 不再用它当台账**。两者不是一回事:异常清单只装 WARNING/ALARM/EXPIRED/OFFLINE 四态设备。
  740. * @param {object} data `toMonitoringSituation()` 的结果
  741. * @param {object} section 分区
  742. * @param {object} [extra] `{ devices }`(`toMonitoringOverview().devices`,外壳给)
  743. */
  744. /**
  745. * 预警 / 报警两条趋势合并成**同轴双线**(维护者 2026-10-29)。
  746. *
  747. * 为什么要在这里合并:两个端点序列的桶起点可能不完全一致(一侧少一个桶、或粒度不同),
  748. * 直接按数组下标配对会在图上画出错位的对照 —— 这是**假数据**,不是排版问题。
  749. * 所以按桶键求并集、缺失一侧记 null(**不补 0**:没这个桶 ≠ 这个桶是 0),
  750. * 序列里出现 null 时该点不画点、不计入折线(渲染层按 filter(Boolean) 处理)。
  751. *
  752. * @param {Array} warningRows `warningTrend` 行(`bucket`/`count`)
  753. * @param {Array} alarmRows `alarmTrend` 行
  754. * @returns {{points: Array, warningCounts: Array, alarmCounts: Array}}
  755. */
  756. export function mergeTrendSeries(warningRows, alarmRows) {
  757. const warning = Array.isArray(warningRows) ? warningRows : []
  758. const alarm = Array.isArray(alarmRows) ? alarmRows : []
  759. const buckets = []
  760. const seen = new Set()
  761. for (const row of [...warning, ...alarm]) {
  762. const key = String((row && row.bucket) || '')
  763. if (!key || seen.has(key)) continue
  764. seen.add(key)
  765. buckets.push(key)
  766. }
  767. buckets.sort()
  768. const index = (rows) => {
  769. const map = new Map()
  770. for (const row of rows) map.set(String((row && row.bucket) || ''), numberish(row && row.count))
  771. return map
  772. }
  773. const warningMap = index(warning)
  774. const alarmMap = index(alarm)
  775. return {
  776. points: buckets.map((bucket) => ({ bucket })),
  777. warningCounts: buckets.map((bucket) => warningMap.get(bucket) ?? null),
  778. alarmCounts: buckets.map((bucket) => alarmMap.get(bucket) ?? null),
  779. }
  780. }
  781. export function operationOverviewPanel(data, section, extra = {}) {
  782. const current = data || {}
  783. // 7 天窗口的桶是「日」粒度,标签按日期显示(只影响显示,不改桶)。
  784. const daily = isDailyWindow(current)
  785. const trendPoints = (list) =>
  786. (list || []).map((row) => ({
  787. key: row.bucket,
  788. label: bucketLabel(row.bucket, daily),
  789. count: row.count,
  790. }))
  791. // 维护者 2026-10-29:两条趋势合成一张双线图(按桶键求并集,缺失不补 0)。
  792. const mergedTrend = mergeTrendSeries(current.warningTrend, current.alarmTrend)
  793. const offlineCount = metricCount(current.metricStatuses, 'OFFLINE')
  794. // 离线设备:从异常清单里挑出离线的那一档。**只挑,不推断**——状态来自后端 `status`。
  795. // 票 62:这段只服务 `offlineNote`(顶部摘要那行),**不再画成清单**。
  796. const offlineDevices = (current.abnormalEquipment || []).filter((item) => item.status === 'OFFLINE')
  797. // 票 62:设备台账数据源(与 `counts.equipmentCount` 同源,行数恒等于它)。
  798. const devices = Array.isArray(extra.devices) ? extra.devices : []
  799. // 票 92(维护者 2026-10-27):KPI 改为 6 张、3×2 排版。全部取自本面板自己的分区
  800. // `/monitoring/situation`(不跨面板取数),数值真实且分区独立:
  801. // · 设备总数 = 六档指标状态计数之和(后端按设备粒度给,总和 = 设备台数);
  802. // · 在线设备 = 正常 + 预警 + 报警(正在上报的设备;与监测概览设备轴「在线」口径一致,已实测比对);
  803. // · 离线设备 = 指标状态 OFFLINE 档(沿用既有取数);
  804. // · 预警/报警设备 = WARNING / ALARM 档(沿用既有取数,改名);
  805. // · 总异常设备 = 异常设备清单总数(pagination.total = 预警+报警+离线+过期)。
  806. // 旧「数据入库时间」卡退役(不在 6 张清单里)。
  807. // 分布没取到时(六档 count 全 null)→ 总数/在线/离线/预警/报警全走占位符,绝不画 0(票 16)。
  808. const distributionProvided = (current.metricStatuses || []).some((row) => row.count !== null)
  809. const deviceTotal = distributionProvided
  810. ? current.metricStatuses.reduce((sum, row) => sum + (row.count || 0), 0)
  811. : null
  812. const onlineCount = distributionProvided
  813. ? metricCount(current.metricStatuses, 'NORMAL')
  814. + metricCount(current.metricStatuses, 'WARNING')
  815. + metricCount(current.metricStatuses, 'ALARM')
  816. : null
  817. const blocks = [
  818. kpiBlock([
  819. { key: 'deviceCount', label: '设备总数', value: valueText(deviceTotal), unit: '台', hint: '按指标状态统计(六档之和)' },
  820. { key: 'online', label: '在线设备', value: valueText(onlineCount), unit: '台', hint: '正常 + 预警 + 报警的设备(正在上报)' },
  821. { key: 'offlineCount', label: '离线设备', value: valueText(offlineCount), unit: '台' },
  822. { key: 'warningCount', label: '预警设备', value: valueText(metricCount(current.metricStatuses, 'WARNING')), unit: '台' },
  823. { key: 'alarmCount', label: '报警设备', value: valueText(metricCount(current.metricStatuses, 'ALARM')), unit: '台' },
  824. { key: 'abnormalCount', label: '总异常设备', value: valueText(current.pagination && current.pagination.total), unit: '台', hint: '预警 + 报警 + 离线 + 过期' },
  825. ], { layout: 'three', emphasis: true }),
  826. // 维护者第 15 轮:「设备/指标异常统计」与「异常态势 · 指标状态分布」是同一份六态数据的
  827. // 两种画法(横条 + 横条)—— 合并成**一张饼图**,一次读出六态占比与读数。
  828. donutBlock('指标状态分布(六态)', abnormalCountRows(current.metricStatuses, 'metric').map((row) => ({
  829. code: row.key,
  830. label: row.label,
  831. count: row.count,
  832. })), { layout: 'compact' }),
  833. // 维护者 2026-10-29:预警与报警合成**一张双线折线**(同一时间窗、同一量纲),并给块顶留出
  834. // 呼吸空间(compact 版式),避免与块标题/点顶数值重叠。两条线仍是两个独立数据源,
  835. // 只共享坐标轴与图例 —— 不改变任何统计口径。
  836. trendBlock('预警与报警趋势', mergedTrend.points.map((row) => ({
  837. key: row.bucket,
  838. label: bucketLabel(row.bucket, daily),
  839. count: 0,
  840. hint: row.bucket,
  841. })), {
  842. chart: 'line',
  843. compact: true,
  844. tall: true,
  845. aside: '双线对照:预警 / 报警',
  846. series: [
  847. { key: 'warning', label: '预警', tone: 'lv2', counts: mergedTrend.warningCounts },
  848. { key: 'alarm', label: '报警', tone: 'lv1', counts: mergedTrend.alarmCounts },
  849. ],
  850. }),
  851. deviceLedgerBlock(devices),
  852. ]
  853. return {
  854. name: 'operationOverview',
  855. label: '运行概况',
  856. section,
  857. hasContent: sectionHasContent(section),
  858. blocks,
  859. // 维护者 2026-10-29:定位入口与监测点台账对齐 —— **整卡点击**即定位并进详情,
  860. // 不再额外画一排「定位」按钮(两条路径会让同一件事有两种手感)。
  861. // 三种"点不动"仍由 `domain/mapLocate.js` 分开,由 locateCode 如实反馈。
  862. locate: [],
  863. locateNote: '点击设备卡片即定位并进入设备详情(与监测点台账同一交互);设备坐标由一张图回联,未加载到的设备不下发飞行',
  864. // 窗口口径:后端回显的实际生效区间(本面板的 24 小时 / 7 天切换写在界面上,见票面 Q8)。
  865. rangeNote: current.rangeStart && current.rangeEnd ? `统计窗口:${current.rangeStart} 至 ${current.rangeEnd}` : '',
  866. offlineNote: offlineDevices.length
  867. ? `离线 ${offlineDevices.length} 台:${offlineDevices.map((item) => item.name).join('、')}`
  868. : '当前窗口没有离线设备',
  869. missing: panelMissingNote(current),
  870. placeholder: sectionPlaceholder(section),
  871. }
  872. }
  873. /** 7 天窗口的桶按日显示(判据是后端回显的区间长度,不是前端自己记的开关)。 */
  874. function isDailyWindow(current) {
  875. const start = Date.parse((current && current.rangeStart) || '')
  876. const end = Date.parse((current && current.rangeEnd) || '')
  877. if (!Number.isFinite(start) || !Number.isFinite(end)) return false
  878. return end - start > 36 * 3600 * 1000
  879. }
  880. /**
  881. * 异常状态 → 色键(报警最重、其次预警、离线与过期走中性)。
  882. * 票 62:异常清单已从运行概况撤下(改展示设备台账),本函数仍服务于
  883. * `offlineNote` 的语义与 `toAbnormalEquipment` 的既有消费点,故保留。
  884. */
  885. function abnormalTone(status) {
  886. if (status === 'ALARM') return 'lv1'
  887. if (status === 'WARNING') return 'lv2'
  888. if (status === 'OFFLINE' || status === 'EXPIRED') return 'neutral'
  889. return 'neutral'
  890. }
  891. /** 设备台账行的展示名:有名称用名称,没名称用编码(**不编造**,也不留空行)。 */
  892. function deviceLabel(item) {
  893. return (item && (item.name || item.code)) || DETAIL_PLACEHOLDER
  894. }
  895. /**
  896. * 设备监测状态 → 色键(票 62)。按语义分档,与 `abnormalTone` 同一套色;
  897. * 在线/正常走成功色,滞后走关注色,离线/未发布走中性(**不把"没状态"画成正常**)。
  898. */
  899. function deviceStateTone(status) {
  900. if (status === 'ALARM') return 'lv1'
  901. if (status === 'WARNING' || status === 'STALE') return 'lv2'
  902. if (status === 'ONLINE' || status === 'NORMAL') return 'lv4'
  903. return 'neutral'
  904. }
  905. /**
  906. * 设备监测状态码 → 人话(票 62)。
  907. * `ONLINE` 是设备轴上的补充取值(指标状态字典里没有它);其余复用六态字典,
  908. * 认不出的回原码、空值如实说「状态未发布」——不猜成正常。
  909. */
  910. function deviceStateText(status) {
  911. const value = typeof status === 'string' ? status.trim() : ''
  912. if (!value) return '状态未发布'
  913. if (value === 'ONLINE') return '在线'
  914. return metricStatusText(value)
  915. }
  916. /**
  917. * 运行概况的**设备台账**清单块(票 62 追加需求,2026-10-22 维护者)。
  918. *
  919. * 与原先「异常设备清单」是**结构性差别**,不只是换个标题:
  920. * · **数据源**:`/monitoring/overview` 的 `devices[]`(全部智能设备,行数 ≡ `counts.equipmentCount`),
  921. * 不是 `/monitoring/situation` 的 `abnormalEquipment[]`(只装 WARNING/ALARM/EXPIRED/OFFLINE);
  922. * · **每行内容**:名称(主键展示)+ 设备编码、类型、行业、监测状态、所属点位、数据入库时间;
  923. * · **总数口径**:读设备台账行数本身(= `equipmentCount`),页脚明说「共 N 台监测设备」;
  924. * · 仍是前端集合分页 10/页(规范三分法),翻页**零请求**。
  925. * @param {Array} devices 领域设备行(`toMonitoringOverview().devices`)
  926. */
  927. function deviceLedgerBlock(devices) {
  928. const rows = (devices || []).map((item) => ({
  929. key: item.code || `${item.typeCode}|${item.pointCode}`,
  930. title: deviceLabel(item),
  931. identityKind: CARD_ACTION.DEVICE,
  932. identityCode: item.code,
  933. identityReason: item.code ? '' : '缺少设备编码,无法展开',
  934. dataTime: valueText(item.createdAt),
  935. // 标签由 domain 给(`TIME_LABELS` 单点词表):渲染层不认「时间」这个词,更不自己拼。
  936. dataTimeLabel: TIME_LABELS.ingested,
  937. tone: deviceStateTone(item.status),
  938. // 色键必带文字(票 06):状态词认不出也回原码,不留空标签、不猜成正常。
  939. toneLabel: deviceStateText(item.status),
  940. meta: [
  941. item.code,
  942. item.typeName,
  943. industryLabel(item.industry) || codeText(item.industry),
  944. item.pointCode ? `点位 ${item.pointCode}` : '未关联点位',
  945. ].filter(Boolean),
  946. // 维护者 2026-10-29:设备卡**不再单独画「定位」小按钮**,改为与监测点台账一致 ——
  947. // 整卡点击 = 定位 + 进详情(一个动作,不是"先点小按钮定位、再点卡进详情"两条路径)。
  948. // 定位本身仍走既有设备维度接缝 `monitoringStore.locateCode`(判定→相机→详情),
  949. // 三种"点不动"由 `domain/mapLocate.js` 分开,不在这里另造一套。
  950. points: [],
  951. }))
  952. return listBlock('设备台账', rows, '当前范围内没有监测设备', {
  953. paginate: true,
  954. // 页码归属键:只看设备全集的身份(行数)——换筛选导致集合变化时自然复位。
  955. // 标量键,不接受对象身份(票 43 教训:视图计划每次重算都是新对象)。
  956. pageScope: `devices|${rows.length}`,
  957. pageNote: rows.length ? `共 ${rows.length} 台监测设备(当前筛选范围)` : '',
  958. })
  959. }
  960. /**
  961. * 监测点台账面板视图。
  962. * 验收第 4 条:以滚动卡片列出当前行业筛选内的监测点;点击卡片走与地图相同的两级详情。
  963. *
  964. * **票 62 改写(批次四)**:数据不再取「分布这一次响应的第 1 页切片」,而是 store 的
  965. * **自动渐进装载链**(`domain/ledgerLoader.js`)已经装好的**完整序列**;
  966. * · 装载与一张图点位数据同款(条件变化 → 新快照 → 自动连翻到 settled);
  967. * · 界面只对**已装载集合**做统一页码分页(10/页、页码直达),翻页是**纯视图动作**;
  968. * · 「加载下一页监测点」按钮与 `ledger-more` 接缝**退役**(自动链自己会翻完);
  969. * · 页脚如实给「已装载 M · 共 N 条(含未关联设备)」+ 装载中/失败标注。
  970. *
  971. * **设备徽标仍走 N+1**(Q10/Q14 不变):本端点不给设备编码,徽标由 store 逐点位取。
  972. * 票 62 的改进是**只为当前页窗口内的卡片补拉**——窗口化之后一屏最多 10 张卡,
  973. * 不再"一页 500 张卡进视口就打出 500 个请求"。
  974. * @param {object} data `toMonitoringDistribution()`/装载链条目(读 `points`/`equipment`/`pagination`)
  975. * @param {object} section 分区
  976. * @param {object} [badges] `{ [pointCode]: { state, total, alarm, warning, offline } }`(store 给)
  977. */
  978. export function monitoringPointLedgerPanel(data, section, badges = {}) {
  979. const current = data || {}
  980. const pagination = current.pagination || {}
  981. // 分母认不出就**整句不出**(作者本意),且绝不用 `undefined` 冒充读数:
  982. // `data` 为 null(真实空态/失败态,见 `sectionFromResult()` 的 `isEmpty` 分支)时
  983. // `pagination` 是 `{}`,`total` 是 `undefined` 而不是 `null` —— 只判 `=== null` 会把
  984. // 它漏进模板串。`numberish()` 是仓库里「数字/数字串→数字,认不出回 null」的唯一口径。
  985. const total = numberish(pagination.total)
  986. const cards = (current.points || []).map((point) => {
  987. const visual = visualForStatus(point.status)
  988. const badge = badges[point.code] || null
  989. return {
  990. key: point.code,
  991. code: point.code,
  992. name: point.name,
  993. identityKind: CARD_ACTION.POINT,
  994. identityCode: point.code,
  995. identityReason: point.code ? '' : '缺少点位编码,无法展开',
  996. dataTime: valueText(point.createdAt),
  997. // 同上:标签由 domain 给,渲染层只拼值。
  998. dataTimeLabel: TIME_LABELS.ingested,
  999. // 状态词与色键来自票 09 的唯一一张表(认不出的状态落「状态未发布」,不猜成正常)。
  1000. status: visual.key,
  1001. tone: visual.tone,
  1002. shape: visual.shape,
  1003. statusLabel: visual.label,
  1004. meta: [
  1005. industryLabel(point.industry) || codeText(point.industry),
  1006. districtLabel(point.district),
  1007. point.typeName,
  1008. ].filter(Boolean),
  1009. reason: (point.statusReasons || []).join(';'),
  1010. // 徽标:还没取到就**不给 0**(0 是"确实没有设备",与"还没问过"是两件事)。
  1011. badge: badge && badge.state === 'success'
  1012. ? {
  1013. total: valueText(badge.total),
  1014. alarm: valueText(badge.alarm),
  1015. warning: valueText(badge.warning),
  1016. offline: valueText(badge.offline),
  1017. }
  1018. : null,
  1019. badgePending: !badge || badge.state === 'pending',
  1020. }
  1021. })
  1022. // 票 62:页脚口径由 store 的装载链给(它才知道「已装载多少 / 总数多少 / 还在不在装」);
  1023. // 装载链没给(走查注入的裸载荷)时退回既有措辞,保持 t27 的防回归判据不变。
  1024. const pageNote = typeof current.ledgerNote === 'string' && current.ledgerNote
  1025. ? current.ledgerNote
  1026. : total === null
  1027. ? ''
  1028. : `已列出 ${cards.length} 个点位 · 本端点序列共 ${total} 条(含未关联设备)`
  1029. const blocks = [
  1030. listBlock('监测点', cards, '当前筛选范围内没有监测点', {
  1031. // 票 62:已装载集合做前端集合分页(翻页零请求)。
  1032. paginate: true,
  1033. // 页码归属键只用条件(换筛选/换快照即复位);装载链继续往集合里追加时**不复位**
  1034. // ——用户停在第 3 页读台账,自动链补完后面的批次不该把人弹回第 1 页(条文 6)。
  1035. pageScope: `${current.snapshotAt || ''}|${pagination.pageSize || ''}`,
  1036. }),
  1037. ]
  1038. return {
  1039. name: 'monitoringPointLedger',
  1040. label: '监测点台账',
  1041. section,
  1042. hasContent: sectionHasContent(section),
  1043. blocks,
  1044. // 卡片本身就是可定位/可详情的对象,所以这里不再另给一批按钮:
  1045. // 点击卡片走**与地图相同**的两级详情入口(`detailStore.openPoint`),不隐式移动相机
  1046. // —— 与"点地图标记"的行为一致(票 10 的既有语义)。
  1047. locate: [],
  1048. locateNote: '点击卡片进入与地图一致的两级详情(点位摘要 → 设备卡片);本面板不移动相机',
  1049. // 分页口径:本端点分页窗口横跨「监测点 + 未关联设备」,所以 total 含设备,
  1050. // 卡片数会小于 total —— 这个差值说明白,免得读成"还有一些点没列出来"。
  1051. pageNote,
  1052. // 票 62:「加载下一页」按钮退役(自动链负责装载),`hasMore` 恒 false 让渲染层不画按钮。
  1053. hasMore: false,
  1054. page: pagination.page,
  1055. missing: panelMissingNote(current),
  1056. placeholder: sectionPlaceholder(section),
  1057. }
  1058. }
  1059. /** panelId → 视图构造函数(本模式自己的四块)。 */
  1060. export const MONITORING_PANEL_BUILDERS = {
  1061. monitoringOverview: monitoringOverviewPanel,
  1062. monitoringDistribution: monitoringDistributionPanel,
  1063. operationOverview: operationOverviewPanel,
  1064. // 台账签名多一个 `badges`(N+1 徽标);注册表调用时给 undefined 即为「还没取到」。
  1065. monitoringPointLedger: (data, section, badges) => monitoringPointLedgerPanel(data, section, badges),
  1066. }
  1067. /**
  1068. * 一个面板的视图。`data` 为 null(失败/空)时仍返回结构完整的视图(块为空),
  1069. * 组件据此画占位说明 —— 「失败」不该让整块面板消失,那会连面板标题都没了。
  1070. */
  1071. export function monitoringPanelView(panelId, data, section, badges) {
  1072. const build = MONITORING_PANEL_BUILDERS[panelId]
  1073. if (!build) return null
  1074. return build(data, section, badges)
  1075. }
  1076. /**
  1077. * 台账当前该请求的下一页(`null` = 不用再翻)。纯函数,断言与旧调用共用。
  1078. *
  1079. * 票 62:装载链的推进已收进 `domain/ledgerLoader.js`(它同时管快照锁定与失败纪律);
  1080. * 本函数保留为**载荷层面的只读判据**(「这份响应还有没有下一页」),不再被 store 用作
  1081. * 推进手段 —— 两处各推一次会把「谁决定下一页」变成两个答案。
  1082. */
  1083. export function nextLedgerPage(data) {
  1084. const pagination = (data && data.pagination) || null
  1085. if (!pagination || pagination.page === null) return 1
  1086. if (pagination.hasMore !== true) return null
  1087. return pagination.page + 1
  1088. }
  1089. /** 该点位是否需要补拉徽标(已被要求过就不重复发请求)。纯函数,便于断言。 */
  1090. export function shouldLoadBadge(badges, pointCode) {
  1091. if (!pointCode) return false
  1092. return !(badges && badges[pointCode])
  1093. }
  1094. /** 台账卡片的状态分布(走查与人工排查读它,不读中文)。 */
  1095. export function ledgerStatusCounts(data) {
  1096. const counts = {}
  1097. for (const point of (data && data.points) || []) {
  1098. const key = visualForStatus(point.status).key
  1099. counts[key] = (counts[key] || 0) + 1
  1100. }
  1101. return counts
  1102. }
  1103. /** 缺失值占位符(组件与本模块共用同一个词,免得两处各写一个字面量)。 */
  1104. export const LEDGER_PLACEHOLDER = DETAIL_PLACEHOLDER