From 808b5c18e6acbb75bad247f0a8edda60976abd06 Mon Sep 17 00:00:00 2001 From: jinpengyong <jpy123456> Date: Fri, 13 Oct 2023 15:14:50 +0800 Subject: [PATCH] chore:五分钟数据补0提交 --- screen-api/src/main/java/com/moral/api/service/impl/AllocationServiceImpl.java | 168 +++++++++++++++++++++++++++++++++++++------------------ 1 files changed, 113 insertions(+), 55 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 b691536..1b2f9ac 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 @@ -68,6 +68,7 @@ @Slf4j public class AllocationServiceImpl extends ServiceImpl<AllocationMapper, Allocation> implements AllocationService { + private final Integer NEW_BUILT = 10; @Autowired private SysDictTypeMapper sysDictTypeMapper; @Autowired @@ -145,19 +146,19 @@ if(Objects.nonNull(allocationCond.getEscalationUnitId())&&allocationCond.getEscalationUnitId().toString().length()==6) { 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); redisTemplate.opsForValue().set(RedisConstants.JBD_DATA,i); - if(AllocationApproveEnum.NEW_BUILT.value.equals(allocationCond.getState())) { + if(NEW_BUILT.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); @@ -181,16 +182,16 @@ if(Objects.nonNull(allocationUpdateCond.getEscalationUnitId())&&allocationUpdateCond.getEscalationUnitId().toString().length()==6) { 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(AllocationApproveEnum.NEW_BUILT.value.equals(allocationUpdateCond.getState())) { + if(NEW_BUILT.equals(allocationUpdateCond.getState())) { allocation.setState(AllocationApproveEnum.UNDER_RECTIFICATION.value); } fileTableService.upDateResult(allocationUpdateCond.getFileBaseList(),allocation.getAllocationId(), FileTableEnum.ALLOCATION_FOUNDATION.value); @@ -210,32 +211,46 @@ 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"); - Map<String, Object> orgInfo = (Map<String, Object>) userInfo.get("organization"); - Integer orgId = (Integer) orgInfo.get("id"); + List<Integer> list = this.unitResult(); if (!ObjectUtils.isEmpty(map.get("unitId"))){ wrapper.in("unit_id",map.get("unitId").toString()); }else { - if (orgId!=24){ - if (ObjectUtils.isEmpty(unitId)){ + if (!ObjectUtils.isEmpty(list)){ + Integer integer = list.get(0); + if (integer==0){ return null; - } - ResponsibilityUnit responsibilityUnit1 = responsibilityUnitMapper.selectById(Integer.parseInt(unitId.toString())); - Integer areaCode = responsibilityUnit1.getAreaCode(); - List<ResponsibilityUnit> responsibilityUnits = responsibilityUnitService.selectUnit(areaCode); - if (ObjectUtils.isEmpty(responsibilityUnits)){ - List<ResponsibilityUnit> responsibilityUnits1 = responsibilityUnitService.selectAreaUnit(areaCode); - Map<Integer, List<ResponsibilityUnit>> collect = responsibilityUnits1.stream().collect(Collectors.groupingBy(o -> o.getUnitId())); - List<Integer> collect1 = collect.keySet().stream().collect(Collectors.toList()); - wrapper.in("unit_id",collect1); }else { - 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); + wrapper.in("unit_id",list); } } } + +// Map<String, Object> userInfo = (Map<String, Object>) TokenUtils.getUserInfo(); +// Object unitId = userInfo.get("unitId"); +// Map<String, Object> orgInfo = (Map<String, Object>) userInfo.get("organization"); +// Integer orgId = (Integer) orgInfo.get("id"); +// if (!ObjectUtils.isEmpty(map.get("unitId"))){ +// wrapper.in("unit_id",map.get("unitId").toString()); +// }else { +// if (orgId!=24){ +// if (ObjectUtils.isEmpty(unitId)){ +// return null; +// } +// ResponsibilityUnit responsibilityUnit1 = responsibilityUnitMapper.selectById(Integer.parseInt(unitId.toString())); +// Integer areaCode = responsibilityUnit1.getAreaCode(); +// List<ResponsibilityUnit> responsibilityUnits = responsibilityUnitService.selectUnit(areaCode); +// if (ObjectUtils.isEmpty(responsibilityUnits)){ +// List<ResponsibilityUnit> responsibilityUnits1 = responsibilityUnitService.selectAreaUnit(areaCode); +// Map<Integer, List<ResponsibilityUnit>> collect = responsibilityUnits1.stream().collect(Collectors.groupingBy(o -> o.getUnitId())); +// List<Integer> collect1 = collect.keySet().stream().collect(Collectors.toList()); +// wrapper.in("unit_id",collect1); +// }else { +// 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); +// } +// } +// } HashMap<String, Object> rsMap = new HashMap<>(); ArrayList<Map<String, Object>> polluteArrayList = new ArrayList<>(); @@ -245,7 +260,7 @@ Object number1 = map.get("number"); 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(); @@ -270,7 +285,7 @@ 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++; } } @@ -327,7 +342,7 @@ 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")){ + if (timeBefor && !state.equals("40") && !state.equals("50") && !state.equals("9")){ //������������ overdue++; } @@ -356,9 +371,9 @@ rsMap.put("unitView",allocationUnitViewDtos); //������ rsMap.put("total",allocations.size()); - //��������� + //��������� rsMap.put("complete",complete); - //������������ + //��������� rsMap.put("unComplete",unComplete); //������ rsMap.put("overdue",overdue); @@ -379,35 +394,48 @@ public List<Map<String, Object>> unitExel(Map<String, Object> map) { QueryWrapper<Allocation> wrapper = new QueryWrapper<>(); //������������������ - Map<String, Object> userInfo = (Map<String, Object>) TokenUtils.getUserInfo(); - Object unitId = userInfo.get("unitId"); - Map<String, Object> orgInfo = (Map<String, Object>) userInfo.get("organization"); - Integer orgId = (Integer) orgInfo.get("id"); - - if (ObjectUtils.isEmpty(unitId)){ - return null; - } - if (orgId!=24){ - ResponsibilityUnit responsibilityUnit1 = responsibilityUnitMapper.selectById(Integer.parseInt(unitId.toString())); - Integer areaCode = responsibilityUnit1.getAreaCode(); - List<ResponsibilityUnit> responsibilityUnits = responsibilityUnitService.selectUnit(areaCode); - if (ObjectUtils.isEmpty(responsibilityUnits)){ - List<ResponsibilityUnit> responsibilityUnits1 = responsibilityUnitService.selectAreaUnit(areaCode); - Map<Integer, List<ResponsibilityUnit>> collect = responsibilityUnits1.stream().collect(Collectors.groupingBy(o -> o.getUnitId())); - List<Integer> collect1 = collect.keySet().stream().collect(Collectors.toList()); - wrapper.in("unit_id",collect1); - }else { - 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); + 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<String, Object> userInfo = (Map<String, Object>) TokenUtils.getUserInfo(); +// Object unitId = userInfo.get("unitId"); +// Map<String, Object> orgInfo = (Map<String, Object>) userInfo.get("organization"); +// Integer orgId = (Integer) orgInfo.get("id"); +// +// if (ObjectUtils.isEmpty(unitId)){ +// return null; +// } +// if (orgId!=24){ +// ResponsibilityUnit responsibilityUnit1 = responsibilityUnitMapper.selectById(Integer.parseInt(unitId.toString())); +// Integer areaCode = responsibilityUnit1.getAreaCode(); +// List<ResponsibilityUnit> responsibilityUnits = responsibilityUnitService.selectUnit(areaCode); +// if (ObjectUtils.isEmpty(responsibilityUnits)){ +// List<ResponsibilityUnit> responsibilityUnits1 = responsibilityUnitService.selectAreaUnit(areaCode); +// Map<Integer, List<ResponsibilityUnit>> collect = responsibilityUnits1.stream().collect(Collectors.groupingBy(o -> o.getUnitId())); +// List<Integer> collect1 = collect.keySet().stream().collect(Collectors.toList()); +// wrapper.in("unit_id",collect1); +// }else { +// 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); +// } +// } 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("startTime"))){ + if (!ObjectUtils.isEmpty(map.get("startTime")) || !ObjectUtils.isEmpty(map.get("endTime"))){ startTime = map.get("startTime").toString(); endTime = map.get("endTime").toString(); @@ -471,8 +499,19 @@ @Override public Page<AllocationPageExt> extPage(AllocationPageCond allocationPageCond) { List<Integer> unitList = unitResult(); + Integer codeId = unitAreaCode(); allocationPageCond.setUnitList(unitList); - return this.baseMapper.extPage(allocationPageCond.getPage().convertPage(), allocationPageCond); + 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); + } + }); + } + return page; } @Override @@ -590,6 +629,7 @@ } 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; @@ -599,7 +639,7 @@ public List<Integer> unitResult() { QxUser user = UserHelper.getCurrentUser(); Integer unitId = Objects.nonNull(user.getUnitId())?user.getUnitId():0; - List<Integer> userList = responsibilityUnitMapper.selectCodeList("JBD",user.getUserId()); + List<Integer> userList = responsibilityUnitMapper.selectCodeList(SysDictTypeEnum.SYS_JBD.getValue(),user.getUserId()); if(CollectionUtils.isNotEmpty(userList)){ return new ArrayList<>(); } @@ -609,4 +649,22 @@ } 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())){ + String code = responsibilityUnitMapper.selectAreaCode(user.getUnitId()); + if(code.length()>6){ + return 0; + }else { + return 2; + } + } + return 1; + } } -- Gitblit v1.8.0