纪要模板crud

pom.xml

@@ -32,7 +32,7 @@
         <maven.compiler.source>1.8</maven.compiler.source>
         <maven.compiler.target>1.8</maven.compiler.target>
         <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
-        <mybatis-plus.version>3.3.0</mybatis-plus.version>
+        <mybatis-plus.version>3.5.3.1</mybatis-plus.version>
     </properties>
     <dependencyManagement>
         <dependencies>
@@ -249,12 +249,6 @@
             </exclusions>
         </dependency>
 
-
-<!--        <dependency>-->
-<!--            <groupId>org.mybatis.spring.boot</groupId>-->
-<!--            <artifactId>mybatis-spring-boot-starter</artifactId>-->
-<!--            <version>2.3.0</version> &lt;!&ndash; 请使用最新版本 &ndash;&gt;-->
-<!--        </dependency>-->
         <dependency>
             <groupId>mysql</groupId>
             <artifactId>mysql-connector-java</artifactId>

src/main/java/com/cmeeting/config/MasterDataSourceConfig.java

 package com.cmeeting.config;
 
+import com.baomidou.mybatisplus.annotation.DbType;
+import com.baomidou.mybatisplus.extension.plugins.MybatisPlusInterceptor;
+import com.baomidou.mybatisplus.extension.plugins.inner.PaginationInnerInterceptor;
 import com.baomidou.mybatisplus.extension.spring.MybatisSqlSessionFactoryBean;
 import org.apache.ibatis.session.SqlSessionFactory;
 import org.mybatis.spring.SqlSessionTemplate;
@@ -26,12 +29,20 @@ public class MasterDataSourceConfig {
         return DataSourceBuilder.create().build();
     }
 
+    @Bean
+    public MybatisPlusInterceptor mybatisPlusInterceptor() {
+        MybatisPlusInterceptor interceptor = new MybatisPlusInterceptor();
+        interceptor.addInnerInterceptor(new PaginationInnerInterceptor(DbType.MYSQL));
+        return interceptor;
+    }
+
     @Primary
     @Bean(name = "masterSqlSessionFactory")
     public SqlSessionFactory masterSqlSessionFactory(@Qualifier("masterDataSource") DataSource dataSource) throws Exception {
         MybatisSqlSessionFactoryBean bean = new MybatisSqlSessionFactoryBean();
         bean.setDataSource(dataSource);
         bean.setMapperLocations(new PathMatchingResourcePatternResolver().getResources("classpath:mapper/primary/*.xml"));
+        bean.setPlugins(mybatisPlusInterceptor());
         return bean.getObject();
     }
 

src/main/java/com/cmeeting/job/CmeetingJob.java

@@ -38,15 +38,15 @@ public class CmeetingJob {
     @Autowired
     private FileProcessProducer producer;
 
-    @PostConstruct
-    public void weComUserInit(){
-        weComUserSync();
-    }
-
-    @PostConstruct
-    public void tencentUserInit(){
-        TencentUserSync();
-    }
+//    @PostConstruct
+//    public void weComUserInit(){
+//        weComUserSync();
+//    }
+//
+//    @PostConstruct
+//    public void tencentUserInit(){
+//        TencentUserSync();
+//    }
 
     /**
      * 企微人员定时同步
@@ -165,7 +165,7 @@ public class CmeetingJob {
         }
 
         // 提交处理任务
-        producer.submitBatchTasks(meetingFiles, "/save/",Boolean.FALSE);
+        producer.submitBatchTasks(meetingFiles,Boolean.FALSE);
     }
 
 
@@ -202,7 +202,7 @@ public class CmeetingJob {
 //            List<UserDTO> accessUserIds = tecentMeetingService.getAccessUserIds();
 
             // 提交处理任务
-            producer.submitBatchTasks(meetingFiles, "/save/", Boolean.TRUE);
+            producer.submitBatchTasks(meetingFiles, Boolean.TRUE);
             log.info("-------生成纪要重试定时任务结束--------");
         } catch (Exception e) {
             e.printStackTrace();
@@ -239,7 +239,7 @@ public class CmeetingJob {
             }
 
             // 提交处理任务
-            producer.submitEmailPushTasks(meetingFiles, "/save/");
+            producer.submitEmailPushTasks(meetingFiles);
             log.info("-------邮件推送重试定时任务结束--------");
         } catch (Exception e) {
             e.printStackTrace();

src/main/java/com/cmeeting/job/FileProcessTask.java

@@ -52,6 +52,7 @@ import java.nio.charset.StandardCharsets;
 import java.nio.file.Files;
 import java.nio.file.Paths;
 import java.security.SecureRandom;
+import java.text.MessageFormat;
 import java.time.Instant;
 import java.time.LocalDateTime;
 import java.time.ZoneId;
@@ -162,6 +163,8 @@ public class FileProcessTask {
                     throw new RuntimeException("获取的转录文本为空，跳过纪要生成");
                 }
                 // 3. 处理文件 (调用Claude API等)
+                String choiceTemplateType = choiceTemplateType(meetingInfo.getSubject(),recordTextBuffer.toString());
+                log.info("choiceTemplateType->{}",choiceTemplateType);
                 String processedResult = processWithClaude(recordTextBuffer.toString());
 
                 // 4. 保存结果
@@ -234,6 +237,33 @@ public class FileProcessTask {
         log.info("DOCX content as string:\n{}", textContent);
         return textContent;
     }
+
+    /**
+     * 提供会议转录文件和会议主题，判断会议类型
+     * @param subject
+     * @param textContent
+     * @return
+     */
+    private String choiceTemplateType(String subject,String textContent) {
+        String token = "AKIAXFAXF62IWJXGLVEE.LnKInaahcMZG9zLsGMH3nTLOw3S3lK5Vcu0+ifnO";
+        String apiAddr = llmApiAddr + "/llm/sse-invoke";
+        String model = "anthropic.claude-3-5-sonnet-20240620-v1:0";
+        int maxTokens = 5000;
+        String prompt = "请先对以下会议转写记录进行简要总结（不超过200字），然后根据会议主题以及总结内容判断该会议最可能属于哪种类型：\\n\\n会议主题： {0}\\n会议转写记录： {1}\\n\\n第一步：请简要总结会议的主要内容和目的（不超过200字）。\\n\\n第二步：根据上述总结和会议主题，将会议分类为以下类型之一：\\n1. 项目沟通会 - 与具体项目进展、问题讨论相关的会议\\n2. 重要会议 - 高层决策、战略规划等重要会议\\n3. 启动会 - 项目启动、活动筹备等初始会议\\n4. 其他 - 不符合以上任何分类\\n\\n分类权重判断规则：\\n- 基础权重分配：会议内容总结(70%)、会议主题(30%)\\n- 会议主题权重动态调整：\\n  * 如果会议主题包含明确分类关键词（如\\\"启动会\\\"、\\\"项目沟通\\\"、\\\"战略决策\\\"等），则会议主题权重提升至60%，总结内容权重调整为40%\\n  * 如果会议主题过于简单或模糊（如仅包含\\\"沟通\\\"、\\\"讨论\\\"、\\\"会议\\\"等通用词），则会议主题权重降低至15%，总结内容权重提升至85%\\n- 一致性判断：如果会议主题和总结内容指向不同分类，优先采用内容总结的分类，除非会议主题非常明确且规范\\n\\n输出格式：\\n请只返回分类名称(如\\\"项目沟通会\\\")，不要包含其他内容（如生成的会议总结等）。";
+        //占位符信息替换
+        String formatPrompt = formatMessage(prompt, subject, textContent);
+        List<Message> messages = new ArrayList<>();
+        ChatMessage chatMessage = new ChatMessage(ChatMessageRole.USER.value(), formatPrompt);
+        messages.add(chatMessage);
+
+        // 调用Claude API处理文件
+        String ret = call_llm(apiAddr, model, token, messages, maxTokens);
+        return ret;
+    }
+
+    private String formatMessage(String pattern, Object... args) {
+        return MessageFormat.format(pattern, args);
+    }
     
     private String processWithClaude(String textContent) {
         //将文件传送给大模型处理

src/main/java/com/cmeeting/pojo/MeetingRecordTemplate.java

@@ -71,4 +71,9 @@ public class MeetingRecordTemplate implements Serializable {
      * 更新人
      */
     private String updateUser;
+
+    /**
+     * 删除标识
+     */
+    private Boolean isDel;
 }
\ No newline at end of file

src/main/java/com/cmeeting/service/FileProcessProducer.java

@@ -44,6 +44,8 @@ public class FileProcessProducer {
     private String tencentAdminUserId;
     @Value(value = "${llm.api-addr}")
     private String llmApiAddr;
+    @Value(value = "${tencent.base-save-path}")
+    private String baseSavePath;
     @Resource
     private MeetingInfoMapper meetingInfoMapper;
     @Resource
@@ -58,10 +60,10 @@ public class FileProcessProducer {
     /**
      * 批量提交生成纪要任务
      * @param recordFiles 转录文件信息
-     * @param baseSavePath 存储临时路径
+     * @param finalRetry 是否为最终重试
      * @param finalRetry
      */
-    public void submitBatchTasks(List<TencentMeetingVO.RecordFile> recordFiles, String baseSavePath, Boolean finalRetry) {
+    public void submitBatchTasks(List<TencentMeetingVO.RecordFile> recordFiles, Boolean finalRetry) {
         List<Future<?>> futures = new ArrayList<>();
         
         for (TencentMeetingVO.RecordFile recordFile : recordFiles) {
@@ -100,7 +102,7 @@ public class FileProcessProducer {
     }
 
     // 批量提交邮箱推送重试任务
-    public void submitEmailPushTasks(List<TencentMeetingVO.RecordFile> recordFiles, String baseSavePath) {
+    public void submitEmailPushTasks(List<TencentMeetingVO.RecordFile> recordFiles) {
         List<Future<?>> futures = new ArrayList<>();
 
         for (TencentMeetingVO.RecordFile recordFile : recordFiles) {

src/main/java/com/cmeeting/service/MeetingRecordTemplateService.java

 package com.cmeeting.service;
 
+import com.baomidou.mybatisplus.core.metadata.IPage;
 import com.baomidou.mybatisplus.extension.service.IService;
 import com.cmeeting.pojo.MeetingRecordTemplate;
+import com.cmeeting.vo.RecordTemplateVO;
 
 public interface MeetingRecordTemplateService extends IService<MeetingRecordTemplate> {
+    IPage<MeetingRecordTemplate> getPage(RecordTemplateVO vo);
 }

src/main/java/com/cmeeting/service/impl/MeetingRecordTemplateServiceImpl.java

 package com.cmeeting.service.impl;
 
+import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
+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.cmeeting.mapper.primary.MeetingRecordTemplateMapper;
 import com.cmeeting.pojo.MeetingRecordTemplate;
 import com.cmeeting.service.MeetingRecordTemplateService;
+import com.cmeeting.vo.RecordTemplateVO;
 import org.springframework.stereotype.Service;
 
+import javax.annotation.Resource;
+import java.util.List;
+
 @Service
 public class MeetingRecordTemplateServiceImpl extends ServiceImpl<MeetingRecordTemplateMapper, MeetingRecordTemplate>  implements MeetingRecordTemplateService {
+
+    @Resource
+    private MeetingRecordTemplateMapper mapper;
+
+    @Override
+    public IPage<MeetingRecordTemplate> getPage(RecordTemplateVO vo) {
+        LambdaQueryWrapper<MeetingRecordTemplate> queryWrapper = new LambdaQueryWrapper<>();
+        queryWrapper.eq(MeetingRecordTemplate::getIsDel,Boolean.FALSE);
+        IPage<MeetingRecordTemplate> resultPage = mapper.selectPage(new Page<>(vo.getCurrent(), vo.getSize()), queryWrapper);
+        return resultPage;
+    }
 }
\ No newline at end of file

src/main/java/com/cmeeting/util/R.java

+package com.cmeeting.util;
+
+import com.fasterxml.jackson.annotation.JsonInclude;
+import lombok.Builder;
+import lombok.Data;
+import lombok.ToString;
+import lombok.experimental.Accessors;
+
+import java.io.Serializable;
+
+
+/**
+ * 返回值
+ *
+ * @author 王长伟
+ */
+@Data
+@ToString
+@Accessors(chain = true)
+@Builder
+public class R implements Serializable {
+
+    public static final int SUCCESS_CODE = 0;
+    public static final int FAIL_CODE = -1;
+
+    public static final String SUCCESS = "操作成功";
+    public static final String FAIL = "操作失败";
+
+    private String message;
+
+    @JsonInclude(JsonInclude.Include.NON_NULL)
+    private Object data;
+
+    private int code;
+
+    public static R ok() {
+        return R.builder().message(SUCCESS).build();
+    }
+
+    public static R ok(Object data) {
+        return R.builder().message(SUCCESS).data(data).build();
+    }
+
+    public static R ok(int code, Object data) {
+        return R.builder().message(SUCCESS).code(code).data(data).build();
+    }
+
+    public static R ok(int code, String message, Object data) {
+        return R.builder().message(message).data(data).code(code).build();
+    }
+
+    public static R error() {
+        return R.builder().message(FAIL).code(FAIL_CODE).build();
+    }
+
+    public static R error(String message) {
+        return R.builder().message(message).code(FAIL_CODE).build();
+    }
+
+    public static R error(int code, String message) {
+        return R.builder().message(message).code(code).build();
+    }
+
+    public static R error(int code, String message, Object data) {
+        return R.builder().message(message).code(code).data(data).build();
+    }
+
+}

src/main/java/com/cmeeting/vo/RecordTemplateVO.java

+package com.cmeeting.vo;
+
+import lombok.Data;
+
+/**
+ * 会议纪要模板展示层
+ */
+@Data
+public class RecordTemplateVO {
+
+    /**
+     * 主键id
+     */
+    private Integer id;
+
+    /**
+     * 模板名称
+     */
+    private String name;
+    
+    /**
+     * 模板类型（系统模板/自定义模板）
+     */
+    private String type;
+
+    /**
+     * 会议类型
+     */
+    private String meetingType;
+    
+    /**
+     * 会议类型描述
+     */
+    private String typeDetail;
+
+    /**
+     * 当前页
+     */
+    private Integer current;
+
+    /**
+     * 每页最大数据行
+     */
+    private Integer size;
+}
\ No newline at end of file

src/main/resources/application.yml

@@ -80,6 +80,7 @@ mybatis-plus:
   mapper-locations: classpath*:mapper/**/*.xml
   configuration:
     map-underscore-to-camel-case: true
+    log-impl: org.apache.ibatis.logging.stdout.StdOutImpl
 # 也建议开启
 global-config:
   db-config:
@@ -103,6 +104,7 @@ tencent:
   meeting:
     token: QQZNb7xWQB47MpZF4C2DFAkv8
     aesKey: agy6ALUePp34lljWz1uIQWa7yQq3dgxxQNmfaN9GROm
+  base-save-path: /save/
 
 email:
   sender: ${EMAIL_SENDER}