zoukankan      html  css  js  c++  java
  • 最近做的一个嵌入式项目

    上个月做的是电压源的项目,再往上个月是GJX监控设备项目,简单记录下该项目的实现,使用的新塘某款单片机+GSM模块+几个传感器,整体很简单,就是定时采集数据然后,上报到服务器,接收服务器控制指令,控制开发。唯一复杂的是使用了MQTT协议,在网上找了一份嵌入式MQTT包,然后重写发送和接收部分,原来使用的是socket,现在没有socket了,就是串口连GSM模块发AT指令,然后配置成透传,基本上就OK了,因为GSM模块就用了透传,单片机直接往串口里丢数据,GSM自动发到服务器是,MQTT协议花了一段时间大概了解了下,我的理解就是一个应用层的协议,所以GSM整个工作流程也就基本确定下来了,首先在服务器上建立一个MQTT server,然后单片机通过向串口下发AT指令建立一个TCP连接,用MQTT协议组包,直接发送到串口,然后串口监听回包就OK了。花了一段时间去调试温度湿度,斜率震动,RTC这些东西,贴个主流程代码

    int main(void)
    {
    		int ret = -1;
    		uint32_t pubtick = 0;
    		uint32_t ctltick = 0;
    		uint8_t AlarmFlag = 0;
    		CheckFlag = 0;
    		TimerFlag = 0;
        /* Init System, IP clock and multi-function I/O */
        SYS_Init();
    		GpioInit();	
        UART0_Init();
        UART1_Init();
    		UART_ENABLE_INT(UART1, (UART_INTEN_RDAIEN_Msk| UART_INTEN_RXTOIEN_Msk));	/*config uart1 interrupt*/
    		NVIC_EnableIRQ(UART1_IRQn);
    		UART_ENABLE_INT(UART0, (UART_INTEN_RDAIEN_Msk| UART_INTEN_RXTOIEN_Msk));	/*config uart1 interrupt*/
    		NVIC_EnableIRQ(UART0_IRQn);
    		TMR0_Init();
    		TMR1_Init();
    		RestGps();
    		RestGsm();
        I2C0_Init();
        I2C1_Init();
    		Getuid();
    //		SetSlope();
    		Pver = 20;
    
    //		memset(&CONFIG,0,sizeof(CONFIG));
    		CheckWakeFlag();
    		SetAccData();
    		SetAlarm(0);//rtc 15min
    		//GetConfig();
    		GetFsuId(FsuId);
    		ret = GsmInit();
    		if(ret)
    		{
    			printf("gsminit timeout
    ");
    			goto error;
    		}
    		ConnectFlag = 0;
    Connect:
    		ret = MQTT_Connect(ConnectFlag);
    		if(ret != 0)
    			goto error;
    		ret = MQTT_SubAndPub();
    		if(ret != 0)
    			goto error;
    		pubtick = gTick1msCnt;
    		while(1)
    		{
    			if(MQTTMsgReceved_proc() == LOGIN_ACK)
    				break;
    			if((YA_GetSysTimeInterval(pubtick) >= 15000))//15 s
    				goto error;
    		}
    		ret = UpdateFsuId();
    		if(ret)
    			goto Connect;
    		SerializePubMsg(ONLINE);
    		mqtt_publish(PubTopic);
    		pubtick = gTick1msCnt;		
    		while(1)
    		{ 
    //			FeedDog();
    			if(SendFlag)
    			{
    				SendFlag = 0;
    //				printf("send all data
    ");
    				GetAllData();
    				SerializePubMsg(SEND_CONFIG_DATA);
    				mqtt_publish(PubTopic);
    				AlarmFlag=GetLockState();
    
    			}
    			switch(WakeUpFlag)
    			{
    				case 0:
    					PowerDownFlag = 1;
    					break;
    				case 1:
    				#if 0
    					SerializePubMsg(SEND_ALARM);
    					mqtt_publish(PubTopic);
    				#endif
    					PowerDownFlag = 1;
    					break;
    				case 2:
    					if(TimerFlag)
    					{
    						ctltick = gTick1msCnt;
    						TimerFlag = 0;
    						CheckFlag = 1;
    					}
    					if(CheckFlag)
    					{
    						if((YA_GetSysTimeInterval(ctltick) >= 10000))
    						{
    							SendFlag = 1;
    							CheckFlag = 0;
    							CheckHaltFlag = 1;
    							break;
    						}
    					}
    					if(CheckHaltFlag)
    					{
    						AlarmFlag=GetLockState();
    						if(!AlarmFlag)
    							PowerDownFlag = 1;
    					}
    					break;
    				default:
    						break;
    			}
    			MQTTMsgReceved_proc();
    //			SetWakeAndHalt(AlarmFlag);
    			if(PowerDownFlag||(YA_GetSysTimeInterval(pubtick) >= HaltTime))
    			{
    				if(WakeUpFlag != 1)
    					SetAccWakeup();
    				SetAlarm(AlarmFlag);
    				PowerDown();
    			}
    		}
    error:
    	SetAccWakeup();
    	SetAlarm(1);
    	PowerDown();		
    		return 0;
    }
    

      

  • 相关阅读:
    重构之路第一篇——重新组织函数的几种方法
    Maven设置http代理
    maven本地仓库路径和修改
    Maven安装目录分析
    使用Python解析Loadrunner的post的中文数据
    Python3 批量创建文件夹
    tomcat设置上传文件大小
    Jenkins启动
    Sublime Text 3 编译Python3
    常用SQL
  • 原文地址:https://www.cnblogs.com/yinseyingji/p/8270073.html
Copyright © 2011-2022 走看看