{

"productKey": "a1l3AKuGZ**",

"deviceName": "robot",

"productSecret":"xLDfQY1XTYru****",

"deviceSecret": "kUbuNQvdLRDvlJtiGkuOk95SLGXm****",

}

public void executeScheduler(DeviceInfoData deviceInfoData) {

thingTestManager.readData(System.getProperty("user.dir") + "/test_case.json");

thingTestManager.setServiceHandler();

test();

}

private void test() {

// （1）设备属性上报云端物模型

// 设备属性上报值

Map<String, ValueWrapper> reportData  = new HashMap<String, ValueWrapper>();

reportData.put("myname", new ValueWrapper.StringValueWrapper("shoen"));   // identifier 是云端定义的属性的唯一标识，valueWrapper是属性的值

reportData.put("myage", new ValueWrapper.IntValueWrapper(20));

// 设备属性上报和回调

LinkKit.getInstance().getDeviceThing().thingPropertyPost(reportData, new IPublishResourceListener() {

public void onSuccess(String s, Object o) {

// 属性上报成功

}

public void onError(String s, AError aError) {

// 属性上报失败

}

});

// （2）从云端物模型获取设备属性，根据 identifier 获取当前物模型中该属性的值

String identifier = "myname";

String myname=(String)LinkKit.getInstance().getDeviceThing().getPropertyValue(identifier).getValue();

ALog.d("helloTag:","shoen："+myname);

String identifier1 = "myage";

int myage=(Integer)LinkKit.getInstance().getDeviceThing().getPropertyValue(identifier1).getValue();

ALog.d("helloTag:","age："+myage);

// （3）设备事件上报云端

HashMap<String, ValueWrapper> valueWrapperMap = new HashMap<String, ValueWrapper>();;

String identity = "myevent";

valueWrapperMap.put("p1", new ValueWrapper.IntValueWrapper(50));  // 参考示例，更多使用可参考demo

OutputParams params = new OutputParams(valueWrapperMap);

LinkKit.getInstance().getDeviceThing().thingEventPost(identity, params, new IPublishResourceListener() {

public void onSuccess(String resId, Object o) {

// 事件上报成功

ALog.d(TAG, "onSuccess() called with: s = [" + resId + "], o = [" + o + "]");

}

public void onError(String resId, AError aError) {

// 事件上报失败

ALog.w(TAG, "onError() called with: s = [" + resId + "], aError = [" + aError.toString() + "]");

}

});

// （4）设备先注册服务的处理监听器

ThingSample ts=new ThingSample(pk, dn);

ts.setServiceHandler();

}

} else if (SERVICE_GET.equals(identify)) {

//  初始化的时候将默认值初始化传进来，物模型内部会直接返回云端缓存的值

} else if ("myscore".equals(identify)) {      /// 响应云端SDK的myscore服务调用

ALog.d(TAG, "响应云端SDK的myscore服务调用");

OutputParams outputParams = new OutputParams();

outputParams.put("out1", new ValueWrapper.IntValueWrapper(50));

itResResponseCallback.onComplete(identify, null, outputParams);

} else {

public static void main(String[] args) throws ClientException {

String accessKey = "LTAIUa25no******";

String accessSecret = "1ktxeXGKyFyiOxiMmb************";

DefaultProfile.addEndpoint("cn-shanghai", "cn-shanghai", "Iot", "iot.cn-shanghai.aliyuncs.com");

IClientProfile profile = DefaultProfile.getProfile("cn-shanghai", accessKey, accessSecret);

DefaultAcsClient client = new DefaultAcsClient(profile);

//  (1) 云端SDK直接设置设备属性

SetDevicePropertyRequest request = new SetDevicePropertyRequest();

request.setProductKey("a1l3AKuGZMp");

request.setDeviceName("robot");

JSONObject itemJson = new JSONObject();

itemJson.put("myage", 2);

request.setItems(itemJson.toString());

try {

SetDevicePropertyResponse response = client.getAcsResponse(request);

System.out.println(response.getRequestId() + ", success: " + response.getSuccess());

} catch (ClientException e) {

e.printStackTrace();

}

//（2）云端SDK调用设备端服务

InvokeThingServiceRequest request1=new InvokeThingServiceRequest();

request1.setProductKey("a1l3AKuGZMp");

request1.setDeviceName("robot");

request1.setIdentifier("myscore");

request1.setArgs("{\"in1\":1}");

//request1.setArgs("{\"LightStatus\":1,\"LightNo\":2}");

try {

InvokeThingServiceResponse response = client.getAcsResponse(request1);

if (response.getSuccess()) {

System.out.println("调用成功");

}

else {

System.out.println("error:" + response.getErrorMessage());

}

}

catch (ClientException e) {

e.printStackTrace();

}

}