一、设置人工干预，决定是否部署到生产环境

1.1.脚本

#!groovy

stage("确认部署到生产"){
    def inputResp = input id: "input_${BUILD_NUMBER}", message: '''确认部署到生产请输入：approve''', parameters: [string(defaultValue: '', description: '''确认是否部署到生产，输入指令后点击Proceed，终止请点击Abort''', name: 'action')]
    
    if(inputResp != "approve")
    {
        throw new Exception("The input is incorrect, we abort this job..")
    }
    println "开始部署到生产......"
}

1.2.执行效果

二、设置人工干预，定义执行动作(可从失败的stage执行)

传入stagesRun的参数确定的情况

脚本

#!groovy

def ansible_path = "/etc/ansible/ansible_playbooks"
timestamps{    
    try {
        node(){
        	stage("配置安装参数"){
                echo "配置安装参数"
            }
            stage("安装docker"){
                stagesRun("installDocker",ansible_path)
            }        
        }//node
    }//try
    catch(Exception err){
        throw new Exception("*******Caught an exception: ${err}")
    }//catch
}

//install docker
def installDocker(ansible_path){
    dir(ansible_path){
        ansiblePlaybook become: true, 
        becomeUser: 'root',				//相当于sudo
        disableHostKeyChecking: true, 
        inventory: '/etc/ansible/hosts', 
        playbook: 'install_docker.yml',
        colorized: true
        //  extraVars: [
        // 	 DBPasswd: DB_pwd
        //  ]
    }
}

def stagesRun(stage_name,ansible_path){
    def nodeId = "node" +  new SimpleDateFormat("YYYYMMddHHmmss").format(Calendar.getInstance().getTime())
    def errorFlag = false
    while(true)
    {
        if (errorFlag)
        {
            def desc = '''请选择下一步动作指令后点击Proceed，要终止请点击Abort'''
            def inputResp = input id: "input_${nodeId}", 
                                        message: "${stage_name}执行失败，请选择下一步动作：", 
                                        parameters: [choice(choices:['retry','skip'], description: desc, name: 'action')]
            if ('skip' == inputResp)
            {
                return
            }
            if('retry' == inputResp)
            {
                echo "重试"
            }
        }//if (errorFlag)
        try
        {
            "${stage_name}"("${ansible_path}")
            break
        }
        catch(Exception err)
        {
            errorFlag = true
            echo "Caught: ${err}"
        }
    }//while(true)
}

传入的参数不确定的情况

主程序

function = load "${WORKSPACE}/jenkinsfile/common.groovy"
def parmList = [a,b,c,d]		//将要传入的参数放到列表里面
function.stagesRun("flywayUpgradeSql",gitProduct,parmList)	

common.groovy

#!groovy
/**
 * @description: 通过flyway升级数据库
 * @param:  [数据库用户名,密码,jdbc_url,flyway升级sql的路径]
 * @return: null
 */
def flywayUpgradeSql(paramList){
    def dbUser = paramList[0]
    def dbPwd = paramList[1]
    def dbUrl = paramList[2]
    def sqlPath = paramList[3]
    sh """
        source /etc/profile
        [[ ! -d ${sqlPath} ]] && echo "ERROR:${sqlPath} Not Found" && exit 1
        /home/admin/flyway-4.2.0/flyway \\
        -user=${dbUser} -password=${dbPwd} \\
        -url=${dbUrl} -locations=filesystem:${sqlPath} \\
        -baselineOnMigrate=true -validateOnMigrate=false -placeholderReplacement=false \\
        repair migrate
    """
}

//运行stage
def stagesRun(stageName,gitProduct,parmList){
    def errorFlag = false
    while(true)
    {
        if (errorFlag)
        {
            def desc = '''请选择下一步动作指令后点击Proceed，要终止请点击Abort'''
            def inputResp = input id: "input_${BUILD_NUMBER}",
                    message: "${stageName}执行失败，请选择下一步动作：",
                    parameters: [choice(choices:['retry','skip'], description: desc, name: 'action')]
            if ('skip' == inputResp)
            {
                return
            }
            if('retry' == inputResp)
            {
                echo "重试"
                sh """
                    for name in `echo ${gitProduct}`
                    do
                    {
                        name=\${name##*/}
                        cd ${WORKSPACE}/\$name
                        git pull
                     } &
                    done
                    wait
                    cd ${WORKSPACE}/devops && git pull
                """
            }
        }//if (errorFlag)
        try
        {
            "${stageName}"(parmList)
            break
        }
        catch(Exception err)
        {
            errorFlag = true
            echo "Caught: ${err}"
        }
    }//while(true)
}

return this		//这句一定得写，不然不能调用

2.2.执行效果