com.zsmartsystems.zigbee.zcl.ZclCluster类的使用及代码示例

x33g5p2x  于2022-02-05 转载在 其他  
字(10.7k)|赞(0)|评价(0)|浏览(122)

本文整理了Java中com.zsmartsystems.zigbee.zcl.ZclCluster类的一些代码示例，展示了ZclCluster类的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。ZclCluster类的具体详情如下：
包路径：com.zsmartsystems.zigbee.zcl.ZclCluster
类名称：ZclCluster

ZclCluster介绍

[英]Base class for the ZCL Cluster
[中]ZCL集群的基类

代码示例

代码示例来源：origin: zsmartsystems/com.zsmartsystems.zigbee

/**
 * @param cluster a ZCL cluster
 * @return a String containing information about the cluster, example 'OnOff server cluster 0x00A4'
 */
protected String printCluster(ZclCluster cluster) {
  String typePrefix = cluster.isServer() ? "server" : "client";
  return String.format("%s cluster %s (%s)", typePrefix, cluster.getClusterName(),
      printClusterId(cluster.getClusterId()));
}

代码示例来源：origin: zsmartsystems/com.zsmartsystems.zigbee

/**
 * Configures the reporting for the specified attribute ID for discrete attributes.
 * <p>
 * <b>minInterval</b>:
 * The minimum reporting interval field is 16 bits in length and shall contain the
 * minimum interval, in seconds, between issuing reports of the specified attribute.
 * If minInterval is set to 0x0000, then there is no minimum limit, unless one is
 * imposed by the specification of the cluster using this reporting mechanism or by
 * the applicable profile.
 * <p>
 * <b>maxInterval</b>:
 * The maximum reporting interval field is 16 bits in length and shall contain the
 * maximum interval, in seconds, between issuing reports of the specified attribute.
 * If maxInterval is set to 0xffff, then the device shall not issue reports for the specified
 * attribute, and the configuration information for that attribute need not be
 * maintained.
 *
 * @param attribute the {@link ZclAttribute} to configure reporting
 * @param minInterval the minimum reporting interval
 * @param maxInterval the maximum reporting interval
 * @return command future {@link CommandResult}
 */
public Future<CommandResult> setReporting(final ZclAttribute attribute, final int minInterval,
    final int maxInterval) {
  return setReporting(attribute, minInterval, maxInterval, null);
}

代码示例来源：origin: openhab/org.openhab.binding.zigbee

/**
   * Creates a binding from the remote cluster to the local {@link ZigBeeProfileType#ZIGBEE_HOME_AUTOMATION} endpoint
   *
   * @param cluster the remote {@link ZclCluster} to bind to
   * @return the future {@link CommandResult}
   */
  protected Future<CommandResult> bind(ZclCluster cluster) {
    return cluster.bind(coordinator.getLocalIeeeAddress(),
        coordinator.getLocalEndpointId(ZigBeeProfileType.ZIGBEE_HOME_AUTOMATION));
  }
}

代码示例来源：origin: openhab/org.openhab.binding.zigbee

@Override
public void disposeConverter() {
  for (ZclCluster clientCluster : clientClusters) {
    logger.debug("{}: Closing cluster {}", endpoint.getIeeeAddress(), clientCluster.getClusterId());
    clientCluster.removeCommandListener(this);
  }
}

代码示例来源：origin: zsmartsystems/com.zsmartsystems.zigbee

private void printClusters(final ZigBeeEndpoint endpoint, final boolean input, final PrintStream out) {
  Collection<Integer> clusters;
  if (input) {
    clusters = endpoint.getInputClusterIds();
  } else {
    clusters = endpoint.getOutputClusterIds();
  }
  Map<Integer, ZclCluster> clusterTree = new TreeMap<Integer, ZclCluster>();
  for (Integer clusterId : clusters) {
    ZclCluster cluster;
    if (input) {
      cluster = endpoint.getInputCluster(clusterId);
    } else {
      cluster = endpoint.getOutputCluster(clusterId);
    }
    clusterTree.put(cluster.getClusterId(), cluster);
  }
  for (ZclCluster cluster : clusterTree.values()) {
    out.println("   " + printClusterId(cluster.getClusterId()) + " " + cluster.getClusterName());
    printAttributes(cluster, out);
  }
}

代码示例来源：origin: zsmartsystems/com.zsmartsystems.zigbee

final ZclAttribute attribute = cluster.getAttribute(attributeId);
final CommandResult result = cluster.setReporting(attribute, 0, 0xFFFF, null).get();
if (result.isSuccess()) {
  final ConfigureReportingResponse response = result.getResponse();

代码示例来源：origin: zsmartsystems/com.zsmartsystems.zigbee

final ZclAttribute attribute = cluster.getAttribute(attributeId);
if (attribute == null) {
  throw new IllegalArgumentException(
      "Attribute " + attributeId + " was not found in cluster " + cluster.getClusterName());
final CommandResult result = cluster.setReporting(attribute, minInterval, maxInterval, reportableChange).get();
if (result.isSuccess()) {
  final ConfigureReportingResponse response = result.getResponse();

代码示例来源：origin: zsmartsystems/com.zsmartsystems.zigbee

/**
 * Adds a specific {@link ZclCluster} to the input clusters in this endpoint.
 *
 * @param cluster the {@link ZclCluster} to add
 * @return true if the cluster was added, false if there was an error (eg the cluster was already included in the
 *         endpoint)
 */
public boolean addInputCluster(ZclCluster cluster) {
  if (inputClusters.containsKey(cluster.getClusterId())) {
    return false;
  }
  inputClusters.put(cluster.getClusterId(), cluster);
  return true;
}

代码示例来源：origin: zsmartsystems/com.zsmartsystems.zigbee

@Test
public void handleAttributeReport() {
  createEndpoint();
  ZclCluster cluster = new ZclOnOffCluster(endpoint);
  ZclAttributeListener listenerMock = Mockito.mock(ZclAttributeListener.class);
  ArgumentCaptor<ZclAttribute> attributeCapture = ArgumentCaptor.forClass(ZclAttribute.class);
  cluster.addAttributeListener(listenerMock);
  cluster.addAttributeListener(listenerMock);
  List<AttributeReport> attributeList = new ArrayList<AttributeReport>();
  AttributeReport report;
  report = new AttributeReport();
  report.setAttributeDataType(ZclDataType.SIGNED_8_BIT_INTEGER);
  report.setAttributeIdentifier(0);
  report.setAttributeValue(Integer.valueOf(1));
  System.out.println(report);
  attributeList.add(report);
  cluster.handleAttributeReport(attributeList);
  ZclAttribute attribute = cluster.getAttribute(0);
  assertTrue(attribute.getLastValue() instanceof Boolean);
  Mockito.verify(listenerMock, Mockito.timeout(1000).times(1)).attributeUpdated(attributeCapture.capture());
  attribute = attributeCapture.getValue();
  assertTrue(attribute.getLastValue() instanceof Boolean);
  assertEquals(ZclDataType.BOOLEAN, attribute.getDataType());
  assertEquals(0, attribute.getId());
  assertEquals(true, attribute.getLastValue());
  cluster.removeAttributeListener(listenerMock);
}

代码示例来源：origin: zsmartsystems/com.zsmartsystems.zigbee

final ZclAttribute attribute = cluster.getAttribute(attributeId);
if (attribute == null) {
  throw new IllegalArgumentException(
final CommandResult result = cluster.getReporting(attribute).get();
if (result.isSuccess()) {
  final ReadAttributesResponse response = result.getResponse();

代码示例来源：origin: zsmartsystems/com.zsmartsystems.zigbee

@Override
  public void process(ZigBeeNetworkManager networkManager, String[] args, PrintStream out)
      throws IllegalArgumentException, InterruptedException, ExecutionException {
    if (args.length != 3) {
      throw new IllegalArgumentException("Invalid number of arguments");
    }

    final ZigBeeEndpoint endpoint = getEndpoint(networkManager, args[1]);
    ZclCluster cluster = getCluster(endpoint, args[2]);

    final Future<Boolean> future = cluster.discoverAttributes(false);
    Boolean result = future.get();
    if (result) {
      out.println("Supported attributes for " + printCluster(cluster));
      out.println("AttrId  Data Type                  Name");
      for (Integer attributeId : cluster.getSupportedAttributes()) {
        out.print(" ");
        ZclAttribute attribute = cluster.getAttribute(attributeId);
        out.print(printAttributeId(attributeId));
        if (attribute != null) {
          out.print("  " + printZclDataType(attribute.getDataType()) + "  " + attribute.getName());
        }
        out.println();
      }
    } else {
      out.println("Failed to retrieve supported attributes");
    }
  }
}

代码示例来源：origin: zsmartsystems/com.zsmartsystems.zigbee

if (newList.contains(cluster.getClusterId())) {
removeIds.add(cluster.getClusterId());
    logger.debug("{}: Setting cluster {} as server", getEndpointAddress(),
        ZclClusterType.getValueById(id));
    clusterClass.setServer();
  } else {
    logger.debug("{}: Setting cluster {} as client", getEndpointAddress(),
        ZclClusterType.getValueById(id));
    clusterClass.setClient();

代码示例来源：origin: zsmartsystems/com.zsmartsystems.zigbee

@Test
public void handleCommandReport() {
  createEndpoint();
  ZclCluster cluster = new ZclOnOffCluster(endpoint);
  ZclCommand command = Mockito.mock(ZclCommand.class);
  ZclCommandListener listenerMock = Mockito.mock(ZclCommandListener.class);
  cluster.addCommandListener(listenerMock);
  cluster.addCommandListener(listenerMock);
  cluster.handleCommand(command);
  Mockito.verify(listenerMock, Mockito.timeout(1000).times(1)).commandReceived(command);
  cluster.removeCommandListener(listenerMock);
}

代码示例来源：origin: zsmartsystems/com.zsmartsystems.zigbee

final ZclAttribute attribute = cluster.getAttribute(attributeId);
if (attribute == null) {
  throw new IllegalArgumentException("Could not find attribute with ID " + attributeId);
final CommandResult result = cluster.write(attribute, value).get();
if (result.isSuccess()) {
  final WriteAttributesResponse response = result.getResponse();

代码示例来源：origin: openhab/org.openhab.binding.zigbee

int clusterId = commandSpec.getClusterId();
if (clientClusters.stream().anyMatch(cluster -> cluster.getClusterId().intValue() == clusterId)) {
clientCluster.addCommandListener(this);
clientClusters.add(clientCluster);

代码示例来源：origin: zsmartsystems/com.zsmartsystems.zigbee

cluster.handleAttributeReport(attributeCommand.getReports());
return;
cluster.handleAttributeStatus(attributeCommand.getRecords());
return;
cluster.handleCommand(command);

代码示例来源：origin: zsmartsystems/com.zsmartsystems.zigbee

ZclAttribute attribute = cluster.getAttribute(attributeId);
if (attribute == null) {
  attributeName = "Attribute " + attributeId;
result = cluster.read(attributeId).get();

代码示例来源：origin: zsmartsystems/com.zsmartsystems.zigbee

/**
 * Write an attribute
 *
 * @param attribute the {@link ZclAttribute} to write
 * @param value the value to set (as {@link Object})
 * @return command future {@link CommandResult}
 */
public Future<CommandResult> write(final ZclAttribute attribute, final Object value) {
  return write(attribute.getId(), attribute.getDataType(), value);
}

代码示例来源：origin: zsmartsystems/com.zsmartsystems.zigbee

private void printAttributes(final ZclCluster cluster, final PrintStream out) {
    Map<Integer, ZclAttribute> attributeTree = new TreeMap<Integer, ZclAttribute>();
    for (ZclAttribute attribute : cluster.getAttributes()) {
      attributeTree.put(attribute.getId(), attribute);
    }

    for (ZclAttribute attribute : attributeTree.values()) {
      out.println(String.format("        %s   %5d %s%s%s %s %-40s %s %s",
          (cluster.getSupportedAttributes().contains(attribute.getId()) ? "S" : "U"), attribute.getId(),
          (attribute.isReadable() ? "r" : "-"), (attribute.isWritable() ? "w" : "-"),
          (attribute.isReportable() ? "s" : "-"), printZclDataType(attribute.getDataType()),
          attribute.getName(),
          (attribute.getLastValue() == null ? "" : attribute.getLastReportTime().getTime()),
          (attribute.getLastValue() == null ? "" : attribute.getLastValue())));
    }
  }
}

代码示例来源：origin: zsmartsystems/com.zsmartsystems.zigbee

@Test
public void isAttributeSupported() {
  createEndpoint();
  ZclCluster cluster = new ZclOnOffCluster(endpoint);
  Set<Integer> set = new HashSet<Integer>();
  set.add(1);
  set.add(4);
  set.add(2);
  setSupportedClusters(cluster, set);
  assertEquals(3, cluster.getSupportedAttributes().size());
  assertTrue(cluster.isAttributeSupported(1));
  assertTrue(cluster.isAttributeSupported(2));
  assertFalse(cluster.isAttributeSupported(3));
}

内容来源于网络，如有侵权，请联系作者删除！

ZclCluster

相关文章

    查看更多

    热门标签

    更多
    JavaquerypythonNode开发语言requestUtil数据库Table后端算法LoggerMessageElementParser

    最新文章

    更多
    • 蜀ICP备13028337号-1 大数据知识库 https://www.saoniuhuo.com © All rights reserved
    • 本站内容来源互联网,如果侵犯您的权益请联系我们删除, 联系方式：448109455@qq.com