260 lines
6.9 KiB
Markdown
260 lines
6.9 KiB
Markdown
|
|
# 数据完整性保障方案 - 万分之一错误率目标
|
|||
|
|
|
|||
|
|
## 📊 质量目标
|
|||
|
|
|
|||
|
|
- **系统错误率**: ≤ 0.01% (万分之一)
|
|||
|
|
- **财务数据准确率**: 100%
|
|||
|
|
- **核心业务数据一致性**: 100%
|
|||
|
|
|
|||
|
|
## 🏗️ 四层防护体系
|
|||
|
|
|
|||
|
|
### 第一层:数据库强约束(最后一道防线)
|
|||
|
|
|
|||
|
|
**文件**: `migrations/20260604_200000_data_integrity_constraints.sql`
|
|||
|
|
|
|||
|
|
#### 1.1 触发器校验
|
|||
|
|
- ✅ 计划数量一致性验证 (`validate_plan_quantity_consistency`)
|
|||
|
|
- ✅ 入库记录正数验证 (`validate_inventory_record_positive`)
|
|||
|
|
- ✅ 付款金额一致性验证 (`validate_payment_amount`)
|
|||
|
|
- ✅ 应付账款汇总验证 (`validate_accounts_payable_totals`)
|
|||
|
|
|
|||
|
|
#### 1.2 CHECK 约束
|
|||
|
|
```sql
|
|||
|
|
-- 入库记录非负
|
|||
|
|
CHECK (quantity >= 0 AND rolls >= 0 AND price_per_meter >= 0)
|
|||
|
|
|
|||
|
|
-- 付款金额非负
|
|||
|
|
CHECK (amount >= 0 AND quantity >= 0 AND price_per_meter >= 0)
|
|||
|
|
|
|||
|
|
-- 应付账款逻辑约束
|
|||
|
|
CHECK (paid_amount <= total_amount AND unpaid_amount <= total_amount)
|
|||
|
|
```
|
|||
|
|
|
|||
|
|
#### 1.3 审计日志
|
|||
|
|
所有关键表的数据变更自动记录到 `data_audit_logs` 表,包含:
|
|||
|
|
- 变更前后的值
|
|||
|
|
- 操作人
|
|||
|
|
- 操作时间
|
|||
|
|
- 验证是否通过
|
|||
|
|
|
|||
|
|
### 第二层:前端预检校验(写入前拦截)
|
|||
|
|
|
|||
|
|
**文件**: `src/utils/dataValidation.ts`
|
|||
|
|
|
|||
|
|
#### 2.1 校验函数
|
|||
|
|
```typescript
|
|||
|
|
// 入库记录校验
|
|||
|
|
validateInventoryRecord({ quantity, rolls, price_per_meter })
|
|||
|
|
|
|||
|
|
// 付款记录校验
|
|||
|
|
validatePayment({ amount, quantity, price_per_meter })
|
|||
|
|
|
|||
|
|
// 计划完成数量校验
|
|||
|
|
validatePlanCompletion({ target_quantity, completed_quantity })
|
|||
|
|
```
|
|||
|
|
|
|||
|
|
#### 2.2 安全写入包装器
|
|||
|
|
```typescript
|
|||
|
|
// 双重校验 + 写入后验证
|
|||
|
|
await safeInsertInventoryRecord(record);
|
|||
|
|
await safeInsertPayment(payment);
|
|||
|
|
```
|
|||
|
|
|
|||
|
|
### 第三层:自动化监控(持续检测)
|
|||
|
|
|
|||
|
|
#### 3.1 Edge Function 定期检查
|
|||
|
|
**文件**: `functions/data-integrity-check/index.ts`
|
|||
|
|
|
|||
|
|
- ⏰ 建议每小时执行一次
|
|||
|
|
- 🔍 检查所有核心表的数据一致性
|
|||
|
|
- 📊 计算错误率并与阈值对比
|
|||
|
|
- 🚨 超标时生成告警
|
|||
|
|
|
|||
|
|
**部署命令**:
|
|||
|
|
```bash
|
|||
|
|
meoo-cli cloud deploy-function -n data-integrity-check
|
|||
|
|
```
|
|||
|
|
|
|||
|
|
#### 3.2 数据库视图实时监控
|
|||
|
|
```sql
|
|||
|
|
-- 计划数量一致性检查
|
|||
|
|
SELECT * FROM v_plan_quantity_check WHERE check_result = '✗ 不一致';
|
|||
|
|
|
|||
|
|
-- 付款金额检查
|
|||
|
|
SELECT * FROM v_payment_check WHERE check_result = '✗ 不一致';
|
|||
|
|
|
|||
|
|
-- 应付账款检查
|
|||
|
|
SELECT * FROM v_accounts_payable_check WHERE check_result = '✗ 不一致';
|
|||
|
|
|
|||
|
|
-- 错误率监控
|
|||
|
|
SELECT * FROM v_error_rate_monitor WHERE error_rate_per_10k > 1;
|
|||
|
|
```
|
|||
|
|
|
|||
|
|
### 第四层:可视化监控面板
|
|||
|
|
|
|||
|
|
**文件**: `src/components/DataIntegrityDashboard.tsx`
|
|||
|
|
|
|||
|
|
功能:
|
|||
|
|
- 📈 实时显示系统数据质量状态
|
|||
|
|
- 🎯 错误率趋势图(近7天)
|
|||
|
|
- ⚠️ 异常项目高亮显示
|
|||
|
|
- 📋 最近失败记录列表
|
|||
|
|
- 🔄 支持手动触发检查
|
|||
|
|
|
|||
|
|
## 🚀 实施步骤
|
|||
|
|
|
|||
|
|
### 步骤1:执行数据库迁移
|
|||
|
|
|
|||
|
|
```bash
|
|||
|
|
# 读取迁移脚本内容
|
|||
|
|
cat migrations/20260604_200000_data_integrity_constraints.sql
|
|||
|
|
|
|||
|
|
# 分批执行(避免单次SQL过长)
|
|||
|
|
meoo-cli cloud migrate --name "data_integrity_constraints" \
|
|||
|
|
--changes "添加数据完整性强约束、触发器、审计日志和监控视图" \
|
|||
|
|
--sql "$(cat migrations/20260604_200000_data_integrity_constraints.sql)"
|
|||
|
|
```
|
|||
|
|
|
|||
|
|
### 步骤2:部署 Edge Function
|
|||
|
|
|
|||
|
|
```bash
|
|||
|
|
# 部署数据完整性检查函数
|
|||
|
|
meoo-cli cloud deploy-function -n data-integrity-check
|
|||
|
|
|
|||
|
|
# 配置定时任务(在 Supabase Dashboard 中设置)
|
|||
|
|
# 建议:每小时执行一次
|
|||
|
|
```
|
|||
|
|
|
|||
|
|
### 步骤3:集成前端组件
|
|||
|
|
|
|||
|
|
在管理后台或系统设置页面添加监控面板:
|
|||
|
|
|
|||
|
|
```tsx
|
|||
|
|
import { DataIntegrityDashboard } from './components/DataIntegrityDashboard';
|
|||
|
|
|
|||
|
|
// 在路由中添加
|
|||
|
|
<Route path="/admin/data-integrity" element={<DataIntegrityDashboard />} />
|
|||
|
|
```
|
|||
|
|
|
|||
|
|
### 步骤4:替换现有写入操作
|
|||
|
|
|
|||
|
|
将现有的直接写入替换为安全写入:
|
|||
|
|
|
|||
|
|
```typescript
|
|||
|
|
// ❌ 旧方式
|
|||
|
|
await supabase.from('inventory_records').insert(record);
|
|||
|
|
|
|||
|
|
// ✅ 新方式
|
|||
|
|
import { safeInsertInventoryRecord } from '../utils/dataValidation';
|
|||
|
|
await safeInsertInventoryRecord(record);
|
|||
|
|
```
|
|||
|
|
|
|||
|
|
需要替换的文件:
|
|||
|
|
- `src/pages/textile/FabricWarehouse.tsx` - 坯布入库
|
|||
|
|
- `src/pages/textile/PlanOverview.tsx` - 流程确认
|
|||
|
|
- `src/pages/purchaser/WarehouseManage.tsx` - 产品入库
|
|||
|
|
- `src/pages/*/PaymentPending.tsx` - 付款操作
|
|||
|
|
|
|||
|
|
### 步骤5:配置告警通知(可选)
|
|||
|
|
|
|||
|
|
在 Edge Function 中集成告警渠道:
|
|||
|
|
- 📧 邮件通知
|
|||
|
|
- 💬 钉钉/企业微信
|
|||
|
|
- 📱 短信告警
|
|||
|
|
|
|||
|
|
## 📋 日常运维检查清单
|
|||
|
|
|
|||
|
|
### 每日检查
|
|||
|
|
- [ ] 查看数据完整性监控面板
|
|||
|
|
- [ ] 确认错误率 ≤ 1/万
|
|||
|
|
- [ ] 检查是否有新的失败记录
|
|||
|
|
|
|||
|
|
### 每周检查
|
|||
|
|
- [ ] 分析错误率趋势
|
|||
|
|
- [ ] 审查审计日志中的异常操作
|
|||
|
|
- [ ] 验证备份数据完整性
|
|||
|
|
|
|||
|
|
### 每月检查
|
|||
|
|
- [ ] 运行全量数据一致性检查
|
|||
|
|
- [ ] 评估是否需要调整阈值
|
|||
|
|
- [ ] 更新数据质量报告
|
|||
|
|
|
|||
|
|
## 🔧 故障处理流程
|
|||
|
|
|
|||
|
|
### 发现数据不一致
|
|||
|
|
|
|||
|
|
1. **立即定位**
|
|||
|
|
```sql
|
|||
|
|
-- 查找不一致的记录
|
|||
|
|
SELECT * FROM v_plan_quantity_check WHERE check_result = '✗ 不一致';
|
|||
|
|
```
|
|||
|
|
|
|||
|
|
2. **分析原因**
|
|||
|
|
```sql
|
|||
|
|
-- 查看审计日志
|
|||
|
|
SELECT * FROM data_audit_logs
|
|||
|
|
WHERE record_id = '{问题记录ID}'
|
|||
|
|
ORDER BY changed_at DESC;
|
|||
|
|
```
|
|||
|
|
|
|||
|
|
3. **修复数据**
|
|||
|
|
- 优先使用事务保证原子性
|
|||
|
|
- 修复后重新运行一致性检查
|
|||
|
|
- 记录修复过程到审计日志
|
|||
|
|
|
|||
|
|
4. **根因分析**
|
|||
|
|
- 是代码bug?→ 修复代码并添加测试
|
|||
|
|
- 是并发问题?→ 添加锁机制或使用事务
|
|||
|
|
- 是用户误操作?→ 加强前端校验和提示
|
|||
|
|
|
|||
|
|
### 错误率突然升高
|
|||
|
|
|
|||
|
|
1. 检查最近的代码部署
|
|||
|
|
2. 查看审计日志中的失败模式
|
|||
|
|
3. 检查数据库负载和性能
|
|||
|
|
4. 必要时回滚最近的变更
|
|||
|
|
|
|||
|
|
## 📊 监控指标定义
|
|||
|
|
|
|||
|
|
| 指标 | 计算公式 | 目标值 | 告警阈值 |
|
|||
|
|
|------|---------|--------|---------|
|
|||
|
|
| 系统错误率 | (不一致记录数 / 总记录数) × 10000 | ≤ 1/万 | > 1/万 |
|
|||
|
|
| 计划数量一致率 | 一致的计划数 / 总计划数 | 100% | < 99.99% |
|
|||
|
|
| 付款金额准确率 | 准确的付款数 / 总付款数 | 100% | < 99.99% |
|
|||
|
|
| 应付账款准确率 | 准确的账款数 / 总账款数 | 100% | < 99.99% |
|
|||
|
|
|
|||
|
|
## 🎯 持续改进
|
|||
|
|
|
|||
|
|
### 短期优化(1-2周)
|
|||
|
|
- [ ] 完成数据库约束部署
|
|||
|
|
- [ ] 集成前端校验工具
|
|||
|
|
- [ ] 部署 Edge Function
|
|||
|
|
- [ ] 添加监控面板
|
|||
|
|
|
|||
|
|
### 中期优化(1-2月)
|
|||
|
|
- [ ] 建立自动化测试覆盖
|
|||
|
|
- [ ] 实现数据修复工具
|
|||
|
|
- [ ] 完善告警通知机制
|
|||
|
|
- [ ] 培训运维人员
|
|||
|
|
|
|||
|
|
### 长期优化(3-6月)
|
|||
|
|
- [ ] 引入机器学习异常检测
|
|||
|
|
- [ ] 建立数据质量评分体系
|
|||
|
|
- [ ] 实现自动修复机制
|
|||
|
|
- [ ] 定期第三方审计
|
|||
|
|
|
|||
|
|
## 📞 技术支持
|
|||
|
|
|
|||
|
|
如遇数据完整性问题,请按以下优先级处理:
|
|||
|
|
|
|||
|
|
1. **P0 - 财务数据错误**: 立即停止相关操作,联系技术负责人
|
|||
|
|
2. **P1 - 核心业务数据不一致**: 1小时内响应,4小时内修复
|
|||
|
|
3. **P2 - 非关键数据异常**: 24小时内处理
|
|||
|
|
4. **P3 - 监控告警**: 按日常运维流程处理
|
|||
|
|
|
|||
|
|
---
|
|||
|
|
|
|||
|
|
**最后更新**: 2026-06-04
|
|||
|
|
**版本**: v1.0
|
|||
|
|
**维护者**: 技术团队
|