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

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