Business Process

Class User.RMHealthOutcomesProd Extends EnsLib.RecordMap.RecordMap {

XData RecordMap [ XMLNamespace = "http://www.intersystems.com/Ensemble/RecordMap" ] { <Record xmlns="http://www.intersystems.com/Ensemble/RecordMap" name="User.RMHealthOutcomesProd" type="delimited" char_encoding="UTF-8" targetClassname="User.RMHealthOutcomesProd.Record" complexBatchManaged="0" padFromLeft="0" recordTerminator="\x0d\x0a" allowEarlyTerminator="0"> <Separators> <Separator>,</Separator> </Separators> <Field name="GroupCohort" required="0" datatype="%String" repeating="0"> </Field> <Field name="ChildNumber" required="0" datatype="%Integer" repeating="0"> </Field> <Field name="GroupVisitsAtten" required="0" datatype="%Integer" repeating="0"> </Field> <Field name="OtherVisitAtten" required="0" datatype="%Integer" repeating="0"> </Field> <Field name="WeeksFirstVisit" required="0" datatype="%Integer" repeating="0"> </Field> <Field name="DueDate" required="0" datatype="%Date" repeating="0"> </Field> <Field name="DeliveryDate" required="0" datatype="%Date" repeating="0"> </Field> <Field name="VaginalBirth" required="0" datatype="%Integer" repeating="0"> </Field> <Field name="VBAC" required="0" datatype="%Integer" repeating="0"> </Field> <Field name="Csession" required="0" datatype="%Integer" repeating="0"> </Field> <Field name="Pounds" required="0" datatype="%Integer" repeating="0"> </Field> <Field name="Weight" required="0" datatype="%Integer" repeating="0"> </Field> <Field name="Discharge" required="0" datatype="%Integer" repeating="0"> </Field> <Field name="NICU" required="0" datatype="%Integer" repeating="0"> </Field> <Field name="NICUDays" required="0" datatype="%Integer" repeating="0"> </Field> <Field name="BefDueDate" required="0" datatype="%Integer" repeating="0"> </Field> <Field name="PractiseID" required="0" datatype="%String" repeating="0"> </Field> </Record> }

/// Method to retrieve a record from a stream or device. This method will be generated based on the /// structure of the RecordMap. For testing purposes, a file name may be passed in the pStream argument. ClassMethod GetObject(pStream As %IO.DeviceStream, Output pObject As %RegisteredObject, pTimeout As %Numeric = -1, ByRef pLookAhead As %String = "", pLabelFound As %Boolean = 0) As %Status { Try { Set tStatus = $$$OK Set pObject = $$$NULLOREF If '$IsObject(pStream) { Set tFilename = pStream Set pStream = ##class(%IO.FileStream).%New() Do pStream.Open(tFilename,,pTimeout,"UTF-8", .tStatus) If $$$ISERR(tStatus) Quit } Set tObjectName = $parameter($this,"OBJECTNAME") Set tObject = $classmethod(tObjectName,"%New") If '$IsObject(tObject) { Set tStatus = $$$ERROR($$$CannotCreateObject,tObjectName) Quit } Set tObject.%Source = pStream.Name Set tGetTopFields = $parameter(tObject,"INCLUDETOPFIELDS") If pStream.AtEnd { Set tStatus = $$$ERROR($$$EnsRecordMapErrStreamAtEnd, pStream.Name) Quit } Set pStream.CharEncoding = "UTF-8"

	#; Parse incoming stream
	Set tStatus = ..GetRecord(pStream, tObject, tGetTopFields, pTimeout, .pLookAhead, pLabelFound)
	If $$$ISERR(tStatus) Quit
}
Catch ex {
	Set tStatus = ex.AsStatus()
}
If $$$ISERR(tStatus) { Set pObject = $$$NULLOREF }
Else { Set pObject = tObject }
Quit tStatus

}

/// Method to write a record to a stream or device. This method will be generated based on the /// structure of the RecordMap. For testing purposes, a file name may be passed in the pStream argument. ClassMethod PutObject(pStream As %IO.DeviceStream, pObject As %RegisteredObject, pFlush As %Boolean = 1, ByRef pPadArray As %String) As %Status { Try { Set tStatus = $$$OK If '$IsObject(pStream) { Set tFilename = pStream Set pStream = ##class(%IO.FileStream).%New() Do pStream.Open(tFilename,"WAE",,"UTF-8", .tStatus) If $$$ISERR(tStatus) Quit } Set tHasTopFields = $parameter(pObject,"INCLUDETOPFIELDS") Set pStream.CharEncoding = "UTF-8"

	Set tStatus = ..PutRecord(pStream, pObject, tHasTopFields, .pPadArray)
	If $$$ISERR(tStatus) Quit
	If pFlush Do pStream.Flush(.tStatus)
	If $$$ISERR(tStatus) Quit
}
Catch ex {
	Set tStatus = ex.AsStatus()
}
Quit tStatus

}

Parameter OBJECTNAME = "User.RMHealthOutcomesProd.Record";

/// Internal helper method to perform parse of incoming data ClassMethod GetRecord(pStream As %IO.DeviceStream, pObject As %RegisteredObject, pGetTopFields As %Boolean, pTimeout As %Numeric, ByRef pLookAhead As %String = "", pLabelFound As %Boolean = 0) As %Status [ Internal, Private ] { Set tStatus = $$$OK If pLabelFound { Set tRecLabel = "" } Else { Set tRecLabel = "" } Set tStatus = ..chunkRecord(pStream, .tRecordData, .tCharCount, "", pTimeout, $char(13,10), tRecLabel, .pLookAhead, "") If $$$ISERR(tStatus) Quit tStatus Set tMaxLocal = $$$MaxLocalLength Set tRecordData("charcount") = +$get(tCharCount) Set tCurrChunk = 1 Set tTopPiece = 1 Set tCurrSep = 1 Set tStrings = 1 Set tSeps = $listbuild($char(44)) If '$data(tRecordData(tCurrChunk, "block")) { Set tCurrString = $piece(tRecordData(tCurrChunk), $char(44), tTopPiece) } Else { Set tCurrString = tRecordData(tCurrChunk) Set tCurrPiece = 1 } Do ..checkMerge(.tCurrChunk, .tRecordData, .tCurrString, $char(44), .tTopPiece) If pGetTopFields { Set pObject.GroupCohort = tCurrString } If '$data(tRecordData(tCurrChunk, "block")) { Set tCurrString = $piece(tRecordData(tCurrChunk), $char(44), tTopPiece) } Do ..checkMerge(.tCurrChunk, .tRecordData, .tCurrString, $char(44), .tTopPiece) If pGetTopFields { Set pObject.ChildNumber = pObject.ChildNumberDisplayToLogical(tCurrString) } If '$data(tRecordData(tCurrChunk, "block")) { Set tCurrString = $piece(tRecordData(tCurrChunk), $char(44), tTopPiece) } Do ..checkMerge(.tCurrChunk, .tRecordData, .tCurrString, $char(44), .tTopPiece) If pGetTopFields { Set pObject.GroupVisitsAtten = pObject.GroupVisitsAttenDisplayToLogical(tCurrString) } If '$data(tRecordData(tCurrChunk, "block")) { Set tCurrString = $piece(tRecordData(tCurrChunk), $char(44), tTopPiece) } Do ..checkMerge(.tCurrChunk, .tRecordData, .tCurrString, $char(44), .tTopPiece) If pGetTopFields { Set pObject.OtherVisitAtten = pObject.OtherVisitAttenDisplayToLogical(tCurrString) } If '$data(tRecordData(tCurrChunk, "block")) { Set tCurrString = $piece(tRecordData(tCurrChunk), $char(44), tTopPiece) } Do ..checkMerge(.tCurrChunk, .tRecordData, .tCurrString, $char(44), .tTopPiece) If pGetTopFields { Set pObject.WeeksFirstVisit = pObject.WeeksFirstVisitDisplayToLogical(tCurrString) } If '$data(tRecordData(tCurrChunk, "block")) { Set tCurrString = $piece(tRecordData(tCurrChunk), $char(44), tTopPiece) } Do ..checkMerge(.tCurrChunk, .tRecordData, .tCurrString, $char(44), .tTopPiece) If pGetTopFields { Set pObject.DueDate = pObject.DueDateDisplayToLogical(tCurrString) } If '$data(tRecordData(tCurrChunk, "block")) { Set tCurrString = $piece(tRecordData(tCurrChunk), $char(44), tTopPiece) } Do ..checkMerge(.tCurrChunk, .tRecordData, .tCurrString, $char(44), .tTopPiece) If pGetTopFields { Set pObject.DeliveryDate = pObject.DeliveryDateDisplayToLogical(tCurrString) } If '$data(tRecordData(tCurrChunk, "block")) { Set tCurrString = $piece(tRecordData(tCurrChunk), $char(44), tTopPiece) } Do ..checkMerge(.tCurrChunk, .tRecordData, .tCurrString, $char(44), .tTopPiece) If pGetTopFields { Set pObject.VaginalBirth = pObject.VaginalBirthDisplayToLogical(tCurrString) } If '$data(tRecordData(tCurrChunk, "block")) { Set tCurrString = $piece(tRecordData(tCurrChunk), $char(44), tTopPiece) } Do ..checkMerge(.tCurrChunk, .tRecordData, .tCurrString, $char(44), .tTopPiece) If pGetTopFields { Set pObject.VBAC = pObject.VBACDisplayToLogical(tCurrString) } If '$data(tRecordData(tCurrChunk, "block")) { Set tCurrString = $piece(tRecordData(tCurrChunk), $char(44), tTopPiece) } Do ..checkMerge(.tCurrChunk, .tRecordData, .tCurrString, $char(44), .tTopPiece) If pGetTopFields { Set pObject.Csession = pObject.CsessionDisplayToLogical(tCurrString) } If '$data(tRecordData(tCurrChunk, "block")) { Set tCurrString = $piece(tRecordData(tCurrChunk), $char(44), tTopPiece) } Do ..checkMerge(.tCurrChunk, .tRecordData, .tCurrString, $char(44), .tTopPiece) If pGetTopFields { Set pObject.Pounds = pObject.PoundsDisplayToLogical(tCurrString) } If '$data(tRecordData(tCurrChunk, "block")) { Set tCurrString = $piece(tRecordData(tCurrChunk), $char(44), tTopPiece) } Do ..checkMerge(.tCurrChunk, .tRecordData, .tCurrString, $char(44), .tTopPiece) If pGetTopFields { Set pObject.Weight = pObject.WeightDisplayToLogical(tCurrString) } If '$data(tRecordData(tCurrChunk, "block")) { Set tCurrString = $piece(tRecordData(tCurrChunk), $char(44), tTopPiece) } Do ..checkMerge(.tCurrChunk, .tRecordData, .tCurrString, $char(44), .tTopPiece) If pGetTopFields { Set pObject.Discharge = pObject.DischargeDisplayToLogical(tCurrString) } If '$data(tRecordData(tCurrChunk, "block")) { Set tCurrString = $piece(tRecordData(tCurrChunk), $char(44), tTopPiece) } Do ..checkMerge(.tCurrChunk, .tRecordData, .tCurrString, $char(44), .tTopPiece) If pGetTopFields { Set pObject.NICU = pObject.NICUDisplayToLogical(tCurrString) } If '$data(tRecordData(tCurrChunk, "block")) { Set tCurrString = $piece(tRecordData(tCurrChunk), $char(44), tTopPiece) } Do ..checkMerge(.tCurrChunk, .tRecordData, .tCurrString, $char(44), .tTopPiece) If pGetTopFields { Set pObject.NICUDays = pObject.NICUDaysDisplayToLogical(tCurrString) } If '$data(tRecordData(tCurrChunk, "block")) { Set tCurrString = $piece(tRecordData(tCurrChunk), $char(44), tTopPiece) } Do ..checkMerge(.tCurrChunk, .tRecordData, .tCurrString, $char(44), .tTopPiece) If pGetTopFields { Set pObject.BefDueDate = pObject.BefDueDateDisplayToLogical(tCurrString) } If '$data(tRecordData(tCurrChunk, "block")) { Set tCurrString = $piece(tRecordData(tCurrChunk), $char(44), tTopPiece) } Do ..checkMerge(.tCurrChunk, .tRecordData, .tCurrString, $char(44), .tTopPiece) If pGetTopFields { Set pObject.PractiseID = tCurrString } Quit tStatus }

/// Internal helper method to output object to a stream ClassMethod PutRecord(pStream As %IO.DeviceStream, pObject As %RegisteredObject, pHasTopFields As %Boolean, ByRef pPadArray As %String) As %Status [ Internal, Private ] { Set tStatus = $$$OK Do pStream.Write($select(pHasTopFields: pObject.GroupCohort,1: ""),0) Do pStream.Write($char(44) _ $select(pHasTopFields: pObject.ChildNumberLogicalToDisplay(pObject.ChildNumber),1: ""),0) Do pStream.Write($char(44) _ $select(pHasTopFields: pObject.GroupVisitsAttenLogicalToDisplay(pObject.GroupVisitsAtten),1: ""),0) Do pStream.Write($char(44) _ $select(pHasTopFields: pObject.OtherVisitAttenLogicalToDisplay(pObject.OtherVisitAtten),1: ""),0) Do pStream.Write($char(44) _ $select(pHasTopFields: pObject.WeeksFirstVisitLogicalToDisplay(pObject.WeeksFirstVisit),1: ""),0) Do pStream.Write($char(44) _ $select(pHasTopFields: pObject.DueDateLogicalToDisplay(pObject.DueDate),1: ""),0) Do pStream.Write($char(44) _ $select(pHasTopFields: pObject.DeliveryDateLogicalToDisplay(pObject.DeliveryDate),1: ""),0) Do pStream.Write($char(44) _ $select(pHasTopFields: pObject.VaginalBirthLogicalToDisplay(pObject.VaginalBirth),1: ""),0) Do pStream.Write($char(44) _ $select(pHasTopFields: pObject.VBACLogicalToDisplay(pObject.VBAC),1: ""),0) Do pStream.Write($char(44) _ $select(pHasTopFields: pObject.CsessionLogicalToDisplay(pObject.Csession),1: ""),0) Do pStream.Write($char(44) _ $select(pHasTopFields: pObject.PoundsLogicalToDisplay(pObject.Pounds),1: ""),0) Do pStream.Write($char(44) _ $select(pHasTopFields: pObject.WeightLogicalToDisplay(pObject.Weight),1: ""),0) Do pStream.Write($char(44) _ $select(pHasTopFields: pObject.DischargeLogicalToDisplay(pObject.Discharge),1: ""),0) Do pStream.Write($char(44) _ $select(pHasTopFields: pObject.NICULogicalToDisplay(pObject.NICU),1: ""),0) Do pStream.Write($char(44) _ $select(pHasTopFields: pObject.NICUDaysLogicalToDisplay(pObject.NICUDays),1: ""),0) Do pStream.Write($char(44) _ $select(pHasTopFields: pObject.BefDueDateLogicalToDisplay(pObject.BefDueDate),1: ""),0) Do pStream.Write($char(44) _ $select(pHasTopFields: pObject.PractiseID,1: ""),0) Do pStream.Write($char(13,10), 0, .tStatus) If $$$ISERR(tStatus) Quit tStatus Quit tStatus }

ClassMethod GetGeneratedClasses(Output pClasses As %String) As %Status { Kill pClasses Set pClasses("User.RMHealthOutcomesProd.Record")="" Set pClasses($classname())="" Quit $$$OK }

ClassMethod getIdentifier() As %String [ CodeMode = expression ] { "" }

ClassMethod getType() As EnsLib.RecordMap.Model.DataType.RecordType [ CodeMode = expression ] { "delimited" }

} In this class i am getting value.

Second class: Class Controllers.HealthOutcomesBOperationProd Extends Ens.BusinessOperation {

Parameter INVOCATION = "Queue";

Method OnMessage(pRequest As User.RMHealthOutcomesProd.Record, Output pResponse As Ens.Response) As %Status {

	///
Set tGroupCohort = pRequest.GroupCohort
set tChildNumber = pRequest.ChildNumber
set tGroupVisitsAtten =pRequest.GroupVisitsAtten
set tOtherVisitAtten = pRequest.OtherVisitAtten	
set tWeeksFirstVisit = pRequest.WeeksFirstVisit
set tDueDate = pRequest.DueDate
set tDeliveryDate = pRequest.DeliveryDate
set tVaginalBirth = pRequest.VaginalBirth
set tVBAC = pRequest.VBAC
set tCsession = pRequest.Csession
set tPounds = pRequest.Pounds
set tWeight = pRequest.Weight
set tDischarge = pRequest.Discharge
set tNICU = pRequest.NICU
set tNICUDays = pRequest.NICUDays
set tBefDueDate = pRequest.BefDueDate
set tPractiseID = pRequest.PractiseID
&SQL(Insert into CHIModel.HealthOutcomesProd(GroupCohort, ChildNumber, GroupVisitsAtten, OtherVisitAtten, WeeksFirstVisit, DueDate, DeliveryDate, VaginalBirth, VBAC, Csession, Pounds, Weight, Discharge, NICU, NICUDays, BefDueDate,PractiseID) values(:tGroupCohort, :tChildNumber, :tGroupVisitsAtten, :tOtherVisitAtten, :tWeeksFirstVisit, :tDueDate, :tDeliveryDate, :tVaginalBirth, :tVBAC, :tCsession, :tPounds, :tWeight, :tDischarge, :tNICU, :tNICUDays, :tBefDueDate, :tPractiseID))
Quit $$$OK
///

}

XData MessageMap { <MapItems> <MapItem MessageType="User.RMHealthOutcomesProd.Record"> <Method>OnMessage</Method> </MapItem> </MapItems> }

} This class for inserting the data from ensemble object but it does not enter in this class. Previously it was working.