package cn.com.goldenwater.dcproj.service.impl.jskejian; import cn.com.goldenwater.dcproj.constValue.BisInspEnum; import cn.com.goldenwater.dcproj.constValue.SplitValue; import cn.com.goldenwater.dcproj.dao.AttJskejianWaterBaseDao; import cn.com.goldenwater.dcproj.dao.AttJskejianWaterRgstrDao; import cn.com.goldenwater.dcproj.dao.BisInspAllObjDao; import cn.com.goldenwater.dcproj.dao.BisInspPblmDao; import cn.com.goldenwater.dcproj.dto.AttJskejianWaterRgstrDto; import cn.com.goldenwater.dcproj.dto.BisInspRgstrDto; import cn.com.goldenwater.dcproj.model.AttJskejianWaterBase; import cn.com.goldenwater.dcproj.model.AttJskejianWaterRgstr; import cn.com.goldenwater.dcproj.model.BisInspAllObj; import cn.com.goldenwater.dcproj.param.AttJskejianWaterRgstrParam; import cn.com.goldenwater.dcproj.param.BisInspAllObjParam; import cn.com.goldenwater.dcproj.param.BisInspPblmParam; import cn.com.goldenwater.dcproj.service.AttJskejianWaterRgstrService; import cn.com.goldenwater.core.service.AbstractCrudService; import cn.com.goldenwater.dcproj.service.BisInspObjStrategy; import cn.com.goldenwater.dcproj.utils.AdLevelUtil; import cn.com.goldenwater.dcproj.utils.BeanUtil; import cn.com.goldenwater.dcproj.utils.FormatFieldUtil; import cn.com.goldenwater.dcproj.utils.GeoUtil; import cn.com.goldenwater.dcproj.utils.expExcel.ExportUtil; import cn.com.goldenwater.id.util.UuidUtil; import com.github.pagehelper.PageHelper; import com.github.pagehelper.PageInfo; import org.apache.commons.lang3.StringUtils; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service; import org.springframework.transaction.annotation.Transactional; import javax.servlet.http.HttpServletResponse; import java.util.ArrayList; import java.util.Date; import java.util.List; import java.util.Map; import static cn.com.goldenwater.dcproj.constValue.BisInspObjEnum.JSWA; import cn.com.goldenwater.dcproj.param.TypeParam; /** * @author lune * @date 2019-12-13 */ @Service @Transactional public class AttJskejianWaterRgstrServiceImpl extends AbstractCrudService implements AttJskejianWaterRgstrService,BisInspObjStrategy { @Autowired private AttJskejianWaterRgstrDao attJskejianWaterRgstrDao; @Autowired private AttJskejianWaterBaseDao jskejianWaterBaseDao; @Autowired private BisInspAllObjDao bisInspAllObjDao; @Autowired private BisInspPblmDao bisInspPblmDao; public AttJskejianWaterRgstrServiceImpl(AttJskejianWaterRgstrDao attJskejianWaterRgstrDao) { super(attJskejianWaterRgstrDao); this.attJskejianWaterRgstrDao = attJskejianWaterRgstrDao; } @Override public void insertObj(BisInspAllObj bisInspAllObj, String persId) { AttJskejianWaterBase jskejianWaterBase = jskejianWaterBaseDao.get(bisInspAllObj.getCode()); AttJskejianWaterRgstr jskejianWaterRgstr = new AttJskejianWaterRgstr(); BeanUtil.copyObject1(jskejianWaterBase, jskejianWaterRgstr); jskejianWaterRgstr.setId(UuidUtil.uuid()); jskejianWaterRgstr.setObjId(bisInspAllObj.getObjId()); jskejianWaterRgstr.setProvince(bisInspAllObj.getProvince()); jskejianWaterRgstr.setPersId(persId); jskejianWaterRgstr.setState("0"); if (jskejianWaterBase.getGdX() != null && jskejianWaterBase.getGdY() != null) { Map params = GeoUtil.gcj02towgs84(jskejianWaterBase.getGdX(), jskejianWaterBase.getGdY()); jskejianWaterRgstr.setCenterX(params.get("lon")); jskejianWaterRgstr.setCenterY(params.get("lat")); } jskejianWaterRgstr.setIntm(new Date()); jskejianWaterRgstr.setUptm(new Date()); attJskejianWaterRgstrDao.insert(jskejianWaterRgstr); } @Override public String getType() { return BisInspEnum.JSWA.getValue(); } @Override public void cleanObjData(String objId) { AttJskejianWaterRgstrParam param = new AttJskejianWaterRgstrParam(); param.setObjId(objId); List list = attJskejianWaterRgstrDao.findList(param); if (list.size() > 0) { String id = list.get(0).getId(); AttJskejianWaterRgstr rgstr = attJskejianWaterRgstrDao.get(id); attJskejianWaterRgstrDao.delete(id); BisInspPblmParam bisInspPblmParam = new BisInspPblmParam(); bisInspPblmParam.setRegid(id); bisInspPblmParam.setObjType(BisInspEnum.JSWA.getValue()); this.bisInspPblmDao.deleteBy(bisInspPblmParam); if (rgstr != null) { this.bisInspAllObjDao.delete(rgstr.getObjId()); } } BisInspAllObjParam bisInspAllObjParam = new BisInspAllObjParam(); if (StringUtils.isNotBlank(objId)) { bisInspAllObjParam.setObjId(objId); this.bisInspAllObjDao.deleteBy(bisInspAllObjParam); } } @Override public PageInfo findObjPageByType(TypeParam typeParam, HttpServletResponse response) { return findJsWaPage(typeParam,response); } @Override public Object findObjListByType(TypeParam typeParam) { return findJsWaList(typeParam); } @Override public PageInfo findJsWaPage(TypeParam typeParam, HttpServletResponse response) { if (StringUtils.isNotBlank(typeParam.getAdCode())) { typeParam.setAdCode(String.valueOf(AdLevelUtil.SubAd(typeParam.getAdCode()).get(SplitValue.SUBAD))); } if ("1".equals(typeParam.getIsExport())) { ExportUtil.exportExcel( attJskejianWaterRgstrDao.findJsWaPage(typeParam), response,"非法采砂督查列表"); } PageHelper.startPage(typeParam); List list = attJskejianWaterRgstrDao.findJsWaPage(typeParam); list=changeList(list); return new PageInfo(list); } @Override public List findJsWaList(TypeParam typeParam) { if (StringUtils.isNotBlank(typeParam.getAdCode())) { typeParam.setAdCode(String.valueOf(AdLevelUtil.SubAd(typeParam.getAdCode()).get(SplitValue.SUBAD))); } List list = attJskejianWaterRgstrDao.findJsWaPage(typeParam); return changeList(list); } @Override public PageInfo findPcJsWaPage(AttJskejianWaterRgstrParam attJskejianWaterRgstrParam) { PageHelper.startPage(attJskejianWaterRgstrParam); List list = attJskejianWaterRgstrDao.findPcJsWaPage(attJskejianWaterRgstrParam); if (list.size() > 0) { for (AttJskejianWaterRgstrDto b : list) { if (b.getAdFullName() != null) { if (b.getAdFullName().contains(SplitValue.HENG_SPLIT)) { String[] split = b.getAdFullName().split(SplitValue.HENG_SPLIT); if (split.length == 3) { b.setProvince(split[0]); b.setCity(split[1]); b.setCounty(split[2]); } if (split.length == 2) { b.setProvince(split[0]); b.setCity(split[1]); b.setCounty(""); } } else { b.setProvince(b.getAdFullName()); } } } } return new PageInfo(list); } @Override public void findPcPageExport(AttJskejianWaterRgstrParam attJskejianWaterRgstrParam,HttpServletResponse response) { List list = attJskejianWaterRgstrDao.findPcJsWaPage(attJskejianWaterRgstrParam); list.forEach(x -> { x.setState(FormatFieldUtil.commonStateFormat(x.getState())); x.setPtype(JSWA.getDesc()); x.setReviConc(FormatFieldUtil.commonReviConcFormat(x.getReviConc())); x.setRectConc(FormatFieldUtil.commonRectConcFormat(x.getRectConc())); }); List columns = new ArrayList<>(); columns.add("id"); columns.add("adCode"); columns.add("centerX"); columns.add("centerY"); columns.add("intm"); columns.add("uptm"); columns.add("gdX"); columns.add("gdY"); columns.add("baseId"); columns.add("rgstrId"); columns.add("objId"); columns.add("persId"); columns.add("groupId"); columns.add("province"); columns.add("code"); columns.add("nodeId"); ExportUtil.exportExcel(list, response, "非法采砂督查登记列表", columns, AttJskejianWaterRgstrDto.class); } private List changeList(List list){ if (list.size() > 0) { for (BisInspRgstrDto rgstrDto : list) { String adFullName = rgstrDto.getAdName(); if(StringUtils.isBlank(adFullName)){ continue; } if (adFullName.contains(SplitValue.HENG_SPLIT)) { String[] split = adFullName.split(SplitValue.HENG_SPLIT); if (split.length == 3) { rgstrDto.setProvince(split[0]); rgstrDto.setCity(split[1]); rgstrDto.setCountry(split[2]); } if (split.length == 2) { rgstrDto.setProvince(split[0]); rgstrDto.setCity(split[1]); rgstrDto.setCountry(""); } } else { rgstrDto.setProvince(adFullName); } } } return list; } }