Compare commits
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
4911f24d40 | ||
|
|
8c24abd53e | ||
|
|
0a7f70757d | ||
|
|
29dc7e040e | ||
|
|
c8387011cc | ||
|
|
5061de70f8 | ||
|
|
ea3ba25da5 | ||
|
|
bd7125fab8 | ||
|
|
94dd1fe677 | ||
|
|
fa6c9b1711 | ||
|
|
f4eacfafe2 | ||
|
|
f8c816dc38 | ||
|
|
e2d9049e45 | ||
|
|
1b0049e342 | ||
|
|
87a5d4f81d | ||
|
|
d6ec7b24ec | ||
|
|
194c91cf25 | ||
|
|
68797e4fb5 | ||
|
|
af4ae1cbc3 | ||
|
|
c42abb05da |
+61
-36
@@ -316,13 +316,33 @@ def attach_common(conn, resource, items):
|
||||
return items
|
||||
|
||||
|
||||
def monthly_finance(conn):
|
||||
def monthly_finance(conn, tenant="科普·无界"):
|
||||
from datetime import date
|
||||
today = date.today()
|
||||
# 6 months: 3 before + current + 2 after
|
||||
from dateutil.relativedelta import relativedelta
|
||||
start = today + relativedelta(months=-3)
|
||||
months = []
|
||||
for i in range(6):
|
||||
m = start + relativedelta(months=i)
|
||||
months.append(m.strftime("%Y-%m"))
|
||||
data = []
|
||||
for item in rows(conn, "SELECT DISTINCT month FROM finance_records ORDER BY month"):
|
||||
month = item["month"]
|
||||
revenue = one(conn, "SELECT COALESCE(SUM(amount),0) AS v FROM finance_records WHERE month=? AND record_type='revenue'", (month,))["v"]
|
||||
cost = one(conn, "SELECT COALESCE(SUM(amount),0) AS v FROM finance_records WHERE month=? AND record_type='cost_expense'", (month,))["v"]
|
||||
data.append({"month": month, "revenue": revenue, "gross_profit": revenue - cost, "cost_expense": cost, "net_profit": revenue - cost})
|
||||
for month in months:
|
||||
col_month = month.replace("-", "_")
|
||||
col_rev = f"rev_{col_month}"
|
||||
col_gross = f"gross_{col_month}"
|
||||
# Only project_finances has columns for 2026-06 through 2026-09
|
||||
if month in ["2026-06", "2026-07", "2026-08", "2026-09"]:
|
||||
revenue = one(conn, f"SELECT COALESCE(SUM({col_rev}),0) AS v FROM project_finances WHERE tenant=?", (tenant,))["v"]
|
||||
gross = one(conn, f"SELECT COALESCE(SUM({col_gross}),0) AS v FROM project_finances WHERE tenant=?", (tenant,))["v"]
|
||||
else:
|
||||
revenue = 0
|
||||
gross = 0
|
||||
data.append({
|
||||
"month": month, "revenue": revenue,
|
||||
"labor": 0, "expense": 0, "purchase": 0,
|
||||
"net_profit": gross,
|
||||
})
|
||||
return data
|
||||
|
||||
|
||||
@@ -333,25 +353,28 @@ def index():
|
||||
|
||||
@app.route("/api/bootstrap")
|
||||
def bootstrap():
|
||||
tenant = request.args.get("tenant", "科普·无界")
|
||||
conn = db()
|
||||
try:
|
||||
sales = attach_common(conn, "sales", rows(conn, "SELECT * FROM sales_leads ORDER BY id DESC"))
|
||||
proposals = attach_common(conn, "proposals", rows(conn, "SELECT * FROM business_proposals ORDER BY id DESC"))
|
||||
operations = attach_common(conn, "operations", rows(conn, "SELECT * FROM operation_projects ORDER BY id DESC"))
|
||||
products = attach_common(conn, "products", rows(conn, "SELECT * FROM product_versions ORDER BY id DESC"))
|
||||
finance = rows(conn, "SELECT * FROM finance_records ORDER BY month DESC, id DESC")
|
||||
def q(sql, *args):
|
||||
return rows(conn, sql, args)
|
||||
sales = attach_common(conn, "sales", q("SELECT * FROM sales_leads WHERE tenant=? ORDER BY id DESC", tenant))
|
||||
proposals = attach_common(conn, "proposals", q("SELECT * FROM business_proposals WHERE tenant=? ORDER BY id DESC", tenant))
|
||||
operations = attach_common(conn, "operations", q("SELECT * FROM operation_projects WHERE tenant=? ORDER BY id DESC", tenant))
|
||||
products = attach_common(conn, "products", q("SELECT * FROM product_versions WHERE tenant=? ORDER BY id DESC", tenant))
|
||||
finance = q("SELECT * FROM finance_records WHERE tenant=? ORDER BY month DESC, id DESC", tenant)
|
||||
tasks = q("SELECT * FROM project_tasks WHERE tenant=? ORDER BY phase, sort_order, id", tenant)
|
||||
pfs = q("SELECT * FROM project_finances WHERE tenant=? ORDER BY id DESC", tenant)
|
||||
current_month = "2026-06"
|
||||
# Finance aggregates
|
||||
def sum_finance(months, rtype):
|
||||
return sum(x["amount"] for x in finance if x["month"] in months and x["record_type"] == rtype)
|
||||
months_2026 = [f"2026-{m:02d}" for m in range(1,7)]
|
||||
months_q2 = ["2026-04","2026-05","2026-06"]
|
||||
revenue_annual = sum_finance(months_2026, "revenue")
|
||||
cost_annual = sum_finance(months_2026, "cost_expense")
|
||||
revenue_q2 = sum_finance(months_q2, "revenue")
|
||||
cost_q2 = sum_finance(months_q2, "cost_expense")
|
||||
revenue_month = sum_finance([current_month], "revenue")
|
||||
cost_month = sum_finance([current_month], "cost_expense")
|
||||
# Finance aggregates — from project_finances (project-based)
|
||||
def pf_sum(field):
|
||||
return sum(x[field] or 0 for x in pfs)
|
||||
rev_month = pf_sum("rev_2026_06")
|
||||
gross_month = pf_sum("gross_2026_06")
|
||||
rev_q2 = pf_sum("rev_2026_06")
|
||||
gross_q2 = pf_sum("gross_2026_06")
|
||||
rev_annual = rev_q2
|
||||
gross_annual = gross_q2
|
||||
# Contract aggregates — time-based
|
||||
signed_amount = sum(x["expected_contract_amount"] or 0 for x in operations if x["project_status"] == "已签约")
|
||||
from datetime import date
|
||||
@@ -374,8 +397,9 @@ def bootstrap():
|
||||
"active_sales": len([x for x in sales if x["status"] in ["待跟进", "跟进中", "方案中", "商务谈判"]]),
|
||||
"execution_projects": len([x for x in operations if x["project_type"] == "execution"]),
|
||||
"risk_projects": len([x for x in operations if x["project_status"] == "有风险" or x["risks"]]),
|
||||
"monthly_revenue": revenue_month,
|
||||
"monthly_net_profit": revenue_month - cost_month,
|
||||
"monthly_revenue": rev_month,
|
||||
"monthly_net_profit": gross_month,
|
||||
"monthly_gross": gross_month,
|
||||
"upcoming_products": len([x for x in products if x["status"] in ["规划中", "设计中", "开发中", "测试中"]]),
|
||||
"total_projects": len(operations),
|
||||
"total_proposals": len(proposals),
|
||||
@@ -386,27 +410,28 @@ def bootstrap():
|
||||
"signed_q2": signed_q2,
|
||||
"signed_month": signed_month,
|
||||
"pipeline_amount": pipeline_amount,
|
||||
"revenue_annual": revenue_annual,
|
||||
"revenue_q2": revenue_q2,
|
||||
"gross_annual": revenue_annual - cost_annual,
|
||||
"gross_q2": revenue_q2 - cost_q2,
|
||||
"revenue_annual": rev_annual,
|
||||
"revenue_q2": rev_q2,
|
||||
"gross_annual": gross_annual,
|
||||
"gross_q2": gross_q2,
|
||||
"signed_not_executed": signed_not_executed,
|
||||
},
|
||||
"recent": rows(conn, "SELECT * FROM follow_up_records ORDER BY id DESC LIMIT 8"),
|
||||
"recent": q("SELECT * FROM follow_up_records WHERE tenant=? ORDER BY id DESC LIMIT 8", tenant),
|
||||
"risks": [{"title": "执行提醒", "content": x["next_action"]} for x in operations if x["next_action"]][:5],
|
||||
}
|
||||
return jsonify({"summary": summary, "sales": sales, "proposals": proposals, "operations": operations, "products": products, "finance": finance, "financeMonthly": monthly_finance(conn), "tasks": rows(conn, "SELECT * FROM project_tasks ORDER BY phase, sort_order, id")})
|
||||
return jsonify({"summary": summary, "sales": sales, "proposals": proposals, "operations": operations, "products": products, "finance": finance, "projectFinances": pfs, "financeMonthly": monthly_finance(conn, tenant), "tasks": tasks, "tenant": tenant, "tenants": ["科普·无界","科研·无界","医患·无界"]})
|
||||
finally:
|
||||
conn.close()
|
||||
|
||||
|
||||
TABLES = {
|
||||
"sales": ("sales_leads", ["target_customer", "priority", "status"]),
|
||||
"proposals": ("business_proposals", ["customer_or_project_name", "version", "description", "status", "created_date"]),
|
||||
"operations": ("operation_projects", ["project_name", "project_version", "project_type", "project_status", "current_stage", "owner", "target_customer", "customer_need", "expected_contract_amount", "expected_sign_date", "sign_probability", "next_action", "sop_stage", "execution_progress", "current_deliverable", "risks", "notes"]),
|
||||
"products": ("product_versions", ["product_name", "version", "version_goal", "feature_list", "launch_date", "status", "platform", "notes"]),
|
||||
"finance": ("finance_records", ["month", "project_name", "record_type", "category", "amount", "occurred_date", "notes"]),
|
||||
"tasks": ("project_tasks", ["project_id", "phase", "milestone", "task", "owner", "due_date", "blockers", "notes", "status", "sort_order"]),
|
||||
"sales": ("sales_leads", ["target_customer", "priority", "status", "tenant"]),
|
||||
"proposals": ("business_proposals", ["customer_or_project_name", "version", "description", "status", "created_date", "tenant"]),
|
||||
"operations": ("operation_projects", ["project_name", "project_version", "project_type", "project_status", "current_stage", "owner", "target_customer", "customer_need", "expected_contract_amount", "expected_sign_date", "sign_probability", "next_action", "sop_stage", "execution_progress", "current_deliverable", "risks", "notes", "tenant"]),
|
||||
"products": ("product_versions", ["product_name", "version", "version_goal", "feature_list", "launch_date", "status", "platform", "notes", "tenant"]),
|
||||
"finance": ("finance_records", ["month", "project_name", "record_type", "category", "amount", "occurred_date", "notes", "tenant"]),
|
||||
"tasks": ("project_tasks", ["project_id", "phase", "milestone", "task", "owner", "due_date", "blockers", "notes", "status", "sort_order", "tenant"]),
|
||||
"projectFinances": ("project_finances", ["project_id", "tenant", "business_type", "customer_name", "sign_amount", "sign_month", "status", "sales_person", "rev_2026_06", "rev_2026_07", "rev_2026_08", "rev_2026_09", "gross_2026_06", "gross_2026_07", "gross_2026_08", "gross_2026_09"]),
|
||||
}
|
||||
|
||||
|
||||
|
||||
@@ -1 +1,2 @@
|
||||
Flask==3.0.3
|
||||
python-dateutil==2.9.0
|
||||
|
||||
+134
-18
File diff suppressed because one or more lines are too long
@@ -554,6 +554,9 @@ td {
|
||||
.task-row:hover { background: #f8fafc; }
|
||||
.task-dot { display: flex; color: #cbd5e1; flex-shrink: 0; cursor: pointer; }
|
||||
.task-dot:hover { color: #6366f1; }
|
||||
.task-grip { display: flex; color: #cbd5e1; flex-shrink: 0; cursor: grab; }
|
||||
.task-grip:hover { color: #94a3b8; }
|
||||
.task-grip:active { cursor: grabbing; }
|
||||
.task-main { flex: 1; min-width: 0; display: flex; flex-direction: column; gap: 2px; }
|
||||
.task-name { color: #1e293b; font-size: 13px; }
|
||||
.task-desc { color: #94a3b8; font-size: 12px; word-wrap: break-word; overflow-wrap: break-word; }
|
||||
|
||||
+12
-3
@@ -27,9 +27,18 @@
|
||||
</head>
|
||||
<body class="min-h-screen bg-slate-50 text-slate-950">
|
||||
<header class="topbar border-b border-slate-200 bg-white px-8 py-5">
|
||||
<div>
|
||||
<p class="eyebrow text-xs font-semibold uppercase tracking-[0.18em] text-blue-700">OPC Manager · 单用户 · 单项目</p>
|
||||
<h1 class="mt-1 text-2xl font-semibold">科普(慰心斋)OPC 工作台</h1>
|
||||
<div class="flex items-center gap-3">
|
||||
<div>
|
||||
<p class="eyebrow text-xs font-semibold uppercase tracking-[0.18em] text-blue-700">OPC Manager</p>
|
||||
<div class="flex items-center gap-3 mt-1">
|
||||
<h1 class="text-2xl font-semibold" id="workspaceTitle">科普 OPC 工作台</h1>
|
||||
<select id="tenantSelect" class="rounded-md border border-slate-200 bg-white px-3 py-1.5 text-sm font-medium text-slate-700 outline-none focus:border-blue-500" onchange="switchTenant(this.value)">
|
||||
<option value="科普·无界">科普·无界</option>
|
||||
<option value="科研·无界">科研·无界</option>
|
||||
<option value="医患·无界">医患·无界</option>
|
||||
</select>
|
||||
</div>
|
||||
</div>
|
||||
</div>
|
||||
<button id="refreshBtn" class="rounded-md border border-slate-200 bg-white px-3 py-2 text-sm font-medium hover:bg-slate-50" type="button"><i data-lucide="refresh-cw"></i>刷新</button>
|
||||
</header>
|
||||
|
||||
Reference in New Issue
Block a user