From 6992aaf0587c09f7c511c1afd12e1519d91363d3 Mon Sep 17 00:00:00 2001 From: cjl <276999030@qq.com> Date: Thu, 14 Dec 2023 15:38:45 +0800 Subject: [PATCH] Merge remote-tracking branch 'origin/cjl' into qa --- screen-api/src/main/java/com/moral/api/service/impl/AllocationServiceImpl.java | 841 ++++++++++++++++++++++++++++++++++++++++++------------- 1 files changed, 637 insertions(+), 204 deletions(-) diff --git a/screen-api/src/main/java/com/moral/api/service/impl/AllocationServiceImpl.java b/screen-api/src/main/java/com/moral/api/service/impl/AllocationServiceImpl.java index 35a76ce..f588770 100644 --- a/screen-api/src/main/java/com/moral/api/service/impl/AllocationServiceImpl.java +++ b/screen-api/src/main/java/com/moral/api/service/impl/AllocationServiceImpl.java @@ -1,77 +1,71 @@ 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.PageCond; import com.moral.api.pojo.query.allocation.*; import com.moral.api.pojo.query.allocationextension.AllocationExtensionAddCond; -import com.moral.api.pojo.vo.approvetable.ApproveTableListVo; +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.AllocationExtensionService; -import com.moral.api.service.ApproveTableService; +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.ArrayList; -import java.util.Date; -import java.util.HashMap; -import java.util.Iterator; -import java.util.List; -import java.util.Map; -import java.util.Set; -import java.util.stream.Collectors; import java.util.*; +import java.util.stream.Collectors; - -import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; -import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; -import com.moral.api.entity.Allocation; -import com.moral.api.entity.ApproveTable; -import com.moral.api.entity.ResponsibilityUnit; -import com.moral.api.entity.SysArea; -import com.moral.api.entity.SysDictData; -import com.moral.api.entity.SysDictType; -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.pojo.dto.allocation.AllocationUnitDto; -import com.moral.api.pojo.dto.allocation.AllocationUnitViewDto; -import com.moral.api.pojo.enums.AllocationApproveEnum; -import com.moral.api.pojo.vo.file.FileVo; -import com.moral.api.service.AllocationService; -import com.moral.api.service.FileTableService; -import com.moral.api.service.SysAreaService; -import com.moral.api.service.SysDictDataService; -import com.moral.constant.Constants; -import com.moral.constant.RedisConstants; -import com.moral.util.DateUtils; -import com.moral.util.TokenUtils; +import javax.servlet.http.HttpServletRequest; @Service @Slf4j public class AllocationServiceImpl extends ServiceImpl<AllocationMapper, Allocation> implements AllocationService { + private final Integer NEW_BUILT = 10; @Autowired private SysDictTypeMapper sysDictTypeMapper; @Autowired - private SysDictDataMapper sysDictDataMapper; - @Autowired private ResponsibilityUnitMapper responsibilityUnitMapper; + @Autowired + private SysDictDataMapper sysDictDataMapper; @Autowired private RedisTemplate redisTemplate; @Autowired @@ -84,6 +78,14 @@ private FileTableService fileTableService; @Autowired private AllocationExtensionService allocationExtensionService; + @Autowired + private ResponsibilityUnitService responsibilityUnitService; + @Autowired + private SysDictTypeService sysDictTypeService; + @Autowired + private UserService userService; + @Autowired + private AllocationLogMapper allocationLogMapper; /** * ������������������������������������ @@ -111,11 +113,11 @@ wrapper.eq("is_del",Constants.NOT_DELETE); wrapper.eq("state",0); wrapper.eq("is_invalid",0); + //������������������ - Map<String, Object> userInfo = (Map<String, Object>) TokenUtils.getUserInfo(); - Object code = userInfo.get("code"); - if (!ObjectUtils.isEmpty(code)){ - wrapper.eq("area_code",code); + List<Integer> unitList = unitResult(); + if (CollectionUtils.isNotEmpty(unitList)){ + wrapper.in("unit_id",unitList); } List<ResponsibilityUnit> responsibilityUnits = responsibilityUnitMapper.selectList(wrapper); return responsibilityUnits; @@ -134,63 +136,34 @@ allocation.setEscalationType(AllocationEscalationTypeEnum.SELF.getValue()); String dateString = DateUtils.dateToDateString(new Date(), DateUtils.yyyyMMdd_EN); Object o = redisTemplate.opsForValue().get(RedisConstants.JBD_DATA); - int i; - if (ObjectUtils.isEmpty(o)){ - i = 1; - }else { - i = Integer.parseInt(o.toString()) + 1; - } + 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().toString().length()==6) { + if(Objects.nonNull(allocationCond.getEscalationUnitId())&& !allocationCond.getEscalationUnitId().equals(allocationCond.getUnitId()) && escalationType(allocationCond.getEscalationUnitId())) { allocation.setEscalationType(AllocationEscalationTypeEnum.CHECK.getValue()); } - if(AllocationApproveEnum.NEW_BUILT.value.equals(allocationCond.getState())) { + 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(AllocationApproveEnum.NEW_BUILT.value.equals(allocationCond.getState())) { + if(NEW_BUILT.equals(allocationCond.getState())||AllocationApproveEnum.UNDER_RECTIFICATION.value.equals(allocationCond.getState())) { //������������������ ApproveTable approveTable = new ApproveTable(); approveTable.setRelationId(allocation.getAllocationId()); - approveTable.setState(AllocationApproveEnum.NEW_BUILT.value); + approveTable.setState(NEW_BUILT); approveTable.setApproveModule(FileTableEnum.ALLOCATION_FOUNDATION.value); - approveTable.setStateName(AllocationApproveEnum.NEW_BUILT.name); + approveTable.setStateName("������"); approveTableService.saveResult(approveTable); } fileTableService.upDateResult(allocationCond.getFileBaseList(),allocation.getAllocationId(), FileTableEnum.ALLOCATION_FOUNDATION.value); return allocation.getAllocationId(); } - /** - * ������������ - * @param id - * @return - */ - @Override - public AllocationUnitDto check(Integer id) { - AllocationUnitDto allocationUnitDto = new AllocationUnitDto(); - Allocation allocation = allocationMapper.selectById(id); - BeanUtils.copyProperties(allocation,allocationUnitDto); - ResponsibilityUnit responsibilityUnit = responsibilityUnitMapper.selectById(allocation.getUnitId()); - allocationUnitDto.setUnitName(responsibilityUnit.getUnitName()); - allocationUnitDto.setEscalationUnitName(responsibilityUnit.getUnitName()); - Map<String, List<SysDictData>> map = (Map<String, List<SysDictData>>) redisTemplate.opsForValue().get(RedisConstants.DICT_DATA_KEY); - List<SysDictData> contaminate = map.get("contaminate"); - for (SysDictData sysDictData : contaminate) { - if (sysDictData.getDataKey().equals(allocation.getPolluteType().toString())){ - allocationUnitDto.setPolluteTypeName(sysDictData.getDataValue()); - break; - } - } - allocationUnitDto.setChangeTypeName(allocation.getChangeType()==0?"������������":"������������"); - allocationUnitDto.setInvestigationTypeName(allocation.getChangeType()==0?"������":"���������"); - //������������ - return allocationUnitDto; - } /** * ��������������� @@ -205,84 +178,27 @@ } //������������������ Allocation allocation = allocationUpdateCond.convert(); - if(Objects.nonNull(allocationUpdateCond.getEscalationUnitId())&&allocationUpdateCond.getEscalationUnitId().toString().length()==6) { + if(Objects.nonNull(allocationUpdateCond.getEscalationUnitId())&& escalationType(allocationUpdateCond.getEscalationUnitId())) { allocation.setEscalationType(AllocationEscalationTypeEnum.CHECK.getValue()); } - if(AllocationApproveEnum.NEW_BUILT.value.equals(allocationUpdateCond.getState())) { + if(NEW_BUILT.equals(allocationUpdateCond.getState())) { //������������������ ApproveTable approveTable = new ApproveTable(); approveTable.setRelationId(allocation.getAllocationId()); - approveTable.setState(AllocationApproveEnum.NEW_BUILT.value); + approveTable.setState(NEW_BUILT); approveTable.setApproveModule(FileTableEnum.ALLOCATION_FOUNDATION.value); - approveTable.setStateName(AllocationApproveEnum.NEW_BUILT.name); + 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 List<Allocation> selectAll(Map<String, Object> map) { - Object unitId = map.get("unitId"); - Object state = map.get("state"); - Object polluteType = map.get("polluteType"); - Object investigationType = map.get("investigationType"); - Object changeType = map.get("changeType"); - Object escalationTime = map.get("escalationTime"); - Object isInvalid = map.get("isInvalid"); -// int page = Integer.parseInt(map.get("page").toString()); -// int size = Integer.parseInt(map.get("size").toString()); - QueryWrapper<Allocation> wrapper = new QueryWrapper<>(); - - //������������ - if (!ObjectUtils.isEmpty(unitId)){ - wrapper.eq("unit_id",Integer.parseInt(unitId.toString())); - } - //������������ - if (!ObjectUtils.isEmpty(state)){ - wrapper.eq("state",Integer.parseInt(state.toString())); - } - //������������ - if (!ObjectUtils.isEmpty(polluteType)){ - wrapper.eq("pollute_type",Integer.parseInt(polluteType.toString())); - } - //������������ - if (!ObjectUtils.isEmpty(investigationType)){ - wrapper.eq("investigation_type",Integer.parseInt(investigationType.toString())); - } - //������������ - if (!ObjectUtils.isEmpty(changeType)){ - wrapper.eq("change_type",Integer.parseInt(changeType.toString())); - } - //������������ - if (!ObjectUtils.isEmpty(isInvalid)){ - wrapper.eq("is_invalid",Integer.parseInt(isInvalid.toString())); - } - if (!ObjectUtils.isEmpty(escalationTime)){ -// wrapper.eq("is_invalid",Integer.parseInt(isInvalid.toString())); - } - List<Allocation> allocations = allocationMapper.selectList(wrapper); - ArrayList<AllocationUnitDto> rsList = new ArrayList<>(); - for (Allocation allocation : allocations) { - AllocationUnitDto allocationUnitDto = new AllocationUnitDto(); - BeanUtils.copyProperties(allocation,allocationUnitDto); - allocation.getEscalationTime(); - Date dateOfDay = DateUtils.getDateOfDay(allocation.getEscalationTime(), allocation.getChangeDay()); - Date date = new Date(); - //��������������������������� - int days = DateUtils.getDays(dateOfDay, date); - allocationUnitDto.setChangeDay(days); - rsList.add(allocationUnitDto); - } - return null; - } /** @@ -294,62 +210,41 @@ public Map<String, Object> selectUnitView(Map<String, Object> map) { QueryWrapper<Allocation> wrapper = new QueryWrapper<>(); //������������������ -// Map<String, Object> userInfo = (Map<String, Object>) TokenUtils.getUserInfo(); -// Object unitId = userInfo.get("unitId"); - - Integer unitId= 17; - if (!ObjectUtils.isEmpty(unitId)){ - ResponsibilityUnit responsibilityUnit1 = responsibilityUnitMapper.selectById(unitId); - Integer areaCode = responsibilityUnit1.getAreaCode(); - if (areaCode<999999){ - QueryWrapper<ResponsibilityUnit> wrapper1 = new QueryWrapper<>(); - wrapper1.eq("parent_code",areaCode); - List<ResponsibilityUnit> responsibilityUnits = responsibilityUnitMapper.selectList(wrapper1); - if (ObjectUtils.isEmpty(responsibilityUnits)){ + List<Integer> 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); } - Map<Integer, List<ResponsibilityUnit>> collect = responsibilityUnits.stream().collect(Collectors.groupingBy(o -> o.getUnitId())); - List<Integer> collect1 = collect.keySet().stream().collect(Collectors.toList()); - wrapper.in("unit_id",collect1); - }else { - wrapper.eq("unit_id",unitId); } } + + HashMap<String, Object> rsMap = new HashMap<>(); - HashMap<String, Object> polluteMap = new HashMap<>(); + ArrayList<Map<String, Object>> polluteArrayList = new ArrayList<>(); + ArrayList<Map<String, Object>> escalationTypeList = new ArrayList<>(); ArrayList<AllocationUnitViewDto> allocationUnitViewDtos = new ArrayList<>(); - Object number1 = map.get("number"); + String number1 = map.get("number").toString(); String startTime=null; String endTime=null; - if (!ObjectUtils.isEmpty(map.get("startTime")) || !ObjectUtils.isEmpty(map.get("startTime"))){ + if (!ObjectUtils.isEmpty(map.get("startTime")) || !ObjectUtils.isEmpty(map.get("endTime"))){ startTime = map.get("startTime").toString(); - endTime = map.get("endTime").toString(); +// endTime = map.get("endTime").toString(); + endTime = DateUtils.getDateOfDay(map.get("endTime").toString(), 1, DateUtils.yyyy_MM_dd_EN); } - if (!ObjectUtils.isEmpty(number1)){ - String s = number1.toString(); - //��������������� + if (!number1.equals("0")){ + String s = "-"+number1; + //������������������ endTime = DateUtils.getCurDateTime(); - if (s.equals("-1")){ - //��������������� - startTime = DateUtils.getDateStringOfMon(Integer.parseInt(s), DateUtils.yyyy_MM_dd_HH_mm_ss_EN); - } - if (s.equals("-2")){ - //��������������� - startTime = DateUtils.getDateStringOfMon(Integer.parseInt(s), DateUtils.yyyy_MM_dd_HH_mm_ss_EN); - } - if (s.equals("-3")){ - startTime = DateUtils.getDateStringOfMon(Integer.parseInt(s), DateUtils.yyyy_MM_dd_HH_mm_ss_EN); - } - if (s.equals("-6")){ - startTime = DateUtils.getDateStringOfMon(Integer.parseInt(s), DateUtils.yyyy_MM_dd_HH_mm_ss_EN); - } - if (s.equals("-12")){ - startTime = DateUtils.getDateStringOfMon(Integer.parseInt(s), DateUtils.yyyy_MM_dd_HH_mm_ss_EN); - } - + startTime = DateUtils.getDateStringOfMon(Integer.parseInt(s), DateUtils.yyyy_MM_dd_HH_mm_ss_EN); } wrapper.between("escalation_time",startTime,endTime); @@ -365,24 +260,39 @@ String state = allocation.getState()+""; if (state.equals("40")||state.equals("50")){ complete++; - }else if(state.equals("10")||state.equals("20") ||state.equals("30")) { + }else { unComplete++; } } + //������������������������ + Map<Integer, List<Allocation>> escalationTypeMap = allocations.stream().collect(Collectors.groupingBy(o -> o.getEscalationType())); + Set<Integer> escalationTypes = escalationTypeMap.keySet(); + for (Integer escalationType : escalationTypes) { + List<Allocation> allocations1 = escalationTypeMap.get(escalationType); + String value = AllocationEscalationTypeEnum.SELF.value.toString(); + HashMap<String, Object> 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<Integer, List<Allocation>> polluteTypeMap = allocations.stream().collect(Collectors.groupingBy(o -> o.getPolluteType())); Set<Integer> polluteTypes = polluteTypeMap.keySet(); for (Integer polluteType : polluteTypes) { - HashMap<String, Object> typeMap = new HashMap<>(); List<Allocation> allocations1 = polluteTypeMap.get(polluteType); QueryWrapper<SysDictData> sysDictDataQueryWrapper = new QueryWrapper<>(); - sysDictDataQueryWrapper.eq("dict_type_id",31); + 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()); - polluteMap.put("polluteType",typeMap); + polluteArrayList.add(typeMap); } //������������������������ Map<Integer, List<Allocation>> unitMap = allocations.stream().collect(Collectors.groupingBy(o -> o.getUnitId())); @@ -392,9 +302,7 @@ for (Integer integer : unitList) { //������������ ResponsibilityUnit responsibilityUnit = responsibilityUnitMapper.selectById(integer); - SysArea areaByCode = sysAreaService.getAreaByCode(responsibilityUnit.getAreaCode()); - AllocationUnitViewDto allocationUnitViewDto = new AllocationUnitViewDto(); List<Allocation> allocations1 = unitMap.get(integer); //������ @@ -403,14 +311,17 @@ int deduction=0; int number=0; for (Allocation allocation : allocations1) { - - Date dateOfDay = DateUtils.getDateOfDay(allocation.getEscalationTime(), allocation.getChangeDay()); - Date date = new Date(); String state = allocation.getState()+""; - boolean timeBefor = DateUtils.isTimeBefor(date, dateOfDay); - if (timeBefor && !state.equals("40") && !state.equals("50")){ - //������������ - overdue++; + 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){ @@ -434,11 +345,18 @@ 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",polluteMap); + //������������ + rsMap.put("polluteType",polluteArrayList); + //������������ + rsMap.put("escalationType",escalationTypeList); return rsMap; } @@ -450,12 +368,106 @@ */ @Override public List<Map<String, Object>> unitExel(Map<String, Object> map) { - return null; + QueryWrapper<Allocation> wrapper = new QueryWrapper<>(); + //������������������ + List<Integer> 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<Map<String, Object>> 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<Allocation> allocations = allocationMapper.selectList(wrapper); + if (ObjectUtils.isEmpty(allocations)){ + return null; + } + //������������������������ + Map<Integer, List<Allocation>> unitMap = allocations.stream().collect(Collectors.groupingBy(o -> o.getUnitId())); + Set<Integer> unitList = unitMap.keySet(); + for (Integer integer : unitList) { +// HashMap<String, Object> map1 = new HashMap<>(); + LinkedHashMap<String, Object> map1 = new LinkedHashMap<>(); + //������������ + ResponsibilityUnit responsibilityUnit = responsibilityUnitMapper.selectById(integer); + SysArea areaByCode = sysAreaService.getAreaByCode(responsibilityUnit.getAreaCode()); + List<Allocation> 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<AllocationPageExt> extPage(AllocationPageCond allocationPageCond) { - return this.baseMapper.extPage(allocationPageCond.getPage().convertPage(), allocationPageCond); + List<Integer> unitAuthority = this.getUnitAuthority(SysDictTypeEnum.SYS_AMEND.value); + List<Integer> unitList = unitResult(); + Integer codeId = unitAreaCode(); + allocationPageCond.setUnitList(unitList); + Page<AllocationPageExt> 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 @@ -465,6 +477,9 @@ 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; } @@ -488,6 +503,9 @@ 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()); @@ -495,7 +513,7 @@ approveTable.setStateName(AllocationApproveEnum.UNDER_RECTIFICATION.name); approveTable.setApproveModule(FileTableEnum.ALLOCATION_FOUNDATION.value); approveTableService.saveResult(approveTable); - fileTableService.upDateResult(changeCond.getFileChangeList(),allocation.getAllocationId(), FileTableEnum.ALLOCATION_FOUNDATION.value); + fileTableService.upDateResult(changeCond.getFileChangeList(),allocation.getAllocationId(), FileTableEnum.ALLOCATION_RECTIFICATION.value); } @Override @@ -508,6 +526,7 @@ 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()); @@ -525,7 +544,7 @@ } approveTable.setApproveModule(FileTableEnum.ALLOCATION_FOUNDATION.value); approveTableService.saveResult(approveTable); - fileTableService.upDateResult(checkCond.getFileApproveList(),checkCond.getAllocationId(), FileTableEnum.ALLOCATION_FOUNDATION.value); + fileTableService.upDateResult(checkCond.getFileApproveList(),checkCond.getAllocationId(), FileTableEnum.ALLOCATION_APPROVE.value); } @Override @@ -572,8 +591,422 @@ } 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<AllocationFindVo> selectSmallRoutine(Integer state,String startTime,String endTime) { + ArrayList<AllocationFindVo> allocationFindVos = new ArrayList<>(); + LambdaQueryWrapper<Allocation> wrapper = new LambdaQueryWrapper<>(); + //������������������ + List<Integer> 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<Allocation> 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<AllocationPageExt> pageApp(AppAllocationPageCond allocationPageCond) { + List<Integer> listUnit = unitResult(); + Integer integer = unitAreaCode(); + allocationPageCond.setUnitList(listUnit); + allocationPageCond.setStateList(stateAllocationList(allocationPageCond.getState(),integer)); + Page<AllocationPageExt> 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<Integer> stateAllocationList(Integer type, Integer integer){ + List<Integer> 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<Allocation> wrapper = new LambdaQueryWrapper<>(); + wrapper.eq(Allocation::getAllocationNum,allocationNum); + wrapper.eq(Allocation::getIsDel,0); + wrapper.eq(Allocation::getIsInvalid,0); + Allocation allocation = allocationMapper.selectOne(wrapper); + + List<Integer> 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<AllocationLog> getLog(String allocationNum) { + LambdaQueryWrapper<AllocationLog> wrapper = new LambdaQueryWrapper<>(); + wrapper.eq(AllocationLog::getAllocationNum,allocationNum); + wrapper.orderByAsc(AllocationLog::getCreateTime); + List<AllocationLog> allocationLogs = allocationLogMapper.selectList(wrapper); + return allocationLogs; + } + + /** + * ������������������������������ + * + * @param code + * @return + */ + @Override + public List<Integer> getUnitAuthority(String code) { + QxUser user = UserHelper.getCurrentUser(); + List<Integer> userList = responsibilityUnitMapper.selectCodeList(code,user.getUserId()); + return userList; + } + + @Override + public List<Integer> unitResult() { + QxUser user = UserHelper.getCurrentUser(); + Integer unitId = Objects.nonNull(user.getUnitId())?user.getUnitId():0; + List<Integer> 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<Integer> 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<AllocationExcelExt> listExcel(List<Integer> id) { + List<AllocationExcelExt> 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; + } } -- Gitblit v1.8.0