forked from moral

blame | history | patch | commit | commitdiff | ignore whitespace
jinpengyong
2023-10-23 a1ef8a466a6603fe37cb6f7341ce127ab0861c07 
 screen-api/src/main/java/com/moral/api/service/impl/AllocationServiceImpl.java


@@ -1,12 +1,19 @@


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;


@@ -15,8 +22,10 @@


import com.moral.api.pojo.query.allocationextension.AllocationExtensionAddCond;


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,43 +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 com.sun.javafx.scene.control.skin.VirtualFlow;


import java.util.stream.Collectors;






@Service


@@ -90,6 +64,8 @@


    private AllocationExtensionService allocationExtensionService;


    @Autowired


    private ResponsibilityUnitService responsibilityUnitService;


    @Autowired


    private SysDictTypeService sysDictTypeService;




    /**


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


@@ -306,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());