物联网到底是什么？

if(pGateWay->run_mode==NwkRunModeStatic)//静态模式 { pNodeTxGw->wireless_ptr=0; if(pGateWay->wireless_num>0) { pNodeTxGw->wireless_ptr=nwk_get_rand()%pGateWay->wireless_num;//随机选择天线 // printf("wireless_ptr=%d\n", pNodeTxGw->wireless_ptr); } printf("wireless_ptr=%d\n", pNodeTxGw->wireless_ptr); printf_oled("wireless_ptr=%d\n", pNodeTxGw->wireless_ptr); pNodeTxGw->tx_state=NwkNodeTxStaticInit;//下一步,静态参数初始化 }

case NwkNodeTxStaticInit://静态参数初始化 { u8 sf=0, bw=0; nwk_get_static_channel4(pNodeTxGw->wireless_ptr, &sf, &bw); u8 freq_ptr=pNodeTxGw->pGateWay->base_freq_ptr + pNodeTxGw->wireless_ptr*NWK_GW_SPACE_FREQ;//计算频率序号,每根天线间隔2MHz pNodeTxGw->freq=NWK_GW_BASE_FREQ+freq_ptr*1000000;//目标天线监听频率 pNodeTxGw->sf=sf; pNodeTxGw->bw=bw; nwk_node_set_lora_param(pNodeTxGw->freq, sf, bw); printf("NwkNodeTxStaticInit P(%.2f, %d, %d)\n", pNodeTxGw->freq/1000000.f, pNodeTxGw->sf, pNodeTxGw->bw); u8 first_buff[20]={0}; u8 first_len=0; first_buff[first_len++]=0xA7; first_buff[first_len++]=g_sNwkNodeWork.node_sn>>24; first_buff[first_len++]=g_sNwkNodeWork.node_sn>>16; first_buff[first_len++]=g_sNwkNodeWork.node_sn>>8; first_buff[first_len++]=g_sNwkNodeWork.node_sn; first_buff[first_len++]=pNodeTxGw->tx_len;//发送长度 first_buff[first_len++]=nwk_get_rand();//随机数1 first_buff[first_len++]=nwk_get_rand();//随机数2 这里暂且明文发送 nwk_node_send_buff(first_buff, first_len);//发送抢占包 u32 tx_time=nwk_calcu_air_time(pNodeTxGw->sf, pNodeTxGw->bw, first_len);//发送时间,冗余 pNodeTxGw->start_rtc_time=nwk_get_rtc_counter();//记录当前时间,防止超时 pNodeTxGw->wait_cnts=tx_time/1000+1;//等待秒数 pNodeTxGw->tx_state=NwkNodeTxStaticFirstCheck; printf("send first buff! tx_time=%ums\n", tx_time); break; } case NwkNodeTxStaticFirstCheck://发送抢占包检测 { u32 now_time=nwk_get_rtc_counter(); u8 result=nwk_node_send_check();//发送完成检测 if(result)//发送完成 { printf("tx_first ok!\n"); pNodeTxGw->freq=nwk_get_sn_freq(g_sNwkNodeWork.node_sn);//根据序列号计算频段 nwk_node_set_lora_param(pNodeTxGw->freq, pNodeTxGw->sf, pNodeTxGw->bw); printf("into recv, wait ack, P(%.2f, %d, %d)\n", pNodeTxGw->freq/1000000.f, pNodeTxGw->sf, pNodeTxGw->bw); nwk_node_recv_init();//进入接收,等待回复 u32 tx_time=nwk_calcu_air_time(pNodeTxGw->sf, pNodeTxGw->bw, 20);//接收回复包等待时间 pNodeTxGw->start_rtc_time=nwk_get_rtc_counter();//记录当前时间,防止超时 pNodeTxGw->wait_cnts=tx_time/1000+2; pNodeTxGw->tx_state=NwkNodeTxStaticFirstAck; } else if(now_time-pNodeTxGw->start_rtc_time>pNodeTxGw->wait_cnts)//发送超时 { printf("tx first time out! wait time=%ds\n", pNodeTxGw->wait_cnts); pNodeTxGw->tx_state=NwkNodeTxStaticExit; } break; } case NwkNodeTxStaticFirstAck://抢占包回复检测 { u32 now_time=nwk_get_rtc_counter(); u8 recv_len=nwk_node_recv_check(g_sNwkNodeWork.node_rx.recv_buff, &g_sNwkNodeWork.rf_param); if(recv_len>0) { //数据解析 u8 *pBuff=g_sNwkNodeWork.node_rx.recv_buff; printf("first ack rssi=%ddbm, snr=%ddbm\n", g_sNwkNodeWork.rf_param.rssi, g_sNwkNodeWork.rf_param.snr); printf_hex("ack=", pBuff, recv_len); u8 head[1]={0xA7}; u8 *pData=nwk_find_head(pBuff, recv_len, head, 1); if(pData) { pData+=1; u32 dst_sn=pData[0]<<24|pData[1]<<16|pData[2]<<8|pData[3]; pData+=4; printf("dst_sn=0x%08X\n", dst_sn); if(dst_sn==g_sNwkNodeWork.node_sn) { nwk_node_send_buff(make_buff, make_len);//发送数据包 u32 tx_time=nwk_calcu_air_time(pNodeTxGw->sf, pNodeTxGw->bw, make_len);//发送时间,冗余 pNodeTxGw->start_rtc_time=nwk_get_rtc_counter();//记录当前时间,防止超时 pNodeTxGw->wait_cnts=tx_time/1000+2;//等待秒数 pNodeTxGw->tx_state=NwkNodeTxStaticAppCheck; printf("send app buff\n"); printf_oled("tx app wire=%d\n", pNodeTxGw->wireless_ptr); } else { printf("sn error!\n"); pNodeTxGw->tx_state=NwkNodeTxStaticExit; } } } else if(now_time-pNodeTxGw->start_rtc_time>pNodeTxGw->wait_cnts)//超时,可能没有抢占到 { printf("wait first ack time out!\n"); pNodeTxGw->tx_state=NwkNodeTxStaticExit; } break; } case NwkNodeTxStaticAppCheck://发送数据包检测 { u32 now_time=nwk_get_rtc_counter(); u8 result=nwk_node_send_check();//发送完成检测 if(result)//发送完成 { printf("tx app ok, recv ack!\n"); nwk_node_recv_init();//进入接收,等待回复 u32 tx_time=nwk_calcu_air_time(pNodeTxGw->sf, pNodeTxGw->bw, 20);//接收回复包等待时间 pNodeTxGw->start_rtc_time=nwk_get_rtc_counter();//记录当前时间,防止超时 pNodeTxGw->wait_cnts=tx_time/1000+2; pNodeTxGw->tx_state=NwkNodeTxStaticAppAck; } else if(now_time-pNodeTxGw->start_rtc_time>pNodeTxGw->wait_cnts)//发送超时 { printf("tx app time out! wait time=%ds\n", pNodeTxGw->wait_cnts); pNodeTxGw->tx_state=NwkNodeTxStaticExit; } break; } case NwkNodeTxStaticAppAck://等待网关回复确认 { u32 now_time=nwk_get_rtc_counter(); u8 recv_len=nwk_node_recv_check(g_sNwkNodeWork.node_rx.recv_buff, &g_sNwkNodeWork.rf_param); if(recv_len>0) { //数据解析 printf("tx ack rssi=%ddbm, snr=%ddbm\n", g_sNwkNodeWork.rf_param.rssi, g_sNwkNodeWork.rf_param.snr); srand(g_sNwkNodeWork.rf_param.rssi); printf_hex("ack=", g_sNwkNodeWork.node_rx.recv_buff, recv_len); nwk_node_recv_parse(g_sNwkNodeWork.node_rx.recv_buff, recv_len); printf_oled("*tx ok! wire=%d", pNodeTxGw->wireless_ptr); } else if(now_time-pNodeTxGw->start_rtc_time>pNodeTxGw->wait_cnts)//超时 { printf("wait ack time out!\n"); pNodeTxGw->tx_state=NwkNodeTxGwExit; } break; } case NwkNodeTxStaticExit://静态退出 { pNodeTxGw->try_cnts++; printf("static try_cnts=%d\n", pNodeTxGw->try_cnts); if(pNodeTxGw->try_cnts>=3)//结束发送 { nwk_node_clear_tx(); pNodeTxGw->alarm_rtc_time=0xFFFFFFFF;//可以进入休眠 } else { u32 now_time=nwk_get_rtc_counter(); pNodeTxGw->wait_cnts=nwk_get_rand()%10;//随机延时,再次尝试 pNodeTxGw->start_rtc_time=now_time; pNodeTxGw->alarm_rtc_time=now_time+pNodeTxGw->wait_cnts;//闹钟时间 if(pNodeTxGw->wireless_ptr>=pNodeTxGw->pGateWay->wireless_num)//结束发送 { nwk_node_clear_tx(); pNodeTxGw->alarm_rtc_time=0xFFFFFFFF;//可以进入休眠 printf_oled("static tx failed!"); } else { printf("tx wait time=%ds\n", pNodeTxGw->wait_cnts); printf_oled("tx wait time=%ds\n", pNodeTxGw->wait_cnts); } printf("static alarm time=%us\n", pNodeTxGw->alarm_rtc_time); } nwk_node_set_led(false);//指示灯灭 pNodeTxGw->tx_state=NwkNodeTxGwIdel;//回合结束 break; }

/* ================================================================================ 描述 : 工作状态检测 输入 : 输出 : ================================================================================ */ void nwk_node_work_check(void) { static NwkNodeTxGwStruct *pNodeTxGw=&g_sNwkNodeWork.node_tx_gw; static NwkNodeTxD2dStruct *pNodeD2d=&g_sNwkNodeWork.node_tx_d2d; static NwkNodeRxStruct *pNodeRx=&g_sNwkNodeWork.node_rx; static NwkNodeSearchStruct *pNodeSearch=&g_sNwkNodeWork.node_search; switch(g_sNwkNodeWork.work_state) { case NwkNodeWorkIdel://空闲 { //网关数据检查 if(pNodeTxGw->tx_len>0)//是否有网关数据需要发送 { u32 now_time=nwk_get_rtc_counter(); if(now_time-pNodeTxGw->start_rtc_time>=pNodeTxGw->wait_cnts)//随机延时结束 { printf("tx gw wait ok! time=%us\n", now_time); pNodeTxGw->alarm_rtc_time=0; pNodeTxGw->tx_state=NwkNodeTxGwInit;//重新开始 g_sNwkNodeWork.work_state=NwkNodeWorkTXGw; } } //D2D数据检查 if(g_sNwkNodeWork.work_state==NwkNodeWorkIdel)//仍旧空闲--D2D { if(pNodeD2d->tx_len>0)//是否有D2D数据需要发送 { u32 now_time=nwk_get_rtc_counter(); u16 wake_period=pNodeD2d->wake_period; if(wake_period==0) wake_period=1; if((now_time+1)%wake_period==0)//唤醒周期到 提前1秒 { printf("tx d2d wait ok! time=%us\n", now_time); pNodeD2d->alarm_rtc_time=0; pNodeD2d->d2d_state=NwkNodeTxD2dInit;//开始 g_sNwkNodeWork.work_state=NwkNodeWorkTXD2d; } } } if(g_sNwkNodeWork.work_state==NwkNodeWorkIdel)//仍旧空闲--入网检查 { u32 now_time=nwk_get_rtc_counter(); for(u8 i=0; i<NWK_GW_NUM; i++) { NwkParentWorkStrcut *pGateWay=&g_sNwkNodeWork.parent_list[i]; if(pGateWay->gw_sn>0) { if(pGateWay->wait_join_time==0) { pGateWay->wait_join_time=nwk_get_rand()%10+3;//首次入网等待时间 pGateWay->last_join_time=now_time; } if(pGateWay->join_state==JoinStateNone && now_time-pGateWay->last_join_time>pGateWay->wait_join_time) { printf("pGateWay=0x%08X, join_state=%d\n", pGateWay->gw_sn, pGateWay->join_state); pGateWay->wait_join_time=nwk_get_rand()%60+60; pGateWay->last_join_time=now_time; nwk_node_req_join(pGateWay->gw_sn);//请求入网 return; } } } } //搜索检查 if(g_sNwkNodeWork.work_state==NwkNodeWorkIdel)//仍旧空闲--搜索 { u32 now_time=nwk_get_rtc_counter(); if(pNodeSearch->search_start_time==0 || //起始 now_time<TIME_STAMP_THRESH || //时间未同步 (pNodeSearch->period>0 && now_time%pNodeSearch->period==0) )//周期到达 { pNodeSearch->search_start_time=now_time; pNodeSearch->search_state=NwkNodeSearchInit; g_sNwkNodeWork.work_state=NwkNodeWorkSearch;//进入搜索状态 } } //接收检查 if(g_sNwkNodeWork.work_state==NwkNodeWorkIdel)//仍旧空闲--接收 { if(g_sNwkNodeWork.wake_period==0)//无需休眠 { pNodeRx->alarm_rtc_time=0;//不休眠 pNodeRx->rx_state=NwkNodeRxInit; g_sNwkNodeWork.work_state=NwkNodeWorkRX; //进入接收监听 } else if(g_sNwkNodeWork.wake_period==0xFFFF)//无需监听 { pNodeRx->alarm_rtc_time=0xFFFFFFFF;//不唤醒 } else { static u32 last_wake_time=0;//上次唤醒时间,避免单次周期内重复唤醒 u32 now_time=nwk_get_rtc_counter(); if(now_time%g_sNwkNodeWork.wake_period==0 && now_time!=last_wake_time) { printf("wake!!! time=%us\n", now_time); // printf_oled("wake!!! time=%us\n", now_time); pNodeRx->rx_state=NwkNodeRxInit; pNodeRx->alarm_rtc_time=now_time+g_sNwkNodeWork.wake_period;//下一次唤醒周期 g_sNwkNodeWork.work_state=NwkNodeWorkRX;//进入接收监听 last_wake_time=now_time; } } } break; } /******************************/ case NwkNodeWorkSearch://搜索 1 { nwk_node_search_process(); if(pNodeSearch->search_state==NwkNodeSearchIdel)//单回合结束 { g_sNwkNodeWork.work_state=NwkNodeWorkIdel; } break; } case NwkNodeWorkRX://接收 2 { nwk_node_rx_process(); if(pNodeRx->rx_state==NwkNodeRxIdel)//单回合结束 { g_sNwkNodeWork.work_state=NwkNodeWorkIdel; } break; } case NwkNodeWorkTXGw://发送到网关 3 { nwk_node_tx_gw_process(); if(pNodeTxGw->tx_state==NwkNodeTxGwIdel)//单回合结束 { g_sNwkNodeWork.work_state=NwkNodeWorkIdel; } break; } case NwkNodeWorkTXD2d://发送到设备 4 { nwk_node_tx_d2d_process(); if(pNodeD2d->d2d_state==NwkNodeTxD2dIdel)//单回合结束 { g_sNwkNodeWork.work_state=NwkNodeWorkIdel; } break; } } }