[613] | 1 | ROREXTUT ;HCIOFO/SG - DATA EXTRACT UTILITIES ; 11/25/05 3:57pm
|
---|
| 2 | ;;1.5;CLINICAL CASE REGISTRIES;;Feb 17, 2006
|
---|
| 3 | ;
|
---|
| 4 | Q
|
---|
| 5 | ;
|
---|
| 6 | ;***** PRINT SOME DEBUG INFORMATION
|
---|
| 7 | DEBUG ;
|
---|
| 8 | D ZW^RORUTL01("ROREXT","Control Data")
|
---|
| 9 | D ZW^RORUTL01("RORLRC","Lab Results to extract")
|
---|
| 10 | W !,"Job number: ",$J,!
|
---|
| 11 | Q
|
---|
| 12 | ;
|
---|
| 13 | ;***** ADDS THE TIME FRAME TO THE LIST
|
---|
| 14 | ;
|
---|
| 15 | ; .DXDTS Reference to a local variable where the
|
---|
| 16 | ; data extraction time frames are stored.
|
---|
| 17 | ;
|
---|
| 18 | ; STDT Start date (FileMan)
|
---|
| 19 | ; ENDT End Date (FileMan)
|
---|
| 20 | ;
|
---|
| 21 | ; DTAR Data area code (see the ROR DATA AREA file #799.33)
|
---|
| 22 | ;
|
---|
| 23 | ; [MAIN] If this parameter defined and not zero, the time
|
---|
| 24 | ; frame is considered the main one.
|
---|
| 25 | ;
|
---|
| 26 | ; Variants of positional relationship of the existing time frames
|
---|
| 27 | ; and the one that is being added to the list (STDT-ENDT):
|
---|
| 28 | ;
|
---|
| 29 | ; (1) +--------TMP +----------+
|
---|
| 30 | ; STDT--------ENDT
|
---|
| 31 | ;
|
---|
| 32 | ; (2) +--------TMP
|
---|
| 33 | ; STDT--------ENDT
|
---|
| 34 | ;
|
---|
| 35 | ; (3) TMP--------+
|
---|
| 36 | ; STDT--------ENDT
|
---|
| 37 | ;
|
---|
| 38 | ; (4) +--------+
|
---|
| 39 | ; STDT------------------ENDT
|
---|
| 40 | ;
|
---|
| 41 | DXADD(DXDTS,STDT,ENDT,DTAR,MAIN) ;
|
---|
| 42 | Q:STDT>ENDT
|
---|
| 43 | N DATE,EXIT,TMP
|
---|
| 44 | ;--- Update the main time frame
|
---|
| 45 | I $G(MAIN) D S DTAR=0
|
---|
| 46 | . S TMP=+$P(DXDTS,U)
|
---|
| 47 | . S:(TMP'>0)!(STDT<TMP) $P(DXDTS,U,1)=STDT
|
---|
| 48 | . S:ENDT>$P(DXDTS,U,2) $P(DXDTS,U,2)=ENDT
|
---|
| 49 | ;--- Merge the time frames if possible
|
---|
| 50 | S DATE=$O(DXDTS(DTAR,ENDT)),EXIT=0
|
---|
| 51 | F S DATE=$O(DXDTS(DTAR,DATE),-1) Q:DATE="" D Q:EXIT
|
---|
| 52 | . S TMP=$P(DXDTS(DTAR,DATE),U,2)
|
---|
| 53 | . I TMP<STDT S EXIT=1 Q ; (1)
|
---|
| 54 | . S:TMP>ENDT ENDT=TMP ; (2)
|
---|
| 55 | . S TMP=$P(DXDTS(DTAR,DATE),U)
|
---|
| 56 | . S:TMP<STDT STDT=TMP ; (3)
|
---|
| 57 | . K DXDTS(DTAR,DATE)
|
---|
| 58 | ;--- Store the new time frame
|
---|
| 59 | S DXDTS(DTAR,STDT)=STDT_U_ENDT
|
---|
| 60 | Q
|
---|
| 61 | ;
|
---|
| 62 | ;***** CALCULATES THE MAIN DATA EXTRACTION TIME FRAME
|
---|
| 63 | ;
|
---|
| 64 | ; .DXDTS Reference to a local variable where the
|
---|
| 65 | ; data extraction time frames are stored.
|
---|
| 66 | ;
|
---|
| 67 | ; IEN IEN of the patient's record in the registry
|
---|
| 68 | ;
|
---|
| 69 | ; Return Values:
|
---|
| 70 | ; <0 Error Code
|
---|
| 71 | ; 0 Ok
|
---|
| 72 | ; >0 Skip the patient
|
---|
| 73 | ;
|
---|
| 74 | ; If the special extraction start date for all patients is defined
|
---|
| 75 | ; then it is as the start date of the main time frame. Usually,
|
---|
| 76 | ; this mode is not used. ;-)
|
---|
| 77 | ;
|
---|
| 78 | ; If the field #9.1 of the patient record in the registry (#798)
|
---|
| 79 | ; has a value then this value is used as the start date of the
|
---|
| 80 | ; main time frame (data have already been extracted until that
|
---|
| 81 | ; date). This field is empty for new patients.
|
---|
| 82 | ;
|
---|
| 83 | ; The function tries to get the earliest date when a selection rule
|
---|
| 84 | ; has been triggered for the newly added patient. If the patient has
|
---|
| 85 | ; been added manually and there are no selection rules in the
|
---|
| 86 | ; SELECTION RULE multiple of the registry record then a date when
|
---|
| 87 | ; the patient was added to the registry is used.
|
---|
| 88 | ;
|
---|
| 89 | ; After that, extract period for new patients (value of the field
|
---|
| 90 | ; #7 of the file #798.1) is subtracted from the date and the result
|
---|
| 91 | ; is used as the start date. If the extract period is not set for
|
---|
| 92 | ; the registry then a default value (365) is used.
|
---|
| 93 | ;
|
---|
| 94 | DXMAIN(DXDTS,IEN) ;
|
---|
| 95 | N ENDT,IENS,LCH,RC,RORBUF,RORMSG,STDT,TMP
|
---|
| 96 | S (ENDT,STDT)="",IENS=IEN_",",LCH=0
|
---|
| 97 | ;--- Get the registry record data
|
---|
| 98 | D GETS^DIQ(798,IENS,"1;3;3.2;4;5;9.1","I","RORBUF","RORMSG")
|
---|
| 99 | Q:$G(DIERR) $$DBS^RORERR("RORMSG",-9,,,798,IENS)
|
---|
| 100 | S ENDT=$$FMADD^XLFDT(ROREXT("DXEND"),-$G(ROREXT("LD",1)))
|
---|
| 101 | F TMP=4,5 S:$G(RORBUF(798,IENS,TMP,"I")) LCH=1
|
---|
| 102 | ;--- Empty time frame for patients who are marked for deletion
|
---|
| 103 | I $G(RORBUF(798,IENS,3,"I"))=5 D Q 0
|
---|
| 104 | . D DXADD(.DXDTS,ENDT,ENDT,0,1)
|
---|
| 105 | ;--- Special start date for ALL patients (if defined)
|
---|
| 106 | S STDT=$G(ROREXT("DXBEG"))
|
---|
| 107 | I STDT'>0 D
|
---|
| 108 | . ;--- Start date from the patient's registry record
|
---|
| 109 | . ;--- (value of the DATA ACKNOWLEDGED UNTIL field)
|
---|
| 110 | . S STDT=$G(RORBUF(798,IENS,9.1,"I"))\1 Q:STDT>0
|
---|
| 111 | . ;--- If value of the DATA ACKNOWLEDGED UNTIL field is missing or
|
---|
| 112 | . ; not greater than 0, then the patient is considered new and
|
---|
| 113 | . ; the start date is calculated as date of earliest selection
|
---|
| 114 | . ; rule minus maximum value of the EXTRACT PERIOD FOR NEW
|
---|
| 115 | . ;--- PATIENT field for all processed registries.
|
---|
| 116 | . S STDT=$G(RORBUF(798,IENS,3.2,"I")) Q:STDT'>0
|
---|
| 117 | . S TMP=+$G(ROREXT("EXTRDAYS"))
|
---|
| 118 | . S STDT=$$FMADD^XLFDT(STDT,-$S(TMP>0:TMP,1:365))\1
|
---|
| 119 | ;--- Check the dates and add the time frame to the list
|
---|
| 120 | I (STDT'>0)!(ENDT'>0) D Q RC
|
---|
| 121 | . S TMP=$$GET1^DIQ(798,IENS,.01,"I",,"RORMSG")
|
---|
| 122 | . S RC=$$ERROR^RORERR(-32,,,TMP,STDT,ENDT)
|
---|
| 123 | S RC=0
|
---|
| 124 | I STDT'<ENDT S RC=1 S:LCH STDT=ENDT,RC=0
|
---|
| 125 | D:'RC DXADD(.DXDTS,STDT,ENDT,0,1)
|
---|
| 126 | Q RC
|
---|
| 127 | ;
|
---|
| 128 | ;***** MERGES SPECIAL TIME FRAMES INTO THE 'DATA-SPECIFIC' LISTS
|
---|
| 129 | ;
|
---|
| 130 | ; .DXDTS Reference to a local variable where the
|
---|
| 131 | ; data extraction time frames are stored.
|
---|
| 132 | ;
|
---|
| 133 | DXMERGE(DXDTS) ;
|
---|
| 134 | N DTAR,TMP
|
---|
| 135 | S DTAR=0
|
---|
| 136 | F S DTAR=$O(ROREXT("DTAR",DTAR)) Q:DTAR'>0 D
|
---|
| 137 | . ;--- Main time frame
|
---|
| 138 | . D DXADD(.DXDTS,$P(DXDTS,U),$P(DXDTS,U,2),DTAR)
|
---|
| 139 | . ;--- Data-specific time frame
|
---|
| 140 | . S TMP=$G(ROREXT("DTAR",DTAR))
|
---|
| 141 | . D:TMP>0 DXADD(.DXDTS,$P(TMP,U),$P(TMP,U,2),DTAR)
|
---|
| 142 | Q
|
---|
| 143 | ;
|
---|
| 144 | ;***** ADDS DATA EXTRACTION PERIODS FOR THE PATIENT TO THE LIST
|
---|
| 145 | ;
|
---|
| 146 | ; .DXDTS Reference to a local variable that the data
|
---|
| 147 | ; extraction time frames are added to. The
|
---|
| 148 | ; main time frame is returned in the root node:
|
---|
| 149 | ;
|
---|
| 150 | ; DXDTS( MainStartDate^MainEndDate (FileMan)
|
---|
| 151 | ; DataArea,
|
---|
| 152 | ; i) StartDate^EndDate (FileMan)
|
---|
| 153 | ;
|
---|
| 154 | ; IEN IEN of the patient record in the registry
|
---|
| 155 | ;
|
---|
| 156 | ; PATIEN Patient IEN
|
---|
| 157 | ;
|
---|
| 158 | ; Return Values:
|
---|
| 159 | ; <0 Error Code
|
---|
| 160 | ; 0 Ok
|
---|
| 161 | ; >0 Skip the patient
|
---|
| 162 | ;
|
---|
| 163 | DXPERIOD(DXDTS,IEN,PATIEN) ;
|
---|
| 164 | N AREA,ENDT,EVTDT,EVTIEN,NODE,RC,STDT,TMP
|
---|
| 165 | S DXDTS=$G(DXDTS)
|
---|
| 166 | ;
|
---|
| 167 | ;=== Main data extraction time frame
|
---|
| 168 | S RC=$$DXMAIN(.DXDTS,IEN) Q:RC RC
|
---|
| 169 | ;
|
---|
| 170 | ;=== Data-specific protocols (only Inpatient at present)
|
---|
| 171 | ; The Inpatient protocol is not used anymore because now the
|
---|
| 172 | ; data search is performed on the PTF CLOSE OUT file instead
|
---|
| 173 | ; of the PTF file (after patch ROR*1*8).
|
---|
| 174 | ;S NODE=$NA(^RORDATA(798.3,+PATIEN,2))
|
---|
| 175 | ;F AREA=3 D
|
---|
| 176 | ;. ;--- Browse the events in the main time frame
|
---|
| 177 | ;. S EVTDT=$O(@NODE@("AT",AREA,+DXDTS),-1)
|
---|
| 178 | ;. S ENDT=+$P(DXDTS,U,2)
|
---|
| 179 | ;. F S EVTDT=$O(@NODE@("AT",AREA,EVTDT)) Q:'EVTDT!(EVTDT'<ENDT) D
|
---|
| 180 | ;. . S EVTIEN=""
|
---|
| 181 | ;. . F S EVTIEN=$O(@NODE@("AT",AREA,EVTDT,EVTIEN)) Q:EVTIEN="" D
|
---|
| 182 | ;. . . S TMP=$P($G(@NODE@(EVTIEN,0)),U,3)\1
|
---|
| 183 | ;. . . D:TMP>0 DXADD(.DXDTS,TMP,$$FMADD^XLFDT(TMP,1),AREA)
|
---|
| 184 | ;
|
---|
| 185 | ;=== Data-specific 'sliding windows'
|
---|
| 186 | D:$G(ROREXT("HDTIEN"))'>0
|
---|
| 187 | . S STDT=$$FMADD^XLFDT($P(DXDTS,U,1),-60)
|
---|
| 188 | . S ENDT=$$FMADD^XLFDT($P(DXDTS,U,2),-60)
|
---|
| 189 | . D DXADD(.DXDTS,STDT,ENDT,7) ; Autopsy
|
---|
| 190 | ;
|
---|
| 191 | ;=== Merge the main time frame into the data-specific ones
|
---|
| 192 | D DXMERGE(.DXDTS)
|
---|
| 193 | Q 0
|
---|
| 194 | ;
|
---|
| 195 | ;***** UPDATES DATA EXTRACTION PARAMETERS OF THE REGISTRY
|
---|
| 196 | ;
|
---|
| 197 | ; .REGLST Reference to a local array containing registry names
|
---|
| 198 | ; as subscripts and optional registry IENs as values
|
---|
| 199 | ;
|
---|
| 200 | ; Return values:
|
---|
| 201 | ; <0 Error code
|
---|
| 202 | ; 0 Ok
|
---|
| 203 | ;
|
---|
| 204 | TMSTMP(REGLST) ;
|
---|
| 205 | N DATE,RC,REGIEN,REGIENS,REGNAME,RORFDA,RORMSG
|
---|
| 206 | S RC=0,DATE=ROREXT("DXEND")\1
|
---|
| 207 | ;---
|
---|
| 208 | S REGNAME=""
|
---|
| 209 | F S REGNAME=$O(REGLST(REGNAME)) Q:REGNAME="" D Q:RC<0
|
---|
| 210 | . ;--- Get the registry IEN
|
---|
| 211 | . S REGIEN=+$G(REGLST(REGNAME))
|
---|
| 212 | . I REGIEN'>0 D I REGIEN'>0 S RC=+REGIEN Q
|
---|
| 213 | . . S REGIEN=$$REGIEN^RORUTL02(REGNAME)
|
---|
| 214 | . S REGIENS=REGIEN_","
|
---|
| 215 | . ;--- Do not update timestamp after historical data extractions
|
---|
| 216 | . I $G(ROREXT("HDTIEN"))'>0 D Q:RC<0
|
---|
| 217 | . . ;--- Check if the new date until that data has been extracted
|
---|
| 218 | . . ; is greater than that stored in the registry parameters
|
---|
| 219 | . . S TMP=$$GET1^DIQ(798.1,REGIENS,2,"I",,"RORMSG")
|
---|
| 220 | . . I $G(DIERR) D Q
|
---|
| 221 | . . . S RC=$$DBS^RORERR("RORMSG",-9,,,798.1,REGIENS)
|
---|
| 222 | . . S:DATE>TMP RORFDA(798.1,REGIENS,2)=DATE
|
---|
| 223 | . ;--- Increment the number of attempts
|
---|
| 224 | . D:$G(ROREXT("NBM"))>0
|
---|
| 225 | . . S TMP=$$GET1^DIQ(798.1,REGIENS,19.3,"I",,"RORMSG")
|
---|
| 226 | . . S RORFDA(798.1,REGIENS,19.3)=TMP+1
|
---|
| 227 | . ;--- Update registry parameters
|
---|
| 228 | . Q:$D(RORFDA)<10
|
---|
| 229 | . D FILE^DIE("K","RORFDA","RORMSG")
|
---|
| 230 | . I $G(DIERR) D Q
|
---|
| 231 | . . S RC=$$DBS^RORERR("RORMSG",-9,,,798.1,REGIENS)
|
---|
| 232 | . ;--- Reset all report stats
|
---|
| 233 | . D CLEAR^RORTSK12(REGIEN)
|
---|
| 234 | ;---
|
---|
| 235 | Q $S(RC<0:RC,1:0)
|
---|