新大陆云平台篇

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


简介



主要功能:温湿度传感器,灯,风扇与网关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();
                }
            } );
        }
    }



相关文章
|
弹性计算 安全 搜索推荐
【年终特辑】看见科技创新力量 洞见时代创业精神—企业服务—道恩威尔:云平台和软硬件设施结合打造智慧社区
【年终特辑】看见科技创新力量 洞见时代创业精神—企业服务—道恩威尔:云平台和软硬件设施结合打造智慧社区
114 1
|
负载均衡 安全 Cloud Native
信创要求下的客户体验难题,与思杰Citrix应用交付的破题
信创要求下的客户体验难题,与思杰Citrix应用交付的破题
|
开发工具 Android开发
新大陆云平台配置(1)
下载云平台Android–SDK 云平台Android–SDK下载
381 0
新大陆云平台配置(1)
|
数据安全/隐私保护 开发者
新大陆云平台配置(2)
云平台登陆代码详解 开启应用 登陆云平台
399 0
新大陆云平台配置(2)
|
架构师 前端开发 Cloud Native
国内首个开源架构治理平台 ArchGuard,专治分布式场景下各种不服
过去的 10 年间,软件的架构发生了巨大的变化,从早先流行的单体 MVC 架构,变成了所谓的 5:5 开,即分布式 vs 单体。只是呢,有大量的软件开发人员,无法看到系统的全貌,又或者是从单体的思维转变过来。于是,哪怕是在使用了微服务的情况下,但是实现的却又是一个一个的单体,只是它们变成了“分布式的单体”。
590 0
国内首个开源架构治理平台 ArchGuard,专治分布式场景下各种不服
|
存储 Cloud Native 关系型数据库
厚积薄发:探寻磐久服务器M系列研发之路
从云栖首发到两次电商流量洪峰考验,阿里云加大底层基础技术的自研逻辑?磐久服务器M系列有何独特技术优势?
厚积薄发:探寻磐久服务器M系列研发之路
|
传感器 人工智能 算法
除了云计算和5G,未来之城还缺哪个「基础设施」?
在智能城市 1.0 时代,因缺少统一的精准时间和空间信息作为基准,海量终端信息无法进行统一管理。 千寻位置的时空智能操作系统「昆仑镜」,是对时空能力进行调度的操作系统 。以前大家所理解的「操作系统」,是对计算能力进行调度的操作系统,比如阿里云的飞天、Windows、iOS 等。「昆仑镜」,是对时空能力进行调度的操作系统,调度「定位 + 地图 + 时间」的能力。 从产业链角度来说,「昆仑镜」的出现也帮助了北斗与终端应用的连接,降低北斗高精度应用门槛,推动北斗产业化进程。
154 0
除了云计算和5G,未来之城还缺哪个「基础设施」?
|
机器学习/深度学习 存储 云安全
|
并行计算 新能源 调度
台风动向它先知!国内电力行业首个云超算平台上线
国内电力行业首个云超算平台——南网调度云超算平台近日已上线。同时,基于南网调度云超算平台的精细化数值天气预报系统台风模式也已投入使用,可提前7天预测台风动向。
440 0