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.Linq;
using System.Reflection;
using System.Text;

namespace Casic.Birmm.RbFreqStandMeasure.R_DataBase.Service.Impl
{
    class CounterDataServiceImpl:CounterDataService
    {

        public int add(string deviceId, string deviceModel, string channl, string outValue, string checkValue,
            string volTage, DateTime checkTime)
        {
            int iRetval = -1;
            try
            {
                if (DbConnectService.mySqlConnect.State == ConnectionState.Closed)
                {
                    LogHelper.WriteErrorLog(MethodBase.GetCurrentMethod().DeclaringType, "addCounterParam : 数据库链接断开");
                    return iRetval;
                }

                string sQry = "INSERT INTO r_counter_data (DEVICE_ID,DEVICE_MODEL,CHANNL,OUT_VALUE,CHECK_VALUE,VOLTAGE,CHECK_TIME)" +
                    "values(@DEVICE_ID,@DEVICE_MODEL,@CHANNL,@OUT_VALUE,@CHECK_VALUE,@VOLTAGE,@CHECK_TIME)";

                MySqlCommand cmd = new MySqlCommand(sQry, DbConnectService.mySqlConnect);
                cmd.Parameters.Add("@DEVICE_ID", MySqlDbType.Int64, 20).Value = deviceId;
                cmd.Parameters.Add("@DEVICE_MODEL", MySqlDbType.String, 255).Value = deviceModel;
                cmd.Parameters.Add("@CHANNL", MySqlDbType.String, 0).Value = channl;
                cmd.Parameters.Add("@OUT_VALUE", MySqlDbType.String, 0).Value = outValue;
                cmd.Parameters.Add("@CHECK_VALUE", MySqlDbType.String, 0).Value = checkValue;
                cmd.Parameters.Add("@VOLTAGE", MySqlDbType.String, 0).Value = volTage;
                cmd.Parameters.Add("@CHECK_TIME", MySqlDbType.DateTime, 0).Value = checkTime;

                cmd.ExecuteNonQuery();

                cmd.Dispose();

                iRetval = 0;
            }
            catch (MySqlException ex)
            {
                LogHelper.WriteErrorLog(MethodBase.GetCurrentMethod().DeclaringType, "addCounterParam : " + ex.Message);
                iRetval = -1;
            }

            return iRetval;
        }
    }
}