Commit 2607117f authored by sml's avatar sml

代码提交(数据开发+配置文件)

parent 9f5de5a1
package com.jz.common.constant;
/**
* @ClassName: CommConstant
* @Description: TODO(通用常亮)
* @author ybz
* @date 2021年1月18日
*
*/
public class CommConstant {
/***************************************************/
//tree类型
public static String TREE_SYNCING_DATA = "1";
//开发任务
public static String TREE_DEVELOP_TASK = "2";
public static String TREE_DEVELOP_WORKFLOW = "2W";
public static String TREE_DEVELOP_SCRIPT = "3";
public static String TREE_MANAGE_RESOURCE = "4";
public static String TREE_MANAGE_FUNCTION = "5";
/***************************************************/
}
......@@ -6,14 +6,15 @@ package com.jz.common.constant;
*/
public class StatuConstant {
public final static String SUCCESS_CODE = "200";
/***************************************************************************/
/*操作码**/
public final static String SUCCESS_CODE = "000";
public final static String SUCCESS_CODE_MSG = "操作成功";
public final static String FAILURE_CODE = "201";
public final static String FAILURE_CODE = "001";
public final static String FAILURE_CODE_MSG = "操作失败";
/*****************************************************************************/
//第三方请求返回结果码定义
public static String CODE_SUCCESS = "000";
public static String MSG_SUCCESS = "操作成功";
public static String CODE_ERROR_REQUESTMETHOD = "100";
public static String MSG_ERROR_REQUESTMETHOD = "请求方式错误(只支持POST方式请求)";
......
package com.jz.common.enums;
public enum ModuleLogEnum {
DEV_SCRIPT(1, "脚本类数据开发"),
DEV_TASK(2, "任务类数据开发"),
VERSION_SYNC_XML(100, "离线同步XML历史版本");
private Integer code;
private String desc;
ModuleLogEnum(Integer code, String desc) {
this.code = code;
this.desc = desc;
}
public Integer getCode() {
return code;
}
public void setCode(Integer code) {
this.code = code;
}
public String getDesc() {
return desc;
}
public void setDesc(String desc) {
this.desc = desc;
}
}
package com.jz.common.enums;
/**
* 节点变更类型
*/
public enum NodeChangeTypeEnum {
ADD("新增"),
UPDATE("修改"),
DELETE("删除");
private String changeType;
NodeChangeTypeEnum(String changeType) {
this.changeType = changeType;
}
public String getChangeType() {
return changeType;
}
public void setChangeType(String changeType) {
this.changeType = changeType;
}
}
package com.jz.common.persistence;
import java.io.ByteArrayInputStream;
import java.io.UnsupportedEncodingException;
import java.sql.Blob;
import java.sql.CallableStatement;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.ResultSetMetaData;
import java.sql.SQLException;
import org.apache.ibatis.type.BaseTypeHandler;
import org.apache.ibatis.type.JdbcType;
import com.jz.common.utils.GZIPUtils;
public class CBTZipHandler extends BaseTypeHandler<String> {
private static final String DEFAULT_CHARSET = "utf-8";
@Override
public void setNonNullParameter(PreparedStatement ps, int i, String parameter, JdbcType jdbcType)
throws SQLException {
ByteArrayInputStream bis;
try {
bis = new ByteArrayInputStream(parameter.getBytes(DEFAULT_CHARSET));
} catch (UnsupportedEncodingException e) {
throw new RuntimeException("Blob Encoding Error!");
}
ps.setBinaryStream(i, bis, parameter.length());
}
@Override
public String getNullableResult(ResultSet rs, String columnName) throws SQLException {
int isGziped = -1;
try {
// getAllColumn(rs);
isGziped = rs.getInt("is_gziped");
} catch (SQLException e) {
System.out.println("获取是否压缩字段列数据发生异常:" + e.getMessage());
}
return getConvertString(rs.getBlob(columnName), isGziped);
}
@Override
public String getNullableResult(CallableStatement cs, int columnIndex) throws SQLException {
int isGziped = -1;
try {
// getAllColumn(cs.getResultSet());
System.out.println("==========>>>CallableStatement解压缩");
isGziped = cs.getInt("is_gziped");
} catch (SQLException e) {
System.out.println("获取是否压缩字段列数据发生异常:" + e.getMessage());
}
return getConvertString(cs.getBlob(columnIndex), isGziped);
}
@Override
public String getNullableResult(ResultSet arg0, int arg1) throws SQLException {
return null;
}
private String getConvertString(Blob blob, int isGziped) throws SQLException {
byte[] returnValue = null;
if (null != blob) {
returnValue = blob.getBytes(1, (int) blob.length());
}
if (returnValue == null) return "";
try {
// 压缩状态
if (isGziped == 1) {
return GZIPUtils.unGzipString(returnValue, DEFAULT_CHARSET);
} else {
return new String(returnValue, DEFAULT_CHARSET);
}
} catch (Exception e) {
throw new RuntimeException("Blob Encoding Error!");
}
}
private String[] getAllColumn(ResultSet rs) throws SQLException {
if (null != rs) {
ResultSetMetaData rsmd = rs.getMetaData();
int count = rsmd.getColumnCount();
String[] name = new String[count];
for (int i = 0; i < count; i++) {
name[i] = rsmd.getColumnName(i + 1);
System.out.println(name[i]);
}
return name;
} else {
return null;
}
}
}
package com.jz.common.utils;
/**
* @ClassName: CodeGeneratorUtil
* @Description: TODO(按照规则生成编码工具类)
* @author ybz
* @date 2021年1月19日
*
*/
public class CodeGeneratorUtils {
//任务起始版本
private static final String TASKVERSION_START = "V1.0";
/**
* @Title: generatorNextTaskVesion
* @Description: TODO(任务版本生成)
* @param @param version
* @param @return
* @param @throws Exception 参数
* @return String 返回类型
* @throws
*/
public static String generatorNextTaskVesion(String version)throws Exception{
if (StringUtils.isEmpty(version)) {//如果没有版本,则返回开始版本
return TASKVERSION_START;
}
String[] strs = version.substring(1, version.length()).split(".");
Integer number_1 = Integer.parseInt(strs[0]);
Integer number_2 = Integer.parseInt(strs[1]);
if (number_2 + 1 > 9) {
number_2 = 0;
number_1 += 1;
}else {
number_2 += 1;
}
return "V"+number_1+"."+number_2;
}
}
package com.jz.common.utils;
import java.io.File;
import java.util.ArrayList;
import java.util.Date;
import java.util.HashMap;
import java.util.Iterator;
import java.util.List;
import java.util.Map;
import org.apache.commons.lang3.StringUtils;
import org.apache.commons.lang3.time.DateFormatUtils;
import com.alibaba.fastjson.JSON;
import com.jz.common.enums.NodeChangeTypeEnum;
import com.jz.dmp.modules.controller.DataIntegration.bean.flow.FlowNode;
import com.jz.dmp.modules.controller.DataIntegration.bean.flow.FlowNodeChangeInfo;
import com.jz.dmp.modules.controller.DataIntegration.bean.flow.FlowPro;
import com.jz.dmp.modules.model.DmpNavigationTree;
import com.jz.dmp.modules.model.DmpProject;
import com.jz.dmp.modules.model.DmpProjectSystemInfo;
import com.jz.dmp.modules.model.DmpWorkFlowSubmitDetails;
import com.jz.dmp.modules.service.DmpDevelopTaskService;
import com.jz.dmp.modules.service.DmpNavigationTreeService;
import com.jz.dmp.modules.service.DmpWorkFlowSubmitDetailsService;
import lombok.Data;
@Data
public class FlowParseTool {
/**
* 流程json
*/
private Map<String, Object> flowDataMap;
/**
* 要发布到的项目信息
*/
private DmpProject publishedToProject;
/**
* 要发布到的项目配置信息
*/
private DmpProjectSystemInfo publishedToProjectSystemInfo;
private DmpDevelopTaskService dmpDevelopTaskService;
private DmpNavigationTreeService dmpNavigationTreeService;
private DmpWorkFlowSubmitDetailsService dmpWorkFlowSubmitDetailsService;
/**
* 不发布项目用
*
* @param flowPro
*/
public FlowParseTool(FlowPro flowPro, DmpWorkFlowSubmitDetailsService dmpWorkFlowSubmitDetailsService) {
this.flowPro = flowPro;
this.flowDataMap = JSON.parseObject(flowPro.getFlowJson(), Map.class);
this.dmpWorkFlowSubmitDetailsService = dmpWorkFlowSubmitDetailsService;
parse();
}
/**
* 发布项目用
*
* @param flowPro
* @param publishedToProject
* @param publishedToProjectSystemInfo
*/
public FlowParseTool(FlowPro flowPro,
DmpProject publishedToProject,
DmpProjectSystemInfo publishedToProjectSystemInfo,
DmpDevelopTaskService dmpDevelopTaskService,
DmpNavigationTreeService dmpNavigationTreeService,
DmpWorkFlowSubmitDetailsService dmpWorkFlowSubmitDetailsService) {
this(flowPro, dmpWorkFlowSubmitDetailsService);
this.publishedToProject = publishedToProject;
this.publishedToProjectSystemInfo = publishedToProjectSystemInfo;
this.dmpDevelopTaskService = dmpDevelopTaskService;
this.dmpNavigationTreeService = dmpNavigationTreeService;
}
/**
* 流程属性
*/
private FlowPro flowPro;
/**
* 节点依赖关系
*/
private Map<String, String> nodeDependcyRefMap;
/**
* 流程节点
* key是节点id
*/
private Map<String, FlowNode> flowNodeMap;
/**
* 流程变更数据
*/
private Map flowChangedMap;
private void parse() {
//处理流程数据
parseFlowPro();
//处理节点关系
parseEdges();
//处理流程节点
parseNodes();
//处理依赖关系
handleFlowNodeDependcy();
}
/**
* 处理流程属性
*/
private void parseFlowPro() {
String key = "flowPro";
Map<String, Object> flowProMap = (Map) flowDataMap.get(key);
String flowName = flowProMap.get("flowName").toString();
//String taskId = flowProMap.get("taskId");
String scheduleSetting = flowProMap.get("scheduleSetting").toString();
String afterFailSelect = flowProMap.get("afterFailSelect").toString();
flowPro.setProjectId(Long.parseLong(flowProMap.get("projectId").toString()));
flowPro.setTreeId(Long.parseLong(flowProMap.get("treeId").toString()));
flowPro.setFlowName(flowName);
//flowPro.setTaskId(taskId);
flowPro.setScheduleSetting(scheduleSetting);
flowPro.setAfterFailSelect(afterFailSelect);
}
/**
* 处理线连接的节点
*/
private void parseEdges() {
String key = "edges";
List<Map<String, String>> edgesRelationList = (List<Map<String, String>>) flowDataMap.get(key);
int size = edgesRelationList.size();
nodeDependcyRefMap = new HashMap<>(size);
Map<String, String> edgesRelationMap;
for (int i = 0; i < size; i++) {
edgesRelationMap = edgesRelationList.get(i);
String sourceNodeId = edgesRelationMap.get("source");
String targetNodeId = edgesRelationMap.get("target");
if (nodeDependcyRefMap.get(targetNodeId) != null) {
//说明已经有
nodeDependcyRefMap.put(targetNodeId, nodeDependcyRefMap.get(targetNodeId) + "," + sourceNodeId);
} else {
//没有 直接存
nodeDependcyRefMap.put(targetNodeId, sourceNodeId);
}
}
}
/**
* 流程节点处理
*
* @return
*/
private void parseNodes() {
String key = "nodes";
List<Map<String, String>> nodesList = (List<Map<String, String>>) flowDataMap.get(key);
int size = nodesList.size();
flowNodeMap = new HashMap<>(size);
FlowNode flowNode;
Map<String, String> tempMap;
for (int i = 0; i < size; i++) {
tempMap = nodesList.get(i);
String nodeId = tempMap.get("id");
String nodeName = tempMap.get("label");
String nodeType = tempMap.get("taskType");
String nodeLocation = tempMap.get("nodeLocation");
String script = tempMap.get("script");
String retryTimes = tempMap.get("retryTimes");
String retryInterval = tempMap.get("retryInterval");
flowNode = new FlowNode();
flowNode.setNodeId(nodeId);
flowNode.setNodeName(nodeName);
flowNode.setNodeType(nodeType);
flowNode.setNodeLocation(nodeLocation);
flowNode.setScript(script);
flowNode.setRetryTimes(retryTimes);
flowNode.setRetryInterval(retryInterval);
flowNode.setNodeData(JSON.toJSONString(tempMap));
flowNodeMap.put(nodeId, flowNode);
}
}
/**
* 处理流程节点依赖
*/
private void handleFlowNodeDependcy() {
Iterator<Map.Entry<String, FlowNode>> iterator = flowNodeMap.entrySet().iterator();
StringBuffer sb;
FlowNode flowNode;
while (iterator.hasNext()) {
Map.Entry<String, FlowNode> next = iterator.next();
String nodeId = next.getKey();
flowNode = next.getValue();
String dependcyNodeIds = nodeDependcyRefMap.get(nodeId);
if (StringUtils.isNotBlank(dependcyNodeIds)) {
sb = new StringBuffer();
String[] dependcyNodeIdArr = dependcyNodeIds.split(",");
for (int i = 0; i < dependcyNodeIdArr.length; i++) {
String dependcyNodeId = dependcyNodeIdArr[i];
String dependcyNodeName = flowNodeMap.get(dependcyNodeId).getNodeName();
sb.append(dependcyNodeName);
sb.append(",");
}
flowNode.setDependedNodeName(sb.toString().substring(0, sb.toString().length() - 1));
}
}
}
/**
* 获取节点变更列表
* @return
*/
public List<FlowNodeChangeInfo> getChangedNodes() {
String currentUserName = "superadmin";
String currentDateStr = DateFormatUtils.format(new Date(), "yyyy-MM-dd HH:mm:ss");
Long projectId = flowPro.getProjectId();
String flowName = flowPro.getFlowName();
boolean isCheckVerion = flowPro.isCheckVerion();
Map queryParamMap = new HashMap();
queryParamMap.put("projectId", projectId);
queryParamMap.put("flowName", flowName);
queryParamMap.put("isCheckVerion", isCheckVerion);
List<DmpWorkFlowSubmitDetails> queryList = dmpWorkFlowSubmitDetailsService.getLatestUnderFlowByNodeName(queryParamMap);
Map<String, DmpWorkFlowSubmitDetails> queryMap = new HashMap<>();
if (queryList != null && queryList.size() > 0) {
for (DmpWorkFlowSubmitDetails dmpWorkFlowSubmitDetails : queryList) {
queryMap.put(dmpWorkFlowSubmitDetails.getNodeName(), dmpWorkFlowSubmitDetails);
}
}
//流程变更节点保存
List<FlowNodeChangeInfo> flowNodeChangeList = new ArrayList<>();
// 比较流程变更
Iterator<Map.Entry<String, FlowNode>> iterator = flowNodeMap.entrySet().iterator();
FlowNode flowNode = null;
DmpWorkFlowSubmitDetails dmpWorkFlowSubmitDetails = null;
FlowNodeChangeInfo flowNodeChangeInfo = null;
while (iterator.hasNext()) {
flowNode = iterator.next().getValue();
String nodeName = flowNode.getNodeName();
String nodeType = flowNode.getNodeType();
String nodeData = flowNode.getNodeData();
dmpWorkFlowSubmitDetails = queryMap.get(nodeName);
if (dmpWorkFlowSubmitDetails == null) {
//没保存过当前节点 所有节点就是新增
flowNodeChangeInfo = new FlowNodeChangeInfo();
flowNodeChangeInfo.setNodeName(nodeName);
flowNodeChangeInfo.setNodeData(nodeData);
flowNodeChangeInfo.setNodeType(nodeType);
flowNodeChangeInfo.setChangedType(NodeChangeTypeEnum.ADD.getChangeType());
flowNodeChangeInfo.setCreateBy(currentUserName);
flowNodeChangeInfo.setUpdateDateStr(currentDateStr);
flowNodeChangeInfo.setVersion(1);
flowNodeChangeList.add(flowNodeChangeInfo);
} else {
//保存过当前节点 比较几点数据是否一致 不一致
if (!nodeData.equals(dmpWorkFlowSubmitDetails.getNodeData())) {
flowNodeChangeInfo = new FlowNodeChangeInfo();
flowNodeChangeInfo.setNodeName(nodeName);
flowNodeChangeInfo.setNodeData(nodeData);
flowNodeChangeInfo.setNodeType(nodeType);
flowNodeChangeInfo.setChangedType(NodeChangeTypeEnum.UPDATE.getChangeType());
flowNodeChangeInfo.setCreateBy(currentUserName);
flowNodeChangeInfo.setUpdateDateStr(currentDateStr);
flowNodeChangeInfo.setVersion(dmpWorkFlowSubmitDetails.getVersion() == null ? 1 : dmpWorkFlowSubmitDetails.getVersion() + 1);
flowNodeChangeList.add(flowNodeChangeInfo);
}
//当前流程有的节点删掉 没有的就全部是删除的
queryMap.remove(nodeName);
}
}
// 获取删除的节点
/*Iterator<Map.Entry<String, DmpWorkFlowSubmitDetails>> delIterator = queryMap.entrySet().iterator();
while (delIterator.hasNext()) {
dmpWorkFlowSubmitDetails = delIterator.next().getValue();
String nodeName = dmpWorkFlowSubmitDetails.getNodeName();
flowNodeChangeInfo = new FlowNodeChangeInfo();
flowNodeChangeInfo.setNodeName(nodeName);
flowNodeChangeInfo.setChangedType(NodeChangeTypeEnum.DELETE.getChangeType());
flowNodeChangeInfo.setCreateBy(currentUserName);
flowNodeChangeInfo.setUpdateDateStr(currentDateStr);
flowNodeChangeInfo.setNodeData(dmpWorkFlowSubmitDetails.getNodeData());
flowNodeChangeList.add(flowNodeChangeInfo);
}*/
return flowNodeChangeList;
}
/**
* 发布流程
*/
public boolean publish()throws Exception {
Long publishedToProjectId = publishedToProjectSystemInfo.getProjectId();
Long treeId = flowPro.getTreeId();
/**
* 当前任务生成文件存放根路径
*/
String localTaskPath = publishedToProjectSystemInfo.getAzkabanLocalTaskFilePath() + "/" + publishedToProjectId + "/" + treeId;
File localTaskFile = new File(localTaskPath);
if (!localTaskFile.exists()) {
localTaskFile.mkdirs();
}
String localTaskSourcePath = localTaskPath + "/source/";
File localTaskSourceFile = new File(localTaskSourcePath);
if (!localTaskSourceFile.exists()) {
localTaskSourceFile.mkdirs();
}
String localTaskExecArgsPath = localTaskPath + "/execArgs/";
File localTaskExecArgsFile = new File(localTaskExecArgsPath);
if (!localTaskExecArgsFile.exists()) {
localTaskExecArgsFile.mkdirs();
}
String localTaskZipPath = localTaskPath + "/target/";
File localTaskZipFile = new File(localTaskZipPath);
if (!localTaskZipFile.exists()) {
localTaskZipFile.mkdirs();
}
//先删除上次创建的文件 ---每次都会新建
FileUtils.deleteDirectory(localTaskPath);
List<String> contents;
Iterator<Map.Entry<String, FlowNode>> iterator = flowNodeMap.entrySet().iterator();
String azkabanJobType = "";
String azkabanJobCommand = "";
while (iterator.hasNext()) {
contents = new ArrayList<>();
FlowNode flowNode = iterator.next().getValue();
String nodeType = flowNode.getNodeType();
if ("shell".equalsIgnoreCase(nodeType)) {
// shell
azkabanJobType = "command";
azkabanJobCommand = generateShellFile(flowNode, localTaskExecArgsPath);
} else if ("sql".equalsIgnoreCase(nodeType)) {
// sql 任务
azkabanJobType = "command";
azkabanJobCommand = generateSqlFile(flowNode, localTaskExecArgsPath);
} else if ("sync".equalsIgnoreCase(nodeType)) {
//同步任务
azkabanJobType = "command";
azkabanJobCommand = generateSyncFile(flowNode);
} else if ("subprocess".equalsIgnoreCase(nodeType)) {
//子流程
azkabanJobType = "flow";
azkabanJobCommand = generateSubprocessFile(flowNode);
}
//子流程类型
contents.add("type=" + azkabanJobType);
contents.add(azkabanJobCommand);
String dependenciesNodeName = flowNode.getDependedNodeName();
if (StringUtils.isNotBlank(dependenciesNodeName)) {
contents.add("dependencies=" + dependenciesNodeName);
}
String retrytimes = flowNode.getRetryTimes();
if (StringUtils.isNotBlank(retrytimes)) {
contents.add("retries=" + retrytimes);
}
String retrybackoff = flowNode.getRetryInterval();
if (StringUtils.isNotBlank(retrybackoff)) {
contents.add("retry.backoff=" + retrybackoff);
}
//生成job文件
String jobFileAbsolutePath = localTaskSourcePath + flowNode.getNodeName() + ".job";
FileUtils.write(jobFileAbsolutePath, contents);
}
String localZipTargetFileName = flowPro.getFlowName() + ".zip";
ZipUtils.zip(localTaskSourcePath, localTaskZipPath, localZipTargetFileName);
//上传到azkaban todo
//上次zip包到azkaban
String localTaskZipAbsolutePath = localTaskZipPath + "/" + localZipTargetFileName;
String azkabanApiUrl = publishedToProjectSystemInfo.getAzkabanMonitorUrl();
AzkabanApiUtils2 azkabanApiUtils = new AzkabanApiUtils2(azkabanApiUrl);
return azkabanApiUtils.loginCreateProjectuploadZipAndSchedule("jz_workflow_" + publishedToProjectId, publishedToProject.getProjectDesc(), localTaskZipAbsolutePath, flowPro);
}
/**
* 生成shell 文件
*
* @param flowNode
* @return
*/
private String generateShellFile(FlowNode flowNode, String localTaskExecArgsPath) {
String fileName = flowNode.getNodeName() + ".sh";
String scriptFileAbsolutePath = localTaskExecArgsPath + fileName;
Long publishedToProjectId = publishedToProjectSystemInfo.getProjectId();
Long treeId = flowPro.getTreeId();
List<String> list = new ArrayList<>();
list.add("#!/bin/sh");
list.add(flowNode.getScript());
FileUtils.write(scriptFileAbsolutePath, list);
//远程shell 路径
String remoteShellDir = publishedToProjectSystemInfo.getAzkabanExectorShellPath() + "/" + publishedToProjectId + "/" + treeId + "/";
//上传shell文件 todo
SFTPUtils sftpUtils = new SFTPUtils(publishedToProjectSystemInfo.getShellCmdServer(),
publishedToProjectSystemInfo.getShellCmdUser(),
publishedToProjectSystemInfo.getShellCmdPassword(),
publishedToProjectSystemInfo.getShellSftpPort());
sftpUtils.singleUploadFile(localTaskExecArgsPath, fileName, remoteShellDir);
String command = "command=" + publishedToProjectSystemInfo.getAzkabanExectorShellExec() + " " + publishedToProjectId + " ${azkaban.flow.flowid} ${azkaban.job.id} " + remoteShellDir + fileName;
return command;
}
/**
* 生成sql文件
*
* @param flowNode
* @param localTaskExecArgsPath
* @return
*/
private String generateSqlFile(FlowNode flowNode, String localTaskExecArgsPath) {
String fileName = flowNode.getNodeName() + ".sql";
String scriptFileAbsolutePath = localTaskExecArgsPath + fileName;
Long publishedToProjectId = publishedToProjectSystemInfo.getProjectId();
Long treeId = flowPro.getTreeId();
FileUtils.write(scriptFileAbsolutePath, flowNode.getScript());
//上传sql文件 todo
//远程shell 路径
String remoteSqlDir = publishedToProjectSystemInfo.getAzkabanExectorSqlPath() + "/" + publishedToProjectId + "/" + treeId + "/";
//上传shell文件 todo
SFTPUtils sftpUtils = new SFTPUtils(publishedToProjectSystemInfo.getShellCmdServer(),
publishedToProjectSystemInfo.getShellCmdUser(),
publishedToProjectSystemInfo.getShellCmdPassword(),
publishedToProjectSystemInfo.getShellSftpPort());
sftpUtils.singleUploadFile(localTaskExecArgsPath, fileName, remoteSqlDir);
String command = "command=" + publishedToProjectSystemInfo.getAzkabanExectorSqlExec() + " " + publishedToProjectId + " ${azkaban.flow.flowid} ${azkaban.job.id} " + remoteSqlDir + fileName;
return command;
}
/**
* 生成同步任务文件
*
* @param flowNode
* @return
*/
private String generateSyncFile(FlowNode flowNode)throws Exception {
/*Long syncTaskId = job.getXmlTaskTreeId();
if (syncTaskId == null) {
throw new RuntimeException("请选择同步任务节点");
}
String execXmlFileNameAndVersion = getPublishSyncTaskFileNameAndLatestVersion(syncTaskId);
job.setXmlSyncTaskFileNameAndLatestVersion(execXmlFileNameAndVersion);
String execXmlFileName = execXmlFileNameAndVersion.split("@")[1];*/
//任务所在项目id
Long projectId = flowPro.getProjectId();
Long publishedToProjectId = publishedToProjectSystemInfo.getProjectId();
//根据taskName获取treeId
String taskName = flowNode.getScript();
DmpNavigationTree dmpNavigationTree = dmpNavigationTreeService.getByProjectIdAndName(projectId, taskName);
if (dmpNavigationTree == null) {
throw new RuntimeException("未找到任务:" + taskName);
}
Long syncTaskTreeId = dmpNavigationTree.getId().longValue();
//暂时不上传
//dmpDevelopTaskService.newPublishSyncing(syncTaskTreeId, publishedToProjectId);
//获取最新版本的同步任务
String execXmlFileNameAndVersion = getPublishSyncTaskFileNameAndLatestVersion(taskName, syncTaskTreeId);
String execXmlFileName = execXmlFileNameAndVersion.split("@")[1];
//xml 执行xml的命令写到job文件中
String command = "command=" + publishedToProjectSystemInfo.getAzkabanExectorXmlExec() + " " + publishedToProjectId + " ${azkaban.flow.flowid} ${azkaban.job.id} " + execXmlFileName;
return command;
}
/**
* 获取选择的数据同步的最新版本
*
* @param syncTaskTreeId 数据同步任务treeId
* @return
*/
private String getPublishSyncTaskFileNameAndLatestVersion(String syncTaskName, Long syncTaskTreeId)throws Exception {
String execXmlFileNameAndVersion = dmpDevelopTaskService.getConfigFileNameNotSuffix4Published(syncTaskTreeId);
if (org.springframework.util.StringUtils.isEmpty(execXmlFileNameAndVersion)) {
throw new RuntimeException("同步任务:" + syncTaskName + " xml配置文件为空,请确认是否提交成功");
}
return syncTaskTreeId + "@" + execXmlFileNameAndVersion;
}
/**
* 生成子流程
*
* @param flowNode
* @return
*/
private String generateSubprocessFile(FlowNode flowNode) {
String subProcessFlowName = flowNode.getScript();
//检查子流程是否存在 todo
String azkabanApiUrl = publishedToProjectSystemInfo.getAzkabanMonitorUrl();
AzkabanApiUtils2 azkabanApiUtils = new AzkabanApiUtils2(azkabanApiUrl);
boolean flowExists = azkabanApiUtils.checkFlowExists("jz_workflow_" + flowPro.getPublishedToProjectId(), subProcessFlowName);
if (!flowExists) {
throw new RuntimeException("节点:" + flowNode.getNodeName() + "设置的子流程:" + subProcessFlowName + "不存在,请先发布" + subProcessFlowName);
}
return "flow.name=" + subProcessFlowName;
}
}
/*
* Copyright 2012 LinkedIn Corp.
*
* Licensed under the Apache License, Version 2.0 (the "License"); you may not
* use this file except in compliance with the License. You may obtain a copy of
* the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS, WITHOUT
* WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the
* License for the specific language governing permissions and limitations under
* the License.
*/
package com.jz.common.utils;
import org.apache.commons.io.IOUtils;
import java.io.*;
import java.util.zip.GZIPInputStream;
import java.util.zip.GZIPOutputStream;
public class GZIPUtils {
public static byte[] gzipString(final String str) throws IOException{
return gzipString(str,"utf-8");
}
public static byte[] gzipString(final String str, final String encType)
throws IOException {
if (str == null){
return null;
}
final byte[] stringData = str.getBytes(encType);
return gzipBytes(stringData);
}
public static byte[] gzipBytes(final byte[] bytes) throws IOException {
return gzipBytes(bytes, 0, bytes.length);
}
public static byte[] gzipBytes(final byte[] bytes, final int offset, final int length)
throws IOException {
final ByteArrayOutputStream byteOutputStream = new ByteArrayOutputStream();
GZIPOutputStream gzipStream = null;
gzipStream = new GZIPOutputStream(byteOutputStream);
gzipStream.write(bytes, offset, length);
gzipStream.close();
return byteOutputStream.toByteArray();
}
public static byte[] unGzipBytes(final byte[] bytes) throws IOException {
final ByteArrayInputStream byteInputStream = new ByteArrayInputStream(bytes);
final GZIPInputStream gzipInputStream = new GZIPInputStream(byteInputStream);
final ByteArrayOutputStream byteOutputStream = new ByteArrayOutputStream();
IOUtils.copy(gzipInputStream, byteOutputStream);
return byteOutputStream.toByteArray();
}
public static String unGzipString(final byte[] bytes, final String encType)
throws IOException {
final byte[] response = unGzipBytes(bytes);
return new String(response, encType);
}
public static void main(String [] args){
String fileName = "C:\\Users\\Marus\\Desktop\\coverage-error.log";
File file = new File(fileName);
BufferedReader reader = null;
StringBuffer sb = new StringBuffer();
try {
System.out.println("以行为单位读取文件内容,一次读一整行:");
reader = new BufferedReader(new FileReader(file));
String tempString = null;
int line = 1;
// 一次读入一行,直到读入null为文件结束
while ((tempString = reader.readLine()) != null) {
sb.append(tempString);
}
reader.close();
} catch (IOException e) {
e.printStackTrace();
} finally {
if (reader != null) {
try {
reader.close();
} catch (IOException e1) {
}
}
}
try {
byte [] a = gzipString(sb.toString(),"utf-8");
System.err.println(sb.toString().length()+"----"+a.length);
} catch (IOException e) {
e.printStackTrace();
}
}
}
package com.jz.common.utils;
import java.util.Properties;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import com.jcraft.jsch.Channel;
import com.jcraft.jsch.ChannelSftp;
import com.jcraft.jsch.JSch;
import com.jcraft.jsch.JSchException;
import com.jcraft.jsch.Session;
import com.jcraft.jsch.SftpATTRS;
import com.jcraft.jsch.SftpException;
/**
* java sftp 客户端工具类
*
*/
public class SFTPUtils {
private static final Logger LOGGER = LoggerFactory.getLogger(SFTPUtils.class);
private ChannelSftp sftp = null;
private Session sshSession = null;
private String host;
private String userName;
private String password;
private Integer port;
/**
*
* @param host
* @param userName
* @param password
* @param port
*/
public SFTPUtils(String host,String userName,String password,Integer port) {
this.host = host;
this.userName = userName;
this.password = password;
this.port = (port == null?22:port);
connect();
}
/**
*
* @param host
* @param userName
* @param password
* @param port
*/
public SFTPUtils(String host,String userName,String password,Long port) {
this.host = host;
this.userName = userName;
this.password = password;
this.port = (port == null?22:port.intValue());
connect();
}
/**
* 建立sftp连接
*/
public void connect() {
LOGGER.info("userName="+userName+",host="+host+",port="+port+" 创建sftp连接");
try {
JSch jsch = new JSch();
sshSession = jsch.getSession(userName, host, port);
LOGGER.info("ssh session created");
sshSession.setPassword(password);
Properties sshConfig = new Properties();
sshConfig.put("StrictHostKeyChecking", "no");
sshSession.setConfig(sshConfig);
sshSession.connect();
LOGGER.info("ssh session connected");
Channel channel = sshSession.openChannel("sftp");
channel.connect();
LOGGER.info("channel connected");
sftp = (ChannelSftp) channel;
LOGGER.info("sftp connection created");
} catch (JSchException e) {
LOGGER.error("userName="+userName+",host="+host+",port="+port+" sftp连接失败");
e.printStackTrace();
throw new RuntimeException("userName="+userName+",host="+host+",port="+port+" sftp连接失败");
}
}
/**
* 关闭sftp连接
*/
public void disConnect() {
if (this.sftp != null) {
if (this.sftp.isConnected()) {
this.sftp.disconnect();
}
}
if (this.sshSession != null) {
if (this.sshSession.isConnected()) {
this.sshSession.disconnect();
}
}
}
/**
* 上传单个文件
* @param localFileDirPath 本地文件目录路径
* @param uploadFileName 要上传的文件名
* @param remoteFileDirPath 要上传到的远程文件路径
*/
public void singleUploadFile(String localFileDirPath,String uploadFileName,String remoteFileDirPath) {
//本地文件绝对路径
String localFileAbsolutePath = localFileDirPath+uploadFileName;
String remoteFileAbsolutePath = remoteFileDirPath+"/"+uploadFileName;
LOGGER.info("上传"+localFileAbsolutePath+" 到 "+remoteFileAbsolutePath+" 开始");
createRemoteDirs(remoteFileDirPath);
try {
sftp.put(localFileAbsolutePath, remoteFileAbsolutePath,ChannelSftp.OVERWRITE);
sftp.chmod(Integer.parseInt("775",8), remoteFileAbsolutePath);
LOGGER.info("上传"+localFileAbsolutePath+" 到 "+remoteFileAbsolutePath+" 成功");
} catch (SftpException e) {
e.printStackTrace();
throw new RuntimeException("上传"+localFileAbsolutePath+"到"+remoteFileAbsolutePath+"失败");
}finally {
disConnect();
}
}
/**
* 批量上传文件
*/
public void batchUploadFile() {
}
/**
* 判断远程目录是否存在
* @param remoteFilePath 远程目录路径
* @return
*/
public boolean isRemoteDirExist(String remoteFilePath) {
try {
SftpATTRS sftpATTRS = sftp.lstat(remoteFilePath);
return sftpATTRS.isDir();
} catch (SftpException e) {
LOGGER.warn(remoteFilePath+"不存在,需要创建");
}
return false;
}
/**
* 创建远程目录
* @param remoteFilePath
* @return
*/
public boolean createRemoteDir(String remoteFilePath) {
try {
LOGGER.info("创建"+remoteFilePath);
sftp.mkdir(remoteFilePath);
return true;
} catch (SftpException e) {
e.printStackTrace();
throw new RuntimeException("创建目录:"+remoteFilePath+"失败");
}
}
/**
* 递归创建文件夹
* @param remoteFilePath
* @return
*/
public boolean createRemoteDirs(String remoteFilePath) {
if (isRemoteDirExist(remoteFilePath)){
return true;
}
int subLength = 0;
if (remoteFilePath.endsWith("/")) {
subLength = 1;
}
String dirs = remoteFilePath.substring(1, remoteFilePath.length()-subLength);
String[] dirArr = dirs.split("/");
String base = "";
for (String d : dirArr) {
base += "/" + d;
if (isRemoteDirExist(base + "/")) {
continue;
} else {
createRemoteDir(base + "/");
}
}
return true;
}
public ChannelSftp getSftp() {
return sftp;
}
public void setSftp(ChannelSftp sftp) {
this.sftp = sftp;
}
public Session getSshSession() {
return sshSession;
}
public void setSshSession(Session sshSession) {
this.sshSession = sshSession;
}
public String getHost() {
return host;
}
public void setHost(String host) {
this.host = host;
}
public String getUserName() {
return userName;
}
public void setUserName(String userName) {
this.userName = userName;
}
public String getPassword() {
return password;
}
public void setPassword(String password) {
this.password = password;
}
public int getPort() {
return port;
}
public void setPort(int port) {
this.port = port;
}
}
......@@ -66,7 +66,7 @@ public class SecurityConfiguration extends WebSecurityConfigurerAdapter {
//登录成功,返回json
.successHandler((request,response,authentication) -> {
Map<String,Object> map = new HashMap<String,Object>();
map.put("code",StatuConstant.CODE_SUCCESS);
map.put("code",StatuConstant.SUCCESS_CODE);
map.put("message","登录成功");
map.put("data",authentication);
response.setContentType("application/json;charset=utf-8");
......@@ -96,7 +96,7 @@ public class SecurityConfiguration extends WebSecurityConfigurerAdapter {
//退出成功,返回json
.logoutSuccessHandler((request,response,authentication) -> {
Map<String,Object> map = new HashMap<String,Object>();
map.put("code",StatuConstant.CODE_SUCCESS);
map.put("code",StatuConstant.SUCCESS_CODE);
map.put("message","退出成功");
map.put("data",authentication);
response.setContentType("application/json;charset=utf-8");
......
......@@ -6,24 +6,31 @@ import lombok.NoArgsConstructor;
import java.io.Serializable;
import io.swagger.annotations.ApiModel;
import io.swagger.annotations.ApiModelProperty;
@Data
@NoArgsConstructor
@AllArgsConstructor
@ApiModel(value = "工作流封装", description = "工作流封装")
public class FlowPro implements Serializable {
/**
* 工作流名称
*/
@ApiModelProperty(value = "工作流名称")
private String flowName;
/**
* 调度周期设置
*/
@ApiModelProperty(value = "调度周期设置")
private String scheduleSetting;
/**
* 失败选项
*/
@ApiModelProperty(value = "失败选项")
private String afterFailSelect;
......@@ -31,41 +38,49 @@ public class FlowPro implements Serializable {
/**
* 流程项目id
*/
@ApiModelProperty(value = "流程项目id")
private Long projectId;
/**
* 流程要发布到的项目id
*/
@ApiModelProperty(value = "流程要发布到的项目id")
private Long publishedToProjectId;
/**
* dmp里生成的任务id
*/
@ApiModelProperty(value = "dmp里生成的任务id")
private Long taskId;
/**
* dmp里的树id
*/
@ApiModelProperty(value = "dmp里的树id")
private Long treeId;
/**
* 整个流程图数据
*/
@ApiModelProperty(value = "整个流程图数据")
private String flowJson;
/**
* 是否带版本号进行节点变更查询
*/
@ApiModelProperty(value = "是否带版本号进行节点变更查询")
private boolean isCheckVerion;
/**
* 检查节点名称要用到的参数
*/
@ApiModelProperty(value = "检查节点名称要用到的参数")
private String nodeName;
/**
*
*/
@ApiModelProperty(value = "是否提交")
private String isSubmit = "0";
}
......
......@@ -8,12 +8,16 @@ import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestMethod;
import org.springframework.web.bind.annotation.RestController;
import com.jz.common.bean.BaseBeanResponse;
import com.jz.common.bean.BaseResponse;
import com.jz.common.bean.PageInfoResponse;
import com.jz.common.constant.StatuConstant;
import com.jz.dmp.modules.controller.bean.DmpDevelopTaskDto;
import com.jz.dmp.modules.controller.bean.DmpDevelopTaskRequest;
import com.jz.dmp.modules.model.DmpDevelopTask;
import com.jz.dmp.modules.service.DmpDevelopTaskService;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiOperation;
/**
......@@ -24,6 +28,7 @@ import io.swagger.annotations.ApiOperation;
*/
@RestController
@RequestMapping("/dmpDevelopTask")
@Api(tags = "任务开发")
public class DmpDevelopTaskController {
/**
* 服务对象
......@@ -49,5 +54,44 @@ public class DmpDevelopTaskController {
return pageInfo;
}
/**新增开发任务
* @param dmpDevelopTaskRequest
* @return
*/
@RequestMapping(method = RequestMethod.POST, value = "/add")
@ApiOperation(value = "新增开发任务", notes = "新增开发任务")
public BaseBeanResponse<DmpDevelopTask> add(@RequestBody DmpDevelopTask dmpDevelopTask, HttpServletRequest httpRequest){
BaseBeanResponse<DmpDevelopTask> baseBeanResponse = new BaseBeanResponse<DmpDevelopTask>();
try {
baseBeanResponse = dmpDevelopTaskService.add(dmpDevelopTask, httpRequest);
} catch (Exception e) {
baseBeanResponse.setMessage("新增或修改开发任务失败");
baseBeanResponse.setCode(StatuConstant.FAILURE_CODE);
e.printStackTrace();
}
return baseBeanResponse;
}
/**任务流程保存提交
* @param dmpDevelopTaskRequest
* @return
*/
@RequestMapping(method = RequestMethod.POST, value = "/flowSubmit")
@ApiOperation(value = "任务流程保存提交", notes = "任务流程保存提交")
public BaseResponse flowSubmit(@RequestBody DmpDevelopTask dmpDevelopTask, HttpServletRequest httpRequest){
BaseResponse baseResponse = new BaseResponse();
try {
baseResponse = dmpDevelopTaskService.flowSubmit(dmpDevelopTask, httpRequest);
} catch (Exception e) {
baseResponse.setMessage("任务流程保存提交失败");
baseResponse.setCode(StatuConstant.FAILURE_CODE);
e.printStackTrace();
}
return baseResponse;
}
}
\ No newline at end of file
......@@ -76,7 +76,7 @@ public class DmpNavigationTreeController {
BaseBeanResponse<DmpNavigationTree> baseBeanResponse = new BaseBeanResponse<DmpNavigationTree>();
try {
DmpNavigationTree dmpNavigationTreeDb = dmpNavigationTreeService.insert(dmpNavigationTree);
baseBeanResponse.setCode(StatuConstant.CODE_SUCCESS);
baseBeanResponse.setCode(StatuConstant.SUCCESS_CODE);
baseBeanResponse.setMessage("新增成功");
baseBeanResponse.setData(dmpNavigationTreeDb);
} catch (Exception e) {
......
......@@ -31,9 +31,9 @@ public class DmpDevelopTaskRequest extends BasePageBean {
private Integer datasourceId;
/**
* 任务类型
* 任务类型(1,开发任务;2,离线任务)
*/
@ApiModelProperty(value = "任务类型")
@ApiModelProperty(value = "任务类型(1,开发任务;2,离线任务)")
private String taskType;
/**
......@@ -197,6 +197,12 @@ public class DmpDevelopTaskRequest extends BasePageBean {
*/
@ApiModelProperty(value = "目标数据表名称")
private String targetTableName;
/**
* 项目id
*/
@ApiModelProperty(value = "项目id")
private Integer projectId;
public Integer getId() {
return id;
......@@ -445,4 +451,12 @@ public class DmpDevelopTaskRequest extends BasePageBean {
public void setTargetTableName(String targetTableName) {
this.targetTableName = targetTableName;
}
public Integer getProjectId() {
return projectId;
}
public void setProjectId(Integer projectId) {
this.projectId = projectId;
}
}
......@@ -26,15 +26,15 @@ public class DmpNavigationTreeRequest extends BasePageBean {
private Integer projectId;
/**
* 树类别
* 树类别(2:开发任务,3:脚本任务)
*/
@ApiModelProperty(value = "树类别")
@ApiModelProperty(value = "树类别(2:开发任务,3:脚本任务)")
private String category;
/**
* 树类型
* 树类型(01:离线同步,02:实时同步,03:数据开发)
*/
@ApiModelProperty(value = "树类型")
@ApiModelProperty(value = "树类型(01:离线同步,02:实时同步,03:数据开发)")
private String type;
/**
......
......@@ -5,6 +5,8 @@ import java.util.List;
import org.springframework.beans.BeanUtils;
import com.alibaba.fastjson.JSONObject;
import com.jz.dmp.modules.controller.DataIntegration.bean.flow.FlowPro;
import com.jz.dmp.modules.model.DmpDevelopTask;
public class MyDmpDevelopTaskConverter {
......@@ -37,4 +39,37 @@ public class MyDmpDevelopTaskConverter {
return dmpDevelopTaskDtos;
}
/**
* @Title: task2flowpro
* @Description: TODO(任务转工作流封装)
* @param @param dmpDevelopTask
* @param @return 参数
* @return FlowPro 返回类型
* @throws
*/
public FlowPro task2flowpro(DmpDevelopTask dmpDevelopTask) {
FlowPro flowPro = new FlowPro();
BeanUtils.copyProperties(dmpDevelopTask, flowPro);
//工作流名称
flowPro.setFlowName(dmpDevelopTask.getName());
//流程要发布到的项目id
flowPro.setPublishedToProjectId(dmpDevelopTask.getProjectId().longValue());
//dmp里生成的任务id
flowPro.setTaskId(dmpDevelopTask.getId().longValue());
//是否带版本号进行节点变更查询?
//检查节点名称要用到的参数?
String script = dmpDevelopTask.getScript();
//整个流程图数据
flowPro.setFlowJson(script);
JSONObject scriptJson = JSONObject.parseObject(script);
//调度周期设置
flowPro.setScheduleSetting(scriptJson.getString("scheduleSetting"));
//失败选项
flowPro.setAfterFailSelect(scriptJson.getString("afterFailSelect"));
return flowPro;
}
}
package com.jz.dmp.modules.controller.bean;
import java.util.ArrayList;
import java.util.Date;
import java.util.List;
import org.springframework.beans.BeanUtils;
import com.jz.common.utils.web.SessionUtils;
import com.jz.dmp.modules.model.DmpDevelopTask;
import com.jz.dmp.modules.model.DmpDevelopTaskHistory;
public class MyDmpDevelopTaskHistoryConverter {
private static MyDmpDevelopTaskHistoryConverter instance;
private MyDmpDevelopTaskHistoryConverter() {};
public synchronized static MyDmpDevelopTaskHistoryConverter INSTANCE() {
if (instance==null) {
instance = new MyDmpDevelopTaskHistoryConverter();
}
return instance;
}
public DmpDevelopTaskHistoryDto domain2dto(DmpDevelopTaskHistory dmpDevelopTaskHistory) {
DmpDevelopTaskHistoryDto dmpDevelopTaskHistoryDto = new DmpDevelopTaskHistoryDto();
BeanUtils.copyProperties(dmpDevelopTaskHistory, dmpDevelopTaskHistoryDto);
return dmpDevelopTaskHistoryDto;
}
public List<DmpDevelopTaskHistoryDto> domain2dto(List<DmpDevelopTaskHistory> dmpDevelopTaskHistorys) {
List<DmpDevelopTaskHistoryDto> dmpDevelopTaskHistoryDtos = new ArrayList<DmpDevelopTaskHistoryDto>();
dmpDevelopTaskHistorys.stream().forEach(x -> {
dmpDevelopTaskHistoryDtos.add(domain2dto(x));
});
return dmpDevelopTaskHistoryDtos;
}
/**
* @Title: task2history
* @Description: TODO(这里用一句话描述这个方法的作用)
* @param @param updateDevelopTask
* @param @return 参数
* @return DmpDevelopTaskHistory 返回类型
* @throws
*/
public DmpDevelopTaskHistory task2history(DmpDevelopTask dmpDevelopTask) {
DmpDevelopTaskHistory dmpDevelopTaskHistory = new DmpDevelopTaskHistory();
BeanUtils.copyProperties(dmpDevelopTask, dmpDevelopTaskHistory);
dmpDevelopTaskHistory.setTaskId(dmpDevelopTask.getId());
dmpDevelopTaskHistory.setTaskCreateUserId(dmpDevelopTask.getCreateUserId());
dmpDevelopTaskHistory.setTaskCreateTime(dmpDevelopTask.getCreateTime());
dmpDevelopTaskHistory.setTaskUpdateUserId(dmpDevelopTask.getUpdateUserId());
dmpDevelopTaskHistory.setTaskUpdateTime(dmpDevelopTask.getUpdateTime());
return dmpDevelopTaskHistory;
}
/**
* @Title: historyDto2task
* @Description: TODO(这里用一句话描述这个方法的作用)
* @param @param dmpDevelopTaskHistoryDto
* @param @return 参数
* @return DmpDevelopTask 返回类型
* @throws
*/
public DmpDevelopTask historyDto2task(DmpDevelopTaskHistoryDto dmpDevelopTaskHistoryDto) {
DmpDevelopTask dmpDevelopTask = new DmpDevelopTask();
BeanUtils.copyProperties(dmpDevelopTaskHistoryDto, dmpDevelopTask);
dmpDevelopTask.setId(dmpDevelopTaskHistoryDto.getTaskId());
dmpDevelopTask.setCreateUserId(dmpDevelopTaskHistoryDto.getTaskCreateUserId());
dmpDevelopTask.setCreateTime(dmpDevelopTaskHistoryDto.getTaskCreateTime());
dmpDevelopTask.setUpdateUserId(SessionUtils.getCurrentUserId());
dmpDevelopTask.setUpdateTime(new Date());
return dmpDevelopTask;
}
}
package com.jz.dmp.modules.controller.projconfig.bean;
import java.util.List;
import com.jz.dmp.modules.model.DmpComputEngine;
/**
* @author ybz
*
*/
public class DmpComputEngineBatch {
private List<DmpComputEngine> dmpComputEngines;
public List<DmpComputEngine> getDmpComputEngines() {
return dmpComputEngines;
}
public void setDmpComputEngines(List<DmpComputEngine> dmpComputEngines) {
this.dmpComputEngines = dmpComputEngines;
}
}
package com.jz.dmp.modules.controller.projconfig.bean;
import com.jz.dmp.modules.model.DmpComputEngine;
import io.swagger.annotations.ApiModel;
/**计算引擎表Dto
* @author ybz
*
*/
@ApiModel(value = "计算引擎表Dto", description = "计算引擎表Dto")
public class DmpComputEngineDto extends DmpComputEngine {
}
package com.jz.dmp.modules.controller.projconfig.bean;
import java.util.List;
import com.jz.dmp.modules.model.DmpComputEngineParam;
/**
* @author ybz
*
*/
public class DmpComputEngineParamBatch {
private List<DmpComputEngineParam> dmpComputEngineParams;
public List<DmpComputEngineParam> getDmpComputEngineParams() {
return dmpComputEngineParams;
}
public void setDmpComputEngineParams(List<DmpComputEngineParam> dmpComputEngineParams) {
this.dmpComputEngineParams = dmpComputEngineParams;
}
}
package com.jz.dmp.modules.controller.projconfig.bean;
import com.jz.dmp.modules.model.DmpComputEngineParam;
import io.swagger.annotations.ApiModel;
/**计算引擎参数表Dto
* @author ybz
*
*/
@ApiModel(value = "计算引擎参数表Dto", description = "计算引擎参数表Dto")
public class DmpComputEngineParamDto extends DmpComputEngineParam {
}
package com.jz.dmp.modules.controller.projconfig.bean;
import java.util.Date;
import com.jz.common.bean.BasePageBean;
import io.swagger.annotations.ApiModel;
import io.swagger.annotations.ApiModelProperty;
/**计算引擎参数表参数请求封装
* @author ybz
*
*/
@ApiModel(value = "计算引擎参数表参数请求封装", description = "计算引擎参数表参数请求封装")
public class DmpComputEngineParamRequest extends BasePageBean {
/**
* 主键
*/
@ApiModelProperty(value = "主键")
private Integer paramId;
/**
* 引擎主键
*/
@ApiModelProperty(value = "引擎主键")
private Integer engineId;
/**
* 参数名称
*/
@ApiModelProperty(value = "参数名称")
private String paramName;
/**
* 类型(0:引擎公共参数,1:引擎私配置参数)
*/
@ApiModelProperty(value = "类型(0:引擎公共参数,1:引擎私配置参数)")
private String paramType;
/**
* 参数值
*/
@ApiModelProperty(value = "参数值")
private String paramValue;
/**
* 备注
*/
@ApiModelProperty(value = "备注")
private String remark;
/**
* 数据状态(0:删除,1,未删除)
*/
@ApiModelProperty(value = "数据状态(0:删除,1,未删除)")
private String dataStatus;
/**
* 创建用户ID
*/
@ApiModelProperty(value = "创建用户ID")
private Integer createUserId;
/**
* 创建时间起
*/
@ApiModelProperty(value = "创建时间起")
private Date createTimeStart;
/**
* 创建时间止
*/
@ApiModelProperty(value = "创建时间止")
private Date createTimeEnd;
/**
* 修改用户ID
*/
@ApiModelProperty(value = "修改用户ID")
private Integer updateUserId;
/**
* 修改时间起
*/
@ApiModelProperty(value = "修改时间起")
private Date updateTimeStart;
/**
* 修改时间止
*/
@ApiModelProperty(value = "修改时间止")
private Date updateTimeEnd;
public Integer getParamId() {
return paramId;
}
public void setParamId(Integer paramId) {
this.paramId = paramId;
}
public Integer getEngineId() {
return engineId;
}
public void setEngineId(Integer engineId) {
this.engineId = engineId;
}
public String getParamName() {
return paramName;
}
public void setParamName(String paramName) {
this.paramName = paramName;
}
public String getParamType() {
return paramType;
}
public void setParamType(String paramType) {
this.paramType = paramType;
}
public String getParamValue() {
return paramValue;
}
public void setParamValue(String paramValue) {
this.paramValue = paramValue;
}
public String getRemark() {
return remark;
}
public void setRemark(String remark) {
this.remark = remark;
}
public String getDataStatus() {
return dataStatus;
}
public void setDataStatus(String dataStatus) {
this.dataStatus = dataStatus;
}
public Integer getCreateUserId() {
return createUserId;
}
public void setCreateUserId(Integer createUserId) {
this.createUserId = createUserId;
}
public Date getCreateTimeStart() {
return createTimeStart;
}
public void setCreateTimeStart(Date createTimeStart) {
this.createTimeStart = createTimeStart;
}
public Date getCreateTimeEnd() {
return createTimeEnd;
}
public void setCreateTimeEnd(Date createTimeEnd) {
this.createTimeEnd = createTimeEnd;
}
public Integer getUpdateUserId() {
return updateUserId;
}
public void setUpdateUserId(Integer updateUserId) {
this.updateUserId = updateUserId;
}
public Date getUpdateTimeStart() {
return updateTimeStart;
}
public void setUpdateTimeStart(Date updateTimeStart) {
this.updateTimeStart = updateTimeStart;
}
public Date getUpdateTimeEnd() {
return updateTimeEnd;
}
public void setUpdateTimeEnd(Date updateTimeEnd) {
this.updateTimeEnd = updateTimeEnd;
}
}
package com.jz.dmp.modules.controller.projconfig.bean;
import java.util.Date;
import com.jz.common.bean.BasePageBean;
import io.swagger.annotations.ApiModel;
import io.swagger.annotations.ApiModelProperty;
/**计算引擎表参数请求封装
* @author ybz
*
*/
@ApiModel(value = "计算引擎表参数请求封装", description = "计算引擎表参数请求封装")
public class DmpComputEngineRequest extends BasePageBean {
/**
* 主键
*/
@ApiModelProperty(value = "主键")
private Integer engineId;
/**
* 引擎名称
*/
@ApiModelProperty(value = "引擎名称")
private String engineName;
/**
* 备注
*/
@ApiModelProperty(value = "备注")
private String remark;
/**
* 数据状态(0:删除,1,未删除)
*/
@ApiModelProperty(value = "数据状态(0:删除,1,未删除)")
private String dataStatus;
/**
* 创建用户ID
*/
@ApiModelProperty(value = "创建用户ID")
private Integer createUserId;
/**
* 创建时间起
*/
@ApiModelProperty(value = "创建时间起")
private Date createTimeStart;
/**
* 创建时间止
*/
@ApiModelProperty(value = "创建时间止")
private Date createTimeEnd;
/**
* 修改用户ID
*/
@ApiModelProperty(value = "修改用户ID")
private Integer updateUserId;
/**
* 修改时间起
*/
@ApiModelProperty(value = "修改时间起")
private Date updateTimeStart;
/**
* 修改时间止
*/
@ApiModelProperty(value = "修改时间止")
private Date updateTimeEnd;
public Integer getEngineId() {
return engineId;
}
public void setEngineId(Integer engineId) {
this.engineId = engineId;
}
public String getEngineName() {
return engineName;
}
public void setEngineName(String engineName) {
this.engineName = engineName;
}
public String getRemark() {
return remark;
}
public void setRemark(String remark) {
this.remark = remark;
}
public String getDataStatus() {
return dataStatus;
}
public void setDataStatus(String dataStatus) {
this.dataStatus = dataStatus;
}
public Integer getCreateUserId() {
return createUserId;
}
public void setCreateUserId(Integer createUserId) {
this.createUserId = createUserId;
}
public Date getCreateTimeStart() {
return createTimeStart;
}
public void setCreateTimeStart(Date createTimeStart) {
this.createTimeStart = createTimeStart;
}
public Date getCreateTimeEnd() {
return createTimeEnd;
}
public void setCreateTimeEnd(Date createTimeEnd) {
this.createTimeEnd = createTimeEnd;
}
public Integer getUpdateUserId() {
return updateUserId;
}
public void setUpdateUserId(Integer updateUserId) {
this.updateUserId = updateUserId;
}
public Date getUpdateTimeStart() {
return updateTimeStart;
}
public void setUpdateTimeStart(Date updateTimeStart) {
this.updateTimeStart = updateTimeStart;
}
public Date getUpdateTimeEnd() {
return updateTimeEnd;
}
public void setUpdateTimeEnd(Date updateTimeEnd) {
this.updateTimeEnd = updateTimeEnd;
}
}
package com.jz.dmp.modules.controller.projconfig.bean;
import java.util.List;
import com.jz.dmp.modules.model.DmpProjectConfigEngine;
/**
* @author ybz
*
*/
public class DmpProjectConfigEngineBatch {
private List<DmpProjectConfigEngine> dmpProjectConfigEngines;
public List<DmpProjectConfigEngine> getDmpProjectConfigEngines() {
return dmpProjectConfigEngines;
}
public void setDmpProjectConfigEngines(List<DmpProjectConfigEngine> dmpProjectConfigEngines) {
this.dmpProjectConfigEngines = dmpProjectConfigEngines;
}
}
package com.jz.dmp.modules.controller.projconfig.bean;
import com.jz.dmp.modules.model.DmpProjectConfigEngine;
import io.swagger.annotations.ApiModel;
/**项目配置计算引擎关系表Dto
* @author ybz
*
*/
@ApiModel(value = "项目配置计算引擎关系表Dto", description = "项目配置计算引擎关系表Dto")
public class DmpProjectConfigEngineDto extends DmpProjectConfigEngine {
}
package com.jz.dmp.modules.controller.projconfig.bean;
import java.util.Date;
import com.jz.common.bean.BasePageBean;
import io.swagger.annotations.ApiModel;
import io.swagger.annotations.ApiModelProperty;
/**项目配置计算引擎关系表参数请求封装
* @author ybz
*
*/
@ApiModel(value = "项目配置计算引擎关系表参数请求封装", description = "项目配置计算引擎关系表参数请求封装")
public class DmpProjectConfigEngineRequest extends BasePageBean {
/**
* 主键
*/
@ApiModelProperty(value = "主键")
private Integer configEngineId;
/**
* 项目主键
*/
@ApiModelProperty(value = "项目主键")
private Integer projectId;
/**
* 引擎主键
*/
@ApiModelProperty(value = "引擎主键")
private Integer engineId;
/**
* 备注
*/
@ApiModelProperty(value = "备注")
private String remark;
/**
* 数据状态(0:删除,1,未删除)
*/
@ApiModelProperty(value = "数据状态(0:删除,1,未删除)")
private String dataStatus;
/**
* 创建用户ID
*/
@ApiModelProperty(value = "创建用户ID")
private Integer createUserId;
/**
* 创建时间起
*/
@ApiModelProperty(value = "创建时间起")
private Date createTimeStart;
/**
* 创建时间止
*/
@ApiModelProperty(value = "创建时间止")
private Date createTimeEnd;
/**
* 修改用户ID
*/
@ApiModelProperty(value = "修改用户ID")
private Integer updateUserId;
/**
* 修改时间起
*/
@ApiModelProperty(value = "修改时间起")
private Date updateTimeStart;
/**
* 修改时间止
*/
@ApiModelProperty(value = "修改时间止")
private Date updateTimeEnd;
public Integer getConfigEngineId() {
return configEngineId;
}
public void setConfigEngineId(Integer configEngineId) {
this.configEngineId = configEngineId;
}
public Integer getProjectId() {
return projectId;
}
public void setProjectId(Integer projectId) {
this.projectId = projectId;
}
public Integer getEngineId() {
return engineId;
}
public void setEngineId(Integer engineId) {
this.engineId = engineId;
}
public String getRemark() {
return remark;
}
public void setRemark(String remark) {
this.remark = remark;
}
public String getDataStatus() {
return dataStatus;
}
public void setDataStatus(String dataStatus) {
this.dataStatus = dataStatus;
}
public Integer getCreateUserId() {
return createUserId;
}
public void setCreateUserId(Integer createUserId) {
this.createUserId = createUserId;
}
public Date getCreateTimeStart() {
return createTimeStart;
}
public void setCreateTimeStart(Date createTimeStart) {
this.createTimeStart = createTimeStart;
}
public Date getCreateTimeEnd() {
return createTimeEnd;
}
public void setCreateTimeEnd(Date createTimeEnd) {
this.createTimeEnd = createTimeEnd;
}
public Integer getUpdateUserId() {
return updateUserId;
}
public void setUpdateUserId(Integer updateUserId) {
this.updateUserId = updateUserId;
}
public Date getUpdateTimeStart() {
return updateTimeStart;
}
public void setUpdateTimeStart(Date updateTimeStart) {
this.updateTimeStart = updateTimeStart;
}
public Date getUpdateTimeEnd() {
return updateTimeEnd;
}
public void setUpdateTimeEnd(Date updateTimeEnd) {
this.updateTimeEnd = updateTimeEnd;
}
}
package com.jz.dmp.modules.controller.projconfig.bean;
import java.util.List;
import com.jz.dmp.modules.model.DmpProjectConfigInfo;
/**
* @author ybz
*
*/
public class DmpProjectConfigInfoBatch {
private List<DmpProjectConfigInfo> dmpProjectConfigInfos;
public List<DmpProjectConfigInfo> getDmpProjectConfigInfos() {
return dmpProjectConfigInfos;
}
public void setDmpProjectConfigInfos(List<DmpProjectConfigInfo> dmpProjectConfigInfos) {
this.dmpProjectConfigInfos = dmpProjectConfigInfos;
}
}
package com.jz.dmp.modules.controller.projconfig.bean;
import com.jz.dmp.modules.model.DmpProjectConfigInfo;
import io.swagger.annotations.ApiModel;
/**项目配置表Dto
* @author ybz
*
*/
@ApiModel(value = "项目配置表Dto", description = "项目配置表Dto")
public class DmpProjectConfigInfoDto extends DmpProjectConfigInfo {
}
package com.jz.dmp.modules.controller.projconfig.bean;
import java.util.Date;
import com.jz.common.bean.BasePageBean;
import io.swagger.annotations.ApiModel;
import io.swagger.annotations.ApiModelProperty;
/**项目配置表参数请求封装
* @author ybz
*
*/
@ApiModel(value = "项目配置表参数请求封装", description = "项目配置表参数请求封装")
public class DmpProjectConfigInfoRequest extends BasePageBean {
/**
* 主键
*/
@ApiModelProperty(value = "主键")
private Integer projectConfigId;
/**
* 项目主键
*/
@ApiModelProperty(value = "项目主键")
private Integer projectId;
/**
* 备注
*/
@ApiModelProperty(value = "备注")
private String remark;
/**
* 数据状态(0:删除,1,未删除)
*/
@ApiModelProperty(value = "数据状态(0:删除,1,未删除)")
private String dataStatus;
/**
* 创建用户ID
*/
@ApiModelProperty(value = "创建用户ID")
private Integer createUserId;
/**
* 创建时间起
*/
@ApiModelProperty(value = "创建时间起")
private Date createTimeStart;
/**
* 创建时间止
*/
@ApiModelProperty(value = "创建时间止")
private Date createTimeEnd;
/**
* 修改用户ID
*/
@ApiModelProperty(value = "修改用户ID")
private Integer updateUserId;
/**
* 修改时间起
*/
@ApiModelProperty(value = "修改时间起")
private Date updateTimeStart;
/**
* 修改时间止
*/
@ApiModelProperty(value = "修改时间止")
private Date updateTimeEnd;
public Integer getProjectConfigId() {
return projectConfigId;
}
public void setProjectConfigId(Integer projectConfigId) {
this.projectConfigId = projectConfigId;
}
public Integer getProjectId() {
return projectId;
}
public void setProjectId(Integer projectId) {
this.projectId = projectId;
}
public String getRemark() {
return remark;
}
public void setRemark(String remark) {
this.remark = remark;
}
public String getDataStatus() {
return dataStatus;
}
public void setDataStatus(String dataStatus) {
this.dataStatus = dataStatus;
}
public Integer getCreateUserId() {
return createUserId;
}
public void setCreateUserId(Integer createUserId) {
this.createUserId = createUserId;
}
public Date getCreateTimeStart() {
return createTimeStart;
}
public void setCreateTimeStart(Date createTimeStart) {
this.createTimeStart = createTimeStart;
}
public Date getCreateTimeEnd() {
return createTimeEnd;
}
public void setCreateTimeEnd(Date createTimeEnd) {
this.createTimeEnd = createTimeEnd;
}
public Integer getUpdateUserId() {
return updateUserId;
}
public void setUpdateUserId(Integer updateUserId) {
this.updateUserId = updateUserId;
}
public Date getUpdateTimeStart() {
return updateTimeStart;
}
public void setUpdateTimeStart(Date updateTimeStart) {
this.updateTimeStart = updateTimeStart;
}
public Date getUpdateTimeEnd() {
return updateTimeEnd;
}
public void setUpdateTimeEnd(Date updateTimeEnd) {
this.updateTimeEnd = updateTimeEnd;
}
}
package com.jz.dmp.modules.controller.projconfig.bean;
import java.util.List;
import com.jz.dmp.modules.model.DmpProjectEngineParam;
/**
* @author ybz
*
*/
public class DmpProjectEngineParamBatch {
private List<DmpProjectEngineParam> dmpProjectEngineParams;
public List<DmpProjectEngineParam> getDmpProjectEngineParams() {
return dmpProjectEngineParams;
}
public void setDmpProjectEngineParams(List<DmpProjectEngineParam> dmpProjectEngineParams) {
this.dmpProjectEngineParams = dmpProjectEngineParams;
}
}
package com.jz.dmp.modules.controller.projconfig.bean;
import com.jz.dmp.modules.model.DmpProjectEngineParam;
import io.swagger.annotations.ApiModel;
/**计算引擎项目参数表Dto
* @author ybz
*
*/
@ApiModel(value = "计算引擎项目参数表Dto", description = "计算引擎项目参数表Dto")
public class DmpProjectEngineParamDto extends DmpProjectEngineParam {
}
package com.jz.dmp.modules.controller.projconfig.bean;
import java.util.Date;
import com.jz.common.bean.BasePageBean;
import io.swagger.annotations.ApiModel;
import io.swagger.annotations.ApiModelProperty;
/**计算引擎项目参数表参数请求封装
* @author ybz
*
*/
@ApiModel(value = "计算引擎项目参数表参数请求封装", description = "计算引擎项目参数表参数请求封装")
public class DmpProjectEngineParamRequest extends BasePageBean {
/**
* 主键
*/
@ApiModelProperty(value = "主键")
private Integer projectParamId;
/**
* 项目配置引擎关系主键
*/
@ApiModelProperty(value = "项目配置引擎关系主键")
private Integer configEngineId;
/**
* 引擎参数主键
*/
@ApiModelProperty(value = "引擎参数主键")
private Integer paramId;
/**
* 参数名称
*/
@ApiModelProperty(value = "参数名称")
private String paramName;
/**
* 参数值
*/
@ApiModelProperty(value = "参数值")
private String paramValue;
/**
* 备注
*/
@ApiModelProperty(value = "备注")
private String remark;
/**
* 数据状态(0:删除,1,未删除)
*/
@ApiModelProperty(value = "数据状态(0:删除,1,未删除)")
private String dataStatus;
/**
* 创建用户ID
*/
@ApiModelProperty(value = "创建用户ID")
private Integer createUserId;
/**
* 创建时间起
*/
@ApiModelProperty(value = "创建时间起")
private Date createTimeStart;
/**
* 创建时间止
*/
@ApiModelProperty(value = "创建时间止")
private Date createTimeEnd;
/**
* 修改用户ID
*/
@ApiModelProperty(value = "修改用户ID")
private Integer updateUserId;
/**
* 修改时间起
*/
@ApiModelProperty(value = "修改时间起")
private Date updateTimeStart;
/**
* 修改时间止
*/
@ApiModelProperty(value = "修改时间止")
private Date updateTimeEnd;
public Integer getProjectParamId() {
return projectParamId;
}
public void setProjectParamId(Integer projectParamId) {
this.projectParamId = projectParamId;
}
public Integer getConfigEngineId() {
return configEngineId;
}
public void setConfigEngineId(Integer configEngineId) {
this.configEngineId = configEngineId;
}
public Integer getParamId() {
return paramId;
}
public void setParamId(Integer paramId) {
this.paramId = paramId;
}
public String getParamName() {
return paramName;
}
public void setParamName(String paramName) {
this.paramName = paramName;
}
public String getParamValue() {
return paramValue;
}
public void setParamValue(String paramValue) {
this.paramValue = paramValue;
}
public String getRemark() {
return remark;
}
public void setRemark(String remark) {
this.remark = remark;
}
public String getDataStatus() {
return dataStatus;
}
public void setDataStatus(String dataStatus) {
this.dataStatus = dataStatus;
}
public Integer getCreateUserId() {
return createUserId;
}
public void setCreateUserId(Integer createUserId) {
this.createUserId = createUserId;
}
public Date getCreateTimeStart() {
return createTimeStart;
}
public void setCreateTimeStart(Date createTimeStart) {
this.createTimeStart = createTimeStart;
}
public Date getCreateTimeEnd() {
return createTimeEnd;
}
public void setCreateTimeEnd(Date createTimeEnd) {
this.createTimeEnd = createTimeEnd;
}
public Integer getUpdateUserId() {
return updateUserId;
}
public void setUpdateUserId(Integer updateUserId) {
this.updateUserId = updateUserId;
}
public Date getUpdateTimeStart() {
return updateTimeStart;
}
public void setUpdateTimeStart(Date updateTimeStart) {
this.updateTimeStart = updateTimeStart;
}
public Date getUpdateTimeEnd() {
return updateTimeEnd;
}
public void setUpdateTimeEnd(Date updateTimeEnd) {
this.updateTimeEnd = updateTimeEnd;
}
}
package com.jz.dmp.modules.controller.projconfig.bean;
import java.util.List;
import com.jz.dmp.modules.model.DmpPublicConfigInfo;
/**
* @author ybz
*
*/
public class DmpPublicConfigInfoBatch {
private List<DmpPublicConfigInfo> dmpPublicConfigInfos;
public List<DmpPublicConfigInfo> getDmpPublicConfigInfos() {
return dmpPublicConfigInfos;
}
public void setDmpPublicConfigInfos(List<DmpPublicConfigInfo> dmpPublicConfigInfos) {
this.dmpPublicConfigInfos = dmpPublicConfigInfos;
}
}
package com.jz.dmp.modules.controller.projconfig.bean;
import com.jz.dmp.modules.model.DmpPublicConfigInfo;
import io.swagger.annotations.ApiModel;
/**公共配置表Dto
* @author ybz
*
*/
@ApiModel(value = "公共配置表Dto", description = "公共配置表Dto")
public class DmpPublicConfigInfoDto extends DmpPublicConfigInfo {
}
package com.jz.dmp.modules.controller.projconfig.bean;
import java.util.Date;
import com.jz.common.bean.BasePageBean;
import io.swagger.annotations.ApiModel;
import io.swagger.annotations.ApiModelProperty;
/**公共配置表参数请求封装
* @author ybz
*
*/
@ApiModel(value = "公共配置表参数请求封装", description = "公共配置表参数请求封装")
public class DmpPublicConfigInfoRequest extends BasePageBean {
/**
* 主键
*/
@ApiModelProperty(value = "主键")
private Integer publicConfigId;
/**
* 是否启动kerberos(单选按钮)(0:不启用,1,启用)
*/
@ApiModelProperty(value = "是否启动kerberos(单选按钮)(0:不启用,1,启用)")
private String kerberosIsenable;
/**
* jaas默认Client名称
*/
@ApiModelProperty(value = "jaas默认Client名称")
private String kerberosJaasClientName;
/**
* krb5地址
*/
@ApiModelProperty(value = "krb5地址")
private String kerberosKrb5Conf;
/**
* jaas地址
*/
@ApiModelProperty(value = "jaas地址")
private String kerberosJaasConf;
/**
* FQDN
*/
@ApiModelProperty(value = "FQDN")
private String kerberosFqdn;
/**
* keytab地址
*/
@ApiModelProperty(value = "keytab地址")
private String kerberosKeytabConf;
/**
* keytab用户
*/
@ApiModelProperty(value = "keytab用户")
private String kerberosKeytabUser;
/**
* spark专用jaas
*/
@ApiModelProperty(value = "spark专用jaas")
private String kerberosSparkJaasConf;
/**
* 提交 XML默认defaultFS
*/
@ApiModelProperty(value = "提交 XML默认defaultFS")
private String hdfsHttpPath;
/**
* 提交XML到HDFS路径
*/
@ApiModelProperty(value = "提交XML到HDFS路径")
private String hdfsSyncingPath;
/**
* Hadoop 用户名
*/
@ApiModelProperty(value = "Hadoop 用户名")
private String hdfsUserName;
/**
* Kafka connector url
*/
@ApiModelProperty(value = "Kafka connector url")
private String kafkaConectorUrl;
/**
* schema register url
*/
@ApiModelProperty(value = "schema register url")
private String kafkaSchemaRegisterUrl;
/**
* kafka bootstarp servers
*/
@ApiModelProperty(value = "kafka bootstarp servers")
private String kafkaBootstrapServers;
/**
* 执行shell任务命令
*/
@ApiModelProperty(value = "执行shell任务命令")
private String azkabanExectorShellExec;
/**
* 执行impala sql任务命令
*/
@ApiModelProperty(value = "执行impala sql任务命令")
private String azkabanExectorSqlExec;
/**
* 执行数据同步任务命令
*/
@ApiModelProperty(value = "执行数据同步任务命令")
private String azkabanExectorXmlExec;
/**
* 调度执行sql路径
*/
@ApiModelProperty(value = "调度执行sql路径")
private String azkabanExectorSqlPath;
/**
* 调度执行shell路径
*/
@ApiModelProperty(value = "调度执行shell路径")
private String azkabanExectorShellPath;
/**
* task配置文件路径
*/
@ApiModelProperty(value = "task配置文件路径")
private String azkabanLocalTaskFilePath;
/**
* 执行数据导出任务命令的shell路径
*/
@ApiModelProperty(value = "执行数据导出任务命令的shell路径")
private String azkabanExectorShellExportData;
/**
* 调度web服务地址
*/
@ApiModelProperty(value = "调度web服务地址")
private String azkabanMonitorUrl;
/**
* 元数据服务web地址
*/
@ApiModelProperty(value = "元数据服务web地址")
private String atlasMonitorUrl;
/**
* 备注
*/
@ApiModelProperty(value = "备注")
private String remark;
/**
* 数据状态(0:删除,1,未删除)
*/
@ApiModelProperty(value = "数据状态(0:删除,1,未删除)")
private String dataStatus;
/**
* 创建用户ID
*/
@ApiModelProperty(value = "创建用户ID")
private Integer createUserId;
/**
* 创建时间起
*/
@ApiModelProperty(value = "创建时间起")
private Date createTimeStart;
/**
* 创建时间止
*/
@ApiModelProperty(value = "创建时间止")
private Date createTimeEnd;
/**
* 修改用户ID
*/
@ApiModelProperty(value = "修改用户ID")
private Integer updateUserId;
/**
* 修改时间起
*/
@ApiModelProperty(value = "修改时间起")
private Date updateTimeStart;
/**
* 修改时间止
*/
@ApiModelProperty(value = "修改时间止")
private Date updateTimeEnd;
public Integer getPublicConfigId() {
return publicConfigId;
}
public void setPublicConfigId(Integer publicConfigId) {
this.publicConfigId = publicConfigId;
}
public String getKerberosIsenable() {
return kerberosIsenable;
}
public void setKerberosIsenable(String kerberosIsenable) {
this.kerberosIsenable = kerberosIsenable;
}
public String getKerberosJaasClientName() {
return kerberosJaasClientName;
}
public void setKerberosJaasClientName(String kerberosJaasClientName) {
this.kerberosJaasClientName = kerberosJaasClientName;
}
public String getKerberosKrb5Conf() {
return kerberosKrb5Conf;
}
public void setKerberosKrb5Conf(String kerberosKrb5Conf) {
this.kerberosKrb5Conf = kerberosKrb5Conf;
}
public String getKerberosJaasConf() {
return kerberosJaasConf;
}
public void setKerberosJaasConf(String kerberosJaasConf) {
this.kerberosJaasConf = kerberosJaasConf;
}
public String getKerberosFqdn() {
return kerberosFqdn;
}
public void setKerberosFqdn(String kerberosFqdn) {
this.kerberosFqdn = kerberosFqdn;
}
public String getKerberosKeytabConf() {
return kerberosKeytabConf;
}
public void setKerberosKeytabConf(String kerberosKeytabConf) {
this.kerberosKeytabConf = kerberosKeytabConf;
}
public String getKerberosKeytabUser() {
return kerberosKeytabUser;
}
public void setKerberosKeytabUser(String kerberosKeytabUser) {
this.kerberosKeytabUser = kerberosKeytabUser;
}
public String getKerberosSparkJaasConf() {
return kerberosSparkJaasConf;
}
public void setKerberosSparkJaasConf(String kerberosSparkJaasConf) {
this.kerberosSparkJaasConf = kerberosSparkJaasConf;
}
public String getHdfsHttpPath() {
return hdfsHttpPath;
}
public void setHdfsHttpPath(String hdfsHttpPath) {
this.hdfsHttpPath = hdfsHttpPath;
}
public String getHdfsSyncingPath() {
return hdfsSyncingPath;
}
public void setHdfsSyncingPath(String hdfsSyncingPath) {
this.hdfsSyncingPath = hdfsSyncingPath;
}
public String getHdfsUserName() {
return hdfsUserName;
}
public void setHdfsUserName(String hdfsUserName) {
this.hdfsUserName = hdfsUserName;
}
public String getKafkaConectorUrl() {
return kafkaConectorUrl;
}
public void setKafkaConectorUrl(String kafkaConectorUrl) {
this.kafkaConectorUrl = kafkaConectorUrl;
}
public String getKafkaSchemaRegisterUrl() {
return kafkaSchemaRegisterUrl;
}
public void setKafkaSchemaRegisterUrl(String kafkaSchemaRegisterUrl) {
this.kafkaSchemaRegisterUrl = kafkaSchemaRegisterUrl;
}
public String getKafkaBootstrapServers() {
return kafkaBootstrapServers;
}
public void setKafkaBootstrapServers(String kafkaBootstrapServers) {
this.kafkaBootstrapServers = kafkaBootstrapServers;
}
public String getAzkabanExectorShellExec() {
return azkabanExectorShellExec;
}
public void setAzkabanExectorShellExec(String azkabanExectorShellExec) {
this.azkabanExectorShellExec = azkabanExectorShellExec;
}
public String getAzkabanExectorSqlExec() {
return azkabanExectorSqlExec;
}
public void setAzkabanExectorSqlExec(String azkabanExectorSqlExec) {
this.azkabanExectorSqlExec = azkabanExectorSqlExec;
}
public String getAzkabanExectorXmlExec() {
return azkabanExectorXmlExec;
}
public void setAzkabanExectorXmlExec(String azkabanExectorXmlExec) {
this.azkabanExectorXmlExec = azkabanExectorXmlExec;
}
public String getAzkabanExectorSqlPath() {
return azkabanExectorSqlPath;
}
public void setAzkabanExectorSqlPath(String azkabanExectorSqlPath) {
this.azkabanExectorSqlPath = azkabanExectorSqlPath;
}
public String getAzkabanExectorShellPath() {
return azkabanExectorShellPath;
}
public void setAzkabanExectorShellPath(String azkabanExectorShellPath) {
this.azkabanExectorShellPath = azkabanExectorShellPath;
}
public String getAzkabanLocalTaskFilePath() {
return azkabanLocalTaskFilePath;
}
public void setAzkabanLocalTaskFilePath(String azkabanLocalTaskFilePath) {
this.azkabanLocalTaskFilePath = azkabanLocalTaskFilePath;
}
public String getAzkabanExectorShellExportData() {
return azkabanExectorShellExportData;
}
public void setAzkabanExectorShellExportData(String azkabanExectorShellExportData) {
this.azkabanExectorShellExportData = azkabanExectorShellExportData;
}
public String getAzkabanMonitorUrl() {
return azkabanMonitorUrl;
}
public void setAzkabanMonitorUrl(String azkabanMonitorUrl) {
this.azkabanMonitorUrl = azkabanMonitorUrl;
}
public String getAtlasMonitorUrl() {
return atlasMonitorUrl;
}
public void setAtlasMonitorUrl(String atlasMonitorUrl) {
this.atlasMonitorUrl = atlasMonitorUrl;
}
public String getRemark() {
return remark;
}
public void setRemark(String remark) {
this.remark = remark;
}
public String getDataStatus() {
return dataStatus;
}
public void setDataStatus(String dataStatus) {
this.dataStatus = dataStatus;
}
public Integer getCreateUserId() {
return createUserId;
}
public void setCreateUserId(Integer createUserId) {
this.createUserId = createUserId;
}
public Date getCreateTimeStart() {
return createTimeStart;
}
public void setCreateTimeStart(Date createTimeStart) {
this.createTimeStart = createTimeStart;
}
public Date getCreateTimeEnd() {
return createTimeEnd;
}
public void setCreateTimeEnd(Date createTimeEnd) {
this.createTimeEnd = createTimeEnd;
}
public Integer getUpdateUserId() {
return updateUserId;
}
public void setUpdateUserId(Integer updateUserId) {
this.updateUserId = updateUserId;
}
public Date getUpdateTimeStart() {
return updateTimeStart;
}
public void setUpdateTimeStart(Date updateTimeStart) {
this.updateTimeStart = updateTimeStart;
}
public Date getUpdateTimeEnd() {
return updateTimeEnd;
}
public void setUpdateTimeEnd(Date updateTimeEnd) {
this.updateTimeEnd = updateTimeEnd;
}
}
......@@ -116,5 +116,16 @@ public interface DmpDevelopTaskHistoryMapper {
* @throws
*/
public void softDeleteByIds(@Param("idList")List<Integer> idList)throws Exception;
/**
* @Title: getMaxVersionByTaskId
* @Description: TODO(获取任务当前最大版本号)
* @param @param taskId
* @param @return
* @param @throws Exception 参数
* @return String 返回类型
* @throws
*/
public String getMaxVersionByTaskId(@Param("taskId")Integer taskId)throws Exception;
}
package com.jz.dmp.modules.dao;
import java.util.List;
import org.apache.ibatis.annotations.Mapper;
import com.jz.dmp.modules.model.DmpModuleOperateLog;
@Mapper
public interface DmpModuleOperateLogDao {
/**新增
* @param dmpModuleOperateLog
* @return
* @throws Exception
*/
public int insert(DmpModuleOperateLog dmpModuleOperateLog)throws Exception;
/**
* 根据组合主键查询最新操作日志
*
* @param operateLog
* @return
*/
public DmpModuleOperateLog getLastOperateLog(DmpModuleOperateLog operateLog);
/**
* @Title: findList
* @Description: TODO(条件查询操作日志信息)
* @param @param operateLog
* @param @return
* @param @throws Exception 参数
* @return List<DmpModuleOperateLog> 返回类型
* @throws
*/
public List<DmpModuleOperateLog> findList(DmpModuleOperateLog operateLog)throws Exception;
}
......@@ -80,4 +80,34 @@ public interface DmpNavigationTreeDao{
int deleteById(Integer id);
int countTreeByName(DmpNavigationTree tree);
/**
* @Title: getByProjectIdAndName
* @Description: TODO(根据项目ID和任务名称获取tree)
* @param @param projectId
* @param @param name
* @param @return
* @param @throws Exception 参数
* @return DmpNavigationTree 返回类型
* @throws
*/
public DmpNavigationTree getByProjectIdAndName(@Param("projectId") Long projectId,@Param("name") String name)throws Exception;
/**
* @Title: getMaxSortById
* @Description: TODO(这里用一句话描述这个方法的作用)
* @param @param tree
* @param @return
* @param @throws Exception 参数
* @return Integer 返回类型
* @throws
*/
public Integer getMaxSortById(DmpNavigationTree tree)throws Exception;
/**选择性增加DMP资源导航树
* @param dmpNavigationTree
* @return
* @throws Exception
*/
public int insertSelective(DmpNavigationTree dmpNavigationTree)throws Exception;
}
\ No newline at end of file
package com.jz.dmp.modules.dao;
import java.util.List;
import java.util.Map;
import org.apache.ibatis.annotations.Mapper;
import com.jz.dmp.modules.model.DmpWorkFlowSubmitDetails;
@Mapper
public interface DmpWorkFlowSubmitDetailsDao {
public List<DmpWorkFlowSubmitDetails> getLatestUnderFlowByNodeName(Map map);
public Integer getLatestVersionByProjectIdFlowNameAndNodeName(Map map);
public void deleteDmpWorkFlowSubmitDetailsByProjectIdFlowNameAndNodeName(Map map);
public List<DmpWorkFlowSubmitDetails> getAllJobNamesByProjectIdBesidesFlowName(Map map);
public List<DmpWorkFlowSubmitDetails> findNodeHistory(DmpWorkFlowSubmitDetails body);
public DmpWorkFlowSubmitDetails getMaxVersionByScheduleProjectIdAndFlowNameNodeName(Map map);
public void deleteByFlow(DmpWorkFlowSubmitDetails detail);
Integer countByNodeName(String nodeName);
/**
* @Title: insert
* @Description: TODO(插入数据)
* @param @param detail
* @param @throws Exception 参数
* @return void 返回类型
* @throws
*/
public void insert(DmpWorkFlowSubmitDetails detail)throws Exception;
}
package com.jz.dmp.modules.dao.projconfig;
import java.util.List;
import java.util.Map;
import org.apache.ibatis.annotations.Param;
import com.jz.dmp.modules.controller.projconfig.bean.DmpComputEngineDto;
import com.jz.dmp.modules.model.DmpComputEngine;
/**计算引擎表 mapper
* @author ybz
*
*/
public interface DmpComputEngineMapper {
/**新增计算引擎表
* @param dmpComputEngine
* @return
* @throws Exception
*/
public int insert(DmpComputEngine dmpComputEngine)throws Exception;
/**选择性增加计算引擎表
* @param dmpComputEngine
* @return
* @throws Exception
*/
public int insertSelective(DmpComputEngine dmpComputEngine)throws Exception;
/**主键修改计算引擎表
* @param dmpComputEngine
* @return
* @throws Exception
*/
public int updateByPrimaryKey(DmpComputEngine dmpComputEngine)throws Exception;
/**选择性修改计算引擎表
* @param dmpComputEngine
* @return
* @throws Exception
*/
public int updateByPrimaryKeySelective(DmpComputEngine dmpComputEngine)throws Exception;
/**主键查询计算引擎表
* @param engineId
* @return
* @throws Exception
*/
public DmpComputEngine selectByPrimaryKey(Integer engineId)throws Exception;
/**主键删除计算引擎表
* @param engineId
* @return
* @throws Exception
*/
public int deleteByPrimaryKey(Integer engineId)throws Exception;
/**主键软删除计算引擎表
* @param engineId
* @return
* @throws Exception
*/
public int softDeleteByPrimaryKey(Integer engineId)throws Exception;
/**主键删除计算引擎表
* @param engineId
* @return
* @throws Exception
*/
public int delete(Map<String, Object> param)throws Exception;
/**主键软删除计算引擎表
* @param engineId
* @return
* @throws Exception
*/
public int softDelete(Map<String, Object> param)throws Exception;
/**条件查询计算引擎表
* @param param
* @return
* @throws Exception
*/
public List<DmpComputEngineDto> findList(Map<String, Object> param)throws Exception;
/**主键查询计算引擎表
* @param engineId
* @return
* @throws Exception
*/
public DmpComputEngineDto findById(Integer engineId)throws Exception;
/**批量新增计算引擎表
* @param dmpComputEngines
* @throws Exception
*/
public void insertBatch(List<DmpComputEngine> dmpComputEngines)throws Exception;
/**
* @Title: deleteByIds
* @Description: TODO(批量删除)
* @param @param idList
* @param @throws Exception 参数
* @return void 返回类型
* @throws
*/
public void deleteByIds(@Param("idList")List<Integer> idList)throws Exception;
/**
* @Title: softDeleteByIds
* @Description: TODO(批量软删除)
* @param @param idList
* @param @throws Exception 参数
* @return void 返回类型
* @throws
*/
public void softDeleteByIds(@Param("idList")List<Integer> idList)throws Exception;
}
package com.jz.dmp.modules.dao.projconfig;
import java.util.List;
import java.util.Map;
import org.apache.ibatis.annotations.Param;
import com.jz.dmp.modules.controller.projconfig.bean.DmpComputEngineParamDto;
import com.jz.dmp.modules.model.DmpComputEngineParam;
/**计算引擎参数表 mapper
* @author ybz
*
*/
public interface DmpComputEngineParamMapper {
/**新增计算引擎参数表
* @param dmpComputEngineParam
* @return
* @throws Exception
*/
public int insert(DmpComputEngineParam dmpComputEngineParam)throws Exception;
/**选择性增加计算引擎参数表
* @param dmpComputEngineParam
* @return
* @throws Exception
*/
public int insertSelective(DmpComputEngineParam dmpComputEngineParam)throws Exception;
/**主键修改计算引擎参数表
* @param dmpComputEngineParam
* @return
* @throws Exception
*/
public int updateByPrimaryKey(DmpComputEngineParam dmpComputEngineParam)throws Exception;
/**选择性修改计算引擎参数表
* @param dmpComputEngineParam
* @return
* @throws Exception
*/
public int updateByPrimaryKeySelective(DmpComputEngineParam dmpComputEngineParam)throws Exception;
/**主键查询计算引擎参数表
* @param paramId
* @return
* @throws Exception
*/
public DmpComputEngineParam selectByPrimaryKey(Integer paramId)throws Exception;
/**主键删除计算引擎参数表
* @param paramId
* @return
* @throws Exception
*/
public int deleteByPrimaryKey(Integer paramId)throws Exception;
/**主键软删除计算引擎参数表
* @param paramId
* @return
* @throws Exception
*/
public int softDeleteByPrimaryKey(Integer paramId)throws Exception;
/**主键删除计算引擎参数表
* @param paramId
* @return
* @throws Exception
*/
public int delete(Map<String, Object> param)throws Exception;
/**主键软删除计算引擎参数表
* @param paramId
* @return
* @throws Exception
*/
public int softDelete(Map<String, Object> param)throws Exception;
/**条件查询计算引擎参数表
* @param param
* @return
* @throws Exception
*/
public List<DmpComputEngineParamDto> findList(Map<String, Object> param)throws Exception;
/**主键查询计算引擎参数表
* @param paramId
* @return
* @throws Exception
*/
public DmpComputEngineParamDto findById(Integer paramId)throws Exception;
/**批量新增计算引擎参数表
* @param dmpComputEngineParams
* @throws Exception
*/
public void insertBatch(List<DmpComputEngineParam> dmpComputEngineParams)throws Exception;
/**
* @Title: deleteByIds
* @Description: TODO(批量删除)
* @param @param idList
* @param @throws Exception 参数
* @return void 返回类型
* @throws
*/
public void deleteByIds(@Param("idList")List<Integer> idList)throws Exception;
/**
* @Title: softDeleteByIds
* @Description: TODO(批量软删除)
* @param @param idList
* @param @throws Exception 参数
* @return void 返回类型
* @throws
*/
public void softDeleteByIds(@Param("idList")List<Integer> idList)throws Exception;
}
package com.jz.dmp.modules.dao.projconfig;
import java.util.List;
import java.util.Map;
import org.apache.ibatis.annotations.Param;
import com.jz.dmp.modules.controller.projconfig.bean.DmpProjectConfigEngineDto;
import com.jz.dmp.modules.model.DmpProjectConfigEngine;
/**项目配置计算引擎关系表 mapper
* @author ybz
*
*/
public interface DmpProjectConfigEngineMapper {
/**新增项目配置计算引擎关系表
* @param dmpProjectConfigEngine
* @return
* @throws Exception
*/
public int insert(DmpProjectConfigEngine dmpProjectConfigEngine)throws Exception;
/**选择性增加项目配置计算引擎关系表
* @param dmpProjectConfigEngine
* @return
* @throws Exception
*/
public int insertSelective(DmpProjectConfigEngine dmpProjectConfigEngine)throws Exception;
/**主键修改项目配置计算引擎关系表
* @param dmpProjectConfigEngine
* @return
* @throws Exception
*/
public int updateByPrimaryKey(DmpProjectConfigEngine dmpProjectConfigEngine)throws Exception;
/**选择性修改项目配置计算引擎关系表
* @param dmpProjectConfigEngine
* @return
* @throws Exception
*/
public int updateByPrimaryKeySelective(DmpProjectConfigEngine dmpProjectConfigEngine)throws Exception;
/**主键查询项目配置计算引擎关系表
* @param configEngineId
* @return
* @throws Exception
*/
public DmpProjectConfigEngine selectByPrimaryKey(Integer configEngineId)throws Exception;
/**主键删除项目配置计算引擎关系表
* @param configEngineId
* @return
* @throws Exception
*/
public int deleteByPrimaryKey(Integer configEngineId)throws Exception;
/**主键软删除项目配置计算引擎关系表
* @param configEngineId
* @return
* @throws Exception
*/
public int softDeleteByPrimaryKey(Integer configEngineId)throws Exception;
/**主键删除项目配置计算引擎关系表
* @param configEngineId
* @return
* @throws Exception
*/
public int delete(Map<String, Object> param)throws Exception;
/**主键软删除项目配置计算引擎关系表
* @param configEngineId
* @return
* @throws Exception
*/
public int softDelete(Map<String, Object> param)throws Exception;
/**条件查询项目配置计算引擎关系表
* @param param
* @return
* @throws Exception
*/
public List<DmpProjectConfigEngineDto> findList(Map<String, Object> param)throws Exception;
/**主键查询项目配置计算引擎关系表
* @param configEngineId
* @return
* @throws Exception
*/
public DmpProjectConfigEngineDto findById(Integer configEngineId)throws Exception;
/**批量新增项目配置计算引擎关系表
* @param dmpProjectConfigEngines
* @throws Exception
*/
public void insertBatch(List<DmpProjectConfigEngine> dmpProjectConfigEngines)throws Exception;
/**
* @Title: deleteByIds
* @Description: TODO(批量删除)
* @param @param idList
* @param @throws Exception 参数
* @return void 返回类型
* @throws
*/
public void deleteByIds(@Param("idList")List<Integer> idList)throws Exception;
/**
* @Title: softDeleteByIds
* @Description: TODO(批量软删除)
* @param @param idList
* @param @throws Exception 参数
* @return void 返回类型
* @throws
*/
public void softDeleteByIds(@Param("idList")List<Integer> idList)throws Exception;
}
package com.jz.dmp.modules.dao.projconfig;
import java.util.List;
import java.util.Map;
import org.apache.ibatis.annotations.Param;
import com.jz.dmp.modules.controller.projconfig.bean.DmpProjectConfigInfoDto;
import com.jz.dmp.modules.model.DmpProjectConfigInfo;
/**项目配置表 mapper
* @author ybz
*
*/
public interface DmpProjectConfigInfoMapper {
/**新增项目配置表
* @param dmpProjectConfigInfo
* @return
* @throws Exception
*/
public int insert(DmpProjectConfigInfo dmpProjectConfigInfo)throws Exception;
/**选择性增加项目配置表
* @param dmpProjectConfigInfo
* @return
* @throws Exception
*/
public int insertSelective(DmpProjectConfigInfo dmpProjectConfigInfo)throws Exception;
/**主键修改项目配置表
* @param dmpProjectConfigInfo
* @return
* @throws Exception
*/
public int updateByPrimaryKey(DmpProjectConfigInfo dmpProjectConfigInfo)throws Exception;
/**选择性修改项目配置表
* @param dmpProjectConfigInfo
* @return
* @throws Exception
*/
public int updateByPrimaryKeySelective(DmpProjectConfigInfo dmpProjectConfigInfo)throws Exception;
/**主键查询项目配置表
* @param projectConfigId
* @return
* @throws Exception
*/
public DmpProjectConfigInfo selectByPrimaryKey(Integer projectConfigId)throws Exception;
/**主键删除项目配置表
* @param projectConfigId
* @return
* @throws Exception
*/
public int deleteByPrimaryKey(Integer projectConfigId)throws Exception;
/**主键软删除项目配置表
* @param projectConfigId
* @return
* @throws Exception
*/
public int softDeleteByPrimaryKey(Integer projectConfigId)throws Exception;
/**主键删除项目配置表
* @param projectConfigId
* @return
* @throws Exception
*/
public int delete(Map<String, Object> param)throws Exception;
/**主键软删除项目配置表
* @param projectConfigId
* @return
* @throws Exception
*/
public int softDelete(Map<String, Object> param)throws Exception;
/**条件查询项目配置表
* @param param
* @return
* @throws Exception
*/
public List<DmpProjectConfigInfoDto> findList(Map<String, Object> param)throws Exception;
/**主键查询项目配置表
* @param projectConfigId
* @return
* @throws Exception
*/
public DmpProjectConfigInfoDto findById(Integer projectConfigId)throws Exception;
/**批量新增项目配置表
* @param dmpProjectConfigInfos
* @throws Exception
*/
public void insertBatch(List<DmpProjectConfigInfo> dmpProjectConfigInfos)throws Exception;
/**
* @Title: deleteByIds
* @Description: TODO(批量删除)
* @param @param idList
* @param @throws Exception 参数
* @return void 返回类型
* @throws
*/
public void deleteByIds(@Param("idList")List<Integer> idList)throws Exception;
/**
* @Title: softDeleteByIds
* @Description: TODO(批量软删除)
* @param @param idList
* @param @throws Exception 参数
* @return void 返回类型
* @throws
*/
public void softDeleteByIds(@Param("idList")List<Integer> idList)throws Exception;
}
package com.jz.dmp.modules.dao.projconfig;
import java.util.List;
import java.util.Map;
import org.apache.ibatis.annotations.Param;
import com.jz.dmp.modules.controller.projconfig.bean.DmpProjectEngineParamDto;
import com.jz.dmp.modules.model.DmpProjectEngineParam;
/**计算引擎项目参数表 mapper
* @author ybz
*
*/
public interface DmpProjectEngineParamMapper {
/**新增计算引擎项目参数表
* @param dmpProjectEngineParam
* @return
* @throws Exception
*/
public int insert(DmpProjectEngineParam dmpProjectEngineParam)throws Exception;
/**选择性增加计算引擎项目参数表
* @param dmpProjectEngineParam
* @return
* @throws Exception
*/
public int insertSelective(DmpProjectEngineParam dmpProjectEngineParam)throws Exception;
/**主键修改计算引擎项目参数表
* @param dmpProjectEngineParam
* @return
* @throws Exception
*/
public int updateByPrimaryKey(DmpProjectEngineParam dmpProjectEngineParam)throws Exception;
/**选择性修改计算引擎项目参数表
* @param dmpProjectEngineParam
* @return
* @throws Exception
*/
public int updateByPrimaryKeySelective(DmpProjectEngineParam dmpProjectEngineParam)throws Exception;
/**主键查询计算引擎项目参数表
* @param projectParamId
* @return
* @throws Exception
*/
public DmpProjectEngineParam selectByPrimaryKey(Integer projectParamId)throws Exception;
/**主键删除计算引擎项目参数表
* @param projectParamId
* @return
* @throws Exception
*/
public int deleteByPrimaryKey(Integer projectParamId)throws Exception;
/**主键软删除计算引擎项目参数表
* @param projectParamId
* @return
* @throws Exception
*/
public int softDeleteByPrimaryKey(Integer projectParamId)throws Exception;
/**主键删除计算引擎项目参数表
* @param projectParamId
* @return
* @throws Exception
*/
public int delete(Map<String, Object> param)throws Exception;
/**主键软删除计算引擎项目参数表
* @param projectParamId
* @return
* @throws Exception
*/
public int softDelete(Map<String, Object> param)throws Exception;
/**条件查询计算引擎项目参数表
* @param param
* @return
* @throws Exception
*/
public List<DmpProjectEngineParamDto> findList(Map<String, Object> param)throws Exception;
/**主键查询计算引擎项目参数表
* @param projectParamId
* @return
* @throws Exception
*/
public DmpProjectEngineParamDto findById(Integer projectParamId)throws Exception;
/**批量新增计算引擎项目参数表
* @param dmpProjectEngineParams
* @throws Exception
*/
public void insertBatch(List<DmpProjectEngineParam> dmpProjectEngineParams)throws Exception;
/**
* @Title: deleteByIds
* @Description: TODO(批量删除)
* @param @param idList
* @param @throws Exception 参数
* @return void 返回类型
* @throws
*/
public void deleteByIds(@Param("idList")List<Integer> idList)throws Exception;
/**
* @Title: softDeleteByIds
* @Description: TODO(批量软删除)
* @param @param idList
* @param @throws Exception 参数
* @return void 返回类型
* @throws
*/
public void softDeleteByIds(@Param("idList")List<Integer> idList)throws Exception;
}
package com.jz.dmp.modules.dao.projconfig;
import java.util.List;
import java.util.Map;
import org.apache.ibatis.annotations.Param;
import com.jz.dmp.modules.controller.projconfig.bean.DmpPublicConfigInfoDto;
import com.jz.dmp.modules.model.DmpPublicConfigInfo;
/**公共配置表 mapper
* @author ybz
*
*/
public interface DmpPublicConfigInfoMapper {
/**新增公共配置表
* @param dmpPublicConfigInfo
* @return
* @throws Exception
*/
public int insert(DmpPublicConfigInfo dmpPublicConfigInfo)throws Exception;
/**选择性增加公共配置表
* @param dmpPublicConfigInfo
* @return
* @throws Exception
*/
public int insertSelective(DmpPublicConfigInfo dmpPublicConfigInfo)throws Exception;
/**主键修改公共配置表
* @param dmpPublicConfigInfo
* @return
* @throws Exception
*/
public int updateByPrimaryKey(DmpPublicConfigInfo dmpPublicConfigInfo)throws Exception;
/**选择性修改公共配置表
* @param dmpPublicConfigInfo
* @return
* @throws Exception
*/
public int updateByPrimaryKeySelective(DmpPublicConfigInfo dmpPublicConfigInfo)throws Exception;
/**主键查询公共配置表
* @param publicConfigId
* @return
* @throws Exception
*/
public DmpPublicConfigInfo selectByPrimaryKey(Integer publicConfigId)throws Exception;
/**主键删除公共配置表
* @param publicConfigId
* @return
* @throws Exception
*/
public int deleteByPrimaryKey(Integer publicConfigId)throws Exception;
/**主键软删除公共配置表
* @param publicConfigId
* @return
* @throws Exception
*/
public int softDeleteByPrimaryKey(Integer publicConfigId)throws Exception;
/**主键删除公共配置表
* @param publicConfigId
* @return
* @throws Exception
*/
public int delete(Map<String, Object> param)throws Exception;
/**主键软删除公共配置表
* @param publicConfigId
* @return
* @throws Exception
*/
public int softDelete(Map<String, Object> param)throws Exception;
/**条件查询公共配置表
* @param param
* @return
* @throws Exception
*/
public List<DmpPublicConfigInfoDto> findList(Map<String, Object> param)throws Exception;
/**主键查询公共配置表
* @param publicConfigId
* @return
* @throws Exception
*/
public DmpPublicConfigInfoDto findById(Integer publicConfigId)throws Exception;
/**批量新增公共配置表
* @param dmpPublicConfigInfos
* @throws Exception
*/
public void insertBatch(List<DmpPublicConfigInfo> dmpPublicConfigInfos)throws Exception;
/**
* @Title: deleteByIds
* @Description: TODO(批量删除)
* @param @param idList
* @param @throws Exception 参数
* @return void 返回类型
* @throws
*/
public void deleteByIds(@Param("idList")List<Integer> idList)throws Exception;
/**
* @Title: softDeleteByIds
* @Description: TODO(批量软删除)
* @param @param idList
* @param @throws Exception 参数
* @return void 返回类型
* @throws
*/
public void softDeleteByIds(@Param("idList")List<Integer> idList)throws Exception;
}
package com.jz.dmp.modules.model;
import java.io.Serializable;
import com.fasterxml.jackson.annotation.JsonFormat;
import io.swagger.annotations.ApiModel;
import io.swagger.annotations.ApiModelProperty;
import java.util.Date;
/**计算引擎表
* @author ybz
*
*/
@ApiModel(value = "计算引擎表", description = "计算引擎表")
public class DmpComputEngine implements Serializable{
/**
*
*/
private static final long serialVersionUID = 1L;
/**
* 主键
*/
@ApiModelProperty(value = "主键")
private Integer engineId;
/**
* 引擎名称
*/
@ApiModelProperty(value = "引擎名称")
private String engineName;
/**
* 备注
*/
@ApiModelProperty(value = "备注")
private String remark;
/**
* 数据状态(0:删除,1,未删除)
*/
@ApiModelProperty(value = "数据状态(0:删除,1,未删除)")
private String dataStatus;
/**
* 创建用户ID
*/
@ApiModelProperty(value = "创建用户ID")
private Integer createUserId;
/**
* 创建时间
*/
@ApiModelProperty(value = "创建时间")
@JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss")
private Date createTime;
/**
* 修改用户ID
*/
@ApiModelProperty(value = "修改用户ID")
private Integer updateUserId;
/**
* 修改时间
*/
@ApiModelProperty(value = "修改时间")
@JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss")
private Date updateTime;
public Integer getEngineId() {
return engineId;
}
public void setEngineId(Integer engineId) {
this.engineId = engineId;
}
public String getEngineName() {
return engineName;
}
public void setEngineName(String engineName) {
this.engineName = engineName;
}
public String getRemark() {
return remark;
}
public void setRemark(String remark) {
this.remark = remark;
}
public String getDataStatus() {
return dataStatus;
}
public void setDataStatus(String dataStatus) {
this.dataStatus = dataStatus;
}
public Integer getCreateUserId() {
return createUserId;
}
public void setCreateUserId(Integer createUserId) {
this.createUserId = createUserId;
}
public Date getCreateTime() {
return createTime;
}
public void setCreateTime(Date createTime) {
this.createTime = createTime;
}
public Integer getUpdateUserId() {
return updateUserId;
}
public void setUpdateUserId(Integer updateUserId) {
this.updateUserId = updateUserId;
}
public Date getUpdateTime() {
return updateTime;
}
public void setUpdateTime(Date updateTime) {
this.updateTime = updateTime;
}
}
package com.jz.dmp.modules.model;
import java.io.Serializable;
import com.fasterxml.jackson.annotation.JsonFormat;
import io.swagger.annotations.ApiModel;
import io.swagger.annotations.ApiModelProperty;
import java.util.Date;
/**计算引擎参数表
* @author ybz
*
*/
@ApiModel(value = "计算引擎参数表", description = "计算引擎参数表")
public class DmpComputEngineParam implements Serializable{
/**
*
*/
private static final long serialVersionUID = 1L;
/**
* 主键
*/
@ApiModelProperty(value = "主键")
private Integer paramId;
/**
* 引擎主键
*/
@ApiModelProperty(value = "引擎主键")
private Integer engineId;
/**
* 参数名称
*/
@ApiModelProperty(value = "参数名称")
private String paramName;
/**
* 类型(0:引擎公共参数,1:引擎私配置参数)
*/
@ApiModelProperty(value = "类型(0:引擎公共参数,1:引擎私配置参数)")
private String paramType;
/**
* 参数值
*/
@ApiModelProperty(value = "参数值")
private String paramValue;
/**
* 备注
*/
@ApiModelProperty(value = "备注")
private String remark;
/**
* 数据状态(0:删除,1,未删除)
*/
@ApiModelProperty(value = "数据状态(0:删除,1,未删除)")
private String dataStatus;
/**
* 创建用户ID
*/
@ApiModelProperty(value = "创建用户ID")
private Integer createUserId;
/**
* 创建时间
*/
@ApiModelProperty(value = "创建时间")
@JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss")
private Date createTime;
/**
* 修改用户ID
*/
@ApiModelProperty(value = "修改用户ID")
private Integer updateUserId;
/**
* 修改时间
*/
@ApiModelProperty(value = "修改时间")
@JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss")
private Date updateTime;
public Integer getParamId() {
return paramId;
}
public void setParamId(Integer paramId) {
this.paramId = paramId;
}
public Integer getEngineId() {
return engineId;
}
public void setEngineId(Integer engineId) {
this.engineId = engineId;
}
public String getParamName() {
return paramName;
}
public void setParamName(String paramName) {
this.paramName = paramName;
}
public String getParamType() {
return paramType;
}
public void setParamType(String paramType) {
this.paramType = paramType;
}
public String getParamValue() {
return paramValue;
}
public void setParamValue(String paramValue) {
this.paramValue = paramValue;
}
public String getRemark() {
return remark;
}
public void setRemark(String remark) {
this.remark = remark;
}
public String getDataStatus() {
return dataStatus;
}
public void setDataStatus(String dataStatus) {
this.dataStatus = dataStatus;
}
public Integer getCreateUserId() {
return createUserId;
}
public void setCreateUserId(Integer createUserId) {
this.createUserId = createUserId;
}
public Date getCreateTime() {
return createTime;
}
public void setCreateTime(Date createTime) {
this.createTime = createTime;
}
public Integer getUpdateUserId() {
return updateUserId;
}
public void setUpdateUserId(Integer updateUserId) {
this.updateUserId = updateUserId;
}
public Date getUpdateTime() {
return updateTime;
}
public void setUpdateTime(Date updateTime) {
this.updateTime = updateTime;
}
}
package com.jz.dmp.modules.model;
import com.fasterxml.jackson.annotation.JsonFormat;
import com.fasterxml.jackson.annotation.JsonProperty;
import io.swagger.annotations.ApiModel;
import io.swagger.annotations.ApiModelProperty;
import java.io.Serializable;
......@@ -12,97 +15,126 @@ import java.util.Date;
* @author Bellamy
* @since 2020-12-22 16:37:54
*/
@ApiModel(value = "任务开发实体类", description = "任务开发实体类")
public class DmpDevelopTask implements Serializable {
private static final long serialVersionUID = 492051123327188782L;
/**
* ID
*/
@ApiModelProperty(value = "ID")
private Integer id;
/**
* 数据源ID
*/
@ApiModelProperty(value = "数据源ID")
private Integer datasourceId;
/**
* 任务类型
* 任务类型(1,开发任务;2,离线任务)
*/
@ApiModelProperty(value = "任务类型(1,开发任务;2,离线任务)")
private String taskType;
/**
* 类型
*/
@ApiModelProperty(value = "类型")
private String type;
/**
* 调度类型
*/
@ApiModelProperty(value = "调度类型")
private String scheduleType;
/**
* 是否已提交
*/
@ApiModelProperty(value = "是否已提交")
private String isSubmit;
/**
* 描述
*/
@ApiModelProperty(value = "描述")
private String taskDesc;
/**
* 脚本
*/
@ApiModelProperty(value = "脚本")
private String script;
/**
* 数据状态
*/
@ApiModelProperty(value = "数据状态")
private String dataStatus;
/**
* 创建用户ID
*/
@ApiModelProperty(value = "创建用户ID")
private String createUserId;
/**
* 数据创建时间
*/
@ApiModelProperty(value = "数据创建时间")
@JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss")
private Date createTime;
/**
* 创建用户ID
*/
@ApiModelProperty(value = "创建用户ID")
private String updateUserId;
/**
* 数据更新时间
*/
@ApiModelProperty(value = "数据更新时间")
@JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss")
private Date updateTime;
/**
* tree ID
*/
@ApiModelProperty(value = "tree ID")
private Integer treeId;
/**
* 校验状态:SUCCEED 成功, FAIL 失败
*/
@ApiModelProperty(value = "校验状态:SUCCEED 成功, FAIL 失败")
private String chkResult;
/**
* 同步状态:SUCCEED 成功,FAIL 失败
*/
@ApiModelProperty(value = "同步状态:SUCCEED 成功,FAIL 失败")
private String syncResult;
/**
* 最终校验时间
*/
@ApiModelProperty(value = "最终校验时间")
@JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss")
private Date chkTime;
/**
* 最终同步时间
*/
@ApiModelProperty(value = "最终同步时间")
@JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss")
private Date syncTime;
@ApiModelProperty(value = "")
private String flowHeader;
@ApiModelProperty(value = "工作流json")
private Object flowJson;
@ApiModelProperty(value = "版本")
private String version;
@ApiModelProperty(value = "是否压缩")
private Integer isGziped;
/**
* 项目id
*/
@ApiModelProperty(value = "项目id")
private Integer projectId;
/*
* 父节点ID
* */
@ApiModelProperty(value = "父节点ID")
private Integer parentId;
@JsonProperty(access = JsonProperty.Access.WRITE_ONLY)
......@@ -137,6 +169,10 @@ public class DmpDevelopTask implements Serializable {
* */
@ApiModelProperty(value = "源数据库表")
private String sourceTableName;
//辅助字段
@ApiModelProperty(value = "任务名称")
private String name;
public Integer getId() {
......@@ -378,4 +414,13 @@ public class DmpDevelopTask implements Serializable {
public void setSourceDbName(String sourceDbName) {
this.sourceDbName = sourceDbName;
}
public String getName() {
return name;
}
public void setName(String name) {
this.name = name;
}
}
\ No newline at end of file
......@@ -7,7 +7,6 @@ import java.util.Collection;
import java.util.Date;
import java.util.List;
import org.springframework.format.annotation.DateTimeFormat;
import org.springframework.security.core.GrantedAuthority;
import org.springframework.security.core.userdetails.UserDetails;
......
package com.jz.dmp.modules.model;
import java.io.Serializable;
import java.text.SimpleDateFormat;
import java.util.Date;
public class DmpModuleOperateLog implements Serializable {
private static final long serialVersionUID = 1L;
private Integer moduleKey;
private Integer primaryKey;
private String operateLog;
private Date operateTime;
private Integer operateUserId;
private String operateUserName;
private String reserveField;
private String remark;
private String operateTimeStr;
//排序方式
private String order;
public Integer getModuleKey() {
return moduleKey;
}
public void setModuleKey(Integer moduleKey) {
this.moduleKey = moduleKey;
}
public Integer getPrimaryKey() {
return primaryKey;
}
public void setPrimaryKey(Integer primaryKey) {
this.primaryKey = primaryKey;
}
public String getOperateLog() {
return operateLog;
}
public void setOperateLog(String operateLog) {
this.operateLog = operateLog;
}
public Date getOperateTime() {
return operateTime;
}
public void setOperateTime(Date operateTime) {
this.operateTime = operateTime;
}
public Integer getOperateUserId() {
return operateUserId;
}
public void setOperateUserId(Integer operateUserId) {
this.operateUserId = operateUserId;
}
public String getOperateUserName() {
return operateUserName;
}
public void setOperateUserName(String operateUserName) {
this.operateUserName = operateUserName;
}
public String getReserveField() {
return reserveField;
}
public void setReserveField(String reserveField) {
this.reserveField = reserveField;
}
public String getRemark() {
return remark;
}
public void setRemark(String remark) {
this.remark = remark;
}
public String getOperateTimeStr() {
if (operateTime != null) {
SimpleDateFormat time = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
operateTimeStr = time.format(operateTime);
}
return operateTimeStr;
}
public void setOperateTimeStr(String operateTimeStr) {
this.operateTimeStr = operateTimeStr;
}
public String getOrder() {
return order;
}
public void setOrder(String order) {
this.order = order;
}
}
......@@ -6,6 +6,8 @@ import io.swagger.annotations.ApiModelProperty;
import java.io.Serializable;
import java.util.Date;
import com.fasterxml.jackson.annotation.JsonFormat;
/**
* DMP资源导航树(DmpNavigationTree)实体类
*
......@@ -21,14 +23,14 @@ public class DmpNavigationTree implements Serializable {
@ApiModelProperty(value = "ID")
private Integer id;
/**
* 树类别
* 树类别(2:开发任务,3:脚本任务)
*/
@ApiModelProperty(value = "树类别")
@ApiModelProperty(value = "树类别(2:开发任务,3:脚本任务)")
private String category;
/**
* 树类型
* 树类型(01:离线同步,02:实时同步,03:数据开发)
*/
@ApiModelProperty(value = "树类型")
@ApiModelProperty(value = "树类型(01:离线同步,02:实时同步,03:数据开发)")
private String type;
/**
* 名称
......@@ -64,6 +66,7 @@ public class DmpNavigationTree implements Serializable {
* 数据创建时间
*/
@ApiModelProperty(value = "数据创建时间")
@JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss")
private Date createTime;
/**
* 创建用户ID
......@@ -74,6 +77,7 @@ public class DmpNavigationTree implements Serializable {
* 数据更新时间
*/
@ApiModelProperty(value = "数据更新时间")
@JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss")
private Date updateTime;
/**
* 项目ID
......
package com.jz.dmp.modules.model;
import java.io.Serializable;
import com.fasterxml.jackson.annotation.JsonFormat;
import io.swagger.annotations.ApiModel;
import io.swagger.annotations.ApiModelProperty;
import java.util.Date;
/**项目配置计算引擎关系表
* @author ybz
*
*/
@ApiModel(value = "项目配置计算引擎关系表", description = "项目配置计算引擎关系表")
public class DmpProjectConfigEngine implements Serializable{
/**
*
*/
private static final long serialVersionUID = 1L;
/**
* 主键
*/
@ApiModelProperty(value = "主键")
private Integer configEngineId;
/**
* 项目主键
*/
@ApiModelProperty(value = "项目主键")
private Integer projectId;
/**
* 引擎主键
*/
@ApiModelProperty(value = "引擎主键")
private Integer engineId;
/**
* 备注
*/
@ApiModelProperty(value = "备注")
private String remark;
/**
* 数据状态(0:删除,1,未删除)
*/
@ApiModelProperty(value = "数据状态(0:删除,1,未删除)")
private String dataStatus;
/**
* 创建用户ID
*/
@ApiModelProperty(value = "创建用户ID")
private Integer createUserId;
/**
* 创建时间
*/
@ApiModelProperty(value = "创建时间")
@JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss")
private Date createTime;
/**
* 修改用户ID
*/
@ApiModelProperty(value = "修改用户ID")
private Integer updateUserId;
/**
* 修改时间
*/
@ApiModelProperty(value = "修改时间")
@JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss")
private Date updateTime;
public Integer getConfigEngineId() {
return configEngineId;
}
public void setConfigEngineId(Integer configEngineId) {
this.configEngineId = configEngineId;
}
public Integer getProjectId() {
return projectId;
}
public void setProjectId(Integer projectId) {
this.projectId = projectId;
}
public Integer getEngineId() {
return engineId;
}
public void setEngineId(Integer engineId) {
this.engineId = engineId;
}
public String getRemark() {
return remark;
}
public void setRemark(String remark) {
this.remark = remark;
}
public String getDataStatus() {
return dataStatus;
}
public void setDataStatus(String dataStatus) {
this.dataStatus = dataStatus;
}
public Integer getCreateUserId() {
return createUserId;
}
public void setCreateUserId(Integer createUserId) {
this.createUserId = createUserId;
}
public Date getCreateTime() {
return createTime;
}
public void setCreateTime(Date createTime) {
this.createTime = createTime;
}
public Integer getUpdateUserId() {
return updateUserId;
}
public void setUpdateUserId(Integer updateUserId) {
this.updateUserId = updateUserId;
}
public Date getUpdateTime() {
return updateTime;
}
public void setUpdateTime(Date updateTime) {
this.updateTime = updateTime;
}
}
package com.jz.dmp.modules.model;
import java.io.Serializable;
import com.fasterxml.jackson.annotation.JsonFormat;
import io.swagger.annotations.ApiModel;
import io.swagger.annotations.ApiModelProperty;
import java.util.Date;
/**项目配置表
* @author ybz
*
*/
@ApiModel(value = "项目配置表", description = "项目配置表")
public class DmpProjectConfigInfo implements Serializable{
/**
*
*/
private static final long serialVersionUID = 1L;
/**
* 主键
*/
@ApiModelProperty(value = "主键")
private Integer projectConfigId;
/**
* 项目主键
*/
@ApiModelProperty(value = "项目主键")
private Integer projectId;
/**
* 备注
*/
@ApiModelProperty(value = "备注")
private String remark;
/**
* 数据状态(0:删除,1,未删除)
*/
@ApiModelProperty(value = "数据状态(0:删除,1,未删除)")
private String dataStatus;
/**
* 创建用户ID
*/
@ApiModelProperty(value = "创建用户ID")
private Integer createUserId;
/**
* 创建时间
*/
@ApiModelProperty(value = "创建时间")
@JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss")
private Date createTime;
/**
* 修改用户ID
*/
@ApiModelProperty(value = "修改用户ID")
private Integer updateUserId;
/**
* 修改时间
*/
@ApiModelProperty(value = "修改时间")
@JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss")
private Date updateTime;
public Integer getProjectConfigId() {
return projectConfigId;
}
public void setProjectConfigId(Integer projectConfigId) {
this.projectConfigId = projectConfigId;
}
public Integer getProjectId() {
return projectId;
}
public void setProjectId(Integer projectId) {
this.projectId = projectId;
}
public String getRemark() {
return remark;
}
public void setRemark(String remark) {
this.remark = remark;
}
public String getDataStatus() {
return dataStatus;
}
public void setDataStatus(String dataStatus) {
this.dataStatus = dataStatus;
}
public Integer getCreateUserId() {
return createUserId;
}
public void setCreateUserId(Integer createUserId) {
this.createUserId = createUserId;
}
public Date getCreateTime() {
return createTime;
}
public void setCreateTime(Date createTime) {
this.createTime = createTime;
}
public Integer getUpdateUserId() {
return updateUserId;
}
public void setUpdateUserId(Integer updateUserId) {
this.updateUserId = updateUserId;
}
public Date getUpdateTime() {
return updateTime;
}
public void setUpdateTime(Date updateTime) {
this.updateTime = updateTime;
}
}
package com.jz.dmp.modules.model;
import java.io.Serializable;
import com.fasterxml.jackson.annotation.JsonFormat;
import io.swagger.annotations.ApiModel;
import io.swagger.annotations.ApiModelProperty;
import java.util.Date;
/**计算引擎项目参数表
* @author ybz
*
*/
@ApiModel(value = "计算引擎项目参数表", description = "计算引擎项目参数表")
public class DmpProjectEngineParam implements Serializable{
/**
*
*/
private static final long serialVersionUID = 1L;
/**
* 主键
*/
@ApiModelProperty(value = "主键")
private Integer projectParamId;
/**
* 项目配置引擎关系主键
*/
@ApiModelProperty(value = "项目配置引擎关系主键")
private Integer configEngineId;
/**
* 引擎参数主键
*/
@ApiModelProperty(value = "引擎参数主键")
private Integer paramId;
/**
* 参数名称
*/
@ApiModelProperty(value = "参数名称")
private String paramName;
/**
* 参数值
*/
@ApiModelProperty(value = "参数值")
private String paramValue;
/**
* 备注
*/
@ApiModelProperty(value = "备注")
private String remark;
/**
* 数据状态(0:删除,1,未删除)
*/
@ApiModelProperty(value = "数据状态(0:删除,1,未删除)")
private String dataStatus;
/**
* 创建用户ID
*/
@ApiModelProperty(value = "创建用户ID")
private Integer createUserId;
/**
* 创建时间
*/
@ApiModelProperty(value = "创建时间")
@JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss")
private Date createTime;
/**
* 修改用户ID
*/
@ApiModelProperty(value = "修改用户ID")
private Integer updateUserId;
/**
* 修改时间
*/
@ApiModelProperty(value = "修改时间")
@JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss")
private Date updateTime;
public Integer getProjectParamId() {
return projectParamId;
}
public void setProjectParamId(Integer projectParamId) {
this.projectParamId = projectParamId;
}
public Integer getConfigEngineId() {
return configEngineId;
}
public void setConfigEngineId(Integer configEngineId) {
this.configEngineId = configEngineId;
}
public Integer getParamId() {
return paramId;
}
public void setParamId(Integer paramId) {
this.paramId = paramId;
}
public String getParamName() {
return paramName;
}
public void setParamName(String paramName) {
this.paramName = paramName;
}
public String getParamValue() {
return paramValue;
}
public void setParamValue(String paramValue) {
this.paramValue = paramValue;
}
public String getRemark() {
return remark;
}
public void setRemark(String remark) {
this.remark = remark;
}
public String getDataStatus() {
return dataStatus;
}
public void setDataStatus(String dataStatus) {
this.dataStatus = dataStatus;
}
public Integer getCreateUserId() {
return createUserId;
}
public void setCreateUserId(Integer createUserId) {
this.createUserId = createUserId;
}
public Date getCreateTime() {
return createTime;
}
public void setCreateTime(Date createTime) {
this.createTime = createTime;
}
public Integer getUpdateUserId() {
return updateUserId;
}
public void setUpdateUserId(Integer updateUserId) {
this.updateUserId = updateUserId;
}
public Date getUpdateTime() {
return updateTime;
}
public void setUpdateTime(Date updateTime) {
this.updateTime = updateTime;
}
}
package com.jz.dmp.modules.model;
import java.io.Serializable;
import com.fasterxml.jackson.annotation.JsonFormat;
import io.swagger.annotations.ApiModel;
import io.swagger.annotations.ApiModelProperty;
import java.util.Date;
/**公共配置表
* @author ybz
*
*/
@ApiModel(value = "公共配置表", description = "公共配置表")
public class DmpPublicConfigInfo implements Serializable{