|
@@ -15,6 +15,7 @@ import com.zfjg.manage.api.dto.other.EnforceObjArchitectureRelateAdd;
|
|
|
import com.zfjg.manage.api.dto.other.EnforceObjArchitectureRelateUpdate;
|
|
|
import com.zfjg.manage.api.dto.other.EnforceObjChangeArchitectureDTO;
|
|
|
import com.zfjg.manage.api.dto.other.EnforceObjCheckDTO;
|
|
|
+import com.zfjg.manage.api.factory.EnforceObjChangeHisFallbackFactory;
|
|
|
import com.zfjg.manage.api.search.other.EnforceObjArchitectureRelateQuery;
|
|
|
import com.zfjg.manage.api.vo.other.ArchitectureVO;
|
|
|
import com.zfjg.manage.mapper.other.EnforceObjArchitectureRelateMapper;
|
|
@@ -25,6 +26,8 @@ import com.zfjg.system.api.domain.SysDept;
|
|
|
import com.zfjg.system.api.domain.SysUser;
|
|
|
import lombok.RequiredArgsConstructor;
|
|
|
import lombok.SneakyThrows;
|
|
|
+import org.slf4j.Logger;
|
|
|
+import org.slf4j.LoggerFactory;
|
|
|
import org.springframework.beans.BeanUtils;
|
|
|
import org.springframework.stereotype.Service;
|
|
|
import org.springframework.beans.factory.annotation.Autowired;
|
|
@@ -44,10 +47,14 @@ import java.util.stream.Collectors;
|
|
|
*/
|
|
|
@Service
|
|
|
public class EnforceObjArchitectureRelateServiceImpl extends ServiceImpl<EnforceObjArchitectureRelateMapper, EnforceObjArchitectureRelate> implements IEnforceObjArchitectureRelateService {
|
|
|
+ private static final Logger log = LoggerFactory.getLogger(EnforceObjArchitectureRelateServiceImpl.class);
|
|
|
+
|
|
|
@Autowired
|
|
|
private IEnforceObjArchitectureRelateHisService enforceObjArchitectureRelateHisService;
|
|
|
@Autowired
|
|
|
private EnforceObjArchitectureRelateMapper enforceObjArchitectureRelateMapper;
|
|
|
+ @Autowired
|
|
|
+ private DeptMapper deptMapper;
|
|
|
|
|
|
@Override
|
|
|
public boolean insertEnforceObjArchitectureRelate(EnforceObjArchitectureRelateAdd add) {
|
|
@@ -79,7 +86,8 @@ public class EnforceObjArchitectureRelateServiceImpl extends ServiceImpl<Enforce
|
|
|
EnforceObjArchitectureRelate dt = this.getOne(new LambdaQueryWrapper<EnforceObjArchitectureRelate>()
|
|
|
.eq(EnforceObjArchitectureRelate::getEnforceObjId, param.getEnforceObjId()));
|
|
|
if (Objects.equals(param.getArchitectureUuid(), dt.getArchitectureUuid()) && Objects.equals(param.getRelateType(),dt.getRelateType())) {
|
|
|
- throw new ServerException("选择建筑与之前一样!");
|
|
|
+ log.info("选择建筑与之前一样!");
|
|
|
+ return true;
|
|
|
}
|
|
|
EnforceObjArchitectureRelateHis his = new EnforceObjArchitectureRelateHis();
|
|
|
his.setEnforceObjId(dt.getEnforceObjId());
|
|
@@ -105,10 +113,23 @@ public class EnforceObjArchitectureRelateServiceImpl extends ServiceImpl<Enforce
|
|
|
|
|
|
@Override
|
|
|
public List<EnforceObjCheckDTO> getEnforceObjList(EnforceObjArchitectureRelateQuery query) {
|
|
|
- List<EnforceObjCheckDTO> list = enforceObjArchitectureRelateMapper.getEnforceObjList(query);
|
|
|
- if (CollectionUtils.isNotEmpty(list)) {
|
|
|
+ List<EnforceObjCheckDTO> list = new ArrayList<>();
|
|
|
+ String orgId = SecurityUtils.getOrgId();
|
|
|
+ SysDept userLoginDept = Optional.ofNullable(deptMapper.selectOne(Wrappers.<SysDept>lambdaQuery()
|
|
|
+ .eq(SysDept::getEnforceOrgId, orgId)
|
|
|
+ .last("limit 1")
|
|
|
+ )).orElse(new SysDept());
|
|
|
+ if (StrUtil.isBlank(userLoginDept.getRegionCode())) return list;
|
|
|
+
|
|
|
+ //非建筑所属辖区或非总队无权限查看
|
|
|
+ if (!Objects.equals(query.getRegionId(), userLoginDept.getRegionCode() + "000000") && !Objects.equals(0L, userLoginDept.getParentId())) {
|
|
|
+ return list;
|
|
|
+ }
|
|
|
+
|
|
|
+ List<String> enforceObjIds = enforceObjArchitectureRelateMapper.getEnforceObjIds(query);
|
|
|
+ if (CollectionUtils.isNotEmpty(enforceObjIds)) {
|
|
|
+ list = enforceObjArchitectureRelateMapper.getEnforceObjList(enforceObjIds);
|
|
|
//任务记录列表
|
|
|
- List<String> enforceObjIds = list.stream().map(EnforceObjCheckDTO::getEnforceObjId).collect(Collectors.toList());
|
|
|
List<EnforceJobObjDTO> enforceJobObjDTOS = enforceObjArchitectureRelateMapper.getEnforceJobList(enforceObjIds);
|
|
|
if (CollectionUtils.isNotEmpty(enforceJobObjDTOS)) {
|
|
|
Map<String, List<EnforceJobObjDTO>> jobMap = enforceJobObjDTOS.stream().collect(Collectors.groupingBy(EnforceJobObjDTO::getEnforceObjId));
|