using System;
|
using System.Collections;
|
using System.Collections.Generic;
|
using System.IO;
|
using System.Linq;
|
using System.Net;
|
using System.Text;
|
|
namespace IStation.BLL
|
{
|
/// <summary>
|
/// 水库水位
|
/// </summary>
|
public class ReservoirWaterLevel
|
{
|
public static double GetRealValue()
|
{
|
if (!ServiceParas.IsRemote)
|
{
|
return -100;
|
}
|
|
if (string.IsNullOrEmpty(ServiceParas.ApiServiceUrl))
|
{
|
return -100;
|
}
|
string url = string.Format(@"{0}/ReservoirWaterLevel/GetRealValue", ServiceParas.ApiServiceUrl);
|
|
//先根据用户请求的uri构造请求地址
|
//string serviceUrl = string.Format("{0}/{1}", this.BaseUri, uri);
|
//string ContentType = "application/json";
|
string Accept = "application/json";
|
//创建Web访问对象
|
HttpWebRequest myRequest = (HttpWebRequest)WebRequest.Create(url);
|
//把用户传过来的数据转成“UTF-8”的字节流
|
//byte[] buf = System.Text.Encoding.GetEncoding("UTF-8").GetBytes(parameterData);
|
|
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;
|
|
//myRequest.Headers.Add("content-type", "application/json");
|
//myRequest.Headers.Add("accept-encoding", "gzip");
|
//myRequest.Headers.Add("accept-charset", "utf-8");
|
|
//发送请求
|
//Stream stream = myRequest.GetRequestStream();
|
//stream.Write(buf, 0, buf.Length);
|
//stream.Close();
|
|
//通过Web访问对象获取响应内容
|
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();
|
return -100;
|
}
|
var ret = (new System.Web.Script.Serialization.JavaScriptSerializer()).Deserialize<IStation.Dto.ApiResult<double>>(returnData);
|
reader.Close();
|
myResponse.Close();
|
|
return ret.Data;
|
}
|
|
/// <summary>
|
/// 获取 预测值
|
/// </summary>
|
/// <returns></returns>
|
public static List<IStation.Model.WaterPredictRecord> GetPredictRecordByHourRange(DateTime start_time, DateTime end_time)
|
{
|
string apiServiceUrl = System.Configuration.ConfigurationManager.AppSettings["ApiServiceUrl"];
|
if (string.IsNullOrEmpty(apiServiceUrl))
|
{
|
return null;
|
}
|
string url = string.Format(@"{0}/ReservoirWaterLevel/GetPredictRecordByHourRange?start_time={1}&end_time={2}",
|
apiServiceUrl,
|
start_time.ToString("yyyy-MM-dd HH:mm:00"),
|
end_time.ToString("yyyy-MM-dd HH:mm:00"));
|
|
//先根据用户请求的uri构造请求地址
|
//string serviceUrl = string.Format("{0}/{1}", this.BaseUri, uri);
|
//string ContentType = "application/json";
|
string Accept = "application/json";
|
//创建Web访问对象
|
HttpWebRequest myRequest = (HttpWebRequest)WebRequest.Create(url);
|
//把用户传过来的数据转成“UTF-8”的字节流
|
//byte[] buf = System.Text.Encoding.GetEncoding("UTF-8").GetBytes(parameterData);
|
|
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;
|
|
//myRequest.Headers.Add("content-type", "application/json");
|
//myRequest.Headers.Add("accept-encoding", "gzip");
|
//myRequest.Headers.Add("accept-charset", "utf-8");
|
|
//发送请求
|
//Stream stream = myRequest.GetRequestStream();
|
//stream.Write(buf, 0, buf.Length);
|
//stream.Close();
|
|
//通过Web访问对象获取响应内容
|
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();
|
return null;
|
}
|
var ret = (new System.Web.Script.Serialization.JavaScriptSerializer()).Deserialize<IStation.Dto.ApiResult<List<IStation.Model.WaterPredictRecord>>>(returnData);
|
reader.Close();
|
myResponse.Close();
|
|
return ret.Data;
|
}
|
|
///// <summary>
|
///// 获取今日预测值(24点时)
|
///// </summary>
|
///// <returns></returns>
|
//public static double GetTodayEndPredictiveValue()
|
//{
|
// string apiServiceUrl = System.Configuration.ConfigurationManager.AppSettings["ApiServiceUrl"];
|
// if (string.IsNullOrEmpty(apiServiceUrl))
|
// {
|
// return -100;
|
// }
|
// string url = string.Format(@"{0}/ReservoirWaterLevel/GetTodayEndPredictiveValue", apiServiceUrl);
|
|
// //先根据用户请求的uri构造请求地址
|
// //string serviceUrl = string.Format("{0}/{1}", this.BaseUri, uri);
|
// //string ContentType = "application/json";
|
// string Accept = "application/json";
|
// //创建Web访问对象
|
// HttpWebRequest myRequest = (HttpWebRequest)WebRequest.Create(url);
|
// //把用户传过来的数据转成“UTF-8”的字节流
|
// //byte[] buf = System.Text.Encoding.GetEncoding("UTF-8").GetBytes(parameterData);
|
|
// 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;
|
|
// //myRequest.Headers.Add("content-type", "application/json");
|
// //myRequest.Headers.Add("accept-encoding", "gzip");
|
// //myRequest.Headers.Add("accept-charset", "utf-8");
|
|
// //发送请求
|
// //Stream stream = myRequest.GetRequestStream();
|
// //stream.Write(buf, 0, buf.Length);
|
// //stream.Close();
|
|
// //通过Web访问对象获取响应内容
|
// 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();
|
// return -100;
|
// }
|
// var ret = (new System.Web.Script.Serialization.JavaScriptSerializer()).Deserialize<IStation.Dto.ApiResult<double>>(returnData);
|
// reader.Close();
|
// myResponse.Close();
|
|
// return ret.Data;
|
//}
|
}
|
}
|
