android/charge.git

			@@ -1,21 +1,14 @@
			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.CallbackIDFactoryImpl;
			import com.dayu.recharge.net.ScoketMessageProtocol;
			import com.dayu.recharge.net.SocketCallBack;
			import com.dayu.recharge.net.SocketData;
			@@ -27,25 +20,30 @@
			import com.dayu.recharge.tools.HexUtil;
			import com.dayu.recharge.utils.AidlUtil;
			import com.dayu.recharge.utils.CRC8;
			import com.dayu.recharge.utils.DeviceNumberUtils;
			import com.dayu.recharge.utils.SocketUtil;
			import com.dayu.recharge.utils.TipUtil;
			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 java.net.InetAddress;
			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();

			//每次启动程序只去注册一遍，不再重新注册。
			public static boolean isCreate = false;


			@Override
			@@ -78,50 +76,22 @@
			public void initEasySocket(boolean isCreate, SocketNet.CreateBack createBack) {
			try {
			this.createBack = createBack;
			ipBean = BaseDaoSingleton.getInstance(MyApplication.myApplication).ipDao().findFirst();
			try {
			ipBean = BaseDaoSingleton.getInstance(MyApplication.myApplication).ipDao().findFirst();
			} catch (Exception e) {
			e.printStackTrace();
			}
			if (ipBean == null) {
			ipBean = new IpBean();
			ipBean.setIp("dayuyanjiuyuan.top");
			ipBean.setPort(8888);
			ipBean.setIp("newreceive.hnsjgg.com");
			ipBean.setPort(9999);
			// 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 (SocketNet.getInstance().isNetworkAvailable(this)){
			if (ipBean != null) {
			try {
			//处理当连接上IP后修改ip不生效问题
			if (EasySocket.getInstance().getDefconnection() != null) {
			SocketAddress address = EasySocket.getInstance().getDefconnection().getOptions().getSocketAddress();
			if (address != null) {
			@@ -130,10 +100,53 @@
			}
			}
			}
			} 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(), "0", 88);
			break;
			case 2:
			InetAddress[] data = (InetAddress[]) msg.obj;
			createSocket(data[0].getHostAddress(), ipBean.getPort(), data[1].getHostAddress(), ipBean.getPort());
			break;
			case -1:
			ToastUtil.show("DNS解析失败");
			break;
			}

			}
			});

			} else {
			//ip方式
			if (EasySocket.getInstance().getContext() == null \|\| isCreate) {
			createSocket(ipBean.getIp(), ipBean.getPort(), "0", 88);
			} 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();
			}
			}
			}
			}

			}
			}
			}else {
			ToastUtil.show("请检查网络连接");
			}

			} catch (Exception e) {
			e.printStackTrace();
			}
			@@ -149,89 +162,93 @@
			&& !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 (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(), "91",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() {
			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(), "92",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("确认收到注册报文状态失败");
			@Override
			public void onSocketResponse(SocketData readData) {
			isDoInitMachine = false;
			MyApplication.myApplication.isCreate = true;
			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 {
			Log.i(TAG, "注册失败--- 状态码：" + state);
			//校验CRC错误
			ToastUtil.show("确认收到注册报文校验CRC错误");
			// ToastUtil.show("确认收到注册报文状态失败");
			}
			} else {
			//校验CRC错误
			ToastUtil.show("确认收到注册报文校验CRC错误");
			}
			}

			@Override
			public void onSocketError(int code, String msg) {
			@Override
			public void onSocketError(int code, String msg) {

			}
			});
			} else {//校验CRC错误
			ToastUtil.show("充值管理注册报文校验CRC错误");
			}
			}
			});
			} else {//校验CRC错误
			ToastUtil.show("充值管理注册报文校验CRC错误");
			}
			}

			@Override
			public void onSocketError(int code, String msg) {
			@Override
			public void onSocketError(int code, String msg) {

			}
			});
			}
			});

			}
			}
			}

			}

			private void createSocket(String ip, int port) {
			private void createSocket(String ip, int port, String backUpIp, int backUpPort) {
			// socket配置
			EasySocketOptions options = new EasySocketOptions.Builder()
			// 主机地址，请填写自己的IP地址，以getString的方式是为了隐藏作者自己的IP地址
			.setSocketAddress(new SocketAddress(ip, port))
			// 定义消息协议，方便解决 socket黏包、分包的问题
			.setReaderProtocol(new ScoketMessageProtocol())
			.setCallbackIDFactory(new CallbackIDFactoryImpl())
			.setMaxWriteBytes(150)
			.setMaxReadBytes(150)
			.setRequestTimeout(5 * 1000)
			.setRequestTimeout(20 * 1000)
			.setBackupAddress(new SocketAddress(backUpIp, backUpPort))
			.build();

			// 初始化