package cn.com.goldenwater.dcproj.service.impl; import cn.com.goldenwater.core.service.AbstractCrudService; import cn.com.goldenwater.dcproj.constValue.BisInspEnum; import cn.com.goldenwater.dcproj.constValue.SplitValue; import cn.com.goldenwater.dcproj.dao.BisInspSwhsjsDao; import cn.com.goldenwater.dcproj.dto.BisInspSwhsjsDto; import cn.com.goldenwater.dcproj.model.AttSwhsjsBase; import cn.com.goldenwater.dcproj.model.BisInspAllObj; import cn.com.goldenwater.dcproj.model.BisInspSwhsjs; import cn.com.goldenwater.dcproj.param.BisInspSwhsjsMgtParam; import cn.com.goldenwater.dcproj.param.BisInspSwhsjsParam; import cn.com.goldenwater.dcproj.param.TypeParam; import cn.com.goldenwater.dcproj.service.AttSwhsjsBaseService; import cn.com.goldenwater.dcproj.service.BisInspSwhsjsMgtService; import cn.com.goldenwater.dcproj.service.BisInspSwhsjsService; import cn.com.goldenwater.dcproj.utils.AdLevelUtil; import cn.com.goldenwater.dcproj.utils.Builder; import cn.com.goldenwater.dcproj.utils.Constant; import cn.com.goldenwater.id.util.UuidUtil; import com.github.pagehelper.PageHelper; import com.github.pagehelper.PageInfo; import org.apache.commons.collections.MapUtils; import org.apache.commons.lang.StringUtils; import org.slf4j.Logger; import org.slf4j.LoggerFactory; import org.springframework.beans.BeanUtils; 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.Date; import java.util.List; import java.util.Map; /** * @author * @date 2022-2-23 */ @Service @Transactional public class BisInspSwhsjsServiceImpl extends AbstractCrudService implements BisInspSwhsjsService { private Logger logger = LoggerFactory.getLogger(getClass()); @Autowired private BisInspSwhsjsDao bisInspSwhsjsDao; @Autowired private AttSwhsjsBaseService attSwhsjsBaseService; @Autowired private BisInspSwhsjsMgtService bisInspSwhsjsMgtService; public BisInspSwhsjsServiceImpl(BisInspSwhsjsDao bisInspSwhsjsDao) { super(bisInspSwhsjsDao); this.bisInspSwhsjsDao = bisInspSwhsjsDao; } @Override public int insert(BisInspSwhsjs bisInspSwhsjs) { String uuid = UuidUtil.uuid(); bisInspSwhsjs.setId(uuid); bisInspSwhsjs.setIntm(new Date()); bisInspSwhsjs.setUptm(new Date()); bisInspSwhsjs.setDataStat("0"); bisInspSwhsjs.setState("0"); bisInspSwhsjs.setMgtStat("0"); this.bisInspSwhsjsMgtService.insert(Builder.of(BisInspSwhsjsMgtParam::new) .with(BisInspSwhsjsMgtParam::setRgstrId, uuid) .build()); return this.bisInspSwhsjsDao.insert(bisInspSwhsjs); } @Override public int update(BisInspSwhsjs bisInspSwhsjs) { bisInspSwhsjs.setUptm(new Date()); return this.bisInspSwhsjsDao.update(bisInspSwhsjs); } @Override public int delete(String id) { return this.bisInspSwhsjsDao.delete(id); } @Override public void updateState(Map map) { BisInspSwhsjs rgstr = get(MapUtils.getString(map, "rgstrId")); if (!Constant.STRING_TWO.equals(rgstr.getState())) { rgstr.setUptm(new Date()); rgstr.setState(Constant.STRING_ONE); if ("mgt".equals(MapUtils.getString(map, "param"))) { if (StringUtils.isBlank(rgstr.getMgtStat()) && !"2".equals(MapUtils.getString(map, "state"))) { map.put("state", "1"); } if (StringUtils.isNotBlank(MapUtils.getString(map, "state"))) { rgstr.setMgtStat(MapUtils.getString(map, "state")); } } update(rgstr); } } @Override public void insertObj(BisInspAllObj bisInspAllObj, String persId) { BisInspSwhsjs b = new BisInspSwhsjs(); AttSwhsjsBase base = attSwhsjsBaseService.get(bisInspAllObj.getCode()); BeanUtils.copyProperties(base, b); b.setObjId(bisInspAllObj.getObjId()); // b.setPersId(bisInspAllObj.getPersId()); // 添加 登记表 insert(b); } @Override public String getType() { return BisInspEnum.SWHSJS.getValue(); } @Override public void cleanObjData(String objId) { BisInspSwhsjsParam rgstrParam = new BisInspSwhsjsParam(); rgstrParam.setObjId(objId); List list = this.bisInspSwhsjsDao.findList(rgstrParam); if (list.size() > 0) { String id = list.get(0).getId(); // 删除子表 this.bisInspSwhsjsMgtService.deleteBy(Builder.of(BisInspSwhsjsMgtParam::new).with(BisInspSwhsjsMgtParam::setRgstrId, id).build()); // 删除登记表 this.bisInspSwhsjsDao.delete(id); } } @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.bisInspSwhsjsDao.findPageList(typeParam); if (list != null && list.size() > 0) { list.forEach(rgstrDto -> { if (StringUtils.isNotBlank(rgstrDto.getAdFullName())) { String[] adFullNames = rgstrDto.getAdFullName().split("-"); rgstrDto.setProName(adFullNames[0]); if (adFullNames.length > 1) { rgstrDto.setCityName(adFullNames[1]); } if (adFullNames.length > 2) { rgstrDto.setCountyName(adFullNames[2]); } } }); } return new PageInfo<>(list); } @Override public Object findObjListByType(TypeParam typeParam) { return this.bisInspSwhsjsDao.findPageList(typeParam); } }