OA2023/OASystem/OASystem.Api/OAMethodLib/Quartz/Jobs/WeeklyFridayJob.cs

using Quartz;
using OASystem.API.OAMethodLib.QiYeWeChatAPI;
using OASystem.Domain.ViewModels.QiYeWeChat;
using Newtonsoft.Json;
using Newtonsoft.Json.Linq;
using Microsoft.AspNetCore.Http;

namespace OASystem.API.OAMethodLib.Quartz.Jobs
{
    /// <summary>
    /// 每周五下午4点执行的定时任务
    /// </summary>
    public class WeeklyFridayJob : IJob
    {
        private readonly ILogger<WeeklyFridayJob> _logger;
        private readonly SqlSugarClient _sqlSugar;
        private readonly IQiYeWeChatApiService _qiYeWeChatApiService;
        private readonly HttpClient _httpClient;

        public WeeklyFridayJob(ILogger<WeeklyFridayJob> logger, SqlSugarClient sqlSugar
        , IHttpClientFactory httpClientFactory, IQiYeWeChatApiService qiYeWeChatApiService)
        {
            _logger = logger;
            _sqlSugar = sqlSugar;
            _httpClient = httpClientFactory.CreateClient();
            _qiYeWeChatApiService = qiYeWeChatApiService;

            _httpClient.Timeout = TimeSpan.FromMinutes(10);
        }

        public async Task Execute(IJobExecutionContext context)
        {
            var jobName = context.JobDetail.Key.Name;
            _logger.LogInformation($"开始执行任务 {jobName}，时间：{DateTime.Now:yyyy-MM-dd HH:mm:ss}");

            try
            {
                var startDate = DateTime.Today.AddDays(-4);
                var endDate = DateTime.Today.AddDays(1);
                string baseUrl = "http://132.232.92.186:8888";//"http://localhost:5256";
                var createUserId = 4;

                var sqSetting = _sqlSugar.Queryable<Sys_SetData>().First(x => x.Id == 1417);
                if (sqSetting != null)
                {
                    Dictionary<int, List<int>> result = JsonConvert.DeserializeObject<Dictionary<int, List<int>>>(sqSetting.Remark);
                    result.Add(235, new List<int> { 258 });

                    foreach (var item in result.Keys)
                    {
                        var keyUser = await _sqlSugar.Queryable<Sys_Users>()
                        .FirstAsync(x => x.Id == item);

                        if (keyUser == null || string.IsNullOrEmpty(keyUser.Email))
                        {
                            _logger.LogWarning($"管理者(ID:{item})不存在或未配置邮箱，跳过发送汇总邮件。");
                            continue;
                        }

                        var users = await _sqlSugar.Queryable<Sys_Users>()
                            .LeftJoin<Sys_Department>((u, d) => u.DepId == d.Id)
                            .LeftJoin<Sys_JobPost>((u, d, jp) => u.JobPostId == jp.Id)
                            .Where((u, d, jp) => u.IsDel == 0 && result[item].Contains(u.Id) && u.Id != item)
                            .Select((u, d, jp) => new { u.Id, u.CnName, DepName = d.DepName ?? "", JobName = jp.JobName ?? "" })
                            .ToListAsync();

                        // 用于收集该管理者下所有员工的附件
                        var attachments = new List<IFormFile>();

                        foreach (var user in users)
                        {
                            // 构建API URL
                            string apiUrl = $"{baseUrl}/api/PersonnelModule/AiPerformanceAnalysis_AllDepartment";

                            // 构建查询参数
                            var queryParams = new Dictionary<string, string>
                            {
                                { "userId", user.Id.ToString() },
                                { "start", startDate.ToString("yyyy-MM-dd HH:mm:ss") },
                                { "end", endDate.ToString("yyyy-MM-dd HH:mm:ss") },
                                { "createUserId", createUserId.ToString() },
                                { "isMonthData", "true" }
                            };

                            // 构建完整URL
                            var queryString = string.Join("&", queryParams.Select(kvp => $"{kvp.Key}={Uri.EscapeDataString(kvp.Value)}"));
                            string fullUrl = $"{apiUrl}?{queryString}";

                            _logger.LogInformation($"正在为用户 {user.CnName}(ID:{user.Id}, 部门:{user.DepName}) 生成绩效数据...");

                            // 发送HTTP GET请求
                            var response = await _httpClient.GetAsync(fullUrl);
                            var responseContent = await response.Content.ReadAsStringAsync();

                            if (response.IsSuccessStatusCode)
                            {
                                try
                                {
                                    var resultJson = JsonConvert.DeserializeObject<JsonView>(responseContent);
                                    if (resultJson != null && resultJson.Code == 200)
                                    {
                                        _logger.LogInformation($"用户 {user.CnName}(ID:{user.Id}, 部门:{user.DepName}) 绩效数据生成成功");
                                        //生成PDF
                                        var url = $"{baseUrl}/api/PersonnelModule/AiPerformanceAnalysis_JobMarketingFileDown";
                                        var queryParamsPdf = new Dictionary<string, string>
                                        {
                                            { "userId", user.Id.ToString() },
                                            { "start", startDate.ToString("yyyy-MM-dd") },
                                            { "end", endDate.ToString("yyyy-MM-dd") },
                                        };

                                        var queryStringPdf = string.Join("&", queryParamsPdf.Select(kvp => $"{kvp.Key}={Uri.EscapeDataString(kvp.Value)}"));
                                        url = $"{url}?{queryStringPdf}";

                                        _logger.LogInformation($"用户 {user.CnName}(ID:{user.Id}, 部门:{user.DepName}) 开始生成PDF：{url}");

                                        var pdfUrl = await _httpClient.PostAsync(url, new StringContent(queryStringPdf));

                                        if (pdfUrl.IsSuccessStatusCode)
                                        {
                                            var pdfContent = await pdfUrl.Content.ReadAsStringAsync();
                                            var pdfContentJson = JObject.Parse(pdfContent);
                                            var pdfUrlString = pdfContentJson["data"]["url"].ToString();
                                            var pdfUrlSeed = new Uri(pdfUrlString);
                                            var pdfBytes = await _httpClient.GetByteArrayAsync(pdfUrlSeed);

                                            // 提取文件名并重命名以包含员工姓名，方便管理者识别
                                            var originalFileName = pdfUrlString.Split('/').Last();
                                            var fileName = $"{originalFileName}";

                                            var pdfFile = new FormFile(new MemoryStream(pdfBytes), 0, pdfBytes.Length, fileName, fileName);

                                            _logger.LogInformation($"用户 {user.CnName}(ID:{user.Id}) PDF生成成功，大小：{pdfFile.Length}，已加入待发送列表");

                                            // 将附件添加到列表
                                            attachments.Add(pdfFile);
                                        }
                                        else
                                        {
                                            _logger.LogWarning($"用户 {user.CnName}(ID:{user.Id}) 生成PDF失败：{pdfUrl.StatusCode}");
                                        }
                                    }
                                    else
                                    {
                                        _logger.LogWarning($"用户 {user.CnName}(ID:{user.Id}) 绩效数据生成失败：{resultJson?.Msg ?? "未知错误"}");
                                    }
                                }
                                catch (Exception ex)
                                {
                                    _logger.LogError(ex, $"处理用户 {user.CnName}(ID:{user.Id}) 时发生异常");
                                }
                            }
                            else
                            {
                                _logger.LogError($"用户 {user.CnName}(ID:{user.Id}) 绩效数据生成API调用失败，状态码: {response.StatusCode}");
                            }

                            // 添加延迟，避免请求过于频繁
                            await Task.Delay(3000);
                        }

                        // 如果该管理者有附件，则一次性发送一封汇总邮件
                        if (attachments.Any())
                        {
                            _logger.LogInformation($"正在为管理者 {keyUser.CnName} 发送汇总邮件，附件数量：{attachments.Count}");

                            var resultEmail = await _qiYeWeChatApiService.EmailSendAsync(new EmailRequestDto
                            {
                                ToEmails = new List<string> { keyUser.Email },
                                Subject = $"员工绩效数据汇总({startDate:yyyy-MM-dd} 至 {endDate:yyyy-MM-dd})",
                                Body = $"您好，附件中包含您负责的 {attachments.Count} 位员工的周绩效报告，请查收。",
                                Files = attachments.ToArray()
                            });

                            _logger.LogInformation($"管理者 {keyUser.CnName} 汇总邮件发送结果：{resultEmail.errcode}, {resultEmail.errmsg}");
                        }
                        else
                        {
                            _logger.LogWarning($"管理者 {keyUser.CnName} 没有生成的绩效附件，跳过发送邮件。");
                        }
                    }
                }

            }
            catch (Exception ex)
            {
                _logger.LogError(ex, $"任务 {jobName} 执行失败");
            }
        }
    }
}