package com.yeshi.fanli.dao.user.invite;
|
|
import java.util.Date;
|
import java.util.List;
|
|
import javax.annotation.Resource;
|
|
import org.springframework.data.mongodb.core.MongoTemplate;
|
import org.springframework.data.mongodb.core.query.Criteria;
|
import org.springframework.data.mongodb.core.query.Query;
|
import org.springframework.data.mongodb.core.query.Update;
|
import org.springframework.stereotype.Repository;
|
|
import com.yeshi.fanli.entity.bus.user.vip.TeamDailyRecord;
|
|
@Repository
|
public class TeamDailyRecordDao {
|
|
@Resource
|
private MongoTemplate mongoTemplate;
|
|
/**
|
* 新增
|
*
|
* @param record
|
*/
|
public void save(TeamDailyRecord record) {
|
if (record == null) {
|
return;
|
}
|
mongoTemplate.save(record);
|
}
|
|
/**
|
* 选择性更新
|
* @param record
|
*/
|
public void updateSelective(TeamDailyRecord record) {
|
Query query = new Query();
|
query.addCriteria(Criteria.where("id").is(record.getId()));
|
|
Update update = new Update();
|
if (record.getFirstNum() != null)
|
update.set("firstNum", record.getFirstNum());
|
if (record.getSecondNum() != null)
|
update.set("secondNum", record.getSecondNum());
|
if (record.getBeyondNum() != null)
|
update.set("beyondNum", record.getBeyondNum());
|
if (record.getFirstDaRen() != null)
|
update.set("firstDaRen", record.getFirstDaRen());
|
if (record.getSecondDaRen() != null)
|
update.set("secondDaRen", record.getSecondDaRen());
|
if (record.getBeyondDaRen() != null)
|
update.set("beyondDaRen", record.getBeyondDaRen());
|
if (record.getFirstHighVIP() != null)
|
update.set("firstHighVIP", record.getFirstHighVIP());
|
if (record.getSecondHighVIP() != null)
|
update.set("secondHighVIP", record.getSecondHighVIP());
|
if (record.getBeyondHighVIP() != null)
|
update.set("beyondHighVIP", record.getBeyondHighVIP());
|
if (record.getFirstSuperVIP() != null)
|
update.set("firstSuperVIP", record.getFirstSuperVIP());
|
if (record.getSecondSuperVIP() != null)
|
update.set("secondSuperVIP", record.getSecondSuperVIP());
|
if (record.getBeyondSuperVIP() != null)
|
update.set("beyondSuperVIP", record.getBeyondSuperVIP());
|
update.set("updateTime", new Date());
|
mongoTemplate.updateMulti(query, update, TeamDailyRecord.class);
|
}
|
|
/**
|
* 根据id查询数据
|
*
|
* @param id
|
* @return
|
*/
|
public TeamDailyRecord getById(String id) {
|
Query query = new Query();
|
query.addCriteria(Criteria.where("id").is(id));
|
return mongoTemplate.findOne(query, TeamDailyRecord.class);
|
}
|
|
/**
|
* 查询
|
*
|
* @return
|
*/
|
public List<TeamDailyRecord> getbyUid(Long uid) {
|
Query query = new Query();
|
query.addCriteria(Criteria.where("uid").is(uid));
|
return mongoTemplate.find(query, TeamDailyRecord.class);
|
}
|
|
/**
|
* 查询
|
*
|
* @return
|
*/
|
public List<TeamDailyRecord> getbyUid(Long uid, Date minTime) {
|
Query query = new Query();
|
query.addCriteria(Criteria.where("uid").is(uid));
|
query.addCriteria(Criteria.where("countDay").lte(minTime));
|
return mongoTemplate.find(query, TeamDailyRecord.class);
|
}
|
|
}
|