| [613] | 1 | RGEQDMN1 ;BHM/RGY-DEQUEUE PROCESSOR CONTINUED ;2/17/98 | 
|---|
|  | 2 | ;;1.0;CLINICAL INFO RESOURCE NETWORK;**19**;30 Apr 99 | 
|---|
|  | 3 | STOP ;Stop dequeue processor | 
|---|
|  | 4 | NEW ENT,DIR,DTOUT,DUOUT,DIRUT,DIE,DA,DR,Y,STAT | 
|---|
|  | 5 | S DIR("A")="Do you want to stop ALL MPI/PD processing" | 
|---|
|  | 6 | S DIR(0)="Y",DIR("B")="NO" | 
|---|
|  | 7 | D ^DIR K DIR Q:$D(DIRUT) | 
|---|
|  | 8 | I Y=1 S ^RGEQ("ASTOP")="YES" W " ... Done" Q | 
|---|
|  | 9 | S DIR("A")="Do you want to ENABLE/DISABLE a particular data class" | 
|---|
|  | 10 | S DIR(0)="Y",DIR("B")="NO" | 
|---|
|  | 11 | D ^DIR K DIR Q:$D(DIRUT) | 
|---|
|  | 12 | I Y=1 D | 
|---|
|  | 13 | .S DIR(0)="PO^995:QEAM",DIR("A")="Select MPI/PD Data Class" | 
|---|
|  | 14 | .D ^DIR K DIR Q:$D(DIRUT) | 
|---|
|  | 15 | .S ENT=+Y,STAT=+$P(^RGEQASN(ENT,0),"^",5) | 
|---|
|  | 16 | .W ! | 
|---|
|  | 17 | .S DIR("A",1)="NOTE: This class is currently "_$P("enabled^disabled","^",STAT+1) | 
|---|
|  | 18 | .S DIR("A")="   ...Do you want to "_$P("DISABLE^ENABLE","^",STAT+1) | 
|---|
|  | 19 | .S DIR(0)="Y",DIR("B")="NO" | 
|---|
|  | 20 | .D ^DIR K DIR Q:$D(DIRUT) | 
|---|
|  | 21 | .I Y=0 Q | 
|---|
|  | 22 | .S DIE="^RGEQASN(",DA=ENT,DR="5////^S X="_$P("1^0","^",STAT+1) D ^DIE | 
|---|
|  | 23 | .W " ...Done." | 
|---|
|  | 24 | .Q | 
|---|
|  | 25 | Q | 
|---|
|  | 26 | START ;Start the queue processor | 
|---|
|  | 27 | NEW DIR,DTOUT,DUOUT,DIRUT,ZTSK,ZTIO,ZTRTN,ZTSAVE,ZTDESC | 
|---|
|  | 28 | L +^RGEQ("MAIN"):0 E  D  Q | 
|---|
|  | 29 | .W !!,"The MPI/PD processor is already running!" | 
|---|
|  | 30 | .Q | 
|---|
|  | 31 | L -^RGEQ("MAIN") | 
|---|
|  | 32 | S DIR("A")="Are you sure you want to start the MPI/PD processor" | 
|---|
|  | 33 | S DIR(0)="Y",DIR("B")="NO" | 
|---|
|  | 34 | D ^DIR K DIR Q:$D(DIRUT) | 
|---|
|  | 35 | I Y=1 D  Q | 
|---|
|  | 36 | .S ZTRTN="MAIN^RGEQDMN",ZTDESC="'MAIN' MPI/PD process" | 
|---|
|  | 37 | .S ZTREQ="@",ZTDTH=$H,ZTIO="" | 
|---|
|  | 38 | .D ^%ZTLOAD | 
|---|
|  | 39 | .I $G(ZTSK) W " ... done." | 
|---|
|  | 40 | .S ^RGEQ("ASTOP")="NO" | 
|---|
|  | 41 | .Q | 
|---|
|  | 42 | W "...NOT queued" | 
|---|
|  | 43 | Q | 
|---|
|  | 44 | AUTO ;Automatically start background process | 
|---|
|  | 45 | NEW ZTSK,ZTIO,ZTRTN,ZTSAVE,ZTDESC | 
|---|
|  | 46 | L +^RGEQ("MAIN"):0 E  Q | 
|---|
|  | 47 | L -^RGEQ("MAIN") | 
|---|
|  | 48 | S ZTRTN="MAIN^RGEQDMN",ZTDESC="'MAIN' MPI/PD process" | 
|---|
|  | 49 | S ZTREQ="@",ZTDTH=$H,ZTIO="" | 
|---|
|  | 50 | D ^%ZTLOAD | 
|---|
|  | 51 | S ^RGEQ("ASTOP")="NO" | 
|---|
|  | 52 | Q | 
|---|
|  | 53 | TEST(TYPE,PARAM,ERROR,HL7) ;Test queue processor | 
|---|
|  | 54 | Q | 
|---|
|  | 55 | ESTOP(TYPE) ;Check to see if filer should stop | 
|---|
|  | 56 | I ($G(^RGEQ("ASTOP"))="YES")!($$SEND^RGJUSITE=0) Q 1 | 
|---|
|  | 57 | I TYPE="MAIN" Q 0 | 
|---|
|  | 58 | Q ($$SEND^RGJUSITE=2)!(+$P($G(^RGEQASN(+$O(^RGEQASN("B",TYPE,0)),0)),"^",5)) | 
|---|
|  | 59 | STATUS ;check current status of event queue, used for menu entry actions | 
|---|
|  | 60 | ;added by CML 4/1/99 | 
|---|
|  | 61 | L +^RGEQ("MAIN"):0 E  D  Q | 
|---|
|  | 62 | .W !!,"=> MPI/PD Event Queue processor is currently running.",! | 
|---|
|  | 63 | .Q | 
|---|
|  | 64 | W $C(7),$C(7),!!,"=> MPI/PD Event Queue processor is <<NOT>> currently running.",! | 
|---|
|  | 65 | L -^RGEQ("MAIN") | 
|---|
|  | 66 | Q | 
|---|