|
|
|
|
@@ -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, 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"]),
|
|
|
|
|
"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"]),
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
@@ -489,6 +514,19 @@ def delete_followup(followup_id):
|
|
|
|
|
conn.close()
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
@app.route("/api/tasks/batch-sort", methods=["POST"])
|
|
|
|
|
def batch_sort_tasks():
|
|
|
|
|
conn = db()
|
|
|
|
|
try:
|
|
|
|
|
items = request.get_json(force=True).get("items", [])
|
|
|
|
|
for item in items:
|
|
|
|
|
conn.execute("UPDATE project_tasks SET sort_order=? WHERE id=?", (item["sort_order"], item["id"]))
|
|
|
|
|
conn.commit()
|
|
|
|
|
return jsonify({"ok": True})
|
|
|
|
|
finally:
|
|
|
|
|
conn.close()
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
@app.route("/api/files/upload", methods=["POST"])
|
|
|
|
|
def upload_file():
|
|
|
|
|
file = request.files["file"]
|
|
|
|
|
|
