如何开发工程项目部管理系统中的进度管理板块（附架构图+流程图+代码参考）

[现场移动/PC]      [管理端PC]
     \               /
      \  (REST/GraphQL)
       \           /
        [API Gateway (Auth, Rate Limit)]
                 |
        [Progress Service] --- [User/Perm Service]
                 |
      -----------------------------------
      |           |           |         |
   PostgreSQL   Redis     Kafka/Rabbit  文件存储(OSS)

-- projects 表（略）
CREATE TABLE projects (
  id SERIAL PRIMARY KEY,
  name TEXT NOT NULL,
  start_date DATE,
  end_date DATE,
  created_at TIMESTAMP DEFAULT now()
);
-- tasks/WBS 节点
CREATE TABLE tasks (
  id SERIAL PRIMARY KEY,
  project_id INT REFERENCES projects(id),
  parent_id INT NULL, -- WBS
  name TEXT NOT NULL,
  planned_start DATE,
  planned_end DATE,
  planned_duration INT,
  created_at TIMESTAMP DEFAULT now()
);
-- progress_entries：现场填报（支持日、周、月、总）
CREATE TABLE progress_entries (
  id SERIAL PRIMARY KEY,
  project_id INT REFERENCES projects(id),
  task_id INT REFERENCES tasks(id),
  entry_type VARCHAR(10) NOT NULL, -- 'day','week','month','total'
  period_start DATE NOT NULL,
  period_end DATE NOT NULL,
  progress_percent NUMERIC(5,2) NOT NULL, -- 0-100
  work_done TEXT,
  blocker TEXT,
  reported_by INT, -- user id
  reported_at TIMESTAMP DEFAULT now(),
  version INT DEFAULT 1 -- 乐观锁
);
-- indexes
CREATE INDEX idx_progress_project ON progress_entries(project_id, entry_type, period_start);

// server.js (简化)
const express = require('express');
const bodyParser = require('body-parser');
const { Pool } = require('pg');
const app = express();
app.use(bodyParser.json());
const pool = new Pool({ connectionString: process.env.DATABASE_URL });
// 简单错误包装
function asyncHandler(fn){ return (req,res,next)=>fn(req,res,next).catch(next); }
module.exports = { app, pool, asyncHandler };

// routes/progress.js (片段)
const express = require('express');
const { pool, asyncHandler } = require('../server');
const router = express.Router();
/**
 * POST /api/progress/day
 * body: { project_id, task_id, period_date, progress_percent, work_done, blocker, reported_by, client_idempotency_key }
 */
router.post('/day', asyncHandler(async (req, res) => {
  const { project_id, task_id, period_date, progress_percent, work_done, blocker, reported_by, client_key } = req.body;
  if (!project_id || !task_id || !period_date) return res.status(400).json({ error: 'missing fields' });
  // 幂等：尝试插入到 idempotency 表（简化）
  const client = await pool.connect();
  try {
    await client.query('BEGIN');
    // 插入进度条目
    const insertSql = `INSERT INTO progress_entries
      (project_id, task_id, entry_type, period_start, period_end, progress_percent, work_done, blocker, reported_by)
      VALUES ($1,$2,'day',$3,$3,$4,$5,$6,$7) RETURNING *`;
    const r = await client.query(insertSql, [project_id, task_id, period_date, progress_percent, work_done, blocker, reported_by]);
    // 推送异步消息（伪）
    // await publishToQueue('progress.created', r.rows[0]);
    await client.query('COMMIT');
    res.json({ ok: true, entry: r.rows[0] });
  } catch(e){
    await client.query('ROLLBACK');
    throw e;
  } finally { client.release(); }
}));
module.exports = router;

// POST /api/plan/week
// body: { project_id, week_start, week_end, items: [{task_id, planned_percent}], created_by }
router.post('/plan/week', asyncHandler(async (req,res) => {
  const { project_id, week_start, week_end, items, created_by } = req.body;
  const client = await pool.connect();
  try {
    await client.query('BEGIN');
    const planRes = await client.query(`INSERT INTO progress_plans (project_id, plan_type, period_start, period_end, created_by) VALUES ($1,'week',$2,$3,$4) RETURNING id`, [project_id, week_start, week_end, created_by]);
    const planId = planRes.rows[0].id;
    const insertItemSql = `INSERT INTO progress_plan_items (plan_id, task_id, planned_percent) VALUES ($1,$2,$3)`;
    for (const it of items) {
      await client.query(insertItemSql, [planId, it.task_id, it.planned_percent]);
    }
    await client.query('COMMIT');
    res.json({ ok:true, plan_id: planId });
  } catch(e) {
    await client.query('ROLLBACK'); throw e;
  } finally { client.release(); }
}));

// POST /api/plan/month/submit
// body: { project_id, month_start, items: [...] }
router.post('/plan/month/submit', asyncHandler(async (req,res) => {
  const { project_id, month_start, items, created_by } = req.body;
  const client = await pool.connect();
  try {
    await client.query('BEGIN');
    const planR = await client.query(`INSERT INTO progress_plans (project_id, plan_type, period_start, period_end, created_by, status) VALUES ($1,'month',$2,$3,$4,'draft') RETURNING id`, [project_id, month_start, getMonthEnd(month_start), created_by]);
    const planId = planR.rows[0].id;
    for (const it of items) await client.query(`INSERT INTO progress_plan_items (plan_id, task_id, planned_percent) VALUES ($1,$2,$3)`, [planId, it.task_id, it.planned_percent]);
    // 提交审批：更新状态并通知审批人（伪）
    await client.query(`UPDATE progress_plans SET status='pending_approval' WHERE id=$1`, [planId]);
    // notify approver...
    await client.query('COMMIT');
    res.json({ ok:true, plan_id:planId });
  } catch(e){ await client.query('ROLLBACK'); throw e; } finally { client.release(); }
}));

// POST /api/plan/total
// body: { project_id, milestones: [{name, planned_date, description}], created_by }
router.post('/plan/total', asyncHandler(async (req,res) => {
  const { project_id, milestones, created_by } = req.body;
  const client = await pool.connect();
  try {
    await client.query('BEGIN');
    const r = await client.query(`INSERT INTO total_plans (project_id, created_by) VALUES ($1,$2) RETURNING id`, [project_id, created_by]);
    const pid = r.rows[0].id;
    for (const m of milestones) await client.query(`INSERT INTO total_plan_milestones (plan_id, name, planned_date, description) VALUES ($1,$2,$3,$4)`, [pid, m.name, m.planned_date, m.description]);
    await client.query('COMMIT');
    res.json({ ok:true, plan_id: pid });
  } catch(e){ await client.query('ROLLBACK'); throw e; } finally { client.release(); }
}));