| 12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788899091929394959697989910010110210310410510610710810911011111211311411511611711811912012112212312412512612712812913013113213313413513613713813914014114214314414514614714814915015115215315415515615715815916016116216316416516616716816917017117217317417517617717817918018118218318418518618718818919019119219319419519619719819920020120220320420520620720820921021121221321421521621721821922022122222322422522622722822923023123223323423523623723823924024124224324424524624724824925025125225325425525625725825926026126226326426526626726826927027127227327427527627727827928028128228328428528628728828929029129229329429529629729829930030130230330430530630730830931031131231331431531631731831932032132232332432532632732832933033133233333433533633733833934034134234334434534634734834935035135235335435535635735835936036136236336436536636736836937037137237337437537637737837938038138238338438538638738838939039139239339439539639739839940040140240340440540640740840941041141241341441541641741841942042142242342442542642742842943043143243343443543643743843944044144244344444544644744844945045145245345445545645745845946046146246346446546646746846947047147247347447547647747847948048148248348448548648748848949049149249349449549649749849950050150250350450550650750850951051151251351451551651751851952052152252352452552652752852953053153253353453553653753853954054154254354454554654754854955055155255355455555655755855956056156256356456556656756856957057157257357457557657757857958058158258358458558658758858959059159259359459559659759859960060160260360460560660760860961061161261361461561661761861962062162262362462562662762862963063163263363463563663763863964064164264364464564664764864965065165265365465565665765865966066166266366466566666766866967067167267367467567667767867968068168268368468568668768868969069169269369469569669769869970070170270370470570670770870971071171271371471571671771871972072172272372472572672772872973073173273373473573673773873974074174274374474574674774874975075175275375475575675775875976076176276376476576676776876977077177277377477577677777877978078178278378478578678778878979079179279379479579679779879980080180280380480580680780880981081181281381481581681781881982082182282382482582682782882983083183283383483583683783883984084184284384484584684784884985085185285385485585685785885986086186286386486586686786886987087187287387487587687787887988088188288388488588688788888989089189289389489589689789889990090190290390490590690790890991091191291391491591691791891992092192292392492592692792892993093193293393493593693793893994094194294394494594694794894995095195295395495595695795895996096196296396496596696796896997097197297397497597697797897998098198298398498598698798898999099199299399499599699799899910001001100210031004100510061007100810091010101110121013101410151016101710181019102010211022102310241025102610271028102910301031103210331034103510361037103810391040104110421043104410451046104710481049105010511052105310541055105610571058105910601061106210631064106510661067106810691070107110721073107410751076107710781079108010811082108310841085108610871088108910901091109210931094109510961097109810991100110111021103110411051106110711081109111011111112111311141115111611171118111911201121112211231124112511261127112811291130 |
- 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.dcproj.vo.AttRsBaseVo;
- 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<AttRsBaseVo> 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;
- }
- }
|