package com.ruoyi.project.pssr.controller; import com.alibaba.fastjson.JSON; import com.github.stuxuhai.jpinyin.PinyinFormat; import com.github.stuxuhai.jpinyin.PinyinHelper; import com.ruoyi.common.jpush.JiGuangPushService; import com.ruoyi.common.sendEmail.IMailService; import com.ruoyi.common.utils.DateUtils; import com.ruoyi.common.utils.StringUtils; import com.ruoyi.common.utils.poi.ExcelUtil; import com.ruoyi.framework.aspectj.lang.annotation.Log; import com.ruoyi.framework.aspectj.lang.enums.BusinessType; import com.ruoyi.framework.web.controller.BaseController; import com.ruoyi.framework.web.domain.AjaxResult; import com.ruoyi.framework.web.page.TableDataInfo; import com.ruoyi.project.pssr.domain.*; import com.ruoyi.project.pssr.service.*; import com.ruoyi.project.reliability.domain.TSafetyvavle; import com.ruoyi.project.reliability.service.ITSafetyvavleService; import com.ruoyi.project.system.domain.SysMessage; import com.ruoyi.project.system.domain.SysUser; import com.ruoyi.project.system.service.ISysMessageService; import com.ruoyi.project.system.service.ISysUserService; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.security.access.prepost.PreAuthorize; import org.springframework.web.bind.annotation.*; import java.util.*; /** * PSSRController * * @author ssy * @date 2024-09-18 */ @RestController @RequestMapping("/pssr/aboveall") public class TPssrAboveallController extends BaseController { //region 注入服务层对象 @Autowired private ITPssrAboveallService tPssrAboveallService; @Autowired private ITPssrSubcontentService tPssrSubcontentService; @Autowired private ITPssrPatrolService tPssrPatrolService; @Autowired private ITPssrMaterialService tPssrMaterialService; @Autowired private ITPssrMaterialRawService tPssrMaterialRawService; @Autowired private ITPssrMocService tPssrMocService; @Autowired private ITSafetyvavleService tSafetyvavleService; @Autowired private ITPssrSafetyValveService tPssrSafetyValveService; @Autowired private ITPssrPublicService tPssrPublicService; @Autowired private ITPssrTorchvocService tPssrTorchvocService; @Autowired private ITPssrLightingService tPssrLightingService; @Autowired private ITPssrPowerService tPssrPowerService; @Autowired private ITPssrHygieneService tPssrHygieneService; @Autowired private ITPssrFrameModelService tPssrFrameModelService; @Autowired private ITPssrFrameService tPssrFrameService; @Autowired private ITPssrProtectionService tPssrProtectionService; @Autowired private TPssrApproveController tPssrApproveController; @Autowired private ISysUserService userService; @Autowired private ITPssrFranklinismService tPssrFranklinismService; @Autowired private ITPssrOverhaulExchangerService tPssrOverhaulExchangerService; @Autowired private ITPssrOverhaulFilterService tPssrOverhaulFilterService; @Autowired private ITPssrOverhaulTowerService tPssrOverhaulTowerService; @Autowired private ITPssrOverhaulValveService tPssrOverhaulValveService; @Autowired private ITPssrBlindService tPssrBlindService; @Autowired private ITPssrLockService tPssrLockService; @Autowired private ITPssrPipeService tPssrPipeService; @Autowired private ITPssrCleaningService tPssrCleaningService; @Autowired private ITPssrAirtightService tPssrAirtightService; @Autowired private ITPssrLaboratoryService tPssrLaboratoryService; @Autowired private ITPssrCircuitService tPssrCircuitService; @Autowired private ITPssrSafetyBleedService tPssrSafetyBleedService; @Autowired private ITPssrSafetyBreathService tPssrSafetyBreathService; @Autowired private ITPssrSafetyBrustService tPssrSafetyBrustService; @Autowired private ITPssrSafetyFlamearresterService tPssrSafetyFlamearresterService; @Autowired private ITPssrMotorService tPssrMotorService; @Autowired private ITPssrInstrumentCalibrationService tPssrInstrumentCalibrationService; @Autowired private ITPssrNitrogenService tPssrNitrogenService; @Autowired private ITPssrGasdetectorService tPssrGasdetectorService; @Autowired private ITPssrAnalyzerService tPssrAnalyzerService; @Autowired private ITPssrMeasureService tPssrMeasureService; @Autowired private ITPssrPumpFillService tPssrPumpFillService; @Autowired private ITPssrPumpCleaningService tPssrPumpCleaningService; @Autowired private ITPssrPumpOverhaulService tPssrPumpOverhaulService; @Autowired private ITPssrInstrumentTestService tPssrInstrumentTestService; @Autowired private ITPssrAlarmService tPssrAlarmService; @Autowired private ITPssrVesselService tPssrVesselService; @Autowired private ITPssrProgrammeService tPssrProgrammeService; @Autowired private JiGuangPushService jiGuangPushService; @Autowired private IMailService mailService; @Autowired private ISysMessageService sysMessageService; //endregion //region 系统方法 /** * 查询PSSR列表 */ @PreAuthorize("@ss.hasPermi('pssr:aboveall:list')") @GetMapping("/list") public TableDataInfo list(TPssrAboveall tPssrAboveall) { startPage(); List list = tPssrAboveallService.selectTPssrAboveallList(tPssrAboveall); return getDataTable(list); } /** * 导出PSSR列表 */ @PreAuthorize("@ss.hasPermi('pssr:aboveall:export')") @Log(title = "PSSR", businessType = BusinessType.EXPORT) @GetMapping("/export") public AjaxResult export(TPssrAboveall tPssrAboveall) { List list = tPssrAboveallService.selectTPssrAboveallList(tPssrAboveall); ExcelUtil util = new ExcelUtil(TPssrAboveall.class); return util.exportExcel(list, "aboveall"); } /** * 获取PSSR详细信息 */ @PreAuthorize("@ss.hasPermi('pssr:aboveall:query')") @GetMapping(value = "/{id}") public AjaxResult getInfo(@PathVariable("id") Long id) { return AjaxResult.success(tPssrAboveallService.selectTPssrAboveallById(id)); } /** * 修改PSSR */ @PreAuthorize("@ss.hasPermi('pssr:aboveall:edit')") @Log(title = "PSSR", businessType = BusinessType.UPDATE) @PutMapping public AjaxResult edit(@RequestBody TPssrAboveall tPssrAboveall) { return toAjax(tPssrAboveallService.updateTPssrAboveall(tPssrAboveall)); } /** * 删除PSSR */ @PreAuthorize("@ss.hasPermi('pssr:aboveall:remove')") @Log(title = "PSSR", businessType = BusinessType.DELETE) @DeleteMapping("/{ids}") public AjaxResult remove(@PathVariable Long[] ids) { return toAjax(tPssrAboveallService.deleteTPssrAboveallByIds(ids)); } /** * 查询pssr相关用户 */ @GetMapping("/listPssrUser") public AjaxResult listPssrUser(TPssrSubcontent sub) { SysUser user = new SysUser(); user.setDeptIds(new Long[]{103L,10042L,10058L}); return AjaxResult.success(userService.selectPssrUser(user)); } //endregion //region 新增 /** * 新增PSSR */ @PreAuthorize("@ss.hasPermi('pssr:aboveall:add')") @Log(title = "PSSR", businessType = BusinessType.INSERT) @PostMapping public AjaxResult add(@RequestBody TPssrAboveall tPssrAboveall) { boolean model = false; TPssrAboveall aboveall = null; if (tPssrAboveall.getId() != null) { model = true; aboveall = tPssrAboveallService.selectTPssrAboveallById(tPssrAboveall.getId()); tPssrAboveall.setUnit(aboveall.getUnit()); tPssrAboveall.setRegion(aboveall.getRegion()); tPssrAboveall.setId(null); tPssrAboveall.setDrivingTime(aboveall.getDrivingTime()); tPssrAboveall.setIncludePublic(aboveall.getIncludePublic()); } if (tPssrAboveall.getIncludePublic() == 1) { tPssrAboveall.setUnit(tPssrAboveall.getUnit() + ",390"); } tPssrAboveallService.insertTPssrAboveall(tPssrAboveall);//新增主表数据 // 记录所有负责人id Set userIds = new HashSet<>(); String userId = getUserId().toString(); //新增子表数据 for (TPssrSubcontent subcontent : tPssrAboveall.getSubcontents()) { if (subcontent.getStatus() == 1) { userIds.add(Long.valueOf(subcontent.getConfirm())); subcontent.setAboveallId(tPssrAboveall.getId());//主表id subcontent.setRegion(tPssrAboveall.getRegion()); subcontent.setUnit(tPssrAboveall.getUnit()); subcontent.setUnitDes(tPssrAboveall.getUnitDes()); subcontent.setApproveStatus(0L); subcontent.setCreatedate(new Date()); subcontent.setCreaterCode(userId); tPssrSubcontentService.insertTPssrSubcontent(subcontent); new Thread(() -> { if (subcontent.getForShort().equals("xqf")) { List tPssrPatrols = new ArrayList<>(); // 手提式/小推车式灭火器/灭火器材箱检查记录,1 tPssrPatrols.add(getEntity(1L, subcontent.getId())); // 消防水炮检查记录,2 tPssrPatrols.add(getEntity(2L, subcontent.getId())); // 地上消火栓检查记录,3 tPssrPatrols.add(getEntity(3L, subcontent.getId())); // 消防水带箱检查记录,4 tPssrPatrols.add(getEntity(4L, subcontent.getId())); // 消防竖管检查记录,5 tPssrPatrols.add(getEntity(5L, subcontent.getId())); // 自动喷淋灭火系统检查记录,6 tPssrPatrols.add(getEntity(6L, subcontent.getId())); // 应急事故柜检查记录,7 tPssrPatrols.add(getEntity(7L, subcontent.getId())); // 现场可燃气体检测器/火灾报警系统检查记录,8 tPssrPatrols.add(getEntity(8L, subcontent.getId())); // CO2气体保护系统检查记录,9 tPssrPatrols.add(getEntity(9L, subcontent.getId())); // 淋浴洗眼器检查记录,12 tPssrPatrols.add(getEntity(12L, subcontent.getId())); // 应急沙箱检查记录,13 tPssrPatrols.add(getEntity(13L, subcontent.getId())); // 常闭式防爆门/防火门检查记录,14 tPssrPatrols.add(getEntity(14L, subcontent.getId())); // 风向标/风向袋/新风系统正压计检查记录,15 tPssrPatrols.add(getEntity(15L, subcontent.getId())); // 蒸汽幕检查记录,16 tPssrPatrols.add(getEntity(16L, subcontent.getId())); // 急救箱 tPssrPatrols.add(getEntity(27L, subcontent.getId())); for (TPssrPatrol pssrPatrol : tPssrPatrols) { tPssrPatrolService.insertTPssrPatrol(pssrPatrol, userId); } } else if (subcontent.getForShort().equals("txjk")) { List tPssrPatrols = new ArrayList<>(); // PAGA系统检查记录,10 tPssrPatrols.add(getEntity(10L, subcontent.getId())); // CCTV系统检查记录,11 tPssrPatrols.add(getEntity(11L, subcontent.getId())); for (TPssrPatrol pssrPatrol : tPssrPatrols) { tPssrPatrolService.insertTPssrPatrol(pssrPatrol, userId); } } else if (subcontent.getForShort().equals("bxsjcy")) { List tPssrPatrols = new ArrayList<>(); // 四合一/苯系物/硫化氢/二氧化碳/射线一氧化碳检测仪检查记录,18 tPssrPatrols.add(getEntity(18L, subcontent.getId())); for (TPssrPatrol pssrPatrol : tPssrPatrols) { tPssrPatrolService.insertTPssrPatrol(pssrPatrol, userId); } } else if (subcontent.getForShort().equals("yfl")) { genYfl(subcontent.getId(), userId); } else if (subcontent.getForShort().equals("aqss")) { genAqf(subcontent, userId); } else if (subcontent.getForShort().equals("gygc")) { genGygc(subcontent.getId(), userId); } else if (subcontent.getForShort().equals("hbss")) { genHbss(subcontent.getId(), userId); } else if (subcontent.getForShort().equals("zmdbr")) { genZmdbr(subcontent.getId(), userId); } else if (subcontent.getForShort().equals("lsdy")) { genLsdy(subcontent.getId(), userId); } else if (subcontent.getForShort().equals("xcws")) { genXcws(subcontent.getId(), userId); } else if (subcontent.getForShort().equals("rsfh")) { genRsfh(subcontent.getId(), userId); } else if (subcontent.getForShort().equals("jdjdkj")) { genJdjdkj(subcontent.getId(), userId); } else if (subcontent.getForShort().equals("zdj")) { genZdj(subcontent.getId(), subcontent.getUnit(), userId); } }, "新增子表数据").start(); } } //同步模板数据 if (model) { genPssrDataByModel(aboveall, tPssrAboveall, userId); } new Thread(() -> { sendEmail(userIds, tPssrAboveall); },"新增pssr开始发邮件").start(); return AjaxResult.success(); } //endregion //region 生成固定内容数据 /** * 生成支吊架数据 */ private void genZdj(Long subId, String units, String userId) { if (StringUtils.isNotEmpty(units)) { for (String unit : units.split(",")) { TPssrFrameModel model = new TPssrFrameModel(); model.setUnit(unit); tPssrFrameModelService.selectTPssrFrameModelList(model).forEach(item -> { TPssrFrame frame = new TPssrFrame(); frame.setSubId(subId); frame.setRegion(item.getRegion()); frame.setBracketNumber(item.getBracketNumber()); frame.setPipelineNumber(item.getPipelineNumber()); frame.setDevNo(item.getDevNo()); frame.setSupportType(item.getSupportType()); frame.setFramePipe("✔"); frame.setFrameRoot("✔"); frame.setFunctionalPart("✔"); frame.setConnector("✔"); frame.setCreaterCode(userId); frame.setCreatedate(new Date()); tPssrFrameService.insertTPssrFrame(frame); }); } } } /** * 生成人身防护数据 */ private void genRsfh(Long subId, String userId) { tPssrProtectionService.insertTPssrProtection(new TPssrProtection(subId, "被保温的管道/设备保温防护层外观完好，无缺失。", userId, new Date())); tPssrProtectionService.insertTPssrProtection(new TPssrProtection(subId, "保温层连接密封处严密，无管道/设备裸露。", userId, new Date())); tPssrProtectionService.insertTPssrProtection(new TPssrProtection(subId, "管道/设备上的保温层不妨碍操作人员进行现场作业。", userId, new Date())); } /** * 生成静电接地跨接数据 */ private void genJdjdkj(Long subId, String userId) { tPssrFranklinismService.insertTPssrFranklinism(new TPssrFranklinism(1L, subId, "电气设备按要求接地，接线规范。", userId, new Date())); tPssrFranklinismService.insertTPssrFranklinism(new TPssrFranklinism(2L, subId, "管线按要求跨接，接线规范。", userId, new Date())); tPssrFranklinismService.insertTPssrFranklinism(new TPssrFranklinism(3L, subId, "接线端头牢固，无松动。", userId, new Date())); tPssrFranklinismService.insertTPssrFranklinism(new TPssrFranklinism(4L, subId, "接地电缆无破损，状况良好。", userId, new Date())); tPssrFranklinismService.insertTPssrFranklinism(new TPssrFranklinism(5L, subId, "接地标记/标识清晰。", userId, new Date())); } /** * 生成现场卫生数据 */ private void genXcws(Long subId, String userId) { tPssrHygieneService.insertTPssrHygiene(new TPssrHygiene(subId, "现场地面无油渍，积水等。", userId, new Date())); tPssrHygieneService.insertTPssrHygiene(new TPssrHygiene(subId, "现场无检修施工后的残留物(碎屑, 密封材料, 螺栓，保温材料等) 。", userId, new Date())); tPssrHygieneService.insertTPssrHygiene(new TPssrHygiene(subId, "所需材料安全堆放在指定区域。 ", userId, new Date())); tPssrHygieneService.insertTPssrHygiene(new TPssrHygiene(subId, "工器具整齐的放置在指定区域。", userId, new Date())); tPssrHygieneService.insertTPssrHygiene(new TPssrHygiene(subId, "地沟、污水管网、污水井、清净下水管网、清净下水管井内无杂物，且畅通无阻。", userId, new Date())); tPssrHygieneService.insertTPssrHygiene(new TPssrHygiene(subId, "无多余的脚手架，现存的脚手架不影响操作人员进行现场作业。", userId, new Date())); } /** * 生成临时电源数据 */ private void genLsdy(Long subId, String userId) { tPssrPowerService.insertTPssrPower(new TPssrPower(subId, "现场电源插座上无接临时用电设备、临时线路。", new Date(), userId)); tPssrPowerService.insertTPssrPower(new TPssrPower(subId, "现场电源插座外观完好，无破损，插座盖子上紧，无脱落。", new Date(), userId)); } /** * 生成照明、电伴热数据 */ private void genZmdbr(Long subId, String userId) { tPssrLightingService.insertTPssrLighting(new TPssrLighting(1L, subId, "照明灯外观完好，干净，无破损。", "1", userId, new Date())); tPssrLightingService.insertTPssrLighting(new TPssrLighting(2L, subId, "照明灯无锈蚀。", "1", userId, new Date())); tPssrLightingService.insertTPssrLighting(new TPssrLighting(3L, subId, "照明灯具固定牢固，无松动。", "1", userId, new Date())); tPssrLightingService.insertTPssrLighting(new TPssrLighting(4L, subId, "照明导线完好，无破损。", "1", userId, new Date())); tPssrLightingService.insertTPssrLighting(new TPssrLighting(5L, subId, "照明开关完好。", "1", userId, new Date())); tPssrLightingService.insertTPssrLighting(new TPssrLighting(6L, subId, "照明设备可以正常打开或者关闭。", "1", userId, new Date())); tPssrLightingService.insertTPssrLighting(new TPssrLighting(1L, subId, "现场电伴热带无破损断裂，无变形", "2", userId, new Date())); tPssrLightingService.insertTPssrLighting(new TPssrLighting(2L, subId, "电伴热带与管道设备紧密贴合，无缝隙", "2", userId, new Date())); tPssrLightingService.insertTPssrLighting(new TPssrLighting(3L, subId, "电源接线盒牢固密封，接线端子无松动锈蚀。", "2", userId, new Date())); } /** * 生成环保设施数据 */ private void genHbss(Long subId, String userId) { tPssrTorchvocService.insertTPssrTorchvoc(new TPssrTorchvoc(1L, subId, "1", "火炬系统检修时所加装的盲板已拆除。", userId, new Date())); tPssrTorchvocService.insertTPssrTorchvoc(new TPssrTorchvoc(2L, subId, "1", "火炬系统已完成氮气置换，氧含量<0.2%。", userId, new Date())); tPssrTorchvocService.insertTPssrTorchvoc(new TPssrTorchvoc(3L, subId, "1", "公用工程（消防水、仪表风、氮气、电、中、低压蒸汽等）已投用或具备使用条件。", userId, new Date())); tPssrTorchvocService.insertTPssrTorchvoc(new TPssrTorchvoc(4L, subId, "1", "火炬系统的所有仪表功能检查正常。", userId, new Date())); tPssrTorchvocService.insertTPssrTorchvoc(new TPssrTorchvoc(5L, subId, "1", "火炬点火用燃料气已引到PCV-9994、PC-9991阀前。", userId, new Date())); tPssrTorchvocService.insertTPssrTorchvoc(new TPssrTorchvoc(6L, subId, "1", "仪表空气已送至PCV-9995阀前。", userId, new Date())); tPssrTorchvocService.insertTPssrTorchvoc(new TPssrTorchvoc(7L, subId, "1", "加热火炬气的甲醇已充进换热器390-E-903，390-E-903的低压蒸汽管线暖管结束。", userId, new Date())); tPssrTorchvocService.insertTPssrTorchvoc(new TPssrTorchvoc(8L, subId, "1", "火炬总管分子封用氮已经投用。", userId, new Date())); tPssrTorchvocService.insertTPssrTorchvoc(new TPssrTorchvoc(9L, subId, "1", "点火器装置和电视监控器等电器设备已送电，设备完好。", userId, new Date())); tPssrTorchvocService.insertTPssrTorchvoc(new TPssrTorchvoc(10L, subId, "1", "火炬消烟蒸汽已引到蒸汽调节阀前，RO-9991～3的前后闸阀全开，管线上所有疏水器均须投用。", userId, new Date())); tPssrTorchvocService.insertTPssrTorchvoc(new TPssrTorchvoc(11L, subId, "1", "由LV-9990向水封罐390-V-940注生产工艺水，直到工艺水由从U形管排出已完成。", userId, new Date())); tPssrTorchvocService.insertTPssrTorchvoc(new TPssrTorchvoc(12L, subId, "1", "设定390-P-940去急冷水塔的流程，已投用390-P-940自启动及停车控制器UC-9990。", userId, new Date())); tPssrTorchvocService.insertTPssrTorchvoc(new TPssrTorchvoc(13L, subId, "1", "已投用各火炬总管端点的吹扫气。", userId, new Date())); tPssrTorchvocService.insertTPssrTorchvoc(new TPssrTorchvoc(14L, subId, "1", "火炬长明灯点火完成，已确认正常。", userId, new Date())); tPssrTorchvocService.insertTPssrTorchvoc(new TPssrTorchvoc(15L, subId, "1", "火炬系统已可以接收装置物料排放。", userId, new Date())); tPssrTorchvocService.insertTPssrTorchvoc(new TPssrTorchvoc(1L, subId, "2", "VOC系统检修时所加装的盲板已拆除。", userId, new Date())); tPssrTorchvocService.insertTPssrTorchvoc(new TPssrTorchvoc(2L, subId, "2", "VOC系统已完成氮气置换，氧含量合格。", userId, new Date())); tPssrTorchvocService.insertTPssrTorchvoc(new TPssrTorchvoc(3L, subId, "2", "公用工程（消防水、仪表风、氮气、电、中、低压蒸汽等）已投用或具备使用条件。", userId, new Date())); tPssrTorchvocService.insertTPssrTorchvoc(new TPssrTorchvoc(4L, subId, "2", "VOC系统的所有仪表功能已检查正常。", userId, new Date())); tPssrTorchvocService.insertTPssrTorchvoc(new TPssrTorchvoc(5L, subId, "2", "VOC系统具备使用条件，开车流程打通，已确认正常。", userId, new Date())); tPssrTorchvocService.insertTPssrTorchvoc(new TPssrTorchvoc(6L, subId, "2", "按操作程序启动390-K-950，已确认K950运行正常。", userId, new Date())); tPssrTorchvocService.insertTPssrTorchvoc(new TPssrTorchvoc(7L, subId, "2", "VOC系统运行正常，已可以接收VOC排放。", userId, new Date())); } /** * 生成巡检数据 */ private TPssrPatrol getEntity(Long planType, Long subId) { TPssrPatrol tPssrPatrol = new TPssrPatrol(); tPssrPatrol.setPlanType(planType); tPssrPatrol.setSubId(subId); return tPssrPatrol; } /** * 生成原辅料数据 */ private void genYfl(Long subId, String userId) { tPssrMaterialService.insertTPssrMaterial(new TPssrMaterial(subId, "Electr. Power", "MWH", userId, new Date(), 0L)); tPssrMaterialService.insertTPssrMaterial(new TPssrMaterial(subId, "LP steam ", "Ton", userId, new Date(), 0L)); tPssrMaterialService.insertTPssrMaterial(new TPssrMaterial(subId, "MP steam", "Ton", userId, new Date(), 0L)); tPssrMaterialService.insertTPssrMaterial(new TPssrMaterial(subId, "HP steam ", "Ton", userId, new Date(), 0L)); tPssrMaterialService.insertTPssrMaterial(new TPssrMaterial(subId, "Potable water", "Ton", userId, new Date(), 0L)); tPssrMaterialService.insertTPssrMaterial(new TPssrMaterial(subId, "production water", "Ton", userId, new Date(), 0L)); tPssrMaterialService.insertTPssrMaterial(new TPssrMaterial(subId, "LP fire water", "Ton", userId, new Date(), 0L)); tPssrMaterialService.insertTPssrMaterial(new TPssrMaterial(subId, "HP fire water", "Ton", userId, new Date(), 0L)); tPssrMaterialService.insertTPssrMaterial(new TPssrMaterial(subId, "Cooling water", "Ton", userId, new Date(), 0L)); tPssrMaterialService.insertTPssrMaterial(new TPssrMaterial(subId, "Polished Water", "Ton", userId, new Date(), 0L)); tPssrMaterialService.insertTPssrMaterial(new TPssrMaterial(subId, "Nitrogen", "Nm3", userId, new Date(), 0L)); tPssrMaterialService.insertTPssrMaterial(new TPssrMaterial(subId, "Plant Air", "Nm3", userId, new Date(), 0L)); tPssrMaterialService.insertTPssrMaterial(new TPssrMaterial(subId, "Instrument Air", "Nm3", userId, new Date(), 0L)); tPssrMaterialService.insertTPssrMaterial(new TPssrMaterial(subId, "WW(only quantity)", "Ton", userId, new Date(), 0L)); tPssrMaterialRawService.insertTPssrMaterialRaw(new TPssrMaterialRaw(subId, "Naphtha", "Ton", userId, new Date(), 0L)); tPssrMaterialRawService.insertTPssrMaterialRaw(new TPssrMaterialRaw(subId, "Flux Oil", "Ton", userId, new Date(), 0L)); tPssrMaterialRawService.insertTPssrMaterialRaw(new TPssrMaterialRaw(subId, "Wash Oil", "Ton", userId, new Date(), 0L)); tPssrMaterialRawService.insertTPssrMaterialRaw(new TPssrMaterialRaw(subId, "C6-C8", "Ton", userId, new Date(), 0L)); tPssrMaterialRawService.insertTPssrMaterialRaw(new TPssrMaterialRaw(subId, "Natural Gas", "Ton", userId, new Date(), 0L)); tPssrMaterialRawService.insertTPssrMaterialRaw(new TPssrMaterialRaw(subId, "Ethylene", "Ton", userId, new Date(), 0L)); tPssrMaterialRawService.insertTPssrMaterialRaw(new TPssrMaterialRaw(subId, "Propylene", "Ton", userId, new Date(), 0L)); tPssrMaterialRawService.insertTPssrMaterialRaw(new TPssrMaterialRaw(subId, "Toluene", "Ton", userId, new Date(), 0L)); } /** * 生成安全阀数据 */ private void genAqf(TPssrSubcontent subcontent, String userId) { if (StringUtils.isNotEmpty(subcontent.getUnit())) for (String unit : subcontent.getUnit().split(",")) { TSafetyvavle query = new TSafetyvavle(); query.setSubarea(unit); for (TSafetyvavle vavle : tSafetyvavleService.selectTSafetyvavleList(query)) { TPssrSafetyValve pssr = new TPssrSafetyValve(); pssr.setUnit(unit); pssr.setSubId(subcontent.getId()); pssr.setDevNo(vavle.getTagno()); pssr.setInstallLocation(vavle.getPlacedesc()); pssr.setSafetyDev(vavle.getService()); pssr.setPidNo(vavle.getPid()); pssr.setSetPressure(vavle.getSettingpres()); pssr.setApproveStatus(0L); pssr.setCreatedate(new Date()); pssr.setCreaterCode(userId); tPssrSafetyValveService.insertTPssrSafetyValve(pssr); } } } /** * 生成公用工程数据 */ private void genGygc(Long subId, String userId) { tPssrPublicService.insertTPssrPublic(new TPssrPublic(subId, "公用工程系统N2已投用或具备投用条件。", "界区阀已打开，N2总管压力390PI9114压力达( )kPa。", "N2总管压力390PI9114压力达( )kPa。", userId, new Date())); tPssrPublicService.insertTPssrPublic(new TPssrPublic(subId, "公用工程系统IA已投用或具备投用条件：", "界区阀已打开，IA管压力PI3901压力达( )kPa。", "IA管压力PI3901压力达( )kPa。", userId, new Date())); tPssrPublicService.insertTPssrPublic(new TPssrPublic(subId, "公用工程系统PA已投用或具备投用条件。", "界区阀已打开，PA管压力PI3902压力达( )kPa。", "PA管压力PI3902压力达( )kPa。", userId, new Date())); tPssrPublicService.insertTPssrPublic(new TPssrPublic(subId, "公用工程系统CW已投用或具备投用条件。", "界区阀已打开，CW进出口压差达( )kPa。", "CW进出口压差达( )kPa。", userId, new Date())); tPssrPublicService.insertTPssrPublic(new TPssrPublic(subId, "公用工程系统高压蒸汽已投用或具备投用条件。", "界区阀已打开，PC9112压力达( )MPa，TI9061温度达( )℃。", "PC9112压力达( )MPa，TI9061温度达( )℃。", userId, new Date())); tPssrPublicService.insertTPssrPublic(new TPssrPublic(subId, "公用工程系统中压蒸汽已投用或具备投用条件。", "界区阀已打开，PC9081压力达( )MPa，TI9081温度达( )℃。", "PC9081压力达( )MPa，TI9081温度达( )℃。", userId, new Date())); tPssrPublicService.insertTPssrPublic(new TPssrPublic(subId, "公用工程系统低压蒸汽已投用或具备投用条件。", "界区阀已打开，PY9109压力达( )MPa，TI9115温度达( )℃。", "PY9109压力达( )MPa，TI9115温度达( )℃。", userId, new Date())); tPssrPublicService.insertTPssrPublic(new TPssrPublic(subId, "公用工程系统精制凝液已投用或具备投用条件。", "界区阀已打开，P3505A/B/C压力达( )MPa。", "P3505A/B/C压力达( )MPa。", userId, new Date())); } //endregion //region 根据模板旧数据生成数据 /** * 根据模板旧数据生成数据 */ private void genPssrDataByModel(TPssrAboveall model, TPssrAboveall newData, String userId) { // new Thread(() -> {//同步模板数据 TPssrSubcontent subcontent = new TPssrSubcontent(); subcontent.setAboveallId(model.getId()); //查询旧数据对应的子表信息，然后根据模板生成新的子表数据 for (TPssrSubcontent oldSub : tPssrSubcontentService.selectTPssrSubcontentList(subcontent)) { //查询模板中是否有该子表数据，如果有则生成新的子表数据 TPssrSubcontent sub = new TPssrSubcontent(); sub.setAboveallId(newData.getId()); sub.setForShort(oldSub.getForShort()); TPssrSubcontent newSub = tPssrSubcontentService.selectTPssrSubcontentList(sub).get(0); switch (oldSub.getForShort()) { case "jxxm": genJxxm(oldSub, newSub, userId); break; case "kgfa": genKgfa(oldSub, newSub, userId); break; case "sjbg": genSjgb(oldSub, newSub, userId); break; case "mb": genMb(oldSub, newSub, userId); break; case "sbqjd": genSbqjd(oldSub, newSub, userId); break; case "qm": genQm(oldSub, newSub, userId); break; case "sksgfmzt": genSksgfmzt(oldSub, newSub, userId); break; case "sys": genSys(oldSub, newSub, userId); break; case "dj": genDj(oldSub, newSub, userId); break; case "dqzh": genDqzh(oldSub, newSub, userId); break; case "aqss": genAqss(oldSub, newSub, userId); break; case "jb": genJb(oldSub, newSub, userId); break; case "ybjy": genYbjy(oldSub, newSub, userId); break; case "yblscs": genYblscs(oldSub, newSub, userId); break; case "bjlszqr": genBjlszqr(oldSub, newSub, userId); break; case "djsb": genDjsb(oldSub, newSub, userId); break; case "qtjcy": genQtjcy(oldSub, newSub, userId); break; case "zxfxy": genZxfxy(oldSub, newSub, userId); break; } } // }, "新增模板子表数据").start(); } /** * 生成短接数据 */ private void genDj(TPssrSubcontent oldSub, TPssrSubcontent newSub, String userId) { TPssrCircuit circuit = new TPssrCircuit(); circuit.setSubId(oldSub.getId()); for (TPssrCircuit oldItem : tPssrCircuitService.selectTPssrCircuitList(circuit)) { TPssrCircuit newItem = oldItem; newItem.setSubId(newSub.getId()); newItem.setId(null); newItem.setCreatedate(new Date()); newItem.setCreaterCode(userId); newItem.setConfirmationDate(null); newItem.setApproveStatus(0L); newItem.setUpdaterCode(null); newItem.setUpdatedate(null); tPssrCircuitService.insertTPssrCircuit(newItem); } } /** * 生成实验室数据 */ private void genSys(TPssrSubcontent oldSub, TPssrSubcontent newSub, String userId) { TPssrLaboratory laboratory = new TPssrLaboratory(); laboratory.setSubId(oldSub.getId()); for (TPssrLaboratory oldItem : tPssrLaboratoryService.selectTPssrLaboratoryList(laboratory)) { TPssrLaboratory newItem = oldItem; newItem.setSubId(newSub.getId()); newItem.setId(null); newItem.setCreatedate(new Date()); newItem.setCreaterCode(userId); newItem.setConfirmationDate(null); newItem.setApproveStatus(0L); newItem.setUpdaterCode(null); newItem.setUpdatedate(null); tPssrLaboratoryService.insertTPssrLaboratory(newItem); } } /** * 生成锁开锁关数据 */ private void genSksgfmzt(TPssrSubcontent oldSub, TPssrSubcontent newSub, String userId) { TPssrLock lock = new TPssrLock(); lock.setSubId(oldSub.getId()); for (TPssrLock oldItem : tPssrLockService.selectTPssrLockList(lock)) { TPssrLock newItem = oldItem; newItem.setSubId(newSub.getId()); newItem.setId(null); newItem.setCreatedate(new Date()); newItem.setCreaterCode(userId); newItem.setConfirmationDate(null); newItem.setApproveStatus(0L); newItem.setUpdaterCode(null); newItem.setUpdatedate(null); tPssrLockService.insertTPssrLock(newItem); } } /** * 生成气密数据 */ private void genQm(TPssrSubcontent oldSub, TPssrSubcontent newSub, String userId) { TPssrAirtight airtight = new TPssrAirtight(); airtight.setSubId(oldSub.getId()); for (TPssrAirtight oldItem : tPssrAirtightService.selectTPssrAirtightList(airtight)) { TPssrAirtight newItem = oldItem; newItem.setSubId(newSub.getId()); newItem.setId(null); newItem.setCreatedate(new Date()); newItem.setCreaterCode(userId); newItem.setConfirmationDate(null); newItem.setApproveStatus(0L); newItem.setUpdaterCode(null); newItem.setUpdatedate(null); tPssrAirtightService.insertTPssrAirtight(newItem); } } /** * 生成设备清洁度数据 */ private void genSbqjd(TPssrSubcontent oldSub, TPssrSubcontent newSub, String userId) { TPssrCleaning cleaning = new TPssrCleaning(); cleaning.setSubId(oldSub.getId()); for (TPssrCleaning oldItem : tPssrCleaningService.selectTPssrCleaningList(cleaning)) { TPssrCleaning newItem = oldItem; newItem.setSubId(newSub.getId()); newItem.setId(null); newItem.setCreatedate(new Date()); newItem.setCreaterCode(userId); newItem.setConfirmationDate(null); newItem.setApproveStatus(0L); newItem.setUpdaterCode(null); newItem.setUpdatedate(null); tPssrCleaningService.insertTPssrCleaning(newItem); } } /** * 生成盲板数据 */ private void genMb(TPssrSubcontent oldSub, TPssrSubcontent newSub, String userId) { TPssrBlind blind = new TPssrBlind(); blind.setSubId(oldSub.getId()); for (TPssrBlind oldItem : tPssrBlindService.selectTPssrBlindList(blind)) { TPssrBlind newItem = oldItem; newItem.setSubId(newSub.getId()); newItem.setId(null); newItem.setCreatedate(new Date()); newItem.setCreaterCode(userId); newItem.setInstallDate(null); newItem.setApproveStatus(0L); newItem.setUpdaterCode(null); newItem.setUpdatedate(null); tPssrBlindService.insertTPssrBlind(newItem); } } /** * 生成氮气置换数据 */ private void genDqzh(TPssrSubcontent oldSub, TPssrSubcontent newSub, String userId) { TPssrNitrogen nitrogen = new TPssrNitrogen(); nitrogen.setSubId(oldSub.getId()); for (TPssrNitrogen oldItem : tPssrNitrogenService.selectTPssrNitrogenList(nitrogen)) { TPssrNitrogen newItem = oldItem; newItem.setSubId(newSub.getId()); newItem.setId(null); newItem.setCreatedate(new Date()); newItem.setCreaterCode(userId); newItem.setConfirmationDate(null); newItem.setApproveStatus(0L); newItem.setUpdaterCode(null); newItem.setUpdatedate(null); tPssrNitrogenService.insertTPssrNitrogen(newItem); } } /** * 生成安全设施数据 */ private void genAqss(TPssrSubcontent oldSub, TPssrSubcontent newSub, String userId) { //泄放阀 TPssrSafetyBleed safetyBleed = new TPssrSafetyBleed(); safetyBleed.setSubId(oldSub.getId()); for (TPssrSafetyBleed oldItem : tPssrSafetyBleedService.selectTPssrSafetyBleedList(safetyBleed)) { TPssrSafetyBleed newItem = oldItem; newItem.setSubId(newSub.getId()); newItem.setId(null); newItem.setCreatedate(new Date()); newItem.setCreaterCode(userId); newItem.setApproveStatus(0L); newItem.setUpdaterCode(null); newItem.setUpdatedate(null); tPssrSafetyBleedService.insertTPssrSafetyBleed(newItem); } //呼吸阀 TPssrSafetyBreath safetyBreath = new TPssrSafetyBreath(); safetyBreath.setSubId(oldSub.getId()); for (TPssrSafetyBreath oldItem : tPssrSafetyBreathService.selectTPssrSafetyBreathList(safetyBreath)) { TPssrSafetyBreath newItem = oldItem; newItem.setSubId(newSub.getId()); newItem.setId(null); newItem.setCreatedate(new Date()); newItem.setCreaterCode(userId); newItem.setApproveStatus(0L); newItem.setUpdaterCode(null); newItem.setUpdatedate(null); tPssrSafetyBreathService.insertTPssrSafetyBreath(newItem); } //爆破片 TPssrSafetyBrust safetyBrust = new TPssrSafetyBrust(); safetyBrust.setSubId(oldSub.getId()); for (TPssrSafetyBrust oldItem : tPssrSafetyBrustService.selectTPssrSafetyBrustList(safetyBrust)) { TPssrSafetyBrust newItem = oldItem; newItem.setSubId(newSub.getId()); newItem.setId(null); newItem.setCreatedate(new Date()); newItem.setCreaterCode(userId); newItem.setApproveStatus(0L); newItem.setUpdaterCode(null); newItem.setUpdatedate(null); tPssrSafetyBrustService.insertTPssrSafetyBrust(newItem); } //阻火器 TPssrSafetyFlamearrester safetyFlamearrester = new TPssrSafetyFlamearrester(); safetyFlamearrester.setSubId(oldSub.getId()); for (TPssrSafetyFlamearrester oldItem : tPssrSafetyFlamearresterService.selectTPssrSafetyFlamearresterList(safetyFlamearrester)) { TPssrSafetyFlamearrester newItem = oldItem; newItem.setSubId(newSub.getId()); newItem.setId(null); newItem.setCreatedate(new Date()); newItem.setCreaterCode(userId); newItem.setApproveStatus(0L); newItem.setUpdaterCode(null); newItem.setUpdatedate(null); tPssrSafetyFlamearresterService.insertTPssrSafetyFlamearrester(newItem); } } /** * 生成机泵数据 */ private void genJb(TPssrSubcontent oldSub, TPssrSubcontent newSub, String userId) { TPssrPumpCleaning pumpCleaning = new TPssrPumpCleaning(); pumpCleaning.setSubId(oldSub.getId()); for (TPssrPumpCleaning oldItem : tPssrPumpCleaningService.selectTPssrPumpCleaningList(pumpCleaning)) { TPssrPumpCleaning newItem = oldItem; newItem.setSubId(newSub.getId()); newItem.setId(null); newItem.setCreatedate(new Date()); newItem.setCreaterCode(userId); newItem.setConfirmationDate(null); newItem.setApproveStatus(0L); newItem.setUpdaterCode(null); newItem.setUpdatedate(null); tPssrPumpCleaningService.insertTPssrPumpCleaning(newItem); } TPssrPumpFill pumpFill = new TPssrPumpFill(); pumpFill.setSubId(oldSub.getId()); for (TPssrPumpFill oldItem : tPssrPumpFillService.selectTPssrPumpFillList(pumpFill)) { TPssrPumpFill newItem = oldItem; newItem.setSubId(newSub.getId()); newItem.setId(null); newItem.setCreatedate(new Date()); newItem.setCreaterCode(userId); newItem.setConfirmationDate(null); newItem.setApproveStatus(0L); newItem.setUpdaterCode(null); newItem.setUpdatedate(null); tPssrPumpFillService.insertTPssrPumpFill(newItem); } TPssrPumpOverhaul pumpOverhaul = new TPssrPumpOverhaul(); pumpOverhaul.setSubId(oldSub.getId()); for (TPssrPumpOverhaul oldItem : tPssrPumpOverhaulService.selectTPssrPumpOverhaulList(pumpOverhaul)) { TPssrPumpOverhaul newItem = oldItem; newItem.setSubId(newSub.getId()); newItem.setId(null); newItem.setCreatedate(new Date()); newItem.setCreaterCode(userId); newItem.setConfirmationDate(null); newItem.setApproveStatus(0L); newItem.setUpdaterCode(null); newItem.setUpdatedate(null); tPssrPumpOverhaulService.insertTPssrPumpOverhaul(newItem); } } /** * 生成仪表校验数据 */ private void genYbjy(TPssrSubcontent oldSub, TPssrSubcontent newSub, String userId) { TPssrInstrumentCalibration instrumentCalibration = new TPssrInstrumentCalibration(); instrumentCalibration.setSubId(oldSub.getId()); for (TPssrInstrumentCalibration oldItem : tPssrInstrumentCalibrationService.selectTPssrInstrumentCalibrationList(instrumentCalibration)) { TPssrInstrumentCalibration newItem = oldItem; newItem.setSubId(newSub.getId()); newItem.setId(null); newItem.setCreatedate(new Date()); newItem.setCreaterCode(userId); newItem.setConfirmationDate(null); newItem.setApproveStatus(0L); newItem.setUpdaterCode(null); newItem.setUpdatedate(null); tPssrInstrumentCalibrationService.insertTPssrInstrumentCalibration(newItem); } } /** * 生成仪表连锁测试数据 */ private void genYblscs(TPssrSubcontent oldSub, TPssrSubcontent newSub, String userId) { TPssrInstrumentTest instrumentTest = new TPssrInstrumentTest(); instrumentTest.setSubId(oldSub.getId()); for (TPssrInstrumentTest oldItem : tPssrInstrumentTestService.selectTPssrInstrumentTestList(instrumentTest)) { TPssrInstrumentTest newItem = oldItem; newItem.setSubId(newSub.getId()); newItem.setId(null); newItem.setCreatedate(new Date()); newItem.setCreaterCode(userId); newItem.setApproveStatus(0L); newItem.setUpdaterCode(null); newItem.setUpdatedate(null); tPssrInstrumentTestService.insertTPssrInstrumentTest(newItem); } } /** * 生成报警连锁值确认数据 */ private void genBjlszqr(TPssrSubcontent oldSub, TPssrSubcontent newSub, String userId) { TPssrAlarm alarm = new TPssrAlarm(); alarm.setSubId(oldSub.getId()); for (TPssrAlarm oldItem : tPssrAlarmService.selectTPssrAlarmList(alarm)) { TPssrAlarm newItem = oldItem; newItem.setSubId(newSub.getId()); newItem.setId(null); newItem.setCreatedate(new Date()); newItem.setCreaterCode(userId); newItem.setApproveStatus(0L); newItem.setUpdaterCode(null); newItem.setUpdatedate(null); tPssrAlarmService.insertTPssrAlarm(newItem); } } /** * 生成电机设备数据 */ private void genDjsb(TPssrSubcontent oldSub, TPssrSubcontent newSub, String userId) { TPssrMotor motor = new TPssrMotor(); motor.setSubId(oldSub.getId()); for (TPssrMotor oldItem : tPssrMotorService.selectTPssrMotorList(motor)) { TPssrMotor newItem = oldItem; newItem.setSubId(newSub.getId()); newItem.setId(null); newItem.setCreatedate(new Date()); newItem.setCreaterCode(userId); newItem.setConfirmationDate(null); newItem.setApproveStatus(0L); newItem.setUpdaterCode(null); newItem.setUpdatedate(null); tPssrMotorService.insertTPssrMotor(newItem); } } /** * 生成气体检测仪数据 */ private void genQtjcy(TPssrSubcontent oldSub, TPssrSubcontent newSub, String userId) { TPssrGasdetector gasdetector = new TPssrGasdetector(); gasdetector.setSubId(oldSub.getId()); for (TPssrGasdetector oldItem : tPssrGasdetectorService.selectTPssrGasdetectorList(gasdetector)) { TPssrGasdetector newItem = oldItem; newItem.setSubId(newSub.getId()); newItem.setId(null); newItem.setCreatedate(new Date()); newItem.setCreaterCode(userId); newItem.setConfirmationDate(null); newItem.setApproveStatus(0L); newItem.setUpdaterCode(null); newItem.setUpdatedate(null); tPssrGasdetectorService.insertTPssrGasdetector(newItem); } } /** * 生成在线分析仪数据 */ private void genZxfxy(TPssrSubcontent oldSub, TPssrSubcontent newSub, String userId) { TPssrAnalyzer analyzer = new TPssrAnalyzer(); analyzer.setSubId(oldSub.getId()); for (TPssrAnalyzer oldItem : tPssrAnalyzerService.selectTPssrAnalyzerList(analyzer)) { TPssrAnalyzer newItem = oldItem; newItem.setSubId(newSub.getId()); newItem.setId(null); newItem.setCreatedate(new Date()); newItem.setCreaterCode(userId); newItem.setConfirmationDate(null); newItem.setApproveStatus(0L); newItem.setUpdaterCode(null); newItem.setUpdatedate(null); tPssrAnalyzerService.insertTPssrAnalyzer(newItem); } } /** * 生成设计变更数据 */ private void genSjgb(TPssrSubcontent oldSub, TPssrSubcontent newSub, String userId) { TPssrMoc moc = new TPssrMoc(); moc.setSubId(oldSub.getId()); for (TPssrMoc oldItem : tPssrMocService.selectTPssrMocList(moc)) { TPssrMoc newItem = oldItem; newItem.setSubId(newSub.getId()); newItem.setId(null); newItem.setCreatedate(new Date()); newItem.setCreaterCode(userId); newItem.setConfirmationDate(null); newItem.setApproveStatus(0L); newItem.setUpdaterCode(null); newItem.setUpdatedate(null); tPssrMocService.insertTPssrMoc(newItem); } } /** * 生成检修项目数据 */ private void genJxxm(TPssrSubcontent oldSub, TPssrSubcontent newSub, String userId) { //换热器 TPssrOverhaulExchanger overhaulExchanger = new TPssrOverhaulExchanger(); overhaulExchanger.setSubId(oldSub.getId()); for (TPssrOverhaulExchanger exchanger : tPssrOverhaulExchangerService.selectTPssrOverhaulExchangerList(overhaulExchanger)) { TPssrOverhaulExchanger newItem = exchanger; newItem.setSubId(newSub.getId()); newItem.setId(null); newItem.setCreatedate(new Date()); newItem.setCreaterCode(userId); newItem.setCompletionDate(null); newItem.setApproveStatus(0L); newItem.setUpdaterCode(null); newItem.setUpdatedate(null); tPssrOverhaulExchangerService.insertTPssrOverhaulExchanger(newItem); } //过滤器 TPssrOverhaulFilter overhaulFilter = new TPssrOverhaulFilter(); overhaulFilter.setSubId(oldSub.getId()); for (TPssrOverhaulFilter filter : tPssrOverhaulFilterService.selectTPssrOverhaulFilterList(overhaulFilter)) { TPssrOverhaulFilter newItem = filter; newItem.setSubId(newSub.getId()); newItem.setId(null); newItem.setCreatedate(new Date()); newItem.setCreaterCode(userId); newItem.setCompletionDate(null); newItem.setApproveStatus(0L); newItem.setUpdaterCode(null); newItem.setUpdatedate(null); tPssrOverhaulFilterService.insertTPssrOverhaulFilter(newItem); } //塔罐 TPssrOverhaulTower overhaulTower = new TPssrOverhaulTower(); overhaulTower.setSubId(oldSub.getId()); for (TPssrOverhaulTower tower : tPssrOverhaulTowerService.selectTPssrOverhaulTowerList(overhaulTower)) { TPssrOverhaulTower newItem = tower; newItem.setSubId(newSub.getId()); newItem.setId(null); newItem.setCreatedate(new Date()); newItem.setCreaterCode(userId); newItem.setCompletionDate(null); newItem.setApproveStatus(0L); newItem.setUpdaterCode(null); newItem.setUpdatedate(null); tPssrOverhaulTowerService.insertTPssrOverhaulTower(newItem); } //阀门 TPssrOverhaulValve overhaulValve = new TPssrOverhaulValve(); overhaulValve.setSubId(oldSub.getId()); for (TPssrOverhaulValve valve : tPssrOverhaulValveService.selectTPssrOverhaulValveList(overhaulValve)) { TPssrOverhaulValve newItem = valve; newItem.setSubId(newSub.getId()); newItem.setId(null); newItem.setCreatedate(new Date()); newItem.setCreaterCode(userId); newItem.setDoneDate(null); newItem.setApproveStatus(0L); newItem.setUpdaterCode(null); newItem.setUpdatedate(null); tPssrOverhaulValveService.insertTPssrOverhaulValve(newItem); } } /** * 生成开工方案数据 */ private void genKgfa(TPssrSubcontent oldSub, TPssrSubcontent newSub, String userId) { TPssrProgramme programme = new TPssrProgramme(); programme.setSubId(oldSub.getId()); for (TPssrProgramme oldItem : tPssrProgrammeService.selectTPssrProgrammeList(programme)) { TPssrProgramme newItem = oldItem; newItem.setSubId(newSub.getId()); newItem.setId(null); newItem.setCreatedate(new Date()); newItem.setCreaterCode(userId); newItem.setApproveStatus(0L); newItem.setUpdaterCode(null); newItem.setUpdatedate(null); tPssrProgrammeService.insertTPssrProgramme(newItem); } } //endregion // region 发邮件 private void sendEmail(Set userIds, TPssrAboveall tPssrAboveall) { for (Long userId : userIds) { try { SysUser sysUser = userService.selectUserById(userId); String email = sysUser.getEmail(); String username = sysUser.getNickName(); String loginName = sysUser.getUserName(); String usernameEN = PinyinHelper.convertToPinyinString(username, " ", PinyinFormat.WITHOUT_TONE); logger.info("email:" + email); logger.info("username:" + username); //写html开始内容 String start = "
" + "" + ""; //表html中间内容 String prime = ""; String center = ""; String one = center.replaceFirst("username", username); String two = one.replaceFirst("usernameEN", usernameEN); String three = two.replace("loginName", loginName); String four = three.replace("region", tPssrAboveall.getRegion()); String five = four.replace("unit", "，" + tPssrAboveall.getUnit() + "单元"); String six = five.replace("aboveallId", tPssrAboveall.getId().toString() ); String seven = six.replaceFirst("startDate", DateUtils.dateTime(tPssrAboveall.getDrivingTime())); String result = seven.replaceFirst("date", DateUtils.dateTime()); prime = prime + result; //写html结尾内容 String end = "
" + "PSSR检查确认 PSSR

" + "" + "亲爱的 username(loginName)
" + "Dear usernameEN(loginName)

" + "

region区域unit的PSSR检查确认已经开始，预计开车时间为startDate：
" + "You Have A New PSSR:
" + "请登录PSSR清单中查看。
" + "Please log in the PSSR to handle it.

" + "

date

" + "
" + "
" + "

此为系统邮件，请勿回复
This e-Mail is an automatic reminder sent by CPMS, please do not reply

" + "
"; //拼接html String html = start + prime + end; logger.info("html:" + html); mailService.sendHtmlMail(email, "PSSR：您有新的PSSR检查待处理", html); } catch (Exception e) { logger.error("邮件发送失败" + JSON.toJSONString(e)); } try { //极光推送 jiGuangPushService.send("PSSR审批", "您有一个新的待办任务，请及时处理。", String.valueOf(userId)); //系统消息推送 SysMessage sysMessage = new SysMessage(); sysMessage.setMsgTitle("PSSR审批"); sysMessage.setMsgContent("您有一个新的待办任务，请及时处理。"); sysMessage.setUserId(userId); sysMessageService.insertSysMessage(sysMessage); } catch (Exception e) { logger.error("推送失败：{}", JSON.toJSONString(e)); } } } // endregion }