from pot_libs.sanic_api import summary
from unify_api.modules.tsp_water.components.drop_dust_cps import DtReq, \
    DtResp, ThReq, ThResp, TisReq, TisResp, DeReq, DeResp, SaResp, TcdResp, \
    TpdResp, AdReq, AdResp
from unify_api.modules.tsp_water.service.tsp_service import \
    real_time_service, tsp_history_service, tsp_index_statistics_service, \
    day_env_service, stat_analysis_service, tsp_predict_deviation_service, \
    tsp_contrast_deviation_service, analysis_describe_service


@summary("TSP信息-实时参数")
async def post_real_time(req, body: DtReq) -> DtResp:
    tsp_id = body.tsp_id
    # return await real_time_service(tsp_id)
    return DtResp(pm2_5=None, pm10=None, tsp=None)


@summary("TSP信息-历史曲线")
async def post_tsp_history(req, body: ThReq) -> ThResp:
    tsp_id = body.tsp_id
    start = body.start
    end = body.end
    # return await tsp_history_service(tsp_id, start, end)
    return ThResp(
        pm2_5={
            "threshold": 75,
            "value_slots": []
        },
        pm10={
            "threshold": 150,
            "value_slots": []
        },
        tsp={
            "threshold": 300,
            "value_slots": []
        },
        time_slots=[
            "string"
        ],
        pm2_5_predict={
            "value_slots": []
        },
        pm10_predict={
            "value_slots": []
        },
        tsp_predict={
            "value_slots": []
        },
        pm2_5_contrast={
            "value_slots": []
        },
        pm10_contrast={
            "value_slots": []
        }
    )


@summary("TSP信息-指标统计")
async def post_tsp_index_statistics(req, body: TisReq) -> TisResp:
    tsp_id = body.tsp_id
    start = body.start
    end = body.end
    # return await tsp_index_statistics_service(tsp_id, start, end)
    return TisResp(pm2_5={}, pm10={}, tsp={})


@summary("当日环境")
async def post_day_env(req, body: DeReq) -> DeResp:
    cid = body.cid
    return await day_env_service(cid)


@summary("统计分析-扬尘")
async def post_stat_analysis(req, body: ThReq) -> SaResp:
    cid = body.cid
    tsp_id = body.tsp_id
    start = body.start
    end = body.end
    # return await stat_analysis_service(cid, tsp_id, start, end)
    return SaResp(pm2_5=[], pm10=[], tsp=[], water=[], fog_gun=[],
                  time_slots=[], r_water_pm25={}, r_water_pm10={},
                  r_water_tsp={}, r_gun_pm25={}, r_gun_pm10={}, r_gun_tsp={})


@summary("TSP信息-预测偏差")
async def post_tsp_predict_deviation(req, body: TisReq) -> TpdResp:
    tsp_id = body.tsp_id
    start = body.start
    end = body.end
    # return await tsp_predict_deviation_service(tsp_id, start, end)
    return TpdResp(pm2_5={}, pm10={}, tsp={})


@summary("TSP信息-对比偏差")
async def post_tsp_contrast_deviation(req, body: TisReq) -> TcdResp:
    tsp_id = body.tsp_id
    start = body.start
    end = body.end
    # return await tsp_contrast_deviation_service(tsp_id, start, end)
    return TcdResp(pm2_5={}, pm10={})


@summary("统计分析-扬尘-描述")
async def post_analysis_describe(req, body: AdReq) -> AdResp:
    cid = body.cid
    start = body.start
    end = body.end
    page_num = body.page_num
    page_size = body.page_size
    measure_type = body.measure_type
    return await analysis_describe_service(cid, start, end, page_num,
                                           page_size, measure_type)