-
Notifications
You must be signed in to change notification settings - Fork 6
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
ADD Entity Tools > GUID to Theme ADD FetchXML Tools > Execute Action ADD FetchXML Tools > Execute Workflow ADD FetchXML Tools > Find Task
- Loading branch information
Showing
12 changed files
with
401 additions
and
113 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,27 @@ | ||
| using System.Activities; | ||
| using Microsoft.Xrm.Sdk; | ||
| using Microsoft.Xrm.Sdk.Workflow; | ||
| using PZone.Xrm.Workflow; | ||
|
|
||
|
|
||
| namespace PZone.EntityTools.Workflow | ||
| { | ||
| /// <summary> | ||
| /// Действие возвращает сущность "Обращение" (incident) для указанного GUID. | ||
| /// </summary> | ||
| public class GuidToIncident : GuidToEntity | ||
| { | ||
| /// <summary> | ||
| /// Обращение. | ||
| /// </summary> | ||
| [Output("Incident")] | ||
| [ReferenceTarget("incident")] | ||
| public OutArgument<EntityReference> Incident { get; set; } | ||
|
|
||
|
|
||
| protected override void Execute(Context context) | ||
| { | ||
| SetValue(context, Incident, "incident"); | ||
| } | ||
| } | ||
| } |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,27 @@ | ||
| using System.Activities; | ||
| using Microsoft.Xrm.Sdk; | ||
| using Microsoft.Xrm.Sdk.Workflow; | ||
| using PZone.Xrm.Workflow; | ||
|
|
||
|
|
||
| namespace PZone.EntityTools.Workflow | ||
| { | ||
| /// <summary> | ||
| /// Действие возвращает сущность "Тема" (theme) для указанного GUID. | ||
| /// </summary> | ||
| public class GuidToTheme : GuidToEntity | ||
| { | ||
| /// <summary> | ||
| /// Тема. | ||
| /// </summary> | ||
| [Output("Theme")] | ||
| [ReferenceTarget("theme")] | ||
| public OutArgument<EntityReference> Theme { get; set; } | ||
|
|
||
|
|
||
| protected override void Execute(Context context) | ||
| { | ||
| SetValue(context, Theme, "theme"); | ||
| } | ||
| } | ||
| } |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
176 changes: 176 additions & 0 deletions
176
Source/Tools/FetchXML/FetchXML/Workflow/ExecuteAction.cs
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,176 @@ | ||
| using System; | ||
| using System.Activities; | ||
| using System.Collections.Generic; | ||
| using System.Linq; | ||
| using System.Text.RegularExpressions; | ||
| using System.Xml.Linq; | ||
| using Microsoft.Crm.Sdk.Messages; | ||
| using Microsoft.Xrm.Sdk; | ||
| using Microsoft.Xrm.Sdk.Messages; | ||
| using Microsoft.Xrm.Sdk.Query; | ||
| using Microsoft.Xrm.Sdk.Workflow; | ||
| using Newtonsoft.Json.Linq; | ||
| using PZone.Xrm.Workflow; | ||
|
|
||
|
|
||
| namespace PZone.FetchXmlTools.Workflow | ||
| { | ||
| /// <summary> | ||
| /// Запуск Action по результатам выполнения FetchXML. | ||
| /// </summary> | ||
| public class ExecuteAction : WorkflowBase | ||
| { | ||
| private string _actionName = null; | ||
| private Dictionary<string, Type> _actionProperties = null; | ||
|
|
||
| private Dictionary<string, Type> _crmTypes = new Dictionary<string, Type> { | ||
| { "EntityCollection", typeof(EntityCollection) }, | ||
| { "EntityReference", typeof(EntityReference)}, | ||
| { "OptionSetValue", typeof(OptionSetValue)}, | ||
| { "String", typeof(string)}, | ||
| { "DateTime", typeof(DateTime)}, | ||
| { "Money", typeof(Money)}, | ||
| { "Decimal", typeof(decimal)}, | ||
| { "Boolean", typeof(bool)}, | ||
| { "Double", typeof(double)}, | ||
| { "Entity", typeof(Entity)}, | ||
| { "Int32", typeof(int)} | ||
| }; | ||
|
|
||
|
|
||
| /// <summary> | ||
| /// Запрос FetchXML, получающий список записей. | ||
| /// </summary> | ||
| [RequiredArgument] | ||
| [Input("FetchXML Query")] | ||
| public InArgument<string> FetchXml { get; set; } | ||
|
|
||
|
|
||
| /// <summary> | ||
| /// Workflow | ||
| /// </summary> | ||
| [RequiredArgument] | ||
| [Input("Action")] | ||
| [ReferenceTarget("workflow")] | ||
| public InArgument<EntityReference> Action { get; set; } | ||
|
|
||
|
|
||
| /// <summary> | ||
| /// JSON с параметрами. | ||
| /// </summary> | ||
| [Input("JSON with Parameters")] | ||
| public InArgument<string> Parameters { get; set; } | ||
|
|
||
|
|
||
| /// <inheritdoc /> | ||
| protected override void Execute(Context context) | ||
| { | ||
| var fetchXmlStr = FetchXml.Get(context); | ||
| var actionRef = Action.Get(context); | ||
| var parametersJsonStr = Parameters.Get(context); | ||
|
|
||
| // Получение имени и параметров действия. | ||
| if (string.IsNullOrEmpty(_actionName)) | ||
| RetrieveActionProperties(context.SystemService, actionRef, out _actionName, out _actionProperties); | ||
|
|
||
| // Формирвоание параметров действия. | ||
| var parameters = new Dictionary<string, object>(); | ||
| foreach (var property in JObject.Parse(parametersJsonStr).Properties()) | ||
| parameters.Add(property.Name, property.ToObject(_actionProperties[property.Name])); | ||
|
|
||
| var moreRecords = false; | ||
| int page = 1; | ||
| string query = fetchXmlStr; | ||
| do | ||
| { | ||
| // Получение списка сущностей. | ||
| var collection = context.SystemService.RetrieveMultiple(new FetchExpression(query)); | ||
| if (collection.Entities.Count < 1) | ||
| break; | ||
|
|
||
| // Формирование запросов для вызова действий. | ||
| var requests = new ExecuteMultipleRequest() | ||
| { | ||
| Settings = new ExecuteMultipleSettings() | ||
| { | ||
| ContinueOnError = false, | ||
| ReturnResponses = true | ||
| }, | ||
| Requests = new OrganizationRequestCollection() { } | ||
| }; | ||
| foreach (var entity in collection.Entities) | ||
| { | ||
| var request = new OrganizationRequest(_actionName) | ||
| { | ||
| ["Target"] = entity.ToEntityReference() | ||
| }; | ||
| request.Parameters.AddRange(parameters); | ||
| requests.Requests.Add(request); | ||
| } | ||
|
|
||
| // Выполнение действий. | ||
| var response = (ExecuteMultipleResponse)context.Service.Execute(requests); | ||
| if (response.IsFaulted) | ||
| { | ||
| var faultResponse = response.Responses.FirstOrDefault(r => r.Fault != null); | ||
| var faultWorkflowRequest = (ExecuteWorkflowRequest)requests.Requests[faultResponse.RequestIndex]; | ||
| SetError(context, $"A record of the \"{collection.EntityName}\" type with the ID \"{faultWorkflowRequest.EntityId}\" returned an error during execution of the action {(string.IsNullOrEmpty(actionRef.Name) ? "" : $"\"{actionRef.Name}\" ")}with the ID \"{actionRef.Id}\"."); | ||
| return; | ||
| } | ||
|
|
||
| // Организация чтения следующей страницы. | ||
| moreRecords = collection.MoreRecords; | ||
| if (moreRecords) | ||
| { | ||
| page++; | ||
| var fetchXml = XDocument.Parse(fetchXmlStr); | ||
| fetchXml.Root.SetAttributeValue("paging-cookie", System.Security.SecurityElement.Escape(collection.PagingCookie)); | ||
| fetchXml.Root.SetAttributeValue("page", page); | ||
| query = fetchXml.ToString(); | ||
| } | ||
| } while (moreRecords); | ||
| } | ||
|
|
||
|
|
||
| private void RetrieveActionProperties(IOrganizationService service, EntityReference actionRef, out string actionLogicalName, out Dictionary<string, Type> properties) | ||
| { | ||
| // Получаем название действия. | ||
| var action = service.Retrieve(actionRef.LogicalName, actionRef.Id, new ColumnSet("solutionid", "uniquename", "xaml")); | ||
| var solutionId = action.GetAttributeValue<Guid>("solutionid"); | ||
| var query = $@" | ||
| <fetch top='1' no-lock='true'> | ||
| <entity name='solution'> | ||
| <filter> | ||
| <condition attribute='solutionid' operator='eq' value='{solutionId}'/> | ||
| </filter> | ||
| <link-entity name='publisher' from='publisherid' to='publisherid' alias='publisher'> | ||
| <attribute name='customizationprefix' /> | ||
| </link-entity> | ||
| </entity> | ||
| </fetch>"; | ||
| var solution = service.RetrieveMultiple(new FetchExpression(query)).Entities.FirstOrDefault(); | ||
| var prefix = solution.GetAttributeValue<AliasedValue>("publisher.customizationprefix").Value.ToString(); | ||
| actionLogicalName = prefix + "_" + action.GetAttributeValue<string>("uniquename"); | ||
|
|
||
| // Получаем список входных параметров действия. | ||
| var xaml = action.GetAttributeValue<string>("xaml"); | ||
| var xDoc = XDocument.Parse(xaml); | ||
| var xProperties = xDoc.Root.Elements() | ||
| .FirstOrDefault(e => e.Name.LocalName == "Members").Elements() | ||
| .Where(e => e.Name.LocalName == "Property"); | ||
| properties = new Dictionary<string, Type>(); | ||
| foreach (var xProperty in xProperties) | ||
| { | ||
| var name = xProperty.Attribute("Name").Value; | ||
| var typeStr = xProperty.Attribute("Type").Value; | ||
| if (name == "InputEntities" || name == "CreatedEntities" || !typeStr.StartsWith("InArgument")) | ||
| continue; | ||
| typeStr = Regex.Match(typeStr, "InArgument[(](?<type>.+)[)]").Groups["type"].Value; | ||
| var typeParts = typeStr.Split(new char[] { ':' }, 2); | ||
| typeStr = typeParts.Length == 1 ? typeStr : typeParts[1]; | ||
| var type = _crmTypes[typeStr]; | ||
| properties.Add(name, type); | ||
| } | ||
| } | ||
| } | ||
| } |
Oops, something went wrong.