[623] | 1 | SDRPA06 ;bp-oifo/swo pait hl7 ack handling ; 10/31/04 3:53pm
|
---|
| 2 | ;;5.3;Scheduling;**290,333,349,376**;AUG 13, 1993
|
---|
| 3 | ;routine called from Vista HL7 when ack messages are received in response
|
---|
| 4 | ;to an out going HL7 message generated by protocol SC-PAIT-EVENT
|
---|
| 5 | ACK ;entry point from Vista HL7
|
---|
| 6 | ;ACKDATE : date/time ack received
|
---|
| 7 | ;FLDSEP : field separator
|
---|
| 8 | ;CMPNTSEP : component separator
|
---|
| 9 | ;REPTNSEP : repetition separator
|
---|
| 10 | ;ACKCODE : acknowledgement code
|
---|
| 11 | ;ERROR : reject reason
|
---|
| 12 | ;BATCHID : batch control ID
|
---|
| 13 | ;BATCHIDO : original batch control ID
|
---|
| 14 | N ACKCODE,ACKDATE,BATCHID,BATCHIDO,CMPNTSEP,ERROR,FLDSEP,REPTNSEP,RUNIEN,SDZAP,V1
|
---|
| 15 | ;disable automatic repair of the last run, not needed to process acks
|
---|
| 16 | ;NHD will be notified when the completion message does not come out
|
---|
| 17 | ;D RSTAT^SDRPA02 ;check the status of the last run
|
---|
| 18 | K ^TMP("SDRPA06",$J)
|
---|
| 19 | S SDZAP=0
|
---|
| 20 | S ACKDATE=$$NOW^XLFDT()
|
---|
| 21 | S FLDSEP=HL("FS")
|
---|
| 22 | S CMPNTSEP=$E(HL("ECH"),1)
|
---|
| 23 | S REPTNSEP=$E(HL("ECH"),2)
|
---|
| 24 | S ACKCODE=$P(HLMSA,FLDSEP)
|
---|
| 25 | S ERROR=$P(HLMSA,FLDSEP,4)
|
---|
| 26 | S (BATCHID,BATCHIDO)=$P(HLMSA,FLDSEP,2)
|
---|
| 27 | S RUNIEN=$$RUNIEN(BATCHIDO) Q:'RUNIEN
|
---|
| 28 | S BATCHID=$$OURB(RUNIEN,BATCHIDO) ;convert to our batch id
|
---|
| 29 | Q:'BATCHID ;error needs to be handled
|
---|
| 30 | ;S V1=$O(^SDWL(409.6,"AMSG",BATCHID,"")),RUNIEN=$O(^SDWL(409.6,"AMSG",BATCHID,V1,""))
|
---|
| 31 | S V1=$O(^SDWL(409.6,"AMSG",BATCHID,"")) Q:V1=""
|
---|
| 32 | Q:'$$DUP^SDRPA02(RUNIEN,BATCHIDO) ;check for duplicate
|
---|
| 33 | S ^XTMP("SDRPA-"_BATCHID,0)=$$FMADD^XLFDT($$DT^XLFDT(),3)_"^"_$$DT^XLFDT() ;set xtmp global for diagnostics
|
---|
| 34 | I $E(ACKCODE,1,2)="AR" D AR(BATCHID,BATCHIDO),MSG(BATCHIDO,3,RUNIEN,BATCHID) Q ;whole batch rejection
|
---|
| 35 | ;Q:($E(ACKCODE,1,2)'="AA") ;quit if not a application ack
|
---|
| 36 | ;will only be 2 ACKCODEs AA and AE so don't have to screen anymore
|
---|
| 37 | F X HLNEXT Q:(HLQUIT'>0) D ;start looping the msg text
|
---|
| 38 | . Q:($E(HLNODE,1,3)'="MSA") ;skip if not a MSA segment
|
---|
| 39 | . I $P(HLNODE,FLDSEP,2)="AE" D ;it's an error
|
---|
| 40 | .. Q:($P($P(HLNODE,FLDSEP,3),"-",2))="" ;no message number
|
---|
| 41 | .. S ^TMP("SDRPA06",$J,+$P($P(HLNODE,FLDSEP,3),"-",2))=+$P(HLNODE,"^",4) ;set xref with message #
|
---|
| 42 | I '$D(^TMP("SDRPA06",$J)) D AA(BATCHID,BATCHIDO),MSG(BATCHIDO,2,RUNIEN,BATCHID) Q ;whole batch accept
|
---|
| 43 | D AAAR(BATCHID,BATCHIDO),MSG(BATCHIDO,1,RUNIEN,BATCHID) ;batch accept with errors
|
---|
| 44 | Q
|
---|
| 45 | AR(BATCH,BATCHIDO) ;whole batch rejection
|
---|
| 46 | ;BATCH : originating batch number
|
---|
| 47 | ;BATCHIDO : original batch number from HL7 ACK
|
---|
| 48 | ;V1 : sequence # (individual message number in batch)
|
---|
| 49 | ;V2 : run # (ien of multiple entry)
|
---|
| 50 | ;V3 : ien (ien in patient multiple)
|
---|
| 51 | ;V4 : ien (ien batch tracking multiple)
|
---|
| 52 | Q:($G(BATCH)="")
|
---|
| 53 | N DA,DIE,DR,V1,V2,V3,V4,ZNODE
|
---|
| 54 | S V1=0
|
---|
| 55 | F S V1=$O(^SDWL(409.6,"AMSG",BATCH,V1)) Q:'V1 D
|
---|
| 56 | . S V2=$O(^SDWL(409.6,"AMSG",BATCH,V1,"")) Q:'V2
|
---|
| 57 | . ;batch tracking enhancement
|
---|
| 58 | . S V4=$O(^SDWL(409.6,V2,2,"B",BATCHIDO,"")) Q:'V4 D
|
---|
| 59 | .. S DA=V4,DA(1)=V2,DIE="^SDWL(409.6,"_V2_",2,",DR=".04///"_$$NOW^XLFDT_";.05///"_ACKCODE
|
---|
| 60 | .. D ^DIE K DIE
|
---|
| 61 | . S V3=0 F S V3=$O(^SDWL(409.6,"AMSG",BATCH,V1,V2,V3)) Q:'V3 D
|
---|
| 62 | .. S ZNODE=$G(^SDWL(409.6,V2,1,V3,0)) Q:ZNODE=""
|
---|
| 63 | .. ;4TH PIECE IS MESSAGE NUMBER
|
---|
| 64 | .. S DA=V3,DA(1)=V2,DIE="^SDWL(409.6,"_V2_",1,"
|
---|
| 65 | .. S DR="7////"_$O(^SCPT(404.472,"B","R","")) D ^DIE
|
---|
| 66 | .. I $D(^SDWL(409.6,"AE","Y",V2,V3)) Q
|
---|
| 67 | .. I $D(^SDWL(409.6,"AE","N",V2,V3)) D
|
---|
| 68 | ... S DR="4///Y" D ^DIE
|
---|
| 69 | Q
|
---|
| 70 | AA(BATCH,BATCHIDO) ;whole batch accept
|
---|
| 71 | ;if the batch is accepted and no rejections then get the run # sequence #
|
---|
| 72 | ;from AMSG xref. If no "AE","Y" xref then call DIK to delete the entry
|
---|
| 73 | ;BATCH : originating batch number
|
---|
| 74 | ;BATCHIDO : original batch number from HL7 ACK
|
---|
| 75 | ;V1 : sequence # (individual message number in batch)
|
---|
| 76 | ;V2 : run # (ien of multiple entry)
|
---|
| 77 | ;V3 : ien (ien in patient multiple)
|
---|
| 78 | ;V4 : ien (ien batch tracking multiple)
|
---|
| 79 | Q:($G(BATCH)="")
|
---|
| 80 | N DA,DIK,DR,V1,V2,V3,V4,ZNODE
|
---|
| 81 | S V1=0
|
---|
| 82 | F S V1=$O(^SDWL(409.6,"AMSG",BATCH,V1)) Q:'V1 D
|
---|
| 83 | . S V2=$O(^SDWL(409.6,"AMSG",BATCH,V1,"")) Q:'V2
|
---|
| 84 | . ;batch tracking enhancement
|
---|
| 85 | . S V4=$O(^SDWL(409.6,V2,2,"B",BATCHIDO,"")) Q:'V4 D
|
---|
| 86 | .. S DA=V4,DA(1)=V2,DIE="^SDWL(409.6,"_V2_",2,",DR=".04///"_$$NOW^XLFDT_";.05///"_ACKCODE
|
---|
| 87 | .. D ^DIE K DIE
|
---|
| 88 | . S V3=0 F S V3=$O(^SDWL(409.6,"AMSG",BATCH,V1,V2,V3)) Q:'V3 D
|
---|
| 89 | .. S ZNODE=$G(^SDWL(409.6,V2,1,V3,0)) Q:ZNODE=""
|
---|
| 90 | .. ;4th piece is the message #
|
---|
| 91 | .. I '$D(^SDWL(409.6,"AE","Y",V2,V3)) D
|
---|
| 92 | ... S DIK="^SDWL(409.6,"_V2_",1,"
|
---|
| 93 | ... S DA(1)=V2,DA=V3 D ^DIK
|
---|
| 94 | ... S ^XTMP("SDRPA-"_BATCH,+$P(ZNODE,"^",4),0)=ZNODE ;diagnostics
|
---|
| 95 | Q
|
---|
| 96 | AAAR(BATCH,BATCHIDO) ;batch accept with errors
|
---|
| 97 | ;BATCH : originating batch number
|
---|
| 98 | ;BATCHIDO : original batch number from HL7 ACK
|
---|
| 99 | ;V1 : sequence # (individual message number in batch)
|
---|
| 100 | ;V2 : run # (ien of multiple entry)
|
---|
| 101 | ;V3 : ien (ien in patient multiple)
|
---|
| 102 | ;V4 : ien (ien batch tracking multiple))
|
---|
| 103 | Q:($G(BATCH)="")
|
---|
| 104 | N DA,DIK,DR,V1,V2,V3,V4,ZNODE
|
---|
| 105 | S V1=0
|
---|
| 106 | F S V1=$O(^SDWL(409.6,"AMSG",BATCH,V1)) Q:'V1 D
|
---|
| 107 | . S V2=$O(^SDWL(409.6,"AMSG",BATCH,V1,"")) Q:'V2
|
---|
| 108 | . ;batch tracking enhancement
|
---|
| 109 | . S V4=$O(^SDWL(409.6,V2,2,"B",BATCHIDO,"")) Q:'V4 D
|
---|
| 110 | .. S DA=V4,DA(1)=V2,DIE="^SDWL(409.6,"_V2_",2,",DR=".04///"_$$NOW^XLFDT_";.05///"_ACKCODE
|
---|
| 111 | .. D ^DIE K DIE
|
---|
| 112 | . S V3=0 F S V3=$O(^SDWL(409.6,"AMSG",BATCH,V1,V2,V3)) Q:'V3 D
|
---|
| 113 | .. S ZNODE=$G(^SDWL(409.6,V2,1,V3,0)) Q:ZNODE=""
|
---|
| 114 | .. ;4th piece is the message #
|
---|
| 115 | .. ;next line screens for accepted batch + accepted message + status final and can be deleted
|
---|
| 116 | .. I '$D(^SDWL(409.6,"AE","Y",V2,V3))&('$D(^TMP("SDRPA06",$J,$P(ZNODE,"^",4)))) D
|
---|
| 117 | ... S DIK="^SDWL(409.6,"_V2_",1,"
|
---|
| 118 | ... S DA(1)=V2,DA=V3 D ^DIK
|
---|
| 119 | ... S ^XTMP("SDRPA-"_BATCH,+$P(ZNODE,"^",4),0)=ZNODE ;diagnostics
|
---|
| 120 | .. ;next line screens for accepted batch + error message
|
---|
| 121 | .. I $D(^TMP("SDRPA06",$J,$P(ZNODE,"^",4))) D
|
---|
| 122 | ... S DA=V3,DA(1)=V2,DIE="^SDWL(409.6,"_V2_",1,"
|
---|
| 123 | ... S DR="7////"_$O(^SCPT(404.472,"B",$G(^TMP("SDRPA06",$J,$P(ZNODE,"^",4))),"")) D ^DIE
|
---|
| 124 | ... I $D(^SDWL(409.6,"AE","Y",V2,V3)) Q
|
---|
| 125 | ... I $D(^SDWL(409.6,"AE","N",V2,V3)) D
|
---|
| 126 | .... S DR="4///Y" D ^DIE
|
---|
| 127 | Q
|
---|
| 128 | CLEAN(RUN) ;housekeeping
|
---|
| 129 | ;clean up batch previous to current one by checking for "AE",("S" or "R") xref and
|
---|
| 130 | ;deleting if entry in xref exists
|
---|
| 131 | ;RUN : run # (ien of multiple entry)
|
---|
| 132 | ;V1 : previous run # (ien of multiple entry)
|
---|
| 133 | ;V2 : ien (ien in multiple)
|
---|
| 134 | Q:($G(RUN)="")
|
---|
| 135 | N V1,V2,V3
|
---|
| 136 | S V1=$O(^SDWL(409.6,RUN),-1) Q:'V1
|
---|
| 137 | F V3="R","S" S V2=0 F S V2=$O(^SDWL(409.6,"AE",V3,V1,V2)) Q:'V2 D
|
---|
| 138 | . S ZNODE=$G(^SDWL(409.6,V1,1,V2,0))
|
---|
| 139 | . S DIK="^SDWL(409.6,"_V1_",1,"
|
---|
| 140 | . S DA(1)=V1,DA=V2 D ^DIK
|
---|
| 141 | . S ^XTMP("SDRPA-"_$P(ZNODE,"^",3),"CLEAN",+$P(ZNODE,"^",4),0)=ZNODE ;diagnostics
|
---|
| 142 | Q
|
---|
| 143 | MSG(BATCHIDO,TYPE,RUNIEN,BATCHID) ;acknowledgement notification to mail group
|
---|
| 144 | ;BATCHID : Our Message ID
|
---|
| 145 | ;BATCHIDO: Batch Control ID
|
---|
| 146 | ;TYPE : type of message (accept with rejects - 1, whole accept 2, whole reject -3)
|
---|
| 147 | ;RUNIEN : run ien associated with this batch
|
---|
| 148 | ;SDAMX : message text array
|
---|
| 149 | ;XMSUB : subject
|
---|
| 150 | ;XMY : addressee
|
---|
| 151 | ;XMTEXT : location of text array
|
---|
| 152 | ;XMDUZ : sender of the message
|
---|
| 153 | ;RUNZ : zero node of run associated with this batch
|
---|
| 154 | N RUNZ,SDAMX,V0,V1,V2,V3,XMSUB,XMY,XMTEXT,XMDUZ
|
---|
| 155 | Q:BATCHID=""
|
---|
| 156 | S V0=$P($G(^SDWL(409.6,RUNIEN,2,0)),"^",4)
|
---|
| 157 | S (V1,V3)=0 F S V1=$O(^SDWL(409.6,RUNIEN,2,V1)) Q:'V1 D
|
---|
| 158 | . S V2=$P($G(^SDWL(409.6,RUNIEN,2,V1,0)),"^",4)
|
---|
| 159 | . S:V2'="" V3=V3+1
|
---|
| 160 | . ;S V3=V3+1
|
---|
| 161 | S RUNZ=$G(^SDWL(409.6,RUNIEN,0))
|
---|
| 162 | S XMSUB="PAIT BATCH ACKNOWLEGEMENT "_BATCHIDO
|
---|
| 163 | S XMY("G.SD-PAIT")=""
|
---|
| 164 | S XMY("S.SD-PAIT-SERVER@FORUM.VA.GOV")=""
|
---|
| 165 | S XMTEXT="SDAMX("
|
---|
| 166 | S XMDUZ="POSTMASTER"
|
---|
| 167 | I TYPE=1 D
|
---|
| 168 | . S SDAMX(1)=" Station Number: "_$P($$SITE^VASITE(),"^",3)
|
---|
| 169 | . S SDAMX(2)="Batch Control ID: "_BATCHIDO
|
---|
| 170 | . S SDAMX(3)=" Message ID: "_BATCHID
|
---|
| 171 | . S SDAMX(4)=" Log Entry: "_RUNIEN
|
---|
| 172 | . S SDAMX(5)=" Run Date: "_$$FMTE^XLFDT($P(RUNZ,"^",7))
|
---|
| 173 | . S SDAMX(6)=" Status: Acknowledged - with rejections "
|
---|
| 174 | . S SDAMX(7)=" "_V3_" of "_V0_" ACKs received for this run date"
|
---|
| 175 | . S SDAMX(8)=""
|
---|
| 176 | . S SDAMX(9)="Use option SD-PAIT REJECTED Rejected Transmissions to view the rejections."
|
---|
| 177 | I TYPE=2 D
|
---|
| 178 | . S SDAMX(1)=" Station Number: "_$P($$SITE^VASITE(),"^",3)
|
---|
| 179 | . S SDAMX(2)="Batch Control ID: "_BATCHIDO
|
---|
| 180 | . S SDAMX(3)=" Message ID: "_BATCHID
|
---|
| 181 | . S SDAMX(4)=" Log Entry: "_RUNIEN
|
---|
| 182 | . S SDAMX(5)=" Run Date: "_$$FMTE^XLFDT($P(RUNZ,"^",7))
|
---|
| 183 | . S SDAMX(6)=" Status: Acknowledged - No Rejections"
|
---|
| 184 | . S SDAMX(7)=" "_V3_" of "_V0_" ACKs received for this run date"
|
---|
| 185 | I TYPE=3 D
|
---|
| 186 | . S SDAMX(1)=" Station Number: "_$P($$SITE^VASITE(),"^",3)
|
---|
| 187 | . S SDAMX(2)="Batch Control ID: "_BATCHIDO
|
---|
| 188 | . S SDAMX(3)=" Message ID: "_BATCHID
|
---|
| 189 | . S SDAMX(4)=" Log Entry: "_RUNIEN
|
---|
| 190 | . S SDAMX(5)=" Run Date: "_$$FMTE^XLFDT($P(RUNZ,"^",7))
|
---|
| 191 | . S SDAMX(6)=" Status: Acknowledged - Entire Batch Rejected"
|
---|
| 192 | . S SDAMX(7)=" "_V3_" of "_V0_" ACKs received for this run date"
|
---|
| 193 | D ^XMD
|
---|
| 194 | Q
|
---|
| 195 | OURB(RUNIEN,BATCHIDO) ;match batch id to msg control id ("AMSG" xref)
|
---|
| 196 | ;RUNIEN : the ien in file 409.6 of the run
|
---|
| 197 | ;BATCHIDO : batchid pulled from the ACK message
|
---|
| 198 | ;V2 : returns 0 if none, or msg control id
|
---|
| 199 | N V1,V2,VNODE
|
---|
| 200 | S V2=0
|
---|
| 201 | I '$G(RUNIEN) Q V2
|
---|
| 202 | I '$G(BATCHIDO) Q V2
|
---|
| 203 | I $G(^SDWL(409.6,RUNIEN,2,0))="" Q V2
|
---|
| 204 | S V1=0 F S V1=$O(^SDWL(409.6,RUNIEN,2,"B",BATCHIDO,V1)) Q:'V1 D
|
---|
| 205 | . S VNODE=$G(^SDWL(409.6,RUNIEN,2,V1,0)) Q:VNODE=""
|
---|
| 206 | . I $P(VNODE,"^",3)="" Q
|
---|
| 207 | . S V2=$P(VNODE,"^",3) Q
|
---|
| 208 | Q V2
|
---|
| 209 | RUNIEN(BATCHID) ;get runien
|
---|
| 210 | N V1,V2
|
---|
| 211 | S V2=0
|
---|
| 212 | S V1=999999999 F S V1=$O(^SDWL(409.6,V1),-1) Q:'V1!(V2) D
|
---|
| 213 | . I $O(^SDWL(409.6,V1,2,"B",BATCHID,"")) S V2=V1 Q
|
---|
| 214 | Q V2
|
---|