Dynamics 365 CE: Create C# plugin, search related records and update records

 The following C# plugin is used to fetch the record through relation and update contact records.

using System;

using System.ServiceModel;

using Microsoft.Xrm.Sdk;

using Microsoft.Xrm.Sdk.Messages;

using Microsoft.Xrm.Sdk.Query;

namespace XMA_ContactEntityUpdate_Plugin.XMA_ContactEntityUpdate

{

    /// <summary>

    /// PostOperationaccountUpdate Plugin.

    /// </summary>    

    public class PostOperationaccountUpdate: IPlugin

    {

        public void Execute(IServiceProvider serviceProvider)

        {

            //Initializing Service Context.

            IPluginExecutionContext context = (IPluginExecutionContext)serviceProvider.GetService(typeof(IPluginExecutionContext));

            IOrganizationServiceFactory factory = (IOrganizationServiceFactory)serviceProvider.GetService(typeof(IOrganizationServiceFactory));

            IOrganizationService service = factory.CreateOrganizationService(context.UserId);

            try

            {

                //Defining Entity Object.

                Entity eTarget = null;

                if (context.MessageName == "Update")

                {                    

                    eTarget = (context.InputParameters.Contains("Target") && context.InputParameters["Target"] != null) ?

                    context.InputParameters["Target"] as Entity : null;                    

                    Guid accountIdGuid = eTarget.GetAttributeValue<Guid>("accountid");                                

                    QueryExpression query = new QueryExpression();

                    query.EntityName = "EntityName";

                    query.ColumnSet = new ColumnSet("columname");

                    Relationship relationship = new Relationship("relation_name");

                    relationship.PrimaryEntityRole = EntityRole.Referenced;

                    RelationshipQueryCollection relatedEntity = new RelationshipQueryCollection();

                    relatedEntity.Add(relationship, query);

                    RetrieveRequest request = new RetrieveRequest();

                    request.RelatedEntitiesQuery = relatedEntity;

                    request.ColumnSet = new ColumnSet("name");

                    request.Target = new EntityReference("account", accountIdGuid);

                    RetrieveResponse response = (RetrieveResponse)service.Execute(request);

                    

                    foreach (var industry in response.Entity.RelatedEntities[relationship].Entities)

                    {

                        var phone = industry["name"];

                        if (industryName != null)

                        {                            

                            QueryExpression qeContactUpdate = new QueryExpression("contact");

                            qeContactUpdate.ColumnSet.AddColumns("contactname");

                            FilterExpression filterUpdate = new FilterExpression(LogicalOperator.And);

                            filterUpdate.AddCondition("accountid", ConditionOperator.Equal, accountIdGuid);

                            qeContactUpdate.Criteria.AddFilter(filterUpdate);

                            EntityCollection entityCollectionUpdate = service.RetrieveMultiple(qeContactUpdate);

                            if (entityCollectionUpdate.Entities.Count > 0)

                            {                                

                                foreach (var entity in entityCollectionUpdate.Entities)

                                {

                                    if (entity.Id != null)

                                    {

                                        Entity eContactUpdate = new Entity("contact");

                                        eContactUpdate.Id = entity.Id;

                                        eContactUpdate["phone"] = phone;

                                        service.Update(eContactUpdate);

                                    }

                                }

                            }

                        }

                    }                    

                }

            }

            catch (Exception ex)

            {

                throw new InvalidPluginExecutionException(ex.Message);

            }

        }

    }

}

Regards,

Arun S Keerthi