资产展示{KLTV}的代码

muyu-source-common/src/main/java/com/muyu/source/domain/AssetAuthorization.java

@@ -0,0 +1,46 @@
+package com.muyu.source.domain;
+
+import com.baomidou.mybatisplus.annotation.IdType;
+import com.baomidou.mybatisplus.annotation.TableId;
+import com.baomidou.mybatisplus.annotation.TableName;
+import com.muyu.common.core.web.domain.BaseEntity;
+import lombok.AllArgsConstructor;
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+import lombok.NoArgsConstructor;
+import lombok.experimental.SuperBuilder;
+
+/**
+ * @author Lenovo
+ * @ Tool：IntelliJ IDEA
+ * @ Author：CHX
+ * @ Date：2024-09-01-10:31
+ * @ Version：1.0
+ * @ Description：资产授权
+ */
+@EqualsAndHashCode(callSuper = true)
+@Data
+@SuperBuilder
+@AllArgsConstructor
+@NoArgsConstructor
+@TableName(value = "asset_authorization", autoResultMap = true)
+public class AssetAuthorization extends BaseEntity {
+    /**
+     * 主键
+     */
+    @TableId(value = "id", type = IdType.AUTO)
+    private Long id;
+    /**
+     * 表ID
+     */
+    private Long tableId;
+    /**
+     * 用户编号
+     */
+    private Long userId;
+    /**
+     * 部门编号
+     */
+    private Long deptId;
+
+}

muyu-source-server/src/main/java/com/muyu/source/controller/AssetDataSourceController.java

@@ -1,6 +1,7 @@
 package com.muyu.source.controller;
 
 import com.muyu.common.core.web.controller.BaseController;
+import org.springframework.web.bind.annotation.RequestMapping;
 import org.springframework.web.bind.annotation.RestController;
 
 /**
@@ -12,5 +13,8 @@ import org.springframework.web.bind.annotation.RestController;
  * @ Description：资产数据源
  */
 @RestController
+@RequestMapping("/asset")
 public class AssetDataSourceController extends BaseController {
+
+
 }

muyu-source-server/src/main/java/com/muyu/source/controller/TableInfoController.java

@@ -81,5 +81,4 @@ public class TableInfoController {
         TableInfo byId = tableInfoService.getById(id);
         return Result.success(byId);
     }
-
 }

muyu-source-server/src/main/java/com/muyu/source/service/Impl/DataSourceServiceImpl.java

@@ -6,7 +6,9 @@ import com.baomidou.mybatisplus.core.toolkit.Assert;
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
 import com.muyu.common.core.utils.StringUtils;
 import com.muyu.common.security.utils.SecurityUtils;
-import com.muyu.source.domain.*;
+import com.muyu.source.domain.DataSource;
+import com.muyu.source.domain.Structure;
+import com.muyu.source.domain.TableInfo;
 import com.muyu.source.mapper.DataSourceMapper;
 import com.muyu.source.pool.MysqlPool;
 import com.muyu.source.service.*;
@@ -20,7 +22,6 @@ import java.util.concurrent.ExecutorService;
 import java.util.concurrent.Executors;
 
 import static com.muyu.source.pool.config.BaseConfig.SELECTALL;
-import static java.util.concurrent.Executors.newFixedThreadPool;
 
 /**
  * @author Lenovo
@@ -46,10 +47,10 @@ public class DataSourceServiceImpl extends ServiceImpl<DataSourceMapper, DataSou
     @Resource
     private StructureService structureService;
 
-    private static final Long PARENTID =0L;
-    private static final String DRIVERNAME ="com.mysql.cj.jdbc.Driver";
-    private static final String MYSQL ="MySql";
-    private static final String REDIS ="redis";
+    private static final Long PARENTID = 0L;
+    private static final String DRIVERNAME = "com.mysql.cj.jdbc.Driver";
+    private static final String MYSQL = "MySql";
+    private static final String REDIS = "redis";
 
 
     /**
@@ -153,6 +154,7 @@ public class DataSourceServiceImpl extends ServiceImpl<DataSourceMapper, DataSou
 
     /**
      * 同步资产结构
+     *
      * @param etlDataScore
      * @return
      */