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.CaseFlowDTO;
|
import cn.huge.module.cases.domain.dto.TabButtonDTO;
|
import cn.huge.module.cases.domain.dto.TabButtonInfoDTO;
|
import cn.huge.module.client.api.impl.CustClientImpl;
|
import cn.huge.module.client.api.impl.UtilsClientImpl;
|
import cn.huge.module.cases.dao.mapper.CaseTaskMapper;
|
import cn.huge.module.cases.domain.po.CaseTask;
|
import cn.huge.module.cust.dto.CtUserDTO;
|
import cn.huge.module.mediate.constant.CaseBaseConsts;
|
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
|
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
|
import com.google.common.collect.Maps;
|
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.*;
|
|
/**
|
* @title: 纠纷任务表业务逻辑处理
|
* @Description 纠纷任务表业务逻辑处理
|
* @company hugeinfo
|
* @author liyj
|
* @Time 2024-09-06 15:50:06
|
* @version 1.0.0
|
*/
|
@Slf4j
|
@Service
|
@Transactional(rollbackFor = Exception.class)
|
public class CaseTaskService extends ServiceImpl<CaseTaskMapper, CaseTask>{
|
|
@Autowired
|
private CaseTaskMapper mapper;
|
|
@Autowired
|
private UtilsClientImpl utilsClient;
|
|
@Autowired
|
private CustClientImpl custClient;
|
|
@Autowired
|
private CaseSuperviseService superviseService;
|
|
/**
|
* 更新对象
|
* @param entity 对象
|
*/
|
public void updateCaseTask(CaseTask entity){
|
try{
|
mapper.updateCaseTask(entity);
|
}catch (Exception e){
|
log.error("[CaseTaskService.updateCaseTask]调用失败，异常信息："+e, e);
|
throw new ServiceException("CaseTaskService.updateCaseTask", e);
|
}
|
}
|
|
/**
|
* 条件更新对象
|
* @param entity 对象
|
* @param terms 条件
|
*/
|
public void updateCaseTaskTerms(CaseTask entity, Map<String, Object> terms){
|
try{
|
mapper.updateCaseTaskTerms(entity, terms);
|
}catch (Exception e){
|
log.error("[CaseTaskService.updateCaseTaskTerms]调用失败，异常信息："+e, e);
|
throw new ServiceException("CaseTaskService.updateCaseTaskTerms", e);
|
}
|
}
|
|
/**
|
* 根据编号物理删除
|
* @param id 查询条件集合
|
*/
|
public void deleteCaseTask(String id){
|
try{
|
mapper.deleteCaseTask(id);
|
}catch (Exception e){
|
log.error("[CaseTaskService.deleteCaseTask]调用失败，异常信息："+e, e);
|
throw new ServiceException("CaseTaskService.deleteCaseTask", e);
|
}
|
}
|
|
/**
|
* 按条件查询
|
* @param terms 条件
|
* @return List
|
*/
|
public List<CaseTask> 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<CaseTask> pageQuery(PageRequest page, Map<String, Object> terms){
|
long total = mapper.countTerms(terms);
|
List<CaseTask> content = mapper.pageTerms(page, terms);
|
return new PageImpl<CaseTask>(content, page, total);
|
}
|
|
/**
|
* 新增或更新对象
|
* @param caseTask 实体对象
|
*/
|
public void saveCaseTask(CaseTask caseTask){
|
try{
|
Date nowDate = DateUtils.getNowDate();
|
// 判断是否新增
|
if (IdUtils.checkNewId(caseTask.getId())){
|
caseTask.setId(utilsClient.getNewTimeId());
|
caseTask.setCreateTime(nowDate);
|
}
|
caseTask.setUpdateTime(nowDate);
|
this.saveOrUpdate(caseTask);
|
}catch (Exception e){
|
log.error("[CaseTaskService.saveCaseTask]调用失败，异常信息："+e, e);
|
throw new ServiceException("CaseTaskService.saveCaseTask", e);
|
}
|
}
|
|
/**
|
* web端-任务出来页面-初始化tab和按钮
|
* @param caseTaskId
|
* @return
|
*/
|
public TabButtonDTO webGetTabButton(String caseTaskId, String userId){
|
try{
|
// 临时给前端联调数据
|
TabButtonDTO tabButtonDTO = new TabButtonDTO();
|
List<TabButtonInfoDTO> tabList = new LinkedList<>();
|
TabButtonInfoDTO sxxq = new TabButtonInfoDTO();
|
sxxq.setId("sxxq");
|
sxxq.setName("事项详情");
|
tabList.add(sxxq);
|
|
TabButtonInfoDTO dslxq = new TabButtonInfoDTO();
|
dslxq.setId("dslxq");
|
dslxq.setName("详情");
|
tabList.add(dslxq);
|
|
TabButtonInfoDTO sxbl = new TabButtonInfoDTO();
|
sxbl.setId("sxbl");
|
sxbl.setName("事项办理");
|
tabList.add(sxbl);
|
|
TabButtonInfoDTO sqjl = new TabButtonInfoDTO();
|
sqjl.setId("sqjl");
|
sqjl.setName("申请记录");
|
tabList.add(sqjl);
|
|
TabButtonInfoDTO htsh = new TabButtonInfoDTO();
|
htsh.setId("htsh");
|
htsh.setName("回退审核");
|
tabList.add(htsh);
|
|
TabButtonInfoDTO sbsh = new TabButtonInfoDTO();
|
sbsh.setId("sbsh");
|
sbsh.setName("上报审核");
|
tabList.add(sbsh);
|
|
TabButtonInfoDTO jash = new TabButtonInfoDTO();
|
jash.setId("jash");
|
jash.setName("结案审核");
|
tabList.add(jash);
|
|
TabButtonInfoDTO lhczsh = new TabButtonInfoDTO();
|
lhczsh.setId("lhczsh");
|
lhczsh.setName("联合处置申请审核");
|
tabList.add(lhczsh);
|
|
TabButtonInfoDTO lcdb = new TabButtonInfoDTO();
|
lcdb.setId("lcdb");
|
lcdb.setName("流程督办");
|
tabList.add(lcdb);
|
|
TabButtonInfoDTO daxx = new TabButtonInfoDTO();
|
daxx.setId("daxx");
|
daxx.setName("档案信息");
|
tabList.add(daxx);
|
tabButtonDTO.setTabList(tabList);
|
|
List<TabButtonInfoDTO> buttonList = new LinkedList<>();
|
TabButtonInfoDTO tjbljl = new TabButtonInfoDTO();
|
tjbljl.setId("tjbljl");
|
tjbljl.setName("添加办理记录");
|
buttonList.add(tjbljl);
|
|
TabButtonInfoDTO lhczsq = new TabButtonInfoDTO();
|
lhczsq.setId("lhczsq");
|
lhczsq.setName("联合处置申请");
|
buttonList.add(lhczsq);
|
|
TabButtonInfoDTO jasq = new TabButtonInfoDTO();
|
jasq.setId("jasq");
|
jasq.setName("结案申请");
|
buttonList.add(jasq);
|
|
TabButtonInfoDTO db = new TabButtonInfoDTO();
|
db.setId("db");
|
db.setName("督办");
|
buttonList.add(db);
|
|
TabButtonInfoDTO sl = new TabButtonInfoDTO();
|
sl.setId("sl");
|
sl.setName("受理");
|
buttonList.add(sl);
|
|
TabButtonInfoDTO ht = new TabButtonInfoDTO();
|
ht.setId("ht");
|
ht.setName("回退");
|
buttonList.add(ht);
|
|
TabButtonInfoDTO zxsl = new TabButtonInfoDTO();
|
zxsl.setId("zxsl");
|
zxsl.setName("自行受理");
|
buttonList.add(zxsl);
|
|
TabButtonInfoDTO jb = new TabButtonInfoDTO();
|
jb.setId("jb");
|
jb.setName("交办");
|
buttonList.add(jb);
|
|
TabButtonInfoDTO sb = new TabButtonInfoDTO();
|
sb.setId("sb");
|
sb.setName("上报");
|
buttonList.add(sb);
|
tabButtonDTO.setButtonList(buttonList);
|
return tabButtonDTO;
|
}catch (Exception e){
|
log.error("[CaseTaskService.webGetTabButton]调用失败，异常信息："+e, e);
|
throw new ServiceException("CaseTaskService.webGetTabButton", e);
|
}
|
}
|
|
/**
|
* web端-查询流程进度
|
* @param caseId 纠纷编号
|
* @return
|
*/
|
public Map<String, Object> webListCaseFlow(String caseId, String userId){
|
try{
|
// 临时给前端联调数据
|
Map<String, Object> result = Maps.newHashMap();
|
|
List<CaseFlowDTO> handleCaseFlowList = new LinkedList<>();
|
CaseFlowDTO lfdj = new CaseFlowDTO();
|
lfdj.setNodeShowName("来访登记");
|
lfdj.setHandleUnitName("白云区新市综治中心");
|
lfdj.setHandleUserName("李晓明");
|
lfdj.setTaskType(1);
|
lfdj.setStatus(2);
|
lfdj.setHandleTime(new Date());
|
handleCaseFlowList.add(lfdj);
|
|
CaseFlowDTO xtpd = new CaseFlowDTO();
|
xtpd.setNodeShowName("事件流转");
|
xtpd.setHandleUnitName("系统派单");
|
xtpd.setHandleTime(new Date());
|
xtpd.setHandleNotes("派单至：白云区新市司法所");
|
xtpd.setTaskType(1);
|
xtpd.setStatus(2);
|
handleCaseFlowList.add(xtpd);
|
|
CaseFlowDTO sjlz = new CaseFlowDTO();
|
sjlz.setNodeShowName("事件流转");
|
sjlz.setHandleUnitName("白云区新市司法所");
|
sjlz.setHandleUserName("赵菲菲");
|
sjlz.setHandleTime(new Date());
|
sjlz.setHandleNotes("已签收");
|
sjlz.setTaskType(1);
|
sjlz.setStatus(2);
|
handleCaseFlowList.add(sjlz);
|
|
CaseFlowDTO sjht = new CaseFlowDTO();
|
sjht.setNodeShowName("事件回退");
|
sjht.setHandleUnitName("白云区新市司法所");
|
sjht.setHandleUserName("赵菲菲");
|
sjht.setHandleTime(new Date());
|
sjht.setTaskType(2);
|
sjht.setStatus(2);
|
handleCaseFlowList.add(sjht);
|
|
CaseFlowDTO htsh = new CaseFlowDTO();
|
htsh.setNodeShowName("回退审核");
|
htsh.setHandleUnitName("白云区新市综治中心");
|
htsh.setHandleUserName("李晓明");
|
htsh.setHandleTime(new Date());
|
htsh.setAuditResult("24_00004-1");
|
htsh.setAuditResultName("通过");
|
htsh.setHandleTime(new Date());
|
htsh.setTaskType(1);
|
htsh.setStatus(2);
|
handleCaseFlowList.add(htsh);
|
|
CaseFlowDTO dsl = new CaseFlowDTO();
|
dsl.setProcessName("待受理");
|
dsl.setHandleUnitName("白云区新市综治中心");
|
dsl.setTaskType(1);
|
dsl.setStatus(1);
|
handleCaseFlowList.add(dsl);
|
result.put("handleCaseFlowList", handleCaseFlowList);
|
|
List<CaseFlowDTO> assistCaseFlowList = new LinkedList<>();
|
CaseFlowDTO xtpd2 = new CaseFlowDTO();
|
xtpd2.setNodeShowName("事件流转");
|
xtpd2.setHandleUnitName("联合处置申请");
|
xtpd2.setHandleTime(new Date());
|
xtpd2.setHandleNotes("联合处置申请：白云区永平司法所");
|
xtpd2.setTaskType(1);
|
xtpd2.setStatus(2);
|
assistCaseFlowList.add(xtpd2);
|
result.put("assistCaseFlowList", assistCaseFlowList);
|
return result;
|
}catch (Exception e){
|
log.error("[CaseTaskService.webGetTabButton]调用失败，异常信息："+e, e);
|
throw new ServiceException("CaseTaskService.webGetTabButton", e);
|
}
|
}
|
|
/**
|
* 按条件统计
|
* @param userId 用户编号
|
* @return long
|
*/
|
public Map<String, Long> getCountList(String userId){
|
CtUserDTO loginUser = custClient.clientGetUserAll(userId);
|
Map<String, Object> terms = new HashMap<>();
|
terms.put("candeUnitId", loginUser.getUnitId());
|
terms.put("candeDeptId", loginUser.getDeptId());
|
mapper.countTaskList(terms);
|
superviseService.countCaseSuperviseList(0,loginUser.getUnitId());
|
Map<String, Long> result = new HashMap<>();
|
return result;
|
}
|
|
/**
|
* wechat端-查询流程进度
|
* @param caseId 纠纷编号
|
* @return
|
*/
|
public List<CaseFlowDTO> wechatListCaseFlow(String caseId, String userId){
|
try{
|
// 临时给前端联调数据
|
List<CaseFlowDTO> list = new ArrayList<>();
|
QueryWrapper<CaseTask> queryWrapper = new QueryWrapper<>();
|
queryWrapper.eq("case_id", caseId);
|
queryWrapper.orderByAsc("create_time");
|
List<CaseTask> caseTasks = mapper.selectList(queryWrapper);
|
if(ObjectUtils.isNotEmpty(caseTasks)){
|
for (CaseTask caseTask : caseTasks) {
|
CaseFlowDTO caseFlowDTO = new CaseFlowDTO();
|
BeanUtils.copyProperties(caseTask, caseFlowDTO);
|
list.add(caseFlowDTO);
|
}
|
}
|
return list;
|
}catch (Exception e){
|
log.error("[CaseTaskService.wechatListCaseFlow]调用失败，异常信息："+e, e);
|
throw new ServiceException("CaseTaskService.wechatListCaseFlow", e);
|
}
|
}
|
}
|
