IWorkflowContext context = executionContext.GetExtension<IWorkflowContext>();
IOrganizationServiceFactory serviceFactory = executionContext.GetExtension<IOrganizationServiceFactory>();
IOrganizationService service = serviceFactory.CreateOrganizationService(context.UserId);
//Condition for WorkflowName
ColumnSet cols = new ColumnSet();
ConditionExpression condworkflowname = new ConditionExpression();
condworkflowname.AttributeName = "name";
condworkflowname.Operator = ConditionOperator.Equal;
condworkflowname.Values.Add("Update Influencer Status based on Start&End Date in Awards");
//Condition for Statuscode
ConditionExpression condworkflowstatuscode = new ConditionExpression();
condworkflowstatuscode.AttributeName = "statuscode";
condworkflowstatuscode.Operator = ConditionOperator.Equal;
condworkflowstatuscode.Values.Add(10);
ConditionExpression condregobjectid = new ConditionExpression();
condregobjectid.AttributeName = "regardingobjectid";
condregobjectid.Operator = ConditionOperator.Equal;
condregobjectid.Values.Add(context.PrimaryEntityId);
//Create the FilterExpression
FilterExpression filter = new FilterExpression();
//Set the properties
filter.FilterOperator = LogicalOperator.And;
filter.Conditions.Add(condworkflowname);
filter.Conditions.Add(condworkflowstatuscode);
filter.Conditions.Add(condregobjectid);
//Create the QueryExpression Object
QueryExpression query = new QueryExpression();
query.EntityName = "asyncoperation";
query.ColumnSet = cols;
query.Criteria = filter;
//Retrieve all the instance of waiting Workflow
EntityCollection asynOp = service.RetrieveMultiple(query);
//Check Response contains Entity
if (asynOp.Entities.Count > 0)
{
foreach (Entity _entity in asynOp.Entities)
{
//Retrive the response from entity
AsyncOperation async = (AsyncOperation)_entity;
async.StateCode = AsyncOperationState.Completed;
service.Update(async);
}
}
Madhu M.
