From a0900b1ceee3f81d890fc33a7ac1090bfc275dba Mon Sep 17 00:00:00 2001
From: liuy <37787198+LiuyCodes@users.noreply.github.com>
Date: Tue, 20 May 2025 16:34:42 +0800
Subject: [PATCH] =?UTF-8?q?feat(nifilog):=20=E6=B7=BB=E5=8A=A0=202025=20?=
 =?UTF-8?q?=E5=B9=B4=204=E6=9C=88=2030=20=E6=97=A5=E7=9A=84=E6=97=A5?=
 =?UTF-8?q?=E5=BF=97=E4=BA=8B=E4=BB=B6=E5=92=8C=E5=B1=9E=E6=80=A7=E8=A1=A8?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

- 新增 LoggingEvent20250430 和 LoggingEventProperty20250430 两个实体类
- 实现了对应的 DAO 和 Service 接口及其实现类
- 添加了分页查询、批量插入等方法
---
 .../nifilog/dao/ILoggingEvent20250430Dao.java |  23 ++
 .../dao/ILoggingEventProperty20250430Dao.java |  14 +
 .../dao/impl/LoggingEvent20250430DaoImpl.java |  26 ++
 .../LoggingEventProperty20250430DaoImpl.java  |  17 +
 .../entity/LoggingEvent20250430Entity.java    |  91 +++++
 .../entity/LoggingEvent20250430Entity.xml     | 313 ++++++++++++++++++
 .../LoggingEventProperty20250430Entity.java   |  25 ++
 .../LoggingEventProperty20250430Entity.xml    | 140 ++++++++
 .../service/ILoggingEvent20250430Service.java |  14 +
 .../ILoggingEventProperty20250430Service.java |  14 +
 .../impl/LoggingEvent20250430ServiceImpl.java |  29 ++
 ...ggingEventProperty20250430ServiceImpl.java |  29 ++
 12 files changed, 735 insertions(+)
 create mode 100644 fw-nifi/src/main/java/com/hzya/frame/nifilog/dao/ILoggingEvent20250430Dao.java
 create mode 100644 fw-nifi/src/main/java/com/hzya/frame/nifilog/dao/ILoggingEventProperty20250430Dao.java
 create mode 100644 fw-nifi/src/main/java/com/hzya/frame/nifilog/dao/impl/LoggingEvent20250430DaoImpl.java
 create mode 100644 fw-nifi/src/main/java/com/hzya/frame/nifilog/dao/impl/LoggingEventProperty20250430DaoImpl.java
 create mode 100644 fw-nifi/src/main/java/com/hzya/frame/nifilog/entity/LoggingEvent20250430Entity.java
 create mode 100644 fw-nifi/src/main/java/com/hzya/frame/nifilog/entity/LoggingEvent20250430Entity.xml
 create mode 100644 fw-nifi/src/main/java/com/hzya/frame/nifilog/entity/LoggingEventProperty20250430Entity.java
 create mode 100644 fw-nifi/src/main/java/com/hzya/frame/nifilog/entity/LoggingEventProperty20250430Entity.xml
 create mode 100644 fw-nifi/src/main/java/com/hzya/frame/nifilog/service/ILoggingEvent20250430Service.java
 create mode 100644 fw-nifi/src/main/java/com/hzya/frame/nifilog/service/ILoggingEventProperty20250430Service.java
 create mode 100644 fw-nifi/src/main/java/com/hzya/frame/nifilog/service/impl/LoggingEvent20250430ServiceImpl.java
 create mode 100644 fw-nifi/src/main/java/com/hzya/frame/nifilog/service/impl/LoggingEventProperty20250430ServiceImpl.java

diff --git a/fw-nifi/src/main/java/com/hzya/frame/nifilog/dao/ILoggingEvent20250430Dao.java b/fw-nifi/src/main/java/com/hzya/frame/nifilog/dao/ILoggingEvent20250430Dao.java
new file mode 100644
index 00000000..4d6aef2a
--- /dev/null
+++ b/fw-nifi/src/main/java/com/hzya/frame/nifilog/dao/ILoggingEvent20250430Dao.java
@@ -0,0 +1,23 @@
+package com.hzya.frame.nifilog.dao;
+
+import com.github.pagehelper.PageInfo;
+import com.hzya.frame.nifilog.entity.LoggingEvent20250430Entity;
+import com.hzya.frame.basedao.dao.IBaseDao;
+import com.hzya.frame.page.PageAttribute;
+
+import java.util.List;
+
+/**
+ * NiFi 日志事件表，按天拆分(logging_event_20250430: table)表数据库访问层
+ *
+ * @author xiang2lin
+ * @since 2025-05-20 09:37:43
+ */
+public interface ILoggingEvent20250430Dao extends IBaseDao<LoggingEvent20250430Entity, String> {
+    /**
+     * 根据指定的处理器id分页查询日志
+     *
+     * @author liuyang
+     */
+    PageInfo<LoggingEvent20250430Entity> queryLoggingEventByProcessorId(LoggingEvent20250430Entity loggingEvent20250430Entity) throws Exception;
+}
\ No newline at end of file
diff --git a/fw-nifi/src/main/java/com/hzya/frame/nifilog/dao/ILoggingEventProperty20250430Dao.java b/fw-nifi/src/main/java/com/hzya/frame/nifilog/dao/ILoggingEventProperty20250430Dao.java
new file mode 100644
index 00000000..757ff095
--- /dev/null
+++ b/fw-nifi/src/main/java/com/hzya/frame/nifilog/dao/ILoggingEventProperty20250430Dao.java
@@ -0,0 +1,14 @@
+package com.hzya.frame.nifilog.dao;
+
+import com.hzya.frame.nifilog.entity.LoggingEventProperty20250430Entity;
+import com.hzya.frame.basedao.dao.IBaseDao;
+
+/**
+ * NiFi 日志MDC属性表，按天拆分(logging_event_property_20250430: table)表数据库访问层
+ *
+ * @author xiang2lin
+ * @since 2025-05-20 09:38:36
+ */
+public interface ILoggingEventProperty20250430Dao extends IBaseDao<LoggingEventProperty20250430Entity, String> {
+
+}
\ No newline at end of file
diff --git a/fw-nifi/src/main/java/com/hzya/frame/nifilog/dao/impl/LoggingEvent20250430DaoImpl.java b/fw-nifi/src/main/java/com/hzya/frame/nifilog/dao/impl/LoggingEvent20250430DaoImpl.java
new file mode 100644
index 00000000..93e1b7ef
--- /dev/null
+++ b/fw-nifi/src/main/java/com/hzya/frame/nifilog/dao/impl/LoggingEvent20250430DaoImpl.java
@@ -0,0 +1,26 @@
+package com.hzya.frame.nifilog.dao.impl;
+
+import com.github.pagehelper.PageInfo;
+import com.hzya.frame.nifilog.entity.LoggingEvent20250430Entity;
+import com.hzya.frame.nifilog.dao.ILoggingEvent20250430Dao;
+import com.hzya.frame.page.PageHelper;
+import org.springframework.stereotype.Repository;
+import com.hzya.frame.basedao.dao.MybatisGenericDao;
+
+import java.util.List;
+
+/**
+ * NiFi 日志事件表，按天拆分(LoggingEvent20250430)表数据库访问层
+ *
+ * @author xiang2lin
+ * @since 2025-05-20 09:37:49
+ */
+@Repository(value = "LoggingEvent20250430DaoImpl")
+public class LoggingEvent20250430DaoImpl extends MybatisGenericDao<LoggingEvent20250430Entity, String> implements ILoggingEvent20250430Dao {
+    @Override
+    public PageInfo<LoggingEvent20250430Entity> queryLoggingEventByProcessorId(LoggingEvent20250430Entity loggingEvent20250430Entity) throws Exception {
+        PageHelper.startPage(loggingEvent20250430Entity.getPageNum(), loggingEvent20250430Entity.getPageSize());
+        List<LoggingEvent20250430Entity> loggingEvent20250430EntityList = query("com.hzya.frame.nifilog.dao.impl.LoggingEvent20250430DaoImpl.selectLoggingEvents", loggingEvent20250430Entity);
+        return new PageInfo(loggingEvent20250430EntityList);
+    }
+}
\ No newline at end of file
diff --git a/fw-nifi/src/main/java/com/hzya/frame/nifilog/dao/impl/LoggingEventProperty20250430DaoImpl.java b/fw-nifi/src/main/java/com/hzya/frame/nifilog/dao/impl/LoggingEventProperty20250430DaoImpl.java
new file mode 100644
index 00000000..7f331eb1
--- /dev/null
+++ b/fw-nifi/src/main/java/com/hzya/frame/nifilog/dao/impl/LoggingEventProperty20250430DaoImpl.java
@@ -0,0 +1,17 @@
+package com.hzya.frame.nifilog.dao.impl;
+
+import com.hzya.frame.nifilog.entity.LoggingEventProperty20250430Entity;
+import com.hzya.frame.nifilog.dao.ILoggingEventProperty20250430Dao;
+import org.springframework.stereotype.Repository;
+import com.hzya.frame.basedao.dao.MybatisGenericDao;
+
+/**
+ * NiFi 日志MDC属性表，按天拆分(LoggingEventProperty20250430)表数据库访问层
+ *
+ * @author xiang2lin
+ * @since 2025-05-20 09:38:36
+ */
+@Repository(value = "LoggingEventProperty20250430DaoImpl")
+public class LoggingEventProperty20250430DaoImpl extends MybatisGenericDao<LoggingEventProperty20250430Entity, String> implements ILoggingEventProperty20250430Dao {
+
+}
\ No newline at end of file
diff --git a/fw-nifi/src/main/java/com/hzya/frame/nifilog/entity/LoggingEvent20250430Entity.java b/fw-nifi/src/main/java/com/hzya/frame/nifilog/entity/LoggingEvent20250430Entity.java
new file mode 100644
index 00000000..f7fef438
--- /dev/null
+++ b/fw-nifi/src/main/java/com/hzya/frame/nifilog/entity/LoggingEvent20250430Entity.java
@@ -0,0 +1,91 @@
+package com.hzya.frame.nifilog.entity;
+
+import com.hzya.frame.web.entity.BaseEntity;
+import lombok.Data;
+
+import java.util.List;
+
+/**
+ * NiFi 日志事件表，按天拆分(LoggingEvent20250430)实体类
+ *
+ * @author xiang2lin
+ * @since 2025-05-20 09:37:50
+ */
+@Data
+public class LoggingEvent20250430Entity extends BaseEntity {
+    /**
+     * 日志时间戳（毫秒）
+     */
+    private Long timestmp;
+    /**
+     * 格式化后的日志消息
+     */
+    private String formattedMessage;
+    /**
+     * 日志记录器的名称
+     */
+    private String loggerName;
+    /**
+     * 日志级别（如INFO、ERROR）
+     */
+    private String levelString;
+    /**
+     * 线程名称
+     */
+    private String threadName;
+    /**
+     * 引用标志（预留字段，当前固定为0）
+     */
+    private Integer referenceFlag;
+    /**
+     * 日志参数0
+     */
+    private String arg0;
+    /**
+     * 日志参数1
+     */
+    private String arg1;
+    /**
+     * 日志参数2
+     */
+    private String arg2;
+    /**
+     * 日志参数3
+     */
+    private String arg3;
+    /**
+     * 调用者的文件名
+     */
+    private String callerFilename;
+    /**
+     * 调用者的类名
+     */
+    private String callerClass;
+    /**
+     * 调用者的方法名
+     */
+    private String callerMethod;
+    /**
+     * 调用者的行号
+     */
+    private String callerLine;
+    /**
+     * 事件ID，主键
+     */
+    private Long eventId;
+
+    /**
+     * 格式化的年月日
+     */
+    private String formattedTime;
+
+    /**
+     * 日志参数0列表
+     */
+    private List<String> arg0List;
+
+    /**
+     * 日期参数列表，250520
+     */
+    private List<String> logDateList;
+}
\ No newline at end of file
diff --git a/fw-nifi/src/main/java/com/hzya/frame/nifilog/entity/LoggingEvent20250430Entity.xml b/fw-nifi/src/main/java/com/hzya/frame/nifilog/entity/LoggingEvent20250430Entity.xml
new file mode 100644
index 00000000..dc835cbd
--- /dev/null
+++ b/fw-nifi/src/main/java/com/hzya/frame/nifilog/entity/LoggingEvent20250430Entity.xml
@@ -0,0 +1,313 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
+<mapper namespace="com.hzya.frame.nifilog.dao.impl.LoggingEvent20250430DaoImpl">
+
+    <resultMap id="get-LoggingEvent20250430Entity-result" type="com.hzya.frame.nifilog.entity.LoggingEvent20250430Entity" >
+           <result property="timestmp" column="timestmp" jdbcType="INTEGER"/>
+           <result property="formattedMessage" column="formatted_message" jdbcType="VARCHAR"/>
+           <result property="loggerName" column="logger_name" jdbcType="VARCHAR"/>
+           <result property="levelString" column="level_string" jdbcType="VARCHAR"/>
+           <result property="threadName" column="thread_name" jdbcType="VARCHAR"/>
+           <result property="referenceFlag" column="reference_flag" jdbcType="INTEGER"/>
+           <result property="arg0" column="arg0" jdbcType="VARCHAR"/>
+           <result property="arg1" column="arg1" jdbcType="VARCHAR"/>
+           <result property="arg2" column="arg2" jdbcType="VARCHAR"/>
+           <result property="arg3" column="arg3" jdbcType="VARCHAR"/>
+           <result property="callerFilename" column="caller_filename" jdbcType="VARCHAR"/>
+           <result property="callerClass" column="caller_class" jdbcType="VARCHAR"/>
+           <result property="callerMethod" column="caller_method" jdbcType="VARCHAR"/>
+           <result property="callerLine" column="caller_line" jdbcType="VARCHAR"/>
+           <result property="eventId" column="event_id" jdbcType="INTEGER"/>
+           <result property="formattedTime" column="formatted_time" jdbcType="VARCHAR"/>
+    </resultMap>
+
+    <!-- 查询的字段-->
+    <sql id = "LoggingEvent20250430Entity_Base_Column_List">
+        timestmp
+       ,formatted_message 
+        ,logger_name 
+        ,level_string 
+        ,thread_name 
+        ,reference_flag 
+        ,arg0 
+        ,arg1 
+        ,arg2 
+        ,arg3 
+        ,caller_filename 
+        ,caller_class 
+        ,caller_method 
+        ,caller_line 
+        ,event_id 
+     </sql>
+ <!-- 查询 采用==查询 -->
+ <select id="entity_list_base" resultMap="get-LoggingEvent20250430Entity-result" parameterType = "com.hzya.frame.nifilog.entity.LoggingEvent20250430Entity">
+    select
+    <include refid="LoggingEvent20250430Entity_Base_Column_List" />
+    from logging_event_20250430
+    <trim prefix="where" prefixOverrides="and"> 
+        <if test="timestmp != null"> and timestmp = #{timestmp} </if>
+            <if test="formattedMessage != null and formattedMessage != ''"> and formatted_message = #{formattedMessage} </if>
+            <if test="loggerName != null and loggerName != ''"> and logger_name = #{loggerName} </if>
+            <if test="levelString != null and levelString != ''"> and level_string = #{levelString} </if>
+            <if test="threadName != null and threadName != ''"> and thread_name = #{threadName} </if>
+            <if test="referenceFlag != null"> and reference_flag = #{referenceFlag} </if>
+            <if test="arg0 != null and arg0 != ''"> and arg0 = #{arg0} </if>
+            <if test="arg1 != null and arg1 != ''"> and arg1 = #{arg1} </if>
+            <if test="arg2 != null and arg2 != ''"> and arg2 = #{arg2} </if>
+            <if test="arg3 != null and arg3 != ''"> and arg3 = #{arg3} </if>
+            <if test="callerFilename != null and callerFilename != ''"> and caller_filename = #{callerFilename} </if>
+            <if test="callerClass != null and callerClass != ''"> and caller_class = #{callerClass} </if>
+            <if test="callerMethod != null and callerMethod != ''"> and caller_method = #{callerMethod} </if>
+            <if test="callerLine != null and callerLine != ''"> and caller_line = #{callerLine} </if>
+            <if test="eventId != null"> and event_id = #{eventId} </if>
+            and sts='Y'
+    </trim>
+    <if test=" sort == null or sort == ''.toString() "> order by sorts asc</if>
+    <if test=" sort !='' and sort!=null and order !='' and order!=null ">order by ${sort} ${order}</if>
+</select>
+    
+<!-- 查询符合条件的数量 -->
+<select id="entity_count" resultType="Integer" parameterType = "com.hzya.frame.nifilog.entity.LoggingEvent20250430Entity">
+        select  count(1)   from logging_event_20250430
+    <trim prefix="where" prefixOverrides="and"> 
+        <if test="timestmp != null"> and timestmp = #{timestmp} </if>
+            <if test="formattedMessage != null and formattedMessage != ''"> and formatted_message = #{formattedMessage} </if>
+            <if test="loggerName != null and loggerName != ''"> and logger_name = #{loggerName} </if>
+            <if test="levelString != null and levelString != ''"> and level_string = #{levelString} </if>
+            <if test="threadName != null and threadName != ''"> and thread_name = #{threadName} </if>
+            <if test="referenceFlag != null"> and reference_flag = #{referenceFlag} </if>
+            <if test="arg0 != null and arg0 != ''"> and arg0 = #{arg0} </if>
+            <if test="arg1 != null and arg1 != ''"> and arg1 = #{arg1} </if>
+            <if test="arg2 != null and arg2 != ''"> and arg2 = #{arg2} </if>
+            <if test="arg3 != null and arg3 != ''"> and arg3 = #{arg3} </if>
+            <if test="callerFilename != null and callerFilename != ''"> and caller_filename = #{callerFilename} </if>
+            <if test="callerClass != null and callerClass != ''"> and caller_class = #{callerClass} </if>
+            <if test="callerMethod != null and callerMethod != ''"> and caller_method = #{callerMethod} </if>
+            <if test="callerLine != null and callerLine != ''"> and caller_line = #{callerLine} </if>
+            <if test="eventId != null"> and event_id = #{eventId} </if>
+            and sts='Y'
+    </trim>
+    <if test=" sort == null or sort == ''.toString() "> order by sorts asc</if>
+    <if test=" sort !='' and sort!=null and order !='' and order!=null "> order by ${sort} ${order}</if>
+    </select>
+
+    <!-- 分页查询列表 采用like格式 -->
+<select id="entity_list_like" resultMap="get-LoggingEvent20250430Entity-result" parameterType = "com.hzya.frame.nifilog.entity.LoggingEvent20250430Entity">
+    select
+    <include refid="LoggingEvent20250430Entity_Base_Column_List" />
+    from logging_event_20250430
+    <trim prefix="where" prefixOverrides="and"> 
+        <if test="timestmp != null"> and timestmp like concat('%',#{timestmp},'%') </if>
+            <if test="formattedMessage != null and formattedMessage != ''"> and formatted_message like concat('%',#{formattedMessage},'%') </if>
+            <if test="loggerName != null and loggerName != ''"> and logger_name like concat('%',#{loggerName},'%') </if>
+            <if test="levelString != null and levelString != ''"> and level_string like concat('%',#{levelString},'%') </if>
+            <if test="threadName != null and threadName != ''"> and thread_name like concat('%',#{threadName},'%') </if>
+            <if test="referenceFlag != null"> and reference_flag like concat('%',#{referenceFlag},'%') </if>
+            <if test="arg0 != null and arg0 != ''"> and arg0 like concat('%',#{arg0},'%') </if>
+            <if test="arg1 != null and arg1 != ''"> and arg1 like concat('%',#{arg1},'%') </if>
+            <if test="arg2 != null and arg2 != ''"> and arg2 like concat('%',#{arg2},'%') </if>
+            <if test="arg3 != null and arg3 != ''"> and arg3 like concat('%',#{arg3},'%') </if>
+            <if test="callerFilename != null and callerFilename != ''"> and caller_filename like concat('%',#{callerFilename},'%') </if>
+            <if test="callerClass != null and callerClass != ''"> and caller_class like concat('%',#{callerClass},'%') </if>
+            <if test="callerMethod != null and callerMethod != ''"> and caller_method like concat('%',#{callerMethod},'%') </if>
+            <if test="callerLine != null and callerLine != ''"> and caller_line like concat('%',#{callerLine},'%') </if>
+            <if test="eventId != null"> and event_id like concat('%',#{eventId},'%') </if>
+            and sts='Y'
+    </trim>
+    <if test=" sort == null or sort == ''.toString() "> order by sorts asc</if>
+    <if test=" sort !='' and sort!=null and order !='' and order!=null ">order by ${sort} ${order}</if>
+</select>
+
+<!-- 查询列表 字段采用or格式 -->
+<select id="LoggingEvent20250430entity_list_or" resultMap="get-LoggingEvent20250430Entity-result" parameterType = "com.hzya.frame.nifilog.entity.LoggingEvent20250430Entity">
+    select
+    <include refid="LoggingEvent20250430Entity_Base_Column_List" />
+    from logging_event_20250430
+    <trim prefix="where" prefixOverrides="and"> 
+         <if test="timestmp != null"> or timestmp = #{timestmp} </if>
+             <if test="formattedMessage != null and formattedMessage != ''"> or formatted_message = #{formattedMessage} </if>
+             <if test="loggerName != null and loggerName != ''"> or logger_name = #{loggerName} </if>
+             <if test="levelString != null and levelString != ''"> or level_string = #{levelString} </if>
+             <if test="threadName != null and threadName != ''"> or thread_name = #{threadName} </if>
+             <if test="referenceFlag != null"> or reference_flag = #{referenceFlag} </if>
+             <if test="arg0 != null and arg0 != ''"> or arg0 = #{arg0} </if>
+             <if test="arg1 != null and arg1 != ''"> or arg1 = #{arg1} </if>
+             <if test="arg2 != null and arg2 != ''"> or arg2 = #{arg2} </if>
+             <if test="arg3 != null and arg3 != ''"> or arg3 = #{arg3} </if>
+             <if test="callerFilename != null and callerFilename != ''"> or caller_filename = #{callerFilename} </if>
+             <if test="callerClass != null and callerClass != ''"> or caller_class = #{callerClass} </if>
+             <if test="callerMethod != null and callerMethod != ''"> or caller_method = #{callerMethod} </if>
+             <if test="callerLine != null and callerLine != ''"> or caller_line = #{callerLine} </if>
+             <if test="eventId != null"> or event_id = #{eventId} </if>
+            and sts='Y'
+    </trim>
+    <if test=" sort == null or sort == ''.toString()  "> order by sorts asc</if>
+    <if test=" sort !='' and sort!=null and order !='' and order!=null ">order by ${sort} ${order}</if>
+</select>
+
+<!--新增所有列-->
+<insert id="entity_insert" parameterType = "com.hzya.frame.nifilog.entity.LoggingEvent20250430Entity" keyProperty="eventId" useGeneratedKeys="true">
+    insert into logging_event_20250430(
+  <trim suffix="" suffixOverrides=",">
+       <if test="timestmp != null"> timestmp , </if>
+            <if test="formattedMessage != null and formattedMessage != ''"> formatted_message , </if>
+            <if test="loggerName != null and loggerName != ''"> logger_name , </if>
+            <if test="levelString != null and levelString != ''"> level_string , </if>
+            <if test="threadName != null and threadName != ''"> thread_name , </if>
+            <if test="referenceFlag != null"> reference_flag , </if>
+            <if test="arg0 != null and arg0 != ''"> arg0 , </if>
+            <if test="arg1 != null and arg1 != ''"> arg1 , </if>
+            <if test="arg2 != null and arg2 != ''"> arg2 , </if>
+            <if test="arg3 != null and arg3 != ''"> arg3 , </if>
+            <if test="callerFilename != null and callerFilename != ''"> caller_filename , </if>
+            <if test="callerClass != null and callerClass != ''"> caller_class , </if>
+            <if test="callerMethod != null and callerMethod != ''"> caller_method , </if>
+            <if test="callerLine != null and callerLine != ''"> caller_line , </if>
+            <if test="eventId != null"> event_id , </if>
+            <if test="sorts == null ">sorts,</if>
+    <if test="sts == null ">sts,</if>
+  </trim>
+  )values(
+ <trim suffix="" suffixOverrides=",">
+       <if test="timestmp != null"> #{timestmp} ,</if>
+            <if test="formattedMessage != null and formattedMessage != ''"> #{formattedMessage} ,</if>
+            <if test="loggerName != null and loggerName != ''"> #{loggerName} ,</if>
+            <if test="levelString != null and levelString != ''"> #{levelString} ,</if>
+            <if test="threadName != null and threadName != ''"> #{threadName} ,</if>
+            <if test="referenceFlag != null"> #{referenceFlag} ,</if>
+            <if test="arg0 != null and arg0 != ''"> #{arg0} ,</if>
+            <if test="arg1 != null and arg1 != ''"> #{arg1} ,</if>
+            <if test="arg2 != null and arg2 != ''"> #{arg2} ,</if>
+            <if test="arg3 != null and arg3 != ''"> #{arg3} ,</if>
+            <if test="callerFilename != null and callerFilename != ''"> #{callerFilename} ,</if>
+            <if test="callerClass != null and callerClass != ''"> #{callerClass} ,</if>
+            <if test="callerMethod != null and callerMethod != ''"> #{callerMethod} ,</if>
+            <if test="callerLine != null and callerLine != ''"> #{callerLine} ,</if>
+            <if test="eventId != null"> #{eventId} ,</if>
+            <if test="sorts == null ">(select (max(IFNULL( a.sorts, 0 )) + 1) as sort from logging_event_20250430 a WHERE a.sts = 'Y' ),</if>
+    <if test="sts == null ">'Y',</if>
+  </trim>
+  )  
+</insert>
+<!-- 批量新增 -->
+<insert id="entityInsertBatch" keyProperty="eventId" useGeneratedKeys="true">
+  insert into logging_event_20250430(timestmp, formatted_message, logger_name, level_string, thread_name, reference_flag, arg0, arg1, arg2, arg3, caller_filename, caller_class, caller_method, caller_line,  sts) 
+    values
+    <foreach collection="entities" item="entity" separator=",">
+    (#{entity.timestmp},#{entity.formattedMessage},#{entity.loggerName},#{entity.levelString},#{entity.threadName},#{entity.referenceFlag},#{entity.arg0},#{entity.arg1},#{entity.arg2},#{entity.arg3},#{entity.callerFilename},#{entity.callerClass},#{entity.callerMethod},#{entity.callerLine}, 'Y')
+    </foreach>
+</insert>
+<!-- 批量新增或者修改-->
+<insert id="entityInsertOrUpdateBatch" keyProperty="eventId" useGeneratedKeys="true">
+    insert into logging_event_20250430(timestmp, formatted_message, logger_name, level_string, thread_name, reference_flag, arg0, arg1, arg2, arg3, caller_filename, caller_class, caller_method, caller_line)
+    values
+    <foreach collection="entities" item="entity" separator=",">
+    (#{entity.timestmp},#{entity.formattedMessage},#{entity.loggerName},#{entity.levelString},#{entity.threadName},#{entity.referenceFlag},#{entity.arg0},#{entity.arg1},#{entity.arg2},#{entity.arg3},#{entity.callerFilename},#{entity.callerClass},#{entity.callerMethod},#{entity.callerLine})
+    </foreach>
+    on duplicate key update
+    timestmp = values(timestmp),
+    formatted_message = values(formatted_message),
+    logger_name = values(logger_name),
+    level_string = values(level_string),
+    thread_name = values(thread_name),
+    reference_flag = values(reference_flag),
+    arg0 = values(arg0),
+    arg1 = values(arg1),
+    arg2 = values(arg2),
+    arg3 = values(arg3),
+    caller_filename = values(caller_filename),
+    caller_class = values(caller_class),
+    caller_method = values(caller_method),
+    caller_line = values(caller_line)</insert>
+<!--通过主键修改方法-->
+<update id="entity_update" parameterType = "com.hzya.frame.nifilog.entity.LoggingEvent20250430Entity" >
+update logging_event_20250430  set
+<trim suffix="" suffixOverrides=",">
+  <if test="timestmp != null"> timestmp = #{timestmp},</if>
+  <if test="formattedMessage != null and formattedMessage != ''"> formatted_message = #{formattedMessage},</if>
+  <if test="loggerName != null and loggerName != ''"> logger_name = #{loggerName},</if>
+  <if test="levelString != null and levelString != ''"> level_string = #{levelString},</if>
+  <if test="threadName != null and threadName != ''"> thread_name = #{threadName},</if>
+  <if test="referenceFlag != null"> reference_flag = #{referenceFlag},</if>
+  <if test="arg0 != null and arg0 != ''"> arg0 = #{arg0},</if>
+  <if test="arg1 != null and arg1 != ''"> arg1 = #{arg1},</if>
+  <if test="arg2 != null and arg2 != ''"> arg2 = #{arg2},</if>
+  <if test="arg3 != null and arg3 != ''"> arg3 = #{arg3},</if>
+  <if test="callerFilename != null and callerFilename != ''"> caller_filename = #{callerFilename},</if>
+  <if test="callerClass != null and callerClass != ''"> caller_class = #{callerClass},</if>
+  <if test="callerMethod != null and callerMethod != ''"> caller_method = #{callerMethod},</if>
+  <if test="callerLine != null and callerLine != ''"> caller_line = #{callerLine},</if>
+</trim>
+where event_id = #{eventId}
+</update>
+<!-- 逻辑删除 -->
+<update id="entity_logicDelete" parameterType = "com.hzya.frame.nifilog.entity.LoggingEvent20250430Entity" >
+update logging_event_20250430  set sts= 'N' ,modify_time = #{modify_time},modify_user_id = #{modify_user_id}
+where event_id = #{eventId}
+</update>
+<!-- 多条件逻辑删除 -->
+<update id="entity_logicDelete_Multi_Condition" parameterType = "com.hzya.frame.nifilog.entity.LoggingEvent20250430Entity" >
+update logging_event_20250430  set sts= 'N' ,modify_time = #{modify_time},modify_user_id = #{modify_user_id}
+ <trim prefix="where" prefixOverrides="and"> 
+        <if test="timestmp != null"> and timestmp = #{timestmp} </if>
+            <if test="formattedMessage != null and formattedMessage != ''"> and formatted_message = #{formattedMessage} </if>
+            <if test="loggerName != null and loggerName != ''"> and logger_name = #{loggerName} </if>
+            <if test="levelString != null and levelString != ''"> and level_string = #{levelString} </if>
+            <if test="threadName != null and threadName != ''"> and thread_name = #{threadName} </if>
+            <if test="referenceFlag != null"> and reference_flag = #{referenceFlag} </if>
+            <if test="arg0 != null and arg0 != ''"> and arg0 = #{arg0} </if>
+            <if test="arg1 != null and arg1 != ''"> and arg1 = #{arg1} </if>
+            <if test="arg2 != null and arg2 != ''"> and arg2 = #{arg2} </if>
+            <if test="arg3 != null and arg3 != ''"> and arg3 = #{arg3} </if>
+            <if test="callerFilename != null and callerFilename != ''"> and caller_filename = #{callerFilename} </if>
+            <if test="callerClass != null and callerClass != ''"> and caller_class = #{callerClass} </if>
+            <if test="callerMethod != null and callerMethod != ''"> and caller_method = #{callerMethod} </if>
+            <if test="callerLine != null and callerLine != ''"> and caller_line = #{callerLine} </if>
+            <if test="eventId != null"> and event_id = #{eventId} </if>
+            and sts='Y'
+    </trim>
+</update>
+<!--通过主键删除-->
+<delete id="entity_delete">
+    delete from logging_event_20250430 where event_id = #{eventId}
+</delete>
+
+<select id="selectLoggingEvents" parameterType="com.hzya.frame.nifilog.entity.LoggingEvent20250430Entity" resultMap="get-LoggingEvent20250430Entity-result">
+    SELECT
+        *
+    FROM
+        (
+            <foreach collection="logDateList" item="date" separator=" UNION ALL " index="index">
+                SELECT
+                    DATE_FORMAT(FROM_UNIXTIME(le.timestmp / 1000), '%Y-%m-%d %H:%i:%s') formatted_time,
+                    le.timestmp,
+                    le.formatted_message,
+                    le.logger_name,
+                    le.level_string,
+                    le.thread_name,
+                    le.reference_flag,
+                    le.arg0,
+                    le.arg1,
+                    le.arg2,
+                    le.arg3,
+                    le.caller_filename,
+                    le.caller_class,
+                    le.caller_method,
+                    le.caller_line,
+                    le.event_id
+                FROM
+                    logging_event_${date} le
+                WHERE
+                    1=1
+                    <if test="arg0List != null and arg0List.size() > 0">
+                        AND le.arg0 IN
+                        <foreach collection="arg0List" item="item" open="(" separator="," close=")" index="index">
+                            '${item}'
+                        </foreach>
+                    </if>
+            </foreach>
+        ) a
+        ORDER BY a.timestmp DESC
+</select>
+
+</mapper>
\ No newline at end of file
diff --git a/fw-nifi/src/main/java/com/hzya/frame/nifilog/entity/LoggingEventProperty20250430Entity.java b/fw-nifi/src/main/java/com/hzya/frame/nifilog/entity/LoggingEventProperty20250430Entity.java
new file mode 100644
index 00000000..967c9350
--- /dev/null
+++ b/fw-nifi/src/main/java/com/hzya/frame/nifilog/entity/LoggingEventProperty20250430Entity.java
@@ -0,0 +1,25 @@
+package com.hzya.frame.nifilog.entity;
+
+import com.hzya.frame.web.entity.BaseEntity;
+
+/**
+ * NiFi 日志MDC属性表，按天拆分(LoggingEventProperty20250430)实体类
+ *
+ * @author xiang2lin
+ * @since 2025-05-20 09:38:36
+ */
+public class LoggingEventProperty20250430Entity extends BaseEntity {
+    /**
+     * 关联logging_event表的事件ID
+     */
+    private Long eventId;
+    /**
+     * MDC属性键
+     */
+    private String mappedKey;
+    /**
+     * MDC属性值
+     */
+    private String mappedValue;
+}
+
diff --git a/fw-nifi/src/main/java/com/hzya/frame/nifilog/entity/LoggingEventProperty20250430Entity.xml b/fw-nifi/src/main/java/com/hzya/frame/nifilog/entity/LoggingEventProperty20250430Entity.xml
new file mode 100644
index 00000000..57857ab7
--- /dev/null
+++ b/fw-nifi/src/main/java/com/hzya/frame/nifilog/entity/LoggingEventProperty20250430Entity.xml
@@ -0,0 +1,140 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
+<mapper namespace="com.hzya.frame.nifilog.dao.impl.LoggingEventProperty20250430DaoImpl">
+
+    <resultMap id="get-LoggingEventProperty20250430Entity-result" type="com.hzya.frame.nifilog.entity.LoggingEventProperty20250430Entity" >
+       <result property="eventId" column="event_id" jdbcType="INTEGER"/>
+           <result property="mappedKey" column="mapped_key" jdbcType="VARCHAR"/>
+           <result property="mappedValue" column="mapped_value" jdbcType="VARCHAR"/>
+        </resultMap>
+    <!-- 查询的字段-->
+    <sql id = "LoggingEventProperty20250430Entity_Base_Column_List">
+        event_id
+       ,mapped_key 
+        ,mapped_value 
+     </sql>
+ <!-- 查询 采用==查询 -->
+ <select id="entity_list_base" resultMap="get-LoggingEventProperty20250430Entity-result" parameterType = "com.hzya.frame.nifilog.entity.LoggingEventProperty20250430Entity">
+    select
+    <include refid="LoggingEventProperty20250430Entity_Base_Column_List" />
+    from logging_event_property_20250430
+    <trim prefix="where" prefixOverrides="and"> 
+        <if test="eventId != null"> and event_id = #{eventId} </if>
+            <if test="mappedKey != null and mappedKey != ''"> and mapped_key = #{mappedKey} </if>
+            <if test="mappedValue != null and mappedValue != ''"> and mapped_value = #{mappedValue} </if>
+            and sts='Y'
+    </trim>
+    <if test=" sort == null or sort == ''.toString() "> order by sorts asc</if>
+    <if test=" sort !='' and sort!=null and order !='' and order!=null ">order by ${sort} ${order}</if>
+</select>
+    
+<!-- 查询符合条件的数量 -->
+<select id="entity_count" resultType="Integer" parameterType = "com.hzya.frame.nifilog.entity.LoggingEventProperty20250430Entity">
+        select  count(1)   from logging_event_property_20250430
+    <trim prefix="where" prefixOverrides="and"> 
+        <if test="eventId != null"> and event_id = #{eventId} </if>
+            <if test="mappedKey != null and mappedKey != ''"> and mapped_key = #{mappedKey} </if>
+            <if test="mappedValue != null and mappedValue != ''"> and mapped_value = #{mappedValue} </if>
+            and sts='Y'
+    </trim>
+    <if test=" sort == null or sort == ''.toString() "> order by sorts asc</if>
+    <if test=" sort !='' and sort!=null and order !='' and order!=null "> order by ${sort} ${order}</if>
+    </select>
+
+    <!-- 分页查询列表 采用like格式 -->
+<select id="entity_list_like" resultMap="get-LoggingEventProperty20250430Entity-result" parameterType = "com.hzya.frame.nifilog.entity.LoggingEventProperty20250430Entity">
+    select
+    <include refid="LoggingEventProperty20250430Entity_Base_Column_List" />
+    from logging_event_property_20250430
+    <trim prefix="where" prefixOverrides="and"> 
+        <if test="eventId != null"> and event_id like concat('%',#{eventId},'%') </if>
+            <if test="mappedKey != null and mappedKey != ''"> and mapped_key like concat('%',#{mappedKey},'%') </if>
+            <if test="mappedValue != null and mappedValue != ''"> and mapped_value like concat('%',#{mappedValue},'%') </if>
+            and sts='Y'
+    </trim>
+    <if test=" sort == null or sort == ''.toString() "> order by sorts asc</if>
+    <if test=" sort !='' and sort!=null and order !='' and order!=null ">order by ${sort} ${order}</if>
+</select>
+
+<!-- 查询列表 字段采用or格式 -->
+<select id="LoggingEventProperty20250430entity_list_or" resultMap="get-LoggingEventProperty20250430Entity-result" parameterType = "com.hzya.frame.nifilog.entity.LoggingEventProperty20250430Entity">
+    select
+    <include refid="LoggingEventProperty20250430Entity_Base_Column_List" />
+    from logging_event_property_20250430
+    <trim prefix="where" prefixOverrides="and"> 
+         <if test="eventId != null"> or event_id = #{eventId} </if>
+             <if test="mappedKey != null and mappedKey != ''"> or mapped_key = #{mappedKey} </if>
+             <if test="mappedValue != null and mappedValue != ''"> or mapped_value = #{mappedValue} </if>
+            and sts='Y'
+    </trim>
+    <if test=" sort == null or sort == ''.toString()  "> order by sorts asc</if>
+    <if test=" sort !='' and sort!=null and order !='' and order!=null ">order by ${sort} ${order}</if>
+</select>
+
+<!--新增所有列-->
+<insert id="entity_insert" parameterType = "com.hzya.frame.nifilog.entity.LoggingEventProperty20250430Entity" keyProperty="eventId" useGeneratedKeys="true">
+    insert into logging_event_property_20250430(
+  <trim suffix="" suffixOverrides=",">
+       <if test="eventId != null"> event_id , </if>
+            <if test="mappedKey != null and mappedKey != ''"> mapped_key , </if>
+            <if test="mappedValue != null and mappedValue != ''"> mapped_value , </if>
+            <if test="sorts == null ">sorts,</if>
+    <if test="sts == null ">sts,</if>
+  </trim>
+  )values(
+ <trim suffix="" suffixOverrides=",">
+       <if test="eventId != null"> #{eventId} ,</if>
+            <if test="mappedKey != null and mappedKey != ''"> #{mappedKey} ,</if>
+            <if test="mappedValue != null and mappedValue != ''"> #{mappedValue} ,</if>
+            <if test="sorts == null ">(select (max(IFNULL( a.sorts, 0 )) + 1) as sort from logging_event_property_20250430 a WHERE a.sts = 'Y' ),</if>
+    <if test="sts == null ">'Y',</if>
+  </trim>
+  )  
+</insert>
+<!-- 批量新增 -->
+<insert id="entityInsertBatch" keyProperty="eventId" useGeneratedKeys="true">
+  insert into logging_event_property_20250430(mapped_value,  sts) 
+    values
+    <foreach collection="entities" item="entity" separator=",">
+    (#{entity.mappedValue}, 'Y')
+    </foreach>
+</insert>
+<!-- 批量新增或者修改-->
+<insert id="entityInsertOrUpdateBatch" keyProperty="eventId" useGeneratedKeys="true">
+    insert into logging_event_property_20250430(mapped_value)
+    values
+    <foreach collection="entities" item="entity" separator=",">
+    (#{entity.mappedValue})
+    </foreach>
+    on duplicate key update
+    mapped_value = values(mapped_value)</insert>
+<!--通过主键修改方法-->
+<update id="entity_update" parameterType = "com.hzya.frame.nifilog.entity.LoggingEventProperty20250430Entity" >
+update logging_event_property_20250430  set
+<trim suffix="" suffixOverrides=",">
+  <if test="mappedValue != null and mappedValue != ''"> mapped_value = #{mappedValue},</if>
+</trim>
+where event_id = #{eventId}
+</update>
+<!-- 逻辑删除 -->
+<update id="entity_logicDelete" parameterType = "com.hzya.frame.nifilog.entity.LoggingEventProperty20250430Entity" >
+update logging_event_property_20250430  set sts= 'N' ,modify_time = #{modify_time},modify_user_id = #{modify_user_id}
+where event_id = #{eventId}
+</update>
+<!-- 多条件逻辑删除 -->
+<update id="entity_logicDelete_Multi_Condition" parameterType = "com.hzya.frame.nifilog.entity.LoggingEventProperty20250430Entity" >
+update logging_event_property_20250430  set sts= 'N' ,modify_time = #{modify_time},modify_user_id = #{modify_user_id}
+ <trim prefix="where" prefixOverrides="and"> 
+        <if test="eventId != null"> and event_id = #{eventId} </if>
+            <if test="mappedKey != null and mappedKey != ''"> and mapped_key = #{mappedKey} </if>
+            <if test="mappedValue != null and mappedValue != ''"> and mapped_value = #{mappedValue} </if>
+            and sts='Y'
+    </trim>
+</update>
+<!--通过主键删除-->
+<delete id="entity_delete">
+    delete from logging_event_property_20250430 where event_id = #{eventId}
+</delete>
+
+</mapper>
+
diff --git a/fw-nifi/src/main/java/com/hzya/frame/nifilog/service/ILoggingEvent20250430Service.java b/fw-nifi/src/main/java/com/hzya/frame/nifilog/service/ILoggingEvent20250430Service.java
new file mode 100644
index 00000000..783b1cc5
--- /dev/null
+++ b/fw-nifi/src/main/java/com/hzya/frame/nifilog/service/ILoggingEvent20250430Service.java
@@ -0,0 +1,14 @@
+package com.hzya.frame.nifilog.service;
+
+import com.hzya.frame.nifilog.entity.LoggingEvent20250430Entity;
+import com.hzya.frame.basedao.service.IBaseService;
+
+/**
+ * NiFi 日志事件表，按天拆分(LoggingEvent20250430)表服务接口
+ *
+ * @author xiang2lin
+ * @since 2025-05-20 09:37:51
+ */
+public interface ILoggingEvent20250430Service extends IBaseService<LoggingEvent20250430Entity, String> {
+
+}
\ No newline at end of file
diff --git a/fw-nifi/src/main/java/com/hzya/frame/nifilog/service/ILoggingEventProperty20250430Service.java b/fw-nifi/src/main/java/com/hzya/frame/nifilog/service/ILoggingEventProperty20250430Service.java
new file mode 100644
index 00000000..0e538a66
--- /dev/null
+++ b/fw-nifi/src/main/java/com/hzya/frame/nifilog/service/ILoggingEventProperty20250430Service.java
@@ -0,0 +1,14 @@
+package com.hzya.frame.nifilog.service;
+
+import com.hzya.frame.nifilog.entity.LoggingEventProperty20250430Entity;
+import com.hzya.frame.basedao.service.IBaseService;
+
+/**
+ * NiFi 日志MDC属性表，按天拆分(LoggingEventProperty20250430)表服务接口
+ *
+ * @author xiang2lin
+ * @since 2025-05-20 09:38:36
+ */
+public interface ILoggingEventProperty20250430Service extends IBaseService<LoggingEventProperty20250430Entity, String> {
+
+}
\ No newline at end of file
diff --git a/fw-nifi/src/main/java/com/hzya/frame/nifilog/service/impl/LoggingEvent20250430ServiceImpl.java b/fw-nifi/src/main/java/com/hzya/frame/nifilog/service/impl/LoggingEvent20250430ServiceImpl.java
new file mode 100644
index 00000000..862d01f5
--- /dev/null
+++ b/fw-nifi/src/main/java/com/hzya/frame/nifilog/service/impl/LoggingEvent20250430ServiceImpl.java
@@ -0,0 +1,29 @@
+package com.hzya.frame.nifilog.service.impl;
+
+import com.hzya.frame.nifilog.entity.LoggingEvent20250430Entity;
+import com.hzya.frame.nifilog.dao.ILoggingEvent20250430Dao;
+import com.hzya.frame.nifilog.service.ILoggingEvent20250430Service;
+import org.springframework.stereotype.Service;
+import org.springframework.beans.factory.annotation.Autowired;
+
+import javax.annotation.Resource;
+
+import com.hzya.frame.basedao.service.impl.BaseService;
+
+/**
+ * NiFi 日志事件表，按天拆分(LoggingEvent20250430)表服务实现类
+ *
+ * @author xiang2lin
+ * @since 2025-05-20 09:37:52
+ */
+@Service(value = "loggingEvent20250430Service")
+public class LoggingEvent20250430ServiceImpl extends BaseService<LoggingEvent20250430Entity, String> implements ILoggingEvent20250430Service {
+
+    private ILoggingEvent20250430Dao loggingEvent20250430Dao;
+
+    @Autowired
+    public void setLoggingEvent20250430Dao(ILoggingEvent20250430Dao dao) {
+        this.loggingEvent20250430Dao = dao;
+        this.dao = dao;
+    }
+}
diff --git a/fw-nifi/src/main/java/com/hzya/frame/nifilog/service/impl/LoggingEventProperty20250430ServiceImpl.java b/fw-nifi/src/main/java/com/hzya/frame/nifilog/service/impl/LoggingEventProperty20250430ServiceImpl.java
new file mode 100644
index 00000000..11032d2a
--- /dev/null
+++ b/fw-nifi/src/main/java/com/hzya/frame/nifilog/service/impl/LoggingEventProperty20250430ServiceImpl.java
@@ -0,0 +1,29 @@
+package com.hzya.frame.nifilog.service.impl;
+
+import com.hzya.frame.nifilog.entity.LoggingEventProperty20250430Entity;
+import com.hzya.frame.nifilog.dao.ILoggingEventProperty20250430Dao;
+import com.hzya.frame.nifilog.service.ILoggingEventProperty20250430Service;
+import org.springframework.stereotype.Service;
+import org.springframework.beans.factory.annotation.Autowired;
+
+import javax.annotation.Resource;
+
+import com.hzya.frame.basedao.service.impl.BaseService;
+
+/**
+ * NiFi 日志MDC属性表，按天拆分(LoggingEventProperty20250430)表服务实现类
+ *
+ * @author xiang2lin
+ * @since 2025-05-20 09:38:36
+ */
+@Service(value = "loggingEventProperty20250430Service")
+public class LoggingEventProperty20250430ServiceImpl extends BaseService<LoggingEventProperty20250430Entity, String> implements ILoggingEventProperty20250430Service {
+
+    private ILoggingEventProperty20250430Dao loggingEventProperty20250430Dao;
+
+    @Autowired
+    public void setLoggingEventProperty20250430Dao(ILoggingEventProperty20250430Dao dao) {
+        this.loggingEventProperty20250430Dao = dao;
+        this.dao = dao;
+    }
+}