]> git.basschouten.com Git - openhab-addons.git/blob
a1e24492ea570433e7e47c233aa6c13c6baa9da8
[openhab-addons.git] /
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.ElectroluxAirConfiguration;
26 import org.openhab.binding.electroluxair.internal.api.ElectroluxDeltaAPI;
27 import org.openhab.binding.electroluxair.internal.dto.ElectroluxPureA9DTO;
28 import org.openhab.core.library.dimension.Density;
29 import org.openhab.core.library.types.OnOffType;
30 import org.openhab.core.library.types.OpenClosedType;
31 import org.openhab.core.library.types.QuantityType;
32 import org.openhab.core.library.types.StringType;
33 import org.openhab.core.library.unit.SIUnits;
34 import org.openhab.core.library.unit.Units;
35 import org.openhab.core.thing.Bridge;
36 import org.openhab.core.thing.Channel;
37 import org.openhab.core.thing.ChannelUID;
38 import org.openhab.core.thing.Thing;
39 import org.openhab.core.thing.ThingStatus;
40 import org.openhab.core.thing.binding.BaseThingHandler;
41 import org.openhab.core.types.Command;
42 import org.openhab.core.types.RefreshType;
43 import org.openhab.core.types.State;
44 import org.openhab.core.types.UnDefType;
45 import org.slf4j.Logger;
46 import org.slf4j.LoggerFactory;
47
48 /**
49  * The {@link ElectroluxAirHandler} is responsible for handling commands, which are
50  * sent to one of the channels.
51  *
52  * @author Jan Gustafsson - Initial contribution
53  */
54 @NonNullByDefault
55 public class ElectroluxAirHandler extends BaseThingHandler {
56
57     private final Logger logger = LoggerFactory.getLogger(ElectroluxAirHandler.class);
58
59     private ElectroluxAirConfiguration config = new ElectroluxAirConfiguration();
60
61     public ElectroluxAirHandler(Thing thing) {
62         super(thing);
63     }
64
65     @Override
66     public void handleCommand(ChannelUID channelUID, Command command) {
67         logger.debug("Command received: {}", command);
68         if (CHANNEL_STATUS.equals(channelUID.getId()) || command instanceof RefreshType) {
69             update();
70         } else {
71             ElectroluxPureA9DTO dto = getElectroluxPureA9DTO();
72             ElectroluxDeltaAPI api = getElectroluxDeltaAPO();
73             if (api != null && dto != null) {
74                 if (CHANNEL_WORK_MODE.equals(channelUID.getId())) {
75                     if (command.toString().equals(COMMAND_WORKMODE_POWEROFF)) {
76                         api.workModePowerOff(dto.getPncId());
77                     } else if (command.toString().equals(COMMAND_WORKMODE_AUTO)) {
78                         api.workModeAuto(dto.getPncId());
79                     } else if (command.toString().equals(COMMAND_WORKMODE_MANUAL)) {
80                         api.workModeManual(dto.getPncId());
81                     }
82                 } else if (CHANNEL_FAN_SPEED.equals(channelUID.getId())) {
83                     api.setFanSpeedLevel(dto.getPncId(), Integer.parseInt(command.toString()));
84                 } else if (CHANNEL_IONIZER.equals(channelUID.getId())) {
85                     if (command == OnOffType.OFF) {
86                         api.setIonizer(dto.getPncId(), "false");
87                     } else if (command == OnOffType.ON) {
88                         api.setIonizer(dto.getPncId(), "true");
89                     } else {
90                         logger.debug("Unknown command! {}", command);
91                     }
92                 }
93             }
94         }
95     }
96
97     @Override
98     public void initialize() {
99         config = getConfigAs(ElectroluxAirConfiguration.class);
100         updateStatus(ThingStatus.UNKNOWN);
101
102         scheduler.execute(() -> {
103             update();
104             Map<String, String> properties = refreshProperties();
105             updateProperties(properties);
106         });
107     }
108
109     public void update() {
110         ElectroluxPureA9DTO dto = getElectroluxPureA9DTO();
111         if (dto != null) {
112             update(dto);
113         } else {
114             logger.warn("ElectroluxPureA9DTO is null!");
115         }
116     }
117
118     private @Nullable ElectroluxDeltaAPI getElectroluxDeltaAPO() {
119         Bridge bridge = getBridge();
120         if (bridge != null) {
121             ElectroluxAirBridgeHandler handler = (ElectroluxAirBridgeHandler) bridge.getHandler();
122             if (handler != null) {
123                 return handler.getElectroluxDeltaAPI();
124             }
125         }
126         return null;
127     }
128
129     private @Nullable ElectroluxPureA9DTO getElectroluxPureA9DTO() {
130         Bridge bridge = getBridge();
131         if (bridge != null) {
132             ElectroluxAirBridgeHandler bridgeHandler = (ElectroluxAirBridgeHandler) bridge.getHandler();
133             if (bridgeHandler != null) {
134                 return bridgeHandler.getElectroluxAirThings().get(config.getDeviceId());
135             }
136         }
137         return null;
138     }
139
140     private void update(@Nullable ElectroluxPureA9DTO dto) {
141         if (dto != null) {
142             // Update all channels from the updated data
143             getThing().getChannels().stream().map(Channel::getUID).filter(channelUID -> isLinked(channelUID))
144                     .forEach(channelUID -> {
145                         State state = getValue(channelUID.getId(), dto);
146                         updateState(channelUID, state);
147                     });
148             updateStatus(ThingStatus.ONLINE);
149         }
150     }
151
152     private State getValue(String channelId, ElectroluxPureA9DTO dto) {
153         switch (channelId) {
154             case CHANNEL_TEMPERATURE:
155                 return new QuantityType<Temperature>(dto.getTwin().getProperties().getReported().getTemp(),
156                         SIUnits.CELSIUS);
157             case CHANNEL_HUMIDITY:
158                 return new QuantityType<Dimensionless>(dto.getTwin().getProperties().getReported().getHumidity(),
159                         Units.PERCENT);
160             case CHANNEL_TVOC:
161                 return new QuantityType<Density>(dto.getTwin().getProperties().getReported().gettVOC(),
162                         Units.MICROGRAM_PER_CUBICMETRE);
163             case CHANNEL_PM1:
164                 return new QuantityType<Dimensionless>(dto.getTwin().getProperties().getReported().getpM1(),
165                         Units.PARTS_PER_BILLION);
166             case CHANNEL_PM25:
167                 return new QuantityType<Dimensionless>(dto.getTwin().getProperties().getReported().getpM25(),
168                         Units.PARTS_PER_BILLION);
169             case CHANNEL_PM10:
170                 return new QuantityType<Dimensionless>(dto.getTwin().getProperties().getReported().getpM10(),
171                         Units.PARTS_PER_BILLION);
172             case CHANNEL_CO2:
173                 return new QuantityType<Dimensionless>(dto.getTwin().getProperties().getReported().getcO2(),
174                         Units.PARTS_PER_MILLION);
175             case CHANNEL_FAN_SPEED:
176                 return new StringType(Integer.toString(dto.getTwin().getProperties().getReported().getFanspeed()));
177             case CHANNEL_FILTER_LIFE:
178                 return new QuantityType<Dimensionless>(dto.getTwin().getProperties().getReported().getFilterLife(),
179                         Units.PERCENT);
180             case CHANNEL_IONIZER:
181                 return OnOffType.from(dto.getTwin().getProperties().getReported().ionizer);
182             case CHANNEL_WORK_MODE:
183                 return new StringType(dto.getTwin().getProperties().getReported().workmode);
184             case CHANNEL_DOOR_OPEN:
185                 return dto.getTwin().getProperties().getReported().doorOpen ? OpenClosedType.OPEN
186                         : OpenClosedType.CLOSED;
187         }
188         return UnDefType.UNDEF;
189     }
190
191     private Map<String, String> refreshProperties() {
192         Map<String, String> properties = new HashMap<>();
193         Bridge bridge = getBridge();
194         if (bridge != null) {
195             ElectroluxAirBridgeHandler bridgeHandler = (ElectroluxAirBridgeHandler) bridge.getHandler();
196             if (bridgeHandler != null) {
197                 ElectroluxPureA9DTO dto = bridgeHandler.getElectroluxAirThings().get(config.getDeviceId());
198                 if (dto != null) {
199                     properties.put(Thing.PROPERTY_VENDOR, dto.getApplicancesInfo().brand);
200                     properties.put(PROPERTY_COLOUR, dto.getApplicancesInfo().colour);
201                     properties.put(PROPERTY_DEVICE, dto.getApplicancesInfo().device);
202                     properties.put(Thing.PROPERTY_MODEL_ID, dto.getApplicancesInfo().model);
203                     properties.put(Thing.PROPERTY_SERIAL_NUMBER, dto.getApplicancesInfo().serialNumber);
204                     properties.put(Thing.PROPERTY_FIRMWARE_VERSION,
205                             dto.getTwin().getProperties().getReported().frmVerNIU);
206                 }
207             }
208         }
209         return properties;
210     }
211 }