using FrontendWebApi.Models;
using Microsoft.AspNetCore.Mvc;
using Microsoft.Extensions.Logging;
using Newtonsoft.Json;
using NPOI.SS.UserModel;
using NPOI.XSSF.UserModel;
using Repository.FrontendRepository.Interface;
using System;
using System.Collections.Generic;
using System.IO;
using System.Linq;
using System.Text;
using System.Threading.Tasks;

namespace FrontendWebApi.ApiControllers
{
    /// <summary>
    /// 告警紀錄
    /// </summary>
    public class AlarmRecordController : MyBaseApiController<AlarmRecordController>
    {
        private readonly IFrontendRepository frontendRepository;
        
        public AlarmRecordController
        (
            IFrontendRepository frontendRepository
        )
        {
            this.frontendRepository = frontendRepository;
        }

        /// <summary>
        /// 告警紀錄過濾條件面板
        /// </summary>
        /// <param name="post"></param>
        /// <returns></returns>
        [HttpPost]
        [Route("api/AlarmRecord/GetAlarmRecordFilterPanel")]
        public async Task<ActionResult<ApiResult<List<AlarmRecordPanel>>>> GetAlarmRecordFilterPanel(string account)
        {
            ApiResult<List<AlarmRecordPanel>> apiResult = new ApiResult<List<AlarmRecordPanel>>(jwt_str);
            if (!jwtlife)
            {
                apiResult.Code = "5000";
                return BadRequest(apiResult);
            }
            try
            {
                var sqlBuildingMain = $@"SELECT
                                            b.building_tag,
                                            b.full_name AS building_name,
                                            v1.system_value,
										    v1.system_key
                                        FROM 
                                        (SELECT * FROM building_menu ORDER BY priority) bm
                                        INNER JOIN (
                                            SELECT
                                               ap.building_tag, ap.ShowView
                                           FROM role_auth ra
                                           JOIN auth_page ap ON ra.AuthCode = ap.AuthCode
                                           JOIN userinfo u ON u.role_guid = ra.role_guid WHERE u.account = @Account
                                           AND ap.building_tag IS NOT NULL
                                        ) ap ON bm.building_tag = ap.building_tag 
                                        JOIN building b ON bm.building_tag = b.building_tag and b.deleted = 0
                                        join variable v2 on ap.ShowView = v2.id and v2.deleted = 0
                                        join variable v1 on v2.system_parent_id = v1.id
                                        GROUP BY b.building_tag, b.full_name, v1.system_value, v1.system_key
                                        order by b.priority, v1.system_priority, bm.priority, v2.system_priority, v2.created_at DESC";

                var alarmRecordPanelRawDatas = await frontendRepository.GetAllAsync<AlarmRecordPanelRawData>(sqlBuildingMain, new { Account = account });

                List<AlarmRecordPanel> alarmRecordPanels = new List<AlarmRecordPanel>();

                var alarmRecordPanelRawDatas_GroupBy = alarmRecordPanelRawDatas.GroupBy(x => x.building_tag);

                foreach (var building in alarmRecordPanelRawDatas_GroupBy)
                {
                    AlarmRecordPanel alarmRecordPanel = new AlarmRecordPanel();
                    alarmRecordPanel.building_tag = building.Key;
                    alarmRecordPanel.building_name = building.First().building_name;
                    alarmRecordPanel.mainSystemPanels = new List<MainSystemPanel>();
                    foreach (var tempData in building)
                    {
                        MainSystemPanel mainSystemPanel = new MainSystemPanel();
                        mainSystemPanel.system_value = tempData.system_value;
                        mainSystemPanel.system_key = tempData.system_key;

                        alarmRecordPanel.mainSystemPanels.Add(mainSystemPanel);
                    }

                    alarmRecordPanels.Add(alarmRecordPanel);
                }

                apiResult.Code = "0000";
                apiResult.Data = alarmRecordPanels;
            }
            catch (Exception exception)
            {
                apiResult.Code = "9999";
                apiResult.Msg = "系統內部錯誤，請聯絡管理者。";
                Logger.LogError("【" + controllerName + "/" + actionName + "】" + exception.Message);
                return Ok(apiResult);
            }
            return Ok(apiResult);
        }

        [HttpPost]
        [Route("api/AlarmRecord/GetAllAlarmRecord")]
        public async Task<ActionResult<ApiResult<List<AlarmRecordFullInfo>>>> GetAllAlarmRecord(AlarmRecordFilter post)
        {
            ApiResult<List<AlarmRecordFullInfo>> apiResult = new ApiResult<List<AlarmRecordFullInfo>>(jwt_str);
            if (!jwtlife)
            {
                apiResult.Code = "5000";
                return BadRequest(apiResult);
            }
            try
            {
                var sql = $@"SELECT 
		                            temp_path.source AS alarm_path,
		                            temp_msg.source_msg AS msgText,
		                            from_unixtime(record.timestamp/1000,'%Y-%m-%d %H:%i:%s') alarm_timestamp,
		                            record.priority,
		                            CASE WHEN record.normalTime > 0 THEN from_unixtime(record.normalTime/1000,'%Y-%m-%d %H:%i:%s')
		                            ELSE NULL
		                            END AS normal_timestamp,
		                            record.sourceState AS ackState,
		                            class.alarmclass AS alarm_className,
		                            record.userAccount

                            FROM alarmOrion_OrionAlarmRecord record 
                            JOIN (
		                            SELECT sourceorder.* ,temp_source.source
		                            FROM alarmOrion_OrionAlarmSourceOrder sourceorder
		                            JOIN alarmOrion_OrionAlarmSource temp_source ON sourceorder.alarmSource = temp_source.id
                            ) temp_path ON record.id = temp_path.alarm
                            JOIN(
			                            SELECT 
					                            val.alarm,
					                            val.value AS source_msg
			                            FROM alarmOrion_OrionAlarmFacetValue val 
			                            JOIN alarmOrion_OrionAlarmFacetName nam ON val.facetName = nam.id AND nam.facetName = 'msgText'
                            ) temp_msg ON record.id = temp_msg.alarm
                            JOIN alarmOrion_OrionAlarmClass class ON record.alarmClass = class.id
                            WHERE from_unixtime(record.timestamp/1000,'%Y-%m-%d %H:%i:%s') BETWEEN @StartTimestamp AND @EndTimeStamp";

                if (post.IsSolve != 0)
                {
                    if(post.IsSolve == 1)
                    {   //未解決
                        sql += " AND record.normalTime = 0";
                    }
                    else if(post.IsSolve == 2)
                    {   //已解決
                        sql += " AND record.normalTime > 0";
                    }
                }

                if (post.IsAck != 0)
                {
                    if (post.IsAck == 1)
                    {   //未確認
                        sql += " AND record.sourceState = 1";
                    }
                    else if (post.IsAck == 2)
                    {   //已確認
                        sql += " AND record.sourceState = 0";
                    }
                }

                var alarmRecords = await frontendRepository.GetAllAsync<AlarmRecord>(sql, post);

                foreach (var alarmRecord in alarmRecords)
                {
                    var alarmSplit = alarmRecord.alarm_path.Split("|");
                    var deviceSplit = alarmSplit[alarmSplit.Length - 1].Split("/");
                    var device_number = deviceSplit[deviceSplit.Length - 3];
                    var point = deviceSplit[deviceSplit.Length - 2];

                    alarmRecord.device_number = device_number.Replace("$3", "");
                    alarmRecord.device_point = point.Replace("$3", "");
                }

                //找出設備資訊
                var sql_device = $@"SELECT * 
                                    FROM device d 
                                    WHERE d.deleted = 0 
                                        AND d.device_building_tag = @building_tag
                                        AND d.device_system_tag IN @main_system_tag";

                var devices = await frontendRepository.GetAllAsync<Device>(sql_device, post);

                List<AlarmRecordFullInfo> alarmRecordFullInfos = new List<AlarmRecordFullInfo>();
                foreach (var alarmRecord in alarmRecords)
                {
                    var selected_device = devices.Where(x => x.device_number == alarmRecord.device_number).FirstOrDefault();

                    if (selected_device != null)
                    {
                        var tempMsgText = alarmRecord.msgText.Replace("s:", "").Replace("$", "\\");
                        byte[] bytes = Encoding.Default.GetBytes(tempMsgText);

                        var tempStr = string.Empty;
                        string[] strlist = tempMsgText.Replace("\\", "").Split('u');
                        try
                        {
                            for (int i = 1; i < strlist.Length; i++)
                            {
                                //將unicode轉為10進制整數，然後轉為char中文
                                tempStr += (char)int.Parse(strlist[i], System.Globalization.NumberStyles.HexNumber);
                            }
                        }
                        catch (FormatException ex)
                        {

                        }

                        alarmRecord.msgText = tempStr;

                        AlarmRecordFullInfo alarmRecordFullInfo = new AlarmRecordFullInfo();
                        alarmRecordFullInfo.device_number = alarmRecord.device_number;
                        alarmRecordFullInfo.device_name = selected_device.full_name;
                        alarmRecordFullInfo.device_point = alarmRecord.device_point;
                        alarmRecordFullInfo.priority = alarmRecord.priority;
                        alarmRecordFullInfo.msgText = alarmRecord.msgText;
                        alarmRecordFullInfo.alarm_timestamp = alarmRecord.alarm_timestamp;
                        alarmRecordFullInfo.normal_timestamp = alarmRecord.normal_timestamp;
                        alarmRecordFullInfo.ackState = alarmRecord.ackState;
                        alarmRecordFullInfo.ackText = alarmRecord.ackState == 1 ? "unack" : "ack";
                        alarmRecordFullInfo.alarm_className = alarmRecord.alarm_className;
                        alarmRecordFullInfo.userAccount = alarmRecord.userAccount;

                        alarmRecordFullInfos.Add(alarmRecordFullInfo);
                    }
                }

                apiResult.Data = alarmRecordFullInfos;
                apiResult.Code = "0000";
            }
            catch (Exception exception)
            {
                apiResult.Code = "9999";
                apiResult.Msg = "系統內部錯誤，請聯絡管理者。";
                Logger.LogError("【" + controllerName + "/" + actionName + "】" + exception.Message);
            }
            return Ok(apiResult);
        }


        [HttpPost]
        [Route("api/AlarmRecord/GetAllAlarmRecordExcel")]
        public ActionResult<ApiResult<string>> GetAllAlarmRecordExcel(AlarmRecordFilter post)
        {
            ApiResult<string> apiResult = new ApiResult<string>();
            if (!jwtlife)
            {
                apiResult.Code = "5000";
                return BadRequest(apiResult);
            }
            var Workbook = new XSSFWorkbook();
            var ms = new NpoiMemoryStream
            {
                AllowClose = false
            };
            #region excel設定
            IFont font12 = Workbook.CreateFont();
            font12.FontName = "新細明體";
            font12.FontHeightInPoints = 12;
            ICellStyle style12 = Workbook.CreateCellStyle();
            style12.SetFont(font12);
            style12.Alignment = HorizontalAlignment.Center;
            style12.VerticalAlignment = VerticalAlignment.Center;
            IFont font12Times = Workbook.CreateFont();
            font12Times.FontName = "Times New Roman";
            font12Times.FontHeightInPoints = 12;
            IFont font18 = Workbook.CreateFont();
            font18.FontName = "新細明體";
            font18.FontHeightInPoints = 18;
            font18.IsBold = true;
            ICellStyle styleTitle18 = Workbook.CreateCellStyle();
            styleTitle18.SetFont(font18);
            styleTitle18.Alignment = HorizontalAlignment.Center;
            styleTitle18.VerticalAlignment = VerticalAlignment.Center;
            ICellStyle styleLeft12 = Workbook.CreateCellStyle();
            styleLeft12.SetFont(font12);
            styleLeft12.Alignment = HorizontalAlignment.Left;
            styleLeft12.VerticalAlignment = VerticalAlignment.Center;
            ICellStyle styleLine12 = Workbook.CreateCellStyle();
            styleLine12.SetFont(font12);
            styleLine12.Alignment = NPOI.SS.UserModel.HorizontalAlignment.Center;
            styleLine12.VerticalAlignment = VerticalAlignment.Center;
            styleLine12.BorderTop = NPOI.SS.UserModel.BorderStyle.Thin;
            styleLine12.BorderBottom = NPOI.SS.UserModel.BorderStyle.Thin;
            styleLine12.BorderRight = NPOI.SS.UserModel.BorderStyle.Thin;
            styleLine12.BorderLeft = NPOI.SS.UserModel.BorderStyle.Thin;
            ICellStyle stylein12 = Workbook.CreateCellStyle();
            stylein12.SetFont(font12Times);
            stylein12.Alignment = NPOI.SS.UserModel.HorizontalAlignment.Left;
            stylein12.VerticalAlignment = VerticalAlignment.Center;
            stylein12.BorderTop = NPOI.SS.UserModel.BorderStyle.Thin;
            stylein12.BorderBottom = NPOI.SS.UserModel.BorderStyle.Thin;
            stylein12.BorderRight = NPOI.SS.UserModel.BorderStyle.Thin;
            stylein12.BorderLeft = NPOI.SS.UserModel.BorderStyle.Thin;
            stylein12.WrapText = true;
            #endregion
            try 
            {
                IActionResult RecordBack = GetAllAlarmRecord(post).Result.Result;
                var RecordBacks = RecordBack as OkObjectResult;
                ApiResult<List<AlarmRecordFullInfo>> Records = (ApiResult<List<AlarmRecordFullInfo>>)RecordBacks.Value;

                var sheet = Workbook.CreateSheet("告警紀錄");
                int RowPosition = 0;
                IRow row = sheet.CreateRow(RowPosition);
                sheet.SetColumnWidth(0, 10 * 160 * 6);
                sheet.SetColumnWidth(1, 4 * 160 * 6);
                sheet.SetColumnWidth(2, 4 * 160 * 6);
                sheet.SetColumnWidth(3, 4 * 160 * 6);
                sheet.SetColumnWidth(4, 6 * 160 * 6);
                sheet.SetColumnWidth(5, 8 * 160 * 6);
                sheet.SetColumnWidth(6, 8 * 160 * 6);
                sheet.SetColumnWidth(7, 4 * 160 * 6);
                sheet.SetColumnWidth(8, 6 * 160 * 6);
                sheet.SetColumnWidth(9, 6 * 160 * 6);
                ICell cell = row.CreateCell(0);
                cell.SetCellValue("設備編號");
                cell.CellStyle = styleLine12;
                cell = row.CreateCell(1);
                cell.SetCellValue("設備名稱");
                cell.CellStyle = styleLine12;
                cell = row.CreateCell(2);
                cell.SetCellValue("設備點位");
                cell.CellStyle = styleLine12;
                cell = row.CreateCell(3);
                cell.SetCellValue("告警層級");
                cell.CellStyle = styleLine12;
                cell = row.CreateCell(4);
                cell.SetCellValue("訊息");
                cell.CellStyle = styleLine12;
                cell = row.CreateCell(5);
                cell.SetCellValue("發報時間");
                cell.CellStyle = styleLine12;
                cell = row.CreateCell(6);
                cell.SetCellValue("賦歸時間");
                cell.CellStyle = styleLine12;
                cell = row.CreateCell(7);
                cell.SetCellValue("確認狀態");
                cell.CellStyle = styleLine12;
                cell = row.CreateCell(8);
                cell.SetCellValue("報警類別");
                cell.CellStyle = styleLine12;
                cell = row.CreateCell(9);
                cell.SetCellValue("確認者");
                cell.CellStyle = styleLine12;

                foreach(var oneRecord in Records.Data)
                {
                    RowPosition += 1;
                    row = sheet.CreateRow(RowPosition);
                    cell = row.CreateCell(0);
                    cell.SetCellValue(oneRecord.device_number);
                    cell.CellStyle = style12;
                    cell = row.CreateCell(1);
                    cell.SetCellValue(oneRecord.device_name);
                    cell.CellStyle = style12;
                    cell = row.CreateCell(2);
                    cell.SetCellValue(oneRecord.device_point);
                    cell.CellStyle = style12;
                    cell = row.CreateCell(3);
                    cell.SetCellValue(oneRecord.priority);
                    cell.CellStyle = style12;
                    cell = row.CreateCell(4);
                    cell.SetCellValue(oneRecord.msgText);
                    cell.CellStyle = style12;
                    cell = row.CreateCell(5);
                    cell.SetCellValue(oneRecord.alarm_timestamp);
                    cell.CellStyle = style12;
                    cell = row.CreateCell(6);
                    cell.SetCellValue(oneRecord.normal_timestamp);
                    cell.CellStyle = style12;
                    cell = row.CreateCell(7);
                    cell.SetCellValue(oneRecord.ackText);
                    cell.CellStyle = style12;
                    cell = row.CreateCell(8);
                    cell.SetCellValue(oneRecord.alarm_className);
                    cell.CellStyle = style12;
                    cell = row.CreateCell(9);
                    cell.SetCellValue(oneRecord.userAccount);
                    cell.CellStyle = style12;
                }

                Workbook.Write(ms);
                ms.Flush();
                ms.Seek(0, SeekOrigin.Begin);

                if (!Directory.Exists(Path.Combine(Directory.GetCurrentDirectory(), "wwwroot")))
                {
                    Directory.CreateDirectory(Path.Combine(Directory.GetCurrentDirectory(), "wwwroot"));
                }
                if (!Directory.Exists(Path.Combine(Directory.GetCurrentDirectory(), "wwwroot", "Excel")))
                {
                    Directory.CreateDirectory(Path.Combine(Directory.GetCurrentDirectory(), "wwwroot", "Excel"));
                }
                var time = DateTime.Now.ToString("yyyy/MM/dd HH:mm:ss");
                time = time.Replace("/", "").Replace(" ", "_").Replace(":", "");

                var n = Path.Combine(Directory.GetCurrentDirectory(), "wwwroot", "Excel", "告警紀錄_" + time + ".xlsx");
                FileStream FS = new FileStream(n, FileMode.Create, FileAccess.Write);
                Workbook.Write(FS);
                FS.Close();

                apiResult.Data = Path.Combine("Excel", "告警紀錄_" + time + ".xlsx");
                apiResult.Code = "0000";

            }
            catch(Exception ex)
            {
                apiResult.Code = "9999";
                apiResult.Msg = "系統內部錯誤，請聯絡管理者。";
                Logger.LogError("【" + controllerName + "/" + actionName + "】" + ex.Message);
            }

            return Ok(apiResult);
        }
    }
}