[613] | 1 | ROREXT03 ;HCIOFO/SG - REGISTRY DATA EXTRACTION (OVERFLOW) ; 11/29/05 4:13pm
|
---|
| 2 | ;;1.5;CLINICAL CASE REGISTRIES;;Feb 17, 2006
|
---|
| 3 | ;
|
---|
| 4 | Q
|
---|
| 5 | ;
|
---|
| 6 | ;*****REGISTRY STATE CSR SEGMENT
|
---|
| 7 | CSR(REGIEN) ;
|
---|
| 8 | N CS,RC,RORINFO,RORSEG,RPTSTATS,TMP
|
---|
| 9 | D ECH^RORHL7(.CS)
|
---|
| 10 | ;
|
---|
| 11 | ;--- Get the registry information
|
---|
| 12 | S RC=$$REGINFO^RORUTL17(REGIEN,"RORINFO") Q:RC<0 RC
|
---|
| 13 | S TMP=$$STATS^RORTSK12(REGIEN,.RPTSTATS)
|
---|
| 14 | ;
|
---|
| 15 | ;--- Initialize the segment
|
---|
| 16 | S RORSEG(0)="CSR"
|
---|
| 17 | ;
|
---|
| 18 | ;--- CSR-1 - Name of the registry and version of the CCR
|
---|
| 19 | S TMP=+$P(ROREXT("VERSION"),U) ; Version
|
---|
| 20 | S:$P(TMP,".",2)="" $P(TMP,".",2)="0"
|
---|
| 21 | S $P(TMP,".",3)=+$P(ROREXT("VERSION"),U,2) ; Patch Number
|
---|
| 22 | S $P(TMP,".",4)=+$$BUILD^ROR ; Build Number
|
---|
| 23 | S RORSEG(1)=$$ESCAPE^RORHL7($P($$REGNAME^RORUTL01(REGIEN),U))_CS_TMP
|
---|
| 24 | ;
|
---|
| 25 | ;--- CSR-3 - Institution
|
---|
| 26 | S RORSEG(3)=$$SITE^RORUTL03(CS)
|
---|
| 27 | ;
|
---|
| 28 | ;--- CSR-4 - Patient ID
|
---|
| 29 | S TMP="0"_CS_CS_CS_CS_"U"
|
---|
| 30 | S $P(TMP,CS,6)=+$G(RORINFO("NPP")) ; Number of pending patients
|
---|
| 31 | S $P(TMP,CS,7)=+$P(RPTSTATS,U) ; Number of reports
|
---|
| 32 | S RORSEG(4)=TMP
|
---|
| 33 | ;
|
---|
| 34 | ;--- Store the segment
|
---|
| 35 | D ADDSEG^RORHL7(.RORSEG)
|
---|
| 36 | Q 0
|
---|
| 37 | ;
|
---|
| 38 | ;***** REGISTRY STATE PID SEGMENT
|
---|
| 39 | PID() ;
|
---|
| 40 | N CS,RORSEG
|
---|
| 41 | D ECH^RORHL7(.CS)
|
---|
| 42 | ;
|
---|
| 43 | ;--- Initialize the segment
|
---|
| 44 | S RORSEG(0)="PID"
|
---|
| 45 | ;
|
---|
| 46 | ;--- PID-3 DFN and Station Number
|
---|
| 47 | S RORSEG(3)="0"_CS_CS_CS_CS_"U"
|
---|
| 48 | ;
|
---|
| 49 | ;--- PID-5 Patient Name
|
---|
| 50 | S RORSEG(5)="PSEUDO"_CS_"PATIENT"
|
---|
| 51 | ;
|
---|
| 52 | ;--- Store the segment
|
---|
| 53 | D ADDSEG^RORHL7(.RORSEG)
|
---|
| 54 | Q 0
|
---|
| 55 | ;
|
---|
| 56 | ;***** GENERATES THE REGISTRY STATE HL7 MESSAGE
|
---|
| 57 | ;
|
---|
| 58 | ; REGIEN Registry IEN
|
---|
| 59 | ;
|
---|
| 60 | ; Return Values:
|
---|
| 61 | ; <0 Error code
|
---|
| 62 | ; 0 Ok
|
---|
| 63 | ; >0 Number of ignored errors
|
---|
| 64 | ;
|
---|
| 65 | REGSTATE(REGIEN) ;
|
---|
| 66 | N RC
|
---|
| 67 | ;--- Output pseudo-patient's segments
|
---|
| 68 | S RC=$$PID() Q:RC<0 RC
|
---|
| 69 | S RC=$$CSR(REGIEN) Q:RC<0 RC
|
---|
| 70 | ;---
|
---|
| 71 | Q 0
|
---|
| 72 | ;
|
---|
| 73 | ;***** SENDS THE CURRENT HL7 BATCH
|
---|
| 74 | ;
|
---|
| 75 | ; .RGIENLST Reference to a local array containing registry
|
---|
| 76 | ; IENs as subscripts and IENs of the corresponding
|
---|
| 77 | ; patient's registry records as values.
|
---|
| 78 | ;
|
---|
| 79 | ; Return Values:
|
---|
| 80 | ; <0 Error Code
|
---|
| 81 | ; 0 Ok
|
---|
| 82 | ;
|
---|
| 83 | SEND(RGIENLST) ;
|
---|
| 84 | N IENS,MID,RC,REGIEN,RORFDA,RORMSG,TMP
|
---|
| 85 | W:$G(RORPARM("DEBUG"))>1 !,"HL7 Batch ID: ",$G(ROREXT("HL7MID"))
|
---|
| 86 | S RC=$$SEND^RORHL7(.MID) Q:RC<0 RC
|
---|
| 87 | I 'RC,$G(MID)'="" D
|
---|
| 88 | . S ROREXT("NBM")=$G(ROREXT("NBM"))+1
|
---|
| 89 | . S TMP="HL7 batch message "_MID_" has been generated"
|
---|
| 90 | . D LOG^RORLOG(2,TMP)
|
---|
| 91 | . ;--- Add message reference to the LAST BATCH CONTROL ID
|
---|
| 92 | . ;--- multiples of the registries that are being processed
|
---|
| 93 | . S (RC,REGIEN)=0
|
---|
| 94 | . F S REGIEN=$O(RGIENLST(REGIEN)) Q:REGIEN'>0 D Q:RC<0
|
---|
| 95 | . . K RORFDA,RORMSG S IENS="+1,"_REGIEN_","
|
---|
| 96 | . . ;--- LAST BATCH CONTROL ID
|
---|
| 97 | . . S RORFDA(798.122,IENS,.01)=MID
|
---|
| 98 | . . ;--- INTERNAL BATCH ID
|
---|
| 99 | . . S RORFDA(798.122,IENS,.02)=$G(ROREXT("HL7MID"))
|
---|
| 100 | . . ;--- Batch Date/Time
|
---|
| 101 | . . S TMP=+$G(ROREXT("HL7DT"))
|
---|
| 102 | . . S RORFDA(798.122,IENS,.03)=$S(TMP>0:TMP,1:$$NOW^XLFDT)
|
---|
| 103 | . . ;--- Create the record
|
---|
| 104 | . . D UPDATE^DIE(,"RORFDA",,"RORMSG")
|
---|
| 105 | . . S:$G(DIERR) RC=$$DBS^RORERR("RORMSG",-9,,PTIEN,798.122,IENS)
|
---|
| 106 | Q 0
|
---|
| 107 | ;
|
---|
| 108 | ;***** UPDATES THE REGISTRY RECORDS AFTER THE DATA EXTRACTION
|
---|
| 109 | ;
|
---|
| 110 | ; PTIEN Patient IEN (DFN)
|
---|
| 111 | ;
|
---|
| 112 | ; .RGIENLST Reference to a local array containing registry
|
---|
| 113 | ; IENs as subscripts and IENs of the corresponding
|
---|
| 114 | ; patient's registry records as values.
|
---|
| 115 | ;
|
---|
| 116 | ; BATCHID
|
---|
| 117 | ;
|
---|
| 118 | ; Return Values:
|
---|
| 119 | ; <0 Error Code
|
---|
| 120 | ; 0 Ok
|
---|
| 121 | ;
|
---|
| 122 | UPDRECS(PTIEN,RGIENLST,BATCHID,ENDT) ;
|
---|
| 123 | N FS,IEN,IENS,RC,REGIEN,RORFDA,RORMSG
|
---|
| 124 | S (RC,REGIEN)=0
|
---|
| 125 | F S REGIEN=$O(RGIENLST(REGIEN)) Q:REGIEN'>0 D Q:RC<0
|
---|
| 126 | . K RORFDA,RORMSG
|
---|
| 127 | . S IEN=+RGIENLST(REGIEN) Q:IEN'>0
|
---|
| 128 | . S IENS=IEN_","
|
---|
| 129 | . ;--- Store the Message ID in the registry
|
---|
| 130 | . S:BATCHID'="" RORFDA(798,IENS,10)=BATCHID
|
---|
| 131 | . ;--- Otherwise, populate the MESSAGE ID field with a fake ID.
|
---|
| 132 | . ; This will force the message status checkup process to
|
---|
| 133 | . ; update the DATA ACKNOWLEDGED UNTIL field so that the next
|
---|
| 134 | . ; data extraction process will not browse through the data
|
---|
| 135 | . ;--- already processed by the previous one.
|
---|
| 136 | . S:BATCHID="" RORFDA(798,IENS,10)=ROREXT("HL7MID")_"-0"
|
---|
| 137 | . ;--- Always update the DATA EXTRACTED UNTIL field
|
---|
| 138 | . S RORFDA(798,IENS,9.2)=ENDT
|
---|
| 139 | . ;--- Update the registry record
|
---|
| 140 | . D FILE^DIE(,"RORFDA","RORMSG")
|
---|
| 141 | . S:$G(DIERR) RC=$$DBS^RORERR("RORMSG",-9,,PTIEN,798,IENS)
|
---|
| 142 | ;---
|
---|
| 143 | Q $S(RC<0:RC,1:0)
|
---|