AlarmModule/core/core.h

#ifndef __MOZIT_CORE_H
#define __MOZIT_CORE_H
#include <stdint.h>
#include <ctype.h>
#include <assert.h>
#include "../include/mysql.sdk.h"
/******************************************************************
** Copyright (c) 2009  Wuhan Technology Co., Ltd .
** FileName:	core.c
** Author:	 	BigHead
** Mail:		jsrenyw@icloud.com
** Editor:		bighead
** Date:		2020-11-10 13:34
** Version: 	2020-11-10
** File Description:  业务逻辑核心代码实现部分
******************************************************************/
#include "../include/debug.h"
#include "mqtta.h"
#include "regfunc.h"
#include "myqueue.h"
#include <signal.h>
#include "list.h"
#include <sys/types.h>
#include <sys/stat.h>

#define EACH_PACK_SIZE 1024
#define FILE_BYTES 1024*300

#define UNUSED(x) (void)(x)
#define NUM_THREADS 2
ArrQueue *m_pque;//任务队列

struct my_thread_info 
{
    int which;
};

typedef union{
	char c_char[4];
	int  i_int;
}char2int;

typedef union{
	char c_char[2];
	short i_short;
}char2short;

/*************************远程升级***************************/
typedef struct ota_info
{
	char ota_mode; // ota 模式 0:差分 1：全量
	char old_file_name[48]; // 旧文件名 
	uint32_t old_file_len; // 旧文件的长度 
	uint32_t old_file_crc; // 旧文件crc32 校验值
	char new_file_name[48]; // 新文件名 
	uint32_t new_file_len; // 新文件的长度
	uint32_t new_file_crc; // 新文件crc32 校验值 
	uint8_t ota_state; // ota 状态 
	uint32_t ota_file_len; // ota 文件的长度 
	uint32_t ota_file_crc; // ota 文件的crc32校验值
	uint16_t ota_file_total_packets; // ota文件的总的包数 
	uint16_t ota_file_packet_len; // ota文件每包的数据长度 
	uint8_t  buf[FILE_BYTES];//升级报文
} ota_info;

typedef struct upgrade_user_info
{
	char mac[30];	//mac
	char ota_file_name[48];	//升级文件名
} upgrade_user_info;



/******************************************************************
 *	Function Name:	core_init
 *	Arguments:
 *	Return Value:	void
 *	Date: 			2020-11-10
 *	Editor:			bighead
 *	Description:	程序启动时刻,调用该初始化函数仅 一次,该函数不允许重复调用
 ******************************************************************/
int core_init( void);

/******************************************************************
 *	Function Name:	core_heart
 *	Arguments:
 *	Return Value:	void
 *	Date: 			2020-11-10
 *	Editor:			bighead
 *	Description:  每次主线程心跳调用, 约200ms一次, 可以调整频率在decode.c
 ******************************************************************/
int core_heart( unsigned int nowtime);

/******************************************************************
 *	Function Name:	core_heart_1s
 *	Arguments:
 *	Return Value:	void
 *	Date: 			2020-11-10
 *	Editor:			bighead
 *	Description:	每次主线程心跳调用, 约1s一次,不超过2s, 在core_heart心跳函数之后调用
 *               可以调整频率在decode.c
 ******************************************************************/
int core_heart_1s( unsigned int nowtime);

/******************************************************************
 *	Function Name:	db_init
 *	Arguments:
 *	Return Value:	void
 *	Date: 			2020-11-10
 *	Editor:			bighead
 *	Description:	程序启动时刻,调用该初始化函数多次,初始化不同mysql 连接
 ******************************************************************/
int db_init(MYSQL *db);

int core_do_test(void);
int core_stats(void);

/******************************************************************
 *	Function Name:	SendCmdFromDb
 *	Arguments:
 *	Return Value:	void
 *	Date: 			2022-04-02
 *	Editor:			chw
 *	Description:	扫描数据库发送指令
 ******************************************************************/
int SendCmdFromDb(void);

/******************************************************************
 *	Function Name:	TimeSyncBroadcast
 *	Arguments:
 *	Return Value:	void
 *	Date: 			2022-04-02
 *	Editor:			chw
 *	Description:	时间同步广播
 ******************************************************************/
int TimeSyncBroadcast(void);

/******************************************************************
 *	Function Name:	ByteToHexStr
 *	Arguments:
 *	Return Value:	void
 *	Date: 			2022-04-02
 *	Editor:			chw
 *	Description:	1.字节流转换为十六进制字符串
 ******************************************************************/
void ByteToHexStr(const unsigned char* source, char* dest, int sourceLen);

/******************************************************************
 *	Function Name:	Hex2Str
 *	Arguments:
 *	Return Value:	void
 *	Date: 			2022-04-02
 *	Editor:			chw
 *	Description:	2.字节流转换为十六进制字符串
 ******************************************************************/
void Hex2Str( const char *sSrc,  char *sDest, int nSrcLen );

/******************************************************************
 *	Function Name:	HexStrToByte
 *	Arguments:
 *	Return Value:	void
 *	Date: 			2022-04-02
 *	Editor:			chw
 *	Description:	十六进制字符串转换为字节流
 ******************************************************************/
void HexStrToByte(const char* source, unsigned char* dest, int sourceLen);

/******************************************************************
 *	Function Name:	EndianSwap
 *	Arguments:
 *	Return Value:	void
 *	Date: 			2022-04-02
 *	Editor:			chw
 *	Description:	改变字节顺序
 ******************************************************************/
void EndianSwap(unsigned char *pData, int startIndex, int length);

/******************************************************************
 *	Function Name:	GetCurrentNYTable
 *	Arguments:
 *	Return Value:	void
 *	Date: 			2022-04-02
 *	Editor:			chw
 *	Description:	获取当前月份历史表
 ******************************************************************/
char* GetCurrentNYTable(void);

/******************************************************************
 *	Function Name:	GetCurrentTime
 *	Arguments:
 *	Return Value:	void
 *	Date: 			2022-04-02
 *	Editor:			chw
 *	Description:	获取系统时间年月日 时分秒
 ******************************************************************/
char* GetCurrentTime(void);

/******************************************************************
 *	Function Name:	IsRelayAlarmCode
 *	Arguments:
 *	Return Value:	void
 *	Date: 			2022-04-02
 *	Editor:			chw
 *	Description:	判断是否属于报警code
 ******************************************************************/
int IsRelayAlarmCode(int relayCode);

/******************************************************************
 *	Function Name:	RelayAlarm
 *	Arguments:
 *	Return Value:	void
 *	Date: 			2022-04-02
 *	Editor:			chw
 *	Description:	继电器报警
 ******************************************************************/
int RelayAlarm(char* mac,char* subMac,int relayCode,MYSQL* _db);

/******************************************************************
 *	Function Name:	find_char
 *	Arguments:
 *	Return Value:	void
 *	Date: 			2022-04-02
 *	Editor:			chw
 *	Description:	字符串中查找指定字符的个数
 ******************************************************************/
int find_char(char str[], char substr[]);

/******************************************************************
 *	Function Name:	find_string
 *	Arguments:
 *	Return Value:	void
 *	Date: 			2022-04-02
 *	Editor:			chw
 *	Description:	从主题中查找指定'/'分割的段
 ******************************************************************/
char* find_string(char* topicName, int section);

/******************************************************************
 *	Function Name:	sendtoqueue
 *	Arguments:
 *	Return Value:	void
 *	Date: 			2022-04-02
 *	Editor:			chw
 *	Description:	将任务放入队列
 ******************************************************************/
void* sendtoqueue(ArrQueue *pQueue,char* stringSql);

/******************************************************************
 *	Function Name:	getqueue
 *	Arguments:
 *	Return Value:	void
 *	Date: 			2022-04-02
 *	Editor:			chw
 *	Description:	将任务从队列中取出
 ******************************************************************/
void* getqueue(void *data);

/******************************************************************
 *	Function Name:	CreateDbHandThread
 *	Arguments:
 *	Return Value:	void
 *	Date: 			2022-04-02
 *	Editor:			chw
 *	Description:	创建任务线程处理数据库执行
 ******************************************************************/
void CreateDbHandThread(void);

/*************************远程升级*********************************************/

/******************************************************************
 *	Function Name:	init_crc32_tab
 *	Arguments:
 *	Return Value:	void
 *	Date: 			2022-04-02
 *	Editor:			chw
 *	Description:	生成CRC查询表
 ******************************************************************/
void init_crc32_tab(void);

/******************************************************************
 *	Function Name:	get_crc32
 *	Arguments:
 *	Return Value:	void
 *	Date: 			2022-04-02
 *	Editor:			chw
 *	Description:	获得CRC
 ******************************************************************/
uint32_t get_crc32(uint32_t crcinit, uint8_t *bs, uint32_t bssize);

/******************************************************************
 *	Function Name:	获取缓存中的crc32
 *	Arguments:
 *	Return Value:	void
 *	Date: 			2022-04-29
 *	Editor:			chw
 *	Description:	获取缓存中的crc32
 ******************************************************************/
int32_t calc_crc32_from_buff(const char *buff, int len, uint32_t *uiCrcValue);

/******************************************************************
 *	Function Name:	readfile_from_db
 *	Arguments:
 *	Return Value:	void
 *	Date: 			2022-04-29
 *	Editor:			chw
 *	Description:	从数据库读取升级文件
 ******************************************************************/
unsigned char *readfile_from_db(const char *filename, MYSQL *_db,int *file_length_bytes);

/******************************************************************
 *	Function Name:	GetFileNameByMac
 *	Arguments:
 *	Return Value:	void
 *	Date: 			2022-04-02
 *	Editor:			chw
 *	Description:	根据mac查询对应升级文件名
 ******************************************************************/
char* GetFileNameByMac(list_node* user_list,char* mac);


/******************************************************************
 *	Function Name:	UpgradeFileAddFromDB
 *	Arguments:
 *	Return Value:	void
 *	Date: 			2022-04-02
 *	Editor:			chw
 *	Description:	新增升级文件映射节点
 ******************************************************************/
void UpgradeFileAddFromDB(list_node* f_list,char* filename,MYSQL *_db,int ota_mode);

/******************************************************************
 *	Function Name:	GetOtaInfoByFileName
 *	Arguments:
 *	Return Value:	void
 *	Date: 			2022-04-02
 *	Editor:			chw
 *	Description:	根据文件名和包序号查询分包数据
 ******************************************************************/
ota_info* GetOtaInfoByFileName(list_node* f_list,char* filename);

/******************************************************************
 *	Function Name:	GetUpgradeFileFromDB
 *	Arguments:
 *	Return Value:	void
 *	Date: 			2022-04-02
 *	Editor:			chw
 *	Description:	数据库查询升级文件名
 ******************************************************************/
void GetUpgradeFileFromDB(char *mac,MYSQL *_db,char* filename);

/******************************************************************
 *	Function Name:	core_alarm_gateway
 *	Arguments:
 *	Return Value:	void
 *	Date: 			2023-12-5
 *	Editor:			cc
 *	Description:	扫描网关设备数据
 ******************************************************************/
int CoreAlarmGateway(void);

/******************************************************************
 *	Function Name:	core_alarm_gateway
 *	Arguments:
 *	Return Value:	void
 *	Date: 			2023-12-8
 *	Editor:			cc
 *	Description:	扫描节点设备数据
 ******************************************************************/
int CoreAlarmNode(void);

/******************************************************************
 *	Function Name:	ElectricAlarm
 *	Arguments:
 *	Return Value:	void
 *	Date: 			2023-12-7
 *	Editor:			cc
 *	Description:	电流数据告警判断
 ******************************************************************/
int ElectricAlarm(char* mac,char* subMac,char* gatewayName,char* nodeName,int alarmCode,char* alarmStr,MYSQL* _db);

/******************************************************************
 * @brief 比较两个时间字符串的大小
 *
 * @param time1 时间字符串1，格式为 "HH:MM"
 * @param time2 时间字符串2，格式为 "HH:MM"
 *
 * @return 返回值为整数：
 *         -1 表示 time1 小于 time2
 *          0 表示 time1 等于 time2
 *          1 表示 time1 大于 time2
 *          0 也可能表示解析失败或转换失败
 *
 * @details 该函数将两个时间字符串解析为 struct tm 结构，并使用 mktime 函数将其转换为 time_t 类型，
 *          然后比较这两个时间，返回相应的比较结果。如果解析或转换失败，函数返回 0。
 ******************************************************************/
int compareTimes(const char *time1, const char *time2);

/**
 * @brief 比较两个时间的函数
 * 
 * @param t1 第一个时间结构体
 * @param t2 第二个时间结构体
 * 
 * @return 负数表示t1 < t2，正数表示t1 > t2，零表示t1 == t2
 * 
 * @details 该函数将两个时间结构体t1和t2转换为秒数，然后比较这两个秒数以确定它们的相对顺序。
 *          函数返回一个整数，用于指示t1相对于t2的顺序。负数表示t1在t2之前，正数表示t1在t2之后，零表示它们相等。
 * 
 * @note 该函数不会修改输入的时间结构体。
 */
int compareModifiedTimes(struct tm t1, struct tm t2);

/**
 * @brief 比较给定时间和系统当前时间的函数
 * 
 * @param t1 给定的时间结构体
 * 
 * @return 负数表示给定时间在系统当前时间之前，正数表示给定时间在系统当前时间之后，零表示它们相等
 * 
 * @details 该函数将给定时间结构体t1转换为秒数，并获取系统当前时间转换为秒数，然后比较这两个秒数以确定它们的相对顺序。
 *          函数返回一个整数，用于指示给定时间相对于系统当前时间的顺序。负数表示给定时间在系统当前时间之前，正数表示
 *          给定时间在系统当前时间之后，零表示它们相等。
 * 
 * @note 该函数不会修改输入的时间结构体。
 */
int compareWithCurrentTime(struct tm t1);

//更新时间和拉合闸的时间点比较
int compareWithUpdateTime(const char *timeString,const char *time1,const char *time2,const char *time3,const char *time4);

#ifdef UPGRADE_BY_FILE
/******************************************************************
*	Function Name:	calc_file_crc32
*	Arguments:
*	Return Value:	void
*	Date: 			2022-04-02
*	Editor:			chw
*	Description:	获得文件CRC 现已从数据库读取,暂不用
******************************************************************/
int32_t calc_file_crc32(const char *pFileName, uint32_t *uiCrcValue);

/******************************************************************
*	Function Name:	GetFileLength
*	Arguments:
*	Return Value:	void
*	Date: 			2022-04-02
*	Editor:			chw
*	Description:	获取文件长度 现已从数据库读取,暂不用
******************************************************************/
int GetFileLength(char* file_path);

/******************************************************************
*	Function Name:	read_myfile
*	Arguments:
*	Return Value:	void
*	Date: 			2022-04-02
*	Editor:			chw
*	Description:	 现已从数据库读取,暂不用
******************************************************************/
//unsigned char *read_myfile(const char *path, int *file_size);
	
/******************************************************************
*	Function Name:	UpgradeUserAdd
*	Arguments:
*	Return Value:	void
*	Date: 			2022-04-02
*	Editor:			chw
*	Description:	增加用户 现已从数据库读取,暂不用
******************************************************************/
//void UpgradeUserAdd(list_node* u_list,char* mac,char* file_name);

/******************************************************************
*	Function Name:	UpgradeFileAdd
*	Arguments:
*	Return Value:	void
*	Date: 			2022-04-02
*	Editor:			chw
*	Description:	新增升级文件映射节点 现已从数据库读取,暂不用
******************************************************************/
//void UpgradeFileAdd(list_node* f_list,char* filename,int ota_mode);
#endif

#endif /* #ifndef __MOZITI_CORE_H */