1、添加统计会议纪要推送数据

src/main/java/com/cmeeting/controller/MeetingInfoController.java

@@ -2,7 +2,6 @@ package com.cmeeting.controller;
 
 import cn.hutool.core.date.DateUtil;
 import cn.hutool.core.io.IoUtil;
-import cn.hutool.core.util.IdUtil;
 import com.baomidou.mybatisplus.core.metadata.IPage;
 import com.cmeeting.ad.entity.RobotSecurityUser;
 import com.cmeeting.ad.util.SecurityUtil;
@@ -22,18 +21,13 @@ import com.fasterxml.jackson.databind.JsonNode;
 import com.fasterxml.jackson.databind.ObjectMapper;
 import com.fasterxml.jackson.dataformat.xml.XmlMapper;
 import lombok.extern.slf4j.Slf4j;
-import org.apache.commons.io.IOUtils;
 import org.apache.commons.lang3.StringUtils;
 import org.apache.poi.xwpf.usermodel.XWPFDocument;
 import org.apache.poi.xwpf.usermodel.XWPFParagraph;
 import org.apache.poi.xwpf.usermodel.XWPFRun;
 import org.springframework.beans.BeanUtils;
 import org.springframework.beans.factory.annotation.Value;
-import org.springframework.core.io.ClassPathResource;
-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;
+import org.springframework.web.bind.annotation.*;
 
 import javax.annotation.Resource;
 import javax.servlet.http.HttpServletResponse;
@@ -305,4 +299,11 @@ public class MeetingInfoController {
         }
         return json;
     }
+
+
+    @GetMapping("/statistics")
+    public void statisticsEmail(HttpServletResponse response) {
+
+        meetingInfoService.statisticsEmail(, response);
+    }
 }

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

@@ -5,10 +5,18 @@ import com.baomidou.mybatisplus.extension.service.IService;
 import com.cmeeting.pojo.MeetingInfo;
 import com.cmeeting.vo.MeetingInfoVO;
 
+import javax.servlet.http.HttpServletResponse;
+
 public interface MeetingInfoService extends IService<MeetingInfo> {
     IPage<MeetingInfo> getPage(MeetingInfoVO vo);
 
     boolean updateRecordXml(MeetingInfoVO vo);
 
     boolean regenerateXml(MeetingInfoVO vo);
+
+    /**
+     * 统计邮件推送情况
+     */
+    void statisticsEmail(Integer type, HttpServletResponse response);
+
 }

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

@@ -5,8 +5,12 @@ import cn.chatbot.openai.completion.chat.ChatMessage;
 import cn.chatbot.openai.completion.chat.ChatMessageRole;
 import cn.chatbot.openai.completion.chat.Message;
 import cn.chatbot.openai.service.LLMService;
-import cn.hutool.core.io.FileUtil;
+import cn.hutool.core.date.DateField;
+import cn.hutool.core.date.DateTime;
+import cn.hutool.core.date.DateUtil;
 import cn.hutool.core.util.IdUtil;
+import cn.hutool.poi.excel.ExcelUtil;
+import cn.hutool.poi.excel.ExcelWriter;
 import com.alibaba.fastjson2.JSON;
 import com.alibaba.fastjson2.JSONArray;
 import com.alibaba.fastjson2.JSONObject;
@@ -17,6 +21,7 @@ import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
 import com.cmeeting.ad.entity.RobotSecurityUser;
 import com.cmeeting.ad.util.SecurityUtil;
+import com.cmeeting.constant.MeetingState;
 import com.cmeeting.log.service.ProcessLogService;
 import com.cmeeting.mapper.primary.MeetingInfoMapper;
 import com.cmeeting.mapper.primary.MeetingRecordTemplateMapper;
@@ -24,10 +29,11 @@ import com.cmeeting.mapper.primary.UserIdMapper;
 import com.cmeeting.pojo.MeetingInfo;
 import com.cmeeting.pojo.MeetingRecordTemplate;
 import com.cmeeting.service.MeetingInfoService;
+import com.cmeeting.service.MeetingRecordTemplateService;
+import com.cmeeting.service.TencentMeetingService;
+import com.cmeeting.service.WeComService;
 import com.cmeeting.util.MinioUtils;
-import com.cmeeting.vo.EmailPush;
 import com.cmeeting.vo.MeetingInfoVO;
-import com.deepoove.poi.XWPFTemplate;
 import com.fasterxml.jackson.databind.ObjectMapper;
 import com.fasterxml.jackson.dataformat.xml.XmlMapper;
 import com.tencentcloudapi.wemeet.Client;
@@ -43,21 +49,22 @@ import lombok.extern.slf4j.Slf4j;
 import okhttp3.OkHttpClient;
 import okhttp3.Request;
 import okhttp3.Response;
-import org.apache.commons.io.IOUtils;
 import org.apache.commons.lang3.StringUtils;
+import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.beans.factory.annotation.Value;
 import org.springframework.stereotype.Service;
 
 import javax.annotation.Resource;
+import javax.servlet.http.HttpServletResponse;
 import java.io.*;
 import java.math.BigInteger;
+import java.net.URLEncoder;
 import java.nio.charset.Charset;
 import java.nio.charset.StandardCharsets;
 import java.security.SecureRandom;
 import java.time.LocalDateTime;
 import java.time.format.DateTimeFormatter;
 import java.util.*;
-import java.util.concurrent.ConcurrentHashMap;
 import java.util.stream.Collectors;
 
 @Service
@@ -90,6 +97,17 @@ public class MeetingInfoServiceImpl extends ServiceImpl<MeetingInfoMapper, Meeti
     private MeetingInfoMapper meetingInfoMapper;
     @Resource
     private UserIdMapper userIdMapper;
+    @Autowired
+    private WeComService weComService;
+    @Autowired
+    private TencentMeetingService tencentMeetingService;
+    @Autowired
+    private MeetingRecordTemplateService meetingRecordTemplateService;
+
+
+    private String CLIENT_ID = "c06fe7cf-2a89-4099-9805-ce03031938f8";
+    private String CLIENT_SECRET = "wsu8Q~GxYxPLf2akioQZDRG8NR1EzCAHIAQRVc6u";
+    private String TENANT_ID = "18653b3e-03c7-499e-8baf-42ef06a814ef";
 
     @Override
     public IPage<MeetingInfo> getPage(MeetingInfoVO vo) {
@@ -402,4 +420,96 @@ public class MeetingInfoServiceImpl extends ServiceImpl<MeetingInfoMapper, Meeti
             throw new RuntimeException("下载文件失败", e);
         }
     }
+
+    /**
+     * 统计邮件推送情况
+     */
+    @Override
+    public void statisticsEmail(Integer type, HttpServletResponse response) {
+
+        DateTime now = DateUtil.date();
+        DateTime startDate;
+        DateTime endTime;
+        if (1== type) {
+            startDate = DateUtil.beginOfDay(DateUtil.offset(now, DateField.DAY_OF_MONTH, -2));
+            endTime = DateUtil.offset(now, DateField.HOUR_OF_DAY, -2);
+        } else {
+            startDate = DateUtil.beginOfDay(now);
+            endTime = now;
+        }
+
+
+        List<MeetingInfo> meetingInfoList = meetingInfoMapper.selectList(new LambdaQueryWrapper<MeetingInfo>()
+                                                .eq(MeetingInfo::getEmailPushAccess, true)
+                                                .between(MeetingInfo::getStartTime, startDate, endTime));
+        Map<String, List<MeetingInfo>> hostUidMeetingInfoMap = meetingInfoList.stream().collect(Collectors.groupingBy(MeetingInfo::getHostUid));
+        Map<String, String> hostMap = meetingInfoList.stream().collect(Collectors.toMap(MeetingInfo::getHostUid, MeetingInfo::getHost));
+
+        List<Map<String, Object>> mapList = new ArrayList<>();
+        for (Map.Entry<String, List<MeetingInfo>> entry : hostUidMeetingInfoMap.entrySet()) {
+            Map<String, Object> map = new LinkedHashMap<>();
+
+            String host = hostMap.get(entry.getKey());
+            List<MeetingInfo> meetingList = entry.getValue();
+            Integer totalNum = meetingList.size();
+            Integer newNum=0,  generatErrorNum=0, noteGeneratedNum=0, pushSuccessNum=0, pushErrorNum=0, emptyNum=0;
+
+            for (MeetingInfo meetingInfo : meetingList) {
+                if (meetingInfo.getStatus() == MeetingState.NEW.getCode()) {
+                    newNum++;
+                } else if (meetingInfo.getStatus() == MeetingState.GENERATE_ERROR.getCode()) {
+                    generatErrorNum++;
+                } else if (meetingInfo.getStatus() == MeetingState.NOTE_GENERATED.getCode()) {
+                    noteGeneratedNum++;
+                } else if (meetingInfo.getStatus() == MeetingState.PUSH_SUCCESS.getCode()) {
+                    pushSuccessNum++;
+                } else if (meetingInfo.getStatus() == MeetingState.PUSH_ERROR.getCode()) {
+                    pushErrorNum++;
+                } else if (meetingInfo.getStatus() == MeetingState.EMPTY.getCode()) {
+                    emptyNum++;
+                }
+            }
+            map.put("host", host);
+            map.put("totalNum", totalNum);
+            map.put("newNum", newNum);
+            map.put("generatErrorNum", generatErrorNum);
+            map.put("noteGeneratedNum", noteGeneratedNum);
+            map.put("pushErrorNum", pushErrorNum);
+            map.put("pushSuccessNum", pushSuccessNum);
+            map.put("emptyNum", emptyNum);
+            mapList.add(map);
+        }
+
+        // 导出
+        ExcelWriter writer = ExcelUtil.getWriter(true);
+        try {
+            String title = String.format("纪要模板推送统计表-%s", DateUtil.format(now, "yyyy-MM-dd_HH:mm"));
+
+            OutputStream outputStream = response.getOutputStream();
+            String fileName = String.format("%s.xlsx", title);
+            response.setContentType("application/vnd.openxmlformats-officedocument.spreadsheetml.sheet;charset=utf-8");
+            response.setHeader("Content-Disposition", "attachment;filename=" + URLEncoder.encode(fileName, "utf8"));
+
+
+            writer.addHeaderAlias("host", "主持人");
+            writer.addHeaderAlias("totalNum", "会议总数");
+            writer.addHeaderAlias("newNum", "待处理");
+            writer.addHeaderAlias("generatErrorNum", "处理中");
+            writer.addHeaderAlias("noteGeneratedNum", "纪要生成成功");
+            writer.addHeaderAlias("pushSuccessNum", "纪要推送成功");
+            writer.addHeaderAlias("pushErrorNum", "纪要推送失败");
+            writer.addHeaderAlias("emptyNum", "没有转录文件");
+            // 合并单元格后的标题行，使用默认标题样式
+            writer.merge(writer.getHeaderAlias().size() - 1, title);
+            // 一次性写出内容，使用默认样式，强制输出标题
+            writer.write(mapList, true);
+            writer.flush(outputStream);
+            // 关闭writer，释放内存
+            writer.close();
+        } catch (Exception e) {
+            e.printStackTrace();
+        } finally {
+            writer.close();
+        }
+    }
 }