Share
Report
2,665Hi All,
I am using below code to associate subgrid in case which is user subgrid taking value from Asset or Division & in both Asset & Division entity user subgrid is there.From there getting User records & associating in case.But while updating asset & division chnge on case its not disassociating & getting error cannot insert duplicate key.
What Could be the issue ?
using System;
using Microsoft.Xrm.Sdk;
using Microsoft.Xrm.Sdk.Client;
using System.Collections.Generic;
using System.Text;
using Microsoft.Xrm.Sdk.Query;
using Microsoft.Xrm.Sdk.Messages;
namespace MIC_CRM.GroupCompliance.Plugins.Case.Conflict_of_Interest
{
public class UpdateGEComplianceCounsel : IPlugin
{
IOrganizationService organizationService;
Guid divisionId = Guid.Empty, assetId = Guid.Empty;
public void Execute(IServiceProvider serviceProvider)
{
try
{
IPluginExecutionContext executionContext = (IPluginExecutionContext)serviceProvider.GetService(typeof(IPluginExecutionContext));
ITracingService tracingService = (ITracingService)serviceProvider.GetService(typeof(ITracingService));
IOrganizationServiceFactory serviceFactory = (IOrganizationServiceFactory)serviceProvider.GetService(typeof(IOrganizationServiceFactory));
organizationService = serviceFactory.CreateOrganizationService(executionContext.UserId);
bool IsGridData = false;
if (executionContext.MessageName.ToUpper() == "UPDATE")
{
if (executionContext.InputParameters.Contains("Target") && (executionContext.InputParameters["Target"] is Entity))
{
Entity incident = (Entity)executionContext.InputParameters["Target"];
if (incident == null || incident.LogicalName != "incident")
{
tracingService.Trace("Target is not as expected");
return;
}
ColumnSet attributes = new ColumnSet(new string[] { "mdc_relateddivision", "mdc_relatedasset" });
Entity entityCase = organizationService.Retrieve(incident.LogicalName, incident.Id, attributes);
tracingService.Trace("Retrieved Incident");
//EntityReference division = entityCase.Attributes.Contains("mdc_relateddivision") ? entityCase?.GetAttributeValue<EntityReference>("mdc_relateddivision") : null;
var division = entityCase.Contains("mdc_relateddivision") ? ((EntityReference)entityCase["mdc_relateddivision"]).Id : Guid.Empty;
tracingService.Trace("Division got....");
//EntityReference asset = entityCase.Attributes.Contains("mdc_relatedasset") ? entityCase?.GetAttributeValue<EntityReference>("mdc_relatedasset") : null;
var asset = entityCase.Contains("mdc_relatedasset") ? ((EntityReference)entityCase["mdc_relatedasset"]).Id : Guid.Empty;
tracingService.Trace("Asset value got....");
if (asset != Guid.Empty)
{
//assetId = (entityCase?.GetAttributeValue<EntityReference>("mdc_relatedasset")).Id;
DisassociateComplianceCounselGrid(incident, tracingService, ref IsGridData);
if (IsGridData) //Check Compliance Counsel grid has no records then Associate Users
{
tracingService.Trace($"Grid has no records");
QueryExpression query = new QueryExpression();
query.EntityName = "systemuser";
query.ColumnSet = new ColumnSet(true);
Relationship relationship = new Relationship();
query.Criteria = new FilterExpression();
relationship.SchemaName = "mdc_mdc_asset_systemuser";
tracingService.Trace($"Relationship exists");
RelationshipQueryCollection relatedEntity = new RelationshipQueryCollection();
relatedEntity.Add(relationship, query);
RetrieveRequest request = new RetrieveRequest();
request.RelatedEntitiesQuery = relatedEntity;
request.ColumnSet = new ColumnSet("mdc_assetid");
if (asset != null)
request.Target = new EntityReference { Id = asset, LogicalName = "mdc_asset" };
RetrieveResponse response = (RetrieveResponse)organizationService.Execute(request);
tracingService.Trace($"Got Response");
List<Entity> relatedEntities = new List<Entity>();
if (((((RelatedEntityCollection)(response.Entity.RelatedEntities)))).Contains(new Relationship("mdc_mdc_asset_systemuser")) &&
((((RelatedEntityCollection)(response.Entity.RelatedEntities))))[new Relationship("mdc_mdc_asset_systemuser")].Entities.Count > 0)
{
foreach (var item in ((((RelatedEntityCollection)(response.Entity.RelatedEntities))))[new Relationship("mdc_mdc_asset_systemuser")].Entities)
{
relatedEntities.Add(item);
AssociateRequest request1 = new AssociateRequest();
if (incident.Id != null)
request1.Target = new EntityReference(incident.LogicalName, incident.Id);
request1.RelatedEntities = new EntityReferenceCollection();
if (item.Id != null)
request1.RelatedEntities.Add(new EntityReference("systemuser", item.Id));
request1.Relationship = new Relationship("mdc_incident_systemusernew");
organizationService.Execute(request1);
tracingService.Trace($"Associated Users for Asset successfully");
}
}
}
}
else if (division != Guid.Empty)
{
//divisionId = (entityCase?.GetAttributeValue<EntityReference>("mdc_relateddivision")).Id;
DisassociateComplianceCounselGrid(incident, tracingService, ref IsGridData);
if (IsGridData) //Check Compliance Counsel grid has no records then Associate Users
{
tracingService.Trace($"Grid has no records");
QueryExpression query = new QueryExpression();
query.EntityName = "systemuser";
query.ColumnSet = new ColumnSet(true);
Relationship relationship = new Relationship();
query.Criteria = new FilterExpression();
relationship.SchemaName = "mdc_mdc_division_systemuser";
tracingService.Trace($"Relationship exists");
RelationshipQueryCollection relatedEntity = new RelationshipQueryCollection();
relatedEntity.Add(relationship, query);
RetrieveRequest request = new RetrieveRequest();
request.RelatedEntitiesQuery = relatedEntity;
request.ColumnSet = new ColumnSet("mdc_divisionid");
if (division != null)
request.Target = new EntityReference { Id = division, LogicalName = "mdc_division" };
RetrieveResponse response = (RetrieveResponse)organizationService.Execute(request);
tracingService.Trace($"Got Response");
List<Entity> relatedEntities = new List<Entity>();
if (((((RelatedEntityCollection)(response.Entity.RelatedEntities)))).Contains(new Relationship("mdc_mdc_division_systemuser")) &&
((((RelatedEntityCollection)(response.Entity.RelatedEntities))))[new Relationship("mdc_mdc_division_systemuser")].Entities.Count > 0)
{
foreach (var item in ((((RelatedEntityCollection)(response.Entity.RelatedEntities))))[new Relationship("mdc_mdc_division_systemuser")].Entities)
{
relatedEntities.Add(item);
AssociateRequest request1 = new AssociateRequest();
if (incident.Id != null)
request1.Target = new EntityReference(incident.LogicalName, incident.Id);
request1.RelatedEntities = new EntityReferenceCollection();
if (item.Id != null)
request1.RelatedEntities.Add(new EntityReference("systemuser", item.Id));
request1.Relationship = new Relationship("mdc_incident_systemusernew");
organizationService.Execute(request1);
tracingService.Trace($"Associated Users successfully");
}
}
}
}
}
}
}
catch (Exception ex)
{
throw new InvalidPluginExecutionException("An error occurred in the Update GE Compliance counsel Plug-in: " + ex.Message, ex);
}
}
private void DisassociateComplianceCounselGrid(Entity incident, ITracingService tracingService, ref bool IsGridData)
{
try
{
//Retrieving Compliance Counsel grid records
ConditionExpression condition = new ConditionExpression();
condition.AttributeName = "mdc_compliancecounselid";
condition.Operator = ConditionOperator.Equal;
if (incident.Id != null)
condition.Values.Add(incident.Id);
tracingService.Trace("incident exists");
//Create a column set.
ColumnSet columns = new ColumnSet(true);
QueryExpression query1 = new QueryExpression();
query1.ColumnSet = columns;
query1.EntityName = "systemuser";
query1.Criteria.AddCondition(condition);
List<Entity> relatedUsers = new List<Entity>();
EntityCollection resColl = organizationService.RetrieveMultiple(query1);
tracingService.Trace($"Subgrid records found");
if (resColl?.Entities != null)
{
IsGridData = true;
tracingService.Trace($"subgrid has data");
foreach (var r in resColl.Entities)
{
relatedUsers.Add(r);
DisassociateRequest disassociateReq = new DisassociateRequest();
if (incident.Id != null)
disassociateReq.Target = new EntityReference("incident", incident.Id);
disassociateReq.RelatedEntities = new EntityReferenceCollection();
if (r.Id != null)
disassociateReq.RelatedEntities.Add(new EntityReference("systemuser", r.Id));
disassociateReq.Relationship = new Relationship("mdc_incident_systemusernew");
organizationService.Execute(disassociateReq);
tracingService.Trace($"Disaasociated Users successfully");
}
}
}
catch (Exception ex)
{
throw new InvalidPluginExecutionException("An error occurred in the DisassociateComplianceCounselGrid method: " + ex.Message, ex);
}
}
}
}
Thanks,
Jharana
All responses (
Answers (
