panleicim/appointment_tool
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

create params.py

Browse Source
This commit is contained in:
PAN Lei
2022-03-01 00:26:04 +01:00
parent 96c5e26abd
commit 1a3ae260b6
4 changed files with 35 additions and 31 deletions
Download Patch File Download Diff File Expand all files Collapse all files
ModemPool.py
+2 -2
View File
@@ -3,10 +3,10 @@ import time
import serial import serial
from serial import Serial from serial import Serial
from db.DbManager import DataManager
from error.SIMError import SIMError from error.SIMError import SIMError
from logs.LogSender import LogSender, LOG_ERROR from logs.LogSender import LogSender, LOG_ERROR
from params import firebase_store_manager
from pojo.SimInfoPojo import SimInfoPojo from pojo.SimInfoPojo import SimInfoPojo
from utils.excel_reader import ExcelHelper from utils.excel_reader import ExcelHelper
@@ -21,7 +21,7 @@ class ModemPool:
self._serial_list = [] self._serial_list = []
self._excel_helper = ExcelHelper() self._excel_helper = ExcelHelper()
self._log_sender = LogSender() self._log_sender = LogSender()
self._db_manager = DataManager() self._db_manager = firebase_store_manager
for port in self._port_list: for port in self._port_list:
ser = serial.Serial(port, self.BAUDRATE, timeout=1) ser = serial.Serial(port, self.BAUDRATE, timeout=1)
db/DbManager.py
+1 -1
View File
@@ -21,7 +21,7 @@ class DataManager:
pass pass
def get_all_successful_items(self): def get_all_successful_items(self):
doc_ref = self._db.collection(u'2022-02-25') doc_ref = self._db.collection(str(datetime.date.today()))
return doc_ref return doc_ref
def save_sim_info(self, simInfoPojo: SimInfoPojo): def save_sim_info(self, simInfoPojo: SimInfoPojo):
main.py
+10 -11
View File
@@ -10,7 +10,7 @@ from ModemPool import ModemPool
from card_pool import CardPool from card_pool import CardPool
from commandor import Commandor from commandor import Commandor
from db.DbManager import DataManager from db.DbManager import DataManager
from params import MODEM_POOL_PORTS, CARD_POOL_PORT from params import MODEM_POOL_PORTS, CARD_POOL_PORT, firebase_store_manager
from pojo.ReserveResultPojo import ReserveResultPojo from pojo.ReserveResultPojo import ReserveResultPojo
from utils.excel_reader import ExcelHelper from utils.excel_reader import ExcelHelper
from pojo.serial_modem import SerialModem from pojo.serial_modem import SerialModem
@@ -22,7 +22,6 @@ OTP_TIMEOUT = 60
is_finished = False is_finished = False
commandor = Commandor() commandor = Commandor()
db_manager = DataManager()
card_pool = CardPool(CARD_POOL_PORT) card_pool = CardPool(CARD_POOL_PORT)
@@ -81,7 +80,7 @@ def create_modem_for_port(port: str) -> SerialModem:
def timeout_occurred(serial_modem: SerialModem): def timeout_occurred(serial_modem: SerialModem):
db_manager.save_timeout_contact(serial_modem.contact) firebase_store_manager.save_timeout_contact(serial_modem.contact)
def start_to_handle_sms(serial_modem: SerialModem): def start_to_handle_sms(serial_modem: SerialModem):
@@ -151,7 +150,7 @@ def on_message_received(ch, method, properties, body):
# parse the received message # parse the received message
result = ReserveResultPojo.from_json(body) result = ReserveResultPojo.from_json(body)
print(result) print(result)
db_manager.save(result) firebase_store_manager.save(result)
# set the flag to True # set the flag to True
global is_finished global is_finished
is_finished = True is_finished = True
@@ -164,8 +163,8 @@ def start_listen():
def read_all_the_phone_number(): def read_all_the_phone_number():
slot_number = 1 slot_number = 3
slot_sum = 3 slot_sum = 32
# card_pool.switch_to_slot(3) # card_pool.switch_to_slot(3)
for i in range(slot_number, slot_sum + 1): for i in range(slot_number, slot_sum + 1):
@@ -178,8 +177,8 @@ def read_all_the_phone_number():
def start_book(): def start_book():
slot_number = 3 slot_number = 1
slot_sum = 3 slot_sum = 32
for i in range(slot_number, slot_sum + 1): for i in range(slot_number, slot_sum + 1):
card_pool.reset() card_pool.reset()
print("will switch to " + str(i)) print("will switch to " + str(i))
@@ -198,6 +197,6 @@ if __name__ == '__main__':
init_logger() init_logger()
logger = logging.getLogger() logger = logging.getLogger()
logger.addHandler(logging.StreamHandler(stream=sys.stdout)) logger.addHandler(logging.StreamHandler(stream=sys.stdout))
# read_all_the_phone_number() read_all_the_phone_number()
start_listen() # start_listen()
start_book() # start_book()
params.py
+22 -17
View File
@@ -1,19 +1,24 @@
from db.DbManager import DataManager
MODEM_POOL_PORTS = [ MODEM_POOL_PORTS = [
"/dev/tty.usbmodem1431101", "/dev/tty.usbmodem11101",
"/dev/tty.usbmodem1431103", "/dev/tty.usbmodem11103",
"/dev/tty.usbmodem1431105", "/dev/tty.usbmodem11105",
"/dev/tty.usbmodem1431107", "/dev/tty.usbmodem11107",
"/dev/tty.usbmodem1431201", "/dev/tty.usbmodem11201",
"/dev/tty.usbmodem1431203", "/dev/tty.usbmodem11203",
"/dev/tty.usbmodem1431205", "/dev/tty.usbmodem11205",
"/dev/tty.usbmodem1431207", "/dev/tty.usbmodem11207",
"/dev/tty.usbmodem1431301", "/dev/tty.usbmodem11301",
## "/dev/tty.usbmodem1431303", ## "/dev/tty.usbmodem11303",
"/dev/tty.usbmodem1431305", "/dev/tty.usbmodem11305",
"/dev/tty.usbmodem1431307", "/dev/tty.usbmodem11307",
"/dev/tty.usbmodem1431401", "/dev/tty.usbmodem11401",
"/dev/tty.usbmodem1431403", "/dev/tty.usbmodem11403",
"/dev/tty.usbmodem1431405", "/dev/tty.usbmodem11405",
"/dev/tty.usbmodem1431407" "/dev/tty.usbmodem11407"
] ]
CARD_POOL_PORT = "/dev/tty.usbmodem1432101" CARD_POOL_PORT = "/dev/tty.usbmodem12101"
firebase_store_manager = DataManager()