From b3bbbb22a7dacb7b0c3dadec6d69f40672288e1f Mon Sep 17 00:00:00 2001 From: dev02 Date: Thu, 11 May 2023 15:46:04 +0800 Subject: [PATCH] =?UTF-8?q?[=E5=BE=8C=E7=AB=AF]=20=E6=96=B0=E5=A2=9E?= =?UTF-8?q?=E6=B0=B4=E9=9B=BB=E8=A1=A8=E5=88=97=E8=A1=A8api?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../ApiControllers/HydroMeterController.cs | 161 ++++++++++++++++++ FrontendWebApi/Models/HydroMeter.cs | 37 ++++ 2 files changed, 198 insertions(+) create mode 100644 FrontendWebApi/ApiControllers/HydroMeterController.cs create mode 100644 FrontendWebApi/Models/HydroMeter.cs diff --git a/FrontendWebApi/ApiControllers/HydroMeterController.cs b/FrontendWebApi/ApiControllers/HydroMeterController.cs new file mode 100644 index 0000000..3a169d0 --- /dev/null +++ b/FrontendWebApi/ApiControllers/HydroMeterController.cs @@ -0,0 +1,161 @@ +using FrontendWebApi.Models; +using Microsoft.AspNetCore.Mvc; +using Microsoft.Extensions.Logging; +using Repository.BackendRepository.Interface; +using Repository.FrontendRepository.Interface; +using System; +using System.Collections.Generic; +using System.IO; +using System.Linq; +using System.Threading.Tasks; + +namespace FrontendWebApi.ApiControllers +{ + public class HydroMeterController : MyBaseApiController + { + private readonly IBackendRepository backendRepository; + private readonly IFrontendRepository frontendRepository; + + public HydroMeterController(IBackendRepository backendRepository, IFrontendRepository frontendRepository) + { + this.backendRepository = backendRepository; + this.frontendRepository = frontendRepository; + } + + /// + /// 電表 + /// + /// + /// + [HttpPost] + [Route("api/MeterList")] + public async Task>>> MeterList([FromBody] HydroMeterInput input) + { + ApiResult> apiResult = new ApiResult>(); + string tableType = "day week month"; + if (input.building_tag == null) + { + apiResult.Code = "9999"; + apiResult.Msg = "棟別沒有被選取"; + return BadRequest(apiResult); + } + else if (input.tableType == null || tableType.Contains(input.tableType)) + { + apiResult.Code = "9999"; + apiResult.Msg = "表單類別錯誤"; + return BadRequest(apiResult); + } + + try + { + string sqlWhere = ""; + if (input.floor_tag != null) + sqlWhere = $@" and substring_index(device_number, '_', 3) == @floor_tag"; + var table = "archive_electric_meter_" + input.tableType; + var dateFormat = input.tableType == "day" || input.tableType == "week" ? "%Y-%m-%d" : input.tableType == "month" ? "%Y-%m" : null; + var sql = $@"select device_number, avg_rawdata, DATE_FORMAT(start_timestamp, @dateFormat) as timeStamp + from @table + where start_timestamp >= @startTime and end_timestamp <= @endTime and point = 'KWH' and substring_index(device_number, '_', 1) == @building_tag + {sqlWhere} + order by created_at desc;"; + var rawData = await backendRepository.GetAllAsync(sql, + new { table = table, starTime = input.startTime, endTime = input.endTime, building_tag = input.building_tag, floor_tag = input.floor_tag }); + var list = rawData + .GroupBy(x => new { building_tag = x.device_number.Split("_")[0], floor_tag = x.device_number.Split("_")[2], device_serial_tag = x.device_number.Split("_")[4] }) + .Select(x => new HydroMeterOutput { building_tag = x.Key.building_tag, floor_tag = x.Key.floor_tag, device_serial_tag = x.Key.device_serial_tag }) + .ToList(); + + foreach (var l in list) + { + l.rawData = new List(); + l.rawData.AddRange( + rawData.Where(x => x.device_number.Split("_")[0] == l.building_tag && x.device_number.Split("_")[2] == l.floor_tag && x.device_number.Split("_")[4] == l.device_serial_tag) + ); + l.total = l.rawData.Count.ToString(); + l.price = (await backendRepository.GetOneAsync("select system_value from variable where system_type = 'MeterPrice' and deleted = 0")).ToString(); + l.total_price = (l.rawData.Count * Int32.Parse(l.price)).ToString(); + } + + apiResult.Code = "0000"; + apiResult.Data = list; + } + catch (Exception exception) + { + apiResult.Code = "9999"; + apiResult.Msg = "系統內部錯誤，請聯絡管理者。"; + string json = System.Text.Json.JsonSerializer.Serialize(input); + Logger.LogError("【" + controllerName + "/" + actionName + "】" + json); + Logger.LogError("【" + controllerName + "/" + actionName + "】" + exception.Message); + } + return apiResult; + } + + /// + /// 水表 + /// + /// + /// + [HttpPost] + [Route("api/WaterList")] + public async Task>>> WaterList([FromBody] HydroMeterInput input) + { + ApiResult> apiResult = new ApiResult>(); + string tableType = "day week month"; + if (input.building_tag == null) + { + apiResult.Code = "9999"; + apiResult.Msg = "棟別沒有被選取"; + return BadRequest(apiResult); + } + else if (input.tableType == null || tableType.Contains(input.tableType)) + { + apiResult.Code = "9999"; + apiResult.Msg = "表單類別錯誤"; + return BadRequest(apiResult); + } + + try + { + string sqlWhere = ""; + if (input.floor_tag != null) + sqlWhere = $@" and substring_index(device_number, '_', 3) == @floor_tag"; + var table = "archive_water_meter_" + input.tableType; + var dateFormat = input.tableType == "day" || input.tableType == "week" ? "%Y-%m-%d" : input.tableType == "month" ? "%Y-%m" : null; + var sql = $@"select device_number, avg_rawdata, DATE_FORMAT(start_timestamp, @dateFormat) as timeStamp + from @table + where start_timestamp >= @startTime and end_timestamp <= @endTime and point = 'RCV' and substring_index(device_number, '_', 1) == @building_tag + {sqlWhere} + order by created_at desc;"; + var rawData = await backendRepository.GetAllAsync(sql, + new { table = table, starTime = input.startTime, endTime = input.endTime, building_tag = input.building_tag, floor_tag = input.floor_tag, dateFormat = dateFormat }); + var list = rawData + .GroupBy(x => new { building_tag = x.device_number.Split("_")[0], floor_tag = x.device_number.Split("_")[2], device_serial_tag = x.device_number.Split("_")[4] }) + .Select(x => new HydroMeterOutput { building_tag = x.Key.building_tag, floor_tag = x.Key.floor_tag, device_serial_tag = x.Key.device_serial_tag }) + .ToList(); + + foreach (var l in list) + { + l.rawData = new List(); + l.rawData.AddRange( + rawData.Where(x => x.device_number.Split("_")[0] == l.building_tag && x.device_number.Split("_")[2] == l.floor_tag && x.device_number.Split("_")[4] == l.device_serial_tag) + ); + l.total = l.rawData.Count.ToString(); + l.price = (await backendRepository.GetOneAsync("select system_value from variable where system_type = 'WaterPrice' and deleted = 0")).ToString(); + l.total_price = (l.rawData.Count * Int32.Parse(l.price)).ToString(); + } + + apiResult.Code = "0000"; + apiResult.Data = list; + } + catch (Exception exception) + { + apiResult.Code = "9999"; + apiResult.Msg = "系統內部錯誤，請聯絡管理者。"; + string json = System.Text.Json.JsonSerializer.Serialize(input); + Logger.LogError("【" + controllerName + "/" + actionName + "】" + json); + Logger.LogError("【" + controllerName + "/" + actionName + "】" + exception.Message); + } + return apiResult; + } + } +} diff --git a/FrontendWebApi/Models/HydroMeter.cs b/FrontendWebApi/Models/HydroMeter.cs new file mode 100644 index 0000000..6bbb95a --- /dev/null +++ b/FrontendWebApi/Models/HydroMeter.cs @@ -0,0 +1,37 @@ +using System; +using System.Collections.Generic; +using System.Security.Cryptography.X509Certificates; + +namespace FrontendWebApi.Models +{ + public class HydroMeter + { + } + + public class HydroMeterInput + { + public string tableType { get; set; } //day, week, month + public string building_tag { get; set; } + public string floor_tag { get; set; } + public DateTime startTime { get; set; } + public DateTime endTime { get; set; } + } + + public class HydroMeterOutput + { + public string building_tag { get; set; } + public string floor_tag { get; set; } + public string device_serial_tag { get; set; } + public string total { get; set; } + public string price { get; set; } + public string total_price { get; set; } + public List rawData { get; set; } + } + + public class HydroMeterRawDataOutput + { + public string timeStamp { get; set; } + public string device_number { get; set; } + public decimal avg_rawdata { get; set; } + } +}