425 lines
20 KiB
C#
425 lines
20 KiB
C#
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 AS main_system_name
|
||
FROM building_menu 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 = 'Bajascript'
|
||
AND ap.building_tag IS NOT NULL
|
||
) ap ON bm.building_tag = ap.building_tag
|
||
LEFT JOIN building b ON bm.building_tag = b.building_tag
|
||
left join variable v2 on ap.ShowView = v2.id and v2.deleted = 0
|
||
left join variable v1 on v2.system_parent_id = v1.id
|
||
GROUP BY b.building_tag, b.full_name, v1.system_value, v1.system_key";
|
||
|
||
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);
|
||
}
|
||
}
|
||
}
|