fj-dc/.svn/pristine/db/dba33579c38f95b4c5455e64da65045ee2562d44.svn-base

package cn.com.goldenwater.dcproj.service.impl.ducha;

import cn.com.goldenwater.core.service.AbstractCrudService;
import cn.com.goldenwater.dcproj.constValue.BisInspEnum;
import cn.com.goldenwater.dcproj.constValue.SplitValue;
import cn.com.goldenwater.dcproj.dao.*;
import cn.com.goldenwater.dcproj.dto.*;
import cn.com.goldenwater.dcproj.model.*;
import cn.com.goldenwater.dcproj.param.*;
import cn.com.goldenwater.dcproj.service.AttEmpwtprjBaseService;
import cn.com.goldenwater.dcproj.service.BisInspBaseService;
import cn.com.goldenwater.dcproj.utils.AMapUtil;
import cn.com.goldenwater.dcproj.utils.AdLevelUtil;
import cn.com.goldenwater.dcproj.utils.Builder;
import cn.com.goldenwater.dcproj.utils.GeoUtil;
import com.github.pagehelper.PageHelper;
import com.github.pagehelper.PageInfo;
import net.sf.json.JSONObject;
import org.apache.commons.collections.map.HashedMap;
import org.apache.commons.lang3.StringUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;

import java.text.DecimalFormat;
import java.text.SimpleDateFormat;
import java.util.*;
import java.util.function.Function;
import java.util.stream.Collectors;

/**
 * @author lhc
 * @date 2019-2-20
 */
@Service
@Transactional(rollbackFor = Exception.class)
public class BisInspBaseServiceImpl extends AbstractCrudService<BisInspBase, BisInspParam> implements BisInspBaseService {

    @Autowired
    private BisInspBaseDao bisInspBaseDao;


    @Autowired
    private AttEmpwtprjBaseService attEmpwtprjBaseService;

    @Autowired
    private TacInspYearBatchGroupPersDao groupPersDao;

    @Autowired
    private BisInspAllRlationPersDao rlationPersDao;

    @Autowired
    private TacInspYearBatchGroupDao groupDao;

    @Autowired
    private TacInspYearBatchAreaDao tacInspYearBatchAreaDao;

    @Autowired
    private TacWorkerBDao workerBDao;

    @Autowired
    private TacAttPawpBaseDao tacAttPawpBaseDao;

    @Autowired
    private TacPawpRgstrDao tacPawpRgstrDao;

    @Autowired
    private TacInspYearBatchObjDao tacInspYearBatchObjDao;

    @Autowired
    private TacInspYearBatchGroupDao tacInspYearBatchGroupDao;

    @Autowired
    private BisInspAllRlationDao bisInspAllRlationDao;

    public BisInspBaseServiceImpl(BisInspBaseDao bisInspBaseDao) {
        super(bisInspBaseDao);
        this.bisInspBaseDao = bisInspBaseDao;
    }

    @Override
    public PageInfo getCatalog(BisInspParam bisInspParam) {
        String type = bisInspParam.getType() == null ? "" : bisInspParam.getType();
        bisInspParam.setAddvcd(AdLevelUtil.getAddvcd(bisInspParam.getAddvcd()));
        if ("RSVR".equals(type)) {
            return getPageRsvrList(bisInspParam);
        } else if ("CWS".equals(type)) {
            return getPageCwsList(bisInspParam);
        } else if ("WTDST".equals(type)) {
            return getPageWtdstList(bisInspParam);
        } else if ("WS".equals(type)) {
            return getPageWrWsList(bisInspParam);
        } else {
            return null;
        }


    }

    @Override
    public PageInfo getPageRsvrList(BisInspParam bisInspParam) {
        bisInspParam.setAddvcd(AdLevelUtil.getAddvcd(bisInspParam.getAddvcd()));
        PageHelper.startPage(bisInspParam.getPageNum(), bisInspParam.getPageSize());
        List<BisInspBaseDto> bisInspBaseDtos = getRsvrList(bisInspParam);
        return new PageInfo<>(bisInspBaseDtos);
    }

    @Override
    public PageInfo getPageCwsList(BisInspParam bisInspParam) {
        bisInspParam.setAddvcd(AdLevelUtil.getAddvcd(bisInspParam.getAddvcd()));
        PageHelper.startPage(bisInspParam.getPageNum(), bisInspParam.getPageSize());
        List<BisInspBaseDto> bisInspBaseDtos = getCwsList(bisInspParam);
        return new PageInfo<>(bisInspBaseDtos);
    }

    @Override
    public PageInfo getPageWtdstList(BisInspParam bisInspParam) {
        bisInspParam.setAddvcd(AdLevelUtil.getAddvcd(bisInspParam.getAddvcd()));
        PageHelper.startPage(bisInspParam.getPageNum(), bisInspParam.getPageSize());
        List<BisInspBaseDto> bisInspBaseDtos = getWtdstList(bisInspParam);
        return new PageInfo<>(bisInspBaseDtos);
    }

    @Override
    public List<BisInspBaseDto> getBaseList(BisInspParam bisInspParam) {
        String type = bisInspParam.getType() == null ? "" : bisInspParam.getType();
        bisInspParam.setAddvcd(AdLevelUtil.getAddvcd(bisInspParam.getAddvcd()));
        if ("RSVR".equals(type)) {
            return getRsvrList(bisInspParam);
        } else if ("CWS".equals(type)) {
            return getCwsList(bisInspParam);
        } else if ("WTDST".equals(type)) {
            return getWtdstList(bisInspParam);
        } else if ("groundwater".equals(type)) {
            return getGrwList(bisInspParam);
        } else if ("empwt".equalsIgnoreCase(type)) {
            return getEmpwtprjList(bisInspParam);
        } else if ("sluice".equalsIgnoreCase(type)) {  //水闸
            return getWagaList(bisInspParam);
        } else if ("wain".equalsIgnoreCase(type)) {  //取水口
            return getWainList(bisInspParam);
        } else if ("stbprp".equalsIgnoreCase(type)) {  //水文站
            return getStbprpList(bisInspParam);
        } else if ("swhs".equalsIgnoreCase(type)) {  //地表水水源地
            return getSwhsList(bisInspParam);
        } else if ("sd".equalsIgnoreCase(type)) {//淤地坝
            return getSdList(bisInspParam);
        } else if ("keyswyhs".equalsIgnoreCase(type)) { //重点水源地
            return getSwhsList(bisInspParam);
        } else if ("wiu".equalsIgnoreCase(type)) {
            return getWiuList(bisInspParam);
        } else if ("city".equalsIgnoreCase(type)) {
            return getCityList(bisInspParam);
        } else if ("svwt".equalsIgnoreCase(type)) {
            return getSvwtList(bisInspParam);
        } else if ("wunt".equalsIgnoreCase(type)) {
            return getWuntList(bisInspParam);
        } else if ("prd".equalsIgnoreCase(type)) {
            return getPrdtList(bisInspParam);
        } else if ("jsfl".equalsIgnoreCase(type)) {
            return getJsfltList(bisInspParam);
        } else if ("jswa".equalsIgnoreCase(type)) {
            return getJswatList(bisInspParam);
        } else if ("rsml".equalsIgnoreCase(type)) {
            bisInspParam.setObjType("22");
            return getRsvrList(bisInspParam);
        } else if ("cdep".equalsIgnoreCase(type)) {
            return getCdepList(bisInspParam);
        } else if ("grow".equalsIgnoreCase(type)) {
            return getGrowList(bisInspParam);
        } else {
            return null;
        }
    }

    private List<BisInspBaseDto> getJswatList(BisInspParam bisInspParam) {
        return this.bisInspBaseDao.getJswatList(bisInspParam);
    }

    private List<BisInspBaseDto> getCdepList(BisInspParam bisInspParam) {
        return this.bisInspBaseDao.getCdepList(bisInspParam);
    }

    private List<BisInspBaseDto> getGrowList(BisInspParam bisInspParam) {
        return this.bisInspBaseDao.getGrowList(bisInspParam);
    }

    private List<BisInspBaseDto> getJsfltList(BisInspParam bisInspParam) {

        return this.bisInspBaseDao.getJsfltList(bisInspParam);
    }

    private List<BisInspBaseDto> getPrdtList(BisInspParam bisInspParam) {

        return this.bisInspBaseDao.getPrdList(bisInspParam);
    }


    private List<BisInspBaseDto> getWuntList(BisInspParam bisInspParam) {
        return this.bisInspBaseDao.getWuntList(bisInspParam);
    }

    private List<BisInspBaseDto> getSvwtList(BisInspParam bisInspParam) {
        return this.bisInspBaseDao.getSvwtList(bisInspParam);
    }

    private List<BisInspBaseDto> getCityList(BisInspParam bisInspParam) {
        return this.bisInspBaseDao.getCityList(bisInspParam);
    }

    private List<BisInspBaseDto> getWiuList(BisInspParam bisInspParam) {
        return this.bisInspBaseDao.getWiuList(bisInspParam);
    }

    @Override
    public AttEngDto getBaseListTop3(BisInspParam bisInspParam) {
        AttEngDto attEngDto = new AttEngDto();
        attEngDto.setRsvrList(getRsvrListTop3(bisInspParam));//水库
        attEngDto.setCwsList(getCwsListTop3(bisInspParam));//农饮
        attEngDto.setVill2020List(getVill2020ListTop3(bisInspParam));//新人饮
        attEngDto.setWtdstList(getWtdstListTop3(bisInspParam));//水毁
        attEngDto.setAdXList(getAdXListTop3(bisInspParam));//村
        attEngDto.setWsList(getWsListTop3(bisInspParam));//水源地
        attEngDto.setEmpwtConList(getEmpwtConListTop3(bisInspParam));//172工程建设
        attEngDto.setEmpwtRunList(getEmpwtRunListTop3(bisInspParam));//172工程运行
        attEngDto.setGrwList(getGrwListTop3(bisInspParam));//地下水
        attEngDto.setWagaList(getWagaListTop3(bisInspParam));//水闸
        attEngDto.setWainList(getWainListTop3(bisInspParam));//取水口
        attEngDto.setStbprpList(getStbprpListTop3(bisInspParam));//水位站
        attEngDto.setSwhsList(getSwhsListTop3(bisInspParam));//地表水源地
        attEngDto.setSdList(getSdListTop3(bisInspParam));
        attEngDto.setWiuList(getWiuListTop3(bisInspParam));
        attEngDto.setSapList(getSapListTop3(bisInspParam));
        bisInspParam.setNote("new");
        attEngDto.setKeySwhsList(getSwhsListTop3(bisInspParam));
        attEngDto.setCityList(getCityListTop3(bisInspParam));
        attEngDto.setSvwtList(getSvwtListTop3(bisInspParam));
        attEngDto.setWuntList(getWuntListTop3(bisInspParam));
        attEngDto.setWintLicList(getWintLicListTop3(bisInspParam));
        attEngDto.setPrdList(getPrdListTop3(bisInspParam));
        attEngDto.setJsflList(getJsflListTop3(bisInspParam));
        attEngDto.setJswaList(getJswaListTop3(bisInspParam));
        attEngDto.setCdepList(getCdepListTop3(bisInspParam));//乙级单位检测
        attEngDto.setGrowList(getGrowListTop3(bisInspParam));//地下水压采
        return attEngDto;
    }

    private List<BisInspBaseDto> getJswaListTop3(BisInspParam bisInspParam) {

        return this.bisInspBaseDao.getJswaListTop3(bisInspParam);
    }

    private List<BisInspBaseDto> getJsflListTop3(BisInspParam bisInspParam) {

        return this.bisInspBaseDao.getJsflListTop3(bisInspParam);
    }

    private List<BisInspBaseDto> getPrdListTop3(BisInspParam bisInspParam) {
        return this.bisInspBaseDao.getPrdListTop3(bisInspParam);
    }

    private List<BisInspBaseDto> getWintLicListTop3(BisInspParam bisInspParam) {

        return this.bisInspBaseDao.getWintLicListTop3(bisInspParam);
    }

    private List<BisInspBaseDto> getWuntListTop3(BisInspParam bisInspParam) {
        return this.bisInspBaseDao.getWuntListTop3(bisInspParam);
    }

    private List<BisInspBaseDto> getSvwtListTop3(BisInspParam bisInspParam) {
        return this.bisInspBaseDao.getSvwtListTop3(bisInspParam);
    }

    private List<BisInspBaseDto> getCityListTop3(BisInspParam bisInspParam) {
        return this.bisInspBaseDao.getCityListTop3(bisInspParam);
    }

    private List<BisInspBaseDto> getWiuListTop3(BisInspParam bisInspParam) {
        return this.bisInspBaseDao.getWiuListTop3(bisInspParam);
    }

    private List<BisInspBaseDto> getSapListTop3(BisInspParam bisInspParam) {
        return this.bisInspBaseDao.getSapListTop3(bisInspParam);
    }

    private List<BisInspBaseDto> getSdListTop3(BisInspParam bisInspParam) {
        return this.bisInspBaseDao.getSdListTop3(bisInspParam);
    }

    private List<BisInspBaseDto> getSwhsListTop3(BisInspParam bisInspParam) {
        return this.bisInspBaseDao.getSwhsListTop3(bisInspParam);
    }

    private List<BisInspBaseDto> getStbprpListTop3(BisInspParam bisInspParam) {
        return this.bisInspBaseDao.getStbprpListTop3(bisInspParam);
    }

    private List<BisInspBaseDto> getWainListTop3(BisInspParam bisInspParam) {
        return this.bisInspBaseDao.getWainListTop3(bisInspParam);
    }

    private List<BisInspBaseDto> getWagaListTop3(BisInspParam bisInspParam) {
        return this.bisInspBaseDao.getWagaListTop3(bisInspParam);
    }

    private List<BisInspBaseDto> getCdepListTop3(BisInspParam bisInspParam) {
        return this.bisInspBaseDao.getCdepListTop3(bisInspParam);
    }

    private List<BisInspBaseDto> getGrowListTop3(BisInspParam bisInspParam) {
        return this.bisInspBaseDao.getGrowListTop3(bisInspParam);
    }

    private List<BisInspBaseDto> getGrwListTop3(BisInspParam bisInspParam) {
        return this.bisInspBaseDao.getGrwListTop3(bisInspParam);
    }

    private List<BisInspBaseDto> getEmpwtConListTop3(BisInspParam bisInspParam) {
        return this.bisInspBaseDao.getEmpwtConListTop3(bisInspParam);
    }

    private List<BisInspBaseDto> getEmpwtRunListTop3(BisInspParam bisInspParam) {
        return this.bisInspBaseDao.getEmpwtRunListTop3(bisInspParam);
    }

    private List<BisInspBaseDto> getWsListTop3(BisInspParam bisInspParam) {
        return this.bisInspBaseDao.getWsListTop3(bisInspParam);
    }

    private List<BisInspBaseDto> getAdXListTop3(BisInspParam bisInspParam) {
        return this.bisInspBaseDao.getAdXListTop3(bisInspParam);
    }

    @Override
    public AttRsBaseDto getRsvrByCode(String code, String province) {

        return bisInspBaseDao.getRsvrByCode(code, province);
    }

    @Override
    public AttPrdCstrProjBase getPrdByCode(String code) {
        return bisInspBaseDao.getPrdByCode(code);
    }

    @Override
    public AttJskejianFlkdisBase getJSFLByCode(String code) {
        return bisInspBaseDao.getJSFLByCode(code);
    }

    @Override
    public AttJskejianWaterBase getJswaByCode(String code) {
        return bisInspBaseDao.getJswaByCode(code);
    }

    @Override
    public PageInfo getPagePrdList(BisInspParam bisInspParam) {
        bisInspParam.setAddvcd(AdLevelUtil.getAddvcd(bisInspParam.getAddvcd()));
        PageHelper.startPage(bisInspParam.getPageNum(), bisInspParam.getPageSize());
        List<BisInspBaseDto> bisInspBaseDtos = getPrdtList(bisInspParam);
        PageInfo page = new PageInfo<>(bisInspBaseDtos);
        return page;
    }

    @Override
    public PageInfo getPageJsflList(BisInspParam bisInspParam) {
        bisInspParam.setAddvcd(AdLevelUtil.getAddvcd(bisInspParam.getAddvcd()));
        PageHelper.startPage(bisInspParam.getPageNum(), bisInspParam.getPageSize());
        List<BisInspBaseDto> bisInspBaseDtos = getJsfltList(bisInspParam);
        PageInfo page = new PageInfo<>(bisInspBaseDtos);
        return page;
    }

    @Override
    public PageInfo getPageJswaList(BisInspParam bisInspParam) {
        bisInspParam.setAddvcd(AdLevelUtil.getAddvcd(bisInspParam.getAddvcd()));
        PageHelper.startPage(bisInspParam.getPageNum(), bisInspParam.getPageSize());
        List<BisInspBaseDto> bisInspBaseDtos = getJswatList(bisInspParam);
        PageInfo page = new PageInfo<>(bisInspBaseDtos);
        return page;
    }

    @Override
    public AttScnsrBaseDto getScnsrByCode(String code) {
        return bisInspBaseDao.getScnsrByCode(code);
    }

    @Override
    public AttEngCwsDto getCwsByCode(String code) {
        return bisInspBaseDao.getCwsByCode(code);
    }

    @Override
    public BisInspWtdstDto getWtdstByCode(String code) {
        return bisInspBaseDao.getWtdstByCode(code);
    }

    @Override
    public List<BisInspPlanDto> getInspPlan(String userid, String province) {
        List<BisInspPlanDto> bisInspPlanDtos = bisInspBaseDao.getInspPlanCount(userid, province);
        boolean isGly = false;
        for (BisInspPlanDto bisInspPlanDto : bisInspPlanDtos) {
            if (bisInspPlanDto.getPlnaId().length() <= 3) {
                isGly = true;
            }
        }
        List<BisInspPlanDto> result = new ArrayList<>();
        if (isGly) {
            result.addAll(bisInspBaseDao.getInspGlPlan(userid, province));
        } else {
            result.addAll(bisInspBaseDao.getInspPlan(userid, province));
        }

        TacWorkerBParam param = new TacWorkerBParam();
        param.setLoginId(userid);
        if (workerBDao.findList(param).size() > 0) {
            //根据id查询
            String persType = rlationPersDao.get(userid).getPersType();
            TacInspYearBatchGroupParam groupParam = new TacInspYearBatchGroupParam();
            if (!"1".equals(persType)) {
                groupParam.setPersId(userid);
            }
            List<TacInspYearBatchGroup> groupList = groupDao.getGroupListApp(groupParam);
            if (groupList.size() > 0) {
                groupList.forEach(group -> {
                    TacInspYearBatchAreaParam areaParam = new TacInspYearBatchAreaParam();
                    areaParam.setGroupId(group.getId());
                    List<TacInspYearBatchArea> areaList = tacInspYearBatchAreaDao.findList(areaParam);
                    BisInspPlanDto dto = new BisInspPlanDto();
                    dto.setPlnaId(group.getId());
                    dto.setPrsnTitle(group.getGroupNm().toString());
                    dto.setPtype("8");
                    if (areaList.size() > 0) {
                        StringBuffer area = new StringBuffer("");
                        areaList.forEach(tacInspYearBatchArea -> {
                            area.append(tacInspYearBatchArea.getAdName()).append(",");
                        });
                        if (area.indexOf(",") > 0) {
                            dto.setPrsnTitle(area.substring(0, area.length() - 1));
                        }
                    }
                    result.add(dto);
                });
            }
        }
        return result;
    }

    @Override
    public List<BisInspGroupPersonDto> getGroupPerson(String groupID, String persName, String province) {
        return bisInspBaseDao.getGroupPerson(groupID, persName, province);
    }

    @Override
    public List<BisInspGroupPersonDto> getGroupPersonV2(String groupID, String persName, String orgId) {
        return bisInspBaseDao.getGroupPersonV2(groupID, persName, orgId);
    }

    @Override
    public List<BisInspGroupInfoDto> getPersonGroup(String userid) {
        return bisInspBaseDao.getPersonGroup(userid);
    }

    @Override
    public List<BisInspGroupInfoDto> getGroupByPersId(String persid, String province) {
        return bisInspBaseDao.getGroupByPersId(persid, province);
    }

    @Override
    public List<BisInspBaseDto> getListRsvrList(BisInspParam bisInspParam) {
        bisInspParam.setAddvcd(AdLevelUtil.getAddvcd(bisInspParam.getAddvcd()));
        List<BisInspBaseDto> bisInspBaseDtos = getRsvrList(bisInspParam);
        return bisInspBaseDtos;
    }

    @Override
    public List getListCwsList(BisInspParam bisInspParam) {
        bisInspParam.setAddvcd(AdLevelUtil.getAddvcd(bisInspParam.getAddvcd()));
        List<BisInspBaseDto> bisInspBaseDtos = getCwsList(bisInspParam);
        return bisInspBaseDtos;
    }

    @Override
    public int exchangeCoordinate(String type) {
        int i = 0;
        if ("ATT_RS_BASE".equals(type)) {
            List<AttRsBase> attRsBaseList = this.bisInspBaseDao.exchangeCoordinate();
            if (attRsBaseList.size() > 0) {
                for (AttRsBase attRsBase : attRsBaseList) {
                    if (attRsBase.getCenterX() != null && attRsBase.getCenterY() != null) {
                        Map<String, Double> map = GeoUtil.wgs84togcj02(Double.parseDouble(attRsBase.getCenterX()), Double.parseDouble(attRsBase.getCenterY()));
                        i += this.bisInspBaseDao.updateCoordinate(attRsBase.getRsCode(), map.get("lon"), map.get("lat"));
                    }
                }
            }
        }
        if ("ATT_AD_X_BASE".equals(type)) {
            List<AttRsBase> attRsBaseList = this.bisInspBaseDao.exchangeCoordinate();
            if (attRsBaseList.size() > 0) {
                for (AttRsBase attRsBase : attRsBaseList) {
                    if (attRsBase.getCenterX() != null && attRsBase.getCenterY() != null) {
                        Map<String, Double> map = GeoUtil.wgs84togcj02(Double.parseDouble(attRsBase.getCenterX()), Double.parseDouble(attRsBase.getCenterY()));
                        i += this.bisInspBaseDao.updateCoordinate(attRsBase.getRsCode(), map.get("lon"), map.get("lat"));
                    }
                }
            }
        }
        if ("BIS_INSP_WTDST".equals(type)) {
            List<AttRsBase> bisInspBases = this.bisInspBaseDao.exchangeWtdstCoordinate();
            if (bisInspBases.size() > 0) {
                for (AttRsBase attRsBase : bisInspBases) {
                    if (attRsBase.getCenterX() != null && attRsBase.getCenterY() != null) {
                        Map<String, Double> map = GeoUtil.wgs84togcj02(Double.parseDouble(attRsBase.getCenterX()), Double.parseDouble(attRsBase.getCenterY()));
                        i += this.bisInspBaseDao.updateWtdstCoordinate(attRsBase.getRsCode(), map.get("lon"), map.get("lat"));
                    }
                }
            }
        }
        if ("ATT_CWS_BASE".equals(type)) {
            List<AttRsBase> bisInspBases = this.bisInspBaseDao.exchangeCwsCoordinate();
            if (bisInspBases.size() > 0) {
                int j = 0;
                DecimalFormat df = new DecimalFormat("0.0000000000");
                for (AttRsBase attRsBase : bisInspBases) {
                    if (attRsBase.getCenterX() != null && attRsBase.getCenterY() != null) {
                        j++;
                        Map<String, Double> map = GeoUtil.wgs84togcj02(Double.parseDouble(attRsBase.getCenterX()), Double.parseDouble(attRsBase.getCenterY()));
                        try {
                            this.bisInspBaseDao.updateCwsCoordinate(attRsBase.getRsCode(), Double.parseDouble(df.format(map.get("lon"))), Double.parseDouble(df.format(map.get("lat"))));
                        } catch (Exception e) {
                            continue;
                        }
                    }
                }
            }
        }
        if ("ATT_GRW_BASE".equals(type)) {
            List<AttRsBase> bisInspBases = this.bisInspBaseDao.exchangeGrwCoordinate();
            if (bisInspBases.size() > 0) {
                int j = 0;
                DecimalFormat df = new DecimalFormat("0.0000000000");
                for (AttRsBase attRsBase : bisInspBases) {
                    if (attRsBase.getCenterX() != null && attRsBase.getCenterY() != null) {
                        j++;
                        Map<String, Double> map = GeoUtil.wgs84togcj02(Double.parseDouble(attRsBase.getCenterX()), Double.parseDouble(attRsBase.getCenterY()));
                        try {
                            this.bisInspBaseDao.updateGrwCoordinate(attRsBase.getRsCode(), Double.parseDouble(df.format(map.get("lon"))), Double.parseDouble(df.format(map.get("lat"))));
                        } catch (Exception e) {
                            continue;
                        }
                    }
                }
            }
        }
        if ("ATT_WAGA_BASE".equals(type)) {
            List<AttRsBase> bisInspBases = this.bisInspBaseDao.exchangeWagaCoordinate();
            if (bisInspBases.size() > 0) {
                int j = 0;
                DecimalFormat df = new DecimalFormat("0.0000000000");
                for (AttRsBase attRsBase : bisInspBases) {
                    if (attRsBase.getCenterX() != null && attRsBase.getCenterY() != null) {
                        j++;
                        Map<String, Double> map = GeoUtil.wgs84togcj02(Double.parseDouble(attRsBase.getCenterX()), Double.parseDouble(attRsBase.getCenterY()));
                        try {
                            this.bisInspBaseDao.updateWagaCoordinate(attRsBase.getRsCode(), Double.parseDouble(df.format(map.get("lon"))), Double.parseDouble(df.format(map.get("lat"))));
                        } catch (Exception e) {
                            continue;
                        }
                    }
                }
            }
        }
        if ("ATT_WAIN_BASE".equals(type)) {
            List<AttRsBase> bisInspBases = this.bisInspBaseDao.exchangeWainCoordinate();
            if (bisInspBases.size() > 0) {
                int j = 0;
                DecimalFormat df = new DecimalFormat("0.0000000000");
                for (AttRsBase attRsBase : bisInspBases) {
                    if (attRsBase.getCenterX() != null && attRsBase.getCenterY() != null) {
                        j++;
                        Map<String, Double> map = GeoUtil.wgs84togcj02(Double.parseDouble(attRsBase.getCenterX()), Double.parseDouble(attRsBase.getCenterY()));
                        try {
                            this.bisInspBaseDao.updateWainCoordinate(attRsBase.getRsCode(), Double.parseDouble(df.format(map.get("lon"))), Double.parseDouble(df.format(map.get("lat"))));
                        } catch (Exception e) {
                            continue;
                        }
                    }
                }
            }
        }
        if ("ST_STBPRP_B".equals(type)) {
            List<AttRsBase> bisInspBases = this.bisInspBaseDao.exchangeStbprpCoordinate();
            if (bisInspBases.size() > 0) {
                int j = 0;
                DecimalFormat df = new DecimalFormat("0.0000000000");
                for (AttRsBase attRsBase : bisInspBases) {
                    if (attRsBase.getCenterX() != null && attRsBase.getCenterY() != null) {
                        j++;
                        Map<String, Double> map = GeoUtil.wgs84togcj02(Double.parseDouble(attRsBase.getCenterX()), Double.parseDouble(attRsBase.getCenterY()));
                        try {
                            this.bisInspBaseDao.updateStbprpCoordinate(attRsBase.getRsCode(), Double.parseDouble(df.format(map.get("lon"))), Double.parseDouble(df.format(map.get("lat"))));
                        } catch (Exception e) {
                            continue;
                        }
                    }
                }
            }
        }
        if ("ATT_SWHS_BASE".equals(type)) {
            List<AttRsBase> bisInspBases = this.bisInspBaseDao.exchangeSwhsCoordinate();
            if (bisInspBases.size() > 0) {
                int j = 0;
                DecimalFormat df = new DecimalFormat("0.0000000000");
                for (AttRsBase attRsBase : bisInspBases) {
                    if (attRsBase.getCenterX() != null && attRsBase.getCenterY() != null) {
                        j++;
                        Map<String, Double> map = GeoUtil.wgs84togcj02(Double.parseDouble(attRsBase.getCenterX()), Double.parseDouble(attRsBase.getCenterY()));
                        try {
                            this.bisInspBaseDao.updateSwhsCoordinate(attRsBase.getRsCode(), Double.parseDouble(df.format(map.get("lon"))), Double.parseDouble(df.format(map.get("lat"))));
                        } catch (Exception e) {
                            continue;
                        }
                    }
                }
            }
        }
        if ("ATT_WAGA_BASE.AD_CODE".equals(type)) {
            List<AttRsBase> bisInspBases = this.bisInspBaseDao.getWagaAdName();
            if (bisInspBases.size() > 0) {
                int j = 0;
                for (AttRsBase attRsBase : bisInspBases) {
                    j++;
                    AttRsBase ar = this.bisInspBaseDao.getAdCode(attRsBase.getAdFullName());
                    this.bisInspBaseDao.updateWagaAdCode(attRsBase.getRsCode(), ar.getAdmDiv());
                }
            }
        }
        return 1;
    }

    @Override
    public WrWsB getWrWsByCode(String code) {
        WrWsB wrWsB = new WrWsB();
        wrWsB = this.bisInspBaseDao.getWrGwsByCode(code);//查询地下水源地表
        if (wrWsB == null) {//如果查询结果为空，再查询地表水源地
            wrWsB = this.bisInspBaseDao.getWrSwsByCode(code);
        }
        return wrWsB;
    }

    @Override
    public PageInfo getPageWrWsList(BisInspParam bisInspParam) {
        PageHelper.startPage(bisInspParam.getPageNum(), bisInspParam.getPageSize());
        List<WrWsB> bisInspBaseDtos = getWrWsList(bisInspParam);
        PageInfo page = new PageInfo<>(bisInspBaseDtos);
        return page;
    }

    @Override
    public List<WrWsB> getWrWsList(BisInspParam bisInspParam) {
        Map<String, Object> map = AdLevelUtil.SubAd(bisInspParam.getAddvcd());
        bisInspParam.setAddvcd(map.get(SplitValue.SUBAD).toString());
        return this.bisInspBaseDao.getWrWsList(bisInspParam);
    }

    @Override
    public List<AttAdXBase> getAdXList(BisInspParam bisInspParam) {
        bisInspParam.setAddvcd(AdLevelUtil.getAddvcd(bisInspParam.getAddvcd()));
        return this.bisInspBaseDao.getAdXList(bisInspParam);
    }

    @Override
    public PageInfo getPageAdXList(BisInspParam bisInspParam) {
        bisInspParam.setAddvcd(AdLevelUtil.getAddvcd(bisInspParam.getAddvcd()));
        PageHelper.startPage(bisInspParam.getPageNum(), bisInspParam.getPageSize());
        List<AttAdXBase> bisInspBaseDtos = getAdXList(bisInspParam);
        PageInfo page = new PageInfo<>(bisInspBaseDtos);
        return page;
    }

    @Override
    public AttAdXBase getAdXByCode(String code) {
        return this.bisInspBaseDao.getAdXByCode(code);
    }

    @Override
    public List<ProCount> getProCountByType() {
        return this.bisInspBaseDao.getProCountByType();
    }

    @Override
    public List<ProCount> getSchCountByType() {
        List<ProCount> proCountList = new ArrayList<>();
        ProCount p1 = this.bisInspBaseDao.getSchCountByRs();
        ProCount p2 = this.bisInspBaseDao.getSchCountByVill();
        ProCount p3 = this.bisInspBaseDao.getSchCountByWtd();
        if (p1 != null) {
            proCountList.add(p1);
        }
        if (p2 != null) {
            proCountList.add(p2);
        }
        if (p3 != null) {
            proCountList.add(p3);
        }
        return proCountList;
    }

    @Override
    public List<ProAdCount> getProCountByAd() {
        return this.bisInspBaseDao.getProCountByAd();
    }

    @Override
    public List<AdXBaseDto> getAdXBaseList(BisInspParam bisInspParam) {
        bisInspParam.setAddvcd(AdLevelUtil.getAddvcd(bisInspParam.getAddvcd()));
        return this.bisInspBaseDao.getAdXBaseList(bisInspParam);
    }

    @Override
    public List<BisInspAll> getInspByPersid(String persid) {
        return this.bisInspBaseDao.getInspByPersid(persid);
    }

    @Override
    public List<BisInspAll> getInspByPid(String pid) {
        return this.bisInspBaseDao.getInspByPid(pid);
    }


    @Override
    public List<BisInspBaseDto> getRsvrList(BisInspParam bisInspParam) {
        if (StringUtils.isNotBlank(bisInspParam.getEngScal()) && (bisInspParam.getEngScal().contains("4") ||
                bisInspParam.getEngScal().contains("5"))) {
            bisInspParam.setType("RSVR");
        }
        return bisInspBaseDao.getRsvrList(bisInspParam);
    }

    public List<BisInspBaseDto> getGrwList(BisInspParam bisInspParam) {
        return bisInspBaseDao.getGrwList(bisInspParam);
    }

    public List<BisInspBaseDto> getWagaList(BisInspParam bisInspParam) {
        return bisInspBaseDao.getWagaList(bisInspParam);
    }

    public List<BisInspBaseDto> getWainList(BisInspParam bisInspParam) {
        return bisInspBaseDao.getWainList(bisInspParam);
    }

    public List<BisInspBaseDto> getStbprpList(BisInspParam bisInspParam) {
        return bisInspBaseDao.getStbprpList(bisInspParam);
    }

    public List<BisInspBaseDto> getSwhsList(BisInspParam bisInspParam) {
        return bisInspBaseDao.getSwhsList(bisInspParam);
    }

    public List<BisInspBaseDto> getEmpwtprjList(BisInspParam bisInspParam) {
        return bisInspBaseDao.getEmpwtprjList(bisInspParam);
    }

    @Override
    public List<BisInspBaseDto> getSdList(BisInspParam bisInspParam) {
        return bisInspBaseDao.getSdList(bisInspParam);
    }

    @Override
    public List<BisInspBaseDto> getCwsList(BisInspParam bisInspParam) {
        return bisInspBaseDao.getCwsList(bisInspParam);
    }

    @Override
    public List<BisInspBaseDto> getWtdstList(BisInspParam bisInspParam) {
        return bisInspBaseDao.getWtdstList(bisInspParam);
    }


    public List<BisInspBaseDto> getRsvrListTop3(BisInspParam bisInspParam) {
        return bisInspBaseDao.getRsvrListTop3(bisInspParam);
    }

    public List<BisInspBaseDto> getCwsListTop3(BisInspParam bisInspParam) {
        return bisInspBaseDao.getCwsListTop3(bisInspParam);
    }

    public List<BisInspBaseDto> getWtdstListTop3(BisInspParam bisInspParam) {
        return bisInspBaseDao.getWtdstListTop3(bisInspParam);
    }

    @Override
    public AllObjDto findAllObj(FindAllObjDto findAllObjDto) {
        AllObjDto allObjDto = new AllObjDto();
        allObjDto.setAttPersBaseList(this.findAllPers(findAllObjDto));
        allObjDto.setAttPersRsList(this.findAllRs(findAllObjDto));
        allObjDto.setAttPersWtdstList(this.findAllWtdst(findAllObjDto));
        allObjDto.setAttCwsBaseList(this.findAllCws(findAllObjDto));
        allObjDto.setAttGrwBaseList(this.findAllGrw(findAllObjDto));
        allObjDto.setAttEmpwtprjBasePageInfo(this.findAllEmpwtprj(findAllObjDto));
        return allObjDto;
    }

    @Override
    public AttGrwBase getGroundWaterByCode(String code) {
        return this.bisInspBaseDao.getGroundWaterByCode(code);
    }

    @Override
    public AttEmpwtprjBase getEmpwtprjListByCode(String code) {
        return attEmpwtprjBaseService.get(code);
    }

    @Override
    public AttWagaBase getSluiceByCode(String code) {
        return this.bisInspBaseDao.getSluiceByCode(code);
    }

    @Autowired
    private BisInspAllDao bisInspAllDao;

    @Override
    public List<BisInspAll> findAreas() {
        return bisInspAllDao.findAreas();
    }

    @Override
    public List<BisInspAll> getGroupByPidAndPersid(String pid, String persid, String province) {
        return this.bisInspBaseDao.getGroupByPidAndPersid(pid, persid, province);
    }

    @Override
    public List<BisInspPlanDto> getByPersid(String userid, String pid, String province, String tabType, String orgId) {
        List<BisInspPlanDto> resultList = new ArrayList<>();
        List<BisInspPlanDto> clearRepeatList = new ArrayList<>();
        String nowTime = new SimpleDateFormat("yyyy-MM-dd").format(new Date());
        Map<String, Object> map = new HashedMap();
        if ("0".equals(pid)) {//获取类型
            List<BisInspPlanDto> list = this.bisInspBaseDao.getPersType(userid, province, tabType, nowTime);
            TacInspYearBatchGroupPersParam persParam = new TacInspYearBatchGroupPersParam();
            persParam.setPersId(userid);
            persParam.setProvince(province);
            List<?> groupPersList = groupPersDao.findPersList(persParam);
            Map<String, BisInspPlanDto> resultMap = list.stream().collect(Collectors.toMap(BisInspPlanDto::getPtype, Function.identity()));
            if (groupPersList.size() > 0) {
                if (!resultMap.containsKey(BisInspEnum.PAWP.getValue())) {
                    BisInspPlanDto dto = new BisInspPlanDto();
                    dto.setPlnaId(BisInspEnum.PAWP.getRlation());
                    dto.setPtype(BisInspEnum.PAWP.getValue());
                    dto.setPrsnTitle("稽察工作");
                    resultMap.put(BisInspEnum.PAWP.getValue(), dto);
                    List<BisInspPlanDto> result = new ArrayList<>(resultMap.values());
                    Collections.sort(result, new Comparator<BisInspPlanDto>() {
                        @Override
                        public int compare(BisInspPlanDto o1, BisInspPlanDto o2) {
                            return o1.getPtype().compareTo(o2.getPtype());
                        }
                    });
                    return result;
                }
            } else {
                if (resultMap.containsKey(BisInspEnum.PAWP.getValue())) {
                    list.remove(resultMap.get(BisInspEnum.PAWP.getValue()));
                }
            }
            return list;
        } else {
            if (pid.startsWith(BisInspEnum.PAWP.getRlation())) {
                TacInspYearBatchGroupPersParam param = new TacInspYearBatchGroupPersParam();
                String persType = rlationPersDao.get(userid).getPersType();
                param.setProvince(province);
                if (!"1".equals(persType)) {
                    param.setPersId(userid);
                }
                if (pid.length() == 3) {
                    //查询年度
                    List<BisInspPlanDto> list = groupPersDao.getYearList(param);
                    return list;
                }
                if (pid.length() == 7) {
                    param.setYear(Long.valueOf(pid.substring(3)));
                    List<BisInspPlanDto> list = groupPersDao.getBatchList(param);
                    return list;
                }
                if (pid.length() >= 8) {
                    TacInspYearBatchGroupParam groupParam = new TacInspYearBatchGroupParam();
                    if (!"1".equals(persType)) {
                        groupParam.setPersId(userid);
                    }
                    String year = pid.substring(3, 7);
                    String batch = pid.substring(7);
                    groupParam.setYear(Long.valueOf(year));
                    groupParam.setBatch(Long.valueOf(batch));
                    groupParam.setProvince(province);
                    List<BisInspPlanDto> list = new ArrayList<>();
                    List<TacInspYearBatchGroup> groupList = groupDao.getGroupListApp(groupParam);
                    if (groupList.size() > 0) {
                        SimpleDateFormat df = new SimpleDateFormat("yyyy-MM-dd");
                        groupList.forEach(group -> {
                            TacInspYearBatchAreaParam areaParam = new TacInspYearBatchAreaParam();
                            areaParam.setGroupId(group.getId());
                            areaParam.setProvince(province);
                            List<TacInspYearBatchArea> areaList = tacInspYearBatchAreaDao.findList(areaParam);
                            BisInspPlanDto dto = new BisInspPlanDto();
                            dto.setPlnaId(group.getId());
                            dto.setPrsnTitle(group.getGroupNm().toString());
                            dto.setPtype("8");

                            dto.setSttm(group.getStTm() != null ? df.format(group.getStTm()) : "");
                            dto.setEntm(group.getEnTm() != null ? df.format(group.getEnTm()) : "");
                            if (areaList.size() > 0) {
                                StringBuffer area = new StringBuffer("");
                                areaList.forEach(tacInspYearBatchArea -> {
                                    area.append(tacInspYearBatchArea.getAdName()).append(",");
                                });
                                if (area.indexOf(",") > 0) {
                                    dto.setPrsnTitle(area.substring(0, area.length() - 1));
                                }
                                list.add(dto);
                            }

                        });
                    }
                    return list;
                }
            }
            List<BisInspPlanDto> bisInspPlanDtoList = this.bisInspBaseDao.getAllNodeByPersid(userid, pid, province, tabType, nowTime, orgId);//001,001041
            if (bisInspPlanDtoList.size() > 0) {
                for (BisInspPlanDto bis : bisInspPlanDtoList) {
                    if (pid.length() == 3) {//如果查机构
                        if (bis.getPlnaId().length() == 3) {//取到类型时  查询下级
                            List<BisInspPlanDto> list = this.bisInspBaseDao.getDept(bis.getPlnaId(), pid, 6, province, tabType, nowTime);
                            resultList.addAll(list);
                        } else if (bis.getPlnaId().length() == 6) {//取到机构时候，直接放到结果集
                            if (pid.substring(0, 3).equals(bis.getPlnaId().substring(0, 3))) {
                                resultList.add(bis);
                            }
                        } else if (bis.getPlnaId().length() == 9) {//取到批次或者组时候，向上查询
                            List<BisInspPlanDto> list = this.bisInspBaseDao.getDeptByGroup(userid, pid, province, tabType, nowTime);
                            resultList.addAll(list);
                        } else if (bis.getPlnaId().length() == 12) {//取到批次或者组时候，向上查询
                            List<BisInspPlanDto> list = this.bisInspBaseDao.getDeptByGroup(userid, pid, province, tabType, nowTime);
                            resultList.addAll(list);
                        }
                    }
                    if (pid.length() == 6) {//如果查批次001041,001
                        if (bis.getPlnaId().length() == 3) {//取到类型时  查询所有批次
                            List<BisInspPlanDto> list = this.bisInspBaseDao.getDept(bis.getPlnaId(), pid, 9, province, tabType, nowTime);
                            resultList.addAll(list);
                        } else if (bis.getPlnaId().length() == 6) {//取到机构时候，查询下级008041
                            List<BisInspPlanDto> list = this.bisInspBaseDao.getDept(bis.getPlnaId(), pid, 9, province, tabType, nowTime);
                            resultList.addAll(list);
                        } else if (bis.getPlnaId().length() == 9) {//取到批次的时候，直接放入结果集
                            if (pid.substring(0, 6).equals(bis.getPlnaId().substring(0, 6))) {
                                resultList.add(bis);
                            }
                        } else if (bis.getPlnaId().length() == 12) {//取到组时候，向上查询
                            List<BisInspPlanDto> list = this.bisInspBaseDao.getBatchByGroup(userid, pid, province, tabType, nowTime);
                            resultList.addAll(list);
                        }
                    }
                    if (pid.length() == 9) {//如果查组
                        if (bis.getPlnaId().length() == 3) {//取到类型时  查询所有组
                            List<BisInspPlanDto> list = this.bisInspBaseDao.getDept(bis.getPlnaId(), pid, 12, province, tabType, nowTime);
                            resultList.addAll(list);
                        } else if (bis.getPlnaId().length() == 6) {//取到机构时候，查询下级
                            List<BisInspPlanDto> list = this.bisInspBaseDao.getDept(bis.getPlnaId(), pid, 12, province, tabType, nowTime);
                            resultList.addAll(list);
                        } else if (bis.getPlnaId().length() == 9) {//取到批次的时候，查询下级
                            List<BisInspPlanDto> list = this.bisInspBaseDao.getDept(bis.getPlnaId(), pid, 12, province, tabType, nowTime);
                            resultList.addAll(list);
                        } else if (bis.getPlnaId().length() == 12) {//取到组时候，放入结果集
                            if (pid.substring(0, 9).equals(bis.getPlnaId().substring(0, 9))) {
                                resultList.add(bis);
                            }
                        }
                    }
                }
                //去重
                for (BisInspPlanDto b : resultList) {
                    map.put(b.getPlnaId(), b);
                }
                for (Map.Entry<String, Object> entry : map.entrySet()) {
                    clearRepeatList.add((BisInspPlanDto) entry.getValue());
                }
                if (clearRepeatList.size() > 0 && pid.length() == 9) {//组按id排序
                    Collections.sort(clearRepeatList, new Comparator<BisInspPlanDto>() {
                        @Override
                        public int compare(BisInspPlanDto o1, BisInspPlanDto o2) {
                            return o2.getPlnaId().compareTo(o1.getPlnaId());
                        }
                    });
                }
                if (clearRepeatList.size() > 0 && pid.length() == 6) {//查月份升序
                    Collections.sort(clearRepeatList, new Comparator<BisInspPlanDto>() {
                        @Override
                        public int compare(BisInspPlanDto o1, BisInspPlanDto o2) {
                            return o1.getPlnaId().compareTo(o2.getPlnaId());
                        }
                    });
                }

                if (pid.length() == 3 && clearRepeatList.size() > 0) {//机构排序
                    Collections.sort(clearRepeatList, new Comparator<BisInspPlanDto>() {
                        @Override
                        public int compare(BisInspPlanDto o1, BisInspPlanDto o2) {
                            //督查办排在第一位
                            if (o2.getPrsnTitle().indexOf("督查办") > -1) {
                                return 1;
                            }
                            return o1.getPlnaId().compareTo(o2.getPlnaId());
                        }
                    });
                }
            }
        }
        return clearRepeatList;
    }

    @Override
    public BisInspPlanDto getByPlanDto(String userid, String pid, String province, String tabType) {
//        获取当前时间判断是否属于月份分组中，若没有月份分组，则提示请新建月份分组，如有相应组则直接返回月份分组。
        String nowTime = new SimpleDateFormat("yyyy-MM-dd").format(new Date());
        List<BisInspPlanDto> bisInspPlanDtos = this.bisInspBaseDao.getByPlanDto(userid, pid, province, nowTime);//001,001041
        for (BisInspPlanDto bisInspPlanDto : bisInspPlanDtos) {
            if (bisInspPlanDto.getPlnaId().length() == 12) {
                return bisInspPlanDto;
            }
        }
        return null;
    }

    @Override
    public void changeAdCode(String province) {
        List<AttGrwBase> attGrwBaseList = this.bisInspBaseDao.getAllGrw(province);
        if (attGrwBaseList.size() > 0) {
            int i = 0;
            for (AttGrwBase attGrwBase : attGrwBaseList) {
                if (attGrwBase != null) {
                    i++;
                    String geocode = AMapUtil.geocode(attGrwBase.getStlc());
                    com.alibaba.fastjson.JSONObject jsStr = com.alibaba.fastjson.JSONObject.parseObject(geocode);
                    List geocodes = (List) jsStr.get("geocodes");
                    if (geocodes.size() > 0) {
                        Object o = geocodes.get(0);
                        JSONObject json = JSONObject.fromObject(o);
                        String district = json.getString("formatted_address");
                        String adcode = json.getString("adcode");
                        if (district.length() > 2) {
                            this.bisInspBaseDao.updateCodeAndName(district, adcode + "000000", attGrwBase.getStcd());
                        } else {
                            this.bisInspBaseDao.updateCode(adcode + "000000", attGrwBase.getStcd());
                            System.out.println(i);
                        }
                    }
                }
            }
        }
    }

    @Override
    public PageInfo getPageEmpwtList(BisInspParam bisInspParam) {
        if (StringUtils.isNotBlank(bisInspParam.getAddvcd())) {
            Map<String, Object> map = AdLevelUtil.SubAd(bisInspParam.getAddvcd());
            bisInspParam.setAddvcd(map.get(SplitValue.SUBAD).toString());
        }
        PageHelper.startPage(bisInspParam.getPageNum(), bisInspParam.getPageSize());
        List<BisInspBaseDto> empwtprjList = bisInspBaseDao.getEmpwtprjList(bisInspParam);
        PageInfo page = new PageInfo<>(empwtprjList);
        return page;
    }

    @Override
    public PageInfo getPageGrwList(BisInspParam bisInspParam) {
        if (StringUtils.isNotBlank(bisInspParam.getAddvcd())) {
            Map<String, Object> map = AdLevelUtil.SubAd(bisInspParam.getAddvcd());
            bisInspParam.setAddvcd(map.get(SplitValue.SUBAD).toString());
        }
        PageHelper.startPage(bisInspParam.getPageNum(), bisInspParam.getPageSize());
        List<BisInspBaseDto> grwList = bisInspBaseDao.getGrwList(bisInspParam);
        PageInfo page = new PageInfo<>(grwList);
        return page;
    }

    @Override
    public PageInfo getPageWagaList(BisInspParam bisInspParam) {
        if (StringUtils.isNotBlank(bisInspParam.getAddvcd())) {
            Map<String, Object> map = AdLevelUtil.SubAd(bisInspParam.getAddvcd());
            bisInspParam.setAddvcd(map.get(SplitValue.SUBAD).toString());
        }
        PageHelper.startPage(bisInspParam.getPageNum(), bisInspParam.getPageSize());
        List<BisInspBaseDto> wagaList = bisInspBaseDao.getWagaList(bisInspParam);
        PageInfo page = new PageInfo<>(wagaList);
        return page;
    }

    @Override
    public PageInfo getPageCdepList(BisInspParam bisInspParam) {
        if (StringUtils.isNotBlank(bisInspParam.getAddvcd())) {
            Map<String, Object> map = AdLevelUtil.SubAd(bisInspParam.getAddvcd());
            bisInspParam.setAddvcd(map.get(SplitValue.SUBAD).toString());
        }
        PageHelper.startPage(bisInspParam.getPageNum(), bisInspParam.getPageSize());
        List<BisInspBaseDto> wagaList = bisInspBaseDao.getCdepList(bisInspParam);
        PageInfo page = new PageInfo<>(wagaList);
        return page;
    }

    @Override
    public PageInfo getPageGrowList(BisInspParam bisInspParam) {
        if (StringUtils.isNotBlank(bisInspParam.getAddvcd())) {
            Map<String, Object> map = AdLevelUtil.SubAd(bisInspParam.getAddvcd());
            bisInspParam.setAddvcd(map.get(SplitValue.SUBAD).toString());
        }
        PageHelper.startPage(bisInspParam.getPageNum(), bisInspParam.getPageSize());
        List<BisInspBaseDto> wagaList = bisInspBaseDao.getGrowList(bisInspParam);
        PageInfo page = new PageInfo<>(wagaList);
        return page;
    }

    @Override
    public List<BisInspGroupPersonDto> getGroupPersonByPersId(String persid, String persName, String province) {
        return this.bisInspBaseDao.getGroupPersonByPersId(persid, persName, province);
    }

    @Override
    public PageInfo getPageWainList(BisInspParam bisInspParam) {
        bisInspParam.setAddvcd(AdLevelUtil.getAddvcd(bisInspParam.getAddvcd()));
        PageHelper.startPage(bisInspParam.getPageNum(), bisInspParam.getPageSize());
        List<BisInspBaseDto> bisInspBaseDtos = getWainList(bisInspParam);
        PageInfo page = new PageInfo<>(bisInspBaseDtos);
        return page;
    }

    @Override
    public PageInfo getPageWintList(BisInspParam bisInspParam) {
        bisInspParam.setAddvcd(AdLevelUtil.getAddvcd(bisInspParam.getAddvcd()));
        PageHelper.startPage(bisInspParam.getPageNum(), bisInspParam.getPageSize());
        List<BisInspBaseDto> bisInspBaseDtos = getWintLicList(bisInspParam);
        PageInfo page = new PageInfo<>(bisInspBaseDtos);
        return page;
    }

    private List<BisInspBaseDto> getWintLicList(BisInspParam bisInspParam) {
        return bisInspBaseDao.getWintLicList(bisInspParam);
    }

    @Override
    public PageInfo getPageStbprpList(BisInspParam bisInspParam) {
        bisInspParam.setAddvcd(AdLevelUtil.getAddvcd(bisInspParam.getAddvcd()));
        PageHelper.startPage(bisInspParam.getPageNum(), bisInspParam.getPageSize());
        List<BisInspBaseDto> bisInspBaseDtos = getStbprpList(bisInspParam);
        PageInfo page = new PageInfo<>(bisInspBaseDtos);
        return page;
    }

    @Override
    public PageInfo getPageSwhsList(BisInspParam bisInspParam) {
        bisInspParam.setAddvcd(AdLevelUtil.getAddvcd(bisInspParam.getAddvcd()));
        PageHelper.startPage(bisInspParam.getPageNum(), bisInspParam.getPageSize());
        List<BisInspBaseDto> bisInspBaseDtos = getSwhsList(bisInspParam);
        PageInfo page = new PageInfo<>(bisInspBaseDtos);
        return page;
    }

    @Override
    public PageInfo<BisInspBaseDto> getPageSdList(BisInspParam bisInspParam) {
        bisInspParam.setAddvcd(AdLevelUtil.getAddvcd(bisInspParam.getAddvcd()));
        PageHelper.startPage(bisInspParam.getPageNum(), bisInspParam.getPageSize());
        List<BisInspBaseDto> list = getSdList(bisInspParam);
        PageInfo<BisInspBaseDto> pageInfo = new PageInfo<>(list);
        return pageInfo;
    }

    @Override
    public PageInfo<BisInspBaseDto> getPageWiuList(BisInspParam bisInspParam) {
        bisInspParam.setAddvcd(AdLevelUtil.getAddvcd(bisInspParam.getAddvcd()));
        PageHelper.startPage(bisInspParam.getPageNum(), bisInspParam.getPageSize());
        List<BisInspBaseDto> list = getWiuList(bisInspParam);
        PageInfo<BisInspBaseDto> pageInfo = new PageInfo<>(list);
        return pageInfo;
    }

    @Override
    public PageInfo getPageWuntList(BisInspParam bisInspParam) {
        bisInspParam.setAddvcd(AdLevelUtil.getAddvcd(bisInspParam.getAddvcd()));
        PageHelper.startPage(bisInspParam.getPageNum(), bisInspParam.getPageSize());
        List<BisInspBaseDto> bisInspBaseDtos = getWuntList(bisInspParam);
        PageInfo page = new PageInfo<>(bisInspBaseDtos);
        return page;
    }

    @Override
    public PageInfo getPageSvwtList(BisInspParam bisInspParam) {
        bisInspParam.setAddvcd(AdLevelUtil.getAddvcd(bisInspParam.getAddvcd()));
        PageHelper.startPage(bisInspParam.getPageNum(), bisInspParam.getPageSize());
        List<BisInspBaseDto> bisInspBaseDtos = getSvwtList(bisInspParam);
        PageInfo page = new PageInfo<>(bisInspBaseDtos);
        return page;
    }

    //农饮工程
    public PageInfo<AttCwsBase> findAllCws(FindAllObjDto findAllObjDto) {
        PageHelper.startPage(findAllObjDto.getPageNum(), findAllObjDto.getPageSize());
        List<AttCwsBase> list = bisInspBaseDao.findAllCws(findAllObjDto);
        PageInfo page = new PageInfo<>(list);
        return page;
    }

    //农饮工程
    public PageInfo<AttGrwBase> findAllGrw(FindAllObjDto findAllObjDto) {
        PageHelper.startPage(findAllObjDto.getPageNum(), findAllObjDto.getPageSize());
        List<AttGrwBase> list = bisInspBaseDao.findAllGrw(findAllObjDto);
        PageInfo page = new PageInfo<>(list);
        return page;
    }

    //172重点水利工程
    public PageInfo<AttEmpwtprjBase> findAllEmpwtprj(FindAllObjDto findAllObjDto) {
        PageHelper.startPage(findAllObjDto.getPageNum(), findAllObjDto.getPageSize());
        List<AttEmpwtprjBase> list = bisInspBaseDao.findAllEmpwtprj(findAllObjDto);
        PageInfo page = new PageInfo<>(list);
        return page;
    }


    //水库
    public PageInfo<AttRsBase> findAllRs(FindAllObjDto findAllObjDto) {
        PageHelper.startPage(findAllObjDto.getPageNum(), findAllObjDto.getPageSize());
        List<AttRsBase> list = bisInspBaseDao.findAllRs(findAllObjDto);
        PageInfo page = new PageInfo<>(list);
        return page;
    }

    //人员
    public PageInfo<AttPersBase> findAllPers(FindAllObjDto findAllObjDto) {
        PageHelper.startPage(findAllObjDto.getPageNum(), findAllObjDto.getPageSize());
        List<AttPersBase> list = bisInspBaseDao.findAllPers(findAllObjDto);
        PageInfo page = new PageInfo<>(list);
        return page;
    }


    //水毁
    public PageInfo<BisInspWtdst> findAllWtdst(FindAllObjDto findAllObjDto) {
        PageHelper.startPage(findAllObjDto.getPageNum(), findAllObjDto.getPageSize());
        List<BisInspWtdst> list = bisInspBaseDao.findAllWtdst(findAllObjDto);
        PageInfo page = new PageInfo<>(list);
        return page;
    }


    @Override
    public PageInfo<BisInspBaseDto> getPageCityList(BisInspParam bisInspParam) {
        bisInspParam.setAddvcd(AdLevelUtil.getAddvcd(bisInspParam.getAddvcd()));
        PageHelper.startPage(bisInspParam.getPageNum(), bisInspParam.getPageSize());
        List<BisInspBaseDto> list = getCityList(bisInspParam);
        PageInfo<BisInspBaseDto> pageInfo = new PageInfo<>(list);
        return pageInfo;
    }

    @Override
    public int updateBaseInfoName(String fromName, String toName, String type) {
        if (StringUtils.isBlank(fromName) || StringUtils.isBlank(toName)) {
            return 0;
        }
        if (BisInspEnum.PAWP.getValue().equals(type)) {
            TacAttPawpBaseParam baseParam = new TacAttPawpBaseParam();
            baseParam.setName(fromName);
            List<TacAttPawpBase> baseList = tacAttPawpBaseDao.findList(baseParam);
            if (baseList.size() >= 0) {
                baseList.forEach(tacAttPawpBase -> {
                    if (fromName.equalsIgnoreCase(tacAttPawpBase.getName())) {
                        tacAttPawpBase.setName(toName);
                        tacAttPawpBaseDao.update(tacAttPawpBase);
                    }
                });
            }
            TacInspYearBatchObjParam objParam = new TacInspYearBatchObjParam();
            objParam.setOjbNm(fromName);
            List<TacInspYearBatchObj> objList = tacInspYearBatchObjDao.findList(objParam);
            if (objList.size() > 0) {
                objList.forEach(tacInspYearBatchObj -> {
                    tacInspYearBatchObj.setOjbNm(toName);
                    tacInspYearBatchObjDao.update(tacInspYearBatchObj);
                });
            }
            TacPawpRgstrParam rgstrParam = new TacPawpRgstrParam();
            rgstrParam.setName(fromName);
            List<TacPawpRgstr> rgstrList = tacPawpRgstrDao.findList(rgstrParam);
            if (rgstrList.size() > 0) {
                rgstrList.forEach(tacPawpRgstr -> {
                    if (fromName.equalsIgnoreCase(tacPawpRgstr.getName())) {
                        tacPawpRgstr.setName(toName);
                        tacPawpRgstrDao.update(tacPawpRgstr);
                    }
                });
            }
        }
        return 0;
    }

    private List<BisInspBaseDto> getVill2020ListTop3(BisInspParam bisInspParam) {
        return this.bisInspBaseDao.getVill2020ListTop3(bisInspParam);
    }

    @Override
    public PageInfo<BisInspBaseDto> getPageVill2020List(BisInspParam bisInspParam) {
        if (StringUtils.isNotBlank(bisInspParam.getAddvcd())) {
            bisInspParam.setAddvcd(AdLevelUtil.getAddvcd(bisInspParam.getAddvcd()));
        }
        PageHelper.startPage(bisInspParam.getPageNum(), bisInspParam.getPageSize());
        List<BisInspBaseDto> list = getVill2020List(bisInspParam);
        PageInfo<BisInspBaseDto> pageInfo = new PageInfo<>(list);
        return pageInfo;
    }


    private List<BisInspBaseDto> getVill2020List(BisInspParam bisInspParam) {

        return bisInspBaseDao.getVill2020List(bisInspParam);
    }


    @Override
    public List<BisInspPlanDto> getCurrGroup(String orgId, String userid, String pid) {
        List<BisInspPlanDto> resultList = new ArrayList<>();
        if (StringUtils.isBlank(pid)) {
            TacInspYearBatchGroupParam groupPersParam = new TacInspYearBatchGroupParam();
            groupPersParam.setPersId(userid);
            groupPersParam.setUseCurrTm("1");
            List<TacInspYearBatchGroup> groupList = tacInspYearBatchGroupDao.getCurrentGroupList(groupPersParam);
            if (groupList.size() > 0) {
                SimpleDateFormat sfd = new SimpleDateFormat("yyyy-MM-dd");
                groupList.forEach(group -> {
                    TacInspYearBatchAreaParam areaParam = new TacInspYearBatchAreaParam();
                    areaParam.setGroupId(group.getId());
                    List<TacInspYearBatchArea> areaList = tacInspYearBatchAreaDao.findList(areaParam);
                    BisInspPlanDto dto = new BisInspPlanDto();
                    dto.setPlnaId(group.getId());
                    dto.setPrsnTitle(group.getGroupNm().toString());
                    dto.setSttm(sfd.format(group.getStTm()));
                    dto.setEntm(sfd.format(group.getEnTm()));
                    dto.setPtype("8");
                    if (areaList.size() > 0) {
                        StringBuffer area = new StringBuffer("");
                        areaList.forEach(tacInspYearBatchArea -> area.append(tacInspYearBatchArea.getAdName()).append(","));
                        if (area.indexOf(",") > 0) {
                            dto.setPrsnTitle(area.substring(0, area.length() - 1));
                        }
                    }
                    resultList.add(dto);
                });
            }

            String[] groupIds = bisInspAllRlationDao.getIdByPersid(Builder
                    .of(BisInspAllRlationParam::new)
                    .with(BisInspAllRlationParam::setPersid, userid)
                    .with(BisInspAllRlationParam::setId, "%" + orgId + "%")
                    .build());

            resultList.addAll(bisInspBaseDao.getNowGroupById(groupIds));
            return resultList;
        }
        switch (pid) {
            case "0":
                return getTacInspYearBatchGroup1(userid);
            case "008":
                return getTacInspYearBatchGroup2(userid);
            default:
                if (pid.length() == 3) {
                    pid += orgId;
                }

                String[] groupIds = bisInspAllRlationDao.getIdByPersid(Builder
                        .of(BisInspAllRlationParam::new)
                        .with(BisInspAllRlationParam::setPersid, userid)
                        .with(BisInspAllRlationParam::setId, pid)
                        .build());

                if (groupIds != null && groupIds.length > 0) {
                    return this.bisInspBaseDao.getNowGroupById(groupIds);
                }
                return new ArrayList<>();
        }
    }

    private List<BisInspPlanDto> getTacInspYearBatchGroup1(String userid) {
        // 获取类型
        List<BisInspPlanDto> list = this.bisInspBaseDao.getCurrPersType(userid);
        TacInspYearBatchGroupParam groupPersParam = new TacInspYearBatchGroupParam();
        groupPersParam.setPersId(userid);
        groupPersParam.setUseCurrTm("1");
        List<TacInspYearBatchGroup> groupList = tacInspYearBatchGroupDao.getCurrentGroupList(groupPersParam);
        Map<String, BisInspPlanDto> resultMap = list.stream().collect(Collectors.toMap(BisInspPlanDto::getPtype, Function.identity()));
        if (groupList.size() > 0) {
            if (!resultMap.containsKey(BisInspEnum.PAWP.getValue())) {
                BisInspPlanDto dto = new BisInspPlanDto();
                dto.setPlnaId(BisInspEnum.PAWP.getRlation());
                dto.setPtype(BisInspEnum.PAWP.getValue());
                dto.setPrsnTitle("稽察工作");
                resultMap.put(BisInspEnum.PAWP.getValue(), dto);
                List<BisInspPlanDto> result = new ArrayList<>(resultMap.values());
                result.sort(Comparator.comparing(BisInspPlanDto::getPtype));
                return result;
            }
        } else {
            if (resultMap.containsKey(BisInspEnum.PAWP.getValue())) {
                list.remove(resultMap.get(BisInspEnum.PAWP.getValue()));
            }
        }
        return list;
    }

    private List<BisInspPlanDto> getTacInspYearBatchGroup2(String userid) {
        List<BisInspPlanDto> resultList = new ArrayList<>();
        //返回稽察组
        TacInspYearBatchGroupParam groupPersParam = new TacInspYearBatchGroupParam();
        groupPersParam.setPersId(userid);
        groupPersParam.setUseCurrTm("1");
        List<TacInspYearBatchGroup> groupList = tacInspYearBatchGroupDao.getCurrentGroupList(groupPersParam);
        if (groupList.size() > 0) {
            SimpleDateFormat sfd = new SimpleDateFormat("yyyy-MM-dd");
            groupList.forEach(group -> {
                TacInspYearBatchAreaParam areaParam = new TacInspYearBatchAreaParam();
                areaParam.setGroupId(group.getId());
                List<TacInspYearBatchArea> areaList = tacInspYearBatchAreaDao.findList(areaParam);
                BisInspPlanDto dto = new BisInspPlanDto();
                dto.setPlnaId(group.getId());
                dto.setPrsnTitle(group.getGroupNm().toString());
                dto.setSttm(sfd.format(group.getStTm()));
                dto.setEntm(sfd.format(group.getEnTm()));
                dto.setPtype("8");
                if (areaList.size() > 0) {
                    StringBuffer area = new StringBuffer("");
                    areaList.forEach(tacInspYearBatchArea -> {
                        area.append(tacInspYearBatchArea.getAdName()).append(",");
                    });
                    if (area.indexOf(",") > 0) {
                        dto.setPrsnTitle(area.substring(0, area.length() - 1));
                    }
                }
                resultList.add(dto);
            });
        }
        return resultList;
    }
}