package com.dayu.recharge; import android.app.Application; 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.IpBean; 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.ToastUtil; import com.dayu.recharge.utils.WSHelper; import java.util.Arrays; import java.util.Timer; import java.util.TimerTask; public class MyApplication extends Application { 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); socketConnect(); CrashReport.initCrashReport(getApplicationContext(), "846987eae9", true); } private boolean isAidl; public boolean isAidl() { return isAidl; } public void setAidl(boolean aidl) { isAidl = aidl; } /** * 初始化EasySocket */ public void initEasySocket(boolean isCreate, SocketNet.CreateBack createBack) { try { this.createBack = createBack; IpBean ipBean = BaseDaoSingleton.getInstance(MyApplication.myApplication).ipDao().findFirst(); 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(MyApplication.this, "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)) { isDoInitMachine = true; InitMachineRequestBean initMachineRequestBean = new InitMachineRequestBean(); initMachineRequestBean.setControl("01"); //130107200008 112 青泉居委会 initMachineRequestBean.setAddress(addressCode); initMachineRequestBean.setXuLie(SocketUtil.getXuLie(this)); initMachineRequestBean.setAFN("91"); // Log.i("Socket", "注册报文"); 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")) { //保存设备注册号 BaseDaoSingleton.getInstance(MyApplication.myApplication).ipDao().findFirst(); WSHelper.getInstance(MyApplication.this).put("initCode", initCode); ToastUtil.show(MyApplication.this, "充值管理注册报文获取成功"); } else { //校验CRC错误 ToastUtil.show(MyApplication.this, "确认收到注册报文状态失败"); } } else { //校验CRC错误 ToastUtil.show(MyApplication.this, "确认收到注册报文校验CRC错误"); } } @Override public void onSocketError(int code, String msg) { } }); } else {//校验CRC错误 ToastUtil.show(MyApplication.this, "充值管理注册报文校验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(1024) .setMaxReadBytes(1024) .setRequestTimeout(10 * 1000) .build(); // 初始化 EasySocket.getInstance().createConnection(options, this);// 创建一个socket连接 // EasySocket.getInstance().subscribeSocketAction(socketActionListener); EasySocket.getInstance().subscribeSocketAction(SocketNet.getInstance().socketNet.socketActionListener); } /** * 定时重连服务器 */ private void socketConnect() { try { TimerTask task = new TimerTask() { @Override public void run() { // TODO Auto-generated method stub Message message = new Message(); message.what = 1; handler.sendMessage(message); } }; // timer.schedule(task, 5000, 1000 * 60 * 3); timer.schedule(task, 5000, 1000 * 60 * 3); } catch (Exception e) { e.printStackTrace(); } } Handler handler = new Handler() { @Override public void handleMessage(Message msg) { // TODO Auto-generated method stub // 要做的事情 super.handleMessage(msg); try { SocketNet.getInstance().isConnect(MyApplication.this); } catch (Exception e) { e.printStackTrace(); } } }; }