qlhb/Ropin.Inspection.Api/Controllers/MTN/TmtnAlarmOrderController.cs

using Microsoft.AspNetCore.Mvc;
using Microsoft.Extensions.Logging;
using Ropin.Inspection.Api.Common;
using Ropin.Inspection.Model;
using Ropin.Inspection.Service.DEV.Interface;
using Ropin.Inspection.Service.MTN.Interface;
using System.Collections.Generic;
using System.Threading.Tasks;
using System;
using Ropin.Inspection.Model.ViewModel.MTN;
using Ropin.Inspection.Model.SearchModel.MTN;
using Ropin.Inspection.Service;
using Microsoft.AspNetCore.Authorization;
using NPOI.SS.UserModel;
using NPOI.Util;
using NPOI.XSSF.UserModel;
using NPOI.XWPF.UserModel;
using Ropin.Inspection.Model.Common;
using System.IO.Compression;
using System.IO;
using System.Linq;
using log4net;
using NPOI.SS.Formula.Functions;
using Newtonsoft.Json;
using ICSharpCode.SharpZipLib.Zip;
using Ropin.Inspection.Common.Helper;
using NPOI.SS.Formula;
using Ropin.Inspection.Repository;
using Ropin.Inspection.Common;
using ICSharpCode.SharpZipLib.Core;

namespace Ropin.Inspection.Api.Controllers.MTN
{
    public class TmtnAlarmOrderController : BaseController
    {
        public ILogger<TmtnAlarmOrderController> _logger { get; }
        private readonly ITmtnAlarmOrderService _repository;
        private readonly IPushMsgService _pushMsgService;
        private readonly ITmtnPushMsgResultService _tmtnPushMsgResultService;
        private readonly ITsysMessageService _tsysMessageService;

        private static readonly ILog log = LogManager.GetLogger(typeof(TmtnAlarmOrderController));
        /// <summary>
        /// 构造函数
        /// </summary>
        /// <param name="logger"></param>
        /// <param name="repository"></param>
        /// <param name="pushMsgService"></param>
        /// <param name="tmtnPushMsgResultService"></param>
        public TmtnAlarmOrderController(ILogger<TmtnAlarmOrderController> logger, ITmtnAlarmOrderService repository, IPushMsgService pushMsgService, ITmtnPushMsgResultService tmtnPushMsgResultService, ITsysMessageService tsysMessageService)
        {
            _logger = logger;
            _repository = repository;
            _pushMsgService = pushMsgService;
            _tmtnPushMsgResultService = tmtnPushMsgResultService;
            _tsysMessageService = tsysMessageService;
        }
        /// <summary>
        /// 创建报警工单
        /// </summary>
        /// <param name="content"></param>
        /// <returns></returns>
        [HttpPost("CreateAsync")]
        public async Task<ApiResult> CreateAsync(AlarmOrderViewModel content)
        {
            if (content == null)
            {
                return new ApiResult(ReturnCode.ArgsError);
            }
            try
            {
                await _repository.CreateOneAsync(content);
            }
            catch (Exception ex)
            {
                return new ApiResult(ReturnCode.GeneralError, ex.Message);
            }
            return new ApiResult(ReturnCode.Success);
        }

        /// <summary>
        /// 创建报警工单+处理记录
        /// </summary>
        /// <param name="content"></param>
        /// <returns></returns>
        [HttpPost("CreateAlarmOrderAsync")]
        public async Task<ApiResult> CreateAlarmOrderAsync(AddAlarmOrderViewModel content)
        {
            if (content == null|| content.C_MessageCode == null)
            {
                return new ApiResult(ReturnCode.ArgsError);
            }
            try
            {
                await _repository.CreateOrderAsync(content);
                log.Info($"创建报警工单+处理记录-保存数据成功【数据=[{JsonConvert.SerializeObject(content)}]】");
                //Guid guid = Guid.Parse(content.C_PushMsgResultCode);
                var PushMsg=await _tsysMessageService.GetByIdAsync(content.C_MessageCode);
                log.Info($"创建报警工单+处理记录-根据MessageCode获取 TSYS_Message 数据=[{JsonConvert.SerializeObject(PushMsg)}]");
                if (PushMsg!=null&&!string.IsNullOrEmpty(PushMsg.C_DevStoreCode))
                {
                    await _pushMsgService.PushAlarmMsgAsync(new TpushMsgModel
                    {
                        C_DevStoreCode = PushMsg.C_DevStoreCode,
                        C_MsgTypeCode = "MSG_TYPE_019",
                        Msg = content.C_Record,//content.C_Name + "  " + content.C_Remark,
                        Subject = content.C_Name,//"上报报警，" + content.C_Name,
                        DevNumber = PushMsg.C_DevStoreCode,
                        DevName = "",
                        GenerationType = 2,
                        msgStatus = 0,
                    },"设备报警工单");
                }
                log.Info($"创建报警工单+处理记录-保存数据END");
            }
            catch (Exception ex)
            {
                log.Info($"创建报警工单+处理记录-保存数据成功异常【{ex.Message}】");
                return new ApiResult(ReturnCode.GeneralError, ex.Message);
            }
            return new ApiResult(ReturnCode.Success);
        }
        /// <summary>
        /// 删除报警工单
        /// </summary>
        /// <param name="id"></param>
        /// <returns></returns>
        [HttpDelete("DeleteAsync/{id}")]
        public async Task<ApiResult> DeleteAsync(string id)
        {
            if (string.IsNullOrEmpty(id))
            {
                return new ApiResult(ReturnCode.GeneralError);
            }
            try
            {
                await _repository.DeleteAsync(id);
            }
            catch (Exception ex)
            {
                return new ApiResult(ReturnCode.GeneralError, ex.Message);
            }
            return new ApiResult(ReturnCode.Success);
        }
        /// <summary>
        /// 更新报警工单
        /// </summary>
        /// <param name="id"></param>
        /// <param name="updateModel"></param>
        /// <returns></returns>
        [HttpPut("UpdateAsync/{id}")]
        public async Task<ApiResult> UpdateAsync(string id, AlarmOrderViewModel updateModel)
        {
            if (string.IsNullOrEmpty(id))
            {
                return new ApiResult(ReturnCode.GeneralError);
            }
            try
            {
                await _repository.UpdateAsync(id, updateModel);
                log.Info($"更新报警工单-保存数据成功【id={id}；数据=[{JsonConvert.SerializeObject(updateModel)}]】");
                var content = await _repository.GetByIdAsync(id);
                if (updateModel.C_Status=="5"&& content!=null&&!string.IsNullOrEmpty(content.C_DevStoreCode)) {
                    await _pushMsgService.PushAlarmMsgAsync(new TpushMsgModel
                    {
                        C_DevStoreCode = content.C_DevStoreCode,
                        C_MsgTypeCode = "MSG_TYPE_020",
                        Msg = updateModel.C_Remark,//content.C_Name + "  " + updateModel.C_Remark,
                        Subject = content.C_Name,//"报警取消，" + content.C_Name,
                        DevNumber = content.C_DevStoreCode,
                        DevName = content.C_DevName,
                        GenerationType = 2,
                        msgStatus = 0,
                    },"设备报警工单");
                }
                log.Info($"更新报警工单-保存数据END");
            }
            catch (Exception ex)
            {
                log.Info($"更新报警工单-保存数据成功异常【{ex.Message}】");
                return new ApiResult(ReturnCode.GeneralError, ex.Message);
            }
            return new ApiResult(ReturnCode.Success);
        }
        /// <summary>
        /// 报警工单-流程
        /// </summary>
        /// <param name="id"></param>
        /// <param name="updateModel"></param>
        /// <returns></returns>
        [HttpPut("OrderFlowAsync/{id}")]
        public async Task<ApiResult> OrderFlowAsync(string id, UpdateAlarmOrderViewModel updateModel)
        {
            if (string.IsNullOrEmpty(id))
            {
                return new ApiResult(ReturnCode.GeneralError);
            }
            try
            {
                await _repository.OrderFlowAsync(id, updateModel);
                log.Info($"报警工单-流程-保存数据成功【id={id}；数据=[{JsonConvert.SerializeObject(updateModel)}]】");
                // 0 = 禁用（删除）;1 = 上报报警（报警上报）;5 = 报警取消;2 = 报警确认;
                // 3 = 正在处理报警;4 = 处理报警完成;6 = 报警处理维保返工; 7 = 报警处理完成确认
                if (updateModel.C_Status=="2"|| updateModel.C_Status=="4" || updateModel.C_Status == "7")
                {
                    var content = await _repository.GetByIdAsync(id);
                    if (content != null && !string.IsNullOrEmpty(content.C_DevStoreCode))
                    {
                        string title = ""; string code = "";
                        switch (updateModel.C_Status)
                        {
                            case "2": title = "报警确认，"; code = "MSG_TYPE_021"; break;
                            case "7": title = "报警完成确认，"; code = "MSG_TYPE_021"; break;
                            case "4": title = "报警完成，"; code = "MSG_TYPE_022"; break;
                            case "5": title = "报警取消，"; code = "MSG_TYPE_020"; break;
                        }
                        await _pushMsgService.PushAlarmMsgAsync(new TpushMsgModel
                        {
                            C_DevStoreCode = content.C_DevStoreCode,
                            C_MsgTypeCode = code,
                            Msg = updateModel.C_Record,//content.C_Name + "  " + updateModel.C_Remark,
                            Subject = content.C_Name,// title + content.C_Name,
                            DevNumber = content.C_DevStoreCode,
                            DevName = content.C_DevName,
                            GenerationType = 2,
                            msgStatus = 0,
                        }, "设备报警工单");
                    }                    
                }
                log.Info($"报警工单-流程-保存数据END");
            }
            catch (Exception ex)
            {
                log.Info($"报警工单-流程-保存数据成功异常【{ex.Message}】");
                return new ApiResult(ReturnCode.GeneralError, ex.Message);
            }
            return new ApiResult(ReturnCode.Success);
        }
        /// <summary>
        /// 通过id获取报警工单信息
        /// </summary>
        /// <param name="id"></param>
        /// <returns></returns>
        [HttpGet("GetAlarmOrderAsync/{id}")]
        public async Task<ApiResult> GetAlarmOrderAsync(string id)
        {
            if (string.IsNullOrEmpty(id))
            {
                return new ApiResult(ReturnCode.GeneralError);
            }
            try
            {
                var content = await _repository.GetByIdAsync(id);
                return new ApiResult<AlarmOrderViewModel>(content);
            }
            catch (Exception ex)
            {
                return new ApiResult(ReturnCode.GeneralError, ex.Message);
            }
        }
        /// <summary>
        /// 通过消息编号获取报警工单信息
        /// </summary>
        /// <param name="messageCode"></param>
        /// <returns></returns>
        [HttpGet("GetAlarmOrderByMessageCodeAsync/{messageCode}")]
        public async Task<ApiResult> GetAlarmOrderByMessageCodeAsync(string messageCode)
        {
            if (string.IsNullOrEmpty(messageCode))
            {
                return new ApiResult(ReturnCode.GeneralError);
            }
            try
            {
                var content = await _repository.GetByMessageCodeAsync(messageCode);
                return new ApiResult<AlarmOrderViewModel>(content);
            }
            catch (Exception ex)
            {
                return new ApiResult(ReturnCode.GeneralError, ex.Message);
            }
        }
        /// <summary>
        /// 报警工单列表
        /// </summary>
        /// <param name="searchModel"></param>
        /// <returns></returns>
        [HttpPost("GetAlarmOrderListAsync")]
        public async Task<ApiResult> GetAlarmOrderListAsync(AlarmOrderSearchModel searchModel)
        {
            if (searchModel == null)
            {
                return new ApiResult(ReturnCode.ArgsError);
            }
            try
            {
                var contentList = await _repository.GetAlarmOrderList(searchModel);
                return new ApiResult<PagesModel<AlarmOrderViewModel>>(new PagesModel<AlarmOrderViewModel>(contentList, searchModel));
            }
            catch (Exception ex)
            {
                return new ApiResult(ReturnCode.GeneralError, ex.Message);
            }
        }
        /// <summary>
        /// 报警工单处理记录列表
        /// </summary>
        /// <param name="searchModel"></param>
        /// <returns></returns>
        [HttpPost("GetAlarmOrderRecordList")]
        public async Task<ApiResult> GetAlarmOrderRecordList(AlarmOrderSearchModel searchModel)
        {
            if (searchModel==null)
            {
                return new ApiResult(ReturnCode.ArgsError);
            }
            try
            {
                searchModel.IsPagination = false;
                var contentList = await _repository.GetAlarmOrderRecordList(searchModel);
                return new ApiResult<IEnumerable<AlarmOrderRecordViewModel>>(contentList);
            }
            catch (Exception ex)
            {
                return new ApiResult(ReturnCode.GeneralError, ex.Message);
            }
        }
        /// <summary>
        /// 报警工单统计
        /// </summary>
        /// <param name="searchModel"></param>
        /// <returns></returns>
        [HttpPost("AlarmOrderStatistics")]
        public async Task<ApiResult> AlarmOrderStatistics(AlarmOrderSearchModel searchModel)
        {
            if (searchModel == null&& searchModel.C_StoreCode!=null)
            {
                return new ApiResult(ReturnCode.ArgsError);
            }
            try
            {
                searchModel.IsPagination = false;
                var contentList = await _repository.AlarmOrderStatistics(searchModel);
                return new ApiResult<AlarmOrderStatistics>(contentList);
            }
            catch (Exception ex)
            {
                return new ApiResult(ReturnCode.GeneralError, ex.Message);
            }
        }

        /// <summary>
        /// 工单表移动端统计（6个月）
        /// </summary>
        /// <param name="storeCode"></param>
        /// <returns></returns>
        [HttpGet("GetAlarmOrderStatisticsAsync/{storeCode}")]
        public async Task<ApiResult> GetAlarmOrderStatisticsAsync(string storeCode)
        {
            if (string.IsNullOrEmpty(storeCode))
            {
                return new ApiResult(ReturnCode.GeneralError);
            }
            try
            {
                var content = await _repository.GetAlarmOrderStatisticsAsync(storeCode);

                return new ApiResult<RepairStatistics>(content);
            }
            catch (Exception ex)
            {
                return new ApiResult(ReturnCode.GeneralError, ex.Message);
            }
        }

        /// <summary>
        /// 导出报警记录压缩包
        /// </summary>
        /// <param name="searchModel"></param>
        /// <returns></returns>
        [HttpPost("ExportZip")]
        [AllowAnonymous]
        public async Task<IActionResult> ExportZip(AlarmOrderSearchModel searchModel)
        {
            var recordList = await _repository.GetAlarmOrderList(searchModel);
            string zip = @"wwwroot\\ZipFile";
            if (!System.IO.Directory.Exists(zip))
            {
                Directory.CreateDirectory(zip);
            }
            string zipPaht = zip + "\\报警记录下载.zip";
            System.IO.File.Delete(zipPaht);
            IWorkbook workbook = new XSSFWorkbook();
            ISheet sheet = workbook.CreateSheet();

            #region 
            //标题加粗居中.
            IFont font = workbook.CreateFont();
            font.IsBold = true;
            font.FontHeightInPoints = 25;
            font.FontName = "宋体";
            ICellStyle titleCellStyle = workbook.CreateCellStyle();
            titleCellStyle.SetFont(font);
            titleCellStyle.Alignment = HorizontalAlignment.Center;  //字体居中
            //边框
            titleCellStyle.BorderBottom = NPOI.SS.UserModel.BorderStyle.Thin;
            titleCellStyle.BorderLeft = NPOI.SS.UserModel.BorderStyle.Thin;
            titleCellStyle.BorderRight = NPOI.SS.UserModel.BorderStyle.Thin;
            titleCellStyle.BorderTop = NPOI.SS.UserModel.BorderStyle.Thin;
            titleCellStyle.WrapText = true;
            #endregion
            #region
            //表头加粗居中.
            IFont font1 = workbook.CreateFont();
            font1.IsBold = true;
            font1.FontHeightInPoints = 14;
            font1.FontName = "宋体";
            ICellStyle headCellStyle = workbook.CreateCellStyle();
            headCellStyle.SetFont(font1);
            headCellStyle.Alignment = HorizontalAlignment.Center;  //字体居中
            //边框
            headCellStyle.BorderBottom = NPOI.SS.UserModel.BorderStyle.Thin;
            headCellStyle.BorderLeft = NPOI.SS.UserModel.BorderStyle.Thin;
            headCellStyle.BorderRight = NPOI.SS.UserModel.BorderStyle.Thin;
            headCellStyle.BorderTop = NPOI.SS.UserModel.BorderStyle.Thin;
            headCellStyle.WrapText = true;
            #endregion
            #region
            //行.
            IFont font2 = workbook.CreateFont();
            font2.IsBold = false;
            font2.FontHeightInPoints = 12;
            font2.FontName = "宋体";
            ICellStyle rowCellStyle = workbook.CreateCellStyle();
            rowCellStyle.SetFont(font2);
            rowCellStyle.Alignment = HorizontalAlignment.Center;  //字体居中
            //边框
            rowCellStyle.BorderBottom = NPOI.SS.UserModel.BorderStyle.Thin;
            rowCellStyle.BorderLeft = NPOI.SS.UserModel.BorderStyle.Thin;
            rowCellStyle.BorderRight = NPOI.SS.UserModel.BorderStyle.Thin;
            rowCellStyle.BorderTop = NPOI.SS.UserModel.BorderStyle.Thin;
            rowCellStyle.WrapText = true;
            #endregion
            #region 超链接
            // 创建样式
            ICellStyle styleLInk = workbook.CreateCellStyle();
            // 设置字体颜色为蓝色
            IFont fontLink = workbook.CreateFont();
            fontLink.IsBold = false;
            fontLink.FontHeightInPoints = 12;
            fontLink.FontName = "宋体";
            fontLink.Color = IndexedColors.Green.Index;
            styleLInk.SetFont(fontLink);
            // 设置下划线
            fontLink.Underline = FontUnderlineType.Single;
            styleLInk.SetFont(fontLink);
            styleLInk.Alignment = HorizontalAlignment.Center;  //字体居中
            //边框
            styleLInk.BorderBottom = NPOI.SS.UserModel.BorderStyle.Thin;
            styleLInk.BorderLeft = NPOI.SS.UserModel.BorderStyle.Thin;
            styleLInk.BorderRight = NPOI.SS.UserModel.BorderStyle.Thin;
            styleLInk.BorderTop = NPOI.SS.UserModel.BorderStyle.Thin;
            styleLInk.WrapText = true;
            #endregion
            sheet.AddMergedRegion(new NPOI.SS.Util.CellRangeAddress(0, 0, 0, 7));
            IRow title = sheet.CreateRow(0);
            title.Height = 30 * 25;
            title.CreateCell(0).SetCellValue("报警记录报表" + (searchModel.C_StoreName == null ? "" : "(" + searchModel.C_StoreName + ")"));
            foreach (var item in title.Cells)
            {
                item.CellStyle = titleCellStyle;
            }
            IRow head = sheet.CreateRow(1);
            head.CreateCell(0).SetCellValue("序号");
            head.CreateCell(1).SetCellValue("报警名称");
            head.CreateCell(2).SetCellValue("状态");
            head.CreateCell(3).SetCellValue("审批人");
            head.CreateCell(4).SetCellValue("审批时间");
            head.CreateCell(5).SetCellValue("上报人员");
            head.CreateCell(6).SetCellValue("上报时间");
            head.CreateCell(7).SetCellValue("记录查看");
            foreach (var item in head.Cells)
            {
                item.CellStyle = headCellStyle;
            }
            int rowNumber = 2; int number = 1;
            if (recordList.Any() && recordList.FirstOrDefault() != null)
            {
                foreach (var x in recordList)
                {
                    if (x!=null)
                    {
                        string status = string.Empty;
                        switch (x.C_Status)
                        {
                            case "1": status = "报警上报"; break;
                            case "2": status = "报警确认"; break;
                            case "3": status = "正在处理"; break;
                            case "4": status = "报警完成"; break;
                            case "5": status = "报警取消"; break;
                            case "6": status = "报警返工"; break;
                            case "7": status = "报警完成确认"; break;
                        }
                        IRow content = sheet.CreateRow(rowNumber);
                        content.CreateCell(0).SetCellValue(number);
                        content.CreateCell(1).SetCellValue(x.C_Name);
                        content.CreateCell(2).SetCellValue(status);
                        content.CreateCell(3).SetCellValue(x.C_ExamineName);
                        content.CreateCell(4).SetCellValue(x.D_ExamineOn?.ToString("yyyy-MM-dd"));
                        content.CreateCell(5).SetCellValue(x.C_CreateName);
                        content.CreateCell(6).SetCellValue(x.D_CreateOn.ToString("yyyy-MM-dd"));
                        //超链接
                        NPOI.SS.UserModel.ICell cell = content.CreateCell(7);
                        cell.SetCellValue("附件");
                        IHyperlink link = new XSSFHyperlink(HyperlinkType.Url);
                        link.Address = ("报警记录/" + x.C_ID + ".docx");
                        cell.Hyperlink = link;
                        foreach (var item in content.Cells)
                        {
                            item.CellStyle = rowCellStyle;
                        }
                        cell.CellStyle = styleLInk;
                        rowNumber++; number++;
                    }
                }
            }
            else
            {
                IRow content1 = sheet.CreateRow(rowNumber);
                content1.CreateCell(0).SetCellValue("暂无数据");
                sheet.AddMergedRegion(new NPOI.SS.Util.CellRangeAddress(2, 2, 0, 7));
            }
            for (int i = 0; i <= 7; i++)
            {
                if (i == 0)
                {
                    sheet.SetColumnWidth(i, 2000);
                }
                else if (i == 1)
                {
                    sheet.SetColumnWidth(i, 7000);
                }
                else
                {
                    sheet.SetColumnWidth(i, 4500);
                }
            }

            using (var zipFile = new FileStream(zipPaht, FileMode.Create))
            {
                // 列表Excel  
                using (var memoryStream = new NpoiMemoryStream())
                {
                    workbook.Write(memoryStream);
                    byte[] excelData = memoryStream.ToArray();

                    using (var archive = new ZipArchive(zipFile, ZipArchiveMode.Update))
                    {
                        archive.CreateEntry("报警记录报表.xlsx").Open().Write(excelData, 0, excelData.Length);
                    }
                }
            }

            //内容word
            foreach (var cell in recordList.ToList())
            {
                if (cell != null)
                {
                    AlarmOrderSearchModel orderSearch = new AlarmOrderSearchModel();
                    orderSearch.IsPagination = false;
                    orderSearch.C_ID = cell.C_ID;
                    var recordItems = await _repository.GetAlarmOrderRecordList(orderSearch);
                    if (recordItems.Count() > 0)
                    {
                        XWPFDocument doc = new XWPFDocument();
                        var paragraph = doc.CreateParagraph();
                        var run1 = paragraph.CreateRun();
                        run1.FontSize = 18;
                        run1.SetText("报警名称：" + cell.C_Name);
                        int serialNum = 1;
                        foreach (var recordItem in recordItems)
                        {
                            if (recordItem==null) { continue; }
                            var p0 = doc.CreateParagraph();
                            var run0 = p0.CreateRun();
                            run0.FontSize = 16;
                            run0.SetText(" " + serialNum.ToString());
                            var p1 = doc.CreateParagraph();
                            var run = p1.CreateRun();
                            run.FontSize = 14;
                            string status = string.Empty;
                            switch (recordItem.C_Status)
                            {
                                case "1": status = "报警上报";  break;
                                case "2": status = "报警确认"; break;
                                case "3": status = "正在处理"; break;
                                case "4": status = "报警完成";  break;
                                case "5": status = "报警取消"; break;
                                case "6": status = "报警返工";  break;
                                case "7": status = "报警完成确认"; break;
                            }
                            run.AppendText("    操作时间：" + recordItem.D_CreateOn.ToString("yyyy-MM-dd HH:mm:ss"));
                            run.AddCarriageReturn();
                            run.AppendText("    状态：" + status);
                            run.AddCarriageReturn();
                            run.AppendText("    处理人员：" + recordItem.C_CreateName);
                            run.AddCarriageReturn();
                            run.AppendText("    现场描述：" + recordItem.C_Remark);
                            run.AddCarriageReturn();
                            run.AppendText("    现场记录：" + recordItem.C_Record);
                            if (recordItem.fileList != null && recordItem.fileList.Count() > 0)
                            {
                                run.AddCarriageReturn();
                                run.AppendText("    现场拍照：");
                                foreach (var path in recordItem.fileList)
                                {
                                    string pathFile = path.C_Url;  
                                    if (!string.IsNullOrEmpty(pathFile))
                                    {
                                        if (pathFile[0].ToString() == @"/")
                                        {
                                            pathFile = pathFile.Substring(1);
                                        }
                                        if (!System.IO.File.Exists(pathFile))
                                        {
                                            pathFile = @"wwwroot/error.png";
                                        }
                                        FileStream fileStream = new FileStream(pathFile, FileMode.Open, FileAccess.Read);
                                        run.AddCarriageReturn();
                                        run.AddPicture(fileStream, 6, pathFile, Units.ToEMU(100), Units.ToEMU(100));
                                    }
                                }
                            }
                            serialNum++;
                        }
                        using (var zipFile = new FileStream(zipPaht, FileMode.OpenOrCreate))
                        {
                            using (var memoryStream = new NpoiMemoryStream())
                            {
                                doc.Write(memoryStream);
                                byte[] excelData = memoryStream.ToArray();

                                using (var archive = new ZipArchive(zipFile, ZipArchiveMode.Update))
                                {
                                    archive.CreateEntry("报警记录/" + cell.C_ID + ".docx").Open().Write(excelData, 0, excelData.Length);
                                }
                            }
                        }
                    }
                }

            }

            var zipFile1 = new FileStream(zipPaht, FileMode.Open);
            // 将压缩后的数据作为响应返回给客户端（这里假设你使用的是HTTP GET请求）  
            return File(zipFile1, "application/zip", "报警记录报表.zip"); // 这里假设你的文件类型是.xlsx的GZip压缩文件。你可以根据需要调整MIME类型和文件扩展名。
        }

        /// <summary>
        /// 发送邮件-根据消息ID获取报警详情
        /// </summary>
        /// <param name="searchModel"></param>
        /// <returns></returns>
        [HttpPost("SendEmilByPushMsgResultCode")]
        [AllowAnonymous]
        public async Task<ApiResult> SendEmilByPushMsgResultCode(SendAlarmOrderModel searchModel)
        {
            try
            {
                if (searchModel==null&&string.IsNullOrEmpty(searchModel.C_MessageCode))
                {
                    return new ApiResult(ReturnCode.ArgsError, "请输入参数");
                }
                AlarmOrderSearchModel orderSearchModel = new AlarmOrderSearchModel();
                orderSearchModel.IsPagination = false;
                orderSearchModel.C_MessageCode = searchModel.C_MessageCode;
                ////var recordItems = await _repository.GetAlarmOrderRecordList(orderSearchModel);
                var MsgData = await _repository.GetByMessageCodeAsync(searchModel.C_MessageCode);
                string zip = @"wwwroot\\ZipFile";
                if (!System.IO.Directory.Exists(zip))
                {
                    Directory.CreateDirectory(zip);
                }
                string zipPaht = zip + $"\\{searchModel.C_MessageCode}报警详情下载.zip";
                List<string> FileDel =new List<string>();
                if (MsgData!=null)
                {
                    var msgEntity = JsonConvert.DeserializeObject<TpushMsgModel>(MsgData.C_Content);
                    string msgTypeName= DataDictionaryHelper.GetValNameByCode(msgEntity.C_MsgTypeCode);
                    XWPFDocument doc = new XWPFDocument();
                    var paragraph = doc.CreateParagraph();
                    var run1 = paragraph.CreateRun();
                    run1.FontSize = 18;
                    run1.AppendText("报警主题：" + msgEntity.Subject);
                    run1.AddCarriageReturn();
                    run1.AppendText("报警设备：" + msgEntity.DevName);
                    run1.AddCarriageReturn();
                    run1.AppendText("报警来源：" + msgEntity.UserName);
                    run1.AddCarriageReturn();
                    run1.AppendText("报警时间：" + msgEntity.CreateOn);
                    run1.AddCarriageReturn();
                    run1.AppendText("报警内容：" + msgEntity.Msg);
                    run1.AddCarriageReturn();
                    run1.AppendText("报警类型：" + msgTypeName);
                    #region 消息图片信息
                    if (MsgData.messageFile != null&& MsgData.messageFile.Count>0)
                    {
                        foreach (var files in MsgData.messageFile)
                        {
                            if (files != null)
                            {
                                if (files.C_Type== "FILE_TYP_006")
                                {
                                    try
                                    {
                                        var fileText = JsonConvert.DeserializeObject<AlmImage>(files.C_Text);
                                        string images = AIConst.AIImageUrl+fileText.PanoramaUrl;
                                        var imgArray= fileText.PanoramaUrl.Split('/');
                                        string AiAlmFile = @"wwwroot\\AiAlm";// + fileText.PanoramaUrl;
                                        string imgName = "";int fI = 0;
                                        foreach (var img in imgArray)
                                        {
                                            if (fI>0)
                                            {
                                                if (!img.Contains("."))
                                                {
                                                    AiAlmFile = AiAlmFile + "/" + img;
                                                }
                                                else
                                                {
                                                    imgName = img;
                                                }
                                            }
                                            fI++;
                                        }
                                        if (!System.IO.Directory.Exists(AiAlmFile))
                                        {
                                            Directory.CreateDirectory(AiAlmFile);
                                        }
                                        string pathFile = AiAlmFile + "/" + imgName;
                                        bool IsDown = true;
                                        if (!System.IO.File.Exists(pathFile))
                                        {
                                            IsDown = FileHelp.FilesDown(images, pathFile);
                                        }
                                        if (IsDown)
                                        {
                                            if (!string.IsNullOrEmpty(pathFile))
                                            {
                                                if (pathFile[0].ToString() == @"/")
                                                {
                                                    pathFile = pathFile.Substring(1);
                                                }
                                                if (System.IO.File.Exists(pathFile))
                                                {
                                                    FileStream fileStream = new FileStream(pathFile, FileMode.Open, FileAccess.Read);
                                                    run1.AddCarriageReturn();
                                                    run1.AddPicture(fileStream, 6, pathFile, Units.ToEMU(400), Units.ToEMU(300));
                                                    FileDel.Add(pathFile);
                                                }
                                            }
                                        }
                                    }
                                    catch (Exception)
                                    {
                                    }
                                }
                                else if (files.C_Type == "FILE_TYP_003")
                                {
                                    string pathFile = files.C_Url;
                                    if (!string.IsNullOrEmpty(pathFile))
                                    {
                                        if (pathFile[0].ToString() == @"/")
                                        {
                                            pathFile = pathFile.Substring(1);
                                        }
                                        if (!System.IO.File.Exists(pathFile))
                                        {
                                            pathFile = @"wwwroot/error.png";
                                        }
                                        FileStream fileStream = new FileStream(pathFile, FileMode.Open, FileAccess.Read);
                                        run1.AddCarriageReturn();
                                        run1.AddPicture(fileStream, 6, pathFile, Units.ToEMU(100), Units.ToEMU(100));
                                    }
                                }
                                else
                                {

                                }
                            }
                        }
                    }
                    #endregion
                    int serialNum = 1;
                    foreach (var recordItem in MsgData.historyRecord)
                    {
                        if (recordItem == null) { continue; }
                        var p0 = doc.CreateParagraph();
                        var run0 = p0.CreateRun();
                        run0.FontSize = 16;
                        run0.SetText(" " + serialNum.ToString());
                        var p1 = doc.CreateParagraph();
                        var run = p1.CreateRun();
                        run.FontSize = 14;
                        string status = string.Empty;
                        switch (recordItem.C_Status)
                        {
                            case "1": status = "报警上报"; break;
                            case "2": status = "报警确认"; break;
                            case "3": status = "正在处理"; break;
                            case "4": status = "报警完成"; break;
                            case "5": status = "报警取消"; break;
                            case "6": status = "报警返工"; break;
                            case "7": status = "报警完成确认"; break;
                        }
                        run.AppendText("    操作时间：" + recordItem.D_CreateOn.ToString("yyyy-MM-dd HH:mm:ss"));
                        run.AddCarriageReturn();
                        run.AppendText("    状态：" + status);
                        run.AddCarriageReturn();
                        run.AppendText("    处理人员：" + recordItem.C_CreateName);
                        run.AddCarriageReturn();
                        run.AppendText("    现场描述：" + recordItem.C_Remark);
                        run.AddCarriageReturn();
                        run.AppendText("    现场记录：" + recordItem.C_Record);
                        if (recordItem.fileList != null && recordItem.fileList.Count() > 0)
                        {
                            run.AddCarriageReturn();
                            run.AppendText("    现场拍照：");
                            foreach (var path in recordItem.fileList)
                            {
                                string pathFile = path.C_Url;
                                if (!string.IsNullOrEmpty(pathFile))
                                {
                                    if (pathFile[0].ToString() == @"/")
                                    {
                                        pathFile = pathFile.Substring(1);
                                    }
                                    if (!System.IO.File.Exists(pathFile))
                                    {
                                        pathFile = @"wwwroot/error.png";
                                    }
                                    FileStream fileStream = new FileStream(pathFile, FileMode.Open, FileAccess.Read);
                                    run.AddCarriageReturn();
                                    run.AddPicture(fileStream, 6, pathFile, Units.ToEMU(100), Units.ToEMU(100));
                                }
                            }
                        }
                        serialNum++;
                    }
                    using (var zipFile = new FileStream(zipPaht, FileMode.Create))
                    {
                        using (var memoryStream = new NpoiMemoryStream())
                        {
                            doc.Write(memoryStream);
                            byte[] excelData = memoryStream.ToArray();

                            using (var archive = new ZipArchive(zipFile, ZipArchiveMode.Update))
                            {
                                archive.CreateEntry($"{searchModel.C_MessageCode}报警详情.docx").Open().Write(excelData, 0, excelData.Length);
                            }
                        }
                    }
                }
                string emailName = $"{searchModel.AlarmContent}-报警详情";
                using (var zipFile1 = new FileStream(zipPaht, FileMode.Open))
                {
                    await Task.Run(() =>
                    {
                        EmailHelper.SendEmail(searchModel.Mails, emailName, "", "详情见附件", $"{emailName}.zip", "application/zip", zipFile1);
                    });
                }
                System.IO.File.Delete(zipPaht);
                //foreach (var item in FileDel)
                //{
                //    if (System.IO.File.Exists(item))
                //    {
                //        System.IO.File.Delete(item);
                //    };
                //}
                return new ApiResult(ReturnCode.Success);
            }
            catch (Exception ex)
            {
                return new ApiResult(ReturnCode.GeneralError, ex.Message);
            }
        }
    }
}