增加主机信息功能

2026-04-12 21:04:03 +08:00
parent 18d8f1dbff
commit f6c2583408
18 changed files with 1749 additions and 1 deletions
--- a/web-api/src/main/java/com/jeesite/modules/apps/Module/ContainerInfo.java
+++ b/web-api/src/main/java/com/jeesite/modules/apps/Module/ContainerInfo.java
@@ -0,0 +1,20 @@
+package com.jeesite.modules.apps.Module;
+
+import lombok.Data;
+
+import java.io.Serializable;
+
+/**
+ * Docker 容器信息
+ */
+@Data
+public class ContainerInfo  implements Serializable {
+
+    private String containerId;
+    private String image;
+    private String command;
+    private String status;
+    private String created;
+    private String names;
+    private String ports;
+}
--- a/web-api/src/main/java/com/jeesite/modules/apps/Module/DockerResult.java
+++ b/web-api/src/main/java/com/jeesite/modules/apps/Module/DockerResult.java
@@ -0,0 +1,36 @@
+package com.jeesite.modules.apps.Module;
+
+import lombok.Data;
+
+import java.io.Serializable;
+
+/**
+ * Docker 操作结果
+ */
+@Data
+public class DockerResult implements Serializable {
+
+    private boolean success;
+    private String output;
+    private String error;
+    private String message;
+
+    public static DockerResult ok(String output) {
+        DockerResult r = new DockerResult();
+        r.success = true;
+        r.output = output;
+        return r;
+    }
+
+    public static DockerResult fail(String message, String error) {
+        DockerResult r = new DockerResult();
+        r.success = false;
+        r.message = message;
+        r.error = error;
+        return r;
+    }
+
+    public static DockerResult fail(String message) {
+        return fail(message, null);
+    }
+}
--- a/web-api/src/main/java/com/jeesite/modules/biz/dao/MySftpAccountsDao.java
+++ b/web-api/src/main/java/com/jeesite/modules/biz/dao/MySftpAccountsDao.java
@@ -0,0 +1,15 @@
+package com.jeesite.modules.biz.dao;
+
+import com.jeesite.common.dao.CrudDao;
+import com.jeesite.common.mybatis.annotation.MyBatisDao;
+import com.jeesite.modules.biz.entity.MySftpAccounts;
+
+/**
+ * 主机信息表 DAO 接口
+ * @author gaoxq
+ * @version 2026-04-12
+ */
+@MyBatisDao(dataSourceName="work")
+public interface MySftpAccountsDao extends CrudDao<MySftpAccounts> {
+	
+}
--- a/web-api/src/main/java/com/jeesite/modules/biz/dao/MySftpHostsDao.java
+++ b/web-api/src/main/java/com/jeesite/modules/biz/dao/MySftpHostsDao.java
@@ -0,0 +1,15 @@
+package com.jeesite.modules.biz.dao;
+
+import com.jeesite.common.dao.CrudDao;
+import com.jeesite.common.mybatis.annotation.MyBatisDao;
+import com.jeesite.modules.biz.entity.MySftpHosts;
+
+/**
+ * 主机信息表 DAO 接口
+ * @author gaoxq
+ * @version 2026-04-12
+ */
+@MyBatisDao(dataSourceName="work")
+public interface MySftpHostsDao extends CrudDao<MySftpHosts> {
+	
+}
--- a/web-api/src/main/java/com/jeesite/modules/biz/entity/MySftpAccounts.java
+++ b/web-api/src/main/java/com/jeesite/modules/biz/entity/MySftpAccounts.java
@@ -0,0 +1,200 @@
+package com.jeesite.modules.biz.entity;
+
+import java.io.Serializable;
+import java.util.Date;
+
+import com.jeesite.common.mybatis.annotation.JoinTable;
+import com.jeesite.common.mybatis.annotation.JoinTable.Type;
+import com.fasterxml.jackson.annotation.JsonFormat;
+import jakarta.validation.constraints.NotBlank;
+import jakarta.validation.constraints.Size;
+
+import com.jeesite.common.entity.DataEntity;
+import com.jeesite.common.mybatis.annotation.Column;
+import com.jeesite.common.mybatis.annotation.Table;
+import com.jeesite.common.mybatis.mapper.query.QueryType;
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+
+import java.io.Serial;
+
+/**
+ * 主机信息表 Entity
+ *
+ * @author gaoxq
+ * @version 2026-04-12
+ */
+@EqualsAndHashCode(callSuper = true)
+@Table(name = "my_sftp_accounts", alias = "a", label = "主机信息", columns = {
+        @Column(name = "create_time", attrName = "createTime", label = "记录时间", isUpdate = false, isUpdateForce = true),
+        @Column(name = "account_id", attrName = "accountId", label = "账号标识", isPK = true),
+        @Column(name = "host_id", attrName = "hostId.hostId", label = "主机名称"),
+        @Column(name = "username", attrName = "username", label = "登录账号"),
+        @Column(name = "password", attrName = "password", label = "登录密码", isQuery = false),
+        @Column(name = "root_path", attrName = "rootPath", label = "初始目录", isQuery = false),
+        @Column(name = "auth_type", attrName = "authType", label = "认证方式"),
+        @Column(name = "private_key", attrName = "privateKey", label = "密钥内容", isQuery = false),
+        @Column(name = "status", attrName = "status", label = "账号状态", isUpdate = false, isQuery = false),
+        @Column(name = "expire_time", attrName = "expireTime", label = "过期时间", isQuery = false, isUpdateForce = true),
+        @Column(name = "account_remark", attrName = "accountRemark", label = "账号备注"),
+        @Column(name = "update_time", attrName = "updateTime", label = "更新时间", isQuery = false, isUpdateForce = true),
+        @Column(name = "ustatus", attrName = "ustatus", label = "状态"),
+}, orderBy = "a.create_time DESC"
+)
+@Data
+public class MySftpAccounts extends DataEntity<MySftpAccounts> implements Serializable {
+
+    @Serial
+    private static final long serialVersionUID = 1L;
+    private Date createTime;        // 记录时间
+    private String accountId;        // 账号标识
+    private MySftpHosts hostId;        // 主机名称 父类
+    private String username;        // 登录账号
+    private String password;        // 登录密码
+    private String rootPath;        // 初始目录
+    private String authType;        // 认证方式
+    private String privateKey;        // 密钥内容
+    private Date expireTime;        // 过期时间
+    private String accountRemark;        // 账号备注
+    private Date updateTime;        // 更新时间
+    private String ustatus;        // 状态
+
+	private String hostIp;		// 主机域名
+	private Integer hostPort;		// 主机端口
+	private String hostName;		// 主机名称
+
+    public MySftpAccounts() {
+        this(null);
+    }
+
+    public MySftpAccounts(MySftpHosts hostId) {
+        this.hostId = hostId;
+    }
+
+    @JsonFormat(pattern = "yyyy-MM-dd HH:mm")
+    public Date getCreateTime() {
+        return createTime;
+    }
+
+    public void setCreateTime(Date createTime) {
+        this.createTime = createTime;
+    }
+
+    public String getAccountId() {
+        return accountId;
+    }
+
+    public void setAccountId(String accountId) {
+        this.accountId = accountId;
+    }
+
+    public MySftpHosts getHostId() {
+        return hostId;
+    }
+
+    public void setHostId(MySftpHosts hostId) {
+        this.hostId = hostId;
+    }
+
+    @NotBlank(message = "登录账号不能为空")
+    @Size(min = 0, max = 100, message = "登录账号长度不能超过 100 个字符")
+    public String getUsername() {
+        return username;
+    }
+
+    public void setUsername(String username) {
+        this.username = username;
+    }
+
+    @NotBlank(message = "登录密码不能为空")
+    @Size(min = 0, max = 255, message = "登录密码长度不能超过 255 个字符")
+    public String getPassword() {
+        return password;
+    }
+
+    public void setPassword(String password) {
+        this.password = password;
+    }
+
+    @NotBlank(message = "初始目录不能为空")
+    @Size(min = 0, max = 255, message = "初始目录长度不能超过 255 个字符")
+    public String getRootPath() {
+        return rootPath;
+    }
+
+    public void setRootPath(String rootPath) {
+        this.rootPath = rootPath;
+    }
+
+    @NotBlank(message = "认证方式不能为空")
+    @Size(min = 0, max = 12, message = "认证方式长度不能超过 12 个字符")
+    public String getAuthType() {
+        return authType;
+    }
+
+    public void setAuthType(String authType) {
+        this.authType = authType;
+    }
+
+    public String getPrivateKey() {
+        return privateKey;
+    }
+
+    public void setPrivateKey(String privateKey) {
+        this.privateKey = privateKey;
+    }
+
+    @JsonFormat(pattern = "yyyy-MM-dd HH:mm")
+    public Date getExpireTime() {
+        return expireTime;
+    }
+
+    public void setExpireTime(Date expireTime) {
+        this.expireTime = expireTime;
+    }
+
+    @Size(min = 0, max = 255, message = "账号备注长度不能超过 255 个字符")
+    public String getAccountRemark() {
+        return accountRemark;
+    }
+
+    public void setAccountRemark(String accountRemark) {
+        this.accountRemark = accountRemark;
+    }
+
+    @JsonFormat(pattern = "yyyy-MM-dd HH:mm")
+    public Date getUpdateTime() {
+        return updateTime;
+    }
+
+    public void setUpdateTime(Date updateTime) {
+        this.updateTime = updateTime;
+    }
+
+    @NotBlank(message = "状态不能为空")
+    @Size(min = 0, max = 12, message = "状态长度不能超过 12 个字符")
+    public String getUstatus() {
+        return ustatus;
+    }
+
+    public void setUstatus(String ustatus) {
+        this.ustatus = ustatus;
+    }
+
+    public Date getCreateTime_gte() {
+        return sqlMap.getWhere().getValue("create_time", QueryType.GTE);
+    }
+
+    public void setCreateTime_gte(Date createTime) {
+        sqlMap.getWhere().and("create_time", QueryType.GTE, createTime);
+    }
+
+    public Date getCreateTime_lte() {
+        return sqlMap.getWhere().getValue("create_time", QueryType.LTE);
+    }
+
+    public void setCreateTime_lte(Date createTime) {
+        sqlMap.getWhere().and("create_time", QueryType.LTE, createTime);
+    }
+
+}
--- a/web-api/src/main/java/com/jeesite/modules/biz/entity/MySftpHosts.java
+++ b/web-api/src/main/java/com/jeesite/modules/biz/entity/MySftpHosts.java
@@ -0,0 +1,161 @@
+package com.jeesite.modules.biz.entity;
+
+import jakarta.validation.Valid;
+
+import java.io.Serializable;
+import java.util.Date;
+import com.jeesite.common.mybatis.annotation.JoinTable;
+import com.jeesite.common.mybatis.annotation.JoinTable.Type;
+import com.fasterxml.jackson.annotation.JsonFormat;
+import jakarta.validation.constraints.NotBlank;
+import jakarta.validation.constraints.Size;
+import jakarta.validation.constraints.NotNull;
+import java.util.List;
+import com.jeesite.common.collect.ListUtils;
+
+import com.jeesite.common.entity.DataEntity;
+import com.jeesite.common.mybatis.annotation.Column;
+import com.jeesite.common.mybatis.annotation.Table;
+import com.jeesite.common.mybatis.mapper.query.QueryType;
+import com.jeesite.common.utils.excel.annotation.ExcelField;
+import com.jeesite.common.utils.excel.annotation.ExcelField.Align;
+import com.jeesite.common.utils.excel.annotation.ExcelFields;
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+
+import java.io.Serial;
+
+/**
+ * 主机信息表 Entity
+ * @author gaoxq
+ * @version 2026-04-12
+ */
+@EqualsAndHashCode(callSuper = true)
+@Table(name="my_sftp_hosts", alias="a", label="主机信息", columns={
+		@Column(name="create_time", attrName="createTime", label="记录时间", isUpdate=false, isQuery=false, isUpdateForce=true),
+		@Column(name="host_id", attrName="hostId", label="主机主键", isPK=true),
+		@Column(name="host_ip", attrName="hostIp", label="主机域名", queryType=QueryType.LIKE),
+		@Column(name="host_port", attrName="hostPort", label="主机端口", isQuery=false),
+		@Column(name="host_name", attrName="hostName", label="主机名称", queryType=QueryType.LIKE),
+		@Column(name="host_remark", attrName="hostRemark", label="备注说明", isQuery=false),
+		@Column(name="update_time", attrName="updateTime", label="更新时间", isQuery=false, isUpdateForce=true),
+		@Column(name="ustatus", attrName="ustatus", label="状态"),
+	}, orderBy="a.create_time DESC"
+)
+@Data
+public class MySftpHosts extends DataEntity<MySftpHosts>  implements Serializable {
+	
+	@Serial
+	private static final long serialVersionUID = 1L;
+	private Date createTime;		// 记录时间
+	private String hostId;		// 主机主键
+	private String hostIp;		// 主机域名
+	private Integer hostPort;		// 主机端口
+	private String hostName;		// 主机名称
+	private String hostRemark;		// 备注说明
+	private Date updateTime;		// 更新时间
+	private String ustatus;		// 状态
+	private List<MySftpAccounts> mySftpAccountsList = ListUtils.newArrayList();		// 子表列表
+
+	@ExcelFields({
+		@ExcelField(title="记录时间", attrName="createTime", align=Align.CENTER, sort=10, dataFormat="yyyy-MM-dd hh:mm"),
+		@ExcelField(title="主机主键", attrName="hostId", align=Align.CENTER, sort=20),
+		@ExcelField(title="主机域名", attrName="hostIp", align=Align.CENTER, sort=30),
+		@ExcelField(title="主机端口", attrName="hostPort", align=Align.CENTER, sort=40),
+		@ExcelField(title="主机名称", attrName="hostName", align=Align.CENTER, sort=50),
+		@ExcelField(title="备注说明", attrName="hostRemark", align=Align.CENTER, sort=60),
+		@ExcelField(title="更新时间", attrName="updateTime", align=Align.CENTER, sort=70, dataFormat="yyyy-MM-dd hh:mm"),
+		@ExcelField(title="状态", attrName="ustatus", align=Align.CENTER, sort=80),
+	})
+	public MySftpHosts() {
+		this(null);
+	}
+	
+	public MySftpHosts(String id){
+		super(id);
+	}
+
+	@JsonFormat(pattern = "yyyy-MM-dd HH:mm")
+	public Date getCreateTime() {
+		return createTime;
+	}
+
+	public void setCreateTime(Date createTime) {
+		this.createTime = createTime;
+	}
+
+	public String getHostId() {
+		return hostId;
+	}
+
+	public void setHostId(String hostId) {
+		this.hostId = hostId;
+	}
+
+	@NotBlank(message="主机域名不能为空")
+	@Size(min=0, max=64, message="主机域名长度不能超过 64 个字符")
+	public String getHostIp() {
+		return hostIp;
+	}
+
+	public void setHostIp(String hostIp) {
+		this.hostIp = hostIp;
+	}
+
+	@NotNull(message="主机端口不能为空")
+	public Integer getHostPort() {
+		return hostPort;
+	}
+
+	public void setHostPort(Integer hostPort) {
+		this.hostPort = hostPort;
+	}
+
+	@NotBlank(message="主机名称不能为空")
+	@Size(min=0, max=100, message="主机名称长度不能超过 100 个字符")
+	public String getHostName() {
+		return hostName;
+	}
+
+	public void setHostName(String hostName) {
+		this.hostName = hostName;
+	}
+
+	@Size(min=0, max=255, message="备注说明长度不能超过 255 个字符")
+	public String getHostRemark() {
+		return hostRemark;
+	}
+
+	public void setHostRemark(String hostRemark) {
+		this.hostRemark = hostRemark;
+	}
+
+	@JsonFormat(pattern = "yyyy-MM-dd HH:mm")
+	public Date getUpdateTime() {
+		return updateTime;
+	}
+
+	public void setUpdateTime(Date updateTime) {
+		this.updateTime = updateTime;
+	}
+
+	@NotBlank(message="状态不能为空")
+	@Size(min=0, max=12, message="状态长度不能超过 12 个字符")
+	public String getUstatus() {
+		return ustatus;
+	}
+
+	public void setUstatus(String ustatus) {
+		this.ustatus = ustatus;
+	}
+	
+	@Valid
+	public List<MySftpAccounts> getMySftpAccountsList() {
+		return mySftpAccountsList;
+	}
+
+	public void setMySftpAccountsList(List<MySftpAccounts> mySftpAccountsList) {
+		this.mySftpAccountsList = mySftpAccountsList;
+	}
+	
+}
--- a/web-api/src/main/java/com/jeesite/modules/biz/service/MySftpHostsService.java
+++ b/web-api/src/main/java/com/jeesite/modules/biz/service/MySftpHostsService.java
@@ -0,0 +1,175 @@
+package com.jeesite.modules.biz.service;
+
+import java.util.List;
+import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
+
+import com.jeesite.common.entity.Page;
+import com.jeesite.common.service.CrudService;
+import com.jeesite.modules.biz.entity.MySftpHosts;
+import com.jeesite.modules.biz.dao.MySftpHostsDao;
+import com.jeesite.common.service.ServiceException;
+import com.jeesite.modules.biz.entity.MySftpAccounts;
+import com.jeesite.modules.biz.dao.MySftpAccountsDao;
+import com.jeesite.common.config.Global;
+import com.jeesite.common.validator.ValidatorUtils;
+import com.jeesite.common.utils.excel.ExcelImport;
+import org.springframework.web.multipart.MultipartFile;
+import jakarta.validation.ConstraintViolation;
+import jakarta.validation.ConstraintViolationException;
+
+/**
+ * 主机信息表 Service
+ * @author gaoxq
+ * @version 2026-04-12
+ */
+@Service
+public class MySftpHostsService extends CrudService<MySftpHostsDao, MySftpHosts> {
+
+	private final MySftpAccountsDao mySftpAccountsDao;
+
+	public MySftpHostsService(MySftpAccountsDao mySftpAccountsDao) {
+		this.mySftpAccountsDao = mySftpAccountsDao;
+	}
+
+	/**
+	 * 获取单条数据
+	 * @param mySftpHosts 主键
+	 */
+	@Override
+	public MySftpHosts get(MySftpHosts mySftpHosts) {
+		MySftpHosts entity = super.get(mySftpHosts);
+		if (entity != null){
+			MySftpAccounts mySftpAccounts = new MySftpAccounts(entity);
+			mySftpAccounts.setStatus(MySftpAccounts.STATUS_NORMAL);
+			entity.setMySftpAccountsList(mySftpAccountsDao.findList(mySftpAccounts));
+		}
+		return entity;
+	}
+	
+	/**
+	 * 查询分页数据
+	 * @param mySftpHosts 查询条件
+	 * @param mySftpHosts page 分页对象
+	 */
+	@Override
+	public Page<MySftpHosts> findPage(MySftpHosts mySftpHosts) {
+		return super.findPage(mySftpHosts);
+	}
+	
+	/**
+	 * 查询列表数据
+	 * @param mySftpHosts 查询条件
+	 */
+	@Override
+	public List<MySftpHosts> findList(MySftpHosts mySftpHosts) {
+		return super.findList(mySftpHosts);
+	}
+	
+	/**
+	 * 查询子表分页数据
+	 * @param mySftpAccounts
+	 * @param mySftpAccounts page 分页对象
+	 */
+	public Page<MySftpAccounts> findSubPage(MySftpAccounts mySftpAccounts) {
+		Page<MySftpAccounts> page = mySftpAccounts.getPage();
+		page.setList(mySftpAccountsDao.findList(mySftpAccounts));
+		return page;
+	}
+	
+	/**
+	 * 保存数据（插入或更新）
+	 * @param mySftpHosts 数据对象
+	 */
+	@Override
+	@Transactional
+	public void save(MySftpHosts mySftpHosts) {
+		super.save(mySftpHosts);
+		// 保存 MySftpHosts子表
+		for (MySftpAccounts mySftpAccounts : mySftpHosts.getMySftpAccountsList()){
+			if (!MySftpAccounts.STATUS_DELETE.equals(mySftpAccounts.getStatus())){
+				mySftpAccounts.setHostId(mySftpHosts);
+				if (mySftpAccounts.getIsNewRecord()){
+					mySftpAccountsDao.insert(mySftpAccounts);
+				}else{
+					mySftpAccountsDao.update(mySftpAccounts);
+				}
+			}else{
+				mySftpAccountsDao.delete(mySftpAccounts);
+			}
+		}
+	}
+
+	/**
+	 * 导入数据
+	 * @param file 导入的数据文件
+	 */
+	@Transactional
+	public String importData(MultipartFile file) {
+		if (file == null){
+			throw new ServiceException(text("请选择导入的数据文件！"));
+		}
+		int successNum = 0; int failureNum = 0;
+		StringBuilder successMsg = new StringBuilder();
+		StringBuilder failureMsg = new StringBuilder();
+		try(ExcelImport ei = new ExcelImport(file, 2, 0)){
+			List<MySftpHosts> list = ei.getDataList(MySftpHosts.class);
+			for (MySftpHosts mySftpHosts : list) {
+				try{
+					ValidatorUtils.validateWithException(mySftpHosts);
+					this.save(mySftpHosts);
+					successNum++;
+					successMsg.append("<br/>" + successNum + "、编号 " + mySftpHosts.getId() + " 导入成功");
+				} catch (Exception e) {
+					failureNum++;
+					String msg = "<br/>" + failureNum + "、编号 " + mySftpHosts.getId() + " 导入失败：";
+					if (e instanceof ConstraintViolationException){
+						ConstraintViolationException cve = (ConstraintViolationException)e;
+						for (ConstraintViolation<?> violation : cve.getConstraintViolations()) {
+							msg += Global.getText(violation.getMessage()) + " ("+violation.getPropertyPath()+")";
+						}
+					}else{
+						msg += e.getMessage();
+					}
+					failureMsg.append(msg);
+					logger.error(msg, e);
+				}
+			}
+		} catch (Exception e) {
+			logger.error(e.getMessage(), e);
+			failureMsg.append(e.getMessage());
+			return failureMsg.toString();
+		}
+		if (failureNum > 0) {
+			failureMsg.insert(0, "很抱歉，导入失败！共 " + failureNum + " 条数据格式不正确，错误如下：");
+			throw new ServiceException(failureMsg.toString());
+		}else{
+			successMsg.insert(0, "恭喜您，数据已全部导入成功！共 " + successNum + " 条，数据如下：");
+		}
+		return successMsg.toString();
+	}
+	
+	/**
+	 * 更新状态
+	 * @param mySftpHosts 数据对象
+	 */
+	@Override
+	@Transactional
+	public void updateStatus(MySftpHosts mySftpHosts) {
+		super.updateStatus(mySftpHosts);
+	}
+	
+	/**
+	 * 删除数据
+	 * @param mySftpHosts 数据对象
+	 */
+	@Override
+	@Transactional
+	public void delete(MySftpHosts mySftpHosts) {
+		super.delete(mySftpHosts);
+		MySftpAccounts mySftpAccounts = new MySftpAccounts();
+		mySftpAccounts.setHostId(mySftpHosts);
+		mySftpAccountsDao.deleteByEntity(mySftpAccounts);
+	}
+	
+}
--- a/web-api/src/main/java/com/jeesite/modules/biz/web/MySftpHostsController.java
+++ b/web-api/src/main/java/com/jeesite/modules/biz/web/MySftpHostsController.java
@@ -0,0 +1,159 @@
+package com.jeesite.modules.biz.web;
+
+import java.util.List;
+import jakarta.servlet.http.HttpServletRequest;
+import jakarta.servlet.http.HttpServletResponse;
+
+import org.apache.shiro.authz.annotation.RequiresPermissions;
+import org.springframework.stereotype.Controller;
+import org.springframework.ui.Model;
+import org.springframework.validation.annotation.Validated;
+import org.springframework.web.bind.annotation.ModelAttribute;
+import org.springframework.web.bind.annotation.PostMapping;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.ResponseBody;
+
+import com.jeesite.common.config.Global;
+import com.jeesite.common.collect.ListUtils;
+import com.jeesite.common.entity.Page;
+import com.jeesite.common.lang.DateUtils;
+import com.jeesite.common.utils.excel.ExcelExport;
+import com.jeesite.common.utils.excel.annotation.ExcelField.Type;
+import org.springframework.web.multipart.MultipartFile;
+import com.jeesite.common.web.BaseController;
+import com.jeesite.modules.biz.entity.MySftpHosts;
+import com.jeesite.modules.biz.entity.MySftpAccounts;
+import com.jeesite.modules.biz.service.MySftpHostsService;
+
+/**
+ * 主机信息表 Controller
+ * @author gaoxq
+ * @version 2026-04-12
+ */
+@Controller
+@RequestMapping(value = "${adminPath}/biz/mySftpHosts")
+public class MySftpHostsController extends BaseController {
+
+	private final MySftpHostsService mySftpHostsService;
+
+	public MySftpHostsController(MySftpHostsService mySftpHostsService) {
+		this.mySftpHostsService = mySftpHostsService;
+	}
+	
+	/**
+	 * 获取数据
+	 */
+	@ModelAttribute
+	public MySftpHosts get(String hostId, boolean isNewRecord) {
+		return mySftpHostsService.get(hostId, isNewRecord);
+	}
+	
+	/**
+	 * 查询列表
+	 */
+	@RequiresPermissions("biz:mySftpHosts:view")
+	@RequestMapping(value = {"list", ""})
+	public String list(MySftpHosts mySftpHosts, Model model) {
+		model.addAttribute("mySftpHosts", mySftpHosts);
+		return "modules/biz/mySftpHostsList";
+	}
+	
+	/**
+	 * 查询列表数据
+	 */
+	@RequiresPermissions("biz:mySftpHosts:view")
+	@RequestMapping(value = "listData")
+	@ResponseBody
+	public Page<MySftpHosts> listData(MySftpHosts mySftpHosts, HttpServletRequest request, HttpServletResponse response) {
+		mySftpHosts.setPage(new Page<>(request, response));
+		Page<MySftpHosts> page = mySftpHostsService.findPage(mySftpHosts);
+		return page;
+	}
+	
+	/**
+	 * 查询子表数据
+	 */
+	@RequiresPermissions("biz:mySftpHosts:view")
+	@RequestMapping(value = "mySftpAccountsListData")
+	@ResponseBody
+	public Page<MySftpAccounts> subListData(MySftpAccounts mySftpAccounts, HttpServletRequest request, HttpServletResponse response) {
+		mySftpAccounts.setPage(new Page<>(request, response));
+		Page<MySftpAccounts> page = mySftpHostsService.findSubPage(mySftpAccounts);
+		return page;
+	}
+
+	/**
+	 * 查看编辑表单
+	 */
+	@RequiresPermissions("biz:mySftpHosts:view")
+	@RequestMapping(value = "form")
+	public String form(MySftpHosts mySftpHosts, Model model) {
+		model.addAttribute("mySftpHosts", mySftpHosts);
+		return "modules/biz/mySftpHostsForm";
+	}
+
+	/**
+	 * 保存数据
+	 */
+	@RequiresPermissions("biz:mySftpHosts:edit")
+	@PostMapping(value = "save")
+	@ResponseBody
+	public String save(@Validated MySftpHosts mySftpHosts) {
+		mySftpHostsService.save(mySftpHosts);
+		return renderResult(Global.TRUE, text("保存主机成功！"));
+	}
+
+	/**
+	 * 导出数据
+	 */
+	@RequiresPermissions("biz:mySftpHosts:view")
+	@RequestMapping(value = "exportData")
+	public void exportData(MySftpHosts mySftpHosts, HttpServletResponse response) {
+		List<MySftpHosts> list = mySftpHostsService.findList(mySftpHosts);
+		String fileName = "主机" + DateUtils.getDate("yyyyMMddHHmmss") + ".xlsx";
+		try(ExcelExport ee = new ExcelExport("主机", MySftpHosts.class)){
+			ee.setDataList(list).write(response, fileName);
+		}
+	}
+
+	/**
+	 * 下载模板
+	 */
+	@RequiresPermissions("biz:mySftpHosts:view")
+	@RequestMapping(value = "importTemplate")
+	public void importTemplate(HttpServletResponse response) {
+		MySftpHosts mySftpHosts = new MySftpHosts();
+		List<MySftpHosts> list = ListUtils.newArrayList(mySftpHosts);
+		String fileName = "主机模板.xlsx";
+		try(ExcelExport ee = new ExcelExport("主机", MySftpHosts.class, Type.IMPORT)){
+			ee.setDataList(list).write(response, fileName);
+		}
+	}
+
+	/**
+	 * 导入数据
+	 */
+	@ResponseBody
+	@RequiresPermissions("biz:mySftpHosts:edit")
+	@PostMapping(value = "importData")
+	public String importData(MultipartFile file) {
+		try {
+			String message = mySftpHostsService.importData(file);
+			return renderResult(Global.TRUE, "posfull:"+message);
+		} catch (Exception ex) {
+			return renderResult(Global.FALSE, "posfull:"+ex.getMessage());
+		}
+	}
+	
+	/**
+	 * 删除数据
+	 */
+	@RequiresPermissions("biz:mySftpHosts:edit")
+	@RequestMapping(value = "delete")
+	@ResponseBody
+	public String delete(MySftpHosts mySftpHosts) {
+		mySftpHostsService.delete(mySftpHosts);
+		return renderResult(Global.TRUE, text("删除主机成功！"));
+	}
+	
+}
--- a/web-api/src/main/java/com/jeesite/modules/utils/DockerUtil.java
+++ b/web-api/src/main/java/com/jeesite/modules/utils/DockerUtil.java
@@ -0,0 +1,176 @@
+package com.jeesite.modules.utils;
+
+import com.jcraft.jsch.*;
+import com.jeesite.modules.apps.Module.ContainerInfo;
+import com.jeesite.modules.apps.Module.DockerResult;
+import com.jeesite.modules.biz.entity.MySftpAccounts;
+
+import java.io.*;
+import java.nio.charset.StandardCharsets;
+import java.util.ArrayList;
+import java.util.List;
+
+/**
+ * Docker 容器管理工具
+ * <p>
+ * 通过 SSH 连接主机，基于 MySftpAccounts 凭证执行 docker 命令。
+ * 支持密码认证和私钥认证。
+ */
+public class DockerUtil {
+
+    private static final int SSH_TIMEOUT = 30000;
+
+    public static DockerResult start(MySftpAccounts account, String image, String name,
+                                     String[] ports, String[] envs) {
+        StringBuilder cmd = new StringBuilder("docker run -d");
+        if (name != null && !name.isEmpty()) {
+            cmd.append(" --name ").append(name);
+        }
+        if (ports != null) {
+            for (String p : ports) cmd.append(" -p ").append(p);
+        }
+        if (envs != null) {
+            for (String e : envs) cmd.append(" -e \"").append(e).append("\"");
+        }
+        cmd.append(" ").append(image);
+        return exec(account, cmd.toString());
+    }
+
+    public static DockerResult stop(MySftpAccounts account, String containerId) {
+        return exec(account, "docker stop " + containerId);
+    }
+
+    public static DockerResult restart(MySftpAccounts account, String containerId) {
+        return exec(account, "docker restart " + containerId);
+    }
+
+    public static DockerResult getLogs(MySftpAccounts account, String containerId,
+                                       int tail, boolean timestamps) {
+        String cmd = "docker logs" + (timestamps ? " -t" : "")
+                + " --tail " + tail + " " + containerId;
+        return exec(account, cmd);
+    }
+
+    public static DockerResult list(MySftpAccounts account, boolean all) {
+        return exec(account, all ? "docker ps -a" : "docker ps");
+    }
+
+    public static DockerResult remove(MySftpAccounts account, String containerId, boolean force) {
+        String cmd = force
+                ? "docker stop " + containerId + " && docker rm " + containerId
+                : "docker rm " + containerId;
+        return exec(account, cmd);
+    }
+
+    public static DockerResult inspect(MySftpAccounts account, String containerId) {
+        return exec(account, "docker inspect " + containerId);
+    }
+
+    public static DockerResult pull(MySftpAccounts account, String image) {
+        return exec(account, "docker pull " + image);
+    }
+
+    public static DockerResult version(MySftpAccounts account) {
+        return exec(account, "docker version --format '{{json .}}'");
+    }
+
+    public static List<ContainerInfo> listContainers(MySftpAccounts account, boolean all) {
+        List<ContainerInfo> list = new ArrayList<>();
+        String cmd = (all ? "docker ps -a" : "docker ps")
+                + " --format \"{{.ID}}|{{.Image}}|{{.Command}}|{{.CreatedAt}}|{{.Status}}|{{.Ports}}|{{.Names}}\"";
+        DockerResult r = exec(account, cmd);
+        if (!r.isSuccess()) {
+            return new ArrayList<>();
+        }
+        for (String line : r.getOutput().split("\n")) {
+            if (line.trim().isEmpty()) continue;
+            String[] p = line.split("\\|");
+            if (p.length < 2) continue;
+            ContainerInfo info = new ContainerInfo();
+            info.setContainerId(p.length > 0 ? p[0].trim() : "");
+            info.setImage(p.length > 1 ? p[1].trim() : "");
+            info.setCommand(p.length > 2 ? p[2].trim() : "");
+            info.setCreated(p.length > 3 ? p[3].trim() : "");
+            info.setStatus(p.length > 4 ? p[4].trim() : "");
+            info.setPorts(p.length > 5 ? p[5].trim() : "");
+            info.setNames(p.length > 6 ? p[6].trim() : "");
+            list.add(info);
+        }
+        return list;
+    }
+
+    public static DockerResult exec(MySftpAccounts account, String command) {
+        JSch jsch = new JSch();
+        Session session = null;
+        ChannelExec channel = null;
+        try {
+            Integer port = account.getHostPort() != null ? account.getHostPort() : 22;
+            session = jsch.getSession(account.getUsername(), account.getHostIp(), port);
+            session.setTimeout(SSH_TIMEOUT);
+
+            if ("key".equalsIgnoreCase(account.getAuthType())
+                    && account.getPrivateKey() != null && !account.getPrivateKey().isEmpty()) {
+                jsch.addIdentity("temp",
+                        account.getPrivateKey().getBytes(StandardCharsets.UTF_8),
+                        null, null);
+            } else if (account.getPassword() != null && !account.getPassword().isEmpty()) {
+                session.setPassword(account.getPassword());
+            } else {
+                return DockerResult.fail("SSH 认证信息不完整：缺少密码或私钥");
+            }
+
+            java.util.Hashtable<String, String> config = new java.util.Hashtable<>();
+            config.put("StrictHostKeyChecking", "no");
+            session.setConfig(config);
+            session.connect(SSH_TIMEOUT);
+
+            channel = (ChannelExec) session.openChannel("exec");
+            String finalCmd = (account.getRootPath() != null && !account.getRootPath().isEmpty())
+                    ? "cd " + account.getRootPath() + " && " + command
+                    : command;
+            channel.setCommand(finalCmd);
+            channel.setInputStream(null);
+
+            InputStream in = channel.getInputStream();
+            ByteArrayOutputStream errOut = new ByteArrayOutputStream();
+            channel.setExtOutputStream(errOut);
+
+            channel.connect();
+
+            StringBuilder outBuilder = new StringBuilder();
+            if (in != null) {
+                byte[] buf = new byte[4096];
+                int n;
+                while ((n = in.read(buf)) != -1) {
+                    outBuilder.append(new String(buf, 0, n, StandardCharsets.UTF_8));
+                }
+            }
+
+            while (!channel.isClosed()) {
+                Thread.sleep(50);
+            }
+
+            String stdout = outBuilder.toString().trim();
+            String stderr = errOut.toString(StandardCharsets.UTF_8).trim();
+            int exitCode = channel.getExitStatus();
+
+            if (exitCode == 0) {
+                return DockerResult.ok(stdout);
+            } else {
+                return DockerResult.fail("命令执行失败，退出码: " + exitCode,
+                        stderr.isEmpty() ? stdout : stderr);
+            }
+
+        } catch (JSchException e) {
+            return DockerResult.fail("SSH 连接失败: " + e.getMessage());
+        } catch (IOException e) {
+            return DockerResult.fail("IO 异常: " + e.getMessage());
+        } catch (InterruptedException e) {
+            Thread.currentThread().interrupt();
+            return DockerResult.fail("执行被中断");
+        } finally {
+            if (channel != null && channel.isConnected()) channel.disconnect();
+            if (session != null && session.isConnected()) session.disconnect();
+        }
+    }
+}
--- a/web-api/src/main/resources/mappings/modules/biz/MySftpAccountsDao.xml
+++ b/web-api/src/main/resources/mappings/modules/biz/MySftpAccountsDao.xml
@@ -0,0 +1,15 @@
+<?xml version="1.0" encoding="UTF-8" ?>
+<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
+<mapper namespace="com.jeesite.modules.biz.dao.MySftpAccountsDao">
+	
+	<!-- 查询数据
+	<select id="findList" resultType="MySftpAccounts">
+		SELECT ${sqlMap.column.toSql()}
+		FROM ${sqlMap.table.toSql()}
+		<where>
+			${sqlMap.where.toSql()}
+		</where>
+		ORDER BY ${sqlMap.order.toSql()}
+	</select> -->
+	
+</mapper>
--- a/web-api/src/main/resources/mappings/modules/biz/MySftpHostsDao.xml
+++ b/web-api/src/main/resources/mappings/modules/biz/MySftpHostsDao.xml
@@ -0,0 +1,15 @@
+<?xml version="1.0" encoding="UTF-8" ?>
+<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
+<mapper namespace="com.jeesite.modules.biz.dao.MySftpHostsDao">
+	
+	<!-- 查询数据
+	<select id="findList" resultType="MySftpHosts">
+		SELECT ${sqlMap.column.toSql()}
+		FROM ${sqlMap.table.toSql()}
+		<where>
+			${sqlMap.where.toSql()}
+		</where>
+		ORDER BY ${sqlMap.order.toSql()}
+	</select> -->
+	
+</mapper>