修改链路监控

liutongyi-admin/src/main/java/com/citygis/web/controller/TabKbListenResultController.java

@@ -0,0 +1,21 @@
+package com.citygis.web.controller;
+
+
+import org.springframework.web.bind.annotation.RequestMapping;
+
+import org.springframework.web.bind.annotation.RestController;
+
+/**
+ * <p>
+ *  前端控制器
+ * </p>
+ *
+ * @author citygis
+ * @since 2025-03-12
+ */
+@RestController
+@RequestMapping("/web/tab-kb-listen-result")
+public class TabKbListenResultController {
+
+}
+

liutongyi-admin/src/main/java/com/citygis/web/domain/SlaveTabUrl.java

@@ -18,13 +18,13 @@ public class SlaveTabUrl {
     @TableId(value = "ID", type = IdType.ASSIGN_ID)
     private Integer id;
 
-    private String systemName;
+//    private String systemName;
 
     private String url;
 
-    private String success;
-
-    private String error;
+//    private String success;
+//
+//    private String error;
 
     private String requestMethodType;
 

liutongyi-admin/src/main/java/com/citygis/web/domain/TabKbListenResult.java

@@ -0,0 +1,48 @@
+package com.citygis.web.domain;
+
+import com.baomidou.mybatisplus.annotation.IdType;
+import com.baomidou.mybatisplus.annotation.TableField;
+import com.baomidou.mybatisplus.annotation.TableId;
+import com.fasterxml.jackson.annotation.JsonFormat;
+import io.swagger.annotations.ApiModel;
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+
+import java.io.Serializable;
+import java.util.Date;
+
+/**
+ * <p>
+ *
+ * </p>
+ *
+ * @author citygis
+ * @since 2025-03-12
+ */
+@Data
+@EqualsAndHashCode(callSuper = false)
+@ApiModel(value = "TabKbListenResult对象", description = "")
+public class TabKbListenResult implements Serializable {
+
+    private static final long serialVersionUID = 1L;
+
+    @TableId(value = "id", type = IdType.ASSIGN_ID)
+    private Long id;
+
+    @TableField("systemName")
+    private String systemName;
+
+    @TableField("tableName")
+    private String tableName;
+
+    @TableField("tableEnglishName")
+    private String tableEnglishName;
+
+    private Integer num;
+
+    @TableField("createTime")
+    @JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss")
+    private Date createTime;
+
+
+}

liutongyi-admin/src/main/java/com/citygis/web/mapper/TabDatalogMapper.java

@@ -8,7 +8,7 @@ import java.util.List;
 
 /**
  * <p>
- *  Mapper 接口
+ * Mapper 接口
  * </p>
  *
  * @author citygis
@@ -22,4 +22,6 @@ public interface TabDatalogMapper extends BaseMapper<TabDatalog> {
 
     TabLinkTitle getLinkTitle(TabDatalog tabDatalog);
 
+    List<TabDatalog> getDataByThatDay();
+
 }

liutongyi-admin/src/main/java/com/citygis/web/mapper/TabKbListenResultMapper.java

@@ -0,0 +1,16 @@
+package com.citygis.web.mapper;
+
+import com.citygis.web.domain.TabKbListenResult;
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+
+/**
+ * <p>
+ *  Mapper 接口
+ * </p>
+ *
+ * @author citygis
+ * @since 2025-03-12
+ */
+public interface TabKbListenResultMapper extends BaseMapper<TabKbListenResult> {
+
+}

liutongyi-admin/src/main/java/com/citygis/web/service/ITabKbListenResultService.java

@@ -0,0 +1,16 @@
+package com.citygis.web.service;
+
+import com.citygis.web.domain.TabKbListenResult;
+import com.baomidou.mybatisplus.extension.service.IService;
+
+/**
+ * <p>
+ *  服务类
+ * </p>
+ *
+ * @author citygis
+ * @since 2025-03-12
+ */
+public interface ITabKbListenResultService extends IService<TabKbListenResult> {
+
+}

liutongyi-admin/src/main/java/com/citygis/web/service/impl/TabKbListenResultServiceImpl.java

@@ -0,0 +1,20 @@
+package com.citygis.web.service.impl;
+
+import com.citygis.web.domain.TabKbListenResult;
+import com.citygis.web.mapper.TabKbListenResultMapper;
+import com.citygis.web.service.ITabKbListenResultService;
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import org.springframework.stereotype.Service;
+
+/**
+ * <p>
+ *  服务实现类
+ * </p>
+ *
+ * @author citygis
+ * @since 2025-03-12
+ */
+@Service
+public class TabKbListenResultServiceImpl extends ServiceImpl<TabKbListenResultMapper, TabKbListenResult> implements ITabKbListenResultService {
+
+}

liutongyi-admin/src/main/java/com/citygis/web/task/FileSpaceTask.java

@@ -48,7 +48,7 @@ public class FileSpaceTask {
             tabSystemSpace.setId(snowflake.nextId());
             tabSystemSpace.setFilepath(tabFileParh.getFilepath());
             tabSystemSpace.setType(tabFileParh.getType());
-            tabSystemSpace.setIp(file.getAbsolutePath());
+            tabSystemSpace.setIp(tabFileParh.getIp());
             tabSystemSpace.setFileSpace(FileUtils.getFilesLengthDesc(FileUtils.getFilesLengthB(file)));
             tabSystemSpace.setUsableSpace(FileUtils.getFilesLengthDesc(file.getUsableSpace()));
             tabSystemSpace.setFileTotalSpace(FileUtils.getFilesLengthDesc(file.getTotalSpace()));

liutongyi-admin/src/main/java/com/citygis/web/task/KBListenTask.java

@@ -0,0 +1,58 @@
+package com.citygis.web.task;
+
+import cn.hutool.core.lang.Snowflake;
+import com.citygis.common.annotation.DataSource;
+import com.citygis.common.enums.DataSourceType;
+import com.citygis.web.domain.TabDatalog;
+import com.citygis.web.domain.TabKbListenResult;
+import com.citygis.web.mapper.TabDatalogMapper;
+import com.citygis.web.service.ITabKbListenResultService;
+import org.springframework.stereotype.Component;
+
+import javax.annotation.Resource;
+import java.util.ArrayList;
+import java.util.Date;
+import java.util.List;
+
+/**
+ * @Author: zyl
+ * @CreateTime: 2025-03-12
+ * @Description: 库表监听
+ * @Version: 1.0
+ */
+@DataSource(DataSourceType.SLAVE)
+@Component("kbListenTask")
+public class KBListenTask {
+
+    @Resource
+    TabDatalogMapper tabDatalogMapper;
+
+    @Resource
+    ITabKbListenResultService tabKbListenResultService;
+
+    public void insertTabKbListenResult() {
+
+        List<TabKbListenResult> tabKbListenResultList = new ArrayList<>();
+
+        Snowflake snowflake = new Snowflake(1, 1);
+
+        List<TabDatalog> dataByThatDay = tabDatalogMapper.getDataByThatDay();
+
+        dataByThatDay.forEach(tabDatalog -> {
+            TabKbListenResult tabKbListenResult = new TabKbListenResult();
+
+            tabKbListenResult.setId(snowflake.nextId());
+            tabKbListenResult.setSystemName(tabDatalog.getSystemName());
+            tabKbListenResult.setTableName(tabDatalog.getTableName());
+            tabKbListenResult.setTableEnglishName(tabDatalog.getTableEnglishName());
+            tabKbListenResult.setNum(tabDatalog.getNum());
+            tabKbListenResult.setCreateTime(new Date());
+
+            tabKbListenResultList.add(tabKbListenResult);
+        });
+
+        tabKbListenResultService.saveBatch(tabKbListenResultList);
+
+    }
+
+}

liutongyi-admin/src/main/resources/mapper/SlaveDataBaseMapper.xml

@@ -4,11 +4,11 @@
 
 
     <select id="getSlaveTabUrl" resultType="com.citygis.web.domain.SlaveTabUrl">
-        SELECT id, system_name, url, success, error, requestMethodType, isApply
-        FROM tab_url where isApply = 1
+        SELECT id, url, requestMethodType, isApply
+        FROM emu_url where isApply = 1
     </select>
 
     <update id="updateIsApplyTabUrlById" parameterType="com.citygis.web.domain.SlaveTabUrl">
-        update tab_url set isApply = #{isApply} where id = #{id}
+        update emu_url set isApply = #{isApply} where id = #{id}
     </update>
 </mapper>

liutongyi-admin/src/main/resources/mapper/TabDatalogMapper.xml

@@ -5,66 +5,74 @@
     <select id="getDataLogList" resultType="com.citygis.web.domain.TabDatalog"
             parameterType="com.citygis.web.domain.TabDatalog">
         SELECT
-        count(1) num,
-        d.操作表 tableEnglishName,
-        tsm.table_name,
-        tsm.system_name
+        tsm.id,
+        tklr.systemName,
+        tklr.tableName,
+        tklr.tableEnglishName,
+        tklr.num,
+        FORMAT(tklr.createTime, 'yyyy-MM-dd HH:mm:ss') time
         FROM
-        数据同步日志_2025_4 d
-        left join tab_system_msg tsm
+        tab_kb_listen_result tklr
+        INNER JOIN (
+        SELECT
+        MAX(createTime) createTime,
+        tableEnglishName
+        FROM
+        tab_kb_listen_result
+        GROUP BY
+        tableEnglishName) tklr2
         on
-        tsm.table_english_name = d.操作表
+        tklr.tableEnglishName = tklr2.tableEnglishName
+        AND tklr.createTime = tklr2.createTime
+        LEFT JOIN tab_system_msg tsm on
+        tklr.tableEnglishName = tsm.table_english_name
         <where>
-            d.操作 = 'insert'
             <if test="tableName != null">
-                and tsm.table_name like concat('%',#{tableName},'%')
+                and tklr.tableName like concat('%',#{tableName},'%')
             </if>
         </where>
-
-        group by
-        d.操作表,
-        tsm.table_name,
-        tsm.system_name
-
     </select>
 
     <select id="getDatalogDetailByTableEnglishName" resultType="com.citygis.web.domain.TabDatalog"
             parameterType="com.citygis.web.domain.TabDatalog">
-        SELECT
-        count(1) num,
-        d.操作表 tableEnglishName,
-        tsm.table_name,
-        tsm.system_name
-        FROM
-        数据同步日志_2025_4 d
-        left join tab_system_msg tsm
-        on
-        tsm.table_english_name = d.操作表
+        SELECT id, systemName, tableName, tableEnglishName, num, FORMAT(createTime, 'yyyy-MM-dd HH:mm:ss') time FROM
+        tab_kb_listen_result
         <where>
-            d.操作 = 'insert'
             <if test="tableEnglishName != null">
-                and d.操作表 like concat('%',#{tableEnglishName},'%')
+                and tableEnglishName like concat('%',#{tableEnglishName},'%')
             </if>
         </where>
         <if test="startTime != null">
-            and 操作时间 >= #{startTime}
-            and 操作时间 &lt;= #{endTime}
+            and createTime >= #{startTime}
+            and createTime &lt;= #{endTime}
         </if>
-        group by
-        d.操作表,
-        tsm.table_name,
-        tsm.system_name
     </select>
 
     <select id="getLinkTitle" resultType="com.citygis.web.domain.TabLinkTitle"
             parameterType="com.citygis.web.domain.TabDatalog">
         SELECT
-        MAX(cnt) big,
-        AVG(cnt) average,
-        MIN(cnt) small
+        MAX(num) big,
+        AVG(num) average,
+        MIN(num) small
+        FROM tab_kb_listen_result
+        where tableEnglishName = #{tableEnglishName}
+    </select>
+
+    <select id="getDataByThatDay" resultType="com.citygis.web.domain.TabDatalog">
+        SELECT
+        s.system_name,
+        s.table_name,
+        s.table_english_name ,
+        COUNT(1) num
         FROM
-        (SELECT COUNT(1) AS cnt FROM 数据同步日志_2025_4 WHERE 操作表 = #{tableEnglishName} GROUP BY 操作时间) AS
-        subquery
+        数据同步日志_2025_4 d
+        INNER JOIN (SELECT system_name, table_name, table_english_name FROM tab_system_msg WHERE access_manner = '库表接口'
+        AND isApply = 1) s ON d.[操作表] = s.table_english_name
+        WHERE CONVERT(DATE, d.[操作时间], 103) = FORMAT(GETDATE(), 'yyyy-MM-dd')
+        GROUP BY
+        s.system_name,
+        s.table_name,
+        s.table_english_name
     </select>
 
 </mapper>

liutongyi-admin/src/main/resources/mapper/TabKafkalogMapper.xml

@@ -7,7 +7,7 @@
         SELECT
         tsm.id,
         tsm.table_english_name tabName,
-        ttlr.createTime time,
+        FORMAT(ttlr.createTime, 'yyyy-MM-dd HH:mm:ss') time,
         ttlr.state,
         SUM(CAST(receiveCount as int)) num
         FROM

liutongyi-admin/src/main/resources/mapper/TabKbListenResultMapper.xml

@@ -0,0 +1,5 @@
+<?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.citygis.web.mapper.TabKbListenResultMapper">
+
+</mapper>

liutongyi-admin/src/main/resources/mapper/TabLog2Mapper.xml

@@ -21,7 +21,7 @@
         ROW_NUMBER() OVER (PARTITION BY url ORDER BY time DESC) AS rn
         FROM tab_log2
         ) tl ON tulr.url = tl.url AND tl.rn = 1
-        LEFT JOIN tab_url tu ON tulr.url = tu.url
+        LEFT JOIN emu_url tu ON tulr.url = tu.url
         WHERE tulr.rn = 1
 
             <if test="url != null">

liutongyi-admin/src/main/resources/mapper/TabSystemSpaceMapper.xml

@@ -35,7 +35,7 @@
 
     <select id="getSpaceDetailByFilepath" resultType="com.citygis.web.domain.TabSystemSpace"
             parameterType="com.citygis.web.domain.TabSystemSpace">
-        select "FILEPATH","IP","DESCRIPTION","FILE_SPACE","USABLE_SPACE","FILE_TOTAL_SPACE",MAX(CREATE_TIME)
+        select "FILEPATH","IP","DESCRIPTION","FILE_SPACE","USABLE_SPACE","FILE_TOTAL_SPACE",MAX(CREATE_TIME) CREATE_TIME
         from "LIU_TONG_YI"."TAB_SYSTEM_SPACE"
         <where>
             <if test="filepath != null">