| | |
|---|
| | | import com.hdl.sdk.common.utils.gson.GsonConvert;
|
|---|
| | | import com.hdl.sdk.connect.bean.LinkResponse;
|
|---|
| | | import com.hdl.sdk.connect.bean.request.AuthenticateRequest;
|
|---|
| | | import com.hdl.sdk.connect.bean.response.DeviceDeleteResponse;
|
|---|
| | | import com.hdl.sdk.connect.bean.response.DeviceInfoResponse;
|
|---|
| | | import com.hdl.sdk.connect.callback.HDLLinkCallBack;
|
|---|
| | | import com.hdl.sdk.connect.config.HDLLinkConfig;
|
|---|
| | |
|---|
| | | response.setData(bodyString);
|
|---|
| | | LogUtils.i("接收到数据:" + response.getTopic() + "\r\n" + response.getData());
|
|---|
| | |
|
|---|
| | | String receivetopic = String.format(TopicConstant.LINK_BROADCAST, HDLLinkConfig.getInstance().getGatewayId());
|
|---|
| | | String updateLocalSecret = String.format(TopicConstant.LINK_BROADCAST, HDLLinkConfig.getInstance().getGatewayId());
|
|---|
| | | String deleteNetwork = "";
|
|---|
| | | if (HDLLinkConfig.getInstance().getDeviceInfoBean() != null) {
|
|---|
| | | deleteNetwork = String.format(TopicConstant.DELETE_NOTIFY, HDLLinkConfig.getInstance().getDeviceInfoBean().getOID());
|
|---|
| | | }
|
|---|
| | |
|
|---|
| | | if (response.getTopic().equals("/user/all/custom/gateway/search")) {
|
|---|
| | | HDLAuthSocket.getInstance().UploadGatewayInfo(new HDLLinkCallBack() {
|
|---|
| | |
|---|
| | | LogUtils.i("UploadGatewayInfo onError");
|
|---|
| | | }
|
|---|
| | | });
|
|---|
| | | } else if (response.getTopic().equals(receivetopic)) {
|
|---|
| | | } else if (response.getTopic().equals(updateLocalSecret)) {
|
|---|
| | | try {
|
|---|
| | | DeviceInfoResponse deviceInfoResponse = GsonConvert.getGson().fromJson(response.getData(), new TypeToken<DeviceInfoResponse>() {
|
|---|
| | | }.getType());
|
|---|
| | |
|---|
| | | mackey = SPUtils.getString("auth_mackey_key", "");
|
|---|
| | | byte[] bodyBytes = AesUtil.aesDecrypt(baseBytes, mackey.substring(mackey.length() - 16));
|
|---|
| | | String localSecret = new String(bodyBytes, "utf-8");
|
|---|
| | | Log.d("panlili", "LinkMessageDecoder.java:----->localSecret= " + localSecret);
|
|---|
| | | HDLLinkConfig.getInstance().setLocalSecret(localSecret);
|
|---|
| | | }
|
|---|
| | | }
|
|---|
| | | } catch (Exception e) {
|
|---|
| | | LogUtils.i("LinkMessageDecoder.java:getLocalSecret----->e= " + e.getMessage());
|
|---|
| | | }
|
|---|
| | | } else if (response.getTopic().equals(deleteNetwork)) {
|
|---|
| | | try {
|
|---|
| | | DeviceDeleteResponse deviceDeleteResponse = GsonConvert.getGson().fromJson(response.getData(), new TypeToken<DeviceDeleteResponse>() {
|
|---|
| | | }.getType());
|
|---|
| | | HDLSocket.getInstance().deleteNetwork(deviceDeleteResponse.getObjects().get(0).getOID(), new HDLLinkCallBack() {
|
|---|
| | | @Override
|
|---|
| | | public void onSuccess(String msg) {
|
|---|
| | | LogUtils.i("deleteNetwork onSucceed");
|
|---|
| | | }
|
|---|
| | |
|
|---|
| | | @Override
|
|---|
| | | public void onError(HDLLinkException e) {
|
|---|
| | | LogUtils.i("deleteNetwork onError");
|
|---|
| | | }
|
|---|
| | | });
|
|---|
| | | } catch (Exception e) {
|
|---|
| | | LogUtils.i("LinkMessageDecoder.java:deleteNetwork----->e= " + e.getMessage());
|
|---|
| | | }
|
|---|
| | | }
|
|---|
| | |
|
|---|
| | | //非正常数据，返回
|
|---|
