io.jpom.service.node.command

Class CommandService

java.lang.Object

io.jpom.service.h2db.BaseDbCommonService<T>

io.jpom.service.h2db.BaseDbService<T>

io.jpom.service.h2db.BaseWorkspaceService<CommandModel>

io.jpom.service.node.command.CommandService

All Implemented Interfaces:

ICron<CommandModel>, ITriggerToken

@Service
public class CommandService
extends BaseWorkspaceService<CommandModel>
implements ICron<CommandModel>, ITriggerToken

命令管理

Since:

: 2021/12/6 22:11

Author:

: Arno

Field Summary

Fields inherited from class io.jpom.service.h2db.BaseDbCommonService

key, tableName, tClass

Constructor Summary

Constructors

Constructor and Description
CommandService(SshService sshService, CommandExecLogService commandExecLogService, WorkspaceEnvVarService workspaceEnvVarService)

Method Summary

Modifier and Type	Method and Description
List<cn.hutool.db.Entity>	allEntityTokens() 当前数据所有 的 token
boolean	checkCron(CommandModel buildInfoModel) 检查定时任务 状态
int	delByKey(String keyValue, javax.servlet.http.HttpServletRequest request) 删除
String	executeBatch(CommandModel commandModel, String params, String nodes, int triggerExecType) 批量执行命令
String	executeBatch(String id, String params, String nodes) 批量执行命令
void	insert(CommandModel commandModel) 插入数据
List<CommandModel>	queryStartingList() 开启定时构建任务
void	syncToWorkspace(String ids, String nowWorkspaceId, String workspaceId) 将ssh 脚本信息同步到其他工作空间
String	typeName() 类型 名称
int	updateById(CommandModel info, javax.servlet.http.HttpServletRequest request) 更新数据,根据ID+工作空间ID

Methods inherited from class io.jpom.service.h2db.BaseWorkspaceService

checkUserWorkspace, checkUserWorkspace, defaultOrders, delByWorkspace, fillInsert, getByKey, getByKey, getCheckUserWorkspace, getWorkspaceId, listById, listByWorkspace, listPage, sortMoveDown, sortMoveUp, sortToTop

Methods inherited from class io.jpom.service.h2db.BaseDbService

autoClear, autoLoopClear, clearTimeColumns, count, count, covetTableName, executeClearImpl, getData, getLastTimeValue, insert, insertNotFill, list, listById, listById, listPage, listPage, parsePage, update, updateById, updateById, upsert

Methods inherited from class io.jpom.service.h2db.BaseDbCommonService

count, count, dataBeanToEntity, del, delByKey, delByKey, entityToBean, entityToBean, entityToBeanList, execute, exists, exists, fillSelectResult, findByCondition, getByKey, getByKey, getByKey, getKey, getTableName, insert, listByBean, listByEntity, listPageOnlyResult, query, query, queryByBean, queryList, queryList, queryList, update, warpException

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface io.jpom.cron.ICron

startCron

Methods inherited from interface io.jpom.service.ITriggerToken

allTokens

Constructor Detail

CommandService

public CommandService(SshService sshService,
                      CommandExecLogService commandExecLogService,
                      WorkspaceEnvVarService workspaceEnvVarService)

Method Detail

insert

public void insert(CommandModel commandModel)

Description copied from class: BaseDbCommonService

插入数据

Overrides:

insert in class BaseDbService<CommandModel>

Parameters:

commandModel - 数据

updateById

public int updateById(CommandModel info,
                      javax.servlet.http.HttpServletRequest request)

Description copied from class: BaseWorkspaceService

更新数据,根据ID+工作空间ID

Overrides:

updateById in class BaseWorkspaceService<CommandModel>

Parameters:

info - 更新的数据

request - 请求

Returns:

影响行数

delByKey

public int delByKey(String keyValue,
                    javax.servlet.http.HttpServletRequest request)

Description copied from class: BaseWorkspaceService

删除

Overrides:

delByKey in class BaseWorkspaceService<CommandModel>

Parameters:

keyValue - 主键

request - 请求信息

Returns:

影响行数

checkCron

public boolean checkCron(CommandModel buildInfoModel)

检查定时任务 状态

Specified by:

checkCron in interface ICron<CommandModel>

Parameters:

buildInfoModel - 构建信息

Returns:

true 开启定时、false 关闭定时

queryStartingList

public List<CommandModel> queryStartingList()

开启定时构建任务

Specified by:

queryStartingList in interface ICron<CommandModel>

Returns:

list

typeName

public String typeName()

Description copied from interface: ITriggerToken

类型 名称

Specified by:

typeName in interface ITriggerToken

Returns:

数据分类名称

allEntityTokens

public List<cn.hutool.db.Entity> allEntityTokens()

Description copied from interface: ITriggerToken

当前数据所有 的 token

Specified by:

allEntityTokens in interface ITriggerToken

Returns:

list Entity

executeBatch

public String executeBatch(String id,
                           String params,
                           String nodes)

批量执行命令

Parameters:

id - 命令 id

nodes - ssh节点

params - 参数

Returns:

批次ID

executeBatch

public String executeBatch(CommandModel commandModel,
                           String params,
                           String nodes,
                           int triggerExecType)

批量执行命令

Parameters:

commandModel - 命令模版

nodes - ssh节点

params - 参数

Returns:

批次ID

syncToWorkspace

public void syncToWorkspace(String ids,
                            String nowWorkspaceId,
                            String workspaceId)

将ssh 脚本信息同步到其他工作空间

Parameters:

ids - 多给节点ID

nowWorkspaceId - 当前的工作空间ID

workspaceId - 同步到哪个工作空间