The real-time workflow when creating records is performed before the record is transferred to the database

Question

The real-time workflow when creating records is performed before the record is transferred to the database

I have this code that works in real time when creating a record. It basically determines which object it works on, tries to get a “field-related” that can change from one object to another, and then see if the related record is associated with the account, if so, to update some attributes of the account.

public override void ExecuteWorkflowLogic(XrmObjects xrmObjects)
{
    using (XrmServiceContext ctx = new XrmServiceContext(xrmObjects.Service))
    {
        var target = xrmObjects.WorkflowContext.InputParameters["Target"] as Entity;
        Xrm.Account account = null;
        var regardingFieldName = string.Empty;

        var logicalName = string.Empty;
        var primaryKeyName = string.Empty;

        switch (target.LogicalName)
        {
            case Xrm.Task.EntityLogicalName:
            case Xrm.Email.EntityLogicalName:
            case Xrm.PhoneCall.EntityLogicalName:
            case Xrm.Letter.EntityLogicalName:
            case Xrm.Appointment.EntityLogicalName:
            case Xrm.Fax.EntityLogicalName:
                regardingFieldName = "regardingobjectid";
                logicalName = Xrm.ActivityPointer.EntityLogicalName;
                primaryKeyName = "activityid";
                break;
            case Xrm.Annotation.EntityLogicalName:
                logicalName = Xrm.Annotation.EntityLogicalName;
                regardingFieldName = "objectid";
                primaryKeyName = "annotationid";
                break;
            case Xrm.Opportunity.EntityLogicalName:
                regardingFieldName = "customerid";
                logicalName = Xrm.Opportunity.EntityLogicalName;
                primaryKeyName = "opportunityid";
                break;
            case Xrm.Post.EntityLogicalName:
                regardingFieldName = "regardingobjectid";
                logicalName = Xrm.Post.EntityLogicalName;
                primaryKeyName = "postid";
                break;
         }


         var activity = (from a in ctx.CreateQuery(logicalName)
                                where a[regardingFieldName] != null && (Guid)a[primaryKeyName] == target.Id
                                select a).FirstOrDefault();

         var ec = (EntityReference)activity[regardingFieldName];

         if (ec == null)
             return;

         //if regarding isn't an account...
         if (ec.LogicalName != Xrm.Account.EntityLogicalName)
             return;

         account = ctx.AccountSet.SingleOrDefault(x => x.Id == ec.Id);

         if (account == null)
             return;

         account.new_last_activity_created_by = (EntityReference)target["createdby"];
         account.new_last_activity_date = (DateTime)target["createdon"];
         account.new_last_activity_type = GetActivityType(target); //returns an optionset based on entity logical name....
         account.new_last_activity_entity_logicalname = target.LogicalName;

         if (!ctx.IsAttached(account))
              ctx.Attach(account);

         ctx.UpdateObject(account);
         ctx.SaveChanges();
    }
}

, , , , , , , ( ), .

, ( switch) , , ( activity )

target GUID ActivityPointerBase TaskBase, EmailBase .. ( , )

async, .

, . .

, BaseWorkflowStep:

public abstract class BaseWorkflowStep : CodeActivity
{
    protected override void Execute(CodeActivityContext context)
    {
        var xrmObjects = new XrmObjects();

        var serviceFactory = context.GetExtension<IOrganizationServiceFactory>();
        xrmObjects.CodeActivityContext = context;
        xrmObjects.TracingService = context.GetExtension<ITracingService>();
        xrmObjects.WorkflowContext = context.GetExtension<IWorkflowContext>();
        xrmObjects.Service = serviceFactory.CreateOrganizationService(xrmObjects.WorkflowContext.UserId);

        ExecuteWorkflowLogic(xrmObjects);
    }

    public virtual void ExecuteWorkflowLogic(XrmObjects xrmObjects)
    {
        throw new NotImplementedException();
    }
}