using System;
using System.Collections.Generic;
using System.Data;
using System.Data.SqlClient;
using WX.CRM.Common;

namespace WX.CRM.DAL.Wx
{
    public class Wx_MsgKey_Dal
    {
        //判断是否含有键
        public bool HasMsgKey(string key)
        {
            bool haskey = false;
            try
            {
                #region
                var para = new List<SqlParameter> { new SqlParameter("@key", key) };
                #endregion
                DataSet set = SqlHelper.GetDataSet(SqlHelper.DatabaseType.AYCRM, "CheckHasKey", CommandType.StoredProcedure, para.ToArray());
                if (set.Tables[0].Rows.Count > 0)
                    haskey = true;//包含数据
            }
            catch (Exception ex)
            {
                LogHelper.Error(ex.ToString());
                throw;
            }
            return haskey;
        }
        //新增键
        public bool CheckAndSetKey(string key)
        {
            bool isok = false;

            try
            {

                #region

                var para = new List<SqlParameter> { new SqlParameter("@key", key) };
                #endregion
                SqlHelper.ExcuteSPOrSql(SqlHelper.DatabaseType.AYCRM, "CheckAndSetKey", CommandType.StoredProcedure, para.ToArray());
                isok = true;
            }
            catch (Exception ex)
            {

                LogHelper.Error(ex.ToString());
                throw;
            }
            return isok;
        }

        public string GetFile(string key)
        {
            string filename = "";
            try
            {

                #region
                string newkey = key.Replace("wx:", "");//直接通过msgid插入数据
                var para = new List<SqlParameter> { new SqlParameter("@MsgSvrId", newkey) };
                #endregion
                DataSet set = SqlHelper.GetDataSet(SqlHelper.DatabaseType.AYCRM, "HasOrNullFilePath", CommandType.StoredProcedure, para.ToArray());

                if (set.Tables[0].Rows.Count > 0)
                {
                    filename = set.Tables[0].Rows[0]["FileName"].ToString();
                }
            }
            catch (Exception ex)
            {

                LogHelper.Error(ex.ToString());
                throw;
            }
            return filename;
        }
        public string HasOrAddFileMd5Relation(string md5, string MsgSvrId)
        {
            string filename = "";
            try
            {

                #region
                var para = new List<SqlParameter> { new SqlParameter("@md5", md5), new SqlParameter("@MsgSvrId", MsgSvrId) };
                #endregion
                DataSet set = SqlHelper.GetDataSet(SqlHelper.DatabaseType.AYCRM, "HasOrAddFileMd5Relation", CommandType.StoredProcedure, para.ToArray());
                if (set.Tables[0].Rows.Count > 0)
                {
                    filename = set.Tables[0].Rows[0]["FileUrl"].ToString();
                }
            }
            catch (Exception ex)
            {

                LogHelper.Error(ex.ToString());
                throw;
            }
            return filename;
        }
    }
}