using Casic.Birmm.RbFreqStandMeasure.R_DataBase.Model;
using Casic.Birmm.RbFreqStandMeasure.Tools;
using MySql.Data.MySqlClient;
using System;
using System.Collections.Generic;
using System.Data;
using System.Reflection;

namespace Casic.Birmm.RbFreqStandMeasure.R_DataBase.Service.Impl
{

    class DetectionItemServiceImpl : DetectionItemService
    {
        public int add(long deviceId, DateTime startTime, DateTime endTime, string stability, string accuracy, string bootFeature, string ageRate, String interval, string channelNo)
        {
            int iRetval = -1;
            try
            {
                if (DbConnectService.mySqlConnect.State == ConnectionState.Closed)
                {
                    LogHelper.WriteErrorLog(MethodBase.GetCurrentMethod().DeclaringType, "addDetectionItem : 数据库链接断开");
                    return iRetval;
                }

                string sQry = "INSERT INTO r_detection_item (DEVICE_ID,START_TIME,END_TIME,STABILITY,ACCURACY,BOOT_FEATURE,AGE_RATE,STABILITY_INTERVAL)" +
                    " VALUES (@DEVICE_ID,@START_TIME,@END_TIME,@STABILITY,@ACCURACY,@BOOT_FEATURE,@AGE_RATE,@INTERVAL)";

                MySqlCommand cmd = new MySqlCommand(sQry, DbConnectService.mySqlConnect);
                cmd.Parameters.Add("@DEVICE_ID", MySqlDbType.Int64, 20).Value = deviceId;
                cmd.Parameters.Add("@START_TIME", MySqlDbType.DateTime, 0).Value = startTime;
                cmd.Parameters.Add("@END_TIME", MySqlDbType.DateTime, 0).Value = endTime;
                cmd.Parameters.Add("@STABILITY", MySqlDbType.String, 50).Value = stability;
                cmd.Parameters.Add("@ACCURACY", MySqlDbType.String, 50).Value = accuracy;
                cmd.Parameters.Add("@BOOT_FEATURE", MySqlDbType.String, 50).Value = bootFeature;
                cmd.Parameters.Add("@AGE_RATE", MySqlDbType.String, 50).Value = ageRate;
                cmd.Parameters.Add("@INTERVAL", MySqlDbType.String, 30).Value = interval;

                cmd.ExecuteNonQuery();

                sQry = "UPDATE r_device SET STATUSID=@STATUSID, CHANNEL=@CHANNEL where ID=@ID";
                cmd = new MySqlCommand(sQry, DbConnectService.mySqlConnect);
                cmd.Parameters.Add("@ID", MySqlDbType.Int64, 20).Value = deviceId;
                cmd.Parameters.Add("@STATUSID", MySqlDbType.String, 20).Value = "2";
                cmd.Parameters.Add("@CHANNEL", MySqlDbType.String, 20).Value = channelNo;

                cmd.ExecuteNonQuery();
                cmd.Dispose();
                iRetval = 0;
            }
            catch (MySqlException e)
            {
                LogHelper.WriteErrorLog(MethodBase.GetCurrentMethod().DeclaringType, "addDetectionItem: " + e.Message);
                iRetval = -1;
            }
            return iRetval;
        }

        public int update(long deviceId, DateTime startTime, DateTime endTime, string stability, string accuracy, string bootFeature, string ageRate, String interval, string counterDetec)
        {
            int iRetval = -1;
            try
            {
                if (DbConnectService.mySqlConnect.State == ConnectionState.Closed)
                {
                    LogHelper.WriteErrorLog(MethodBase.GetCurrentMethod().DeclaringType, "updateDetectionItem : 数据库链接断开");
                    return iRetval;
                }

                string sQry = "UPDATE r_detection_item  SET START_TIME=@START_TIME,END_TIME=@END_TIME,STABILITY=@STABILITY,ACCURACY=@ACCURACY,BOOT_FEATURE=@BOOT_FEATURE,AGE_RATE=@AGE_RATE,STABILITY_INTERVAL=@INTERVAL,COUNTER_DETEC=@COUNTER_DETEC WHERE DEVICE_ID = " + deviceId;

                MySqlCommand cmd = new MySqlCommand(sQry, DbConnectService.mySqlConnect);
                cmd.Parameters.Add("@START_TIME", MySqlDbType.DateTime, 0).Value = startTime;
                cmd.Parameters.Add("@END_TIME", MySqlDbType.DateTime, 0).Value = endTime;
                cmd.Parameters.Add("@STABILITY", MySqlDbType.String, 10).Value = stability;
                cmd.Parameters.Add("@ACCURACY", MySqlDbType.String, 10).Value = accuracy;
                cmd.Parameters.Add("@BOOT_FEATURE", MySqlDbType.String, 10).Value = bootFeature;
                cmd.Parameters.Add("@AGE_RATE", MySqlDbType.String, 10).Value = ageRate;
                cmd.Parameters.Add("@INTERVAL", MySqlDbType.String, 30).Value = interval;
                cmd.Parameters.Add("@COUNTER_DETEC", MySqlDbType.String, 30).Value = counterDetec;

                cmd.ExecuteNonQuery();

                cmd.Dispose();
                iRetval = 0;
            }
            catch (MySqlException e)
            {
                LogHelper.WriteErrorLog(MethodBase.GetCurrentMethod().DeclaringType, "updateDetectionItem: " + e.Message);
                iRetval = -1;
            }
            return iRetval;
        }

        public int updateDetecStatus(long deviceId, string stability, string accuracy, string bootFeature, string ageRate, string counterDetec)
        {
            int iRetval = -1;
            try
            {
                if (DbConnectService.mySqlConnect.State == ConnectionState.Closed)
                {
                    LogHelper.WriteErrorLog(MethodBase.GetCurrentMethod().DeclaringType, "updateDetectionItem : 数据库链接断开");
                    return iRetval;
                }

                if (stability.Equals("") && accuracy.Equals("") && bootFeature.Equals("") && ageRate.Equals("")) return -1;

                string sQry = "UPDATE r_detection_item SET";
                if(!stability.Equals(""))
                    sQry = sQry + " STABILITY=@STABILITY";
                if (!accuracy.Equals(""))
                    sQry = sQry + " ACCURACY=@ACCURACY";
                if (!bootFeature.Equals(""))
                    sQry = sQry + " BOOT_FEATURE=@BOOT_FEATURE";
                if (!ageRate.Equals(""))
                    sQry = sQry + " AGE_RATE=@AGE_RATE";
                if (!counterDetec.Equals(""))
                    sQry = sQry + " COUNTER_DETEC=@COUNTER_DETEC";

                sQry = sQry + " where DEVICE_ID = " + deviceId;


                MySqlCommand cmd = new MySqlCommand(sQry, DbConnectService.mySqlConnect);
                cmd.Parameters.Add("@STABILITY", MySqlDbType.String, 10).Value = stability;
                cmd.Parameters.Add("@ACCURACY", MySqlDbType.String, 10).Value = accuracy;
                cmd.Parameters.Add("@BOOT_FEATURE", MySqlDbType.String, 10).Value = bootFeature;
                cmd.Parameters.Add("@AGE_RATE", MySqlDbType.String, 10).Value = ageRate;
                cmd.Parameters.Add("@COUNTER_DETEC", MySqlDbType.String, 10).Value = counterDetec;

                cmd.ExecuteNonQuery();

                cmd.Dispose();
                iRetval = 0;
            }
            catch (MySqlException e)
            {
                LogHelper.WriteErrorLog(MethodBase.GetCurrentMethod().DeclaringType, "updateDetectionItem: " + e.Message);
                iRetval = -1;
            }
            return iRetval;
        }


        public int stopDetection(long deviceId, DateTime startTime, DateTime endTime, bool isDeleteData)
        {
            int iRetval = -1;
            try
            {
                if (DbConnectService.mySqlConnect.State == ConnectionState.Closed)
                {
                    LogHelper.WriteErrorLog(MethodBase.GetCurrentMethod().DeclaringType, "updateDetectionItem : 数据库链接断开");
                    return iRetval;
                }
                
                string sQry = "UPDATE r_device SET STATUSID="+"1"+", CHANNEL=@CHANNEL where ID=" + deviceId;
                MySqlCommand cmd = new MySqlCommand(sQry, DbConnectService.mySqlConnect);
                cmd.Parameters.Add("@CHANNEL", MySqlDbType.String, 20).Value = "";
                cmd.ExecuteNonQuery();

                if (isDeleteData)
                {
                    sQry = "DELETE FROM r_detection_item WHERE DEVICE_ID = " + deviceId + "AND START_TIME=" + startTime + " AND END_TIME=" + endTime;
                    cmd = new MySqlCommand(sQry, DbConnectService.mySqlConnect);
                    cmd.ExecuteNonQuery();

                    sQry = "DELETE FROM r_detection WHERE DEVICE_ID = " + deviceId + "AND LOG_TIME>=" + startTime;
                    cmd = new MySqlCommand(sQry, DbConnectService.mySqlConnect);
                    cmd.ExecuteNonQuery();
                }

                cmd.Dispose();
                iRetval = 0;
            }
            catch (MySqlException e)
            {
                LogHelper.WriteErrorLog(MethodBase.GetCurrentMethod().DeclaringType, "updateDetectionItem: " + e.Message);
                iRetval = -1;
            }
            return iRetval;
        }

        public List<DetectionItem> search(long deviceId, bool isInDetection)
        {
            List<DetectionItem> detectionItemList = new List<DetectionItem>();
            try
            {
                if (DbConnectService.mySqlConnect.State == ConnectionState.Closed)
                {
                    LogHelper.WriteErrorLog(MethodBase.GetCurrentMethod().DeclaringType, "searchDetectionItem : 数据库链接断开");
                    return null;
                }

                string sQry = "SELECT * FROM r_detection_item where DEVICE_ID = " + deviceId;
                if (isInDetection)
                {
                    sQry = sQry + " and ('" + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss") + "' between START_TIME AND END_TIME)";
                }
                MySqlCommand aCommand = new MySqlCommand(sQry, DbConnectService.mySqlConnect);

                using (MySqlDataReader aReader = aCommand.ExecuteReader())
                {
                    while (aReader.Read())
                    {
                        DetectionItem detectionItem = new DetectionItem();
                        //姓名
                        if (!aReader.IsDBNull(0)) detectionItem.Id=Convert.ToInt32(aReader.GetString(0));
                        if (!aReader.IsDBNull(1)) detectionItem.DeviceId = Convert.ToInt64(aReader.GetString(1));
                        if (!aReader.IsDBNull(2)) detectionItem.StartTime = Convert.ToDateTime(aReader.GetString(2));
                        if (!aReader.IsDBNull(3)) detectionItem.EndTime = Convert.ToDateTime(aReader.GetString(3));
                        if (!aReader.IsDBNull(4)) detectionItem.Stability = aReader.GetString(4);
                        if (!aReader.IsDBNull(5)) detectionItem.Accuracy = aReader.GetString(5);
                        if (!aReader.IsDBNull(6)) detectionItem.BootFeature = aReader.GetString(6);
                        if (!aReader.IsDBNull(7)) detectionItem.AgeRate = aReader.GetString(7);
                        if (!aReader.IsDBNull(8)) detectionItem.Interval = aReader.GetString(8);
                        detectionItemList.Add(detectionItem);
                    }

                    aCommand.Dispose();
                }
            }
            catch (MySqlException ex)
            {
                LogHelper.WriteErrorLog(MethodBase.GetCurrentMethod().DeclaringType, "searchDetectionItem: " + ex.Message);               
            }
            return detectionItemList;
        }

    }
}