from pot_libs.mysql_util.mysql_util import MysqlUtil
async def equipment_operations_dao(sql):
async with MysqlUtil() as conn:
data = await conn.fetchall(sql)
return data
async def total_equipment_operations_dao(sql):
async with MysqlUtil() as conn:
data = await conn.fetchone(sql)
return data
async def monitor_by_cid_sid(cid, sid):
sql = "SELECT * from monitor where cid = %s and sid = %s and demolished=0"
async with MysqlUtil() as conn:
monitor_dic = await conn.fetchone(sql, args=(cid, sid))
return monitor_dic
-
lcn authored7d4d2d0a