package com.dayu.recharge.net;
|
|
import android.content.Context;
|
import android.os.Handler;
|
import android.text.TextUtils;
|
import android.util.Log;
|
|
import com.dayu.recharge.dao.BaseDaoSingleton;
|
import com.dayu.recharge.dbBean.AdminDataBean;
|
import com.dayu.recharge.dbBean.IpBean;
|
import com.easysocket.EasySocket;
|
import com.easysocket.entity.OriginReadData;
|
import com.easysocket.entity.SocketAddress;
|
import com.easysocket.interfaces.conn.ISocketActionListener;
|
import com.easysocket.interfaces.conn.SocketActionListener;
|
import com.dayu.recharge.MyApplication;
|
import com.dayu.recharge.utils.ToastUtil;
|
import com.dayu.recharge.utils.WSHelper;
|
import com.easysocket.utils.LogUtil;
|
|
|
/**
|
* Copyright (C), 2022,
|
* Author: zuo
|
* Date: 2022/2/8 21:30
|
* Description: Socket通信
|
*/
|
public class SocketNet {
|
public static SocketNet socketNet;
|
SocketCallBack myCallBack;
|
byte[] dataMessage;
|
boolean isTest = false;
|
Context mContext;
|
|
public static SocketNet getInstance() {
|
if (socketNet == null) {
|
socketNet = new SocketNet();
|
if (socketNet.socketActionListener != null) {
|
|
}
|
}
|
return socketNet;
|
}
|
|
|
/**
|
* 发送一个的消息，
|
*/
|
public void sendTestMessage(byte[] dataMessage, SocketCallBack callBack) {
|
myCallBack = callBack;
|
isTest = false;
|
// 发送
|
// EasySocket.getInstance().upMessage(dataMessage);
|
if (EasySocket.getInstance().getDefOptions().getSocketAddress() != null) {
|
EasySocket.getInstance().disconnect(false);
|
EasySocket.getInstance().connect();
|
this.dataMessage = dataMessage;
|
} else {
|
LogUtil.w("Socket地址为空");
|
}
|
}
|
|
|
/**
|
* 测试socket是否连接通畅
|
*
|
* @param context
|
*/
|
public void isConnect(Context context) {
|
Log.i("SocketActionListener", "测试连接");
|
isTest = true;
|
mContext = context;
|
if (EasySocket.getInstance().getDefOptions().getSocketAddress() != null && !MyApplication.myApplication.isDoInitMachine) {
|
EasySocket.getInstance().disconnect(false);
|
EasySocket.getInstance().connect();
|
} else {
|
// ToastUtil.show(mContext, "Socket地址为空");
|
}
|
}
|
|
|
public interface CreateBack {
|
void Success();
|
|
void error();
|
}
|
|
/**
|
* socket行为监听
|
*/
|
public ISocketActionListener socketActionListener = new SocketActionListener() {
|
/**
|
* socket连接成功
|
* @param socketAddress
|
*/
|
@Override
|
public void onSocketConnSuccess(SocketAddress socketAddress) {
|
Log.i("SocketActionListener", "连接成功");
|
String initCode = WSHelper.getInstance(MyApplication.myApplication).get("initCode", "");
|
if (TextUtils.isEmpty(initCode) && !MyApplication.myApplication.isDoInitMachine) {
|
new Handler().postDelayed(new Runnable() {
|
@Override
|
public void run() {
|
IpBean ipBean = BaseDaoSingleton.getInstance(MyApplication.myApplication).ipDao().findFirst();
|
AdminDataBean adminData = BaseDaoSingleton.getInstance(MyApplication.myApplication).adminDao().findFirst();
|
if (ipBean != null && adminData != null) {
|
MyApplication.myApplication.initMachineRequestBean(ipBean.getIp(), ipBean.getPort(), adminData.getAddressCode());
|
}
|
}
|
}, 2000);
|
|
}
|
if (dataMessage != null) {
|
EasySocket.getInstance().upMessage(dataMessage);
|
}
|
if (isTest) {
|
MyApplication.myApplication.isConncet = true;
|
EasySocket.getInstance().disconnect(false);
|
} else {
|
|
}
|
|
}
|
|
/**
|
* socket连接失败
|
* @param socketAddress
|
* @param isNeedReconnect 是否需要重连
|
*/
|
@Override
|
public void onSocketConnFail(SocketAddress socketAddress, boolean isNeedReconnect) {
|
// isConnected = false;
|
Log.i("SocketActionListener", "socket连接失败");
|
if (isTest) {
|
ToastUtil.show(mContext, "连接失败,请检查网络");
|
} else {
|
if (myCallBack != null) {
|
myCallBack.onSocketError(-1, "socket连接失败,请检查网络");
|
}
|
}
|
}
|
|
/**
|
* socket断开连接
|
* @param socketAddress
|
* @param isNeedReconnect 是否需要重连
|
*/
|
@Override
|
public void onSocketDisconnect(SocketAddress socketAddress, boolean isNeedReconnect) {
|
Log.i("SocketActionListener", "---> socket断开连接，是否需要重连：" + isNeedReconnect);
|
|
}
|
|
/**
|
* socket接收的数据
|
* @param socketAddress
|
* @param readData
|
*/
|
@Override
|
public void onSocketResponse(SocketAddress socketAddress, String readData) {
|
Log.i("SocketActionListener", "SocketActionListener收到数据-->" + readData);
|
|
}
|
|
@Override
|
public void onSocketResponse(SocketAddress socketAddress, OriginReadData originReadData) {
|
super.onSocketResponse(socketAddress, originReadData);
|
Log.i("SocketActionListener", "SocketActionListener收到数据-->" + originReadData.getBodyString());
|
SocketData socketData = new SocketData();
|
socketData.setBodyData(originReadData.getBodyBytes());
|
socketData.setHeaderData(originReadData.getHeaderData());
|
dataMessage = null;
|
if (myCallBack!=null){
|
myCallBack.onSocketResponse(socketData);
|
}
|
|
}
|
};
|
|
}
|
