using Dapper; using Repository.BackendRepository.Interface; using Repository.Helper; using System; using System.Text; using System.Collections.Generic; using System.Data; using System.Linq; using System.Threading.Tasks; using System.Transactions; using Repository.Models; using System.Data.SqlTypes; using Microsoft.Extensions.Primitives; using System.Web; using Org.BouncyCastle.Utilities.Collections; using System.Reflection; using System.Drawing; namespace Repository.BackendRepository.Implement { public class NiagaraDataSynchronizeRepository : BackendRepository, INiagaraDataSynchronizeRepository { public NiagaraDataSynchronizeRepository(IDatabaseHelper databaseHelper) : base(databaseHelper) { } /// /// 更新import_niagara_tag資料表 /// /// /// /// public async Task InsertNiagaraTagList(List ds, List building, string tag_quantity) { using (IDbConnection conn = GetDbConnection()) { conn.Open(); StringBuilder sb = new StringBuilder(); try { foreach(var b in building) { string sql = @"CREATE TABLE IF NOT EXISTS `import_niagara_tag` ( `id` int(11) NOT NULL AUTO_INCREMENT, `db_tags` varchar(50) DEFAULT NULL, `niagara_tags` varchar(50) DEFAULT NULL, `device_area_tag` varchar(50) DEFAULT NULL, `device_building_tag` varchar(50) DEFAULT NULL, `device_system_tag` varchar(50) DEFAULT NULL, `device_name_tag` varchar(50) DEFAULT NULL, `device_floor_tag` varchar(50) DEFAULT NULL, `device_master_tag` varchar(50) DEFAULT NULL, `device_last_name_tag` varchar(50) DEFAULT NULL, `device_serial_tag` varchar(50) DEFAULT NULL, `atDateTime` datetime(1) DEFAULT NULL, `device_full_name` varchar(100) DEFAULT NULL, `is_used` smallint(1) DEFAULT 0, PRIMARY KEY (`id`) ) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_0900_ai_ci;"; using (TransactionScope scope = new TransactionScope(TransactionScopeAsyncFlowOption.Enabled)) { await conn.ExecuteAsync(sql); } sql = "delete from import_niagara_tag where device_building_tag = '" + b + "' limit 10000"; using (TransactionScope scope = new TransactionScope(TransactionScopeAsyncFlowOption.Enabled)) { await conn.ExecuteAsync(sql); } } //N4資料groupBy後放入import_niagara_tag資料表 var ds2 = ds.GroupBy(x => new { tag_name2 = x.tag_name, displayName2 = x.displayName }).Select(x => new Device_value { tag_name = x.Key.tag_name2, displayName = x.Key.displayName2 }); // StringBuilder sb = new StringBuilder(); bool isDome = false; //是否為巨蛋案 int count = 0; foreach (var row in ds2) { if (string.IsNullOrEmpty(row.tag_name)) continue; string[] arrTag = row.tag_name.Split('_'); if (int.Parse(tag_quantity) == 8) { if (arrTag.Length == 8) { sb.Append($@" insert into import_niagara_tag(niagara_tags, device_area_tag, device_building_tag, device_system_tag, device_name_tag, device_floor_tag, device_master_tag, device_last_name_tag, device_serial_tag, device_full_name, atDateTime) values('" + row.tag_name + "', '" + //niagara_tags arrTag[0] + "', '" + //device_area_tag arrTag[1] + "', '" + //device_building_tag arrTag[2] + "', '" + //device_system_tag arrTag[3] + "', '" + //device_name_tag arrTag[4] + "', '" + //device_floor_tag arrTag[5] + "', '" + //device_master_tag arrTag[6] + "', '" + //device_last_name_tag arrTag[7] + "', '" + //device_serial_tag row.displayName + "', " + //device_full_name "now());"); //atDateTime } } else { if (arrTag.Length == 5) { isDome= true; sb.Append($@" insert into import_niagara_tag(niagara_tags, device_area_tag, device_building_tag, device_system_tag, device_name_tag, device_floor_tag, device_master_tag, device_last_name_tag, device_serial_tag, device_full_name, atDateTime) values('" + row.tag_name + "', '" + //niagara_tags "', '" + //device_area_tag arrTag[0] + "', '" + //device_building_tag arrTag[1] + "', '" + //device_system_tag 巨蛋沒有大類，後面再用關聯的方式補上 arrTag[3] + "', '" + //device_name_tag arrTag[2] + "', '" + //device_floor_tag "', '" + //device_master_tag "', '" + //device_last_name_tag arrTag[4] + "', '" + //device_serial_tag row.displayName + "', " + //device_full_name "now());"); //atDateTime //await conn.ExecuteAsync(sb.ToString()); //sb.Clear(); count += 1; if (count >= 100) { count = 0; using (TransactionScope scope = new TransactionScope(TransactionScopeAsyncFlowOption.Enabled)) { await conn.ExecuteAsync(sb.ToString()); } sb.Clear(); } } } } if (sb.Length > 0) { var temp = sb.ToString(); using (TransactionScope scope = new TransactionScope(TransactionScopeAsyncFlowOption.Enabled)) { await conn.ExecuteAsync(temp); } sb.Clear(); //巨蛋特殊處理 if (isDome) { sb.Append($@" -- tag 第二碼為小類(除了安全系統之外) update import_niagara_tag set device_name_tag = device_system_tag where (device_system_tag <> 'S' and device_system_tag <> 'CWB' and device_system_tag <> 'B' and (device_system_tag <> 'FM' or device_system_tag <> 'APS' or device_system_tag <> 'VICL')); update import_niagara_tag a join dic_system b on a.device_name_tag COLLATE utf8mb4_general_ci = b.s2_code set device_system_tag = b.s1_code -- tag 第二碼為小類(除了安全系統之外) where (device_system_tag <> 'S' and device_system_tag <> 'CWB' and device_system_tag <> 'B' and (device_system_tag <> 'FM' or device_system_tag <> 'APS' or device_system_tag <> 'VICL')); -- 安全系統 第二段大類 第四段小類"); using (TransactionScope scope = new TransactionScope(TransactionScopeAsyncFlowOption.Enabled)) { await conn.ExecuteAsync(sb.ToString()); } } } } catch (Exception exception) { Console.WriteLine(sb.ToString()); throw exception; } finally { conn.Close(); } } } /// /// 獲取照明開關 是否在 device_node 層 /// /// public async Task getLightSwitchLevel() { using (IDbConnection conn = GetDbConnection()) { conn.Open(); var sql = "select system_value from variable where system_type = 'module_light_switch' "; var module_light_switch = conn.QueryAsync(sql).Result.FirstOrDefault(); conn.Close(); return module_light_switch; } } /// /// 更新import_niagara_tag資料表 /// /// /// /// public async Task InsertItemFromNiagara(List ds, List building) { using (IDbConnection conn = GetDbConnection()) { conn.Open(); try { #region 刪除 import_niagara_item資料表中選取的棟別 foreach(var b in building) { string sql = @"CREATE TABLE IF NOT EXISTS `import_niagara_item` ( `id` int(11) NOT NULL AUTO_INCREMENT, `device_area_tag` varchar(50) DEFAULT NULL, `device_building_tag` varchar(50) DEFAULT NULL, `device_system_tag` varchar(50) DEFAULT NULL, `device_name_tag` varchar(50) DEFAULT NULL, `device_point_name` varchar(50) DEFAULT NULL, `check_status` varchar(50) DEFAULT NULL, `parent_path` varchar(50) DEFAULT NULL, `full_name` varchar(50) DEFAULT NULL, PRIMARY KEY (`id`) ) ENGINE=InnoDB AUTO_INCREMENT=59 DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_0900_ai_ci;"; using (TransactionScope scope = new TransactionScope(TransactionScopeAsyncFlowOption.Enabled)) { await conn.ExecuteAsync(sql); } sql = "delete from import_niagara_item where device_building_tag = '" + b + "' limit 10000;"; using (TransactionScope scope = new TransactionScope(TransactionScopeAsyncFlowOption.Enabled)) { await conn.ExecuteAsync(sql); } } #endregion ds = ds.GroupBy(x => new { device_area_tag = x.device_area_tag, device_building_tag = x.device_building_tag, device_system_tag = x.device_system_tag, device_name_tag = x.device_name_tag, device_point_name = x.device_point_name, full_name = x.full_name, parent_path = x.parent_path, isHistory = x.isHistory }) .Select(x => new ImpNiaItem { device_area_tag = x.Key.device_area_tag, device_building_tag = x.Key.device_building_tag, device_system_tag = x.Key.device_system_tag, device_name_tag = x.Key.device_name_tag, device_point_name = x.Key.device_point_name, full_name = x.Key.full_name, parent_path = x.Key.parent_path, isHistory = x.Key.isHistory }).ToList(); StringBuilder sb = new StringBuilder(); #region 放入import_niagara_item資料表 foreach (var row in ds) { sb.Append($@" insert import_niagara_item(device_area_tag, device_building_tag, device_system_tag, device_name_tag, device_point_name, parent_path, full_name, is_history) values('"+ row.device_area_tag + "', '" + row.device_building_tag + "', '" + row.device_system_tag + "', '" + row.device_name_tag + "', '" + row.device_point_name + "', '" + row.parent_path + "', '" + row.full_name + "'," + row.isHistory + ");"); } var isDome = await GetOneAsync("select system_value from variable where deleted = 0 and system_type = 'project_name';"); if (sb.Length > 0) { if (isDome.Contains("ibms_dome")) { sb.Append($@" update import_niagara_item a join dic_system b on a.device_name_tag COLLATE utf8mb4_0900_ai_ci = b.s2_code COLLATE utf8mb4_0900_ai_ci set device_system_tag = b.s1_code where (device_system_tag <> 'S' and device_system_tag <> 'CWB' and device_system_tag <> 'B');"); } sb.Append($@" update import_niagara_item set full_name = device_point_name where full_name = '' or full_name is null;"); using (TransactionScope scope = new TransactionScope(TransactionScopeAsyncFlowOption.Enabled)) { await conn.ExecuteAsync(sb.ToString()); } sb.Clear(); } #endregion } catch (Exception exception) { throw exception; } finally { conn.Close(); } } } /// /// 比對 device /// /// public async Task DeviceComparison(string LightSwitchLevel) { using (IDbConnection conn = GetDbConnection()) { conn.Open(); try { List result; StringBuilder sb = new StringBuilder(); StringBuilder sb2 = new StringBuilder(); sb.Append($@"SELECT m.* FROM import_niagara_tag m WHERE NOT EXISTS ( SELECT 1 FROM device d WHERE m.niagara_tags = d.device_number );"); result = (await conn.QueryAsync(sb.ToString())).ToList(); sb.Clear(); #region device, device_kind 新增 //新增至device, is_link = 1 if (result.Count > 0) { var result2 = result.GroupBy(x => new { device_building_tag2 = x.device_building_tag, device_system_tag2 = x.device_system_tag, device_name_tag2 = x.device_name_tag }).Select(x => new Device_item8 { device_building_tag = x.Key.device_building_tag2, device_system_tag = x.Key.device_system_tag2, device_name_tag = x.Key.device_name_tag2 }); int count = 0; foreach (var data in result) { //開關控制在個別燈具(device_node層) and 小類為二線式照明系統 and tag第八段開頭不是 G if (LightSwitchLevel == "node" && data.device_name_tag == "L1" && data.device_serial_tag.Substring(0, 1) != "G") { // 燈具新增 device_node continue; } else { sb.Append($@" insert device(device_guid, deleted, status, priority, is_link, device_area_tag, device_building_tag, device_system_tag, device_name_tag, full_name, device_floor_tag, device_master, device_last_name, device_serial_tag, device_number, device_system_category_layer3, visible, created_at, updated_at) values(uuid(), 0, 1, 0, 1, '" + data.device_area_tag + "', '" + data.device_building_tag + "', '" + data.device_system_tag + "', '" + data.device_name_tag + "', '" + data.device_full_name + "', '" + data.device_floor_tag + "', '" + data.device_master_tag + "', '" + data.device_last_name_tag + "', '" + data.device_serial_tag + "', '" + data.niagara_tags + "', '" + data.device_system_tag + "', 1, now(), now() );"); count += 1; if (count >= 100) { using (TransactionScope scope = new TransactionScope((TransactionScopeOption)TransactionScopeAsyncFlowOption.Enabled)) { await conn.ExecuteAsync(sb.ToString()); } sb.Clear(); count = 0; } } } count = 0; foreach (var data in result2) { var sqlString = new StringBuilder(); sqlString.Append("select * from device_kind where device_building_tag = '" + data.device_building_tag + "' and device_system_tag = '" + data.device_system_tag + "' and device_name_tag = '" + data.device_name_tag + "'"); var dk = (await conn.QueryAsync(sqlString.ToString())).ToList(); if (dk.Count == 0) { sb2.Append($@"INSERT device_kind (device_kind_guid, device_building_tag, device_system_tag, device_name_tag, device_normal_flashing, device_close_flashing, device_error_flashing, device_error_independent, created_by, created_at) VALUES (uuid(), '" + data.device_building_tag + "', '" + data.device_system_tag + "', '" + data.device_name_tag + "', 0, 0, 1, 0, 'B43E3CA7-96DD-4FC7-B6E6-974ACC3B0878', now());"); count += 1; if (count >= 100) { using (TransactionScope scope = new TransactionScope((TransactionScopeOption)TransactionScopeAsyncFlowOption.Enabled)) { await conn.ExecuteAsync(sb2.ToString()); } sb2.Clear(); count = 0; } } } if (sb.Length > 0) { using (TransactionScope scope = new TransactionScope((TransactionScopeOption)TransactionScopeAsyncFlowOption.Enabled)) { await conn.ExecuteAsync(sb.ToString()); await conn.ExecuteAsync(sb2.ToString()); } sb.Clear(); sb2.Clear(); } } #endregion #region device_node 新增 sb.Append($@" SELECT m.* FROM import_niagara_tag m WHERE NOT EXISTS ( SELECT 1 FROM device_node d WHERE m.niagara_tags COLLATE utf8mb4_0900_ai_ci = d.device_number COLLATE utf8mb4_0900_ai_ci );"); result = (await conn.QueryAsync(sb.ToString())).ToList(); sb.Clear(); if (result.Count > 0) { var result2 = result.GroupBy(x => new { device_building_tag2 = x.device_building_tag, device_system_tag2 = x.device_system_tag, device_name_tag2 = x.device_name_tag }).Select(x => new Device_item8 { device_building_tag = x.Key.device_building_tag2, device_system_tag = x.Key.device_system_tag2, device_name_tag = x.Key.device_name_tag2 }); int count = 0; foreach (var data in result) { //開關控制在個別燈具(device_node層) and 小類為二線式照明系統 and tag第八段開頭不是 G if (LightSwitchLevel == "node" && data.device_name_tag == "L1" && data.device_serial_tag.Substring(0, 1) != "G") { // 燈具新增 device_node sb.Append($@"INSERT INTO device_node(device_node_guid, deleted, device_guid, device_number, full_name, created_by, created_at, updated_at) VALUES (uuid(), 0, '' " + //device_guid 父層需要 forge 那邊提供 ",'" + data.niagara_tags + // device_number "', '" + data.device_full_name + //full_name "','B43E3CA7-96DD-4FC7-B6E6-974ACC3B0878', now(), now());"); count += 1; if (count >= 100) { using (TransactionScope scope = new TransactionScope((TransactionScopeOption)TransactionScopeAsyncFlowOption.Enabled)) { await conn.ExecuteAsync(sb.ToString()); } sb.Clear(); count = 0; } } } if (sb.Length > 0) { using (TransactionScope scope = new TransactionScope((TransactionScopeOption)TransactionScopeAsyncFlowOption.Enabled)) { await conn.ExecuteAsync(sb.ToString()); } sb.Clear(); } } #endregion //device有，niagara有，is_link 更新成 1 sb.Append($@" SET SQL_SAFE_UPDATES = 0; UPDATE device d JOIN ( SELECT niagara_tags FROM import_niagara_tag LIMIT 100000 ) i ON d.device_number = i.niagara_tags SET d.is_link = 1"); using (TransactionScope scope = new TransactionScope((TransactionScopeOption)TransactionScopeAsyncFlowOption.Enabled)) { await conn.ExecuteAsync(sb.ToString()); } sb.Clear(); //device有，niagara沒有，is_link 更新成 0 sb.Append($@" SET SQL_SAFE_UPDATES = 0; UPDATE device d left JOIN ( SELECT niagara_tags FROM import_niagara_tag LIMIT 100000 ) i ON d.device_number = i.niagara_tags SET d.is_link = 0 WHERE d.is_link = 1 and i.niagara_tags is null;"); using (TransactionScope scope = new TransactionScope((TransactionScopeOption)TransactionScopeAsyncFlowOption.Enabled)) { await conn.ExecuteAsync(sb.ToString()); } sb.Clear(); // device_node 有, niagara沒有, is_link 更新成 0 sb.Append($@" SET SQL_SAFE_UPDATES = 0; UPDATE device_node dn left JOIN ( SELECT niagara_tags FROM import_niagara_tag LIMIT 100000 ) i ON dn.device_number COLLATE utf8mb4_0900_ai_ci = i.niagara_tags COLLATE utf8mb4_0900_ai_ci SET dn.is_link = 0 WHERE dn.is_link = 1 and i.niagara_tags is null;"); using (TransactionScope scope = new TransactionScope((TransactionScopeOption)TransactionScopeAsyncFlowOption.Enabled)) { await conn.ExecuteAsync(sb.ToString()); } } catch (Exception exception) { //throw exception; throw; } finally { conn.Close(); } } } /// /// 比對 device_item /// /// public async Task DeviceItemComparison() { using (IDbConnection conn = GetDbConnection()) { conn.Open(); try { List result; StringBuilder sb = new StringBuilder(); sb.Append($@" SELECT m.* FROM import_niagara_item m LEFT JOIN device_item d ON m.device_system_tag = d.device_system_tag and m.device_name_tag = d.device_name_tag and m.device_point_name = d.points and m.device_building_tag collate utf8mb4_0900_ai_ci = d.device_building_tag WHERE d.points IS NULL;"); result = (await conn.QueryAsync(sb.ToString())).ToList(); sb.Clear(); # region 新增至device, is_link = 1 if (result.Count > 0) { foreach (var data in result) { var isControll = 0; var isBool = 0; if (data.device_point_name == "ER" || data.device_point_name == "AL" || data.device_point_name == "ST") { isControll = 1; } if (data.device_point_name == "ER" || data.device_point_name == "ST") { isBool = 1; } sb.Append($@"insert device_item(deleted, points, is_show, is_show_riserDiagram, is_controll, is_bool, is_show_history, is_link, device_system_tag, device_name_tag, device_building_tag, full_name, parent_path, created_at, updated_at) VALUES (0, '" + data.device_point_name + "', 1, 0, " + isControll + "," + isBool + "," + data.is_history + ", 1, '" + data.device_system_tag + "', '" + data.device_name_tag + "', '" + data.device_building_tag + "', '" + data.full_name + "', '" + data.parent_path + "', " + "now(), now());"); } if (sb.Length > 0) { using (TransactionScope scope = new TransactionScope(TransactionScopeAsyncFlowOption.Enabled)) { await conn.ExecuteAsync(sb.ToString()); } sb.Clear(); } } #endregion //device有，niagara沒有，is_link 更新成 0 //sb.Append($@" SET SQL_SAFE_UPDATES = 0; // UPDATE device_item d LEFT JOIN import_niagara_item m // ON d.device_system_tag = m.device_system_tag and d.device_name_tag = m.device_name_tag and d.points = m.device_point_name // SET d.is_link = 0, d.is_show_history = 0 // WHERE m.device_point_name IS NULL"); //本次有匯入的 isLink 改為 1, 沒有的 isLink = 0 sb.Append($@" SET SQL_SAFE_UPDATES = 0; UPDATE device_item d LEFT JOIN ( SELECT device_system_tag, device_name_tag, device_point_name, full_name FROM import_niagara_item LIMIT 100000 -- Specify your desired limit here ) m ON d.device_system_tag = m.device_system_tag AND d.device_name_tag = m.device_name_tag AND d.points = m.device_point_name AND d.full_name = m.full_name SET d.is_link = CASE WHEN m.device_point_name IS NULL THEN 0 ELSE 1 END; "); using (TransactionScope scope = new TransactionScope(TransactionScopeAsyncFlowOption.Enabled)) { await conn.ExecuteAsync(sb.ToString()); } sb.Clear(); sb.Append($@" SET SQL_SAFE_UPDATES = 0; UPDATE device_item d LEFT JOIN ( SELECT m.device_system_tag, m.device_name_tag, m.device_point_name, m.full_name FROM import_niagara_item m WHERE (m.is_history = 1) LIMIT 100000 -- Specify your desired limit here ) AS subquery ON d.device_system_tag = subquery.device_system_tag AND d.device_name_tag = subquery.device_name_tag AND d.points = subquery.device_point_name AND d.full_name = subquery.full_name SET d.is_show_history = CASE WHEN subquery.device_point_name IS NULL THEN 0 ELSE 1 END WHERE (d.is_show_history);"); using (TransactionScope scope = new TransactionScope(TransactionScopeAsyncFlowOption.Enabled)) { await conn.ExecuteAsync(sb.ToString()); } } catch (Exception exception) { throw exception; } finally { conn.Close(); } } } /// /// 新增資料至 buildingMenu /// /// public async Task InsertBuildingMenu() { using (IDbConnection conn = GetDbConnection()) { conn.Open(); try { List result; StringBuilder sb = new StringBuilder(); #region comparison building_menu and import_niagara_tag sb.Append($@" select a.* from ( select device_building_tag, device_system_tag, device_name_tag from import_niagara_tag group by device_building_tag, device_system_tag, device_name_tag ) AS a LEFT JOIN building_menu b ON a.device_building_tag COLLATE utf8mb4_0900_ai_ci = b.device_building_tag COLLATE utf8mb4_0900_ai_ci and a.device_system_tag COLLATE utf8mb4_0900_ai_ci = b.device_system_tag COLLATE utf8mb4_0900_ai_ci and a.device_name_tag COLLATE utf8mb4_0900_ai_ci = b.sub_system_tag COLLATE utf8mb4_0900_ai_ci WHERE b.device_building_tag IS NULL"); result = (await conn.QueryAsync(sb.ToString())).ToList(); #endregion sb.Clear(); if (result.Count > 0) { foreach (var data in result) { StringBuilder sqlString = new StringBuilder(); sqlString.Append(@"select * from building_menu where building_tag = '" + data.device_building_tag + "' and main_system_tag = '" + data.device_system_tag + "' and sub_system_tag = '" + data.device_name_tag + "'"); var bm = (await conn.QueryAsync(sqlString.ToString())).ToList(); #region insert building_menu if (bm.Count == 0) { sb.Append(@$"insert building_menu(building_tag, main_system_tag, sub_system_tag, device_building_tag, device_system_tag, left_drawing, left_icon_click, left_icon_click_url_width, left_icon_click_url_height, left_planimetric_click, is_link, created_by, created_at, updated_by, updated_at) values('{data.device_building_tag}', '{data.device_system_tag}', '{data.device_name_tag}', '{data.device_building_tag}', '{data.device_system_tag}', 4, 1, 0, 0, 1, 1, 'B43E3CA7-96DD-4FC7-B6E6-974ACC3B0878', now(), 'B43E3CA7-96DD-4FC7-B6E6-974ACC3B0878', now());"); } #endregion } if (sb.Length > 0) { using (TransactionScope scope = new TransactionScope(TransactionScopeAsyncFlowOption.Enabled)) { await conn.ExecuteAsync(sb.ToString()); } sb.Clear(); } } //building_menu有，import_niagara_tag沒有，is_link 更新成 0 sb.Append($@" SET SQL_SAFE_UPDATES = 0; UPDATE building_menu b LEFT JOIN ( select device_building_tag, device_system_tag, device_name_tag from import_niagara_tag group by device_building_tag, device_system_tag, device_name_tag ) AS a ON b.building_tag COLLATE utf8mb4_0900_ai_ci = a.device_building_tag COLLATE utf8mb4_0900_ai_ci and a.device_system_tag COLLATE utf8mb4_0900_ai_ci = b.main_system_tag COLLATE utf8mb4_0900_ai_ci and a.device_name_tag COLLATE utf8mb4_0900_ai_ci = b.sub_system_tag COLLATE utf8mb4_0900_ai_ci SET b.is_link = 0 WHERE a.device_building_tag IS NULL and b.is_link < 2"); using (TransactionScope scope = new TransactionScope(TransactionScopeAsyncFlowOption.Enabled)) { await conn.ExecuteAsync(sb.ToString()); } } catch (Exception exception) { throw exception; } finally { conn.Close(); } } } /// /// 新增資料至 subSystemFloor /// /// public async Task InsertSubSystemFloor() { using (IDbConnection conn = GetDbConnection()) { conn.Open(); try { List result; StringBuilder sb = new StringBuilder(); #region comparison sub_system_floor and import_niagara_tag sb.Append($@" select a.* from ( select device_building_tag, device_system_tag, device_name_tag, device_floor_tag from import_niagara_tag group by device_building_tag, device_system_tag, device_name_tag, device_floor_tag ) AS a LEFT JOIN sub_system_floor b ON a.device_building_tag COLLATE utf8mb4_0900_ai_ci = b.building_tag COLLATE utf8mb4_0900_ai_ci and a.device_system_tag COLLATE utf8mb4_0900_ai_ci = b.main_system_tag COLLATE utf8mb4_0900_ai_ci and a.device_name_tag COLLATE utf8mb4_0900_ai_ci = b.sub_system_tag COLLATE utf8mb4_0900_ai_ci and a.device_floor_tag COLLATE utf8mb4_0900_ai_ci = b.floor_tag COLLATE utf8mb4_0900_ai_ci WHERE b.building_tag IS NULL"); result = (await conn.QueryAsync(sb.ToString())).ToList(); #endregion sb.Clear(); if (result.Count > 0) { foreach (var data in result) { #region insert building_menu sb.Append(@"insert sub_system_floor(building_tag, main_system_tag, sub_system_tag, floor_tag, is_link, created_by, created_at, updated_by, updated_at) VALUES ('" + data.device_building_tag + "', '" + data.device_system_tag + "', '" + data.device_name_tag + "', '" + data.device_floor_tag + "', " + "1, 'B43E3CA7-96DD-4FC7-B6E6-974ACC3B0878', now(), 'B43E3CA7-96DD-4FC7-B6E6-974ACC3B0878', now());"); #endregion } if (sb.Length > 0) { using (TransactionScope scope = new TransactionScope(TransactionScopeAsyncFlowOption.Enabled)) { await conn.ExecuteAsync(sb.ToString()); } sb.Clear(); } } //building_menu有，import_niagara_tag沒有，is_link 更新成 0 sb.Append($@" SET SQL_SAFE_UPDATES = 0; UPDATE sub_system_floor b LEFT JOIN ( select device_building_tag, device_system_tag, device_name_tag, device_floor_tag from import_niagara_tag group by device_building_tag, device_system_tag, device_name_tag, device_floor_tag ) AS a ON b.building_tag COLLATE utf8mb4_0900_ai_ci = a.device_building_tag COLLATE utf8mb4_0900_ai_ci and b.main_system_tag COLLATE utf8mb4_0900_ai_ci = a.device_system_tag COLLATE utf8mb4_0900_ai_ci and b.sub_system_tag COLLATE utf8mb4_0900_ai_ci = a.device_name_tag COLLATE utf8mb4_0900_ai_ci and b.floor_tag COLLATE utf8mb4_0900_ai_ci = a.device_floor_tag COLLATE utf8mb4_0900_ai_ci SET b.is_link = 0 WHERE b.building_tag IS NULL"); using (TransactionScope scope = new TransactionScope(TransactionScopeAsyncFlowOption.Enabled)) { await conn.ExecuteAsync(sb.ToString()); } } catch (Exception exception) { throw exception; } finally { conn.Close(); } } } /// /// 檢查device內FullName為空的值，以device_Name取代 /// /// public async Task CheckFullNameEmptyReplaceByDeviceName() { using (IDbConnection conn = GetDbConnection()) { conn.Open(); using (TransactionScope scope = new TransactionScope(TransactionScopeAsyncFlowOption.Enabled)) { try { StringBuilder sb = new StringBuilder(); sb.Append("update device set full_name=device_number where full_Name='';"); await conn.ExecuteAsync(sb.ToString()); } catch (Exception exception) { throw exception; } finally { conn.Close(); } } } } /// /// 檢查device_item內FullName為空的值，以points取代 /// /// public async Task ItemCheckFullNameEmptyReplaceByDeviceName() { //檢查是否有空值 using (IDbConnection conn = GetDbConnection()) { conn.Open(); using (TransactionScope scope = new TransactionScope(TransactionScopeAsyncFlowOption.Enabled)) { try { StringBuilder sb = new StringBuilder(); sb.Append("update device_item set full_name = points where full_Name = '''''';"); await conn.ExecuteAsync(sb.ToString()); } catch (Exception exception) { throw exception; } finally { conn.Close(); } } } } /// /// 檢查device的full_name與niagara device_full_name不同者 覆蓋 /// /// public async Task CheckDiffFullNameAndCover() { using (IDbConnection conn = GetDbConnection()) { conn.Open(); using (TransactionScope scope = new TransactionScope((TransactionScopeOption)TransactionScopeAsyncFlowOption.Enabled, new TimeSpan (0, 0, 200))) { try { StringBuilder sb = new StringBuilder(); sb.Append(@"SET SQL_SAFE_UPDATES = 0; update device d JOIN ( select niagara_tags, device_full_name from import_niagara_tag limit 100000 ) m ON m.niagara_tags = d.device_number LEFT JOIN ( SELECT niagara_tags, device_full_name FROM import_niagara_tag LIMIT 100000 ) m2 ON m2.niagara_tags = d.device_number AND m2.device_full_name = d.full_name SET d.full_name = m.device_full_name WHERE m2.niagara_tags IS NULL;"); await conn.ExecuteAsync(sb.ToString()); } catch (Exception exception) { throw exception; } finally { conn.Close(); } } } } /// /// 比對 device_item full_name 與 import_niagara_item full_name是否相同 /// 不同則覆蓋 /// /// public async Task CheckItemDiffFullNameAndCover() { //檢查 using (IDbConnection conn = GetDbConnection()) { conn.Open(); using (TransactionScope scope = new TransactionScope(TransactionScopeAsyncFlowOption.Enabled)) { try { StringBuilder sb = new StringBuilder(); sb.Append($@"UPDATE device_item d INNER JOIN ( SELECT m.device_system_tag, m.device_name_tag, m.device_point_name, m.full_name FROM import_niagara_item m join device_item d LIMIT 100000 -- Specify your desired limit here ) AS subquery ON d.device_system_tag = subquery.device_system_tag AND d.device_name_tag = subquery.device_name_tag AND d.points = subquery.device_point_name SET d.full_name = subquery.full_name WHERE d.full_name <> subquery.full_name"); await conn.ExecuteAsync(sb.ToString()); } catch (Exception exception) { throw exception; } finally { conn.Close(); } } } } /// /// 先將device_item 的is_show_history全部關掉 /// 根據niagara輸入資料來決定要開哪些點 /// /// public async Task CheckItemIsShowHistory() { //先將所有is_show_history關閉,niagara有的才開啟 using (IDbConnection conn = GetDbConnection()) { conn.Open(); try { StringBuilder sb = new StringBuilder(); //先全部關閉 sb.Append("update device_item set is_show_history=0;"); using (TransactionScope scope = new TransactionScope(TransactionScopeAsyncFlowOption.Enabled)) { await conn.ExecuteAsync(sb.ToString()); } sb.Clear(); sb.Append($@"SET SQL_SAFE_UPDATES = 0; update device_item di JOIN ( select distinct device_system_tag, device_name_tag, device_point_name, full_name, device_building_tag from import_niagara_item where is_history = 1 limit 100000 ) niagara ON di.device_system_tag = niagara.device_system_tag AND di.device_name_tag = niagara.device_name_tag AND di.points = niagara.device_point_name AND di.full_name = niagara.full_name AND di.device_building_tag = niagara.device_building_tag set di.is_show_history = 1"); using (TransactionScope scope = new TransactionScope(TransactionScopeAsyncFlowOption.Enabled)) { await conn.ExecuteAsync(sb.ToString()); } } catch (Exception exception) { throw exception; } finally { conn.Close(); } } } public async Task DeviceDisasterAysnc(List dv) { using (IDbConnection conn = GetDbConnection()) { conn.Open(); StringBuilder sb = new StringBuilder(); List deviceDisaster = new List(); List device = new List(); using (TransactionScope scope = new TransactionScope((TransactionScopeOption)TransactionScopeAsyncFlowOption.Enabled)) { try { sb.Append("select * from device_disaster;"); deviceDisaster = (await conn.QueryAsync(sb.ToString())).ToList(); sb.Clear(); sb.Append("select * from device where deleted = 0;"); device = (await conn.QueryAsync(sb.ToString())).ToList(); } catch (Exception exception) { throw exception; } finally { conn.Close(); } } dv = dv.Where(x => device.Any(d => d.device_number == x.value.Split('/')[6])).ToList(); sb.Clear(); var updateList = dv.Where(x => deviceDisaster.Any(dd => dd.device_number == x.value.Split('/')[6] && dd.device_system_value != x.disasterValue)).ToList(); foreach (var d in updateList) { string device_number = d.value.Split('/')[6]; sb.Append($"update device_disaster set device_system_value = '{d.disasterValue}' where device_number = '{device_number}'; "); } var insertList = dv.Where(x => !deviceDisaster.Any(dd => dd.device_number == x.value.Split('/')[6])).ToList(); foreach (var d in insertList) { string device_number = d.value.Split('/')[6]; string device_guid = device.Where(x => x.device_number == device_number).Select(x => x.device_guid).FirstOrDefault(); string device_system_tag = device.Where(x => x.device_number == device_number).Select(x => x.device_system_tag).FirstOrDefault(); string device_name_tag = device.Where(x => x.device_number == device_number).Select(x => x.device_name_tag).FirstOrDefault(); sb.Append($@" insert into device_disaster (device_guid, device_system_value, device_building_tag, device_system_tag, device_name_tag, device_floor_tag, device_serial_tag, device_number) values ('{device_guid}', '{d.disasterValue}', '{device_number.Split('_')[0]}', '{device_system_tag}', '{device_name_tag}', '{device_number.Split('_')[2]}', '{device_number.Split('_')[4]}', '{device_number}'); "); } using (TransactionScope scope = new TransactionScope(TransactionScopeAsyncFlowOption.Enabled)) { try { if (!string.IsNullOrEmpty(sb.ToString())) await conn.ExecuteAsync(sb.ToString()); } catch (Exception ex) { throw ex; } finally { conn.Close(); } } } } /// /// InsertFloor /// /// public async Task InsertFloor() { using (IDbConnection conn = GetDbConnection()) { conn.Open(); using (TransactionScope scope = new TransactionScope(TransactionScopeAsyncFlowOption.Enabled)) { try { List result; StringBuilder sb = new StringBuilder(); #region comparison floor and sub_system_floor sb.Append($@" select tag.* from ( select device_building_tag, device_floor_tag from import_niagara_tag group by device_building_tag, device_floor_tag ) AS tag LEFT JOIN floor f ON tag.device_building_tag COLLATE utf8mb4_0900_ai_ci = f.building_tag COLLATE utf8mb4_0900_ai_ci and tag.device_floor_tag COLLATE utf8mb4_0900_ai_ci = f.full_name COLLATE utf8mb4_0900_ai_ci and f.deleted = 0 WHERE f.building_tag IS NULL;"); result = (await conn.QueryAsync(sb.ToString())).ToList(); #endregion sb.Clear(); #region insert floor if (result.Count > 0) { Dictionary floorPriority = new Dictionary(); foreach (var data in result) { FloorPriority fp = (await conn.QueryAsync($@"select building_tag, max(priority) as priority from floor where building_tag = '{data.device_building_tag}' and deleted = 0 group by building_tag;")).FirstOrDefault(); int priority = 0; if (fp == null && floorPriority.GetValueOrDefault(data.device_building_tag) == 0) floorPriority.Add(data.device_building_tag, 0); else if (fp != null && floorPriority.GetValueOrDefault(fp.building_tag) == 0) floorPriority.Add(fp.building_tag, fp.Priority); priority = ++floorPriority[data.device_building_tag]; sb.Append($@"insert into floor(floor_guid, building_tag, deleted, status, full_name, priority, created_by, created_at) VALUES (uuid(), '{data.device_building_tag}', 0, 1, '{data.device_floor_tag}', {priority}, 'B43E3CA7-96DD-4FC7-B6E6-974ACC3B0878', now());"); } if (sb.Length > 0) { await conn.ExecuteAsync(sb.ToString()); sb.Clear(); } } #endregion #region update unuse floor with niagara data var floor = (await conn.QueryAsync($@"select f1.* from floor as f1 left join ( select f.floor_guid from ( select device_building_tag, device_floor_tag from import_niagara_tag group by device_building_tag, device_floor_tag ) AS tag LEFT JOIN floor f ON tag.device_building_tag COLLATE utf8mb4_0900_ai_ci = f.building_tag COLLATE utf8mb4_0900_ai_ci and tag.device_floor_tag COLLATE utf8mb4_0900_ai_ci = f.full_name COLLATE utf8mb4_0900_ai_ci and f.deleted = 0 ) as f2 on f1.floor_guid = f2.floor_guid where f2.floor_guid is null and f1.deleted = 0;")).ToList(); if (floor.Count > 0) { sb.Clear(); foreach (var f in floor) { sb.Append($"update floor set deleted = 1 where floor_guid = '{f.Floor_guid}';"); } await conn.ExecuteAsync(sb.ToString()); } #endregion } catch (Exception exception) { throw exception; } finally { conn.Close(); } } } } public async Task InsertItemFromNiagara_History(List ds, List building) { using (IDbConnection conn = GetDbConnection()) { conn.Open(); try { //改成每次都新增 string sql = @"SET NAMES utf8mb4; SET FOREIGN_KEY_CHECKS = 0; -- ---------------------------- -- Table structure for import_niagara_item_history -- ---------------------------- DROP TABLE IF EXISTS `import_niagara_item_history`; CREATE TABLE `import_niagara_item_history` ( `id` int(11) NOT NULL AUTO_INCREMENT, `device_area_tag` varchar(50) CHARACTER SET utf8mb4 COLLATE utf8mb4_unicode_ci NULL DEFAULT NULL, `device_building_tag` varchar(50) CHARACTER SET utf8mb4 COLLATE utf8mb4_unicode_ci NULL DEFAULT NULL, `device_system_tag` varchar(50) CHARACTER SET utf8mb4 COLLATE utf8mb4_unicode_ci NULL DEFAULT NULL, `device_name_tag` varchar(50) CHARACTER SET utf8mb4 COLLATE utf8mb4_unicode_ci NULL DEFAULT NULL, `device_floor_tag` varchar(50) CHARACTER SET utf8mb4 COLLATE utf8mb4_unicode_ci NULL DEFAULT NULL, `device_master_tag` varchar(50) CHARACTER SET utf8mb4 COLLATE utf8mb4_unicode_ci NULL DEFAULT NULL, `device_last_name_tag` varchar(50) CHARACTER SET utf8mb4 COLLATE utf8mb4_unicode_ci NULL DEFAULT NULL, `device_serial_tag` varchar(50) CHARACTER SET utf8mb4 COLLATE utf8mb4_unicode_ci NULL DEFAULT NULL, `device_point_name` varchar(50) CHARACTER SET utf8mb4 COLLATE utf8mb4_unicode_ci NULL DEFAULT NULL, `parent_path` varchar(50) CHARACTER SET utf8mb4 COLLATE utf8mb4_unicode_ci NULL DEFAULT NULL, `is_history` bit(1) NULL DEFAULT b'0', `full_name` varchar(50) CHARACTER SET utf8mb4 COLLATE utf8mb4_unicode_ci NULL DEFAULT NULL, `check_status` varchar(50) CHARACTER SET utf8mb4 COLLATE utf8mb4_unicode_ci NULL DEFAULT NULL, `created_at` timestamp NULL DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP, PRIMARY KEY (`id`) USING BTREE ) ENGINE = InnoDB AUTO_INCREMENT = 271 CHARACTER SET = utf8mb4 COLLATE = utf8mb4_unicode_ci ROW_FORMAT = Dynamic; SET FOREIGN_KEY_CHECKS = 1;"; using (TransactionScope scope = new TransactionScope(TransactionScopeAsyncFlowOption.Enabled)) { await conn.ExecuteAsync(sql); } #region 刪除 import_niagara_item資料表中選取的棟別 //foreach (var b in building) //{ // sql = "delete from import_niagara_item_history where device_building_tag = '" + b + "'"; // await conn.ExecuteAsync(sql); //} #endregion StringBuilder sb = new StringBuilder(); int count = 0; #region 放入import_niagara_item資料表 foreach (var row in ds) { string ss = $@" insert import_niagara_item_history(device_area_tag, device_building_tag, device_system_tag, device_name_tag, device_floor_tag, device_master_tag, device_last_name_tag, device_serial_tag, device_point_name, parent_path, full_name, is_history, created_at) values('" + row.device_area_tag + "', '" + row.device_building_tag + "', '" + row.device_system_tag + "', '" + row.device_name_tag + "', '" + row.device_floor_tag + "', '" + row.device_master_tag + "', '" + row.device_last_name_tag + "', '" + row.device_serial_tag + "', '" + row.device_point_name + "', '" + row.parent_path + "', '" + row.full_name + "'," + row.isHistory + ", now() " + ");"; sb.Append(ss); count++; if (count == 100) { using (TransactionScope scope = new TransactionScope(TransactionScopeAsyncFlowOption.Enabled)) { await conn.ExecuteAsync(sb.ToString()); } sb.Clear(); count = 0; } } if (sb.Length > 0) { using (TransactionScope scope = new TransactionScope(TransactionScopeAsyncFlowOption.Enabled)) { await conn.ExecuteAsync(sb.ToString()); } sb.Clear(); } #endregion } catch (Exception exception) { throw exception; } finally { conn.Close(); } } } /// /// Recover device_system_tag /// /// public async Task RecoverSysTag(string tableName) { //檢查 using (IDbConnection conn = GetDbConnection()) { conn.Open(); using (TransactionScope scope = new TransactionScope(TransactionScopeAsyncFlowOption.Enabled)) { try { StringBuilder sb = new StringBuilder(); sb.Append($@"SET SQL_SAFE_UPDATES = 0; update {tableName} a join dic_system ds on ds.s2_code = a.device_name_tag set a.device_system_tag = ds.s1_code where a.device_system_tag is null or a.device_system_tag = '';"); await conn.ExecuteAsync(sb.ToString()); } catch (Exception exception) { throw exception; } finally { conn.Close(); } } } } } }