2022-10-14 16:08:54 +08:00
using FrontendWebApi.Models ;
using Microsoft.AspNetCore.Mvc ;
using Microsoft.Extensions.Logging ;
using Microsoft.Extensions.Options ;
using Newtonsoft.Json ;
using Newtonsoft.Json.Linq ;
using Repository.BackendRepository.Interface ;
using Repository.FrontendRepository.Interface ;
using System ;
using System.Collections.Generic ;
using System.IO ;
using System.Linq ;
using System.Net ;
using System.Text ;
using System.Threading.Tasks ;
using System.Xml ;
2022-11-14 12:14:11 +08:00
using NPOI.XSSF.UserModel ;
using NPOI.SS.UserModel ;
2022-11-25 12:32:32 +08:00
using Microsoft.AspNetCore.Mvc.Infrastructure ;
using Microsoft.AspNetCore.StaticFiles ;
using NPOI.HPSF ;
2023-05-16 18:29:28 +08:00
using Google.Protobuf.WellKnownTypes ;
2022-10-14 16:08:54 +08:00
namespace FrontendWebApi.ApiControllers
{
public class HistoryController : MyBaseApiController < EmergencyRecordController >
{
private readonly IBackendRepository backendRepository ;
private readonly IFrontendRepository frontendRepository ;
2023-05-15 12:59:01 +08:00
private readonly IBackgroundServiceMsSqlRepository backgroundServiceMsSqlRepository ;
2022-10-14 16:08:54 +08:00
public HistoryController
(
IBackendRepository backendRepository ,
2023-05-15 12:59:01 +08:00
IFrontendRepository frontendRepository ,
IBackgroundServiceMsSqlRepository backgroundServiceMsSqlRepository
2022-10-14 16:08:54 +08:00
)
{
this . backendRepository = backendRepository ;
this . frontendRepository = frontendRepository ;
2023-05-15 12:59:01 +08:00
this . backgroundServiceMsSqlRepository = backgroundServiceMsSqlRepository ;
2022-10-14 16:08:54 +08:00
}
2022-11-14 12:14:11 +08:00
/// <summary>
/// 匯出excel
/// </summary>
/// <param name="lhe"></param>
/// <returns></returns>
2022-11-25 12:32:32 +08:00
public ActionResult < ApiResult < string > > OpeExportExcel ( [ FromBody ] List < HistoryExport > lhe )
2022-11-14 12:14:11 +08:00
{
2022-11-25 12:32:32 +08:00
ApiResult < string > apiResult = new ApiResult < string > ( ) ;
2022-11-14 12:14:11 +08:00
2022-11-25 12:32:32 +08:00
if ( lhe = = null )
{
apiResult . Code = "0001" ;
apiResult . Msg = "沒有資料匯入" ;
return apiResult ;
}
2022-11-14 12:14:11 +08:00
2022-11-25 12:32:32 +08:00
try
2022-11-14 12:14:11 +08:00
{
2022-11-28 16:51:11 +08:00
var fileDateName = lhe . FirstOrDefault ( ) . dateType = = "month" ? lhe . FirstOrDefault ( ) . starttime . ToString ( "yyyy-MM" ) : lhe . FirstOrDefault ( ) . endtime = = null ? lhe . FirstOrDefault ( ) . starttime . ToString ( "yyyy-MM-dd" ) : lhe . FirstOrDefault ( ) . starttime . ToString ( "yyyy-MM-dd" ) + "_" + ( ( DateTime ) lhe . FirstOrDefault ( ) . endtime ) . ToString ( "yyyy-MM-dd" ) ;
2022-11-30 18:11:37 +08:00
var fileName = "歷史資料_" + fileDateName + ".xlsx" ;
2022-11-25 12:32:32 +08:00
var filePath = Path . Combine ( Directory . GetCurrentDirectory ( ) , "wwwroot" , "excel" , "history" ) ;
if ( ! System . IO . Directory . Exists ( filePath ) )
System . IO . Directory . CreateDirectory ( filePath ) ;
using ( var fs = new FileStream ( Path . Combine ( filePath , fileName ) , FileMode . Create , FileAccess . Write ) )
2022-11-14 12:14:11 +08:00
{
2022-11-25 12:32:32 +08:00
IWorkbook 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
ISheet sheet = workbook . CreateSheet ( "歷史資料" ) ;
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 ) ;
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 ;
#endregion
if ( lhe . Count > 0 )
2022-11-14 12:14:11 +08:00
{
2022-11-25 12:32:32 +08:00
foreach ( var he in lhe )
2022-11-14 12:14:11 +08:00
{
2022-11-25 12:32:32 +08:00
RowPosition + = 1 ;
row = sheet . CreateRow ( RowPosition ) ;
for ( var i = 0 ; i < 3 ; i + + )
{
cell = row . CreateCell ( i ) ;
if ( i = = 0 )
{
2022-11-30 18:11:37 +08:00
cell . SetCellValue ( he . type ) ;
2022-11-25 12:32:32 +08:00
}
if ( i = = 1 )
{
2022-11-30 18:11:37 +08:00
cell . SetCellValue ( he . deviceName ) ;
2022-11-25 12:32:32 +08:00
}
if ( i = = 2 )
2022-11-30 18:11:37 +08:00
{
cell . SetCellValue ( he . value ) ;
}
if ( i = = 3 )
2022-11-25 12:32:32 +08:00
{
cell . SetCellValue ( he . timestamp . ToString ( "yyyy-MM-dd HH:mm" ) + ":00" ) ; //
}
2022-11-14 12:14:11 +08:00
2022-11-25 12:32:32 +08:00
cell . CellStyle = style12 ;
}
}
2022-11-14 12:14:11 +08:00
}
2022-11-25 12:32:32 +08:00
workbook . Write ( fs ) ;
2022-11-14 12:14:11 +08:00
}
2022-11-25 12:32:32 +08:00
apiResult . Code = "0000" ;
2022-12-01 09:17:55 +08:00
apiResult . Data = "history/" + fileName ;
2022-11-14 12:14:11 +08:00
}
2022-11-25 12:32:32 +08:00
catch ( Exception exception )
2022-11-14 12:14:11 +08:00
{
2022-11-25 12:32:32 +08:00
apiResult . Code = "9999" ;
apiResult . Msg = "系統內部錯誤，請聯絡管理者。" ;
Logger . LogError ( "【" + controllerName + "/" + actionName + "】" + exception . Message ) ;
return Ok ( apiResult ) ;
}
return Ok ( apiResult ) ;
2022-11-14 12:14:11 +08:00
}
2022-10-14 16:08:54 +08:00
/// <summary>
/// 即時趨勢條件過濾條件面板
/// </summary>
/// <param name="account"></param>
/// <returns></returns>
[HttpPost]
[Route("api/History/GetMainSub")]
2022-11-22 11:02:51 +08:00
public async Task < ActionResult < ApiResult < History_MainSubBuildFloor > > > GetMainSub ( [ FromBody ] HistoryFind hf )
2022-10-14 16:08:54 +08:00
{
ApiResult < History_MainSubBuildFloor > apiResult = new ApiResult < History_MainSubBuildFloor > ( jwt_str ) ;
if ( ! jwtlife )
{
apiResult . Code = "5000" ;
return BadRequest ( apiResult ) ;
}
2022-11-22 11:02:51 +08:00
else if ( string . IsNullOrEmpty ( hf . building_tag ) )
{
apiResult . Code = "0002" ;
apiResult . Msg = "必須選擇東別" ;
return apiResult ;
}
2022-10-14 16:08:54 +08:00
try
{
var dbsub = await frontendRepository . GetAllAsync < HistoryDBMainSub > (
2022-11-23 15:59:19 +08:00
@ $ "select distinct v1.system_key main_name, v1.system_value main_system_tag, v2.system_key sub_name, v2.system_value sub_system_tag, v1.system_priority, v2.system_priority,
2023-02-09 16:10:16 +08:00
d . device_number , d . full_name as device_full_name , d . device_serial_tag , di . is_show_history device_item_is_show_hsitory
2022-11-15 11:25:25 +08:00
from role_auth a
2022-10-14 16:08:54 +08:00
join auth_page b on a . AuthCode = b . AuthCode
join userinfo c on c . role_guid = a . role_guid
2022-11-15 11:25:25 +08:00
join variable v2 on b . ShowView = v2 . id and v2 . system_type = @sub_system_type
join variable v1 on v1 . id = v2 . system_parent_id and v1 . system_type = @main_system_type
2023-02-07 11:55:52 +08:00
join device d on v1 . system_value = d . device_system_tag and v2 . system_value = d . device_name_tag and d . deleted = 0 and d . visible = 1
2023-02-09 16:10:16 +08:00
join device_item di on d . device_system_tag = di . device_system_tag and d . device_name_tag = di . device_name_tag
2023-05-02 10:05:49 +08:00
and di . is_link = 1 and di . is_show_history = 1
2022-11-14 12:14:11 +08:00
where c . account = @account
2022-11-15 11:25:25 +08:00
order by v1 . system_priority , v2 . system_priority ", new { @account = myUser.account, @sub_system_type = sub_system_type, @main_system_type = main_system_type });
2022-10-14 16:08:54 +08:00
var dbbuilding = await frontendRepository . GetAllAsync < History_Build > (
2023-05-12 10:55:23 +08:00
@ $ "select distinct d.building_tag,d.full_name,d.priority from role_auth a
2022-10-14 16:08:54 +08:00
join auth_page b on a . AuthCode = b . AuthCode
join userinfo c on c . role_guid = a . role_guid
2022-11-15 11:25:25 +08:00
join building d on d . building_tag = b . building_tag
2022-11-22 11:02:51 +08:00
where c . account = @account and d . building_tag = @building_tag
2022-10-14 16:08:54 +08:00
order by d . priority
2022-11-22 11:02:51 +08:00
", new { @account = myUser.account, @building_tag = hf.building_tag });
2022-11-14 12:14:11 +08:00
var mains = dbsub . GroupBy ( a = > a . main_system_tag ) . ToList ( ) ;
2022-10-14 16:08:54 +08:00
apiResult . Data = new History_MainSubBuildFloor ( ) ;
apiResult . Data . history_Main_Systems = new List < History_Main_system > ( ) ;
foreach ( var main in mains )
{
History_Main_system history_Main_System = new History_Main_system ( ) ;
2022-11-14 12:14:11 +08:00
history_Main_System . main_system_tag = main . Select ( a = > a . main_system_tag ) . FirstOrDefault ( ) ;
2022-10-14 16:08:54 +08:00
history_Main_System . full_name = main . Select ( a = > a . main_name ) . FirstOrDefault ( ) ;
2022-11-23 15:59:19 +08:00
var subs = dbsub . Where ( x = > x . main_system_tag = = main . Select ( m = > m . main_system_tag ) . FirstOrDefault ( ) ) . GroupBy ( x = > x . sub_system_tag ) . ToList ( ) ;
history_Main_System . History_Sub_systems = subs . Count > 0 ? new List < History_Sub_system > ( ) : null ;
2022-10-14 16:08:54 +08:00
foreach ( var sub in subs )
{
History_Sub_system history_Sub_System = new History_Sub_system ( ) ;
2022-11-23 15:59:19 +08:00
history_Sub_System . full_name = sub . Select ( x = > x . sub_name ) . FirstOrDefault ( ) ;
history_Sub_System . sub_system_tag = sub . Select ( x = > x . sub_system_tag ) . FirstOrDefault ( ) ;
2023-02-09 16:10:16 +08:00
history_Sub_System . is_show_history = sub . Select ( x = > x . device_item_is_show_hsitory ) . FirstOrDefault ( ) ;
2022-11-23 15:59:19 +08:00
2023-02-18 18:31:48 +08:00
var devices = dbsub . Where ( x = > x . main_system_tag = = main . Select ( m = > m . main_system_tag ) . FirstOrDefault ( ) & & x . sub_system_tag = = sub . Select ( x = > x . sub_system_tag ) . FirstOrDefault ( ) & & x . device_number ! = null ) . OrderBy ( x = > x . device_full_name . Length ) . ThenBy ( x = > x . device_full_name ) . ToList ( ) ;
2022-11-23 15:59:19 +08:00
history_Sub_System . device = devices . Count > 0 ? new List < Device > ( ) : null ;
foreach ( var d in devices )
{
Device device = new Device ( ) ;
device . device_number = d . device_number ;
device . device_serial_tag = d . device_serial_tag ;
device . full_name = d . device_full_name ;
history_Sub_System . device . Add ( device ) ;
}
2023-02-09 16:10:16 +08:00
if ( history_Sub_System . is_show_history = = 1 )
{
history_Main_System . History_Sub_systems . Add ( history_Sub_System ) ;
}
2022-10-14 16:08:54 +08:00
}
2023-02-18 18:31:48 +08:00
apiResult . Data . history_Main_Systems . Add ( history_Main_System ) ;
2022-10-14 16:08:54 +08:00
}
apiResult . Data . history_Builds = dbbuilding ;
apiResult . Code = "0000" ;
2023-02-18 18:31:48 +08:00
2022-11-23 15:59:19 +08:00
}
catch ( Exception exception )
{
apiResult . Code = "9999" ;
apiResult . Msg = "系統內部錯誤，請聯絡管理者。" ;
Logger . LogError ( "【" + controllerName + "/" + actionName + "】" + exception . Message ) ;
return Ok ( apiResult ) ;
}
return Ok ( apiResult ) ;
}
/// <summary>
/// 即時趨勢條件過濾條件面板
/// </summary>
/// <param name="account"></param>
/// <returns></returns>
[HttpPost]
[Route("api/History/GetDevPoi")]
public async Task < ActionResult < ApiResult < List < DeviceItem > > > > GetDevPoi ( [ FromBody ] HistoryFind hf )
{
ApiResult < List < DeviceItem > > apiResult = new ApiResult < List < DeviceItem > > ( jwt_str ) ;
if ( ! jwtlife )
{
apiResult . Code = "5000" ;
return BadRequest ( apiResult ) ;
}
else if ( string . IsNullOrEmpty ( hf . device_number ) )
{
apiResult . Code = "0002" ;
apiResult . Msg = "必須選擇設備" ;
return apiResult ;
}
2022-10-14 16:08:54 +08:00
2022-11-23 15:59:19 +08:00
try
{
List < DeviceItem > deviceItems = new List < DeviceItem > ( ) ;
var main_system_value = hf . device_number . Split ( '_' ) [ 2 ] ;
var sub_system_value = hf . device_number . Split ( '_' ) [ 3 ] ;
2022-12-30 16:29:42 +08:00
var sqlString = $@"select * from device_item where deleted = 0 and device_system_tag = @main_system_value and device_name_tag = @sub_system_value and is_show_history = 1" ;
2022-11-23 15:59:19 +08:00
deviceItems = await frontendRepository . GetAllAsync < DeviceItem > ( sqlString , new { @main_system_value = main_system_value , @sub_system_value = sub_system_value } ) ;
apiResult . Data = deviceItems ;
apiResult . Code = "0000" ;
2022-10-14 16:08:54 +08:00
}
catch ( Exception exception )
{
apiResult . Code = "9999" ;
apiResult . Msg = "系統內部錯誤，請聯絡管理者。" ;
Logger . LogError ( "【" + controllerName + "/" + actionName + "】" + exception . Message ) ;
return Ok ( apiResult ) ;
}
return Ok ( apiResult ) ;
}
/// <summary>
/// 依據過濾條件取得設備列表
/// </summary>
/// <param name="postDevice"></param>
/// <returns></returns>
[HttpPost]
[Route("api/History/GetDevice")]
public async Task < ActionResult < ApiResult < List < History_GetDevice > > > > GetDevice ( History_PostDevice postDevice )
{
ApiResult < List < History_GetDevice > > apiResult = new ApiResult < List < History_GetDevice > > ( jwt_str ) ;
if ( ! jwtlife )
{
apiResult . Code = "5000" ;
return BadRequest ( apiResult ) ;
}
try
{
List < string > wheres = new List < string > ( ) ;
wheres . Add ( "d.deleted = 0" ) ;
if ( postDevice . SelectBuildings ! = null & & postDevice . SelectBuildings . Count ( ) > 0 )
{
2023-05-12 10:55:23 +08:00
wheres . Add ( "d.device_building_tag in @builds" ) ;
2022-10-14 16:08:54 +08:00
}
if ( postDevice . SelectFloors ! = null & & postDevice . SelectFloors . Count ( ) > 0 )
{
2023-05-16 12:15:38 +08:00
wheres . Add ( "d.device_floor_tag in @floor_tag" ) ;
2022-10-14 16:08:54 +08:00
}
if ( postDevice . SelectSub ! = null & & postDevice . SelectSub . Count ( ) > 0 )
{
2023-05-10 16:34:09 +08:00
wheres . Add ( "d.device_name_tag in @syss" ) ;
2022-10-14 16:08:54 +08:00
}
if ( ! string . IsNullOrEmpty ( postDevice . Device_name ) )
{
wheres . Add ( "d.full_name LIKE CONCAT('%', @device_name, '%')" ) ;
}
var wheres_str = string . Join ( " AND " , wheres ) ;
var sql = $ @ "SELECT
a . device_guid ,
b . full_name building_name ,
2023-05-10 16:34:09 +08:00
v1 . system_key main_name ,
v2 . system_key sub_name ,
2022-10-14 16:08:54 +08:00
a . full_name device_name ,
a . device_number
from ( SELECT *
FROM device d
WHERE { wheres_str } ) a
2023-05-12 10:55:23 +08:00
join building b on b . building_tag = a . device_building_tag
2023-05-10 16:34:09 +08:00
join variable v1 on v1 . system_value = a . device_system_tag and v1 . deleted = 0 and v1 . system_type = ' device_system_category_layer2 '
2023-05-12 10:55:23 +08:00
join variable v2 on v2 . system_value = a . device_name_tag and v2 . deleted = 0 and v2 . system_type = ' device_system_category_layer3 '
2023-05-10 16:34:09 +08:00
order by b . priority , v1 . system_priority , v2 . system_priority , a . priority ";
2022-10-14 16:08:54 +08:00
2023-05-16 12:15:38 +08:00
var dbDevice = await backendRepository . GetAllAsync < History_GetDevice > ( sql , new { builds = postDevice . SelectBuildings , floor_tag = postDevice . SelectFloors , syss = postDevice . SelectSub , device_name = postDevice . Device_name } ) ;
2022-10-14 16:08:54 +08:00
apiResult . Data = dbDevice ;
apiResult . Code = "0000" ;
}
catch ( Exception exception )
{
apiResult . Code = "9999" ;
apiResult . Msg = "系統內部錯誤，請聯絡管理者。" ;
Logger . LogError ( "【" + controllerName + "/" + actionName + "】" + exception . Message ) ;
}
return Ok ( apiResult ) ;
}
/// <summary>
/// 依據選得的設備，查看所有設備點位
/// </summary>
/// <param name="postDevice"></param>
/// <returns></returns>
[HttpPost]
[Route("api/History/LookRealTime")]
public async Task < ActionResult < ApiResult < List < History_PostItem > > > > LookRealTime ( itemlist postDevice )
{
ApiResult < List < History_PostItem > > apiResult = new ApiResult < List < History_PostItem > > ( jwt_str ) ;
if ( ! jwtlife )
{
apiResult . Code = "5000" ;
return BadRequest ( apiResult ) ;
}
try
{
var dbDevice = await backendRepository . GetAllAsync < History_PostItem > (
@ $ "select c.full_name building_name,b.device_number,b.full_name device_name,a.full_name item_name,a.points,a.unit
from device_item a
2023-05-16 15:18:10 +08:00
join device b on a . device_system_tag = b . device_system_tag
and a . device_building_tag COLLATE utf8mb4_unicode_ci = b . device_building_tag
and a . device_name_tag COLLATE utf8mb4_unicode_ci = b . device_name_tag
2023-05-12 10:55:23 +08:00
join building c on c . building_tag = b . device_building_tag
2023-05-10 16:34:09 +08:00
join variable v1 on v1 . system_value = b . device_system_tag and v1 . deleted = 0 and v1 . system_type = ' device_system_category_layer2 '
2023-05-12 10:55:23 +08:00
join variable v2 on v2 . system_value = b . device_name_tag and v2 . deleted = 0 and v2 . system_type = ' device_system_category_layer3 '
2023-05-10 16:34:09 +08:00
where a . deleted = 0 and b . deleted = 0 and v2 . deleted = 0 and v1 . deleted = 0
2022-10-14 16:08:54 +08:00
and a . unit is not null and b . device_number in @Device_number
2023-05-16 15:18:10 +08:00
order by c . priority , b . priority ; "
2022-10-14 16:08:54 +08:00
, new { Device_number = postDevice . select_data . Select ( a = > a . device_number ) . ToList ( ) }
) ;
apiResult . Data = dbDevice ;
apiResult . Code = "0000" ;
}
catch ( Exception exception )
{
apiResult . Code = "9999" ;
apiResult . Msg = "系統內部錯誤，請聯絡管理者。" ;
Logger . LogError ( "【" + controllerName + "/" + actionName + "】" + exception . Message ) ;
}
return Ok ( apiResult ) ;
}
/// <summary>
/// 取得即時趨勢常用組合
/// </summary>
/// <param name="postDevice"></param>
/// <returns></returns>
[HttpPost]
[Route("api/History/RealTimeCombination")]
public async Task < ActionResult < ApiResult < List < RealTimeCombination > > > > GetRealTimeCombination ( PostRealTimeCombination post )
{
ApiResult < List < RealTimeCombination > > apiResult = new ApiResult < List < RealTimeCombination > > ( jwt_str ) ;
if ( ! jwtlife )
{
apiResult . Code = "5000" ;
return BadRequest ( apiResult ) ;
}
try
{
var sql = $ @ "
SELECT
2023-05-10 15:14:46 +08:00
rc . combination_guid ,
rc . full_name AS combination_full_name ,
rcd . device_guid ,
d . device_number ,
d . full_name AS Device_full_name ,
b . full_name AS Building_full_name ,
v1 . system_key AS Main_system_full_name ,
v2 . system_key AS Sub_system_full_name
FROM realtime_combination_detail rcd
LEFT JOIN
( SELECT
rc . *
FROM realtime_combination rc
WHERE building_tag = @building_tag
AND userinfo_guid = @userinfo_guid
) rc ON rcd . combination_guid = rc . combination_guid
JOIN device d ON d . deleted = 0 AND d . device_guid = rcd . device_guid
JOIN building b ON b . deleted = 0 AND b . building_tag = d . device_building_tag
JOIN variable v1 ON v1 . deleted = 0 AND v1 . system_value = d . device_system_tag and v1 . system_type = ' device_system_category_layer2 '
JOIN variable v2 ON v2 . deleted = 0 AND v2 . system_value = d . device_name_tag and v2 . system_type = ' device_system_category_layer3 '
WHERE rc . deleted = 0 ";
var rawDatas = await frontendRepository . GetAllAsync < RealTimeCombinationRawData > ( sql , new { building_tag = post . building_tag , userinfo_guid = myUser . userinfo_guid } ) ;
2022-10-14 16:08:54 +08:00
var rawDatas_groups = rawDatas . GroupBy ( x = > x . Combination_guid ) . ToList ( ) ;
List < RealTimeCombination > realTimeCombinations = new List < RealTimeCombination > ( ) ;
foreach ( var rawDatas_group in rawDatas_groups )
{
RealTimeCombination realTimeCombination = new RealTimeCombination ( ) ;
realTimeCombination . Combination_guid = rawDatas_group . Key ;
realTimeCombination . Combination_full_name = rawDatas_group . First ( ) . Combination_full_name ;
realTimeCombination . Details = new List < RealTimeCombinationDetail > ( ) ;
foreach ( var rawData in rawDatas_group )
{
RealTimeCombinationDetail realTimeCombinationDetail = new RealTimeCombinationDetail ( ) ;
realTimeCombinationDetail . Combination_guid = rawData . Combination_guid ;
realTimeCombinationDetail . Device_guid = rawData . Device_guid ;
realTimeCombinationDetail . Device_number = rawData . Device_number ;
realTimeCombinationDetail . Device_full_name = rawData . Device_full_name ;
realTimeCombinationDetail . Building_full_name = rawData . Building_full_name ;
realTimeCombinationDetail . Main_system_full_name = rawData . Main_system_full_name ;
realTimeCombinationDetail . Sub_system_full_name = rawData . Sub_system_full_name ;
realTimeCombination . Details . Add ( realTimeCombinationDetail ) ;
}
realTimeCombinations . Add ( realTimeCombination ) ;
}
apiResult . Data = realTimeCombinations ;
apiResult . Code = "0000" ;
}
catch ( Exception exception )
{
apiResult . Code = "9999" ;
apiResult . Msg = "系統內部錯誤，請聯絡管理者。" ;
Logger . LogError ( "【" + controllerName + "/" + actionName + "】" + exception . Message ) ;
}
return Ok ( apiResult ) ;
}
/// <summary>
/// 新增常用組合(包含覆蓋、另存新檔)
/// </summary>
/// <param name="post"></param>
/// <returns></returns>
[HttpPost]
[Route("api/History/SaveRealTimeCombination")]
public async Task < ActionResult < ApiResult < string > > > SaveRealTimeCombination ( PostSaveRealTimeCombination post )
{
ApiResult < string > apiResult = new ApiResult < string > ( jwt_str ) ;
if ( ! jwtlife )
{
apiResult . Code = "5000" ;
return BadRequest ( apiResult ) ;
}
try
{
if ( post . Save_type = = 1 )
{ //另存新檔
//產生一組GUID
var guid = Guid . NewGuid ( ) ; //常用組合GUID
Dictionary < string , object > combination = new Dictionary < string , object > ( ) ;
combination = new Dictionary < string , object > ( )
{
{ "@combination_guid" , guid } ,
2023-05-10 15:14:46 +08:00
{ "@building_tag" , post . Building_tag } ,
2022-10-14 16:08:54 +08:00
{ "@userinfo_guid" , myUser . userinfo_guid } ,
{ "@full_name" , post . Full_name } ,
{ "@created_by" , myUser . userinfo_guid }
} ;
await frontendRepository . AddOneByCustomTable ( combination , "realtime_combination" ) ;
List < Dictionary < string , object > > detailDics = new List < Dictionary < string , object > > ( ) ;
foreach ( var detail in post . Details )
{
Dictionary < string , object > detailDic = new Dictionary < string , object > ( )
{
{ "@combination_guid" , guid } ,
{ "@device_guid" , detail . Device_guid } ,
{ "@created_by" , myUser . userinfo_guid }
} ;
detailDics . Add ( detailDic ) ;
}
await frontendRepository . AddMutiByCustomTable ( detailDics , "realtime_combination_detail" ) ;
}
else
{ //覆蓋
var sWhere = $@"deleted = 0 AND combination_guid = @combination_guid" ;
var realTimeCombination = await frontendRepository . GetOneAsync < RealTimeCombination > ( "realtime_combination" , sWhere , new { combination_guid = post . Combination_guid } ) ;
if ( realTimeCombination = = null )
{
apiResult . Code = "9996" ;
apiResult . Msg = "查無該常用組合" ;
return Ok ( apiResult ) ;
}
else
{
//刪除該組合的所有設備
await frontendRepository . PurgeOneAsync ( realTimeCombination . Combination_guid , "realtime_combination_detail" , "combination_guid" ) ;
//重新新增
List < Dictionary < string , object > > detailDics = new List < Dictionary < string , object > > ( ) ;
foreach ( var detail in post . Details )
{
Dictionary < string , object > detailDic = new Dictionary < string , object > ( )
{
{ "@combination_guid" , realTimeCombination . Combination_guid } ,
{ "@device_guid" , detail . Device_guid } ,
{ "@created_by" , myUser . userinfo_guid }
} ;
detailDics . Add ( detailDic ) ;
}
await frontendRepository . AddMutiByCustomTable ( detailDics , "realtime_combination_detail" ) ;
}
}
apiResult . Code = "0000" ;
}
catch ( Exception exception )
{
apiResult . Code = "9999" ;
apiResult . Msg = "系統內部錯誤，請聯絡管理者。" ;
Logger . LogError ( "【" + controllerName + "/" + actionName + "】" + exception . Message ) ;
}
return Ok ( apiResult ) ;
}
/// <summary>
/// 修改常用組合名稱
/// </summary>
/// <param name="post"></param>
/// <returns></returns>
[HttpPost]
[Route("api/History/EditRealTimeCombination")]
public async Task < ActionResult < ApiResult < string > > > EditRealTimeCombination ( PostEditRealTimeCombination post )
{
ApiResult < string > apiResult = new ApiResult < string > ( jwt_str ) ;
if ( ! jwtlife )
{
apiResult . Code = "5000" ;
return BadRequest ( apiResult ) ;
}
try
{
var sWhere = $@"deleted = 0 AND combination_guid = @combination_guid" ;
var realTimeCombination = await frontendRepository . GetOneAsync < RealTimeCombination > ( "realtime_combination" , sWhere , new { combination_guid = post . Combination_guid } ) ;
if ( realTimeCombination = = null )
{
apiResult . Code = "9996" ;
}
else
{
Dictionary < string , object > realTimeCombinationDic = new Dictionary < string , object > ( )
{
{ "@full_name" , post . Full_name } ,
{ "@updated_by" , myUser . userinfo_guid } ,
{ "@updated_at" , DateTime . Now . ToString ( "yyyy-MM-dd HH:mm:ss" ) }
} ;
await frontendRepository . UpdateOneByCustomTable ( realTimeCombinationDic , "realtime_combination" , "combination_guid = '" + post . Combination_guid + "'" ) ;
}
apiResult . Code = "0000" ;
}
catch ( Exception exception )
{
apiResult . Code = "9999" ;
apiResult . Msg = "系統內部錯誤，請聯絡管理者。" ;
Logger . LogError ( "【" + controllerName + "/" + actionName + "】" + exception . Message ) ;
}
return Ok ( apiResult ) ;
}
/// <summary>
/// 刪除常用組合名稱
/// </summary>
/// <param name="post"></param>
/// <returns></returns>
[HttpPost]
[Route("api/History/DeleteRealTimeCombination")]
public async Task < ActionResult < ApiResult < string > > > DeleteRealTimeCombination ( string guid )
{
ApiResult < string > apiResult = new ApiResult < string > ( jwt_str ) ;
if ( ! jwtlife )
{
apiResult . Code = "5000" ;
return BadRequest ( apiResult ) ;
}
try
{
var sWhere = $@"deleted = 0 AND combination_guid = @combination_guid" ;
var realTimeCombination = await frontendRepository . GetOneAsync < RealTimeCombination > ( "realtime_combination" , sWhere , new { combination_guid = guid } ) ;
if ( realTimeCombination = = null )
{
apiResult . Code = "9996" ;
}
else
{
await frontendRepository . DeleteOne ( guid , "realtime_combination" , "combination_guid" ) ;
}
apiResult . Code = "0000" ;
}
catch ( Exception exception )
{
apiResult . Code = "9999" ;
apiResult . Msg = "系統內部錯誤，請聯絡管理者。" ;
Logger . LogError ( "【" + controllerName + "/" + actionName + "】" + exception . Message ) ;
}
return Ok ( apiResult ) ;
}
//[HttpPost]
//[Route("api/History/GetHistoryMenu")]
//public async Task<ActionResult<ApiResult<List<History_Main_system>>>> GetHistoryMenu(string account)
//{
// ApiResult<List<History_Main_system>> apiResult = new ApiResult<List<History_Main_system>>(jwt_str);
// if (!jwtlife)
// {
// apiResult.Code = "5000";
// return BadRequest(apiResult);
// }
// try
// {
// var dbitems = await backendRepository.GetAllAsync<HistoryClass>(
// @$"select c.main_system_guid ,c.full_name main_name,b.sub_system_guid,b.full_name sub_name,e.building_guid,e.full_name building_name,a.device_item_guid,a.full_name item_name
// from device_item a
// join sub_system b on b.sub_system_guid = a.sub_system_guid
// join main_system c on c.main_system_guid = b.main_system_guid
// join auth_page d on d.ShowView = b.sub_system_guid
// join building e on e.building_guid = d.building_guid
// join role_auth f on f.AuthCode = d.AuthCode
// join userinfo g on g.role_guid = f.role_guid
// where g.account = '{account}' and a.deleted = 0");
// var dbdevice = await backendRepository.GetAllAsync<History_Sub_device>
// ("device", " deleted = 0");
// var main_systems = dbitems.GroupBy(a => a.main_system_guid).ToList();
// List<History_Main_system> History_Main_system = new List<History_Main_system>();
// foreach (var main_system in main_systems)
// {
// History_Main_system history_Main_System = new History_Main_system()
// {
// History_Sub_systems = new List<History_Sub_system>(),
// main_system_guid = main_system.Select(a => a.main_system_guid).FirstOrDefault(),
// full_name = main_system.Select(a => a.main_name).FirstOrDefault()
// };
// var sub_systems = main_system.GroupBy(a => a.sub_system_guid).ToList();
// foreach (var sub_system in sub_systems)
// {
// History_Sub_system history_Sub_System = new History_Sub_system()
// {
// sub_system_guid = sub_system.Select(a => a.sub_system_guid).FirstOrDefault(),
// full_name = sub_system.Select(a => a.sub_name).FirstOrDefault(),
// History_Builds = new List<History_Build>()
// };
// var builds = sub_system.GroupBy(a => a.building_guid).ToList();
// foreach (var build in builds)
// {
// History_Build history_Build = new History_Build()
// {
// building_guid = build.Select(a => a.building_guid).First(),
// full_name = build.Select(a => a.building_name).FirstOrDefault(),
// History_Devices = new List<History_Device>()
// };
// var devices = dbdevice.Where(a => a.building_guid == history_Build.building_guid & a.sub_system_guid == history_Sub_System.sub_system_guid).ToList();
// foreach (var device in devices)
// {
// History_Device history_Device = new History_Device()
// {
// device_guid = device.device_guid,
// full_name = device.full_name,
// History_Deviceitems = new List<History_Deviceitem>()
// };
// var items = build.GroupBy(a => a.device_item_guid).ToList();
// foreach (var item in items)
// {
// History_Deviceitem history_Deviceitem = new History_Deviceitem()
// {
// device_item_guid = item.Select(a => a.device_item_guid).FirstOrDefault(),
// full_name = item.Select(a => a.item_name).FirstOrDefault()
// };
// history_Device.History_Deviceitems.Add(history_Deviceitem);
// }
// history_Build.History_Devices.Add(history_Device);
// }
// history_Sub_System.History_Builds.Add(history_Build);
// }
// history_Main_System.History_Sub_systems.Add(history_Sub_System);
// }
// History_Main_system.Add(history_Main_System);
// }
// apiResult.Code = "0000";
// apiResult.Data = History_Main_system;
// }
// catch (Exception exception)
// {
// apiResult.Code = "9999";
// Logger.LogError("【" + controllerName + "/" + actionName + "】" + exception.Message);
// return Ok(apiResult);
// }
// return Ok(apiResult);
//}
/// <summary>
/// 歷史資料查詢過濾條件面板
/// </summary>
/// <param name="post"></param>
/// <returns></returns>
[HttpPost]
[Route("api/History/GetHistoryFilterPanel")]
public async Task < ActionResult < ApiResult < History_MainSubBuildFloor > > > GetHistoryFilterPanel ( PostHistoryFilterPanel post )
{
ApiResult < History_MainSubBuildFloor > apiResult = new ApiResult < History_MainSubBuildFloor > ( jwt_str ) ;
if ( ! jwtlife )
{
apiResult . Code = "5000" ;
return BadRequest ( apiResult ) ;
}
try
{
#region 取 得 區 域 樓 層
var sqlBuildingFloor = $ @ "SELECT
2023-05-10 16:34:09 +08:00
b . building_tag ,
2022-10-14 16:08:54 +08:00
b . full_name AS building_name ,
b . priority ,
f . floor_guid ,
f . full_name AS floor_name ,
f . priority
FROM building b
2023-05-10 16:34:09 +08:00
JOIN floor f ON f . deleted = 0 AND f . building_tag = b . building_tag
WHERE b . building_tag IN (
2022-10-14 16:08:54 +08:00
SELECT
2023-05-10 16:34:09 +08:00
ap . building_tag
2022-10-14 16:08:54 +08:00
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
)
ORDER BY b . priority , f . priority ";
var buildingFloorRawDatas = await frontendRepository . GetAllAsync < BuildingFloorRawData > ( sqlBuildingFloor , post ) ;
2023-05-10 16:34:09 +08:00
var buildingFloorRawDatas_GroupBy_building_guid = buildingFloorRawDatas . GroupBy ( x = > x . building_tag ) . ToList ( ) ;
2022-10-14 16:08:54 +08:00
List < History_Build > history_Builds = new List < History_Build > ( ) ;
foreach ( var buildingFloorRawData in buildingFloorRawDatas_GroupBy_building_guid )
{
List < History_Floor > history_Floors = new List < History_Floor > ( ) ;
foreach ( var floorRawData in buildingFloorRawData )
{
History_Floor history_Floor = new History_Floor ( )
{
floor_guid = floorRawData . floor_guid ,
full_name = floorRawData . floor_name ,
} ;
history_Floors . Add ( history_Floor ) ;
}
History_Build history_Build = new History_Build ( )
{
2023-05-10 16:34:09 +08:00
building_tag = buildingFloorRawData . Key ,
2022-10-14 16:08:54 +08:00
full_name = buildingFloorRawData . First ( ) . building_name ,
history_Floors = history_Floors
} ;
history_Builds . Add ( history_Build ) ;
}
#endregion
#region 取 得 系 統 大 小 類
2023-05-10 16:34:09 +08:00
var sqlMainSubSystem = $ @ "select
v1 . system_value as main_system_tag , v1 . system_key as main_name , v2 . system_value as sub_system_tag , v2 . system_key as sub_name
from variable v2
inner join variable v1 on v2 . system_parent_id = v1 . id
where v2 . deleted = 0 and
2023-05-16 12:15:38 +08:00
v2 . id in (
2023-05-10 16:34:09 +08:00
select ap . ShowView
from role_auth ra
inner join auth_page ap on ra . AuthCode = ap . AuthCode
inner join userinfo ui on ra . role_guid = ui . role_guid
where ui . account = @Account
)
order by v1 . system_priority , v2 . system_priority ; ";
2022-10-14 16:08:54 +08:00
var mainSubSystemRawDatas = await frontendRepository . GetAllAsync < HistoryDBMainSub > ( sqlMainSubSystem , post ) ;
2022-11-14 12:14:11 +08:00
var mainSubSystemRawDatas_GroupBy_main_system_guid = mainSubSystemRawDatas . GroupBy ( x = > x . main_system_tag ) . ToList ( ) ;
2022-10-14 16:08:54 +08:00
List < History_Main_system > history_Main_Systems = new List < History_Main_system > ( ) ;
foreach ( var mainSubSystemRawData in mainSubSystemRawDatas_GroupBy_main_system_guid )
{
List < History_Sub_system > history_Sub_Systems = new List < History_Sub_system > ( ) ;
foreach ( var SubSystemRawData in mainSubSystemRawData )
{
History_Sub_system history_Sub_System = new History_Sub_system ( )
{
2022-11-14 12:14:11 +08:00
sub_system_tag = SubSystemRawData . sub_system_tag ,
2022-10-14 16:08:54 +08:00
full_name = SubSystemRawData . sub_name ,
} ;
history_Sub_Systems . Add ( history_Sub_System ) ;
}
History_Main_system history_Main_System = new History_Main_system ( )
{
2022-11-14 12:14:11 +08:00
main_system_tag = mainSubSystemRawData . Key ,
2022-10-14 16:08:54 +08:00
full_name = mainSubSystemRawData . First ( ) . main_name ,
History_Sub_systems = history_Sub_Systems
} ;
history_Main_Systems . Add ( history_Main_System ) ;
}
#endregion
History_MainSubBuildFloor history_MainSubBuildFloor = new History_MainSubBuildFloor ( )
{
history_Builds = history_Builds ,
history_Main_Systems = history_Main_Systems
} ;
apiResult . Code = "0000" ;
apiResult . Data = history_MainSubBuildFloor ;
}
catch ( Exception exception )
{
apiResult . Code = "9999" ;
apiResult . Msg = "系統內部錯誤，請聯絡管理者。" ;
Logger . LogError ( "【" + controllerName + "/" + actionName + "】" + exception . Message ) ;
return Ok ( apiResult ) ;
}
return Ok ( apiResult ) ;
}
/// <summary>
/// 取得歷史資料
/// </summary>
/// <param name="post"></param>
/// <returns></returns>
[HttpPost]
[Route("api/History/GetHistoryRawData")]
public async Task < ActionResult < ApiResult < List < HistoryRawData > > > > GetHistoryRawData ( PostHistoryRawDataFilter post )
{
ApiResult < List < HistoryRawData > > apiResult = new ApiResult < List < HistoryRawData > > ( jwt_str ) ;
if ( ! jwtlife )
{
apiResult . Code = "5000" ;
return BadRequest ( apiResult ) ;
}
try
{
EDFunction ed = new EDFunction ( ) ;
var obixApiConfig = new ObixApiConfig ( ) ;
var sqlObix = $@"SELECT system_value as Value, system_key as Name FROM variable WHERE deleted = 0 AND system_type = 'obixConfig'" ;
var variable = await frontendRepository . GetAllAsync < KeyValue > ( sqlObix ) ;
obixApiConfig . ApiBase = variable . Where ( x = > x . Name = = "ApiBase" ) . Select ( x = > x . Value ) . FirstOrDefault ( ) ;
obixApiConfig . UserName = ed . AESDecrypt ( variable . Where ( x = > x . Name = = "UserName" ) . Select ( x = > x . Value ) . FirstOrDefault ( ) ) ;
obixApiConfig . Password = ed . AESDecrypt ( variable . Where ( x = > x . Name = = "Password" ) . Select ( x = > x . Value ) . FirstOrDefault ( ) ) ;
String encoded = System . Convert . ToBase64String ( System . Text . Encoding . GetEncoding ( "ISO-8859-1" ) . GetBytes ( obixApiConfig . UserName + ":" + obixApiConfig . Password ) ) ;
//找出被選擇的設備編號
var device_numbers = post . HistoryItems . Select ( x = > x . Device_number_point . Split ( ":" ) [ 0 ] ) . Distinct ( ) . ToList ( ) ;
//依據被選擇的設備找出相對應資料
2023-05-10 16:34:09 +08:00
var sqlDeviceItemInfo = $ @ "select
2023-05-16 14:43:47 +08:00
b . full_name as building_name ,
v1 . system_key as Main_system_name ,
v2 . system_key as Sub_system_name ,
temp . device_number ,
temp . device_name ,
temp . full_name as item_name ,
temp . points ,
temp . unit
from (
select
di . * ,
d . device_number ,
d . full_name as device_name ,
d . priority
from device_item di
2023-05-16 18:29:28 +08:00
inner join device d on di . device_building_tag COLLATE utf8mb4_unicode_ci = d . device_building_tag
and di . device_system_tag COLLATE utf8mb4_unicode_ci = d . device_system_tag
and di . device_name_tag COLLATE utf8mb4_unicode_ci = d . device_name_tag
and d . deleted = 0
2023-05-16 14:43:47 +08:00
where di . deleted = 0 and di . unit is not null and d . device_number IN @Device_number
) temp
inner join building b on temp . device_building_tag COLLATE utf8mb4_unicode_ci = b . building_tag and b . deleted = 0
inner join variable v1 on temp . device_system_tag COLLATE utf8mb4_unicode_ci = v1 . system_value and v1 . deleted = 0 and v1 . system_type = ' device_system_category_layer2 '
inner join variable v2 on temp . device_name_tag COLLATE utf8mb4_unicode_ci = v2 . system_value and v2 . deleted = 0 and v2 . system_type = ' device_system_category_layer3 '
order by b . priority , v1 . system_priority , v2 . system_priority , temp . priority ; ";
2022-10-14 16:08:54 +08:00
var device_item_infos = await frontendRepository . GetAllAsync < DeviceItemInfo > ( sqlDeviceItemInfo , new { Device_number = device_numbers } ) ;
//轉換日期格式
2023-05-16 18:33:34 +08:00
var start = string . Format ( "{0}T00:00:00.000+08:00" , post . Start_timestamp ) ;
var end = string . Format ( "{0}T23:59:59.000+08:00" , post . End_timestamp ) ;
2022-10-14 16:08:54 +08:00
var historyQueryFilter = $ @ "<obj is='obix: HistoryFilter'>
< abstime name = ' start ' val = ' { start } ' / >
< abstime name = ' end ' val = ' { end } ' / >
< / obj > ";
XmlDocument xmlDocument = new XmlDocument ( ) ;
List < HistoryRawData > historyRawDatas = new List < HistoryRawData > ( ) ;
List < string > errorPoints = new List < string > ( ) ; //錯誤的設備點位
foreach ( var historyItem in post . HistoryItems )
{
var device_number_point = historyItem . Device_number_point . Replace ( ":" , "_" ) ;
HttpWebRequest request = ( HttpWebRequest ) WebRequest . Create ( $"{obixApiConfig.ApiBase}obix/histories/FIC_Center/{device_number_point}/~historyQuery/" ) ;
request . Method = "POST" ;
request . Headers . Add ( "Authorization" , "Basic " + encoded ) ;
request . PreAuthenticate = true ;
byte [ ] byteArray = Encoding . UTF8 . GetBytes ( historyQueryFilter ) ;
using ( Stream reqStream = request . GetRequestStream ( ) )
{
reqStream . Write ( byteArray , 0 , byteArray . Length ) ;
}
HttpWebResponse response = ( HttpWebResponse ) request . GetResponse ( ) ;
var responseContent = new StreamReader ( response . GetResponseStream ( ) ) . ReadToEnd ( ) ;
xmlDocument . LoadXml ( responseContent ) ;
string responseContentJson = JsonConvert . SerializeXmlNode ( xmlDocument ) ;
JObject responseContentJsonResult = ( JObject ) JsonConvert . DeserializeObject ( responseContentJson ) ;
if ( responseContentJsonResult . ContainsKey ( "err" ) ) //抓取錯誤
{
errorPoints . Add ( device_number_point ) ;
continue ;
}
if ( responseContentJsonResult . ContainsKey ( "obj" ) ) //表示可以讀取到內容
{
var countObj = responseContentJsonResult [ "obj" ] [ "int" ] ;
if ( countObj ! = null & & countObj [ "@name" ] . ToString ( ) = = "count" )
{ //判斷是否有資料筆數
if ( Convert . ToInt32 ( countObj [ "@val" ] . ToString ( ) ) > 0 )
{
var dataList = responseContentJsonResult [ "obj" ] [ "list" ] ;
if ( dataList ! = null & & dataList [ "obj" ] . HasValues )
{
//讀取資料
foreach ( var obj in dataList [ "obj" ] )
{
HistoryRawData historyRawData = new HistoryRawData ( ) ;
//取得設備基本資訊
var tempSplit = historyItem . Device_number_point . Split ( ":" ) ;
var device_number = tempSplit [ 0 ] ;
var point = tempSplit [ 1 ] ;
var device_item_info = device_item_infos . Where ( x = > x . Device_number = = device_number & & x . Points = = point ) . FirstOrDefault ( ) ;
historyRawData . Building_name = device_item_info . Building_name ;
historyRawData . Main_system_name = device_item_info . Main_system_name ;
historyRawData . Sub_system_name = device_item_info . Sub_system_name ;
historyRawData . Device_number = device_item_info . Device_number ;
historyRawData . Device_name = device_item_info . Device_name ;
historyRawData . Item_name = device_item_info . Item_name ;
historyRawData . Points = device_item_info . Points ;
historyRawData . Unit = device_item_info . Unit ;
//取得時間
var abstime = obj [ "abstime" ] [ "@val" ] . ToString ( ) ;
historyRawData . Timestamp = Convert . ToDateTime ( abstime ) . ToString ( "yyyy-MM-dd HH:mm:ss" ) ;
//取得資料
historyRawData . Value = obj [ "real" ] [ "@val" ] . ToString ( ) ;
historyRawDatas . Add ( historyRawData ) ;
}
}
}
}
}
}
if ( errorPoints . Count ( ) > 0 )
{
apiResult . Code = "9998" ;
apiResult . Msg = String . Join ( "," , errorPoints ) ;
return Ok ( apiResult ) ;
}
apiResult . Code = "0000" ;
apiResult . Data = historyRawDatas ;
}
catch ( Exception exception )
{
apiResult . Code = "9999" ;
apiResult . Msg = "系統內部錯誤，請聯絡管理者。" ;
Logger . LogError ( "【" + controllerName + "/" + actionName + "】" + exception . ToString ( ) ) ;
return Ok ( apiResult ) ;
}
return Ok ( apiResult ) ;
}
2023-05-15 12:59:01 +08:00
/// <summary>
/// 即使歷史資料(前7天)
/// </summary>
/// <param name="input"></param>
/// <returns></returns>
[HttpPost]
[Route("api/HistoryRealTime")]
2023-05-16 18:29:28 +08:00
public async Task < ActionResult < ApiResult < List < HistoryRawData > > > > GetHistoryRealTime ( PostHistoryRawDataFilter input )
2023-05-15 12:59:01 +08:00
{
2023-05-16 18:29:28 +08:00
ApiResult < List < HistoryRawData > > apiResult = new ApiResult < List < HistoryRawData > > ( jwt_str ) ;
apiResult . Data = new List < HistoryRawData > ( ) ;
2023-05-15 12:59:01 +08:00
if ( ! jwtlife )
{
apiResult . Code = "5000" ;
return BadRequest ( apiResult ) ;
}
2023-05-16 18:29:28 +08:00
if ( input . HistoryItems . Count = = 0 )
2023-05-15 12:59:01 +08:00
{
apiResult . Code = "9998" ;
apiResult . Msg = "沒有設備被選擇" ;
return BadRequest ( apiResult ) ;
}
try
{
2023-05-16 18:29:28 +08:00
//依據被選擇的設備找出相對應資料
var sqlDeviceItemInfo = $ @ "select
2023-05-17 09:29:51 +08:00
b . full_name as building_name ,
v1 . system_key as Main_system_name ,
v2 . system_key as Sub_system_name ,
temp . device_number ,
temp . device_name ,
temp . full_name as item_name ,
temp . points ,
temp . unit
from (
select
di . * ,
d . device_number ,
d . full_name as device_name ,
d . priority
from device_item di
inner join device d on di . device_building_tag COLLATE utf8mb4_unicode_ci = d . device_building_tag
and di . device_system_tag COLLATE utf8mb4_unicode_ci = d . device_system_tag
and di . device_name_tag COLLATE utf8mb4_unicode_ci = d . device_name_tag
and d . deleted = 0
where di . deleted = 0 and di . unit is not null and d . device_number IN @Device_number
) temp
2023-05-16 18:29:28 +08:00
inner join building b on temp . device_building_tag COLLATE utf8mb4_unicode_ci = b . building_tag and b . deleted = 0
inner join variable v1 on temp . device_system_tag COLLATE utf8mb4_unicode_ci = v1 . system_value and v1 . deleted = 0 and v1 . system_type = ' device_system_category_layer2 '
inner join variable v2 on temp . device_name_tag COLLATE utf8mb4_unicode_ci = v2 . system_value and v2 . deleted = 0 and v2 . system_type = ' device_system_category_layer3 '
order by b . priority , v1 . system_priority , v2 . system_priority , temp . priority ; ";
2023-05-15 12:59:01 +08:00
2023-05-16 18:29:28 +08:00
foreach ( var hi in input . HistoryItems )
2023-05-15 12:59:01 +08:00
{
2023-05-16 18:29:28 +08:00
var device_number = hi . Device_number_point . Split ( ":" ) [ 0 ] ;
var point = hi . Device_number_point . Split ( ":" ) [ 1 ] ;
2023-05-17 10:41:47 +08:00
var tableName = await backgroundServiceMsSqlRepository . GetOneAsync < string > ( $"select table_name from INFORMATION_SCHEMA.TABLES where table_name like '%{device_number}_{point}%'" ) ;
if ( ! string . IsNullOrEmpty ( tableName ) )
{
var device_item_infos = await frontendRepository . GetAllAsync < DeviceItemInfo > ( sqlDeviceItemInfo , new { Device_number = hi . Device_number_point } ) ;
var device_item_info = device_item_infos . Where ( x = > x . Device_number = = device_number & & x . Points = = point ) . FirstOrDefault ( ) ;
var sql = $ @ "select '{device_item_info.Building_name}' as Building_name, '{device_item_info.Main_system_name}' as Main_system_name,
' { device_item_info . Sub_system_name } ' as Sub_system_name ' , { device_item_info . Device_number } ' as Device_number ,
' { device_item_info . Device_name } ' as Device_name , ' { device_item_info . Item_name } ' as Item_name , ' { device_item_info . Points } ' as Points ,
' { device_item_info . Unit } ' as Unit , timestamp as Timestamp , round ( value , 2 ) as Value
from FIC_CENTER_ { device_number } _ { point }
where replace ( convert ( varchar , [ timestamp ] , 111 ) , '/' , '-' ) > = @startTime
and replace ( convert ( varchar , [ timestamp ] , 111 ) , '/' , '-' ) < = @endTime order by timestamp ";
apiResult . Data . AddRange (
await backgroundServiceMsSqlRepository . GetAllAsync < HistoryRawData > ( sql , new { startTime = input . Start_timestamp , endTime = input . End_timestamp } )
) ;
}
2023-05-16 18:29:28 +08:00
//foreach (var tn in tableName)
//{
//}
2023-05-15 12:59:01 +08:00
}
2023-05-16 18:29:28 +08:00
apiResult . Data = apiResult . Data . OrderBy ( x = > x . Device_number ) . ThenBy ( x = > x . Timestamp ) . ToList ( ) ;
2023-05-15 12:59:01 +08:00
}
catch ( Exception exception )
{
apiResult . Code = "9999" ;
apiResult . Msg = "系統內部錯誤，請聯絡管理者。" ;
Logger . LogError ( "【" + controllerName + "/" + actionName + "】" + exception . Message ) ;
return Ok ( apiResult ) ;
}
return Ok ( apiResult ) ;
}
2022-10-14 16:08:54 +08:00
}
}
