From e94e5dbbfc544c558a09fb388e7f4d4341fe8ec4 Mon Sep 17 00:00:00 2001
From: cjl <276999030@qq.com>
Date: Thu, 28 Sep 2023 16:59:01 +0800
Subject: [PATCH] ci:添加自有权限

---
 screen-api/src/main/java/com/moral/api/service/impl/AllocationServiceImpl.java |  210 ++++++++++++---------------------------------------
 1 files changed, 51 insertions(+), 159 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 d72e2ec..d58c404 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
@@ -138,63 +139,32 @@
         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) {
             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);
         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;
-    }
 
     /**
      * ���������������
@@ -212,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);
@@ -229,67 +199,7 @@
     }
 
 
-    /**
-     * ������������������
-     * @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;
-    }
 
 
     /**
@@ -309,6 +219,9 @@
             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);
@@ -322,21 +235,12 @@
                     List<Integer> collect1 = collect.keySet().stream().collect(Collectors.toList());
                     wrapper.in("unit_id",collect1);
                 }
-            }else if(orgId==24) {
-
-            }else {
-                if (ObjectUtils.isEmpty(unitId)){
-                    return null;
-                }
             }
         }
 
         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");
@@ -349,26 +253,9 @@
         }
         if (!ObjectUtils.isEmpty(number1)){
             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);
@@ -384,7 +271,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++;
             }
         }
@@ -407,7 +294,6 @@
         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<>();
@@ -416,7 +302,6 @@
             SysDictData sysDictData = sysDictDataMapper.selectOne(sysDictDataQueryWrapper);
             typeMap.put("name",sysDictData.getDataValue());
             typeMap.put("value",allocations1.size());
-//            polluteMap.put("polluteType",typeMap);
             polluteArrayList.add(typeMap);
         }
         //������������������������
@@ -427,9 +312,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);
             //������
@@ -445,7 +328,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++;
                     }
@@ -474,9 +357,9 @@
         rsMap.put("unitView",allocationUnitViewDtos);
         //������
         rsMap.put("total",allocations.size());
-        //���������
+        //���������
         rsMap.put("complete",complete);
-        //������������
+        //���������
         rsMap.put("unComplete",unComplete);
         //������
         rsMap.put("overdue",overdue);
@@ -532,26 +415,9 @@
         }
         if (!ObjectUtils.isEmpty(number1)){
             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);
@@ -569,11 +435,8 @@
             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;
             //������
@@ -609,8 +472,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
@@ -747,4 +621,22 @@
         }
         return Arrays.asList(0);
     }
+
+    @Override
+    public Integer unitAreaCode() {
+        QxUser user = UserHelper.getCurrentUser();
+        List<Integer> userList = responsibilityUnitMapper.selectCodeList("JBD",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