Microservice/pqs
5
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases 1 Wiki Activity

1.技术监督功能干扰源用户代码提交

Browse Source
This commit is contained in:
cdf
2024-04-10 09:02:17 +08:00
parent 90de9184d4
commit 859be88988
6 changed files with 161 additions and 67 deletions
Download Patch File Download Diff File Expand all files Collapse all files

17
pqs-process/process-boot/src/main/java/com/njcn/process/controller/LoadTypeUserManageController.java
View File

@@ -117,7 +117,7 @@ public class LoadTypeUserManageController extends BaseController {
* @author qijian
* @date 2022/11/14
*/
@OperateInfo(info = LogEnum.BUSINESS_COMMON,operateType= OperateType.UPDATE)
@OperateInfo(info = LogEnum.BUSINESS_COMMON)
@PostMapping("/uploadLoadTypeUserI")
@ApiOperation("上传干扰源用户入网报告（未建档干扰源用户管理）")
public HttpResult<Boolean> uploadLoadTypeUserI(@Validated LoadTypeUserIUploadParam loadTypeUserIUploadParam){
@@ -234,4 +234,19 @@ public class LoadTypeUserManageController extends BaseController {
PoiUtil.exportFileByWorkbook(workbook, fileName, response);
return null;
}
/**
* 删除新增干扰源用户计划
* @author cdf
* @date 2024/4/9
*/
@OperateInfo(info = LogEnum.BUSINESS_COMMON)
@ApiOperation("删除新增干扰源用户计划")
@PostMapping(value = "delLoadTypeUserPlan")
@ApiImplicitParam(name = "list", value = "主键参数集合", required = true)
public HttpResult<String>delLoadTypeUserPlan(@RequestBody List<String> list) {
String methodDescribe = getMethodDescribe("delLoadTypeUserPlan");
loadTypeUserManageService.delLoadTypeUserPlan(list);
return HttpResultUtil.assembleCommonResponseResult(CommonResponseEnum.SUCCESS, null, methodDescribe);
}
}

29
pqs-process/process-boot/src/main/java/com/njcn/process/service/LoadTypeUserManageService.java
View File

@@ -79,20 +79,29 @@ public interface LoadTypeUserManageService {
* @return
*/
List<LoadTypeRelationExcel> exportLoadTypeRelationList(List<String> list);
/**
/**
* @Description: 入网评估报告审核
* @Param: [loadTypeUserCheckParam]
* @return: java.lang.Boolean
* @Param: [loadTypeUserCheckParam]
* @return: java.lang.Boolean
* @Author: clam
* @Date: 2023/2/22
*/
* @Date: 2023/2/22
*/
Boolean checkLoadTypeUserI(LoadTypeUserCheckParam loadTypeUserCheckParam);
/**
/**
* @Description: 实测报告审核
* @Param: [loadTypeUserCheckParam]
* @return: java.lang.Boolean
* @Param: [loadTypeUserCheckParam]
* @return: java.lang.Boolean
* @Author: clam
* @Date: 2023/2/22
*/
* @Date: 2023/2/22
*/
Boolean checkLoadTypeUserA(LoadTypeUserCheckParam loadTypeUserCheckParam);
/**
*
* @author cdf
* @date 2024/4/9
*/
Boolean delLoadTypeUserPlan(List<String> ids);
}

121
pqs-process/process-boot/src/main/java/com/njcn/process/service/impl/LoadTypeUserManageServiceImpl.java
View File

@@ -1,11 +1,14 @@
package com.njcn.process.service.impl;
import cn.hutool.core.collection.CollectionUtil;
import cn.hutool.core.date.DateUtil;
import cn.hutool.core.lang.UUID;
import cn.hutool.core.util.IdUtil;
import cn.hutool.core.util.StrUtil;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.core.conditions.update.UpdateWrapper;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.njcn.common.config.GeneralInfo;
import com.njcn.common.pojo.enums.response.CommonResponseEnum;
import com.njcn.common.pojo.exception.BusinessException;
@@ -14,6 +17,7 @@ import com.njcn.oss.constant.OssPath;
import com.njcn.device.pms.api.DistributionMonitorClient;
import com.njcn.oss.utils.FileStorageUtil;
import com.njcn.process.constant.Param;
import com.njcn.process.enums.AuditProcessEnum;
import com.njcn.process.mapper.FlowFormAssMapper;
import com.njcn.process.mapper.FlowableAssMapper;
import com.njcn.process.mapper.LoadTypeUserManageMapper;
@@ -34,8 +38,11 @@ import com.njcn.system.enums.DicDataEnum;
import com.njcn.system.enums.DicDataTypeEnum;
import com.njcn.system.pojo.po.DictData;
import com.njcn.user.api.DeptFeignClient;
import com.njcn.user.api.UserFeignClient;
import com.njcn.user.pojo.dto.DeptDTO;
import com.njcn.user.pojo.dto.UserDTO;
import com.njcn.user.pojo.po.Dept;
import com.njcn.user.pojo.po.User;
import com.njcn.user.pojo.vo.PvTerminalTreeVO;
import com.njcn.web.utils.RequestUtil;
import com.njcn.web.utils.WebUtil;
@@ -51,6 +58,7 @@ import org.springframework.web.multipart.MultipartFile;
import javax.annotation.Resource;
import java.util.*;
import java.util.function.Function;
import java.util.stream.Collectors;
/**
@@ -63,12 +71,14 @@ import java.util.stream.Collectors;
@Service
@RequiredArgsConstructor
@Slf4j
public class LoadTypeUserManageServiceImpl implements LoadTypeUserManageService {
public class LoadTypeUserManageServiceImpl extends ServiceImpl<LoadTypeUserManageMapper,RLoadTypeUserManage> implements LoadTypeUserManageService {
private final LoadTypeUserManageMapper loadTypeUserManageMapper;
private final DicDataFeignClient dicDataFeignClient;
private final DeptFeignClient deptFeignClient;
private final UserFeignClient userFeignClient;
private final FileStorageUtil fileStorageUtil;
private final FlowFormAssMapper flowFormAssMapper;
@@ -100,12 +110,40 @@ public class LoadTypeUserManageServiceImpl implements LoadTypeUserManageService
}
//干扰源用户信息录入
Page<RLoadTypeUserManageVO> loadTypeUserPage = loadTypeUserManageMapper.getLoadTypeUserPage(page, loadTypeUserSearchParam,ids,aStatus);
//查询审核，创建用户信息
List<String> personList = new ArrayList<>();
loadTypeUserPage.getRecords().forEach(it->{
if(StrUtil.isNotBlank(it.getACheckPerson())){
personList.add(it.getACheckPerson());
}
if(StrUtil.isNotBlank(it.getACheckPerson())){
personList.add(it.getICheckPerson());
}
if(StrUtil.isNotBlank(it.getCreateBy())){
personList.add(it.getCreateBy());
}
});
Map<String,User> userMap = new HashMap<>();
if(CollectionUtil.isNotEmpty(personList)){
List<User> userList = userFeignClient.getUserByIdList(personList.stream().distinct().collect(Collectors.toList())).getData();
userMap = userList.stream().collect(Collectors.toMap(User::getId, Function.identity()));
}
List<PvTerminalTreeVO> dept = deptFeignClient.allDeptList().getData();
Map<String, PvTerminalTreeVO> pvTerminalTreeVOMap = dept.stream().collect(Collectors.toMap(PvTerminalTreeVO::getId, pvTerminalTreeVO -> pvTerminalTreeVO));
//部门处理：根据部门code取名称
loadTypeUserPage.getRecords().stream().forEach(item -> {
item.setOrgName(pvTerminalTreeVOMap.get(item.getOrgNo()).getName()); //单位名称
});
for(RLoadTypeUserManageVO rLoadTypeUserManageVO : loadTypeUserPage.getRecords()){
if(StrUtil.isNotBlank(rLoadTypeUserManageVO.getACheckPerson())){
rLoadTypeUserManageVO.setACheckPersonName(userMap.get(rLoadTypeUserManageVO.getACheckPerson()).getName());
}
if(StrUtil.isNotBlank(rLoadTypeUserManageVO.getICheckPersonName())){
rLoadTypeUserManageVO.setICheckPersonName(userMap.get(rLoadTypeUserManageVO.getICheckPersonName()).getName());
}
if(StrUtil.isNotBlank(rLoadTypeUserManageVO.getCreateBy())){
rLoadTypeUserManageVO.setCreateByName(userMap.get(rLoadTypeUserManageVO.getCreateBy()).getName());
}
rLoadTypeUserManageVO.setOrgName(pvTerminalTreeVOMap.get(rLoadTypeUserManageVO.getOrgNo()).getName()); //单位名称
}
//返回新的数据组
return loadTypeUserPage;
}
@@ -149,15 +187,11 @@ public class LoadTypeUserManageServiceImpl implements LoadTypeUserManageService
//塞入建档时间
Date date = DateUtil.parse(loadTypeUserParam.getRecordTime(), "yyyy-MM-dd HH:mm:ss");
rLoadTypeUserManage.setRecordTime(date);
//获取部门信息
Dept data = deptFeignClient.getDeptById (loadTypeUserParam.getOrgNo()).getData();
rLoadTypeUserManage.setICheckPerson(data.getPid());
rLoadTypeUserManage.setACheckPerson(data.getPid());
rLoadTypeUserManage.setIStatus(AuditProcessEnum.New.getStatus());
rLoadTypeUserManage.setId(IdUtil.simpleUUID());
loadTypeUserManageMapper.insert(rLoadTypeUserManage);
//绑定工作流
//开始流程
FlowFormAss flowFormAss = flowFormAssMapper.selectOne(new LambdaQueryWrapper<FlowFormAss>().eq(FlowFormAss::getFormId, 2));
if (Objects.isNull(flowFormAss)) {
@@ -195,25 +229,8 @@ public class LoadTypeUserManageServiceImpl implements LoadTypeUserManageService
rLoadTypeUserManage.setIFilePathName(multipartFile.getOriginalFilename());
rLoadTypeUserManage.setIUploadTime(new Date());
}
//提交：待审核/保存：新建
String dictData;
if (Objects.equals(Param.LOAD_TYPE_USER_SUBMIT, loadTypeUserIUploadParam.getStatus())) {
dictData = dicDataFeignClient.getDicDataByCode(DicDataEnum.AUDIT.getCode()).getData().getId();
rLoadTypeUserManage.setICheckPerson("");
rLoadTypeUserManage.setICheckComment("");
} else {
//是否是未通过，未通过则不修改状态
if(aBoolean){
dictData=null;
}else{
dictData = dicDataFeignClient.getDicDataByCode(DicDataEnum.NEWLY.getCode()).getData().getId();
}
}
rLoadTypeUserManage.setIStatus(dictData);
rLoadTypeUserManage.setIIsFileUpload(rLoadTypeUserManage.getIFilePath()!=null?1:0);
loadTypeUserManageMapper.updateById(rLoadTypeUserManage);
return true;
}
@@ -290,7 +307,7 @@ public class LoadTypeUserManageServiceImpl implements LoadTypeUserManageService
}
//提交：待审核/保存：新建
DictData dictData;
/* DictData dictData;
if (Objects.equals(Param.LOAD_TYPE_USER_SUBMIT, loadTypeUserAUploadParam.getStatus())) {
dictData = dicDataFeignClient.getDicDataByCode(DicDataEnum.AUDIT.getCode()).getData();
} else {
@@ -303,7 +320,7 @@ public class LoadTypeUserManageServiceImpl implements LoadTypeUserManageService
}
if(!aBoolean){
rLoadTypeUserManage.setAStatus(dictData.getId());
}
}*/
rLoadTypeUserManage.setAIsFileUpload(rLoadTypeUserManage.getAFilePath()!=null?1:0);
loadTypeUserManageMapper.updateById(rLoadTypeUserManage);
return true;
@@ -461,6 +478,26 @@ public class LoadTypeUserManageServiceImpl implements LoadTypeUserManageService
return result;
}
@Override
public Boolean delLoadTypeUserPlan(List<String> ids) {
List<RLoadTypeUserManage> rLoadTypeUserManageList = this.lambdaQuery().in(RLoadTypeUserManage::getId,ids).list();
long count = rLoadTypeUserManageList.stream().map(RLoadTypeUserManage::getIStatus).filter(item-> Objects.equals(item, AuditProcessEnum.WaitAudit.getStatus())||Objects.equals(item, AuditProcessEnum.Release.getStatus())).count();
if(count>0){
throw new BusinessException("非新建驳回状态条目无法删除");
}
this.removeByIds(ids);
//删除同时删除报告
for(RLoadTypeUserManage rLoadTypeUserManage : rLoadTypeUserManageList){
if(Objects.equals(rLoadTypeUserManage.getAIsFileUpload(),1)){
fileStorageUtil.getFileUrl(rLoadTypeUserManage.getIFilePath());
}
if(Objects.equals(rLoadTypeUserManage.getAIsFileUpload(),1)){
fileStorageUtil.getFileUrl(rLoadTypeUserManage.getAFilePath());
}
}
return true;
}
/**
* @Description: 干扰源用户报告状态，待审核无法修改信息
* @param id
@@ -469,37 +506,21 @@ public class LoadTypeUserManageServiceImpl implements LoadTypeUserManageService
* @Date: 2024/1/30 10:44
*/
private Boolean checkStatus(String id,Integer type){
Boolean fly=false;
RLoadTypeUserManage rLoadTypeUserManage = loadTypeUserManageMapper.selectById(id);
if(type==0){
//入网评估
DictData audit = dicDataFeignClient.getDicDataByCode(DicDataEnum.AUDIT.getCode()).getData();
DictData finish = dicDataFeignClient.getDicDataByCode(DicDataEnum.FINISH.getCode()).getData();
String iStatus = rLoadTypeUserManage.getIStatus();
if(audit.getId().equals(iStatus)||finish.getId().equals(iStatus)){
Integer iStatus = rLoadTypeUserManage.getIStatus();
if(Objects.equals(iStatus, AuditProcessEnum.WaitAudit.getStatus()) ||Objects.equals(iStatus, AuditProcessEnum.Release.getStatus()) ){
throw new BusinessException(CommonResponseEnum.FAIL, "只有新建和未通过状态下，可修改信息");
}
DictData failed = dicDataFeignClient.getDicDataByCode(DicDataEnum.FAILED.getCode()).getData();
if(failed.getId().equals(iStatus)){
fly=true;
}
}
if(type==1){
}else if(type==1){
//实测评估
DictData audit = dicDataFeignClient.getDicDataByCode(DicDataEnum.AUDITT.getCode()).getData();
DictData success = dicDataFeignClient.getDicDataByCode(DicDataEnum.SUCCESS.getCode()).getData();
String aStatus = rLoadTypeUserManage.getAStatus();
if(audit.getId().equals(aStatus)||success.getId().equals(aStatus)){
Integer aStatus = rLoadTypeUserManage.getAStatus();
if(Objects.equals(aStatus, AuditProcessEnum.WaitAudit.getStatus()) ||Objects.equals(aStatus, AuditProcessEnum.Release.getStatus()) ){
throw new BusinessException(CommonResponseEnum.FAIL, "只有新建和未通过状态下，可修改信息");
}
DictData failed = dicDataFeignClient.getDicDataByCode(DicDataEnum.FAIL.getCode()).getData();
if(failed.getId().equals(aStatus)){
fly=true;
}
}
return fly;
return true;
}