|
@@ -290,12 +290,19 @@ async def readjust_all_target(project_id: str, space_id: str, wechat_time: str):
|
|
|
platform = DataPlatformService(client, project_id)
|
|
|
|
|
|
realtime_temperature = await platform.get_realtime_temperature(space_id)
|
|
|
+ logger.debug(realtime_temperature)
|
|
|
current_targets = await transfer.get_custom_target()
|
|
|
+ logger.debug(current_targets)
|
|
|
feedback = await transfer.get_feedback(wechat_time)
|
|
|
+ logger.debug(feedback)
|
|
|
is_customized = await transfer.is_customized()
|
|
|
+ logger.debug(is_customized)
|
|
|
is_temporary = await transfer.is_temporary()
|
|
|
+ logger.debug(is_temporary)
|
|
|
season = await transfer.get_season()
|
|
|
+ logger.debug(season)
|
|
|
previous_changes = await transfer.env_database_get()
|
|
|
+ logger.debug(previous_changes)
|
|
|
|
|
|
if feedback.get('switch off') and feedback.get('switch off') > 0:
|
|
|
need_switch_off = True
|
|
@@ -336,10 +343,13 @@ async def readjust_all_target(project_id: str, space_id: str, wechat_time: str):
|
|
|
transfer = SpaceInfoService(client, project_id, space_id)
|
|
|
|
|
|
if temperature_results.get('temporary_targets'):
|
|
|
+ logger.debug(temperature_results.get('temporary_targets'))
|
|
|
await transfer.set_custom_target('temperature', temperature_results.get('temporary_targets'), '0')
|
|
|
if temperature_results.get('global_targets'):
|
|
|
+ logger.debug(temperature_results.get('global_targets'))
|
|
|
await transfer.set_custom_target('temperature', temperature_results.get('global_targets'), '1')
|
|
|
if temperature_results.get('latest_change'):
|
|
|
+ logger.debug(temperature_results.get('latest_change'))
|
|
|
await transfer.env_database_set('temperature', temperature_results.get('latest_change'))
|
|
|
|
|
|
return need_run_room_control
|