package com.kaidi.oa.seed; import com.kaidi.oa.common.Money; import com.kaidi.oa.domain.SewageCrossDeptLinkage; import com.kaidi.oa.domain.SewageExtLabCommission; import com.kaidi.oa.repository.SewageCrossDeptLinkageRepository; import com.kaidi.oa.repository.SewageExtLabCommissionRepository; import org.springframework.boot.ApplicationArguments; import org.springframework.boot.ApplicationRunner; import org.springframework.core.annotation.Order; import org.springframework.transaction.annotation.Transactional; import java.time.Instant; import java.time.temporal.ChronoUnit; /** * 城镇污水运营·跨部门联动触发器 & 外部实验室委托检测 演示种子数据。 * * 补深审计 low 缺口（11.与其他部门接口要求）：让联动台账与外委检测台账活体可见， * 覆盖多种状态（成功/失败/待触发 / 合格/超标/待判定），演示完整业务链路。 * * 幂等：linkageRepo.count() == 0 才插入；commRepo.count() == 0 才插入。 */ @DemoSeed @Order(30) public class SewageCrossDeptSeeder implements ApplicationRunner { private final SewageCrossDeptLinkageRepository linkageRepo; private final SewageExtLabCommissionRepository commRepo; public SewageCrossDeptSeeder(SewageCrossDeptLinkageRepository linkageRepo, SewageExtLabCommissionRepository commRepo) { this.linkageRepo = linkageRepo; this.commRepo = commRepo; } @Override @Transactional public void run(ApplicationArguments args) { seedLinkages(); seedExtLabCommissions(); } // ------------------------------------------------------------------ 跨部门联动触发器演示数据 private void seedLinkages() { if (linkageRepo.count() > 0) return; Instant now = Instant.now(); // 1. 成功联动：药剂低库存→采购工单（真实写入） SewageCrossDeptLinkage lk1 = new SewageCrossDeptLinkage(); lk1.setEventKey("REAGENT_LOW_STOCK"); lk1.setSourceId(1L); lk1.setSourceModule("sewage_reagent_stock"); lk1.setEventDesc("聚合氯化铝(PAC)（凯迪一污水厂）库存 280 kg 低于安全库存 500 kg，需补货"); lk1.setTargetDept("采购部"); lk1.setLinkageAction("生成采购工单"); lk1.setStatus("成功"); lk1.setTargetEntityType("mfg_purchase_order"); lk1.setTargetEntityId(1001L); lk1.setResultNote("已真实创建采购工单 MfgPurchaseOrder#1001（来源：sewage_reagent_stock/1）"); lk1.setOwner("系统自动"); lk1.setTriggeredAt(now.minus(3, ChronoUnit.DAYS)); lk1.setCompletedAt(now.minus(3, ChronoUnit.DAYS).plus(2, ChronoUnit.SECONDS)); lk1.setCreatedAt(now.minus(3, ChronoUnit.DAYS)); lk1.setUpdatedAt(now.minus(3, ChronoUnit.DAYS)); linkageRepo.save(lk1); // 2. 成功联动：月度成本归集完成→财务凭证（真实写入） SewageCrossDeptLinkage lk2 = new SewageCrossDeptLinkage(); lk2.setEventKey("COST_MONTH_COMPLETE"); lk2.setSourceId(2L); lk2.setSourceModule("sewage_cost_month"); lk2.setEventDesc("2026-04 凯迪一污水厂 月度完全成本 ¥386500.00 完成，触发财务过账"); lk2.setTargetDept("财务部"); lk2.setLinkageAction("成本过账"); lk2.setStatus("成功"); lk2.setTargetEntityType("voucher"); lk2.setTargetEntityId(2001L); lk2.setResultNote("已真实创建记账凭证 Voucher#2001（来源：sewage_cost_month/2）科目：5001-运营成本←2201-应付账款"); lk2.setOwner("系统自动"); lk2.setTriggeredAt(now.minus(10, ChronoUnit.DAYS)); lk2.setCompletedAt(now.minus(10, ChronoUnit.DAYS).plus(1, ChronoUnit.SECONDS)); lk2.setCreatedAt(now.minus(10, ChronoUnit.DAYS)); lk2.setUpdatedAt(now.minus(10, ChronoUnit.DAYS)); linkageRepo.save(lk2); // 3. 成功联动：检测报告签发→申报服务部数据包 SewageCrossDeptLinkage lk3 = new SewageCrossDeptLinkage(); lk3.setEventKey("DETECT_REPORT_SIGNED"); lk3.setSourceId(5L); lk3.setSourceModule("sewage_detection_report"); lk3.setEventDesc("2026-05 月度水质检测报告已签发，COD削减量 42.8吨，氨氮削减量 8.6吨"); lk3.setTargetDept("申报服务部"); lk3.setLinkageAction("发送运营数据包"); lk3.setStatus("成功"); lk3.setTargetEntityType("ops_data_package"); lk3.setTargetEntityId(5L); lk3.setResultNote("已将运营数据（检测报告 sourceId=5）打包推送至申报服务部，含减排贡献数据"); lk3.setOwner("王运营"); lk3.setTriggeredAt(now.minus(5, ChronoUnit.DAYS)); lk3.setCompletedAt(now.minus(5, ChronoUnit.DAYS).plus(1, ChronoUnit.SECONDS)); lk3.setCreatedAt(now.minus(5, ChronoUnit.DAYS)); lk3.setUpdatedAt(now.minus(5, ChronoUnit.DAYS)); linkageRepo.save(lk3); // 4. 失败联动：月度成本归集→财务部（待重试） SewageCrossDeptLinkage lk4 = new SewageCrossDeptLinkage(); lk4.setEventKey("COST_MONTH_COMPLETE"); lk4.setSourceId(3L); lk4.setSourceModule("sewage_cost_month"); lk4.setEventDesc("2026-05 凯迪二污水厂 月度完全成本 ¥312000.00 完成，触发财务过账"); lk4.setTargetDept("财务部"); lk4.setLinkageAction("成本过账"); lk4.setStatus("失败"); lk4.setResultNote("联动执行失败: 财务部凭证接口超时，请稍后重试"); lk4.setOwner("系统自动"); lk4.setTriggeredAt(now.minus(1, ChronoUnit.DAYS)); lk4.setCreatedAt(now.minus(1, ChronoUnit.DAYS)); lk4.setUpdatedAt(now.minus(1, ChronoUnit.DAYS)); linkageRepo.save(lk4); // 5. 待触发：运营记录自动归档 SewageCrossDeptLinkage lk5 = new SewageCrossDeptLinkage(); lk5.setEventKey("DETECTION_REPORT_ARCHIVE"); lk5.setSourceId(7L); lk5.setSourceModule("sewage_detection_report"); lk5.setEventDesc("2026-05 水质检测原始记录待归档至资料室"); lk5.setTargetDept("资料室"); lk5.setLinkageAction("自动归档"); lk5.setStatus("待触发"); lk5.setOwner("李化验"); lk5.setTriggeredAt(now); lk5.setCreatedAt(now); lk5.setUpdatedAt(now); linkageRepo.save(lk5); // 6. 成功联动：外委检测超标→法务风险部（真实写入 LegalRiskEvent） SewageCrossDeptLinkage lk6 = new SewageCrossDeptLinkage(); lk6.setEventKey("EXT_LAB_EXCEED_LEGAL"); lk6.setSourceId(1L); lk6.setSourceModule("sewage_ext_lab_commission"); lk6.setEventDesc("EXT-LAB-0001 超标（总磷 0.82mg/L），已推送至法务风险部（LegalRiskEvent#3001）"); lk6.setTargetDept("法务风险部"); lk6.setLinkageAction("创建环保处罚风险事件"); lk6.setStatus("成功"); lk6.setTargetEntityType("legal_risk_event"); lk6.setTargetEntityId(3001L); lk6.setResultNote("真实写入 LegalRiskEvent id=3001，类型=行政处罚，状态=待分析"); lk6.setOwner("张水质"); lk6.setTriggeredAt(now.minus(2, ChronoUnit.DAYS)); lk6.setCompletedAt(now.minus(2, ChronoUnit.DAYS).plus(1, ChronoUnit.SECONDS)); lk6.setCreatedAt(now.minus(2, ChronoUnit.DAYS)); lk6.setUpdatedAt(now.minus(2, ChronoUnit.DAYS)); linkageRepo.save(lk6); } // ------------------------------------------------------------------ 外部实验室委托检测演示数据 private void seedExtLabCommissions() { if (commRepo.count() > 0) return; Instant now = Instant.now(); // 1. 超标整改状态（总磷超标，已推送法务） SewageExtLabCommission c1 = new SewageExtLabCommission(); c1.setCommissionNo("EXT-LAB-0001"); c1.setPlant("凯迪一污水厂"); c1.setCommissionDate("2026-05-10"); c1.setPlannedReportDate("2026-05-18"); c1.setActualReportDate("2026-05-17"); c1.setLabName("省环境检测技术中心"); c1.setLabCertNo("CMA(2024)川字第12345号"); c1.setSampleType("出水"); c1.setSampleDate("2026-05-10"); c1.setSampleNo("SMP-20260510-001"); c1.setTestItems("COD,氨氮,总磷,总氮,SS,pH"); c1.setResultSummary("COD=8.5mg/L;氨氮=0.42mg/L;总磷=0.82mg/L;总氮=10.6mg/L;SS=6mg/L;pH=7.2"); c1.setComplianceResult("超标"); c1.setExceedItems("总磷"); c1.setCorrectionNote("总磷实测0.82 mg/L，超出GB18918一级A标准0.5 mg/L，需检查深度除磷单元，加强PAC加药量"); c1.setStatus("超标整改"); c1.setAmount(Money.of(3800.0)); c1.setLinkageId(3001L); c1.setOwner("张水质"); c1.setRemark("第三方年度水质监督性抽检"); c1.setCreatedAt(now.minus(25, ChronoUnit.DAYS)); c1.setUpdatedAt(now.minus(8, ChronoUnit.DAYS)); commRepo.save(c1); // 2. 合格状态，已归档 SewageExtLabCommission c2 = new SewageExtLabCommission(); c2.setCommissionNo("EXT-LAB-0002"); c2.setPlant("凯迪二污水厂"); c2.setCommissionDate("2026-04-15"); c2.setPlannedReportDate("2026-04-22"); c2.setActualReportDate("2026-04-21"); c2.setLabName("市水质监测站"); c2.setLabCertNo("CNAS L1234"); c2.setSampleType("出水"); c2.setSampleDate("2026-04-15"); c2.setSampleNo("SMP-20260415-002"); c2.setTestItems("COD,氨氮,总磷,总氮,SS"); c2.setResultSummary("COD=6.2mg/L;氨氮=0.18mg/L;总磷=0.32mg/L;总氮=8.4mg/L;SS=4mg/L"); c2.setComplianceResult("合格"); c2.setStatus("已归档"); c2.setAmount(Money.of(2500.0)); c2.setOwner("李化验"); c2.setRemark("季度合规性检测"); c2.setCreatedAt(now.minus(60, ChronoUnit.DAYS)); c2.setUpdatedAt(now.minus(45, ChronoUnit.DAYS)); commRepo.save(c2); // 3. 检测中（刚发样，尚未出结果） SewageExtLabCommission c3 = new SewageExtLabCommission(); c3.setCommissionNo("EXT-LAB-0003"); c3.setPlant("凯迪一污水厂"); c3.setCommissionDate("2026-06-05"); c3.setPlannedReportDate("2026-06-15"); c3.setLabName("省环境检测技术中心"); c3.setLabCertNo("CMA(2024)川字第12345号"); c3.setSampleType("工艺段（A/O末端）"); c3.setSampleDate("2026-06-05"); c3.setSampleNo("SMP-20260605-003"); c3.setTestItems("溶解氧,氨氮,总磷,总氮,MLSS"); c3.setComplianceResult("待判定"); c3.setStatus("检测中"); c3.setAmount(Money.of(4200.0)); c3.setOwner("张水质"); c3.setRemark("A/O生化段专项监测，配合工艺优化调整"); c3.setCreatedAt(now.minus(10, ChronoUnit.DAYS)); c3.setUpdatedAt(now.minus(10, ChronoUnit.DAYS)); commRepo.save(c3); // 4. 待发样（刚创建） SewageExtLabCommission c4 = new SewageExtLabCommission(); c4.setCommissionNo("EXT-LAB-0004"); c4.setPlant("凯迪三污水厂"); c4.setCommissionDate("2026-06-12"); c4.setPlannedReportDate("2026-06-20"); c4.setLabName("某市第三方水质检测机构"); c4.setSampleType("污泥滤液"); c4.setSampleDate("2026-06-12"); c4.setSampleNo("SMP-20260612-004"); c4.setTestItems("COD,氨氮,重金属（铅,镉,铬）"); c4.setComplianceResult("待判定"); c4.setStatus("待发样"); c4.setAmount(Money.of(5600.0)); c4.setOwner("赵厂长"); c4.setRemark("污泥处置前合规性检测，确认重金属含量符合处置要求"); c4.setCreatedAt(now.minus(3, ChronoUnit.DAYS)); c4.setUpdatedAt(now.minus(3, ChronoUnit.DAYS)); commRepo.save(c4); // 5. 已出报告-合格（重金属检测通过） SewageExtLabCommission c5 = new SewageExtLabCommission(); c5.setCommissionNo("EXT-LAB-0005"); c5.setPlant("凯迪二污水厂"); c5.setCommissionDate("2026-05-20"); c5.setPlannedReportDate("2026-05-28"); c5.setActualReportDate("2026-05-27"); c5.setLabName("省环境检测技术中心"); c5.setLabCertNo("CMA(2024)川字第12345号"); c5.setSampleType("进水"); c5.setSampleDate("2026-05-20"); c5.setSampleNo("SMP-20260520-005"); c5.setTestItems("COD,氨氮,总磷,总氮,SS,重金属筛查"); c5.setResultSummary("COD=245mg/L;氨氮=28.6mg/L;总磷=3.2mg/L;总氮=36.4mg/L;SS=180mg/L;重金属未检出"); c5.setComplianceResult("合格"); c5.setStatus("已出报告"); c5.setAmount(Money.of(6800.0)); c5.setOwner("李化验"); c5.setRemark("重要工业用户纳管排查配套检测"); c5.setCreatedAt(now.minus(26, ChronoUnit.DAYS)); c5.setUpdatedAt(now.minus(19, ChronoUnit.DAYS)); commRepo.save(c5); } }