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 DictServiceImpl:DictService
    {
        public String getNameByCode(string codeType,string code)
        {
            String name = "";
            try
            {
                string sql = "SELECT name FROM r_dict where pid = (select id from r_dict where code = '"
                    + codeType + "') and code = " + code;
                
                MySqlCommand cmd = new MySqlCommand(sql, DbConnectService.mySqlConnect);

                MySqlDataReader aReader = cmd.ExecuteReader(CommandBehavior.Default);

                if (aReader != null)
                {
                    if (aReader.Read())
                    {
                        //判断门的状态
                        if (!aReader.IsDBNull(0))
                        {
                            name = aReader.GetString(0);
                        }
                    }
                }

                cmd.Dispose();
                return name;
            }
            catch(MySqlException ex)
            {
                LogHelper.WriteErrorLog(MethodBase.GetCurrentMethod().DeclaringType, "getNameByCode: " + ex.Message);
                name = "";
            }
            return name;
        }

        public List<String> getTypeListByCodeType(string codeType)
        {
            List<String> nameList = new List<string>();
            try
            {
                if (DbConnectService.mySqlConnect.State == ConnectionState.Closed)
                {
                    LogHelper.WriteErrorLog(MethodBase.GetCurrentMethod().DeclaringType, "getTypeListByCodeType : 数据库链接断开");
                    return null;
                }

                string sQry = "SELECT name FROM r_dict where pid = (select id from r_dict where code = '" + codeType + "')";
                MySqlCommand aCommand = new MySqlCommand(sQry, DbConnectService.mySqlConnect);

                using (MySqlDataReader aReader = aCommand.ExecuteReader())
                {
                    while (aReader.Read())
                    {
                        if (!aReader.IsDBNull(0))
                            nameList.Add(aReader.GetString(0));
                    }

                    aCommand.Dispose();
                }
            }
            catch(MySqlException ex)
            {
                LogHelper.WriteErrorLog(MethodBase.GetCurrentMethod().DeclaringType, "getTypeListByCodeType: " + ex.Message);
                nameList = null;
            }

            return nameList;
        }


    }
}