YuanHongbin/GateWay
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity
Files
68a5a185fcc77f873af7fd4a3c9da8367fee4010
GateWay/Project/GateWay/source/User/Src/main.c
T

475 lines
16 KiB
C
Raw Blame History

#include "main.h"
#include "CatOneTask.h"
#include "EthTask.h"
#include "LoraTask.h"
#include "RS485Task.h"
#include "DebugCmd.h"
#include "Update.h"
#include "spiflash.h"
//雅下： 81-00-00-06-00-01
// 81-00-00-06-00-02
// 81-00-00-06-00-03
// 81-00-00-06-00-04
// 81-00-00-06-00-05
// 81-00-00-06-00-06
// 81-00-00-06-00-07
// 81-00-00-06-00-08
// 81-00-00-06-00-09
// 81-00-00-06-00-0A
//网关MAC编码由Boot程序固定在0x4000(协议规定: VerInfo(1)+PrjNum(3)+GwNum(2))
bool MainDispEn = true;
static rt_thread_t Lora_Thread = RT_NULL;
static rt_thread_t Cat1_Thread = RT_NULL;
static rt_thread_t Eth_Thread = RT_NULL;
static rt_thread_t RS485Ch1_Thread = RT_NULL;
static rt_thread_t RS485Ch2_Thread = RT_NULL;
static rt_thread_t Debug_Thread = RT_NULL;
GateWayPara_t GateWay;
#define ARRAY_DIM(a) (sizeof(a) / sizeof((a)[0]))
//static int Battery_Level_Percent_Table[11] = {3000, 3650, 3700, 3740, 3760, 3795, 3840, 3910, 3980, 4070, 4150};
static int Battery_Level_Percent_Table[11] = {6000, 7300, 7400, 7480, 7520, 7590, 7680, 7820, 7960, 8140, 8300};
int toPercentage(int voltage)
{
int i;
if(voltage < Battery_Level_Percent_Table[0])
return 0;
for(i = 0; i<ARRAY_DIM(Battery_Level_Percent_Table); i++){
if(voltage < Battery_Level_Percent_Table[i])
return i*10 - (10UL * (int)(Battery_Level_Percent_Table[i] - voltage)) /
(int)(Battery_Level_Percent_Table[i] - Battery_Level_Percent_Table[i-1]);;
}
return 100;
}
/*****************************************************************************************
* 函数名称: MainDBGOnOff
* 功能描述: 主调试信息开关函数
* 参 数: OnOff,开关
* 返 回 值: 无
*****************************************************************************************/
void MainDBGOnOff(bool OnOff)
{
MainDispEn = OnOff;
if(OnOff)
Debug_Printf("\r\nMain Display Enable!\r\n\r\n");
else
Debug_Printf("\r\nMain Display Disable!\r\n\r\n");
}
void GateWayInit(void)
{
LogHeader_t Header;
uint32_t FlashID = SpiFlashReadId();
Debug_Printf("FlashID: %08x\r\n", FlashID);
memset((uint8_t *)&GateWay.ConfigPara, 0x00, sizeof(GWConfigPara_t));
boot_para_t bootParam;
dev_boot_read_param(&bootParam);
rt_kprintf("AppFlag: 0x%08x\r\n", bootParam.AppFlag);
/*升级完成后Boot会设AppFlag=APP_START_FLAG并清UpdateFlag=0,
检测到升级异常(UpdateFlag仍为APP_UPDATE_FLAG 或 非首次且AppFlag无效)时擦外置Flash*/
if(bootParam.UpdateFlag == APP_UPDATE_FLAG
|| (bootParam.FirstRunFlag == 0 && bootParam.AppFlag != APP_START_FLAG)) {
rt_kprintf("Boot upgrade detected, erasing external Flash...\r\n");
SpiFlashEraseChip();
bootParam.UpdateFlag = 0;
dev_boot_write_param(bootParam);
}
int ret = ReadPara((uint8_t *)&GateWay.ConfigPara, sizeof(GWConfigPara_t));
if(GateWay.ConfigPara.SavFlag != LOG_SAV_FLAG) {
memset((uint8_t *)&GateWay.ConfigPara, 0x00, sizeof(GWConfigPara_t));
GateWay.ConfigPara.SavFlag = LOG_SAV_FLAG;
/*通道/服务器等默认参数全部从Boot参数区(BootPara_t)获取, 由Boot直接配置*/
GateWay.ConfigPara.Much = (Channel_m)bootParam.Much;
GateWay.ConfigPara.Auch = (Channel_m)bootParam.Auch;
GateWay.ConfigPara.Duch = (Channel_m)bootParam.Duch;
GateWay.ConfigPara.CuchMask = bootParam.CuchMask;
GateWay.ConfigPara.LTENet.DestAddr[0] = bootParam.SvrAddr[0];
GateWay.ConfigPara.LTENet.DestAddr[1] = bootParam.SvrAddr[1];
GateWay.ConfigPara.LTENet.DestAddr[2] = bootParam.SvrAddr[2];
GateWay.ConfigPara.LTENet.DestAddr[3] = bootParam.SvrAddr[3];
GateWay.ConfigPara.LTENet.DestPort = bootParam.SvrPort;
GateWay.ConfigPara.CommUnitReadInterval = COMMUNIT_READ_SENSOR_INTERVAL_MAX;//非低功耗设备
memset(GateWay.ConfigPara.CommUnitArray, 0x00, sizeof(CommUnitData_t) * COMMUNIT_NUM_MAX);
GateWay.ConfigPara.Rs485Ch1.Enable = true;
GateWay.ConfigPara.Rs485Ch1.CommUnitEnable = false;
GateWay.ConfigPara.Rs485Ch1.BaudRate = 500000;
GateWay.ConfigPara.Rs485Ch1.UpgradeEnable = true;
GateWay.ConfigPara.Rs485Ch1.Power = false;
GateWay.ConfigPara.Rs485Ch2.Enable = true;
GateWay.ConfigPara.Rs485Ch2.BaudRate = 500000;
GateWay.ConfigPara.Rs485Ch2.UpgradeEnable = false;
GateWay.ConfigPara.Rs485Ch2.CommUnitEnable = false;
GateWay.ConfigPara.Rs485Ch2.Power = false;
GateWay.ConfigPara.Rs485Ch1.RS485Send = RS485Ch1UartSend;
GateWay.ConfigPara.Rs485Ch2.RS485Send = RS485Ch2UartSend;
GateWay.ConfigPara.Lora.OnOff = true;
GateWay.ConfigPara.Lora.ucChannel = 8;
GateWay.ConfigPara.Lora.ucPower = 20;
GateWay.ConfigPara.Lora.SignalBw = 8;
GateWay.ConfigPara.Lora.SpreadFactor = 9;
GateWay.ConfigPara.Lora.ErrorCoding = 2;
GateWay.ConfigPara.Lora.RegPreamble = 10;
GateWay.ConfigPara.Lora.FreqCent = bootParam.LoraFreq;
GateWay.ConfigPara.OutageFlag = false;
}
/*网关MAC编码从Boot参数区(BootPara_t.GwMac)获取, 由Boot从固定地址0x4000同步
(协议规定: Mac[0]=VerInfo, Mac[1:3]=PrjNum, Mac[4:5]=GwNum)*/
for(int i = 0; i < 6; i++) {
GateWay.ConfigPara.GwMac[i] = bootParam.GwMac[i];
}
/*参照hc32l170_app UpdateInit: 保证AppFlag=APP_START_FLAG, 使Boot下次直接跳转App*/
UpdateInit();
if(GateWay.ConfigPara.OutageFlag != true && GateWay.ConfigPara.OutageFlag != false)
GateWay.ConfigPara.OutageFlag = false;
GateWay.MuchRegFlag = false;
memset(GateWay.SvrMac, 0x00, 6);
if(ChannelIsActive(GateWay.ConfigPara, CH_RS485_1)) {
GateWay.ConfigPara.Rs485Ch1.Enable = true;
GateWay.ConfigPara.Rs485Ch1.BaudRate = 500000;
}
if(GateWay.ConfigPara.Rs485Ch1.BaudRate < 2400 || GateWay.ConfigPara.Rs485Ch1.BaudRate > 921600)
GateWay.ConfigPara.Rs485Ch1.BaudRate = 500000;
RS485Ch1_Config(GateWay.ConfigPara.Rs485Ch1.BaudRate);
if(ChannelIsActive(GateWay.ConfigPara, CH_RS485_2)) {
GateWay.ConfigPara.Rs485Ch2.Enable = true;
GateWay.ConfigPara.Rs485Ch2.BaudRate = 500000;
}
if(GateWay.ConfigPara.Rs485Ch2.BaudRate < 2400 || GateWay.ConfigPara.Rs485Ch2.BaudRate > 921600)
GateWay.ConfigPara.Rs485Ch2.BaudRate = 500000;
RS485Ch2_Config(GateWay.ConfigPara.Rs485Ch2.BaudRate);
if(GateWay.ConfigPara.Rs485Ch1.Power)
RS485_CH1_POW_ON();
else
RS485_CH1_POW_OFF();
if(GateWay.ConfigPara.Rs485Ch2.Power) {
RS485_CH2_POW_OFF();
rt_thread_delay(1000);
RS485_CH2_POW_ON();
}
else
RS485_CH2_POW_OFF();
if(GateWay.ConfigPara.Lora.OnOff == true) {
LORA_POW_ON();
}
else {
LORA_POW_OFF();
}
if(LoraSetChannel(GateWay.ConfigPara.Lora.ucChannel) == false) {
GateWay.ConfigPara.Lora.ucChannel = 8;
LoraSetChannel(GateWay.ConfigPara.Lora.ucChannel);
//WritePara((uint8_t *)&GateWay.ConfigPara, sizeof(GWConfigPara_t));
}
if(LoraSetFreqCent(GateWay.ConfigPara.Lora.FreqCent) == false)
{
GateWay.ConfigPara.Lora.FreqCent = 433100000;
LoraSetFreqCent(GateWay.ConfigPara.Lora.FreqCent);
}
if(LoraSetPower(GateWay.ConfigPara.Lora.ucPower) == false) {
GateWay.ConfigPara.Lora.ucPower = 20;
LoraSetPower(GateWay.ConfigPara.Lora.ucPower);
//WritePara((uint8_t *)&GateWay.ConfigPara, sizeof(GWConfigPara_t));
}
if(LoraSetSignalBw(GateWay.ConfigPara.Lora.SignalBw) == false) {
GateWay.ConfigPara.Lora.SignalBw = 8;
LoraSetSignalBw(GateWay.ConfigPara.Lora.SignalBw);
//WritePara((uint8_t *)&GateWay.ConfigPara, sizeof(GWConfigPara_t));
}
if(LoraSetSpreadFactor(GateWay.ConfigPara.Lora.SpreadFactor) == false) {
GateWay.ConfigPara.Lora.SpreadFactor = 9;
LoraSetSpreadFactor(GateWay.ConfigPara.Lora.SpreadFactor);
//WritePara((uint8_t *)&GateWay.ConfigPara, sizeof(GWConfigPara_t));
}
if(LoraSetErrorCoding(GateWay.ConfigPara.Lora.ErrorCoding) == false) {
GateWay.ConfigPara.Lora.ErrorCoding = 2;
LoraSetErrorCoding(GateWay.ConfigPara.Lora.ErrorCoding);
//WritePara((uint8_t *)&GateWay.ConfigPara, sizeof(GWConfigPara_t));
}
if(GateWay.ConfigPara.Lora.RegPreamble > 0xFE) {
GateWay.ConfigPara.Lora.RegPreamble = 10;
LoraSetRegPreamble(GateWay.ConfigPara.Lora.RegPreamble);
//WritePara((uint8_t *)&GateWay.ConfigPara, sizeof(GWConfigPara_t));
}
WritePara((uint8_t *)&GateWay.ConfigPara, sizeof(GWConfigPara_t));
LogInit();
Header.LogEndAddr = 0;
if(ReadLogNum() > 0) {
int ret = ReadLog(&Header, NULL, 0);
if(ret > 0) {
GateWay.HistoryNum = ReadLogNum() - Header.LogIdx + 1;
rt_kprintf("History Num: %d\r\n", GateWay.HistoryNum);
}
else {
rt_kprintf("History Num: 0\r\n");
}
}
else
rt_kprintf("History Num: 0\r\n");
bool cat1Active = ChannelIsActive(GateWay.ConfigPara, CH_CAT1);
bool ethActive = ChannelIsActive(GateWay.ConfigPara, CH_ETH);
if(cat1Active) { DbgOrCat1Uart_Config(115200); CAT1_ON(); }
else { DBG_ON(); DbgOrCat1Uart_Config(500000); }
if(ethActive) { ETH_ON(); rt_thread_delay(1000); ETHReset(); }
}
void OutageUpdate(uint8_t AlarmType, bool AlarmState, uint8_t Batt)
{
GateWayAlarmType_t *Alarm;
uint8_t MegData[6],len;
len = sizeof(GateWayAlarmType_t);
MegData[0] = len & 0x00ff;;
MegData[1] = (len >> 8) & 0x00ff;
MegData[2] = NET_COMM_CMD_ALARM;
Alarm = (GateWayAlarmType_t *)&MegData[3];
Alarm->AlarmType = AlarmType;
Alarm->AlarmState = AlarmState;
Alarm->AlarmPara = Batt;
UploadSend(MegData, 6); //发送报警信息
}
/*****************************************************************************************
* 函数名称: main
* 功能描述: 主函数
* 参 数: 无
* 返 回 值: 运行错误返回-1
*****************************************************************************************/
static uint8_t LastBattery = 0xff; //上一次电池电压
int main(void)
{
uint16_t OneSecondDlyCnt = 0;
// struct tm cTime;
uint16_t PowerONLedDly = 2000;
uint32_t SystemRseetDlyCnt = 0;
uint32_t BatteryUpdateDlyCnt = 0;
uint8_t AlarmType = 0;
GateWayInit();
rt_kprintf("\r\n\r\n");
rt_kprintf("****************************************************\r\n");
rt_kprintf("** **\r\n");
rt_kprintf("** GateWay **\r\n");
rt_kprintf("** SoftWare V%d.%d **\r\n", SOFTWARE_VERSION / 10, SOFTWARE_VERSION % 10);
rt_kprintf("** HardWare V%d.%d **\r\n", HARDWARE_VERSION / 10, HARDWARE_VERSION % 10);
rt_kprintf("** Compile: %s %s **\r\n", __DATE__, __TIME__);
rt_kprintf("** **\r\n");
rt_kprintf("****************************************************\r\n\r\n");
// TimeGet(&cTime);
// TimeShow(TimeTs());
FeedDog();
//Cat1DBGOnOff(true);
GateWay.CommUnitRevCallBack = CommUnitAnalyze;
GateWay.MuchRevCallBack = MuchRevCallBack;
GateWay.AuchRevCallBack = AuchRevCallBack;
for(int i = 0; i < 6; i++) {
char name[8];
sprintf(name, "ChMQ%d", i);
GateWay.ChMQ[i] = rt_mq_create(name, 256, 5, RT_IPC_FLAG_FIFO);
}
GateWay.LoraRev_MQ = rt_mq_create("LoraRevMQ", 256, 10, RT_IPC_FLAG_FIFO);
if(GateWay.LoraRev_MQ == RT_NULL) {
rt_kprintf("LoraRev MQ Create Failed!\r\n");
}
GateWay.UartRevMutex = rt_mutex_create("urmutex", RT_IPC_FLAG_FIFO);
if(GateWay.UartRevMutex == RT_NULL) {
rt_kprintf("UR Mutex Create Failed!\r\n");
}
GateWay.EthTxMutex = rt_mutex_create("ethtxmtx", RT_IPC_FLAG_FIFO);
if(GateWay.EthTxMutex == RT_NULL) {
rt_kprintf("EthTx Mutex Create Failed!\r\n");
}
RS485Ch1_Thread = rt_thread_create("RS485Ch1", RS485Ch1_Thread_Entry, &GateWay, 2048, 3, 20);
if (RS485Ch1_Thread != RT_NULL)
rt_thread_startup(RS485Ch1_Thread);
else
return -1;
RS485Ch2_Thread = rt_thread_create("RS485Ch2", RS485Ch2_Thread_Entry, &GateWay, 2048, 3, 20);
if (RS485Ch2_Thread != RT_NULL)
rt_thread_startup(RS485Ch2_Thread);
else
return -1;
Debug_Thread = rt_thread_create("DebugUart", Debug_Thread_Entry, &GateWay, 2048, 3, 20);
if (Debug_Thread != RT_NULL)
rt_thread_startup(Debug_Thread);
else
return -1;
Cat1_Thread = rt_thread_create("Cat1", CatOne_Thread_Entry, &GateWay, 4096, 3, 20);
if (Cat1_Thread != RT_NULL)
rt_thread_startup(Cat1_Thread);
else
return -1;
Eth_Thread = rt_thread_create("Eth", Eth_Thread_Entry, &GateWay, 4096, 3, 20);
if (Eth_Thread != RT_NULL)
rt_thread_startup(Eth_Thread);
else
return -1;
Lora_Thread = rt_thread_create("Lora", Lora_Thread_Entry, &GateWay, 1024, 3, 20);
if (Lora_Thread != RT_NULL)
rt_thread_startup(Lora_Thread);
else
return -1;
while(1) {
if(PowerONLedDly > 0) {
PowerONLedDly--;
if(PowerONLedDly == 1) {
POWER_LED_OFF();
}
}
if(ChannelIsActive(GateWay.ConfigPara, CH_ETH)) EthOverHandler();
if(ChannelIsActive(GateWay.ConfigPara, CH_RS485_1) || ChannelIsActive(GateWay.ConfigPara, CH_RS485_2)
|| GateWay.ConfigPara.Rs485Ch1.UpgradeEnable || GateWay.ConfigPara.Rs485Ch2.UpgradeEnable)
RS485RxOverhandler();
DebugOrCat1RxOverhandler();
if(OneSecondDlyCnt % 200 == 0) {
FeedDog();
LORA_RX_TOGGLE();
POWER_TOGGLE();
}
OneSecondDlyCnt++;
if(OneSecondDlyCnt == 1000) {
OneSecondDlyCnt = 0;
if(GateWay.BatteryReadDlyCnt > 0) {
GateWay.BatteryReadDlyCnt--;
continue;
}
uint16_t ADValue = GetADCBuffPoint();
//V = (AD * 3.3 / 4096) * (R1+R2) / R1; R1 = 200, R2 = 120
//计算出常数为0.0021484375，扩大1000倍
float Voltage = ADValue * 2.1484375;
GateWay.Battery = toPercentage(Voltage);
//上电判断电量
if(LastBattery == 0xff) {
LastBattery = GateWay.Battery;
if(GateWay.ConfigPara.OutageFlag == true) { //有报警
AlarmType = 1;
}
else {
AlarmType = 0;
}
//BatteryUpdateDlyCnt = 2 * 60;
BatteryUpdateDlyCnt = 10;
}
else {
if(GateWay.ConfigPara.OutageFlag == false) { //没有告警，判断电池电压是否降低
if(GateWay.Battery <= LastBattery) {
if(LastBattery <= 5) {
GateWay.ConfigPara.OutageFlag = true;
WritePara((uint8_t *)&GateWay.ConfigPara, sizeof(GWConfigPara_t));
Debug_Printf("The power is cutted.(1) Bat = %d, LBat = %d\r\n", GateWay.Battery, LastBattery);
LastBattery = GateWay.Battery;
AlarmType = 1;
OutageUpdate(AlarmType, GateWay.ConfigPara.OutageFlag, LastBattery);
BatteryUpdateDlyCnt = 20 * 60;
}
else if((LastBattery - GateWay.Battery) > 2) {
GateWay.ConfigPara.OutageFlag = true;
WritePara((uint8_t *)&GateWay.ConfigPara, sizeof(GWConfigPara_t));
LastBattery = GateWay.Battery;
AlarmType = 1;
Debug_Printf("The power is cutted.(2) Bat = %d, LBat = %d\r\n", GateWay.Battery, LastBattery);
OutageUpdate(AlarmType, GateWay.ConfigPara.OutageFlag, LastBattery);
BatteryUpdateDlyCnt = 20 * 60;
}
}
else { //充电，更新上一次电池电压
LastBattery = GateWay.Battery;
}
}
else {
if(GateWay.Battery >= LastBattery) {
if(LastBattery > 95) {
GateWay.ConfigPara.OutageFlag = false;
WritePara((uint8_t *)&GateWay.ConfigPara, sizeof(GWConfigPara_t));
Debug_Printf("The power is restored.(1) Bat = %d, LBat = %d\r\n", GateWay.Battery, LastBattery);
LastBattery = GateWay.Battery;
AlarmType = 1;
OutageUpdate(AlarmType, GateWay.ConfigPara.OutageFlag, LastBattery);
BatteryUpdateDlyCnt = 90 * 60;
AlarmType = 0;
}
else if(GateWay.Battery - LastBattery > 5) {
GateWay.ConfigPara.OutageFlag = false;
WritePara((uint8_t *)&GateWay.ConfigPara, sizeof(GWConfigPara_t));
Debug_Printf("The power is restored.(2) Bat = %d, LBat = %d\r\n", GateWay.Battery, LastBattery);
LastBattery = GateWay.Battery;
AlarmType = 1;
OutageUpdate(AlarmType, GateWay.ConfigPara.OutageFlag, LastBattery);
BatteryUpdateDlyCnt = 90 * 60;
AlarmType = 0;
}
}
else { //电池继续放电，更新上一次电池电压
LastBattery = GateWay.Battery;
}
}
}
BatteryUpdateDlyCnt--;
if(BatteryUpdateDlyCnt == 0) {
if(GateWay.ConfigPara.OutageFlag) { //有报警
BatteryUpdateDlyCnt = 20 * 60;
}
else {
BatteryUpdateDlyCnt = 90 * 60;
}
OutageUpdate(AlarmType, GateWay.ConfigPara.OutageFlag, LastBattery);
}
//ADC_Start();
}
SystemRseetDlyCnt++;
if(SystemRseetDlyCnt > (24 * 60 * 60 * 1000)) {
SystemRseetDlyCnt = 0;
Debug_Printf("The system resets periodically.\r\n");
rt_thread_delay(3000);
NVIC_SystemReset();
}
rt_thread_delay(1);
}
}
Reference in New Issue View Git Blame Copy Permalink