Dynamics Community Forum Thread Details

First off, let me start by saying I am new to writing workflows and in C#.
I'm currently trying to send emails from a ribbon button. I'm able to add the button and command, and the workflow is triggered. However,
no matter what I do, it won't send an email... Not sure what I'm doing wrong here.
using System;
using System.Collections.Generic;
using System.Text;
using System.Linq;
using System.Xml.Linq;
using System.ServiceModel;
using System.Activities;
using Microsoft.Xrm.Sdk.Client;
using Microsoft.Crm.Sdk.Messages;
using Microsoft.Xrm.Sdk;
using Microsoft.Xrm.Sdk.Query;
using Microsoft.Xrm.Sdk.Workflow;

namespace SendNotificationsForWeeklyReport
{
    using System;
    using System.Activities;
    using System.ServiceModel;
    using Microsoft.Xrm.Sdk;
    using Microsoft.Xrm.Sdk.Workflow;

    public sealed class SendNotificationsForWeeklyReport : CodeActivity
    {
        [Input("Email")]
        [ReferenceTarget("email")]
        public InArgument<EntityReference> Email { get; set; }
        [Input("Account")]
        [ReferenceTarget("account")]
        public InArgument<EntityReference> Account { get; set; }
        protected override void Execute(CodeActivityContext executionContext)
        {
            ITracingService tracingService = executionContext.GetExtension<ITracingService>();
            if (tracingService == null)
            {
                throw new InvalidPluginExecutionException("Failed to retrieve tracing service.");
            }
            tracingService.Trace("Entered SendNotificationsForWeeklyReport.Execute(), Activity Instance Id: {0}, Workflow Instance Id: {1}",
                executionContext.ActivityInstanceId,
                executionContext.WorkflowInstanceId);
            IWorkflowContext context = executionContext.GetExtension<IWorkflowContext>();
            if (context == null) throw new InvalidPluginExecutionException("Failed to retrieve workflow context.");


            tracingService.Trace("SendNotificationsForWeeklyReport.Execute(), Correlation Id: {0}, Initiating User: {1}",
                context.CorrelationId,
                context.InitiatingUserId);

            IOrganizationServiceFactory serviceFactory = executionContext.GetExtension<IOrganizationServiceFactory>();
            IOrganizationService service = serviceFactory.CreateOrganizationService(context.UserId);
            try
            {
                if (context.InputParameters.Contains("Target") && context.InputParameters["Target"] is Entity)
                {
                    Entity entity = (Entity)context.InputParameters["Target"];
                    tracingService.Trace("Target Entity is {0} id {1}", entity.LogicalName, entity.Id);
                    Entity email = new Entity("email");
                    //Entity email = service.Retrieve("email", Email.Get(executionContext).Id, new ColumnSet(true));
                    Entity WREntity = service.Retrieve(entity.LogicalName, entity.Id, new ColumnSet(new string[] { "createdby", "am_dwterritory"}));
                    List<Entity> fromList = new List<Entity>();
                    List<Entity> toList = new List<Entity>();
                    if (WREntity.Attributes.Contains("createdby"))
                    {
                        Entity createdby = (Entity) WREntity.Attributes["createdby"];
                        tracingService.Trace("createdby: " + createdby);
                        Entity fromP = new Entity("activityparty");
                        fromP["partyid"] = new EntityReference("systemuser", createdby.Id);
                        fromList.Add(fromP);
                        email.Attributes["from"] = fromList.ToArray();
                        service.Update(email);
                    }

                    QueryExpression teamQuery = new QueryExpression()
                    {
                        EntityName = "weeklyreport_team",
                        ColumnSet = new ColumnSet(true),
                        LinkEntities = 
                        {
                            new LinkEntity
                            {
                                LinkFromEntityName = "weeklyreport",
                                LinkFromAttributeName = "weeklyreportid",
                                LinkToEntityName = "team",
                                LinkToAttributeName = "teamid",
                            }
                        }
                    };

                    teamQuery.Criteria = new FilterExpression();
                    teamQuery.Criteria.AddCondition("weeklyreportid", ConditionOperator.Equal, entity.Id);


                    EntityCollection teams = service.RetrieveMultiple(teamQuery);
                    // getting people in product line team(s)
                    for (int i = 0; i < teams.Entities.Count; i++)
                    {
                        Entity team = teams.Entities[i];
                        tracingService.Trace("Query Expression Retrieved: {0}", team);
                        QueryExpression qe = new QueryExpression();
                        qe.EntityName = "teammembership";
                        qe.ColumnSet = new ColumnSet();
                        qe.ColumnSet.Columns.Add("systemuser");
                        qe.LinkEntities.Add(new LinkEntity("team", "systemuser", "teamid", "accountid", JoinOperator.Inner));
                        qe.Criteria = new FilterExpression();
                        qe.Criteria.AddCondition("teamid", ConditionOperator.Equal, team.Id);

                        EntityCollection ec = service.RetrieveMultiple(qe);
                        foreach (Entity user in ec.Entities)
                        {
                            if (user.Attributes.Contains("internalemailaddress"))
                            {
                                tracingService.Trace("Get Email " + user.Attributes["internalemailaddress"].ToString());
                                Entity toParty = new Entity("activityparty");
                                toParty["partyid"] = new EntityReference("systemuser", user.Id);
                                toList.Add(toParty);
                            }
                        }
                    }

                    // retrieving additional recipients
                    QueryExpression userQuery = new QueryExpression()
                    {
                        EntityName = "issi_issi_weeklyreport_systemuser",
                        ColumnSet = new ColumnSet(true),
                        LinkEntities = 
                        {
                            new LinkEntity
                            {
                                LinkFromEntityName = "weeklyreport",
                                LinkFromAttributeName = "weeklyreportid",
                                LinkToEntityName = "systemuser",
                                LinkToAttributeName = "systemuserid",
                            }
                        }
                    };
                    userQuery.Criteria = new FilterExpression();
                    userQuery.Criteria.AddCondition("weeklyreportid", ConditionOperator.Equal, entity.Id);

                    EntityCollection users = service.RetrieveMultiple(userQuery);
                    foreach (Entity user in users.Entities)
                    {
                        Entity toParty = new Entity("activityparty");
                        toParty["partyid"] = new EntityReference("systemuser", user.Id);
                        toList.Add(toParty);
                    }

                    email.Attributes["to"] = toList.ToArray();
                    service.Update(email);
                    Guid emailid = service.Create(email);
                    tracingService.Trace("Sending Mail");
                    SendEmailRequest SendEmail = new SendEmailRequest();
                    SendEmail.EmailId = emailid;
                    SendEmail.TrackingToken = "";
                    SendEmail.IssueSend = true;
                    tracingService.Trace("Sending Mail");
                    SendEmailResponse res = (SendEmailResponse)service.Execute(SendEmail);
                }
            }
            catch (FaultException<OrganizationServiceFault> e)
            {
                tracingService.Trace("Exception: {0}", e.ToString());

                // Handle the exception.
                throw;
            }

            tracingService.Trace("Exiting SendNotificationsForWeeklyReport.Execute(), Correlation Id: {0}", context.CorrelationId);
        }
    }
}