import Queue
import time
import re
-import comon
-import soltesz
+import database
from threading import *
+import config
# TODO: merge the RT mailer from mailer.py into this file.
-# RT database access constants file
-RT_DB_CONSTANTS_PATH='rt_db'
-
#Logging
logger = logging.getLogger("monitor")
def open_rt_db():
# read plc database passwords and connect
- rt_db_constants= readConstantsFile(RT_DB_CONSTANTS_PATH)
- if rt_db_constants is None:
- print "Unable to read database access constants from %s" % \
- RT_DB_CONSTANTS_PATH
- return -1
+ #rt_db_constants= readConstantsFile(RT_DB_CONSTANTS_PATH)
+ #if rt_db_constants is None:
+ # print "Unable to read database access constants from %s" % \
+ # RT_DB_CONSTANTS_PATH
+ # return -1
try:
- rt_db = MySQLdb.connect(host=rt_db_constants['RT_DB_HOST'],
- user=rt_db_constants['RT_DB_USER'],
- passwd=rt_db_constants['RT_DB_PASSWORD'],
- db=rt_db_constants['RT_DB_NAME'])
+ rt_db = MySQLdb.connect(host=config.RT_DB_HOST,
+ user=config.RT_DB_USER,
+ passwd=config.RT_DB_PASSWORD,
+ db=config.RT_DB_NAME)
except Exception, err:
print "Failed to connect to RT database: %s" %err
return -1
#WHERE Tk.Queue != 10 AND Tk.id > 10000 AND
#Tr.id=At.TransactionID AND ( Tk.Status = 'open' OR
#Tk.Status = 'new') """
- sqlall = """SELECT distinct Tk.id, Tk.Status, Tk.Subject, At.Content, Us.EmailAddress, Tk.LastUpdated FROM Tickets AS Tk, Attachments AS At, Users as Us JOIN Transactions AS Tr ON Tk.id=Tr.ObjectId WHERE (Tk.Queue=3 OR Tk.Queue=22) AND Tk.id > 10000 AND Tr.id=At.TransactionID AND ( Tk.Status = 'open' OR Tk.Status = 'new') AND Us.id=Tk.LastUpdatedBy """
+ sqlall = """SELECT distinct Tk.id, Tk.Status, Tk.Subject, At.Content, Us.EmailAddress, Tk.LastUpdated, Q.Name, Tk.Owner FROM Tickets AS Tk, Attachments AS At, Queues as Q, Users as Us JOIN Transactions AS Tr ON Tk.id=Tr.ObjectId WHERE (Tk.Queue=3 OR Tk.Queue=22) AND Tk.id > 10000 AND Tr.id=At.TransactionID AND ( Tk.Status = 'open' OR Tk.Status = 'new') AND Us.id=Tk.LastUpdatedBy AND Q.id=Tk.Queue """
raw = fetch_from_db(db, sql)
"content":str(x[3]),
"email":str(x[4]),
"lastupdated":str(x[5]),
+ "queue":str(x[6]),
+ "owner":str(x[7]),
},
raw)
idTickets = {}
for t in tickets_all:
idTickets[t['ticket_id']] = t
- soltesz.dbDump("idTickets", idTickets)
+ database.dbDump("idTickets", idTickets)
return tickets
return (False, None)
# This search, while O(tickets), takes less than a millisecond, 05-25-07
- #t = soltesz.MyTimer()
+ #t = commands.MyTimer()
ret = search_tickets(host, ad_rt_tickets)
#del t
logger.addHandler(ch)
tickets = rt_tickets()
- soltesz.dbDump("ad_dbTickets", tickets)
+ database.dbDump("ad_dbTickets", tickets)
if __name__ == '__main__':