From c147f79e96d9e54b8d7ab4465bd1b4db583137c9 Mon Sep 17 00:00:00 2001 From: "jay.chang" Date: Wed, 12 Jun 2024 16:29:20 +0800 Subject: [PATCH] =?UTF-8?q?[WebApi]=E7=B7=8A=E6=80=A5=E6=87=89=E8=AE=8A?= =?UTF-8?q?=E4=BA=8B=E4=BB=B6=E6=9F=A5=E8=A9=A2=E9=A0=81=E9=9D=A2=E4=BF=AE?= =?UTF-8?q?=E6=94=B9=EF=BC=8C=E5=8F=AA=E8=A6=81=E7=99=BC=E7=94=9F=E9=81=8E?= =?UTF-8?q?=E5=B0=B1=E6=9C=83=E6=9C=89=E7=B4=80=E9=8C=84=20[BGService]?= =?UTF-8?q?=E6=96=B0=E5=A2=9E=E7=B7=8A=E6=80=A5=E6=87=89=E8=AE=8A=E4=BA=8B?= =?UTF-8?q?=E4=BB=B6=E7=B4=80=E9=8C=84=E5=AE=9A=E6=9C=9F=E5=AD=98DB?= =?UTF-8?q?=E6=8E=92=E7=A8=8B?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- BackendWorkerService/Program.cs | 9 +- .../Quartz/Jobs/EmergencyRecordJob.cs | 156 +++ .../appsettings.Development.json | 1 + BackendWorkerService/appsettings.json | 1 + .../ApiControllers/AlarmController.cs | 2 +- .../EmergencyDeviceController.cs | 39 +- .../EmergencyRecordController.cs | 2 +- FrontendWebApi/Models/EmergencyDevice.cs | 3 + FrontendWebApi/Models/EmergencyRecord.cs | 4 + .../Views/EmergencyDeviceMenu/Index.cshtml | 68 +- .../Views/EmergencyHardwareMenu/Index.cshtml | 84 +- .../Views/EmergencyRecord/Index.cshtml | 1120 ++++++++++++++++- 12 files changed, 1412 insertions(+), 77 deletions(-) create mode 100644 BackendWorkerService/Quartz/Jobs/EmergencyRecordJob.cs diff --git a/BackendWorkerService/Program.cs b/BackendWorkerService/Program.cs index df384df..f2ea9b1 100644 --- a/BackendWorkerService/Program.cs +++ b/BackendWorkerService/Program.cs @@ -150,12 +150,19 @@ namespace BackendWorkerService #endregion #region 定時檢查燈控排程 - services.AddSingleton< LightScheduleJob>(); + services.AddSingleton(); services.AddSingleton( new JobSchedule(jobType: typeof(LightScheduleJob), cronExpression: configuration.GetValue("BackgroundServiceCron:LightScheduleJob ")) ); #endregion + #region 定時記錄緊急應變告警排程 + services.AddSingleton(); + services.AddSingleton( + new JobSchedule(jobType: typeof(EmergencyRecordJob), cronExpression: configuration.GetValue("BackgroundServiceCron:EmergencyRecordJob ")) + ); + #endregion + }).ConfigureLogging((hostContext, logFactory) => { IConfiguration configuration = hostContext.Configuration; diff --git a/BackendWorkerService/Quartz/Jobs/EmergencyRecordJob.cs b/BackendWorkerService/Quartz/Jobs/EmergencyRecordJob.cs new file mode 100644 index 0000000..db01740 --- /dev/null +++ b/BackendWorkerService/Quartz/Jobs/EmergencyRecordJob.cs @@ -0,0 +1,156 @@ +嚜簑sing FrontendWebApi.Models; +using Microsoft.Extensions.Logging; +using Quartz; +using Repository.BackendRepository.Interface; +using System; +using System.Collections.Generic; +using System.IO; +using System.Linq; +using System.Net.Http; +using System.Text; +using System.Threading.Tasks; +using System.Xml.Linq; + +namespace BackendWorkerService.Quartz.Jobs +{ + [DisallowConcurrentExecution] + + class EmergencyRecordJob : IJob + { + private readonly ILogger logger; + private readonly IBackendRepository backendRepository; + private readonly ILogger loggers; + public EmergencyRecordJob(ILogger logger, IBackendRepository backendRepository, ILogger loggers) + { + this.logger = logger; + this.backendRepository = backendRepository; + this.loggers = loggers; + } + + public async Task Execute(IJobExecutionContext context) + { + Task_Detail task_Detail = new Task_Detail(loggers, backendRepository); + try + { + if (await task_Detail.GetNeedWorkTask("EmergencyRecordJob", "EmergencyRecord")) + { + try + { + await task_Detail.InsertWorkTime("EmergencyRecordJob", "EmergencyRecord"); + + var sqlString = $@"SELECT system_value FROM variable WHERE system_type = 'obixConfig' AND system_key = 'ApiBase' AND deleted = 0"; + string baseApiUrl = await backendRepository.GetOneAsync(sqlString); + + + sqlString = $@"SELECT system_value FROM variable WHERE system_type = 'emergencyConfig' AND system_key = 'getNiagaraAlarmMoveDayNumStart' AND deleted = 0"; + int moveDayNum = int.Parse((await backendRepository.GetOneAsync(sqlString)) ?? "-1"); + + string apiUrl = Path.Combine(baseApiUrl, "obix/config/Services/AlarmService/~alarmQuery/"); + + + var device_disaster = await backendRepository.GetAllAsync("device_disaster",""); + + using (HttpClient client = new HttpClient()) + { + string username = "stanGG"; + string password = "St12345678"; + string encoded = Convert.ToBase64String(System.Text.Encoding.GetEncoding("ISO-8859-1").GetBytes(username + ":" + password)); + + client.DefaultRequestHeaders.Add("Authorization", "Basic " + encoded); + // 撱箸 XML 豢 + string xmlData = @$" + + + "; + HttpContent content = new StringContent(xmlData, Encoding.UTF8, "application/xml"); + + var response = await client.PostAsync(apiUrl, content); + var resString = (await response.Content.ReadAsStringAsync()).ToString(); + + XDocument xmlDoc = XDocument.Parse(resString); + + var list = xmlDoc.Descendants().Where(d => d.Name?.LocalName == "list").FirstOrDefault(); + var objs = list.Descendants().Where(d => d.Name?.LocalName == "obj" && (d.Attribute("is")?.Value?.Contains("obix:Alarm") ?? false)).ToList(); + var dictionaryList = new List>(); + + + List filterList = device_disaster.Select(x => x.device_number).ToList(); + + var filteredObjs = objs.Where(obj => + { + var deviceNumber = obj.Descendants().Where(d => d.Name.LocalName == "str" && d.Attribute("name").Value == "sourceName") + .Select(d => d.Attribute("val").Value) + .Select(d => string.Join("_", d.Split("_").Take(5))) + .FirstOrDefault(); + + return filterList.Contains(deviceNumber); + }).ToList(); + + foreach (var obj in filteredObjs) + { + var newguid = Guid.NewGuid(); + var alarm_timestamp = obj.Descendants().Where(d => d.Name.LocalName == "abstime" && d.Attribute("name").Value == "timestamp") + .Select(d => + { + DateTime valid; + if (DateTime.TryParse(d.Attribute("val").Value, out valid)) + { + return DateTime.Parse(d.Attribute("val").Value).ToString("yyyy-MM-dd HH:mm:ss"); + } + else + { + return null; + } + }).FirstOrDefault(); + var device_number = obj.Descendants().Where(d => d.Name.LocalName == "str" && d.Attribute("name").Value == "sourceName") + .Select(d => d.Attribute("val").Value) + .Select(d => string.Join("_", d.Split("_").Take(5))) + .FirstOrDefault(); + var filterDevice = device_disaster.Where(x => x.device_number == device_number).FirstOrDefault(); + + var dictionary = new Dictionary() + { + {"@emergency_event_guid",newguid}, + {"@disaster",filterDevice.device_system_value}, + {"@building_tag", filterDevice.device_building_tag}, + {"@device_guid",filterDevice.device_guid }, + {"@type",0}, + {"@alarm_time",alarm_timestamp} + }; + dictionaryList.Add(dictionary); + + } + + var mergeSql = @" + INSERT INTO emergency_event + (emergency_event_guid, disaster, device_guid, building_tag, type, alarm_time) + VALUES + (@emergency_event_guid, @disaster, @device_guid, @building_tag, @type, @alarm_time) + ON DUPLICATE KEY UPDATE + disaster = VALUES(disaster), + building_tag = VALUES(building_tag), + type = VALUES(type)"; + + + await backendRepository.ExecuteSql(mergeSql, dictionaryList); + + } + + await task_Detail.InsertWorkTime_End("EmergencyRecordJob", "EmergencyRecord"); + } + catch (Exception ex) + { + await task_Detail.WorkFail("EmergencyRecordJob", "EmergencyRecord", ex.Message.ToString()); + } + } + } + catch (Exception exception) + { + logger.LogError("EmergencyRecordJob隞餃憭望"); + logger.LogError("EmergencyRecordJob隞餃憭望[Exception]嚗{0}", exception.ToString()); + } + } + + } + +} diff --git a/BackendWorkerService/appsettings.Development.json b/BackendWorkerService/appsettings.Development.json index 2246065..b242733 100644 --- a/BackendWorkerService/appsettings.Development.json +++ b/BackendWorkerService/appsettings.Development.json @@ -16,6 +16,7 @@ "ArchiveElectricMeterHourJob": "0 0 2 * * ?", "ArchiveElectricMeterDayJob": "0/5 * * * * ?", "LightScheduleJob ": "0/5 * * * * ?", + "EmergencyRecordJob ": "0/5 * * * * ?", "WeatherAPIJob": "0/5 * * * * ?" }, "DBConfig": { diff --git a/BackendWorkerService/appsettings.json b/BackendWorkerService/appsettings.json index 55bfb05..7b21805 100644 --- a/BackendWorkerService/appsettings.json +++ b/BackendWorkerService/appsettings.json @@ -17,6 +17,7 @@ "ArchiveElectricMeterHourJob": "0 0 2 * * ?", "ArchiveElectricMeterDayJob": "0/5 * * * * ?", "LightScheduleJob ": "0 0/1 * * * ?", + "EmergencyRecordJob ": "0 0/1 * * * ?", "WeatherAPIJob": "0 0 2 * * ?" }, "DBConfig": { diff --git a/FrontendWebApi/ApiControllers/AlarmController.cs b/FrontendWebApi/ApiControllers/AlarmController.cs index a9bbf46..170053a 100644 --- a/FrontendWebApi/ApiControllers/AlarmController.cs +++ b/FrontendWebApi/ApiControllers/AlarmController.cs @@ -121,7 +121,7 @@ namespace FrontendWebApi.ApiControllers DateTime valid; if (DateTime.TryParse(d.Attribute("val").Value, out valid)) { - return DateTime.Parse(d.Attribute("val").Value).ToString("yyyy-MM-dd HH:mm:ss.fff"); + return DateTime.Parse(d.Attribute("val").Value).ToString("yyyy-MM-dd HH:mm:ss"); } else { diff --git a/FrontendWebApi/ApiControllers/EmergencyDeviceController.cs b/FrontendWebApi/ApiControllers/EmergencyDeviceController.cs index b7b2885..7173129 100644 --- a/FrontendWebApi/ApiControllers/EmergencyDeviceController.cs +++ b/FrontendWebApi/ApiControllers/EmergencyDeviceController.cs @@ -6,6 +6,7 @@ using Newtonsoft.Json; using Repository.BackendRepository.Interface; using Repository.FrontendRepository.Interface; using System; +using System.Collections; using System.Collections.Generic; using System.Data.SqlTypes; using System.Diagnostics; @@ -256,18 +257,44 @@ namespace FrontendWebApi.ApiControllers } try { - var newguid = Guid.NewGuid(); - var dictionary = new Dictionary() + if (eventpost.emergency_event_guid != null) + { + var dictionary = new Dictionary() + { + {"@finish_time",DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss")} + }; + await backendRepository.UpdateOneByCustomTable(dictionary, "emergency_event", $"emergency_event_guid = '{eventpost.emergency_event_guid}'"); + apiResult.Code = "0000"; + apiResult.Msg = "湔啣"; + } + else + { + // 瑼Ｘ交臬行閰脩 + var sql = "SELECT * FROM emergency_event WHERE alarm_time = @alarmTime AND device_guid = @deviceGuid"; + var count = await backendRepository.GetOneAsync(sql, new { alarmTime = eventpost.alarm_time, deviceGuid = eventpost.device }); + if (count != null) + { + apiResult.Code = "0000"; + apiResult.Msg = "撌脫閰脩蝝"; + apiResult.Data = count.emergency_event_guid; + + return Ok(apiResult); + } + + var newguid = Guid.NewGuid(); + var dictionary = new Dictionary() { {"@emergency_event_guid",newguid}, {"@disaster",eventpost.disaster}, {"@building_tag", eventpost.build}, {"@device_guid",eventpost.device }, - {"@type",eventpost.type} + {"@type",eventpost.type}, + {"@alarm_time",eventpost.alarm_time} }; - await backendRepository.AddOneByCustomTable(dictionary, "emergency_event"); - apiResult.Data = newguid.ToString(); - apiResult.Code = "0000"; + await backendRepository.AddOneByCustomTable(dictionary, "emergency_event"); + apiResult.Data = newguid.ToString(); + apiResult.Code = "0000"; + } } catch (Exception exception) { diff --git a/FrontendWebApi/ApiControllers/EmergencyRecordController.cs b/FrontendWebApi/ApiControllers/EmergencyRecordController.cs index 871cb49..21a3159 100644 --- a/FrontendWebApi/ApiControllers/EmergencyRecordController.cs +++ b/FrontendWebApi/ApiControllers/EmergencyRecordController.cs @@ -71,7 +71,7 @@ namespace FrontendWebApi.ApiControllers } EmergencyRecordEvent = await backendRepository.GetAllAsync($@" - select d.device_number device_name,v.system_key disaster_name,ee.*,b.full_name building_name from emergency_event ee + select d.device_number device_name,v.system_key disaster_name,ee.*,b.full_name building_name,ee.alarm_time,ee.finish_time from emergency_event ee left join (select * from variable v where v.system_type = 'disaster') v on v.system_value = ee.disaster left join device d on d.device_guid = ee.device_guid left join building b on b.building_tag = ee.building_tag diff --git a/FrontendWebApi/Models/EmergencyDevice.cs b/FrontendWebApi/Models/EmergencyDevice.cs index a7ffe41..800230d 100644 --- a/FrontendWebApi/Models/EmergencyDevice.cs +++ b/FrontendWebApi/Models/EmergencyDevice.cs @@ -113,10 +113,13 @@ namespace FrontendWebApi.Models public class Eventpost { + public string emergency_event_guid { get; set; } public int disaster { get; set; } public string build { get; set; } public byte type { get; set; } public string device { get; set; } + public string alarm_time { get; set; } = DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss"); + } public class EmergencySetting diff --git a/FrontendWebApi/Models/EmergencyRecord.cs b/FrontendWebApi/Models/EmergencyRecord.cs index a0bab2f..458ae63 100644 --- a/FrontendWebApi/Models/EmergencyRecord.cs +++ b/FrontendWebApi/Models/EmergencyRecord.cs @@ -19,11 +19,15 @@ namespace FrontendWebApi.Models public class EmergencyRecordEvent : Actor { + private string _alarm_time; + private string _finish_time; public string emergency_event_guid { get; set; } public int disaster { get; set; } public string device_guid { get; set; } public string building_guid { get; set; } public byte type { get; set; } + public string alarm_time { get { return Convert.ToDateTime(_alarm_time).ToString("yyyy-MM-dd HH:mm:ss"); } set { _alarm_time = value; } } + public string finish_time { get { return Convert.ToDateTime(_finish_time).ToString("yyyy-MM-dd HH:mm:ss"); } set { _finish_time = value; } } } public class EmergencyRecordEventTable : EmergencyRecordEvent diff --git a/FrontendWebApi/Views/EmergencyDeviceMenu/Index.cshtml b/FrontendWebApi/Views/EmergencyDeviceMenu/Index.cshtml index 133df90..713ed78 100644 --- a/FrontendWebApi/Views/EmergencyDeviceMenu/Index.cshtml +++ b/FrontendWebApi/Views/EmergencyDeviceMenu/Index.cshtml @@ -1,12 +1,12 @@ 嚜濃{ ViewData["MainNum"] = "4"; ViewData["SubNum"] = "1"; - ViewData["Title"] = "閮剖蝮質汗"; + ViewData["Title"] = "鈭隞嗆"; }
  1. 擐
    2. -
  2. 閮剖蝮質汗
    3. +
  3. 鈭隞嗆
@@ -94,7 +94,10 @@ @**@ - +
+ @**@ + +
@@ -621,6 +624,7 @@ 'createdRow': function (row, data, dataIndex) { $(row).attr('data-guid', data.device_guid); $(row).attr('data-disaster', data.disaster); + $(row).attr('data-time', data.alarm_timestamp); }, "ajax": { "url": "/api/EmergencyDevice", @@ -651,7 +655,7 @@ enable_alarm_timer = true; is_need_reload = false; - + // 憒臬霅阡Ｗ脰閮剖皜株alarm閮剖瘥撠 if (show_mode == 'alarm') { backfill_building_alarm_device_amount = []; backfill_layer2_alarm_device_amount = []; @@ -748,9 +752,10 @@ selected_device_guid = $(this).parents('tr').attr('data-guid'); selected_device_disaster = $(this).parents('tr').attr('data-disaster'); + selected_device_time = $(this).parents('tr').attr('data-time'); - OnSimulationExercise(selected_device_guid, selected_device_disaster, 0); - + OnSimulationExercise(selected_device_guid, selected_device_disaster, 0, selected_device_time); + // SendMessageAsync("D001"); }); //#endregion @@ -1389,7 +1394,7 @@ //#endregion //#region 璅⊥祆蝺 / SOP 恍 - function OnSimulationExercise(guid, disaster, type) { + function OnSimulationExercise(guid, disaster, type ,time) { if (type === 1 && SelectedFilter.disasters.length > 1) { toast_warning("脩賡亙芾賢桅賂隢靽格寥脩賡"); @@ -1415,6 +1420,7 @@ build: SelectedFilter.building_tag[0] ?? null, disaster: disaster, type: type, + alarm_time: time, device: guid }; $.post(url, send_data, function (rel) { @@ -1433,6 +1439,49 @@ } //#endregion + //#region 湔唬隞嗅 + function UpdateRecordFinishTime() { + + var url = "/api/EmergencyDevice/SaveAndOpenSimulationExercise"; + var send_data = { + emergency_event_guid: SimulationExerciseGuid + }; + $.post(url, send_data, function (rel) { + if (rel.code != "0000") { + if (rel.code == "9999") { + toast_error(rel.msg); + } + return; + } + else { + + return; + } + }, 'json'); + } + //#endregion + + //#region 潮餉閮 + function SendMessageAsync(message) { + + var url = "/api/Send"; + var send_data = { + message: message + }; + $.post(url, send_data, function (rel) { + if (rel.code != "0000") { + if (rel.code == "9999") { + toast_error("餉閮" + message + "憭望"); + } + return; + } + else { + + return; + } + }, 'json'); + } + //#endregion //#region 璅⊥祆蝺 / SOP modal 敺蝯 function GetbuttonList(selected_disaster) { var url = "/api/EmergencyDevice/GetGroupingList"; @@ -1805,7 +1854,7 @@ if (tablist == undefined) { $('#button_' + EmerNowsetting).find('button').attr('disabled', true); - CloseVerify = true; + // CloseVerify = true; //$('#closemodal').attr('disabled', false); } else { $('#' + tablist).trigger('click'); @@ -1903,6 +1952,9 @@ CloseVerify = true; $('#emergency-verify-modal').modal('hide'); $('#SimulationExercisemodal').modal('hide'); + // SendMessageAsync("D002"); + UpdateRecordFinishTime() + CloseVerify = false; // 瘥甈⊿瘚蝔質撽霅銝甈 } else { toast_warning('撖蝣潮霅憭望嚗隢圈霅'); } diff --git a/FrontendWebApi/Views/EmergencyHardwareMenu/Index.cshtml b/FrontendWebApi/Views/EmergencyHardwareMenu/Index.cshtml index 7a8c0d1..cd73a2f 100644 --- a/FrontendWebApi/Views/EmergencyHardwareMenu/Index.cshtml +++ b/FrontendWebApi/Views/EmergencyHardwareMenu/Index.cshtml @@ -359,56 +359,56 @@ }) //#region 摰敺梯郎閮剖(3s) - interval_id = setInterval(function () { - if (!enable_alarm_timer) { - return; - } - var url = "/api/Device/Getalarm"; - $.post(url, null, function (rel) { - if (rel.code != "0000") { - if (rel.code == "9999") { - toast_error(rel.msg); - } - else { - toast_warning(rel.msg); - } - return; - } - else { + // interval_id = setInterval(function () { + // if (!enable_alarm_timer) { + // return; + // } + // var url = "/api/Device/Getalarm"; + // $.post(url, null, function (rel) { + // if (rel.code != "0000") { + // if (rel.code == "9999") { + // toast_error(rel.msg); + // } + // else { + // toast_warning(rel.msg); + // } + // return; + // } + // else { - var is_diff = false; - if (Object.keys(temp_alarm_device).length == Object.keys(rel.data.alarmorion).length) { + // var is_diff = false; + // if (Object.keys(temp_alarm_device).length == Object.keys(rel.data.alarmorion).length) { - for (var i = 0; i < Object.keys(rel.data.alarmorion).length; i++) { + // for (var i = 0; i < Object.keys(rel.data.alarmorion).length; i++) { - var index = temp_alarm_device.findIndex(x => x.alarm_timestamp == rel.data.alarmorion[i].alarm_timestamp - && x.device_number == rel.data.alarmorion[i].device_number) + // var index = temp_alarm_device.findIndex(x => x.alarm_timestamp == rel.data.alarmorion[i].alarm_timestamp + // && x.device_number == rel.data.alarmorion[i].device_number) - if (index > -1) { - is_diff = false; - } else { - is_diff = true; - } - } + // if (index > -1) { + // is_diff = false; + // } else { + // is_diff = true; + // } + // } - } else { - is_diff = true; - } + // } else { + // is_diff = true; + // } - temp_alarm_device = rel.data.alarmorion; + // temp_alarm_device = rel.data.alarmorion; - if (show_mode == "alarm" && (is_need_reload || is_diff)) { - enable_alarm_timer = false; //亥岷啣虜閮剖嚗踹銴澆 + // if (show_mode == "alarm" && (is_need_reload || is_diff)) { + // enable_alarm_timer = false; 亥岷啣虜閮剖嚗踹銴澆 - $("#building").find(".building_device_amount").html(0); - rel.data.buildingAlarmDeviceAmount.forEach(function (item) { - $(`#${item.building_tag}_device_amount`).html(item.device_amount); - }); - ResetDeviceTable(); - } - } - }, 'json'); - }, 3000); + // $("#building").find(".building_device_amount").html(0); + // rel.data.buildingAlarmDeviceAmount.forEach(function (item) { + // $(`#${item.building_tag}_device_amount`).html(item.device_amount); + // }); + // ResetDeviceTable(); + // } + // } + // }, 'json'); + // }, 3000); //#endregion //#region 璅⊥祆蝺 / SOP modal 舐窗皜娛able diff --git a/FrontendWebApi/Views/EmergencyRecord/Index.cshtml b/FrontendWebApi/Views/EmergencyRecord/Index.cshtml index 4b42cb0..d8b7644 100644 --- a/FrontendWebApi/Views/EmergencyRecord/Index.cshtml +++ b/FrontendWebApi/Views/EmergencyRecord/Index.cshtml @@ -23,14 +23,12 @@
-
-
@@ -55,8 +53,8 @@
@*
- 臬摺DF - 臬慟xcel + 臬摺DF + 臬慟xcel
*@
+ + + + + @section Scripts { } \ No newline at end of file