feat: add pre calculate of logmonitor (#757)

traas-stack · Dec 11, 2023 · 452546c · 452546c
1 parent b87ee62
commit 452546c
Show file tree

Hide file tree

Showing 33 changed files with 875 additions and 92 deletions.
diff --git a/...mon/common-dao-gen/src/main/java/io/holoinsight/server/common/dao/entity/AggTaskV1DO.java b/...mon/common-dao-gen/src/main/java/io/holoinsight/server/common/dao/entity/AggTaskV1DO.java
@@ -18,6 +18,8 @@ public class AggTaskV1DO {
 
   private Long version;
 
+  private String refId;
+
   private Integer deleted;
 
   private String json;
@@ -62,6 +64,14 @@ public void setVersion(Long version) {
     this.version = version;
   }
 
+  public String getRefId() {
+    return refId;
+  }
+
+  public void setRefId(String refId) {
+    this.refId = refId == null ? null : refId.trim();
+  }
+
   public Integer getDeleted() {
     return deleted;
   }
@@ -89,6 +99,7 @@ public String toString() {
     sb.append(", gmtModified=").append(gmtModified);
     sb.append(", aggId=").append(aggId);
     sb.append(", version=").append(version);
+    sb.append(", refId=").append(refId);
     sb.append(", deleted=").append(deleted);
     sb.append(", json=").append(json);
     sb.append("]");
@@ -116,6 +127,8 @@ public boolean equals(Object that) {
             : this.getAggId().equals(other.getAggId()))
         && (this.getVersion() == null ? other.getVersion() == null
             : this.getVersion().equals(other.getVersion()))
+        && (this.getRefId() == null ? other.getRefId() == null
+            : this.getRefId().equals(other.getRefId()))
         && (this.getDeleted() == null ? other.getDeleted() == null
             : this.getDeleted().equals(other.getDeleted()))
         && (this.getJson() == null ? other.getJson() == null
@@ -131,6 +144,7 @@ public int hashCode() {
     result = prime * result + ((getGmtModified() == null) ? 0 : getGmtModified().hashCode());
     result = prime * result + ((getAggId() == null) ? 0 : getAggId().hashCode());
     result = prime * result + ((getVersion() == null) ? 0 : getVersion().hashCode());
+    result = prime * result + ((getRefId() == null) ? 0 : getRefId().hashCode());
     result = prime * result + ((getDeleted() == null) ? 0 : getDeleted().hashCode());
     result = prime * result + ((getJson() == null) ? 0 : getJson().hashCode());
     return result;
@@ -172,6 +186,11 @@ public Builder version(Long version) {
       return this;
     }
 
+    public Builder refId(String refId) {
+      obj.setRefId(refId);
+      return this;
+    }
+
     public Builder deleted(Integer deleted) {
       obj.setDeleted(deleted);
       return this;
@@ -190,8 +209,9 @@ public AggTaskV1DO build() {
   public enum Column {
     id("id", "id", "BIGINT", false), gmtCreate("gmt_create", "gmtCreate", "TIMESTAMP",
         false), gmtModified("gmt_modified", "gmtModified", "TIMESTAMP", false), aggId("agg_id",
-            "aggId", "VARCHAR", false), version("version", "version", "BIGINT", false), deleted(
-                "deleted", "deleted", "INTEGER", false), json("json", "json", "LONGVARCHAR", false);
+            "aggId", "VARCHAR", false), version("version", "version", "BIGINT",
+                false), refId("ref_id", "refId", "VARCHAR", false), deleted("deleted", "deleted",
+                    "INTEGER", false), json("json", "json", "LONGVARCHAR", false);
 
     private static final String BEGINNING_DELIMITER = "`";
 

diff --git a/...mon-dao-gen/src/main/java/io/holoinsight/server/common/dao/entity/AggTaskV1DOExample.java b/...mon-dao-gen/src/main/java/io/holoinsight/server/common/dao/entity/AggTaskV1DOExample.java
@@ -666,6 +666,109 @@ public Criteria andVersionNotBetween(Long value1, Long value2) {
       return (Criteria) this;
     }
 
+    public Criteria andRefIdIsNull() {
+      addCriterion("ref_id is null");
+      return (Criteria) this;
+    }
+
+    public Criteria andRefIdIsNotNull() {
+      addCriterion("ref_id is not null");
+      return (Criteria) this;
+    }
+
+    public Criteria andRefIdEqualTo(String value) {
+      addCriterion("ref_id =", value, "refId");
+      return (Criteria) this;
+    }
+
+    public Criteria andRefIdEqualToColumn(AggTaskV1DO.Column column) {
+      addCriterion(new StringBuilder("ref_id = ").append(column.getEscapedColumnName()).toString());
+      return (Criteria) this;
+    }
+
+    public Criteria andRefIdNotEqualTo(String value) {
+      addCriterion("ref_id <>", value, "refId");
+      return (Criteria) this;
+    }
+
+    public Criteria andRefIdNotEqualToColumn(AggTaskV1DO.Column column) {
+      addCriterion(
+          new StringBuilder("ref_id <> ").append(column.getEscapedColumnName()).toString());
+      return (Criteria) this;
+    }
+
+    public Criteria andRefIdGreaterThan(String value) {
+      addCriterion("ref_id >", value, "refId");
+      return (Criteria) this;
+    }
+
+    public Criteria andRefIdGreaterThanColumn(AggTaskV1DO.Column column) {
+      addCriterion(new StringBuilder("ref_id > ").append(column.getEscapedColumnName()).toString());
+      return (Criteria) this;
+    }
+
+    public Criteria andRefIdGreaterThanOrEqualTo(String value) {
+      addCriterion("ref_id >=", value, "refId");
+      return (Criteria) this;
+    }
+
+    public Criteria andRefIdGreaterThanOrEqualToColumn(AggTaskV1DO.Column column) {
+      addCriterion(
+          new StringBuilder("ref_id >= ").append(column.getEscapedColumnName()).toString());
+      return (Criteria) this;
+    }
+
+    public Criteria andRefIdLessThan(String value) {
+      addCriterion("ref_id <", value, "refId");
+      return (Criteria) this;
+    }
+
+    public Criteria andRefIdLessThanColumn(AggTaskV1DO.Column column) {
+      addCriterion(new StringBuilder("ref_id < ").append(column.getEscapedColumnName()).toString());
+      return (Criteria) this;
+    }
+
+    public Criteria andRefIdLessThanOrEqualTo(String value) {
+      addCriterion("ref_id <=", value, "refId");
+      return (Criteria) this;
+    }
+
+    public Criteria andRefIdLessThanOrEqualToColumn(AggTaskV1DO.Column column) {
+      addCriterion(
+          new StringBuilder("ref_id <= ").append(column.getEscapedColumnName()).toString());
+      return (Criteria) this;
+    }
+
+    public Criteria andRefIdLike(String value) {
+      addCriterion("ref_id like", value, "refId");
+      return (Criteria) this;
+    }
+
+    public Criteria andRefIdNotLike(String value) {
+      addCriterion("ref_id not like", value, "refId");
+      return (Criteria) this;
+    }
+
+    public Criteria andRefIdIn(List<String> values) {
+      addCriterion("ref_id in", values, "refId");
+      return (Criteria) this;
+    }
+
+    public Criteria andRefIdNotIn(List<String> values) {
+      addCriterion("ref_id not in", values, "refId");
+      return (Criteria) this;
+    }
+
+    public Criteria andRefIdBetween(String value1, String value2) {
+      addCriterion("ref_id between", value1, value2, "refId");
+      return (Criteria) this;
+    }
+
+    public Criteria andRefIdNotBetween(String value1, String value2) {
+      addCriterion("ref_id not between", value1, value2, "refId");
+      return (Criteria) this;
+    }
+
     public Criteria andDeletedIsNull() {
       addCriterion("deleted is null");
       return (Criteria) this;

diff --git a/server/common/common-dao-gen/src/main/resources/sqlmap/AggTaskV1DOMapper.xml b/server/common/common-dao-gen/src/main/resources/sqlmap/AggTaskV1DOMapper.xml
@@ -7,6 +7,7 @@
     <result column="gmt_modified" jdbcType="TIMESTAMP" property="gmtModified" />
     <result column="agg_id" jdbcType="VARCHAR" property="aggId" />
     <result column="version" jdbcType="BIGINT" property="version" />
+    <result column="ref_id" jdbcType="VARCHAR" property="refId" />
     <result column="deleted" jdbcType="INTEGER" property="deleted" />
   </resultMap>
   <resultMap extends="BaseResultMap" id="ResultMapWithBLOBs" type="io.holoinsight.server.common.dao.entity.AggTaskV1DO">
@@ -71,7 +72,7 @@
     </where>
   </sql>
   <sql id="Base_Column_List">
-    id, gmt_create, gmt_modified, agg_id, version, deleted
+    id, gmt_create, gmt_modified, agg_id, version, ref_id, deleted
   </sql>
   <sql id="Blob_Column_List">
     json
@@ -192,11 +193,11 @@
   </delete>
   <insert id="insert" parameterType="io.holoinsight.server.common.dao.entity.AggTaskV1DO">
     insert into agg_task_v1 (id, gmt_create, gmt_modified, 
-      agg_id, version, deleted, 
-      json)
+      agg_id, version, ref_id, 
+      deleted, json)
     values (#{id,jdbcType=BIGINT}, #{gmtCreate,jdbcType=TIMESTAMP}, #{gmtModified,jdbcType=TIMESTAMP}, 
-      #{aggId,jdbcType=VARCHAR}, #{version,jdbcType=BIGINT}, #{deleted,jdbcType=INTEGER}, 
-      #{json,jdbcType=LONGVARCHAR})
+      #{aggId,jdbcType=VARCHAR}, #{version,jdbcType=BIGINT}, #{refId,jdbcType=VARCHAR}, 
+      #{deleted,jdbcType=INTEGER}, #{json,jdbcType=LONGVARCHAR})
   </insert>
   <insert id="insertSelective" parameterType="map">
     insert into agg_task_v1
@@ -223,6 +224,9 @@
           <if test="record.version != null">
             version,
           </if>
+          <if test="record.refId != null">
+            ref_id,
+          </if>
           <if test="record.deleted != null">
             deleted,
           </if>
@@ -257,6 +261,9 @@
           <if test="record.version != null">
             #{record.version,jdbcType=BIGINT},
           </if>
+          <if test="record.refId != null">
+            #{record.refId,jdbcType=VARCHAR},
+          </if>
           <if test="record.deleted != null">
             #{record.deleted,jdbcType=INTEGER},
           </if>
@@ -299,6 +306,9 @@
           <if test="record.version != null">
             version = #{record.version,jdbcType=BIGINT},
           </if>
+          <if test="record.refId != null">
+            ref_id = #{record.refId,jdbcType=VARCHAR},
+          </if>
           <if test="record.deleted != null">
             deleted = #{record.deleted,jdbcType=INTEGER},
           </if>
@@ -319,6 +329,7 @@
       gmt_modified = #{record.gmtModified,jdbcType=TIMESTAMP},
       agg_id = #{record.aggId,jdbcType=VARCHAR},
       version = #{record.version,jdbcType=BIGINT},
+      ref_id = #{record.refId,jdbcType=VARCHAR},
       deleted = #{record.deleted,jdbcType=INTEGER},
       json = #{record.json,jdbcType=LONGVARCHAR}
     <if test="_parameter != null">
@@ -332,6 +343,7 @@
       gmt_modified = #{record.gmtModified,jdbcType=TIMESTAMP},
       agg_id = #{record.aggId,jdbcType=VARCHAR},
       version = #{record.version,jdbcType=BIGINT},
+      ref_id = #{record.refId,jdbcType=VARCHAR},
       deleted = #{record.deleted,jdbcType=INTEGER}
     <if test="_parameter != null">
       <include refid="Update_By_Example_Where_Clause" />
@@ -360,6 +372,9 @@
           <if test="record.version != null">
             version = #{record.version,jdbcType=BIGINT},
           </if>
+          <if test="record.refId != null">
+            ref_id = #{record.refId,jdbcType=VARCHAR},
+          </if>
           <if test="record.deleted != null">
             deleted = #{record.deleted,jdbcType=INTEGER},
           </if>
@@ -377,6 +392,7 @@
       gmt_modified = #{gmtModified,jdbcType=TIMESTAMP},
       agg_id = #{aggId,jdbcType=VARCHAR},
       version = #{version,jdbcType=BIGINT},
+      ref_id = #{refId,jdbcType=VARCHAR},
       deleted = #{deleted,jdbcType=INTEGER},
       json = #{json,jdbcType=LONGVARCHAR}
     where id = #{id,jdbcType=BIGINT}
@@ -387,6 +403,7 @@
       gmt_modified = #{gmtModified,jdbcType=TIMESTAMP},
       agg_id = #{aggId,jdbcType=VARCHAR},
       version = #{version,jdbcType=BIGINT},
+      ref_id = #{refId,jdbcType=VARCHAR},
       deleted = #{deleted,jdbcType=INTEGER}
     where id = #{id,jdbcType=BIGINT}
   </update>
@@ -441,12 +458,12 @@
   </select>
   <insert id="batchInsert" parameterType="map">
     insert into agg_task_v1
-    (id, gmt_create, gmt_modified, agg_id, version, deleted, json)
+    (id, gmt_create, gmt_modified, agg_id, version, ref_id, deleted, json)
     values
     <foreach collection="list" item="item" separator=",">
       (#{item.id,jdbcType=BIGINT}, #{item.gmtCreate,jdbcType=TIMESTAMP}, #{item.gmtModified,jdbcType=TIMESTAMP}, 
-        #{item.aggId,jdbcType=VARCHAR}, #{item.version,jdbcType=BIGINT}, #{item.deleted,jdbcType=INTEGER}, 
-        #{item.json,jdbcType=LONGVARCHAR})
+        #{item.aggId,jdbcType=VARCHAR}, #{item.version,jdbcType=BIGINT}, #{item.refId,jdbcType=VARCHAR}, 
+        #{item.deleted,jdbcType=INTEGER}, #{item.json,jdbcType=LONGVARCHAR})
     </foreach>
   </insert>
   <insert id="batchInsertSelective" parameterType="map">
@@ -474,6 +491,9 @@
         <if test="'version'.toString() == column.value">
           #{item.version,jdbcType=BIGINT}
         </if>
+        <if test="'ref_id'.toString() == column.value">
+          #{item.refId,jdbcType=VARCHAR}
+        </if>
         <if test="'deleted'.toString() == column.value">
           #{item.deleted,jdbcType=INTEGER}
         </if>
@@ -509,6 +529,9 @@
           <if test="record.version != null">
             version,
           </if>
+          <if test="record.refId != null">
+            ref_id,
+          </if>
           <if test="record.deleted != null">
             deleted,
           </if>
@@ -543,6 +566,9 @@
           <if test="record.version != null">
             #{record.version,jdbcType=BIGINT},
           </if>
+          <if test="record.refId != null">
+            #{record.refId,jdbcType=VARCHAR},
+          </if>
           <if test="record.deleted != null">
             #{record.deleted,jdbcType=INTEGER},
           </if>
@@ -576,6 +602,9 @@
           <if test="record.version != null">
             version = #{record.version,jdbcType=BIGINT},
           </if>
+          <if test="record.refId != null">
+            ref_id = #{record.refId,jdbcType=VARCHAR},
+          </if>
           <if test="record.deleted != null">
             deleted = #{record.deleted,jdbcType=INTEGER},
           </if>
@@ -588,32 +617,34 @@
   </insert>
   <insert id="upsert" parameterType="io.holoinsight.server.common.dao.entity.AggTaskV1DO">
     insert into agg_task_v1
-    (id, gmt_create, gmt_modified, agg_id, version, deleted)
+    (id, gmt_create, gmt_modified, agg_id, version, ref_id, deleted)
     values
     (#{id,jdbcType=BIGINT}, #{gmtCreate,jdbcType=TIMESTAMP}, #{gmtModified,jdbcType=TIMESTAMP}, 
-      #{aggId,jdbcType=VARCHAR}, #{version,jdbcType=BIGINT}, #{deleted,jdbcType=INTEGER}
-      )
+      #{aggId,jdbcType=VARCHAR}, #{version,jdbcType=BIGINT}, #{refId,jdbcType=VARCHAR}, 
+      #{deleted,jdbcType=INTEGER})
     on duplicate key update 
     id = #{id,jdbcType=BIGINT}, 
     gmt_create = #{gmtCreate,jdbcType=TIMESTAMP}, 
     gmt_modified = #{gmtModified,jdbcType=TIMESTAMP}, 
     agg_id = #{aggId,jdbcType=VARCHAR}, 
     version = #{version,jdbcType=BIGINT}, 
+    ref_id = #{refId,jdbcType=VARCHAR}, 
     deleted = #{deleted,jdbcType=INTEGER}
   </insert>
   <insert id="upsertWithBLOBs" parameterType="io.holoinsight.server.common.dao.entity.AggTaskV1DO">
     insert into agg_task_v1
-    (id, gmt_create, gmt_modified, agg_id, version, deleted, json)
+    (id, gmt_create, gmt_modified, agg_id, version, ref_id, deleted, json)
     values
     (#{id,jdbcType=BIGINT}, #{gmtCreate,jdbcType=TIMESTAMP}, #{gmtModified,jdbcType=TIMESTAMP}, 
-      #{aggId,jdbcType=VARCHAR}, #{version,jdbcType=BIGINT}, #{deleted,jdbcType=INTEGER}, 
-      #{json,jdbcType=LONGVARCHAR})
+      #{aggId,jdbcType=VARCHAR}, #{version,jdbcType=BIGINT}, #{refId,jdbcType=VARCHAR}, 
+      #{deleted,jdbcType=INTEGER}, #{json,jdbcType=LONGVARCHAR})
     on duplicate key update 
     id = #{id,jdbcType=BIGINT}, 
     gmt_create = #{gmtCreate,jdbcType=TIMESTAMP}, 
     gmt_modified = #{gmtModified,jdbcType=TIMESTAMP}, 
     agg_id = #{aggId,jdbcType=VARCHAR}, 
     version = #{version,jdbcType=BIGINT}, 
+    ref_id = #{refId,jdbcType=VARCHAR}, 
     deleted = #{deleted,jdbcType=INTEGER}, 
     json = #{json,jdbcType=LONGVARCHAR}
   </insert>