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