1ceef8a02ba67171db00b719e0b4925c3bd2eb19.svn-base 7.9 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198
  1. package cn.com.goldenwater.dcproj.service.impl.stnd;
  2. import cn.com.goldenwater.dcproj.constValue.BisInspEnum;
  3. import cn.com.goldenwater.dcproj.constValue.SplitValue;
  4. import cn.com.goldenwater.dcproj.constValue.StateEnum;
  5. import cn.com.goldenwater.dcproj.dao.*;
  6. import cn.com.goldenwater.dcproj.dto.BisInspRgstrDto;
  7. import cn.com.goldenwater.dcproj.model.AttRsBase;
  8. import cn.com.goldenwater.dcproj.model.BisInspAllObj;
  9. import cn.com.goldenwater.dcproj.model.BisInspStndRgstr;
  10. import cn.com.goldenwater.dcproj.param.*;
  11. import cn.com.goldenwater.dcproj.service.BisInspObjStrategy;
  12. import cn.com.goldenwater.dcproj.service.BisInspStndRgstrService;
  13. import cn.com.goldenwater.core.service.AbstractCrudService;
  14. import cn.com.goldenwater.dcproj.utils.AdLevelUtil;
  15. import com.github.pagehelper.PageHelper;
  16. import com.github.pagehelper.PageInfo;
  17. import org.apache.commons.lang3.StringUtils;
  18. import org.springframework.beans.factory.annotation.Autowired;
  19. import org.springframework.stereotype.Service;
  20. import org.springframework.transaction.annotation.Transactional;
  21. import cn.com.goldenwater.id.util.UuidUtil;
  22. import javax.servlet.http.HttpServletResponse;
  23. import java.util.List;
  24. import java.util.Date;
  25. /**
  26. * @author lhc
  27. * @date 2020-3-25
  28. */
  29. @Service
  30. @Transactional
  31. public class BisInspStndRgstrServiceImpl extends AbstractCrudService<BisInspStndRgstr, BisInspStndRgstrParam> implements BisInspStndRgstrService, BisInspObjStrategy {
  32. @Autowired
  33. private BisInspStndRgstrDao bisInspStndRgstrDao;
  34. @Autowired
  35. private AttRsBaseDao attRsBaseDao;
  36. @Autowired
  37. private BisInspAllObjDao bisInspAllObjDao;
  38. @Autowired
  39. private BisInspPblmDao bisInspPblmDao;
  40. @Autowired
  41. private BisInspStndDtyminDao bisInspStndDtyminDao;
  42. @Autowired
  43. private BisInspStndMgamtDao bisInspStndMgamtDao;
  44. @Autowired
  45. private BisInspStndPlrdDao bisInspStndPlrdDao;
  46. public BisInspStndRgstrServiceImpl(BisInspStndRgstrDao bisInspStndRgstrDao) {
  47. super(bisInspStndRgstrDao);
  48. this.bisInspStndRgstrDao = bisInspStndRgstrDao;
  49. }
  50. @Override
  51. public int insert(BisInspStndRgstr bisInspStndRgstr) {
  52. String uuid = UuidUtil.uuid(); // 生成uuid
  53. bisInspStndRgstr.setId(uuid);
  54. bisInspStndRgstr.setIntm(new Date());
  55. bisInspStndRgstr.setUptm(new Date());
  56. bisInspStndRgstr.setDataStat("0");
  57. return this.bisInspStndRgstrDao.insert(bisInspStndRgstr);
  58. }
  59. @Override
  60. public int update(BisInspStndRgstr bisInspStndRgstr) {
  61. bisInspStndRgstr.setUptm(new Date());
  62. return this.bisInspStndRgstrDao.update(bisInspStndRgstr);
  63. }
  64. @Override
  65. public int delete(String id) {
  66. return this.bisInspStndRgstrDao.delete(id);
  67. }
  68. @Override
  69. public PageInfo<BisInspRgstrDto> findStndRgstrPage(TypeParam typeParam, HttpServletResponse response) {
  70. PageHelper.startPage(typeParam);
  71. return new PageInfo<BisInspRgstrDto>(setSsx(typeParam));
  72. }
  73. private List<BisInspRgstrDto> setSsx(TypeParam typeParam) {
  74. if (StringUtils.isNotBlank(typeParam.getAdCode())) {
  75. typeParam.setAdCode(String.valueOf(AdLevelUtil.SubAd(typeParam.getAdCode()).get(SplitValue.SUBAD)));
  76. }
  77. List<BisInspRgstrDto> list = bisInspStndRgstrDao.findStndRgstrPage(typeParam);
  78. if (list.size() > 0) {
  79. for (BisInspRgstrDto b : list) {
  80. if (b.getLocation() != null) {
  81. if (b.getLocation().contains(SplitValue.HENG_SPLIT)) {
  82. String[] split = b.getLocation().split(SplitValue.HENG_SPLIT);
  83. if (split.length == 3) {
  84. b.setProvince(split[0]);
  85. b.setCity(split[1]);
  86. b.setCountry(split[2]);
  87. }
  88. if (split.length == 2) {
  89. b.setProvince(split[0]);
  90. b.setCity(split[1]);
  91. b.setCountry("");
  92. }
  93. } else {
  94. b.setProvince(b.getLocation());
  95. }
  96. }
  97. }
  98. }
  99. return list;
  100. }
  101. @Override
  102. public void insertObj(BisInspAllObj bisInspAllObj, String persId) {
  103. String rsraqgRgstrId = UuidUtil.uuid();
  104. //获取小水库信息
  105. AttRsBaseParam baseParam = new AttRsBaseParam();
  106. baseParam.setRsCode(bisInspAllObj.getCode());
  107. AttRsBase attRsBase = attRsBaseDao.getBy(baseParam);
  108. BisInspStndRgstr b = new BisInspStndRgstr();
  109. b.setRgstrId(rsraqgRgstrId);
  110. b.setOrgId(bisInspAllObj.getOrgId());
  111. b.setObjId(bisInspAllObj.getObjId());
  112. b.setRsCode(attRsBase.getRsCode());
  113. b.setRsvrNm(bisInspAllObj.getNm());
  114. b.setAdCode(attRsBase.getAdmDiv());
  115. b.setResCreateTime(attRsBase.getCompDate());
  116. b.setEngScal(attRsBase.getEngScal());
  117. b.setTotCap(attRsBase.getTotCap());
  118. b.setHystSite(attRsBase.getRsLoc());
  119. b.setDamRegCode(attRsBase.getRegCode());
  120. b.setDamType(attRsBase.getDamType());
  121. b.setHasDamRegCode(StringUtils.isNotBlank(attRsBase.getRegCode()) ? "1" : "2");
  122. b.setResCreateTimeNote(attRsBase.getCompDateStr());
  123. Date date = new Date();
  124. b.setIntm(date);
  125. b.setUptm(date);
  126. b.setGroupId(bisInspAllObj.getId());
  127. b.setPersId(persId);
  128. b.setState(StateEnum.NOWASTSTATE.getKey());
  129. b.setDataStat(StateEnum.NOWASTSTATE.getKey());
  130. b.setJxDuty(attRsBase.getJxDuty());
  131. b.setJxDutyPhone(attRsBase.getJxDutyPhone());
  132. b.setJxRsvrStndLev(attRsBase.getJxRsvrStndLev());
  133. b.setJxRsvrType(attRsBase.getJxRsvrType());
  134. b.setRsAdmCode(attRsBase.getRsAdmCode());
  135. b.setRsAdmName(attRsBase.getRsAdmName());
  136. b.setAdNm(attRsBase.getLocation());
  137. b.setCenterX(attRsBase.getCenterX() == null ? null : Double.parseDouble(attRsBase.getCenterX()));
  138. b.setCenterY(attRsBase.getCenterY() == null ? null : Double.parseDouble(attRsBase.getCenterY()));
  139. b.setCenterXGd(attRsBase.getCenterXGd() == null ? null : Double.parseDouble(attRsBase.getCenterXGd()));
  140. b.setCenterYGd(attRsBase.getCenterYGd() == null ? null : Double.parseDouble(attRsBase.getCenterYGd()));
  141. b.setDamSizeHig(attRsBase.getDamSizeHig());
  142. bisInspStndRgstrDao.insert(b);
  143. }
  144. @Override
  145. public String getType() {
  146. return BisInspEnum.STND.getValue();
  147. }
  148. @Override
  149. public void cleanObjData(String objId) {
  150. BisInspStndRgstrParam param = new BisInspStndRgstrParam();
  151. param.setObjId(objId);
  152. List<BisInspStndRgstr> list = bisInspStndRgstrDao.findList(param);
  153. if (list.size() > 0) {
  154. String id = list.get(0).getId();
  155. bisInspStndRgstrDao.delete(id);
  156. BisInspPblmParam bisInspPblmParam = new BisInspPblmParam();
  157. bisInspPblmParam.setRegid(id);
  158. BisInspStndPlrdParam bisInspStndPlrdParam = new BisInspStndPlrdParam();
  159. bisInspStndPlrdParam.setRgstrId(id);
  160. bisInspStndPlrdDao.deleteBy(bisInspStndPlrdParam);
  161. BisInspStndMgamtParam bisInspStndMgamtParam = new BisInspStndMgamtParam();
  162. bisInspStndMgamtParam.setRgstrId(id);
  163. bisInspStndMgamtDao.deleteBy(bisInspStndMgamtParam);
  164. BisInspStndDtyminParam bisInspStndDtyminParam = new BisInspStndDtyminParam();
  165. bisInspStndDtyminParam.setRgstrId(id);
  166. bisInspStndDtyminDao.deleteBy(bisInspStndDtyminParam);
  167. bisInspPblmParam.setObjType(BisInspEnum.ECOFRD.getValue());
  168. this.bisInspPblmDao.deleteBy(bisInspPblmParam);
  169. this.bisInspAllObjDao.delete(objId);
  170. }
  171. }
  172. @Override
  173. public PageInfo findObjPageByType(TypeParam typeParam, HttpServletResponse response) {
  174. return findStndRgstrPage(typeParam, response);
  175. }
  176. @Override
  177. public Object findObjListByType(TypeParam typeParam) {
  178. return setSsx(typeParam);
  179. }
  180. }