drop_dust.py 2.57 KB
Newer Older
lcn's avatar
lcn committed
1 2 3 4 5 6 7 8 9 10 11 12
from pot_libs.sanic_api import summary
from unify_api.modules.tsp_water.components.drop_dust_cps import DdReq, DdResp, \
    DdwReq, DdwResp, DeReq, IrmResp, IosResp, ItiResp, WsStatiReq, WsStatiResp
from unify_api.modules.tsp_water.service.drop_dust_service import \
    post_drop_dust_service, post_drop_dust_wave_service, \
    drop_water_wave_service, index_run_monit_service, index_op_stat_service, \
    index_today_info_service, index_water_service, index_electric_service


@summary("降尘措施-卡片信息")
async def post_drop_dust(req, body: DdReq) -> DdResp:
    storeys = body.storeys
wang.wenrong's avatar
wang.wenrong committed
13 14 15
    return_list = []
    return DdResp(res_data=return_list)
    # return await post_drop_dust_service(storeys) todo:tsp 临时简单处理
lcn's avatar
lcn committed
16 17 18 19 20 21 22


@summary("降尘措施-雾炮-运行曲线")
async def post_drop_dust_wave(req, body: DdwReq) -> DdwResp:
    point_id = body.point_id
    start = body.start
    end = body.end
wang.wenrong's avatar
wang.wenrong committed
23
    # return await post_drop_dust_wave_service(point_id, start, end)
wang.wenrong's avatar
wang.wenrong committed
24 25
    return DdwResp(slots=[], value=[])

lcn's avatar
lcn committed
26 27 28 29 30 31

@summary("降尘措施-喷淋-运行曲线")
async def post_drop_water_wave(req, body: DdwReq) -> DdwResp:
    point_id = body.point_id  # 对应的tsp_id
    start = body.start
    end = body.end
wang.wenrong's avatar
wang.wenrong committed
32
    # return await drop_water_wave_service(point_id, start, end)
wang.wenrong's avatar
wang.wenrong committed
33 34
    return DdwResp(slots=[], value=[])

lcn's avatar
lcn committed
35 36 37 38

@summary("首页-运行监测-统计")
async def post_index_run_monit(req, body: DeReq) -> IrmResp:
    cid = body.cid
wang.wenrong's avatar
wang.wenrong committed
39
    # return await index_run_monit_service(cid)
wang.wenrong's avatar
wang.wenrong committed
40 41
    return IrmResp(water={}, fog_gun={})

lcn's avatar
lcn committed
42 43 44 45

@summary("首页-运行统计-扬尘")
async def post_index_op_stat(req, body: DeReq) -> IosResp:
    cid = body.cid
wang.wenrong's avatar
wang.wenrong committed
46
    # return await index_op_stat_service(cid)
wang.wenrong's avatar
wang.wenrong committed
47 48
    return IosResp(water={}, fog_gun={})

lcn's avatar
lcn committed
49 50 51 52

@summary("首页-今日数据-扬尘")
async def post_index_today_info(req, body: DeReq) -> ItiResp:
    cid = body.cid
wang.wenrong's avatar
wang.wenrong committed
53
    # return await index_today_info_service(cid)
wang.wenrong's avatar
wang.wenrong committed
54 55
    return ItiResp(pm2_5={}, pm10={}, tsp={}, today_water=0, today_kwh=0)

lcn's avatar
lcn committed
56 57 58 59 60 61

@summary("首页-运行趋势-喷淋")
async def post_index_water_stati(req, body: WsStatiReq) -> WsStatiResp:
    start = body.start
    end = body.end
    date_type = body.date_type
wang.wenrong's avatar
wang.wenrong committed
62
    # return await index_water_service(start, end, date_type)
wang.wenrong's avatar
wang.wenrong committed
63 64
    return WsStatiResp(pm2_5=[], pm10=[], tsp=[], water_or_electric=[], slots=[])

lcn's avatar
lcn committed
65 66 67 68 69 70

@summary("首页-运行趋势-雾炮")
async def post_index_wave_stati(req, body: WsStatiReq) -> WsStatiResp:
    cid = body.cid
    start = body.start
    end = body.end
wang.wenrong's avatar
wang.wenrong committed
71
    # return await index_electric_service(cid, start, end)
wang.wenrong's avatar
wang.wenrong committed
72
    return WsStatiResp(pm2_5=[], pm10=[], tsp=[], water_or_electric=[], slots=[])