Compare commits
No commits in common. 'master' and 'topo_dev' have entirely different histories.
@ -1,4 +0,0 @@
|
||||
alter table task_record
|
||||
add finish_time datetime null comment '结束时间' after cancel_time;
|
||||
alter table task_case_record
|
||||
add prompt_id varchar(64) null comment '提示词ID' after task_record_id;
|
||||
@ -1,7 +0,0 @@
|
||||
alter table model_atomic_result
|
||||
modify record_split_id text null comment '笔录片段id';
|
||||
|
||||
alter table note_record_split
|
||||
add processed_question text null comment '处理后的回答' after answer;
|
||||
alter table note_record_split
|
||||
add processed_answer text null comment '处理后的回答' after processed_question;
|
||||
@ -1,28 +1,15 @@
|
||||
package com.supervision.common.constant;
|
||||
|
||||
public class DifyConstants {
|
||||
public static final String QA_TYPE_DIFY = "0";
|
||||
public static final String QA_TYPE_NX_LLM = "1";
|
||||
|
||||
public static final String INTENT_TYPE_INDEX_RESULT = "0";
|
||||
public static final String INTENT_TYPE_CASE_RESULT = "1";
|
||||
public static final String INTENT_TYPE_CASE_OVERVIEW = "2";
|
||||
public static final String INTENT_TYPE_CASE_EVIDENCE_GUIDE = "3";
|
||||
|
||||
public static final String METHOD_DATASET = "/datasets";
|
||||
public static final String METHOD_DOCUMENT = "/document";
|
||||
public static final String METHOD_DOCUMENTS = "/documents";
|
||||
public static final String METHOD_CREATE_BY_FILE = "/create-by-file";
|
||||
public static final String METHOD_CREATE_BY_TEXT = "/create_by_text";
|
||||
public static final String METHOD_CHAT_MESSAGES = "/chat-messages";
|
||||
|
||||
public static final String DATASET_INDEXING_TECHNIQUE_HIGH_QUALITY = "high_quality";
|
||||
public static final String CHAT_RESPONSE_MODE_BLOCKING = "blocking";
|
||||
public static final String CHAT_RESPONSE_MODE_STREAMING = "streaming";
|
||||
|
||||
public static final String INTENT_TYPE_TEXT_CASE_RESULT = "案件分析结果";
|
||||
public static final String INTENT_TYPE_TEXT_CASE_OVERVIEW = "案件概况";
|
||||
public static final String INTENT_TYPE_TEXT_CASE_EVIDENCE_GUIDE = "案件证据指引";
|
||||
|
||||
|
||||
}
|
||||
|
||||
@ -1,23 +0,0 @@
|
||||
package com.supervision.common.constant;
|
||||
|
||||
public class TaskRecordConstants {
|
||||
// 任务名称前缀
|
||||
public static final String TASK_NAME_PREFIX = "任务";
|
||||
public static final String TASK_NAME_PREFIX_TYPE_ALL_CASE = "全部案件";
|
||||
public static final String TASK_NAME_PREFIX_TYPE_SPECIFIED_CASE = "指定案件";
|
||||
public static final String TASK_NAME_PREFIX_TYPE_SPECIFIED_RECORD = "指定笔录";
|
||||
public static final String TASK_NAME_PREFIX_TYPE_SPECIFIED_EVIDENCE = "指定证据";
|
||||
// 任务类型
|
||||
public static final String TASK_TYPE_ALL_CASE = "0";
|
||||
public static final String TASK_TYPE_SPECIFIED_CASE = "1";
|
||||
public static final String TASK_TYPE_SPECIFIED_RECORD = "2";
|
||||
public static final String TASK_TYPE_SPECIFIED_EVIDENCE = "3";
|
||||
public static final String TASK_TYPE_ONE_CLICK = "4";
|
||||
// 任务状态
|
||||
public static final String TASK_STATUS_WAITING = "0";
|
||||
public static final String TASK_STATUS_PROCESSING = "1";
|
||||
public static final String TASK_STATUS_CANCELLING = "2";
|
||||
public static final String TASK_STATUS_CANCELED = "3";
|
||||
public static final String TASK_STATUS_SUCCESS = "4";
|
||||
public static final String TASK_STATUS_FAIL = "5";
|
||||
}
|
||||
@ -1,57 +0,0 @@
|
||||
package com.supervision.police.controller;
|
||||
|
||||
import com.baomidou.mybatisplus.core.metadata.IPage;
|
||||
import com.supervision.common.domain.R;
|
||||
import com.supervision.police.domain.ScoringModelInfo;
|
||||
import com.supervision.police.service.ScoringModelInfoService;
|
||||
import io.swagger.v3.oas.annotations.Operation;
|
||||
import io.swagger.v3.oas.annotations.Parameter;
|
||||
import io.swagger.v3.oas.annotations.tags.Tag;
|
||||
import lombok.RequiredArgsConstructor;
|
||||
import org.springframework.web.bind.annotation.*;
|
||||
|
||||
@Tag(name = "赋分模型信息")
|
||||
@RestController
|
||||
@RequestMapping("/scoringModel")
|
||||
@RequiredArgsConstructor
|
||||
public class ScoringModelInfoController {
|
||||
|
||||
private final ScoringModelInfoService scoringModelInfoService;
|
||||
|
||||
@Operation(summary = "保存赋分模型")
|
||||
@PostMapping("/save")
|
||||
public R<String> saveScoringModel(@RequestBody ScoringModelInfo modelInfo) {
|
||||
String roleId = scoringModelInfoService.saveScoringModel(modelInfo);
|
||||
return R.ok(roleId);
|
||||
}
|
||||
|
||||
@Operation(summary = "删除赋分模型")
|
||||
@PostMapping("/delete")
|
||||
public R<?> deleteScoringModel(@RequestBody ScoringModelInfo modelInfo) {
|
||||
scoringModelInfoService.deleteScoringModel(modelInfo.getId());
|
||||
return R.ok();
|
||||
}
|
||||
|
||||
@Operation(summary = "修改赋分模型")
|
||||
@PostMapping("/update")
|
||||
public R<?> updateScoringModel(@RequestBody ScoringModelInfo modelInfo) {
|
||||
scoringModelInfoService.updateScoringModel(modelInfo);
|
||||
return R.ok();
|
||||
}
|
||||
|
||||
@Operation(summary = "复制赋分模型")
|
||||
@PostMapping("/copy")
|
||||
public R<String> copyScoringModel(@RequestBody ScoringModelInfo modelInfo) {
|
||||
String modelId = scoringModelInfoService.copyScoringModel(modelInfo);
|
||||
return R.ok(modelId);
|
||||
}
|
||||
|
||||
@Operation(summary = "查看赋分模型列表")
|
||||
@GetMapping("/pageList")
|
||||
public R<IPage<ScoringModelInfo>> pageList(@RequestParam(required = false) @Parameter(name = "modelName",description = "模型名称") String modelName,
|
||||
@RequestParam(defaultValue = "1") @Parameter(name = "pageNum",description = "页码") Integer pageNum,
|
||||
@RequestParam(defaultValue = "99999") @Parameter(name = "pageSize",description = "每页数量") Integer pageSize) {
|
||||
IPage<ScoringModelInfo> page = scoringModelInfoService.pageList(modelName,pageNum, pageSize);
|
||||
return R.ok(page);
|
||||
}
|
||||
}
|
||||
@ -1,64 +0,0 @@
|
||||
package com.supervision.police.controller;
|
||||
|
||||
import com.baomidou.mybatisplus.core.metadata.IPage;
|
||||
import com.supervision.common.domain.R;
|
||||
import com.supervision.police.dto.TaskInfoDTO;
|
||||
import com.supervision.police.dto.taskRecord.TaskRecordVo;
|
||||
import com.supervision.police.service.TaskCaseRecordService;
|
||||
import com.supervision.police.service.TaskRecordService;
|
||||
import com.supervision.police.vo.TaskInfoReqVO;
|
||||
import io.swagger.v3.oas.annotations.Operation;
|
||||
import io.swagger.v3.oas.annotations.tags.Tag;
|
||||
import lombok.RequiredArgsConstructor;
|
||||
import org.springframework.web.bind.annotation.*;
|
||||
|
||||
import java.util.List;
|
||||
|
||||
@Tag(name = "任务管理")
|
||||
@RestController
|
||||
@RequestMapping("/taskRecord")
|
||||
@RequiredArgsConstructor
|
||||
public class TaskRecordController {
|
||||
|
||||
private final TaskRecordService taskRecordService;
|
||||
|
||||
@Operation(summary = "执行提示词提取任务")
|
||||
@PostMapping("/executePromptExtractTask")
|
||||
public R<?> executePromptExtractTask(@RequestBody TaskRecordVo taskRecordVo) {
|
||||
taskRecordService.executePromptExtractTask(taskRecordVo);
|
||||
return R.ok();
|
||||
}
|
||||
|
||||
@Operation(summary = "一键提取任务")
|
||||
@PostMapping("/executeAllPromptExtractTask")
|
||||
public R<?> executeAllPromptExtractTask() {
|
||||
taskRecordService.executeAllPromptExtractTask();
|
||||
return R.ok();
|
||||
}
|
||||
|
||||
|
||||
@Operation(summary = "查询任务列表")
|
||||
@PostMapping("/taskList")
|
||||
public R<IPage<TaskInfoDTO>> queryTaskList(@RequestBody TaskInfoReqVO taskInfoReqVO,
|
||||
@RequestParam(required = false, defaultValue = "1") Integer page,
|
||||
@RequestParam(required = false, defaultValue = "20") Integer size) {
|
||||
IPage<TaskInfoDTO> iPage = taskRecordService.queryTaskList(taskInfoReqVO, page, size);
|
||||
return R.ok(iPage);
|
||||
}
|
||||
|
||||
|
||||
@Operation(summary = "取消任务")
|
||||
@PostMapping("/cancelTask")
|
||||
public R<Boolean> cancelTask(@RequestBody List<String> taskIds) {
|
||||
taskRecordService.cancelTask(taskIds);
|
||||
return R.ok(true);
|
||||
}
|
||||
|
||||
|
||||
@Operation(summary = "删除任务")
|
||||
@PostMapping("/deleteTask")
|
||||
public R<Boolean> deleteTask(@RequestBody List<String> taskIds) {
|
||||
taskRecordService.deleteTask(taskIds);
|
||||
return R.ok(true);
|
||||
}
|
||||
}
|
||||
@ -1,56 +0,0 @@
|
||||
package com.supervision.police.domain;
|
||||
|
||||
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 conversation
|
||||
*/
|
||||
@TableName(value ="conversation")
|
||||
@Data
|
||||
public class Conversation implements Serializable {
|
||||
/**
|
||||
*
|
||||
*/
|
||||
@TableId
|
||||
private String id;
|
||||
|
||||
/**
|
||||
* 标题
|
||||
*/
|
||||
private String title;
|
||||
|
||||
/**
|
||||
* 类型
|
||||
*/
|
||||
private String type;
|
||||
|
||||
/**
|
||||
* 案件ID
|
||||
*/
|
||||
private String caseId;
|
||||
|
||||
/**
|
||||
* 用户ID
|
||||
*/
|
||||
private String userId;
|
||||
|
||||
/**
|
||||
*
|
||||
*/
|
||||
private Date createTime;
|
||||
|
||||
/**
|
||||
*
|
||||
*/
|
||||
private Date updateTime;
|
||||
|
||||
@TableField(exist = false)
|
||||
private static final long serialVersionUID = 1L;
|
||||
}
|
||||
@ -1,68 +0,0 @@
|
||||
package com.supervision.police.domain;
|
||||
|
||||
import com.baomidou.mybatisplus.annotation.*;
|
||||
|
||||
import java.io.Serializable;
|
||||
import java.time.LocalDateTime;
|
||||
|
||||
import com.fasterxml.jackson.annotation.JsonFormat;
|
||||
import lombok.Data;
|
||||
import org.springframework.format.annotation.DateTimeFormat;
|
||||
|
||||
/**
|
||||
* 赋分模型信息表
|
||||
* @TableName scoring_model_info
|
||||
*/
|
||||
@Data
|
||||
@TableName(value ="scoring_model_info")
|
||||
public class ScoringModelInfo implements Serializable {
|
||||
/**
|
||||
* 主键
|
||||
*/
|
||||
@TableId
|
||||
private String id;
|
||||
|
||||
/**
|
||||
* 模型名
|
||||
*/
|
||||
private String modelName;
|
||||
|
||||
/**
|
||||
* 模型说明
|
||||
*/
|
||||
private String modelDesc;
|
||||
|
||||
/**
|
||||
* 模型设置及赋分规则
|
||||
*/
|
||||
private String scoringRules;
|
||||
|
||||
/**
|
||||
* 创建人id
|
||||
*/
|
||||
private String createUserId;
|
||||
|
||||
/**
|
||||
* 创建时间
|
||||
*/
|
||||
@TableField(fill = FieldFill.INSERT)
|
||||
@JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss", timezone = "GMT+8")
|
||||
@DateTimeFormat(pattern = "yyyy-MM-dd HH:mm:ss")
|
||||
private LocalDateTime createTime;
|
||||
|
||||
/**
|
||||
* 更新人
|
||||
*/
|
||||
private String updateUserId;
|
||||
|
||||
/**
|
||||
* 更新时间
|
||||
*/
|
||||
@TableField(fill = FieldFill.INSERT_UPDATE)
|
||||
@JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss", timezone = "GMT+8")
|
||||
@DateTimeFormat(pattern = "yyyy-MM-dd HH:mm:ss")
|
||||
private LocalDateTime updateTime;
|
||||
|
||||
@TableField(exist = false)
|
||||
private static final long serialVersionUID = 1L;
|
||||
}
|
||||
@ -1,22 +0,0 @@
|
||||
package com.supervision.police.dto;
|
||||
|
||||
import lombok.Data;
|
||||
|
||||
/**
|
||||
* 原子指标使用情况DTO
|
||||
*/
|
||||
@Data
|
||||
public class AtomicIndexUsedDTO {
|
||||
|
||||
private String atomicIndexId;
|
||||
|
||||
private String atomicIndexName;
|
||||
|
||||
private String indexId;
|
||||
|
||||
private String indexName;
|
||||
|
||||
private String modelName;
|
||||
|
||||
private String modelId;
|
||||
}
|
||||
@ -1,72 +0,0 @@
|
||||
package com.supervision.police.dto;
|
||||
|
||||
import com.fasterxml.jackson.annotation.JsonFormat;
|
||||
import lombok.Data;
|
||||
import java.time.LocalDateTime;
|
||||
|
||||
@Data
|
||||
public class TaskInfoDTO {
|
||||
|
||||
/**
|
||||
* 任务id
|
||||
*/
|
||||
private String taskId;
|
||||
|
||||
/**
|
||||
* 案件id
|
||||
*/
|
||||
private String caseId;
|
||||
|
||||
/**
|
||||
* 案件名称
|
||||
*/
|
||||
private String caseName;
|
||||
|
||||
/**
|
||||
* 任务名称
|
||||
*/
|
||||
private String taskName;
|
||||
|
||||
|
||||
private String taskType;
|
||||
|
||||
|
||||
private String promptId;
|
||||
|
||||
|
||||
private String promptName;
|
||||
|
||||
/**
|
||||
* 任务状态
|
||||
*/
|
||||
private String taskStatus;
|
||||
|
||||
/**
|
||||
* 任务取消时间
|
||||
*/
|
||||
@JsonFormat(pattern="yyyy-MM-dd HH:mm:ss",timezone = "GMT+8")
|
||||
private LocalDateTime cancelTime;
|
||||
|
||||
/**
|
||||
* 任务完成时间
|
||||
*/
|
||||
@JsonFormat(pattern="yyyy-MM-dd HH:mm:ss",timezone = "GMT+8")
|
||||
private LocalDateTime finishTime;
|
||||
|
||||
/**
|
||||
* 任务创建时间
|
||||
*/
|
||||
@JsonFormat(pattern="yyyy-MM-dd HH:mm:ss",timezone = "GMT+8")
|
||||
private LocalDateTime createTime;
|
||||
|
||||
/**
|
||||
* 任务创建人id
|
||||
*/
|
||||
private String createUserId;
|
||||
|
||||
/**
|
||||
* 任务创建人姓名
|
||||
*/
|
||||
private String createUserName;
|
||||
|
||||
}
|
||||
@ -1,12 +0,0 @@
|
||||
package com.supervision.police.dto.taskRecord;
|
||||
|
||||
import lombok.Data;
|
||||
|
||||
@Data
|
||||
public class TaskRecordVo {
|
||||
private String caseId;
|
||||
private String recordId;
|
||||
private String evidenceId;
|
||||
private String promptId;
|
||||
private String type;
|
||||
}
|
||||
@ -1,32 +0,0 @@
|
||||
package com.supervision.police.handler;
|
||||
|
||||
import com.baomidou.mybatisplus.extension.handlers.AbstractJsonTypeHandler;
|
||||
import com.fasterxml.jackson.core.type.TypeReference;
|
||||
import com.fasterxml.jackson.databind.ObjectMapper;
|
||||
import com.supervision.police.dto.NotePromptExtractAttributesDto;
|
||||
import com.supervision.police.vo.dify.KnowledgeBaseSegmentVO;
|
||||
|
||||
import java.util.List;
|
||||
|
||||
public class KnowledgeBaseSegmentVOTypeHandler extends AbstractJsonTypeHandler<List<KnowledgeBaseSegmentVO>> {
|
||||
private static final ObjectMapper objectMapper = new ObjectMapper();
|
||||
|
||||
@Override
|
||||
protected List<KnowledgeBaseSegmentVO> parse(String json) {
|
||||
try {
|
||||
return objectMapper.readValue(json, new TypeReference<List<KnowledgeBaseSegmentVO>>() {
|
||||
});
|
||||
} catch (Exception e) {
|
||||
throw new RuntimeException("Failed to parse JSON to List<KnowledgeBaseSegmentVO>", e);
|
||||
}
|
||||
}
|
||||
|
||||
@Override
|
||||
protected String toJson(List<KnowledgeBaseSegmentVO> obj) {
|
||||
try {
|
||||
return objectMapper.writeValueAsString(obj);
|
||||
} catch (Exception e) {
|
||||
throw new RuntimeException("Failed to convert List<KnowledgeBaseSegmentVO> to JSON", e);
|
||||
}
|
||||
}
|
||||
}
|
||||
@ -1,18 +0,0 @@
|
||||
package com.supervision.police.mapper;
|
||||
|
||||
import com.supervision.police.domain.AuditLog;
|
||||
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
|
||||
|
||||
/**
|
||||
* @author Administrator
|
||||
* @description 针对表【audit_log(日志审计表)】的数据库操作Mapper
|
||||
* @createDate 2024-12-09 13:19:15
|
||||
* @Entity com.supervision.police.domain.AuditLog
|
||||
*/
|
||||
public interface AuditLogMapper extends BaseMapper<AuditLog> {
|
||||
|
||||
}
|
||||
|
||||
|
||||
|
||||
|
||||
@ -1,23 +0,0 @@
|
||||
package com.supervision.police.mapper;
|
||||
|
||||
import com.baomidou.mybatisplus.core.metadata.IPage;
|
||||
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
|
||||
import com.supervision.police.domain.Conversation;
|
||||
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
|
||||
import com.supervision.police.vo.ConversationResVo;
|
||||
import java.util.Date;
|
||||
|
||||
/**
|
||||
* @author yaxin
|
||||
* @description 针对表【conversation(会话记录表)】的数据库操作Mapper
|
||||
* @createDate 2024-11-25 13:43:52
|
||||
* @Entity com.supervision.police.domain.Conversation
|
||||
*/
|
||||
public interface ConversationMapper extends BaseMapper<Conversation> {
|
||||
|
||||
IPage<ConversationResVo> queryUserConversationList(String userId, Date startTime,Date endTime, Page<ConversationResVo> page);
|
||||
}
|
||||
|
||||
|
||||
|
||||
|
||||
@ -1,18 +0,0 @@
|
||||
package com.supervision.police.mapper;
|
||||
|
||||
import com.supervision.police.domain.ConversationQa;
|
||||
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
|
||||
|
||||
/**
|
||||
* @author yaxin
|
||||
* @description 针对表【conversation_qa】的数据库操作Mapper
|
||||
* @createDate 2024-11-22 11:37:02
|
||||
* @Entity com.supervision.police.domain.ConversationQa
|
||||
*/
|
||||
public interface ConversationQaMapper extends BaseMapper<ConversationQa> {
|
||||
|
||||
}
|
||||
|
||||
|
||||
|
||||
|
||||
@ -1,18 +0,0 @@
|
||||
package com.supervision.police.mapper;
|
||||
|
||||
import com.supervision.police.domain.ScoringModelInfo;
|
||||
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
|
||||
|
||||
/**
|
||||
* @author Administrator
|
||||
* @description 针对表【scoring_model_info(赋分模型信息表)】的数据库操作Mapper
|
||||
* @createDate 2025-02-14 16:27:25
|
||||
* @Entity com.supervision.police.domain.ScoringModelInfo
|
||||
*/
|
||||
public interface ScoringModelInfoMapper extends BaseMapper<ScoringModelInfo> {
|
||||
|
||||
}
|
||||
|
||||
|
||||
|
||||
|
||||
@ -1,18 +0,0 @@
|
||||
package com.supervision.police.mapper;
|
||||
|
||||
import com.supervision.police.domain.TaskCaseRecord;
|
||||
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
|
||||
|
||||
/**
|
||||
* @author dxy
|
||||
* @description 针对表【task_case_record】的数据库操作Mapper
|
||||
* @createDate 2024-12-25 09:57:08
|
||||
* @Entity com.supervision.police.domain.TaskCaseRecord
|
||||
*/
|
||||
public interface TaskCaseRecordMapper extends BaseMapper<TaskCaseRecord> {
|
||||
|
||||
}
|
||||
|
||||
|
||||
|
||||
|
||||
@ -1,23 +0,0 @@
|
||||
package com.supervision.police.mapper;
|
||||
|
||||
import com.baomidou.mybatisplus.core.metadata.IPage;
|
||||
import com.supervision.police.domain.TaskRecord;
|
||||
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
|
||||
import com.supervision.police.dto.TaskInfoDTO;
|
||||
import com.supervision.police.vo.TaskInfoReqVO;
|
||||
import org.apache.ibatis.annotations.Param;
|
||||
|
||||
/**
|
||||
* @author dxy
|
||||
* @description 针对表【task_record】的数据库操作Mapper
|
||||
* @createDate 2024-12-24 14:44:43
|
||||
* @Entity com.supervision.police.domain.TaskRecord
|
||||
*/
|
||||
public interface TaskRecordMapper extends BaseMapper<TaskRecord> {
|
||||
|
||||
IPage<TaskInfoDTO> queryTaskList(@Param("taskInfo") TaskInfoReqVO taskInfo, @Param("page")IPage<TaskInfoDTO> page);
|
||||
}
|
||||
|
||||
|
||||
|
||||
|
||||
@ -1,16 +0,0 @@
|
||||
package com.supervision.police.service;
|
||||
|
||||
import com.supervision.police.domain.AuditLog;
|
||||
import com.baomidou.mybatisplus.extension.service.IService;
|
||||
import com.supervision.police.dto.AuditLogDTO;
|
||||
|
||||
/**
|
||||
* @author Administrator
|
||||
* @description 针对表【audit_log(日志审计表)】的数据库操作Service
|
||||
* @createDate 2024-12-09 13:19:15
|
||||
*/
|
||||
public interface AuditLogService extends IService<AuditLog> {
|
||||
|
||||
|
||||
void saveAuditLog(AuditLogDTO auditLogDTO);
|
||||
}
|
||||
@ -1,23 +1,8 @@
|
||||
package com.supervision.police.service;
|
||||
|
||||
import com.baomidou.mybatisplus.core.metadata.IPage;
|
||||
import com.supervision.common.domain.R;
|
||||
import com.supervision.police.vo.ChatReqVO;
|
||||
import com.supervision.police.vo.ChatResVO;
|
||||
import com.supervision.police.vo.ConversationResVo;
|
||||
|
||||
import java.util.List;
|
||||
|
||||
public interface ChatService {
|
||||
ChatResVO chat(ChatReqVO chatReqVO);
|
||||
R<ChatResVO> chatNew(ChatReqVO chatReqVO);
|
||||
|
||||
|
||||
IPage<ChatResVO> queryConversationInfoList(String conversationId, int page, int size);
|
||||
|
||||
|
||||
IPage<ConversationResVo> queryUserConversationList(String userId, int page, int size);
|
||||
|
||||
|
||||
void deleteConversation(List<String> conversationIdList);
|
||||
}
|
||||
|
||||
@ -1,13 +0,0 @@
|
||||
package com.supervision.police.service;
|
||||
|
||||
import com.supervision.police.domain.ConversationQa;
|
||||
import com.baomidou.mybatisplus.extension.service.IService;
|
||||
|
||||
/**
|
||||
* @author yaxin
|
||||
* @description 针对表【conversation_qa】的数据库操作Service
|
||||
* @createDate 2024-11-22 11:37:02
|
||||
*/
|
||||
public interface ConversationQaService extends IService<ConversationQa> {
|
||||
|
||||
}
|
||||
@ -1,19 +0,0 @@
|
||||
package com.supervision.police.service;
|
||||
|
||||
import com.baomidou.mybatisplus.core.metadata.IPage;
|
||||
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
|
||||
import com.supervision.police.domain.Conversation;
|
||||
import com.baomidou.mybatisplus.extension.service.IService;
|
||||
import com.supervision.police.vo.ConversationResVo;
|
||||
import java.util.Date;
|
||||
|
||||
/**
|
||||
* @author yaxin
|
||||
* @description 针对表【conversation(会话记录表)】的数据库操作Service
|
||||
* @createDate 2024-11-25 13:43:52
|
||||
*/
|
||||
public interface ConversationService extends IService<Conversation> {
|
||||
|
||||
IPage<ConversationResVo> queryUserConversationList(String userId, Date startTime, Date endTime, Page<ConversationResVo> page);
|
||||
|
||||
}
|
||||
@ -1,18 +1,6 @@
|
||||
package com.supervision.police.service;
|
||||
|
||||
import com.supervision.police.domain.CasePerson;
|
||||
import com.supervision.police.domain.NotePrompt;
|
||||
import com.supervision.police.domain.NoteRecordSplit;
|
||||
import com.supervision.police.domain.TripleInfo;
|
||||
|
||||
import java.util.List;
|
||||
|
||||
public interface ExtractTripleInfoService {
|
||||
|
||||
void extractTripleInfo(String caseId, String name, String recordSplitId);
|
||||
|
||||
List<TripleInfo> extractTripleInfo(NotePrompt notePrompt, CasePerson mainActor, List<NoteRecordSplit> noteRecordSplitList);
|
||||
|
||||
|
||||
List<TripleInfo> extractTripleInfo(NotePrompt notePrompt, String caseId, String recordId);
|
||||
}
|
||||
|
||||
@ -1,8 +0,0 @@
|
||||
package com.supervision.police.service;
|
||||
|
||||
import com.baomidou.mybatisplus.extension.service.IService;
|
||||
import com.supervision.police.domain.ModelIndexResult;
|
||||
public interface ModelIndexResultService extends IService<ModelIndexResult> {
|
||||
|
||||
void removeByCaseId(String caseId);
|
||||
}
|
||||
@ -1,15 +0,0 @@
|
||||
package com.supervision.police.service;
|
||||
|
||||
import com.baomidou.mybatisplus.core.metadata.IPage;
|
||||
import com.supervision.police.dto.CaseProcessDTO;
|
||||
import com.supervision.police.dto.TaskInfoDTO;
|
||||
import com.supervision.police.vo.CaseProcessReqVO;
|
||||
import com.supervision.police.vo.TaskInfoReqVO;
|
||||
|
||||
import java.util.List;
|
||||
|
||||
public interface MroService {
|
||||
IPage<CaseProcessDTO> queryCaseList(CaseProcessReqVO caseProcessReqVO, Integer page, Integer size);
|
||||
|
||||
void analysisCase(List<String> caseIds);
|
||||
}
|
||||
@ -1,28 +0,0 @@
|
||||
package com.supervision.police.service;
|
||||
|
||||
import com.baomidou.mybatisplus.core.metadata.IPage;
|
||||
import com.supervision.police.domain.ScoringModelInfo;
|
||||
import com.baomidou.mybatisplus.extension.service.IService;
|
||||
|
||||
import java.util.List;
|
||||
import java.util.stream.LongStream;
|
||||
|
||||
/**
|
||||
* @author Administrator
|
||||
* @description 针对表【scoring_model_info(赋分模型信息表)】的数据库操作Service
|
||||
* @createDate 2025-02-14 16:27:25
|
||||
*/
|
||||
public interface ScoringModelInfoService extends IService<ScoringModelInfo> {
|
||||
|
||||
String saveScoringModel(ScoringModelInfo modelInfo);
|
||||
|
||||
void deleteScoringModel(String modelId);
|
||||
|
||||
void updateScoringModel(ScoringModelInfo modelInfo);
|
||||
|
||||
String copyScoringModel(ScoringModelInfo modelInfo);
|
||||
|
||||
IPage<ScoringModelInfo> pageList(String modelName, Integer pageNum, Integer pageSize);
|
||||
|
||||
String getScoringModelNameById(String modelId, List<ScoringModelInfo> modelInfoList);
|
||||
}
|
||||
@ -1,40 +0,0 @@
|
||||
package com.supervision.police.service;
|
||||
|
||||
import com.supervision.police.domain.TaskCaseRecord;
|
||||
import com.baomidou.mybatisplus.extension.service.IService;
|
||||
import java.util.List;
|
||||
import java.util.Map;
|
||||
|
||||
/**
|
||||
* @author dxy
|
||||
* @description 针对表【task_case_record】的数据库操作Service
|
||||
* @createDate 2024-12-25 09:57:08
|
||||
*/
|
||||
public interface TaskCaseRecordService extends IService<TaskCaseRecord> {
|
||||
|
||||
|
||||
/**
|
||||
* 查询正在处理的任务列表
|
||||
* @return
|
||||
*/
|
||||
List<TaskCaseRecord> queryProcessingTaskList();
|
||||
|
||||
|
||||
List<TaskCaseRecord> queryByTaskId(String taskId);
|
||||
|
||||
|
||||
/**
|
||||
* 获取实际状态
|
||||
* @param taskCaseRecord 任务记录
|
||||
* @return
|
||||
*/
|
||||
String getActuallyStatus(TaskCaseRecord taskCaseRecord);
|
||||
|
||||
TaskCaseRecord updateStatus(String taskId, String executeId,String promptId,boolean isSuccess);
|
||||
TaskCaseRecord updateStatus(String taskId, String executeId,String promptId,boolean isSuccess,List<TaskCaseRecord> taskCaseRecordList);
|
||||
|
||||
Boolean updateStatus(String taskId,List<String> olderStatus,String nowStatus);
|
||||
|
||||
|
||||
Boolean removeByTaskId(List<String> taskIds);
|
||||
}
|
||||
@ -1,22 +1,7 @@
|
||||
package com.supervision.police.service;
|
||||
|
||||
import com.baomidou.mybatisplus.extension.service.IService;
|
||||
import com.supervision.police.domain.NotePrompt;
|
||||
import com.supervision.police.domain.TripleInfo;
|
||||
|
||||
import java.util.List;
|
||||
|
||||
public interface TripleInfoService extends IService<TripleInfo> {
|
||||
|
||||
/**
|
||||
* 根据业务字段或者主键id更新或新增三元组信息
|
||||
* @param tripleInfo
|
||||
* @return
|
||||
*/
|
||||
TripleInfo saveOrUpdateByBusiness(TripleInfo tripleInfo);
|
||||
|
||||
|
||||
void updateNeo4jFlag(List<String> ids, String neo4jFlag);
|
||||
|
||||
List<TripleInfo> queryByRecordIdAndPrompt(String recordId, NotePrompt notePrompt);
|
||||
}
|
||||
|
||||
@ -1,32 +0,0 @@
|
||||
package com.supervision.police.service.impl;
|
||||
|
||||
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
|
||||
import com.supervision.police.domain.AuditLog;
|
||||
import com.supervision.police.dto.AuditLogDTO;
|
||||
import com.supervision.police.service.AuditLogService;
|
||||
import com.supervision.police.mapper.AuditLogMapper;
|
||||
import org.springframework.stereotype.Service;
|
||||
|
||||
/**
|
||||
* @author Administrator
|
||||
* @description 针对表【audit_log(日志审计表)】的数据库操作Service实现
|
||||
* @createDate 2024-12-09 13:19:15
|
||||
*/
|
||||
@Service
|
||||
public class AuditLogServiceImpl extends ServiceImpl<AuditLogMapper, AuditLog>
|
||||
implements AuditLogService{
|
||||
|
||||
@Override
|
||||
public void saveAuditLog(AuditLogDTO auditLogDTO) {
|
||||
if (null == auditLogDTO){
|
||||
return;
|
||||
}
|
||||
|
||||
AuditLog auditLog = auditLogDTO.toAuditLog();
|
||||
this.save(auditLog);
|
||||
}
|
||||
}
|
||||
|
||||
|
||||
|
||||
|
||||
@ -1,22 +0,0 @@
|
||||
package com.supervision.police.service.impl;
|
||||
|
||||
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
|
||||
import com.supervision.police.domain.ConversationQa;
|
||||
import com.supervision.police.service.ConversationQaService;
|
||||
import com.supervision.police.mapper.ConversationQaMapper;
|
||||
import org.springframework.stereotype.Service;
|
||||
|
||||
/**
|
||||
* @author yaxin
|
||||
* @description 针对表【conversation_qa】的数据库操作Service实现
|
||||
* @createDate 2024-11-22 11:37:02
|
||||
*/
|
||||
@Service
|
||||
public class ConversationQaServiceImpl extends ServiceImpl<ConversationQaMapper, ConversationQa>
|
||||
implements ConversationQaService{
|
||||
|
||||
}
|
||||
|
||||
|
||||
|
||||
|
||||
@ -1,31 +0,0 @@
|
||||
package com.supervision.police.service.impl;
|
||||
|
||||
import com.baomidou.mybatisplus.core.metadata.IPage;
|
||||
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
|
||||
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
|
||||
import com.supervision.police.domain.Conversation;
|
||||
import com.supervision.police.service.ConversationService;
|
||||
import com.supervision.police.mapper.ConversationMapper;
|
||||
import com.supervision.police.vo.ConversationResVo;
|
||||
import org.springframework.stereotype.Service;
|
||||
|
||||
import java.util.Date;
|
||||
|
||||
/**
|
||||
* @author yaxin
|
||||
* @description 针对表【conversation(会话记录表)】的数据库操作Service实现
|
||||
* @createDate 2024-11-25 13:43:52
|
||||
*/
|
||||
@Service
|
||||
public class ConversationServiceImpl extends ServiceImpl<ConversationMapper, Conversation>
|
||||
implements ConversationService{
|
||||
|
||||
@Override
|
||||
public IPage<ConversationResVo> queryUserConversationList(String userId, Date startTime,Date endTime, Page<ConversationResVo> page) {
|
||||
return super.getBaseMapper().queryUserConversationList(userId,startTime,endTime, page);
|
||||
}
|
||||
}
|
||||
|
||||
|
||||
|
||||
|
||||
Some files were not shown because too many files have changed in this diff Show More
Loading…
Reference in New Issue