Commit a9335fe4 authored by 赵啸非's avatar 赵啸非

添加根据部门id 查询所属大厅

parent 4db1de0b
...@@ -211,11 +211,12 @@ public class SiteServiceImpl extends AbstractCRUDCacheServiceImpl<SiteDao, SiteE ...@@ -211,11 +211,12 @@ public class SiteServiceImpl extends AbstractCRUDCacheServiceImpl<SiteDao, SiteE
SiteQuery siteQuery = new SiteQuery(); SiteQuery siteQuery = new SiteQuery();
//如果站点为空 或者用户为空 返回空数组 //如果站点为空 或者用户为空 返回空数组
if (context.getUser() == null || context.getUser().getSiteIds() == null) { if (context.getUser() == null) {
return new ArrayList<>(); return new ArrayList<>();
} }
List<SiteEntity> siteList = new ArrayList<>();
if (context.getUser() != null && context.getUser().getSiteIds() != null) { if (context.getUser().getSiteIds() != null) {
Set<String> siteSet = Arrays.stream(context.getUser().getSiteIds().split(",")).filter(f -> !f.equals("")).collect(Collectors.toSet()); Set<String> siteSet = Arrays.stream(context.getUser().getSiteIds().split(",")).filter(f -> !f.equals("")).collect(Collectors.toSet());
if (!ObjectUtils.isEmpty(siteSet)) { if (!ObjectUtils.isEmpty(siteSet)) {
List<Long> siteIdList = siteSet.stream().map(Long::parseLong).collect(Collectors.toList()); List<Long> siteIdList = siteSet.stream().map(Long::parseLong).collect(Collectors.toList());
...@@ -223,17 +224,20 @@ public class SiteServiceImpl extends AbstractCRUDCacheServiceImpl<SiteDao, SiteE ...@@ -223,17 +224,20 @@ public class SiteServiceImpl extends AbstractCRUDCacheServiceImpl<SiteDao, SiteE
siteQuery.idList(siteIdList); siteQuery.idList(siteIdList);
} }
} }
}
//查詢指定的站點ids //查詢指定的站點ids
log.info(String.format("siteQuery==>%s", JSON.toJSONString(siteQuery))); log.info(String.format("siteQuery==>%s", JSON.toJSONString(siteQuery)));
List<SiteEntity> siteList = this.find(siteQuery); siteList = this.find(siteQuery);
}
//如果是管理员 默认全部站点 //如果是管理员 默认全部站点
if (context.getUser().isAdmin()) { if (context.getUser().isAdmin() || context.getUser().getId() == 0L) {
log.info("user is admin !"); log.info("user is admin !");
siteList = this.find(new SiteQuery()); siteList = this.find(new SiteQuery());
} }
if (ObjectUtils.isEmpty(siteList)) {
return new ArrayList<>();
}
//turn to sitemap //turn to sitemap
Map<String, SiteEntity> siteMap = siteList.parallelStream().collect(Collectors.toMap(x -> x.getSiteCode(), y -> y, (o, n) -> n)); Map<String, SiteEntity> siteMap = siteList.parallelStream().collect(Collectors.toMap(x -> x.getSiteCode(), y -> y, (o, n) -> n));
//遍历过滤站点树 //遍历过滤站点树
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment