package com.hdl.sdk.hdl_sdk.activity;
|
|
import android.support.v7.app.AppCompatActivity;
|
import android.os.Bundle;
|
import android.util.Log;
|
import android.view.View;
|
import android.widget.Button;
|
|
import com.hdl.sdk.hdl_core.Config.Configuration;
|
import com.hdl.sdk.hdl_core.HDLDeviceManger.Bean.ZigbeeBean.ZigbeeGatewayInfoBean;
|
import com.hdl.sdk.hdl_core.Util.LogUtil.HDLLog;
|
import com.hdl.sdk.hdl_core.Util.NetUtil.NetWorkUtil;
|
import com.hdl.sdk.hdl_core.Util.TransformUtil.StringUtil;
|
import com.hdl.sdk.hdl_sdk.R;
|
|
import java.net.DatagramPacket;
|
import java.net.DatagramSocket;
|
import java.net.InetAddress;
|
import java.net.Socket;
|
import java.net.SocketException;
|
import java.util.ArrayList;
|
import java.util.List;
|
import java.util.Timer;
|
import java.util.TimerTask;
|
|
public class TextUdpActivity extends AppCompatActivity {
|
private static DatagramSocket datagramSocket7624 = null;
|
public static List<ZigbeeGatewayInfoBean> zigbeeGatewayInfoBeanList = new ArrayList<>();
|
public static Timer searchTimer = null;
|
private static boolean isStop = false;
|
Button button;
|
public static void release() {
|
isStop = true;
|
datagramSocket7624.disconnect();
|
datagramSocket7624 = null;
|
}
|
|
@Override
|
protected void onCreate(Bundle savedInstanceState) {
|
super.onCreate(savedInstanceState);
|
setContentView(R.layout.activity_text_udp);
|
button = findViewById(R.id.button1);
|
init7624();
|
button.setOnClickListener(new View.OnClickListener() {
|
@Override
|
public void onClick(View view) {
|
SearchGateWay();
|
}
|
});
|
}
|
|
private static void SearchGateWay() {
|
new Thread(new Runnable() {
|
@Override
|
public void run() {
|
try {
|
byte[] sendBytes = new byte[44];
|
sendBytes[0] = (byte) 0xFE;
|
sendBytes[1] = 0x29;
|
sendBytes[2] = 0;
|
sendBytes[3] = 0;
|
sendBytes[4] = 0;
|
sendBytes[5] = 0;
|
sendBytes[6] = 0;
|
//获取所有网关（无需houseID模式），后面要改
|
sendBytes[7] = 0x67;
|
sendBytes[8] = 0x65;
|
sendBytes[9] = 0x74;
|
sendBytes[10] = 0x61;
|
sendBytes[11] = 0x6c;
|
sendBytes[12] = 0x6c;
|
sendBytes[13] = 0x67;
|
sendBytes[14] = 0x77;
|
for (int i = 15; i<sendBytes.length-1;i++){
|
sendBytes[i] = 0;
|
}
|
sendBytes[sendBytes.length - 1] = 0x02;
|
DatagramSocket socket = new DatagramSocket();
|
InetAddress address = InetAddress.getByName(NetWorkUtil.getLocalBroadCast());
|
DatagramPacket packet = new DatagramPacket(
|
sendBytes,
|
sendBytes.length,
|
address, Configuration.ZIGBEE_PORT);
|
socket.send(packet);
|
socket.close();
|
} catch (Exception e) {
|
e.printStackTrace();
|
}
|
}
|
}).start();
|
|
}
|
|
/**
|
* 初始化7624端口
|
*/
|
public static void init7624(){
|
if (datagramSocket7624 != null){
|
HDLLog.info( "HDL SDK 7624 已启动");
|
}else {
|
HDLLog.info( "HDLSocket 7624 init");
|
new Thread(new Runnable() {
|
@Override
|
public void run() {
|
try {
|
datagramSocket7624 = new DatagramSocket(Configuration.ZIGBEE_PORT);
|
while (!isStop && datagramSocket7624 != null) {
|
datagramSocket7624.setReceiveBufferSize(1024 * 20);
|
datagramSocket7624.setReuseAddress(true);
|
while (datagramSocket7624 != null){
|
byte[] receiveBytes = new byte[1024];
|
DatagramPacket dataPacket = new DatagramPacket(receiveBytes, receiveBytes.length);
|
if (datagramSocket7624 != null || (!datagramSocket7624.isClosed())) {
|
datagramSocket7624.receive(dataPacket);
|
}
|
Log.d("11114", "初始化端口接收的数据为receiveBytes： "+StringUtil.ByteArrToHex(receiveBytes,0,receiveBytes.length));
|
handleData(receiveBytes,dataPacket);
|
}
|
}
|
} catch (Exception e) {
|
datagramSocket7624 = null;
|
return;
|
}
|
}
|
}).start();
|
}
|
}
|
|
private static void handleData(byte[] receiveBytes,DatagramPacket dataPacket) {
|
if (receiveBytes[45] ==0){
|
return;
|
}
|
Log.d("11114", "处理的数据为receiveBytes： "+StringUtil.ByteArrToHex(receiveBytes,0,receiveBytes.length));
|
//是否主网关-01为主网关-00为从网关
|
String IsDomain = StringUtil.Byte2Hex(dataPacket.getData()[44]);
|
int headLength = 49;
|
if (receiveBytes.length > headLength) {
|
//网关名称长度
|
String str = StringUtil.Byte2Hex(dataPacket.getData()[49]);
|
int GwNameLength = Integer.parseInt(str, 16);
|
|
//网关名称
|
byte[] gwnamebyte = new byte[GwNameLength];
|
for (int i = 0; i < GwNameLength; i++) {
|
gwnamebyte[i] = dataPacket.getData()[i + 50];
|
}
|
String GwName = new String(gwnamebyte, 0, gwnamebyte.length);
|
|
//网关id长度
|
String str1 = StringUtil.Byte2Hex(dataPacket.getData()[50 + GwNameLength]);
|
int GwIdLength = Integer.parseInt(str1, 16);
|
|
//获取网关id
|
byte[] gatewayId = new byte[GwIdLength];
|
for (int i = 0; i < GwIdLength; i++) {
|
gatewayId[i] = dataPacket.getData()[i + 51 + GwNameLength];
|
}
|
|
if (gatewayId.length > 1) {
|
String stringGateWayId = new String(gatewayId, 0, gatewayId.length);
|
Log.d("11114", "网关id: " + stringGateWayId);
|
|
ZigbeeGatewayInfoBean zigbeeGatewayInfoBean = new ZigbeeGatewayInfoBean();
|
zigbeeGatewayInfoBean.setGatewayId(stringGateWayId);
|
zigbeeGatewayInfoBean.setIpAddress(dataPacket.getAddress().getHostAddress());
|
if (IsDomain.equals("01")){
|
zigbeeGatewayInfoBean.setDomain(true);
|
}else {
|
zigbeeGatewayInfoBean.setDomain(false);
|
}
|
zigbeeGatewayInfoBean.setGatewayName(GwName);
|
boolean isExit = false;
|
for (int i = 0; i < zigbeeGatewayInfoBeanList.size(); i++) {
|
if (zigbeeGatewayInfoBeanList.get(i).getGatewayId()
|
.equals(zigbeeGatewayInfoBean.getGatewayId())) {
|
isExit = true;
|
break;
|
}
|
}
|
if (!isExit) {
|
zigbeeGatewayInfoBeanList.add(zigbeeGatewayInfoBean);
|
Log.d("11114", "addList:成功添加 ");
|
}
|
}
|
}
|
}
|
}
|
