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

graph LR
  subgraph Data
    A[手机 APP / PC 表单] -->|事件/检查| B[采集 API]
    C[第三方系统] -->|接口/ETL| B
  end
  B --> D[消息队列 Kafka/Rabbit]
  D --> E[业务服务：隐患/检查/培训/事故微服务]
  E --> F[规则引擎 / 评分服务]
  E --> G[数据库：Postgres / MySQL]
  F --> G
  G --> H[分析服务 / OLAP（ClickHouse）]
  H --> I[看板服务（React + Chart）]
  I --> J[管理端/移动端]
  F --> K[考核导出服务 -> HR 系统 / Excel]

flowchart TD
  A[巡检/隐患上报/事故上报/培训记录] --> B[事件入库]
  B --> C{责任人分配?}
  C -->|是| D[指派责任人并开始整改]
  C -->|否| E[分配给主管或安全员]
  D --> F[整改执行 -> 提交整改报告]
  F --> G[验收]
  G --> H[事件闭环并计入指标]
  H --> I[规则引擎计算分数]
  I --> J[生成考核（周/月/季）]
  J --> K[送审 -> HR / 主管复核]
  K --> L[发布考核结果 -> 看板/导出]

-- 事件表
CREATE TABLE ehs_event (
  id BIGINT PRIMARY KEY AUTO_INCREMENT,
  event_type VARCHAR(32), -- hazard, incident, near_miss
  title VARCHAR(255),
  description TEXT,
  site_id BIGINT,
  reported_by BIGINT,
  reported_at DATETIME,
  severity INT,
  status VARCHAR(32), -- open, in_progress, closed
  responsible_person BIGINT,
  department_id BIGINT,
  closed_at DATETIME,
  created_at DATETIME DEFAULT CURRENT_TIMESTAMP,
  updated_at DATETIME DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP
);
-- 指标定义表
CREATE TABLE ehs_metric (
  id BIGINT PRIMARY KEY AUTO_INCREMENT,
  code VARCHAR(64) UNIQUE,
  name VARCHAR(128),
  metric_type VARCHAR(32), -- rate, count, avg_time, score
  weight DECIMAL(5,2) DEFAULT 1.0,
  config JSON, -- 存放规则/阈值等
  created_at DATETIME DEFAULT CURRENT_TIMESTAMP
);
-- 考核快照表
CREATE TABLE ehs_score_snapshot (
  id BIGINT PRIMARY KEY AUTO_INCREMENT,
  user_id BIGINT,
  department_id BIGINT,
  period_start DATE,
  period_end DATE,
  total_score DECIMAL(6,2),
  details JSON, -- 每个指标得分明细
  created_at DATETIME DEFAULT CURRENT_TIMESTAMP
);

// scoreEngine.js - 简化示例
function calcScores(events, checks, trainings, rules, weightConfig) {
  // events: array of event objects within period
  // rules: array of rule objects (code, type, threshold, penalty)
  const userScores = {}; // { userId: { base:100, details: [] } }
  // 初始化每人基础分 100
  const users = new Set();
  events.forEach(e => users.add(e.responsible_person));
  checks.forEach(c => users.add(c.inspector_id));
  users.forEach(u => userScores[u] = { total: 100, details: [] });
  // 隐患超期扣分
  events.forEach(e => {
    if (e.status === 'open') {
      const daysOpen = (now - new Date(e.reported_at)) / (1000*60*60*24);
      const sla = e.sla_days || 3;
      if (daysOpen > sla) {
        const d = Math.ceil(daysOpen - sla);
        const penalty = Math.min(20, 5 * d); // 每超1天扣5分，最多20分
        userScores[e.responsible_person].total -= penalty;
        userScores[e.responsible_person].details.push({
          reason: '隐患超期',
          penalty
        });
      }
    }
  });
  // 检查低分扣分（按检查分配到部门负责人）
  checks.forEach(c => {
    if (c.score < 80) {
      const penalty = 10;
      const owner = getDeptOwner(c.department_id);
      userScores[owner].total -= penalty;
      userScores[owner].details.push({ reason: '检查低分', penalty });
    }
  });
  // 培训未达标扣分
  trainings.forEach(t => {
    t.participants.forEach(p => {
      if (!p.passed) {
        userScores[p.user_id].total -= 2;
        userScores[p.user_id].details.push({ reason: '培训未通过', penalty: 2 });
      }
    });
  });
  // 最终裁剪与归一
  Object.keys(userScores).forEach(u => {
    userScores[u].total = Math.max(0, Math.min(100, userScores[u].total));
  });
  return userScores;
}

// Dashboard.jsx (简化)
import React, { useEffect, useState } from 'react';
import { Line, Bar } from 'react-chartjs-2';
export default function DeptDashboard({ deptId }) {
  const [data, setData] = useState(null);
  useEffect(() => {
    fetch(`/api/dashboard/department/${deptId}`)
      .then(r => r.json())
      .then(setData);
  }, [deptId]);
  if (!data) return <div>加载中...</div>;
  const rankData = {
    labels: data.ranking.map(r=>r.name),
    datasets: [{ label: '得分', data: data.ranking.map(r=>r.score) }]
  };
  const trendData = {
    labels: data.trend.map(t=>t.period),
    datasets: [{ label: '平均分', data: data.trend.map(t=>t.avg) }]
  };
  return (
    <div>
      <h3>{data.departmentName} - EHS 绩效看板</h3>
      <div style={{display:'flex', gap:20}}>
        <div style={{flex:1}}>
          <Bar data={rankData} />
        </div>
        <div style={{flex:1}}>
          <Line data={trendData} />
        </div>
      </div>
      <div>
        <h4>低分明细</h4>
        <ul>
          {data.lowDetails.map(d=>(
            <li key={d.id}>{d.title} - 责任人: {d.responsible} - 得分: {d.score}</li>
          ))}
        </ul>
      </div>
    </div>
  );
}

// runScoreJob.js
async function runScoreJob(periodStart, periodEnd) {
  const events = await db.query('SELECT * FROM ehs_event WHERE reported_at BETWEEN ? AND ?', [periodStart, periodEnd]);
  const checks = await db.query('SELECT * FROM ehs_check WHERE check_time BETWEEN ? AND ?', [periodStart, periodEnd]);
  const trainings = await db.query('SELECT * FROM ehs_training WHERE training_date BETWEEN ? AND ?', [periodStart, periodEnd]);
  const rules = await db.query('SELECT * FROM ehs_rule WHERE active=1');
  const userScores = calcScores(events, checks, trainings, rules);
  const snapshots = [];
  for (const userId in userScores) {
    snapshots.push({
      user_id: userId,
      department_id: getUserDept(userId),
      period_start: periodStart,
      period_end: periodEnd,
      total_score: userScores[userId].total,
      details: JSON.stringify(userScores[userId].details),
      created_at: new Date()
    });
  }
  await db.batchInsert('ehs_score_snapshot', snapshots);
  // 可触发通知：低于阈值的用户发送告警
}