dtu_lan_gateway/app/System/includes/task.h

#ifndef __TASK_H
#define	__TASK_H
#include "includes.h"
#include "stm32f2xx.h"
#include "radio.h"
#include "gateway_message.h"
//主要的数据处理线程
#define DATA_TASK_PRIO 8
#define DATA_STK_SIZE  2*1024

#define GetCurrentTime()  OSTimeGet()
extern void data_task(void *pdata);
extern tRadioDriver *Radio;

/* 写入modbus寄存器 */
void write_modbus_data(char* buf);
/* 发送至mqtt */
void send_mqtt(char*buf, int jsonCunt,char*pubJsonStringCopy);
/* 比较data1与data2*/
void find_difference(char* data1, char* data2, char* string);
/* 读取设备数据 */
int read_device_data(DEVICE_PARAMS *current_device,char* buf);

void send_modbus_data(GATEWAY_PARAMS *get, char* buf, int jsonCunt, char*pubJsonStringCopy);
void send_dlt645_data(GATEWAY_PARAMS *get, char* buf, int jsonCunt, char*pubJsonStringCopy);

#endif