#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 MessageCenter : IMessageCenter
    {
        public void Broadcast(byte[] loginTicket, string message,
            string messageType)
        {
            try
            {
                var loginer = WebSecurity.ValidateLoginer(loginTicket);
                new dalMessageCenter(loginer).Broadcast(message, messageType);
            }
            catch (Exception ex)
            {
                throw new FaultException(ex.Message);
            }
        }

        public bool DeleteBroadcast(byte[] loginTicket, int isid)
        {
            try
            {
                var loginer = WebSecurity.ValidateLoginer(loginTicket);
                return new dalMessageCenter(loginer).DeleteBroadcast(isid);
            }
            catch (Exception ex)
            {
                throw new FaultException(ex.Message);
            }
        }

        public bool DeleteMessage(byte[] loginTicket, string messageId)
        {
            try
            {
                var loginer = WebSecurity.ValidateLoginer(loginTicket);
                return new dalMessageCenter(loginer).DeleteMessage(messageId);
            }
            catch (Exception ex)
            {
                throw new FaultException(ex.Message);
            }
        }

        public byte[] GetBroadcast(byte[] loginTicket)
        {
            try
            {
                var loginer = WebSecurity.ValidateLoginer(loginTicket);
                var data = new dalMessageCenter(loginer).GetBroadcast();
                return ZipTools.CompressionDataSet(
                    ServerLibrary.TableToDataSet(data));
            }
            catch (Exception ex)
            {
                throw new FaultException(ex.Message);
            }
        }

        public string GetBroadcastMessage(byte[] identity)
        {
            try
            {
                var isIdentity = WebSecurity.ValidateLoginIdentity(identity);
                return new dalMessageCenter(null).GetBroadcastMessage();
            }
            catch (Exception ex)
            {
                throw new FaultException(ex.Message);
            }
        }

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

        public byte[] GetMessageTopDays(byte[] loginTicket, int days)
        {
            try
            {
                var loginer = WebSecurity.ValidateLoginer(loginTicket);
                var data =
                    new dalMessageCenter(loginer).GetMessageTopDays(days);
                return ZipTools.CompressionDataSet(
                    ServerLibrary.TableToDataSet(data));
            }
            catch (Exception ex)
            {
                throw new FaultException(ex.Message);
            }
        }

        public void MakeRead(byte[] loginTicket, string messageID,
            string account)
        {
            try
            {
                var loginer = WebSecurity.ValidateLoginer(loginTicket);
                new dalMessageCenter(loginer).MakeRead(messageID, account);
            }
            catch (Exception ex)
            {
                throw new FaultException(ex.Message);
            }
        }

        public bool SendMessage(byte[] loginTicket, string message,
            int accountGroupType, string accountOrGroup)
        {
            try
            {
                var loginer = WebSecurity.ValidateLoginer(loginTicket);
                new dalMessageCenter(loginer).SendMessage(message,
                    accountGroupType, accountOrGroup);
                return true;
            }
            catch (Exception ex)
            {
                throw new FaultException(ex.Message);
            }
        }
    }
}