From 8f5cb469b825cce61734c84fd633f0dfc3000ee6 Mon Sep 17 00:00:00 2001
From: guyue <1721849008@qq.com>
Date: 星期二, 08 七月 2025 18:50:01 +0800
Subject: [PATCH] 第三方接口请求数据完成
---
src/main/java/com/linghu/service/impl/KeywordServiceImpl.java | 63 +++++++++++++++++++++----------
1 files changed, 42 insertions(+), 21 deletions(-)
diff --git a/src/main/java/com/linghu/service/impl/KeywordServiceImpl.java b/src/main/java/com/linghu/service/impl/KeywordServiceImpl.java
index 568e27b..b849f0e 100644
--- a/src/main/java/com/linghu/service/impl/KeywordServiceImpl.java
+++ b/src/main/java/com/linghu/service/impl/KeywordServiceImpl.java
@@ -9,73 +9,76 @@
import com.linghu.service.KeywordService;
import com.linghu.mapper.KeywordMapper;
-
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
+import org.springframework.util.StringUtils;
+import java.util.ArrayList;
import java.util.List;
import java.util.Map;
/**
-* @author xy
-* @description 针对表【keyword】的数据库操作Service实现
-* @createDate 2025-07-04 20:17:33
-*/
+ * @author xy
+ * @description 针对表【keyword】的数据库操作Service实现
+ * @createDate 2025-07-04 20:17:33
+ */
@Service
-public class KeywordServiceImpl extends ServiceImpl<KeywordMapper, Keyword> implements KeywordService{
+public class KeywordServiceImpl extends ServiceImpl<KeywordMapper, Keyword> implements KeywordService {
@Autowired
private KeywordMapper keywordMapper;
@Override
public ResponseResult<KeywordStaticsListVO> statics(Integer keywordId, Integer questionId) {
KeywordStaticsListVO vo = new KeywordStaticsListVO();
- //1.关键词是否存在
+ // 1.关键词是否存在
Keyword keyword = this.getById(keywordId);
if (keyword == null) {
return ResponseResult.error("关键词不存在");
}
- if (!"completed".equals(keyword.getStatus())){
+ if (!"completed".equals(keyword.getStatus())) {
return ResponseResult.error("关键词采集未完成");
}
- List<KeywordStaticsVO> statics = this.getBaseMapper().statics(keywordId,questionId,keyword.getNum());
+ List<KeywordStaticsVO> statics = this.getBaseMapper().statics(keywordId, questionId, keyword.getNum());
vo.setNowRecord(statics);
- if (keyword.getNum()!=0){
- statics = this.getBaseMapper().statics(keywordId,questionId,keyword.getNum()-1);
+ if (keyword.getNum() != 0) {
+ statics = this.getBaseMapper().statics(keywordId, questionId, keyword.getNum() - 1);
vo.setBeforeRecord(statics);
}
return ResponseResult.success(vo);
}
@Override
- public ResponseResult<List<PlatformProportionVO>> getResultByTypeId(Integer keywordId, Integer questionId, Integer typeId) {
- //1.关键词是否存在
+ public ResponseResult<List<PlatformProportionVO>> getResultByTypeId(Integer keywordId, Integer questionId,
+ Integer typeId) {
+ // 1.关键词是否存在
Keyword keyword = this.getById(keywordId);
if (keyword == null) {
return ResponseResult.error("关键词不存在");
}
- if (!"completed".equals(keyword.getStatus())){
+ if (!"completed".equals(keyword.getStatus())) {
return ResponseResult.error("关键词采集未完成");
}
- List<PlatformProportionVO> result = this.getBaseMapper().getResultByTypeId(keywordId, questionId, keyword.getNum(), typeId);
+ List<PlatformProportionVO> result = this.getBaseMapper().getResultByTypeId(keywordId, questionId,
+ keyword.getNum(), typeId);
return ResponseResult.success(result);
}
@Override
- public ResponseResult<List<ResultListVO>> getResultByPlatformId(Integer keywordId, Integer questionId, Integer platformId) {
- //1.关键词是否存在
+ public ResponseResult<List<ResultListVO>> getResultByPlatformId(Integer keywordId, Integer questionId,
+ Integer platformId) {
+ // 1.关键词是否存在
Keyword keyword = this.getById(keywordId);
if (keyword == null) {
return ResponseResult.error("关键词不存在");
}
- if (!"completed".equals(keyword.getStatus())){
+ if (!"completed".equals(keyword.getStatus())) {
return ResponseResult.error("关键词采集未完成");
}
- List<ResultListVO> result = this.getBaseMapper().getResultByPlatformId(keywordId, questionId, keyword.getNum(), platformId);
+ List<ResultListVO> result = this.getBaseMapper().getResultByPlatformId(keywordId, questionId, keyword.getNum(),
+ platformId);
return ResponseResult.success(result);
}
-
-
@Override
public List<Keyword> getKeywordsByOrderId(String orderId) {
@@ -84,4 +87,22 @@
return keywordMapper.selectList(queryWrapper);
}
+ @Override
+ public Boolean saveKeywords(String keywords, String order_id) {
+ if (StringUtils.hasText(keywords)) {
+ List<Keyword> keywordList = new ArrayList<>();
+ String[] keywordArray = keywords.split("\\n");
+ for (String keyword : keywordArray) {
+ Keyword newKeyword = new Keyword();
+ newKeyword.setKeyword_name(keyword);
+ newKeyword.setOrder_id(order_id);
+ newKeyword.setStatus("notSubmitted");
+ keywordList.add(newKeyword);
+ }
+ return this.saveBatch(keywordList);
+ }else {
+ return false;
+ }
+ }
+
}
--
Gitblit v1.7.1