From f1a5fa163c846982635729db114c6ad910a485b7 Mon Sep 17 00:00:00 2001 From: Lei PAN Date: Wed, 2 Mar 2022 14:39:29 +0100 Subject: [PATCH] send successful log to oracle --- logs/LogSender.py | 1 + main.py | 4 ++-- 2 files changed, 3 insertions(+), 2 deletions(-) diff --git a/logs/LogSender.py b/logs/LogSender.py index e979d84..804dae8 100644 --- a/logs/LogSender.py +++ b/logs/LogSender.py @@ -12,6 +12,7 @@ LOG_ERROR = "ERROR" LOG_INFO = "INFO" LOG_APPOINTMENT_ERROR = "APPOINTMENT_ERROR" LOG_APPOINTMENT_TIMEOUT = "TIMEOUT" +LOG_APPOINTMENT_SUCCESS = "SUCCESS" class LogSender: diff --git a/main.py b/main.py index 2f6acbc..8694a89 100644 --- a/main.py +++ b/main.py @@ -9,8 +9,7 @@ from gsmmodem import GsmModem from ModemPool import ModemPool from card_pool import CardPool from commandor import Commandor -from db.DbManager import DataManager -from logs.LogSender import LOG_APPOINTMENT_TIMEOUT +from logs.LogSender import LOG_APPOINTMENT_TIMEOUT, LOG_APPOINTMENT_SUCCESS from params import MODEM_POOL_PORTS, CARD_POOL_PORT, firebase_store_manager, oracle_log_sender from pojo.ReserveResultPojo import ReserveResultPojo from utils.excel_reader import ExcelHelper @@ -153,6 +152,7 @@ def on_message_received(ch, method, properties, body): result = ReserveResultPojo.from_json(body) print(result) firebase_store_manager.save(result) + oracle_log_sender.send_log(str(result.id), type=LOG_APPOINTMENT_SUCCESS) # set the flag to True global is_finished is_finished = True