charging-cabinet/tools/update_cabinets.py
12451 471b61d277 fix(test)+fix(deploy)+docs: 探针状态语义反转修复、退出码补齐、文档校订
1) probe_export.py:任务状态语义**搞反了**(导出成功也会被判失败)
   - download_tasks.status 的权威语义是 0 排队 / 1 处理中 / **2 完成** / 3 失败
     (db/migrate.rs:225 列注释;写入侧 charge_records.rs::mark_task_completed 写的就是 2)。
   - 该脚本此前**等 status == 1(处理中)当成功、把 status == 2(完成)判成"导出失败"**
     —— 典型假红。已按权威语义订正,并与另外两处**本来就正确**的口径对齐:
     web/src/pages/charge-records/DownloadCenter.tsx::statusText、
     test/schema_alignment_e2e.py(等 status in (2,3) 再断言 == 2)。
   - 同批修正退出码分类:账号缺 charge_record:export(403)由 exit 1 改为
     **exit 2「未验证」** —— 本项要验证的是"降权成 pms 后能否往 exports/ 落盘",
     没权限根本走不到那一步,报 1 是**把夹具缺陷说成产品缺陷**(误报与假绿同样有害)。
   - 允许用 PMS_PROBE_PHONE / PMS_PROBE_PASSWORD 换成有权限的账号。
   - **C 项结论(由落盘物证直接判定,不依赖该脚本)**:测试环境
     exports/充电记录__-.xlsx 5559 B、生产同类产物 5457 B,属主均为 pms:pms;
     两环境 exports/uploads 目录均 pms:pms,两 api-server 单元均 User=pms/Group=pms
     ⇒ 降权进程确实能落盘。已在 README 写明并给出取证依据。

2) deploy-prod.ps1 的退出码(此前失败的探针只打印 ❌ 就继续,脚本仍以 0 退出)
   - 消费链路探测失败(exit 1)现在**记入失败清单**并以 exit 1 收尾;
     "未验证"(隧道没起)默认仍不计失败(环境问题会误报),
     但新增 **-StrictVerify** 开关供 CI/无人值守使用,打开即 exit 1。
   - 好处:把这条从"打印了 ❌ 却 exit 0"(仓库第 8 条假绿)里摘出来。

3) 统一退出码 0/1/2 落地到本批脚本,并对每个失败路径实测取证:
   - test/tcp_e2e_smoke.py:13/13 通过(含未登录业务报文被静默丢弃);先复位夹具再跑。
   - test/security-hardening/ 新增 verdict.py 判据容器(未跟踪 → 本次入库);
     4 个探针全部按失败→exit 1 改造,并各实测过失败路径。
   - 实测结果(2026-09-20 发布后回归):smoke_prod 4/4 exit 0、
     probe_prod 5/5 exit 0、probe_upload 6/6 exit 0。

4) 工具与文档
   - tools/db.py 默认库由**生产 pms 改为测试 pms_dev**(可用 PMS_MYSQL_DB 覆盖,
     切生产时打印醒目警告)—— "以为在测测试库、实际打生产"的隐患。
   - tools/db_schema_diff.py:连不上必须是 exit 2,绝不伪装成"无漂移"的 0。
   - 新增 tools/dev-tunnel.ps1(入库,SSH 隧道;口令走 PMS_SSH_PASSWORD 环境变量),
     配套 tools/dev-tunnel-run.ps1 自愈启动器**保持 gitignore**(内含口令)。
   - deploy/nginx/nginx.conf 镜像随线上同步(移除 stream 转发;与线上逐字节一致)。
   - AGENTS.md / README.md:补「踩过的坑」第 7/8 条(掐断上游管道会杀被测进程、
     打印 ❌ 却 exit 0 是假绿)、退出码约定、本地开发改 SSH 隧道、
     在线判据口径订正、order_timeout 守门补齐、小程序 vue-tsc 门禁与其抓到的两个真 BUG。

发布验收(本次统一发布,按 device→api 顺序):
- 测试环境与生产环境四服务 active,端口 9000/9001/3000/3001 正确,ERROR 均为 0;
- 生产迁移按判据 grep '更新列注释' 实测对齐 cabinets.status 列注释;
- 结构漂移 python tools/db_schema_diff.py = 0 处漂移 / exit 0(--vs-ddl 两库同样 0);
- schema_alignment_e2e --env dev 全部通过 exit 0;
- 生产域名 /api/pms/cabinets -> 401、/pms/ -> 200;消费链路探测通过。
2026-09-20 04:31:42 +08:00

86 lines
2.9 KiB
Python
Raw Blame History

This file contains ambiguous Unicode characters

This file contains Unicode characters that might be confused with other characters. If you think that this is intentional, you can safely ignore this warning. Use the Escape button to reveal them.

import os
import pymysql
import random
# 默认指向 SSH 隧道(tools/dev-tunnel.ps1),不再使用已移除的 ZeroTier/nginx 转发
conn = pymysql.connect(
host=os.environ.get('PMS_MYSQL_HOST', '127.0.0.1'),
port=int(os.environ.get('PMS_MYSQL_PORT', '13306')),
user='root', password='Hbhyg731024@', database='pms',
)
cur = conn.cursor()
# 1. 添加address字段
try:
cur.execute("ALTER TABLE cabinets ADD COLUMN address VARCHAR(200) DEFAULT NULL COMMENT '安装地址' AFTER name")
print("✓ address字段添加成功")
except:
print("✓ address字段已存在")
# 2. 更新柜子数据(中文名字+地址)
addresses = [
"无锡市太湖新城观山路88号",
"无锡市梁溪区中山路168号",
"无锡市新吴区菱湖大道200号",
"苏州市工业园区星湖街328号",
"苏州市高新区竹园路78号",
"杭州市西湖区文三路123号",
"杭州市滨江区网商路599号",
"南京市建邺区庐山路158号",
"上海市浦东新区张江高科技园区",
"上海市闵行区紫竹科学园区",
"合肥市高新区望江西路800号",
"武汉市东湖高新区光谷大道77号",
"成都市高新区天府大道999号",
"重庆市渝北区新溉大道2号",
"长沙市岳麓区麓谷大道662号",
"广州市天河区科韵路16号",
"深圳市南山区科技南路18号",
"宁波市鄞州区宁穿路1888号",
"厦门市思明区软件园二期",
"青岛市崂山区株洲路78号",
]
names = [
"太湖新城换电柜A", "太湖新城换电柜B",
"梁溪区换电柜A", "梁溪区换电柜B",
"新吴区换电柜A",
"工业园区换电柜A", "工业园区换电柜B",
"高新区换电柜A",
"西湖区换电柜A", "西湖区换电柜B",
"滨江区换电柜A",
"建邺区换电柜A",
"张江换电柜A", "张江换电柜B",
"紫竹换电柜A",
"高新区换电柜A", "高新区换电柜B",
"光谷换电柜A",
"天府新区换电柜A", "天府新区换电柜B",
"渝北区换电柜A",
"麓谷换电柜A",
"天河区换电柜A", "天河区换电柜B",
"南山换电柜A", "南山换电柜B",
"鄞州换电柜A",
"软件园换电柜A",
"崂山换电柜A",
]
# 更新所有柜子
cur.execute("SELECT id FROM cabinets ORDER BY id")
cabinet_ids = [row[0] for row in cur.fetchall()]
for i, cab_id in enumerate(cabinet_ids):
name = names[i] if i < len(names) else f"充电柜-{i+1:03d}"
addr = addresses[i % len(addresses)]
cur.execute(f"UPDATE cabinets SET name='{name}', address='{addr}' WHERE id={cab_id}")
conn.commit()
print(f"✓ 更新了 {len(cabinet_ids)} 个柜子的名字和地址")
# 统计
cur.execute("SELECT COUNT(*) FROM cabinets WHERE name IS NOT NULL")
print(f"有名字的柜子: {cur.fetchone()[0]}")
cur.execute("SELECT COUNT(*) FROM cabinets WHERE address IS NOT NULL")
print(f"有地址的柜子: {cur.fetchone()[0]}")
conn.close()