NBDXSY/LeaRun.Application/LeaRun.Application.Busines/PipeNetworkManage/RealTimeMonitoringBLL.cs

using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using LeaRun.Application.Service.PipeNetworkManage;
using LeaRun.Util.WebControl;
using LeaRun.Util;
using LeaRun.Application.Entity.PipeNetworkManage;

namespace LeaRun.Application.Busines.PipeNetworkManage
{
    public class RealTimeMonitoringBLL
    {
        private RealTimeMonitoringService service = new RealTimeMonitoringService();

        #region 获取数据


        /// <summary>
        /// 实时列表 
        /// </summary>
        /// <param name="devId">监测点</param>
        /// <returns></returns>
        public string GetRealTimeData(string devId, Pagination pagination)
        {
            return service.GetRealTimeData(devId, pagination);
        }

        /// <summary>
        /// 实时分析
        /// </summary>
        /// <param name="departId"></param>
        /// <param name="devId"></param>
        /// <param name="pagination">分页参数</param>
        /// <param name="selField">分析字段</param>
        /// <param name="fieldName">字段名称</param>
        /// <returns></returns>
        public string GetRealTimeAnalysis(Pagination pagination, string selField, string fieldName)
        {
            return service.GetRealTimeAnalysis(pagination,selField,fieldName);
        }


        /// <summary>
        /// 获取实时图表
        /// </summary>
        /// <param name="tableNames"></param>
        /// <param name="type"></param>
        /// <returns></returns>
        public string GetRealCurves(string tableNames, string type)
        {
            var tables = Json.ToList<string>(tableNames);
            List<RealCurvesEntity> list = service.GetRealCurve(tables, type);
            StringBuilder sb = new StringBuilder("[");
            Dictionary<string, List<RealCurvesEntity>> d = new Dictionary<string, List<RealCurvesEntity>>();
            for (int i = 0; i < tables.Count; i++)
            {
                d.Add(tables[i], new List<RealCurvesEntity>());
            }
            for (int i = 0; i < list.Count; i++)
            {
                d["MeterAssessment_" + list[i].MeterAssessmentId].Add(list[i]);
            }
            return Json.ToJson(d);            
        } 
        #endregion
    }
}