package com.dayu.recharge; import android.app.Application; import android.nfc.Tag; import android.os.Handler; import android.os.Message; import android.text.TextUtils; import android.util.Log; import com.dayu.recharge.dao.BaseDaoSingleton; import com.dayu.recharge.dbBean.DeviceNumber; import com.dayu.recharge.dbBean.IpBean; import com.dayu.recharge.utils.DeviceNumberUtils; import com.dayu.recharge.utils.ToastUtil; import com.easysocket.EasySocket; import com.easysocket.config.EasySocketOptions; import com.easysocket.entity.SocketAddress; import com.tencent.bugly.crashreport.CrashReport; import com.dayu.recharge.net.ScoketMessageProtocol; import com.dayu.recharge.net.SocketCallBack; import com.dayu.recharge.net.SocketData; import com.dayu.recharge.net.SocketNet; import com.dayu.recharge.socketBean.ConfirmMachineRequestBean; import com.dayu.recharge.socketBean.InitMachineBackBean; import com.dayu.recharge.socketBean.InitMachineRequestBean; import com.dayu.recharge.tools.BcdUtil; import com.dayu.recharge.tools.HexUtil; import com.dayu.recharge.utils.AidlUtil; import com.dayu.recharge.utils.CRC8; import com.dayu.recharge.utils.SocketUtil; import com.dayu.recharge.utils.TipUtil; import java.util.Arrays; import java.util.Timer; import java.util.TimerTask; public class MyApplication extends Application { public static String TAG = "MyApplication"; public static MyApplication myApplication; private String address; SocketNet.CreateBack createBack; //是否正在请求初始化接口 public boolean isDoInitMachine = false; //是否连接服务器成功 public boolean isConncet = false; private final Timer timer = new Timer(); @Override public void onCreate() { super.onCreate(); myApplication = this; isAidl = true; AidlUtil.getInstance().connectPrinterService(this); // initEasySocket(false, null); CrashReport.initCrashReport(getApplicationContext(), "45551598b8", true); } private boolean isAidl; public boolean isAidl() { return isAidl; } public void setAidl(boolean aidl) { isAidl = aidl; } public IpBean ipBean; /** * 初始化EasySocket * * @param isCreate 当前已连接服务器后是否重新连接 * @param createBack */ public void initEasySocket(boolean isCreate, SocketNet.CreateBack createBack) { try { this.createBack = createBack; ipBean = BaseDaoSingleton.getInstance(MyApplication.myApplication).ipDao().findFirst(); if (ipBean == null) { ipBean = new IpBean(); ipBean.setIp("dayuyanjiuyuan.top"); ipBean.setPort(8888); } if (ipBean != null) { try { //处理当连接上IP后修改ip不生效问题 if (EasySocket.getInstance().getDefconnection() != null) { SocketAddress address = EasySocket.getInstance().getDefconnection().getOptions().getSocketAddress(); if (address != null) { if (!address.getIp().equals(ipBean.getIp()) || address.getPort() != ipBean.getPort()) { EasySocket.getInstance().destroyConnection(); } } } } catch (Exception e) { e.printStackTrace(); } if (!SocketUtil.isInteger(ipBean.getIp())) { //域名方式 SocketUtil.parseHostGetIPAddress(ipBean.getIp(), new Handler() { @Override public void handleMessage(Message msg) { super.handleMessage(msg); switch (msg.what) { case 1: createSocket(msg.obj + "", ipBean.getPort()); break; case 2: ToastUtil.show("DNS解析失败"); break; } } }); } else { //ip方式 if (EasySocket.getInstance().getContext() == null || isCreate) { createSocket(ipBean.getIp(), ipBean.getPort()); } else { if (EasySocket.getInstance().getDefconnection() != null) { SocketAddress address = EasySocket.getInstance().getDefconnection().getOptions().getSocketAddress(); if (address != null) { if (!address.getIp().equals(ipBean.getIp()) || address.getPort() != ipBean.getPort()) { EasySocket.getInstance().destroyConnection(); } } } } } } } catch (Exception e) { e.printStackTrace(); } } /** * 充值管理机注册 */ public void initMachineRequestBean(String ip, int port, String addressCode) { if (!TextUtils.isEmpty(ip) && !TextUtils.isEmpty(String.valueOf(port)) && !TextUtils.isEmpty(addressCode)) { Log.i("initMachineRequestBean", "开始注册设备"); if (EasySocket.getInstance().getDefconnection() != null) { isDoInitMachine = true; InitMachineRequestBean initMachineRequestBean = new InitMachineRequestBean(); initMachineRequestBean.setControl("01"); //130107200008 112 青泉居委会 initMachineRequestBean.setAddress(addressCode); initMachineRequestBean.setXuLie(SocketUtil.getXuLie(this)); initMachineRequestBean.setAFN("91"); SocketNet.getInstance().sendTestMessage(initMachineRequestBean.pack(), new SocketCallBack() { @Override public void onSocketResponse(SocketData readData) { if (CRC8.isCRC8(readData.getOriginDataBytes())) { //校验CRC成功 InitMachineBackBean initMachineBackBean = new InitMachineBackBean(); String initCode = HexUtil.bytesToHex(Arrays.copyOfRange(readData.getBodyBytes(), 2, 18)); //确认收到注册号报文 ConfirmMachineRequestBean confirmMachineRequestBean = new ConfirmMachineRequestBean(); confirmMachineRequestBean.setControl("01"); //130107200008 112 青泉居委会 confirmMachineRequestBean.setAddress(addressCode); confirmMachineRequestBean.setXuLie(SocketUtil.getXuLie(MyApplication.this)); confirmMachineRequestBean.setAFN("92"); confirmMachineRequestBean.setInitCode(initCode); Log.i("Socket", "确认注册报文"); SocketNet.getInstance().sendTestMessage(confirmMachineRequestBean.pack(), new SocketCallBack() { @Override public void onSocketResponse(SocketData readData) { isDoInitMachine = false; if (CRC8.isCRC8(readData.getOriginDataBytes())) { byte stateByte = readData.getBodyBytes()[2]; String state = BcdUtil.bcdToStr(stateByte); //BCD码00成功01失败(注册号不是服务器返回信息) if (state.equalsIgnoreCase("00")) { //保存设备注册号 if (!TextUtils.isEmpty(initCode)) { DeviceNumberUtils.setDeviceNumber(initCode); } Log.i(TAG, "onSuccess: 设备注册号：" + initCode); // WSHelper.getInstance(MyApplication.this).put("initCode", initCode); ToastUtil.show("充值管理注册报文获取成功"); } else { //校验CRC错误 // ToastUtil.show("确认收到注册报文状态失败"); } } else { //校验CRC错误 ToastUtil.show("确认收到注册报文校验CRC错误"); } } @Override public void onSocketError(int code, String msg) { } }); } else {//校验CRC错误 ToastUtil.show("充值管理注册报文校验CRC错误"); } } @Override public void onSocketError(int code, String msg) { } }); } } } private void createSocket(String ip, int port) { // socket配置 EasySocketOptions options = new EasySocketOptions.Builder() // 主机地址，请填写自己的IP地址，以getString的方式是为了隐藏作者自己的IP地址 .setSocketAddress(new SocketAddress(ip, port)) // 定义消息协议，方便解决 socket黏包、分包的问题 .setReaderProtocol(new ScoketMessageProtocol()) .setMaxWriteBytes(150) .setMaxReadBytes(150) .setRequestTimeout(5 * 1000) .build(); // 初始化 EasySocket.getInstance().createConnection(options, this);// 创建一个socket连接 // EasySocket.getInstance().subscribeSocketAction(socketActionListener); EasySocket.getInstance().subscribeSocketAction(SocketNet.getInstance().socketNet.socketActionListener); } }