From dbde6db5c2c91a8b00aa98166257783871706eb9 Mon Sep 17 00:00:00 2001
From: whycq <10027870+whycq@user.noreply.gitee.com>
Date: 星期一, 12 八月 2024 10:00:11 +0800
Subject: [PATCH] #

---
 app/src/main/java/com/example/agvcontroller/StartActivity.java |   41 ++++++++++++++++++++++++++++++++++-------
 1 files changed, 34 insertions(+), 7 deletions(-)

diff --git a/app/src/main/java/com/example/agvcontroller/StartActivity.java b/app/src/main/java/com/example/agvcontroller/StartActivity.java
index 0a37be5..6d9fef1 100644
--- a/app/src/main/java/com/example/agvcontroller/StartActivity.java
+++ b/app/src/main/java/com/example/agvcontroller/StartActivity.java
@@ -1,12 +1,17 @@
 package com.example.agvcontroller;
 
 import android.os.Bundle;
+import android.util.Log;
 
 import androidx.appcompat.app.AppCompatActivity;
 import androidx.recyclerview.widget.LinearLayoutManager;
 import androidx.recyclerview.widget.RecyclerView;
 
 import com.example.agvcontroller.socket.SocketManager;
+
+import org.greenrobot.eventbus.EventBus;
+import org.greenrobot.eventbus.Subscribe;
+import org.greenrobot.eventbus.ThreadMode;
 
 import java.util.ArrayList;
 import java.util.List;
@@ -22,19 +27,41 @@
         super.onCreate(savedInstanceState);
         setContentView(R.layout.activity_start);
 
-        socketManager = new SocketManager();
-        socketManager.startServer(8080);
-
         recyclerView = findViewById(R.id.recyclerView);
         recyclerView.setLayoutManager(new LinearLayoutManager(this));
 
         items = new ArrayList<>();
-        //items.add(new Item("192.168.4.188", "Item 1", "Description of Item 1"));
-        //items.add(new Item("192.168.4.61", "Item 2", "Description of Item 2"));
-        //items.add(new Item("192.168.4.233", "Item 3", "Description of Item 3"));
 
         adapter = new ItemAdapter(items);
         recyclerView.setAdapter(adapter);
-        adapter.addItem(new Item("AGV-3948", "192.168.4.188:56487", "Description of Item 1"));
+
+        EventBus.getDefault().register(this);
+
+        socketManager = new SocketManager();
+        socketManager.startServer(8080);
+    }
+
+    @Subscribe(threadMode = ThreadMode.MAIN)
+    public void onDeviceConnected(Item deviceAddress) {
+        Log.i("EventBus", "Received device connected: " + deviceAddress);
+        items.add(new Item("1",deviceAddress.getIp(),"3"));
+        if (items.size() > 0) {
+            for (Item item : items) {
+                Log.i("Item",item.getIp());
+            }
+        }
+        adapter.notifyDataSetChanged();
+    }
+
+    @Subscribe(threadMode = ThreadMode.MAIN)
+    public void onDeviceDisconnected(String deviceIp) {
+        Log.i("EventBus", "Received device disconnected: " + deviceIp);
+        for (int i = 0; i < items.size(); i++) {
+            if (items.get(i).getIp().equals(deviceIp)) {
+                items.remove(i);
+                break;
+            }
+        }
+        adapter.notifyDataSetChanged();
     }
 }
\ No newline at end of file

--
Gitblit v1.9.1