From 5b602b536c5be89b2cbfd211025236fb41ba2fa3 Mon Sep 17 00:00:00 2001
From: zuoxiao <470321431@qq.com>
Date: 星期一, 18 十二月 2023 17:46:00 +0800
Subject: [PATCH] 充值记录分页加载 补卡用户列表分页加载 通信模块添加日志方便分析长时间链接后不能通讯问题

---
 app/src/main/java/com/dayu/recharge/net/SocketNet.java |   56 +++++++++++++++++++++++++++++---------------------------
 1 files changed, 29 insertions(+), 27 deletions(-)

diff --git a/app/src/main/java/com/dayu/recharge/net/SocketNet.java b/app/src/main/java/com/dayu/recharge/net/SocketNet.java
index dd42aa1..9783701 100644
--- a/app/src/main/java/com/dayu/recharge/net/SocketNet.java
+++ b/app/src/main/java/com/dayu/recharge/net/SocketNet.java
@@ -2,6 +2,7 @@
 
 import android.content.Context;
 import android.os.Handler;
+import android.text.TextUtils;
 import android.util.Log;
 
 import com.dayu.recharge.activity.HomeActivity;
@@ -10,11 +11,13 @@
 import com.dayu.recharge.dbBean.DeviceNumber;
 import com.dayu.recharge.dbBean.IpBean;
 import com.easysocket.EasySocket;
+import com.easysocket.connection.action.SocketStatus;
 import com.easysocket.entity.OriginReadData;
 import com.easysocket.entity.SocketAddress;
 import com.easysocket.interfaces.conn.ISocketActionListener;
 import com.easysocket.interfaces.conn.SocketActionListener;
 import com.dayu.recharge.MyApplication;
+import com.easysocket.utils.HexUtil;
 
 
 /**
@@ -52,7 +55,12 @@
         if (EasySocket.getInstance().getDefconnection() != null) {
 //            EasySocket.getInstance().disconnect(false);
 //            EasySocket.getInstance().connect();
+//            if (EasySocket.getInstance().getDefconnection().getConnectionStatus()== SocketStatus.SOCKET_CONNECTED){
             EasySocket.getInstance().upMessage(dataMessage);
+//            }else {
+//
+//            }
+
 //            this.dataMessage = dataMessage;
         } else {
             MyApplication.myApplication.initEasySocket(false, null);
@@ -94,28 +102,22 @@
          */
         @Override
         public void onSocketConnSuccess(SocketAddress socketAddress) {
-            Log.i("SocketActionListener", "杩炴帴鎴愬姛");
+            Log.i("SocketActionListener1111", "杩炴帴鎴愬姛");
             MyApplication.myApplication.isConncet = true;
-            rushState();
-            DeviceNumber initCode = BaseDaoSingleton.getInstance(MyApplication.myApplication).deviceNumberDao().findFirst();
-            if (initCode == null && !MyApplication.myApplication.isDoInitMachine) {
-                new Handler().postDelayed(new Runnable() {
-                    @Override
-                    public void run() {
+            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());
 
-                        AdminDataBean adminData = BaseDaoSingleton.getInstance(MyApplication.myApplication).adminDao().findFirst();
-                        if (MyApplication.myApplication.ipBean != null && adminData != null) {
-                            MyApplication.myApplication.initMachineRequestBean(MyApplication.myApplication.ipBean.getIp(), MyApplication.myApplication.ipBean.getPort(), adminData.getAddressCode());
-                        }
                     }
-                }, 500);
+                }
 
             }
-//            if (dataMessage != null) {
-//                EasySocket.getInstance().upMessage(dataMessage);
-//            }
-
-
+            rushState();
         }
 
         /**
@@ -149,21 +151,17 @@
             rushState();
         }
 
+
+
         /**
          * socket鎺ユ敹鐨勬暟鎹�
          * @param socketAddress
-         * @param readData
+         * @param originReadData
          */
-        @Override
-        public void onSocketResponse(SocketAddress socketAddress, String readData) {
-            Log.i("SocketActionListener", "SocketActionListener鏀跺埌鏁版嵁-->" + readData);
-
-        }
-
         @Override
         public void onSocketResponse(SocketAddress socketAddress, OriginReadData originReadData) {
             super.onSocketResponse(socketAddress, originReadData);
-            Log.i("SocketActionListener", "SocketActionListener鏀跺埌鏁版嵁-->" + originReadData.getBodyString());
+            Log.i("SocketActionListener", "SocketActionListener鏀跺埌鏁版嵁-->" + HexUtil.bytesToHex(originReadData.getBodyBytes()));
             SocketData socketData = new SocketData();
             socketData.setBodyData(originReadData.getBodyBytes());
             socketData.setHeaderData(originReadData.getHeaderData());
@@ -176,8 +174,12 @@
     };
 
     private void rushState() {
-        if (HomeActivity.homeActivity != null) {
-            HomeActivity.homeActivity.rushState();
+        try {
+            if (HomeActivity.homeActivity != null) {
+                HomeActivity.homeActivity.rushState();
+            }
+        } catch (Exception e) {
+            e.printStackTrace();
         }
     }
 

--
Gitblit v1.8.0