package com.ks.app.dao.admin; import com.ks.app.entity.admin.AdminRole; import com.ks.app.entity.admin.AdminUserRoles; 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 org.yeshi.utils.mongo.MongodbBaseDao; import java.util.ArrayList; import java.util.Date; import java.util.List; @Repository public class AdminUserRolesDao extends MongodbBaseDao{ public void updateSelective(AdminUserRoles bean) { Query query = new Query(); Update update=new Update(); query.addCriteria(Criteria.where("id").is(bean.getId())); if(bean.getAdminId() != null) { update.set("adminId", bean.getAdminId()); } if(bean.getRole() != null) { update.set("role", bean.getRole()); } if(bean.getCreateTime() != null) { update.set("createTime", bean.getCreateTime()); } update.set("updateTime", new Date()); update(query, update); } public List list(DaoQuery daoQuery){ Query query = getQuery(daoQuery); if (daoQuery.sortList!=null && daoQuery.sortList.size()>0){ query.with(Sort.by(daoQuery.sortList)); } query.skip(daoQuery.start); query.limit(daoQuery.count); return findList(query); } public long count(DaoQuery daoQuery){ Query query=getQuery(daoQuery); return count(query); } private Query getQuery(DaoQuery daoQuery){ List andList=new ArrayList<>(); if(daoQuery.adminId!=null){ andList.add(Criteria.where("adminId").is(daoQuery.adminId)); } if(daoQuery.role!=null){ andList.add(Criteria.where("role").is(daoQuery.role)); } Query query=new Query(); Criteria[] ands=new Criteria[andList.size()]; andList.toArray(ands); if(ands.length>0){ query.addCriteria(new Criteria().andOperator(ands)); } return query; } public static class DaoQuery{ public String adminId; public AdminRole role; public int start; public int count; public List sortList; } }