新大陆云平台篇

简介: 新大陆云平台篇简介代码分析全部代码


简介



主要功能:温湿度传感器,灯,风扇与网关ZIGBBE自组网,然后网关将数据上传至云平台,上位机程序(android)通过云平台实时获取数据

1:获取温湿度数据

2:控制风扇,灯

3:如果实时获取的温度大于了一定数值自动开启风扇,如果小于一定数组自动开启灯

4:输入的温度大于了一定数值自动开启风扇,如果小于一定数值自动开启灯


代码分析



首先连接云平台,进行登陆。获取访问令牌

ConnectCloud.setOnClickListener( new View.OnClickListener() {
            @Override
            public void onClick(View v) {
                netWorkBusiness.signIn( new SignIn( UserName, PassWord ), new NCallBack<BaseResponseEntity<User>>(getApplicationContext()) {
                    @Override
                    protected void onResponse(BaseResponseEntity<User> response) {
                    }
                    @Override
                    public void onResponse(Call<BaseResponseEntity<User>> call, Response<BaseResponseEntity<User>> response) {
                        BaseResponseEntity<User> body = response.body();
                        if (body != null){
                            if (body.getStatus() == 0){
                                AccessToken = body.getResultObj().getAccessToken();
                                if (AccessToken == null){
                                    Toast.makeText( MainActivity.this,"访问令牌为空",Toast.LENGTH_SHORT ).show();
                                    return;
                                }
                                netWorkBusiness = new NetWorkBusiness( AccessToken, Url);
                            }
                        }
                    }
                } );
            }
        } );

开启子线程,实时获取温度数据,

并通过runOnUiThread从子线程跳转到主线程,更新UI,下面采用的是lamda写法。

 thread = new Thread( ()->{
            while (true){
                /**while start*/
                try{
                    Thread.sleep( 2000 );
                }catch (InterruptedException e){
                    e.printStackTrace();
                }
                /**获取温度数据开始*/
                netWorkBusiness.getSensors( DeviceID, TmpTag, new NCallBack<BaseResponseEntity<List<SensorInfo>>>(getApplicationContext()) {
                    @Override
                    protected void onResponse(BaseResponseEntity<List<SensorInfo>> response) {
                    }
                    @Override
                    public void onResponse(Call<BaseResponseEntity<List<SensorInfo>>> call, Response<BaseResponseEntity<List<SensorInfo>>> response) {
                        BaseResponseEntity<List<SensorInfo>> body = response.body();
                        if (body != null){
                            if (body.getStatus() == 0){
                                TmpValue = Double.parseDouble( body.getResultObj().get( 0 ).getValue() );
                            }
                        }
                    }
                } );
                /**获取温度数据结束*/
                /**改变温度的值*/
                runOnUiThread( ()->{
                    Tmp.setText( TmpValue+" ℃" );
                } );
                /**改变温度的值*/

打开风扇和灯通过新大陆JAR包中的control方法

/**
     * 发送命令/控制设备
     *
     * @param deviceId 设备ID(必填)
     * @param apiTag   传感标识名(必须但值可为空)
     * @param data     开关类:开=1,关=0,暂停=2
     *                 家居类:调光灯亮度=0~254,RGB灯色度=2~239,窗帘、卷闸门、幕布打开百分比=3%~100%,红外指令=1(on)2(off)
     *                 其它:integer/float/Json/String类型值
     */
 OpenFan.setOnClickListener( new View.OnClickListener() {
        @Override
        public void onClick(View v) {
            Fan.startAnimation( Rotate );
            netWorkBusiness.control( DeviceID, FanTag, 1, new NCallBack<BaseResponseEntity>(getApplicationContext()) {
                @Override
                protected void onResponse(BaseResponseEntity response) {
                    Toast.makeText( MainActivity.this,"打开风扇",Toast.LENGTH_SHORT ).show();
                }
            } );
        }
    } );

当硬件风扇选择时,对应的上位机程序风扇动画

 private void InitAnimation(){
        Rotate = AnimationUtils.loadAnimation( MainActivity.this,R.anim.rotate );
        Rotate.setDuration(1000);
        //animation.setRepeatCount(-1); //无限旋转
        Rotate.setRepeatMode(1);
        Rotate.setFillAfter(true);
        CycleInterpolator interpolator = new CycleInterpolator(1);
        Rotate.setInterpolator(interpolator);
    }


全部代码


 protected void onCreate(Bundle savedInstanceState) {
        super.onCreate( savedInstanceState );
        setContentView( R.layout.activity_main );
        InitView();
        GetData();
        InitAnimation();
        InputTmpOk.setOnClickListener( new View.OnClickListener() {
            @Override
            public void onClick(View v) {
                String GetEditTextTmpValue = InputTmp.getText().toString();
                int IntTmpValue = Integer.parseInt( GetEditTextTmpValue );
                if (IntTmpValue < 0){
                    Toast.makeText( MainActivity.this,"温度不能小于0",Toast.LENGTH_SHORT ).show();
                    return;
                }
                if (IntTmpValue > 40){
                    Toast.makeText( MainActivity.this,"温度不能大于40",Toast.LENGTH_SHORT ).show();
                    return;
                }
                ControlFan(IntTmpValue);
            }
        } );
        ButtonOpenLamp.setOnClickListener( new View.OnClickListener() {
            @Override
            public void onClick(View v) {
                CloseLamp.setVisibility( View.INVISIBLE );
                OpenLamp.setVisibility( View.VISIBLE );
                netWorkBusiness.control( DeviceID, LightTag, 1, new NCallBack<BaseResponseEntity>(getApplicationContext()) {
                    @Override
                    protected void onResponse(BaseResponseEntity response) {
                      Toast.makeText( MainActivity.this,"开灯",Toast.LENGTH_SHORT ).show();
                    }
                } );
            }
        } );
        ButtonCloseLamp.setOnClickListener( new View.OnClickListener() {
            @Override
            public void onClick(View v) {
                CloseLamp.setVisibility( View.VISIBLE );
                OpenLamp.setVisibility( View.INVISIBLE );
                netWorkBusiness.control( DeviceID, LightTag, 0, new NCallBack<BaseResponseEntity>(getApplicationContext()) {
                    @Override
                    protected void onResponse(BaseResponseEntity response) {
                        Toast.makeText( MainActivity.this,"关灯",Toast.LENGTH_SHORT ).show();
                    }
                } );
            }
        } );
        OpenFan.setOnClickListener( new View.OnClickListener() {
        @Override
        public void onClick(View v) {
            Fan.startAnimation( Rotate );
            netWorkBusiness.control( DeviceID, FanTag, 1, new NCallBack<BaseResponseEntity>(getApplicationContext()) {
                @Override
                protected void onResponse(BaseResponseEntity response) {
                    Toast.makeText( MainActivity.this,"打开风扇",Toast.LENGTH_SHORT ).show();
                }
            } );
        }
    } );
        CloseFan.setOnClickListener( new View.OnClickListener() {
        @Override
        public void onClick(View v) {
            Fan.clearAnimation();
            netWorkBusiness.control( DeviceID, FanTag, 0, new NCallBack<BaseResponseEntity>(getApplicationContext()) {
                @Override
                protected void onResponse(BaseResponseEntity response) {
                    Toast.makeText( MainActivity.this,"关闭风扇",Toast.LENGTH_SHORT ).show();
                }
            } );
        }
    } );
}
    private void InitView(){
        Tmp = findViewById( R.id.Tmp );
        Hum = findViewById( R.id.Hum );
        InputTmp = findViewById( R.id.InputTmp );
        InputTmpOk = findViewById( R.id.InputOk );
        ConnectCloud = findViewById( R.id.ConnectCloud );
        CloseLamp = findViewById( R.id.LampClose );
        OpenLamp = findViewById( R.id.LampOpen );
        ButtonOpenLamp = findViewById( R.id.ButtonOpenLamp );
        ButtonCloseLamp = findViewById( R.id.ButtonCloseLamp );
        Fan = findViewById( R.id.Fan );
        OpenFan = findViewById( R.id.OpenFan );
        CloseFan= findViewById( R.id.CloseFan );
    }
    private void InitAnimation(){
        Rotate = AnimationUtils.loadAnimation( MainActivity.this,R.anim.rotate );
        Rotate.setDuration(1000);
        //animation.setRepeatCount(-1); //无限旋转
        Rotate.setRepeatMode(1);
        Rotate.setFillAfter(true);
        CycleInterpolator interpolator = new CycleInterpolator(1);
        Rotate.setInterpolator(interpolator);
    }
    private void GetData(){
        /**登陆开始*/
        ConnectCloud.setOnClickListener( new View.OnClickListener() {
            @Override
            public void onClick(View v) {
                netWorkBusiness.signIn( new SignIn( UserName, PassWord ), new NCallBack<BaseResponseEntity<User>>(getApplicationContext()) {
                    @Override
                    protected void onResponse(BaseResponseEntity<User> response) {
                    }
                    @Override
                    public void onResponse(Call<BaseResponseEntity<User>> call, Response<BaseResponseEntity<User>> response) {
                        BaseResponseEntity<User> body = response.body();
                        if (body != null){
                            if (body.getStatus() == 0){
                                AccessToken = body.getResultObj().getAccessToken();
                                if (AccessToken == null){
                                    Toast.makeText( MainActivity.this,"访问令牌为空",Toast.LENGTH_SHORT ).show();
                                    return;
                                }
                                netWorkBusiness = new NetWorkBusiness( AccessToken, Url);
                            }
                        }
                    }
                } );
            }
        } );
                /**登陆结束*/
         thread = new Thread( ()->{
            while (true){
                /**while start*/
                try{
                    Thread.sleep( 2000 );
                }catch (InterruptedException e){
                    e.printStackTrace();
                }
                /**获取温度数据开始*/
                netWorkBusiness.getSensors( DeviceID, TmpTag, new NCallBack<BaseResponseEntity<List<SensorInfo>>>(getApplicationContext()) {
                    @Override
                    protected void onResponse(BaseResponseEntity<List<SensorInfo>> response) {
                    }
                    @Override
                    public void onResponse(Call<BaseResponseEntity<List<SensorInfo>>> call, Response<BaseResponseEntity<List<SensorInfo>>> response) {
                        BaseResponseEntity<List<SensorInfo>> body = response.body();
                        if (body != null){
                            if (body.getStatus() == 0){
                                TmpValue = Double.parseDouble( body.getResultObj().get( 0 ).getValue() );
                            }
                        }
                    }
                } );
                /**获取温度数据结束*/
                /**改变温度的值*/
                runOnUiThread( ()->{
                    Tmp.setText( TmpValue+" ℃" );
                } );
                /**改变温度的值*/
                /**获取湿度数据开始*/
                netWorkBusiness.getSensors( DeviceID, HumTag, new NCallBack<BaseResponseEntity<List<SensorInfo>>>(getApplicationContext()) {
                    @Override
                    protected void onResponse(BaseResponseEntity<List<SensorInfo>> response) {
                    }
                    @Override
                    public void onResponse(Call<BaseResponseEntity<List<SensorInfo>>> call, Response<BaseResponseEntity<List<SensorInfo>>> response) {
                        BaseResponseEntity<List<SensorInfo>> entity = response.body();
                        if (entity != null){
                            if (entity.getStatus() == 0){
                                HumValue = Double.parseDouble( entity.getResultObj().get( 0 ).getValue() );
                            }
                        }
                    }
                } );
                /**获取湿度数据结束*/
                /**改变湿度的值*/
                runOnUiThread( ()->{
                    Hum.setText( HumValue+" RH" );
                } );
                /**改变湿度的值*/
                /**while end*/
            }
        } );
        thread.start();
    }
    /**如果大于规定温度,开启风扇*/
    private void ControlFan(int GetTmpValue){
        if (GetTmpValue > MaxTmpValue){
            netWorkBusiness.control( DeviceID, LightTag, 1, new NCallBack<BaseResponseEntity>(getApplicationContext()) {
                @Override
                protected void onResponse(BaseResponseEntity response) {
                }
                @Override
                public void onResponse(Call<BaseResponseEntity> call, Response<BaseResponseEntity> response) {
                    Toast.makeText( MainActivity.this,"风扇已经开启",Toast.LENGTH_SHORT ).show();
                }
            } );
        }else if (GetTmpValue< MInTmpValue){
            netWorkBusiness.control( DeviceID, LightTag, 0, new NCallBack<BaseResponseEntity>(getApplicationContext()) {
                @Override
                protected void onResponse(BaseResponseEntity response) {
                }
                @Override
                public void onResponse(Call<BaseResponseEntity> call, Response<BaseResponseEntity> response) {
                    Toast.makeText( MainActivity.this,"风扇已经关闭",Toast.LENGTH_SHORT ).show();
                }
            } );
        }
    }



相关文章
|
网络协议 数据处理 数据格式
51单片机ESP8266云端通信的实现
51单片机ESP8266云端通信的实现
734 1
|
Linux iOS开发 MacOS
brew - mac 下的 brew 切换为国内源
brew - mac 下的 brew 切换为国内源
4649 0
VScode修改打开默认编码及自动匹配文件编码格式
VScode修改打开默认编码及自动匹配文件编码格式
4874 0
VScode修改打开默认编码及自动匹配文件编码格式
|
SpringCloudAlibaba 负载均衡 算法
SpringCloudAliBaba篇之Ribbon负载均衡器:让你的应用从容应对高并发
SpringCloudAliBaba篇之Ribbon负载均衡器:让你的应用从容应对高并发
617 0
|
8月前
|
机器学习/深度学习 编解码 人工智能
SeedVR:高效视频修复模型,支持任意长度和分辨率,生成真实感细节
SeedVR 是南洋理工大学和字节跳动联合推出的扩散变换器模型,能够高效修复低质量视频,支持任意长度和分辨率,生成真实感细节。
376 16
SeedVR:高效视频修复模型,支持任意长度和分辨率,生成真实感细节
|
10月前
|
供应链 搜索推荐 数据挖掘
API接口对电商的深远影响
在数字化商业时代,电子商务竞争激烈,创新和效率成为企业成功的关键。API(应用程序编程接口)在电商领域的应用正逐渐改变企业的运营模式,带来诸多机遇和显著收益。API 接口通过数据共享和功能集成,实现了多平台商品同步、个性化推荐、订单管理、支付结算、物流跟踪等,提升了运营效率,增强了用户体验,拓展了市场覆盖,促进了数据驱动的决策。未来,API 在电商领域的应用将更加广泛,助力企业在竞争中保持领先。
260 4
|
传感器
DIY_实现光敏电阻传感器简单控制LED
DIY_实现光敏电阻传感器简单控制LED
2448 2
|
10月前
|
消息中间件 存储 负载均衡
【赵渝强老师】Kafka的体系架构
Kafka消息系统是一个分布式系统,包含生产者、消费者、Broker和ZooKeeper。生产者将消息发送到Broker,消费者从Broker中拉取消息并处理。主题按分区存储,每个分区有唯一的偏移量地址,确保消息顺序。Kafka支持负载均衡和容错。视频讲解和术语表进一步帮助理解。
143 0
|
SQL 数据库连接 网络安全
SQLServer非默认端口下事务复制代理作业服务无法启动的处理
【8月更文挑战第14天】若SQL Server非默认端口下的事务复制代理作业无法启动,可按以下步骤解决:1) 确认服务器连接字符串正确无误,包括非默认端口号;2) 检查防火墙设置,确保允许非默认端口的连接;3) 核实SQL Server配置已启用非默认端口;4) 查阅代理作业日志寻找错误详情;5) 重启SQL Server与Agent服务;6) 使用工具测试非默认端口的连接性。如问题持续,请寻求专业支持。
184 0
|
数据采集 缓存
【MODBUS】Modbus设备与云平台对接的方式
【MODBUS】Modbus设备与云平台对接的方式
518 0