[FE API] ElectricList_keke version 未完成
This commit is contained in:
keke
parent
a93b405ba6
commit
88b723aeb4
@ -15,6 +15,7 @@ using System.Threading.Tasks;
|
||||
using Ionic.Zip;
|
||||
using System.Collections.Immutable;
|
||||
using System.Text;
|
||||
using iTextSharp.text;
|
||||
|
||||
namespace FrontendWebApi.ApiControllers
|
||||
{
|
||||
@ -822,6 +823,341 @@ namespace FrontendWebApi.ApiControllers
|
||||
return File(ms, "application/vnd.ms-excel", @$"電表報表{System.DateTime.Now.ToString("yyyyMMddHHmm")}.xlsx");
|
||||
}
|
||||
|
||||
[HttpPost]
|
||||
[Route("api/ExportElectricEachCompareList")]
|
||||
public FileResult OpeExportEachCompareExcelElec([FromBody] HydroMeterInput input)
|
||||
{
|
||||
List<List<HydroMeterOutput>> result = new List<List<HydroMeterOutput>>();
|
||||
var building = backendRepository.GetAllAsync<HydroBuildList>("select * from building where deleted = 0").Result;
|
||||
StringBuilder fix_buildingTag = new StringBuilder();
|
||||
foreach (var b in building)
|
||||
{
|
||||
fix_buildingTag.Append("'").Append(b.building_tag.Trim()).Append("', ");
|
||||
}
|
||||
input.building_tag = fix_buildingTag.ToString().TrimEnd(',', ' ');
|
||||
|
||||
result.Add(ElectricList_keke(input).Result.Value.Data.ToList());
|
||||
|
||||
// --- 8/24 修改到這裡囉 ---
|
||||
|
||||
List<Dictionary<string, byte[]>> docFile = new List<Dictionary<string, byte[]>>();
|
||||
|
||||
var workbook = new XSSFWorkbook();
|
||||
#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
|
||||
foreach (var r in result)
|
||||
{
|
||||
if (r.Count > 0)
|
||||
{
|
||||
string buildingName = r.Select(x => x.building_name).FirstOrDefault();
|
||||
var sheet = workbook.CreateSheet($"{buildingName} 電表報表");
|
||||
int RowPosition = 0;
|
||||
#region set cell
|
||||
IRow row = sheet.CreateRow(RowPosition);
|
||||
sheet.SetColumnWidth(0, 4 * 160 * 12);
|
||||
sheet.SetColumnWidth(1, 4 * 160 * 12);
|
||||
sheet.SetColumnWidth(2, 4 * 160 * 12);
|
||||
|
||||
int i = 0;
|
||||
ICell cell = row.CreateCell(i++);
|
||||
cell.SetCellValue("棟別");
|
||||
cell.CellStyle = styleLine12;
|
||||
cell = row.CreateCell(i++);
|
||||
cell.SetCellValue("樓層");
|
||||
cell.CellStyle = styleLine12;
|
||||
cell = row.CreateCell(i++);
|
||||
cell.SetCellValue("設備");
|
||||
cell.CellStyle = styleLine12;
|
||||
cell = row.CreateCell(i++);
|
||||
cell.SetCellValue("單位");
|
||||
cell.CellStyle = styleLine12;
|
||||
|
||||
foreach (var rr in r.FirstOrDefault().rawData)
|
||||
{
|
||||
cell = row.CreateCell(i++);
|
||||
cell.SetCellValue(rr.timeStamp);
|
||||
cell.CellStyle = styleLine12;
|
||||
}
|
||||
|
||||
cell = row.CreateCell(i++);
|
||||
cell.SetCellValue("小計");
|
||||
cell.CellStyle = styleLine12;
|
||||
cell = row.CreateCell(i++);
|
||||
cell.SetCellValue("單價");
|
||||
cell.CellStyle = styleLine12;
|
||||
cell = row.CreateCell(i++);
|
||||
cell.SetCellValue("金額總計");
|
||||
cell.CellStyle = styleLine12;
|
||||
#endregion
|
||||
|
||||
foreach (var rr in r)
|
||||
{
|
||||
RowPosition += 1;
|
||||
int k = 4;
|
||||
row = sheet.CreateRow(RowPosition);
|
||||
for (int j = 0; j <= i; j++)
|
||||
{
|
||||
cell = row.CreateCell(j);
|
||||
if (j == 0)
|
||||
{
|
||||
cell.SetCellValue(rr.building_name);
|
||||
}
|
||||
else if (j == 1)
|
||||
{
|
||||
cell.SetCellValue(rr.floor_tag);
|
||||
}
|
||||
else if (j == 2)
|
||||
{
|
||||
cell.SetCellValue(rr.device_full_name);
|
||||
}
|
||||
else if (j == 3)
|
||||
{
|
||||
cell.SetCellValue("kWh");
|
||||
}
|
||||
|
||||
else if (j == 4)
|
||||
{
|
||||
foreach (var rrr in rr.rawData)
|
||||
{
|
||||
cell.SetCellValue(rrr.avg_rawdata.ToString());
|
||||
j++;
|
||||
k++;
|
||||
cell = row.CreateCell(j);
|
||||
}
|
||||
}
|
||||
|
||||
if (j == k)
|
||||
{
|
||||
cell.SetCellValue(rr.total);
|
||||
}
|
||||
else if (j == k + 1)
|
||||
{
|
||||
cell.SetCellValue(rr.price);
|
||||
}
|
||||
else if (j == k + 2)
|
||||
{
|
||||
cell.SetCellValue(rr.total_price);
|
||||
}
|
||||
|
||||
cell.CellStyle = style12;
|
||||
}
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
var ms = new NpoiMemoryStream
|
||||
{
|
||||
AllowClose = false
|
||||
};
|
||||
workbook.Write(ms);
|
||||
ms.Flush();
|
||||
ms.Seek(0, SeekOrigin.Begin);
|
||||
Response.Headers.Add("Access-Control-Expose-Headers", "Content-Disposition");
|
||||
return File(ms, "application/vnd.ms", @$"電表報表{System.DateTime.Now.ToString("yyyyMMddHHmm")}.xlsx");
|
||||
}
|
||||
|
||||
[HttpPost]
|
||||
[Route("api/ElectricList_keke")]
|
||||
public async Task<ActionResult<ApiResult<List<HydroMeterOutput>>>> ElectricList_keke([FromBody] HydroMeterInput input)
|
||||
{
|
||||
ApiResult<List<HydroMeterOutput>> apiResult = new ApiResult<List<HydroMeterOutput>>(jwt_str);
|
||||
if (!jwtlife)
|
||||
{
|
||||
apiResult.Code = "5000";
|
||||
return BadRequest(apiResult);
|
||||
}
|
||||
|
||||
string tableType = "day week month year";
|
||||
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
|
||||
{
|
||||
// 利用今年當月的字串，產生今年上月及去年同月的字串
|
||||
DateTime date = DateTime.ParseExact(input.startTime, "yyyy-MM", null); // 2023-08
|
||||
DateTime start = date.AddYears(-1).AddMonths(-1);
|
||||
DateTime end = date.AddMonths(1);
|
||||
DateTime previousYear = date.AddYears(-1);
|
||||
DateTime previousMonth = date.AddMonths(-1);
|
||||
//Console.WriteLine(previousYear.ToString("yyyy-MM")); // 2022-08
|
||||
//Console.WriteLine(previousMonth.ToString("yyyy-MM")); // 2023-07
|
||||
|
||||
var startTime = start.ToString("yyyy-MM"); // 查詢月份的去年 (去年同月)
|
||||
var endTime = end.ToString("yyyy-MM"); // 查詢月份的上個月
|
||||
var lastYear = previousYear.ToString("yyyy-MM");
|
||||
var lastMonth = previousMonth.ToString("yyyy-MM");
|
||||
var searchTime = input.startTime; // 欲查詢的月份
|
||||
|
||||
string sqlWhere = "";
|
||||
string sqlGroup = "";
|
||||
string sqlAvgRawData = "";
|
||||
string buildingSql = "";
|
||||
string tag_quantity = await backendRepository.GetOneAsync<string>("select system_value from variable where system_type = 'obixConfig' and system_key = 'tag_quantity' and deleted = 0");
|
||||
|
||||
// 將棟別字串前處理 (後續 SQL 語法可以使用 IN 的格式)
|
||||
string[] parts_buildingTag = input.building_tag.Split(',');
|
||||
StringBuilder fix_buildingTag = new StringBuilder();
|
||||
foreach (string part in parts_buildingTag)
|
||||
{
|
||||
fix_buildingTag.Append("'").Append(part.Trim()).Append("', ");
|
||||
}
|
||||
input.building_tag = fix_buildingTag.ToString().TrimEnd(',', ' ');
|
||||
|
||||
if (tag_quantity == "5")
|
||||
buildingSql = @$" and SUBSTRING_INDEX(device_number, '_', 1) in ({input.building_tag}) ";
|
||||
else
|
||||
buildingSql = @$" and SUBSTRING_INDEX(SUBSTRING_INDEX(device_number, '_', 2), '_', -1) in ({input.building_tag}) ";
|
||||
|
||||
sqlAvgRawData = " round(kwh_result, 2) as avg_rawdata, start_timestamp, end_timestamp ";
|
||||
|
||||
var table = "archive_electric_meter_month";
|
||||
var schema = await backendRepository.GetOneAsync<string>($"select system_value from variable where system_type = 'project_name'");
|
||||
var isTable = await backendRepository.GetOneAsync<string>($"select table_name from information_schema.tables where table_name = '{table}' and table_schema = '{schema.Split('/')[0]}'");
|
||||
if (string.IsNullOrEmpty(isTable)) //check for has table or not
|
||||
{
|
||||
apiResult.Code = "0000";
|
||||
apiResult.Data = new List<HydroMeterOutput>() { };
|
||||
return Ok(apiResult);
|
||||
}
|
||||
|
||||
var dateFormat = input.tableType == "day" || input.tableType == "week" ? "%Y-%m-%d" : input.tableType == "month" ? "%Y-%m" : input.tableType == "year" ? "%Y" : null;
|
||||
var aemmEndDate = input.tableType == "year" ? $"year(DATE_ADD(fd.date, INTERVAL +1 {input.tableType}))" : $"DATE_ADD(fd.date, INTERVAL +1 {input.tableType})";
|
||||
var aemmStaDate = input.tableType == "year" ? "year(fd.date)" : "fd.date";
|
||||
var sql = $@"set @i = -1;
|
||||
select fd.device_number, case when aemm.avg_rawdata = -1.0 then 'NaN' when aemm.avg_rawdata is null then 0.00 else aemm.avg_rawdata end as avg_rawdata, DATE_FORMAT(fd.date, '{dateFormat}') as timestamp
|
||||
from (
|
||||
select *
|
||||
from (
|
||||
(
|
||||
SELECT DATE(ADDDATE(@startTime, INTERVAL @i:=@i+1 {input.tableType})) AS date
|
||||
FROM {table}
|
||||
HAVING @i < TIMESTAMPDIFF({input.tableType}, @startTime, ADDDATE(@endTime, INTERVAL -1 DAY))
|
||||
) d,
|
||||
(
|
||||
select device_number
|
||||
from {table}
|
||||
where start_timestamp >= @startTime and end_timestamp < @endTime and point = 'KWH' {buildingSql}
|
||||
{sqlWhere}
|
||||
group by device_number
|
||||
) dn
|
||||
)
|
||||
) fd
|
||||
left join (
|
||||
select device_number, {sqlAvgRawData}
|
||||
from {table}
|
||||
where start_timestamp >= @startTime and end_timestamp < @endTime and point = 'KWH' {buildingSql}
|
||||
{sqlWhere} {sqlGroup}
|
||||
) aemm on aemm.start_timestamp >= {aemmStaDate} and aemm.end_timestamp < {aemmEndDate} and aemm.device_number = fd.device_number
|
||||
where DATE_FORMAT(fd.date, '%Y-%m') = '{searchTime}' or DATE_FORMAT(fd.date, '%Y-%m') = '{lastMonth}' or DATE_FORMAT(fd.date, '%Y-%m') = '{lastYear}'
|
||||
order by fd.device_number, fd.date";
|
||||
Logger.LogInformation("SQL = " + sql + " startTime=" + startTime + " endTime=" + endTime + " building=" + input.building_tag + " floor_tag = " + input.floor_tag);
|
||||
var rawData = await backendRepository.GetAllAsync<HydroMeterRawDataOutput>(sql,
|
||||
new { startTime = startTime, endtime = endTime, building_tag = input.building_tag, dateFormat = dateFormat });
|
||||
|
||||
List<HydroMeterOutput> Result = new List<HydroMeterOutput>();
|
||||
if (tag_quantity == "5")
|
||||
{
|
||||
Result = 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], device_number = x.device_number })
|
||||
.Select(x => new HydroMeterOutput { building_tag = x.Key.building_tag, floor_tag = x.Key.floor_tag, device_serial_tag = x.Key.device_serial_tag, device_number = x.Key.device_number })
|
||||
.ToList();
|
||||
}
|
||||
else
|
||||
{
|
||||
Result = rawData
|
||||
.GroupBy(x => new { building_tag = x.device_number.Split("_")[1], floor_tag = x.device_number.Split("_")[4], device_master = x.device_number.Split("_")[5], device_serial_tag = x.device_number.Split("_")[7], device_number = x.device_number })
|
||||
.Select(x => new HydroMeterOutput { building_tag = x.Key.building_tag, floor_tag = x.Key.floor_tag, device_serial_tag = x.Key.device_serial_tag, device_master = x.Key.device_master, device_number = x.Key.device_number })
|
||||
.ToList();
|
||||
}
|
||||
|
||||
foreach (var l in Result)
|
||||
{
|
||||
l.rawData = new List<HydroMeterRawDataOutput>();
|
||||
l.device_full_name = await backendRepository.GetOneAsync<string>($"select full_name from device where device_number = '{l.device_number}'");
|
||||
if (tag_quantity == "5")
|
||||
{
|
||||
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)
|
||||
);
|
||||
}
|
||||
else
|
||||
{
|
||||
l.rawData.AddRange(
|
||||
rawData.Where(x => x.device_number.Split("_")[1] == l.building_tag && x.device_number.Split("_")[4] == l.floor_tag && x.device_number.Split("_")[5] == l.device_master && x.device_number.Split("_")[7] == l.device_serial_tag)
|
||||
);
|
||||
}
|
||||
l.building_name = await backendRepository.GetOneAsync<string>("select full_name from building where building_tag = @building_tag and deleted = 0",
|
||||
new { building_tag = l.building_tag });
|
||||
l.total = l.rawData.Where(x => x.avg_rawdata != "NaN").Sum(x => decimal.Parse(x.avg_rawdata ?? "0", System.Globalization.NumberStyles.Float)).ToString();
|
||||
l.price = input.price.HasValue
|
||||
? (Math.Round(input.price.Value, 2)).ToString()
|
||||
: Math.Round((await backendRepository.GetOneAsync<decimal>("select system_value from variable where system_type = 'ElectricPrice' and deleted = 0")), 2).ToString();
|
||||
l.total_price = Math.Round((Decimal.Parse(l.total) * Decimal.Parse(l.price)), 2).ToString();
|
||||
}
|
||||
|
||||
apiResult.Code = "0000";
|
||||
apiResult.Data = Result;
|
||||
}
|
||||
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;
|
||||
}
|
||||
|
||||
public static int GetDayInMonth(string yearMonth)
|
||||
{
|
||||
List<string> datesList = new List<string>();
|
||||
|
||||
Loading…
Reference in New Issue
Block a user