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 model, string devCode, string channel, string nominalValue, string indexValue, DateTime createTime)
        {
            int iRetval = -1;
            try
            {
                if (DbConnectService.mySqlConnect.State == ConnectionState.Closed)
                {
                    LogHelper.WriteErrorLog(MethodBase.GetCurrentMethod().DeclaringType, "addCounterData : 数据库链接断开");
                    return iRetval;
                }

                string sQry = "INSERT INTO r_counter_data (MODEL,DEVCODE,CHANNEL,NOMINAL_VALUE,INDEX_VALUE,CREATE_TIME)" +
                    "values(@MODEL,@DEVCODE,@CHANNEL,@NOMINAL_VALUE,@INDEX_VALUE,@CREATE_TIME)";

                MySqlCommand cmd = new MySqlCommand(sQry, DbConnectService.mySqlConnect);
                cmd.Parameters.Add("@MODEL", MySqlDbType.Int64, 20).Value = model;
                cmd.Parameters.Add("@DEVCODE", MySqlDbType.String, 30).Value = devCode;
                cmd.Parameters.Add("@CHANNEL", MySqlDbType.String, 30).Value = channel;
                cmd.Parameters.Add("@NOMINAL_VALUE", MySqlDbType.String, 30).Value = nominalValue;
                cmd.Parameters.Add("@INDEX_VALUE", MySqlDbType.String, 30).Value = indexValue;
                cmd.Parameters.Add("@CREATE_TIME", MySqlDbType.Date, 0).Value = createTime;

                cmd.ExecuteNonQuery();

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

            return iRetval;
        }

    }
}