james/rsoc
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

可以上传阿里云，概率随机动

Browse Source
This commit is contained in:
james 2024-08-05 11:24:14 +08:00
parent 65e7298351
commit 5db946f9db
3 changed files with 118 additions and 94 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
Day4/pin_irq_example.c
View File

@ -12,8 +12,11 @@
#define KEY_LEFT GET_PIN(C, 0) #define KEY_LEFT GET_PIN(C, 0)
#define KEY_RIGHT GET_PIN(C, 4) #define KEY_RIGHT GET_PIN(C, 4)
extern rt_atomic_t now_direction ; extern rt_atomic_t now_direction ;
void key_up_callback(void *args) extern rt_atomic_t snake_pressed ;
extern int snake_max;
void key_up_callback(void *args)
{ {
rt_atomic_store(&snake_pressed, snake_max+1);
if(rt_atomic_load(&now_direction) != 2) rt_atomic_store(&now_direction, 0); if(rt_atomic_load(&now_direction) != 2) rt_atomic_store(&now_direction, 0);
int value = rt_pin_read(KEY_UP); int value = rt_pin_read(KEY_UP);
LOG_I("key up value: %d\n", value); LOG_I("key up value: %d\n", value);
@ -21,6 +24,7 @@ void key_up_callback(void *args)
void key_down_callback(void *args) void key_down_callback(void *args)
{ {
rt_atomic_store(&snake_pressed, snake_max+1);
int value = rt_pin_read(KEY_DOWN); int value = rt_pin_read(KEY_DOWN);
if(rt_atomic_load(&now_direction) != 0) rt_atomic_store(&now_direction, 2); if(rt_atomic_load(&now_direction) != 0) rt_atomic_store(&now_direction, 2);
LOG_I("key down value: %d\n", value); LOG_I("key down value: %d\n", value);
@ -28,6 +32,7 @@ void key_down_callback(void *args)
void key_left_callback(void *args) void key_left_callback(void *args)
{ {
rt_atomic_store(&snake_pressed, snake_max+1);
if(rt_atomic_load(&now_direction) != 3) rt_atomic_store(&now_direction, 1); if(rt_atomic_load(&now_direction) != 3) rt_atomic_store(&now_direction, 1);
int value = rt_pin_read(KEY_LEFT); int value = rt_pin_read(KEY_LEFT);
LOG_I("key left value: %d\n", value); LOG_I("key left value: %d\n", value);
@ -35,6 +40,7 @@ void key_left_callback(void *args)
void key_right_callback(void *args) void key_right_callback(void *args)
{ {
rt_atomic_store(&snake_pressed, snake_max+1);
if(rt_atomic_load(&now_direction) != 1) rt_atomic_store(&now_direction, 3); if(rt_atomic_load(&now_direction) != 1) rt_atomic_store(&now_direction, 3);
int value = rt_pin_read(KEY_RIGHT); int value = rt_pin_read(KEY_RIGHT);
LOG_I("key right value: %d\n", value); LOG_I("key right value: %d\n", value);

177
dayandnight/myproject.c
View File

@ -11,7 +11,6 @@
#include <drv_lcd.h> #include <drv_lcd.h>
#include "mysnake.h" #include "mysnake.h"
char DEMO_PRODUCT_KEY[IOTX_PRODUCT_KEY_LEN + 1] = {0}; char DEMO_PRODUCT_KEY[IOTX_PRODUCT_KEY_LEN + 1] = {0};
char DEMO_DEVICE_NAME[IOTX_DEVICE_NAME_LEN + 1] = {0}; char DEMO_DEVICE_NAME[IOTX_DEVICE_NAME_LEN + 1] = {0};
char DEMO_DEVICE_SECRET[IOTX_DEVICE_SECRET_LEN + 1] = {0}; char DEMO_DEVICE_SECRET[IOTX_DEVICE_SECRET_LEN + 1] = {0};
@ -25,17 +24,17 @@ int HAL_GetDeviceSecret(char device_secret[IOTX_DEVICE_SECRET_LEN]);
uint64_t HAL_UptimeMs(void); uint64_t HAL_UptimeMs(void);
int HAL_Snprintf(char *str, const int len, const char *fmt, ...); int HAL_Snprintf(char *str, const int len, const char *fmt, ...);
//定义接受文件内容的缓冲区 // 定义接受文件内容的缓冲区
char buffer[1026] = {}; char buffer[1026] = {};
char tmp[1026]; char tmp[1026];
extern int snake_len;
#define GPIO_LED_B GET_PIN(F,11) #define GPIO_LED_B GET_PIN(F, 11)
#define GPIO_LED_R GET_PIN(F,12) #define GPIO_LED_R GET_PIN(F, 12)
// AHT挂载的总线名字 // AHT挂载的总线名字
#define AHT10_I2C_BUS "i2c3" #define AHT10_I2C_BUS "i2c3"
// AHT,ap3216c设备指针 // AHT,ap3216c设备指针
aht10_device_t Dev = RT_NULL; aht10_device_t Dev = RT_NULL;
ap3216c_device_t dev; ap3216c_device_t dev;
@ -51,39 +50,41 @@ void ath_init(void);
void mqt_init(void); void mqt_init(void);
int ap3_init(void); int ap3_init(void);
#define EXAMPLE_TRACE(fmt, ...) \ #define EXAMPLE_TRACE(fmt, ...) \
do { \ do \
{ \
HAL_Printf("%s|%03d :: ", __func__, __LINE__); \ HAL_Printf("%s|%03d :: ", __func__, __LINE__); \
HAL_Printf(fmt, ##__VA_ARGS__); \ HAL_Printf(fmt, ##__VA_ARGS__); \
HAL_Printf("%s", "\r\n"); \ HAL_Printf("%s", "\r\n"); \
} while(0) } while (0)
static void example_message_arrive(void *pcontext, void *pclient, iotx_mqtt_event_msg_pt msg) static void example_message_arrive(void *pcontext, void *pclient, iotx_mqtt_event_msg_pt msg)
{ {
iotx_mqtt_topic_info_t *topic_info = (iotx_mqtt_topic_info_pt) msg->msg; iotx_mqtt_topic_info_t *topic_info = (iotx_mqtt_topic_info_pt)msg->msg;
switch (msg->event_type) { switch (msg->event_type)
case IOTX_MQTT_EVENT_PUBLISH_RECEIVED: {
/* print topic name and topic message */ case IOTX_MQTT_EVENT_PUBLISH_RECEIVED:
EXAMPLE_TRACE("Message Arrived:"); /* print topic name and topic message */
rt_pin_mode(GPIO_LED_R, PIN_MODE_OUTPUT); EXAMPLE_TRACE("Message Arrived:");
//topic_info->payload 为发送的内容，可以据此设置命令 rt_pin_mode(GPIO_LED_R, PIN_MODE_OUTPUT);
if(rt_pin_read(GPIO_LED_R) == PIN_HIGH) // topic_info->payload 为发送的内容，可以据此设置命令
{ if (rt_pin_read(GPIO_LED_R) == PIN_HIGH)
// rt_kprintf("LED_R should be ON\n"); {
rt_pin_write(GPIO_LED_R, PIN_LOW); // rt_kprintf("LED_R should be ON\n");
} rt_pin_write(GPIO_LED_R, PIN_LOW);
else }
{ else
// rt_kprintf("LED_R should be OFF\n"); {
rt_pin_write(GPIO_LED_R, PIN_HIGH); // rt_kprintf("LED_R should be OFF\n");
} rt_pin_write(GPIO_LED_R, PIN_HIGH);
EXAMPLE_TRACE("Topic : %.*s", topic_info->topic_len, topic_info->ptopic); }
EXAMPLE_TRACE("Payload: %.*s", topic_info->payload_len, topic_info->payload); EXAMPLE_TRACE("Topic : %.*s", topic_info->topic_len, topic_info->ptopic);
EXAMPLE_TRACE("\n"); EXAMPLE_TRACE("Payload: %.*s", topic_info->payload_len, topic_info->payload);
break; EXAMPLE_TRACE("\n");
default: break;
break; default:
break;
} }
} }
@ -96,7 +97,8 @@ static int example_subscribe(void *handle)
topic_len = strlen(fmt) + strlen(DEMO_PRODUCT_KEY) + strlen(DEMO_DEVICE_NAME) + 1; topic_len = strlen(fmt) + strlen(DEMO_PRODUCT_KEY) + strlen(DEMO_DEVICE_NAME) + 1;
topic = HAL_Malloc(topic_len); topic = HAL_Malloc(topic_len);
if (topic == NULL) { if (topic == NULL)
{
EXAMPLE_TRACE("memory not enough"); EXAMPLE_TRACE("memory not enough");
return -1; return -1;
} }
@ -104,7 +106,8 @@ static int example_subscribe(void *handle)
HAL_Snprintf(topic, topic_len, fmt, DEMO_PRODUCT_KEY, DEMO_DEVICE_NAME); HAL_Snprintf(topic, topic_len, fmt, DEMO_PRODUCT_KEY, DEMO_DEVICE_NAME);
res = IOT_MQTT_Subscribe(handle, topic, IOTX_MQTT_QOS0, example_message_arrive, NULL); res = IOT_MQTT_Subscribe(handle, topic, IOTX_MQTT_QOS0, example_message_arrive, NULL);
if (res < 0) { if (res < 0)
{
EXAMPLE_TRACE("subscribe failed"); EXAMPLE_TRACE("subscribe failed");
HAL_Free(topic); HAL_Free(topic);
return -1; return -1;
@ -116,7 +119,7 @@ static int example_subscribe(void *handle)
int plus_lcd_y(int pls) int plus_lcd_y(int pls)
{ {
int_tmp = lcd_y; int_tmp = lcd_y;
lcd_y+=pls; lcd_y += pls;
return int_tmp; return int_tmp;
} }
void easy_show_lcd(char *title, float Temp) void easy_show_lcd(char *title, float Temp)
@ -147,49 +150,49 @@ void show_lcd()
void make_file() void make_file()
{ {
//文件描述符 // 文件描述符
int fd; int fd;
//用只写方式打开文件,如果没有该文件,则创建一个文件 // 用只写方式打开文件,如果没有该文件,则创建一个文件
fd = open("/fal/test/Data.txt", O_WRONLY | O_CREAT | O_APPEND); //和原来相比，只是把O_TRUNC参数更改为O_APPEND，即更改为打开后，如果再进行写入，将从文件的末尾位置开始写。 fd = open("/fal/test/Data.txt", O_WRONLY | O_CREAT | O_APPEND); // 和原来相比，只是把O_TRUNC参数更改为O_APPEND，即更改为打开后，如果再进行写入，将从文件的末尾位置开始写。
// rt_kprintf("\n%f %f tmp:%s\n",Humi,Temp,String); // rt_kprintf("\n%f %f tmp:%s\n",Humi,Temp,String);
//如果打开成功 // 如果打开成功
if (fd >= 0) if (fd >= 0)
{ {
//写入文件 // 写入文件
write(fd, tmp, sizeof(tmp)); write(fd, tmp, sizeof(tmp));
// rt_kprintf("Write done.\n"); // rt_kprintf("Write done.\n");
//关闭文件 // 关闭文件
close(fd); close(fd);
} }
else else
{ {
rt_kprintf("File Open Fail.\n"); rt_kprintf("File Open Fail.\n");
} }
return; return;
} }
int cnt = 0; int cnt = 0;
void tmp_payload(void) void tmp_payload(void)
{ {
// 读取温湿度值 // 读取温湿度值
Humi = aht10_read_humidity(Dev); Humi = aht10_read_humidity(Dev);
Temp = aht10_read_temperature(Dev); Temp = aht10_read_temperature(Dev);
brightness = ap3216c_read_ambient_light(dev); brightness = ap3216c_read_ambient_light(dev);
ps_data = ap3216c_read_ps_data(dev); ps_data = ap3216c_read_ps_data(dev);
// icm20608_get_accel(icm20608_device_t dev, rt_int16_t *accel_x, rt_int16_t *accel_y, rt_int16_t *accel_z) // icm20608_get_accel(icm20608_device_t dev, rt_int16_t *accel_x, rt_int16_t *accel_y, rt_int16_t *accel_z)
// memset(tmp, 0, sizeof(tmp)); // memset(tmp, 0, sizeof(tmp));
// sprintf(tmp, "Temp: %.1f;Humi: %.1f;Count: %d\n", Temp, Humi,++cnt); // sprintf(tmp, "Temp: %.1f;Humi: %.1f;Count: %d\n", Temp, Humi,++cnt);
// rt_kprintf("\n%f %f tmp:%s\n",Humi,Temp,tmp); // rt_kprintf("\n%f %f tmp:%s\n",Humi,Temp,tmp);
// make_file(); // make_file();
show_lcd(); // show_lcd();
sprintf(tmp, "{\"params\":{\"temperature\":%.2f,\"humidity\":%.2f,,\"LightLux\":%.2f,\"Psdata\":%d}}", Temp, Humi,brightness,ps_data); sprintf(tmp, "{\"params\":{\"temperature\":%.2f,\"humidity\":%.2f,\"LightLux\":%.2f,\"Psdata\":%d,\"Snakelen\":%d}}", Temp, Humi, brightness, ps_data, snake_len);
return; return;
} }
void test_lcd() void test_lcd()
{ {
// show_str(10, 10+24+32+24+32, 100, 32, "你好", 32); // show_str(10, 10+24+32+24+32, 100, 32, "你好", 32);
ath_init(); ath_init();
ap3_init(); ap3_init();
while(1) while (1)
{ {
tmp_payload(); tmp_payload();
rt_thread_mdelay(100); rt_thread_mdelay(100);
@ -198,20 +201,20 @@ void test_lcd()
MSH_CMD_EXPORT(test_lcd, run my project); MSH_CMD_EXPORT(test_lcd, run my project);
static int example_publish(void *handle) static int example_publish(void *handle)
{ {
tmp_payload(); tmp_payload();
int res = 0; int res = 0;
const char *fmt = "/sys/%s/%s/thing/event/property/post"; const char *fmt = "/sys/%s/%s/thing/event/property/post";
// /k1lyriw1yGj/${deviceName}/user/get // /k1lyriw1yGj/${deviceName}/user/get
char *topic = NULL; char *topic = NULL;
int topic_len = 0; int topic_len = 0;
char *payload = tmp; char *payload = tmp;
// strcpy(payload,tmp_payload()); // strcpy(payload,tmp_payload());
// rt_kprintf("payload:%s\n",payload); // rt_kprintf("payload:%s\n",payload);
topic_len = strlen(fmt) + strlen(DEMO_PRODUCT_KEY) + strlen(DEMO_DEVICE_NAME) + 1; topic_len = strlen(fmt) + strlen(DEMO_PRODUCT_KEY) + strlen(DEMO_DEVICE_NAME) + 1;
topic = HAL_Malloc(topic_len); topic = HAL_Malloc(topic_len);
if (topic == NULL) { if (topic == NULL)
{
EXAMPLE_TRACE("memory not enough"); EXAMPLE_TRACE("memory not enough");
return -1; return -1;
} }
@ -219,7 +222,8 @@ static int example_publish(void *handle)
HAL_Snprintf(topic, topic_len, fmt, DEMO_PRODUCT_KEY, DEMO_DEVICE_NAME); HAL_Snprintf(topic, topic_len, fmt, DEMO_PRODUCT_KEY, DEMO_DEVICE_NAME);
res = IOT_MQTT_Publish_Simple(0, topic, IOTX_MQTT_QOS0, payload, strlen(payload)); res = IOT_MQTT_Publish_Simple(0, topic, IOTX_MQTT_QOS0, payload, strlen(payload));
if (res < 0) { if (res < 0)
{
EXAMPLE_TRACE("publish failed, res = %d", res); EXAMPLE_TRACE("publish failed, res = %d", res);
HAL_Free(topic); HAL_Free(topic);
return -1; return -1;
@ -236,10 +240,10 @@ static void example_event_handle(void *pcontext, void *pclient, iotx_mqtt_event_
static void mqtt_example_main(void *parameter) static void mqtt_example_main(void *parameter)
{ {
void *pclient = NULL; void *pclient = NULL;
int res = 0; int res = 0;
int loop_cnt = 0; int loop_cnt = 0;
iotx_mqtt_param_t mqtt_params; iotx_mqtt_param_t mqtt_params;
HAL_GetProductKey(DEMO_PRODUCT_KEY); HAL_GetProductKey(DEMO_PRODUCT_KEY);
HAL_GetDeviceName(DEMO_DEVICE_NAME); HAL_GetDeviceName(DEMO_DEVICE_NAME);
@ -247,25 +251,28 @@ static void mqtt_example_main(void *parameter)
EXAMPLE_TRACE("mqtt example"); EXAMPLE_TRACE("mqtt example");
memset(&mqtt_params, 0x0, sizeof(mqtt_params)); memset(&mqtt_params, 0x0, sizeof(mqtt_params));
mqtt_params.handle_event.h_fp = example_event_handle; mqtt_params.handle_event.h_fp = example_event_handle;
pclient = IOT_MQTT_Construct(&mqtt_params); pclient = IOT_MQTT_Construct(&mqtt_params);
if (NULL == pclient) { if (NULL == pclient)
{
EXAMPLE_TRACE("MQTT construct failed"); EXAMPLE_TRACE("MQTT construct failed");
return ; return;
} }
res = example_subscribe(pclient); res = example_subscribe(pclient);
if (res < 0) { if (res < 0)
{
IOT_MQTT_Destroy(&pclient); IOT_MQTT_Destroy(&pclient);
return ; return;
} }
while (1) { while (1)
if (0 == loop_cnt % 20) { {
if (0 == loop_cnt % 20)
{
example_publish(pclient); example_publish(pclient);
} }
@ -274,10 +281,9 @@ static void mqtt_example_main(void *parameter)
loop_cnt += 1; loop_cnt += 1;
} }
return ; return;
} }
#define THREAD_PRIORITY 25 #define THREAD_PRIORITY 25
#define THREAD_STACK_SIZE 4096 #define THREAD_STACK_SIZE 4096
#define THREAD_TIMESLICE 5 #define THREAD_TIMESLICE 5
@ -308,8 +314,9 @@ void mqt_init(void)
rt_kprintf("MQTT Thread Create Failed!\n"); rt_kprintf("MQTT Thread Create Failed!\n");
} }
} }
int ap3_init(void){ int ap3_init(void)
const char* i2c_bus_name = "i2c2"; {
const char *i2c_bus_name = "i2c2";
dev = ap3216c_init(i2c_bus_name); dev = ap3216c_init(i2c_bus_name);
@ -341,9 +348,9 @@ MSH_CMD_EXPORT_ALIAS(snk_init, snake, "snake game");
void my_project(void) void my_project(void)
{ {
ath_init(); ath_init();
mqt_init(); mqt_init();
ap3_init(); ap3_init();
} }
MSH_CMD_EXPORT_ALIAS(my_project,myproject, run my project); MSH_CMD_EXPORT_ALIAS(my_project, myproject, run my project);

27
dayandnight/mysnake.c
View File

@ -10,6 +10,9 @@
#define SNAKE_SIZE 20 #define SNAKE_SIZE 20
#define SNAKE_MAX LCD_MAX / SNAKE_SIZE #define SNAKE_MAX LCD_MAX / SNAKE_SIZE
rt_atomic_t now_direction = 3; rt_atomic_t now_direction = 3;
rt_atomic_t snake_pressed = 0;
int snake_max = SNAKE_MAX * 3;
int snake_len = 3;
// bool snake_table[SNAKE_MAX][SNAKE_MAX] = {0}; // bool snake_table[SNAKE_MAX][SNAKE_MAX] = {0};
// struct My_snake // struct My_snake
@ -32,8 +35,7 @@ void snake_entry(void *parameter)
bool food_flag = false; bool food_flag = false;
char snake_dirshow[4][7] = {"upup", "left", "down", "rigt"}; char snake_dirshow[4][7] = {"upup", "left", "down", "rigt"};
char tmp[10]; char tmp[10];
int snake_head = 2, snake_tail = 0, former_head; // 蛇头，蛇尾 int snake_head = 2, snake_tail = 0; // 蛇头，蛇尾
int snake_len = 3;
snake_list[1][0] = SNAKE_MAX / 2; snake_list[1][0] = SNAKE_MAX / 2;
snake_list[1][1] = SNAKE_MAX / 2; snake_list[1][1] = SNAKE_MAX / 2;
snake_list[0][0] = snake_list[1][0] - 1; snake_list[0][0] = snake_list[1][0] - 1;
@ -50,13 +52,22 @@ void snake_entry(void *parameter)
snake_food[1] = rand() % SNAKE_MAX; snake_food[1] = rand() % SNAKE_MAX;
snake_address(snake_food[0], snake_food[1], SNAKE_SIZE, GREEN); snake_address(snake_food[0], snake_food[1], SNAKE_SIZE, GREEN);
int new_head_x = 0, new_head_y = 0; int new_head_x = 0, new_head_y = 0;
int new_direction = 0;
while (1) while (1)
{ {
// if(snake) if (!snake_pressed)
// new_direction = rand() % 3; {
// now_direction = (now_direction+3+new_direction)%4;//防止反向,走回头路 //80%的概率保持当前方向，20%的概率随机改变方向
if (rand() % 100 < 20)
former_head = snake_head; {
new_direction = rand() % 3;
now_direction = (now_direction + 3 + new_direction) % 4; // 防止反向,走回头路
}
}
else
{
rt_atomic_add(&snake_pressed, -1);
}
new_head_x = (snake_list[snake_head][0] + snake_direction[now_direction][0] + SNAKE_MAX) % (SNAKE_MAX); new_head_x = (snake_list[snake_head][0] + snake_direction[now_direction][0] + SNAKE_MAX) % (SNAKE_MAX);
new_head_y = (snake_list[snake_head][1] + snake_direction[now_direction][1] + SNAKE_MAX) % (SNAKE_MAX); new_head_y = (snake_list[snake_head][1] + snake_direction[now_direction][1] + SNAKE_MAX) % (SNAKE_MAX);
@ -85,7 +96,7 @@ void snake_entry(void *parameter)
else else
{ {
if (snake_list[snake_tail][0] == snake_food[0] && snake_list[snake_tail][1] == snake_food[1]) if (snake_list[snake_tail][0] == snake_food[0] && snake_list[snake_tail][1] == snake_food[1])
{ {
} }
else else
{ {