0ab5fe823ec11b6fe0a39a1c3253201b59265d78.svn-base 60 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970971972973974975976977978979980981982983984985986987988989990991992993994995996997998999100010011002100310041005100610071008100910101011101210131014101510161017101810191020102110221023102410251026102710281029103010311032103310341035103610371038103910401041104210431044104510461047104810491050105110521053105410551056105710581059106010611062106310641065106610671068106910701071107210731074107510761077107810791080108110821083108410851086108710881089109010911092109310941095109610971098109911001101110211031104110511061107110811091110111111121113111411151116111711181119112011211122112311241125112611271128
  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. if (StringUtils.isBlank(typeParam.getNm()) &&
  498. StringUtils.isNotBlank(pagePersObjParam.getWtdstNm())) {
  499. typeParam.setNm(pagePersObjParam.getWtdstNm());
  500. }
  501. BisInspObjStrategy strategy = factory.createStrategy(pagePersObjParam.getObjType());
  502. return (List) strategy.findObjListByType(typeParam);
  503. }
  504. }
  505. @Override
  506. public Object getObjListNotInspGroupId(InspObjParam inspObjParam) {
  507. if (!StringUtils.isBlank(inspObjParam.getAdCode())) {
  508. Map<String, Object> map = AdLevelUtil.SubAd(inspObjParam.getAdCode());
  509. logger.debug("adCode:"+String.valueOf(inspObjParam.getAdCode()));
  510. if(null != map.get("subAd")){
  511. inspObjParam.setAdCode(map.get("subAd").toString());
  512. }
  513. }
  514. String province = inspObjParam.getProvince();
  515. //查询该节点是否设置督查区域
  516. //设置分页
  517. PageHelper.startPage(inspObjParam.getPageNum(), inspObjParam.getPageSize());
  518. List<Object> list = new ArrayList<>();
  519. //根据type分流
  520. if ("1".equalsIgnoreCase(inspObjParam.getObjType()) || "24".equalsIgnoreCase(inspObjParam.getObjType()) || "26".equals(inspObjParam.getObjType())) {
  521. List<AttRsBase> result = attRsBaseDao.getObjListNotInspGroupId(inspObjParam.getInspGroupId(), inspObjParam.getObjType(),
  522. inspObjParam.getRsName(), inspObjParam.getEngScal(), inspObjParam.getRsAdmDep(), inspObjParam.getAdCode(), province);
  523. return new PageInfo<>(result);
  524. } else if ("2".equalsIgnoreCase(inspObjParam.getObjType()) || "27".equals(inspObjParam.getObjType()) || "25".equals(inspObjParam.getObjType())) {
  525. List<AttAdBase> result = attAdBaseDao.getObjListNotInspGroupId(inspObjParam.getInspGroupId(), inspObjParam.getObjType(), inspObjParam.getAdName(), inspObjParam.getAdCode(), province);
  526. return new PageInfo<AttAdBase>(result);
  527. } else if ("3".equalsIgnoreCase(inspObjParam.getObjType())) {
  528. List<BisInspWtdst> result = bisInspWtdstDao.getObjListNotInspGroupId(inspObjParam);
  529. return new PageInfo<BisInspWtdst>(result);
  530. } else if ("4".equalsIgnoreCase(inspObjParam.getObjType())) {
  531. List<AttEmpwtprjBase> result = attEmpwtprjBaseDao.getObjListNotInspGroupId(inspObjParam.getInspGroupId(), inspObjParam.getObjType(),
  532. inspObjParam.getAdName(), inspObjParam.getAdCode(), province);
  533. return new PageInfo<AttEmpwtprjBase>(result);
  534. } else if ("5".equalsIgnoreCase(inspObjParam.getObjType())) {
  535. List<AttGrwBase> result = attGrwBaseDao.getObjListNotInspGroupId(inspObjParam.getInspGroupId(), inspObjParam.getObjType(),
  536. inspObjParam.getAdName(), inspObjParam.getAdCode(), province);
  537. return new PageInfo<AttGrwBase>(result);
  538. } else if ("6".equalsIgnoreCase(inspObjParam.getObjType())) {
  539. List<AttWagaBase> result = attWagaBaseDao.getObjListNotInspGroupId(inspObjParam.getInspGroupId(), inspObjParam.getObjType(),
  540. inspObjParam.getAdName(), inspObjParam.getAdCode(), province);
  541. return new PageInfo<AttWagaBase>(result);
  542. } else if ("7".equalsIgnoreCase(inspObjParam.getObjType())) {
  543. List<AttEmpwtprjBase> result = attEmpwtprjBaseDao.getObjListNotInspGroupId(inspObjParam.getInspGroupId(), inspObjParam.getObjType(),
  544. inspObjParam.getAdName(), inspObjParam.getAdCode(), province);
  545. return new PageInfo<AttEmpwtprjBase>(result);
  546. } else if ("8".equalsIgnoreCase(inspObjParam.getObjType())) {
  547. return null;
  548. } else if ("9".equalsIgnoreCase(inspObjParam.getObjType())) {
  549. List<AttFscBase> result = attFscBaseDao.getObjListNotInspGroupId(inspObjParam.getInspGroupId(), inspObjParam.getObjType(),
  550. inspObjParam.getAdName(), inspObjParam.getAdCode(), province);
  551. return new PageInfo<AttFscBase>(result);
  552. } else if ("10".equalsIgnoreCase(inspObjParam.getObjType())) {
  553. List<AttOtherBase> result = attOtherBaseDao.getObjListNotInspGroupId(inspObjParam.getInspGroupId(), inspObjParam.getObjType(),
  554. inspObjParam.getAdName(), inspObjParam.getAdCode(), province);
  555. return new PageInfo<AttOtherBase>(result);
  556. } else if ("11".equalsIgnoreCase(inspObjParam.getObjType())) {
  557. List<AttSdBase> result = sdBaseDao.getObjListNotInspGroupId(inspObjParam.getInspGroupId(), inspObjParam.getObjType(),
  558. inspObjParam.getAdName(), inspObjParam.getAdCode(), province);
  559. return new PageInfo<AttSdBase>(result);
  560. } else if ("12".equalsIgnoreCase(inspObjParam.getObjType())) {
  561. List<AttWiuBase> result = wiuBaseDao.getObjListNotInspGroupId(inspObjParam.getInspGroupId(), inspObjParam.getObjType(),
  562. inspObjParam.getAdName(), inspObjParam.getAdCode(), province);
  563. return new PageInfo<AttWiuBase>(result);
  564. } else if ("13".equalsIgnoreCase(inspObjParam.getObjType())) {
  565. List<AttSwhsBase> result = swhsBaseDao.getObjListNotInspGroupId(inspObjParam.getInspGroupId(), inspObjParam.getObjType(),
  566. inspObjParam.getAdName(), inspObjParam.getAdCode(), province);
  567. return new PageInfo<AttSwhsBase>(result);
  568. } else if ("14".equalsIgnoreCase(inspObjParam.getObjType())) {
  569. List<AttAdXBase> result = attAdXBaseDao.getObjListNotInspGroupId(inspObjParam.getInspGroupId(), inspObjParam.getObjType(),
  570. inspObjParam.getAdName(), inspObjParam.getAdCode(), province);
  571. return new PageInfo<AttAdXBase>(result);
  572. } else if ("15".equalsIgnoreCase(inspObjParam.getObjType())) {
  573. List<AttAdXBase> result = attAdXBaseDao.getObjListNotInspGroupId(inspObjParam.getInspGroupId(), inspObjParam.getObjType(),
  574. inspObjParam.getAdName(), inspObjParam.getAdCode(), province);
  575. return new PageInfo<AttAdXBase>(result);
  576. } else if ("16".equalsIgnoreCase(inspObjParam.getObjType())) {
  577. List<AttWuntBase> result = wuntBaseDao.getObjListNotInspGroupId(inspObjParam.getInspGroupId(), inspObjParam.getObjType(),
  578. inspObjParam.getAdName(), inspObjParam.getAdCode(), province);
  579. return new PageInfo<AttWuntBase>(result);
  580. } else if ("17".equalsIgnoreCase(inspObjParam.getObjType())) {
  581. //生产建设项目
  582. List<AttPrdCstrProjBase> result = oprdCstrProjRgstrDao.getObjPrdListNotInspGroupId(inspObjParam.getInspGroupId(), inspObjParam.getObjType(),
  583. inspObjParam.getAdName(), inspObjParam.getAdCode(), province);
  584. return new PageInfo<AttPrdCstrProjBase>(result);
  585. } else if ("18".equalsIgnoreCase(inspObjParam.getObjType())) {
  586. //生产建设项目
  587. List<AttJskejianFlkdisBase> result = jskejianFlkdisBaseDao.getObjJsFlListNotInspGroupId(inspObjParam.getInspGroupId(), inspObjParam.getObjType(),
  588. inspObjParam.getAdName(), inspObjParam.getAdCode(), province);
  589. return new PageInfo<AttJskejianFlkdisBase>(result);
  590. } else if ("19".equalsIgnoreCase(inspObjParam.getObjType())) {
  591. //生产建设项目
  592. List<AttJskejianWaterBase> result = jskejianWaterBaseDao.getObjJsWaListNotInspGroupId(inspObjParam.getInspGroupId(), inspObjParam.getObjType(),
  593. inspObjParam.getAdName(), inspObjParam.getAdCode(), province);
  594. return new PageInfo<AttJskejianWaterBase>(result);
  595. } else if ("23".equalsIgnoreCase(inspObjParam.getObjType())) {
  596. //量化考核
  597. List<AttAdXBase> result = attAdXBaseDao.getObjListNotInspGroupId(inspObjParam.getInspGroupId(), inspObjParam.getObjType(),
  598. inspObjParam.getAdName(), inspObjParam.getAdCode(), province);
  599. return new PageInfo<AttAdXBase>(result);
  600. } else if (BisInspEnum.SAP.getValue().equalsIgnoreCase(inspObjParam.getObjType())) {
  601. List<AttWagaSapBase> result = bisInspWagaSapRgstrDao.getObjListNotInspGroupId(inspObjParam.getInspGroupId(), inspObjParam.getObjType(),
  602. inspObjParam.getAdName(), inspObjParam.getAdCode(), province);
  603. return new PageInfo<AttWagaSapBase>(result);
  604. } else if (BisInspEnum.EFP.getValue().equalsIgnoreCase(inspObjParam.getObjType())) {
  605. List<AttEfpBase> result = bisInspEfpRgstrDao.getObjListNotInspGroupId(inspObjParam.getInspGroupId(), inspObjParam.getObjType(),
  606. inspObjParam.getAdName(), inspObjParam.getAdCode(), province);
  607. return new PageInfo<AttEfpBase>(result);
  608. }
  609. return null;
  610. }
  611. @Override
  612. public Map<String, Object> addDcAndObjRel(String baseId, String objType, String inspGroupId, String objName,
  613. String objLttd, String objLgtd, String objProvincial ,String persId, String orgId) {
  614. Map<String, Object> ret = new HashMap<>();
  615. boolean isSuccess = true;
  616. StringBuilder objStringBuilder = new StringBuilder();
  617. //处理参数添加
  618. String[] baseIdArray = baseId.split(SplitValue.DOUHAO_SPLIT);
  619. String[] objNameArray = objName.split(SplitValue.DOUHAO_SPLIT);
  620. String[] objLttdArray = objLttd.split(SplitValue.DOUHAO_SPLIT);
  621. String[] objLgtdArray = objLgtd.split(SplitValue.DOUHAO_SPLIT);
  622. String[] provincialArray = objProvincial.split(SplitValue.DOUHAO_SPLIT);
  623. String province = inspOrgService.getProvince(orgId);
  624. // 循环对象
  625. for (int i = 0; i < baseIdArray.length; i++) {
  626. // 基础表ID为空时跳过
  627. if (StringUtils.isBlank(baseIdArray[i])) {
  628. continue;
  629. }
  630. // 组装 bisInspAllObj
  631. BisInspAllObj bisInspAllObj = new BisInspAllObj();
  632. bisInspAllObj.setId(inspGroupId);
  633. bisInspAllObj.setObjId(UuidUtil.uuid());
  634. bisInspAllObj.setCode(baseIdArray[i]);
  635. bisInspAllObj.setPtype(objType);
  636. bisInspAllObj.setNm(objNameArray[i]);
  637. // 增加 督察对象 是否省属 属性 1是2否 add by lxf 2022/10/10
  638. logger.debug("Provincial: "+provincialArray[i]);
  639. String tmp = ("null".equalsIgnoreCase(provincialArray[i])||"".equals(provincialArray[i]))?null:provincialArray[i];
  640. if(null != tmp && "是,否".contains(tmp)){
  641. tmp = "是".equals(tmp)?"1":"2";
  642. }
  643. if(null != tmp && !"1".equals(tmp) && !"2".equals(tmp)){
  644. tmp = "2";
  645. }
  646. bisInspAllObj.setProvincial(tmp);
  647. if (!province.startsWith(AdCodeLabel.START_PARENT_ADCODE)) {
  648. bisInspAllObj.setAdCode(province);
  649. bisInspAllObj.setOrgId(orgId);
  650. } else {
  651. orgId = "";
  652. }
  653. if (objLttdArray.length > 0 && !"".equals(objLttdArray[i]) &&
  654. !"null".equals(objLttdArray[i])) {
  655. bisInspAllObj.setLgtd(Double.parseDouble(objLgtdArray[i]));
  656. bisInspAllObj.setLttd(Double.parseDouble(objLttdArray[i]));
  657. }
  658. // obj 重复校验
  659. BisInspAllObjDto baj = this.bisInspAllObjDao.getObj(bisInspAllObj);
  660. if (baj != null) {
  661. isSuccess = false;
  662. ObjectNameDto ond = this.bisInspAllObjDao.getGroup(bisInspAllObj.getId());
  663. objStringBuilder.append(ond.getName()).append("、");
  664. continue;
  665. }
  666. bisInspAllObjDao.insert(bisInspAllObj);
  667. if ("36".equals(objType)) {
  668. // 36 走小水库
  669. objType = "1";
  670. }
  671. BisInspObjStrategy strategy = factory.createStrategy(objType);
  672. strategy.insertObj(bisInspAllObj, persId);
  673. }
  674. if (isSuccess) {
  675. ret.put("code", "200");
  676. ret.put("mess", "添加成功");
  677. } else {
  678. ret.put("code", "201");
  679. ret.put("mess", objStringBuilder.toString().substring(0, objStringBuilder.toString().length() - 1) + "重复添加");
  680. }
  681. return ret;
  682. }
  683. @Autowired
  684. private BisNewVillRgstrDao bisNewVillRgstrDao;
  685. @Override
  686. public List getObjByPersId(PersObjParam persObjParam, HttpServletResponse response) {
  687. if (StringUtils.isNotBlank(persObjParam.getAdCode())) {
  688. persObjParam.setAdCode(AdLevelUtil.SubAd(persObjParam.getAdCode()).get("subAd").toString());
  689. }
  690. persObjParam.setInIdsSql(SqlUtils.getinIdsSql(persObjParam.getPersGuid(), persObjParam.getProvince()));
  691. BisInspEnum bisInspEnum = BisInspEnum.getEnumByType(persObjParam.getObjType());
  692. Optional.ofNullable(bisInspEnum).orElseThrow(() -> new CheckException("未找到与 objType:" + persObjParam.getObjType() + " 相对应的督查项!"));
  693. //根据type分流
  694. switch (bisInspEnum) {
  695. case SAP:
  696. List<AttWagaSapBaseDto> result = this.bisInspObjDao.getSapObjByPersId(persObjParam);
  697. exportExcel(persObjParam.getIsExport(), result, response);
  698. return result;
  699. case SAP_BASE:
  700. return bisInspObjDao.getSapBaseList(persObjParam);
  701. case SAP_OBJ:
  702. TypeParam typeParam = new TypeParam();
  703. typeParam.setPresId(persObjParam.getPersGuid());
  704. typeParam.setRsName(persObjParam.getRsName());
  705. typeParam.setState(persObjParam.getState());
  706. typeParam.setAdCode(persObjParam.getAdCode());
  707. typeParam.setpType(BisInspEnum.SAP.getValue());
  708. typeParam.setProvince(persObjParam.getProvince());
  709. return this.bisInspWagaSapRgstrDao.getWagaSapRegstrInfo(typeParam);
  710. default:
  711. }
  712. if (BisInspEnum.REVER.getValue().equalsIgnoreCase(persObjParam.getObjType())) {
  713. List<AttPersRs> result = attRsBaseDao.getObjByPersId(persObjParam);
  714. exportExcel(persObjParam.getIsExport(), result, response);
  715. return result;
  716. } else if (BisInspEnum.VILL.getValue().equalsIgnoreCase(persObjParam.getObjType())) {
  717. if (persObjParam.getProvince().length() == 12) {
  718. persObjParam.setProvince(persObjParam.getProvince().substring(0, 2));
  719. }
  720. List<SecsurveyVlgDto> result = attAdBaseDao.getObjByPersId(persObjParam);
  721. exportExcel(persObjParam.getIsExport(), result, response);
  722. return result;
  723. } else if (BisInspEnum.VILL2020.getValue().equalsIgnoreCase(persObjParam.getObjType())) {
  724. if (persObjParam.getProvince().length() == 12) {
  725. persObjParam.setProvince(persObjParam.getProvince().substring(0, 2));
  726. }
  727. List<BisNewWateruserInfoDto> result = bisNewVillRgstrDao.getVill20ByPersId(persObjParam);
  728. exportExcel(persObjParam.getIsExport(), result, response);
  729. return result;
  730. } else if (BisInspObjEnum.CWS.getValue().equalsIgnoreCase(persObjParam.getObjType())) {
  731. if (persObjParam.getProvince().length() == 12) {
  732. persObjParam.setProvince(persObjParam.getProvince().substring(0, 2));
  733. }
  734. persObjParam.setObjType(persObjParam.getObjType().substring(0, 1));
  735. List<AttCwsBaseDto> result = attAdBaseDao.getCwsByPersId(persObjParam);
  736. exportExcel(persObjParam.getIsExport(), result, response);
  737. return result;
  738. } else if (BisInspObjEnum.PSP.getValue().equalsIgnoreCase(persObjParam.getObjType())) {
  739. persObjParam.setObjType(persObjParam.getObjType().substring(0, 1));
  740. List<ProSourceProtectDto> result = attAdBaseDao.getPspByPersId(persObjParam);
  741. exportExcel(persObjParam.getIsExport(), result, response);
  742. return result;
  743. } else if (BisInspObjEnum.COUNTRY.getValue().equalsIgnoreCase(persObjParam.getObjType())) {
  744. persObjParam.setObjType(persObjParam.getObjType().substring(0, 1));
  745. List<AttAdBase> result = attAdBaseDao.getAdBaseByPersId(persObjParam);
  746. exportExcel(persObjParam.getIsExport(), result, response);
  747. return result;
  748. } else if (BisInspEnum.TRACK.getValue().equalsIgnoreCase(persObjParam.getObjType())) {
  749. if (persObjParam.getProvince().length() == 12) {
  750. persObjParam.setProvince(persObjParam.getProvince().substring(0, 2));
  751. }
  752. List<AttPersWtdst> result = bisInspWtdstDao.getObjByPersId(persObjParam);
  753. exportExcel(persObjParam.getIsExport(), result, response);
  754. return result;
  755. } else if (BisInspEnum.EMPWT.getValue().equalsIgnoreCase(persObjParam.getObjType())) {
  756. List<AttEmpwtprjBase> result = attEmpwtprjBaseDao.getObjByPersId(persObjParam);
  757. exportExcel(persObjParam.getIsExport(), result, response);
  758. return result;
  759. } else if (BisInspEnum.GRW.getValue().equalsIgnoreCase(persObjParam.getObjType())) {
  760. List<AttPersGrw> result = attGrwBaseDao.getObjByPersId(persObjParam);
  761. exportExcel(persObjParam.getIsExport(), result, response);
  762. return result;
  763. } else if (BisInspEnum.WAGA.getValue().equalsIgnoreCase(persObjParam.getObjType())) {
  764. List<AttWagaBase> result = attWagaBaseDao.getObjByPersId(persObjParam);
  765. exportExcel(persObjParam.getIsExport(), result, response);
  766. return result;
  767. } else if (BisInspObjEnum.STBPRP.getValue().equalsIgnoreCase(persObjParam.getObjType())) { //水文站
  768. List<StStbprpB> result = stStbprpBDao.findListBy(persObjParam);
  769. exportExcel(persObjParam.getIsExport(), result, response);
  770. return result;
  771. } else if (BisInspObjEnum.PKX.getValue().equalsIgnoreCase(persObjParam.getObjType())) {//贫困县
  772. List<AttPkxBase> result = attPkxBaseDao.findListBy(persObjParam);
  773. exportExcel(persObjParam.getIsExport(), result, response);
  774. return result;
  775. } else if (BisInspObjEnum.WAIN.getValue().equalsIgnoreCase(persObjParam.getObjType())) {//取水口
  776. List<AttWainBase> result = attWainBaseDao.findListByPersId(persObjParam);
  777. exportExcel(persObjParam.getIsExport(), result, response);
  778. return result;
  779. } else if (BisInspObjEnum.SWHS.getValue().equalsIgnoreCase(persObjParam.getObjType())) {
  780. List<AttSwhsBase> result = swhsBaseDao.findListBy(persObjParam);
  781. exportExcel(persObjParam.getIsExport(), result, response);
  782. return result;
  783. } else if (BisInspObjEnum.FSC.getValue().equalsIgnoreCase(persObjParam.getObjType())) {
  784. List<AttFscBase> result = attFscBaseDao.findListBy(persObjParam);
  785. exportExcel(persObjParam.getIsExport(), result, response);
  786. return result;
  787. } else if (BisInspObjEnum.OTHER.getValue().equalsIgnoreCase(persObjParam.getObjType())) {
  788. List<AttOtherBase> result = attOtherBaseDao.findListBy(persObjParam);
  789. exportExcel(persObjParam.getIsExport(), result, response);
  790. return result;
  791. } else if (BisInspObjEnum.SD.getValue().equalsIgnoreCase(persObjParam.getObjType())) {
  792. List<BisInspObjDto> result = bisInspObjDao.getSdObjByPersId(persObjParam);
  793. exportExcel(persObjParam.getIsExport(), result, response);
  794. return result;
  795. } else if (BisInspObjEnum.WIU.getValue().equalsIgnoreCase(persObjParam.getObjType())) {//取用水户
  796. persObjParam.setObjType(BisInspEnum.WIU.getValue());
  797. List<BisInspObjDto> result = this.bisInspObjDao.getWiuObjByPersId(persObjParam);
  798. exportExcel(persObjParam.getIsExport(), result, response);
  799. return result;
  800. } else if (BisInspObjEnum.KEYSWHS.getValue().equalsIgnoreCase(persObjParam.getObjType())) {//重点水源地
  801. persObjParam.setObjType(BisInspEnum.SWHS.getValue());
  802. List<BisInspObjDto> result = this.bisInspObjDao.getKeySwhsObjByPersId(persObjParam);
  803. exportExcel(persObjParam.getIsExport(), result, response);
  804. return result;
  805. } else if (BisInspObjEnum.WINT.getValue().equalsIgnoreCase(persObjParam.getObjType())) {
  806. List<BisInspObjDto> result = this.bisInspObjDao.getWintObjByPersId(persObjParam);
  807. exportExcel(persObjParam.getIsExport(), result, response);
  808. return result;
  809. } else if (BisInspObjEnum.SVWT.getValue().equals(persObjParam.getObjType())) {
  810. persObjParam.setObjType(BisInspEnum.SVWT.getValue());
  811. List<BisInspObjDto> result = this.bisInspObjDao.getSvwtObjByPersId(persObjParam);
  812. exportExcel(persObjParam.getIsExport(), result, response);
  813. return result;
  814. } else if (BisInspObjEnum.WUNT.getValue().equals(persObjParam.getObjType())) {
  815. persObjParam.setObjType(BisInspEnum.WUNT.getValue());
  816. List<BisInspObjDto> result = this.bisInspObjDao.getWuntObjByPersId(persObjParam);
  817. exportExcel(persObjParam.getIsExport(), result, response);
  818. return result;
  819. } else if (BisInspObjEnum.PRD.getValue().equals(persObjParam.getObjType())) {
  820. persObjParam.setObjType(BisInspEnum.PRD.getValue());
  821. List<BisInspObjDto> result = this.bisInspObjDao.getPrdObjByPersId(persObjParam);
  822. exportExcel(persObjParam.getIsExport(), result, response);
  823. return result;
  824. } else if (BisInspObjEnum.JSFL.getValue().equals(persObjParam.getObjType())) {
  825. persObjParam.setObjType(BisInspEnum.JSFL.getValue());
  826. List<BisInspObjDto> result = this.bisInspObjDao.getJSFLObjByPersId(persObjParam);
  827. exportExcel(persObjParam.getIsExport(), result, response);
  828. return result;
  829. } else if (BisInspObjEnum.JSWA.getValue().equals(persObjParam.getObjType())) {
  830. persObjParam.setObjType(BisInspEnum.JSWA.getValue());
  831. List<BisInspObjDto> result = this.bisInspObjDao.getJSWAObjByPersId(persObjParam);
  832. exportExcel(persObjParam.getIsExport(), result, response);
  833. return result;
  834. } else if (persObjParam.getObjType().startsWith(BisInspEnum.IRR.getValue())) {
  835. return getIrrDataList(persObjParam);
  836. }
  837. return null;
  838. }
  839. private List getIrrDataList(PersObjParam persObjParam) {
  840. if (BisInspObjEnum.IRR_VILL.getValue().equals(persObjParam.getObjType())) {
  841. List<BisInspObjDto> result = bisInspIrrRgstrDao.getIrrVillList(persObjParam);
  842. return result;
  843. } else if (BisInspObjEnum.IRR_WTUSR.getValue().equals(persObjParam.getObjType())) {
  844. List<BisInspObjDto> result = bisInspIrrRgstrDao.getIrrWtusrList(persObjParam);
  845. return result;
  846. } else if (BisInspObjEnum.IRR_TOWN.getValue().equals(persObjParam.getObjType())) {
  847. List<BisInspObjDto> result = bisInspIrrRgstrDao.getIrrTownList(persObjParam);
  848. return result;
  849. } else if (BisInspObjEnum.IRR_PRO.getValue().equals(persObjParam.getObjType())) {
  850. List<BisInspObjDto> result = bisInspIrrRgstrDao.getIrrProList(persObjParam);
  851. return result;
  852. } else if (BisInspObjEnum.IRR_CITY.getValue().equals(persObjParam.getObjType())) {
  853. TypeParam typeParam = new TypeParam();
  854. typeParam.setPresId(persObjParam.getPersGuid());
  855. typeParam.setRsName(persObjParam.getRsName());
  856. typeParam.setState(persObjParam.getState());
  857. typeParam.setAdCode(persObjParam.getAdCode());
  858. typeParam.setpType(BisInspEnum.IRR.getValue());
  859. List<BisInspRgstrDto> result = bisInspIrrRgstrDao.findIrrList(typeParam);
  860. return result;
  861. } else if (BisInspObjEnum.IRR_BASE.getValue().equals(persObjParam.getObjType())) {
  862. List<BisInspObjDto> result = bisInspIrrRgstrDao.getIrrBaseList(persObjParam);
  863. return result;
  864. }
  865. return null;
  866. }
  867. @Override
  868. public PageInfo getPageByPersId(PersObjParam persObjParam, HttpServletResponse response) {
  869. if (StringUtils.isNotBlank(persObjParam.getAdCode())) {
  870. persObjParam.setAdCode(AdLevelUtil.SubAd(persObjParam.getAdCode()).get("subAd").toString());
  871. }
  872. //设置分页
  873. PageHelper.startPage(persObjParam.getPageNum(), persObjParam.getPageSize());
  874. //根据type分流
  875. BisInspEnum bisInspEnum = BisInspEnum.getEnumByType(persObjParam.getObjType());
  876. Optional.ofNullable(bisInspEnum).orElseThrow(() -> new CheckException("未找到与 objType:" + persObjParam.getObjType() + " 相对应的督查项!"));
  877. //根据type分流
  878. switch (bisInspEnum) {
  879. case SAP:
  880. List<AttWagaSapBaseDto> result = this.bisInspObjDao.getSapObjByPersId(persObjParam);
  881. exportExcel(persObjParam.getIsExport(), result, response);
  882. return new PageInfo<>(result);
  883. case SAP_BASE:
  884. return new PageInfo<>(bisInspObjDao.getSapBaseList(persObjParam));
  885. case SAP_OBJ:
  886. TypeParam typeParam = new TypeParam();
  887. typeParam.setPresId(persObjParam.getPersGuid());
  888. typeParam.setRsName(persObjParam.getRsName());
  889. typeParam.setState(persObjParam.getState());
  890. typeParam.setAdCode(persObjParam.getAdCode());
  891. typeParam.setpType(BisInspEnum.SAP.getValue());
  892. typeParam.setProvince(persObjParam.getProvince());
  893. return new PageInfo<>(this.bisInspWagaSapRgstrDao.getWagaSapRegstrInfo(typeParam));
  894. default:
  895. }
  896. if (BisInspEnum.REVER.getValue().equalsIgnoreCase(persObjParam.getObjType())) {//水库
  897. List<AttPersRs> result = attRsBaseDao.getObjByPersId(persObjParam);
  898. return new PageInfo<>(result);
  899. } else if (BisInspEnum.VILL.getValue().equalsIgnoreCase(persObjParam.getObjType())) {//人饮行政村
  900. List<SecsurveyVlgDto> result = attAdBaseDao.getObjByPersId(persObjParam);
  901. exportExcel(persObjParam.getIsExport(), result, response);
  902. return new PageInfo<SecsurveyVlgDto>(result);
  903. } else if (BisInspObjEnum.CWS.getValue().equalsIgnoreCase(persObjParam.getObjType())) {//农村饮水工程
  904. persObjParam.setObjType(persObjParam.getObjType().substring(0, 1));
  905. List<AttCwsBaseDto> result = attAdBaseDao.getCwsByPersId(persObjParam);
  906. exportExcel(persObjParam.getIsExport(), result, response);
  907. return new PageInfo<AttCwsBaseDto>(result);
  908. } else if (BisInspObjEnum.PSP.getValue().equalsIgnoreCase(persObjParam.getObjType())) {//水源地
  909. persObjParam.setObjType(persObjParam.getObjType().substring(0, 1));
  910. List<ProSourceProtectDto> result = attAdBaseDao.getPspByPersId(persObjParam);
  911. exportExcel(persObjParam.getIsExport(), result, response);
  912. return new PageInfo<ProSourceProtectDto>(result);
  913. } else if (BisInspObjEnum.COUNTRY.getValue().equalsIgnoreCase(persObjParam.getObjType())) {//督查县
  914. List<AttAdBase> result = attAdBaseDao.getAdBaseByPersId(persObjParam);
  915. exportExcel(persObjParam.getIsExport(), result, response);
  916. return new PageInfo<AttAdBase>(result);
  917. } else if (BisInspEnum.TRACK.getValue().equalsIgnoreCase(persObjParam.getObjType())) {//水毁
  918. List<AttPersWtdst> result = bisInspWtdstDao.getObjByPersId(persObjParam);
  919. exportExcel(persObjParam.getIsExport(), result, response);
  920. return new PageInfo<AttPersWtdst>(result);
  921. } else if (BisInspEnum.EMPWT.getValue().equalsIgnoreCase(persObjParam.getObjType())) {//172
  922. List<AttEmpwtprjBase> result = attEmpwtprjBaseDao.getObjByPersId(persObjParam);
  923. exportExcel(persObjParam.getIsExport(), result, response);
  924. return new PageInfo<AttEmpwtprjBase>(result);
  925. } else if (BisInspEnum.GRW.getValue().equalsIgnoreCase(persObjParam.getObjType())) {//地下水
  926. List<AttPersGrw> result = attGrwBaseDao.getObjByPersId(persObjParam);
  927. exportExcel(persObjParam.getIsExport(), result, response);
  928. return new PageInfo<AttPersGrw>(result);
  929. } else if (BisInspEnum.WAGA.getValue().equalsIgnoreCase(persObjParam.getObjType())) {//水闸
  930. List<AttWagaBase> result = attWagaBaseDao.getObjByPersId(persObjParam);
  931. exportExcel(persObjParam.getIsExport(), result, response);
  932. return new PageInfo<AttWagaBase>(result);
  933. } else if (BisInspObjEnum.STBPRP.getValue().equalsIgnoreCase(persObjParam.getObjType())) { //水文站
  934. List<StStbprpB> result = stStbprpBDao.findListBy(persObjParam);
  935. exportExcel(persObjParam.getIsExport(), result, response);
  936. return new PageInfo<StStbprpB>(result);
  937. } else if (BisInspObjEnum.PKX.getValue().equalsIgnoreCase(persObjParam.getObjType())) {//贫困县
  938. List<AttPkxBase> result = attPkxBaseDao.findListBy(persObjParam);
  939. exportExcel(persObjParam.getIsExport(), result, response);
  940. return new PageInfo<AttPkxBase>(result);
  941. } else if (BisInspObjEnum.WAIN.getValue().equalsIgnoreCase(persObjParam.getObjType())) {//取水口
  942. List<AttWainBase> result = attWainBaseDao.findListByPersId(persObjParam);
  943. exportExcel(persObjParam.getIsExport(), result, response);
  944. return new PageInfo<AttWainBase>(result);
  945. } else if (BisInspObjEnum.SWHS.getValue().equalsIgnoreCase(persObjParam.getObjType())) {//地表水
  946. List<AttSwhsBase> result = swhsBaseDao.findListBy(persObjParam);
  947. exportExcel(persObjParam.getIsExport(), result, response);
  948. return new PageInfo<AttSwhsBase>(result);
  949. } else if (BisInspObjEnum.FSC.getValue().equalsIgnoreCase(persObjParam.getObjType())) {
  950. List<AttFscBase> result = attFscBaseDao.findListBy(persObjParam);
  951. exportExcel(persObjParam.getIsExport(), result, response);
  952. return new PageInfo<AttFscBase>(result);
  953. } else if (BisInspObjEnum.OTHER.getValue().equalsIgnoreCase(persObjParam.getObjType())) {
  954. List<AttOtherBase> result = attOtherBaseDao.findListBy(persObjParam);
  955. exportExcel(persObjParam.getIsExport(), result, response);
  956. return new PageInfo<AttOtherBase>(result);
  957. } else if (BisInspObjEnum.SD.getValue().equalsIgnoreCase(persObjParam.getObjType())) {
  958. List<BisInspObjDto> result = bisInspObjDao.getSdObjByPersId(persObjParam);
  959. exportExcel(persObjParam.getIsExport(), result, response);
  960. return new PageInfo<BisInspObjDto>(result);
  961. } else if (BisInspObjEnum.WINT.getValue().equalsIgnoreCase(persObjParam.getObjType())) {
  962. List<BisInspObjDto> result = this.bisInspObjDao.getWintObjByPersId(persObjParam);
  963. exportExcel(persObjParam.getIsExport(), result, response);
  964. return new PageInfo<BisInspObjDto>(result);
  965. } else if (BisInspObjEnum.KEYSWHS.getValue().equalsIgnoreCase(persObjParam.getObjType())) {//重点水源地
  966. persObjParam.setObjType(BisInspEnum.SWHS.getValue());
  967. List<BisInspObjDto> result = this.bisInspObjDao.getKeySwhsObjByPersId(persObjParam);
  968. exportExcel(persObjParam.getIsExport(), result, response);
  969. return new PageInfo<BisInspObjDto>(result);
  970. } else if (BisInspObjEnum.SVWT.getValue().equalsIgnoreCase(persObjParam.getObjType())) {
  971. persObjParam.setObjType(BisInspEnum.SVWT.getValue());
  972. List<BisInspObjDto> result = this.bisInspObjDao.getSvwtObjByPersId(persObjParam);
  973. exportExcel(persObjParam.getIsExport(), result, response);
  974. return new PageInfo<BisInspObjDto>(result);
  975. } else if (BisInspObjEnum.WUNT.getValue().equalsIgnoreCase(persObjParam.getObjType())) {
  976. persObjParam.setObjType(BisInspEnum.WUNT.getValue());
  977. List<BisInspObjDto> result = this.bisInspObjDao.getWuntObjByPersId(persObjParam);
  978. exportExcel(persObjParam.getIsExport(), result, response);
  979. return new PageInfo<BisInspObjDto>(result);
  980. } else if (BisInspObjEnum.PRD.getValue().equalsIgnoreCase(persObjParam.getObjType())) {
  981. persObjParam.setObjType(BisInspEnum.PRD.getValue());
  982. List<BisInspObjDto> result = this.bisInspObjDao.getPrdObjByPersId(persObjParam);
  983. exportExcel(persObjParam.getIsExport(), result, response);
  984. return new PageInfo<BisInspObjDto>(result);
  985. } else if (BisInspObjEnum.JSFL.getValue().equalsIgnoreCase(persObjParam.getObjType())) {
  986. persObjParam.setObjType(BisInspEnum.JSFL.getValue());
  987. List<BisInspObjDto> result = this.bisInspObjDao.getJSFLObjByPersId(persObjParam);
  988. exportExcel(persObjParam.getIsExport(), result, response);
  989. return new PageInfo<BisInspObjDto>(result);
  990. } else if (BisInspObjEnum.JSWA.getValue().equalsIgnoreCase(persObjParam.getObjType())) {
  991. persObjParam.setObjType(BisInspEnum.JSWA.getValue());
  992. List<BisInspObjDto> result = this.bisInspObjDao.getJSWAObjByPersId(persObjParam);
  993. exportExcel(persObjParam.getIsExport(), result, response);
  994. return new PageInfo<BisInspObjDto>(result);
  995. } else if ("28".equalsIgnoreCase(persObjParam.getObjType())) {
  996. persObjParam.setObjType(BisInspEnum.IRR.getValue());
  997. List<BisInspObjDto> result = this.bisInspObjDao.getIrrObjByPersId(persObjParam);
  998. exportExcel(persObjParam.getIsExport(), result, response);
  999. return new PageInfo<>(result);
  1000. } else if ("29".equalsIgnoreCase(persObjParam.getObjType())) {
  1001. persObjParam.setObjType(BisInspEnum.SAP.getValue());
  1002. List<AttWagaSapBaseDto> result = this.bisInspObjDao.getSapObjByPersId(persObjParam);
  1003. exportExcel(persObjParam.getIsExport(), result, response);
  1004. return new PageInfo<>(result);
  1005. }
  1006. return null;
  1007. }
  1008. @Override
  1009. public VillRgstrEngIdDto getRgstrByCode(String code, String type, String orgId) {
  1010. String province = inspOrgService.getProvince(orgId);
  1011. VillRgstrEngIdDto villRgstrEngIdDto = new VillRgstrEngIdDto();
  1012. if ("ADX".equals(type)) {
  1013. villRgstrEngIdDto = this.bisInspVillRgstrDao.getRgstrByAdXCode(code, orgId);
  1014. }
  1015. if ("CWS".equals(type)) {
  1016. villRgstrEngIdDto = this.bisInspVillRgstrDao.getRgstrByCwsCode(code, orgId);
  1017. }
  1018. if (villRgstrEngIdDto == null) {
  1019. VillRgstrEngIdDto v1 = new VillRgstrEngIdDto();
  1020. v1.setStateCode("1003");
  1021. return v1;
  1022. } else {
  1023. if (villRgstrEngIdDto.getEngId() != null) {
  1024. villRgstrEngIdDto.setStateCode("1001");
  1025. return villRgstrEngIdDto;
  1026. } else {
  1027. if (villRgstrEngIdDto.getCode() != null) {
  1028. BisInspVillRgstr bivr = new BisInspVillRgstr();
  1029. bivr.setEngId(UUID.randomUUID().toString().replace("-", ""));
  1030. bivr.setObjId(villRgstrEngIdDto.getObjId());
  1031. bivr.setRegsNm(villRgstrEngIdDto.getNm());
  1032. Date date = new Date();
  1033. SimpleDateFormat dateFormat = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
  1034. String format = dateFormat.format(date);
  1035. bivr.setIntm(format);
  1036. bivr.setRecPersId("1");
  1037. if (!province.startsWith(AdCodeLabel.START_PARENT_ADCODE)) {
  1038. bivr.setOrgId(orgId);
  1039. }
  1040. bisInspVillRgstrService.insert(bivr);
  1041. villRgstrEngIdDto.setEngId(bivr.getEngId());
  1042. villRgstrEngIdDto.setStateCode("1002");
  1043. return villRgstrEngIdDto;
  1044. } else {
  1045. return null;
  1046. }
  1047. }
  1048. }
  1049. }
  1050. @Override
  1051. public PageInfo<AttGrwBase> getGrwNotInGroup(InGroupGrwParam inGroupGrwParam) {
  1052. if (inGroupGrwParam.getAdcd() != null) {
  1053. if (inGroupGrwParam.getAdcd().contains(",")) {//如果有多个行政区划编码,要根据逗号分隔截取
  1054. StringBuffer stringBuffer = new StringBuffer();
  1055. String[] split = inGroupGrwParam.getAdcd().split(",");
  1056. for (String s : split) {//拼接sql,对多个截取后的行政区划进行模糊查询
  1057. String subAd = AdLevelUtil.SubAd(s).get("subAd").toString();
  1058. stringBuffer.append(subAd);
  1059. stringBuffer.append("%");
  1060. stringBuffer.append("' OR ADCD LIKE '");
  1061. }
  1062. //将最后的“ OR ADCD LIKE ”截掉
  1063. String substring = stringBuffer.substring(0, stringBuffer.length() - 15);
  1064. substring = "(ADCD LIKE '" + substring + ")";
  1065. inGroupGrwParam.setAdcd(substring);
  1066. } else {
  1067. String subAd = AdLevelUtil.SubAd(inGroupGrwParam.getAdcd()).get("subAd").toString();
  1068. subAd = "ADCD LIKE '" + subAd + "%'";
  1069. inGroupGrwParam.setAdcd(subAd);
  1070. }
  1071. }
  1072. PageHelper.startPage(inGroupGrwParam.getPageNum(), inGroupGrwParam.getPageSize());
  1073. List<AttGrwBase> attGrwBaseList = this.attGrwBaseDao.getGrwNotInGroup(inGroupGrwParam);
  1074. PageInfo<AttGrwBase> pageInfo = new PageInfo<>(attGrwBaseList);
  1075. return pageInfo;
  1076. }
  1077. }