f44f7eab9e
后端: - 新增 expense_data TEXT 列(columns.py迁移) - 新增 data_split 迁移:旧 budget_data cost/paid → expense_data(幂等) - sum_budget cost/paid → sum_expense cost/paid(routes.py/helpers.py) - TABLES 配置加入 expense_data 前端: - 项目详情弹窗Tab:基本信息→确收与回款→费用明细→执行信息→任务管理→活动 - 确收与回款Tab:月份/确收/毛利/回款/备注 - 费用明细Tab:月份/费用类型/应付/已付/备注 - 项目表格三视图(月/季/总)cost/paid来源切换为expense_data - 保存逻辑分两路: budget_data(rev/gross/payment)+expense_data(cost/paid)
57 lines
1.9 KiB
Python
57 lines
1.9 KiB
Python
"""migrations/data_split.py — 预算数据拆分迁移：budget_data → expense_data
|
||
|
||
旧结构：budget_data = [{month, rev, gross, payment, cost, paid}]
|
||
新结构：expense_data = [{month, expense_type, cost, paid, exp_note}]
|
||
|
||
部署时自动：检测未拆分的旧数据，将 cost/paid 从 budget_data 迁移到 expense_data。
|
||
幂等：只处理 expense_data 为空的记录。
|
||
"""
|
||
|
||
|
||
def migrate_data_split():
|
||
"""一次性数据拆分迁移"""
|
||
from db import db, _exec
|
||
import json
|
||
|
||
conn = db()
|
||
try:
|
||
# 查询未迁移的记录
|
||
cur = conn.cursor(dictionary=True)
|
||
cur.execute(
|
||
"SELECT id, budget_data, expense_data FROM project_finances "
|
||
"WHERE (expense_data IS NULL OR expense_data = '' OR expense_data = '[]') "
|
||
"AND budget_data IS NOT NULL AND budget_data != '' AND budget_data != '[]'"
|
||
)
|
||
rows = cur.fetchall()
|
||
cur.close()
|
||
|
||
migrated = 0
|
||
for row in rows:
|
||
try:
|
||
budget = json.loads(row.get("budget_data") or "[]")
|
||
except (json.JSONDecodeError, TypeError):
|
||
continue
|
||
|
||
expense_rows = []
|
||
for b in budget:
|
||
expense_rows.append({
|
||
"month": b.get("month", ""),
|
||
"expense_type": "",
|
||
"cost": float(b.get("cost") or 0),
|
||
"paid": float(b.get("paid") or 0),
|
||
"exp_note": "",
|
||
})
|
||
|
||
if expense_rows:
|
||
_exec(
|
||
conn,
|
||
"UPDATE project_finances SET expense_data = ? WHERE id = ?",
|
||
(json.dumps(expense_rows, ensure_ascii=False), row["id"]),
|
||
)
|
||
migrated += 1
|
||
|
||
conn.commit()
|
||
print(f"[migrate] 数据拆分迁移完成：{migrated} 条记录已从 budget_data 提取 cost/paid 到 expense_data")
|
||
finally:
|
||
conn.close()
|