Skip to content

duckula-ops
duckula-ops

duckula / duckula-ops

通知 6
Star 1
Fork 0
duckula-ops
duckula-ops

前往新版Gitcode，体验更适合开发者的 AI 搜索 >>

提交 a9ef70be 编写于 作者: 偏锋书生's avatar 偏锋书生
浏览文件
操作

支持flink

上级 8e80a6d7
展开全部 隐藏空白更改
内联 并排
Showing with 1737 addition and 1269 deletion
src/main/java/net/wicp/tams/app/duckula/controller/bean/models/DevopsDoris.java
浏览文件 @ a9ef70be
......@@ -14,117 +14,67 @@ import net.wicp.tams.common.constant.dic.YesOrNo;
*/
@TamsBean(title = "doris运维配置")
public class DevopsDoris {
/**
*
* This field was generated by MyBatis Generator. This field corresponds to the
* database column devops_doris.id
*
* This field was generated by MyBatis Generator. This field corresponds to the database column devops_doris.id
* @mbg.generated
*/
private Long id;
/**
* Database Column Remarks: 客户名
*
* This field was generated by MyBatis Generator. This field corresponds to the
* database column devops_doris.name
*
* Database Column Remarks: 客户名 This field was generated by MyBatis Generator. This field corresponds to the database column devops_doris.name
* @mbg.generated
*/
@TamsCol(value = "租户名", save = 1, query = 1, showWidth = 100)
private String name;
/**
* Database Column Remarks: ip1地址
*
* This field was generated by MyBatis Generator. This field corresponds to the
* database column devops_doris.ip
*
* Database Column Remarks: ip1地址 This field was generated by MyBatis Generator. This field corresponds to the database column devops_doris.ip
* @mbg.generated
*/
@TamsCol(value = "IP地址", save = 1, query = 1, showWidth = 150)
private String ip;
/**
* Database Column Remarks: 集群
*
* This field was generated by MyBatis Generator. This field corresponds to the
* database column devops_doris.cluster
*
* Database Column Remarks: 集群 This field was generated by MyBatis Generator. This field corresponds to the database column devops_doris.cluster
* @mbg.generated
*/
@TamsCol(value = "集群", save = 1, query = 0, showWidth = 150)
private String cluster;
/**
* Database Column Remarks: 服务器的角色
*
* This field was generated by MyBatis Generator. This field corresponds to the
* database column devops_doris.roles
*
* Database Column Remarks: 服务器的角色 This field was generated by MyBatis Generator. This field corresponds to the database column devops_doris.roles
* @mbg.generated
*/
@TamsCol(value = "角色", save = 1, query = -1, showWidth = 150, multiple = true, enumClass = DorisRole.class)
private String roles;
/**
* Database Column Remarks: 存储磁盘
*
* This field was generated by MyBatis Generator. This field corresponds to the
* database column devops_doris.fs
*
* Database Column Remarks: 存储磁盘 This field was generated by MyBatis Generator. This field corresponds to the database column devops_doris.fs
* @mbg.generated
*/
// ,comboxurl = "/devops/dorisconfig:listFs"不好实现
@TamsCol(value = "存储磁盘", save = 1, query = -1, showWidth = 150)
private String fs;
/**
* Database Column Remarks: root密码
*
* This field was generated by MyBatis Generator. This field corresponds to the
* database column devops_doris.root_pwd
*
* Database Column Remarks: root密码 This field was generated by MyBatis Generator. This field corresponds to the database column devops_doris.root_pwd
* @mbg.generated
*/
@TamsCol(value = "root密码", save = 1, query = -1)
private String rootPwd;
/**
* Database Column Remarks: 是否初始化，yes:已初始化 no:未初始化 创建duckula用户，创建环境变量创建目录
*
* This field was generated by MyBatis Generator. This field corresponds to the
* database column devops_doris.is_init
*
* Database Column Remarks: 是否初始化，yes:已初始化 no:未初始化 创建duckula用户，创建环境变量创建目录 This field was generated by MyBatis Generator. This field corresponds to the database column devops_doris.is_init
* @mbg.generated
*/
@TamsCol(value = "初始化", save = 1, query = 0, enumClass = YesOrNo.class, showWidth = 100)
private String isInit;
/**
* Database Column Remarks: 创建时间
*
* This field was generated by MyBatis Generator. This field corresponds to the
* database column devops_doris.create_time
*
* Database Column Remarks: 创建时间 This field was generated by MyBatis Generator. This field corresponds to the database column devops_doris.create_time
* @mbg.generated
*/
private Date createTime;
/**
* Database Column Remarks: 创建时间
*
* This field was generated by MyBatis Generator. This field corresponds to the
* database column devops_doris.update_time
*
* Database Column Remarks: 创建时间 This field was generated by MyBatis Generator. This field corresponds to the database column devops_doris.update_time
* @mbg.generated
*/
private Date updateTime;
/**
* This method was generated by MyBatis Generator. This method corresponds to
* the database table devops_doris
*
* This method was generated by MyBatis Generator. This method corresponds to the database table devops_doris
* @mbg.generated
*/
public DevopsDoris(Long id, String name, String ip, String cluster, String roles, String fs, String rootPwd,
......@@ -142,9 +92,7 @@ public class DevopsDoris {
}
/**
* This method was generated by MyBatis Generator. This method corresponds to
* the database table devops_doris
*
* This method was generated by MyBatis Generator. This method corresponds to the database table devops_doris
* @mbg.generated
*/
public DevopsDoris() {
......@@ -152,11 +100,8 @@ public class DevopsDoris {
}
/**
* This method was generated by MyBatis Generator. This method returns the value
* of the database column devops_doris.id
*
* @return the value of devops_doris.id
*
* This method was generated by MyBatis Generator. This method returns the value of the database column devops_doris.id
* @return the value of devops_doris.id
* @mbg.generated
*/
public Long getId() {
......@@ -164,11 +109,8 @@ public class DevopsDoris {
}
/**
* This method was generated by MyBatis Generator. This method sets the value of
* the database column devops_doris.id
*
* @param id the value for devops_doris.id
*
* This method was generated by MyBatis Generator. This method sets the value of the database column devops_doris.id
* @param id the value for devops_doris.id
* @mbg.generated
*/
public void setId(Long id) {
......@@ -176,11 +118,8 @@ public class DevopsDoris {
}
/**
* This method was generated by MyBatis Generator. This method returns the value
* of the database column devops_doris.name
*
* @return the value of devops_doris.name
*
* This method was generated by MyBatis Generator. This method returns the value of the database column devops_doris.name
* @return the value of devops_doris.name
* @mbg.generated
*/
public String getName() {
......@@ -188,11 +127,8 @@ public class DevopsDoris {
}
/**
* This method was generated by MyBatis Generator. This method sets the value of
* the database column devops_doris.name
*
* @param name the value for devops_doris.name
*
* This method was generated by MyBatis Generator. This method sets the value of the database column devops_doris.name
* @param name the value for devops_doris.name
* @mbg.generated
*/
public void setName(String name) {
......@@ -200,11 +136,8 @@ public class DevopsDoris {
}
/**
* This method was generated by MyBatis Generator. This method returns the value
* of the database column devops_doris.ip
*
* @return the value of devops_doris.ip
*
* This method was generated by MyBatis Generator. This method returns the value of the database column devops_doris.ip
* @return the value of devops_doris.ip
* @mbg.generated
*/
public String getIp() {
......@@ -212,11 +145,8 @@ public class DevopsDoris {
}
/**
* This method was generated by MyBatis Generator. This method sets the value of
* the database column devops_doris.ip
*
* @param ip the value for devops_doris.ip
*
* This method was generated by MyBatis Generator. This method sets the value of the database column devops_doris.ip
* @param ip the value for devops_doris.ip
* @mbg.generated
*/
public void setIp(String ip) {
......@@ -224,11 +154,8 @@ public class DevopsDoris {
}
/**
* This method was generated by MyBatis Generator. This method returns the value
* of the database column devops_doris.cluster
*
* @return the value of devops_doris.cluster
*
* This method was generated by MyBatis Generator. This method returns the value of the database column devops_doris.cluster
* @return the value of devops_doris.cluster
* @mbg.generated
*/
public String getCluster() {
......@@ -236,11 +163,8 @@ public class DevopsDoris {
}
/**
* This method was generated by MyBatis Generator. This method sets the value of
* the database column devops_doris.cluster
*
* @param cluster the value for devops_doris.cluster
*
* This method was generated by MyBatis Generator. This method sets the value of the database column devops_doris.cluster
* @param cluster the value for devops_doris.cluster
* @mbg.generated
*/
public void setCluster(String cluster) {
......@@ -248,11 +172,8 @@ public class DevopsDoris {
}
/**
* This method was generated by MyBatis Generator. This method returns the value
* of the database column devops_doris.roles
*
* @return the value of devops_doris.roles
*
* This method was generated by MyBatis Generator. This method returns the value of the database column devops_doris.roles
* @return the value of devops_doris.roles
* @mbg.generated
*/
public String getRoles() {
......@@ -260,11 +181,8 @@ public class DevopsDoris {
}
/**
* This method was generated by MyBatis Generator. This method sets the value of
* the database column devops_doris.roles
*
* @param roles the value for devops_doris.roles
*
* This method was generated by MyBatis Generator. This method sets the value of the database column devops_doris.roles
* @param roles the value for devops_doris.roles
* @mbg.generated
*/
public void setRoles(String roles) {
......@@ -272,11 +190,8 @@ public class DevopsDoris {
}
/**
* This method was generated by MyBatis Generator. This method returns the value
* of the database column devops_doris.fs
*
* @return the value of devops_doris.fs
*
* This method was generated by MyBatis Generator. This method returns the value of the database column devops_doris.fs
* @return the value of devops_doris.fs
* @mbg.generated
*/
public String getFs() {
......@@ -284,11 +199,8 @@ public class DevopsDoris {
}
/**
* This method was generated by MyBatis Generator. This method sets the value of
* the database column devops_doris.fs
*
* @param fs the value for devops_doris.fs
*
* This method was generated by MyBatis Generator. This method sets the value of the database column devops_doris.fs
* @param fs the value for devops_doris.fs
* @mbg.generated
*/
public void setFs(String fs) {
......@@ -296,11 +208,8 @@ public class DevopsDoris {
}
/**
* This method was generated by MyBatis Generator. This method returns the value
* of the database column devops_doris.root_pwd
*
* @return the value of devops_doris.root_pwd
*
* This method was generated by MyBatis Generator. This method returns the value of the database column devops_doris.root_pwd
* @return the value of devops_doris.root_pwd
* @mbg.generated
*/
public String getRootPwd() {
......@@ -308,11 +217,8 @@ public class DevopsDoris {
}
/**
* This method was generated by MyBatis Generator. This method sets the value of
* the database column devops_doris.root_pwd
*
* @param rootPwd the value for devops_doris.root_pwd
*
* This method was generated by MyBatis Generator. This method sets the value of the database column devops_doris.root_pwd
* @param rootPwd the value for devops_doris.root_pwd
* @mbg.generated
*/
public void setRootPwd(String rootPwd) {
......@@ -320,11 +226,8 @@ public class DevopsDoris {
}
/**
* This method was generated by MyBatis Generator. This method returns the value
* of the database column devops_doris.is_init
*
* @return the value of devops_doris.is_init
*
* This method was generated by MyBatis Generator. This method returns the value of the database column devops_doris.is_init
* @return the value of devops_doris.is_init
* @mbg.generated
*/
public String getIsInit() {
......@@ -332,11 +235,8 @@ public class DevopsDoris {
}
/**
* This method was generated by MyBatis Generator. This method sets the value of
* the database column devops_doris.is_init
*
* @param isInit the value for devops_doris.is_init
*
* This method was generated by MyBatis Generator. This method sets the value of the database column devops_doris.is_init
* @param isInit the value for devops_doris.is_init
* @mbg.generated
*/
public void setIsInit(String isInit) {
......@@ -344,11 +244,8 @@ public class DevopsDoris {
}
/**
* This method was generated by MyBatis Generator. This method returns the value
* of the database column devops_doris.create_time
*
* @return the value of devops_doris.create_time
*
* This method was generated by MyBatis Generator. This method returns the value of the database column devops_doris.create_time
* @return the value of devops_doris.create_time
* @mbg.generated
*/
public Date getCreateTime() {
......@@ -356,11 +253,8 @@ public class DevopsDoris {
}
/**
* This method was generated by MyBatis Generator. This method sets the value of
* the database column devops_doris.create_time
*
* @param createTime the value for devops_doris.create_time
*
* This method was generated by MyBatis Generator. This method sets the value of the database column devops_doris.create_time
* @param createTime the value for devops_doris.create_time
* @mbg.generated
*/
public void setCreateTime(Date createTime) {
......@@ -368,11 +262,8 @@ public class DevopsDoris {
}
/**
* This method was generated by MyBatis Generator. This method returns the value
* of the database column devops_doris.update_time
*
* @return the value of devops_doris.update_time
*
* This method was generated by MyBatis Generator. This method returns the value of the database column devops_doris.update_time
* @return the value of devops_doris.update_time
* @mbg.generated
*/
public Date getUpdateTime() {
......@@ -380,11 +271,8 @@ public class DevopsDoris {
}
/**
* This method was generated by MyBatis Generator. This method sets the value of
* the database column devops_doris.update_time
*
* @param updateTime the value for devops_doris.update_time
*
* This method was generated by MyBatis Generator. This method sets the value of the database column devops_doris.update_time
* @param updateTime the value for devops_doris.update_time
* @mbg.generated
*/
public void setUpdateTime(Date updateTime) {
......
src/main/java/net/wicp/tams/app/duckula/controller/bean/models/DevopsFlink.java
浏览文件 @ a9ef70be
......@@ -23,26 +23,56 @@ public class DevopsFlink {
* Database Column Remarks: 客户名 This field was generated by MyBatis Generator. This field corresponds to the database column devops_flink.name
* @mbg.generated
*/
@TamsCol(value = "租户名", save = 1, query = 1, showWidth = 100)
@TamsCol(value = "租户名", save = 1, query = 1, showWidth = 100, orderby = 1)
private String name;
/**
* Database Column Remarks: 集群 This field was generated by MyBatis Generator. This field corresponds to the database column devops_flink.cluster
* @mbg.generated
*/
@TamsCol(value = "集群名", save = 1, query = 1, showWidth = 100, orderby = 2)
private String cluster;
/**
* Database Column Remarks: ip1地址 This field was generated by MyBatis Generator. This field corresponds to the database column devops_flink.ip
* @mbg.generated
*/
@TamsCol(value = "IP地址", save = 1, query = 1, showWidth = 150)
@TamsCol(value = "IP地址", save = 1, query = 1, showWidth = 150, orderby = 3)
private String ip;
/**
* Database Column Remarks: 主机名，系统生成 This field was generated by MyBatis Generator. This field corresponds to the database column devops_flink.hostname
* @mbg.generated
*/
@TamsCol(value = "主机名", save = -1, query = -1, showWidth = 150)
private String hostname;
/**
* Database Column Remarks: root用户名 This field was generated by MyBatis Generator. This field corresponds to the database column devops_flink.root_user
* @mbg.generated
*/
@TamsCol(value = "root用户", save = 1, query = -1, orderby = 5)
private String rootUser;
/**
* Database Column Remarks: root密码 This field was generated by MyBatis Generator. This field corresponds to the database column devops_flink.root_pwd
* @mbg.generated
*/
@TamsCol(value = "root密码", save = 1, query = -1)
@TamsCol(value = "root密码", save = 1, query = -1, orderby = 6)
private String rootPwd;
/**
* Database Column Remarks: 是否需要做免密 This field was generated by MyBatis Generator. This field corresponds to the database column devops_flink.need_free
* @mbg.generated
*/
@TamsCol(value = "需要免密", save = 1, query = 0, enumClass = YesOrNo.class, showWidth = 100, orderby = 4)
private String needFree;
/**
* Database Column Remarks: 是否初始化，yes:已初始化 no:未初始化 创建duckula用户，创建环境变量创建目录 This field was generated by MyBatis Generator. This field corresponds to the database column devops_flink.is_init
* @mbg.generated
*/
@TamsCol(value = "初始化", save = 1, query = 0, enumClass = YesOrNo.class, showWidth = 100)
@TamsCol(value = "初始化", save = -1, query = 0, enumClass = YesOrNo.class, showWidth = 100, orderby = 7)
private String isInit;
/**
* Database Column Remarks: 是否免密 This field was generated by MyBatis Generator. This field corresponds to the database column devops_flink.is_free
* @mbg.generated
*/
@TamsCol(value = "免密", save = -1, query = 0, enumClass = YesOrNo.class, showWidth = 100, orderby = 8)
private String isFree;
/**
* Database Column Remarks: 创建时间 This field was generated by MyBatis Generator. This field corresponds to the database column devops_flink.create_time
* @mbg.generated
......@@ -58,13 +88,18 @@ public class DevopsFlink {
* This method was generated by MyBatis Generator. This method corresponds to the database table devops_flink
* @mbg.generated
*/
public DevopsFlink(Long id, String name, String ip, String rootPwd, String isInit, Date createTime,
Date updateTime) {
public DevopsFlink(Long id, String name, String cluster, String ip, String hostname, String rootUser,
String rootPwd, String needFree, String isInit, String isFree, Date createTime, Date updateTime) {
this.id = id;
this.name = name;
this.cluster = cluster;
this.ip = ip;
this.hostname = hostname;
this.rootUser = rootUser;
this.rootPwd = rootPwd;
this.needFree = needFree;
this.isInit = isInit;
this.isFree = isFree;
this.createTime = createTime;
this.updateTime = updateTime;
}
......@@ -113,6 +148,24 @@ public class DevopsFlink {
this.name = name;
}
/**
* This method was generated by MyBatis Generator. This method returns the value of the database column devops_flink.cluster
* @return the value of devops_flink.cluster
* @mbg.generated
*/
public String getCluster() {
return cluster;
}
/**
* This method was generated by MyBatis Generator. This method sets the value of the database column devops_flink.cluster
* @param cluster the value for devops_flink.cluster
* @mbg.generated
*/
public void setCluster(String cluster) {
this.cluster = cluster;
}
/**
* This method was generated by MyBatis Generator. This method returns the value of the database column devops_flink.ip
* @return the value of devops_flink.ip
......@@ -131,6 +184,42 @@ public class DevopsFlink {
this.ip = ip;
}
/**
* This method was generated by MyBatis Generator. This method returns the value of the database column devops_flink.hostname
* @return the value of devops_flink.hostname
* @mbg.generated
*/
public String getHostname() {
return hostname;
}
/**
* This method was generated by MyBatis Generator. This method sets the value of the database column devops_flink.hostname
* @param hostname the value for devops_flink.hostname
* @mbg.generated
*/
public void setHostname(String hostname) {
this.hostname = hostname;
}
/**
* This method was generated by MyBatis Generator. This method returns the value of the database column devops_flink.root_user
* @return the value of devops_flink.root_user
* @mbg.generated
*/
public String getRootUser() {
return rootUser;
}
/**
* This method was generated by MyBatis Generator. This method sets the value of the database column devops_flink.root_user
* @param rootUser the value for devops_flink.root_user
* @mbg.generated
*/
public void setRootUser(String rootUser) {
this.rootUser = rootUser;
}
/**
* This method was generated by MyBatis Generator. This method returns the value of the database column devops_flink.root_pwd
* @return the value of devops_flink.root_pwd
......@@ -149,6 +238,24 @@ public class DevopsFlink {
this.rootPwd = rootPwd;
}
/**
* This method was generated by MyBatis Generator. This method returns the value of the database column devops_flink.need_free
* @return the value of devops_flink.need_free
* @mbg.generated
*/
public String getNeedFree() {
return needFree;
}
/**
* This method was generated by MyBatis Generator. This method sets the value of the database column devops_flink.need_free
* @param needFree the value for devops_flink.need_free
* @mbg.generated
*/
public void setNeedFree(String needFree) {
this.needFree = needFree;
}
/**
* This method was generated by MyBatis Generator. This method returns the value of the database column devops_flink.is_init
* @return the value of devops_flink.is_init
......@@ -167,6 +274,24 @@ public class DevopsFlink {
this.isInit = isInit;
}
/**
* This method was generated by MyBatis Generator. This method returns the value of the database column devops_flink.is_free
* @return the value of devops_flink.is_free
* @mbg.generated
*/
public String getIsFree() {
return isFree;
}
/**
* This method was generated by MyBatis Generator. This method sets the value of the database column devops_flink.is_free
* @param isFree the value for devops_flink.is_free
* @mbg.generated
*/
public void setIsFree(String isFree) {
this.isFree = isFree;
}
/**
* This method was generated by MyBatis Generator. This method returns the value of the database column devops_flink.create_time
* @return the value of devops_flink.create_time
......
src/main/java/net/wicp/tams/app/duckula/controller/bean/models/DevopsFlinkExample.java
浏览文件 @ a9ef70be
......@@ -293,6 +293,76 @@ public class DevopsFlinkExample {
return (Criteria) this;
}
public Criteria andClusterIsNull() {
addCriterion("cluster is null");
return (Criteria) this;
}
public Criteria andClusterIsNotNull() {
addCriterion("cluster is not null");
return (Criteria) this;
}
public Criteria andClusterEqualTo(String value) {
addCriterion("cluster =", value, "cluster");
return (Criteria) this;
}
public Criteria andClusterNotEqualTo(String value) {
addCriterion("cluster <>", value, "cluster");
return (Criteria) this;
}
public Criteria andClusterGreaterThan(String value) {
addCriterion("cluster >", value, "cluster");
return (Criteria) this;
}
public Criteria andClusterGreaterThanOrEqualTo(String value) {
addCriterion("cluster >=", value, "cluster");
return (Criteria) this;
}
public Criteria andClusterLessThan(String value) {
addCriterion("cluster <", value, "cluster");
return (Criteria) this;
}
public Criteria andClusterLessThanOrEqualTo(String value) {
addCriterion("cluster <=", value, "cluster");
return (Criteria) this;
}
public Criteria andClusterLike(String value) {
addCriterion("cluster like", value, "cluster");
return (Criteria) this;
}
public Criteria andClusterNotLike(String value) {
addCriterion("cluster not like", value, "cluster");
return (Criteria) this;
}
public Criteria andClusterIn(List<String> values) {
addCriterion("cluster in", values, "cluster");
return (Criteria) this;
}
public Criteria andClusterNotIn(List<String> values) {
addCriterion("cluster not in", values, "cluster");
return (Criteria) this;
}
public Criteria andClusterBetween(String value1, String value2) {
addCriterion("cluster between", value1, value2, "cluster");
return (Criteria) this;
}
public Criteria andClusterNotBetween(String value1, String value2) {
addCriterion("cluster not between", value1, value2, "cluster");
return (Criteria) this;
}
public Criteria andIpIsNull() {
addCriterion("ip is null");
return (Criteria) this;
......@@ -363,6 +433,146 @@ public class DevopsFlinkExample {
return (Criteria) this;
}
public Criteria andHostnameIsNull() {
addCriterion("hostname is null");
return (Criteria) this;
}
public Criteria andHostnameIsNotNull() {
addCriterion("hostname is not null");
return (Criteria) this;
}
public Criteria andHostnameEqualTo(String value) {
addCriterion("hostname =", value, "hostname");
return (Criteria) this;
}
public Criteria andHostnameNotEqualTo(String value) {
addCriterion("hostname <>", value, "hostname");
return (Criteria) this;
}
public Criteria andHostnameGreaterThan(String value) {
addCriterion("hostname >", value, "hostname");
return (Criteria) this;
}
public Criteria andHostnameGreaterThanOrEqualTo(String value) {
addCriterion("hostname >=", value, "hostname");
return (Criteria) this;
}
public Criteria andHostnameLessThan(String value) {
addCriterion("hostname <", value, "hostname");
return (Criteria) this;
}
public Criteria andHostnameLessThanOrEqualTo(String value) {
addCriterion("hostname <=", value, "hostname");
return (Criteria) this;
}
public Criteria andHostnameLike(String value) {
addCriterion("hostname like", value, "hostname");
return (Criteria) this;
}
public Criteria andHostnameNotLike(String value) {
addCriterion("hostname not like", value, "hostname");
return (Criteria) this;
}
public Criteria andHostnameIn(List<String> values) {
addCriterion("hostname in", values, "hostname");
return (Criteria) this;
}
public Criteria andHostnameNotIn(List<String> values) {
addCriterion("hostname not in", values, "hostname");
return (Criteria) this;
}
public Criteria andHostnameBetween(String value1, String value2) {
addCriterion("hostname between", value1, value2, "hostname");
return (Criteria) this;
}
public Criteria andHostnameNotBetween(String value1, String value2) {
addCriterion("hostname not between", value1, value2, "hostname");
return (Criteria) this;
}
public Criteria andRootUserIsNull() {
addCriterion("root_user is null");
return (Criteria) this;
}
public Criteria andRootUserIsNotNull() {
addCriterion("root_user is not null");
return (Criteria) this;
}
public Criteria andRootUserEqualTo(String value) {
addCriterion("root_user =", value, "rootUser");
return (Criteria) this;
}
public Criteria andRootUserNotEqualTo(String value) {
addCriterion("root_user <>", value, "rootUser");
return (Criteria) this;
}
public Criteria andRootUserGreaterThan(String value) {
addCriterion("root_user >", value, "rootUser");
return (Criteria) this;
}
public Criteria andRootUserGreaterThanOrEqualTo(String value) {
addCriterion("root_user >=", value, "rootUser");
return (Criteria) this;
}
public Criteria andRootUserLessThan(String value) {
addCriterion("root_user <", value, "rootUser");
return (Criteria) this;
}
public Criteria andRootUserLessThanOrEqualTo(String value) {
addCriterion("root_user <=", value, "rootUser");
return (Criteria) this;
}
public Criteria andRootUserLike(String value) {
addCriterion("root_user like", value, "rootUser");
return (Criteria) this;
}
public Criteria andRootUserNotLike(String value) {
addCriterion("root_user not like", value, "rootUser");
return (Criteria) this;
}
public Criteria andRootUserIn(List<String> values) {
addCriterion("root_user in", values, "rootUser");
return (Criteria) this;
}
public Criteria andRootUserNotIn(List<String> values) {
addCriterion("root_user not in", values, "rootUser");
return (Criteria) this;
}
public Criteria andRootUserBetween(String value1, String value2) {
addCriterion("root_user between", value1, value2, "rootUser");
return (Criteria) this;
}
public Criteria andRootUserNotBetween(String value1, String value2) {
addCriterion("root_user not between", value1, value2, "rootUser");
return (Criteria) this;
}
public Criteria andRootPwdIsNull() {
addCriterion("root_pwd is null");
return (Criteria) this;
......@@ -433,6 +643,76 @@ public class DevopsFlinkExample {
return (Criteria) this;
}
public Criteria andNeedFreeIsNull() {
addCriterion("need_free is null");
return (Criteria) this;
}
public Criteria andNeedFreeIsNotNull() {
addCriterion("need_free is not null");
return (Criteria) this;
}
public Criteria andNeedFreeEqualTo(String value) {
addCriterion("need_free =", value, "needFree");
return (Criteria) this;
}
public Criteria andNeedFreeNotEqualTo(String value) {
addCriterion("need_free <>", value, "needFree");
return (Criteria) this;
}
public Criteria andNeedFreeGreaterThan(String value) {
addCriterion("need_free >", value, "needFree");
return (Criteria) this;
}
public Criteria andNeedFreeGreaterThanOrEqualTo(String value) {
addCriterion("need_free >=", value, "needFree");
return (Criteria) this;
}
public Criteria andNeedFreeLessThan(String value) {
addCriterion("need_free <", value, "needFree");
return (Criteria) this;
}
public Criteria andNeedFreeLessThanOrEqualTo(String value) {
addCriterion("need_free <=", value, "needFree");
return (Criteria) this;
}
public Criteria andNeedFreeLike(String value) {
addCriterion("need_free like", value, "needFree");
return (Criteria) this;
}
public Criteria andNeedFreeNotLike(String value) {
addCriterion("need_free not like", value, "needFree");
return (Criteria) this;
}
public Criteria andNeedFreeIn(List<String> values) {
addCriterion("need_free in", values, "needFree");
return (Criteria) this;
}
public Criteria andNeedFreeNotIn(List<String> values) {
addCriterion("need_free not in", values, "needFree");
return (Criteria) this;
}
public Criteria andNeedFreeBetween(String value1, String value2) {
addCriterion("need_free between", value1, value2, "needFree");
return (Criteria) this;
}
public Criteria andNeedFreeNotBetween(String value1, String value2) {
addCriterion("need_free not between", value1, value2, "needFree");
return (Criteria) this;
}
public Criteria andIsInitIsNull() {
addCriterion("is_init is null");
return (Criteria) this;
......@@ -503,6 +783,76 @@ public class DevopsFlinkExample {
return (Criteria) this;
}
public Criteria andIsFreeIsNull() {
addCriterion("is_free is null");
return (Criteria) this;
}
public Criteria andIsFreeIsNotNull() {
addCriterion("is_free is not null");
return (Criteria) this;
}
public Criteria andIsFreeEqualTo(String value) {
addCriterion("is_free =", value, "isFree");
return (Criteria) this;
}
public Criteria andIsFreeNotEqualTo(String value) {
addCriterion("is_free <>", value, "isFree");
return (Criteria) this;
}
public Criteria andIsFreeGreaterThan(String value) {
addCriterion("is_free >", value, "isFree");
return (Criteria) this;
}
public Criteria andIsFreeGreaterThanOrEqualTo(String value) {
addCriterion("is_free >=", value, "isFree");
return (Criteria) this;
}
public Criteria andIsFreeLessThan(String value) {
addCriterion("is_free <", value, "isFree");
return (Criteria) this;
}
public Criteria andIsFreeLessThanOrEqualTo(String value) {
addCriterion("is_free <=", value, "isFree");
return (Criteria) this;
}
public Criteria andIsFreeLike(String value) {
addCriterion("is_free like", value, "isFree");
return (Criteria) this;
}
public Criteria andIsFreeNotLike(String value) {
addCriterion("is_free not like", value, "isFree");
return (Criteria) this;
}
public Criteria andIsFreeIn(List<String> values) {
addCriterion("is_free in", values, "isFree");
return (Criteria) this;
}
public Criteria andIsFreeNotIn(List<String> values) {
addCriterion("is_free not in", values, "isFree");
return (Criteria) this;
}
public Criteria andIsFreeBetween(String value1, String value2) {
addCriterion("is_free between", value1, value2, "isFree");
return (Criteria) this;
}
public Criteria andIsFreeNotBetween(String value1, String value2) {
addCriterion("is_free not between", value1, value2, "isFree");
return (Criteria) this;
}
public Criteria andCreateTimeIsNull() {
addCriterion("create_time is null");
return (Criteria) this;
......
src/main/java/net/wicp/tams/app/duckula/controller/config/constant/DevOpsType.java
浏览文件 @ a9ef70be
......@@ -10,16 +10,44 @@ import net.wicp.tams.common.constant.dic.intf.IEnumCombobox;
*/
public enum DevOpsType implements IEnumCombobox {
flink("flink流计算", "oss://lc-bigdata/doris/check_system.sh", "oss://lc-bigdata/doris/%s/check_system.sh", "v12"),
flink("flink流计算", "oss://lc-bigdata/flink", "oss://lc-bigdata/flink/init/frontcheck.sh",
"oss://lc-bigdata/doris/%s/check_system.sh", "v12", "oss://lc-bigdata/flink/init.tar",
new String[] { "oss://lc-bigdata/flink/init/frontcheck.sh" }),
doris("大数据存储", "oss://lc-bigdata/doris/check_system.sh", "", ""),
doris("大数据存储", "oss://lc-bigdata/doris", "oss://lc-bigdata/doris/check_system.sh", "", "",
"oss://lc-bigdata/doris/check_system.sh", new String[] {}),
dmep("dmep数据平台", "", "", "");
dmep("dmep数据平台", "oss://lc-bigdata/dmep", "", "", "", "oss://lc-bigdata/doris/check_system.sh", new String[] {});
private final String desc;
private final String checkurl;
private final String baseurl;// 根路径，要跟据它来截取相对路径
private final String installurlFormat;
private final String lastversion;
private final String[] otherparams;// 其它文件 ，如flink需要在check后要做免密
private final String checkDownFile;//OSS要下载的文件
public String getCheckDownFile() {
return checkDownFile;
}
public String getRelaPath(String url) {
return url.replace(this.baseurl, "");
}
public String getRelaPathCheck() {
return getRelaPath(this.checkurl);
}
public String getRelaPathCheckDir() {
String fileName = this.checkurl.substring(this.checkurl.lastIndexOf("/") + 1);
String replace = getRelaPathCheck().replace(fileName, "");
return replace;
}
public String[] getOtherparams() {
return otherparams;
}
public String getCheckurl() {
return checkurl;
......@@ -33,11 +61,15 @@ public enum DevOpsType implements IEnumCombobox {
return String.format(this.installurlFormat, lastversion);
}
private DevOpsType(String desc, String checkurl, String installurlFormat, String lastversion) {
private DevOpsType(String desc, String baseurl, String checkurl, String installurlFormat, String lastversion,
String checkDownFile, String[] otherparams) {
this.desc = desc;
this.baseurl = baseurl;
this.checkurl = checkurl;
this.installurlFormat = installurlFormat;
this.lastversion = lastversion;
this.checkDownFile = checkDownFile;
this.otherparams = otherparams;
}
public String getDesc() {
......
src/main/java/net/wicp/tams/app/duckula/controller/dao/DevopsDorisMapper.java
浏览文件 @ a9ef70be
......@@ -15,125 +15,84 @@ import net.wicp.tams.app.duckula.controller.bean.models.DevopsDoris;
import net.wicp.tams.app.duckula.controller.bean.models.DevopsDorisExample;
public interface DevopsDorisMapper extends BaseMapper<DevopsDoris> {
/**
* This method was generated by MyBatis Generator.
* This method corresponds to the database table devops_doris
*
* @mbg.generated
*/
long countByExample(DevopsDorisExample example);
/**
* This method was generated by MyBatis Generator.
* This method corresponds to the database table devops_doris
*
* @mbg.generated
*/
int deleteByExample(DevopsDorisExample example);
/**
* This method was generated by MyBatis Generator.
* This method corresponds to the database table devops_doris
*
* @mbg.generated
*/
@Delete({
"delete from devops_doris",
"where id = #{id,jdbcType=BIGINT}"
})
int deleteByPrimaryKey(Long id);
/**
* This method was generated by MyBatis Generator.
* This method corresponds to the database table devops_doris
*
* @mbg.generated
*/
@Insert({
"insert into devops_doris (id, name, ",
"ip, cluster, roles, ",
"fs, root_pwd, is_init, ",
"create_time, update_time)",
"values (#{id,jdbcType=BIGINT}, #{name,jdbcType=VARCHAR}, ",
"#{ip,jdbcType=VARCHAR}, #{cluster,jdbcType=VARCHAR}, #{roles,jdbcType=VARCHAR}, ",
"#{fs,jdbcType=VARCHAR}, #{rootPwd,jdbcType=VARCHAR}, #{isInit,jdbcType=VARCHAR}, ",
"#{createTime,jdbcType=TIMESTAMP}, #{updateTime,jdbcType=TIMESTAMP})"
})
int insert(DevopsDoris record);
/**
* This method was generated by MyBatis Generator.
* This method corresponds to the database table devops_doris
*
* @mbg.generated
*/
int insertSelective(DevopsDoris record);
/**
* This method was generated by MyBatis Generator.
* This method corresponds to the database table devops_doris
*
* @mbg.generated
*/
List<DevopsDoris> selectByExample(DevopsDorisExample example);
/**
* This method was generated by MyBatis Generator.
* This method corresponds to the database table devops_doris
*
* @mbg.generated
*/
@Select({
"select",
"id, name, ip, cluster, roles, fs, root_pwd, is_init, create_time, update_time",
"from devops_doris",
"where id = #{id,jdbcType=BIGINT}"
})
@ResultMap("net.wicp.tams.app.duckula.controller.dao.DevopsDorisMapper.BaseResultMap")
DevopsDoris selectByPrimaryKey(Long id);
/**
* This method was generated by MyBatis Generator.
* This method corresponds to the database table devops_doris
*
* @mbg.generated
*/
int updateByExampleSelective(@Param("record") DevopsDoris record, @Param("example") DevopsDorisExample example);
/**
* This method was generated by MyBatis Generator.
* This method corresponds to the database table devops_doris
*
* @mbg.generated
*/
int updateByExample(@Param("record") DevopsDoris record, @Param("example") DevopsDorisExample example);
/**
* This method was generated by MyBatis Generator.
* This method corresponds to the database table devops_doris
*
* @mbg.generated
*/
int updateByPrimaryKeySelective(DevopsDoris record);
/**
* This method was generated by MyBatis Generator.
* This method corresponds to the database table devops_doris
*
* @mbg.generated
*/
@Update({
"update devops_doris",
"set name = #{name,jdbcType=VARCHAR},",
"ip = #{ip,jdbcType=VARCHAR},",
"cluster = #{cluster,jdbcType=VARCHAR},",
"roles = #{roles,jdbcType=VARCHAR},",
"fs = #{fs,jdbcType=VARCHAR},",
"root_pwd = #{rootPwd,jdbcType=VARCHAR},",
"is_init = #{isInit,jdbcType=VARCHAR},",
"create_time = #{createTime,jdbcType=TIMESTAMP},",
"update_time = #{updateTime,jdbcType=TIMESTAMP}",
"where id = #{id,jdbcType=BIGINT}"
})
int updateByPrimaryKey(DevopsDoris record);
/**
* This method was generated by MyBatis Generator. This method corresponds to the database table devops_doris
* @mbg.generated
*/
long countByExample(DevopsDorisExample example);
/**
* This method was generated by MyBatis Generator. This method corresponds to the database table devops_doris
* @mbg.generated
*/
int deleteByExample(DevopsDorisExample example);
/**
* This method was generated by MyBatis Generator. This method corresponds to the database table devops_doris
* @mbg.generated
*/
@Delete({ "delete from devops_doris", "where id = #{id,jdbcType=BIGINT}" })
int deleteByPrimaryKey(Long id);
/**
* This method was generated by MyBatis Generator. This method corresponds to the database table devops_doris
* @mbg.generated
*/
@Insert({ "insert into devops_doris (id, name, ", "ip, cluster, roles, ", "fs, root_pwd, is_init, ",
"create_time, update_time)", "values (#{id,jdbcType=BIGINT}, #{name,jdbcType=VARCHAR}, ",
"#{ip,jdbcType=VARCHAR}, #{cluster,jdbcType=VARCHAR}, #{roles,jdbcType=VARCHAR}, ",
"#{fs,jdbcType=VARCHAR}, #{rootPwd,jdbcType=VARCHAR}, #{isInit,jdbcType=VARCHAR}, ",
"#{createTime,jdbcType=TIMESTAMP}, #{updateTime,jdbcType=TIMESTAMP})" })
int insert(DevopsDoris record);
/**
* This method was generated by MyBatis Generator. This method corresponds to the database table devops_doris
* @mbg.generated
*/
int insertSelective(DevopsDoris record);
/**
* This method was generated by MyBatis Generator. This method corresponds to the database table devops_doris
* @mbg.generated
*/
List<DevopsDoris> selectByExample(DevopsDorisExample example);
/**
* This method was generated by MyBatis Generator. This method corresponds to the database table devops_doris
* @mbg.generated
*/
@Select({ "select", "id, name, ip, cluster, roles, fs, root_pwd, is_init, create_time, update_time",
"from devops_doris", "where id = #{id,jdbcType=BIGINT}" })
@ResultMap("net.wicp.tams.app.duckula.controller.dao.DevopsDorisMapper.BaseResultMap")
DevopsDoris selectByPrimaryKey(Long id);
/**
* This method was generated by MyBatis Generator. This method corresponds to the database table devops_doris
* @mbg.generated
*/
int updateByExampleSelective(@Param("record") DevopsDoris record, @Param("example") DevopsDorisExample example);
/**
* This method was generated by MyBatis Generator. This method corresponds to the database table devops_doris
* @mbg.generated
*/
int updateByExample(@Param("record") DevopsDoris record, @Param("example") DevopsDorisExample example);
/**
* This method was generated by MyBatis Generator. This method corresponds to the database table devops_doris
* @mbg.generated
*/
int updateByPrimaryKeySelective(DevopsDoris record);
/**
* This method was generated by MyBatis Generator. This method corresponds to the database table devops_doris
* @mbg.generated
*/
@Update({ "update devops_doris", "set name = #{name,jdbcType=VARCHAR},", "ip = #{ip,jdbcType=VARCHAR},",
"cluster = #{cluster,jdbcType=VARCHAR},", "roles = #{roles,jdbcType=VARCHAR},",
"fs = #{fs,jdbcType=VARCHAR},", "root_pwd = #{rootPwd,jdbcType=VARCHAR},",
"is_init = #{isInit,jdbcType=VARCHAR},", "create_time = #{createTime,jdbcType=TIMESTAMP},",
"update_time = #{updateTime,jdbcType=TIMESTAMP}", "where id = #{id,jdbcType=BIGINT}" })
int updateByPrimaryKey(DevopsDoris record);
}
\ No newline at end of file
src/main/java/net/wicp/tams/app/duckula/controller/dao/DevopsFlinkMapper.java
浏览文件 @ a9ef70be
......@@ -39,10 +39,13 @@ public interface DevopsFlinkMapper extends BaseMapper<DevopsFlink>{
* This method was generated by MyBatis Generator. This method corresponds to the database table devops_flink
* @mbg.generated
*/
@Insert({ "insert into devops_flink (id, name, ", "ip, root_pwd, is_init, ", "create_time, update_time)",
@Insert({ "insert into devops_flink (id, name, ", "cluster, ip, hostname, ", "root_user, root_pwd, ",
"need_free, is_init, ", "is_free, create_time, ", "update_time)",
"values (#{id,jdbcType=BIGINT}, #{name,jdbcType=VARCHAR}, ",
"#{ip,jdbcType=VARCHAR}, #{rootPwd,jdbcType=VARCHAR}, #{isInit,jdbcType=VARCHAR}, ",
"#{createTime,jdbcType=TIMESTAMP}, #{updateTime,jdbcType=TIMESTAMP})" })
"#{cluster,jdbcType=VARCHAR}, #{ip,jdbcType=VARCHAR}, #{hostname,jdbcType=VARCHAR}, ",
"#{rootUser,jdbcType=VARCHAR}, #{rootPwd,jdbcType=VARCHAR}, ",
"#{needFree,jdbcType=VARCHAR}, #{isInit,jdbcType=VARCHAR}, ",
"#{isFree,jdbcType=VARCHAR}, #{createTime,jdbcType=TIMESTAMP}, ", "#{updateTime,jdbcType=TIMESTAMP})" })
int insert(DevopsFlink record);
/**
......@@ -61,8 +64,8 @@ public interface DevopsFlinkMapper extends BaseMapper<DevopsFlink>{
* This method was generated by MyBatis Generator. This method corresponds to the database table devops_flink
* @mbg.generated
*/
@Select({ "select", "id, name, ip, root_pwd, is_init, create_time, update_time", "from devops_flink",
"where id = #{id,jdbcType=BIGINT}" })
@Select({ "select", "id, name, cluster, ip, hostname, root_user, root_pwd, need_free, is_init, is_free, ",
"create_time, update_time", "from devops_flink", "where id = #{id,jdbcType=BIGINT}" })
@ResultMap("net.wicp.tams.app.duckula.controller.dao.DevopsFlinkMapper.BaseResultMap")
DevopsFlink selectByPrimaryKey(Long id);
......@@ -88,9 +91,11 @@ public interface DevopsFlinkMapper extends BaseMapper<DevopsFlink>{
* This method was generated by MyBatis Generator. This method corresponds to the database table devops_flink
* @mbg.generated
*/
@Update({ "update devops_flink", "set name = #{name,jdbcType=VARCHAR},", "ip = #{ip,jdbcType=VARCHAR},",
"root_pwd = #{rootPwd,jdbcType=VARCHAR},", "is_init = #{isInit,jdbcType=VARCHAR},",
"create_time = #{createTime,jdbcType=TIMESTAMP},", "update_time = #{updateTime,jdbcType=TIMESTAMP}",
"where id = #{id,jdbcType=BIGINT}" })
@Update({ "update devops_flink", "set name = #{name,jdbcType=VARCHAR},", "cluster = #{cluster,jdbcType=VARCHAR},",
"ip = #{ip,jdbcType=VARCHAR},", "hostname = #{hostname,jdbcType=VARCHAR},",
"root_user = #{rootUser,jdbcType=VARCHAR},", "root_pwd = #{rootPwd,jdbcType=VARCHAR},",
"need_free = #{needFree,jdbcType=VARCHAR},", "is_init = #{isInit,jdbcType=VARCHAR},",
"is_free = #{isFree,jdbcType=VARCHAR},", "create_time = #{createTime,jdbcType=TIMESTAMP},",
"update_time = #{updateTime,jdbcType=TIMESTAMP}", "where id = #{id,jdbcType=BIGINT}" })
int updateByPrimaryKey(DevopsFlink record);
}
\ No newline at end of file
src/main/java/net/wicp/tams/duckula/ops/pages/devops/FlinkConfig.java
浏览文件 @ a9ef70be
package net.wicp.tams.duckula.ops.pages.devops;
import java.util.List;
import org.apache.commons.collections.CollectionUtils;
import org.apache.tapestry5.ioc.annotations.Inject;
import org.apache.tapestry5.util.TextStreamResponse;
......@@ -8,11 +11,15 @@ import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import lombok.extern.slf4j.Slf4j;
import net.wicp.tams.app.duckula.controller.bean.models.DevopsFlink;
import net.wicp.tams.app.duckula.controller.bean.models.DevopsFlinkExample;
import net.wicp.tams.app.duckula.controller.bean.models.DevopsFlinkExample.Criteria;
import net.wicp.tams.app.duckula.controller.config.constant.DevOpsType;
import net.wicp.tams.app.duckula.controller.dao.DevopsFlinkMapper;
import net.wicp.tams.common.Result;
import net.wicp.tams.common.apiext.IOUtil;
import net.wicp.tams.common.apiext.StringUtil;
import net.wicp.tams.common.constant.PathType;
import net.wicp.tams.common.constant.dic.YesOrNo;
import net.wicp.tams.common.os.SSHAssit;
import net.wicp.tams.common.os.pool.SSHConnection;
import net.wicp.tams.component.tools.TapestryAssist;
......@@ -27,6 +34,16 @@ public class FlinkConfig extends ParentPageBean<DevopsFlink> {
@Override
public void doSave(DevopsFlink t, boolean isInsert) {
if (isInsert) {
t.setIsInit(YesOrNo.no.name());
t.setIsFree(YesOrNo.no.name());
List<DevopsFlink> list = queryHostByCluster(t.getCluster());
int lastindex = 0;
if (CollectionUtils.isNotEmpty(list)) {
String hostname = list.get(list.size() - 1).getHostname();
String last = hostname.substring(hostname.length() - 1, hostname.length());
lastindex = Integer.parseInt(last);
}
t.setHostname(String.format("prod-bigdata-flink%02d", ++lastindex));// 设置主机名
devopsFlinkMapper.insert(t);
} else {
devopsFlinkMapper.updateByPrimaryKeySelective(t);
......@@ -53,6 +70,16 @@ public class FlinkConfig extends ParentPageBean<DevopsFlink> {
}
}
// 不排序是以id顺序
private List<DevopsFlink> queryHostByCluster(String cluster) {
DevopsFlinkExample example = new DevopsFlinkExample();
Criteria criteria = example.createCriteria();
criteria.andClusterEqualTo(cluster);
List<DevopsFlink> list = devopsFlinkMapper.selectByExample(example);
return list;
}
/***
* 测试用后端调用
*
......@@ -60,17 +87,69 @@ public class FlinkConfig extends ParentPageBean<DevopsFlink> {
*/
public TextStreamResponse onCheckHost() {
final DevopsFlink devopsFlink = TapestryAssist.getBeanFromPage(DevopsFlink.class, requestGlobals);
// 查询此集群下面的主机配置
List<DevopsFlink> list = queryHostByCluster(devopsFlink.getCluster());
StringBuffer checkparam = new StringBuffer();
StringBuffer freeparam = new StringBuffer();
for (int i = 0; i < list.size(); i++) {
DevopsFlink flink = list.get(i);
checkparam.append(String.format(" %s %s", flink.getIp(), flink.getHostname()));
freeparam.append(String.format(" %s %s %s", flink.getRootUser(), flink.getHostname(), flink.getRootPwd()));
}
// 1、OSS下载
String localPath = PathType.getPath(DevOpsType.flink.getCheckurl());
String localPath = PathType.getPath(DevOpsType.flink.getCheckDownFile());
// 1、登陆
SSHConnection conn = SSHAssit.getConn(devopsFlink.getIp(), "root", devopsFlink.getRootPwd());
String fileName = localPath.substring(localPath.lastIndexOf("/") + 1);
conn.scp(localPath, fileName, "~", "0744");
// 执行
Result result = conn.executeCommand(String.format("sh ~/%s", fileName));
log.info(result.getMessage());
conn.close();
return TapestryAssist.getTextStreamResponse(Result.getError("检查结果：" + result.getMessage()));
SSHConnection conn = SSHAssit.getConn(devopsFlink.getIp(), devopsFlink.getRootUser(), devopsFlink.getRootPwd());
// String fileName = localPath.substring(localPath.lastIndexOf("/") + 1);
String remoteDir = IOUtil.mergeFolderAndFilePath("~/", DevOpsType.flink.getRelaPathCheckDir());
conn.executeCommand("mkdir -p " + remoteDir);
// conn.scpToDir(localPath,remoteDir , "0744");
conn.scpDir(localPath, remoteDir, "0744", new String[] {}, new String[] {});
// conn.scp(localPath, fileName, "~" + DevOpsType.flink.getRelaPathCheck(),
// "0744");
// check
Result result = conn.executeCommand(String.format("sh %s %s",
IOUtil.mergeFolderAndFilePath("~/", DevOpsType.flink.getRelaPathCheck()), checkparam.toString()));
if (!result.isSuc()) {// 不成功
log.info(result.getMessage());
conn.close();
return TapestryAssist.getTextStreamResponse(Result.getError(result.getMessage()));
}
devopsFlink.setIsInit(YesOrNo.yes.name());
devopsFlinkMapper.updateByPrimaryKeySelective(devopsFlink);// 保存check结果
if (YesOrNo.yes.name().equals(devopsFlink.getNeedFree())) {
boolean doFree = true;// 默认需要做
for (DevopsFlink ele : list) {
if (YesOrNo.no.name().equals(ele.getIsInit())) {
doFree = false;
break;
}
}
if (doFree) {
// 三台机都做免密
for (DevopsFlink devopsFlink2 : list) {
SSHConnection freeconn = SSHAssit.getConn(devopsFlink.getIp(), devopsFlink2.getRootUser(),
devopsFlink2.getRootPwd());
try {
// free
Result freeRs = freeconn.executeCommand(String.format("sh %s %s",
IOUtil.mergeFolderAndFilePath("~/",
DevOpsType.flink.getRelaPath(DevOpsType.flink.getOtherparams()[0])),
freeparam.toString()));
if (freeRs.isSuc()) {
// 保存
devopsFlink2.setIsFree(YesOrNo.yes.name());
devopsFlinkMapper.updateByPrimaryKeySelective(devopsFlink2);// 保存免密结果
}
} finally {
SSHAssit.close(freeconn);
}
}
}
}
return TapestryAssist.getTextStreamResponse(Result.getSuc());
}
}
src/main/resources/mybatis/primary/sqlmap/DevopsFlinkMapper.xml
浏览文件 @ a9ef70be
......@@ -9,9 +9,14 @@
<constructor>
<idArg column="id" javaType="java.lang.Long" jdbcType="BIGINT" />
<arg column="name" javaType="java.lang.String" jdbcType="VARCHAR" />
<arg column="cluster" javaType="java.lang.String" jdbcType="VARCHAR" />
<arg column="ip" javaType="java.lang.String" jdbcType="VARCHAR" />
<arg column="hostname" javaType="java.lang.String" jdbcType="VARCHAR" />
<arg column="root_user" javaType="java.lang.String" jdbcType="VARCHAR" />
<arg column="root_pwd" javaType="java.lang.String" jdbcType="VARCHAR" />
<arg column="need_free" javaType="java.lang.String" jdbcType="VARCHAR" />
<arg column="is_init" javaType="java.lang.String" jdbcType="VARCHAR" />
<arg column="is_free" javaType="java.lang.String" jdbcType="VARCHAR" />
<arg column="create_time" javaType="java.util.Date" jdbcType="TIMESTAMP" />
<arg column="update_time" javaType="java.util.Date" jdbcType="TIMESTAMP" />
</constructor>
......@@ -87,7 +92,8 @@
WARNING - @mbg.generated
This element is automatically generated by MyBatis Generator, do not modify.
-->
id, name, ip, root_pwd, is_init, create_time, update_time
id, name, cluster, ip, hostname, root_user, root_pwd, need_free, is_init, is_free,
create_time, update_time
</sql>
<select id="selectByExample" parameterType="net.wicp.tams.app.duckula.controller.bean.models.DevopsFlinkExample" resultMap="BaseResultMap">
<!--
......@@ -130,15 +136,30 @@
<if test="name != null">
name,
</if>
<if test="cluster != null">
cluster,
</if>
<if test="ip != null">
ip,
</if>
<if test="hostname != null">
hostname,
</if>
<if test="rootUser != null">
root_user,
</if>
<if test="rootPwd != null">
root_pwd,
</if>
<if test="needFree != null">
need_free,
</if>
<if test="isInit != null">
is_init,
</if>
<if test="isFree != null">
is_free,
</if>
<if test="createTime != null">
create_time,
</if>
......@@ -153,15 +174,30 @@
<if test="name != null">
#{name,jdbcType=VARCHAR},
</if>
<if test="cluster != null">
#{cluster,jdbcType=VARCHAR},
</if>
<if test="ip != null">
#{ip,jdbcType=VARCHAR},
</if>
<if test="hostname != null">
#{hostname,jdbcType=VARCHAR},
</if>
<if test="rootUser != null">
#{rootUser,jdbcType=VARCHAR},
</if>
<if test="rootPwd != null">
#{rootPwd,jdbcType=VARCHAR},
</if>
<if test="needFree != null">
#{needFree,jdbcType=VARCHAR},
</if>
<if test="isInit != null">
#{isInit,jdbcType=VARCHAR},
</if>
<if test="isFree != null">
#{isFree,jdbcType=VARCHAR},
</if>
<if test="createTime != null">
#{createTime,jdbcType=TIMESTAMP},
</if>
......@@ -193,15 +229,30 @@
<if test="record.name != null">
name = #{record.name,jdbcType=VARCHAR},
</if>
<if test="record.cluster != null">
cluster = #{record.cluster,jdbcType=VARCHAR},
</if>
<if test="record.ip != null">
ip = #{record.ip,jdbcType=VARCHAR},
</if>
<if test="record.hostname != null">
hostname = #{record.hostname,jdbcType=VARCHAR},
</if>
<if test="record.rootUser != null">
root_user = #{record.rootUser,jdbcType=VARCHAR},
</if>
<if test="record.rootPwd != null">
root_pwd = #{record.rootPwd,jdbcType=VARCHAR},
</if>
<if test="record.needFree != null">
need_free = #{record.needFree,jdbcType=VARCHAR},
</if>
<if test="record.isInit != null">
is_init = #{record.isInit,jdbcType=VARCHAR},
</if>
<if test="record.isFree != null">
is_free = #{record.isFree,jdbcType=VARCHAR},
</if>
<if test="record.createTime != null">
create_time = #{record.createTime,jdbcType=TIMESTAMP},
</if>
......@@ -221,9 +272,14 @@
update devops_flink
set id = #{record.id,jdbcType=BIGINT},
name = #{record.name,jdbcType=VARCHAR},
cluster = #{record.cluster,jdbcType=VARCHAR},
ip = #{record.ip,jdbcType=VARCHAR},
hostname = #{record.hostname,jdbcType=VARCHAR},
root_user = #{record.rootUser,jdbcType=VARCHAR},
root_pwd = #{record.rootPwd,jdbcType=VARCHAR},
need_free = #{record.needFree,jdbcType=VARCHAR},
is_init = #{record.isInit,jdbcType=VARCHAR},
is_free = #{record.isFree,jdbcType=VARCHAR},
create_time = #{record.createTime,jdbcType=TIMESTAMP},
update_time = #{record.updateTime,jdbcType=TIMESTAMP}
<if test="_parameter != null">
......@@ -240,15 +296,30 @@
<if test="name != null">
name = #{name,jdbcType=VARCHAR},
</if>
<if test="cluster != null">
cluster = #{cluster,jdbcType=VARCHAR},
</if>
<if test="ip != null">
ip = #{ip,jdbcType=VARCHAR},
</if>
<if test="hostname != null">
hostname = #{hostname,jdbcType=VARCHAR},
</if>
<if test="rootUser != null">
root_user = #{rootUser,jdbcType=VARCHAR},
</if>
<if test="rootPwd != null">
root_pwd = #{rootPwd,jdbcType=VARCHAR},
</if>
<if test="needFree != null">
need_free = #{needFree,jdbcType=VARCHAR},
</if>
<if test="isInit != null">
is_init = #{isInit,jdbcType=VARCHAR},
</if>
<if test="isFree != null">
is_free = #{isFree,jdbcType=VARCHAR},
</if>
<if test="createTime != null">
create_time = #{createTime,jdbcType=TIMESTAMP},
</if>
......
src/main/resources/net/wicp/tams/duckula/ops/pages/devops/FlinkConfig.tml
浏览文件 @ a9ef70be
<html t:type="rjzjh/layoutQuery" queryButs="[{'id':'checkBut','iconCls':'icon-attach','text':'检查服务器','url':'checkHost','confirm':'你确定要检查此服务器吗？'}]"
<html t:type="rjzjh/layoutQuery" queryButs="[{'id':'checkBut','iconCls':'icon-attach','text':'初始化服务器','url':'checkHost','confirm':'你确定要初始化此服务器吗？'}]"
xmlns:t="http://tapestry.apache.org/schema/tapestry_5_4.xsd"
xmlns:r="tapestry-library:rjzjh"
xmlns:s="tapestry-library:tams"
......
Markdown is supported
0% 或 .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑！
想要评论请 注册 或