104 lines
3.6 KiB
Python
104 lines
3.6 KiB
Python
#!/usr/bin/env python
|
|
|
|
'''
|
|
MySQL Tag Server
|
|
Created on April 7, 2016
|
|
@author: Patrick McDonagh
|
|
@description: Continuously loops through a list of tags to store values from a PLC into a MySQL database
|
|
'''
|
|
|
|
from tag.tag_mysql import Tag
|
|
import traceback
|
|
import time
|
|
import random
|
|
import requests
|
|
import json
|
|
|
|
web_address = "http://localhost:3000"
|
|
|
|
|
|
class Sample(Tag):
|
|
def read(self, forceSend):
|
|
writeToDB = False
|
|
if self.tag:
|
|
v = 0.0
|
|
if not (self.value is None):
|
|
v = [self.value + (10.0 * (random.random() - 0.5))]
|
|
else:
|
|
v = [random.random() * 100.0]
|
|
if v:
|
|
val = v[0]
|
|
if self.data_type == 'BOOL' or self.data_type == 'STRING':
|
|
if self.mapFn:
|
|
val = self.mapFn[val]
|
|
if (self.last_send_time == 0) or (self.value is None) or not (self.value == val) or ((time.time() - self.last_send_time) > self.guarantee_sec) or (forceSend is True):
|
|
self.last_value = self.value
|
|
self.value = val
|
|
writeToDB = True
|
|
else:
|
|
writeToDB = False
|
|
else:
|
|
if (self.last_send_time == 0) or (self.value is None) or (abs(self.value - v[0]) > self.chg_threshold) or ((time.time() - self.last_send_time) > self.guarantee_sec) or (forceSend is True):
|
|
self.last_value = self.value
|
|
self.value = v[0]
|
|
writeToDB = True
|
|
else:
|
|
writeToDB = False
|
|
if forceSend is False:
|
|
writeToDB = False
|
|
if writeToDB:
|
|
self.sendToDB()
|
|
return self.value
|
|
|
|
def sendToDB(self):
|
|
data = {}
|
|
data['val'] = self.value
|
|
data['tagID'] = self.db_id
|
|
r = requests.post('{}/tag_val'.format(web_address), data=data)
|
|
resp = json.loads(r.text)
|
|
print("Stored {} for {} at {}".format(resp['val'], self.name, resp['createdAt']))
|
|
|
|
tag_store = {}
|
|
scan_rate = 30 # default scan rate is 30 seconds
|
|
save_all = "test"
|
|
|
|
def main():
|
|
|
|
# Get tags stored in database
|
|
get_tag_request_data = {'where':'{"tag_class":5}'}
|
|
get_tag_request = requests.get('{}/tag'.format(web_address), params=get_tag_request_data)
|
|
tags = json.loads(get_tag_request.text)
|
|
|
|
sr_req_data = 'where={"parameter": "scan_rate"}'
|
|
sr_req = requests.get('{}/config?{}'.format(web_address, sr_req_data))
|
|
print sr_req.url
|
|
sr_try = json.loads(sr_req.text)
|
|
if len(sr_try) > 0:
|
|
scan_rate = int(sr_try[0]['val'])
|
|
|
|
sa_req_data = {"where":{"parameter":"save_all"}}
|
|
sa_req = requests.get('{}/config'.format(web_address), params=sa_req_data)
|
|
sa_try = json.loads(sa_req.text)
|
|
if len(sa_try) > 0:
|
|
if sa_try[0]['val'].lower() == "true":
|
|
save_all = True
|
|
elif sa_try[0]['val'].lower() == "false":
|
|
save_all = False
|
|
|
|
for t in tags:
|
|
# name, tag, db_id, data_type, change_threshold, guarantee_sec, mapFn=None, device_type='CLX', ip_address='192.168.1.10'):
|
|
tag_store[t['name']] = Sample(t['name'], t['tag'],t['id'], t['data_type'], t['change_threshold'], t['guarantee_sec'], mapFn=t['map_function'], ip_address=t['deviceID']['address'])
|
|
|
|
|
|
while True:
|
|
for tag in tag_store:
|
|
try:
|
|
tag_store[tag].read('test')
|
|
except:
|
|
print("ERROR EVALUATING {}".format(tag))
|
|
traceback.print_exc()
|
|
time.sleep(scan_rate)
|
|
|
|
if __name__ == '__main__':
|
|
main()
|