ibms-dome/Backend/Controllers/DeviceManageController.cs

1750 lines
83 KiB
C#
Raw Normal View History

2022-10-14 16:08:54 +08:00
using Backend.Models;
using Microsoft.AspNetCore.Mvc;
using Microsoft.Extensions.Logging;
using Repository.BackendRepository.Interface;
using System;
using System.Collections.Generic;
using System.IO;
using System.Linq;
using System.Text.Json;
using System.Threading.Tasks;
namespace Backend.Controllers
{
public class DeviceManageController : MybaseController<DeviceManageController>
{
private readonly IBackendRepository backendRepository;
private readonly IDeviceManageRepository deviceManageRepository;
private string deviceKindFileSaveAsPath = "";
private string deviceKindFilePath = "upload/device_icon/";
public DeviceManageController(IBackendRepository backendRepository, IDeviceManageRepository deviceManageRepository)
{
this.backendRepository = backendRepository;
this.deviceManageRepository = deviceManageRepository;
deviceKindFileSaveAsPath = Path.Combine(Directory.GetCurrentDirectory(), "wwwroot", "upload", "device_icon");
}
public IActionResult Index()
{
return View();
}
/// <summary>
/// 取得設備管理左側選單
/// </summary>
/// <param name="filter"></param>
/// <returns></returns>
[HttpPost]
public async Task<ApiResult<List<BuildingCollapse>>> GetBuildingMenuCollapse(string filter)
{
ApiResult<List<BuildingCollapse>> apiResult = new ApiResult<List<BuildingCollapse>>();
try
{
//取得區域選單
var sql = $@"SELECT
bm.*,
b.full_name AS bFull_name,
b.priority AS bPriority,
mv.system_key AS mFull_name,
mv.system_priority AS mPriority,
sv.system_key AS sFull_name,
sv.system_priority AS sPriority
2022-10-14 16:08:54 +08:00
FROM building_menu bm
JOIN building b ON bm.building_tag = b.building_tag AND b.deleted = 0
2023-09-07 16:18:44 +08:00
JOIN variable mv ON bm.main_system_tag = mv.system_value AND mv.deleted = 0 and mv.system_type = '{main_system_type}'
2023-09-07 18:56:23 +08:00
JOIN variable sv ON bm.sub_system_tag = sv.system_value AND sv.deleted = 0 and sv.system_type = '{sub_system_type}'
where bm.is_link = 1 ";
2022-10-14 16:08:54 +08:00
if (!string.IsNullOrEmpty(filter))
{
2023-09-07 18:56:23 +08:00
sql += $@" and (
2022-10-14 16:08:54 +08:00
b.full_name LIKE CONCAT('%', @Filter, '%')
OR mv.system_key LIKE CONCAT('%', @Filter, '%')
OR sv.system_key LIKE CONCAT('%', @Filter, '%')
2023-09-07 18:56:23 +08:00
) ";
2022-10-14 16:08:54 +08:00
}
sql += $@" ORDER BY b.priority, mv.system_priority, bm.priority, sv.system_priority, sv.created_at DESC";
2022-10-14 16:08:54 +08:00
var buildingMenuRawDatas = await backendRepository.GetAllAsync<BuildingMenuRawData>(sql, new { Filter = filter });
//取得系統小類樓層
var sub_sql = $@"SELECT
ssf.*,
f.full_name AS fFull_name,
f.InitMapName,
f.floor_map_name,
f.priority AS fPriority
2022-10-14 16:08:54 +08:00
FROM sub_system_floor ssf
JOIN floor f ON ssf.floor_tag = f.full_name AND ssf.building_tag = f.building_tag AND f.deleted = 0
2022-10-14 16:08:54 +08:00
WHERE ssf.deleted = 0
ORDER BY f.priority, f.created_at
";
2022-10-14 16:08:54 +08:00
var subSystemFloorRawDatas = await backendRepository.GetAllAsync<SubSystemFloorRawData>(sub_sql);
var buildingMenu_Group_Building_tag = buildingMenuRawDatas.GroupBy(x => x.building_tag).ToList();
2022-10-14 16:08:54 +08:00
List<BuildingCollapse> buildingCollapses = new List<BuildingCollapse>();
foreach (var buildingMenus_Building_tag in buildingMenu_Group_Building_tag)
2022-10-14 16:08:54 +08:00
{
BuildingCollapse buildingCollapse = new BuildingCollapse();
buildingCollapse.Building_tag = buildingMenus_Building_tag.Key;
buildingCollapse.Full_name = buildingMenus_Building_tag.First().bFull_name;
2022-10-14 16:08:54 +08:00
buildingCollapse.Main_systems = new List<Main_system>();
var buildingMenus_Group_Main_system_tag = buildingMenus_Building_tag.GroupBy(x => x.main_system_tag).ToList();
2022-10-14 16:08:54 +08:00
foreach (var buildingMenus_Main_system_tag in buildingMenus_Group_Main_system_tag)
2022-10-14 16:08:54 +08:00
{
Main_system main_System = new Main_system();
main_System.Main_system_tag = buildingMenus_Main_system_tag.Key;
main_System.Full_name = buildingMenus_Main_system_tag.First().mFull_name;
2022-10-14 16:08:54 +08:00
main_System.Sub_systems = new List<Sub_system>();
var buildingMenus_Group_Sub_system_tag = buildingMenus_Main_system_tag.GroupBy(x => x.sub_system_tag).ToList();
2022-10-14 16:08:54 +08:00
foreach (var buildingMenus_Sub_system_tag in buildingMenus_Group_Sub_system_tag)
2022-10-14 16:08:54 +08:00
{
2023-09-07 18:56:23 +08:00
if (main_System.Main_system_tag == "S")
{
string name = buildingMenus_Sub_system_tag.First().sFull_name;
if (name == "人流計數")
{
bool check = buildingMenus_Sub_system_tag.Key.StartsWith(buildingMenus_Building_tag.Key[0]);
if (!check)
continue; //跳回圈
}
}
2022-10-14 16:08:54 +08:00
Sub_system sub_System = new Sub_system();
sub_System.Sub_system_tag = buildingMenus_Sub_system_tag.Key;
sub_System.Full_name = buildingMenus_Sub_system_tag.First().sFull_name;
2022-10-14 16:08:54 +08:00
sub_System.Floors = new List<Floor>();
var floorRawDatas = subSystemFloorRawDatas.Where(x => x.building_tag == buildingCollapse.Building_tag
&& x.main_system_tag == main_System.Main_system_tag
&& x.sub_system_tag == sub_System.Sub_system_tag).ToList();
2022-10-14 16:08:54 +08:00
foreach (var floorRawData in floorRawDatas)
{
Floor floor = new Floor();
floor.Floor_tag = floorRawData.Floor_tag;
2022-10-14 16:08:54 +08:00
floor.Full_name = floorRawData.fFull_name;
floor.InitMapName = floorRawData.InitMapName;
floor.Floor_map_name = floorRawData.Floor_map_name;
sub_System.Floors.Add(floor);
}
main_System.Sub_systems.Add(sub_System);
}
buildingCollapse.Main_systems.Add(main_System);
}
buildingCollapses.Add(buildingCollapse);
}
apiResult.Code = "0000";
apiResult.Data = buildingCollapses;
}
catch (Exception exception)
{
apiResult.Code = "9999";
apiResult.Msg = "系統內部錯誤,請聯絡管理者。";
Logger.LogError("【" + controllerName + "/" + actionName + "】" + exception.Message);
}
return apiResult;
}
/// <summary>
/// 取得設備基本資料清單
/// </summary>
/// <returns></returns>
[HttpPost]
public async Task<ApiResult<List<Device>>> DeviceTableList(PostDeviceFilter post)
{
ApiResult<List<Device>> apiResult = new ApiResult<List<Device>>();
try
{
var sql = $@"SELECT
d.*,
d.full_name AS Device_full_name,
b.full_name AS Building_full_name,
mv.system_key AS Main_system_full_name,
sv.system_key AS Sub_system_full_name,
f.full_name AS Floor_full_name,
dk.device_image,
CONCAT('{baseURL}', '{deviceKindFilePath}', dk.device_image) AS device_image_url,
dk.device_close_color,
dk.device_normal_color,
dk.device_error_color,
dk.device_normal_flashing,
dk.device_close_flashing,
dk.device_error_flashing,
(SELECT
GROUP_CONCAT( IFNULL(system_key, ' '), ',')
FROM device_disaster dd
JOIN variable v ON v.deleted = 0 AND v.system_type = 'disaster' AND v.system_value = dd.device_system_value
WHERE dd.device_guid = d.device_guid
) AS Device_disaster_type_text
FROM (
SELECT *
FROM device d
WHERE d.device_building_tag = @building_tag
AND d.device_system_tag = @main_system_tag
AND d.device_name_tag = @sub_system_tag
AND d.device_floor_tag = @floor_tag
AND d.deleted = 0
AND d.is_link = 1
) d
JOIN building b ON d.device_building_tag = b.building_tag
2023-10-12 21:48:00 +08:00
JOIN variable mv ON d.device_system_tag = mv.system_value AND mv.system_type = @main_system_type and mv.deleted = 0
JOIN variable sv ON d.device_name_tag = sv.system_value AND sv.system_type = @sub_system_type and sv.deleted = 0
2023-11-17 15:17:35 +08:00
JOIN floor f ON d.device_floor_tag = f.full_name AND d.device_building_tag = f.building_tag and f.deleted = 0
LEFT JOIN device_kind dk ON dk.device_building_tag = d.device_building_tag AND dk.device_system_tag = d.device_system_tag AND dk.device_name_tag = d.device_name_tag and dk.is_link = 1
ORDER BY d.priority ASC, d.device_number ASC";
var devices = await backendRepository.GetAllAsync<Device>(sql, new
{
building_tag = post.building_tag,
main_system_tag = post.device_system_tag,
sub_system_tag = post.device_name_tag,
floor_tag = post.device_floor_tag,
main_system_type = main_system_type,
sub_system_type = sub_system_type
});
2022-10-14 16:08:54 +08:00
var sql_node = $@"SELECT
dn.device_node_guid,
dn.device_guid,
dn.full_name AS Device_node_full_name,
dn.device_node_coordinate,
dn.priority
FROM device_node dn
WHERE dn.deleted = 0 AND dn.device_guid = @device_guid
ORDER BY dn.priority ASC";
foreach (var device in devices)
{
device.Device_nodes = await backendRepository.GetAllAsync<DeviceNode>(sql_node, new { device_guid = device.Device_guid });
}
apiResult.Code = "0000";
apiResult.Data = devices;
}
catch (Exception exception)
{
apiResult.Code = "9999";
apiResult.Msg = "系統內部錯誤,請聯絡管理者。";
Logger.LogError("【" + controllerName + "/" + actionName + "】" + exception.Message);
}
return apiResult;
}
/// <summary>
/// 取得單一設備基本資料
/// </summary>
/// <param name="guid"></param>
/// <returns></returns>
[HttpPost]
public async Task<ApiResult<Device>> GetOneDevice(string guid)
{
ApiResult<Device> apiResult = new ApiResult<Device>();
try
{
string sql = $@"SELECT
d.*,
d.full_name AS Device_full_name,
b.full_name AS Building_full_name,
mv.system_key AS Main_system_full_name,
sv.system_key AS Sub_system_full_name,
2022-10-14 16:08:54 +08:00
f.full_name AS Floor_full_name
FROM (
SELECT *
FROM device d
WHERE
d.device_guid = @Device_guid
AND d.deleted = @Deleted
) d
JOIN building b ON d.device_building_tag = b.building_tag
JOIN variable mv ON d.device_system_tag = mv.system_value AND mv.system_type = @main_system_type
JOIN variable sv ON d.device_name_tag = sv.system_value AND sv.system_type = @sub_system_type
JOIN floor f ON d.device_floor_tag = f.full_name
2022-10-14 16:08:54 +08:00
";
object param = new { Deleted = 0, Device_guid = guid, main_system_type = main_system_type, sub_system_type = sub_system_type };
2022-10-14 16:08:54 +08:00
var device = await backendRepository.GetOneAsync<Device>(sql, param);
string sWhere = "Device_guid = @Device_guid";
device.Device_disasters = await backendRepository.GetAllAsync<DeviceDisaster>("device_disaster", sWhere, new { Device_guid = device.Device_guid });
apiResult.Code = "0000";
apiResult.Data = device;
}
catch (Exception exception)
{
apiResult.Code = "9999";
apiResult.Msg = "系統內部錯誤,請聯絡管理者。";
Logger.LogError("【" + controllerName + "/" + actionName + "】" + exception.Message);
}
return apiResult;
}
/// <summary>
/// 取得災害類型
/// </summary>
/// <param name="guid"></param>
/// <returns></returns>
[HttpPost]
public async Task<ApiResult<List<Variable>>> GetDisasterList()
{
ApiResult<List<Variable>> apiResult = new ApiResult<List<Variable>>();
try
{
var sWhere = "system_type = @System_type";
object param = new { System_type = "disaster" };
var variables = await backendRepository.GetAllAsync<Variable>("variable", sWhere, param);
apiResult.Code = "0000";
apiResult.Data = variables;
}
catch (Exception exception)
{
apiResult.Code = "9999";
Logger.LogError("【" + controllerName + "/" + actionName + "】" + exception.Message);
}
return apiResult;
}
/// <summary>
/// 新增 設備基本資料
/// </summary>
/// <param name="post"></param>
/// <returns></returns>
[HttpPost]
public async Task<ApiResult<string>> SaveDeviceInfoAdd(PostDeviceInfoAdd post)
{
ApiResult<string> apiResult = new ApiResult<string>();
try
{
List<Dictionary<string, object>> deviceDics = new List<Dictionary<string, object>>();
List<Dictionary<string, object>> device_disaster_dicts = new List<Dictionary<string, object>>();
PostDeviceKind postDeviceKind = new PostDeviceKind();
2022-10-14 16:08:54 +08:00
using (var reader = new StreamReader(post.SelectedDevicesFile.OpenReadStream()))
{
string content = reader.ReadToEnd();
post.SelectedDevices = JsonSerializer.Deserialize<List<SelcectedDeviceAdd>>(content);
}
foreach (var device in post.SelectedDevices)
{
var guid = Guid.NewGuid();
var split = device.Device_number.Split('_');
var device_area_tag = !string.IsNullOrEmpty(split[0]) ? split[0] : "";
var device_building_tag = !string.IsNullOrEmpty(post.Building_tag) ? post.Building_tag : "";
var device_system_tag = !string.IsNullOrEmpty(post.Main_system_tag) ? post.Main_system_tag : "";
var device_name_tag = !string.IsNullOrEmpty(post.Sub_system_tag) ? post.Sub_system_tag : "";
var device_floor_tag = !string.IsNullOrEmpty(post.Floor_tag) ? post.Floor_tag : "";
var device_last_name = !string.IsNullOrEmpty(split[6]) ? split[6] : "";
var device_serial_tag = !string.IsNullOrEmpty(split[7]) ? split[7] : "";
string device_master = "NA";
2022-10-14 16:08:54 +08:00
//針對燈具加入master
if (device.Device_system_category_layer3 == "L1" || device.Device_system_category_layer3 == "L2")
{
device_master = device_building_tag + device_name_tag;
}
Dictionary<string, object> deviceDic = new Dictionary<string, object>()
{
{ "@device_guid", guid},
{ "@device_area_tag", device_area_tag},
2022-10-14 16:08:54 +08:00
{ "@device_building_tag", device_building_tag},
{ "@device_system_tag", device_system_tag},
{ "@device_floor_tag", device_floor_tag},
{ "@device_name_tag", device_name_tag},
{ "@device_serial_tag", device_serial_tag},
{ "@device_last_name", device_last_name},
2022-10-14 16:08:54 +08:00
{ "@device_master", device_master},
{ "@device_number", device.Device_number},
{ "@device_system_category_layer3", device.Device_system_category_layer3},
{ "@created_by", myUserInfo.Userinfo_guid},
};
postDeviceKind = new PostDeviceKind()
{
Device_building_tag = device_building_tag,
Device_system_tag = device_system_tag,
Device_floor_tag = device_floor_tag,
Device_name_tag = device_name_tag,
};
2022-10-14 16:08:54 +08:00
deviceDics.Add(deviceDic);
if (device.Device_disasters != null)
{
foreach (var device_disasters_str in device.Device_disasters)
{
var device_disasters = device_disasters_str.ToString().Trim().Split(',');
foreach (var dd in device_disasters)
{
Dictionary<string, object> device_disaster_dict = new Dictionary<string, object>()
{
{ "@device_guid", guid },
{ "@device_system_value", dd }
};
device_disaster_dicts.Add(device_disaster_dict);
}
}
}
}
await deviceManageRepository.AddMutiByCustomTable(deviceDics, "device");
if (device_disaster_dicts.Count() > 0)
{
await deviceManageRepository.AddMutiByCustomTable(device_disaster_dicts, "device_disaster");
}
await ResetDeviceGroup(); //重新寫入設備群組
await AddDeviceKind(postDeviceKind);
2022-10-14 16:08:54 +08:00
apiResult.Code = "0000";
apiResult.Msg = "修改成功";
}
catch (Exception exception)
{
apiResult.Code = "9999";
apiResult.Msg = "系統內部錯誤,請聯絡管理者。";
string json = System.Text.Json.JsonSerializer.Serialize(post);
Logger.LogError("【" + controllerName + "/" + actionName + "】" + json);
Logger.LogError("【" + controllerName + "/" + actionName + "】" + exception.Message);
}
return apiResult;
}
/// <summary>
/// 修改 設備基本資料
/// </summary>
/// <param name="post"></param>
/// <returns></returns>
[HttpPost]
public async Task<ApiResult<string>> SaveDeviceInfoEdit(PostDeviceInfoEdit post)
{
ApiResult<string> apiResult = new ApiResult<string>();
try
{
string sWhere = @$"deleted = @Deleted AND device_guid = @Guid";
object param = new { Deleted = 0, Guid = post.Device_guid };
var device = await backendRepository.GetOneAsync<Device>("device", sWhere, param);
if (device == null)
{
apiResult.Code = "9998";
apiResult.Msg = "查無該設備";
}
else
{
string coordinate = null;
if (post.Device_coordinate_x != null && post.Device_coordinate_y != null)
{
coordinate = Math.Round(Convert.ToDouble(post.Device_coordinate_x), 3).ToString() + "," + Math.Round(Convert.ToDouble(post.Device_coordinate_y), 3).ToString();
}
Dictionary<string, object> deviceDic = new Dictionary<string, object>()
{
{ "@full_name", post.Full_name},
{ "@device_coordinate", coordinate},
{ "@device_ip", post.Device_ip},
{ "@device_port", post.Device_port},
{ "@updated_by", myUserInfo.Userinfo_guid},
{ "@updated_at", DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss")},
};
List<Dictionary<string, object>> device_disaster_dicts = new List<Dictionary<string, object>>();
if (post.Device_disasters != null)
{
foreach (var disaster in post.Device_disasters)
{
Dictionary<string, object> device_disaster_dict = new Dictionary<string, object>()
{
{ "device_guid", device.Device_guid},
{ "@device_system_value", disaster},
};
device_disaster_dicts.Add(device_disaster_dict);
}
}
await deviceManageRepository.UpdateOneDeviceInfo(device.Device_guid, deviceDic, device_disaster_dicts);
apiResult.Code = "0000";
apiResult.Msg = "修改成功";
}
}
catch (Exception exception)
{
apiResult.Code = "9999";
apiResult.Msg = "系統內部錯誤,請聯絡管理者。";
string json = System.Text.Json.JsonSerializer.Serialize(post);
Logger.LogError("【" + controllerName + "/" + actionName + "】" + json);
Logger.LogError("【" + controllerName + "/" + actionName + "】" + exception.Message);
}
return apiResult;
}
/// <summary>
/// 軟刪除單一設備
/// </summary>
/// <param name="post"></param>
/// <returns></returns>
[HttpPost]
public async Task<ApiResult<string>> DeleteOneDevice(string guid)
{
ApiResult<string> apiResult = new ApiResult<string>();
try
{
string sWhere = @$"deleted = @Deleted AND device_guid = @Guid";
object param = new { Deleted = 0, Guid = guid };
var device = await backendRepository.GetOneAsync<Device>("device", sWhere, param);
if (device == null)
{
apiResult.Code = "9998";
apiResult.Msg = "查無該設備";
}
else
{
Dictionary<string, object> deviceDic = new Dictionary<string, object>()
{
{ "@deleted", 1},
{ "@updated_by", myUserInfo.Userinfo_guid},
{ "@updated_at", DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss")},
};
await backendRepository.UpdateOneByCustomTable(deviceDic, "device", "device_guid='" + guid + "'");
await ResetDeviceGroup(); //重新寫入設備群組
apiResult.Code = "0000";
apiResult.Msg = "修改成功";
}
}
catch (Exception exception)
{
apiResult.Code = "9999";
apiResult.Msg = "系統內部錯誤,請聯絡管理者。";
Logger.LogError("【" + controllerName + "/" + actionName + "】 GUID = " + guid);
Logger.LogError("【" + controllerName + "/" + actionName + "】" + exception.Message);
}
return apiResult;
}
/// <summary>
/// 修改 設備座標
/// </summary>
/// <param name="post"></param>
/// <returns></returns>
[HttpPost]
public async Task<ApiResult<string>> SaveDeviceCoordinate(PostDeviceCoordinate post)
{
ApiResult<string> apiResult = new ApiResult<string>();
try
{
if (string.IsNullOrEmpty(post.Device_node_guid))
{
//修改設備本身
string sWhere = @$"deleted = @Deleted AND device_guid = @Guid";
object param = new { Deleted = 0, Guid = post.Device_guid };
var device = await backendRepository.GetOneAsync<Device>("device", sWhere, param);
if (device == null)
{
apiResult.Code = "9998";
apiResult.Msg = "查無該設備";
}
else
{
Dictionary<string, object> deviceDic = new Dictionary<string, object>()
{
{ "@device_coordinate", post.Coordinate},
{ "@updated_by", myUserInfo.Userinfo_guid},
{ "@updated_at", DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss")},
};
await backendRepository.UpdateOneByCustomTable(deviceDic, "device", "device_guid='" + post.Device_guid + "'");
apiResult.Code = "0000";
apiResult.Msg = "修改成功";
}
}
else
{
//修改設備子節點本身
string sWhere = @$"deleted = @Deleted AND device_node_guid = @Guid";
object param = new { Deleted = 0, Guid = post.Device_node_guid };
var deviceNode = await backendRepository.GetOneAsync<DeviceNode>("device_node", sWhere, param);
if (deviceNode == null)
{
apiResult.Code = "9998";
apiResult.Msg = "查無該設備子節點";
}
else
{
Dictionary<string, object> deviceNodeDic = new Dictionary<string, object>()
{
{ "@device_node_coordinate", post.Coordinate},
{ "@updated_by", myUserInfo.Userinfo_guid},
{ "@updated_at", DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss")},
};
await backendRepository.UpdateOneByCustomTable(deviceNodeDic, "device_node", "device_node_guid='" + post.Device_node_guid + "'");
apiResult.Code = "0000";
apiResult.Msg = "修改成功";
}
}
}
catch (Exception exception)
{
apiResult.Code = "9999";
apiResult.Msg = "系統內部錯誤,請聯絡管理者。";
string json = System.Text.Json.JsonSerializer.Serialize(post);
Logger.LogError("【" + controllerName + "/" + actionName + "】" + json);
Logger.LogError("【" + controllerName + "/" + actionName + "】" + exception.Message);
}
return apiResult;
}
/// <summary>
/// 取得單一設備子節點資料
/// </summary>
/// <param name="guid"></param>
/// <returns></returns>
[HttpPost]
public async Task<ApiResult<DeviceNode>> GetOneDeviceNode(string guid)
{
ApiResult<DeviceNode> apiResult = new ApiResult<DeviceNode>();
try
{
string sql = $@"SELECT
dn.*,
dn.full_name AS Device_node_full_name
FROM device_node dn
WHERE dn.deleted = @Deleted
AND dn.device_node_guid = @Device_node_guid
";
object param = new { Deleted = 0, Device_node_guid = guid };
var deviceNode = await backendRepository.GetOneAsync<DeviceNode>(sql, param);
apiResult.Code = "0000";
apiResult.Data = deviceNode;
}
catch (Exception exception)
{
apiResult.Code = "9999";
apiResult.Msg = "系統內部錯誤,請聯絡管理者。";
Logger.LogError("【" + controllerName + "/" + actionName + "】" + exception.Message);
}
return apiResult;
}
/// <summary>
/// 新增/儲存 設備子節點資料
/// </summary>
/// <param name="post"></param>
/// <returns></returns>
[HttpPost]
public async Task<ApiResult<string>> SaveDeviceNode(PostDeviceNode post)
{
ApiResult<string> apiResult = new ApiResult<string>();
try
{
string sWhere = @$"deleted = @Deleted AND device_node_guid = @Guid";
object param = new { Deleted = 0, Guid = post.Device_node_guid };
var deviceNode = await backendRepository.GetOneAsync<DeviceNode>("device_node", sWhere, param);
string coordinate = null;
if (post.Device_node_coordinate_x != null && post.Device_node_coordinate_y != null)
{
coordinate = Math.Round(Convert.ToDouble(post.Device_node_coordinate_x), 3).ToString() + "," + Math.Round(Convert.ToDouble(post.Device_node_coordinate_y), 3).ToString();
}
if (deviceNode == null)
{
//產生一組GUID
var guid = Guid.NewGuid(); //大樓GUID
//抓取當前的Priority
var current_priority = await backendRepository.GetCurrentPriority("device_node");
Dictionary<string, object> device_node_dic = new Dictionary<string, object>();
device_node_dic = new Dictionary<string, object>()
{
{ "@device_node_guid", guid},
{ "@device_guid", post.Device_guid},
{ "@full_name", post.Full_name},
{ "@device_node_coordinate", coordinate},
{ "@priority", current_priority + 1},
{ "@created_by", myUserInfo.Userinfo_guid}
};
await backendRepository.AddOneByCustomTable(device_node_dic, "device_node");
apiResult.Code = "0000";
apiResult.Msg = "新增成功";
}
else
{
Dictionary<string, object> deviceNodeDic = new Dictionary<string, object>()
{
{ "@full_name", post.Full_name},
{ "@device_node_coordinate", coordinate},
{ "@updated_by", myUserInfo.Userinfo_guid},
{ "@updated_at", DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss")},
};
await backendRepository.UpdateOneByCustomTable(deviceNodeDic, "device_node", "device_node_guid='" + post.Device_node_guid + "'");
apiResult.Code = "0000";
apiResult.Msg = "修改成功";
}
}
catch (Exception exception)
{
apiResult.Code = "9999";
apiResult.Msg = "系統內部錯誤,請聯絡管理者。";
string json = System.Text.Json.JsonSerializer.Serialize(post);
Logger.LogError("【" + controllerName + "/" + actionName + "】" + json);
Logger.LogError("【" + controllerName + "/" + actionName + "】" + exception.Message);
}
return apiResult;
}
/// <summary>
/// 軟刪除單一設備子節點
/// </summary>
/// <param name="post"></param>
/// <returns></returns>
[HttpPost]
public async Task<ApiResult<string>> DeleteOneDeviceNode(string guid)
{
ApiResult<string> apiResult = new ApiResult<string>();
try
{
string sWhere = @$"deleted = @Deleted AND device_node_guid = @Guid";
object param = new { Deleted = 0, Guid = guid };
var deviceNode = await backendRepository.GetOneAsync<DeviceNode>("device_node", sWhere, param);
if (deviceNode == null)
{
apiResult.Code = "9998";
apiResult.Msg = "查無該設備子節點";
}
else
{
Dictionary<string, object> deviceNodeDic = new Dictionary<string, object>()
{
{ "@deleted", 1},
{ "@updated_by", myUserInfo.Userinfo_guid},
{ "@updated_at", DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss")},
};
await backendRepository.UpdateOneByCustomTable(deviceNodeDic, "device_node", "device_node_guid='" + guid + "'");
apiResult.Code = "0000";
apiResult.Msg = "修改成功";
}
}
catch (Exception exception)
{
apiResult.Code = "9999";
apiResult.Msg = "系統內部錯誤,請聯絡管理者。";
Logger.LogError("【" + controllerName + "/" + actionName + "】 GUID = " + guid);
Logger.LogError("【" + controllerName + "/" + actionName + "】" + exception.Message);
}
return apiResult;
}
/// <summary>
/// 取得設備基本資料清單
/// </summary>
/// <returns></returns>
[HttpPost]
public async Task<ApiResult<List<DeviceImportCheckTempFilter>>> GetDeviceImportCheckTempFilter()
{
ApiResult<List<DeviceImportCheckTempFilter>> apiResult = new ApiResult<List<DeviceImportCheckTempFilter>>();
try
{
var rawDatas = await backendRepository.GetAllAsync<DeviceImportCheckTempRawData>("import_niagara_tag", null, null, "device_building_tag, device_system_tag, device_floor_tag, device_name_tag");
2022-10-14 16:08:54 +08:00
var rawDatas_Group_Building_tag = rawDatas.GroupBy(x => x.Device_building_tag).ToList();
List<DeviceImportCheckTempFilter> tempFilters = new List<DeviceImportCheckTempFilter>();
foreach (var rawData_Building_tag in rawDatas_Group_Building_tag)
{
DeviceImportCheckTempFilter tempFilter = new DeviceImportCheckTempFilter();
tempFilter.Device_building_tag = rawData_Building_tag.Key;
tempFilter.Device_system_tags = new List<ImportTempDeviceSystemTag>();
var rawDatas_Group_System_tag = rawData_Building_tag.GroupBy(x => x.Device_system_tag).ToList();
foreach (var rawData_System_tag in rawDatas_Group_System_tag)
{
ImportTempDeviceSystemTag systemTag = new ImportTempDeviceSystemTag();
systemTag.Device_system_tag = rawData_System_tag.Key;
systemTag.Device_floor_tags = new List<ImportTempDeviceFloorTag>();
var rawDatas_Group_Floor_tag = rawData_System_tag.GroupBy(x => x.Device_floor_tag).ToList();
foreach (var rawData_Floor_tag in rawDatas_Group_Floor_tag)
{
ImportTempDeviceFloorTag floorTag = new ImportTempDeviceFloorTag();
floorTag.Device_floor_tag = rawData_Floor_tag.Key;
floorTag.Device_name_tags = new List<string>();
var rawDatas_Group_Name_tag = rawData_Floor_tag.GroupBy(x => x.Device_name_tag).ToList();
foreach (var rawData_Name_tag in rawDatas_Group_Name_tag)
{
floorTag.Device_name_tags.Add(rawData_Name_tag.Key);
}
systemTag.Device_floor_tags.Add(floorTag);
}
tempFilter.Device_system_tags.Add(systemTag);
}
tempFilters.Add(tempFilter);
}
apiResult.Code = "0000";
apiResult.Data = tempFilters;
}
catch (Exception exception)
{
apiResult.Code = "9999";
apiResult.Msg = "系統內部錯誤,請聯絡管理者。";
Logger.LogError("【" + controllerName + "/" + actionName + "】" + exception.Message);
}
return apiResult;
}
/// <summary>
/// 取得新增設備基本資料modal的設備清單
/// </summary>
/// <returns></returns>
[HttpPost]
public async Task<ApiResult<List<DeviceImportCheckTemp>>> DeviceImportCheckTempTableList(DeviceImportCheckTemp post)
{
ApiResult<List<DeviceImportCheckTemp>> apiResult = new ApiResult<List<DeviceImportCheckTemp>>();
try
{
2022-10-18 18:22:36 +08:00
string sql = @"SELECT
di.device_building_tag,
di.device_system_tag,
di.device_floor_tag,
di.device_last_name_tag as device_name_tag,
di.device_serial_tag,
2022-10-20 17:25:47 +08:00
0 as Device_disasters,
0 as Device_disaster_type_text,
2022-10-18 18:22:36 +08:00
di.niagara_tags as device_number
FROM
(
SELECT
*
FROM
import_niagara_tag intag
WHERE
device_building_tag = @Device_building_tag
AND device_system_tag = @Device_system_tag
AND device_floor_tag = @Device_floor_tag
AND device_name_tag = @Device_name_tag
AND convert(intag.niagara_tags, nchar) NOT IN ( SELECT convert(d.device_number, nchar) FROM device d WHERE d.deleted = 0 )
) di
GROUP BY
di.device_building_tag,
di.device_system_tag,
di.device_floor_tag,
di.device_last_name_tag,
di.device_serial_tag,
di.niagara_tags";
2022-10-14 16:08:54 +08:00
var deviceImports = await backendRepository.GetAllAsync<DeviceImportCheckTemp>(sql, post);
apiResult.Code = "0000";
apiResult.Data = deviceImports;
}
catch (Exception exception)
{
apiResult.Code = "9999";
apiResult.Msg = "系統內部錯誤,請聯絡管理者。";
Logger.LogError("【" + controllerName + "/" + actionName + "】" + exception.Message);
}
return apiResult;
}
/// <summary>
/// 取得設備基本資料清單
/// </summary>
/// <returns></returns>
[HttpPost]
public async Task<ApiResult<List<DeviceKind>>> DeviceKindTableList(PostDeviceFilter post)
{
ApiResult<List<DeviceKind>> apiResult = new ApiResult<List<DeviceKind>>();
try
{
var sql = $@"SELECT
dk.device_kind_guid,
dd.device_building_tag,
dd.device_system_tag,
-- dd.device_floor_tag,
dd.device_name_tag,
dk.device_image,
dk.device_normal_text,
dk.device_normal_point_name,
dk.device_normal_point_col,
dk.device_normal_point_value,
dk.device_normal_color,
dk.device_normal_flashing,
dk.device_close_text,
dk.device_close_point_name,
dk.device_close_point_col,
dk.device_close_point_value,
dk.device_close_color,
dk.device_close_flashing,
dk.device_error_text,
dk.device_error_point_name,
dk.device_error_point_col,
dk.device_error_point_value,
dk.device_error_color,
dk.device_error_flashing,
dk.device_error_independent,
dk.device_model_tag
FROM ( SELECT
d.device_building_tag,
d.device_system_tag,
-- d.device_floor_tag,
d.device_name_tag
FROM (
SELECT *
FROM device d
WHERE
d.device_building_tag = @building_tag
AND d.device_system_tag = @device_system_tag
AND d.device_name_tag = @device_name_tag
-- AND d.floor_guid = @Floor_tag
AND d.deleted = 0
) d
GROUP BY d.device_building_tag,
d.device_system_tag,
-- d.device_floor_tag,
d.device_name_tag) dd
LEFT JOIN device_kind dk ON dd.device_building_tag = dk.device_building_tag
AND dd.device_system_tag = dk.device_system_tag
-- AND dd.device_floor_tag = dk.device_floor_tag
AND dd.device_name_tag = dk.device_name_tag
and dk.is_link = 1";
2022-10-14 16:08:54 +08:00
var deviceKinds = await backendRepository.GetAllAsync<DeviceKind>(sql, post);
apiResult.Code = "0000";
apiResult.Data = deviceKinds;
}
catch (Exception exception)
{
apiResult.Code = "9999";
apiResult.Msg = "系統內部錯誤,請聯絡管理者。";
Logger.LogError("【" + controllerName + "/" + actionName + "】" + exception.Message);
}
return apiResult;
}
/// <summary>
/// 取得單一設備種類
/// </summary>
/// <param name="guid"></param>
/// <returns></returns>
[HttpPost]
public async Task<ApiResult<DeviceKind>> GetOneDevicekind(string guid)
{
ApiResult<DeviceKind> apiResult = new ApiResult<DeviceKind>();
try
{
string sWhere = "device_kind_guid = @Device_kind_guid and is_link = 1";
2022-10-14 16:08:54 +08:00
object param = new { Deleted = 0, Device_kind_guid = guid };
var deviceKind = await backendRepository.GetOneAsync<DeviceKind>("device_kind", sWhere, param);
apiResult.Code = "0000";
apiResult.Data = deviceKind;
}
catch (Exception exception)
{
apiResult.Code = "9999";
apiResult.Msg = "系統內部錯誤,請聯絡管理者。";
Logger.LogError("【" + controllerName + "/" + actionName + "】" + exception.Message);
}
return apiResult;
}
public async Task AddDeviceKind(PostDeviceKind post)
{
string sWhere = @$"device_building_tag = @building_tag and device_system_tag = @system_tag and device_name_tag = @name_tag";
object param = new { building_tag = post.Device_building_tag, system_tag = post.Device_system_tag, name_tag = post.Device_name_tag };
var deviceKind = await backendRepository.GetOneAsync<DeviceKind>("device_kind", sWhere, param);
if (deviceKind == null)
{
//新增
//產生一組GUID
var guid = Guid.NewGuid();
//抓出點位名稱
//var point_name = new PointName();
//var sql_device_normal_point = @"SELECT n.points AS device_normal_point_name FROM (SELECT * FROM device_item di WHERE di.device_item_id = @device_normal_point_guid) n";
//point_name.Device_normal_point_name = await backendRepository.GetOneAsync<string>(sql_device_normal_point, new { device_normal_point_guid = post.Device_normal_point_guid });
//var sql_device_close_point = @"SELECT c.points AS device_close_point_name FROM (SELECT * FROM device_item di WHERE di.device_item_guid = @device_close_point_guid) c";
//point_name.Device_close_point_name = await backendRepository.GetOneAsync<string>(sql_device_close_point, new { device_close_point_guid = post.Device_close_point_guid });
//var sql_device_error_point = @"SELECT e.points AS device_error_point_name FROM (SELECT * FROM device_item di WHERE di.device_item_guid = @device_error_point_guid) e";
//point_name.Device_error_point_name = await backendRepository.GetOneAsync<string>(sql_device_error_point, new { device_error_point_guid = post.Device_error_point_guid });
Dictionary<string, object> deviceKindDic = new Dictionary<string, object>()
{
{ "@device_kind_guid", guid},
{ "@device_building_tag", post.Device_building_tag},
{ "@device_system_tag", post.Device_system_tag},
//{ "@device_floor_tag", post.Device_floor_tag},
{ "@device_name_tag", post.Device_name_tag},
{ "@device_image", null },
{ "@device_normal_text", post.Device_normal_text},
{ "@device_normal_point_guid", post.Device_normal_point_guid},
{ "@device_normal_point_name", null},
{ "@device_normal_point_col", post.Device_normal_point_col},
{ "@device_normal_point_value", post.Device_normal_point_value},
{ "@device_normal_color", post.Device_normal_color},
{ "@device_normal_flashing", post.Device_normal_flashing},
{ "@device_close_text", post.Device_close_text},
{ "@device_close_point_guid", post.Device_close_point_guid},
{ "@device_close_point_name", null},
{ "@device_close_point_col", post.Device_close_point_col},
{ "@device_close_point_value", post.Device_close_point_value},
{ "@device_close_color", post.Device_close_color},
{ "@device_close_flashing", post.Device_close_flashing},
{ "@device_error_text", post.Device_error_text},
{ "@device_error_point_guid", post.Device_error_point_guid},
{ "@device_error_point_name", null},
{ "@device_error_point_col", post.Device_error_point_col},
{ "@device_error_point_value", post.Device_error_point_value},
{ "@device_error_color", post.Device_error_color},
{ "@device_error_flashing", post.Device_error_flashing},
{ "@device_error_independent", post.Device_error_independent},
{ "@is_link", 1},
{ "@created_by", myUserInfo.Userinfo_guid}
};
await backendRepository.AddOneByCustomTable(deviceKindDic, "device_kind");
}
}
2022-10-14 16:08:54 +08:00
/// <summary>
/// 修改 設備基本資料
/// </summary>
/// <param name="post"></param>
/// <returns></returns>
[HttpPost]
public async Task<ApiResult<string>> SaveDeviceKind(PostDeviceKind post)
{
ApiResult<string> apiResult = new ApiResult<string>();
try
{
string sWhere = @$"device_kind_guid = @Guid";
object param = new { Guid = post.Device_kind_guid };
var deviceKind = await backendRepository.GetOneAsync<DeviceKind>("device_kind", sWhere, param);
if (deviceKind == null)
{
//新增
//產生一組GUID
var guid = Guid.NewGuid();
var image_name = string.Empty;
var split_image = new string[0];
if (post.Device_image_file != null)
{
split_image = post.Device_image_file.FileName.Split(".");
image_name = guid + "." + split_image[split_image.Length - 1];
}
//抓出點位名稱
var point_name = new PointName();
var sql_device_normal_point = @"SELECT n.points AS device_normal_point_name FROM (SELECT * FROM device_item di WHERE di.id = @device_normal_point_id) n";
point_name.Device_normal_point_name = await backendRepository.GetOneAsync<string>(sql_device_normal_point, new { device_normal_point_id = post.Device_normal_point_guid });
2022-10-14 16:08:54 +08:00
var sql_device_close_point = @"SELECT c.points AS device_close_point_name FROM (SELECT * FROM device_item di WHERE di.id = @device_close_point_id) c";
point_name.Device_close_point_name = await backendRepository.GetOneAsync<string>(sql_device_close_point, new { device_close_point_id = post.Device_close_point_guid });
2022-10-14 16:08:54 +08:00
var sql_device_error_point = @"SELECT e.points AS device_error_point_name FROM (SELECT * FROM device_item di WHERE di.id = @device_error_point_id) e";
point_name.Device_error_point_name = await backendRepository.GetOneAsync<string>(sql_device_error_point, new { device_error_point_id = post.Device_error_point_guid });
2022-10-14 16:08:54 +08:00
Dictionary<string, object> deviceKindDic = new Dictionary<string, object>()
{
{ "@device_kind_guid", guid},
{ "@device_building_tag", post.Device_building_tag},
{ "@device_system_tag", post.Device_system_tag},
//{ "@device_floor_tag", post.Device_floor_tag},
{ "@device_name_tag", post.Device_name_tag},
{ "@device_image", image_name },
{ "@device_normal_text", post.Device_normal_text},
{ "@device_normal_point_guid", post.Device_normal_point_guid},
{ "@device_normal_point_name", point_name.Device_normal_point_name},
{ "@device_normal_point_col", post.Device_normal_point_col},
{ "@device_normal_point_value", post.Device_normal_point_value},
{ "@device_normal_color", post.Device_normal_color},
{ "@device_normal_flashing", post.Device_normal_flashing},
{ "@device_close_text", post.Device_close_text},
{ "@device_close_point_guid", post.Device_close_point_guid},
{ "@device_close_point_name", point_name.Device_close_point_name},
{ "@device_close_point_col", post.Device_close_point_col},
{ "@device_close_point_value", post.Device_close_point_value},
{ "@device_close_color", post.Device_close_color},
{ "@device_close_flashing", post.Device_close_flashing},
{ "@device_error_text", post.Device_error_text},
{ "@device_error_point_guid", post.Device_error_point_guid},
{ "@device_error_point_name", point_name.Device_error_point_name},
{ "@device_error_point_col", post.Device_error_point_col},
{ "@device_error_point_value", post.Device_error_point_value},
{ "@device_error_color", post.Device_error_color},
{ "@device_error_flashing", post.Device_error_flashing},
{ "@device_error_independent", post.Device_error_independent},
{ "@is_link", 1},
2022-10-14 16:08:54 +08:00
{ "@created_by", myUserInfo.Userinfo_guid}
};
await backendRepository.AddOneByCustomTable(deviceKindDic, "device_kind");
if (post.Device_image_file != null)
{
var split = post.Device_image_file.FileName.Split(".");
var fileName = guid + "." + split[split.Length - 1];
var fullPath = Path.Combine(deviceKindFileSaveAsPath, fileName);
using (var stream = new FileStream(fullPath, FileMode.Create))
{
post.Device_image_file.CopyTo(stream);
}
2023-10-26 16:11:23 +08:00
2023-11-23 17:13:24 +08:00
var frontendPath = await backendRepository.GetOneAsync<string>("select system_value from variable where system_type = 'directory_device_icon' and system_key = 'frontend'");
2023-10-26 16:11:23 +08:00
2023-11-23 17:13:24 +08:00
fullPath = frontendPath;
2023-10-26 16:11:23 +08:00
if (!System.IO.Directory.Exists(fullPath))
System.IO.Directory.CreateDirectory(fullPath);
fullPath = Path.Combine(fullPath, fileName);
using (var stream = new FileStream(fullPath, FileMode.Create))
{
post.Device_image_file.CopyTo(stream);
}
2022-10-14 16:08:54 +08:00
}
#region
//List<Repository.Models.FileInfo> fileInfos = new List<Repository.Models.FileInfo>();
//if (post.Device_image_file != null)
//{
// var split = post.Device_image_file.FileName.Split(".");
// var fileName = guid + "." + split[split.Length - 1];
// var fullPath = Path.Combine(deviceKindFileSaveAsPath, fileName);
// Repository.Models.FileInfo fileInfo = new Repository.Models.FileInfo();
// fileInfo.Folder = "device_icon";
// fileInfo.OriginalFileName = null;
// fileInfo.FileName = fileName;
// fileInfo.File = fullPath;
// fileInfos.Add(fileInfo);
// await backendRepository.ManualInsertFileBackgroundServiceTask("", "", "device_kind", fileInfos);
//}
2022-10-14 16:08:54 +08:00
#endregion
apiResult.Code = "0000";
apiResult.Msg = "新增成功";
}
else
{
var image_name = string.Empty;
var image_guid = Guid.NewGuid();
var split_image = new string[0];
if (post.Device_image_file != null)
{
split_image = post.Device_image_file.FileName.Split(".");
image_name = image_guid + "." + split_image[split_image.Length - 1];
}
else
{
image_name = deviceKind.Device_image;
}
//抓出點位名稱
var point_name = new PointName();
var sql_device_normal_point = @"SELECT n.points AS device_normal_point_name FROM (SELECT * FROM device_item di WHERE di.id = @device_normal_point_id) n";
point_name.Device_normal_point_name = await backendRepository.GetOneAsync<string>(sql_device_normal_point, new { device_normal_point_id = post.Device_normal_point_guid });
2022-10-14 16:08:54 +08:00
var sql_device_close_point = @"SELECT c.points AS device_close_point_name FROM (SELECT * FROM device_item di WHERE di.id = @device_close_point_id) c";
point_name.Device_close_point_name = await backendRepository.GetOneAsync<string>(sql_device_close_point, new { device_close_point_id = post.Device_close_point_guid });
2022-10-14 16:08:54 +08:00
var sql_device_error_point = @"SELECT e.points AS device_error_point_name FROM (SELECT * FROM device_item di WHERE di.id = @device_error_point_id) e";
point_name.Device_error_point_name = await backendRepository.GetOneAsync<string>(sql_device_error_point, new { device_error_point_id = post.Device_error_point_guid });
2022-10-14 16:08:54 +08:00
Dictionary<string, object> deviceKindDic = new Dictionary<string, object>()
{
{ "@device_image", image_name},
{ "@device_normal_text", post.Device_normal_text},
{ "@device_normal_point_guid", post.Device_normal_point_guid},
{ "@device_normal_point_name", point_name != null? point_name.Device_normal_point_name : null},
{ "@device_normal_point_col", post.Device_normal_point_col},
{ "@device_normal_point_value", post.Device_normal_point_value},
{ "@device_normal_color", post.Device_normal_color},
{ "@device_normal_flashing", post.Device_normal_flashing},
{ "@device_close_text", post.Device_close_text},
{ "@device_close_point_guid", post.Device_close_point_guid},
{ "@device_close_point_name", point_name != null? point_name.Device_close_point_name : null},
{ "@device_close_point_col", post.Device_close_point_col},
{ "@device_close_point_value", post.Device_close_point_value},
{ "@device_close_color", post.Device_close_color},
{ "@device_close_flashing", post.Device_close_flashing},
{ "@device_error_text", post.Device_error_text},
{ "@device_error_point_guid", post.Device_error_point_guid},
{ "@device_error_point_name", point_name != null? point_name.Device_error_point_name : null},
{ "@device_error_point_col", post.Device_error_point_col},
{ "@device_error_point_value", post.Device_error_point_value},
{ "@device_error_color", post.Device_error_color},
{ "@device_error_flashing", post.Device_error_flashing},
{ "@device_error_independent", post.Device_error_independent},
{ "@updated_by", myUserInfo.Userinfo_guid},
{ "@updated_at", DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss")}
};
await backendRepository.UpdateOneByCustomTable(deviceKindDic, "device_kind", "device_kind_guid='" + deviceKind.Device_kind_guid + "'");
if (post.Device_image_file != null)
{
//刪除原本的檔案
FolderFunction folderFunction = new FolderFunction();
if (deviceKind.Device_image != null) {
folderFunction.DeleteFile(Path.Combine(deviceKindFileSaveAsPath, deviceKind.Device_image));
}
2022-10-14 16:08:54 +08:00
var split = post.Device_image_file.FileName.Split(".");
var fileName = image_guid + "." + split[split.Length - 1];
var fullPath = Path.Combine(deviceKindFileSaveAsPath, fileName);
using (var stream = new FileStream(fullPath, FileMode.Create))
{
post.Device_image_file.CopyTo(stream);
}
2023-10-26 16:11:23 +08:00
2023-11-23 17:13:24 +08:00
var frontendPath = await backendRepository.GetOneAsync<string>("select system_value from variable where system_type = 'directory_device_icon' and system_key = 'frontend'");
2023-10-26 16:11:23 +08:00
2023-11-23 17:13:24 +08:00
fullPath = frontendPath;
2023-10-26 16:11:23 +08:00
if (!System.IO.Directory.Exists(fullPath))
System.IO.Directory.CreateDirectory(fullPath);
fullPath = Path.Combine(fullPath, fileName);
using (var stream = new FileStream(fullPath, FileMode.Create))
{
post.Device_image_file.CopyTo(stream);
}
2022-10-14 16:08:54 +08:00
}
#region
//List<Repository.Models.FileInfo> fileInfos = new List<Repository.Models.FileInfo>();
//if (post.Device_image_file != null)
//{
// var split = post.Device_image_file.FileName.Split(".");
// var fileName = image_guid + "." + split[split.Length - 1];
// var fullPath = Path.Combine(deviceKindFileSaveAsPath, fileName);
// Repository.Models.FileInfo fileInfo = new Repository.Models.FileInfo();
// fileInfo.Folder = "device_icon";
// fileInfo.OriginalFileName = deviceKind.Device_image;
// fileInfo.FileName = fileName;
// fileInfo.File = fullPath;
// fileInfos.Add(fileInfo);
// await backendRepository.ManualInsertFileBackgroundServiceTask("", "", "device_kind", fileInfos);
//}
2022-10-14 16:08:54 +08:00
#endregion
apiResult.Code = "0000";
apiResult.Msg = "修改成功";
}
}
catch (Exception exception)
{
apiResult.Code = "9999";
apiResult.Msg = "系統內部錯誤,請聯絡管理者。";
string json = System.Text.Json.JsonSerializer.Serialize(post);
Logger.LogError("【" + controllerName + "/" + actionName + "】" + json);
Logger.LogError("【" + controllerName + "/" + actionName + "】" + exception.Message);
}
return apiResult;
}
private async Task ResetDeviceGroup()
{
//先刪除整個device_group
var delete_group_sql = @"DROP TABLE IF EXISTS `device_group` ;
2022-10-19 13:24:45 +08:00
CREATE TABLE `device_group` (
`id` int(11) NOT NULL AUTO_INCREMENT,
2022-10-19 13:24:45 +08:00
`device_disaster` varchar(50) CHARACTER SET utf8mb4 COLLATE utf8mb4_unicode_ci DEFAULT NULL COMMENT '',
`device_building_tag` varchar(36) CHARACTER SET utf8mb4 COLLATE utf8mb4_unicode_ci DEFAULT NULL COMMENT 'guid',
2022-10-19 13:24:45 +08:00
`device_floor_guid` varchar(36) CHARACTER SET utf8mb4 COLLATE utf8mb4_unicode_ci DEFAULT NULL COMMENT 'guid',
`device_area_tag` varchar(50) CHARACTER SET utf8mb4 COLLATE utf8mb4_unicode_ci DEFAULT NULL COMMENT '',
`device_system_category_layer2` varchar(50) CHARACTER SET utf8mb4 COLLATE utf8mb4_unicode_ci DEFAULT NULL COMMENT 'device_system_tag',
`device_system_category_layer3` varchar(50) CHARACTER SET utf8mb4 COLLATE utf8mb4_unicode_ci DEFAULT NULL COMMENT 'device_name_tag',
`device_amount` int(11) NOT NULL DEFAULT '0' COMMENT '',
PRIMARY KEY (`id`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_unicode_ci COMMENT=' - UI ';";
2022-10-14 16:08:54 +08:00
await backendRepository.ExecuteSql(delete_group_sql);
//更新整個device_group
var insert_group_sql = @"
INSERT INTO device_group (device_disaster, device_building_tag, device_floor_guid, device_system_category_layer2, device_system_category_layer3, device_amount)
2022-10-14 16:08:54 +08:00
SELECT
dd.device_system_value AS device_disaster,
d.device_building_tag AS device_building_tag,
f.floor_guid AS device_floor_guid,
2022-10-14 16:08:54 +08:00
vv.device_system_category_layer2 AS device_system_category_layer2,
d.device_system_category_layer3 AS device_system_category_layer3,
count(*) AS device_amount
FROM device d
JOIN device_disaster dd ON d.device_guid = dd.device_guid
JOIN floor f ON d.device_floor_tag = f.full_name
2022-10-14 16:08:54 +08:00
JOIN (SELECT
v.system_value AS device_system_category_layer3,
v2.system_value AS device_system_category_layer2
FROM variable v
LEFT JOIN variable v2 ON v.system_parent_id = v2.id
WHERE v.system_type = 'device_system_category_layer3'
) vv ON d.device_system_category_layer3 = vv.device_system_category_layer3
WHERE d.deleted = 0
GROUP BY dd.device_system_value,
d.device_building_tag,
f.floor_guid,
2022-10-14 16:08:54 +08:00
vv.device_system_category_layer2,
d.device_system_category_layer3";
await backendRepository.ExecuteSql(insert_group_sql);
#region
var deviceGroups = await backendRepository.GetAllAsync<DeviceGroup>("device_group", "");
List<Dictionary<string, object>> deviceGroupsDics = new List<Dictionary<string, object>>();
foreach (var deviceGroup in deviceGroups)
{
Dictionary<string, object> deviceGroupDic = new Dictionary<string, object>()
{
{ "@id", deviceGroup.id},
{ "@device_disaster", deviceGroup.device_disaster},
{ "@device_building_tag", deviceGroup.device_building_tag},
{ "@device_floor_guid", deviceGroup.device_floor_tag},
2022-10-14 16:08:54 +08:00
{ "@device_system_category_layer2", deviceGroup.device_system_category_layer2},
{ "@device_system_category_layer3", deviceGroup.device_system_category_layer3},
{ "@device_amount", deviceGroup.device_amount},
};
deviceGroupsDics.Add(deviceGroupDic);
}
2022-10-14 16:08:54 +08:00
#endregion
}
/// <summary>
/// 取得設備Master清單
/// </summary>
/// <returns></returns>
[HttpPost]
public async Task<ApiResult<List<DeviceMaster>>> GetDeviceMasterTableList(PostDeviceFilter post)
{
ApiResult<List<DeviceMaster>> apiResult = new ApiResult<List<DeviceMaster>>();
try
{
var sql = $@"SELECT
dm.device_master_guid,
dd.device_building_tag,
dd.device_name_tag,
dm.device_master_number,
dm.device_master_full_name,
dm.device_master_icon
FROM ( SELECT
d.device_building_tag,
d.device_name_tag
FROM (
SELECT *
FROM device d
WHERE
d.device_building_tag = @building_tag
AND d.device_system_tag = @main_system_tag
AND d.device_name_tag = @sub_system_tag
AND d.device_floor_tag = @floor_tag
AND d.deleted = 0
) d
GROUP BY d.device_building_tag, d.device_name_tag) dd
LEFT JOIN device_master dm ON dd.device_building_tag = dm.device_building_tag
AND dd.device_name_tag = dm.device_name_tag";
2022-10-14 16:08:54 +08:00
var deviceMasters = await backendRepository.GetAllAsync<DeviceMaster>(sql, post);
apiResult.Code = "0000";
apiResult.Data = deviceMasters;
}
catch (Exception exception)
{
apiResult.Code = "9999";
apiResult.Msg = "系統內部錯誤,請聯絡管理者。";
Logger.LogError("【" + controllerName + "/" + actionName + "】" + exception.Message);
}
return apiResult;
}
/// <summary>
/// 取得單一設備master
/// </summary>
/// <param name="guid"></param>
/// <returns></returns>
[HttpPost]
public async Task<ApiResult<DeviceMaster>> GetOneDeviceMaster(string guid)
{
ApiResult<DeviceMaster> apiResult = new ApiResult<DeviceMaster>();
try
{
string sWhere = "device_master_guid = @Device_master_guid";
object param = new { Device_master_guid = guid };
2022-10-14 16:08:54 +08:00
var deviceMaster = await backendRepository.GetOneAsync<DeviceMaster>("device_master", sWhere, param);
apiResult.Code = "0000";
apiResult.Data = deviceMaster;
}
catch (Exception exception)
{
apiResult.Code = "9999";
apiResult.Msg = "系統內部錯誤,請聯絡管理者。";
Logger.LogError("【" + controllerName + "/" + actionName + "】" + exception.Message);
}
return apiResult;
}
/// <summary>
/// 修改 設備基本資料
/// </summary>
/// <param name="post"></param>
/// <returns></returns>
[HttpPost]
public async Task<ApiResult<string>> SaveDeviceMaster(PostDeviceMaster post)
{
ApiResult<string> apiResult = new ApiResult<string>();
try
{
string sWhere = @$"device_master_guid = @Guid";
object param = new { Guid = post.Device_master_guid };
var deviceMaster = await backendRepository.GetOneAsync<DeviceMaster>("device_master", sWhere, param);
if (deviceMaster == null)
{
//新增
//產生一組GUID
var guid = Guid.NewGuid();
var image_name = string.Empty;
var split_image = new string[0];
if (post.Device_master_icon_file != null)
{
split_image = post.Device_master_icon_file.FileName.Split(".");
image_name = guid + "." + split_image[split_image.Length - 1];
}
string temp_device_master_number = null;
if (!string.IsNullOrEmpty(post.Device_building_tag) && !string.IsNullOrEmpty(post.Device_name_tag))
2022-10-14 16:08:54 +08:00
{
temp_device_master_number = post.Device_building_tag + "_" + post.Device_name_tag;
}
Dictionary<string, object> deviceMasterDic = new Dictionary<string, object>()
{
{ "@device_master_guid", guid},
{ "@device_building_tag", post.Device_building_tag},
{ "@device_name_tag", post.Device_name_tag},
{ "@device_master_number", temp_device_master_number},
{ "@device_master_full_name", post.Device_master_full_name},
{ "@device_master_icon", image_name },
{ "@created_by", myUserInfo.Userinfo_guid}
};
await backendRepository.AddOneByCustomTable(deviceMasterDic, "device_master");
if (post.Device_master_icon_file != null)
{
var split = post.Device_master_icon_file.FileName.Split(".");
var fileName = guid + "." + split[split.Length - 1];
var fullPath = Path.Combine(deviceKindFileSaveAsPath, fileName);
using (var stream = new FileStream(fullPath, FileMode.Create))
{
post.Device_master_icon_file.CopyTo(stream);
}
2023-10-26 16:11:23 +08:00
2023-11-23 17:13:24 +08:00
var frontendPath = await backendRepository.GetOneAsync<string>("select system_value from variable where system_type = 'directory_device_master' and system_key = 'frontend'");
2023-10-26 16:11:23 +08:00
2023-11-23 17:13:24 +08:00
fullPath = frontendPath;
2023-10-26 16:11:23 +08:00
if (!System.IO.Directory.Exists(fullPath))
System.IO.Directory.CreateDirectory(fullPath);
fullPath = Path.Combine(fullPath, fileName);
using (var stream = new FileStream(fullPath, FileMode.Create))
{
post.Device_master_icon_file.CopyTo(stream);
}
2022-10-14 16:08:54 +08:00
}
#region
List<Repository.Models.FileInfo> fileInfos = new List<Repository.Models.FileInfo>();
if (post.Device_master_icon_file != null)
{
var split = post.Device_master_icon_file.FileName.Split(".");
var fileName = guid + "." + split[split.Length - 1];
var fullPath = Path.Combine(deviceKindFileSaveAsPath, fileName);
Repository.Models.FileInfo fileInfo = new Repository.Models.FileInfo();
fileInfo.Folder = "device_icon";
fileInfo.OriginalFileName = null;
fileInfo.FileName = fileName;
fileInfo.File = fullPath;
fileInfos.Add(fileInfo);
await backendRepository.ManualInsertFileBackgroundServiceTask("", "", "device_master", fileInfos);
}
#endregion
apiResult.Code = "0000";
apiResult.Msg = "新增成功";
}
else
{
var image_name = string.Empty;
var image_guid = Guid.NewGuid();
var split_image = new string[0];
if (post.Device_master_icon_file != null)
{
split_image = post.Device_master_icon_file.FileName.Split(".");
image_name = image_guid + "." + split_image[split_image.Length - 1];
}
else
{
image_name = deviceMaster.Device_master_icon;
}
Dictionary<string, object> deviceMasterDic = new Dictionary<string, object>()
{
{ "@device_master_icon", image_name},
{ "@device_master_full_name", post.Device_master_full_name},
{ "@updated_by", myUserInfo.Userinfo_guid},
{ "@updated_at", DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss")}
};
await backendRepository.UpdateOneByCustomTable(deviceMasterDic, "device_master", "device_master_guid='" + deviceMaster.Device_master_guid + "'");
if (post.Device_master_icon_file != null)
{
//刪除原本的檔案
FolderFunction folderFunction = new FolderFunction();
folderFunction.DeleteFile(Path.Combine(deviceKindFileSaveAsPath, deviceMaster.Device_master_icon));
var split = post.Device_master_icon_file.FileName.Split(".");
var fileName = image_guid + "." + split[split.Length - 1];
var fullPath = Path.Combine(deviceKindFileSaveAsPath, fileName);
using (var stream = new FileStream(fullPath, FileMode.Create))
{
2023-10-26 16:11:23 +08:00
post.Device_master_icon_file.CopyTo(stream);
}
2023-11-23 17:13:24 +08:00
var frontendPath = await backendRepository.GetOneAsync<string>("select system_value from variable where system_type = 'directory_device_master' and system_key = 'frontend'");
2023-10-26 16:11:23 +08:00
2023-11-23 17:13:24 +08:00
fullPath = frontendPath;
2023-10-26 16:11:23 +08:00
if (!System.IO.Directory.Exists(fullPath))
System.IO.Directory.CreateDirectory(fullPath);
fullPath = Path.Combine(fullPath, fileName);
using (var stream = new FileStream(fullPath, FileMode.Create))
{
2022-10-14 16:08:54 +08:00
post.Device_master_icon_file.CopyTo(stream);
}
}
#region
List<Repository.Models.FileInfo> fileInfos = new List<Repository.Models.FileInfo>();
if (post.Device_master_icon_file != null)
{
var split = post.Device_master_icon_file.FileName.Split(".");
var fileName = image_guid + "." + split[split.Length - 1];
var fullPath = Path.Combine(deviceKindFileSaveAsPath, fileName);
Repository.Models.FileInfo fileInfo = new Repository.Models.FileInfo();
fileInfo.Folder = "device_icon";
fileInfo.OriginalFileName = deviceMaster.Device_master_icon;
fileInfo.FileName = fileName;
fileInfo.File = fullPath;
fileInfos.Add(fileInfo);
await backendRepository.ManualInsertFileBackgroundServiceTask("", "", "device_kind", fileInfos);
}
#endregion
apiResult.Code = "0000";
apiResult.Msg = "修改成功";
}
}
catch (Exception exception)
{
apiResult.Code = "9999";
apiResult.Msg = "系統內部錯誤,請聯絡管理者。";
string json = System.Text.Json.JsonSerializer.Serialize(post);
Logger.LogError("【" + controllerName + "/" + actionName + "】" + json);
Logger.LogError("【" + controllerName + "/" + actionName + "】" + exception.Message);
}
return apiResult;
}
/// <summary>
/// 取得子系統的device item
/// </summary>
/// <param name="input"></param>
2022-10-14 16:08:54 +08:00
/// <returns></returns>
[HttpPost]
public async Task<ApiResult<List<Device_item>>> GetDeviceItem(DeviceItemInput input)
2022-10-14 16:08:54 +08:00
{
ApiResult<List<Device_item>> apiResult = new ApiResult<List<Device_item>>();
try
{
string sWhere = "deleted = 0 AND device_name_tag = @Sub_system_tag and device_building_tag = @device_building_tag and is_link = 1 and is_controll = 1";
2022-10-14 16:08:54 +08:00
object param = new { Sub_system_tag = input.sub_system_tag, device_building_tag = input.building_tag };
2022-10-14 16:08:54 +08:00
var deviceItems = await backendRepository.GetAllAsync<Device_item>("device_item", sWhere, param);
apiResult.Code = "0000";
apiResult.Data = deviceItems;
}
catch (Exception exception)
{
apiResult.Code = "9999";
apiResult.Msg = "系統內部錯誤,請聯絡管理者。";
Logger.LogError("【" + controllerName + "/" + actionName + "】" + exception.Message);
}
return apiResult;
}
}
}