]> git.basschouten.com Git - openhab-addons.git/blob
ce3895fd67c4e4446ffcd5ad9e3fab224197103d
[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.shelly.internal.handler;
14
15 import static org.openhab.binding.shelly.internal.ShellyBindingConstants.*;
16 import static org.openhab.binding.shelly.internal.api1.Shelly1ApiJsonDTO.*;
17 import static org.openhab.binding.shelly.internal.util.ShellyUtils.*;
18
19 import org.eclipse.jdt.annotation.NonNullByDefault;
20 import org.eclipse.jetty.client.HttpClient;
21 import org.openhab.binding.shelly.internal.api.ShellyApiException;
22 import org.openhab.binding.shelly.internal.api1.Shelly1ApiJsonDTO.ShellyRollerStatus;
23 import org.openhab.binding.shelly.internal.api1.Shelly1ApiJsonDTO.ShellySettingsRelay;
24 import org.openhab.binding.shelly.internal.api1.Shelly1ApiJsonDTO.ShellySettingsStatus;
25 import org.openhab.binding.shelly.internal.api1.Shelly1ApiJsonDTO.ShellyShortLightStatus;
26 import org.openhab.binding.shelly.internal.api1.Shelly1CoapServer;
27 import org.openhab.binding.shelly.internal.config.ShellyBindingConfiguration;
28 import org.openhab.binding.shelly.internal.provider.ShellyChannelDefinitions;
29 import org.openhab.binding.shelly.internal.provider.ShellyTranslationProvider;
30 import org.openhab.core.library.types.DecimalType;
31 import org.openhab.core.library.types.IncreaseDecreaseType;
32 import org.openhab.core.library.types.OnOffType;
33 import org.openhab.core.library.types.PercentType;
34 import org.openhab.core.library.types.StopMoveType;
35 import org.openhab.core.library.types.UpDownType;
36 import org.openhab.core.library.unit.Units;
37 import org.openhab.core.thing.ChannelUID;
38 import org.openhab.core.thing.Thing;
39 import org.openhab.core.types.Command;
40 import org.slf4j.Logger;
41 import org.slf4j.LoggerFactory;
42
43 /***
44  * The{@link ShellyRelayHandler} handles light (bulb+rgbw2) specific commands and status. All other commands will be
45  * handled by the generic thing handler.
46  *
47  * @author Markus Michels - Initial contribution
48  */
49 @NonNullByDefault
50 public class ShellyRelayHandler extends ShellyBaseHandler {
51     private final Logger logger = LoggerFactory.getLogger(ShellyRelayHandler.class);
52
53     /**
54      * Constructor
55      *
56      * @param thing The thing passed by the HandlerFactory
57      * @param bindingConfig configuration of the binding
58      * @param coapServer coap server instance
59      * @param localIP local IP of the openHAB host
60      * @param httpPort port of the openHAB HTTP API
61      */
62     public ShellyRelayHandler(final Thing thing, final ShellyTranslationProvider translationProvider,
63             final ShellyBindingConfiguration bindingConfig, ShellyThingTable thingTable,
64             final Shelly1CoapServer coapServer, final HttpClient httpClient) {
65         super(thing, translationProvider, bindingConfig, thingTable, coapServer, httpClient);
66     }
67
68     @Override
69     public void initialize() {
70         super.initialize();
71     }
72
73     @Override
74     public boolean handleDeviceCommand(ChannelUID channelUID, Command command) throws ShellyApiException {
75         // Process command
76         String groupName = getString(channelUID.getGroupId());
77         Integer rIndex = 0;
78         if (groupName.startsWith(CHANNEL_GROUP_RELAY_CONTROL)
79                 && groupName.length() > CHANNEL_GROUP_RELAY_CONTROL.length()) {
80             rIndex = Integer.parseInt(substringAfter(channelUID.getGroupId(), CHANNEL_GROUP_RELAY_CONTROL)) - 1;
81         } else if (groupName.startsWith(CHANNEL_GROUP_ROL_CONTROL)
82                 && groupName.length() > CHANNEL_GROUP_ROL_CONTROL.length()) {
83             rIndex = Integer.parseInt(substringAfter(channelUID.getGroupId(), CHANNEL_GROUP_ROL_CONTROL)) - 1;
84         }
85
86         switch (channelUID.getIdWithoutGroup()) {
87             default:
88                 return false;
89
90             case CHANNEL_OUTPUT:
91                 if (!profile.isRoller) {
92                     // extract relay number of group name (relay0->0, relay1->1...)
93                     logger.debug("{}: Set relay output to {}", thingName, command);
94                     api.setRelayTurn(rIndex, command == OnOffType.ON ? SHELLY_API_ON : SHELLY_API_OFF);
95                 } else {
96                     logger.debug("{}: Device is in roller mode, channel command {} ignored", thingName, channelUID);
97                 }
98                 break;
99             case CHANNEL_BRIGHTNESS: // e.g.Dimmer, Duo
100                 handleBrightness(command, rIndex);
101                 break;
102
103             case CHANNEL_ROL_CONTROL_POS:
104             case CHANNEL_ROL_CONTROL_CONTROL:
105                 logger.debug("{}: Roller command/position {}", thingName, command);
106                 handleRoller(command, groupName, rIndex,
107                         channelUID.getIdWithoutGroup().equals(CHANNEL_ROL_CONTROL_CONTROL));
108
109                 // request updates the next 45sec to update roller position after it stopped
110                 if (!autoCoIoT && !profile.isGen2) {
111                     requestUpdates(45 / UPDATE_STATUS_INTERVAL_SECONDS, false);
112                 }
113                 break;
114
115             case CHANNEL_ROL_CONTROL_FAV:
116                 if (command instanceof Number) {
117                     int id = ((Number) command).intValue() - 1;
118                     int pos = profile.getRollerFav(id);
119                     if (pos > 0) {
120                         logger.debug("{}: Selecting favorite {}, position = {}", thingName, id, pos);
121                         api.setRollerPos(rIndex, pos);
122                         break;
123                     }
124                 }
125                 logger.debug("{}: Invalid favorite index: {}", thingName, command);
126                 break;
127
128             case CHANNEL_TIMER_AUTOON:
129                 logger.debug("{}: Set Auto-ON timer to {}", thingName, command);
130                 api.setAutoTimer(rIndex, SHELLY_TIMER_AUTOON, getNumber(command).doubleValue());
131                 break;
132             case CHANNEL_TIMER_AUTOOFF:
133                 logger.debug("{}: Set Auto-OFF timer to {}", thingName, command);
134                 api.setAutoTimer(rIndex, SHELLY_TIMER_AUTOOFF, getNumber(command).doubleValue());
135                 break;
136             case CHANNEL_EMETER_RESETTOTAL:
137                 logger.debug("{}: Reset Meter Totals", thingName);
138                 int mIndex = Integer.parseInt(substringAfter(groupName, CHANNEL_GROUP_METER)) - 1;
139                 api.resetMeterTotal(mIndex);
140                 updateChannel(groupName, CHANNEL_EMETER_RESETTOTAL, OnOffType.OFF);
141                 break;
142         }
143         return true;
144     }
145
146     /**
147      * Brightness channel has 2 functions: Switch On/Off (OnOnType) and setting brightness (PercentType)
148      * There is some more logic in the control. When brightness is set to 0 the control sends also an OFF command
149      * When current brightness is 0 and slider will be moved the new brightness will be set, but also an ON command is
150      * sent.
151      *
152      * @param command
153      * @param index
154      * @throws ShellyApiException
155      */
156     private void handleBrightness(Command command, Integer index) throws ShellyApiException {
157         Integer value = -1;
158         if (command instanceof PercentType) { // Dimmer
159             value = ((PercentType) command).intValue();
160         } else if (command instanceof DecimalType) { // Number
161             value = ((DecimalType) command).intValue();
162         } else if (command instanceof OnOffType) { // Switch
163             logger.debug("{}: Switch output {}", thingName, command);
164             updateBrightnessChannel(index, (OnOffType) command, value);
165             return;
166         } else if (command instanceof IncreaseDecreaseType) {
167             ShellyShortLightStatus light = api.getLightStatus(index);
168             if (command == IncreaseDecreaseType.INCREASE) {
169                 value = Math.min(light.brightness + DIM_STEPSIZE, 100);
170             } else {
171                 value = Math.max(light.brightness - DIM_STEPSIZE, 0);
172             }
173             logger.debug("{}: Increase/Decrease brightness from {} to {}", thingName, light.brightness, value);
174         }
175         validateRange("brightness", value, 0, 100);
176
177         // Switch light off on brightness = 0
178         if (value == 0) {
179             logger.debug("{}: Brightness=0 -> switch output OFF", thingName);
180             updateBrightnessChannel(index, OnOffType.OFF, 0);
181         } else {
182             logger.debug("{}: Setting dimmer brightness to {}", thingName, value);
183             updateBrightnessChannel(index, OnOffType.ON, value);
184         }
185     }
186
187     private void updateBrightnessChannel(int lightId, OnOffType power, int brightness) throws ShellyApiException {
188         updateChannel(CHANNEL_COLOR_WHITE, CHANNEL_BRIGHTNESS + "$Switch", power);
189         if (brightness > 0) {
190             api.setBrightness(lightId, brightness, config.brightnessAutoOn);
191         } else {
192             api.setLightTurn(lightId, power == OnOffType.ON ? SHELLY_API_ON : SHELLY_API_OFF);
193             if (brightness >= 0) { // ignore -1
194                 updateChannel(CHANNEL_COLOR_WHITE, CHANNEL_BRIGHTNESS + "$Value",
195                         toQuantityType((double) (power == OnOffType.ON ? brightness : 0), DIGITS_NONE, Units.PERCENT));
196             }
197         }
198     }
199
200     @Override
201     public boolean updateDeviceStatus(ShellySettingsStatus status) throws ShellyApiException {
202         // map status to channels
203         boolean updated = false;
204         updated |= updateRelays(status);
205         updated |= ShellyComponents.updateDimmers(this, status);
206         updated |= updateLed(status);
207         return updated;
208     }
209
210     /**
211      * Handle Roller Commands
212      *
213      * @param command from handleCommand()
214      * @param groupName relay, roller...
215      * @param index relay number
216      * @param isControl true: is the Rollershutter channel, false: rollerpos channel
217      * @throws ShellyApiException
218      */
219     private void handleRoller(Command command, String groupName, Integer index, boolean isControl)
220             throws ShellyApiException {
221         int position = -1;
222
223         if ((command instanceof UpDownType) || (command instanceof OnOffType)) {
224             ShellyRollerStatus rstatus = api.getRollerStatus(index);
225
226             if (!getString(rstatus.state).isEmpty() && !getString(rstatus.state).equals(SHELLY_ALWD_ROLLER_TURN_STOP)) {
227                 if ((command == UpDownType.UP && getString(rstatus.state).equals(SHELLY_ALWD_ROLLER_TURN_OPEN))
228                         || (command == UpDownType.DOWN
229                                 && getString(rstatus.state).equals(SHELLY_ALWD_ROLLER_TURN_CLOSE))) {
230                     logger.debug("{}: Roller is already in requested position ({}), ignore command {}", thingName,
231                             getString(rstatus.state), command);
232                     requestUpdates(1, false);
233                     return;
234                 }
235             }
236
237             if (command == UpDownType.UP || command == OnOffType.ON
238                     || ((command instanceof DecimalType) && (((DecimalType) command).intValue() == 100))) {
239                 logger.debug("{}: Open roller", thingName);
240                 int shpos = profile.getRollerFav(config.favoriteUP - 1);
241                 if (shpos > 0) {
242                     logger.debug("{}: Use favoriteUP id {} for positioning roller({}%)", thingName, config.favoriteUP,
243                             shpos);
244                     api.setRollerPos(index, shpos);
245                     position = shpos;
246                 } else {
247                     api.setRollerTurn(index, SHELLY_ALWD_ROLLER_TURN_OPEN);
248                 }
249             } else if (command == UpDownType.DOWN || command == OnOffType.OFF
250                     || ((command instanceof DecimalType) && (((DecimalType) command).intValue() == 0))) {
251                 logger.debug("{}: Closing roller", thingName);
252                 int shpos = profile.getRollerFav(config.favoriteDOWN - 1);
253                 if (shpos > 0) {
254                     // use favorite position
255                     logger.debug("{}: Use favoriteDOWN id {} for positioning roller ({}%)", thingName,
256                             config.favoriteDOWN, shpos);
257                     api.setRollerPos(index, shpos);
258                     position = shpos;
259                 } else {
260                     api.setRollerTurn(index, SHELLY_ALWD_ROLLER_TURN_CLOSE);
261                 }
262             }
263         } else if (command == StopMoveType.STOP) {
264             logger.debug("{}: Stop roller", thingName);
265             api.setRollerTurn(index, SHELLY_ALWD_ROLLER_TURN_STOP);
266         } else {
267             logger.debug("{}: Set roller to position {}", thingName, command);
268             if (command instanceof PercentType) {
269                 PercentType p = (PercentType) command;
270                 position = p.intValue();
271             } else if (command instanceof DecimalType) {
272                 DecimalType d = (DecimalType) command;
273                 position = d.intValue();
274             } else {
275                 throw new IllegalArgumentException(
276                         "Invalid value type for roller control/position" + command.getClass().toString());
277             }
278
279             // take position from RollerShutter control and map to Shelly positon
280             // OH: 0=closed, 100=open; Shelly 0=open, 100=closed)
281             // take position 1:1 from position channel
282             position = isControl ? SHELLY_MAX_ROLLER_POS - position : position;
283             validateRange("roller position", position, SHELLY_MIN_ROLLER_POS, SHELLY_MAX_ROLLER_POS);
284
285             logger.debug("{}: Changing roller position to {}", thingName, position);
286             api.setRollerPos(index, position);
287         }
288     }
289
290     /**
291      * Auto-create relay channels depending on relay type/mode
292      */
293     private void createRelayChannels(ShellySettingsRelay relay, int idx) {
294         if (!areChannelsCreated()) {
295             updateChannelDefinitions(ShellyChannelDefinitions.createRelayChannels(getThing(), profile, relay, idx));
296         }
297     }
298
299     private void createRollerChannels(ShellyRollerStatus roller) {
300         if (!areChannelsCreated()) {
301             updateChannelDefinitions(ShellyChannelDefinitions.createRollerChannels(getThing(), roller));
302         }
303     }
304
305     /**
306      * Update Relay/Roller channels
307      *
308      * @param th Thing Handler instance
309      * @param profile ShellyDeviceProfile
310      * @param status Last ShellySettingsStatus
311      *
312      * @throws ShellyApiException
313      */
314     public boolean updateRelays(ShellySettingsStatus status) throws ShellyApiException {
315         boolean updated = false;
316         if (profile.hasRelays && !profile.isDimmer) {
317             double voltage = -1;
318             if (status.voltage == null && profile.settings.supplyVoltage != null) {
319                 // Shelly 1PM/1L (fix)
320                 voltage = profile.settings.supplyVoltage == 0 ? 110.0 : 220.0;
321             } else {
322                 // Shelly 2.5 (measured)
323                 voltage = getDouble(status.voltage);
324             }
325             if (voltage > 0) {
326                 updated |= updateChannel(CHANNEL_GROUP_DEV_STATUS, CHANNEL_DEVST_VOLTAGE,
327                         toQuantityType(voltage, DIGITS_VOLT, Units.VOLT));
328             }
329
330             if (!profile.isRoller) {
331                 logger.trace("{}: Updating {} relay(s)", thingName, profile.numRelays);
332                 for (int i = 0; i < status.relays.size(); i++) {
333                     createRelayChannels(status.relays.get(i), i);
334                     updated |= ShellyComponents.updateRelay(this, status, i);
335                 }
336             } else {
337                 // Check for Relay in Roller Mode
338                 logger.trace("{}: Updating {} rollers", thingName, profile.numRollers);
339                 for (int i = 0; i < profile.numRollers; i++) {
340                     ShellyRollerStatus roller = status.rollers.get(i);
341                     createRollerChannels(roller);
342                     updated |= ShellyComponents.updateRoller(this, roller, i);
343                 }
344             }
345         }
346         return updated;
347     }
348
349     /**
350      * Update LED channels
351      *
352      * @param th Thing Handler instance
353      * @param profile ShellyDeviceProfile
354      * @param status Last ShellySettingsStatus
355      */
356     public boolean updateLed(ShellySettingsStatus status) {
357         boolean updated = false;
358         updated |= updateChannel(CHANNEL_GROUP_DEV_STATUS, CHANNEL_LED_STATUS_DISABLE,
359                 getOnOff(profile.settings.ledStatusDisable));
360         updated |= updateChannel(CHANNEL_GROUP_DEV_STATUS, CHANNEL_LED_POWER_DISABLE,
361                 getOnOff(profile.settings.ledPowerDisable));
362         return updated;
363     }
364 }