dtu_lan_gateway/app/System/source/sys_sx1278.c

#include "sys_sx1278.h"
#include "json_queue.h"
#include "sys_mqtt.h"
#include "malloc.h"
#include "task.h"
//sx1278发送线程，其可能存在两处数据源，即轮询发送的采集信息，一个是mqtt下发的数据源，从队列中读取出数据

void sx1278_send_task(void *pdata)
{
	uint8_t err;
	StringInfo *message=NULL; //接收队列消息结构体
	int length;
	while(1)
	{
		message=(StringInfo *)OSQPend(JsonQ,1000,&err);
		if(message!= NULL)
		{
			WRITE_MODBUS_DATA(message->p);
		}
		printf("sx1278_task_recv : %s",message->p);
		myfree(SRAMEX ,message->p);
	}
}