From a33418113aae0a4fea7e4ec174991f149cdce0bf Mon Sep 17 00:00:00 2001 From: lnk Date: Fri, 30 May 2025 15:40:20 +0800 Subject: [PATCH] log optimize --- cfg_parse/SimpleProducer.cpp | 3 + cfg_parse/cfg_parser.cpp | 11 +++- json/create_json.cpp | 13 ++-- json/save2json.cpp | 117 +++++++++++++++++++++-------------- mms/rdb_client.c | 2 +- mms/rdb_ext_utils.c | 12 ++++ 6 files changed, 106 insertions(+), 52 deletions(-) diff --git a/cfg_parse/SimpleProducer.cpp b/cfg_parse/SimpleProducer.cpp index 3f4e0b9..d21e73a 100644 --- a/cfg_parse/SimpleProducer.cpp +++ b/cfg_parse/SimpleProducer.cpp @@ -36,6 +36,8 @@ #include // 用于互斥锁（在 C++98 中没有 std::mutex） #include // for std::pair +#include "../log4cplus/log4.h"//lnk添加log4 + using namespace std; extern std::string G_ROCKETMQ_PRODUCER;//rocketmq producer @@ -553,6 +555,7 @@ void rocketmq_producer_send(const char* strbody, const char* topic) catch (const std::exception& e) { std::cerr << "Failed to send message: " << e.what() << std::endl; // 处理发送失败的情况，例如记录日志或重试 + DIY_ERRORLOG("process","【ERROR】前置的%s%d号进程 mq发送失败,请检查mq配置", get_front_msg_from_subdir(), g_front_seg_index); } } #endif diff --git a/cfg_parse/cfg_parser.cpp b/cfg_parse/cfg_parser.cpp index 1f1b67c..ef8e8a9 100644 --- a/cfg_parse/cfg_parser.cpp +++ b/cfg_parse/cfg_parser.cpp @@ -4470,7 +4470,10 @@ int parse_model_cfg_web() } ///////////////////////////////////////////////////////////////////////// - parse_model_web(&icd_model_map,codes); + if(parse_model_web(&icd_model_map,codes)){ + DIY_ERRORLOG("process","【ERROR】前置的%s%d号进程 icd模型接口异常,将使用默认的icd模型,请检查接口配置", get_front_msg_from_subdir(), g_front_seg_index); + return APR_SUCCESS; //可以使用默认的映射文件所以返回正常 + } codes.clear(); @@ -4723,6 +4726,7 @@ int recall_json_handle(const char* jstr) if(strcmp(ied_usr->LD_info[m].mp_id,monitorId.toStdString().c_str()) == 0){//匹配上了 + DIY_INFOLOG("process","【NORMAL】前置的%s%d号进程处理监测点%s -id:%s 的数据补招",get_front_msg_from_subdir(), g_front_seg_index,ied_usr->LD_info[m].name,ied_usr->LD_info[m].mp_id); mppair = 1; break;//找到就退出监测点循环 } @@ -4945,6 +4949,7 @@ void handleUploadResponse(const std::string& response, char* wavepath) { cJSON* json_data = cJSON_Parse(response.c_str()); if (json_data == nullptr) { std::cerr << "Error parsing response: " << cJSON_GetErrorPtr() << std::endl; + DIY_ERRORLOG("process","【ERROR】前置上传暂态录波文件失败,web返回的消息不是json格式"); return; } @@ -4989,9 +4994,12 @@ void handleUploadResponse(const std::string& response, char* wavepath) { strcpy(wavepath, nameWithoutExt.c_str()); std::cout << "wavepath: " << wavepath << std::endl; + + DIY_INFOLOG("process","【NORMAL】前置上传暂态录波文件成功,远端文件名:%s",wavepath); } } else { std::cerr << "Error: Missing expected fields in JSON response." << std::endl; + DIY_ERRORLOG("process","【ERROR】前置上传暂态录波文件失败,web返回的消息没有远端文件名"); } // 释放 JSON 对象 @@ -5108,6 +5116,7 @@ void SendFileWeb(const std::string& strUrl, const char* localpath, const char* c CURLcode res = curl_easy_perform(curl); if (res != CURLE_OK) { std::cerr << "http web failed: " << curl_easy_strerror(res) << std::endl; + DIY_ERRORLOG("process","【ERROR】前置上传暂态录波文件 %s 失败，请检查文件上传接口配置",localpath); } else { std::cout << "http web success, response: " << resPost0 << std::endl; handleUploadResponse(resPost0, wavepath); // 处理响应 diff --git a/json/create_json.cpp b/json/create_json.cpp index 072acb0..4ba22e4 100644 --- a/json/create_json.cpp +++ b/json/create_json.cpp @@ -2890,11 +2890,11 @@ static void getDirectoryFilesInfo(const std::string &dirPath, std::vectortype != cJSON_String) { std::cerr << "'messageJson' is missing or is not an cJSON_String" << std::endl; cJSON_Delete(root); - return ; + return 1; } // 解析 messageBody 中的 JSON 字符串 @@ -901,14 +901,14 @@ void parse_set(const std::string& json_str) { if (messageBodyStr == nullptr || strlen(messageBodyStr) == 0) { std::cerr << "Failed to parse 'messageBody' JSON or it's empty." << std::endl; cJSON_Delete(root); - return; + return 1; } cJSON* messageBody = cJSON_Parse(messageBodyStr); // 解析 messageBody 字符串 if (messageBody == NULL) { std::cerr << "Failed to parse 'messageBody' JSON." << std::endl; cJSON_Delete(root); - return ; + return 1; } // 获取 guid 字段 @@ -916,7 +916,7 @@ void parse_set(const std::string& json_str) { if (guidstr == nullptr) { std::cout << "Missing 'guid' in JSON." << std::endl; cJSON_Delete(root); - return; + return 1; } // 根据 guid 字段回复消息 @@ -927,7 +927,7 @@ void parse_set(const std::string& json_str) { if (code == nullptr) { std::cout << "Missing 'code' in JSON." << std::endl; cJSON_Delete(root); - return; + return 1; } // 根据 code 字段值执行不同的解析逻辑 @@ -937,7 +937,7 @@ void parse_set(const std::string& json_str) { if (processNo == nullptr) { std::cout << "Missing 'processNo' in JSON." << std::endl; cJSON_Delete(root); - return; + return 1; } //判断是不是自己进程号： @@ -947,7 +947,7 @@ void parse_set(const std::string& json_str) { if (funtion == nullptr) { std::cout << "Missing 'fun' in JSON." << std::endl; cJSON_Delete(root); - return; + return 1; } std::string fun = funtion->valuestring; @@ -956,7 +956,7 @@ void parse_set(const std::string& json_str) { if (front == nullptr) { std::cout << "Missing 'frontType' in JSON." << std::endl; cJSON_Delete(root); - return; + return 1; } std::string frontType = front->valuestring; @@ -964,12 +964,13 @@ void parse_set(const std::string& json_str) { if (index_value != g_front_seg_index && g_front_seg_index != 0) { std::cout << "msg index:"<< index_value <<"doesnt match self index:" << g_front_seg_index << std::endl; cJSON_Delete(root); - return; + return 0; } //进程号为0或者进程号匹配上 std::cout << "msg index:"<< index_value <<" self index:" << g_front_seg_index << std::endl; + DIY_INFOLOG("process","【NORMAL】前置的%s%d号进程处理topic:%s_%s的进程控制消息",get_front_msg_from_subdir(), g_front_seg_index,FRONT_INST.c_str(),G_MQCONSUMER_TOPIC_SET.c_str()); if (code_str == "set_process") { @@ -977,7 +978,7 @@ void parse_set(const std::string& json_str) { if (num == nullptr) { std::cout << "Missing 'processNum' in JSON." << std::endl; cJSON_Delete(root); - return; + return 1; } int processNum = num->valueint; @@ -995,6 +996,8 @@ void parse_set(const std::string& json_str) { } execute_bash(fun, processNum, frontType); + DIY_WARNLOG("process","【WARN】前置的%s%d号进程执行指令:%s,reset表示重启所有进程,add表示添加进程",get_front_msg_from_subdir(), g_front_seg_index,fun.c_str()); + //脚本在3秒后执行 //回复消息 send_reply_to_kafka(guid,"1","收到重置进程指令,重启所有进程!"); @@ -1015,6 +1018,7 @@ void parse_set(const std::string& json_str) { send_reply_to_kafka(guid,"1","收到删除进程指令,这个进程将会重启 "); //上送日志 + DIY_WARNLOG("process","【WARN】前置的%s%d号进程执行指令:%s,即将重启",get_front_msg_from_subdir(), g_front_seg_index,fun.c_str()); apr_sleep(apr_time_from_sec(10)); ::_exit(-1039); //进程退出 @@ -1032,7 +1036,7 @@ void parse_set(const std::string& json_str) { if (onlyip == nullptr) { std::cout << "Missing 'ip' in JSON." << std::endl; cJSON_Delete(root); - return; + return 1; } std::string ip = onlyip->valuestring; @@ -1041,7 +1045,7 @@ void parse_set(const std::string& json_str) { if (index_item == nullptr) { std::cout << "Missing 'proindex' in JSON." << std::endl; cJSON_Delete(root); - return; + return 1; } int proindex = index_item->valueint; @@ -1054,6 +1058,8 @@ void parse_set(const std::string& json_str) { (frontType == "stat" || frontType == "recall" || frontType == "realTime" || frontType == "comtrade") && (proindex >= 10 && proindex < 100)){ //单连测试用的进程号应该大于10小于100 execute_bash_debug(fun, ip, frontType,proindex); + + DIY_WARNLOG("process","【WARN】前置的%s%d号进程执行指令:%s,start开启单连进程,delete杀死单连进程",get_front_msg_from_subdir(), g_front_seg_index,fun.c_str()); } else{ std::cout << "param is not executable" <type != cJSON_String) { std::cerr << "'messageJson' is missing or is not an cJSON_String" << std::endl; cJSON_Delete(root); - return ; + return 1; } // 解析 messageBody 中的 JSON 字符串 @@ -1286,14 +1293,14 @@ void parse_log(const std::string& json_str) { if (messageBodyStr == nullptr || strlen(messageBodyStr) == 0) { std::cerr << "Failed to parse 'messageBody' JSON or it's empty." << std::endl; cJSON_Delete(root); - return; + return 1; } cJSON* messageBody = cJSON_Parse(messageBodyStr); // 解析 messageBody 字符串 if (messageBody == NULL) { std::cerr << "Failed to parse 'messageBody' JSON." << std::endl; cJSON_Delete(root); - return ; + return 1; } // 获取 guid 字段 @@ -1301,7 +1308,7 @@ void parse_log(const std::string& json_str) { if (guidstr == nullptr) { std::cout << "Missing 'guid' in JSON." << std::endl; cJSON_Delete(root); - return; + return 1; } // 根据 guid 字段回复消息 @@ -1312,7 +1319,7 @@ void parse_log(const std::string& json_str) { if (code == nullptr) { std::cout << "Missing 'code' in JSON." << std::endl; cJSON_Delete(root); - return; + return 1; } // 根据 code 字段值执行不同的解析逻辑 @@ -1323,7 +1330,7 @@ void parse_log(const std::string& json_str) { if (process == nullptr) { std::cout << "Missing 'processNo' in JSON." << std::endl; cJSON_Delete(root); - return; + return 1; } //判断是不是自己进程号： @@ -1334,7 +1341,7 @@ void parse_log(const std::string& json_str) { if (idstr == nullptr) { std::cout << "Missing 'id' in JSON." << std::endl; cJSON_Delete(root); - return; + return 1; } std::string id = idstr->valuestring; @@ -1344,7 +1351,7 @@ void parse_log(const std::string& json_str) { if (levelstr == nullptr) { std::cout << "Missing 'level' in JSON." << std::endl; cJSON_Delete(root); - return; + return 1; } std::string level = levelstr->valuestring; @@ -1354,7 +1361,7 @@ void parse_log(const std::string& json_str) { if (gradestr == nullptr) { std::cout << "Missing 'grade' in JSON." << std::endl; cJSON_Delete(root); - return; + return 1; } std::string grade = gradestr->valuestring; @@ -1364,7 +1371,7 @@ void parse_log(const std::string& json_str) { if (logtypestr == nullptr) { std::cout << "Missing 'logtype' in JSON." << std::endl; cJSON_Delete(root); - return; + return 1; } std::string logtype = logtypestr->valuestring; @@ -1374,7 +1381,7 @@ void parse_log(const std::string& json_str) { if (frontTypestr == nullptr) { std::cout << "Missing 'frontType' in JSON." << std::endl; cJSON_Delete(root); - return; + return 1; } std::string frontType = frontTypestr->valuestring; @@ -1382,15 +1389,17 @@ void parse_log(const std::string& json_str) { if (processNo != g_front_seg_index) { std::cout << "msg index:"<< processNo <<"doesnt match self index:" << g_front_seg_index << std::endl; cJSON_Delete(root); - return; + return 0; } if (frontType != subdir) { std::cout << "msg frontType:"<< frontType <<"doesnt match self frontType:" << subdir << std::endl; cJSON_Delete(root); - return; + return 0; } + DIY_INFOLOG("process","【NORMAL】前置的%s%d号进程处理日志上送消息",get_front_msg_from_subdir(), g_front_seg_index); + //进程号和匹配上 std::cout << "msg index:"<< processNo <<" self index:" << g_front_seg_index << std::endl; std::cout << "msg frontType:"<< frontType <<" self frontType:" << subdir << std::endl; @@ -1419,15 +1428,16 @@ void parse_log(const std::string& json_str) { // 释放 JSON 对象 cJSON_Delete(root); + return 0; } // 台账更新不区分功能 -void parse_control(const std::string& json_str, const std::string& output_dir) { +int parse_control(const std::string& json_str, const std::string& output_dir) { // 解析 JSON 字符串 cJSON* root = cJSON_Parse(json_str.c_str()); if (root == nullptr) { std::cout << "Error parsing JSON." << std::endl; - return; + return 1; } // 提取 "messageBody" 部分 @@ -1435,7 +1445,7 @@ void parse_control(const std::string& json_str, const std::string& output_dir) { if (messageJson == NULL || messageJson->type != cJSON_String) { std::cerr << "'messageJson' is missing or is not an cJSON_String" << std::endl; cJSON_Delete(root); - return ; + return 1; } // 解析 messageBody 中的 JSON 字符串 @@ -1443,14 +1453,14 @@ void parse_control(const std::string& json_str, const std::string& output_dir) { if (messageBodyStr == nullptr || strlen(messageBodyStr) == 0) { std::cerr << "Failed to parse 'messageBody' JSON or it's empty." << std::endl; cJSON_Delete(root); - return; + return 1; } cJSON* messageBody = cJSON_Parse(messageBodyStr); // 解析 messageBody 字符串 if (messageBody == NULL) { std::cerr << "Failed to parse 'messageBody' JSON." << std::endl; cJSON_Delete(root); - return ; + return 1; } // 获取 code 字段 @@ -1458,7 +1468,7 @@ void parse_control(const std::string& json_str, const std::string& output_dir) { if (code == nullptr) { std::cout << "Missing 'code' in JSON." << std::endl; cJSON_Delete(root); - return; + return 1; } // 根据 code 字段值执行不同的解析逻辑 @@ -1469,7 +1479,7 @@ void parse_control(const std::string& json_str, const std::string& output_dir) { if (process == nullptr) { std::cout << "Missing 'processNo' in JSON." << std::endl; cJSON_Delete(root); - return; + return 1; } //判断是不是自己进程号： @@ -1480,7 +1490,7 @@ void parse_control(const std::string& json_str, const std::string& output_dir) { if (guidstr == nullptr) { std::cout << "Missing 'guid' in JSON." << std::endl; cJSON_Delete(root); - return; + return 1; } // 根据 guid 字段回复消息 @@ -1490,12 +1500,15 @@ void parse_control(const std::string& json_str, const std::string& output_dir) { if (process_No != g_front_seg_index && g_front_seg_index !=0) { std::cout << "msg index:"<< process_No <<"doesnt match self index:" << g_front_seg_index << std::endl; cJSON_Delete(root); - return; + return 0; } //进程号为0或者进程号匹配上 std::cout << "msg index:"<< process_No <<" self index:" << g_front_seg_index << std::endl; + //记录日志 + DIY_INFOLOG("process","【NORMAL】前置的%s%d号进程处理topic:%s_%s的台账更新消息",get_front_msg_from_subdir(), g_front_seg_index,FRONT_INST.c_str(),G_MQCONSUMER_TOPIC_UD.c_str()); + //匹配后响应收到台账更新消息 //除了回复收到消息，执行结束后还要回复结果 send_reply_to_kafka(guid,"1","收到台账更新指令"); @@ -1709,6 +1722,8 @@ void parse_control(const std::string& json_str, const std::string& output_dir) { // 释放 JSON 对象 cJSON_Delete(root); + + return 0; } ///////////////////////////////////////////////////////////////////////////////////////////////////////// @@ -1759,6 +1774,8 @@ int myMessageCallbackrtdata(CPushConsumer* consumer, CMessageExt* msg) return E_RECONSUME_LATER; } else{ + //记录日志 + DIY_INFOLOG("process","【NORMAL】前置消费topic:%s_%s的实时触发消息",FRONT_INST.c_str(),G_MQCONSUMER_TOPIC_RT.c_str()); // 处理消息（例如，打印消息内容） std::cout << "rt data Callback received message: " << body << std::endl; @@ -1776,19 +1793,18 @@ int myMessageCallbackrtdata(CPushConsumer* consumer, CMessageExt* msg) // 解析 JSON 数据 if (!parseJsonMessageRT(body, devid, line, realData, soeData, limit)) { std::cerr << "Failed to parse the JSON message." << std::endl; + //记录日志 + DIY_ERRORLOG("process","【ERROR】前置消费topic:%s_%s的实时触发消息失败,消息的json格式不正确",FRONT_INST.c_str(),G_MQCONSUMER_TOPIC_RT.c_str()); return E_RECONSUME_LATER; } - - //记录日志 - //mq处理实时数据指令查询台账时添加锁 - pthread_mutex_lock(&mtx); std::cout << "update ledger xml hold lock !!!!!!!!!!!" << std::endl; + pthread_mutex_lock(&mtx); std::cout << "rtdata hold lock !!!!!!!!!!!" << std::endl; int dev_index = find_dev_index_from_dev_id(devid); int mp_index = find_mp_index_from_mp_id(line); - pthread_mutex_unlock(&mtx); std::cout << "update ledger xml free lock !!!!!!!!!!!" << std::endl; + pthread_mutex_unlock(&mtx); std::cout << "rtdata free lock !!!!!!!!!!!" << std::endl; if(dev_index == 0 || mp_index == 0){ std::cerr << "dev index or mp index is 0" << std::endl; @@ -1796,6 +1812,7 @@ int myMessageCallbackrtdata(CPushConsumer* consumer, CMessageExt* msg) } // 创建 XML 文件 if (!createXmlFile(dev_index, mp_index, realData, soeData, limit,"new")) { + DIY_ERRORLOG("process","【ERROR】前置无法创建实时数据触发文件"); std::cerr << "Failed to create the XML file." << std::endl; return E_RECONSUME_LATER; } @@ -1823,6 +1840,7 @@ int myMessageCallbackupdate(CPushConsumer* consumer, CMessageExt* msg) return E_RECONSUME_LATER; } else{ + //处理消费数据 std::cout << "ledger update Callback received message: " << body << std::endl; if (key) { @@ -1834,7 +1852,9 @@ int myMessageCallbackupdate(CPushConsumer* consumer, CMessageExt* msg) //处理台账更新消息 std::string updatefilepath = "/home/pq/FeProject/etc/ledgerupdate"; - parse_control(body,updatefilepath); + if(parse_control(body,updatefilepath)){ + DIY_ERRORLOG("process","【ERROR】前置的%s%d号进程处理topic:%s_%s的台账更新消息失败,消息的json结构不正确",get_front_msg_from_subdir(), g_front_seg_index,FRONT_INST.c_str(),G_MQCONSUMER_TOPIC_UD.c_str()); + } } @@ -1868,7 +1888,9 @@ int myMessageCallbackset(CPushConsumer* consumer, CMessageExt* msg) } //处理进程更新消息 - parse_set(body); + if(parse_set(body)){ + DIY_ERRORLOG("process","【ERROR】前置的%s%d号进程处理topic:%s_%s的进程控制消息失败,消息的json结构不正确",get_front_msg_from_subdir(), g_front_seg_index,FRONT_INST.c_str(),G_MQCONSUMER_TOPIC_SET.c_str()); + } } @@ -1902,7 +1924,9 @@ int myMessageCallbacklog(CPushConsumer* consumer, CMessageExt* msg) } //处理进程更新消息 - parse_log(body); + if(parse_log(body)){ + DIY_ERRORLOG("process","【ERROR】前置的%s%d号进程处理topic:%s_%s的日志上送消息失败,消息的json结构不正确",get_front_msg_from_subdir(), g_front_seg_index,FRONT_INST.c_str(),G_MQCONSUMER_TOPIC_LOG.c_str()); + } } @@ -1950,6 +1974,7 @@ int myMessageCallbackrecall(CPushConsumer* consumer, CMessageExt* msg) } else{ std::cerr << "recall data is NULL." << std::endl; + DIY_ERRORLOG("process","【ERROR】前置的%s%d号进程处理topic:%s_%s的补招触发消息失败,消息的json结构不正确",get_front_msg_from_subdir(), g_front_seg_index,FRONT_INST.c_str(),G_MQCONSUMER_TOPIC_RC.c_str()); } } diff --git a/mms/rdb_client.c b/mms/rdb_client.c index 76d7421..9a89cef 100644 --- a/mms/rdb_client.c +++ b/mms/rdb_client.c @@ -203,7 +203,7 @@ apr_status_t init_rdb() init_loggers(); rv = parse_model_cfg_web(); - if (rv != APR_SUCCESS) { + if (rv != APR_SUCCESS) {//不可能 echo_errg("Parsed model with error,try to run! \n"); //char buf[256]; diff --git a/mms/rdb_ext_utils.c b/mms/rdb_ext_utils.c index e2f8e82..6aaba44 100644 --- a/mms/rdb_ext_utils.c +++ b/mms/rdb_ext_utils.c @@ -14,6 +14,7 @@ #include "xmltools.h" #include "db_interface.h" #include "../cfg_parse/custom_printf.h"//lnk20250225 +#include "../log4cplus/log4.h"//lnk添加log4 //extern rdb_t* g_rdb ; extern node_t* g_node ; extern char g_my_conf_fname[256]; @@ -517,6 +518,12 @@ void processQVVR_end(LD_info_t* LD_info) ied_usr_t *ied_usr = GET_IEDEXT_ADDR(ied); int ret; + //监测点日志的key,lnk20250526 + char full_key_m_c[256]; // 分配足够空间 + char full_key_m_d[256]; // 分配足够空间 + snprintf(full_key_m_c, sizeof(full_key_m_c), "monitor.%s.COM", LD_info->mp_id); + snprintf(full_key_m_d, sizeof(full_key_m_d), "monitor.%s.DATA", LD_info->mp_id); + //监测点日志的key,lnk20250526 //////////////////////////////////////////////////////////////////////////////////////////////////////////// int find_paired = FALSE; @@ -584,6 +591,7 @@ void processQVVR_end(LD_info_t* LD_info) //long long end_tm = (long long)(LD_info->qvvr[LD_info->qvvr_idx].QVVR_PerTime*1000) + LD_info->qvvr[i].QVVR_time;//结束时间是持续时间加最初的触发时间，毫秒 long long end_tm = (long long)(LD_info->qvvr[LD_info->qvvr_idx].QVVR_PerTime/s_or_ms) + LD_info->qvvr[i].QVVR_time;//结束时间是持续时间加最初的触发时间，毫秒 + //调试用 printf("\n~~~~~~~now qvvr node type before record is %d~~~~~~~~~~ \n",LD_info->qvvr[LD_info->qvvr_idx].QVVR_type); printf("~~~~~~~now qvvr node QVVR_PerTime before record is %f~~~~~~~~~~ \n",LD_info->qvvr[LD_info->qvvr_idx].QVVR_PerTime); printf("~~~~~~~now qvvr node QVVR_Amg before record is %f~~~~~~~~~~ \n",LD_info->qvvr[LD_info->qvvr_idx].QVVR_Amg); @@ -600,6 +608,7 @@ void processQVVR_end(LD_info_t* LD_info) LD_info->qvvr[LD_info->qvvr_idx].used_status = QVVR_DATA_NOT_USED; //当前这个点位置释放 find_paired = TRUE; + //调试用 printf("~~~~~~~this qvvr node QVVR_PerTime after record is %f~~~~~~~~~~ \n",LD_info->qvvr[i].QVVR_PerTime); printf("~~~~~~~this qvvr node QVVR_Amg after record is %f~~~~~~~~~~ \n",LD_info->qvvr[i].QVVR_Amg); printf("~~~~~~~this qvvr node used_status after record is %d~~~~~~~~~~ \n",LD_info->qvvr[i].used_status); @@ -609,6 +618,9 @@ void processQVVR_end(LD_info_t* LD_info) printf("~~~~~~~this qvvr node QVVR_start before record is %d~~~~~~~~~~ \n",LD_info->qvvr[i].QVVR_start); //匹配后再发qvvr，起始时间要填暂态触发的时间，就是第一次事件上送时只有时间没有值的那个时间 + //mq日志 + DIY_WARNLOG(full_key_m_d,"【WARN】监测点%s - id:%s 发生暂态事件",LD_info->name,LD_info->mp_id); + ret = transfer_json_qvvr_data(g_node_id, //这个参数没有使用 LD_info->line_id, //监测点序号 (double)LD_info->qvvr[LD_info->qvvr_idx].QVVR_Amg,