using DataServer.api; using Microsoft.Ajax.Utilities; using Newtonsoft.Json; using System; using System.Collections.Generic; using System.Linq; using System.Net; using System.Net.Http; using System.Text; using System.Web.Http; namespace JinanCementFactoryAPI.Controllers.api { /// /// 实时碳排放 /// public class GetRealtimeCarbonController : ApiController { DataServer.BLL.coal_equipment bll = new DataServer.BLL.coal_equipment(); DataServer.BLL.gw_data bll_gw = new DataServer.BLL.gw_data(); // GET api/ public HttpResponseMessage Get() { var res = new get_realtime_carbon(); try { var list = bll.GetModelList(""); var alist = new List(); var now=DateTime.Now; string time; if (now.Month < 10) { time = now.ToString("yyyy_M"); } else { time = now.ToString("yyyy_MM"); } for(var i = 0; i < 6; i++) { var sdate = now.AddHours(-i).ToString("yyyy-MM-dd HH:00:00"); var edate = now.AddHours(-(i + 1)).ToString("yyyy-MM-dd HH:00:00"); var model = new realtime_carbonData(); model.CarbonTime = DateTime.Now.AddHours(-i).ToString("HH:00"); decimal? num1 = 0; decimal? num2 = 0; var slist=string.Join(",", list.Select(x=>x.Reserve1)); var list1 = bll_gw.GetModelListsDate(slist, time).DistinctBy(x => new { x.XTagName, x.XTimeStamp }).ToList(); var alist1=new List(); if (i == 0) { alist1 = list1.GroupBy(x => x.XTagName).Select(g => g.OrderByDescending(x => x.XTimeStamp).FirstOrDefault()).ToList(); } else { alist1 = list1.Where(x => x.XTimeStamp == Convert.ToDateTime(sdate)).GroupBy(x => x.XTagName).Select(g => g.OrderByDescending(x => x.XTimeStamp).FirstOrDefault()).ToList(); } var alist2 = list1.Where(x => x.XTimeStamp == Convert.ToDateTime(edate)).GroupBy(x => x.XTagName).Select(g => g.OrderByDescending(x => x.XTimeStamp).FirstOrDefault()).ToList(); foreach (var item in alist1) { num1 += Convert.ToDecimal(item.XValue); } foreach (var item in alist2) { num2 += Convert.ToDecimal(item.XValue); } model.CarbonValue =Convert.ToDecimal(Math.Round(Convert.ToDouble((num1-num2) * Convert.ToDecimal(25.909) * Convert.ToDecimal(0.02610) * 44 / 12),3)) ; alist.Add(model); } res.code = 200; res.msg = "成功"; res.data = alist; } 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; } } }