19fb2143c5027308a3709bc460961937b31b97c6.svn-base 23 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544
  1. package cn.com.goldenwater.dcproj.service.impl.waga;
  2. import cn.com.goldenwater.core.service.AbstractCrudService;
  3. import cn.com.goldenwater.dcproj.constValue.BisInspEnum;
  4. import cn.com.goldenwater.dcproj.constValue.SplitValue;
  5. import cn.com.goldenwater.dcproj.constValue.StateEnum;
  6. import cn.com.goldenwater.dcproj.constValue.WagaEnum;
  7. import cn.com.goldenwater.dcproj.dao.*;
  8. import cn.com.goldenwater.dcproj.model.*;
  9. import cn.com.goldenwater.dcproj.param.*;
  10. import cn.com.goldenwater.dcproj.service.AttWagaRgstrService;
  11. import cn.com.goldenwater.dcproj.service.BisInspObjStrategy;
  12. import cn.com.goldenwater.dcproj.service.BisInspWagaPblmService;
  13. import cn.com.goldenwater.dcproj.util.StringUtil;
  14. import cn.com.goldenwater.dcproj.utils.AdLevelUtil;
  15. import cn.com.goldenwater.dcproj.utils.Builder;
  16. import cn.com.goldenwater.dcproj.utils.expExcel.ExportUtil;
  17. import cn.com.goldenwater.id.util.UuidUtil;
  18. import com.github.pagehelper.PageHelper;
  19. import com.github.pagehelper.PageInfo;
  20. import org.apache.commons.lang3.StringUtils;
  21. import org.springframework.beans.factory.annotation.Autowired;
  22. import org.springframework.stereotype.Service;
  23. import org.springframework.transaction.annotation.Transactional;
  24. import javax.servlet.http.HttpServletResponse;
  25. import java.util.Date;
  26. import java.util.List;
  27. /**
  28. * @author lune
  29. * @date 2019-4-22
  30. */
  31. @Service
  32. @Transactional(rollbackFor = Exception.class)
  33. public class AttWagaRgstrServiceImpl extends AbstractCrudService<AttWagaRgstr, AttWagaRgstrParam> implements AttWagaRgstrService, BisInspObjStrategy {
  34. @Autowired
  35. private AttWagaRgstrDao attWagaRgstrDao;
  36. @Autowired
  37. private BisInspPblmDao bisInspPblmDao;
  38. @Autowired
  39. private BisInspAllObjDao bisInspAllObjDao;
  40. @Autowired
  41. private BisInspWagaMrsCiDao bisInspWagaMrsCiDao;
  42. @Autowired
  43. private BisInspWagaSafeManageDao bisInspWagaSafeManageDao;
  44. @Autowired
  45. private BisInspWagaDmamInfoDao bisInspWagaDmamInfoDao;
  46. @Autowired
  47. private BisInspWagaProenInfoDao bisInspWagaProenInfoDao;
  48. @Autowired
  49. private AttAdXBaseDao attAdXBaseDao;
  50. @Autowired
  51. private BisInspWagaPblmService bisInspWagaPblmService;
  52. public AttWagaRgstrServiceImpl(AttWagaRgstrDao attWagaRgstrDao) {
  53. super(attWagaRgstrDao);
  54. this.attWagaRgstrDao = attWagaRgstrDao;
  55. }
  56. @Override
  57. public AttWagaRgstr get(String key) {
  58. AttWagaRgstr rgstr = super.get(key);
  59. if (!"2".equals(rgstr.getRectStat())) {
  60. checkFinished(rgstr);
  61. }
  62. return rgstr;
  63. }
  64. /**
  65. * 更新整改问题状态
  66. * 判断问题是否全部整改
  67. *
  68. * @param rgstr
  69. */
  70. private void checkFinished(AttWagaRgstr rgstr) {
  71. String rectStat = "0";
  72. List<BisInspWagaPblm> pblmMendList = bisInspWagaPblmService.findList(Builder.of(BisInspWagaPblmParam::new).with(BisInspWagaPblmParam::setObjCode, rgstr.getObjCode()).build());
  73. if (pblmMendList == null || pblmMendList.size() == 0) {
  74. rectStat = "2";
  75. } else {
  76. long total = pblmMendList.size();
  77. long revw = pblmMendList.stream().filter(p -> "2".equals(p.getRevwState())).count();
  78. if (total == revw) {
  79. rectStat = "2";
  80. } else if (total > revw && revw != 0) {
  81. rectStat = "1";
  82. }
  83. }
  84. if (!rectStat.equals(rgstr.getRectStat())) {
  85. rgstr.setRectStat(rectStat);
  86. // bisInspRslkbkRgstrDao.update(rgstr);
  87. }
  88. }
  89. @Override
  90. public void insertObj(BisInspAllObj bisInspAllObj, String persId) {
  91. String state = StateEnum.NOWASTSTATE.getKey();
  92. AttWagaRgstr wagaRgstr = new AttWagaRgstr();
  93. AttWagaBase wagaBase = wagaBaseDao.get(bisInspAllObj.getCode());
  94. String rgstId = UuidUtil.uuid();
  95. wagaRgstr.setId(rgstId);
  96. wagaRgstr.setSafeStat(state);
  97. wagaRgstr.setProenStat(state);
  98. wagaRgstr.setMrsCiStat(state);
  99. wagaRgstr.setDmamStat(state);
  100. wagaRgstr.setLocationXiang(wagaBase.getLocationXiang());
  101. wagaRgstr.setAdCode(wagaBase.getAdCode());
  102. wagaRgstr.setState(state);
  103. wagaRgstr.setCenterX(wagaBase.getCenterX());
  104. wagaRgstr.setCenterY(wagaBase.getCenterY());
  105. wagaRgstr.setDataStat(state);
  106. wagaRgstr.setEngScal(wagaBase.getEngScal());
  107. wagaRgstr.setGateAdmName(wagaBase.getGateAdmName());
  108. wagaRgstr.setGateFlow(wagaBase.getGateFlow());
  109. wagaRgstr.setGateType(wagaBase.getGateType());
  110. wagaRgstr.setGateName(wagaBase.getGateName());
  111. wagaRgstr.setGdX(wagaBase.getGdX());
  112. wagaRgstr.setGdY(wagaBase.getGdY());
  113. wagaRgstr.setIntm(new Date());
  114. wagaRgstr.setPersId(persId);
  115. wagaRgstr.setEngSta(wagaBase.getEngSta());
  116. wagaRgstr.setLocation(wagaBase.getLocationCun());
  117. wagaRgstr.setBuidTimeMon(wagaBase.getBuidTimeMon());
  118. wagaRgstr.setBuidTimeYear(wagaBase.getBuidTimeYear());
  119. wagaRgstr.setStaTimeMon(wagaBase.getStaTimeMon());
  120. wagaRgstr.setStaTimeYear(wagaBase.getStaTimeYear());
  121. wagaRgstr.setObjCode(bisInspAllObj.getCode());
  122. wagaRgstr.setObjId(bisInspAllObj.getObjId());
  123. wagaRgstr.setGateAdmOrg(wagaBase.getLocRvName());
  124. wagaRgstr.setGroupId(bisInspAllObj.getId());
  125. attWagaRgstrDao.insert(wagaRgstr);
  126. // 添加子表
  127. BisInspWagaBase bisInspWagaBase = new BisInspWagaBase();
  128. bisInspWagaBase.setId(UuidUtil.uuid());
  129. bisInspWagaBase.setRgstrId(rgstId);
  130. bisInspWagaBase.setRecPersId(persId);
  131. bisInspWagaBase.setAdCode(wagaBase.getAdCode());
  132. if (StringUtils.isNotBlank(wagaBase.getAdCode())) {
  133. AttAdXBase attAdXBase = attAdXBaseDao.get(wagaBase.getAdCode());
  134. if (attAdXBase != null) {
  135. bisInspWagaBase.setAdName(attAdXBase.getAdName());
  136. bisInspWagaBase.setAdFullName(attAdXBase.getAdFullName());
  137. }
  138. }
  139. bisInspWagaBase.setGateAdmName(wagaBase.getGateAdmName());
  140. bisInspWagaBase.setGateFlow(wagaBase.getGateFlow());
  141. bisInspWagaBase.setEngScal(wagaBase.getEngScal());
  142. bisInspWagaBase.setGateAdmOrg(wagaBase.getGateAdmOrg());
  143. bisInspWagaBaseDao.insert(bisInspWagaBase);
  144. }
  145. @Autowired
  146. private BisInspWagaBaseDao bisInspWagaBaseDao;
  147. @Override
  148. public String getOeseState(String rgstrId) {
  149. BisInspWagaBaseParam bisInspWagaBaseParam = new BisInspWagaBaseParam();
  150. bisInspWagaBaseParam.setRgstrId(rgstrId);
  151. List<BisInspWagaBase> baseList = bisInspWagaBaseDao.findList(bisInspWagaBaseParam);
  152. if (baseList != null && baseList.size() > 0) {
  153. return getOeseState(baseList.get(0));
  154. }
  155. BisInspWagaBase base = new BisInspWagaBase();
  156. base.setRgstrId(rgstrId);
  157. return getOeseState(base);
  158. }
  159. @Override
  160. public int updateBaseData() {
  161. BisInspWagaBaseParam bisInspWagaBaseParam = new BisInspWagaBaseParam();
  162. List<BisInspWagaBase> baseList = bisInspWagaBaseDao.findList(bisInspWagaBaseParam);
  163. for (BisInspWagaBase base : baseList) {
  164. String oeseState = getOeseState(base);
  165. bisInspWagaBaseDao.updateOeseInfo(oeseState, base.getRgstrId());
  166. }
  167. return 0;
  168. }
  169. @Override
  170. public String getOeseState(BisInspWagaBase base) {
  171. String flag = StateEnum.COMASTSTATE.getKey();
  172. if (StateEnum.EXWASTSTATE.getKey().equals(base.getExtDamSafeAppr()) && "4".equals(base.getPrftaofcIsH())) {
  173. if ("3".equals(base.getExtDamSafeApprInfo()) || "4".equals(base.getExtDamSafeApprInfo())) {
  174. return StateEnum.NOWASTSTATE.getKey();
  175. } else if ("2".equals(base.getExtDamSafeApprInfo())) {
  176. flag = StateEnum.EXWASTSTATE.getKey();
  177. }
  178. }
  179. WagaParam pblmParam = new WagaParam();
  180. pblmParam.setRgstrId(base.getRgstrId());
  181. pblmParam.setpType(BisInspEnum.WAGA.getValue());
  182. pblmParam.setPersId(base.getRecPersId());
  183. List<BisInspPblm> pblmList = bisInspPblmDao.findWagaPlbmList(pblmParam);
  184. //处理问题列表
  185. return getOeseStateByPblmList(pblmList, flag);
  186. }
  187. private String getOeseStateByPblmList(List<BisInspPblm> pblmList, String flag) {
  188. if (!pblmList.isEmpty()) {
  189. long heaPblmLevelOne = pblmList.stream().filter(pblm -> StringUtils.isNotBlank(pblm.getCheckPointBz()))
  190. .filter(pblm -> pblm.getCheckPointBz().contains("△"))
  191. .filter(pblm -> (!"工程实体".equals(pblm.getPblmNameBz()) && "3".equals(pblm.getInspPblmCate())) || ("工程实体".equals(pblm.getPblmNameBz()) && "2".equals(pblm.getInspPblmCate())))
  192. .count();
  193. if (heaPblmLevelOne >= 1) {
  194. return StateEnum.NOWASTSTATE.getKey();
  195. }
  196. long heaPblmLevelTwo = pblmList.stream().filter(pblm -> StringUtils.isNotBlank(pblm.getCheckPointBz()))
  197. .filter(pblm -> !pblm.getCheckPointBz().contains("△"))
  198. .filter(pblm -> (!"工程实体".equals(pblm.getPblmNameBz()) && "3".equals(pblm.getInspPblmCate())) || ("工程实体".equals(pblm.getPblmNameBz()) && "2".equals(pblm.getInspPblmCate())))
  199. .count();
  200. if (heaPblmLevelTwo >= 3) {
  201. return StateEnum.NOWASTSTATE.getKey();
  202. }
  203. long heaPblmLevelThree = pblmList.stream().filter(pblm -> StringUtils.isNotBlank(pblm.getCheckPointBz()))
  204. .filter(pblm -> !pblm.getCheckPointBz().contains("△"))
  205. .filter(pblm -> (!"工程实体".equals(pblm.getPblmNameBz()) && "2".equals(pblm.getInspPblmCate())) || ("工程实体".equals(pblm.getPblmNameBz()) && "1".equals(pblm.getInspPblmCate())))
  206. .count();
  207. if (heaPblmLevelTwo < 3 && heaPblmLevelThree >= 5) {
  208. return StateEnum.NOWASTSTATE.getKey();
  209. }
  210. long comPblmLevelOne = pblmList.stream().filter(pblm -> (!"工程实体".equals(pblm.getPblmNameBz()) && "2".equals(pblm.getInspPblmCate())) || ("工程实体".equals(pblm.getPblmNameBz()) && "1".equals(pblm.getInspPblmCate()))).count();
  211. if (comPblmLevelOne > 0 && comPblmLevelOne < 5) {
  212. if (StateEnum.EXWASTSTATE.getKey().compareTo(flag) < 0) {
  213. return StateEnum.EXWASTSTATE.getKey();
  214. }
  215. }
  216. long comPblmLevelTwo = pblmList.stream().filter(pblm -> !"工程实体".equals(pblm.getPblmNameBz())).filter(pblm -> "1".equals(pblm.getInspPblmCate())).count();
  217. long comPblmLevelTwo1 = pblmList.stream().filter(pblm -> "工程实体".equals(pblm.getPblmNameBz())).filter(pblm -> "1".equals(pblm.getInspPblmCate())).count();
  218. if (comPblmLevelTwo >= 3 || comPblmLevelTwo1 >= 1) {
  219. if (StateEnum.EXWASTSTATE.getKey().compareTo(flag) < 0) {
  220. return StateEnum.EXWASTSTATE.getKey();
  221. }
  222. }
  223. long comPblmLevelThree = pblmList.stream().filter(pblm -> !"工程实体".equals(pblm.getPblmNameBz())).filter(pblm -> "0".equals(pblm.getInspPblmCate())).count();
  224. long comPblmLevelThree1 = pblmList.stream().filter(pblm -> "工程实体".equals(pblm.getPblmNameBz())).filter(pblm -> "0".equals(pblm.getInspPblmCate())).count();
  225. if (comPblmLevelThree >= 8 || comPblmLevelThree1 >= 5) {
  226. if (StateEnum.EXWASTSTATE.getKey().compareTo(flag) < 0) {
  227. return StateEnum.EXWASTSTATE.getKey();
  228. }
  229. }
  230. }
  231. return flag;
  232. }
  233. @Override
  234. public void cleanObjData(String objId) {
  235. AttWagaRgstrParam attWagaRgstrParam = new AttWagaRgstrParam();
  236. attWagaRgstrParam.setObjId(objId);
  237. List<AttWagaRgstr> list = this.attWagaRgstrDao.findList(attWagaRgstrParam);
  238. if (list.size() > 0) {
  239. String id = list.get(0).getId();
  240. BisInspPblmParam bisInspPblmParam = new BisInspPblmParam();
  241. bisInspPblmParam.setRegid(id);
  242. bisInspPblmParam.setObjType(BisInspEnum.WAGA.getValue());
  243. this.bisInspPblmDao.deleteBy(bisInspPblmParam);//删除问题
  244. //删除水闸督查基本情况
  245. BisInspWagaBaseParam bisInspWagaBaseParam = new BisInspWagaBaseParam();
  246. bisInspWagaBaseParam.setRgstrId(id);
  247. bisInspWagaBaseDao.deleteBy(bisInspWagaBaseParam);
  248. BisInspWagaMrsCiParam bisInspWagaMrsCi = new BisInspWagaMrsCiParam();
  249. bisInspWagaMrsCi.setRgstrId(id);
  250. //删除水闸督查管理责任体系建设和落实情况
  251. this.bisInspWagaMrsCiDao.deleteBy(bisInspWagaMrsCi);
  252. BisInspWagaSafeManageParam bisInspWagaSafeManage = new BisInspWagaSafeManageParam();
  253. bisInspWagaSafeManage.setRgstrId(id);
  254. //删除水闸督查安全管理情况
  255. this.bisInspWagaSafeManageDao.deleteBy(bisInspWagaSafeManage);
  256. BisInspWagaDmamInfoParam bisInspWagaDmamInfoParam = new BisInspWagaDmamInfoParam();
  257. bisInspWagaDmamInfoParam.setRgstrId(id);
  258. //删除水闸督查日常管理和维修养护情况
  259. this.bisInspWagaDmamInfoDao.deleteBy(bisInspWagaDmamInfoParam);
  260. BisInspWagaProenInfoParam bisInspWagaProenInfoParam = new BisInspWagaProenInfoParam();
  261. bisInspWagaProenInfoParam.setRgstrId(id);
  262. //删除水闸督查工程实体情况
  263. this.bisInspWagaProenInfoDao.deleteBy(bisInspWagaProenInfoParam);
  264. AttWagaRgstr attWagaRgstr = this.attWagaRgstrDao.get(id);
  265. //删除登记表
  266. this.attWagaRgstrDao.delete(id);
  267. if (attWagaRgstr != null) {
  268. //删除督查对象
  269. BisInspAllObjParam bisInspAllObjParam = new BisInspAllObjParam();
  270. bisInspAllObjParam.setObjId(objId);
  271. this.bisInspAllObjDao.deleteBy(bisInspAllObjParam);
  272. }
  273. }
  274. }
  275. @Override
  276. public PageInfo findObjPageByType(TypeParam typeParam, HttpServletResponse response) {
  277. return this.findPageWagaPage(typeParam);
  278. }
  279. @Override
  280. public Object findObjListByType(TypeParam typeParam) {
  281. return this.findWagaPage(typeParam);
  282. }
  283. @Override
  284. public String getType() {
  285. return BisInspEnum.WAGA.getValue();
  286. }
  287. @Override
  288. public void addState(String rgStrId, String dataStat, String input) {
  289. if (StringUtils.isBlank(rgStrId)) {
  290. return;
  291. }
  292. AttWagaRgstr attWagaRgstr = attWagaRgstrDao.get(rgStrId);
  293. attWagaRgstr.setId(rgStrId);
  294. String stat = "2";
  295. if (StringUtils.isNotBlank(dataStat)) {
  296. if (WagaEnum.MRS.getValue().equals(input)) {
  297. attWagaRgstr.setMrsCiStat(dataStat);
  298. }
  299. if (WagaEnum.DAM.getValue().equals(input)) {
  300. attWagaRgstr.setDmamStat(dataStat);
  301. }
  302. if (WagaEnum.PRO.getValue().equals(input)) {
  303. attWagaRgstr.setProenStat(dataStat);
  304. }
  305. if (WagaEnum.SAFE.getValue().equals(input)) {
  306. attWagaRgstr.setSafeStat(dataStat);
  307. }
  308. if (WagaEnum.BASE.getValue().equals(input)) {
  309. attWagaRgstr.setBaseStat(dataStat);
  310. }
  311. } else {
  312. if (WagaEnum.MRS.getValue().equals(input)) {
  313. attWagaRgstr.setMrsCiStat(stat);
  314. }
  315. if (WagaEnum.DAM.getValue().equals(input)) {
  316. attWagaRgstr.setDmamStat(stat);
  317. }
  318. if (WagaEnum.PRO.getValue().equals(input)) {
  319. attWagaRgstr.setProenStat(stat);
  320. }
  321. if (WagaEnum.SAFE.getValue().equals(input)) {
  322. attWagaRgstr.setSafeStat(stat);
  323. }
  324. if (WagaEnum.BASE.getValue().equals(input)) {
  325. attWagaRgstr.setBaseStat(stat);
  326. }
  327. }
  328. if (StringUtils.isBlank(attWagaRgstr.getState()) || "0".equals(attWagaRgstr.getState())) {
  329. attWagaRgstr.setState("1");
  330. } else {
  331. attWagaRgstr.setState(attWagaRgstr.getState());
  332. }
  333. attWagaRgstrDao.update(attWagaRgstr);
  334. }
  335. @Override
  336. public List<BisInspWagaRgstrDto> findWagaPage(TypeParam typeParam) {
  337. return attWagaRgstrDao.findWagaPage(typeParam);
  338. }
  339. @Override
  340. public PageInfo<BisInspWagaRgstrDto> findPageWagaPage(TypeParam typeParam) {
  341. if (StringUtils.isNotBlank(typeParam.getAdCode())) {
  342. typeParam.setAdCode(String.valueOf(AdLevelUtil.SubAd(typeParam.getAdCode()).get(SplitValue.SUBAD)));
  343. }
  344. PageHelper.startPage(typeParam);
  345. List<BisInspWagaRgstrDto> list = attWagaRgstrDao.findWagaPage(typeParam);
  346. PageInfo<BisInspWagaRgstrDto> pageInfo = new PageInfo(list);
  347. return pageInfo;
  348. }
  349. @Autowired
  350. private AttWagaBaseDao wagaBaseDao;
  351. @Override
  352. public AttWagaRgstr getByRsvrRgstr(AttWagaRgstrParam wagaRgstrParam) {
  353. String state = "0";
  354. String groupId = wagaRgstrParam.getGroupId();
  355. String persId = wagaRgstrParam.getPersId();
  356. wagaRgstrParam.setPersId("");
  357. AttWagaRgstr wagaRgstr = attWagaRgstrDao.getBy(wagaRgstrParam);
  358. if (wagaRgstr != null) {
  359. if (wagaRgstr.getIntm() == null) {
  360. wagaRgstr.setIntm(new Date());
  361. attWagaRgstrDao.update(wagaRgstr);
  362. }
  363. if (!"2".equals(wagaRgstr.getRectStat())) {
  364. checkFinished(wagaRgstr);
  365. }
  366. return wagaRgstr;
  367. }
  368. wagaRgstr = new AttWagaRgstr();
  369. AttWagaBase wagaBase = wagaBaseDao.get(wagaRgstrParam.getObjCode());
  370. if (wagaBase == null) {
  371. return wagaRgstr;
  372. }
  373. String id = UuidUtil.uuid();
  374. wagaRgstr.setId(id);
  375. wagaRgstr.setSafeStat(state);
  376. wagaRgstr.setProenStat(state);
  377. wagaRgstr.setMrsCiStat(state);
  378. wagaRgstr.setDmamStat(state);
  379. wagaRgstr.setAdCode(wagaBase.getAdCode());
  380. wagaRgstr.setState(state);
  381. wagaRgstr.setCenterX(wagaBase.getCenterX());
  382. wagaRgstr.setCenterY(wagaBase.getCenterY());
  383. wagaRgstr.setDataStat(state);
  384. wagaRgstr.setEngScal(wagaBase.getEngScal());
  385. wagaRgstr.setGateAdmName(wagaBase.getGateAdmName());
  386. wagaRgstr.setGateFlow(wagaBase.getGateFlow());
  387. wagaRgstr.setGateType(wagaBase.getGateType());
  388. wagaRgstr.setGateName(wagaBase.getGateName());
  389. wagaRgstr.setGdX(wagaBase.getGdX());
  390. wagaRgstr.setGdY(wagaBase.getGdY());
  391. wagaRgstr.setIntm(new Date());
  392. wagaRgstr.setPersId(persId);
  393. wagaRgstr.setEngSta(wagaBase.getEngSta());
  394. wagaRgstr.setLocationXiang(wagaBase.getLocationXiang());
  395. wagaRgstr.setLocation(wagaBase.getLocationCun());
  396. wagaRgstr.setBuidTimeMon(wagaBase.getBuidTimeMon());
  397. wagaRgstr.setBuidTimeYear(wagaBase.getBuidTimeYear());
  398. wagaRgstr.setStaTimeMon(wagaBase.getStaTimeMon());
  399. wagaRgstr.setStaTimeYear(wagaBase.getStaTimeYear());
  400. wagaRgstr.setObjCode(wagaRgstrParam.getObjCode());
  401. wagaRgstr.setObjId(wagaRgstrParam.getObjId());
  402. wagaRgstr.setGateAdmOrg(wagaBase.getLocRvName());
  403. wagaRgstr.setGroupId(groupId);
  404. this.insert(wagaRgstr);
  405. checkFinished(wagaRgstr);
  406. BisInspWagaBase bisInspWagaBase = new BisInspWagaBase();
  407. bisInspWagaBase.setId(UuidUtil.uuid());
  408. bisInspWagaBase.setRgstrId(id);
  409. bisInspWagaBase.setRecPersId(persId);
  410. bisInspWagaBase.setAdCode(wagaBase.getAdCode());
  411. if (StringUtils.isNotBlank(wagaBase.getAdCode())) {
  412. AttAdXBase attAdXBase = attAdXBaseDao.get(wagaBase.getAdCode());
  413. bisInspWagaBase.setAdName(attAdXBase.getAdName());
  414. bisInspWagaBase.setAdFullName(attAdXBase.getAdFullName());
  415. }
  416. bisInspWagaBase.setGateAdmName(wagaBase.getGateAdmName());
  417. bisInspWagaBase.setGateFlow(wagaBase.getGateFlow());
  418. bisInspWagaBase.setEngScal(wagaBase.getEngScal());
  419. bisInspWagaBase.setGateAdmOrg(wagaBase.getGateAdmOrg());
  420. bisInspWagaBaseDao.insert(bisInspWagaBase);
  421. return wagaRgstr;
  422. }
  423. @Override
  424. public PageInfo<BisInspWagaRgstrDto> findPcPage(TypeParam typeParam, HttpServletResponse response) {
  425. PageHelper.startPage(typeParam);
  426. if (null != typeParam.getAdCodes()) {
  427. typeParam.setAdCodes(AdLevelUtil.getListAddvcd(typeParam.getAdCodes()));
  428. }
  429. if (typeParam.getSortList() != null && typeParam.getSortList().size() > 0) {
  430. String sortSql = "";
  431. for (SortListParam sortList : typeParam.getSortList()
  432. ) {
  433. if (StringUtils.isNotBlank(sortList.getIsDescOrAsce())) {
  434. String column = sortList.getColumn();
  435. column = StringUtil.camelToUnderline(column);
  436. if ("ascending".equals(sortList.getIsDescOrAsce())) {
  437. sortSql += " " + column + " ASC";
  438. } else if ("descending".equals(sortList.getIsDescOrAsce())) {
  439. sortSql += " " + column + " DESC";
  440. }
  441. }
  442. }
  443. if (StringUtils.isNotBlank(sortSql)) {
  444. sortSql = "ORDER BY " + sortSql;
  445. typeParam.setSortSql(sortSql);
  446. }
  447. }
  448. List<BisInspWagaRgstrDto> list = changeList(attWagaRgstrDao.findPcWagaPage(typeParam));
  449. PageInfo<BisInspWagaRgstrDto> pageInfo = new PageInfo(list);
  450. return pageInfo;
  451. }
  452. @Override
  453. public List<BisInspWagaRgstrDto> findPcList(TypeParam typeParam, HttpServletResponse response) {
  454. List<BisInspWagaRgstrDto> list = attWagaRgstrDao.findPcWagaPage(typeParam);
  455. ExportUtil.exportExcel(typeParam.getIsExport(), list, response);
  456. return changeList(list);
  457. }
  458. @Override
  459. public List<BisInspWagaRgstrDto> getListByInspGroupIdObjType(PagePersObjParam pagePersObjParam) {
  460. return wagaBaseDao.getListByInspGroupIdObjType(pagePersObjParam);
  461. }
  462. private List<BisInspWagaRgstrDto> changeList(List<BisInspWagaRgstrDto> list) {
  463. if (list.size() > 0) {
  464. for (BisInspWagaRgstrDto b : list) {
  465. if (b.getAdFullName() != null) {
  466. if (b.getAdFullName().contains(SplitValue.HENG_SPLIT)) {
  467. String[] split = b.getAdFullName().split(SplitValue.HENG_SPLIT);
  468. if (split.length >= 3) {
  469. b.setProvince(split[0]);
  470. b.setCity(split[1]);
  471. b.setCounty(split[2]);
  472. }
  473. if (split.length == 2) {
  474. b.setProvince(split[0]);
  475. b.setCity(split[1]);
  476. b.setCounty("");
  477. }
  478. } else {
  479. b.setProvince(b.getAdFullName());
  480. }
  481. }
  482. }
  483. }
  484. return list;
  485. }
  486. @Override
  487. public int insert(AttWagaRgstr b) {
  488. int ret = 1;
  489. AttWagaRgstrParam wagaRgstrParam = new AttWagaRgstrParam();
  490. wagaRgstrParam.setObjId(b.getObjId());
  491. List<AttWagaRgstr> list = attWagaRgstrDao.findList(wagaRgstrParam);
  492. if (list == null || list.size() == 0) {
  493. ret = attWagaRgstrDao.insert(b);
  494. }
  495. return ret;
  496. }
  497. }