功能完善

admin

2022-04-07 e1cc0d03fadc2d251d36c0dc3650f75e830d5363

 app/src/main/java/com/yeshi/makemoney/app/service/impl/goldcorn/GoldCornConsumeRecordServiceImpl.java

@@ -2,10 +2,18 @@

import java.lang.Exception;
import javax.annotation.Resource;

import com.yeshi.makemoney.app.exception.goldcorn.GoldCornConsumeRecordException;
import org.springframework.stereotype.Service;

import java.util.Date;

import org.yeshi.utils.StringUtil;
import org.yeshi.utils.TimeUtil;
import org.yeshi.utils.bean.BeanUtil;

import java.util.List;

import com.yeshi.makemoney.app.dao.goldcorn.GoldCornConsumeRecordDao;
import com.yeshi.makemoney.app.entity.goldcorn.GoldCornConsumeRecord;
import com.yeshi.makemoney.app.service.inter.goldcorn.GoldCornConsumeRecordService;
@@ -16,71 +24,82 @@
import org.springframework.data.mongodb.core.query.Query;

@Service
public class GoldCornConsumeRecordServiceImpl implements GoldCornConsumeRecordService{
public class GoldCornConsumeRecordServiceImpl implements GoldCornConsumeRecordService {

  @Resource
  private GoldCornConsumeRecordDao goldCornConsumeRecordDao;
    @Resource
    private GoldCornConsumeRecordDao goldCornConsumeRecordDao;

  @Override
  public List<GoldCornConsumeRecord> list(GoldCornConsumeRecordQuery goldCornConsumeRecordQuery, int page, int pageSize)  {
    DaoQuery daoQuery = new DaoQuery();
    try {
        BeanUtil.copyProperties(goldCornConsumeRecordQuery, daoQuery);
    } catch (IllegalAccessException e) {
          e.printStackTrace();
    @Override
    public List<GoldCornConsumeRecord> list(GoldCornConsumeRecordQuery goldCornConsumeRecordQuery, int page, int pageSize) {
        DaoQuery daoQuery = new DaoQuery();
        daoQuery.type = goldCornConsumeRecordQuery.getType();
        daoQuery.uid = goldCornConsumeRecordQuery.getUid();
        daoQuery.minCreateTime = goldCornConsumeRecordQuery.toStartTime();
        daoQuery.maxCreateTime = goldCornConsumeRecordQuery.toEndTime();

        daoQuery.start = (page - 1) * pageSize;
        daoQuery.count = pageSize;
        return goldCornConsumeRecordDao.list(daoQuery);
    }
    daoQuery.start=(page-1)*pageSize;
    daoQuery.count=pageSize;
    return goldCornConsumeRecordDao.list(daoQuery);
  }

  @Override
  public long count(GoldCornConsumeRecordQuery goldCornConsumeRecordQuery)  {
    DaoQuery daoQuery = new DaoQuery();
    try {
        BeanUtil.copyProperties(goldCornConsumeRecordQuery, daoQuery);
    } catch (IllegalAccessException e) {
          e.printStackTrace();
    @Override
    public long count(GoldCornConsumeRecordQuery goldCornConsumeRecordQuery) {
        DaoQuery daoQuery = new DaoQuery();
        daoQuery.type = goldCornConsumeRecordQuery.getType();
        daoQuery.uid = goldCornConsumeRecordQuery.getUid();
        daoQuery.minCreateTime = goldCornConsumeRecordQuery.toStartTime();
        daoQuery.maxCreateTime = goldCornConsumeRecordQuery.toEndTime();
        return goldCornConsumeRecordDao.count(daoQuery);
    }
    return goldCornConsumeRecordDao.count(daoQuery);
  }

  @Override
  public GoldCornConsumeRecord get(String id)  {
    Query query=new Query();
    query.addCriteria(Criteria.where("_id").is(id));
    return goldCornConsumeRecordDao.findOne(query);
  }
    @Override
    public GoldCornConsumeRecord get(String id) {
        Query query = new Query();
        query.addCriteria(Criteria.where("_id").is(id));
        return goldCornConsumeRecordDao.findOne(query);
    }

  @Override
  public void add(GoldCornConsumeRecord goldCornConsumeRecord)  throws Exception {
     //查询主键ID是否存在
     if(goldCornConsumeRecordDao.get(goldCornConsumeRecord.getId())!=null){
        throw new Exception("已存在");
     }
    @Override
    public void add(GoldCornConsumeRecord goldCornConsumeRecord) throws GoldCornConsumeRecordException {

     if(goldCornConsumeRecord.getCreateTime()==null){
        goldCornConsumeRecord.setCreateTime(new Date());
     }
     //保存
     goldCornConsumeRecordDao.save(goldCornConsumeRecord);
  }
        if (goldCornConsumeRecord.getType() == null || goldCornConsumeRecord.getUid() == null || goldCornConsumeRecord.getCornNum() == null) {
            throw new GoldCornConsumeRecordException(GoldCornConsumeRecordException.CODE_PARAMS_NOT_ENOUGH, "参数不完整");
        }

  @Override
  public void update(GoldCornConsumeRecord goldCornConsumeRecord)  {
     if(goldCornConsumeRecord.getUpdateTime()==null){
        goldCornConsumeRecord.setUpdateTime(new Date());
     }
     //更新
     goldCornConsumeRecordDao.updateSelective(goldCornConsumeRecord);
  }

  @Override
  public void delete(List<String> idList)  {
     for (String id : idList){
        goldCornConsumeRecordDao.delete(id);
     }
  }
        if (goldCornConsumeRecord.getCreateTime() == null) {
            goldCornConsumeRecord.setCreateTime(new Date());
        }

        if (goldCornConsumeRecord.getId() == null) {
            goldCornConsumeRecord.setId(goldCornConsumeRecord.toId());
        }

        //查询主键ID是否存在
        if (goldCornConsumeRecordDao.get(goldCornConsumeRecord.getId()) != null) {
            throw new GoldCornConsumeRecordException(GoldCornConsumeRecordException.CODE_EXIST, "记录已存在");
        }


        //保存
        goldCornConsumeRecordDao.save(goldCornConsumeRecord);
    }

    @Override
    public void update(GoldCornConsumeRecord goldCornConsumeRecord) {
        if (goldCornConsumeRecord.getUpdateTime() == null) {
            goldCornConsumeRecord.setUpdateTime(new Date());
        }
        //更新
        goldCornConsumeRecordDao.updateSelective(goldCornConsumeRecord);
    }

    @Override
    public void delete(List<String> idList) {
        for (String id : idList) {
            goldCornConsumeRecordDao.delete(id);
        }
    }


}