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
|
---|