课设整个流程：

  1. 将代码烧写到终端和协调器上，并将协调器和终端上电，等待协调器和终端组好网后。
  2. 用串口线将协调器和电脑连接起来，观察终端和协调器是否闪灯，若闪灯则是在发送数据。
  3. 打开电脑上的串口工具（自己写的），读出串口数据并且上传到老师服务器的数据库中。
  4. 打开安卓APP，在输入框中输入学号，点击确定，查看上传的数据。

终端向协调器发送数据（多少个数据，什么数据，怎么发送，怎么处理数据）

温湿度：

总共发了6个字节，温度占两个字节，在第二（高位）和第三个字节，湿度占两个字节，在第四（高位）和第五个字节，第一个是0xff是接收数据时用来判断是否接收的，第六个字节是传设备的ID。

光照：

总共发了3个字节，第一个字节是0xff是接收数据时用来判断是否接收的，光照占两个字节，在第二（高位）和第三个字节。

怎么发送：

终端通过无线传感器网络传给协调器，协调器通过串口传给电脑，电脑上写的串口工具可以读取串口上的数据，然后将数据处理后发给老师的服务器（服务器上有SQL server数据库），最后安卓通过调用老师服务器的接口（http://106.52.230.85/wsntest/WebServicedDemo.asmx/getdateXHjson?XH=）传入XH（学号）后返回 json 串，在安卓端处理后展示。

怎么处理数据：

硬件端

光照：

终端发送：
image.png

  1. static void myReportData(void)
  2. {
  3.     byte dat[6];
  4.     //获取本节点的网络短地址
  5.     uint16 sAddr = NLME_GetShortAddr();
  6.     //获取协调器的网络短地址
  7.     uint16 pAddr = NLME_GetCoordShortAddr();
  8.    // DHT22_Read();
  9.     //LED灯闪烁1次
  10.    //GetAM231Data();
  12.     HalLedSet( HAL_LED_1, HAL_LED_MODE_OFF );
  13.     HalLedSet( HAL_LED_1, HAL_LED_MODE_BLINK );
  15.     //将节点信息进行封装
  16.     dat[0] = 0xff;
  17.     //dat[1] =gHumiture[0]; //(Rxbuf>>8) & 0xff;
  18.     //dat[2] = gHumiture[1];
  19.     //dat[3] =gHumiture[2];
  20.     //dat[4] = gHumiture[3];
  21.     //uint32 vol = getVol();
  22.     //dat[1] = (vol>>24)& 0xff; //(Rxbuf>>8) & 0xff;
  23.     //dat[2] = (vol>>16)& 0xff;
  24.     //dat[3] = (vol>>8)& 0xff;
  25.     //dat[4] = (vol>>0)& 0xff;
  27.     CBTDevice_LIGHT_Processing();
  28.     dat[2]=gLight & 0xff;     //低位
  29.     dat[1]=(gLight>>8) & 0xFF;//高位
  30.     //dat[3] = 0xff;
  31.     //dat[4] = 0xff;
  32.     //dat[1] = 0x00;
  33.     //lendata = 4;
  34.     //SampleApp_SendPeriodicMessage(SENSOR_LIGHT, SENSOR_INDEX, POSITION, sdata, 4);
  35.     //dat[5] = MYDEVID;
  36.     //将数据包发送给协调器
  37.     zb_SendDataRequest(0, ID_CMD_REPORT, 3, dat, 0, AF_ACK_REQUEST, 0 );  
  38. }

协调器接收
image.png

  1. #include <stdio.h>
  2. void zb_ReceiveDataIndication( uint16 source, uint16 command, uint16 len, uint8 *pData  )
  3. {
  4.     char buf[32];
  5.     char buf1[2];
  6.     //接收到数据之后LED灯闪烁
  7.     HalLedSet( HAL_LED_1, HAL_LED_MODE_OFF );
  8.     HalLedSet( HAL_LED_1, HAL_LED_MODE_BLINK );     
  10.     if (len==3 && pData[0]==0xff) {  
  11.       float temp_f, humi_f;
  12.       buf1[0]=pData[1];
  13.       buf1[1]=pData[2];
  14.       humi_f = ((float)(( pData[1]<<8)+ pData[2])/10);    
  15.   //temp_f = ((float)(( pData[3]<<8)+ pData[4])/10);
  16.       //sprintf(buf, "%02X H:%-6.2f%% T:%-6.2f℃", pData[5],humi_f, temp_f);
  17.       sprintf(buf, "%.0f",humi_f);
  18.       debug_str(buf1);//将数据通过串口传递给上位机
  19.     } 
  20. }

温湿度：

终端发送：
image.png

  1. static void myReportData(void)
  2. {
  3.     byte dat[6];
  4.     //获取本节点的网络短地址
  5.     uint16 sAddr = NLME_GetShortAddr();
  6.     //获取协调器的网络短地址
  7.     uint16 pAddr = NLME_GetCoordShortAddr();
  8.    // DHT22_Read();
  9.     //LED灯闪烁1次
  10.    GetAM231Data();
  12.     HalLedSet( HAL_LED_1, HAL_LED_MODE_OFF );
  13.     HalLedSet( HAL_LED_1, HAL_LED_MODE_BLINK );
  15.     //将节点信息进行封装
  16.     dat[0] = 0xff;
  17.     dat[1] =gHumiture[0]; //(Rxbuf>>8) & 0xff;
  18.     dat[2] = gHumiture[1];
  19.     dat[3] =gHumiture[2];
  20.     dat[4] = gHumiture[3];
  21.     dat[5] = MYDEVID;
  22.     //将数据包发送给协调器
  23.     zb_SendDataRequest(0, ID_CMD_REPORT, 6, dat, 0, AF_ACK_REQUEST, 0 );  
  24. }

协调器接收
image.png

  1. void zb_ReceiveDataIndication( uint16 source, uint16 command, uint16 len, uint8 *pData  )
  2. {
  3.     char buf[32];
  4.     //接收到数据之后LED灯闪烁
  5.     HalLedSet( HAL_LED_1, HAL_LED_MODE_OFF );
  6.     HalLedSet( HAL_LED_1, HAL_LED_MODE_BLINK );     
  8.     if (len==6 && pData[0]==0xff) {  
  9.       float temp_f, humi_f;
  10.   humi_f = ((float)(( pData[1]<<8)+ pData[2])/10);    
  11.   temp_f = ((float)(( pData[3]<<8)+ pData[4])/10);
  12.       sprintf(buf, "%-6.2f %-6.2f",humi_f, temp_f);
  13.       debug_str(buf);//将数据通过串口传递给上位机
  14.     } 
  15. }

串口工具端

image.png

主要修改函数的地方（看两个等号分割中间的地方）
image.png

  1.     public void onActionOpenBtn(ActionEvent actionEvent) {
  2.         isOpen = !isOpen;
  3.         if (isOpen) {
  4.             if (!serialController.open(comboBox.getValue(), BaudRateBox.getValue())) {
  5.                 return;
  6.             }
  7.             serialController.setListenerToSerialPort(ev -> {
  8.                 if (ev.getEventType() == SerialPortEvent.DATA_AVAILABLE) {
  9.                     String str = null;
  10.                     System.out.println("====================================================================================");
  11.                     try {
  13.                         str = serialController.readData();
  15.                         String regEX="[^0-9]";
  16.                         Pattern compile = Pattern.compile(regEX);
  18.                         Matcher matcher = compile.matcher(str);
  20.                         String guangzhao = matcher.replaceAll("").trim();
  22.                         System.out.println("guangzhao:"+guangzhao);
  24.                         Connection connection = SqlUtils.getConnection();
  26.                         Statement statement = connection.createStatement();
  28.                         /**
  29.                          * ID GROUPID XH VALUE UPDATETIME
  30.                          */
  31.                         //String sql = "SELECT * FROM WSNTEST";
  32. //                        String sql1 = "INSERT INTO WSNTEST(GROUPID,XH,VALUE) VALUES ('202004071-202003978-202003983','wenglushi','"+"温度:"+wd+"湿度:"+sd+"')";
  34. //                        String sql2 = "INSERT INTO WSNTEST(GROUPID,XH,VALUE) VALUES ('202004071-202003978-202003983','wenglushi','"+"光照:"+guangzhao+"')";
  36. //                        if (wd < 30 && wd>10){
  37. //                            statement.executeUpdate(sql1);
  38. //                        }
  39. //                        if(Integer.parseInt(guangzhao) > 100){
  40. //                            statement.executeUpdate(sql2);
  41. //                        }
  45.                         if (guangzhao.length()==8){//温湿度
  46.                             char c0 = guangzhao.charAt(0);
  47.                             char c1 = guangzhao.charAt(1);
  48.                             char c2 = guangzhao.charAt(2);
  49.                             char c3 = guangzhao.charAt(3);
  50.                             char c4 = guangzhao.charAt(4);
  51.                             char c5 = guangzhao.charAt(5);
  52.                             char c6 = guangzhao.charAt(6);
  53.                             char c7 = guangzhao.charAt(7);
  55.                             String wsd="湿度："+c0+c1+"."+c2+c3+" 温度："+c4+c5+"."+c6+c7;
  56.                             String sql1 = "INSERT INTO WSNTEST(GROUPID,XH,VALUE) VALUES ('20200471-202003978-202003983','wenglushi','"+wsd+"')";
  57.                             statement.executeUpdate(sql1);
  58.                         }else if(guangzhao.length()==3){
  59.                             String gzhao = "光照："+guangzhao;
  60.                             String sql2 = "INSERT INTO WSNTEST(GROUPID,XH,VALUE) VALUES ('20200471-202003978-202003983','wenglushi','"+gzhao+"')";
  61.                             statement.executeUpdate(sql2);
  62.                         }
  63. //=======================================================================================================================================
  64.                         System.out.println("str:"+str);
  66. //                        byte[] bytes = Hex.decodeHex(str);
  68. //                        System.out.println(bytes);
  70.                         char[] chars = str.toCharArray();
  72.                         ArrayList<String> strings = new ArrayList<>();
  74.                         System.out.println("strings:"+strings);
  76.                         for (int i= 0;i<chars.length;i++){
  77.                             String s = Integer.toHexString(chars[i]);
  79.                             strings.add(s);
  81.                             System.out.println("000000000:"+s);
  82.                         }
  84.                         System.out.println("1111111:"+strings);
  86.                         Integer wd = Integer.parseInt(strings.get(1),16);
  89. //                        Integer gz = Integer.parseInt(((Integer.parseInt(strings.get(1),16)*256)+Integer.parseInt(strings.get(2),16))/10+"");
  90. //                        Integer gz = Integer.parseInt(((Integer.parseInt(strings.get(1)+strings.get(2),16)))+"");
  92.                         System.out.println("gz:"+guangzhao);
  94.                         Integer sd = Integer.parseInt(strings.get(2),16);
  97.                         System.out.println("2222222:"+"wd:"+wd+"sd:"+sd);
  100. //                        ResultSet resultSet = statement.executeQuery(sql);
  102. /*
  103.                         while (resultSet.next()) {
  104.                             String ID = resultSet.getString("ID");
  105.                             String GROUPID = resultSet.getString("GROUPID");
  106.                             String XH = resultSet.getString("XH");
  107.                             String VALUE = resultSet.getString("VALUE");
  108.                             String UPDATETIME = resultSet.getString("UPDATETIME");
  110.                             System.out.println(ID+GROUPID+XH+VALUE+UPDATETIME);
  111.                         }*/
  115.                     } catch (UnsupportedEncodingException | SQLException e) {
  116.                         e.printStackTrace();
  117.                     }
  118.                     String finalStr = str;
  119.                     Platform.runLater(() -> {
  120.                         if (receiveText.getLength() < 4000) {
  121.                             receiveText.appendText(finalStr);
  122.                         } else {
  123.                             receiveText.deleteText(0, finalStr.length());
  124.                             receiveText.appendText(finalStr);
  125.                         }
  126.                     });
  128.                 }
  129.             });
  130.             openBnt.setText("关闭串口");
  131.         } else {
  132.             serialController.close();
  133.             openBnt.setText("打开串口");
  134.         }
  135.     }

安卓怎么读数据

注意文件位置
image.png
image.png
image.png
image.png

  1.     /**
  2.      * json转List<HashMap<String, String>>
  3.      * @param data
  4.      * @return
  5.      */
  6.     public List<HashMap<String, String>> jsonToList(String data){
  7.         List<HashMap<String, String>> list = null;
  8.         try {
  10. //            JSONObject jsonObject1 = new JSONObject(data);
  11. //            JSONArray jsonArray = jsonObject1.getJSONArray("");
  13.             list = new ArrayList<>();
  14.             JSONArray jsonArray = new JSONArray(data);
  16. //            int i = jsonArray.length() - 1;
  17. //            JSONObject jsonObject = (JSONObject) jsonArray.get(i);
  18.             //取出name
  20.             JSONObject jsonObject1;
  21.             HashMap<String, String> hashMap;
  22.             for (int i = 0;i < jsonArray.length();i++){
  23.                 String json = (String) jsonArray.getString(i);
  25.                 jsonObject1 = new JSONObject(json);
  27.                 String ID = jsonObject1.getString("ID");
  28.                 String GROUPID = jsonObject1.getString("GROUPID");
  29.                 String XH = jsonObject1.getString("XH");
  30.                 String VALUE = jsonObject1.getString("VALUE");
  31.                 String UPDATETIME = jsonObject1.getString("UPDATETIME");
  33.                 hashMap = new HashMap<>();
  35.                 hashMap.put("ID",ID);
  36.                 hashMap.put("GROUPID",GROUPID);
  37.                 hashMap.put("XH",XH);
  38.                 hashMap.put("VALUE",VALUE);
  39.                 hashMap.put("UPDATETIME",UPDATETIME);
  41.                 list.add(hashMap);
  42.             }
  45. //            String groupid = jsonArray.getString(1);
  46. //            String xh = jsonArray.getString(2);
  47. //            String value = jsonArray.getString(3);
  48. //            String update = jsonArray.getString(4);
  49. //            data = "组号："+groupid + "\n" + "学号："+xh + "\n" +"传值："+ value + "\n"+"最后更新时间："+ update;
  50.         } catch (Exception e) {
  51.             e.printStackTrace();
  52.         }
  53.         /*List<HashMap<String, String>> list = new ArrayList<>();
  55.         try {
  56. //            JSONObject jsonObject1 = new JSONObject(data);
  58. //            JSONArray jsonArray = jsonObject1.getJSONArray("WSNTEST");
  60.             JSONArray jsonArray = new JSONArray(data);
  62. //            int i = jsonArray.length() - 1;
  63. //            JSONObject jsonObject = (JSONObject) jsonArray.get(i);
  64.             //取出name
  65.             //
  67.             for (int i = 0;i < jsonArray.length();i++){
  69.                 String ID = (String) jsonArray.get(0);
  72.             }
  74. //            String ID = jsonObject1.getString("ID");
  75. //            String GROUPID = jsonObject1.getString("GROUPID");
  76. //            String XH = jsonObject1.getString("XH");
  77. //            String VALUE = jsonObject1.getString("VALUE");
  78. //            String UPDATETIME = jsonObject1.getString("UPDATETIME");
  80.             HashMap<String, String> hashMap = new HashMap<>();
  82. //            hashMap.put("ID",ID);
  83. //            hashMap.put("GROUPID",GROUPID);
  84. //            hashMap.put("XH",XH);
  85. //            hashMap.put("VALUE",VALUE);
  86. //            hashMap.put("UPDATETIME",UPDATETIME);
  87. //
  88. //            list.add(hashMap);
  89.         } catch (JSONException e) {
  90.             e.printStackTrace();
  91.         }*/
  94.         return list;
  95.     }
  97.     /**
  98.      * json处理
  99.      * @param data
  100.      * @return
  101.      */
  102.     public String Stringjson(String data) {
  104.         List<HashMap<String, String>> list;
  105.         try {
  107. //            JSONObject jsonObject1 = new JSONObject(data);
  108. //            JSONArray jsonArray = jsonObject1.getJSONArray("");
  110.             list = new ArrayList<>();
  111.             JSONArray jsonArray = new JSONArray(data);
  113. //            int i = jsonArray.length() - 1;
  114. //            JSONObject jsonObject = (JSONObject) jsonArray.get(i);
  115.             //取出name
  117.             JSONObject jsonObject1;
  118.             HashMap<String, String> hashMap;
  119.             for (int i = 0;i < jsonArray.length();i++){
  120.                 String json = (String) jsonArray.getString(i);
  122.                 jsonObject1 = new JSONObject(json);
  124.                 String ID = jsonObject1.getString("ID");
  125.                 String GROUPID = jsonObject1.getString("GROUPID");
  126.                 String XH = jsonObject1.getString("XH");
  127.                 String VALUE = jsonObject1.getString("VALUE");
  128.                 String UPDATETIME = jsonObject1.getString("UPDATETIME");
  130.                 hashMap = new HashMap<>();
  132.                 hashMap.put("ID",ID);
  133.                 hashMap.put("GROUPID",GROUPID);
  134.                 hashMap.put("XH",XH);
  135.                 hashMap.put("VALUE",VALUE);
  136.                 hashMap.put("UPDATETIME",UPDATETIME);
  138.                 list.add(hashMap);
  139.             }
  142. //            String groupid = jsonArray.getString(1);
  143. //            String xh = jsonArray.getString(2);
  144. //            String value = jsonArray.getString(3);
  145. //            String update = jsonArray.getString(4);
  146. //            data = "组号："+groupid + "\n" + "学号："+xh + "\n" +"传值："+ value + "\n"+"最后更新时间："+ update;
  147.         } catch (Exception e) {
  148.             e.printStackTrace();
  149.         }
  150.         return data;
  151.     }

image.png

  1.     /**
  2.      * 将数据展示到ListView
  3.      * @param list
  4.      * @param lv_shop_data
  5.      * @throws SQLException
  6.      */
  7.     private void setListView(List<HashMap<String, String>> list,ListView lv_shop_data) throws SQLException {
  9. //        lv_shop_data.setVisibility(View.VISIBLE);
  12.         adapter = new SimpleAdapter(
  13.                 MainActivity.this,
  14.                 list,
  15.                 R.layout.adapter_item,
  16.                 //ID GROUPID XH VALUE UPDATETIME
  17.                 new String[] { "ID", "GROUPID", "XH" ,"VALUE","UPDATETIME"},
  18.                 new int[] { R.id.txt_ID, R.id.txt_GROUPID, R.id.txt_XH, R.id.txt_VALUE, R.id.txt_UPDATETIME });
  20.         lv_shop_data.setAdapter(adapter);
  22.     }