初始内容提交

etl-manager/pom.xml

@@ -111,30 +111,6 @@
 			</properties>
 		</profile>
 
-		<profile>
-			<id>yanyuan</id>
-			<properties>
-				<profiles.active>yanyuan</profiles.active>
-				<profiles.nacos.server-addr>172.16.30.245:8848</profiles.nacos.server-addr>
-				<profiles.nacos.group>DEFAULT_GROUP</profiles.nacos.group>
-				<profiles.nacos.namespace>smart-gov</profiles.nacos.namespace>
-				<package.environment>build:prod</package.environment>
-				<skipDeploy>true</skipDeploy>
-			</properties>
-		</profile>
-
-		<profile>
-			<id>pengxi</id>
-			<properties>
-				<profiles.active>pengxi</profiles.active>
-				<profiles.nacos.server-addr>192.168.106.6:8848</profiles.nacos.server-addr>
-				<profiles.nacos.group>DEFAULT_GROUP</profiles.nacos.group>
-				<profiles.nacos.namespace>smart-gov</profiles.nacos.namespace>
-				<package.environment>build:prod</package.environment>
-				<skipDeploy>true</skipDeploy>
-			</properties>
-		</profile>
-
 	</profiles>
 
 	<dependencies>

etl-manager/src/main/java/com/mortals/xhx/base/framework/interceptor/AuthUserInterceptor.java

@@ -34,8 +34,6 @@ public class AuthUserInterceptor extends BaseInterceptor {
     private InterceptorConfig config;
     @Autowired
     private IAuthTokenService authTokenService;
-    @Autowired
-    private ICacheService cacheService;
 
     @Override
     public int getOrder() {

etl-manager/src/main/java/com/mortals/xhx/common/code/DeletedEnum.java

@@ -4,13 +4,13 @@ import java.util.LinkedHashMap;
 import java.util.Map;
 
 /**
-* 是否删除，(0.否，1.是)枚举类
+* 是否删除 (0.未删除,1.删除)枚举类
 *
 * @author zxfei
 */
 public enum DeletedEnum {
-    否(0, "否"),
-    是(1, "是");
+    未删除(0, "未删除"),
+    删除(1, "删除");
     private Integer value;
     private String desc;
 

etl-manager/src/main/java/com/mortals/xhx/common/code/EnabledEnum.java

@@ -4,7 +4,7 @@ import java.util.LinkedHashMap;
 import java.util.Map;
 
 /**
-* 启用状态 (0.停止，1.启用)枚举类
+* 启用状态,(0.停止,1.启用)枚举类
 *
 * @author zxfei
 */

etl-manager/src/main/java/com/mortals/xhx/common/code/FunctionScopeEnum.java

+package com.mortals.xhx.common.code;
+
+import java.util.LinkedHashMap;
+import java.util.Map;
+
+/**
+* 作用域,(global.全局,local.局部)枚举类
+*
+* @author zxfei
+*/
+public enum FunctionScopeEnum {
+    全局("global", "全局"),
+    局部("local", "局部");
+    private String value;
+    private String desc;
+
+    FunctionScopeEnum(String value, String desc) {
+        this.value = value;
+        this.desc = desc;
+    }
+
+    public String getValue() {
+        return this.value;
+    }
+
+    public String getDesc() {
+        return this.desc;
+    }
+
+    public static FunctionScopeEnum getByValue(String value) {
+        for (FunctionScopeEnum functionScopeEnum : FunctionScopeEnum.values()) {
+            if (functionScopeEnum.getValue() == value) {
+                return functionScopeEnum;
+            }
+        }
+        return null;
+    }
+
+    /**
+    * 获取Map集合
+    *
+    * @param eItem 不包含项
+    * @return
+    */
+    public static Map<String, String> getEnumMap(String... eItem) {
+        Map<String, String> resultMap = new LinkedHashMap<>();
+        for (FunctionScopeEnum item : FunctionScopeEnum.values()) {
+            try {
+                boolean hasE = false;
+                for (String e : eItem) {
+                    if (item.getValue() == e) {
+                        hasE = true;
+                        break;
+                    }
+                }
+                if (!hasE) {
+                    resultMap.put(item.getValue() + "", item.getDesc());
+                }
+            } catch (Exception ex) {
+
+            }
+        }
+        return resultMap;
+    }
+}
\ No newline at end of file

etl-manager/src/main/java/com/mortals/xhx/common/code/MsgTypeEnum.java

+package com.mortals.xhx.common.code;
+
+import java.util.LinkedHashMap;
+import java.util.Map;
+
+/**
+* 信息类型 (通知,营销)枚举类
+*
+* @author zxfei
+*/
+public enum MsgTypeEnum {
+    通知("通知", "通知"),
+    营销("营销", "营销");
+    private String value;
+    private String desc;
+
+    MsgTypeEnum(String value, String desc) {
+        this.value = value;
+        this.desc = desc;
+    }
+
+    public String getValue() {
+        return this.value;
+    }
+
+    public String getDesc() {
+        return this.desc;
+    }
+
+    public static MsgTypeEnum getByValue(String value) {
+        for (MsgTypeEnum msgTypeEnum : MsgTypeEnum.values()) {
+            if (msgTypeEnum.getValue() == value) {
+                return msgTypeEnum;
+            }
+        }
+        return null;
+    }
+
+    /**
+    * 获取Map集合
+    *
+    * @param eItem 不包含项
+    * @return
+    */
+    public static Map<String, String> getEnumMap(String... eItem) {
+        Map<String, String> resultMap = new LinkedHashMap<>();
+        for (MsgTypeEnum item : MsgTypeEnum.values()) {
+            try {
+                boolean hasE = false;
+                for (String e : eItem) {
+                    if (item.getValue() == e) {
+                        hasE = true;
+                        break;
+                    }
+                }
+                if (!hasE) {
+                    resultMap.put(item.getValue() + "", item.getDesc());
+                }
+            } catch (Exception ex) {
+
+            }
+        }
+        return resultMap;
+    }
+}
\ No newline at end of file

etl-manager/src/main/java/com/mortals/xhx/common/code/ReturnTypeEnum.java

+package com.mortals.xhx.common.code;
+
+import java.util.LinkedHashMap;
+import java.util.Map;
+
+/**
+* 函数返回类型,(int,long,string,array,map,object)枚举类
+*
+* @author zxfei
+*/
+public enum ReturnTypeEnum {
+    int("int", "int"),
+    long("long", "long"),
+    string("string", "string"),
+    array("array", "array"),
+    map("map", "map"),
+    object("object", "object");
+    private String value;
+    private String desc;
+
+    ReturnTypeEnum(String value, String desc) {
+        this.value = value;
+        this.desc = desc;
+    }
+
+    public String getValue() {
+        return this.value;
+    }
+
+    public String getDesc() {
+        return this.desc;
+    }
+
+    public static ReturnTypeEnum getByValue(String value) {
+        for (ReturnTypeEnum returnTypeEnum : ReturnTypeEnum.values()) {
+            if (returnTypeEnum.getValue() == value) {
+                return returnTypeEnum;
+            }
+        }
+        return null;
+    }
+
+    /**
+    * 获取Map集合
+    *
+    * @param eItem 不包含项
+    * @return
+    */
+    public static Map<String, String> getEnumMap(String... eItem) {
+        Map<String, String> resultMap = new LinkedHashMap<>();
+        for (ReturnTypeEnum item : ReturnTypeEnum.values()) {
+            try {
+                boolean hasE = false;
+                for (String e : eItem) {
+                    if (item.getValue() == e) {
+                        hasE = true;
+                        break;
+                    }
+                }
+                if (!hasE) {
+                    resultMap.put(item.getValue() + "", item.getDesc());
+                }
+            } catch (Exception ex) {
+
+            }
+        }
+        return resultMap;
+    }
+}
\ No newline at end of file

etl-manager/src/main/java/com/mortals/xhx/common/code/ShowTypeEnum.java

+package com.mortals.xhx.common.code;
+
+import java.util.LinkedHashMap;
+import java.util.Map;
+
+/**
+* 展示类型 (1.弹框,2.文字)枚举类
+*
+* @author zxfei
+*/
+public enum ShowTypeEnum {
+    弹框(1, "弹框"),
+    文字(2, "文字");
+    private Integer value;
+    private String desc;
+
+    ShowTypeEnum(Integer value, String desc) {
+        this.value = value;
+        this.desc = desc;
+    }
+
+    public Integer getValue() {
+        return this.value;
+    }
+
+    public String getDesc() {
+        return this.desc;
+    }
+
+    public static ShowTypeEnum getByValue(Integer value) {
+        for (ShowTypeEnum showTypeEnum : ShowTypeEnum.values()) {
+            if (showTypeEnum.getValue() == value) {
+                return showTypeEnum;
+            }
+        }
+        return null;
+    }
+
+    /**
+    * 获取Map集合
+    *
+    * @param eItem 不包含项
+    * @return
+    */
+    public static Map<String, String> getEnumMap(Integer... eItem) {
+        Map<String, String> resultMap = new LinkedHashMap<>();
+        for (ShowTypeEnum item : ShowTypeEnum.values()) {
+            try {
+                boolean hasE = false;
+                for (Integer e : eItem) {
+                    if (item.getValue() == e) {
+                        hasE = true;
+                        break;
+                    }
+                }
+                if (!hasE) {
+                    resultMap.put(item.getValue() + "", item.getDesc());
+                }
+            } catch (Exception ex) {
+
+            }
+        }
+        return resultMap;
+    }
+}
\ No newline at end of file

etl-manager/src/main/java/com/mortals/xhx/common/code/StatusEnum.java

@@ -4,13 +4,16 @@ import java.util.LinkedHashMap;
 import java.util.Map;
 
 /**
-* 启用状态 (0.停止，1.启用)枚举类
+* 状态 (0.未处理,1.处理中,2.失败,3.成功,4.不处理)枚举类
 *
 * @author zxfei
 */
 public enum StatusEnum {
-    停止(0, "停止"),
-    启用(1, "启用");
+    未处理(0, "未处理"),
+    处理中(1, "处理中"),
+    失败(2, "失败"),
+    成功(3, "成功"),
+    不处理(4, "不处理");
     private Integer value;
     private String desc;
 

etl-manager/src/main/java/com/mortals/xhx/common/utils/ZipUtils.java

@@ -12,8 +12,7 @@ import java.io.*;
 public class ZipUtils {
     public static void main(String[] args) throws Exception {
         unzip(new File("F:\\1664176173348.zip"), "F:\\tmp");
-//        String path = "F:\\Users\\Isuzu\\Desktop\\test.zip";
-//        unzip(new File(path), "D:\\data");
+
     }
 
     public static void unzip(File zipFile, String descDir) {

etl-manager/src/main/java/com/mortals/xhx/daemon/task/SyncUserTaskImpl.java

@@ -15,11 +15,8 @@ import org.springframework.stereotype.Service;
  */
 @Slf4j
 @Service("SyncUserTask")
-@ConditionalOnExpression("'${platform.type:null}'=='cloud'")
 public class SyncUserTaskImpl implements ITaskExcuteService {
 
-    @Autowired
-    private IUserFeign userFeign;
     @Autowired
     private UserService userService;
 

etl-manager/src/main/java/com/mortals/xhx/module/alarm/dao/AlarmSmsInfoDao.java

+package com.mortals.xhx.module.alarm.dao;
+
+import com.mortals.framework.dao.ICRUDDao;
+import com.mortals.xhx.module.alarm.model.AlarmSmsInfoEntity;
+import java.util.List;
+/**
+* 短信告警信息Dao
+* 短信告警信息 DAO接口
+*
+* @author zxfei
+* @date 2024-07-15
+*/
+
+public interface  AlarmSmsInfoDao extends ICRUDDao<AlarmSmsInfoEntity,Long>{
+
+
+}

etl-manager/src/main/java/com/mortals/xhx/module/alarm/dao/ibatis/AlarmSmsInfoDaoImpl.java

+package com.mortals.xhx.module.alarm.dao.ibatis;
+
+
+import org.springframework.stereotype.Repository;
+import com.mortals.xhx.module.alarm.dao.AlarmSmsInfoDao;
+import com.mortals.xhx.module.alarm.model.AlarmSmsInfoEntity;
+import java.util.Date;
+import com.mortals.framework.dao.ibatis.BaseCRUDDaoMybatis;
+import java.util.List;
+/**
+* 短信告警信息DaoImpl DAO接口
+*
+* @author zxfei
+* @date 2024-07-15
+*/
+@Repository("alarmSmsInfoDao")
+public class AlarmSmsInfoDaoImpl extends BaseCRUDDaoMybatis<AlarmSmsInfoEntity,Long> implements AlarmSmsInfoDao {
+
+
+
+}

etl-manager/src/main/java/com/mortals/xhx/module/alarm/model/AlarmSmsInfoEntity.java

+package com.mortals.xhx.module.alarm.model;
+import java.util.List;
+import java.util.ArrayList;
+import java.math.BigDecimal;
+import cn.hutool.core.date.DateUtil;
+import java.util.Date;
+import com.fasterxml.jackson.annotation.JsonFormat;
+import com.mortals.framework.annotation.Excel;
+import com.mortals.framework.model.BaseEntityLong;
+import com.mortals.xhx.module.alarm.model.vo.AlarmSmsInfoVo;
+import lombok.Data;
+/**
+* 短信告警信息实体对象
+*
+* @author zxfei
+* @date 2024-07-15
+*/
+@Data
+public class AlarmSmsInfoEntity extends AlarmSmsInfoVo {
+    private static final long serialVersionUID = 1L;
+
+    /**
+    * 任务说明
+    */
+    private String title;
+    /**
+    * 信息
+    */
+    private String msg;
+    /**
+    * 信息类型 (通知,营销)
+    */
+    private String msgType;
+    /**
+    * 短信附带连接
+    */
+    private String msgUrl;
+    /**
+    * 手机号
+    */
+    private String phone;
+    /**
+    * 状态 (0.未处理,1.处理中,2.失败,3.成功,4.不处理)
+    */
+    private Integer status;
+    /**
+    * 创建用户名称
+    */
+    private String createUserName;
+    @Override
+    public int hashCode() {
+         return this.getId().hashCode();
+    }
+    @Override
+    public boolean equals(Object obj) {
+        if (obj == null) return false;
+        if (obj instanceof AlarmSmsInfoEntity) {
+            AlarmSmsInfoEntity tmp = (AlarmSmsInfoEntity) obj;
+            if (this.getId() == tmp.getId()) {
+                 return true;
+            }
+        }
+        return false;
+    }
+
+    public void initAttrValue(){
+            this.title = "";
+            this.msg = "";
+            this.msgType = "";
+            this.msgUrl = "";
+            this.phone = "";
+            this.status = 0;
+            this.createUserName = "";
+    }
+}
\ No newline at end of file

etl-manager/src/main/java/com/mortals/xhx/module/alarm/model/vo/AlarmSmsInfoVo.java

+package com.mortals.xhx.module.alarm.model.vo;
+import com.mortals.framework.model.BaseEntityLong;
+import com.mortals.xhx.module.alarm.model.AlarmSmsInfoEntity;
+import java.util.ArrayList;
+import java.util.List;
+import lombok.Data;
+import com.mortals.framework.annotation.Excel;
+import java.math.BigDecimal;
+import java.util.Date;
+/**
+* 短信告警信息视图对象
+*
+* @author zxfei
+* @date 2024-07-15
+*/
+@Data
+public class AlarmSmsInfoVo extends BaseEntityLong {
+
+    /** 序号，主键，自增长列表 */
+    private List <Long> idList;
+
+
+}
\ No newline at end of file

etl-manager/src/main/java/com/mortals/xhx/module/alarm/service/AlarmSmsInfoService.java

+package com.mortals.xhx.module.alarm.service;
+import com.mortals.framework.service.ICRUDService;
+import com.mortals.xhx.module.alarm.model.AlarmSmsInfoEntity;
+import com.mortals.xhx.module.alarm.dao.AlarmSmsInfoDao;
+/**
+* AlarmSmsInfoService
+*
+* 短信告警信息 service接口
+*
+* @author zxfei
+* @date 2024-07-15
+*/
+public interface AlarmSmsInfoService extends ICRUDService<AlarmSmsInfoEntity,Long>{
+
+    AlarmSmsInfoDao getDao();
+}
\ No newline at end of file

etl-manager/src/main/java/com/mortals/xhx/module/alarm/service/impl/AlarmSmsInfoServiceImpl.java

+package com.mortals.xhx.module.alarm.service.impl;
+import org.springframework.stereotype.Service;
+import com.mortals.framework.service.impl.AbstractCRUDServiceImpl;
+import com.mortals.framework.exception.AppException;
+import com.mortals.framework.model.Context;
+import com.mortals.xhx.module.alarm.dao.AlarmSmsInfoDao;
+import com.mortals.xhx.module.alarm.model.AlarmSmsInfoEntity;
+import com.mortals.xhx.module.alarm.service.AlarmSmsInfoService;
+import lombok.extern.slf4j.Slf4j;
+/**
+* AlarmSmsInfoService
+* 短信告警信息 service实现
+*
+* @author zxfei
+* @date 2024-07-15
+*/
+@Service("alarmSmsInfoService")
+@Slf4j
+public class AlarmSmsInfoServiceImpl extends AbstractCRUDServiceImpl<AlarmSmsInfoDao, AlarmSmsInfoEntity, Long> implements AlarmSmsInfoService {
+    
+}
\ No newline at end of file

etl-manager/src/main/java/com/mortals/xhx/module/alarm/web/AlarmSmsInfoController.java

+package com.mortals.xhx.module.alarm.web;
+import com.mortals.framework.web.BaseCRUDJsonBodyMappingController;
+import com.mortals.xhx.base.system.param.service.ParamService;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RestController;
+import org.springframework.web.bind.annotation.*;
+import com.mortals.framework.model.Context;
+import javax.servlet.http.HttpServletRequest;
+import javax.servlet.http.HttpServletResponse;
+import com.mortals.framework.web.BaseCRUDJsonBodyMappingController;
+import com.mortals.xhx.module.alarm.model.AlarmSmsInfoEntity;
+import com.mortals.xhx.module.alarm.service.AlarmSmsInfoService;
+import org.apache.commons.lang3.ArrayUtils;
+import com.mortals.framework.util.StringUtils;
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
+import java.util.stream.Collectors;
+import com.alibaba.fastjson.JSONObject;
+import java.util.Arrays;
+import org.springframework.web.bind.annotation.*;
+import org.springframework.web.multipart.MultipartFile;
+import static com.mortals.framework.ap.SysConstains.*;
+import com.mortals.xhx.common.code.*;
+/**
+*
+* 短信告警信息
+*
+* @author zxfei
+* @date 2024-07-15
+*/
+@RestController
+@RequestMapping("alarm/sms/info")
+public class AlarmSmsInfoController extends BaseCRUDJsonBodyMappingController<AlarmSmsInfoService,AlarmSmsInfoEntity,Long> {
+
+    @Autowired
+    private ParamService paramService;
+
+    public AlarmSmsInfoController(){
+        super.setModuleDesc( "短信告警信息");
+    }
+
+    @Override
+    protected void init(Map<String, Object> model, Context context) {
+                this.addDict(model, "msgType", MsgTypeEnum.getEnumMap());
+                this.addDict(model, "status", StatusEnum.getEnumMap());
+        super.init(model, context);
+    }
+
+
+}
\ No newline at end of file

etl-manager/src/main/java/com/mortals/xhx/module/apply/dao/ApplyTaskInfoDao.java

+package com.mortals.xhx.module.apply.dao;
+
+import com.mortals.framework.dao.ICRUDDao;
+import com.mortals.xhx.module.apply.model.ApplyTaskInfoEntity;
+import java.util.List;
+/**
+* etl申请源任务信息Dao
+* etl申请源任务信息 DAO接口
+*
+* @author zxfei
+* @date 2024-07-15
+*/
+
+public interface  ApplyTaskInfoDao extends ICRUDDao<ApplyTaskInfoEntity,Long>{
+
+
+}

etl-manager/src/main/java/com/mortals/xhx/module/apply/dao/ibatis/ApplyTaskInfoDaoImpl.java

+package com.mortals.xhx.module.apply.dao.ibatis;
+
+
+import org.springframework.stereotype.Repository;
+import com.mortals.xhx.module.apply.dao.ApplyTaskInfoDao;
+import com.mortals.xhx.module.apply.model.ApplyTaskInfoEntity;
+import java.util.Date;
+import com.mortals.framework.dao.ibatis.BaseCRUDDaoMybatis;
+import java.util.List;
+/**
+* etl申请源任务信息DaoImpl DAO接口
+*
+* @author zxfei
+* @date 2024-07-15
+*/
+@Repository("applyTaskInfoDao")
+public class ApplyTaskInfoDaoImpl extends BaseCRUDDaoMybatis<ApplyTaskInfoEntity,Long> implements ApplyTaskInfoDao {
+
+
+
+}

etl-manager/src/main/java/com/mortals/xhx/module/apply/model/ApplyTaskInfoEntity.java

+package com.mortals.xhx.module.apply.model;
+import java.util.List;
+import java.util.ArrayList;
+import java.math.BigDecimal;
+import cn.hutool.core.date.DateUtil;
+import java.util.Date;
+import com.fasterxml.jackson.annotation.JsonFormat;
+import com.mortals.framework.annotation.Excel;
+import com.mortals.framework.model.BaseEntityLong;
+import com.mortals.xhx.module.apply.model.vo.ApplyTaskInfoVo;
+import lombok.Data;
+/**
+* etl申请源任务信息实体对象
+*
+* @author zxfei
+* @date 2024-07-15
+*/
+@Data
+public class ApplyTaskInfoEntity extends ApplyTaskInfoVo {
+    private static final long serialVersionUID = 1L;
+
+    /**
+    * 任务说明
+    */
+    private String etlContext;
+    /**
+    * 输入数据源id
+    */
+    private String dataSourcesChooseInput;
+    /**
+    * 输入数据源类型
+    */
+    private String dataSourceTypeInput;
+    /**
+    * 输入数据源表名
+    */
+    private String dataSourcesTableNameInput;
+    /**
+    * 输入数据源文件名
+    */
+    private String dataSourcesFileNameInput;
+    /**
+    * 输入数据源文件列名
+    */
+    private String dataSourcesFileColumns;
+    /**
+    * 输入数据源表列名
+    */
+    private String dataSourcesTableColumns;
+    /**
+    * 输入数据源参数
+    */
+    private String dataSourcesParamsInput;
+    /**
+    * 输入数据源过滤条件
+    */
+    private String dataSourcesFilterInput;
+    /**
+    * 输出数据源id
+    */
+    private String dataSourcesChooseOutput;
+    /**
+    * 输出数据源类型
+    */
+    private String dataSourceTypeOutput;
+    /**
+    * 输出数据源表名
+    */
+    private String dataSourcesTableNameOutput;
+    /**
+    * 输出数据源文件名
+    */
+    private String dataSourcesFileNameOutput;
+    /**
+    * 输出数据源参数
+    */
+    private String dataSourcesParamsOutput;
+    /**
+    * 输入输出自定映射关系
+    */
+    private String columnDatas;
+    /**
+    * 数据源数据源删除条件
+    */
+    private String dataSourcesClearOutput;
+    /**
+    * 表所属公司
+    */
+    private String company;
+    /**
+    * 表所属部门
+    */
+    private String section;
+    /**
+    * 表所属服务
+    */
+    private String service;
+    /**
+    * 更新说明
+    */
+    private String updateContext;
+    /**
+    * 字段个数
+    */
+    private String columnSize;
+    /**
+    * 行数范围
+    */
+    private String rowsRange;
+    /**
+    * 错误率
+    */
+    private String errorRate;
+    /**
+    * 是否开启质量检测
+    */
+    private String enableQuality;
+    /**
+    * 去重字段
+    */
+    private String duplicateColumns;
+    /**
+    * 不可重复字段
+    */
+    private String primaryColumns;
+    /**
+    * 输入文件类型
+    */
+    private String fileTypeInput;
+    /**
+    * 输入文件编码
+    */
+    private String encodingInput;
+    /**
+    * 输入分割符
+    */
+    private String sepInput;
+    /**
+    * 输出文件类型
+    */
+    private String fileTypeOutput;
+    /**
+    * 输出文件编码
+    */
+    private String encodingOutput;
+    /**
+    * 输出文件分割符
+    */
+    private String sepOutput;
+    /**
+    * 输入是否包含表头
+    */
+    private String headerInput;
+    /**
+    * 输出是否包含表头
+    */
+    private String headerOutput;
+    /**
+    * 洗牌个数默认空
+    */
+    private String repartitionNumInput;
+    /**
+    * 洗牌字段默认空
+    */
+    private String repartitionColsInput;
+    /**
+    * 写入模式默认空
+    */
+    private String modelOutput;
+    /**
+    * 分区字段默认空
+    */
+    private String partitionByOutput;
+    /**
+    * 合并小文件默认-1 不合并
+    */
+    private String mergeOutput;
+    /**
+    * 产品code
+    */
+    private String productCode;
+    /**
+    * 用户组
+    */
+    private String dimGroup;
+    /**
+    * 是否删除 (0.未删除,1.删除)
+    */
+    private Integer deleted;
+    /**
+    * 拥有者
+    */
+    private String owner;
+    /**
+    * 创建用户名称
+    */
+    private String createUserName;
+    @Override
+    public int hashCode() {
+         return this.getId().hashCode();
+    }
+    @Override
+    public boolean equals(Object obj) {
+        if (obj == null) return false;
+        if (obj instanceof ApplyTaskInfoEntity) {
+            ApplyTaskInfoEntity tmp = (ApplyTaskInfoEntity) obj;
+            if (this.getId() == tmp.getId()) {
+                 return true;
+            }
+        }
+        return false;
+    }
+
+    public void initAttrValue(){
+            this.etlContext = "";
+            this.dataSourcesChooseInput = "";
+            this.dataSourceTypeInput = "";
+            this.dataSourcesTableNameInput = "";
+            this.dataSourcesFileNameInput = "";
+            this.dataSourcesFileColumns = "";
+            this.dataSourcesTableColumns = "";
+            this.dataSourcesParamsInput = "";
+            this.dataSourcesFilterInput = "";
+            this.dataSourcesChooseOutput = "";
+            this.dataSourceTypeOutput = "";
+            this.dataSourcesTableNameOutput = "";
+            this.dataSourcesFileNameOutput = "";
+            this.dataSourcesParamsOutput = "";
+            this.columnDatas = "";
+            this.dataSourcesClearOutput = "";
+            this.company = "";
+            this.section = "";
+            this.service = "";
+            this.updateContext = "";
+            this.columnSize = "";
+            this.rowsRange = "";
+            this.errorRate = "";
+            this.enableQuality = "";
+            this.duplicateColumns = "";
+            this.primaryColumns = "";
+            this.fileTypeInput = "";
+            this.encodingInput = "";
+            this.sepInput = "";
+            this.fileTypeOutput = "";
+            this.encodingOutput = "";
+            this.sepOutput = "";
+            this.headerInput = "";
+            this.headerOutput = "";
+            this.repartitionNumInput = "";
+            this.repartitionColsInput = "";
+            this.modelOutput = "";
+            this.partitionByOutput = "";
+            this.mergeOutput = "-1";
+            this.productCode = "";
+            this.dimGroup = "";
+            this.deleted = 0;
+            this.owner = "";
+            this.createUserName = "";
+    }
+}
\ No newline at end of file

etl-manager/src/main/java/com/mortals/xhx/module/apply/model/vo/ApplyTaskInfoVo.java

+package com.mortals.xhx.module.apply.model.vo;
+import com.mortals.framework.model.BaseEntityLong;
+import com.mortals.xhx.module.apply.model.ApplyTaskInfoEntity;
+import java.util.ArrayList;
+import java.util.List;
+import lombok.Data;
+import com.mortals.framework.annotation.Excel;
+import java.math.BigDecimal;
+import java.util.Date;
+/**
+* etl申请源任务信息视图对象
+*
+* @author zxfei
+* @date 2024-07-15
+*/
+@Data
+public class ApplyTaskInfoVo extends BaseEntityLong {
+
+    /** 序号，主键，自增长列表 */
+    private List <Long> idList;
+
+
+}
\ No newline at end of file

etl-manager/src/main/java/com/mortals/xhx/module/apply/service/ApplyTaskInfoService.java

+package com.mortals.xhx.module.apply.service;
+import com.mortals.framework.service.ICRUDService;
+import com.mortals.xhx.module.apply.model.ApplyTaskInfoEntity;
+import com.mortals.xhx.module.apply.dao.ApplyTaskInfoDao;
+/**
+* ApplyTaskInfoService
+*
+* etl申请源任务信息 service接口
+*
+* @author zxfei
+* @date 2024-07-15
+*/
+public interface ApplyTaskInfoService extends ICRUDService<ApplyTaskInfoEntity,Long>{
+
+    ApplyTaskInfoDao getDao();
+}
\ No newline at end of file

etl-manager/src/main/java/com/mortals/xhx/module/apply/service/impl/ApplyTaskInfoServiceImpl.java

+package com.mortals.xhx.module.apply.service.impl;
+import org.springframework.stereotype.Service;
+import com.mortals.framework.service.impl.AbstractCRUDServiceImpl;
+import com.mortals.framework.exception.AppException;
+import com.mortals.framework.model.Context;
+import com.mortals.xhx.module.apply.dao.ApplyTaskInfoDao;
+import com.mortals.xhx.module.apply.model.ApplyTaskInfoEntity;
+import com.mortals.xhx.module.apply.service.ApplyTaskInfoService;
+import lombok.extern.slf4j.Slf4j;
+/**
+* ApplyTaskInfoService
+* etl申请源任务信息 service实现
+*
+* @author zxfei
+* @date 2024-07-15
+*/
+@Service("applyTaskInfoService")
+@Slf4j
+public class ApplyTaskInfoServiceImpl extends AbstractCRUDServiceImpl<ApplyTaskInfoDao, ApplyTaskInfoEntity, Long> implements ApplyTaskInfoService {
+    
+}
\ No newline at end of file

etl-manager/src/main/java/com/mortals/xhx/module/apply/web/ApplyTaskInfoController.java

+package com.mortals.xhx.module.apply.web;
+import com.mortals.framework.web.BaseCRUDJsonBodyMappingController;
+import com.mortals.xhx.base.system.param.service.ParamService;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RestController;
+import org.springframework.web.bind.annotation.*;
+import com.mortals.framework.model.Context;
+import javax.servlet.http.HttpServletRequest;
+import javax.servlet.http.HttpServletResponse;
+import com.mortals.framework.web.BaseCRUDJsonBodyMappingController;
+import com.mortals.xhx.module.apply.model.ApplyTaskInfoEntity;
+import com.mortals.xhx.module.apply.service.ApplyTaskInfoService;
+import org.apache.commons.lang3.ArrayUtils;
+import com.mortals.framework.util.StringUtils;
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
+import java.util.stream.Collectors;
+import com.alibaba.fastjson.JSONObject;
+import java.util.Arrays;
+import org.springframework.web.bind.annotation.*;
+import org.springframework.web.multipart.MultipartFile;
+import static com.mortals.framework.ap.SysConstains.*;
+import com.mortals.xhx.common.code.*;
+/**
+*
+* etl申请源任务信息
+*
+* @author zxfei
+* @date 2024-07-15
+*/
+@RestController
+@RequestMapping("apply/task/info")
+public class ApplyTaskInfoController extends BaseCRUDJsonBodyMappingController<ApplyTaskInfoService,ApplyTaskInfoEntity,Long> {
+
+    @Autowired
+    private ParamService paramService;
+
+    public ApplyTaskInfoController(){
+        super.setModuleDesc( "etl申请源任务信息");
+    }
+
+    @Override
+    protected void init(Map<String, Object> model, Context context) {
+                this.addDict(model, "deleted", DeletedEnum.getEnumMap());
+        super.init(model, context);
+    }
+
+
+}
\ No newline at end of file

etl-manager/src/main/java/com/mortals/xhx/module/data/dao/DataSourcesInfoDao.java

+package com.mortals.xhx.module.data.dao;
+
+import com.mortals.framework.dao.ICRUDDao;
+import com.mortals.xhx.module.data.model.DataSourcesInfoEntity;
+import java.util.List;
+/**
+* 数据源信息Dao
+* 数据源信息 DAO接口
+*
+* @author zxfei
+* @date 2024-07-15
+*/
+
+public interface  DataSourcesInfoDao extends ICRUDDao<DataSourcesInfoEntity,Long>{
+
+
+}

etl-manager/src/main/java/com/mortals/xhx/module/data/dao/DataSourcesTypeInfoDao.java

+package com.mortals.xhx.module.data.dao;
+
+import com.mortals.framework.dao.ICRUDDao;
+import com.mortals.xhx.module.data.model.DataSourcesTypeInfoEntity;
+import java.util.List;
+/**
+* 数据源类型Dao
+* 数据源类型 DAO接口
+*
+* @author zxfei
+* @date 2024-07-15
+*/
+
+public interface  DataSourcesTypeInfoDao extends ICRUDDao<DataSourcesTypeInfoEntity,Long>{
+
+
+}

etl-manager/src/main/java/com/mortals/xhx/module/data/dao/DataTagGroupInfoDao.java

+package com.mortals.xhx.module.data.dao;
+
+import com.mortals.framework.dao.ICRUDDao;
+import com.mortals.xhx.module.data.model.DataTagGroupInfoEntity;
+import java.util.List;
+/**
+* 权限-数据标识组信息Dao
+* 权限-数据标识组信息 DAO接口
+*
+* @author zxfei
+* @date 2024-07-15
+*/
+
+public interface  DataTagGroupInfoDao extends ICRUDDao<DataTagGroupInfoEntity,Long>{
+
+
+}

etl-manager/src/main/java/com/mortals/xhx/module/data/dao/DataTagInfoDao.java

+package com.mortals.xhx.module.data.dao;
+
+import com.mortals.framework.dao.ICRUDDao;
+import com.mortals.xhx.module.data.model.DataTagInfoEntity;
+import java.util.List;
+/**
+* 权限-数据标识信息Dao
+* 权限-数据标识信息 DAO接口
+*
+* @author zxfei
+* @date 2024-07-15
+*/
+
+public interface  DataTagInfoDao extends ICRUDDao<DataTagInfoEntity,Long>{
+
+
+}

etl-manager/src/main/java/com/mortals/xhx/module/data/dao/ibatis/DataSourcesInfoDaoImpl.java

+package com.mortals.xhx.module.data.dao.ibatis;
+
+
+import org.springframework.stereotype.Repository;
+import com.mortals.xhx.module.data.dao.DataSourcesInfoDao;
+import com.mortals.xhx.module.data.model.DataSourcesInfoEntity;
+import java.util.Date;
+import com.mortals.framework.dao.ibatis.BaseCRUDDaoMybatis;
+import java.util.List;
+/**
+* 数据源信息DaoImpl DAO接口
+*
+* @author zxfei
+* @date 2024-07-15
+*/
+@Repository("dataSourcesInfoDao")
+public class DataSourcesInfoDaoImpl extends BaseCRUDDaoMybatis<DataSourcesInfoEntity,Long> implements DataSourcesInfoDao {
+
+
+
+}

etl-manager/src/main/java/com/mortals/xhx/module/data/dao/ibatis/DataSourcesTypeInfoDaoImpl.java

+package com.mortals.xhx.module.data.dao.ibatis;
+
+
+import org.springframework.stereotype.Repository;
+import com.mortals.xhx.module.data.dao.DataSourcesTypeInfoDao;
+import com.mortals.xhx.module.data.model.DataSourcesTypeInfoEntity;
+import java.util.Date;
+import com.mortals.framework.dao.ibatis.BaseCRUDDaoMybatis;
+import java.util.List;
+/**
+* 数据源类型DaoImpl DAO接口
+*
+* @author zxfei
+* @date 2024-07-15
+*/
+@Repository("dataSourcesTypeInfoDao")
+public class DataSourcesTypeInfoDaoImpl extends BaseCRUDDaoMybatis<DataSourcesTypeInfoEntity,Long> implements DataSourcesTypeInfoDao {
+
+
+
+}

etl-manager/src/main/java/com/mortals/xhx/module/data/dao/ibatis/DataTagGroupInfoDaoImpl.java

+package com.mortals.xhx.module.data.dao.ibatis;
+
+
+import org.springframework.stereotype.Repository;
+import com.mortals.xhx.module.data.dao.DataTagGroupInfoDao;
+import com.mortals.xhx.module.data.model.DataTagGroupInfoEntity;
+import java.util.Date;
+import com.mortals.framework.dao.ibatis.BaseCRUDDaoMybatis;
+import java.util.List;
+/**
+* 权限-数据标识组信息DaoImpl DAO接口
+*
+* @author zxfei
+* @date 2024-07-15
+*/
+@Repository("dataTagGroupInfoDao")
+public class DataTagGroupInfoDaoImpl extends BaseCRUDDaoMybatis<DataTagGroupInfoEntity,Long> implements DataTagGroupInfoDao {
+
+
+
+}

etl-manager/src/main/java/com/mortals/xhx/module/data/dao/ibatis/DataTagInfoDaoImpl.java

+package com.mortals.xhx.module.data.dao.ibatis;
+
+
+import org.springframework.stereotype.Repository;
+import com.mortals.xhx.module.data.dao.DataTagInfoDao;
+import com.mortals.xhx.module.data.model.DataTagInfoEntity;
+import java.util.Date;
+import com.mortals.framework.dao.ibatis.BaseCRUDDaoMybatis;
+import java.util.List;
+/**
+* 权限-数据标识信息DaoImpl DAO接口
+*
+* @author zxfei
+* @date 2024-07-15
+*/
+@Repository("dataTagInfoDao")
+public class DataTagInfoDaoImpl extends BaseCRUDDaoMybatis<DataTagInfoEntity,Long> implements DataTagInfoDao {
+
+
+
+}

etl-manager/src/main/java/com/mortals/xhx/module/data/model/DataSourcesInfoEntity.java

+package com.mortals.xhx.module.data.model;
+import java.util.List;
+import java.util.ArrayList;
+import java.math.BigDecimal;
+import cn.hutool.core.date.DateUtil;
+import java.util.Date;
+import com.fasterxml.jackson.annotation.JsonFormat;
+import com.mortals.framework.annotation.Excel;
+import com.mortals.framework.model.BaseEntityLong;
+import com.mortals.xhx.module.data.model.vo.DataSourcesInfoVo;
+import lombok.Data;
+/**
+* 数据源信息实体对象
+*
+* @author zxfei
+* @date 2024-07-15
+*/
+@Data
+public class DataSourcesInfoEntity extends DataSourcesInfoVo {
+    private static final long serialVersionUID = 1L;
+
+    /**
+    * 数据源说明
+    */
+    private String dataSourceContext;
+    /**
+    * 数据源类型
+    */
+    private String dataSourceType;
+    /**
+    * 驱动连接串
+    */
+    private String driver;
+    /**
+    * 连接url
+    */
+    private String url;
+    /**
+    * 用户名
+    */
+    private String username;
+    /**
+    * 密码
+    */
+    private String password;
+    /**
+    * 数据组标识,多个逗号分割
+    */
+    private String tagGroupCode;
+    /**
+    * 产品code
+    */
+    private String productCode;
+    /**
+    * 用户组
+    */
+    private String dimGroup;
+    /**
+    * 是否删除 (0.未删除,1.删除)
+    */
+    private Integer deleted;
+    /**
+    * 拥有者
+    */
+    private String owner;
+    /**
+    * 创建用户名称
+    */
+    private String createUserName;
+    @Override
+    public int hashCode() {
+         return this.getId().hashCode();
+    }
+    @Override
+    public boolean equals(Object obj) {
+        if (obj == null) return false;
+        if (obj instanceof DataSourcesInfoEntity) {
+            DataSourcesInfoEntity tmp = (DataSourcesInfoEntity) obj;
+            if (this.getId() == tmp.getId()) {
+                 return true;
+            }
+        }
+        return false;
+    }
+
+    public void initAttrValue(){
+            this.dataSourceContext = "";
+            this.dataSourceType = "";
+            this.driver = "";
+            this.url = "";
+            this.username = "";
+            this.password = "";
+            this.tagGroupCode = "";
+            this.productCode = "";
+            this.dimGroup = "";
+            this.deleted = 0;
+            this.owner = "";
+            this.createUserName = "";
+    }
+}
\ No newline at end of file

etl-manager/src/main/java/com/mortals/xhx/module/data/model/DataSourcesTypeInfoEntity.java

+package com.mortals.xhx.module.data.model;
+import java.util.List;
+import java.util.ArrayList;
+import java.math.BigDecimal;
+import cn.hutool.core.date.DateUtil;
+import java.util.Date;
+import com.fasterxml.jackson.annotation.JsonFormat;
+import com.mortals.framework.annotation.Excel;
+import com.mortals.framework.model.BaseEntityLong;
+import com.mortals.xhx.module.data.model.vo.DataSourcesTypeInfoVo;
+import lombok.Data;
+/**
+* 数据源类型实体对象
+*
+* @author zxfei
+* @date 2024-07-15
+*/
+@Data
+public class DataSourcesTypeInfoEntity extends DataSourcesTypeInfoVo {
+    private static final long serialVersionUID = 1L;
+
+    /**
+    * 
+    */
+    private String sourcesType;
+    /**
+    * 创建用户名称
+    */
+    private String createUserName;
+    @Override
+    public int hashCode() {
+         return this.getId().hashCode();
+    }
+    @Override
+    public boolean equals(Object obj) {
+        if (obj == null) return false;
+        if (obj instanceof DataSourcesTypeInfoEntity) {
+            DataSourcesTypeInfoEntity tmp = (DataSourcesTypeInfoEntity) obj;
+            if (this.getId() == tmp.getId()) {
+                 return true;
+            }
+        }
+        return false;
+    }
+
+    public void initAttrValue(){
+            this.sourcesType = "";
+            this.createUserName = "";
+    }
+}
\ No newline at end of file

etl-manager/src/main/java/com/mortals/xhx/module/data/model/DataTagGroupInfoEntity.java

+package com.mortals.xhx.module.data.model;
+import java.util.List;
+import java.util.ArrayList;
+import java.math.BigDecimal;
+import cn.hutool.core.date.DateUtil;
+import java.util.Date;
+import com.fasterxml.jackson.annotation.JsonFormat;
+import com.mortals.framework.annotation.Excel;
+import com.mortals.framework.model.BaseEntityLong;
+import com.mortals.xhx.module.data.model.vo.DataTagGroupInfoVo;
+import lombok.Data;
+/**
+* 权限-数据标识组信息实体对象
+*
+* @author zxfei
+* @date 2024-07-15
+*/
+@Data
+public class DataTagGroupInfoEntity extends DataTagGroupInfoVo {
+    private static final long serialVersionUID = 1L;
+
+    /**
+    * 标识组code
+    */
+    private String tagGroupCode;
+    /**
+    * 标识组名称
+    */
+    private String tagGroupName;
+    /**
+    * 标识code列表,逗号分割
+    */
+    private String tagCodes;
+    /**
+    * 产品code
+    */
+    private String productCode;
+    /**
+    * 是否删除 (0.未删除,1.删除)
+    */
+    private Integer deleted;
+    /**
+    * 拥有者
+    */
+    private String owner;
+    /**
+    * 创建用户名称
+    */
+    private String createUserName;
+    @Override
+    public int hashCode() {
+         return this.getId().hashCode();
+    }
+    @Override
+    public boolean equals(Object obj) {
+        if (obj == null) return false;
+        if (obj instanceof DataTagGroupInfoEntity) {
+            DataTagGroupInfoEntity tmp = (DataTagGroupInfoEntity) obj;
+            if (this.getId() == tmp.getId()) {
+                 return true;
+            }
+        }
+        return false;
+    }
+
+    public void initAttrValue(){
+            this.tagGroupCode = "";
+            this.tagGroupName = "";
+            this.tagCodes = "";
+            this.productCode = "";
+            this.deleted = 0;
+            this.owner = "";
+            this.createUserName = "";
+    }
+}
\ No newline at end of file

etl-manager/src/main/java/com/mortals/xhx/module/data/model/DataTagInfoEntity.java

+package com.mortals.xhx.module.data.model;
+import java.util.List;
+import java.util.ArrayList;
+import java.math.BigDecimal;
+import cn.hutool.core.date.DateUtil;
+import java.util.Date;
+import com.fasterxml.jackson.annotation.JsonFormat;
+import com.mortals.framework.annotation.Excel;
+import com.mortals.framework.model.BaseEntityLong;
+import com.mortals.xhx.module.data.model.vo.DataTagInfoVo;
+import lombok.Data;
+/**
+* 权限-数据标识信息实体对象
+*
+* @author zxfei
+* @date 2024-07-15
+*/
+@Data
+public class DataTagInfoEntity extends DataTagInfoVo {
+    private static final long serialVersionUID = 1L;
+
+    /**
+    * 标识code
+    */
+    private String tagCode;
+    /**
+    * 标识名称
+    */
+    private String tagName;
+    /**
+    * 产品code
+    */
+    private String productCode;
+    /**
+    * 是否删除 (0.未删除,1.删除)
+    */
+    private Integer deleted;
+    /**
+    * 拥有者
+    */
+    private String owner;
+    /**
+    * 创建用户名称
+    */
+    private String createUserName;
+    @Override
+    public int hashCode() {
+         return this.getId().hashCode();
+    }
+    @Override
+    public boolean equals(Object obj) {
+        if (obj == null) return false;
+        if (obj instanceof DataTagInfoEntity) {
+            DataTagInfoEntity tmp = (DataTagInfoEntity) obj;
+            if (this.getId() == tmp.getId()) {
+                 return true;
+            }
+        }
+        return false;
+    }
+
+    public void initAttrValue(){
+            this.tagCode = "";
+            this.tagName = "";
+            this.productCode = "";
+            this.deleted = 0;
+            this.owner = "";
+            this.createUserName = "";
+    }
+}
\ No newline at end of file

etl-manager/src/main/java/com/mortals/xhx/module/data/model/vo/DataSourcesInfoVo.java

+package com.mortals.xhx.module.data.model.vo;
+import com.mortals.framework.model.BaseEntityLong;
+import com.mortals.xhx.module.data.model.DataSourcesInfoEntity;
+import java.util.ArrayList;
+import java.util.List;
+import lombok.Data;
+import com.mortals.framework.annotation.Excel;
+import java.math.BigDecimal;
+import java.util.Date;
+/**
+* 数据源信息视图对象
+*
+* @author zxfei
+* @date 2024-07-15
+*/
+@Data
+public class DataSourcesInfoVo extends BaseEntityLong {
+
+    /** 序号，主键，自增长列表 */
+    private List <Long> idList;
+
+
+}
\ No newline at end of file

etl-manager/src/main/java/com/mortals/xhx/module/data/model/vo/DataSourcesTypeInfoVo.java

+package com.mortals.xhx.module.data.model.vo;
+import com.mortals.framework.model.BaseEntityLong;
+import com.mortals.xhx.module.data.model.DataSourcesTypeInfoEntity;
+import java.util.ArrayList;
+import java.util.List;
+import lombok.Data;
+import com.mortals.framework.annotation.Excel;
+import java.math.BigDecimal;
+import java.util.Date;
+/**
+* 数据源类型视图对象
+*
+* @author zxfei
+* @date 2024-07-15
+*/
+@Data
+public class DataSourcesTypeInfoVo extends BaseEntityLong {
+
+    /** 序号，主键，自增长列表 */
+    private List <Long> idList;
+
+
+}
\ No newline at end of file

etl-manager/src/main/java/com/mortals/xhx/module/data/model/vo/DataTagGroupInfoVo.java

+package com.mortals.xhx.module.data.model.vo;
+import com.mortals.framework.model.BaseEntityLong;
+import com.mortals.xhx.module.data.model.DataTagGroupInfoEntity;
+import java.util.ArrayList;
+import java.util.List;
+import lombok.Data;
+import com.mortals.framework.annotation.Excel;
+import java.math.BigDecimal;
+import java.util.Date;
+/**
+* 权限-数据标识组信息视图对象
+*
+* @author zxfei
+* @date 2024-07-15
+*/
+@Data
+public class DataTagGroupInfoVo extends BaseEntityLong {
+
+    /** 序号，主键，自增长列表 */
+    private List <Long> idList;
+
+
+}
\ No newline at end of file

etl-manager/src/main/java/com/mortals/xhx/module/data/model/vo/DataTagInfoVo.java

+package com.mortals.xhx.module.data.model.vo;
+import com.mortals.framework.model.BaseEntityLong;
+import com.mortals.xhx.module.data.model.DataTagInfoEntity;
+import java.util.ArrayList;
+import java.util.List;
+import lombok.Data;
+import com.mortals.framework.annotation.Excel;
+import java.math.BigDecimal;
+import java.util.Date;
+/**
+* 权限-数据标识信息视图对象
+*
+* @author zxfei
+* @date 2024-07-15
+*/
+@Data
+public class DataTagInfoVo extends BaseEntityLong {
+
+    /** 序号，主键，自增长列表 */
+    private List <Long> idList;
+
+
+}
\ No newline at end of file

etl-manager/src/main/java/com/mortals/xhx/module/data/service/DataSourcesInfoService.java

+package com.mortals.xhx.module.data.service;
+import com.mortals.framework.service.ICRUDService;
+import com.mortals.xhx.module.data.model.DataSourcesInfoEntity;
+import com.mortals.xhx.module.data.dao.DataSourcesInfoDao;
+/**
+* DataSourcesInfoService
+*
+* 数据源信息 service接口
+*
+* @author zxfei
+* @date 2024-07-15
+*/
+public interface DataSourcesInfoService extends ICRUDService<DataSourcesInfoEntity,Long>{
+
+    DataSourcesInfoDao getDao();
+}
\ No newline at end of file

etl-manager/src/main/java/com/mortals/xhx/module/data/service/DataSourcesTypeInfoService.java

+package com.mortals.xhx.module.data.service;
+import com.mortals.framework.service.ICRUDService;
+import com.mortals.xhx.module.data.model.DataSourcesTypeInfoEntity;
+import com.mortals.xhx.module.data.dao.DataSourcesTypeInfoDao;
+/**
+* DataSourcesTypeInfoService
+*
+* 数据源类型 service接口
+*
+* @author zxfei
+* @date 2024-07-15
+*/
+public interface DataSourcesTypeInfoService extends ICRUDService<DataSourcesTypeInfoEntity,Long>{
+
+    DataSourcesTypeInfoDao getDao();
+}
\ No newline at end of file

etl-manager/src/main/java/com/mortals/xhx/module/data/service/DataTagGroupInfoService.java

+package com.mortals.xhx.module.data.service;
+import com.mortals.framework.service.ICRUDService;
+import com.mortals.xhx.module.data.model.DataTagGroupInfoEntity;
+import com.mortals.xhx.module.data.dao.DataTagGroupInfoDao;
+/**
+* DataTagGroupInfoService
+*
+* 权限-数据标识组信息 service接口
+*
+* @author zxfei
+* @date 2024-07-15
+*/
+public interface DataTagGroupInfoService extends ICRUDService<DataTagGroupInfoEntity,Long>{
+
+    DataTagGroupInfoDao getDao();
+}
\ No newline at end of file

etl-manager/src/main/java/com/mortals/xhx/module/data/service/DataTagInfoService.java

+package com.mortals.xhx.module.data.service;
+import com.mortals.framework.service.ICRUDService;
+import com.mortals.xhx.module.data.model.DataTagInfoEntity;
+import com.mortals.xhx.module.data.dao.DataTagInfoDao;
+/**
+* DataTagInfoService
+*
+* 权限-数据标识信息 service接口
+*
+* @author zxfei
+* @date 2024-07-15
+*/
+public interface DataTagInfoService extends ICRUDService<DataTagInfoEntity,Long>{
+
+    DataTagInfoDao getDao();
+}
\ No newline at end of file

etl-manager/src/main/java/com/mortals/xhx/module/data/service/impl/DataSourcesInfoServiceImpl.java

+package com.mortals.xhx.module.data.service.impl;
+import org.springframework.stereotype.Service;
+import com.mortals.framework.service.impl.AbstractCRUDServiceImpl;
+import com.mortals.framework.exception.AppException;
+import com.mortals.framework.model.Context;
+import com.mortals.xhx.module.data.dao.DataSourcesInfoDao;
+import com.mortals.xhx.module.data.model.DataSourcesInfoEntity;
+import com.mortals.xhx.module.data.service.DataSourcesInfoService;
+import lombok.extern.slf4j.Slf4j;
+/**
+* DataSourcesInfoService
+* 数据源信息 service实现
+*
+* @author zxfei
+* @date 2024-07-15
+*/
+@Service("dataSourcesInfoService")
+@Slf4j
+public class DataSourcesInfoServiceImpl extends AbstractCRUDServiceImpl<DataSourcesInfoDao, DataSourcesInfoEntity, Long> implements DataSourcesInfoService {
+    
+}
\ No newline at end of file

etl-manager/src/main/java/com/mortals/xhx/module/data/service/impl/DataSourcesTypeInfoServiceImpl.java

+package com.mortals.xhx.module.data.service.impl;
+import org.springframework.stereotype.Service;
+import com.mortals.framework.service.impl.AbstractCRUDServiceImpl;
+import com.mortals.framework.exception.AppException;
+import com.mortals.framework.model.Context;
+import com.mortals.xhx.module.data.dao.DataSourcesTypeInfoDao;
+import com.mortals.xhx.module.data.model.DataSourcesTypeInfoEntity;
+import com.mortals.xhx.module.data.service.DataSourcesTypeInfoService;
+import lombok.extern.slf4j.Slf4j;
+/**
+* DataSourcesTypeInfoService
+* 数据源类型 service实现
+*
+* @author zxfei
+* @date 2024-07-15
+*/
+@Service("dataSourcesTypeInfoService")
+@Slf4j
+public class DataSourcesTypeInfoServiceImpl extends AbstractCRUDServiceImpl<DataSourcesTypeInfoDao, DataSourcesTypeInfoEntity, Long> implements DataSourcesTypeInfoService {
+    
+}
\ No newline at end of file

etl-manager/src/main/java/com/mortals/xhx/module/data/service/impl/DataTagGroupInfoServiceImpl.java

+package com.mortals.xhx.module.data.service.impl;
+import org.springframework.stereotype.Service;
+import com.mortals.framework.service.impl.AbstractCRUDServiceImpl;
+import com.mortals.framework.exception.AppException;
+import com.mortals.framework.model.Context;
+import com.mortals.xhx.module.data.dao.DataTagGroupInfoDao;
+import com.mortals.xhx.module.data.model.DataTagGroupInfoEntity;
+import com.mortals.xhx.module.data.service.DataTagGroupInfoService;
+import lombok.extern.slf4j.Slf4j;
+/**
+* DataTagGroupInfoService
+* 权限-数据标识组信息 service实现
+*
+* @author zxfei
+* @date 2024-07-15
+*/
+@Service("dataTagGroupInfoService")
+@Slf4j
+public class DataTagGroupInfoServiceImpl extends AbstractCRUDServiceImpl<DataTagGroupInfoDao, DataTagGroupInfoEntity, Long> implements DataTagGroupInfoService {
+    
+}
\ No newline at end of file

etl-manager/src/main/java/com/mortals/xhx/module/data/service/impl/DataTagInfoServiceImpl.java

+package com.mortals.xhx.module.data.service.impl;
+import org.springframework.stereotype.Service;
+import com.mortals.framework.service.impl.AbstractCRUDServiceImpl;
+import com.mortals.framework.exception.AppException;
+import com.mortals.framework.model.Context;
+import com.mortals.xhx.module.data.dao.DataTagInfoDao;
+import com.mortals.xhx.module.data.model.DataTagInfoEntity;
+import com.mortals.xhx.module.data.service.DataTagInfoService;
+import lombok.extern.slf4j.Slf4j;
+/**
+* DataTagInfoService
+* 权限-数据标识信息 service实现
+*
+* @author zxfei
+* @date 2024-07-15
+*/
+@Service("dataTagInfoService")
+@Slf4j
+public class DataTagInfoServiceImpl extends AbstractCRUDServiceImpl<DataTagInfoDao, DataTagInfoEntity, Long> implements DataTagInfoService {
+    
+}
\ No newline at end of file