jay.chang/ibms-dome
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

[Backend] 更新device_node

Browse Source
This commit is contained in:
wanli 2023-01-04 10:54:34 +08:00
parent f95674cf15
commit 2568624e52
3 changed files with 78 additions and 25 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

52
Backend/Controllers/DeviceImportController.cs
View File

@ -755,6 +755,7 @@ namespace Backend.Controllers
public async Task<ApiResult<string>> ImportDevForCor([FromBody] List<ImportDevForCoo> post) public async Task<ApiResult<string>> ImportDevForCor([FromBody] List<ImportDevForCoo> post)
{ {
ApiResult<string> apiResult = new ApiResult<string>(); ApiResult<string> apiResult = new ApiResult<string>();
var device_guid_record = "";
try try
{ {
if (post != null) if (post != null)
@ -762,38 +763,43 @@ namespace Backend.Controllers
if (post.Count > 0) if (post.Count > 0)
{ {
//清空device_node資料表 //清空device_node資料表
//await backendRepository.TruncateTable("device_node"); await backendRepository.TruncateTable("device_node");
//int node_priority = 1; int node_priority = 1;
foreach(var idfc in post) foreach(var idfc in post)
{ {
//if(idfc.device_number.IndexOf("_LT_L1") > -1) if (idfc.device_number.IndexOf("_LT_L1") > -1)
//{ {
// //取得device_guid //取得device_guid
// var sWhere = $@"where deleted = 0 and device_number = " + idfc.device_number; var sWhere = $@" deleted = 0 and device_number = '" + idfc.device_number + "'";
// var device_guid = await backendRepository.GetOneAsync<string>("device_node", sWhere, "device_guid"); var device_guid = await backendRepository.GetOneColAsync("device", sWhere, "device_guid");
if(device_guid.ToString() != device_guid_record)
{
device_guid_record = device_guid.ToString();
node_priority = 1;
}
// //燈具 //燈具
// Dictionary<string, object> device = new Dictionary<string, object>(); Dictionary<string, object> device = new Dictionary<string, object>();
// device.Add("@device_node_guid", Guid.NewGuid()); device.Add("@device_node_guid", Guid.NewGuid());
// device.Add("@deleted", 0); device.Add("@deleted", 0);
// device.Add("@device_guid", device_guid); device.Add("@device_guid", device_guid);
// device.Add("@device_node_coordinate_3d", idfc.device_coordinate_3d); device.Add("@device_node_coordinate_3d", idfc.device_coordinate_3d);
// device.Add("@forge_dbid", idfc.forge_dbid); device.Add("@forge_dbid", idfc.forge_dbid);
// device.Add("@priority", node_priority); device.Add("@priority", node_priority);
// device.Add("@created_by", myUserInfo.Userinfo_guid); device.Add("@created_by", myUserInfo.Userinfo_guid);
// device.Add("@created_at", DateTime.Now); device.Add("@created_at", DateTime.Now);
// node_priority++; node_priority++;
// await backendRepository.AddOneByCustomTableReturnId(device, "device_node", false); await backendRepository.AddOneByCustomTableReturnId(device, "device_node", false);
//} }
//else else
//{ {
Dictionary<string, object> device = new Dictionary<string, object>(); Dictionary<string, object> device = new Dictionary<string, object>();
device.Add("@device_coordinate_3d", idfc.device_coordinate_3d); device.Add("@device_coordinate_3d", idfc.device_coordinate_3d);
device.Add("@forge_dbid", idfc.forge_dbid); device.Add("@forge_dbid", idfc.forge_dbid);
await backendRepository.UpdateOneByCustomTable(device, "device", $@" device_number = '{idfc.device_number}'"); await backendRepository.UpdateOneByCustomTable(device, "device", $@" device_number = '{idfc.device_number}'");
//} }

35
Repository/BaseRepository/Implement/BaseRepository.cs
View File

@ -270,6 +270,41 @@ namespace Repository.BaseRepository.Implement
return result; return result;
} }
} }
/// <summary>
/// 取得單一筆資料某一欄位(排序)
/// </summary>
/// <param name="tableName"></param>
/// <param name="sWhere"></param>
/// <param name="selCol">填放欄位</param>
/// <param name="param">參數值</param>
/// <param name="sOrderBy"></param>
/// <returns></returns>
public virtual async Task<string> GetOneColAsync(string tableName, string sWhere, string selCol, object param = null, string sOrderBy = "")
{
string result;
using (IDbConnection conn = GetDbConnection())
{
try
{
var sql = $"SELECT {selCol} FROM {tableName}";
if (!string.IsNullOrEmpty(sWhere))
{
sql += $" WHERE {sWhere}";
}
if (!string.IsNullOrEmpty(sOrderBy))
{
sql += $" ORDER BY {sOrderBy}";
}
result = await conn.QueryFirstOrDefaultAsync<string>(sql, param);
}
catch (Exception exception)
{
throw exception;
}
return result;
}
}
/// <summary> /// <summary>
/// 取得單一筆資料(根據自訂SQL, 自訂參數) /// 取得單一筆資料(根據自訂SQL, 自訂參數)

12
Repository/BaseRepository/Interface/IBaseRepository.cs
View File

@ -95,6 +95,18 @@ namespace Repository.BaseRepository.Interface
/// <returns></returns> /// <returns></returns>
Task<object> GetOneAsync(string tableName, string sWhere, string selCol, object param = null, string sOrderBy = ""); Task<object> GetOneAsync(string tableName, string sWhere, string selCol, object param = null, string sOrderBy = "");
/// <summary> /// <summary>
/// 取得單一筆資料某一欄位(排序)，不需sWhere及sOrderBy填""
/// <para>
/// SELECT {selCol} FROM {tableName} WHERE {sWhere} ORDER BY {sOrderBy}
/// </para>
/// </summary>
/// <param name="tableName"></param>
/// <param name="sWhere"></param>
/// <param name="sOrderBy"></param>
/// <param name="selCol">填放欄位</param>
/// <returns></returns>
Task<string> GetOneColAsync(string tableName, string sWhere, string selCol, object param = null, string sOrderBy = "");
/// <summary>
/// 取得單一筆資料(根據自訂SQL, 自訂參數) /// 取得單一筆資料(根據自訂SQL, 自訂參數)
/// </summary> /// </summary>
/// <param name="sqlString"></param> /// <param name="sqlString"></param>