Dynamics Extentions BasePlugin

Dynamics 365/CRM 插件基础扩展，插件继承此类后，可以简化一些基础服务的初始化以及Target等参数的取用；

以下为基本使用方式，更多能力请自动探索

using lce.mscrm.engine;
using Microsoft.Xrm.Sdk;
 
namespace MSCRM.CRM.Plugins.Fund
{
    /// 
    /// 测试实体Demo展示
    /// 测试实体 lce_test
    /// Entity:lce_test,Message:Create,Event:Pre
    /// Entity:lce_test,Message:Create\Update,Event:Post
    /// 
    public class TestPost : BasePlugin
    {
        public override void HandleExecute(IOrganizationService service, IOrganizationService caller, ITracingService tracing, IPluginExecutionContext context)
        {
 
            if (EqualActionOrMessage(20, MessageName.Create) && Target.IsNotNull("lce_name"))
            {
                HandleCreateLoigc(service, Target);
            }
 
            if (EqualActionOrMessage(40, MessageName.Create) && Target.IsNotNull("lce_name"))
            {
                HandleCreateLoigc(service, Target);
            }
 
            if (EqualActionOrMessage(40, MessageName.Update) && Target.IsNotNull("lce_name"))
            {
                HandleUpdateLoigc(service, Target);
            }
        }
 
        private void HandleCreateLoigc(IOrganizationService service, Entity target)
        {
           //do things
        }
 
        private void HandleUpdateLoigc(IOrganizationService service, Entity target)
        {
           //do things
        }
    }
}

以下为BasePlugin扩展类源代码

/* file name：lce.mscrm.engine.BasePlugin.cs
* author：lynx lynx.kor@163.com @ 2018/10/28 13:13:00
* copyright (c) 2020 Copyright@lynxce.com
* desc：
* > add description for BasePlugin
* revision：
*
*/
 
using lce.ext.providers;
using Microsoft.Xrm.Sdk;
using System;
using System.ServiceModel;
 
namespace lce.mscrm.engine
{
    #region === MessageName ===
 
    public enum MessageName
    {
        /// 
        /// Assign
        /// Changes ownership of a record. Valid for user-owned or team-owned entities.
        /// 
        Assign,
 
        /// 
        /// Creates links between a record and a collection of records where there is a relationship
        /// between the entities.
        /// 
        Associate,
 
        /// 
        /// Create Target
        /// Creates a record of a specific entity type, including custom entities.
        /// 
        Create,
 
        /// 
        /// Delete Target
        /// Deletes a record.
        /// 
        Delete,
 
        /// 
        /// Removes links between a record and a collection of records where there is a relationship
        /// between the entities.
        /// 
        Disassociate,
 
        AssignUserRoles,
        GrantAccess,
        ModifyAccess,
 
        /// 
        /// Retrieves a record.
        /// 
        Retrieve,
 
        /// 
        /// Retrieves a collection of records.
        /// 
        RetrieveMultiple,
 
        RetrievePrincipalAccess,
        RetrieveSharedPrincipalsAndAccess,
        RevokeAccess,
 
        /// 
        /// Set the state of a record.
        /// 
        SetState,
 
        /// 
        /// Grants, modifies or revokes access to a record to another user or team. Valid for
        /// user-owned or team-owned entities.
        /// 
        Share,
 
        /// 
        /// Update Target
        /// Modifies the contents of a record.
        /// 
        Update,
    }
 
    #endregion === MessageName ===
 
    /// 
    /// action：BasePlugin
    /// UserId = _context.UserId
    /// 
    public abstract class BasePlugin : IPlugin
    {
        #region === 私有变量/方法 ===
 
        private IPluginExecutionContext _context;
 
        /// 
        /// 
        /// 
        /// 
        /// 
        private T GetService<T>(IServiceProvider serviceProvider)
        {
            return (T)serviceProvider.GetService(typeof(T));
        }
 
        #endregion === 私有变量/方法 ===
 
        /// 
        /// 修改后
        /// 
        protected Entity PostImage { get; set; }
 
        /// 
        /// 修改前
        /// 
        protected Entity PreImage { get; set; }
 
        /// 
        /// 当前实例
        /// 
        protected Entity Target { get; set; }
 
        /// 
        /// 当前实例
        /// 
        protected EntityReference TargetReference { get; set; }
 
        /// 
        /// check the attribute in entity is null.
        /// 
        ///    
        /// 
        /// 
        public static bool IsNotNull(Entity entity, string attribute)
        {
            return null != entity && entity.Contains(attribute) && IsNotNull(entity[attribute]);
        }
 
        /// 
        /// check the object is not null.
        /// 
        /// 
        /// 
        public static bool IsNotNull(object obj)
        {
            return null != obj && DBNull.Value != obj && !string.IsNullOrEmpty(obj.ToString());
        }
 
        /// 
        /// 插件回滚，弹出消息。
        /// 
        /// 消息类容
        public static void ShowErrorMessage(string msg)
        {
            throw new InvalidPluginExecutionException(msg);
        }
 
        /// 
        /// 实体状态比较
        /// 
        ///  pre:20;post:40
        /// create,update,delete
        /// 
        public bool EqualActionOrMessage(int state, MessageName action)
        {
            return _context.Stage == state && _context.MessageName.ToLower().Equals(action.ToString().ToLower());
        }
 
        /// 
        /// 
        /// 
        public void Execute(IServiceProvider serviceProvider)
        {
            _context = GetService(serviceProvider);            //上下文
            var _tracing = GetService(serviceProvider);                //跟踪服务
            var _factory = GetService(serviceProvider);    //服务工厂
            var _caller = _factory.CreateOrganizationService(_context.UserId);          //用户权限服务
            var _service = _factory.CreateOrganizationService(null);                    //管理员权限服务
 
            try
            {
                if (_context.InputParameters.Contains("Target") && _context.InputParameters["Target"] is EntityReference)
                {
                    TargetReference = (EntityReference)_context.InputParameters["Target"];
                }
 
                if (_context.InputParameters.Contains("Target") && _context.InputParameters["Target"] is Entity)
                {
                    Target = (Entity)_context.InputParameters["Target"];
                    TargetReference = Target.ToEntityReference();
                }
 
                if (_context.PreEntityImages.Contains("PreImage") && _context.PreEntityImages["PreImage"] is Entity)
                    PreImage = _context.PreEntityImages["PreImage"];
 
                if (_context.PostEntityImages.Contains("PostImage") && _context.PostEntityImages["PostImage"] is Entity)
                    PostImage = _context.PostEntityImages["PostImage"];
 
                // do same logic
                HandleExecute(_service, _caller, _tracing, _context);
            }
            catch (InvalidPluginExecutionException ex)
            {
                _tracing.Trace($"操作提醒：{ex.Message}[Plugin]");
                throw ex;
            }
            catch (FaultException ex)
            {
                var msg = $"操作错误：{ex.Message}";
                if (null != ex.InnerException)
                    msg = $"{msg}=>{ex.InnerException.Message}";
                _tracing.Trace($"插件业务错误：{msg}{ex.StackTrace}");
                LogExt.e($"{_context.MessageName}:{TargetReference.LogicalName}:{TargetReference.Id}:{msg}", ex, $"plugin.{TargetReference.LogicalName}");
                throw new InvalidPluginExecutionException(msg);
            }
            catch (Exception ex)
            {
                var msg = $"系统错误：{ex.Message}";
                if (null != ex.InnerException)
                    msg = $"{msg}=>{ex.InnerException.Message}";
                _tracing.Trace($"系统内部错误：{msg}{ex.StackTrace}");
                LogExt.e($"{_context.MessageName}:{TargetReference.LogicalName}:{TargetReference.Id}:{msg}", ex, $"plugin.{TargetReference.LogicalName}");
                throw new InvalidPluginExecutionException(msg);
            }
        }
 
        /// 
        /// 插件继承BasePlugin后实现些方法，进行业务处理
        /// 
        public abstract void HandleExecute(IOrganizationService service, IOrganizationService caller, ITracingService tracing, IPluginExecutionContext context);
    }
}