以下作品由安信可社區(qū)用戶

ch999制作

前言：

筆者這次決定使用AI-WB2-32s-Kit＋雷達(dá)模塊制+藍(lán)牙信標(biāo)作安防檢測(cè)，靈感來(lái)源是想著馬上畢業(yè)要外出租房，擔(dān)心陌生人進(jìn)入房間。

制作這個(gè)項(xiàng)目，目的是實(shí)現(xiàn)當(dāng)有人進(jìn)入房間時(shí)起到提示作用。但如果僅用雷達(dá)檢查，每次自己回家都也會(huì)觸發(fā)報(bào)告，那樣就太煩了，所以決定通過(guò)藍(lán)牙信標(biāo)來(lái)過(guò)濾指定目標(biāo)。

01

材料

●Ai-WB2-32S-Kit

●雷達(dá)模塊（自帶uart串口，通過(guò)串口輸出數(shù)據(jù)）

●藍(lán)牙模塊

●服務(wù)器，用來(lái)做中轉(zhuǎn)發(fā)送消息

雷達(dá)部分的代碼

#include
#include
#include
#include
#include
#include "bl_sys.h"
#include
#include
#include
#include
#include "bl_uart.h"
#define TAG "uart_demo"
#define GPIO_LED_PIN 3
hosal_uart_dev_t uart_dev_log = {
.config = {
.uart_id = 0,
.tx_pin = 16, // TXD GPIO
.rx_pin = 7, // RXD GPIO
.cts_pin = 255,
.rts_pin = 255,
.baud_rate = 115200,
.data_width = HOSAL_DATA_WIDTH_8BIT,
.parity = HOSAL_NO_PARITY,
.stop_bits = HOSAL_STOP_BITS_1,
.mode = HOSAL_UART_MODE_POLL,
},
};
//UART radar
void uart_radar_data(void *param)
{
char data[64];
int ret;
while (1)
{
/* UART receive poll */
ret = hosal_uart_receive(&uart_dev_log, data, sizeof(data)-1);
if (ret > 0)
{
bl_gpio_output_set(GPIO_LED_PIN, 1);//set led
}
else{
bl_gpio_output_set(GPIO_LED_PIN, 0);//set led
}
/* sscanf 是 C 語(yǔ)言標(biāo)準(zhǔn)庫(kù)中的一個(gè)函數(shù)，
* 用于從字符串中按照指定的格式讀取數(shù)據(jù)，
* 并將數(shù)據(jù)存儲(chǔ)到指定的變量中123。
* 它的原型定義在 頭文件中
*/
//雷達(dá)串口輸出數(shù)據(jù)的格式: v=-0.6 km/h, str=208
float velocity;
int str_value;
if (2 == sscanf(data, "v=%f km/h, str=%d", &velocity, &str_value)) {
printf("Parsed: v=%.1f, str=%drn", velocity, str_value);
}
vTaskDelay(200);
}
}
void main(void)
{
/* UART InIt device */
hosal_uart_init(&uart_dev_log);
/*LED*/
bl_gpio_enable_output(GPIO_LED_PIN, 0, 0);
xTaskCreate(uart_radar_data, "radar", 1024, NULL, 15, NULL);
}

第一階段先通過(guò)這個(gè)小項(xiàng)目，測(cè)試了點(diǎn)燈和串口，以及結(jié)合外設(shè)實(shí)現(xiàn)安防功能。

接下來(lái)要做的：藍(lán)牙信標(biāo)（該部分以完成）

開(kāi)發(fā)板以主機(jī)模式掃描設(shè)備，雷達(dá)發(fā)現(xiàn)有人進(jìn)屋且掃描到指定MAC設(shè)備，表示是自己回家，否則就是陌生人闖入。

藍(lán)牙部分代碼

在bl_interface.c庫(kù)文件里添加如下代碼實(shí)現(xiàn)mac比對(duì)和rssi。

//
int ble_master_get_rssi_by_mac(uint8_t *target_mac){
if(target_mac==NULL)return -127;
int ret=0;
int rssi=0;
int retry=3;
struct bt_le_scan_param scan_param;
char scan_data[250];
scan_param.type = BT_LE_SCAN_TYPE_ACTIVE;
scan_param.filter_dup = BT_LE_SCAN_FILTER_DUPLICATE;
scan_param.interval = 320;
scan_param.window = 48;
master_current_scan = 0;
memset(scan_le_addr, 0, sizeof(scan_le_addr));
memset(master_scan_tbl, 0, sizeof(master_scan_tbl));
//scan
ret = bt_le_scan_start(&scan_param, scan_device_found);
if(ret!=0){rssi=-127;}
vTaskDelay(800 / portTICK_PERIOD_MS);//持續(xù)掃描的時(shí)間
for (int i = 0; i < master_current_scan; i++) {
ble_reverse_byte(master_scan_tbl[i].mac, 6);
if(memcmp(target_mac,master_scan_tbl[i].mac, 6)==0){
sprintf(scan_data,"My BLE MAC:%02X%02X%02X%02X%02X%02X RSSI:%i name:%srn",
master_scan_tbl[i].mac[0],master_scan_tbl[i].mac[1],master_scan_tbl[i].mac[2],
master_scan_tbl[i].mac[3],master_scan_tbl[i].mac[4],master_scan_tbl[i].mac[5],
master_scan_tbl[i].rssi, master_scan_tbl[i].name);
bleuart_printf(scan_data);
rssi=master_scan_tbl[i].rssi;
break;
}
else{
//bleuart_printf("Not Found MAC Devicern");
rssi= -127;
}
}
return rssi;
}

再部署完服務(wù)器后，進(jìn)行一下簡(jiǎn)單測(cè)試。

完成雷達(dá)掃描和藍(lán)牙信標(biāo)后，現(xiàn)在來(lái)完成信息發(fā)送功能，參照安信可社區(qū)這位大佬的做法 ：用AI-WB2消息推送到個(gè)人通知https://bbs.ai-thinker.com/forum.php?mod=viewthread&tid=45846&highlight=wb2&_dsign=04722896

可以看到手機(jī)可以正常接收消息。

接下來(lái)是開(kāi)發(fā)板代碼,notify部分的代碼參考原文鏈接，記得添加必要的network庫(kù)到MAKEFILE以及修改pro_config.mk

notify.h

#ifndef __NOTIFY_H__
#define __NOTIFY_H__
#define WEB_SERVER "192.168.43.218" //這里改成你搭建的gotify服務(wù)器地址
#define WEB_PORT "8000" //默認(rèn)地址是80 我改為了8000,dokcer部署時(shí)選到什么端口這里填什么端口，最好避開(kāi)80，怕運(yùn)營(yíng)商屏蔽
#define WEB_PATH_BASE "/message"
#define QUERY_STRING "?token=AQSv2fQhrE.8_Fq" //token替換為你的通道token，token加到token=Axxxxxx后面
void notify_task(void *pvParameters);
#endif

notify.c

這里的Wi-Fi是從sdk里的Wi-Fi demo修改過(guò)來(lái)的。

#include "notify.h"
#include
#include
#include
#include
#include
#include
#include
#include
#include
#include
#define BOUNDARY "---"
static char REQUEST[512];
typedef struct {
const char *title;
const char *message;
const char *priority;
} Message;
void notify_task(void *pvParameters) {
Message *params = (Message *)pvParameters; // 接收參數(shù)
//
//
//
printf("title=%s rnmessage=%srnpriority=%srn", params->title,
params->message, params->priority);
//
const struct addrinfo hints = {
.ai_family = AF_INET,
.ai_socktype = SOCK_STREAM,
};
struct addrinfo *res;
struct in_addr *addr;
int s, r;
char recv_buf[4096];
while (1) {
int err = getaddrinfo(WEB_SERVER, WEB_PORT, &hints, &res);
if (err != 0 || res == NULL) {
blog_error("DNS lookup failed err=%d res=%p", err, res);
vTaskDelay(1000 / portTICK_PERIOD_MS);
continue;
}
/* Code to print the resolved IP.
Note: inet_ntoa is non-reentrant, look at ipaddr_ntoa_r for "real" code
*/
addr = &((struct sockaddr_in *)res->ai_addr)->sin_addr;
blog_info("DNS lookup succeeded. IP=%s", inet_ntoa(*addr));
s = socket(res->ai_family, res->ai_socktype, 0);
if (s < 0) {
blog_error("... Failed to allocate socket.");
freeaddrinfo(res);
vTaskDelay(1000 / portTICK_PERIOD_MS);
continue;
}
blog_info("... allocated socket");
if (connect(s, res->ai_addr, res->ai_addrlen) != 0) {
blog_error("... socket connect failed errno=%d", errno);
close(s);
freeaddrinfo(res);
vTaskDelay(4000 / portTICK_PERIOD_MS);
continue;
}
blog_info("... connected");
freeaddrinfo(res);
// 構(gòu)造請(qǐng)求體
char body[1024];
snprintf(body, sizeof(body),
"--%srn"
"Content-Disposition: form-data; name="title"rnrn"
"%srn"
"--%srn"
"Content-Disposition: form-data; name="message"rnrn"
"%srn"
"--%srn"
"Content-Disposition: form-data; name="priority"rnrn"
"%srn"
"--%s--rn",
BOUNDARY, params->title, BOUNDARY, params->message, BOUNDARY,
params->priority, BOUNDARY);
snprintf(REQUEST, sizeof(REQUEST),
"POST %s%s HTTP/1.0rn"
"Host: %s:%srn"
"User-Agent: aithinker wb2rn"
"Content-Type: multipart/form-data; boundary=%srn"
"Content-Length: %drn"
"rn"
"%s",
WEB_PATH_BASE, QUERY_STRING, WEB_SERVER, WEB_PORT, BOUNDARY,
strlen(body), body);
if (write(s, REQUEST, strlen(REQUEST)) < 0) {
blog_error("... socket send failed");
close(s);
vTaskDelay(4000 / portTICK_PERIOD_MS);
continue;
}
blog_info("... socket send success");
struct timeval receiving_timeout;
receiving_timeout.tv_sec = 5;
receiving_timeout.tv_usec = 0;
if (setsockopt(s, SOL_SOCKET, SO_RCVTIMEO, &receiving_timeout,
sizeof(receiving_timeout)) < 0) {
blog_error("... failed to set socket receiving timeout");
close(s);
vTaskDelay(4000 / portTICK_PERIOD_MS);
continue;
}
blog_info("... set socket receiving timeout success");
// FIXME fix putchar
extern int bl_putchar(int c);
/* Read HTTP response */
do {
bzero(recv_buf, sizeof(recv_buf));
r = read(s, recv_buf, sizeof(recv_buf) - 1);
for (int i = 0; i < r; i++) {
bl_putchar(recv_buf[i]);
}
} while (r > 0);
blog_info("... done reading from socket. Last read return=%d "
"errno=%drn",
r, errno);
close(s);
for (int countdown = 10; countdown >= 0; countdown--) {
blog_info("%d... ", countdown);
vTaskDelay(1000 / portTICK_PERIOD_MS);
}
blog_info("Starting again!");
}
}
#include
#include
#include
#include
#include
#include
#include
#include
#include
#include
#include
#include
#include
#include
#include
#include
#include
#include
#include
#include
#include
#include
#include
#include
#include
#include
#include
#include
#include
#include
#include
#include
#include
#include
#include
#include
#include
#include
#include
#include
#include
#include
#include
#include
#include
#include
#include
#include "bluetooth.h"
#include "ble_interface.h"
#include
#include "notify.h"
#include
#include
#include
#include
#define ROUTER_SSID "Play4T"
#define ROUTER_PWD "qq123456"
typedef struct {
const char *title;
const char *message;
const char *priority;
} Message;
hosal_uart_dev_t ble_uart_dev = {
.config = {
.uart_id = 0,
.tx_pin = 16, // TXD GPIO
.rx_pin = 7, // RXD GPIO
.cts_pin = 255,
.rts_pin = 255,
.baud_rate = 115200,
.data_width = HOSAL_DATA_WIDTH_8BIT,
.parity = HOSAL_NO_PARITY,
.stop_bits = HOSAL_STOP_BITS_1,
.mode = HOSAL_UART_MODE_POLL,
},
};
static wifi_conf_t conf = {
.country_code = "CN",
};
//
bool is_Send=false;
uint32_t last_send_time=0;
int rssi;
// 構(gòu)建消息內(nèi)容結(jié)構(gòu)體
static const char title[] = "tt";
static const char message[] = "12345";
static const char priority[] = "0";
static uint8_t target_mac[6] ={0xD1,0x10,0x91,0x29,0x8F,0xF5}; // 目標(biāo)設(shè)備MAC地址，請(qǐng)改為實(shí)際MAC
static Message msg = {title, message, priority};
extern uint8_t axk_HalBleInit();
/**
* @brief wifi_sta_connect
* wifi station mode connect start
* @param ssid
* @param password
*/
static void wifi_sta_connect(char *ssid, char *password) {
wifi_interface_t wifi_interface;
wifi_interface = wifi_mgmr_sta_enable();
wifi_mgmr_sta_connect(wifi_interface, ssid, password, NULL, NULL, 0, 0);
}
// WiFi事件處理
static void event_cb_wifi_event(input_event_t *event, void *private_data) {
static char *ssid;
static char *password;
switch (event->code) {
case CODE_WIFI_ON_INIT_DONE: {
printf("[APP] [EVT] INIT DONE %lldrn", aos_now_ms());
wifi_mgmr_start_background(&conf);
} break;
case CODE_WIFI_ON_MGMR_DONE: {
printf("[APP] [EVT] MGMR DONE %lldrn", aos_now_ms());
//_connect_wifi();
wifi_sta_connect(ROUTER_SSID, ROUTER_PWD);
} break;
case CODE_WIFI_ON_SCAN_DONE: {
printf("[APP] [EVT] SCAN Done %lldrn", aos_now_ms());
// wifi_mgmr_cli_scanlist();
} break;
case CODE_WIFI_ON_DISCONNECT: {
printf("[APP] [EVT] disconnect %lldrn", aos_now_ms());
} break;
case CODE_WIFI_ON_CONNECTING: {
printf("[APP] [EVT] Connecting %lldrn", aos_now_ms());
} break;
case CODE_WIFI_CMD_RECONNECT: {
printf("[APP] [EVT] Reconnect %lldrn", aos_now_ms());
} break;
case CODE_WIFI_ON_CONNECTED: {
printf("[APP] [EVT] connected %lldrn", aos_now_ms());
} break;
case CODE_WIFI_ON_PRE_GOT_IP: {
printf("[APP] [EVT] connected %lldrn", aos_now_ms());
} break;
case CODE_WIFI_ON_GOT_IP: {
printf("[APP] [EVT] GOT IP %lldrn", aos_now_ms());
printf("[SYS] Memory left is %d Bytesrn", xPortGetFreeHeapSize());
} break;
case CODE_WIFI_ON_PROV_SSID: {
printf("[APP] [EVT] [PROV] [SSID] %lld: %srn", aos_now_ms(),
event->value ? (const char *)event->value : "UNKNOWN");
if (ssid) {
vPortFree(ssid);
ssid = NULL;
}
ssid = (char *)event->value;
} break;
case CODE_WIFI_ON_PROV_BSSID: {
printf("[APP] [EVT] [PROV] [BSSID] %lld: %srn", aos_now_ms(),
event->value ? (const char *)event->value : "UNKNOWN");
if (event->value) {
vPortFree((void *)event->value);
}
} break;
case CODE_WIFI_ON_PROV_PASSWD: {
printf("[APP] [EVT] [PROV] [PASSWD] %lld: %srn", aos_now_ms(),
event->value ? (const char *)event->value : "UNKNOWN");
if (password) {
vPortFree(password);
password = NULL;
}
password = (char *)event->value;
} break;
case CODE_WIFI_ON_PROV_CONNECT: {
printf("[APP] [EVT] [PROV] [CONNECT] %lldrn", aos_now_ms());
printf("connecting to %s:%s...rn", ssid, password);
wifi_sta_connect(ssid, password);
} break;
case CODE_WIFI_ON_PROV_DISCONNECT: {
printf("[APP] [EVT] [PROV] [DISCONNECT] %lldrn", aos_now_ms());
} break;
default: {
printf("[APP] [EVT] Unknown code %u, %lldrn", event->code, aos_now_ms());
/*nothing*/
}
}
}
//開(kāi)啟藍(lán)牙掃描必須要聲明bleuart_printf這個(gè)函數(shù)，不知道為什么，這個(gè)函數(shù)在ble_interface.c中要用到
//注釋掉ble_interface.c會(huì)報(bào)錯(cuò)，實(shí)再?zèng)]看懂，留著吧
void bleuart_printf(char *buf)
{
hosal_uart_send(&ble_uart_dev, buf, strlen(buf));
}
// UART InIt device
static void uart_init(void)
{
hosal_uart_init(&ble_uart_dev);
}
//UART radar
static void radar_detection(void *param)
{
char data[64];
while (1)
{
//接收到數(shù)據(jù)data
hosal_uart_receive(&ble_uart_dev, data, sizeof(data)-1);
/*data: v=-0.6 km/h, str=208
* sscanf 是 C 語(yǔ)言標(biāo)準(zhǔn)庫(kù)中的一個(gè)函數(shù)，
* 用于從字符串中按照指定的格式讀取數(shù)據(jù)，
* 并將數(shù)據(jù)存儲(chǔ)到指定的變量中123。
* 它的原型定義在 頭文件中
*/
//解析data
float velocity;
int str_value;
if (2 == sscanf(data, "v=%f km/h, str=%d", &velocity, &str_value)) {
//printf("radar data: v=%.1f, str=%drn", velocity, str_value);
}
if(str_value>1000 && rssi==-127){
xTaskCreate(?ify_task, "notify_task", 2048, &msg, 5, NULL);
printf("There are strangers entering the housern");
}
vTaskDelay(200);
}
}
//BLE
static void ble_loop_proc(void *pvParameters)
{
char data[250];
while (1)
{
rssi=ble_master_get_rssi_by_mac(target_mac); // 掃描指定MAC的藍(lán)牙設(shè)備
if(rssi>-80){
bl_gpio_output_set(3, 1);
}
else{
bl_gpio_output_set(3, 0);
}
hosal_uart_receive(&ble_uart_dev, data, sizeof(data));
vTaskDelay(100/portTICK_PERIOD_MS);
}
}
////發(fā)送消息
//static void send_message(void *param){
// while(1){
// if(is_BreakIn){
//printf("is_BreakIn");
// //uint32_t current_time=aos_now_ms();
// //if((current_time-last_send_time)>10){
// xTaskCreate(?ify_task, "notify_task", 1024, &msg, 5, NULL);
// //last_send_time=current_time;
// is_BreakIn=false;
// printf("There are strangers entering the housern");
// //}
//
// }
// }
//
//}
void main()
{
uart_init();
bl_sys_init(); // if use BLE ,must InIt
axk_HalBleInit();
//printf("BLE MASTER InItrn");
tcpip_init(NULL, NULL);
aos_register_event_filter(EV_WIFI, event_cb_wifi_event, NULL);
hal_wifi_start_firmware_task();
aos_post_event(EV_WIFI, CODE_WIFI_ON_INIT_DONE, 0);
bl_gpio_enable_output(3, 0, 0);//GPIO
xTaskCreate(ble_loop_proc, "ble master", 1024, NULL, 15, NULL);
xTaskCreate(radar_detection, "radar", 1024, NULL, 15, NULL);
// xTaskCreate(send_message, "send_message", 1024, NULL, 15, NULL);
}

雷達(dá)掃描到有人時(shí)，如果開(kāi)發(fā)板同時(shí)掃描到指定MAC地址的藍(lán)牙，則表示自己回家，否則就發(fā)送消息到服務(wù)器，接下來(lái)只需要把服務(wù)器放公網(wǎng)上或者用內(nèi)網(wǎng)穿透，即可實(shí)現(xiàn)公網(wǎng)通知了，當(dāng)然用其他的消息通知也是一樣的，看個(gè)人喜好。

審核編輯 黃宇