forked from moral

blame | history | patch | commit | commitdiff | ignore whitespace
cjl
2023-10-25 e13c78395130ffd3da92f83d27a7f54b52717195 
 screen-api/src/main/java/com/moral/api/service/impl/AllocationServiceImpl.java


@@ -1,22 +1,31 @@


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.entity.*;


import com.moral.api.exception.BusinessException;


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.bean.BaseInvalidEntity;


import com.moral.api.pojo.dto.allocation.AllocationUnitViewDto;


import com.moral.api.pojo.enums.*;


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.vo.allocation.AllocationFindVo;


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.constant.Constants;


import com.moral.constant.RedisConstants;


import com.moral.util.DateUtils;


import lombok.extern.slf4j.Slf4j;


import org.apache.commons.collections4.CollectionUtils;


import org.springframework.beans.BeanUtils;


@@ -26,42 +35,8 @@


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


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 java.util.stream.Collectors;






@Service


@@ -89,6 +64,8 @@


    private AllocationExtensionService allocationExtensionService;


    @Autowired


    private ResponsibilityUnitService responsibilityUnitService;


    @Autowired


    private SysDictTypeService sysDictTypeService;




    /**


     * 根据字典类型获取字典数据


@@ -143,7 +120,7 @@


        //单号


        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())&& escalationType(allocationCond.getEscalationUnitId())) {


            allocation.setEscalationType(AllocationEscalationTypeEnum.CHECK.getValue());


        }


        if(NEW_BUILT.equals(allocationCond.getState())) {


@@ -179,7 +156,7 @@


        }


        //获取用户信息


        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(NEW_BUILT.equals(allocationUpdateCond.getState())) {


@@ -305,13 +282,14 @@


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


@@ -636,6 +614,154 @@


    }




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


    }




    /**


     * 小程序整改


     *


     * @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.setState(AllocationApproveEnum.UNDER_RECTIFICATION.value);


        approveTable.setStateName(AllocationApproveEnum.UNDER_RECTIFICATION.name);


        approveTable.setApproveModule(FileTableEnum.ALLOCATION_FOUNDATION.value);


        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 List<Integer>  unitResult() {


        QxUser user = UserHelper.getCurrentUser();


        Integer unitId = Objects.nonNull(user.getUnitId())?user.getUnitId():0;


@@ -667,4 +793,12 @@


        }


        return 1;


    }


    private boolean escalationType(Integer id){


        boolean f = false;


        String code = responsibilityUnitMapper.selectAreaCode(id);


        if(code.length() == 6){


            return true;


        }


        return f;


    }


}