level_dao.py 1.66 KB
Newer Older
lcn's avatar
lcn committed
1 2 3 4 5
from pot_libs.mysql_util.mysql_util import MysqlUtil


async def inline_zdu_by_cid(cid):
    """inline_zdu"""
6 7
    sql = "SELECT * from inline iz inner join monitor m2 " \
          "on iz.mtid = m2.mtid where iz.cid = %s " \
lcn's avatar
lcn committed
8 9 10 11 12 13 14 15 16
          "order by iz.sort_num"
    async with MysqlUtil() as conn:
        inline_zdu_list = await conn.fetchall(sql, args=(cid,))
    return inline_zdu_list


async def feeder_by_cid(cid):
    """馈线"""
    sql = "SELECT * from feeder f inner join monitor m2 " \
wang.wenrong's avatar
wang.wenrong committed
17
          "on f.mtid = m2.mtid where f.cid = %s " \
lcn's avatar
lcn committed
18 19 20 21 22 23 24 25 26
          "order by f.sort_num"
    async with MysqlUtil() as conn:
        feeder_list = await conn.fetchall(sql, args=(cid,))
    return feeder_list


async def transformer_by_cid(cid):
    """变压器"""
    sql = "SELECT * from transformer t inner join monitor m2 " \
wang.wenrong's avatar
wang.wenrong committed
27
          "on t.mtid = m2.mtid where t.cid = %s " \
lcn's avatar
lcn committed
28 29 30 31 32 33 34 35 36
          "order by t.sort_num"
    async with MysqlUtil() as conn:
        transformer_list = await conn.fetchall(sql, args=(cid,))
    return transformer_list


async def power_dist_by_cid(cid):
    """配电"""
    sql = "SELECT * from power_dist pd inner join monitor m2 " \
wang.wenrong's avatar
wang.wenrong committed
37
          "on pd.mtid = m2.mtid where pd.cid = %s " \
lcn's avatar
lcn committed
38 39 40 41 42 43 44 45 46
          "order by pd.sort_num"
    async with MysqlUtil() as conn:
        power_dist_list = await conn.fetchall(sql, args=(cid,))
    return power_dist_list


async def device_level_by_cid(cid):
    """设备级"""
    sql = "SELECT * from device_level dl inner join monitor m2 " \
wang.wenrong's avatar
wang.wenrong committed
47
          "on dl.mtid = m2.mtid where dl.cid = %s " \
lcn's avatar
lcn committed
48 49 50 51
          "order by dl.sort_num"
    async with MysqlUtil() as conn:
        device_list = await conn.fetchall(sql, args=(cid,))
    return device_list