#region

using System;
using System.ServiceModel;
using CSFrameworkV5.Common;
using CSFrameworkV5.DataAccess;

#endregion

namespace CSFrameworkV5.WCFContract.WCF_Class
{
    [ServiceBehavior(IncludeExceptionDetailInFaults = true)]
    [WCF_ExceptionBehaviour(typeof(WCF_ExceptionHandler))]
    public class DataDictService : IDataDictService
    {
        public bool CheckNoExists(byte[] loginTicket, string keyValue,
            string ORM_TypeName)
        {
            try
            {
                var loginer = WebSecurity.ValidateLoginer(loginTicket);

                var dict = DALFactory.CreateDalByORM(loginer, ORM_TypeName);
                return dict.CheckNoExists(keyValue);
            }
            catch (Exception ex)
            {
                throw new FaultException(ex.Message);
            }
        }

        public bool CheckNoExistsEx(byte[] loginTicket, string keyFieldName,
            string keyValue, string ORM_TypeName)
        {
            try
            {
                var loginer = WebSecurity.ValidateLoginer(loginTicket);

                var dict = DALFactory.CreateDalByORM(loginer, ORM_TypeName);
                return dict.CheckNoExists(keyFieldName, keyValue);
            }
            catch (Exception ex)
            {
                throw new FaultException(ex.Message);
            }
        }

        /// <summary>
        ///     删除一条数据字典记录
        /// </summary>
        /// <param name="loginTicket"></param>
        /// <param name="keyValue">主键</param>
        /// <param name="ORM_TypeName">ORM类型</param>
        /// <returns></returns>
        public bool Delete(byte[] loginTicket, string keyValue,
            string ORM_TypeName)
        {
            try
            {
                var loginer = WebSecurity.ValidateLoginer(loginTicket);
                var dict =
                    DALFactory.CreateDalByORM(loginer, ORM_TypeName); //创建DAL层实例
                return dict.Delete(keyValue);
            }
            catch (Exception ex)
            {
                throw
                    new FaultException(ex
                        .Message); //转换为客户端可截取的异常类型(FaultException)信息。
                //throw new FaultException("删除记录发生错误！");//或者提示更具体的异常信息，屏蔽WCF系统内部消息。
            }
        }

        public byte[] GetDataByKey(byte[] loginTicket, string ORM_TypeName,
            string key)
        {
            try
            {
                var loginer = WebSecurity.ValidateLoginer(loginTicket);

                var dict = DALFactory.CreateDalByORM(loginer, ORM_TypeName);
                var data = dict.GetDataByKey(key);
                return ZipTools.CompressionObject(
                    ServerLibrary.TableToDataSet(data));
            }
            catch (Exception ex)
            {
                throw new FaultException(ex.Message);
            }
        }

        public byte[] GetDataDictByDBTableName(byte[] loginTicket,
            string tableName, string DBID)
        {
            try
            {
                if (string.IsNullOrWhiteSpace(tableName) ||
                    string.IsNullOrWhiteSpace(DBID))
                    throw new Exception(
                        "GetDataDictByDBTableName方法缺少DBID/tableName参数值！");

                var loginer = WebSecurity.ValidateLoginer(loginTicket);
                var dal = DALFactory.CreateDalByTableName(loginer, tableName);
                if (dal == null) dal = new dalBaseDataDict(loginer, tableName);

                dal.Database = DatabaseProvider.GetDatabase(DBID);
                var data = dal.GetSummaryData();
                return ZipTools.CompressionObject(
                    ServerLibrary.TableToDataSet(data));
            }
            catch (Exception ex)
            {
                throw new FaultException(ex.Message);
            }
        }

        public byte[] GetDataDictByTableName(byte[] loginTicket,
            string tableName)
        {
            try
            {
                var loginer = WebSecurity.ValidateLoginer(loginTicket);
                var dal = DALFactory.CreateDalByTableName(loginer, tableName);
                if (dal == null) dal = new dalBaseDataDict(loginer, tableName);

                var data = dal.GetSummaryData();
                return ZipTools.CompressionObject(
                    ServerLibrary.TableToDataSet(data));
            }
            catch (Exception ex)
            {
                throw new FaultException(ex.Message);
            }
        }

        public byte[] GetEmptyTable(byte[] loginTicket, string databaseName,
            string tableName)
        {
            try
            {
                var loginer = WebSecurity.ValidateLoginer(loginTicket);
                var data =
                    new dalCommon(loginer).GetEmptyTable(databaseName,
                        tableName);
                return ZipTools.CompressionDataSet(
                    ServerLibrary.TableToDataSet(data));
            }
            catch (Exception ex)
            {
                throw new FaultException(ex.Message);
            }
        }

        public byte[] GetLookupData(byte[] loginTicket, string tableName)
        {
            try
            {
                var loginer = WebSecurity.ValidateLoginer(loginTicket);
                var dal = DALFactory.CreateDalByTableName(loginer, tableName);
                if (dal == null) dal = new dalBaseDataDict(loginer, tableName);

                var data = dal.GetLookupData();
                return ZipTools.CompressionDataSet(
                    ServerLibrary.TableToDataSet(data));
            }
            catch (Exception ex)
            {
                throw new FaultException(ex.Message);
            }
        }

        public byte[] GetLookupDataByDBTableName(byte[] loginTicket,
            string tableName, string DBID)
        {
            try
            {
                var loginer = WebSecurity.ValidateLoginer(loginTicket);
                var dal = DALFactory.CreateDalByTableName(loginer, tableName);
                if (dal == null) dal = new dalBaseDataDict(loginer, tableName);

                dal.Database = DatabaseProvider.GetDatabase(DBID);
                var data = dal.GetLookupData();
                return ZipTools.CompressionDataSet(
                    ServerLibrary.TableToDataSet(data));
            }
            catch (Exception ex)
            {
                throw new FaultException(ex.Message);
            }
        }

        public byte[] GetLookupDataByTableName(byte[] loginTicket,
            string tableName)
        {
            try
            {
                var loginer = WebSecurity.ValidateLoginer(loginTicket);
                var dal = DALFactory.CreateDalByTableName(loginer, tableName);
                if (dal == null) dal = new dalBaseDataDict(loginer, tableName);

                var data = dal.GetLookupData();
                return ZipTools.CompressionDataSet(
                    ServerLibrary.TableToDataSet(data));
            }
            catch (Exception ex)
            {
                throw new FaultException(ex.Message);
            }
        }

        public byte[] GetSummaryData(byte[] loginTicket, string ORM_TypeName)
        {
            try
            {
                var loginer = WebSecurity.ValidateLoginer(loginTicket);

                var dict = DALFactory.CreateDalByORM(loginer, ORM_TypeName);
                var data = dict.GetSummaryData();
                return ZipTools.CompressionObject(
                    ServerLibrary.TableToDataSet(data));
            }
            catch (Exception ex)
            {
                throw new FaultException(ex.Message);
            }
        }

        public bool Update(byte[] loginTicket, byte[] bs, string ORM_TypeName)
        {
            try
            {
                var loginer = WebSecurity.ValidateLoginer(loginTicket);

                var data = ZipTools.DecompressionDataSet(bs);
                var dict = DALFactory.CreateDalByORM(loginer, ORM_TypeName);
                return dict.Update(data);
            }
            catch (Exception ex)
            {
                throw new FaultException(ex.Message);
            }
        }

        public byte[] UpdateEx(byte[] loginTicket, byte[] bs,
            string ORM_TypeName)
        {
            try
            {
                var loginer = WebSecurity.ValidateLoginer(loginTicket);

                var data = ZipTools.DecompressionDataSet(bs);
                var dict = DALFactory.CreateDalByORM(loginer, ORM_TypeName);
                var result = dict.UpdateEx(data); //保存数据
                return ZipTools.CompressionObject(result); //序列化返回对象
            }
            catch (Exception ex)
            {
                throw new FaultException(ex.Message);
            }
        }
    }
}