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

using LeaRun.Application.IService.PipeNetworkManage;
using System;
using System.Collections.Generic;
using System.Data;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using LeaRun.Data;
using LeaRun.Util;
using LeaRun.Util.WebControl;

namespace LeaRun.Application.Service.PipeNetworkManage
{
    public class AnalysisService : IAnalysisService
    {
        SqlHelper sqlHelper = new SqlHelper("PipeNetworkDb");
        /// <summary>
        /// 年度用水分析
        /// </summary>
        /// <param name="departId"></param>
        /// <param name="typeID"></param>
        /// <param name="devId"></param>
        /// <param name="time"></param>
        /// <returns></returns>
        public string GetYearAnalysis(string devId, string time, Pagination pagination)
        {
            string strSql = "Select MeterAssessmentId,MeterAssessmentName From MeterAssessmentBase Where  MeterAssessmentId in (" + devId + ")";
            DateTime dateTime = DateTime.Parse(time + "-01-01");
            int months = 12;
            int total = pagination.records;
            //DataTable dt = sqlHelper.ExecuteDataTable(strSql, CommandType.Text, null);
            DataTable dt = sqlHelper.ExecuteDataTable(strSql, "", false, pagination.rows, pagination.page, out total, null);
            pagination.records = total;
            StringBuilder builder = new StringBuilder();
            builder.Append("[");
            for (int i = 0; i < dt.Rows.Count; i++)
            {
                string deviceId = dt.Rows[i]["MeterAssessmentId"].ToString();
                string name = dt.Rows[i]["MeterAssessmentName"].ToString();
                builder.Append("{");
                builder.Append("\"ID\":\"").Append(deviceId).Append("\",");
                builder.Append("\"DevName\":\"").Append(name).Append("\",");
                string strTableName = "MeterAssessment_" + deviceId;
                if (sqlHelper.DBTableIsExists(strTableName))
                {

                    DateTime startDay = dateTime;
                    for (int j = 0; j < months; j++)
                    {
                        DateTime nowDay = startDay.AddMonths(j);
                        DateTime endDay = nowDay.AddMonths(1);
                        strSql = "Select GetDateTime,NetCumulativeFlow From " + strTableName + " Where NetCumulativeFlow<>0 And NetCumulativeFlow is not null And GetDateTime between '" + nowDay.ToString("yyyy-MM-dd") + "' And '" + endDay.ToString("yyyy-MM-dd") + "'";
                        DataTable table = sqlHelper.ExecuteDataTable(strSql, CommandType.Text, null);
                        if (table.Rows.Count > 0)
                        {
                            decimal min = decimal.Parse(table.Rows[0]["NetCumulativeFlow"].ToString());
                            decimal max = decimal.Parse(table.Rows[table.Rows.Count - 1]["NetCumulativeFlow"].ToString());
                            builder.Append("\"Month" + (j + 1) + "\":\"").Append((max - min).ToString()).Append("\"");
                        }
                        else
                        {
                            builder.Append("\"Month" + (j + 1) + "\":\"").Append("--\"");
                        }
                        if (j < months - 1)
                            builder.Append(",");
                    }
                }
                else
                {
                    string strDay = time + "-01";
                    for (int j = 0; j < months; j++)
                    {
                        builder.Append("\"Month" + (j + 1) + "\":\"").Append("--\"");
                        if (j < months - 1)
                            builder.Append(",");
                    }
                }
                builder.Append("}");
                if (i < dt.Rows.Count - 1)
                    builder.Append(",");
            }
            builder.Append("]");
            return builder.ToString();
        }

        /// <summary>
        /// 月度用水分析
        /// </summary>
        /// <param name="departId"></param>
        /// <param name="typeID"></param>
        /// <param name="devId"></param>
        /// <param name="time"></param>
        /// <returns></returns>
        public string GetMonthAnalysis(string devId, string time, Pagination pagination)
        {
            string strSql = "";

            strSql = "Select MeterAssessmentId,MeterAssessmentName From MeterAssessmentBase Where  MeterAssessmentId  in (" + devId + ")";

            DateTime dateTime = DateTime.Parse(time);
            int days = LeaRun.Util.Time.GetDaysOfMonth(dateTime.Year, dateTime.Month);
            int total = pagination.records;
            DataTable dt = sqlHelper.ExecuteDataTable(strSql, "", false, pagination.rows, pagination.page, out total, null);
            pagination.records = total;
            StringBuilder builder = new StringBuilder();
            builder.Append("[");
            for (int i = 0; i < dt.Rows.Count; i++)
            {
                string deviceId = dt.Rows[i]["MeterAssessmentId"].ToString();
                string name = dt.Rows[i]["MeterAssessmentName"].ToString();
                builder.Append("{");
                builder.Append("\"ID\":\"").Append(deviceId).Append("\",");
                builder.Append("\"DevName\":\"").Append(name).Append("\",");
                string strTableName = "MeterAssessment_" + deviceId;
                if (sqlHelper.DBTableIsExists(strTableName))
                {
                    string strDay = time + "-01";
                    DateTime startDay = DateTime.Parse(strDay);
                    for (int j = 0; j < days; j++)
                    {
                        DateTime nowDay = startDay.AddDays(j);
                        DateTime endDay = nowDay.AddDays(1);
                        strSql = "Select GetDateTime, NetCumulativeFlow From " + strTableName + " Where NetCumulativeFlow<>0 And NetCumulativeFlow is not null And GetDateTime between '" + nowDay.ToString("yyyy-MM-dd") + "' And '" + endDay.ToString("yyyy-MM-dd") + "'";
                        DataTable table = sqlHelper.ExecuteDataTable(strSql, CommandType.Text, null);
                        if (table.Rows.Count > 0)
                        {
                            decimal min = decimal.Parse(table.Rows[0]["NetCumulativeFlow"].ToString());
                            decimal max = decimal.Parse(table.Rows[table.Rows.Count - 1]["NetCumulativeFlow"].ToString());
                            builder.Append("\"Day" + (j + 1) + "\":\"").Append((max - min).ToString("0.00")).Append("\"");
                        }
                        else
                        {
                            builder.Append("\"Day" + (j + 1) + "\":\"").Append("--\"");
                        }
                        if (j < days - 1)
                            builder.Append(",");
                    }
                }
                else
                {
                    string strDay = time + "-01";
                    for (int j = 0; j < days; j++)
                    {
                        builder.Append("\"Day" + (j + 1) + "\":\"").Append("--\"");
                        if (j < days - 1)
                            builder.Append(",");
                    }
                }
                builder.Append("}");
                if (i < dt.Rows.Count - 1)
                    builder.Append(",");
            }
            builder.Append("]");
            return builder.ToString();
        }



        /// <summary>
        /// 每小时用水量
        /// </summary>
        /// <param name="deviceId">测点ID</param>
        /// <param name="time">时间</param>
        /// <returns></returns>
        public string GetHourFlow(string deviceId, string time)
        {
            var json = "[]";
            var strSql = "Select MeterAssessmentId,MeterAssessmentName From  MeterAssessmentBase Where MeterAssessmentId=" + deviceId;
            DataTable dt = sqlHelper.ExecuteDataTable(strSql, CommandType.Text, null);
            if (dt.Rows.Count > 0)
            {
                string devName = dt.Rows[0]["MeterAssessmentName"].ToString();
                DateTime dateTime = DateTime.Parse(time);
                StringBuilder builder = new StringBuilder();
                builder.Append("[");
                string strTableName = "MeterAssessment_" + deviceId;
                if (sqlHelper.DBTableIsExists(strTableName))
                {
                    for (int i = 0; i < 24; i++)
                    {
                        DateTime nowDay = dateTime.AddHours(i);
                        DateTime endDay = nowDay.AddHours(1);
                        strSql = "Select NetCumulativeFlow From " + strTableName + " Where NetCumulativeFlow<>0 And NetCumulativeFlow is not null And GetDateTime between '" + nowDay.ToString("yyyy-MM-dd HH:mm:ss") + "' And '" + endDay.ToString("yyyy-MM-dd HH:mm:ss") + "' Order by GetDateTime";

                        DataTable table = sqlHelper.ExecuteDataTable(strSql, CommandType.Text, null);
                        builder.Append("{");
                        if (table.Rows.Count > 0)
                        {
                            decimal min = decimal.Parse(table.Rows[0]["NetCumulativeFlow"].ToString());
                            decimal max = decimal.Parse(table.Rows[table.Rows.Count - 1]["NetCumulativeFlow"].ToString());
                            builder.Append("\"DevName\":\"").Append(devName).Append("\",");
                            builder.Append("\"HourNetFlow\":\"").Append((max - min).ToString()).Append("\",");
                            builder.Append("\"LedgerTime\":\"").Append(i + 1).Append("\"");
                        }
                        else
                        {
                            builder.Append("\"HourNetFlow\":\"0\",");
                            builder.Append("\"LedgerTime\":\"").Append(i + 1).Append("\"");
                        }
                        builder.Append("}");
                        if (i < 23)
                            builder.Append(",");
                    }
                }
                builder.Append("]");
                json = builder.ToString();
            }
            return json;
        }

        ///// <summary>
        ///// 前三天平均用水量
        ///// </summary>
        ///// <param name="devId"></param>
        ///// <param name="time"></param>
        ///// <returns></returns>
        public string GetHourAvgFlow(string deviceId, string time)
        {
            var json = "[]";
            var strSql = "Select MeterAssessmentId,MeterAssessmentName From  MeterAssessmentBase Where MeterAssessmentId=" + deviceId;
            DataTable dt = sqlHelper.ExecuteDataTable(strSql, CommandType.Text, null);
            if (dt.Rows.Count > 0)
            {
                DateTime dateTime = DateTime.Parse(time);
                StringBuilder builder = new StringBuilder();
                builder.Append("[");
                string strTableName = "MeterAssessment_" + deviceId;
                if (sqlHelper.DBTableIsExists(strTableName))
                {
                    DateTime yesterDay = dateTime.AddDays(-1);//昨天
                    DateTime twoDaysBefore = dateTime.AddDays(-2);//两天前
                    DateTime threeDaysBefore = dateTime.AddDays(-3);//三天前
                    decimal yesterDayUsed = 0, twoDaysBeforeUsed = 0, threeDaysBeforeUsed = 0;
                    for (int i = 0; i < 24; i++)
                    {

                        DateTime yesterDayHour = yesterDay.AddHours(i);
                        DateTime yesterDayEndHour = yesterDayHour.AddHours(1);


                        DateTime twoDaysBeforeHour = twoDaysBefore.AddHours(i);
                        DateTime twoDaysBeforeEndHour = twoDaysBeforeHour.AddHours(1);

                        DateTime threeDaysBeforeHour = threeDaysBefore.AddHours(i);
                        DateTime threeDaysBeforeEndHour = threeDaysBeforeHour.AddHours(1);
                        #region 昨天小时流量
                        strSql = "Select NetCumulativeFlow From " + strTableName + " Where NetCumulativeFlow<>0 And NetCumulativeFlow is not null And GetDateTime between '" + yesterDayHour.ToString("yyyy-MM-dd HH:mm:ss") + "' And '" + yesterDayEndHour.ToString("yyyy-MM-dd HH:mm:ss") + "' Order by GetDateTime";
                        DataTable tableYes = sqlHelper.ExecuteDataTable(strSql, CommandType.Text, null);
                        if (tableYes.Rows.Count > 0)
                        {
                            decimal min = decimal.Parse(tableYes.Rows[0]["NetCumulativeFlow"].ToString());
                            decimal max = decimal.Parse(tableYes.Rows[tableYes.Rows.Count - 1]["NetCumulativeFlow"].ToString());
                            yesterDayUsed = max - min;
                        }
                        else
                        {
                            yesterDayUsed = 0;
                        }
                        #endregion

                        #region 两天前小时流量
                        strSql = "Select NetCumulativeFlow From " + strTableName + " Where NetCumulativeFlow<>0 And NetCumulativeFlow is not null And GetDateTime between '" + twoDaysBeforeHour.ToString("yyyy-MM-dd HH:mm:ss") + "' And '" + twoDaysBeforeEndHour.ToString("yyyy-MM-dd HH:mm:ss") + "' Order by GetDateTime";
                        tableYes = sqlHelper.ExecuteDataTable(strSql, CommandType.Text, null);
                        if (tableYes.Rows.Count > 0)
                        {
                            decimal min = decimal.Parse(tableYes.Rows[0]["NetCumulativeFlow"].ToString());
                            decimal max = decimal.Parse(tableYes.Rows[tableYes.Rows.Count - 1]["NetCumulativeFlow"].ToString());
                            twoDaysBeforeUsed = max - min;
                        }
                        else
                        {
                            twoDaysBeforeUsed = 0;
                        }
                        #endregion

                        #region 三天前小时流量
                        strSql = "Select NetCumulativeFlow From " + strTableName + " Where NetCumulativeFlow<>0 And NetCumulativeFlow is not null And GetDateTime between '" + threeDaysBeforeHour.ToString("yyyy-MM-dd HH:mm:ss") + "' And '" + threeDaysBeforeEndHour.ToString("yyyy-MM-dd HH:mm:ss") + "' Order by GetDateTime";
                        tableYes = sqlHelper.ExecuteDataTable(strSql, CommandType.Text, null);
                        if (tableYes.Rows.Count > 0)
                        {
                            decimal min = decimal.Parse(tableYes.Rows[0]["NetCumulativeFlow"].ToString());
                            decimal max = decimal.Parse(tableYes.Rows[tableYes.Rows.Count - 1]["NetCumulativeFlow"].ToString());
                            threeDaysBeforeUsed = max - min;
                        }
                        else
                        {
                            threeDaysBeforeUsed = 0;
                        }
                        #endregion

                        decimal avgFlow = (yesterDayUsed + twoDaysBeforeUsed + threeDaysBeforeUsed) / 3;
                        builder.Append(avgFlow);
                        if (i < 23)
                            builder.Append(",");
                    }
                }
                builder.Append("]");
                json = builder.ToString();
            }
            return json;
        }

        /// <summary>
        /// 每日用水量
        /// </summary>
        /// <param name="deviceId"></param>
        /// <param name="time"></param>
        /// <returns></returns>
        public string GetDayFlow(string deviceId, string time)
        {
            var json = "[]";
            var strSql = "Select MeterAssessmentId,MeterAssessmentName From  MeterAssessmentBase Where MeterAssessmentId=" + deviceId;
            DataTable dt = sqlHelper.ExecuteDataTable(strSql, CommandType.Text, null);
            if (dt.Rows.Count > 0)
            {
                string devName = dt.Rows[0]["MeterAssessmentName"].ToString();
                DateTime dateTime = DateTime.Parse(time + "-01");
                int days = Time.GetDaysOfMonth(dateTime);

                StringBuilder builder = new StringBuilder();
                builder.Append("[");
                string strTableName = "MeterAssessment_" + deviceId;
                if (sqlHelper.DBTableIsExists(strTableName))
                {
                    for (int i = 0; i < days; i++)
                    {
                        DateTime nowDay = dateTime.AddDays(i);
                        DateTime endDay = nowDay.AddDays(1);
                        strSql = "Select NetCumulativeFlow From " + strTableName + " Where NetCumulativeFlow<>0 And NetCumulativeFlow is not null And GetDateTime between '" + nowDay.ToString("yyyy-MM-dd HH:mm:ss") + "' And '" + endDay.ToString("yyyy-MM-dd HH:mm:ss") + "' Order by GetDateTime";

                        DataTable table = sqlHelper.ExecuteDataTable(strSql, CommandType.Text, null);
                        builder.Append("{");
                        builder.Append("\"DevName\":\"").Append(devName).Append("\",");
                        if (table.Rows.Count > 0)
                        {
                            decimal min = decimal.Parse(table.Rows[0]["NetCumulativeFlow"].ToString());
                            decimal max = decimal.Parse(table.Rows[table.Rows.Count - 1]["NetCumulativeFlow"].ToString());
                            builder.Append("\"HourNetFlow\":\"").Append((max - min).ToString()).Append("\",");
                            builder.Append("\"LedgerTime\":\"").Append(i + 1).Append("\",");
                        }
                        else
                        {
                            builder.Append("\"HourNetFlow\":\"0\",");
                            builder.Append("\"LedgerTime\":\"").Append(i + 1).Append("\",");
                        }
                        strSql = "Select min(Pressure) as 最小压力,max(Pressure) as 最大压力,avg(Pressure) as 平均压力 From " + strTableName + " Where Pressure is not null And GetDateTime between '" + nowDay.ToString("yyyy-MM-dd HH:mm:ss") + "' And '" + endDay.ToString("yyyy-MM-dd HH:mm:ss") + "'";
                        DataTable dtP = sqlHelper.ExecuteDataTable(strSql, CommandType.Text, null);
                        if (dtP.Rows.Count > 0)
                        {
                            builder.Append("\"minP\":\"").Append(dtP.Rows[0]["最小压力"].ToString()).Append("\",");
                            builder.Append("\"maxP\":\"").Append(dtP.Rows[0]["最大压力"].ToString()).Append("\",");
                            builder.Append("\"avgP\":\"").Append(dtP.Rows[0]["平均压力"].ToString()).Append("\"");
                        }
                        else
                        {
                            builder.Append("\"minP\":\"0\",");
                            builder.Append("\"maxP\":\"0\",");
                            builder.Append("\"avgP\":\"0\"");
                        }
                        builder.Append("}");
                        if (i < days - 1)
                            builder.Append(",");
                    }
                }
                builder.Append("]");
                json = builder.ToString();
            }
            return json;
        }


        /// <summary>
        /// 每月用水量
        /// </summary>
        /// <param name="deviceId"></param>
        /// <param name="time"></param>
        /// <returns></returns>
        public string GetMonthFlow(string deviceId, string time)
        {
            var json = "[]";
            var strSql = "Select MeterAssessmentId,MeterAssessmentName From  MeterAssessmentBase Where MeterAssessmentId=" + deviceId;
            DataTable dt = sqlHelper.ExecuteDataTable(strSql, CommandType.Text, null);
            if (dt.Rows.Count > 0)
            {
                string devName = dt.Rows[0]["MeterAssessmentName"].ToString();
                DateTime dateTime = DateTime.Parse(time + "-01-01");
                StringBuilder builder = new StringBuilder();
                builder.Append("[");
                string strTableName = "MeterAssessment_" + deviceId;
                if (sqlHelper.DBTableIsExists(strTableName))
                {
                    for (int i = 0; i < 12; i++)
                    {
                        DateTime nowDay = dateTime.AddMonths(i);
                        DateTime endDay = nowDay.AddMonths(1);
                        strSql = "Select NetCumulativeFlow From " + strTableName + " Where NetCumulativeFlow<>0 And NetCumulativeFlow is not null And GetDateTime between '" + nowDay.ToString("yyyy-MM-dd HH:mm:ss") + "' And '" + endDay.ToString("yyyy-MM-dd HH:mm:ss") + "' Order by GetDateTime";

                        DataTable table = sqlHelper.ExecuteDataTable(strSql, CommandType.Text, null);
                        builder.Append("{");
                        if (table.Rows.Count > 0)
                        {
                            decimal min = decimal.Parse(table.Rows[0]["NetCumulativeFlow"].ToString());
                            decimal max = decimal.Parse(table.Rows[table.Rows.Count - 1]["NetCumulativeFlow"].ToString());
                            builder.Append("\"DevName\":\"").Append(devName).Append("\",");
                            builder.Append("\"HourNetFlow\":\"").Append((max - min).ToString()).Append("\",");
                            builder.Append("\"LedgerTime\":\"").Append(i + 1).Append("\"");
                        }
                        else
                        {
                            builder.Append("\"HourNetFlow\":\"0\",");
                            builder.Append("\"LedgerTime\":\"").Append(i + 1).Append("\"");
                        }
                        builder.Append("}");
                        if (i < 11)
                            builder.Append(",");
                    }
                }
                builder.Append("]");
                json = builder.ToString();
            }

            return json;
        }



        /// <summary>
        /// 瞬时流量
        /// </summary>
        /// <param name="deviceId"></param>
        /// <param name="start"></param>
        /// <param name="end"></param>        
        /// <returns></returns>
        public string GetFlowRate(string deviceId, string start, string end)
        {
            var json = "[]";
            var sql = "Select MeterAssessmentName From MeterAssessmentBase Where MeterAssessmentId=" + deviceId;
            DataTable dtDev = sqlHelper.ExecuteDataTable(sql, CommandType.Text, null);
            string devName = "";
            if (dtDev.Rows.Count > 0)
            {
                devName = dtDev.Rows[0]["MeterAssessmentName"].ToString();
            }
            DateTime dateTime = DateTime.Parse(start);
            string strTableName = "MeterAssessment_" + deviceId;
            if (sqlHelper.DBTableIsExists(strTableName))
            {
                var strSql = "Select InstantaneousFlow,Pressure,GetDateTime From " + strTableName + " Where  InstantaneousFlow is not null And GetDateTime between '" + start + "' and '" + end + "' Order by GetDateTime";
                DataTable dt = sqlHelper.ExecuteDataTable(strSql, CommandType.Text, null);
                StringBuilder builder = new StringBuilder();
                builder.Append("[");
                for (int i = 0; i < dt.Rows.Count; i++)
                {
                    builder.Append("{");
                    builder.Append("\"FlowRate\":\"").Append(dt.Rows[i]["InstantaneousFlow"].ToString()).Append("\",");
                    builder.Append("\"Pressure\":\"").Append(string.IsNullOrEmpty(dt.Rows[i]["Pressure"].ToString()) == true ? "-" : dt.Rows[i]["Pressure"].ToString()).Append("\",");
                    DateTime dtN = DateTime.Parse(dt.Rows[i]["GetDateTime"].ToString());

                    builder.Append("\"FlowTime\":\"").Append(dtN.ToString("yyyy-MM-dd HH:mm:ss")).Append("\"");
                    builder.Append("}");
                    if (i < dt.Rows.Count - 1)
                        builder.Append(",");
                }
                builder.Append("]");
                json = builder.ToString();
                json = "{\"devName\":\"" + devName + "\",\"devData\":" + json + ",";
                strSql = "Select avg(InstantaneousFlow) as 平均流量,MIN(InstantaneousFlow) as 最小流量 From " + strTableName + " Where InstantaneousFlow is not null And GetDateTime between '" + start + "' and '" + end + "'";
                DataTable dtAvg = sqlHelper.ExecuteDataTable(strSql, CommandType.Text, null);
                if (dtAvg.Rows.Count > 0)
                {
                    //decimal avgFlow=decimal
                    string strAvg = dtAvg.Rows[0]["平均流量"].ToString();
                    #region
                    if (!string.IsNullOrEmpty(strAvg))
                    {
                        decimal avgFlow = decimal.Parse(dtAvg.Rows[0]["平均流量"].ToString());
                        decimal minFlow = decimal.Parse(dtAvg.Rows[0]["最小流量"].ToString());
                        DateTime dtStart = DateTime.Parse(start);
                        DateTime dtEnd = DateTime.Parse(end);
                        List<decimal> totalMinFlow = new List<decimal>();
                        int days = (dtEnd - dtStart).Days;
                        for (int i = 0; i < days; i++)
                        {
                            DateTime dtTomorrow = dtStart.AddDays(1);
                            strSql = "Select avg(InstantaneousFlow) as 平均流量,MIN(InstantaneousFlow) as 最小流量 From " + strTableName + " Where InstantaneousFlow is not null And GetDateTime between '" + dtStart.ToString("yyyy-MM-dd 00:00") + "' and '" + dtTomorrow.ToString("yyyy-MM-dd 00:00") + "'";
                            dtStart = dtStart.AddDays(1);
                            DataTable dtMin = sqlHelper.ExecuteDataTable(strSql, CommandType.Text, null);
                            if (dtMin.Rows.Count > 0)
                            {
                                if (!string.IsNullOrEmpty(dtMin.Rows[0]["最小流量"].ToString()))
                                {
                                    totalMinFlow.Add(decimal.Parse(dtMin.Rows[0]["最小流量"].ToString()));
                                }
                            }
                        }
                        if (totalMinFlow.Count > 0)
                        {
                            decimal totalM = 0;
                            foreach (var item in totalMinFlow)
                            {
                                totalM += item;
                            }
                            minFlow = Math.Round(totalM / totalMinFlow.Count, 3);

                        }
                        //疑似漏水量,疑似漏失率,夜间允许漏水量,期间供水量,期间售水量
                        decimal suspectedLeakFlow, suspectedLeakRate, nightAllowLeakFlow, waterSupply, salesWater;
                        suspectedLeakFlow = minFlow - avgFlow / 5;
                        if (avgFlow != 0)
                        {
                            suspectedLeakRate = suspectedLeakFlow / avgFlow * 100;
                        }
                        else
                        {
                            suspectedLeakRate = 0;
                        }
                        nightAllowLeakFlow = minFlow - suspectedLeakFlow;
                        waterSupply = avgFlow * 24;
                        salesWater = waterSupply - suspectedLeakFlow * 24;
                        json += "\"avgFlow\":" + dtAvg.Rows[0]["平均流量"].ToString() + ",\"minFlow\":" + dtAvg.Rows[0]["最小流量"].ToString() + ",";
                        json += "\"suspectedLeakFlow\":" + Math.Round(suspectedLeakFlow, 3) + ",";
                        json += "\"suspectedLeakRate\":" + Math.Round(suspectedLeakRate, 3) + ",";
                        json += "\"nightAllowLeakFlow\":" + Math.Round(nightAllowLeakFlow, 3) + ",";
                        json += "\"waterSupply\":" + Math.Round(waterSupply, 3) + ",";
                        json += "\"salesWater\":" + Math.Round(salesWater, 3) + "}";
                    }
                    else
                    {
                        json += "\"avgFlow\":\"--\",\"minFlow\":\"--\",";
                        json += "\"suspectedLeakFlow\":\"--\",";
                        json += "\"suspectedLeakRate\":\"--\",";
                        json += "\"nightAllowLeakFlow\":\"--\",";
                        json += "\"waterSupply\":\"--\",";
                        json += "\"salesWater\":\"--\"}";
                    }
                    #endregion
                }
                else
                {
                    json += "\"avgFlow\":\"--\",\"minFlow\":\"--\",";
                    json += "\"suspectedLeakFlow\":\"--\",";
                    json += "\"suspectedLeakRate\":\"--\",";
                    json += "\"nightAllowLeakFlow\":\"--\",";
                    json += "\"waterSupply\":\"--\",";
                    json += "\"salesWater\":\"--\"}";
                }

            }
            return json;
        }

        /// <summary>
        /// 最小流量分析
        /// </summary>
        /// <param name="deviceId"></param>
        /// <param name="start"></param>
        /// <param name="end"></param>
        /// <returns></returns>
        public string GetMinFlow(string deviceId, string start, string end)
        {
            var json = "{\"devName\":\"\",\"devData\":[]";

            var sql = "Select MeterAssessmentName From MeterAssessmentBase Where MeterAssessmentId=" + deviceId;
            DataTable dtDev = sqlHelper.ExecuteDataTable(sql, CommandType.Text, null);
            string devName = "";
            if (dtDev.Rows.Count > 0)
            {
                devName = dtDev.Rows[0]["MeterAssessmentName"].ToString();
            }
            DateTime dateTime = DateTime.Parse(start);
            string strTableName = "MeterAssessment_" + deviceId;


            DateTime dtStart = DateTime.Parse(start);
            DateTime dtEnd = DateTime.Parse(end);
            int days = (dtEnd - dtStart).Days;
            string strSql = "";
            StringBuilder builder = new StringBuilder();
            builder.Append("{\"devName\":\"").Append(devName);
            builder.Append("\",\"devData\":");
            builder.Append("[");
            for (int i = 0; i < days; i++)
            {

                DateTime dtTomorrow = dtStart.AddDays(1);
                strSql = "Select avg(InstantaneousFlow) as 平均流量,MIN(InstantaneousFlow) as 最小流量 From " + strTableName + " Where InstantaneousFlow is not null And GetDateTime between '" + dtStart.ToString("yyyy-MM-dd 00:00") + "' and '" + dtTomorrow.ToString("yyyy-MM-dd 00:00") + "'";

                DataTable dtMin = sqlHelper.ExecuteDataTable(strSql, CommandType.Text, null);
                if (dtMin.Rows.Count > 0)
                {
                    builder.Append("{");
                    builder.Append("\"FlowRate\":\"").Append(dtMin.Rows[0]["最小流量"].ToString()).Append("\",");
                    //计算前三天的平均瞬时流量
                    if (i >= 3)
                    {
                        strSql = "Select Avg(InstantaneousFlow) as 平均流量  From " + strTableName + " Where InstantaneousFlow is not null And GetDateTime between '" + dtStart.AddDays(-3).ToString("yyyy-MM-dd 00:00") + "' and '" + dtStart.ToString("yyyy-MM-dd 00:00") + "'";
                        DataTable dtAvg = sqlHelper.ExecuteDataTable(strSql, CommandType.Text, null);
                        if (dtAvg.Rows.Count > 0)
                        {
                            builder.Append("\"AvgFlow\":\"").Append(dtAvg.Rows[0]["平均流量"].ToString()).Append("\",");
                        }
                        else
                        {
                            builder.Append("\"AvgFlow\":\"-\",");
                        }
                    }
                    else
                    {
                        builder.Append("\"AvgFlow\":\"").Append(dtMin.Rows[0]["平均流量"].ToString()).Append("\",");
                    }
                    builder.Append("\"FlowTime\":\"").Append(dtStart.ToString("yyyy-MM-dd")).Append("\"");
                    builder.Append("}");
                }
                else
                {
                    builder.Append("{");
                    builder.Append("\"FlowRate\":\"-\",");
                    builder.Append("\"AvgFlow\":\"-\",");
                    builder.Append("\"FlowTime\":\"").Append(dtStart.ToString("yyyy-MM-dd")).Append("\"");
                    builder.Append("}");
                }
                if (i < days - 1)
                    builder.Append(",");
                dtStart = dtStart.AddDays(1);
            }

            builder.Append("]}");
            json = builder.ToString();
            // + json + "}";


            return json;
        }
    }


}