TRACKING in VB.NET

Generating ECC200 in VB.NET TRACKING

public void AddNewLead(Lead l) { this.lstLeads.Dispatcher.BeginInvoke (new Action(() => this.lstLeads.Items.Add(l))); } private void lstLeads_SelectionChanged(object sender, RoutedEventArgs e) { if (lstLeads.SelectedIndex >= 0) { Lead l = (Lead)lstLeads.Items[lstLeads.SelectedIndex]; lblSelectedNotes.Content = l.Comments; lblSelectedNotes.Visibility = Visibility.Visible; if (l.Status == "Open") { lblAgent.Visibility = Visibility.Visible; txtAgent.Visibility = Visibility.Visible; btnAssign.Visibility = Visibility.Visible; } else { lblAgent.Visibility = Visibility.Hidden; txtAgent.Visibility = Visibility.Hidden; btnAssign.Visibility = Visibility.Hidden; } } else { lblSelectedNotes.Content = ""; lblSelectedNotes.Visibility = Visibility.Hidden; lblAgent.Visibility = Visibility.Hidden; txtAgent.Visibility = Visibility.Hidden; btnAssign.Visibility = Visibility.Hidden; } } private void btnAssign_Click(object sender, RoutedEventArgs e) { if (lstLeads.SelectedIndex >= 0) { Lead l = (Lead)lstLeads.Items[lstLeads.SelectedIndex]; Guid id = l.WorkflowID; LeadDataDataContext dc = new LeadDataDataContext(_connectionString); dc.Refresh(RefreshMode.OverwriteCurrentValues, dc.Leads); l = dc.Leads.SingleOrDefault<Lead>(x => x.WorkflowID == id); if (l != null) { l.AssignedTo = txtAgent.Text; l.Status = "Assigned"; dc.SubmitChanges();

// Clear the input txtAgent.Text = ""; } // Update the grid lstLeads.Items[lstLeads.SelectedIndex] = l; lstLeads.Items.Refresh(); WorkflowApplication i = new WorkflowApplication(new EnterLead()); SetupInstance(i); i.Load(id); try { i.ResumeBookmark("GetAssignment", l); } catch (Exception e2) { AddEvent(e2.Message); } } } private void LoadExistingLeads() { LeadDataDataContext dc = new LeadDataDataContext(_connectionString); dc.Refresh(RefreshMode.OverwriteCurrentValues, dc.Leads); IEnumerable<Lead> q = dc.Leads .Where<Lead>(x => x.Status == "Open" || x.Status == "Assigned"); foreach (Lead l in q) { AddNewLead(l); } } private void SetupInstance(WorkflowApplication i) { // Setup the instance store i.InstanceStore = _instanceStore; // Setup the PersistableIdle event handler i.PersistableIdle = (waiea) => PersistableIdleAction.Unload; // Setup the connection string i.Extensions.Add(_dbExtension); // Display the accumulated comments i.Completed = (wacea) => {

// Get the CommentExtension IEnumerable<CommentExtension> q = wacea.GetInstanceExtensions<CommentExtension>(); // Add the comments to the event log if (q.Count() > 0) { string comments = "Comments: \r\n" + q.First<CommentExtension>().Comments; this.lstEvents.Dispatcher.BeginInvoke (new Action(() => this.lstEvents.Items.Add(comments))); } this.lstEvents.Dispatcher.BeginInvoke (new Action(() => this.lstEvents.Items.Add ("\r\nThe workflow has completed"))); }; // Set up tracking i.Extensions.Add(_tracking); i.Extensions.Add(_etwTracking); i.Extensions.Add(_sqlTracking); } private void CreateTrackingParticipant() { _tracking = new ListBoxTrackingParticipant(this.lstEvents) { TrackingProfile = new TrackingProfile() { Name = "ListBoxTrackingProfile", Queries = { // For instance data, only track the started and // completed events new WorkflowInstanceQuery() { States = { WorkflowInstanceStates.Started, WorkflowInstanceStates.Completed }, }, // For bookmark data, only track the GetAssignment event new BookmarkResumptionQuery() { Name = "GetAssignment" }, // For activity data, track all states of the InvokeMethod new ActivityStateQuery() {

ActivityName = "InvokeMethod", States = { "*" }, }, // For User data, track all events new CustomTrackingQuery() { Name = "*", ActivityName = "*" } } } }; } private void CreateETWTrackingParticipant() { _etwTracking = new EtwTrackingParticipant() { TrackingProfile = new TrackingProfile() { Name = "EtwTrackingProfile", Queries = { new CustomTrackingQuery() { Name = "*", ActivityName = "*" } } } }; } private void CreateSqlTrackingParticipant() { _sqlTracking = new SqlTrackingParticipant(_connectionString) { TrackingProfile = new TrackingProfile() { Name = "SqlTrackingProfile", Queries = { new WorkflowInstanceQuery() { States = { "*" }, }, new BookmarkResumptionQuery() {

Name = "*" }, new ActivityStateQuery() { // Subscribe for track records from all activities // for all states ActivityName = "*", States = { "*" }, }, // For User data, track all events new CustomTrackingQuery() { Name = "*", ActivityName = "*" } } } }; } } }

In this chapter, you will learn how to enlist your workflow activities on the same database transaction to ensure that updates are performed in a consistent manner.

You will reuse the project that you developed in 13. Start by creating a blank solution as shown in Figure 14-1. For the solution name, enter 14.

From Windows Explorer, copy the LeadGenerator folder from the 13 folder to the 14 folder. Back in Visual Studio, from the Solution Explorer, right-click the 14 solution and choose Add Existing Project. Select the LeadGenerator project that you just copied to the 14 folder. Create a 14 database and run the following scripts to initialize the database schema: SqlWorkflowInstanceStoreSchema.sql SqlWorkflowInstanceStoreLogic.sql Lead.sql Tracking.sql

Open the app.config file and change the connectionString attribute to use the 14 database. Right-click the LeadGenerator project and choose Add Reference. In the .NET tab, add the System.Transaction assembly.