]]> _
_
Public Class ScriptMain
Inherits UserComponent
'''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''
Public Overrides Sub Input_ProcessInputRow(ByVal Row As InputBuffer)
Try
Dim req As New OrganizationRequest
req.RequestName = "QualifyLead"
' Setup LeadId.
req("LeadId") = SetupEntityReference_("lead", New Guid(Row.Buffer(m_liIndex).ToString()))
' Setup Status.
Dim status As New OptionSetValue()
status.Value = Convert.ToInt32(Row.Buffer(m_sIndex))
req("Status") = status
Dim value As Object
value = GetBufferValue_(Row.Buffer, m_caIndex)
If Not value Is Nothing Then
req("CreateAccount") = Convert.ToBoolean(value)
End If
value = GetBufferValue_(Row.Buffer, m_ccIndex)
If Not value Is Nothing Then
req("CreateContact") = Convert.ToBoolean(value)
End If
value = GetBufferValue_(Row.Buffer, m_coIndex)
If Not value Is Nothing Then
req("CreateOpportunity") = Convert.ToBoolean(value)
End If
value = GetBufferValue_(Row.Buffer, m_ocurrIdIndex)
If Not value Is Nothing Then
req("OpportunityCurrencyId") = SetupEntityReference_( _
"transactioncurrency", _
New Guid(value.ToString()))
End If
value = GetBufferValue_(Row.Buffer, m_ocustIdIndex)
If Not value Is Nothing Then
req("OpportunityCustomerId") = SetupEntityReference_( _
"account", _
New Guid(value.ToString()))
End If
value = GetBufferValue_(Row.Buffer, m_sciIndex)
If Not value Is Nothing Then
req("SourceCampaignId") = SetupEntityReference_( _
"campaign", _
New Guid(value.ToString()))
End If
' Execute action.
Call m_service.Execute(req)
Catch ex As SoapException
Call FireError_(ex.Detail.InnerXml)
Catch ex As Exception
Call FireError_(ex.Message)
End Try
End Sub ' Input_ProcessInputRow
'''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''
Public Overrides Sub PreExecute()
Call MyBase.PreExecute()
' Setup CRM service.
m_connection = CType( _
Me.Connections.CrmConnection.AcquireConnection(Nothing), _
IConnection)
Call m_connection.Connect()
m_service = CType(m_connection.GetService(0), OrganizationServiceClient) ' 0 - CRM Service
' Get input column indexes.
m_caIndex = GetColumnIndex_("CreateAccount")
m_ccIndex = GetColumnIndex_("CreateContact")
m_coIndex = GetColumnIndex_("CreateOpportunity")
m_liIndex = GetColumnIndex_("LeadId")
m_ocurrIdIndex = GetColumnIndex_("OpportunityCurrencyId")
m_ocustIdIndex = GetColumnIndex_("OpportunityCustomerId")
m_sciIndex = GetColumnIndex_("SourceCampaignId")
m_sIndex = GetColumnIndex_("Status")
End Sub ' PreExecute
'''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''
Public Overrides Sub PostExecute()
Call MyBase.PostExecute()
Call m_connection.Close()
m_caIndex = -1
m_ccIndex = -1
m_coIndex = -1
m_liIndex = -1
m_ocurrIdIndex = -1
m_ocustIdIndex = -1
m_sciIndex = -1
m_sIndex = -1
End Sub ' PostExecute
'''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''
Public Function Validate(ByRef errMessage As String) As Boolean
Dim result As Boolean
Try
If String.IsNullOrEmpty(Me.CrmConnection) Then
Throw New Exception("Select Dynamics CRM Connection.")
End If
Dim inputCol As IDTSInputColumn90 = Nothing
inputCol = GetInputColumn_("LeadId")
If inputCol Is Nothing Then
Throw New Exception("LeadId column is not mapped.")
End If
inputCol = GetInputColumn_("Status")
If inputCol Is Nothing Then
Throw New Exception("Status column is not mapped.")
End If
' Store connection information in the runtime connection collection, too.
' Cannot directly use RuntimeConnectionCollection in the property get/set
' because of issues with multi-threading.
Me.ComponentMetaData.RuntimeConnectionCollection("CrmConnection").ConnectionManagerID = Me.CrmConnection
result = True
Catch ex As Exception
result = False
errMessage = ex.Message
End Try
Validate = result
End Function 'Validate
'''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''
Public Overrides Sub ReinitializeMetaData()
Call MyBase.ReinitializeMetaData()
If MyBase.ComponentMetaData.InputCollection.Count = 0 Then
' At least one input must exist.
Throw New Exception("No inputs.")
End If
Dim input As IDTSInput90 = MyBase.ComponentMetaData.InputCollection(0)
' Cleanup.
input.ExternalMetadataColumnCollection.IsUsed = True
Call input.InputColumnCollection.RemoveAll()
Call input.ExternalMetadataColumnCollection.RemoveAll()
Dim column As IDTSExternalMetadataColumn90
' Setup CreateAccount column.
column = input.ExternalMetadataColumnCollection.[New]()
column.Name = "CreateAccount"
column.DataType = DataType.DT_BOOL
' Setup CreateContact column.
column = input.ExternalMetadataColumnCollection.[New]()
column.Name = "CreateContact"
column.DataType = DataType.DT_BOOL
' Setup CreateOpportunity column.
column = input.ExternalMetadataColumnCollection.[New]()
column.Name = "CreateOpportunity"
column.DataType = DataType.DT_BOOL
' Setup LeadId column.
column = input.ExternalMetadataColumnCollection.[New]()
column.Name = "LeadId"
column.DataType = DataType.DT_GUID
' Setup OpportunityCurrencyId column.
column = input.ExternalMetadataColumnCollection.[New]()
column.Name = "OpportunityCurrencyId"
column.DataType = DataType.DT_GUID
' Setup OpportunityCustomerId column.
column = input.ExternalMetadataColumnCollection.[New]()
column.Name = "OpportunityCustomerId"
column.DataType = DataType.DT_GUID
' Setup SourceCampaignId column.
column = input.ExternalMetadataColumnCollection.[New]()
column.Name = "SourceCampaignId"
column.DataType = DataType.DT_GUID
' Setup Status column.
column = input.ExternalMetadataColumnCollection.[New]()
column.Name = "Status"
column.DataType = DataType.DT_I4
End Sub ' ReinitializeMetaData
#Region "Properties"
'''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''
_
_
Public Property CrmConnection() As String
Get
CrmConnection = m_crmConnection
End Get
Set(ByVal value As String)
m_crmConnection = value
End Set
End Property ' CrmConnection
#End Region ' Properties
#Region "Internals"
'''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''
Private ReadOnly Property CrmConnectionType() As String()
Get
CrmConnectionType = New String() {"DYNAMICS-CRM"}
End Get
End Property ' CrmConnectionType
'''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''
Private Sub FireError_(ByVal message As String)
Dim cancel As Boolean = False
Call MyBase.ComponentMetaData.FireError( _
0, _
"Dynamics CRM Qualify Lead", _
message, _
String.Empty, _
0, _
cancel)
End Sub ' FireError_
'''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''
Private Function GetInputColumn_(ByVal externalName As String) As IDTSInputColumn90
Dim result As IDTSInputColumn90 = Nothing
Dim input As IDTSInput90 = MyBase.ComponentMetaData.InputCollection(0)
Dim extColumn As IDTSExternalMetadataColumn90 = input.ExternalMetadataColumnCollection(externalName)
' Find input column for specified external column.
For Each inputCol As IDTSInputColumn90 In input.InputColumnCollection
If inputCol.ExternalMetadataColumnID = extColumn.ID Then
' Found input column.
result = inputCol
Exit For
End If
Next
GetInputColumn_ = result
End Function ' GetInputColumn_
'''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''
Private Function GetColumnIndex_(ByVal externalName As String) As Integer
Dim result As Integer = -1
Dim input As IDTSInput90 = MyBase.ComponentMetaData.InputCollection(0)
Dim inputCol As IDTSInputColumn90 = GetInputColumn_(externalName)
If Not inputCol Is Nothing Then
result = Me.HostComponent.BufferManager.FindColumnByLineageID( _
input.Buffer, _
inputCol.LineageID)
End If
GetColumnIndex_ = result
End Function ' GetColumnIndex_
'''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''
Private Function SetupEntityReference_(ByVal entityName As String, ByVal id As Guid) As EntityReference
Dim result As New EntityReference
result.LogicalName = entityName
result.Id = id
SetupEntityReference_ = result
End Function ' SetupEntityReference_
'''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''
Private Function GetBufferValue_( _
ByVal buffer As Microsoft.SqlServer.Dts.Pipeline.PipelineBuffer, _
ByVal index As Integer) As Object
Dim result As Object = Nothing
If index <> -1 AndAlso Not buffer.IsNull(index) Then
result = buffer(index)
End If
GetBufferValue_ = result
End Function ' GetBufferValue_
#End Region ' Internals
#Region "Attributes"
Private m_crmConnection As String
Private m_connection As IConnection
Private m_service As OrganizationServiceClient
Private m_caIndex As Integer
Private m_ccIndex As Integer
Private m_coIndex As Integer
Private m_liIndex As Integer
Private m_ocurrIdIndex As Integer
Private m_ocustIdIndex As Integer
Private m_sciIndex As Integer
Private m_sIndex As Integer
#End Region ' Attributes
End Class ' ScriptMain
]]>ScriptComponent_6cb9d41b1123408eb60baf08185166fetrueCozyRoc.SqlServer.SSIS.ScriptComponentHostPlus, CozyRoc.SSISPlus, Version=1.0.0.0, Culture=neutral, PublicKeyToken=16cf490bb80c34ea