0201_APP/APP/gw_ctrl.h

/*
 * @Description: 
 * @Version: 2.0
 * @Author: Seven
 * @Date: 2022-08-22 09:55:26
 * @LastEditors: Seven
 * @LastEditTime: 2022-09-27 15:18:29
 */
#ifndef __GW_CTRL_H__
#define __GW_CTRL_H__
#include "stm32f10x.h"
#include "tools.h"
#include "Uart.h"

#define PROTOCOL_VERSION    0X01 //协议版本
#define PROTOCOL_VERSION_2	0x02 //2.0协议版本
#define PROTOCOL_VERSION_3	0x03 //3.0协议版本
#define PROTOCOL_VERSION_FF	0xFF //FF协议版本,查当前协议版本

#define UART_TIMEOUT_TIMER (1000)		//串口超时时间

#define LORA_GROUP_NUM 4	//Lora组个数
#define LORA_ADDR           0X40 //Lora参数起始地址
#define LORA_ADDR_OFFSET    0x0C //Lora参数地址偏移量

//协议消息类型
/*网关下发*/
#define GATE_COLL_CMD73			   0x52  //读取73指令
#define GATE_COLL_XSP_QUERY		   0x54	 //显示屏（0904）命令下行
#define GATE_COLL_DISPLAY_QUERY    0x55  //网关下发查询显示屏数据
#define GATE_COLL_HEARTBEAT        0X56  //网关与采集器的下行心跳包
#define GATE_COLL_TAX_QUERY        0x57  //网关下发查询采集器数据(报税口、显示屏)
#define GATE_COLL_HARD_QUERY       0x58  //网关下发查询固件信息
#define GATE_COLL_REBOOT           0x59  //采集器设备重新启动
#define GATE_COLL_TIMESYNC         0x5A  //时间同步
#define GATE_COLL_CTRL_LORAPARA    0x5B  //网关下发切换lora参数
#define GATE_COLL_ENCODER          0x5C  //网关下发查询编码器数据
#define GATE_COLL_REBOOT_TYPE	   0x5D  //根据设备类型重启

/*采集器上传*/
#define COLL_GATE_CMD73			   0x62  //返回73指令
#define COLL_GATE_XSP_REPLY		   0x64  //显示屏（0904）命令上行
//#define COLL_GATE_DISPLAY_REPLY    0x65  //采集器上传显示屏查询数据
#define COLL_GATE_HEARTBEAT        0x66  //网关与采集器的上行心跳包
#define COLL_GATE_TAX_REPLY        0x67  //采集器上传报税口查询的数据
#define COLL_GATE_HARD_REPLY       0x68  //采集器上发固件信息
#define COLL_GATE_ENCODER          0x6C  //采集器上传编码器数据

#define FIRST_TYPE_SYSTEM			0x01 	//一级类型 系统类 transparent
#define SYSTEM_SECOND_TRANS_DOWN	0x1052  //透传指令下行
#define SYSTEM_SECOND_TRANS_UP  	0x2052  //透传指令上行

#define PLAINTEXT      1  //明文
#define CIPHERTEXT     2  //密文

#define POS            4  //POS口
#define TAX            0x0201  //报税口
#define DISPLAY        0x1FFF  //显示屏
#define XSP_0904       0x0904  //显示屏(0904)
#define ENCODER        0x0501  //编码器
#define COLL		   0x0201  //采集器
#define COLL_73		   0x0701  //读73指令

#define UART_SUCCESS   1  //报税口或显示屏口收到数据
#define UART_TIMEOUT   2  //报税口或显示屏口超时
#define UART_TYPE_ERR  3  //明文密文协议错误或查询设备类型错误
#define TAX_GUN_ERR    4  //报税口号或枪号错误
#define ORDER_ERR      5  //编码器指令错误
#define TAX_BUSY	   6  //报税口忙，正在加油

//报税口超时连续次数
typedef struct _uart_timeout_times_t
{
	uint8_t tax1_ch;
	uint32_t tax1_times;
	uint8_t tax2_ch;
	uint32_t tax2_times;
}uart_timeout_times_t;
extern uart_timeout_times_t uart_timeout_times;

#define CIPHERTEXT_ERR_LEN	12//加密模块返回错误指令的最大长度（实际为10字节）

#define CIPHERTEXT_RESET_TIME (1*60*60*1000) //加密模块死机重启定时时间（1hour）
typedef struct _ciphertext_state
{
//	uint8_t flag;
	uint8_t send_num;
//	uint8_t rcv_num;
	timeout_t ciphertext;
}ciphertext_state_t;
extern ciphertext_state_t ciphertext_state;

//读编码器时参数记录
#define ENCODER_GUNSTATUS_TIMEOUT	(2*1000)//2S
typedef struct _read_encoder_para_t
{
	uint8_t flag;						//标记，1 表示1s定时未结束，需读取抬枪状态； 0 表示已结束，不用读取
	uint8_t tax;						//上次读取报税口
	uint8_t gunstatus;					//上次抬枪状态
	timeout_t tt_encoder;				//编码器定时器
}read_encoder_para_t;
extern read_encoder_para_t read_encoder_para;

//下发命令参数存储
typedef struct _msg_para_t
{
	uint32_t Msg_id;					//消息序列号
	uint8_t Coll_no;					//采集器号
	uint16_t Devices_type;				//设备类型
	uint8_t Uart;						//串口号
	uint8_t Tax_no;						//报税口号
	uint8_t Gun_no;						//枪号
	uint8_t Prot_type;					//协议类型  1表示明文，2表示密文
	uint8_t First_type;					//一级消息类型
	uint16_t Second_type;				//二级消息类型
	uint32_t Gw_sn;						//网关sn
}msg_para_t;
extern msg_para_t msg_para;

//Lora通信信息
typedef struct _lora_comm_info_t
{
	timeout_t uart_timeout;
}lora_comm_info_t;
extern lora_comm_info_t lora_comm_info;


//网关下发的设备sn信息
typedef struct _device_sn_info
{
	uint32_t device_sn;
	uint8_t coll_no;
}__attribute__((packed)) device_sn_info_t;

#define MSG_DATA_LEN 244
//网关和采集器通信协议头
typedef struct _collect_gateway_msg_format
{
	uint16_t frame_header;				//帧头
	uint8_t proto_Ver;					//版本号
	uint32_t msg_id;					//消息序列号
	uint8_t  first_type;				//一级消息类型
	uint16_t second_type;				//二级消息类型
	uint16_t msg_len;					//消息长度
	char 	 info[MSG_DATA_LEN];
}__attribute__((packed)) collect_gateway_msg_format_t;

//网关读取73指令结构体
typedef struct _cmd73_query_info
{
	uint32_t device_sn;         		//设备sn
	uint8_t coll_no;            		//采集器号
	uint16_t device_type;       		//查询设备类型（0x0701）
	uint8_t tax_no;             		//报税口号
	uint8_t status;             		//执行结果(1:成功 ；4：报税口号或枪号错误；)
	uint16_t data_len;          		//后面数据长度
	char info[128];
}__attribute__((packed)) cmd73_query_info_t;

#define BUSINESS_DATA_LEN	229
//网关查询业务数据的结构体(报税口、显示屏、编码器)
typedef struct _business_query_info
{
	uint32_t device_sn;         		//设备sn
	uint8_t coll_no;            		//采集器号
	uint16_t device_type;       		//查询设备类型（0x0101：网关；0x0201：采集器；0x0301:液位仪采集器；0x0401：屏采集器；0x0501：编码器）
	uint8_t tax_no;             		//报税口号
	uint8_t gun_no;          			//枪号
	uint8_t prot_type;          		//协议类型  1表示明文，2表示密文
	uint8_t status;             		//执行结果 1:成功 2：读取数据超时
	uint16_t data_len;          		//后面数据长度
	char info[BUSINESS_DATA_LEN+2];
}__attribute__((packed)) business_query_info_t;


//心跳包返回结构体
typedef struct _coll_heartbeat
{
	uint32_t device_sn;        			//设备sn
	uint8_t coll_no;           			//采集器号
	uint8_t status;            			//采集器明文密文类型，1表示明文，2表示密文 （网关下发时没有这个参数）
}__attribute__((packed)) coll_heartbeat_t;


//采集器固件信息上传
typedef struct _coll_hard_reply
{
	uint32_t device_sn;        			//设备sn
	uint8_t coll_no;           			//采集器号
	uint32_t bootloader_vr;    			//bootloader版本
	uint32_t app_vr;           			//app版本
	uint32_t reset_num;        			//复位次数
	uint8_t last_reset_type;   			//最后一次复位类型
	uint32_t run_times;        			//运行时长
	uint32_t voltage;          			//电压
	uint32_t temperature;      			//温度
	uint8_t updata_state;      			//升级状态
	uint8_t UUID[12];          			//UUID
}__attribute__((packed)) coll_hard_reply_t;

//Lora下发参数
typedef struct _gateway_lora_para
{
	uint32_t device_sn;                	//设备sn
	uint8_t coll_no;                   	//采集器号
	uint8_t para_flag;                 	//0：仅lora_paraIndex参数字段有效，其他参数字段无效，默认。 1：全部参数字段有效
	uint8_t lora_group;                	//Lora参数组号
	uint32_t lora_fre;                 	//频率
	uint8_t lora_tx_output_power;      	//功率
	uint8_t lora_bandwidth;            	//带宽
	uint8_t lora_spreading_factor;     	//扩频因子
	uint8_t lora_codingrate;           	//纠错编码率
	uint8_t lora_preamble_length;      	//前导码长度
}__attribute__((packed)) gateway_lora_para_t;


//时间同步
typedef struct _time_sync
{
	uint32_t device_id;                	//设备编号
	uint8_t coll_no;                   	//采集器号
	uint32_t time_stamp;               	//时间戳
}__attribute__((packed)) time_sync_t;

//根据设备类型复位
typedef struct _reboot_type_t
{
	uint32_t device_id;					//设备sn
	uint8_t coll_no;					//采集器号
	uint16_t device_type;				//设置类型
	uint8_t cmd;						//命令（0x01，重启）
	uint32_t reserve;					//预留
}__attribute__((packed)) reboot_type_t;


//透传指令
typedef struct _transparent_info_t
{
	uint32_t gw_sn;						//网关sn
	uint32_t coll_sn;					//采集器sn
	uint8_t tax_no;						//报税口号
	uint8_t status;						//状态
	uint16_t data_len;					//数据长度
	uint8_t info[128];					//数据
}__attribute__((packed)) transparent_info_t;

//读明密文状态信息
typedef struct _read_56_inifo
{
	uint8_t step;
	uint8_t num;
	uint8_t read_way;			//读取方式，1： 72、73， 0： 86
	uint8_t read_way_tax1;		//读取方式，1： 72、73， 0： 86
	uint8_t read_way_tax2;		//读取方式，1： 72、73， 0： 86
}read_56_info_t;
extern read_56_info_t read_56_info;

#define CMD73_LEN		32
//73信息存储
typedef struct _cmd_73_info
{
	uint8_t read_flag;
	uint16_t len;
	uint8_t data[CMD73_LEN];
}__attribute__((packed)) cmd_73_info_t;
extern cmd_73_info_t cmd_73_info[2];

//结构体头的长度
#define FRAME_HEADER_LEN 12
#define BUSINESS_QUERY_HEADER_LEN  13
#define HEARTBEAT_HEADER_LEN (sizeof(coll_heartbeat_t))
#define HARD_HEADER_LEN (sizeof(coll_hard_reply_t))
#define TRANSPARENT_HEADER_LEN 12
#define CMD73_QUERY_HEADER_LEN	(sizeof(cmd73_query_info_t)-128)
	

extern uint8_t rcv_buf[UART_RCV_PROCBUF_LEN];
extern uint16_t rcv_size,rcv_size_temp;

void ciphertext_state_isout(void);
void uart_timeout_handle(void);
void gateway_down_business_return(uint8_t first_type, uint8_t state, uint8_t *data, uint8_t len);
void business_uart_rcv_proc(void);
void gateway_coll_ctrl_comm(collect_gateway_msg_format_t *p_msg);
void coll_encoder_return(uint8_t tax, uint8_t gun, uint8_t order);
void coll_transparent_return(uint8_t first_type, uint8_t state, uint8_t *data, uint8_t len);
void gateway_coll_transparent_proc(collect_gateway_msg_format_t *p_msg);
void read_56_init(void);
void read_56_start(uint8_t uart_id);
extern void tax_rcv_proc(uint8_t *data, uint16_t len);
void uart_fifo_clear(uint8_t uart_id);
extern void tax_ciphertext_0x8C_process(void);
extern void coll_heartbeat_return(void);
#endif