277 lines
15 KiB
C#
277 lines
15 KiB
C#
using Microsoft.AspNetCore.Mvc;
|
||
using Repository.BackendRepository.Interface;
|
||
using System.Collections.Generic;
|
||
using System.Threading.Tasks;
|
||
using System;
|
||
//using Backend.Models;
|
||
using Microsoft.Extensions.Logging;
|
||
using Backend.Services;
|
||
using Backend.Services.Implement;
|
||
using Repository.Models;
|
||
using System.Linq;
|
||
using Microsoft.Extensions.DependencyInjection;
|
||
using NPOI.SS.Formula.Functions;
|
||
using Repository.Helper;
|
||
using Microsoft.AspNetCore.Routing.Matching;
|
||
using Newtonsoft.Json;
|
||
|
||
namespace Backend.Controllers
|
||
{
|
||
public class NiagaraDataSynchronizeController : MybaseController<NiagaraDataSynchronizeController>
|
||
{
|
||
private readonly IBackendRepository backendRepository;
|
||
//private readonly IDeviceImportRepository deviceImportRepository;
|
||
private readonly INiagaraDataSynchronizeRepository niagaraDataSynchronizeRepository;
|
||
private readonly IBackEndConfigHelper backEndConfig;
|
||
public NiagaraDataSynchronizeController(IBackendRepository backendRepository, INiagaraDataSynchronizeRepository niagaraDataSynchronizeRepository,IBackEndConfigHelper backEndConfig)
|
||
{
|
||
this.backendRepository = backendRepository;
|
||
//this.deviceImportRepository = deviceImportRepository;
|
||
this.niagaraDataSynchronizeRepository = niagaraDataSynchronizeRepository;
|
||
this.backEndConfig = backEndConfig;
|
||
}
|
||
|
||
public IActionResult Index()
|
||
{
|
||
return View();
|
||
}
|
||
|
||
/// <summary>
|
||
/// N4匯入列表
|
||
/// </summary>
|
||
/// <returns></returns>
|
||
[HttpPost]
|
||
public Task<ApiResult<List<Device_value>>> RawDataList()
|
||
{
|
||
ApiResult<List<Device_value>> apiResult = new ApiResult<List<Device_value>>();
|
||
|
||
try
|
||
{
|
||
var sqlObix = $@"SELECT system_value as Value, system_key as Name FROM variable WHERE deleted = 0 AND system_type = 'obixConfig'";
|
||
var variableObix = backendRepository.GetAllAsync<Backend.Models.KeyValue>(sqlObix).Result;
|
||
var obixApiConfig = new Backend.Models.ObixApiConfig();
|
||
EDFunction ed = new EDFunction();
|
||
obixApiConfig.ApiBase = variableObix.Where(x => x.Name == "ApiBase").Select(x => x.Value).FirstOrDefault() + "obix/config/Program/ObixQuery/query/";
|
||
//obixApiConfig.UrlSlot =variableObix.Where(x => x.Name == "url_slot").Select(x => x.Value).FirstOrDefault();
|
||
obixApiConfig.TagQuantity = variableObix.Where(x => x.Name == "tag_quantity").Select(x => x.Value).FirstOrDefault();
|
||
obixApiConfig.UserName = variableObix.Where(x => x.Name == "UserName").Select(x => x.Value).FirstOrDefault();
|
||
obixApiConfig.Password = variableObix.Where(x => x.Name == "Password").Select(x => x.Value).FirstOrDefault();
|
||
|
||
var ds = new List<Device_value>();
|
||
|
||
string top100 = "";//" top 100 ";
|
||
webRequestService svc = new webRequestService();
|
||
var urlSlots = backendRepository.GetAllAsync<string>("select obixSlot from building where deleted = 0").Result;
|
||
foreach(var us in urlSlots)
|
||
{
|
||
string bql = us + "bql:select " + top100 + " * from baja:Folder ";
|
||
//ds = svc.obixQuery("http://192.168.0.136:8080/obix/config/Arena/Program/ObixQuery/query/", bql);
|
||
//ds = svc.obixQuery("http://localhost:8080/obix/config/Program/ObixQuery/query/", bql);
|
||
ds.AddRange(svc.obixQuery(obixApiConfig.ApiBase, bql, obixApiConfig.TagQuantity, obixApiConfig.UserName, obixApiConfig.Password));//三菱
|
||
}
|
||
|
||
apiResult.Code = "0000";
|
||
apiResult.Data = ds;
|
||
}
|
||
catch (Exception exception)
|
||
{
|
||
apiResult.Code = "9999";
|
||
apiResult.Msg = "【" + controllerName + "/" + actionName + "】" + exception.Message;
|
||
Logger.LogError("【" + controllerName + "/" + actionName + "】" + exception.Message + Environment.NewLine + exception.StackTrace);
|
||
// Logger.LogError("【" + controllerName + "/" + actionName + "】" + exception.Message);
|
||
}
|
||
|
||
//return apiResult;
|
||
return Task.FromResult(apiResult);
|
||
}
|
||
|
||
/// <summary>
|
||
/// 比對N4與資料表，有差異在同步至資料表中
|
||
/// </summary>
|
||
/// <returns></returns>
|
||
[HttpPost]
|
||
public async Task<ApiResult<bool>> CompareData([FromBody] List<Device_value> ds)
|
||
{
|
||
bool result = false;
|
||
|
||
ApiResult<bool> apiResult = new ApiResult<bool>();
|
||
var sqlObix = $@"SELECT system_value as Value, system_key as Name FROM variable WHERE deleted = 0 AND system_type = 'obixConfig'";
|
||
var variableObix = await backendRepository.GetAllAsync<Backend.Models.KeyValue>(sqlObix);
|
||
string tag_quantity = variableObix.Where(x => x.Name == "tag_quantity").Select(x => x.Value).FirstOrDefault();
|
||
|
||
try
|
||
{
|
||
string ss = ds.Where(x => x.tag_name != "").FirstOrDefault().tag_name;
|
||
var data = ds.Where(x => x.tag_name != "");
|
||
List<string> building = null;
|
||
if (tag_quantity == "5")
|
||
{
|
||
//building.Add(ss.Split("_")[0]);
|
||
building = data.GroupBy(x => x.tag_name.Split("_")[0]).Select(x => x.Key).ToList();
|
||
}
|
||
else
|
||
{
|
||
//building.Add(ss.Split("_")[1]);
|
||
building = data.GroupBy(x => x.tag_name.Split("_")[1]).Select(x => x.Key).ToList();
|
||
}
|
||
|
||
string LightSwitchLevel = await niagaraDataSynchronizeRepository.getLightSwitchLevel(); //獲取照明開關 是否在 device or device_node
|
||
await niagaraDataSynchronizeRepository.InsertNiagaraTagList(ds, building, tag_quantity); // 匯入 MySQL table: import_niagara_tag
|
||
await niagaraDataSynchronizeRepository.DeviceComparison(LightSwitchLevel);
|
||
await niagaraDataSynchronizeRepository.CheckDiffFullNameAndCover(); // *
|
||
await niagaraDataSynchronizeRepository.CheckFullNameEmptyReplaceByDeviceName();
|
||
await niagaraDataSynchronizeRepository.InsertBuildingMenu();
|
||
await niagaraDataSynchronizeRepository.InsertSubSystemFloor();
|
||
await niagaraDataSynchronizeRepository.InsertFloor();
|
||
await this.DeviceDisasterAsync();
|
||
result = true;
|
||
|
||
apiResult.Code = "0000";
|
||
apiResult.Data = result;
|
||
}
|
||
catch (Exception exception)
|
||
{
|
||
apiResult.Code = "9999";
|
||
apiResult.Msg = "【" + controllerName + "/" + actionName + "】" + exception.Message;
|
||
Logger.LogError("【" + controllerName + "/" + actionName + "】" + exception.Message + Environment.NewLine + exception.StackTrace);
|
||
}
|
||
|
||
return apiResult;
|
||
}
|
||
|
||
/// <summary>
|
||
/// N4匯入列表(device_item)
|
||
/// </summary>
|
||
/// <returns></returns>
|
||
[HttpPost]
|
||
public Task<ApiResult<List<ImpNiaItem>>> RawDataDevItemList([FromBody] Device_value building)
|
||
{
|
||
ApiResult<List<ImpNiaItem>> apiResult = new ApiResult<List<ImpNiaItem>>();
|
||
|
||
try
|
||
{
|
||
var ds = new List<ImpNiaItem>();
|
||
|
||
webRequestService svc = new webRequestService();
|
||
|
||
var sqlObix = $@"SELECT system_value as Value, system_key as Name FROM variable WHERE deleted = 0 AND system_type = 'obixConfig'";
|
||
var variableObix = backendRepository.GetAllAsync<Backend.Models.KeyValue>(sqlObix).Result;
|
||
var obixApiConfig = new Backend.Models.ObixApiConfig();
|
||
EDFunction ed = new EDFunction();
|
||
obixApiConfig.ApiBase = variableObix.Where(x => x.Name == "ApiBase").Select(x => x.Value).FirstOrDefault();
|
||
obixApiConfig.UserName = variableObix.Where(x => x.Name == "UserName").Select(x => x.Value).FirstOrDefault();
|
||
obixApiConfig.Password = variableObix.Where(x => x.Name == "Password").Select(x => x.Value).FirstOrDefault();
|
||
//obixApiConfig.UrlSlot = variableObix.Where(x => x.Name == "url_slot").Select(x => x.Value).FirstOrDefault();
|
||
var urlSlots = backendRepository.GetAllAsync<BuildingDetail>("select obixSlot, area_tag from building where deleted = 0").Result;
|
||
foreach(var us in urlSlots)
|
||
{
|
||
var data = svc.obixHisQuery(obixApiConfig.ApiBase + "obix/config/Program/ObixQuery/query/", obixApiConfig.ApiBase + "obix/histories", us.obixSlot,
|
||
obixApiConfig.UserName, obixApiConfig.Password, us.area_tag);
|
||
ds.AddRange(data);
|
||
}
|
||
|
||
var buildings = backendRepository.GetAllAsync<string>("select building_tag from building where deleted = 0").Result;
|
||
apiResult.Code = "0000";
|
||
apiResult.Data = ds.Where(x => buildings.Contains(x.device_building_tag)).ToList();
|
||
}
|
||
catch (Exception exception)
|
||
{
|
||
apiResult.Code = "9999";
|
||
apiResult.Msg = "【" + controllerName + "/" + actionName + "】" + exception.Message;
|
||
Logger.LogError("【" + controllerName + "/" + actionName + "】" + exception.Message + Environment.NewLine + exception.StackTrace);
|
||
}
|
||
|
||
//return apiResult;
|
||
return Task.FromResult(apiResult);
|
||
}
|
||
|
||
/// <summary>
|
||
/// 比對N4與資料表，有差異在同步至資料表中(device_item)
|
||
/// </summary>
|
||
/// <returns></returns>
|
||
[HttpPost]
|
||
public async Task<ApiResult<bool>> DevIteComData([FromBody] List<ImpNiaItem> ds)
|
||
{
|
||
bool result = false;
|
||
var oldDs = JsonConvert.DeserializeObject<List<ImpNiaItem>>(JsonConvert.SerializeObject(ds));
|
||
ApiResult<bool> apiResult = new ApiResult<bool>();
|
||
try
|
||
{
|
||
if (ds.Count > 0)
|
||
{
|
||
//string ss = ds.Where(x => x.tag_name != "").FirstOrDefault().tag_name;
|
||
//var building = ss.Split("_")[0];
|
||
var building = ds.GroupBy(x => x.device_building_tag).Select(x => x.Key).ToList();
|
||
#region 歷史資料處理
|
||
ds.Clear();
|
||
var isDome = await backendRepository.GetOneAsync<string>("select system_value from variable where deleted = 0 and system_type = 'project_name';");
|
||
var sqlObix = $@"SELECT system_value as Value, system_key as Name FROM variable WHERE deleted = 0 AND system_type = 'obixConfig'";
|
||
var variableObix = backendRepository.GetAllAsync<Backend.Models.KeyValue>(sqlObix).Result;
|
||
var obixApiConfig = new Backend.Models.ObixApiConfig();
|
||
EDFunction ed = new EDFunction();
|
||
obixApiConfig.ApiBase = variableObix.Where(x => x.Name == "ApiBase").Select(x => x.Value).FirstOrDefault();
|
||
obixApiConfig.UserName = variableObix.Where(x => x.Name == "UserName").Select(x => x.Value).FirstOrDefault();
|
||
obixApiConfig.Password = variableObix.Where(x => x.Name == "Password").Select(x => x.Value).FirstOrDefault();
|
||
//obixApiConfig.UrlSlot = variableObix.Where(x => x.Name == "url_slot").Select(x => x.Value).FirstOrDefault();
|
||
webRequestService svc = new webRequestService();
|
||
var data = svc.obixHisQuery_v2(obixApiConfig.ApiBase + "obix/config/Program/ObixQuery/query/", obixApiConfig.ApiBase + "obix/histories", "",
|
||
obixApiConfig.UserName, obixApiConfig.Password);
|
||
ds.AddRange(data);
|
||
// save to history
|
||
await niagaraDataSynchronizeRepository.InsertItemFromNiagara_History(ds, building); // insert 暫存table import_niagara_item_history
|
||
if (!string.IsNullOrEmpty(isDome) && isDome.Contains("ibms_dome"))
|
||
await niagaraDataSynchronizeRepository.RecoverSysTag("import_niagara_item_history"); // recover missing deivce_system_tag
|
||
#endregion
|
||
|
||
await niagaraDataSynchronizeRepository.InsertItemFromNiagara(oldDs, building); // insert 暫存table import_niagara_item
|
||
await niagaraDataSynchronizeRepository.DeviceItemComparison(); //insert device_item
|
||
await niagaraDataSynchronizeRepository.CheckItemDiffFullNameAndCover(); // update device_item.fullname
|
||
await niagaraDataSynchronizeRepository.ItemCheckFullNameEmptyReplaceByDeviceName(); // 檢查device_item內FullName為空的值，以points取代
|
||
await niagaraDataSynchronizeRepository.CheckItemIsShowHistory();
|
||
|
||
result = true;
|
||
|
||
apiResult.Code = "0000";
|
||
apiResult.Data = result;
|
||
}
|
||
|
||
}
|
||
catch (Exception exception)
|
||
{
|
||
apiResult.Code = "9999";
|
||
apiResult.Msg = "【" + controllerName + "/" + actionName + "】" + exception.Message;
|
||
Logger.LogError("【" + controllerName + "/" + actionName + "】" + exception.Message + Environment.NewLine + exception.StackTrace);
|
||
}
|
||
|
||
return apiResult;
|
||
}
|
||
|
||
private async Task DeviceDisasterAsync()
|
||
{
|
||
var sqlObix = $@"SELECT system_value as Value, system_key as Name FROM variable WHERE deleted = 0 AND system_type = 'obixConfig'";
|
||
var variableObix = await backendRepository.GetAllAsync<Backend.Models.KeyValue>(sqlObix);
|
||
var obixApiConfig = new Models.ObixApiConfig();
|
||
obixApiConfig.ApiBase = variableObix.Where(x => x.Name == "ApiBase").Select(x => x.Value).FirstOrDefault();
|
||
obixApiConfig.UserName = variableObix.Where(x => x.Name == "UserName").Select(x => x.Value).FirstOrDefault();
|
||
obixApiConfig.Password = variableObix.Where(x => x.Name == "Password").Select(x => x.Value).FirstOrDefault();
|
||
obixApiConfig.TagQuantity = variableObix.Where(x => x.Name == "tag_quantity").Select(x => x.Value).FirstOrDefault();
|
||
|
||
if (obixApiConfig.TagQuantity == "5")
|
||
{
|
||
List<Device_value_disaster> dv = new List<Device_value_disaster>();
|
||
List<string> urlSlots = await backendRepository.GetAllAsync<string>("select obixSlot from building where deleted = 0");
|
||
List<string> disasterTag = await backendRepository.GetAllAsync<string>("select system_value from variable where system_type = 'disaster' and deleted = 0");
|
||
webRequestService svc = new webRequestService();
|
||
foreach(var dt in disasterTag)
|
||
{
|
||
string bql = "neql:hs:geoAddr=\"ER" + dt + "\"";
|
||
dv.AddRange(svc.obixDevDisaster(obixApiConfig.ApiBase + "obix/config/Arena/Program/ObixQuery/query/", bql, obixApiConfig.TagQuantity, obixApiConfig.UserName,
|
||
obixApiConfig.Password, dt));
|
||
}
|
||
|
||
await niagaraDataSynchronizeRepository.DeviceDisasterAysnc(dv);
|
||
}
|
||
}
|
||
}
|
||
}
|