“把原来单一串口单一传感器改成多串口多传感器模式”

TestComm/app/src/main/cpp/SensorsProtocol.h

@@ -8,11 +8,98 @@
 #include <string>
 #include "GPIOControl.h"
 
+#ifndef DWORD
+typedef unsigned int DWORD;
+#endif
+#ifndef WORD
+typedef unsigned short WORD;
+#endif
+#ifndef BYTE
+typedef unsigned char BYTE;
+#endif
+#ifndef FALSE
+#define FALSE 0
+#endif
+#ifndef TRUE
+#define TRUE 1
+#endif
+
+#define LOBYTE(w)               ((unsigned char)(w))
+#define HIBYTE(w)               ((unsigned char)(((unsigned short)(w) >> 8) & 0xFF))
+
+#define LOWORD(l)       ((WORD)(l))
+#define HIWORD(l)       ((WORD)((DWORD)(l) >> 16))
+
 #define MAX_STRING_LEN 32
 #define IOT_PARAM_WRITE 0xAE
 #define IOT_PARAM_READ 0xAF
 
-#define LOGE(fmt, args...) __android_log_print(ANDROID_LOG_ERROR, "serial_port_comm", fmt, ##args)
+#define	MAX_SERIAL_DEV_NUM			25		/* 最大接串口传感器数量*/
+#define	MAX_SERIAL_PORT_NUM		    3		/* 最大串口数量*/
+
+#define		TIMER_CNT				10			// Poll命令定时器时间 50 ms
+
+#define	WEATHER_PROTOCOL    	    1			/* 温湿度协议序号*/
+#define	WIND_PROTOCOL				2			/* 风速风向协议序号*/
+#define	SLANT_PROTOCOL			    3			/* 倾斜角协议序号*/
+#define	RALLY_PROTOCOL		        4			/* 拉力协议序号*/
+#define	PELCO_P_PROTOCOL			5			/* 摄像机Pelco_P协议序号*/
+#define	PELCO_D_PROTOCOL			6			/* 摄像机Pelco_D协议序号*/
+#define	SERIALCAMERA_PROTOCOL	    8			/* 串口摄像机协议序号*/
+#define	RESERVE2_PROTOCOL			17			/* 备用2协议序号*/
+#define	RESERVE4_PROTOCOL			19			/* 备用4协议序号*/
+#define	RESERVE5_PROTOCOL			20			/* 备用5协议序号*/
+#define	INVALID_PROTOCOL			21			/* 无效协议序号*/
+
+#define	WEATHER_DATA_NUM			8			/* 气象数据最大数量(一般最多是6要素)*/
+#define	RALLY_DATA_NUM				2			/* 拉力数据最大数量(一般是1个)*/
+#define	SLANTANGLE_DATA_NUM			3			/* 倾角数据最大数量(一般只有X轴和Y轴值)*/
+
+#define			PTZ_MOVETIME		            1 	    // 云台移动等待时间为1秒
+#define		    MAX_CHANNEL_NUM		            2		/* 视频通道最大通道*/
+#define		    MAX_PHOTO_FRAME_LEN				256		/* 图片数据一包最大长度*/
+
+#define	RECVDATA_MAXLENTH		    2048			/* 接收数据缓冲区最大值*/
+#define		TIMER_CNT				10			// Poll命令定时器时间 50 ms
+#define	SENDDATA_MAXLENTH 	RECVDATA_MAXLENTH				/* 正常发送数据缓冲区最大值*/
+
+// 摄像机控制命令宏定义
+#define Cmd_Cancel				0x00000000 // 关闭功能
+#define SET_PRESETNO			0x00030000 // 设置预置点
+#define MOVE_TO_PRESETNO		0x00070000 // 调用预置点
+
+/* 摄像机PELCO-P控制命令宏定义*/
+#define P_Auto_Scan					0x20000000 /* 自动扫描功能控制(1/0 打开/关闭该功能)*/
+#define P_IRIS_CLOSE				0x08000000 /* 光圈缩小(1 有效)*/
+#define P_IRIS_OPEN					0x04000000 /* 光圈放大(1 有效)*/
+#define P_FOCUS_NEAR				0x02000000 /* 近距离聚焦(1 有效)*/
+#define P_FOCUS_FAR					0x01000000 /* 远距离聚焦(1 有效)*/
+#define P_ZOOM_WIDE				0x00400000 /* 远离物体(1 有效)*/
+#define P_ZOOM_TELE					0x00200000 /* 接近物体(1 有效)*/
+#define P_MOVE_DOWN				0x0010001f /* 向下移动镜头(1 有效)*/
+#define P_MOVE_UP					0x0008001f /* 向上移动镜头(1 有效)*/
+#define P_MOVE_LEFT					0x00041f00 /* 向左移动镜头(1 有效)*/
+#define P_MOVE_RIGHT				0x00021f00 /* 向右移动镜头(1 有效)*/
+
+// 摄像机PELCO-D控制命令宏定义
+#define D_Auto_Scan					0x10000000 /* 自动扫描功能控制(1/0 打开/关闭该功能)*/
+#define D_IRIS_CLOSE				0x04000000 /* 光圈缩小(1 有效)*/
+#define D_IRIS_OPEN					0x02000000 /* 光圈放大(1 有效)*/
+#define D_FOCUS_NEAR				0x01000000 /* 近距离聚焦(1 有效)*/
+#define D_FOCUS_FAR				0x00800000 /* 远距离聚焦(1 有效)*/
+#define D_ZOOM_WIDE				0x00400000 /* 远离物体(1 有效)*/
+#define D_ZOOM_TELE				0x00200000 /* 接近物体(1 有效)*/
+#define D_MOVE_DOWN				0x0010002d /* 向下移动镜头(1 有效)*/
+#define D_MOVE_UP					0x0008002d /* 向上移动镜头(1 有效)*/
+#define D_MOVE_LEFT					0x00042d00 /* 向左移动镜头(1 有效)*/
+#define D_MOVE_RIGHT				0x00022d00 /* 向右移动镜头(1 有效)*/
+
+#define LOGE(fmt, args...) __android_log_print(ANDROID_LOG_ERROR, "serial_port_comm", fmt, ##args)  /* 红色*/
+#define LOGI(fmt, args...) __android_log_print(ANDROID_LOG_INFO, "Sensors_Protocol", fmt, ##args)   /* 草绿色*/
+#define LOGV(fmt, args...) __android_log_print(ANDROID_LOG_VERBOSE, "serial_port_comm", fmt, ##args)/* 白色*/
+#define LOGW(fmt, args...) __android_log_print(ANDROID_LOG_WARN, "Sensors_Protocol", fmt, ##args)   /* 黄色*/
+#define LOGD(fmt, args...) __android_log_print(ANDROID_LOG_DEBUG, "Sensors_Protocol", fmt, ##args)  /* 蓝色*/
+#define		HexCharToInt( c ) (((c) >= '0') && ((c) <= '9') ? (c) - '0' : ((c) >= 'a') && ((c) <= 'f') ? (c) - 'a' + 10 :((c) >= 'A') && ((c) <= 'F') ? (c) - 'A' + 10 : 0 )
 
 typedef struct
 {
@@ -23,26 +110,184 @@ typedef struct
     char str[MAX_STRING_LEN];
 }IOT_PARAM;
 
-// 串口参数
 typedef struct
 {
-    int		    baudrate;	/* 波特率*/
+    //float		fAiDead;		// 数据变化死区(百分系数值,如:设置死区为5%，只需赋值5即可)
-    int 		databit;	/* 数据位*/
+    float		fFactor;		// 数据系数
-    char		stopbit[8];	/* 停止位*/
+    float		EuValueDelta;	// 数据工程值偏移
-    char		parity;		/* 校验位*/
+    //BYTE		Polar;			// 数据极性(有无符号位)
-    char		pathname[128];/* 串口文件名及路径*/
+} AI_PARAM;
+
+typedef struct
+{
+    AI_PARAM	    AiParam;		// 数据点配置参数
+    BYTE		    AiState;		// 遥测是否有效标识
+    float			EuValue;		// 遥测工程值
+} AI_DEF;
+
+// 需要配置的串口装置参数
+typedef struct
+{
+    unsigned int		    baudrate;	        /* 波特率*/
+    int 		            databit;	        /* 数据位*/
+    char		            stopbit[8];	        /* 停止位*/
+    char		            parity;		        /* 校验位*/
+    char		            pathname[64];       /* 串口文件名及路径*/
+    int                     commid;             /* 串口序号*/
+    u_char		            ProtocolIdx;		/* 规约索引，大于 0*/
+    int			            devaddr;			/* 装置使用的地址*/
+    u_char		            IsNoInsta;			/* 装置没有安装或者已经坏了(1:正常, 0:无效，坏了或没有安装)*/
+    u_char		            CameraChannel;		/* 像机的通道号*/
+    //u_char		            PowerPort;		/* 传感器所接航空头编号*/
 } SERIAL_PARAM;
 
 typedef struct
 {
-    int		    m_iRevStatus;	/* */
+    int		    m_iRevStatus;	    /* */
-    int 		m_iRecvLen;	/* */
+    int 		m_iRecvLen;	        /* */
     int		    m_iNeedRevLength;	/* */
-    int		    iRecvTime;		/* */
+    int		    iRecvTime;		    /* */
-    int         RevCmdFlag;
+    u_char	    m_au8RecvBuf[RECVDATA_MAXLENTH];/* */
-    unsigned char	m_au8RecvBuf[128];/* */
+    int         fd;                    /* 串口打开的文件句柄*/
+    u_char		PollCmd[SENDDATA_MAXLENTH];
+    int			cmdlen;				// 发送缓冲区命令长度
+    //******************** Poll Cmd ****************************
+    u_char		Retry;				/* 重试命令次数 */
+    u_char		RetryCnt;			/* 重试命令计数*/
+    u_long		RetryTime;			/* 重试命令时间 */
+    u_long		RetryTimeCnt;		/* 重试命令时间计数*/
+    u_long		WaitTime;			/* 命令间隔时间	*/
+    u_long		WaitTimeCnt;		/* 命令间隔时间计数*/
+    u_char		ForceWaitFlag;		/* 强制等待标志*/
+    u_short		ForceWaitCnt;		/* 强制等待计数*/
+    u_char		ReSendCmdFlag;		/* 重发命令标志	*/
+    u_char		SendCmdFlag;		/* 命令发送标志 */
+    u_char		RevCmdFlag;		/* 命令正常接收标志*/
+    //**********************************************************
 } SIO_PARAM_SERIAL_DEF;
 
+//串口相关装置所有参数集中定义
+typedef struct
+{
+    //******************** 端口基本信息 ************************
+    u_char		IsNeedSerial;		/* 是否需要使用串口通讯*/
+    int			CmdWaitTime;		/* 没有使用*/
+    u_char		UseSerialidx;		/* 使用的串口序号*/
+    int			SerialCmdidx;		/* 正在使用的串口发送命令的命令序号(-1:表示没有命令发送)
+									    加密使用
+									    0x00,生成初始向量IV(即生成随机数)
+									    0x01，导入初始向量；
+									    0x02，用对端SM2公钥加密随机数；
+									    0x03，使用SM3 Hash报文数据；
+									    0x04，使用SM2私钥签名；
+									    0x05，使用SM2私钥解密对端随机数；
+									    0x06，对安全因子进行认证；
+									    0x0a，使用对端SM2公钥验签；
+									    0x09，导入密钥DK(即导入对称密钥)；
+									    0x08，使用SM1加密；
+									    0x0b，使用SM1解密；
+									    0x0c，导出SM2公钥；
+									    密钥协商过程:
+									    1、请求0->2->c->3->3->4
+									    2、对端应答5->a
+									    3、确认6->3->9
+									    数据加解密过程:
+									    1、加密0->1->8
+									    2、解密1->b*/
+
+    int			enrecvtime;			/* 发送加密命令后接收到应答计时*/
+    int			FirstCmdTimeCnt;	/* 读取雨量计时计数*/
+    u_char		nextcmd;			/* 第二次发送读取气象雨量命令
+									     加密使用:
+									     0x00，无加密动作;
+									     0x1X，密钥协商请求过程;
+									     0x2X，密钥协商对端应答过程;
+									     0x3X，密钥协商确认过程;
+									     0x4X，数据加密过程;
+									     0x5X，数据解密过程;*/
+    int         		m_iRevStatus;		/* 接收数据缓冲区状态*/
+    int			m_iRecvLen;			/* 接收数据长度*/
+    int         		m_iNeedRevLength;   /* 还需要接收的数据长度*/
+    int			recvdatacnt;			/* 接收到有效数据*/
+    u_char		SameTypeDevIdx;	/* 相同类型装置顺序排列序号(从0开始)*/
+    int			iRecvTime;			/* 最近一次收到数据的绝对时间*/
+    u_char		uOpenPowerFlag;	/* 传感器上电标志(0:不需要打开; 1:需要打开)*/
+} SERIAL_DEV_DEF;
+
+//串口相关装置所有参数集中定义
+typedef struct
+{
+    u_char	uRunMode;									/* 程序运行模式(0:正常运行模式;1:测试运行模式;)*/
+    u_char	IsGprs;										/* GPRS网络是否注册*/
+
+    u_char	IsHexToAt;									/* 串口1是否使用At指令(0:使用At指令;1:使用16进制数据传输)*/
+    module_type	modtype;								/* 切换到mod_mmi用户之前的用户名称*/
+    u_char	CommMod;									/* 通讯模式(0:自动切换通讯模式;1:手动强制使用光网通讯;2:手动强制使用GPRS通讯)*/
+
+    u_char	sampling;									/* 正在进行采样(0:没有进行采样;1:正在进行采样;)*/
+    u_char	clcyesampling;								/* 正在进行采样(0:没有进行采样;1:正在进行采样;)*/
+    u_char	camerauseserial;							/* 云台指令正在使用那个串口*/
+    DWORD	PtzCmdType;								/* 云台指令类型*/
+    int			usecameradevidx;						/* 有像机指令需要执行*/
+    /* 执行指令的装置序号(-1:表示没有需要执行的指令;)*/
+    int		SendStopPtzCmdTimeCnt;						/* 发送云台停止指令*/
+    u_char	serialstatus[MAX_SERIAL_PORT_NUM];			/* 串口是否可以使用状态分别对应串口1、2、3*/
+    SERIAL_DEV_DEF	ms_dev[MAX_SERIAL_DEV_NUM];		/* 装置所接传感器数量*/
+    int		UseingSerialdev[MAX_SERIAL_PORT_NUM];		/* 正在使用串口通讯的装置序号(-1,表示串口空闲)*/
+    int		curdevidx[MAX_SERIAL_PORT_NUM];			/* 当前正在通讯的装置序号(-1表示没有装置需要通讯)*/
+    u_char	IsReadWireTem;								/* 是否在开始读取测温数据(0:表示没有;1:是)*/
+    //int		proruntime;									/* 程序运行时间*/
+    int		IsSleep;										/* 是否使程序休眠(1:不休眠;2:休眠)*/
+    int		tempsamplingstartime;						/* 测温启动距离采样启动时间间隔*/
+    int		tempsamplingsucctime;						/* 测温启动距离采样成功时间间隔*/
+    int		samplingtimeSec;							/* 高速采样数据秒级时间控制*/
+    int		SectimesamplingCnt[3];						/* 高速采样数据秒级采样数*/
+    int		SunshineSensorsFault;						/* 控制日照传感器故障发送*/
+    int		TempSensorsFault;							/* 控制测温传感器故障发送*/
+    int		FirstSensorsFault;							/* 第一次检测传感器故障发送*/
+    int		SensorsIsUse;								/* 传感器是否启用与自检位置匹配*/
+    int		sequsampling;								/* 顺序采样控制序号-1:无采样;其他对应相应装置序号*/
+
+#if !SOUTHERN_POWER_GRID_V1
+    int		SensorsFault;			/*字节位从低到高温度、湿度、风速、风向、
+										气压、导线测温、日照、雨量、摄像头、拉力、倾角*/
+    int		FlagSensorsFault;		/*标志字节位从低到高温度、湿度、风速、风向、
+										气压、导线测温、日照、雨量、摄像头、拉力、倾角*/
+#endif
+    BYTE	SameTypeDevNum[SENSORS_TYPE_NUM];		/* 相同类型数据传感器数量*/
+    int		imagepacketnum;							/* 串口摄像机拍照图片总包数*/
+    int		historyimagenum[MAX_CHANNEL_NUM];			/* 球机保存的历史图片数量*/
+#if 1
+    //int		sendflag;							/* 临时上送泄露电流值标志*/
+    int		sendphototime;						/* 临时上送图片数据统计*/
+    int		sendphotocmdcnt;					/* 一次拍照过程中发送拍照指令计数*/
+    int		photographtime;							/* 图片拍摄的时间*/
+    int		iLastGetPhotoNo;					/* 设置串口摄像机参数时暂存拍照命令序号*/
+#endif
+    u_char		errorPhotoNoCnt;	/* 串口摄像机拍照时回应错误包号计数(如:召第6包回应第3包)*/
+    u_char		RephotographCnt;	/* 串口摄像机重拍计数(只在读照片数据应答出错时才重拍)*/
+    int			restartflag;			/* 升级重启标识*/
+    int			selfflag;				/* 是否检测传感器故障和关闭485电源标志*/
+
+    BYTE		bEncryptstate;		/* 加密状态
+									0:加密协商过程;1:加密协商完成;
+									2:明文协商过程;3:明文协商完成*/
+#if ENCRYPTION_CHIP
+    CERTIFICATE		cert;	/* 本端证书*/
+
+	BYTE		Randomnumber[18];	/* 临时存储加密芯片产生的随机数据*/
+	BYTE		KeyRandonum[18];	/* 临时存储对端的随机数据及会话密钥DK*/
+	BYTE		Sm2publickey[64];	/* 临时存储本端Sm2公钥*/
+	BYTE		Sm2encrypt[128];	/* 临时存储使用本端Sm2公钥加密后的数据*/
+	BYTE		Sm3hashdata[32];	/* 临时存储Sm3 Hash后数据*/
+	BYTE		Safetycertification[32];/* 临时存储安全认证因子*/
+	char			ticr[64];				/* 临时存储证书请求的主题信息*/
+	WORD		wframeno;			/* 帧序号*/
+	BYTE		encry_chipstate;		/* 加密芯片复位状态*/
+	int			enchipstartnum;		/* 加密芯片复位次数*/
+#endif
+} SRDT_DEF;
+
 static void PortDataProcess( void );
 static long get_msec(void );
 int serial_port_comm();
@@ -54,4 +299,107 @@ static void set485ReadMode();
 static void set12VEnable(bool z);
 static void setCam3V3Enable(bool enabled);
 
+// 串口相关的所有函数定义
+/* 打开串口电源*/
+void Gm_OpenSerialPower(void);
+
+// 打开串口通讯
+void Gm_OpenSerialPort(int devidx);
+
+// 关闭串口通讯
+void Gm_CloseSerialPort(void);
+
+// 功能说明:串口发送数据 返回实际发送的字节数
+WORD GM_SerialComSend(const unsigned char * cSendBuf, unsigned long nSendLen, int commid);
+
+// 启动串口通讯
+void GM_StartSerialComm(BYTE compid);
+// 启动使用串口拍照
+void GM_StartSerialCameraPhoto(BYTE channel, int cmdidx);
+
+// 串口轮询通讯定时器
+int GM_SerialTimer(void);
+//轮询所有串口和传感器是否需要生成下发命令
+void Gm_FindAllSensorsCommand(void);
+//检查所有传感器是否采集完毕，采集完毕的关闭传感器电源
+void GM_IsCloseSensors(void);
+//检查所有串口是否有数据接收，有则启动接收
+void GM_AllSerialComRecv(void);
+//读取被动接收的测温球数据以及判断是否需要关闭定时器
+void GM_ReadWireTemAndCloseTimer(void);
+
+// 串口接收数据处理
+void SerialDataProcess(int devidx, u_char *buf, int len);
+
+// 串口摄像机数据处理
+void CameraPhotoPortDataProcess( int port);
+
+// 发送命令
+void SendCmdFormPollCmdBuf( int port );
+
+// 清除发送命令的所有标识
+void ClearCmdAllFlag(int commid);
+
+// 下发串口拍照指令控制
+int FindNextCameraPhotoCommand(int devidx);
+// 生成 CameraPhoto命令
+void MakeCameraPhotoCommand( int portno, BYTE cmdidx, int OneParam, WORD TwoParam, BYTE Threep );
+
+// 清除命令缓冲区
+void ClearCmdFormPollCmdBuf(int port);
+
+// 准备发送云台指令
+int Gm_CtrlPtzCmd(u_char channel, DWORD ptzcmd);
+
+// 发送转动摄像机云台命令定时器
+int Gm_Camera_Timer(void);
+
+//  生成 PELCO_P 命令					      			*
+void Gm_SendPelco_pCommand( DWORD cmdtype);
+
+// 计算Pelco_p校验
+BYTE Gm_Pelco_pXORCheck( BYTE *msg, int len );
+//  生成 PELCO_D 命令					      			*
+void Gm_SendPelco_DCommand( DWORD cmdtype);
+
+// 计算Pelco_D校验
+BYTE Gm_Pelco_DCheck( BYTE *msg, int len );
+// 查询传感器电源状态
+char Gm_GetSensorsPowerState(int port);
+
+// 通过传感器使用的航空头查找传感器使用的串口序号
+void FindDevUseSerialCommNo(void);
+
+// 初始化所有串口及所接传感器的配置
+void Gm_InitSerialComm(void);
+
+// 寻找并生成下一条倾角命令
+int FindNextShxyProtocolCommand( int devidx );
+// 倾角命令校验码计算
+unsigned char CalLpc(unsigned char *msg, int len);
+// 读上海欣影传感器协议数据
+void ShxyProtocolRecvData(int commid, u_char *buf, int len);
+// 检查检验和是否正确
+int CheckShxyProtocolLpcError( u_char* msg, int len );
+
+// 把16进制和10进制ASCII字符串转换成int整数
+int ATOI(char *buf);
+
+//生成倾角命令
+void MakeShxyProtocolPollCommand(int portno, BYTE cmdidx);
+// 上海欣影传感器协议数据处理
+void ShxyProtocolDataProcess( int commid);
+// 控制关闭传感器电源
+void Gm_CtrlCloseSensorsPower(int devidx);
+// 检查传感器电源是否应该关闭或打开
+//void Gm_CheckSensorsPower(void);
+void Gm_SetSerialPortBaud(int commid,  UART_baudrate Baudrate);
+// 得到串口波特率
+//T_baudrate Gm_GetSerialPortBaud(UART_baudrate	Baudrate);
+
+void Gm_CloseSerialCamera(void);
+
+// 生成一个随机整数
+int GeneratingRandomNumber(void);
+
 #endif //WEATHERCOMM_H

TestComm/app/src/main/cpp/native-lib.cpp

@@ -20,6 +20,7 @@
 #include "GPIOControl.h"
 #include "serialComm.h"
 #include "SensorsProtocol.h"
+//#include "WeatherComm.h"
 
 #if 0
 #define BYTE u_char;

TestComm/app/src/main/cpp/serialComm.cpp

@@ -101,6 +101,8 @@ int set_port_attr (int fd, int baudrate, int databit, const char *stopbit, char
     set_data_bit(&opt, databit);
     set_parity(&opt, parity);
     set_stopbit(&opt, stopbit);
+    opt.c_iflag &=~(INLCR|ICRNL);
+    opt.c_iflag &=~(IXON);/* 流控*/
     opt.c_oflag = 0;
     //opt.c_lflag |= 0;
     opt.c_oflag &= ~OPOST;

app/src/main/cpp/CMakeLists.txt

@@ -302,7 +302,9 @@ add_library( # Sets the name of the library.
         # TextPaint.cpp
         CvText.cpp
         SerialPort.cpp
-        WeatherComm.cpp
+        #WeatherComm.cpp
+        SensorsProtocol.cpp
+        serialComm.cpp
 
         ncnn/yolov5ncnn.cpp
 

app/src/main/cpp/SensorsProtocol.h

@@ -0,0 +1,405 @@
+//
+// Created by hyz on 2024/6/5.
+//
+
+#ifndef WEATHERCOMM_H
+#define WEATHERCOMM_H
+
+#include <string>
+#include "GPIOControl.h"
+
+#ifndef DWORD
+typedef unsigned int DWORD;
+#endif
+#ifndef WORD
+typedef unsigned short WORD;
+#endif
+#ifndef BYTE
+typedef unsigned char BYTE;
+#endif
+#ifndef FALSE
+#define FALSE 0
+#endif
+#ifndef TRUE
+#define TRUE 1
+#endif
+
+#define LOBYTE(w)               ((unsigned char)(w))
+#define HIBYTE(w)               ((unsigned char)(((unsigned short)(w) >> 8) & 0xFF))
+
+#define LOWORD(l)       ((WORD)(l))
+#define HIWORD(l)       ((WORD)((DWORD)(l) >> 16))
+
+#define MAX_STRING_LEN 32
+#define IOT_PARAM_WRITE 0xAE
+#define IOT_PARAM_READ 0xAF
+
+#define	MAX_SERIAL_DEV_NUM			25		/* 最大接串口传感器数量*/
+#define	MAX_SERIAL_PORT_NUM		    3		/* 最大串口数量*/
+
+#define		TIMER_CNT				10			// Poll命令定时器时间 50 ms
+
+#define	WEATHER_PROTOCOL    	    1			/* 温湿度协议序号*/
+#define	WIND_PROTOCOL				2			/* 风速风向协议序号*/
+#define	SLANT_PROTOCOL			    3			/* 倾斜角协议序号*/
+#define	RALLY_PROTOCOL		        4			/* 拉力协议序号*/
+#define	PELCO_P_PROTOCOL			5			/* 摄像机Pelco_P协议序号*/
+#define	PELCO_D_PROTOCOL			6			/* 摄像机Pelco_D协议序号*/
+#define	SERIALCAMERA_PROTOCOL	    8			/* 串口摄像机协议序号*/
+#define	RESERVE2_PROTOCOL			17			/* 备用2协议序号*/
+#define	RESERVE4_PROTOCOL			19			/* 备用4协议序号*/
+#define	RESERVE5_PROTOCOL			20			/* 备用5协议序号*/
+#define	INVALID_PROTOCOL			21			/* 无效协议序号*/
+
+#define	WEATHER_DATA_NUM			8			/* 气象数据最大数量(一般最多是6要素)*/
+#define	RALLY_DATA_NUM				2			/* 拉力数据最大数量(一般是1个)*/
+#define	SLANTANGLE_DATA_NUM			3			/* 倾角数据最大数量(一般只有X轴和Y轴值)*/
+
+#define			PTZ_MOVETIME		            1 	    // 云台移动等待时间为1秒
+#define		    MAX_CHANNEL_NUM		            2		/* 视频通道最大通道*/
+#define		    MAX_PHOTO_FRAME_LEN				256		/* 图片数据一包最大长度*/
+
+#define	RECVDATA_MAXLENTH		    2048			/* 接收数据缓冲区最大值*/
+#define		TIMER_CNT				10			// Poll命令定时器时间 50 ms
+#define	SENDDATA_MAXLENTH 	RECVDATA_MAXLENTH				/* 正常发送数据缓冲区最大值*/
+
+// 摄像机控制命令宏定义
+#define Cmd_Cancel				0x00000000 // 关闭功能
+#define SET_PRESETNO			0x00030000 // 设置预置点
+#define MOVE_TO_PRESETNO		0x00070000 // 调用预置点
+
+/* 摄像机PELCO-P控制命令宏定义*/
+#define P_Auto_Scan					0x20000000 /* 自动扫描功能控制(1/0 打开/关闭该功能)*/
+#define P_IRIS_CLOSE				0x08000000 /* 光圈缩小(1 有效)*/
+#define P_IRIS_OPEN					0x04000000 /* 光圈放大(1 有效)*/
+#define P_FOCUS_NEAR				0x02000000 /* 近距离聚焦(1 有效)*/
+#define P_FOCUS_FAR					0x01000000 /* 远距离聚焦(1 有效)*/
+#define P_ZOOM_WIDE				0x00400000 /* 远离物体(1 有效)*/
+#define P_ZOOM_TELE					0x00200000 /* 接近物体(1 有效)*/
+#define P_MOVE_DOWN				0x0010001f /* 向下移动镜头(1 有效)*/
+#define P_MOVE_UP					0x0008001f /* 向上移动镜头(1 有效)*/
+#define P_MOVE_LEFT					0x00041f00 /* 向左移动镜头(1 有效)*/
+#define P_MOVE_RIGHT				0x00021f00 /* 向右移动镜头(1 有效)*/
+
+// 摄像机PELCO-D控制命令宏定义
+#define D_Auto_Scan					0x10000000 /* 自动扫描功能控制(1/0 打开/关闭该功能)*/
+#define D_IRIS_CLOSE				0x04000000 /* 光圈缩小(1 有效)*/
+#define D_IRIS_OPEN					0x02000000 /* 光圈放大(1 有效)*/
+#define D_FOCUS_NEAR				0x01000000 /* 近距离聚焦(1 有效)*/
+#define D_FOCUS_FAR				0x00800000 /* 远距离聚焦(1 有效)*/
+#define D_ZOOM_WIDE				0x00400000 /* 远离物体(1 有效)*/
+#define D_ZOOM_TELE				0x00200000 /* 接近物体(1 有效)*/
+#define D_MOVE_DOWN				0x0010002d /* 向下移动镜头(1 有效)*/
+#define D_MOVE_UP					0x0008002d /* 向上移动镜头(1 有效)*/
+#define D_MOVE_LEFT					0x00042d00 /* 向左移动镜头(1 有效)*/
+#define D_MOVE_RIGHT				0x00022d00 /* 向右移动镜头(1 有效)*/
+
+#define LOGE(fmt, args...) __android_log_print(ANDROID_LOG_ERROR, "serial_port_comm", fmt, ##args)  /* 红色*/
+#define LOGI(fmt, args...) __android_log_print(ANDROID_LOG_INFO, "Sensors_Protocol", fmt, ##args)   /* 草绿色*/
+#define LOGV(fmt, args...) __android_log_print(ANDROID_LOG_VERBOSE, "serial_port_comm", fmt, ##args)/* 白色*/
+#define LOGW(fmt, args...) __android_log_print(ANDROID_LOG_WARN, "Sensors_Protocol", fmt, ##args)   /* 黄色*/
+#define LOGD(fmt, args...) __android_log_print(ANDROID_LOG_DEBUG, "Sensors_Protocol", fmt, ##args)  /* 蓝色*/
+#define		HexCharToInt( c ) (((c) >= '0') && ((c) <= '9') ? (c) - '0' : ((c) >= 'a') && ((c) <= 'f') ? (c) - 'a' + 10 :((c) >= 'A') && ((c) <= 'F') ? (c) - 'A' + 10 : 0 )
+
+typedef struct
+{
+    int cmd;
+    int value;
+    int result;
+    long value2;
+    char str[MAX_STRING_LEN];
+}IOT_PARAM;
+
+typedef struct
+{
+    //float		fAiDead;		// 数据变化死区(百分系数值,如:设置死区为5%，只需赋值5即可)
+    float		fFactor;		// 数据系数
+    float		EuValueDelta;	// 数据工程值偏移
+    //BYTE		Polar;			// 数据极性(有无符号位)
+} AI_PARAM;
+
+typedef struct
+{
+    AI_PARAM	    AiParam;		// 数据点配置参数
+    BYTE		    AiState;		// 遥测是否有效标识
+    float			EuValue;		// 遥测工程值
+} AI_DEF;
+
+// 需要配置的串口装置参数
+typedef struct
+{
+    unsigned int		    baudrate;	        /* 波特率*/
+    int 		            databit;	        /* 数据位*/
+    char		            stopbit[8];	        /* 停止位*/
+    char		            parity;		        /* 校验位*/
+    char		            pathname[64];       /* 串口文件名及路径*/
+    int                     commid;             /* 串口序号*/
+    u_char		            ProtocolIdx;		/* 规约索引，大于 0*/
+    int			            devaddr;			/* 装置使用的地址*/
+    u_char		            IsNoInsta;			/* 装置没有安装或者已经坏了(1:正常, 0:无效，坏了或没有安装)*/
+    u_char		            CameraChannel;		/* 像机的通道号*/
+    //u_char		            PowerPort;		/* 传感器所接航空头编号*/
+} SERIAL_PARAM;
+
+typedef struct
+{
+    int		    m_iRevStatus;	    /* */
+    int 		m_iRecvLen;	        /* */
+    int		    m_iNeedRevLength;	/* */
+    int		    iRecvTime;		    /* */
+    u_char	    m_au8RecvBuf[RECVDATA_MAXLENTH];/* */
+    int         fd;                    /* 串口打开的文件句柄*/
+    u_char		PollCmd[SENDDATA_MAXLENTH];
+    int			cmdlen;				// 发送缓冲区命令长度
+    //******************** Poll Cmd ****************************
+    u_char		Retry;				/* 重试命令次数 */
+    u_char		RetryCnt;			/* 重试命令计数*/
+    u_long		RetryTime;			/* 重试命令时间 */
+    u_long		RetryTimeCnt;		/* 重试命令时间计数*/
+    u_long		WaitTime;			/* 命令间隔时间	*/
+    u_long		WaitTimeCnt;		/* 命令间隔时间计数*/
+    u_char		ForceWaitFlag;		/* 强制等待标志*/
+    u_short		ForceWaitCnt;		/* 强制等待计数*/
+    u_char		ReSendCmdFlag;		/* 重发命令标志	*/
+    u_char		SendCmdFlag;		/* 命令发送标志 */
+    u_char		RevCmdFlag;		/* 命令正常接收标志*/
+    //**********************************************************
+} SIO_PARAM_SERIAL_DEF;
+
+//串口相关装置所有参数集中定义
+typedef struct
+{
+    //******************** 端口基本信息 ************************
+    u_char		IsNeedSerial;		/* 是否需要使用串口通讯*/
+    int			CmdWaitTime;		/* 没有使用*/
+    u_char		UseSerialidx;		/* 使用的串口序号*/
+    int			SerialCmdidx;		/* 正在使用的串口发送命令的命令序号(-1:表示没有命令发送)
+									    加密使用
+									    0x00,生成初始向量IV(即生成随机数)
+									    0x01，导入初始向量；
+									    0x02，用对端SM2公钥加密随机数；
+									    0x03，使用SM3 Hash报文数据；
+									    0x04，使用SM2私钥签名；
+									    0x05，使用SM2私钥解密对端随机数；
+									    0x06，对安全因子进行认证；
+									    0x0a，使用对端SM2公钥验签；
+									    0x09，导入密钥DK(即导入对称密钥)；
+									    0x08，使用SM1加密；
+									    0x0b，使用SM1解密；
+									    0x0c，导出SM2公钥；
+									    密钥协商过程:
+									    1、请求0->2->c->3->3->4
+									    2、对端应答5->a
+									    3、确认6->3->9
+									    数据加解密过程:
+									    1、加密0->1->8
+									    2、解密1->b*/
+
+    int			enrecvtime;			/* 发送加密命令后接收到应答计时*/
+    int			FirstCmdTimeCnt;	/* 读取雨量计时计数*/
+    u_char		nextcmd;			/* 第二次发送读取气象雨量命令
+									     加密使用:
+									     0x00，无加密动作;
+									     0x1X，密钥协商请求过程;
+									     0x2X，密钥协商对端应答过程;
+									     0x3X，密钥协商确认过程;
+									     0x4X，数据加密过程;
+									     0x5X，数据解密过程;*/
+    int         		m_iRevStatus;		/* 接收数据缓冲区状态*/
+    int			m_iRecvLen;			/* 接收数据长度*/
+    int         		m_iNeedRevLength;   /* 还需要接收的数据长度*/
+    int			recvdatacnt;			/* 接收到有效数据*/
+    u_char		SameTypeDevIdx;	/* 相同类型装置顺序排列序号(从0开始)*/
+    int			iRecvTime;			/* 最近一次收到数据的绝对时间*/
+    u_char		uOpenPowerFlag;	/* 传感器上电标志(0:不需要打开; 1:需要打开)*/
+} SERIAL_DEV_DEF;
+
+//串口相关装置所有参数集中定义
+typedef struct
+{
+    u_char	uRunMode;									/* 程序运行模式(0:正常运行模式;1:测试运行模式;)*/
+    u_char	IsGprs;										/* GPRS网络是否注册*/
+
+    u_char	IsHexToAt;									/* 串口1是否使用At指令(0:使用At指令;1:使用16进制数据传输)*/
+    module_type	modtype;								/* 切换到mod_mmi用户之前的用户名称*/
+    u_char	CommMod;									/* 通讯模式(0:自动切换通讯模式;1:手动强制使用光网通讯;2:手动强制使用GPRS通讯)*/
+
+    u_char	sampling;									/* 正在进行采样(0:没有进行采样;1:正在进行采样;)*/
+    u_char	clcyesampling;								/* 正在进行采样(0:没有进行采样;1:正在进行采样;)*/
+    u_char	camerauseserial;							/* 云台指令正在使用那个串口*/
+    DWORD	PtzCmdType;								/* 云台指令类型*/
+    int			usecameradevidx;						/* 有像机指令需要执行*/
+    /* 执行指令的装置序号(-1:表示没有需要执行的指令;)*/
+    int		SendStopPtzCmdTimeCnt;						/* 发送云台停止指令*/
+    u_char	serialstatus[MAX_SERIAL_PORT_NUM];			/* 串口是否可以使用状态分别对应串口1、2、3*/
+    SERIAL_DEV_DEF	ms_dev[MAX_SERIAL_DEV_NUM];		/* 装置所接传感器数量*/
+    int		UseingSerialdev[MAX_SERIAL_PORT_NUM];		/* 正在使用串口通讯的装置序号(-1,表示串口空闲)*/
+    int		curdevidx[MAX_SERIAL_PORT_NUM];			/* 当前正在通讯的装置序号(-1表示没有装置需要通讯)*/
+    u_char	IsReadWireTem;								/* 是否在开始读取测温数据(0:表示没有;1:是)*/
+    //int		proruntime;									/* 程序运行时间*/
+    int		IsSleep;										/* 是否使程序休眠(1:不休眠;2:休眠)*/
+    int		tempsamplingstartime;						/* 测温启动距离采样启动时间间隔*/
+    int		tempsamplingsucctime;						/* 测温启动距离采样成功时间间隔*/
+    int		samplingtimeSec;							/* 高速采样数据秒级时间控制*/
+    int		SectimesamplingCnt[3];						/* 高速采样数据秒级采样数*/
+    int		SunshineSensorsFault;						/* 控制日照传感器故障发送*/
+    int		TempSensorsFault;							/* 控制测温传感器故障发送*/
+    int		FirstSensorsFault;							/* 第一次检测传感器故障发送*/
+    int		SensorsIsUse;								/* 传感器是否启用与自检位置匹配*/
+    int		sequsampling;								/* 顺序采样控制序号-1:无采样;其他对应相应装置序号*/
+
+#if !SOUTHERN_POWER_GRID_V1
+    int		SensorsFault;			/*字节位从低到高温度、湿度、风速、风向、
+										气压、导线测温、日照、雨量、摄像头、拉力、倾角*/
+    int		FlagSensorsFault;		/*标志字节位从低到高温度、湿度、风速、风向、
+										气压、导线测温、日照、雨量、摄像头、拉力、倾角*/
+#endif
+    BYTE	SameTypeDevNum[SENSORS_TYPE_NUM];		/* 相同类型数据传感器数量*/
+    int		imagepacketnum;							/* 串口摄像机拍照图片总包数*/
+    int		historyimagenum[MAX_CHANNEL_NUM];			/* 球机保存的历史图片数量*/
+#if 1
+    //int		sendflag;							/* 临时上送泄露电流值标志*/
+    int		sendphototime;						/* 临时上送图片数据统计*/
+    int		sendphotocmdcnt;					/* 一次拍照过程中发送拍照指令计数*/
+    int		photographtime;							/* 图片拍摄的时间*/
+    int		iLastGetPhotoNo;					/* 设置串口摄像机参数时暂存拍照命令序号*/
+#endif
+    u_char		errorPhotoNoCnt;	/* 串口摄像机拍照时回应错误包号计数(如:召第6包回应第3包)*/
+    u_char		RephotographCnt;	/* 串口摄像机重拍计数(只在读照片数据应答出错时才重拍)*/
+    int			restartflag;			/* 升级重启标识*/
+    int			selfflag;				/* 是否检测传感器故障和关闭485电源标志*/
+
+    BYTE		bEncryptstate;		/* 加密状态
+									0:加密协商过程;1:加密协商完成;
+									2:明文协商过程;3:明文协商完成*/
+#if ENCRYPTION_CHIP
+    CERTIFICATE		cert;	/* 本端证书*/
+
+	BYTE		Randomnumber[18];	/* 临时存储加密芯片产生的随机数据*/
+	BYTE		KeyRandonum[18];	/* 临时存储对端的随机数据及会话密钥DK*/
+	BYTE		Sm2publickey[64];	/* 临时存储本端Sm2公钥*/
+	BYTE		Sm2encrypt[128];	/* 临时存储使用本端Sm2公钥加密后的数据*/
+	BYTE		Sm3hashdata[32];	/* 临时存储Sm3 Hash后数据*/
+	BYTE		Safetycertification[32];/* 临时存储安全认证因子*/
+	char			ticr[64];				/* 临时存储证书请求的主题信息*/
+	WORD		wframeno;			/* 帧序号*/
+	BYTE		encry_chipstate;		/* 加密芯片复位状态*/
+	int			enchipstartnum;		/* 加密芯片复位次数*/
+#endif
+} SRDT_DEF;
+
+static void PortDataProcess( void );
+static long get_msec(void );
+int serial_port_comm();
+static int weather_comm(SERIAL_PARAM weatherport);
+
+static void setRS485Enable(bool z);
+static void set485WriteMode();
+static void set485ReadMode();
+static void set12VEnable(bool z);
+static void setCam3V3Enable(bool enabled);
+
+// 串口相关的所有函数定义
+/* 打开串口电源*/
+void Gm_OpenSerialPower(void);
+
+// 打开串口通讯
+void Gm_OpenSerialPort(int devidx);
+
+// 关闭串口通讯
+void Gm_CloseSerialPort(void);
+
+// 功能说明:串口发送数据 返回实际发送的字节数
+WORD GM_SerialComSend(const unsigned char * cSendBuf, unsigned long nSendLen, int commid);
+
+// 启动串口通讯
+void GM_StartSerialComm(BYTE compid);
+// 启动使用串口拍照
+void GM_StartSerialCameraPhoto(BYTE channel, int cmdidx);
+
+// 串口轮询通讯定时器
+int GM_SerialTimer(void);
+//轮询所有串口和传感器是否需要生成下发命令
+void Gm_FindAllSensorsCommand(void);
+//检查所有传感器是否采集完毕，采集完毕的关闭传感器电源
+void GM_IsCloseSensors(void);
+//检查所有串口是否有数据接收，有则启动接收
+void GM_AllSerialComRecv(void);
+//读取被动接收的测温球数据以及判断是否需要关闭定时器
+void GM_ReadWireTemAndCloseTimer(void);
+
+// 串口接收数据处理
+void SerialDataProcess(int devidx, u_char *buf, int len);
+
+// 串口摄像机数据处理
+void CameraPhotoPortDataProcess( int port);
+
+// 发送命令
+void SendCmdFormPollCmdBuf( int port );
+
+// 清除发送命令的所有标识
+void ClearCmdAllFlag(int commid);
+
+// 下发串口拍照指令控制
+int FindNextCameraPhotoCommand(int devidx);
+// 生成 CameraPhoto命令
+void MakeCameraPhotoCommand( int portno, BYTE cmdidx, int OneParam, WORD TwoParam, BYTE Threep );
+
+// 清除命令缓冲区
+void ClearCmdFormPollCmdBuf(int port);
+
+// 准备发送云台指令
+int Gm_CtrlPtzCmd(u_char channel, DWORD ptzcmd);
+
+// 发送转动摄像机云台命令定时器
+int Gm_Camera_Timer(void);
+
+//  生成 PELCO_P 命令					      			*
+void Gm_SendPelco_pCommand( DWORD cmdtype);
+
+// 计算Pelco_p校验
+BYTE Gm_Pelco_pXORCheck( BYTE *msg, int len );
+//  生成 PELCO_D 命令					      			*
+void Gm_SendPelco_DCommand( DWORD cmdtype);
+
+// 计算Pelco_D校验
+BYTE Gm_Pelco_DCheck( BYTE *msg, int len );
+// 查询传感器电源状态
+char Gm_GetSensorsPowerState(int port);
+
+// 通过传感器使用的航空头查找传感器使用的串口序号
+void FindDevUseSerialCommNo(void);
+
+// 初始化所有串口及所接传感器的配置
+void Gm_InitSerialComm(void);
+
+// 寻找并生成下一条倾角命令
+int FindNextShxyProtocolCommand( int devidx );
+// 倾角命令校验码计算
+unsigned char CalLpc(unsigned char *msg, int len);
+// 读上海欣影传感器协议数据
+void ShxyProtocolRecvData(int commid, u_char *buf, int len);
+// 检查检验和是否正确
+int CheckShxyProtocolLpcError( u_char* msg, int len );
+
+// 把16进制和10进制ASCII字符串转换成int整数
+int ATOI(char *buf);
+
+//生成倾角命令
+void MakeShxyProtocolPollCommand(int portno, BYTE cmdidx);
+// 上海欣影传感器协议数据处理
+void ShxyProtocolDataProcess( int commid);
+// 控制关闭传感器电源
+void Gm_CtrlCloseSensorsPower(int devidx);
+// 检查传感器电源是否应该关闭或打开
+//void Gm_CheckSensorsPower(void);
+void Gm_SetSerialPortBaud(int commid,  UART_baudrate Baudrate);
+// 得到串口波特率
+//T_baudrate Gm_GetSerialPortBaud(UART_baudrate	Baudrate);
+
+void Gm_CloseSerialCamera(void);
+
+// 生成一个随机整数
+int GeneratingRandomNumber(void);
+
+#endif //WEATHERCOMM_H

app/src/main/cpp/WeatherComm.cpp

@@ -1,558 +0,0 @@
-#include <jni.h>
-#include <string>
-
-#include <fcntl.h>
-#include <unistd.h>
-#include <sys/ioctl.h>
-#include <linux/spi/spidev.h>
-#include <android/log.h>
-#include <stdio.h>
-#include <dirent.h>
-#include <stdlib.h>
-#include <unistd.h>
-#include <fcntl.h>
-#include <string.h>
-#include <termios.h>
-#include <time.h>
-#include "GPIOControl.h"
-#include "WeatherComm.h"
-#include <sys/time.h>
-
-SIO_PARAM_SERIAL_DEF serialport;
-float weatherpntmsg[10];
-
-static void set_baudrate (struct termios *opt, unsigned int baudrate)
-{
-    cfsetispeed(opt, baudrate);
-    cfsetospeed(opt, baudrate);
-}
-
-static void set_data_bit (struct termios *opt, unsigned int databit)
-{
-    opt->c_cflag &= ~CSIZE;
-    switch (databit)
-    {
-        case 8:
-            opt->c_cflag |= CS8;
-            break;
-        case 7:
-            opt->c_cflag |= CS7;
-            break;
-        case 6:
-            opt->c_cflag |= CS6;
-            break;
-        case 5:
-            opt->c_cflag |= CS5;
-            break;
-        default:
-            opt->c_cflag |= CS8;
-            break;
-    }
-}
-
-static void set_parity (struct termios *opt, char parity)
-{
-    switch (parity)
-    {
-        case'N':/* 无校验 */
-        case 'n':
-            opt->c_cflag &= ~PARENB;
-            break;
-        case'E':/*偶校验*/
-        case 'e':
-            opt->c_cflag |= PARENB;
-            opt->c_cflag &= ~PARODD;
-            break;
-        case'O':/* 奇校验 */
-        case 'o':
-            opt->c_cflag |= PARENB;
-            opt->c_cflag |= ~PARODD;
-            break;
-        default: /*其它选择为无校验 */
-            opt->c_cflag &= ~PARENB;
-            break;
-    }
-}
-
-static void set_stopbit (struct termios *opt, const char *stopbit)
-{
-    if (strcmp(stopbit, "1") == 0)
-    {
-        opt->c_cflag &= ~CSTOPB;/*1 位停止位 t */
-    }
-    else if(0 == strcmp(stopbit, "1.5"))
-    {
-        opt->c_cflag &= ~CSTOPB;/*1.5 位停止位 */
-    }
-    else if(0 == strcmp (stopbit,"2"))
-    {
-        opt->c_cflag |= CSTOPB; /*2 位停止位 */
-    }
-    else
-    {
-        opt->c_cflag &= ~CSTOPB; /*1 位停止位 */
-    }
-}
-
-int set_port_attr (int fd, int baudrate, int databit, const char *stopbit, char parity, int vtime, int vmin )
-{
-    struct termios opt;
-    tcgetattr(fd, &opt);
-    set_baudrate(&opt, baudrate);
-    //opt.c_cflag |= CLOCAL|CREAD; /*|CRTSCTS */
-    opt.c_lflag &= ~(ICANON | ECHO |ECHOE |ISIG);
-    set_data_bit(&opt, databit);
-    set_parity(&opt, parity);
-    set_stopbit(&opt, stopbit);
-    opt.c_oflag = 0;
-    //opt.c_lflag |= 0;
-    opt.c_oflag &= ~OPOST;
-    opt.c_cc[VTIME] = vtime;
-    opt.c_cc[VMIN] = vmin;
-    tcflush (fd, TCIFLUSH);
-    return (tcsetattr (fd, TCSANOW, &opt));
-}
-
-static void setInt(int cmd, int value)
-{
-    int fd = open("/dev/mtkgpioctrl", O_RDONLY);
-    IOT_PARAM param;
-    param.cmd = cmd;
-    param.value = value;
-    // LOGE("set_int fd=%d,cmd=%d,value=%d\r\n",fd, cmd, value);
-    if( fd > 0 )
-    {
-        int res = ioctl(fd, IOT_PARAM_WRITE, &param);
-        // LOGE("set_int22 cmd=%d,value=%d,result=%d\r\n",param.cmd, param.value, param.result);
-        close(fd);
-    }
-    return;
-}
-static void setRS485Enable(bool z) {
-    setInt(CMD_SET_485_EN_STATE, z ? 1 : 0);
-}
-
-static void set485WriteMode() {
-    setInt(CMD_SET_485_STATE, 1);
-}
-
-static void set485ReadMode() {
-    setInt(CMD_SET_485_STATE, 0);
-}
-static void set12VEnable(bool z) {
-    setInt(CMD_SET_12V_EN_STATE, z ? 1 : 0);
-}
-
-static void setCam3V3Enable(bool enabled)
-{
-    setInt(CMD_SET_CAM_3V3_EN_STATE, enabled ? 1 : 0);
-}
-
-
-/*********************************************************************************
-*						            气象数据处理							         *
-**********************************************************************************/
-void PortDataProcess( void )
-{
-    float			fvalue, fcorvalue, *fvalua, frnb/*, fwind*/;
-    //WORD		uDevAddr;
-    unsigned char		cmdidx;
-    int			i, j, aipnt, datanum;
-    SIO_PARAM_SERIAL_DEF	*pPortParam;
-    char			szbuf[64];
-
-    pPortParam = &serialport;
-    //取出装置地址,开始处理地址+++
-    if(0x02 == pPortParam->m_au8RecvBuf[5])
-    {
-        //pPortParam->devaddr = pPortParam->m_au8RecvBuf[4];
-        return;
-    }
-    cmdidx = pPortParam->m_au8RecvBuf[5];
-#if 0
-    aipnt = pPortParam->SameTypeDevIdx;
-    uDevAddr = serialport->m_au8RecvBuf[4];
-    if(0 == srdt.IsReadWireTem)
-    {
-        if(uDevAddr != pPortParam->devaddr)
-            return;
-    }
-#endif
-    fvalua = &fvalue;
-    datanum = pPortParam->m_au8RecvBuf[6];
-    if((0x08 != cmdidx) && (0x09 != cmdidx))
-        return;
-
-    for(i = 0, j=7; (i<datanum) && (j<6+pPortParam->m_au8RecvBuf[1]); i++, j+=5 )
-    {
-        if(0x08 == cmdidx)
-            fvalue = (pPortParam->m_au8RecvBuf[j+1]<<24)+(pPortParam->m_au8RecvBuf[j+2]<<16)
-                     +(pPortParam->m_au8RecvBuf[j+3]<<8)+pPortParam->m_au8RecvBuf[j+4];
-        else
-        {
-            *(u_char *)fvalua = pPortParam->m_au8RecvBuf[j+4];
-            *((u_char *)fvalua+1) = pPortParam->m_au8RecvBuf[j+3];
-            *((u_char *)fvalua+2) = pPortParam->m_au8RecvBuf[j+2];
-            *((u_char *)fvalua+3) = pPortParam->m_au8RecvBuf[j+1];
-        }
-        switch(pPortParam->m_au8RecvBuf[j])
-        {
-            case	1:	/*温度*/
-                weatherpntmsg[0] = fvalue;
-                LOGE("温度:%0.3f  ", fvalue);
-                break;
-            case	2:	/*气压*/
-                weatherpntmsg[5] = fvalue;
-                LOGE("气压:%0.3f  ", fvalue);
-                break;
-            case	3:	/*湿度*/
-                weatherpntmsg[1] = fvalue;
-                LOGE("湿度:%0.3f  ", fvalue);
-                break;
-            case	4:	/*雨量*/
-                break;
-            case	5:	/*日照*/
-                break;
-            case	6:	/*风速*/
-                weatherpntmsg[2] = fvalue;
-                LOGE("风速:%0.3f  ", fvalue);
-                break;
-            case	7:	/*风向*/
-                weatherpntmsg[3] = fvalue;
-                LOGE("风向:%0.3f  ", fvalue);
-                break;
-            case	8:	/*拉力*/
-            case	9:	/*倾角传感器X轴倾角*/
-            case	10:	/*倾角传感器Y轴倾角*/
-            case	11:	/*测温球导线温度*/
-            case	12:	/*测温球内部温度*/
-                break;
-            case	13:	/*测温球导线X轴倾角*/
-                break;
-            case	14:	/*测温球导线Y轴倾角*/
-                break;
-            case	15:	/*测温球导线电流*/
-                break;
-            case	16:	/*测温球电池电压*/
-                break;
-            case	17: /*A相泄漏电流平均值；*/
-                break;
-            case	18: /*A相泄漏电流最大值；*/
-                break;
-            case	19: /*A相超过3mA的脉冲频次*/
-                break;
-            case	20: /*A相超过10mA的脉冲频次*/
-                break;
-            case	21: /*B相泄漏电流平均值；*/
-                break;
-            case	22: /*B相泄漏电流最大值；*/
-                break;
-            case	23: /*B相超过3mA的脉冲频次*/
-                break;
-            case	24: /*B相超过10mA的脉冲频次*/
-            case	25: /*C相泄漏电流平均值；*/
-            case	26: /*C相泄漏电流最大值；*/
-            case	27: /*C相超过3mA的脉冲频次*/
-            case	28: /*C相超过10mA的脉冲频次*/
-                break;
-        }
-    }
-}
-
-//***************************************************************
-//*    		     		按照协议格式化接收数据				*
-//***************************************************************
-static void RecvData(u_char *buf, int len)// 规约读数据处理
-{
-    int  				i, ictime;
-    //WORD				crc, check;
-    SIO_PARAM_SERIAL_DEF	*pPortParam;
-
-    pPortParam = &serialport;
-    ictime = (int)time(NULL);
-
-    if(pPortParam->m_iRecvLen == 0)
-    {
-        pPortParam->iRecvTime = ictime;
-    }
-    else
-    {
-        if((ictime-pPortParam->iRecvTime > 6) || (ictime - pPortParam->iRecvTime < 0))
-            pPortParam->iRecvTime = ictime;
-        else if(ictime - pPortParam->iRecvTime > 2)
-        {
-            pPortParam->m_iRecvLen = 0;
-            pPortParam->m_iRevStatus = 0;
-        }
-    }
-
-    for(i=0; i<len; i++)
-    {
-        switch(pPortParam->m_iRevStatus)
-        {
-            case 0:			// 0x68
-                pPortParam->m_iRecvLen = 0;
-                pPortParam->m_au8RecvBuf[pPortParam->m_iRecvLen++] = buf[i];
-                if(0x68 == buf[i])
-                    pPortParam->m_iRevStatus++;
-                else
-                    pPortParam->m_iRevStatus = 18;
-                break;
-            case 1:			// len1
-                pPortParam->m_au8RecvBuf[pPortParam->m_iRecvLen++] = buf[i];
-                pPortParam->m_iRevStatus++;
-                break;
-            case 2:			// len2
-                pPortParam->m_au8RecvBuf[pPortParam->m_iRecvLen++] = buf[i];
-                if(buf[i] == pPortParam->m_au8RecvBuf[pPortParam->m_iRecvLen-2])
-                {
-                    pPortParam->m_iRevStatus++;
-                    pPortParam->m_iNeedRevLength = buf[i]+5;
-                }
-                else
-                    pPortParam->m_iRevStatus = 18;
-                break;
-            case 3:			// 0x68
-                pPortParam->m_au8RecvBuf[pPortParam->m_iRecvLen++] = buf[i];
-                pPortParam->m_iNeedRevLength--;
-                if(0x68 == buf[i])
-                    pPortParam->m_iRevStatus++;
-                else
-                    pPortParam->m_iRevStatus = 18;
-                break;
-            case 4:	// 正确接收数据
-                pPortParam->m_iNeedRevLength--;
-                pPortParam->m_au8RecvBuf[pPortParam->m_iRecvLen++] = buf[i];
-                if(pPortParam->m_iNeedRevLength > 0)
-                    break;
-                if(buf[i] != 0x16)
-                {
-                    pPortParam->m_iRevStatus=18;
-                    break;
-                }
-
-                //if(CheckLpcError(serialport->m_au8RecvBuf, pPortParam->m_iRecvLen) == TRUE)
-                {
-                    PortDataProcess();
-                    pPortParam->m_iRevStatus = 0;
-                    pPortParam->RevCmdFlag = 1;
-                }
-                 pPortParam->m_iRecvLen = 0;
-                break;
-            case 255:// 错误接收数据
-            default:
-                if(buf[i] == 0x68)
-                {
-                    pPortParam->m_iRevStatus = 1;
-                    pPortParam->m_iRecvLen = 1;
-                    pPortParam->m_au8RecvBuf[0] = buf[i];
-                }
-                else if(buf[i] == 0x16)
-                {
-                    pPortParam->m_au8RecvBuf[pPortParam->m_iRecvLen++] = buf[i];
-                    pPortParam->m_iRevStatus = 0;
-                    pPortParam->m_iRecvLen = 0;
-                }
-                else
-                {
-                    pPortParam->m_au8RecvBuf[pPortParam->m_iRecvLen++] = buf[i];
-                    if(pPortParam->m_iRecvLen > 200)
-                    {
-                        pPortParam->m_iRecvLen = 0;
-                    }
-                }
-                break;
-        }
-    }
-}
-
-static long get_msec(void )
-{
-    struct timeval tv;
-
-    gettimeofday(&tv, NULL);
-    long time_in_msec = tv.tv_sec * 1000 + tv.tv_usec/1000;
-
-    return time_in_msec;
-}
-//int inum =0;
-//int itimecnt=0;
-static int weather_comm(SERIAL_PARAM weatherport)
-{
-    int fd = -1;
-    int len, i,ret, icnt=0;
-    long ictime, iruntime, isendtime, irecvtime;
-    unsigned char sendbuf[] = {0x68,0x00,0x00,0x68,0x01,0x09,0x0a,0x16};
-    char recvbuf[256], szbuf[512];
-    //char serial_description[] = "/dev/ttyS0";
-
-#if 0
-    DIR *dir = opendir("/dev");
-    if (dir == NULL) {
-        LOGE("_test_ opendir");
-        return -1;
-    }
-
-    // 读取目录项
-    struct dirent *entry;
-    while ((entry = readdir(dir)) != NULL) {
-        // 过滤出串口设备，通常以"ttyS"或"ttyUSB"开头
-        if ((strncmp(entry->d_name, "ttyS2", 5) == 0) ||
-            (strncmp(entry->d_name, "ttyS0", 5) == 0)) {
-            LOGE("_test_ Found serial port: %s\n", entry->d_name);
-        }
-    }
-
-    // 关闭目录
-    closedir(dir);
-#endif
-    serialport.RevCmdFlag = 1;
-    serialport.m_iRecvLen = 0;
-    serialport.m_iRevStatus = 0;
-
-    set12VEnable(true);
-    setCam3V3Enable(true);
-    setRS485Enable(true);
-    sleep(2);
-    //ictime = (int)time(NULL);
-    ictime = get_msec();
-    for(;;)
-    {
-        if(fd < 0)
-        {
-            fd = open(weatherport.pathname, O_RDWR | O_NDELAY);
-            //fd = open(weatherport.pathname, O_RDWR | O_NOCTTY);
-            if(fd < 0)
-            {
-                LOGE("_test_ open serial error \n");
-                perror(weatherport.pathname);
-                return -1;
-            }
-
-            ret= set_port_attr (fd, weatherport.baudrate,weatherport.databit,weatherport.stopbit,weatherport.parity,0,0 );/*9600 8n1 */
-            if(ret < 0)
-            {
-                LOGE("_test_ set uart arrt faile \n");
-                return -1;
-            }
-        }
-
-        usleep(10000);
-        //iruntime = (int)time(NULL);
-        iruntime = get_msec();
-        if((iruntime - ictime > 120000) || (iruntime - ictime < 0))
-            ictime = iruntime;
-        if(iruntime - ictime > 20000)
-        {
-            memset(szbuf, 0, sizeof(szbuf));
-            sprintf(szbuf, "气象采样时间=%0.3f秒,停止采样!", (iruntime-ictime)/1000.0);
-            LOGE("%s", szbuf);
-            break;
-        }
-
-        if(1 == serialport.RevCmdFlag)
-        {
-            set485WriteMode();
-
-            len = write(fd, sendbuf, sizeof(sendbuf));/* 向串囗发送字符串 */
-            serialport.RevCmdFlag = 0;
-            //LOGE("发送命令时间差%ld毫秒", get_msec()-isendtime);
-            //isendtime = time(NULL);
-            isendtime = get_msec();
-            if (len < 0) {
-                LOGE("write data error \n");
-                return -1;
-            } else {
-                memset(szbuf, 0, sizeof(szbuf));
-                sprintf(szbuf, "Send：");
-                for (i = 0; i < len; i++) {
-                    sprintf(szbuf, "%s %02X", szbuf, sendbuf[i]);
-                }
-                LOGE("%s", szbuf);
-                //icnt = 0;
-                //inum++;
-            }
-            tcdrain(fd);
-            //usleep(50000);
-        }
-        else
-        {
-            //irecvtime = time(NULL);
-            irecvtime = get_msec();
-            if((irecvtime-isendtime > 6000) ||(irecvtime - isendtime < 0))
-                isendtime = irecvtime;
-            if (irecvtime-isendtime > 300)
-            {
-                LOGE("传感器超过%ld毫秒未应答", irecvtime-isendtime);
-                serialport.RevCmdFlag = 1;
-                serialport.m_iRecvLen = 0;
-                serialport.m_iRevStatus = 0;
-                close(fd);
-                //set12VEnable(false);
-                //setCam3V3Enable(false);
-                //setRS485Enable(false);
-                fd = -1;
-                continue;
-            }
-        }
-        set485ReadMode();
-        memset(recvbuf, 0, sizeof(recvbuf));
-        len = read(fd, recvbuf, sizeof(recvbuf));/* 在串口读取字符串 */
-        if (len < 0) {
-            LOGE("serial read error \n");
-            continue;
-        }
-        if(0 == len)
-        {
-            //icnt++;
-            continue;
-        }
-
-        memset(szbuf, 0, sizeof(szbuf));
-        sprintf(szbuf, "Recv：");
-        for (i = 0; i < len; i++) {
-            sprintf(szbuf, "%s %02X", szbuf, recvbuf[i]);
-        }
-        __android_log_print(ANDROID_LOG_INFO, "serial", "%s", szbuf);
-        RecvData((u_char*)recvbuf, len);
-        //LOGE("一周期空循环次数%d, 读取次数%d, 时间：%d %d", icnt, inum, (int)time(NULL), itimecnt);
-        icnt = 0;
-        //serialport.RevCmdFlag =1;
-    }
-
-    close(fd);
-    set12VEnable(false);
-    setCam3V3Enable(false);
-    setRS485Enable(false);
-
-    //exit(-1);
-    return(0);
-}
-
-int serial_port_comm()
-{
-    SERIAL_PARAM  portparm;
-
-    //struct timeval tv;
-
-    //gettimeofday(&tv, NULL);
-    //long time_in_microseconds = tv.tv_sec * 1000000 + tv.tv_usec;
-
-    //LOGE("Current time in microseconds: %ld\n", time_in_microseconds);
-
-#if 1
-    memset(portparm.pathname, 0, sizeof(portparm.pathname));
-    sprintf(portparm.pathname, "/dev/ttyS0");
-    portparm.parity = 'N';
-    portparm.databit = 8;
-    portparm.baudrate = B9600;
-    memset(portparm.stopbit, 0, sizeof(portparm.stopbit));
-    sprintf(portparm.stopbit, "1");
-#endif
-    //itimecnt = (int)time(NULL);
-
-    //for(;;)
-        weather_comm(portparm);
-    return 0;
-}
-

app/src/main/cpp/WeatherComm.h

@@ -1,51 +0,0 @@
-//
-// Created by hyz on 2024/6/5.
-//
-
-#ifndef WEATHERCOMM_H
-#define WEATHERCOMM_H
-
-#include <string>
-#include "GPIOControl.h"
-
-#define MAX_STRING_LEN 32
-#define IOT_PARAM_WRITE 0xAE
-#define IOT_PARAM_READ 0xAF
-
-#define LOGE(fmt, args...) __android_log_print(ANDROID_LOG_ERROR, "serial_port_comm", fmt, ##args)
-
-// 串口参数
-typedef struct
-{
-    int		    baudrate;	/* 波特率*/
-    int 		databit;	/* 数据位*/
-    char		stopbit[8];	/* 停止位*/
-    char		parity;		/* 校验位*/
-    char		pathname[128];/* 串口文件名及路径*/
-} SERIAL_PARAM;
-
-typedef struct
-{
-    int		    m_iRevStatus;	/* */
-    int 		m_iRecvLen;	/* */
-    int		    m_iNeedRevLength;	/* */
-    int		    iRecvTime;		/* */
-    int         RevCmdFlag;
-    unsigned char	m_au8RecvBuf[128];/* */
-} SIO_PARAM_SERIAL_DEF;
-
-typedef struct
-{
-    int cmd;
-    int value;
-    int result;
-    long value2;
-    char str[MAX_STRING_LEN];
-}IOT_PARAM;
-
-void PortDataProcess( void );
-int serial_port_comm();
-static int weather_comm(SERIAL_PARAM weatherport);
-int set_port_attr (int fd, int baudrate, int databit, const char *stopbit, char parity, int vtime, int vmin );
-
-#endif //WEATHERCOMM_H

app/src/main/cpp/serialComm.cpp

@@ -0,0 +1,117 @@
+#include <jni.h>
+#include <string>
+
+#include <fcntl.h>
+#include <unistd.h>
+#include <sys/ioctl.h>
+#include <linux/spi/spidev.h>
+#include <android/log.h>
+#include <stdio.h>
+#include <dirent.h>
+#include <stdlib.h>
+#include <unistd.h>
+#include <fcntl.h>
+#include <string.h>
+#include <termios.h>
+#include <time.h>
+#include "GPIOControl.h"
+#include "serialComm.h"
+
+
+static void set_baudrate (struct termios *opt, unsigned int baudrate)
+{
+    cfsetispeed(opt, baudrate);
+    cfsetospeed(opt, baudrate);
+}
+
+static void set_data_bit (struct termios *opt, unsigned int databit)
+{
+    opt->c_cflag &= ~CSIZE;
+    switch (databit)
+    {
+        case 8:
+            opt->c_cflag |= CS8;
+            break;
+        case 7:
+            opt->c_cflag |= CS7;
+            break;
+        case 6:
+            opt->c_cflag |= CS6;
+            break;
+        case 5:
+            opt->c_cflag |= CS5;
+            break;
+        default:
+            opt->c_cflag |= CS8;
+            break;
+    }
+}
+
+static void set_parity (struct termios *opt, char parity)
+{
+    switch (parity)
+    {
+        case'N':/* 无校验 */
+        case 'n':
+            opt->c_cflag &= ~PARENB;
+            break;
+        case'E':/*偶校验*/
+        case 'e':
+            opt->c_cflag |= PARENB;
+            opt->c_cflag &= ~PARODD;
+            break;
+        case'O':/* 奇校验 */
+        case 'o':
+            opt->c_cflag |= PARENB;
+            opt->c_cflag |= ~PARODD;
+            break;
+        default: /*其它选择为无校验 */
+            opt->c_cflag &= ~PARENB;
+            break;
+    }
+}
+
+static void set_stopbit (struct termios *opt, const char *stopbit)
+{
+    if (strcmp(stopbit, "1") == 0)
+    {
+        opt->c_cflag &= ~CSTOPB;/*1 位停止位 t */
+    }
+    else if(0 == strcmp(stopbit, "1.5"))
+    {
+        opt->c_cflag &= ~CSTOPB;/*1.5 位停止位 */
+    }
+    else if(0 == strcmp (stopbit,"2"))
+    {
+        opt->c_cflag |= CSTOPB; /*2 位停止位 */
+    }
+    else
+    {
+        opt->c_cflag &= ~CSTOPB; /*1 位停止位 */
+    }
+}
+
+int set_port_attr (int fd, int baudrate, int databit, const char *stopbit, char parity, int vtime, int vmin )
+{
+    struct termios opt;
+    tcgetattr(fd, &opt);
+    set_baudrate(&opt, baudrate);
+    //opt.c_cflag |= CLOCAL|CREAD; /*|CRTSCTS */
+    opt.c_lflag &= ~(ICANON | ECHO |ECHOE |ISIG);
+    set_data_bit(&opt, databit);
+    set_parity(&opt, parity);
+    set_stopbit(&opt, stopbit);
+    opt.c_iflag &=~(INLCR|ICRNL);
+    opt.c_iflag &=~(IXON);/* 流控*/
+    opt.c_oflag = 0;
+    //opt.c_lflag |= 0;
+    opt.c_oflag &= ~OPOST;
+    opt.c_cc[VTIME] = vtime;
+    opt.c_cc[VMIN] = vmin;
+    tcflush (fd, TCIFLUSH);
+    return (tcsetattr (fd, TCSANOW, &opt));
+}
+
+
+
+

app/src/main/cpp/serialComm.h

@@ -0,0 +1,19 @@
+//
+// Created by hyz on 2024/6/5.
+//
+
+#ifndef SERIAL_COMM_BASE89656_H
+#define SERIAL_COMM_BASE89656_H
+
+#include <string>
+#include "GPIOControl.h"
+
+#define MAX_STRING_LEN 32
+#define IOT_PARAM_WRITE 0xAE
+#define IOT_PARAM_READ 0xAF
+
+#define LOGE(fmt, args...) __android_log_print(ANDROID_LOG_ERROR, "serial_port_comm", fmt, ##args)
+
+int set_port_attr (int fd, int baudrate, int databit, const char *stopbit, char parity, int vtime, int vmin );
+
+#endif //SERIAL_COMM_BASE89656_H