package cn.huge.module.cases.service;
|
|
import cn.huge.base.common.exception.ServiceException;
|
import cn.huge.base.common.utils.DateUtils;
|
import cn.huge.base.common.utils.IdUtils;
|
import cn.huge.base.common.utils.ObjectUtils;
|
import cn.huge.module.cases.domain.dto.FileRelateDTO;
|
import cn.huge.module.cases.domain.dto.FrontPageListDTO;
|
import cn.huge.module.cases.domain.dto.QuiltUnitDTO;
|
import cn.huge.module.cases.domain.po.CaseInfo;
|
import cn.huge.module.cases.domain.po.CaseInfoUnfold;
|
import cn.huge.module.cases.utils.TaskUsetimeUtils;
|
import cn.huge.module.client.api.impl.CustClientImpl;
|
import cn.huge.module.client.api.impl.SysClientImpl;
|
import cn.huge.module.client.api.impl.UtilsClientImpl;
|
import cn.huge.module.cases.dao.mapper.CaseSuperviseMapper;
|
import cn.huge.module.cases.domain.po.CaseSupervise;
|
import cn.huge.module.cust.dto.CtUserDTO;
|
import cn.huge.module.sy.service.SyHolidayService;
|
import cn.huge.module.sys.constant.FileOwnerTypeBaseEnum;
|
import cn.huge.module.sys.constant.SyTimeEnum;
|
import cn.huge.module.sys.dto.FileIdInfoBaseDTO;
|
import cn.huge.module.sys.dto.FileIdTypeInfoBaseDTO;
|
import cn.huge.module.sys.dto.FileInfoBaseDTO;
|
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
|
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
|
import org.apache.commons.collections.CollectionUtils;
|
import org.apache.commons.lang3.StringUtils;
|
import org.springframework.beans.BeanUtils;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.stereotype.Service;
|
import lombok.extern.slf4j.Slf4j;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.data.domain.Page;
|
import org.springframework.data.domain.PageImpl;
|
import org.springframework.data.domain.PageRequest;
|
import org.springframework.transaction.annotation.Transactional;
|
|
import javax.annotation.PostConstruct;
|
import java.util.*;
|
import java.util.stream.Collectors;
|
|
/**
|
* @title: 纠纷督办信息表业务逻辑处理
|
* @Description 纠纷督办信息表业务逻辑处理
|
* @company hugeinfo
|
* @author wangwh
|
* @Time 2024-09-03 10:53:01
|
* @version 1.0.0
|
*/
|
@Slf4j
|
@Service
|
@Transactional(rollbackFor = Exception.class)
|
public class CaseSuperviseService extends ServiceImpl<CaseSuperviseMapper, CaseSupervise>{
|
|
@Autowired
|
private CaseSuperviseMapper mapper;
|
|
@Autowired
|
private UtilsClientImpl utilsClient;
|
|
@Autowired
|
private CustClientImpl custClient;
|
|
@Autowired
|
private SysClientImpl sysClient;
|
|
@Autowired
|
private CaseInfoService caseInfoService;
|
|
@Autowired
|
private SyHolidayService syHolidayService;
|
|
/**
|
* 条件更新对象
|
* @param entity 对象
|
* @param terms 条件
|
*/
|
public void updateCaseSuperviseTerms(CaseSupervise entity, Map<String, Object> terms){
|
try{
|
mapper.updateCaseSuperviseTerms(entity, terms);
|
}catch (Exception e){
|
log.error("[CaseSuperviseService.updateCaseSuperviseTerms]调用失败，异常信息："+e, e);
|
throw new ServiceException("CaseSuperviseService.updateCaseSuperviseTerms", e);
|
}
|
}
|
|
/**
|
* 根据编号物理删除
|
* @param id 查询条件集合
|
*/
|
public void deleteCaseSupervise(String id){
|
try{
|
mapper.deleteCaseSupervise(id);
|
}catch (Exception e){
|
log.error("[CaseSuperviseService.deleteCaseSupervise]调用失败，异常信息："+e, e);
|
throw new ServiceException("CaseSuperviseService.deleteCaseSupervise", e);
|
}
|
}
|
|
/**
|
* 按条件查询
|
* @param terms 条件
|
* @return List
|
*/
|
public List<CaseSupervise> listTerms(Map<String, Object> terms){
|
return mapper.listTerms(terms);
|
}
|
|
/**
|
* 按条件统计
|
* @param terms 条件
|
* @return long
|
*/
|
public long countTerms(Map<String, Object> terms){
|
return mapper.countTerms(terms);
|
}
|
|
/**
|
* 按条件分页查询
|
* @param page 分页对象
|
* @param terms 条件
|
* @return Page
|
*/
|
public Page<CaseSupervise> pageQuery(PageRequest page, Map<String, Object> terms){
|
long total = mapper.countTerms(terms);
|
List<CaseSupervise> content = mapper.pageTerms(page, terms);
|
return new PageImpl<CaseSupervise>(content, page, total);
|
}
|
|
/**
|
* 新增或更新对象
|
* @param caseSupervise 实体对象
|
*/
|
public void saveCaseSupervise(CaseSupervise caseSupervise){
|
try{
|
Date nowDate = DateUtils.getNowDate();
|
// 判断是否新增
|
if (IdUtils.checkNewId(caseSupervise.getId())){
|
caseSupervise.setId(utilsClient.getNewTimeId());
|
caseSupervise.setCreateTime(nowDate);
|
}
|
caseSupervise.setUpdateTime(nowDate);
|
this.saveOrUpdate(caseSupervise);
|
}catch (Exception e){
|
log.error("[CaseSuperviseService.saveCaseSupervise]调用失败，异常信息："+e, e);
|
throw new ServiceException("CaseSuperviseService.saveCaseSupervise", e);
|
}
|
}
|
|
/**
|
* 添加督办
|
* @param caseSupervise 实体对象
|
*/
|
public void addCaseSupervise(CaseSupervise caseSupervise, String userId){
|
try{
|
List<QuiltUnitDTO> quiltUnitDTOList = caseSupervise.getQuiltUnitDTOList();
|
Integer timeTerm = sysClient.getTimeLimitHour(SyTimeEnum.SY_TIME_5.getIndex());
|
List<CaseSupervise> caseSuperviseList = new ArrayList<>();
|
List<FileRelateDTO> fileRelateDTOList = sysClient.listFileRelateByOwnerId(caseSupervise.getId());
|
int count = 0;
|
List<FileRelateDTO> fileRelateDTOListNew = new ArrayList<>();
|
for(QuiltUnitDTO quiltUnitDTO: quiltUnitDTOList){
|
CaseSupervise caseSuperviseNew = new CaseSupervise();
|
BeanUtils.copyProperties(caseSupervise, caseSuperviseNew);
|
// 获取当前登录用户
|
CtUserDTO loginUser = custClient.clientGetUserAll(userId);
|
Date nowDate = DateUtils.getNowDate();
|
caseSuperviseNew.setSupUserId(loginUser.getId());
|
caseSuperviseNew.setSupUserName(loginUser.getTrueName());
|
caseSuperviseNew.setSupUnitId(loginUser.getUnitId());
|
caseSuperviseNew.setSupUnitName(loginUser.getUnitName());
|
caseSuperviseNew.setSupTime(nowDate);
|
caseSuperviseNew.setQuiltUnitId(quiltUnitDTO.getQuiltUnitId());
|
caseSuperviseNew.setQuiltUnitName(quiltUnitDTO.getQuiltUnitName());
|
caseSuperviseNew.setSupStatus(0);
|
caseSuperviseNew.setCreateTime(nowDate);
|
caseSuperviseNew.setUpdateTime(nowDate);
|
caseSuperviseNew.setReplyTerm(timeTerm);
|
//给每条督办添加附件信息
|
if(0 != count){
|
String caseSupId = utilsClient.getNewTimeId();
|
caseSuperviseNew.setId(caseSupId);
|
for(FileRelateDTO fileRelateDTO: fileRelateDTOList){
|
String fileRealateId = utilsClient.getNewTimeSysId();
|
FileRelateDTO fileRelateDTONew = new FileRelateDTO();
|
BeanUtils.copyProperties(fileRelateDTO, fileRelateDTONew);
|
fileRelateDTONew.setOwnerId(caseSuperviseNew.getId());
|
fileRelateDTONew.setId(fileRealateId);
|
fileRelateDTOListNew.add(fileRelateDTONew);
|
}
|
}
|
caseSuperviseList.add(caseSuperviseNew);
|
count++;
|
}
|
this.saveBatch(caseSuperviseList);
|
if(CollectionUtils.isNotEmpty(fileRelateDTOListNew)){
|
sysClient.saveFileRelateList(fileRelateDTOListNew);
|
}
|
}catch (Exception e){
|
log.error("[CaseSuperviseService.saveCaseSupervise]调用失败，异常信息："+e, e);
|
throw new ServiceException("CaseSuperviseService.saveCaseSupervise", e);
|
}
|
}
|
|
/**
|
* 批量添加督办
|
* @param caseSuperviseList
|
*/
|
public void addBatchCaseSupervise(List<CaseSupervise> caseSuperviseList, String userId){
|
try{
|
List<CaseSupervise> caseSuperviseListNew = new ArrayList<>();
|
List<FileRelateDTO> fileRelateDTOListNew = new ArrayList<>();
|
//查询附件
|
List<FileRelateDTO> fileRelateDTOList = sysClient.listFileRelateByOwnerId(caseSuperviseList.get(0).getId());
|
// 获取当前登录用户
|
CtUserDTO loginUser = custClient.clientGetUserAll(userId);
|
//查询任务时限
|
Integer timeTerm = sysClient.getTimeLimitHour(SyTimeEnum.SY_TIME_5.getIndex());
|
for(CaseSupervise caseSupervise: caseSuperviseList){
|
List<QuiltUnitDTO> quiltUnitDTOList = caseSupervise.getQuiltUnitDTOList();
|
int count = 0;
|
|
for(QuiltUnitDTO quiltUnitDTO: quiltUnitDTOList){
|
CaseSupervise caseSuperviseNew = new CaseSupervise();
|
BeanUtils.copyProperties(caseSupervise, caseSuperviseNew);
|
Date nowDate = DateUtils.getNowDate();
|
caseSuperviseNew.setSupUserId(loginUser.getId());
|
caseSuperviseNew.setSupUserName(loginUser.getTrueName());
|
caseSuperviseNew.setSupUnitId(loginUser.getUnitId());
|
caseSuperviseNew.setSupUnitName(loginUser.getUnitName());
|
caseSuperviseNew.setSupTime(nowDate);
|
caseSuperviseNew.setQuiltUnitId(quiltUnitDTO.getQuiltUnitId());
|
caseSuperviseNew.setQuiltUnitName(quiltUnitDTO.getQuiltUnitName());
|
caseSuperviseNew.setSupStatus(0);
|
caseSuperviseNew.setCreateTime(nowDate);
|
caseSuperviseNew.setUpdateTime(nowDate);
|
caseSuperviseNew.setReplyTerm(timeTerm);
|
//给每条督办添加附件信息
|
if(0 != count){
|
String caseSupId = utilsClient.getNewTimeId();
|
caseSuperviseNew.setId(caseSupId);
|
for(FileRelateDTO fileRelateDTO: fileRelateDTOList){
|
String fileRealateId = utilsClient.getNewTimeSysId();
|
FileRelateDTO fileRelateDTONew = new FileRelateDTO();
|
BeanUtils.copyProperties(fileRelateDTO, fileRelateDTONew);
|
fileRelateDTONew.setOwnerId(caseSuperviseNew.getId());
|
fileRelateDTONew.setId(fileRealateId);
|
fileRelateDTOListNew.add(fileRelateDTONew);
|
}
|
}
|
caseSuperviseListNew.add(caseSuperviseNew);
|
count++;
|
}
|
}
|
|
this.saveBatch(caseSuperviseListNew);
|
if(CollectionUtils.isNotEmpty(fileRelateDTOListNew)){
|
sysClient.saveFileRelateList(fileRelateDTOListNew);
|
}
|
}catch (Exception e){
|
log.error("[CaseSuperviseService.saveCaseSupervise]调用失败，异常信息："+e, e);
|
throw new ServiceException("CaseSuperviseService.saveCaseSupervise", e);
|
}
|
}
|
|
/**
|
* 回复督办
|
* @param caseSupervise 对象
|
*/
|
public void replyCaseSupervise(CaseSupervise caseSupervise, String userId){
|
try{
|
CaseSupervise caseSupervisePO = mapper.selectById(caseSupervise.getId());
|
// 获取当前登录用户
|
CtUserDTO loginUser = custClient.clientGetUserAll(userId);
|
Date now = DateUtils.getNowDate();
|
caseSupervise.setSupStatus(1);
|
caseSupervise.setReplyUserId(loginUser.getId());
|
caseSupervise.setReplyUserName(loginUser.getTrueName());
|
caseSupervise.setReplyTime(now);
|
caseSupervise.setUpdateTime(now);
|
caseSupervise.setUsetimeHour(TaskUsetimeUtils.getUsetimeHour(caseSupervise.getReplyTime(), caseSupervisePO.getSupTime()));
|
caseSupervise.setOvertimeStatus(TaskUsetimeUtils.getOvertimeStatus(caseSupervise.getReplyTime(), syHolidayService.getExpiryHour(caseSupervisePO.getSupTime(), caseSupervisePO.getReplyTerm())));
|
caseSupervise.setOvertimeHour(TaskUsetimeUtils.getOvertimeHour(caseSupervise.getReplyTime(), syHolidayService.getExpiryHour(caseSupervisePO.getSupTime(), caseSupervisePO.getReplyTerm())));
|
mapper.updateCaseSupervise(caseSupervise);
|
}catch (Exception e){
|
log.error("[CaseSuperviseService.replyCaseSupervise]调用失败，异常信息："+e, e);
|
throw new ServiceException("CaseSuperviseService.replyCaseSupervise", e);
|
}
|
}
|
|
/**
|
* 流转办理-督办列表
|
* @param caseId 事项Id
|
*/
|
public Page<CaseSupervise> pageCaseSupervise(String caseId, PageRequest page, int supStatus, String userId, int type){
|
try{
|
CtUserDTO loginUser = custClient.clientGetUserAll(userId);
|
String quiltUnitId = loginUser.getUnitId();
|
Map<String, Object> terms = new HashMap<>();
|
terms.put("caseId", caseId);
|
terms.put("type", type);
|
if(1 == type){
|
terms.put("supStatus", supStatus);
|
terms.put("quiltUnitId", quiltUnitId);
|
}else if(2 == type){
|
terms.put("supStatus", supStatus);
|
}
|
long countSuperviseList = mapper.countCaseSupervise(terms);
|
List<CaseSupervise> caseSuperviseList = mapper.pageCaseSupervise(terms, page);
|
CaseInfo caseInfo = new CaseInfo();
|
if(CollectionUtils.isNotEmpty(caseSuperviseList)){
|
if(1 != type){
|
|
QueryWrapper<CaseInfo>caseInfoQueryWrapper = new QueryWrapper<>();
|
caseInfoQueryWrapper.eq("id", caseId);
|
caseInfo = caseInfoService.getOne(caseInfoQueryWrapper);
|
for(CaseSupervise caseSupervise: caseSuperviseList){
|
if(ObjectUtils.isNotEmpty(caseSupervise.getSupTime()) && ObjectUtils.isNotEmpty(caseSupervise.getReplyTerm())){
|
caseSupervise.setTimeLimit(syHolidayService.getExpiryHour(caseSupervise.getSupTime(), caseSupervise.getReplyTerm()));
|
}
|
if(ObjectUtils.isNotEmpty(caseInfo)){
|
caseSupervise.setCaseGrade(caseInfo.getCaseLevel());
|
}
|
}
|
}else{
|
Map<String, Object>map = new HashMap<>();
|
map.put("mainId", caseId);
|
map.put("ownerIds", "'" + caseSuperviseList.stream().map(CaseSupervise::getId).collect(Collectors.joining("','"))+ "'");
|
map.put("types", "'"+ FileOwnerTypeBaseEnum.OWNER_TYPE_506.getIndex()+ "','" +FileOwnerTypeBaseEnum.OWNER_TYPE_507.getIndex()+"'");
|
List<FileIdTypeInfoBaseDTO> fileIdTypeInfoBaseDTOList = sysClient.listIdTypeInfoByOwnerIdList(map);
|
for(CaseSupervise caseSupervise: caseSuperviseList){
|
for(FileIdTypeInfoBaseDTO fileIdTypeInfoBaseDTO: fileIdTypeInfoBaseDTOList){
|
if(caseSupervise.getId().equals(fileIdTypeInfoBaseDTO.getOwnerId())){
|
caseSupervise.setFileInfoList(fileIdTypeInfoBaseDTO.getFileList());
|
}
|
}
|
}
|
}
|
}
|
return new PageImpl<CaseSupervise>(caseSuperviseList, page, countSuperviseList);
|
}catch (Exception e){
|
log.error("[CaseSuperviseService.pageReplied]调用失败，异常信息："+e, e);
|
throw new ServiceException("CaseSuperviseService.pageReplied", e);
|
}
|
}
|
|
/**
|
* 首页-督办
|
* @param page
|
* @param terms
|
*/
|
public Page<FrontPageListDTO> pageMyTaskDb(PageRequest page, Map<String, Object> terms){
|
try{
|
long countSuperviseList = mapper.countMyTaskDb(terms);
|
List<FrontPageListDTO> caseSuperviseList = mapper.pageMyTaskDb(page, terms);
|
return new PageImpl<FrontPageListDTO>(caseSuperviseList, page, countSuperviseList);
|
}catch (Exception e){
|
log.error("[CaseSuperviseService.pageReplied]调用失败，异常信息："+e, e);
|
throw new ServiceException("CaseSuperviseService.pageReplied", e);
|
}
|
}
|
|
/**
|
* 查询督办数量
|
* @param supStatus 回复状态
|
* @param quiltUnitId 被督办组织编号
|
* @return long
|
*/
|
public long countCaseSuperviseList(Integer supStatus, String quiltUnitId){
|
return mapper.countCaseSuperviseList(supStatus, quiltUnitId);
|
}
|
|
/**
|
* 根据督办编号查询督办信息
|
* @param id 督办编号
|
* @return List
|
*/
|
public CaseSupervise getById(String id){
|
try {
|
CaseSupervise caseSupervise = mapper.selectById(id);
|
Map<String, Object> terms = new HashMap<>();
|
terms.put("mainId", caseSupervise.getCaseId());
|
terms.put("ownerIds", "'" + id + "'");
|
List<FileIdTypeInfoBaseDTO> fileIdTypeInfoBaseDTOList = sysClient.listIdTypeInfoByOwnerIdList(terms);
|
if(CollectionUtils.isNotEmpty(fileIdTypeInfoBaseDTOList)){
|
caseSupervise.setFileInfoList(fileIdTypeInfoBaseDTOList.get(0).getFileList());
|
}
|
return caseSupervise;
|
}catch (Exception e){
|
log.error("[CaseSuperviseService.getById]调用失败，异常信息："+e, e);
|
throw new ServiceException("CaseSuperviseService.getById", e);
|
}
|
|
}
|
}
|
