T536_DTU/dtu/dtu_main_t536/app/SOE.c

/************************************************************************* 
* 版权所有：	
* 文件版本： V1.00
* 文件名称：SOE.c
* 生成日期： 2008年9月1日
* 作	者： xxxxxx
* 功	能： 事件记录处理
* 更新信息：
	2015-11-02  
		增强了SOE处理时资源竞争保护，此次增强基于以下假设
		1、除了优先级别低于主循环的地方外，可以在其它各个优先级别调用SOE记录函数。
		2、处理SOE必须在主循环中，也就是说优先级别最低的地方。
*/
/*------------------------------- 头文件 --------------------------------------
*/
#include "head.h"


/*------------------------------- 宏定义 --------------------------------------
*/
#define RCDTYPE_EVENT	1
#define RCDTYPE_YX		2

#define SOE_SAVE_BUF_NUM 	64


/*-------------------------------类型结构--------------------------------------
*/
/*------------------------------ 全局变量 -------------------------------------
*/
u32 		g_ev_words[EV_NUMBER_WORDS];  	// 所有事件的状态保存
SOE_QUEUE 	g_soe_queue;  					// 事件队列
SOE_INF 	g_soe_info;       				// 系统事件的信息结构
int			g_soe_test;

static EVENT_SAVE g_soe_sbuf[SOE_SAVE_BUF_NUM]; // SOE保存加速BUF
#ifdef ADD_DEBUG_RECORD_AUTO_SHOW_FUN
const u16 ExecuteEventIdTbl[]={EV_GL1TZ,EV_GL2TZ,EV_GL3TZ,
                               EV_LX1TZ,EV_LX2TZ,
	                           EV_LX3TZ,
                               EV_GLJS,EV_LXJS,EV_FA_GL_TZ,	
                            #if defined GD_AREA_ECZD_2020
	                           EV_FA_GL_TZ2,
                            #endif 
                               EV_FA_LX_TZ,EV_AR1,EV_AR2,EV_AR3,EV_ARBS,EV_U0TZ,EV_XBBS,EV_BS_ALL,
       	                       EV_BS_FZMORE,EV_TQHZ,EV_GGDY_TZ,EV_GDDY_TZ,EV_GDY_TZ,EV_DDY_TZ,EV_LOWPL_TZ,EV_GPL_TZ,EV_DPL_TZ, 
       	                       EV_GOOSE_QC_QD,EV_GOOSE_GL_QD,EV_GOOSE_HZ_QD,EV_GOOSE_GL_TZ, 
                            #if defined GD_AREA_ZHONGSHAN || defined GD_AREA_ZHONGSHAN_2020
	                           EV_GOOSE_GL2_TZ, 		// 过流2段跳闸
                            #endif
                            #ifdef GD_AREA_ZHONGSHAN_2020
	                           EV_GOOSE_HZ_GL1,EV_GOOSE_HZ_GL2,EV_GOOSE_HZ_LX,EV_BSTZ,	
                            #endif                            
	                           EV_GOOSE_LX_TZ,EV_GOOSE_SDLOST_TZ,EV_GOOSE_ERRLOST_TZ,EV_GOOSE_EXT_TZ,EV_BSTZ,EV_FA_FZ,
		                       EV_BS_U0,EV_HHGZ,EV_HHGZ_P,EV_HHGZ_L,EV_BSTZ_FA,EV_FA_HZ,EV_FA_LL_HZ,EV_FA_FZ,	                           
	                        #ifdef XDL_ZT	
	                           EV_LX_XDL_TZ,		// 零序小电流跳闸	
	                        #endif
	                           EV_GOOSE_ERR,
	                           EV_SYS_GOOSE_ERR,
	                           EV_PT1ERR,EV_PT2ERR,
	                           EV_BS_UF_P,EV_BS_UF_L,
	                           
	                           
};    //TODO: add param
#define  EXECUTE_EVENT_NUM   (sizeof(ExecuteEventIdTbl)/sizeof(u16))
#endif

/*------------------------------ 函数声明 -------------------------------------
 */

/*------------------------------ 外部函数 -------------------------------------
外部函数供其它实体文件引用，必须仔细检查传入参数的合法性.
*/
// 遥信取SOE BUF，因为遥信处理在最高优先级，所以可以不用屏蔽中断
// 如果采用屏蔽中断的方式，在10个遥信同时动作的情况下，一次遥信处理会多消耗38us。
EVENT_SAVE *soe_get_buffer_yx(void)
{
    u16 i, head;
    head = g_soe_queue.head.n++;

    if (g_soe_queue.head.n == g_soe_queue.tail_eep.n)
    {
        g_soe_queue.tail_eep.n++;
        g_soe_queue.stat_eep_over++;
    }

    // 缓冲区满了，调整tail_send和tail_ack
    for (i = 0; i < COMM_CHANNEL_NUM; i++)
    {
        if (g_soe_queue.head.n == g_soe_queue.tail_send[i].n)
        {
            g_soe_queue.tail_send[i].n++;
            g_soe_queue.stat_send_over[i]++;
        }

        if (g_soe_queue.head.n == g_soe_queue.tail_ack[i].n)
        {
            g_soe_queue.tail_ack[i].n++;
            g_soe_queue.stat_ack_over[i]++;
        }
    }

    // 保存标志清零，防止不该有的事件确认
    g_soe_queue.soe[head].es_flag = 0;

    // 唤醒主循环
    mainloop_wakeup();

    return &g_soe_queue.soe[head];
}

EVENT_SAVE *soe_get_buffer(u16 *extarg)
{
    u16 i, head;
    uint32_t flags;

    rt_irq_save(flags);
    head = g_soe_queue.head.n++;
    rt_irq_restore(flags);

    rt_irq_save(flags);
    if (g_soe_queue.head.n == g_soe_queue.tail_eep.n)
    {
        g_soe_queue.tail_eep.n++;
        g_soe_queue.stat_eep_over++;
    }
    rt_irq_restore(flags);

    // 缓冲区满了，调整tail_send和tail_ack
    for (i = 0; i < COMM_CHANNEL_NUM; i++)
    {
        rt_irq_save(flags);
        if (g_soe_queue.head.n == g_soe_queue.tail_send[i].n)
        {
            g_soe_queue.tail_send[i].n++;
            g_soe_queue.stat_send_over[i]++;
        }

        if (g_soe_queue.head.n == g_soe_queue.tail_ack[i].n)
        {
            g_soe_queue.tail_ack[i].n++;
            g_soe_queue.stat_ack_over[i]++;
        }
        rt_irq_restore(flags);
    }

    // 保存标志清零，防止不该有的事件确认
    g_soe_queue.soe[head].es_flag = 0;

    // 唤醒主循环
    mainloop_wakeup();

    if (extarg != NULL)
        *extarg = head;
    return &g_soe_queue.soe[head];
}

void soe_init(void)
{
    u32 i, addr;
    u16 index;
    EVENT_SAVE tEvt;

    // 清零事件状态和事件队列
    // 以下1行需屏蔽
    // 原因1:定值初始化中会对开出软压板定值及对应事件状态初始化，此处会把该初始化清0
    // 原因2:手动清除事件和操作时，会把当前事件的标志清0，会对事件的管理造成混乱
    // memset(&g_ev_words,0,sizeof(g_ev_words));
    memset(&g_soe_queue, 0, sizeof(g_soe_queue));

    // 事件保存信息初始化
    g_soe_info.wEvIndex = -1;
    g_soe_info.wEvNumber = 0;
    g_soe_info.wEvID = 0;
    g_soe_info.wEvAck = 0;
    g_soe_info.wOpIndex = -1;
    g_soe_info.wOpNumber = 0;
    g_soe_info.wOpID = 0;

    g_soe_info.wVipIndex = -1;
    g_soe_info.wVipNumber = 0;
    g_soe_info.wVipID = 0;

#ifdef ADD_DEBUG_RECORD_FUN
    g_soe_info.wDebugIndex = -1;
    g_soe_info.wDebugNumber = 0;
    g_soe_info.wDebugID = 0;
#endif
    // 统计事件记录信息
    for (i = 0; i < MAX_EVENT_NUMBER; i++)
    {
        addr = EEP_SOE_ADDR + i * (sizeof(EVENT_SAVE));
        e2prom_read(addr, (u8 *)&tEvt, sizeof(EVENT_SAVE));
        if (tEvt.es_flag != SOE_ID_MASK)
        {
            break;
        }
        if ((s16)(tEvt.es_id - g_soe_info.wEvID) > 0)
        {
            g_soe_info.wEvIndex = i;
            g_soe_info.wEvID = tEvt.es_id;
        }
        g_soe_info.wEvNumber++;
    }
    g_soe_info.wEvID++;

    // 统计操作记录信息
    for (i = 0; i < MAX_OPERATE_NUMBER; i++)
    {
        addr = EEP_OPERATE_ADDR + i * (sizeof(EVENT_SAVE));
        e2prom_read(addr, (u8 *)&tEvt, sizeof(EVENT_SAVE));
        if (tEvt.es_flag != SOE_ID_MASK)
        {
            break;
        }
        if ((s16)(tEvt.es_id - g_soe_info.wOpID) > 0)
        {
            g_soe_info.wOpIndex = i;
            g_soe_info.wOpID = tEvt.es_id;
        }
        g_soe_info.wOpNumber++;
    }
    g_soe_info.wOpID++;
    // 统计关键记录信息
    for (i = 0; i < MAX_VIP_NUMBER; i++)
    {
        addr = EEP_VIP_ADDR + i * (sizeof(EVENT_SAVE));
        e2prom_read(addr, (u8 *)&tEvt, sizeof(EVENT_SAVE));
        if (tEvt.es_flag != SOE_ID_MASK)
        {
            break;
        }
        if ((s16)(tEvt.es_id - g_soe_info.wVipID) > 0)
        {
            g_soe_info.wVipIndex = i;
            g_soe_info.wVipID = tEvt.es_id;
        }
        g_soe_info.wVipNumber++;
    }
    g_soe_info.wVipID++;
    // #ifdef ADD_DEBUG_RECORD_FUN
    for (i = 0; i < MAX_DEBUG_RECORD_NUMBER; i++)
    {
        addr = EEP_DEBUG_RECORD_ADDR + i * (sizeof(EVENT_SAVE));
        e2prom_read(addr, (u8 *)&tEvt, sizeof(EVENT_SAVE));
        if (tEvt.es_flag != SOE_ID_MASK)
        {
            break;
        }
        // if((s16)(tEvt.es_id - g_soe_info.wVipID) > 0)   //可考虑去除此判断
        {
            g_soe_info.wDebugIndex = i;
            // g_soe_info.wVipID=tEvt.es_id;
        }
        g_soe_info.wDebugNumber++;
    }
    // #endif

    // 如果SOE上电续传没有投入，直接返回
    if (pRunSet->bTT_SoeResumePower == 0)
    {
        return;
    }

    // 将后台没有确认的事件导入事件队列
    index = g_soe_info.wEvIndex + 1;
    for (i = 0; i < MAX_EVENT_NUMBER; i++)
    {
        // 调整索引
        if (index == MAX_EVENT_NUMBER)
        {
            index = 0;
        }

        // 取出事件
        addr = EEP_SOE_ADDR + index * (sizeof(EVENT_SAVE));
        e2prom_read(addr, (u8 *)&tEvt, sizeof(EVENT_SAVE));

        // 如果是没有确认的事件，放入事件队列
        //	rt_printf("soe_init:index=%04d,flag=%02x,ack=%02x.\r\n",index,tEvt.es_flag,tEvt.es_ack);
        if ((tEvt.es_flag == SOE_ID_MASK) && (tEvt.es_ack == SOE_ID_ACK_NONE))
        {
            EVENT_SAVE *ev = soe_get_buffer(NULL);
            *ev = tEvt;
            ev->es_id = addr - EEP_SOE_BASE;

            g_soe_info.wEvAck++;
        }

        index++;
    }

    // 保证事件队列中没有确认的事件不会重新保存
    g_soe_queue.tail_eep.n = g_soe_queue.head.n;
}

int soe_ev_set(u16 code, u8 v)
{
    if (code >= EV_NUMBER)
    {
        return -1;
    }

    if (code < EV_PUB_START)
    {
        g_sw[code / EV_SW_NUM].di[code % EV_SW_NUM + SW_DI_NUM] = v ? SW_DI_TYPE_ON : SW_DI_TYPE_OFF;
    }
    else
    {
        g_sw_pub.di[code - EV_PUB_START + PUB_DI_NUM] = v ? SW_DI_TYPE_ON : SW_DI_TYPE_OFF;
    }

    if (v)
    {
        g_ev_words[code / 32] |= (1 << (code % 32)); // 状态更新
    }
    else
    {
        g_ev_words[code / 32] &= ~(DWORD)(1 << (code % 32)); // 状态更新
    }

    return 0;
}

u16 soe_lp2cp(u8 ev_type, u16 ev_code, s32 is_mix)
{
    int index;
    u16 cp = 0;
    u8 slot, no;

    switch (ev_type & SOE_TYPE_MASK)
    {
    // 事件通讯点从逻辑单点数组中找
    case SOE_TYPE_EV:
        if (ev_code < EV_PUB_END)
        {
            // index = ev_code + PUB_DI_NUM+(SW_DI_NUM*SWITCH_NUM_MAX);
            if (ev_code < EV_PUB_START)
            {
                int sw;
                sw = ev_code / EV_SW_NUM;
                index = ev_code % EV_SW_NUM;
                index = PUB_DI_NUM_ALL + sw * SW_DI_NUM_ALL + SW_DI_NUM + index;
            }
            else
            {
                index = ev_code - EV_PUB_START + PUB_DI_NUM;
            }
            cp = g_lp[index].cp;
        }
        break;
    // 遥信事件通讯点从逻辑单点数组中找
    case SOE_TYPE_YX:
        slot = ev_code >> 8;
        no = ev_code & 0xff;
        index = plc_yx2index(g_di_st[slot][no].owner, g_di_st[slot][no].type);
        if (index >= 0)
        {
            cp = g_lp[index].cp;
        }
        break;
    // 级联事件通讯点
    case SOE_TYPE_LNK:
        if (is_mix == 0)
            cp = ev_code; // 若是级联点是合并点，不上送，由PLC逻辑上送
        break;
    // 双点事件通讯点从转发点表中的双点部分找
    case SOE_TYPE_DPI:
        if (ev_code < g_table_head->di_db_num)
        {
            cp = g_di_db_table[ev_code].cp;
        }
        break;
    // PLC事件通讯点从PLC结构数组中找
    case SOE_TYPE_PLC:
        if (ev_code < g_plc_num)
        {
            cp = g_plc[ev_code].cp;
        }
        break;
    // 测试事件通讯点直接传送
    case SOE_TYPE_TST:
        cp = ev_code;
        break;
    // 操作事件不送后台
    case SOE_TYPE_OPT:
        cp = 0;
        break;
    }

    return cp;
}

void soe_ext_arg(u16 index, u32 sw)
{
    EVENT_EXT_ARG *pArg;
    int ui_begin;
    if (sw > 0 && sw <= SWITCH_NUM_MAX)
    {
        sw -= 1;
    }
    else
    {
        sw = 0;
    }
    pArg = &g_soe_queue.tExtArg[index]; // 附加参数
    ui_begin = UI_SW_INDEX_BEGIN(sw);
    pArg->arg[0] = _Mul_Div_U(sqrt_32fix(g_ui[ui_begin + SW_AC_IA].m2[0]), 256, g_ui[ui_begin + SW_AC_IA].m2_factor_k);
    pArg->arg[1] = _Mul_Div_U(sqrt_32fix(g_ui[ui_begin + SW_AC_IB].m2[0]), 256, g_ui[ui_begin + SW_AC_IB].m2_factor_k);
    pArg->arg[2] = _Mul_Div_U(sqrt_32fix(g_ui[ui_begin + SW_AC_IC].m2[0]), 256, g_ui[ui_begin + SW_AC_IC].m2_factor_k);
    pArg->arg[3] = _Mul_Div_U(sqrt_32fix(g_ui[ui_begin + SW_AC_I0].m2[0]), 256, g_ui[ui_begin + SW_AC_I0].m2_factor_k);

    if (pRunSet->tSwSet[sw].bTT_Power_v2)
    {
        pArg->arg[4] = _Mul_Div_U(sqrt_32fix(g_ui[PUB_AC_UA2].m2[0]), 256, g_ui[PUB_AC_UA2].m2_factor_k);
        pArg->arg[5] = _Mul_Div_U(sqrt_32fix(g_ui[PUB_AC_UB2].m2[0]), 256, g_ui[PUB_AC_UB2].m2_factor_k);
        pArg->arg[6] = _Mul_Div_U(sqrt_32fix(g_ui[PUB_AC_UC2].m2[0]), 256, g_ui[PUB_AC_UC2].m2_factor_k);
        pArg->arg[7] = _Mul_Div_U(sqrt_32fix(g_ui[PUB_AC_U02].m2[0]), 256, g_ui[PUB_AC_U02].m2_factor_k);
        pArg->arg[8] = _Mul_Div_U(sqrt_32fix(g_ui[PUB_AC_UAB2].m2[0]), 256, g_ui[PUB_AC_UAB2].m2_factor_k);
        pArg->arg[9] = _Mul_Div_U(sqrt_32fix(g_ui[PUB_AC_UBC2].m2[0]), 256, g_ui[PUB_AC_UBC2].m2_factor_k);
        pArg->arg[10] = _Mul_Div_U(sqrt_32fix(g_ui[PUB_AC_UCA2].m2[0]), 256, g_ui[PUB_AC_UCA2].m2_factor_k);
    }
    else
    {
        pArg->arg[4] = _Mul_Div_U(sqrt_32fix(g_ui[PUB_AC_UA1].m2[0]), 256, g_ui[PUB_AC_UA1].m2_factor_k);
        pArg->arg[5] = _Mul_Div_U(sqrt_32fix(g_ui[PUB_AC_UB1].m2[0]), 256, g_ui[PUB_AC_UB1].m2_factor_k);
        pArg->arg[6] = _Mul_Div_U(sqrt_32fix(g_ui[PUB_AC_UC1].m2[0]), 256, g_ui[PUB_AC_UC1].m2_factor_k);
        pArg->arg[7] = _Mul_Div_U(sqrt_32fix(g_ui[PUB_AC_U01].m2[0]), 256, g_ui[PUB_AC_U01].m2_factor_k);
        pArg->arg[8] = _Mul_Div_U(sqrt_32fix(g_ui[PUB_AC_UAB1].m2[0]), 256, g_ui[PUB_AC_UAB1].m2_factor_k);
        pArg->arg[9] = _Mul_Div_U(sqrt_32fix(g_ui[PUB_AC_UBC1].m2[0]), 256, g_ui[PUB_AC_UBC1].m2_factor_k);
        pArg->arg[10] = _Mul_Div_U(sqrt_32fix(g_ui[PUB_AC_UCA1].m2[0]), 256, g_ui[PUB_AC_UCA1].m2_factor_k);
    }
    pArg->arg[11] = _Mul_Div_U(sqrt_32fix(g_ui[PUB_AC_US1].m2[0]), 256, g_ui[PUB_AC_US1].m2_factor_k);
    pArg->arg[12] = _Mul_Div_U(sqrt_32fix(g_ui[PUB_AC_US2].m2[0]), 256, g_ui[PUB_AC_US2].m2_factor_k);

    pArg->type[0] = SW_AC_IA;
    pArg->type[1] = SW_AC_IB;
    pArg->type[2] = SW_AC_IC;
    pArg->type[3] = SW_AC_I0;
    if (pRunSet->tSwSet[sw].bTT_Power_v2)
    {
        pArg->type[4] = PUB_AC_UA2 | 0x80;
        pArg->type[5] = PUB_AC_UB2 | 0x80;
        pArg->type[6] = PUB_AC_UC2 | 0x80;
        pArg->type[7] = PUB_AC_U02 | 0x80;
        pArg->type[8] = PUB_AC_UAB2 | 0x80;
        pArg->type[9] = PUB_AC_UBC2 | 0x80;
        pArg->type[10] = PUB_AC_UCA2 | 0x80;
    }
    else
    {
        pArg->type[4] = PUB_AC_UA1 | 0x80;
        pArg->type[5] = PUB_AC_UB1 | 0x80;
        pArg->type[6] = PUB_AC_UC1 | 0x80;
        pArg->type[7] = PUB_AC_U01 | 0x80;
        pArg->type[8] = PUB_AC_UAB1 | 0x80;
        pArg->type[9] = PUB_AC_UBC1 | 0x80;
        pArg->type[10] = PUB_AC_UCA1 | 0x80;
    }
    pArg->type[11] = PUB_AC_US1 | 0x80;
    pArg->type[12] = PUB_AC_US2 | 0x80;

    pArg->sw = sw;
}

#ifdef SOE_PARA_ALL_SAVE
void soe_record_allArg(s32 *arg, int sw)
{

    int ui_begin;
    if (sw > 0 && sw <= SWITCH_NUM_MAX)
    {
        sw -= 1;
    }
    else
    {
        sw = 0;
    }
    ui_begin = UI_SW_INDEX_BEGIN(sw);
    *arg++ = _Mul_Div_U(sqrt_32fix(g_ui[PUB_AC_UAB1].m2[0]), 256, g_ui[PUB_AC_UAB1].m2_factor_k);
    *arg++ = _Mul_Div_U(sqrt_32fix(g_ui[PUB_AC_UBC1].m2[0]), 256, g_ui[PUB_AC_UBC1].m2_factor_k);
    *arg++ = _Mul_Div_U(sqrt_32fix(g_ui[PUB_AC_UCA1].m2[0]), 256, g_ui[PUB_AC_UCA1].m2_factor_k);
    *arg++ = _Mul_Div_U(sqrt_32fix(g_ui[PUB_AC_U01].m2[0]), 256, g_ui[PUB_AC_U01].m2_factor_k);

    *arg++ = _Mul_Div_U(sqrt_32fix(g_ui[ui_begin + SW_AC_IA].m2[0]), 256, g_ui[ui_begin + SW_AC_IA].m2_factor_k);
    *arg++ = _Mul_Div_U(sqrt_32fix(g_ui[ui_begin + SW_AC_IB].m2[0]), 256, g_ui[ui_begin + SW_AC_IB].m2_factor_k);
    *arg++ = _Mul_Div_U(sqrt_32fix(g_ui[ui_begin + SW_AC_IC].m2[0]), 256, g_ui[ui_begin + SW_AC_IC].m2_factor_k);
    *arg++ = _Mul_Div_U(sqrt_32fix(g_ui[ui_begin + SW_AC_I0].m2[0]), 256, g_ui[ui_begin + SW_AC_I0].m2_factor_k);
}
#endif

void soe_record_ev(u16 code, u8 value, long v1, long v2, long v3)
{
    u16 extarg;
    EVENT_STRUCT *ev;
    u32 sw;
    bool allarg = false;
    if (code < EV_PUB_START)
    {
        sw = (code / EV_SW_NUM) + 1;
    }
    else
    {
        sw = 0;
    }

    if (code < EV_PUB_START) // add by sunxi 增加故障记录标示
    {
#ifdef SOE_RECORD_DELAY
        if (!gb_wake_soe) // 首次上电时，对前一次上电产生的闭锁事件不做延时处理，避免逻辑运行出错
        {
            if (tAllSOE[code % EV_SW_NUM].soe_def & SOE_TYPE_DELAY_FHZ && (value == 0))
            { /*清SOE事件应在置SOE事件完成上送后再清，如果当前SOE事件未置则一直等待，
              避免因分合闸延时上送SOE导致先清了SOE事件再送置SOE事件导致上送COS出错（正确是先置再清）*/
                if (g_soe_queue.fzsoe_wait_flag)
                {
                    int i;
                    g_soe_queue.fzsoe_delay_flag = true;
                    g_soe_queue.fzsoe_wait_flag = false;
                    for (i = 0; i < DELAY_SOE_MAX; i++)
                    {
                        if (g_soe_queue.delay_fzsoe_tab[i].value == 0)
                            break;
                        g_soe_queue.delay_fzsoe_count = i;
                        soe_record_ev(g_soe_queue.delay_fzsoe_tab[i].code, g_soe_queue.delay_fzsoe_tab[i].value, g_soe_queue.delay_fzsoe_tab[i].v1, g_soe_queue.delay_fzsoe_tab[i].v2, g_soe_queue.delay_fzsoe_tab[i].v3);
                    }
                    /*置SOE后调用一次plc_scan，避免置->清SOE间隔过短导致正常plc_san扫描时无法扫描到置SOE*/
                    plc_scan(1);
                    memset((char *)&g_soe_queue.delay_fzsoe_tab, 0, sizeof(DELAY_SOE_DATA) * DELAY_SOE_MAX); // clear delay_soe_tab[] buffer
                    g_soe_queue.delay_fzsoe_count = 0;
                    g_soe_queue.fzsoe_delay_flag = false;
                }
                if (g_soe_queue.hzsoe_wait_flag)
                {
                    int i;
                    g_soe_queue.hzsoe_delay_flag = true;
                    g_soe_queue.hzsoe_wait_flag = false;
                    for (i = 0; i < DELAY_SOE_MAX; i++)
                    {
                        if (g_soe_queue.delay_hzsoe_tab[i].value == 0)
                            break;
                        g_soe_queue.delay_hzsoe_count = i;
                        soe_record_ev(g_soe_queue.delay_hzsoe_tab[i].code, g_soe_queue.delay_hzsoe_tab[i].value, g_soe_queue.delay_hzsoe_tab[i].v1, g_soe_queue.delay_hzsoe_tab[i].v2, g_soe_queue.delay_hzsoe_tab[i].v3);
                    }
                    memset((char *)&g_soe_queue.delay_hzsoe_tab, 0, sizeof(DELAY_SOE_DATA) * DELAY_SOE_MAX); // clear delay_soe_tab[] buffer
                    g_soe_queue.delay_hzsoe_count = 0;
                    g_soe_queue.hzsoe_delay_flag = false;
                }
            }
            else if (tAllSOE[code % EV_SW_NUM].soe_def & SOE_TYPE_DELAY_FHZ && value) // 开关延时保存分/合闸动作SOE && 动作
            {
                u8 i = 0;
                bool soe_fh = ((code % EV_SW_NUM) == EV_AR1) || ((code % EV_SW_NUM) == EV_AR2) || ((code % EV_SW_NUM) == EV_AR3) ||
                              ((code % EV_SW_NUM) == EV_FA_HZ) || ((code % EV_SW_NUM) == EV_FA_LL_HZ); // 0-fz soe;1-hz soe
                // 延时soe入QUEUE
                if ((g_soe_queue.fzsoe_delay_flag == 0) && (g_tRelay[0].run_stu.sw == 2) && (!soe_fh)) // 非分闸延时SOE QUEUE转录SOE && 合位 && 分闸SOE  		fzsoe_tab[]
                {
                    for (i = 0; i < DELAY_SOE_MAX; i++) // 大于最大缓存，直接保存SOE
                    {
                        if (g_soe_queue.delay_fzsoe_tab[i].code == code) // 当前SOE已保存
                        {
                            return; // 此次不保存数据
                        }
                        else if (g_soe_queue.delay_fzsoe_tab[i].value == 0)
                        {
                            clk_time_get(&g_soe_queue.delay_fzsoe_tab[i].ts);
                            g_soe_queue.delay_fzsoe_tab[i].value = value;
                            g_soe_queue.delay_fzsoe_tab[i].code = code;
                            g_soe_queue.delay_fzsoe_tab[i].v1 = v1;
                            g_soe_queue.delay_fzsoe_tab[i].v2 = v2;
                            g_soe_queue.delay_fzsoe_tab[i].v3 = v3;
                            g_soe_queue.fzsoe_wait_flag = true;
                            return; // 此次不保存数据
                        }
                    }
                }
                else if ((g_soe_queue.hzsoe_delay_flag == 0) && (g_tRelay[0].run_stu.sw == 1) && soe_fh) ////非合闸延时SOE QUEUE转录SOE && 分位 && 闸SOE hzsoe_tab[]
                {
                    for (i = 0; i < DELAY_SOE_MAX; i++) // 大于最大缓存，直接保存SOE
                    {
                        if (g_soe_queue.delay_hzsoe_tab[i].code == code) // 当前SOE已保存
                        {
                            return; // 此次不保存数据
                        }
                        else if (g_soe_queue.delay_hzsoe_tab[i].value == 0)
                        {
                            clk_time_get(&g_soe_queue.delay_hzsoe_tab[i].ts);
                            g_soe_queue.delay_hzsoe_tab[i].value = value;
                            g_soe_queue.delay_hzsoe_tab[i].code = code;
                            g_soe_queue.delay_hzsoe_tab[i].v1 = v1;
                            g_soe_queue.delay_hzsoe_tab[i].v2 = v2;
                            g_soe_queue.delay_hzsoe_tab[i].v3 = v3;
                            g_soe_queue.hzsoe_wait_flag = true;
                            return; // 此次不保存数据
                        }
                    }
                }
            }
        }
#endif
        ev = &soe_get_buffer(&extarg)->es_ev;
        ev->ev_type = SOE_TYPE_EV;
        if (tAllSOE[code % EV_SW_NUM].soe_def & SOE_TYPE_FAULT) // 需上送故障记录
        {
            ev->ev_type |= SOE_TYPE_FAULT;
            soe_ext_arg(extarg, sw);
        }
        if (tAllSOE[code % EV_SW_NUM].soe_def & SOE_TYPE_RSV3) // 置关键事件标志
        {
            ev->ev_type |= SOE_TYPE_VIP;
        }
        if (tAllSOE[code % EV_SW_NUM].soe_def & SOE_TYPE_VIP) // 全数据保存
        {
            allarg = true;
        }
    }
    else
    {
#ifdef SOE_RECORD_DELAY
        if (!gb_wake_soe) // 首次上电时，对前一次上电产生的闭锁事件不做延时处理，避免逻辑运行出错
        {
            if (tAllSOE[code - EV_PUB_START + EV_SW_NUM].soe_def & SOE_TYPE_DELAY_FHZ && (value == 0))
            {
                if (g_soe_queue.fzsoe_wait_flag)
                {
                    int i;
                    g_soe_queue.fzsoe_delay_flag = true;
                    g_soe_queue.fzsoe_wait_flag = false;
                    for (i = 0; i < DELAY_SOE_MAX; i++)
                    {
                        if (g_soe_queue.delay_fzsoe_tab[i].value == 0)
                            break;
                        g_soe_queue.delay_fzsoe_count = i;
                        soe_record_ev(g_soe_queue.delay_fzsoe_tab[i].code, g_soe_queue.delay_fzsoe_tab[i].value, g_soe_queue.delay_fzsoe_tab[i].v1, g_soe_queue.delay_fzsoe_tab[i].v2, g_soe_queue.delay_fzsoe_tab[i].v3);
                    }
                    memset((char *)&g_soe_queue.delay_fzsoe_tab, 0, sizeof(DELAY_SOE_DATA) * DELAY_SOE_MAX); // clear delay_soe_tab[] buffer
                    g_soe_queue.delay_fzsoe_count = 0;
                    g_soe_queue.fzsoe_delay_flag = false;
                }
                if (g_soe_queue.hzsoe_wait_flag)
                {
                    int i;
                    g_soe_queue.hzsoe_delay_flag = true;
                    g_soe_queue.hzsoe_wait_flag = false;
                    for (i = 0; i < DELAY_SOE_MAX; i++)
                    {
                        g_soe_queue.delay_hzsoe_count = i;
                        if (g_soe_queue.delay_hzsoe_tab[i].value == 0)
                            break;
                        soe_record_ev(g_soe_queue.delay_hzsoe_tab[i].code, g_soe_queue.delay_hzsoe_tab[i].value, g_soe_queue.delay_hzsoe_tab[i].v1, g_soe_queue.delay_hzsoe_tab[i].v2, g_soe_queue.delay_hzsoe_tab[i].v3);
                    }
                    memset((char *)&g_soe_queue.delay_hzsoe_tab, 0, sizeof(DELAY_SOE_DATA) * DELAY_SOE_MAX); // clear delay_soe_tab[] buffer
                    g_soe_queue.delay_hzsoe_count = 0;
                    g_soe_queue.hzsoe_delay_flag = false;
                }
            }
            else if (tAllSOE[code - EV_PUB_START + EV_SW_NUM].soe_def & SOE_TYPE_DELAY_FHZ && value) // 开关延时保存分/合闸动作SOE && 动作
            {
                u8 i = 0;
                bool soe_fh = (((code - EV_PUB_START + EV_SW_NUM) % EV_SW_NUM) == EV_AR1) || (((code - EV_PUB_START + EV_SW_NUM) % EV_SW_NUM) == EV_AR2) || (((code - EV_PUB_START + EV_SW_NUM) % EV_SW_NUM) == EV_AR3) ||
                              (((code - EV_PUB_START + EV_SW_NUM) % EV_SW_NUM) == EV_FA_HZ) || (((code - EV_PUB_START + EV_SW_NUM) % EV_SW_NUM) == EV_FA_LL_HZ); // 0-fz soe;1-hz soe
                // 延时soe入QUEUE
                if ((g_soe_queue.fzsoe_delay_flag == 0) && (g_tRelay[sw].run_stu.sw == 2) && (!soe_fh)) // 非分闸延时SOE QUEUE转录SOE && 合位 && 分闸SOE  		fzsoe_tab[]
                {
                    for (i = 0; i < DELAY_SOE_MAX; i++) // 大于最大缓存，直接保存SOE
                    {
                        if (g_soe_queue.delay_fzsoe_tab[i].code == code) // 当前SOE已保存
                        {
                            return; // 此次不保存数据
                        }
                        else if (g_soe_queue.delay_fzsoe_tab[i].value == 0)
                        {
                            clk_time_get(&g_soe_queue.delay_fzsoe_tab[i].ts);
                            g_soe_queue.delay_fzsoe_tab[i].value = value;
                            g_soe_queue.delay_fzsoe_tab[i].code = code;
                            g_soe_queue.delay_fzsoe_tab[i].v1 = v1;
                            g_soe_queue.delay_fzsoe_tab[i].v2 = v2;
                            g_soe_queue.delay_fzsoe_tab[i].v3 = v3;
                            g_soe_queue.fzsoe_wait_flag = true;
                            return; // 此次不保存数据
                        }
                    }
                }
                else if ((g_soe_queue.hzsoe_delay_flag == 0) && (g_tRelay[sw].run_stu.sw == 1) && soe_fh) ////非合闸延时SOE QUEUE转录SOE && 分位 && 合闸SOE hzsoe_tab[]
                {
                    for (i = 0; i < DELAY_SOE_MAX; i++) // 大于最大缓存，直接保存SOE
                    {
                        if (g_soe_queue.delay_hzsoe_tab[i].code == code) // 当前SOE已保存
                        {
                            return; // 此次不保存数据
                        }
                        else if (g_soe_queue.delay_hzsoe_tab[i].value == 0)
                        {
                            clk_time_get(&g_soe_queue.delay_hzsoe_tab[i].ts);
                            g_soe_queue.delay_hzsoe_tab[i].value = value;
                            g_soe_queue.delay_hzsoe_tab[i].code = code;
                            g_soe_queue.delay_hzsoe_tab[i].v1 = v1;
                            g_soe_queue.delay_hzsoe_tab[i].v2 = v2;
                            g_soe_queue.delay_hzsoe_tab[i].v3 = v3;
                            g_soe_queue.hzsoe_wait_flag = true;
                            return; // 此次不保存数据
                        }
                    }
                }
            }
        }
#endif
        ev = &soe_get_buffer(&extarg)->es_ev;
        ev->ev_type = SOE_TYPE_EV;
        if (tAllSOE[code - EV_PUB_START + EV_SW_NUM].soe_def & SOE_TYPE_FAULT) // 需上送故障记录
        {
            ev->ev_type |= SOE_TYPE_FAULT;
            soe_ext_arg(extarg, sw);
        }
        if (tAllSOE[code - EV_PUB_START + EV_SW_NUM].soe_def & SOE_TYPE_RSV3) // 关键记录 单独保存
        {
            ev->ev_type |= SOE_TYPE_VIP;
        }
        if (tAllSOE[code - EV_PUB_START + EV_SW_NUM].soe_def & SOE_TYPE_VIP) // 全参数保存
        {
            allarg = true;
        }
    }
    if (allarg) // 保存全参数
    {
#ifdef SOE_PARA_ALL_SAVE
        soe_record_allArg(&ev->allarg[0], sw);
#endif
    }
    soe_ev_set(code, value);
    ev->ev_value = value;
    ev->ev_code = code;
    ev->ev_arg[0] = v1;
    ev->ev_arg[1] = v2;
    ev->ev_arg[2] = v3;
#ifdef SOE_RECORD_DELAY
    // 延时SOE QUEUE中SOE时标获得
    // 转录SOE && QUEUE非空 && code对应 && 动作
    if (!gb_wake_soe)
    {
        if (g_soe_queue.fzsoe_delay_flag && !g_soe_queue.fzsoe_wait_flag && g_soe_queue.delay_fzsoe_tab[g_soe_queue.delay_fzsoe_count].code == code && value)
        {
            memcpy(&ev->ts, &g_soe_queue.delay_fzsoe_tab[g_soe_queue.delay_fzsoe_count].ts, sizeof(struct timespec));
        }
        else if (g_soe_queue.hzsoe_delay_flag && !g_soe_queue.hzsoe_wait_flag && g_soe_queue.delay_hzsoe_tab[g_soe_queue.delay_hzsoe_count].code == code && value)
        {
            memcpy(&ev->ts, &g_soe_queue.delay_hzsoe_tab[g_soe_queue.delay_hzsoe_count].ts, sizeof(struct timespec));
        }
        else // 其它非延时SOE 时标获得
        {
            clk_time_get(&ev->ts);
        }
    }
    else // 其它非延时SOE 时标获得
    {
        clk_time_get(&ev->ts);
    }
#else
    clk_time_get(&ev->ts);
#endif
    g_soe_queue.stat_cnt_type[SOE_TYPE_EV]++;
}

int soe_record_imp(u16 code, u8 val)
{

    int i;
    u8 slot = (u8)(code >> 8); // 板卡号
    u8 dino = (u8)(code);      // 遥信号

    for (i = 0; i < g_equ_config->di_num; i++)
    {
        if ((g_equ_config_di[i].slot == slot) && (g_equ_config_di[i].index == dino))
        {
            break;
        }
    }
    if (i < g_equ_config->di_num)
    {
        u8 sw = g_equ_config_di[i].owner;
        u8 type = g_equ_config_di[i].type;
        if (type == 0 || sw == 0 || sw > SWITCH_NUM_MAX)
            return 0;
        type -= 1;
        sw -= 1;
        if (type >= SW_DI_IMP1 && type <= SW_DI_IMP2) // 是脉冲计数
        {
            if (val == 1)
                g_sw[sw].ac_in[SW_AC_IN_IMP1 + type - SW_DI_IMP1]++;
            return 1;
        }
    }
    return 0;
}

void soe_record_yx(u16 code, u8 value, struct timespec *ts)
{
    EVENT_STRUCT *ev;
    if (soe_record_imp(code, value))
        return; // 是脉冲计数值，直接返回，不保存
    ev = &soe_get_buffer_yx()->es_ev;
    ev->ev_type = SOE_TYPE_YX;
    ev->ev_value = value;
    ev->ev_code = code;
    ev->ev_arg[0] = 0;
    ev->ev_arg[1] = 0;
    ev->ev_arg[2] = 0;

    ev->ts = *ts;

    // 双点触发
    plc_db_soe(ev);
    g_soe_queue.stat_cnt_type[SOE_TYPE_YX]++;
    // 关键遥信变位处理
    {
        u8 type;
        u8 slot = (u8)(code >> 8); // 板卡号
        u8 no = (u8)(code);        // 遥信号
        type = equ_di_type(slot, no);
        if (type > 0)
        {
            type--;

            // 开关分合位为关键记录
            if (type == SW_DI_KRHW || type == SW_DI_KRTW) // 跳位
            {
                ev->ev_type |= SOE_TYPE_VIP;
            }
        }
    }
}

void soe_record_lnk(u16 code, u8 value, struct timespec *ts, s32 v1, bool bmix, u32 cp_s)
{
    EVENT_STRUCT *ev = &soe_get_buffer(NULL)->es_ev;
    // rt_printf("\r\n soe_record_lnk :code=%04x v=%d v1=%d bmix=%d",code,value,v1,bmix);
    ev->ev_type = SOE_TYPE_LNK;
    ev->ev_value = value;
    ev->ev_code = code;
    ev->ev_arg[0] = v1;
    ev->ev_arg[1] = bmix;
    ev->ev_arg[2] = cp_s;

    ev->ts = *ts;

    g_soe_queue.stat_cnt_type[SOE_TYPE_LNK]++;
}

void soe_record_dpi(u16 code, u8 value, struct timespec *ts)
{
    EVENT_STRUCT *ev = &soe_get_buffer(NULL)->es_ev;

    ev->ev_type = SOE_TYPE_DPI;
    ev->ev_value = value;
    ev->ev_code = code;
    ev->ev_arg[0] = 0;
    ev->ev_arg[1] = 0;
    ev->ev_arg[2] = 0;

    ev->ts = *ts;

    g_soe_queue.stat_cnt_type[SOE_TYPE_DPI]++;
}

void soe_record_plc(u16 code, u8 value, u32 flag)
{
    u16 extarg;
    EVENT_STRUCT *ev = &soe_get_buffer(&extarg)->es_ev;

    ev->ev_type = SOE_TYPE_PLC;
    if (flag & PLC_FLAG_FAULT)
    {
        ev->ev_type |= SOE_TYPE_FAULT;
        soe_ext_arg(extarg, (flag >> 16));
    }
    ev->ev_value = value;
    ev->ev_code = code;
    ev->ev_arg[0] = 0;
    ev->ev_arg[1] = 0;
    ev->ev_arg[2] = 0;

    clk_time_get(&ev->ts);

    g_soe_queue.stat_cnt_type[SOE_TYPE_PLC]++;
}

void soe_record_tst(u16 code, u8 value)
{
    EVENT_STRUCT *ev = &soe_get_buffer(NULL)->es_ev;

    ev->ev_type = SOE_TYPE_TST;
    ev->ev_value = value;
    ev->ev_code = code;
    ev->ev_arg[0] = 0;
    ev->ev_arg[1] = 0;
    ev->ev_arg[2] = 0;

    clk_time_get(&ev->ts);

    g_soe_queue.stat_cnt_type[SOE_TYPE_TST]++;
}

void soe_record_opt(u16 code, long v1)
{
    EVENT_STRUCT *ev = &soe_get_buffer(NULL)->es_ev;

    ev->ev_type = SOE_TYPE_OPT;
    if (tAllSOE[code - EV_SW_NUM * (SWITCH_NUM_MAX - 1)].soe_def & SOE_TYPE_RSV3) // 置关键事件标志
    {
        ev->ev_type |= SOE_TYPE_VIP;
    }
    ev->ev_value = 1;
    ev->ev_code = code;
    ev->ev_arg[0] = v1;
    ev->ev_arg[1] = 0;
    ev->ev_arg[2] = 0;

    clk_time_get(&ev->ts);

    g_soe_queue.stat_cnt_type[SOE_TYPE_OPT]++;
}

void soe_record_opt3(u16 code, long v1, long v2, long v3)
{
    EVENT_STRUCT *ev = &soe_get_buffer(NULL)->es_ev;

    ev->ev_type = SOE_TYPE_OPT;
    if (tAllSOE[code - EV_SW_NUM * (SWITCH_NUM_MAX - 1)].soe_def & SOE_TYPE_RSV3) // 置关键事件标志
    {
        ev->ev_type |= SOE_TYPE_VIP;
    }
    ev->ev_value = 1;
    ev->ev_code = code;
    ev->ev_arg[0] = v1;
    ev->ev_arg[1] = v2;
    ev->ev_arg[2] = v3;

    clk_time_get(&ev->ts);

    g_soe_queue.stat_cnt_type[SOE_TYPE_OPT]++;
}

int soe_get(u8 ch, EVENT_STRUCT *ev)
{
    u16 tail_send;
    sbi_t tail_send_new;
    uint32_t flags;
    int ok;

    // 检查参数
    if (ch >= COMM_CHANNEL_NUM || ev == NULL)
    {
        return -1;
    }

    // 检查是否有数据
    if (g_soe_queue.tail_send[ch].n == g_soe_queue.head.n)
    {
        return -2;
    }

    // 为了防止取出不正确或不完整的数据(在SOE池已满且事件正在产生，此时104主站连接进来时最容易产生)
    // 需检查tail_send是否被中断修改。
    while (1)
    {
        // 获取事件，调整尾指针
        tail_send = g_soe_queue.tail_send[ch].n;
        *ev = g_soe_queue.soe[tail_send].es_ev;
        tail_send_new.n = tail_send + 1;

        // 在关中断的情况下，检测修改尾指针，避免数据错误。
        ok = 0;
        rt_irq_save(flags);
        if (tail_send == g_soe_queue.tail_send[ch].n)
        {
            g_soe_queue.tail_send[ch].n = tail_send_new.n;
            ok = 1;
        }
        rt_irq_restore(flags);

        if (ok)
        {
            break;
        }

        rt_printf_time("soe_get(%d): old =%d,new=%d!\r\n", ch, tail_send, g_soe_queue.tail_send[ch].n);
    }

    return tail_send_new.n;
}

// 注意:ack是已确认事件的下一个(还不能确认)
void soe_ack(u8 chnl, u16 ack)
{
    u32 es_save_addr = 0, es_save_cnt = 0;
    sbi_t num_all, num_send, num_ack;
    EVENT_SAVE *es, tEvt;
    u8 soe_type;
    u32 addr;

    // 检查ack是否在合法的范围内，ack的位置必须在tail_ack和tail_send之间
    num_send.n = g_soe_queue.tail_send[chnl].n - g_soe_queue.tail_ack[chnl].n;
    num_ack.n = ack - g_soe_queue.tail_ack[chnl].n;

    if (num_ack.n > num_send.n)
    {
        num_all.n = g_soe_queue.head.n - g_soe_queue.tail_ack[chnl].n;
        rt_printf_time("soe_ack error:num_send=%d,num_ack=%d,head=%d,tail_send=%d,tail_ack=%d,ack=%d.\r\n",
                       num_send.n, num_ack.n, g_soe_queue.head.n, g_soe_queue.tail_send[chnl].n, g_soe_queue.tail_ack[chnl].n, ack);

        return;
    }

    // 循环确认事件
    for (; g_soe_queue.tail_ack[chnl].n != ack; g_soe_queue.tail_ack[chnl].n++)
    {
        es = &g_soe_queue.soe[g_soe_queue.tail_ack[chnl].n];

        // 检查是否是不需要确认的事件
        soe_type = es->es_ev.ev_type & SOE_TYPE_MASK;
        if (soe_type >= SOE_TYPE_ACK)
        {
            continue;
        }

        // 没有保存过的事件不能更新
        if (es->es_flag != SOE_ID_MASK)
        {
            rt_printf_time("soe_ack_ev:没有保存过的事件不能更新,es_flag=%02x.\r\n", es->es_flag);
            continue;
        }

        // 已确认过的事件不再确认
        if (es->es_ack == SOE_ID_ACK_OK)
        {
            continue;
        }
        es->es_ack = SOE_ID_ACK_OK;

        // 读出已保存的事件
        addr = es->es_id + EEP_SOE_BASE;
        e2prom_read(addr, (u8 *)&tEvt, sizeof(EVENT_SAVE));
        es->es_id = tEvt.es_id;

        // 两份内容除了ack外，应完全一样
        tEvt.es_ack = es->es_ack;
        if (memcmp(es, &tEvt, sizeof(tEvt)))
        {
            rt_printf_time("soe_update_ev:memcmp error!\r\n");
            continue;
        }

        // 处理保存信息
        if (es_save_cnt == 0)
        {
            es_save_addr = addr;
        }
        // 如果地址不连续或BUF已满，先保存一段
        else if ((addr != es_save_addr + es_save_cnt * sizeof(EVENT_SAVE)) || es_save_cnt == SOE_SAVE_BUF_NUM)
        {
            e2prom_write(es_save_addr, (u8 *)&g_soe_sbuf, sizeof(EVENT_SAVE) * es_save_cnt);
            es_save_cnt = 0;
            es_save_addr = addr;
        }

        // 写入确认事件
        memcpy(&g_soe_sbuf[es_save_cnt++], &tEvt, sizeof(EVENT_SAVE));

        g_soe_info.wEvAck--;
    }

    if (es_save_cnt)
    {
        e2prom_write(es_save_addr, (u8 *)&g_soe_sbuf, sizeof(EVENT_SAVE) * es_save_cnt);
    }

    //	rt_printf("SOE通讯BUF:head=%d,tail_send=%d,tail_ack=%d\r\n",g_soe_queue.head.n,g_soe_queue.tail_send[chnl].n,g_soe_queue.tail_ack[chnl].n);

    return;
}

void soe_log(EVENT_STRUCT *er)
{
    static char log[512];

    u8 soe_type;
    char *buf;

    struct rtc_time_t tm;
    timespec_to_rtc(er->ts, &tm, 0);

    buf = log;
    sprintf(buf, "20%02hu-%02hu-%02hu %02hu:%02hu:%02hu.%06u ", tm.year, tm.month, tm.day, tm.hour, tm.min, tm.ms / 1000, er->ts.tv_nsec / 1000);
    buf += strlen(buf);

    soe_type = er->ev_type & SOE_TYPE_MASK;
    if (soe_type == SOE_TYPE_EV || soe_type == SOE_TYPE_OPT) // 不是遥信变位
    {
        int i;
        int ev_sw = 0;
        int len = 0;
        u16 code;
        const SOE_DEF *psoe;

        if (er->ev_code >= EV_NUMBER)
        {
            sprintf(buf, "错误代码:%d", er->ev_code);
            log_str_ext(LOG_SOE, log);
            return;
        }

        if (er->ev_code < EV_SW_NUM)
        {
            code = er->ev_code;
            ev_sw = 1;
        }
        else if ((er->ev_code >= EV_SW_NUM) && (er->ev_code < EV_PUB_START))
        {
            code = er->ev_code % EV_SW_NUM;
            ev_sw = (er->ev_code / EV_SW_NUM) + 1;
        }
        else
        {
            if (er->ev_code == EV_SET_CHANGE_PARA)
                return; // 定值修改操作记录，不做日志，已经有修改内容记录
            code = er->ev_code - EV_SW_NUM * (SWITCH_NUM_MAX - 1);
        }

#if SWITCH_NUM_MAX != 1
        {
            if ((ev_sw > 0) && (ev_sw <= SWITCH_NUM_MAX))
            {
                sprintf(buf, "开关%02d ", ev_sw);
                len = strlen(buf);
            }
        }
#endif

        psoe = &tAllSOE[code];
        if (soe_ev_is_on(er)) // 置1 ,产生，显示参数
        {
#ifdef XDL_ZT
            if (code == EV_LX_XDL_QD)
            {
                if (er->ev_arg[2] == 1)
                    strcpy(&buf[len], "小电流接地：启动[界内动作]");
                else if (er->ev_arg[2] == 0)
                    strcpy(&buf[len], "小电流接地：启动[界外动作]");
                else if (er->ev_arg[2] == -1)
                    strcpy(&buf[len], "小电流接地：启动[线路无流]");
                else if (er->ev_arg[2] == -2)
                    strcpy(&buf[len], "小电流接地：启动[电压欠幅]");
                else if (er->ev_arg[2] == -3)
                    strcpy(&buf[len], "小电流接地：启动[电压无向]");
                else if (er->ev_arg[2] == -4)
                    strcpy(&buf[len], "小电流接地：启动[无首半波]");
                else if (er->ev_arg[2] == -11)
                    strcpy(&buf[len], "小电流接地：启动[无电压通道]");
                else if (er->ev_arg[2] == -12)
                    strcpy(&buf[len], "小电流接地：启动[功能禁止]");
                else if (er->ev_arg[2] == -13)
                    strcpy(&buf[len], "小电流接地：启动[无电流通道]");
                else if (er->ev_arg[2] == -14)
                    strcpy(&buf[len], "小电流接地：启动[处理超时]");
                else if (er->ev_arg[2] == -15)
                    strcpy(&buf[len], "小电流接地：启动[开关序号异常]");
            }
            else
            {
                strcpy(&buf[len], psoe->strName);
            }
#else
            strcpy(&buf[len], psoe->strName);
#endif
            buf += strlen(buf);
#if (1) /* 显示值 直接按照上送值显示 lch */
            sprintf(buf,"(%d)", er->ev_value);
			buf += strlen(buf);
#endif
            for (i = 0; i < 3; i++)
            {
                u8 index = (psoe->Attrib[i] & 0x1f);
                if (index == 0)
                {
                    continue;
                }
                switch ((psoe->Attrib[i] >> 5) & 0x07)
                {
                case 0: // 浮点数
                    sprintf(buf, " %s=%f%s", ev_para[index].strName, (float)er->ev_arg[i] / Q16_BASE, g_unit[ev_para[index].byNo].name);
                    break;
                case 1: // 整型值
                    sprintf(buf, " %s=%d%s", ev_para[index].strName, er->ev_arg[i], g_unit[ev_para[index].byNo].name);
                    break;
                case 2: // 遥控操作
                    if (i == 0)
                    {
                        u8 sw = (er->ev_arg[0] >> 8) & 0xff; // 开关号
                        u8 no = (er->ev_arg[0] >> 0) & 0xff; // 序号
                        char *ykowner;
                        ykowner = get_yk_owner((er->ev_arg[0] >> 16) & 0xff);
                        if (sw == 0)
                        {
                            sprintf(buf, "--%s:公共开出%02d", ykowner, no);
                        }
                        else
                        {
                            sprintf(buf, "--%s:开关%02d开出%02d", ykowner, sw, no);
                        }
                    }
                    break;
                case 3: // 压板操作
                {
                    strcpy(buf, "投入");
                }
                break;
                default:
                    sprintf(buf, " 参数错误");
                    break;
                }
                buf += strlen(buf);
            }
        }
        else // 显示事件索引
        {
            strcpy(&buf[len], psoe->strName);
            buf += strlen(buf);
            strcpy(buf, ev_back[(psoe->soe_def & SOE_TYPE_QUIT)]);
        }

        if (soe_type == SOE_TYPE_EV)
        {

            log_str_ext(LOG_SOE, log);

            if (soe_ev_is_on(er)) // 置1 ,产生，显示参数
            {
                if (er->ev_code == EV_TWYL)
                {
                    load_hs_log_rcd(TYPE_SW_YX, false, &tm, "Tripping position but current occured", 1);
                }
                else if (er->ev_code == EV_BOARDCOMM)
                {
                    load_hs_log_rcd(TYPE_HW_ERR, false, &tm, "The subboard communication is abnormal occured", 1);
                }
                else if (er->ev_code == EV_HMIERR)
                {
                    load_hs_log_rcd(TYPE_HW_ERR, false, &tm, "Panel communication error occured", 1);
                }
                else if (er->ev_code == EV_TZFAIL)
                {
                    load_hs_log_rcd(TYPE_CTL_LOOP, false, &tm, "Tripping failure occured", 1);
                }
            }
            else
            {
                if (er->ev_code == EV_TWYL)
                {
                    load_hs_log_rcd(TYPE_SW_YX, false, &tm, "Tripping position but current disappeared", 0);
                }
                else if (er->ev_code == EV_BOARDCOMM)
                {
                    load_hs_log_rcd(TYPE_HW_ERR, false, &tm, "The subboard communication is abnormal disappeared", 0);
                }
                else if (er->ev_code == EV_HMIERR)
                {
                    load_hs_log_rcd(TYPE_HW_ERR, false, &tm, "Panel communication error disappeared", 0);
                }
                else if (er->ev_code == EV_TZFAIL)
                {
                    load_hs_log_rcd(TYPE_CTL_LOOP, false, &tm, "Tripping failure disappeared", 0);
                }
            }
        }
        else
        {
            log_str(LOG_OPERATE, log);

            if (er->ev_code == EV_SET_OK)
            {
                load_hs_log_rcd(TYPE_DEV_PARM, false, &tm, "The fixed value is determined successfully", 1);
            }
            else if (er->ev_code == EV_CSTSET_OK)
            {
                load_hs_log_rcd(TYPE_DEV_PARM, false, &tm, "The setting of the internal fixed value is determined successfully", 1);
            }
            else if (er->ev_code == EV_EQUPARA_OK)
            {
                load_hs_log_rcd(TYPE_DEV_PARM, false, &tm, "Device parameter setting successfully", 1);
            }
            else if (er->ev_code == EV_SET_FAIL)
            {
                load_hs_log_rcd(TYPE_DEV_PARM, false, &tm, "The fixed value is set to fail", 1);
            }
            else if (er->ev_code == EV_CSTSET_FAIL)
            {
                load_hs_log_rcd(TYPE_DEV_PARM, false, &tm, "Internal setting failed", 1);
            }
            else if (er->ev_code == EV_EQUPARA_FAIL)
            {
                load_hs_log_rcd(TYPE_DEV_PARM, false, &tm, "Device parameter setting failed", 1);
            }

            if (er->ev_code == EV_BAT_AUTOACTIVE)
            {
                load_hs_log_rcd(TYPE_STANDBY_POW, false, &tm, "Automatic battery activation", 0);
            }
            else if (er->ev_code == EV_BAT_HANDACTIVE)
            {
                load_hs_log_rcd(TYPE_STANDBY_POW, false, &tm, "Battery activation", 0);
            }
            else if (er->ev_code == EV_BAT_HANDACTOFF)
            {
                load_hs_log_rcd(TYPE_STANDBY_POW, false, &tm, "Battery activation exit", 0);
            }
            else if (er->ev_code == EV_BAT_HANDOFF)
            {
                load_hs_log_rcd(TYPE_STANDBY_POW, false, &tm, "Manual exit of battery", 0);
            }
            // else if(er->ev_code == EV_BATERR)
            //{
            //	load_hs_log_rcd(TYPE_STANDBY_POW,false,&tm,"Abnormal battery alarm",0);
            // }
        }
    }
    // 遥信变位记录
    else if (soe_type == SOE_TYPE_YX)
    {
        u8 slot = (u8)(er->ev_code >> 8); // 板卡号
        u8 dino = (u8)(er->ev_code);      // 遥信号
        char *name;

        name = equ_di_name(slot, dino);
        if (name)
        {
            sprintf(buf, "板卡%02d开入%02d[%s]变位", slot, dino + 1, name);
        }
        else
        {
            sprintf(buf, "板卡%02d开入%02d[]变位", slot, dino + 1);
        }

        buf += strlen(buf);

        if (soe_ev_is_on(er)) // 置1 ,产生，显示参数
        {
            sprintf(buf, " 0->1");
        }
        else
        {
            sprintf(buf, " 1->0");
        }

        log_str_ext(LOG_YX, log);
    }
    // 级联SOE记录
    else if (soe_type == SOE_TYPE_LNK)
    {
        char name[TRANS_SZ_BUF_LEN];
        LINK_TABLE *lt;

        lt = (LINK_TABLE *)er->ev_arg[0];

        name[0] = 0;
        if (lt->is_mix == 1)
        {
            sprintf(name, "合并点%d", lt->tbl_index + 1);
        }
        else
        {
            tbl_getname(RES_TYPE_YX, lt->tbl_index, name);
        }
        sprintf(buf, "通道%d地址%02d 点号0x%04x(级联点号0x%04x  %s)变位", (u8)((lt->cp_s >> 21) & 0x0f), (u8)((lt->cp_s >> 16) & 0x1f), lt->cp, (lt->cp_s) & 0xffff, name);
        buf += strlen(buf);

        if (soe_ev_is_on(er)) // 置1 ,产生，显示参数
        {
            sprintf(buf, " 0->1");
        }
        else
        {
            sprintf(buf, " 1->0");
        }

        log_str_ext(LOG_SOE, log);
    }
    // 双点变位记录
    else if (soe_type == SOE_TYPE_DPI)
    {
        sprintf(buf, "双点%02d变位[值:%d,通讯点:0x%04x]", er->ev_code, er->ev_value, g_di_db_table[er->ev_code].cp);
        log_str_ext(LOG_SOE, log);
    }
    // PLC变位记录
    else if (soe_type == SOE_TYPE_PLC)
    {
        sprintf(buf, "PLC%02d变位[值:%d,通讯点:0x%04x]", er->ev_code, er->ev_value, g_plc[er->ev_code].cp);
        log_str_ext(LOG_SOE, log);
    }

    else
    {
        sprintf(buf, "未知类型:%d", er->ev_code);
        log_str_ext(LOG_SOE, log);
    }
}

#ifdef ADD_DEBUG_RECORD_AUTO_SHOW_FUN
// TODO: add execute event judge
u8 JudgeExecuteEventFun(EVENT_SAVE es)
{
    u8 res = FALSE;
    u16 count;
    // rt_printf("EXECUTE_EVENT_NUM=%d\r\n",EXECUTE_EVENT_NUM);
    for (count = 0; count < EXECUTE_EVENT_NUM; count++)
        if (ExecuteEventIdTbl[count] == es.es_ev.ev_code)
        {
            res = TRUE;
            break;
        }

    return res;
}
#endif

void soe_save(void)
{
    u32 es_save_addr = 0, es_save_cnt = 0;

    u32 addr, ok, head;
    sbi_t tail_send, tail_send_new;
    EVENT_SAVE es, *esp;
    uint32_t flags;
    u8 soe_type;
    u64 us0;

    // 循环保存所有记录
    us0 = bsp_ustimer_get_origin();
    head = g_soe_queue.head.n;
    while (g_soe_queue.tail_eep.n != head && es_save_cnt < SOE_SAVE_BUF_NUM)
    {
        // 为了防止取出不正确或不完整的数据(在SOE池已满且事件正在产生)
        // 需检查tail_send是否被中断修改。
        while (1)
        {
            // 获取事件，调整尾指针
            tail_send.n = g_soe_queue.tail_eep.n;
            es = g_soe_queue.soe[tail_send.n];
            esp = &g_soe_queue.soe[tail_send.n];

            // 在关中断的情况下，检测修改尾指针，避免数据错误。
            ok = 0;
            tail_send_new.n = tail_send.n + 1;
            rt_irq_save(flags);
            if (tail_send.n == g_soe_queue.tail_eep.n)
            {
                g_soe_queue.tail_eep.n = tail_send_new.n;
                ok = 1;
            }
            rt_irq_restore(flags);

            if (ok)
            {
                break;
            }

            rt_printf("soe_save: old =%d,new=%d!\r\n", tail_send.n, g_soe_queue.tail_eep.n);
        }

        soe_type = es.es_ev.ev_type & SOE_TYPE_MASK;
        if (soe_type != SOE_TYPE_TST)
        {
            // 输出到日志记录文本文件
            soe_log(&es.es_ev);

            // 输出历史SOE记录文件
            refresh_soe_file(&es.es_ev);

            // 初始化事件保存信息
            addr = 0;
            es.es_flag = SOE_ID_MASK; // 记录标志
            es.es_ack = pRunSet->bTT_SoeResumePower ? SOE_ID_ACK_NONE : SOE_ID_ACK_OK;

            // 记录事件
            if (soe_type < SOE_TYPE_ACK)
            {
                // 刷新显示
                if (!g_bVipSoe_show)
                {
                    g_soe_info.bDpNew = true;
                    g_soe_info.wDpAutoShow = tail_send.n;
                }
                // 调整事件指针
                g_soe_info.wEvIndex++;
                if (g_soe_info.wEvIndex >= MAX_EVENT_NUMBER)
                {
                    g_soe_info.wEvIndex = 0;

                    // 如果事件回绕，先保存一段
                    if (es_save_cnt)
                    {
                        e2prom_write(es_save_addr, (u8 *)&g_soe_sbuf, sizeof(EVENT_SAVE) * es_save_cnt);
                        // rt_printf("soe_save:cnt=%d,head=%d,tail=%d.\r\n",es_save_cnt,head,g_soe_queue.tail_eep.n);
                        es_save_cnt = 0;
                    }
                }

                // 计算地址
                addr = EEP_SOE_ADDR + g_soe_info.wEvIndex * (sizeof(EVENT_SAVE));
                if (es_save_cnt == 0)
                {
                    es_save_addr = addr;
                }

                // 放入保存buf中
                es.es_id = g_soe_info.wEvID++;
                memcpy(&g_soe_sbuf[es_save_cnt], &es, sizeof(EVENT_SAVE));

                // 保存计数加一
                es_save_cnt++;
                if (pRunSet->bTT_SoeResumePower)
                {
                    g_soe_info.wEvAck++;
                }

                // 调整事件记录数
                if (g_soe_info.wEvNumber < MAX_EVENT_NUMBER)
                {
                    g_soe_info.wEvNumber++;
                }

                // 保存到关键事件缓冲区
                if (es.es_ev.ev_type & SOE_TYPE_VIP)
                {
#ifdef ADD_DEBUG_RECORD_AUTO_SHOW_FUN
                    u8 IsExeEvent = FALSE;

                    IsExeEvent = JudgeExecuteEventFun(es);
                    if (IsExeEvent == TRUE)
#endif
                        // 只有关键记录才刷新显示
                        if (g_bVipSoe_show)
                        {
                            g_soe_info.bDpNew = true;
                            g_soe_info.wDpAutoShow = tail_send.n;
                            g_soe_info.bDpType = false;
                        }
                    es.es_id = g_soe_info.wVipID++;
                    g_soe_info.wVipIndex++;
                    if (g_soe_info.wVipIndex >= MAX_VIP_NUMBER)
                    {
                        g_soe_info.wVipIndex = 0;
                    }

                    addr = EEP_VIP_ADDR + g_soe_info.wVipIndex * (sizeof(EVENT_SAVE));
                    e2prom_write(addr, (u8 *)&es, sizeof(EVENT_SAVE));

                    if (g_soe_info.wVipNumber < MAX_VIP_NUMBER)
                    {
                        g_soe_info.wVipNumber++;
                    }
#ifdef ADD_DEBUG_RECORD_FUN
#ifdef ADD_DEBUG_RECORD_AUTO_SHOW_FUN
                    if ((es.es_ev.ev_value == TRUE) && (IsExeEvent == TRUE)) // 当为被选中的动作事件时才存入动作记录中
#else
                    if (es.es_ev.ev_value == TRUE)
#endif
                    {
                        g_soe_info.wDebugIndex++;
                        if (g_soe_info.wDebugIndex >= MAX_DEBUG_RECORD_NUMBER)
                        {
                            g_soe_info.wDebugIndex = 0;
                        }

                        addr = EEP_DEBUG_RECORD_ADDR + g_soe_info.wDebugIndex * (sizeof(EVENT_SAVE));
                        e2prom_write(addr, (u8 *)&es, sizeof(EVENT_SAVE));

                        if (g_soe_info.wDebugNumber < MAX_DEBUG_RECORD_NUMBER)
                        {
                            g_soe_info.wDebugNumber++;
                        }
                    }
#endif
                }
            }
            // 记录操作
            else if (soe_type == SOE_TYPE_OPT)
            {
                if (es.es_ev.ev_type & SOE_TYPE_VIP)
                {
                    if (g_bVipSoe_show)
                    {
                        g_soe_info.bDpNew = true;
                        g_soe_info.wDpAutoShow = tail_send.n;
                        g_soe_info.bDpType = true;
                    }
                }
                es.es_id = g_soe_info.wOpID++;

                g_soe_info.wOpIndex++;
                if (g_soe_info.wOpIndex >= MAX_OPERATE_NUMBER)
                {
                    g_soe_info.wOpIndex = 0;
                }

                addr = EEP_OPERATE_ADDR + g_soe_info.wOpIndex * (sizeof(EVENT_SAVE));
                e2prom_write(addr, (u8 *)&es, sizeof(EVENT_SAVE));

                if (g_soe_info.wOpNumber < MAX_OPERATE_NUMBER)
                {
                    g_soe_info.wOpNumber++;
                }
            }

            // 事件内容保存完后，将事件队列的事件保存信息完善，
            // 如果队列溢出，没有办法保证事件确认的正确性。
            esp->es_flag = es.es_flag;
            esp->es_ack = es.es_ack;
            esp->es_id = addr; // 事件队列中的ID用来保存事件的地址，供事件确认用
        }
    }

    if (es_save_cnt)
    {
        e2prom_write(es_save_addr, (u8 *)&g_soe_sbuf, sizeof(EVENT_SAVE) * es_save_cnt);
        // rt_printf("soe_save:cnt=%d,head=%d,tail=%d.\r\n",es_save_cnt,head,g_soe_queue.tail_eep.n);
    }

    log_str_ext_flush(LOG_YX);
    log_str_ext_flush(LOG_SOE);

    rt_stat_other_in(5, bsp_ustimer_get_duration(us0) / USTIMER_US);
}

void soe_clear_ev(void)
{
    u32 i, addr;
    u8 tempflag[4];
#ifdef BATTERY_WITH_COMM
    bool b_bat_comm = false;
#endif
    tempflag[0] = 0;
    tempflag[1] = 0;
    tempflag[2] = 0;
    tempflag[3] = 0;
    for (i = 0; i < MAX_EVENT_NUMBER; i++)
    {
        addr = EEP_SOE_ADDR + i * (sizeof(EVENT_SAVE));
        e2prom_write(addr, tempflag, 4);
    }

    for (i = 0; i < MAX_VIP_NUMBER; i++)
    {
        addr = EEP_VIP_ADDR + i * (sizeof(EVENT_SAVE));
        e2prom_write(addr, tempflag, 4);
    }

#ifdef ADD_DEBUG_RECORD_FUN
    for (i = 0; i < MAX_DEBUG_RECORD_NUMBER; i++)
    {
        addr = EEP_DEBUG_RECORD_ADDR + i * (sizeof(EVENT_SAVE));
        e2prom_write(addr, tempflag, 4);
    }
#endif

    soe_init();
    tRunPara.sysData.wSwTzCount = 0;
    tRunPara.sysData.wSwHzCount = 0;
    tRunPara.sysData.bWriteFlag = TRUE; // 无需等待定时扫描循环，立即保存数据

#ifdef BATTERY_WITH_COMM
    for (i = 0; i < CFG_UART_NUM_MAX; i++)
    {
        if (tRunPara.tUartPara[i].wProtocol == PROTOCOL_POWER_MOD)
        {
            b_bat_comm = true;
        }
    }

    if (b_bat_comm)
    {
        ClearBattActInfo();
    }
#endif
}

void soe_clear_opt(void)
{
    u32 i, addr;
    u8 tempflag[4];
    tempflag[0] = 0;
    tempflag[1] = 0;
    tempflag[2] = 0;
    tempflag[3] = 0;
    for (i = 0; i < MAX_OPERATE_NUMBER; i++)
    {
        addr = EEP_OPERATE_ADDR + i * (sizeof(EVENT_SAVE));
        e2prom_write(addr, tempflag, 4);
    }

    soe_init();
}

bool soe_check(u32 code)
{
    DWORD dv = g_ev_words[code / 32];
    if (dv & (1 << (code % 32)))
    {
        return true;
    }
    return false;
}

int soe_stat_reset(void)
{
    int i;

    g_soe_queue.stat_eep_over = 0;

    for (i = 0; i < COMM_CHANNEL_NUM; i++)
    {
        g_soe_queue.stat_send_over[i] = 0;
        g_soe_queue.stat_ack_over[i] = 0;
    }

    for (i = 0; i < SOE_TYPE_NUM; i++)
    {
        g_soe_queue.stat_cnt_type[i] = 0;
    }

    return 0;
}

int soe_info_printf(void)
{
    int i;

    rt_printf("事件记录:Num=%d,Index=%d,id=%d,ack=%d.\r\n", g_soe_info.wEvNumber, g_soe_info.wEvIndex, g_soe_info.wEvID, g_soe_info.wEvAck);
    rt_printf("操作记录:Num=%d,Index=%d,id=%d.\r\n\r\n", g_soe_info.wOpNumber, g_soe_info.wOpIndex, g_soe_info.wOpID);

    for (i = 0; i < SOE_TYPE_NUM; i++)
    {
        rt_printf("事件统计[%02d]:%d.\r\n", i, g_soe_queue.stat_cnt_type[i]);
    }

    rt_printf("\r\n");
    rt_printf("保存队列  :head=%d,eep=%d,eep_over=%d.\r\n",
              g_soe_queue.head.n, g_soe_queue.tail_eep.n, g_soe_queue.stat_eep_over);
    for (i = 0; i < COMM_CHANNEL_NUM; i++)
    {
        rt_printf("通讯队列[%02d]:head=%d,send=%d,ack=%d,send_over=%d,ack_over=%d.\r\n",
                  i, g_soe_queue.head.n, g_soe_queue.tail_send[i].n, g_soe_queue.tail_ack[i].n, g_soe_queue.stat_send_over[i], g_soe_queue.stat_ack_over[i]);
    }

    return 0;
}

static u32 cnt_5ms;
static u32 cnt_act;
static u32 is_on;
void soe_test(void)
{
    if (g_soe_test)
    {

        cnt_5ms++;
        if (cnt_5ms == 10)
        {
            if (is_on == 0)
            {
                sw_do_pub(PUB_DO_08, SW_DO_TYPE_ON);
            }
            else
            {
                sw_do_pub(PUB_DO_08, SW_DO_TYPE_OFF);
                cnt_act++;
                if (cnt_act >= 100)
                {
                    cnt_act = 0;

                    cnt_5ms = 0;
                    g_soe_test = 0;
                    rt_printf("soe_test完成。\r\n");
                }
            }

            is_on = !is_on;
            cnt_5ms = 0;
        }
    }
}