2162 lines
85 KiB
C
2162 lines
85 KiB
C
/**
|
||
* @file: $RCSfile: mms_process.c,v $
|
||
* @brief: $PROFIBUS 与SSRTDB交互
|
||
*
|
||
* @version: $Revision: 1.28 $
|
||
* @date: $Date: 2022/11/28 07:13:13 $
|
||
* @author: $Author: lizhongming $
|
||
* @state: $State: Exp $
|
||
*
|
||
* @latest: $Id: mms_process.c,v 1.28 2022/11/28 07:13:13 lizhongming Exp $
|
||
*/
|
||
#include <string.h>
|
||
#include "rdb_client.h"
|
||
#include <stdlib.h>
|
||
#include "db_interface.h"
|
||
#include "node.h"
|
||
#include "ied.h"
|
||
#include "../json/mms_json_inter.h"
|
||
#include "../cfg_parse/custom_printf.h"//lnk20250225
|
||
|
||
#include "../log4cplus/log4.h"//lnk添加log4
|
||
|
||
void clear_rpt_counter_by_trigger(trigger_t *trigger);
|
||
|
||
//lnk20241031
|
||
extern void SOEFileWeb(char* localpath,char* cloudpath,char* wavepath);
|
||
//lnk 2024-11-4 添加时间转换函数
|
||
char* convertMsToDateTimeString(int64_t msTime);
|
||
//lnk20250115
|
||
extern pthread_mutex_t mtx;
|
||
extern apr_pool_t* g_cfg_pool;
|
||
extern apr_pool_t* g_init_pool;
|
||
|
||
extern int g_DevFlag; //日志配置中读取的参数，暂无特定使用lnk20250121
|
||
|
||
extern int IED_COUNT;
|
||
|
||
//lnk20250115end
|
||
|
||
#ifdef DEBUG_SISCO
|
||
SD_CONST static ST_CHAR *SD_CONST thisFileName = __FILE__;
|
||
#endif
|
||
|
||
#ifdef _OS_UNIX_
|
||
#include <sys/vfs.h>
|
||
#endif
|
||
extern uint32_t g_dead_lock_counter;
|
||
extern uint32_t g_thread_blocked_times;
|
||
|
||
extern uint16_t g_client_id;
|
||
|
||
extern RPT_TYPEIDS g_rpt_typeids;
|
||
//extern rdb_t *g_rdb ;
|
||
extern node_t *g_node ;
|
||
extern char g_my_conf_fname[256];
|
||
extern apr_pool_t *g_init_pool;
|
||
extern apr_pool_t *g_run_pool;
|
||
extern pt61850app_t *g_pt61850app;
|
||
//extern char *g_sysfile_filedir;
|
||
extern char g_onlyIP[255]; //直连某个IP，仅仅为方便测试
|
||
//extern int g_sysfile_appid; //add by rzx
|
||
//extern apr_time_t g_file_valid_time;
|
||
extern uint32_t g_min_free_size;
|
||
/////////////////////////////////////////////////////////////////
|
||
///////////////////////////////////////////////////////////////////////////////
|
||
extern uint32_t g_node_id;
|
||
|
||
extern int three_secs_enabled;
|
||
extern int auto_register_report_enabled;
|
||
extern int FRONT_MP_NUM;
|
||
///////////////////////////////////////////////////////////////////////////////
|
||
extern int FILE_FLAG;
|
||
|
||
extern int recall_len;
|
||
extern int recall_sta;
|
||
extern int recall_daily;
|
||
extern char* UDS_UPLOAD_URL;
|
||
|
||
///////////////////////////////////////////////////////////////////
|
||
//lnk20250122start
|
||
apr_status_t init_rem_dib_table()
|
||
{
|
||
int pos = 0;
|
||
int iedno,chnl_no;
|
||
ied_t *ied;
|
||
struct in_addr ip;
|
||
chnl_usr_t *chnl_usr;
|
||
|
||
if(IED_COUNT < g_pt61850app->chnl_counts){
|
||
set_rem_dib_table_size( g_pt61850app->chnl_counts );//按照最大的终端数来申请
|
||
g_pt61850app->chnl_usr = apr_pcalloc( g_init_pool,g_pt61850app->chnl_counts*sizeof(chnl_usr_t*) );
|
||
printf( "set_rem_dib_table_size %d \n",g_pt61850app->chnl_counts );
|
||
}
|
||
else{
|
||
set_rem_dib_table_size( IED_COUNT );//按照最大的终端数来申请
|
||
g_pt61850app->chnl_usr = apr_pcalloc( g_init_pool,IED_COUNT*sizeof(chnl_usr_t*) );
|
||
printf( "set_rem_dib_table_size %d \n",IED_COUNT );
|
||
}
|
||
|
||
for(iedno=0 ; iedno<g_node->n_clients; iedno++) {
|
||
ied = g_node->clients[iedno];
|
||
for(chnl_no=0 ; chnl_no<ied->chncount; chnl_no++) {
|
||
chnl_usr = ied->channel[chnl_no].connect;
|
||
g_pt61850app->chnl_usr[pos] = chnl_usr;
|
||
ip.s_addr = htonl(ied->channel[chnl_no].addr);
|
||
strcpy(chnl_usr->ip_str,inet_ntoa(ip));
|
||
printf( " add_rem_dib_table %s:%d \n",chnl_usr->ip_str ,ied->channel[chnl_no].port );
|
||
add_rem_dib_table (pos++,chnl_usr->ip_str,ied->channel[chnl_no].port );
|
||
{
|
||
char comm_str[256];
|
||
memset(comm_str,0,256);
|
||
apr_snprintf(comm_str,sizeof(comm_str),"%16s:%d\t\tinited",chnl_usr->ip_str,ied->channel[chnl_no].port);
|
||
add_comm_log(comm_str);
|
||
}
|
||
}
|
||
}
|
||
return APR_SUCCESS;
|
||
}
|
||
//lnk20250122end
|
||
|
||
void CloseIECReports(chnl_usr_t *chnl_usr)
|
||
{
|
||
ied_t *ied;
|
||
ied_usr_t *ied_usr;
|
||
LD_info_t *LD_info;
|
||
rptinfo_t *rptinfo = NULL;
|
||
int cpuno,rpt_no;
|
||
ST_RET ret;
|
||
|
||
ied = chnl_usr->chnl->ied;
|
||
ied_usr = GET_IEDEXT_ADDR(ied);
|
||
for(cpuno=0 ; cpuno<ied->cpucount; cpuno++) {
|
||
LD_info = &(ied_usr->LD_info[cpuno]);
|
||
for(rpt_no=0 ; rpt_no<LD_info->rptcount; rpt_no++) {
|
||
char rpt_inst_name[65];
|
||
rptinfo = LD_info->rptinfo[rpt_no];
|
||
if ( ! rptinfo->rpt_registered )
|
||
continue;
|
||
if ( rptinfo->chnl_id != chnl_usr->chnl_id)
|
||
continue;
|
||
|
||
rptinfo->rpt_registered = FALSE;
|
||
//注销报告后，取消10分钟 再注册一次的限制，可立即注册
|
||
rptinfo->m_LastRegisterFailedTime = sGetMsTime() -10*60*1000;
|
||
rptinfo->m_rcb_info = NULL;
|
||
}
|
||
}
|
||
}
|
||
|
||
void closeChannel(chnl_usr_t *chnl_usr)
|
||
{
|
||
|
||
//终端日志的key,lnk20250526
|
||
char full_key_t_c[256]; // 分配足够空间
|
||
char full_key_t_d[256]; // 分配足够空间
|
||
snprintf(full_key_t_c, sizeof(full_key_t_c), "terminal.%s.COM", ((ied_usr_t*)(chnl_usr->chnl->ied->usr_ext))->terminal_id);
|
||
snprintf(full_key_t_d, sizeof(full_key_t_d), "terminal.%s.DATA", ((ied_usr_t*)(chnl_usr->chnl->ied->usr_ext))->terminal_id);
|
||
//终端日志的key,lnk20250526
|
||
|
||
char comm_str[256];
|
||
memset(comm_str,0,256);
|
||
apr_snprintf(comm_str,sizeof(comm_str),"%16s:%d\t\tdisconnected !!!",chnl_usr->ip_str,chnl_usr->chnl->port);
|
||
add_comm_log(comm_str);
|
||
FRONT_MP_NUM--;
|
||
echo_warn1("Close Channel IP: %s",chnl_usr->ip_str );
|
||
|
||
CloseIECReports(chnl_usr);
|
||
echo_warn1("-------Close Channel IP: %s success!!!!!!!!!", chnl_usr->ip_str);
|
||
|
||
if (chnl_usr->net_info) {
|
||
ALL_RCB_INFO *all_rcb_info;
|
||
RCB_INFO *rcb_info;
|
||
ST_RET ret;
|
||
if(chnl_usr->net_info->user_info)
|
||
{
|
||
all_rcb_info = (ALL_RCB_INFO *)chnl_usr->net_info->user_info;
|
||
while((rcb_info = (RCB_INFO *)list_get_first(&all_rcb_info->rcb_info_list)) != NULL)
|
||
rcb_info_destroy (rcb_info);
|
||
chk_free(all_rcb_info);
|
||
chnl_usr->net_info->user_info=NULL;
|
||
}
|
||
chnl_usr->net_info->rem_vmd = NULL;
|
||
echo_warn("---------start disconnectFromServer!\n");
|
||
ret = mms_disconnectFromServer(chnl_usr->net_info,&chnl_usr->m_reqCtrl);
|
||
echo_warn("---------end disconnectFromServer!\n");
|
||
|
||
DIY_WARNLOG(full_key_t_c,"【WARN】前置与终端%s - ip端口%s:%d 断开连接", ((ied_usr_t*)(chnl_usr->chnl->ied->usr_ext))->terminal_id,chnl_usr->ip_str,chnl_usr->chnl->port);
|
||
|
||
if (ret != SD_SUCCESS){
|
||
echo_warn("---------disconnectFromServer success!\n");
|
||
|
||
echo_warn2( "CHANNEL %s,NetInfo= %x mms_disconnectFromServer failed ,Disconnect it roughly! \n",chnl_usr->ip_str,chnl_usr->net_info);
|
||
|
||
mvl_free_req_ctrl(chnl_usr->m_reqCtrl);
|
||
|
||
chnl_usr->net_info->user_ext = NULL;
|
||
chnl_usr->net_info = NULL;
|
||
|
||
|
||
chnl_usr->m_reqCtrl = NULL;
|
||
chnl_usr->net_info = NULL;
|
||
chnl_usr->m_state = CHANNEL_DISCONNECTED;
|
||
chnl_usr->m_ClosedMsTime = sGetMsTime();
|
||
|
||
chnl_usr->chnl->status = STATUS_BREAKOFF;
|
||
}
|
||
else{
|
||
chnl_usr->m_state = CHANNEL_DISCONNECTING;
|
||
chnl_usr->m_StartDisconnectingTime = sGetMsTime();
|
||
}
|
||
}else {
|
||
chnl_usr->m_state = CHANNEL_DISCONNECTED;
|
||
chnl_usr->m_ClosedMsTime = sGetMsTime();
|
||
|
||
chnl_usr->chnl->status = STATUS_BREAKOFF;
|
||
}
|
||
}
|
||
|
||
ST_VOID Callback_channel_disconnect_ind(MVL_NET_INFO * NetInfo, ST_INT discType)
|
||
{
|
||
chnl_usr_t *chnl_usr;
|
||
|
||
chnl_usr = (chnl_usr_t*)NetInfo->user_ext;
|
||
|
||
if ( chnl_usr ) {
|
||
if(chnl_usr->m_state == CHANNEL_CONNECTING)
|
||
{ //do nothing;
|
||
printf("Do nothing,m_state == CHANNEL_CONNECTING ,NetInfo = %x",NetInfo);
|
||
}else if ( chnl_usr->m_state == CHANNEL_CONNECTED )
|
||
{
|
||
closeChannel(chnl_usr);
|
||
}else if ( chnl_usr->m_state == CHANNEL_DISCONNECTING )
|
||
{ //do nothing;
|
||
printf("Do nothing,m_state == CHANNEL_DISCONNECTING ,NetInfo = %x",NetInfo);
|
||
}else if ( chnl_usr->m_state == CHANNEL_DISCONNECTED )
|
||
{ //do nothing;
|
||
printf("Do nothing,m_state == CHANNEL_DISCONNECTED ,NetInfo = %x",NetInfo);
|
||
}
|
||
|
||
|
||
chnl_usr->net_info = NULL;
|
||
NetInfo->user_ext = NULL;
|
||
|
||
}
|
||
printf(" Callback_channel_disconnect_ind ,NetInfo = %x",NetInfo);
|
||
|
||
//zw修改 2023 - 8 - 17 通讯中断回调函数 PG库记录当日中断次数
|
||
ied_usr_t* ied_usr = (ied_usr_t*)(chnl_usr->chnl[0].ied->usr_ext);
|
||
}
|
||
|
||
|
||
void IECReport_tryGI(chnl_usr_t *chnl_usr,rptinfo_t *rptinfo)
|
||
{
|
||
char varName[64] = "";
|
||
ST_BOOLEAN GI = TRUE; /* call GI */
|
||
|
||
if ( (sGetMsTime() -rptinfo->m_LastGITime) < g_pt61850app->giTime*1000 )
|
||
return;
|
||
rptinfo->m_LastGITime = sGetMsTime();
|
||
get_rpt_inst_name(rptinfo,varName);
|
||
strcat(varName, "$GI");
|
||
mms_named_var_write (chnl_usr->net_info, varName, DOM_SPEC, rptinfo->LD_info->LD_name,
|
||
g_rpt_typeids.mmsbool, (ST_CHAR *) &GI, g_pt61850app->mmsOpTimeout);
|
||
}
|
||
|
||
//增加处理根据稳态，或暂态功能等，决定 报告是否需要注册、取消注册或 不做任何处理
|
||
int judge_rpt_next_should_do(rptinfo_t *rptinfo)
|
||
{
|
||
int should_register_state = 1; //各功能默认注册
|
||
int is_real_report = (rptinfo->report_PQ_type & REPORT_TYPE_REAL);//报告控制中包含的类型
|
||
int is_soe_report = (rptinfo->report_PQ_type & REPORT_TYPE_SOE);
|
||
|
||
if (three_secs_enabled) {
|
||
should_register_state = 0; //3秒功能模块，默认不注册
|
||
if (is_real_report) {//映射中包含控制块且触发
|
||
should_register_state = rptinfo->LD_info->real_data;
|
||
}
|
||
if (is_soe_report) {
|
||
should_register_state = rptinfo->LD_info->soe_data;
|
||
}
|
||
}
|
||
|
||
if (should_register_state==rptinfo->rpt_registered)//已经触发/没有触发，没有变动
|
||
return SHOULD_DO_NOTHING;
|
||
else if (should_register_state)//有变动且要触发
|
||
return SHOULD_REGISTER;
|
||
else
|
||
return SHOULD_UNREGISTER;//有变动，不触发
|
||
}
|
||
|
||
void ChannelCheckIECReports(chnl_usr_t *chnl_usr)
|
||
{
|
||
ied_t *ied;
|
||
ied_usr_t *ied_usr;
|
||
LD_info_t *LD_info;
|
||
rptinfo_t *rptinfo = NULL;
|
||
channel_t *channel = NULL;
|
||
int cpuno,rpt_no;
|
||
char rpt_inst_name[65];
|
||
ST_RET ret;
|
||
|
||
ied = chnl_usr->chnl->ied;
|
||
ied_usr = GET_IEDEXT_ADDR(ied);
|
||
channel = chnl_usr->chnl;
|
||
|
||
for(cpuno=0 ; cpuno<ied->cpucount; cpuno++)
|
||
|
||
{
|
||
LD_info = &(ied_usr->LD_info[cpuno]); //遍历监测点
|
||
|
||
if (LD_info->cpuno==0)
|
||
continue;
|
||
|
||
for(rpt_no=0 ; rpt_no<LD_info->rptcount; rpt_no++) { //遍历报告（映射文件中读取的报告控制）
|
||
|
||
//监测点日志的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
|
||
|
||
rptinfo = LD_info->rptinfo[rpt_no] ;
|
||
|
||
if (judge_rpt_next_should_do(rptinfo)==SHOULD_DO_NOTHING)//检查是否触发
|
||
{
|
||
//DIY_DEBUGLOG(full_key_m_c,"【DEBUG】监测点:%s - id:%s不注册报告", LD_info->name,LD_info->mp_id);
|
||
continue;
|
||
}
|
||
|
||
if(rptinfo->m_curRptSuffix==-1)
|
||
rptinfo->m_curRptSuffix = g_pt61850app->rptSuffix[g_client_id][0] ;
|
||
|
||
get_rpt_inst_name(rptinfo,rpt_inst_name);//获取报告名
|
||
|
||
if ( ! rptinfo->rpt_registered ) {
|
||
if ( (sGetMsTime() -rptinfo->m_LastRegisterFailedTime) > 20*1000 ) {
|
||
//注册失败后间隔 20秒 再注册一次
|
||
RCB_INFO *rcb_info;
|
||
printf("start mms_register_iec_rpt................................\n");
|
||
|
||
//mq日志
|
||
DIY_INFOLOG(full_key_m_c,"【NORMAL】监测点:%s - id:%s开始注册报告,报告名:%s", LD_info->name,LD_info->mp_id,rpt_inst_name);
|
||
|
||
if ( strstr(rptinfo->rptID,"LLN0$BR$brcbFlickerData") )
|
||
rptinfo->IntgPd = 600; //10分钟
|
||
|
||
/////////////////////////WW 2023-08-30 增加设备类型与报告绑定
|
||
rcb_info = mms_register_iec_rpt (chnl_usr->net_info, &g_rpt_typeids,
|
||
LD_info->LD_name,rpt_inst_name,g_pt61850app->mmsOpTimeout, rptinfo->IntgPd,rptinfo->TrgOpt,
|
||
(ST_UINT8*)rptinfo->m_EntryID ,(ST_UINT8*)rptinfo->OptFlds);
|
||
//WW end
|
||
///////////////////////////
|
||
if( !rcb_info )
|
||
{
|
||
if ( ++rptinfo->m_curRptSuffix > g_pt61850app->rptSuffix[g_client_id][1] )
|
||
rptinfo->m_curRptSuffix = g_pt61850app->rptSuffix[g_client_id][0] ;
|
||
|
||
rptinfo->m_LastRegisterFailedTime = sGetMsTime() ;
|
||
|
||
echo_err9("\n注册报告失败！Rregister iec_rpt failed !!! IED_ID=%d ,CPU=%d , domain: %s ,rpt_inst_name: %s ,ip: %s:%d,chnl_id: %d ,IntgPd=%d ,TrgOpt=0x%x \n",
|
||
APR_EGENERAL, LD_info->ied->id,LD_info->cpuno,LD_info->LD_name,rpt_inst_name,chnl_usr->ip_str,chnl_usr->chnl->port,
|
||
chnl_usr->chnl_id, rptinfo->IntgPd,rptinfo->TrgOpt );
|
||
|
||
//mq日志
|
||
DIY_WARNLOG(full_key_m_c,"【WARN】监测点:%s - id:%s注册报告失败,报告名:%s", LD_info->name,LD_info->mp_id,rpt_inst_name);
|
||
|
||
}
|
||
else
|
||
{
|
||
|
||
double GIoffset;
|
||
rptinfo->rpt_registered = TRUE;
|
||
rptinfo->m_rcb_info = rcb_info;
|
||
rptinfo->chnl_id = chnl_usr->chnl_id;
|
||
chnl_usr->m_NegRespTimes = 0;
|
||
chnl_usr->m_LastPosRespTime = sGetMsTime();
|
||
|
||
echo_msg11("\nRegister iec_rpt succeed, IED_ID=%d ,CPU=%d ,domain: %s ,rpt_inst_name: %s ,ip: %s:%d,chnl_id: %d ,IntgPd=%d ,TrgOpt=0x%x ,OptFlds=0x%x%x \n",
|
||
LD_info->ied->id,LD_info->cpuno,LD_info->LD_name,rpt_inst_name,chnl_usr->ip_str,chnl_usr->chnl->port,chnl_usr->chnl_id,
|
||
rptinfo->IntgPd,rptinfo->TrgOpt,rptinfo->OptFlds[0],rptinfo->OptFlds[1] );
|
||
|
||
//mq日志
|
||
DIY_WARNLOG(full_key_m_c,"【WARN】监测点:%s - id:%s注册报告成功,报告名:%s", LD_info->name,LD_info->mp_id,rpt_inst_name);
|
||
|
||
// add here to GI not the same time
|
||
GIoffset = 0.5 * g_pt61850app->giTime;
|
||
rptinfo->m_LastGITime = sGetMsTime() - GIoffset*1000;
|
||
}
|
||
printf("end mms_register_iec_rpt................................\n");
|
||
//mq日志
|
||
DIY_INFOLOG(full_key_m_c,"【NORMAL】监测点:%s - id:%s注册报告结束,报告名:%s", LD_info->name,LD_info->mp_id,rpt_inst_name);
|
||
}
|
||
}
|
||
else { //rpt_registered ==TRUE
|
||
if ( (sGetMsTime() -rptinfo->m_LastUnRegisterFailedTime) > 20*1000 ) {
|
||
//取消注册失败后间隔 20秒 再取消注册一次
|
||
printf("start mms_unregister_iec_rpt................................\n");
|
||
|
||
//mq日志
|
||
DIY_INFOLOG(full_key_m_c,"【NORMAL】监测点:%s - id:%s开始注销报告,报告名:%s", LD_info->name,LD_info->mp_id,rpt_inst_name);
|
||
|
||
ret = mms_unregister_iec_rpt (chnl_usr->net_info, &g_rpt_typeids,
|
||
LD_info->LD_name,rpt_inst_name,g_pt61850app->mmsOpTimeout);
|
||
|
||
if( ret == SD_FAILURE ) {
|
||
rptinfo->m_LastUnRegisterFailedTime = sGetMsTime() ;
|
||
echo_err6("\n取消注册报告失败！UnRregister iec_rpt failed !!! IED_ID=%d ,CPU=%d , domain: %s ,rpt_inst_name: %s ,ip: %s,chnl_id: %d \n",
|
||
APR_EGENERAL, LD_info->ied->id,LD_info->cpuno,LD_info->LD_name,rpt_inst_name,chnl_usr->ip_str,chnl_usr->chnl_id);
|
||
|
||
//mq日志
|
||
DIY_WARNLOG(full_key_m_c,"【WARN】监测点:%s - id:%s注销报告失败,报告名:%s", LD_info->name,LD_info->mp_id,rpt_inst_name);
|
||
|
||
}
|
||
else {
|
||
rptinfo->rpt_registered = FALSE;
|
||
echo_msg7("\nUnRegister iec_rpt succeed, IED_ID=%d ,CPU=%d ,domain: %s ,rpt_inst_name: %s ,ip: %s:%d,chnl_id: %d \n",
|
||
LD_info->ied->id,LD_info->cpuno,LD_info->LD_name,rpt_inst_name,chnl_usr->ip_str,chnl_usr->chnl->port,chnl_usr->chnl_id );
|
||
|
||
//mq日志
|
||
DIY_INFOLOG(full_key_m_c,"【NORMAL】监测点:%s - id:%s注销报告成功,报告名:%s", LD_info->name,LD_info->mp_id,rpt_inst_name);
|
||
}
|
||
printf("end mms_unregister_iec_rpt................................\n");
|
||
//mq日志
|
||
DIY_INFOLOG(full_key_m_c,"【NORMAL】监测点:%s - id:%s注销报告结束,报告名:%s", LD_info->name,LD_info->mp_id,rpt_inst_name);
|
||
}
|
||
|
||
}
|
||
}
|
||
}
|
||
}
|
||
|
||
void ChannelCheckWaveFiles(chnl_usr_t *chnl_usr)
|
||
{
|
||
ied_t *ied;
|
||
ied_usr_t *ied_usr;
|
||
LD_info_t *LD_info;
|
||
int cpuno;
|
||
|
||
ied = chnl_usr->chnl->ied;
|
||
ied_usr = GET_IEDEXT_ADDR(ied);
|
||
for(cpuno=0 ; cpuno<ied->cpucount; cpuno++) {
|
||
LD_info = &(ied_usr->LD_info[cpuno]);
|
||
if (LD_info->line_id<=0) {
|
||
continue;
|
||
}
|
||
call_cn_wavelist(LD_info); //try to call wave file
|
||
}
|
||
}
|
||
|
||
void ChannelCheckIECLogs(chnl_usr_t *chnl_usr)
|
||
{
|
||
ST_RET ret;
|
||
ied_t *ied;
|
||
ied_usr_t *ied_usr;
|
||
LD_info_t *LD_info;
|
||
loginfo_t *loginfo = NULL;
|
||
int cpuno;
|
||
|
||
double now;
|
||
static double last_check_recall_config_time = 0.0;
|
||
|
||
ied = chnl_usr->chnl->ied;
|
||
ied_usr = GET_IEDEXT_ADDR(ied);
|
||
|
||
for(cpuno=0 ; cpuno<ied->cpucount; cpuno++) {
|
||
LD_info = &(ied_usr->LD_info[cpuno]);
|
||
|
||
if (LD_info->logcount<=0)
|
||
continue;
|
||
loginfo = LD_info->loginfo[0] ;
|
||
|
||
apr_sleep(apr_time_from_sec(1) / 10);
|
||
|
||
//监测点日志的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
|
||
|
||
Check_Recall_Config(LD_info->mp_id);//尝试获取xml结构
|
||
|
||
//补招数量不为0且不是正在补招
|
||
if (LD_info->autorecallcount != 0 && LD_info->autorecallflag != 1) {
|
||
int i;
|
||
int failed_count = 0;
|
||
|
||
/////////////////////////////////////////////////////根据配置文件控制下发补招时间为北京时间还是utc时间
|
||
printf("~~~~~~~this dev type is %s~~~~~~~",ied_usr->dev_type);
|
||
XmlConfigC cfg1;
|
||
if (get_xml_config_by_dev_type(ied_usr->dev_type, &cfg1)) {
|
||
printf("ValueOfTimeUnit = %s\n", cfg1.ValueOfTimeUnit);
|
||
} else {
|
||
printf("读取失败，未找到 dev_type\n");
|
||
}
|
||
long long utc_or_beijing;
|
||
|
||
if(strcmp(cfg1.ValueOfTimeUnit, "utc") == 0){//装置时间是utc还是北京
|
||
utc_or_beijing = 28800000;
|
||
DIY_WARNLOG(full_key_m_c,"【WARN】监测点:%s - id:%s开始补招数据,下发补招时间为utc时间,监测点对应装置型号:%s", LD_info->name,LD_info->mp_id,ied_usr->dev_type);
|
||
}
|
||
else{
|
||
utc_or_beijing = 0;
|
||
DIY_WARNLOG(full_key_m_c,"【WARN】监测点:%s - id:%s开始补招数据,下发补招时间为beijing时间,监测点对应装置型号:%s", LD_info->name,LD_info->mp_id,ied_usr->dev_type);
|
||
}
|
||
|
||
//////////////////////////////////////////////////////////////
|
||
|
||
for (i = 0; i < LD_info->autorecallcount; i++) {
|
||
|
||
LD_info->autorecallflag = 1;//正在补招
|
||
|
||
//当前不区分稳态和暂态lnk20241030，如果做区分修改：Check_Recall_Config从xml文件获取数据后，赋值给了LD_info
|
||
loginfo->need_steady = LD_info->autorecall[i]->need_steady; loginfo->need_voltage = LD_info->autorecall[i]->need_voltage;
|
||
|
||
loginfo->start_time = apr_time_from_sec(LD_info->autorecall[i]->start - 5);
|
||
loginfo->end_time = apr_time_from_sec(LD_info->autorecall[i]->end - 5);
|
||
|
||
/////////////////////////////////////////////////////根据配置文件控制下发补招时间为北京时间还是utc时间,上送的数据61850库会转换成北京时间？
|
||
loginfo->start_time = loginfo->end_time - utc_or_beijing;//下发utc时间需要减去8小时
|
||
loginfo->end_time = loginfo->end_time - utc_or_beijing;
|
||
/////////////////////////////////////////////////////
|
||
|
||
if (loginfo->need_steady == 0 && loginfo->need_voltage == 0)
|
||
continue;
|
||
if (loginfo->end_time <= loginfo->start_time)
|
||
continue;
|
||
|
||
printf("start mms_jread................................\n");
|
||
|
||
echo_msg6("\n mms_jread IED_ID=%d ,CPU=%d ,domain: %s ,logName: %s ,ip: %s,chnl_id: %d \n",
|
||
LD_info->ied->id, LD_info->cpuno, LD_info->LD_name, loginfo->logName, chnl_usr->ip_str, chnl_usr->chnl_id);
|
||
|
||
//mq日志
|
||
//DIY_WARNLOG(full_key_m_c,"【WARN】监测点:%s - id:%s开始补招数据", LD_info->name,LD_info->mp_id);
|
||
|
||
ret = mms_jread(loginfo, chnl_usr->net_info, loginfo->LD_info->LD_name, loginfo->logName,
|
||
loginfo->start_time, loginfo->end_time, g_pt61850app->mmsOpTimeout, chnl_usr->ip_str);
|
||
if (ret != SD_SUCCESS) {
|
||
echo_warn6("\n mms_jread Failed! IED_ID=%d ,CPU=%d ,domain: %s ,logName: %s ,ip: %s,chnl_id: %d \n",
|
||
LD_info->ied->id, LD_info->cpuno, LD_info->LD_name, loginfo->logName, chnl_usr->ip_str, chnl_usr->chnl_id);
|
||
|
||
//mq日志
|
||
DIY_ERRORLOG(full_key_m_c,"【ERROR】监测点:%s - id:%s补招数据失败 - 失败时间点:%lld 至 %lld", LD_info->name,LD_info->mp_id,loginfo->start_time,loginfo->end_time);
|
||
|
||
failed_count++;
|
||
}
|
||
|
||
del_mvl_type_ctrl();
|
||
|
||
loginfo->need_steady = 0;
|
||
loginfo->need_voltage = 0;
|
||
loginfo->start_time = loginfo->end_time;
|
||
|
||
g_dead_lock_counter = 0;
|
||
g_thread_blocked_times = 0; //防止补招时间过长导致进程退出
|
||
|
||
now = sGetMsTime();
|
||
last_check_recall_config_time = now;
|
||
printf("end ==============%.2f================\n", last_check_recall_config_time);
|
||
printf("end mms_jread................................\n");
|
||
}
|
||
|
||
//不管是否成功，这个补招文件必须删除，可能出现一直失败，循环读取文件和循环补招导致程序崩溃202050724lnk
|
||
//if (failed_count==0) {//成功
|
||
Delete_recall_Xml(LD_info->mp_id);
|
||
DIY_WARNLOG(full_key_m_c,"【WARN】监测点:%s - id:%s结束补招数据", LD_info->name,LD_info->mp_id);
|
||
//}
|
||
}
|
||
|
||
}
|
||
}
|
||
|
||
|
||
void process_3s_config(trigger_3s_xml_t *trigger_3s_xml)
|
||
{
|
||
int i,j;
|
||
trigger_t *trigger;
|
||
trigger_t *trigger_work;
|
||
int trigger_num;
|
||
ied_t *ied;
|
||
LD_info_t *LD_info;
|
||
|
||
int need_write_file;
|
||
int new_in_work_found;
|
||
|
||
printf("start process_3s_config\n");
|
||
|
||
need_write_file = FALSE;
|
||
trigger = trigger_3s_xml->new_triggers; //3s配置文件中的newtrigger数组，如果没有newtrigger这里就是0
|
||
trigger_num = trigger_3s_xml->new_trigger_num;
|
||
for (i=0; i<trigger_num; i++){
|
||
new_in_work_found = FALSE;
|
||
for (j=0; j<trigger_3s_xml->work_trigger_num; j++){
|
||
trigger_work = &trigger_3s_xml->work_triggers[j];
|
||
if (trigger_work->dev_idx==trigger[i].dev_idx && trigger_work->line_id==trigger[i].line_id ) {
|
||
|
||
if (trigger[i].real_data>=0)
|
||
trigger_work->real_data = trigger[i].real_data;//更新rtdata标志
|
||
if (trigger[i].soe_data>=0)
|
||
trigger_work->soe_data = trigger[i].soe_data; //更新soe标志
|
||
trigger_work->limit = trigger[i].limit;
|
||
|
||
clear_rpt_counter_by_trigger(trigger_work);//清理报告
|
||
new_in_work_found = TRUE;
|
||
}
|
||
}
|
||
if (!new_in_work_found) { //newtrigger为0，这是全新的触发，不是正在工作的触发
|
||
clear_rpt_counter_by_trigger(&trigger[i]);
|
||
if (trigger[i].real_data<0)
|
||
trigger[i].real_data = 0;
|
||
if (trigger[i].soe_data<0)
|
||
trigger[i].soe_data = 0;
|
||
trigger_3s_xml->work_triggers[trigger_3s_xml->work_trigger_num++] = trigger[i];
|
||
}
|
||
need_write_file = TRUE;//需要将新增的点写到文件中
|
||
}
|
||
|
||
trigger = trigger_3s_xml->delete_triggers; //如果没有deletetrigger这里就是0
|
||
trigger_num = trigger_3s_xml->delete_trigger_num;
|
||
for (i=0; i<trigger_num; i++){
|
||
for (j=0; j<trigger_3s_xml->work_trigger_num; j++){
|
||
trigger_work = &trigger_3s_xml->work_triggers[j];
|
||
if (trigger_work->dev_idx==trigger[i].dev_idx && trigger_work->line_id==trigger[i].line_id ) {
|
||
clear_rpt_counter_by_trigger(trigger_work);
|
||
trigger_work->dev_idx = INVALID_DEV_IDX;
|
||
}
|
||
}
|
||
need_write_file = TRUE;
|
||
}
|
||
|
||
trigger = trigger_3s_xml->modify_triggers; //如果没有modifytrigger这里就是0
|
||
trigger_num = trigger_3s_xml->modify_trigger_num;
|
||
for (i=0; i<trigger_num; i++){
|
||
for (j=0; j<trigger_3s_xml->work_trigger_num; j++){
|
||
trigger_work = &trigger_3s_xml->work_triggers[j];
|
||
if (trigger_work->dev_idx==trigger[i].dev_idx && trigger_work->line_id==trigger[i].line_id ) {
|
||
*trigger_work = trigger[i];
|
||
clear_rpt_counter_by_trigger(trigger_work);
|
||
}
|
||
}
|
||
need_write_file = TRUE;
|
||
}
|
||
|
||
clear_all_LD_real_soe_report_shoud_register(); //清空所有需要注册的报告，根据实时配置文件来。这里使LD_info->real_data = 0;LD_info->soe_data = 0;就不会触发报告
|
||
|
||
trigger = trigger_3s_xml->work_triggers; //文件的work块
|
||
trigger_num = trigger_3s_xml->work_trigger_num;
|
||
|
||
for (i=0; i<trigger_num; i++){ //遍历work块中所有触发点
|
||
int real_report_count = 0; //实时报告数量
|
||
|
||
if (trigger[i].dev_idx==INVALID_DEV_IDX){//跳过错误的终端号
|
||
printf("dev_idx incaild\n");
|
||
continue;
|
||
}
|
||
|
||
ied = find_ied_from_dev_idx(trigger[i].dev_idx); //通过文件中的dev号找到配置的设备，找不到说明不在这个进程里跳过（多进程的实现是否有必要？如果要实现就得每个进程一个操作目录）
|
||
if (!ied){
|
||
printf("can't find ied by dev_idx\n");
|
||
continue;
|
||
}
|
||
|
||
LD_info = find_LD_info_from_line_id(ied,trigger[i].line_id); //用文件中的检测点号找到配置的监测点
|
||
if (!LD_info){
|
||
printf("can't find line by line_idx\n");
|
||
continue;
|
||
}
|
||
|
||
real_report_count = get_real_report_count(LD_info); //获取监测点的实时报告数量LD_info->rptinfo[rpt_no]->count
|
||
|
||
//调试用
|
||
printf("terminal:%s - mp:%s real_report_count %d\n", ((ied_usr_t*)(ied->usr_ext))->terminal_id, LD_info->mp_id, real_report_count);
|
||
|
||
trigger[i].count = real_report_count; //记录此时这个监测点的实时报告数量
|
||
if (trigger[i].real_data && trigger[i].limit && (real_report_count>trigger[i].limit) ) {//监测点的实时报告数量大于当前文件中的限制，这个监测点的数据清零不再触发
|
||
trigger[i].real_data = 0;
|
||
trigger[i].limit = 0;
|
||
trigger[i].count = 0;
|
||
need_write_file = TRUE;
|
||
}
|
||
LD_info->real_data = trigger[i].real_data; //根据文件中的配置来设置，然后在报告触发中触发实时报告
|
||
LD_info->soe_data = trigger[i].soe_data;
|
||
LD_info->limit = trigger[i].limit;
|
||
LD_info->count = trigger[i].count;
|
||
if (LD_info->limit > 0) //限制数更新记录
|
||
need_write_file = TRUE;
|
||
if ( trigger[i].real_data==0 && trigger[i].soe_data==0 )//不触发条件记录
|
||
need_write_file = TRUE;
|
||
}
|
||
|
||
if (need_write_file)
|
||
create_3s_xml(trigger_3s_xml); //写入文件的work块
|
||
}
|
||
|
||
void del_process_recall_config(recall_xml_t* recall_xml)
|
||
{
|
||
int i,j;
|
||
recall_t *recall;
|
||
recall_t *recall_work;
|
||
int recall_num;
|
||
ied_t *ied;
|
||
LD_info_t *LD_info;
|
||
loginfo_t *loginfo = NULL;
|
||
int need_write_file;
|
||
|
||
need_write_file = FALSE;
|
||
recall = recall_xml->new_recalls;
|
||
recall_num = recall_xml->new_recall_num;
|
||
for (i=0; i<recall_num; i++){
|
||
recall_xml->work_recalls[recall_xml->work_recall_num++] = recall[i];
|
||
need_write_file = TRUE;
|
||
}
|
||
|
||
recall = recall_xml->work_recalls;
|
||
recall_num = recall_xml->work_recall_num;
|
||
for (i=0; i<recall_num; i++){
|
||
LD_info = find_LD_info_only_from_line_id(recall[i].line_id);
|
||
if (!LD_info)
|
||
continue;
|
||
if (LD_info->logcount<=0)
|
||
continue;
|
||
loginfo = LD_info->loginfo[0] ;
|
||
|
||
loginfo->need_steady = recall[i].need_steady;
|
||
loginfo->need_voltage = recall[i].need_voltage;
|
||
|
||
loginfo->start_time = recall[i].start_time;
|
||
loginfo->end_time = recall[i].end_time;
|
||
|
||
}
|
||
|
||
}
|
||
|
||
void check_3s_config()
|
||
{
|
||
double now;
|
||
static double last_check_3s_config_time = 0.0;//初始化时间
|
||
trigger_3s_xml_t trigger_3s_xml; //3s触发文件
|
||
|
||
if (!three_secs_enabled) //cfg_3s_data进程才会开启
|
||
return;
|
||
now = sGetMsTime(); //当前时间
|
||
if ( fabs(now - last_check_3s_config_time) < 3*1000 ) //wait 3secs //当前进程任务执行时查看当前时间和上次执行时间间隔，小于3秒不执行，大于等于3秒往下执行
|
||
return;
|
||
|
||
//调试用
|
||
//printf("begin 3s config...\n");
|
||
|
||
last_check_3s_config_time = now; //记录本次运行时间
|
||
while (APR_SUCCESS==parse_3s_xml(&trigger_3s_xml)){ //处理3秒文件，一次处理一个
|
||
//处理实时触发加台账锁lnk20250114
|
||
//pthread_mutex_lock(&mtx); printf("3s hold lock !!!!!!!!!!!");
|
||
process_3s_config(&trigger_3s_xml); //根据文件处理数据
|
||
//pthread_mutex_unlock(&mtx); printf("3s free lock !!!!!!!!!!!");
|
||
}
|
||
}
|
||
////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////
|
||
//lnk20250114参照实时数据方法处理台账信息
|
||
int isValidModelId(const char* model_id) {
|
||
size_t i;
|
||
|
||
if (model_id == NULL)
|
||
{
|
||
printf("!!!model_id null!!!\n");
|
||
return 0;
|
||
} // NULL 无效
|
||
|
||
size_t len = strlen(model_id);
|
||
if (len < 4) {
|
||
printf("!!!model_id length < 4!!!\n");
|
||
return 0; // 长度 < 4 无效
|
||
}
|
||
|
||
// 检查是否全是空格
|
||
for (i = 0; i < len; i++) {
|
||
if (!isspace((unsigned char)model_id[i])) {
|
||
return 1; // 只要包含非空格字符，就是合法的
|
||
}
|
||
}
|
||
printf("!!!model_id only space!!!\n");
|
||
return 0; // 仅包含空格，无效
|
||
}
|
||
|
||
void process_ledger_update(trigger_update_xml_t *ledger_update_xml)
|
||
{
|
||
int i,j;
|
||
terminal *update;
|
||
terminal *update_work;
|
||
int update_num;
|
||
ied_t *ied;
|
||
LD_info_t *LD_info;
|
||
int new_in_work_found;
|
||
|
||
ied_usr_t* ied_usr;
|
||
int chnl_no;
|
||
chnl_usr_t *chnl_usr = NULL;
|
||
|
||
printf("!!!start update ledger!!!\n");
|
||
|
||
update = ledger_update_xml->new_updates; //处理新增台账部分
|
||
update_num = ledger_update_xml->new_update_num;
|
||
printf("add ledger num:%d\n",update_num);
|
||
for (i=0; i<update_num; i++){ //查看所有需要新增的台账
|
||
new_in_work_found = FALSE;
|
||
if(update[i].terminal_id != NULL){
|
||
printf("add ledger of %s\n",update[i].terminal_id);
|
||
ied = find_ied_from_terminal_id(update[i].terminal_id); //通过文件中的终端号找到配置的设备
|
||
if (ied){
|
||
printf("find ied by terminal_id, terminal already exsist\n");
|
||
new_in_work_found = TRUE; //当前运行的台账中找到已有台账，变为更新
|
||
|
||
// 将当前终端从 new_updates 数组中移到 modify_updates 数组
|
||
if (ledger_update_xml->modify_update_num < MAX_UPDATEA_NUM) {
|
||
// 添加到 modify_updates 数组
|
||
ledger_update_xml->modify_updates[ledger_update_xml->modify_update_num] = update[i];
|
||
ledger_update_xml->modify_update_num++; // 更新 modify 数组的计数器
|
||
|
||
// 删除该终端（从 new_updates 数组中移除）
|
||
for (j = i; j < ledger_update_xml->new_update_num - 1; j++) {
|
||
ledger_update_xml->new_updates[j] = ledger_update_xml->new_updates[j + 1]; // 向前移动元素
|
||
}
|
||
|
||
ledger_update_xml->new_update_num--; // 更新 new_update_num，减少一个元素
|
||
continue;
|
||
} else {
|
||
fprintf(stderr, "Exceeded MAX_UPDATEA_NUM limit for modify_updates!\n");
|
||
}
|
||
}
|
||
}
|
||
|
||
if (!new_in_work_found) { //这是全新的台账，在台账数组中没有包含这个设备
|
||
|
||
int terminal_index;
|
||
int ied_take = 0; //当前台账数组里有不使用的ied空间？0没有，1有
|
||
//进行台账添加和初始化操作
|
||
//1-申请新的内存空间//////////////////////////////
|
||
//新的台账数量 (n_clients) 和原有的台账数量 (原数量为 g_node->n_clients)
|
||
int new_client_count = g_node->n_clients + 1; // 增加一个新的台账
|
||
|
||
//判断新增进程后是否超过原有的台账数组，如果超过了就从不使能的ied空间中找可用空间，如果还是没有那就提示不能荷载更多终端
|
||
if(new_client_count > IED_COUNT){ //不更新台账数量
|
||
ied_t *ied_unused = NULL;
|
||
ied_usr_t* ied_usr_unused = NULL;
|
||
ied_unused = find_ied_unused();//遍历g_node找到第一个不使用的ied，这个ied之前初始化时分配过空间，直接占用
|
||
if(ied_unused != NULL){
|
||
ied_usr_unused = (ied_usr_t*)ied_unused->usr_ext;
|
||
ied = ied_unused; //新增的ied指向已有的未使用的ied空间
|
||
terminal_index = ied_usr_unused->dev_idx; //记录这个ied的编号，即g_node的下标
|
||
|
||
//打印提示
|
||
printf("!!!!!!!!ied index:%d ,origin terminal_id:%s has been taken!!!!!!!!!!\n",ied_usr_unused->dev_idx,ied_usr_unused->terminal_id);
|
||
|
||
//终端初始化，不需要再申请空间
|
||
ied_usr = (ied_usr_t*)ied->usr_ext;
|
||
ied_usr->last_call_wavelist_time = sGetMsTime() + g_pt61850app->giTime * 1000;
|
||
|
||
ied_usr->dev_flag = ENABLE;//终端有效
|
||
|
||
ied->chncount = 1; //通信端口数
|
||
//不再分配通道空间
|
||
ied->channel[0].ied = ied; //通道的所属设备
|
||
ied->channel[0].status = STATUS_BREAKOFF;//初始化为通信中断
|
||
ied->cpucount = 0; //监测点数初始为0，读取监测点台账时写入
|
||
|
||
ied_take = 1;//ied之前存在
|
||
|
||
}
|
||
else{ //在已有的全部台账中都没找到不使用的ied，说明这个进程可挂的台账满了，不再处理
|
||
printf("!!!!!!!!!!ledger array is full!!!!!!\n");
|
||
|
||
//添加mq响应台账添加失败：台账挂满
|
||
//update[i].guid
|
||
char msg[256];
|
||
sprintf(msg, "终端 id: %s 台账更新失败, 这个进程的台账空间已满，达到了配置台账数量的最大值", update[i].terminal_id);
|
||
send_reply_to_kafka_c(update[i].guid, "2", msg);
|
||
|
||
return;
|
||
}
|
||
|
||
}//新台账数量小于等于设定的台账数量
|
||
else{
|
||
|
||
//调试用
|
||
printf("!!!!!!!!!!gnodeindex:%d!!!!!!\n",new_client_count - 1);
|
||
|
||
// 新增的台账在已有的台账数组中记录
|
||
g_node->clients[new_client_count - 1] = (ied_t*)apr_pcalloc(g_cfg_pool, sizeof(ied_t));
|
||
|
||
// 更新台账数量
|
||
g_node->n_clients = new_client_count; // 更新台账数量
|
||
//1-申请新的内存空间//////////////////////////////
|
||
|
||
//2-处理终端台账///////////////////////////////////
|
||
ied = g_node->clients[new_client_count - 1];//终端台账指针定向到ied数组当前位置的后一位
|
||
|
||
terminal_index = new_client_count;//新的台账终端
|
||
|
||
ied_usr = (ied_usr_t*)apr_pcalloc(g_init_pool, sizeof(ied_usr_t));
|
||
ied->usr_ext = ied_usr;//内存挂到ied上
|
||
if (ied_usr == NULL){
|
||
char msg[256];
|
||
snprintf(msg, sizeof(msg), "终端 id: %s 台账更新失败,没有找到台账的终端空间", update[i].terminal_id);
|
||
send_reply_to_kafka_c(update[i].guid, "2", msg);
|
||
return ;
|
||
}
|
||
|
||
|
||
ied_usr->last_call_wavelist_time = sGetMsTime() + g_pt61850app->giTime * 1000;//从FeProject/子功能目录/etc/pt61850netd_pqfe.xml中读取的总查询时间
|
||
|
||
ied_usr->LD_info = (LD_info_t*)apr_pcalloc(g_init_pool, MAX_CPUNO * sizeof(LD_info_t));//内存挂到ied上
|
||
if (ied_usr->LD_info == NULL){
|
||
char msg[256];
|
||
snprintf(msg, sizeof(msg), "终端 id: %s 台账更新失败,没有找到台账的监测点空间", update[i].terminal_id);
|
||
send_reply_to_kafka_c(update[i].guid, "2", msg);
|
||
return ;
|
||
}
|
||
|
||
|
||
ied_usr->dev_flag = ENABLE;//终端有效
|
||
|
||
ied->chncount = 1; //通信端口数,一个终端一般只有一个
|
||
ied->channel = (channel_t*)apr_pcalloc(g_cfg_pool, sizeof(channel_t) * ied->chncount);//内存挂到ied上
|
||
ied->channel[0].ied = ied; //通道的所属设备
|
||
ied->channel[0].status = STATUS_BREAKOFF;//初始化为通信中断
|
||
ied->cpucount = 0; //监测点数初始为0，读取监测点台账时写入
|
||
//2-处理终端台账///////////////////////////////////
|
||
}
|
||
|
||
//3-写入台账内容//////////////////////////////
|
||
int ret = update_one_terminal_ledger(update,i,ied,terminal_index,ied_take);
|
||
if(ret){
|
||
printf("ledger can not be update!!!!!quit process!!!!!\n");
|
||
char msg[256];
|
||
snprintf(msg, sizeof(msg), "终端 id: %s 台账更新失败,无法写入台账", update[i].terminal_id);
|
||
send_reply_to_kafka_c(update[i].guid, "2", msg);
|
||
|
||
clearIed(ied);//添加失败清空整个ied
|
||
|
||
return ;
|
||
}
|
||
//3-写入台账内容///////////////////////////////////
|
||
|
||
//4-配置映射文件//////////////////////////////
|
||
char model[64] = {0};
|
||
// 获取模型ID，检查是否返回 NULL
|
||
parse_model_cfg_web_one(ied,&model);//存储在/FeProject/dat/
|
||
|
||
if (isValidModelId(model)) { //lnk20250313防止拿不到映射文件
|
||
// 安全拷贝字符串到 model 数组
|
||
strncpy(model, model, sizeof(model) - 1);
|
||
model[sizeof(model) - 1] = '\0'; // 确保以 null 结尾
|
||
printf("ledger Model ID: %s\n", model);
|
||
} else {
|
||
printf("ledger No model ID found.quit\n");
|
||
char msg[256];
|
||
snprintf(msg, sizeof(msg), "终端 id: %s 台账更新失败,没有找到装置型号", update[i].terminal_id);
|
||
send_reply_to_kafka_c(update[i].guid, "2", msg);
|
||
|
||
clearIed(ied);//添加失败清空整个ied
|
||
|
||
return ;
|
||
}
|
||
char full_path[128];
|
||
snprintf(full_path, sizeof(full_path), "/FeProject/dat/%s.xml", model); // 拼接路径
|
||
|
||
// 打印模型路径
|
||
printf("ledger icd config file full path: %s\n", full_path);
|
||
|
||
//映射文件解析
|
||
Set_xml_nodeinfo_one(ied_usr->dev_type);
|
||
//4-配置映射文件///////////////////////////////////
|
||
|
||
//5-报告块初始化//////////////////////////////
|
||
parse_rpt_log_ini_one(ied);
|
||
//5-报告块初始化///////////////////////////////////
|
||
|
||
//调试
|
||
printf("ledger id: %s\n", ((ied_usr_t*)ied->channel[0].ied->usr_ext)->terminal_id);
|
||
|
||
//6-init_rem_dib_table//////////////////////////////
|
||
init_rem_dib_table_one(ied);
|
||
//6-init_rem_dib_table///////////////////////////////////
|
||
|
||
//7启动终端日志
|
||
init_loggers_bydevid(((ied_usr_t*)ied->channel[0].ied->usr_ext)->terminal_id);
|
||
|
||
//8响应添加成功
|
||
//update[i].guid
|
||
char msg[256];
|
||
snprintf(msg, sizeof(msg), "终端 id: %s 台账添加成功", update[i].terminal_id);
|
||
send_reply_to_kafka_c(update[i].guid, "2", msg);
|
||
|
||
}
|
||
}
|
||
|
||
//////////////////////////////////////////////////////////////////////////////modify
|
||
update = ledger_update_xml->modify_updates; //处理修改台账部分
|
||
update_num = ledger_update_xml->modify_update_num;
|
||
printf("modify ledger num:%d\n",update_num);
|
||
for (i=0; i<update_num; i++){ //查看所有需要新增的台账
|
||
new_in_work_found = FALSE;
|
||
if(update[i].terminal_id != NULL){
|
||
printf("modify ledger of %s\n",update[i].terminal_id);
|
||
ied = find_ied_from_terminal_id(update[i].terminal_id); //通过文件中的终端号找到配置的设备
|
||
if (ied){
|
||
printf("find ied by terminal_id, terminal already exsist\n");
|
||
new_in_work_found = TRUE; //当前运行的台账中找到已有台账，更新它
|
||
|
||
//关闭这个终端的所有连接//////////////////////////////////////////////////////////////////////
|
||
for(chnl_no=0 ; chnl_no<ied->chncount; chnl_no++) {
|
||
chnl_usr = (chnl_usr_t*)ied->channel[chnl_no].connect;
|
||
if (chnl_usr->m_state!=CHANNEL_CONNECTED){//跳过未连接的通道
|
||
continue;
|
||
}
|
||
closeChannel(chnl_usr);//关闭更新台账后，任务会自动连接
|
||
}
|
||
|
||
//更新数据/////////////////////////////////////////////////////////////////////////////////
|
||
//3-写入台账内容//////////////////////////////
|
||
ied_usr = ied->usr_ext;
|
||
|
||
//清空logger
|
||
remove_loggers_by_terminal_id(update[i].terminal_id);
|
||
|
||
//写入前先清空已有数据
|
||
clearIedUsr(ied_usr);//不会清空dev_idx
|
||
|
||
//ied_usr->last_call_wavelist_time = sGetMsTime() + g_pt61850app->giTime * 1000;//从FeProject/子功能目录/etc/pt61850netd_pqfe.xml中读取的总查询时间
|
||
|
||
ied_usr->dev_flag = ENABLE;//终端有效
|
||
|
||
int ret = update_one_terminal_ledger(update,i,ied,ied_usr->dev_idx,1);//1：更新已有的ied
|
||
if(ret){
|
||
printf("ledger can not be update!!!!!quit process!!!!!\n");
|
||
|
||
char msg[256];
|
||
snprintf(msg, sizeof(msg), "终端 id: %s 台账更新失败,台账无法写入", update[i].terminal_id);
|
||
send_reply_to_kafka_c(update[i].guid, "2", msg);
|
||
|
||
clearIed(ied);//添加失败清空整个ied
|
||
|
||
return ;
|
||
}
|
||
//3-写入台账内容////////////////////////////////////////////
|
||
|
||
//4-配置映射文件///////////////////////////////////////////
|
||
char model[64] = {0};
|
||
// 获取模型ID，检查是否返回 NULL
|
||
parse_model_cfg_web_one(ied,&model);//存储在/FeProject/dat/
|
||
|
||
if (isValidModelId(model)) {
|
||
// 安全拷贝字符串到 model 数组
|
||
strncpy(model, model, sizeof(model) - 1);
|
||
model[sizeof(model) - 1] = '\0'; // 确保以 null 结尾
|
||
printf("ledger Model ID: %s\n", model);
|
||
} else {
|
||
printf("ledger No model ID found.\n");
|
||
|
||
char msg[256];
|
||
snprintf(msg, sizeof(msg), "终端 id: %s 台账更新失败,没有找到装置型号", update[i].terminal_id);
|
||
send_reply_to_kafka_c(update[i].guid, "2", msg);
|
||
|
||
clearIed(ied);//添加失败清空整个ied
|
||
|
||
return ;
|
||
}
|
||
char full_path[128];
|
||
snprintf(full_path, sizeof(full_path), "/FeProject/dat/%s.xml", model); // 拼接路径
|
||
|
||
// 打印模型路径
|
||
printf("ledger icd config file full path: %s\n", full_path);
|
||
|
||
//映射文件解析
|
||
Set_xml_nodeinfo_one(ied_usr->dev_type);
|
||
//4-配置映射文件///////////////////////////////////
|
||
|
||
//5-报告块初始化//////////////////////////////
|
||
parse_rpt_log_ini_one(ied);
|
||
//5-报告块初始化///////////////////////////////////
|
||
|
||
//6-init_rem_dib_table//////////////////////////////
|
||
init_rem_dib_table_one(ied);
|
||
//6-init_rem_dib_table///////////////////////////////////
|
||
//更新数据//////////////////////////////////////////////////////////////////////
|
||
|
||
//7启动终端日志
|
||
init_loggers_bydevid(((ied_usr_t*)ied->channel[0].ied->usr_ext)->terminal_id);
|
||
|
||
//8响应添加成功
|
||
//update[i].guid
|
||
char msg[256];
|
||
snprintf(msg, sizeof(msg), "终端 id: %s 台账修改成功", update[i].terminal_id);
|
||
send_reply_to_kafka_c(update[i].guid, "2", msg);
|
||
}
|
||
}
|
||
|
||
if (!new_in_work_found){
|
||
printf("modify_updates can not find ied!!!!!!\n");
|
||
|
||
//添加mq响应台账添加失败：台账找不到
|
||
//update[i].guid
|
||
char msg[256];
|
||
sprintf(msg, "终端 id: %s 台账修改失败, 无法找到这个终端", update[i].terminal_id);
|
||
send_reply_to_kafka_c(update[i].guid, "2", msg);
|
||
}
|
||
}
|
||
///////////////////////////////////////////////////////////////////////////////delete
|
||
update = ledger_update_xml->delete_updates; //处理删除台账部分
|
||
update_num = ledger_update_xml->delete_update_num; //删除的数量
|
||
printf("delete ledger num:%d\n",update_num);
|
||
|
||
for (i=0; i<update_num; i++){ //查看所有需要删除的台账
|
||
new_in_work_found = FALSE; //找到现存台账的标志
|
||
if(update[i].terminal_id != NULL){ //处理非空台账
|
||
printf("delete ledger of %s\n",update[i].terminal_id);
|
||
|
||
ied = find_ied_from_terminal_id(update[i].terminal_id); //通过文件中的终端号找到配置的设备，没找到就不处理
|
||
if (ied){
|
||
printf("find ied by terminal_id, terminal already exsist\n");
|
||
new_in_work_found = TRUE; //当前运行的台账中找到已有台账，更新它
|
||
|
||
//关闭这个终端的所有连接//////////////////////////////////////////////////////////////////////
|
||
for(chnl_no=0 ; chnl_no<ied->chncount; chnl_no++) {
|
||
chnl_usr = (chnl_usr_t*)ied->channel[chnl_no].connect;
|
||
if (chnl_usr->m_state!=CHANNEL_CONNECTED){ //跳过没连接的通道，一般一个终端只有一个
|
||
continue;
|
||
}
|
||
closeChannel(chnl_usr);//关闭更新台账后，如果是删除则不会再连接，关闭连接时这个ied的报告会被清除，报告控制会被注销
|
||
}
|
||
|
||
//更新数据//////////////////////////////////////////////////////////////////////
|
||
//3-删除台账内容//////////////////////////////
|
||
|
||
//调试用
|
||
// 假设要删除 g_node->clients 中的某个 ied，index 为删除的索引
|
||
int index_to_remove = 0;
|
||
ied_t* ied_find = NULL;
|
||
int iedno;
|
||
ied_usr_t* ied_usr_find = NULL; //遍历的ied
|
||
ied_usr = (ied_usr_t*)ied->usr_ext;//要删除的ied
|
||
for (iedno = 0; iedno < g_node->n_clients; iedno++) {
|
||
ied_find = g_node->clients[iedno];
|
||
ied_usr_find = (ied_usr_t*)ied_find->usr_ext;
|
||
if (ied_usr_find && strcmp(ied_usr_find->terminal_id, ied_usr->terminal_id) == 0) {
|
||
index_to_remove = iedno;//找到要删除的ied在g_node中的位置
|
||
break; //找到退出
|
||
}
|
||
}
|
||
|
||
// 先清理要删除的 ied 的内容
|
||
ied_t* ied_to_remove = g_node->clients[index_to_remove];//指向g_node对应的内存区
|
||
|
||
if(ied_to_remove == ied){//通过终端id找到的ied应该也指向g_node对应的内存区
|
||
printf("this ied is ied_to_remove\n");
|
||
}
|
||
//调试用
|
||
|
||
//清空logger
|
||
remove_loggers_by_terminal_id(update[i].terminal_id);
|
||
|
||
//清空ied的内容
|
||
clearIed(ied_to_remove);
|
||
|
||
//3-删除台账内容///////////////////////////////////
|
||
|
||
//4-配置映射文件//////////////////////////////
|
||
//映射文件保留，如果再次添加这个ied，如果是相同的映射文件则可以直接加载
|
||
//4-配置映射文件///////////////////////////////////
|
||
|
||
//5-报告块//////////////////////////////
|
||
//关闭连接时这个ied的报告已清空。报告控制块保留，因为报告控制块是根据设备类型设置的，如果删除会影响其他同类型的ied。这个ied对应的控制块在清空内容时已清空
|
||
//5-报告块///////////////////////////////////
|
||
|
||
//6-init_rem_dib_table//////////////////////////////
|
||
//rem_dib_table的内容将会被保留，如果有新的台账使用这个位置，将会直接覆盖
|
||
//6-init_rem_dib_table///////////////////////////////////
|
||
//更新数据//////////////////////////////////////////////////////////////////////
|
||
|
||
//7响应添加成功
|
||
//update[i].guid
|
||
char msg[256];
|
||
snprintf(msg, sizeof(msg), "终端 id: %s 台账删除成功", update[i].terminal_id);
|
||
send_reply_to_kafka_c(update[i].guid, "2", msg);
|
||
}
|
||
}
|
||
|
||
if (!new_in_work_found) {
|
||
printf("modify_updates can not find ied!!!!!!\n");
|
||
|
||
//添加mq响应台账添加失败：台账找不到
|
||
//update[i].guid
|
||
|
||
char msg[256];
|
||
sprintf(msg, "终端 id: %s 台账删除失败, 无法找到这个终端", update[i].terminal_id);
|
||
send_reply_to_kafka_c(update[i].guid, "2", msg);
|
||
|
||
}
|
||
}
|
||
//////////////////////////////////////////////////////////////////////////////
|
||
if (ledger_update_xml->modify_update_num || ledger_update_xml->new_update_num || ledger_update_xml->delete_update_num){
|
||
create_ledger_log(ledger_update_xml); //写入文件
|
||
}
|
||
|
||
}
|
||
//台账更新调试打印函数
|
||
// 检查字符串是否为空
|
||
// 检查字符串是否为空
|
||
int is_empty(const char* str) {
|
||
return (str == NULL || str[0] == '\0');
|
||
}
|
||
|
||
// 打印 monitor 结构体信息
|
||
void print_monitor(const monitor* mon) {
|
||
printf("Monitor ID: %s\n", is_empty(mon->monitor_id) ? "N/A" : mon->monitor_id);
|
||
printf("Terminal Code: %s\n", is_empty(mon->terminal_code) ? "N/A" : mon->terminal_code);
|
||
printf("Monitor Name: %s\n", is_empty(mon->monitor_name) ? "N/A" : mon->monitor_name);
|
||
printf("Logical Device Sequence: %s\n", is_empty(mon->logical_device_seq) ? "N/A" : mon->logical_device_seq);
|
||
printf("Voltage Level: %s\n", is_empty(mon->voltage_level) ? "N/A" : mon->voltage_level);
|
||
printf("Terminal Connect: %s\n", is_empty(mon->terminal_connect) ? "N/A" : mon->terminal_connect);
|
||
printf("Timestamp: %s\n", is_empty(mon->timestamp) ? "N/A" : mon->timestamp);
|
||
printf("Status: %s\n", is_empty(mon->status) ? "N/A" : mon->status);
|
||
}
|
||
|
||
// 打印 terminal 结构体信息
|
||
void print_terminal(const terminal* tmnl) {
|
||
printf("GUID: %s\n", is_empty(tmnl->guid) ? "N/A" : tmnl->guid);//lnk20250506
|
||
printf("Terminal ID: %s\n", is_empty(tmnl->terminal_id) ? "N/A" : tmnl->terminal_id);
|
||
printf("Terminal Code: %s\n", is_empty(tmnl->terminal_code) ? "N/A" : tmnl->terminal_code);
|
||
printf("Organization Name: %s\n", is_empty(tmnl->org_name) ? "N/A" : tmnl->org_name);
|
||
printf("Maintenance Name: %s\n", is_empty(tmnl->maint_name) ? "N/A" : tmnl->maint_name);
|
||
printf("Station Name: %s\n", is_empty(tmnl->station_name) ? "N/A" : tmnl->station_name);
|
||
printf("Factory Name: %s\n", is_empty(tmnl->tmnl_factory) ? "N/A" : tmnl->tmnl_factory);
|
||
printf("Terminal Status: %s\n", is_empty(tmnl->tmnl_status) ? "N/A" : tmnl->tmnl_status);
|
||
printf("Device Type: %s\n", is_empty(tmnl->dev_type) ? "N/A" : tmnl->dev_type);
|
||
printf("Device Key: %s\n", is_empty(tmnl->dev_key) ? "N/A" : tmnl->dev_key);
|
||
printf("Device Series: %s\n", is_empty(tmnl->dev_series) ? "N/A" : tmnl->dev_series);
|
||
printf("Address: %s\n", is_empty(tmnl->addr_str) ? "N/A" : tmnl->addr_str);
|
||
printf("Port: %s\n", is_empty(tmnl->port) ? "N/A" : tmnl->port);
|
||
printf("Timestamp: %s\n", is_empty(tmnl->timestamp) ? "N/A" : tmnl->timestamp);
|
||
|
||
// 打印监测点信息，如果监测点字段为空，则打印 N/A
|
||
int i;
|
||
for (i = 0; i < 10 && !is_empty(tmnl->line[i].monitor_id); ++i) {
|
||
printf(" Monitor %d:\n", i + 1);
|
||
print_monitor(&tmnl->line[i]);
|
||
}
|
||
}
|
||
|
||
// 打印 trigger_update_xml_t 结构体信息
|
||
void print_trigger_update_xml(const trigger_update_xml_t* trigger_update) {
|
||
printf("Work Updates Count: %d\n", trigger_update->work_update_num);
|
||
printf("New Updates Count: %d\n", trigger_update->new_update_num);
|
||
printf("Delete Updates Count: %d\n", trigger_update->delete_update_num);
|
||
printf("Modify Updates Count: %d\n", trigger_update->modify_update_num);
|
||
|
||
printf("\nWork Updates:\n");
|
||
int i;
|
||
for (i = 0; i < trigger_update->work_update_num; ++i) {
|
||
printf("Work Update %d:\n", i + 1);
|
||
print_terminal(&trigger_update->work_updates[i]);
|
||
}
|
||
|
||
printf("\nNew Updates:\n");
|
||
for (i = 0; i < trigger_update->new_update_num; ++i) {
|
||
printf("New Update %d:\n", i + 1);
|
||
print_terminal(&trigger_update->new_updates[i]);
|
||
}
|
||
|
||
printf("\nDelete Updates:\n");
|
||
for (i = 0; i < trigger_update->delete_update_num; ++i) {
|
||
printf("Delete Update %d:\n", i + 1);
|
||
print_terminal(&trigger_update->delete_updates[i]);
|
||
}
|
||
|
||
printf("\nModify Updates:\n");
|
||
for (i = 0; i < trigger_update->modify_update_num; ++i) {
|
||
printf("Modify Update %d:\n", i + 1);
|
||
print_terminal(&trigger_update->modify_updates[i]);
|
||
}
|
||
}
|
||
|
||
void check_ledger_update()//lnk20250113
|
||
{
|
||
double now;
|
||
static double last_check_3s_config_time = 0.0;//初始化时间
|
||
|
||
now = sGetMsTime(); //当前时间
|
||
if ( fabs(now - last_check_3s_config_time) < 3*1000 ) //wait 3secs //当前进程任务执行时查看当前时间和上次执行时间间隔，小于3秒不执行，大于等于3秒往下执行
|
||
return;
|
||
|
||
// 动态分配内存给 trigger_ledger_update_xml 结构体
|
||
trigger_update_xml_t* trigger_ledger_update_xml = (trigger_update_xml_t*)malloc(sizeof(trigger_update_xml_t));
|
||
if (trigger_ledger_update_xml == NULL) {
|
||
printf("Memory allocation failed!\n");
|
||
return; // 如果内存分配失败，返回
|
||
}
|
||
|
||
//每次都初始化防止重复
|
||
memset(trigger_ledger_update_xml, 0, sizeof(trigger_update_xml_t));
|
||
|
||
//printf("check ledger update...trigger_ledger_update_xml:%d\n",trigger_ledger_update_xml->modify_update_num);//减少不必要的打印
|
||
|
||
last_check_3s_config_time = now; //记录本次运行时间
|
||
|
||
//判断是否满足执行条件，一个文件就是一个终端，读取文件后删除文件
|
||
if (APR_SUCCESS==parse_ledger_update_xml(trigger_ledger_update_xml)){ //处理台账更新文件,如果有可以更新或者添加台账的
|
||
//调试用
|
||
print_trigger_update_xml(trigger_ledger_update_xml);
|
||
|
||
//处理台账更新加台账锁lnk20250114
|
||
//pthread_mutex_lock(&mtx); printf("ledgerupdate hold lock !!!!!!!!!!!");
|
||
process_ledger_update(trigger_ledger_update_xml); //台账更新
|
||
//pthread_mutex_unlock(&mtx); printf("ledgerupdate free lock !!!!!!!!!!!");
|
||
|
||
}
|
||
|
||
// 使用完后释放动态分配的内存
|
||
free(trigger_ledger_update_xml);
|
||
}
|
||
/////////////////////////////////////////////////////////////////////////////////////////////////////////////////////
|
||
#ifdef _OS_UNIX_
|
||
uint32_t get_freedisk_MB(uint32_t* totalSizeMB)
|
||
{
|
||
struct statfs diskInfo;
|
||
unsigned long long totalBlocks = 0;
|
||
unsigned long long totalSize = 0;
|
||
size_t mbTotalsize = 0;
|
||
size_t freeDisk=0;
|
||
size_t mbFreeDisk = 0;
|
||
|
||
statfs("/home/pq", &diskInfo);
|
||
totalBlocks = diskInfo.f_bsize;
|
||
totalSize = totalBlocks * diskInfo.f_blocks;
|
||
mbTotalsize = totalSize >> 20;
|
||
freeDisk = diskInfo.f_bfree*totalBlocks;
|
||
mbFreeDisk = freeDisk >> 20;
|
||
printf("/home/pq total=%dMB, free=%dMB \n", mbTotalsize, mbFreeDisk);
|
||
if (totalSizeMB)
|
||
*totalSizeMB = mbTotalsize;
|
||
return mbFreeDisk;
|
||
}
|
||
#else
|
||
uint32_t get_freedisk_MB(uint32_t* totalSizeMB) {
|
||
if (totalSizeMB)
|
||
*totalSizeMB = 1000;
|
||
return 5;
|
||
}
|
||
#endif
|
||
|
||
void check_disk_quota()
|
||
{
|
||
double now;
|
||
static double last_check_time = -10000000.0;
|
||
uint32_t freeSizeMB,totalSizeMB;
|
||
|
||
if(g_node_id != STAT_DATA_BASE_NODE_ID || g_front_seg_index != 1)//lnk20250527只有稳态进程1监测磁盘
|
||
return;
|
||
now = sGetMsTime();
|
||
if ( fabs(now - last_check_time) < 15*1000 ) //wait 15 secs
|
||
return;
|
||
|
||
last_check_time = now;
|
||
|
||
freeSizeMB = get_freedisk_MB(&totalSizeMB);
|
||
|
||
//printf("Current user disk free size: %dMB ,total size: %dMB \n",freeSizeMB,totalSizeMB);
|
||
if (freeSizeMB<g_min_free_size){
|
||
echo_warn2("Current user disk free size: %dMB < %dMB, please check!\n",freeSizeMB,g_min_free_size);
|
||
DIY_WARNLOG("process","【WARN】前置磁盘检测： 当前磁盘的可用空间为%dMB,小于最小可用空间%dMB,请检查磁盘",freeSizeMB,g_min_free_size);
|
||
}
|
||
|
||
if ((freeSizeMB/(totalSizeMB/100+1) )<10){
|
||
echo_warn2("Current user disk free size percent < 10%%, free size: %dMB ,total size: %dMB ,please check!\n",
|
||
freeSizeMB,totalSizeMB);
|
||
DIY_WARNLOG("process","【WARN】前置磁盘检测： 当前磁盘的可用空间的百分比小于10%%,可用空间为%dMB,总空间为%dMB,请检查磁盘",freeSizeMB,totalSizeMB);
|
||
}
|
||
|
||
}
|
||
|
||
void create_recall_xml()
|
||
{
|
||
//生成待补招xml文件
|
||
if (g_node_id == HIS_DATA_BASE_NODE_ID || g_node_id == NEW_HIS_DATA_BASE_NODE_ID || g_node_id == RECALL_HIS_DATA_BASE_NODE_ID || (g_node_id == RECALL_ALL_DATA_BASE_NODE_ID)) {
|
||
DeletcRecallXml();
|
||
CreateRecallXml();
|
||
}
|
||
}
|
||
|
||
void Delete_recall_Xml(char* id) {
|
||
if (g_node_id == HIS_DATA_BASE_NODE_ID || g_node_id == NEW_HIS_DATA_BASE_NODE_ID || g_node_id == RECALL_HIS_DATA_BASE_NODE_ID || (g_node_id == RECALL_ALL_DATA_BASE_NODE_ID)) {
|
||
delete_recall_xml(id);
|
||
|
||
}
|
||
}
|
||
|
||
void Check_Recall_Config(char *id) //检查补招配置文件Recall.xml
|
||
{
|
||
if (g_node_id == HIS_DATA_BASE_NODE_ID || g_node_id == NEW_HIS_DATA_BASE_NODE_ID || g_node_id == RECALL_HIS_DATA_BASE_NODE_ID || (g_node_id == RECALL_ALL_DATA_BASE_NODE_ID)) {
|
||
|
||
recall_xml_t recall_xml;
|
||
memset((char*)&recall_xml, 0, sizeof(recall_xml_t));
|
||
parse_recall_xml(&recall_xml,id); //解析补招文件，目录下所有属于这个监测点的文件都读取
|
||
process_recall_config(&recall_xml); //解析的补招数据赋值到全局变量
|
||
}
|
||
}
|
||
|
||
void CheckAllConnectedChannel()
|
||
{
|
||
chnl_usr_t *chnl_usr;
|
||
static uint32_t chnl_sequence_no = 0;
|
||
|
||
|
||
//lnk20250514如果进程启动没有台账则不往下执行，等待台账更新
|
||
if(g_pt61850app->chnl_counts == 0)return;
|
||
//lnk20250514如果进程启动没有台账则不往下执行，等待台账更新
|
||
|
||
|
||
//一次访问一个终端
|
||
do {
|
||
chnl_usr = g_pt61850app->chnl_usr[chnl_sequence_no];
|
||
chnl_sequence_no = (chnl_sequence_no+1) % g_pt61850app->chnl_counts;
|
||
|
||
if (chnl_usr == NULL) continue; // 安全防护lnk20250701
|
||
|
||
} while ( (g_onlyIP[0]!=0) && (strcmp(g_onlyIP,chnl_usr->ip_str)!=0) );
|
||
|
||
if (chnl_usr == NULL || chnl_usr->chnl == NULL || chnl_usr->chnl->ied == NULL || chnl_usr->chnl->ied->usr_ext == NULL) {
|
||
printf("chnl_usr or nested member is NULL, skip...\n");
|
||
return;
|
||
}
|
||
|
||
if(chnl_usr->m_state == CHANNEL_CONNECTED)
|
||
{
|
||
|
||
ChannelCheckIECReports(chnl_usr);//报告
|
||
if ( (g_node_id == SOE_COMTRADE_BASE_NODE_ID) || (g_node_id == HIS_DATA_BASE_NODE_ID) || (g_node_id == NEW_HIS_DATA_BASE_NODE_ID) || (g_node_id == RECALL_HIS_DATA_BASE_NODE_ID) || (g_node_id == RECALL_ALL_DATA_BASE_NODE_ID))
|
||
ChannelCheckWaveFiles(chnl_usr);//录波文件
|
||
if(g_node_id == HIS_DATA_BASE_NODE_ID || g_node_id == NEW_HIS_DATA_BASE_NODE_ID || g_node_id == RECALL_HIS_DATA_BASE_NODE_ID || (g_node_id == RECALL_ALL_DATA_BASE_NODE_ID))
|
||
ChannelCheckIECLogs(chnl_usr);//补招文件
|
||
if ( (sGetMsTime() - chnl_usr->m_LastPosRespTime) > 15*1000 ) //wait 15 secs，隔15秒获取一次响应，两次没响应后关闭
|
||
{
|
||
char** varnames ;
|
||
int varnum;
|
||
|
||
ST_RET ret = mms_mvla_getnam(chnl_usr->net_info, VMD_SPEC, NULL,MMS_CLASS_DOM,g_pt61850app->mmsOpTimeout,
|
||
&varnames,&varnum,g_pt61850app->tmp_pool);
|
||
|
||
chnl_usr->m_LastPosRespTime = sGetMsTime();
|
||
if (ret == SD_SUCCESS) {
|
||
|
||
chnl_usr->m_NegRespTimes = 0;
|
||
}else {
|
||
|
||
printf("%d--------------\n", chnl_usr->m_NegRespTimes);
|
||
chnl_usr->m_NegRespTimes++;
|
||
}
|
||
}
|
||
if ( chnl_usr->m_NegRespTimes >=2 ) {
|
||
|
||
closeChannel(chnl_usr);//???特殊情况是否需要 mms_release_connection
|
||
chnl_usr->m_NegRespTimes = 0;
|
||
chnl_usr->m_LastPosRespTime = sGetMsTime();
|
||
}
|
||
}
|
||
}
|
||
|
||
void CheckNextNotConnectedChannel()
|
||
{
|
||
static uint32_t chnl_total_no = 0;
|
||
chnl_usr_t *chnl_usr;
|
||
|
||
//lnk20250514如果进程启动没有台账则不往下执行，等待台账更新
|
||
if(g_pt61850app->chnl_counts == 0)return;
|
||
//lnk20250514如果进程启动没有台账则不往下执行，等待台账更新
|
||
|
||
do {
|
||
chnl_usr = g_pt61850app->chnl_usr[chnl_total_no];
|
||
chnl_total_no = (chnl_total_no+1) % g_pt61850app->chnl_counts;
|
||
|
||
if (chnl_usr == NULL) continue; // 安全防护lnk20250701
|
||
|
||
} while ( (g_onlyIP[0]!=0) && (strcmp(g_onlyIP,chnl_usr->ip_str)!=0) );
|
||
|
||
if (chnl_usr == NULL || chnl_usr->chnl == NULL || chnl_usr->chnl->ied == NULL || chnl_usr->chnl->ied->usr_ext == NULL) {
|
||
printf("chnl_usr or nested member is NULL, skip...\n");
|
||
return;
|
||
}
|
||
|
||
//终端日志的key,lnk20250526
|
||
char full_key_t_c[256]; // 分配足够空间
|
||
char full_key_t_d[256]; // 分配足够空间
|
||
snprintf(full_key_t_c, sizeof(full_key_t_c), "terminal.%s.COM", ((ied_usr_t*)(chnl_usr->chnl->ied->usr_ext))->terminal_id);
|
||
snprintf(full_key_t_d, sizeof(full_key_t_d), "terminal.%s.DATA", ((ied_usr_t*)(chnl_usr->chnl->ied->usr_ext))->terminal_id);
|
||
//终端日志的key,lnk20250526
|
||
|
||
//10-11-01 22:03 beijing
|
||
if( ( (chnl_total_no+1)==g_pt61850app->chnl_counts) || (g_onlyIP[0]!=0) ){
|
||
if(g_pt61850app->initNum<255)
|
||
g_pt61850app->initNum++;
|
||
}
|
||
|
||
if(chnl_usr->m_state == CHANNEL_CONNECTING)//正在连接
|
||
{
|
||
|
||
MVL_REQ_PEND* reqCtrl= chnl_usr->m_reqCtrl ;
|
||
|
||
if( reqCtrl->done == SD_TRUE)
|
||
{
|
||
|
||
if(reqCtrl->result == SD_SUCCESS)
|
||
{
|
||
|
||
ALL_RCB_INFO *all_rcb_info;
|
||
|
||
echo_warn4("\nCHANNEL_CONNECTED %s:%d ,NetInfo= %x chnl_usr= %x \n",
|
||
chnl_usr->ip_str,chnl_usr->chnl->port,chnl_usr->net_info,chnl_usr);
|
||
|
||
//mq日志
|
||
((ied_usr_t*)(chnl_usr->chnl->ied->usr_ext))->lastconnectstat = true;
|
||
((ied_usr_t*)(chnl_usr->chnl->ied->usr_ext))->has_logged_disconnect = false;
|
||
DIY_WARNLOG(full_key_t_c,"【WARN】终端%s - ip端口:%s:%d连接成功", ((ied_usr_t*)(chnl_usr->chnl->ied->usr_ext))->terminal_id,chnl_usr->ip_str,chnl_usr->chnl->port);
|
||
|
||
mvl_free_req_ctrl(chnl_usr->m_reqCtrl);
|
||
chnl_usr->m_reqCtrl = NULL;
|
||
|
||
chnl_usr->m_state = CHANNEL_CONNECTED;
|
||
chnl_usr->net_info->user_ext = chnl_usr;
|
||
|
||
all_rcb_info = (ALL_RCB_INFO *)chk_calloc(1, sizeof (ALL_RCB_INFO));
|
||
all_rcb_info->rpt_typeids = &g_rpt_typeids;
|
||
|
||
if (chnl_usr->net_info->user_info != NULL) {
|
||
echo_warn("chnl_usr->net_info->user_info is not NULL\n");
|
||
}
|
||
|
||
chnl_usr->net_info->user_info = all_rcb_info;
|
||
chnl_usr->chnl->ied->status = STATUS_NORMAL;
|
||
chnl_usr->chnl->status = STATUS_NORMAL;
|
||
|
||
{
|
||
char comm_str[256];
|
||
memset(comm_str,0,256);
|
||
apr_snprintf(comm_str,sizeof(comm_str),"%16s:%d\t\tconnected",chnl_usr->ip_str,chnl_usr->chnl->port);
|
||
add_comm_log(comm_str);
|
||
FRONT_MP_NUM++;
|
||
}
|
||
|
||
//lnk202411-1添加连接成功的记录
|
||
ied_usr_t* ied_usr = (ied_usr_t*)chnl_usr->chnl->ied->usr_ext;
|
||
apr_time_t t_now = apr_time_now();
|
||
printf("msTime:%ld",t_now);
|
||
connectlog_pgsql(ied_usr->terminal_id,convertMsToDateTimeString(t_now),1);//1成功
|
||
|
||
}
|
||
else
|
||
{// solaris 9 上 224秒
|
||
|
||
int secsSince = (int)(sGetMsTime() - chnl_usr->m_StartConnectingTime)/1000 ;
|
||
|
||
ied_usr_t* ied_usr = (ied_usr_t*)chnl_usr->chnl->ied->usr_ext;
|
||
|
||
printf( "reqCtrl->result == FAIL, Since StartConnecting %i sec ,channel IP %s:%d \n",secsSince,chnl_usr->ip_str,chnl_usr->chnl->port);
|
||
|
||
//mq日志
|
||
if(true == ((ied_usr_t*)(chnl_usr->chnl->ied->usr_ext))->lastconnectstat){
|
||
((ied_usr_t*)(chnl_usr->chnl->ied->usr_ext))->lastconnectstat = false;
|
||
((ied_usr_t*)(chnl_usr->chnl->ied->usr_ext))->has_logged_disconnect = true;
|
||
DIY_WARNLOG(full_key_t_c,"【WARN】终端%s - ip/端口:%s:%d - 识别码/秘钥:%s/%s,从开始连接到目前已经%i秒,连接失败，断开连接！", ((ied_usr_t*)(chnl_usr->chnl->ied->usr_ext))->terminal_id,chnl_usr->ip_str,chnl_usr->chnl->port,((ied_usr_t*)(chnl_usr->chnl->ied->usr_ext))->dev_series,((ied_usr_t*)(chnl_usr->chnl->ied->usr_ext))->dev_key,secsSince);
|
||
}
|
||
else if(false == ((ied_usr_t*)(chnl_usr->chnl->ied->usr_ext))->lastconnectstat && false == ((ied_usr_t*)(chnl_usr->chnl->ied->usr_ext))->has_logged_disconnect){
|
||
((ied_usr_t*)(chnl_usr->chnl->ied->usr_ext))->has_logged_disconnect = true;
|
||
DIY_WARNLOG(full_key_t_c,"【WARN】终端%s - ip/端口:%s:%d - 识别码/秘钥:%s/%s,从开始连接到目前已经%i秒,连接失败，断开连接！", ((ied_usr_t*)(chnl_usr->chnl->ied->usr_ext))->terminal_id,chnl_usr->ip_str,chnl_usr->chnl->port,((ied_usr_t*)(chnl_usr->chnl->ied->usr_ext))->dev_series,((ied_usr_t*)(chnl_usr->chnl->ied->usr_ext))->dev_key,secsSince);
|
||
}
|
||
|
||
mvl_free_req_ctrl(chnl_usr->m_reqCtrl);
|
||
chnl_usr->m_reqCtrl = NULL;
|
||
chnl_usr->net_info->rem_vmd = NULL;
|
||
chnl_usr->m_state = CHANNEL_DISCONNECTED;
|
||
chnl_usr->m_ClosedMsTime = sGetMsTime();
|
||
}
|
||
}
|
||
else
|
||
{
|
||
|
||
if ( (sGetMsTime() - chnl_usr->m_StartConnectingTime) > 300*1000 ) //300*1000 ) //wait 300 secs
|
||
{
|
||
ied_usr_t* ied_usr = (ied_usr_t*)chnl_usr->chnl->ied->usr_ext;
|
||
|
||
echo_warn2( "reqCtrl->done未完成,but time over 300 secs, close channel IP %s,NetInfo= %x ",chnl_usr->ip_str,chnl_usr->net_info);
|
||
|
||
//mq日志
|
||
if(true == ((ied_usr_t*)(chnl_usr->chnl->ied->usr_ext))->lastconnectstat){
|
||
((ied_usr_t*)(chnl_usr->chnl->ied->usr_ext))->lastconnectstat = false;
|
||
((ied_usr_t*)(chnl_usr->chnl->ied->usr_ext))->has_logged_disconnect = true;
|
||
DIY_WARNLOG(full_key_t_c,"【WARN】终端%s - ip端口:%s:%d,从开始连接到目前已经300秒,未能获取连接响应，断开连接！", ((ied_usr_t*)(chnl_usr->chnl->ied->usr_ext))->terminal_id,chnl_usr->ip_str,chnl_usr->chnl->port);
|
||
}
|
||
else if(false == ((ied_usr_t*)(chnl_usr->chnl->ied->usr_ext))->lastconnectstat && false == ((ied_usr_t*)(chnl_usr->chnl->ied->usr_ext))->has_logged_disconnect){
|
||
((ied_usr_t*)(chnl_usr->chnl->ied->usr_ext))->has_logged_disconnect = true;
|
||
DIY_WARNLOG(full_key_t_c,"【WARN】终端%s - ip端口:%s:%d,从开始连接到目前已经300秒,未能获取连接响应，断开连接！", ((ied_usr_t*)(chnl_usr->chnl->ied->usr_ext))->terminal_id,chnl_usr->ip_str,chnl_usr->chnl->port);
|
||
}
|
||
|
||
|
||
if (chnl_usr->net_info->req_pend_list) {
|
||
echo_warn("reqCtrl->done未完成,but time over 300 secs!!!!!!!!\n");
|
||
mvl_free_req_ctrl(chnl_usr->m_reqCtrl);
|
||
chnl_usr->m_reqCtrl = NULL;
|
||
}
|
||
mms_release_connection(chnl_usr->net_info);
|
||
|
||
chnl_usr->net_info->rem_vmd = NULL;
|
||
chnl_usr->m_state = CHANNEL_DISCONNECTED;
|
||
chnl_usr->m_ClosedMsTime = sGetMsTime();
|
||
|
||
}
|
||
}
|
||
}
|
||
|
||
else if(chnl_usr->m_state == CHANNEL_DISCONNECTED)
|
||
{
|
||
|
||
if ( (sGetMsTime() - chnl_usr->m_ClosedMsTime) > NEXT_CONNECT_TIME ) //wait 10 secs
|
||
{
|
||
|
||
ST_RET ret;
|
||
ST_CHAR serverARName[32];
|
||
ied_usr_t *ied_usr = (ied_usr_t*)chnl_usr->chnl->ied->usr_ext;
|
||
apr_snprintf(serverARName,sizeof(serverARName),"%s:%d",chnl_usr->ip_str,chnl_usr->chnl->port);
|
||
if (chnl_usr->chnl->ied->cpucount != NULL && chnl_usr->chnl->ied->cpucount > 0 && ied_usr->dev_flag == ENABLE) {//2023-09-26 czy 如果line count<0 不需要连接//lnk20250121如果终端无效则不连接
|
||
|
||
//mq日志
|
||
//DIY_WARNLOG(full_key_t_c,"【WARN】重新连接终端%s - ip端口:%s:%d", ((ied_usr_t*)(chnl_usr->chnl->ied->usr_ext))->terminal_id,chnl_usr->ip_str,chnl_usr->chnl->port);
|
||
|
||
ret = mms_connectToServer(ied_usr->dev_key, ied_usr->dev_series, serverARName, &(chnl_usr->net_info), &(chnl_usr->m_reqCtrl));
|
||
|
||
if (ret == SD_SUCCESS)
|
||
{
|
||
|
||
echo_msg3("mms_connectToServer IP %s:%d ,NetInfo= %x \n", chnl_usr->ip_str, chnl_usr->chnl->port, chnl_usr->net_info);
|
||
chnl_usr->m_state = CHANNEL_CONNECTING;
|
||
chnl_usr->m_StartConnectingTime = sGetMsTime();
|
||
|
||
//mq日志
|
||
//DIY_WARNLOG(full_key_t_c,"【WARN】正在重新连接终端%s - ip端口:%s:%d - 识别码/秘钥:%s/%s", ((ied_usr_t*)(chnl_usr->chnl->ied->usr_ext))->terminal_id,chnl_usr->ip_str,chnl_usr->chnl->port,((ied_usr_t*)(chnl_usr->chnl->ied->usr_ext))->dev_series,((ied_usr_t*)(chnl_usr->chnl->ied->usr_ext))->dev_key);
|
||
|
||
|
||
}
|
||
else
|
||
{
|
||
|
||
chnl_usr->m_ClosedMsTime = sGetMsTime();
|
||
|
||
echo_warn3("FAILED: mms_connectToServer IP %s:%d ,NetInfo= %x \n", chnl_usr->ip_str, chnl_usr->chnl->port, chnl_usr->net_info);
|
||
|
||
//mq日志
|
||
//DIY_WARNLOG(full_key_t_c,"【WARN】重新连接终端%s - ip端口:%s:%d 失败！", ((ied_usr_t*)(chnl_usr->chnl->ied->usr_ext))->terminal_id,chnl_usr->ip_str,chnl_usr->chnl->port);
|
||
}
|
||
}
|
||
|
||
}
|
||
}
|
||
else if(chnl_usr->m_state == CHANNEL_DISCONNECTING) //need check timeout?会不会永远停留在这里
|
||
{
|
||
|
||
MVL_REQ_PEND* reqCtrl= chnl_usr->m_reqCtrl ;
|
||
if( reqCtrl->done == SD_TRUE)
|
||
{
|
||
|
||
echo_warn3( "CHANNEL_DISCONNECTING done %s:%d,NetInfo= %x ",chnl_usr->ip_str,chnl_usr->chnl->port,chnl_usr->net_info);
|
||
mvl_free_req_ctrl(chnl_usr->m_reqCtrl);
|
||
if(chnl_usr->net_info)
|
||
chnl_usr->net_info->user_ext = NULL;
|
||
|
||
chnl_usr->m_reqCtrl = NULL;
|
||
chnl_usr->net_info = NULL;
|
||
chnl_usr->m_state = CHANNEL_DISCONNECTED;
|
||
chnl_usr->m_ClosedMsTime = sGetMsTime();
|
||
//断联成功
|
||
ied_usr_t* ied_usr = (ied_usr_t*)chnl_usr->chnl->ied->usr_ext;
|
||
apr_time_t t_now = apr_time_now();
|
||
connectlog_pgsql(ied_usr->terminal_id,convertMsToDateTimeString(t_now),0);
|
||
|
||
//mq日志
|
||
DIY_WARNLOG(full_key_t_c,"【WARN】终端%s - ip端口:%s:%d 断连完成，关闭连接通道", ((ied_usr_t*)(chnl_usr->chnl->ied->usr_ext))->terminal_id,chnl_usr->ip_str,chnl_usr->chnl->port);
|
||
|
||
}
|
||
else
|
||
{
|
||
|
||
echo_warn2( "CHANNEL_DISCONNECTING waiting ... %s,NetInfo= %x ",chnl_usr->ip_str,chnl_usr->net_info);
|
||
|
||
if ( (sGetMsTime() - chnl_usr->m_StartDisconnectingTime) > 30*1000 ) // //wait 30 secs ?????
|
||
{
|
||
|
||
echo_warn2( "CHANNEL_DISCONNECTING reqCtrl->done未完成,but time over 180 secs, close channel IP %s,NetInfo= %x ",chnl_usr->ip_str,chnl_usr->net_info);
|
||
mvl_free_req_ctrl(chnl_usr->m_reqCtrl);
|
||
chnl_usr->net_info->user_ext = NULL;
|
||
|
||
mms_release_connection(chnl_usr->net_info);
|
||
chnl_usr->net_info->rem_vmd = NULL;
|
||
chnl_usr->m_reqCtrl = NULL;
|
||
chnl_usr->net_info = NULL;
|
||
chnl_usr->m_state = CHANNEL_DISCONNECTED;
|
||
chnl_usr->m_ClosedMsTime = sGetMsTime();
|
||
//超时断联成功
|
||
ied_usr_t* ied_usr = (ied_usr_t*)chnl_usr->chnl->ied->usr_ext;
|
||
apr_time_t t_now = apr_time_now();
|
||
connectlog_pgsql(ied_usr->terminal_id,convertMsToDateTimeString(t_now),0);
|
||
|
||
//mq日志
|
||
DIY_WARNLOG(full_key_t_c,"【WARN】终端%s - ip端口:%s:%d 断连未完成,但是已经超时180秒,关闭连接通道", ((ied_usr_t*)(chnl_usr->chnl->ied->usr_ext))->terminal_id,chnl_usr->ip_str,chnl_usr->chnl->port);
|
||
|
||
}
|
||
}
|
||
}
|
||
}
|
||
|
||
//////////////////////*********相关控制操作**********////////////////////////////////////////////////
|
||
static ST_RET Read_Named_Var(LD_info_t *LD_info,chnl_usr_t *chnl_usr,char* VarName,ST_INT type_id, ST_VOID *dataDest, ST_INT timeOut)
|
||
{
|
||
ST_RET ret= SD_FAILURE;
|
||
ST_CHAR *domName = LD_info->LD_name;
|
||
int Need_Destroy_Typeid = FALSE;
|
||
assert(chnl_usr && LD_info);
|
||
if (type_id==-1) {
|
||
Need_Destroy_Typeid = TRUE;
|
||
type_id= mms_var_type_id_create (chnl_usr->net_info,DOM_SPEC, domName, VarName,timeOut);
|
||
if (type_id==-1) ret = SD_FAILURE; else ret = SD_SUCCESS;
|
||
if (ret == SD_FAILURE) return SD_FAILURE;
|
||
}
|
||
ret=mms_named_var_read (chnl_usr->net_info,VarName,DOM_SPEC, domName,type_id, dataDest, timeOut);
|
||
if (Need_Destroy_Typeid)
|
||
if (type_id!=-1) mvl_type_id_destroy(type_id);
|
||
return ret;
|
||
}
|
||
|
||
static ST_RET Write_Named_Var(LD_info_t *LD_info,chnl_usr_t *chnl_usr,char* VarName,ST_INT type_id, ST_VOID *dataDest, ST_INT timeOut)
|
||
{
|
||
ST_RET ret= SD_FAILURE;
|
||
ST_CHAR *domName = LD_info->LD_name;
|
||
int Need_Destroy_Typeid = FALSE;
|
||
assert(chnl_usr && LD_info);
|
||
if (type_id==-1) {
|
||
Need_Destroy_Typeid = TRUE;
|
||
type_id= mms_var_type_id_create (chnl_usr->net_info,DOM_SPEC, domName, VarName,timeOut);
|
||
if (type_id==-1) ret = SD_FAILURE; else ret = SD_SUCCESS;
|
||
if (ret == SD_FAILURE) return SD_FAILURE;
|
||
}
|
||
ret=mms_named_var_write(chnl_usr->net_info,VarName,DOM_SPEC, domName,type_id, dataDest, timeOut);
|
||
if (Need_Destroy_Typeid)
|
||
if (type_id!=-1) mvl_type_id_destroy(type_id);
|
||
return ret;
|
||
}
|
||
|
||
/*
|
||
<EnumType id="ctlModelsEnum">
|
||
<EnumVal ord="0">status-only</EnumVal>
|
||
<EnumVal ord="1">direct-with-normal-security</EnumVal>
|
||
<EnumVal ord="2">sbo-with-normal-security</EnumVal>
|
||
<EnumVal ord="3">direct-with-enhanced-security</EnumVal>
|
||
<EnumVal ord="4">sbo-with-enhanced-security</EnumVal>
|
||
</EnumType>
|
||
*/
|
||
|
||
|
||
#define TICKS_PER_MIN 60LL*1000LL*1000LL
|
||
|
||
|
||
int pt61850_write_cn_file(chnl_usr_t *chnl_usr, ied_t *ied, char *rem_filename, char *only_filename_ret)
|
||
{
|
||
int ret ;
|
||
|
||
char loc_filename[128], loc_file_fullname[256], rem_file_fullname[256],only_filename_str[256];
|
||
|
||
char *only_filename,*the_full_file;
|
||
|
||
memset(loc_filename,0,sizeof(loc_filename));
|
||
memset(only_filename_str,0,sizeof(only_filename_str) );
|
||
|
||
strcat(only_filename_str,rem_filename);
|
||
only_filename = only_filename_str;
|
||
the_full_file = only_filename_str;
|
||
while ( *the_full_file != 0 ) {
|
||
if (*the_full_file == '/')
|
||
only_filename=the_full_file+1;
|
||
the_full_file++;
|
||
}
|
||
|
||
memset(rem_file_fullname,0,sizeof(rem_file_fullname) );
|
||
if (strstr(rem_filename,"/")!= NULL) {
|
||
strcat(rem_file_fullname,rem_filename);
|
||
}
|
||
else {
|
||
strcat(rem_file_fullname,g_pt61850app->accPath);
|
||
strcat(rem_file_fullname,rem_filename);
|
||
}
|
||
|
||
memset(loc_file_fullname,0,sizeof(loc_file_fullname) );
|
||
apr_snprintf(loc_file_fullname,sizeof(loc_file_fullname),"../comtrade/%s",only_filename);
|
||
apr_snprintf(only_filename_ret,256,"%s",only_filename);
|
||
printf("\n >>>>>>>>>****** Get wave file : %s from %s\n",loc_file_fullname,rem_file_fullname);
|
||
|
||
ret = mms_getFile(chnl_usr->net_info,loc_file_fullname,rem_file_fullname,g_pt61850app->mmsOpTimeout);
|
||
if (ret==SD_SUCCESS) {
|
||
|
||
}
|
||
else {
|
||
echo_warn3(">>>>>**** Error!!! %s mms_getFile wave file : %s from %s\n",chnl_usr->ip_str ,loc_file_fullname,rem_file_fullname);
|
||
}
|
||
return ret;
|
||
}
|
||
|
||
apr_status_t prepare_call_cn_wavelist(LD_info_t *LD_info, int FltNum)
|
||
{
|
||
int i;
|
||
|
||
for (i=0;i<256;i++) {
|
||
if (LD_info->FltNum[i]<=0) {
|
||
LD_info->FltNum[i] = FltNum;
|
||
break;
|
||
}
|
||
}
|
||
return APR_SUCCESS;
|
||
}
|
||
|
||
apr_status_t call_cn_wavelist(LD_info_t *LD_info )
|
||
{
|
||
int ret ;
|
||
int chnl_no;
|
||
chnl_usr_t *chnl_usr = NULL;
|
||
char **filenames;
|
||
int filenum ;
|
||
int i;
|
||
char file_match_str[65];
|
||
char *ldstr;
|
||
ied_t *ied = LD_info->ied;
|
||
ied_usr_t *ied_usr = GET_IEDEXT_ADDR(ied);
|
||
int have_new_files = FALSE;
|
||
|
||
//监测点日志的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
|
||
|
||
for (i=0;i<256;i++) {
|
||
if (LD_info->FltNum[i]<=0)
|
||
continue;
|
||
|
||
//LD名称规范四字节：PQMn, 或者PQLDn ,有5个字节， 但也只取4个字符进行匹配
|
||
ldstr = LD_info->LD_name+strlen(LD_info->LD_name)-4;
|
||
apr_snprintf(file_match_str,sizeof(file_match_str),"%s_%06d",ldstr,LD_info->FltNum[i]);
|
||
|
||
printf(">>>>>>>> IED [%d]: %s is calling cn wavefile, !!!!!!!! file_match_str=%s \n",ied->id,ied->name,file_match_str);
|
||
|
||
//mq日志
|
||
DIY_INFOLOG(full_key_m_c,"【NORMAL】监测点:%s - id:%s开始召唤录波文件", LD_info->name,LD_info->mp_id);
|
||
|
||
ret = SD_FAILURE;
|
||
filenum = 0;
|
||
assert(ied->chncount);
|
||
for(chnl_no=0 ; chnl_no<ied->chncount; chnl_no++) {
|
||
chnl_usr = (chnl_usr_t*)ied->channel[chnl_no].connect;
|
||
if (chnl_usr->m_state!=CHANNEL_CONNECTED)
|
||
continue;
|
||
ret = mms_mvla_fdir(chnl_usr->net_info,g_pt61850app->accPath,3*g_pt61850app->mmsOpTimeout,&filenames,&filenum,g_pt61850app->tmp_pool);
|
||
if (ret==SD_SUCCESS)
|
||
break;
|
||
}
|
||
if (ret==SD_SUCCESS) {
|
||
int cfg_idx,dat_idx;
|
||
char file_base_name[128];
|
||
char file_yyyymm[128];
|
||
char cfg_only_filename_ret[256];
|
||
char dat_only_filename_ret[256];
|
||
int ret2,ret3;
|
||
|
||
//mq日志
|
||
DIY_INFOLOG(full_key_m_c,"【NORMAL】监测点:%s - id:%s获取录波文件列表成功,开始匹配录波文件", LD_info->name,LD_info->mp_id);
|
||
|
||
//WW 2023-11-01将录波段号由字符串匹配修改为int的fltnum匹配
|
||
ret2 = parse_file_names_by_fltnum(LD_info->FltNum[i], ldstr, filenames, filenum, &cfg_idx, &dat_idx, file_base_name, file_yyyymm);
|
||
//WW 2023-11-01 end
|
||
if (ret2 !=APR_SUCCESS){
|
||
//mq日志
|
||
DIY_WARNLOG(full_key_m_c,"【WARN】监测点:%s - id:%s匹配录波文件失败", LD_info->name,LD_info->mp_id);
|
||
return ret2;
|
||
}
|
||
|
||
//完成录波文件，记录在文件名dat/cfg_only_filename_ret中，两个后缀不一样的录波文件，要上传两次
|
||
ret2 = pt61850_write_cn_file(chnl_usr,ied,filenames[cfg_idx],cfg_only_filename_ret);
|
||
ret3 = pt61850_write_cn_file(chnl_usr,ied,filenames[dat_idx],dat_only_filename_ret);
|
||
have_new_files = TRUE;
|
||
|
||
/////////////////////////////////////////////////////////////////////////////////////////////上传文件
|
||
if (ret2==SD_SUCCESS && ret3==SD_SUCCESS ) { //两个文件都写好了
|
||
|
||
//mq日志
|
||
DIY_INFOLOG(full_key_m_c,"【NORMAL】监测点:%s - id:%s从终端获取录波文件成功,开始上传录波文件到web并更新暂态事件", LD_info->name,LD_info->mp_id);
|
||
|
||
QVVR_t *qvvr; //暂态事件
|
||
long long start_tm,trig_tm,end_tm;
|
||
|
||
ret2 = extract_timestamp_from_cfg_file(filenames[cfg_idx],&start_tm,&trig_tm);//提取文件的开始时间和触发时间
|
||
printf(">>>>>>>> extract_timestamp_from_cfg_file end \n");
|
||
if (ret2 ==APR_SUCCESS) {
|
||
//to find the paired qvvr by the time of trig_tm
|
||
printf(">>>>>>>> extract_timestamp_from_cfg_file success \n");
|
||
qvvr = find_qvvr_by_trig_tm(LD_info,trig_tm); //根据文件的触发时间查找检测点记录的匹配上的暂态事件
|
||
if (qvvr) {
|
||
char* uuid_cfg = (char*)malloc(65 * sizeof(char));//上传文件后获取到的路径
|
||
char* uuid_dat = (char*)malloc(65 * sizeof(char));
|
||
char* filename_cfg = (char*)malloc(100 * sizeof(char));//上传文件后获取到的文件名
|
||
char* filename_dat = (char*)malloc(100 * sizeof(char));
|
||
|
||
//lnk202411-5 记录web返回的路径+文件名
|
||
char* wavepath_cfg = (char*)malloc(256 * sizeof(char));
|
||
char* wavepath_dat = (char*)malloc(256 * sizeof(char));
|
||
/*上传.cfg和.dat两个文件*/
|
||
char linux_cmd[256] = {0};
|
||
printf(">>>>>>>> qvvr ok end \n");
|
||
apr_snprintf(linux_cmd,sizeof(linux_cmd),"./sftp_upload %s %s/%04d",cfg_only_filename_ret,file_yyyymm,LD_info->line_id);//没有使用
|
||
|
||
char loc_file_fullname_cfg[256];//本地文件名
|
||
memset(loc_file_fullname_cfg, 0, sizeof(loc_file_fullname_cfg));
|
||
apr_snprintf(loc_file_fullname_cfg, sizeof(loc_file_fullname_cfg), "/home/pq/FeProject/comtrade/%s", cfg_only_filename_ret);
|
||
char oss_file_fullname_cfg[256];//远端文件名
|
||
memset(oss_file_fullname_cfg, 0, sizeof(oss_file_fullname_cfg));
|
||
apr_snprintf(oss_file_fullname_cfg, sizeof(oss_file_fullname_cfg), "comtrade/wave/%s/%s", LD_info->mp_id, cfg_only_filename_ret);
|
||
if (FILE_FLAG == 1) {
|
||
PutOSS(oss_file_fullname_cfg, loc_file_fullname_cfg);//使用buffer推送文件
|
||
}
|
||
else if (FILE_FLAG == 2) {
|
||
OBSFile(loc_file_fullname_cfg, oss_file_fullname_cfg, "putObject");//这里并没有上传文件流
|
||
}
|
||
else if(FILE_FLAG==3){
|
||
WebAPI_Uds_Upload(UDS_UPLOAD_URL, loc_file_fullname_cfg, uuid_cfg, filename_cfg);//通过form-data上传文件
|
||
}
|
||
//LNK20241031使用JSON编码文件上传-具体的远端路径可以用原本代码的硬编码或者在配置文件中获取
|
||
else if (FILE_FLAG == 4) {
|
||
char mq_file_fullname_cfg[256]; // 远端文件名
|
||
memset(mq_file_fullname_cfg, 0, sizeof(mq_file_fullname_cfg));
|
||
|
||
// 使用修改后的文件名传入 apr_snprintf
|
||
apr_snprintf(mq_file_fullname_cfg, sizeof(mq_file_fullname_cfg), "comtrade/%s/",
|
||
LD_info->ied->channel[0].addr_str);
|
||
|
||
SOEFileWeb(loc_file_fullname_cfg, mq_file_fullname_cfg, wavepath_cfg);
|
||
|
||
printf("\n>>>>>>!! %s %s...... \n", mq_file_fullname_cfg, loc_file_fullname_cfg);
|
||
}
|
||
|
||
if (FILE_FLAG == 4) {
|
||
|
||
}
|
||
else{
|
||
printf("\n>>>>>>!! %s %s...... \n", oss_file_fullname_cfg, loc_file_fullname_cfg);
|
||
}
|
||
|
||
apr_snprintf(linux_cmd,sizeof(linux_cmd),"./sftp_upload %s %s/%04d",dat_only_filename_ret,file_yyyymm,LD_info->line_id);//先通过sftp上传才发json过去
|
||
|
||
char loc_file_fullname_dat[256];
|
||
memset(loc_file_fullname_dat, 0, sizeof(loc_file_fullname_dat));
|
||
apr_snprintf(loc_file_fullname_dat, sizeof(loc_file_fullname_dat), "/home/pq/FeProject/comtrade/%s", dat_only_filename_ret);
|
||
char oss_file_fullname_dat[256];
|
||
memset(oss_file_fullname_dat, 0, sizeof(oss_file_fullname_dat));
|
||
apr_snprintf(oss_file_fullname_dat, sizeof(oss_file_fullname_dat), "comtrade/wave/%s/%s", LD_info->mp_id, dat_only_filename_ret);
|
||
if (FILE_FLAG == 1) {
|
||
PutOSS(oss_file_fullname_dat, loc_file_fullname_dat);//使用buffer推送文件
|
||
}
|
||
else if (FILE_FLAG == 2) {
|
||
OBSFile(loc_file_fullname_dat, oss_file_fullname_dat, "putObject");//这里并没有上传文件流
|
||
}
|
||
else if(FILE_FLAG==3){
|
||
WebAPI_Uds_Upload(UDS_UPLOAD_URL, loc_file_fullname_dat, uuid_dat, filename_dat);//通过form-data上传文件
|
||
}
|
||
//LNK20241031使用JSON编码文件上传-具体的远端路径可以用原本代码的硬编码或者在配置文件中获取
|
||
else if (FILE_FLAG == 4) {
|
||
char mq_file_fullname_dat[256]; // 远端文件名
|
||
memset(mq_file_fullname_dat, 0, sizeof(mq_file_fullname_dat));
|
||
|
||
// 使用修改后的文件名传入 apr_snprintf
|
||
apr_snprintf(mq_file_fullname_dat, sizeof(mq_file_fullname_dat), "comtrade/%s/",
|
||
LD_info->ied->channel[0].addr_str);
|
||
|
||
SOEFileWeb(loc_file_fullname_dat, mq_file_fullname_dat, wavepath_dat);
|
||
|
||
printf("\n>>>>>>!! %s %s...... \n", mq_file_fullname_dat, loc_file_fullname_dat);
|
||
}
|
||
|
||
if (FILE_FLAG == 4) {
|
||
|
||
}
|
||
else{
|
||
printf("\n>>>>>>!! %s %s...... \n", oss_file_fullname_dat, loc_file_fullname_dat);
|
||
}
|
||
|
||
/*上传.cfg和.dat两个文件*/
|
||
/*上传消息*/
|
||
/////////////////////////////////////////////////////lnk20250520
|
||
//根据配置文件控制上传的暂态事件时间为北京时间的ms数
|
||
printf("~~~~~~~this dev type is %s~~~~~~~",ied_usr->dev_type);
|
||
XmlConfigC cfg1;
|
||
if (get_xml_config_by_dev_type(ied_usr->dev_type, &cfg1)) {
|
||
printf("UnitOfTimeUnit = %s\n", cfg1.UnitOfTimeUnit);
|
||
printf("ValueOfTimeUnit = %s\n", cfg1.ValueOfTimeUnit);
|
||
} else {
|
||
printf("读取失败，未找到 dev_type\n");
|
||
}
|
||
double s_or_ms;
|
||
long long utc_or_beijing;
|
||
if(strcmp(cfg1.UnitOfTimeUnit, "1") == 0){//持续时间上送的是秒1还是毫秒0
|
||
s_or_ms = 0.001;
|
||
}
|
||
else{
|
||
s_or_ms = 1.0;
|
||
}
|
||
|
||
if(strcmp(cfg1.ValueOfTimeUnit, "utc") == 0){//上送的是utc还是北京
|
||
utc_or_beijing = 28800000;
|
||
}
|
||
else{
|
||
utc_or_beijing = 0;
|
||
}
|
||
/////////////////////////////////////////////////////
|
||
|
||
//to send json of this qvvr and rdre
|
||
end_tm = (long long)(qvvr->QVVR_PerTime*1000) + trig_tm; //结束时间是持续时间加触发时间
|
||
if (FILE_FLAG == 3) {
|
||
size_t cfg_len = strlen(uuid_cfg) + strlen(filename_cfg) + 3; // 额外的3个字符用于"-"和结束符'\0'
|
||
char* cfg_result = (char*)malloc(cfg_len * sizeof(char)); // 动态分配足够的内存空间
|
||
size_t dat_len = strlen(uuid_dat) + strlen(filename_dat) + 3; // 额外的3个字符用于"-"和结束符'\0'
|
||
char* dat_result = (char*)malloc(dat_len * sizeof(char)); // 动态分配足够的内存空间
|
||
if (cfg_result != NULL && dat_result != NULL) {
|
||
snprintf(cfg_result, cfg_len, "%s-%s", uuid_cfg, filename_cfg); // 拼接字符串并确保不会溢出目标缓冲区
|
||
snprintf(dat_result, dat_len, "%s-%s", uuid_dat, filename_dat); // 拼接字符串并确保不会溢出目标缓冲区
|
||
ret3 = transfer_json_qvvr_data(g_node_id,
|
||
LD_info->line_id,
|
||
(double)qvvr->QVVR_Amg,
|
||
(double)qvvr->QVVR_PerTime/s_or_ms, //lnk20250520上送的暂态持续时间为毫秒
|
||
start_tm + utc_or_beijing, //lnk20250520上送的暂态时间为北京时间
|
||
end_tm + utc_or_beijing, //lnk20250520上送的暂态时间为北京时间
|
||
qvvr->QVVR_type,
|
||
cfg_result,
|
||
dat_result,
|
||
LD_info->mp_id,
|
||
qvvr->QVVR_Rptname,
|
||
ied_usr->dev_type);
|
||
}
|
||
free(cfg_result); // 使用完毕后释放动态分配的内存空间
|
||
free(dat_result); // 使用完毕后释放动态分配的内存空间
|
||
}
|
||
else if(FILE_FLAG==4)//lnk20241031发送暂态web消息
|
||
{
|
||
//内存分配部分不修改
|
||
size_t cfg_len = strlen(wavepath_cfg) + 1;
|
||
char* cfg_result = (char*)malloc(cfg_len * sizeof(char)); // 动态分配足够的内存空间
|
||
size_t dat_len = strlen(wavepath_dat) + 1;
|
||
char* dat_result = (char*)malloc(dat_len * sizeof(char)); // 动态分配足够的内存空间
|
||
|
||
if (cfg_result != NULL && dat_result != NULL) {
|
||
snprintf(cfg_result, cfg_len, wavepath_cfg); // 拼接字符串并确保不会溢出目标缓冲区
|
||
snprintf(dat_result, dat_len, wavepath_dat); // 拼接字符串并确保不会溢出目标缓冲区
|
||
ret3 = transfer_json_qvvr_data(g_node_id, //这个参数没有使用
|
||
LD_info->line_id, //监测点序号
|
||
(double)qvvr->QVVR_Amg,
|
||
(double)qvvr->QVVR_PerTime/s_or_ms, //lnk20250520上送的暂态持续时间为毫秒
|
||
qvvr->QVVR_time + utc_or_beijing, //lnk20250520上送的暂态时间为北京时间 //这里不使用文件中的开始时间start_tm，因为会影响写库，使用QVVR的时间QVVR_time//lnk20250311
|
||
end_tm + utc_or_beijing, //lnk20250520上送的暂态时间为北京时间
|
||
qvvr->QVVR_type, //伏值、持续时间、开始时间、结束时间、暂态类型
|
||
cfg_result,
|
||
dat_result, //两个文件路径
|
||
LD_info->mp_id,
|
||
qvvr->QVVR_Rptname,
|
||
ied_usr->dev_type);//监测点号，文件和监测点暂态事件匹配上的暂态报告名，终端类型
|
||
}
|
||
free(cfg_result); // 使用完毕后释放动态分配的内存空间
|
||
free(dat_result); // 使用完毕后释放动态分配的内存空间
|
||
}
|
||
else if (FILE_FLAG == 1 || FILE_FLAG == 2)
|
||
{
|
||
size_t cfg_len = strlen(oss_file_fullname_cfg) + strlen(cfg_only_filename_ret) + 3; // 额外的3个字符用于"-"和结束符'\0'
|
||
char* cfg_result = (char*)malloc(cfg_len * sizeof(char)); // 动态分配足够的内存空间
|
||
size_t dat_len = strlen(oss_file_fullname_dat) + strlen(dat_only_filename_ret) + 3; // 额外的3个字符用于"-"和结束符'\0'
|
||
char* dat_result = (char*)malloc(dat_len * sizeof(char)); // 动态分配足够的内存空间
|
||
if (cfg_result != NULL && dat_result != NULL) {
|
||
snprintf(cfg_result, cfg_len, "%s-%s", oss_file_fullname_cfg, cfg_only_filename_ret); // 拼接字符串并确保不会溢出目标缓冲区
|
||
snprintf(dat_result, dat_len, "%s-%s", oss_file_fullname_dat, dat_only_filename_ret); // 拼接字符串并确保不会溢出目标缓冲区
|
||
ret3 = transfer_json_qvvr_data(g_node_id,
|
||
LD_info->line_id,
|
||
(double)qvvr->QVVR_Amg,
|
||
(double)qvvr->QVVR_PerTime/s_or_ms, //lnk20250520上送的暂态持续时间为毫秒
|
||
start_tm + utc_or_beijing, //lnk20250520上送的暂态时间为北京时间
|
||
end_tm + utc_or_beijing, //lnk20250520上送的暂态时间为北京时间
|
||
qvvr->QVVR_type,
|
||
cfg_result,
|
||
dat_result,
|
||
LD_info->mp_id,
|
||
qvvr->QVVR_Rptname,
|
||
ied_usr->dev_type);
|
||
}
|
||
free(cfg_result); // 使用完毕后释放动态分配的内存空间
|
||
free(dat_result); // 使用完毕后释放动态分配的内存空间
|
||
}
|
||
/*上传消息*/
|
||
qvvr->used_status = QVVR_DATA_NOT_USED;//上传信息后这个qvvr的状态置为未使用
|
||
free(uuid_cfg);
|
||
free(uuid_dat);
|
||
free(filename_cfg);
|
||
free(filename_dat);
|
||
|
||
//lnk 202411-5
|
||
free(wavepath_cfg);
|
||
free(wavepath_dat);
|
||
|
||
}
|
||
}
|
||
}
|
||
|
||
}
|
||
else {
|
||
if (ied && chnl_usr){
|
||
echo_warn2("mms_mvla_fdir Failed: IED [%d] %s \n", ied->id , chnl_usr->ip_str) ;
|
||
//mq日志
|
||
DIY_WARNLOG(full_key_m_c,"【WARN】监测点:%s - id:%s召唤录波文件失败", LD_info->name,LD_info->mp_id);
|
||
}
|
||
|
||
return APR_EAGAIN;
|
||
}
|
||
LD_info->FltNum[i]= -1;
|
||
}
|
||
|
||
if (have_new_files)
|
||
clear_old_comtrade_files();
|
||
|
||
return APR_SUCCESS;
|
||
}
|
||
|
||
//lnk 2024-11-4 添加时间转换函数
|
||
char* convertMsToDateTimeString(int64_t usTime) {
|
||
// 确保时间戳是有效的
|
||
if (usTime < 0) {
|
||
return "Invalid timestamp";
|
||
}
|
||
|
||
// 将 `apr_time_t` 微秒（us）转换为 `time_t` 秒（s）
|
||
time_t seconds = usTime / 1000000;
|
||
|
||
// 用 `struct tm` 变量存储时间
|
||
struct tm timeInfo;
|
||
// **使用 `localtime_r()` 考虑系统时区**
|
||
localtime_r(&seconds, &timeInfo);
|
||
|
||
// 静态分配的字符数组存储转换后的字符串
|
||
static char buffer[30];
|
||
strftime(buffer, sizeof(buffer), "%Y-%m-%d %H:%M:%S", &timeInfo);
|
||
|
||
return buffer;
|
||
}
|
||
|