60 lines
2.0 KiB
Python
60 lines
2.0 KiB
Python
# Enter your python code.
|
|
import json
|
|
from quickfaas.measure import recall
|
|
from common.Logger import logger
|
|
|
|
def sync(wizard_api):
|
|
#get new values and send
|
|
payload = {}
|
|
try:
|
|
data = recall()#json.loads(recall().decode("utf-8"))
|
|
except Exception as e:
|
|
logger.error(e)
|
|
logger.info(data)
|
|
for controller in data:
|
|
for measure in controller["measures"]:
|
|
#publish measure
|
|
topic = "v1/devices/me/telemetry"
|
|
payload[measure["name"]] = measure["value"]
|
|
logger.debug("Sending on topic: {}".format(topic))
|
|
logger.debug("Sending value: {}".format(payload))
|
|
wizard_api.mqtt_publish(topic, json.dumps(payload))
|
|
def writeplctag(value, wizard_api):
|
|
try:
|
|
#value = json.loads(value.replace("'",'"'))
|
|
logger.debug(value)
|
|
message = {"advvfdipp":{value["measurement"]: value["value"]}}
|
|
resp = wizard_api.write_plc_values(message)
|
|
#logger.debug("RETURN FROM WRITE: {}".format(resp))
|
|
return True
|
|
except Exception as e:
|
|
logger.debug(e)
|
|
return False
|
|
|
|
def receiveCommand(topic, payload, wizard_api):
|
|
try:
|
|
logger.debug(topic)
|
|
logger.debug(json.loads(payload))
|
|
p = json.loads(payload)
|
|
command = p["method"]
|
|
commands = {
|
|
"sync": sync,
|
|
"writeplctag": writeplctag,
|
|
}
|
|
if command == "setPLCTag":
|
|
result = commands["writeplctag"](p["params"],wizard_api)
|
|
if result:
|
|
sync(wizard_api)
|
|
#commands[command](p["mac"].lower(),p["payload"]["value"], wizard_api)
|
|
#logger.debug(command)
|
|
ack(topic.split("/")[-1], wizard_api)
|
|
except Exception as e:
|
|
logger.debug(e)
|
|
|
|
|
|
def ack(msgid, wizard_api):
|
|
#logger.debug(msgid)
|
|
#logger.debug(mac)
|
|
#logger.debug(name)
|
|
#logger.debug(value)
|
|
wizard_api.mqtt_publish("v1/devices/me/rpc/response/" + str(msgid), json.dumps({"msg": {"time": time.time()}, "metadata": "", "msgType": ""})) |