Alarm logger Updates
This commit is contained in:
Patrick McDonagh
422
alarmLogger.py
422
alarmLogger.py
@@ -1,211 +1,211 @@
|
||||
#!/usr/bin/env python
|
||||
|
||||
'''
|
||||
Created on Oct 1, 2014
|
||||
|
||||
@author: PJMcdona
|
||||
'''
|
||||
|
||||
from datetime import datetime
|
||||
from random import randint
|
||||
from time import sleep
|
||||
import sys
|
||||
|
||||
# MYSQL Config
|
||||
import MySQLdb
|
||||
|
||||
db = MySQLdb.connect(host="127.0.0.1", user="website", passwd="henrypump", db="WellData")
|
||||
cur = db.cursor()
|
||||
query = "SELECT * FROM WellData.config ORDER BY dateChanged DESC LIMIT 1;"
|
||||
cur.execute(query)
|
||||
setup = cur.fetchall()
|
||||
db.commit()
|
||||
db.close()
|
||||
|
||||
PLC_IP_ADDRESS = setup[0][2]
|
||||
PLC_TYPE = setup[0][1]
|
||||
|
||||
sys.path.append("../")
|
||||
|
||||
|
||||
path_to_CSV = "/mnt/usb/"
|
||||
|
||||
# TUXEIP Connection to PLC
|
||||
# TUXEIP Connection to PLC
|
||||
from tuxeip import TuxEIP, LGX, LGX_REAL
|
||||
|
||||
tux = TuxEIP(libpath="/usr/lib/libtuxeip.so")
|
||||
sess = tux.OpenSession(PLC_IP_ADDRESS)
|
||||
reg = tux.RegisterSession(sess)
|
||||
conn = tux.ConnectPLCOverCNET(sess, LGX, 1, 100, 123, randint(0, 9999), 123, 321, 100, 5000, 1, '01')
|
||||
|
||||
|
||||
|
||||
safetySetup = [["Safety_Casing_Pressure", "Casing Pressure"],
|
||||
["Safety_Flow_Line_Pressure", "Flow Line Pressure"],
|
||||
["Safety_Flowmeter", "Flowmeter"],
|
||||
["Safety_Fluid_Load", "Fluid Load"],
|
||||
["Safety_Inclinometer", "Inclinometer"],
|
||||
["Safety_Load_HiHi", "Load HiHi"],
|
||||
["Safety_Load_Hi", "Load Hi"],
|
||||
["Safety_Load_Lo", "Load Lo"],
|
||||
["Safety_Load_LoLo", "Load LoLo"],
|
||||
["Safety_Speed", "Speed"],
|
||||
["Safety_Tubing_Pressure", "Tubing Pressure"]
|
||||
]
|
||||
|
||||
condition = {
|
||||
20: "Low",
|
||||
21: "High",
|
||||
24: "LoLo",
|
||||
25: "HiHi",
|
||||
32: "Input Failure",
|
||||
34: "Configuration Error",
|
||||
16: "Failure to Stop",
|
||||
17: "Failure to Start",
|
||||
18: "Drive Fault"
|
||||
}
|
||||
|
||||
bitsSetup = [
|
||||
["Pump.Auto_Stop", "Pump Off (Auto Mode)", "Unit Stop"],
|
||||
["Pump.POC_Stop", "Pump Off (POC Mode)", "Unit Stop"],
|
||||
["Pump.Timed_Stop", "Pump Off (Timer Mode)", "Unit Stop"],
|
||||
["Pump.Stop", "User Initiated Stop", "Unit Stop"],
|
||||
["PeakEnergy.Stop", "Peak Energy Stop", "Unit Stop"],
|
||||
["Pump.Start", "User Initiated Start", "Unit Start"],
|
||||
["Pump.POC_Restart", "Restart (POC Mode)", "Unit Start"],
|
||||
["Pump.Timed_Restart", "Restart (Timer Mode)", "Unit Start"],
|
||||
["Pump.Auto_Restart", "Restart (Auto Mode)", "Unit Start"],
|
||||
["PeakEnergy.Restart", "Peak Energy Restart", "Unit Start"],
|
||||
["Pump.Jog", "Unit Jogged", "Unit Jog"],
|
||||
]
|
||||
|
||||
safetyList = []
|
||||
bitList = []
|
||||
|
||||
|
||||
class SafetyTag:
|
||||
"""Safety structure"""
|
||||
|
||||
def __init__(self, tag, name):
|
||||
self.name = name
|
||||
self.tag = tag
|
||||
self.alarm = False
|
||||
self.warning = False
|
||||
self.condition = ""
|
||||
self.type = ""
|
||||
self.value = 0.0
|
||||
self.stored = False
|
||||
|
||||
def writeToDB(self):
|
||||
global tux
|
||||
global sess
|
||||
global conn
|
||||
global condition
|
||||
stroke_num = int(tux.ReadLGXDataAsInteger(sess, conn, "Stroke_Count_Today", 1)[0])
|
||||
db = MySQLdb.connect(host="127.0.0.1", user="website", passwd="henrypump", db="WellData")
|
||||
cur = db.cursor()
|
||||
event_query = "INSERT INTO WellData.Event_List (device_name, type, cond, value, datetime, tag, stroke_number) VALUES ('{0}', '{1}', '{2}', {3}, '{4}', '{5}', {6});".format(
|
||||
self.name, self.type, self.condition, self.value, datetime.now(), self.name, stroke_num)
|
||||
print event_query
|
||||
store_event = cur.execute(event_query)
|
||||
db.commit()
|
||||
db.close()
|
||||
self.stored = True
|
||||
|
||||
def ReadStatus(self):
|
||||
global tux
|
||||
global sess
|
||||
global conn
|
||||
global condition
|
||||
try:
|
||||
a = tux.ReadLGXDataAsInteger(sess, conn, self.tag + ".Alarm", 1)
|
||||
w = tux.ReadLGXDataAsInteger(sess, conn, self.tag + ".Warning", 1)
|
||||
aInt = int(a[0])
|
||||
wInt = int(w[0])
|
||||
if aInt == 1:
|
||||
self.alarm = True
|
||||
self.condition = condition[tux.ReadLGXDataAsInteger(sess, conn, self.tag + ".Alarm_Code", 1)]
|
||||
self.value = round(tux.ReadLGXDataAsInteger(sess, conn, self.tag + ".Alarm_Value", 1), 3)
|
||||
self.type = "Alarm"
|
||||
if (self.stored == False):
|
||||
self.writeToDB()
|
||||
elif wInt == 1:
|
||||
self.warning = True
|
||||
self.condition = condition[tux.ReadLGXDataAsInteger(sess, conn, self.tag + ".Alarm_Code", 1)]
|
||||
self.value = round(tux.ReadLGXDataAsInteger(sess, conn, self.tag + ".Alarm_Value", 1), 3)
|
||||
self.type = "Warning"
|
||||
if (self.stored == False):
|
||||
self.writeToDB()
|
||||
else:
|
||||
self.alarm = False
|
||||
self.warning = False
|
||||
self.condition = ""
|
||||
self.type = ""
|
||||
self.stored = False
|
||||
except:
|
||||
print "Unable to read " + self.tag
|
||||
|
||||
|
||||
class BitTag:
|
||||
"""Safety structure"""
|
||||
|
||||
def __init__(self, tag, name, condition):
|
||||
self.name = name
|
||||
self.tag = tag
|
||||
self.condition = condition
|
||||
self.type = "Info"
|
||||
self.value = 0.0
|
||||
self.stored = False
|
||||
|
||||
def writeToDB(self):
|
||||
global tux
|
||||
global sess
|
||||
global conn
|
||||
global condition
|
||||
stroke_num = int(tux.ReadLGXDataAsInteger(sess, conn, "Stroke_Count_Today", 1)[0])
|
||||
db = MySQLdb.connect(host="127.0.0.1", user="website", passwd="henrypump", db="WellData")
|
||||
cur = db.cursor()
|
||||
event_query = "INSERT INTO WellData.Event_List (device_name, type, cond, value, datetime, tag, stroke_number) VALUES ('{0}', '{1}', '{2}', {3}, '{4}', '{5}', {6});".format(
|
||||
self.name, self.type, self.condition, self.value, datetime.now(), self.name, stroke_num)
|
||||
print event_query
|
||||
store_event = cur.execute(event_query)
|
||||
db.commit()
|
||||
db.close()
|
||||
self.stored = True
|
||||
|
||||
def ReadStatus(self):
|
||||
global tux
|
||||
global sess
|
||||
global conn
|
||||
global condition
|
||||
try:
|
||||
a = tux.ReadLGXDataAsInteger(sess, conn, self.tag, 1)
|
||||
aInt = int(a[0])
|
||||
# print self.tag + ": " + str(aInt)
|
||||
if aInt <> 0:
|
||||
if (self.stored == False):
|
||||
self.writeToDB()
|
||||
else:
|
||||
self.stored = False
|
||||
except:
|
||||
print "Unable to read " + self.tag
|
||||
|
||||
|
||||
for saf in safetySetup:
|
||||
safetyList.append(SafetyTag(saf[0], saf[1]))
|
||||
|
||||
for bit in bitsSetup:
|
||||
bitList.append(BitTag(bit[0], bit[1], bit[2]))
|
||||
|
||||
if (PLC_TYPE == "VFD"):
|
||||
safetyList.append(SafetyTag("Safety_Pump_PF755", "Drive"))
|
||||
if (PLC_TYPE == "E300"):
|
||||
safetyList.append(SafetyTag("Safety_E300", "Relay Overload"))
|
||||
|
||||
while True:
|
||||
for s in safetyList:
|
||||
s.ReadStatus()
|
||||
for b in bitList:
|
||||
b.ReadStatus()
|
||||
sleep(.50)
|
||||
#!/usr/bin/env python
|
||||
|
||||
'''
|
||||
Created on Oct 1, 2014
|
||||
|
||||
@author: PJMcdona
|
||||
'''
|
||||
|
||||
from datetime import datetime
|
||||
from random import randint
|
||||
from time import sleep
|
||||
import sys
|
||||
|
||||
# MYSQL Config
|
||||
import MySQLdb
|
||||
|
||||
db = MySQLdb.connect(host="127.0.0.1", user="website", passwd="henrypump", db="WellData")
|
||||
cur = db.cursor()
|
||||
query = "SELECT * FROM WellData.config ORDER BY dateChanged DESC LIMIT 1;"
|
||||
cur.execute(query)
|
||||
setup = cur.fetchall()
|
||||
db.commit()
|
||||
db.close()
|
||||
|
||||
PLC_IP_ADDRESS = setup[0][2]
|
||||
PLC_TYPE = setup[0][1]
|
||||
|
||||
sys.path.append("../")
|
||||
|
||||
|
||||
path_to_CSV = "/mnt/usb/"
|
||||
|
||||
# TUXEIP Connection to PLC
|
||||
# TUXEIP Connection to PLC
|
||||
from tuxeip import TuxEIP, LGX, LGX_REAL
|
||||
|
||||
tux = TuxEIP(libpath="/usr/lib/libtuxeip.so")
|
||||
sess = tux.OpenSession(PLC_IP_ADDRESS)
|
||||
reg = tux.RegisterSession(sess)
|
||||
conn = tux.ConnectPLCOverCNET(sess, LGX, 1, 100, 123, randint(0, 9999), 123, 321, 100, 5000, 1, '01')
|
||||
|
||||
|
||||
|
||||
safetySetup = [["Safety_Casing_Pressure", "Casing Pressure"],
|
||||
["Safety_Flow_Line_Pressure", "Flow Line Pressure"],
|
||||
["Safety_Flowmeter", "Flowmeter"],
|
||||
["Safety_Fluid_Load", "Fluid Load"],
|
||||
["Safety_Inclinometer", "Inclinometer"],
|
||||
["Safety_Load_HiHi", "Load HiHi"],
|
||||
["Safety_Load_Hi", "Load Hi"],
|
||||
["Safety_Load_Lo", "Load Lo"],
|
||||
["Safety_Load_LoLo", "Load LoLo"],
|
||||
["Safety_Speed", "Speed"],
|
||||
["Safety_Tubing_Pressure", "Tubing Pressure"]
|
||||
]
|
||||
|
||||
condition = {
|
||||
20: "Low",
|
||||
21: "High",
|
||||
24: "LoLo",
|
||||
25: "HiHi",
|
||||
32: "Input Failure",
|
||||
34: "Configuration Error",
|
||||
16: "Failure to Stop",
|
||||
17: "Failure to Start",
|
||||
18: "Drive Fault"
|
||||
}
|
||||
|
||||
bitsSetup = [
|
||||
["Pump.Auto_Stop", "Pump Off (Auto Mode)", "Unit Stop"],
|
||||
["Pump.POC_Stop", "Pump Off (POC Mode)", "Unit Stop"],
|
||||
["Pump.Timed_Stop", "Pump Off (Timer Mode)", "Unit Stop"],
|
||||
["Pump.Stop", "User Initiated Stop", "Unit Stop"],
|
||||
["PeakEnergy.Stop", "Peak Energy Stop", "Unit Stop"],
|
||||
["Pump.Start", "User Initiated Start", "Unit Start"],
|
||||
["Pump.POC_Restart", "Restart (POC Mode)", "Unit Start"],
|
||||
["Pump.Timed_Restart", "Restart (Timer Mode)", "Unit Start"],
|
||||
["Pump.Auto_Restart", "Restart (Auto Mode)", "Unit Start"],
|
||||
["PeakEnergy.Restart", "Peak Energy Restart", "Unit Start"],
|
||||
["Pump.Jog", "Unit Jogged", "Unit Jog"],
|
||||
]
|
||||
|
||||
safetyList = []
|
||||
bitList = []
|
||||
|
||||
|
||||
class SafetyTag:
|
||||
"""Safety structure"""
|
||||
|
||||
def __init__(self, tag, name):
|
||||
self.name = name
|
||||
self.tag = tag
|
||||
self.alarm = False
|
||||
self.warning = False
|
||||
self.condition = ""
|
||||
self.type = ""
|
||||
self.value = 0.0
|
||||
self.stored = False
|
||||
|
||||
def writeToDB(self):
|
||||
global tux
|
||||
global sess
|
||||
global conn
|
||||
global condition
|
||||
stroke_num = int(tux.ReadLGXDataAsInteger(sess, conn, "Stroke_Count_Today", 1)[0])
|
||||
db = MySQLdb.connect(host="127.0.0.1", user="website", passwd="henrypump", db="WellData")
|
||||
cur = db.cursor()
|
||||
event_query = "INSERT INTO WellData.Event_List (device_name, type, cond, value, datetime, tag, stroke_number) VALUES ('{0}', '{1}', '{2}', {3}, '{4}', '{5}', {6});".format(
|
||||
self.name, self.type, self.condition, self.value, datetime.now(), self.name, stroke_num)
|
||||
print event_query
|
||||
store_event = cur.execute(event_query)
|
||||
db.commit()
|
||||
db.close()
|
||||
self.stored = True
|
||||
|
||||
def ReadStatus(self):
|
||||
global tux
|
||||
global sess
|
||||
global conn
|
||||
global condition
|
||||
try:
|
||||
a = tux.ReadLGXDataAsInteger(sess, conn, self.tag + ".Alarm", 1)
|
||||
w = tux.ReadLGXDataAsInteger(sess, conn, self.tag + ".Warning", 1)
|
||||
aInt = int(a[0])
|
||||
wInt = int(w[0])
|
||||
if aInt == 1:
|
||||
self.alarm = True
|
||||
self.condition = condition[tux.ReadLGXDataAsInteger(sess, conn, self.tag + ".Alarm_Code", 1)]
|
||||
self.value = round(tux.ReadLGXDataAsInteger(sess, conn, self.tag + ".Alarm_Value", 1), 3)
|
||||
self.type = "Alarm"
|
||||
if (self.stored == False):
|
||||
self.writeToDB()
|
||||
elif wInt == 1:
|
||||
self.warning = True
|
||||
self.condition = condition[tux.ReadLGXDataAsInteger(sess, conn, self.tag + ".Alarm_Code", 1)]
|
||||
self.value = round(tux.ReadLGXDataAsInteger(sess, conn, self.tag + ".Alarm_Value", 1), 3)
|
||||
self.type = "Warning"
|
||||
if (self.stored == False):
|
||||
self.writeToDB()
|
||||
else:
|
||||
self.alarm = False
|
||||
self.warning = False
|
||||
self.condition = ""
|
||||
self.type = ""
|
||||
self.stored = False
|
||||
except:
|
||||
print "Unable to read " + self.tag
|
||||
|
||||
|
||||
class BitTag:
|
||||
"""Safety structure"""
|
||||
|
||||
def __init__(self, tag, name, condition):
|
||||
self.name = name
|
||||
self.tag = tag
|
||||
self.condition = condition
|
||||
self.type = "Info"
|
||||
self.value = 0.0
|
||||
self.stored = False
|
||||
|
||||
def writeToDB(self):
|
||||
global tux
|
||||
global sess
|
||||
global conn
|
||||
global condition
|
||||
stroke_num = int(tux.ReadLGXDataAsInteger(sess, conn, "Stroke_Count_Today", 1)[0])
|
||||
db = MySQLdb.connect(host="127.0.0.1", user="website", passwd="henrypump", db="WellData")
|
||||
cur = db.cursor()
|
||||
event_query = "INSERT INTO WellData.Event_List (device_name, type, cond, value, datetime, tag, stroke_number) VALUES ('{0}', '{1}', '{2}', {3}, '{4}', '{5}', {6});".format(
|
||||
self.name, self.type, self.condition, self.value, datetime.now(), self.name, stroke_num)
|
||||
print event_query
|
||||
store_event = cur.execute(event_query)
|
||||
db.commit()
|
||||
db.close()
|
||||
self.stored = True
|
||||
|
||||
def ReadStatus(self):
|
||||
global tux
|
||||
global sess
|
||||
global conn
|
||||
global condition
|
||||
try:
|
||||
a = tux.ReadLGXDataAsInteger(sess, conn, self.tag, 1)
|
||||
aInt = int(a[0])
|
||||
# print self.tag + ": " + str(aInt)
|
||||
if aInt <> 0:
|
||||
if (self.stored == False):
|
||||
self.writeToDB()
|
||||
else:
|
||||
self.stored = False
|
||||
except:
|
||||
print "Unable to read " + self.tag
|
||||
|
||||
|
||||
for saf in safetySetup:
|
||||
safetyList.append(SafetyTag(saf[0], saf[1]))
|
||||
|
||||
for bit in bitsSetup:
|
||||
bitList.append(BitTag(bit[0], bit[1], bit[2]))
|
||||
|
||||
if (PLC_TYPE == "VFD"):
|
||||
safetyList.append(SafetyTag("Safety_Pump_PF755", "Drive"))
|
||||
if (PLC_TYPE == "E300"):
|
||||
safetyList.append(SafetyTag("Safety_E300", "Relay Overload"))
|
||||
|
||||
while True:
|
||||
for s in safetyList:
|
||||
s.ReadStatus()
|
||||
for b in bitList:
|
||||
b.ReadStatus()
|
||||
sleep(.50)
|
||||
|
||||
@@ -1,143 +1,143 @@
|
||||
#!/usr/bin/python
|
||||
|
||||
from datetime import datetime
|
||||
from time import sleep
|
||||
import sys
|
||||
|
||||
# MYSQL Config
|
||||
import MySQLdb
|
||||
|
||||
db = MySQLdb.connect(host="127.0.0.1", user="website", passwd="henrypump", db="WellData")
|
||||
cur = db.cursor()
|
||||
query = "SELECT * FROM WellData.config ORDER BY dateChanged DESC LIMIT 1;"
|
||||
cur.execute(query)
|
||||
setup = cur.fetchall()
|
||||
db.commit()
|
||||
db.close()
|
||||
|
||||
try:
|
||||
PLC_IP_ADDRESS = setup[0][2]
|
||||
PLC_TYPE = setup[0][1]
|
||||
except:
|
||||
print("PLC Address not set in database... using default of 192.168.1.10")
|
||||
PLC_IP_ADDRESS = "192.168.1.10"
|
||||
PLC_TYPE = "VFD"
|
||||
|
||||
#PYCOMM Connection to PLC
|
||||
from pycomm.ab_comm.clx import Driver as ClxDriver
|
||||
from pycomm.ab_comm.clx import CommError as ClxCommError
|
||||
from pycomm.ab_comm.clx import DataError as ClxDataError
|
||||
c = ClxDriver(True, 'ClxDriver.log')
|
||||
|
||||
safetySetup = [{'tag':"Safety_Casing_Pressure", 'name':"Casing Pressure", "active":False},
|
||||
{'tag':"Safety_Flow_Line_Pressure", 'name':"Flow Line Pressure", "active":False},
|
||||
{'tag':"Safety_Flowmeter", 'name':"Flowmeter", "active":False},
|
||||
{'tag':"Safety_Fluid_Load", 'name':"Fluid Load", "active":False},
|
||||
{'tag':"Safety_Inclinometer", 'name':"Inclinometer", "active":False},
|
||||
{'tag':"Safety_Load_HiHi", 'name':"Load HiHi", "active":False},
|
||||
{'tag':"Safety_Load_Hi", 'name':"Load Hi", "active":False},
|
||||
{'tag':"Safety_Load_Lo", 'name':"Load Lo", "active":False},
|
||||
{'tag':"Safety_Load_LoLo", 'name':"Load LoLo", "active":False},
|
||||
{'tag':"Safety_Speed", 'name':"Speed", "active":False},
|
||||
{'tag':"Safety_Tubing_Pressure", 'name':"Tubing Pressure", "active":False}
|
||||
]
|
||||
|
||||
condition = {
|
||||
20: "Low",
|
||||
21: "High",
|
||||
24: "LoLo",
|
||||
25: "HiHi",
|
||||
32: "Input Failure",
|
||||
34: "Configuration Error",
|
||||
16: "Failure to Stop",
|
||||
17: "Failure to Start",
|
||||
18: "Drive Fault"
|
||||
}
|
||||
|
||||
bitsSetup = [
|
||||
{'tag':"Pump.Auto_Stop", 'name':"Pump Off (Auto Mode)", 'condition':"Unit Stop", 'active':False},
|
||||
{'tag':"Pump.POC_Stop", 'name':"Pump Off (POC Mode)", 'condition':"Unit Stop", 'active':False},
|
||||
{'tag':"Pump.Timed_Stop", 'name':"Pump Off (Timer Mode)", 'condition':"Unit Stop", 'active':False},
|
||||
{'tag':"Pump.Stop", 'name':"User Initiated Stop", 'condition':"Unit Stop", 'active':False},
|
||||
{'tag':"PeakEnergy.Stop", 'name':"Peak Energy Stop", 'condition':"Unit Stop", 'active':False},
|
||||
{'tag':"Pump.Start", 'name':"User Initiated Start", 'condition':"Unit Start", 'active':False},
|
||||
{'tag':"Pump.POC_Restart", 'name':"Restart (POC Mode)", 'condition':"Unit Start", 'active':False},
|
||||
{'tag':"Pump.Timed_Restart", 'name':"Restart (Timer Mode)", 'condition':"Unit Start", 'active':False},
|
||||
{'tag':"Pump.Auto_Restart", 'name':"Restart (Auto Mode)", 'condition':"Unit Start", 'active':False},
|
||||
{'tag':"PeakEnergy.Restart", 'name':"Peak Energy Restart", 'condition':"Unit Start", 'active':False},
|
||||
{'tag':"Pump.Jog", 'name':"Unit Jogged", 'condition':"Unit Jog", 'active':False},
|
||||
]
|
||||
|
||||
def write_alarm(name, type, condition, value, tag):
|
||||
"""writes the specified alarm to the MySQL database"""
|
||||
global c
|
||||
|
||||
stroke_num = int(c.read_tag(["Stroke_Count_Today"])[0][1])
|
||||
db = MySQLdb.connect(host="127.0.0.1", user="website", passwd="henrypump", db="WellData")
|
||||
cur = db.cursor()
|
||||
event_query = "INSERT INTO WellData.Event_List (device_name, type, cond, value, datetime, tag, stroke_number) VALUES ('{0}', '{1}', '{2}', {3}, '{4}', '{5}', {6});".format(
|
||||
name, type, condition, value, datetime.now(), tag, stroke_num)
|
||||
print event_query
|
||||
store_event = cur.execute(event_query)
|
||||
db.commit()
|
||||
db.close()
|
||||
|
||||
c.open(PLC_IP_ADDRESS)
|
||||
retry = False
|
||||
number_of_retry = 0
|
||||
while True:
|
||||
try:
|
||||
if retry:
|
||||
retry = False
|
||||
print "retrying"
|
||||
sleep(0.5)
|
||||
c.forward_close()
|
||||
if number_of_retry >= 5:
|
||||
c.close()
|
||||
c.open(PLC_IP_ADDRESS)
|
||||
number_of_retry = 0
|
||||
|
||||
for safety in safetySetup:
|
||||
try:
|
||||
alarm_sts = int(c.read_tag(["{0}.Alarm".format(safety['tag'])])[0][1])
|
||||
warning_sts = int(c.read_tag([safety['tag'] + ".Warning"])[0][1])
|
||||
print("Tag: {0}, Alarm: {1}, Warning: {2}".format(safety['tag'], alarm_sts, warning_sts))
|
||||
safety_type = ""
|
||||
if alarm_sts == 1:
|
||||
safety_type = "Alarm"
|
||||
if warning_sts == 1:
|
||||
safety_type = "Warning"
|
||||
if (alarm_sts == 1 or warning_sts == 1):
|
||||
safety_condition = condition[c.read_tag(["{0}.Alarm_Code".format(safety['tag'])])[0][1]]
|
||||
safety_value = round(c.read_tag(["{0}.Alarm_Value".format(safety['tag'])])[0][1], 3)
|
||||
if not safety['active']:
|
||||
write_alarm(safety['name'], safety_type, safety_condition, safety_value, safety['tag'])
|
||||
safety['active'] = True
|
||||
else:
|
||||
safety['active'] = False
|
||||
except Exception, e:
|
||||
print("[ERROR] Error reading safety {0}: {1}".format(safety['tag'], e))
|
||||
for bit in bitsSetup:
|
||||
try:
|
||||
bit_sts = int(c.read_tag([bit['tag']])[0][1])
|
||||
print("Tag: {0}, Status: {1}".format(bit['tag'], bit_sts))
|
||||
bit_type = "Info"
|
||||
if bit_sts == 1:
|
||||
bit_condition = bit['condition']
|
||||
bit_value = 0.0
|
||||
if not bit['active']:
|
||||
write_alarm(bit['name'], bit_type, bit_condition, bit_value, bit['tag'])
|
||||
bit['active'] = True
|
||||
else:
|
||||
bit['active'] = False
|
||||
except Exception, e:
|
||||
print("[ERROR] Error reading bit {0}: {1}".format(bit['tag'], e))
|
||||
|
||||
sleep(0.5)
|
||||
except ClxCommError as e:
|
||||
print(e)
|
||||
retry = True
|
||||
|
||||
except ClxDataError as e:
|
||||
print (e)
|
||||
c.close()
|
||||
#!/usr/bin/python
|
||||
|
||||
from datetime import datetime
|
||||
from time import sleep
|
||||
import sys
|
||||
|
||||
# MYSQL Config
|
||||
import MySQLdb
|
||||
|
||||
db = MySQLdb.connect(host="127.0.0.1", user="website", passwd="henrypump", db="WellData")
|
||||
cur = db.cursor()
|
||||
query = "SELECT * FROM WellData.config ORDER BY dateChanged DESC LIMIT 1;"
|
||||
cur.execute(query)
|
||||
setup = cur.fetchall()
|
||||
db.commit()
|
||||
db.close()
|
||||
|
||||
try:
|
||||
PLC_IP_ADDRESS = setup[0][2]
|
||||
PLC_TYPE = setup[0][1]
|
||||
except:
|
||||
print("PLC Address not set in database... using default of 192.168.1.10")
|
||||
PLC_IP_ADDRESS = "192.168.1.10"
|
||||
PLC_TYPE = "VFD"
|
||||
|
||||
#PYCOMM Connection to PLC
|
||||
from pycomm.ab_comm.clx import Driver as ClxDriver
|
||||
from pycomm.ab_comm.clx import CommError as ClxCommError
|
||||
from pycomm.ab_comm.clx import DataError as ClxDataError
|
||||
c = ClxDriver(True, 'ClxDriver.log')
|
||||
|
||||
safetySetup = [{'tag':"Safety_Casing_Pressure", 'name':"Casing Pressure", "active":False},
|
||||
{'tag':"Safety_Flow_Line_Pressure", 'name':"Flow Line Pressure", "active":False},
|
||||
{'tag':"Safety_Flowmeter", 'name':"Flowmeter", "active":False},
|
||||
{'tag':"Safety_Fluid_Load", 'name':"Fluid Load", "active":False},
|
||||
{'tag':"Safety_Inclinometer", 'name':"Inclinometer", "active":False},
|
||||
{'tag':"Safety_Load_HiHi", 'name':"Load HiHi", "active":False},
|
||||
{'tag':"Safety_Load_Hi", 'name':"Load Hi", "active":False},
|
||||
{'tag':"Safety_Load_Lo", 'name':"Load Lo", "active":False},
|
||||
{'tag':"Safety_Load_LoLo", 'name':"Load LoLo", "active":False},
|
||||
{'tag':"Safety_Speed", 'name':"Speed", "active":False},
|
||||
{'tag':"Safety_Tubing_Pressure", 'name':"Tubing Pressure", "active":False}
|
||||
]
|
||||
|
||||
condition = {
|
||||
20: "Low",
|
||||
21: "High",
|
||||
24: "LoLo",
|
||||
25: "HiHi",
|
||||
32: "Input Failure",
|
||||
34: "Configuration Error",
|
||||
16: "Failure to Stop",
|
||||
17: "Failure to Start",
|
||||
18: "Drive Fault"
|
||||
}
|
||||
|
||||
bitsSetup = [
|
||||
{'tag':"Pump.Auto_Stop", 'name':"Pump Off (Auto Mode)", 'condition':"Unit Stop", 'active':False},
|
||||
{'tag':"Pump.POC_Stop", 'name':"Pump Off (POC Mode)", 'condition':"Unit Stop", 'active':False},
|
||||
{'tag':"Pump.Timed_Stop", 'name':"Pump Off (Timer Mode)", 'condition':"Unit Stop", 'active':False},
|
||||
{'tag':"Pump.Stop", 'name':"User Initiated Stop", 'condition':"Unit Stop", 'active':False},
|
||||
{'tag':"PeakEnergy.Stop", 'name':"Peak Energy Stop", 'condition':"Unit Stop", 'active':False},
|
||||
{'tag':"Pump.Start", 'name':"User Initiated Start", 'condition':"Unit Start", 'active':False},
|
||||
{'tag':"Pump.POC_Restart", 'name':"Restart (POC Mode)", 'condition':"Unit Start", 'active':False},
|
||||
{'tag':"Pump.Timed_Restart", 'name':"Restart (Timer Mode)", 'condition':"Unit Start", 'active':False},
|
||||
{'tag':"Pump.Auto_Restart", 'name':"Restart (Auto Mode)", 'condition':"Unit Start", 'active':False},
|
||||
{'tag':"PeakEnergy.Restart", 'name':"Peak Energy Restart", 'condition':"Unit Start", 'active':False},
|
||||
{'tag':"Pump.Jog", 'name':"Unit Jogged", 'condition':"Unit Jog", 'active':False},
|
||||
]
|
||||
|
||||
def write_alarm(name, type, condition, value, tag):
|
||||
"""writes the specified alarm to the MySQL database"""
|
||||
global c
|
||||
|
||||
stroke_num = int(c.read_tag(["Stroke_Count_Today"])[0][1])
|
||||
db = MySQLdb.connect(host="127.0.0.1", user="website", passwd="henrypump", db="WellData")
|
||||
cur = db.cursor()
|
||||
event_query = "INSERT INTO WellData.Event_List (device_name, type, cond, value, datetime, tag, stroke_number) VALUES ('{0}', '{1}', '{2}', {3}, '{4}', '{5}', {6});".format(
|
||||
name, type, condition, value, datetime.now(), tag, stroke_num)
|
||||
print event_query
|
||||
store_event = cur.execute(event_query)
|
||||
db.commit()
|
||||
db.close()
|
||||
|
||||
c.open(PLC_IP_ADDRESS)
|
||||
retry = False
|
||||
number_of_retry = 0
|
||||
while True:
|
||||
try:
|
||||
if retry:
|
||||
retry = False
|
||||
print "retrying"
|
||||
sleep(0.5)
|
||||
c.forward_close()
|
||||
if number_of_retry >= 5:
|
||||
c.close()
|
||||
c.open(PLC_IP_ADDRESS)
|
||||
number_of_retry = 0
|
||||
|
||||
for safety in safetySetup:
|
||||
try:
|
||||
alarm_sts = int(c.read_tag(["{0}.Alarm".format(safety['tag'])])[0][1])
|
||||
warning_sts = int(c.read_tag([safety['tag'] + ".Warning"])[0][1])
|
||||
print("Tag: {0}, Alarm: {1}, Warning: {2}".format(safety['tag'], alarm_sts, warning_sts))
|
||||
safety_type = ""
|
||||
if alarm_sts == 1:
|
||||
safety_type = "Alarm"
|
||||
if warning_sts == 1:
|
||||
safety_type = "Warning"
|
||||
if (alarm_sts == 1 or warning_sts == 1):
|
||||
safety_condition = condition[c.read_tag(["{0}.Alarm_Code".format(safety['tag'])])[0][1]]
|
||||
safety_value = round(c.read_tag(["{0}.Alarm_Value".format(safety['tag'])])[0][1], 3)
|
||||
if not safety['active']:
|
||||
write_alarm(safety['name'], safety_type, safety_condition, safety_value, safety['tag'])
|
||||
safety['active'] = True
|
||||
else:
|
||||
safety['active'] = False
|
||||
except Exception, e:
|
||||
print("[ERROR] Error reading safety {0}: {1}".format(safety['tag'], e))
|
||||
for bit in bitsSetup:
|
||||
try:
|
||||
bit_sts = int(c.read_tag([bit['tag']])[0][1])
|
||||
print("Tag: {0}, Status: {1}".format(bit['tag'], bit_sts))
|
||||
bit_type = "Info"
|
||||
if bit_sts == 1:
|
||||
bit_condition = bit['condition']
|
||||
bit_value = 0.0
|
||||
if not bit['active']:
|
||||
write_alarm(bit['name'], bit_type, bit_condition, bit_value, bit['tag'])
|
||||
bit['active'] = True
|
||||
else:
|
||||
bit['active'] = False
|
||||
except Exception, e:
|
||||
print("[ERROR] Error reading bit {0}: {1}".format(bit['tag'], e))
|
||||
|
||||
sleep(0.5)
|
||||
except ClxCommError as e:
|
||||
print(e)
|
||||
retry = True
|
||||
|
||||
except ClxDataError as e:
|
||||
print (e)
|
||||
c.close()
|
||||
|
||||
Reference in New Issue
Block a user