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

   1 /**
   2  * Copyright (c) 2010-2021 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.caddx.internal.handler;
  14
  15 import java.util.Collection;
  16 import java.util.Collections;
  17
  18 import org.eclipse.jdt.annotation.NonNullByDefault;
  19 import org.openhab.binding.caddx.internal.CaddxBindingConstants;
  20 import org.openhab.binding.caddx.internal.CaddxEvent;
  21 import org.openhab.binding.caddx.internal.CaddxMessage;
  22 import org.openhab.binding.caddx.internal.CaddxMessageType;
  23 import org.openhab.binding.caddx.internal.CaddxProperty;
  24 import org.openhab.binding.caddx.internal.action.CaddxZoneActions;
  25 import org.openhab.core.library.types.OnOffType;
  26 import org.openhab.core.library.types.OpenClosedType;
  27 import org.openhab.core.library.types.StringType;
  28 import org.openhab.core.thing.ChannelUID;
  29 import org.openhab.core.thing.Thing;
  30 import org.openhab.core.thing.ThingStatus;
  31 import org.openhab.core.thing.binding.ThingHandlerService;
  32 import org.openhab.core.types.Command;
  33 import org.openhab.core.types.RefreshType;
  34 import org.slf4j.Logger;
  35 import org.slf4j.LoggerFactory;
  36
  37 /**
  38  * This is a class for handling a Zone type Thing.
  39  *
  40  * @author Georgios Moutsos - Initial contribution
  41  */
  42 @NonNullByDefault
  43 public class ThingHandlerZone extends CaddxBaseThingHandler {
  44
  45     private final Logger logger = LoggerFactory.getLogger(ThingHandlerZone.class);
  46     private long lastRefreshTime = 0;
  47
  48     public ThingHandlerZone(Thing thing) {
  49         super(thing, CaddxThingType.ZONE);
  50     }
  51
  52     @Override
  53     public void updateChannel(ChannelUID channelUID, String data) {
  54         if (channelUID.getId().equals(CaddxBindingConstants.ZONE_NAME)) {
  55             updateState(channelUID, new StringType(data));
  56
  57             logger.trace("  updateChannel: {} = {}", channelUID, data);
  58         } else if (channelUID.getId().equals(CaddxBindingConstants.ZONE_FAULTED)) {
  59             OpenClosedType openClosedType = ("true".equals(data)) ? OpenClosedType.OPEN : OpenClosedType.CLOSED;
  60             updateState(channelUID, openClosedType);
  61
  62             logger.trace("  updateChannel: {} = {}", channelUID, data);
  63         } else {
  64             OnOffType onOffType = ("true".equals(data)) ? OnOffType.ON : OnOffType.OFF;
  65             updateState(channelUID, onOffType);
  66
  67             logger.trace("  updateChannel: {} = {}", channelUID, onOffType);
  68         }
  69     }
  70
  71     @Override
  72     public void handleCommand(ChannelUID channelUID, Command command) {
  73         logger.debug("handleCommand(): Command Received - {} {}.", channelUID, command);
  74
  75         String cmd1 = null;
  76         String cmd2 = null;
  77         String data = null;
  78
  79         if (command instanceof RefreshType) {
  80             // Refresh only if 2 seconds have passed from the last refresh
  81             if (System.currentTimeMillis() - lastRefreshTime > 2000) {
  82                 cmd1 = CaddxBindingConstants.ZONE_STATUS_REQUEST;
  83                 cmd2 = CaddxBindingConstants.ZONE_NAME_REQUEST;
  84                 data = String.format("%d", getZoneNumber() - 1);
  85             } else {
  86                 return;
  87             }
  88             lastRefreshTime = System.currentTimeMillis();
  89         } else if (channelUID.getId().equals(CaddxBindingConstants.ZONE_BYPASSED)) {
  90             cmd1 = CaddxBindingConstants.ZONE_BYPASSED;
  91             cmd2 = CaddxBindingConstants.ZONE_STATUS_REQUEST;
  92             data = String.format("%d", getZoneNumber() - 1);
  93         } else {
  94             logger.debug("Unknown command {}", command);
  95             return;
  96         }
  97
  98         CaddxBridgeHandler bridgeHandler = getCaddxBridgeHandler();
  99         if (bridgeHandler == null) {
 100             return;
 101         }
 102         bridgeHandler.sendCommand(cmd1, data);
 103         bridgeHandler.sendCommand(cmd2, data);
 104     }
 105
 106     @Override
 107     public void caddxEventReceived(CaddxEvent event, Thing thing) {
 108         logger.trace("caddxEventReceived(): Event Received - {}", event);
 109
 110         if (getThing().equals(thing)) {
 111             CaddxMessage message = event.getCaddxMessage();
 112             CaddxMessageType mt = message.getCaddxMessageType();
 113             ChannelUID channelUID = null;
 114
 115             for (CaddxProperty p : mt.properties) {
 116                 logger.trace("  Checking property: {}", p.getName());
 117
 118                 if (!p.getId().isEmpty()) {
 119                     String value = message.getPropertyById(p.getId());
 120                     channelUID = new ChannelUID(getThing().getUID(), p.getId());
 121                     updateChannel(channelUID, value);
 122
 123                     logger.trace("  updateChannel: {} = {}", channelUID, value);
 124                 }
 125             }
 126         }
 127
 128         updateStatus(ThingStatus.ONLINE);
 129     }
 130
 131     @Override
 132     public Collection<Class<? extends ThingHandlerService>> getServices() {
 133         return Collections.singleton(CaddxZoneActions.class);
 134     }
 135
 136     public void bypass() {
 137         String cmd = CaddxBindingConstants.ZONE_BYPASSED;
 138         String data = String.format("%d", getZoneNumber() - 1);
 139
 140         CaddxBridgeHandler bridgeHandler = getCaddxBridgeHandler();
 141         if (bridgeHandler == null) {
 142             return;
 143         }
 144         bridgeHandler.sendCommand(cmd, data);
 145     }
 146 }