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 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 result = attRsBaseDao.getListByInspGroupIdObjType(pagePersObjParam); return result; } else if ("2".equalsIgnoreCase(pagePersObjParam.getObjType()) || "25".equalsIgnoreCase(pagePersObjParam.getObjType())) { List result = attAdBaseDao.getListByInspGroupIdObjType(pagePersObjParam); return result; } else if ("3".equalsIgnoreCase(pagePersObjParam.getObjType())) { List result = bisInspWtdstDao.getListByInspGroupIdObjType(pagePersObjParam); return result; } else if ("5".equalsIgnoreCase(pagePersObjParam.getObjType())) { List result = attGrwBaseDao.getListByInspGroupIdObjType(pagePersObjParam); return result; } else if ("8".equalsIgnoreCase(pagePersObjParam.getObjType())) { List result = bisInspAllObjDao.getListByInspGroupIdObjType(pagePersObjParam); return result; } else if ("6".equalsIgnoreCase(pagePersObjParam.getObjType())) { List result = attWagaRgstrService.getListByInspGroupIdObjType(pagePersObjParam); return result; } else if ("4".equalsIgnoreCase(pagePersObjParam.getObjType())) { //水利工程建设 List result = bisInspKeyRegisterService.getListByInspGroupIdObjTypeBuild(pagePersObjParam); return result; } else if ("7".equalsIgnoreCase(pagePersObjParam.getObjType())) { List result = bisInspKeyRegisterService.getListByInspGroupIdObjTypeRun(pagePersObjParam); return result; } else if ("9".equalsIgnoreCase(pagePersObjParam.getObjType())) { //特定飞检 List result = bisInspFscRgstrDao.getListByInspGroupIdObjType(pagePersObjParam); return result; } else if ("10".equalsIgnoreCase(pagePersObjParam.getObjType())) { //其他检查 List result = bisInspOtherRgstrDao.getListByInspGroupIdObjType(pagePersObjParam); return result; } else if ("11".equalsIgnoreCase(pagePersObjParam.getObjType())) { //淤地坝 List result = inspSdRgstrDao.getListByInspGroupIdObjType(pagePersObjParam); return result; } else if ("12".equalsIgnoreCase(pagePersObjParam.getObjType())) { //取用水户 List result = inspWiuRgstrDao.getListByInspGroupIdObjType(pagePersObjParam); return result; } else if ("13".equalsIgnoreCase(pagePersObjParam.getObjType())) { //水源地 List result = inspSwhsRgstrDao.getListByInspGroupIdObjType(pagePersObjParam); return result; } else if ("14".equalsIgnoreCase(pagePersObjParam.getObjType())) { //县级行政区 List result = wintRgstrDao.getListByInspGroupIdObjType(pagePersObjParam); return result; } else if ("15".equalsIgnoreCase(pagePersObjParam.getObjType())) { //节水管理与评价 List result = inspSvwtAreaRgstrDao.getListByInspGroupIdObjType(pagePersObjParam); return result; } else if ("16".equalsIgnoreCase(pagePersObjParam.getObjType())) { //用水单位 List result = inspSvwtWuntRgstrDao.getListByInspGroupIdObjType(pagePersObjParam); return result; } else if ("17".equalsIgnoreCase(pagePersObjParam.getObjType())) { //生产建设项目 List result = oprdCstrProjRgstrDao.getListOprdByInspGroupIdObjType(pagePersObjParam); return result; } else if ("18".equalsIgnoreCase(pagePersObjParam.getObjType())) { //河湖四乱项目 List result = jskejianFlkdisRgstrDao.getListJSFLByInspGroupIdObjType(pagePersObjParam); return result; } else if ("19".equalsIgnoreCase(pagePersObjParam.getObjType())) { //非法采砂督查 List result = jskejianWaterRgstrDao.getListJSWAByInspGroupIdObjType(pagePersObjParam); return result; } else if ("20".equalsIgnoreCase(pagePersObjParam.getObjType())) { //中央环保督查 List result = jskejianEcofrdRgstrDao.getListEcofrdByInspGroupIdObjType(pagePersObjParam); return result; } else if (BisInspEnum.RSML.getValue().equals(pagePersObjParam.getObjType())) { List result = bisInspRsmlRgstrDao.getListRsmlByInspGroupIdObjType(pagePersObjParam); return result; } else if (BisInspEnum.RSRAQG.getValue().equals(pagePersObjParam.getObjType())) { //量化考核 List result = bisInspRsraqgRgstrDao.getListRsraqByInspGroupIdObjType(pagePersObjParam); return result; } else if (BisInspEnum.IRR.getValue().equalsIgnoreCase(pagePersObjParam.getObjType())) { List list = bisInspIrrRgstrDao.getListByInspGroupIdObjType(pagePersObjParam); return list; } else if (BisInspEnum.SAP.getValue().equalsIgnoreCase(pagePersObjParam.getObjType())) { List list = bisInspWagaSapRgstrDao.getListByInspGroupIdObjType(pagePersObjParam); return list; } else if (BisInspEnum.EFP.getValue().equalsIgnoreCase(pagePersObjParam.getObjType())) { List 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 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 list = new ArrayList<>(); //根据type分流 if ("1".equalsIgnoreCase(inspObjParam.getObjType()) || "24".equalsIgnoreCase(inspObjParam.getObjType()) || "26".equals(inspObjParam.getObjType())) { List 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 result = attAdBaseDao.getObjListNotInspGroupId(inspObjParam.getInspGroupId(), inspObjParam.getObjType(), inspObjParam.getAdName(), inspObjParam.getAdCode(), province); return new PageInfo(result); } else if ("3".equalsIgnoreCase(inspObjParam.getObjType())) { List result = bisInspWtdstDao.getObjListNotInspGroupId(inspObjParam); return new PageInfo(result); } else if ("4".equalsIgnoreCase(inspObjParam.getObjType())) { List result = attEmpwtprjBaseDao.getObjListNotInspGroupId(inspObjParam.getInspGroupId(), inspObjParam.getObjType(), inspObjParam.getAdName(), inspObjParam.getAdCode(), province); return new PageInfo(result); } else if ("5".equalsIgnoreCase(inspObjParam.getObjType())) { List result = attGrwBaseDao.getObjListNotInspGroupId(inspObjParam.getInspGroupId(), inspObjParam.getObjType(), inspObjParam.getAdName(), inspObjParam.getAdCode(), province); return new PageInfo(result); } else if ("6".equalsIgnoreCase(inspObjParam.getObjType())) { List result = attWagaBaseDao.getObjListNotInspGroupId(inspObjParam.getInspGroupId(), inspObjParam.getObjType(), inspObjParam.getAdName(), inspObjParam.getAdCode(), province); return new PageInfo(result); } else if ("7".equalsIgnoreCase(inspObjParam.getObjType())) { List result = attEmpwtprjBaseDao.getObjListNotInspGroupId(inspObjParam.getInspGroupId(), inspObjParam.getObjType(), inspObjParam.getAdName(), inspObjParam.getAdCode(), province); return new PageInfo(result); } else if ("8".equalsIgnoreCase(inspObjParam.getObjType())) { return null; } else if ("9".equalsIgnoreCase(inspObjParam.getObjType())) { List result = attFscBaseDao.getObjListNotInspGroupId(inspObjParam.getInspGroupId(), inspObjParam.getObjType(), inspObjParam.getAdName(), inspObjParam.getAdCode(), province); return new PageInfo(result); } else if ("10".equalsIgnoreCase(inspObjParam.getObjType())) { List result = attOtherBaseDao.getObjListNotInspGroupId(inspObjParam.getInspGroupId(), inspObjParam.getObjType(), inspObjParam.getAdName(), inspObjParam.getAdCode(), province); return new PageInfo(result); } else if ("11".equalsIgnoreCase(inspObjParam.getObjType())) { List result = sdBaseDao.getObjListNotInspGroupId(inspObjParam.getInspGroupId(), inspObjParam.getObjType(), inspObjParam.getAdName(), inspObjParam.getAdCode(), province); return new PageInfo(result); } else if ("12".equalsIgnoreCase(inspObjParam.getObjType())) { List result = wiuBaseDao.getObjListNotInspGroupId(inspObjParam.getInspGroupId(), inspObjParam.getObjType(), inspObjParam.getAdName(), inspObjParam.getAdCode(), province); return new PageInfo(result); } else if ("13".equalsIgnoreCase(inspObjParam.getObjType())) { List result = swhsBaseDao.getObjListNotInspGroupId(inspObjParam.getInspGroupId(), inspObjParam.getObjType(), inspObjParam.getAdName(), inspObjParam.getAdCode(), province); return new PageInfo(result); } else if ("14".equalsIgnoreCase(inspObjParam.getObjType())) { List result = attAdXBaseDao.getObjListNotInspGroupId(inspObjParam.getInspGroupId(), inspObjParam.getObjType(), inspObjParam.getAdName(), inspObjParam.getAdCode(), province); return new PageInfo(result); } else if ("15".equalsIgnoreCase(inspObjParam.getObjType())) { List result = attAdXBaseDao.getObjListNotInspGroupId(inspObjParam.getInspGroupId(), inspObjParam.getObjType(), inspObjParam.getAdName(), inspObjParam.getAdCode(), province); return new PageInfo(result); } else if ("16".equalsIgnoreCase(inspObjParam.getObjType())) { List result = wuntBaseDao.getObjListNotInspGroupId(inspObjParam.getInspGroupId(), inspObjParam.getObjType(), inspObjParam.getAdName(), inspObjParam.getAdCode(), province); return new PageInfo(result); } else if ("17".equalsIgnoreCase(inspObjParam.getObjType())) { //生产建设项目 List result = oprdCstrProjRgstrDao.getObjPrdListNotInspGroupId(inspObjParam.getInspGroupId(), inspObjParam.getObjType(), inspObjParam.getAdName(), inspObjParam.getAdCode(), province); return new PageInfo(result); } else if ("18".equalsIgnoreCase(inspObjParam.getObjType())) { //生产建设项目 List result = jskejianFlkdisBaseDao.getObjJsFlListNotInspGroupId(inspObjParam.getInspGroupId(), inspObjParam.getObjType(), inspObjParam.getAdName(), inspObjParam.getAdCode(), province); return new PageInfo(result); } else if ("19".equalsIgnoreCase(inspObjParam.getObjType())) { //生产建设项目 List result = jskejianWaterBaseDao.getObjJsWaListNotInspGroupId(inspObjParam.getInspGroupId(), inspObjParam.getObjType(), inspObjParam.getAdName(), inspObjParam.getAdCode(), province); return new PageInfo(result); } else if ("23".equalsIgnoreCase(inspObjParam.getObjType())) { //量化考核 List result = attAdXBaseDao.getObjListNotInspGroupId(inspObjParam.getInspGroupId(), inspObjParam.getObjType(), inspObjParam.getAdName(), inspObjParam.getAdCode(), province); return new PageInfo(result); } else if (BisInspEnum.SAP.getValue().equalsIgnoreCase(inspObjParam.getObjType())) { List result = bisInspWagaSapRgstrDao.getObjListNotInspGroupId(inspObjParam.getInspGroupId(), inspObjParam.getObjType(), inspObjParam.getAdName(), inspObjParam.getAdCode(), province); return new PageInfo(result); } else if (BisInspEnum.EFP.getValue().equalsIgnoreCase(inspObjParam.getObjType())) { List result = bisInspEfpRgstrDao.getObjListNotInspGroupId(inspObjParam.getInspGroupId(), inspObjParam.getObjType(), inspObjParam.getAdName(), inspObjParam.getAdCode(), province); return new PageInfo(result); } return null; } @Override public Map addDcAndObjRel(String baseId, String objType, String inspGroupId, String objName, String objLttd, String objLgtd, String objProvincial ,String persId, String orgId) { Map 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 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 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 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 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 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 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 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 result = bisInspWtdstDao.getObjByPersId(persObjParam); exportExcel(persObjParam.getIsExport(), result, response); return result; } else if (BisInspEnum.EMPWT.getValue().equalsIgnoreCase(persObjParam.getObjType())) { List result = attEmpwtprjBaseDao.getObjByPersId(persObjParam); exportExcel(persObjParam.getIsExport(), result, response); return result; } else if (BisInspEnum.GRW.getValue().equalsIgnoreCase(persObjParam.getObjType())) { List result = attGrwBaseDao.getObjByPersId(persObjParam); exportExcel(persObjParam.getIsExport(), result, response); return result; } else if (BisInspEnum.WAGA.getValue().equalsIgnoreCase(persObjParam.getObjType())) { List result = attWagaBaseDao.getObjByPersId(persObjParam); exportExcel(persObjParam.getIsExport(), result, response); return result; } else if (BisInspObjEnum.STBPRP.getValue().equalsIgnoreCase(persObjParam.getObjType())) { //水文站 List result = stStbprpBDao.findListBy(persObjParam); exportExcel(persObjParam.getIsExport(), result, response); return result; } else if (BisInspObjEnum.PKX.getValue().equalsIgnoreCase(persObjParam.getObjType())) {//贫困县 List result = attPkxBaseDao.findListBy(persObjParam); exportExcel(persObjParam.getIsExport(), result, response); return result; } else if (BisInspObjEnum.WAIN.getValue().equalsIgnoreCase(persObjParam.getObjType())) {//取水口 List result = attWainBaseDao.findListByPersId(persObjParam); exportExcel(persObjParam.getIsExport(), result, response); return result; } else if (BisInspObjEnum.SWHS.getValue().equalsIgnoreCase(persObjParam.getObjType())) { List result = swhsBaseDao.findListBy(persObjParam); exportExcel(persObjParam.getIsExport(), result, response); return result; } else if (BisInspObjEnum.FSC.getValue().equalsIgnoreCase(persObjParam.getObjType())) { List result = attFscBaseDao.findListBy(persObjParam); exportExcel(persObjParam.getIsExport(), result, response); return result; } else if (BisInspObjEnum.OTHER.getValue().equalsIgnoreCase(persObjParam.getObjType())) { List result = attOtherBaseDao.findListBy(persObjParam); exportExcel(persObjParam.getIsExport(), result, response); return result; } else if (BisInspObjEnum.SD.getValue().equalsIgnoreCase(persObjParam.getObjType())) { List 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 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 result = this.bisInspObjDao.getKeySwhsObjByPersId(persObjParam); exportExcel(persObjParam.getIsExport(), result, response); return result; } else if (BisInspObjEnum.WINT.getValue().equalsIgnoreCase(persObjParam.getObjType())) { List 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 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 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 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 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 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 result = bisInspIrrRgstrDao.getIrrVillList(persObjParam); return result; } else if (BisInspObjEnum.IRR_WTUSR.getValue().equals(persObjParam.getObjType())) { List result = bisInspIrrRgstrDao.getIrrWtusrList(persObjParam); return result; } else if (BisInspObjEnum.IRR_TOWN.getValue().equals(persObjParam.getObjType())) { List result = bisInspIrrRgstrDao.getIrrTownList(persObjParam); return result; } else if (BisInspObjEnum.IRR_PRO.getValue().equals(persObjParam.getObjType())) { List 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 result = bisInspIrrRgstrDao.findIrrList(typeParam); return result; } else if (BisInspObjEnum.IRR_BASE.getValue().equals(persObjParam.getObjType())) { List 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 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 result = attRsBaseDao.getObjByPersId(persObjParam); return new PageInfo<>(result); } else if (BisInspEnum.VILL.getValue().equalsIgnoreCase(persObjParam.getObjType())) {//人饮行政村 List result = attAdBaseDao.getObjByPersId(persObjParam); exportExcel(persObjParam.getIsExport(), result, response); return new PageInfo(result); } else if (BisInspObjEnum.CWS.getValue().equalsIgnoreCase(persObjParam.getObjType())) {//农村饮水工程 persObjParam.setObjType(persObjParam.getObjType().substring(0, 1)); List result = attAdBaseDao.getCwsByPersId(persObjParam); exportExcel(persObjParam.getIsExport(), result, response); return new PageInfo(result); } else if (BisInspObjEnum.PSP.getValue().equalsIgnoreCase(persObjParam.getObjType())) {//水源地 persObjParam.setObjType(persObjParam.getObjType().substring(0, 1)); List result = attAdBaseDao.getPspByPersId(persObjParam); exportExcel(persObjParam.getIsExport(), result, response); return new PageInfo(result); } else if (BisInspObjEnum.COUNTRY.getValue().equalsIgnoreCase(persObjParam.getObjType())) {//督查县 List result = attAdBaseDao.getAdBaseByPersId(persObjParam); exportExcel(persObjParam.getIsExport(), result, response); return new PageInfo(result); } else if (BisInspEnum.TRACK.getValue().equalsIgnoreCase(persObjParam.getObjType())) {//水毁 List result = bisInspWtdstDao.getObjByPersId(persObjParam); exportExcel(persObjParam.getIsExport(), result, response); return new PageInfo(result); } else if (BisInspEnum.EMPWT.getValue().equalsIgnoreCase(persObjParam.getObjType())) {//172 List result = attEmpwtprjBaseDao.getObjByPersId(persObjParam); exportExcel(persObjParam.getIsExport(), result, response); return new PageInfo(result); } else if (BisInspEnum.GRW.getValue().equalsIgnoreCase(persObjParam.getObjType())) {//地下水 List result = attGrwBaseDao.getObjByPersId(persObjParam); exportExcel(persObjParam.getIsExport(), result, response); return new PageInfo(result); } else if (BisInspEnum.WAGA.getValue().equalsIgnoreCase(persObjParam.getObjType())) {//水闸 List result = attWagaBaseDao.getObjByPersId(persObjParam); exportExcel(persObjParam.getIsExport(), result, response); return new PageInfo(result); } else if (BisInspObjEnum.STBPRP.getValue().equalsIgnoreCase(persObjParam.getObjType())) { //水文站 List result = stStbprpBDao.findListBy(persObjParam); exportExcel(persObjParam.getIsExport(), result, response); return new PageInfo(result); } else if (BisInspObjEnum.PKX.getValue().equalsIgnoreCase(persObjParam.getObjType())) {//贫困县 List result = attPkxBaseDao.findListBy(persObjParam); exportExcel(persObjParam.getIsExport(), result, response); return new PageInfo(result); } else if (BisInspObjEnum.WAIN.getValue().equalsIgnoreCase(persObjParam.getObjType())) {//取水口 List result = attWainBaseDao.findListByPersId(persObjParam); exportExcel(persObjParam.getIsExport(), result, response); return new PageInfo(result); } else if (BisInspObjEnum.SWHS.getValue().equalsIgnoreCase(persObjParam.getObjType())) {//地表水 List result = swhsBaseDao.findListBy(persObjParam); exportExcel(persObjParam.getIsExport(), result, response); return new PageInfo(result); } else if (BisInspObjEnum.FSC.getValue().equalsIgnoreCase(persObjParam.getObjType())) { List result = attFscBaseDao.findListBy(persObjParam); exportExcel(persObjParam.getIsExport(), result, response); return new PageInfo(result); } else if (BisInspObjEnum.OTHER.getValue().equalsIgnoreCase(persObjParam.getObjType())) { List result = attOtherBaseDao.findListBy(persObjParam); exportExcel(persObjParam.getIsExport(), result, response); return new PageInfo(result); } else if (BisInspObjEnum.SD.getValue().equalsIgnoreCase(persObjParam.getObjType())) { List result = bisInspObjDao.getSdObjByPersId(persObjParam); exportExcel(persObjParam.getIsExport(), result, response); return new PageInfo(result); } else if (BisInspObjEnum.WINT.getValue().equalsIgnoreCase(persObjParam.getObjType())) { List result = this.bisInspObjDao.getWintObjByPersId(persObjParam); exportExcel(persObjParam.getIsExport(), result, response); return new PageInfo(result); } else if (BisInspObjEnum.KEYSWHS.getValue().equalsIgnoreCase(persObjParam.getObjType())) {//重点水源地 persObjParam.setObjType(BisInspEnum.SWHS.getValue()); List result = this.bisInspObjDao.getKeySwhsObjByPersId(persObjParam); exportExcel(persObjParam.getIsExport(), result, response); return new PageInfo(result); } else if (BisInspObjEnum.SVWT.getValue().equalsIgnoreCase(persObjParam.getObjType())) { persObjParam.setObjType(BisInspEnum.SVWT.getValue()); List result = this.bisInspObjDao.getSvwtObjByPersId(persObjParam); exportExcel(persObjParam.getIsExport(), result, response); return new PageInfo(result); } else if (BisInspObjEnum.WUNT.getValue().equalsIgnoreCase(persObjParam.getObjType())) { persObjParam.setObjType(BisInspEnum.WUNT.getValue()); List result = this.bisInspObjDao.getWuntObjByPersId(persObjParam); exportExcel(persObjParam.getIsExport(), result, response); return new PageInfo(result); } else if (BisInspObjEnum.PRD.getValue().equalsIgnoreCase(persObjParam.getObjType())) { persObjParam.setObjType(BisInspEnum.PRD.getValue()); List result = this.bisInspObjDao.getPrdObjByPersId(persObjParam); exportExcel(persObjParam.getIsExport(), result, response); return new PageInfo(result); } else if (BisInspObjEnum.JSFL.getValue().equalsIgnoreCase(persObjParam.getObjType())) { persObjParam.setObjType(BisInspEnum.JSFL.getValue()); List result = this.bisInspObjDao.getJSFLObjByPersId(persObjParam); exportExcel(persObjParam.getIsExport(), result, response); return new PageInfo(result); } else if (BisInspObjEnum.JSWA.getValue().equalsIgnoreCase(persObjParam.getObjType())) { persObjParam.setObjType(BisInspEnum.JSWA.getValue()); List result = this.bisInspObjDao.getJSWAObjByPersId(persObjParam); exportExcel(persObjParam.getIsExport(), result, response); return new PageInfo(result); } else if ("28".equalsIgnoreCase(persObjParam.getObjType())) { persObjParam.setObjType(BisInspEnum.IRR.getValue()); List 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 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 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 attGrwBaseList = this.attGrwBaseDao.getGrwNotInGroup(inGroupGrwParam); PageInfo pageInfo = new PageInfo<>(attGrwBaseList); return pageInfo; } }