VIAAQUE ;ALB/CR - RTLS Queue General Utility ;5/04/16 10:00am
;;1.0;RTLS;**3**;April 22, 2013;Build 20
;
Q
;
; create a task that can requeue itself and check file #6930
; every 3-6 minutes (180-360 seconds) or so
; =============== NOTICE ====================
; Per HPMO reference # OITIMB33554520, a waiver has been granted
; for the use of Cache ObjectScript along with standard MUMPS commands
;
STR ; enter here to send a message right away if entries are found
L +^VIAA(6930):5 Q:'$T ; we want just one job running
N COUNT,DATA,ROOT
I '$D(^VIAA(6930)) Q
F COUNT=0:0 S COUNT=+$O(^VIAA(6930,COUNT)) Q:'COUNT D
. S ROOT=$G(^VIAA(6930,COUNT,0))
. ; get all 3 pieces for processing in Eng file
. S DATA=$P(ROOT,U,1,3) ; take first 3 pieces at once
. D MSG
L -^VIAA(6930)
;
; -- if Mule is reachable, then call web service and deliver the
; -- entries. Otherwise, defer any action to the queue process.
Q
;
SEND ; come here to place the entries in the queue for the Mule service
;
N ZTRTN,ZTIO,ZTSAVE,ZTDESC,ZTDTH
I $D(^VIAA(6930)) D
. S ZTDESC="Pending RTLS File Queue Transmission"
. S ZTRTN="STR^VIAAQUE"
. S ZTIO="NULL",ZTDTH=$H ; need the null device for HWSC call
. S ZTSAVE("*")=""
. D ^%ZTLOAD
Q
;
; for transmission to Mule:
; if status = 500, we have to hold the entries for the next round
; of the queue; if status = 200, Mule has accepted the record and we
; can clean it from the file PENDING RTLS EVENTS (#6930)
MSG N MSG,STATUS,XCODE
;
S MSG="?siteID="_$P(DATA,U,1)_"&"_"fileNumber="_$P(DATA,U,2)_"&"_"IEN="_$P(DATA,U,3)
S XCODE=$$XMIT(MSG)
S STATUS=$S(XCODE=200:"OK",XCODE=500:"NOK",1:XCODE)
I STATUS'="OK" Q
D DEL^VIAATRI(COUNT) ; clear entry from file #6930
Q
;
XMIT(DATA) ; Transmit the RESTful request.
;
N $ETRAP,$ESTACK,ERR,REST,XCODE,XOBREADR,XOBREAK,XOBSTAT
S $ETRAP="D XERR^VIAAQUE"
;
S XCODE=0
S REST=$$GETREST^XOBWLIB("VIAA VISTA TRIGGER SERVICE","VIAA VISTA TRIGGER SERVER")
S REST.Timeout=60
I $$POST^XOBWLIB(REST,DATA,.ERR) D
. S XOBSTAT=##class(%XML.TextReader).ParseStream(REST.HttpResponse.Data,.XOBREADR)
. I ($$STATCHK^XOBWLIB(XOBSTAT,.ERR)) D
.. S XOBREAK=0 F Q:XOBREAK!XOBREADR.EOF!'XOBREADR.Read() D
... I (XOBREADR.NodeType="element"),(XOBREADR.LocalName="code") D
.... I XOBREADR.MoveToContent() D
..... S XCODE=XOBREADR.Value,XOBREAK=1
Q XCODE
;
XERR ; -- Error trap handler --
;
S $ECODE=""
Q
--- Routine Detail --- with STRUCTURED ROUTINE LISTING ---[H[J[2J[HVIAAQUE 2474 printed Dec 13, 2024@02:33:18 Page 2
VIAAQUE ;ALB/CR - RTLS Queue General Utility ;5/04/16 10:00am
+1 ;;1.0;RTLS;**3**;April 22, 2013;Build 20
+2 ;
+3 QUIT
+4 ;
+5 ; create a task that can requeue itself and check file #6930
+6 ; every 3-6 minutes (180-360 seconds) or so
+7 ; =============== NOTICE ====================
+8 ; Per HPMO reference # OITIMB33554520, a waiver has been granted
+9 ; for the use of Cache ObjectScript along with standard MUMPS commands
+10 ;
STR ; enter here to send a message right away if entries are found
+1 ; we want just one job running
LOCK +^VIAA(6930):5
if '$TEST
QUIT
+2 NEW COUNT,DATA,ROOT
+3 IF '$DATA(^VIAA(6930))
QUIT
+4 FOR COUNT=0:0
SET COUNT=+$ORDER(^VIAA(6930,COUNT))
if 'COUNT
QUIT
Begin DoDot:1
+5 SET ROOT=$GET(^VIAA(6930,COUNT,0))
+6 ; get all 3 pieces for processing in Eng file
+7 ; take first 3 pieces at once
SET DATA=$PIECE(ROOT,U,1,3)
+8 DO MSG
End DoDot:1
+9 LOCK -^VIAA(6930)
+10 ;
+11 ; -- if Mule is reachable, then call web service and deliver the
+12 ; -- entries. Otherwise, defer any action to the queue process.
+13 QUIT
+14 ;
SEND ; come here to place the entries in the queue for the Mule service
+1 ;
+2 NEW ZTRTN,ZTIO,ZTSAVE,ZTDESC,ZTDTH
+3 IF $DATA(^VIAA(6930))
Begin DoDot:1
+4 SET ZTDESC="Pending RTLS File Queue Transmission"
+5 SET ZTRTN="STR^VIAAQUE"
+6 ; need the null device for HWSC call
SET ZTIO="NULL"
SET ZTDTH=$HOROLOG
+7 SET ZTSAVE("*")=""
+8 DO ^%ZTLOAD
End DoDot:1
+9 QUIT
+10 ;
+11 ; for transmission to Mule:
+12 ; if status = 500, we have to hold the entries for the next round
+13 ; of the queue; if status = 200, Mule has accepted the record and we
+14 ; can clean it from the file PENDING RTLS EVENTS (#6930)
MSG NEW MSG,STATUS,XCODE
+1 ;
+2 SET MSG="?siteID="_$PIECE(DATA,U,1)_"&"_"fileNumber="_$PIECE(DATA,U,2)_"&"_"IEN="_$PIECE(DATA,U,3)
+3 SET XCODE=$$XMIT(MSG)
+4 SET STATUS=$SELECT(XCODE=200:"OK",XCODE=500:"NOK",1:XCODE)
+5 IF STATUS'="OK"
QUIT
+6 ; clear entry from file #6930
DO DEL^VIAATRI(COUNT)
+7 QUIT
+8 ;
XMIT(DATA) ; Transmit the RESTful request.
+1 ;
+2 NEW $ETRAP,$ESTACK,ERR,REST,XCODE,XOBREADR,XOBREAK,XOBSTAT
+3 SET $ETRAP="D XERR^VIAAQUE"
+4 ;
+5 SET XCODE=0
+6 SET REST=$$GETREST^XOBWLIB("VIAA VISTA TRIGGER SERVICE","VIAA VISTA TRIGGER SERVER")
+7 SET REST.Timeout=60
+8 IF $$POST^XOBWLIB(REST,DATA,.ERR)
Begin DoDot:1
+9 SET XOBSTAT=##class(%XML.TextReader).ParseStream(REST.HttpResponse.Data,.XOBREADR)
+10 IF ($$STATCHK^XOBWLIB(XOBSTAT,.ERR))
Begin DoDot:2
+11 SET XOBREAK=0
FOR
if XOBREAK!XOBREADR.EOF!'XOBREADR.Read()
QUIT
Begin DoDot:3
+12 IF (XOBREADR.NodeType="element")
IF (XOBREADR.LocalName="code")
Begin DoDot:4
+13 IF XOBREADR.MoveToContent()
Begin DoDot:5
+14 SET XCODE=XOBREADR.Value
SET XOBREAK=1
End DoDot:5
End DoDot:4
End DoDot:3
End DoDot:2
End DoDot:1
+15 QUIT XCODE
+16 ;
XERR ; -- Error trap handler --
+1 ;
+2 SET $ECODE=""
+3 QUIT
