using IStation.ChEr.Application;
|
using System;
|
using System.Collections.Generic;
|
using System.Linq;
|
using System.Net;
|
using System.Text;
|
using System.Threading.Tasks;
|
using Yw.Untity;
|
using static IStation.Service.SSAPredictHelper;
|
|
namespace IStation.Application
|
{
|
/// <summary>
|
///
|
/// </summary>
|
public class ConnectHelper
|
{
|
/// <summary>
|
///
|
/// </summary>
|
public class OutTotalDayList
|
{
|
/// <summary>
|
///
|
/// </summary>
|
public DateTime DateTime { get; set; }
|
|
/// <summary>
|
///
|
/// </summary>
|
public List<TotalOneDay> pumpOutWater { get; set; }
|
}
|
|
/// <summary>
|
///
|
/// </summary>
|
public class TotalOneDay
|
{
|
/// <summary>
|
///
|
/// </summary>
|
public DateTime DateTime { get; set; }
|
|
/// <summary>
|
///
|
/// </summary>
|
public double Total { get; set; }
|
}
|
|
//获取总管天参数(累计总计)
|
public static List<OutTotalDayList> ReadPumpAllDayAccOutWater(DateTime StartDay, DateTime EndDay)
|
{
|
//var root_folder = System.IO.Path.Combine(IStation.DataFolderHelper.GetRootPath(), "供水参数");
|
var root_folder = "C:\\Users\\ZKC\\Desktop\\累计总计";
|
// var root_folder = "D:\\IStation\\ChErWebApi\\Data\\供水参数";
|
if (!System.IO.Directory.Exists(root_folder))
|
{
|
return null;
|
}
|
// var month_folder = System.IO.Path.Combine(root_folder, "累计总计");
|
// day.ToString("yyyy-MM")
|
List<OutTotalDayList> outTotalDayLists = new List<OutTotalDayList>();
|
if (StartDay < new DateTime(2022, 11, 2))
|
{
|
return null;
|
}
|
for (DateTime date = StartDay; date < EndDay; date = date.AddDays(1))
|
{
|
string Path = System.IO.Path.Combine(root_folder,
|
string.Format("{0}", date.ToString("yyyy-MM")));
|
string filepath = System.IO.Path.Combine(Path,
|
string.Format("{0}.json", date.ToString("yyyy-MM-dd")));
|
if (!File.Exists(filepath))
|
{
|
// var reuslt = GetByPumpOneDayWaterData(date, date);
|
// outTotalDayLists.Add(new OutTotalDayList() { pumpOutWater = reuslt, DateTime = reuslt[0].DateTime });
|
}
|
else
|
{
|
string Text = File.ReadAllText(filepath);
|
var outwater = Yw.JsonHelper.Json2Object<List<TotalOneDay>>(Text);
|
outTotalDayLists.Add(new OutTotalDayList() { pumpOutWater = outwater, DateTime = outwater[0].DateTime });
|
}
|
}
|
return outTotalDayLists;
|
}
|
|
public static List<SSAData> GetByPumpOneDayWaterData(DateTime starttime, DateTime endtime)
|
{
|
// string apiServiceUrl = System.Configuration.ConfigurationManager.AppSettings["ApiServiceUrl"];
|
string apiServiceUrl = "http://192.168.21.14:86/";
|
|
string url = string.Format(@"{0}/PumpRun/GetPumpHistoryData?startday={1}&endday={2}", apiServiceUrl, starttime, endtime);
|
string Accept = "application/json";
|
//创建Web访问对象
|
HttpWebRequest myRequest = (HttpWebRequest)WebRequest.Create(url);
|
myRequest.Method = "GET";
|
//myRequest.Accept = "application/json";
|
// myRequest.ContentType = "application/json"; // //Content-Type: application/x-www-form-urlencoded
|
myRequest.AutomaticDecompression = DecompressionMethods.GZip;
|
myRequest.Accept = Accept;
|
//myRequest.ContentType = ContentType;
|
myRequest.ContentType = "application/json; charset=UTF-8";
|
//myRequest.ContentLength = buf.Length;
|
myRequest.MaximumAutomaticRedirections = 1;
|
myRequest.AllowAutoRedirect = true;
|
HttpWebResponse myResponse = (HttpWebResponse)myRequest.GetResponse();
|
//通过响应内容流创建StreamReader对象，因为StreamReader更高级更快
|
StreamReader reader = new StreamReader(myResponse.GetResponseStream(), Encoding.UTF8);
|
//string returnXml = HttpUtility.UrlDecode(reader.ReadToEnd());//如果有编码问题就用这个方法
|
string returnData = reader.ReadToEnd();//利用StreamReader就可以从响应内容从头读到尾
|
if (string.IsNullOrEmpty(returnData))
|
{
|
myResponse.Close();
|
// error = "利用StreamReader就可以从响应内容从头读到尾";
|
return null;
|
}
|
var ret = Yw.JsonHelper.Json2Object<IStation.Dto.ApiResult<List<SSAData>>>(returnData);
|
reader.Close();
|
myResponse.Close();
|
// error = null;
|
return ret.Data;
|
}
|
|
public static List<SSAData> GetByPumpOpenState(DateTime starttime, DateTime endtime)
|
{
|
// string apiServiceUrl = System.Configuration.ConfigurationManager.AppSettings["ApiServiceUrl"];
|
string apiServiceUrl = "http://192.168.21.14:86/";
|
|
string url = string.Format(@"{0}/PumpRun/GetPumpOpenState?startday={1}&endday={2}", apiServiceUrl, starttime, endtime);
|
string Accept = "application/json";
|
//创建Web访问对象
|
HttpWebRequest myRequest = (HttpWebRequest)WebRequest.Create(url);
|
myRequest.Method = "GET";
|
//myRequest.Accept = "application/json";
|
// myRequest.ContentType = "application/json"; // //Content-Type: application/x-www-form-urlencoded
|
myRequest.AutomaticDecompression = DecompressionMethods.GZip;
|
myRequest.Accept = Accept;
|
//myRequest.ContentType = ContentType;
|
myRequest.ContentType = "application/json; charset=UTF-8";
|
//myRequest.ContentLength = buf.Length;
|
myRequest.MaximumAutomaticRedirections = 1;
|
myRequest.AllowAutoRedirect = true;
|
HttpWebResponse myResponse = (HttpWebResponse)myRequest.GetResponse();
|
//通过响应内容流创建StreamReader对象，因为StreamReader更高级更快
|
StreamReader reader = new StreamReader(myResponse.GetResponseStream(), Encoding.UTF8);
|
//string returnXml = HttpUtility.UrlDecode(reader.ReadToEnd());//如果有编码问题就用这个方法
|
string returnData = reader.ReadToEnd();//利用StreamReader就可以从响应内容从头读到尾
|
if (string.IsNullOrEmpty(returnData))
|
{
|
myResponse.Close();
|
// error = "利用StreamReader就可以从响应内容从头读到尾";
|
return null;
|
}
|
var ret = Yw.JsonHelper.Json2Object<IStation.Dto.ApiResult<List<SSAData>>>(returnData);
|
reader.Close();
|
myResponse.Close();
|
// error = null;
|
return ret.Data;
|
}
|
}
|
}
|
