#region

using System;
using System.ServiceModel;

#endregion

namespace CSFrameworkV5.WebRef
{
    /// <summary>
    ///     WCF客户端代理层-基类
    /// </summary>
    /// <typeparam name="T"></typeparam>
    public class WCF_Base<T> where T : class
    {
        private void CloseService(ICommunicationObject svc)
        {
            try
            {
                //查看连接状态，关闭WCF                
                var state = svc.State; //创建WCF通道，默认State=Opened;

                svc.Close();

                //svc.Close();//测试关闭状态下，调用Close
            }
            catch
            {
            }
        }

        /// <summary>
        ///     执行WCF方法
        /// </summary>
        /// <param name="action">调用WCF接口核心逻辑</param>
        protected void Excute(Action<T> action)
        {
            T svc = null;

            try
            {
                svc = WCFFactory.Create<T>();
                action(svc);
                CloseService(svc as ICommunicationObject); //关闭WCF服务
            }
            catch (Exception ex)
            {
                if (svc != null) CloseService(svc as ICommunicationObject);

                throw ex;
            }
        }

        /// <summary>
        ///     执行WCF方法
        /// </summary>
        /// <typeparam name="R">数据类型</typeparam>
        /// <param name="action">调用WCF接口核心逻辑</param>
        /// <returns></returns>
        protected R Excute<R>(Func<T, R> action)
        {
            T svc = null;

            try
            {
                svc = WCFFactory.Create<T>(); //创建WCF接口实例                
                var result = action(svc); //调用接口逻辑
                CloseService(svc as ICommunicationObject); //关闭WCF服务
                return result;
            }
            catch (Exception ex)
            {
                if (svc != null) CloseService(svc as ICommunicationObject);

                throw ex;
            }
        }

        /// <summary>
        ///     执行指定WCF接口的方法
        /// </summary>
        /// <typeparam name="M">WCF接口</typeparam>
        /// <typeparam name="R">数据类型</typeparam>
        /// <param name="action">调用WCF接口核心逻辑</param>
        /// <returns></returns>
        protected R Excute<R, M>(Func<M, R> action) where M : class
        {
            M svc = null;

            try
            {
                svc = WCFFactory.Create<M>(); //创建WCF接口实例                
                var result = action(svc); //调用接口逻辑
                CloseService(svc as ICommunicationObject); //关闭WCF服务
                return result;
            }
            catch (Exception ex)
            {
                if (svc != null) CloseService(svc as ICommunicationObject);

                throw ex;
            }
        }
    }
}