| 1 | PRCVMON ;ISC-SF/GJW;Monitor subscriptions ; 6/6/05 3:48pm | 
|---|
| 2 | ;;5.1;IFCAP;**81**;Oct 20, 2000 | 
|---|
| 3 | ;Per VHA Directive 10-93-142, this routine should not be modified. | 
|---|
| 4 | ; | 
|---|
| 5 | ; | 
|---|
| 6 | INIT ;Create initial set of FCP balances | 
|---|
| 7 | N I,J,K,IENS,OUT,STAT,FCP | 
|---|
| 8 | N IENS1,BAL,NODE | 
|---|
| 9 | S I="" | 
|---|
| 10 | F  S I=$O(^PRCV(414.03,"AC",1,I)) Q:I=""  D | 
|---|
| 11 | .S IENS=I_"," | 
|---|
| 12 | .D GETS^DIQ(414.03,IENS,"@;.01;.02","I","OUT") | 
|---|
| 13 | .S STAT=$G(OUT(414.03,IENS,.01,"I")) | 
|---|
| 14 | .S FCP=$G(OUT(414.03,IENS,.02,"I")) | 
|---|
| 15 | .K OUT | 
|---|
| 16 | .S J=0 | 
|---|
| 17 | .;The pattern match is needed because IENs in this subfile | 
|---|
| 18 | .;are actually strings, not (canonic) numbers | 
|---|
| 19 | .F  S J=$O(^PRC(420,STAT,1,FCP,4,J)) Q:((J="")!(J?1.A))  D | 
|---|
| 20 | ..;Unfortunately, an IEN of "00" confuses Fileman, so it is | 
|---|
| 21 | ..;necessary to use a global read instead of a Fileman call. | 
|---|
| 22 | ..I $$FY4(J)'<$$GETFY D | 
|---|
| 23 | ...S NODE=$G(^PRC(420,STAT,1,FCP,4,J,0)) | 
|---|
| 24 | ...F K=1:1:4 D | 
|---|
| 25 | ....S BAL(K)=+$P(NODE,"^",K+1) | 
|---|
| 26 | ...D UPD(STAT,FCP,J,.BAL) | 
|---|
| 27 | Q | 
|---|
| 28 | ; | 
|---|
| 29 | ;Reset values to contents of PRCVAL | 
|---|
| 30 | RESET(PRCVAL) ; | 
|---|
| 31 | N STAT,FCP,FY,I,MYBAL | 
|---|
| 32 | S STAT="" | 
|---|
| 33 | F  S STAT=$O(@PRCVAL@(STAT)) Q:STAT=""  D | 
|---|
| 34 | .S FY="" | 
|---|
| 35 | .F  S FY=$O(@PRCVAL@(STAT,FY)) Q:FY=""  D | 
|---|
| 36 | ..I $$FY4(FY)'<$$GETFY D | 
|---|
| 37 | ...S FCP="" | 
|---|
| 38 | ...F  S FCP=$O(@PRCVAL@(STAT,FY,FCP)) Q:FCP=""  D | 
|---|
| 39 | ....F I=1:1:4 D | 
|---|
| 40 | .....S MYBAL(I)=$G(@PRCVAL@(STAT,FY,FCP,I)) | 
|---|
| 41 | ....;update 414.03 | 
|---|
| 42 | ....D UPD(STAT,FCP,FY,.MYBAL) | 
|---|
| 43 | Q | 
|---|
| 44 | ; | 
|---|
| 45 | ;Schedule the task | 
|---|
| 46 | SCHED ; | 
|---|
| 47 | N ZTRTN,ZTDESC,ZTDTH,ZTIO,ZTPRI,ZTSK | 
|---|
| 48 | ;Quit if not a DM site | 
|---|
| 49 | I '$$CHK D  Q | 
|---|
| 50 | .W !,"This task may not be scheduled at a non-Dynamed site." | 
|---|
| 51 | I $$ISRUN D  Q | 
|---|
| 52 | .W !,$C(7),"The FCP monitor is already running!" | 
|---|
| 53 | ; | 
|---|
| 54 | ;Go ahead and schedule the task | 
|---|
| 55 | S ZTRTN="RUN^PRCVMON" | 
|---|
| 56 | S ZTDESC="FCP Balance Monitor" | 
|---|
| 57 | S ZTDTH=$H ;right now | 
|---|
| 58 | S ZTIO="" | 
|---|
| 59 | S ZTPRI=3 | 
|---|
| 60 | D ^%ZTLOAD | 
|---|
| 61 | D ISQED^%ZTLOAD | 
|---|
| 62 | I $L($G(ZTSK(0)))>0 D | 
|---|
| 63 | .D SETRUN(1) | 
|---|
| 64 | .W !,"The FCP monitor (task # ",$G(ZTSK),") was scheduled" | 
|---|
| 65 | .W " to run at ",$$HTE^XLFDT(ZTSK("D")) | 
|---|
| 66 | Q | 
|---|
| 67 | ; | 
|---|
| 68 | DIFF(PRCVX,PRCVY) ; | 
|---|
| 69 | N T1,T2,VAL | 
|---|
| 70 | ;check for wrap-around | 
|---|
| 71 | I PRCVY<PRCVX D | 
|---|
| 72 | .S T1=86400-PRCVX | 
|---|
| 73 | .S T2=PRCVY | 
|---|
| 74 | .S VAL=T1+T2 | 
|---|
| 75 | Q:PRCVY<PRCVX VAL | 
|---|
| 76 | S VAL=PRCVY-PRCVX | 
|---|
| 77 | Q VAL | 
|---|
| 78 | ; | 
|---|
| 79 | RUN ; | 
|---|
| 80 | N STAT,FCP,OUT,OUT1,OUT2,FY,FY2,FYIEN,VAL,VAL2,DELTA | 
|---|
| 81 | N I,J,K,IX,IENS,IENS1,IENS2,IENS3,MROOT,PRCVQUIT | 
|---|
| 82 | S PRCVSTRT=$P($H,",",2) | 
|---|
| 83 | S DELTA=0 | 
|---|
| 84 | ;Quit if not a DM site | 
|---|
| 85 | I '$$CHK D  Q | 
|---|
| 86 | .D SETRUN(0) | 
|---|
| 87 | N $ET,$ES S $ET="D TRAP^PRCVMON" | 
|---|
| 88 | ; | 
|---|
| 89 | D INIT ;initialize 414.03 from 420 (one time only) | 
|---|
| 90 | S PRCVQUIT=0 | 
|---|
| 91 | ;loop through the active subscriptions | 
|---|
| 92 | LOOP ; | 
|---|
| 93 | H 1 ;breathing room | 
|---|
| 94 | ;Asked to stop? | 
|---|
| 95 | S:$D(PRCVEND) DELTA=+$G(DELTA)+$$DIFF(PRCVSTRT,PRCVEND) | 
|---|
| 96 | I +$G(DELTA)'<120 D | 
|---|
| 97 | .I $$S^%ZTLOAD S PRCVQUIT=1 | 
|---|
| 98 | .I $$SHLDSTP S PRCVQUIT=1 | 
|---|
| 99 | .S PRCVSTRT=$P($H,",",2) | 
|---|
| 100 | .S DELTA=0 | 
|---|
| 101 | G:PRCVQUIT DONE | 
|---|
| 102 | ONCE ; | 
|---|
| 103 | S VAL=$NA(^TMP("PRCVAL",$J)) ;values from 420 | 
|---|
| 104 | S VAL2=$NA(^TMP("PRCVAL2",$J)) ;values from 414.03 | 
|---|
| 105 | ; | 
|---|
| 106 | ;for each subscription type | 
|---|
| 107 | S I="" | 
|---|
| 108 | F  S I=$O(^PRCV(414.03,"AC",1,I)) Q:I=""  D | 
|---|
| 109 | .S IENS=I_"," | 
|---|
| 110 | .D GETS^DIQ(414.03,IENS,"@;.01;.02","I","OUT") | 
|---|
| 111 | .S STAT=$G(OUT(414.03,IENS,.01,"I")) | 
|---|
| 112 | .S FCP=$G(OUT(414.03,IENS,.02,"I")) | 
|---|
| 113 | .K OUT | 
|---|
| 114 | .;get a list of values from file 420 | 
|---|
| 115 | .S IENS1=","_FCP_","_STAT_"," | 
|---|
| 116 | .D LIST^DIC(420.06,IENS1,"@;.01;1;2;3;4","P",,,,"B",,,"OUT1") | 
|---|
| 117 | .S J="" | 
|---|
| 118 | .F  S J=$O(OUT1("DILIST",J)) Q:J=""  D | 
|---|
| 119 | ..S FYIEN=$P($G(OUT1("DILIST",J,0)),"^",1) | 
|---|
| 120 | ..S FY=$P($G(OUT1("DILIST",J,0)),"^",2) | 
|---|
| 121 | ..I $$FY4(FY)'<$$GETFY D | 
|---|
| 122 | ...S @VAL@(STAT,FY,FCP,1)=$P($G(OUT1("DILIST",J,0)),"^",3) | 
|---|
| 123 | ...S @VAL@(STAT,FY,FCP,2)=$P($G(OUT1("DILIST",J,0)),"^",4) | 
|---|
| 124 | ...S @VAL@(STAT,FY,FCP,3)=$P($G(OUT1("DILIST",J,0)),"^",5) | 
|---|
| 125 | ...S @VAL@(STAT,FY,FCP,4)=$P($G(OUT1("DILIST",J,0)),"^",6) | 
|---|
| 126 | .K OUT1 | 
|---|
| 127 | .S K=0 | 
|---|
| 128 | .F  S K=$O(^PRCV(414.03,I,1,K)) Q:+K'>0  D | 
|---|
| 129 | ..S IENS2=K_","_I_"," | 
|---|
| 130 | ..S FY2=$$GET1^DIQ(414.031,IENS2,.01) | 
|---|
| 131 | ..S IENS3=","_IENS2 | 
|---|
| 132 | ..D LIST^DIC(414.0311,IENS3,"@;.01;1","P",,,,"B",,,"OUT2","MROOT") | 
|---|
| 133 | ..I $$FY4(FY2)'<$$GETFY D | 
|---|
| 134 | ...F IX=1:1:4 D | 
|---|
| 135 | ....S @VAL2@(STAT,FY2,FCP,IX)=$P($G(OUT2("DILIST",IX,0)),"^",3) | 
|---|
| 136 | ...K OUT2 | 
|---|
| 137 | ;Reset the values in 414.03 | 
|---|
| 138 | ;The old values are not needed, as they have been captured in ^TMP. | 
|---|
| 139 | D RESET(VAL) | 
|---|
| 140 | ;Now, compare the values | 
|---|
| 141 | D COMP2(VAL,VAL2) | 
|---|
| 142 | K @VAL,@VAL2 | 
|---|
| 143 | H 10 ;breathing room | 
|---|
| 144 | S PRCVEND=$P($H,",",2) ;seconds since midnight | 
|---|
| 145 | Q:'$D(PRCVQUIT) | 
|---|
| 146 | G LOOP | 
|---|
| 147 | DONE ; | 
|---|
| 148 | K PRCVSTRT,PRCVEND | 
|---|
| 149 | D SETRUN(0) | 
|---|
| 150 | Q | 
|---|
| 151 | ; | 
|---|
| 152 | COMP2(PRCVNEW,PRCVOLD) ; | 
|---|
| 153 | N STAT,FY,FCP,PRCVTMP1,PRCVTMP2 | 
|---|
| 154 | S STAT="" | 
|---|
| 155 | F  S STAT=$O(@PRCVNEW@(STAT)) Q:STAT=""  D | 
|---|
| 156 | .S FY="" | 
|---|
| 157 | .F  S FY=$O(@PRCVNEW@(STAT,FY)) Q:FY=""  D | 
|---|
| 158 | ..S FCP="" | 
|---|
| 159 | ..F  S FCP=$O(@PRCVNEW@(STAT,FY,FCP)) Q:FCP=""  D | 
|---|
| 160 | ...K PRCVTMP1,PRCVTMP2 | 
|---|
| 161 | ...M PRCVTMP1=@PRCVNEW@(STAT,FY,FCP) | 
|---|
| 162 | ...M PRCVTMP2=@PRCVOLD@(STAT,FY,FCP) | 
|---|
| 163 | ...D CHECK(.PRCVTMP1,.PRCVTMP2,STAT,FY,FCP) | 
|---|
| 164 | K PRCVTMP1,PRCVTMP2 | 
|---|
| 165 | Q | 
|---|
| 166 | ; | 
|---|
| 167 | CHECK(PRCVNBAL,PRCVOBAL,PRCVSTAT,PRCVFY,PRCVCP) ; | 
|---|
| 168 | N I,CHG | 
|---|
| 169 | Q:$$FY4(PRCVFY)<$$GETFY  ;don't send anything for past years | 
|---|
| 170 | S CHG=0 ;assume no change | 
|---|
| 171 | F I=1:1:4 I +$G(PRCVNBAL(I))'=+$G(PRCVOBAL(I)) S CHG=1 | 
|---|
| 172 | I CHG D SEND(PRCVSTAT,PRCVFY,PRCVCP,.PRCVNBAL) | 
|---|
| 173 | Q | 
|---|
| 174 | ; | 
|---|
| 175 | SEND(PRCVSTAT,PRCVFY,PRCVCP,PRCVBAL) ; | 
|---|
| 176 | N OBJ,PROTO,MYOPTNS,MYRES | 
|---|
| 177 | S OBJ=$NA(^TMP($J,"PRCV_FBAL")) | 
|---|
| 178 | S @OBJ@("TIME")=$$NOW^XLFDT | 
|---|
| 179 | S @OBJ@("STAT")=$G(PRCVSTAT) | 
|---|
| 180 | S @OBJ@("FCP_NUM")=$G(PRCVCP) | 
|---|
| 181 | S @OBJ@("FY")=$G(PRCVFY) | 
|---|
| 182 | S @OBJ@("1QBAL")=$G(PRCVBAL(1)) | 
|---|
| 183 | S @OBJ@("2QBAL")=$G(PRCVBAL(2)) | 
|---|
| 184 | S @OBJ@("3QBAL")=$G(PRCVBAL(3)) | 
|---|
| 185 | S @OBJ@("4QBAL")=$G(PRCVBAL(4)) | 
|---|
| 186 | D BLD1^PRCVBLD(OBJ) | 
|---|
| 187 | S PROTO="PRCV_DYNAMED_22_EV_FUND_BAL_DATA" | 
|---|
| 188 | S MYOPTNS("NAMESPACE")="PRCV" | 
|---|
| 189 | D GENERATE^HLMA(PROTO,"GM",1,.MYRES,,.MYOPTNS) | 
|---|
| 190 | K @OBJ | 
|---|
| 191 | Q | 
|---|
| 192 | ; | 
|---|
| 193 | ;Update 414.03 | 
|---|
| 194 | UPD(PRCVSTAT,PRCVFCP,PRCVFY,PRCVBAL) ; | 
|---|
| 195 | N OUT,VAL,IEN,IENS1,IENS2,MYFDA,I | 
|---|
| 196 | N MROOT | 
|---|
| 197 | S VAL(1)=PRCVSTAT | 
|---|
| 198 | S VAL(2)=PRCVFCP | 
|---|
| 199 | S VAL(3)=1 | 
|---|
| 200 | D FIND^DIC(414.03,,"@;.01;.02;.03","KX",.VAL,,,,,"OUT","MROOT") | 
|---|
| 201 | S IEN=$G(OUT("DILIST",2,1)) | 
|---|
| 202 | S IENS1="?+1"_","_IEN_"," | 
|---|
| 203 | S MYFDA(414.031,IENS1,.01)=PRCVFY | 
|---|
| 204 | S I="" | 
|---|
| 205 | F  S I=$O(PRCVBAL(I)) Q:I=""  D | 
|---|
| 206 | .S IENS2="?+"_(I+1)_","_IENS1 | 
|---|
| 207 | .S MYFDA(414.0311,IENS2,.01)=I | 
|---|
| 208 | .S MYFDA(414.0311,IENS2,1)=$G(PRCVBAL(I)) | 
|---|
| 209 | D UPDATE^DIE("EK","MYFDA",,"MROOT") | 
|---|
| 210 | Q | 
|---|
| 211 | ; | 
|---|
| 212 | TRAP ; | 
|---|
| 213 | ;clear the 'run' flag | 
|---|
| 214 | D SETRUN(0) | 
|---|
| 215 | ;Have the temporary globals been deleted? | 
|---|
| 216 | S VAL=$G(VAL),VAL2=$G(VAL2) | 
|---|
| 217 | I VAL?1"^".E1"(".E K @VAL | 
|---|
| 218 | I VAL2?1"^".E1"(".E K @VAL2 | 
|---|
| 219 | D ^%ZTER | 
|---|
| 220 | D UNWIND^%ZTER | 
|---|
| 221 | Q | 
|---|
| 222 | ; | 
|---|
| 223 | ;Provide a convenient way to enable/disable monitor | 
|---|
| 224 | GETSTAT() ; | 
|---|
| 225 | N PRMY,IENS | 
|---|
| 226 | S PRMY=$$PSTAT | 
|---|
| 227 | S IENS=PRMY_"," | 
|---|
| 228 | Q +$$GET1^DIQ(411,IENS,106,"I") | 
|---|
| 229 | ; | 
|---|
| 230 | SETSTAT(PRCVST) ; | 
|---|
| 231 | N FDA,IENS,PRMY,STATE | 
|---|
| 232 | S PRCVST=$G(PRCVST) | 
|---|
| 233 | S STATE=$$EXTERNAL^DILFD(411,106,,PRCVST) | 
|---|
| 234 | I STATE="" D  Q | 
|---|
| 235 | .W:IO=IO(0) !,"Invalid status!" | 
|---|
| 236 | W:IO=IO(0) !,"Setting status to ",STATE | 
|---|
| 237 | S PRMY=$$PSTAT | 
|---|
| 238 | S IENS=PRMY_"," | 
|---|
| 239 | S FDA(411,IENS,106)=PRCVST | 
|---|
| 240 | D UPDATE^DIE("","FDA") | 
|---|
| 241 | Q | 
|---|
| 242 | ; | 
|---|
| 243 | SETRUN(PRCVST) ; | 
|---|
| 244 | N FDA,IENS,PRMY | 
|---|
| 245 | S PRCVST=+$G(PRCVST) | 
|---|
| 246 | Q:((PRCVST'=0)&(PRCVST'=1)) | 
|---|
| 247 | S PRMY=$$PSTAT | 
|---|
| 248 | S IENS=PRMY_"," | 
|---|
| 249 | S FDA(411,IENS,107)=PRCVST | 
|---|
| 250 | D UPDATE^DIE("","FDA") | 
|---|
| 251 | Q | 
|---|
| 252 | ISRUN() ; | 
|---|
| 253 | N PRMY,IENS | 
|---|
| 254 | S PRMY=$$PSTAT | 
|---|
| 255 | S IENS=PRMY_"," | 
|---|
| 256 | Q +$$GET1^DIQ(411,IENS,107,"I") | 
|---|
| 257 | ; | 
|---|
| 258 | GETFY() ; | 
|---|
| 259 | N DATE,YEAR,MON,FY | 
|---|
| 260 | ;Get the calendar year | 
|---|
| 261 | S DATE=$$DT^XLFDT | 
|---|
| 262 | S YEAR=($E(DATE,1)+17)*100+$E(DATE,2,3) | 
|---|
| 263 | S MON=+$E(DATE,4,5) | 
|---|
| 264 | S FY=$S(MON>9:YEAR+1,1:YEAR) | 
|---|
| 265 | Q FY | 
|---|
| 266 | ; | 
|---|
| 267 | FY4(PRCVFY) ; | 
|---|
| 268 | I $L(PRCVFY)'<4 Q PRCVFY | 
|---|
| 269 | I +$G(PRCVFY)'<30 Q 1900+PRCVFY | 
|---|
| 270 | Q 2000+PRCVFY | 
|---|
| 271 | ; | 
|---|
| 272 | ;Various simple checks | 
|---|
| 273 | CHK() ; | 
|---|
| 274 | Q $$GET^XPAR("SYS","PRCV COTS INVENTORY",1,"Q") | 
|---|
| 275 | ; | 
|---|
| 276 | ;Primary station | 
|---|
| 277 | PSTAT() ; | 
|---|
| 278 | N PRMY | 
|---|
| 279 | I '$D(^PRC(411,"AC","Y")) Q 0  ;no primary station in x-ref | 
|---|
| 280 | Q $O(^PRC(411,"AC","Y","")) | 
|---|
| 281 | ; | 
|---|
| 282 | ;Should the monitor stop? | 
|---|
| 283 | SHLDSTP() ; | 
|---|
| 284 | N FLG | 
|---|
| 285 | S FLG=$$GETSTAT | 
|---|
| 286 | Q $S(FLG=0:1,FLG=1:0,FLG=2:1,1:1) | 
|---|
| 287 | ; | 
|---|
| 288 | PUSH1(PRCVSTAT,PRCVFY,PRCVCP) ; | 
|---|
| 289 | N OBJ,PROTO,MYOPTNS,MYRES | 
|---|
| 290 | S OBJ=$NA(^TMP($J,"PRCV_FBAL")) | 
|---|
| 291 | S @OBJ@("TIME")=$$NOW^XLFDT | 
|---|
| 292 | S @OBJ@("STAT")=$G(PRCVSTAT) | 
|---|
| 293 | S @OBJ@("FCP_NUM")=$G(PRCVCP) | 
|---|
| 294 | S @OBJ@("FY")=$G(PRCVFY) | 
|---|
| 295 | S @OBJ@("1QBAL")=+$P($G(^PRC(420,PRCVSTAT,1,PRCVCP,4,PRCVFY,0)),"^",2) | 
|---|
| 296 | S @OBJ@("2QBAL")=+$P($G(^PRC(420,PRCVSTAT,1,PRCVCP,4,PRCVFY,0)),"^",3) | 
|---|
| 297 | S @OBJ@("3QBAL")=+$P($G(^PRC(420,PRCVSTAT,1,PRCVCP,4,PRCVFY,0)),"^",4) | 
|---|
| 298 | S @OBJ@("4QBAL")=+$P($G(^PRC(420,PRCVSTAT,1,PRCVCP,4,PRCVFY,0)),"^",5) | 
|---|
| 299 | D BLD1^PRCVBLD(OBJ) | 
|---|
| 300 | S PROTO="PRCV_DYNAMED_22_EV_FUND_BAL_DATA" | 
|---|
| 301 | S MYOPTNS("NAMESPACE")="PRCV" | 
|---|
| 302 | D GENERATE^HLMA(PROTO,"GM",1,.MYRES,,.MYOPTNS) | 
|---|
| 303 | ;W:IO=IO(0) !,"Message generated: ",$P(MYRES,"^",1) | 
|---|
| 304 | K @OBJ | 
|---|
| 305 | Q | 
|---|