| 1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495969798991001011021031041051061071081091101111121131141151161171181191201211221231241251261271281291301311321331341351361371381391401411421431441451461471481491501511521531541551561571581591601611621631641651661671681691701711721731741751761771781791801811821831841851861871881891901911921931941951961971981992002012022032042052062072082092102112122132142152162172182192202212222232242252262272282292302312322332342352362372382392402412422432442452462472482492502512522532542552562572582592602612622632642652662672682692702712722732742752762772782792802812822832842852862872882892902912922932942952962972982993003013023033043053063073083093103113123133143153163173183193203213223233243253263273283293303313323333343353363373383393403413423433443453463473483493503513523533543553563573583593603613623633643653663673683693703713723733743753763773783793803813823833843853863873883893903913923933943953963973983994004014024034044054064074084094104114124134144154164174184194204214224234244254264274284294304314324334344354364374384394404414424434444454464474484494504514524534544554564574584594604614624634644654664674684694704714724734744754764774784794804814824834844854864874884894904914924934944954964974984995005015025035045055065075085095105115125135145155165175185195205215225235245255265275285295305315325335345355365375385395405415425435445455465475485495505515525535545555565575585595605615625635645655665675685695705715725735745755765775785795805815825835845855865875885895905915925935945955965975985996006016026036046056066076086096106116126136146156166176186196206216226236246256266276286296306316326336346356366376386396406416426436446456466476486496506516526536546556566576586596606616626636646656666676686696706716726736746756766776786796806816826836846856866876886896906916926936946956966976986997007017027037047057067077087097107117127137147157167177187197207217227237247257267277287297307317327337347357367377387397407417427437447457467477487497507517527537547557567577587597607617627637647657667677687697707717727737747757767777787797807817827837847857867877887897907917927937947957967977987998008018028038048058068078088098108118128138148158168178188198208218228238248258268278288298308318328338348358368378388398408418428438448458468478488498508518528538548558568578588598608618628638648658668678688698708718728738748758768778788798808818828838848858868878888898908918928938948958968978988999009019029039049059069079089099109119129139149159169179189199209219229239249259269279289299309319329339349359369379389399409419429439449459469479489499509519529539549559569579589599609619629639649659669679689699709719729739749759769779789799809819829839849859869879889899909919929939949959969979989991000100110021003100410051006100710081009101010111012101310141015101610171018101910201021102210231024102510261027102810291030103110321033103410351036103710381039104010411042104310441045104610471048104910501051105210531054105510561057105810591060106110621063106410651066106710681069107010711072107310741075107610771078107910801081108210831084108510861087108810891090109110921093109410951096109710981099110011011102110311041105110611071108110911101111111211131114111511161117111811191120112111221123112411251126112711281129 |
- package cn.com.goldenwater.dcproj.service.impl.ducha;
- import cn.com.goldenwater.core.service.AbstractCrudService;
- import cn.com.goldenwater.dcproj.constValue.AdCodeLabel;
- import cn.com.goldenwater.dcproj.constValue.BisInspEnum;
- import cn.com.goldenwater.dcproj.constValue.BisInspObjEnum;
- import cn.com.goldenwater.dcproj.constValue.SplitValue;
- import cn.com.goldenwater.dcproj.dao.*;
- import cn.com.goldenwater.dcproj.dto.AttCwsBaseDto;
- import cn.com.goldenwater.dcproj.dto.AttWagaSapBaseDto;
- import cn.com.goldenwater.dcproj.dto.BisInspAllObjDto;
- import cn.com.goldenwater.dcproj.dto.BisInspFscRgstrDto;
- import cn.com.goldenwater.dcproj.dto.BisInspKeyRegisterDto;
- import cn.com.goldenwater.dcproj.dto.BisInspObjDto;
- import cn.com.goldenwater.dcproj.dto.BisInspOtherRgstrDto;
- import cn.com.goldenwater.dcproj.dto.BisInspRgstrDto;
- import cn.com.goldenwater.dcproj.dto.BisInspSdRgstrDto;
- import cn.com.goldenwater.dcproj.dto.BisInspWiuRgstrDto;
- import cn.com.goldenwater.dcproj.dto.BisNewWateruserInfoDto;
- import cn.com.goldenwater.dcproj.dto.ObjectNameDto;
- import cn.com.goldenwater.dcproj.dto.ProSourceProtectDto;
- import cn.com.goldenwater.dcproj.dto.SecsurveyVlgDto;
- import cn.com.goldenwater.dcproj.dto.VillRgstrEngIdDto;
- import cn.com.goldenwater.dcproj.model.AttAdBase;
- import cn.com.goldenwater.dcproj.model.AttAdXBase;
- import cn.com.goldenwater.dcproj.model.AttEfpBase;
- import cn.com.goldenwater.dcproj.model.AttEmpwtprjBase;
- import cn.com.goldenwater.dcproj.model.AttFscBase;
- import cn.com.goldenwater.dcproj.model.AttGrwBase;
- import cn.com.goldenwater.dcproj.model.AttIrrBase;
- import cn.com.goldenwater.dcproj.model.AttJskejianEcofrdRgstr;
- import cn.com.goldenwater.dcproj.model.AttJskejianFlkdisBase;
- import cn.com.goldenwater.dcproj.model.AttJskejianFlkdisRgstr;
- import cn.com.goldenwater.dcproj.model.AttJskejianWaterBase;
- import cn.com.goldenwater.dcproj.model.AttJskejianWaterRgstr;
- import cn.com.goldenwater.dcproj.model.AttOtherBase;
- import cn.com.goldenwater.dcproj.model.AttPersGrw;
- import cn.com.goldenwater.dcproj.model.AttPersRs;
- import cn.com.goldenwater.dcproj.model.AttPersWtdst;
- import cn.com.goldenwater.dcproj.model.AttPkxBase;
- import cn.com.goldenwater.dcproj.model.AttPrdCstrProjBase;
- import cn.com.goldenwater.dcproj.model.AttRsBase;
- import cn.com.goldenwater.dcproj.model.AttSdBase;
- import cn.com.goldenwater.dcproj.model.AttSwhsBase;
- import cn.com.goldenwater.dcproj.model.AttWagaBase;
- import cn.com.goldenwater.dcproj.model.AttWagaSapBase;
- import cn.com.goldenwater.dcproj.model.AttWainBase;
- import cn.com.goldenwater.dcproj.model.AttWiuBase;
- import cn.com.goldenwater.dcproj.model.AttWuntBase;
- import cn.com.goldenwater.dcproj.model.BisInspAllObj;
- import cn.com.goldenwater.dcproj.model.BisInspObj;
- import cn.com.goldenwater.dcproj.model.BisInspOprdCstrProjRgstr;
- import cn.com.goldenwater.dcproj.model.BisInspRsmlRgstr;
- import cn.com.goldenwater.dcproj.model.BisInspSvwtAreaRgstr;
- import cn.com.goldenwater.dcproj.model.BisInspSvwtWuntRgstr;
- import cn.com.goldenwater.dcproj.model.BisInspSwhsRgstr;
- import cn.com.goldenwater.dcproj.model.BisInspVillRgstr;
- import cn.com.goldenwater.dcproj.model.BisInspWagaRgstrDto;
- import cn.com.goldenwater.dcproj.model.BisInspWintRgstr;
- import cn.com.goldenwater.dcproj.model.BisInspWtdst;
- import cn.com.goldenwater.dcproj.model.GrwBaseByType;
- import cn.com.goldenwater.dcproj.model.StStbprpB;
- import cn.com.goldenwater.dcproj.model.TacAttPawpBase;
- import cn.com.goldenwater.dcproj.param.BisInspObjParam;
- import cn.com.goldenwater.dcproj.param.InGroupGrwParam;
- import cn.com.goldenwater.dcproj.param.InspObjParam;
- import cn.com.goldenwater.dcproj.param.PagePersObjParam;
- import cn.com.goldenwater.dcproj.param.PersObjParam;
- import cn.com.goldenwater.dcproj.param.TypeParam;
- import cn.com.goldenwater.dcproj.service.AttWagaRgstrService;
- import cn.com.goldenwater.dcproj.service.BisInspKeyRegisterService;
- import cn.com.goldenwater.dcproj.service.BisInspObjService;
- import cn.com.goldenwater.dcproj.service.BisInspObjStrategy;
- import cn.com.goldenwater.dcproj.service.BisInspVillRgstrService;
- import cn.com.goldenwater.dcproj.service.OlBisInspOrgService;
- import cn.com.goldenwater.dcproj.service.SupervisionPlanService;
- import cn.com.goldenwater.dcproj.service.impl.system.BisInspObjFactory;
- import cn.com.goldenwater.dcproj.utils.AdLevelUtil;
- import cn.com.goldenwater.id.util.UuidUtil;
- import cn.com.goldenwater.target.CheckException;
- import cn.com.goldenwater.util.common.SqlUtils;
- import com.github.pagehelper.PageHelper;
- import com.github.pagehelper.PageInfo;
- import org.apache.commons.lang3.StringUtils;
- import org.slf4j.Logger;
- import org.slf4j.LoggerFactory;
- import org.springframework.beans.BeanUtils;
- import org.springframework.beans.factory.annotation.Autowired;
- import org.springframework.stereotype.Service;
- import org.springframework.transaction.annotation.Transactional;
- import javax.servlet.http.HttpServletResponse;
- import java.text.SimpleDateFormat;
- import java.util.ArrayList;
- import java.util.Date;
- import java.util.HashMap;
- import java.util.List;
- import java.util.Map;
- import java.util.Optional;
- import java.util.UUID;
- import static cn.com.goldenwater.dcproj.utils.expExcel.ExportUtil.exportExcel;
- /**
- * @author lune
- * @date 2019-2-18
- */
- @Service
- @Transactional(rollbackFor = Exception.class)
- public class BisInspObjServiceImpl extends AbstractCrudService<BisInspObj, BisInspObjParam> implements BisInspObjService {
- private static Logger logger = LoggerFactory.getLogger(BisInspObjServiceImpl.class);
- @Autowired
- private AttJskejianFlkdisBaseDao jskejianFlkdisBaseDao;
- @Autowired
- private AttJskejianFlkdisRgstrDao jskejianFlkdisRgstrDao;
- @Autowired
- private AttJskejianWaterRgstrDao jskejianWaterRgstrDao;
- @Autowired
- private AttJskejianWaterBaseDao jskejianWaterBaseDao;
- @Autowired
- private AttJskejianEcofrdRgstrDao jskejianEcofrdRgstrDao;
- @Autowired
- private BisInspRsmlRgstrDao bisInspRsmlRgstrDao;
- @Autowired
- private BisInspObjDao bisInspObjDao;
- @Autowired
- private AttSdBaseDao sdBaseDao;
- @Autowired
- private BisInspAllObjDao bisInspAllObjDao;
- @Autowired
- private AttWainBaseDao attWainBaseDao;
- @Autowired
- private AttAdXBaseDao attAdXBaseDao;
- @Autowired
- private AttWiuBaseDao wiuBaseDao;
- @Autowired
- private AttRsBaseDao attRsBaseDao;
- @Autowired
- private AttSwhsBaseDao swhsBaseDao;
- //取水用户
- //水毁
- @Autowired
- private BisInspWtdstDao bisInspWtdstDao;
- //农饮
- @Autowired
- private AttAdBaseDao attAdBaseDao;
- //农饮登记
- @Autowired
- private BisInspVillRgstrDao bisInspVillRgstrDao;
- @Autowired
- private AttGrwBaseDao attGrwBaseDao;
- @Autowired
- private AttPkxBaseDao attPkxBaseDao;
- @Autowired
- private StStbprpBDao stStbprpBDao;
- @Autowired
- private AttEmpwtprjBaseDao attEmpwtprjBaseDao;
- @Autowired
- private AttWagaBaseDao attWagaBaseDao;
- @Autowired
- private BisInspKeyRegisterService bisInspKeyRegisterService;
- @Autowired
- private BisInspVillRgstrService bisInspVillRgstrService;
- @Autowired
- private SupervisionPlanService supervisionPlanService;
- @Autowired
- private AttWuntBaseDao wuntBaseDao;
- @Autowired
- private AttWagaRgstrService attWagaRgstrService;
- @Autowired
- private OlBisInspOrgService inspOrgService;
- @Autowired
- private BisInspFscRgstrDao bisInspFscRgstrDao;
- @Autowired
- private BisInspOtherRgstrDao bisInspOtherRgstrDao;
- @Autowired
- private AttOtherBaseDao attOtherBaseDao;
- @Autowired
- private BisInspSvwtAreaRgstrDao svwtAreaRgstrDao;
- @Autowired
- private BisInspSdRgstrDao inspSdRgstrDao;
- @Autowired
- private BisInspWiuRgstrDao inspWiuRgstrDao;
- @Autowired
- private BisInspSwhsRgstrDao inspSwhsRgstrDao;
- @Autowired
- private BisInspSvwtAreaRgstrDao inspSvwtAreaRgstrDao;
- @Autowired
- private BisInspSvwtWuntRgstrDao inspSvwtWuntRgstrDao;
- @Autowired
- private BisInspWintRgstrDao wintRgstrDao;
- @Autowired
- private BisInspOprdCstrProjRgstrDao oprdCstrProjRgstrDao;
- @Autowired
- private BisInspRsraqgRgstrDao bisInspRsraqgRgstrDao;
- @Autowired
- private BisZhejiangJgRgstrDao bisZhejiangJgRgstrDao;
- @Autowired
- private BisInspWtcrrRgstrDao bisInspWtcrrRgstrDao;
- @Autowired
- private AttFscBaseDao attFscBaseDao;
- @Autowired
- private BisInspObjFactory factory;
- @Autowired
- private BisInspStstnDao bisInspStstnDao;
- public BisInspObjServiceImpl(BisInspObjDao bisInspObjDao) {
- super(bisInspObjDao);
- this.bisInspObjDao = bisInspObjDao;
- }
- @Override
- public int deleteInspObj(BisInspObj bisInspObj) {
- supervisionPlanService.cleanObjDataByObjId(bisInspObj.getObjType(), bisInspObj.getObjId());
- return 1;
- }
- @Override
- public List getObjListByTypeAndAdCode(PagePersObjParam pagePersObjParam) {
- if ("1".equalsIgnoreCase(pagePersObjParam.getObjType()) || "36".equalsIgnoreCase(pagePersObjParam.getObjType()) || "24".equalsIgnoreCase(pagePersObjParam.getObjType())) {
- List<AttRsBase> result = attRsBaseDao.getListByInspGroupIdObjType(pagePersObjParam);
- return result;
- } else if ("2".equalsIgnoreCase(pagePersObjParam.getObjType()) || "25".equalsIgnoreCase(pagePersObjParam.getObjType())) {
- List<AttAdBase> result = attAdBaseDao.getListByInspGroupIdObjType(pagePersObjParam);
- return result;
- } else if ("3".equalsIgnoreCase(pagePersObjParam.getObjType())) {
- List<BisInspWtdst> result = bisInspWtdstDao.getListByInspGroupIdObjType(pagePersObjParam);
- return result;
- } else if ("5".equalsIgnoreCase(pagePersObjParam.getObjType())) {
- List<GrwBaseByType> result = attGrwBaseDao.getListByInspGroupIdObjType(pagePersObjParam);
- return result;
- } else if ("8".equalsIgnoreCase(pagePersObjParam.getObjType())) {
- List<TacAttPawpBase> result = bisInspAllObjDao.getListByInspGroupIdObjType(pagePersObjParam);
- return result;
- } else if ("6".equalsIgnoreCase(pagePersObjParam.getObjType())) {
- List<BisInspWagaRgstrDto> result = attWagaRgstrService.getListByInspGroupIdObjType(pagePersObjParam);
- return result;
- } else if ("4".equalsIgnoreCase(pagePersObjParam.getObjType())) {
- //水利工程建设
- List<BisInspKeyRegisterDto> result = bisInspKeyRegisterService.getListByInspGroupIdObjTypeBuild(pagePersObjParam);
- return result;
- } else if ("7".equalsIgnoreCase(pagePersObjParam.getObjType())) {
- List<BisInspKeyRegisterDto> result = bisInspKeyRegisterService.getListByInspGroupIdObjTypeRun(pagePersObjParam);
- return result;
- } else if ("9".equalsIgnoreCase(pagePersObjParam.getObjType())) {
- //特定飞检
- List<BisInspFscRgstrDto> result = bisInspFscRgstrDao.getListByInspGroupIdObjType(pagePersObjParam);
- return result;
- } else if ("10".equalsIgnoreCase(pagePersObjParam.getObjType())) {
- //其他检查
- List<BisInspOtherRgstrDto> result = bisInspOtherRgstrDao.getListByInspGroupIdObjType(pagePersObjParam);
- return result;
- } else if ("11".equalsIgnoreCase(pagePersObjParam.getObjType())) {
- //淤地坝
- List<BisInspSdRgstrDto> result = inspSdRgstrDao.getListByInspGroupIdObjType(pagePersObjParam);
- return result;
- } else if ("12".equalsIgnoreCase(pagePersObjParam.getObjType())) {
- //取用水户
- List<BisInspWiuRgstrDto> result = inspWiuRgstrDao.getListByInspGroupIdObjType(pagePersObjParam);
- return result;
- } else if ("13".equalsIgnoreCase(pagePersObjParam.getObjType())) {
- //水源地
- List<BisInspSwhsRgstr> result = inspSwhsRgstrDao.getListByInspGroupIdObjType(pagePersObjParam);
- return result;
- } else if ("14".equalsIgnoreCase(pagePersObjParam.getObjType())) {
- //县级行政区
- List<BisInspWintRgstr> result = wintRgstrDao.getListByInspGroupIdObjType(pagePersObjParam);
- return result;
- } else if ("15".equalsIgnoreCase(pagePersObjParam.getObjType())) {
- //节水管理与评价
- List<BisInspSvwtAreaRgstr> result = inspSvwtAreaRgstrDao.getListByInspGroupIdObjType(pagePersObjParam);
- return result;
- } else if ("16".equalsIgnoreCase(pagePersObjParam.getObjType())) {
- //用水单位
- List<BisInspSvwtWuntRgstr> result = inspSvwtWuntRgstrDao.getListByInspGroupIdObjType(pagePersObjParam);
- return result;
- } else if ("17".equalsIgnoreCase(pagePersObjParam.getObjType())) {
- //生产建设项目
- List<BisInspOprdCstrProjRgstr> result = oprdCstrProjRgstrDao.getListOprdByInspGroupIdObjType(pagePersObjParam);
- return result;
- } else if ("18".equalsIgnoreCase(pagePersObjParam.getObjType())) {
- //河湖四乱项目
- List<AttJskejianFlkdisRgstr> result = jskejianFlkdisRgstrDao.getListJSFLByInspGroupIdObjType(pagePersObjParam);
- return result;
- } else if ("19".equalsIgnoreCase(pagePersObjParam.getObjType())) {
- //非法采砂督查
- List<AttJskejianWaterRgstr> result = jskejianWaterRgstrDao.getListJSWAByInspGroupIdObjType(pagePersObjParam);
- return result;
- } else if ("20".equalsIgnoreCase(pagePersObjParam.getObjType())) {
- //中央环保督查
- List<AttJskejianEcofrdRgstr> result = jskejianEcofrdRgstrDao.getListEcofrdByInspGroupIdObjType(pagePersObjParam);
- return result;
- } else if (BisInspEnum.RSML.getValue().equals(pagePersObjParam.getObjType())) {
- List<BisInspRsmlRgstr> result = bisInspRsmlRgstrDao.getListRsmlByInspGroupIdObjType(pagePersObjParam);
- return result;
- } else if (BisInspEnum.RSRAQG.getValue().equals(pagePersObjParam.getObjType())) {
- //量化考核
- List<AttAdBase> result = bisInspRsraqgRgstrDao.getListRsraqByInspGroupIdObjType(pagePersObjParam);
- return result;
- } else if (BisInspEnum.IRR.getValue().equalsIgnoreCase(pagePersObjParam.getObjType())) {
- List<AttIrrBase> list = bisInspIrrRgstrDao.getListByInspGroupIdObjType(pagePersObjParam);
- return list;
- } else if (BisInspEnum.SAP.getValue().equalsIgnoreCase(pagePersObjParam.getObjType())) {
- List<AttWagaSapBase> list = bisInspWagaSapRgstrDao.getListByInspGroupIdObjType(pagePersObjParam);
- return list;
- } else if (BisInspEnum.EFP.getValue().equalsIgnoreCase(pagePersObjParam.getObjType())) {
- List<AttEfpBase> list = bisInspEfpRgstrDao.getListByInspGroupIdObjType(pagePersObjParam);
- return list;
- }
- return null;
- }
- @Autowired
- private BisInspIrrRgstrDao bisInspIrrRgstrDao;
- @Autowired
- private BisInspWagaSapRgstrDao bisInspWagaSapRgstrDao;
- @Autowired
- private BisInspEfpRgstrDao bisInspEfpRgstrDao;
- @Autowired
- private BisInspSvwtWuntRgstrDao bisInspSvwtWuntRgstrDao;
- @Autowired
- private BisInspSamrmpRgstrDao bisInspSamrmpRgstrDao;
- @Autowired
- private BisInspWrmRgstrDao bisInspWrmRgstrDao;
- @Autowired
- private BisInspWintuRgstrDao bisInspWintuRgstrDao;
- @Autowired
- private BisInspWtgtRgstrDao bisInspWtgtRgstrDao;
- @Autowired
- private BisInspWtgthRgstrDao bisInspWtgthRgstrDao;
- @Autowired
- private BisInspCdepRgstrDao bisInspCdepRgstrDao;
- @Autowired
- private BisInspBidRgstrDao bisInspBidRgstrDao;
- @Autowired
- private BisInspRlrwRgstrDao bisInspRlrwRgstrDao;
- @Autowired
- private BisInspGrowRgstrDao bisInspGrowRgstrDao;
- @Autowired
- private BisInspFundRgstrDao bisInspFundRgstrDao;
- @Autowired
- private BisInspDrdmpRgstrDao bisInspDrdmpRgstrDao;
- @Autowired
- private BisInspRsvrSdDao bisInspRsvrSdDao;
- @Autowired
- private BisInspHystpDao bisInspHystpDao;
- @Autowired
- private BisInspJspwiuDao bisInspJspwiuDao;
- @Autowired
- private BisInspJspwiu2024Dao bisInspJspwiu2024Dao;
- @Override
- public PageInfo getObjListByGroupIdAndType(PagePersObjParam pagePersObjParam) {
- //设置分页
- PageHelper.startPage(pagePersObjParam.getPageNum(), pagePersObjParam.getPageSize());
- List result = getListByInspGroupIdObjType(pagePersObjParam);
- return new PageInfo<>(result);
- }
- private List getListByInspGroupIdObjType(PagePersObjParam pagePersObjParam) {
- //根据type分流
- BisInspEnum bisInspEnum = BisInspEnum.getEnumByType(pagePersObjParam.getObjType());
- Optional.ofNullable(bisInspEnum).orElseThrow(() -> new CheckException("未找到与 objType:" + pagePersObjParam.getObjType() + " 相对应的督查项!"));
- switch (bisInspEnum) {
- case REVER:
- case REVER2:
- case STND:
- case RSFCO:
- case RSSFDR:
- case RSSFGD:
- case RSFCOQH:
- case RSVRYN:
- return attRsBaseDao.getListByInspGroupIdObjType(pagePersObjParam);
- case IRR:
- case VILL:
- case VILL2020:
- case VILL2021:
- case VILLZHEJIANG:
- case VILLQH:
- case VILLGD:
- case MFDP:
- case RDWSP:
- case WRWS:
- case WRWX:
- case MFDPQH:
- case SVWTQH:
- case XJVILL:
- return attAdBaseDao.getListByInspGroupIdObjType(pagePersObjParam);
- case TRACK:// 水毁
- return bisInspWtdstDao.getListByInspGroupIdObjType(pagePersObjParam);
- case GRW:
- return attGrwBaseDao.getListByInspGroupIdObjType(pagePersObjParam);
- case PAWP:
- return bisInspAllObjDao.getListByInspGroupIdObjType(pagePersObjParam);
- case WAGA:
- case WAGAJS:
- return attWagaRgstrService.getListByInspGroupIdObjType(pagePersObjParam);
- case EMPWT:
- case KEYSAFQH:
- case KEYCHKQH:
- //水利工程建设
- return bisInspKeyRegisterService.getListByInspGroupIdObjTypeBuild(pagePersObjParam);
- case EMPWTRUN:
- return bisInspKeyRegisterService.getListByInspGroupIdObjTypeRun(pagePersObjParam);
- case FSC:
- //特定飞检
- return bisInspFscRgstrDao.getListByInspGroupIdObjType(pagePersObjParam);
- case OTHER:
- //其他检查
- return bisInspOtherRgstrDao.getListByInspGroupIdObjType(pagePersObjParam);
- case SD:
- //淤地坝
- return inspSdRgstrDao.getListByInspGroupIdObjType(pagePersObjParam);
- case WIU:
- //取用水户
- return inspWiuRgstrDao.getListByInspGroupIdObjType(pagePersObjParam);
- case SWHS:
- //水源地
- return inspSwhsRgstrDao.getListByInspGroupIdObjType(pagePersObjParam);
- case CITY:
- //县级行政区
- return wintRgstrDao.getListByInspGroupIdObjType(pagePersObjParam);
- case SVWT:
- //节水管理与评价
- return inspSvwtAreaRgstrDao.getListByInspGroupIdObjType(pagePersObjParam);
- case WUNT:
- //用水单位
- return inspSvwtWuntRgstrDao.getListByInspGroupIdObjType(pagePersObjParam);
- case PRD:
- //水保工作核实
- return oprdCstrProjRgstrDao.getListOprdByInspGroupIdObjType(pagePersObjParam);
- case JSFL:
- //河湖四乱项目
- return jskejianFlkdisRgstrDao.getListJSFLByInspGroupIdObjType(pagePersObjParam);
- case JSWA:
- //非法采砂督查
- return jskejianWaterRgstrDao.getListJSWAByInspGroupIdObjType(pagePersObjParam);
- case ECOFRD:
- //中央环保督查
- return jskejianEcofrdRgstrDao.getListEcofrdByInspGroupIdObjType(pagePersObjParam);
- case RSML:
- case RSLKBK:
- return bisInspRsmlRgstrDao.getListRsmlByInspGroupIdObjType(pagePersObjParam);
- case RSRAQG:
- //量化考核
- return bisInspRsraqgRgstrDao.getListRsraqByInspGroupIdObjType(pagePersObjParam);
- case BIS_ZHEJIANG_JG_RGSTR:
- return bisZhejiangJgRgstrDao.getListByInspGroupIdObjType(pagePersObjParam);
- case SAP:
- return bisInspWagaSapRgstrDao.getListByInspGroupIdObjType(pagePersObjParam);
- case EFP:
- return bisInspEfpRgstrDao.getListByInspGroupIdObjType(pagePersObjParam);
- case WINTU:
- // 31.取用水督查
- return bisInspWintuRgstrDao.getListByInspGroupIdObjType(pagePersObjParam);
- case WRM:
- case WTGOV:
- case CHMCLS:
- case WRM2021:
- // 32.水资源
- return bisInspWrmRgstrDao.getListByInspGroupIdObjType(pagePersObjParam);
- case WTUNT:
- // 33.节约用水
- return bisInspSvwtWuntRgstrDao.getListByInspGroupIdObjType(pagePersObjParam);
- case SAMRMP:
- // 35.中小河流
- return bisInspSamrmpRgstrDao.getListByInspGroupIdObjType(pagePersObjParam);
- case WTCRR:
- // 54.节水载体复核表
- return bisInspWtcrrRgstrDao.getListByInspGroupIdObjType(pagePersObjParam);
- case WTGT:
- // 55.取水许可管理复核表
- return bisInspWtgtRgstrDao.getListByInspGroupIdObjType(pagePersObjParam);
- case WTGTH:
- // 57.取水许可管理复核表
- return bisInspWtgthRgstrDao.getListByInspGroupIdObjType(pagePersObjParam);
- case CDEP:
- // 62.乙级检测单位
- return bisInspCdepRgstrDao.getListByInspGroupIdObjType(pagePersObjParam);
- case BID:
- // 67.招投标
- return bisInspBidRgstrDao.getListByInspGroupIdObjType(pagePersObjParam);
- case RLRW:
- // 68.退地减水
- return bisInspRlrwRgstrDao.getListByInspGroupIdObjType(pagePersObjParam);
- case GROW:
- // 70.地下水压采
- return bisInspGrowRgstrDao.getListByInspGroupIdObjType(pagePersObjParam);
- case FUND:
- // 98.水利资金
- return bisInspFundRgstrDao.getListByInspGroupIdObjType(pagePersObjParam);
- case RSVRSD:
- return bisInspRsvrSdDao.getListByInspGroupIdObjType(pagePersObjParam);
- case HYSTP:
- return bisInspHystpDao.getListByInspGroupIdObjType(pagePersObjParam);
- // 120 江苏计划用水户及取水口督查
- case JSPWIU:
- return bisInspJspwiuDao.getListByInspGroupIdObjType(pagePersObjParam);
- // 126 江苏取用水户督查
- case JSPWIU2024:
- return bisInspJspwiu2024Dao.getListByInspGroupIdObjType(pagePersObjParam);
- default:
- TypeParam typeParam = new TypeParam();
- BeanUtils.copyProperties(pagePersObjParam, typeParam);
- typeParam.setpType(pagePersObjParam.getObjType());
- typeParam.setGroupId(pagePersObjParam.getInspGroupId());
- typeParam.setPresId(pagePersObjParam.getPersId());
- if (StringUtils.isBlank(typeParam.getNm()) &&
- StringUtils.isNotBlank(pagePersObjParam.getWtdstNm())) {
- typeParam.setNm(pagePersObjParam.getWtdstNm());
- }
- BisInspObjStrategy strategy = factory.createStrategy(pagePersObjParam.getObjType());
- return (List) strategy.findObjListByType(typeParam);
- }
- }
- @Override
- public Object getObjListNotInspGroupId(InspObjParam inspObjParam) {
- if (!StringUtils.isBlank(inspObjParam.getAdCode())) {
- Map<String, Object> map = AdLevelUtil.SubAd(inspObjParam.getAdCode());
- logger.debug("adCode:"+String.valueOf(inspObjParam.getAdCode()));
- if(null != map.get("subAd")){
- inspObjParam.setAdCode(map.get("subAd").toString());
- }
- }
- String province = inspObjParam.getProvince();
- //查询该节点是否设置督查区域
- //设置分页
- PageHelper.startPage(inspObjParam.getPageNum(), inspObjParam.getPageSize());
- List<Object> list = new ArrayList<>();
- //根据type分流
- if ("1".equalsIgnoreCase(inspObjParam.getObjType()) || "24".equalsIgnoreCase(inspObjParam.getObjType()) || "26".equals(inspObjParam.getObjType())) {
- List<AttRsBase> result = attRsBaseDao.getObjListNotInspGroupId(inspObjParam.getInspGroupId(), inspObjParam.getObjType(),
- inspObjParam.getRsName(), inspObjParam.getEngScal(), inspObjParam.getRsAdmDep(), inspObjParam.getAdCode(), province);
- return new PageInfo<>(result);
- } else if ("2".equalsIgnoreCase(inspObjParam.getObjType()) || "27".equals(inspObjParam.getObjType()) || "25".equals(inspObjParam.getObjType())) {
- List<AttAdBase> result = attAdBaseDao.getObjListNotInspGroupId(inspObjParam.getInspGroupId(), inspObjParam.getObjType(), inspObjParam.getAdName(), inspObjParam.getAdCode(), province);
- return new PageInfo<AttAdBase>(result);
- } else if ("3".equalsIgnoreCase(inspObjParam.getObjType())) {
- List<BisInspWtdst> result = bisInspWtdstDao.getObjListNotInspGroupId(inspObjParam);
- return new PageInfo<BisInspWtdst>(result);
- } else if ("4".equalsIgnoreCase(inspObjParam.getObjType())) {
- List<AttEmpwtprjBase> result = attEmpwtprjBaseDao.getObjListNotInspGroupId(inspObjParam.getInspGroupId(), inspObjParam.getObjType(),
- inspObjParam.getAdName(), inspObjParam.getAdCode(), province);
- return new PageInfo<AttEmpwtprjBase>(result);
- } else if ("5".equalsIgnoreCase(inspObjParam.getObjType())) {
- List<AttGrwBase> result = attGrwBaseDao.getObjListNotInspGroupId(inspObjParam.getInspGroupId(), inspObjParam.getObjType(),
- inspObjParam.getAdName(), inspObjParam.getAdCode(), province);
- return new PageInfo<AttGrwBase>(result);
- } else if ("6".equalsIgnoreCase(inspObjParam.getObjType())) {
- List<AttWagaBase> result = attWagaBaseDao.getObjListNotInspGroupId(inspObjParam.getInspGroupId(), inspObjParam.getObjType(),
- inspObjParam.getAdName(), inspObjParam.getAdCode(), province);
- return new PageInfo<AttWagaBase>(result);
- } else if ("7".equalsIgnoreCase(inspObjParam.getObjType())) {
- List<AttEmpwtprjBase> result = attEmpwtprjBaseDao.getObjListNotInspGroupId(inspObjParam.getInspGroupId(), inspObjParam.getObjType(),
- inspObjParam.getAdName(), inspObjParam.getAdCode(), province);
- return new PageInfo<AttEmpwtprjBase>(result);
- } else if ("8".equalsIgnoreCase(inspObjParam.getObjType())) {
- return null;
- } else if ("9".equalsIgnoreCase(inspObjParam.getObjType())) {
- List<AttFscBase> result = attFscBaseDao.getObjListNotInspGroupId(inspObjParam.getInspGroupId(), inspObjParam.getObjType(),
- inspObjParam.getAdName(), inspObjParam.getAdCode(), province);
- return new PageInfo<AttFscBase>(result);
- } else if ("10".equalsIgnoreCase(inspObjParam.getObjType())) {
- List<AttOtherBase> result = attOtherBaseDao.getObjListNotInspGroupId(inspObjParam.getInspGroupId(), inspObjParam.getObjType(),
- inspObjParam.getAdName(), inspObjParam.getAdCode(), province);
- return new PageInfo<AttOtherBase>(result);
- } else if ("11".equalsIgnoreCase(inspObjParam.getObjType())) {
- List<AttSdBase> result = sdBaseDao.getObjListNotInspGroupId(inspObjParam.getInspGroupId(), inspObjParam.getObjType(),
- inspObjParam.getAdName(), inspObjParam.getAdCode(), province);
- return new PageInfo<AttSdBase>(result);
- } else if ("12".equalsIgnoreCase(inspObjParam.getObjType())) {
- List<AttWiuBase> result = wiuBaseDao.getObjListNotInspGroupId(inspObjParam.getInspGroupId(), inspObjParam.getObjType(),
- inspObjParam.getAdName(), inspObjParam.getAdCode(), province);
- return new PageInfo<AttWiuBase>(result);
- } else if ("13".equalsIgnoreCase(inspObjParam.getObjType())) {
- List<AttSwhsBase> result = swhsBaseDao.getObjListNotInspGroupId(inspObjParam.getInspGroupId(), inspObjParam.getObjType(),
- inspObjParam.getAdName(), inspObjParam.getAdCode(), province);
- return new PageInfo<AttSwhsBase>(result);
- } else if ("14".equalsIgnoreCase(inspObjParam.getObjType())) {
- List<AttAdXBase> result = attAdXBaseDao.getObjListNotInspGroupId(inspObjParam.getInspGroupId(), inspObjParam.getObjType(),
- inspObjParam.getAdName(), inspObjParam.getAdCode(), province);
- return new PageInfo<AttAdXBase>(result);
- } else if ("15".equalsIgnoreCase(inspObjParam.getObjType())) {
- List<AttAdXBase> result = attAdXBaseDao.getObjListNotInspGroupId(inspObjParam.getInspGroupId(), inspObjParam.getObjType(),
- inspObjParam.getAdName(), inspObjParam.getAdCode(), province);
- return new PageInfo<AttAdXBase>(result);
- } else if ("16".equalsIgnoreCase(inspObjParam.getObjType())) {
- List<AttWuntBase> result = wuntBaseDao.getObjListNotInspGroupId(inspObjParam.getInspGroupId(), inspObjParam.getObjType(),
- inspObjParam.getAdName(), inspObjParam.getAdCode(), province);
- return new PageInfo<AttWuntBase>(result);
- } else if ("17".equalsIgnoreCase(inspObjParam.getObjType())) {
- //生产建设项目
- List<AttPrdCstrProjBase> result = oprdCstrProjRgstrDao.getObjPrdListNotInspGroupId(inspObjParam.getInspGroupId(), inspObjParam.getObjType(),
- inspObjParam.getAdName(), inspObjParam.getAdCode(), province);
- return new PageInfo<AttPrdCstrProjBase>(result);
- } else if ("18".equalsIgnoreCase(inspObjParam.getObjType())) {
- //生产建设项目
- List<AttJskejianFlkdisBase> result = jskejianFlkdisBaseDao.getObjJsFlListNotInspGroupId(inspObjParam.getInspGroupId(), inspObjParam.getObjType(),
- inspObjParam.getAdName(), inspObjParam.getAdCode(), province);
- return new PageInfo<AttJskejianFlkdisBase>(result);
- } else if ("19".equalsIgnoreCase(inspObjParam.getObjType())) {
- //生产建设项目
- List<AttJskejianWaterBase> result = jskejianWaterBaseDao.getObjJsWaListNotInspGroupId(inspObjParam.getInspGroupId(), inspObjParam.getObjType(),
- inspObjParam.getAdName(), inspObjParam.getAdCode(), province);
- return new PageInfo<AttJskejianWaterBase>(result);
- } else if ("23".equalsIgnoreCase(inspObjParam.getObjType())) {
- //量化考核
- List<AttAdXBase> result = attAdXBaseDao.getObjListNotInspGroupId(inspObjParam.getInspGroupId(), inspObjParam.getObjType(),
- inspObjParam.getAdName(), inspObjParam.getAdCode(), province);
- return new PageInfo<AttAdXBase>(result);
- } else if (BisInspEnum.SAP.getValue().equalsIgnoreCase(inspObjParam.getObjType())) {
- List<AttWagaSapBase> result = bisInspWagaSapRgstrDao.getObjListNotInspGroupId(inspObjParam.getInspGroupId(), inspObjParam.getObjType(),
- inspObjParam.getAdName(), inspObjParam.getAdCode(), province);
- return new PageInfo<AttWagaSapBase>(result);
- } else if (BisInspEnum.EFP.getValue().equalsIgnoreCase(inspObjParam.getObjType())) {
- List<AttEfpBase> result = bisInspEfpRgstrDao.getObjListNotInspGroupId(inspObjParam.getInspGroupId(), inspObjParam.getObjType(),
- inspObjParam.getAdName(), inspObjParam.getAdCode(), province);
- return new PageInfo<AttEfpBase>(result);
- }
- return null;
- }
- @Override
- public Map<String, Object> addDcAndObjRel(String baseId, String objType, String inspGroupId, String objName,
- String objLttd, String objLgtd, String objProvincial ,String persId, String orgId) {
- Map<String, Object> ret = new HashMap<>();
- boolean isSuccess = true;
- StringBuilder objStringBuilder = new StringBuilder();
- //处理参数添加
- String[] baseIdArray = baseId.split(SplitValue.DOUHAO_SPLIT);
- String[] objNameArray = objName.split(SplitValue.DOUHAO_SPLIT);
- String[] objLttdArray = objLttd.split(SplitValue.DOUHAO_SPLIT);
- String[] objLgtdArray = objLgtd.split(SplitValue.DOUHAO_SPLIT);
- String[] provincialArray = objProvincial.split(SplitValue.DOUHAO_SPLIT);
- String province = inspOrgService.getProvince(orgId);
- // 循环对象
- for (int i = 0; i < baseIdArray.length; i++) {
- // 基础表ID为空时跳过
- if (StringUtils.isBlank(baseIdArray[i])) {
- continue;
- }
- // 组装 bisInspAllObj
- BisInspAllObj bisInspAllObj = new BisInspAllObj();
- bisInspAllObj.setId(inspGroupId);
- bisInspAllObj.setObjId(UuidUtil.uuid());
- bisInspAllObj.setCode(baseIdArray[i]);
- bisInspAllObj.setPtype(objType);
- bisInspAllObj.setNm(objNameArray[i]);
- // 增加 督察对象 是否省属 属性 1是2否 add by lxf 2022/10/10
- logger.debug("Provincial: "+provincialArray[i]);
- String tmp = ("null".equalsIgnoreCase(provincialArray[i])||"".equals(provincialArray[i]))?null:provincialArray[i];
- if(null != tmp && "是,否".contains(tmp)){
- tmp = "是".equals(tmp)?"1":"2";
- }
- if(null != tmp && !"1".equals(tmp) && !"2".equals(tmp)){
- tmp = "2";
- }
- bisInspAllObj.setProvincial(tmp);
- if (!province.startsWith(AdCodeLabel.START_PARENT_ADCODE)) {
- bisInspAllObj.setAdCode(province);
- bisInspAllObj.setOrgId(orgId);
- } else {
- orgId = "";
- }
- if (objLttdArray.length > 0 && !"".equals(objLttdArray[i]) &&
- !"null".equals(objLttdArray[i])) {
- bisInspAllObj.setLgtd(Double.parseDouble(objLgtdArray[i]));
- bisInspAllObj.setLttd(Double.parseDouble(objLttdArray[i]));
- }
- // obj 重复校验
- BisInspAllObjDto baj = this.bisInspAllObjDao.getObj(bisInspAllObj);
- if (baj != null) {
- isSuccess = false;
- ObjectNameDto ond = this.bisInspAllObjDao.getGroup(bisInspAllObj.getId());
- objStringBuilder.append(ond.getName()).append("、");
- continue;
- }
- bisInspAllObjDao.insert(bisInspAllObj);
- if ("36".equals(objType)) {
- // 36 走小水库
- objType = "1";
- }
- BisInspObjStrategy strategy = factory.createStrategy(objType);
- strategy.insertObj(bisInspAllObj, persId);
- }
- if (isSuccess) {
- ret.put("code", "200");
- ret.put("mess", "添加成功");
- } else {
- ret.put("code", "201");
- ret.put("mess", objStringBuilder.toString().substring(0, objStringBuilder.toString().length() - 1) + "重复添加");
- }
- return ret;
- }
- @Autowired
- private BisNewVillRgstrDao bisNewVillRgstrDao;
- @Override
- public List getObjByPersId(PersObjParam persObjParam, HttpServletResponse response) {
- if (StringUtils.isNotBlank(persObjParam.getAdCode())) {
- persObjParam.setAdCode(AdLevelUtil.SubAd(persObjParam.getAdCode()).get("subAd").toString());
- }
- persObjParam.setInIdsSql(SqlUtils.getinIdsSql(persObjParam.getPersGuid(), persObjParam.getProvince()));
- BisInspEnum bisInspEnum = BisInspEnum.getEnumByType(persObjParam.getObjType());
- Optional.ofNullable(bisInspEnum).orElseThrow(() -> new CheckException("未找到与 objType:" + persObjParam.getObjType() + " 相对应的督查项!"));
- //根据type分流
- switch (bisInspEnum) {
- case SAP:
- List<AttWagaSapBaseDto> result = this.bisInspObjDao.getSapObjByPersId(persObjParam);
- exportExcel(persObjParam.getIsExport(), result, response);
- return result;
- case SAP_BASE:
- return bisInspObjDao.getSapBaseList(persObjParam);
- case SAP_OBJ:
- TypeParam typeParam = new TypeParam();
- typeParam.setPresId(persObjParam.getPersGuid());
- typeParam.setRsName(persObjParam.getRsName());
- typeParam.setState(persObjParam.getState());
- typeParam.setAdCode(persObjParam.getAdCode());
- typeParam.setpType(BisInspEnum.SAP.getValue());
- typeParam.setProvince(persObjParam.getProvince());
- return this.bisInspWagaSapRgstrDao.getWagaSapRegstrInfo(typeParam);
- default:
- }
- if (BisInspEnum.REVER.getValue().equalsIgnoreCase(persObjParam.getObjType())) {
- List<AttPersRs> result = attRsBaseDao.getObjByPersId(persObjParam);
- exportExcel(persObjParam.getIsExport(), result, response);
- return result;
- } else if (BisInspEnum.VILL.getValue().equalsIgnoreCase(persObjParam.getObjType())) {
- if (persObjParam.getProvince().length() == 12) {
- persObjParam.setProvince(persObjParam.getProvince().substring(0, 2));
- }
- List<SecsurveyVlgDto> result = attAdBaseDao.getObjByPersId(persObjParam);
- exportExcel(persObjParam.getIsExport(), result, response);
- return result;
- } else if (BisInspEnum.VILL2020.getValue().equalsIgnoreCase(persObjParam.getObjType())) {
- if (persObjParam.getProvince().length() == 12) {
- persObjParam.setProvince(persObjParam.getProvince().substring(0, 2));
- }
- List<BisNewWateruserInfoDto> result = bisNewVillRgstrDao.getVill20ByPersId(persObjParam);
- exportExcel(persObjParam.getIsExport(), result, response);
- return result;
- } else if (BisInspObjEnum.CWS.getValue().equalsIgnoreCase(persObjParam.getObjType())) {
- if (persObjParam.getProvince().length() == 12) {
- persObjParam.setProvince(persObjParam.getProvince().substring(0, 2));
- }
- persObjParam.setObjType(persObjParam.getObjType().substring(0, 1));
- List<AttCwsBaseDto> result = attAdBaseDao.getCwsByPersId(persObjParam);
- exportExcel(persObjParam.getIsExport(), result, response);
- return result;
- } else if (BisInspObjEnum.PSP.getValue().equalsIgnoreCase(persObjParam.getObjType())) {
- persObjParam.setObjType(persObjParam.getObjType().substring(0, 1));
- List<ProSourceProtectDto> result = attAdBaseDao.getPspByPersId(persObjParam);
- exportExcel(persObjParam.getIsExport(), result, response);
- return result;
- } else if (BisInspObjEnum.COUNTRY.getValue().equalsIgnoreCase(persObjParam.getObjType())) {
- persObjParam.setObjType(persObjParam.getObjType().substring(0, 1));
- List<AttAdBase> result = attAdBaseDao.getAdBaseByPersId(persObjParam);
- exportExcel(persObjParam.getIsExport(), result, response);
- return result;
- } else if (BisInspEnum.TRACK.getValue().equalsIgnoreCase(persObjParam.getObjType())) {
- if (persObjParam.getProvince().length() == 12) {
- persObjParam.setProvince(persObjParam.getProvince().substring(0, 2));
- }
- List<AttPersWtdst> result = bisInspWtdstDao.getObjByPersId(persObjParam);
- exportExcel(persObjParam.getIsExport(), result, response);
- return result;
- } else if (BisInspEnum.EMPWT.getValue().equalsIgnoreCase(persObjParam.getObjType())) {
- List<AttEmpwtprjBase> result = attEmpwtprjBaseDao.getObjByPersId(persObjParam);
- exportExcel(persObjParam.getIsExport(), result, response);
- return result;
- } else if (BisInspEnum.GRW.getValue().equalsIgnoreCase(persObjParam.getObjType())) {
- List<AttPersGrw> result = attGrwBaseDao.getObjByPersId(persObjParam);
- exportExcel(persObjParam.getIsExport(), result, response);
- return result;
- } else if (BisInspEnum.WAGA.getValue().equalsIgnoreCase(persObjParam.getObjType())) {
- List<AttWagaBase> result = attWagaBaseDao.getObjByPersId(persObjParam);
- exportExcel(persObjParam.getIsExport(), result, response);
- return result;
- } else if (BisInspObjEnum.STBPRP.getValue().equalsIgnoreCase(persObjParam.getObjType())) { //水文站
- List<StStbprpB> result = stStbprpBDao.findListBy(persObjParam);
- exportExcel(persObjParam.getIsExport(), result, response);
- return result;
- } else if (BisInspObjEnum.PKX.getValue().equalsIgnoreCase(persObjParam.getObjType())) {//贫困县
- List<AttPkxBase> result = attPkxBaseDao.findListBy(persObjParam);
- exportExcel(persObjParam.getIsExport(), result, response);
- return result;
- } else if (BisInspObjEnum.WAIN.getValue().equalsIgnoreCase(persObjParam.getObjType())) {//取水口
- List<AttWainBase> result = attWainBaseDao.findListByPersId(persObjParam);
- exportExcel(persObjParam.getIsExport(), result, response);
- return result;
- } else if (BisInspObjEnum.SWHS.getValue().equalsIgnoreCase(persObjParam.getObjType())) {
- List<AttSwhsBase> result = swhsBaseDao.findListBy(persObjParam);
- exportExcel(persObjParam.getIsExport(), result, response);
- return result;
- } else if (BisInspObjEnum.FSC.getValue().equalsIgnoreCase(persObjParam.getObjType())) {
- List<AttFscBase> result = attFscBaseDao.findListBy(persObjParam);
- exportExcel(persObjParam.getIsExport(), result, response);
- return result;
- } else if (BisInspObjEnum.OTHER.getValue().equalsIgnoreCase(persObjParam.getObjType())) {
- List<AttOtherBase> result = attOtherBaseDao.findListBy(persObjParam);
- exportExcel(persObjParam.getIsExport(), result, response);
- return result;
- } else if (BisInspObjEnum.SD.getValue().equalsIgnoreCase(persObjParam.getObjType())) {
- List<BisInspObjDto> result = bisInspObjDao.getSdObjByPersId(persObjParam);
- exportExcel(persObjParam.getIsExport(), result, response);
- return result;
- } else if (BisInspObjEnum.WIU.getValue().equalsIgnoreCase(persObjParam.getObjType())) {//取用水户
- persObjParam.setObjType(BisInspEnum.WIU.getValue());
- List<BisInspObjDto> result = this.bisInspObjDao.getWiuObjByPersId(persObjParam);
- exportExcel(persObjParam.getIsExport(), result, response);
- return result;
- } else if (BisInspObjEnum.KEYSWHS.getValue().equalsIgnoreCase(persObjParam.getObjType())) {//重点水源地
- persObjParam.setObjType(BisInspEnum.SWHS.getValue());
- List<BisInspObjDto> result = this.bisInspObjDao.getKeySwhsObjByPersId(persObjParam);
- exportExcel(persObjParam.getIsExport(), result, response);
- return result;
- } else if (BisInspObjEnum.WINT.getValue().equalsIgnoreCase(persObjParam.getObjType())) {
- List<BisInspObjDto> result = this.bisInspObjDao.getWintObjByPersId(persObjParam);
- exportExcel(persObjParam.getIsExport(), result, response);
- return result;
- } else if (BisInspObjEnum.SVWT.getValue().equals(persObjParam.getObjType())) {
- persObjParam.setObjType(BisInspEnum.SVWT.getValue());
- List<BisInspObjDto> result = this.bisInspObjDao.getSvwtObjByPersId(persObjParam);
- exportExcel(persObjParam.getIsExport(), result, response);
- return result;
- } else if (BisInspObjEnum.WUNT.getValue().equals(persObjParam.getObjType())) {
- persObjParam.setObjType(BisInspEnum.WUNT.getValue());
- List<BisInspObjDto> result = this.bisInspObjDao.getWuntObjByPersId(persObjParam);
- exportExcel(persObjParam.getIsExport(), result, response);
- return result;
- } else if (BisInspObjEnum.PRD.getValue().equals(persObjParam.getObjType())) {
- persObjParam.setObjType(BisInspEnum.PRD.getValue());
- List<BisInspObjDto> result = this.bisInspObjDao.getPrdObjByPersId(persObjParam);
- exportExcel(persObjParam.getIsExport(), result, response);
- return result;
- } else if (BisInspObjEnum.JSFL.getValue().equals(persObjParam.getObjType())) {
- persObjParam.setObjType(BisInspEnum.JSFL.getValue());
- List<BisInspObjDto> result = this.bisInspObjDao.getJSFLObjByPersId(persObjParam);
- exportExcel(persObjParam.getIsExport(), result, response);
- return result;
- } else if (BisInspObjEnum.JSWA.getValue().equals(persObjParam.getObjType())) {
- persObjParam.setObjType(BisInspEnum.JSWA.getValue());
- List<BisInspObjDto> result = this.bisInspObjDao.getJSWAObjByPersId(persObjParam);
- exportExcel(persObjParam.getIsExport(), result, response);
- return result;
- } else if (persObjParam.getObjType().startsWith(BisInspEnum.IRR.getValue())) {
- return getIrrDataList(persObjParam);
- }
- return null;
- }
- private List getIrrDataList(PersObjParam persObjParam) {
- if (BisInspObjEnum.IRR_VILL.getValue().equals(persObjParam.getObjType())) {
- List<BisInspObjDto> result = bisInspIrrRgstrDao.getIrrVillList(persObjParam);
- return result;
- } else if (BisInspObjEnum.IRR_WTUSR.getValue().equals(persObjParam.getObjType())) {
- List<BisInspObjDto> result = bisInspIrrRgstrDao.getIrrWtusrList(persObjParam);
- return result;
- } else if (BisInspObjEnum.IRR_TOWN.getValue().equals(persObjParam.getObjType())) {
- List<BisInspObjDto> result = bisInspIrrRgstrDao.getIrrTownList(persObjParam);
- return result;
- } else if (BisInspObjEnum.IRR_PRO.getValue().equals(persObjParam.getObjType())) {
- List<BisInspObjDto> result = bisInspIrrRgstrDao.getIrrProList(persObjParam);
- return result;
- } else if (BisInspObjEnum.IRR_CITY.getValue().equals(persObjParam.getObjType())) {
- TypeParam typeParam = new TypeParam();
- typeParam.setPresId(persObjParam.getPersGuid());
- typeParam.setRsName(persObjParam.getRsName());
- typeParam.setState(persObjParam.getState());
- typeParam.setAdCode(persObjParam.getAdCode());
- typeParam.setpType(BisInspEnum.IRR.getValue());
- List<BisInspRgstrDto> result = bisInspIrrRgstrDao.findIrrList(typeParam);
- return result;
- } else if (BisInspObjEnum.IRR_BASE.getValue().equals(persObjParam.getObjType())) {
- List<BisInspObjDto> result = bisInspIrrRgstrDao.getIrrBaseList(persObjParam);
- return result;
- }
- return null;
- }
- @Override
- public PageInfo getPageByPersId(PersObjParam persObjParam, HttpServletResponse response) {
- if (StringUtils.isNotBlank(persObjParam.getAdCode())) {
- persObjParam.setAdCode(AdLevelUtil.SubAd(persObjParam.getAdCode()).get("subAd").toString());
- }
- //设置分页
- PageHelper.startPage(persObjParam.getPageNum(), persObjParam.getPageSize());
- //根据type分流
- BisInspEnum bisInspEnum = BisInspEnum.getEnumByType(persObjParam.getObjType());
- Optional.ofNullable(bisInspEnum).orElseThrow(() -> new CheckException("未找到与 objType:" + persObjParam.getObjType() + " 相对应的督查项!"));
- //根据type分流
- switch (bisInspEnum) {
- case SAP:
- List<AttWagaSapBaseDto> result = this.bisInspObjDao.getSapObjByPersId(persObjParam);
- exportExcel(persObjParam.getIsExport(), result, response);
- return new PageInfo<>(result);
- case SAP_BASE:
- return new PageInfo<>(bisInspObjDao.getSapBaseList(persObjParam));
- case SAP_OBJ:
- TypeParam typeParam = new TypeParam();
- typeParam.setPresId(persObjParam.getPersGuid());
- typeParam.setRsName(persObjParam.getRsName());
- typeParam.setState(persObjParam.getState());
- typeParam.setAdCode(persObjParam.getAdCode());
- typeParam.setpType(BisInspEnum.SAP.getValue());
- typeParam.setProvince(persObjParam.getProvince());
- return new PageInfo<>(this.bisInspWagaSapRgstrDao.getWagaSapRegstrInfo(typeParam));
- default:
- }
- if (BisInspEnum.REVER.getValue().equalsIgnoreCase(persObjParam.getObjType())) {//水库
- List<AttPersRs> result = attRsBaseDao.getObjByPersId(persObjParam);
- return new PageInfo<>(result);
- } else if (BisInspEnum.VILL.getValue().equalsIgnoreCase(persObjParam.getObjType())) {//人饮行政村
- List<SecsurveyVlgDto> result = attAdBaseDao.getObjByPersId(persObjParam);
- exportExcel(persObjParam.getIsExport(), result, response);
- return new PageInfo<SecsurveyVlgDto>(result);
- } else if (BisInspObjEnum.CWS.getValue().equalsIgnoreCase(persObjParam.getObjType())) {//农村饮水工程
- persObjParam.setObjType(persObjParam.getObjType().substring(0, 1));
- List<AttCwsBaseDto> result = attAdBaseDao.getCwsByPersId(persObjParam);
- exportExcel(persObjParam.getIsExport(), result, response);
- return new PageInfo<AttCwsBaseDto>(result);
- } else if (BisInspObjEnum.PSP.getValue().equalsIgnoreCase(persObjParam.getObjType())) {//水源地
- persObjParam.setObjType(persObjParam.getObjType().substring(0, 1));
- List<ProSourceProtectDto> result = attAdBaseDao.getPspByPersId(persObjParam);
- exportExcel(persObjParam.getIsExport(), result, response);
- return new PageInfo<ProSourceProtectDto>(result);
- } else if (BisInspObjEnum.COUNTRY.getValue().equalsIgnoreCase(persObjParam.getObjType())) {//督查县
- List<AttAdBase> result = attAdBaseDao.getAdBaseByPersId(persObjParam);
- exportExcel(persObjParam.getIsExport(), result, response);
- return new PageInfo<AttAdBase>(result);
- } else if (BisInspEnum.TRACK.getValue().equalsIgnoreCase(persObjParam.getObjType())) {//水毁
- List<AttPersWtdst> result = bisInspWtdstDao.getObjByPersId(persObjParam);
- exportExcel(persObjParam.getIsExport(), result, response);
- return new PageInfo<AttPersWtdst>(result);
- } else if (BisInspEnum.EMPWT.getValue().equalsIgnoreCase(persObjParam.getObjType())) {//172
- List<AttEmpwtprjBase> result = attEmpwtprjBaseDao.getObjByPersId(persObjParam);
- exportExcel(persObjParam.getIsExport(), result, response);
- return new PageInfo<AttEmpwtprjBase>(result);
- } else if (BisInspEnum.GRW.getValue().equalsIgnoreCase(persObjParam.getObjType())) {//地下水
- List<AttPersGrw> result = attGrwBaseDao.getObjByPersId(persObjParam);
- exportExcel(persObjParam.getIsExport(), result, response);
- return new PageInfo<AttPersGrw>(result);
- } else if (BisInspEnum.WAGA.getValue().equalsIgnoreCase(persObjParam.getObjType())) {//水闸
- List<AttWagaBase> result = attWagaBaseDao.getObjByPersId(persObjParam);
- exportExcel(persObjParam.getIsExport(), result, response);
- return new PageInfo<AttWagaBase>(result);
- } else if (BisInspObjEnum.STBPRP.getValue().equalsIgnoreCase(persObjParam.getObjType())) { //水文站
- List<StStbprpB> result = stStbprpBDao.findListBy(persObjParam);
- exportExcel(persObjParam.getIsExport(), result, response);
- return new PageInfo<StStbprpB>(result);
- } else if (BisInspObjEnum.PKX.getValue().equalsIgnoreCase(persObjParam.getObjType())) {//贫困县
- List<AttPkxBase> result = attPkxBaseDao.findListBy(persObjParam);
- exportExcel(persObjParam.getIsExport(), result, response);
- return new PageInfo<AttPkxBase>(result);
- } else if (BisInspObjEnum.WAIN.getValue().equalsIgnoreCase(persObjParam.getObjType())) {//取水口
- List<AttWainBase> result = attWainBaseDao.findListByPersId(persObjParam);
- exportExcel(persObjParam.getIsExport(), result, response);
- return new PageInfo<AttWainBase>(result);
- } else if (BisInspObjEnum.SWHS.getValue().equalsIgnoreCase(persObjParam.getObjType())) {//地表水
- List<AttSwhsBase> result = swhsBaseDao.findListBy(persObjParam);
- exportExcel(persObjParam.getIsExport(), result, response);
- return new PageInfo<AttSwhsBase>(result);
- } else if (BisInspObjEnum.FSC.getValue().equalsIgnoreCase(persObjParam.getObjType())) {
- List<AttFscBase> result = attFscBaseDao.findListBy(persObjParam);
- exportExcel(persObjParam.getIsExport(), result, response);
- return new PageInfo<AttFscBase>(result);
- } else if (BisInspObjEnum.OTHER.getValue().equalsIgnoreCase(persObjParam.getObjType())) {
- List<AttOtherBase> result = attOtherBaseDao.findListBy(persObjParam);
- exportExcel(persObjParam.getIsExport(), result, response);
- return new PageInfo<AttOtherBase>(result);
- } else if (BisInspObjEnum.SD.getValue().equalsIgnoreCase(persObjParam.getObjType())) {
- List<BisInspObjDto> result = bisInspObjDao.getSdObjByPersId(persObjParam);
- exportExcel(persObjParam.getIsExport(), result, response);
- return new PageInfo<BisInspObjDto>(result);
- } else if (BisInspObjEnum.WINT.getValue().equalsIgnoreCase(persObjParam.getObjType())) {
- List<BisInspObjDto> result = this.bisInspObjDao.getWintObjByPersId(persObjParam);
- exportExcel(persObjParam.getIsExport(), result, response);
- return new PageInfo<BisInspObjDto>(result);
- } else if (BisInspObjEnum.KEYSWHS.getValue().equalsIgnoreCase(persObjParam.getObjType())) {//重点水源地
- persObjParam.setObjType(BisInspEnum.SWHS.getValue());
- List<BisInspObjDto> result = this.bisInspObjDao.getKeySwhsObjByPersId(persObjParam);
- exportExcel(persObjParam.getIsExport(), result, response);
- return new PageInfo<BisInspObjDto>(result);
- } else if (BisInspObjEnum.SVWT.getValue().equalsIgnoreCase(persObjParam.getObjType())) {
- persObjParam.setObjType(BisInspEnum.SVWT.getValue());
- List<BisInspObjDto> result = this.bisInspObjDao.getSvwtObjByPersId(persObjParam);
- exportExcel(persObjParam.getIsExport(), result, response);
- return new PageInfo<BisInspObjDto>(result);
- } else if (BisInspObjEnum.WUNT.getValue().equalsIgnoreCase(persObjParam.getObjType())) {
- persObjParam.setObjType(BisInspEnum.WUNT.getValue());
- List<BisInspObjDto> result = this.bisInspObjDao.getWuntObjByPersId(persObjParam);
- exportExcel(persObjParam.getIsExport(), result, response);
- return new PageInfo<BisInspObjDto>(result);
- } else if (BisInspObjEnum.PRD.getValue().equalsIgnoreCase(persObjParam.getObjType())) {
- persObjParam.setObjType(BisInspEnum.PRD.getValue());
- List<BisInspObjDto> result = this.bisInspObjDao.getPrdObjByPersId(persObjParam);
- exportExcel(persObjParam.getIsExport(), result, response);
- return new PageInfo<BisInspObjDto>(result);
- } else if (BisInspObjEnum.JSFL.getValue().equalsIgnoreCase(persObjParam.getObjType())) {
- persObjParam.setObjType(BisInspEnum.JSFL.getValue());
- List<BisInspObjDto> result = this.bisInspObjDao.getJSFLObjByPersId(persObjParam);
- exportExcel(persObjParam.getIsExport(), result, response);
- return new PageInfo<BisInspObjDto>(result);
- } else if (BisInspObjEnum.JSWA.getValue().equalsIgnoreCase(persObjParam.getObjType())) {
- persObjParam.setObjType(BisInspEnum.JSWA.getValue());
- List<BisInspObjDto> result = this.bisInspObjDao.getJSWAObjByPersId(persObjParam);
- exportExcel(persObjParam.getIsExport(), result, response);
- return new PageInfo<BisInspObjDto>(result);
- } else if ("28".equalsIgnoreCase(persObjParam.getObjType())) {
- persObjParam.setObjType(BisInspEnum.IRR.getValue());
- List<BisInspObjDto> result = this.bisInspObjDao.getIrrObjByPersId(persObjParam);
- exportExcel(persObjParam.getIsExport(), result, response);
- return new PageInfo<>(result);
- } else if ("29".equalsIgnoreCase(persObjParam.getObjType())) {
- persObjParam.setObjType(BisInspEnum.SAP.getValue());
- List<AttWagaSapBaseDto> result = this.bisInspObjDao.getSapObjByPersId(persObjParam);
- exportExcel(persObjParam.getIsExport(), result, response);
- return new PageInfo<>(result);
- }
- return null;
- }
- @Override
- public VillRgstrEngIdDto getRgstrByCode(String code, String type, String orgId) {
- String province = inspOrgService.getProvince(orgId);
- VillRgstrEngIdDto villRgstrEngIdDto = new VillRgstrEngIdDto();
- if ("ADX".equals(type)) {
- villRgstrEngIdDto = this.bisInspVillRgstrDao.getRgstrByAdXCode(code, orgId);
- }
- if ("CWS".equals(type)) {
- villRgstrEngIdDto = this.bisInspVillRgstrDao.getRgstrByCwsCode(code, orgId);
- }
- if (villRgstrEngIdDto == null) {
- VillRgstrEngIdDto v1 = new VillRgstrEngIdDto();
- v1.setStateCode("1003");
- return v1;
- } else {
- if (villRgstrEngIdDto.getEngId() != null) {
- villRgstrEngIdDto.setStateCode("1001");
- return villRgstrEngIdDto;
- } else {
- if (villRgstrEngIdDto.getCode() != null) {
- BisInspVillRgstr bivr = new BisInspVillRgstr();
- bivr.setEngId(UUID.randomUUID().toString().replace("-", ""));
- bivr.setObjId(villRgstrEngIdDto.getObjId());
- bivr.setRegsNm(villRgstrEngIdDto.getNm());
- Date date = new Date();
- SimpleDateFormat dateFormat = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
- String format = dateFormat.format(date);
- bivr.setIntm(format);
- bivr.setRecPersId("1");
- if (!province.startsWith(AdCodeLabel.START_PARENT_ADCODE)) {
- bivr.setOrgId(orgId);
- }
- bisInspVillRgstrService.insert(bivr);
- villRgstrEngIdDto.setEngId(bivr.getEngId());
- villRgstrEngIdDto.setStateCode("1002");
- return villRgstrEngIdDto;
- } else {
- return null;
- }
- }
- }
- }
- @Override
- public PageInfo<AttGrwBase> getGrwNotInGroup(InGroupGrwParam inGroupGrwParam) {
- if (inGroupGrwParam.getAdcd() != null) {
- if (inGroupGrwParam.getAdcd().contains(",")) {//如果有多个行政区划编码,要根据逗号分隔截取
- StringBuffer stringBuffer = new StringBuffer();
- String[] split = inGroupGrwParam.getAdcd().split(",");
- for (String s : split) {//拼接sql,对多个截取后的行政区划进行模糊查询
- String subAd = AdLevelUtil.SubAd(s).get("subAd").toString();
- stringBuffer.append(subAd);
- stringBuffer.append("%");
- stringBuffer.append("' OR ADCD LIKE '");
- }
- //将最后的“ OR ADCD LIKE ”截掉
- String substring = stringBuffer.substring(0, stringBuffer.length() - 15);
- substring = "(ADCD LIKE '" + substring + ")";
- inGroupGrwParam.setAdcd(substring);
- } else {
- String subAd = AdLevelUtil.SubAd(inGroupGrwParam.getAdcd()).get("subAd").toString();
- subAd = "ADCD LIKE '" + subAd + "%'";
- inGroupGrwParam.setAdcd(subAd);
- }
- }
- PageHelper.startPage(inGroupGrwParam.getPageNum(), inGroupGrwParam.getPageSize());
- List<AttGrwBase> attGrwBaseList = this.attGrwBaseDao.getGrwNotInGroup(inGroupGrwParam);
- PageInfo<AttGrwBase> pageInfo = new PageInfo<>(attGrwBaseList);
- return pageInfo;
- }
- }
|