package cn.com.goldenwater.dcproj.service.impl; import cn.com.goldenwater.dcproj.constValue.BisInspEnum; import cn.com.goldenwater.dcproj.constValue.CommonLabel; import cn.com.goldenwater.dcproj.constValue.SplitValue; import cn.com.goldenwater.dcproj.dao.AttGrowBaseDao; import cn.com.goldenwater.dcproj.dao.BisInspAllObjDao; import cn.com.goldenwater.dcproj.dao.BisInspGrowRgstrDao; import cn.com.goldenwater.dcproj.dao.BisInspPblmDao; import cn.com.goldenwater.dcproj.dto.BisInspGrowRgstrDto; import cn.com.goldenwater.dcproj.model.*; import cn.com.goldenwater.dcproj.param.*; import cn.com.goldenwater.dcproj.service.*; import cn.com.goldenwater.core.service.AbstractCrudService; import cn.com.goldenwater.dcproj.utils.AdLevelUtil; import cn.com.goldenwater.dcproj.utils.Constant; import com.github.pagehelper.PageHelper; import com.github.pagehelper.PageInfo; import org.apache.commons.collections.MapUtils; import org.apache.commons.lang3.StringUtils; import org.springframework.beans.BeanUtils; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service; import org.springframework.transaction.annotation.Transactional; import cn.com.goldenwater.id.util.UuidUtil; import javax.servlet.http.HttpServletResponse; import java.util.List; import java.util.Date; import java.util.Map; /** * @author lhc * @date 2021-1-22 */ @Service @Transactional public class BisInspGrowRgstrServiceImpl extends AbstractCrudService implements BisInspGrowRgstrService , BisInspObjStrategy { @Autowired private BisInspGrowRgstrDao bisInspGrowRgstrDao; @Autowired private AttGrowBaseService attGrowBaseService; @Autowired private AttGrowBaseDao attGrowBaseDao; @Autowired private BisInspGrowCloService bisInspGrowCloService; @Autowired private BisInspGrowDrouService bisInspGrowDrouService; @Autowired private BisInspGrowOutService bisInspGrowOutService; @Autowired private BisInspGrowWithService bisInspGrowWithService; @Autowired private BisInspPblmDao bisInspPblmDao; @Autowired private BisInspAllObjDao bisInspAllObjDao; public BisInspGrowRgstrServiceImpl(BisInspGrowRgstrDao bisInspGrowRgstrDao) { super(bisInspGrowRgstrDao); this.bisInspGrowRgstrDao = bisInspGrowRgstrDao; } @Override public int insert(BisInspGrowRgstr bisInspGrowRgstr) { String uuid = UuidUtil.uuid(); // 生成uuid bisInspGrowRgstr.setId(uuid); bisInspGrowRgstr.setIntm(new Date()); bisInspGrowRgstr.setUptm(new Date()); bisInspGrowRgstr.setDataStat("0"); return this.bisInspGrowRgstrDao.insert(bisInspGrowRgstr); } @Override public int update(BisInspGrowRgstr bisInspGrowRgstr) { bisInspGrowRgstr.setUptm(new Date()); return this.bisInspGrowRgstrDao.update(bisInspGrowRgstr); } @Override public int delete(String id) { return this.bisInspGrowRgstrDao.delete(id); } @Override public BisInspGrowRgstr save(BisInspGrowRgstr bisInspGrowRgstr) { // 根据有无主键,来新增、更新信息 int ret = 0; if (StringUtils.isNotBlank(bisInspGrowRgstr.getRgstrId())) { // rgstrId 不为 空 时,传给ID bisInspGrowRgstr.setId(bisInspGrowRgstr.getRgstrId()); } if (StringUtils.isBlank(bisInspGrowRgstr.getId())) { if (StringUtils.isNotBlank(bisInspGrowRgstr.getObjId())) { BisInspGrowRgstrParam param = new BisInspGrowRgstrParam(); param.setObjId(bisInspGrowRgstr.getId()); BisInspGrowRgstr rgstr = getBy(param); // 如果没有注册表,添加 if (null == rgstr) { ret = insert(bisInspGrowRgstr); } else { bisInspGrowRgstr.setId(rgstr.getId()); bisInspGrowRgstr.setUptm(new Date()); update(bisInspGrowRgstr); // 更新基础表 updateAttGrowBase(bisInspGrowRgstr); } } } else { if (StringUtils.isBlank(bisInspGrowRgstr.getObjId())) { BisInspGrowRgstr rgstr = get(bisInspGrowRgstr.getId()); if (null != rgstr) { bisInspGrowRgstr.setObjId(rgstr.getObjId()); } } bisInspGrowRgstr.setUptm(new Date()); update(bisInspGrowRgstr); // 更新基础表 updateAttGrowBase(bisInspGrowRgstr); } return bisInspGrowRgstr; } @Override public PageInfo findGrowPageInfo(BisInspGrowRgstrParam bisInspGrowRgstrParam) { PageHelper.startPage(bisInspGrowRgstrParam.getPageNum(),bisInspGrowRgstrParam.getPageSize()); List list = bisInspGrowRgstrDao.findGrowPageInfo(bisInspGrowRgstrParam); return new PageInfo(list); } @Override public void updateState(Map map) { BisInspGrowRgstr rgstr = get(MapUtils.getString(map, "rgstrId")); if (!Constant.STRING_TWO.equals(rgstr.getState()) && StringUtils.isNotBlank(MapUtils.getString(map, "state"))) { rgstr.setUptm(new Date()); rgstr.setState(Constant.STRING_ONE); switch (MapUtils.getString(map, "param")) { case "clo": rgstr.setGrowCloState(MapUtils.getString(map, "state")); break; case "drou": rgstr.setGrowDrouState(MapUtils.getString(map, "state")); break; case "out": rgstr.setGrowOutState(MapUtils.getString(map, "state")); break; case "with": rgstr.setGrowWithState(MapUtils.getString(map, "state")); break; default: } update(rgstr); } } private void updateAttGrowBase(BisInspGrowRgstr bisInspGrowRgstr) { // 清空特殊数据 if (StringUtils.isNotBlank(bisInspGrowRgstr.getObjId())) { AttGrowBase attCdepBase = attGrowBaseService.getObjId(bisInspGrowRgstr.getObjId()); // 转换基础表ID String attCdepBaseId = attCdepBase.getId(); BeanUtils.copyProperties(bisInspGrowRgstr, attCdepBase); attCdepBase.setId(attCdepBaseId); attCdepBase.setIntm(null); attGrowBaseService.update(attCdepBase); } } @Override public void insertObj(BisInspAllObj bisInspAllObj, String persId) { BisInspGrowRgstr rgstr = new BisInspGrowRgstr(); AttGrowBase base = attGrowBaseDao.get(bisInspAllObj.getCode()); BeanUtils.copyProperties(base, rgstr); // 统一字段 rgstrId, objId rgstr.setId(UuidUtil.uuid()); rgstr.setObjId(bisInspAllObj.getObjId()); rgstr.setGroupId(bisInspAllObj.getId()); rgstr.setProvince(bisInspAllObj.getProvince()); // 日期 Date d = new Date(); rgstr.setIntm(d); rgstr.setUptm(d); // 数据状态 默认为 0 rgstr.setDataStat(CommonLabel.INIT_DATA); // 督查状态(0:未督查;1:督查中;2:已督查) rgstr.setState(CommonLabel.INIT_DATA); // 子表状态(0:未督查;1:督查中;2:已督查) rgstr.setGrowCloState(CommonLabel.INIT_DATA); rgstr.setGrowDrouState(CommonLabel.INIT_DATA); rgstr.setGrowOutState(CommonLabel.INIT_DATA); rgstr.setGrowOutState(CommonLabel.INIT_DATA); // 创建人 rgstr.setPersId(persId); /* 添加 登记表 */ this.bisInspGrowRgstrDao.insert(rgstr); /* 添加 子表 */ BisInspGrowClo bisInspGrowClo = new BisInspGrowClo(); bisInspGrowClo.setRgstrId(rgstr.getId()); bisInspGrowCloService.insert(bisInspGrowClo); BisInspGrowDrou bisInspGrowDrou = new BisInspGrowDrou(); bisInspGrowDrou.setRgstrId(rgstr.getId()); bisInspGrowDrouService.insert(bisInspGrowDrou); BisInspGrowOut bisInspGrowOut = new BisInspGrowOut(); bisInspGrowOut.setRgstrId(rgstr.getId()); bisInspGrowOutService.insert(bisInspGrowOut); BisInspGrowWith bisInspGrowWith = new BisInspGrowWith(); bisInspGrowWith.setRgstrId(rgstr.getId()); bisInspGrowWithService.insert(bisInspGrowWith); } @Override public String getType() { return BisInspEnum.GROW.getValue(); } @Override public void cleanObjData(String objId) { BisInspGrowRgstrParam rgstrParam = new BisInspGrowRgstrParam(); rgstrParam.setObjId(objId); List list = this.bisInspGrowRgstrDao.findList(rgstrParam); if (list.size() > 0) { String id = list.get(0).getId(); // 删除子表 BisInspGrowCloParam bisInspGrowCloParam = new BisInspGrowCloParam(); bisInspGrowCloParam.setRgstrId(id); bisInspGrowCloService.deleteBy(bisInspGrowCloParam); BisInspGrowDrouParam bisInspGrowDrouParam = new BisInspGrowDrouParam(); bisInspGrowDrouParam.setRgstrId(id); bisInspGrowDrouService.deleteBy(bisInspGrowDrouParam); BisInspGrowOutParam bisInspGrowOutParam = new BisInspGrowOutParam(); bisInspGrowOutParam.setRgstrId(id); bisInspGrowOutService.deleteBy(bisInspGrowOutParam); BisInspGrowWithParam bisInspGrowWithParam = new BisInspGrowWithParam(); bisInspGrowWithParam.setRgstrId(id); bisInspGrowWithService.deleteBy(bisInspGrowWithParam); // 删除登记表 this.bisInspGrowRgstrDao.delete(id); } // 删除问题 BisInspPblmParam bisInspPblmParam = new BisInspPblmParam(); bisInspPblmParam.setObjId(objId); bisInspPblmParam.setObjType(BisInspEnum.CDEP.getValue()); bisInspPblmDao.deleteBy(bisInspPblmParam); // 删除对象名录表 BisInspAllObjParam bisInspAllObjParam = new BisInspAllObjParam(); bisInspAllObjParam.setObjId(objId); bisInspAllObjDao.deleteBy(bisInspAllObjParam); } @Override public PageInfo findObjPageByType(TypeParam typeParam, HttpServletResponse response) { if (StringUtils.isNotBlank(typeParam.getAdCode())) { typeParam.setAdCode(String.valueOf(AdLevelUtil.SubAd(typeParam.getAdCode()).get(SplitValue.SUBAD))); } PageHelper.startPage(typeParam); List list = this.bisInspGrowRgstrDao.findPageList(typeParam); return (PageInfo) new PageInfo(list); } @Override public Object findObjListByType(TypeParam typeParam) { return this.bisInspGrowRgstrDao.findPageList(typeParam); } }