diff --git a/src/main/java/com/zhgd/xmgl/modules/dangerous/service/IDangerousEngineeringRecordService.java b/src/main/java/com/zhgd/xmgl/modules/dangerous/service/IDangerousEngineeringRecordService.java index 55172451d..26b2c0da4 100644 --- a/src/main/java/com/zhgd/xmgl/modules/dangerous/service/IDangerousEngineeringRecordService.java +++ b/src/main/java/com/zhgd/xmgl/modules/dangerous/service/IDangerousEngineeringRecordService.java @@ -31,4 +31,6 @@ public interface IDangerousEngineeringRecordService extends IService paramMap); BigDecimal getScore(String projectSn, Date time); + + void finish(Long engineeringId); } diff --git a/src/main/java/com/zhgd/xmgl/modules/dangerous/service/impl/DangerousEngineeringProgressRecordServiceImpl.java b/src/main/java/com/zhgd/xmgl/modules/dangerous/service/impl/DangerousEngineeringProgressRecordServiceImpl.java index f5e6f184f..d79c7e3b2 100644 --- a/src/main/java/com/zhgd/xmgl/modules/dangerous/service/impl/DangerousEngineeringProgressRecordServiceImpl.java +++ b/src/main/java/com/zhgd/xmgl/modules/dangerous/service/impl/DangerousEngineeringProgressRecordServiceImpl.java @@ -28,11 +28,13 @@ public class DangerousEngineeringProgressRecordServiceImpl extends ServiceImpl selectEngineeringProgressList(Map map) { + map.putIfAbsent("type", 1); return dangerousEngineeringProgressRecordMapper.selectEngineeringProgressList(map); } @Override public Page selectEngineeringProgressPage(Map map) { + map.putIfAbsent("type", 1); Page page = PageUtil.getPage(map); return dangerousEngineeringProgressRecordMapper.selectEngineeringProgressList(map, page); } diff --git a/src/main/java/com/zhgd/xmgl/modules/dangerous/service/impl/DangerousEngineeringRecordServiceImpl.java b/src/main/java/com/zhgd/xmgl/modules/dangerous/service/impl/DangerousEngineeringRecordServiceImpl.java index da8c28c8e..df96bd8d2 100644 --- a/src/main/java/com/zhgd/xmgl/modules/dangerous/service/impl/DangerousEngineeringRecordServiceImpl.java +++ b/src/main/java/com/zhgd/xmgl/modules/dangerous/service/impl/DangerousEngineeringRecordServiceImpl.java @@ -4,6 +4,7 @@ import cn.hutool.core.collection.CollUtil; import cn.hutool.core.date.DateUtil; import cn.hutool.core.util.StrUtil; import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; +import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper; import com.baomidou.mybatisplus.core.metadata.IPage; import com.baomidou.mybatisplus.core.toolkit.Wrappers; import com.baomidou.mybatisplus.extension.plugins.pagination.Page; @@ -255,4 +256,12 @@ public class DangerousEngineeringRecordServiceImpl extends ServiceImpl() + .eq(DangerousEngineeringRecord::getId, engineeringId) + .set(DangerousEngineeringRecord::getFinalAcceptanceStatus, 2) + ); + } } diff --git a/src/main/java/com/zhgd/xmgl/modules/dangerous/service/impl/DangerousEngineeringSideStationServiceImpl.java b/src/main/java/com/zhgd/xmgl/modules/dangerous/service/impl/DangerousEngineeringSideStationServiceImpl.java index 7fde29a32..3a6107e22 100644 --- a/src/main/java/com/zhgd/xmgl/modules/dangerous/service/impl/DangerousEngineeringSideStationServiceImpl.java +++ b/src/main/java/com/zhgd/xmgl/modules/dangerous/service/impl/DangerousEngineeringSideStationServiceImpl.java @@ -29,11 +29,13 @@ public class DangerousEngineeringSideStationServiceImpl extends ServiceImpl selectSideStationList(Map map) { + map.putIfAbsent("type", 1); return dangerousEngineeringSideStationMapper.selectSideStationList(map); } @Override public Page selectSideStationPage(Map map) { + map.putIfAbsent("type", 1); Page page = PageUtil.getPage(map); return dangerousEngineeringSideStationMapper.selectSideStationList(map, page); } diff --git a/src/main/java/com/zhgd/xmgl/modules/xz.security/mapper/xml/XzSecurityQualityInspectionRecordMapper.xml b/src/main/java/com/zhgd/xmgl/modules/xz.security/mapper/xml/XzSecurityQualityInspectionRecordMapper.xml index 3f068144f..58e19f5fd 100644 --- a/src/main/java/com/zhgd/xmgl/modules/xz.security/mapper/xml/XzSecurityQualityInspectionRecordMapper.xml +++ b/src/main/java/com/zhgd/xmgl/modules/xz.security/mapper/xml/XzSecurityQualityInspectionRecordMapper.xml @@ -2,6 +2,9 @@ + + and t.type = #{param.type} + and t.inspect_time =]]> #{param.inspectTime_begin} @@ -261,6 +264,9 @@ LEFT join subdivision_project subentry on subentry.id = t.subentry_id LEFT join dangerous_engineering_record der on der.id = t.engineering_id WHERE t.project_sn = #{param.projectSn} + + and t.type = #{param.type} + and t.enterprise_id = #{param.enterpriseId} diff --git a/src/main/java/com/zhgd/xmgl/modules/xz.security/service/impl/XzSecurityXzSecurityQualityInspectionRecordServiceImpl.java b/src/main/java/com/zhgd/xmgl/modules/xz.security/service/impl/XzSecurityXzSecurityQualityInspectionRecordServiceImpl.java index 512fdef0e..88a65a182 100644 --- a/src/main/java/com/zhgd/xmgl/modules/xz.security/service/impl/XzSecurityXzSecurityQualityInspectionRecordServiceImpl.java +++ b/src/main/java/com/zhgd/xmgl/modules/xz.security/service/impl/XzSecurityXzSecurityQualityInspectionRecordServiceImpl.java @@ -171,6 +171,7 @@ public class XzSecurityXzSecurityQualityInspectionRecordServiceImpl extends Serv } } Page page = new Page<>(pageNo, pageSize); + map.putIfAbsent("type", 1); List list = xzSecurityQualityInspectionRecordMapper.selectQualityInspectionRecordPage(page, map); for (XzSecurityQualityInspectionRecordVo vo : list) { setProblemDescription(vo); diff --git a/src/main/java/com/zhgd/xmgl/modules/xz/service/impl/XzDangerousEngineeringAcceptanceServiceImpl.java b/src/main/java/com/zhgd/xmgl/modules/xz/service/impl/XzDangerousEngineeringAcceptanceServiceImpl.java index 54824a8a0..e4e9446b1 100644 --- a/src/main/java/com/zhgd/xmgl/modules/xz/service/impl/XzDangerousEngineeringAcceptanceServiceImpl.java +++ b/src/main/java/com/zhgd/xmgl/modules/xz/service/impl/XzDangerousEngineeringAcceptanceServiceImpl.java @@ -3,7 +3,6 @@ package com.zhgd.xmgl.modules.xz.service.impl; import cn.hutool.core.collection.CollUtil; import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; -import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper; import com.baomidou.mybatisplus.core.metadata.IPage; import com.baomidou.mybatisplus.extension.plugins.pagination.Page; import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; @@ -13,17 +12,17 @@ import com.zhgd.xmgl.modules.basicdata.entity.SystemUser; import com.zhgd.xmgl.modules.basicdata.service.impl.SystemUserServiceImpl; import com.zhgd.xmgl.modules.dangerous.entity.DangerousEngineeringControlItem; import com.zhgd.xmgl.modules.dangerous.entity.DangerousEngineeringProgressRecord; -import com.zhgd.xmgl.modules.dangerous.entity.DangerousEngineeringRecord; import com.zhgd.xmgl.modules.dangerous.entity.DangerousEngineeringSideStation; import com.zhgd.xmgl.modules.dangerous.mapper.DangerousEngineeringProgressRecordMapper; -import com.zhgd.xmgl.modules.dangerous.mapper.DangerousEngineeringRecordMapper; import com.zhgd.xmgl.modules.dangerous.mapper.DangerousEngineeringSideStationMapper; import com.zhgd.xmgl.modules.dangerous.service.impl.DangerousEngineeringControlItemServiceImpl; +import com.zhgd.xmgl.modules.dangerous.service.impl.DangerousEngineeringRecordServiceImpl; import com.zhgd.xmgl.modules.xz.entity.XzDangerousEngineeringAcceptance; import com.zhgd.xmgl.modules.xz.mapper.XzDangerousEngineeringAcceptanceMapper; import com.zhgd.xmgl.modules.xz.security.entity.XzSecurityQualityInspectionRecord; import com.zhgd.xmgl.modules.xz.security.mapper.XzSecurityQualityInspectionRecordMapper; import com.zhgd.xmgl.modules.xz.service.IXzDangerousEngineeringAcceptanceService; +import com.zhgd.xmgl.modules.xz.special.service.impl.XzSpecialOperationFireSafetyServiceImpl; import com.zhgd.xmgl.security.util.SecurityUtils; import com.zhgd.xmgl.util.PageUtil; import com.zhgd.xmgl.util.RefUtil; @@ -54,11 +53,11 @@ public class XzDangerousEngineeringAcceptanceServiceImpl extends ServiceImpl queryPageList(HashMap paramMap) { @@ -76,6 +75,7 @@ public class XzDangerousEngineeringAcceptanceServiceImpl extends ServiceImpl getQueryWrapper(HashMap paramMap) { + paramMap.putIfAbsent("type", 1); String alias = "xdea."; QueryWrapper queryWrapper = QueryGenerator.initPageQueryWrapper(XzDangerousEngineeringAcceptance.class, paramMap, alias); queryWrapper.orderByDesc(alias + RefUtil.fieldNameUlc(XzDangerousEngineeringAcceptance::getCreateTime)); @@ -88,7 +88,7 @@ public class XzDangerousEngineeringAcceptanceServiceImpl extends ServiceImpl dangerousEngineeringProgressRecords = dangerousEngineeringProgressRecordMapper.selectList(new LambdaQueryWrapper() .eq(DangerousEngineeringProgressRecord::getEngineeringId, engineeringId) @@ -119,6 +120,7 @@ public class XzDangerousEngineeringAcceptanceServiceImpl extends ServiceImpl notCloseList = xzSecurityQualityInspectionRecords.stream().filter(xzSecurityQualityInspectionRecord -> xzSecurityQualityInspectionRecord.getStatus() != 5 && xzSecurityQualityInspectionRecord.getStatus() != 6 && xzSecurityQualityInspectionRecord.getType() == 1).collect(Collectors.toList()); if (CollUtil.isNotEmpty(notCloseList)) { @@ -131,28 +133,32 @@ public class XzDangerousEngineeringAcceptanceServiceImpl extends ServiceImpl map = new HashMap<>(); - map.put("engineeringId", engineeringId); - List dangerousEngineeringControlItems = dangerousEngineeringControlItemService.selectEngineeringControlItemList(map); - List notCollectList = dangerousEngineeringControlItems.stream().filter(dangerousEngineeringControlItem -> dangerousEngineeringControlItem.getChooseType() == null || Objects.equals(dangerousEngineeringControlItem.getChooseType(), 2)).collect(Collectors.toList()); - if (CollUtil.isNotEmpty(notCollectList)) { - throw new OpenAlertException("有管控要点未正确,无法添加验收"); + + if (type == 1) { + HashMap map = new HashMap<>(); + map.put("engineeringId", engineeringId); + List dangerousEngineeringControlItems = dangerousEngineeringControlItemService.selectEngineeringControlItemList(map); + List notCollectList = dangerousEngineeringControlItems.stream().filter(dangerousEngineeringControlItem -> dangerousEngineeringControlItem.getChooseType() == null || Objects.equals(dangerousEngineeringControlItem.getChooseType(), 2)).collect(Collectors.toList()); + if (CollUtil.isNotEmpty(notCollectList)) { + throw new OpenAlertException("有管控要点未正确,无法添加验收"); + } } + } @Override public void edit(XzDangerousEngineeringAcceptance acceptance) { - XzDangerousEngineeringAcceptance oldXzDangerousEngineeringAcceptance = baseMapper.selectById(acceptance.getId()); - if (oldXzDangerousEngineeringAcceptance == null) { + XzDangerousEngineeringAcceptance old = baseMapper.selectById(acceptance.getId()); + if (old == null) { throw new OpenAlertException("未找到对应实体"); } baseMapper.updateById(acceptance); + Long engineeringId = old.getEngineeringId(); if (Objects.equals(acceptance.getAcceptanceResult(), 1) && Objects.equals(acceptance.getType(), 1)) { - dangerousEngineeringRecordMapper.update(null, new LambdaUpdateWrapper() - .eq(DangerousEngineeringRecord::getId, oldXzDangerousEngineeringAcceptance.getEngineeringId()) - .set(DangerousEngineeringRecord::getFinalAcceptanceStatus, 2) - ); + dangerousEngineeringRecordService.finish(engineeringId); + } else if (Objects.equals(acceptance.getAcceptanceResult(), 1) && Objects.equals(acceptance.getType(), 2)) { + xzSpecialOperationFireSafetyService.finish(engineeringId); } } diff --git a/src/main/java/com/zhgd/xmgl/modules/xz/special/service/IXzSpecialOperationFireSafetyService.java b/src/main/java/com/zhgd/xmgl/modules/xz/special/service/IXzSpecialOperationFireSafetyService.java index 9c33e7896..503f7af8c 100644 --- a/src/main/java/com/zhgd/xmgl/modules/xz/special/service/IXzSpecialOperationFireSafetyService.java +++ b/src/main/java/com/zhgd/xmgl/modules/xz/special/service/IXzSpecialOperationFireSafetyService.java @@ -26,4 +26,6 @@ public interface IXzSpecialOperationFireSafetyService extends IService() + .eq(XzSpecialOperationFireSafety::getId, engineeringId) + .set(XzSpecialOperationFireSafety::getFinalAcceptanceStatus, 2) + ); + } + }