xg_auto_deploy/internal/auto/send_cmd.go

package auto

import (
	"fmt"
	"xg_auto_deploy/internal/global"
	"xg_auto_deploy/internal/remote"
)

func CmdToNodes(nodeIds []string, cmd string) {

	global.Logs.Infoln("----------------开始发送命令----------------------------")

	if nodeIds[0] == "all" {
		fmt.Println("is ALL")
		for _, nodeTemp := range global.ServerNodeConfigs {

			msg, err := remote.SingleCmd(&nodeTemp, cmd)
			if err != nil {
				global.Logs.Errorf("节点%s 发送命令失败:%s \n", nodeTemp.NodeId, err)
				return
			}
			global.Logs.Infof("节点%s 发送命令成功:%s", nodeTemp.NodeId, msg)
		}
		return
	}

	if !IsNumericArray(nodeIds) {
		fmt.Println("传入指定节点参数错误，请检查：", nodeIds)
		return
	}

	for _, NodeId := range nodeIds {
		nodeTemp := global.ServerNodeConfigs[NodeId]

		msg, err := remote.SingleCmd(&nodeTemp, cmd)
		if err != nil {
			global.Logs.Errorf("节点%s 发送命令失败:%s \n", nodeTemp.NodeId, err)
			return
		}
		global.Logs.Infof("节点%s 发送命令成功:%s", nodeTemp.NodeId, msg)
	}
}