8a46e8c34a58a3cd5f7b6bf0668e432e6c0cfd54.svn-base 60 KB

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