我最近开始在 Execute 方法中获取 CRM 对象,并在单独的方法中执行插件/工作流业务逻辑。
这种方法可以改进(或丢弃)吗?
使用 LINQ 获取工作流的目标记录是否可以接受?
比输入参数方便;工作流也是异步的,不会影响用户体验。
对于插件:
public class AddEmailAttachments : IPlugin
{
private void AddAttachments(Entity target, IOrganizationService service, Context linq)
{
// Business logic
}
/*
* Get all the Objects that we need
* and call AddAttachments
* */
public void Execute(IServiceProvider serviceProvider)
{
IPluginExecutionContext context = null;
IOrganizationServiceFactory factory = null;
IOrganizationService service = null;
Entity target = null;
Context linq = null;
try // and get the services we need
{
context = (IPluginExecutionContext)serviceProvider.GetService(typeof(IPluginExecutionContext));
factory = (IOrganizationServiceFactory)serviceProvider.GetService(typeof(IOrganizationServiceFactory));
service = factory.CreateOrganizationService(context.UserId);
target = (Entity)context.InputParameters["Target"];
linq = new Context(service);
if (service != null && target != null && linq != null)
AddAttachments(target, service, linq);
}
catch (Exception) { }; // this is strict because if this plugin fails then the email will not be created in CRM and disrupt the business process
}
}
对于工作流:
public class SendCaseNotifications : CodeActivity
{
/* Receives the necessary Objects and
* Sends the email
* */
private void SendNotifications(Incident incident, IOrganizationService service, Email email, Context linq)
{
// Perform business logic
}
/* Get the Objects that are required and call
* the method
* */
protected override void Execute(CodeActivityContext context)
{
IWorkflowContext workflowContext = context.GetExtension<IWorkflowContext>();
IOrganizationServiceFactory factory = context.GetExtension<IOrganizationServiceFactory>();
IOrganizationService service = factory.CreateOrganizationService(workflowContext.InitiatingUserId);
Entity target = workflowContext.InputParameters["Target"] as Entity;
Incident incident = null;
Email email = null;
Context linq = new Context(service);
IEnumerable<Incident> incidentQuery = from incidents in linq.IncidentSet where incidents.Id.Equals(target.Id) select incidents;
if (incidentQuery.Any())
incident = incidentQuery.First();
if (incident == null)
throw new InvalidPluginExecutionException("Unable to retrieve Case with id: " + target.Id.ToString() + ". Re-try the operation or contact the system administrator.");
IEnumerable<Email> emailQuery = from emails in linq.EmailSet where emails.Id.Equals(incident.mda_originatingemail.Id) select emails;
if (emailQuery.Any())
email = emailQuery.First();
if (email == null)
throw new InvalidPluginExecutionException("Unable to retrieve Email with id: " + incident.mda_originatingemail.Id.ToString() + ". Re-try the operation or contact the system administrator.");
SendNotifications(incident, service, email, linq);
}
}
我在 Execute 中尽可能多地处理异常,然后将对象传递给执行实际工作的方法。
我最近了解到,如果同步插件抛出异常,它会影响业务流程。