返回发烧友论坛
发 帖  

[文章]HarmonyOS教程—分布式运动健康（手机端）

红旧衫
2021-09-07 10:57:38
阅读量0
HarmonyOS分布式
0
2
1. 介绍      
HarmonyOS支持应用以Ability为单位进行部署，Ability可以分为FA（Feature Ability）和PA（Particle Ability）两种类型，本篇Codelab将会使用到Page Ability以及Service Ability来进行开发，其中Page Ability是FA唯一支持的模板，用于提供与用户交互的能力，Service Ability是PA的一种，用于提供后台运行任务的能力。
分布式运动健康Codelab包含两个HarmonyOS应用（手机端和智能穿戴端），本篇要介绍的是基于手机的HarmonyOS分布式运动健康应用，在这个应用中，您将使用到HarmonyOS中的常用Java UI布局DirectionalLayout，以及跨设备拉起PA服务，跨设备同步数据等能力来共同实现一个基于分布式的HarmonyOS运动健康手机侧应用。
           
本篇Codelab实现了如下功能：
  • 智能穿戴设备的心率和步数数据到手机A的实时传输；
  • 实时心率异常提醒；
  • 手机A得到的健康数据共享至手机B。

最终效果预览
我们最终会构建一个简易的HarmonyOS分布式运动健康智能穿戴设备客户端和手机客户端。手机应用包含两个页面，分别是健康数据页面和他人数据页面，两个页面都展示了来自于个人智能穿戴设备或他人智能穿戴设备的运动步数和心率数据，其中健康数据页面的实现逻辑中会定时地去读取与之绑定的智能穿戴设备数据，实现跨设备同步数据。效果如下图所示。本篇Codelab我们将会一起完成这个客户端，其中包括：
  • 页面布局
  • 应用初始化
  • 同步数据
  • 渲染数据

将步数转换成距离、热量、爬楼层数；步数小于等于400为低强度，步数大于400小于等于600为中等强度，步数大于600小于等于800为中高强度，步数大于800为高强度；手机端效果展示：
   

2. 搭建HarmonyOS环境   
我们首先需要完成HarmonyOS开发环境搭建，可参照如下步骤进行。
  • 安装DevEco Studio，详情请参考下载和安装软件。
  • 设置DevEco Studio开发环境，DevEco Studio开发环境依赖于网络环境，需要连接上网络才能确保工具的正常使用，可以根据如下两种情况来配置开发环境：
    • 如果可以直接访问Internet，只需进行下载HarmonyOS SDK操作。
    • 如果网络不能直接访问Internet，需要通过代理服务器才可以访问，请参考配置开发环境。
  • 开发者可以参考以下链接，完成设备调试的相关配置：
    • 使用真机进行调试
    • 使用模拟器进行调试
说明
智能穿戴侧应用需要通过运动健康APP完成和手机侧绑定，才可以实现分布式相关调测。   

3. 代码结构解读      
本篇Codelab只对核心代码进行讲解，对于完整代码，我们会在第十章节参考中提供下载方式，接下来我们会用一小节来讲解整个工程的代码结构：

  • annotation：Bind是一个自定义注解，用来初始化页面中的组件。
  • Entity：WatchEntity为封装了手表数据的实体类。
  • enums：KeyEnum是一个枚举类，用来表示运动健康数据（K-V键值对）的键值。
  • factory：MyKvManagerFactory是一个工厂类，通过懒汉式+DCL产生我们需要的单例KvManager。
  • slice：HealthSlice是主要代码逻辑实现的一个类，同时对应我们的页面。
  • task：NotifyTask是一个通知任务，被手机端的一个PA服务（ServiceAbility）调用，PushDataTask是一个写数据（智能穿戴设备-手机A之间DB数据的一次拷贝）的任务。
  • util：存放所有封装好的公共方法，如CommonUtils，LogUtils等。
  • view：加载页面相关的类。
  • ServiceAbility：一个PA服务类，主要的功能是当智能穿戴设备端发现心率异常，会拉起手机端的这个PA服务（即状态栏收到心率异常通知，点击通知拉起手机FA进入主页面）。
  • resources：存放工程使用到的资源文件，其中resourcesbaselayout下存放xml布局文件；resourcesbasemedia下存放图片资源。
  • config.json：工程相关配置文件。
   
4. 页面布局      
健康数据页面
此页面包含同步手表数据定时器开关，手动同步智能穿戴设备数据，总步数，最新心率以及心率范围的布局，对应的xml文件名为ability_main.xml，下面一一介绍相关布局：
同步智能穿戴设备数据定时器开关对应布局文件如下，具体开关逻辑和样式的设置参考第五章节
  1. <Switch
  2.         ohos:id="$+id:btn_switch"
  3.         ohos:height="30vp"
  4.         ohos:width="60vp"
  5.         ohos:layout_alignment="left"
  6.         ohos:text_state_off="OFF"
  7.         ohos:text_state_on="ON"/>
复制代码
手动同步智能穿戴设备数据对应布局文件如下，点击事件代码请参考第五章节
  1. <Button
  2.         ohos:id="$+id:button_syncData"
  3.         ohos:height="35vp"
  4.         ohos:width="200vp"
  5.         ohos:background_element="$graphic:step"
  6.         ohos:layout_alignment="horizontal_center"
  7.         ohos:text="同步手表数据"
  8.         ohos:text_color="#FFF7F7FA"
  9.         ohos:text_size="27fp"
  10.         ohos:top_margin="20vp"
  11.         ohos:top_padding="10px"
  12.         />
复制代码
运动步数布局文件如下，其中用到了RoundProgressBar组件，详细使用方法可参考RoundProgressBar
  1. <DirectionalLayout
  2.         ohos:id="$+id:stepLayout"
  3.         ohos:height="240vp"
  4.         ohos:width="370vp"
  5.         ohos:alignment="left"
  6.         ohos:background_element="$graphic:step"
  7.         ohos:top_margin="50vp">

  9.         <DirectionalLayout
  10.             ohos:height="match_content"
  11.             ohos:width="match_parent"
  12.             ohos:alignment="vertical_center"
  13.             ohos:orientation="horizontal">

  15.             <Text
  16.                 ohos:id="$+id:stepTimeText"
  17.                 ohos:height="match_content"
  18.                 ohos:width="match_content"
  19.                 ohos:left_margin="115vp"
  20.                 ohos:text="同步时间 00:00"
  21.                 ohos:text_alignment="center"
  22.                 ohos:text_color="white"
  23.                 ohos:text_size="20fp"/>
  24.         </DirectionalLayout>

  26.         <DirectionalLayout
  27.             ohos:height="match_content"
  28.             ohos:width="match_parent"
  29.             ohos:alignment="vertical_center"
  30.             ohos:orientation="horizontal">

  32.             <RoundProgressBar
  33.                 ohos:progress_hint_text="步数0步"
  34.                 .....
  35.                                        />

  37.             <RoundProgressBar           
  38.                 ohos:progress_hint_text="低强度"
  39.                 .....               
  40.                                        />
  41.         </DirectionalLayout>

  43.         <DirectionalLayout
  44.             ohos:height="match_content"
  45.             ohos:width="match_parent"
  46.             ohos:alignment="vertical_center"
  47.             ohos:orientation="horizontal">

  49.             <Text
  50.                 ohos:text="距离0.00公里 |"
  51.                 .....
  52.                                          />

  54.             <Text               
  55.                 ohos:text="热量0.00千卡 |"
  56.                 .....
  57.                                          />

  59.             <Text               
  60.                 ohos:text="爬楼0层"
  61.                 .....
  62.                                          />
  63.         </DirectionalLayout>
  64.     </DirectionalLayout>
复制代码
心脏健康和心率范围布局文件如下，同步逻辑可参考第六章节
  1. <DirectionalLayout
  2.         xmlns:ohos="http://schemas.huawei.com/res/ohos"
  3.         ohos:id="$+id:test10"
  4.         ohos:height="match_parent"
  5.         ohos:width="match_parent"
  6.         ohos:alignment="horizontal_center"
  7.         ohos:orientation="horizontal">

  9.       <DirectionalLayout
  10.         ohos:id="$+id:test3"
  11.         ohos:height="180vp"
  12.         ohos:layout_alignment="left"
  13.         ohos:width="175vp"
  14.         ohos:alignment="left"
  15.         ohos:background_element="$graphic:rate"
  16.         ohos:top_margin="50vp"
  17.         >
  18.         <DirectionalLayout
  19.             ohos:height="match_content"
  20.             ohos:width="match_parent"
  21.             ohos:alignment="vertical_center"
  22.             ohos:orientation="vertical">

  24.             <Text
  25.                 ohos:id="$+id:rateText"
  26.                 ohos:height="match_content"
  27.                 ohos:width="match_content"
  28.                 ohos:left_margin="10vp"
  29.                 ohos:text="心脏健康"
  30.                 ohos:text_color="#FF0C0C0C"
  31.                 ohos:text_size="20fp"/>

  33.             <Text               
  34.                 ohos:text="00:00"
  35.                 .....
  36.                                      />
  37.         </DirectionalLayout>

  39.         <DirectionalLayout
  40.             ohos:height="match_parent"
  41.             ohos:width="match_parent"
  42.             ohos:alignment="vertical_center"
  43.             ohos:orientation="horizontal">

  45.             <Text
  46.                 ohos:id="$+id:rateData"
  47.                 ohos:height="match_content"
  48.                 ohos:width="match_content"
  49.                 ohos:text="0"
  50.                 ohos:text_color="#FF0C0C0C"
  51.                 ohos:text_size="30fp"
  52.                 ohos:top_margin="30vp"/>

  54.             <Text                 
  55.                 ohos:text="次/分钟"  
  56.                 .....               
  57.                                      />

  59.         </DirectionalLayout>
  60.     </DirectionalLayout>

  62.         <Component
  63.             ohos:height="match_content"
  64.             ohos:width="5vp"/>

  66.       <DirectionalLayout
  67.         ohos:id="$+id:test4"
  68.         ohos:height="180vp"
  69.         ohos:width="175vp"
  70.         ohos:layout_alignment="right"
  71.         ohos:background_element="$graphic:range"
  72.         ohos:top_margin="50vp"
  73.         >

  75.         <Text
  76.             ohos:id="$+id:rateTexts"
  77.             ohos:height="match_content"
  78.             ohos:width="match_content"
  79.             ohos:left_margin="10vp"
  80.             ohos:text="心率范围"
  81.             ohos:text_color="#FF0E0E0E"
  82.             ohos:text_size="20fp"/>

  84.         <DirectionalLayout
  85.             ohos:height="match_parent"
  86.             ohos:width="match_parent"
  87.             ohos:alignment="vertical_center"
  88.             ohos:orientation="horizontal">

  90.             <Text
  91.              ohos:text="0~0"
  92.              .....
  93.                                    />

  95.             <Text
  96.              ohos:text="次/分钟"
  97.              .....
  98.                                     />

  100.         </DirectionalLayout>

  102.       </DirectionalLayout>

  104.     </DirectionalLayout>
复制代码
他人数据页面布局与健康页面布局大致相同，对应的文件名为tablist_layout.xml，具体可见参考部分的完整代码。
底部Tab切换布局
对应的文件名为root.xml

  1. <DependentLayout
  2.     ohos:id="$+id:root"
  3.     xmlns:ohos="http://schemas.huawei.com/res/ohos"
  4.     ohos:width="match_parent"
  5.     ohos:height="match_parent">

  7.     <DirectionalLayout
  8.         ohos:id="$+id:page_wrap"
  9.         ohos:width="match_parent"
  10.         ohos:height="match_parent"
  11.         ohos:above="$+id:footer"
  12.         ohos:orientation="vertical"
  13.         >
  14.         <ScrollView
  15.             ohos:id="$+id:page"
  16.             ohos:width="match_parent"
  17.             ohos:height="match_parent"
  18.             ></ScrollView>
  19.     </DirectionalLayout>

  21.     <Component
  22.         ohos:width="match_parent"
  23.         ohos:height="1vp"
  24.         ohos:above="$+id:footer"
  25.         ohos:background_element="#EDF1F5"
  26.         ></Component>

  28.     <DirectionalLayout
  29.         ohos:id="$+id:footer"
  30.         ohos:width="match_parent"
  31.         ohos:height="54vp"
  32.         ohos:align_parent_bottom="true"
  33.         ohos:orientation="horizontal">
  34.         <TabList
  35.             ohos:id="$+id:footer_tab"
  36.             ohos:width="match_parent"
  37.             ohos:height="match_parent"
  38.             ohos:top_padding="8vp"/>
  39.     </DirectionalLayout>

  41. </DependentLayout>
复制代码
5. 应用初始化   
当我们首次安装应用打开时会进入到类MainAbility的onStart(Intent intent)方法。这里面做了两件事，设置页面路由和授予权限。
权限配置
说明
权限需要在config.json中添加如下配置，同时需要在应用启动时手动授予手机分布式数据同步权限。
  1. "reqPermissions": [
  2.       {
  3.         "name": "ohos.permission.DISTRIBUTED_DATASYNC"
  4.       },
  5.       {
  6.         "name": "ohos.permission.VIBRATE"
  7.       },
  8.       {
  9.         "name": "ohos.permission.DISTRIBUTED_DEVICE_STATE_CHANGE"
  10.       },
  11.       {
  12.         "name": "ohos.permission.GET_DISTRIBUTED_DEVICE_INFO"
  13.       },
  14.       {
  15.         "name": "ohos.permission.GET_BUNDLE_INFO"
  16.       }
  17.     ]
复制代码
MainAbility#requestPermission():手动授予权限
  1. private void requestPermission() {
  2.     if (verifySelfPermission(DISTRIBUTED_DATASYNC) != IBundleManager.PERMISSION_GRANTED) {
  3.             // 校验没有权限时,手动授权
  4.             if (canRequestPermission(DISTRIBUTED_DATASYNC)) {
  5.                 // toast
  6.                 requestPermissionsFromUser(new String[] {DISTRIBUTED_DATASYNC}, PERMISSION_CODE);
  7.             }
  8.         }
  9.     }
复制代码
应用加载流程
在HealthSlice类的onStart(Intent intent)方法按步骤完成：
  • 设置页面UI
    1. manager = new HomeLayoutManager(this);
    2. rootLayout = manager.initSliceLayout();
    3. super.setUIContent(rootLayout);
    复制代码

  • 初始化页面上的组件，此处只展示部分组件变量，其余部分代码请浏览第十章节
    1. @Bind(ResourceTable.Id_stepData)
    2. private RoundProgressBar stepData;

    4. @Bind(ResourceTable.Id_stepTimeText)
    5. private Text stepTime;

    7. .....

    9. private void initViewAnnotation() {
    10. Field[] fields = getClass().getDeclaredFields();
    11.     for (Field field : fields) {
    12.         Bind bind = field.getAnnotation(Bind.class);
    13.         if (bind != null) {
    14.             if (bind.value() == -1) {
    15.                 LogUtils.error(TAG, "bind.value must set!");
    16.                 return;
    17.             }
    18.             try {
    19.                 field.setAccessible(true);
    20.                 field.set(this, findComponentById(bind.value()));
    21.             } catch (IllegalAccessException e) {
    22.                 LogUtils.error(TAG, "IllegalAccessException :" + e.getMessage());
    23.             }
    24.         }
    25.     }
    26. }
    复制代码

  • 给按钮设置监听事件
    1. private void initListener() {
    2.     // 同步手表数据
    3.     syncData.setClickedListener(
    4.             va -> {
    5.                 syncData(singleKvStore);
    6.             });
    7.     // 同步其他手机数据
    8.     syncPhoneData.setClickedListener(
    9.             va -> {
    10.                 syncData(singleKvStore2);
    11.             });
    12.     // 定时刷新开关
    13.     aSwitch.setCheckedStateChangedListener(new AbsButton.CheckedStateChangedListener() {
    14.         // 回调处理Switch状态改变事件
    15.         [url=home.php?mod=space&uid=2735960]@Override[/url]
    16.         public void onCheckedChanged(AbsButton button, boolean isChecked) {
    17.             if (isChecked) {
    18.                 timer = new Timer();
    19.                 initMyHandler();
    20.             }else{
    21.                 timer.cancel();
    22.             }
    23.         }
    24.     });
    25. }
    复制代码

  • 投递定时任务事件(当开关处于开的状态时，应用启动时默认关闭状态)
    1. private MyEventHandler myHandler;

    3. private Timer timer ;

    5. private void initMyHandler() {
    6.     myHandler = new MyEventHandler(EventRunner.current());
    7.     long param = 0L;
    8.     Object object = null;
    9.     InnerEvent normalInnerEvent = InnerEvent.get(EVENT_MESSAGE_NORMAL, param, object);
    10.     myHandler.sendEvent(normalInnerEvent, 0, EventHandler.Priority.IMMEDIATE);
    11. }

    13. // 处理投递的事件
    14. class MyEventHandler extends EventHandler {
    15.     MyEventHandler(EventRunner runner) throws IllegalArgumentException {
    16.         super(runner);
    17.     }

    19.     @Override
    20.     protected void processEvent(InnerEvent event) {
    21.         super.processEvent(event);
    22.         if (event == null) {
    23.             return;
    24.         }
    25.         int eventId = event.eventId;
    26.         switch (eventId) {
    27.             case EVENT_MESSAGE_NORMAL:
    28.                timer.schedule(new TimerTask() {
    29.                     public void run() {
    30.                         LogUtils.info(",", "定时同步" + "");
    31.                         getUITaskDispatcher().syncDispatch(new Runnable() {
    32.                             @Override
    33.                             public void run() {
    34.                                 syncData(singleKvStore);
    35.                             }
    36.                         });
    37.                     }
    38.                 }, 0, INTERVAL);
    39.                 break;
    40.             default:
    41.                 break;
    42.         }
    43.     }
    44. }
    复制代码

  • 初始化开关样式
    1. private StateElement trackElementInit(ShapeElement on, ShapeElement off) {
    2.     StateElement trackElement = new StateElement();
    3.     trackElement.addState(new int[]{ComponentState.COMPONENT_STATE_CHECKED}, on);
    4.     trackElement.addState(new int[]{ComponentState.COMPONENT_STATE_EMPTY}, off);
    5.     return trackElement;
    6. }

    8. private StateElement thumbElementInit(ShapeElement on, ShapeElement off) {
    9.     StateElement thumbElement = new StateElement();
    10.     thumbElement.addState(new int[]{ComponentState.COMPONENT_STATE_CHECKED}, on);
    11.     thumbElement.addState(new int[]{ComponentState.COMPONENT_STATE_EMPTY}, off);
    12.     return thumbElement;
    13. }

    15. private void initSwitch() {
    16.     // 开启状态下滑块的样式
    17.     ShapeElement elementThumbOn = new ShapeElement();
    18.     elementThumbOn.setShape(ShapeElement.OVAL);
    19.     elementThumbOn.setRgbColor(RgbColor.fromArgbInt(ON_COLOR_SLIDER));
    20.     elementThumbOn.setCornerRadius(CORNER_RADIUS);

    22.     // 关闭状态下滑块的样式
    23.     ShapeElement elementThumbOff = new ShapeElement();
    24.     elementThumbOff.setShape(ShapeElement.OVAL);
    25.     elementThumbOff.setRgbColor(RgbColor.fromArgbInt(OFF_COLOR_SLIDER));
    26.     elementThumbOff.setCornerRadius(CORNER_RADIUS);

    28.     // 开启状态下轨迹样式
    29.     ShapeElement elementTrackOn = new ShapeElement();
    30.     elementTrackOn.setShape(ShapeElement.RECTANGLE);
    31.     elementTrackOn.setRgbColor(RgbColor.fromArgbInt(ON_COLOR));
    32.     elementTrackOn.setCornerRadius(CORNER_RADIUS);

    34.     // 关闭状态下轨迹样式
    35.     ShapeElement elementTrackOff = new ShapeElement();
    36.     elementTrackOff.setShape(ShapeElement.RECTANGLE);
    37.     elementTrackOff.setRgbColor(RgbColor.fromArgbInt(OFF_COLOR));
    38.     elementTrackOff.setCornerRadius(CORNER_RADIUS);

    40.     sw.setTrackElement(trackElementInit(elementTrackOn, elementTrackOff));
    41.     sw.setThumbElement(thumbElementInit(elementThumbOn, elementThumbOff));
    42. }
    复制代码

  • 使用单例模式初始化分布式数据库
    1. private void initDb() {
    2.     KvManagerConfig config = new KvManagerConfig(this);
    3.     kvManager = MyKvManagerFactory.getInstance(config);
    4.     Options options = new Options();
    5.     options.setCreateIfMissing(true).setEncrypt(false).setKvStoreType(KvStoreType.SINGLE_VERSION);
    6.     try {
    7.         singleKvStore = kvManager.getKvStore(options, STORE_ID);
    8.         singleKvStore2 = kvManager.getKvStore(options, STORE_ID2);
    9.     } catch (KvStoreException e) {
    10.         LogUtils.info(TAG, "KvStore Exception Occur");
    11.     }
    12. }

    14. public class MyKvManagerFactory {
    15.     private static KvManager instance = null;

    17.     private MyKvManagerFactory() { }

    19.     public static KvManager getInstance(KvManagerConfig config) {
    20.         if (instance == null) {
    21.             synchronized (MyKvManagerFactory.class) {
    22.                 if (instance == null) {
    23.                     try {
    24.                         instance = KvManagerFactory.getInstance().createKvManager(config);
    25.                     } catch (KvStoreException e) {
    26.                         LogUtils.info("KvStoreException", e.getMessage());
    27.                     }
    28.                 }
    29.             }
    30.         }
    31.         return instance;
    32.     }
    33. }
    复制代码

说明
  • 此demo模拟的是单向场景：智能穿戴设备->手机A->手机B
  • STORE_ID：用于智能穿戴设备与手机A之间的数据同步
  • STORE_ID2：用于手机A和手机B之间的数据同步(手机A在读取智能穿戴设备写入STORE_ID的同时，将数据备份至此数据库中，用于手机B查看他人数据)

6. 同步数据      
HealthSlice类的syncData(SingleKvStore kvStore)方法为手动同步(拉取)智能穿戴设备或手机的数据，这里根据kvStore来进行区分。
说明
singleKvStore:   智能穿戴设备写数据，手机A读数据singleKvStore2：手机A写数据 ，手机B读数据获取组网内的设备列表,将设备ID存入容器中，同时推断需要同步的设备类型，进而进行相关业务处理操作
  1. private void syncData(SingleKvStore kvStore) {
  2.     List<DeviceInfo> deviceInfoList = kvManager.getConnectedDevicesInfo(DeviceFilterStrategy.NO_FILTER);
  3.     if (deviceInfoList.size() == 0) {
  4.         String message = "未发现手表/手机设备";
  5.         showTip(message);
  6.         renderingData(kvStore);
  7.         return;
  8.     }
  9.     deviceIdList.clear();
  10.     for (DeviceInfo deviceInfo : deviceInfoList) {
  11.         deviceIdList.add(deviceInfo.getId());
  12.     }
  13.     inferredSyncDevice(kvStore);
  14. }

  16. private void inferredSyncDevice(SingleKvStore kvStore) {
  17.     if (kvStore.equals(singleKvStore)) {
  18.         String message = "同步手表数据成功";
  19.         doSync(message, kvStore);
  20.         renderingData(kvStore);
  21.     } else if (kvStore.equals(singleKvStore2)) {
  22.         String message = "同步手机数据成功";
  23.         doSync(message, kvStore);
  24.         renderingData(kvStore);
  25.     } else {
  26.         LogUtils.info("syncData()==>", "DATA BASE NOT EXIST");
  27.     }
  28. }
复制代码
手动调用同步接口进行分布式数据库的数据同步,同步完成会进入此回调
  1. private void doSync(String message, SingleKvStore kvStore) {
  2.     kvStore.registerSyncCallback(
  3.             new SyncCallback() {
  4.                 @Override
  5.                 public void syncCompleted(Map<String, Integer> map) {
  6.                     getUITaskDispatcher()
  7.                             .asyncDispatch(
  8.                                     new Runnable() {
  9.                                         @Override
  10.                                         public void run() {
  11.                                             showTip(message);
  12.                                         }
  13.                                     });
  14.                     kvStore.unRegisterSyncCallback();
  15.                 }
  16.             });
  17.     try {
  18.         LogUtils.info(TAG, "Start to get data");
  19.         kvStore.sync(deviceIdList, SyncMode.PULL_ONLY);
  20.     } catch (KvStoreException e) {
  21.         LogUtils.info(TAG, "doSync KvStoreException");
  22.     }
  23. }
复制代码
7. 渲染数据
同步数据完成后，进行数据在页面上的渲染,同时会将智能穿戴设备写入的数据备份一份至singleKvStore2中，用于手机B查看他人数据
  1. private void renderingData(SingleKvStore kvStore) {
  2.     if (kvStore != null) {
  3.         List<Entry> entries = kvStore.getEntries("");
  4.         if (entries.size() == 0 || entries.isEmpty() || entries.equals(null)) {
  5.             String message = "未找到数据";
  6.             showTip(message);
  7.             return;
  8.         }
  9.         dealEntries(entries, kvStore);
  10.     }
  11. }

  13. private void dealEntries(List<Entry> entries, SingleKvStore kvStore) {
  14.     for (Entry entry : entries) {
  15.         // 完成页面数据的加载
  16.         finishPageInitialization(entry.getKey(), kvStore, createWatchDataEntity(entry));
  17.     }
  18.     // 填充心率范围数据
  19.     populateRateRangePage(entries, kvStore);
  20. }

  22. private void finishPageInitialization(String key, SingleKvStore kvStore, WatchEntity watchEntity) {
  23.     if (KeyEnum.LATEST_STEP.getValue().equals(key)) {
  24.         // 填充最新步数数据
  25.         populateStepPage(kvStore, watchEntity);
  26.     } else if (KeyEnum.LATEST_RATE.getValue().equals(key)) {
  27.         if (kvStore.equals(singleKvStore)) {
  28.            // 填充最新心率数据
  29.             populateRatePage(rateData, rateTime, watchEntity);
  30.         } else {
  31.             populateRatePage(otherRateData, otherRateTime, watchEntity);
  32.         }
  33.     } else if (key.contains(KeyEnum.RATE.getValue())) {
  34.         rateList.add(Integer.valueOf(watchEntity.getData()));
  35.     } else {
  36.         stepList.add(Integer.valueOf(watchEntity.getData()));
  37.     }
  38. }

  40. private void populateRateRangePage(List<Entry> entries, SingleKvStore kvStore) {
  41.     if (rateList.size() == 0) {
  42.         return;
  43.     }
  44.     doPopulateRateRangePage(entries, kvStore);
  45. }

  47. // 执行心率范围数据填充以及数据的备份操作
  48. private void doPopulateRateRangePage(List<Entry> entries, SingleKvStore kvStore) {
  49.     Integer min = Collections.min(rateList);
  50.     Integer max = Collections.max(rateList);
  51.     if (kvStore.equals(singleKvStore)) {
  52.         rateRange.setText(min + "~" + max);
  53.         List<Entry> entries2 = singleKvStore2.getEntries("");
  54.         getUITaskDispatcher().asyncDispatch(new PushDataTask(entries, entries2, singleKvStore2));
  55.     } else {
  56.         otherRateRangeData.setText(min + "~" + max);
  57.         if (min < MIN_HEART_RATE || max > MAX_HEART_RATE) {
  58.             String message = "他人心率异常";
  59.             showTip(message);
  60.         }
  61.     }
  62. }

  64. // 封装手表数据为Entity，方便传参
  65. private WatchEntity createWatchDataEntity(Entry entry) {
  66.     String value = entry.getValue().getString();
  67.     String[] split = value.split(regex);
  68.     WatchEntity watchEntity = new WatchEntity();
  69.     watchEntity.setTime(split[0]);
  70.     watchEntity.setData(split[1].substring(0, split[1].indexOf(DOT)));
  71.     return watchEntity;
  72. }

  74. private void populateStepPage(SingleKvStore kvStore, WatchEntity watchDataEntity) {
  75.     if (kvStore.equals(singleKvStore)) { // 我的数据
  76.         stepData.setProgressHintText("步数 " + watchDataEntity.getData() + " 步");
  77.         stepData.setProgressValue(CommonUtils.getProgressWithSteps(Integer.parseInt(watchDataEntity.getData())));
  78.         stepTime.setText(watchDataEntity.getTime());
  79.         // 距离
  80.         stepDistances.setText("距离" + CommonUtils.getDistanceWithSteps(
  81.                 Integer.parseInt(watchDataEntity.getData())) + "公里 |");
  82.         // 热量
  83.         stepHeat.setText("热量" + CommonUtils.getCalorieWithSteps(
  84.                 Integer.parseInt(watchDataEntity.getData())) + "千卡 |");
  85.         // 爬楼层
  86.         stepFloor.setText("爬楼" + CommonUtils.getFloorWithSteps(
  87.                 Integer.parseInt(watchDataEntity.getData())) + "层");
  88.         // 强度
  89.         Map<String, String> intensityMap = CommonUtils.getIntensityWithSteps(
  90.                 Integer.parseInt(watchDataEntity.getData()));
  91.         stepData1.setProgressHintText(intensityMap.get("text"));
  92.         stepData1.setProgressValue(Integer.parseInt(intensityMap.get("progress")));
  93.     } else { // 他人数据
  94.         otherStepData.setProgressHintText("步数 " + watchDataEntity.getData() + " 步");
  95.         otherStepData.setProgressValue(CommonUtils.getProgressWithSteps(
  96.                 Integer.parseInt(watchDataEntity.getData())));
  97.         otherStepTime.setText(watchDataEntity.getTime());
  98.         // 距离
  99.         otherStepDistances.setText("距离" + CommonUtils.getDistanceWithSteps(
  100.                 Integer.parseInt(watchDataEntity.getData())) + "公里 |");
  101.         // 热量
  102.         otherStepHeat.setText("热量" + CommonUtils.getCalorieWithSteps(
  103.                 Integer.parseInt(watchDataEntity.getData())) + "千卡 |");
  104.         // 爬楼层
  105.         otherStepFloor.setText("爬楼" + CommonUtils.getFloorWithSteps(
  106.                 Integer.parseInt(watchDataEntity.getData())) + "层");
  107.         // 强度
  108.         Map<String, String> intensityMap = CommonUtils.getIntensityWithSteps(
  109.                 Integer.parseInt(watchDataEntity.getData()));
  110.         otherStepData1.setProgressHintText(intensityMap.get("text"));
  111.         otherStepData1.setProgressValue(Integer.parseInt(intensityMap.get("progress")));
  112.     }
  113. }

  115. private void populateRatePage(Text rateData, Text rateTime, WatchEntity watchDataEntity) {
  116.     rateData.setText(watchDataEntity.getData());
  117.     rateTime.setText(watchDataEntity.getTime());
  118. }

  120. // 弹框处理
  121. private void showTip(String message) {
  122.     myHandler.postTask(new Runnable() {
  123.         @Override
  124.         public void run() {
  125.             new ToastDialog(getContext())
  126.                     .setAlignment(LayoutAlignment.TOP)
  127.                     .setText(message)
  128.                     .setDuration(SHOW_TIME)
  129.                     .setSize(DIALOG_SIZE_WIDTH, DIALOG_SIZE_HEIGHT)
  130.                     .show();
  131.         }
  132.     });
  133. }
复制代码
说明
以上代码仅demo演示参考使用
8. 回顾和总结
本篇Codelab我们介绍了应用的初始化加载过程和同步数据渲染数据的代码逻辑，在主页面可以通过底部的按钮切换到不同类别的数据(健康数据和他人数据)。点击上方手动同步按钮会进行数据的手动同步，同时也提供自动刷新的机制。当智能穿戴设备发现心率异常时会拉起手机端的PA服务，手机端会在状态栏收到手表心率异常的通知，点击该通知可以进入应用主页面。

9. 恭喜你  
目前你已经成功完成了Codelab并且学到了：
  • 如何进行布局编写及页面切换
  • 如何进行心率和步数数据的采集
  • 状态栏通知,点击通知进入FA和分布式数据库数据同步

10. 参考

举报

回帖

声明：本文内容及配图由入驻作者撰写或者入驻合作网站授权转载。文章观点仅代表作者本人，不代表电子发烧友网立场。文章及其配图仅供工程师学习之用，如有内容图片侵权或者其他问题，请联系本站作侵删。 侵权投诉
链接复制成功，分享给好友