using DataServer.api.EnergyEfficiency;
using DongYingAPI.Util;
using Newtonsoft.Json;
using System;
using System.Collections.Generic;
using System.Configuration;
using System.Linq;
using System.Net;
using System.Net.Http;
using System.Text;
using System.Web.Http;
namespace DongYingAPI.Controllers.api.EnergyEfficiency
{
public class GetEnergyCalendarController : ApiController
{
DataServer.BLL.device_info device_bll = new DataServer.BLL.device_info();
DataServer.BLL.electricity_data bll = new DataServer.BLL.electricity_data();
DataServer.BLL.water_data water_bll = new DataServer.BLL.water_data();
DataServer.BLL.gas_data gas_bll = new DataServer.BLL.gas_data();
///
/// 获取能耗日历接口
///
/// 日期
///
public HttpResponseMessage Get(string Date)
{
var res = new get_energy_calendar_response();
try
{
var now = DateTime.Now;
var start_time = DateTime.Parse(Date + " 00:00:00");
var end_time = start_time.AddDays(1);
if (Date == now.ToString("yyyy-MM-dd"))
{
end_time = DateTime.Parse(now.ToString("yyyy-MM-dd HH") + ":00:00");
}
var water_data = new List();
var gas_data = new List();
var electricity_data = new List();
//总水量
decimal total_water = 0;
//根据事件查询两条数据,然后值相减为用水量
var water_list = water_bll.GetModelList(" EntireTime>='" + start_time + "' and EntireTime<='" + end_time + "' ");
var count = (end_time - start_time).TotalHours;
for (int i = 0; i < count; i++)
{
var start = start_time.AddHours(i);
var end = start.AddHours(1);
var start_data = water_list.Where(a => a.EntireTime.Value == start).FirstOrDefault();
var end_data = water_list.Where(a => a.EntireTime.Value == end).FirstOrDefault();
decimal water = 0;
if (start_data != null && end_data != null)
{
if (start_data.WaterYield != null && end_data.WaterYield != null)
{
decimal water_yield = end_data.WaterYield.Value - start_data.WaterYield.Value;
water = water_yield;
}
}
total_water += water;
var model = new energy_calendar_data();
model.Time = start.ToString("HH:mm");
model.Value = water;
water_data.Add(model);
}
//总天然气
decimal total_gas = 0;
var gas_list = gas_bll.GetModelList(" EntireTime>='" + start_time + "' and EntireTime<='" + end_time + "' ");
for (int i = 0; i < count; i++)
{
var start = start_time.AddHours(i);
var end = start.AddHours(1);
var start_data = gas_list.Where(a => a.EntireTime.Value == start).FirstOrDefault();
var end_data = gas_list.Where(a => a.EntireTime.Value == end).FirstOrDefault();
decimal natural_gas = 0;
if (start_data != null && end_data != null)
{
if (start_data.GasConsumption != null && end_data.GasConsumption != null)
{
decimal gas_consumption = end_data.GasConsumption.Value - start_data.GasConsumption.Value;
natural_gas = gas_consumption;
}
}
total_gas += natural_gas;
var model = new energy_calendar_data();
model.Time = start.ToString("HH:mm");
model.Value = natural_gas;
gas_data.Add(model);
}
//总电
decimal total_electricity = 0;
//判断表是否存在,不存在就创建
var date_base = ConfigurationManager.AppSettings["MySQLDataBase"].ToString();
var list = new List();
var time_count = Tool.GetUsedMonth1("月", start_time, end_time);
var source = "";
for (int i = 0; i <= time_count; i++)
{
var time = start_time.AddMonths(i).ToString("yyyyMM");
if (bll.IsExistsTable(date_base, "electricity_data_" + time))
{
if (time == start_time.ToString("yyyyMM") || time == end_time.ToString("yyyyMM"))
{
source += string.Format(" (select ElectricityId,DeviceId,EH,P,Kvar,Ia,Ib,Ic,Ua,Ub,Uc,ServiceRating,CreateTime,EntireTime,Reserve1,Reserve2,Reserve3,Reserve4,Reserve5 from electricity_data_{0} where EntireTime>='{1}' and EntireTime<='{2}'", time, start_time, end_time);
}
else
{
source += string.Format(" (select ElectricityId,DeviceId,EH,P,Kvar,Ia,Ib,Ic,Ua,Ub,Uc,ServiceRating,CreateTime,EntireTime,Reserve1,Reserve2,Reserve3,Reserve4,Reserve5 from electricity_data_{0} where 1=1 ", time);
}
source += ") UNION all ";
}
}
if (!string.IsNullOrEmpty(source))
{
source = source.Substring(0, source.Length - 11);
list = bll.GetList(source, "", "");
}
var device_list = device_bll.GetModelList("");
for (int i = 0; i < count; i++)
{
var start = start_time.AddHours(i);
var end = start.AddHours(1);
decimal electricity = 0;
foreach (var item in device_list)
{
var start_data = list.Where(a => a.DeviceId == item.DeviceId && a.EntireTime.Value == start).FirstOrDefault();
var end_data = list.Where(a => a.DeviceId == item.DeviceId && a.EntireTime.Value == end).FirstOrDefault();
if (start_data != null && end_data != null)
{
if (start_data.EH != null && end_data.EH != null)
{
decimal eh = end_data.EH.Value - start_data.EH.Value;
electricity += eh;
}
}
}
total_electricity += electricity;
var model = new energy_calendar_data();
model.Time = start.ToString("HH:mm");
model.Value = electricity;
electricity_data.Add(model);
}
res.code = 200;
res.msg = "成功";
res.data = new energy_calendar() { ElectricityList = new energy_calendar_list() { Total = total_electricity, List = electricity_data }, GasList = new energy_calendar_list() { Total = total_gas, List = gas_data }, WaterList = new energy_calendar_list() { Total = total_water, List = water_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;
}
}
}