如何物业管理（园区式）系统的行政综合板块？（附架构图+流程图+代码参考）

yaml
客户端（Web / H5 / 小程序 / 管理端）
      |
      v
API 网关（鉴权、限流、日志）
      |
      v
微服务 / 单体后端（Auth、物业核心、行政综合、财务、报修）
      |
      v

mermaid
graph LR
  A[客户端：Web/H5/小程序] --> B[API 网关]
  B --> C{Auth Service}
  B --> D{物业核心服务}
  B --> E{行政综合服务}
  B --> F{财务服务}
  D --> DB[关系型数据库（MySQL）]
  E --> DB2[关系型（MySQL）]
  subgraph infra
    Redis[Redis Cache]
    OSS[对象存储 S3/OSS]
    MQ[消息队列 RabbitMQ]
    ES[搜索/分析 ElasticSearch]
  end
  D --> Redis
  E --> OSS
  D --> MQ
  F --> ES

sql
CREATE TABLE announcements (
  id BIGINT PRIMARY KEY AUTO_INCREMENT,
  title VARCHAR(255) NOT NULL,
  content TEXT NOT NULL,
  target_scope JSON, -- e.g., {"groups":["all","owners"], "tags":[...]}
  attachments JSON,
  status ENUM('draft','pending','published','archived'),
  publish_time DATETIME,
  created_by BIGINT,
  created_at DATETIME DEFAULT CURRENT_TIMESTAMP,
  updated_at DATETIME
);
CREATE TABLE announcement_reads (
  id BIGINT PRIMARY KEY AUTO_INCREMENT,
  announcement_id BIGINT,
  user_id BIGINT,
  read_at DATETIME
);

js
// routes/announcement.js
const express = require('express');
const router = express.Router();
const db = require('../db'); // 假设有 db.query
// 发布（草稿/定时/直接发布）
router.post('/', async (req,res)=>{
  const { title, content, target_scope, attachments, publish_time } = req.body;
  const sql = `INSERT INTO announcements (title,content,target_scope,attachments,publish_time,status,created_by) VALUES (?, ?, ?, ?, ?, ?, ?)`;
  const status = publish_time ? 'draft' : 'published';
  const result = await db.query(sql, [title, content, JSON.stringify(target_scope), JSON.stringify(attachments), publish_time, status, req.user.id]);
  res.json({ id: result.insertId });
});
// 查看并记录阅读
router.post('/:id/read', async (req,res)=>{
  const id = req.params.id;
  await db.query(`INSERT INTO announcement_reads (announcement_id,user_id,read_at) VALUES (?, ?, NOW())`, [id, req.user.id]);
  res.sendStatus(200);
});
module.exports = router;

jsx
// AnnouncementItem.jsx
export default function AnnouncementItem({ item }) {
  const onRead = async () => {
    await fetch(`/api/announcements/${item.id}/read`, { method: 'POST' });
    // 打开 modal 显示内容
  };
  return (
    <div className="card">
      <h3>{item.title}</h3>
      <p>{item.summary}</p>
      <button onClick={onRead}>查看</button>
    </div>
  );
}

sql
CREATE TABLE weekly_reports (
  id BIGINT PRIMARY KEY AUTO_INCREMENT,
  project_id BIGINT,
  week_start DATE,
  week_end DATE,
  metrics JSON, -- e.g., {"repairs":12,"receipts":20000,"consumables_used":50}
  editor_id BIGINT,
  status ENUM('draft','pending','approved','published'),
  created_at DATETIME
);

js
// weeklyJob.js
async function generateWeeklyReports() {
  const projects = await db.query('SELECT id FROM projects');
  for (const p of projects) {
    const metrics = await gatherMetrics(p.id);
    await db.query('INSERT INTO weekly_reports (project_id,week_start,week_end,metrics,status) VALUES (?, ?, ?, ?, ?)', [p.id, start, end, JSON.stringify(metrics), 'draft']);
  }
}

sql
CREATE TABLE employees (
  id BIGINT PRIMARY KEY AUTO_INCREMENT,
  name VARCHAR(100),
  id_card VARCHAR(50),
  phone VARCHAR(20),
  position VARCHAR(100),
  status ENUM('active','on_leave','resigned'),
  join_date DATE,
  attachments JSON, -- 合同等
  created_at DATETIME
);

sql
CREATE TABLE assets (
  id BIGINT PRIMARY KEY AUTO_INCREMENT,
  code VARCHAR(50), -- 资产编号或二维码
  name VARCHAR(255),
  category VARCHAR(100),
  supplier_id BIGINT,
  purchase_date DATE,
  warranty_until DATE,
  status ENUM('in_stock','in_use','disposed'),
  location VARCHAR(255),
  created_at DATETIME
);

sql
CREATE TABLE consumables (
  id BIGINT PRIMARY KEY AUTO_INCREMENT,
  sku VARCHAR(50),
  name VARCHAR(255),
  unit VARCHAR(20),
  stock INT,
  min_stock INT,
  category VARCHAR(100)
);
CREATE TABLE consumable_requests (
  id BIGINT PRIMARY KEY AUTO_INCREMENT,
  requester_id BIGINT,
  project_id BIGINT,
  items JSON, -- [{sku, qty, reason}]
  status ENUM('pending','approved','rejected','completed'),
  created_at DATETIME
);
CREATE TABLE consumable_outs (
  id BIGINT PRIMARY KEY AUTO_INCREMENT,
  request_id BIGINT,
  out_items JSON,
  operator_id BIGINT,
  out_time DATETIME
);

js
// 申请
router.post('/requests', async (req,res)=>{
  const { items, project_id } = req.body;
  await db.query('INSERT INTO consumable_requests (requester_id, project_id, items, status) VALUES (?, ?, ?, ?)', [req.user.id, project_id, JSON.stringify(items), 'pending']);
  res.json({ ok: true });
});
// 审批并出库（仓库操作）
router.post('/requests/:id/approve', async (req,res)=>{
  const id = req.params.id;
  const request = await db.query('SELECT * FROM consumable_requests WHERE id=?', [id]);
  // 简化库存扣减逻辑
  const items = JSON.parse(request.items);
  await db.beginTransaction();
  try {
    for (const it of items) {
      await db.query('UPDATE consumables SET stock = stock - ? WHERE sku = ?', [it.qty, it.sku]);
    }
    await db.query('UPDATE consumable_requests SET status = ? WHERE id = ?', ['approved', id]);
    await db.query('INSERT INTO consumable_outs (request_id, out_items, operator_id, out_time) VALUES (?, ?, ?, NOW())', [id, JSON.stringify(items), req.user.id]);
    await db.commit();
    res.json({ ok: true });
  } catch (err) {
    await db.rollback();
    res.status(500).json({ error: err.message });
  }
});

sql
CREATE TABLE rain_checkpoints (
  id BIGINT PRIMARY KEY AUTO_INCREMENT,
  name VARCHAR(255),
  lat DOUBLE,
  lng DOUBLE,
  risk_level ENUM('low','medium','high'),
  project_id BIGINT
);
CREATE TABLE rain_incidents (
  id BIGINT PRIMARY KEY AUTO_INCREMENT,
  checkpoint_id BIGINT,
  reporter_id BIGINT,
  description TEXT,
  photos JSON,
  status ENUM('reported','in_progress','resolved'),
  created_at DATETIME
);