1 | RORHDTUT ;HCIOFO/SG - HISTORICAL DATA EXTRACTION UTILITIES ; 1/23/06 8:16am
|
---|
2 | ;;1.5;CLINICAL CASE REGISTRIES;;Feb 17, 2006
|
---|
3 | ;
|
---|
4 | Q
|
---|
5 | ;
|
---|
6 | ;***** RETURNS THE DATA EXTRACTION TIME FRAME(S)
|
---|
7 | ;
|
---|
8 | ; HDEIEN Data Extract IEN
|
---|
9 | ;
|
---|
10 | ; .DXDTF Reference to a local array where the time frame(s)
|
---|
11 | ; will be returned to.
|
---|
12 | ;
|
---|
13 | ; DXTDF( A single time frame if no specific parameters are
|
---|
14 | ; defined for the data area(s)
|
---|
15 | ; ^01: Start Date
|
---|
16 | ; ^02: End Date
|
---|
17 | ; DataArea) Time frame for the data area:
|
---|
18 | ; ^01: Start Date
|
---|
19 | ; ^02: End Date
|
---|
20 | ;
|
---|
21 | ; Return Values:
|
---|
22 | ; <0 Error code
|
---|
23 | ; 0 Ok
|
---|
24 | ;
|
---|
25 | DXDTF(HDEIEN,DXDTF) ;
|
---|
26 | N BUF,DAC,ENDT,IENS,RORBUF,RORMSG,STDT,TMP
|
---|
27 | K DXDTF
|
---|
28 | ;--- Load the time frame(s) from the data extract definition
|
---|
29 | S IENS=(+HDEIEN)_","
|
---|
30 | D GETS^DIQ(799.6,IENS,".03;.04;1*","I","RORBUF","RORMSG")
|
---|
31 | Q:$G(DIERR) $$DBS^RORERR("RORMSG",-9,,,799.6,IENS)
|
---|
32 | ;--- Get the main time frame (if defined)
|
---|
33 | S STDT=$G(RORBUF(799.6,IENS,.03,"I"))\1 ; Start Date
|
---|
34 | S ENDT=$G(RORBUF(799.6,IENS,.04,"I"))\1 ; End Date
|
---|
35 | ;--- Check for data area time frames
|
---|
36 | S IENS=""
|
---|
37 | F S IENS=$O(RORBUF(799.61,IENS)) Q:IENS="" D
|
---|
38 | . S DAC=+$G(RORBUF(799.61,IENS,.01,"I")) Q:DAC'>0
|
---|
39 | . S BUF=""
|
---|
40 | . ;--- Start Date
|
---|
41 | . S TMP=$G(RORBUF(799.61,IENS,.02,"I"))\1
|
---|
42 | . I TMP'>0 S TMP=STDT Q:TMP'>0
|
---|
43 | . S $P(BUF,U,1)=TMP
|
---|
44 | . ;--- End Date
|
---|
45 | . S TMP=$G(RORBUF(799.61,IENS,.03,"I"))\1
|
---|
46 | . I TMP'>0 S TMP=ENDT Q:TMP'>0
|
---|
47 | . S $P(BUF,U,2)=TMP
|
---|
48 | . ;--- Store the time frame
|
---|
49 | . S DXDTF(DAC)=BUF
|
---|
50 | ;--- Otherwise, return the main time frame
|
---|
51 | S:$D(DXDTF)<10 DXDTF=STDT_U_ENDT
|
---|
52 | ;--- Success
|
---|
53 | Q 0
|
---|
54 | ;
|
---|
55 | ;***** GENERATES A NEW UNUSED FILE NAME FOR THE TASK
|
---|
56 | ;
|
---|
57 | ; HDEIEN Data Extract IEN
|
---|
58 | ; TASKIEN Task IEN
|
---|
59 | ; [.FILE] New name is returned via this parameter
|
---|
60 | ; [GNONLY] Only generate a new name but do not store it into
|
---|
61 | ; task record
|
---|
62 | ;
|
---|
63 | ; Return Values:
|
---|
64 | ; <0 Error code
|
---|
65 | ; 0 Ok
|
---|
66 | ;
|
---|
67 | NEWFILE(HDEIEN,TASKIEN,FILE,GNONLY) ;
|
---|
68 | N BASE,EXT,FN,IENS,NAME,OUTDIR,RC,RORBUF,RORLST,RORMSG,TMP
|
---|
69 | S RC=$$TASKFILE(HDEIEN,TASKIEN,.OUTDIR,.FILE) Q:RC<0 RC
|
---|
70 | S BASE=$P($P(FILE,"."),"-",1,3),EXT=$P($P(FILE,".",2),";")
|
---|
71 | ;--- Get a list of files in the output directory
|
---|
72 | S RORBUF(BASE_"*."_EXT)=""
|
---|
73 | Q:'$$LIST^%ZISH(OUTDIR,"RORBUF","RORLST") 0
|
---|
74 | Q:$D(RORLST)<10 0
|
---|
75 | K RORBUF
|
---|
76 | ;--- Generate a new name
|
---|
77 | S NAME="",FN=0
|
---|
78 | F S NAME=$O(RORLST(NAME)) Q:NAME="" D
|
---|
79 | . S TMP=+$P(NAME,"-",4) S:TMP>FN FN=TMP
|
---|
80 | S FILE=BASE,$P(FILE,"-",4)=$TR($J(FN+1,2)," ","0")
|
---|
81 | S FILE=FILE_"."_EXT
|
---|
82 | Q:$G(GNONLY) 0
|
---|
83 | K RORLST
|
---|
84 | ;--- Store it to the task record
|
---|
85 | S IENS=(+TASKIEN)_","_(+HDEIEN)_","
|
---|
86 | S RORBUF(799.64,IENS,.05)=FILE
|
---|
87 | D FILE^DIE(,"RORBUF","RORMSG")
|
---|
88 | Q $$DBS^RORERR("RORMSG",-9,,,799.64,IENS)
|
---|
89 | ;
|
---|
90 | ;***** PAUSES THE OUTPUT AT PAGE END
|
---|
91 | ;
|
---|
92 | ; Return values:
|
---|
93 | ; -2 Timeout
|
---|
94 | ; -1 User entered a '^'
|
---|
95 | ; 0 Continue
|
---|
96 | ;
|
---|
97 | PAGE() ;
|
---|
98 | I $G(IOST)'["C-" S $Y=0 Q:$QUIT 0 Q
|
---|
99 | N DA,DIR,DIROUT,DIRUT,DTOUT,DUOUT,X,Y
|
---|
100 | S DIR(0)="E" D ^DIR S $Y=0
|
---|
101 | Q:$QUIT $S($D(DUOUT):-1,$D(DTOUT):-2,1:0)
|
---|
102 | Q
|
---|
103 | ;
|
---|
104 | ;***** SELECTS/ADDS A HISTORICAL DATA EXTRACTION DEFINITION
|
---|
105 | ;
|
---|
106 | ; [FLAGS] Flags that control the processing
|
---|
107 | ; "A" Allow addition of new entries
|
---|
108 | ;
|
---|
109 | ; [.NAME] Data extract name is returned via this parameter
|
---|
110 | ;
|
---|
111 | ; [.NATIONAL] This parameter is set to 1 if a national data
|
---|
112 | ; extraction is selected
|
---|
113 | ;
|
---|
114 | ; Return Values:
|
---|
115 | ; <0 Error code
|
---|
116 | ; "" "^" has been entered or timeout
|
---|
117 | ; 0 Nothing has been selected
|
---|
118 | ; >0 IEN of the selected definition (file #799.6)
|
---|
119 | ;
|
---|
120 | SELHDE(FLAGS,NAME,NATIONAL) ;
|
---|
121 | N DA,DIC,DLAYGO,DTOUT,DUOUT,X,Y
|
---|
122 | S NAME="",NATIONAL=0,FLAGS=$G(FLAGS)
|
---|
123 | S DIC=799.6,DIC(0)="AENQZ"
|
---|
124 | I FLAGS["A" D S DIC(0)=DIC(0)_"L",DLAYGO=DIC
|
---|
125 | . S DIC("DR")="[RORHDT EDIT EXTRACTION]"
|
---|
126 | S DIC("A")="Select a Data Extraction: "
|
---|
127 | S DIC("S")="I $P($G(^(0)),U,2)=2" ; Only "Manual" type
|
---|
128 | W ! D ^DIC Q:$D(DTOUT)!$D(DUOUT) ""
|
---|
129 | I Y>0 S NAME=Y(0,0),NATIONAL=+$P(Y(0),U,9) Q +Y
|
---|
130 | Q 0
|
---|
131 | ;
|
---|
132 | ;***** SELECTS A DATA EXTRACTION TASK
|
---|
133 | ;
|
---|
134 | ; RORHDIEN Data Extraction Definition IEN
|
---|
135 | ;
|
---|
136 | ; Return Values:
|
---|
137 | ; <0 Error code
|
---|
138 | ; "" "^" has been entered or timeout
|
---|
139 | ; 0 Nothing has been selected
|
---|
140 | ; >0 IEN of the selected task (multiple #4 of file #799.6)
|
---|
141 | ;
|
---|
142 | SELTASK(RORHDIEN) ;
|
---|
143 | N DA,DIR,DTOUT,DUOUT,IENS,RC,ROROOT,X,Y
|
---|
144 | ;--- Display status of the data extraction
|
---|
145 | S RC=$$STATUS^RORHDT01(RORHDIEN) Q:RC<0 RC
|
---|
146 | ;--- Select a task
|
---|
147 | S ROROOT=$$ROOT^DILFD(799.64,","_RORHDIEN_",",1)
|
---|
148 | S TMP=+$O(@ROROOT@(" "),-1)
|
---|
149 | S DIR(0)="NO^1:"_TMP_":0^K:'$D(@ROROOT@(X,0)) X"
|
---|
150 | S DIR("A")="Task ID"
|
---|
151 | S DIR("?")="^I $$TASKLIST^RORHDTUT(RORHDIEN)"
|
---|
152 | W ! D ^DIR
|
---|
153 | Q $S($D(DTOUT)!$D(DUOUT):"",Y>0:+Y,1:0)
|
---|
154 | ;
|
---|
155 | ;***** GETS THE NAME OF THE TASK OUTPUT FILE
|
---|
156 | ;
|
---|
157 | ; HDEIEN Data Extract IEN
|
---|
158 | ; TASKIEN Task IEN
|
---|
159 | ; .OUTDIR Output directory is returned via this parameter
|
---|
160 | ; .FILE File name is returned via the parameter
|
---|
161 | ;
|
---|
162 | ; Return Values:
|
---|
163 | ; <0 Error code
|
---|
164 | ; 0 Ok
|
---|
165 | ;
|
---|
166 | TASKFILE(HDEIEN,TASKIEN,OUTDIR,FILE) ;
|
---|
167 | N IENS,RC,RORMSG
|
---|
168 | S (OUTDIR,FILE)=""
|
---|
169 | ;--- Get the output directory
|
---|
170 | S IENS=(+HDEIEN)_","
|
---|
171 | S OUTDIR=$$GET1^DIQ(799.6,IENS,2,,,"RORMSG")
|
---|
172 | Q:$G(DIERR) $$DBS^RORERR("RORMSG",-9,,,799.6,IENS)
|
---|
173 | ;--- Get the file name
|
---|
174 | S IENS=(+TASKIEN)_","_(+HDEIEN)_","
|
---|
175 | S FILE=$$GET1^DIQ(799.64,IENS,.05,,,"RORMSG")
|
---|
176 | Q:$G(DIERR) $$DBS^RORERR("RORMSG",-9,,,799.6,IENS)
|
---|
177 | ;--- Success
|
---|
178 | Q 0
|
---|
179 | ;
|
---|
180 | ;***** DISPLAYS THE TASK LIST
|
---|
181 | ;
|
---|
182 | ; HDEIEN Data Extract IEN
|
---|
183 | ;
|
---|
184 | ; Return Values:
|
---|
185 | ; <0 Error code
|
---|
186 | ; 0 Ok
|
---|
187 | ;
|
---|
188 | TASKLIST(HDEIEN) ;
|
---|
189 | N IENS,IT,RC,RORBUF,RORMNL,RORMSG,TASKIEN,TS
|
---|
190 | ;--- Get the list of tasks
|
---|
191 | S IENS=","_(+HDEIEN)_",",TMP="@;.01;.02;.05"
|
---|
192 | D LIST^DIC(799.64,IENS,TMP,"Q",,,,"B",,,"RORBUF","RORMSG")
|
---|
193 | Q:$G(DIERR) $$DBS^RORERR("RORMSG",-9,,,799.64,IENS)
|
---|
194 | I $G(RORBUF("DILIST",0))<1 D Q 0
|
---|
195 | . W !,?10,"No tasks have been defined"
|
---|
196 | ;--- Get status of the tasks
|
---|
197 | S IT=""
|
---|
198 | F S IT=$O(RORBUF("DILIST","ID",IT)) Q:IT="" D
|
---|
199 | . S TASKIEN=+RORBUF("DILIST",2,IT)
|
---|
200 | . S TS=$$TASKSTAT(HDEIEN,TASKIEN)
|
---|
201 | . S RORBUF("DILIST","ID",IT,.03)=$P(TS,U,2)
|
---|
202 | ;--- Display the task table
|
---|
203 | S RORMNL=$S($G(IOSL)>3:IOSL-3,1:20),$Y=0
|
---|
204 | D TASKLP() W !
|
---|
205 | S IT="",RC=0
|
---|
206 | F S IT=$O(RORBUF("DILIST","ID",IT)) Q:IT="" D Q:RC
|
---|
207 | . D TASKLP(IT) S:$Y'<RORMNL RC=$$PAGE()
|
---|
208 | ;--- Success
|
---|
209 | Q 0
|
---|
210 | ;
|
---|
211 | ;***** DISPLAYS A LINE OF THE TASK TABLE
|
---|
212 | ;
|
---|
213 | ; RORBUF Field values from the record of the file #798.5
|
---|
214 | ; returned by LIST^DIC
|
---|
215 | ;
|
---|
216 | ; IT Index in the table
|
---|
217 | ;
|
---|
218 | TASKLP(IT) ;
|
---|
219 | ;;!?2^ID^$J($G(RORBUF("DILIST",2,IT)),2)
|
---|
220 | ;;?6^File Name^$G(RORBUF("DILIST","ID",IT,.05))
|
---|
221 | ;;?39^Task^$G(RORBUF("DILIST","ID",IT,.02))
|
---|
222 | ;;?49^Status^$G(RORBUF("DILIST","ID",IT,.03))
|
---|
223 | ;
|
---|
224 | N I,TMP
|
---|
225 | ;--- Display the headers
|
---|
226 | I '$G(IT) D Q
|
---|
227 | . F I=1:1 S TMP=$P($T(TASKLP+I),";;",2,999) Q:TMP="" D
|
---|
228 | . . W @$TR($P(TMP,"^")," "),$P(TMP,"^",2)
|
---|
229 | ;--- Display the values
|
---|
230 | F I=1:1 S TMP=$P($T(TASKLP+I),";;",2,999) Q:TMP="" D
|
---|
231 | . W @$TR($P(TMP,"^")," "),@$P(TMP,"^",3)
|
---|
232 | Q
|
---|
233 | ;
|
---|
234 | ;***** RETURNS THE TASK NUMBER
|
---|
235 | ;
|
---|
236 | ; HDEIEN Data Extract IEN
|
---|
237 | ; TASKIEN Task IEN
|
---|
238 | ;
|
---|
239 | ; Return Values:
|
---|
240 | ; <0 Error code
|
---|
241 | ; 0 No task defined
|
---|
242 | ; >0 Task Number
|
---|
243 | ;
|
---|
244 | TASKNUM(HDEIEN,TASKIEN) ;
|
---|
245 | N IENS,RORMSG,TASK
|
---|
246 | S IENS=(+TASKIEN)_","_(+HDEIEN)_","
|
---|
247 | S TASK=+$$GET1^DIQ(799.64,IENS,.02,"I",,"RORMSG")
|
---|
248 | Q:$G(DIERR) $$DBS^RORERR("RORMSG",-9,,,799.64,IENS)
|
---|
249 | Q TASK
|
---|
250 | ;
|
---|
251 | ;***** RETURNS STATUS OF THE TASK
|
---|
252 | ;
|
---|
253 | ; HDEIEN Data Extract IEN
|
---|
254 | ; TASKIEN Task IEN
|
---|
255 | ; [LTO] LOCK timeout
|
---|
256 | ;
|
---|
257 | ; Return Values:
|
---|
258 | ; <0 Error code
|
---|
259 | ; 0 Unknown Status
|
---|
260 | ; >0 Status (Code^Description)
|
---|
261 | ;
|
---|
262 | ; 1 Active: Pending
|
---|
263 | ; 2 Active: Running
|
---|
264 | ; 3 Inactive: Finished
|
---|
265 | ; 4 Inactive: Available
|
---|
266 | ; 5 Inactive: Interrupted
|
---|
267 | ;
|
---|
268 | ; 100 Inactive: Crashed
|
---|
269 | ; 101 Inactive: Errors
|
---|
270 | ; 102 Active: Suspended
|
---|
271 | ; 103 Active: Stopping
|
---|
272 | ;
|
---|
273 | TASKSTAT(HDEIEN,TASKIEN,LTO) ;
|
---|
274 | N IENS,RORBUF,RORFDA,RORMSG,STATUS,TASK,TMP
|
---|
275 | S IENS=(+TASKIEN)_","_(+HDEIEN)_","
|
---|
276 | ;--- Get the task number and its last known status
|
---|
277 | D GETS^DIQ(799.64,IENS,".02;.03","EI","RORBUF","RORMSG")
|
---|
278 | Q:$G(DIERR) $$DBS^RORERR("RORMSG",-9,,,799.64,IENS)
|
---|
279 | S TASK=$G(RORBUF(799.64,IENS,.02,"I"))
|
---|
280 | Q:TASK="" 0
|
---|
281 | ;--- Try to get status of the task
|
---|
282 | S STATUS=$$STATUS^RORTSK02(TASK,$G(LTO))
|
---|
283 | Q:STATUS<0 STATUS
|
---|
284 | ;--- If the task record exists, then update the task STATUS
|
---|
285 | ;--- field if necessary and return the current task status
|
---|
286 | I STATUS>0 D:+STATUS'=$G(RORBUF(799.64,IENS,.03,"I")) Q STATUS
|
---|
287 | . S RORFDA(799.64,IENS,.03)=+STATUS
|
---|
288 | . D FILE^DIE(,"RORFDA","RORMSG")
|
---|
289 | . D:$G(DIERR) DBS^RORERR("RORMSG",-9,,,799.64,IENS)
|
---|
290 | ;--- Otherwise, return the last known status
|
---|
291 | S STATUS=+$G(RORBUF(799.64,IENS,.03,"I"))
|
---|
292 | Q:STATUS'>0 0
|
---|
293 | S TMP=$TR($G(RORBUF(799.64,IENS,.03,"E")),">",":")
|
---|
294 | Q STATUS_U_TMP
|
---|