android/charge.git

			@@ -1,6 +1,7 @@
			package com.dayu.recharge;

			import android.app.Application;
			import android.nfc.Tag;
			import android.os.Handler;
			import android.os.Message;
			import android.text.TextUtils;
			@@ -9,6 +10,7 @@
			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;
			@@ -29,12 +31,13 @@
			import com.dayu.recharge.utils.TipUtil;


			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;

			@@ -45,13 +48,15 @@
			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);

			// initEasySocket(false, null);

			CrashReport.initCrashReport(getApplicationContext(), "45551598b8", true);
			}
			@@ -66,13 +71,20 @@
			isAidl = aidl;
			}

			public IpBean ipBean;

			/**
			* 初始化EasySocket
			*/
			public void initEasySocket(boolean isCreate, SocketNet.CreateBack createBack) {
			try {
			this.createBack = createBack;
			IpBean ipBean = BaseDaoSingleton.getInstance(MyApplication.myApplication).ipDao().findFirst();
			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不生效问题
			@@ -96,9 +108,13 @@
			super.handleMessage(msg);
			switch (msg.what) {
			case 1:
			createSocket(msg.obj + "", ipBean.getPort());
			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;
			}
			@@ -109,7 +125,7 @@
			} else {
			//ip方式
			if (EasySocket.getInstance().getContext() == null \|\| isCreate) {
			createSocket(ipBean.getIp(), ipBean.getPort());
			createSocket(ipBean.getIp(), ipBean.getPort(), "0", 88);
			} else {
			if (EasySocket.getInstance().getDefconnection() != null) {
			SocketAddress address = EasySocket.getInstance().getDefconnection().getOptions().getSocketAddress();
			@@ -136,6 +152,8 @@
			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();
			@@ -144,8 +162,6 @@
			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) {
			@@ -153,7 +169,6 @@
			if (CRC8.isCRC8(readData.getOriginDataBytes())) {
			//校验CRC成功
			InitMachineBackBean initMachineBackBean = new InitMachineBackBean();

			String initCode = HexUtil.bytesToHex(Arrays.copyOfRange(readData.getBodyBytes(), 2, 18));
			//确认收到注册号报文
			ConfirmMachineRequestBean confirmMachineRequestBean = new ConfirmMachineRequestBean();
			@@ -175,15 +190,10 @@
			//BCD码00成功01失败(注册号不是服务器返回信息)
			if (state.equalsIgnoreCase("00")) {
			//保存设备注册号
			DeviceNumber deviceNumber = BaseDaoSingleton.getInstance(MyApplication.myApplication).deviceNumberDao().findFirst();
			if (deviceNumber != null) {
			deviceNumber.setDeviceRegistrationNumber(initCode);
			} else {
			deviceNumber = new DeviceNumber();
			deviceNumber.setDeviceRegistrationNumber(initCode);
			if (!TextUtils.isEmpty(initCode)) {
			DeviceNumberUtils.setDeviceNumber(initCode);
			}
			BaseDaoSingleton.getInstance(MyApplication.myApplication).deviceNumberDao().insert(deviceNumber);

			Log.i(TAG, "onSuccess: 设备注册号：" + initCode);
			// WSHelper.getInstance(MyApplication.this).put("initCode", initCode);
			ToastUtil.show("充值管理注册报文获取成功");
			} else {
			@@ -213,21 +223,21 @@
			});

			}


			}

			}

			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())
			.setMaxWriteBytes(1024)
			.setMaxReadBytes(1024)
			.setRequestTimeout(10 * 1000)
			.setMaxWriteBytes(150)
			.setMaxReadBytes(150)
			.setRequestTimeout(5 * 1000)
			.setBackupAddress(new SocketAddress(backUpIp, backUpPort))
			.build();

			// 初始化