设备影子

数据上行

• 获取云端设备影子

• 更新云端设备影子

• 删除云端设备影子

// 获取设备影子 具体业务可参考 Demo
String data = "{" + "\"method\": \"get\"" + "}";
// 更新设备影子 需要根据获得到的设备影子读取返回的 version值，在更新的时候 {ver} 替换为version+1
// String data = "{" + "\"method\": \"update\"," + "\"state\": {" + "\"reported\": {" +
//            "\"color\": \"red\"" + "}" + "}," + "\"version\": {ver}" + "}";
//删除设备影子 color 属性  {ver}需要替换
// String data = "{" + "\"method\": \"delete\"," + "\"state\": {" + "\"reported\": {" +
//            "\"color\": \"null\"" + "}" + "}," + "\"version\": {ver}" + "}";
LinkKit.getInstance().getDeviceShadow().shadowUpload(data, new IConnectSendListener() {
    @Override
    public void onResponse(ARequest aRequest, AResponse aResponse) {
        // 设备影子更新成功
        // 数据解析参考数据下行或 Demo
    }

    @Override
    public void onFailure(ARequest aRequest, AError aError) {
        // 设备影子更新失败
    }
});
			

数据下行

监听云端设备影子数据更新，一般使用在 APP 去控制设备的时候。APP控制设备的时候，通过云端下发设备影子更新到设备端，设备端拿到云端下行的设备影子之后，根据 desired 的值去执行设备更新。

// 监听云端设备影子更新
LinkKit.getInstance().getDeviceShadow().setShadowChangeListener(new IShadowRRPC() {
    @Override
    public void onSubscribeSuccess(ARequest aRequest) {
        // 订阅设备影子下行数据成功
    }

    @Override
    public void onSubscribeFailed(ARequest aRequest, AError aError) {
        // 订阅设备影子下行数据失败
    }

    @Override
    public void onReceived(ARequest aRequest, AResponse aResponse, IConnectRrpcHandle iConnectRrpcHandle) {
        // 接收到云端数据下行，下行数据在 aResponse 想里面
        try {
            if (aRequest != null) {
                String dataStr = null;
                if (aResponse.data instanceof byte[]) {
                    dataStr = new String((byte[]) aResponse.data, "UTF-8");
                } else if (aResponse.data instanceof String) {
                    dataStr = (String) aResponse.data;
                } else {
                    dataStr = String.valueOf(aResponse.data);
                }
                // Log.d(TAG, "dataStr = " + dataStr);
                // 返回数据示例
                //{"method":"control","payload":{"state":{"desired":{"mode":2,"color":"white"},"reported":{"mode":"1","color":"red"}},"metadata":{"desired":{"mode":{"timestamp":1547642408},"color":{"timestamp":1547642408}},"reported":{"mode":{"timestamp":1547642408},"color":{"timestamp":1547642408}}}},"timestamp":1547642408,"version":12}
                // 仅供参考
                ShadowResponse<String> shadowResponse = JSONObject.parseObject(dataStr, new TypeReference<ShadowResponse<String>>() {
                }.getType());
                if (shadowResponse != null && shadowResponse.version != null && TextUtils.isDigitsOnly(shadowResponse.version)) {
                    version = Long.valueOf(shadowResponse.version);
                }

                AResponse response = new AResponse();
                // TODO 用户实现控制设备
                // 用户控制设备之后 上报影子的值到云端
                // 上报设置之后的值到云端
                // 根据当前实际值上报
                response.data = shadowUpdate.replace("{ver}", String.valueOf(version + 1));
                // 第一个值 replyTopic 有默认值 用户不需要设置
                iConnectRrpcHandle.onRrpcResponse(null, response);
            }
        } catch (Exception e) {
            e.printStackTrace();
        }
    }

    @Override
    public void onResponseSuccess(ARequest aRequest) {
        // 下行处理之后上报成功
    }

    @Override
    public void onResponseFailed(ARequest aRequest, AError aError) {
        // 下行处理之后上报失败
    }
});