package cn.com.goldenwater.dcproj.service.impl.vill; import cn.com.goldenwater.dcproj.dao.AttAdXBaseDao; import cn.com.goldenwater.dcproj.dao.BisInspVillRgstrDao; import cn.com.goldenwater.dcproj.dao.BisInspWateruserInfoDao; import cn.com.goldenwater.dcproj.dto.BisInspWateruserInfoDcdxDto; import cn.com.goldenwater.dcproj.dto.VillRgstrDto; import cn.com.goldenwater.dcproj.model.AttAdXBase; import cn.com.goldenwater.dcproj.model.BisInspVillRgstr; import cn.com.goldenwater.dcproj.model.BisInspWateruserInfo; import cn.com.goldenwater.dcproj.param.AttAdXBaseParam; import cn.com.goldenwater.dcproj.param.BisInspWateruserInfoParam; import cn.com.goldenwater.dcproj.param.GetPageByNodeIdParam; import cn.com.goldenwater.dcproj.param.GetVillPageByNodeIdParam; import cn.com.goldenwater.dcproj.service.BisInspWateruserInfoService; import cn.com.goldenwater.core.service.AbstractCrudService; import com.github.pagehelper.PageHelper; 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 com.github.pagehelper.PageInfo; import java.util.List; import cn.com.goldenwater.id.util.UuidUtil; import java.util.Date; import cn.com.goldenwater.dcproj.utils.DateUtils; /** * @author zhengdafei * @date 2019-2-21 */ @Service @Transactional public class BisInspWateruserInfoServiceImpl extends AbstractCrudService implements BisInspWateruserInfoService { @Autowired private BisInspWateruserInfoDao bisInspWateruserInfoDao; @Autowired private BisInspVillRgstrDao bisInspVillRgstrDao; @Autowired private AttAdXBaseDao attAdXBaseDao; public BisInspWateruserInfoServiceImpl(BisInspWateruserInfoDao bisInspWateruserInfoDao) { super(bisInspWateruserInfoDao); this.bisInspWateruserInfoDao = bisInspWateruserInfoDao; } @Override public String add(BisInspWateruserInfo p) throws Exception { String uuid = UuidUtil.uuid(); String now = DateUtils.getTodayYMDHMS(); p.setCreateTime(now); p.setUpdateTime(now); if (StringUtils.isNotBlank(p.getVillageCode())) { //如果村代码不为空,从数据库取出名字,保存进村名称 AttAdXBase attAdXBase = attAdXBaseDao.get(p.getVillageCode()); if (StringUtils.isNotBlank(attAdXBase.getAdFullName())) { p.setVillageNm(attAdXBase.getAdFullName()); } } p.setPrsnWaterId(uuid); bisInspWateruserInfoDao.insert(p); BisInspVillRgstr rp = new BisInspVillRgstr(); rp.setEngId(p.getEngId()); rp.setState("1"); bisInspVillRgstrDao.update(rp); return uuid; } @Override public int modify(BisInspWateruserInfo p) throws Exception { String now = DateUtils.getTodayYMDHMS(); p.setUpdateTime(now); int ret = bisInspWateruserInfoDao.update(p); return ret; } @Override public PageInfo queryListByPage(BisInspWateruserInfoParam p) throws Exception { PageHelper.startPage(p.getPageNum(), p.getPageSize()); List list = bisInspWateruserInfoDao.findList(p); return new PageInfo(list); } @Override public List queryList(BisInspWateruserInfoParam p) throws Exception { List list = bisInspWateruserInfoDao.findList(p); return list; } @Override public List getListByCodeAndPerId(VillRgstrDto villRgstrDto) { return this.bisInspWateruserInfoDao.getListByCodeAndPerId(villRgstrDto); } @Override public PageInfo getPageByCodeAndPerId(VillRgstrDto villRgstrDto) { PageHelper.startPage(villRgstrDto.getPageNum(), villRgstrDto.getPageSize()); List list = bisInspWateruserInfoDao.getListByCodeAndPerId(villRgstrDto); return new PageInfo(list); } @Override public PageInfo getPageByNodeId(GetVillPageByNodeIdParam p) throws Exception { PageHelper.startPage(p.getPageNum(), p.getPageSize()); List list = bisInspWateruserInfoDao.getPageByNodeId(p); return new PageInfo(list); } }