package com.hdl.hdlsdk;
|
|
import androidx.activity.result.ActivityResultCallback;
|
import androidx.activity.result.ActivityResultLauncher;
|
import androidx.activity.result.contract.ActivityResultContracts;
|
import androidx.annotation.NonNull;
|
import androidx.appcompat.app.AppCompatActivity;
|
import androidx.recyclerview.widget.LinearLayoutManager;
|
import androidx.recyclerview.widget.RecyclerView;
|
|
import android.Manifest;
|
import android.os.Bundle;
|
import android.util.Log;
|
import android.view.View;
|
import android.widget.TextView;
|
import android.widget.Toast;
|
|
import com.chad.library.adapter.base.BaseQuickAdapter;
|
import com.chad.library.adapter.base.listener.OnItemClickListener;
|
import com.hdl.sdk.common.event.EventListener;
|
import com.hdl.sdk.common.exception.HDLLinkException;
|
import com.hdl.sdk.common.utils.IdUtils;
|
import com.hdl.sdk.common.utils.IpUtils;
|
import com.hdl.sdk.connect.HDLLink;
|
import com.hdl.sdk.connect.bean.LinkResponse;
|
import com.hdl.sdk.connect.bean.request.AuthenticateRequest;
|
import com.hdl.sdk.connect.bean.request.PropertyReadRequest;
|
import com.hdl.sdk.connect.bean.response.GatewaySearchBean;
|
import com.hdl.sdk.connect.callback.HDLLinkCallBack;
|
import com.hdl.sdk.connect.callback.HDLLinkResponseCallBack;
|
import com.hdl.sdk.connect.socket.HDLAuthSocket;
|
import com.hdl.sdk.connect.socket.HDLSocket;
|
import com.hdl.sdk.connect.bean.request.DeviceControlRequest;
|
import com.hdl.sdk.connect.protocol.LinkMessageDecoder;
|
import com.hdl.sdk.connect.protocol.LinkMessageEncoder;
|
import com.hdl.sdk.socket.SocketOptions;
|
import com.hdl.sdk.socket.codec.MessagePipeLine;
|
|
import java.io.UnsupportedEncodingException;
|
import java.security.MessageDigest;
|
import java.security.NoSuchAlgorithmException;
|
import java.util.ArrayList;
|
import java.util.List;
|
import java.util.Map;
|
|
public class MainActivity extends AppCompatActivity {
|
|
private DemoAdapter demoAdapter;
|
private RecyclerView rv;
|
private TextView tv;
|
private TextView responseTv;
|
boolean isOn;
|
private EventListener allTopicsListener;
|
private String testLightSid = "000101B847C71B02020100010101";
|
|
@Override
|
protected void onDestroy() {
|
super.onDestroy();
|
removeAllTopicsListener();
|
}
|
|
@Override
|
protected void onCreate(Bundle savedInstanceState) {
|
super.onCreate(savedInstanceState);
|
setContentView(R.layout.activity_main);
|
responseTv = findViewById(R.id.response_tv);
|
tv = findViewById(R.id.state_tv);
|
rv = findViewById(R.id.rv);
|
rv.setLayoutManager(new LinearLayoutManager(this));
|
|
checkIfCertified();
|
|
registerAllTopicsListener();
|
|
ActivityResultLauncher<String[]> launcher = registerForActivityResult(new ActivityResultContracts.RequestMultiplePermissions(), new ActivityResultCallback<Map<String, Boolean>>() {
|
@Override
|
public void onActivityResult(Map<String, Boolean> result) {
|
|
}
|
});
|
|
launcher.launch(new String[]{Manifest.permission.WRITE_EXTERNAL_STORAGE, Manifest.permission.READ_EXTERNAL_STORAGE});
|
|
final List<DemoBean> beans = new ArrayList<>();
|
beans.add(new DemoBean("入网认证"));
|
beans.add(new DemoBean("搜索指定网关是否在线"));
|
beans.add(new DemoBean("获取功能列表"));
|
beans.add(new DemoBean("功能属性读取"));
|
beans.add(new DemoBean("设备控制"));
|
beans.add(new DemoBean("读取状态"));
|
beans.add(new DemoBean("获取场景列表"));
|
beans.add(new DemoBean("场景控制"));
|
demoAdapter = new DemoAdapter(beans);
|
rv.setAdapter(demoAdapter);
|
|
|
final SocketOptions options = new SocketOptions();
|
|
MessagePipeLine pipeLine = new MessagePipeLine();
|
pipeLine.add(new LinkMessageDecoder());
|
pipeLine.add(new LinkMessageEncoder());
|
options.setHandleMessage(pipeLine);
|
options.setEnabledHeartbeat(false);
|
|
demoAdapter.setOnItemClickListener(new OnItemClickListener() {
|
@Override
|
public void onItemClick(@NonNull BaseQuickAdapter<?, ?> adapter, @NonNull View view, int position) {
|
switch (position) {
|
case 0:
|
//入网认证
|
sendAuthenticateRequest();
|
break;
|
case 1:
|
//搜索网关
|
searchGatewayBroadcast();
|
break;
|
case 2:
|
//获取功能列表
|
getFunctionList();
|
break;
|
case 3:
|
//功能属性读取
|
getFunctionAttribute();
|
break;
|
case 4:
|
//设备控制
|
controlDecide();
|
break;
|
case 5:
|
//读取状态
|
propertyRead();
|
break;
|
case 6:
|
//获取场景列表
|
getSceneList();
|
break;
|
case 7:
|
//获取场景列表
|
controlScene();
|
break;
|
}
|
}
|
});
|
}
|
public void showToast(String text) {
|
Toast.makeText(this, text, Toast.LENGTH_SHORT).show();
|
}
|
|
/**
|
* 检测是否认证过
|
*/
|
void checkIfCertified(){
|
boolean isCertified = HDLLink.getInstance().checkIfCertified();
|
String mes = isCertified?"已经认证过":"未认证";
|
showToast(mes);
|
tv.setText(mes);
|
}
|
|
/**
|
* 注册所有主题数据的监听
|
*/
|
void registerAllTopicsListener(){
|
allTopicsListener = new EventListener() {
|
@Override
|
public void onMessage(Object msg) {
|
LinkResponse response = (LinkResponse)msg;
|
Log.i("TAG", "AllTopicsListener onMessage: "+msg.toString());
|
}
|
};
|
HDLLink.getInstance().registerAllTopicsListener(allTopicsListener);
|
}
|
|
/**
|
* 移除所有主题数据的监听
|
*/
|
void removeAllTopicsListener(){
|
HDLLink.getInstance().removeAllTopicsListener(allTopicsListener);
|
}
|
|
/**
|
* 入网认证
|
*/
|
void sendAuthenticateRequest(){
|
tv.setText("开始入网认证...");
|
//认证提交参数准备
|
|
String spkStr = "ir.module";//产品spk
|
String macStr = "AA000000000000BB";//设备唯一MAC地址
|
String secret = "87ae414b7a853f65";//通过spk和mac提交云端认证后分配的secret
|
String mac_key = stringToMD5(stringToMD5(macStr + secret));
|
String versionString = "HDL_V1.0.1";//
|
String time = String.valueOf(System.currentTimeMillis());
|
|
//1.设置认证信息
|
AuthenticateRequest.RequestBean requestBean = new AuthenticateRequest.RequestBean();
|
requestBean.setMAC(macStr);
|
requestBean.setSupplier("HDL");
|
requestBean.setFirmwareVersion(versionString);
|
requestBean.setHardwareModel("1956F");
|
AuthenticateRequest.AuthBean authbean = new AuthenticateRequest.AuthBean();
|
authbean.setSpk(spkStr);
|
authbean.setMACKey(mac_key);
|
authbean.setRequest(requestBean);
|
|
//2.设置设备信息
|
AuthenticateRequest.AuthenticateDeviceInfoBean infoBean = new AuthenticateRequest.AuthenticateDeviceInfoBean();
|
infoBean.setDeviceMAC(macStr);
|
infoBean.setIPMAC(macStr);
|
infoBean.setDeviceName("红外宝");//设备名字
|
infoBean.setDeviceModel("HDL");//
|
infoBean.setAccessMode("WIFI");
|
infoBean.setIPGateway("192.168.10.1");
|
infoBean.setIPAddress(IpUtils.getIP(this));
|
|
infoBean.setOID("010105000000FE08");
|
infoBean.setSid("010105000000FE08110100000000");
|
// infoBean.set
|
AuthenticateRequest.VersionBean[] versionBeans = new AuthenticateRequest.VersionBean[]{new AuthenticateRequest.VersionBean("FW", versionString), new AuthenticateRequest.VersionBean("HW", "1956F")};
|
infoBean.setVersions(versionBeans);
|
AuthenticateRequest request = new AuthenticateRequest(IdUtils.getUUId(), time, infoBean, authbean);
|
HDLLink.getInstance().startAuthenticateRequest(request, new HDLLinkCallBack() {
|
@Override
|
public void onError(HDLLinkException e) {
|
tv.setText("认证失败");
|
responseTv.setText(e.getMsg());
|
Log.i("TAG", "onError: 认证失败");
|
}
|
|
@Override
|
public void onSuccess(String msg) {
|
tv.setText("认证成功");
|
responseTv.setText(msg.toString());
|
}
|
});
|
}
|
|
String stringToMD5(String text) {
|
byte[] hash;
|
try {
|
hash = MessageDigest.getInstance("MD5").digest(text.getBytes("UTF-8"));
|
} catch (NoSuchAlgorithmException e) {
|
e.printStackTrace();
|
return null;
|
} catch (UnsupportedEncodingException e) {
|
e.printStackTrace();
|
return null;
|
}
|
|
StringBuilder hex = new StringBuilder(hash.length * 2);
|
for (byte b : hash) {
|
if ((b & 0xFF) < 0x10)
|
hex.append("0");
|
hex.append(Integer.toHexString(b & 0xFF));
|
}
|
|
return hex.toString();
|
}
|
|
/**
|
* 如果已经认证后，搜索指定网关是否在线
|
* 广播搜索认证过的网关是否在线
|
*/
|
void searchGatewayBroadcast(){
|
tv.setText("搜索网关中...");
|
HDLLink.getInstance().searchGatewayBroadcast(new HDLAuthSocket.SearchGatewayCallBack() {
|
@Override
|
public void onError(HDLLinkException e) {
|
tv.setText("网关不在线");
|
}
|
@Override
|
public void onSuccess(GatewaySearchBean gatewaySearchBean) {
|
tv.setText("网关在线");
|
responseTv.setText("搜索成功 网关id："+gatewaySearchBean.getGatewayId());
|
// LogUtils.i("TAG", "onSuccess: 搜索成功："+gatewaySearchBean.getGatewayId());
|
}
|
});
|
}
|
|
/**
|
* 获取功能列表
|
*/
|
void getFunctionList(){
|
tv.setText("获取功能列表中...");
|
responseTv.setText("");
|
HDLLink.getInstance().getFunctionList(new HDLLinkCallBack() {
|
@Override
|
public void onError(HDLLinkException error) {
|
tv.setText(error.getMsg());
|
}
|
|
@Override
|
public void onSuccess(String data) {
|
tv.setText("获取功能列表成功");
|
responseTv.setText(data);
|
}
|
});
|
}
|
|
/**
|
* 功能属性读取
|
* 支持批量读取
|
*/
|
void getFunctionAttribute(){
|
tv.setText("功能属性读取");
|
List<String> sids = new ArrayList<>();
|
sids.add(testLightSid);
|
HDLLink.getInstance().getFunctionAttribute(sids, new HDLLinkCallBack() {
|
@Override
|
public void onSuccess(String msg) {
|
responseTv.setText(msg);
|
}
|
|
@Override
|
public void onError(HDLLinkException e) {
|
responseTv.setText(e.getMsg());
|
}
|
});
|
}
|
|
/**
|
* 读取设备状态
|
* 支持批量读取
|
*/
|
void propertyRead(){
|
tv.setText("读取状态中...");
|
List<String> list = new ArrayList<>();
|
list.add(testLightSid);//要读取设备的sid
|
HDLLink.getInstance().propertyRead(list, new HDLLinkCallBack() {
|
@Override
|
public void onSuccess(String data) {
|
tv.setText("读取成功");
|
responseTv.setText(data);
|
}
|
@Override
|
public void onError(HDLLinkException e) {
|
tv.setText("读取失败");
|
responseTv.setText(e.getMsg());
|
}
|
});
|
}
|
|
/**
|
* 控制失败
|
* 回复响应code为200 代表执行成功
|
*/
|
void controlDecide(){
|
tv.setText("控制设备");
|
isOn = !isOn;
|
List<DeviceControlRequest> requestList = new ArrayList<>();
|
DeviceControlRequest request = new DeviceControlRequest();
|
request.setSid(testLightSid);
|
List<DeviceControlRequest.StatusBean> statusBeanList= new ArrayList<>();
|
DeviceControlRequest.StatusBean bean = new DeviceControlRequest.StatusBean();
|
bean.setKey("on_off");
|
bean.setValue(isOn ? "on" : "off");
|
statusBeanList.add(bean);
|
request.setStatus(statusBeanList);
|
requestList.add(request);
|
HDLLink.getInstance().propertyDown(requestList, new HDLLinkCallBack() {
|
@Override
|
public void onSuccess(String data) {
|
responseTv.setText(data);
|
}
|
|
@Override
|
public void onError(HDLLinkException e) {
|
responseTv.setText(e.getMsg());
|
}
|
});
|
}
|
|
/**
|
* 获取场景列表
|
*/
|
void getSceneList(){
|
tv.setText("读取场景列表");
|
HDLLink.getInstance().getSceneList(new HDLLinkCallBack() {
|
@Override
|
public void onSuccess(String msg) {
|
responseTv.setText(msg);
|
}
|
|
@Override
|
public void onError(HDLLinkException e) {
|
responseTv.setText(e.getMsg());
|
}
|
});
|
}
|
|
//场景列表
|
// {"id":"8a5eaa143ce943b987b577df5a66759b","time_stamp":"1637040217235","objects":[{"sid":"04010560D2C7170A0A0100000000","name":"回家模式","status":"off","group":"255","delay":"0","modify_time":"1634871490"},{"sid":"04010560D2C76E0A0A0100010000","name":"离家模式","status":"off","group":"255","delay":"0","modify_time":"1634785823"}]}
|
/**
|
* 控制场景
|
* 执行成功的话 响应code为200
|
*/
|
void controlScene(){
|
tv.setText("场景控制");
|
//控制场景sid列表，支持批量控制
|
List<String> sids = new ArrayList<>();
|
isOn = !isOn;
|
if(isOn){
|
sids.add("04010560D2C7170A0A0100000000");
|
}else{
|
sids.add("04010560D2C76E0A0A0100010000");
|
}
|
HDLLink.getInstance().controlScene(sids,new HDLLinkCallBack() {
|
@Override
|
public void onSuccess(String msg) {
|
responseTv.setText(msg);
|
}
|
|
@Override
|
public void onError(HDLLinkException e) {
|
responseTv.setText(e.getMsg());
|
}
|
});
|
}
|
|
|
}
|
