提交 2a810bca 作者: chenshiqiang

adjust logic

上级 18c0280b
...@@ -172,6 +172,12 @@ ...@@ -172,6 +172,12 @@
<version>1.1</version> <version>1.1</version>
</dependency> </dependency>
<dependency>
<groupId>org.jsoup</groupId>
<artifactId>jsoup</artifactId>
<version>1.14.3</version>
</dependency>
</dependencies> </dependencies>
<build> <build>
......
...@@ -31,16 +31,16 @@ public class KnowInterceptor implements HandlerInterceptor { ...@@ -31,16 +31,16 @@ public class KnowInterceptor implements HandlerInterceptor {
// 在请求处理之前进行调用(Controller方法调用之前) // 在请求处理之前进行调用(Controller方法调用之前)
// 返回true才会继续执行后续的Interceptor和Controller // 返回true才会继续执行后续的Interceptor和Controller
// 返回false则取消当前请求 // 返回false则取消当前请求
// String token = request.getHeader("X-Access-Token"); String token = request.getHeader("X-Access-Token");
//
// KbAuthorizedUserService userService = SpringContextUtils.getBean(KbAuthorizedUserService.class); KbAuthorizedUserService userService = SpringContextUtils.getBean(KbAuthorizedUserService.class);
// Result<?> result = userService.doCheckAndGetUser(token); Result<?> result = userService.doCheckAndGetUser(token);
// /**第三方用户验证未通过,直接拦截请求并返回提示*/ /**第三方用户验证未通过,直接拦截请求并返回提示*/
// if (!result.isSuccess()){ if (!result.isSuccess()){
// doRes(request,response); doRes(request,response);
// return false; return false;
// } }
// request.setAttribute(Constants.USER_INFO, JSONUtil.toJsonStr(result.getResult())); request.setAttribute(Constants.USER_INFO, JSONUtil.toJsonStr(result.getResult()));
return true; return true;
} }
......
...@@ -95,7 +95,6 @@ public class KnowledgeController { ...@@ -95,7 +95,6 @@ public class KnowledgeController {
@PostMapping(value = "/uploadKnowledge") @PostMapping(value = "/uploadKnowledge")
public Result<?> uploadKnowledge(HttpServletRequest request, Knowledge knowledge) { public Result<?> uploadKnowledge(HttpServletRequest request, Knowledge knowledge) {
MultipartHttpServletRequest multipartRequest = WebUtils.getNativeRequest(request, MultipartHttpServletRequest.class); MultipartHttpServletRequest multipartRequest = WebUtils.getNativeRequest(request, MultipartHttpServletRequest.class);
Map<String, MultipartFile> fileMap = multipartRequest.getFileMap(); Map<String, MultipartFile> fileMap = multipartRequest.getFileMap();
List<Result<KnowFile>> resultList = localFileService.upload(fileMap); List<Result<KnowFile>> resultList = localFileService.upload(fileMap);
if (null == resultList || resultList.isEmpty()) { if (null == resultList || resultList.isEmpty()) {
...@@ -148,7 +147,7 @@ public class KnowledgeController { ...@@ -148,7 +147,7 @@ public class KnowledgeController {
* @return * @return
*/ */
@PostMapping(value = "/IntelligentQa") @PostMapping(value = "/IntelligentQa")
public Result<?> intelligentQa(IntelligentQaParam intelligentQaParam) throws IOException { public Result<?> intelligentQa(@RequestBody IntelligentQaParam intelligentQaParam) throws IOException {
JSONObject params = new JSONObject(); JSONObject params = new JSONObject();
params.put("question", intelligentQaParam.getQuestion()); params.put("question", intelligentQaParam.getQuestion());
params.put("knowledge_base_id", intelligentQaParam.getKbKnowledgeIds().split(",")); params.put("knowledge_base_id", intelligentQaParam.getKbKnowledgeIds().split(","));
......
...@@ -73,7 +73,7 @@ public class Knowledge implements Serializable { ...@@ -73,7 +73,7 @@ public class Knowledge implements Serializable {
/** /**
* 作者 * 作者
*/ */
private Integer author; private String author;
/** /**
* 发布时间 * 发布时间
*/ */
......
...@@ -154,7 +154,7 @@ public class KbKnowledgeProjectServiceImpl extends ServiceImpl<KbKnowledgeProjec ...@@ -154,7 +154,7 @@ public class KbKnowledgeProjectServiceImpl extends ServiceImpl<KbKnowledgeProjec
@Override @Override
public List<KbKnowledgeProject> getTreeListBy(String id) { public List<KbKnowledgeProject> getTreeListBy(String id) {
return baseMapper.selectList(new LambdaQueryWrapper<KbKnowledgeProject>() return baseMapper.selectList(new LambdaQueryWrapper<KbKnowledgeProject>()
.like(KbKnowledgeProject::getFullPath, id) .like(!"0".equals(id),KbKnowledgeProject::getFullPath, id)
); );
} }
......
...@@ -30,6 +30,7 @@ import org.elasticsearch.index.query.QueryBuilders; ...@@ -30,6 +30,7 @@ import org.elasticsearch.index.query.QueryBuilders;
import org.elasticsearch.search.SearchHit; import org.elasticsearch.search.SearchHit;
import org.elasticsearch.search.builder.SearchSourceBuilder; import org.elasticsearch.search.builder.SearchSourceBuilder;
import org.elasticsearch.search.sort.SortOrder; import org.elasticsearch.search.sort.SortOrder;
import org.jsoup.Jsoup;
import org.springframework.beans.BeanUtils; import org.springframework.beans.BeanUtils;
import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Value; import org.springframework.beans.factory.annotation.Value;
...@@ -70,6 +71,8 @@ class KnowledgeServiceImpl implements IKnowledgeService { ...@@ -70,6 +71,8 @@ class KnowledgeServiceImpl implements IKnowledgeService {
@Override @Override
public void addKnowledge(KnowFile knowFile, Knowledge knowledge) { public void addKnowledge(KnowFile knowFile, Knowledge knowledge) {
KbAuthorizedUser userInfo = SpringContextUtils.getUserInfo();
knowledge.setAuthor(userInfo.getName());
if (null == knowledge.getId()) { if (null == knowledge.getId()) {
knowledge.setId(codeGenerateUtil.geneIdNo(Constants.FINANCE, 8)); knowledge.setId(codeGenerateUtil.geneIdNo(Constants.FINANCE, 8));
} }
...@@ -123,7 +126,7 @@ class KnowledgeServiceImpl implements IKnowledgeService { ...@@ -123,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(item.getContent().replaceAll("<[^>]`>", ""))); messageContentList.forEach(item->item.setContent(Jsoup.parse(item.getContent()).text()));
knowledgeMessage.setContents(messageContentList); knowledgeMessage.setContents(messageContentList);
produceInfo.sendKnowledgeContents(knowledgeMessage); produceInfo.sendKnowledgeContents(knowledgeMessage);
} }
...@@ -156,11 +159,15 @@ class KnowledgeServiceImpl implements IKnowledgeService { ...@@ -156,11 +159,15 @@ 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> 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());
//获取用户拥有的分类 if(false){
//获取用户拥有的分类
KbAuthorizedUser userInfo = SpringContextUtils.getUserInfo(); KbAuthorizedUser userInfo = SpringContextUtils.getUserInfo();
userInfo.setId("chenshiqiang");
if(null==userInfo){ if(null==userInfo){
return null; return null;
} }
...@@ -175,9 +182,15 @@ class KnowledgeServiceImpl implements IKnowledgeService { ...@@ -175,9 +182,15 @@ class KnowledgeServiceImpl implements IKnowledgeService {
.filter(item->item.getSign()==1) .filter(item->item.getSign()==1)
.map(KbAuthuserKnowledgeprojectMap::getKnowledgeProjectId) .map(KbAuthuserKnowledgeprojectMap::getKnowledgeProjectId)
.collect(Collectors.toList()); .collect(Collectors.toList());
List<String> permitKnowList=knowledgeProjectService.getKnowledgeListByUserId(userInfo.getId(),knowPermitList);
Collection<Serializable> catList = CollectionUtils.intersection(treeList, allPermitList);
if(!knowPermitList.isEmpty()){
permitKnowList=knowledgeProjectService.getKnowledgeListByUserId(userInfo.getId(),knowPermitList);
}
catList = (List<String>) CollectionUtils.intersection(treeList, allPermitList);
}else {
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();
...@@ -282,11 +295,8 @@ class KnowledgeServiceImpl implements IKnowledgeService { ...@@ -282,11 +295,8 @@ class KnowledgeServiceImpl implements IKnowledgeService {
} }
if (StringUtils.isNotBlank(knowledgeParam.getEndTime())) { if (StringUtils.isNotBlank(knowledgeParam.getEndTime())) {
boolQuery.filter(QueryBuilders.rangeQuery("publishDate").lte(EsDateUtil.esFieldDateFormat(knowledgeParam.getEndTime()))); boolQuery.filter(QueryBuilders.rangeQuery("publishDate").lte(EsDateUtil.esFieldDateFormat(knowledgeParam.getEndTime())));
} else {
boolQuery.filter(QueryBuilders.rangeQuery("publishDate").lte(EsDateUtil.esFieldDateFormat(DateUtil.dateToString(new Date()))));
} }
searchSourceBuilder.query(boolQuery); searchSourceBuilder.query(boolQuery);
searchRequest.source(searchSourceBuilder); searchRequest.source(searchSourceBuilder);
SearchResponse searchResponse = null; SearchResponse searchResponse = null;
...@@ -318,9 +328,11 @@ class KnowledgeServiceImpl implements IKnowledgeService { ...@@ -318,9 +328,11 @@ class KnowledgeServiceImpl implements IKnowledgeService {
if (true) { if (true) {
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> catList=new ArrayList<>();
if(false){
//获取用户拥有的分类 //获取用户拥有的分类
KbAuthorizedUser userInfo = SpringContextUtils.getUserInfo(); KbAuthorizedUser userInfo = SpringContextUtils.getUserInfo();
userInfo.setId("chenshiqiang");
if(null==userInfo){ if(null==userInfo){
return null; return null;
} }
...@@ -335,8 +347,11 @@ class KnowledgeServiceImpl implements IKnowledgeService { ...@@ -335,8 +347,11 @@ class KnowledgeServiceImpl implements IKnowledgeService {
.filter(item->item.getSign()==1) .filter(item->item.getSign()==1)
.map(KbAuthuserKnowledgeprojectMap::getKnowledgeProjectId) .map(KbAuthuserKnowledgeprojectMap::getKnowledgeProjectId)
.collect(Collectors.toList()); .collect(Collectors.toList());
List<String> permitKnowList=knowledgeProjectService.getKnowledgeListByUserId(userInfo.getId(),knowPermitList); permitKnowList=knowledgeProjectService.getKnowledgeListByUserId(userInfo.getId(),knowPermitList);
Collection<Serializable> catList = CollectionUtils.intersection(treeList, allPermitList); catList = (List<String>) CollectionUtils.intersection(treeList, allPermitList);
}else {
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(",")) {
......
...@@ -29,6 +29,7 @@ public class KnowledgeVO { ...@@ -29,6 +29,7 @@ public class KnowledgeVO {
private String kbKnowledgeId; private String kbKnowledgeId;
private String type; private String type;
private String verifierName; private String verifierName;
private String author;
private Integer score; private Integer score;
private Integer verifyStatus; private Integer verifyStatus;
private List<Content> contents; private List<Content> contents;
......
...@@ -47,8 +47,8 @@ python: ...@@ -47,8 +47,8 @@ python:
know: know:
thirdpartyurl: thirdpartyurl:
checkuserurl: http://127.0.0.1:9988/sys/checkToken checkuserurl: http://192.168.1.146:9988/sys/checkToken
getusersurl: http://127.0.0.1:9988/sys/user/thirdparty getusersurl: http://192.168.1.146:9988/sys/user/thirdparty
document: document:
server: server:
......
...@@ -3,6 +3,7 @@ package com.zzsn.knowbase; ...@@ -3,6 +3,7 @@ package com.zzsn.knowbase;
import com.zzsn.knowbase.constant.Constants; import com.zzsn.knowbase.constant.Constants;
import com.zzsn.knowbase.service.ILocalFileService; import com.zzsn.knowbase.service.ILocalFileService;
import com.zzsn.knowbase.util.CodeGenerateUtil; import com.zzsn.knowbase.util.CodeGenerateUtil;
import org.jsoup.Jsoup;
import org.junit.jupiter.api.Test; import org.junit.jupiter.api.Test;
import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.test.context.SpringBootTest; import org.springframework.boot.test.context.SpringBootTest;
...@@ -29,4 +30,11 @@ class KnowBaseApplicationTests { ...@@ -29,4 +30,11 @@ class KnowBaseApplicationTests {
} }
@Test
void format() {
String source = "<a id=\\\"_Toc7881\\\"></a><a id=\\\"_Toc20510\\\"></a><a id=\\\"_Toc1184\\\"></a>引言";
System.out.println();
}
} }
Markdown 格式
0%
您添加了 0 到此讨论。请谨慎行事。
请先完成此评论的编辑!
注册 或者 后发表评论