import asm3.configuration
import asm3.i18n
import asm3.utils
from .base import AbstractPublisher, get_microchip_data
from asm3.sitedefs import ANIBASE_BASE_URL, ANIBASE_API_USER, ANIBASE_API_KEY
import sys
class AnibaseUKPublisher(AbstractPublisher):
"""
Handles updating UK Identichip microchips with the Anibase web service
(which uses VetXML)
"""
def __init__(self, dbo, publishCriteria):
publishCriteria.uploadDirectly = True
publishCriteria.thumbnails = False
AbstractPublisher.__init__(self, dbo, publishCriteria)
self.initLog("anibaseuk", "Anibase UK Publisher")
def get_vetxml_species(self, asmspeciesid):
SPECIES_MAP = {
1: "Canine",
2: "Feline",
3: "Avian",
4: "Rodent",
5: "Rodent",
7: "Rabbit",
9: "Ferret",
11: "Reptilian",
12: "Tortoise",
13: "Reptilian",
14: "Avian",
15: "Avian",
16: "Goat",
10: "Rodent",
18: "Rodent",
20: "Rodent",
21: "Fish",
22: "Rodent",
23: "Camelid",
24: "Equine",
25: "Equine",
26: "Donkey"
}
if asmspeciesid in SPECIES_MAP:
return SPECIES_MAP[asmspeciesid]
return "Miscellaneous"
def run(self):
self.log(self.publisherName + " starting...")
if self.isPublisherExecuting(): return
self.updatePublisherProgress(0)
self.setLastError("")
self.setStartPublishing()
practiceid = asm3.configuration.anibase_practice_id(self.dbo)
pinno = asm3.configuration.anibase_pin_no(self.dbo)
if pinno == "":
self.setLastError("Anibase vet code must be set")
return
animals = get_microchip_data(self.dbo, ['9851', '9861'], "anibaseuk")
if len(animals) == 0:
self.setLastError("No animals found to publish.")
return
anCount = 0
processed_animals = []
for an in animals:
try:
anCount += 1
self.log("Processing: %s: %s (%d of %d)" % ( an["SHELTERCODE"], an["ANIMALNAME"], anCount, len(animals)))
self.updatePublisherProgress(self.getProgress(anCount, len(animals)))
# If the user cancelled, stop now
if self.shouldStopPublishing():
self.log("User cancelled publish. Stopping.")
self.resetPublisherProgress()
return
if not self.validate(an): continue
x = self.processAnimal(an, practiceid, pinno)
# Build our auth headers
authheaders = {
"APIUSER": ANIBASE_API_USER,
"APIKEY": ANIBASE_API_KEY
}
try:
# Post the VetXML document
self.log("Posting microchip registration document to %s \n%s\n" % (ANIBASE_BASE_URL, x))
r = asm3.utils.post_xml(ANIBASE_BASE_URL, x, authheaders)
self.log("Response %d, HTTP headers: %s, body: %s" % (r["status"], r["headers"], r["response"]))
if r["status"] != 200: raise Exception(r["response"])
# Look in the headers for successful results
wassuccess = False
SUCCESS = ( "54000", "54100", "54108" )
for code in SUCCESS:
if str(r["headers"]).find(code) != -1:
self.log("successful %s response header found, marking processed" % code)
processed_animals.append(an)
# Mark success in the log
self.logSuccess("Processed: %s: %s (%d of %d)" % ( an["SHELTERCODE"], an["ANIMALNAME"], anCount, len(animals)))
wassuccess = True
break
# If we got a chipfound=false or chipRegisterable=false message, mark the chip as processed
# and a success so we don't try and register it in future
if str(r["response"]).find("false") != -1 or str(r["response"]).find("false") != -1:
self.log("chipFound=false/chipRegisterable=false response found, marking chip processed to prevent future sending")
processed_animals.append(an)
wassuccess = True
# If we saw an account not found message, there's no point sending
# anything else as they will all trigger the same error
if str(r["headers"]).find("54101") != -1:
self.logError("received Anibase 54101 'sender not recognised' response header - abandoning run")
break
if not wassuccess:
self.logError("no successful response header %s received" % str(SUCCESS))
except Exception as err:
em = str(err)
self.logError("Failed registering microchip: %s" % em, sys.exc_info())
continue
except Exception as err:
self.logError("Failed processing animal: %s, %s" % (str(an["SHELTERCODE"]), err), sys.exc_info())
# Only mark processed if we aren't using Anibase test URL
if len(processed_animals) > 0 and ANIBASE_BASE_URL.find("test") == -1:
self.log("successfully processed %d animals, marking sent" % len(processed_animals))
self.markAnimalsPublished(processed_animals)
if ANIBASE_BASE_URL.find("test") != -1:
self.log("Anibase test mode, not marking animals published")
self.saveLog()
self.setPublisherComplete()
def processAnimal(self, an, practiceid="", pinno=""):
""" Generates a VetXML document (str) from the animal """
def xe(s):
if s is None: return ""
return s.replace("&", "&").replace("<", "<").replace(">", ">")
implantdate = ""
if an["IDENTICHIPDATE"] is not None: implantdate = asm3.i18n.format_date(an["IDENTICHIPDATE"], "%d/%m/%Y")
# Construct the XML document
return '\n' \
'' \
'' \
' ' + practiceid + '' \
' ' + pinno + '' \
' ' \
'' \
'' \
' ' + xe(an["CURRENTOWNERTITLE"]) + '' \
' ' + xe(an["CURRENTOWNERINITIALS"]) + '' \
' ' + xe(an["CURRENTOWNERFORENAMES"]) + '' \
' ' + xe(an["CURRENTOWNERSURNAME"]) + '' \
' ' \
' '+ xe(an["CURRENTOWNERADDRESS"]) + '' \
' '+ xe(an["CURRENTOWNERTOWN"]) + '' \
' ' + xe(an["CURRENTOWNERPOSTCODE"]) + '' \
' '+ xe(an["CURRENTOWNERCOUNTY"]) + '' \
' United Kingdom' \
' ' \
' ' + xe(an["CURRENTOWNERWORKTELEPHONE"]) + '' \
' ' + xe(an["CURRENTOWNERHOMETELEPHONE"]) + '' \
' ' + xe(an["CURRENTOWNERMOBILETELEPHONE"]) + '' \
' ' \
' ' \
' ' + xe(an["CURRENTOWNEREMAILADDRESS"]) + '' \
' ' \
'' \
'' \
' ' + xe(an["ANIMALNAME"]) + '' \
' ' + self.get_vetxml_species(an["SPECIESID"]) + '' \
' ' + xe(an["BREEDNAME"]) + '