添加会议记录和时间限制

(cherry picked from commit 18ab55f)

Author: heavyrian2012

config/application.properties

@@ -152,3 +152,6 @@ spring.mail.to_lists=admin1@wildfirechat.cn,admin2@wildfirechat.cn,admin3@wildfi
 
 # 头像背景颜色可选列表，逗号分隔，中间不能有空格
 avatar.bg.corlors=#D32F2F,#D81B60,#880E4F,#9C27B0,#6A1B9A,#4A148C,#AA00FF,#C51162,#673AB7,#311B92,#651FFF,#5C6BC0,#283593,#1A237E,#304FFE,#1976D2,#0D47A1,#2962FF,#0D47A1,#0277BD,#01579B
+
+# 会议配额配置：默认会议额度（分钟），当用户没有单独配置配额时使用。0表示不限制
+conference.default_quota_minutes=0

src/main/java/cn/wildfirechat/app/RestResult.java

@@ -23,7 +23,8 @@ public enum  RestCode {
         ERROR_PASSWORD_INCORRECT(19, "密码错误"),
         ERROR_FAILURE_TOO_MUCH_TIMES(20, "密码错误次数太多，请等5分钟再试试"),
         ERROR_USER_FORBIDDEN(21, "用户被封禁"),
-        ERROR_SLIDE_VERIFY_NOT_PASS(22, "滑动验证未通过");
+        ERROR_SLIDE_VERIFY_NOT_PASS(22, "滑动验证未通过"),
+        ERROR_CONFERENCE_QUOTA_EXCEEDED(23, "会议额度已用完");
         public int code;
         public String msg;
 

src/main/java/cn/wildfirechat/app/conference/ConferenceCleanupService.java

@@ -0,0 +1,68 @@
+package cn.wildfirechat.app.conference;
+
+import cn.wildfirechat.app.jpa.ConferenceEntity;
+import cn.wildfirechat.app.jpa.ConferenceEntityRepository;
+import cn.wildfirechat.common.ErrorCode;
+import cn.wildfirechat.sdk.ConferenceAdmin;
+import cn.wildfirechat.sdk.model.IMResult;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.scheduling.annotation.Scheduled;
+import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
+
+import java.util.List;
+
+@Service
+public class ConferenceCleanupService {
+    private static final Logger LOG = LoggerFactory.getLogger(ConferenceCleanupService.class);
+
+    @Autowired
+    private ConferenceEntityRepository conferenceEntityRepository;
+
+    @Autowired
+    private ConferenceServiceImpl conferenceServiceImpl;
+
+    /**
+     * 每5分钟检查一次过期会议，并调用SDK销毁
+     */
+    @Scheduled(fixedRate = 5 * 60 * 1000)
+    @Transactional
+    public void cleanupExpiredConferences() {
+        long currentTime = System.currentTimeMillis() / 1000; // 转换为秒
+        LOG.info("开始检查过期会议，当前时间: {} 秒", currentTime);
+
+        List<ConferenceEntity> expiredConferences = conferenceEntityRepository.findExpiredConferences(currentTime);
+        LOG.info("发现 {} 个过期会议", expiredConferences.size());
+
+        for (ConferenceEntity conference : expiredConferences) {
+            try {
+                LOG.info("正在销毁过期会议: {}, endTime: {}", conference.id, conference.endTime);
+                
+                // 调用SDK销毁会议
+                IMResult<Void> result = ConferenceAdmin.destroy(conference.id, conference.advance);
+                if (result != null && result.getErrorCode() == ErrorCode.ERROR_CODE_SUCCESS) {
+                    LOG.info("成功销毁会议: {}", conference.id);
+                } else {
+                    LOG.warn("销毁会议 {} 返回错误: {}", conference.id, 
+                        result != null ? result.getErrorCode().getMsg() : "null result");
+                }
+
+                Thread.sleep(100);
+                
+                // 记录会议结束并更新使用量（使用计划的endTime作为实际结束时间）
+                conferenceServiceImpl.endConferenceAndUpdateUsage(conference.id, conference.endTime);
+                
+                // 从数据库删除会议记录
+                conferenceEntityRepository.delete(conference);
+                LOG.info("已从数据库删除会议记录: {}", conference.id);
+                
+            } catch (Exception e) {
+                LOG.error("销毁会议 {} 时发生异常", conference.id, e);
+            }
+        }
+
+        LOG.info("过期会议清理完成，共处理 {} 个会议", expiredConferences.size());
+    }
+}

src/main/java/cn/wildfirechat/app/conference/ConferenceController.java

@@ -86,4 +86,10 @@ public Object isFavConference(@PathVariable("conferenceId") String conferenceId)
     public Object getFavConferences() throws IOException {
         return mService.getFavConferences();
     }
+
+    @CrossOrigin
+    @PostMapping(value = "/conference/quota")
+    public Object getMyConferenceQuota() throws IOException {
+        return mService.getMyConferenceQuota();
+    }
 }

src/main/java/cn/wildfirechat/app/conference/ConferenceService.java

@@ -22,4 +22,10 @@ public interface ConferenceService {
     RestResult unfavConference(String conferenceId);
     RestResult getFavConferences();
     RestResult isFavConference(String conferenceId);
+    
+    /**
+     * 查询当前用户的会议额度
+     * @return 额度信息（包含总额度、已使用、剩余额度）
+     */
+    RestResult getMyConferenceQuota();
 }