HDLSDK_A_Android
blame | 历史 | 补丁 | 提交 | 提交对比 | ignore whitespace
562935844@qq.com
2023-08-31 fdcf461fbfa3bcd650685743e891ad3357898f0c 
 HDLSDK/app/src/main/java/com/hdl/hdlsdk/MainActivity.java


@@ -1,5 +1,19 @@


package com.hdl.hdlsdk;




import android.Manifest;


import android.content.Context;


import android.content.Intent;


import android.content.pm.PackageInfo;


import android.content.pm.PackageManager;


import android.os.Build;


import android.os.Bundle;


import android.text.TextUtils;


import android.util.Log;


import android.view.View;


import android.widget.EditText;


import android.widget.TextView;


import android.widget.Toast;




import androidx.activity.result.ActivityResultCallback;


import androidx.activity.result.ActivityResultLauncher;


import androidx.activity.result.contract.ActivityResultContracts;


@@ -9,47 +23,33 @@


import androidx.recyclerview.widget.LinearLayoutManager;


import androidx.recyclerview.widget.RecyclerView;




import android.Manifest;


import android.content.Intent;


import android.os.Build;


import android.os.Bundle;


import android.text.TextUtils;


import android.util.Log;


import android.view.View;


import android.widget.TextView;


import android.widget.Toast;




import com.chad.library.adapter.base.BaseQuickAdapter;


import com.chad.library.adapter.base.listener.OnItemClickListener;


import com.google.gson.JsonObject;


import com.google.gson.reflect.TypeToken;


import com.hdl.hdlsdk.device.DevicesListActivity;


import com.hdl.sdk.common.config.TopicConstant;


import com.hdl.sdk.common.event.DeleteNetworkListener;


import com.hdl.sdk.common.event.EventListener;


import com.hdl.sdk.common.exception.HDLLinkException;


import com.hdl.sdk.common.utils.IdUtils;


import com.hdl.sdk.common.utils.IpUtils;


import com.hdl.sdk.common.utils.LogUtils;


import com.hdl.sdk.common.utils.gson.GsonConvert;


import com.hdl.sdk.connect.HDLLink;


import com.hdl.sdk.connect.bean.LinkRequest;


import com.hdl.sdk.connect.bean.LinkResponse;


import com.hdl.sdk.connect.bean.request.AuthenticateRequest;


import com.hdl.sdk.connect.bean.request.BroadcastRequest;


import com.hdl.sdk.connect.bean.request.PropertyReadRequest;


import com.hdl.sdk.connect.bean.request.DeviceControlRequest;


import com.hdl.sdk.connect.bean.request.ListUploadRequest;


import com.hdl.sdk.connect.bean.response.BaseLocalResponse;


import com.hdl.sdk.connect.bean.response.GatewaySearchBean;


import com.hdl.sdk.connect.bean.response.UpdateInfo;


import com.hdl.sdk.connect.callback.HDLLinkCallBack;


import com.hdl.sdk.connect.callback.HDLLinkResponseCallBack;


import com.hdl.sdk.connect.cloud.CallBackListener;


import com.hdl.sdk.connect.cloud.CheckAppVersionListener;


import com.hdl.sdk.connect.cloud.HDLException;


import com.hdl.sdk.connect.config.HDLLinkConfig;


import com.hdl.sdk.connect.socket.HDLAuthSocket;


import com.hdl.sdk.connect.socket.HDLSocket;


import com.hdl.sdk.connect.bean.request.DeviceControlRequest;


import com.hdl.sdk.connect.protocol.LinkMessageDecoder;


import com.hdl.sdk.connect.protocol.LinkMessageEncoder;


import com.hdl.sdk.socket.SocketOptions;


import com.hdl.sdk.socket.codec.MessagePipeLine;


import java.util.Base64;


import com.hdl.sdk.connect.utils.AesUtil;




import java.io.UnsupportedEncodingException;


import java.security.MessageDigest;


@@ -59,9 +59,6 @@


import java.util.List;


import java.util.Map;




import static com.hdl.sdk.common.config.TopicConstant.GATEWAY_SEARCH_REPLY;


import static java.util.Base64.*;




public class MainActivity extends AppCompatActivity {




    private static final String TAG = "MainActivity";


@@ -69,35 +66,132 @@


    private RecyclerView rv;


    private TextView tv;


    private TextView responseTv;


    private TextView localSecret;


    private EditText editText;


    boolean isOn;


    private EventListener allTopicsListener;


    private String testLightSid = "0001010D48C71B02020100010101";


    private String testLightSid = "02010131D9C03D01020300010107";


    private String secret = "";




    @Override


    protected void onDestroy() {


        super.onDestroy();


        removeAllTopicsListener();


    }


void init() {


//    HDLLinkConfig.getInstance().setLocalSecret("7d04c4e3c2b7d600");


//    HDLLinkConfig.getInstance().setGatewayId("1473119283609321473");


//    HDLLinkConfig.getInstance().setLocalEncrypt(true);


}


    @RequiresApi(api = Build.VERSION_CODES.O)




    void applyDeviceSecret() {


        tv.setText("开始申请设备密钥...");


        responseTv.setText("");




//        //正式服务器


        String appKey = "i8hR07jzrIS";//appkey


        String appSecret = "BmnJ8RWTtaVEBk24zPPF4UMwfYu0lAWU";//appsecret




        //测试服务器


//        String appKey ="FcRyUJlLJFF";


//        String appSecret = "wz8wn75ABidx8vXcFGUotqhwFkTaYvvJ";




//        String appKey = "L2OZliZRxHc";


//        String appSecret = "aCIWSvJDOukXfx3kivsKW11x9xdR3IbV";


        String supplier = "JINMAOYUN";//厂商


//        String mac = "AA00000000000100";//设备唯一MAC地址


        String mac = editText.getText().toString();


        String spk = "screen.touch";//产品spk




        if (TextUtils.isEmpty(mac)) {


            Toast.makeText(this, "mac不能为空！", Toast.LENGTH_SHORT).show();


            return;


        }




        HDLLink.getInstance().applyDeviceSecret(this, appKey, appSecret, supplier, mac, spk, new CallBackListener() {


            @Override


            public void onError(HDLException e) {


                tv.setText("申请失败");


                responseTv.setText(e.getMsg());


                secret = "";


            }




            @Override


            public void onSuccess(String msg) {


                tv.setText("申请成功");


                responseTv.setText(msg.toString());


                secret = msg.toString();


            }


        });




    }




    void checkAppVersion() {


        tv.setText("开始检测更新...");


        responseTv.setText("");




//        //正式服务器


        String appKey = "i8hR07jzrIS";//appkey


        String appSecret = "BmnJ8RWTtaVEBk24zPPF4UMwfYu0lAWU";//appsecret




        String appCode = "1697150870315999233";//appCode




        HDLLink.getInstance().checkAppVersion(this, appKey, appSecret, getAppVersionName(this), appCode, new CheckAppVersionListener() {


            @Override


            public void onSuccess(UpdateInfo info) {


                tv.setText("有新更新");


                responseTv.setText(info.toString());


            }




            @Override


            public void onError(HDLException e) {


                tv.setText("检测更新失败");


                responseTv.setText(e.getMsg());


            }


        });




    }




    public void UploadDeviceAuth(String mac, String result, String message, String auth_code) {


        //将认证结果上报给网关


        HDLLink.getInstance().UploadDeviceAuth(mac, result, message, auth_code, new HDLLinkCallBack() {


            @Override


            public void onSuccess(String s) {


                tv.setText("上报结果成功");


                responseTv.setText(s.toString());


            }




            @Override


            public void onError(HDLLinkException e) {


                tv.setText("上报结果失败");


                responseTv.setText(e.getMsg());


                Log.i(TAG, "onError: 上报结果失败");


            }


        });


    }






    @Override


    protected void onCreate(Bundle savedInstanceState) {


        super.onCreate(savedInstanceState);




        setContentView(R.layout.activity_main);


        responseTv = findViewById(R.id.response_tv);


        editText = findViewById(R.id.edittext);


        localSecret = findViewById(R.id.local_secret);


        tv = findViewById(R.id.state_tv);


        rv = findViewById(R.id.rv);


        rv.setLayoutManager(new LinearLayoutManager(this));




         init();


        selectnetwork();


        checkIfCertified();


        initDeviceInfo();//初始化基本信息，非常重要，认证时要用


        initDeviceInfo();//初始化


        registerAllTopicsListener();


        HDLLink.getInstance().setDeleteNetworkListener(new DeleteNetworkListener() {


            @Override


            public void onSuccess(Object msg) {


                LogUtils.i("setDeleteNetworkListener onSucceed = " + msg);


            }




            @Override


            public void onFailure() {


                LogUtils.i("setDeleteNetworkListener onFailure");


            }


        });




        ActivityResultLauncher<String[]> launcher = registerForActivityResult(new ActivityResultContracts.RequestMultiplePermissions(), new ActivityResultCallback<Map<String, Boolean>>() {


            @Override


@@ -108,9 +202,11 @@




        launcher.launch(new String[]{Manifest.permission.WRITE_EXTERNAL_STORAGE, Manifest.permission.READ_EXTERNAL_STORAGE});




        final List<DemoBean> beans = new ArrayList<>();


        final List<DemoBean> beans = new ArrayList<DemoBean>();


        beans.add(new DemoBean("申请设备密钥"));


        beans.add(new DemoBean("入网认证"));


        beans.add(new DemoBean("搜索指定网关是否在线"));


        beans.add(new DemoBean("上报oid列表"));


        beans.add(new DemoBean("获取功能列表"));


        beans.add(new DemoBean("功能属性读取"));


        beans.add(new DemoBean("设备控制"));


@@ -122,6 +218,8 @@


        beans.add(new DemoBean("TCP发送"));


        beans.add(new DemoBean("UDP发送，监听主题回复，带重发带回调"));


        beans.add(new DemoBean("TCP发送，监听主题回复，带重发带回调"));


        beans.add(new DemoBean("退网"));


        beans.add(new DemoBean("检测更新"));


        demoAdapter = new DemoAdapter(beans);


        rv.setAdapter(demoAdapter);




@@ -137,56 +235,72 @@


            public void onItemClick(@NonNull BaseQuickAdapter<?, ?> adapter, @NonNull View view, int position) {


                switch (position) {


                    case 0:


                        //申请设备密钥


                        applyDeviceSecret();


                        break;


                    case 1:


                        //入网认证


                        sendAuthenticateRequest();


                        break;


                    case 1:


                    case 2:


                        //搜索网关


                        searchGatewayBroadcast();


                        break;


                    case 2:


                    case 3:


                        //上报oid列表


                        UploadOidList();


                        break;


                    case 4:


                        //获取功能列表


                        getFunctionList();


                        break;


                    case 3:


                    case 5:


                        //功能属性读取


                        getFunctionAttribute();


                        break;


                    case 4:


                    case 6:


                        //设备控制


                        controlDecide();


                        break;


                    case 5:


                    case 7:


                        //读取状态


                        propertyRead();


                        break;


                    case 6:


                    case 8:


                        //获取场景列表


                        getSceneList();


                        break;


                    case 7:


                        //获取场景列表


                        controlScene();


                    case 9:


                        //场景控制


                        getScene();


                        break;


                    case 8:


                    case 10:


                        //功能列表


                        startDevicesListActivity();


                        break;


                    case 9:


                    case 11:


                        //UDP发送


                        udpSend();


                        break;


                    case 10:


                    case 12:


                        //TCP发送


                        tcpSend();


                        break;


                    case 11:


                    case 13:


                        //UDP发送，监听主题回复，带重发带回调


                        udpSendWithCallback();


                        break;


                    case 12:


                    case 14:


                        //TCP发送，监听主题回复，带重发带回调


                        tcpSendWithCallback();


                        break;


                    case 15:


                        //退网


                        deleteNetwork();


                        break;


                    case 16:


                        //检测更新


                        checkAppVersion();


                        break;


                }


            }


@@ -196,6 +310,10 @@




    public void showToast(String text) {


        Toast.makeText(this, text, Toast.LENGTH_SHORT).show();


    }




    void selectnetwork() {


        HDLLink.getInstance().selectNetwork("wlan0");


    }




    /**


@@ -216,7 +334,9 @@


            @Override


            public void onMessage(Object msg) {


                LinkResponse response = (LinkResponse) msg;


                handleLinkResponse(response);


                if ("/user/all/custom/gateway/broadcast_reply".equals(response.getTopic())) {


                    localSecret.setText("密钥：" + HDLLinkConfig.getInstance().getLocalSecret());


                }


            }


        };


        HDLLink.getInstance().registerAllTopicsListener(allTopicsListener);


@@ -361,6 +481,7 @@


     */


    void searchGatewayBroadcast() {


        tv.setText("搜索网关中...");


        responseTv.setText("");


        HDLLink.getInstance().searchGatewayBroadcast(new HDLAuthSocket.SearchGatewayCallBack() {


            @Override


            public void onError(HDLLinkException e) {


@@ -403,6 +524,7 @@


     */


    void getFunctionAttribute() {


        tv.setText("功能属性读取");


        responseTv.setText("");


        List<String> sids = new ArrayList<>();


        sids.add(testLightSid);


        HDLLink.getInstance().getFunctionAttribute(sids, new HDLLinkCallBack() {


@@ -424,6 +546,7 @@


     */


    void propertyRead() {


        tv.setText("读取状态中...");


        responseTv.setText("");


        List<String> list = new ArrayList<>();


        list.add(testLightSid);//要读取设备的sid


        HDLLink.getInstance().propertyRead(list, new HDLLinkCallBack() {


@@ -447,6 +570,7 @@


     */


    void controlDecide() {


        tv.setText("控制设备");


        responseTv.setText("");


        isOn = !isOn;


        List<DeviceControlRequest> requestList = new ArrayList<>();


        DeviceControlRequest request = new DeviceControlRequest();


@@ -476,10 +600,12 @@


     */


    void getSceneList() {


        tv.setText("读取场景列表");


        responseTv.setText("");


        HDLLink.getInstance().getSceneList(new HDLLinkCallBack() {


            @Override


            public void onSuccess(String msg) {


                responseTv.setText(msg);


                Log.d("panlili", "MainActivity.java:getSceneList-----> " + msg);


            }




            @Override


@@ -493,11 +619,36 @@


    // {"id":"8a5eaa143ce943b987b577df5a66759b","time_stamp":"1637040217235","objects":[{"sid":"04010560D2C7170A0A0100000000","name":"回家模式","status":"off","group":"255","delay":"0","modify_time":"1634871490"},{"sid":"04010560D2C76E0A0A0100010000","name":"离家模式","status":"off","group":"255","delay":"0","modify_time":"1634785823"}]}




    /**


     * 获取场景详情


     * 执行成功的话 响应code为200


     */


    void getScene() {


        tv.setText("场景读取");


        responseTv.setText("");


        //场景sid列表，支持批量读取


        List<String> sids = new ArrayList<>();


        sids.add("0201034C50B53F0A0A0100011100");


        sids.add("0201037F50B53F0A0A0100021100");


        HDLLink.getInstance().getScene(sids, new HDLLinkCallBack() {


            @Override


            public void onSuccess(String msg) {


                responseTv.setText(msg);


            }




            @Override


            public void onError(HDLLinkException e) {


                responseTv.setText(e.getMsg());


            }


        });


    }




    /**


     * 控制场景


     * 执行成功的话 响应code为200


     */


    void controlScene() {


        tv.setText("场景控制");


        responseTv.setText("");


        //控制场景sid列表，支持批量控制


        List<String> sids = new ArrayList<>();


        isOn = !isOn;


@@ -530,6 +681,7 @@


     */


    private void tcpSend() {


        tv.setText("TCP发送 只发一次，不监听回复，不重发");


        responseTv.setText("");


        String propertyDownTopic = String.format(TopicConstant.PROPERTY_DOWN, HDLLinkConfig.getInstance().getGatewayId());


        String bodyStr = getPropertyDownBodyStr();


        HDLLink.getInstance().tcpSendMsg(propertyDownTopic, bodyStr);


@@ -540,6 +692,7 @@


     */


    private void udpSend() {


        tv.setText("UDP发送 只发一次，不监听回复，不重发");


        responseTv.setText("");


        String propertyDownTopic = String.format(TopicConstant.PROPERTY_DOWN, HDLLinkConfig.getInstance().getGatewayId());


        String bodyStr = getPropertyDownBodyStr();


        HDLLink.getInstance().udpSendMsg(propertyDownTopic, bodyStr);


@@ -572,6 +725,7 @@


     */


    private void udpSendWithCallback() {


        tv.setText("UDP发送，监听主题回复，带重发带回调");


        responseTv.setText("");


        String propertyDownTopic = String.format(TopicConstant.PROPERTY_DOWN, HDLLinkConfig.getInstance().getGatewayId());


        String bodyStr = getPropertyDownBodyStr();


        HDLLink.getInstance().udpSendMsg(propertyDownTopic, bodyStr, new HDLLinkResponseCallBack() {


@@ -593,6 +747,7 @@


     */


    private void tcpSendWithCallback() {


        tv.setText("TCP发送，监听主题回复，带重发带回调");


        responseTv.setText("");


        String propertyDownTopic = String.format(TopicConstant.PROPERTY_DOWN, HDLLinkConfig.getInstance().getGatewayId());


        String bodyStr = getPropertyDownBodyStr();


        HDLLink.getInstance().tcpSendMsg(propertyDownTopic, bodyStr, new HDLLinkCallBack() {


@@ -608,4 +763,76 @@


            }


        });


    }




    private void deleteNetwork() {


        tv.setText("退网");


        responseTv.setText("");


        String oid = HDLLinkConfig.getInstance().getDeviceInfoBean().getOID();


        HDLLink.getInstance().deleteNetwork(oid, false, new HDLLinkCallBack() {


            @Override


            public void onSuccess(String msg) {


                responseTv.setText(msg);


                //退网成功，删除数据


            }




            @Override


            public void onError(HDLLinkException e) {


                responseTv.setText(e.getMsg());


            }


        });


    }




    /**


     * 上报oid列表


     */


    private void UploadOidList() {


        tv.setText("上报oid列表...");


        responseTv.setText("");




        //1.设置设备信息


        AuthenticateRequest.AuthenticateDeviceInfoBean authenticateDeviceInfoBean = HDLLinkConfig.getInstance().getDeviceInfoBean();




        ListUploadRequest request = new ListUploadRequest();


        request.setOid(authenticateDeviceInfoBean.getOID());


        request.setDevice_name(authenticateDeviceInfoBean.getDeviceName());


        request.setDevice_model(authenticateDeviceInfoBean.getDeviceModel());


        request.setDevice_mac(authenticateDeviceInfoBean.getDeviceMAC());


        request.setSrc("LINK");//来自哪个驱动，如Link设备没有则填"LINK"


        request.setFrom(authenticateDeviceInfoBean.getOID());//来自哪个网关，如果时Link网络设备，则填自身oid；如果是驱动则不需要此字段




        HDLLink.getInstance().UploadOidList(request, new HDLLinkCallBack() {


            @Override


            public void onError(HDLLinkException error) {


                tv.setText(error.getMsg());


            }




            @Override


            public void onSuccess(String data) {


                tv.setText("上报oid列表成功");


                responseTv.setText(data);


            }


        });


    }




    /**


     * 获取APP版本


     *


     * @param context


     * @return


     */


    public static String getAppVersionName(Context context) {


        String versionName = "0";


        try {


            PackageManager packageManager = context.getPackageManager();


            PackageInfo packageInfo = packageManager.getPackageInfo(context.getPackageName(), 0);


            versionName = packageInfo.versionName;


            if (TextUtils.isEmpty(versionName)) {


                versionName = "0";


            }


        } catch (Exception e) {


            e.printStackTrace();


        }


        return versionName;


    }




}