ft control smart screen

wugian
1 parent 4155c8d2
Showing 2 changed files with 301 additions and 113 deletions
gimiCinema/src/main/java/com/xgimi/gimicinema/activity/MainActivity.java
gimiCinema/src/main/java/com/xgimi/smartscreen/service/ConfigService.java
--- a/gimiCinema/src/main/java/com/xgimi/gimicinema/activity/MainActivity.java
View file @3376fc7
+++ b/gimiCinema/src/main/java/com/xgimi/gimicinema/activity/MainActivity.java
View file @3376fc7
@@ -29,6 +29,8 @@ import android.graphics.Point;
 import android.graphics.Rect;
 import android.os.Bundle;
 import android.os.Handler;
+import android.os.Looper;
+import android.os.Message;
 import android.support.v7.widget.GridLayoutManager;
 import android.support.v7.widget.RecyclerView;
 import android.text.TextUtils;
@@ -63,6 +65,7 @@ import com.gimi.common.cinema.utils.M1905Utils;
 import com.gimi.common.cinema.utils.OpenMMUtils;
 import com.gimi.common.cinema.utils.ScreenUtils;
 import com.gimi.common.cinema.utils.SystemUtils;
+import com.gimi.common.cinema.utils.Utils;
 import com.google.gson.Gson;
 import com.qnbar.smc.model.Light;
 import com.qnbar.smc.model.Lights;
@@ -94,10 +97,20 @@ import com.xgimi.gimicinema.presenter.MainPresenter;
 import com.xgimi.gimicinema.view.ClazzItem;
 import com.xgimi.gimicinema.view.MovieItem;
 import com.xgimi.gimicinema.view.OrderRecyclerView;
+import com.xgimi.smartscreen.SmartScreenBean;
+import com.xgimi.smartscreen.service.ConfigService;
 import org.greenrobot.eventbus.EventBus;
 import org.greenrobot.eventbus.Subscribe;
 import org.greenrobot.eventbus.ThreadMode;
-
+import org.json.JSONException;
+import org.json.JSONObject;
+
+import java.io.BufferedReader;
+import java.io.IOException;
+import java.io.InputStreamReader;
+import java.io.PrintWriter;
+import java.net.Socket;
+import java.net.SocketTimeoutException;
 import java.text.SimpleDateFormat;
 import java.util.ArrayList;
 import java.util.Date;
@@ -161,10 +174,11 @@ public class MainActivity extends BaseActivity implements IMainView, EventListen
         mApplication.doInit();
         setContentView(R.layout.a_main);
         EventBus.getDefault().register(this);
+        context = this;
         initLight();
         initLock();
-        context = this;
+        initScreen();
         mData = new ArrayList<>();
         clazzData = new ArrayList<>();
         screenPoint = ScreenUtils.getScreenParam(context);
@@ -218,6 +232,105 @@ public class MainActivity extends BaseActivity implements IMainView, EventListen
         startService(intent);
     }
+    @Override
+    protected void onStart() {
+        super.onStart();
+        Log.d(TAG, "onStart");
+        int result = BuildUtils.assetSdkVersion("4.4");
+        Log.d(TAG, " Version : " + result);
+
+        // 监听各种事件
+        mApplication.addEventListener(DeviceEvent.STATUS_CHANGED, this);
+        mApplication.addEventListener(NotificationEvent.ONLINE_STATUS, this);
+        mApplication.addEventListener(ServiceEvent.SERVICE_CONNECTED, this);
+        mApplication.addEventListener(MeshEvent.OFFLINE, this);
+        mApplication.addEventListener(MeshEvent.ERROR, this);
+        new Handler().postDelayed(new Runnable() {
+            @Override
+            public void run() {
+                MainActivity.this.autoConnect();
+            }
+        }, 3 * 1000);
+    }
+
+    @Override
+    protected void onResume() {
+        super.onResume();
+        presenter.checkAuth();
+        if (mData != null) {
+            if (mData.size() == 0) {
+                presenter.loadRecommend(context);
+            }
+        }
+        if (HAS_SYSTEM_FEATURE_BLUETOOTH_LE) {
+            IntentFilter intentFilter = new IntentFilter();
+            intentFilter.addAction(BLEBroadcastReceiver.ACTION_BLE_ERROR);
+            intentFilter.addAction(BLEBroadcastReceiver.ACTION_SHAKING_BLE_ERROR);
+            intentFilter.addAction(BLEBroadcastReceiver.ACTION_WRITTEN_SUCCESS);
+            registerReceiver(bleBroadcastReceiver, intentFilter);
+        }
+        if (!LeBluetooth.getInstance().isSupport(getApplicationContext())) {
+            Toast.makeText(this, "ble not support", Toast.LENGTH_SHORT).show();
+            finish();
+            return;
+        }
+
+        if (!LeBluetooth.getInstance().isEnabled()) {
+//            AlertDialog.Builder builder = new AlertDialog.Builder(this);
+//            builder.setMessage("开启蓝牙，体验智能灯!");
+//            builder.setNeutralButton("cancel", new DialogInterface.OnClickListener() {
+//                @Override
+//                public void onClick(DialogInterface dialog, int which) {
+//                    finish();
+//                }
+//            });
+//            builder.setNegativeButton("enable", new DialogInterface.OnClickListener() {
+//                @Override
+//                public void onClick(DialogInterface dialog, int which) {
+            LeBluetooth.getInstance().enable(getApplicationContext());
+            Log.d(TAG, "开启蓝牙，体验智能灯!");
+//                }
+//            });
+//            builder.show();
+        }
+
+        DeviceInfo deviceInfo = mApplication.getConnectDevice();
+
+        if (deviceInfo != null) {
+            connectMeshAddress = mApplication.getConnectDevice().meshAddress & 0xFF;
+        } else {
+            autoConnect();
+        }
+        if (findCount++ < 5) {
+            if (!findHub || !findSwitch) {
+                initSwitch();
+                Log.d(TAG, "re init switch");
+            }
+        } else {
+            Log.d(TAG, "find switch more than 5 times ,there may not exist right switch");
+        }
+
+
+        Log.d(TAG, "onResume");
+    }
+
+    @Override
+    protected void onPause() {
+        super.onPause();
+        isSearching = false;
+        if (HAS_SYSTEM_FEATURE_BLUETOOTH_LE) {
+            unregisterReceiver(bleBroadcastReceiver);
+        }
+    }
+
+    @Override
+    protected void onDestroy() {
+        super.onDestroy();
+        presenter.umountSamba();
+        unregisterReceiver(mReceiver);
+        EventBus.getDefault().unregister(this);
+    }
+
     @Override
     public void loadCtrlImg(Bitmap bitmap) {
@@ -351,67 +464,6 @@ public class MainActivity extends BaseActivity implements IMainView, EventListen
     }
-    @Override
-    protected void onResume() {
-        super.onResume();
-        presenter.checkAuth();
-        if (mData != null) {
-            if (mData.size() == 0) {
-                presenter.loadRecommend(context);
-            }
-        }
-        if (HAS_SYSTEM_FEATURE_BLUETOOTH_LE) {
-            IntentFilter intentFilter = new IntentFilter();
-            intentFilter.addAction(BLEBroadcastReceiver.ACTION_BLE_ERROR);
-            intentFilter.addAction(BLEBroadcastReceiver.ACTION_SHAKING_BLE_ERROR);
-            intentFilter.addAction(BLEBroadcastReceiver.ACTION_WRITTEN_SUCCESS);
-            registerReceiver(bleBroadcastReceiver, intentFilter);
-        }
-        if (!LeBluetooth.getInstance().isSupport(getApplicationContext())) {
-            Toast.makeText(this, "ble not support", Toast.LENGTH_SHORT).show();
-            finish();
-            return;
-        }
-
-        if (!LeBluetooth.getInstance().isEnabled()) {
-//            AlertDialog.Builder builder = new AlertDialog.Builder(this);
-//            builder.setMessage("开启蓝牙，体验智能灯!");
-//            builder.setNeutralButton("cancel", new DialogInterface.OnClickListener() {
-//                @Override
-//                public void onClick(DialogInterface dialog, int which) {
-//                    finish();
-//                }
-//            });
-//            builder.setNegativeButton("enable", new DialogInterface.OnClickListener() {
-//                @Override
-//                public void onClick(DialogInterface dialog, int which) {
-            LeBluetooth.getInstance().enable(getApplicationContext());
-            Log.d(TAG, "开启蓝牙，体验智能灯!");
-//                }
-//            });
-//            builder.show();
-        }
-
-        DeviceInfo deviceInfo = mApplication.getConnectDevice();
-
-        if (deviceInfo != null) {
-            connectMeshAddress = mApplication.getConnectDevice().meshAddress & 0xFF;
-        } else {
-            autoConnect();
-        }
-        if (findCount++ < 5) {
-            if (!findHub || !findSwitch) {
-                initSwitch();
-                Log.d(TAG, "re init switch");
-            }
-        } else {
-            Log.d(TAG, "find switch more than 5 times ,there may not exist right switch");
-        }
-
-
-        Log.d(TAG, "onResume");
-    }
-
     int findCount = 0;
     @Override
@@ -431,14 +483,6 @@ public class MainActivity extends BaseActivity implements IMainView, EventListen
         return super.onKeyDown(keyCode, event);
     }
-    @Override
-    protected void onPause() {
-        super.onPause();
-        if (HAS_SYSTEM_FEATURE_BLUETOOTH_LE) {
-            unregisterReceiver(bleBroadcastReceiver);
-        }
-    }
-
     private class MovieListAdapter
             extends RecyclerView.Adapter<MovieListAdapter.MovieListViewHolder>
@@ -621,17 +665,8 @@ public class MainActivity extends BaseActivity implements IMainView, EventListen
         presenter.jumpToSearch();
     }
-    @Override
-    protected void onDestroy() {
-        super.onDestroy();
-        presenter.umountSamba();
-        unregisterReceiver(mReceiver);
-        EventBus.getDefault().unregister(this);
-    }
-
     //lock
-    private String openCMD = "Open the door";
 //    private String onClickDeviceMac;
     private boolean HAS_SYSTEM_FEATURE_BLUETOOTH_LE = true;
@@ -671,27 +706,6 @@ public class MainActivity extends BaseActivity implements IMainView, EventListen
         GREENBLE.send(this, "DC:F6:70:C1:AA:D6", openCMD.getBytes());*/
     }
-    @Override
-    protected void onStart() {
-        super.onStart();
-        Log.d(TAG, "onStart");
-        int result = BuildUtils.assetSdkVersion("4.4");
-        Log.d(TAG, " Version : " + result);
-
-        // 监听各种事件
-        mApplication.addEventListener(DeviceEvent.STATUS_CHANGED, this);
-        mApplication.addEventListener(NotificationEvent.ONLINE_STATUS, this);
-        mApplication.addEventListener(ServiceEvent.SERVICE_CONNECTED, this);
-        mApplication.addEventListener(MeshEvent.OFFLINE, this);
-        mApplication.addEventListener(MeshEvent.ERROR, this);
-        new Handler().postDelayed(new Runnable() {
-            @Override
-            public void run() {
-                MainActivity.this.autoConnect();
-            }
-        }, 3 * 1000);
-    }
-
     //lights
     private FangTangApplication mApplication;
@@ -878,6 +892,9 @@ public class MainActivity extends BaseActivity implements IMainView, EventListen
         switch (messageEvent.getEventId()) {
             case OPEN_DOOR_CMD:
                 openDoor();
+                if (rightSn) {
+                    down();
+                }
                 Log.d("event bus", messageEvent.getMessage());
                 Log.d("event bus", "open door");
 //                MessageEvent msgEvent = new MessageEvent();
@@ -944,6 +961,7 @@ public class MainActivity extends BaseActivity implements IMainView, EventListen
             }
         });
+        String openCMD = "Open the door";
         GREENBLE.send(this, "DC:F6:70:C1:AA:D6", openCMD.getBytes());
         List<LocalMovieMessage> localMovieMessages = new NewDBManager(this).queryRandomMovies();
         if (localMovieMessages != null && localMovieMessages.size() > 0) {
@@ -1003,4 +1021,171 @@ public class MainActivity extends BaseActivity implements IMainView, EventListen
         }
     }
     //---------------------------about switch-----------------------------------
+
+    //---------------------------about screen-----------------------------------
+    private boolean rightSn = false;
+    private boolean isSearching = false;
+    private String mDeviceIp = "";
+    private MessageThread messageThread;
+    private static final int PORT = 8009;
+    List<String> listData = new ArrayList<>();
+
+    void initScreen() {
+        startService(new Intent(this, ConfigService.class));
+        mDeviceIp = Utils.getString(context, "screen-ip");
+        if (TextUtils.isEmpty(mDeviceIp)) {
+            show("没有配置智能幕布");
+            return;
+        }
+        messageThread = new MessageThread();
+
+        new Thread(messageThread).start();
+
+        new Handler().postDelayed(new Runnable() {
+            public void run() {
+                getDeviceInfo(null);
+            }
+        }, 1000);
+    }
+
+    private void getDeviceInfo(String ip) {
+        if (!TextUtils.isEmpty(ip)) {
+            mDeviceIp = ip;
+        }
+        JSONObject dataGetInfo = new JSONObject();
+        try {
+            dataGetInfo.put("cmd", 1);
+        } catch (JSONException e) {
+            e.printStackTrace();
+        }
+
+        sendMsg(0x345, dataGetInfo);
+    }
+
+    private void sendMsg(int msgId, Object msg) {
+        Message msgGetInfo = new Message();
+        msgGetInfo.what = msgId;
+        msgGetInfo.obj = msg;
+        messageThread.sendHandler.sendMessage(msgGetInfo);
+    }
+
+    Handler handler = new Handler() {
+        @Override
+        public void handleMessage(Message msg) {
+            super.handleMessage(msg);
+
+            if (msg.what == 0x123) {
+                String data = (msg.obj).toString();
+                try {
+                    JSONObject jsonObject = new JSONObject(data);
+                    int cmd = jsonObject.getInt("cmd");
+                    if (cmd == 1) {
+                        int sn = jsonObject.getInt("sn");
+                        if (sn == Utils.getInt(context, "screen-sn", -1)) {
+                            rightSn = true;
+                            Log.d(TAG, "rightSn:" + rightSn);
+                        }
+                    }
+                } catch (JSONException e) {
+                    e.printStackTrace();
+                }
+            }
+        }
+    };
+
+
+    public class MessageThread implements Runnable {
+        //接收UI线程消息的Handler对象
+        public Handler sendHandler;
+
+        private Socket socket;
+        BufferedReader br = null;
+        PrintWriter pw = null;
+
+        @Override
+        public void run() {
+
+            try {
+                socket = new Socket(mDeviceIp, PORT);
+                br = new BufferedReader(new InputStreamReader(socket.getInputStream()));
+                pw = new PrintWriter(socket.getOutputStream());
+
+                //启动一个线程来读取数据
+                new Thread(new Runnable() {
+                    @Override
+                    public void run() {
+
+                        String data = null;
+
+                        try {
+                            while ((data = br.readLine()) != null) {
+                                Log.i(TAG, "接收到的数据：" + data);
+
+                                Message msg = new Message();
+                                msg.what = 0x123;
+                                msg.obj = data;
+                                handler.sendMessage(msg);
+                            }
+
+                        } catch (IOException e) {
+                            Log.i(TAG, "接收数据异常:" + e.getMessage());
+                            e.printStackTrace();
+                        }
+
+                    }
+                }).start();
+
+                Looper.prepare();
+                sendHandler = new Handler() {
+                    @Override
+                    public void handleMessage(Message msg) {
+                        super.handleMessage(msg);
+
+                        if (msg.what == 0x345) {
+                            Log.i(TAG, "写数据：" + (msg.obj).toString());
+                            pw.write((msg.obj).toString());
+//                            pw.write("{\"cmd\":2,\"action\":0}");
+                            pw.flush();
+                        }
+                    }
+                };
+                //启动Looper
+                Looper.loop();
+
+            } catch (SocketTimeoutException e) {
+                Log.i(TAG, "网络连接超时！");
+            } catch (IOException e) {
+                e.printStackTrace();
+            } finally {
+                try {
+                    if (pw != null) {
+                        pw.close();
+                    }
+                    if (br != null) {
+                        br.close();
+                    }
+                    if (socket != null) {
+                        socket.close();
+                    }
+                } catch (IOException e) {
+                    e.printStackTrace();
+                }
+            }
+        }
+    }
+
+    public void down() {
+        MessageEvent msgEvent = new MessageEvent();
+        msgEvent.setEventId(SmartScreenBean.DOWNACTION);
+        msgEvent.setMessage(mDeviceIp);
+        EventBus.getDefault().post(msgEvent);
+    }
+
+    public void up() {
+        MessageEvent msgEvent = new MessageEvent();
+        msgEvent.setEventId(SmartScreenBean.UPACTION);
+        msgEvent.setMessage(mDeviceIp);
+        EventBus.getDefault().post(msgEvent);
+    }
+    //---------------------------about screen-----------------------------------
 }
--- a/gimiCinema/src/main/java/com/xgimi/smartscreen/service/ConfigService.java
View file @3376fc7
+++ b/gimiCinema/src/main/java/com/xgimi/smartscreen/service/ConfigService.java
View file @3376fc7
@@ -14,7 +14,6 @@ import android.text.TextUtils;
 import android.util.Log;
 import android.widget.Toast;
 import com.gimi.common.cinema.model.MessageEvent;
-import com.google.gson.Gson;
 import com.xgimi.smartscreen.SmartScreenBean;
 import com.xgimi.smartscreen.confignetwork.ChTask;
 import com.xgimi.smartscreen.confignetwork.IChListener;
@@ -101,7 +100,7 @@ public class ConfigService extends Service {
             getNetStat();
         }
-        String action = intent.getAction();
+      /*  String action = intent.getAction();
         if ("com.xgimi.smartscreen.ACTION.CONTROL".equals(action)) {
             state = intent.getIntExtra("CONTROL", -1);
             String ip = intent.getStringExtra("CONTROLIP");
@@ -115,7 +114,7 @@ public class ConfigService extends Service {
             XgimiSettingsSP.putString(ConfigService.this, "BINDINFO", bindInfo);
             Intent notifyIntent = new Intent("com.xgimi.smartscreen.ACTION.DEVICEBIND");
             sendBroadcast(notifyIntent);
-        }/*else if("com.xgimi.smartscreen.ACTION.POWEROFF".equals(action)){
+        }*//*else if("com.xgimi.smartscreen.ACTION.POWEROFF".equals(action)){
             state = SmartScreenBean.UPACTION;
             hasTask = true;
             String bindInfo = XgimiSettingsSP.getString(ConfigService.this,"BINDINFO");
@@ -230,9 +229,13 @@ public class ConfigService extends Service {
                     if (cmd == 2) {
                         int result = jsonObject.getInt("result");
                         if (result == 1) { //成功
+                            Toast.makeText(ConfigService.this, "操作成功", Toast.LENGTH_SHORT).show();
                             Log.e(TAG, "操作成功");
-                        } else if (result == 0) {  //失败
-                            Log.e(TAG, "操作失败");
+                        } else {
+                            if (result == 0) {  //失败
+                                Toast.makeText(ConfigService.this, "操作失败", Toast.LENGTH_SHORT).show();
+                                Log.e(TAG, "操作失败");
+                            }
                         }
                     }
                 } catch (JSONException e) {
@@ -461,19 +464,19 @@ public class ConfigService extends Service {
                 smartScreenBean.ip = s;
                 smartScreenBean.name = "极米智能幕布";
                 smartScreenBean.state = 0;
-                String bindInfo = new Gson().toJson(smartScreenBean, SmartScreenBean.class);
-                XgimiSettingsSP.putString(ConfigService.this, "BINDINFO", bindInfo);
-                Intent notifyIntent = new Intent("com.xgimi.smartscreen.ACTION.DEVICEBIND");
-                sendBroadcast(notifyIntent);
+//                String bindInfo = new Gson().toJson(smartScreenBean, SmartScreenBean.class);
+//                XgimiSettingsSP.putString(ConfigService.this, "BINDINFO", bindInfo);
+//                Intent notifyIntent = new Intent("com.xgimi.smartscreen.ACTION.DEVICEBIND");
+//                sendBroadcast(notifyIntent);
                 if (hasTask) {
                     Control(s, state);
                     hasTask = false;
                 }
             } else {
                 Log.e(TAG, "没有发现设备！");
-                XgimiSettingsSP.putString(ConfigService.this, "BINDINFO", "");
-                Intent notifyIntent = new Intent("com.xgimi.smartscreen.ACTION.NODEVICE");
-                sendBroadcast(notifyIntent);
+//                XgimiSettingsSP.putString(ConfigService.this, "BINDINFO", "");
+//                Intent notifyIntent = new Intent("com.xgimi.smartscreen.ACTION.NODEVICE");
+//                sendBroadcast(notifyIntent);
             }
         }
     }