NBDXSY/LeaRun.Application/LeaRun.Application.Service/PipeNetworkManage/FlowService.cs

using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using LeaRun.Application.IService.PipeNetworkManage;
using LeaRun.Data;
using System.Data;
using LeaRun.Util;
namespace LeaRun.Application.Service.PipeNetworkManage
{
    public class FlowService : IFlowService
    {
        SqlHelper sqlHelper = new SqlHelper("PipeNetworkDb");

        /// <summary>
        /// 压力报表
        /// </summary>
        /// <param name="typeFlag">0-日 1-月 2-年</param>
        /// <param name="ids">设备ID集合</param>
        /// <param name="time">查询日期</param>
        /// <returns></returns>
        public string GetFlowReport(string typeFlag, string ids, string time)
        {
            try
            {
                //DateTime nowTime = Convert.ToDateTime(time);
                string sql = "SELECT * FROM  MeterAssessmentBase WHERE MeterAssessmentId IN (" + ids + ")";
                DataTable dt = sqlHelper.ExecuteDataTable(sql, CommandType.Text, null);
                StringBuilder jqData = new StringBuilder();
                jqData.Append("[");
                switch (typeFlag)
                {
                    case "0":
                        jqData.Append(GetDayReportData(dt, time));
                        break;
                    case "1":
                        DateTime nowTime = Convert.ToDateTime(time + "/01");
                        jqData.Append(GetMonthReportData(dt, nowTime));
                        break;
                    case "2":
                        DateTime yearTime = Convert.ToDateTime(time + "/01/01");
                        jqData.Append(GetYearReportData(dt, yearTime));
                        break;
                }
                jqData.Append("]");

                return jqData.ToString();
            }
            catch (Exception ex)
            {
                return "[]";
            }
        }

        /// <summary>
        /// 压力日报表数据
        /// </summary>
        /// <param name="dt"></param>
        /// <param name="time"></param>
        /// <returns></returns>
        public StringBuilder GetDayReportData(DataTable dt, string time)
        {
            StringBuilder sbText = new StringBuilder();
            DataTable[] dtSources = new DataTable[dt.Rows.Count];
            double[] maxValue = new double[dt.Rows.Count];
            double[] minValue = new double[dt.Rows.Count];
            double[] sunValue = new double[dt.Rows.Count];
            DateTime[] maxValueTime = new DateTime[dt.Rows.Count];
            DateTime[] minValueTime = new DateTime[dt.Rows.Count];
            int numCount = 0; ;
            for (int i = 0; i < 24; i++)
            {
                sbText.Append("{");
                sbText.Append("\"showtime\":\"").Append(i + ":00").Append("\",");

                for (int row = 0; row < dt.Rows.Count; row++)
                {
                    string deviceId = dt.Rows[row]["MeterAssessmentId"].ToString();
                    string tableName = "MeterAssessment_" + deviceId;
                    string selDr = "GetDateTime='" + time + " " + i + ":00:00" + "'";
                    string selSql = "SELECT * FROM " + tableName + " WHERE DATEDIFF(DAY, '" + time + "' ,GetDateTime)=0 ORDER BY GetDateTime";
                    DataTable dtResult;
                    //结果存储 避免大量访问数据库
                    if (dtSources[row] != null)
                    {
                        dtResult = dtSources[row];
                    }
                    else
                    {
                        dtResult = sqlHelper.ExecuteDataTable(selSql, CommandType.Text, null);
                        dtSources[row] = dtResult;
                    }

                    DataRow[] drs = dtResult.Select(selDr);

                    if (drs.Count() > 0)
                    {
                        numCount++;
                        DateTime tempTime = Convert.ToDateTime(drs[0]["GetDateTime"].ToString());
                        double instantaneousFlow = Convert.ToDouble(drs[0]["InstantaneousFlow"]);
                        //初始化
                        if (i == 0)
                        {
                            minValue[row] = instantaneousFlow;
                            maxValue[row] = instantaneousFlow;
                            sunValue[row] = instantaneousFlow;
                            maxValueTime[row] = tempTime;
                            minValueTime[row] = tempTime;
                        }
                        else
                        {
                            if (minValue[row] > instantaneousFlow)
                            {
                                minValue[row] = instantaneousFlow;
                                minValueTime[row] = tempTime;
                            }
                            if (maxValue[row] < instantaneousFlow)
                            {
                                maxValue[row] = instantaneousFlow;
                                maxValueTime[row] = tempTime;
                            }
                            sunValue[row] = sunValue[row] + instantaneousFlow;
                        }

                        sbText.Append("\"flow_" + deviceId + "\":\"").Append(drs[0]["InstantaneousFlow"]).Append("\"");
                    }
                    else
                    {
                        sbText.Append("\"flow_" + deviceId + "\":\"").Append("--").Append("\"");
                    }
                    if (row < dt.Rows.Count - 1) sbText.Append(",");
                }
                sbText.Append("},");
            }
            #region 平均值 最小值  最大值
            sbText.Append("{");
            sbText.Append("\"showtime\":\"").Append("平均值").Append("\",");
            //一天中的 平均值
            for (int i = 0; i < dt.Rows.Count; i++)
            {
                string deviceId = dt.Rows[i]["MeterAssessmentId"].ToString();
                sbText.Append("\"flow_" + deviceId + "\":\"").Append((sunValue[i] / numCount).ToString("0.00")).Append("\"");
                if (i < dt.Rows.Count - 1) sbText.Append(",");
            }
            sbText.Append("},");
            sbText.Append("{");
            sbText.Append("\"showtime\":\"").Append("最小值").Append("\",");
            //一天中的 最小值
            for (int i = 0; i < dt.Rows.Count; i++)
            {
                string deviceId = dt.Rows[i]["MeterAssessmentId"].ToString();
                sbText.Append("\"flow_" + deviceId + "\":\"").Append(minValue[i]).Append("\"");
                if (i < dt.Rows.Count - 1) sbText.Append(",");
            }
            sbText.Append("},");

            sbText.Append("{");
            sbText.Append("\"showtime\":\"").Append("最小值时间").Append("\",");
            //一天中的 最小值时间
            for (int i = 0; i < dt.Rows.Count; i++)
            {
                string deviceId = dt.Rows[i]["MeterAssessmentId"].ToString();
                sbText.Append("\"flow_" + deviceId + "\":\"").Append(minValueTime[i].ToString("HH:mm")).Append("\"");
                if (i < dt.Rows.Count - 1) sbText.Append(",");
            }
            sbText.Append("},");

            sbText.Append("{");
            sbText.Append("\"showtime\":\"").Append("最大值").Append("\",");
            //一天中的 最大值
            for (int i = 0; i < dt.Rows.Count; i++)
            {
                string deviceId = dt.Rows[i]["MeterAssessmentId"].ToString();
                sbText.Append("\"flow_" + deviceId + "\":\"").Append(maxValue[i]).Append("\"");
                if (i < dt.Rows.Count - 1) sbText.Append(",");
            }
            sbText.Append("},");

            sbText.Append("{");
            sbText.Append("\"showtime\":\"").Append("最大值时间").Append("\",");
            //一天中的 最小值时间
            for (int i = 0; i < dt.Rows.Count; i++)
            {
                string deviceId = dt.Rows[i]["MeterAssessmentId"].ToString();
                sbText.Append("\"flow_" + deviceId + "\":\"").Append(maxValueTime[i].ToString("HH:mm")).Append("\"");
                if (i < dt.Rows.Count - 1) sbText.Append(",");
            }
            sbText.Append("},");

            sbText.Append("{");
            sbText.Append("\"showtime\":\"").Append("变化系数").Append("\",");
            //一天中的  变化系数  最大值/平均值
            for (int i = 0; i < dt.Rows.Count; i++)
            {
                string deviceId = dt.Rows[i]["MeterAssessmentId"].ToString();
                sbText.Append("\"flow_" + deviceId + "\":\"").Append((maxValue[i] / (sunValue[i] / numCount)).ToString("0.00")).Append("\"");
                if (i < dt.Rows.Count - 1) sbText.Append(",");
            }
            sbText.Append("}");
            #endregion

            return sbText;
        }

        /// <summary>
        /// 压力报表 -日报表 动态表头创建
        /// </summary>
        /// <param name="ids"></param>
        /// <returns></returns>
        public string GetFlowDayReportHead(string ids)
        {
            try
            {
                string sql = "SELECT * FROM  MeterAssessmentBase WHERE MeterAssessmentId IN (" + ids + ")";
                DataTable dt = sqlHelper.ExecuteDataTable(sql, CommandType.Text, null);
                StringBuilder sbColMod = new StringBuilder();
                sbColMod.Append("[");
                sbColMod.Append("{");
                sbColMod.Append("\"label\":\"").Append("时间").Append("\",");
                sbColMod.Append("\"name\":\"").Append("showtime").Append("\",");
                sbColMod.Append("\"align\":\"").Append("center").Append("\",");
                sbColMod.Append("\"width\":\"").Append("100").Append("\",");
                sbColMod.Append("\"sortable \":\"").Append("false").Append("\"");
                sbColMod.Append("}");

                for (int i = 0; i < dt.Rows.Count; i++)
                {
                    string deviceId = dt.Rows[i]["MeterAssessmentId"].ToString();
                    string name = dt.Rows[i]["MeterAssessmentName"].ToString();

                    if (i == 0) sbColMod.Append(",");
                    sbColMod.Append("{");
                    sbColMod.Append("\"label\":\"").Append(name).Append("\",");
                    sbColMod.Append("\"name\":\"").Append("flow_" + deviceId).Append("\",");
                    sbColMod.Append("\"align\":\"").Append("center").Append("\",");
                    sbColMod.Append("\"width\":\"").Append("150").Append("\",");
                    sbColMod.Append("\"sortable \":\"").Append("false").Append("\"");
                    sbColMod.Append("}");

                    if (i < dt.Rows.Count - 1)
                    {
                        sbColMod.Append(",");
                    }
                }
                sbColMod.Append("]");

                return sbColMod.ToString();
            }
            catch (Exception ex)
            {
                return "[]";
            }
        }


        /// <summary>
        /// 压力报表 -月（年）报表 动态表头创建
        /// </summary>
        /// <param name="ids"></param>
        /// <returns></returns>
        public string GetFlowMonthReportHead(string ids)
        {
            try
            {
                string sql = "SELECT * FROM  MeterAssessmentBase WHERE MeterAssessmentId IN (" + ids + ")";
                DataTable dt = sqlHelper.ExecuteDataTable(sql, CommandType.Text, null);
                StringBuilder sbColMod = new StringBuilder();
                sbColMod.Append("[");
                sbColMod.Append("{");
                sbColMod.Append("\"label\":\"").Append("时间").Append("\",");
                sbColMod.Append("\"name\":\"").Append("showtime").Append("\",");
                sbColMod.Append("\"align\":\"").Append("center").Append("\",");
                sbColMod.Append("\"width\":\"").Append("100").Append("\",");
                sbColMod.Append("\"sortable \":\"").Append("false").Append("\"");
                sbColMod.Append("}");

                for (int i = 0; i < dt.Rows.Count; i++)
                {
                    string deviceId = dt.Rows[i]["MeterAssessmentId"].ToString();
                    string name = dt.Rows[i]["MeterAssessmentName"].ToString();

                    if (i == 0) sbColMod.Append(",");
                    sbColMod.Append("{");
                    sbColMod.Append("\"label\":\"").Append("平均值").Append("\",");
                    sbColMod.Append("\"name\":\"").Append("avg_" + deviceId).Append("\",");
                    sbColMod.Append("\"align\":\"").Append("center").Append("\",");
                    sbColMod.Append("\"width\":\"").Append("150").Append("\",");
                    sbColMod.Append("\"sortable \":\"").Append("false").Append("\"");
                    sbColMod.Append("},");
                    sbColMod.Append("{");
                    sbColMod.Append("\"label\":\"").Append("最大值").Append("\",");
                    sbColMod.Append("\"name\":\"").Append("max_" + deviceId).Append("\",");
                    sbColMod.Append("\"align\":\"").Append("center").Append("\",");
                    sbColMod.Append("\"width\":\"").Append("150").Append("\",");
                    sbColMod.Append("\"sortable \":\"").Append("false").Append("\"");
                    sbColMod.Append("},");
                    sbColMod.Append("{");
                    sbColMod.Append("\"label\":\"").Append("最小值").Append("\",");
                    sbColMod.Append("\"name\":\"").Append("min_" + deviceId).Append("\",");
                    sbColMod.Append("\"align\":\"").Append("center").Append("\",");
                    sbColMod.Append("\"width\":\"").Append("150").Append("\",");
                    sbColMod.Append("\"sortable \":\"").Append("false").Append("\"");
                    sbColMod.Append("}");

                    if (i < dt.Rows.Count - 1)
                    {
                        sbColMod.Append(",");
                    }
                }
                sbColMod.Append("]");

                return sbColMod.ToString();
            }
            catch (Exception ex)
            {
                return "[]";
            }
        }

        /// <summary>
        /// 压力月报表获取
        /// </summary>
        /// <param name="dt"></param>
        /// <param name="time"></param>`
        /// <returns></returns>
        public StringBuilder GetMonthReportData(DataTable dt, DateTime time)
        {
            StringBuilder sbText = new StringBuilder();
            DataTable[] dtSources = new DataTable[dt.Rows.Count];

            int numCount = 0;
            int days = Time.GetDaysOfMonth(time.Year, time.Month);
            for (int i = 0; i < days; i++)
            {
                sbText.Append("{");
                sbText.Append("\"showtime\":\"").Append(time.AddDays(i).ToShortDateString()).Append("\",");

                for (int row = 0; row < dt.Rows.Count; row++)
                {
                    string deviceId = dt.Rows[row]["MeterAssessmentId"].ToString();
                    string tableName = "MeterAssessment_" + deviceId;

                    string selSql = "SELECT DAY(GetDateTime) AS monthDay ,max(InstantaneousFlow) AS maxFlow ,MIN(InstantaneousFlow) AS minFlow,AVG(InstantaneousFlow) AS avgFlow  FROM " + tableName + " WHERE DATEDIFF(MONTH,'" + time + "',GetDateTime)=0 GROUP BY DAY(GetDateTime) ORDER BY DAY(GetDateTime)";
                    DataTable dtResult;
                    //结果存储 避免大量访问数据库
                    if (dtSources[row] != null)
                    {
                        dtResult = dtSources[row];
                    }
                    else
                    {
                        dtResult = sqlHelper.ExecuteDataTable(selSql, CommandType.Text, null);
                        dtSources[row] = dtResult;
                    }

                    DataRow[] drs = dtResult.Select("monthDay=" + (i + 1));

                    if (drs.Count() > 0)
                    {
                        numCount++;
                        sbText.Append("\"avg_" + deviceId + "\":\"").Append(drs[0]["avgFlow"]).Append("\",");
                        sbText.Append("\"max_" + deviceId + "\":\"").Append(drs[0]["maxFlow"]).Append("\",");
                        sbText.Append("\"min_" + deviceId + "\":\"").Append(drs[0]["minFlow"]).Append("\"");
                    }
                    else
                    {
                        sbText.Append("\"avg_" + deviceId + "\":\"").Append("--").Append("\",");
                        sbText.Append("\"max_" + deviceId + "\":\"").Append("--").Append("\",");
                        sbText.Append("\"min_" + deviceId + "\":\"").Append("--").Append("\"");
                    }
                    if (row < dt.Rows.Count - 1) sbText.Append(",");
                }
                sbText.Append("},");
                //if (i < days - 1) sbText.Append(",");
            }

            #region 平均值 最小值  最大值
            double maxAvg = 0;
            double avgAvg = 0;
            double maxMax = 0;
            double avgMax = 0;
            double maxMin = 0;
            double avgMin = 0;
            sbText.Append("{");
            sbText.Append("\"showtime\":\"").Append("平均值").Append("\",");
            //一月中的 平均值
            for (int i = 0; i < dt.Rows.Count; i++)
            {
                DataTable tempDt = dtSources[i];
                var avg_avg = tempDt.Compute("avg(avgFlow)", "");
                var avg_max = tempDt.Compute("avg(maxFlow)", "");
                var avg_min = tempDt.Compute("avg(minFlow)", "");
                avgAvg = Convert.ToDouble(avg_avg);
                avgMax = Convert.ToDouble(avg_max);
                avgMin = Convert.ToDouble(avg_min);
                string deviceId = dt.Rows[i]["MeterAssessmentId"].ToString();
                sbText.Append("\"avg_" + deviceId + "\":\"").Append(avg_avg).Append("\",");
                sbText.Append("\"max_" + deviceId + "\":\"").Append(avg_max).Append("\",");
                sbText.Append("\"min_" + deviceId + "\":\"").Append(avg_min).Append("\"");
                if (i < dt.Rows.Count - 1) sbText.Append(",");
            }
            sbText.Append("},");
            sbText.Append("{");
            sbText.Append("\"showtime\":\"").Append("最小值").Append("\",");
            //一月中的 最小值
            for (int i = 0; i < dt.Rows.Count; i++)
            {
                string deviceId = dt.Rows[i]["MeterAssessmentId"].ToString();
                DataTable tempDt = dtSources[i];
                tempDt.DefaultView.Sort = "avgFlow";
                tempDt.AcceptChanges();
                sbText.Append("\"avg_" + deviceId + "\":\"").Append(tempDt.Rows.Count > 0 ? tempDt.Rows[0]["avgFlow"] : "--").Append("\",");
                tempDt.DefaultView.Sort = "maxFlow";
                tempDt.AcceptChanges();
                sbText.Append("\"max_" + deviceId + "\":\"").Append(tempDt.Rows.Count > 0 ? tempDt.Rows[0]["maxFlow"] : "--").Append("\",");
                tempDt.DefaultView.Sort = "minFlow";
                tempDt.AcceptChanges();
                sbText.Append("\"min_" + deviceId + "\":\"").Append(tempDt.Rows.Count > 0 ? tempDt.Rows[0]["minFlow"] : "--").Append("\"");
                if (i < dt.Rows.Count - 1) sbText.Append(",");
            }
            sbText.Append("},");

            sbText.Append("{");
            sbText.Append("\"showtime\":\"").Append("最小值时间").Append("\",");
            //一月中的 最小值时间
            for (int i = 0; i < dt.Rows.Count; i++)
            {
                string deviceId = dt.Rows[i]["MeterAssessmentId"].ToString();
                DataTable tempDt = dtSources[i];
                tempDt.DefaultView.Sort = "avgFlow";
                tempDt.AcceptChanges();
                sbText.Append("\"avg_" + deviceId + "\":\"").Append(tempDt.Rows.Count > 0 ? time.Year + "-" + time.Month + "-" + tempDt.Rows[0]["monthDay"] : "--").Append("\",");
                tempDt.DefaultView.Sort = "maxFlow";
                tempDt.AcceptChanges();
                sbText.Append("\"max_" + deviceId + "\":\"").Append(tempDt.Rows.Count > 0 ? time.Year + "-" + time.Month + "-" + tempDt.Rows[0]["monthDay"] : "--").Append("\",");
                tempDt.DefaultView.Sort = "minFlow";
                tempDt.AcceptChanges();
                sbText.Append("\"min_" + deviceId + "\":\"").Append(tempDt.Rows.Count > 0 ? time.Year + "-" + time.Month + "-" + tempDt.Rows[0]["monthDay"] : "--").Append("\"");

                if (i < dt.Rows.Count - 1) sbText.Append(",");
            }
            sbText.Append("},");

            sbText.Append("{");
            sbText.Append("\"showtime\":\"").Append("最大值").Append("\",");
            //一月中的 最大值
            for (int i = 0; i < dt.Rows.Count; i++)
            {
                string deviceId = dt.Rows[i]["MeterAssessmentId"].ToString();
                DataTable tempDt = dtSources[i];
                tempDt.DefaultView.Sort = "avgFlow desc";
                tempDt.AcceptChanges();
                sbText.Append("\"avg_" + deviceId + "\":\"").Append(tempDt.Rows.Count > 0 ? tempDt.Rows[0]["avgFlow"] : "--").Append("\",");
                maxAvg = tempDt.Rows.Count > 0 ? Convert.ToDouble(tempDt.Rows[0]["avgFlow"].ToString()) : 0;
                tempDt.DefaultView.Sort = "maxFlow desc";
                tempDt.AcceptChanges();
                sbText.Append("\"max_" + deviceId + "\":\"").Append(tempDt.Rows.Count > 0 ? tempDt.Rows[0]["maxFlow"] : "--").Append("\",");
                maxMax = tempDt.Rows.Count > 0 ? Convert.ToDouble(tempDt.Rows[0]["maxFlow"].ToString()) : 0;
                tempDt.DefaultView.Sort = "minFlow desc";
                tempDt.AcceptChanges();
                sbText.Append("\"min_" + deviceId + "\":\"").Append(tempDt.Rows.Count > 0 ? tempDt.Rows[0]["minFlow"] : "--").Append("\"");
                maxMin = tempDt.Rows.Count > 0 ? Convert.ToDouble(tempDt.Rows[0]["minFlow"].ToString()) : 0;
                if (i < dt.Rows.Count - 1) sbText.Append(",");
            }
            sbText.Append("},");

            sbText.Append("{");
            sbText.Append("\"showtime\":\"").Append("最大值时间").Append("\",");
            //一月中的 最小值时间
            for (int i = 0; i < dt.Rows.Count; i++)
            {
                string deviceId = dt.Rows[i]["MeterAssessmentId"].ToString();
                DataTable tempDt = dtSources[i];
                tempDt.DefaultView.Sort = "avgFlow desc";
                tempDt.AcceptChanges();
                sbText.Append("\"avg_" + deviceId + "\":\"").Append(tempDt.Rows.Count > 0 ? time.Year + "-" + time.Month + "-" + tempDt.Rows[0]["monthDay"] : "--").Append("\",");
                tempDt.DefaultView.Sort = "maxFlow desc";
                tempDt.AcceptChanges();
                sbText.Append("\"max_" + deviceId + "\":\"").Append(tempDt.Rows.Count > 0 ? time.Year + "-" + time.Month + "-" + tempDt.Rows[0]["monthDay"] : "--").Append("\",");
                tempDt.DefaultView.Sort = "minFlow desc";
                tempDt.AcceptChanges();
                sbText.Append("\"min_" + deviceId + "\":\"").Append(tempDt.Rows.Count > 0 ? time.Year + "-" + time.Month + "-" + tempDt.Rows[0]["monthDay"] : "--").Append("\"");

                if (i < dt.Rows.Count - 1) sbText.Append(",");
            }
            sbText.Append("},");

            sbText.Append("{");
            sbText.Append("\"showtime\":\"").Append("变化系数").Append("\",");
            //一月中的  变化系数  最大值/平均值
            for (int i = 0; i < dt.Rows.Count; i++)
            {
                string deviceId = dt.Rows[i]["MeterAssessmentId"].ToString();

                sbText.Append("\"avg_" + deviceId + "\":\"").Append((maxAvg / avgAvg).ToString("0.00")).Append("\",");
                sbText.Append("\"max_" + deviceId + "\":\"").Append((maxMax / avgMax).ToString("0.00")).Append("\",");
                sbText.Append("\"min_" + deviceId + "\":\"").Append((maxMin / avgMin).ToString("0.00")).Append("\"");
                if (i < dt.Rows.Count - 1) sbText.Append(",");
            }
            sbText.Append("}");
            #endregion

            return sbText;
        }

        /// <summary>
        /// 压力年报表获取
        /// </summary>
        /// <param name="dt"></param>
        /// <param name="time"></param>
        /// <returns></returns>
        public StringBuilder GetYearReportData(DataTable dt, DateTime time)
        {
            StringBuilder sbText = new StringBuilder();
            DataTable[] dtSources = new DataTable[dt.Rows.Count];

            int numCount = 0;
            for (int i = 0; i < 12; i++)
            {
                sbText.Append("{");
                sbText.Append("\"showtime\":\"").Append(time.AddMonths(i).ToString("yyyy-MM")).Append("\",");

                for (int row = 0; row < dt.Rows.Count; row++)
                {
                    string deviceId = dt.Rows[row]["MeterAssessmentId"].ToString();
                    string tableName = "MeterAssessment_" + deviceId;

                    string selSql = "SELECT MONTH(GetDateTime) AS monthDay ,max(InstantaneousFlow) AS maxFlow ,MIN(InstantaneousFlow) AS minFlow,AVG(InstantaneousFlow) AS avgFlow  FROM " + tableName + " WHERE DATEDIFF(YEAR,'" + time + "',GetDateTime)=0 GROUP BY MONTH(GetDateTime) ORDER BY MONTH(GetDateTime)";
                    DataTable dtResult;
                    //结果存储 避免大量访问数据库
                    if (dtSources[row] != null)
                    {
                        dtResult = dtSources[row];
                    }
                    else
                    {
                        dtResult = sqlHelper.ExecuteDataTable(selSql, CommandType.Text, null);
                        dtSources[row] = dtResult;
                    }

                    DataRow[] drs = dtResult.Select("monthDay=" + (i + 1));

                    if (drs.Count() > 0)
                    {
                        numCount++;
                        sbText.Append("\"avg_" + deviceId + "\":\"").Append(drs[0]["avgFlow"]).Append("\",");
                        sbText.Append("\"max_" + deviceId + "\":\"").Append(drs[0]["maxFlow"]).Append("\",");
                        sbText.Append("\"min_" + deviceId + "\":\"").Append(drs[0]["maxFlow"]).Append("\"");
                    }
                    else
                    {
                        sbText.Append("\"avg_" + deviceId + "\":\"").Append("--").Append("\",");
                        sbText.Append("\"max_" + deviceId + "\":\"").Append("--").Append("\",");
                        sbText.Append("\"min_" + deviceId + "\":\"").Append("--").Append("\"");
                    }
                    if (row < dt.Rows.Count - 1) sbText.Append(",");
                }
                sbText.Append("},");
                //if (i < days - 1) sbText.Append(",");
            }

            #region 平均值 最小值  最大值
            double maxAvg = 0;
            double avgAvg = 0;
            double maxMax = 0;
            double avgMax = 0;
            double maxMin = 0;
            double avgMin = 0;
            sbText.Append("{");
            sbText.Append("\"showtime\":\"").Append("平均值").Append("\",");
            //一月中的 平均值
            for (int i = 0; i < dt.Rows.Count; i++)
            {
                DataTable tempDt = dtSources[i];
                var avg_avg = tempDt.Compute("avg(avgFlow)", "");
                var avg_max = tempDt.Compute("avg(maxFlow)", "");
                var avg_min = tempDt.Compute("avg(maxFlow)", "");
                avgAvg = Convert.ToDouble(avg_avg);
                avgMax = Convert.ToDouble(avg_max);
                avgMin = Convert.ToDouble(avg_min);
                string deviceId = dt.Rows[i]["MeterAssessmentId"].ToString();
                sbText.Append("\"avg_" + deviceId + "\":\"").Append(avg_avg).Append("\",");
                sbText.Append("\"max_" + deviceId + "\":\"").Append(avg_max).Append("\",");
                sbText.Append("\"min_" + deviceId + "\":\"").Append(avg_min).Append("\"");
                if (i < dt.Rows.Count - 1) sbText.Append(",");
            }
            sbText.Append("},");
            sbText.Append("{");
            sbText.Append("\"showtime\":\"").Append("最小值").Append("\",");
            //一月中的 最小值
            for (int i = 0; i < dt.Rows.Count; i++)
            {
                string deviceId = dt.Rows[i]["MeterAssessmentId"].ToString();
                DataTable tempDt = dtSources[i];
                tempDt.DefaultView.Sort = "avgFlow";
                tempDt.AcceptChanges();
                sbText.Append("\"avg_" + deviceId + "\":\"").Append(tempDt.Rows.Count > 0 ? tempDt.Rows[0]["avgFlow"] : "--").Append("\",");
                tempDt.DefaultView.Sort = "maxFlow";
                tempDt.AcceptChanges();
                sbText.Append("\"max_" + deviceId + "\":\"").Append(tempDt.Rows.Count > 0 ? tempDt.Rows[0]["maxFlow"] : "--").Append("\",");
                tempDt.DefaultView.Sort = "minFlow";
                tempDt.AcceptChanges();
                sbText.Append("\"min_" + deviceId + "\":\"").Append(tempDt.Rows.Count > 0 ? tempDt.Rows[0]["minFlow"] : "--").Append("\"");
                if (i < dt.Rows.Count - 1) sbText.Append(",");
            }
            sbText.Append("},");

            sbText.Append("{");
            sbText.Append("\"showtime\":\"").Append("最小值时间").Append("\",");
            //一月中的 最小值时间
            for (int i = 0; i < dt.Rows.Count; i++)
            {
                string deviceId = dt.Rows[i]["MeterAssessmentId"].ToString();
                DataTable tempDt = dtSources[i];
                tempDt.DefaultView.Sort = "avgFlow";
                tempDt.AcceptChanges();
                sbText.Append("\"avg_" + deviceId + "\":\"").Append(tempDt.Rows.Count > 0 ? time.Year + "-" + tempDt.Rows[0]["monthDay"] : "--").Append("\",");
                tempDt.DefaultView.Sort = "maxFlow";
                tempDt.AcceptChanges();
                sbText.Append("\"max_" + deviceId + "\":\"").Append(tempDt.Rows.Count > 0 ? time.Year + "-" + tempDt.Rows[0]["monthDay"] : "--").Append("\",");
                tempDt.DefaultView.Sort = "minFlow";
                tempDt.AcceptChanges();
                sbText.Append("\"min_" + deviceId + "\":\"").Append(tempDt.Rows.Count > 0 ? time.Year + "-" + tempDt.Rows[0]["monthDay"] : "--").Append("\"");

                if (i < dt.Rows.Count - 1) sbText.Append(",");
            }
            sbText.Append("},");

            sbText.Append("{");
            sbText.Append("\"showtime\":\"").Append("最大值").Append("\",");
            //一月中的 最大值
            for (int i = 0; i < dt.Rows.Count; i++)
            {
                string deviceId = dt.Rows[i]["MeterAssessmentId"].ToString();
                DataTable tempDt = dtSources[i];
                tempDt.DefaultView.Sort = "avgFlow desc";
                tempDt.AcceptChanges();
                sbText.Append("\"avg_" + deviceId + "\":\"").Append(tempDt.Rows.Count > 0 ? tempDt.Rows[0]["avgFlow"] : "--").Append("\",");
                maxAvg = tempDt.Rows.Count > 0 ? Convert.ToDouble(tempDt.Rows[0]["avgFlow"].ToString()) : 0;
                tempDt.DefaultView.Sort = "maxFlow desc";
                tempDt.AcceptChanges();
                sbText.Append("\"max_" + deviceId + "\":\"").Append(tempDt.Rows.Count > 0 ? tempDt.Rows[0]["maxFlow"] : "--").Append("\",");
                maxMax = tempDt.Rows.Count > 0 ? Convert.ToDouble(tempDt.Rows[0]["maxFlow"].ToString()) : 0;
                tempDt.DefaultView.Sort = "minFlow desc";
                tempDt.AcceptChanges();
                sbText.Append("\"min_" + deviceId + "\":\"").Append(tempDt.Rows.Count > 0 ? tempDt.Rows[0]["maxFlow"] : "--").Append("\"");
                maxMin = tempDt.Rows.Count > 0 ? Convert.ToDouble(tempDt.Rows[0]["maxFlow"].ToString()) : 0;
                if (i < dt.Rows.Count - 1) sbText.Append(",");
            }
            sbText.Append("},");

            sbText.Append("{");
            sbText.Append("\"showtime\":\"").Append("最大值时间").Append("\",");
            //一月中的 最小值时间
            for (int i = 0; i < dt.Rows.Count; i++)
            {
                string deviceId = dt.Rows[i]["MeterAssessmentId"].ToString();
                DataTable tempDt = dtSources[i];
                tempDt.DefaultView.Sort = "avgFlow desc";
                tempDt.AcceptChanges();
                sbText.Append("\"avg_" + deviceId + "\":\"").Append(tempDt.Rows.Count > 0 ? time.Year + "-" + tempDt.Rows[0]["monthDay"] : "--").Append("\",");
                tempDt.DefaultView.Sort = "maxFlow desc";
                tempDt.AcceptChanges();
                sbText.Append("\"max_" + deviceId + "\":\"").Append(tempDt.Rows.Count > 0 ? time.Year + "-" + tempDt.Rows[0]["monthDay"] : "--").Append("\",");
                tempDt.DefaultView.Sort = "minFlow desc";
                tempDt.AcceptChanges();
                sbText.Append("\"min_" + deviceId + "\":\"").Append(tempDt.Rows.Count > 0 ? time.Year + "-" + tempDt.Rows[0]["monthDay"] : "--").Append("\"");

                if (i < dt.Rows.Count - 1) sbText.Append(",");
            }
            sbText.Append("},");

            sbText.Append("{");
            sbText.Append("\"showtime\":\"").Append("变化系数").Append("\",");
            //一月中的  变化系数  最大值/平均值
            for (int i = 0; i < dt.Rows.Count; i++)
            {
                string deviceId = dt.Rows[i]["MeterAssessmentId"].ToString();

                sbText.Append("\"avg_" + deviceId + "\":\"").Append((maxAvg / avgAvg).ToString("0.00")).Append("\",");
                sbText.Append("\"max_" + deviceId + "\":\"").Append((maxMax / avgMax).ToString("0.00")).Append("\",");
                sbText.Append("\"min_" + deviceId + "\":\"").Append((maxMin / avgMin).ToString("0.00")).Append("\"");
                if (i < dt.Rows.Count - 1) sbText.Append(",");
            }
            sbText.Append("}");
            #endregion

            return sbText;
        }
    }
}