Merge branch 'master' of ssh://115.28.86.8:29418/~admin/昆仑_1025

lzz

2024-11-01 ea5a9a7ea7dc79e9144bb9d084d766eda6e46284

 Server/ÂíÀöƼ/code/log/log.h

@@ -3,12 +3,12 @@

#include <stdio.h>
#include <iostream>
#include <string>
#include <stdarg.h>
#include <thread> 
#include <thread>
#include "block_queue.h"
#include "locker.h" // ç¡®ä¿ locker.h è¢«åŒ…含
#include "locker.h"
#include <fstream>
#include <sqlite3.h> // æ·»åŠ  SQLite æ•°æ®åº“的头文件

using namespace std;

@@ -22,10 +22,12 @@

// å­˜å‚¨è§£æžæ—¥å¿—文件的结构体
struct ParsedLog {
    std::string timestamp; // æ—¶é—´æˆ³
    std::string device_id; // è®¾å¤‡ID
    std::string level;     // æ—¥å¿—级别
    std::string content;   // æ—¥å¿—内容
    char timestamp[64]; // æ—¶é—´æˆ³
    char device_id[64]; // è®¾å¤‡ID
    char level[16];     // æ—¥å¿—级别
    char content[256];  // æ—¥å¿—内容
    char source[64];    // æ¥æºæ¨¡å—
    char user_id[64];   // ç”¨æˆ·ID
};

class Log
@@ -42,17 +44,19 @@
    void flush_log_thread(); // ä¿®æ”¹ä¸ºéžé™æ€æˆå‘˜å‡½æ•°

    // åˆå§‹åŒ–日志系统，参数包括文件名、是否关闭日志、缓冲区大小、最大行数和最大队列大小
    bool Log::init(const char *file_name, int close_log, int log_buf_size, int split_lines, int max_queue_size);
    bool init(const char *file_name, int close_log, int log_buf_size, int split_lines, int max_queue_size);

    
    // å†™å…¥æ—¥å¿—
    void write_log(int level, const char *format, ...);
    
    // åˆ·æ–°æ—¥å¿—文件
    void flush(void);

    //接收原始的要公共类
    void receiveLog(const std::string& raw_log); // æŽ¥æ”¶åŽŸå§‹æ—¥å¿—
    // æŽ¥æ”¶åŽŸå§‹æ—¥å¿—
    void receiveLog(const char* raw_log);

    // å°†æ—¥å¿—写入数据库
    void writeLogToDatabase(const ParsedLog& log);

private:
    Log(); // æž„造函数
@@ -62,12 +66,12 @@
    bool check_log_size(); // æ£€æŸ¥æ—¥å¿—文件大小
    void rotate_logs(); // è½®æ¢æ—¥å¿—文件
    
    ParsedLog parseLog(const std::string& log); // è§£æžæ—¥å¿—
    bool init(const std::string &file_name, int close_log, int log_buf_size, int split_lines, int max_queue_size);
    void queryLogs(const std::string &device_id); // æŸ¥è¯¢æ—¥å¿—
    ParsedLog parseLog(const char* log); // è§£æžæ—¥å¿—
    bool init(const char *file_name, int close_log, int log_buf_size, int split_lines, int max_queue_size);
    void queryLogs(const char *device_id); // æŸ¥è¯¢æ—¥å¿—

    const char* log_level_to_string(int level); // å°†æ—¥å¿—级别转换为字符串
    int levelToInt(const std::string &level);
    int levelToInt(const char *level);

private:
    char dir_name[128]; // æ—¥å¿—文件目录
@@ -78,16 +82,18 @@
    int m_today;        // è®°å½•å½“前时间
    std::ofstream m_fp; // å°† FILE * m_fp æ›´æ”¹ä¸º std::ofstream m_fp
    char *m_buf;        // æ—¥å¿—缓冲区
    block_queue<string> *m_log_queue; // é˜»å¡žé˜Ÿåˆ—
    block_queue<char*> *m_log_queue; // é˜»å¡žé˜Ÿåˆ—
    bool m_is_async;                  // æ˜¯å¦å¼‚步标志位
    locker m_mutex;                   // äº’斥锁
    int m_close_log; // å…³é—­æ—¥å¿—的标志
    long max_size = 10 * 1024 * 1024; // 10MB
    //测试文件里面的
    int m_close_log; // ç¡®ä¿åœ¨è¿™é‡Œå®šä¹‰
    long max_size = 10 * 1024 * 1024; // å•ä¸ªæ—¥å¿—文件的大小 10MB

    // æ•°æ®åº“相关
    sqlite3 *db; // SQLite æ•°æ®åº“指针
    void openDatabase(const char *db_name); // æ‰“开数据库
    void closeDatabase(); // å…³é—­æ•°æ®åº“
};

// å®å®šä¹‰ç”¨äºŽä¸åŒçº§åˆ«çš„日志记录
#define LOG_DEBUG(format, ...) if(0 == m_close_log) {Log::get_instance()->write_log(DEBUG, format, ##__VA_ARGS__); Log::get_instance()->flush();}
#define LOG_INFO(format, ...) if(0 == m_close_log) {Log::get_instance()->write_log(INFO, format, ##__VA_ARGS__); Log::get_instance()->flush();}
#define LOG_WARN(format, ...) if(0 == m_close_log) {Log::get_instance()->write_log(WARN, format, ##__VA_ARGS__); Log::get_instance()->flush();}