提交 2c05e998 作者: obcy

Merge remote-tracking branch 'origin/master'

...@@ -126,7 +126,7 @@ class KnowledgeServiceImpl implements IKnowledgeService { ...@@ -126,7 +126,7 @@ class KnowledgeServiceImpl implements IKnowledgeService {
.filter(item -> !item.getContent().contains("<td>")) .filter(item -> !item.getContent().contains("<td>"))
.filter(item -> !item.getContent().contains("</td>")) .filter(item -> !item.getContent().contains("</td>"))
.collect(Collectors.toList()); .collect(Collectors.toList());
messageContentList.forEach(item->item.setContent(Jsoup.parse(item.getContent()).text())); messageContentList.forEach(item -> item.setContent(Jsoup.parse(item.getContent()).text()));
knowledgeMessage.setContents(messageContentList); knowledgeMessage.setContents(messageContentList);
produceInfo.sendKnowledgeContents(knowledgeMessage); produceInfo.sendKnowledgeContents(knowledgeMessage);
} }
...@@ -160,37 +160,37 @@ class KnowledgeServiceImpl implements IKnowledgeService { ...@@ -160,37 +160,37 @@ class KnowledgeServiceImpl implements IKnowledgeService {
@Override @Override
public IPage<KnowledgeVO> queryPageList(KnowledgeParam knowledgeParam, Integer pageNo, Integer pageSize, String column, String order) { public IPage<KnowledgeVO> queryPageList(KnowledgeParam knowledgeParam, Integer pageNo, Integer pageSize, String column, String order) {
List<String> permitKnowList=new ArrayList<>(); List<String> permitKnowList = new ArrayList<>();
List<String> catList; List<String> catList;
List<String> treeList = knowledgeProjectService.getTreeListBy(knowledgeParam.getKnowledgeProjectId()) List<String> treeList = knowledgeProjectService.getTreeListBy(knowledgeParam.getKnowledgeProjectId())
.stream().map(KbKnowledgeProject::getId).collect(Collectors.toList()); .stream().map(KbKnowledgeProject::getId).collect(Collectors.toList());
//获取用户拥有的分类 //获取用户拥有的分类
KbAuthorizedUser userInfo = SpringContextUtils.getUserInfo(); KbAuthorizedUser userInfo = SpringContextUtils.getUserInfo();
if(null==userInfo){ if (null == userInfo) {
return null; return null;
} }
//查看全部且是非管理员的时候 //查看全部且是非管理员的时候
if((!Integer.valueOf("0").equals(userInfo.getIsAll()))&&knowledgeParam.getKnowledgeProjectId().equals("0")){ if ((!Integer.valueOf("0").equals(userInfo.getIsAll())) && knowledgeParam.getKnowledgeProjectId().equals("0")) {
List<KbAuthuserKnowledgeprojectMap> permitKnowProjectList=knowledgeProjectService.getKnowledgeProjectListByUserId(userInfo.getId()); List<KbAuthuserKnowledgeprojectMap> permitKnowProjectList = knowledgeProjectService.getKnowledgeProjectListByUserId(userInfo.getId());
//all permit //all permit
List<String > allPermitList=permitKnowProjectList.stream() List<String> allPermitList = permitKnowProjectList.stream()
.filter(item->item.getSign()==0) .filter(item -> item.getSign() == 0)
.map(KbAuthuserKnowledgeprojectMap::getKnowledgeProjectId) .map(KbAuthuserKnowledgeprojectMap::getKnowledgeProjectId)
.collect(Collectors.toList()); .collect(Collectors.toList());
//know permit //know permit
List<String > knowPermitList=permitKnowProjectList.stream() List<String> knowPermitList = permitKnowProjectList.stream()
.filter(item->item.getSign()==1) .filter(item -> item.getSign() == 1)
.map(KbAuthuserKnowledgeprojectMap::getKnowledgeProjectId) .map(KbAuthuserKnowledgeprojectMap::getKnowledgeProjectId)
.collect(Collectors.toList()); .collect(Collectors.toList());
if(!knowPermitList.isEmpty()){ if (!knowPermitList.isEmpty()) {
permitKnowList=knowledgeProjectService.getKnowledgeListByUserId(userInfo.getId(),knowPermitList); permitKnowList = knowledgeProjectService.getKnowledgeListByUserId(userInfo.getId(), knowPermitList);
} }
catList = (List<String>) CollectionUtils.intersection(treeList, allPermitList); catList = (List<String>) CollectionUtils.intersection(treeList, allPermitList);
}else { } else {
catList=treeList; catList = treeList;
} }
SearchRequest searchRequest = new SearchRequest(Constants.ES_DATA_FOR_KNOWLEDGE); SearchRequest searchRequest = new SearchRequest(Constants.ES_DATA_FOR_KNOWLEDGE);
SearchSourceBuilder searchSourceBuilder = new SearchSourceBuilder(); SearchSourceBuilder searchSourceBuilder = new SearchSourceBuilder();
...@@ -200,21 +200,18 @@ class KnowledgeServiceImpl implements IKnowledgeService { ...@@ -200,21 +200,18 @@ class KnowledgeServiceImpl implements IKnowledgeService {
//默认按照置顶以及时间倒序排列 //默认按照置顶以及时间倒序排列
//根据topNum正序查找,查询置顶数据 //根据topNum正序查找,查询置顶数据
searchSourceBuilder.sort("publishDate", SortOrder.DESC); searchSourceBuilder.sort("publishDate", SortOrder.DESC);
if ("score".equals(column)) { if ("publishDate".equals(column)) {
if ("asc".equals(order)) {
searchSourceBuilder.sort("score", SortOrder.ASC);
searchSourceBuilder.sort("publishDate", SortOrder.ASC);
} else if ("desc".equals(order)) {
searchSourceBuilder.sort("score", SortOrder.DESC);
searchSourceBuilder.sort("publishDate", SortOrder.DESC);
}
} else if ("publishDate".equals(column)) {
if ("desc".equals(order)) { if ("desc".equals(order)) {
searchSourceBuilder.sort("publishDate", SortOrder.DESC); searchSourceBuilder.sort("publishDate", SortOrder.DESC);
searchSourceBuilder.sort("score", SortOrder.DESC);
} else if ("asc".equals(order)) { } else if ("asc".equals(order)) {
searchSourceBuilder.sort("publishDate", SortOrder.ASC); searchSourceBuilder.sort("publishDate", SortOrder.ASC);
searchSourceBuilder.sort("score", SortOrder.ASC); }
}
if ("verifyTime".equals(column)) {
if ("desc".equals(order)) {
searchSourceBuilder.sort("verifyTime", SortOrder.DESC);
} else if ("asc".equals(order)) {
searchSourceBuilder.sort("verifyTime", SortOrder.ASC);
} }
} }
//默认最大数量是10000,设置为true后,显示准确数量 //默认最大数量是10000,设置为true后,显示准确数量
...@@ -280,7 +277,7 @@ class KnowledgeServiceImpl implements IKnowledgeService { ...@@ -280,7 +277,7 @@ class KnowledgeServiceImpl implements IKnowledgeService {
} }
if (StringUtils.isNotEmpty(knowledgeParam.getId())) { if (StringUtils.isNotEmpty(knowledgeParam.getId())) {
boolQuery.must(QueryBuilders.termsQuery("id",permitKnowList)); boolQuery.must(QueryBuilders.termsQuery("id", permitKnowList));
} }
if (!catList.isEmpty()) { if (!catList.isEmpty()) {
boolQuery.must(QueryBuilders.termsQuery("knowledgeProjectId", catList)); boolQuery.must(QueryBuilders.termsQuery("knowledgeProjectId", catList));
...@@ -301,7 +298,7 @@ class KnowledgeServiceImpl implements IKnowledgeService { ...@@ -301,7 +298,7 @@ class KnowledgeServiceImpl implements IKnowledgeService {
searchRequest.source(searchSourceBuilder); searchRequest.source(searchSourceBuilder);
SearchResponse searchResponse = null; SearchResponse searchResponse = null;
try { try {
searchResponse = client.search(searchRequest, RequestOptions.DEFAULT); searchResponse = client.search(searchRequest, RequestOptions.DEFAULT);
} catch (IOException e) { } catch (IOException e) {
e.printStackTrace(); e.printStackTrace();
} }
...@@ -327,29 +324,29 @@ class KnowledgeServiceImpl implements IKnowledgeService { ...@@ -327,29 +324,29 @@ class KnowledgeServiceImpl implements IKnowledgeService {
if (org.springframework.util.StringUtils.isEmpty(data)) { if (org.springframework.util.StringUtils.isEmpty(data)) {
List<String> treeList = knowledgeProjectService.getTreeListBy(knowledgeParam.getKnowledgeProjectId()) List<String> treeList = knowledgeProjectService.getTreeListBy(knowledgeParam.getKnowledgeProjectId())
.stream().map(KbKnowledgeProject::getId).collect(Collectors.toList()); .stream().map(KbKnowledgeProject::getId).collect(Collectors.toList());
List<String> permitKnowList=new ArrayList<>(); List<String> permitKnowList = new ArrayList<>();
List<String> catList=new ArrayList<>(); List<String> catList = new ArrayList<>();
KbAuthorizedUser userInfo = SpringContextUtils.getUserInfo(); KbAuthorizedUser userInfo = SpringContextUtils.getUserInfo();
if(null==userInfo){ if (null == userInfo) {
return null; return null;
} }
if(Integer.valueOf("0").equals(userInfo.getIsAll())){ if (Integer.valueOf("0").equals(userInfo.getIsAll())) {
List<KbAuthuserKnowledgeprojectMap> permitKnowProjectList=knowledgeProjectService.getKnowledgeProjectListByUserId(userInfo.getId()); List<KbAuthuserKnowledgeprojectMap> permitKnowProjectList = knowledgeProjectService.getKnowledgeProjectListByUserId(userInfo.getId());
//all permit //all permit
List<String > allPermitList=permitKnowProjectList.stream() List<String> allPermitList = permitKnowProjectList.stream()
.filter(item->item.getSign()==0) .filter(item -> item.getSign() == 0)
.map(KbAuthuserKnowledgeprojectMap::getKnowledgeProjectId) .map(KbAuthuserKnowledgeprojectMap::getKnowledgeProjectId)
.collect(Collectors.toList()); .collect(Collectors.toList());
//know permit //know permit
List<String > knowPermitList=permitKnowProjectList.stream() List<String> knowPermitList = permitKnowProjectList.stream()
.filter(item->item.getSign()==1) .filter(item -> item.getSign() == 1)
.map(KbAuthuserKnowledgeprojectMap::getKnowledgeProjectId) .map(KbAuthuserKnowledgeprojectMap::getKnowledgeProjectId)
.collect(Collectors.toList()); .collect(Collectors.toList());
permitKnowList=knowledgeProjectService.getKnowledgeListByUserId(userInfo.getId(),knowPermitList); permitKnowList = knowledgeProjectService.getKnowledgeListByUserId(userInfo.getId(), knowPermitList);
catList = (List<String>) CollectionUtils.intersection(treeList, allPermitList); catList = (List<String>) CollectionUtils.intersection(treeList, allPermitList);
}else { } else {
catList=treeList; catList = treeList;
} }
StringBuilder typeNames = new StringBuilder(); StringBuilder typeNames = new StringBuilder();
if (null != knowledgeParam.getTypeIds()) { if (null != knowledgeParam.getTypeIds()) {
for (String type : knowledgeParam.getTypeIds().split(",")) { for (String type : knowledgeParam.getTypeIds().split(",")) {
......
...@@ -46,7 +46,7 @@ mybatis-plus: ...@@ -46,7 +46,7 @@ mybatis-plus:
python: python:
intelligentQaUrl: http://116.63.179.212:7862/platform/chat intelligentQaUrl: http://116.63.179.212:7862/platform/chat
searchUrl: http://116.63.179.212:7862/platform/searchInfo searchUrl: http://116.63.179.212:7862/platform/searchInfo
deleteUrl: http://114.115.172.99:10013/platform/delete deleteUrl: http://116.63.179.212:7863/platform/delete
know: know:
thirdpartyurl: thirdpartyurl:
......
Markdown 格式
0%
您添加了 0 到此讨论。请谨慎行事。
请先完成此评论的编辑!
注册 或者 后发表评论