Method offlineAlarmThread

server/src/main.cpp:703–804

}

void CMain::offlineAlarmThread(void *pUser)
{
    CJSONUpdateThreadData *m_OfflineAlarmThreadData = (CJSONUpdateThreadData *)pUser;
    CClient *pClients = m_OfflineAlarmThreadData->pClients;
    CWatchDog *pWatchDogs = m_OfflineAlarmThreadData->pWatchDogs;
    volatile short ClientID = m_OfflineAlarmThreadData->m_ReloadRequired;
    thread_sleep(25000);
    if(!pClients[ClientID].m_Connected)
    {
        int ID = 0;
        while (strcmp(pWatchDogs[ID].m_aName, "NULL"))
        {
            typedef exprtk::symbol_table<double> symbol_table_t;
            typedef exprtk::expression<double>   expression_t;
            typedef exprtk::parser<double>       parser_t;
            const std::string expression_string = pWatchDogs[ID].m_aRule;
            std::string username = pClients[ClientID].m_aUsername;
            std::string name = pClients[ClientID].m_aName;
            std::string type = pClients[ClientID].m_aType;
            std::string host = pClients[ClientID].m_aHost;
            std::string location = pClients[ClientID].m_aLocation;
            std::double_t online4 = pClients[ClientID].m_Stats.m_Online4;
            std::double_t online6 = pClients[ClientID].m_Stats.m_Online6;

            symbol_table_t symbol_table;
            symbol_table.add_stringvar("username", username);
            symbol_table.add_stringvar("name", name);
            symbol_table.add_stringvar("type", type);
            symbol_table.add_stringvar("host", host);
            symbol_table.add_stringvar("location", location);
            symbol_table.add_variable("online4",online4);
            symbol_table.add_variable("online6",online6);
            symbol_table.add_constants();

            expression_t expression;
            expression.register_symbol_table(symbol_table);

            parser_t parser;
            parser.compile(expression_string,expression);

            if (expression.value() > 0)
            {
                time_t currentStamp = (long long)time(/*ago*/0);
                if ((currentStamp-pClients[ClientID].m_AlarmLastTime) > pWatchDogs[ID].m_aInterval)
                {
                    printf("客户端下线且超过阈值, Client disconnects and sends alert information\n");
                    pClients[ClientID].m_AlarmLastTime = currentStamp;
                    CURL *curl;
                    CURLcode res;
                    curl_global_init(CURL_GLOBAL_ALL);

                    curl = curl_easy_init();
                    if(curl) {
                        //standard time
                        char standardTime[32]= { 0 };
                        strftime(standardTime, sizeof(standardTime), "%Y-%m-%d %H:%M:%S",localtime(&currentStamp));

                        //url encode, Rules conflict with url special characters，eg：&, del rules, by https://cpp.la, 2023-10-09