|  |  |  | 
|---|
|  |  |  |  | 
|---|
|  |  |  | import android.content.Context; | 
|---|
|  |  |  | import android.os.Handler; | 
|---|
|  |  |  | import android.text.TextUtils; | 
|---|
|  |  |  | import android.util.Log; | 
|---|
|  |  |  |  | 
|---|
|  |  |  | import com.dayu.recharge.activity.HomeActivity; | 
|---|
|  |  |  | import com.dayu.recharge.dao.BaseDaoSingleton; | 
|---|
|  |  |  | import com.dayu.recharge.dbBean.AdminDataBean; | 
|---|
|  |  |  | import com.dayu.recharge.dbBean.DeviceNumber; | 
|---|
|  |  |  | 
|---|
|  |  |  | */ | 
|---|
|  |  |  | @Override | 
|---|
|  |  |  | public void onSocketConnSuccess(SocketAddress socketAddress) { | 
|---|
|  |  |  | Log.i("SocketActionListener", "连接成功"); | 
|---|
|  |  |  | Log.i("SocketActionListener1111", "连接成功"); | 
|---|
|  |  |  | MyApplication.myApplication.isConncet = true; | 
|---|
|  |  |  | DeviceNumber initCode = BaseDaoSingleton.getInstance(MyApplication.myApplication).deviceNumberDao().findFirst(); | 
|---|
|  |  |  | if (initCode == null && !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()); | 
|---|
|  |  |  | } | 
|---|
|  |  |  | AdminDataBean adminData = BaseDaoSingleton.getInstance(MyApplication.myApplication).adminDao().findFirst(); | 
|---|
|  |  |  | Log.i("SocketActionListener1111", "isDoInitMachine==" + MyApplication.myApplication.isDoInitMachine + ""); | 
|---|
|  |  |  | if (!MyApplication.myApplication.isDoInitMachine) { | 
|---|
|  |  |  | Log.i("SocketActionListener1111", "isDoInitMachine"); | 
|---|
|  |  |  | if (MyApplication.myApplication.ipBean != null && adminData != null) { | 
|---|
|  |  |  | if (!TextUtils.isEmpty(adminData.getAddressCode())) { | 
|---|
|  |  |  | Log.i("SocketActionListener1111", "initMachineRequestBean"); | 
|---|
|  |  |  | MyApplication.myApplication.initMachineRequestBean(MyApplication.myApplication.ipBean.getIp(), MyApplication.myApplication.ipBean.getPort(), adminData.getAddressCode()); | 
|---|
|  |  |  |  | 
|---|
|  |  |  | } | 
|---|
|  |  |  | }, 500); | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|
|  |  |  | } | 
|---|
|  |  |  | //            if (dataMessage != null) { | 
|---|
|  |  |  | //                EasySocket.getInstance().upMessage(dataMessage); | 
|---|
|  |  |  | //            } | 
|---|
|  |  |  | if (isTest) { | 
|---|
|  |  |  | MyApplication.myApplication.isConncet = true; | 
|---|
|  |  |  | //                EasySocket.getInstance().disconnect(false); | 
|---|
|  |  |  | } else { | 
|---|
|  |  |  |  | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|
|  |  |  | rushState(); | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|
|  |  |  | /** | 
|---|
|  |  |  | 
|---|
|  |  |  | @Override | 
|---|
|  |  |  | public void onSocketConnFail(SocketAddress socketAddress, boolean isNeedReconnect) { | 
|---|
|  |  |  | MyApplication.myApplication.isConncet = false; | 
|---|
|  |  |  | rushState(); | 
|---|
|  |  |  | Log.i("SocketActionListener", "socket连接失败"); | 
|---|
|  |  |  | if (isTest) { | 
|---|
|  |  |  | //                ToastUtil.show(mContext, "连接失败,请检查网络"); | 
|---|
|  |  |  | } else { | 
|---|
|  |  |  | if (myCallBack != null) { | 
|---|
|  |  |  | myCallBack.onSocketError(-1, "socket连接失败,请检查网络"); | 
|---|
|  |  |  | myCallBack.onSocketError(-1, "连接数据中心失败,请检查网络"); | 
|---|
|  |  |  | } | 
|---|
|  |  |  | } | 
|---|
|  |  |  | } | 
|---|
|  |  |  | 
|---|
|  |  |  | @Override | 
|---|
|  |  |  | public void onSocketDisconnect(SocketAddress socketAddress, boolean isNeedReconnect) { | 
|---|
|  |  |  | Log.i("SocketActionListener", "---> socket断开连接,是否需要重连:" + isNeedReconnect); | 
|---|
|  |  |  |  | 
|---|
|  |  |  | MyApplication.myApplication.isConncet = false; | 
|---|
|  |  |  | rushState(); | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|
|  |  |  | /** | 
|---|
|  |  |  | 
|---|
|  |  |  | } | 
|---|
|  |  |  | }; | 
|---|
|  |  |  |  | 
|---|
|  |  |  | private void rushState() { | 
|---|
|  |  |  | try { | 
|---|
|  |  |  | if (HomeActivity.homeActivity != null) { | 
|---|
|  |  |  | HomeActivity.homeActivity.rushState(); | 
|---|
|  |  |  | } | 
|---|
|  |  |  | } catch (Exception e) { | 
|---|
|  |  |  | e.printStackTrace(); | 
|---|
|  |  |  | } | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|
|  |  |  | } | 
|---|