123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145 |
- from fastapi import APIRouter, BackgroundTasks, Depends, Query
- from sqlalchemy.orm import Session
- import app.models.domain.devices as domain_devices
- from app.api.dependencies.db import get_db
- from app.controllers.equipment.ahu.supply_air_temperature_set import get_next_supply_air_temperature_set
- from app.controllers.equipment.ahu.thermal_mode import get_thermal_mode
- from app.controllers.equipment.fcu.basic import build_acatfc_instructions
- from app.controllers.equipment.fcu.early_start import get_recommended_early_start_time
- from app.controllers.equipment.fcu.on_ratio import start_on_ratio_mode
- from app.controllers.equipment.pau.freq_set import get_next_acatfu_freq_set
- from app.controllers.equipment.pau.supply_air_temperature_set import get_next_acatfu_supply_air_temperature_set
- from app.controllers.equipment.pau.switch import get_switch_action
- from app.controllers.equipment.vav import build_acatva_instructions
- from app.controllers.equipment.vrf.basic import build_acatvi_instructions
- from app.models.domain.devices import DevicesInstructionsBaseResponse, DevicesEarlyStartTime
- router = APIRouter()
- @router.get('/instructions/acatah/thermal-mode-set', response_model=DevicesInstructionsBaseResponse)
- async def get_acatah_thermal_mode_set(
- project_id: str = Query(..., max_length=50, regex='^Pj', alias='projectId'),
- device_id: str = Query(..., max_length=50, regex='^Eq', alias='equipId')
- ):
- thermal_mode = await get_thermal_mode(project_id, device_id)
- return {
- 'projectId': project_id,
- 'equipId': device_id,
- 'output': {
- 'thermalModeSet': thermal_mode
- }
- }
- @router.get('/instructions/acatah/supply-air-temperature-set', response_model=DevicesInstructionsBaseResponse)
- async def get_acatah_supply_air_temperature_set(
- project_id: str = Query(..., max_length=50, regex='^Pj', alias='projectId'),
- device_id: str = Query(..., max_length=50, regex='^Eq', alias='equipId')
- ):
- next_supply_air_temperature_set = await get_next_supply_air_temperature_set(project_id, device_id)
- return {
- 'projectId': project_id,
- 'equipId': device_id,
- 'output': {
- 'supplyAirTemperatureSet': next_supply_air_temperature_set
- }
- }
- @router.post('/on-ratio-experiment/fcu/{fcu_id}/target/{target}/period/{period}')
- async def run_on_ratio_experiment(fcu_id: str, target: float, period: int, background_tasks: BackgroundTasks):
- background_tasks.add_task(start_on_ratio_mode, fcu_id, target, period)
- return {
- 'fcu': fcu_id,
- 'target': target,
- 'period': period
- }
- @router.get('/instructions/acatfu/equip-switch-set', response_model=DevicesInstructionsBaseResponse)
- async def get_acatfu_equip_switch_set(
- project_id: str = Query(..., max_length=50, regex='^Pj', alias='projectId'),
- device_id: str = Query(..., max_length=50, regex='^Eq', alias='equipId')
- ):
- action = await get_switch_action(project_id, device_id)
- return {
- 'projectId': project_id,
- 'equipId': device_id,
- 'output': {
- 'equipSwitchSet': action
- }
- }
- @router.get('/instructions/acatfu/supply-air-temperature-set', response_model=DevicesInstructionsBaseResponse)
- async def get_acatfu_supply_air_temperature_set(
- project_id: str = Query(..., max_length=50, regex='^Pj', alias='projectId'),
- device_id: str = Query(..., max_length=50, regex='^Eq', alias='equipId')
- ):
- temperature_set = await get_next_acatfu_supply_air_temperature_set(project_id, device_id)
- return {
- 'projectId': project_id,
- 'equipId': device_id,
- 'output': {
- 'supplyAirTemperatureSet': temperature_set
- }
- }
- @router.get('/instructions/acatfu/freq-set', response_model=DevicesInstructionsBaseResponse)
- async def get_acatfu_freq_set(
- project_id: str = Query(..., max_length=50, regex='^Pj', alias='projectId'),
- device_id: str = Query(..., max_length=50, regex='^Eq', alias='equipId')
- ):
- freq_set = await get_next_acatfu_freq_set(project_id, device_id)
- return {
- 'projectId': project_id,
- 'equipId': device_id,
- 'output': {
- 'fanFreqSet': freq_set
- }
- }
- @router.get('/early-start/prediction/acatfc', response_model=DevicesEarlyStartTime)
- async def get_acatfc_early_start_time(
- project_id: str = Query(..., max_length=50, regex='^Pj', alias='projectId'),
- space_id: str = Query(..., max_length=50, regex='^Sp', alias='spaceId'),
- db: Session = Depends(get_db)
- ):
- minutes = await get_recommended_early_start_time(db, project_id, space_id)
- return {
- 'projectId': project_id,
- 'spaceId': space_id,
- 'minutes': minutes
- }
- @router.post('/instructions/acatvi', response_model=domain_devices.ACATVIInstructionsTemporaryResponse)
- async def get_acatvi_instructions(params: domain_devices.ACATVIInstructionsRequest):
- instructions = await build_acatvi_instructions(params)
- return {
- 'output': instructions
- }
- @router.post('/instructions/acatfc', response_model=domain_devices.ACATFCInstructionsResponse)
- async def get_acatfc_instructions(params: domain_devices.ACATFCInstructionsRequest):
- instructions = await build_acatfc_instructions(params)
- return instructions
- @router.post('/instructions/acatva', response_model=domain_devices.ACATVAInstructionsResponse)
- async def get_acatva_instructions(params: domain_devices.ACATVAInstructionsRequest):
- instructions = await build_acatva_instructions(params)
- return instructions
|