basic.py 4.6 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118
  1. # -*- coding: utf-8 -*-
  2. from typing import Dict, List, Optional
  3. import numpy as np
  4. from httpx import AsyncClient
  5. from loguru import logger
  6. from app.schemas.equipment import AHU
  7. from app.schemas.system import ACAT
  8. from app.services.platform import DataPlatformService, InfoCode
  9. from app.services.transfer import Duoduo
  10. from app.services.weather import WeatherService
  11. class AHUController:
  12. def __init__(self, equipment: Optional[AHU] = None, system: Optional[ACAT] = None):
  13. super(AHUController, self).__init__()
  14. self._equipment = equipment
  15. self._system = system
  16. async def build_freq_set(self, supply_air_temperature_set_duration: List, hot_rate: float) -> float:
  17. extent = 5
  18. if np.isnan(self._equipment.fan_freq_set)\
  19. or np.isnan(self._system.supply_static_press)\
  20. or np.isnan(self._system.supply_static_press_set):
  21. temp_freq_set = 80.0
  22. else:
  23. pre_fan_freq_set = self._equipment.fan_freq_set
  24. if self._system.supply_static_press < self._system.supply_static_press_set - extent:
  25. temp_freq_set = pre_fan_freq_set + 2
  26. elif self._system.supply_static_press > self._system.supply_static_press_set + extent:
  27. temp_freq_set = pre_fan_freq_set - 2
  28. else:
  29. temp_freq_set = pre_fan_freq_set
  30. temperature_value_list = np.array([item['value'] for item in supply_air_temperature_set_duration])
  31. freq_upper_limit = 90.0
  32. if temperature_value_list.size > 0\
  33. and np.all(temperature_value_list == temperature_value_list[0])\
  34. and temperature_value_list[0] <= 18.0\
  35. and hot_rate >= 0.5:
  36. freq_upper_limit = 100.0
  37. freq_set = min(temp_freq_set, freq_upper_limit)
  38. return freq_set
  39. @staticmethod
  40. async def build_supply_air_temperature(outdoor_temperature: float) -> float:
  41. if outdoor_temperature <= 19.0:
  42. supply_air_temperature = 22.0
  43. elif outdoor_temperature <= 24.0:
  44. supply_air_temperature = 21.0
  45. elif outdoor_temperature <= 29.0:
  46. supply_air_temperature = 20.0
  47. elif outdoor_temperature <= 33.0:
  48. supply_air_temperature = 19.0
  49. else:
  50. supply_air_temperature = 18.0
  51. return supply_air_temperature
  52. @logger.catch()
  53. async def get_freq_controlled(project_id: str, equipment_id: str) -> None:
  54. async with AsyncClient() as client:
  55. platform = DataPlatformService(client, project_id)
  56. review_service = Duoduo(client, project_id)
  57. fan_freq_set = await platform.get_realtime_fan_freq_set(equipment_id)
  58. # system = await equip_service.get_system_by_equipment(equipment_id)
  59. system = ['Sy1101050030eab54ad66b084a1cb1b919950b263280']
  60. press = await platform.get_realtime_supply_static_press(system[0])
  61. press_set = await platform.get_realtime_supply_static_press_set(system[0])
  62. hot_rate = await review_service.get_fill_rate()
  63. supply_air_temperature_set = await platform.get_duration(
  64. InfoCode.supply_air_temperature_set,
  65. equipment_id,
  66. 30 * 60
  67. )
  68. equip_params = {
  69. 'id': equipment_id,
  70. 'fan_freq_set': fan_freq_set
  71. }
  72. ahu = AHU(**equip_params)
  73. system_params = {
  74. 'id': system[0],
  75. 'supply_static_press': press,
  76. 'supply_static_press_set': press_set
  77. }
  78. acat_system = ACAT(**system_params)
  79. ahu_controller = AHUController(ahu, acat_system)
  80. new_freq_set = await ahu_controller.build_freq_set(supply_air_temperature_set, hot_rate)
  81. # logger.debug(f'{equipment_id} freq set: {new_freq_set}')
  82. async with AsyncClient() as client:
  83. platform = DataPlatformService(client, project_id)
  84. await platform.set_code_value(equipment_id, InfoCode.fan_freq_set, new_freq_set)
  85. @logger.catch()
  86. async def get_supply_air_temperature_controlled(project_id: str, equipment_id: str) -> None:
  87. async with AsyncClient() as client:
  88. weather_service = WeatherService(client)
  89. realtime_weather = await weather_service.get_realtime_weather(project_id)
  90. outdoor_temperature = float(realtime_weather.get('temperature'))
  91. ahu_controller = AHUController()
  92. new_supply_air_temperature_set = await ahu_controller.build_supply_air_temperature(outdoor_temperature)
  93. # logger.debug(f'{equipment_id} supply air temperature set: {new_supply_air_temperature_set}')
  94. async with AsyncClient() as client:
  95. platform = DataPlatformService(client, project_id)
  96. await platform.set_code_value(equipment_id, InfoCode.supply_air_temperature_set, new_supply_air_temperature_set)