159 lines
4.9 KiB
Mathematica
159 lines
4.9 KiB
Mathematica
HLOPROC ;ALB/CJM- Generic HL7 Process - 10/4/94 1pm ;03/26/2007
|
|
;;1.6;HEALTH LEVEL SEVEN;**126,134**;Oct 13, 1995;Build 30
|
|
;Per VHA Directive 2004-038, this routine should not be modified.
|
|
;
|
|
PROCESS ;queued entry point
|
|
;
|
|
;insure just one process manager
|
|
I PROCNAME="PROCESS MANAGER" N RUNNING L +^HLTMP(PROCNAME):1 S RUNNING='$T D Q:RUNNING
|
|
.I 'RUNNING D
|
|
..D SETNM^%ZOSV($E("HLOmgr:"_$J,1,17))
|
|
.E D
|
|
..L +HL7("COUNTING PROCESSES"):20
|
|
..K:$D(ZTSK) ^HLTMP("HL7 QUEUED PROCESSES",ZTSK)
|
|
..S ^HLC("HL7 PROCESS COUNTS","RUNNING","PROCESS MANAGER")=1
|
|
..S ^HLC("HL7 PROCESS COUNTS","QUEUED","PROCESS MANAGER")=0
|
|
..L -HL7("COUNTING PROCESSES")
|
|
..S ZTREQ="@"
|
|
;
|
|
;invoke the framework process
|
|
D HL7PROC(PROCNAME)
|
|
;
|
|
I PROCNAME="PROCESS MANAGER" L -^HLTMP(PROCNAME)
|
|
S ZTREQ="@"
|
|
Q
|
|
;
|
|
HL7PROC(PROCNAME) ;
|
|
;This is the generic HL7 process used by all processes started under the HL7 Process Manager
|
|
;Input:
|
|
; PROCNAME - the name of a process found in the HL7 Process Registry
|
|
; OUTPUT - none
|
|
;
|
|
N PROCESS,HL7STOP,WORK
|
|
;
|
|
S ^HL7TMP("HL7 PROCESS NAME",$J)=PROCNAME
|
|
;
|
|
L +HL7("COUNTING PROCESSES"):20
|
|
I $D(ZTQUEUED) D
|
|
.K:$D(ZTSK) ^HLTMP("HL7 QUEUED PROCESSES",ZTSK)
|
|
.I $$INC^HLOSITE($NA(^HLC("HL7 PROCESS COUNTS","QUEUED",PROCNAME)),-1)<0,$$INC^HLOSITE($NA(^HLC("HL7 PROCESS COUNTS","QUEUED",PROCNAME)))
|
|
L +^HLTMP("HL7 RUNNING PROCESSES",$J):0
|
|
I $$INC^HLOSITE($NA(^HLC("HL7 PROCESS COUNTS","RUNNING",PROCNAME)))
|
|
S ^HLTMP("HL7 RUNNING PROCESSES",$J)=$H_"^"_$G(ZTSK)_"^"_PROCNAME
|
|
L -HL7("COUNTING PROCESSES")
|
|
;
|
|
;
|
|
I $$GETPROC(PROCNAME,.PROCESS),'$$CHK4STOP(.PROCESS) D
|
|
.S $P(^HLD(779.3,PROCESS("IEN"),0),"^",6)=$$NOW^XLFDT
|
|
.;
|
|
.;should this task be made persistent?
|
|
.I PROCESS("PERSISTENT"),$G(ZTQUEUED),$$PSET^%ZTLOAD(ZTQUEUED)
|
|
.;
|
|
.S HL7STOP=0
|
|
.F D Q:HL7STOP
|
|
..N $ETRAP,$ESTACK S $ETRAP="G ERROR^HLOPROC"
|
|
..N HL7TRIES,GOTWORK
|
|
..F HL7TRIES=1:1 D Q:GOTWORK Q:$G(HL7STOP)
|
|
...S GOTWORK=$$GETWORK(.PROCESS,.WORK)
|
|
...Q:GOTWORK
|
|
...;since there is no work, don't want another process starting
|
|
...S $P(^HLD(779.3,PROCESS("IEN"),0),"^",6)=$$NOW^XLFDT
|
|
...H PROCESS("HANG")
|
|
...S HL7STOP=$$CHK4STOP(.PROCESS,HL7TRIES)
|
|
..Q:$G(HL7STOP)
|
|
..I GOTWORK D DOWORK(.PROCESS,.WORK) S HL7TRIES=0
|
|
..S:'$G(HL7STOP) HL7STOP=$$CHK4STOP(.PROCESS,.HL7TRIES)
|
|
;
|
|
S $P(^HLD(779.3,PROCESS("IEN"),0),"^",6)=$$NOW^XLFDT
|
|
;
|
|
END ;
|
|
S HL7STOP=1
|
|
K ^HL7TMP("HL7 PROCESS NAME",$J)
|
|
L +HL7("COUNTING PROCESSES"):20
|
|
K ^HLTMP("HL7 RUNNING PROCESSES",$J)
|
|
I $$INC^HLOSITE($NA(^HLC("HL7 PROCESS COUNTS","RUNNING",PROCNAME)),-1)<0,$$INC^HLOSITE($NA(^HLC("HL7 PROCESS COUNTS","RUNNING",PROCNAME)),1)
|
|
L -^HLTMP("HL7 RUNNING PROCESSES",$J)
|
|
L -HL7("COUNTING PROCESSES")
|
|
K ^TMP("HL7 ERRORS",$J)
|
|
;
|
|
Q
|
|
;
|
|
ERROR ;error trap
|
|
;
|
|
S $ETRAP="Q:$QUIT """" Q"
|
|
;
|
|
;while debugging always quit on error
|
|
I $G(^HLTMP("LOG ALL ERRORS"))!($ECODE["TOOMANYFILES")!($ECODE["EDITED") D Q:$QUIT "" Q
|
|
.D ^%ZTER
|
|
.S:'$D(PROCNAME) PROCNAME=$G(^HL7TMP("HL7 PROCESS NAME",$J))
|
|
.D END
|
|
;
|
|
;a lot of errors of the same type may indicate an endless loop, so quit
|
|
;to be on the safe side. Decrement the process count.
|
|
N HOUR
|
|
S HOUR=$E($$NOW^XLFDT,1,10)
|
|
I $G(^TMP("HL7 ERRORS",$J,HOUR,$P($ECODE,",",2)))>30 D Q:$QUIT "" Q
|
|
.;D ^%ZTER
|
|
.S:'$D(PROCNAME) PROCNAME=$G(^HL7TMP("HL7 PROCESS NAME",$J))
|
|
.D END
|
|
;
|
|
;can continue processing after logging the error
|
|
S ^TMP("HL7 ERRORS",$J,HOUR,$P($ECODE,",",2))=$G(^TMP("HL7 ERRORS",$J,HOUR,$P($ECODE,",",2)))+1
|
|
D ^%ZTER
|
|
D UNWIND^%ZTER
|
|
Q
|
|
;
|
|
GETPROC(PROCNAME,PROCESS) ;
|
|
;using PROCNAME to find the entry in the HL7 Process Registry, returns the entry as a subscripted array in .PROCESS
|
|
;
|
|
;Output: Function returns 0 on failure, 1 on success
|
|
;
|
|
N IEN,NODE
|
|
S IEN=$O(^HLD(779.3,"B",PROCNAME,0))
|
|
Q:'IEN 0
|
|
S PROCESS("NAME")=PROCNAME
|
|
S PROCESS("IEN")=IEN
|
|
S NODE=$G(^HLD(779.3,IEN,0))
|
|
S PROCESS("MINIMUM")=+$P(NODE,"^",3)
|
|
S PROCESS("MAXIMUM")=+$P(NODE,"^",4)
|
|
S PROCESS("HANG")=+$P(NODE,"^",7)
|
|
I 'PROCESS("HANG") S PROCESS("HANG")=1
|
|
S PROCESS("GET WORK")=$P(NODE,"^",8,9)
|
|
S PROCESS("DO WORK")=$P(NODE,"^",10,11)
|
|
S PROCESS("MAX TRIES")=$P(NODE,"^",12)
|
|
I 'PROCESS("MAX TRIES") S PROCESS("MAX TRIES")=999
|
|
S PROCESS("PERSISTENT")=+$P(NODE,"^",13)
|
|
S PROCESS("LINK")=$P(NODE,"^",14)
|
|
Q 1
|
|
;
|
|
GETWORK(PROCESS,WORK) ;
|
|
N RETURN,XECUTE
|
|
I PROCESS("LINK")]"" S WORK("LINK")=PROCESS("LINK")
|
|
S XECUTE="S RETURN=$$"_PROCESS("GET WORK")_"(.WORK)"
|
|
D
|
|
.N PROCESS
|
|
.X XECUTE
|
|
Q RETURN
|
|
;
|
|
DOWORK(PROCESS,WORK) ;
|
|
N XECUTE
|
|
M PARMS=WORK
|
|
S XECUTE="D "_PROCESS("DO WORK")_"(.WORK)"
|
|
D
|
|
.N PROCESS,HL7TRIES,PARMS,PROCNAME
|
|
.X XECUTE
|
|
M WORK=PARMS
|
|
Q
|
|
;
|
|
CHK4STOP(PROCESS,HL7TRIES) ;
|
|
;Determines if the process should stop, returns 1 if yes, 0 if no
|
|
;
|
|
Q:$$CHKSTOP 1
|
|
Q:'$P($G(^HLD(779.3,PROCESS("IEN"),0)),"^",2) 1
|
|
I $G(HL7TRIES)>(PROCESS("MAX TRIES")-1),PROCESS("MINIMUM")<$G(^HLC("HL7 PROCESS COUNTS","RUNNING",PROCESS("NAME"))) Q 1
|
|
Q:$G(^HLC("HL7 PROCESS COUNTS","RUNNING",PROCESS("NAME")))>PROCESS("MAXIMUM") 1
|
|
Q 0
|
|
;
|
|
CHKSTOP() ;has HL7 been requested to stop?
|
|
Q '$P($G(^HLD(779.1,1,0)),"^",9)
|