package com.yeshi.buwan.dao.live;
|
|
import com.yeshi.buwan.domain.live.TVLiveCategory;
|
import com.yeshi.buwan.domain.live.TVLiveChannel;
|
import com.yeshi.buwan.dao.base.MongodbBaseDao;
|
import com.yeshi.buwan.query.BaseQuery;
|
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.data.mongodb.core.query.Update;
|
import org.springframework.stereotype.Repository;
|
|
import java.util.ArrayList;
|
import java.util.Date;
|
import java.util.List;
|
|
@Repository
|
public class TVLiveChannelDao extends MongodbBaseDao<TVLiveChannel> {
|
|
public void updateSelective(TVLiveChannel bean) {
|
Query query = new Query();
|
Update update = new Update();
|
query.addCriteria(Criteria.where("id").is(bean.getId()));
|
if (bean.getName() != null) {
|
update.set("name", bean.getName());
|
}
|
if (bean.gethPicture() != null) {
|
update.set("hPicture", bean.gethPicture());
|
}
|
if (bean.getvPicture() != null) {
|
update.set("vPicture", bean.getvPicture());
|
}
|
if (bean.getNowProgram() != null) {
|
update.set("nowProgram", bean.getNowProgram());
|
}
|
if (bean.getNowProgramTime() != null) {
|
update.set("nowProgramTime", bean.getNowProgramTime());
|
}
|
if (bean.getNextProgram() != null) {
|
update.set("nextProgram", bean.getNextProgram());
|
}
|
if (bean.getNextProgramTime() != null) {
|
update.set("nextProgramTime", bean.getNextProgramTime());
|
}
|
if (bean.getState() != null) {
|
update.set("state", bean.getState());
|
}
|
if (bean.getCreateTime() != null) {
|
update.set("createTime", bean.getCreateTime());
|
}
|
update.set("updateTime", new Date());
|
update(query, update);
|
}
|
|
|
public List<TVLiveChannel> listByIds(List<String> ids) {
|
if (ids == null || ids.size() == 0)
|
return null;
|
Criteria[] ors = new Criteria[ids.size()];
|
for (int i = 0; i < ors.length; i++) {
|
ors[i] = Criteria.where("_id").is(ids.get(i));
|
}
|
Query query = new Query();
|
query.addCriteria(new Criteria().orOperator(ors));
|
return findList(query);
|
}
|
|
private Query getQuery(DaoQuery daoQuery) {
|
Query query = BaseQuery.createBaseMongoQuery(daoQuery, daoQuery.sortList);
|
List<Criteria> andList = new ArrayList<>();
|
if (daoQuery.name != null) {
|
andList.add(Criteria.where("name").regex(daoQuery.name));
|
}
|
if (daoQuery.state != null) {
|
andList.add(Criteria.where("state").is(daoQuery.state));
|
}
|
Criteria[] ands = new Criteria[andList.size()];
|
andList.toArray(ands);
|
query.addCriteria(new Criteria().andOperator(ands));
|
return query;
|
|
}
|
|
|
public List<TVLiveChannel> list(DaoQuery daoQuery) {
|
return findList(getQuery(daoQuery));
|
}
|
|
public long count(DaoQuery daoQuery) {
|
return count(getQuery(daoQuery));
|
}
|
|
|
public static class DaoQuery extends BaseQuery {
|
public String name;
|
public Integer state;
|
public List<Sort.Order> sortList;
|
}
|
|
}
|
