blame | history | patch | commit | commitdiff | ignore whitespace
cjl
2023-09-26 c0c80bebcc93e90834e06404d6056322e51b02dd 
 screen-api/src/main/java/com/moral/api/service/impl/AllocationServiceImpl.java


@@ -13,6 +13,7 @@


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.vo.user.QxUser;


import com.moral.api.service.AllocationExtensionService;


import com.moral.api.service.ApproveTableService;


@@ -24,18 +25,37 @@


import org.springframework.transaction.annotation.Transactional;


import org.springframework.util.ObjectUtils;




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 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;


@@ -56,6 +76,8 @@


    private RedisTemplate redisTemplate;


    @Autowired


    private AllocationMapper allocationMapper;


    @Autowired


    private  SysAreaService sysAreaService;


    @Autowired


    private ApproveTableService approveTableService;


    @Autowired


@@ -119,10 +141,13 @@


             i = Integer.parseInt(o.toString()) + 1;


        }


        //单号


        String allocationNum = "JBD" + dateString + String.format("%04d", i);


        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())) {


            allocation.setState(AllocationApproveEnum.UNDER_RECTIFICATION.value);


        }


        //获取新建图片


        allocationMapper.insert(allocation);


@@ -259,6 +284,175 @@


        return null;


    }






    /**


     * 表单总览


     * @param map


     * @return


     */


    @Override


    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)){


                    return null;


                }


                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<AllocationUnitViewDto> allocationUnitViewDtos = new ArrayList<>();




        Object number1 = map.get("number");


        String startTime=null;


        String endTime=null;


        if (!ObjectUtils.isEmpty(map.get("startTime")) || !ObjectUtils.isEmpty(map.get("startTime"))){


             startTime = map.get("startTime").toString();


             endTime = map.get("endTime").toString();




        }


        if (!ObjectUtils.isEmpty(number1)){


            String s = number1.toString();


            //当前时间的


            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);


            }




        }




        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;


        }


         int complete=0;


         int unComplete=0;


        for (Allocation allocation : allocations) {


            String state = allocation.getState()+"";


            if (state.equals("40")||state.equals("50")){


                 complete++;


            }else if(state.equals("10")||state.equals("20") ||state.equals("30")) {


                 unComplete++;


            }


        }


        //根据污染类型分类


        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("dataKey",polluteType);


            SysDictData sysDictData = sysDictDataMapper.selectOne(sysDictDataQueryWrapper);


            typeMap.put("name",sysDictData.getDataValue());


            typeMap.put("value",allocations1.size());


            polluteMap.put("polluteType",typeMap);


        }


        //根据责任单位分类


        Map<Integer, List<Allocation>> unitMap = allocations.stream().collect(Collectors.groupingBy(o -> o.getUnitId()));


        Set<Integer> 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<Allocation> allocations1 = unitMap.get(integer);


            //加分


            int marks=0;


            //减分


            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++;


                }


                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",polluteMap);


        return rsMap;


    }






    /**


     * 导出


     * @param map


     * @return


     */


    @Override


    public List<Map<String, Object>> unitExel(Map<String, Object> map) {


        return null;


    }




    @Override


    public Page<AllocationPageExt> extPage(AllocationPageCond allocationPageCond) {


        return this.baseMapper.extPage(allocationPageCond.getPage().convertPage(), allocationPageCond);


@@ -270,11 +464,12 @@


        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.setApproveList(approveTableService.listAll(id, FileTableEnum.ALLOCATION_FOUNDATION.value));


        return allocationExt;


    }




    private AllocationExt oneAllocation(Integer id){


    @Override


    public AllocationExt oneAllocation(Integer id){


        return this.baseMapper.extOne(id);


    }




@@ -282,8 +477,8 @@


    @Transactional


    public void changeAllocation(AllocationChangeCond changeCond) {


        AllocationExt allocationExt = oneAllocation(changeCond.getAllocationId());


        if(!AllocationApproveEnum.NEW_BUILT.value.equals(allocationExt.getState())) {


            throw new BusinessException("新建状态，才能提交整改！");


        if(!AllocationApproveEnum.UNDER_RECTIFICATION.value.equals(allocationExt.getState())) {


            throw new BusinessException("整改状态，才能提交审批！");


        }


        Allocation allocation = new Allocation();


        allocation.setAllocationId(changeCond.getAllocationId());


@@ -307,8 +502,8 @@


    @Transactional


    public void checkAllocation(AllocationCheckCond checkCond) {


        AllocationExt allocationExt = oneAllocation(checkCond.getAllocationId());


        if(!AllocationApproveEnum.UNDER_RECTIFICATION.value.equals(allocationExt.getState())) {


            throw new BusinessException("整改状态，才能提交审批！");


        if(!AllocationApproveEnum.IN_APPROVAL.value.equals(allocationExt.getState())) {


            throw new BusinessException("审批状态，才能进行审批操作！");


        }


        QxUser qxUser = UserHelper.getCurrentUser();


        Allocation allocation = new Allocation();


@@ -330,7 +525,7 @@


        }


        approveTable.setApproveModule(FileTableEnum.ALLOCATION_FOUNDATION.value);


        approveTableService.saveResult(approveTable);


        fileTableService.upDateResult(checkCond.getFileApproveList(),allocation.getAllocationId(), FileTableEnum.ALLOCATION_FOUNDATION.value);


        fileTableService.upDateResult(checkCond.getFileApproveList(),checkCond.getAllocationId(), FileTableEnum.ALLOCATION_FOUNDATION.value);


    }




    @Override


@@ -369,7 +564,7 @@


        if( !AllocationApproveEnum.UNDER_RECTIFICATION.value.equals(allocationExt.getState())) {


            type = true;


        }


        if(!ChangeEnum.DEADLINE.value.equals(allocationExt.getState())){


        if(!ChangeEnum.DEADLINE.value.equals(allocationExt.getChangeType())){


            type = true;


        }


        if(type){