IMEX.mes.wcf/WCF.Service/WCF.Services/ServiceHost/ServiceInvoker.cs

/*******************************************************************************
 * Copyright(c) 2014 DongkeSoft All rights reserved. / Confidential
 * 类的信息：
 *      1.程序名称：ServiceHostCollection.cs
 *      2.功能描述：服务集合
 * 编辑履历：
 *      作者            日期                版本            修改内容
 *      陈晓野          2014/09/16          1.00            新建
 *******************************************************************************/

using System;
using Dongke.IBOSS.PRD.Basics.DataAccess;
using Dongke.IBOSS.PRD.Basics.Library;
using Dongke.IBOSS.PRD.Service.PDAModuleLogic;
using Dongke.IBOSS.PRD.WCF.DataModels;

namespace Dongke.IBOSS.PRD.WCF.Services
{
    public class ServiceInvoker
    {
        #region 服务事件
        /// <summary>
        /// 服务开始
        /// </summary>
        public static event ServiceDoingEventHandler ServiceDoingEvent;
        /// <summary>
        /// 服务结束
        /// </summary>
        public static event ServiceDoneEventHandler ServiceDoneEvent;
        /// <summary>
        /// 服务异常
        /// </summary>
        public static event ServiceExceptionEventHandler ServiceExceptionEvent;
        #endregion 服务事件

        /// <summary>
        /// 执行
        /// </summary>
        /// <param name="sender"></param>
        /// <param name="serviceInvocation"></param>
        public static void Invoke(object sender, Action serviceInvocation)
        {
            ServiceEventArgs eventArgs = new ServiceEventArgs();
            eventArgs.Sender = sender;
            eventArgs.ServiceName = sender.ToString();
            eventArgs.MethodName = serviceInvocation.Method.Name;

            BeginInvoke(eventArgs);
            try
            {
                serviceInvocation();
            }
            catch (Exception ex)
            {
                eventArgs.Exception = ex;
                InvokeException(eventArgs);
                HandleException(eventArgs);
            }
            finally
            {
                EndInvoke(eventArgs);
            }
        }

        /// <summary>
        /// 执行
        /// </summary>
        /// <typeparam name="TResult"></typeparam>
        /// <param name="sender"></param>
        /// <param name="serviceInvocation"></param>
        /// <param name="webUserInfo"></param>
        /// <returns></returns>
        public static TResult Invoke<TResult>(object sender, Func<TResult> serviceInvocation)
        {
            ServiceEventArgs eventArgs = new ServiceEventArgs();
            eventArgs.Sender = sender;
            eventArgs.ServiceName = sender.ToString();
            eventArgs.MethodName = serviceInvocation.Method.Name;

            BeginInvoke(eventArgs);
            TResult result = default(TResult);
            try
            {
                result = serviceInvocation();
            }
            catch (Exception ex)
            {
                eventArgs.Exception = ex;
                InvokeException(eventArgs);
                HandleException(eventArgs);
            }
            finally
            {
                EndInvoke(eventArgs);
            }
            return result;
        }

		/// <summary>
		/// 执行
		/// </summary>
		/// <typeparam name="TResult"></typeparam>
		/// <param name="sender"></param>
		/// <param name="serviceInvocation"></param>
		/// <param name="webUserInfo"></param>
		/// <returns></returns>
		public static ServiceResultEntity Invoke(object sender, Func<ServiceResultEntity> serviceInvocation)
		{
			ServiceEventArgs eventArgs = new ServiceEventArgs();
			eventArgs.Sender = sender;
			eventArgs.ServiceName = sender.ToString();
			eventArgs.MethodName = serviceInvocation.Method.Name;

			BeginInvoke(eventArgs);
			ServiceResultEntity result = null;
			try
			{
                result = serviceInvocation();
			}
			catch (Exception ex)
			{
				eventArgs.Exception = ex;
				InvokeException(eventArgs);

				HandleException(eventArgs);
				//OutputLog.TraceLog(LogPriority.Error,
				//					eventArgs.Sender.ToString(),
				//					eventArgs.MethodName,
				//					eventArgs.Exception.ToString(),
				//					LocalPath.LogExePath);
				//result = new ServiceResultEntity();
				//result.Status = Basics.BaseResources.Constant.ServiceResultStatus.SystemError;
				//result.Message = ex.ToString();
				////result.Exception = ex;
			}
			finally
			{
				EndInvoke(eventArgs);
			}
			return result;
		}

        /// <summary>
        /// 开始执行
        /// </summary>
        /// <param name="eventArgs"></param>
        public static void BeginInvoke(ServiceEventArgs eventArgs)
        {
            if (ServiceDoingEvent != null)
            {
                ServiceDoingEvent(eventArgs.Sender, eventArgs);
            }
        }

        /// <summary>
        /// 执行异常
        /// </summary>
        /// <param name="eventArgs"></param>
        public static void InvokeException(ServiceEventArgs eventArgs)
        {
            if (ServiceExceptionEvent != null)
            {
                ServiceExceptionEvent.BeginInvoke(eventArgs.Sender, eventArgs, null, null);
            }
        }

        /// <summary>
        /// 结束执行
        /// </summary>
        /// <param name="eventArgs"></param>
        public static void EndInvoke(ServiceEventArgs eventArgs)
        {
            if (ServiceDoneEvent != null)
            {
                ServiceDoneEvent.BeginInvoke(eventArgs.Sender, eventArgs, null, null);
            }
        }

        /// <summary>
        /// 异常处理
        /// </summary>
        /// <param name="ex"></param>
        public static void HandleException(ServiceEventArgs ex)
        {
            string em = ex.Exception.Message;
            if (em.Contains("LoginInfoError") ||
                em.Contains("RepeatLogin") ||
                em.Contains("LicInfoError")
                )
            {
                throw new Exception(ex.MethodName, ex.Exception);
            }

            //LogFileOperation.Error(DataManager.LogFileName, ex.MethodName + "  " + ex.Exception.Message);

            string userInfo = null;
            if (ex.Sender is ServicesBase)
            {
                ServicesBase sb = ex.Sender as ServicesBase;
                if (sb != null)
                {
                    if (sb.SUserInfo != null)
                    {
                        userInfo = JsonHelper.ToJson(sb.SUserInfo) + System.Environment.NewLine;
                    }
                }
            }
            OutputLog.TraceLog(LogPriority.Error,
                ex.Sender.ToString(),
                userInfo + ex.MethodName,
                ex.Exception.ToString(),
                LocalPath.LogExePath);

            // TODO 异常处理
            throw new Exception(ex.MethodName, ex.Exception);
        }
    }
}