package com.yeshi.fanli.dao.user.cloud;
|
|
import java.util.Date;
|
import java.util.List;
|
|
import org.springframework.data.domain.Sort;
|
import org.springframework.data.mongodb.core.query.Criteria;
|
import org.springframework.data.mongodb.core.query.Query;
|
import org.springframework.stereotype.Repository;
|
|
import com.yeshi.fanli.dao.MongodbBaseDao;
|
import com.yeshi.fanli.entity.bus.user.cloud.UserCloudSendRecord;
|
|
@Repository
|
public class UserCloudSendRecordDao extends MongodbBaseDao<UserCloudSendRecord> {
|
|
/**
|
* 查询已发送id
|
* @param uid
|
* @param sendId
|
* @param sendOrigin
|
* @return
|
*/
|
public List<UserCloudSendRecord> listByUidAndSendId(Long uid, String sendId){
|
Query query = new Query();
|
query.addCriteria(Criteria.where("uid").is(uid));
|
query.addCriteria(Criteria.where("sendId").is(sendId));
|
query.addCriteria(Criteria.where("sendOrigin").is(UserCloudSendRecord.ORIGIN_EVALUATE));
|
return findList(query);
|
}
|
|
|
/**
|
* 查询已发送id
|
* @param uid
|
* @param sendId
|
* @param sendOrigin
|
* @return
|
*/
|
public List<UserCloudSendRecord> getLastByUid(Long uid, Date lastTime){
|
Query query = new Query();
|
query.addCriteria(Criteria.where("uid").is(uid));
|
query.addCriteria(Criteria.where("sendWay").is(UserCloudSendRecord.SEND_WAY_AUTO));
|
query.addCriteria(Criteria.where("sendOrigin").is(UserCloudSendRecord.ORIGIN_EVALUATE));
|
query.addCriteria(Criteria.where("sendTime").gt(lastTime));
|
query.with(new Sort(Sort.Direction.ASC,"sendTime"));
|
|
return findList(query);
|
}
|
}
|