-
Notifications
You must be signed in to change notification settings - Fork 6
/
VPRJGDSQ.m
102 lines (102 loc) · 3.92 KB
/
VPRJGDSQ.m
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
VPRJGDSQ ;SLC/KCM/CJE -- Query for JSON objects (Generic Data Store)
;;1.0;JSON DATA STORE;;Sep 01, 2012
;
QKEY(KEY,TEMPLATE) ; Return an object given the key (i.e., urn:va:fresh:93EF:10076)
N VPRDATA,ORDER,GLOBAL,GLOBALJ
S TEMPLATE=$G(TEMPLATE)
; Parsed JSON
S GLOBAL="^"_$G(^VPRCONFIG("store",$G(HTTPREQ("store")),"global"))
; RAW JSON
S GLOBALJ="^"_$G(^VPRCONFIG("store",$G(HTTPREQ("store")),"global"))_"J"
;
I '$D(@GLOBALJ("JSON",KEY)) D SETERROR^VPRJRER(104,"UID:"_KEY) Q
K:$D(^TMP("VPRDATA",$J)) ^TMP("VPRDATA",$J)
S ^TMP("VPRDATA",$J,KEY,0)="",VPRDATA=1,ORDER(0)=0
D BUILD^VPRJCB
K:$D(^TMP("VPRDATA",$J)) ^TMP("VPRDATA",$J)
Q
;
QCOUNT(CNTNM) ; Return a set of counts across patients
; return tallies as data:{items:[{"topic":"med","count":4}
N BUFFER,GLOBAL,GLOBALX
S BUFFER=""
; Parsed JSON
S GLOBAL="^"_$G(^VPRCONFIG("store",$G(HTTPREQ("store")),"global"))
; Index
S GLOBALX="^"_$G(^VPRCONFIG("store",$G(HTTPREQ("store")),"global"))_"X"
;
K:$D(^TMP($J)) ^TMP($J)
;
N TOPIC,DATA,COUNT,X
S DATA=0,TOPIC=""
F S TOPIC=$O(@GLOBALX@("count",CNTNM,TOPIC)) Q:TOPIC="" D
. S COUNT=+@GLOBALX@("count",CNTNM,TOPIC)
. S X=$S('DATA:"",1:",")_"{""topic"":"""_TOPIC_""",""count"":"_COUNT_"}"
. S DATA=DATA+1,DATA(DATA)=X
S X=$$BLDHEAD^VPRJCB(DATA) D STAGE^VPRJCB(X)
S DATA=0 F S DATA=$O(DATA(DATA)) Q:'DATA D STAGE^VPRJCB(DATA(DATA))
D STAGE^VPRJCB("]}}"),OUT^VPRJCB
Q
QTALLY(CNTNM) ; Return a set of counts
; return tallies as data:{items:[{"topic":"MEDICATION,INPT","count":4}
I '$L(CNTNM) D SETERROR^VPRJRER(101) Q
N BUFFER,GLOBAL,GLOBALX
S BUFFER=""
; Parsed JSON
S GLOBAL="^"_$G(^VPRCONFIG("store",$G(HTTPREQ("store")),"global"))
; Index
S GLOBALX="^"_$G(^VPRCONFIG("store",$G(HTTPREQ("store")),"global"))_"X"
;
;
N TOPIC,DATA,COUNT,X
S DATA=0,TOPIC=""
F S TOPIC=$O(@GLOBALX@("tally",CNTNM,TOPIC)) Q:TOPIC="" D
. S COUNT=+@GLOBALX@("tally",CNTNM,TOPIC)
. S X=$S('DATA:"",1:",")_"{""topic"":"""_TOPIC_""",""count"":"_COUNT_"}"
. S DATA=DATA+1,DATA(DATA)=X
S X=$$BLDHEAD^VPRJCB(DATA) D STAGE^VPRJCB(X)
S DATA=0 F S DATA=$O(DATA(DATA)) Q:'DATA D STAGE^VPRJCB(DATA(DATA))
D STAGE^VPRJCB("]}}"),OUT^VPRJCB
Q
;
;defined at the QINDEX level:
; INDEX: Name of the index
; RANGE: range of values, examples: A..Z, GLUCOSE*>2010..2013, A,C,E
; ORDER: sequece of the returned valuse, examples: desc | facilityName asc
; BAIL: maximum number of matches to return
; METHOD: style of index, "attr", "time"
; FILTER: criteria statement to further limit returned results
; CLAUSES: clauses to apply filter to each object
;
QINDEX(INDEX,RANGE,ORDER,BAIL,TEMPLATE,FILTER,SKIPLOCK) ; query based on index
I '$L($G(INDEX)) D SETERROR^VPRJRER(101) Q
N VPRDATA,METHOD,CLAUSES
S RANGE=$G(RANGE),ORDER=$G(ORDER),BAIL=$G(BAIL),TEMPLATE=$G(TEMPLATE),FILTER=$G(FILTER)
S VPRDATA=0 S:'BAIL BAIL=999999
M INDEX=^VPRMETA("index",INDEX,"common")
S METHOD=$G(INDEX("method")) I '$L(METHOD) D SETERROR^VPRJRER(102,INDEX) Q
I $L(FILTER) D PARSE^VPRJCF(FILTER,.CLAUSES) Q:$G(HTTPERR)
D SETORDER^VPRJCO(.ORDER) Q:$G(HTTPERR)
K:$D(^TMP("VPRDATA",$J)) ^TMP("VPRDATA",$J)
I METHOD="attr" D QATTR^VPRJGDSQA
D BUILD^VPRJCB
K:$D(^TMP("VPRDATA",$J)) ^TMP("VPRDATA",$J)
Q
QLAST(INDEX,RANGE,ORDER,BAIL,TEMPLATE,FILTER) ; return most recent item in the list
Q ; NOT IMPLEMENTED
N IDXLAST S IDXLAST=1
D QINDEX(INDEX,$G(RANGE),$G(ORDER),$G(BAIL),$G(TEMPLATE),$G(FILTER))
Q
QFIND(COLL,ORDER,BAIL,TEMPLATE,FILTER) ; return items from collection without index
Q ; NOT IMPLEMENTED
N VPRDATA,CLAUSES,PREFIX,KEY
S ORDER=$G(ORDER),BAIL=$G(BAIL),TEMPLATE=$G(TEMPLATE),FILTER=$G(FILTER)
S VPRDATA=0 S:'BAIL BAIL=999999
I $L(FILTER) D PARSE^VPRJCF(FILTER,.CLAUSES) Q:$G(HTTPERR)
D SETORDER^VPRJCO(.ORDER) Q:$G(HTTPERR)
K:$D(^TMP("VPRDATA",$J)) ^TMP("VPRDATA",$J)
S PREFIX="urn:va:"_COLL_":",KEY=PREFIX
F S KEY=$O(^VPRJD(KEY)) Q:$E(KEY,1,$L(PREFIX))'=PREFIX D ADDONE^VPRJGDSQA(KEY,0)
D BUILD^VPRJCB
K:$D(^TMP("VPRDATA",$J)) ^TMP("VPRDATA",$J)
Q