Method BatchOperate

agent/app/service/agents.go:421–477

(req dto.AgentBatchOperateReq)

}

func (a AgentService) BatchOperate(req dto.AgentBatchOperateReq) ([]dto.AgentBatchOperateResult, error) {
	operate := constant.AppOperate(strings.TrimSpace(req.Operate))
	if operate != constant.Start && operate != constant.Stop && operate != constant.Restart && operate != constant.Delete {
		return nil, fmt.Errorf("operate %s is not supported", req.Operate)
	}
	agents, err := listBatchAgents(req.AgentType)
	if err != nil {
		return nil, err
	}
	results := make([]dto.AgentBatchOperateResult, 0, len(agents))
	for _, agent := range agents {
		result := dto.AgentBatchOperateResult{
			AgentID:      agent.ID,
			AgentName:    agent.Name,
			AppInstallID: agent.AppInstallID,
		}
		if operate == constant.Delete {
			if err := a.Delete(dto.AgentDeleteReq{
				ID:          agent.ID,
				TaskID:      buildBatchOperateTaskID(req.TaskID, agent.ID),
				ForceDelete: req.ForceDelete,
			}); err != nil {
				result.Message = err.Error()
			} else {
				result.Success = true
			}
			results = append(results, result)
			continue
		}
		ctx, message := loadBatchAgentInstall(agent, req.AgentType)
		if message != "" {
			result.Message = message
			results = append(results, result)
			continue
		}
		install := ctx.install
		result.AppInstallID = install.ID
		if message := batchOperateSkipMessage(operate, install.Status); message != "" {
			result.Success = true
			result.Skipped = true
			result.Message = message
			results = append(results, result)
			continue
		}
		if err := NewIAppInstalledService().Operate(request.AppInstalledOperate{
			InstallId: install.ID,
			Operate:   operate,
			TaskID:    buildBatchOperateTaskID(req.TaskID, agent.ID),
		}); err != nil {
			result.Message = err.Error()
		} else {
			result.Success = true
		}
		results = append(results, result)
	}
	return results, nil
}