MSSQL connection status check

######################################################################
# Name:         pgn_rde_to_premier
# Purpose:
# UPoC type:    tps
# Args:         tps keyedlist containing the following keys:
#               MODE    run mode (”start”, “run” or “time”)
#               MSGID   message handle
#               ARGS    user-supplied arguments:
#                      
#
# Returns: tps disposition list:
#

proc pgn_rde_to_premier { args } {

keylget args MODE mode                      ;# Fetch mode

global env

set dispList {}                             ;# Nothing to return
 
set warnCategory pharmacy
set warnGroups [list pharmacists all]

set deferDb pgnToPremierDbTimeoutQueue
 set deferDestination premierRde

set failsafeSendSec 120

switch -exact — $mode {
start {
# Perform special init functions
# N.B.: there may or may not be a MSGID key in args
}

run {
# ‘run’ mode always has a MSGID; fetch and process it

keylget args MSGID mh

set msg [msgget $mh]                                ;# Get message

# Parse message
crmcHL7::parseMsg $msg msgArray

set warnings “”

# Determine if this is a message we want to process
set killMsg 0
set dbQueueErr 0
set msgType [crmcHL7::readSegFieldComponent msgArray MSH 9 1]
switch -exact $msgType {
RDE {

# Added queueing to SQLite DB – 9/4/2014 – jld
#  this prevents problems with failures when the
#  Paragon DB is unavailable – as during an upgrade.

set clMsgIdKeyedList [msgmetaget $mh MID]
set cmid [keylget clMsgIdKeyedList DOMAIN].[keylget clMsgIdKeyedList HUB].[keylget clMsgIdKeyedList NUM]

if { ! [crmcDeferMsgsDb::writeMsg $deferDb $deferDestination $cmid $cmid $msg 0 0] } {
 
crmcMessagingDb::fetchAddresses $warnCategory $warnGroups foundAddrs

catch {crmcEmail::sendMessage “Paragon RDE to Premier ERROR” “ERROR: Failed to write message to defer database $deferDbnnmsg: $msg” $foundAddrs(aggregateEmail)}

msgmetaset $mh USERDATA “Failed to write message to defer database $deferDb”

set dbQueueErr 1
}

}
TPM {

# This is a trigger message – don’t store in SQLite – just process any queued messages
#
#   Triggers should be config’d to arrive in the outbound pool every few minutes
#   and will only come into play if the Paragon DB has been down for a while, but
#   a new message has not yet been received from the sending system.
#
#   In that situation, this will trigger any messages queued in SQLite to be sent.
#
#   Otherwise, in normal operations, it will be one message in/stored and
#   then immediately sent out.  During normal operations, this trigger will
#   find no messages queued in SQLite and will just be discarded.

#puts “Primer message (TPM) ignorednnmsg=$msg”

}
default {
set killMsg 1
}
}

if { $killMsg } {
lappend dispList “KILL $mh”
} else {
       
if { $dbQueueErr } {
lappend dispList “ERROR $mh”
} else {

# Process any messages stored in SQLite DB

set numMsgsProcessed [__pgn_rde_to_premier_worker__ $mh $deferDb $deferDestination $warnCategory $warnGroups dispList]

if { $msgType == “TPM” && $numMsgsProcessed } {
puts “Processed $numMsgsProcessed messages – Triggered by $msgType message”
}

# Must kill the original message since it’s successfully queued to defer DB
lappend dispList “KILL $mh”

}

}

}        

time {

# Timer-based processing
# N.B.: there may or may not be a MSGID key in args

}

       
shutdown {
#nothing to do
}
       
default {
error “Unknown mode ‘$mode’ in pgn_rde_to_premier”
}
       
}

return $dispList

}

proc __pgn_rde_to_premier_worker__ { mh deferDb deferDestination warnCategory warnGroups dispListName } {

upvar $dispListName dispList

 set numMsgs 0

if { [crmcParagonDb::dbOpen db] } {

if { ! [crmcDeferMsgsDb::getMatureMsgs $deferDb $deferDestination [clock seconds] matureDeferredMsgArray] } {
crmcMessagingDb::fetchAddresses $warnCategory $warnGroups foundAddrs
catch {crmcEmail::sendMessage “Paragon RDE to Premier ERROR” “ERROR: Failed to read deferred messages from $deferDb database for $deferDestination destination. Refer to [crmcSqliteUtils::dirPath $deferDb LOG] for details” $foundAddrs(aggregateEmail)}
} else {

for { set m 0 } { $m >>>> Do message processing here <<<<<

# Convert the modified message back into a string for msgset
crmcHL7::assembleMsg msgArray outBuf

# copy message if we have a message handle, otherwise create a new one
if { $mh eq "" } {
set newmh [msgcreate -recover]
} else {
set newmh [msgcopy $mh]
}

msgset $newmh $outBuf

lappend dispList "CONTINUE $newmh"

# delete deferred msg from DB
catch {crmcDeferMsgsDb::deleteMsg $deferDb $matureDeferredMsgArray($m,destinationSys) $matureDeferredMsgArray($m,appSpecificMsgId)}

catch {crmcDeferMsgsDb::setLastDeferredMsgSendSec $deferDb $deferDestination}

incr numMsgs

}

}

} else {
crmcMessagingDb::fetchAddresses $warnCategory $warnGroups foundAddrs
catch {crmcEmail::sendMessage "Paragon RDE to Premier DB WAIT" "Paragon DB unavailable – waiting" $foundAddrs(aggregateEmail)}
}

crmcParagonDb::dbClose db

return $numMsgs

}