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

css
[用户浏览器 React SPA] <--HTTPS--> [API Gateway / Nginx] --> [Auth Service (JWT/OAuth2)]
                                                         --> [EHS Core Service (Express)]
                                                         --> [Device Service]
                                                         --> [Reporting Service]
                                                         --> [DB: PostgreSQL]
                                                         --> [Search: Elasticsearch]
                                                         --> [Queue: RabbitMQ]
                                                         --> [Storage: S3]

sql
-- 基础信息表
CREATE TABLE dept (
  id SERIAL PRIMARY KEY,
  name VARCHAR(200) NOT NULL,
  parent_id INT REFERENCES dept(id),
  created_at TIMESTAMP DEFAULT now()
);
CREATE TABLE employee (
  id SERIAL PRIMARY KEY,
  emp_no VARCHAR(50),
  name VARCHAR(100),
  dept_id INT REFERENCES dept(id),
  role VARCHAR(50),
  mobile VARCHAR(30),
  email VARCHAR(200),
  extra JSONB
);
-- 隐患排查表
CREATE TABLE hazard (
  id SERIAL PRIMARY KEY,
  title VARCHAR(255),
  description TEXT,
  location VARCHAR(255),
  reporter_id INT REFERENCES employee(id),
  assignee_id INT REFERENCES employee(id),
  severity INT,
  status VARCHAR(30),
  attachments JSONB,
  created_at TIMESTAMP DEFAULT now(),
  updated_at TIMESTAMP DEFAULT now()
);
-- 事故管理表
CREATE TABLE accident (
  id SERIAL PRIMARY KEY,
  title VARCHAR(255),
  occur_time TIMESTAMP,
  location VARCHAR(255),
  involved_people JSONB,
  severity INT,
  report TEXT,
  attachments JSONB,
  status VARCHAR(30),
  created_by INT REFERENCES employee(id)
);

js
const express = require('express');
const bodyParser = require('body-parser');
const app = express();
app.use(bodyParser.json());
// 路由管理
const hazardRouter = require('./routes/hazard');
app.use('/api/hazard', hazardRouter);
// 启动服务器
app.listen(3000, () => console.log('EHS API running on port 3000'));

js
const express = require('express');
const router = express.Router();
const db = require('../db'); // PostgreSQL 客户端
// 隐患上报
router.post('/', async (req, res) => {
  const { title, description, location, reporter_id, severity } = req.body;
  try {
    const result = await db.query(
      'INSERT INTO hazard(title, description, location, reporter_id, severity, status, created_at) VALUES ($1, $2, $3, $4, $5, $6, now()) RETURNING *',
      [title, description, location, reporter_id, severity, 'reported']
    );
    res.json(result.rows[0]);
  } catch (err) {
    res.status(500).send('Error creating hazard report');
  }
});
module.exports = router;

HazardReport.js
jsx
import React, { useState } from 'react';
import axios from 'axios';
function HazardReport() {
  const [title, setTitle] = useState('');
  const [description, setDescription] = useState('');
  const [location, setLocation] = useState('');
  const [severity, setSeverity] = useState(1);
  const submit = async () => {
    const payload = { title, description, location, reporter_id: 1, severity };
    try {
      const res = await axios.post('/api/hazard', payload);
      alert('隐患报告已提交，ID: ' + res.data.id);
    } catch (err) {
      alert('提交失败，请重试');
    }
  };
  return (
    <div>
      <h3>隐患上报</h3>
      <input 
        type="text" 
        value={title} 
        onChange={e => setTitle(e.target.value)} 
        placeholder="隐患标题"
      />
      <textarea 
        value={description} 
        onChange={e => setDescription(e.target.value)} 
        placeholder="隐患描述"
      />
      <input 
        type="text" 
        value={location} 
        onChange={e => setLocation(e.target.value)} 
        placeholder="隐患位置"
      />
      <button onClick={submit}>提交上报</button>
    </div>
  );
}
export default HazardReport;