debug

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

@@ -99,7 +99,7 @@ public class MeetingInfo implements Serializable {
      */
     private Boolean isPushed;
     /**
-     * 会议状态： 0新会议待处理 1生成纪要失败 2生成纪要成功 3推送邮件成功 4推送邮件失败 5转录文件为空
+     * 会议状态： 0新会议待处理 1生成纪要失败 2生成纪要成功 3推送邮件成功 4推送邮件失败 5转录文件为空 6文件已删除
      */
     private Integer status;
     /**
@@ -154,6 +154,7 @@ public class MeetingInfo implements Serializable {
      * 是否在重新生成
      */
     private Boolean reprocess = false;
+    private Boolean clear = false;
 
     @TableField(exist = false)
     private String userId;

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

@@ -132,7 +132,7 @@ public class MeetingInfoServiceImpl extends ServiceImpl<MeetingInfoMapper, Meeti
                 .between(vo.getStartTime() != null, MeetingInfo::getStartTime, vo.getStartTime(), vo.getEndTime())
                 .orderByDesc(MeetingInfo::getStartTime)
                 .select(MeetingInfo::getId, MeetingInfo::getMeetingId, MeetingInfo::getSubject, MeetingInfo::getHost, MeetingInfo::getHostUid,
-                        MeetingInfo::getStartTime, MeetingInfo::getEndTime, MeetingInfo::getIsGenerated, MeetingInfo::getIsPushed, MeetingInfo::getReprocess);
+                        MeetingInfo::getStartTime, MeetingInfo::getEndTime, MeetingInfo::getIsGenerated, MeetingInfo::getIsPushed, MeetingInfo::getReprocess, MeetingInfo::getClear);
         Page<MeetingInfo> meetingInfoPage = mapper.selectPage(new Page<>(vo.getCurrent(), vo.getSize()), queryWrapper);
         if (CollUtil.isNotEmpty(meetingInfoPage.getRecords())) {
             List<MeetingInfo> records = meetingInfoPage.getRecords();
@@ -179,14 +179,14 @@ public class MeetingInfoServiceImpl extends ServiceImpl<MeetingInfoMapper, Meeti
             log.warn("key already exists in redis!, key: {}", key);
             return false;
         }
+        meetingInfoMapper.update(null,
+                new LambdaUpdateWrapper<MeetingInfo>()
+                        .eq(MeetingInfo::getMeetingId, meetingInfo.getMeetingId())
+                        .eq(meetingInfo.getSubMeetingId() != null, MeetingInfo::getSubMeetingId, meetingInfo.getSubMeetingId())
+                        .set(MeetingInfo::getReprocess, true)
+        );
         regenerateProcessExecutor.execute(()->{
             try{
-                meetingInfoMapper.update(null,
-                        new LambdaUpdateWrapper<MeetingInfo>()
-                                .eq(MeetingInfo::getMeetingId, meetingInfo.getMeetingId())
-                                .eq(meetingInfo.getSubMeetingId() != null, MeetingInfo::getSubMeetingId, meetingInfo.getSubMeetingId())
-                                .set(MeetingInfo::getReprocess, true)
-                );
                 regenerateXml(meetingInfo, meetingRecordTemplate);
             } finally {
                 meetingInfoMapper.update(null,

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

@@ -128,7 +128,6 @@ public class TencentMeetingServiceImpl extends ServiceImpl<TecentMeetingMapper,
     public List<TencentMeetingVO.RecordFile> getMeetingFiles(List<UserDTO> accessUserIds, Map<String, WeComUser> weComUserMap) {
         List<TencentMeetingVO.RecordFile> meetingFiles = new ArrayList<>();
         List<MeetingInfo> meetingSaveList = new ArrayList<>();
-        int i = 0;
         // 查询近searchDays天的会议录制列表
         try {
             ZonedDateTime now = ZonedDateTime.now();
@@ -158,9 +157,6 @@ public class TencentMeetingServiceImpl extends ServiceImpl<TecentMeetingMapper,
             List<TencentMeetingUser> meetingUsers = tecentMeetingMapper.getAlluser();
             Map<String, String> meetingMap = meetingUsers.stream().collect(Collectors.toMap(TencentMeetingUser::getUserId, TencentMeetingUser::getUserName));
             while (currentPage.intValue() <= totalPage){
-                if (i >= 150) {
-                    break;
-                }
                 CorpRecordsVO data = fetchMeetingRecords(tencentAdminUserId, 1, startTime, endTime, currentPage.getAndIncrement(), 20);
                 //设置总页数
                 if (data != null && data.getRecordMeetings() != null && !data.getRecordMeetings().isEmpty()) {
@@ -296,7 +292,6 @@ public class TencentMeetingServiceImpl extends ServiceImpl<TecentMeetingMapper,
                                         .email(email)
                                         .build();
                                 meetingSaveList.add(meetingItem);
-                                i++;
                             }
                         } catch (Exception e) {
                             if (e instanceof NoSuchElementException) {

src/main/resources/mapper/primary/MeetingInfoMapper.xml

@@ -62,7 +62,7 @@
     </select>
 
     <delete id="deleteDataAfterThan2Days">
-        update cmt_meeting_info set record_content = '', record_xml = '' where start_time &lt; DATE_SUB(#{date}, INTERVAL 1 DAY);
+        update cmt_meeting_info set record_content = '', record_xml = '',clear = 1 where start_time &lt; DATE_SUB(#{date}, INTERVAL 1 DAY);
     </delete>
 
 </mapper>