package com.hdl.sdk.connect; import android.text.TextUtils; import android.util.Log; import com.google.gson.Gson; import com.google.gson.JsonObject; import com.google.gson.reflect.TypeToken; import com.hdl.sdk.common.config.AuthenticateConfig; import com.hdl.sdk.common.config.TopicConstant; import com.hdl.sdk.common.utils.IdUtils; import com.hdl.sdk.common.utils.IpUtils; import com.hdl.sdk.common.utils.gson.GsonConvert; import com.hdl.sdk.connect.bean.AuthenticateRequest; import com.hdl.sdk.connect.bean.AuthenticateRequest.AuthenticateDeviceInfoBean; import com.hdl.sdk.connect.bean.BaseLocalResponse; import com.hdl.sdk.connect.bean.DeviceControlRequest; import com.hdl.sdk.connect.bean.GatewaySearchBean; import com.hdl.sdk.connect.bean.LinkRequest; import com.hdl.sdk.connect.bean.LinkResponse; import com.hdl.sdk.connect.protocol.LinkMessageDecoder; import com.hdl.sdk.connect.protocol.LinkMessageEncoder; import com.hdl.sdk.socket.SocketBoot; import com.hdl.sdk.socket.SocketOptions; import com.hdl.sdk.socket.client.UdpClient; import com.hdl.sdk.socket.codec.MessagePipeLine; import java.io.UnsupportedEncodingException; import java.security.MessageDigest; import java.security.NoSuchAlgorithmException; import java.util.List; import static com.hdl.sdk.common.config.TopicConstant.DEIVCE_AUTH_REQUEST; /** * Created by jlchen on 11/11/21. * * @Description : HDLAuthSocket */ public class HDLAuthSocket { /** * udp默认端口 */ private static final int UDP_PORT = 8585; private static SocketBoot updBoot; /** * instance */ private volatile static HDLAuthSocket instance; public interface CallBack { void onError(String error); void onSuccess(String data); } /** * getInstance * * @return HDLAuthSocket */ public static synchronized HDLAuthSocket getInstance() { if (instance == null) { synchronized (AuthenticateConfig.class) { if (instance == null) { instance = new HDLAuthSocket(); } } } return instance; } private SocketOptions getUdpOptions() { final SocketOptions options = new SocketOptions(); final MessagePipeLine pipeLine = new MessagePipeLine(); pipeLine.add(new LinkMessageDecoder()); pipeLine.add(new LinkMessageEncoder()); options.setHandleMessage(pipeLine); options.setEnabledHeartbeat(false); return options; } private SocketBoot getUdpBoot(String ip) { if (updBoot == null) { updBoot = UdpClient.init(ip, UDP_PORT, getUdpOptions()); updBoot.connect(); } return updBoot; } private String getOid() { return "000101EA9B8C1C22"; } private String getSid() { return "000101EA9B8C1C2202010001021A"; } /** * 发送入网及认证请求 * * @param ip 网关IP * @param request 认证请求信息 * @param callBack 结果回调 */ public void sendAuthenticateRequest(String ip, AuthenticateRequest request, CallBack callBack) { if (request == null) { callBack.onError("request null"); } String topic = DEIVCE_AUTH_REQUEST; Gson gs = new Gson(); String requestStr = gs.toJson(request); LinkRequest message = new LinkRequest(topic, requestStr); HdlSocketHelper.send(getUdpBoot(ip), message, new HdlSocketHelper.HdlSocketListener() { @Override public void onSucceed(Object msg) { callBack.onSuccess(msg.toString()); } @Override public void onFailure() { Log.i("TAG", "onFailure: "); callBack.onError("超时"); } }); } /** * 发送入网及认证请求 * * @param callBack 结果回调 */ public void sendAuthenticateRequest(CallBack callBack) { String macStr = "AA000000000000BB"; String secret = "87ae414b7a853f65"; 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("ir.module"); authbean.setMACKey(mac_key); authbean.setRequest(requestBean); //2.设置设备信息 AuthenticateDeviceInfoBean infoBean = new AuthenticateDeviceInfoBean(); infoBean.setDeviceMAC(macStr); infoBean.setIPMAC(macStr); infoBean.setDeviceName("HDL面板"); infoBean.setAccessMode("HDL"); infoBean.setOID(getOid()); infoBean.setSid(getSid()); // 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); String ip = IpUtils.getBroadcastAddress(); ip = "192.168.10.102"; sendAuthenticateRequest(ip, request, callBack); } public interface SearchGatewayCallBack { /** * 搜索结束 * * @param error */ void onEnd(String error); /** * 搜索网关成功 * * @param gatewaySearchBean */ void onSuccess(GatewaySearchBean gatewaySearchBean); } /** * 开始搜索所有网关，有网关回复就回调，上层自己做去重判断 * * @param callBack 回调 */ public void startSearchAllGateway(SearchGatewayCallBack callBack) { } /** * 暂停搜索网关 */ public void endSearchAllGateway() { } /** * 搜索指定网关是否在线，搜索到则返回指定的网关对象 * * @param gatewayId 网关id * @param callBack 回调 */ public void searchGateway(String gatewayId, SearchGatewayCallBack callBack) { String time = String.valueOf(System.currentTimeMillis()); JsonObject jsonObject = new JsonObject(); jsonObject.addProperty("id", IdUtils.getUUId()); jsonObject.addProperty("time_stamp", time); String ip = IpUtils.getBroadcastAddress(); LinkRequest message = new LinkRequest(TopicConstant.GATEWAY_SEARCH, jsonObject.toString()); HdlSocketHelper.send(getUdpBoot(ip), message, new HdlSocketHelper.HdlSocketListener() { @Override public void onSucceed(Object msg) { GatewaySearchBean searchBean = getGatewaySearchBean(msg); if (searchBean != null && searchBean.getGatewayId() == gatewayId) { Log.i("TAG", "onSuccess: "); callBack.onSuccess(searchBean); } } @Override public void onFailure() { Log.i("TAG", "onFailure: "); callBack.onEnd("超时"); } }); } private GatewaySearchBean getGatewaySearchBean(Object msg) { GatewaySearchBean searchBean = null; if (msg instanceof LinkResponse) { LinkResponse linkResponse = (LinkResponse) msg; String data = linkResponse.getData(); if (!TextUtils.isEmpty(data)) { final BaseLocalResponse response = GsonConvert.getGson().fromJson(data, new TypeToken>() { }.getType()); searchBean = response.getObjects(); } } return searchBean; } /** * 设备控制 */ public void propertyDown(List request, HDLSocket.CallBack callBack) { // if (!TextUtils.isEmpty(getGatewayId()) && !TextUtils.isEmpty(getTcpIp())) { String time = String.valueOf(System.currentTimeMillis()); final BaseLocalResponse> data = new BaseLocalResponse<>(); data.setId(IdUtils.getUUId()); data.setTime_stamp(time); data.setObjects(request); String topic = String.format(TopicConstant.PROPERTY_DOWN, "1406844230123372545"); LinkRequest message = new LinkRequest(topic, GsonConvert.getGson().toJson(request)); Log.i("TAG", "propertyDown: " + message.getData()); String ip = IpUtils.getBroadcastAddress(); HdlSocketHelper.send(getUdpBoot(ip), message, null); // } } 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(); } }