投影控制

 package com.qnbar.smc.service;
 
+import android.content.ComponentName;
 import android.content.Context;
 import android.content.Intent;
+import android.content.ServiceConnection;
+import android.media.AudioManager;
 import android.os.Handler;
 import android.os.IBinder;
+import android.os.RemoteException;
 import android.text.TextUtils;
 import android.util.Log;
 import android.widget.Toast;
 import com.gimi.common.cinema.model.MessageEvent;
 import com.gimi.common.cinema.model.RoomInfo;
 import com.gimi.common.cinema.utils.ActivityCollector;
+import com.gimi.common.cinema.utils.ShellUtils;
 import com.gimi.common.cinema.utils.SystemUtils;
 import com.gimi.common.cinema.utils.Utils;
 import com.google.gson.Gson;
 import com.google.gson.JsonSyntaxException;
+import com.qnbar.smc.model.Lights;
+import com.qnbar.smc.soketProtocol.fromServer.EquipmentControl;
+import com.qnbar.smc.soketProtocol.toServer.EquipmentStatus;
+import com.qnbar.smc.soketProtocol.MainRequest;
+import com.qnbar.smc.soketProtocol.MainResponse;
+import com.qnbar.smc.soketProtocol.fromServer.OpenDoor;
+import com.qnbar.smc.soketProtocol.fromServer.ReportEquStatus;
 import com.qnbar.smc.utils.LightOperationUtils;
+import com.telink.bluetooth.light.ConnectionStatus;
+import com.xgimi.gimicinema.ICinemaControl;
 import com.xgimi.gimicinema.activity.MainActivity;
 import com.xgimi.gimicinema.activity.QrCodeShowActivity;
 import com.xgimi.gimicinema.application.FangTangApplication;
+import com.xgimi.gimicinema.service.CinemaControlService;
 import com.xgimi.smartscreen.encrypt.AuthCode;
 import org.greenrobot.eventbus.EventBus;
 
@@ -65,11 +80,15 @@ public class SocketService1 extends BaseService {
     private static final int ROOM_SN_CONNECTED = 10010;//room_sn 已连接,不能再连接
     private static final int OPEN_DOOR = 50001;//开门命令
     private static final int CLEAN_OVER = 50002;//
+    private static final int REPORT_EQU_STATUS = 50003;//返回设备状态信息
+    private static final int SET_EQU_STATUS = 50004;//返回设备状态信息
 
     private static final int ROOM_HAS_REGISTERED = 1001;
     private static final int ROOM_NOT_EXIST_M = 1002;
     private static final int HEAT_BEAT_RTN = 1003;
 
+    private static final int CMD_REPORT_EQU_STATUS = 20030;//上报设备状态信息
+
     //    online
     public static final String SERVER_HOST_ONLINE = "conn.ft.qnbar.com";// "192.168.1.21";//
     public static final int SERVER_PORT_ONLINE = 8899;
@@ -91,6 +110,7 @@ public class SocketService1 extends BaseService {
 
     private ReadThread mReadThread;
     private Gson gson;
+    ICinemaControl iPlayer;
 
     private WeakReference<Socket> mSocket;
     // For heart Beat
@@ -141,6 +161,9 @@ public class SocketService1 extends BaseService {
         gson = new Gson();
         context = this;
         Log.d(TAG, "onCreate");
+
+        bindService(new Intent(SocketService1.this, CinemaControlService.class), conn, Context.BIND_AUTO_CREATE);
+        startService(new Intent(SocketService1.this, CinemaControlService.class));
     }
 
     @Override
@@ -295,7 +318,8 @@ public class SocketService1 extends BaseService {
                                 if (message.endsWith(END_SYMBOL)) {
                                     message = message.replace(END_SYMBOL, "");
                                 }
-                                SocketResponse socketResponse = gson.fromJson(message, SocketResponse.class);
+//                                SocketResponse socketResponse = gson.fromJson(message, SocketResponse.class);
+                                MainResponse socketResponse = gson.fromJson(message, MainResponse.class);
                                 switch (socketResponse.getCode()) {
                                     case SUCCESS_MESSAGE:
                                         Log.d(TAG, "SUCCESS_MESSAGE");
@@ -336,55 +360,20 @@ public class SocketService1 extends BaseService {
                                         break;
                                     case RETURN_VERIFY_CODE:
                                         Log.d(TAG, "RETURN_VERIFY_CODE");
-                                        if (!TextUtils.isEmpty(socketResponse.getData().getVerify())) {
-                                            String verifyMsg = AuthCode.getDecodeStr(socketResponse.getData().getVerify());
-                                            SocketSendMsg ssm = new SocketSendMsg().contractVerifyMsg(testRoomSn, verifyMsg);
-                                            String msg = gson.toJson(ssm) + END_SYMBOL;
-                                            sendMsg(msg);
+                                        if (!TextUtils.isEmpty(socketResponse.getData())) {
+                                            OpenDoor openDoorResponse = gson.fromJson(socketResponse.getData(), OpenDoor.class);
+
+                                            if (!TextUtils.isEmpty(openDoorResponse.getVerify())) {
+                                                String verifyMsg = AuthCode.getDecodeStr(openDoorResponse.getVerify());
+                                                SocketSendMsg ssm = new SocketSendMsg().contractVerifyMsg(testRoomSn, verifyMsg);
+                                                String msg = gson.toJson(ssm) + END_SYMBOL;
+                                                sendMsg(msg);
+                                            }
                                         }
                                         break;
                                     case CONTAIN_MESSAGE:
                                         Log.d(TAG, "CONTAIN_MESSAGE");
-                                        if (socketResponse.getData() != null) {
-                                            if (socketResponse.getCmd() == OPEN_DOOR) {
-                                                switch (socketResponse.getData().getUser()) {
-                                                    //10用户,20管理员,默认值为0
-                                                    case 10:
-                                                        new SystemUtils().openFtLed(context.getApplicationContext());
-                                                        if (TextUtils.isEmpty(((FangTangApplication) getApplication()).getCurrentPlayUrl())) {
-                                                            LightOperationUtils.open();
-                                                            LightOperationUtils.setLightValue(Utils.getInt(context, "brightness", 50));
-                                                        }
-                                                        sendMessage(QrCodeShowActivity.KILL_SELF, "finish the QR CODE activity when new user come in");
-                                                        if (socketResponse.getData().getFirst() == 1) {
-                                                            sendMessage(USER_OPEN_DOOR_AND_GET_MOVIE, "user first open the door");
-                                                        } else {
-                                                            sendMessage(USER_OPEN_DOOR, "user open the door");
-                                                        }
-                                                        break;
-                                                    case 20:
-                                                        if (TextUtils.isEmpty(((FangTangApplication) getApplication()).getCurrentPlayUrl())) {
-                                                            Log.d("LightOperationUtils", "admin open light");
-                                                            LightOperationUtils.open();
-                                                            LightOperationUtils.setLightValue(Utils.getInt(context, "brightness", 50));
-                                                        }
-                                                        sendMessage(JUST_OPEN_DOOR, "administrator open the door");
-                                                        break;
-                                                    case 0:
-                                                        sendMessage(JUST_OPEN_DOOR, "get zero none user or administrator open the door");
-                                                        break;
-                                                    default:
-                                                        sendMessage(JUST_OPEN_DOOR, "none user or administrator open the door");
-                                                        break;
-                                                }
-                                            } else if (socketResponse.getCmd() == CLEAN_OVER) {
-                                                Log.d("LightOperationUtils", "admin clean over close light");
-                                                LightOperationUtils.setLightValue(5);
-                                                LightOperationUtils.close();
-                                                new SystemUtils().closeFtLed(context.getApplicationContext());
-                                                sendMessage(QrCodeShowActivity.KILL_SELF, "finish the QR CODE activity when clean over");
-                                            }
-                                        }
+                                        serverCommandDeal(socketResponse);
                                         break;
                                     default:
                                         Log.d(TAG, "default msg:" + socketResponse.toString());
@@ -418,4 +407,231 @@ public class SocketService1 extends BaseService {
         Log.d(TAG, "socket service destroy");
         super.onDestroy();
     }
+
+    /**
+     * 处理服务器发送的命令
+     * @param socketResponse
+     */
+    private void serverCommandDeal(MainResponse socketResponse)
+    {
+        switch (socketResponse.getCmd())
+        {
+            case OPEN_DOOR://开门
+                if (socketResponse.getData() != null) {
+                    OpenDoor openDoorResponse = gson.fromJson(socketResponse.getData(), OpenDoor.class);
+                    openDoor(openDoorResponse);
+                }
+                break;
+            case CLEAN_OVER://清洁完成处理
+                Log.d("LightOperationUtils", "admin clean over close light");
+                LightOperationUtils.setLightValue(5);
+                LightOperationUtils.close();
+                new SystemUtils().closeFtLed(context.getApplicationContext());
+                sendMessage(QrCodeShowActivity.KILL_SELF, "finish the QR CODE activity when clean over");
+                break;
+
+            case REPORT_EQU_STATUS://获取声音,灯光,播放暂停状态
+                Log.d("ReportInfo","收到上报命令");
+                //获取serverId
+                ReportEquStatus rps = gson.fromJson(socketResponse.getData(), ReportEquStatus.class);
+//                String serverId = rps.getServerId();
+                reportEquStatus(rps.getServerId());
+                break;
+
+            case SET_EQU_STATUS://设置声音,灯光,播放暂停
+                Log.d("ReportInfo","收到控制命令:"+socketResponse.getData());
+                EquipmentControl equc = gson.fromJson(socketResponse.getData(), EquipmentControl.class);
+                setEquipmentStatus(equc);
+                break;
+        }
+    }
+
+/*--命令处理-start-----------------------------------*/
+
+    private void openDoor(OpenDoor openDoorResponse)
+    {
+        switch (openDoorResponse.getUser()) {
+            //10用户,20管理员,默认值为0
+            case 10:
+                new SystemUtils().openFtLed(context.getApplicationContext());
+                if (TextUtils.isEmpty(((FangTangApplication) getApplication()).getCurrentPlayUrl())) {
+                    LightOperationUtils.open();
+                    LightOperationUtils.setLightValue(Utils.getInt(context, "brightness", 50));
+                }
+                sendMessage(QrCodeShowActivity.KILL_SELF, "finish the QR CODE activity when new user come in");
+                if (openDoorResponse.getFirst() == 1) {
+                    sendMessage(USER_OPEN_DOOR_AND_GET_MOVIE, "user first open the door");
+                } else {
+                    sendMessage(USER_OPEN_DOOR, "user open the door");
+                }
+                break;
+            case 20:
+                if (TextUtils.isEmpty(((FangTangApplication) getApplication()).getCurrentPlayUrl())) {
+                    Log.d("LightOperationUtils", "admin open light");
+                    LightOperationUtils.open();
+                    LightOperationUtils.setLightValue(Utils.getInt(context, "brightness", 50));
+                }
+                sendMessage(JUST_OPEN_DOOR, "administrator open the door");
+                break;
+            case 0:
+                sendMessage(JUST_OPEN_DOOR, "get zero none user or administrator open the door");
+                break;
+            default:
+                sendMessage(JUST_OPEN_DOOR, "none user or administrator open the door");
+                break;
+        }
+    }
+
+    private void reportEquStatus(String serverId)
+    {
+        //填充返回数据
+        int volume = getAudioVolume()/6 + 1;
+        int lightStatus = 2;
+
+        int playStatus = 0;
+        try {
+            playStatus = iPlayer.getCurrentStatus();
+            Log.d("ReportInfo","playStatus:"+playStatus);
+        } catch (RemoteException e) {
+            e.printStackTrace();
+        }
+
+        if( Lights.getInstance().getByMeshAddress(
+                ((FangTangApplication) getApplication()).getConnectDevice().meshAddress).status == ConnectionStatus.ON )
+        {
+            lightStatus = 1;
+        }
+
+        EquipmentStatus equStatus = new EquipmentStatus();
+        equStatus.setLightStatus(lightStatus);
+        equStatus.setPlayStatus(playStatus);
+        equStatus.setVolume(volume);
+        equStatus.setServerId(serverId);
+        equStatus.setRoom_sn(testRoomSn);
+
+        MainRequest rep = new MainRequest();
+        rep.setCmd(CMD_REPORT_EQU_STATUS);
+        rep.setData(equStatus);
+        String msg = gson.toJson(rep) + END_SYMBOL;
+        sendMsg(msg);
+        Log.d("ReportInfo",msg);
+    }
+
+    private void setLight(int op)
+    {
+        if (op == 1)//打开灯光
+        {
+            Log.d("setEqu","打开灯光");
+            LightOperationUtils.open();
+            LightOperationUtils.setLightValue(Utils.getInt(context, "brightness", 50));
+        }
+        else if(op == 2)//关闭灯光
+        {
+            Log.d("setEqu","关闭灯光");
+            LightOperationUtils.setLightValue(5);
+            LightOperationUtils.close();
+        }
+    }
+
+    private void playCtl(int op)
+    {
+        int status = -1;
+        try {
+            status = iPlayer.getCurrentStatus();
+        } catch (RemoteException e) {
+            e.printStackTrace();
+        }
+
+        if (op == 1 && status == 2)
+        {
+            Log.d("setEqu","开始播放");
+            ShellUtils.execCommand("input keyevent 23", false);
+        }
+        else if (op == 2 && status == 1)
+        {
+            Log.d("setEqu","暂停播放");
+            ShellUtils.execCommand("input keyevent 23", false);
+        }
+
+        try {
+            status = iPlayer.getCurrentStatus();
+        } catch (RemoteException e) {
+            e.printStackTrace();
+        }
+    }
+
+    private void setEquipmentStatus(EquipmentControl equc)
+    {
+        setLight(equc.getLightCtl());
+
+        playCtl(equc.getPlayCtl());
+
+        setAudioVolume(equc.getAudioCtl());
+
+        reportEquStatus(equc.getServerId());
+
+    }
+
+/*--命令处理-end-----------------------------------*/
+
+    private int getAudioVolume()
+    {
+        AudioManager mAudioManager;
+        mAudioManager = (AudioManager) getSystemService(Context.AUDIO_SERVICE);
+        int current = mAudioManager.getStreamVolume( AudioManager.STREAM_MUSIC );
+        return current;
+    }
+
+    private int setAudioVolume(int volume)
+    {
+        AudioManager mAudioManager;
+        mAudioManager = (AudioManager) getSystemService(Context.AUDIO_SERVICE);
+        int now = getAudioVolume()/6;
+
+        if (volume == 0)
+        {
+            return now;
+        }
+        else
+        {
+            volume--;
+        }
+
+        if (volume > now)//加音量
+        {
+            Log.d("setEqu","加音量"+now+":"+volume);
+            while(now < volume)
+            {
+                mAudioManager.adjustStreamVolume(
+                        AudioManager.STREAM_MUSIC,
+                        AudioManager.ADJUST_RAISE,
+                        AudioManager.FLAG_PLAY_SOUND | AudioManager.FLAG_SHOW_UI);
+                now ++;
+            }
+        }
+        else if(volume < now)//减音量
+        {
+            Log.d("setEqu","减音量"+now+":"+volume);
+            while(now > volume)
+            {
+                mAudioManager.adjustStreamVolume(
+                        AudioManager.STREAM_MUSIC,
+                        AudioManager.ADJUST_LOWER,
+                        AudioManager.FLAG_PLAY_SOUND | AudioManager.FLAG_SHOW_UI);
+                now --;
+            }
+        }
+
+        return now;
+    }
+
+    private ServiceConnection conn = new ServiceConnection() {
+        public void onServiceConnected(ComponentName className, IBinder service) {
+            Log.i("yao", "ServiceConnection -> onServiceConnected");
+            iPlayer = ICinemaControl.Stub.asInterface(service);
+        }
+
+        public void onServiceDisconnected(ComponentName className) {
+        };
+    };
 }
\ No newline at end of file

+package com.qnbar.smc.soketProtocol;
+
+/**
+ * Created by jinyan.yi on 2017/5/23.
+ */
+
+public abstract class DataInfo {
+}

+package com.qnbar.smc.soketProtocol;
+
+/**
+ * Created by jinyan.yi on 2017/5/23.
+ */
+
+public class MainRequest {
+    private int cmd;
+    private DataInfo data;
+
+    public int getCmd() {
+        return cmd;
+    }
+
+    public void setCmd(int cmd) {
+        this.cmd = cmd;
+    }
+
+    public DataInfo getData() {
+        return data;
+    }
+
+    public void setData(DataInfo data) {
+        this.data = data;
+    }
+}

+package com.qnbar.smc.soketProtocol;
+
+/**
+ * Created by jinyan.yi on 2017/5/23.
+ */
+
+public class MainResponse {
+    private int code;
+    private String msg;
+    private String data;
+    private int cmd;
+
+    public int getCode() {
+        return code;
+    }
+
+    public void setCode(int code) {
+        this.code = code;
+    }
+
+    public String getMsg() {
+        return msg;
+    }
+
+    public void setMsg(String msg) {
+        this.msg = msg;
+    }
+
+    public String getData() {
+        return data;
+    }
+
+    public void setData(String data) {
+        this.data = data;
+    }
+
+    public int getCmd() {
+        return cmd;
+    }
+
+    public void setCmd(int cmd) {
+        this.cmd = cmd;
+    }
+
+    @Override
+    public String toString() {
+        return "MainResponse{" +
+                "code=" + code +
+                ", msg='" + msg + '\'' +
+                ", data='" + data + '\'' +
+                ", cmd=" + cmd +
+                '}';
+    }
+}

+package com.qnbar.smc.soketProtocol.fromServer;
+
+/**
+ * Created by jinyan.yi on 2017/5/23.
+ */
+
+public class EquipmentControl {
+    private int audioCtl;
+    private int playCtl;
+    private int lightCtl;
+    private String serverId;
+
+    public int getAudioCtl() {
+        return audioCtl;
+    }
+
+    public void setAudioCtl(int audioCtl) {
+        this.audioCtl = audioCtl;
+    }
+
+    public int getPlayCtl() {
+        return playCtl;
+    }
+
+    public void setPlayCtl(int playCtl) {
+        this.playCtl = playCtl;
+    }
+
+    public int getLightCtl() {
+        return lightCtl;
+    }
+
+    public void setLightCtl(int lightCtl) {
+        this.lightCtl = lightCtl;
+    }
+
+    public String getServerId() {
+        return serverId;
+    }
+
+    public void setServerId(String serverId) {
+        this.serverId = serverId;
+    }
+
+    @Override
+    public String toString() {
+        return "EquipmentControl{" +
+                "audioCtl=" + audioCtl +
+                ", playCtl=" + playCtl +
+                ", lightCtl=" + lightCtl +
+                ", serverId='" + serverId + '\'' +
+                '}';
+    }
+}

+package com.qnbar.smc.soketProtocol.fromServer;
+
+/**
+ * Created by jinyan.yi on 2017/5/23.
+ */
+
+public class OpenDoor {
+    private String verify;
+    private int user;
+    private int first;
+
+    public String getVerify() {
+        return verify;
+    }
+
+    public void setVerify(String verify) {
+        this.verify = verify;
+    }
+
+    public int getUser() {
+        return user;
+    }
+
+    public void setUser(int user) {
+        this.user = user;
+    }
+
+    public int getFirst() {
+        return first;
+    }
+
+    public void setFirst(int first) {
+        this.first = first;
+    }
+
+    @Override
+    public String toString() {
+        return "OpenDoor{" +
+                "verify='" + verify + '\'' +
+                ", user=" + user +
+                ", first=" + first +
+                '}';
+    }
+}

+package com.qnbar.smc.soketProtocol.fromServer;
+
+/**
+ * Created by jinyan.yi on 2017/5/23.
+ */
+
+public class ReportEquStatus {
+    private String serverId;
+
+    public String getServerId() {
+        return serverId;
+    }
+
+    public void setServerId(String serverId) {
+        this.serverId = serverId;
+    }
+}

+package com.qnbar.smc.soketProtocol.toServer;
+
+import com.qnbar.smc.soketProtocol.DataInfo;
+
+/**
+ * Created by jinyan.yi on 2017/5/23.
+ */
+
+public class EquipmentStatus extends DataInfo {
+    private int volume;
+    private int lightStatus;
+    private int playStatus;
+    private String serverId;
+    private String room_sn;
+
+    public int getVolume() {
+        return volume;
+    }
+
+    public void setVolume(int volume) {
+        this.volume = volume;
+    }
+
+    public int getLightStatus() {
+        return lightStatus;
+    }
+
+    public void setLightStatus(int lightStatus) {
+        this.lightStatus = lightStatus;
+    }
+
+    public int getPlayStatus() {
+        return playStatus;
+    }
+
+    public void setPlayStatus(int playStatus) {
+        this.playStatus = playStatus;
+    }
+
+    public String getServerId() {
+        return serverId;
+    }
+
+    public void setServerId(String serverId) {
+        this.serverId = serverId;
+    }
+
+    public String getRoom_sn() {
+        return room_sn;
+    }
+
+    public void setRoom_sn(String room_sn) {
+        this.room_sn = room_sn;
+    }
+}

@@ -74,15 +74,15 @@ public class CinemaControlService extends Service {
         public void setCurrentMoviePosition(long duration) throws RemoteException {
 //            Log.d("aidl", "setCurrentMoviePosition: " + duration);
             currentPosition = duration;
-            if (saveBeat-- <= 0) {
+            if (saveBeat-- == 0) {
                 //TODO 保存当前进度,需要时从保存位置开始播放,取消播放器播放记录功能
                 // 播放一段时间确保状态为关闭
-                saveBeat = SAVE_BEAT;
+//                saveBeat = SAVE_BEAT;
                 try {
                     if (!fadeOuting && Lights.getInstance().getByMeshAddress(
                             ((FangTangApplication) getApplication()).getConnectDevice().meshAddress).status
                             == ConnectionStatus.ON) {
-                        fadeOut();
+//                        fadeOut();
                     }
                 } catch (Exception e) {
                     e.printStackTrace();
@@ -129,7 +129,7 @@ public class CinemaControlService extends Service {
 //                        EventBus.getDefault().post(msgEvent);
                         break;
                     case 2://暂停
-                        fadeIn();
+//                        fadeIn();
 //                        msgEvent.setEventId(0x19910);
 //                        msgEvent.setMessage("open_switch");
 //                        EventBus.getDefault().post(msgEvent);