using DataServer; using DataServer.api; using Newtonsoft.Json; using System; using System.Collections.Generic; using System.Linq; using System.Net; using System.Net.Http; using System.Reflection; using System.Security.Cryptography.X509Certificates; using System.Text; using System.Web.Http; namespace DongYingAPI.Controllers.api { /// /// 用能监测4-实时数据 /// public class GetRealtimeDataController : ApiController { DataServer.BLL.electricity_data bll = new DataServer.BLL.electricity_data(); DataServer.BLL.device_info bll_info = new DataServer.BLL.device_info(); public HttpResponseMessage Post([FromBody] select_switching_name room) { var res = new get_realtime_data(); try { if (!string.IsNullOrEmpty(room.name)) { var data=new List(); var date=DateTime.Now; var time = DateTime.Now.ToString("yyyyMM"); var sdate=DateTime.Now.ToString("yyyy-MM-dd 00:00:00"); var edate=DateTime.Now.AddDays(1).ToString("yyyy-MM-dd 00:00:00"); var list1=bll_info.GetModelList(" DeviceName='"+room.name+"'"); var llist = bll.GetModelListDate("CreateTime>='" + sdate + "' and CreateTime<'" + edate + "'", time); var alist = bll.GetModelListDate("CreateTime>='" + sdate + "' and CreateTime<'" + edate + "'", time); foreach (var bitem in list1) { var list = llist.Where(x=>x.DeviceId==bitem.DeviceId).ToList(); if (list.Count == 0) { var model = new realtime_dataData(); model.P = 0; model.LoadRate = 0; model.ConversionRate =0; model.DeviceState = 0; data.Add(model); } else { foreach (var item in list) { var model = new realtime_dataData(); model.P = item.P; decimal? num = 0; foreach (var aitem in alist) { num += aitem.P; } var cnum = Math.Round(Convert.ToDouble(item.P) / Convert.ToDouble(num), 3); model.LoadRate = Convert.ToDecimal(cnum) * 100; model.ConversionRate = Math.Round(Convert.ToDecimal(5.5) / Convert.ToDecimal(item.EH), 3) * 100; model.DeviceState = 1; data.Add(model); } } } res.code = 200; res.msg = "成功"; res.data = data; } 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; } } }