如何开发一套EHS健康安全环境管理系统中的事故管理板块？（附架构图+流程图+代码参考）

css
[事故发生]
     ↓
[员工提交事故登记表]
     ↓
[部门经理审核 → 退回修改 或 分配责任人]
     ↓
[责任人整改并提交整改报告]
     ↓
[安全主管复核]
     ↓
[关闭事故/存档]

bash
┌──────────────────┐
│   前端（Vue3）    │
│  - 登记表单        │
│  - 看板可视化       │
│  - 数据分析图表     │
└─────────┬────────┘
          │ REST API
┌─────────▼────────┐
│   后端（Node.js） │
│  - API 接口层     │
│  - 业务逻辑层     │
│  - 权限认证 JWT   │
└─────────┬────────┘
          │ SQL
┌─────────▼────────┐
│  数据库（MySQL）  │
│  - accident       │
│  - users          │
│  - dept           │
└──────────────────┘

javascript
/* === 数据库 SQL === */
-- 创建用户表
CREATE TABLE users (
  id INT PRIMARY KEY AUTO_INCREMENT,
  name VARCHAR(50),
  role ENUM('employee','manager','supervisor')
);
-- 创建事故表
CREATE TABLE accident (
  id INT PRIMARY KEY AUTO_INCREMENT,
  title VARCHAR(100),
  description TEXT,
  type ENUM('person','equipment','environment'),
  location VARCHAR(100),
  status ENUM('pending','in_progress','closed') DEFAULT 'pending',
  reporter_id INT,
  assigned_to INT,
  created_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP
);
/* === 后端 Node.js Express === */
const express = require('express');
const mysql = require('mysql2/promise');
const app = express();
app.use(express.json());
const db = mysql.createPool({ host: 'localhost', user: 'root', password: '123456', database: 'ehs' });
// 提交事故
app.post('/accidents', async (req, res) => {
  const { title, description, type, location, reporter_id } = req.body;
  const [result] = await db.execute(
    'INSERT INTO accident (title, description, type, location, reporter_id) VALUES (?,?,?,?,?)',
    [title, description, type, location, reporter_id]
  );
  res.json({ id: result.insertId, message: '事故已提交' });
});
// 获取事故列表
app.get('/accidents', async (req, res) => {
  const [rows] = await db.execute('SELECT * FROM accident ORDER BY created_at DESC');
  res.json(rows);
});
// 更新事故状态
app.put('/accidents/:id/status', async (req, res) => {
  const { status, assigned_to } = req.body;
  await db.execute('UPDATE accident SET status=?, assigned_to=? WHERE id=?', [status, assigned_to, req.params.id]);
  res.json({ message: '状态已更新' });
});
app.listen(3000, () => console.log('Server running on port 3000'));
/* === 前端 Vue3 === */
<template>
  <div>
    <h1>事故登记</h1>
    <form @submit.prevent="submitAccident">
      <input v-model="form.title" placeholder="事故标题" required />
      <textarea v-model="form.description" placeholder="描述" required></textarea>
      <select v-model="form.type">
        <option value="person">人身</option>
        <option value="equipment">设备</option>
        <option value="environment">环境</option>
      </select>
      <input v-model="form.location" placeholder="地点" required />
      <button type="submit">提交</button>
    </form>
    <h2>事故列表</h2>
    <ul>
      <li v-for="a in accidents" :key="a.id">
        {{a.title}} - {{a.status}}
      </li>
    </ul>
  </div>
</template>
<script setup>
import { ref, onMounted } from 'vue';
const form = ref({ title: '', description: '', type: 'person', location: '', reporter_id: 1 });
const accidents = ref([]);
async function submitAccident() {
  await fetch('/accidents', { method: 'POST', headers: { 'Content-Type': 'application/json' }, body: JSON.stringify(form.value) });
  loadAccidents();
}
async function loadAccidents() {
  const res = await fetch('/accidents');
  accidents.value = await res.json();
}
onMounted(loadAccidents);
</script>