git.basschouten.com Git - openhab-addons.git/blob

   1 /**
   2  * Copyright (c) 2010-2024 Contributors to the openHAB project
   3  *
   4  * See the NOTICE file(s) distributed with this work for additional
   5  * information.
   6  *
   7  * This program and the accompanying materials are made available under the
   8  * terms of the Eclipse Public License 2.0 which is available at
   9  * http://www.eclipse.org/legal/epl-2.0
  10  *
  11  * SPDX-License-Identifier: EPL-2.0
  12  */
  13 package org.openhab.binding.electroluxair.internal.handler;
  14
  15 import static org.openhab.binding.electroluxair.internal.ElectroluxAirBindingConstants.*;
  16
  17 import java.util.HashMap;
  18 import java.util.Map;
  19
  20 import org.eclipse.jdt.annotation.NonNullByDefault;
  21 import org.eclipse.jdt.annotation.Nullable;
  22 import org.openhab.binding.electroluxair.internal.ElectroluxAirBindingConstants;
  23 import org.openhab.binding.electroluxair.internal.ElectroluxAirConfiguration;
  24 import org.openhab.binding.electroluxair.internal.api.ElectroluxDeltaAPI;
  25 import org.openhab.binding.electroluxair.internal.dto.ElectroluxPureA9DTO;
  26 import org.openhab.core.library.types.OnOffType;
  27 import org.openhab.core.library.types.OpenClosedType;
  28 import org.openhab.core.library.types.QuantityType;
  29 import org.openhab.core.library.types.StringType;
  30 import org.openhab.core.library.unit.SIUnits;
  31 import org.openhab.core.library.unit.Units;
  32 import org.openhab.core.thing.Bridge;
  33 import org.openhab.core.thing.Channel;
  34 import org.openhab.core.thing.ChannelUID;
  35 import org.openhab.core.thing.Thing;
  36 import org.openhab.core.thing.ThingStatus;
  37 import org.openhab.core.thing.binding.BaseThingHandler;
  38 import org.openhab.core.thing.binding.BridgeHandler;
  39 import org.openhab.core.types.Command;
  40 import org.openhab.core.types.RefreshType;
  41 import org.openhab.core.types.State;
  42 import org.openhab.core.types.UnDefType;
  43 import org.slf4j.Logger;
  44 import org.slf4j.LoggerFactory;
  45
  46 /**
  47  * The {@link ElectroluxAirHandler} is responsible for handling commands, which are
  48  * sent to one of the channels.
  49  *
  50  * @author Jan Gustafsson - Initial contribution
  51  */
  52 @NonNullByDefault
  53 public class ElectroluxAirHandler extends BaseThingHandler {
  54
  55     private final Logger logger = LoggerFactory.getLogger(ElectroluxAirHandler.class);
  56
  57     private ElectroluxAirConfiguration config = new ElectroluxAirConfiguration();
  58
  59     public ElectroluxAirHandler(Thing thing) {
  60         super(thing);
  61     }
  62
  63     @Override
  64     public void handleCommand(ChannelUID channelUID, Command command) {
  65         logger.debug("Command received: {}", command);
  66         if (CHANNEL_STATUS.equals(channelUID.getId()) || command instanceof RefreshType) {
  67             Bridge bridge = getBridge();
  68             if (bridge != null) {
  69                 BridgeHandler bridgeHandler = bridge.getHandler();
  70                 if (bridgeHandler != null) {
  71                     bridgeHandler.handleCommand(channelUID, command);
  72                 }
  73             }
  74         } else {
  75             ElectroluxPureA9DTO dto = getElectroluxPureA9DTO();
  76             ElectroluxDeltaAPI api = getElectroluxDeltaAPI();
  77             if (api != null && dto != null) {
  78                 if (CHANNEL_WORK_MODE.equals(channelUID.getId())) {
  79                     if (command.toString().equals(COMMAND_WORKMODE_POWEROFF)) {
  80                         api.workModePowerOff(dto.getApplianceId());
  81                     } else if (command.toString().equals(COMMAND_WORKMODE_AUTO)) {
  82                         api.workModeAuto(dto.getApplianceId());
  83                     } else if (command.toString().equals(COMMAND_WORKMODE_MANUAL)) {
  84                         api.workModeManual(dto.getApplianceId());
  85                     }
  86                 } else if (CHANNEL_FAN_SPEED.equals(channelUID.getId())) {
  87                     api.setFanSpeedLevel(dto.getApplianceId(), Integer.parseInt(command.toString()));
  88                 } else if (CHANNEL_IONIZER.equals(channelUID.getId())) {
  89                     if (command == OnOffType.OFF) {
  90                         api.setIonizer(dto.getApplianceId(), "false");
  91                     } else if (command == OnOffType.ON) {
  92                         api.setIonizer(dto.getApplianceId(), "true");
  93                     } else {
  94                         logger.debug("Unknown command! {}", command);
  95                     }
  96                 } else if (CHANNEL_UI_LIGHT.equals(channelUID.getId())) {
  97                     if (command == OnOffType.OFF) {
  98                         api.setUILight(dto.getApplianceId(), "false");
  99                     } else if (command == OnOffType.ON) {
 100                         api.setUILight(dto.getApplianceId(), "true");
 101                     } else {
 102                         logger.debug("Unknown command! {}", command);
 103                     }
 104                 } else if (CHANNEL_SAFETY_LOCK.equals(channelUID.getId())) {
 105                     if (command == OnOffType.OFF) {
 106                         api.setSafetyLock(dto.getApplianceId(), "false");
 107                     } else if (command == OnOffType.ON) {
 108                         api.setSafetyLock(dto.getApplianceId(), "true");
 109                     } else {
 110                         logger.debug("Unknown command! {}", command);
 111                     }
 112                 }
 113
 114                 Bridge bridge = getBridge();
 115                 if (bridge != null) {
 116                     BridgeHandler bridgeHandler = bridge.getHandler();
 117                     if (bridgeHandler != null) {
 118                         bridgeHandler.handleCommand(
 119                                 new ChannelUID(this.thing.getUID(), ElectroluxAirBindingConstants.CHANNEL_STATUS),
 120                                 RefreshType.REFRESH);
 121                     }
 122                 }
 123             }
 124         }
 125     }
 126
 127     @Override
 128     public void initialize() {
 129         config = getConfigAs(ElectroluxAirConfiguration.class);
 130         updateStatus(ThingStatus.UNKNOWN);
 131
 132         scheduler.execute(() -> {
 133             update();
 134             Map<String, String> properties = refreshProperties();
 135             updateProperties(properties);
 136         });
 137     }
 138
 139     public void update() {
 140         ElectroluxPureA9DTO dto = getElectroluxPureA9DTO();
 141         if (dto != null) {
 142             update(dto);
 143         } else {
 144             logger.warn("ElectroluxPureA9DTO is null!");
 145         }
 146     }
 147
 148     private @Nullable ElectroluxDeltaAPI getElectroluxDeltaAPI() {
 149         Bridge bridge = getBridge();
 150         if (bridge != null) {
 151             ElectroluxAirBridgeHandler handler = (ElectroluxAirBridgeHandler) bridge.getHandler();
 152             if (handler != null) {
 153                 return handler.getElectroluxDeltaAPI();
 154             }
 155         }
 156         return null;
 157     }
 158
 159     private @Nullable ElectroluxPureA9DTO getElectroluxPureA9DTO() {
 160         Bridge bridge = getBridge();
 161         if (bridge != null) {
 162             ElectroluxAirBridgeHandler bridgeHandler = (ElectroluxAirBridgeHandler) bridge.getHandler();
 163             if (bridgeHandler != null) {
 164                 return bridgeHandler.getElectroluxAirThings().get(config.getDeviceId());
 165             }
 166         }
 167         return null;
 168     }
 169
 170     private void update(@Nullable ElectroluxPureA9DTO dto) {
 171         if (dto != null) {
 172             // Update all channels from the updated data
 173             getThing().getChannels().stream().map(Channel::getUID).filter(channelUID -> isLinked(channelUID))
 174                     .forEach(channelUID -> {
 175                         State state = getValue(channelUID.getId(), dto);
 176                         logger.trace("Channel: {}, State: {}", channelUID, state);
 177                         updateState(channelUID, state);
 178                     });
 179             updateStatus(ThingStatus.ONLINE);
 180         }
 181     }
 182
 183     private State getValue(String channelId, ElectroluxPureA9DTO dto) {
 184         switch (channelId) {
 185             case CHANNEL_TEMPERATURE:
 186                 return new QuantityType<>(dto.getProperties().getReported().getTemp(), SIUnits.CELSIUS);
 187             case CHANNEL_HUMIDITY:
 188                 return new QuantityType<>(dto.getProperties().getReported().getHumidity(), Units.PERCENT);
 189             case CHANNEL_TVOC:
 190                 return new QuantityType<>(dto.getProperties().getReported().getTVOC(), Units.MICROGRAM_PER_CUBICMETRE);
 191             case CHANNEL_PM1:
 192                 return new QuantityType<>(dto.getProperties().getReported().getPM1(), Units.PARTS_PER_BILLION);
 193             case CHANNEL_PM25:
 194                 return new QuantityType<>(dto.getProperties().getReported().getPM25(), Units.PARTS_PER_BILLION);
 195             case CHANNEL_PM10:
 196                 return new QuantityType<>(dto.getProperties().getReported().getPM10(), Units.PARTS_PER_BILLION);
 197             case CHANNEL_CO2:
 198                 return new QuantityType<>(dto.getProperties().getReported().getCO2(), Units.PARTS_PER_MILLION);
 199             case CHANNEL_FAN_SPEED:
 200                 return new StringType(Integer.toString(dto.getProperties().getReported().getFanspeed()));
 201             case CHANNEL_FILTER_LIFE:
 202                 return new QuantityType<>(dto.getProperties().getReported().getFilterLife(), Units.PERCENT);
 203             case CHANNEL_IONIZER:
 204                 return OnOffType.from(dto.getProperties().getReported().isIonizer());
 205             case CHANNEL_UI_LIGHT:
 206                 return OnOffType.from(dto.getProperties().getReported().isUILight());
 207             case CHANNEL_SAFETY_LOCK:
 208                 return OnOffType.from(dto.getProperties().getReported().isSafetyLock());
 209             case CHANNEL_WORK_MODE:
 210                 return new StringType(dto.getProperties().getReported().getWorkmode());
 211             case CHANNEL_DOOR_OPEN:
 212                 return dto.getProperties().getReported().isDoorOpen() ? OpenClosedType.OPEN : OpenClosedType.CLOSED;
 213         }
 214         return UnDefType.UNDEF;
 215     }
 216
 217     private Map<String, String> refreshProperties() {
 218         Map<String, String> properties = new HashMap<>();
 219         Bridge bridge = getBridge();
 220         if (bridge != null) {
 221             ElectroluxAirBridgeHandler bridgeHandler = (ElectroluxAirBridgeHandler) bridge.getHandler();
 222             if (bridgeHandler != null) {
 223                 ElectroluxPureA9DTO dto = bridgeHandler.getElectroluxAirThings().get(config.getDeviceId());
 224                 if (dto != null) {
 225                     properties.put(Thing.PROPERTY_VENDOR, dto.getApplianceInfo().getBrand());
 226                     properties.put(PROPERTY_COLOUR, dto.getApplianceInfo().getColour());
 227                     properties.put(PROPERTY_DEVICE, dto.getApplianceInfo().getDeviceType());
 228                     properties.put(Thing.PROPERTY_MODEL_ID, dto.getApplianceInfo().getModel());
 229                     properties.put(Thing.PROPERTY_SERIAL_NUMBER, dto.getApplianceInfo().getSerialNumber());
 230                     properties.put(Thing.PROPERTY_FIRMWARE_VERSION, dto.getProperties().getReported().getFrmVerNIU());
 231                 }
 232             }
 233         }
 234         return properties;
 235     }
 236 }