补卡相关

zuoxiao

2023-11-21 fc6048b630901058ccd90529e32e031e612b8384

 app/src/main/java/com/dayu/recharge/net/SocketNet.java

@@ -7,6 +7,7 @@

import com.dayu.recharge.dao.BaseDaoSingleton;
import com.dayu.recharge.dbBean.AdminDataBean;
import com.dayu.recharge.dbBean.DeviceNumber;
import com.dayu.recharge.dbBean.IpBean;
import com.easysocket.EasySocket;
import com.easysocket.entity.OriginReadData;
@@ -51,12 +52,12 @@
        isTest = false;
        // 发送
//        EasySocket.getInstance().upMessage(dataMessage);
        if (EasySocket.getInstance().getDefOptions().getSocketAddress() != null) {
        if (EasySocket.getInstance().getDefconnection() != null) {
            EasySocket.getInstance().disconnect(false);
            EasySocket.getInstance().connect();
            this.dataMessage = dataMessage;
        } else {
            LogUtil.w("Socket地址为空");
            MyApplication.myApplication.initEasySocket(false, null);
        }
    }

@@ -96,8 +97,8 @@
        @Override
        public void onSocketConnSuccess(SocketAddress socketAddress) {
            Log.i("SocketActionListener", "连接成功");
            String initCode = WSHelper.getInstance(MyApplication.myApplication).get("initCode", "");
            if (TextUtils.isEmpty(initCode) && !MyApplication.myApplication.isDoInitMachine) {
            DeviceNumber initCode = BaseDaoSingleton.getInstance(MyApplication.myApplication).deviceNumberDao().findFirst();
            if (initCode==null && !MyApplication.myApplication.isDoInitMachine) {
                new Handler().postDelayed(new Runnable() {
                    @Override
                    public void run() {
@@ -107,7 +108,7 @@
                            MyApplication.myApplication.initMachineRequestBean(ipBean.getIp(), ipBean.getPort(), adminData.getAddressCode());
                        }
                    }
                }, 2000);
                }, 500);

            }
            if (dataMessage != null) {
@@ -132,7 +133,7 @@
//            isConnected = false;
            Log.i("SocketActionListener", "socket连接失败");
            if (isTest) {
                ToastUtil.show(mContext, "连接失败,请检查网络");
//                ToastUtil.show(mContext, "连接失败,请检查网络");
            } else {
                if (myCallBack != null) {
                    myCallBack.onSocketError(-1, "socket连接失败,请检查网络");
@@ -170,7 +171,7 @@
            socketData.setBodyData(originReadData.getBodyBytes());
            socketData.setHeaderData(originReadData.getHeaderData());
            dataMessage = null;
            if (myCallBack!=null){
            if (myCallBack != null) {
                myCallBack.onSocketResponse(socketData);
            }