package com.ks.app.dao.admin; import com.ks.app.entity.admin.AdminRole; import com.ks.app.entity.admin.AdminRoleRule; 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 AdminRoleRuleDao extends MongodbBaseDao { public void updateSelective(AdminRoleRule bean) { Query query = new Query(); Update update = new Update(); query.addCriteria(Criteria.where("id").is(bean.getId())); if (bean.getRole() != null) { update.set("role", bean.getRole()); } if (bean.getPath() != null) { update.set("path", bean.getPath()); } if (bean.getNavPage() != null) { update.set("navPage", bean.getNavPage()); } 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.role != null) { andList.add(Criteria.where("role").is(daoQuery.role)); } if (daoQuery.roles != null && daoQuery.roles.size() > 0) { Criteria[] ors = new Criteria[daoQuery.roles.size()]; for (int i = 0; i < ors.length; i++) { ors[i] =new Criteria("role").is(daoQuery.roles.get(i)); } andList.add(new Criteria().orOperator(ors)); } if (daoQuery.path != null) { andList.add(Criteria.where("path").regex(daoQuery.path)); } if (daoQuery.navPage != null) { andList.add(Criteria.where("navPage").is(daoQuery.navPage)); } 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 AdminRole role; public String path; public Boolean navPage; public List roles; public int start; public int count; public List sortList; } }