|
|
@@ -0,0 +1,188 @@
|
|
|
+package cn.start.tz.module.pressure2.service.dynamicOFData.pipe;
|
|
|
+
|
|
|
+import cn.start.tz.module.pressure2.controller.admin.dynamictbins.vo.CreateInstantiateWithRuleVO;
|
|
|
+import cn.start.tz.module.pressure2.dal.dataobject.equippipe.EquipPipeDO;
|
|
|
+import cn.start.tz.module.pressure2.dal.dataobject.equippipedetail.EquipPipeDetailDO;
|
|
|
+import cn.start.tz.module.pressure2.dal.dataobject.pipetaskorder.PipeTaskOrderDO;
|
|
|
+import cn.start.tz.module.pressure2.dal.dataobject.pipetaskorderinput.PipeTaskOrderInputDO;
|
|
|
+import cn.start.tz.module.pressure2.dal.dataobject.pipetaskorderitem.PipeTaskOrderItemDO;
|
|
|
+import cn.start.tz.module.pressure2.dal.dataobject.pipetaskorderitemdetail.PipeTaskOrderItemDetailDO;
|
|
|
+import cn.start.tz.module.pressure2.dal.dataobject.pipetaskorderitemreport.PipeTaskOrderItemReportDO;
|
|
|
+import cn.start.tz.module.pressure2.dal.mysql.equippipe.EquipPipeMapper;
|
|
|
+import cn.start.tz.module.pressure2.dal.mysql.equippipedetail.EquipPipeDetailMapper;
|
|
|
+import cn.start.tz.module.pressure2.dal.mysql.pipetaskorder.PipeTaskOrderMapper;
|
|
|
+import cn.start.tz.module.pressure2.dal.mysql.pipetaskorderitem.PipeTaskOrderItemMapper;
|
|
|
+import cn.start.tz.module.pressure2.dal.mysql.pipetaskorderitemdetail.PipeTaskOrderItemDetailMapper;
|
|
|
+import cn.start.tz.module.pressure2.dal.mysql.pipetaskorderitemreport.PipeTaskOrderItemReportMapper;
|
|
|
+import cn.start.tz.module.pressure2.service.dynamicOFData.IDynamicOFData;
|
|
|
+import cn.start.tz.module.pressure2.service.dynamicOFData.util.AutoDataPipeService;
|
|
|
+import cn.start.tz.module.pressure2.service.dynamicOFData.util.GenerateReportJsonService;
|
|
|
+import cn.start.tz.module.pressure2.service.dynamicOFData.util.JsonConvertUtil;
|
|
|
+import cn.start.tz.module.pressure2.service.dynamictbcol.DynamicTbColService;
|
|
|
+import cn.start.tz.module.pressure2.service.dynamictbval.DynamicTbValService;
|
|
|
+import cn.start.tz.module.pressure2.service.pipetaskorderinput.PipeTaskOrderInputService;
|
|
|
+import cn.start.tz.module.system.api.clientunit.ClientUnitApi;
|
|
|
+import cn.start.tz.module.system.api.clientunit.dto.ClientUnitDTO;
|
|
|
+import cn.start.tz.module.system.api.dict.DictDataApi;
|
|
|
+import cn.start.tz.module.system.api.dict.dto.DictDataRespDTO;
|
|
|
+import cn.start.tz.module.system.api.user.AdminUserApi;
|
|
|
+import com.alibaba.fastjson2.JSONObject;
|
|
|
+import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
|
|
|
+import jakarta.annotation.Resource;
|
|
|
+import org.apache.commons.lang3.StringUtils;
|
|
|
+import org.springframework.stereotype.Service;
|
|
|
+
|
|
|
+import java.time.format.DateTimeFormatter;
|
|
|
+import java.util.List;
|
|
|
+import java.util.Objects;
|
|
|
+import java.util.Set;
|
|
|
+import java.util.stream.Collectors;
|
|
|
+
|
|
|
+/**
|
|
|
+ * 状况不明工业管道安全评估结论报告
|
|
|
+ */
|
|
|
+@Service("QC12077_202401ReportOFData")
|
|
|
+public class QC12077_202401ReportOFData implements IDynamicOFData {
|
|
|
+
|
|
|
+ @Resource
|
|
|
+ private EquipPipeMapper equipPipeMapper;
|
|
|
+
|
|
|
+ @Resource
|
|
|
+ private EquipPipeDetailMapper equipPipeDetailMapper;
|
|
|
+
|
|
|
+ @Resource
|
|
|
+ private PipeTaskOrderItemMapper pipeTaskOrderItemMapper;
|
|
|
+
|
|
|
+ @Resource
|
|
|
+ private PipeTaskOrderItemReportMapper pipeTaskOrderItemReportMapper;
|
|
|
+
|
|
|
+ @Resource
|
|
|
+ private PipeTaskOrderMapper pipeTaskOrderMapper;
|
|
|
+
|
|
|
+ @Resource
|
|
|
+ private PipeTaskOrderInputService pipeTaskOrderInputService;
|
|
|
+
|
|
|
+ @Resource
|
|
|
+ private PipeTaskOrderItemDetailMapper pipeTaskOrderItemDetailMapper;
|
|
|
+
|
|
|
+ @Resource
|
|
|
+ private DynamicTbValService dynamicTbValService;
|
|
|
+
|
|
|
+ @Resource
|
|
|
+ private DynamicTbColService dynamicTbColService;
|
|
|
+
|
|
|
+ @Resource
|
|
|
+ private GenerateReportJsonService generateReportJsonService;
|
|
|
+
|
|
|
+ @Resource
|
|
|
+ private AdminUserApi adminUserApi;
|
|
|
+
|
|
|
+ @Resource
|
|
|
+ private DictDataApi dictDataApi;
|
|
|
+
|
|
|
+ @Resource
|
|
|
+ private AutoDataPipeService autoDataPipeService;
|
|
|
+
|
|
|
+ @Resource
|
|
|
+ private ClientUnitApi clientUnitApi;
|
|
|
+
|
|
|
+ @Override
|
|
|
+ public JSONObject getOFData(JSONObject params) {
|
|
|
+ return null;
|
|
|
+ }
|
|
|
+
|
|
|
+ @Override
|
|
|
+ public JSONObject getOfDataByVO(CreateInstantiateWithRuleVO ruleVO) {
|
|
|
+
|
|
|
+ //日期格式
|
|
|
+ DateTimeFormatter dateFormat = DateTimeFormatter.ofPattern("yyyy年MM月dd日");
|
|
|
+
|
|
|
+ //设备报表ID
|
|
|
+ String refId = ruleVO.getRefId();
|
|
|
+
|
|
|
+ JSONObject result = new JSONObject();
|
|
|
+ PipeTaskOrderItemReportDO itemReportDO = pipeTaskOrderItemReportMapper.selectById(refId);
|
|
|
+
|
|
|
+ if (itemReportDO != null) {
|
|
|
+
|
|
|
+ //根据记录字段动态生成报告字段
|
|
|
+ result = generateReportJsonService.generateReportFromRecord(ruleVO.getReportType(), ruleVO.getTemplateId(), refId);
|
|
|
+ result = autoDataPipeService.autoGeneratePipeReportData(result, refId);
|
|
|
+
|
|
|
+ List<PipeTaskOrderItemDO> itemDOList = pipeTaskOrderItemMapper.selectList(new LambdaQueryWrapper<PipeTaskOrderItemDO>()
|
|
|
+ .eq(PipeTaskOrderItemDO::getOrderId, itemReportDO.getOrderId()));
|
|
|
+ if (!itemDOList.isEmpty()) {
|
|
|
+
|
|
|
+ //设备信息
|
|
|
+ List<PipeTaskOrderItemDetailDO> allDetailDOS = pipeTaskOrderItemDetailMapper.selectList(PipeTaskOrderItemDetailDO::getOrderId, itemReportDO.getOrderId());
|
|
|
+ if (!allDetailDOS.isEmpty()){
|
|
|
+ List<EquipPipeDetailDO> equipPipeDetailDOList = equipPipeDetailMapper.selectList(new LambdaQueryWrapper<EquipPipeDetailDO>().in(EquipPipeDetailDO::getId, allDetailDOS.stream().map(PipeTaskOrderItemDetailDO::getEquipDetailId).toList()));
|
|
|
+ double sum = equipPipeDetailDOList.stream().mapToDouble(equipPipeDetailDO -> equipPipeDetailDO.getPipeLength() != null ? equipPipeDetailDO.getPipeLength().doubleValue() : 0.0).sum();
|
|
|
+ result.put("pipeLengthTotal", JsonConvertUtil.formatNumber(sum));
|
|
|
+ }
|
|
|
+ //获取约检管线
|
|
|
+ if (!allDetailDOS.isEmpty()){
|
|
|
+
|
|
|
+ List<EquipPipeDetailDO> equipPipeDetailDOList = equipPipeDetailMapper.selectList(new LambdaQueryWrapper<EquipPipeDetailDO>()
|
|
|
+ .in(EquipPipeDetailDO::getId, allDetailDOS.stream().map(PipeTaskOrderItemDetailDO::getEquipDetailId).toList()));
|
|
|
+ if (equipPipeDetailDOList.size() > 1){
|
|
|
+ result.put("pipeName","见一览表" );
|
|
|
+ }else if (equipPipeDetailDOList.size() == 1){
|
|
|
+ result.put("pipeName", equipPipeDetailDOList.get(0).getPipeName());
|
|
|
+ }
|
|
|
+
|
|
|
+ if (!equipPipeDetailDOList.isEmpty()) {
|
|
|
+ // 判断pipeLevel是否相同
|
|
|
+ String pipeLevelValue;
|
|
|
+ Set<String> pipeLevels = equipPipeDetailDOList.stream()
|
|
|
+ .map(EquipPipeDetailDO::getPipeLevel)
|
|
|
+ .filter(Objects::nonNull)
|
|
|
+ .collect(Collectors.toSet());
|
|
|
+ // 如果只有一个唯一的pipeLevel值,则使用该值;否则设置为"见一览表"
|
|
|
+ pipeLevelValue = pipeLevels.size() == 1 ? pipeLevels.iterator().next() : "见一览表";
|
|
|
+ result.put("pipeLevel", pipeLevelValue);
|
|
|
+ }
|
|
|
+
|
|
|
+ }
|
|
|
+
|
|
|
+ EquipPipeDO equipPipeDO = equipPipeMapper.selectById(itemDOList.get(0).getEquipId());
|
|
|
+ if (equipPipeDO != null){
|
|
|
+ if (equipPipeDO.getUnitCode() != null){
|
|
|
+ //企业信息
|
|
|
+ ClientUnitDTO clientUnit = clientUnitApi.getClientUnitByCode(equipPipeDO.getUnitCode()).getData();
|
|
|
+ if (clientUnit != null){
|
|
|
+ result.put("socialCreditCode", clientUnit.getSocialCreditCode());
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ result.put("unitName", equipPipeDO.getUnitName());
|
|
|
+ result.put("unitAddress", equipPipeDO.getUnitAddress());
|
|
|
+ result.put("zipCode", equipPipeDO.getPostalCode());
|
|
|
+ result.put("securityDept", equipPipeDO.getSecurityDept());
|
|
|
+ result.put("securityMan", equipPipeDO.getSecurityMan());
|
|
|
+ result.put("pipeClass", equipPipeDO.getPipeClass());
|
|
|
+ result.put("contactPhone", equipPipeDO.getContactPhone());
|
|
|
+
|
|
|
+ if (equipPipeDO.getNextLegalCheckDate() != null){
|
|
|
+ result.put("nextLegalCheckDate", equipPipeDO.getNextLegalCheckDate().format(dateFormat));
|
|
|
+ }
|
|
|
+ if (equipPipeDO.getNextYearCheckDate() != null){
|
|
|
+ result.put("nextYearCheckDate", equipPipeDO.getNextYearCheckDate().format(dateFormat));
|
|
|
+ }
|
|
|
+
|
|
|
+ }
|
|
|
+
|
|
|
+ if (itemDOList.size() > 1) {
|
|
|
+
|
|
|
+ } else {
|
|
|
+ if (equipPipeDO != null) {
|
|
|
+
|
|
|
+ }
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ }
|
|
|
+
|
|
|
+ return result;
|
|
|
+ }
|
|
|
+}
|