#ifndef _EC800_H_ #define _EC800_H_ //----------------------包含 #include "usart.h" #include #include #include #include #include #include "cJSON.h" #include "cmsis_os2.h" #include "nmea.h" #include "main.h" #include "turnDetection.h" #include "EC800_FTP_OTA.h" #include "electronicFence.h" #include "task_ec800_upload.h" #include "task_communication.h" #include "global.h" //----------------------宏 //--------参数定义 #define TIMEOUT_MS 2 // 接收响应的等待时间，单位为100毫秒 #define TURN_INTERVAL_TIME_MS 10 // 发布消息的间隔时间单位为100毫秒 转弯过程中的上传时间间隔 #define PUBLISH_TIME_MS 30 // 发布消息的间隔时间单位为100毫秒 行车过程中的上传时间间隔 #define CTR_CODE_JUDETIME 106 // 对时响应的控制代码 #define CTR_CODE_REALDATE 202 // 实时数据响应的控制代码 #define CTR_CODE_REMOTE 602 // 远程响应的控制代码 #define CTR_CODE_LOGIN 102 // 登录响应的控制代码 #define CTR_CODE_FENCES 605 // 围栏数据响应的控制代码 //--------AT指令基础配置 #define AT_CMD_TEST "AT\r\n" // 检查模组状态 模块返回:OK #define AT_CMD_ATE0 "ATE0\r\n" // 取消模块回显 模块返回:OK #define AT_CMD_CPIN "AT+CPIN?\r\n" // 检查SIM是否正常 模块返回:+CPIN: READY #define AT_CMD_CSQ "AT+CSQ\r\n" // 检查信号 模块返回:+CSQ: 25,99 注:主要25这个字段小于31就行 #define AT_CMD_CREG "AT+CREG?\r\n" // 查询模组是否注册上GSM网络 模块返回:+CREG: 0,1 注:1或者5为正常 #define AT_CMD_QIDEACT "AT+QIDEACT=1\r\n" // 关闭移动场景 模块返回:OK #define AT_CMD_QIACT "AT+QIACT=1\r\n" // 打开移动场景 模块返回:OK #define AT_CIMI "AT+CIMI\r\n" // 查询 IMSI 模块返回: OK //--------连接mqtt服务器 #define AT_CMD_QMTCFG \ do { \ "AT+QMTCFG=\"qmtping\",0,30\r\n" \ } while (0) // 设置MQTT心跳 模块返回:OK #define AT_CMD_QMTCFG_SET_DATA_MODE "AT+QMTCFG=\"recv/mode\",0,0,1\r\n" // 设置接收数据的模式 模块返回:OK #define AT_CMD_QMTOPEN "AT+QMTOPEN=0,\"39.98.37.180\",32449\r\n" // 为模块打开一个网络 模块返回:+QMTOPEN: 0,0 #define AT_CMD_QMTCONN "AT+QMTCONN=0,\"NULL\",\"hechun\",\"admin123\"\r\n" // 连接到mqtt服务器 模块返回:+QMTCONN: 0,0,0 //--------订阅主题以及发布 #define TOPIC1 "" // 订阅主题1 #define TOPIC2 "" // 订阅主题2 #define AT_CMD_QMTSUB(TOPIC1, TOPIC2) \ do { \ "AT+QMTSUB=0,1,\"TOPIC1\",0,\"TOPIC2\",0\r\n" \ } while (0) // 连接到mqtt服务器 模块返回:+QMTCONN: 0,0,0 #define STR_TOPIC "" // 访问的主题 #define AT_CMD_QMTPUBEX(STR_TOPIC, len) \ do { \ " AT+QMTPUBEX=0,0,0,0,\"STR_TOPIC\",len\r\n" \ } while (0) // 连接到mqtt服务器 模块返回:+QMTCONN: 0,0,0 //--------AT指令的响应 #define AT_RESP_OK "OK\r\n" #define AT_RESP_ERROR "ERROR\r\n" #define AT_RESP_CPIN_READY "+CPIN: READY\r\n\r\nOK\r\n" #define AT_RESP_CSQ "+CSQ: \r\n" #define AT_RESP_QMTOPEN "+QMTOPEN: 0,0" #define AT_RESP_QMTCONN "+QMTCONN: 0,0,0" #define AT_RESP_QMTSUB "+QMTSUB: 0,1,0,0" #define AT_RESP_QMTPUBEX_RE "> \r\n" #define AT_RESP_QMTPUBEX "+QMTPUBEX: 0,0,0" //--------GNSS的配置 #define AT_QGPS_1 "AT+QGPS=1\r\n" // 打开 GNSS 模块返回:OK #define AT_QGPS_0 "AT+QGPS=0\r\n" // 关闭 GNSS 模块返回:OK #define AT_QGPSCFG_out_port "AT+QGPSCFG=\"outport\",\"uartdebug\"\r\n" // 通过调试串口输出NMEA语句 模块返回:OK #define AT_QGPSCFG_nmeasrc "AT+QGPSCFG=\"nmeasrc\",1\r\n" // 启用/禁用通过 AT+QGPSGNMEA 获取 NMEA 语句。 // 使能后，执行AT+QGPSGNMEA， NMEA 语句将以命令返回值的形式通过 AT 口输出。 模块返回:OK #define AT_QGPSCFG_gpsnmeatype "AT+QGPSCFG=\"gpsnmeatype\",63\r\n" // 配置 NMEA 语句的输出类型 为 所有 格式 模块返回:OK #define AT_QGPSCFG_gnssconfig "AT+QGPSCFG=\"gnssconfig\",1\r\n" // 配置支持的 GNSS 卫星导航系统为 GPS + BeiDou 模块返回:OK #define AT_QGPSCFG_autogps "AT+QGPSCFG=\"autogps\",0\r\n" // 禁用 GNSS 自启动 模块返回:OK #define AT_QGPSCFG_apflash "AT+QGPSCFG=\"apflash\",0\r\n" // 禁用 AP-Flash 快速热启动功能。 模块返回:OK #define AT_QGPSLOC "AT+QGPSLOC=0\r\n" // 获取定位信息 纬度和经度显示格式,格式： ddmm.mmmmN/S,dddmm.mmmmE/W #define AT_QGPSGNMEA_GGA "AT+QGPSGNMEA=\"GGA\"\r\n" // 查询 GGA 语句 #define AT_QGPSGNMEA_GSA "AT+QGPSGNMEA=\"GSA\"\r\n" // 查询 GSA 语句 #define AT_QGPSGNMEA_RMC "AT+QGPSGNMEA=\"RMC\"\r\n" // 查询 RMC 语句 //---------------------函数声明 // @brief 发送指令函数 void EC800M_SendCommand(const char* command); // @brief 接收指令回复函数 char* EC800M_RecRespond(char *haystack, const char *needle ); // @brief 接收使能函数 void EC800_recEnable(void); // @brief EC800M状态转换与使用 extern void EC800_stateTransition_use(void); // 接收并比较响应字符串 uint8_t Accept_and_Compare_Str(const char* needle); // 自定义的搜索函数 void* search_sequence(const void* haystack, size_t haystack_len, const void* needle, size_t needle_len); // @brief 故障数据上传 extern uint8_t EC800_uploadFaultReport(void); // @brief MQTT服务器数据接收处理 extern void handleReceive(void); //---------------------参数声明 typedef struct{ // 为模块打开一个网络中 char ip[20]; // IP uint16_t port; // port // 连接到mqtt服务器 char clientid[20]; // clientid char username[20]; // username char password[20]; // password // 外部使用 uint8_t ec800InitFlag; // ec800模块初始化标志 0：未初始化完成 1；初始化完成 uint8_t hardwareUpdate; // 固件更新标志 1为更新 0为不更新 uint8_t fenceRecSuccess; // 围栏数据接收成功标志 1；接收成功 0；未接收 uint8_t vehSpeed; // vehicle speed 服务器下发的限制车速 }ec800Date; extern ec800Date s_ec800Date; typedef struct{ short drivDirection; // 行驶方向 单位 度 short类型 short vehicleStatus; // 车辆状态 停驶:0 运行中:1 充电中:2 电池离仓:3 故障:4 离线:5 uint8_t nshemi; //北纬/南纬,N:北纬;S:南纬 uint8_t ewhemi; //东经/西经,E:东经;W:西经 uint32_t latitude; //纬度 分扩大100000倍,实际要除以100000 uint32_t longitude; //经度 分扩大100000倍,实际要除以100000 uint32_t Timestamp; // 时间戳 char lat_long_data[40]; // 经纬度数据 // char uploadTime[20]; // 上传时间 char imsi[20]; // SIM卡的IMSI信息 uint16_t vehicleSpeed; // 实时车速 uint16_t dailyDrivTime; // 当日行驶时长 高字节用来表示小时，低字节用来表示分钟 服务器单位为 小时 uint16_t dailyDrivMileage; // 当日行驶里程 0.1km 服务器单位为 km 需要除个10 uint16_t accTotalDrivTime_day; // 累积行驶总时长 天 服务器单位为 小时 uint16_t accTotalDrivTime_h_min; // 累积行驶总时长 小时 分钟 高字节用来表示小时，低字节用来表示分钟 uint16_t accTotalMileage_h; // 累积行驶总里程 高16字节 服务器单位为 km uint16_t accTotalMileage_l; // 累积行驶总里程 低16字节 uint16_t runTime; // 单次运行时长 高字节用来表示小时，低字节用来表示分钟 uint16_t batCompartmentTemp; // 电池仓温度 uint16_t demandCur; // 需求电流 0.1A 上传为float类型 需要除个10 uint16_t demandVol; // 需求电压 0.1V 上传为float类型 需要除个10 uint16_t alarmLevel; // 告警等级 uint16_t alarmType; // 告警类型 uint8_t batSn[40]; // 电池编码ASCII码 uint8_t Vehicle_Num[20]; // 车辆编号 uint8_t VIN[26]; // 车架号 // 设备的唯一ID uint32_t devId[3]; // mcu的唯一性ID // 登录响应数据 uint8_t loginResult; // 登录服务器结果 1: 登录成功 0：登录失败 // 中控板故障数据 uint8_t malfunction; // 故障 定义 // bit0:超出围栏故障 bit1:485通信故障 bit2:升级故障 bit3:MQTT故障 // bit4:陀螺仪故障 bit5：电池故障 bit6：4G模块初始化失败 }messageDate; extern messageDate s_messageDate; extern nmea_utc_time s_nmea_utc_time; #endif