package com.moral.api.service.impl; import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; import com.baomidou.mybatisplus.extension.conditions.update.LambdaUpdateChainWrapper; import com.baomidou.mybatisplus.extension.plugins.pagination.Page; import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; import com.moral.api.config.Interceptor.UserHelper; import com.moral.api.controller.LogController; import com.moral.api.entity.*; import com.moral.api.exception.BusinessException; import com.moral.api.mapper.AllocationLogMapper; import com.moral.api.mapper.AllocationMapper; import com.moral.api.mapper.ResponsibilityUnitMapper; import com.moral.api.mapper.SysDictDataMapper; import com.moral.api.mapper.SysDictTypeMapper; import com.moral.api.mapper.UserLogMapper; import com.moral.api.mapper.UserMapper; import com.moral.api.pojo.bean.BaseInvalidEntity; import com.moral.api.pojo.dto.allocation.AllocationUnitViewDto; import com.moral.api.pojo.enums.*; import com.moral.api.pojo.ext.allocation.AllocationExcelExt; import com.moral.api.pojo.ext.allocation.AllocationExt; import com.moral.api.pojo.ext.allocation.AllocationListExt; import com.moral.api.pojo.ext.allocation.AllocationPageExt; import com.moral.api.pojo.query.allocation.*; import com.moral.api.pojo.query.allocationextension.AllocationExtensionAddCond; import com.moral.api.pojo.query.app.AppAllocationFileCond; import com.moral.api.pojo.query.app.AppAllocationPageCond; import com.moral.api.pojo.vo.allocation.AllocationFindVo; import com.moral.api.pojo.vo.app.AppAllocationFindVo; import com.moral.api.pojo.vo.app.AppAuthority; import com.moral.api.pojo.vo.user.QxUser; import com.moral.api.service.*; import com.moral.api.utils.BeanConverts; import com.moral.constant.Constants; import com.moral.constant.RedisConstants; import com.moral.util.DateUtils; import com.moral.util.WebUtils; import lombok.extern.slf4j.Slf4j; import org.apache.commons.collections4.CollectionUtils; import org.springframework.beans.BeanUtils; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.data.redis.core.RedisTemplate; import org.springframework.stereotype.Service; import org.springframework.transaction.annotation.Transactional; import org.springframework.util.ObjectUtils; import org.springframework.web.context.request.RequestContextHolder; import org.springframework.web.context.request.ServletRequestAttributes; import java.util.*; import java.util.stream.Collectors; import javax.servlet.http.HttpServletRequest; @Service @Slf4j public class AllocationServiceImpl extends ServiceImpl implements AllocationService { private final Integer NEW_BUILT = 10; @Autowired private SysDictTypeMapper sysDictTypeMapper; @Autowired private ResponsibilityUnitMapper responsibilityUnitMapper; @Autowired private SysDictDataMapper sysDictDataMapper; @Autowired private RedisTemplate redisTemplate; @Autowired private AllocationMapper allocationMapper; @Autowired private SysAreaService sysAreaService; @Autowired private ApproveTableService approveTableService; @Autowired private FileTableService fileTableService; @Autowired private AllocationExtensionService allocationExtensionService; @Autowired private ResponsibilityUnitService responsibilityUnitService; @Autowired private SysDictTypeService sysDictTypeService; @Autowired private UserService userService; @Autowired private AllocationLogMapper allocationLogMapper; /** * 根据字典类型获取字典数据 * @param dictType * @return */ @Override public List> sysDictData(String dictType) { QueryWrapper typeQueryWrapper = new QueryWrapper<>(); typeQueryWrapper.select("id").eq("name", dictType); SysDictType sysDictType = sysDictTypeMapper.selectOne(typeQueryWrapper); QueryWrapper dataQueryWrapper = new QueryWrapper<>(); dataQueryWrapper.select("dataKey", "dataValue").eq("dict_type_id", sysDictType.getId()).eq("is_delete", Constants.NOT_DELETE); return sysDictDataMapper.selectMaps(dataQueryWrapper); } /** * 查询责任主体 * @return */ @Override public List seleteUnit() { QueryWrapper wrapper = new QueryWrapper<>(); wrapper.select("unit_name","unit_id"); wrapper.eq("is_del",Constants.NOT_DELETE); wrapper.eq("state",0); wrapper.eq("is_invalid",0); //获取用户信息 List unitList = unitResult(); if (CollectionUtils.isNotEmpty(unitList)){ wrapper.in("unit_id",unitList); } List responsibilityUnits = responsibilityUnitMapper.selectList(wrapper); return responsibilityUnits; } /** * 添加交办单 * @param allocationCond * @return */ @Override @Transactional public Integer insertAllocation(AllocationAddCond allocationCond) { Allocation allocation = allocationCond.convert(); allocation.setEscalationType(AllocationEscalationTypeEnum.SELF.getValue()); String dateString = DateUtils.dateToDateString(new Date(), DateUtils.yyyyMMdd_EN); Object o = redisTemplate.opsForValue().get(RedisConstants.JBD_DATA); int i = ObjectUtils.isEmpty(o)?1:Integer.parseInt(o.toString()) + 1; //单号 String allocationNum = "JBD-" + dateString + String.format("%04d", i); allocation.setAllocationNum(allocationNum); if(Objects.nonNull(allocationCond.getEscalationUnitId())&& !allocationCond.getEscalationUnitId().equals(allocationCond.getUnitId()) && escalationType(allocationCond.getEscalationUnitId())) { allocation.setEscalationType(AllocationEscalationTypeEnum.CHECK.getValue()); } if(NEW_BUILT.equals(allocationCond.getState())) { allocation.setState(AllocationApproveEnum.UNDER_RECTIFICATION.value); } //获取新建图片 allocationMapper.insert(allocation); //推送数据 userService.pushOneUser(allocation); redisTemplate.opsForValue().set(RedisConstants.JBD_DATA,i); if(NEW_BUILT.equals(allocationCond.getState())||AllocationApproveEnum.UNDER_RECTIFICATION.value.equals(allocationCond.getState())) { //添加流程数据 ApproveTable approveTable = new ApproveTable(); approveTable.setRelationId(allocation.getAllocationId()); approveTable.setState(NEW_BUILT); approveTable.setApproveModule(FileTableEnum.ALLOCATION_FOUNDATION.value); approveTable.setStateName("新建"); approveTableService.saveResult(approveTable); } fileTableService.upDateResult(allocationCond.getFileBaseList(),allocation.getAllocationId(), FileTableEnum.ALLOCATION_FOUNDATION.value); return allocation.getAllocationId(); } /** * 修改交办单 * @param allocationUpdateCond */ @Override @Transactional public void updateAll(AllocationUpdateCond allocationUpdateCond) { AllocationExt allocationExt = oneAllocation(allocationUpdateCond.getAllocationId()); if(!AllocationApproveEnum.DRAFT.value.equals(allocationExt.getState())) { throw new BusinessException("新建未提交状态，才能编辑！"); } //获取用户信息 Allocation allocation = allocationUpdateCond.convert(); if(Objects.nonNull(allocationUpdateCond.getEscalationUnitId())&& escalationType(allocationUpdateCond.getEscalationUnitId())) { allocation.setEscalationType(AllocationEscalationTypeEnum.CHECK.getValue()); } if(NEW_BUILT.equals(allocationUpdateCond.getState())) { //添加流程数据 ApproveTable approveTable = new ApproveTable(); approveTable.setRelationId(allocation.getAllocationId()); approveTable.setState(NEW_BUILT); approveTable.setApproveModule(FileTableEnum.ALLOCATION_FOUNDATION.value); approveTable.setStateName("新建"); approveTableService.saveResult(approveTable); } if(NEW_BUILT.equals(allocationUpdateCond.getState())) { allocation.setState(AllocationApproveEnum.UNDER_RECTIFICATION.value); } fileTableService.upDateResult(allocationUpdateCond.getFileBaseList(),allocation.getAllocationId(), FileTableEnum.ALLOCATION_FOUNDATION.value); allocationMapper.updateById(allocation); } /** * 表单总览 * @param map * @return */ @Override public Map selectUnitView(Map map) { QueryWrapper wrapper = new QueryWrapper<>(); //获取用户信息 List list = this.unitResult(); if (!ObjectUtils.isEmpty(map.get("unitId"))){ wrapper.in("unit_id",map.get("unitId").toString()); }else { if (!ObjectUtils.isEmpty(list)){ Integer integer = list.get(0); if (integer==0){ return null; }else { wrapper.in("unit_id",list); } } } HashMap rsMap = new HashMap<>(); ArrayList> polluteArrayList = new ArrayList<>(); ArrayList> escalationTypeList = new ArrayList<>(); ArrayList allocationUnitViewDtos = new ArrayList<>(); String number1 = map.get("number").toString(); String startTime=null; String endTime=null; if (!ObjectUtils.isEmpty(map.get("startTime")) || !ObjectUtils.isEmpty(map.get("endTime"))){ startTime = map.get("startTime").toString(); // endTime = map.get("endTime").toString(); endTime = DateUtils.getDateOfDay(map.get("endTime").toString(), 1, DateUtils.yyyy_MM_dd_EN); } if (!number1.equals("0")){ String s = "-"+number1; //获取当前时间 endTime = DateUtils.getCurDateTime(); startTime = DateUtils.getDateStringOfMon(Integer.parseInt(s), DateUtils.yyyy_MM_dd_HH_mm_ss_EN); } wrapper.between("escalation_time",startTime,endTime); wrapper.eq("is_del",0); wrapper.eq("is_invalid",0); List allocations = allocationMapper.selectList(wrapper); if (ObjectUtils.isEmpty(allocations)){ return null; } int complete=0; int unComplete=0; for (Allocation allocation : allocations) { String state = allocation.getState()+""; if (state.equals("40")||state.equals("50")){ complete++; }else { unComplete++; } } //根据上报类型分类 Map> escalationTypeMap = allocations.stream().collect(Collectors.groupingBy(o -> o.getEscalationType())); Set escalationTypes = escalationTypeMap.keySet(); for (Integer escalationType : escalationTypes) { List allocations1 = escalationTypeMap.get(escalationType); String value = AllocationEscalationTypeEnum.SELF.value.toString(); HashMap typeMap = new HashMap<>(); if (value.equals(escalationType+"")){ typeMap.put("name",AllocationEscalationTypeEnum.SELF.name); }else { typeMap.put("name",AllocationEscalationTypeEnum.CHECK.name); } typeMap.put("value",allocations1.size()); escalationTypeList.add(typeMap); } //根据污染类型分类 SysDictType sysDictType = sysDictTypeService.slectFind(Constants.WU_RAN_LEI_XING); Map> polluteTypeMap = allocations.stream().collect(Collectors.groupingBy(o -> o.getPolluteType())); Set polluteTypes = polluteTypeMap.keySet(); for (Integer polluteType : polluteTypes) { HashMap typeMap = new HashMap<>(); List allocations1 = polluteTypeMap.get(polluteType); QueryWrapper sysDictDataQueryWrapper = new QueryWrapper<>(); sysDictDataQueryWrapper.eq("dict_type_id",sysDictType.getId()); sysDictDataQueryWrapper.eq("dataKey",polluteType); SysDictData sysDictData = sysDictDataMapper.selectOne(sysDictDataQueryWrapper); typeMap.put("name",sysDictData.getDataValue()); typeMap.put("value",allocations1.size()); polluteArrayList.add(typeMap); } //根据责任单位分类 Map> unitMap = allocations.stream().collect(Collectors.groupingBy(o -> o.getUnitId())); Set unitList = unitMap.keySet(); //逾期次数 int overdue=0; for (Integer integer : unitList) { //获取城市 ResponsibilityUnit responsibilityUnit = responsibilityUnitMapper.selectById(integer); SysArea areaByCode = sysAreaService.getAreaByCode(responsibilityUnit.getAreaCode()); AllocationUnitViewDto allocationUnitViewDto = new AllocationUnitViewDto(); List allocations1 = unitMap.get(integer); //加分 int marks=0; //减分 int deduction=0; int number=0; for (Allocation allocation : allocations1) { String state = allocation.getState()+""; Integer changeType = allocation.getChangeType(); String value = ChangeEnum.DEADLINE.value.toString(); if (value.equals(changeType+"")){ Date dateOfDay = DateUtils.getDateOfDay(allocation.getEscalationTime(), allocation.getChangeDay()); Date date = new Date(); boolean timeBefor = DateUtils.isTimeBefor(date, dateOfDay); if (timeBefor && !state.equals("40") && !state.equals("50") && !state.equals("9")){ //逾期次数 overdue++; } } if (state.equals("40")||state.equals("50")){ if (allocation.getCheckScore()>0){ marks = marks + allocation.getCheckScore(); }else { deduction = deduction + allocation.getCheckScore(); } number++; } } int total = allocations1.size(); allocationUnitViewDto.setDeduction(deduction); allocationUnitViewDto.setMarks(marks); allocationUnitViewDto.setTotal(total); allocationUnitViewDto.setTotalPoints(marks+deduction); allocationUnitViewDto.setNumber(number); String rate = (number * 100 /total)+"%"; allocationUnitViewDto.setRate(rate); allocationUnitViewDto.setUnNumber(total-number); allocationUnitViewDto.setUnitName(areaByCode.getAreaName()); allocationUnitViewDtos.add(allocationUnitViewDto); } rsMap.put("unitView",allocationUnitViewDtos); //总数 rsMap.put("total",allocations.size()); //已完成 rsMap.put("complete",complete); //进行中 rsMap.put("unComplete",unComplete); //预期 rsMap.put("overdue",overdue); //污染类型 rsMap.put("polluteType",polluteArrayList); //上报类型 rsMap.put("escalationType",escalationTypeList); return rsMap; } /** * 导出 * @param map * @return */ @Override public List> unitExel(Map map) { QueryWrapper wrapper = new QueryWrapper<>(); //获取用户信息 List list = this.unitResult(); if (!ObjectUtils.isEmpty(map.get("unitId"))){ wrapper.in("unit_id",map.get("unitId").toString()); }else { if (!ObjectUtils.isEmpty(list)){ Integer integer = list.get(0); if (integer==0){ return null; }else { wrapper.in("unit_id",list); } } } ArrayList> rsMap = new ArrayList<>(); Object number1 = map.get("number"); String startTime=null; String endTime=null; if (!ObjectUtils.isEmpty(map.get("startTime")) || !ObjectUtils.isEmpty(map.get("endTime"))){ startTime = map.get("startTime").toString(); endTime = map.get("endTime").toString(); } if (!ObjectUtils.isEmpty(number1)){ String s = "-"+number1; //获取当前时间 endTime = DateUtils.getCurDateTime(); startTime = DateUtils.getDateStringOfMon(Integer.parseInt(s), DateUtils.yyyy_MM_dd_HH_mm_ss_EN); } wrapper.between("escalation_time",startTime,endTime); wrapper.eq("is_del",0); wrapper.eq("is_invalid",0); List allocations = allocationMapper.selectList(wrapper); if (ObjectUtils.isEmpty(allocations)){ return null; } //根据责任单位分类 Map> unitMap = allocations.stream().collect(Collectors.groupingBy(o -> o.getUnitId())); Set unitList = unitMap.keySet(); for (Integer integer : unitList) { // HashMap map1 = new HashMap<>(); LinkedHashMap map1 = new LinkedHashMap<>(); //获取城市 ResponsibilityUnit responsibilityUnit = responsibilityUnitMapper.selectById(integer); SysArea areaByCode = sysAreaService.getAreaByCode(responsibilityUnit.getAreaCode()); List allocations1 = unitMap.get(integer); //加分 int marks=0; //减分 int deduction=0; int number=0; for (Allocation allocation : allocations1) { String state = allocation.getState()+""; if (state.equals("40")||state.equals("50")){ if (allocation.getCheckScore()>0){ marks = marks + allocation.getCheckScore(); }else { deduction = deduction + allocation.getCheckScore(); } number++; } } int total = allocations1.size(); String rate = (number * 100 /total)+"%"; map1.put("责任单位",areaByCode.getAreaName()); map1.put("总工单",total); map1.put("完成数",number); map1.put("未完成数",total-number); map1.put("完成率",rate); map1.put("扣分",deduction); map1.put("加分",marks); map1.put("总得分",marks+deduction); rsMap.add(map1); } return rsMap; } @Override public Page extPage(AllocationPageCond allocationPageCond) { List unitAuthority = this.getUnitAuthority(SysDictTypeEnum.SYS_AMEND.value); List unitList = unitResult(); Integer codeId = unitAreaCode(); allocationPageCond.setUnitList(unitList); Page page = this.baseMapper.extPage(allocationPageCond.getPage().convertPage(), allocationPageCond); if(CollectionUtils.isNotEmpty(page.getRecords())){ page.getRecords().forEach(it->{ if((CollectionUtils.isEmpty(unitList)&&codeId.equals(1))||codeId.equals(2)){ it.setIsApprove(1); }else { it.setIsApprove(0); } it.setIsCode(ObjectUtils.isEmpty(unitAuthority)?"2":"1"); }); } return page; } @Override public AllocationExt extOne(Integer id) { AllocationExt allocationExt = oneAllocation(id); allocationExt.setFileBaseList(fileTableService.list(id,FileTableEnum.ALLOCATION_FOUNDATION.value)); allocationExt.setFileChangeList(fileTableService.list(id,FileTableEnum.ALLOCATION_RECTIFICATION.value)); allocationExt.setFileApproveList(fileTableService.list(id,FileTableEnum.ALLOCATION_APPROVE.value)); allocationExt.setApproveList(approveTableService.listAll(id, FileTableEnum.ALLOCATION_FOUNDATION.value)); allocationExt.setUnitName(getUnitName(allocationExt.getUnitId()).getUnitName()); allocationExt.setEscalationUnitName(getUnitName(allocationExt.getEscalationUnitId()).getUnitName()); allocationExt.setPolluteTypeName(responsibilityUnitMapper.selectName(Constants.WU_RAN_LEI_XING,allocationExt.getPolluteType())); return allocationExt; } @Override public AllocationExt oneAllocation(Integer id){ return this.baseMapper.extOne(id); } @Override @Transactional public void changeAllocation(AllocationChangeCond changeCond) { AllocationExt allocationExt = oneAllocation(changeCond.getAllocationId()); if(!AllocationApproveEnum.UNDER_RECTIFICATION.value.equals(allocationExt.getState())) { throw new BusinessException("整改状态，才能提交审批！"); } Allocation allocation = new Allocation(); allocation.setAllocationId(changeCond.getAllocationId()); allocation.setIsChange(changeCond.getIsChange()); allocation.setChangeName(changeCond.getChangeName()); allocation.setChangeDescribe(changeCond.getChangeDescribe()); allocation.setState(changeCond.getState()); allocation.setChangeTime(new Date()); this.updateById(allocation); //推送数据 Allocation allocation1 = this.getById(changeCond.getAllocationId()); userService.pushOneUser(allocation1); //添加流程数据 ApproveTable approveTable = new ApproveTable(); approveTable.setRelationId(allocation.getAllocationId()); approveTable.setState(AllocationApproveEnum.UNDER_RECTIFICATION.value); approveTable.setStateName(AllocationApproveEnum.UNDER_RECTIFICATION.name); approveTable.setApproveModule(FileTableEnum.ALLOCATION_FOUNDATION.value); approveTableService.saveResult(approveTable); fileTableService.upDateResult(changeCond.getFileChangeList(),allocation.getAllocationId(), FileTableEnum.ALLOCATION_RECTIFICATION.value); } @Override @Transactional public void checkAllocation(AllocationCheckCond checkCond) { AllocationExt allocationExt = oneAllocation(checkCond.getAllocationId()); if(!AllocationApproveEnum.IN_APPROVAL.value.equals(allocationExt.getState())) { throw new BusinessException("审批状态，才能进行审批操作！"); } QxUser qxUser = UserHelper.getCurrentUser(); Allocation allocation = new Allocation(); allocation.setCheckScore(checkCond.getCheckScore()); allocation.setAllocationId(checkCond.getAllocationId()); allocation.setCheckDescribe(checkCond.getCheckDescribe()); allocation.setCheckName(qxUser.getUserName()); allocation.setCheckTime(new Date()); allocation.setState(checkCond.getState()); this.updateById(allocation); //添加流程数据 ApproveTable approveTable = new ApproveTable(); approveTable.setRelationId(allocation.getAllocationId()); if(AllocationApproveEnum.PASS.value.equals(checkCond.getState())){ approveTable.setState(AllocationApproveEnum.PASS.value); approveTable.setStateName(AllocationApproveEnum.PASS.name); }else { approveTable.setState(AllocationApproveEnum.REFUSE.value); approveTable.setStateName(AllocationApproveEnum.REFUSE.name); } approveTable.setApproveModule(FileTableEnum.ALLOCATION_FOUNDATION.value); approveTableService.saveResult(approveTable); fileTableService.upDateResult(checkCond.getFileApproveList(),checkCond.getAllocationId(), FileTableEnum.ALLOCATION_APPROVE.value); } @Override @Transactional public boolean removeById(Integer id) { AllocationExt allocationExt = oneAllocation(id); if(!AllocationApproveEnum.DRAFT.value.equals(allocationExt.getState())) { throw new BusinessException("新建草稿状态，才能删除！"); } this.baseMapper.deleteById(id); return true; } @Override @Transactional public boolean invalidResult(Integer id,String invalidReason) { AllocationExt allocationExt = oneAllocation(id); if( AllocationApproveEnum.IN_APPROVAL.value >= allocationExt.getState() ) { throw new BusinessException("审批结束才能作废！"); } LambdaUpdateChainWrapper wrapper =lambdaUpdate(); wrapper.eq(Allocation::getAllocationId,id).set(Allocation::getInvalidReason,invalidReason).set(BaseInvalidEntity::getIsInvalid, YesOrNo.YES.value); return wrapper.update(); } @Override public List extList(AllocationListCond allocationListCond) { return null; } @Override @Transactional public boolean applyFor(AllocationExtensionAddCond allocationExtensionAddCond) { AllocationExt allocationExt = oneAllocation(allocationExtensionAddCond.getAllocationId()); boolean type = false; if( !AllocationApproveEnum.UNDER_RECTIFICATION.value.equals(allocationExt.getState())) { type = true; } if(!ChangeEnum.DEADLINE.value.equals(allocationExt.getChangeType())){ type = true; } if(type){ throw new BusinessException("只有限期整改类型，状态为整改中，才能发起延期申请！"); } AllocationExtension allocationExtension = allocationExtensionAddCond.convert(); allocationExtension.setState(AllocationExtensionApproveEnum.APPLYING.value); allocationExtension.setExtensionOldNum(allocationExt.getChangeDay()); allocationExtensionService.save(allocationExtension); fileTableService.upDateResult(allocationExtensionAddCond.getFileList(),allocationExtension.getId(), FileTableEnum.ALLOCATION_EXTENSION.value); return true; } @Override public List selectSmallRoutine(Integer state,String startTime,String endTime) { ArrayList allocationFindVos = new ArrayList<>(); LambdaQueryWrapper wrapper = new LambdaQueryWrapper<>(); //获取用户信息 List list = unitResult(); if (!ObjectUtils.isEmpty(list)){ wrapper.in(Allocation::getUnitId,list); } Integer integer = unitAreaCode(); // 管理员 if (integer==1){ if (state==3){ wrapper.in(Allocation::getState,AllocationApproveEnum.PASS.value,AllocationApproveEnum.REFUSE.value); }else if (state==1){ wrapper.in(Allocation::getState,AllocationApproveEnum.UNDER_RECTIFICATION.value,AllocationApproveEnum.DRAFT.value,AllocationApproveEnum.IN_APPROVAL.value); }else { wrapper.eq(Allocation::getState,0); } }else if(integer == 0) { if (state==3){ wrapper.in(Allocation::getState,AllocationApproveEnum.PASS.value,AllocationApproveEnum.REFUSE.value); }else if (state==2){ wrapper.eq(Allocation::getState,AllocationApproveEnum.IN_APPROVAL.value); }else if (state==1){ wrapper.in(Allocation::getState,AllocationApproveEnum.UNDER_RECTIFICATION.value,AllocationApproveEnum.DRAFT.value); } }else if(integer == 2){ if (state==3){ wrapper.in(Allocation::getState,AllocationApproveEnum.PASS.value,AllocationApproveEnum.REFUSE.value); }else if (state==2){ wrapper.in(Allocation::getState,AllocationApproveEnum.UNDER_RECTIFICATION.value,AllocationApproveEnum.DRAFT.value); }else if (state==1){ wrapper.eq(Allocation::getState,AllocationApproveEnum.IN_APPROVAL.value); } } if (!ObjectUtils.isEmpty(startTime) && !ObjectUtils.isEmpty(endTime)){ wrapper.between(Allocation::getEscalationTime,startTime,endTime); } wrapper.eq(Allocation::getIsDel,0).eq(Allocation::getIsInvalid,0); wrapper.orderByDesc(Allocation::getEscalationTime,Allocation::getAllocationId); List allocations = allocationMapper.selectList(wrapper); for (Allocation allocation : allocations) { AllocationFindVo allocationFindVo = new AllocationFindVo(); BeanUtils.copyProperties(allocation,allocationFindVo); Integer state1 = allocationFindVo.getState(); if ( integer==2){ if (state1.equals(AllocationApproveEnum.DRAFT.value)||state1.equals(AllocationApproveEnum.UNDER_RECTIFICATION.value)){ allocationFindVo.setStateName(AppAllocationStateEnum.TO_BE_COMPLETED.name); }else if (state1.equals(AllocationApproveEnum.IN_APPROVAL.value)){ allocationFindVo.setStateName(AppAllocationStateEnum.TO_BE_PROCESSED.name); }else if (state1.equals(AllocationApproveEnum.PASS.value)||state1.equals(AllocationApproveEnum.REFUSE.value)){ allocationFindVo.setStateName(AppAllocationStateEnum.COMPLETED.name); } }else if(integer==1){ if (state1.equals(AllocationApproveEnum.DRAFT.value)||state1.equals(AllocationApproveEnum.UNDER_RECTIFICATION.value)||state1.equals(AllocationApproveEnum.IN_APPROVAL.value)){ allocationFindVo.setStateName(AppAllocationStateEnum.TO_BE_PROCESSED.name); }else if (state1.equals(AllocationApproveEnum.PASS.value)||state1.equals(AllocationApproveEnum.REFUSE.value)){ allocationFindVo.setStateName(AppAllocationStateEnum.COMPLETED.name); } }else if(integer==0) { if (state1.equals(AllocationApproveEnum.DRAFT.value)||state1.equals(AllocationApproveEnum.UNDER_RECTIFICATION.value)){ allocationFindVo.setStateName(AppAllocationStateEnum.TO_BE_PROCESSED.name); }else if (state1.equals(AllocationApproveEnum.IN_APPROVAL.value)){ allocationFindVo.setStateName(AppAllocationStateEnum.TO_BE_COMPLETED.name); }else if (state1.equals(AllocationApproveEnum.PASS.value)||state1.equals(AllocationApproveEnum.REFUSE.value)){ allocationFindVo.setStateName(AppAllocationStateEnum.COMPLETED.name); } } allocationFindVos.add(allocationFindVo); } return allocationFindVos; } @Override public Page pageApp(AppAllocationPageCond allocationPageCond) { List listUnit = unitResult(); Integer integer = unitAreaCode(); allocationPageCond.setUnitList(listUnit); allocationPageCond.setStateList(stateAllocationList(allocationPageCond.getState(),integer)); Page extAppPage = this.baseMapper.extAppPage(allocationPageCond.getPage().convertPage(),allocationPageCond); extAppPage.getRecords().forEach(it->{ Integer state = it.getState(); //获取上报单位名字 it.setEscalationUnitName(getUnitName(it.getEscalationUnitId()).getUnitName()); if (state.equals(AllocationApproveEnum.DRAFT.value)||state.equals(AllocationApproveEnum.UNDER_RECTIFICATION.value)){ if(integer==0||integer==1){ it.setStateName(AppAllocationStateEnum.TO_BE_PROCESSED.name); }else if(integer==2){ it.setStateName(AppAllocationStateEnum.TO_BE_COMPLETED.name); } }else if(state.equals(AllocationApproveEnum.IN_APPROVAL.value)){ if(integer==2||integer==1){ it.setStateName(AppAllocationStateEnum.TO_BE_PROCESSED.name); }else if(integer==0){ it.setStateName(AppAllocationStateEnum.TO_BE_COMPLETED.name); } }else{ it.setStateName(AppAllocationStateEnum.COMPLETED.name); } }); return extAppPage; } @Override @Transactional public boolean saveFile(AppAllocationFileCond appAllocationFileCond) { fileTableService.upDateResult(Arrays.asList(appAllocationFileCond.getFile()),appAllocationFileCond.getUserId(), FileTableEnum.APP_ALLOCATION.value); return true; } private List stateAllocationList(Integer type, Integer integer){ List integerList = new ArrayList<>(); // type 0 全部 1待办 2待处理 3 已完成 if(integer.equals(0)){ if(type.equals(1)){ integerList.add(AllocationApproveEnum.UNDER_RECTIFICATION.value); integerList.add(AllocationApproveEnum.DRAFT.value); }else if(type.equals(2)){ integerList.add(AllocationApproveEnum.IN_APPROVAL.value); } }else if(integer.equals(2)){ if(type.equals(1)){ integerList.add(AllocationApproveEnum.IN_APPROVAL.value); }else if(type.equals(2)){ integerList.add(AllocationApproveEnum.UNDER_RECTIFICATION.value); integerList.add(AllocationApproveEnum.DRAFT.value); } }else if(integer.equals(1)){ if(type.equals(1)){ integerList.add(AllocationApproveEnum.IN_APPROVAL.value); integerList.add(AllocationApproveEnum.UNDER_RECTIFICATION.value); integerList.add(AllocationApproveEnum.DRAFT.value); }else if(type.equals(2)){ integerList.add(0); } } if(type.equals(3)){ integerList.add(AllocationApproveEnum.PASS.value); integerList.add(AllocationApproveEnum.REFUSE.value); } return integerList; } /** * 小程序整改 * * @param changeCond */ @Override @Transactional public void changeSmallRoutine(AllocationChangeCond changeCond) { Integer integer = unitAreaCode(); if (integer==2){ throw new BusinessException("此账户只能审核，不能整改！"); } AllocationExt allocationExt = oneAllocation(changeCond.getAllocationId()); if(!AllocationApproveEnum.UNDER_RECTIFICATION.value.equals(allocationExt.getState())) { throw new BusinessException("整改状态，才能提交审批！"); } Allocation allocation = new Allocation(); allocation.setAllocationId(changeCond.getAllocationId()); allocation.setIsChange(changeCond.getIsChange()); allocation.setChangeName(changeCond.getChangeName()); allocation.setChangeDescribe(changeCond.getChangeDescribe()); allocation.setState(changeCond.getState()); allocation.setChangeTime(new Date()); this.updateById(allocation); //添加流程数据 ApproveTable approveTable = new ApproveTable(); approveTable.setRelationId(allocation.getAllocationId()); approveTable.setApproveModule(FileTableEnum.ALLOCATION_FOUNDATION.value); /* approveTable.setState(NEW_BUILT); approveTable.setStateName("新建"); approveTableService.saveResult(approveTable);*/ approveTable.setState(AllocationApproveEnum.UNDER_RECTIFICATION.value); approveTable.setStateName(AllocationApproveEnum.UNDER_RECTIFICATION.name); approveTableService.saveResult(approveTable); fileTableService.upDateResult(changeCond.getFileChangeList(),allocation.getAllocationId(), FileTableEnum.ALLOCATION_RECTIFICATION.value); } /** * 小程序审批 * * @param checkCond */ @Override @Transactional public void checkSmallRoutine(AllocationCheckCond checkCond) { Integer integer = unitAreaCode(); if (integer==0){ throw new BusinessException("此账户只能整改，不能审批！"); } AllocationExt allocationExt = oneAllocation(checkCond.getAllocationId()); if(!AllocationApproveEnum.IN_APPROVAL.value.equals(allocationExt.getState())) { throw new BusinessException("审批状态，才能进行审批操作！"); } QxUser qxUser = UserHelper.getCurrentUser(); Allocation allocation = new Allocation(); allocation.setCheckScore(checkCond.getCheckScore()); allocation.setAllocationId(checkCond.getAllocationId()); allocation.setCheckDescribe(checkCond.getCheckDescribe()); allocation.setCheckName(qxUser.getUserName()); allocation.setCheckTime(new Date()); allocation.setState(checkCond.getState()); this.updateById(allocation); //添加流程数据 ApproveTable approveTable = new ApproveTable(); approveTable.setRelationId(allocation.getAllocationId()); if(AllocationApproveEnum.PASS.value.equals(checkCond.getState())){ approveTable.setState(AllocationApproveEnum.PASS.value); approveTable.setStateName(AllocationApproveEnum.PASS.name); }else { approveTable.setState(AllocationApproveEnum.REFUSE.value); approveTable.setStateName(AllocationApproveEnum.REFUSE.name); } approveTable.setApproveModule(FileTableEnum.ALLOCATION_FOUNDATION.value); approveTableService.saveResult(approveTable); fileTableService.upDateResult(checkCond.getFileApproveList(),checkCond.getAllocationId(), FileTableEnum.ALLOCATION_APPROVE.value); } @Override public AppAuthority authority(String allocationNum,Integer userId) { //返回数据 AppAuthority appAuthority = new AppAuthority(); //获取用户信息 QxUser user = UserHelper.getCurrentUser(); //获取交办单信息 LambdaQueryWrapper wrapper = new LambdaQueryWrapper<>(); wrapper.eq(Allocation::getAllocationNum,allocationNum); wrapper.eq(Allocation::getIsDel,0); wrapper.eq(Allocation::getIsInvalid,0); Allocation allocation = allocationMapper.selectOne(wrapper); List userList = responsibilityUnitMapper.selectCodeList(SysDictTypeEnum.SYS_JBD.getValue(),user.getUserId()); if(CollectionUtils.isNotEmpty(userList)){ //可以看，可以填 if (allocation.getState()>30){ appAuthority.setCode(2); appAuthority.setName(AppAllocationStateEnum.COMPLETED.name); }else { appAuthority.setCode(1); appAuthority.setName(AppAllocationStateEnum.COMPLETED.name); } return appAuthority; } if(Objects.nonNull(user.getUnitId())&&user.getUnitId()!=0){ String code = responsibilityUnitMapper.selectAreaCode(user.getUnitId()); if (code.length() > 6 && allocation.getUnitId().equals(user.getUnitId())) { if (allocation.getState().equals(AllocationApproveEnum.UNDER_RECTIFICATION.value)){ appAuthority.setCode(1); appAuthority.setName(AppAllocationStateEnum.TO_BE_PROCESSED.name); return appAuthority; }else if (allocation.getState().equals(AllocationApproveEnum.IN_APPROVAL.value)){ appAuthority.setCode(2); appAuthority.setName(AppAllocationStateEnum.TO_BE_COMPLETED.name); return appAuthority; }else { appAuthority.setCode(2); appAuthority.setName(AppAllocationStateEnum.COMPLETED.name); return appAuthority; } } else if (code.length() <= 6){ if (allocation.getState().equals(AllocationApproveEnum.IN_APPROVAL.value)){ appAuthority.setCode(1); appAuthority.setName(AppAllocationStateEnum.TO_BE_PROCESSED.name); return appAuthority; }else if (allocation.getState().equals(AllocationApproveEnum.UNDER_RECTIFICATION.value)){ appAuthority.setCode(2); appAuthority.setName(AppAllocationStateEnum.TO_BE_COMPLETED.name); return appAuthority; }else { appAuthority.setCode(2); appAuthority.setName(AppAllocationStateEnum.COMPLETED.name); return appAuthority; } } } //不能看，不能填 appAuthority.setCode(3); appAuthority.setName("没有权限"); return appAuthority; } /** * 修改责任单位 * * @param id * @param unitId */ @Override @Transactional public void updataUnit(Integer id, Integer unitId,Integer polluteType) { AllocationLog allocationLog = new AllocationLog(); //获取用户信息 QxUser user = UserHelper.getCurrentUser(); Allocation allocation = allocationMapper.selectById(id); if (!ObjectUtils.isEmpty(unitId)){ ResponsibilityUnit unitName1 = getUnitName(allocation.getUnitId()); ResponsibilityUnit unitName2 = getUnitName(unitId); allocation.setUnitId(unitId); allocationLog.setContent(unitName1.getUnitName()+"----修改成----"+unitName2.getUnitName()); } if (!ObjectUtils.isEmpty(polluteType)){ SysDictData sysDictData1 = sysDictTypeService.listOne(Constants.WU_RAN_LEI_XING,allocation.getPolluteType().toString()); SysDictData sysDictData2 = sysDictTypeService.listOne(Constants.WU_RAN_LEI_XING, polluteType.toString()); allocation.setPolluteType(polluteType); allocationLog.setPolluteType(sysDictData1.getDataValue()+"----修改成----"+sysDictData2.getDataValue()); } allocationMapper.updateById(allocation); //日志 HttpServletRequest request = ((ServletRequestAttributes) Objects.requireNonNull(RequestContextHolder.getRequestAttributes())).getRequest(); allocationLog.setAllocationNum(allocation.getAllocationNum()); allocationLog.setIp(WebUtils.getIpAddr(request)); allocationLog.setAccountId(user.getUserId()); allocationLog.setAccount(user.getAccount()); allocationLog.setUserName(user.getUserName()); allocationLog.setCreateTime(new Date()); allocationLogMapper.insert(allocationLog); } /** * 查看修改记录 * * @param allocationNum * @return */ @Override public List getLog(String allocationNum) { LambdaQueryWrapper wrapper = new LambdaQueryWrapper<>(); wrapper.eq(AllocationLog::getAllocationNum,allocationNum); wrapper.orderByAsc(AllocationLog::getCreateTime); List allocationLogs = allocationLogMapper.selectList(wrapper); return allocationLogs; } /** * 根据字典名称获取权限 * * @param code * @return */ @Override public List getUnitAuthority(String code) { QxUser user = UserHelper.getCurrentUser(); List userList = responsibilityUnitMapper.selectCodeList(code,user.getUserId()); return userList; } @Override public List unitResult() { QxUser user = UserHelper.getCurrentUser(); Integer unitId = Objects.nonNull(user.getUnitId())?user.getUnitId():0; List userList = responsibilityUnitMapper.selectCodeList(SysDictTypeEnum.SYS_JBD.getValue(),user.getUserId()); if(CollectionUtils.isNotEmpty(userList)){ return new ArrayList<>(); } userList = responsibilityUnitMapper.selectResultList(unitId); if(CollectionUtils.isNotEmpty(userList)){ return userList; } return Arrays.asList(0); } @Override public Integer unitAreaCode() { QxUser user = UserHelper.getCurrentUser(); List userList = responsibilityUnitMapper.selectCodeList(SysDictTypeEnum.SYS_JBD.getValue(),user.getUserId()); if(CollectionUtils.isNotEmpty(userList)){ return 1; } if(Objects.nonNull(user.getUnitId())&&user.getUnitId()!=0) { String code = responsibilityUnitMapper.selectAreaCode(user.getUnitId()); if (code.length() > 6) { return 0; } else { return 2; } } return 0; } private boolean escalationType(Integer id){ boolean f = false; String code = responsibilityUnitMapper.selectAreaCode(id); if(code.length() == 6){ return true; } return f; } private ResponsibilityUnit getUnitName(Integer unitId){ ResponsibilityUnit responsibilityUnit = responsibilityUnitMapper.selectById(unitId); return responsibilityUnit; } @Override public List listExcel(List id) { List list = new ArrayList<>(); for(Integer i : id){ AllocationExt allocationExt = oneAllocation(i); AllocationExcelExt allocationExcelExt = BeanConverts.convert(allocationExt,AllocationExcelExt.class); allocationExcelExt.setFileBaseList(fileTableService.list(i,FileTableEnum.ALLOCATION_FOUNDATION.value,FileType.PICTURE.getValue())); allocationExcelExt.setFileChangeList(fileTableService.list(i,FileTableEnum.ALLOCATION_RECTIFICATION.value,FileType.PICTURE.getValue())); list.add(allocationExcelExt); } return list; } }