c7d09b5b67f1412e80301b8aa31b8af9dfee8574.svn-base 60 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495969798991001011021031041051061071081091101111121131141151161171181191201211221231241251261271281291301311321331341351361371381391401411421431441451461471481491501511521531541551561571581591601611621631641651661671681691701711721731741751761771781791801811821831841851861871881891901911921931941951961971981992002012022032042052062072082092102112122132142152162172182192202212222232242252262272282292302312322332342352362372382392402412422432442452462472482492502512522532542552562572582592602612622632642652662672682692702712722732742752762772782792802812822832842852862872882892902912922932942952962972982993003013023033043053063073083093103113123133143153163173183193203213223233243253263273283293303313323333343353363373383393403413423433443453463473483493503513523533543553563573583593603613623633643653663673683693703713723733743753763773783793803813823833843853863873883893903913923933943953963973983994004014024034044054064074084094104114124134144154164174184194204214224234244254264274284294304314324334344354364374384394404414424434444454464474484494504514524534544554564574584594604614624634644654664674684694704714724734744754764774784794804814824834844854864874884894904914924934944954964974984995005015025035045055065075085095105115125135145155165175185195205215225235245255265275285295305315325335345355365375385395405415425435445455465475485495505515525535545555565575585595605615625635645655665675685695705715725735745755765775785795805815825835845855865875885895905915925935945955965975985996006016026036046056066076086096106116126136146156166176186196206216226236246256266276286296306316326336346356366376386396406416426436446456466476486496506516526536546556566576586596606616626636646656666676686696706716726736746756766776786796806816826836846856866876886896906916926936946956966976986997007017027037047057067077087097107117127137147157167177187197207217227237247257267277287297307317327337347357367377387397407417427437447457467477487497507517527537547557567577587597607617627637647657667677687697707717727737747757767777787797807817827837847857867877887897907917927937947957967977987998008018028038048058068078088098108118128138148158168178188198208218228238248258268278288298308318328338348358368378388398408418428438448458468478488498508518528538548558568578588598608618628638648658668678688698708718728738748758768778788798808818828838848858868878888898908918928938948958968978988999009019029039049059069079089099109119129139149159169179189199209219229239249259269279289299309319329339349359369379389399409419429439449459469479489499509519529539549559569579589599609619629639649659669679689699709719729739749759769779789799809819829839849859869879889899909919929939949959969979989991000100110021003100410051006100710081009101010111012101310141015101610171018101910201021102210231024102510261027102810291030103110321033103410351036103710381039104010411042104310441045104610471048104910501051105210531054105510561057105810591060106110621063106410651066106710681069107010711072107310741075107610771078107910801081108210831084108510861087108810891090109110921093109410951096109710981099110011011102110311041105110611071108110911101111111211131114111511161117111811191120112111221123112411251126112711281129
  1. package cn.com.goldenwater.dcproj.service.impl.ducha;
  2. import cn.com.goldenwater.core.service.AbstractCrudService;
  3. import cn.com.goldenwater.dcproj.constValue.AdCodeLabel;
  4. import cn.com.goldenwater.dcproj.constValue.BisInspEnum;
  5. import cn.com.goldenwater.dcproj.constValue.BisInspObjEnum;
  6. import cn.com.goldenwater.dcproj.constValue.SplitValue;
  7. import cn.com.goldenwater.dcproj.dao.*;
  8. import cn.com.goldenwater.dcproj.dto.AttCwsBaseDto;
  9. import cn.com.goldenwater.dcproj.dto.AttWagaSapBaseDto;
  10. import cn.com.goldenwater.dcproj.dto.BisInspAllObjDto;
  11. import cn.com.goldenwater.dcproj.dto.BisInspFscRgstrDto;
  12. import cn.com.goldenwater.dcproj.dto.BisInspKeyRegisterDto;
  13. import cn.com.goldenwater.dcproj.dto.BisInspObjDto;
  14. import cn.com.goldenwater.dcproj.dto.BisInspOtherRgstrDto;
  15. import cn.com.goldenwater.dcproj.dto.BisInspRgstrDto;
  16. import cn.com.goldenwater.dcproj.dto.BisInspSdRgstrDto;
  17. import cn.com.goldenwater.dcproj.dto.BisInspWiuRgstrDto;
  18. import cn.com.goldenwater.dcproj.dto.BisNewWateruserInfoDto;
  19. import cn.com.goldenwater.dcproj.dto.ObjectNameDto;
  20. import cn.com.goldenwater.dcproj.dto.ProSourceProtectDto;
  21. import cn.com.goldenwater.dcproj.dto.SecsurveyVlgDto;
  22. import cn.com.goldenwater.dcproj.dto.VillRgstrEngIdDto;
  23. import cn.com.goldenwater.dcproj.model.AttAdBase;
  24. import cn.com.goldenwater.dcproj.model.AttAdXBase;
  25. import cn.com.goldenwater.dcproj.model.AttEfpBase;
  26. import cn.com.goldenwater.dcproj.model.AttEmpwtprjBase;
  27. import cn.com.goldenwater.dcproj.model.AttFscBase;
  28. import cn.com.goldenwater.dcproj.model.AttGrwBase;
  29. import cn.com.goldenwater.dcproj.model.AttIrrBase;
  30. import cn.com.goldenwater.dcproj.model.AttJskejianEcofrdRgstr;
  31. import cn.com.goldenwater.dcproj.model.AttJskejianFlkdisBase;
  32. import cn.com.goldenwater.dcproj.model.AttJskejianFlkdisRgstr;
  33. import cn.com.goldenwater.dcproj.model.AttJskejianWaterBase;
  34. import cn.com.goldenwater.dcproj.model.AttJskejianWaterRgstr;
  35. import cn.com.goldenwater.dcproj.model.AttOtherBase;
  36. import cn.com.goldenwater.dcproj.model.AttPersGrw;
  37. import cn.com.goldenwater.dcproj.model.AttPersRs;
  38. import cn.com.goldenwater.dcproj.model.AttPersWtdst;
  39. import cn.com.goldenwater.dcproj.model.AttPkxBase;
  40. import cn.com.goldenwater.dcproj.model.AttPrdCstrProjBase;
  41. import cn.com.goldenwater.dcproj.model.AttRsBase;
  42. import cn.com.goldenwater.dcproj.model.AttSdBase;
  43. import cn.com.goldenwater.dcproj.model.AttSwhsBase;
  44. import cn.com.goldenwater.dcproj.model.AttWagaBase;
  45. import cn.com.goldenwater.dcproj.model.AttWagaSapBase;
  46. import cn.com.goldenwater.dcproj.model.AttWainBase;
  47. import cn.com.goldenwater.dcproj.model.AttWiuBase;
  48. import cn.com.goldenwater.dcproj.model.AttWuntBase;
  49. import cn.com.goldenwater.dcproj.model.BisInspAllObj;
  50. import cn.com.goldenwater.dcproj.model.BisInspObj;
  51. import cn.com.goldenwater.dcproj.model.BisInspOprdCstrProjRgstr;
  52. import cn.com.goldenwater.dcproj.model.BisInspRsmlRgstr;
  53. import cn.com.goldenwater.dcproj.model.BisInspSvwtAreaRgstr;
  54. import cn.com.goldenwater.dcproj.model.BisInspSvwtWuntRgstr;
  55. import cn.com.goldenwater.dcproj.model.BisInspSwhsRgstr;
  56. import cn.com.goldenwater.dcproj.model.BisInspVillRgstr;
  57. import cn.com.goldenwater.dcproj.model.BisInspWagaRgstrDto;
  58. import cn.com.goldenwater.dcproj.model.BisInspWintRgstr;
  59. import cn.com.goldenwater.dcproj.model.BisInspWtdst;
  60. import cn.com.goldenwater.dcproj.model.GrwBaseByType;
  61. import cn.com.goldenwater.dcproj.model.StStbprpB;
  62. import cn.com.goldenwater.dcproj.model.TacAttPawpBase;
  63. import cn.com.goldenwater.dcproj.param.BisInspObjParam;
  64. import cn.com.goldenwater.dcproj.param.InGroupGrwParam;
  65. import cn.com.goldenwater.dcproj.param.InspObjParam;
  66. import cn.com.goldenwater.dcproj.param.PagePersObjParam;
  67. import cn.com.goldenwater.dcproj.param.PersObjParam;
  68. import cn.com.goldenwater.dcproj.param.TypeParam;
  69. import cn.com.goldenwater.dcproj.service.AttWagaRgstrService;
  70. import cn.com.goldenwater.dcproj.service.BisInspKeyRegisterService;
  71. import cn.com.goldenwater.dcproj.service.BisInspObjService;
  72. import cn.com.goldenwater.dcproj.service.BisInspObjStrategy;
  73. import cn.com.goldenwater.dcproj.service.BisInspVillRgstrService;
  74. import cn.com.goldenwater.dcproj.service.OlBisInspOrgService;
  75. import cn.com.goldenwater.dcproj.service.SupervisionPlanService;
  76. import cn.com.goldenwater.dcproj.service.impl.system.BisInspObjFactory;
  77. import cn.com.goldenwater.dcproj.utils.AdLevelUtil;
  78. import cn.com.goldenwater.id.util.UuidUtil;
  79. import cn.com.goldenwater.target.CheckException;
  80. import cn.com.goldenwater.util.common.SqlUtils;
  81. import com.github.pagehelper.PageHelper;
  82. import com.github.pagehelper.PageInfo;
  83. import org.apache.commons.lang3.StringUtils;
  84. import org.slf4j.Logger;
  85. import org.slf4j.LoggerFactory;
  86. import org.springframework.beans.BeanUtils;
  87. import org.springframework.beans.factory.annotation.Autowired;
  88. import org.springframework.stereotype.Service;
  89. import org.springframework.transaction.annotation.Transactional;
  90. import javax.servlet.http.HttpServletResponse;
  91. import java.text.SimpleDateFormat;
  92. import java.util.ArrayList;
  93. import java.util.Date;
  94. import java.util.HashMap;
  95. import java.util.List;
  96. import java.util.Map;
  97. import java.util.Optional;
  98. import java.util.UUID;
  99. import static cn.com.goldenwater.dcproj.utils.expExcel.ExportUtil.exportExcel;
  100. /**
  101. * @author lune
  102. * @date 2019-2-18
  103. */
  104. @Service
  105. @Transactional(rollbackFor = Exception.class)
  106. public class BisInspObjServiceImpl extends AbstractCrudService<BisInspObj, BisInspObjParam> implements BisInspObjService {
  107. private static Logger logger = LoggerFactory.getLogger(BisInspObjServiceImpl.class);
  108. @Autowired
  109. private AttJskejianFlkdisBaseDao jskejianFlkdisBaseDao;
  110. @Autowired
  111. private AttJskejianFlkdisRgstrDao jskejianFlkdisRgstrDao;
  112. @Autowired
  113. private AttJskejianWaterRgstrDao jskejianWaterRgstrDao;
  114. @Autowired
  115. private AttJskejianWaterBaseDao jskejianWaterBaseDao;
  116. @Autowired
  117. private AttJskejianEcofrdRgstrDao jskejianEcofrdRgstrDao;
  118. @Autowired
  119. private BisInspRsmlRgstrDao bisInspRsmlRgstrDao;
  120. @Autowired
  121. private BisInspObjDao bisInspObjDao;
  122. @Autowired
  123. private AttSdBaseDao sdBaseDao;
  124. @Autowired
  125. private BisInspAllObjDao bisInspAllObjDao;
  126. @Autowired
  127. private AttWainBaseDao attWainBaseDao;
  128. @Autowired
  129. private AttAdXBaseDao attAdXBaseDao;
  130. @Autowired
  131. private AttWiuBaseDao wiuBaseDao;
  132. @Autowired
  133. private AttRsBaseDao attRsBaseDao;
  134. @Autowired
  135. private AttSwhsBaseDao swhsBaseDao;
  136. //取水用户
  137. //水毁
  138. @Autowired
  139. private BisInspWtdstDao bisInspWtdstDao;
  140. //农饮
  141. @Autowired
  142. private AttAdBaseDao attAdBaseDao;
  143. //农饮登记
  144. @Autowired
  145. private BisInspVillRgstrDao bisInspVillRgstrDao;
  146. @Autowired
  147. private AttGrwBaseDao attGrwBaseDao;
  148. @Autowired
  149. private AttPkxBaseDao attPkxBaseDao;
  150. @Autowired
  151. private StStbprpBDao stStbprpBDao;
  152. @Autowired
  153. private AttEmpwtprjBaseDao attEmpwtprjBaseDao;
  154. @Autowired
  155. private AttWagaBaseDao attWagaBaseDao;
  156. @Autowired
  157. private BisInspKeyRegisterService bisInspKeyRegisterService;
  158. @Autowired
  159. private BisInspVillRgstrService bisInspVillRgstrService;
  160. @Autowired
  161. private SupervisionPlanService supervisionPlanService;
  162. @Autowired
  163. private AttWuntBaseDao wuntBaseDao;
  164. @Autowired
  165. private AttWagaRgstrService attWagaRgstrService;
  166. @Autowired
  167. private OlBisInspOrgService inspOrgService;
  168. @Autowired
  169. private BisInspFscRgstrDao bisInspFscRgstrDao;
  170. @Autowired
  171. private BisInspOtherRgstrDao bisInspOtherRgstrDao;
  172. @Autowired
  173. private AttOtherBaseDao attOtherBaseDao;
  174. @Autowired
  175. private BisInspSvwtAreaRgstrDao svwtAreaRgstrDao;
  176. @Autowired
  177. private BisInspSdRgstrDao inspSdRgstrDao;
  178. @Autowired
  179. private BisInspWiuRgstrDao inspWiuRgstrDao;
  180. @Autowired
  181. private BisInspSwhsRgstrDao inspSwhsRgstrDao;
  182. @Autowired
  183. private BisInspSvwtAreaRgstrDao inspSvwtAreaRgstrDao;
  184. @Autowired
  185. private BisInspSvwtWuntRgstrDao inspSvwtWuntRgstrDao;
  186. @Autowired
  187. private BisInspWintRgstrDao wintRgstrDao;
  188. @Autowired
  189. private BisInspOprdCstrProjRgstrDao oprdCstrProjRgstrDao;
  190. @Autowired
  191. private BisInspRsraqgRgstrDao bisInspRsraqgRgstrDao;
  192. @Autowired
  193. private BisZhejiangJgRgstrDao bisZhejiangJgRgstrDao;
  194. @Autowired
  195. private BisInspWtcrrRgstrDao bisInspWtcrrRgstrDao;
  196. @Autowired
  197. private AttFscBaseDao attFscBaseDao;
  198. @Autowired
  199. private BisInspObjFactory factory;
  200. @Autowired
  201. private BisInspStstnDao bisInspStstnDao;
  202. public BisInspObjServiceImpl(BisInspObjDao bisInspObjDao) {
  203. super(bisInspObjDao);
  204. this.bisInspObjDao = bisInspObjDao;
  205. }
  206. @Override
  207. public int deleteInspObj(BisInspObj bisInspObj) {
  208. supervisionPlanService.cleanObjDataByObjId(bisInspObj.getObjType(), bisInspObj.getObjId());
  209. return 1;
  210. }
  211. @Override
  212. public List getObjListByTypeAndAdCode(PagePersObjParam pagePersObjParam) {
  213. if ("1".equalsIgnoreCase(pagePersObjParam.getObjType()) || "36".equalsIgnoreCase(pagePersObjParam.getObjType()) || "24".equalsIgnoreCase(pagePersObjParam.getObjType())) {
  214. List<AttRsBase> result = attRsBaseDao.getListByInspGroupIdObjType(pagePersObjParam);
  215. return result;
  216. } else if ("2".equalsIgnoreCase(pagePersObjParam.getObjType()) || "25".equalsIgnoreCase(pagePersObjParam.getObjType())) {
  217. List<AttAdBase> result = attAdBaseDao.getListByInspGroupIdObjType(pagePersObjParam);
  218. return result;
  219. } else if ("3".equalsIgnoreCase(pagePersObjParam.getObjType())) {
  220. List<BisInspWtdst> result = bisInspWtdstDao.getListByInspGroupIdObjType(pagePersObjParam);
  221. return result;
  222. } else if ("5".equalsIgnoreCase(pagePersObjParam.getObjType())) {
  223. List<GrwBaseByType> result = attGrwBaseDao.getListByInspGroupIdObjType(pagePersObjParam);
  224. return result;
  225. } else if ("8".equalsIgnoreCase(pagePersObjParam.getObjType())) {
  226. List<TacAttPawpBase> result = bisInspAllObjDao.getListByInspGroupIdObjType(pagePersObjParam);
  227. return result;
  228. } else if ("6".equalsIgnoreCase(pagePersObjParam.getObjType())) {
  229. List<BisInspWagaRgstrDto> result = attWagaRgstrService.getListByInspGroupIdObjType(pagePersObjParam);
  230. return result;
  231. } else if ("4".equalsIgnoreCase(pagePersObjParam.getObjType())) {
  232. //水利工程建设
  233. List<BisInspKeyRegisterDto> result = bisInspKeyRegisterService.getListByInspGroupIdObjTypeBuild(pagePersObjParam);
  234. return result;
  235. } else if ("7".equalsIgnoreCase(pagePersObjParam.getObjType())) {
  236. List<BisInspKeyRegisterDto> result = bisInspKeyRegisterService.getListByInspGroupIdObjTypeRun(pagePersObjParam);
  237. return result;
  238. } else if ("9".equalsIgnoreCase(pagePersObjParam.getObjType())) {
  239. //特定飞检
  240. List<BisInspFscRgstrDto> result = bisInspFscRgstrDao.getListByInspGroupIdObjType(pagePersObjParam);
  241. return result;
  242. } else if ("10".equalsIgnoreCase(pagePersObjParam.getObjType())) {
  243. //其他检查
  244. List<BisInspOtherRgstrDto> result = bisInspOtherRgstrDao.getListByInspGroupIdObjType(pagePersObjParam);
  245. return result;
  246. } else if ("11".equalsIgnoreCase(pagePersObjParam.getObjType())) {
  247. //淤地坝
  248. List<BisInspSdRgstrDto> result = inspSdRgstrDao.getListByInspGroupIdObjType(pagePersObjParam);
  249. return result;
  250. } else if ("12".equalsIgnoreCase(pagePersObjParam.getObjType())) {
  251. //取用水户
  252. List<BisInspWiuRgstrDto> result = inspWiuRgstrDao.getListByInspGroupIdObjType(pagePersObjParam);
  253. return result;
  254. } else if ("13".equalsIgnoreCase(pagePersObjParam.getObjType())) {
  255. //水源地
  256. List<BisInspSwhsRgstr> result = inspSwhsRgstrDao.getListByInspGroupIdObjType(pagePersObjParam);
  257. return result;
  258. } else if ("14".equalsIgnoreCase(pagePersObjParam.getObjType())) {
  259. //县级行政区
  260. List<BisInspWintRgstr> result = wintRgstrDao.getListByInspGroupIdObjType(pagePersObjParam);
  261. return result;
  262. } else if ("15".equalsIgnoreCase(pagePersObjParam.getObjType())) {
  263. //节水管理与评价
  264. List<BisInspSvwtAreaRgstr> result = inspSvwtAreaRgstrDao.getListByInspGroupIdObjType(pagePersObjParam);
  265. return result;
  266. } else if ("16".equalsIgnoreCase(pagePersObjParam.getObjType())) {
  267. //用水单位
  268. List<BisInspSvwtWuntRgstr> result = inspSvwtWuntRgstrDao.getListByInspGroupIdObjType(pagePersObjParam);
  269. return result;
  270. } else if ("17".equalsIgnoreCase(pagePersObjParam.getObjType())) {
  271. //生产建设项目
  272. List<BisInspOprdCstrProjRgstr> result = oprdCstrProjRgstrDao.getListOprdByInspGroupIdObjType(pagePersObjParam);
  273. return result;
  274. } else if ("18".equalsIgnoreCase(pagePersObjParam.getObjType())) {
  275. //河湖四乱项目
  276. List<AttJskejianFlkdisRgstr> result = jskejianFlkdisRgstrDao.getListJSFLByInspGroupIdObjType(pagePersObjParam);
  277. return result;
  278. } else if ("19".equalsIgnoreCase(pagePersObjParam.getObjType())) {
  279. //非法采砂督查
  280. List<AttJskejianWaterRgstr> result = jskejianWaterRgstrDao.getListJSWAByInspGroupIdObjType(pagePersObjParam);
  281. return result;
  282. } else if ("20".equalsIgnoreCase(pagePersObjParam.getObjType())) {
  283. //中央环保督查
  284. List<AttJskejianEcofrdRgstr> result = jskejianEcofrdRgstrDao.getListEcofrdByInspGroupIdObjType(pagePersObjParam);
  285. return result;
  286. } else if (BisInspEnum.RSML.getValue().equals(pagePersObjParam.getObjType())) {
  287. List<BisInspRsmlRgstr> result = bisInspRsmlRgstrDao.getListRsmlByInspGroupIdObjType(pagePersObjParam);
  288. return result;
  289. } else if (BisInspEnum.RSRAQG.getValue().equals(pagePersObjParam.getObjType())) {
  290. //量化考核
  291. List<AttAdBase> result = bisInspRsraqgRgstrDao.getListRsraqByInspGroupIdObjType(pagePersObjParam);
  292. return result;
  293. } else if (BisInspEnum.IRR.getValue().equalsIgnoreCase(pagePersObjParam.getObjType())) {
  294. List<AttIrrBase> list = bisInspIrrRgstrDao.getListByInspGroupIdObjType(pagePersObjParam);
  295. return list;
  296. } else if (BisInspEnum.SAP.getValue().equalsIgnoreCase(pagePersObjParam.getObjType())) {
  297. List<AttWagaSapBase> list = bisInspWagaSapRgstrDao.getListByInspGroupIdObjType(pagePersObjParam);
  298. return list;
  299. } else if (BisInspEnum.EFP.getValue().equalsIgnoreCase(pagePersObjParam.getObjType())) {
  300. List<AttEfpBase> list = bisInspEfpRgstrDao.getListByInspGroupIdObjType(pagePersObjParam);
  301. return list;
  302. }
  303. return null;
  304. }
  305. @Autowired
  306. private BisInspIrrRgstrDao bisInspIrrRgstrDao;
  307. @Autowired
  308. private BisInspWagaSapRgstrDao bisInspWagaSapRgstrDao;
  309. @Autowired
  310. private BisInspEfpRgstrDao bisInspEfpRgstrDao;
  311. @Autowired
  312. private BisInspSvwtWuntRgstrDao bisInspSvwtWuntRgstrDao;
  313. @Autowired
  314. private BisInspSamrmpRgstrDao bisInspSamrmpRgstrDao;
  315. @Autowired
  316. private BisInspWrmRgstrDao bisInspWrmRgstrDao;
  317. @Autowired
  318. private BisInspWintuRgstrDao bisInspWintuRgstrDao;
  319. @Autowired
  320. private BisInspWtgtRgstrDao bisInspWtgtRgstrDao;
  321. @Autowired
  322. private BisInspWtgthRgstrDao bisInspWtgthRgstrDao;
  323. @Autowired
  324. private BisInspCdepRgstrDao bisInspCdepRgstrDao;
  325. @Autowired
  326. private BisInspBidRgstrDao bisInspBidRgstrDao;
  327. @Autowired
  328. private BisInspRlrwRgstrDao bisInspRlrwRgstrDao;
  329. @Autowired
  330. private BisInspGrowRgstrDao bisInspGrowRgstrDao;
  331. @Autowired
  332. private BisInspFundRgstrDao bisInspFundRgstrDao;
  333. @Autowired
  334. private BisInspDrdmpRgstrDao bisInspDrdmpRgstrDao;
  335. @Autowired
  336. private BisInspRsvrSdDao bisInspRsvrSdDao;
  337. @Autowired
  338. private BisInspHystpDao bisInspHystpDao;
  339. @Autowired
  340. private BisInspJspwiuDao bisInspJspwiuDao;
  341. @Autowired
  342. private BisInspJspwiu2024Dao bisInspJspwiu2024Dao;
  343. @Override
  344. public PageInfo getObjListByGroupIdAndType(PagePersObjParam pagePersObjParam) {
  345. //设置分页
  346. PageHelper.startPage(pagePersObjParam.getPageNum(), pagePersObjParam.getPageSize());
  347. List result = getListByInspGroupIdObjType(pagePersObjParam);
  348. return new PageInfo<>(result);
  349. }
  350. private List getListByInspGroupIdObjType(PagePersObjParam pagePersObjParam) {
  351. //根据type分流
  352. BisInspEnum bisInspEnum = BisInspEnum.getEnumByType(pagePersObjParam.getObjType());
  353. Optional.ofNullable(bisInspEnum).orElseThrow(() -> new CheckException("未找到与 objType:" + pagePersObjParam.getObjType() + " 相对应的督查项!"));
  354. switch (bisInspEnum) {
  355. case REVER:
  356. case REVER2:
  357. case STND:
  358. case RSFCO:
  359. case RSSFDR:
  360. case RSSFGD:
  361. case RSFCOQH:
  362. case RSVRYN:
  363. return attRsBaseDao.getListByInspGroupIdObjType(pagePersObjParam);
  364. case IRR:
  365. case VILL:
  366. case VILL2020:
  367. case VILL2021:
  368. case VILLZHEJIANG:
  369. case VILLQH:
  370. case VILLGD:
  371. case MFDP:
  372. case RDWSP:
  373. case WRWS:
  374. case WRWX:
  375. case MFDPQH:
  376. case SVWTQH:
  377. case XJVILL:
  378. return attAdBaseDao.getListByInspGroupIdObjType(pagePersObjParam);
  379. case TRACK:// 水毁
  380. return bisInspWtdstDao.getListByInspGroupIdObjType(pagePersObjParam);
  381. case GRW:
  382. return attGrwBaseDao.getListByInspGroupIdObjType(pagePersObjParam);
  383. case PAWP:
  384. return bisInspAllObjDao.getListByInspGroupIdObjType(pagePersObjParam);
  385. case WAGA:
  386. case WAGAJS:
  387. return attWagaRgstrService.getListByInspGroupIdObjType(pagePersObjParam);
  388. case EMPWT:
  389. case KEYSAFQH:
  390. case KEYCHKQH:
  391. //水利工程建设
  392. return bisInspKeyRegisterService.getListByInspGroupIdObjTypeBuild(pagePersObjParam);
  393. case EMPWTRUN:
  394. return bisInspKeyRegisterService.getListByInspGroupIdObjTypeRun(pagePersObjParam);
  395. case FSC:
  396. //特定飞检
  397. return bisInspFscRgstrDao.getListByInspGroupIdObjType(pagePersObjParam);
  398. case OTHER:
  399. //其他检查
  400. return bisInspOtherRgstrDao.getListByInspGroupIdObjType(pagePersObjParam);
  401. case SD:
  402. //淤地坝
  403. return inspSdRgstrDao.getListByInspGroupIdObjType(pagePersObjParam);
  404. case WIU:
  405. //取用水户
  406. return inspWiuRgstrDao.getListByInspGroupIdObjType(pagePersObjParam);
  407. case SWHS:
  408. //水源地
  409. return inspSwhsRgstrDao.getListByInspGroupIdObjType(pagePersObjParam);
  410. case CITY:
  411. //县级行政区
  412. return wintRgstrDao.getListByInspGroupIdObjType(pagePersObjParam);
  413. case SVWT:
  414. //节水管理与评价
  415. return inspSvwtAreaRgstrDao.getListByInspGroupIdObjType(pagePersObjParam);
  416. case WUNT:
  417. //用水单位
  418. return inspSvwtWuntRgstrDao.getListByInspGroupIdObjType(pagePersObjParam);
  419. case PRD:
  420. //水保工作核实
  421. return oprdCstrProjRgstrDao.getListOprdByInspGroupIdObjType(pagePersObjParam);
  422. case JSFL:
  423. //河湖四乱项目
  424. return jskejianFlkdisRgstrDao.getListJSFLByInspGroupIdObjType(pagePersObjParam);
  425. case JSWA:
  426. //非法采砂督查
  427. return jskejianWaterRgstrDao.getListJSWAByInspGroupIdObjType(pagePersObjParam);
  428. case ECOFRD:
  429. //中央环保督查
  430. return jskejianEcofrdRgstrDao.getListEcofrdByInspGroupIdObjType(pagePersObjParam);
  431. case RSML:
  432. case RSLKBK:
  433. return bisInspRsmlRgstrDao.getListRsmlByInspGroupIdObjType(pagePersObjParam);
  434. case RSRAQG:
  435. //量化考核
  436. return bisInspRsraqgRgstrDao.getListRsraqByInspGroupIdObjType(pagePersObjParam);
  437. case BIS_ZHEJIANG_JG_RGSTR:
  438. return bisZhejiangJgRgstrDao.getListByInspGroupIdObjType(pagePersObjParam);
  439. case SAP:
  440. return bisInspWagaSapRgstrDao.getListByInspGroupIdObjType(pagePersObjParam);
  441. case EFP:
  442. return bisInspEfpRgstrDao.getListByInspGroupIdObjType(pagePersObjParam);
  443. case WINTU:
  444. // 31.取用水督查
  445. return bisInspWintuRgstrDao.getListByInspGroupIdObjType(pagePersObjParam);
  446. case WRM:
  447. case WTGOV:
  448. case CHMCLS:
  449. case WRM2021:
  450. // 32.水资源
  451. return bisInspWrmRgstrDao.getListByInspGroupIdObjType(pagePersObjParam);
  452. case WTUNT:
  453. // 33.节约用水
  454. return bisInspSvwtWuntRgstrDao.getListByInspGroupIdObjType(pagePersObjParam);
  455. case SAMRMP:
  456. // 35.中小河流
  457. return bisInspSamrmpRgstrDao.getListByInspGroupIdObjType(pagePersObjParam);
  458. case WTCRR:
  459. // 54.节水载体复核表
  460. return bisInspWtcrrRgstrDao.getListByInspGroupIdObjType(pagePersObjParam);
  461. case WTGT:
  462. // 55.取水许可管理复核表
  463. return bisInspWtgtRgstrDao.getListByInspGroupIdObjType(pagePersObjParam);
  464. case WTGTH:
  465. // 57.取水许可管理复核表
  466. return bisInspWtgthRgstrDao.getListByInspGroupIdObjType(pagePersObjParam);
  467. case CDEP:
  468. // 62.乙级检测单位
  469. return bisInspCdepRgstrDao.getListByInspGroupIdObjType(pagePersObjParam);
  470. case BID:
  471. // 67.招投标
  472. return bisInspBidRgstrDao.getListByInspGroupIdObjType(pagePersObjParam);
  473. case RLRW:
  474. // 68.退地减水
  475. return bisInspRlrwRgstrDao.getListByInspGroupIdObjType(pagePersObjParam);
  476. case GROW:
  477. // 70.地下水压采
  478. return bisInspGrowRgstrDao.getListByInspGroupIdObjType(pagePersObjParam);
  479. case FUND:
  480. // 98.水利资金
  481. return bisInspFundRgstrDao.getListByInspGroupIdObjType(pagePersObjParam);
  482. case RSVRSD:
  483. return bisInspRsvrSdDao.getListByInspGroupIdObjType(pagePersObjParam);
  484. case HYSTP:
  485. return bisInspHystpDao.getListByInspGroupIdObjType(pagePersObjParam);
  486. // 120 江苏计划用水户及取水口督查
  487. case JSPWIU:
  488. return bisInspJspwiuDao.getListByInspGroupIdObjType(pagePersObjParam);
  489. // 126 江苏取用水户督查
  490. case JSPWIU2024:
  491. return bisInspJspwiu2024Dao.getListByInspGroupIdObjType(pagePersObjParam);
  492. default:
  493. TypeParam typeParam = new TypeParam();
  494. BeanUtils.copyProperties(pagePersObjParam, typeParam);
  495. typeParam.setpType(pagePersObjParam.getObjType());
  496. typeParam.setGroupId(pagePersObjParam.getInspGroupId());
  497. typeParam.setPresId(pagePersObjParam.getPersId());
  498. if (StringUtils.isBlank(typeParam.getNm()) &&
  499. StringUtils.isNotBlank(pagePersObjParam.getWtdstNm())) {
  500. typeParam.setNm(pagePersObjParam.getWtdstNm());
  501. }
  502. BisInspObjStrategy strategy = factory.createStrategy(pagePersObjParam.getObjType());
  503. return (List) strategy.findObjListByType(typeParam);
  504. }
  505. }
  506. @Override
  507. public Object getObjListNotInspGroupId(InspObjParam inspObjParam) {
  508. if (!StringUtils.isBlank(inspObjParam.getAdCode())) {
  509. Map<String, Object> map = AdLevelUtil.SubAd(inspObjParam.getAdCode());
  510. logger.debug("adCode:"+String.valueOf(inspObjParam.getAdCode()));
  511. if(null != map.get("subAd")){
  512. inspObjParam.setAdCode(map.get("subAd").toString());
  513. }
  514. }
  515. String province = inspObjParam.getProvince();
  516. //查询该节点是否设置督查区域
  517. //设置分页
  518. PageHelper.startPage(inspObjParam.getPageNum(), inspObjParam.getPageSize());
  519. List<Object> list = new ArrayList<>();
  520. //根据type分流
  521. if ("1".equalsIgnoreCase(inspObjParam.getObjType()) || "24".equalsIgnoreCase(inspObjParam.getObjType()) || "26".equals(inspObjParam.getObjType())) {
  522. List<AttRsBase> result = attRsBaseDao.getObjListNotInspGroupId(inspObjParam.getInspGroupId(), inspObjParam.getObjType(),
  523. inspObjParam.getRsName(), inspObjParam.getEngScal(), inspObjParam.getRsAdmDep(), inspObjParam.getAdCode(), province);
  524. return new PageInfo<>(result);
  525. } else if ("2".equalsIgnoreCase(inspObjParam.getObjType()) || "27".equals(inspObjParam.getObjType()) || "25".equals(inspObjParam.getObjType())) {
  526. List<AttAdBase> result = attAdBaseDao.getObjListNotInspGroupId(inspObjParam.getInspGroupId(), inspObjParam.getObjType(), inspObjParam.getAdName(), inspObjParam.getAdCode(), province);
  527. return new PageInfo<AttAdBase>(result);
  528. } else if ("3".equalsIgnoreCase(inspObjParam.getObjType())) {
  529. List<BisInspWtdst> result = bisInspWtdstDao.getObjListNotInspGroupId(inspObjParam);
  530. return new PageInfo<BisInspWtdst>(result);
  531. } else if ("4".equalsIgnoreCase(inspObjParam.getObjType())) {
  532. List<AttEmpwtprjBase> result = attEmpwtprjBaseDao.getObjListNotInspGroupId(inspObjParam.getInspGroupId(), inspObjParam.getObjType(),
  533. inspObjParam.getAdName(), inspObjParam.getAdCode(), province);
  534. return new PageInfo<AttEmpwtprjBase>(result);
  535. } else if ("5".equalsIgnoreCase(inspObjParam.getObjType())) {
  536. List<AttGrwBase> result = attGrwBaseDao.getObjListNotInspGroupId(inspObjParam.getInspGroupId(), inspObjParam.getObjType(),
  537. inspObjParam.getAdName(), inspObjParam.getAdCode(), province);
  538. return new PageInfo<AttGrwBase>(result);
  539. } else if ("6".equalsIgnoreCase(inspObjParam.getObjType())) {
  540. List<AttWagaBase> result = attWagaBaseDao.getObjListNotInspGroupId(inspObjParam.getInspGroupId(), inspObjParam.getObjType(),
  541. inspObjParam.getAdName(), inspObjParam.getAdCode(), province);
  542. return new PageInfo<AttWagaBase>(result);
  543. } else if ("7".equalsIgnoreCase(inspObjParam.getObjType())) {
  544. List<AttEmpwtprjBase> result = attEmpwtprjBaseDao.getObjListNotInspGroupId(inspObjParam.getInspGroupId(), inspObjParam.getObjType(),
  545. inspObjParam.getAdName(), inspObjParam.getAdCode(), province);
  546. return new PageInfo<AttEmpwtprjBase>(result);
  547. } else if ("8".equalsIgnoreCase(inspObjParam.getObjType())) {
  548. return null;
  549. } else if ("9".equalsIgnoreCase(inspObjParam.getObjType())) {
  550. List<AttFscBase> result = attFscBaseDao.getObjListNotInspGroupId(inspObjParam.getInspGroupId(), inspObjParam.getObjType(),
  551. inspObjParam.getAdName(), inspObjParam.getAdCode(), province);
  552. return new PageInfo<AttFscBase>(result);
  553. } else if ("10".equalsIgnoreCase(inspObjParam.getObjType())) {
  554. List<AttOtherBase> result = attOtherBaseDao.getObjListNotInspGroupId(inspObjParam.getInspGroupId(), inspObjParam.getObjType(),
  555. inspObjParam.getAdName(), inspObjParam.getAdCode(), province);
  556. return new PageInfo<AttOtherBase>(result);
  557. } else if ("11".equalsIgnoreCase(inspObjParam.getObjType())) {
  558. List<AttSdBase> result = sdBaseDao.getObjListNotInspGroupId(inspObjParam.getInspGroupId(), inspObjParam.getObjType(),
  559. inspObjParam.getAdName(), inspObjParam.getAdCode(), province);
  560. return new PageInfo<AttSdBase>(result);
  561. } else if ("12".equalsIgnoreCase(inspObjParam.getObjType())) {
  562. List<AttWiuBase> result = wiuBaseDao.getObjListNotInspGroupId(inspObjParam.getInspGroupId(), inspObjParam.getObjType(),
  563. inspObjParam.getAdName(), inspObjParam.getAdCode(), province);
  564. return new PageInfo<AttWiuBase>(result);
  565. } else if ("13".equalsIgnoreCase(inspObjParam.getObjType())) {
  566. List<AttSwhsBase> result = swhsBaseDao.getObjListNotInspGroupId(inspObjParam.getInspGroupId(), inspObjParam.getObjType(),
  567. inspObjParam.getAdName(), inspObjParam.getAdCode(), province);
  568. return new PageInfo<AttSwhsBase>(result);
  569. } else if ("14".equalsIgnoreCase(inspObjParam.getObjType())) {
  570. List<AttAdXBase> result = attAdXBaseDao.getObjListNotInspGroupId(inspObjParam.getInspGroupId(), inspObjParam.getObjType(),
  571. inspObjParam.getAdName(), inspObjParam.getAdCode(), province);
  572. return new PageInfo<AttAdXBase>(result);
  573. } else if ("15".equalsIgnoreCase(inspObjParam.getObjType())) {
  574. List<AttAdXBase> result = attAdXBaseDao.getObjListNotInspGroupId(inspObjParam.getInspGroupId(), inspObjParam.getObjType(),
  575. inspObjParam.getAdName(), inspObjParam.getAdCode(), province);
  576. return new PageInfo<AttAdXBase>(result);
  577. } else if ("16".equalsIgnoreCase(inspObjParam.getObjType())) {
  578. List<AttWuntBase> result = wuntBaseDao.getObjListNotInspGroupId(inspObjParam.getInspGroupId(), inspObjParam.getObjType(),
  579. inspObjParam.getAdName(), inspObjParam.getAdCode(), province);
  580. return new PageInfo<AttWuntBase>(result);
  581. } else if ("17".equalsIgnoreCase(inspObjParam.getObjType())) {
  582. //生产建设项目
  583. List<AttPrdCstrProjBase> result = oprdCstrProjRgstrDao.getObjPrdListNotInspGroupId(inspObjParam.getInspGroupId(), inspObjParam.getObjType(),
  584. inspObjParam.getAdName(), inspObjParam.getAdCode(), province);
  585. return new PageInfo<AttPrdCstrProjBase>(result);
  586. } else if ("18".equalsIgnoreCase(inspObjParam.getObjType())) {
  587. //生产建设项目
  588. List<AttJskejianFlkdisBase> result = jskejianFlkdisBaseDao.getObjJsFlListNotInspGroupId(inspObjParam.getInspGroupId(), inspObjParam.getObjType(),
  589. inspObjParam.getAdName(), inspObjParam.getAdCode(), province);
  590. return new PageInfo<AttJskejianFlkdisBase>(result);
  591. } else if ("19".equalsIgnoreCase(inspObjParam.getObjType())) {
  592. //生产建设项目
  593. List<AttJskejianWaterBase> result = jskejianWaterBaseDao.getObjJsWaListNotInspGroupId(inspObjParam.getInspGroupId(), inspObjParam.getObjType(),
  594. inspObjParam.getAdName(), inspObjParam.getAdCode(), province);
  595. return new PageInfo<AttJskejianWaterBase>(result);
  596. } else if ("23".equalsIgnoreCase(inspObjParam.getObjType())) {
  597. //量化考核
  598. List<AttAdXBase> result = attAdXBaseDao.getObjListNotInspGroupId(inspObjParam.getInspGroupId(), inspObjParam.getObjType(),
  599. inspObjParam.getAdName(), inspObjParam.getAdCode(), province);
  600. return new PageInfo<AttAdXBase>(result);
  601. } else if (BisInspEnum.SAP.getValue().equalsIgnoreCase(inspObjParam.getObjType())) {
  602. List<AttWagaSapBase> result = bisInspWagaSapRgstrDao.getObjListNotInspGroupId(inspObjParam.getInspGroupId(), inspObjParam.getObjType(),
  603. inspObjParam.getAdName(), inspObjParam.getAdCode(), province);
  604. return new PageInfo<AttWagaSapBase>(result);
  605. } else if (BisInspEnum.EFP.getValue().equalsIgnoreCase(inspObjParam.getObjType())) {
  606. List<AttEfpBase> result = bisInspEfpRgstrDao.getObjListNotInspGroupId(inspObjParam.getInspGroupId(), inspObjParam.getObjType(),
  607. inspObjParam.getAdName(), inspObjParam.getAdCode(), province);
  608. return new PageInfo<AttEfpBase>(result);
  609. }
  610. return null;
  611. }
  612. @Override
  613. public Map<String, Object> addDcAndObjRel(String baseId, String objType, String inspGroupId, String objName,
  614. String objLttd, String objLgtd, String objProvincial ,String persId, String orgId) {
  615. Map<String, Object> ret = new HashMap<>();
  616. boolean isSuccess = true;
  617. StringBuilder objStringBuilder = new StringBuilder();
  618. //处理参数添加
  619. String[] baseIdArray = baseId.split(SplitValue.DOUHAO_SPLIT);
  620. String[] objNameArray = objName.split(SplitValue.DOUHAO_SPLIT);
  621. String[] objLttdArray = objLttd.split(SplitValue.DOUHAO_SPLIT);
  622. String[] objLgtdArray = objLgtd.split(SplitValue.DOUHAO_SPLIT);
  623. String[] provincialArray = objProvincial.split(SplitValue.DOUHAO_SPLIT);
  624. String province = inspOrgService.getProvince(orgId);
  625. // 循环对象
  626. for (int i = 0; i < baseIdArray.length; i++) {
  627. // 基础表ID为空时跳过
  628. if (StringUtils.isBlank(baseIdArray[i])) {
  629. continue;
  630. }
  631. // 组装 bisInspAllObj
  632. BisInspAllObj bisInspAllObj = new BisInspAllObj();
  633. bisInspAllObj.setId(inspGroupId);
  634. bisInspAllObj.setObjId(UuidUtil.uuid());
  635. bisInspAllObj.setCode(baseIdArray[i]);
  636. bisInspAllObj.setPtype(objType);
  637. bisInspAllObj.setNm(objNameArray[i]);
  638. // 增加 督察对象 是否省属 属性 1是2否 add by lxf 2022/10/10
  639. logger.debug("Provincial: "+provincialArray[i]);
  640. String tmp = ("null".equalsIgnoreCase(provincialArray[i])||"".equals(provincialArray[i]))?null:provincialArray[i];
  641. if(null != tmp && "是,否".contains(tmp)){
  642. tmp = "是".equals(tmp)?"1":"2";
  643. }
  644. if(null != tmp && !"1".equals(tmp) && !"2".equals(tmp)){
  645. tmp = "2";
  646. }
  647. bisInspAllObj.setProvincial(tmp);
  648. if (!province.startsWith(AdCodeLabel.START_PARENT_ADCODE)) {
  649. bisInspAllObj.setAdCode(province);
  650. bisInspAllObj.setOrgId(orgId);
  651. } else {
  652. orgId = "";
  653. }
  654. if (objLttdArray.length > 0 && !"".equals(objLttdArray[i]) &&
  655. !"null".equals(objLttdArray[i])) {
  656. bisInspAllObj.setLgtd(Double.parseDouble(objLgtdArray[i]));
  657. bisInspAllObj.setLttd(Double.parseDouble(objLttdArray[i]));
  658. }
  659. // obj 重复校验
  660. BisInspAllObjDto baj = this.bisInspAllObjDao.getObj(bisInspAllObj);
  661. if (baj != null) {
  662. isSuccess = false;
  663. ObjectNameDto ond = this.bisInspAllObjDao.getGroup(bisInspAllObj.getId());
  664. objStringBuilder.append(ond.getName()).append("、");
  665. continue;
  666. }
  667. bisInspAllObjDao.insert(bisInspAllObj);
  668. if ("36".equals(objType)) {
  669. // 36 走小水库
  670. objType = "1";
  671. }
  672. BisInspObjStrategy strategy = factory.createStrategy(objType);
  673. strategy.insertObj(bisInspAllObj, persId);
  674. }
  675. if (isSuccess) {
  676. ret.put("code", "200");
  677. ret.put("mess", "添加成功");
  678. } else {
  679. ret.put("code", "201");
  680. ret.put("mess", objStringBuilder.toString().substring(0, objStringBuilder.toString().length() - 1) + "重复添加");
  681. }
  682. return ret;
  683. }
  684. @Autowired
  685. private BisNewVillRgstrDao bisNewVillRgstrDao;
  686. @Override
  687. public List getObjByPersId(PersObjParam persObjParam, HttpServletResponse response) {
  688. if (StringUtils.isNotBlank(persObjParam.getAdCode())) {
  689. persObjParam.setAdCode(AdLevelUtil.SubAd(persObjParam.getAdCode()).get("subAd").toString());
  690. }
  691. persObjParam.setInIdsSql(SqlUtils.getinIdsSql(persObjParam.getPersGuid(), persObjParam.getProvince()));
  692. BisInspEnum bisInspEnum = BisInspEnum.getEnumByType(persObjParam.getObjType());
  693. Optional.ofNullable(bisInspEnum).orElseThrow(() -> new CheckException("未找到与 objType:" + persObjParam.getObjType() + " 相对应的督查项!"));
  694. //根据type分流
  695. switch (bisInspEnum) {
  696. case SAP:
  697. List<AttWagaSapBaseDto> result = this.bisInspObjDao.getSapObjByPersId(persObjParam);
  698. exportExcel(persObjParam.getIsExport(), result, response);
  699. return result;
  700. case SAP_BASE:
  701. return bisInspObjDao.getSapBaseList(persObjParam);
  702. case SAP_OBJ:
  703. TypeParam typeParam = new TypeParam();
  704. typeParam.setPresId(persObjParam.getPersGuid());
  705. typeParam.setRsName(persObjParam.getRsName());
  706. typeParam.setState(persObjParam.getState());
  707. typeParam.setAdCode(persObjParam.getAdCode());
  708. typeParam.setpType(BisInspEnum.SAP.getValue());
  709. typeParam.setProvince(persObjParam.getProvince());
  710. return this.bisInspWagaSapRgstrDao.getWagaSapRegstrInfo(typeParam);
  711. default:
  712. }
  713. if (BisInspEnum.REVER.getValue().equalsIgnoreCase(persObjParam.getObjType())) {
  714. List<AttPersRs> result = attRsBaseDao.getObjByPersId(persObjParam);
  715. exportExcel(persObjParam.getIsExport(), result, response);
  716. return result;
  717. } else if (BisInspEnum.VILL.getValue().equalsIgnoreCase(persObjParam.getObjType())) {
  718. if (persObjParam.getProvince().length() == 12) {
  719. persObjParam.setProvince(persObjParam.getProvince().substring(0, 2));
  720. }
  721. List<SecsurveyVlgDto> result = attAdBaseDao.getObjByPersId(persObjParam);
  722. exportExcel(persObjParam.getIsExport(), result, response);
  723. return result;
  724. } else if (BisInspEnum.VILL2020.getValue().equalsIgnoreCase(persObjParam.getObjType())) {
  725. if (persObjParam.getProvince().length() == 12) {
  726. persObjParam.setProvince(persObjParam.getProvince().substring(0, 2));
  727. }
  728. List<BisNewWateruserInfoDto> result = bisNewVillRgstrDao.getVill20ByPersId(persObjParam);
  729. exportExcel(persObjParam.getIsExport(), result, response);
  730. return result;
  731. } else if (BisInspObjEnum.CWS.getValue().equalsIgnoreCase(persObjParam.getObjType())) {
  732. if (persObjParam.getProvince().length() == 12) {
  733. persObjParam.setProvince(persObjParam.getProvince().substring(0, 2));
  734. }
  735. persObjParam.setObjType(persObjParam.getObjType().substring(0, 1));
  736. List<AttCwsBaseDto> result = attAdBaseDao.getCwsByPersId(persObjParam);
  737. exportExcel(persObjParam.getIsExport(), result, response);
  738. return result;
  739. } else if (BisInspObjEnum.PSP.getValue().equalsIgnoreCase(persObjParam.getObjType())) {
  740. persObjParam.setObjType(persObjParam.getObjType().substring(0, 1));
  741. List<ProSourceProtectDto> result = attAdBaseDao.getPspByPersId(persObjParam);
  742. exportExcel(persObjParam.getIsExport(), result, response);
  743. return result;
  744. } else if (BisInspObjEnum.COUNTRY.getValue().equalsIgnoreCase(persObjParam.getObjType())) {
  745. persObjParam.setObjType(persObjParam.getObjType().substring(0, 1));
  746. List<AttAdBase> result = attAdBaseDao.getAdBaseByPersId(persObjParam);
  747. exportExcel(persObjParam.getIsExport(), result, response);
  748. return result;
  749. } else if (BisInspEnum.TRACK.getValue().equalsIgnoreCase(persObjParam.getObjType())) {
  750. if (persObjParam.getProvince().length() == 12) {
  751. persObjParam.setProvince(persObjParam.getProvince().substring(0, 2));
  752. }
  753. List<AttPersWtdst> result = bisInspWtdstDao.getObjByPersId(persObjParam);
  754. exportExcel(persObjParam.getIsExport(), result, response);
  755. return result;
  756. } else if (BisInspEnum.EMPWT.getValue().equalsIgnoreCase(persObjParam.getObjType())) {
  757. List<AttEmpwtprjBase> result = attEmpwtprjBaseDao.getObjByPersId(persObjParam);
  758. exportExcel(persObjParam.getIsExport(), result, response);
  759. return result;
  760. } else if (BisInspEnum.GRW.getValue().equalsIgnoreCase(persObjParam.getObjType())) {
  761. List<AttPersGrw> result = attGrwBaseDao.getObjByPersId(persObjParam);
  762. exportExcel(persObjParam.getIsExport(), result, response);
  763. return result;
  764. } else if (BisInspEnum.WAGA.getValue().equalsIgnoreCase(persObjParam.getObjType())) {
  765. List<AttWagaBase> result = attWagaBaseDao.getObjByPersId(persObjParam);
  766. exportExcel(persObjParam.getIsExport(), result, response);
  767. return result;
  768. } else if (BisInspObjEnum.STBPRP.getValue().equalsIgnoreCase(persObjParam.getObjType())) { //水文站
  769. List<StStbprpB> result = stStbprpBDao.findListBy(persObjParam);
  770. exportExcel(persObjParam.getIsExport(), result, response);
  771. return result;
  772. } else if (BisInspObjEnum.PKX.getValue().equalsIgnoreCase(persObjParam.getObjType())) {//贫困县
  773. List<AttPkxBase> result = attPkxBaseDao.findListBy(persObjParam);
  774. exportExcel(persObjParam.getIsExport(), result, response);
  775. return result;
  776. } else if (BisInspObjEnum.WAIN.getValue().equalsIgnoreCase(persObjParam.getObjType())) {//取水口
  777. List<AttWainBase> result = attWainBaseDao.findListByPersId(persObjParam);
  778. exportExcel(persObjParam.getIsExport(), result, response);
  779. return result;
  780. } else if (BisInspObjEnum.SWHS.getValue().equalsIgnoreCase(persObjParam.getObjType())) {
  781. List<AttSwhsBase> result = swhsBaseDao.findListBy(persObjParam);
  782. exportExcel(persObjParam.getIsExport(), result, response);
  783. return result;
  784. } else if (BisInspObjEnum.FSC.getValue().equalsIgnoreCase(persObjParam.getObjType())) {
  785. List<AttFscBase> result = attFscBaseDao.findListBy(persObjParam);
  786. exportExcel(persObjParam.getIsExport(), result, response);
  787. return result;
  788. } else if (BisInspObjEnum.OTHER.getValue().equalsIgnoreCase(persObjParam.getObjType())) {
  789. List<AttOtherBase> result = attOtherBaseDao.findListBy(persObjParam);
  790. exportExcel(persObjParam.getIsExport(), result, response);
  791. return result;
  792. } else if (BisInspObjEnum.SD.getValue().equalsIgnoreCase(persObjParam.getObjType())) {
  793. List<BisInspObjDto> result = bisInspObjDao.getSdObjByPersId(persObjParam);
  794. exportExcel(persObjParam.getIsExport(), result, response);
  795. return result;
  796. } else if (BisInspObjEnum.WIU.getValue().equalsIgnoreCase(persObjParam.getObjType())) {//取用水户
  797. persObjParam.setObjType(BisInspEnum.WIU.getValue());
  798. List<BisInspObjDto> result = this.bisInspObjDao.getWiuObjByPersId(persObjParam);
  799. exportExcel(persObjParam.getIsExport(), result, response);
  800. return result;
  801. } else if (BisInspObjEnum.KEYSWHS.getValue().equalsIgnoreCase(persObjParam.getObjType())) {//重点水源地
  802. persObjParam.setObjType(BisInspEnum.SWHS.getValue());
  803. List<BisInspObjDto> result = this.bisInspObjDao.getKeySwhsObjByPersId(persObjParam);
  804. exportExcel(persObjParam.getIsExport(), result, response);
  805. return result;
  806. } else if (BisInspObjEnum.WINT.getValue().equalsIgnoreCase(persObjParam.getObjType())) {
  807. List<BisInspObjDto> result = this.bisInspObjDao.getWintObjByPersId(persObjParam);
  808. exportExcel(persObjParam.getIsExport(), result, response);
  809. return result;
  810. } else if (BisInspObjEnum.SVWT.getValue().equals(persObjParam.getObjType())) {
  811. persObjParam.setObjType(BisInspEnum.SVWT.getValue());
  812. List<BisInspObjDto> result = this.bisInspObjDao.getSvwtObjByPersId(persObjParam);
  813. exportExcel(persObjParam.getIsExport(), result, response);
  814. return result;
  815. } else if (BisInspObjEnum.WUNT.getValue().equals(persObjParam.getObjType())) {
  816. persObjParam.setObjType(BisInspEnum.WUNT.getValue());
  817. List<BisInspObjDto> result = this.bisInspObjDao.getWuntObjByPersId(persObjParam);
  818. exportExcel(persObjParam.getIsExport(), result, response);
  819. return result;
  820. } else if (BisInspObjEnum.PRD.getValue().equals(persObjParam.getObjType())) {
  821. persObjParam.setObjType(BisInspEnum.PRD.getValue());
  822. List<BisInspObjDto> result = this.bisInspObjDao.getPrdObjByPersId(persObjParam);
  823. exportExcel(persObjParam.getIsExport(), result, response);
  824. return result;
  825. } else if (BisInspObjEnum.JSFL.getValue().equals(persObjParam.getObjType())) {
  826. persObjParam.setObjType(BisInspEnum.JSFL.getValue());
  827. List<BisInspObjDto> result = this.bisInspObjDao.getJSFLObjByPersId(persObjParam);
  828. exportExcel(persObjParam.getIsExport(), result, response);
  829. return result;
  830. } else if (BisInspObjEnum.JSWA.getValue().equals(persObjParam.getObjType())) {
  831. persObjParam.setObjType(BisInspEnum.JSWA.getValue());
  832. List<BisInspObjDto> result = this.bisInspObjDao.getJSWAObjByPersId(persObjParam);
  833. exportExcel(persObjParam.getIsExport(), result, response);
  834. return result;
  835. } else if (persObjParam.getObjType().startsWith(BisInspEnum.IRR.getValue())) {
  836. return getIrrDataList(persObjParam);
  837. }
  838. return null;
  839. }
  840. private List getIrrDataList(PersObjParam persObjParam) {
  841. if (BisInspObjEnum.IRR_VILL.getValue().equals(persObjParam.getObjType())) {
  842. List<BisInspObjDto> result = bisInspIrrRgstrDao.getIrrVillList(persObjParam);
  843. return result;
  844. } else if (BisInspObjEnum.IRR_WTUSR.getValue().equals(persObjParam.getObjType())) {
  845. List<BisInspObjDto> result = bisInspIrrRgstrDao.getIrrWtusrList(persObjParam);
  846. return result;
  847. } else if (BisInspObjEnum.IRR_TOWN.getValue().equals(persObjParam.getObjType())) {
  848. List<BisInspObjDto> result = bisInspIrrRgstrDao.getIrrTownList(persObjParam);
  849. return result;
  850. } else if (BisInspObjEnum.IRR_PRO.getValue().equals(persObjParam.getObjType())) {
  851. List<BisInspObjDto> result = bisInspIrrRgstrDao.getIrrProList(persObjParam);
  852. return result;
  853. } else if (BisInspObjEnum.IRR_CITY.getValue().equals(persObjParam.getObjType())) {
  854. TypeParam typeParam = new TypeParam();
  855. typeParam.setPresId(persObjParam.getPersGuid());
  856. typeParam.setRsName(persObjParam.getRsName());
  857. typeParam.setState(persObjParam.getState());
  858. typeParam.setAdCode(persObjParam.getAdCode());
  859. typeParam.setpType(BisInspEnum.IRR.getValue());
  860. List<BisInspRgstrDto> result = bisInspIrrRgstrDao.findIrrList(typeParam);
  861. return result;
  862. } else if (BisInspObjEnum.IRR_BASE.getValue().equals(persObjParam.getObjType())) {
  863. List<BisInspObjDto> result = bisInspIrrRgstrDao.getIrrBaseList(persObjParam);
  864. return result;
  865. }
  866. return null;
  867. }
  868. @Override
  869. public PageInfo getPageByPersId(PersObjParam persObjParam, HttpServletResponse response) {
  870. if (StringUtils.isNotBlank(persObjParam.getAdCode())) {
  871. persObjParam.setAdCode(AdLevelUtil.SubAd(persObjParam.getAdCode()).get("subAd").toString());
  872. }
  873. //设置分页
  874. PageHelper.startPage(persObjParam.getPageNum(), persObjParam.getPageSize());
  875. //根据type分流
  876. BisInspEnum bisInspEnum = BisInspEnum.getEnumByType(persObjParam.getObjType());
  877. Optional.ofNullable(bisInspEnum).orElseThrow(() -> new CheckException("未找到与 objType:" + persObjParam.getObjType() + " 相对应的督查项!"));
  878. //根据type分流
  879. switch (bisInspEnum) {
  880. case SAP:
  881. List<AttWagaSapBaseDto> result = this.bisInspObjDao.getSapObjByPersId(persObjParam);
  882. exportExcel(persObjParam.getIsExport(), result, response);
  883. return new PageInfo<>(result);
  884. case SAP_BASE:
  885. return new PageInfo<>(bisInspObjDao.getSapBaseList(persObjParam));
  886. case SAP_OBJ:
  887. TypeParam typeParam = new TypeParam();
  888. typeParam.setPresId(persObjParam.getPersGuid());
  889. typeParam.setRsName(persObjParam.getRsName());
  890. typeParam.setState(persObjParam.getState());
  891. typeParam.setAdCode(persObjParam.getAdCode());
  892. typeParam.setpType(BisInspEnum.SAP.getValue());
  893. typeParam.setProvince(persObjParam.getProvince());
  894. return new PageInfo<>(this.bisInspWagaSapRgstrDao.getWagaSapRegstrInfo(typeParam));
  895. default:
  896. }
  897. if (BisInspEnum.REVER.getValue().equalsIgnoreCase(persObjParam.getObjType())) {//水库
  898. List<AttPersRs> result = attRsBaseDao.getObjByPersId(persObjParam);
  899. return new PageInfo<>(result);
  900. } else if (BisInspEnum.VILL.getValue().equalsIgnoreCase(persObjParam.getObjType())) {//人饮行政村
  901. List<SecsurveyVlgDto> result = attAdBaseDao.getObjByPersId(persObjParam);
  902. exportExcel(persObjParam.getIsExport(), result, response);
  903. return new PageInfo<SecsurveyVlgDto>(result);
  904. } else if (BisInspObjEnum.CWS.getValue().equalsIgnoreCase(persObjParam.getObjType())) {//农村饮水工程
  905. persObjParam.setObjType(persObjParam.getObjType().substring(0, 1));
  906. List<AttCwsBaseDto> result = attAdBaseDao.getCwsByPersId(persObjParam);
  907. exportExcel(persObjParam.getIsExport(), result, response);
  908. return new PageInfo<AttCwsBaseDto>(result);
  909. } else if (BisInspObjEnum.PSP.getValue().equalsIgnoreCase(persObjParam.getObjType())) {//水源地
  910. persObjParam.setObjType(persObjParam.getObjType().substring(0, 1));
  911. List<ProSourceProtectDto> result = attAdBaseDao.getPspByPersId(persObjParam);
  912. exportExcel(persObjParam.getIsExport(), result, response);
  913. return new PageInfo<ProSourceProtectDto>(result);
  914. } else if (BisInspObjEnum.COUNTRY.getValue().equalsIgnoreCase(persObjParam.getObjType())) {//督查县
  915. List<AttAdBase> result = attAdBaseDao.getAdBaseByPersId(persObjParam);
  916. exportExcel(persObjParam.getIsExport(), result, response);
  917. return new PageInfo<AttAdBase>(result);
  918. } else if (BisInspEnum.TRACK.getValue().equalsIgnoreCase(persObjParam.getObjType())) {//水毁
  919. List<AttPersWtdst> result = bisInspWtdstDao.getObjByPersId(persObjParam);
  920. exportExcel(persObjParam.getIsExport(), result, response);
  921. return new PageInfo<AttPersWtdst>(result);
  922. } else if (BisInspEnum.EMPWT.getValue().equalsIgnoreCase(persObjParam.getObjType())) {//172
  923. List<AttEmpwtprjBase> result = attEmpwtprjBaseDao.getObjByPersId(persObjParam);
  924. exportExcel(persObjParam.getIsExport(), result, response);
  925. return new PageInfo<AttEmpwtprjBase>(result);
  926. } else if (BisInspEnum.GRW.getValue().equalsIgnoreCase(persObjParam.getObjType())) {//地下水
  927. List<AttPersGrw> result = attGrwBaseDao.getObjByPersId(persObjParam);
  928. exportExcel(persObjParam.getIsExport(), result, response);
  929. return new PageInfo<AttPersGrw>(result);
  930. } else if (BisInspEnum.WAGA.getValue().equalsIgnoreCase(persObjParam.getObjType())) {//水闸
  931. List<AttWagaBase> result = attWagaBaseDao.getObjByPersId(persObjParam);
  932. exportExcel(persObjParam.getIsExport(), result, response);
  933. return new PageInfo<AttWagaBase>(result);
  934. } else if (BisInspObjEnum.STBPRP.getValue().equalsIgnoreCase(persObjParam.getObjType())) { //水文站
  935. List<StStbprpB> result = stStbprpBDao.findListBy(persObjParam);
  936. exportExcel(persObjParam.getIsExport(), result, response);
  937. return new PageInfo<StStbprpB>(result);
  938. } else if (BisInspObjEnum.PKX.getValue().equalsIgnoreCase(persObjParam.getObjType())) {//贫困县
  939. List<AttPkxBase> result = attPkxBaseDao.findListBy(persObjParam);
  940. exportExcel(persObjParam.getIsExport(), result, response);
  941. return new PageInfo<AttPkxBase>(result);
  942. } else if (BisInspObjEnum.WAIN.getValue().equalsIgnoreCase(persObjParam.getObjType())) {//取水口
  943. List<AttWainBase> result = attWainBaseDao.findListByPersId(persObjParam);
  944. exportExcel(persObjParam.getIsExport(), result, response);
  945. return new PageInfo<AttWainBase>(result);
  946. } else if (BisInspObjEnum.SWHS.getValue().equalsIgnoreCase(persObjParam.getObjType())) {//地表水
  947. List<AttSwhsBase> result = swhsBaseDao.findListBy(persObjParam);
  948. exportExcel(persObjParam.getIsExport(), result, response);
  949. return new PageInfo<AttSwhsBase>(result);
  950. } else if (BisInspObjEnum.FSC.getValue().equalsIgnoreCase(persObjParam.getObjType())) {
  951. List<AttFscBase> result = attFscBaseDao.findListBy(persObjParam);
  952. exportExcel(persObjParam.getIsExport(), result, response);
  953. return new PageInfo<AttFscBase>(result);
  954. } else if (BisInspObjEnum.OTHER.getValue().equalsIgnoreCase(persObjParam.getObjType())) {
  955. List<AttOtherBase> result = attOtherBaseDao.findListBy(persObjParam);
  956. exportExcel(persObjParam.getIsExport(), result, response);
  957. return new PageInfo<AttOtherBase>(result);
  958. } else if (BisInspObjEnum.SD.getValue().equalsIgnoreCase(persObjParam.getObjType())) {
  959. List<BisInspObjDto> result = bisInspObjDao.getSdObjByPersId(persObjParam);
  960. exportExcel(persObjParam.getIsExport(), result, response);
  961. return new PageInfo<BisInspObjDto>(result);
  962. } else if (BisInspObjEnum.WINT.getValue().equalsIgnoreCase(persObjParam.getObjType())) {
  963. List<BisInspObjDto> result = this.bisInspObjDao.getWintObjByPersId(persObjParam);
  964. exportExcel(persObjParam.getIsExport(), result, response);
  965. return new PageInfo<BisInspObjDto>(result);
  966. } else if (BisInspObjEnum.KEYSWHS.getValue().equalsIgnoreCase(persObjParam.getObjType())) {//重点水源地
  967. persObjParam.setObjType(BisInspEnum.SWHS.getValue());
  968. List<BisInspObjDto> result = this.bisInspObjDao.getKeySwhsObjByPersId(persObjParam);
  969. exportExcel(persObjParam.getIsExport(), result, response);
  970. return new PageInfo<BisInspObjDto>(result);
  971. } else if (BisInspObjEnum.SVWT.getValue().equalsIgnoreCase(persObjParam.getObjType())) {
  972. persObjParam.setObjType(BisInspEnum.SVWT.getValue());
  973. List<BisInspObjDto> result = this.bisInspObjDao.getSvwtObjByPersId(persObjParam);
  974. exportExcel(persObjParam.getIsExport(), result, response);
  975. return new PageInfo<BisInspObjDto>(result);
  976. } else if (BisInspObjEnum.WUNT.getValue().equalsIgnoreCase(persObjParam.getObjType())) {
  977. persObjParam.setObjType(BisInspEnum.WUNT.getValue());
  978. List<BisInspObjDto> result = this.bisInspObjDao.getWuntObjByPersId(persObjParam);
  979. exportExcel(persObjParam.getIsExport(), result, response);
  980. return new PageInfo<BisInspObjDto>(result);
  981. } else if (BisInspObjEnum.PRD.getValue().equalsIgnoreCase(persObjParam.getObjType())) {
  982. persObjParam.setObjType(BisInspEnum.PRD.getValue());
  983. List<BisInspObjDto> result = this.bisInspObjDao.getPrdObjByPersId(persObjParam);
  984. exportExcel(persObjParam.getIsExport(), result, response);
  985. return new PageInfo<BisInspObjDto>(result);
  986. } else if (BisInspObjEnum.JSFL.getValue().equalsIgnoreCase(persObjParam.getObjType())) {
  987. persObjParam.setObjType(BisInspEnum.JSFL.getValue());
  988. List<BisInspObjDto> result = this.bisInspObjDao.getJSFLObjByPersId(persObjParam);
  989. exportExcel(persObjParam.getIsExport(), result, response);
  990. return new PageInfo<BisInspObjDto>(result);
  991. } else if (BisInspObjEnum.JSWA.getValue().equalsIgnoreCase(persObjParam.getObjType())) {
  992. persObjParam.setObjType(BisInspEnum.JSWA.getValue());
  993. List<BisInspObjDto> result = this.bisInspObjDao.getJSWAObjByPersId(persObjParam);
  994. exportExcel(persObjParam.getIsExport(), result, response);
  995. return new PageInfo<BisInspObjDto>(result);
  996. } else if ("28".equalsIgnoreCase(persObjParam.getObjType())) {
  997. persObjParam.setObjType(BisInspEnum.IRR.getValue());
  998. List<BisInspObjDto> result = this.bisInspObjDao.getIrrObjByPersId(persObjParam);
  999. exportExcel(persObjParam.getIsExport(), result, response);
  1000. return new PageInfo<>(result);
  1001. } else if ("29".equalsIgnoreCase(persObjParam.getObjType())) {
  1002. persObjParam.setObjType(BisInspEnum.SAP.getValue());
  1003. List<AttWagaSapBaseDto> result = this.bisInspObjDao.getSapObjByPersId(persObjParam);
  1004. exportExcel(persObjParam.getIsExport(), result, response);
  1005. return new PageInfo<>(result);
  1006. }
  1007. return null;
  1008. }
  1009. @Override
  1010. public VillRgstrEngIdDto getRgstrByCode(String code, String type, String orgId) {
  1011. String province = inspOrgService.getProvince(orgId);
  1012. VillRgstrEngIdDto villRgstrEngIdDto = new VillRgstrEngIdDto();
  1013. if ("ADX".equals(type)) {
  1014. villRgstrEngIdDto = this.bisInspVillRgstrDao.getRgstrByAdXCode(code, orgId);
  1015. }
  1016. if ("CWS".equals(type)) {
  1017. villRgstrEngIdDto = this.bisInspVillRgstrDao.getRgstrByCwsCode(code, orgId);
  1018. }
  1019. if (villRgstrEngIdDto == null) {
  1020. VillRgstrEngIdDto v1 = new VillRgstrEngIdDto();
  1021. v1.setStateCode("1003");
  1022. return v1;
  1023. } else {
  1024. if (villRgstrEngIdDto.getEngId() != null) {
  1025. villRgstrEngIdDto.setStateCode("1001");
  1026. return villRgstrEngIdDto;
  1027. } else {
  1028. if (villRgstrEngIdDto.getCode() != null) {
  1029. BisInspVillRgstr bivr = new BisInspVillRgstr();
  1030. bivr.setEngId(UUID.randomUUID().toString().replace("-", ""));
  1031. bivr.setObjId(villRgstrEngIdDto.getObjId());
  1032. bivr.setRegsNm(villRgstrEngIdDto.getNm());
  1033. Date date = new Date();
  1034. SimpleDateFormat dateFormat = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
  1035. String format = dateFormat.format(date);
  1036. bivr.setIntm(format);
  1037. bivr.setRecPersId("1");
  1038. if (!province.startsWith(AdCodeLabel.START_PARENT_ADCODE)) {
  1039. bivr.setOrgId(orgId);
  1040. }
  1041. bisInspVillRgstrService.insert(bivr);
  1042. villRgstrEngIdDto.setEngId(bivr.getEngId());
  1043. villRgstrEngIdDto.setStateCode("1002");
  1044. return villRgstrEngIdDto;
  1045. } else {
  1046. return null;
  1047. }
  1048. }
  1049. }
  1050. }
  1051. @Override
  1052. public PageInfo<AttGrwBase> getGrwNotInGroup(InGroupGrwParam inGroupGrwParam) {
  1053. if (inGroupGrwParam.getAdcd() != null) {
  1054. if (inGroupGrwParam.getAdcd().contains(",")) {//如果有多个行政区划编码,要根据逗号分隔截取
  1055. StringBuffer stringBuffer = new StringBuffer();
  1056. String[] split = inGroupGrwParam.getAdcd().split(",");
  1057. for (String s : split) {//拼接sql,对多个截取后的行政区划进行模糊查询
  1058. String subAd = AdLevelUtil.SubAd(s).get("subAd").toString();
  1059. stringBuffer.append(subAd);
  1060. stringBuffer.append("%");
  1061. stringBuffer.append("' OR ADCD LIKE '");
  1062. }
  1063. //将最后的“ OR ADCD LIKE ”截掉
  1064. String substring = stringBuffer.substring(0, stringBuffer.length() - 15);
  1065. substring = "(ADCD LIKE '" + substring + ")";
  1066. inGroupGrwParam.setAdcd(substring);
  1067. } else {
  1068. String subAd = AdLevelUtil.SubAd(inGroupGrwParam.getAdcd()).get("subAd").toString();
  1069. subAd = "ADCD LIKE '" + subAd + "%'";
  1070. inGroupGrwParam.setAdcd(subAd);
  1071. }
  1072. }
  1073. PageHelper.startPage(inGroupGrwParam.getPageNum(), inGroupGrwParam.getPageSize());
  1074. List<AttGrwBase> attGrwBaseList = this.attGrwBaseDao.getGrwNotInGroup(inGroupGrwParam);
  1075. PageInfo<AttGrwBase> pageInfo = new PageInfo<>(attGrwBaseList);
  1076. return pageInfo;
  1077. }
  1078. }