#include "led.h" #include "app.h" #include "device.h" #include "ch455g.h" #include "net_proc.h" #include "bsp.h" #include "at_module.h" #include "net_ctrl.h" #include "me3616.h" #include "./gateway_collect/gateway_collect.h" #include "downlink.h" #include "uart_conf.h" #include "../APP/network/nettimer.h" #include "../APP/network_mgr/net_proc.h" extern ME3616 air; /* ********************************************************************************************************* * LOCAL VARIABLES ********************************************************************************************************* */ extern float Temp_test(void); OS_TCB LED_TASK_HandleTCB; CPU_STK LED_TASK_HandleStk[APP_TASK_START_STK_SIZE]; void LED_TASK_Handle(void * p_arg); OS_TCB UART_TASK_HandleTCB; CPU_STK UART_TASK_HandleStk[UART_TASK_START_STK_SIZE]; void UART_TASK_Handle(void * p_arg); OS_TCB PROG_TASK_HandleTCB; CPU_STK PROG_TASK_HandleStk[PROG_TASK_START_STK_SIZE]; void PROG_TASK_Handle(void * p_arg); OS_TCB SVC_TASK_HandleTCB; CPU_STK SVC_TASK_HandleStk[SVC_TASK_START_STK_SIZE]; void SVC_TASK_Handle(void * p_arg); OS_TCB LORA_TASK_HandleTCB; CPU_STK LORA_TASK_HandleStk[LORA_TASK_START_STK_SIZE]; void LORA_TASK_Handle(void * p_arg); OS_TCB INFO_TASK_HandleTCB; CPU_STK INFO_TASK_HandleStk[INFO_TASK_START_STK_SIZE]; void INFO_TASK_Handle(void * p_arg); /* ********************************************************************************************************* * STARTUP TASK * * Description : This is an example of a startup task. As mentioned in the book's text, you MUST * initialize the ticker only once multitasking has started. * * Arguments : p_arg is the argument passed to 'AppTaskStart()' by 'OSTaskCreate()'. * * Returns : none * * Notes : 1) The first line of code is used to prevent a compiler warning because 'p_arg' is not * used. The compiler should not generate any code for this statement. ********************************************************************************************************* */ extern u8 USART3_RX_BUF[128]; //接收缓冲,最大USART_REC_LEN个字节. //接收状态 //bit15， 接收完成标志 //bit14， 接收到0x0d //bit13~0， 接收到的有效字节数目 extern u16 USART3_RX_STA; extern int rcv_flag; int len; void init_powerup_ledstatus(void) { uint16_t ledstatus = 0; volatile uint32_t i = 0; ledstatus = (~ledstatus&0xFFFF); set_led_no_init_sn(ledstatus); for(i=0;i<500000;i++); //ledstatus = (~ledstatus&0x0FFF); // set_led_no_init_sn(ledstatus); } void AppTaskStart (void *p_arg) { OS_ERR err; uint16_t flash_size, ram_size; uint8_t chip_id[12]; uint16_t data = 0; uint8_t usmflag = 0; g_ptTest.bTestStart = 0; BSP_Init(); // Initialize BSP functions CPU_Init(); // Initialize the uC/CPU services CH455_Init(); // cmd_init(UART_DEBUG); init_powerup_ledstatus(); cpuidGetId(); //读取芯片ID getcpuTypeIdcode(); printf("\r\ App Start \r\n"); data = BKP_ReadBackupRegister(BKP_DR2); // 升级标志 if(data != 0){ if(updata_state_cmp(data)){ if((data&0x00ff) == 0x82){ // 升级成功 data = set_updata_state(UPDATE_SUCCESS); BKP_WriteBackupRegister(BKP_DR3, data); printf("\r\n send to net update sucess\r\n"); } else if((data&0x00ff) == 0x83) { // 回退成功 data = set_updata_state(UPDATE_RETURN_SUCESS); BKP_WriteBackupRegister(BKP_DR3, data); printf("\r\n send to net return sucess\r\n"); } printf("\r\n update status1 = %x\r\n",data); data = BKP_ReadBackupRegister(BKP_DR3); BKP_WriteBackupRegister(BKP_DR2, 0); g_runData.bsendUpdateStatus = data&0xFF; data = BKP_ReadBackupRegister(BKP_DR5); if(data == UP_PROG_FROM_NET) g_runData.bResetUpdate = 1; else g_runData.bResetUpdate = 2; BKP_WriteBackupRegister(BKP_DR5, 0); } } else{ g_runData.bResetUpdate = 0; printf("\r\n no update program, data = %x\r\n",data); } // printf("coll_msg size = %d\r\n",sizeof(collect_conf_t)); check_usim_status(0); #if OS_CFG_STAT_TASK_EN > 0u //如果使能（默认使能）了统计任务 OSStatTaskCPUUsageInit(&err); //计算没有应用任务（只有空闲任务）运行时 CPU 的（最大） #endif //容量（决定 OS_Stat_IdleCtrMax 的值，为后面计算 CPU //使用率使用）。 board_info_get(&flash_size, &ram_size, chip_id); #if 0//for test adc_test(); SPI_FLASH_Test(); SPI_E2PROM_Test(); I2C_Test(); can_test(); #endif OSTaskCreate((OS_TCB *)&LED_TASK_HandleTCB, (CPU_CHAR *)"LED TASK Handle", (OS_TASK_PTR )LED_TASK_Handle, (void *)0, (OS_PRIO )LED_TASK_PRIO, (CPU_STK *)&LED_TASK_HandleStk[0], (CPU_STK_SIZE)APP_TASK_START_STK_SIZE / 10, (CPU_STK_SIZE)APP_TASK_START_STK_SIZE, (OS_MSG_QTY )0, (OS_TICK )0, (void *)0, (OS_OPT )(OS_OPT_TASK_STK_CHK | OS_OPT_TASK_STK_CLR), (OS_ERR *)&err); OSTaskCreate((OS_TCB *)&UART_TASK_HandleTCB, (CPU_CHAR *)"UART TASK Handle", (OS_TASK_PTR )UART_TASK_Handle, //串口数据查询 (void *)0, (OS_PRIO )UART_TASK_PRIO, (CPU_STK *)&UART_TASK_HandleStk[0], (CPU_STK_SIZE)UART_TASK_START_STK_SIZE / 10, (CPU_STK_SIZE)UART_TASK_START_STK_SIZE, (OS_MSG_QTY )0, (OS_TICK )0, (void *)0, (OS_OPT )(OS_OPT_TASK_STK_CHK | OS_OPT_TASK_STK_CLR), (OS_ERR *)&err); OSTaskCreate((OS_TCB *)&LORA_TASK_HandleTCB, (CPU_CHAR *)"LORA TASK Handle", (OS_TASK_PTR )LORA_TASK_Handle, // lora数据处理 (void *)0, (OS_PRIO )LORA_TASK_PRIO, (CPU_STK *)&LORA_TASK_HandleStk[0], (CPU_STK_SIZE)LORA_TASK_START_STK_SIZE / 10, (CPU_STK_SIZE)LORA_TASK_START_STK_SIZE, (OS_MSG_QTY )0, (OS_TICK )0, (void *)0, (OS_OPT )(OS_OPT_TASK_STK_CHK | OS_OPT_TASK_STK_CLR), (OS_ERR *)&err); OSTaskCreate((OS_TCB *)&PROG_TASK_HandleTCB, (CPU_CHAR *)"PROG TASK Handle", (OS_TASK_PTR )PROG_TASK_Handle, // 4G模块收发处理 (void *)0, (OS_PRIO )PROG_TASK_PRIO, (CPU_STK *)&PROG_TASK_HandleStk[0], (CPU_STK_SIZE)PROG_TASK_START_STK_SIZE / 10, (CPU_STK_SIZE)PROG_TASK_START_STK_SIZE, (OS_MSG_QTY )0, (OS_TICK )0, (void *)0, (OS_OPT )(OS_OPT_TASK_STK_CHK | OS_OPT_TASK_STK_CLR), (OS_ERR *)&err); OSTaskCreate((OS_TCB *)&SVC_TASK_HandleTCB, (CPU_CHAR *)"SVC TASK Handle", (OS_TASK_PTR )SVC_TASK_Handle, // 设备初始化 (void *)0, (OS_PRIO )SVC_TASK_PRIO, (CPU_STK *)&SVC_TASK_HandleStk[0], (CPU_STK_SIZE)SVC_TASK_START_STK_SIZE / 10, (CPU_STK_SIZE)SVC_TASK_START_STK_SIZE, (OS_MSG_QTY )0, (OS_TICK )0, (void *)0, (OS_OPT )(OS_OPT_TASK_STK_CHK | OS_OPT_TASK_STK_CLR), (OS_ERR *)&err); OSTaskCreate((OS_TCB *)&INFO_TASK_HandleTCB, (CPU_CHAR *)"INFO TASK Handle", (OS_TASK_PTR )INFO_TASK_Handle, //网关查询采集器的信息 0x86 0x83 0x89这组协议是明文 (void *)0, (OS_PRIO )INFO_TASK_PRIO, (CPU_STK *)&INFO_TASK_HandleStk[0], (CPU_STK_SIZE)INFO_TASK_START_STK_SIZE / 10, (CPU_STK_SIZE)INFO_TASK_START_STK_SIZE, (OS_MSG_QTY )0, (OS_TICK )0, (void *)0, (OS_OPT )(OS_OPT_TASK_STK_CHK | OS_OPT_TASK_STK_CLR), (OS_ERR *)&err); OSTaskDel(&AppTaskStartTCB, &err); } uint8_t rcv_buf_pt[128], rcv_size = 0; uint8_t lora_buf[13] = "this is gw"; void LED_TASK_Handle(void * p_arg)//信息传输装置 { uint8_t i = 0; uint8_t key = 0; char val = 0; OS_ERR err; float vol=0.0,sumVol = 0.0,temperature = 0.0, sumTemperature = 0.0; uint16_t temp=0,updata_state_save= 0; static uint16_t times = 0,ledstatus = 0; static uint8_t flag = 0; (void)p_arg; SysTick_init(); g_ledStatus.ledM = LED_M_LOW; while (1) { if(flag>=g_ledStatus.ledM){ LED_RUN = !LED_RUN; flag = 0; if(downlink_config.gateway_id==0x00000000 || downlink_config.gateway_id==0xFFFFFFFF) { ledstatus = (~ledstatus&0x0FFF); ledstatus = ((g_firmwareExpl.dd<<4)&0xF000) | ledstatus; set_led_no_init_sn(ledstatus); } } flag++; key=KEY_Scan(0); // if(key == KEY0_PRES){ printf("\n this is key \n"); printf("Alarm Time:%d-%d-%d %d:%d:%d\n",calendar.w_year,calendar.w_month,calendar.w_date,calendar.hour,calendar.min,calendar.sec);//输出闹铃时间 } else if(key == KEY1_PRES){ // if(key_info.state == 0){ key_info.state = 1; key_info.num = 0; timeout_setValue(&key_info.tt_key_state,5*1000);// timeout_start(&key_info.tt_key_state); } key_info.num++; key_info.keyvalue = key; printf("key num:%d\n",key_info.num); } else if(key == KEY2_PRES){ printf("按键k2 \n"); updata_state = UPDATA_DATA_SUCCESS; updata_state_save = set_updata_state(updata_state); BKP_WriteBackupRegister(BKP_DR3, updata_state_save); //置升级标志 updata_state_info.updata_flag = set_updata_state(UPDATA_FLAG); BKP_WriteBackupRegister(BKP_DR2, updata_state_info.updata_flag); } if(key_info.keyvalue == KEY1_PRES) { if(timeout_isOut(&key_info.tt_key_state))//按键计时 { key_info.state = 0; if(key_info.num == 3) { // 5S内按三次，进行升级任务 printf("key = 3\r\n"); gateway_update_gateway_proc(); } key_info.num = 0; } //lora组号灯计时 if(timeout_isOut(&key_info.tt_key_state))//灯亮超时 { if(key_info.optcmd == 3){ key_info.optcmd = 0; } key_info.keyvalue = 0; } } if(times<5) { temp = get_adc(ADC_Channel_0, 1, ADC_SampleTime_239Cycles5); vol = (float)temp*3300/4096; sumVol += vol;// temp = get_adc(ADC_Channel_16, 1, ADC_SampleTime_239Cycles5); temperature = (1.42 - temp*3.3/4096)*1000/4.35;// + 25; sumTemperature += temperature;// if(times>=4){ vol = sumVol/5.0; sumVol = 0.0; g_firmwareMsg.gatewayMsg.fVol.fvoltage = vol/1000.0; temperature = sumTemperature/5.0; sumTemperature = 0.0; g_firmwareMsg.gatewayMsg.fTemper.ftemperature = temperature; // printf("ADC_Channel_0 Voltage measurement is : %f mV\r\n",vol); // // printf("ADC_Channel_16 Temper measurement is : %f C\r\n",temperature); // times= 0; } else times++; } OSTimeDlyHMSM(0, 0, 0, 100, OS_OPT_TIME_DLY, &err); /******************************/ /* //屏蔽// uart_rs232_init(Console_UID, cmd_rcv); */ rcv_size = uart_blocking_read((char *)rcv_buf_pt, UART_DEBUG, 10); if(rcv_size) { uart_cmd_task(rcv_buf_pt,rcv_size); } /******************************/ } } extern u8 uart_redirect_cfg[UART_MAX]; static int uart_rcv(u8 uartid, void *arg, u8 *pbuf, u16 buflen,u8 version) { int i; #if 0 if(uart_redirect_cfg[uartid]) { uart_msg_send(uart_redirect_cfg[uartid] - 1, pbuf, buflen); } else { uart_msg_send(uartid, pbuf, buflen); } #endif printf("uart%d receive %d %s:\r\n", uartid+1, buflen, pbuf); for(i = 0;i < buflen;i++) { printf("%c", *(pbuf + i)); } printf("\r\n"); return 0; } u8 gps_buff[100]; u8 gps_index = 0; static int gps_data_rcv(u8 uartid, void *arg, u8 *pbuf, u16 buflen,u8 version) { int i; for(i = 0;i < buflen;i++) { gps_buff[gps_index] = *(pbuf+i); if(gps_buff[gps_index] == '$') { gps_index = 0; gps_buff[gps_index] = *(pbuf+i); } else if((gps_buff[gps_index] == 0x0a)&& (gps_buff[gps_index-1] == 0x0d)) { if(strstr(gps_buff, "RMC")) { //printf("%s", gps_buff); } memset(gps_buff, 0 , gps_index); gps_index = 0; continue; } gps_index++; } return 0; } void UART_TASK_Handle(void * p_arg)//信息传输装置 { u8 i; OS_ERR err; (void)p_arg; //char hello[32] = "hello world!!\n" SysTick_init(); for(i = 0;i < UART_MAX;i++) { if(i == UART_DEBUG) { uart_rs232_init(i, NULL); continue; } else if(i == UART2_ID) { uart_rs232_init(i, gps_data_rcv); continue; } else { uart_rs232_init(i, NULL); continue; } } while (1) { for(i = 0;i < UART_MAX;i++) { //5个串口数据接收 uart_rcv_process(i); //uart_msg_send(i, hello, sizeof(hello)); OSTimeDlyHMSM(0, 0, 0, 10, OS_OPT_TIME_DLY, &err); } } } void PROG_TASK_Handle(void * p_arg)//信息传输装置 { (void)p_arg; //char hello[32] = "hello world!!\n" SysTick_init(); net_proc(); } void SVC_TASK_Handle(void * p_arg)//信息传输装置 { sys_eeprom_info_t info; (void)p_arg; SysTick_init(); system_info_get(&info); gateway_power_info_get(); info.DevId = g_firmwareMsg.gatewayMsg.hardwareMsg.gateway_sn; svc_proc(info.DevType, info.DevId); } void LORA_TASK_Handle(void * p_arg)//信息传输装置 { OS_ERR err; (void)p_arg; SysTick_init(); lora_init("golden_beans"); while(1) { if(g_ptTest.bTestStart == PT_OFF ){ lora_task(); ota_process_handle(); } OSTimeDlyHMSM(0, 0, 0, 1, OS_OPT_TIME_DLY, &err); } } extern void lora_send(char *tx_data, uint32_t tx_len); float tmper = 0.0; void INFO_TASK_Handle(void * p_arg)// { static uint8_t flag = 0; uint8_t ret = 0; OS_ERR err; (void)p_arg; SysTick_init(); nettimer_init(); timeout_setValue(&g_usmTimeOut,60*1000); // tax_init1(); while(1) { if(g_ptTest.bTestStart == PT_ON ){ OSTimeDlyHMSM(0, 0, 17, 0, OS_OPT_TIME_DLY, &err); continue; } if(sys_net.net_hdl && (downlink_config.config_flag == CONFIG_WRITE) && (g_runData.bInitNetProc==1)) { gateway_net_send_gatewayMsg(); gateway_reset_send_update_status();// 上报服务器网关自己的升级状态 } if(((g_runData.cregStatus!=1) || (g_data4G.errorTime>=2) || (air.State.MQTT_State==0)) \ && (sys_net.net_hdl!=NULL) && (g_runData.bUpdate==0)) { // 网络注册失败 ret = check_usim_status(1); if((ret!=0) && (timeout_isOut(&g_usmTimeOut) ||(g_data4G.errorTime>=2) )){ timeout_stop(&g_usmTimeOut); sys_net.net_hdl = NULL; sys_net.net_hdl = uplink_net_init((char*)g_upLinkTopic); sys_net.uplink_send = uplink_net_send; //上传数据的函数指针 4G sys_net.downlink_send = lora_send; // 下发数据的函数指针 lora device_init(0x0101, downlink_config.gateway_id); flag++; if(flag==1) timeout_setValue(&g_usmTimeOut,3*60*1000); else if(flag==2) timeout_setValue(&g_usmTimeOut,5*60*1000); else { flag = 3; timeout_setValue(&g_usmTimeOut,10*60*1000); } timeout_start(&g_usmTimeOut); if(g_data4G.errorTime>=2){ printf("mqtt can not connect\r\n"); } g_data4G.errorTime = 0; g_mqttRunDa.connectNum++; if(g_mqttRunDa.connectNum>=3) { g_mqttRunDa.bChangeSuc = 2; // 切换连接失败 } } } else if(g_runData.cregStatus==1 && flag!=0){ flag = 0; timeout_setValue(&g_usmTimeOut,60*1000); timeout_stop(&g_usmTimeOut); } if(g_mqttRunDa.bChangeMqtt == 1){ // 切换mqtt if(air.State.MQTT_State==1) { // 切换成功// 保存mqtt地址 memset(&(g_firmwareMsg.mqttidport),0,sizeof(MqttIdPort)); memcpy(g_firmwareMsg.mqttidport.ip,g_mqttRunDa.mqttMsg.ip,g_mqttRunDa.mqttIdlen); memcpy(g_firmwareMsg.mqttidport.port,g_mqttRunDa.mqttMsg.port,g_mqttRunDa.mqttPortlen); memcpy(g_firmwareMsg.mqttidport.admin,g_mqttRunDa.mqttMsg.admin,g_mqttRunDa.mqttUserlen); memcpy(g_firmwareMsg.mqttidport.password,g_mqttRunDa.mqttMsg.password,g_mqttRunDa.mqttPwdlen); g_firmwareMsg.mqttidport.flag = 1; fram_write_mqtt_msg(); printf("mqtt 切换成功,并保存mqtt的地址\r\n"); g_mqttRunDa.bChangeMqtt = 0; g_mqttRunDa.connectNum = 0; } else if((air.State.MQTT_State==0) && (g_mqttRunDa.bChangeSuc==2)){ // 切换失败 // 恢复mqtt地址，进行重新连接 g_mqttRunDa.bChangeMqtt = 0; g_mqttRunDa.connectNum = 0; timeout_stop(&g_usmTimeOut); printf("mqtt 切换失败，切换到原来的地址上\r\n"); } } OSTimeDlyHMSM(0, 0, 17, 0, OS_OPT_TIME_DLY, &err); } }