From e285517df2a3cb206282a41f958c80044422a552 Mon Sep 17 00:00:00 2001
From: guyue <1721849008@qq.com>
Date: 星期一, 07 七月 2025 17:51:35 +0800
Subject: [PATCH] 基本增删改
---
src/main/resources/mapper/OrderMapper.xml | 14
src/main/java/com/linghu/model/entity/Platform.java | 133 ++
src/main/java/com/linghu/service/PlatformExcelService.java | 86 +
src/main/resources/mapper/ReferenceMapper.xml | 26
src/main/java/com/linghu/service/PlatformService.java | 13
src/main/java/com/linghu/service/QuestionService.java | 13
src/main/java/com/linghu/config/Swagger2Config.java | 68 +
src/main/java/com/linghu/service/ReferenceService.java | 13
src/main/java/com/linghu/mapper/PlatformMapper.java | 14
src/main/resources/sql/keyword.sql | 12
src/main/java/com/linghu/model/entity/Question.java | 133 ++
src/main/java/com/linghu/mapper/TypeMapper.java | 4
src/main/java/com/linghu/model/dto/OrderDto.java | 17
src/main/resources/sql/reference.sql | 17
src/main/java/com/linghu/service/OrderService.java | 17
src/main/java/com/linghu/model/entity/User.java | 104 ++
src/main/java/com/linghu/model/dto/KeywordDto.java | 14
src/main/java/com/linghu/service/TypeService.java | 33
src/main/java/com/linghu/mapper/KeywordMapper.java | 4
src/main/java/com/linghu/service/impl/ReferenceServiceImpl.java | 22
src/main/java/com/linghu/config/WebClientConfig.java | 17
src/main/java/com/linghu/model/dto/SearchTaskResponse.java | 11
src/main/java/com/linghu/controller/QuestionController.java | 112 ++
src/main/java/com/linghu/mapper/UserMapper.java | 18
src/main/java/com/linghu/controller/CollectController.java | 295 ++++++
src/main/java/com/linghu/model/dto/TaskStatusResponse.java | 34
src/main/java/com/linghu/model/entity/Keyword.java | 42
src/main/java/com/linghu/utils/JwtUtils.java | 86 +
src/main/java/com/linghu/mapper/OrderMapper.java | 4
src/main/java/com/linghu/service/UserService.java | 13
src/main/java/com/linghu/model/excel/PlatformExcel.java | 16
src/main/resources/sql/question.sql | 14
src/main/java/com/linghu/controller/TypeController.java | 60
src/main/resources/mapper/QuestionMapper.xml | 26
src/main/java/com/linghu/mapper/QuestionMapper.java | 18
src/main/java/com/linghu/service/impl/PlatformServiceImpl.java | 18
src/main/resources/schema.sql | 42
src/main/resources/mapper/TypeMapper.xml | 6
src/main/java/com/linghu/service/impl/KeywordServiceImpl.java | 2
pom.xml | 33
src/main/resources/mapper/UserMapper.xml | 19
src/main/java/com/linghu/model/entity/Reference.java | 165 +++
src/main/java/com/linghu/service/impl/UserServiceImpl.java | 22
src/main/java/com/linghu/mapper/ReferenceMapper.java | 18
src/main/java/com/linghu/model/dto/TaskCancelResponse.java | 16
src/main/java/com/linghu/service/impl/TypeServiceImpl.java | 40
src/main/java/com/linghu/model/dto/TaskResultResponse.java | 53 +
src/main/resources/mapper/PlatformMapper.xml | 24
src/main/java/com/linghu/service/KeywordService.java | 2
src/main/java/com/linghu/model/entity/Order.java | 59
src/main/java/com/linghu/controller/PlatformController.java | 192 ++++
/dev/null | 23
src/main/java/com/linghu/model/dto/SearchTaskRequest.java | 37
src/main/java/com/linghu/model/entity/Type.java | 86
src/main/java/com/linghu/service/impl/QuestionServiceImpl.java | 22
src/main/resources/mapper/keywordMapper.xml | 20
src/main/java/com/linghu/controller/AuthController.java | 46 +
src/main/java/com/linghu/controller/OrderController.java | 157 +++
src/main/java/com/linghu/service/impl/OrderServiceImpl.java | 84 +
src/main/resources/application.yml | 17
60 files changed, 2,494 insertions(+), 232 deletions(-)
diff --git a/pom.xml b/pom.xml
index 5d46808..44aab22 100644
--- a/pom.xml
+++ b/pom.xml
@@ -52,6 +52,39 @@
<artifactId>springfox-swagger-ui</artifactId>
<version>2.9.2</version>
</dependency>
+
+ <!-- EasyExcel依赖 -->
+ <dependency>
+ <groupId>com.alibaba</groupId>
+ <artifactId>easyexcel</artifactId>
+ <version>3.3.2</version>
+ </dependency>
+ <dependency>
+ <groupId>io.jsonwebtoken</groupId>
+ <artifactId>jjwt-api</artifactId>
+ <version>0.12.5</version>
+ </dependency>
+ <dependency>
+ <groupId>io.jsonwebtoken</groupId>
+ <artifactId>jjwt-impl</artifactId>
+ <version>0.12.5</version>
+
+ </dependency>
+ <dependency>
+ <groupId>io.jsonwebtoken</groupId>
+ <artifactId>jjwt-jackson</artifactId> <!-- 或 jjwt-gson -->
+ <version>0.12.5</version>
+
+ </dependency>
+ <dependency>
+ <groupId>org.springframework.boot</groupId>
+ <artifactId>spring-boot-starter-validation</artifactId>
+ </dependency>
+ <dependency>
+ <groupId>org.springframework.boot</groupId>
+ <artifactId>spring-boot-starter-webflux</artifactId>
+ </dependency>
+
</dependencies>
<dependencyManagement>
<dependencies>
diff --git a/src/main/java/com/linghu/config/Swagger2Config.java b/src/main/java/com/linghu/config/Swagger2Config.java
index 9ec9da2..8bd9361 100644
--- a/src/main/java/com/linghu/config/Swagger2Config.java
+++ b/src/main/java/com/linghu/config/Swagger2Config.java
@@ -5,14 +5,25 @@
import springfox.documentation.builders.ApiInfoBuilder;
import springfox.documentation.builders.PathSelectors;
import springfox.documentation.builders.RequestHandlerSelectors;
+import springfox.documentation.builders.ParameterBuilder;
+import springfox.documentation.schema.ModelRef;
import springfox.documentation.service.ApiInfo;
+import springfox.documentation.service.ApiKey;
+import springfox.documentation.service.AuthorizationScope;
import springfox.documentation.service.Contact;
+import springfox.documentation.service.Parameter;
+import springfox.documentation.service.SecurityReference;
import springfox.documentation.spi.DocumentationType;
+import springfox.documentation.spi.service.contexts.SecurityContext;
import springfox.documentation.spring.web.plugins.Docket;
import springfox.documentation.swagger2.annotations.EnableSwagger2;
+import java.util.ArrayList;
+import java.util.Arrays;
+import java.util.List;
+
@Configuration
-@EnableSwagger2 // 开启Swagger2
+@EnableSwagger2 // 开启Swagger2
public class Swagger2Config {
/**
@@ -29,18 +40,65 @@
.apis(RequestHandlerSelectors.basePackage("com.linghu.controller"))
// 匹配所有路径
.paths(PathSelectors.any())
+ .build()
+ // 添加安全方案配置
+ .securitySchemes(Arrays.asList(securityScheme()))
+ .securityContexts(Arrays.asList(securityContext()))
+ // 添加全局参数（header中的token参数）
+ .globalOperationParameters(globalParameters());
+ }
+
+ /**
+ * 配置JWT安全方案
+ */
+ private ApiKey securityScheme() {
+ return new ApiKey("BearerToken", "Authorization", "header");
+ }
+
+ /**
+ * 配置安全上下文
+ */
+ private SecurityContext securityContext() {
+ return SecurityContext.builder()
+ .securityReferences(defaultAuth())
+ .forPaths(PathSelectors.any())
.build();
}
/**
+ * 默认的安全引用
+ */
+ private List<SecurityReference> defaultAuth() {
+ AuthorizationScope authorizationScope = new AuthorizationScope("global", "accessEverything");
+ AuthorizationScope[] authorizationScopes = new AuthorizationScope[1];
+ authorizationScopes[0] = authorizationScope;
+ return Arrays.asList(new SecurityReference("BearerToken", authorizationScopes));
+ }
+
+ /**
+ * 配置全局参数
+ */
+ private List<Parameter> globalParameters() {
+ List<Parameter> parameters = new ArrayList<>();
+ parameters.add(new ParameterBuilder()
+ .name("Authorization")
+ .description("JWT Token (格式: Bearer [token])")
+ .modelRef(new ModelRef("string"))
+ .parameterType("header")
+ .required(false)
+ .build());
+ return parameters;
+ }
+
+ /**
+ * http://127.0.0.1:8080/swagger-ui.html
* 配置API文档基本信息（标题、描述、作者等）
*/
private ApiInfo apiInfo() {
return new ApiInfoBuilder()
- .title("灵狐GEO系统 接口文档") // 文档标题
- .description("使用 Swagger2 生成的API文档") // 文档描述
- .version("1.0.0") // 版本号
-
+ .title("灵狐GEO系统 接口文档") // 文档标题
+ .description("使用 Swagger2 生成的API文档") // 文档描述
+ .version("1.0.0") // 版本号
.build();
}
}
\ No newline at end of file
diff --git a/src/main/java/com/linghu/config/WebClientConfig.java b/src/main/java/com/linghu/config/WebClientConfig.java
new file mode 100644
index 0000000..0e483fe
--- /dev/null
+++ b/src/main/java/com/linghu/config/WebClientConfig.java
@@ -0,0 +1,17 @@
+package com.linghu.config;
+
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+import org.springframework.web.reactive.function.client.WebClient;
+
+@Configuration
+public class WebClientConfig {
+ @Value("${linghu.url}")
+ private String baseUrl;
+
+ @Bean
+ public WebClient webClient() {
+ return WebClient.create(baseUrl);
+ }
+}
\ No newline at end of file
diff --git a/src/main/java/com/linghu/controller/AuthController.java b/src/main/java/com/linghu/controller/AuthController.java
new file mode 100644
index 0000000..ab7b110
--- /dev/null
+++ b/src/main/java/com/linghu/controller/AuthController.java
@@ -0,0 +1,46 @@
+package com.linghu.controller;
+
+import java.util.HashMap;
+import java.util.Map;
+
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.http.ResponseEntity;
+import org.springframework.web.bind.annotation.PostMapping;
+import org.springframework.web.bind.annotation.RequestBody;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RequestParam;
+import org.springframework.web.bind.annotation.RestController;
+
+import com.linghu.model.entity.User;
+import com.linghu.utils.JwtUtils;
+
+@RestController
+@RequestMapping("/auth")
+public class AuthController {
+ @Value("${jwt.secret}")
+ private String secretKey;
+
+ @PostMapping("/login")
+ public ResponseEntity<?> externalLogin(
+ @RequestBody User user) {
+
+ // 生成JWT令牌
+ JwtUtils jwtUtils = new JwtUtils(secretKey, 3600);
+ String token = jwtUtils.generateToken(user);
+
+ Map<String, String> response = new HashMap<>();
+ response.put("token", token);
+ // 返回JWT令牌
+ return ResponseEntity.ok(response);
+ }
+
+ // 获取用户信息
+ @PostMapping("/getUserInfo")
+ public ResponseEntity<?> getUserInfo(@RequestParam String token) {
+ // 解析JWT令牌，获取用户信息
+ JwtUtils jwtUtils = new JwtUtils(secretKey, 3600);
+ User user = jwtUtils.parseToken(token);
+ // 返回用户信息
+ return ResponseEntity.ok(user);
+ }
+}
\ No newline at end of file
diff --git a/src/main/java/com/linghu/controller/CollectController.java b/src/main/java/com/linghu/controller/CollectController.java
new file mode 100644
index 0000000..323f987
--- /dev/null
+++ b/src/main/java/com/linghu/controller/CollectController.java
@@ -0,0 +1,295 @@
+package com.linghu.controller;
+
+import java.time.LocalDateTime;
+import java.util.ArrayList;
+import java.util.Date;
+import java.util.List;
+import java.util.Map;
+import java.util.stream.Collectors;
+
+import javax.servlet.http.HttpServletRequest;
+
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.core.ParameterizedTypeReference;
+import org.springframework.http.*;
+import org.springframework.web.client.RestTemplate;
+import org.springframework.web.reactive.function.client.WebClient;
+import org.springframework.http.client.HttpComponentsClientHttpRequestFactory;
+
+import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper;
+import com.linghu.model.common.ResponseResult;
+import com.linghu.model.dto.SearchTaskRequest;
+import com.linghu.model.entity.Keyword;
+import com.linghu.model.entity.Question;
+import com.linghu.model.entity.User;
+import com.linghu.service.KeywordService;
+import com.linghu.service.QuestionService;
+import com.linghu.service.ReferenceService;
+import com.linghu.utils.JwtUtils;
+import com.linghu.model.dto.SearchTaskResponse;
+import com.linghu.model.dto.TaskStatusResponse;
+import com.linghu.model.dto.TaskCancelResponse;
+
+import io.jsonwebtoken.lang.Collections;
+import io.swagger.annotations.Api;
+import io.swagger.annotations.ApiOperation;
+import reactor.core.publisher.Mono;
+
+import org.springframework.web.bind.annotation.*;
+import org.springframework.http.HttpStatus;
+import com.linghu.model.dto.TaskResultResponse;
+import com.linghu.model.dto.TaskResultResponse.QuestionResult;
+import com.linghu.model.dto.TaskResultResponse.UserResult;
+import com.linghu.model.entity.Reference;
+import java.util.stream.Collectors;
+
+@RestController
+@RequestMapping("/collect")
+@Api(value = "采集接口", tags = "采集管理")
+public class CollectController {
+
+ @Autowired
+ private ReferenceService referenceService;
+
+ @Value("${linghu.url}")
+ private String baseUrl;
+
+ @Autowired
+ private WebClient webClient;
+
+ @Autowired
+ private JwtUtils jwtUtils;
+ @Autowired
+ private KeywordService keywordService;
+ @Autowired
+ private QuestionService questionService;
+
+ @PostMapping("/search")
+ @ApiOperation(value = "开始采集")
+ public Mono<ResponseResult<SearchTaskResponse>> createSearchTask(
+ @RequestBody SearchTaskRequest searchTaskRequest,
+ HttpServletRequest request) {
+ String token = request.getHeader("Authorization");
+ User user = jwtUtils.parseToken(token);
+ List<User> users = new ArrayList<>();
+ users.add(user);
+ searchTaskRequest.setUsers(users);
+
+ return webClient.post()
+ .uri(baseUrl + "/search")
+ .contentType(MediaType.APPLICATION_JSON)
+ .bodyValue(searchTaskRequest)
+ .retrieve()
+ .bodyToMono(new ParameterizedTypeReference<ResponseResult<SearchTaskResponse>>() {
+ })
+ .flatMap(responseResult -> {
+ // 提取任务ID
+ SearchTaskResponse taskResponse = responseResult.getData();
+ if (taskResponse != null && taskResponse.getTask_id() != null) {
+ // 保存任务ID到关键词
+ LambdaUpdateWrapper<Keyword> updateWrapper = new LambdaUpdateWrapper<>();
+ updateWrapper.eq(Keyword::getKeyword_id, searchTaskRequest.getKeyword_id());
+ updateWrapper.set(Keyword::getTask_id, taskResponse.getTask_id());
+ keywordService.update(updateWrapper);
+ // 可选：更新响应中的其他信息
+ // taskResponse.setMessage("任务已提交并保存，ID: " + taskResponse.getTaskId());
+ }
+ return Mono.just(responseResult);
+ })
+ .onErrorResume(e -> {
+ return Mono.just(ResponseResult.error("调用失败: " + e.getMessage()));
+ });
+ }
+
+ @ApiOperation(value = "查询任务状态")
+ @GetMapping("/status")
+ public Mono<TaskStatusResponse> getTaskStatus(String taskId) {
+ return webClient.get()
+ .uri(baseUrl + "/tasks/" + taskId)
+ .accept(MediaType.APPLICATION_JSON)
+ .retrieve()
+ .onStatus(HttpStatus::is4xxClientError, response -> response.bodyToMono(String.class)
+ .flatMap(errorBody -> Mono.error(new RuntimeException("任务不存在: " + errorBody))))
+ .bodyToMono(TaskStatusResponse.class)
+ .flatMap(result -> {
+ TaskStatusResponse taskStatusResponse = result;
+ if (taskStatusResponse != null && taskStatusResponse.getStatus() != null) {
+ List<Question> updateQuestions = taskStatusResponse.getQuestions_status().stream()
+ .map(qs -> {
+ Question question = new Question();
+ question.setQuestion_id(qs.getQuestion_id());
+ question.setStatus(qs.getStatus());
+ return question;
+ }).collect(Collectors.toList());
+
+ questionService.updateBatchById(updateQuestions);
+ }
+ return Mono.just(result);
+ });
+ }
+
+ @PostMapping("/cancel/{taskId}")
+ @ApiOperation(value = "取消任务")
+ public Mono<ResponseResult<TaskCancelResponse>> cancelTask(@PathVariable String taskId) {
+ return webClient.post()
+ .uri(baseUrl + "/tasks/" + taskId + "/cancel")
+ .contentType(MediaType.APPLICATION_JSON)
+ .bodyValue(Collections.emptyMap()) // 添加空请求体
+ .retrieve()
+ .onStatus(HttpStatus::isError, response -> {
+ if (response.statusCode() == HttpStatus.NOT_FOUND) {
+ return response.bodyToMono(String.class)
+ .flatMap(errorBody -> Mono.error(new RuntimeException("任务不存在")));
+ } else if (response.statusCode() == HttpStatus.BAD_REQUEST) {
+ return response.bodyToMono(String.class)
+ .flatMap(errorBody -> Mono.error(new RuntimeException("任务已经完成，无法取消")));
+ }
+ return response.createException().flatMap(Mono::error);
+ })
+ .bodyToMono(TaskCancelResponse.class)
+ .map(data -> ResponseResult.success(data))
+ .onErrorResume(e -> {
+ if (e.getMessage().contains("任务不存在")) {
+ return Mono.just(ResponseResult.error(404, "任务不存在"));
+ } else if (e.getMessage().contains("无法取消")) {
+ return Mono.just(ResponseResult.error(400, "任务已完成，无法取消"));
+ }
+ return Mono.just(ResponseResult.error(500, "取消任务失败: " + e.getMessage()));
+ });
+ }
+ // @ApiOperation(value = "获取任务结果")
+ // @GetMapping("/tasks/{taskId}/result")
+ // public Mono<ResponseResult<TaskResultResponse>> getTaskResult(@PathVariable
+ // String taskId) {
+ // return webClient.get()
+ // .uri(baseUrl + "/tasks/" + taskId + "/result")
+ // .retrieve()
+ // .onStatus(HttpStatus::isError, response -> response.bodyToMono(String.class)
+ // .flatMap(errorBody -> Mono.error(new RuntimeException("获取结果失败: " +
+ // errorBody))))
+ // .bodyToMono(TaskResultResponse.class)
+ // .flatMap(result -> {
+ // // 更新keyword状态
+ // LambdaUpdateWrapper<Keyword> keywordWrapper = new LambdaUpdateWrapper<>();
+ // keywordWrapper.eq(Keyword::getTask_id, taskId)
+ // .set(Keyword::getStatus, "completed");
+ // keywordService.update(keywordWrapper);
+
+ // // 更新question信息并收集references
+ // List<Question> updateQuestions = new ArrayList<>();
+ // List<Reference> references = new ArrayList<>();
+
+ // result.getResults().forEach(userResult -> {
+ // userResult.getQuestions_results().forEach(qResult -> {
+ // Question question = new Question();
+ // question.setQuestion_id(qResult.getQuestion_id());
+ // question.setResponse(qResult.getResponse());
+ // question.setStatus(qResult.getStatus());
+ // updateQuestions.add(question);
+
+ // // 转换references
+ // references.addAll(qResult.getReferences().stream()
+ // .map(ref -> new Reference(
+ // qResult.getQuestion_id(),
+ // ref.getTitle(),
+ // ref.getUrl(),
+ // ref.getDomain(),
+ // result.getTask_id(),
+ // ))
+ // .collect(Collectors.toList()));
+ // });
+ // });
+
+ // // 批量更新和插入
+ // if (!updateQuestions.isEmpty()) {
+ // questionService.updateBatchById(updateQuestions);
+ // }
+ // if (!references.isEmpty()) {
+ // referenceService.saveBatch(references);
+ // }
+
+ // return Mono.just(ResponseResult.success(result));
+ // })
+ // .onErrorResume(e -> Mono.just(ResponseResult.error(e.getMessage())));
+ // }
+
+ // @ApiOperation(value = "获取任务结果")
+ // @GetMapping("/tasks/{taskId}/result")
+ // public Mono<ResponseResult<TaskResultResponse>>
+ // getTaskResultlMono(@PathVariable String taskId) {
+ // return webClient.get()
+ // .uri(baseUrl + "/tasks/" + taskId + "/result")
+ // .accept(MediaType.APPLICATION_JSON)
+ // .retrieve()
+ // .onStatus(HttpStatus::is4xxClientError, response -> {
+ // if (response.statusCode() == HttpStatus.NOT_FOUND) {
+ // return response.bodyToMono(String.class)
+ // .flatMap(errorBody -> Mono.error(new RuntimeException("任务不存在")));
+ // } else if (response.statusCode() == HttpStatus.BAD_REQUEST) {
+ // return response.bodyToMono(String.class)
+ // .flatMap(errorBody -> Mono.error(new RuntimeException("任务未完成，无法获取结果")));
+ // }
+ // return response.createException().flatMap(Mono::error);
+ // })
+ // .bodyToMono(new
+ // ParameterizedTypeReference<ResponseResult<TaskResultResponse>>() {})
+ // .flatMap(responseResult -> {
+ // TaskResultResponse result = responseResult.getData();
+ // if (result != null && result.getResults() != null) {
+ // // 处理结果并更新数据库
+ // return updateQuestionAndReference(result)
+ // .thenReturn(responseResult);
+ // }
+ // return Mono.just(responseResult);
+ // })
+ // .onErrorResume(e -> {
+
+ // return Mono.just(ResponseResult.error(e.getMessage()));
+ // });
+ // }
+
+ // 更新问题和引用数据
+ // private Mono<Void> updateQuestionAndReference(TaskResultResponse result) {
+ // return Mono.fromRunnable(() -> {
+ // // 1. 更新关键词状态
+ // LambdaUpdateWrapper<Keyword> keywordUpdate = new LambdaUpdateWrapper<>();
+ // keywordUpdate.eq(Keyword::getTask_id, result.getTask_id())
+ // .set(Keyword::getStatus, "completed");
+ // keywordService.update(keywordUpdate);
+
+ // // 2. 处理每个用户的问题结果
+ // for (UserResult userResult : result.getResults()) {
+ // for (QuestionResult questionResult : userResult.getQuestions_results()) {
+ // // 2.1 更新问题状态
+ // LambdaUpdateWrapper<Question> questionUpdate = new LambdaUpdateWrapper<>();
+ // questionUpdate.eq(Question::getTa, result.getTask_id())
+ // .eq(Question::getContent, questionResult.getQuestion())
+ // .set(Question::getStatus, questionResult.getStatus())
+ // .set(Question::getResponse, questionResult.getResponse())
+ // .set(Question::getProcessTime,
+ // LocalDateTime.parse(questionResult.getTimestamp()));
+ // questionService.update(questionUpdate);
+
+ // // 2.2 保存引用数据
+ // List<Reference> references = questionResult.getReferences().stream()
+ // .map(ref -> {
+ // Reference reference = new Reference();
+ // reference.setQuestionId(questionService.getOne(questionUpdate).getId());
+ // reference.setTitle(ref.getTitle());
+ // reference.setUrl(ref.getUrl());
+ // reference.setDomain(ref.getDomain());
+ // reference.setCreateTime(LocalDateTime.now());
+ // return reference;
+ // })
+ // .collect(Collectors.toList());
+
+ // if (!references.isEmpty()) {
+ // referenceService.saveBatch(references);
+ // }
+ // }
+ // }
+ // });
+ // }
+
+}
diff --git a/src/main/java/com/linghu/controller/OrderController.java b/src/main/java/com/linghu/controller/OrderController.java
new file mode 100644
index 0000000..ea27ecc
--- /dev/null
+++ b/src/main/java/com/linghu/controller/OrderController.java
@@ -0,0 +1,157 @@
+package com.linghu.controller;
+
+import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
+import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
+import com.fasterxml.jackson.databind.util.BeanUtil;
+import com.linghu.model.common.ResponseResult;
+import com.linghu.model.entity.Order;
+import com.linghu.model.dto.OrderDto;
+import com.linghu.service.OrderService;
+
+import org.springframework.beans.BeanUtils;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.web.bind.annotation.*;
+
+import java.text.SimpleDateFormat;
+import java.util.Date;
+import java.util.List;
+
+/**
+ * 订单管理接口
+ */
+@RestController
+@RequestMapping("/order")
+public class OrderController {
+
+ @Autowired
+ private OrderService orderService;
+
+ /**
+ * 新增订单
+ */
+ @PostMapping
+ public ResponseResult<Order> add(@RequestBody OrderDto orderDto) {
+ //将dto转entity
+ Order order = new Order();
+ BeanUtils.copyProperties(orderDto, order);
+
+ if (order.getClient_name() == null || order.getClient_name().trim().isEmpty()) {
+ return ResponseResult.error("客户名称不能为空");
+ }
+
+ // 生成订单ID：日期+当天的订单数量（如：202507060001）
+ SimpleDateFormat dateFormat = new SimpleDateFormat("yyyyMMdd");
+ String dateStr = dateFormat.format(new Date());
+
+ // 查询当天订单数量
+ LambdaQueryWrapper<Order> queryWrapper = new LambdaQueryWrapper<>();
+ queryWrapper.likeRight(Order::getOrder_id, dateStr);
+ long count = orderService.count(queryWrapper);
+
+ // 生成订单ID
+ String orderId = String.format("%s%04d", dateStr, count + 1);
+ order.setOrder_id(orderId);
+
+ // 设置初始状态
+ order.setStatus(1); // 待处理
+ order.setDel_flag(0); // 未删除
+ order.setCreate_time(new Date());
+ //保存关键词
+ boolean saveOrderWithKeywords = orderService.saveOrderWithKeywords(orderDto);
+
+
+ if (orderService.save(order)) {
+ return ResponseResult.success(order);
+ }
+ return ResponseResult.error("添加订单失败");
+ }
+
+ /**
+ * 删除订单（逻辑删除）
+ */
+ @DeleteMapping("/{orderId}")
+ public ResponseResult<Void> delete(@PathVariable String orderId) {
+ Order order = orderService.getById(orderId);
+ if (order == null) {
+ return ResponseResult.error("订单不存在");
+ }
+
+ order.setDel_flag(1);
+ order.setUpdate_time(new Date());
+
+ if (orderService.updateById(order)) {
+ return ResponseResult.success();
+ }
+ return ResponseResult.error("删除订单失败");
+ }
+
+ /**
+ * 更新订单
+ */
+ @PutMapping
+ public ResponseResult<Void> update(@RequestBody Order order) {
+ if (order.getOrder_id() == null) {
+ return ResponseResult.error("订单ID不能为空");
+ }
+ if (order.getClient_name() == null || order.getClient_name().trim().isEmpty()) {
+ return ResponseResult.error("客户名称不能为空");
+ }
+
+ Order existingOrder = orderService.getById(order.getOrder_id());
+ if (existingOrder == null) {
+ return ResponseResult.error("订单不存在");
+ }
+
+ order.setUpdate_time(new Date());
+
+ if (orderService.updateById(order)) {
+ return ResponseResult.success();
+ }
+ return ResponseResult.error("更新订单失败");
+ }
+
+ /**
+ * 根据ID查询订单
+ */
+ @GetMapping("/{orderId}")
+ public ResponseResult<Order> getById(@PathVariable String orderId) {
+ Order order = orderService.getById(orderId);
+ if (order == null || order.getDel_flag() == 1) {
+ return ResponseResult.error("订单不存在");
+ }
+ return ResponseResult.success(order);
+ }
+
+ /**
+ * 查询订单列表
+ */
+ @GetMapping
+ public ResponseResult<List<Order>> list(
+ @RequestParam(required = false) Integer pageNum,
+ @RequestParam(required = false) Integer pageSize,
+ @RequestParam(required = false) String clientName,
+ @RequestParam(required = false) Integer status) {
+
+ LambdaQueryWrapper<Order> queryWrapper = new LambdaQueryWrapper<>();
+ queryWrapper.eq(Order::getDel_flag, 0); // 只查询未删除的订单
+
+ // 添加查询条件
+ if (clientName != null && !clientName.trim().isEmpty()) {
+ queryWrapper.like(Order::getClient_name, clientName);
+ }
+ if (status != null) {
+ queryWrapper.eq(Order::getStatus, status);
+ }
+
+ // 分页查询
+ if (pageNum != null && pageSize != null) {
+ Page<Order> pageInfo = new Page<>(pageNum, pageSize);
+ Page<Order> result = orderService.page(pageInfo, queryWrapper);
+ return ResponseResult.success(result.getRecords());
+ }
+
+ // 不分页
+ List<Order> list = orderService.list(queryWrapper);
+ return ResponseResult.success(list);
+ }
+}
\ No newline at end of file
diff --git a/src/main/java/com/linghu/controller/PlatformController.java b/src/main/java/com/linghu/controller/PlatformController.java
new file mode 100644
index 0000000..e71fb80
--- /dev/null
+++ b/src/main/java/com/linghu/controller/PlatformController.java
@@ -0,0 +1,192 @@
+package com.linghu.controller;
+
+import com.alibaba.excel.EasyExcel;
+import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
+import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
+import com.linghu.model.common.ResponseResult;
+import com.linghu.model.entity.Platform;
+import com.linghu.model.entity.Type;
+import com.linghu.model.excel.PlatformExcel;
+import com.linghu.service.PlatformService;
+import com.linghu.service.TypeService;
+
+import io.swagger.annotations.Api;
+import io.swagger.annotations.ApiOperation;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.http.HttpHeaders;
+import org.springframework.http.MediaType;
+import org.springframework.http.ResponseEntity;
+import org.springframework.util.StringUtils;
+import org.springframework.web.bind.annotation.*;
+import org.springframework.web.multipart.MultipartFile;
+
+import java.io.ByteArrayOutputStream;
+import java.io.IOException;
+
+import java.util.ArrayList;
+import java.util.Date;
+import java.util.List;
+import java.util.stream.Collectors;
+
+@RestController
+@RequestMapping("/platform")
+@Api(value = "平台相关接口", tags = "设置-平台")
+public class PlatformController {
+
+ @Autowired
+ private PlatformService platformService;
+ @Autowired
+ private TypeService typeService;
+
+ @PostMapping
+ @ApiOperation(value = "添加平台")
+ public ResponseResult<Platform> add(@RequestBody Platform platform) {
+ // 校验平台名称和域名不能为空
+ if (!StringUtils.hasText(platform.getPlatform_name())) {
+ return ResponseResult.error("平台名称不能为空");
+ }
+ if (!StringUtils.hasText(platform.getDomain())) {
+ return ResponseResult.error("平台域名不能为空");
+ }
+
+ boolean success = platformService.save(platform);
+ if (success) {
+ return ResponseResult.success(platform);
+ }
+ return ResponseResult.error("添加平台失败");
+ }
+
+ @DeleteMapping("/{platformId}")
+ public ResponseResult<Void> delete(@PathVariable Integer platformId) {
+ boolean success = platformService.removeById(platformId);
+ if (success) {
+ return ResponseResult.success();
+ }
+ return ResponseResult.error("删除平台失败");
+ }
+
+ @PutMapping
+ public ResponseResult<Void> update(@RequestBody Platform platform) {
+ // 校验平台名称和域名不能为空
+ if (!StringUtils.hasText(platform.getPlatform_name())) {
+ return ResponseResult.error("平台名称不能为空");
+ }
+ if (!StringUtils.hasText(platform.getDomain())) {
+ return ResponseResult.error("平台域名不能为空");
+ }
+
+ boolean success = platformService.updateById(platform);
+ if (success) {
+ return ResponseResult.success();
+ }
+ return ResponseResult.error("更新平台失败");
+ }
+
+ @GetMapping("/{platformId}")
+ public ResponseResult<Platform> getById(@PathVariable Integer platformId) {
+ Platform platform = platformService.getById(platformId);
+ if (platform != null) {
+ return ResponseResult.success(platform);
+ }
+ return ResponseResult.error("平台不存在");
+ }
+
+ @GetMapping("/list")
+ public ResponseResult<List<Platform>> list(
+ @RequestParam(required = false) Integer page,
+ @RequestParam(required = false) Integer pageSize) {
+ if (page != null && pageSize != null) {
+ Page<Platform> pageInfo = new Page<>(page, pageSize);
+ Page<Platform> result = platformService.page(pageInfo);
+ return ResponseResult.success(result.getRecords());
+ } else {
+ List<Platform> list = platformService.list();
+ return ResponseResult.success(list);
+ }
+ }
+
+ @GetMapping("/download")
+ @ApiOperation("下载平台模板")
+ public ResponseEntity<byte[]> downloadTemplate() throws IOException {
+ ByteArrayOutputStream out = new ByteArrayOutputStream();
+ EasyExcel.write(out, PlatformExcel.class).sheet("平台模板").doWrite(new ArrayList<>());
+
+ return ResponseEntity.ok()
+ .header(HttpHeaders.CONTENT_DISPOSITION, "attachment;filename=platform_template.xlsx")
+ .contentType(MediaType.APPLICATION_OCTET_STREAM)
+ .body(out.toByteArray());
+ }
+
+ @PostMapping("/import")
+ @ApiOperation("导入平台数据")
+ public ResponseResult<String> importPlatforms(@RequestParam("file") MultipartFile file) {
+ try {
+ // 检查文件是否为空
+ if (file.isEmpty()) {
+ return ResponseResult.error("上传文件不能为空");
+ }
+
+ // 读取Excel数据
+ List<PlatformExcel> excelList = EasyExcel.read(file.getInputStream())
+ .head(PlatformExcel.class)
+ .sheet()
+ .doReadSync();
+
+ // 数据转换与验证
+ List<Platform> platforms = new ArrayList<>();
+ List<String> errorMessages = new ArrayList<>();
+
+ for (PlatformExcel excel : excelList) {
+ // 检查必要字段
+ if (!StringUtils.hasText(excel.getPlatform_name())) {
+ errorMessages.add("平台名称不能为空");
+ continue;
+ }
+ if (!StringUtils.hasText(excel.getType_name())) {
+ errorMessages.add("平台类型不能为空");
+ continue;
+ }
+ if (!StringUtils.hasText(excel.getDomain())) {
+ errorMessages.add("平台域名不能为空");
+ continue;
+ }
+
+ // 查找类型
+ Type typeByName = typeService.getTypeByName(excel.getType_name());
+ if (typeByName == null) {
+ errorMessages.add("未知的平台类型: " + excel.getType_name());
+ continue;
+ }
+
+ // 构建平台对象
+ Platform platform = new Platform();
+ platform.setPlatform_name(excel.getPlatform_name());
+ platform.setDomain(excel.getDomain());
+ platform.setType_id(typeByName.getType_id());
+
+ // 设置创建时间（解决之前的数据库错误）
+ platform.setCreate_time(new Date());
+
+ platforms.add(platform);
+ }
+
+ // 处理错误
+ if (!errorMessages.isEmpty()) {
+ return ResponseResult.error("数据验证失败: " + String.join("; ", errorMessages));
+ }
+
+ // 批量保存
+ if (!platforms.isEmpty()) {
+ platformService.saveBatch(platforms);
+ return ResponseResult.success("成功导入" + platforms.size() + "条数据");
+ } else {
+ return ResponseResult.error("没有有效数据可导入");
+ }
+
+ } catch (Exception e) {
+ // 记录详细异常信息
+
+ return ResponseResult.error("文件解析失败：" + e.getMessage());
+ }
+ }
+}
diff --git a/src/main/java/com/linghu/controller/QuestionController.java b/src/main/java/com/linghu/controller/QuestionController.java
new file mode 100644
index 0000000..5922e03
--- /dev/null
+++ b/src/main/java/com/linghu/controller/QuestionController.java
@@ -0,0 +1,112 @@
+package com.linghu.controller;
+
+import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
+import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
+import com.linghu.model.common.ResponseResult;
+import com.linghu.model.entity.Question;
+import com.linghu.service.QuestionService;
+import io.swagger.annotations.Api;
+import io.swagger.annotations.ApiOperation;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.transaction.annotation.Transactional;
+import org.springframework.web.bind.annotation.*;
+import com.linghu.model.dto.KeywordDto;
+
+import java.util.Arrays;
+import java.util.List;
+import java.util.stream.Collectors;
+
+@RestController
+@RequestMapping("/question")
+@Api(value = "提问词相关接口", tags = "设置-提问词")
+public class QuestionController {
+
+ @Autowired
+ private QuestionService questionService;
+
+ @PostMapping
+ @ApiOperation(value = "添加提问词")
+ @Transactional
+ public ResponseResult<List<Question>> add(@RequestBody KeywordDto keywordDto) {
+
+ List<Question> questionList = Arrays.stream(keywordDto.getQuestions().split("\\n"))
+ .filter(q -> !q.trim().isEmpty())
+ .map(q -> {
+ Question question = new Question();
+ question.setKeyword_id(keywordDto.getKeyword_id());
+ question.setQuestion(q.trim());
+ question.setStatus("pending");
+
+ return question;
+ }).collect(Collectors.toList());
+
+ boolean success = questionService.saveBatch(questionList);
+ if (success) {
+ return ResponseResult.success(questionList);
+ }
+ return ResponseResult.error("添加提问词失败");
+ }
+
+ // @DeleteMapping("/{questionId}")
+ // public ResponseResult<Void> delete(@PathVariable Integer questionId) {
+ // Question question = new Question();
+ // question.setQuestion_id(questionId);
+ // question.setDel_flag(1);
+ // boolean success = questionService.updateById(question);
+ // if (success) {
+ // return ResponseResult.success();
+ // }
+ // return ResponseResult.error("删除提问词失败");
+ // }
+
+ @PutMapping
+ @Transactional
+ public ResponseResult<Void> update(@RequestBody List<Question> questions) {
+ boolean success = questionService.updateBatchById(questions);
+ // 不存在的问题id就新增
+ List<Question> newQuestions = questions.stream()
+ .filter(q -> q.getQuestion_id() == null)
+ .collect(Collectors.toList());
+ if (!newQuestions.isEmpty()) {
+ questionService.saveBatch(newQuestions);
+ }
+ if (success) {
+ return ResponseResult.success();
+ }
+ return ResponseResult.error("更新提问词失败");
+ }
+
+ @GetMapping("/{questionId}")
+ public ResponseResult<Question> getById(@PathVariable Integer questionId) {
+ Question question = questionService.getById(questionId);
+ if (question != null) {
+ return ResponseResult.success(question);
+ }
+ return ResponseResult.error("提问词不存在");
+ }
+
+ // @DeleteMapping("/batch")
+ // @Transactional
+ // public ResponseResult<Void> batchDelete(@RequestBody List<Integer>
+ // questionIds) {
+ // List<Question> questions = questionIds.stream().map(id -> {
+ // Question question = new Question();
+ // question.setQuestion_id(id);
+ // return question;
+ // }).collect(Collectors.toList());
+
+ // boolean success = questionService.updateBatchById(questions);
+ // if (success) {
+ // return ResponseResult.success();
+ // }
+ // return ResponseResult.error("批量删除提问词失败");
+ // }
+
+ @GetMapping("/list")
+ public ResponseResult<List<Question>> list() {
+ LambdaQueryWrapper<Question> queryWrapper = new LambdaQueryWrapper<>();
+ List<Question> list = questionService.list(queryWrapper);
+ return ResponseResult.success(list);
+
+ }
+}
\ No newline at end of file
diff --git a/src/main/java/com/linghu/controller/TypeController.java b/src/main/java/com/linghu/controller/TypeController.java
index ef03c95..9115431 100644
--- a/src/main/java/com/linghu/controller/TypeController.java
+++ b/src/main/java/com/linghu/controller/TypeController.java
@@ -10,6 +10,7 @@
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.*;
+import java.util.Date;
import java.util.List;
@RestController
@@ -23,7 +24,7 @@
@PostMapping
@ApiOperation(value = "添加类型")
public ResponseResult<Type> add(@RequestBody Type type) {
- type.setDelFlag(0);
+ type.setDel_flag(0);
boolean success = typeService.save(type);
if (success) {
return ResponseResult.success(type);
@@ -33,6 +34,8 @@
@PostMapping("/batch")
public ResponseResult<Void> batchAdd(@RequestBody List<Type> types) {
+ types.forEach(type -> type.setDel_flag(0));
+
boolean success = typeService.saveBatch(types);
if (success) {
return ResponseResult.success();
@@ -43,22 +46,13 @@
@DeleteMapping("/{typeId}")
public ResponseResult<Void> delete(@PathVariable Integer typeId) {
Type type = new Type();
- type.setTypeId(typeId);
- type.setDelFlag(1);
+ type.setType_id(typeId);
+ type.setDel_flag(1);
boolean success = typeService.updateById(type);
if (success) {
return ResponseResult.success();
}
return ResponseResult.error("删除类型失败");
- }
-
- @DeleteMapping("/batch")
- public ResponseResult<Void> batchDelete(@RequestBody List<Integer> typeIds) {
- boolean success = typeService.removeBatchByIds(typeIds);
- if (success) {
- return ResponseResult.success();
- }
- return ResponseResult.error("批量删除类型失败");
}
@PutMapping
@@ -82,29 +76,41 @@
@GetMapping("/{typeId}")
public ResponseResult<Type> getById(@PathVariable Integer typeId) {
Type type = typeService.getById(typeId);
- if (type != null && type.getDelFlag() != 1) {
+ if (type != null && type.getDel_flag() != 1) {
return ResponseResult.success(type);
}
return ResponseResult.error("类型不存在");
}
- @GetMapping("/list")
- public ResponseResult<?> list(
- @RequestParam(required = false) Integer pageNum,
- @RequestParam(required = false) Integer pageSize,
- @RequestParam(required = false) String typeName) {
-
- // 不传分页参数则返回全部数据
- if (pageNum == null || pageSize == null) {
- List<Type> types = typeService.listAllAvailable();
- return ResponseResult.success(types);
+ @DeleteMapping("/batch")
+ public ResponseResult<Void> batchDelete(@RequestBody List<Integer> typeIds) {
+ List<Type> types = typeIds.stream().map(id -> {
+ Type type = new Type();
+ type.setType_id(id);
+ type.setDel_flag(1);
+ return type;
+ }).collect(java.util.stream.Collectors.toList());
+ boolean success = typeService.updateBatchById(types);
+ if (success) {
+ return ResponseResult.success();
}
+ return ResponseResult.error("批量删除类型失败");
+ }
+ @GetMapping("/list")
+ public ResponseResult<List<Type>> list(
+ @RequestParam(required = false) Integer page,
+ @RequestParam(required = false) Integer pageSize) {
LambdaQueryWrapper<Type> queryWrapper = new LambdaQueryWrapper<>();
- queryWrapper.eq(Type::getDelFlag, 0)
- .like(typeName != null, Type::getTypeName, typeName);
+ queryWrapper.eq(Type::getDel_flag, 0);
- Page<Type> page = typeService.page(new Page<>(pageNum, pageSize), queryWrapper);
- return ResponseResult.success(page);
+ if (page != null && pageSize != null) {
+ Page<Type> pageInfo = new Page<>(page, pageSize);
+ Page<Type> result = typeService.page(pageInfo, queryWrapper);
+ return ResponseResult.success(result.getRecords());
+ } else {
+ List<Type> list = typeService.list(queryWrapper);
+ return ResponseResult.success(list);
+ }
}
}
\ No newline at end of file
diff --git a/src/main/java/com/linghu/controller/baseController.java b/src/main/java/com/linghu/controller/baseController.java
deleted file mode 100644
index 8ba620f..0000000
--- a/src/main/java/com/linghu/controller/baseController.java
+++ /dev/null
@@ -1,13 +0,0 @@
-package com.linghu.controller;
-
-import org.springframework.stereotype.Controller;
-import org.springframework.web.bind.annotation.RequestMapping;
-import org.springframework.web.bind.annotation.RestController;
-
-@RestController
-public class baseController {
- @RequestMapping("/ceshi")
- public String index(){
- return "index";
- }
-}
diff --git a/src/main/java/com/linghu/mapper/CallwordMapper.java b/src/main/java/com/linghu/mapper/CallwordMapper.java
deleted file mode 100644
index 2347b8d..0000000
--- a/src/main/java/com/linghu/mapper/CallwordMapper.java
+++ /dev/null
@@ -1,18 +0,0 @@
-package com.linghu.mapper;
-
-import com.linghu.model.entity.Callword;
-import com.baomidou.mybatisplus.core.mapper.BaseMapper;
-
-/**
-* @author xy
-* @description 针对表【callword】的数据库操作Mapper
-* @createDate 2025-07-02 16:32:19
-* @Entity generator.entity.Callword
-*/
-public interface CallwordMapper extends BaseMapper<Callword> {
-
-}
-
-
-
-
diff --git a/src/main/java/com/linghu/mapper/KeywordMapper.java b/src/main/java/com/linghu/mapper/KeywordMapper.java
index a5f6071..267f6d3 100644
--- a/src/main/java/com/linghu/mapper/KeywordMapper.java
+++ b/src/main/java/com/linghu/mapper/KeywordMapper.java
@@ -6,8 +6,8 @@
/**
* @author xy
* @description 针对表【keyword】的数据库操作Mapper
-* @createDate 2025-07-02 16:32:19
-* @Entity generator.entity.Keyword
+* @createDate 2025-07-04 20:17:33
+* @Entity com.linghu.model.entity.Keyword
*/
public interface KeywordMapper extends BaseMapper<Keyword> {
diff --git a/src/main/java/com/linghu/mapper/OrderMapper.java b/src/main/java/com/linghu/mapper/OrderMapper.java
index 6b1678b..23b6c6d 100644
--- a/src/main/java/com/linghu/mapper/OrderMapper.java
+++ b/src/main/java/com/linghu/mapper/OrderMapper.java
@@ -6,8 +6,8 @@
/**
* @author xy
* @description 针对表【order】的数据库操作Mapper
-* @createDate 2025-07-02 16:32:19
-* @Entity generator.entity.Order
+* @createDate 2025-07-04 20:17:33
+* @Entity com.linghu.model.entity.Order
*/
public interface OrderMapper extends BaseMapper<Order> {
diff --git a/src/main/java/com/linghu/mapper/PlatformMapper.java b/src/main/java/com/linghu/mapper/PlatformMapper.java
new file mode 100644
index 0000000..5180439
--- /dev/null
+++ b/src/main/java/com/linghu/mapper/PlatformMapper.java
@@ -0,0 +1,14 @@
+package com.linghu.mapper;
+
+import com.linghu.model.entity.Platform;
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+
+/**
+ * @author xy
+ * @description 针对表【platfrom】的数据库操作Mapper
+ * @createDate 2025-07-04 20:17:33
+ * @Entity com.linghu.model.entity.Platfrom
+ */
+public interface PlatformMapper extends BaseMapper<Platform> {
+
+}
diff --git a/src/main/java/com/linghu/mapper/PlatfromMapper.java b/src/main/java/com/linghu/mapper/PlatfromMapper.java
deleted file mode 100644
index 9e3dbe0..0000000
--- a/src/main/java/com/linghu/mapper/PlatfromMapper.java
+++ /dev/null
@@ -1,18 +0,0 @@
-package com.linghu.mapper;
-
-import com.linghu.model.entity.Platfrom;
-import com.baomidou.mybatisplus.core.mapper.BaseMapper;
-
-/**
-* @author xy
-* @description 针对表【platfrom】的数据库操作Mapper
-* @createDate 2025-07-02 16:32:19
-* @Entity generator.entity.Platfrom
-*/
-public interface PlatfromMapper extends BaseMapper<Platfrom> {
-
-}
-
-
-
-
diff --git a/src/main/java/com/linghu/mapper/QuestionMapper.java b/src/main/java/com/linghu/mapper/QuestionMapper.java
new file mode 100644
index 0000000..c8873b3
--- /dev/null
+++ b/src/main/java/com/linghu/mapper/QuestionMapper.java
@@ -0,0 +1,18 @@
+package com.linghu.mapper;
+
+import com.linghu.model.entity.Question;
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+
+/**
+* @author xy
+* @description 针对表【question】的数据库操作Mapper
+* @createDate 2025-07-04 20:17:33
+* @Entity com.linghu.model.entity.Question
+*/
+public interface QuestionMapper extends BaseMapper<Question> {
+
+}
+
+
+
+
diff --git a/src/main/java/com/linghu/mapper/ReferenceMapper.java b/src/main/java/com/linghu/mapper/ReferenceMapper.java
new file mode 100644
index 0000000..4c95eb1
--- /dev/null
+++ b/src/main/java/com/linghu/mapper/ReferenceMapper.java
@@ -0,0 +1,18 @@
+package com.linghu.mapper;
+
+import com.linghu.model.entity.Reference;
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+
+/**
+* @author xy
+* @description 针对表【reference】的数据库操作Mapper
+* @createDate 2025-07-04 20:17:33
+* @Entity com.linghu.model.entity.Reference
+*/
+public interface ReferenceMapper extends BaseMapper<Reference> {
+
+}
+
+
+
+
diff --git a/src/main/java/com/linghu/mapper/ResultMapper.java b/src/main/java/com/linghu/mapper/ResultMapper.java
deleted file mode 100644
index a3b4de6..0000000
--- a/src/main/java/com/linghu/mapper/ResultMapper.java
+++ /dev/null
@@ -1,18 +0,0 @@
-package com.linghu.mapper;
-
-import com.linghu.model.entity.Result;
-import com.baomidou.mybatisplus.core.mapper.BaseMapper;
-
-/**
-* @author xy
-* @description 针对表【result】的数据库操作Mapper
-* @createDate 2025-07-02 16:32:19
-* @Entity generator.entity.Result
-*/
-public interface ResultMapper extends BaseMapper<Result> {
-
-}
-
-
-
-
diff --git a/src/main/java/com/linghu/mapper/TypeMapper.java b/src/main/java/com/linghu/mapper/TypeMapper.java
index 950d2fe..d793077 100644
--- a/src/main/java/com/linghu/mapper/TypeMapper.java
+++ b/src/main/java/com/linghu/mapper/TypeMapper.java
@@ -6,8 +6,8 @@
/**
* @author xy
* @description 针对表【type】的数据库操作Mapper
-* @createDate 2025-07-02 16:32:19
-* @Entity generator.entity.Type
+* @createDate 2025-07-04 20:10:31
+* @Entity com.linghu.model.entity.Type
*/
public interface TypeMapper extends BaseMapper<Type> {
diff --git a/src/main/java/com/linghu/mapper/UserMapper.java b/src/main/java/com/linghu/mapper/UserMapper.java
new file mode 100644
index 0000000..b7b16b7
--- /dev/null
+++ b/src/main/java/com/linghu/mapper/UserMapper.java
@@ -0,0 +1,18 @@
+package com.linghu.mapper;
+
+import com.linghu.model.entity.User;
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+
+/**
+* @author xy
+* @description 针对表【user】的数据库操作Mapper
+* @createDate 2025-07-07 10:26:00
+* @Entity com.linghu.model.entity.User
+*/
+public interface UserMapper extends BaseMapper<User> {
+
+}
+
+
+
+
diff --git a/src/main/java/com/linghu/model/dto/KeywordDto.java b/src/main/java/com/linghu/model/dto/KeywordDto.java
new file mode 100644
index 0000000..b463b97
--- /dev/null
+++ b/src/main/java/com/linghu/model/dto/KeywordDto.java
@@ -0,0 +1,14 @@
+package com.linghu.model.dto;
+
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+import com.linghu.model.entity.Keyword;
+
+@EqualsAndHashCode(callSuper = true)
+@Data
+public class KeywordDto extends Keyword {
+ /**
+ * 提问词列表，用换行符分隔
+ */
+ private String questions;
+}
diff --git a/src/main/java/com/linghu/model/dto/OrderDto.java b/src/main/java/com/linghu/model/dto/OrderDto.java
new file mode 100644
index 0000000..6043fe2
--- /dev/null
+++ b/src/main/java/com/linghu/model/dto/OrderDto.java
@@ -0,0 +1,17 @@
+package com.linghu.model.dto;
+
+import com.linghu.model.entity.Order;
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+
+/**
+ * 订单数据传输对象，扩展Order实体
+ */
+@Data
+@EqualsAndHashCode(callSuper = true)
+public class OrderDto extends Order {
+ /**
+ * 关键词列表，用换行符分隔
+ */
+ private String keywords;
+}
\ No newline at end of file
diff --git a/src/main/java/com/linghu/model/dto/SearchTaskRequest.java b/src/main/java/com/linghu/model/dto/SearchTaskRequest.java
new file mode 100644
index 0000000..ede867d
--- /dev/null
+++ b/src/main/java/com/linghu/model/dto/SearchTaskRequest.java
@@ -0,0 +1,37 @@
+package com.linghu.model.dto;
+
+import lombok.Data;
+import javax.validation.Valid;
+import javax.validation.constraints.*;
+
+import com.linghu.model.entity.User;
+
+import java.util.List;
+
+@Data
+public class SearchTaskRequest {
+ @Valid
+ @NotEmpty(message = "用户列表不能为空")
+ private List<User> users;
+
+ @NotEmpty(message = "问题列表不能为空")
+ private List<String> questions;
+
+ @Valid
+ private ConfigDTO config;
+
+ private Boolean save_to_database = false;
+ private String webhook_url;
+ private Integer keyword_id;
+
+ @Data
+ public static class ConfigDTO {
+ @Min(value = 1, message = "最大并发用户数至少为1")
+ private Integer max_concurrent_users = 3;
+
+ @Min(value = 0, message = "用户启动延迟不能为负数")
+ private Integer user_start_delay = 1;
+
+ private Boolean headless = true;
+ }
+}
\ No newline at end of file
diff --git a/src/main/java/com/linghu/model/dto/SearchTaskResponse.java b/src/main/java/com/linghu/model/dto/SearchTaskResponse.java
new file mode 100644
index 0000000..6015651
--- /dev/null
+++ b/src/main/java/com/linghu/model/dto/SearchTaskResponse.java
@@ -0,0 +1,11 @@
+package com.linghu.model.dto;
+
+import lombok.Data;
+
+@Data
+public class SearchTaskResponse {
+ private String task_id;
+ private String status;
+ private String message;
+
+}
diff --git a/src/main/java/com/linghu/model/dto/TaskCancelResponse.java b/src/main/java/com/linghu/model/dto/TaskCancelResponse.java
new file mode 100644
index 0000000..a204e11
--- /dev/null
+++ b/src/main/java/com/linghu/model/dto/TaskCancelResponse.java
@@ -0,0 +1,16 @@
+package com.linghu.model.dto;
+
+import lombok.Data;
+
+@Data
+public class TaskCancelResponse {
+ private String task_id;
+ private String status;
+ private String message;
+
+ public TaskCancelResponse(String taskId, String status, String message) {
+ this.task_id = taskId;
+ this.status = status;
+ this.message = message;
+ }
+}
\ No newline at end of file
diff --git a/src/main/java/com/linghu/model/dto/TaskResultResponse.java b/src/main/java/com/linghu/model/dto/TaskResultResponse.java
new file mode 100644
index 0000000..ad7a792
--- /dev/null
+++ b/src/main/java/com/linghu/model/dto/TaskResultResponse.java
@@ -0,0 +1,53 @@
+package com.linghu.model.dto;
+
+import lombok.Data;
+import lombok.NoArgsConstructor;
+import lombok.AllArgsConstructor;
+
+import java.util.Date;
+import java.util.List;
+
+@Data
+@NoArgsConstructor
+@AllArgsConstructor
+public class TaskResultResponse {
+ private String task_id;
+ private Integer total_users;
+ private Integer total_questions;
+ private Integer successful_users;
+ private Date total_duration;
+ private List<UserResult> results;
+
+ @Data
+ @NoArgsConstructor
+ @AllArgsConstructor
+ public static class UserResult {
+
+ private String user_name;
+ private String user_email;
+ private String status;
+ private List<QuestionResult> questions_results;
+ }
+
+ @Data
+ @NoArgsConstructor
+ @AllArgsConstructor
+ public static class QuestionResult {
+ private String question;
+ private String response;
+ private String status;
+ private Integer extracted_count;
+ private Date timestamp;
+ private String error;
+ private List<Reference> references;
+ }
+
+ @Data
+ @NoArgsConstructor
+ @AllArgsConstructor
+ public static class Reference {
+ private String title;
+ private String url;
+ private String domain;
+ }
+}
\ No newline at end of file
diff --git a/src/main/java/com/linghu/model/dto/TaskStatusResponse.java b/src/main/java/com/linghu/model/dto/TaskStatusResponse.java
new file mode 100644
index 0000000..3222219
--- /dev/null
+++ b/src/main/java/com/linghu/model/dto/TaskStatusResponse.java
@@ -0,0 +1,34 @@
+package com.linghu.model.dto;
+
+import java.util.List;
+
+import lombok.Data;
+
+@Data
+public class TaskStatusResponse {
+ private String task_id;
+ private String status;
+ private double progress;
+ private String message;
+ private String start_time;
+ private String end_time;
+ private int users_count;
+ private int questions_count;
+ private boolean save_to_database;
+ private String webhook_url;
+ private List<QuestionStatus> questions_status;
+
+ @Data
+ public static class QuestionStatus {
+ private int question_id;
+ private String question;
+ private String user_name;
+ private String user_email;
+ private String status;
+ private String timestamp;
+ private int extracted_count;
+
+ // Getters and Setters
+
+ }
+}
diff --git a/src/main/java/com/linghu/model/entity/Callword.java b/src/main/java/com/linghu/model/entity/Callword.java
deleted file mode 100644
index 89b63ad..0000000
--- a/src/main/java/com/linghu/model/entity/Callword.java
+++ /dev/null
@@ -1,84 +0,0 @@
-package com.linghu.model.entity;
-
-import com.baomidou.mybatisplus.annotation.IdType;
-import com.baomidou.mybatisplus.annotation.TableField;
-import com.baomidou.mybatisplus.annotation.TableId;
-import com.baomidou.mybatisplus.annotation.TableName;
-import java.io.Serializable;
-import lombok.Data;
-
-/**
- *
- * @TableName callword
- */
-@TableName(value ="callword")
-@Data
-public class Callword implements Serializable {
- /**
- * 提示词id
- */
- @TableId
- private String callwordId;
-
- /**
- * 关键词id
- */
- private Integer keywordId;
-
- /**
- * 提示词名称
- */
- private String callwordName;
-
- /**
- * 提示词状态，1-未采集，2-采集完成，3-采集报错
- */
- private String status;
-
- @TableField(exist = false)
- private static final long serialVersionUID = 1L;
-
- @Override
- public boolean equals(Object that) {
- if (this == that) {
- return true;
- }
- if (that == null) {
- return false;
- }
- if (getClass() != that.getClass()) {
- return false;
- }
- Callword other = (Callword) that;
- return (this.getCallwordId() == null ? other.getCallwordId() == null : this.getCallwordId().equals(other.getCallwordId()))
- && (this.getKeywordId() == null ? other.getKeywordId() == null : this.getKeywordId().equals(other.getKeywordId()))
- && (this.getCallwordName() == null ? other.getCallwordName() == null : this.getCallwordName().equals(other.getCallwordName()))
- && (this.getStatus() == null ? other.getStatus() == null : this.getStatus().equals(other.getStatus()));
- }
-
- @Override
- public int hashCode() {
- final int prime = 31;
- int result = 1;
- result = prime * result + ((getCallwordId() == null) ? 0 : getCallwordId().hashCode());
- result = prime * result + ((getKeywordId() == null) ? 0 : getKeywordId().hashCode());
- result = prime * result + ((getCallwordName() == null) ? 0 : getCallwordName().hashCode());
- result = prime * result + ((getStatus() == null) ? 0 : getStatus().hashCode());
- return result;
- }
-
- @Override
- public String toString() {
- StringBuilder sb = new StringBuilder();
- sb.append(getClass().getSimpleName());
- sb.append(" [");
- sb.append("Hash = ").append(hashCode());
- sb.append(", callwordId=").append(callwordId);
- sb.append(", keywordId=").append(keywordId);
- sb.append(", callwordName=").append(callwordName);
- sb.append(", status=").append(status);
- sb.append(", serialVersionUID=").append(serialVersionUID);
- sb.append("]");
- return sb.toString();
- }
-}
\ No newline at end of file
diff --git a/src/main/java/com/linghu/model/entity/Keyword.java b/src/main/java/com/linghu/model/entity/Keyword.java
index 0b7163c..fba41c9 100644
--- a/src/main/java/com/linghu/model/entity/Keyword.java
+++ b/src/main/java/com/linghu/model/entity/Keyword.java
@@ -18,22 +18,32 @@
* 关键词
*/
@TableId(type = IdType.AUTO)
- private Integer keywordId;
+ private Integer keyword_id;
/**
* 关联订单id
*/
- private String orderId;
+ private String order_id;
/**
* 关键词名称
*/
- private String keywordName;
+ private String keyword_name;
/**
* 采集轮数
*/
private Integer num;
+
+ /**
+ * 任务唯一标识符
+ */
+ private String task_id;
+
+ /**
+ * 任务状态（notSubmitted：待处理；submitted：已提交 ； ）
+ */
+ private String status;
@TableField(exist = false)
private static final long serialVersionUID = 1L;
@@ -50,20 +60,24 @@
return false;
}
Keyword other = (Keyword) that;
- return (this.getKeywordId() == null ? other.getKeywordId() == null : this.getKeywordId().equals(other.getKeywordId()))
- && (this.getOrderId() == null ? other.getOrderId() == null : this.getOrderId().equals(other.getOrderId()))
- && (this.getKeywordName() == null ? other.getKeywordName() == null : this.getKeywordName().equals(other.getKeywordName()))
- && (this.getNum() == null ? other.getNum() == null : this.getNum().equals(other.getNum()));
+ return (this.getKeyword_id() == null ? other.getKeyword_id() == null : this.getKeyword_id().equals(other.getKeyword_id()))
+ && (this.getOrder_id() == null ? other.getOrder_id() == null : this.getOrder_id().equals(other.getOrder_id()))
+ && (this.getKeyword_name() == null ? other.getKeyword_name() == null : this.getKeyword_name().equals(other.getKeyword_name()))
+ && (this.getNum() == null ? other.getNum() == null : this.getNum().equals(other.getNum()))
+ && (this.getTask_id() == null ? other.getTask_id() == null : this.getTask_id().equals(other.getTask_id()))
+ && (this.getStatus() == null ? other.getStatus() == null : this.getStatus().equals(other.getStatus()));
}
@Override
public int hashCode() {
final int prime = 31;
int result = 1;
- result = prime * result + ((getKeywordId() == null) ? 0 : getKeywordId().hashCode());
- result = prime * result + ((getOrderId() == null) ? 0 : getOrderId().hashCode());
- result = prime * result + ((getKeywordName() == null) ? 0 : getKeywordName().hashCode());
+ result = prime * result + ((getKeyword_id() == null) ? 0 : getKeyword_id().hashCode());
+ result = prime * result + ((getOrder_id() == null) ? 0 : getOrder_id().hashCode());
+ result = prime * result + ((getKeyword_name() == null) ? 0 : getKeyword_name().hashCode());
result = prime * result + ((getNum() == null) ? 0 : getNum().hashCode());
+ result = prime * result + ((getTask_id() == null) ? 0 : getTask_id().hashCode());
+ result = prime * result + ((getStatus() == null) ? 0 : getStatus().hashCode());
return result;
}
@@ -73,10 +87,12 @@
sb.append(getClass().getSimpleName());
sb.append(" [");
sb.append("Hash = ").append(hashCode());
- sb.append(", keywordId=").append(keywordId);
- sb.append(", orderId=").append(orderId);
- sb.append(", keywordName=").append(keywordName);
+ sb.append(", keyword_id=").append(keyword_id);
+ sb.append(", order_id=").append(order_id);
+ sb.append(", keyword_name=").append(keyword_name);
sb.append(", num=").append(num);
+ sb.append(", task_id=").append(task_id);
+ sb.append(", status=").append(status);
sb.append(", serialVersionUID=").append(serialVersionUID);
sb.append("]");
return sb.toString();
diff --git a/src/main/java/com/linghu/model/entity/Order.java b/src/main/java/com/linghu/model/entity/Order.java
index f75e0eb..5f11e03 100644
--- a/src/main/java/com/linghu/model/entity/Order.java
+++ b/src/main/java/com/linghu/model/entity/Order.java
@@ -1,6 +1,5 @@
package com.linghu.model.entity;
-import com.baomidou.mybatisplus.annotation.IdType;
import com.baomidou.mybatisplus.annotation.TableField;
import com.baomidou.mybatisplus.annotation.TableId;
import com.baomidou.mybatisplus.annotation.TableName;
@@ -16,15 +15,15 @@
@Data
public class Order implements Serializable {
/**
- * 订单id,格式：日期-数量
+ * 订单id,格式：日期-数量（202506100001）
*/
@TableId
- private String orderId;
+ private String order_id;
/**
* 客户名称
*/
- private String clientName;
+ private String client_name;
/**
* 状态 1-待处理，2-执行中，3-已完成
@@ -34,27 +33,27 @@
/**
* 0-未删除 1-已删除
*/
- private Integer delFlag;
+ private Integer del_flag;
/**
* 提交人
*/
- private String createBy;
+ private String create_by;
/**
* 创建时间
*/
- private Date createTime;
+ private Date create_time;
/**
*
*/
- private String updateBy;
+ private String update_by;
/**
*
*/
- private Date updateTime;
+ private Date update_time;
@TableField(exist = false)
private static final long serialVersionUID = 1L;
@@ -71,28 +70,28 @@
return false;
}
Order other = (Order) that;
- return (this.getOrderId() == null ? other.getOrderId() == null : this.getOrderId().equals(other.getOrderId()))
- && (this.getClientName() == null ? other.getClientName() == null : this.getClientName().equals(other.getClientName()))
+ return (this.getOrder_id() == null ? other.getOrder_id() == null : this.getOrder_id().equals(other.getOrder_id()))
+ && (this.getClient_name() == null ? other.getClient_name() == null : this.getClient_name().equals(other.getClient_name()))
&& (this.getStatus() == null ? other.getStatus() == null : this.getStatus().equals(other.getStatus()))
- && (this.getDelFlag() == null ? other.getDelFlag() == null : this.getDelFlag().equals(other.getDelFlag()))
- && (this.getCreateBy() == null ? other.getCreateBy() == null : this.getCreateBy().equals(other.getCreateBy()))
- && (this.getCreateTime() == null ? other.getCreateTime() == null : this.getCreateTime().equals(other.getCreateTime()))
- && (this.getUpdateBy() == null ? other.getUpdateBy() == null : this.getUpdateBy().equals(other.getUpdateBy()))
- && (this.getUpdateTime() == null ? other.getUpdateTime() == null : this.getUpdateTime().equals(other.getUpdateTime()));
+ && (this.getDel_flag() == null ? other.getDel_flag() == null : this.getDel_flag().equals(other.getDel_flag()))
+ && (this.getCreate_by() == null ? other.getCreate_by() == null : this.getCreate_by().equals(other.getCreate_by()))
+ && (this.getCreate_time() == null ? other.getCreate_time() == null : this.getCreate_time().equals(other.getCreate_time()))
+ && (this.getUpdate_by() == null ? other.getUpdate_by() == null : this.getUpdate_by().equals(other.getUpdate_by()))
+ && (this.getUpdate_time() == null ? other.getUpdate_time() == null : this.getUpdate_time().equals(other.getUpdate_time()));
}
@Override
public int hashCode() {
final int prime = 31;
int result = 1;
- result = prime * result + ((getOrderId() == null) ? 0 : getOrderId().hashCode());
- result = prime * result + ((getClientName() == null) ? 0 : getClientName().hashCode());
+ result = prime * result + ((getOrder_id() == null) ? 0 : getOrder_id().hashCode());
+ result = prime * result + ((getClient_name() == null) ? 0 : getClient_name().hashCode());
result = prime * result + ((getStatus() == null) ? 0 : getStatus().hashCode());
- result = prime * result + ((getDelFlag() == null) ? 0 : getDelFlag().hashCode());
- result = prime * result + ((getCreateBy() == null) ? 0 : getCreateBy().hashCode());
- result = prime * result + ((getCreateTime() == null) ? 0 : getCreateTime().hashCode());
- result = prime * result + ((getUpdateBy() == null) ? 0 : getUpdateBy().hashCode());
- result = prime * result + ((getUpdateTime() == null) ? 0 : getUpdateTime().hashCode());
+ result = prime * result + ((getDel_flag() == null) ? 0 : getDel_flag().hashCode());
+ result = prime * result + ((getCreate_by() == null) ? 0 : getCreate_by().hashCode());
+ result = prime * result + ((getCreate_time() == null) ? 0 : getCreate_time().hashCode());
+ result = prime * result + ((getUpdate_by() == null) ? 0 : getUpdate_by().hashCode());
+ result = prime * result + ((getUpdate_time() == null) ? 0 : getUpdate_time().hashCode());
return result;
}
@@ -102,14 +101,14 @@
sb.append(getClass().getSimpleName());
sb.append(" [");
sb.append("Hash = ").append(hashCode());
- sb.append(", orderId=").append(orderId);
- sb.append(", clientName=").append(clientName);
+ sb.append(", order_id=").append(order_id);
+ sb.append(", client_name=").append(client_name);
sb.append(", status=").append(status);
- sb.append(", delFlag=").append(delFlag);
- sb.append(", createBy=").append(createBy);
- sb.append(", createTime=").append(createTime);
- sb.append(", updateBy=").append(updateBy);
- sb.append(", updateTime=").append(updateTime);
+ sb.append(", del_flag=").append(del_flag);
+ sb.append(", create_by=").append(create_by);
+ sb.append(", create_time=").append(create_time);
+ sb.append(", update_by=").append(update_by);
+ sb.append(", update_time=").append(update_time);
sb.append(", serialVersionUID=").append(serialVersionUID);
sb.append("]");
return sb.toString();
diff --git a/src/main/java/com/linghu/model/entity/Platform.java b/src/main/java/com/linghu/model/entity/Platform.java
new file mode 100644
index 0000000..ffeaa7e
--- /dev/null
+++ b/src/main/java/com/linghu/model/entity/Platform.java
@@ -0,0 +1,133 @@
+package com.linghu.model.entity;
+
+import com.baomidou.mybatisplus.annotation.IdType;
+import com.baomidou.mybatisplus.annotation.TableField;
+import com.baomidou.mybatisplus.annotation.TableId;
+import com.baomidou.mybatisplus.annotation.TableName;
+import java.io.Serializable;
+import java.util.Date;
+import lombok.Data;
+
+/**
+ *
+ * @TableName platfrom
+ */
+@TableName(value = "platform")
+@Data
+public class Platform implements Serializable {
+ /**
+ * 平台id
+ */
+ @TableId(type = IdType.AUTO)
+ private Integer platform_id;
+
+ /**
+ * 类型id
+ */
+ private Integer type_id;
+
+ /**
+ * 平台名称
+ */
+ private String platform_name;
+
+ /**
+ * 平台域名
+ */
+ private String domain;
+
+ /**
+ *
+ */
+ private Date create_time;
+
+ /**
+ *
+ */
+ private String create_by;
+
+ /**
+ *
+ */
+ private Date update_time;
+
+ /**
+ *
+ */
+ private String update_by;
+
+ /**
+ * 0-未删除，1-已删除
+ */
+ private Integer del_flag;
+
+ @TableField(exist = false)
+ private static final long serialVersionUID = 1L;
+
+ @Override
+ public boolean equals(Object that) {
+ if (this == that) {
+ return true;
+ }
+ if (that == null) {
+ return false;
+ }
+ if (getClass() != that.getClass()) {
+ return false;
+ }
+ Platform other = (Platform) that;
+ return (this.getPlatform_id() == null ? other.getPlatform_id() == null
+ : this.getPlatform_id().equals(other.getPlatform_id()))
+ && (this.getType_id() == null ? other.getType_id() == null
+ : this.getType_id().equals(other.getType_id()))
+ && (this.getPlatform_name() == null ? other.getPlatform_name() == null
+ : this.getPlatform_name().equals(other.getPlatform_name()))
+ && (this.getDomain() == null ? other.getDomain() == null : this.getDomain().equals(other.getDomain()))
+ && (this.getCreate_time() == null ? other.getCreate_time() == null
+ : this.getCreate_time().equals(other.getCreate_time()))
+ && (this.getCreate_by() == null ? other.getCreate_by() == null
+ : this.getCreate_by().equals(other.getCreate_by()))
+ && (this.getUpdate_time() == null ? other.getUpdate_time() == null
+ : this.getUpdate_time().equals(other.getUpdate_time()))
+ && (this.getUpdate_by() == null ? other.getUpdate_by() == null
+ : this.getUpdate_by().equals(other.getUpdate_by()))
+ && (this.getDel_flag() == null ? other.getDel_flag() == null
+ : this.getDel_flag().equals(other.getDel_flag()));
+ }
+
+ @Override
+ public int hashCode() {
+ final int prime = 31;
+ int result = 1;
+ result = prime * result + ((getPlatform_id() == null) ? 0 : getPlatform_id().hashCode());
+ result = prime * result + ((getType_id() == null) ? 0 : getType_id().hashCode());
+ result = prime * result + ((getPlatform_name() == null) ? 0 : getPlatform_name().hashCode());
+ result = prime * result + ((getDomain() == null) ? 0 : getDomain().hashCode());
+ result = prime * result + ((getCreate_time() == null) ? 0 : getCreate_time().hashCode());
+ result = prime * result + ((getCreate_by() == null) ? 0 : getCreate_by().hashCode());
+ result = prime * result + ((getUpdate_time() == null) ? 0 : getUpdate_time().hashCode());
+ result = prime * result + ((getUpdate_by() == null) ? 0 : getUpdate_by().hashCode());
+ result = prime * result + ((getDel_flag() == null) ? 0 : getDel_flag().hashCode());
+ return result;
+ }
+
+ @Override
+ public String toString() {
+ StringBuilder sb = new StringBuilder();
+ sb.append(getClass().getSimpleName());
+ sb.append(" [");
+ sb.append("Hash = ").append(hashCode());
+ sb.append(", platform_id=").append(platform_id);
+ sb.append(", type_id=").append(type_id);
+ sb.append(", platform_name=").append(platform_name);
+ sb.append(", domain=").append(domain);
+ sb.append(", create_time=").append(create_time);
+ sb.append(", create_by=").append(create_by);
+ sb.append(", update_time=").append(update_time);
+ sb.append(", update_by=").append(update_by);
+ sb.append(", del_flag=").append(del_flag);
+ sb.append(", serialVersionUID=").append(serialVersionUID);
+ sb.append("]");
+ return sb.toString();
+ }
+}
\ No newline at end of file
diff --git a/src/main/java/com/linghu/model/entity/Platfrom.java b/src/main/java/com/linghu/model/entity/Platfrom.java
deleted file mode 100644
index 0c0ce9e..0000000
--- a/src/main/java/com/linghu/model/entity/Platfrom.java
+++ /dev/null
@@ -1,125 +0,0 @@
-package com.linghu.model.entity;
-
-import com.baomidou.mybatisplus.annotation.IdType;
-import com.baomidou.mybatisplus.annotation.TableField;
-import com.baomidou.mybatisplus.annotation.TableId;
-import com.baomidou.mybatisplus.annotation.TableName;
-import java.io.Serializable;
-import java.util.Date;
-import lombok.Data;
-
-/**
- *
- * @TableName platfrom
- */
-@TableName(value ="platfrom")
-@Data
-public class Platfrom implements Serializable {
- /**
- * 平台id
- */
- @TableId(type = IdType.AUTO)
- private Integer platformId;
-
- /**
- * 类型id
- */
- private Integer typeId;
-
- /**
- * 平台名称
- */
- private String platformName;
-
- /**
- * 网址
- */
- private String platformUrl;
-
- /**
- *
- */
- private Date createTime;
-
- /**
- *
- */
- private String createBy;
-
- /**
- *
- */
- private Date updateTime;
-
- /**
- *
- */
- private String updateBy;
-
- /**
- * 0-未删除，1-已删除
- */
- private Integer delFlag;
-
- @TableField(exist = false)
- private static final long serialVersionUID = 1L;
-
- @Override
- public boolean equals(Object that) {
- if (this == that) {
- return true;
- }
- if (that == null) {
- return false;
- }
- if (getClass() != that.getClass()) {
- return false;
- }
- Platfrom other = (Platfrom) that;
- return (this.getPlatformId() == null ? other.getPlatformId() == null : this.getPlatformId().equals(other.getPlatformId()))
- && (this.getTypeId() == null ? other.getTypeId() == null : this.getTypeId().equals(other.getTypeId()))
- && (this.getPlatformName() == null ? other.getPlatformName() == null : this.getPlatformName().equals(other.getPlatformName()))
- && (this.getPlatformUrl() == null ? other.getPlatformUrl() == null : this.getPlatformUrl().equals(other.getPlatformUrl()))
- && (this.getCreateTime() == null ? other.getCreateTime() == null : this.getCreateTime().equals(other.getCreateTime()))
- && (this.getCreateBy() == null ? other.getCreateBy() == null : this.getCreateBy().equals(other.getCreateBy()))
- && (this.getUpdateTime() == null ? other.getUpdateTime() == null : this.getUpdateTime().equals(other.getUpdateTime()))
- && (this.getUpdateBy() == null ? other.getUpdateBy() == null : this.getUpdateBy().equals(other.getUpdateBy()))
- && (this.getDelFlag() == null ? other.getDelFlag() == null : this.getDelFlag().equals(other.getDelFlag()));
- }
-
- @Override
- public int hashCode() {
- final int prime = 31;
- int result = 1;
- result = prime * result + ((getPlatformId() == null) ? 0 : getPlatformId().hashCode());
- result = prime * result + ((getTypeId() == null) ? 0 : getTypeId().hashCode());
- result = prime * result + ((getPlatformName() == null) ? 0 : getPlatformName().hashCode());
- result = prime * result + ((getPlatformUrl() == null) ? 0 : getPlatformUrl().hashCode());
- result = prime * result + ((getCreateTime() == null) ? 0 : getCreateTime().hashCode());
- result = prime * result + ((getCreateBy() == null) ? 0 : getCreateBy().hashCode());
- result = prime * result + ((getUpdateTime() == null) ? 0 : getUpdateTime().hashCode());
- result = prime * result + ((getUpdateBy() == null) ? 0 : getUpdateBy().hashCode());
- result = prime * result + ((getDelFlag() == null) ? 0 : getDelFlag().hashCode());
- return result;
- }
-
- @Override
- public String toString() {
- StringBuilder sb = new StringBuilder();
- sb.append(getClass().getSimpleName());
- sb.append(" [");
- sb.append("Hash = ").append(hashCode());
- sb.append(", platformId=").append(platformId);
- sb.append(", typeId=").append(typeId);
- sb.append(", platformName=").append(platformName);
- sb.append(", platformUrl=").append(platformUrl);
- sb.append(", createTime=").append(createTime);
- sb.append(", createBy=").append(createBy);
- sb.append(", updateTime=").append(updateTime);
- sb.append(", updateBy=").append(updateBy);
- sb.append(", delFlag=").append(delFlag);
- sb.append(", serialVersionUID=").append(serialVersionUID);
- sb.append("]");
- return sb.toString();
- }
-}
\ No newline at end of file
diff --git a/src/main/java/com/linghu/model/entity/Question.java b/src/main/java/com/linghu/model/entity/Question.java
new file mode 100644
index 0000000..8544350
--- /dev/null
+++ b/src/main/java/com/linghu/model/entity/Question.java
@@ -0,0 +1,133 @@
+package com.linghu.model.entity;
+
+import com.baomidou.mybatisplus.annotation.IdType;
+import com.baomidou.mybatisplus.annotation.TableField;
+import com.baomidou.mybatisplus.annotation.TableId;
+import com.baomidou.mybatisplus.annotation.TableName;
+import java.io.Serializable;
+import java.util.Date;
+import lombok.Data;
+
+/**
+ *
+ * @TableName question
+ */
+@TableName(value ="question")
+@Data
+public class Question implements Serializable {
+ /**
+ * 提问词id
+ */
+ @TableId(type = IdType.AUTO)
+ private Integer question_id;
+
+ /**
+ * 关键词id
+ */
+ private Integer keyword_id;
+
+ /**
+ * 提问词
+ */
+ private String question;
+
+ /**
+ * 提示词状态，（pending：待处理；processing：处理中 ； success：处理成功；failed：处理失败 ）
+ */
+ private String status;
+
+ /**
+ * 提交人
+ */
+ private String user_name;
+
+ /**
+ * 提交人邮箱
+ */
+ private String user_email;
+
+ /**
+ * 采集时间
+ */
+ private Date timestamp;
+
+ /**
+ * 提取的引用数量
+ */
+ private Integer extracted_count;
+
+ /**
+ * AI回复内容
+ */
+ private String response;
+
+ /**
+ * 错误信息
+ */
+ private String error;
+
+ @TableField(exist = false)
+ private static final long serialVersionUID = 1L;
+
+ @Override
+ public boolean equals(Object that) {
+ if (this == that) {
+ return true;
+ }
+ if (that == null) {
+ return false;
+ }
+ if (getClass() != that.getClass()) {
+ return false;
+ }
+ Question other = (Question) that;
+ return (this.getQuestion_id() == null ? other.getQuestion_id() == null : this.getQuestion_id().equals(other.getQuestion_id()))
+ && (this.getKeyword_id() == null ? other.getKeyword_id() == null : this.getKeyword_id().equals(other.getKeyword_id()))
+ && (this.getQuestion() == null ? other.getQuestion() == null : this.getQuestion().equals(other.getQuestion()))
+ && (this.getStatus() == null ? other.getStatus() == null : this.getStatus().equals(other.getStatus()))
+ && (this.getUser_name() == null ? other.getUser_name() == null : this.getUser_name().equals(other.getUser_name()))
+ && (this.getUser_email() == null ? other.getUser_email() == null : this.getUser_email().equals(other.getUser_email()))
+ && (this.getTimestamp() == null ? other.getTimestamp() == null : this.getTimestamp().equals(other.getTimestamp()))
+ && (this.getExtracted_count() == null ? other.getExtracted_count() == null : this.getExtracted_count().equals(other.getExtracted_count()))
+ && (this.getResponse() == null ? other.getResponse() == null : this.getResponse().equals(other.getResponse()))
+ && (this.getError() == null ? other.getError() == null : this.getError().equals(other.getError()));
+ }
+
+ @Override
+ public int hashCode() {
+ final int prime = 31;
+ int result = 1;
+ result = prime * result + ((getQuestion_id() == null) ? 0 : getQuestion_id().hashCode());
+ result = prime * result + ((getKeyword_id() == null) ? 0 : getKeyword_id().hashCode());
+ result = prime * result + ((getQuestion() == null) ? 0 : getQuestion().hashCode());
+ result = prime * result + ((getStatus() == null) ? 0 : getStatus().hashCode());
+ result = prime * result + ((getUser_name() == null) ? 0 : getUser_name().hashCode());
+ result = prime * result + ((getUser_email() == null) ? 0 : getUser_email().hashCode());
+ result = prime * result + ((getTimestamp() == null) ? 0 : getTimestamp().hashCode());
+ result = prime * result + ((getExtracted_count() == null) ? 0 : getExtracted_count().hashCode());
+ result = prime * result + ((getResponse() == null) ? 0 : getResponse().hashCode());
+ result = prime * result + ((getError() == null) ? 0 : getError().hashCode());
+ return result;
+ }
+
+ @Override
+ public String toString() {
+ StringBuilder sb = new StringBuilder();
+ sb.append(getClass().getSimpleName());
+ sb.append(" [");
+ sb.append("Hash = ").append(hashCode());
+ sb.append(", question_id=").append(question_id);
+ sb.append(", keyword_id=").append(keyword_id);
+ sb.append(", question=").append(question);
+ sb.append(", status=").append(status);
+ sb.append(", user_name=").append(user_name);
+ sb.append(", user_email=").append(user_email);
+ sb.append(", timestamp=").append(timestamp);
+ sb.append(", extracted_count=").append(extracted_count);
+ sb.append(", response=").append(response);
+ sb.append(", error=").append(error);
+ sb.append(", serialVersionUID=").append(serialVersionUID);
+ sb.append("]");
+ return sb.toString();
+ }
+}
\ No newline at end of file
diff --git a/src/main/java/com/linghu/model/entity/Reference.java b/src/main/java/com/linghu/model/entity/Reference.java
new file mode 100644
index 0000000..272f955
--- /dev/null
+++ b/src/main/java/com/linghu/model/entity/Reference.java
@@ -0,0 +1,165 @@
+package com.linghu.model.entity;
+
+import com.baomidou.mybatisplus.annotation.TableField;
+import com.baomidou.mybatisplus.annotation.TableId;
+import com.baomidou.mybatisplus.annotation.TableName;
+import java.io.Serializable;
+import java.util.Date;
+import lombok.Data;
+
+/**
+ *
+ * @TableName reference
+ */
+@TableName(value = "reference")
+@Data
+public class Reference implements Serializable {
+ /**
+ * 结果id
+ */
+ @TableId
+ private Integer reference_id;
+
+ /**
+ * 类型id
+ */
+ private Integer type_id;
+
+ /**
+ * 平台id
+ */
+ private Integer platform_id;
+
+ /**
+ * 标题
+ */
+ private String title;
+
+ /**
+ * 重复次数
+ */
+ private Integer repetition_num;
+
+ /**
+ * 创建时间
+ */
+ private Date create_time;
+
+ /**
+ * 采集轮数
+ */
+ private Integer num;
+
+ /**
+ * 来源url
+ */
+ private String url;
+
+ /**
+ * 域名
+ */
+ private String domain;
+
+ /**
+ * 任务id
+ */
+ private String task_id;
+
+ /**
+ * 关键词id
+ */
+ private Integer keyword_id;
+ /**
+ * 问题id
+ */
+ private Integer question_id;
+
+ @TableField(exist = false)
+ private static final long serialVersionUID = 1L;
+
+ public Reference(Integer question_id, String title, String url, String domain, Integer keyword_id, String task_id) {
+ this.question_id = question_id;
+ this.title = title;
+ this.url = url;
+ this.domain = domain;
+ this.task_id = task_id;
+ this.keyword_id = keyword_id;
+
+ }
+
+ @Override
+ public boolean equals(Object that) {
+ if (this == that) {
+ return true;
+ }
+ if (that == null) {
+ return false;
+ }
+ if (getClass() != that.getClass()) {
+ return false;
+ }
+ Reference other = (Reference) that;
+ return (this.getReference_id() == null ? other.getReference_id() == null
+ : this.getReference_id().equals(other.getReference_id()))
+ && (this.getType_id() == null ? other.getType_id() == null
+ : this.getType_id().equals(other.getType_id()))
+ && (this.getPlatform_id() == null ? other.getPlatform_id() == null
+ : this.getPlatform_id().equals(other.getPlatform_id()))
+ && (this.getTitle() == null ? other.getTitle() == null : this.getTitle().equals(other.getTitle()))
+ && (this.getRepetition_num() == null ? other.getRepetition_num() == null
+ : this.getRepetition_num().equals(other.getRepetition_num()))
+ && (this.getCreate_time() == null ? other.getCreate_time() == null
+ : this.getCreate_time().equals(other.getCreate_time()))
+ && (this.getNum() == null ? other.getNum() == null : this.getNum().equals(other.getNum()))
+ && (this.getUrl() == null ? other.getUrl() == null : this.getUrl().equals(other.getUrl()))
+ && (this.getDomain() == null ? other.getDomain() == null : this.getDomain().equals(other.getDomain()))
+ && (this.getTask_id() == null ? other.getTask_id() == null
+ : this.getTask_id().equals(other.getTask_id()))
+ && (this.getKeyword_id() == null ? other.getKeyword_id() == null
+ : this.getKeyword_id().equals(other.getKeyword_id()))
+ && (this.getQuestion_id() == null ? other.getQuestion_id() == null
+ : this.getQuestion_id().equals(other.getQuestion_id()));
+ }
+
+ @Override
+ public int hashCode() {
+ final int prime = 31;
+ int result = 1;
+ result = prime * result + ((getReference_id() == null) ? 0 : getReference_id().hashCode());
+ result = prime * result + ((getType_id() == null) ? 0 : getType_id().hashCode());
+ result = prime * result + ((getPlatform_id() == null) ? 0 : getPlatform_id().hashCode());
+ result = prime * result + ((getTitle() == null) ? 0 : getTitle().hashCode());
+ result = prime * result + ((getRepetition_num() == null) ? 0 : getRepetition_num().hashCode());
+ result = prime * result + ((getCreate_time() == null) ? 0 : getCreate_time().hashCode());
+ result = prime * result + ((getNum() == null) ? 0 : getNum().hashCode());
+ result = prime * result + ((getUrl() == null) ? 0 : getUrl().hashCode());
+ result = prime * result + ((getDomain() == null) ? 0 : getDomain().hashCode());
+ result = prime * result + ((getTask_id() == null) ? 0 : getTask_id().hashCode());
+ result = prime * result + ((getKeyword_id() == null) ? 0 : getKeyword_id().hashCode());
+ result = prime * result + ((getQuestion_id() == null) ? 0 : getQuestion_id().hashCode());
+ return result;
+ }
+
+ @Override
+ public String toString() {
+ StringBuilder sb = new StringBuilder();
+ sb.append(getClass().getSimpleName());
+ sb.append(" [");
+ sb.append("Hash = ").append(hashCode());
+ sb.append(", reference_id=").append(reference_id);
+ sb.append(", type_id=").append(type_id);
+ sb.append(", platform_id=").append(platform_id);
+ sb.append(", title=").append(title);
+ sb.append(", repetition_num=").append(repetition_num);
+ sb.append(", create_time=").append(create_time);
+ sb.append(", num=").append(num);
+ sb.append(", url=").append(url);
+ sb.append(", domain=").append(domain);
+ sb.append(", task_id=").append(task_id);
+ sb.append(", keyword_id=").append(keyword_id);
+ sb.append(", question_id=").append(question_id);
+ sb.append(", serialVersionUID=").append(serialVersionUID);
+ sb.append("]");
+ return sb.toString();
+ }
+}
\ No newline at end of file
diff --git a/src/main/java/com/linghu/model/entity/Result.java b/src/main/java/com/linghu/model/entity/Result.java
deleted file mode 100644
index dad5a1b..0000000
--- a/src/main/java/com/linghu/model/entity/Result.java
+++ /dev/null
@@ -1,117 +0,0 @@
-package com.linghu.model.entity;
-
-import com.baomidou.mybatisplus.annotation.IdType;
-import com.baomidou.mybatisplus.annotation.TableField;
-import com.baomidou.mybatisplus.annotation.TableId;
-import com.baomidou.mybatisplus.annotation.TableName;
-import java.io.Serializable;
-import java.util.Date;
-import lombok.Data;
-
-/**
- *
- * @TableName result
- */
-@TableName(value ="result")
-@Data
-public class Result implements Serializable {
- /**
- * 结果id
- */
- @TableId
- private Integer resultId;
-
- /**
- * 类型id
- */
- private Integer typeId;
-
- /**
- * 平台id
- */
- private Integer platformId;
-
- /**
- * 标题
- */
- private String title;
-
- /**
- * 重复次数
- */
- private Integer repetitionNum;
-
- /**
- * 创建时间
- */
- private Date createTime;
-
- /**
- * 采集轮数
- */
- private Integer num;
-
- /**
- * 来源url
- */
- private String url;
-
- @TableField(exist = false)
- private static final long serialVersionUID = 1L;
-
- @Override
- public boolean equals(Object that) {
- if (this == that) {
- return true;
- }
- if (that == null) {
- return false;
- }
- if (getClass() != that.getClass()) {
- return false;
- }
- Result other = (Result) that;
- return (this.getResultId() == null ? other.getResultId() == null : this.getResultId().equals(other.getResultId()))
- && (this.getTypeId() == null ? other.getTypeId() == null : this.getTypeId().equals(other.getTypeId()))
- && (this.getPlatformId() == null ? other.getPlatformId() == null : this.getPlatformId().equals(other.getPlatformId()))
- && (this.getTitle() == null ? other.getTitle() == null : this.getTitle().equals(other.getTitle()))
- && (this.getRepetitionNum() == null ? other.getRepetitionNum() == null : this.getRepetitionNum().equals(other.getRepetitionNum()))
- && (this.getCreateTime() == null ? other.getCreateTime() == null : this.getCreateTime().equals(other.getCreateTime()))
- && (this.getNum() == null ? other.getNum() == null : this.getNum().equals(other.getNum()))
- && (this.getUrl() == null ? other.getUrl() == null : this.getUrl().equals(other.getUrl()));
- }
-
- @Override
- public int hashCode() {
- final int prime = 31;
- int result = 1;
- result = prime * result + ((getResultId() == null) ? 0 : getResultId().hashCode());
- result = prime * result + ((getTypeId() == null) ? 0 : getTypeId().hashCode());
- result = prime * result + ((getPlatformId() == null) ? 0 : getPlatformId().hashCode());
- result = prime * result + ((getTitle() == null) ? 0 : getTitle().hashCode());
- result = prime * result + ((getRepetitionNum() == null) ? 0 : getRepetitionNum().hashCode());
- result = prime * result + ((getCreateTime() == null) ? 0 : getCreateTime().hashCode());
- result = prime * result + ((getNum() == null) ? 0 : getNum().hashCode());
- result = prime * result + ((getUrl() == null) ? 0 : getUrl().hashCode());
- return result;
- }
-
- @Override
- public String toString() {
- StringBuilder sb = new StringBuilder();
- sb.append(getClass().getSimpleName());
- sb.append(" [");
- sb.append("Hash = ").append(hashCode());
- sb.append(", resultId=").append(resultId);
- sb.append(", typeId=").append(typeId);
- sb.append(", platformId=").append(platformId);
- sb.append(", title=").append(title);
- sb.append(", repetitionNum=").append(repetitionNum);
- sb.append(", createTime=").append(createTime);
- sb.append(", num=").append(num);
- sb.append(", url=").append(url);
- sb.append(", serialVersionUID=").append(serialVersionUID);
- sb.append("]");
- return sb.toString();
- }
-}
\ No newline at end of file
diff --git a/src/main/java/com/linghu/model/entity/Type.java b/src/main/java/com/linghu/model/entity/Type.java
index 17b3c23..406223d 100644
--- a/src/main/java/com/linghu/model/entity/Type.java
+++ b/src/main/java/com/linghu/model/entity/Type.java
@@ -18,59 +18,59 @@
* 类型
*/
@TableId(type = IdType.AUTO)
- private Integer typeId;
+ private Integer type_id;
/**
* 名字
*/
- private String typeName;
+ private String type_name;
/**
* 0-未删除 1-删除
*/
- private Integer delFlag;
+ private Integer del_flag;
@TableField(exist = false)
private static final long serialVersionUID = 1L;
- @Override
- public boolean equals(Object that) {
- if (this == that) {
- return true;
- }
- if (that == null) {
- return false;
- }
- if (getClass() != that.getClass()) {
- return false;
- }
- Type other = (Type) that;
- return (this.getTypeId() == null ? other.getTypeId() == null : this.getTypeId().equals(other.getTypeId()))
- && (this.getTypeName() == null ? other.getTypeName() == null : this.getTypeName().equals(other.getTypeName()))
- && (this.getDelFlag() == null ? other.getDelFlag() == null : this.getDelFlag().equals(other.getDelFlag()));
- }
-
- @Override
- public int hashCode() {
- final int prime = 31;
- int result = 1;
- result = prime * result + ((getTypeId() == null) ? 0 : getTypeId().hashCode());
- result = prime * result + ((getTypeName() == null) ? 0 : getTypeName().hashCode());
- result = prime * result + ((getDelFlag() == null) ? 0 : getDelFlag().hashCode());
- return result;
- }
-
- @Override
- public String toString() {
- StringBuilder sb = new StringBuilder();
- sb.append(getClass().getSimpleName());
- sb.append(" [");
- sb.append("Hash = ").append(hashCode());
- sb.append(", typeId=").append(typeId);
- sb.append(", typeName=").append(typeName);
- sb.append(", delFlag=").append(delFlag);
- sb.append(", serialVersionUID=").append(serialVersionUID);
- sb.append("]");
- return sb.toString();
- }
+// @Override
+// public boolean equals(Object that) {
+// if (this == that) {
+// return true;
+// }
+// if (that == null) {
+// return false;
+// }
+// if (getClass() != that.getClass()) {
+// return false;
+// }
+// Type other = (Type) that;
+// return (this.getType_id() == null ? other.getType_id() == null : this.getType_id().equals(other.getType_id()))
+// && (this.getType_name() == null ? other.getType_name() == null : this.getType_name().equals(other.getType_name()))
+// && (this.getDel_flag() == null ? other.getDel_flag() == null : this.getDel_flag().equals(other.getDel_flag()));
+// }
+//
+// @Override
+// public int hashCode() {
+// final int prime = 31;
+// int result = 1;
+// result = prime * result + ((getType_id() == null) ? 0 : getType_id().hashCode());
+// result = prime * result + ((getType_name() == null) ? 0 : getType_name().hashCode());
+// result = prime * result + ((getDel_flag() == null) ? 0 : getDel_flag().hashCode());
+// return result;
+// }
+//
+// @Override
+// public String toString() {
+// StringBuilder sb = new StringBuilder();
+// sb.append(getClass().getSimpleName());
+// sb.append(" [");
+// sb.append("Hash = ").append(hashCode());
+// sb.append(", type_id=").append(type_id);
+// sb.append(", type_name=").append(type_name);
+// sb.append(", del_flag=").append(del_flag);
+// sb.append(", serialVersionUID=").append(serialVersionUID);
+// sb.append("]");
+// return sb.toString();
+// }
}
\ No newline at end of file
diff --git a/src/main/java/com/linghu/model/entity/User.java b/src/main/java/com/linghu/model/entity/User.java
new file mode 100644
index 0000000..cbc51f6
--- /dev/null
+++ b/src/main/java/com/linghu/model/entity/User.java
@@ -0,0 +1,104 @@
+package com.linghu.model.entity;
+
+import com.baomidou.mybatisplus.annotation.TableField;
+import com.baomidou.mybatisplus.annotation.TableId;
+import com.baomidou.mybatisplus.annotation.TableName;
+import java.io.Serializable;
+
+import javax.validation.constraints.Email;
+import javax.validation.constraints.NotBlank;
+import javax.validation.constraints.Size;
+
+import lombok.Data;
+
+/**
+ *
+ * @TableName user
+ */
+@TableName(value = "user")
+@Data
+public class User implements Serializable {
+ /**
+ * 用户id
+ */
+ @TableId
+ private Integer user_id;
+
+ /**
+ * 用户名
+ */
+ @NotBlank(message = "用户名不能为空")
+ private String user_name;
+
+ /**
+ * 用户邮箱
+ */
+ @NotBlank(message = "邮箱不能为空")
+ @Email(message = "邮箱格式不正确")
+ private String user_email;
+
+ /**
+ * 密码
+ */
+ @NotBlank(message = "密码不能为空")
+ @Size(min = 6, message = "密码长度至少6位")
+ private String password;
+
+ /**
+ * 手机号
+ */
+ private Integer phone;
+
+ @TableField(exist = false)
+ private static final long serialVersionUID = 1L;
+
+ @Override
+ public boolean equals(Object that) {
+ if (this == that) {
+ return true;
+ }
+ if (that == null) {
+ return false;
+ }
+ if (getClass() != that.getClass()) {
+ return false;
+ }
+ User other = (User) that;
+ return (this.getUser_id() == null ? other.getUser_id() == null : this.getUser_id().equals(other.getUser_id()))
+ && (this.getUser_name() == null ? other.getUser_name() == null
+ : this.getUser_name().equals(other.getUser_name()))
+ && (this.getUser_email() == null ? other.getUser_email() == null
+ : this.getUser_email().equals(other.getUser_email()))
+ && (this.getPassword() == null ? other.getPassword() == null
+ : this.getPassword().equals(other.getPassword()))
+ && (this.getPhone() == null ? other.getPhone() == null : this.getPhone().equals(other.getPhone()));
+ }
+
+ @Override
+ public int hashCode() {
+ final int prime = 31;
+ int result = 1;
+ result = prime * result + ((getUser_id() == null) ? 0 : getUser_id().hashCode());
+ result = prime * result + ((getUser_name() == null) ? 0 : getUser_name().hashCode());
+ result = prime * result + ((getUser_email() == null) ? 0 : getUser_email().hashCode());
+ result = prime * result + ((getPassword() == null) ? 0 : getPassword().hashCode());
+ result = prime * result + ((getPhone() == null) ? 0 : getPhone().hashCode());
+ return result;
+ }
+
+ @Override
+ public String toString() {
+ StringBuilder sb = new StringBuilder();
+ sb.append(getClass().getSimpleName());
+ sb.append(" [");
+ sb.append("Hash = ").append(hashCode());
+ sb.append(", user_id=").append(user_id);
+ sb.append(", user_name=").append(user_name);
+ sb.append(", user_email=").append(user_email);
+ sb.append(", password=").append(password);
+ sb.append(", phone=").append(phone);
+ sb.append(", serialVersionUID=").append(serialVersionUID);
+ sb.append("]");
+ return sb.toString();
+ }
+}
\ No newline at end of file
diff --git a/src/main/java/com/linghu/model/excel/PlatformExcel.java b/src/main/java/com/linghu/model/excel/PlatformExcel.java
new file mode 100644
index 0000000..c42a0e2
--- /dev/null
+++ b/src/main/java/com/linghu/model/excel/PlatformExcel.java
@@ -0,0 +1,16 @@
+package com.linghu.model.excel;
+
+import com.alibaba.excel.annotation.ExcelProperty;
+import lombok.Data;
+
+@Data
+public class PlatformExcel {
+ @ExcelProperty("平台名称")
+ private String platform_name;
+
+ @ExcelProperty("发布网址")
+ private String domain;
+
+ @ExcelProperty("类型名称")
+ private String type_name;
+}
\ No newline at end of file
diff --git a/src/main/java/com/linghu/service/CallwordService.java b/src/main/java/com/linghu/service/CallwordService.java
deleted file mode 100644
index f8d82fc..0000000
--- a/src/main/java/com/linghu/service/CallwordService.java
+++ /dev/null
@@ -1,13 +0,0 @@
-package com.linghu.service;
-
-import com.linghu.model.entity.Callword;
-import com.baomidou.mybatisplus.extension.service.IService;
-
-/**
-* @author xy
-* @description 针对表【callword】的数据库操作Service
-* @createDate 2025-07-02 16:32:19
-*/
-public interface CallwordService extends IService<Callword> {
-
-}
diff --git a/src/main/java/com/linghu/service/KeywordService.java b/src/main/java/com/linghu/service/KeywordService.java
index 649d208..10a3ae7 100644
--- a/src/main/java/com/linghu/service/KeywordService.java
+++ b/src/main/java/com/linghu/service/KeywordService.java
@@ -6,7 +6,7 @@
/**
* @author xy
* @description 针对表【keyword】的数据库操作Service
-* @createDate 2025-07-02 16:32:19
+* @createDate 2025-07-04 20:17:33
*/
public interface KeywordService extends IService<Keyword> {
diff --git a/src/main/java/com/linghu/service/OrderService.java b/src/main/java/com/linghu/service/OrderService.java
index fe5079b..6c5ec01 100644
--- a/src/main/java/com/linghu/service/OrderService.java
+++ b/src/main/java/com/linghu/service/OrderService.java
@@ -1,13 +1,22 @@
package com.linghu.service;
import com.linghu.model.entity.Order;
+import com.linghu.model.dto.OrderDto;
import com.baomidou.mybatisplus.extension.service.IService;
/**
-* @author xy
-* @description 针对表【order】的数据库操作Service
-* @createDate 2025-07-02 16:32:19
-*/
+ * @author xy
+ * @description 针对表【order】的数据库操作Service
+ * @createDate 2025-07-04 20:17:33
+ */
public interface OrderService extends IService<Order> {
+ boolean updateOrderWithKeywords(OrderDto orderDto, Integer currentStatus);
+ /**
+ * 保存订单及其关键词
+ *
+ * @param orderDto 订单数据传输对象
+ * @return 是否保存成功
+ */
+ boolean saveOrderWithKeywords(OrderDto orderDto);
}
diff --git a/src/main/java/com/linghu/service/PlatformExcelService.java b/src/main/java/com/linghu/service/PlatformExcelService.java
new file mode 100644
index 0000000..d1992f8
--- /dev/null
+++ b/src/main/java/com/linghu/service/PlatformExcelService.java
@@ -0,0 +1,86 @@
+package com.linghu.service;
+
+import com.alibaba.excel.EasyExcel;
+import com.alibaba.excel.context.AnalysisContext;
+import com.alibaba.excel.read.listener.ReadListener;
+import com.linghu.model.entity.Platform;
+import com.linghu.model.entity.Type;
+import com.linghu.model.excel.PlatformExcel;
+import com.linghu.service.TypeService;
+import com.linghu.service.PlatformService;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
+import org.springframework.web.multipart.MultipartFile;
+
+import javax.servlet.http.HttpServletResponse;
+import java.io.IOException;
+import java.net.URLEncoder;
+import java.util.ArrayList;
+import java.util.Date;
+import java.util.List;
+
+@Service
+public class PlatformExcelService {
+
+ @Autowired
+ private PlatformService platformService;
+
+ @Autowired
+ private TypeService typeService;
+
+ /**
+ * 下载平台导入模板
+ */
+ public void downloadTemplate(HttpServletResponse response) throws IOException {
+ response.setContentType("application/vnd.ms-excel");
+ response.setCharacterEncoding("utf-8");
+ String fileName = URLEncoder.encode("平台导入模板", "UTF-8");
+ response.setHeader("Content-disposition", "attachment;filename=" + fileName + ".xlsx");
+ EasyExcel.write(response.getOutputStream(), PlatformExcel.class).sheet("平台信息").doWrite(new ArrayList<>());
+ }
+
+ /**
+ * 导入平台信息
+ */
+ @Transactional(rollbackFor = Exception.class)
+ public void importPlatform(MultipartFile file) throws IOException {
+ EasyExcel.read(file.getInputStream(), PlatformExcel.class, new ReadListener<PlatformExcel>() {
+ private List<Platform> platforms = new ArrayList<>();
+
+ @Override
+ public void invoke(PlatformExcel data, AnalysisContext context) {
+ // 根据类型名称获取类型ID
+ Type type = typeService.getTypeByName(data.getType_name());
+ if (type == null) {
+ throw new RuntimeException("类型名称不存在：" + data.getType_name());
+ }
+
+ Platform platform = new Platform();
+ platform.setPlatform_name(data.getPlatform_name());
+ platform.setDomain(data.getDomain());
+ platform.setType_id(type.getType_id());
+ platform.setCreate_time(new Date());
+ platform.setDel_flag(0);
+ platforms.add(platform);
+
+ // 每100条保存一次
+ if (platforms.size() >= 100) {
+ saveData();
+ platforms.clear();
+ }
+ }
+
+ @Override
+ public void doAfterAllAnalysed(AnalysisContext context) {
+ saveData();
+ }
+
+ private void saveData() {
+ if (!platforms.isEmpty()) {
+ platformService.saveBatch(platforms);
+ }
+ }
+ }).sheet().doRead();
+ }
+}
\ No newline at end of file
diff --git a/src/main/java/com/linghu/service/PlatformService.java b/src/main/java/com/linghu/service/PlatformService.java
new file mode 100644
index 0000000..0d42b27
--- /dev/null
+++ b/src/main/java/com/linghu/service/PlatformService.java
@@ -0,0 +1,13 @@
+package com.linghu.service;
+
+import com.linghu.model.entity.Platform;
+import com.baomidou.mybatisplus.extension.service.IService;
+
+/**
+ * @author xy
+ * @description 针对表【platfrom】的数据库操作Service
+ * @createDate 2025-07-04 20:17:33
+ */
+public interface PlatformService extends IService<Platform> {
+
+}
diff --git a/src/main/java/com/linghu/service/PlatfromService.java b/src/main/java/com/linghu/service/PlatfromService.java
deleted file mode 100644
index ff5ca71..0000000
--- a/src/main/java/com/linghu/service/PlatfromService.java
+++ /dev/null
@@ -1,13 +0,0 @@
-package com.linghu.service;
-
-import com.linghu.model.entity.Platfrom;
-import com.baomidou.mybatisplus.extension.service.IService;
-
-/**
-* @author xy
-* @description 针对表【platfrom】的数据库操作Service
-* @createDate 2025-07-02 16:32:19
-*/
-public interface PlatfromService extends IService<Platfrom> {
-
-}
diff --git a/src/main/java/com/linghu/service/QuestionService.java b/src/main/java/com/linghu/service/QuestionService.java
new file mode 100644
index 0000000..afbfd54
--- /dev/null
+++ b/src/main/java/com/linghu/service/QuestionService.java
@@ -0,0 +1,13 @@
+package com.linghu.service;
+
+import com.linghu.model.entity.Question;
+import com.baomidou.mybatisplus.extension.service.IService;
+
+/**
+* @author xy
+* @description 针对表【question】的数据库操作Service
+* @createDate 2025-07-04 20:17:33
+*/
+public interface QuestionService extends IService<Question> {
+
+}
diff --git a/src/main/java/com/linghu/service/ReferenceService.java b/src/main/java/com/linghu/service/ReferenceService.java
new file mode 100644
index 0000000..f05bad8
--- /dev/null
+++ b/src/main/java/com/linghu/service/ReferenceService.java
@@ -0,0 +1,13 @@
+package com.linghu.service;
+
+import com.linghu.model.entity.Reference;
+import com.baomidou.mybatisplus.extension.service.IService;
+
+/**
+* @author xy
+* @description 针对表【reference】的数据库操作Service
+* @createDate 2025-07-04 20:17:33
+*/
+public interface ReferenceService extends IService<Reference> {
+
+}
diff --git a/src/main/java/com/linghu/service/ResultService.java b/src/main/java/com/linghu/service/ResultService.java
deleted file mode 100644
index 6603dea..0000000
--- a/src/main/java/com/linghu/service/ResultService.java
+++ /dev/null
@@ -1,13 +0,0 @@
-package com.linghu.service;
-
-import com.linghu.model.entity.Result;
-import com.baomidou.mybatisplus.extension.service.IService;
-
-/**
-* @author xy
-* @description 针对表【result】的数据库操作Service
-* @createDate 2025-07-02 16:32:19
-*/
-public interface ResultService extends IService<Result> {
-
-}
diff --git a/src/main/java/com/linghu/service/TypeService.java b/src/main/java/com/linghu/service/TypeService.java
index 273f5dc..344b147 100644
--- a/src/main/java/com/linghu/service/TypeService.java
+++ b/src/main/java/com/linghu/service/TypeService.java
@@ -3,42 +3,13 @@
import com.linghu.model.entity.Type;
import com.baomidou.mybatisplus.extension.service.IService;
-import java.util.List;
-
/**
* @author xy
* @description 针对表【type】的数据库操作Service
- * @createDate 2025-07-02 16:32:19
+ * @createDate 2025-07-04 20:10:31
*/
public interface TypeService extends IService<Type> {
- /**
- * 批量添加类型
- *
- * @param types 类型列表
- * @return 是否成功
- */
- boolean saveBatch(List<Type> types);
- /**
- * 批量更新类型
- *
- * @param types 类型列表
- * @return 是否成功
- */
- boolean updateBatchById(List<Type> types);
+ public Type getTypeByName(String typeName);
- /**
- * 批量删除类型
- *
- * @param typeIds 类型ID列表
- * @return 是否成功
- */
- boolean removeBatchByIds(List<Integer> typeIds);
-
- /**
- * 获取所有未删除的类型
- *
- * @return 类型列表
- */
- List<Type> listAllAvailable();
}
diff --git a/src/main/java/com/linghu/service/UserService.java b/src/main/java/com/linghu/service/UserService.java
new file mode 100644
index 0000000..3620a0c
--- /dev/null
+++ b/src/main/java/com/linghu/service/UserService.java
@@ -0,0 +1,13 @@
+package com.linghu.service;
+
+import com.linghu.model.entity.User;
+import com.baomidou.mybatisplus.extension.service.IService;
+
+/**
+* @author xy
+* @description 针对表【user】的数据库操作Service
+* @createDate 2025-07-07 10:26:00
+*/
+public interface UserService extends IService<User> {
+
+}
diff --git a/src/main/java/com/linghu/service/impl/CallwordServiceImpl.java b/src/main/java/com/linghu/service/impl/CallwordServiceImpl.java
deleted file mode 100644
index 25485cb..0000000
--- a/src/main/java/com/linghu/service/impl/CallwordServiceImpl.java
+++ /dev/null
@@ -1,22 +0,0 @@
-package com.linghu.service.impl;
-
-import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
-import com.linghu.model.entity.Callword;
-import com.linghu.service.CallwordService;
-import com.linghu.mapper.CallwordMapper;
-import org.springframework.stereotype.Service;
-
-/**
-* @author xy
-* @description 针对表【callword】的数据库操作Service实现
-* @createDate 2025-07-02 16:32:19
-*/
-@Service
-public class CallwordServiceImpl extends ServiceImpl<CallwordMapper, Callword>
- implements CallwordService{
-
-}
-
-
-
-
diff --git a/src/main/java/com/linghu/service/impl/KeywordServiceImpl.java b/src/main/java/com/linghu/service/impl/KeywordServiceImpl.java
index dbd234b..125bc52 100644
--- a/src/main/java/com/linghu/service/impl/KeywordServiceImpl.java
+++ b/src/main/java/com/linghu/service/impl/KeywordServiceImpl.java
@@ -9,7 +9,7 @@
/**
* @author xy
* @description 针对表【keyword】的数据库操作Service实现
-* @createDate 2025-07-02 16:32:19
+* @createDate 2025-07-04 20:17:33
*/
@Service
public class KeywordServiceImpl extends ServiceImpl<KeywordMapper, Keyword>
diff --git a/src/main/java/com/linghu/service/impl/OrderServiceImpl.java b/src/main/java/com/linghu/service/impl/OrderServiceImpl.java
index bcc381f..e8fa8ba 100644
--- a/src/main/java/com/linghu/service/impl/OrderServiceImpl.java
+++ b/src/main/java/com/linghu/service/impl/OrderServiceImpl.java
@@ -1,22 +1,88 @@
package com.linghu.service.impl;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import com.linghu.model.dto.OrderDto;
+import com.linghu.model.entity.Keyword;
import com.linghu.model.entity.Order;
+import com.linghu.service.KeywordService;
import com.linghu.service.OrderService;
import com.linghu.mapper.OrderMapper;
+import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
+import org.springframework.util.StringUtils;
/**
-* @author xy
-* @description 针对表【order】的数据库操作Service实现
-* @createDate 2025-07-02 16:32:19
-*/
+ * @author xy
+ * @description 针对表【order】的数据库操作Service实现
+ * @createDate 2025-07-04 20:17:33
+ */
@Service
public class OrderServiceImpl extends ServiceImpl<OrderMapper, Order>
- implements OrderService{
+ implements OrderService {
+ @Autowired
+ private KeywordService keywordService;
+
+ @Override
+ @Transactional(rollbackFor = Exception.class)
+ public boolean saveOrderWithKeywords(OrderDto orderDto) {
+ // 保存订单
+ if (!this.save(orderDto)) {
+ return false;
+ }
+
+ // 如果有关键词，则保存关键词
+ if (StringUtils.hasText(orderDto.getKeywords())) {
+ String[] keywordArray = orderDto.getKeywords().split("\\n");
+ for (String keywordName : keywordArray) {
+ if (StringUtils.hasText(keywordName)) {
+ Keyword keyword = new Keyword();
+ keyword.setOrder_id(orderDto.getOrder_id());
+ keyword.setKeyword_name(keywordName.trim());
+ keyword.setStatus("notSubmitted");
+ // keyword.setNum(1); // 默认采集轮数为1
+ keywordService.save(keyword);
+ }
+ }
+ }
+
+ return true;
+ }
+
+ @Override
+ @Transactional(rollbackFor = Exception.class)
+ public boolean updateOrderWithKeywords(OrderDto orderDto, Integer currentStatus) {
+ // 状态为2或3时禁止修改
+ if (currentStatus >= 2) {
+ throw new RuntimeException("执行中和已完成状态的订单不可修改");
+ }
+
+ // 更新订单基本信息
+ if (!this.updateById(orderDto)) {
+ return false;
+ }
+
+ // 删除旧关键词（当状态为1时允许修改关键词）
+ keywordService.lambdaUpdate()
+ .eq(Keyword::getOrder_id, orderDto.getOrder_id())
+ .eq(Keyword::getStatus, "notSubmitted")
+ .remove();
+
+ // 保存新关键词
+ if (StringUtils.hasText(orderDto.getKeywords())) {
+ String[] keywordArray = orderDto.getKeywords().split("\\n");
+ for (String keywordName : keywordArray) {
+ if (StringUtils.hasText(keywordName)) {
+ Keyword keyword = new Keyword();
+ keyword.setOrder_id(orderDto.getOrder_id());
+ keyword.setKeyword_name(keywordName.trim());
+ keyword.setStatus("notSubmitted");
+ keywordService.save(keyword);
+ }
+ }
+ }
+
+ return true;
+ }
}
-
-
-
-
diff --git a/src/main/java/com/linghu/service/impl/PlatformServiceImpl.java b/src/main/java/com/linghu/service/impl/PlatformServiceImpl.java
new file mode 100644
index 0000000..99482ba
--- /dev/null
+++ b/src/main/java/com/linghu/service/impl/PlatformServiceImpl.java
@@ -0,0 +1,18 @@
+package com.linghu.service.impl;
+
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import com.linghu.model.entity.Platform;
+import com.linghu.service.PlatformService;
+import com.linghu.mapper.PlatformMapper;
+import org.springframework.stereotype.Service;
+
+/**
+ * @author xy
+ * @description 针对表【platfrom】的数据库操作Service实现
+ * @createDate 2025-07-04 20:17:33
+ */
+@Service
+public class PlatformServiceImpl extends ServiceImpl<PlatformMapper, Platform>
+ implements PlatformService {
+
+}
diff --git a/src/main/java/com/linghu/service/impl/PlatfromServiceImpl.java b/src/main/java/com/linghu/service/impl/PlatfromServiceImpl.java
deleted file mode 100644
index 71fb7a7..0000000
--- a/src/main/java/com/linghu/service/impl/PlatfromServiceImpl.java
+++ /dev/null
@@ -1,22 +0,0 @@
-package com.linghu.service.impl;
-
-import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
-import com.linghu.model.entity.Platfrom;
-import com.linghu.service.PlatfromService;
-import com.linghu.mapper.PlatfromMapper;
-import org.springframework.stereotype.Service;
-
-/**
-* @author xy
-* @description 针对表【platfrom】的数据库操作Service实现
-* @createDate 2025-07-02 16:32:19
-*/
-@Service
-public class PlatfromServiceImpl extends ServiceImpl<PlatfromMapper, Platfrom>
- implements PlatfromService{
-
-}
-
-
-
-
diff --git a/src/main/java/com/linghu/service/impl/QuestionServiceImpl.java b/src/main/java/com/linghu/service/impl/QuestionServiceImpl.java
new file mode 100644
index 0000000..f6ec1bf
--- /dev/null
+++ b/src/main/java/com/linghu/service/impl/QuestionServiceImpl.java
@@ -0,0 +1,22 @@
+package com.linghu.service.impl;
+
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import com.linghu.model.entity.Question;
+import com.linghu.service.QuestionService;
+import com.linghu.mapper.QuestionMapper;
+import org.springframework.stereotype.Service;
+
+/**
+* @author xy
+* @description 针对表【question】的数据库操作Service实现
+* @createDate 2025-07-04 20:17:33
+*/
+@Service
+public class QuestionServiceImpl extends ServiceImpl<QuestionMapper, Question>
+ implements QuestionService{
+
+}
+
+
+
+
diff --git a/src/main/java/com/linghu/service/impl/ReferenceServiceImpl.java b/src/main/java/com/linghu/service/impl/ReferenceServiceImpl.java
new file mode 100644
index 0000000..c0cd7d3
--- /dev/null
+++ b/src/main/java/com/linghu/service/impl/ReferenceServiceImpl.java
@@ -0,0 +1,22 @@
+package com.linghu.service.impl;
+
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import com.linghu.model.entity.Reference;
+import com.linghu.service.ReferenceService;
+import com.linghu.mapper.ReferenceMapper;
+import org.springframework.stereotype.Service;
+
+/**
+* @author xy
+* @description 针对表【reference】的数据库操作Service实现
+* @createDate 2025-07-04 20:17:33
+*/
+@Service
+public class ReferenceServiceImpl extends ServiceImpl<ReferenceMapper, Reference>
+ implements ReferenceService{
+
+}
+
+
+
+
diff --git a/src/main/java/com/linghu/service/impl/ResultServiceImpl.java b/src/main/java/com/linghu/service/impl/ResultServiceImpl.java
deleted file mode 100644
index 5604ddd..0000000
--- a/src/main/java/com/linghu/service/impl/ResultServiceImpl.java
+++ /dev/null
@@ -1,22 +0,0 @@
-package com.linghu.service.impl;
-
-import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
-import com.linghu.model.entity.Result;
-import com.linghu.service.ResultService;
-import com.linghu.mapper.ResultMapper;
-import org.springframework.stereotype.Service;
-
-/**
-* @author xy
-* @description 针对表【result】的数据库操作Service实现
-* @createDate 2025-07-02 16:32:19
-*/
-@Service
-public class ResultServiceImpl extends ServiceImpl<ResultMapper, Result>
- implements ResultService{
-
-}
-
-
-
-
diff --git a/src/main/java/com/linghu/service/impl/TypeServiceImpl.java b/src/main/java/com/linghu/service/impl/TypeServiceImpl.java
index d90f3a0..742ef35 100644
--- a/src/main/java/com/linghu/service/impl/TypeServiceImpl.java
+++ b/src/main/java/com/linghu/service/impl/TypeServiceImpl.java
@@ -1,49 +1,33 @@
package com.linghu.service.impl;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
+import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.linghu.model.entity.Type;
import com.linghu.service.TypeService;
import com.linghu.mapper.TypeMapper;
import org.springframework.stereotype.Service;
-import org.springframework.transaction.annotation.Transactional;
-import java.util.List;
+import javax.annotation.Resource;
/**
* @author xy
* @description 针对表【type】的数据库操作Service实现
- * @createDate 2025-07-02 16:32:19
+ * @createDate 2025-07-04 20:10:31
*/
@Service
public class TypeServiceImpl extends ServiceImpl<TypeMapper, Type>
implements TypeService {
-
+ @Resource
+ private TypeMapper typeMapper;
@Override
- @Transactional(rollbackFor = Exception.class)
- public boolean saveBatch(List<Type> types) {
- types.forEach(type -> type.setDelFlag(0));
- return super.saveBatch(types);
- }
-
- @Override
- @Transactional(rollbackFor = Exception.class)
- public boolean updateBatchById(List<Type> types) {
- return super.updateBatchById(types);
- }
-
- @Override
- @Transactional(rollbackFor = Exception.class)
- public boolean removeBatchByIds(List<Integer> typeIds) {
- List<Type> types = this.listByIds(typeIds);
- types.forEach(type -> type.setDelFlag(1));
- return this.updateBatchById(types);
- }
-
- @Override
- public List<Type> listAllAvailable() {
+ public Type getTypeByName(String typeName) {
+ // 查询
LambdaQueryWrapper<Type> queryWrapper = new LambdaQueryWrapper<>();
- queryWrapper.eq(Type::getDelFlag, 0);
- return this.list(queryWrapper);
+ queryWrapper.eq(Type::getType_name, typeName);
+ queryWrapper.eq(Type::getDel_flag, 0);
+ return typeMapper.selectOne(queryWrapper);
+
}
+
}
diff --git a/src/main/java/com/linghu/service/impl/UserServiceImpl.java b/src/main/java/com/linghu/service/impl/UserServiceImpl.java
new file mode 100644
index 0000000..cc52375
--- /dev/null
+++ b/src/main/java/com/linghu/service/impl/UserServiceImpl.java
@@ -0,0 +1,22 @@
+package com.linghu.service.impl;
+
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import com.linghu.model.entity.User;
+import com.linghu.service.UserService;
+import com.linghu.mapper.UserMapper;
+import org.springframework.stereotype.Service;
+
+/**
+* @author xy
+* @description 针对表【user】的数据库操作Service实现
+* @createDate 2025-07-07 10:26:00
+*/
+@Service
+public class UserServiceImpl extends ServiceImpl<UserMapper, User>
+ implements UserService{
+
+}
+
+
+
+
diff --git a/src/main/java/com/linghu/utils/JwtUtils.java b/src/main/java/com/linghu/utils/JwtUtils.java
new file mode 100644
index 0000000..408f751
--- /dev/null
+++ b/src/main/java/com/linghu/utils/JwtUtils.java
@@ -0,0 +1,86 @@
+package com.linghu.utils;
+
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.stereotype.Component;
+
+import com.linghu.model.entity.User;
+
+import io.jsonwebtoken.Claims;
+import io.jsonwebtoken.ExpiredJwtException;
+import io.jsonwebtoken.Jwts;
+import io.jsonwebtoken.MalformedJwtException;
+import io.jsonwebtoken.SignatureAlgorithm;
+import io.jsonwebtoken.UnsupportedJwtException;
+import io.jsonwebtoken.security.Keys;
+import io.jsonwebtoken.security.SignatureException;
+
+import javax.crypto.SecretKey;
+import java.util.Date;
+import java.util.Map;
+
+@Component
+public class JwtUtils {
+ @Value("${jwt.secret}")
+ private final String secret;
+
+ @Value("${jwt.expiration}")
+ private final Long expiration;
+
+ // 生成安全的密钥
+ private SecretKey getSigningKey() {
+ return Keys.hmacShaKeyFor(secret.getBytes());
+ }
+
+ // 通过构造函数注入配置值
+ public JwtUtils(
+ @Value("${jwt.secret}") String secret,
+ @Value("${jwt.expiration}") long expiration) {
+
+ this.secret = secret;
+ this.expiration = expiration;
+ }
+
+ public String generateToken(User user) {
+ SecretKey key = Keys.hmacShaKeyFor(secret.getBytes());
+
+ return Jwts.builder()
+ .setSubject(user.getUser_name())
+ .claim("email", user.getUser_email())
+ .setIssuedAt(new Date())
+ .setExpiration(new Date(System.currentTimeMillis() + expiration * 1000))
+ .signWith(key, SignatureAlgorithm.HS256)
+ .compact();
+ }
+
+ public User parseToken(String token)
+ throws ExpiredJwtException, UnsupportedJwtException,
+ MalformedJwtException, SignatureException, IllegalArgumentException {
+
+ Claims claims = Jwts.parser()
+ .setSigningKey(getSigningKey())
+ .build()
+ .parseClaimsJws(token)
+ .getBody();
+
+ // 创建User对象并填充数据
+ User user = new User();
+ user.setUser_name(claims.getSubject()); // 主题是用户名
+ user.setUser_email(claims.get("email", String.class));
+
+ // 添加角色信息（如果存在）
+ // if (claims.containsKey("roles")) {
+ // user.setRoles(claims.get("roles", String.class));
+ // }
+
+ return user;
+ }
+
+ public boolean validateToken(String token) {
+ try {
+ parseToken(token);
+ return true;
+ } catch (Exception e) {
+ return false;
+ }
+ }
+}
\ No newline at end of file
diff --git a/src/main/resources/application.yml b/src/main/resources/application.yml
index 241490e..ecda751 100644
--- a/src/main/resources/application.yml
+++ b/src/main/resources/application.yml
@@ -1,14 +1,29 @@
server:
port: 8080
-
+# JWT配置
+jwt:
+ secret: linghu-system-mySuperSecretKeyThatIsAtLeast-key-2024
+ expiration: 3600
spring:
datasource:
url: jdbc:mysql://192.168.110.21:3306/linghu_geo_system?useSSL=false&serverTimezone=Asia/Shanghai&allowPublicKeyRetrieval=true&characterEncoding=UTF-8
+ # url: jdbc:mysql://127.0.0.1:3306/linghu?useSSL=false&serverTimezone=Asia/Shanghai&allowPublicKeyRetrieval=true&characterEncoding=UTF-8
username: root
password: "123456"
driver-class-name: com.mysql.cj.jdbc.Driver
mvc:
pathmatch:
matching-strategy: ant_path_matcher # 使用 AntPathMatcher 替代 PathPatternMatcher
+mybatis-plus:
+ global-config:
+ db-config:
+ logic-delete-field: del_flag #默认deleted
+ logic-delete-value: 1
+ logic-not-delete-value: 0
+ configuration:
+ map-underscore-to-camel-case: false
+
+linghu:
+ url: http://182.92.208.99:8000/api/v1
\ No newline at end of file
diff --git a/src/main/resources/mapper/CallwordMapper.xml b/src/main/resources/mapper/CallwordMapper.xml
deleted file mode 100644
index 1e5799f..0000000
--- a/src/main/resources/mapper/CallwordMapper.xml
+++ /dev/null
@@ -1,18 +0,0 @@
-<?xml version="1.0" encoding="UTF-8"?>
-<!DOCTYPE mapper
- PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
- "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
-<mapper namespace="com.linghu.mapper.CallwordMapper">
-
- <resultMap id="BaseResultMap" type="com.linghu.model.entity.Callword">
- <id property="callwordId" column="callword_id" jdbcType="VARCHAR"/>
- <result property="keywordId" column="keyword_id" jdbcType="INTEGER"/>
- <result property="callwordName" column="callword_name" jdbcType="VARCHAR"/>
- <result property="status" column="status" jdbcType="VARCHAR"/>
- </resultMap>
-
- <sql id="Base_Column_List">
- callword_id,keyword_id,callword_name,
- status
- </sql>
-</mapper>
diff --git a/src/main/resources/mapper/KeywordMapper.xml b/src/main/resources/mapper/KeywordMapper.xml
deleted file mode 100644
index 2ff08a9..0000000
--- a/src/main/resources/mapper/KeywordMapper.xml
+++ /dev/null
@@ -1,18 +0,0 @@
-<?xml version="1.0" encoding="UTF-8"?>
-<!DOCTYPE mapper
- PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
- "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
-<mapper namespace="com.linghu.mapper.KeywordMapper">
-
- <resultMap id="BaseResultMap" type="com.linghu.model.entity.Keyword">
- <id property="keywordId" column="keyword_id" jdbcType="INTEGER"/>
- <result property="orderId" column="order_id" jdbcType="VARCHAR"/>
- <result property="keywordName" column="keyword_name" jdbcType="VARCHAR"/>
- <result property="num" column="num" jdbcType="INTEGER"/>
- </resultMap>
-
- <sql id="Base_Column_List">
- keyword_id,order_id,keyword_name,
- num
- </sql>
-</mapper>
diff --git a/src/main/resources/mapper/OrderMapper.xml b/src/main/resources/mapper/OrderMapper.xml
index d3c988c..244104a 100644
--- a/src/main/resources/mapper/OrderMapper.xml
+++ b/src/main/resources/mapper/OrderMapper.xml
@@ -5,14 +5,14 @@
<mapper namespace="com.linghu.mapper.OrderMapper">
<resultMap id="BaseResultMap" type="com.linghu.model.entity.Order">
- <id property="orderId" column="order_id" jdbcType="VARCHAR"/>
- <result property="clientName" column="client_name" jdbcType="VARCHAR"/>
+ <id property="order_id" column="order_id" jdbcType="VARCHAR"/>
+ <result property="client_name" column="client_name" jdbcType="VARCHAR"/>
<result property="status" column="status" jdbcType="TINYINT"/>
- <result property="delFlag" column="del_flag" jdbcType="TINYINT"/>
- <result property="createBy" column="create_by" jdbcType="VARCHAR"/>
- <result property="createTime" column="create_time" jdbcType="TIMESTAMP"/>
- <result property="updateBy" column="update_by" jdbcType="VARCHAR"/>
- <result property="updateTime" column="update_time" jdbcType="TIMESTAMP"/>
+ <result property="del_flag" column="del_flag" jdbcType="TINYINT"/>
+ <result property="create_by" column="create_by" jdbcType="VARCHAR"/>
+ <result property="create_time" column="create_time" jdbcType="TIMESTAMP"/>
+ <result property="update_by" column="update_by" jdbcType="VARCHAR"/>
+ <result property="update_time" column="update_time" jdbcType="TIMESTAMP"/>
</resultMap>
<sql id="Base_Column_List">
diff --git a/src/main/resources/mapper/PlatformMapper.xml b/src/main/resources/mapper/PlatformMapper.xml
new file mode 100644
index 0000000..87a815d
--- /dev/null
+++ b/src/main/resources/mapper/PlatformMapper.xml
@@ -0,0 +1,24 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<!DOCTYPE mapper
+ PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
+ "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
+<mapper namespace="com.linghu.mapper.PlatformMapper">
+
+ <resultMap id="BaseResultMap" type="com.linghu.model.entity.Platform">
+ <id property="platform_id" column="platform_id" jdbcType="INTEGER"/>
+ <result property="type_id" column="type_id" jdbcType="INTEGER"/>
+ <result property="platform_name" column="platform_name" jdbcType="VARCHAR"/>
+ <result property="domain" column="domain" jdbcType="VARCHAR"/>
+ <result property="create_time" column="create_time" jdbcType="TIMESTAMP"/>
+ <result property="create_by" column="create_by" jdbcType="VARCHAR"/>
+ <result property="update_time" column="update_time" jdbcType="TIMESTAMP"/>
+ <result property="update_by" column="update_by" jdbcType="VARCHAR"/>
+ <result property="del_flag" column="del_flag" jdbcType="TINYINT"/>
+ </resultMap>
+
+ <sql id="Base_Column_List">
+ platform_id,type_id,platform_name,
+ domain,create_time,create_by,
+ update_time,update_by,del_flag
+ </sql>
+</mapper>
diff --git a/src/main/resources/mapper/PlatfromMapper.xml b/src/main/resources/mapper/PlatfromMapper.xml
deleted file mode 100644
index bb17dd4..0000000
--- a/src/main/resources/mapper/PlatfromMapper.xml
+++ /dev/null
@@ -1,24 +0,0 @@
-<?xml version="1.0" encoding="UTF-8"?>
-<!DOCTYPE mapper
- PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
- "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
-<mapper namespace="com.linghu.mapper.PlatfromMapper">
-
- <resultMap id="BaseResultMap" type="com.linghu.model.entity.Platfrom">
- <id property="platformId" column="platform_id" jdbcType="INTEGER"/>
- <result property="typeId" column="type_id" jdbcType="INTEGER"/>
- <result property="platformName" column="platform_name" jdbcType="VARCHAR"/>
- <result property="platformUrl" column="platform_url" jdbcType="VARCHAR"/>
- <result property="createTime" column="create_time" jdbcType="TIMESTAMP"/>
- <result property="createBy" column="create_by" jdbcType="VARCHAR"/>
- <result property="updateTime" column="update_time" jdbcType="TIMESTAMP"/>
- <result property="updateBy" column="update_by" jdbcType="VARCHAR"/>
- <result property="delFlag" column="del_flag" jdbcType="TINYINT"/>
- </resultMap>
-
- <sql id="Base_Column_List">
- platform_id,type_id,platform_name,
- platform_url,create_time,create_by,
- update_time,update_by,del_flag
- </sql>
-</mapper>
diff --git a/src/main/resources/mapper/QuestionMapper.xml b/src/main/resources/mapper/QuestionMapper.xml
new file mode 100644
index 0000000..dec797d
--- /dev/null
+++ b/src/main/resources/mapper/QuestionMapper.xml
@@ -0,0 +1,26 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<!DOCTYPE mapper
+ PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
+ "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
+<mapper namespace="com.linghu.mapper.QuestionMapper">
+
+ <resultMap id="BaseResultMap" type="com.linghu.model.entity.Question">
+ <id property="question_id" column="question_id" jdbcType="INTEGER"/>
+ <result property="keyword_id" column="keyword_id" jdbcType="INTEGER"/>
+ <result property="question" column="question" jdbcType="VARCHAR"/>
+ <result property="status" column="status" jdbcType="VARCHAR"/>
+ <result property="user_name" column="user_name" jdbcType="VARCHAR"/>
+ <result property="user_email" column="user_email" jdbcType="VARCHAR"/>
+ <result property="timestamp" column="timestamp" jdbcType="TIMESTAMP"/>
+ <result property="extracted_count" column="extracted_count" jdbcType="INTEGER"/>
+ <result property="response" column="response" jdbcType="VARCHAR"/>
+ <result property="error" column="error" jdbcType="VARCHAR"/>
+ </resultMap>
+
+ <sql id="Base_Column_List">
+ question_id,keyword_id,question,
+ status,user_name,user_email,
+ timestamp,extracted_count,response,
+ error
+ </sql>
+</mapper>
diff --git a/src/main/resources/mapper/ReferenceMapper.xml b/src/main/resources/mapper/ReferenceMapper.xml
new file mode 100644
index 0000000..1fae3f4
--- /dev/null
+++ b/src/main/resources/mapper/ReferenceMapper.xml
@@ -0,0 +1,26 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<!DOCTYPE mapper
+ PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
+ "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
+<mapper namespace="com.linghu.mapper.ReferenceMapper">
+
+ <resultMap id="BaseResultMap" type="com.linghu.model.entity.Reference">
+ <id property="reference_id" column="reference_id" jdbcType="INTEGER"/>
+ <result property="type_id" column="type_id" jdbcType="INTEGER"/>
+ <result property="platform_id" column="platform_id" jdbcType="INTEGER"/>
+ <result property="title" column="title" jdbcType="VARCHAR"/>
+ <result property="repetition_num" column="repetition_num" jdbcType="INTEGER"/>
+ <result property="create_time" column="create_time" jdbcType="TIMESTAMP"/>
+ <result property="num" column="num" jdbcType="INTEGER"/>
+ <result property="url" column="url" jdbcType="VARCHAR"/>
+ <result property="domain" column="domain" jdbcType="VARCHAR"/>
+ <result property="task_id" column="task_id" jdbcType="VARCHAR"/>
+ </resultMap>
+
+ <sql id="Base_Column_List">
+ reference_id,type_id,platform_id,
+ title,repetition_num,create_time,
+ num,url,domain,
+ task_id
+ </sql>
+</mapper>
diff --git a/src/main/resources/mapper/ResultMapper.xml b/src/main/resources/mapper/ResultMapper.xml
deleted file mode 100644
index 2ed5caa..0000000
--- a/src/main/resources/mapper/ResultMapper.xml
+++ /dev/null
@@ -1,23 +0,0 @@
-<?xml version="1.0" encoding="UTF-8"?>
-<!DOCTYPE mapper
- PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
- "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
-<mapper namespace="com.linghu.mapper.ResultMapper">
-
- <resultMap id="BaseResultMap" type="com.linghu.model.entity.Result">
- <id property="resultId" column="result_id" jdbcType="INTEGER"/>
- <result property="typeId" column="type_id" jdbcType="INTEGER"/>
- <result property="platformId" column="platform_id" jdbcType="INTEGER"/>
- <result property="title" column="title" jdbcType="VARCHAR"/>
- <result property="repetitionNum" column="repetition_num" jdbcType="INTEGER"/>
- <result property="createTime" column="create_time" jdbcType="TIMESTAMP"/>
- <result property="num" column="num" jdbcType="INTEGER"/>
- <result property="url" column="url" jdbcType="VARCHAR"/>
- </resultMap>
-
- <sql id="Base_Column_List">
- result_id,type_id,platform_id,
- title,repetition_num,create_time,
- num,url
- </sql>
-</mapper>
diff --git a/src/main/resources/mapper/TypeMapper.xml b/src/main/resources/mapper/TypeMapper.xml
index 21d8ff1..2108366 100644
--- a/src/main/resources/mapper/TypeMapper.xml
+++ b/src/main/resources/mapper/TypeMapper.xml
@@ -5,9 +5,9 @@
<mapper namespace="com.linghu.mapper.TypeMapper">
<resultMap id="BaseResultMap" type="com.linghu.model.entity.Type">
- <id property="typeId" column="type_id" jdbcType="INTEGER"/>
- <result property="typeName" column="type_name" jdbcType="VARCHAR"/>
- <result property="delFlag" column="del_flag" jdbcType="TINYINT"/>
+ <id property="type_id" column="type_id" jdbcType="INTEGER"/>
+ <result property="type_name" column="type_name" jdbcType="VARCHAR"/>
+ <result property="del_flag" column="del_flag" jdbcType="TINYINT"/>
</resultMap>
<sql id="Base_Column_List">
diff --git a/src/main/resources/mapper/UserMapper.xml b/src/main/resources/mapper/UserMapper.xml
new file mode 100644
index 0000000..a4819c2
--- /dev/null
+++ b/src/main/resources/mapper/UserMapper.xml
@@ -0,0 +1,19 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<!DOCTYPE mapper
+ PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
+ "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
+<mapper namespace="com.linghu.mapper.UserMapper">
+
+ <resultMap id="BaseResultMap" type="com.linghu.model.entity.User">
+ <id property="user_id" column="user_id" jdbcType="INTEGER"/>
+ <result property="user_name" column="user_name" jdbcType="VARCHAR"/>
+ <result property="user_email" column="user_email" jdbcType="VARCHAR"/>
+ <result property="password" column="password" jdbcType="VARCHAR"/>
+ <result property="phone" column="phone" jdbcType="INTEGER"/>
+ </resultMap>
+
+ <sql id="Base_Column_List">
+ user_id,user_name,user_email,
+ password,phone
+ </sql>
+</mapper>
diff --git a/src/main/resources/mapper/keywordMapper.xml b/src/main/resources/mapper/keywordMapper.xml
new file mode 100644
index 0000000..e8516a1
--- /dev/null
+++ b/src/main/resources/mapper/keywordMapper.xml
@@ -0,0 +1,20 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<!DOCTYPE mapper
+ PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
+ "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
+<mapper namespace="com.linghu.mapper.KeywordMapper">
+
+ <resultMap id="BaseResultMap" type="com.linghu.model.entity.Keyword">
+ <id property="keyword_id" column="keyword_id" jdbcType="INTEGER"/>
+ <result property="order_id" column="order_id" jdbcType="VARCHAR"/>
+ <result property="keyword_name" column="keyword_name" jdbcType="VARCHAR"/>
+ <result property="num" column="num" jdbcType="INTEGER"/>
+ <result property="task_id" column="task_id" jdbcType="VARCHAR"/>
+ <result property="status" column="status" jdbcType="VARCHAR"/>
+ </resultMap>
+
+ <sql id="Base_Column_List">
+ keyword_id,order_id,keyword_name,
+ num,task_id,status
+ </sql>
+</mapper>
diff --git a/src/main/resources/schema.sql b/src/main/resources/schema.sql
new file mode 100644
index 0000000..25a4d0c
--- /dev/null
+++ b/src/main/resources/schema.sql
@@ -0,0 +1,42 @@
+-- 订单表
+CREATE TABLE IF NOT EXISTS `order` (
+ `order_id` varchar(20) NOT NULL COMMENT '订单ID',
+ `client_name` varchar(100) NOT NULL COMMENT '客户名称',
+ `status` int(1) NOT NULL DEFAULT 1 COMMENT '状态：1-待处理',
+ `del_flag` int(1) NOT NULL DEFAULT 0 COMMENT '删除标记：0-未删除，1-已删除',
+ `create_time` datetime NOT NULL COMMENT '创建时间',
+ `update_time` datetime DEFAULT NULL COMMENT '更新时间',
+ PRIMARY KEY (`order_id`)
+) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COMMENT='订单表';
+
+-- 平台表
+CREATE TABLE IF NOT EXISTS `platform` (
+ `platform_id` int(11) NOT NULL AUTO_INCREMENT COMMENT '平台ID',
+ `platform_name` varchar(100) NOT NULL COMMENT '平台名称',
+ `domain` varchar(100) NOT NULL COMMENT '平台域名',
+ `del_flag` int(1) NOT NULL DEFAULT 0 COMMENT '删除标记：0-未删除，1-已删除',
+ `create_time` datetime NOT NULL COMMENT '创建时间',
+ `update_time` datetime DEFAULT NULL COMMENT '更新时间',
+ PRIMARY KEY (`platform_id`)
+) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COMMENT='平台表';
+
+-- 类型表
+CREATE TABLE IF NOT EXISTS `type` (
+ `type_id` int(11) NOT NULL AUTO_INCREMENT COMMENT '类型ID',
+ `type_name` varchar(100) NOT NULL COMMENT '类型名称',
+ `del_flag` int(1) NOT NULL DEFAULT 0 COMMENT '删除标记：0-未删除，1-已删除',
+ `create_time` datetime NOT NULL COMMENT '创建时间',
+ `update_time` datetime DEFAULT NULL COMMENT '更新时间',
+ PRIMARY KEY (`type_id`)
+) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COMMENT='类型表';
+
+-- 提问词表
+CREATE TABLE IF NOT EXISTS `question` (
+ `question_id` int(11) NOT NULL AUTO_INCREMENT COMMENT '提问词ID',
+ `question` varchar(500) NOT NULL COMMENT '提问词内容',
+ `status` varchar(20) NOT NULL DEFAULT 'pending' COMMENT '状态：pending-待处理',
+ `del_flag` int(1) NOT NULL DEFAULT 0 COMMENT '删除标记：0-未删除，1-已删除',
+ `create_time` datetime NOT NULL COMMENT '创建时间',
+ `update_time` datetime DEFAULT NULL COMMENT '更新时间',
+ PRIMARY KEY (`question_id`)
+) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COMMENT='提问词表';
\ No newline at end of file
diff --git a/src/main/resources/sql/keyword.sql b/src/main/resources/sql/keyword.sql
new file mode 100644
index 0000000..1dc5f2e
--- /dev/null
+++ b/src/main/resources/sql/keyword.sql
@@ -0,0 +1,12 @@
+CREATE TABLE `keyword` (
+ `keyword_id` INT NOT NULL AUTO_INCREMENT COMMENT '关键词',
+ `order_id` VARCHAR(50) NOT NULL COMMENT '关联订单id',
+ `keyword_name` VARCHAR(255) NOT NULL COMMENT '关键词名称',
+ `num` INT DEFAULT 0 COMMENT '采集轮数',
+ `task_id` VARCHAR(50) COMMENT '任务唯一标识符',
+ `status` VARCHAR(50) DEFAULT 'notSubmitted' COMMENT '任务状态（notSubmitted：待处理；submitted：已提交）',
+ `del_flag` INT DEFAULT 0 COMMENT '0-未删除 1-删除',
+ `create_time` DATETIME DEFAULT CURRENT_TIMESTAMP COMMENT '创建时间',
+ `update_time` DATETIME DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP COMMENT '更新时间',
+ PRIMARY KEY (`keyword_id`)
+) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COMMENT='关键词表';
\ No newline at end of file
diff --git a/src/main/resources/sql/question.sql b/src/main/resources/sql/question.sql
new file mode 100644
index 0000000..0f0518f
--- /dev/null
+++ b/src/main/resources/sql/question.sql
@@ -0,0 +1,14 @@
+CREATE TABLE `question` (
+ `question_id` varchar(255) NOT NULL COMMENT '提问词ID',
+ `keyword_id` int(11) DEFAULT NULL COMMENT '关键词ID',
+ `question` varchar(255) DEFAULT NULL COMMENT '提问词',
+ `status` varchar(20) DEFAULT NULL COMMENT '提示词状态（pending：待处理；processing：处理中；success：处理成功；failed：处理失败）',
+ `user_name` varchar(255) DEFAULT NULL COMMENT '提交人',
+ `user_email` varchar(255) DEFAULT NULL COMMENT '提交人邮箱',
+ `timestamp` datetime DEFAULT NULL COMMENT '采集时间',
+ `extracted_count` int(11) DEFAULT NULL COMMENT '提取的引用数量',
+ `response` text COMMENT 'AI回复内容',
+ `error` text COMMENT '错误信息',
+ PRIMARY KEY (`question_id`),
+ KEY `idx_keyword_id` (`keyword_id`)
+) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COMMENT='提问词表';
\ No newline at end of file
diff --git a/src/main/resources/sql/reference.sql b/src/main/resources/sql/reference.sql
new file mode 100644
index 0000000..0792d89
--- /dev/null
+++ b/src/main/resources/sql/reference.sql
@@ -0,0 +1,17 @@
+CREATE TABLE `reference` (
+ `reference_id` int(11) NOT NULL COMMENT '结果ID',
+ `type_id` int(11) DEFAULT NULL COMMENT '类型ID',
+ `platform_id` int(11) DEFAULT NULL COMMENT '平台ID',
+ `title` varchar(255) DEFAULT NULL COMMENT '标题',
+ `repetition_num` int(11) DEFAULT NULL COMMENT '重复次数',
+ `create_time` datetime DEFAULT NULL COMMENT '创建时间',
+ `num` int(11) DEFAULT NULL COMMENT '采集轮数',
+ `url` varchar(255) DEFAULT NULL COMMENT '来源url',
+ `domain` varchar(255) DEFAULT NULL COMMENT '域名',
+ `task_id` varchar(255) DEFAULT NULL COMMENT '任务id',
+ `keyword_id` int(11) DEFAULT NULL COMMENT '关键词id',
+ PRIMARY KEY (`reference_id`),
+ KEY `idx_type_id` (`type_id`),
+ KEY `idx_platform_id` (`platform_id`),
+ KEY `idx_keyword_id` (`keyword_id`)
+) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COMMENT='引用表';
\ No newline at end of file
--
Gitblit v1.7.1