mazhiyuan
/
R2UWaterRS485UW500
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity
R2UWaterRS485UW500/hardinterface/ML302/nb_driver_ml302.c

1792 lines
50 KiB
C
Raw Permalink Normal View History

修改readme20231114
2024-06-03 15:49:39 +08:00
/************************************************************************************
* @Copyright (c) :(C)2017, Qindao ieslab Co., Ltd
* @FileName :pic24_nb_driver.c
* @Author :QDIES PLATFORM TEAM
* @Version :V1.0
* @Date :2017-03-01
* @Description :
************************************************************************************/
#include "sys_config.h"
#ifdef MODULE_ML302_TCP
#ifdef __cplusplus
extern "C"
{
#endif
#include "nb_uart_driver_ml302.h"
#include "nb_driver_ml302.h"
#include "stdio.h"
#include <time.h>
#include "UWater_timer1uS_driver.h"
#include "UWater_uart_driver.h"
#include "UWater_Rtcc_Driver.h"
#include "UWater_frame_app.h"
/********************************<2A><><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>************************************/
//ģ<><C4A3><EFBFBD><EFBFBD>Ϣ<EFBFBD><CFA2><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>á<EFBFBD><C3A1><EFBFBD><EFBFBD><EFBFBD>״̬<D7B4><CCAC><EFBFBD>ز<EFBFBD><D8B2><EFBFBD>
NBIOT_PARA Nbiot_Para;
//ģ<><C4A3><EFBFBD><EFBFBD><EFBFBD>ݷ<EFBFBD><DDB7><EFBFBD>ָ<EFBFBD><D6B8>
NBIOT_SEND_DATA Nbiot_Send_Data;
//ATָ<54><D6B8>ƴ<EFBFBD>ӻ<EFBFBD><D3BB><EFBFBD>
static char stringbuffer_temp[UP_BUF_SIZE*2];
//ATָ<54><EFBFBD>ͻ<EFBFBD><CDBB><EFBFBD>
static char AT_BUF[50 + UP_BUF_SIZE * 2];
//<2F><><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>
TYP_TASK_RESULT g_s_nbiot_task_flag = TASK_INIT;
//<2F><><EFBFBD>ݷ<EFBFBD><DDB7><EFBFBD>ͨ<EFBFBD><CDA8>
u8 g_s_nbiot_send_type;
//ģ<><C4A3><EFBFBD>ϵ<EFBFBD><CFB5><EFBFBD>־
u8 nb_power_flag = FALSE;
//ATָ<54><D6B8><EFBFBD><EFBFBD>ѯʧ<D1AF>ܴ<EFBFBD><DCB4><EFBFBD>
u8 at_requestErrorCount=0;
//ATָ<54><D6B8>ִ<EFBFBD>н<EFBFBD><D0BD><EFBFBD>
TYP_RESULT_CODE g_at_request_res;
//ATָ<54><D6B8><EFBFBD><EFBFBD><EFBFBD><EFBFBD>
int g_at_index=0;
//TCPҪ<50><D2AA><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>ݵij<DDB5><C4B3><EFBFBD>
u16 tcp_send_len=0;
char tcp_send_len_buf[8];
u8 tcp_send_len_buf_len=0;
//UDPҪ<50><D2AA><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>ݵij<DDB5><C4B3><EFBFBD>
u16 udp_send_len=0;
char udp_send_len_buf[8];
u8 udp_send_len_buf_len=0;
//IP<49><50>ַ
unsigned char *coap_ip;
u16 coap_port;
unsigned char *udp_ip1;
u16 udp_port1;
unsigned char *udp_ip2;
u16 udp_port2;
u8 nbiot_temp_connect_type=NBIOT_CONNECT_COAP;
//ATָ<54>
static STRUCT_AT_CMD AtCmdBuf[AT_CMD_COUNT]={
/*****ģ<><C4A3><EFBFBD><EFBFBD>ʼ<EFBFBD><CABC>ָ<EFBFBD><D6B8>********************/
{AT_CODE_AT, "AT+CMVERSION", WT_2S, RETRY_5, cst_AT_No_AT},//ATָ<54><D6B8>
{AT_CODE_VERCTRL, "AT+VERCTRL?", WT_2S, RETRY_5, cst_AT_No_VERCTRL_CK},//<2F><>ѯ<EFBFBD><D1AF><EFBFBD>ʽ
{AT_CODE_VERCTRL1,"AT+VERCTRL=0,1", WT_2S, RETRY_5, cst_AT_No_AT},//<2F><><EFBFBD><EFBFBD><EFBFBD>Զ<EFBFBD><D4B6><EFBFBD><EFBFBD>ʽ
{AT_CODE_CMEE, "AT+CMEE=1", WT_2S, RETRY_5, cst_AT_No_AT_CMEE},//<2F><><EFBFBD><EFBFBD>ERROR<4F><52><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>ʾ
{AT_CODE_CGSN, "AT+CGSN=1", WT_2S, RETRY_5, cst_AT_No_AT_IMEI},//<2F><>ѯIMEI
{AT_CODE_CPIN, "AT+CPIN?", WT_2S, RETRY_5, cst_AT_No_AT_CPIN},//<2F><>ѯSIM<49><4D>״̬,READY<44><59>ʾSIM<49><4D><EFBFBD><EFBFBD><EFBFBD><EFBFBD>ʶ<EFBFBD><CAB6><EFBFBD><EFBFBD><EFBFBD>С<EFBFBD>
{AT_CODE_CIMI, "AT+CIMI", WT_2S, RETRY_5, cst_AT_No_AT_CIMI},//<2F><>ѯIMSI
{AT_CODE_ICCID, "AT+ICCID", WT_2S, RETRY_5, cst_AT_No_AT_ICCID},//<2F><>ѯICCID
{AT_CODE_CFUN_CK, "AT+CFUN?", WT_2S, RETRY_5, cst_AT_No_AT_CFUN},//<2F><>ѯЭ<D1AF><D0AD>ջ<EFBFBD>Ƿ<EFBFBD><C7B7><EFBFBD><EFBFBD><EFBFBD>
{AT_CODE_CFUN0, "AT+CFUN=0", WT_2S, RETRY_5, cst_AT_No_AT_CFUN},//
{AT_CODE_CFUN1, "AT+CFUN=1", WT_2S, RETRY_5, cst_AT_No_AT_CFUN},//
{AT_CODE_CSQ, "AT+CSQ", WT_2S, RETRY_5, cst_AT_No_AT_CSQ},//<2F><>ѯ<EFBFBD>ź<EFBFBD><C5BA><EFBFBD><EFBFBD><EFBFBD>
{AT_CODE_TUEINFO, "AT+TUEINFO", WT_2S, RETRY_2, cst_AT_No_AT_TUEINFO},//<2F><>ѯ<EFBFBD>ź<EFBFBD>״̬
{AT_CODE_CCED, "AT+CCED=0,1", WT_2S, RETRY_2, cst_AT_No_AT_CCED},//Single shot requested.
{AT_CODE_CGDCONT, "AT+CGDCONT=1,\"IP\",\"", WT_2S, RETRY_1, cst_AT_No_AT},//<2F><><EFBFBD><EFBFBD>APN AT+CGDCONT=1,<2C><>IP<49><50>,<2C><>CMIOT<4F><54>
{AT_CODE_CGACT, "AT+CGACT=1,1", WT_20S,RETRY_2, cst_AT_No_AT_CGACT_how},//<2F><><EFBFBD><EFBFBD> PDP //<2F><EFBFBD>ȴ<EFBFBD>20s,<2C>ڼ䷢<DABC><E4B7A2>ATָ<54><D6B8><EFBFBD><EFBFBD>Ӧ<EFBFBD><D3A6>
{AT_CODE_CEREG, "AT+CEREG?", WT_2S, RETRY_10,cst_AT_No_AT_CEREG},//<2F><>ѯ<EFBFBD><D1AF><EFBFBD><EFBFBD>ע<EFBFBD><D7A2>״̬
{AT_CODE_CGACT_CK,"AT+CGACT?", WT_5S, RETRY_5,cst_AT_No_AT_CGACT_how},//<2F><>ѯ<EFBFBD><D1AF><EFBFBD>總<EFBFBD><E7B8BD>״̬
{AT_CODE_CCLK, "AT+CCLK?", WT_5S, RETRY_3, cst_AT_No_AT_CCLK},//<2F><>ѯģ<D1AF><C4A3>ʱ<EFBFBD><CAB1>
{AT_CODE_CTEC_CK, "AT+CTEC?", WT_5S, RETRY_1, cst_AT_No_AT_CCLK},//<2F><>ѯģ<D1AF><C4A3>ʱ<EFBFBD><CAB1>
{AT_CODE_CCED_CK, "AT+CCED=0,1", WT_5S, RETRY_5, cst_AT_No_AT_CCLK},//<2F><>ѯģ<D1AF><C4A3>ʱ<EFBFBD><CAB1>
/*****TCP<43><50><EFBFBD><EFBFBD>ָ<EFBFBD><D6B8>***********************/
/*When mode set to 1(transparent mode), n(connect_id) must be 0 and no TCP/UDP connection has already been
established.*/
//{AT_CODE_MIPMODE1,"AT+MIPMODE=0,1", WT_2S, RETRY_5, cst_AT_No_AT},//<2F><><EFBFBD><EFBFBD>͸<EFBFBD><CDB8><EFBFBD><EFBFBD><EFBFBD>ӷ<EFBFBD>ʽ AT+MIPMODE=0,1
//{AT_CODE_MIPOPEN, "AT+MIPOPEN=0,\"TCP\",\"",WT_5S, RETRY_5, cst_AT_No_AT_MIPOPEN},// AT+MIPOPEN=0,"TCP","58.59.6.130",21628
{AT_CODE_MIPMODE1,"AT+MIPMODE=1,0", WT_2S, RETRY_5, cst_AT_No_AT},//(<28><>ʹ<EFBFBD><CAB9>͸<EFBFBD><CDB8><EFBFBD><EFBFBD>ʽ)
{AT_CODE_MIPOPEN, "AT+MIPOPEN=1,\"TCP\",\"",WT_40S, RETRY_1, cst_AT_No_AT_MIPOPEN},// AT+MIPOPEN=1,"TCP","58.59.6.130",21628
/*****TCP<43><50><EFBFBD>ݷ<EFBFBD><DDB7><EFBFBD>***********************/
{AT_CODE_MIPSENDCOUNT,"AT+MIPSEND=1,", WT_5S, RETRY_2, cst_AT_No_AT_MIPSENDCOUNT},//<2F><><EFBFBD>÷<EFBFBD><C3B7><EFBFBD><EFBFBD>ֽ<EFBFBD><D6BD><EFBFBD>
{AT_CODE_TCPSEND, "", WT_5S, RETRY_0, cst_AT_No_AT_TCPSEND},//
//<2F>ر<EFBFBD>TCP<43><50><EFBFBD><EFBFBD>
{AT_CODE_MIPCLOSE, "AT+MIPCLOSE=1", WT_5S, RETRY_2, cst_AT_No_AT_MIPCLOSE},//AT+MIPCLOSE=0
/*****UDP1<50><31><EFBFBD><EFBFBD>ָ<EFBFBD><D6B8>**********************/
{AT_CODE_MIPOPEN_UDP1,"AT+MIPOPEN=2,\"UDP\",\"",WT_5S, RETRY_5, cst_AT_No_AT_MIPOPEN},// AT+MIPOPEN=1,"UDP","60.208.16.58",7833
/*****UDP1<50><31><EFBFBD>ݷ<EFBFBD><DDB7><EFBFBD>***********************/
{AT_CODE_MIPSENDCOUNT_UDP1,"AT+MIPSEND=2,", WT_5S, RETRY_2, cst_AT_No_AT_MIPSENDCOUNT},//<2F><><EFBFBD>÷<EFBFBD><C3B7><EFBFBD><EFBFBD>ֽ<EFBFBD><D6BD><EFBFBD>
{AT_CODE_UDPSEND1, "", WT_5S, RETRY_0, cst_AT_No_AT_TCPSEND},//
//<2F>ر<EFBFBD>UDP1<50><31><EFBFBD><EFBFBD>
{AT_CODE_MIPCLOSE_UDP1, "AT+MIPCLOSE=2", WT_5S, RETRY_2, cst_AT_No_AT_MIPCLOSE},//AT+MIPCLOSE=0
/*****UDP2<50><32><EFBFBD><EFBFBD>ָ<EFBFBD><D6B8>**********************/
{AT_CODE_MIPOPEN_UDP2,"AT+MIPOPEN=3,\"UDP\",\"",WT_5S, RETRY_5, cst_AT_No_AT_MIPOPEN},// AT+MIPOPEN=1,"UDP","60.208.16.58",7833
/*****UDP2<50><32><EFBFBD>ݷ<EFBFBD><DDB7><EFBFBD>***********************/
{AT_CODE_MIPSENDCOUNT_UDP2,"AT+MIPSEND=3,", WT_5S, RETRY_2, cst_AT_No_AT_MIPSENDCOUNT},//<2F><><EFBFBD>÷<EFBFBD><C3B7><EFBFBD><EFBFBD>ֽ<EFBFBD><D6BD><EFBFBD>
{AT_CODE_UDPSEND2, "", WT_5S, RETRY_0, cst_AT_No_AT_TCPSEND},//
//<2F>ر<EFBFBD>UDP2<50><32><EFBFBD><EFBFBD>
{AT_CODE_MIPCLOSE_UDP2, "AT+MIPCLOSE=3", WT_5S, RETRY_2, cst_AT_No_AT_MIPCLOSE},//AT+MIPCLOSE=0
};
/*****************************<2A>ڲ<EFBFBD><DAB2><EFBFBD><EFBFBD><EFBFBD>״̬<D7B4><CCAC><EFBFBD><EFBFBD>*********************************/
//<2F><>״̬
TYP_STATE_MAIN_CONNECT g_s_nbiot_main_state = S_NBIOT_MAIN_IDLE;
//<2F><><EFBFBD><EFBFBD>״̬
TYP_STEP_MODULE_POWERON s_power_on_state = MODULE_IDLE;
//<2F>ػ<EFBFBD>״̬
TYP_STATE_POWER_OFF s_power_off_state = S_PWOFF_IDLE;
//ATָ<54><D6B8><EFBFBD><EFBFBD>ѯ״̬
TYP_STATE_AT_REQUEST s_at_requeset_state = AT_REQUEST_IDLE;
//ģ<><C4A3><EFBFBD><EFBFBD>ʼ<EFBFBD><CABC>״̬
TYP_MODULE_INIT s_init_state=S_MODULE_INIT_IDLE;
//TCP<43><50><EFBFBD><EFBFBD>״̬
TYP_TCP_CONNECT s_tcp_connect_state = S_TCP_CONNECT_IDLE;
//TCP<43><50><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>״̬
TYP_TCP_SEND s_tcp_send_state;
//UDP<44><50><EFBFBD><EFBFBD>״̬
TYP_UDP_CONNECT s_udp_connect_state = S_UDP_CONNECT_IDLE;
//UDP<44><50><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>״̬
TYP_UDP_SEND s_udp_send_state;
/*****************************<2A>ڲ<EFBFBD><DAB2><EFBFBD><EFBFBD><EFBFBD>״̬<D7B4><CCAC><EFBFBD><EFBFBD><EFBFBD><EFBFBD>*********************************/
void NbiotInitMachine(void);
void NbiotPowerOffMachine(void);
void UdpReadDataMachine(void);
//TCP<43><50><EFBFBD><EFBFBD>
void TcpStartConnect(void);
void TcpConnectMachine(void);
//TCP<43><50><EFBFBD><EFBFBD>
void StartTcpSendData(void);
void TcpSendDataMachine(void);
//UDP<44><50><EFBFBD><EFBFBD>
void UdpStartConnect(u8 udp_num);
void UdpConnectMachine(void);
//UDP<44><50><EFBFBD><EFBFBD>
void StartUdpSendData(void);
void UdpSendDataMachine(void);
/*****************************<2A>ڲ<EFBFBD><DAB2><EFBFBD>ʱ<EFBFBD><CAB1><EFBFBD>ӿ<EFBFBD>**********************************/
void set_timer_1s(u16 time);
u16 check_timer_1s(void);
void set_timer_1ms(u16 time);
u16 check_timer_1ms(void);
void StartNbiotInit(void);
/*****************************<2A>ⲿ<EFBFBD>ӿ<EFBFBD>****************************************/
void NB_Power_Disable(void)
{
Gpio_WriteOutputIO(BAT_NB_PORT, BAT_NB_PIN, FALSE);
nb_power_flag = FALSE;
}
void NB_Power_Enable(void)
{
Gpio_WriteOutputIO(BAT_NB_PORT, BAT_NB_PIN, TRUE);
nb_power_flag = TRUE;
}
u8 If_NB_Poweron(void)
{
return nb_power_flag;
}
/***************************************************************************
* @fun_name void NbModuleIOInit(void)
* @brief ģ<EFBFBD>鹩<EFBFBD><EFBFBD>IO<EFBFBD><EFBFBD>ģ<EFBFBD>鸴λ<EFBFBD><EFBFBD><EFBFBD><EFBFBD>Դ<EFBFBD><EFBFBD>PSM<EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>ų<EFBFBD>ʼ<EFBFBD><EFBFBD>
***************************************************************************/
void NbModuleIOInit(void)
{
stc_gpio_cfg_t stcGpioCfg;
DDL_ZERO_STRUCT(stcGpioCfg);
stcGpioCfg.enDir = GpioDirOut; ///< <20>˿ڷ<CBBF><DAB7><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>
stcGpioCfg.enDrv = GpioDrvL; ///< <20>˿<EFBFBD><CBBF><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>-><3E><><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>
stcGpioCfg.enPu = GpioPuDisable; ///< <20>˿<EFBFBD><CBBF><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>-><3E><>
stcGpioCfg.enPd = GpioPdDisable;
stcGpioCfg.enOD = GpioOdDisable; ///< <20>˿ڿ<CBBF>©<EFBFBD><C2A9><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>
stcGpioCfg.enCtrlMode = GpioAHB; ///< <20>˿<EFBFBD><CBBF><EFBFBD><EFBFBD><EFBFBD>/<2F><><EFBFBD><EFBFBD>ֵ<EFBFBD>Ĵ<EFBFBD><C4B4><EFBFBD><EFBFBD><EFBFBD><EFBFBD>߿<EFBFBD><DFBF><EFBFBD>ģʽ<C4A3><CABD><EFBFBD><EFBFBD>->AHB
Gpio_Init(BAT_NB_PORT, BAT_NB_PIN, &stcGpioCfg); //ģ<>鹩<EFBFBD><E9B9A9>IO
Gpio_Init(RSTN_NB_PORT, RSTN_NB_PIN, &stcGpioCfg);
Gpio_Init(NB_PSM_WAKE_PORT, NB_PSM_WAKE_PIN, &stcGpioCfg);
Gpio_Init(PWR_NB_PORT, PWR_NB_PIN, &stcGpioCfg); //<2F><>Դ<EFBFBD><D4B4><EFBFBD>ƽ<EFBFBD>
Gpio_WriteOutputIO(BAT_NB_PORT, BAT_NB_PIN, FALSE);
Gpio_WriteOutputIO(PWR_NB_PORT, PWR_NB_PIN, FALSE);
Gpio_WriteOutputIO(RSTN_NB_PORT, RSTN_NB_PIN, FALSE);
Gpio_WriteOutputIO(NB_PSM_WAKE_PORT , NB_PSM_WAKE_PIN, FALSE);
}
/*ģ<><C4A3><EFBFBD>˴<EFBFBD><CBB4>ڵ<EFBFBD><DAB5><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>*/
void NB_UartInitForGPIO(void)//debug
{
stc_gpio_cfg_t stcGpioCfg;
DDL_ZERO_STRUCT(stcGpioCfg);
//PA0,PA1:<3A><><EFBFBD><EFBFBD>Ϊ<EFBFBD><CEAA><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>
stcGpioCfg.enDir = GpioDirIn; ///< <20>˿ڷ<CBBF><DAB7><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>-><3E><><EFBFBD><EFBFBD>
stcGpioCfg.enDrv = GpioDrvL; ///< <20>˿<EFBFBD><CBBF><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>-><3E><><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>
stcGpioCfg.enPu = GpioPuDisable; ///< <20>˿<EFBFBD><CBBF><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>-><3E><>
stcGpioCfg.enPd = GpioPdDisable;
stcGpioCfg.enOD = GpioOdDisable; ///< <20>˿ڿ<CBBF>©<EFBFBD><C2A9><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>-><3E><>©<EFBFBD><C2A9><EFBFBD><EFBFBD><EFBFBD>ر<EFBFBD>
stcGpioCfg.enCtrlMode = GpioAHB; ///< <20>˿<EFBFBD><CBBF><EFBFBD><EFBFBD><EFBFBD>/<2F><><EFBFBD><EFBFBD>ֵ<EFBFBD>Ĵ<EFBFBD><C4B4><EFBFBD><EFBFBD><EFBFBD><EFBFBD>߿<EFBFBD><DFBF><EFBFBD>ģʽ<C4A3><CABD><EFBFBD><EFBFBD>->AHB
Gpio_Init(GpioPortA, GpioPin0, &stcGpioCfg);
Gpio_Init(GpioPortA, GpioPin1, &stcGpioCfg);
}
/***************************************************************************
* @fun_name void NbiotMainMachine()
* @brief NBIOT<EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>ռ<EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>ѭ<EFBFBD><EFBFBD><EFBFBD>У<EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>NBIOT<EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>
***************************************************************************/
void NbiotMainMachine(void)
{
switch (g_s_nbiot_main_state)
{
case S_NBIOT_MAIN_IDLE:
{
}
break;
case S_NBIOT_MAIN_POWER_INIT:
{
if (TASK_INIT == g_s_nbiot_task_flag) //<2F><><EFBFBD><EFBFBD><EFBFBD>dz<EFBFBD>ʼ״̬
{
NbiotInitMachine(); //ģ<><C4A3><EFBFBD><EFBFBD>ʼ<EFBFBD><CABC>״̬<D7B4><CCAC>
}
else
{
if (TASK_SUCCESS == g_s_nbiot_task_flag) //<2F><><EFBFBD><EFBFBD><EFBFBD>ɹ<EFBFBD>
{
Nbiot_Para.net_state = NB_ON_LINE;
g_s_nbiot_main_state = S_NBIOT_MAIN_IDLE;
}
else //<2F><><EFBFBD><EFBFBD>ʧ<EFBFBD><CAA7>
{
*Nbiot_Send_Data.state = NBIOT_ERROR;
g_s_nbiot_main_state = S_NBIOT_MAIN_IDLE;
}
g_s_nbiot_task_flag = TASK_INIT; //<2F><><EFBFBD><EFBFBD>־λ
}
}
break;
case S_NBIOT_MAIN_TCP_OPEN:
{
if (TASK_INIT == g_s_nbiot_task_flag)
{
TcpConnectMachine(); //<2F><><EFBFBD><EFBFBD>վ<EFBFBD><D5BE><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>״̬<D7B4><CCAC>
}
else
{
if (TASK_SUCCESS == g_s_nbiot_task_flag)
{
Nbiot_Para.coap_state = CONNECT_ON_LINE;
}
else
{
Nbiot_Para.coap_state = CONNECT_OFF_LINE;
*Nbiot_Send_Data.state = NBIOT_ERROR;
}
g_s_nbiot_task_flag = TASK_INIT;
g_s_nbiot_main_state = S_NBIOT_MAIN_IDLE;
}
}
break;
case S_NBIOT_MAIN_TCP_SEND:
{
if (CONNECT_ON_LINE == Nbiot_Para.coap_state)
{
if (TASK_INIT == g_s_nbiot_task_flag)
{
TcpSendDataMachine(); //<2F><><EFBFBD>ݷ<EFBFBD><DDB7><EFBFBD>״̬<D7B4><CCAC>
}
else//<2F><><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>ɹ<EFBFBD><C9B9><EFBFBD>ʧ<EFBFBD>ܶ<EFBFBD><DCB6>ص<EFBFBD><D8B5><EFBFBD><EFBFBD><EFBFBD>
{
*Nbiot_Send_Data.state = NBIOT_SUCCESS;
g_s_nbiot_task_flag = TASK_INIT;
g_s_nbiot_main_state = S_NBIOT_MAIN_IDLE;
}
}
else
{
g_s_nbiot_task_flag = TASK_INIT;
g_s_nbiot_main_state = S_NBIOT_MAIN_IDLE;
}
}
break;
case S_NBIOT_MAIN_UDP_OPEN:
{
if (TASK_INIT == g_s_nbiot_task_flag)
{
UdpConnectMachine(); //<2F><><EFBFBD><EFBFBD>վ<EFBFBD><D5BE><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>״̬<D7B4><CCAC>
}
else
{
if (TASK_SUCCESS == g_s_nbiot_task_flag)
{
if(nbiot_temp_connect_type == NBIOT_CONNECT_UDP1)
{
Nbiot_Para.udp1_state = CONNECT_ON_LINE;
}
else if(nbiot_temp_connect_type == NBIOT_CONNECT_UDP2)
{
Nbiot_Para.udp2_state = CONNECT_ON_LINE;
}
}
g_s_nbiot_task_flag = TASK_INIT;
g_s_nbiot_main_state = S_NBIOT_MAIN_IDLE;
}
}
break;
case S_NBIOT_MAIN_UDP_SEND:
{
if (CONNECT_ON_LINE == Nbiot_Para.udp1_state)
{
if (TASK_INIT == g_s_nbiot_task_flag)
{
UdpSendDataMachine(); //<2F><><EFBFBD>ݷ<EFBFBD><DDB7><EFBFBD>״̬<D7B4><CCAC>
}
else//<2F><><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>ɹ<EFBFBD><C9B9><EFBFBD>ʧ<EFBFBD>ܶ<EFBFBD><DCB6>ص<EFBFBD><D8B5><EFBFBD><EFBFBD><EFBFBD>
{
g_s_nbiot_task_flag = TASK_INIT;
g_s_nbiot_main_state = S_NBIOT_MAIN_IDLE;
}
}
else
{
g_s_nbiot_task_flag = TASK_INIT;
g_s_nbiot_main_state = S_NBIOT_MAIN_IDLE;
}
}
break;
case S_NBIOT_MAIN_POWER_OFF:
{
if (TASK_INIT == g_s_nbiot_task_flag)
{
NbiotPowerOffMachine(); //<2F>ϵ<EFBFBD><CFB5>ػ<EFBFBD>
}
else
{
g_s_nbiot_task_flag = TASK_INIT;
g_s_nbiot_main_state = S_NBIOT_MAIN_IDLE;
Nbiot_Para.net_state = NB_OFF_LINE;
Nbiot_Para.coap_state = CONNECT_OFF_LINE;
Nbiot_Para.udp1_state = CONNECT_OFF_LINE;
Nbiot_Para.udp2_state = CONNECT_OFF_LINE;
}
}
break;
default:
{
g_s_nbiot_main_state = S_NBIOT_MAIN_IDLE;
}
break;
}
}
/***************************************************************************
* @fun_name u8 NbiotIfIdle()
* @brief <EFBFBD><EFBFBD>ѯģ<EFBFBD><EFBFBD><EFBFBD>Ŀ<EFBFBD><EFBFBD><EFBFBD>״̬
***************************************************************************/
u8 NbiotIfIdle(void)
{
if (S_NBIOT_MAIN_IDLE == g_s_nbiot_main_state)
{
return TASK_IDLE;
}
else
{
return TASK_BUSY;
}
}
/***************************************************************************
* @fun_name u8 NbiotIfOnline()
* @brief <EFBFBD><EFBFBD>ѯNBIOT<EFBFBD>Ƿ<EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>
***************************************************************************/
u8 NbiotIfOnline(void)
{
if (NB_ON_LINE == Nbiot_Para.net_state)
{
return TRUE;
}
else
{
return FALSE;
}
}
/***************************************************************************
* @fun_name u8 UdpIfOnline()
* @brief <EFBFBD><EFBFBD>ѯUDP<EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>Ƿ<EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>
***************************************************************************/
//u8 UdpIfOnline(void)
//{
// if (CONNECT_ON_LINE == Nbiot_Para.udp1_state)
// {
// return TRUE;
// }
// else
// {
// return FALSE;
// }
//}
/***************************************************************************
* @fun_name u8 ConncetIfOnline()
* @brief <EFBFBD><EFBFBD>ѯ<EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>Ƿ<EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>
***************************************************************************/
u8 ConncetIfOnline(u8 connect_type)
{
if(connect_type == NBIOT_CONNECT_COAP)
{
if (CONNECT_ON_LINE == Nbiot_Para.coap_state)
{
return TRUE;
}
else
{
return FALSE;
}
}
else if(connect_type == NBIOT_CONNECT_UDP1)
{
if (CONNECT_ON_LINE == Nbiot_Para.udp1_state)
{
return TRUE;
}
else
{
return FALSE;
}
}
else if(connect_type == NBIOT_CONNECT_UDP2)
{
if (CONNECT_ON_LINE == Nbiot_Para.udp2_state)
{
return TRUE;
}
else
{
return FALSE;
}
}
return FALSE;
}
/***************************************************************************
* @fun_name void NbiotOnlineTask(u8 *state)
* @brief NBIOT<EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>
* @param[in] state:״̬<EFBFBD><EFBFBD>Ϣ
***************************************************************************/
void NbiotOnlineTask(u8 *state)
{
if (S_NBIOT_MAIN_IDLE == g_s_nbiot_main_state)
{
if (!NbiotIfOnline())
{
if (S_NBIOT_MAIN_IDLE == g_s_nbiot_main_state)
{
Nbiot_Send_Data.state = state; //<2F><>ַ<EFBFBD><D6B7><EFBFBD><EFBFBD>
*state = NBIOT_ING;
g_s_nbiot_task_flag = TASK_INIT;
g_s_nbiot_main_state = S_NBIOT_MAIN_POWER_INIT;
StartNbiotInit();
}
}
else
{
*state = NBIOT_ONLINE;
}
}
else
{
*state = NBIOT_ERROR;
}
}
/***************************************************************************
* @fun_name void NB_NetConnectStart
* @brief <EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>ͽ<EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>
* @param[in] state:״̬<EFBFBD><EFBFBD>Ϣ
***************************************************************************/
void NB_NetConnectStart(unsigned char* temp_ip, u16 temp_port, u8 connect_type)
{
if(connect_type == NBIOT_CONNECT_COAP)
{
coap_ip = temp_ip;
coap_port = temp_port;
TcpStartConnect();
nbiot_temp_connect_type = NBIOT_CONNECT_COAP;
g_s_nbiot_main_state = S_NBIOT_MAIN_TCP_OPEN;
}
else if(connect_type == NBIOT_CONNECT_UDP1)
{
udp_ip1 = temp_ip;
udp_port1 = temp_port;
UdpStartConnect(connect_type);
g_s_nbiot_main_state = S_NBIOT_MAIN_UDP_OPEN;
}
else if(connect_type == NBIOT_CONNECT_UDP2)
{
udp_ip2 = temp_ip;
udp_port2 = temp_port;
UdpStartConnect(connect_type);
g_s_nbiot_main_state = S_NBIOT_MAIN_UDP_OPEN;
}
g_s_nbiot_task_flag = TASK_INIT;
}
/***************************************************************************
* @fun_name void NbiotSendTask(u8 *addr, u16 len, u8 send_type,u8 *state)
* @brief NBIOT<EFBFBD><EFBFBD><EFBFBD>ݷ<EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>
* @param[in] addr<EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>ݵ<EFBFBD><EFBFBD>׵<EFBFBD>ַ len<EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>
* @param[out] state:״̬<EFBFBD><EFBFBD>Ϣ
* @retval None
* @other state(NBIOT_ING<EFBFBD><EFBFBD><EFBFBD><EFBFBD>ѯ<EFBFBD><EFBFBD>, NBIOT_SUCCES<EFBFBD><EFBFBD><EFBFBD>ɹ<EFBFBD> <EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>쳣)
***************************************************************************/
void NbiotSendTask(u8 *addr, u16 len, u8 send_type,u8 *state)
{
if ((S_NBIOT_MAIN_IDLE == g_s_nbiot_main_state) && (len > 0) && (len <= UP_BUF_SIZE))
{
Nbiot_Send_Data.buf = addr; //<2F><>ַ<EFBFBD><D6B7><EFBFBD><EFBFBD>
Nbiot_Send_Data.len = len; //ֵ<><D6B5><EFBFBD><EFBFBD>
Nbiot_Send_Data.state = state; //<2F><>ַ<EFBFBD><D6B7><EFBFBD><EFBFBD>
*state = NBIOT_ING;
g_s_nbiot_send_type = send_type;
g_s_nbiot_task_flag = TASK_INIT;
if((SEND_TYPE_UDP1 == g_s_nbiot_send_type)||(SEND_TYPE_UDP2 == g_s_nbiot_send_type))
{
g_s_nbiot_main_state = S_NBIOT_MAIN_UDP_SEND;
StartUdpSendData();
}
else
{
StartTcpSendData();
g_s_nbiot_main_state = S_NBIOT_MAIN_TCP_SEND; //<2F><><EFBFBD><EFBFBD>NBIOT<4F><54><EFBFBD><EFBFBD>
}
}
else
{
*state = NBIOT_ERROR;
}
}
//<2F><>ȡ<EFBFBD><C8A1><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>
u8 GetNbiotSendType(void)
{
return g_s_nbiot_send_type;
}
/***************************************************************************
* @fun_name void NbiotReadCsqTask(u8 *out_csq,u8 *state)
* @brief NBIOT<EFBFBD><EFBFBD>ѯ<EFBFBD>ź<EFBFBD>ֵ<EFBFBD><EFBFBD><EFBFBD><EFBFBD>
* @param[in] out_csq<EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>ݵ<EFBFBD>ַ
* @param[out] state:״̬<EFBFBD><EFBFBD>Ϣ
* @retval None
* @other state(CSQ_ING<EFBFBD><EFBFBD><EFBFBD><EFBFBD>ѯ<EFBFBD><EFBFBD>, CSQ_SUCCES<EFBFBD><EFBFBD><EFBFBD>ɹ<EFBFBD> <EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>쳣)
***************************************************************************/
//void NbiotUdpOpenTask(void)
//{
// if (S_NBIOT_MAIN_IDLE == g_s_nbiot_main_state)
// {
// if(!UdpIfOnline())
// {
// g_s_nbiot_task_flag = TASK_INIT;
// g_s_nbiot_main_state = S_NBIOT_MAIN_UDP_OPEN;
// UdpStartConnect();
// }
// }
//}
/***************************************************************************
* @fun_name u8 NbiotIfSleep()
* @brief <EFBFBD>Ƿ<EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>
* @param[in] None
* @param[out] None
* @retval TRUE: <EFBFBD><EFBFBD><EFBFBD><EFBFBD> FALSE:<EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>
* @other None
***************************************************************************/
u8 NbiotIfSleep(void)
{
if (S_NBIOT_MAIN_IDLE == g_s_nbiot_main_state)
{
return TRUE;
}
else
{
return FALSE;
}
}
/***************************************************************************
* @fun_name void NbiotPreSleep()
* @brief <EFBFBD><EFBFBD><EFBFBD><EFBFBD>ǰ<EFBFBD><EFBFBD><EFBFBD><EFBFBD>
* @param[in] None
* @param[out] None
* @retval None
* @other None
***************************************************************************/
void NbiotPreSleep(void)
{
NB_Power_Disable(); //<2F>жϵ<D0B6>Դ
UartPreSleep(NB_UART_COM);
g_s_nbiot_main_state = S_NBIOT_MAIN_IDLE;
Nbiot_Para.net_state = NB_OFF_LINE;
Nbiot_Para.coap_state = CONNECT_OFF_LINE;
Nbiot_Para.udp1_state = CONNECT_OFF_LINE;
Nbiot_Para.udp2_state = CONNECT_OFF_LINE;
//<2F><><EFBFBD><EFBFBD>NB<4E><42><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>
stc_gpio_cfg_t stcGpioCfg;
DDL_ZERO_STRUCT(stcGpioCfg);
stcGpioCfg.enDir = GpioDirOut; ///< <20>˿ڷ<CBBF><DAB7><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>
stcGpioCfg.enDrv = GpioDrvL; ///< <20>˿<EFBFBD><CBBF><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>-><3E><><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>
stcGpioCfg.enPu = GpioPuDisable; ///< <20>˿<EFBFBD><CBBF><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>-><3E><>
stcGpioCfg.enPd = GpioPdDisable;
stcGpioCfg.enOD = GpioOdDisable; ///< <20>˿ڿ<CBBF>©<EFBFBD><C2A9><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>
stcGpioCfg.enCtrlMode = GpioAHB; ///< <20>˿<EFBFBD><CBBF><EFBFBD><EFBFBD><EFBFBD>/<2F><><EFBFBD><EFBFBD>ֵ<EFBFBD>Ĵ<EFBFBD><C4B4><EFBFBD><EFBFBD><EFBFBD><EFBFBD>߿<EFBFBD><DFBF><EFBFBD>ģʽ<C4A3><CABD><EFBFBD><EFBFBD>->AHB
Gpio_Init(BAT_NB_PORT, BAT_NB_PIN, &stcGpioCfg); //ģ<>鹩<EFBFBD><E9B9A9>IO
Gpio_Init(RSTN_NB_PORT, RSTN_NB_PIN, &stcGpioCfg);
Gpio_Init(NB_PSM_WAKE_PORT, NB_PSM_WAKE_PIN, &stcGpioCfg);
Gpio_Init(PWR_NB_PORT, PWR_NB_PIN, &stcGpioCfg); //<2F><>Դ<EFBFBD><D4B4><EFBFBD>ƽ<EFBFBD>
Gpio_WriteOutputIO(BAT_NB_PORT, BAT_NB_PIN, FALSE);
Gpio_WriteOutputIO(PWR_NB_PORT, PWR_NB_PIN, FALSE);
Gpio_WriteOutputIO(RSTN_NB_PORT, RSTN_NB_PIN, FALSE);
Gpio_WriteOutputIO(NB_PSM_WAKE_PORT , NB_PSM_WAKE_PIN, FALSE);
Gpio_Init(LPUART1_TX_PORT, LPUART1_TX_PIN, &stcGpioCfg);
Gpio_WriteOutputIO(LPUART1_TX_PORT, LPUART1_TX_PIN, FALSE); //TXҲ<58><D2B2><EFBFBD><EFBFBD>Ϊ<EFBFBD><CEAA><EFBFBD><EFBFBD><EFBFBD><EFBFBD>
stcGpioCfg.enDir = GpioDirIn; //RX<52><58><EFBFBD><EFBFBD>
Gpio_Init(LPUART1_RX_PORT, LPUART1_RX_PIN, &stcGpioCfg);
}
/***************************************************************************
* @fun_name void NbiotWakeSleep()
* @brief <EFBFBD><EFBFBD><EFBFBD>ߺ<EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>
* @param[in] None
* @param[out] None
* @retval None
* @other None
***************************************************************************/
void NbiotWakeSleep(void)
{
}
/******************************<2A>ڲ<EFBFBD>״̬<D7B4><CCAC>***********************************/
/***************************************************************************
* @fun_name void NetModulePowerOn_Proc()
* @brief ģ<EFBFBD>鿪<EFBFBD><EFBFBD>״̬
* @param[in] None
* @param[out] None
* @retval None
* @other None
***************************************************************************/
TYP_RESULT_CODE NetModulePowerOn_Proc(void)
{
switch(s_power_on_state)
{
case MODULE_IDLE://ģ<><C4A3><EFBFBD>͵<EFBFBD>
{
}
break;
case MODULE_POWERON://ģ<><C4A3><EFBFBD>͵<EFBFBD>
{
NbModuleIOInit(); //<2F><>ʼ<EFBFBD><CABC>Ĭ<EFBFBD><C4AC>ģ<EFBFBD><C4A3><EFBFBD>ϵ<EFBFBD>
UartInit(NB_UART_COM, BAUD9600, DATA_BIT_8, STOPBIT_1, UART_NONE_PARITY,UART_LPUART_Disable);
RSTN_NB_HIG();
PWR_NB_HIG();
NB_Power_Enable(); //<2F>򿪵<EFBFBD>Դ<EFBFBD><D4B4><EFBFBD><EFBFBD>ʱ1S,<2C>ȴ<EFBFBD><C8B4>ϵ<EFBFBD><CFB5>ȶ<EFBFBD>
set_timer_1ms(MODULE_POWER_DELAY_TIME);
s_power_on_state = MODULE_POWERON_WT;
}
break;
case MODULE_POWERON_WT://NBģ<42><C4A3><EFBFBD>͵<EFBFBD>
{
if (!check_timer_1ms())
{
PWR_NB_LOW();
set_timer_1ms(MODULE_POWERKEY_DELAY_TIME);
s_power_on_state = MODULE_POWER_KEY_ON_WT;
}
}
break;
case MODULE_POWER_KEY_ON_WT://NBģ<42><C4A3><EFBFBD>͵<EFBFBD>
{
if (!check_timer_1ms())
{
s_power_on_state = MODULE_IDLE;
return ResultOk;
}
}
break;
default:
{
s_power_on_state = MODULE_IDLE;
}
break;
}
return ResultBusy;
}
/***************************************************************************
* @fun_name void AT_Common_Requeset_Proc()
* @brief ATָ<EFBFBD>ͨ<EFBFBD>ò<EFBFBD>ѯ<EFBFBD><EFBFBD><EFBFBD><EFBFBD>
* @param[in] None
* @param[out] None
* @retval None
* @other <EFBFBD>й<EFBFBD><EFBFBD>ƶ<EFBFBD><EFBFBD><EFBFBD>Ϊ:898600;898602;898604;898607 <EFBFBD>й<EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>898603;898611
***************************************************************************/
int getAtIndexFromCode(TYP_AT_CMDCODE atCode)
{
for(int i=0;i<AT_CMD_COUNT;i++)
{
if(AtCmdBuf[i].AtCode == atCode)
{
return i;
}
}
return 0;
}
TYP_RESULT_CODE AT_Common_Requeset_Proc(TYP_AT_CMDCODE atCode, char addFlag, char* addBuf, int addLen)
{
switch(s_at_requeset_state)
{
case AT_REQUEST_IDLE:
{
g_at_index = getAtIndexFromCode(atCode);
at_requestErrorCount = 0;
set_timer_1ms(500);
s_at_requeset_state = AT_REQUEST_WT;
}
break;
case AT_REQUEST_WT:
{
if (!check_timer_1ms())
{
set_timer_1s(0);
s_at_requeset_state = AT_REQUEST_SEND;
}
}
break;
case AT_REQUEST_SEND:
{
if(!check_timer_1s())
{
memset(AT_BUF,0,sizeof(AT_BUF));
int i=0;
int all_len=0;
int str_len = strlen(AtCmdBuf[g_at_index].pAtCmdStr);
const char *p;
p = AtCmdBuf[g_at_index].pAtCmdStr;
for(i=0; i<str_len; i++)
{
AT_BUF[i] = *p++;
all_len++;
}
if(addFlag==1)
{
for(i=0; i<addLen; i++)
{
AT_BUF[str_len+i] = *addBuf++;
all_len++;
}
}
AT_BUF[all_len++] = '\r';
/*strcpy(AT_BUF, AtCmdBuf[g_at_index].pAtCmdStr);//<2F><><EFBFBD><EFBFBD>ʹ<EFBFBD><CAB9>strcpy,<2C><><EFBFBD><EFBFBD>ȡ<EFBFBD><C8A1><EFBFBD><EFBFBD>ֻ<EFBFBD>ܵ<EFBFBD>0x00
if(addFlag==1)
{
strcat(AT_BUF, addBuf);
}
strcat(AT_BUF, "\r");*/
NbiotUartSend((u8*)AT_BUF, all_len, AtCmdBuf[g_at_index].CaseAtNum);//<2F><><EFBFBD><EFBFBD><EFBFBD><EFBFBD>strlen(AT_BUF),<2C><><EFBFBD><EFBFBD>ֻ<EFBFBD>ܷ<EFBFBD><DCB7>͵<EFBFBD>0x00
set_timer_1s(AtCmdBuf[g_at_index].WaitTime);
s_at_requeset_state = AT_REQUEST_CHECK;
}
}
break;
case AT_REQUEST_CHECK:
{
if (NbiotCheckAtAck() == UART_OK)//<2F><><EFBFBD><EFBFBD><EFBFBD><EFBFBD>ȷ<EFBFBD><C8B7>Ӧ<EFBFBD><D3A6>
{
s_at_requeset_state = AT_REQUEST_IDLE;
return ResultOk;
}
else if ((!check_timer_1s()) || (NbiotCheckAtAck() == UART_ERROR)) //Ӧ<><D3A6><EFBFBD><EFBFBD>ʱ<EFBFBD><CAB1><EFBFBD>ߴ<EFBFBD><DFB4><EFBFBD>
{
if (at_requestErrorCount >= AtCmdBuf[g_at_index].ErrorLimit)
{
s_at_requeset_state = AT_REQUEST_IDLE;
return ResultFail;
}
else
{
at_requestErrorCount++;
set_timer_1s(AtCmdBuf[g_at_index].WaitTime);
s_at_requeset_state = AT_REQUEST_SEND;
}
}
}
break;
default:
{
s_at_requeset_state = AT_REQUEST_IDLE;
return ResultFail;
}
}
return ResultBusy;
}
/***************************************************************************
* @fun_name void NbiotInitMachine()
* @brief ģ<EFBFBD><EFBFBD><EFBFBD><EFBFBD>ʼ<EFBFBD><EFBFBD>״̬<EFBFBD><EFBFBD>
* @param[in] None
* @param[out] None
* @retval None
* @other
***************************************************************************/
void StartNbiotInit(void)
{
s_init_state = S_MODULE_INIT_POWER_ON;
s_power_on_state = MODULE_POWERON;//ģ<><C4A3><EFBFBD>͵<EFBFBD>
}
void NbiotInitMachine_ML302(void)
{
switch (s_init_state)
{
case S_MODULE_INIT_IDLE:
{
break;
}
case S_MODULE_INIT_POWER_ON://NBģ<42><C4A3><EFBFBD>͵<EFBFBD>
{
g_at_request_res = NetModulePowerOn_Proc();
if(g_at_request_res == ResultOk)
{
//NB_UartInitForGPIO();//debug
//<2F><>ʼ<EFBFBD><CABC><EFBFBD>ɵ<EFBFBD><C9B5><EFBFBD><EFBFBD><EFBFBD>
u8 NB_login_ask_times = (FrameCheckParaApp(FramePara_NbParaLoginAckTimes)/3);
if (NB_login_ask_times < NET_CEREG_MIN_TIMES)
{
NB_login_ask_times = NET_CEREG_MIN_TIMES;
}
if (NB_login_ask_times > NET_CEREG_MAX_TIMES)
{
NB_login_ask_times = NET_CEREG_MAX_TIMES;
}
AtCmdBuf[getAtIndexFromCode(AT_CODE_CEREG)].ErrorLimit = NB_login_ask_times;//<2F><>ѯ<EFBFBD><D1AF><EFBFBD><EFBFBD>ע<EFBFBD><D7A2>״̬<D7B4><CCAC><EFBFBD><EFBFBD>
s_init_state = S_MODULE_INIT_AT;
}
}
break;
case S_MODULE_INIT_AT:
{
g_at_request_res = AT_Common_Requeset_Proc(AT_CODE_AT, 0, NULL,0);
if(g_at_request_res == ResultOk)
{
s_init_state = S_MODULE_INIT_CMEE;
}
else if(g_at_request_res == ResultFail)
{
g_s_nbiot_task_flag = TASK_FAIL; //<2F><>ʼ<EFBFBD><CABC><EFBFBD><EFBFBD><EFBFBD><EFBFBD>ʧ<EFBFBD><CAA7>
s_init_state = S_MODULE_INIT_IDLE;
}
}
break;
case S_MODULE_INIT_CMEE:
{
g_at_request_res = AT_Common_Requeset_Proc(AT_CODE_CMEE, 0, NULL,0);
if(g_at_request_res == ResultOk)
{
s_init_state = S_MODULE_INIT_CGSN;
}
else if(g_at_request_res == ResultFail)
{
g_s_nbiot_task_flag = TASK_FAIL; //<2F><>ʼ<EFBFBD><CABC><EFBFBD><EFBFBD><EFBFBD><EFBFBD>ʧ<EFBFBD><CAA7>
s_init_state = S_MODULE_INIT_IDLE;
}
}
break;
case S_MODULE_INIT_CGSN:
{
g_at_request_res = AT_Common_Requeset_Proc(AT_CODE_CGSN, 0, NULL,0);
if(g_at_request_res == ResultOk)
{
s_init_state = S_MODULE_INIT_CPIN;
}
else if(g_at_request_res == ResultFail)
{
g_s_nbiot_task_flag = TASK_FAIL; //<2F><>ʼ<EFBFBD><CABC><EFBFBD><EFBFBD><EFBFBD><EFBFBD>ʧ<EFBFBD><CAA7>
s_init_state = S_MODULE_INIT_IDLE;
}
}
break;
case S_MODULE_INIT_CPIN:
{
g_at_request_res = AT_Common_Requeset_Proc(AT_CODE_CPIN, 0, NULL,0);
if(g_at_request_res == ResultOk)
{
s_init_state = S_MODULE_INIT_CIMI;
}
else if(g_at_request_res == ResultFail)
{
g_s_nbiot_task_flag = TASK_FAIL; //<2F><>ʼ<EFBFBD><CABC><EFBFBD><EFBFBD><EFBFBD><EFBFBD>ʧ<EFBFBD><CAA7>
s_init_state = S_MODULE_INIT_IDLE;
}
}
break;
case S_MODULE_INIT_CIMI:
{
g_at_request_res = AT_Common_Requeset_Proc(AT_CODE_CIMI, 0, NULL,0);
if(g_at_request_res == ResultOk)
{
s_init_state = S_MODULE_INIT_ICCID;
}
else if(g_at_request_res == ResultFail)
{
g_s_nbiot_task_flag = TASK_FAIL; //<2F><>ʼ<EFBFBD><CABC><EFBFBD><EFBFBD><EFBFBD><EFBFBD>ʧ<EFBFBD><CAA7>
s_init_state = S_MODULE_INIT_IDLE;
}
}
break;
case S_MODULE_INIT_ICCID:
{
g_at_request_res = AT_Common_Requeset_Proc(AT_CODE_ICCID, 0, NULL,0);
if(g_at_request_res == ResultOk)
{
s_init_state = S_MODULE_INIT_CFUN_CK;
}
else if(g_at_request_res == ResultFail)
{
g_s_nbiot_task_flag = TASK_FAIL; //<2F><>ʼ<EFBFBD><CABC><EFBFBD><EFBFBD><EFBFBD><EFBFBD>ʧ<EFBFBD><CAA7>
s_init_state = S_MODULE_INIT_IDLE;
}
}
break;
case S_MODULE_INIT_CFUN_CK:
{
g_at_request_res = AT_Common_Requeset_Proc(AT_CODE_CFUN_CK, 0, NULL,0);
if(g_at_request_res == ResultOk)
{
s_init_state = S_MODULE_INIT_VERCTRL;
}
else if(g_at_request_res == ResultFail)
{
s_init_state = S_MODULE_INIT_CFUN1;
}
}
break;
case S_MODULE_INIT_CFUN1:
{
g_at_request_res = AT_Common_Requeset_Proc(AT_CODE_CFUN1, 0, NULL,0);
if(g_at_request_res == ResultOk)
{
s_init_state = S_MODULE_INIT_VERCTRL;
}
else if(g_at_request_res == ResultFail)
{
s_init_state = S_MODULE_INIT_VERCTRL;
}
}
break;
case S_MODULE_INIT_VERCTRL://<2F><>ѯ<EFBFBD><D1AF><EFBFBD>ʽ
{
g_at_request_res = AT_Common_Requeset_Proc(AT_CODE_VERCTRL, 0, NULL,0);
if(g_at_request_res == ResultOk)//<2F><><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>Զ<EFBFBD><D4B6><EFBFBD><EFBFBD><EFBFBD>
{
s_init_state = S_MODULE_INIT_CSQ;
}
else if(g_at_request_res == ResultFail)
{
s_init_state = S_MODULE_INIT_VERCTRL1;
}
}
break;
case S_MODULE_INIT_VERCTRL1://<2F><><EFBFBD><EFBFBD><EFBFBD>Զ<EFBFBD><D4B6><EFBFBD><EFBFBD><EFBFBD>(ע<><D7A2>,<2C><><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>Ч,PCBA<42><41><EFBFBD>Բ<EFBFBD><D4B2><EFBFBD>Ҫ<EFBFBD><D2AA><EFBFBD><EFBFBD><EFBFBD>ɹ<EFBFBD>)
{
g_at_request_res = AT_Common_Requeset_Proc(AT_CODE_VERCTRL1, 0, NULL,0);
if(g_at_request_res == ResultOk)
{
s_init_state = S_MODULE_INIT_CSQ;
}
else if(g_at_request_res == ResultFail)
{
g_s_nbiot_task_flag = TASK_FAIL; //<2F><>ʼ<EFBFBD><CABC><EFBFBD><EFBFBD><EFBFBD><EFBFBD>ʧ<EFBFBD><CAA7>
s_init_state = S_MODULE_INIT_IDLE;
}
}
break;
case S_MODULE_INIT_CSQ:
{
g_at_request_res = AT_Common_Requeset_Proc(AT_CODE_CSQ, 0, NULL,0);
if(g_at_request_res == ResultOk)
{
s_init_state = S_MODULE_INIT_CEREG_CK;
}
else if(g_at_request_res == ResultFail)
{
s_init_state = S_MODULE_INIT_CEREG_CK;
}
}
break;
/*
case S_MODULE_INIT_CTEC_CK:
{
g_at_request_res = AT_Common_Requeset_Proc(AT_CODE_CTEC_CK, 0, NULL,0);
if(g_at_request_res == ResultOk)
{
s_init_state = S_MODULE_INIT_CCED_CK;
}
else if(g_at_request_res == ResultFail)
{
s_init_state = S_MODULE_INIT_CCED_CK;
}
}
break;
case S_MODULE_INIT_CCED_CK:
{
g_at_request_res = AT_Common_Requeset_Proc(AT_CODE_CCED_CK, 0, NULL,0);
if(g_at_request_res == ResultOk)
{
s_init_state = S_MODULE_INIT_CEREG_CK;
}
else if(g_at_request_res == ResultFail)
{
s_init_state = S_MODULE_INIT_CEREG_CK;
}
}
break;
*/
/*case S_MODULE_INIT_CGDCONT:
{
//<2F><>ȡAPN<50><4E><EFBFBD><EFBFBD>
memset(stringbuffer_temp,0,sizeof(stringbuffer_temp));
for(int i = 0; i < Sys_data_object.P1.apn[1]; i++)
{
stringbuffer_temp[i] = Sys_data_object.P1.apn[2 + i];
}
stringbuffer_temp[Sys_data_object.P1.apn[1]] = '\"';
g_at_request_res = AT_Common_Requeset_Proc(AT_CODE_CGDCONT, 1, stringbuffer_temp, Sys_data_object.P1.apn[1]+1);
if(g_at_request_res == ResultOk)
{
s_init_state = S_MODULE_INIT_CGACT;
}
else if(g_at_request_res == ResultFail)
{
s_init_state = S_MODULE_INIT_CGACT;
}
}
break;
case S_MODULE_INIT_CGACT:
{
g_at_request_res = AT_Common_Requeset_Proc(AT_CODE_CGACT, 0, NULL,0);
if(g_at_request_res == ResultOk)
{
s_init_state = S_MODULE_INIT_CEREG_CK;
}
else if(g_at_request_res == ResultFail)
{
s_init_state = S_MODULE_INIT_CEREG_CK;
}
}
break;
*/
case S_MODULE_INIT_CEREG_CK:
{
g_at_request_res = AT_Common_Requeset_Proc(AT_CODE_CEREG, 0, NULL,0);
if(g_at_request_res == ResultOk)
{
s_init_state = S_MODULE_INIT_CGACT_CK;
}
else if(g_at_request_res == ResultFail)
{
s_init_state = S_MODULE_INIT_CGACT_CK;
}
}
break;
case S_MODULE_INIT_CGACT_CK:
{
g_at_request_res = AT_Common_Requeset_Proc(AT_CODE_CGACT_CK, 0, NULL,0);
if(g_at_request_res == ResultOk)
{
s_init_state = S_MODULE_INIT_TUEINFO;
}
else if(g_at_request_res == ResultFail)
{
g_s_nbiot_task_flag = TASK_FAIL; //<2F><>ʼ<EFBFBD><CABC><EFBFBD><EFBFBD><EFBFBD><EFBFBD>ʧ<EFBFBD><CAA7>
s_init_state = S_MODULE_INIT_IDLE;
}
}
break;
case S_MODULE_INIT_TUEINFO:
{
g_at_request_res = AT_Common_Requeset_Proc(AT_CODE_TUEINFO, 0, NULL,0);
if(g_at_request_res == ResultOk)
{
s_init_state = S_MODULE_INIT_CCED;
}
else if(g_at_request_res == ResultFail)
{
s_init_state = S_MODULE_INIT_CCED;
}
}
break;
case S_MODULE_INIT_CCED:
{
g_at_request_res = AT_Common_Requeset_Proc(AT_CODE_CCED, 0, NULL,0);
if(g_at_request_res == ResultOk)
{
s_init_state = S_MODULE_INIT_CCLK;
}
else if(g_at_request_res == ResultFail)
{
s_init_state = S_MODULE_INIT_CCLK;
}
}
break;
case S_MODULE_INIT_CCLK:
{
g_at_request_res = AT_Common_Requeset_Proc(AT_CODE_CCLK, 0, NULL,0);
if(g_at_request_res == ResultOk)
{
g_s_nbiot_task_flag = TASK_SUCCESS; //<2F><>ʼ<EFBFBD><CABC><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>ɹ<EFBFBD>
s_init_state = S_MODULE_INIT_IDLE;
}
else if(g_at_request_res == ResultFail)
{
g_s_nbiot_task_flag = TASK_SUCCESS; //<2F><>ʼ<EFBFBD><CABC><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>ɹ<EFBFBD>
s_init_state = S_MODULE_INIT_IDLE;
}
}
break;
default:
{
g_s_nbiot_task_flag = TASK_FAIL; //<2F><>ʼ<EFBFBD><CABC><EFBFBD><EFBFBD><EFBFBD><EFBFBD>ʧ<EFBFBD><CAA7>
s_init_state = S_MODULE_INIT_IDLE;
}
break;
}
}
void NbiotInitMachine(void)
{
NbiotInitMachine_ML302();
}
/***************************************************************************
* @fun_name void TcpConnectMachine()
* @brief TCP<EFBFBD><EFBFBD><EFBFBD><EFBFBD>״̬<EFBFBD><EFBFBD>
* @param[in] None
* @param[out] None
* @retval None
* @other
***************************************************************************/
void TcpStartConnect(void)
{
s_tcp_connect_state = S_TCP_CONNECT_START;
}
void TcpConnectMachine_ML302(void)
{
unsigned char *nbiot_ip;
u16 nbiot_port;
static int ip_len=0;
switch (s_tcp_connect_state)
{
case S_TCP_CONNECT_IDLE:
{
break;
}
case S_TCP_CONNECT_START:
{
g_at_request_res = AT_Common_Requeset_Proc(AT_CODE_MIPMODE1, 0, NULL,0);
if(g_at_request_res == ResultOk)
{
ip_len = 0;
nbiot_port = coap_port;//Sys_data_object.P1.server_port.datas;
nbiot_ip = coap_ip;//Sys_data_object.P1.server_ip;
memset(stringbuffer_temp,0,sizeof(stringbuffer_temp));
//IP <20>Ĵ洢<C4B4><E6B4A2>Ȼʹ<C8BB><CAB9>ˮ<EFBFBD><CBAE>ԭ<EFBFBD><D4AD><EFBFBD><EFBFBD>ʽ<EFBFBD><CABD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>桰.<2E><><EFBFBD>ţ<EFBFBD>ʹ<EFBFBD><CAB9>ʱ<EFBFBD><CAB1><EFBFBD><EFBFBD>
int i;
for (i = 0; i < 4; i++)
{
if (nbiot_ip[i] < 10)
{
stringbuffer_temp[ip_len++] = nbiot_ip[i] + 0x30;
}
else if (nbiot_ip[i] < 100)
{
stringbuffer_temp[ip_len++] = (nbiot_ip[i] / 10) + 0x30;
stringbuffer_temp[ip_len++] = (nbiot_ip[i] % 10) + 0x30;
}
else
{
stringbuffer_temp[ip_len++] = (nbiot_ip[i] / 100) + 0x30;
stringbuffer_temp[ip_len++] = (nbiot_ip[i] / 10) % 10 + 0x30;
stringbuffer_temp[ip_len++] = (nbiot_ip[i] % 10) + 0x30;
}
stringbuffer_temp[ip_len++] = '.';
}
ip_len--; //<2F><><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>ĵ<EFBFBD><C4B5><EFBFBD>
stringbuffer_temp[ip_len++] = '\"';
stringbuffer_temp[ip_len++] = ',';
stringbuffer_temp[ip_len++] = ((nbiot_port) / 10000) + 0x30;
stringbuffer_temp[ip_len++] = (((nbiot_port) % 10000) / 1000) + 0x30;
stringbuffer_temp[ip_len++] = (((nbiot_port) % 1000) / 100) + 0x30;
stringbuffer_temp[ip_len++] = (((nbiot_port) % 100) / 10) + 0x30;
stringbuffer_temp[ip_len++] = ((nbiot_port) % 10) + 0x30;
stringbuffer_temp[ip_len++] = '\r';
s_tcp_connect_state = S_TCP_CONNECT_MIPOPEN;
}
else if(g_at_request_res == ResultFail)
{
s_tcp_connect_state = S_TCP_CONNECT_MIPOPEN;
}
}
break;
case S_TCP_CONNECT_MIPOPEN:
{
g_at_request_res = AT_Common_Requeset_Proc(AT_CODE_MIPOPEN, 1, stringbuffer_temp,ip_len);
if(g_at_request_res == ResultOk)
{
g_s_nbiot_task_flag = TASK_SUCCESS; //<2F>ɹ<EFBFBD>
s_tcp_connect_state = S_TCP_CONNECT_IDLE;
}
else if(g_at_request_res == ResultFail)
{
g_s_nbiot_task_flag = TASK_FAIL; //<2F><><EFBFBD><EFBFBD>ʧ<EFBFBD><CAA7>
s_tcp_connect_state = S_TCP_CONNECT_IDLE;
}
}
break;
default:
{
g_s_nbiot_task_flag = TASK_FAIL;
s_tcp_connect_state = S_TCP_CONNECT_IDLE;
break;
}
}
}
void TcpConnectMachine(void)
{
TcpConnectMachine_ML302();
}
/***************************************************************************
* @fun_name void TcpSendDataMachine()
* @brief TCP<EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>״̬<EFBFBD><EFBFBD>
* @param[in] None
* @param[out] None
* @retval None
* @other
[15:27:39.342]<EFBFBD>ա<EFBFBD><EFBFBD><EFBFBD>AT+MIPSEND=1,0352
>
[15:27:43.341]<EFBFBD>ա<EFBFBD><EFBFBD><EFBFBD>AT+MIPSEND=1,0352
[15:27:47.357]<EFBFBD>ա<EFBFBD><EFBFBD><EFBFBD>AT+MIPSEND=1,0352
[15:27:51.356]<EFBFBD>ա<EFBFBD><EFBFBD><EFBFBD>AT+MIPSEND=1,0352
[15:27:55.371]<EFBFBD>ա<EFBFBD><EFBFBD><EFBFBD>AT+MIPSEND=1,0352
ע<EFBFBD>⣬<EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>˷<EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>ݳ<EFBFBD><EFBFBD>ȣ<EFBFBD><EFBFBD><EFBFBD>û<EFBFBD>з<EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>ݣ<EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>ó<EFBFBD><EFBFBD><EFBFBD><EFBFBD>޷<EFBFBD>Ӧ
***************************************************************************/
void StartTcpSendData(void)
{
s_tcp_send_state = S_TCP_SEND_START;
}
void TcpSendDataMachine_ML302(void)
{
switch (s_tcp_send_state)
{
case S_TCP_SEND_IDLE:
{
}
break;
case S_TCP_SEND_START:
{
NbiotClearMsg();
memset(stringbuffer_temp,0,sizeof(stringbuffer_temp));
//<2F><><EFBFBD><EFBFBD>
tcp_send_len = 0;
for (int i = 0; i < Nbiot_Send_Data.len; i++)//<2F><>ȡ<EFBFBD><C8A1><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>
{
stringbuffer_temp[tcp_send_len++] = *(Nbiot_Send_Data.buf + i);//<2F><><EFBFBD>ݷ<EFBFBD><DDB7><EFBFBD>ʮ<EFBFBD><CAAE><EFBFBD><EFBFBD><EFBFBD>Ƹ<EFBFBD>ʽ
}
memset(tcp_send_len_buf,0,sizeof(tcp_send_len_buf));
tcp_send_len = Nbiot_Send_Data.len;
//<2F><><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>ݳ<EFBFBD><DDB3><EFBFBD>
if (tcp_send_len < 10)
{
tcp_send_len_buf[0] = tcp_send_len + 0x30;
tcp_send_len_buf_len = 1;
}
else if (tcp_send_len < 100)
{
tcp_send_len_buf[0] = (tcp_send_len / 10) + 0x30;
tcp_send_len_buf[1] = (tcp_send_len % 10) + 0x30;
tcp_send_len_buf_len = 2;
}
else
{
tcp_send_len_buf[0] = (tcp_send_len / 100) + 0x30;
tcp_send_len_buf[1] = (tcp_send_len / 10) % 10 + 0x30;
tcp_send_len_buf[2] = (tcp_send_len % 10) + 0x30;
tcp_send_len_buf_len = 3;
}
s_tcp_send_state = S_TCP_SEND_DATALEN;
}
break;
case S_TCP_SEND_DATALEN://<2F><><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>ݳ<EFBFBD><DDB3><EFBFBD>
{
g_at_request_res = AT_Common_Requeset_Proc(AT_CODE_MIPSENDCOUNT, 1, tcp_send_len_buf, tcp_send_len_buf_len);
if(g_at_request_res == ResultOk)
{
s_tcp_send_state = S_TCP_SEND_DATA;
}
else if(g_at_request_res == ResultFail)
{
g_s_nbiot_task_flag = TASK_FAIL; //ʧ<><CAA7>
s_tcp_send_state = S_TCP_SEND_IDLE;
}
}
break;
case S_TCP_SEND_DATA://<2F><><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>
{
g_at_request_res = AT_Common_Requeset_Proc(AT_CODE_TCPSEND, 1, stringbuffer_temp, tcp_send_len);
if(g_at_request_res == ResultOk)
{
g_s_nbiot_task_flag = TASK_SUCCESS; //<2F>ɹ<EFBFBD>
s_tcp_send_state = S_TCP_SEND_IDLE;
}
else if(g_at_request_res == ResultFail)
{
g_s_nbiot_task_flag = TASK_FAIL; //ʧ<><CAA7>
s_tcp_send_state = S_TCP_SEND_IDLE;
}
}
break;
default:
{
g_s_nbiot_task_flag = TASK_FAIL; //ʧ<><CAA7>
s_tcp_send_state = S_TCP_SEND_IDLE;
}
break;
}
}
void TcpSendDataMachine(void)
{
TcpSendDataMachine_ML302();
}
//<2F><><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>UDP
void UdpStartConnect(u8 udp_num)
{
nbiot_temp_connect_type = udp_num;
s_udp_connect_state = S_UDP_CONNECT_START;
}
/***************************************************************************
* @fun_name void UdpConnectMachine(void)
* @brief <EFBFBD><EFBFBD><EFBFBD><EFBFBD>UDP״̬<EFBFBD><EFBFBD>
***************************************************************************/
void UdpConnectMachine_ML302(void)
{
unsigned char *nbiot_ip;
u16 nbiot_port;
static int ip_len=0;
switch (s_udp_connect_state)
{
case S_UDP_CONNECT_IDLE:
{
break;
}
case S_UDP_CONNECT_START:
{
ip_len = 0;
if(nbiot_temp_connect_type == NBIOT_CONNECT_UDP1)
{
nbiot_port = udp_port1;//Sys_data_object.P2.server_port.datas;
nbiot_ip = udp_ip1;//Sys_data_object.P2.server_ip;
}
else if(nbiot_temp_connect_type == NBIOT_CONNECT_UDP2)
{
nbiot_port = udp_port2;
nbiot_ip = udp_ip2;
}
memset(stringbuffer_temp,0,sizeof(stringbuffer_temp));
//IP <20>Ĵ洢<C4B4><E6B4A2>Ȼʹ<C8BB><CAB9>ˮ<EFBFBD><CBAE>ԭ<EFBFBD><D4AD><EFBFBD><EFBFBD>ʽ<EFBFBD><CABD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>桰.<2E><><EFBFBD>ţ<EFBFBD>ʹ<EFBFBD><CAB9>ʱ<EFBFBD><CAB1><EFBFBD><EFBFBD>
int i;
for (i = 0; i < 4; i++)
{
if (nbiot_ip[i] < 10)
{
stringbuffer_temp[ip_len++] = nbiot_ip[i] + 0x30;
}
else if (nbiot_ip[i] < 100)
{
stringbuffer_temp[ip_len++] = (nbiot_ip[i] / 10) + 0x30;
stringbuffer_temp[ip_len++] = (nbiot_ip[i] % 10) + 0x30;
}
else
{
stringbuffer_temp[ip_len++] = (nbiot_ip[i] / 100) + 0x30;
stringbuffer_temp[ip_len++] = (nbiot_ip[i] / 10) % 10 + 0x30;
stringbuffer_temp[ip_len++] = (nbiot_ip[i] % 10) + 0x30;
}
stringbuffer_temp[ip_len++] = '.';
}
ip_len--; //<2F><><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>ĵ<EFBFBD><C4B5><EFBFBD>
stringbuffer_temp[ip_len++] = '\"';
stringbuffer_temp[ip_len++] = ',';
stringbuffer_temp[ip_len++] = ((nbiot_port) / 10000) + 0x30;
stringbuffer_temp[ip_len++] = (((nbiot_port) % 10000) / 1000) + 0x30;
stringbuffer_temp[ip_len++] = (((nbiot_port) % 1000) / 100) + 0x30;
stringbuffer_temp[ip_len++] = (((nbiot_port) % 100) / 10) + 0x30;
stringbuffer_temp[ip_len++] = ((nbiot_port) % 10) + 0x30;
stringbuffer_temp[ip_len++] = '\r';
s_udp_connect_state = S_UDP_CONNECT_MIPOPEN;
}
break;
case S_UDP_CONNECT_MIPOPEN:
{
if(nbiot_temp_connect_type == NBIOT_CONNECT_UDP1)
{
g_at_request_res = AT_Common_Requeset_Proc(AT_CODE_MIPOPEN_UDP1, 1, stringbuffer_temp,ip_len);
}
else if(nbiot_temp_connect_type == NBIOT_CONNECT_UDP2)
{
g_at_request_res = AT_Common_Requeset_Proc(AT_CODE_MIPOPEN_UDP2, 1, stringbuffer_temp,ip_len);
}
if(g_at_request_res == ResultOk)
{
g_s_nbiot_task_flag = TASK_SUCCESS; //<2F>ɹ<EFBFBD>
s_udp_connect_state = S_UDP_CONNECT_IDLE;
}
else if(g_at_request_res == ResultFail)
{
g_s_nbiot_task_flag = TASK_FAIL; //<2F><><EFBFBD><EFBFBD>ʧ<EFBFBD><CAA7>
s_udp_connect_state = S_UDP_CONNECT_IDLE;
}
}
break;
default:
{
g_s_nbiot_task_flag = TASK_FAIL;
s_udp_connect_state = S_UDP_CONNECT_IDLE;
break;
}
}
}
void UdpConnectMachine(void)
{
UdpConnectMachine_ML302();
}
//
void StartUdpSendData(void)
{
s_udp_send_state = S_UDP_SEND_START;
}
//
void UdpSendDataMachine_ML302(void)
{
switch (s_udp_send_state)
{
case S_UDP_SEND_IDLE:
{
}
break;
case S_UDP_SEND_START:
{
NbiotClearMsg();
memset(stringbuffer_temp,0,sizeof(stringbuffer_temp));
//<2F><><EFBFBD><EFBFBD>
udp_send_len = 0;
for (int i = 0; i < Nbiot_Send_Data.len; i++)//<2F><>ȡ<EFBFBD><C8A1><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>
{
stringbuffer_temp[udp_send_len++] = *(Nbiot_Send_Data.buf + i);//<2F><><EFBFBD>ݷ<EFBFBD><DDB7><EFBFBD>ʮ<EFBFBD><CAAE><EFBFBD><EFBFBD><EFBFBD>Ƹ<EFBFBD>ʽ
}
memset(udp_send_len_buf,0,sizeof(udp_send_len_buf));
udp_send_len = Nbiot_Send_Data.len;
//<2F><><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>ݳ<EFBFBD><DDB3><EFBFBD>
if (udp_send_len < 10)
{
udp_send_len_buf[0] = udp_send_len + 0x30;
udp_send_len_buf_len = 1;
}
else if (udp_send_len < 100)
{
udp_send_len_buf[0] = (udp_send_len / 10) + 0x30;
udp_send_len_buf[1] = (udp_send_len % 10) + 0x30;
udp_send_len_buf_len = 2;
}
else
{
udp_send_len_buf[0] = (udp_send_len / 100) + 0x30;
udp_send_len_buf[1] = (udp_send_len / 10) % 10 + 0x30;
udp_send_len_buf[2] = (udp_send_len % 10) + 0x30;
udp_send_len_buf_len = 3;
}
s_udp_send_state = S_UDP_SEND_DATALEN;
}
break;
case S_UDP_SEND_DATALEN://<2F><><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>ݳ<EFBFBD><DDB3><EFBFBD>
{
if(g_s_nbiot_send_type == SEND_TYPE_UDP1)
{
g_at_request_res = AT_Common_Requeset_Proc(AT_CODE_MIPSENDCOUNT_UDP1, 1, udp_send_len_buf, udp_send_len_buf_len);
}
else if(g_s_nbiot_send_type == SEND_TYPE_UDP2)
{
g_at_request_res = AT_Common_Requeset_Proc(AT_CODE_MIPSENDCOUNT_UDP2, 1, udp_send_len_buf, udp_send_len_buf_len);
}
if(g_at_request_res == ResultOk)
{
s_udp_send_state = S_UDP_SEND_DATA;
}
else if(g_at_request_res == ResultFail)
{
g_s_nbiot_task_flag = TASK_FAIL; //ʧ<><CAA7>
s_udp_send_state = S_UDP_SEND_IDLE;
}
}
break;
case S_UDP_SEND_DATA://<2F><><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>
{
if(g_s_nbiot_send_type == SEND_TYPE_UDP1)
{
g_at_request_res = AT_Common_Requeset_Proc(AT_CODE_UDPSEND1, 1, stringbuffer_temp, udp_send_len);
}
else if(g_s_nbiot_send_type == SEND_TYPE_UDP2)
{
g_at_request_res = AT_Common_Requeset_Proc(AT_CODE_UDPSEND2, 1, stringbuffer_temp, udp_send_len);
}
if(g_at_request_res == ResultOk)
{
g_s_nbiot_task_flag = TASK_SUCCESS; //<2F>ɹ<EFBFBD>
s_udp_send_state = S_UDP_SEND_IDLE;
}
else if(g_at_request_res == ResultFail)
{
g_s_nbiot_task_flag = TASK_FAIL; //ʧ<><CAA7>
s_udp_send_state = S_UDP_SEND_IDLE;
}
}
break;
default:
{
g_s_nbiot_task_flag = TASK_FAIL; //ʧ<><CAA7>
s_udp_send_state = S_UDP_SEND_IDLE;
}
break;
}
}
void UdpSendDataMachine(void)
{
UdpSendDataMachine_ML302();
}
/***************************************************************************
* @fun_name static void NbiotPowerOffMachine()
* @brief <EFBFBD>ػ<EFBFBD>״̬<EFBFBD><EFBFBD>
***************************************************************************/
//ģ<><C4A3><EFBFBD>ػ<EFBFBD>״̬<D7B4><CCAC>
void NbiotPowerOffMachine(void) //<2F><>ע<EFBFBD><D7A2><EFBFBD><EFBFBD><EFBFBD><EFBFBD>Ȼ<EFBFBD><C8BB><EFBFBD>ϵ<EFBFBD><CFB5>ػ<EFBFBD>
{
switch (s_power_off_state)
{
case S_PWOFF_IDLE:
{
}
break;
case S_PWOFF_TCP_CLOSE:
{
if(ConncetIfOnline(NBIOT_CONNECT_COAP) == TRUE)
{
g_at_request_res = AT_Common_Requeset_Proc(AT_CODE_MIPCLOSE, 0, NULL,0);
if(g_at_request_res == ResultOk)
{
s_power_off_state = S_PWOFF_UDP1_CLOSE;
}
else if(g_at_request_res == ResultFail)
{
s_power_off_state = S_PWOFF_UDP1_CLOSE;
}
}
else
{
s_power_off_state = S_PWOFF_UDP1_CLOSE;
}
}
break;
case S_PWOFF_UDP1_CLOSE:
{
if(ConncetIfOnline(NBIOT_CONNECT_UDP1) == TRUE)
{
g_at_request_res = AT_Common_Requeset_Proc(AT_CODE_MIPCLOSE_UDP1, 0, NULL,0);
if(g_at_request_res == ResultOk)
{
s_power_off_state = S_PWOFF_UDP2_CLOSE;
}
else if(g_at_request_res == ResultFail)
{
s_power_off_state = S_PWOFF_UDP2_CLOSE;
}
}
else
{
s_power_off_state = S_PWOFF_UDP2_CLOSE;
}
}
break;
case S_PWOFF_UDP2_CLOSE:
{
if(ConncetIfOnline(NBIOT_CONNECT_UDP2) == TRUE)
{
g_at_request_res = AT_Common_Requeset_Proc(AT_CODE_MIPCLOSE_UDP2, 0, NULL,0);
if(g_at_request_res == ResultOk)
{
s_power_off_state = S_PWOFF_PW_DOWN;
}
else if(g_at_request_res == ResultFail)
{
s_power_off_state = S_PWOFF_PW_DOWN;
}
}
else
{
s_power_off_state = S_PWOFF_PW_DOWN;
}
}
break;
case S_PWOFF_PW_DOWN:
{
if (!check_timer_1s())
{
NB_Power_Disable(); //<2F>жϵ<D0B6>Դ
set_timer_1s(1);
s_power_off_state = S_PWOFF_PW_DOWN_WAIT;
Nbiot_Para.net_state = NB_OFF_LINE;
Nbiot_Para.coap_state = CONNECT_OFF_LINE;
Nbiot_Para.udp1_state = CONNECT_OFF_LINE;
Nbiot_Para.udp2_state = CONNECT_OFF_LINE;
}
}
break;
case S_PWOFF_PW_DOWN_WAIT:
{
if (!check_timer_1s())
{
NbiotPreSleep();
g_s_nbiot_task_flag = TASK_SUCCESS;
s_power_off_state = S_PWOFF_IDLE;
}
}
break;
default:
{
s_power_off_state = S_PWOFF_IDLE;
}
break;
}
}
/***************************************************************************
* @fun_name <EFBFBD><EFBFBD>ʱ<EFBFBD><EFBFBD><EFBFBD><EFBFBD>Դ
* @brief <EFBFBD><EFBFBD><EFBFBD>ڲ<EFBFBD><EFBFBD>ӿ<EFBFBD><EFBFBD><EFBFBD>ҪΪ<EFBFBD>˷<EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>估ʹ<EFBFBD><EFBFBD>
***************************************************************************/
void set_timer_1s(u16 time)
{
Set100msTimer(TIMER_100MS_NBIOT, time * 10);
}
u16 check_timer_1s(void)
{
return Check100msTimer(TIMER_100MS_NBIOT);
}
void set_timer_1ms(u16 time)
{
Set5msTimer(TIMER_5MS_NBIOT, time / 5);
}
u16 check_timer_1ms(void)
{
return Check5msTimer(TIMER_5MS_NBIOT);
}
/***************************************************************************
* @fun_name void StartPowerOffTask()
* @brief <EFBFBD>ػ<EFBFBD><EFBFBD>ӿ<EFBFBD>
***************************************************************************/
void StartPowerOffTask(void)
{
g_s_nbiot_task_flag = TASK_INIT;
g_s_nbiot_main_state = S_NBIOT_MAIN_POWER_OFF;
s_power_off_state = S_PWOFF_TCP_CLOSE;
}
//NBǿ<42>ƹػ<C6B9>
void NbForcePowerOff(void)
{
NB_Power_Disable();
Nbiot_Para.net_state = NB_OFF_LINE;
Nbiot_Para.coap_state = CONNECT_OFF_LINE;
Nbiot_Para.udp1_state = CONNECT_OFF_LINE;
Nbiot_Para.udp2_state = CONNECT_OFF_LINE;
g_s_nbiot_task_flag = TASK_INIT;
g_s_nbiot_main_state = S_NBIOT_MAIN_IDLE;
s_at_requeset_state = AT_REQUEST_IDLE;
}
UNION_4U8TOU32 net_state_data;
u32 sys_get_net_state(void)
{
s16 s_temp_data=0;
if(g_s_nbiot_main_state == S_NBIOT_MAIN_POWER_INIT)
{
net_state_data.data_buf[0] = 1;
net_state_data.data_buf[1] = s_init_state;
//net_state_buf[2]CEREG
//net_state_buf[3]cgatt
}
else if(g_s_nbiot_main_state == S_NBIOT_MAIN_TCP_OPEN)
{
net_state_data.data_buf[0] = 2;
net_state_data.data_buf[1] = s_tcp_connect_state;
}
else if(If_NB_Poweron()==FALSE)
{
net_state_data.data_buf[0] = 3;
//rsrp
NbiotGetRSRP(&s_temp_data);
net_state_data.data_buf[1] = -(s_temp_data/10);
//SNR
NbiotGetSNR(&s_temp_data);
if(s_temp_data<0)
{
net_state_data.data_buf[2] = (-s_temp_data/10)|0x80;
}
else
{
net_state_data.data_buf[2] = s_temp_data/10;
}
//CSQ
NbiotGetCSQ(&net_state_data.data_buf[3]);
}
return net_state_data.datas;
}
void sys_set_net_state(u8 state, u8 data)
{
net_state_data.data_buf[state] = data;
}
/**NB<4E>ӿ<EFBFBD>**/
TYP_PSM_STATE getPsmState(void)
{
return PSM_STATE_OUT;//<2F><><EFBFBD><EFBFBD><EFBFBD><EFBFBD>PSMģʽ
}
void NbiotPsmWakeupTask(void)
{
}
void NbiotPsmSleepTask(void)
{
}
void NbiotPsmCheckTask(void)
{
}
#ifdef __cplusplus
}
#endif
#endif