equipment_operations.py 2.1 KB
Newer Older
lcn's avatar
lcn committed
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61
from pot_libs.sanic_api import summary
from unify_api.modules.zhiwei_u.components.equipment_operations_cps import \
    EquOptReq, EquOptResp, EdReq, EdResp, EdmReq, EcnReq, ErReq, EdmlReq
from unify_api.modules.zhiwei_u.procedures.common import zhiweiu_required
from unify_api.modules.zhiwei_u.service.equipment_operations_service import \
    equipment_operations_service, equipment_details_mysql_service, \
    equipment_details_mqtt_service, equipment_change_name_service, \
    equipment_replace_service, equipment_demolish_service


@summary('设备管理')
async def post_equipment_operations(req, body: EquOptReq) -> EquOptResp:
    prod_id = body.product
    cid = body.cid
    pid = body.pid
    page_size = body.page_size
    page_num = body.page_num
    sid = body.sid
    user_id = req.ctx.user_id
    return await equipment_operations_service(user_id, prod_id, cid, sid, pid,
                                              page_num, page_size)


@summary('设备管理-详情和修改-从mqtt获取数据')
async def post_equipment_details_mqtt(req, body: EdReq) -> EdResp:
    sid = body.sid
    mtid = body.mtid
    return await equipment_details_mqtt_service(sid, mtid)


@summary('设备管理-详情和修改-从mysql获取数据')
async def post_equipment_details_mysql(req, body: EdmReq) -> EdResp:
    sid = body.sid
    mtid = body.mtid
    return await equipment_details_mysql_service(sid, mtid)


@summary('设备管理-修改-安装点更名')
@zhiweiu_required()
async def post_equipment_change_name(req, body: EcnReq):
    mtid = int(body.mtid)
    pid = body.pid
    new_name = body.new_name
    return await equipment_change_name_service(mtid, pid, new_name)


@summary('设备管理-修改-装置更换')
@zhiweiu_required()
async def post_equipment_replace(req, body: ErReq):
    cid = body.cid
    sid = body.sid
    new_sid = body.new_sid
    return await equipment_replace_service(cid, sid, new_sid)


@summary('设备管理-修改-装置拆除')
@zhiweiu_required()
async def post_equipment_demolish(req, body: EdmlReq):
    cid = body.cid
    sid = body.sid
    return await equipment_demolish_service(cid, sid)