ibms-dome/Backend/Controllers/SystemCategoryController.cs

862 lines
39 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.Linq;
using System.Text;
2022-10-14 16:08:54 +08:00
using System.Threading.Tasks;
namespace Backend.Controllers
{
public class SystemCategoryController : MybaseController<SystemCategoryController>
{
private readonly IBackendRepository backendRepository;
public SystemCategoryController(IBackendRepository backendRepository)
{
this.backendRepository = backendRepository;
}
public IActionResult Index()
{
return View();
}
/// <summary>
/// 取得系統大類清單
/// </summary>
/// <returns></returns>
[HttpPost]
2022-10-20 17:25:47 +08:00
public async Task<ApiResult<List<VariableInfo>>> SystemMainList()
2022-10-14 16:08:54 +08:00
{
2022-10-20 17:25:47 +08:00
ApiResult<List<VariableInfo>> apiResult = new ApiResult<List<VariableInfo>>();
2022-10-14 16:08:54 +08:00
try
{
2022-10-20 17:25:47 +08:00
var sWhere = "deleted = 0 AND system_type = @System_type";
2022-10-14 16:08:54 +08:00
2022-10-21 19:40:38 +08:00
var param = new { System_type = main_system_type };
2022-10-20 17:25:47 +08:00
var systemMainList = await backendRepository.GetAllAsync<VariableInfo>("variable", sWhere, param, "system_priority ASC, created_at DESC");
2022-10-14 16:08:54 +08:00
apiResult.Code = "0000";
apiResult.Data = systemMainList;
}
catch (Exception exception)
{
apiResult.Code = "9999";
Logger.LogError("【" + controllerName + "/" + actionName + "】" + exception.Message);
}
return apiResult;
}
/// <summary>
/// 取得單一系統大類
/// </summary>
/// <param name="guid"></param>
/// <returns></returns>
[HttpPost]
2022-10-20 17:25:47 +08:00
public async Task<ApiResult<VariableInfo>> GetOneSystemMain(int id)
2022-10-14 16:08:54 +08:00
{
2022-10-20 17:25:47 +08:00
ApiResult<VariableInfo> apiResult = new ApiResult<VariableInfo>();
2022-10-14 16:08:54 +08:00
try
{
2022-10-20 17:25:47 +08:00
string sWhere = @$"deleted = @Deleted AND id = @id";
2022-10-14 16:08:54 +08:00
2022-10-20 17:25:47 +08:00
object param = new { Deleted = 0, id = id};
2022-10-14 16:08:54 +08:00
2022-10-20 17:25:47 +08:00
var systemMain = await backendRepository.GetOneAsync<VariableInfo>("variable", sWhere, param);
2022-10-14 16:08:54 +08:00
apiResult.Code = "0000";
apiResult.Data = systemMain;
}
catch (Exception exception)
{
apiResult.Code = "9999";
Logger.LogError("【" + controllerName + "/" + actionName + "】" + exception.Message);
}
return apiResult;
}
/// <summary>
/// 新增 / 修改 系統大類資料
/// </summary>
/// <param name="post"></param>
/// <returns></returns>
[HttpPost]
2022-10-20 17:25:47 +08:00
public async Task<ApiResult<string>> SaveSystemMain(VariableInfo post)
2022-10-14 16:08:54 +08:00
{
ApiResult<string> apiResult = new ApiResult<string>();
try
{
2022-10-20 17:25:47 +08:00
string sWhere = @$"deleted = @Deleted AND id = @id";
2022-10-14 16:08:54 +08:00
2022-10-20 17:25:47 +08:00
object param = new { Deleted = 0, id = post.id };
2022-10-14 16:08:54 +08:00
var check = await backendRepository.GetOneAsync<string>($"select id from variable where id != {post.id} and system_type = '{main_system_type}' and system_value = '{post.system_value}' and deleted = 0;");
2023-08-04 11:52:36 +08:00
if (!string.IsNullOrEmpty(check))
{
apiResult.Code = "9998";
apiResult.Msg = "已有相同大類";
return apiResult;
}
2022-10-20 17:25:47 +08:00
var systemMain = await backendRepository.GetOneAsync<VariableInfo>("variable", sWhere, param);
2022-10-14 16:08:54 +08:00
if (systemMain == null)
{
//新增
2022-10-20 17:25:47 +08:00
//獲取最新的大類
sWhere = @$"deleted = @Deleted AND system_type = @System_type";
2022-10-21 19:40:38 +08:00
param = new { Deleted = 0, System_type = main_system_type };
2022-10-20 17:25:47 +08:00
var sOrder = @"id DESC LIMIT 1";
var latestVariable = await backendRepository.GetOneAsync<VariableInfo>("variable", sWhere, param, sOrder);
2022-10-14 16:08:54 +08:00
2022-10-20 17:25:47 +08:00
Dictionary<string, object> variableMainDic = new Dictionary<string, object>()
2022-10-14 16:08:54 +08:00
{
2022-10-21 19:40:38 +08:00
{ "@system_type", main_system_type},
2022-10-20 17:25:47 +08:00
{ "@system_key", post.System_key},
{ "@system_value", post.system_value},
{ "@system_remark", "系統類別(第2層)"},
{ "@system_priority", latestVariable.system_priority + 1},
{ "@created_by", myUserInfo.Userinfo_guid},
{ "@created_at", DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss")}
2022-10-14 16:08:54 +08:00
};
2022-10-20 17:25:47 +08:00
await backendRepository.AddOneByCustomTable(variableMainDic, "variable");
2022-10-14 16:08:54 +08:00
apiResult.Code = "0000";
apiResult.Msg = "新增成功";
}
else
{
2022-10-20 17:25:47 +08:00
Dictionary<string, object> variableMainDic = new Dictionary<string, object>()
2022-10-14 16:08:54 +08:00
{
2022-10-20 17:25:47 +08:00
{ "@system_key", post.System_key},
{ "@system_value", post.system_value},
2022-10-14 16:08:54 +08:00
{ "@updated_by", myUserInfo.Userinfo_guid},
{ "@updated_at", DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss")},
};
2022-10-20 17:25:47 +08:00
await backendRepository.UpdateOneByCustomTable(variableMainDic, "variable", "id='" + systemMain.id + "' AND deleted = 0");
2022-10-14 16:08:54 +08:00
var AuthCodes = await backendRepository.GetAllAsync<string>(
2022-10-20 17:25:47 +08:00
@$"select AuthCode
from auth_page ap
2022-10-21 19:40:38 +08:00
join variable sv on ap.ShowView = sv.id and sv.system_type = 'device_system_category_layer1'
where sv.system_parent_id = '{systemMain.id}'");
2022-10-14 16:08:54 +08:00
if(AuthCodes.Count > 0)
{
await backendRepository.ExecuteSql($@"UPDATE auth_page
2022-10-20 17:25:47 +08:00
SET MainName = '{post.System_key}'
2022-10-14 16:08:54 +08:00
WHERE AuthCode IN @authCode;",new { authCode = AuthCodes });
2022-10-20 17:25:47 +08:00
}
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="guid"></param>
/// <returns></returns>
[HttpPost]
2022-10-20 17:25:47 +08:00
public async Task<ApiResult<string>> DeleteOneSystemMain(int id)
2022-10-14 16:08:54 +08:00
{
ApiResult<string> apiResult = new ApiResult<string>();
try
{
2022-10-20 17:25:47 +08:00
string sWhere = @$"deleted = @Deleted AND id = @id";
2022-10-14 16:08:54 +08:00
2022-10-20 17:25:47 +08:00
object param = new { Deleted = 0, id = id };
2022-10-14 16:08:54 +08:00
2022-10-20 17:25:47 +08:00
var systemMain = await backendRepository.GetOneAsync<VariableInfo>("variable", sWhere, param);
2022-10-14 16:08:54 +08:00
if (systemMain == null)
{
apiResult.Code = "9998";
apiResult.Msg = "查無該系統大類";
return apiResult;
}
//檢查是否有未刪除的區域選單
var sbuildMenu = $@"SELECT
b.full_name
FROM building_menu bm
2022-10-20 17:25:47 +08:00
LEFT JOIN building b ON bm.building_tag = b.building_tag AND b.deleted = 0
WHERE bm.main_system_tag = @System_Value
2022-10-14 16:08:54 +08:00
GROUP BY b.full_name";
2022-10-20 17:25:47 +08:00
var buildMenus = await backendRepository.GetAllAsync<string>(sbuildMenu, new { System_Value = systemMain.system_value });
2022-10-14 16:08:54 +08:00
if (buildMenus.Count > 0)
{
apiResult.Code = "9997";
apiResult.Msg = "區域選單中尚有棟別正在使用該系統大類,故無法刪除";
apiResult.Data = string.Join("<br>", buildMenus);
return apiResult;
}
//檢查底下是否有未刪除的系統小類
2022-10-20 17:25:47 +08:00
string sqlSub = @$"SELECT id FROM variable
WHERE deleted = @Deleted AND system_parent_id = @id";
object sub_param = new { Deleted = 0, id = id };
var v = await backendRepository.GetAllAsync<VariableInfo>(sqlSub, sub_param);
2022-10-14 16:08:54 +08:00
2022-10-20 17:25:47 +08:00
if (v.Count > 0)
2022-10-14 16:08:54 +08:00
{
apiResult.Code = "9997";
apiResult.Msg = "系統小類中尚有小類正在使用系統大類,故無法刪除";
2022-10-20 17:25:47 +08:00
apiResult.Data = string.Join("<br>", v.Where(x => x.id == id).Select(x => x.System_key).ToList());
2022-10-14 16:08:54 +08:00
return apiResult;
}
2022-10-20 17:25:47 +08:00
await backendRepository.DeleteOne(id.ToString(), "variable", "id");
2022-10-14 16:08:54 +08:00
apiResult.Code = "0000";
apiResult.Msg = "刪除成功";
}
catch (Exception exception)
{
apiResult.Code = "9999";
apiResult.Msg = "系統內部錯誤,請聯絡管理者。";
2022-10-20 17:25:47 +08:00
Logger.LogError("【" + controllerName + "/" + actionName + "】" + "id=" + id);
2022-10-14 16:08:54 +08:00
Logger.LogError("【" + controllerName + "/" + actionName + "】" + exception.Message);
}
return apiResult;
}
/// <summary>
/// 取得系統小類清單
/// </summary>
/// <param name="main_system_guid"></param>
/// <returns></returns>
[HttpPost]
2022-10-20 17:25:47 +08:00
public async Task<ApiResult<List<VariableInfo>>> SystemSubList(int id)
2022-10-14 16:08:54 +08:00
{
2022-10-20 17:25:47 +08:00
ApiResult<List<VariableInfo>> apiResult = new ApiResult<List<VariableInfo>>();
2022-10-14 16:08:54 +08:00
try
{
2022-10-20 17:25:47 +08:00
var sWhere = @"deleted = @Deleted AND system_parent_id = @id";
2022-10-14 16:08:54 +08:00
2022-10-20 17:25:47 +08:00
object param = new { Deleted = 0, id = id};
2022-10-14 16:08:54 +08:00
2022-10-20 17:25:47 +08:00
var systemSubs = await backendRepository.GetAllAsync<VariableInfo>("variable", sWhere, param, "system_priority ASC, created_at DESC");
2022-10-14 16:08:54 +08:00
apiResult.Code = "0000";
apiResult.Data = systemSubs;
}
catch (Exception exception)
{
apiResult.Code = "9999";
Logger.LogError("【" + controllerName + "/" + actionName + "】" + exception.Message);
}
return apiResult;
}
/// <summary>
/// 取得單一系統小類
/// </summary>
/// <param name="guid"></param>
/// <returns></returns>
[HttpPost]
2022-10-20 17:25:47 +08:00
public async Task<ApiResult<VariableInfo>> GetOneSystemSub(int id)
2022-10-14 16:08:54 +08:00
{
2022-10-20 17:25:47 +08:00
ApiResult<VariableInfo> apiResult = new ApiResult<VariableInfo>();
2022-10-14 16:08:54 +08:00
try
{
2022-10-20 17:25:47 +08:00
string sWhere = @$"deleted = @Deleted AND id = @id";
2022-10-14 16:08:54 +08:00
2022-10-20 17:25:47 +08:00
object param = new { Deleted = 0, id = id };
2022-10-14 16:08:54 +08:00
2022-10-20 17:25:47 +08:00
var systemSub = await backendRepository.GetOneAsync<VariableInfo>("variable", sWhere, param);
2022-10-14 16:08:54 +08:00
apiResult.Code = "0000";
apiResult.Data = systemSub;
}
catch (Exception exception)
{
apiResult.Code = "9999";
Logger.LogError("【" + controllerName + "/" + actionName + "】" + exception.Message);
}
return apiResult;
}
/// <summary>
/// 新增 / 修改 系統小類資料
/// </summary>
/// <param name="post"></param>
/// <returns></returns>
[HttpPost]
2022-10-20 17:25:47 +08:00
public async Task<ApiResult<string>> SaveSystemSub(VariableInfo post)
2022-10-14 16:08:54 +08:00
{
ApiResult<string> apiResult = new ApiResult<string>();
try
{
var check = await backendRepository.GetOneAsync<string>($"select id from variable where id != {post.id} and system_type = '{sub_system_type}' and system_value = '{post.system_value}' and system_parent_id = {post.system_parent_id} and deleted = 0;");
2023-08-04 11:52:36 +08:00
if (!string.IsNullOrEmpty(check))
{
apiResult.Code = "9998";
apiResult.Msg = "已有相同小類";
return apiResult;
}
2022-10-20 17:25:47 +08:00
string sWhere = @$"deleted = @Deleted AND id = @id";
2022-10-14 16:08:54 +08:00
2022-10-20 17:25:47 +08:00
object param = new { Deleted = 0, id = post.id };
2022-10-14 16:08:54 +08:00
2022-10-20 17:25:47 +08:00
var systemSub = await backendRepository.GetOneAsync<VariableInfo>("variable", sWhere, param);
2022-10-14 16:08:54 +08:00
if (systemSub == null)
{
2022-10-14 16:08:54 +08:00
//新增
//產生一組GUID
2022-10-20 17:25:47 +08:00
//獲取最新的大類
sWhere = @$"deleted = @Deleted AND system_type = @System_type";
2022-10-21 19:40:38 +08:00
param = new { Deleted = 0, System_type = sub_system_type };
2022-10-20 17:25:47 +08:00
var sOrder = @"id DESC LIMIT 1";
var latestVariable = await backendRepository.GetOneAsync<VariableInfo>("variable", sWhere, param, sOrder);
2022-10-14 16:08:54 +08:00
Dictionary<string, object> systemSubDic = new Dictionary<string, object>()
{
2022-10-21 19:40:38 +08:00
{ "@system_type", sub_system_type},
2022-10-20 17:25:47 +08:00
{ "@system_key", post.System_key},
{ "@system_value", post.system_value},
{ "@system_parent_id", post.system_parent_id},
2022-10-21 19:40:38 +08:00
{ "@system_remark", "系統類別(第3層)"},
2022-10-20 17:25:47 +08:00
{ "@system_priority", latestVariable.system_priority + 1},
{ "@created_by", myUserInfo.Userinfo_guid},
{ "@created_at", DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss")}
2022-10-14 16:08:54 +08:00
};
2022-10-20 17:25:47 +08:00
await backendRepository.AddOneByCustomTable(systemSubDic, "variable");
2022-10-14 16:08:54 +08:00
var systemId = await backendRepository.GetOneAsync<int>($@"select id from variable where system_value = '{post.system_value}' and deleted = 0 and system_parent_id = '{post.system_parent_id}' and system_type = '{sub_system_type}'");
var buildings = await backendRepository.GetAllAsync<string>($@"select building_tag from building where deleted = 0");
var authCode = await backendRepository.GetOneAsync<int>($@"select max(cast(SUBSTRING(authcode, 2) AS UNSIGNED)) from auth_page where authcode like 'F%'");
var parentSystemName = await backendRepository.GetOneAsync<string>($@"select system_key from variable where id = {post.system_parent_id}");
StringBuilder sb = new StringBuilder();
foreach (var b in buildings)
{
sb.Append($@" insert into auth_page(AuthCode, AuthType, MainName, SubName, building_tag, ShowView, created_at)
values ('F{++authCode}', '1', '{parentSystemName}', '{post.System_key}', '{b}', '{systemId}', Now());");
}
await backendRepository.ExecuteSql(sb.ToString());
2022-10-14 16:08:54 +08:00
apiResult.Code = "0000";
apiResult.Msg = "新增成功";
}
else
{
Dictionary<string, object> systemSubDic = new Dictionary<string, object>()
{
2022-10-20 17:25:47 +08:00
{ "@system_key", post.System_key},
{ "@system_value", post.system_value},
2022-10-14 16:08:54 +08:00
{ "@updated_by", myUserInfo.Userinfo_guid},
{ "@updated_at", DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss")},
};
2022-10-20 17:25:47 +08:00
await backendRepository.UpdateOneByCustomTable(systemSubDic, "variable", "id='" + systemSub.id + "'");
2022-10-14 16:08:54 +08:00
var AuthCodes = await backendRepository.GetAllAsync<string>(
@$"select AuthCode from auth_page ap
2022-10-20 17:25:47 +08:00
where ap.ShowView = '{systemSub.id}'");
2022-10-14 16:08:54 +08:00
if (AuthCodes.Count > 0)
{
await backendRepository.ExecuteSql($@"UPDATE auth_page
2022-10-20 17:25:47 +08:00
SET SubName = '{post.System_key}'
2022-10-14 16:08:54 +08:00
WHERE AuthCode IN @authCode;", new { authCode = AuthCodes });
}
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]
2022-10-20 17:25:47 +08:00
public async Task<ApiResult<string>> DeleteOneSystemSub(string id)
2022-10-14 16:08:54 +08:00
{
ApiResult<string> apiResult = new ApiResult<string>();
try
{
2022-10-20 17:25:47 +08:00
string sWhere = @$"deleted = @Deleted AND id = @id";
2022-10-14 16:08:54 +08:00
2022-10-20 17:25:47 +08:00
object param = new { Deleted = 0, id = id };
2022-10-14 16:08:54 +08:00
2022-10-20 17:25:47 +08:00
var systemSub = await backendRepository.GetOneAsync<VariableInfo>("variable", sWhere, param);
2022-10-14 16:08:54 +08:00
if (systemSub == null)
{
apiResult.Code = "9998";
apiResult.Msg = "查無該系統小類";
return apiResult;
}
//檢查是否有未刪除的區域選單
var sbuildMenu = $@"SELECT
2022-10-21 19:40:38 +08:00
CONCAT(b.full_name, ' - ', sv.system_key)
2022-10-14 16:08:54 +08:00
FROM building_menu bm
2022-10-20 17:25:47 +08:00
LEFT JOIN building b ON bm.building_tag = b.building_tag AND b.deleted = 0
2022-10-21 19:40:38 +08:00
LEFT JOIN variable sv ON bm.sub_system_tag = sv.system_value AND sv.deleted = 0
LEFT JOIN variable mv ON sv.system_parent_id = mv.id AND mv.deleted = 0
WHERE sv.id = @id";
2022-10-14 16:08:54 +08:00
2022-10-20 17:25:47 +08:00
var buildMenus = await backendRepository.GetAllAsync<string>(sbuildMenu, new { id = id });
2022-10-14 16:08:54 +08:00
if (buildMenus.Count > 0)
{
apiResult.Code = "9997";
apiResult.Msg = "區域選單中尚有選單正在使用該系統小類,故無法刪除";
apiResult.Data = string.Join("<br>", buildMenus);
return apiResult;
}
//檢查是否有未刪除的系統小類樓層
var ssubSystemFloor = $@"SELECT
2022-10-21 19:40:38 +08:00
CONCAT(b.full_name, ' - ', mv.full_name, ' - ', sv.full_name, ' - ', f.full_name)
2022-10-14 16:08:54 +08:00
FROM sub_system_floor ssf
2022-10-20 17:25:47 +08:00
LEFT JOIN building b ON ssf.building_tag = b.building_tag AND b.deleted = 0
2022-10-21 19:40:38 +08:00
LEFT JOIN variable sv ON sv.system_value = ssf.sub_system_tag AND sv.deleted = 0
LEFT JOIN variable mv ON sv.system_parent_id = mv.id AND mv.deleted = 0
2022-10-14 16:08:54 +08:00
LEFT JOIN floor f ON ssf.floor_guid = f.floor_guid AND f.deleted = 0
2022-10-21 19:40:38 +08:00
WHERE sv.id = @id AND ssf.deleted = 0";
2022-10-14 16:08:54 +08:00
2022-10-20 17:25:47 +08:00
var subSystemFloor = await backendRepository.GetAllAsync<string>(sbuildMenu, new { id = id });
2022-10-14 16:08:54 +08:00
if (subSystemFloor.Count > 0)
{
apiResult.Code = "9997";
apiResult.Msg = "區域選單中尚有樓層正在使用該系統小類,故無法刪除";
apiResult.Data = string.Join("<br>", subSystemFloor);
return apiResult;
}
//檢查是否有未刪除的設備項目
var sdeviceItem = $@"SELECT
2022-10-20 17:25:47 +08:00
di.full_name
2022-10-14 16:08:54 +08:00
FROM device_item di
2022-10-21 19:40:38 +08:00
INNER JOIN variable sv on di.device_name_tag = sv.system_value
2022-10-22 13:24:29 +08:00
WHERE sv.deleted = 0 AND sv.id = @id AND di.deleted = 0";
2022-10-14 16:08:54 +08:00
2022-10-20 17:25:47 +08:00
var deviceItems = await backendRepository.GetAllAsync<string>(sdeviceItem, new { id = id });
2022-10-14 16:08:54 +08:00
if (deviceItems.Count > 0)
{
apiResult.Code = "9997";
apiResult.Msg = "設備項目中尚有項目正在使用該系統小類,故無法刪除";
apiResult.Data = string.Join("<br>", deviceItems);
return apiResult;
}
2022-10-20 17:25:47 +08:00
await backendRepository.DeleteOne(id, "variable", "id");
2022-10-14 16:08:54 +08:00
await backendRepository.ExecuteSql($@"delete from auth_page where AuthCode like 'F%' and AuthType = 1 and ShowView = '{id}'");
2022-10-14 16:08:54 +08:00
apiResult.Code = "0000";
apiResult.Msg = "刪除成功";
}
catch (Exception exception)
{
apiResult.Code = "9999";
apiResult.Msg = "系統內部錯誤,請聯絡管理者。";
2022-10-20 17:25:47 +08:00
Logger.LogError("【" + controllerName + "/" + actionName + "】" + "id=" + id);
2022-10-14 16:08:54 +08:00
Logger.LogError("【" + controllerName + "/" + actionName + "】" + exception.Message);
}
return apiResult;
}
[HttpPost]
public async Task<ApiResult<string>> Savedevice_item(Device_item device_Item)
{
ApiResult<string> apiResult = new ApiResult<string>();
try
{
var main_tag = await backendRepository.GetOneAsync<string>($@"SELECT system_value FROM variable WHERE id = @id", new { id = device_Item.device_system_tag });
var sub_tag = await backendRepository.GetOneAsync<string>($@"SELECT system_value FROM variable WHERE id = @id", new { id = device_Item.device_name_tag });
2022-10-14 16:08:54 +08:00
//檢查是否有未刪除的區域選單
if (device_Item.is_show_riserDiagram == 1)
2022-10-14 16:08:54 +08:00
{
var sql_show_riserDiagram = $@"SELECT di.id FROM device_item di
WHERE di.id != @id AND di.deleted = 0 AND is_show_riserDiagram = 1 and device_system_tag = @device_system_tag
and device_name_tag = @device_name_tag";
2022-10-14 16:08:54 +08:00
var deviceItemId = await backendRepository.GetAllAsync<int>(sql_show_riserDiagram,
new { id = device_Item.id, device_system_tag = main_tag, device_name_tag = sub_tag });
2022-10-14 16:08:54 +08:00
if (deviceItemId.Count() > 0)
2022-10-14 16:08:54 +08:00
{
foreach (var id in deviceItemId)
{
Dictionary<string, object> Device_itemDic = new Dictionary<string, object>()
{
{ "@is_show_riserDiagram", false},
{ "@updated_by", myUserInfo.Userinfo_guid},
{ "@updated_at", DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss")},
};
await backendRepository.UpdateOneByCustomTable(Device_itemDic, "device_item", "id='" + id + "'");
}
2022-10-14 16:08:54 +08:00
}
}
2022-10-20 17:25:47 +08:00
if (device_Item.id == 0)
2022-10-14 16:08:54 +08:00
{
var building = await backendRepository.GetAllAsync<string>("select building_tag from building where deleted = 0");
foreach (var b in building)
2022-10-14 16:08:54 +08:00
{
//新增
Dictionary<string, object> Device_itemDic = new Dictionary<string, object>()
{
{ "@device_system_tag", main_tag},
{ "@device_name_tag", sub_tag},
{ "@full_name", device_Item.full_name},
{ "@points", device_Item.points},
{ "@unit", device_Item.unit},
{ "@is_show", device_Item.is_show},
{ "@is_show_riserDiagram", device_Item.is_show_riserDiagram},
{ "@is_controll", device_Item.is_controll},
{ "@is_bool", device_Item.is_bool},
{ "@is_show_history", device_Item.is_show_history},
{ "@created_by", myUserInfo.Userinfo_guid},
{ "@device_building_tag", b},
{ "@is_link", "1"},
};
await backendRepository.AddOneByCustomTable(Device_itemDic, "device_item");
}
2022-10-14 16:08:54 +08:00
apiResult.Code = "0000";
apiResult.Msg = "新增成功";
}
else
{
var sql = $@"SELECT di.id FROM device_item di
WHERE di.deleted = 0 AND device_system_tag = @device_system_tag and device_name_tag = @device_name_tag and points = @points";
var deviceItemId = await backendRepository.GetAllAsync<int>(sql,
new { points = device_Item.points, device_system_tag = main_tag, device_name_tag = sub_tag });
if (deviceItemId.Count() > 0)
2022-10-14 16:08:54 +08:00
{
foreach (var id in deviceItemId)
{
Dictionary<string, object> Device_itemDic = new Dictionary<string, object>()
{
{ "@full_name", device_Item.full_name},
{ "@points", device_Item.points},
{ "@unit", device_Item.unit},
{ "@is_show", device_Item.is_show},
{ "@is_show_riserDiagram", device_Item.is_show_riserDiagram},
{ "@is_controll", device_Item.is_controll},
{ "@is_bool", device_Item.is_bool},
{ "@is_show_history", device_Item.is_show_history},
{ "@updated_by", myUserInfo.Userinfo_guid},
{ "@updated_at", DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss")},
};
2022-10-14 16:08:54 +08:00
await backendRepository.UpdateOneByCustomTable(Device_itemDic, "device_item", "id='" + id + "'");
}
}
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(device_Item);
Logger.LogError("【" + controllerName + "/" + actionName + "】" + json);
Logger.LogError("【" + controllerName + "/" + actionName + "】" + exception.Message);
}
return apiResult;
}
[HttpPost]
2022-10-20 17:25:47 +08:00
public async Task<ApiResult<List<Device_item>>> DeviceItemTable(int id)
2022-10-14 16:08:54 +08:00
{
ApiResult<List<Device_item>> apiResult = new ApiResult<List<Device_item>>();
try
{
var building_tag = await backendRepository.GetOneAsync<string>($@"select system_value from variable where system_type = 'project_name' and deleted = 0");
//var sql = @"SELECT di.*
// FROM device_item di
// JOIN variable sv ON di.device_name_tag = sv.system_value
// JOIN variable mv ON sv.system_parent_id = mv.id AND di.device_system_tag = mv.system_value
// WHERE sv.id = @id AND di.deleted = @Deleted and di.device_building_tag = @building_tag and di.is_link = 1";
var sql = @"SELECT min(di.id), di.full_name, di.points, di.unit, di.is_show, di.is_show_riserDiagram, di.is_controll, di.is_bool, di.is_link, di.is_show_history, di.device_system_tag, di.device_name_tag
2022-10-20 17:25:47 +08:00
FROM device_item di
2022-10-21 19:40:38 +08:00
JOIN variable sv ON di.device_name_tag = sv.system_value
JOIN variable mv ON sv.system_parent_id = mv.id AND di.device_system_tag = mv.system_value
WHERE sv.id = 35 and di.deleted = 0 and di.is_link = 1
group by di.full_name, di.points, di.unit, di.is_show, di.is_show_riserDiagram, di.is_controll, di.is_bool, di.is_link, di.is_show_history, di.device_system_tag, di.device_name_tag";
2022-10-14 16:08:54 +08:00
object param = new { Deleted = 0, id = id, building_tag = building_tag.Split("/")[1] };
2022-10-14 16:08:54 +08:00
2022-10-20 17:25:47 +08:00
var systemSubs = await backendRepository.GetAllAsync<Device_item>(sql, param);
2022-10-14 16:08:54 +08:00
apiResult.Code = "0000";
apiResult.Data = systemSubs;
}
catch (Exception exception)
{
apiResult.Code = "9999";
Logger.LogError("【" + controllerName + "/" + actionName + "】" + exception.Message);
}
return apiResult;
}
[HttpPost]
2022-10-20 17:25:47 +08:00
public async Task<ApiResult<Device_item>> GetOneDeviceItem(int id)
2022-10-14 16:08:54 +08:00
{
ApiResult<Device_item> apiResult = new ApiResult<Device_item>();
try
{
2022-10-20 17:25:47 +08:00
string sWhere = @$"deleted = @Deleted AND id = @id";
2022-10-14 16:08:54 +08:00
2022-10-20 17:25:47 +08:00
object param = new { Deleted = 0, id = id };
2022-10-14 16:08:54 +08:00
var Deviceitem = await backendRepository.GetOneAsync<Device_item>("device_item", sWhere, param);
apiResult.Code = "0000";
apiResult.Data = Deviceitem;
}
catch (Exception exception)
{
apiResult.Code = "9999";
Logger.LogError("【" + controllerName + "/" + actionName + "】" + exception.Message);
}
return apiResult;
}
[HttpPost]
2022-10-20 17:25:47 +08:00
public async Task<ApiResult<string>> DeleteOneSystemSubDeviceItem(int id)
2022-10-14 16:08:54 +08:00
{
ApiResult<string> apiResult = new ApiResult<string>();
try
{
2022-10-20 17:25:47 +08:00
string sWhere = @$"deleted = @Deleted AND id = @id";
2022-10-14 16:08:54 +08:00
object param = new { Deleted = 0, id = id };
2022-10-14 16:08:54 +08:00
var device_Item = await backendRepository.GetOneAsync<Device_item>("device_item", sWhere, param);
if (device_Item == null)
{
apiResult.Code = "9998";
apiResult.Msg = "查無該設備項目";
return apiResult;
}
string sql = $@"update device_item set deleted = 1 where device_system_tag = '{device_Item.device_system_tag}' and device_name_tag = '{device_Item.device_name_tag}' and deleted = 0
and points = '{device_Item.points}'";
await backendRepository.ExecuteSql(sql);
2022-10-14 16:08:54 +08:00
apiResult.Code = "0000";
apiResult.Msg = "刪除成功";
}
catch (Exception exception)
{
apiResult.Code = "9999";
apiResult.Msg = "系統內部錯誤,請聯絡管理者。";
2022-10-20 17:25:47 +08:00
Logger.LogError("【" + controllerName + "/" + actionName + "】" + "id=" + id);
2022-10-14 16:08:54 +08:00
Logger.LogError("【" + controllerName + "/" + actionName + "】" + exception.Message);
}
return apiResult;
}
public async Task<ApiResult<bool>> HaveSamePoints(Checksame post)
{
ApiResult<bool> apiResult = new ApiResult<bool>();
try
{
2022-10-20 17:25:47 +08:00
var sql = $@"SELECT *
FROM device_item di
INNER JOIN variable v ON di.device_name_tag = v.system_value
WHERE v.id = @SubId AND di.id != @Id AND points = @Points";
var param = new { SubId = post.subId, Points = post.points, id = post.id };
var point = await backendRepository.GetOneAsync<Device_item>(sql, param);
2022-10-14 16:08:54 +08:00
if (point != null)
{
apiResult.Data = true;
}
else
{
apiResult.Data = false;
}
apiResult.Code = "0000";
}
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;
}
public async Task<ApiResult<Deletebool>> CheckCanDelete(guidandsubguid post)
{
ApiResult<Deletebool> apiResult = new ApiResult<Deletebool>();
try
{
var tags = await backendRepository.GetAllAsync<Tags>(
2022-10-20 17:25:47 +08:00
@$"select * from (select dk.device_building_tag ,dk.device_name_tag,dk.device_system_tag from device_kind dk where dk.device_normal_point_id = @id) dkn
union(select dk.device_building_tag, dk.device_name_tag, dk.device_system_tag from device_kind dk where dk.device_close_point_id = @id)
union(select dk.device_building_tag, dk.device_name_tag, dk.device_system_tag from device_kind dk where dk.device_error_point_id = @id)", new { id = post.guid});
2022-10-14 16:08:54 +08:00
if (tags.Count == 0)
{
Deletebool deletebool = new Deletebool()
{
Delete = false,
Reason = ""
};
apiResult.Data = deletebool;
}
else
{
Deletebool deletebool = new Deletebool()
{
Delete = true,
Reason = ""
};
var unionsql = "";
var last = tags.Last();
2022-10-20 17:25:47 +08:00
var sub_system = await backendRepository.GetOneAsync<VariableInfo>($@"SELECT * FROM variable WHERE id = @id", new { id = post.subguid });
2022-10-14 16:08:54 +08:00
foreach (var tag in tags)
{
2022-10-20 17:25:47 +08:00
unionsql += $@"select d.building_tag,d.device_system_tag,d.device_name_tag,d.device_last_name from device d where d.device_name_tag = '{sub_system.system_value}'
and d.device_building_tag = '{tag.device_building_tag}' and d.device_system_tag = '{tag.device_system_tag}' and d.device_name_tag = '{tag.device_name_tag}' group by d.building_guid,d.main_system_guid,d.sub_system_guid,d.device_name_tag";
2022-10-14 16:08:54 +08:00
if (!last.Equals(tag))
{
unionsql += " union ";
}
}
2022-10-21 19:40:38 +08:00
var sql = @$"select mv.system_key msname, b.full_name bname, sv.system_key subname,de.device_last_name as device_name_tag from
2022-10-14 16:08:54 +08:00
({unionsql}) de
2022-10-21 19:40:38 +08:00
left join variable mv on mv.system_value = de.device_system_tag and mv.system_type = @main_system_type
2022-10-20 17:25:47 +08:00
left join building b on b.building_tag = de.building_tag
2022-10-21 19:40:38 +08:00
left join variable sv on sv.system_value = de.device_name_tag and sv.system_type = @sub_system_type";
2022-10-20 17:25:47 +08:00
2022-10-21 19:40:38 +08:00
var param = new { main_system_type = main_system_type, sub_system_type = sub_system_type};
2022-10-20 17:25:47 +08:00
var names = await backendRepository.GetAllAsync<GetCheckName>(sql, param);
2022-10-14 16:08:54 +08:00
var count = 0;
foreach (var name in names)
{
count++;
deletebool.Reason += count.ToString() + "." + name.bname + "-" + name.msname + "-" + name.subname + "-" + name.device_name_tag + "<br>";
}
apiResult.Data = deletebool;
}
apiResult.Code = "0000";
}
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;
}
public async Task<ApiResult<Deletebool>> CheckCanSubDelete(string guid)
{
ApiResult<Deletebool> apiResult = new ApiResult<Deletebool>();
try
{
var text = "";
var item = await backendRepository.GetAllAsync<string>(@$"select device_item_guid from device_item where deleted = 0 and sub_system_guid = '{guid}'");
if(item.Count > 0)
{
text += "項目還有尚未刪除<br>";
}
var menu = await backendRepository.GetAllAsync<string>($"select sub_system_guid from building_menu where sub_system_guid = '{guid}'");
if (menu.Count > 0)
{
text += "區域選單還有尚未刪除<br>";
}
Deletebool deletebool = new Deletebool()
{
Delete = false,
Reason = ""
};
if (text != "")
{
deletebool.Delete = true;
deletebool.Reason = text;
}
else
{
deletebool.Delete = false;
}
apiResult.Data = deletebool;
apiResult.Code = "0000";
}
catch (Exception exception)
{
apiResult.Code = "9999";
apiResult.Msg = "系統內部錯誤,請聯絡管理者。";
Logger.LogError("【" + controllerName + "/" + actionName + "】" + guid);
Logger.LogError("【" + controllerName + "/" + actionName + "】" + exception.Message);
}
return apiResult;
}
}
}