209 lines
8.8 KiB
C#
209 lines
8.8 KiB
C#
using DataServer.api;
|
|
using Newtonsoft.Json;
|
|
using System;
|
|
using System.Collections.Generic;
|
|
using System.Configuration;
|
|
using System.Linq;
|
|
using System.Net;
|
|
using System.Net.Http;
|
|
using System.Runtime.Remoting.Channels;
|
|
using System.Runtime.Serialization;
|
|
using System.Text;
|
|
using System.Web.Http;
|
|
|
|
namespace DongYingAPI.Controllers.api
|
|
{
|
|
/// <summary>
|
|
/// 碳-碳流图1
|
|
/// </summary>
|
|
public class GetCarbonFluxController : ApiController
|
|
{
|
|
DataServer.BLL.electricity_data bll = new DataServer.BLL.electricity_data();
|
|
DataServer.BLL.device_info bll_info = new DataServer.BLL.device_info();
|
|
// GET api/<controller>
|
|
public HttpResponseMessage Get()
|
|
{
|
|
var res = new get_carbon_flux();
|
|
#region 表是否存在
|
|
//表名
|
|
var date_base = ConfigurationManager.AppSettings["MySQLDataBase"].ToString();
|
|
//今月的表是否存在
|
|
var time = DateTime.Now.ToString("yyyyMM");
|
|
var a1 = bll.IsExistsTable(date_base, "electricity_data_" + time);
|
|
if (a1 == false)
|
|
{
|
|
bll.CreateTable(time);
|
|
}
|
|
#endregion
|
|
try
|
|
{
|
|
var data = new List<carbon_fluxData>();
|
|
var model = new carbon_fluxData();
|
|
var list = bll_info.GetModelList("");
|
|
var now = DateTime.Now;
|
|
//这个
|
|
var ztime = now.AddHours(-1).ToString("yyyy-MM-dd HH:00:00");
|
|
//上个
|
|
var stime = now.ToString("yyyy-MM-dd 00:00:00");
|
|
var ltime = DateTime.Now.ToString("yyyyMM");
|
|
var aa = bll.IsExistsTable(date_base, "electricity_data_" + ltime);
|
|
if (aa == false)
|
|
{
|
|
bll.CreateTable(ltime);
|
|
}
|
|
//这个列表
|
|
var alist = bll.GetModelListDate("",time).Where(x => x.EntireTime == Convert.ToDateTime(ztime) ).ToList();
|
|
decimal? num1 = 0;
|
|
foreach (var item in alist)
|
|
{
|
|
num1 +=Convert.ToDecimal(item.EH);
|
|
}
|
|
//上个列表
|
|
var alists = bll.GetModelListDate("", ltime).Where(x => x.EntireTime == Convert.ToDateTime(stime)).ToList();
|
|
decimal? num2 = 0;
|
|
foreach (var item in alists)
|
|
{
|
|
num2 +=Convert.ToDecimal(item.EH);
|
|
}
|
|
decimal? num = num1 - num2;
|
|
#region 一级
|
|
model.AggregateName = "总量";
|
|
var e = Math.Round(Convert.ToDecimal(num / 1000 * Convert.ToDecimal(0.5703)), 4);
|
|
model.AggregateValue = e+Convert.ToDecimal(0.493);
|
|
#endregion
|
|
#region 天然气
|
|
var alist1 = new List<secondlevel>();
|
|
var amodel = new secondlevel();
|
|
amodel.SecondName = "天然气";
|
|
amodel.SecondValue =Convert.ToDecimal(0.493);
|
|
#endregion
|
|
#region 食堂
|
|
var tlist1 = new List<threelevel>();
|
|
var sbmodel = new threelevel();
|
|
sbmodel.ThreeName = "食堂";
|
|
sbmodel.ThreeValue = Convert.ToDecimal(0.493) ;
|
|
tlist1.Add(sbmodel);
|
|
#endregion
|
|
#region 电
|
|
var amodel1 = new secondlevel();
|
|
amodel1.SecondName = "电";
|
|
amodel1.SecondValue = Math.Round(Convert.ToDecimal(num / 1000 * Convert.ToDecimal(0.5703)), 3);
|
|
alist1.Add(amodel);
|
|
alist1.Add(amodel1);
|
|
model.list= alist1;
|
|
#endregion
|
|
#region 空调
|
|
var tlist= new List<threelevel>();
|
|
var klist = list.Where(x => x.DeviceName.Contains("空调")).ToList();
|
|
var bmodel = new threelevel();
|
|
bmodel.ThreeName = "空调";
|
|
decimal? num3 = 0;
|
|
decimal? num4 = 0;
|
|
foreach (var item in klist)
|
|
{
|
|
//这个
|
|
var list1 = alist.Where(x => x.DeviceId == item.DeviceId).ToList();
|
|
foreach (var aitem in list1)
|
|
{
|
|
num3 += aitem.EH;
|
|
}
|
|
//上个
|
|
var list2 = alists.Where(x => x.DeviceId == item.DeviceId).ToList();
|
|
foreach (var aitem in list2)
|
|
{
|
|
num4 += aitem.EH;
|
|
}
|
|
}
|
|
decimal? anum = num3 - num4;
|
|
bmodel.ThreeValue = Math.Round(Convert.ToDecimal(anum / 1000 * Convert.ToDecimal(0.5703)), 4);
|
|
tlist.Add(bmodel);
|
|
#endregion
|
|
#region 照明
|
|
var bmodel1 = new threelevel();
|
|
bmodel1.ThreeName = "照明";
|
|
var zlist = list.Where(x => x.DeviceName.Contains("照明")).ToList();
|
|
decimal? num5 = 0;
|
|
decimal? num6 = 0;
|
|
foreach (var item in zlist)
|
|
{
|
|
//这个
|
|
var list1 = alist.Where(x => x.DeviceId == item.DeviceId).ToList();
|
|
foreach (var aitem in list1)
|
|
{
|
|
num5 += aitem.EH;
|
|
}
|
|
//上个
|
|
var list2 = alists.Where(x => x.DeviceId == item.DeviceId).ToList();
|
|
foreach (var aitem in list2)
|
|
{
|
|
num6 += aitem.EH;
|
|
}
|
|
}
|
|
decimal? bnum = num5-num6;
|
|
bmodel1.ThreeValue = Math.Round(Convert.ToDecimal(bnum / 1000 * Convert.ToDecimal(0.5703)), 4);
|
|
tlist.Add(bmodel1);
|
|
|
|
#endregion
|
|
#region 电梯
|
|
var dmodel1 = new threelevel();
|
|
dmodel1.ThreeName = "电梯";
|
|
var dlist = list.Where(x => x.DeviceName.Contains("电梯") || x.DeviceName.Contains("梯")).ToList();
|
|
decimal? num7 = 0;
|
|
decimal? num8 = 0;
|
|
foreach (var item in dlist)
|
|
{
|
|
var list1 = alist.Where(x => x.DeviceId == item.DeviceId).ToList();
|
|
foreach (var aitem in list1)
|
|
{
|
|
num7 += aitem.EH;
|
|
}
|
|
var list2 = alists.Where(x => x.DeviceId == item.DeviceId).ToList();
|
|
foreach (var aitem in list2)
|
|
{
|
|
num8 += aitem.EH;
|
|
}
|
|
}
|
|
decimal? cnum = num7-num8;
|
|
dmodel1.ThreeValue = Math.Round(Convert.ToDecimal(cnum / 1000 * Convert.ToDecimal(0.5703)), 4);
|
|
tlist.Add(dmodel1);
|
|
#endregion
|
|
#region 其它
|
|
var qmodel1 = new threelevel();
|
|
qmodel1.ThreeName = "其它";
|
|
var qlist = list.Where(x =>!( x.DeviceName.Contains("电梯") || x.DeviceName.Contains("梯")||x.DeviceName.Contains("空调")||x.DeviceName.Contains("照明"))).ToList();
|
|
decimal? num9 = 0;
|
|
decimal? num10 = 0;
|
|
foreach (var item in qlist)
|
|
{
|
|
var list1 = alist.Where(x => x.DeviceId == item.DeviceId).ToList();
|
|
foreach (var aitem in list1)
|
|
{
|
|
num9 += aitem.EH;
|
|
}
|
|
var list2 = alists.Where(x => x.DeviceId == item.DeviceId).ToList();
|
|
foreach (var aitem in list2)
|
|
{
|
|
num10 += aitem.EH;
|
|
}
|
|
}
|
|
decimal? fnum = num9-num10;
|
|
qmodel1.ThreeValue = Math.Round(Convert.ToDecimal(fnum / 1000 * Convert.ToDecimal(0.5703)), 4);
|
|
tlist.Add(qmodel1);
|
|
#endregion
|
|
amodel.list = tlist1;
|
|
amodel1.list = tlist;
|
|
data.Add(model);
|
|
res.code = 200;
|
|
res.msg = "成功";
|
|
res.data = data;
|
|
}
|
|
catch (Exception ex)
|
|
{
|
|
res.code = 500;
|
|
res.msg = "失败," + ex.Message;
|
|
}
|
|
HttpResponseMessage result = new HttpResponseMessage { Content = new StringContent(JsonConvert.SerializeObject(res), Encoding.GetEncoding("UTF-8"), "application/json") };
|
|
return result;
|
|
}
|
|
}
|
|
} |