132 lines
6.1 KiB
C#
132 lines
6.1 KiB
C#
using System;
|
||
using System.Collections.Generic;
|
||
using System.Linq;
|
||
using System.Xml;
|
||
using Newtonsoft.Json;
|
||
using Repository.Models;
|
||
using Newtonsoft.Json.Linq;
|
||
using System.IO;
|
||
using System.Net;
|
||
using System.Text;
|
||
using System.Xml.Linq;
|
||
using Repository.BackendRepository.Implement;
|
||
using Repository.BackendRepository;
|
||
|
||
namespace Backend.Services.Implement
|
||
{
|
||
public class webRequestService
|
||
{
|
||
public List<Device_value> obixQuery(string urlString, string bql)
|
||
{
|
||
List<Device_value> result = new List<Device_value>();
|
||
String username = "obixUser";
|
||
String password = "Admin123456";
|
||
String encoded = System.Convert.ToBase64String(System.Text.Encoding.GetEncoding("ISO-8859-1").GetBytes(username + ":" + password));
|
||
String API_Url = urlString;
|
||
|
||
XmlDocument xmlDoc = new XmlDocument();
|
||
//xmlDoc.LoadXml(responseString);
|
||
xmlDoc.Load("N4.xml");//N4v1021
|
||
|
||
//xmlDoc.Save("N4.xml");
|
||
|
||
string jsonText = JsonConvert.SerializeXmlNode(xmlDoc);
|
||
var data = Welcome.FromJson(jsonText);
|
||
|
||
foreach (var item in data.Obj.Str)
|
||
{
|
||
Device_value row = new Device_value();
|
||
row.value = item.Val;
|
||
string[] s1 = item.Val.Split(',');
|
||
|
||
string[] s2 = s1[0].Split('/');
|
||
foreach (var ss in s2)
|
||
{
|
||
if (ss.Contains('_'))
|
||
{
|
||
string[] s3 = ss.Split('_');
|
||
if (s3.Count() > 3)
|
||
{
|
||
row.tag_name = ss;
|
||
row.point_name = s2[s2.Length - 2];
|
||
break;
|
||
}
|
||
}
|
||
}
|
||
result.Add(row);
|
||
|
||
}
|
||
return result;
|
||
}
|
||
|
||
//public void getObix()
|
||
//{
|
||
// //#region 取得obix 設定
|
||
// //var obixApiConfig = new ObixApiConfig();
|
||
|
||
// //var sqlObix = $@"SELECT system_value as Value, system_key as Name FROM variable WHERE deleted = 0 AND system_type = 'obixConfig'";
|
||
|
||
// //var variableObix = await backgroundServiceRepository.GetAllAsync<KeyValue>(sqlObix);
|
||
// //obixApiConfig.ApiBase = variableObix.Where(x => x.Name == "ApiBase").Select(x => x.Value).FirstOrDefault();
|
||
// //obixApiConfig.UserName = ed.AESDecrypt(variableObix.Where(x => x.Name == "UserName").Select(x => x.Value).FirstOrDefault());
|
||
// //obixApiConfig.Password = ed.AESDecrypt(variableObix.Where(x => x.Name == "Password").Select(x => x.Value).FirstOrDefault());
|
||
|
||
// //String encoded = System.Convert.ToBase64String(System.Text.Encoding.GetEncoding("ISO-8859-1").GetBytes(obixApiConfig.UserName + ":" + obixApiConfig.Password));
|
||
// //#endregion 取得obix 設定
|
||
|
||
|
||
// HttpWebRequest archiveMonthRequest = (HttpWebRequest)WebRequest.Create($"{obixApiConfig.ApiBase}obix/histories/FIC_Center/{deviceNumberPoint.FullDeviceNumberPoint}/~historyRollup/");
|
||
// //HttpWebRequest archiveMonthRequest = (HttpWebRequest)WebRequest.Create($"{obixApiConfig.ApiBase}obix/histories/FIC_Center/H_E1_B1F_MVCB_MVCBH_V1/~historyRollup/");
|
||
// archiveMonthRequest.Method = "POST";
|
||
// archiveMonthRequest.Headers.Add("Authorization", "Basic " + encoded);
|
||
// archiveMonthRequest.PreAuthenticate = true;
|
||
|
||
// byte[] byteArray = Encoding.UTF8.GetBytes(historyQueryFilter);
|
||
// using (Stream reqStream = archiveMonthRequest.GetRequestStream())
|
||
// {
|
||
// reqStream.Write(byteArray, 0, byteArray.Length);
|
||
// }
|
||
|
||
// HttpWebResponse archiveMonthResponse = (HttpWebResponse)archiveMonthRequest.GetResponse();
|
||
// var archiveMonthResponseContent = new StreamReader(archiveMonthResponse.GetResponseStream()).ReadToEnd();
|
||
|
||
// xmlDocument.LoadXml(archiveMonthResponseContent);
|
||
// string archiveMonthJson = JsonConvert.SerializeXmlNode(xmlDocument);
|
||
// JObject archiveMonthJsonResult = (JObject)JsonConvert.DeserializeObject(archiveMonthJson);
|
||
|
||
// if (archiveMonthJsonResult.ContainsKey("err")) //抓取錯誤
|
||
// {
|
||
// //logger.LogError("【ArchiveElectricMeterDayJob】【月歸檔】【取得資料失敗】");
|
||
// //logger.LogError("【ArchiveElectricMeterDayJob】【月歸檔】【取得資料失敗】[錯誤內容]：{0}", archiveMonthJsonResult);
|
||
|
||
// Dictionary<string, object> archiveMonthRawData = new Dictionary<string, object>();
|
||
// archiveMonthRawData.Add("@device_number", deviceNumberPoint.DeviceNumber);
|
||
// archiveMonthRawData.Add("@point", deviceNumberPoint.Point);
|
||
// archiveMonthRawData.Add("@start_timestamp", startTimestamp.Replace("T", " ").Substring(0, 19));
|
||
// archiveMonthRawData.Add("@end_timestamp", endTimestamp.Replace("T", " ").Substring(0, 19));
|
||
// archiveMonthRawData.Add("@is_complete", 0);
|
||
// archiveMonthRawData.Add("@repeat_times", 0);
|
||
// archiveMonthRawData.Add("@fail_reason", archiveMonthJson);
|
||
|
||
// archiveMonthRawData.Add("@count_rawdata", 0);
|
||
// archiveMonthRawData.Add("@min_rawdata", 0);
|
||
// archiveMonthRawData.Add("@max_rawdata", 0);
|
||
// archiveMonthRawData.Add("@avg_rawdata", 0);
|
||
// archiveMonthRawData.Add("@sum_rawdata", 0);
|
||
// archiveMonthRawData.Add("@updated_at", DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss"));
|
||
|
||
// archiveMonthRawDatas.Add(archiveMonthRawData);
|
||
// }
|
||
|
||
// if (archiveMonthJsonResult.ContainsKey("obj")) //表示可以讀取到內容
|
||
// {
|
||
// var ArrangeRawDatas = ArrangeRawData(deviceNumberPoint, archiveMonthJsonResult);
|
||
// if (ArrangeRawDatas != null && ArrangeRawDatas.Count() > 0)
|
||
// {
|
||
// archiveMonthRawDatas.AddRange(ArrangeRawDatas);
|
||
// }
|
||
// }
|
||
//}
|
||
}
|
||
}
|