提示词提取任务模型设计

src/main/java/com/supervision/common/constant/TaskRecordConstants.java

@@ -0,0 +1,15 @@
+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 = "AllCase";
+    public static final String TASK_NAME_PREFIX_TYPE_SPECIFIED_CASE = "CasePart";
+    public static final String TASK_NAME_PREFIX_TYPE_SPECIFIED_RECORD = "CaseRecord";
+    public static final String TASK_NAME_PREFIX_TYPE_SPECIFIED_EVIDENCE = "CaseEvidence";
+    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_EXTRACT_RECORD = "record";
+    public static final String TASK_EXTRACT_EVIDENCE = "evidence";
+}

src/main/java/com/supervision/job/XxlJobTask.java

@@ -28,4 +28,37 @@ public class XxlJobTask {
             log.info("任务执行完成");
         }
     }
+
+    /**
+     * 根据任务提取证据
+     */
+    @XxlJob("extractEvidenceByTask")
+    public void extractEvidenceByTask() {
+        String param = XxlJobHelper.getJobParam();
+        log.info("【证据解析】任务开始。ID: 【{}】", param);
+        try {
+            caseEvidenceService.evidenceAnalysis(param);
+        } catch (Exception e) {
+            log.error("任务执行失败", e);
+        } finally {
+            log.info("任务执行完成");
+        }
+    }
+
+    /**
+     * 根据任务提取笔录
+     */
+    @XxlJob("extractRecordByTask")
+    public void extractRecordByTask() {
+        String param = XxlJobHelper.getJobParam();
+        log.info("【证据解析】任务开始。ID: 【{}】", param);
+        try {
+            caseEvidenceService.evidenceAnalysis(param);
+        } catch (Exception e) {
+            log.error("任务执行失败", e);
+        } finally {
+            log.info("任务执行完成");
+        }
+    }
+
 }

src/main/java/com/supervision/police/controller/TaskRecordController.java

@@ -0,0 +1,31 @@
+package com.supervision.police.controller;
+
+import com.supervision.common.domain.R;
+import com.supervision.police.dto.taskRecord.TaskRecordVo;
+import com.supervision.police.service.TaskCaseRecordService;
+import com.supervision.police.service.TaskRecordService;
+import io.swagger.v3.oas.annotations.Operation;
+import io.swagger.v3.oas.annotations.tags.Tag;
+import lombok.RequiredArgsConstructor;
+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.RestController;
+
+@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();
+    }
+
+}

src/main/java/com/supervision/police/domain/TaskCaseRecord.java

@@ -0,0 +1,70 @@
+package com.supervision.police.domain;
+
+import com.baomidou.mybatisplus.annotation.TableField;
+import com.baomidou.mybatisplus.annotation.TableId;
+import com.baomidou.mybatisplus.annotation.TableName;
+import lombok.Data;
+
+import java.io.Serializable;
+import java.util.Date;
+
+/**
+ * @TableName task_case_record
+ */
+@TableName(value = "task_case_record")
+@Data
+public class TaskCaseRecord implements Serializable {
+    /**
+     *
+     */
+    @TableId
+    private String id;
+
+    /**
+     * 任务ID
+     */
+    private String taskRecordId;
+
+    /**
+     * 案件ID
+     */
+    private String caseId;
+
+    /**
+     * 异常ID，逗号分隔
+     */
+    private String exceptionId;
+
+    /**
+     * 0：待处理 1：处理中 2：取消中 3：已取消 4：处理成功 5：处理失败
+     */
+    private String status;
+
+    /**
+     * 创建人ID
+     */
+    private String createUserId;
+
+    /**
+     * 创建时间
+     */
+    private Date createTime;
+
+    /**
+     * 更新人ID
+     */
+    private String updateUserId;
+
+    /**
+     * 更新时间
+     */
+    private Date updateTime;
+
+    /**
+     * 提取笔录还是证据 record：笔录 evidence：证据
+     */
+    private String recordOrEvidence;
+
+    @TableField(exist = false)
+    private static final long serialVersionUID = 1L;
+}

src/main/java/com/supervision/police/domain/TaskRecord.java

@@ -0,0 +1,86 @@
+package com.supervision.police.domain;
+
+import com.baomidou.mybatisplus.annotation.TableField;
+import com.baomidou.mybatisplus.annotation.TableId;
+import com.baomidou.mybatisplus.annotation.TableName;
+import lombok.Data;
+
+import java.io.Serializable;
+import java.util.Date;
+
+/**
+ * @author dxy
+ * @TableName task_record
+ */
+@TableName(value = "task_record")
+@Data
+public class TaskRecord implements Serializable {
+    /**
+     *
+     */
+    @TableId
+    private String id;
+
+    /**
+     * 名称
+     */
+    private String name;
+
+    /**
+     * 案件ID，英文逗号分隔
+     */
+    private String caseId;
+
+    /**
+     * 笔录ID，英文逗号分隔
+     */
+    private String recordId;
+
+    /**
+     * 证据ID，英文逗号分隔
+     */
+    private String evidenceId;
+
+    /**
+     * 提取笔录还是证据 record：笔录 evidence：证据
+     */
+    private String recordOrEvidence;
+
+    /**
+     * 0：全部案件 1：部分案件 2：部分笔录 3：部分证据
+     */
+    private String type;
+
+    /**
+     * 0：待处理 1：处理中 2：取消中 3：已取消 4：处理成功 5：处理失败
+     */
+    private String status;
+
+    /**
+     * 取消时间
+     */
+    private Date cancelTime;
+
+    /**
+     * 创建人ID
+     */
+    private String createUserId;
+
+    /**
+     * 创建时间
+     */
+    private Date createTime;
+
+    /**
+     * 更新人ID
+     */
+    private String updateUserId;
+
+    /**
+     * 更新时间
+     */
+    private Date updateTime;
+
+    @TableField(exist = false)
+    private static final long serialVersionUID = 1L;
+}

src/main/java/com/supervision/police/dto/taskRecord/TaskRecordVo.java

@@ -0,0 +1,13 @@
+package com.supervision.police.dto.taskRecord;
+
+import lombok.Data;
+
+@Data
+public class TaskRecordVo {
+    private String caseId;
+    private String recordId;
+    private String evidenceId;
+    private String recordOrEvidence;
+    private String type;
+    private String status;
+}

src/main/java/com/supervision/police/mapper/TaskCaseRecordMapper.java

@@ -0,0 +1,18 @@
+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> {
+
+}
+
+
+
+

src/main/java/com/supervision/police/mapper/TaskRecordMapper.java

@@ -0,0 +1,18 @@
+package com.supervision.police.mapper;
+
+import com.supervision.police.domain.TaskRecord;
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+
+/**
+* @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> {
+
+}
+
+
+
+

src/main/java/com/supervision/police/service/TaskCaseRecordService.java

@@ -0,0 +1,14 @@
+package com.supervision.police.service;
+
+import com.supervision.police.domain.TaskCaseRecord;
+import com.baomidou.mybatisplus.extension.service.IService;
+import com.supervision.police.dto.taskRecord.TaskRecordVo;
+
+/**
+* @author dxy
+* @description 针对表【task_case_record】的数据库操作Service
+* @createDate 2024-12-25 09:57:08
+*/
+public interface TaskCaseRecordService extends IService<TaskCaseRecord> {
+
+}

src/main/java/com/supervision/police/service/TaskRecordService.java

@@ -0,0 +1,15 @@
+package com.supervision.police.service;
+
+import com.supervision.police.domain.TaskRecord;
+import com.baomidou.mybatisplus.extension.service.IService;
+import com.supervision.police.dto.taskRecord.TaskRecordVo;
+
+/**
+* @author dxy
+* @description 针对表【task_record】的数据库操作Service
+* @createDate 2024-12-24 14:44:43
+*/
+public interface TaskRecordService extends IService<TaskRecord> {
+
+    void executePromptExtractTask(TaskRecordVo taskRecordVo);
+}

src/main/java/com/supervision/police/service/impl/TaskCaseRecordServiceImpl.java

@@ -0,0 +1,25 @@
+package com.supervision.police.service.impl;
+
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import com.supervision.common.constant.TaskRecordConstants;
+import com.supervision.police.domain.TaskCaseRecord;
+import com.supervision.police.domain.TaskRecord;
+import com.supervision.police.dto.taskRecord.TaskRecordVo;
+import com.supervision.police.service.TaskCaseRecordService;
+import com.supervision.police.mapper.TaskCaseRecordMapper;
+import org.springframework.beans.BeanUtils;
+import org.springframework.stereotype.Service;
+
+/**
+* @author dxy
+* @description 针对表【task_case_record】的数据库操作Service实现
+* @createDate 2024-12-25 09:57:08
+*/
+@Service
+public class TaskCaseRecordServiceImpl extends ServiceImpl<TaskCaseRecordMapper, TaskCaseRecord>
+    implements TaskCaseRecordService{
+}
+
+
+
+

src/main/java/com/supervision/police/service/impl/TaskRecordServiceImpl.java

@@ -0,0 +1,49 @@
+package com.supervision.police.service.impl;
+
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import com.supervision.common.constant.TaskRecordConstants;
+import com.supervision.police.domain.TaskRecord;
+import com.supervision.police.dto.taskRecord.TaskRecordVo;
+import com.supervision.police.service.TaskCaseRecordService;
+import com.supervision.police.service.TaskRecordService;
+import com.supervision.police.mapper.TaskRecordMapper;
+import lombok.RequiredArgsConstructor;
+import org.springframework.beans.BeanUtils;
+import org.springframework.stereotype.Service;
+
+/**
+* @author dxy
+* @description 针对表【task_record】的数据库操作Service实现
+* @createDate 2024-12-24 14:44:43
+*/
+@Service
+@RequiredArgsConstructor
+public class TaskRecordServiceImpl extends ServiceImpl<TaskRecordMapper, TaskRecord>
+    implements TaskRecordService{
+
+    final TaskCaseRecordService taskCaseRecordService;
+
+    @Override
+    public void executePromptExtractTask(TaskRecordVo taskRecordVo) {
+        TaskRecord taskRecord = new TaskRecord();
+        BeanUtils.copyProperties(taskRecordVo, taskRecord);
+        save(taskRecord);
+        switch (taskRecord.getType()) {
+            case TaskRecordConstants.TASK_TYPE_ALL_CASE:
+                break;
+            case TaskRecordConstants.TASK_TYPE_SPECIFIED_CASE:
+                break;
+            case TaskRecordConstants.TASK_TYPE_SPECIFIED_RECORD:
+                break;
+            case TaskRecordConstants.TASK_TYPE_SPECIFIED_EVIDENCE:
+                break;
+            default:
+                break;
+        }
+    }
+
+}
+
+
+
+

src/main/resources/mapper/TaskCaseRecordMapper.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.supervision.police.mapper.TaskCaseRecordMapper">
+
+    <resultMap id="BaseResultMap" type="com.supervision.police.domain.TaskCaseRecord">
+            <id property="id" column="id" jdbcType="VARCHAR"/>
+            <result property="taskRecordId" column="task_record_id" jdbcType="VARCHAR"/>
+            <result property="caseId" column="case_id" jdbcType="VARCHAR"/>
+            <result property="exceptionId" column="exception_id" jdbcType="VARCHAR"/>
+            <result property="status" column="status" jdbcType="VARCHAR"/>
+            <result property="createUserId" column="create_user_id" jdbcType="VARCHAR"/>
+            <result property="createTime" column="create_time" jdbcType="TIMESTAMP"/>
+            <result property="updateUserId" column="update_user_id" jdbcType="VARCHAR"/>
+            <result property="updateTime" column="update_time" jdbcType="TIMESTAMP"/>
+            <result property="recordOrEvidence" column="record_or_evidence" jdbcType="VARCHAR"/>
+    </resultMap>
+
+    <sql id="Base_Column_List">
+        id,task_record_id,case_id,
+        exception_id,status,create_user_id,
+        create_time,update_user_id,update_time,
+        record_or_evidence
+    </sql>
+</mapper>

src/main/resources/mapper/TaskRecordMapper.xml

@@ -0,0 +1,29 @@
+<?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.supervision.police.mapper.TaskRecordMapper">
+
+    <resultMap id="BaseResultMap" type="com.supervision.police.domain.TaskRecord">
+            <id property="id" column="id" jdbcType="VARCHAR"/>
+            <result property="name" column="name" jdbcType="VARCHAR"/>
+            <result property="caseId" column="case_id" jdbcType="VARCHAR"/>
+            <result property="recordId" column="record_id" jdbcType="VARCHAR"/>
+            <result property="evidenceId" column="evidence_id" jdbcType="VARCHAR"/>
+            <result property="type" column="type" jdbcType="VARCHAR"/>
+            <result property="status" column="status" jdbcType="VARCHAR"/>
+            <result property="cancelTime" column="cancel_time" jdbcType="TIMESTAMP"/>
+            <result property="createUserId" column="create_user_id" jdbcType="VARCHAR"/>
+            <result property="createTime" column="create_time" jdbcType="TIMESTAMP"/>
+            <result property="updateUserId" column="update_user_id" jdbcType="VARCHAR"/>
+            <result property="updateTime" column="update_time" jdbcType="TIMESTAMP"/>
+    </resultMap>
+
+    <sql id="Base_Column_List">
+        id,name,case_id,
+        record_id,evidence_id,type,
+        status,cancel_time,create_user_id,
+        create_time,update_user_id,update_time,
+        batch_no
+    </sql>
+</mapper>