chengzhi
/
incubator_embeded
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases 1 Wiki Activity

改用定时器发送传感器数据请求命令和环境参数同步命令。尝试将数据同步到串口屏的数据，改为有差异才同步

Browse Source
main
Zeng wei (曾威) 2 years ago
parent 82badf0a0b
commit 68c33afc88
14 changed files with 1771 additions and 1486 deletions
Show Stats Download Patch File Download Diff File

6
.vscode/settings.json vendored
Unescape View File

@ -0,0 +1,6 @@
{
"files.associations": {
"w25q128_ins.h": "c",
"usart.h": "c"
}
}

8
HARDWARE/PID.c
Unescape View File

@ -19,9 +19,11 @@ int max_speed_count = 6000;
void PID_Init()
{
// pid.set_tem=tem;// user set temperature
pid.Kp = 110;
pid.Ki = 0.001;
pid.Kd = 340;
// if flash have not a vaild value, just set a default value
if (pid.Kp < 1e-7) { pid.Kp = 110; }
if (pid.Ki < 1e-7) { pid.Ki = 0.001; }
if (pid.Kd < 1e-7) { pid.Kd = 340; }
pid.t = 500; // PID calc period
// pid.Ti=5000000;// integral time
// pid.Td=1000;// differential time

18
HARDWARE/PID.h
Unescape View File

@ -8,19 +8,19 @@ void PID_Calc(void);
typedef struct Pid
{
float set_tem;//用户设定值
float now_tem;//当前温度
float set_tem;// User settings
float now_tem;// current temperature
float Kp; // 110
int t; //PID计算周期--采样周期
float Ti;
float Td;
float Ki; // 0.001
float Kd; // 340
int t; // PID calculation cycle - sampling cycle
float Ti;
float Td;
float Ek; //本次偏差
float Ek_1;//上次偏差
float SEk; //历史偏差之和
float Ek; // This deviation
float Ek_1;// Last deviation
float SEk; // The sum of historical deviations
float Iout;
float Pout;
@ -32,7 +32,7 @@ typedef struct Pid
int C1ms;
int pwmcycle;//pwm周期
int pwmcycle;// PWM cycle
int times;
}PID;

10
HARDWARE/bufcut.c
Unescape View File

@ -2,14 +2,16 @@
#include <stdio.h>
#include "rs485.h"
//u8 rx_buf[64];
extern u8 RS485_RX_BUF_COPY[128];
void bufcut_Init(u8 *RX_BUF,u8 *CUT_RX_BUF,u8 start_index, u8 end_index)
void bufcut_Init(u8 *TARGET_RX_BUF,u8 *SOURCE_CUT_RX_BUF,u8 start_index, u8 end_index)
{
int i, j = 0;
for (i = start_index; i < end_index; i++)
{
RX_BUF[j] = CUT_RX_BUF[i];
TARGET_RX_BUF[j] = SOURCE_CUT_RX_BUF[i];
j++;
}
}
@ -17,14 +19,14 @@ void bufcut_Init(u8 *RX_BUF,u8 *CUT_RX_BUF,u8 start_index, u8 end_index)
void RX_BUF_Init(void)
{
int i=0;
for(i=0;i<64;i++)
for(i=0;i<128;i++)
{
RS485_RX_BUF[i]=0;
}
}
void RX_BUF_ZERO(u8 num)//把处理过的数组变为0
void RX_BUF_ZERO(u8 num)// set RS485_RX_BUF_COPY to 0
{
for(int i=0;i<num;i++)
{

2
HARDWARE/bufcut.h
Unescape View File

@ -3,7 +3,7 @@
#include "system.h"
u8 bufcut_Init(u8 *RX_BUF,u8 *CUT_RX_BUF,u8 start_index, u8 end_index);
u8 bufcut_Init(u8 *TARGET_RX_BUF,u8 *SOURCE_CUT_RX_BUF,u8 start_index, u8 end_index);
void RX_BUF_Init(void);
void RX_BUF_ZERO(u8 num);
void RX_BUF_Transfer(u8 zero,u8 transfer_num);

341
HARDWARE/rs485.c
Unescape View File

@ -4,8 +4,10 @@
#include "Relays.h"
#include "myfreertos.h"
u8 prev_sendbuf[37] = {0xEE, 0xB5, 0x05, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00,
0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0xFF, 0xFC, 0xFF, 0xFF};
u8 sendbuf[37] = {0xEE, 0xB5, 0x05, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00,
0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0xFF, 0xFC, 0xFF, 0xFF}; // 发送给串口屏的实时数据
0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0xFF, 0xFC, 0xFF, 0xFF};
u8 sendbuf_crc[20] = {0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00,
0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00};
extern u8 global_buffer[64];
@ -55,7 +57,7 @@ extern PID pid;
// extern u8 white_light2;
// extern u8 blue_light1;
// extern u8 blue_light2;
// CRC校验 自己后面添加的
// CRC verifies the information added later on
const u8 auchCRCHi[] = {
0x00, 0xC1, 0x81, 0x40, 0x01, 0xC0, 0x80, 0x41, 0x01, 0xC0, 0x80, 0x41, 0x00, 0xC1, 0x81, 0x40, 0x01, 0xC0, 0x80, 0x41,
0x00, 0xC1, 0x81, 0x40, 0x00, 0xC1, 0x81, 0x40, 0x01, 0xC0, 0x80, 0x41, 0x01, 0xC0, 0x80, 0x41, 0x00, 0xC1, 0x81, 0x40,
@ -86,11 +88,29 @@ const u8 auchCRCLo[] = {
0x99, 0x59, 0x58, 0x98, 0x88, 0x48, 0x49, 0x89, 0x4B, 0x8B, 0x8A, 0x4A, 0x4E, 0x8E, 0x8F, 0x4F, 0x8D, 0x4D, 0x4C, 0x8C,
0x44, 0x84, 0x85, 0x45, 0x87, 0x47, 0x46, 0x86, 0x82, 0x42, 0x43, 0x83, 0x41, 0x81, 0x80, 0x40};
u8 RS485_RX_BUF[128]; // 接收缓冲,最大64个字节.
u8 RS485_RX_BUF[128];
u8 RS485_RX_CNT = 0; // 接收到的数据长度
u8 RS485_RX_CNT = 0;
u8 RS485_RX_Flag = 0; // 接收到的数据标志
u8 RS485_RX_Flag = 0;
/**
* return 1 if diff, 0 if same
*/
u8 cmp_str(u8 *prev, u8*curr, u8 len) {
for (u8 i = 0; i < len; i++) {
if (prev[i] != curr[i]) {
return 1;
}
}
return 0;
}
void cp_str_to_prev(u8 *prev, u8*curr, u8 len) {
for (u8 i = 0; i < len; i++) {
prev[i] = curr[i];
}
}
void GetCRC16(u8 *puchMsg, u16 usDataLen, u8 *uchCRCHi, u8 *uchCRCLo)
{
@ -105,7 +125,10 @@ void GetCRC16(u8 *puchMsg, u16 usDataLen, u8 *uchCRCHi, u8 *uchCRCLo)
}
// return ((uchCRCHi<< 8) | (uchCRCLo)) ;
}
// 查表法计算CRC值并且校验
/**
* Calculate CRC value using lookup table method and verify
* @return int 1 means success, 0 means false
*/
u8 CRC16_check(u8 *puchMsg, u16 usDataLen)
{
u8 uchCRCHi = 0xFF;
@ -119,7 +142,6 @@ u8 CRC16_check(u8 *puchMsg, u16 usDataLen)
}
if (uchCRCHi == *puchMsg++ && uchCRCLo == *puchMsg++)
{
// printf("CRC 校验成功\r\n"); // 调试使用
return 1;
}
else
@ -129,13 +151,13 @@ void USART1_IRQHandler(void)
{
u8 res;
if (USART_GetITStatus(USART1, USART_IT_RXNE) != RESET) // 接收到数据
if (USART_GetITStatus(USART1, USART_IT_RXNE) != RESET) // receive data
{
res = USART_ReceiveData(USART1); // 读取接收到的数据
res = USART_ReceiveData(USART1); // read received data
if (RS485_RX_CNT < 128)
{
RS485_RX_BUF[RS485_RX_CNT] = res; // 记录接收到的值
RS485_RX_CNT++; // 接收数据增加1
RS485_RX_BUF[RS485_RX_CNT] = res; // Record received values
RS485_RX_CNT++; // Received data count increased by 1
}
}
}
@ -143,189 +165,185 @@ void USART1_IRQHandler(void)
void SN74CB3Q3253_Init(void)
{
RCC_APB2PeriphClockCmd(RCC_APB2Periph_GPIOB, ENABLE); // 使能PB端口时钟
RCC_APB2PeriphClockCmd(RCC_APB2Periph_GPIOB, ENABLE);
GPIO_InitTypeDef GPIO_InitStructure;
GPIO_InitStructure.GPIO_Pin = GPIO_Pin_5 | GPIO_Pin_6 | GPIO_Pin_7; // PB5 PB6 PB7 端口配置, 推挽输出
GPIO_InitStructure.GPIO_Mode = GPIO_Mode_Out_PP; // 推挽输出
GPIO_InitStructure.GPIO_Speed = GPIO_Speed_50MHz; // IO口速度为50MHz
GPIO_Init(GPIOB, &GPIO_InitStructure); // 推挽输出 ，IO口速度为50MHz
GPIO_ResetBits(GPIOB, GPIO_Pin_7); // PB7输出低
GPIO_InitStructure.GPIO_Pin = GPIO_Pin_5 | GPIO_Pin_6 | GPIO_Pin_7; // PB5 PB6 PB7
GPIO_InitStructure.GPIO_Mode = GPIO_Mode_Out_PP;
GPIO_InitStructure.GPIO_Speed = GPIO_Speed_50MHz; // IO??????50MHz
GPIO_Init(GPIOB, &GPIO_InitStructure);
GPIO_ResetBits(GPIOB, GPIO_Pin_7); // PB7?????
}
// RS485_1_Init->J6 ，PB5->S1,PB6->S0,PB7->USART_OE
// SN74CB3Q3253多路复用器 - 多路信号分离器的引脚配置为OE S1 S0对应的值为001，使1B2 2B2响应
// 初始化IO 串口1
// pclk1:PCLK1时钟频率(Mhz)
// bound:波特率
// RS485_1_Init->J6 ??PB5->S1,PB6->S0,PB7->USART_OE
// SN74CB3Q3253??¡¤?????? - ??¡¤???????????????????OE S1 S0???????001???1B2 2B2???
// pclk1:PCLK1??????(Mhz)
// bound:??????
void RS485_1_Init(u32 bound)
{
SN74CB3Q3253_Init();
GPIO_ResetBits(GPIOB, GPIO_Pin_5); // S1配置为低电平
GPIO_SetBits(GPIOB, GPIO_Pin_6); // S0配置为高电平
GPIO_ResetBits(GPIOB, GPIO_Pin_5); // S1?????????
GPIO_SetBits(GPIOB, GPIO_Pin_6); // S0?????????
GPIO_InitTypeDef GPIO_InitStructure;
USART_InitTypeDef USART_InitStructure;
NVIC_InitTypeDef NVIC_InitStructure;
RCC_APB2PeriphClockCmd(RCC_APB2Periph_GPIOA | RCC_APB2Periph_GPIOB, ENABLE); // 使能GPIOA,D时钟
RCC_APB2PeriphClockCmd(RCC_APB2Periph_USART1, ENABLE); // 使能USART1时钟
RCC_APB2PeriphClockCmd(RCC_APB2Periph_GPIOA | RCC_APB2Periph_GPIOB, ENABLE);
RCC_APB2PeriphClockCmd(RCC_APB2Periph_USART1, ENABLE);
GPIO_InitStructure.GPIO_Pin = GPIO_Pin_11; // 端口配置
GPIO_InitStructure.GPIO_Mode = GPIO_Mode_Out_PP; // 推挽输出
GPIO_InitStructure.GPIO_Pin = GPIO_Pin_11;
GPIO_InitStructure.GPIO_Mode = GPIO_Mode_Out_PP;
GPIO_InitStructure.GPIO_Speed = GPIO_Speed_50MHz;
GPIO_Init(GPIOB, &GPIO_InitStructure);
GPIO_InitStructure.GPIO_Pin = GPIO_Pin_9; // PA9
GPIO_InitStructure.GPIO_Mode = GPIO_Mode_AF_PP; // 复用推挽
GPIO_InitStructure.GPIO_Mode = GPIO_Mode_AF_PP;
GPIO_Init(GPIOA, &GPIO_InitStructure);
GPIO_InitStructure.GPIO_Pin = GPIO_Pin_10; // PA10
GPIO_InitStructure.GPIO_Mode = GPIO_Mode_IN_FLOATING; // 浮空输入
GPIO_InitStructure.GPIO_Mode = GPIO_Mode_IN_FLOATING;
GPIO_Init(GPIOA, &GPIO_InitStructure);
RCC_APB2PeriphResetCmd(RCC_APB2Periph_USART1, ENABLE); // 复位串口1
RCC_APB2PeriphResetCmd(RCC_APB2Periph_USART1, DISABLE); // 停止复位
RCC_APB2PeriphResetCmd(RCC_APB2Periph_USART1, ENABLE);
RCC_APB2PeriphResetCmd(RCC_APB2Periph_USART1, DISABLE);
USART_InitStructure.USART_BaudRate = bound; // 波特率设置
USART_InitStructure.USART_WordLength = USART_WordLength_8b; // 8位数据长度
USART_InitStructure.USART_StopBits = USART_StopBits_1; // 一个停止位
USART_InitStructure.USART_Parity = USART_Parity_No; /// 奇偶校验位
USART_InitStructure.USART_HardwareFlowControl = USART_HardwareFlowControl_None; // 无硬件数据流控制
USART_InitStructure.USART_Mode = USART_Mode_Rx | USART_Mode_Tx; // 收发模式
USART_InitStructure.USART_BaudRate = bound;
USART_InitStructure.USART_WordLength = USART_WordLength_8b;
USART_InitStructure.USART_StopBits = USART_StopBits_1;
USART_InitStructure.USART_Parity = USART_Parity_No;
USART_InitStructure.USART_HardwareFlowControl = USART_HardwareFlowControl_None;
USART_InitStructure.USART_Mode = USART_Mode_Rx | USART_Mode_Tx;
USART_Init(USART1, &USART_InitStructure);
; // 初始化串口
;
NVIC_InitStructure.NVIC_IRQChannel = USART1_IRQn; // 使能串口1中断
NVIC_InitStructure.NVIC_IRQChannelPreemptionPriority = 0; // 先占优先级2级
// NVIC_InitStructure.NVIC_IRQChannelSubPriority = 3; //从优先级2级
NVIC_InitStructure.NVIC_IRQChannelCmd = ENABLE; // 使能外部中断通道
NVIC_Init(&NVIC_InitStructure); // 根据NVIC_InitStruct中指定的参数初始化外设NVIC寄存器
NVIC_InitStructure.NVIC_IRQChannel = USART1_IRQn;
NVIC_InitStructure.NVIC_IRQChannelPreemptionPriority = 0;
// NVIC_InitStructure.NVIC_IRQChannelSubPriority = 3; //???????2??
NVIC_InitStructure.NVIC_IRQChannelCmd = ENABLE;
NVIC_Init(&NVIC_InitStructure);
USART_ITConfig(USART1, USART_IT_RXNE, ENABLE); // 开启中断
USART_Cmd(USART1, ENABLE); // 使能串口
USART_ITConfig(USART1, USART_IT_RXNE, ENABLE);
USART_Cmd(USART1, ENABLE);
RS485_1_TX_EN = 0; // 默认为接收模式
RS485_1_TX_EN = 0;
}
// RS485_2_Init->J7 ，PB5->S1,PB6->S0,PB7->USART_OE
// SN74CB3Q3253多路复用器 - 多路信号分离器的引脚配置为OE S1 S0对应的值为000，使1B1 2B1响应
// RS485_2_Init->J7 ??PB5->S1,PB6->S0,PB7->USART_OE
// SN74CB3Q3253??¡¤?????? - ??¡¤???????????????????OE S1 S0???????000???1B1 2B1???
void RS485_2_Init(u32 bound)
{
SN74CB3Q3253_Init();
GPIO_ResetBits(GPIOB, GPIO_Pin_5 | GPIO_Pin_6); // S1,S0配置为低电平
GPIO_ResetBits(GPIOB, GPIO_Pin_5 | GPIO_Pin_6);
GPIO_InitTypeDef GPIO_InitStructure;
USART_InitTypeDef USART_InitStructure;
NVIC_InitTypeDef NVIC_InitStructure;
RCC_APB2PeriphClockCmd(RCC_APB2Periph_GPIOA | RCC_APB2Periph_GPIOB, ENABLE); // 使能GPIOA,D时钟
RCC_APB2PeriphClockCmd(RCC_APB2Periph_USART1, ENABLE); // 使能USART1时钟
RCC_APB2PeriphClockCmd(RCC_APB2Periph_GPIOA | RCC_APB2Periph_GPIOB, ENABLE);
RCC_APB2PeriphClockCmd(RCC_APB2Periph_USART1, ENABLE);
GPIO_InitStructure.GPIO_Pin = GPIO_Pin_10; // 端口配置
GPIO_InitStructure.GPIO_Mode = GPIO_Mode_Out_PP; // 推挽输出
GPIO_InitStructure.GPIO_Pin = GPIO_Pin_10;
GPIO_InitStructure.GPIO_Mode = GPIO_Mode_Out_PP;
GPIO_InitStructure.GPIO_Speed = GPIO_Speed_50MHz;
GPIO_Init(GPIOB, &GPIO_InitStructure);
GPIO_InitStructure.GPIO_Pin = GPIO_Pin_9; // PA9
GPIO_InitStructure.GPIO_Mode = GPIO_Mode_AF_PP; // 复用推挽
GPIO_InitStructure.GPIO_Mode = GPIO_Mode_AF_PP;
GPIO_Init(GPIOA, &GPIO_InitStructure);
GPIO_InitStructure.GPIO_Pin = GPIO_Pin_10; // PA10
GPIO_InitStructure.GPIO_Mode = GPIO_Mode_IN_FLOATING; // 浮空输入
GPIO_InitStructure.GPIO_Mode = GPIO_Mode_IN_FLOATING;
GPIO_Init(GPIOA, &GPIO_InitStructure);
RCC_APB2PeriphResetCmd(RCC_APB2Periph_USART1, ENABLE); // 复位串口1
RCC_APB2PeriphResetCmd(RCC_APB2Periph_USART1, DISABLE); // 停止复位
RCC_APB2PeriphResetCmd(RCC_APB2Periph_USART1, ENABLE);
RCC_APB2PeriphResetCmd(RCC_APB2Periph_USART1, DISABLE);
USART_InitStructure.USART_BaudRate = bound; // 波特率设置
USART_InitStructure.USART_WordLength = USART_WordLength_8b; // 8位数据长度
USART_InitStructure.USART_StopBits = USART_StopBits_1; // 一个停止位
USART_InitStructure.USART_Parity = USART_Parity_No; /// 奇偶校验位
USART_InitStructure.USART_HardwareFlowControl = USART_HardwareFlowControl_None; // 无硬件数据流控制
USART_InitStructure.USART_Mode = USART_Mode_Rx | USART_Mode_Tx; // 收发模式
USART_InitStructure.USART_BaudRate = bound;
USART_InitStructure.USART_WordLength = USART_WordLength_8b;
USART_InitStructure.USART_StopBits = USART_StopBits_1;
USART_InitStructure.USART_Parity = USART_Parity_No;
USART_InitStructure.USART_HardwareFlowControl = USART_HardwareFlowControl_None;
USART_InitStructure.USART_Mode = USART_Mode_Rx | USART_Mode_Tx;
USART_Init(USART1, &USART_InitStructure);
; // 初始化串口
;
NVIC_InitStructure.NVIC_IRQChannel = USART1_IRQn; // 使能串口1中断
NVIC_InitStructure.NVIC_IRQChannelPreemptionPriority = 1; // 先占优先级2级
// NVIC_InitStructure.NVIC_IRQChannelSubPriority = 3; //从优先级2级
NVIC_InitStructure.NVIC_IRQChannelCmd = ENABLE; // 使能外部中断通道
NVIC_Init(&NVIC_InitStructure); // 根据NVIC_InitStruct中指定的参数初始化外设NVIC寄存器
NVIC_InitStructure.NVIC_IRQChannel = USART1_IRQn;
NVIC_InitStructure.NVIC_IRQChannelPreemptionPriority = 1;
// NVIC_InitStructure.NVIC_IRQChannelSubPriority = 3; //???????2??
NVIC_InitStructure.NVIC_IRQChannelCmd = ENABLE;
NVIC_Init(&NVIC_InitStructure);
USART_ITConfig(USART1, USART_IT_RXNE, ENABLE); // 开启中断
USART_Cmd(USART1, ENABLE); // 使能串口
USART_ITConfig(USART1, USART_IT_RXNE, ENABLE);
USART_Cmd(USART1, ENABLE);
RS485_2_TX_EN = 0; // 默认为接收模式
RS485_2_TX_EN = 0;
}
// RS485_3_Init->J7 ，PB5->S1,PB6->S0,PB7->USART_OE
// SN74CB3Q3253多路复用器 - 多路信号分离器的引脚配置为OE S1 S0对应的值为010，使1B3 2B3响应
// RS485_3_Init->J7 ??PB5->S1,PB6->S0,PB7->USART_OE
// SN74CB3Q3253??¡¤?????? - ??¡¤???????????????????OE S1 S0???????010???1B3 2B3???
void RS485_3_Init(u32 bound)
{
SN74CB3Q3253_Init();
GPIO_ResetBits(GPIOB, GPIO_Pin_6); // S0配置为低电平
GPIO_SetBits(GPIOB, GPIO_Pin_5); // S1配置为高电平
GPIO_ResetBits(GPIOB, GPIO_Pin_6); // S0?????????
GPIO_SetBits(GPIOB, GPIO_Pin_5); // S1?????????
GPIO_InitTypeDef GPIO_InitStructure;
USART_InitTypeDef USART_InitStructure;
NVIC_InitTypeDef NVIC_InitStructure;
RCC_APB2PeriphClockCmd(RCC_APB2Periph_GPIOA | RCC_APB2Periph_GPIOB, ENABLE); // 使能GPIOA,D时钟
RCC_APB2PeriphClockCmd(RCC_APB2Periph_USART1, ENABLE); // 使能USART1时钟
RCC_APB2PeriphClockCmd(RCC_APB2Periph_GPIOA | RCC_APB2Periph_GPIOB, ENABLE);
RCC_APB2PeriphClockCmd(RCC_APB2Periph_USART1, ENABLE);
GPIO_InitStructure.GPIO_Pin = GPIO_Pin_4; // 端口配置
GPIO_InitStructure.GPIO_Mode = GPIO_Mode_Out_PP; // 推挽输出
GPIO_InitStructure.GPIO_Pin = GPIO_Pin_4;
GPIO_InitStructure.GPIO_Mode = GPIO_Mode_Out_PP;
GPIO_InitStructure.GPIO_Speed = GPIO_Speed_50MHz;
GPIO_Init(GPIOB, &GPIO_InitStructure);
GPIO_InitStructure.GPIO_Pin = GPIO_Pin_9; // PA9
GPIO_InitStructure.GPIO_Mode = GPIO_Mode_AF_PP; // 复用推挽
GPIO_InitStructure.GPIO_Mode = GPIO_Mode_AF_PP;
GPIO_Init(GPIOA, &GPIO_InitStructure);
GPIO_InitStructure.GPIO_Pin = GPIO_Pin_10; // PA10
GPIO_InitStructure.GPIO_Mode = GPIO_Mode_IN_FLOATING; // 浮空输入
GPIO_InitStructure.GPIO_Mode = GPIO_Mode_IN_FLOATING;
GPIO_Init(GPIOA, &GPIO_InitStructure);
RCC_APB2PeriphResetCmd(RCC_APB2Periph_USART1, ENABLE); // 复位串口1
RCC_APB2PeriphResetCmd(RCC_APB2Periph_USART1, DISABLE); // 停止复位
RCC_APB2PeriphResetCmd(RCC_APB2Periph_USART1, ENABLE);
RCC_APB2PeriphResetCmd(RCC_APB2Periph_USART1, DISABLE);
USART_InitStructure.USART_BaudRate = bound; // 波特率设置
USART_InitStructure.USART_WordLength = USART_WordLength_8b; // 8位数据长度
USART_InitStructure.USART_StopBits = USART_StopBits_1; // 一个停止位
USART_InitStructure.USART_Parity = USART_Parity_No; /// 奇偶校验位
USART_InitStructure.USART_HardwareFlowControl = USART_HardwareFlowControl_None; // 无硬件数据流控制
USART_InitStructure.USART_Mode = USART_Mode_Rx | USART_Mode_Tx; // 收发模式
USART_InitStructure.USART_BaudRate = bound;
USART_InitStructure.USART_WordLength = USART_WordLength_8b;
USART_InitStructure.USART_StopBits = USART_StopBits_1;
USART_InitStructure.USART_Parity = USART_Parity_No;
USART_InitStructure.USART_HardwareFlowControl = USART_HardwareFlowControl_None;
USART_InitStructure.USART_Mode = USART_Mode_Rx | USART_Mode_Tx;
USART_Init(USART1, &USART_InitStructure);
; // 初始化串口
;
NVIC_InitStructure.NVIC_IRQChannel = USART1_IRQn; // 使能串口1中断
NVIC_InitStructure.NVIC_IRQChannelPreemptionPriority = 1; // 先占优先级2级
// NVIC_InitStructure.NVIC_IRQChannelSubPriority = 3; //从优先级2级
NVIC_InitStructure.NVIC_IRQChannelCmd = ENABLE; // 使能外部中断通道
NVIC_Init(&NVIC_InitStructure); // 根据NVIC_InitStruct中指定的参数初始化外设NVIC寄存器
NVIC_InitStructure.NVIC_IRQChannel = USART1_IRQn;
NVIC_InitStructure.NVIC_IRQChannelPreemptionPriority = 1;
// NVIC_InitStructure.NVIC_IRQChannelSubPriority = 3; //???????2??
NVIC_InitStructure.NVIC_IRQChannelCmd = ENABLE;
NVIC_Init(&NVIC_InitStructure);
USART_ITConfig(USART1, USART_IT_RXNE, ENABLE); // 开启中断
USART_Cmd(USART1, ENABLE); // 使能串口
USART_ITConfig(USART1, USART_IT_RXNE, ENABLE);
USART_Cmd(USART1, ENABLE);
RS485_3_TX_EN = 0; // 默认为接收模式
RS485_3_TX_EN = 0;
}
// RS485发送len个字节.
// buf:发送区首地址
// len:发送的字节数(为了和本代码的接收匹配,这里建议不要超过64个字节)
void RS485_1_Send_Data(u8 *buf, u8 len)
{
u8 t;
RS485_1_TX_EN = 1; // 设置为发送模式
RS485_1_TX_EN = 1;
for (t = 0; t < len; t++) // 循环发送数据
for (t = 0; t < len; t++)
{
while (USART_GetFlagStatus(USART1, USART_FLAG_TC) == RESET)
;
@ -336,16 +354,16 @@ void RS485_1_Send_Data(u8 *buf, u8 len)
;
RS485_RX_CNT = 0;
RS485_1_TX_EN = 0; // 设置为接收模式
RS485_1_TX_EN = 0;
}
void RS485_1_Send_Data_1(u8 *buf, u8 len)
{
u8 t;
RS485_1_TX_EN = 1; // 设置为发送模式
RS485_1_TX_EN = 1;
for (t = 0; t < len; t++) // 循环发送数据
for (t = 0; t < len; t++)
{
while (USART_GetFlagStatus(USART1, USART_FLAG_TC) == RESET)
;
@ -356,13 +374,10 @@ void RS485_1_Send_Data_1(u8 *buf, u8 len)
;
// RS485_RX_CNT=0;
RS485_1_TX_EN = 0; // 设置为接收模式
RS485_1_TX_EN = 0;
}
// RS485发送len个字节.
// buf:发送区首地址
// len:发送的字节数(为了和本代码的接收匹配,这里建议不要超过64个字节)
void RS485_1_Send_Data_2(void) // 上传温湿度二氧化碳
void RS485_1_Send_Data_2(void)
{
sendbuf[0] = 0xEE;
sendbuf[1] = 0xB5;
@ -372,16 +387,18 @@ void RS485_1_Send_Data_2(void) //
sendbuf[35] = 0xFF;
sendbuf[36] = 0xFF;
u8 a;
RS485_1_TX_EN = 1; // 设置为发送模式
if (T <= 500000)
if (T <= 1000 && T >= -1000)
{
TEM1 = RS485_RX_BUF_COPY[3];
TEM2 = RS485_RX_BUF_COPY[4];
if (T < 0) {
T = (~(T - 1)) & 0xFFFF;
}
TEM1 = (T & 0xFF00) >> 8;
TEM2 = T & 0x00FF;
}
if (H <= 1000)
{
HUM1 = RS485_RX_BUF_COPY[5];
HUM2 = RS485_RX_BUF_COPY[6];
HUM1 = (H & 0xFF00) >> 8;
HUM2 = H & 0x00FF;
}
sendbuf[3] = TEM1;
sendbuf[4] = TEM2;
@ -406,19 +423,19 @@ void RS485_1_Send_Data_2(void) //
white_light2 = total[14 + 18 * (now_stage - 1)];
}
sendbuf[7] = red_light1;
sendbuf[8] = red_light2; // 红光
sendbuf[8] = red_light2;
sendbuf[9] = blue_light1;
sendbuf[10] = blue_light2; // 蓝光
sendbuf[10] = blue_light2;
sendbuf[11] = white_light1;
sendbuf[12] = white_light2; // 白光
sendbuf[12] = white_light2;
if (C <= 5000)
{
CO2_1 = RS485_RX_BUF_COPY[19];
CO2_2 = RS485_RX_BUF_COPY[20];
CO2_1 = (C & 0xFF00) >> 8;
CO2_1 = C & 0x00FF;
}
sendbuf[13] = CO2_1;
sendbuf[14] = CO2_2;
if (now_stage < 7 && total[3 + 18 * (now_stage - 1)] < 24 && total[4 + 18 * (now_stage - 1)] < 60 && chour < 24 && cminute < 60)
if (now_stage > 0 && now_stage < 7 && total[3 + 18 * (now_stage - 1)] < 24 && total[4 + 18 * (now_stage - 1)] < 60 && chour < 24 && cminute < 60)
{
sendbuf[15] = now_stage; // current state
sendbuf[16] = total[3 + 18 * (now_stage - 1)]; // stage hour
@ -426,6 +443,12 @@ void RS485_1_Send_Data_2(void) //
sendbuf[18] = chour; // run hour
sendbuf[19] = cminute; // run minute
}
// now_stage = 1;
sendbuf[15] = now_stage; // current state
sendbuf[16] = total[3 + 18 * (now_stage - 1)]; // stage hour
sendbuf[17] = total[4 + 18 * (now_stage - 1)]; // stage minute
sendbuf[18] = chour; // run hour
sendbuf[19] = cminute; // run minute
sendbuf[20] = hot_clod_flag; // hot clod state
sendbuf[21] = humidity_flag; // humidity state
sendbuf[22] = ALARM; // ALARM state
@ -450,35 +473,37 @@ void RS485_1_Send_Data_2(void) //
// sendbuf[29] = ((int)(pid.OUT * 1000)) / 256;
// sendbuf[30] = ((int)(pid.OUT * 1000)) % 256;
bufcut_Init(sendbuf_crc, sendbuf, 3, 31);
GetCRC16(sendbuf_crc, 28, &crc_num1, &crc_num2);
// bufcut_Init(sendbuf_crc, sendbuf, 3, 31);
// GetCRC16(sendbuf_crc, 28, &crc_num1, &crc_num2);
GetCRC16(sendbuf, 31, &crc_num1, &crc_num2);
sendbuf[31] = crc_num1;
sendbuf[32] = crc_num2;
for (a = 0; a < 37; a++) // 循环发送数据
{
while (USART_GetFlagStatus(USART1, USART_FLAG_TC) == RESET)
;
USART_SendData(USART1, sendbuf[a]);
// if(a==0)printf("%x\r\n",sendbuf[0]);
// only when modify happen, then send
if (cmp_str(prev_sendbuf, sendbuf, 37) != 0) {
RS485_1_Send_Data(sendbuf, 37);
cp_str_to_prev(prev_sendbuf, sendbuf, 37);
}
while (USART_GetFlagStatus(USART1, USART_FLAG_TC) == RESET)
;
// RS485_RX_CNT=0;
RS485_1_TX_EN = 0; // 设置为接收模式
}
/**
* sync environment params
*/
void RS485_1_Send_Data_3(void)
{
u8 batchbuf[8] = {0xEE, 0xB5, 0x01, 0x00, 0xFF, 0xFC, 0xFF, 0xFF};
u8 batchbuf[10] = {0xEE, 0xB5, 0x01, 0x00, 0x00, 0x00, 0xFF, 0xFC, 0xFF, 0xFF};
u8 t;
RS485_1_TX_EN = 1; // 设置为发送模式
RS485_1_TX_EN = 1;
batchbuf[3] = NUM;
NUM += 1;
if (NUM > 6)
NUM = 1;
for (t = 0; t < 8; t++) // 循环发送数据
GetCRC16(batchbuf, 4, batchbuf + 4, batchbuf + 5);
for (t = 0; t < 10; t++)
{
while (USART_GetFlagStatus(USART1, USART_FLAG_TC) == RESET)
;
@ -489,16 +514,16 @@ void RS485_1_Send_Data_3(void)
;
// RS485_RX_CNT=0;
RS485_1_TX_EN = 0; // 设置为接收模式
RS485_1_TX_EN = 0;
}
// void RS485_3_Send_Data_2(void)//上传当前周期(1)，周期时长(2)，已运行时长(2)，红蓝白光(6)，加热制冷状态(1)，加湿除湿状态(1)，报警状态(1)
// void RS485_3_Send_Data_2(void)
//{
// delay_ms(50);
// u8 sendbuf[21]={0xEE,0xB5,0x05,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0xFF,0xFC,0xFF,0xFF};//发送给串口屏的实时数据
// u8 sendbuf[21]={0xEE,0xB5,0x05,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0xFF,0xFC,0xFF,0xFF};//???????????????????
// u8 a;
// GPIO8_Init();
// GPIO_SetBits(GPIOB,GPIO_Pin_8);
// RS485_3_TX_EN=1; //设置为发送模式
// RS485_3_TX_EN=1;
// sendbuf[3]=t;
// sendbuf[4]=total[3 + 18 * (t - 1)];
// sendbuf[5]=total[4 + 18 * (t - 1)];
@ -515,7 +540,7 @@ void RS485_1_Send_Data_3(void)
// sendbuf[16]=ALARM;
//
//
// for(a=0;a<21;a++) //循环发送数据
// for(a=0;a<21;a++)
// {
// while(USART_GetFlagStatus(USART1, USART_FLAG_TC) == RESET);
// USART_SendData(USART1,sendbuf[a]);
@ -524,19 +549,16 @@ void RS485_1_Send_Data_3(void)
// while(USART_GetFlagStatus(USART1, USART_FLAG_TC) == RESET);
// RS485_RX_CNT=0;
// GPIO_ResetBits(GPIOB,GPIO_Pin_8);
// RS485_3_TX_EN=0; //设置为接收模式
// RS485_3_TX_EN=0;
//}
// RS485发送len个字节.
// buf:发送区首地址
// len:发送的字节数(为了和本代码的接收匹配,这里建议不要超过64个字节)
void RS485_3_Send_Data(u8 *buf,u8 len)
{
u8 t;
// GPIO8_Init();
// GPIO_SetBits(GPIOB,GPIO_Pin_8);
RS485_3_TX_EN=1; //设置为发送模式
for(t=0;t<len;t++) //循环发送数据
RS485_3_TX_EN=1;
for(t=0;t<len;t++)
{
while(USART_GetFlagStatus(USART1, USART_FLAG_TC) == RESET);
USART_SendData(USART1,buf[t]);
@ -545,25 +567,22 @@ void RS485_3_Send_Data(u8 *buf,u8 len)
while(USART_GetFlagStatus(USART1, USART_FLAG_TC) == RESET);
// RS485_RX_CNT=0;
// GPIO_ResetBits(GPIOB,GPIO_Pin_8);
RS485_3_TX_EN=0; //设置为接收模式
RS485_3_TX_EN=0;
}
// RS485查询接收到的数据
// buf:接收缓存首地址
// len:读到的数据长度
void RS485_Receive_Data(u8 *buf, u8 *len)
{
u8 rxlen = RS485_RX_CNT;
u8 i = 0;
*len = 0; // 默认为0
delay_ms(10); // 等待10ms,连续超过10ms没有接收到一个数据,则认为接收结束
if (rxlen == RS485_RX_CNT && rxlen) // 接收到了数据,且接收完成了
*len = 0;
delay_ms(10);
if (rxlen == RS485_RX_CNT && rxlen)
{
for (i = 0; i < rxlen; i++)
{
buf[i] = RS485_RX_BUF[i];
}
*len = RS485_RX_CNT; // 记录本次数据长度
RS485_RX_CNT = 0; // 清零
*len = RS485_RX_CNT;
RS485_RX_CNT = 0;
}
}

11
HARDWARE/rs485.h
Unescape View File

@ -5,15 +5,14 @@
extern u8 RS485_RX_BUF[128]; //接收缓冲,最大64个字节
extern u8 RS485_RX_CNT; //接收到的数据长度
extern u8 RS485_RX_BUF[128]; //receive buffer, max 128
extern u8 RS485_RX_CNT; // received data length
extern u8 RS485_RX_Flag_Num;
extern u8 RS485_RX_Flag;
//模式控制
#define RS485_1_TX_EN PBout(11) //485模式控制.0,接收;1,发送.
#define RS485_2_TX_EN PBout(10) //485模式控制.0,接收;1,发送.
#define RS485_3_TX_EN PBout(4) //485模式控制.0,接收;1,发送.
#define RS485_1_TX_EN PBout(11) // 485 mode control. 0:receiving; 1:Send
#define RS485_2_TX_EN PBout(10) // 485 mode control. 0:receiving; 1:Send
#define RS485_3_TX_EN PBout(4) // 485 mode control. 0:receiving; 1:Send
void RS485_1_Init(u32 bound);

57
HARDWARE/write.c
Unescape View File

@ -5,13 +5,17 @@
#include "rtc.h"
#include "SysTick.h"
#include "myfreertos.h"
extern u8 RS485_RX_BUF[128]; //
// extern u8 buf[51];
extern u8 RS485_RX_BUF[128]; //
extern u8 store_stage;
u8 read_stage = 1; // 从flash读取出来的阶段号
extern u8 now_stage;
extern u8 chour;
extern u8 cminute;
extern PID pid;
u16 current_minute = 0;
u16 total_minute = 0;
/*
@ -27,6 +31,7 @@ u8 total[] = {0xEE, 0XEE, 0x01, 0x04, 0x00, 0x00, 0xFA, 0x02, 0xBC, 0x00, 0x64,
0xEE, 0XEE, 0x05, 0x04, 0x00, 0x00, 0xFA, 0x02, 0xBC, 0x00, 0x64, 0x00, 0x64, 0x00, 0x64, 0xFF, 0xFF, 0xFF,
0xEE, 0XEE, 0x06, 0x04, 0x00, 0x00, 0xFA, 0x02, 0xBC, 0x00, 0x64, 0x00, 0x64, 0x00, 0x64, 0xFF, 0xFF, 0xFF};
void Array(u8 *n, u8 *hour, u8 *min, u16 *tem, u16 *hum, u16 *red, u16 *blue, u16 *white)
{
*hour = (total[3 + 18 * (*n - 1)]);
@ -41,23 +46,63 @@ void Array(u8 *n, u8 *hour, u8 *min, u16 *tem, u16 *hum, u16 *red, u16 *blue, u1
uint8_t ArrayRead[108];
uint8_t ArrayWrite[108];
uint8_t pidsRead[6];
uint8_t pidsWrite[6];
void Write_Init(void)
{
W25QXX_Init();
W25QXX_Erase_Sector(0x000000);
delay_ms(150);
W25QXX_Write_NoCheck(total, 0x000000, 108); // 把数据写入flash
W25QXX_Write_NoCheck(&store_stage, 0x00006D, 1); // 把当前运行阶段写入flash
W25QXX_Write(total, 0x000000, 108); // write data to flash
if (store_stage <= 0 || store_stage > 6) {
store_stage = 1;
}
W25QXX_Write(&store_stage, 0x001000, 1); // write current stage to flash
pidsWrite[0] = (int)pid.Kp / 256; // Kp 110
pidsWrite[1] = (int)(pid.Kp) % 256; // Kp 110
pidsWrite[2] = ((int)(pid.Ki * 100000)) / 256; // Ti 0.001
pidsWrite[3] = ((int)(pid.Ki * 100000)) % 256; // Ti 0.001
pidsWrite[4] = (int)pid.Kd / 256; // Td 340
pidsWrite[5] = (int)pid.Kd % 256; // Td 340
// // wtite p i d
W25QXX_Write(pidsWrite, 0x002000, 6); // p i d, 2bytes for each
W25QXX_Read(ArrayRead, 0x000000, 108); // 把数据读出来
}
void Read_Init(void)
{
W25QXX_Init();
W25QXX_Read(ArrayRead, 0x000000, 108); // 把数据读出来
bufcut_Init(total, ArrayRead, 0, 109); // 把读出来的数据赋值给total数组
W25QXX_Read(&read_stage, 0x00006D, 1);
bufcut_Init(total, ArrayRead, 0, 108); // 把读出来的数据赋值给total数组
W25QXX_Read(&read_stage, 0x001000, 1);
now_stage = read_stage; // 读出来的阶段赋值给当前阶段
// if (now_stage <= 0 || now_stage > 6) {
// now_stage = 3;
// }
// now_stage = 3;
// read p i d
W25QXX_Read(pidsRead, 0x002000, 6); // p i d, 2bytes for each
float Kp = pidsRead[0] * 256.0 + pidsRead[1];
float Ki = (pidsRead[2] * 256.0 + pidsRead[3]) / 100000.0;
float Kd = pidsRead[4] * 256.0 + pidsRead[5];
// pid.Kp = 120;
if (Kp > 1e-3) { pid.Kp = Kp; }
if (Ki > 1e-3) { pid.Ki = Ki; }
if (Kd > 1e-3) { pid.Kd = Kd; }
// pid.Ki = 0.002;
// pid.Kd = 300;
// pid.Kp = pidsRead[0] * 256.0 + pidsRead[1];
// pid.Ki = (pidsRead[2] * 256.0 + pidsRead[3]) / 100000.0;
// pid.Kd = pidsRead[4] * 256.0 + pidsRead[5];
// printf("%d\r\n",now_stage);
// printf("\r\n");
// printf("\r\n");

16
SYSTEM/USART.c
Unescape View File

@ -1,6 +1,5 @@
#include "USART.h"
// int fputc(int ch, FILE *f)
//{
// RS485_4_TX_EN=1;
@ -14,7 +13,8 @@ int fputc(int ch,FILE *p) //
{
RS485_4_TX_EN = 1;
USART_SendData(USART2, (u8)ch);
while(USART_GetFlagStatus(USART2,USART_FLAG_TXE)==RESET);
while (USART_GetFlagStatus(USART2, USART_FLAG_TXE) == RESET)
;
RS485_4_TX_EN = 0;
return ch;
}
@ -148,17 +148,21 @@ void USART2_IRQHandler(void) //
{
if (USART2_RX_STA & 0x4000) // 接收到了0x0d
{
if(r!=0x0a)USART2_RX_STA=0;//接收错误,重新开始
else USART2_RX_STA|=0x8000; //接收完成了
if (r != 0x0a)
USART2_RX_STA = 0; // 接收错误,重新开始
else
USART2_RX_STA |= 0x8000; // 接收完成了
}
else // 还没收到0X0D
{
if(r==0x0d)USART2_RX_STA|=0x4000;
if (r == 0x0d)
USART2_RX_STA |= 0x4000;
else
{
USART2_RX_BUF[USART2_RX_STA & 0X3FFF] = r;
USART2_RX_STA++;
if(USART2_RX_STA>(USART2_REC_LEN-1))USART2_RX_STA=0;//接收数据错误,重新开始接收
if (USART2_RX_STA > (USART2_REC_LEN - 1))
USART2_RX_STA = 0; // 接收数据错误,重新开始接收
}
}
}

2205
USER/Listings/LED.map
View File

File diff suppressed because it is too large Load Diff

44
USER/control.uvguix.Administrator
View File

File diff suppressed because one or more lines are too long

307
myfreertos/myfreertos.c
Unescape View File

@ -1,5 +1,7 @@
#include "myfreertos.h"
#define SENSOR_ADDRESS 0x02
char pubTopic[512] = "/sys/hp8oQhMZJ67/Device1/thing/event/property/post"; // Publish topic
char subTopic[512] = "/sys/hp8oQhMZJ67/Device1/thing/service/property/set"; // Subscribe topic
@ -25,6 +27,24 @@ void Sensor_Communication_task(void *pvParameters);
void Host_Computer_Communication(void);
// 10seconds delay
#define SENSOR_DATA_REQUEST_PERIOD pdMS_TO_TICKS(5000)
// 60seconds delay
#define SYNC_ENVIRONMENT_DATA_REQUEST_PERIOD pdMS_TO_TICKS(60000)
/**
* sensor data request: 02 03
*/
void SensorDataRequestTask(void *pvParameters);
/**
* sync environment data: EE B5 01
*/
void SyncEnvironmentDataRequestTask(void *pvParameters);
int isZeros(u8 arr[]);
u8 RS485_RX_BUF_COPY[128] = {0};
u8 cnt_flag = 0, sub_flag = 0, pub_flag = 0;
@ -51,16 +71,24 @@ u8 Feed_Dog_Count = 0; // Feeding dog timing
u8 now_stage = 1; // Current operational phase
u16 tem, hum, red, blue, white;
u8 hour, min;
u8 change_stage_rev1 = 0;
u8 change_stage_rev2 = 0;
u8 change_stage_rev3 = 0;
u8 rs485buf[8] = {0x02, 0x03, 0x00, 0x01, 0x00, 0x09, 0xD4, 0x3F}; // Sensor exchange data
u8 rs485buf[8] = {SENSOR_ADDRESS, 0x03, 0x00, 0x01, 0x00, 0x09, 0xD4, 0x3F}; // Sensor exchange data
u16 sync_cnt = 0; // 同步环境控制参数的计数器，到0同步
int T = 0, H = 0, C = 0, G = 0, current_T = 0;
extern u8 total[];
float Humidity = 0;
float temperature = 0;
// pages in hmi
#define page_index 43
#define page_curve 45
#define page_setting 46
#define page_upgrade 23
#define page_scan_wifi 48
#define page_wifi_setting 49
#define page_param_adjust 50
#define page_status 51
// u8 RS485_RX_BUF[64];
/*********************
@ -77,6 +105,13 @@ void os_init(void)
(void *)NULL,
(UBaseType_t)START_TASK_PRIO,
(TaskHandle_t *)&StartTask_Handler);
// 创建传感器数据请求任务
xTaskCreate(SensorDataRequestTask, "SensorDataRequestTask", configMINIMAL_STACK_SIZE, NULL, tskIDLE_PRIORITY + 1, NULL);
xTaskCreate(SyncEnvironmentDataRequestTask, "SyncEnvironmentDataRequestTask", configMINIMAL_STACK_SIZE, NULL, tskIDLE_PRIORITY + 2, NULL);
vTaskStartScheduler();
}
@ -128,10 +163,33 @@ void start_task(void *pvParameters)
// (TaskHandle_t* )&LEDTask_Handler);
// if(handler4==pdPASS){printf("控灯任务创建成功\r\n");}
// else{printf("控灯任务创建失败\r\n");}
vTaskDelete(StartTask_Handler); // 删除开始任务
taskEXIT_CRITICAL(); // 退出临界区
}
void SensorDataRequestTask(void *pvParameters) {
while (1) {
// 发送传感器数据请求的操作
RS485_1_Send_Data_1(rs485buf, 8);
vTaskDelay(SENSOR_DATA_REQUEST_PERIOD);
}
}
void SyncEnvironmentDataRequestTask(void *pvParameters) {
while (1) {
// 发送传感器数据请求的操作
RS485_1_Send_Data_3();
vTaskDelay(SYNC_ENVIRONMENT_DATA_REQUEST_PERIOD);
}
}
u8 temp[4] = {0xaa,0xbb,0xcc,0xdd};
void Sensor_Communication_task(void *pvParameters)
{
@ -155,47 +213,166 @@ void Sensor_Communication_task(void *pvParameters)
now_stage = timelong_Compare(); //
// printf("%d %d\r\n",chour,cminute);
Array(&now_stage, &hour, &min, &tem, &hum, &red, &blue, &white); // 更新对应阶段号的参数
// printf("current stage: %d\r\n",now_stage);
RS485_1_Send_Data_1(rs485buf, 8); //(RS485_RX_CNT=0已被注释)
// printf("send finish\r\n");
delay_xms(200);
printf("current stage: %d\r\n",now_stage);
// RS485_1_Send_Data_1(rs485buf, 8); //(RS485_RX_CNT=0已被注释)
// delay_xms(50);
// // RX_BUF_Printf(128);
// if (sync_cnt <= 0)
// {
// RS485_1_Send_Data_3();
// sync_cnt = 10;
// }
// else
// {
// sync_cnt--;
// }
delay_xms(50);
// RX_BUF_Printf(128);
if (sync_cnt <= 0)
bufcut_Init(RS485_RX_BUF_COPY, RS485_RX_BUF, 0, 128);
RS485_RX_CNT = 0;
while (isAllZeros(RS485_RX_BUF_COPY, 128) == 0)
{
RS485_1_Send_Data_3();
sync_cnt = 600;
if (RS485_RX_BUF_COPY[0] == 0x02 && RS485_RX_BUF_COPY[1] == 0x03 && CRC16_check(RS485_RX_BUF_COPY, 21) == 1)
{
// receive message from sensor
u8 temp_data[23] = {0};
for (int i=0;i<23;i++) {
temp_data[i] = RS485_RX_BUF_COPY[i];
}
process_sensor_data(temp_data);
RX_BUF_Transfer(0, 23);
}
else if (RS485_RX_BUF_COPY[0] == 0xEE && RS485_RX_BUF_COPY[1] == 0xB6 && RS485_RX_BUF_COPY[2] == 0x01)
{
// batch update params in a stage
// total length: 22
if (CRC16_check(RS485_RX_BUF_COPY, 16) == 1) {
Batch_synchronization(&n, RS485_RX_BUF_COPY);
Array(&now_stage, &hour, &min, &tem, &hum, &red, &blue, &white); // update param correspond to current stage
}
RX_BUF_Transfer(0, 22);
}
else if (RS485_RX_BUF_COPY[0] == 0xEE && RS485_RX_BUF_COPY[1] == 0xB6 && RS485_RX_BUF_COPY[2] == 0x03)
{
// update single environment param
// total length: 13
if (CRC16_check(RS485_RX_BUF_COPY, 7) == 1) {
Analysis(&n, &i, RS485_RX_BUF_COPY);
Array(&now_stage, &hour, &min, &tem, &hum, &red, &blue, &white); // update param correspond to current stage
Write_Init();
}
RX_BUF_Transfer(0, 13);
}
else if (RS485_RX_BUF_COPY[0] == 0xEE && RS485_RX_BUF_COPY[1] == 0xB6 && RS485_RX_BUF_COPY[2] == 0x04)
{
// change running stage
// total length: 10
if (CRC16_check(RS485_RX_BUF_COPY, 4) == 1) {
int target_stage = RS485_RX_BUF_COPY[3];
RTC_synchronization_ins(2023, 9, 1, 0, 00, 00);
now_stage = target_stage;
store_stage = target_stage;
Write_Init();
}
RX_BUF_Transfer(0, 10);
}
else if (RS485_RX_BUF_COPY[0] == 0xEE && RS485_RX_BUF_COPY[1] == 0xB6 && RS485_RX_BUF_COPY[2] == 0x05)
{
// change pid params
// total length: 12
if (CRC16_check(RS485_RX_BUF_COPY, 6) == 1) {
int param_index = RS485_RX_BUF_COPY[3];
switch(param_index) {
case 0x01:
{
pid.Kp = RS485_RX_BUF_COPY[4] * 256.0 + RS485_RX_BUF_COPY[5];
break;
}
case 0x02:
{
pid.Ki = (RS485_RX_BUF_COPY[4] * 256.0 + RS485_RX_BUF_COPY[5]) / 100000.0;
break;
}
case 0x03:
{
pid.Kd = RS485_RX_BUF_COPY[4] * 256.0 + RS485_RX_BUF_COPY[5];
break;
}
}
Write_Init();
}
RX_BUF_Transfer(0, 12);
}
else if (RS485_RX_BUF_COPY[0] == 0xEE && RS485_RX_BUF_COPY[1] == 0xB1 && RS485_RX_BUF_COPY[2] == 0x11 && RS485_RX_BUF_COPY[15] == 0xFF && RS485_RX_BUF[16] == 0xFF)
{
RX_BUF_Transfer(0, 17);
}
else if (RS485_RX_BUF_COPY[0] == 0xEE && RS485_RX_BUF_COPY[1] == 0xB1 && RS485_RX_BUF_COPY[2] == 0x11 && RS485_RX_BUF_COPY[14] == 0xFF && RS485_RX_BUF[15] == 0xFF)
{
RX_BUF_Transfer(0, 16);
}
else if (RS485_RX_BUF_COPY[0] == 0xEE && RS485_RX_BUF_COPY[1] == 0xB1 && RS485_RX_BUF_COPY[2] == 0x11 && RS485_RX_BUF_COPY[12] == 0xFF && RS485_RX_BUF[13] == 0xFF)
{
// btn down or up
process_hmi_btn_event(RS485_RX_BUF_COPY[3] * 256 + RS485_RX_BUF_COPY[4], RS485_RX_BUF_COPY[5] * 256 + RS485_RX_BUF_COPY[6], RS485_RX_BUF_COPY[9]);
RX_BUF_Transfer(0, 14);
}
else if (RS485_RX_BUF_COPY[0] == 0xEE && RS485_RX_BUF_COPY[1] == 0xB1 && RS485_RX_BUF_COPY[2] == 0x01 && RS485_RX_BUF_COPY[7] == 0xFF && RS485_RX_BUF_COPY[8] == 0xFF)
{
RX_BUF_Transfer(0, 9);
}
else
{
sync_cnt--;
int ZERO_Count = 0;
if ((RS485_RX_BUF_COPY[0] != 0x00))
{
RX_BUF_Transfer(0, 1);
}
delay_xms(200);
// RX_BUF_Printf(128);
bufcut_Init(RS485_RX_BUF_COPY, RS485_RX_BUF, 0, 128);
RS485_RX_CNT = 0;
// HC595_Send_Byte(0x00); // close all
while ((isAllZeros(RS485_RX_BUF_COPY, 128) == 0))
while (RS485_RX_BUF_COPY[ZERO_Count] == 0x00)
{
ZERO_Count++;
}
RX_BUF_Transfer(0, ZERO_Count);
}
}
if (RS485_RX_BUF_COPY[0] == 0x02 && RS485_RX_BUF_COPY[1] == 0x03) // 判断是否校验成功
if (red <= 1000 && blue <= 1000)
{
// -21
// RS485_RX_BUF_COPY[3] = 0xFF;
// RS485_RX_BUF_COPY[4] = 0xB1;
T = RS485_RX_BUF_COPY[3];
T = T << 8 | RS485_RX_BUF_COPY[4];
// 支持负数温度
PWM_SetCompare1((red / 100.0 * 3.5 + 28)); // J9
PWM_SetCompare2((blue / 100.0 * 3.5 + 28)); // J11
PWM_SetCompare4((white / 100.0 * 3.5 + 28)); // J10
}
RS485_RX_CNT = 0;
}
}
/**
* process sensor data
*/
void process_sensor_data(u8 *data) {
T = data[3];
T = T << 8 | data[4];
// Negative temperature treatment
if (T & 0x8000)
{
T = ((~T + 1) & 0xFFFF);
}
H = RS485_RX_BUF_COPY[5];
H = H << 8 | RS485_RX_BUF_COPY[6];
H = data[5];
H = H << 8 | data[6];
C = RS485_RX_BUF_COPY[19];
C = C << 8 | RS485_RX_BUF_COPY[20];
C = data[19];
C = C << 8 | data[20];
/*GPIO1->报警铃 GPIO3->加热棒 GPIO4—>新风风扇 GPIO5->加湿器 GPIO6->压缩机 */
@ -256,75 +433,29 @@ void Sensor_Communication_task(void *pvParameters)
HC595_Send_Byte(gpio_state &= 0xE7); // 关闭加湿器 关闭风扇 &=1110 0111 0xE7
humidity_flag = 0;
}
RS485_1_Send_Data_2(); // 上传参数
delay_xms(200);
RX_BUF_Transfer(0, 23);
}
else if (RS485_RX_BUF_COPY[0] == 0xEE && RS485_RX_BUF_COPY[1] == 0xB6 && RS485_RX_BUF_COPY[2] == 0x03)
{
Analysis(&n, &i, RS485_RX_BUF_COPY);
Array(&now_stage, &hour, &min, &tem, &hum, &red, &blue, &white); // 更新对应阶段号的参数
Write_Init();
RX_BUF_Transfer(0, 11);
}
else if (RS485_RX_BUF_COPY[0] == 0xEE && RS485_RX_BUF_COPY[1] == 0xB6 && RS485_RX_BUF_COPY[2] == 0x04)
/**
* hmi event process
*/
void process_hmi_btn_event(u8 page, u8 btn_index, u8 value) {
switch(page) {
case page_param_adjust:
{
change_stage_rev1 = RS485_RX_BUF_COPY[3];
// change current stage
if (btn_index >= 45 && btn_index <= 50 && value == 0x01) {
int target_stage = btn_index - 44;
RTC_synchronization_ins(2023, 9, 1, 0, 00, 00);
now_stage = change_stage_rev1;
store_stage = change_stage_rev1;
now_stage = target_stage;
store_stage = target_stage;
Write_Init();
RX_BUF_Transfer(0, 8);
}
else if (RS485_RX_BUF_COPY[0] == 0xEE && RS485_RX_BUF_COPY[1] == 0xB6 && RS485_RX_BUF_COPY[2] == 0x01)
{
Batch_synchronization(&n, RS485_RX_BUF_COPY);
Array(&now_stage, &hour, &min, &tem, &hum, &red, &blue, &white); // 更新对应阶段号的参数
RX_BUF_Transfer(0, 20);
}
else if (RS485_RX_BUF_COPY[0] == 0xEE && RS485_RX_BUF_COPY[1] == 0xB1 && RS485_RX_BUF_COPY[2] == 0x11 && RS485_RX_BUF_COPY[15] == 0xFF && RS485_RX_BUF[16] == 0xFF)
{
RX_BUF_Transfer(0, 17);
}
else if (RS485_RX_BUF_COPY[0] == 0xEE && RS485_RX_BUF_COPY[1] == 0xB1 && RS485_RX_BUF_COPY[2] == 0x11 && RS485_RX_BUF_COPY[14] == 0xFF && RS485_RX_BUF[15] == 0xFF)
{
RX_BUF_Transfer(0, 16);
}
else if (RS485_RX_BUF_COPY[0] == 0xEE && RS485_RX_BUF_COPY[1] == 0xB1 && RS485_RX_BUF_COPY[2] == 0x11 && RS485_RX_BUF_COPY[12] == 0xFF && RS485_RX_BUF[13] == 0xFF)
{
RX_BUF_Transfer(0, 14);
}
else if (RS485_RX_BUF_COPY[0] == 0xEE && RS485_RX_BUF_COPY[1] == 0xB1 && RS485_RX_BUF_COPY[2] == 0x01 && RS485_RX_BUF_COPY[7] == 0xFF && RS485_RX_BUF_COPY[8] == 0xFF)
{
RX_BUF_Transfer(0, 9);
}
else
{
int ZERO_Count = 0;
// if()与while()的顺序不能变
if ((RS485_RX_BUF_COPY[0] != 0x00)) // 不为0，处理掉
{
RX_BUF_Transfer(0, 1);
}
while (RS485_RX_BUF_COPY[ZERO_Count] == 0x00)
{
ZERO_Count++;
}
RX_BUF_Transfer(0, ZERO_Count);
break;
}
}
if (red <= 1000 && blue <= 1000)
{
PWM_SetCompare1((red / 100.0 * 3.5 + 28)); // J9
PWM_SetCompare2((blue / 100.0 * 3.5 + 28)); // J11
PWM_SetCompare4((white / 100.0 * 3.5 + 28)); // J10
}
RS485_RX_CNT = 0;
}
}
// void Host_Computer_Communication(void)

2
myfreertos/myfreertos.h
Unescape View File

@ -24,6 +24,8 @@
#include "mqtt_api.h"
void os_init(void);
void process_sensor_data(u8 *data);
void process_hmi_btn_event(u8 page_index, u8 btn_index, u8 value);
#endif

Write Preview
Loading…
Cancel
Save