analysis_result_dao.py 668 Bytes
from pot_libs.mysql_util.mysql_util import MysqlUtil


async def query_sdu_power_wave(pid, cal_day):
    """根据pid和时间查询功率波动数据"""
    async with MysqlUtil() as conn:
        sql = "select * from sdu_power_wave where pid=%s and cal_day=%s"
        res = await conn.fetchone(sql, args=(pid, cal_day))
    return res


async def query_sdu_recog_record(pid, start, end):
    """根据pid查询用电设备识别结果"""
    async with MysqlUtil() as conn:
        sql = "select * from sdu_recog_record where pid=%s " \
              "and recog_dt>=%s and recog_dt<=%s"
        res = await conn.fetchall(sql, args=(pid, start, end))
    return res