| 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) | 
|---|