0301_APP/APP/network_mgr/net_proc.h

#ifndef _NET_PROC_H_
#define _NET_PROC_H_
#include "stm32f10x.h"
//#include "os.h"
#include "includes.h"
#include "device.h"
#include "gateway.h"
//#include "net_proc.h"
#include "../dev_mgr/taxctrl/tax_ctrl.h"
//#include "oiltank.h"
//#include "net_ctrl.h"
#include "../network/downlink.h"
#include "../network/uplink.h"
#include "net_ctrl.h"
#include "../gateway_collect/gateway_collect.h"


#define UPDATE_TOTAL_PERIOD (10*60)//(5*60) //(500*10)//*60) // 1为1S， 5为5S 5*60：5分钟


#define UPDATE_EACH_TIME 300
extern uint8_t RadioRxPayload[255];

enum {
    UP_PROG_FROM_NET = 0x22, // 来源来网络
    UP_PROG_FROM_GAT = 0x44, //来源来网关
};
enum { // 升级结果类型
    UPDATE_RECEIVE_UPDATEFLAG = 0x11, // URL的地址与长度不匹配
    UPDATE_SAMEVERSION, // 和当前版本相同
    UPDATE_FAILE_NOCOLLECT, // 此采集器不在本网关下
    UPDATE_DOWNLOADFILE_FAILED, //文件下载失败,即文件大小小于2个字节
    UPDATE_HTTP_ERROR,  //HTTP返回错误码
    UPDATE_DOWNLOADFILE_SUCCESS, // 文件下载成功
    UPDATE_CRCERROR, // 文件包中的CRC与实际不符
    UPDATE_URL_FILE_TYPE_ERROR, // URL中的文件信息与文件包中的信息不一致
    UPDATE_DEVICETYPEERROR, // 升级设备类型不匹配
    UPdATE_FILE_LEN_ERROR,  // 升级文件长度超过128个字节
    UPDATE_SUCCESS, // 升级成功
    UPDATE_RETURN_SUCESS, // 回退
//    UPDATE_SUCESS, // 升级程序成功
//    UPDATE_TYPEERROR, // 升级类型不匹配 当前升级文件不是网关的，或不是本采集器的
//    UPDATE_FIXCHARERROR, // 文件包中的固定字符错误
//    UPDATE_TOTALLENERROR, // 文件包中的长度与实际长度不对应该
//    UPDATE_FILEVERSION, // 文件包中的版本和当前文件名中的版本不一致
//    UPDATE_FAILED , // 升级失败
//    UPDATE_UPDATEING, // 升级中
//    UPDATE_FINISH, // 升级完成
};

typedef enum net_msg_type {
	/* 以下为外部交互信息 */
	/* uplink, 设备侧 ---> 后端服务器 */
	net_msg_type_none,
	net_msg_type_lot = 1,
	net_msg_type_trans = 2,
	net_msg_type_oiltank = 3,
	net_msg_type_gps = 4,
	net_msg_type_gateway = 5,
	net_msg_type_log = 6,
	net_msg_type_debug = 7,
	
	/* downlink 后端服务器 ----> 设备侧 */
	net_msg_type_rsv = 0x80,
	net_msg_type_config = 0x81,
	net_msg_type_update = 0x82,
	net_msg_type_chnbind = 0x83,
	net_msg_type_commnd = 0x84,
	net_msg_type_reboot = 0x85,

	/* 以下为内部交互信息，通过内部lora局域网交互升级包 */
	net_msg_type_timer,

	/* Gateway ----> Node */
	net_msg_type_update_start = 0x13,
	net_msg_type_update_continues = 0x14,
	net_msg_type_update_retransmit_rsp = 0x15,
	net_msg_type_update_ack_status = 0x16,	

	/* Node ---->  Gateway */	
	net_msg_type_update_retransmit_req = 0x22,
	net_msg_type_update_status = 0x21,		

	/* 网关绑定相关 */
	net_msg_type_bind_req = 0x40,
	net_msg_type_bind_rsp = 0x41,
	net_msg_type_node_echo = 0x42,
	net_msg_type_gw_echo = 0x43,
} net_msg_type;

typedef struct _update_msg_format {
        uint16_t rcv_device_type; // 接收设备的类型
        uint32_t rcv_device_id; //接收设备的SN
        uint16_t des_device_type;//升级设备的类型
        uint32_t des_device_id;//升级设备的SN
        uint32_t update_version; //升级版本
	char  url[128];
}__attribute__((packed)) update_msg_format;

// 0x13指令 下行，启动升级指令
typedef struct _ota_start_info {   
        uint16_t rcv_device_type;// 接收设备的类型 和SN
        uint32_t  rcv_device_id;
        uint16_t  des_device_type;//被升级设备的设备类型和id
        uint32_t  des_device_id;
        uint32_t  update_version;//升级包类型和版本；
        uint32_t  total_bytes;//升级包总长度和校验码
        uint16_t  time;  // 每包间隔时常

}__attribute__((packed)) ota_start_info_t;
// 0x14 0x15 指令 连续包 和重传包指令
typedef struct _ota_continues_info { 
    uint16_t rcv_device_type;// 接收设备的类型 和SN
    uint32_t  rcv_device_id;
    uint16_t  des_device_type;//被升级设备的设备类型和id
    uint32_t  des_device_id;
    uint16_t  total_pkgs; // 升级包的总个数
    uint16_t  sub_pkg_id; //升级包的编号
    uint8_t   sub_pkg_len; //每包的长度
//	uint32_t *pkg_content;
}__attribute__((packed)) ota_continues_info_t;
// 0x22指令 请求重传包指令
typedef struct _ota_retransmit_req {//重传请求
        uint16_t  rcv_devict_type; //接收设备
        uint32_t  rcv_device_id; //接收设备
        uint16_t  repeat_sub_pkg_id;
}__attribute__((packed)) ota_retransmit_req_t;

// 0x16指令  网关通知采集器去升级采集器
typedef struct _ota_lineoffupdate_collect {
    uint16_t master_device_type; // 主设备类型
    uint32_t master_device_sn;   // 主设备SN
    uint16_t slave_device_type;  // 从设备类型
    uint32_t slave_device_sn;    // 从设备 SN
    uint16_t des_device_type;    // 升级目标设备类型
    uint32_t des_device_sn;      // 升级目标设备SN
    uint32_t reserve;            // 预留
}__attribute__((packed)) ota_lineoffupdate_coll_t;

// 0x23 指令，
typedef struct _ota_updatestatus_up { // 升级状态上报
    uint16_t rcv_device_type;// 接收设备的类型 和SN
    uint32_t  rcv_device_id;
    uint16_t  des_device_type;//被升级设备的设备类型和id
    uint32_t  des_device_id;
    uint32_t  des_device_bootVr; //被升级设备的bootloader版本
    uint32_t  des_device_appVr;  // 被升级设备的APP版本
    uint8_t   status; // 升级状态码
    uint32_t  reserve;  // 预留
}__attribute__((packed)) ota_updatestatus_up_t;

typedef struct _inner_msg_format {
	uint16_t frame_header;      //帧头
	uint16_t fcs;               //帧校验
	uint32_t seq_no;            //消息序列号
	uint8_t  proto_ver;         //协议版本
	uint8_t  type;              //消息类型
	uint16_t len;               //消息长度
	char 	 info[160];
} inner_msg_format_t;



typedef struct _server_msg_header {
    uint16_t frame_header;      //帧头
    uint8_t  proto_ver;         //协议版本 0x01
    uint32_t seq_no;            //消息序列号
    uint8_t  msgtypeFirst;      //一级消息类型 0x01:系统类  0x02:状态类 0x03:数据类 0x04:产测类
    uint16_t msgtypeSecd;       // 二级消息类型
    uint16_t len;               //消息长度
    char 	 info[1024];
}__attribute__((packed)) sverMsgHeader;




#define		FRAME_HEADER_LEN		12

#if 1
//#define		MQTT_SERVER_IP			"8.142.80.166"
#define		MQTT_SERVER_IP			"test-mqtt.cpyypt.cn"
#else
#define		MQTT_SERVER_IP			"39.100.96.218"
#endif
//#define		MQTT_SERVER_PORT		"1883"
#define		MQTT_SERVER_PORT		"9000"

//#define		MQTT_UPLINK_LOT_TOPIC		"LotDeviceInfo"  //LotDeviceInfo
#define		MQTT_UPLINK_LOT_TOPIC		"cpyypt/up/"//"/mqtt/topic"  //LotDeviceInfo //"/mqtt/downlink"
#define		MQTT_UPLINK_TRANS_TOPIC		"Transaction"
#define		MQTT_UPLINK_TANK_TOPIC		"OilTankLevel"
#define		MQTT_UPLINK_GPS_TOPIC		"GPSLocation"
#define		MQTT_UPLINK_GATEWAY_TOPIC	"GWDeviceInfo" //
#define		MQTT_UPLINK_LOG_TOPIC		"LogInfo"
#define		MQTT_UPLINK_DEBUG_TOPIC		"DebugInfo"

#define         MQTT_UPLINK_TOPIC  "cpyypt/up/"
#define         MQTT_DNLINK_TOPIC  "cpyypt/down/"
#define         MQTT_DNLINK_TOPIC_CASE "cpyypt/down/"

#define 	TOPIC_GET_BY_MSGTYPE(msg_type)		((msg_type == net_msg_type_lot)?(MQTT_UPLINK_LOT_TOPIC):\
				((msg_type == net_msg_type_trans)?(MQTT_UPLINK_TRANS_TOPIC):	\
				((msg_type == net_msg_type_oiltank)?(MQTT_UPLINK_TANK_TOPIC):	\
				((msg_type == net_msg_type_gps)?(MQTT_UPLINK_GPS_TOPIC):(MQTT_UPLINK_GATEWAY_TOPIC)))))

typedef void (*net_init)(char *device_id);
typedef void (*net_send)(char *buffer, uint32_t len);
typedef uint32_t (*net_recv)(char *buffer, uint32_t *len);

typedef struct _net_drv {
	net_init init;
	net_send send;
	net_recv recv;
} net_drv_t;

typedef enum DEV_WORK_STATE
{
        DEV_WORK_STATE_NORMAL,
        DEV_WORK_STATE_UPDATING,
        DEV_WORK_STATE_UPDATE_RETRANSMIT,
        DEV_WORK_STATE_ONLOOKER,                   //旁观者模式
        DEV_WORK_STATE_OTA_BEGIN,                  //开始升级模式
        DEV_WORK_STATE_OTA_CONTINUOUS,             //升级中连续收包模式
        DEV_WORK_STATE_OTA_RETRANSMIT,             //升级中重传模式
        DEV_WORK_STATE_OTA_UPGRADE_RCV_END,        //升级中升级包接收完成模式
        DEV_WORK_STATE_PT,                         //产测模式
        DEV_WORK_STATE_UNINIT,                     //出厂信息未初始化模式

        DEV_WORK_STATE_MAX
}DEV_WORK_STATE_T;

typedef struct _system_network {
        uint8_t memory[4][1024];		//必须4字节对齐
	uint8_t dev_type;
	uint8_t workstate;
	OS_Q  net_q;
	OS_SEM sem;
	OS_MEM net_m;
	OS_TMR net_tmr;
	void * net_hdl; // mqtt是否初始化
	net_send uplink_send; //4G 上传数据的函数指针
	net_send downlink_send; //4G 下载数据的函数指针
	uint32_t seq_no;
	char str[1024];
}system_network_t;


extern system_network_t	sys_net;

void NET_IMEI_ICCID_INFO_GET(char *imei, char *iccid);
void net_queue_insert(char *p_msg, uint32_t msg_len);
void * net_queue_mem_calloc(void);
int net_queue_mem_free(void * p_msg);
//void net_msg_frame_fill(gateway_collect_com_t *p_msg, uint8_t msg_type, uint16_t len);

extern void close_tcp_mqtt(void);

void svc_proc(uint32_t dev_type, uint32_t dev_id);
void * net_queue_mem_calloc_must(void);
//extern void collect_msg_frame_fill(gateway_collect_com_t *p_msg,uint8_t msg_type,uint16_t len);
extern void gateway_update_proc(uint8_t *data,uint8_t msg_len);
extern void gateway_update_collect_status(void);
extern void gateway_reset_send_update_status(void);

extern void uplink_net_send(char *buffer, uint32_t len);
extern void * uplink_net_init(char *device_id) ;
extern void gateway_update_gateway_proc(void);
extern void gateway_update_gateway_status(void);
#endif