Иногда возникает необходимость выполнить объединение совпадающих записей в одну. Это можно сделать выполнив слияние сущностей, с дальнейшим обновлением ссылок слитой сущности на основную сущность.

Предположим, что у нас есть сущность «Физическое лицо» или «Клиент» или «Контакт» (contact), с дополнительным внешним идентификатором (new_id) и связанной сущностью «Документ клиента» (new_client_document). Нам необходимо создать плагин, который будет при создании новой записи Документа клиента искать клиентов с совпадающими данными документа и пустым дополнительным идентификатором, и объединять их в одну запись клиента.

Пример

Клиент №1. Иванов Иван, Документ 1234 123456, идентификатор отсутствует.

Клиент №2. Петров Петр, Документ 1234 123456, идентификатор отсутствует.

Создаем нового клиента:

Клиент №3. Сидоров Сидор, Документ 1234 123456, идентификатор 123.

В результате в системе должна остаться одна активная запись Клиента №3, на которую ссылаются все связанные записи от Клиента №1 и Клиента №2.

Код

/// <summary> 
/// Плагин для автоматического поиска "Физических лиц" с совпадающими данными и их слияния. 
/// </summary> 
/// <remarks> 
/// Данный плагин регистрируется на сообщение Create, сущности "Документ клиента" (new_client_document),  
/// состояние post-operation в асинхронном режиме. 
/// </remarks>
public class Plugin : IPlugin
{
       public void Execute(IServiceProvider serviceProvider)
       {
             // Получить контекст выполнения и сервис от поставщика услуг.
             IPluginExecutionContext context = (IPluginExecutionContext)serviceProvider.GetService(typeof(IPluginExecutionContext));
             var serviceFactory = (IOrganizationServiceFactory)serviceProvider.GetService(typeof(IOrganizationServiceFactory));
             var service = serviceFactory.CreateOrganizationService(context.UserId);

             // Коллекция InputParameters содержит все данные, переданные в запросе.
             if (context.InputParameters.Contains("Target") && context.InputParameters["Target"] is Entity)
             {
                    // Получить целевой объект из входных параметров.
                    var clientDocument = (Entity)context.InputParameters["Target"];

                    // Ищем контакты с совпадающими данными документа.
                    var contacts = GetContacts(service, clientDocument);
                    if (contacts.Length == 0)
                    {
                           return;
                    }

                    // Связанные со сливаемым клиентом записи.
                    var entityNames = GetOneToManyRelationshipEntityAttributePair(service);

                    // Сливаем совпадающие контакты и обновляем ссылки.
                    foreach (var contact in contacts)
                    {
                           var client = clientDocument.GetAttributeValue<EntityReference>("new_clientid");
                           MergeContact(service, client, contact);
                           foreach (var entity in entityNames)
                           {
                                  UpdateLookup(service, entity.Item1, entity.Item2, contact.Id, client.Id);
                           }
                    }
             }
       }

       /// <summary>
       /// Выполняет получение массива "Физических лиц", удовлетворяющих условиям.
       /// </summary>
       /// <remarks>
       /// Совпадает серия и номер "Документа клиента" "Физического лица" с обрабатываемым "Документом клиента".
       /// Отсутствует идентификатор у "Физического лица.
       /// </remarks>
       /// <param name="service">Провайдер предоставляющий доступ к данным и метаданным организации.</param>
       /// <param name="clientDocument">Документ клиента.</param>
       /// <returns>Массив "Физических лиц".</returns>
       private EntityCollection GetContacts(IOrganizationService service, Entity clientDocument)
       {
             var series = clientDocument.GetAttributeValue<string>("new_series");
             var number = clientDocument.GetAttributeValue<string>("new_number");

             var query = new QueryExpression()
             {
                    EntityName = "contact",
                    ColumnSet = new ColumnSet(false),
                    Distinct = true,
                    LinkEntities =
                    {
                           new LinkEntity()
                           {
                                  LinkFromEntityName = "contact",
                                  LinkFromAttributeName = "contactid",
                                  LinkToEntityName = "new_client_document",
                                  LinkToAttributeName = "new_clientid",
                                  Columns = new ColumnSet(false),
                                  LinkCriteria = new FilterExpression
                                  {
                                        FilterOperator = LogicalOperator.And,
                                        Conditions =
                                        {
                                               new ConditionExpression("new_series", ConditionOperator.Equal, series),
                                               new ConditionExpression("new_number", ConditionOperator.Equal, number)
                                        }
                                  }
                           },
                    },
                    Criteria =
                    {
                           Conditions =
                           {
                                  new ConditionExpression("new_id", ConditionOperator.Null)
                           }
                    }
             };

             var contacts = service.RetrieveMultiple(query);
             return contacts;
       }

       /// <summary>
       /// Получить список имен зависимых сущностей и атрибутов.
       /// </summary>
       /// <param name="service">Провайдер предоставляющий доступ к данным и метаданным организации.</param>
       /// <returns>Список пар "Имя сущности" - "Атрибут сущности".</returns>
       private List<(string, string)> GetOneToManyRelationshipEntityAttributePair(IOrganizationService service)
       {
             // Не все сущности поддерживают возможность выполнения поисковых запросов.
             // Обычно это внутренние служебные сущности CRM.
             // Поэтому мы пропускаем эти сущности.
             var excludeEntitys = new string[] { "postrole", "postregarding", "mailboxtrackingfolder", "customeraddress" };

             var contactMetadata = RetrieveEntityMetadata(service, "contact");

             var result = contactMetadata.OneToManyRelationships
                    .Select(c => new ValueTuple<string, string>
                    {
                           Item1 = c.ReferencingEntity,
                           Item2 = c.ReferencingAttribute
                    })
                    .Where(c => !excludeEntitys.Contains(c.Item1)).ToList();
             return result;
       }

       /// <summary>
       /// Получает метаданные заданной сущности.
       /// </summary>
       /// <param name="service">Провайдер предоставляющий доступ к данным и метаданным организации.</param>
       /// <param name="logicalName">Логическое имя сущности.</param>
       /// <returns>Метаданные сущности.</returns>
       public static EntityMetadata RetrieveEntityMetadata(IOrganizationService service, string logicalName)
       {
             var request = new RetrieveEntityRequest
             {
                    LogicalName = logicalName,
                    EntityFilters = EntityFilters.All,
                    RetrieveAsIfPublished = false
             };
             var result = (RetrieveEntityResponse)service.Execute(request);
             return result.EntityMetadata;
       }
}

Подробнее про регистрацию плагинов можно прочитать в статье Создание Plug-in для Microsoft Dynamic 365

 
×
%d такие блоггеры, как: