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


@@ -1,5 +1,22 @@


package com.moral.api.service.impl;




import com.baomidou.mybatisplus.extension.conditions.update.LambdaUpdateChainWrapper;


import com.baomidou.mybatisplus.extension.plugins.pagination.Page;


import com.moral.api.config.Interceptor.UserHelper;


import com.moral.api.entity.*;


import com.moral.api.exception.BusinessException;


import com.moral.api.pojo.bean.BaseInvalidEntity;


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


import com.moral.api.service.AllocationExtensionService;


import com.moral.api.service.ApproveTableService;


import lombok.extern.slf4j.Slf4j;


import org.springframework.beans.BeanUtils;


import org.springframework.beans.factory.annotation.Autowired;


@@ -16,6 +33,7 @@


import java.util.Map;


import java.util.Set;


import java.util.stream.Collectors;


import java.util.*;






import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;


@@ -27,9 +45,7 @@


import com.moral.api.entity.SysDictData;


import com.moral.api.entity.SysDictType;


import com.moral.api.mapper.AllocationMapper;


import com.moral.api.mapper.ApproveTableMapper;


import com.moral.api.mapper.ResponsibilityUnitMapper;


import com.moral.api.mapper.SysAreaMapper;


import com.moral.api.mapper.SysDictDataMapper;


import com.moral.api.mapper.SysDictTypeMapper;


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


@@ -61,9 +77,13 @@


    @Autowired


    private AllocationMapper allocationMapper;


    @Autowired


    private ApproveTableMapper approveTableMapper;


    @Autowired


    private  SysAreaService sysAreaService;


    @Autowired


    private ApproveTableService approveTableService;


    @Autowired


    private FileTableService fileTableService;


    @Autowired


    private AllocationExtensionService allocationExtensionService;




    /**


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


@@ -104,53 +124,46 @@




    /**


     * 添加交办单


     * @param allocation


     * @param allocationCond


     * @return


     */


    @Override


    @Transactional


    public Integer insertAllocation(Allocation allocation) {


        ApproveTable approveTable = new ApproveTable();


        //获取用户信息


        Map<String, Object> userInfo = (Map<String, Object>) TokenUtils.getUserInfo();


    public Integer insertAllocation(AllocationAddCond allocationCond) {


        Allocation allocation = allocationCond.convert();


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


        String dateString = DateUtils.dateToDateString(new Date(), DateUtils.yyyyMMdd_EN);


        QueryWrapper<Allocation> wrapper = new QueryWrapper<>();


        Object o = redisTemplate.opsForValue().get(RedisConstants.JBD_DATA);


        int i;


        if (ObjectUtils.isEmpty(o)){


            wrapper.last("limit 1");


            Allocation selectOne = allocationMapper.selectOne(wrapper);


            String allocationNum = selectOne.getAllocationNum();


            String num = allocationNum.substring(10);


             i = Integer.parseInt(num)+1;


             i = 1;


        }else {


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


        allocation.setIsDel("0");


        allocation.setIsInvalid("0");


        allocation.setCreateId(Integer.parseInt(userInfo.get("userId").toString()));


        allocation.setCreateTime(new Date());


        allocation.setCreateName(userInfo.get("account").toString());


        allocation.setUpdateId(Integer.parseInt(userInfo.get("userId").toString()));


        allocation.setUpdateTime(new Date());


        allocation.setUpdateName(userInfo.get("account").toString());


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




        redisTemplate.opsForValue().set(RedisConstants.JBD_DATA,i);


        //添加流程数据


        approveTable.setRelationId(allocation.getAllocationId());


        approveTable.setState(Integer.parseInt(allocation.getState()));


        approveTable.setApproveModule(null);


        approveTable.setStateName(null);


        approveTable.setIsDel(0);


        approveTableMapper.insert(approveTable);


        return null;


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


            //添加流程数据


            ApproveTable approveTable = new ApproveTable();


            approveTable.setRelationId(allocation.getAllocationId());


            approveTable.setState(AllocationApproveEnum.NEW_BUILT.value);


            approveTable.setApproveModule(FileTableEnum.ALLOCATION_FOUNDATION.value);


            approveTable.setStateName(AllocationApproveEnum.NEW_BUILT.name);


            approveTableService.saveResult(approveTable);


        }


        fileTableService.upDateResult(allocationCond.getFileBaseList(),allocation.getAllocationId(), FileTableEnum.ALLOCATION_FOUNDATION.value);


        return allocation.getAllocationId();


    }






    /**


     * 查看表单


@@ -175,29 +188,36 @@


        }


        allocationUnitDto.setChangeTypeName(allocation.getChangeType()==0?"限期整改":"立即整改");


        allocationUnitDto.setInvestigationTypeName(allocation.getChangeType()==0?"现场":"无人机");




        //获取图片


        return allocationUnitDto;


    }




    /**


     * 修改交办单


     * @param allocation


     * @param allocationUpdateCond


     */


    @Override


    public void updateAll(Allocation allocation) {


        //获取用户信息


        Map<String, Object> userInfo = (Map<String, Object>) TokenUtils.getUserInfo();


        if (allocation.getState().equals("1")){


            //获取整改图片


            allocation.setChangeTime(new Date());


        }else {


            //获取审核图片


            allocation.setCheckTime(new Date());


    @Transactional


    public void updateAll(AllocationUpdateCond allocationUpdateCond) {


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


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


            throw new BusinessException("新建未提交状态，才能编辑！");


        }


        allocation.setUpdateId(Integer.parseInt(userInfo.get("userId").toString()));


        allocation.setUpdateTime(new Date());


        allocation.setUpdateName(userInfo.get("account").toString());


        //获取用户信息


        Allocation allocation = allocationUpdateCond.convert();


        if(Objects.nonNull(allocationUpdateCond.getEscalationUnitId())&&allocationUpdateCond.getEscalationUnitId().toString().length()==6) {


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


        }


        if(AllocationApproveEnum.NEW_BUILT.value.equals(allocationUpdateCond.getState())) {


            //添加流程数据


            ApproveTable approveTable = new ApproveTable();


            approveTable.setRelationId(allocation.getAllocationId());


            approveTable.setState(AllocationApproveEnum.NEW_BUILT.value);


            approveTable.setApproveModule(FileTableEnum.ALLOCATION_FOUNDATION.value);


            approveTable.setStateName(AllocationApproveEnum.NEW_BUILT.name);


            approveTableService.saveResult(approveTable);


        }


        fileTableService.upDateResult(allocationUpdateCond.getFileBaseList(),allocation.getAllocationId(), FileTableEnum.ALLOCATION_FOUNDATION.value);


        allocationMapper.updateById(allocation);


    }




@@ -314,7 +334,6 @@


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


@@ -343,7 +362,7 @@


         int complete=0;


         int unComplete=0;


        for (Allocation allocation : allocations) {


            String state = allocation.getState();


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


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


                 complete++;


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


@@ -378,7 +397,6 @@




            AllocationUnitViewDto allocationUnitViewDto = new AllocationUnitViewDto();


            List<Allocation> allocations1 = unitMap.get(integer);




            //加分


            int marks=0;


            //减分


@@ -388,7 +406,7 @@




                Date dateOfDay = DateUtils.getDateOfDay(allocation.getEscalationTime(), allocation.getChangeDay());


                Date date = new Date();


                String state = allocation.getState();


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


                boolean timeBefor = DateUtils.isTimeBefor(date, dateOfDay);


                if (timeBefor && !state.equals("40") && !state.equals("50")){


                    //逾期次数


@@ -434,4 +452,128 @@


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


    }




    @Override


    public AllocationExt extOne(Integer id) {


        AllocationExt allocationExt = oneAllocation(id);


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


        return allocationExt;


    }




    @Override


    public AllocationExt oneAllocation(Integer id){


        return this.baseMapper.extOne(id);


    }




    @Override


    @Transactional


    public void changeAllocation(AllocationChangeCond changeCond) {


        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_FOUNDATION.value);


    }




    @Override


    @Transactional


    public void checkAllocation(AllocationCheckCond checkCond) {


        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.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_FOUNDATION.value);


    }




    @Override


    @Transactional


    public boolean removeById(Integer id) {


        AllocationExt allocationExt = oneAllocation(id);


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


            throw new BusinessException("新建草稿状态，才能删除！");


        }


        this.baseMapper.deleteById(id);


        return true;


    }




    @Override


    @Transactional


    public boolean invalidResult(Integer id,String invalidReason) {


        AllocationExt allocationExt = oneAllocation(id);


        if( AllocationApproveEnum.IN_APPROVAL.value >= allocationExt.getState() ) {


            throw new BusinessException("审批结束才能作废！");


        }


        LambdaUpdateChainWrapper<Allocation> wrapper =lambdaUpdate();


        wrapper.eq(Allocation::getAllocationId,id).set(Allocation::getInvalidReason,invalidReason).set(BaseInvalidEntity::getIsInvalid, YesOrNo.YES.value);


        return wrapper.update();


    }




    @Override


    public List<AllocationListExt> extList(AllocationListCond allocationListCond) {


        return null;


    }




    @Override


    @Transactional


    public boolean applyFor(AllocationExtensionAddCond allocationExtensionAddCond) {


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


        boolean type = false;


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


            type = true;


        }


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


            type = true;


        }


        if(type){


            throw new BusinessException("只有限期整改类型，状态为整改中，才能发起延期申请！");


        }


        AllocationExtension allocationExtension = allocationExtensionAddCond.convert();


        allocationExtension.setState(AllocationExtensionApproveEnum.APPLYING.value);


        allocationExtensionService.save(allocationExtension);


        fileTableService.upDateResult(allocationExtensionAddCond.getFileList(),allocationExtension.getId(), FileTableEnum.ALLOCATION_EXTENSION.value);


        return true;


    }


}