85f0d4bb81469ab8fe003babc9dc4c4dd40fc680.svn-base 53 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970971972973974975976977978979980981982983984985986987988989990991992993994995996997998999100010011002100310041005100610071008100910101011101210131014101510161017101810191020102110221023102410251026102710281029103010311032103310341035103610371038103910401041104210431044104510461047104810491050105110521053105410551056105710581059106010611062106310641065106610671068106910701071107210731074107510761077107810791080108110821083108410851086108710881089109010911092109310941095109610971098109911001101110211031104110511061107110811091110111111121113111411151116111711181119112011211122112311241125112611271128112911301131113211331134113511361137113811391140114111421143114411451146114711481149115011511152115311541155115611571158115911601161116211631164116511661167116811691170117111721173117411751176117711781179118011811182118311841185118611871188118911901191119211931194119511961197119811991200120112021203120412051206120712081209121012111212121312141215121612171218121912201221122212231224122512261227122812291230123112321233
  1. /*
  2. package cn.com.goldenwater.dcproj.service.impl.rsvr;
  3. import cn.com.goldenwater.core.service.AbstractCrudService;
  4. import cn.com.goldenwater.dcproj.constValue.BisInspEnum;
  5. import cn.com.goldenwater.dcproj.constValue.SplitValue;
  6. import cn.com.goldenwater.dcproj.dao.*;
  7. import cn.com.goldenwater.dcproj.dto.*;
  8. import cn.com.goldenwater.dcproj.model.*;
  9. import cn.com.goldenwater.dcproj.param.*;
  10. import cn.com.goldenwater.dcproj.service.BisInspBaseService;
  11. import cn.com.goldenwater.dcproj.service.impl.keyreg.AttprjBaseServiceImpl;
  12. import cn.com.goldenwater.dcproj.service.impl.vill.AttEngDikeServiceImpl;
  13. import cn.com.goldenwater.dcproj.utils.AMapUtil;
  14. import cn.com.goldenwater.dcproj.utils.AdLevelUtil;
  15. import cn.com.goldenwater.dcproj.utils.GeoUtil;
  16. import com.github.pagehelper.PageHelper;
  17. import com.github.pagehelper.PageInfo;
  18. import net.sf.json.JSONObject;
  19. import org.apache.commons.collections.map.HashedMap;
  20. import org.apache.commons.lang3.StringUtils;
  21. import org.springframework.beans.factory.annotation.Autowired;
  22. import org.springframework.jdbc.datasource.DataSourceTransactionManager;
  23. import org.springframework.stereotype.Service;
  24. import org.springframework.transaction.annotation.Transactional;
  25. import java.text.DecimalFormat;
  26. import java.util.*;
  27. import java.util.function.Function;
  28. import java.util.stream.Collectors;
  29. */
  30. /**
  31. * @author lhc
  32. * @date 2019-2-20
  33. *//*
  34. @Service
  35. @Transactional(rollbackFor = Exception.class)
  36. public class BisInspBaseServiceImpl extends AbstractCrudService<BisInspBase, BisInspParam> implements BisInspBaseService {
  37. @Autowired
  38. private BisInspBaseDao bisInspBaseDao;
  39. @Autowired
  40. private AttEmpwtprjBaseServiceImpl attEmpwtprjBaseService;
  41. @Autowired
  42. private TacInspYearBatchGroupPersDao groupPersDao;
  43. @Autowired
  44. private BisInspAllRlationPersDao rlationPersDao;
  45. @Autowired
  46. private TacInspYearBatchGroupDao groupDao;
  47. @Autowired
  48. private TacInspYearBatchAreaDao tacInspYearBatchAreaDao;
  49. @Autowired
  50. private TacWorkerBDao workerBDao;
  51. @Autowired
  52. private TacAttPawpBaseDao tacAttPawpBaseDao;
  53. @Autowired
  54. private TacPawpRgstrDao tacPawpRgstrDao;
  55. @Autowired
  56. private TacInspYearBatchObjDao tacInspYearBatchObjDao;
  57. public BisInspBaseServiceImpl(BisInspBaseDao bisInspBaseDao) {
  58. super(bisInspBaseDao);
  59. this.bisInspBaseDao = bisInspBaseDao;
  60. }
  61. @Override
  62. public PageInfo getCatalog(BisInspParam bisInspParam) {
  63. String type = bisInspParam.getType()==null?"":bisInspParam.getType();
  64. bisInspParam.setAddvcd(AdLevelUtil.getAddvcd(bisInspParam.getAddvcd()));
  65. if ("RSVR".equals(type)) {
  66. return getPageRsvrList(bisInspParam);
  67. } else if (type.equals("CWS")) {
  68. return getPageCwsList(bisInspParam);
  69. } else if (type.equals("WTDST")) {
  70. return getPageWtdstList(bisInspParam);
  71. } else if (type.equals("WS")) {
  72. return getPageWrWsList(bisInspParam);
  73. } else {
  74. return null;
  75. }
  76. }
  77. @Override
  78. public PageInfo getPageRsvrList(BisInspParam bisInspParam) {
  79. bisInspParam.setAddvcd(AdLevelUtil.getAddvcd(bisInspParam.getAddvcd()));
  80. PageHelper.startPage(bisInspParam.getPageNum(), bisInspParam.getPageSize());
  81. List<BisInspBaseDto> bisInspBaseDtos = getRsvrList(bisInspParam);
  82. PageInfo page = new PageInfo(bisInspBaseDtos);
  83. return page;
  84. }
  85. @Override
  86. public PageInfo getPageCwsList(BisInspParam bisInspParam) {
  87. bisInspParam.setAddvcd(AdLevelUtil.getAddvcd(bisInspParam.getAddvcd()));
  88. PageHelper.startPage(bisInspParam.getPageNum(), bisInspParam.getPageSize());
  89. List<BisInspBaseDto> bisInspBaseDtos = getCwsList(bisInspParam);
  90. PageInfo page = new PageInfo(bisInspBaseDtos);
  91. return page;
  92. }
  93. @Override
  94. public PageInfo getPageWtdstList(BisInspParam bisInspParam) {
  95. bisInspParam.setAddvcd(AdLevelUtil.getAddvcd(bisInspParam.getAddvcd()));
  96. PageHelper.startPage(bisInspParam.getPageNum(), bisInspParam.getPageSize());
  97. List<BisInspBaseDto> bisInspBaseDtos = getWtdstList(bisInspParam);
  98. PageInfo page = new PageInfo(bisInspBaseDtos);
  99. return page;
  100. }
  101. @Override
  102. public List<BisInspBaseDto> getBaseList(BisInspParam bisInspParam) {
  103. String type = bisInspParam.getType()==null?"":bisInspParam.getType();
  104. bisInspParam.setAddvcd(AdLevelUtil.getAddvcd(bisInspParam.getAddvcd()));
  105. if (type.equals("RSVR")) {
  106. return getRsvrList(bisInspParam);
  107. } else if (type.equals("CWS")) {
  108. return getCwsList(bisInspParam);
  109. } else if (type.equals("WTDST")) {
  110. return getWtdstList(bisInspParam);
  111. } else if (type.equals("groundwater")) {
  112. return getGrwList(bisInspParam);
  113. } else if (type.equalsIgnoreCase("empwt")) {
  114. return getEmpwtprjList(bisInspParam);
  115. } else if (type.equalsIgnoreCase("sluice")) { //水闸
  116. return getWagaList(bisInspParam);
  117. } else if (type.equalsIgnoreCase("wain")) { //取水口
  118. return getWainList(bisInspParam);
  119. } else if (type.equalsIgnoreCase("stbprp")) { //水文站
  120. return getStbprpList(bisInspParam);
  121. } else if (type.equalsIgnoreCase("swhs")) { //地表水水源地
  122. return getSwhsList(bisInspParam);
  123. } else if (type.equalsIgnoreCase("sd")) {//淤地坝
  124. return getSdList(bisInspParam);
  125. } else if (type.equalsIgnoreCase("keyswyhs")) { //重点水源地
  126. return getSwhsList(bisInspParam);
  127. } else if (type.equalsIgnoreCase("wiu")) {
  128. return getWiuList(bisInspParam);
  129. } else if (type.equalsIgnoreCase("city")) {
  130. return getCityList(bisInspParam);
  131. } else if (type.equalsIgnoreCase("svwt")) {
  132. return getSvwtList(bisInspParam);
  133. } else if (type.equalsIgnoreCase("wunt")){
  134. return getWuntList(bisInspParam);
  135. }else if (type.equalsIgnoreCase("prd")){
  136. return getPrdtList(bisInspParam);
  137. }else if (type.equalsIgnoreCase("jsfl")){
  138. return getJsfltList(bisInspParam);
  139. }else if (type.equalsIgnoreCase("jswa")){
  140. return getJswatList(bisInspParam);
  141. } else if (type.equalsIgnoreCase("rsml")) {
  142. bisInspParam.setObjType("22");
  143. return getRsvrList(bisInspParam);
  144. } else {
  145. return null;
  146. }
  147. }
  148. private List<BisInspBaseDto> getJswatList(BisInspParam bisInspParam) {
  149. return this.bisInspBaseDao.getJswatList(bisInspParam);
  150. }
  151. private List<BisInspBaseDto> getJsfltList(BisInspParam bisInspParam) {
  152. return this.bisInspBaseDao.getJsfltList(bisInspParam);
  153. }
  154. private List<BisInspBaseDto> getPrdtList(BisInspParam bisInspParam) {
  155. return this.bisInspBaseDao.getPrdList(bisInspParam);
  156. }
  157. private List<BisInspBaseDto> getWuntList(BisInspParam bisInspParam) {
  158. return this.bisInspBaseDao.getWuntList(bisInspParam);
  159. }
  160. private List<BisInspBaseDto> getSvwtList(BisInspParam bisInspParam) {
  161. return this.bisInspBaseDao.getSvwtList(bisInspParam);
  162. }
  163. private List<BisInspBaseDto> getCityList(BisInspParam bisInspParam) {
  164. return this.bisInspBaseDao.getCityList(bisInspParam);
  165. }
  166. private List<BisInspBaseDto> getWiuList(BisInspParam bisInspParam) {
  167. return this.bisInspBaseDao.getWiuList(bisInspParam);
  168. }
  169. @Override
  170. public AttEngDto getBaseListTop3(BisInspParam bisInspParam) {
  171. AttEngDto attEngDto = new AttEngDto();
  172. attEngDto.setRsvrList(getRsvrListTop3(bisInspParam));//水库
  173. attEngDto.setCwsList(getCwsListTop3(bisInspParam));//农饮
  174. attEngDto.setWtdstList(getWtdstListTop3(bisInspParam));//水毁
  175. attEngDto.setAdXList(getAdXListTop3(bisInspParam));//村
  176. attEngDto.setWsList(getWsListTop3(bisInspParam));//水源地
  177. attEngDto.setEmpwtConList(getEmpwtConListTop3(bisInspParam));//172工程建设
  178. attEngDto.setEmpwtRunList(getEmpwtRunListTop3(bisInspParam));//172工程运行
  179. attEngDto.setGrwList(getGrwListTop3(bisInspParam));//地下水
  180. attEngDto.setWagaList(getWagaListTop3(bisInspParam));//水闸
  181. attEngDto.setWainList(getWainListTop3(bisInspParam));//取水口
  182. attEngDto.setStbprpList(getStbprpListTop3(bisInspParam));//水位站
  183. attEngDto.setSwhsList(getSwhsListTop3(bisInspParam));//地表水源地
  184. attEngDto.setSdList(getSdListTop3(bisInspParam));
  185. attEngDto.setWiuList(getWiuListTop3(bisInspParam));
  186. bisInspParam.setNote("new");
  187. attEngDto.setKeySwhsList(getSwhsListTop3(bisInspParam));
  188. attEngDto.setCityList(getCityListTop3(bisInspParam));
  189. attEngDto.setSvwtList(getSvwtListTop3(bisInspParam));
  190. attEngDto.setWuntList(getWuntListTop3(bisInspParam));
  191. attEngDto.setWintLicList(getWintLicListTop3(bisInspParam));
  192. attEngDto.setPrdList(getPrdListTop3(bisInspParam));
  193. attEngDto.setJsflList(getJsflListTop3(bisInspParam));
  194. attEngDto.setJswaList(getJswaListTop3(bisInspParam));
  195. return attEngDto;
  196. }
  197. private List<BisInspBaseDto> getJswaListTop3(BisInspParam bisInspParam) {
  198. return this.bisInspBaseDao.getJswaListTop3(bisInspParam);
  199. }
  200. private List<BisInspBaseDto> getJsflListTop3(BisInspParam bisInspParam) {
  201. return this.bisInspBaseDao.getJsflListTop3(bisInspParam);
  202. }
  203. private List<BisInspBaseDto> getPrdListTop3(BisInspParam bisInspParam) {
  204. return this.bisInspBaseDao.getPrdListTop3(bisInspParam);
  205. }
  206. private List<BisInspBaseDto> getWintLicListTop3(BisInspParam bisInspParam){
  207. return this.bisInspBaseDao.getWintLicListTop3(bisInspParam);
  208. }
  209. private List<BisInspBaseDto> getWuntListTop3(BisInspParam bisInspParam) {
  210. return this.bisInspBaseDao.getWuntListTop3(bisInspParam);
  211. }
  212. private List<BisInspBaseDto> getSvwtListTop3(BisInspParam bisInspParam) {
  213. return this.bisInspBaseDao.getSvwtListTop3(bisInspParam);
  214. }
  215. private List<BisInspBaseDto> getCityListTop3(BisInspParam bisInspParam) {
  216. return this.bisInspBaseDao.getCityListTop3(bisInspParam);
  217. }
  218. private List<BisInspBaseDto> getWiuListTop3(BisInspParam bisInspParam) {
  219. return this.bisInspBaseDao.getWiuListTop3(bisInspParam);
  220. }
  221. private List<BisInspBaseDto> getSdListTop3(BisInspParam bisInspParam) {
  222. return this.bisInspBaseDao.getSdListTop3(bisInspParam);
  223. }
  224. private List<BisInspBaseDto> getSwhsListTop3(BisInspParam bisInspParam) {
  225. return this.bisInspBaseDao.getSwhsListTop3(bisInspParam);
  226. }
  227. private List<BisInspBaseDto> getStbprpListTop3(BisInspParam bisInspParam) {
  228. return this.bisInspBaseDao.getStbprpListTop3(bisInspParam);
  229. }
  230. private List<BisInspBaseDto> getWainListTop3(BisInspParam bisInspParam) {
  231. return this.bisInspBaseDao.getWainListTop3(bisInspParam);
  232. }
  233. private List<BisInspBaseDto> getWagaListTop3(BisInspParam bisInspParam) {
  234. return this.bisInspBaseDao.getWagaListTop3(bisInspParam);
  235. }
  236. private List<BisInspBaseDto> getGrwListTop3(BisInspParam bisInspParam) {
  237. return this.bisInspBaseDao.getGrwListTop3(bisInspParam);
  238. }
  239. private List<BisInspBaseDto> getEmpwtConListTop3(BisInspParam bisInspParam) {
  240. return this.bisInspBaseDao.getEmpwtConListTop3(bisInspParam);
  241. }
  242. private List<BisInspBaseDto> getEmpwtRunListTop3(BisInspParam bisInspParam) {
  243. return this.bisInspBaseDao.getEmpwtRunListTop3(bisInspParam);
  244. }
  245. private List<BisInspBaseDto> getWsListTop3(BisInspParam bisInspParam) {
  246. return this.bisInspBaseDao.getWsListTop3(bisInspParam);
  247. }
  248. private List<BisInspBaseDto> getAdXListTop3(BisInspParam bisInspParam) {
  249. return this.bisInspBaseDao.getAdXListTop3(bisInspParam);
  250. }
  251. @Override
  252. public AttRsBaseDto getRsvrByCode(String code,String province) {
  253. return bisInspBaseDao.getRsvrByCode(code,province);
  254. }
  255. @Override
  256. public AttPrdCstrProjBase getPrdByCode(String code) {
  257. return bisInspBaseDao.getPrdByCode(code);
  258. }
  259. @Override
  260. public AttJskejianFlkdisBase getJSFLByCode(String code) {
  261. return bisInspBaseDao.getJSFLByCode(code);
  262. }
  263. @Override
  264. public AttJskejianWaterBase getJswaByCode(String code) {
  265. return bisInspBaseDao.getJswaByCode(code);
  266. }
  267. @Override
  268. public PageInfo getPagePrdList(BisInspParam bisInspParam) {
  269. bisInspParam.setAddvcd(AdLevelUtil.getAddvcd(bisInspParam.getAddvcd()));
  270. PageHelper.startPage(bisInspParam.getPageNum(), bisInspParam.getPageSize());
  271. List<BisInspBaseDto> bisInspBaseDtos = getPrdtList(bisInspParam);
  272. PageInfo page = new PageInfo(bisInspBaseDtos);
  273. return page;
  274. }
  275. @Override
  276. public PageInfo getPageJsflList(BisInspParam bisInspParam) {
  277. bisInspParam.setAddvcd(AdLevelUtil.getAddvcd(bisInspParam.getAddvcd()));
  278. PageHelper.startPage(bisInspParam.getPageNum(), bisInspParam.getPageSize());
  279. List<BisInspBaseDto> bisInspBaseDtos = getJsfltList(bisInspParam);
  280. PageInfo page = new PageInfo(bisInspBaseDtos);
  281. return page;
  282. }
  283. @Override
  284. public PageInfo getPageJswaList(BisInspParam bisInspParam) {
  285. bisInspParam.setAddvcd(AdLevelUtil.getAddvcd(bisInspParam.getAddvcd()));
  286. PageHelper.startPage(bisInspParam.getPageNum(), bisInspParam.getPageSize());
  287. List<BisInspBaseDto> bisInspBaseDtos = getJswatList(bisInspParam);
  288. PageInfo page = new PageInfo(bisInspBaseDtos);
  289. return page;
  290. }
  291. @Override
  292. public AttScnsrBaseDto getScnsrByCode(String code) {
  293. return bisInspBaseDao.getScnsrByCode(code);
  294. }
  295. @Override
  296. public AttEngCwsDto getCwsByCode(String code) {
  297. return bisInspBaseDao.getCwsByCode(code);
  298. }
  299. @Override
  300. public BisInspWtdstDto getWtdstByCode(String code) {
  301. return bisInspBaseDao.getWtdstByCode(code);
  302. }
  303. @Override
  304. public List<BisInspPlanDto> getInspPlan(String userid,String province) {
  305. List<BisInspPlanDto> bisInspPlanDtos = bisInspBaseDao.getInspPlanCount(userid,province);
  306. Boolean isGly = false;
  307. for (int i = 0; i < bisInspPlanDtos.size(); i++) {
  308. if (bisInspPlanDtos.get(i).getPlnaId().length() <= 3) {
  309. isGly = true;
  310. }
  311. }
  312. List<BisInspPlanDto> result = new ArrayList<>();
  313. if (isGly) {
  314. result.addAll(bisInspBaseDao.getInspGlPlan(userid,province));
  315. } else {
  316. result.addAll(bisInspBaseDao.getInspPlan(userid,province));
  317. }
  318. TacWorkerBParam param = new TacWorkerBParam();
  319. param.setLoginId(userid);
  320. if (workerBDao.findList(param).size() > 0) {
  321. //根据id查询
  322. String persType = rlationPersDao.get(userid).getPersType();
  323. TacInspYearBatchGroupParam groupParam = new TacInspYearBatchGroupParam();
  324. if (!"1".equals(persType)) {
  325. groupParam.setPersId(userid);
  326. }
  327. List<TacInspYearBatchGroup> groupList = groupDao.getGroupListApp(groupParam);
  328. if (groupList.size() > 0) {
  329. groupList.forEach(group -> {
  330. TacInspYearBatchAreaParam areaParam = new TacInspYearBatchAreaParam();
  331. areaParam.setGroupId(group.getId());
  332. List<TacInspYearBatchArea> areaList = tacInspYearBatchAreaDao.findList(areaParam);
  333. BisInspPlanDto dto = new BisInspPlanDto();
  334. dto.setPlnaId(group.getId());
  335. dto.setPrsnTitle(group.getGroupNm().toString());
  336. dto.setPtype("8");
  337. if (areaList.size() > 0) {
  338. StringBuffer area = new StringBuffer("");
  339. areaList.forEach(tacInspYearBatchArea -> {
  340. area.append(tacInspYearBatchArea.getAdName()).append(",");
  341. });
  342. if (area.indexOf(",") > 0){
  343. dto.setPrsnTitle(area.substring(0,area.length() - 1));
  344. }
  345. }
  346. result.add(dto);
  347. });
  348. }
  349. }
  350. return result;
  351. }
  352. @Override
  353. public List<BisInspGroupPersonDto> getGroupPerson(String groupID, String persName,String province) {
  354. return bisInspBaseDao.getGroupPerson(groupID, persName,province);
  355. }
  356. @Override
  357. public List<BisInspGroupPersonDto> getGroupPersonV2(String groupID, String persName, String orgId) {
  358. return bisInspBaseDao.getGroupPersonV2(groupID, persName, orgId);
  359. }
  360. @Override
  361. public List<BisInspGroupInfoDto> getPersonGroup(String userid) {
  362. return bisInspBaseDao.getPersonGroup(userid);
  363. }
  364. @Override
  365. public List<BisInspGroupInfoDto> getGroupByPersId(String persid,String province) {
  366. return bisInspBaseDao.getGroupByPersId(persid,province);
  367. }
  368. @Override
  369. public List<BisInspBaseDto> getListRsvrList(BisInspParam bisInspParam) {
  370. bisInspParam.setAddvcd(AdLevelUtil.getAddvcd(bisInspParam.getAddvcd()));
  371. List<BisInspBaseDto> bisInspBaseDtos = getRsvrList(bisInspParam);
  372. return bisInspBaseDtos;
  373. }
  374. @Override
  375. public List getListCwsList(BisInspParam bisInspParam) {
  376. bisInspParam.setAddvcd(AdLevelUtil.getAddvcd(bisInspParam.getAddvcd()));
  377. List<BisInspBaseDto> bisInspBaseDtos = getCwsList(bisInspParam);
  378. return bisInspBaseDtos;
  379. }
  380. @Override
  381. public int exchangeCoordinate(String type) {
  382. int i = 0;
  383. if ("ATT_RS_BASE".equals(type)) {
  384. List<AttRsBase> attRsBaseList = this.bisInspBaseDao.exchangeCoordinate();
  385. if (attRsBaseList.size() > 0) {
  386. for (AttRsBase attRsBase : attRsBaseList) {
  387. if (attRsBase.getCenterX() != null && attRsBase.getCenterY() != null) {
  388. Map<String, Double> map = GeoUtil.wgs84togcj02(Double.parseDouble(attRsBase.getCenterX()), Double.parseDouble(attRsBase.getCenterY()));
  389. i += this.bisInspBaseDao.updateCoordinate(attRsBase.getRsCode(), map.get("lon"), map.get("lat"));
  390. }
  391. }
  392. }
  393. }
  394. if ("ATT_AD_X_BASE".equals(type)) {
  395. List<AttRsBase> attRsBaseList = this.bisInspBaseDao.exchangeCoordinate();
  396. if (attRsBaseList.size() > 0) {
  397. for (AttRsBase attRsBase : attRsBaseList) {
  398. if (attRsBase.getCenterX() != null && attRsBase.getCenterY() != null) {
  399. Map<String, Double> map = GeoUtil.wgs84togcj02(Double.parseDouble(attRsBase.getCenterX()), Double.parseDouble(attRsBase.getCenterY()));
  400. i += this.bisInspBaseDao.updateCoordinate(attRsBase.getRsCode(), map.get("lon"), map.get("lat"));
  401. }
  402. }
  403. }
  404. }
  405. if ("BIS_INSP_WTDST".equals(type)) {
  406. List<AttRsBase> bisInspBases = this.bisInspBaseDao.exchangeWtdstCoordinate();
  407. if (bisInspBases.size() > 0) {
  408. for (AttRsBase attRsBase : bisInspBases) {
  409. if (attRsBase.getCenterX() != null && attRsBase.getCenterY() != null) {
  410. Map<String, Double> map = GeoUtil.wgs84togcj02(Double.parseDouble(attRsBase.getCenterX()), Double.parseDouble(attRsBase.getCenterY()));
  411. i += this.bisInspBaseDao.updateWtdstCoordinate(attRsBase.getRsCode(), map.get("lon"), map.get("lat"));
  412. }
  413. }
  414. }
  415. }
  416. if ("ATT_CWS_BASE".equals(type)) {
  417. List<AttRsBase> bisInspBases = this.bisInspBaseDao.exchangeCwsCoordinate();
  418. if (bisInspBases.size() > 0) {
  419. int j = 0;
  420. DecimalFormat df = new DecimalFormat("0.0000000000");
  421. for (AttRsBase attRsBase : bisInspBases) {
  422. if (attRsBase.getCenterX() != null && attRsBase.getCenterY() != null) {
  423. j++;
  424. Map<String, Double> map = GeoUtil.wgs84togcj02(Double.parseDouble(attRsBase.getCenterX()), Double.parseDouble(attRsBase.getCenterY()));
  425. try {
  426. this.bisInspBaseDao.updateCwsCoordinate(attRsBase.getRsCode(), Double.parseDouble(df.format(map.get("lon"))), Double.parseDouble(df.format(map.get("lat"))));
  427. } catch (Exception e) {
  428. continue;
  429. }
  430. }
  431. }
  432. }
  433. }
  434. if ("ATT_GRW_BASE".equals(type)) {
  435. List<AttRsBase> bisInspBases = this.bisInspBaseDao.exchangeGrwCoordinate();
  436. if (bisInspBases.size() > 0) {
  437. int j = 0;
  438. DecimalFormat df = new DecimalFormat("0.0000000000");
  439. for (AttRsBase attRsBase : bisInspBases) {
  440. if (attRsBase.getCenterX() != null && attRsBase.getCenterY() != null) {
  441. j++;
  442. Map<String, Double> map = GeoUtil.wgs84togcj02(Double.parseDouble(attRsBase.getCenterX()), Double.parseDouble(attRsBase.getCenterY()));
  443. try {
  444. this.bisInspBaseDao.updateGrwCoordinate(attRsBase.getRsCode(), Double.parseDouble(df.format(map.get("lon"))), Double.parseDouble(df.format(map.get("lat"))));
  445. } catch (Exception e) {
  446. continue;
  447. }
  448. }
  449. }
  450. }
  451. }
  452. if ("ATT_WAGA_BASE".equals(type)) {
  453. List<AttRsBase> bisInspBases = this.bisInspBaseDao.exchangeWagaCoordinate();
  454. if (bisInspBases.size() > 0) {
  455. int j = 0;
  456. DecimalFormat df = new DecimalFormat("0.0000000000");
  457. for (AttRsBase attRsBase : bisInspBases) {
  458. if (attRsBase.getCenterX() != null && attRsBase.getCenterY() != null) {
  459. j++;
  460. Map<String, Double> map = GeoUtil.wgs84togcj02(Double.parseDouble(attRsBase.getCenterX()), Double.parseDouble(attRsBase.getCenterY()));
  461. try {
  462. this.bisInspBaseDao.updateWagaCoordinate(attRsBase.getRsCode(), Double.parseDouble(df.format(map.get("lon"))), Double.parseDouble(df.format(map.get("lat"))));
  463. } catch (Exception e) {
  464. continue;
  465. }
  466. }
  467. }
  468. }
  469. }
  470. if ("ATT_WAIN_BASE".equals(type)) {
  471. List<AttRsBase> bisInspBases = this.bisInspBaseDao.exchangeWainCoordinate();
  472. if (bisInspBases.size() > 0) {
  473. int j = 0;
  474. DecimalFormat df = new DecimalFormat("0.0000000000");
  475. for (AttRsBase attRsBase : bisInspBases) {
  476. if (attRsBase.getCenterX() != null && attRsBase.getCenterY() != null) {
  477. j++;
  478. Map<String, Double> map = GeoUtil.wgs84togcj02(Double.parseDouble(attRsBase.getCenterX()), Double.parseDouble(attRsBase.getCenterY()));
  479. try {
  480. this.bisInspBaseDao.updateWainCoordinate(attRsBase.getRsCode(), Double.parseDouble(df.format(map.get("lon"))), Double.parseDouble(df.format(map.get("lat"))));
  481. } catch (Exception e) {
  482. continue;
  483. }
  484. }
  485. }
  486. }
  487. }
  488. if ("ST_STBPRP_B".equals(type)) {
  489. List<AttRsBase> bisInspBases = this.bisInspBaseDao.exchangeStbprpCoordinate();
  490. if (bisInspBases.size() > 0) {
  491. int j = 0;
  492. DecimalFormat df = new DecimalFormat("0.0000000000");
  493. for (AttRsBase attRsBase : bisInspBases) {
  494. if (attRsBase.getCenterX() != null && attRsBase.getCenterY() != null) {
  495. j++;
  496. Map<String, Double> map = GeoUtil.wgs84togcj02(Double.parseDouble(attRsBase.getCenterX()), Double.parseDouble(attRsBase.getCenterY()));
  497. try {
  498. this.bisInspBaseDao.updateStbprpCoordinate(attRsBase.getRsCode(), Double.parseDouble(df.format(map.get("lon"))), Double.parseDouble(df.format(map.get("lat"))));
  499. } catch (Exception e) {
  500. continue;
  501. }
  502. }
  503. }
  504. }
  505. }
  506. if ("ATT_SWHS_BASE".equals(type)) {
  507. List<AttRsBase> bisInspBases = this.bisInspBaseDao.exchangeSwhsCoordinate();
  508. if (bisInspBases.size() > 0) {
  509. int j = 0;
  510. DecimalFormat df = new DecimalFormat("0.0000000000");
  511. for (AttRsBase attRsBase : bisInspBases) {
  512. if (attRsBase.getCenterX() != null && attRsBase.getCenterY() != null) {
  513. j++;
  514. Map<String, Double> map = GeoUtil.wgs84togcj02(Double.parseDouble(attRsBase.getCenterX()), Double.parseDouble(attRsBase.getCenterY()));
  515. try {
  516. this.bisInspBaseDao.updateSwhsCoordinate(attRsBase.getRsCode(), Double.parseDouble(df.format(map.get("lon"))), Double.parseDouble(df.format(map.get("lat"))));
  517. } catch (Exception e) {
  518. continue;
  519. }
  520. }
  521. }
  522. }
  523. }
  524. if ("ATT_WAGA_BASE.AD_CODE".equals(type)) {
  525. List<AttRsBase> bisInspBases = this.bisInspBaseDao.getWagaAdName();
  526. if (bisInspBases.size() > 0) {
  527. int j = 0;
  528. for (AttRsBase attRsBase : bisInspBases) {
  529. j++;
  530. AttRsBase ar = this.bisInspBaseDao.getAdCode(attRsBase.getAdFullName());
  531. this.bisInspBaseDao.updateWagaAdCode(attRsBase.getRsCode(), ar.getAdmDiv());
  532. }
  533. }
  534. }
  535. return 1;
  536. }
  537. @Override
  538. public WrWsB getWrWsByCode(String code) {
  539. WrWsB wrWsB = new WrWsB();
  540. wrWsB = this.bisInspBaseDao.getWrGwsByCode(code);//查询地下水源地表
  541. if (wrWsB == null) {//如果查询结果为空,再查询地表水源地
  542. wrWsB = this.bisInspBaseDao.getWrSwsByCode(code);
  543. }
  544. return wrWsB;
  545. }
  546. @Override
  547. public PageInfo getPageWrWsList(BisInspParam bisInspParam) {
  548. PageHelper.startPage(bisInspParam.getPageNum(), bisInspParam.getPageSize());
  549. List<WrWsB> bisInspBaseDtos = getWrWsList(bisInspParam);
  550. PageInfo page = new PageInfo(bisInspBaseDtos);
  551. return page;
  552. }
  553. @Override
  554. public List<WrWsB> getWrWsList(BisInspParam bisInspParam) {
  555. Map<String, Object> map = AdLevelUtil.SubAd(bisInspParam.getAddvcd());
  556. bisInspParam.setAddvcd(map.get(SplitValue.SUBAD).toString());
  557. return this.bisInspBaseDao.getWrWsList(bisInspParam);
  558. }
  559. @Override
  560. public List<AttAdXBase> getAdXList(BisInspParam bisInspParam) {
  561. bisInspParam.setAddvcd(AdLevelUtil.getAddvcd(bisInspParam.getAddvcd()));
  562. return this.bisInspBaseDao.getAdXList(bisInspParam);
  563. }
  564. @Override
  565. public PageInfo getPageAdXList(BisInspParam bisInspParam) {
  566. bisInspParam.setAddvcd(AdLevelUtil.getAddvcd(bisInspParam.getAddvcd()));
  567. PageHelper.startPage(bisInspParam.getPageNum(), bisInspParam.getPageSize());
  568. List<AttAdXBase> bisInspBaseDtos = getAdXList(bisInspParam);
  569. PageInfo page = new PageInfo(bisInspBaseDtos);
  570. return page;
  571. }
  572. @Override
  573. public AttAdXBase getAdXByCode(String code) {
  574. return this.bisInspBaseDao.getAdXByCode(code);
  575. }
  576. @Override
  577. public List<ProCount> getProCountByType() {
  578. return this.bisInspBaseDao.getProCountByType();
  579. }
  580. @Override
  581. public List<ProCount> getSchCountByType() {
  582. List<ProCount> proCountList = new ArrayList<>();
  583. ProCount p1 = this.bisInspBaseDao.getSchCountByRs();
  584. ProCount p2 = this.bisInspBaseDao.getSchCountByVill();
  585. ProCount p3 = this.bisInspBaseDao.getSchCountByWtd();
  586. if (p1 != null) {
  587. proCountList.add(p1);
  588. }
  589. if (p2 != null) {
  590. proCountList.add(p2);
  591. }
  592. if (p3 != null) {
  593. proCountList.add(p3);
  594. }
  595. return proCountList;
  596. }
  597. @Override
  598. public List<ProAdCount> getProCountByAd() {
  599. return this.bisInspBaseDao.getProCountByAd();
  600. }
  601. @Override
  602. public List<AdXBaseDto> getAdXBaseList(BisInspParam bisInspParam) {
  603. bisInspParam.setAddvcd(AdLevelUtil.getAddvcd(bisInspParam.getAddvcd()));
  604. return this.bisInspBaseDao.getAdXBaseList(bisInspParam);
  605. }
  606. @Override
  607. public List<BisInspAll> getInspByPersid(String persid) {
  608. return this.bisInspBaseDao.getInspByPersid(persid);
  609. }
  610. @Override
  611. public List<BisInspAll> getInspByPid(String pid) {
  612. return this.bisInspBaseDao.getInspByPid(pid);
  613. }
  614. @Override
  615. public List<BisInspBaseDto> getRsvrList(BisInspParam bisInspParam) {
  616. if(StringUtils.isNotBlank(bisInspParam.getEngScal()) && (bisInspParam.getEngScal().contains("4")||
  617. bisInspParam.getEngScal().contains("5"))){
  618. bisInspParam.setType("RSVR");
  619. }
  620. return bisInspBaseDao.getRsvrList(bisInspParam);
  621. }
  622. public List<BisInspBaseDto> getGrwList(BisInspParam bisInspParam) {
  623. return bisInspBaseDao.getGrwList(bisInspParam);
  624. }
  625. public List<BisInspBaseDto> getWagaList(BisInspParam bisInspParam) {
  626. return bisInspBaseDao.getWagaList(bisInspParam);
  627. }
  628. public List<BisInspBaseDto> getWainList(BisInspParam bisInspParam) {
  629. return bisInspBaseDao.getWainList(bisInspParam);
  630. }
  631. public List<BisInspBaseDto> getStbprpList(BisInspParam bisInspParam) {
  632. return bisInspBaseDao.getStbprpList(bisInspParam);
  633. }
  634. public List<BisInspBaseDto> getSwhsList(BisInspParam bisInspParam) {
  635. return bisInspBaseDao.getSwhsList(bisInspParam);
  636. }
  637. public List<BisInspBaseDto> getEmpwtprjList(BisInspParam bisInspParam) {
  638. return bisInspBaseDao.getEmpwtprjList(bisInspParam);
  639. }
  640. @Override
  641. public List<BisInspBaseDto> getSdList(BisInspParam bisInspParam) {
  642. return bisInspBaseDao.getSdList(bisInspParam);
  643. }
  644. @Override
  645. public List<BisInspBaseDto> getCwsList(BisInspParam bisInspParam) {
  646. return bisInspBaseDao.getCwsList(bisInspParam);
  647. }
  648. @Override
  649. public List<BisInspBaseDto> getWtdstList(BisInspParam bisInspParam) {
  650. return bisInspBaseDao.getWtdstList(bisInspParam);
  651. }
  652. public List<BisInspBaseDto> getRsvrListTop3(BisInspParam bisInspParam) {
  653. return bisInspBaseDao.getRsvrListTop3(bisInspParam);
  654. }
  655. public List<BisInspBaseDto> getCwsListTop3(BisInspParam bisInspParam) {
  656. return bisInspBaseDao.getCwsListTop3(bisInspParam);
  657. }
  658. public List<BisInspBaseDto> getWtdstListTop3(BisInspParam bisInspParam) {
  659. return bisInspBaseDao.getWtdstListTop3(bisInspParam);
  660. }
  661. @Override
  662. public AllObjDto findAllObj(FindAllObjDto findAllObjDto) {
  663. AllObjDto allObjDto = new AllObjDto();
  664. allObjDto.setAttPersBaseList(this.findAllPers(findAllObjDto));
  665. allObjDto.setAttPersRsList(this.findAllRs(findAllObjDto));
  666. allObjDto.setAttPersWtdstList(this.findAllWtdst(findAllObjDto));
  667. allObjDto.setAttCwsBaseList(this.findAllCws(findAllObjDto));
  668. allObjDto.setAttGrwBaseList(this.findAllGrw(findAllObjDto));
  669. allObjDto.setAttEmpwtprjBasePageInfo(this.findAllEmpwtprj(findAllObjDto));
  670. return allObjDto;
  671. }
  672. @Override
  673. public AttGrwBase getGroundWaterByCode(String code) {
  674. return this.bisInspBaseDao.getGroundWaterByCode(code);
  675. }
  676. @Override
  677. public AttEmpwtprjBase getEmpwtprjListByCode(String code) {
  678. return attEmpwtprjBaseService.get(code);
  679. }
  680. @Override
  681. public AttWagaBase getSluiceByCode(String code) {
  682. return this.bisInspBaseDao.getSluiceByCode(code);
  683. }
  684. @Autowired
  685. private BisInspAllDao bisInspAllDao;
  686. @Override
  687. public List<BisInspAll> findAreas() {
  688. return bisInspAllDao.findAreas();
  689. }
  690. @Override
  691. public List<BisInspAll> getGroupByPidAndPersid(String pid, String persid,String province) {
  692. return this.bisInspBaseDao.getGroupByPidAndPersid(pid, persid, province);
  693. }
  694. @Override
  695. public List<BisInspPlanDto> getByPersid(String userid, String pid,String province) {
  696. List<BisInspPlanDto> resultList = new ArrayList<>();
  697. List<BisInspPlanDto> clearRepeatList = new ArrayList<>();
  698. Map<String, Object> map = new HashedMap();
  699. if ("0".equals(pid)) {//获取类型
  700. List<BisInspPlanDto> list = this.bisInspBaseDao.getPersType(userid,province);
  701. TacInspYearBatchGroupPersParam persParam = new TacInspYearBatchGroupPersParam();
  702. persParam.setPersId(userid);
  703. persParam.setProvince(province);
  704. List<?> groupPersList = groupPersDao.findPersList(persParam);
  705. Map<String, BisInspPlanDto> resultMap = list.stream().collect(Collectors.toMap(BisInspPlanDto::getPtype, Function.identity()));
  706. if (groupPersList.size() > 0) {
  707. if (!resultMap.containsKey(BisInspEnum.PAWP.getValue())) {
  708. BisInspPlanDto dto = new BisInspPlanDto();
  709. dto.setPlnaId(BisInspEnum.PAWP.getRlation());
  710. dto.setPtype(BisInspEnum.PAWP.getValue());
  711. dto.setPrsnTitle("稽察工作");
  712. resultMap.put(BisInspEnum.PAWP.getValue(), dto);
  713. List<BisInspPlanDto> result = new ArrayList<>(resultMap.values());
  714. Collections.sort(result, new Comparator<BisInspPlanDto>() {
  715. @Override
  716. public int compare(BisInspPlanDto o1, BisInspPlanDto o2) {
  717. return o1.getPtype().compareTo(o2.getPtype());
  718. }
  719. });
  720. return result;
  721. }
  722. } else {
  723. if (resultMap.containsKey(BisInspEnum.PAWP.getValue())) {
  724. list.remove(resultMap.get(BisInspEnum.PAWP.getValue()));
  725. }
  726. }
  727. return list;
  728. } else {
  729. if (pid.startsWith(BisInspEnum.PAWP.getRlation())) {
  730. TacInspYearBatchGroupPersParam param = new TacInspYearBatchGroupPersParam();
  731. String persType = rlationPersDao.get(userid).getPersType();
  732. param.setProvince(province);
  733. if (!"1".equals(persType)) {
  734. param.setPersId(userid);
  735. }
  736. if (pid.length() == 3) {
  737. //查询年度
  738. List<BisInspPlanDto> list = groupPersDao.getYearList(param);
  739. return list;
  740. }
  741. if (pid.length() == 7) {
  742. param.setYear(Long.valueOf(pid.substring(3)));
  743. List<BisInspPlanDto> list = groupPersDao.getBatchList(param);
  744. return list;
  745. }
  746. if (pid.length() >= 8) {
  747. TacInspYearBatchGroupParam groupParam = new TacInspYearBatchGroupParam();
  748. if (!"1".equals(persType)) {
  749. groupParam.setPersId(userid);
  750. }
  751. String year = pid.substring(3,7);
  752. String batch = pid.substring(7);
  753. groupParam.setYear(Long.valueOf(year));
  754. groupParam.setBatch(Long.valueOf(batch));
  755. groupParam.setProvince(province);
  756. List<BisInspPlanDto> list = new ArrayList<>();
  757. List<TacInspYearBatchGroup> groupList = groupDao.getGroupListApp(groupParam);
  758. if (groupList.size() > 0) {
  759. groupList.forEach(group -> {
  760. TacInspYearBatchAreaParam areaParam = new TacInspYearBatchAreaParam();
  761. areaParam.setGroupId(group.getId());
  762. areaParam.setProvince(province);
  763. List<TacInspYearBatchArea> areaList = tacInspYearBatchAreaDao.findList(areaParam);
  764. BisInspPlanDto dto = new BisInspPlanDto();
  765. dto.setPlnaId(group.getId());
  766. dto.setPrsnTitle(group.getGroupNm().toString());
  767. dto.setPtype("8");
  768. if (areaList.size() > 0) {
  769. StringBuffer area = new StringBuffer("");
  770. areaList.forEach(tacInspYearBatchArea -> {
  771. area.append(tacInspYearBatchArea.getAdName()).append(",");
  772. });
  773. if (area.indexOf(",") > 0){
  774. dto.setPrsnTitle(area.substring(0,area.length() - 1));
  775. }
  776. }
  777. list.add(dto);
  778. });
  779. }
  780. return list;
  781. }
  782. }
  783. List<BisInspPlanDto> bisInspPlanDtoList = this.bisInspBaseDao.getAllNodeByPersid(userid, pid,province);//001,001041
  784. if (bisInspPlanDtoList.size() > 0) {
  785. for (BisInspPlanDto bis : bisInspPlanDtoList) {
  786. if (pid.length() == 3) {//如果查机构
  787. if (bis.getPlnaId().length() == 3) {//取到类型时 查询下级
  788. List<BisInspPlanDto> list = this.bisInspBaseDao.getDept(bis.getPlnaId(), pid, 6,province);
  789. resultList.addAll(list);
  790. } else if (bis.getPlnaId().length() == 6) {//取到机构时候,直接放到结果集
  791. if (pid.substring(0, 3).equals(bis.getPlnaId().substring(0, 3))) {
  792. resultList.add(bis);
  793. }
  794. } else if (bis.getPlnaId().length() == 9) {//取到批次或者组时候,向上查询
  795. List<BisInspPlanDto> list = this.bisInspBaseDao.getDeptByGroup(userid, pid,province);
  796. resultList.addAll(list);
  797. } else if (bis.getPlnaId().length() == 12) {//取到批次或者组时候,向上查询
  798. List<BisInspPlanDto> list = this.bisInspBaseDao.getDeptByGroup(userid, pid,province);
  799. resultList.addAll(list);
  800. }
  801. }
  802. if (pid.length() == 6) {//如果查批次001041,001
  803. if (bis.getPlnaId().length() == 3) {//取到类型时 查询所有批次
  804. List<BisInspPlanDto> list = this.bisInspBaseDao.getDept(bis.getPlnaId(), pid, 9,province);
  805. resultList.addAll(list);
  806. } else if (bis.getPlnaId().length() == 6) {//取到机构时候,查询下级008041
  807. List<BisInspPlanDto> list = this.bisInspBaseDao.getDept(bis.getPlnaId(), pid, 9,province);
  808. resultList.addAll(list);
  809. } else if (bis.getPlnaId().length() == 9) {//取到批次的时候,直接放入结果集
  810. if (pid.substring(0, 6).equals(bis.getPlnaId().substring(0, 6))) {
  811. resultList.add(bis);
  812. }
  813. } else if (bis.getPlnaId().length() == 12) {//取到组时候,向上查询
  814. List<BisInspPlanDto> list = this.bisInspBaseDao.getBatchByGroup(userid, pid,province);
  815. resultList.addAll(list);
  816. }
  817. }
  818. if (pid.length() == 9) {//如果查组
  819. if (bis.getPlnaId().length() == 3) {//取到类型时 查询所有组
  820. List<BisInspPlanDto> list = this.bisInspBaseDao.getDept(bis.getPlnaId(), pid, 12,province);
  821. resultList.addAll(list);
  822. } else if (bis.getPlnaId().length() == 6) {//取到机构时候,查询下级
  823. List<BisInspPlanDto> list = this.bisInspBaseDao.getDept(bis.getPlnaId(), pid, 12,province);
  824. resultList.addAll(list);
  825. } else if (bis.getPlnaId().length() == 9) {//取到批次的时候,查询下级
  826. List<BisInspPlanDto> list = this.bisInspBaseDao.getDept(bis.getPlnaId(), pid, 12,province);
  827. resultList.addAll(list);
  828. } else if (bis.getPlnaId().length() == 12) {//取到组时候,放入结果集
  829. if (pid.substring(0, 9).equals(bis.getPlnaId().substring(0, 9))) {
  830. resultList.add(bis);
  831. }
  832. }
  833. }
  834. }
  835. //去重
  836. for (BisInspPlanDto b : resultList) {
  837. map.put(b.getPlnaId(), b);
  838. }
  839. for (Map.Entry<String, Object> entry : map.entrySet()) {
  840. clearRepeatList.add((BisInspPlanDto) entry.getValue());
  841. }
  842. if (clearRepeatList.size() > 0 && pid.length() == 9) {//组按id排序
  843. Collections.sort(clearRepeatList, new Comparator<BisInspPlanDto>() {
  844. @Override
  845. public int compare(BisInspPlanDto o1, BisInspPlanDto o2) {
  846. return o2.getPlnaId().compareTo(o1.getPlnaId());
  847. }
  848. });
  849. }
  850. if (clearRepeatList.size() > 0 && pid.length() == 6) {//查月份升序
  851. Collections.sort(clearRepeatList, new Comparator<BisInspPlanDto>() {
  852. @Override
  853. public int compare(BisInspPlanDto o1, BisInspPlanDto o2) {
  854. return o1.getPlnaId().compareTo(o2.getPlnaId());
  855. }
  856. });
  857. }
  858. if (pid.length() == 3 && clearRepeatList.size() > 0) {//机构排序
  859. Collections.sort(clearRepeatList, new Comparator<BisInspPlanDto>() {
  860. @Override
  861. public int compare(BisInspPlanDto o1, BisInspPlanDto o2) {
  862. //督查办排在第一位
  863. if (o2.getPrsnTitle().indexOf("督查办") > -1) {
  864. return 1;
  865. }
  866. return o1.getPlnaId().compareTo(o2.getPlnaId());
  867. }
  868. });
  869. }
  870. }
  871. }
  872. return clearRepeatList;
  873. }
  874. @Override
  875. public void changeAdCode(String province) {
  876. List<AttGrwBase> attGrwBaseList = this.bisInspBaseDao.getAllGrw(province);
  877. if (attGrwBaseList.size() > 0) {
  878. int i = 0;
  879. for (AttGrwBase attGrwBase : attGrwBaseList) {
  880. if (attGrwBase != null) {
  881. i++;
  882. String geocode = AMapUtil.geocode(attGrwBase.getStlc());
  883. com.alibaba.fastjson.JSONObject jsStr = com.alibaba.fastjson.JSONObject.parseObject(geocode);
  884. List geocodes = (List) jsStr.get("geocodes");
  885. if (geocodes.size() > 0) {
  886. Object o = geocodes.get(0);
  887. JSONObject json = JSONObject.fromObject(o);
  888. String district = json.getString("formatted_address");
  889. String adcode = json.getString("adcode");
  890. if (district.length() > 2) {
  891. this.bisInspBaseDao.updateCodeAndName(district, adcode + "000000", attGrwBase.getStcd());
  892. } else {
  893. this.bisInspBaseDao.updateCode(adcode + "000000", attGrwBase.getStcd());
  894. System.out.println(i);
  895. }
  896. }
  897. }
  898. }
  899. }
  900. }
  901. @Override
  902. public PageInfo getPageEmpwtList(BisInspParam bisInspParam) {
  903. if (StringUtils.isNotBlank(bisInspParam.getAddvcd())) {
  904. Map<String, Object> map = AdLevelUtil.SubAd(bisInspParam.getAddvcd());
  905. bisInspParam.setAddvcd(map.get(SplitValue.SUBAD).toString());
  906. }
  907. PageHelper.startPage(bisInspParam.getPageNum(), bisInspParam.getPageSize());
  908. List<BisInspBaseDto> empwtprjList = bisInspBaseDao.getEmpwtprjList(bisInspParam);
  909. PageInfo page = new PageInfo(empwtprjList);
  910. return page;
  911. }
  912. @Override
  913. public PageInfo getPageGrwList(BisInspParam bisInspParam) {
  914. if (StringUtils.isNotBlank(bisInspParam.getAddvcd())) {
  915. Map<String, Object> map = AdLevelUtil.SubAd(bisInspParam.getAddvcd());
  916. bisInspParam.setAddvcd(map.get(SplitValue.SUBAD).toString());
  917. }
  918. PageHelper.startPage(bisInspParam.getPageNum(), bisInspParam.getPageSize());
  919. List<BisInspBaseDto> grwList = bisInspBaseDao.getGrwList(bisInspParam);
  920. PageInfo page = new PageInfo(grwList);
  921. return page;
  922. }
  923. @Override
  924. public PageInfo getPageWagaList(BisInspParam bisInspParam) {
  925. if (StringUtils.isNotBlank(bisInspParam.getAddvcd())) {
  926. Map<String, Object> map = AdLevelUtil.SubAd(bisInspParam.getAddvcd());
  927. bisInspParam.setAddvcd(map.get(SplitValue.SUBAD).toString());
  928. }
  929. PageHelper.startPage(bisInspParam.getPageNum(), bisInspParam.getPageSize());
  930. List<BisInspBaseDto> wagaList = bisInspBaseDao.getWagaList(bisInspParam);
  931. PageInfo page = new PageInfo(wagaList);
  932. return page;
  933. }
  934. @Override
  935. public List<BisInspGroupPersonDto> getGroupPersonByPersId(String persid, String persName,String province) {
  936. return this.bisInspBaseDao.getGroupPersonByPersId(persid, persName,province);
  937. }
  938. @Override
  939. public PageInfo getPageWainList(BisInspParam bisInspParam) {
  940. bisInspParam.setAddvcd(AdLevelUtil.getAddvcd(bisInspParam.getAddvcd()));
  941. PageHelper.startPage(bisInspParam.getPageNum(), bisInspParam.getPageSize());
  942. List<BisInspBaseDto> bisInspBaseDtos = getWainList(bisInspParam);
  943. PageInfo page = new PageInfo(bisInspBaseDtos);
  944. return page;
  945. }
  946. @Override
  947. public PageInfo getPageWintList(BisInspParam bisInspParam) {
  948. bisInspParam.setAddvcd(AdLevelUtil.getAddvcd(bisInspParam.getAddvcd()));
  949. PageHelper.startPage(bisInspParam.getPageNum(), bisInspParam.getPageSize());
  950. List<BisInspBaseDto> bisInspBaseDtos = getWintLicList(bisInspParam);
  951. PageInfo page = new PageInfo(bisInspBaseDtos);
  952. return page;
  953. }
  954. private List<BisInspBaseDto> getWintLicList(BisInspParam bisInspParam) {
  955. return bisInspBaseDao.getWintLicList(bisInspParam);
  956. }
  957. @Override
  958. public PageInfo getPageStbprpList(BisInspParam bisInspParam) {
  959. bisInspParam.setAddvcd(AdLevelUtil.getAddvcd(bisInspParam.getAddvcd()));
  960. PageHelper.startPage(bisInspParam.getPageNum(), bisInspParam.getPageSize());
  961. List<BisInspBaseDto> bisInspBaseDtos = getStbprpList(bisInspParam);
  962. PageInfo page = new PageInfo(bisInspBaseDtos);
  963. return page;
  964. }
  965. @Override
  966. public PageInfo getPageSwhsList(BisInspParam bisInspParam) {
  967. bisInspParam.setAddvcd(AdLevelUtil.getAddvcd(bisInspParam.getAddvcd()));
  968. PageHelper.startPage(bisInspParam.getPageNum(), bisInspParam.getPageSize());
  969. List<BisInspBaseDto> bisInspBaseDtos = getSwhsList(bisInspParam);
  970. PageInfo page = new PageInfo(bisInspBaseDtos);
  971. return page;
  972. }
  973. @Override
  974. public PageInfo<BisInspBaseDto> getPageSdList(BisInspParam bisInspParam) {
  975. bisInspParam.setAddvcd(AdLevelUtil.getAddvcd(bisInspParam.getAddvcd()));
  976. PageHelper.startPage(bisInspParam.getPageNum(), bisInspParam.getPageSize());
  977. List<BisInspBaseDto> list = getSdList(bisInspParam);
  978. PageInfo<BisInspBaseDto> pageInfo = new PageInfo(list);
  979. return pageInfo;
  980. }
  981. @Override
  982. public PageInfo<BisInspBaseDto> getPageWiuList(BisInspParam bisInspParam) {
  983. bisInspParam.setAddvcd(AdLevelUtil.getAddvcd(bisInspParam.getAddvcd()));
  984. PageHelper.startPage(bisInspParam.getPageNum(), bisInspParam.getPageSize());
  985. List<BisInspBaseDto> list = getWiuList(bisInspParam);
  986. PageInfo<BisInspBaseDto> pageInfo = new PageInfo(list);
  987. return pageInfo;
  988. }
  989. @Override
  990. public PageInfo getPageWuntList(BisInspParam bisInspParam) {
  991. bisInspParam.setAddvcd(AdLevelUtil.getAddvcd(bisInspParam.getAddvcd()));
  992. PageHelper.startPage(bisInspParam.getPageNum(), bisInspParam.getPageSize());
  993. List<BisInspBaseDto> bisInspBaseDtos = getWuntList(bisInspParam);
  994. PageInfo page = new PageInfo(bisInspBaseDtos);
  995. return page;
  996. }
  997. @Override
  998. public PageInfo getPageSvwtList(BisInspParam bisInspParam) {
  999. bisInspParam.setAddvcd(AdLevelUtil.getAddvcd(bisInspParam.getAddvcd()));
  1000. PageHelper.startPage(bisInspParam.getPageNum(), bisInspParam.getPageSize());
  1001. List<BisInspBaseDto> bisInspBaseDtos = getSvwtList(bisInspParam);
  1002. PageInfo page = new PageInfo(bisInspBaseDtos);
  1003. return page;
  1004. }
  1005. //农饮工程
  1006. public PageInfo<AttCwsBase> findAllCws(FindAllObjDto findAllObjDto) {
  1007. PageHelper.startPage(findAllObjDto.getPageNum(), findAllObjDto.getPageSize());
  1008. List<AttCwsBase> list = bisInspBaseDao.findAllCws(findAllObjDto);
  1009. PageInfo page = new PageInfo(list);
  1010. return page;
  1011. }
  1012. //农饮工程
  1013. public PageInfo<AttGrwBase> findAllGrw(FindAllObjDto findAllObjDto) {
  1014. PageHelper.startPage(findAllObjDto.getPageNum(), findAllObjDto.getPageSize());
  1015. List<AttGrwBase> list = bisInspBaseDao.findAllGrw(findAllObjDto);
  1016. PageInfo page = new PageInfo(list);
  1017. return page;
  1018. }
  1019. //172重点水利工程
  1020. public PageInfo<AttEmpwtprjBase> findAllEmpwtprj(FindAllObjDto findAllObjDto) {
  1021. PageHelper.startPage(findAllObjDto.getPageNum(), findAllObjDto.getPageSize());
  1022. List<AttEmpwtprjBase> list = bisInspBaseDao.findAllEmpwtprj(findAllObjDto);
  1023. PageInfo page = new PageInfo(list);
  1024. return page;
  1025. }
  1026. //水库
  1027. public PageInfo<AttRsBase> findAllRs(FindAllObjDto findAllObjDto) {
  1028. PageHelper.startPage(findAllObjDto.getPageNum(), findAllObjDto.getPageSize());
  1029. List<AttRsBase> list = bisInspBaseDao.findAllRs(findAllObjDto);
  1030. PageInfo page = new PageInfo(list);
  1031. return page;
  1032. }
  1033. //人员
  1034. public PageInfo<AttPersBase> findAllPers(FindAllObjDto findAllObjDto) {
  1035. PageHelper.startPage(findAllObjDto.getPageNum(), findAllObjDto.getPageSize());
  1036. List<AttPersBase> list = bisInspBaseDao.findAllPers(findAllObjDto);
  1037. PageInfo page = new PageInfo(list);
  1038. return page;
  1039. }
  1040. //水毁
  1041. public PageInfo<BisInspWtdst> findAllWtdst(FindAllObjDto findAllObjDto) {
  1042. PageHelper.startPage(findAllObjDto.getPageNum(), findAllObjDto.getPageSize());
  1043. List<BisInspWtdst> list = bisInspBaseDao.findAllWtdst(findAllObjDto);
  1044. PageInfo page = new PageInfo(list);
  1045. return page;
  1046. }
  1047. @Override
  1048. public PageInfo<BisInspBaseDto> getPageCityList(BisInspParam bisInspParam) {
  1049. bisInspParam.setAddvcd(AdLevelUtil.getAddvcd(bisInspParam.getAddvcd()));
  1050. PageHelper.startPage(bisInspParam.getPageNum(), bisInspParam.getPageSize());
  1051. List<BisInspBaseDto> list = getCityList(bisInspParam);
  1052. PageInfo<BisInspBaseDto> pageInfo = new PageInfo(list);
  1053. return pageInfo;
  1054. }
  1055. @Override
  1056. public int updateBaseInfoName(String fromName, String toName, String type) {
  1057. if (StringUtils.isBlank(fromName) || StringUtils.isBlank(toName)) {
  1058. return 0;
  1059. }
  1060. if (BisInspEnum.PAWP.getValue().equals(type)) {
  1061. TacAttPawpBaseParam baseParam = new TacAttPawpBaseParam();
  1062. baseParam.setName(fromName);
  1063. List<TacAttPawpBase> baseList = tacAttPawpBaseDao.findList(baseParam);
  1064. if (baseList.size() >= 0) {
  1065. baseList.forEach(tacAttPawpBase -> {
  1066. if (fromName.equalsIgnoreCase(tacAttPawpBase.getName())){
  1067. tacAttPawpBase.setName(toName);
  1068. tacAttPawpBaseDao.update(tacAttPawpBase);
  1069. }
  1070. });
  1071. }
  1072. TacInspYearBatchObjParam objParam = new TacInspYearBatchObjParam();
  1073. objParam.setOjbNm(fromName);
  1074. List<TacInspYearBatchObj> objList = tacInspYearBatchObjDao.findList(objParam);
  1075. if (objList.size() > 0) {
  1076. objList.forEach(tacInspYearBatchObj -> {
  1077. tacInspYearBatchObj.setOjbNm(toName);
  1078. tacInspYearBatchObjDao.update(tacInspYearBatchObj);
  1079. });
  1080. }
  1081. TacPawpRgstrParam rgstrParam = new TacPawpRgstrParam();
  1082. rgstrParam.setName(fromName);
  1083. List<TacPawpRgstr> rgstrList = tacPawpRgstrDao.findList(rgstrParam);
  1084. if (rgstrList.size() > 0) {
  1085. rgstrList.forEach(tacPawpRgstr -> {
  1086. if (fromName.equalsIgnoreCase(tacPawpRgstr.getName())){
  1087. tacPawpRgstr.setName(toName);
  1088. tacPawpRgstrDao.update(tacPawpRgstr);
  1089. }
  1090. });
  1091. }
  1092. }
  1093. return 0;
  1094. }
  1095. }
  1096. */