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.Reflection;
using System.Security.Cryptography.X509Certificates;
using System.Security.Policy;
using System.Text;
using System.Web.Http;

namespace DongYingAPI.Controllers.api
{
    /// <summary>
    /// 用能监测1-碳排放
    /// </summary>
    public class GetCarbonEmissionController : ApiController
    {
        DataServer.BLL.electricity_data bll = new DataServer.BLL.electricity_data();
        DataServer.BLL.device_info bll_info = new DataServer.BLL.device_info();
        public HttpResponseMessage Get(string date = "")
        {
            var res = new get_carbon_emission();
            #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
            {
                if (!string.IsNullOrEmpty(date))
                {
                    var data = new List<carbon_emissionData>();
                    if (date == "日")
                    {
                        var list = bll_info.GetModelList(" FloorName='科技馆负一层地源热泵'");
                        var alist = list.Where(x => x.DeviceName.Contains("B1一次循环") || x.DeviceName.Contains("B5二次循环")).ToList();
                        var blist = list.Where(x => x.DeviceName.Contains("地源侧循环泵")).ToList();
                        var clist = list.Where(x => x.DeviceName.Contains("主机控制柜")).ToList();
                        var now = DateTime.Now;
                        var time_count = Convert.ToInt32(DateTime.Now.Hour);
                        for (int i = 1; i < time_count; i++)
                        {
                            // 只处理今日的数据
                            if (DateTime.Now.AddHours(-i).Day != DateTime.Now.Day)
                            {
                                continue;
                            }
                            time = now.AddDays(-i).ToString("yyyMM");
                            var atime = now.AddDays(-(i + 1)).ToString("yyyyMM");
                            var jtime = now.AddHours(-i).ToString("HH:00");
                            //这个小时
                            var ztime = now.AddHours(-i).ToString("yyyy-MM-dd HH:00:00");
                            //上个小时
                            var stime = now.AddHours(-(i + 1)).ToString("yyyy-MM-dd HH:00:00");
                            //这个小时列表
                            decimal? num1 = 0;
                            decimal? num2 = 0;
                            decimal? num3 = 0;
                            decimal? num4 = 0;
                            decimal? num5 = 0;
                            decimal? num6 = 0;
                            var alist1 = bll.GetModelListDate("EntireTime='" + ztime + "'", time);
                            var alist2 = bll.GetModelListDate(" EntireTime='" + stime + "'", atime);
                            foreach (var item in alist)
                            {
                                var list1 = alist1.Where(x => x.DeviceId == item.DeviceId);
                                num1 += Convert.ToDecimal(list1.Sum(x => x.EH));
                                var list2 = alist2.Where(x => x.DeviceId == item.DeviceId);
                                num4 += Convert.ToDecimal(list2.Sum(x => x.EH));
                            }
                            foreach (var item in blist)
                            {
                                var list1 = alist1.Where(x => x.DeviceId == item.DeviceId);
                                num2 += Convert.ToDecimal(list1.Sum(x => x.EH));
                                var list2 = alist2.Where(x => x.DeviceId == item.DeviceId);
                                num5 += Convert.ToDecimal(list2.Sum(x => x.EH));
                            }
                            foreach (var item in clist)
                            {
                                var list1 = alist1.Where(x => x.DeviceId == item.DeviceId);
                                num3 += Convert.ToDecimal(list1.Sum(x => x.EH));
                                var list2 = alist2.Where(x => x.DeviceId == item.DeviceId);
                                num6 += Convert.ToDecimal(list2.Sum(x => x.EH));
                            }

                            var model = new carbon_emissionData()
                            {
                                time = jtime,
                                PrimaryCirculation =Convert.ToDecimal( Math.Round(Convert.ToDouble((num1 - num4) / 1000 * Convert.ToDecimal(0.5703)),3)),
                                CollateralCirculation =Convert.ToDecimal(Math.Round(Convert.ToDouble((num2 - num5) / 1000 * Convert.ToDecimal(0.5703)),3)),
                                TerrestrialSource = Convert.ToDecimal(Math.Round(Convert.ToDouble((num3 - num6) / 1000 * Convert.ToDecimal(0.5703)), 3))
                            };
                            if (model.PrimaryCirculation < 0)
                            {
                                model.PrimaryCirculation = 0;
                            }
                            if(model.CollateralCirculation < 0)
                            {
                                model.CollateralCirculation= 0;
                            }
                            if(model.TerrestrialSource< 0)
                            {
                                model.TerrestrialSource = 0;
                            }
                            data.Add(model);

                        }
                    }
                    else if (date == "月")
                    {
                        var list = bll_info.GetModelList(" FloorName='科技馆负一层地源热泵'");
                        var alist = list.Where(x => x.DeviceName.Contains("B1一次循环") || x.DeviceName.Contains("B5二次循环")).ToList();
                        var blist = list.Where(x => x.DeviceName.Contains("地源侧循环泵")).ToList();
                        var clist = list.Where(x => x.DeviceName.Contains("主机控制柜")).ToList();
                        var now = DateTime.Now;
                        var time_count = Convert.ToInt32(DateTime.Now.Day);
                        for (int i = 0; i < time_count; i++)
                        {
                            // 只处理今月的数据
                            if (DateTime.Now.AddDays(-i).Month != DateTime.Now.Month)
                            {
                                continue;
                            }
                            time = now.AddDays(-i).ToString("yyyMM");
                            var a = bll.IsExistsTable(date_base, "electricity_data_" + time);
                            if (a == false)
                            {
                                bll.CreateTable(time);
                            }
                            var jtime = now.AddDays(-i).ToString("MM-dd");
                            var ztime = "";
                            if (i == 0)
                            {
                                //这天
                                ztime = now.AddDays(-i).AddHours(-1).ToString("yyyy-MM-dd HH:00:00");
                            }
                            else
                            {
                                //这天
                                ztime = now.AddDays(-i+1).ToString("yyyy-MM-dd 00:00:00");
                            }
                            //上天
                            var stime = now.AddDays(-(i)).ToString("yyyy-MM-dd 00:00:00");
                            var atime = now.AddDays(-(i)).ToString("yyyyMM");
                            var b = bll.IsExistsTable(date_base, "electricity_data_" + atime);
                            if (b == false)
                            {
                                bll.CreateTable(time);
                            }
                            //这个小时列表
                            decimal? num1 = 0;
                            decimal? num2 = 0;
                            decimal? num3 = 0;
                            decimal? num4 = 0;
                            decimal? num5 = 0;
                            decimal? num6 = 0;
                            var alist1 = bll.GetModelListDate("EntireTime='" + ztime + "'", time);
                            var alist2= bll.GetModelListDate(" EntireTime='" + stime + "'", atime);
                            foreach (var item in alist)
                            {
                                var list1 = alist1.Where(x=>x.DeviceId==item.DeviceId);
                                num1 += Convert.ToDecimal(list1.Sum(x => x.EH));
                                var list2 = alist2.Where(x => x.DeviceId == item.DeviceId);
                                num4 += Convert.ToDecimal(list2.Sum(x => x.EH));
                            }
                            foreach (var item in blist)
                            {
                                var list1 = alist1.Where(x => x.DeviceId == item.DeviceId);
                                num2 += Convert.ToDecimal(list1.Sum(x => x.EH));
                                var list2 = alist2.Where(x => x.DeviceId == item.DeviceId);
                                num5 += Convert.ToDecimal(list2.Sum(x => x.EH));
                            }
                            foreach (var item in clist)
                            {
                                var list1 = alist1.Where(x => x.DeviceId == item.DeviceId);
                                num3 += Convert.ToDecimal(list1.Sum(x => x.EH));
                                var list2 = alist2.Where(x => x.DeviceId == item.DeviceId);
                                num6 += Convert.ToDecimal(list2.Sum(x => x.EH));
                            }

                            var model = new carbon_emissionData()
                            {
                                time = jtime,
                                PrimaryCirculation = Convert.ToDecimal(Math.Round(Convert.ToDouble((num1 - num4) / 1000 * Convert.ToDecimal(0.5703)), 3)),
                                CollateralCirculation = Convert.ToDecimal(Math.Round(Convert.ToDouble((num2 - num5) / 1000 * Convert.ToDecimal(0.5703)), 3)),
                                TerrestrialSource = Convert.ToDecimal(Math.Round(Convert.ToDouble((num3 - num6) / 1000 * Convert.ToDecimal(0.5703)), 3))
                            };
                            if (model.PrimaryCirculation < 0)
                            {
                                model.PrimaryCirculation = 0;
                            }
                            if (model.CollateralCirculation < 0)
                            {
                                model.CollateralCirculation = 0;
                            }
                            if (model.TerrestrialSource < 0)
                            {
                                model.TerrestrialSource = 0;
                            }
                            data.Add(model);

                        }
                    }
                    else if (date == "年")
                    {

                        var list = bll_info.GetModelList(" FloorName='科技馆负一层地源热泵'");
                        var alist = list.Where(x => x.DeviceName.Contains("B1一次循环") || x.DeviceName.Contains("B5二次循环")).ToList();
                        var blist = list.Where(x => x.DeviceName.Contains("地源侧循环泵")).ToList();
                        var clist = list.Where(x => x.DeviceName.Contains("主机控制柜")).ToList();
                        var now = DateTime.Now;
                        var time_count = Convert.ToInt32(DateTime.Now.Month);
                        for (int i = 0; i < time_count; i++)
                        {
                            // 只处理今年的数据
                            if (DateTime.Now.AddMonths(-i).Year != DateTime.Now.Year)
                            {
                                continue;
                            }
                            time = now.AddMonths(-i).ToString("yyyMM");
                            var a = bll.IsExistsTable(date_base, "electricity_data_" + time);
                            if (a == false)
                            {
                                bll.CreateTable(time);
                            }
                            var jtime = now.AddMonths(-i).ToString("MM月");
                            var ztime1 = "";
                            DateTime ztime;
                            if (i == 0)
                            {
                                //这月
                                ztime1 = now.AddMonths(-i).AddHours(-1).ToString("yyyy-MM-dd HH:00:00");
                                ztime = Convert.ToDateTime(ztime1);
                            }
                            else
                            {
                                //这月
                                ztime1 = now.AddMonths(-i + 1).ToString("yyyy-MM-01 00:00:00");
                                var ztime2 = Convert.ToDateTime(ztime1);
                                ztime = ztime2.AddDays(-1);

                            }
                            //上天
                            var stime1 = now.AddMonths(-(i)).ToString("yyyy-MM-01 00:00:00");
                            var stime2 = Convert.ToDateTime(stime1);
                            var stime = stime2.AddDays(0);
                            var atime = stime.ToString("yyyyMM");
                            var b = bll.IsExistsTable(date_base, "electricity_data_" + atime);
                            if (b == false)
                            {
                                bll.CreateTable(atime);
                            }
                            //这个小时列表
                            decimal? num1 = 0;
                            decimal? num2 = 0;
                            decimal? num3 = 0;
                            decimal? num4 = 0;
                            decimal? num5 = 0;
                            decimal? num6 = 0;

                            var alist1 = bll.GetModelListDate("EntireTime='" + ztime + "'", time);
                            var alist2 = bll.GetModelListDate(" EntireTime='" + stime + "'", atime);
                            foreach (var item in alist)
                            {
                                var list1 = alist1.Where(x => x.DeviceId == item.DeviceId);
                                num1 += Convert.ToDecimal(list1.Sum(x => x.EH));
                                var list2 = alist2.Where(x => x.DeviceId == item.DeviceId);
                                num4 += Convert.ToDecimal(list2.Sum(x => x.EH));
                            }
                            foreach (var item in blist)
                            {
                                var list1 = alist1.Where(x => x.DeviceId == item.DeviceId);
                                num2 += Convert.ToDecimal(list1.Sum(x => x.EH));
                                var list2 = alist2.Where(x => x.DeviceId == item.DeviceId);
                                num5 += Convert.ToDecimal(list2.Sum(x => x.EH));
                            }
                            foreach (var item in clist)
                            {
                                var list1 = alist1.Where(x => x.DeviceId == item.DeviceId);
                                num3 += Convert.ToDecimal(list1.Sum(x => x.EH));
                                var list2 = alist2.Where(x => x.DeviceId == item.DeviceId);
                                num6 += Convert.ToDecimal(list2.Sum(x => x.EH));
                            }

                            var model = new carbon_emissionData()
                            {
                                time = jtime,
                                PrimaryCirculation = Convert.ToDecimal(Math.Round(Convert.ToDouble((num1 - num4) / 1000 * Convert.ToDecimal(0.5703)), 3)),
                                CollateralCirculation = Convert.ToDecimal(Math.Round(Convert.ToDouble((num2 - num5) / 1000 * Convert.ToDecimal(0.5703)), 3)),
                                TerrestrialSource = Convert.ToDecimal(Math.Round(Convert.ToDouble((num3 - num6) / 1000 * Convert.ToDecimal(0.5703)), 3))
                            };
                            if(model.PrimaryCirculation< 0)
                            {
                                model.PrimaryCirculation = 0;
                            }
                            if(model.CollateralCirculation< 0)
                            {
                                model.CollateralCirculation = 0;
                            }
                            if(model.TerrestrialSource< 0)
                            {
                                model.TerrestrialSource= 0;
                            }
                            data.Add(model);
                        }
                    }
                    var adata=data.OrderBy(x=>x.time).ToList();
                    res.code = 200;
                    res.msg = "成功";
                    res.data = adata;
                }
                else
                {
                    res.code = 201;
                    res.msg = "参数为空";
                }
            }
            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;
        }
    }
}