/**
 * @author chenlang
 * date 2018/5/7
 */
@Slf4j
public class JenkinsPromotionUtils {
 
 
    private static final String SUB_PATH_PROMOTION_COOMMAND = "/hudson.plugins.promoted__builds.PromotionProcess";
    private static final String SUB_PATH_BUILD = "/buildSteps";
    private static final String SUB_PATH_BUILDER_SHELL_COMMAND = "/hudson.tasks.Shell/command";
    private static final String PATH_PROMOTION_COMMAND = SUB_PATH_PROMOTION_COOMMAND + SUB_PATH_BUILD + SUB_PATH_BUILDER_SHELL_COMMAND;
    private static String CREATE_PROMOTION_JSON = "{'properties':{'stapler-class-bag':'true','hudson-plugins-promoted_builds-JobPropertyImpl':{'promotions':{'activeItems':{'name':'%s','isVisible':'','icon':'star-gold','hasAssignedLabel':false,'assignedLabelString':'','conditions':{'stapler-class-bag':'true'}}}}}}";
    private static final String CONTENT_TYPE = "application/x-www-form-urlencoded";
 
 
    public static void updatePromotionShell(Document jobConfigDocument, String jobName, JenkinsPromotionClient jenkinsPromotionClient, String promotionShell, String path) throws IOException, DocumentException {
        if (StringUtils.isBlank(promotionShell)) {
            return;
        }
        String promotionName = getPromotionName(jobConfigDocument, path);
        Document document = jenkinsPromotionClient.getJobPromotionXml(jobName, promotionName);
        document.selectSingleNode(PATH_PROMOTION_COMMAND).setText(promotionShell);
        jenkinsPromotionClient.updateJob(jobName, promotionName, document.asXML());
    }
 
    public static void createPromotionShell(Document jobConfigDocument, String tmpJobName, String jobName, String promotionShell, String path, JenkinsPromotionClient jenkinsPromotionClient) throws IOException, DocumentException {
        if (StringUtils.isBlank(promotionShell)) {
            return;
        }
        String promotionName = getPromotionName(jobConfigDocument, path);
        Document document = jenkinsPromotionClient.getJobPromotionXml(tmpJobName, promotionName);
        document.selectSingleNode(PATH_PROMOTION_COMMAND).setText(promotionShell);
        Map<String, String> map = Maps.newHashMap();
        map.put("Content-Type", CONTENT_TYPE);
        map.put("json", String.format(CREATE_PROMOTION_JSON, promotionName));
        try {
            jenkinsPromotionClient.createJob(jobName, map);
        } catch (Exception e) {
            log.error("初创promotion时失败" + e);
        }
        jenkinsPromotionClient.createJob(jobName, promotionName, document.asXML());
    }
 
    public static String getPromotionName(Document jobConfigDocument, String path) {
        return jobConfigDocument.selectSingleNode(path).getText();
    }
 
}

package cn.caijiajia.phoenix.service.jenkins;
 
import com.offbytwo.jenkins.client.JenkinsHttpClient;
import com.offbytwo.jenkins.client.util.EncodingUtils;
import org.dom4j.Document;
import org.dom4j.DocumentException;
import org.dom4j.DocumentHelper;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;
 
import java.io.IOException;
import java.util.Map;
 
/**
 * @author chenlang
 * date 2018/5/4
 */
@Component
public class JenkinsPromotionClient {
 
    @Autowired
    private JenkinsHttpClient jenkinsHttpClient;
 
    public JenkinsPromotionClient() {
    }
 
    /**
     * 获取job的promotion配置文件
     *
     * @param jobName       job名称
     * @param promotionName promotion名称
     * @return
     * @throws IOException
     */
    public Document getJobPromotionXml(String jobName, String promotionName) throws IOException, DocumentException {
        return DocumentHelper.parseText(this.getJobXml(jobName, promotionName));
    }
 
 
    /**
     * 更新job
     *
     * @param jobName
     * @param promotionName
     * @param jobXml
     * @throws IOException
     */
    public void updateJob(String jobName, String promotionName, String jobXml) throws IOException {
        this.jenkinsHttpClient.post_xml(this.toJobBaseUrl(jobName, promotionName) + "/config.xml", jobXml, true);
    }
 
    /**
     * 添加job脚本
     *
     * @param jobName
     * @param jobXml
     * @throws IOException
     */
    public void createJob(String jobName, String promotionName, String jobXml) throws IOException {
        this.jenkinsHttpClient.post_xml(this.toJobBaseUrl(jobName, promotionName) + "/config.xml", jobXml, true);
    }
 
    /**
     * 添加promotion的job
     *
     * @param jobName
     * @param map
     * @throws IOException
     */
    public void createJob(String jobName, Map map) throws IOException {
        this.jenkinsHttpClient.post_form("/job/" + EncodingUtils.encode(jobName) + "/configSubmit?", map, false);
    }
 
    private String getJobXml(String jobName, String promotionName) throws IOException {
        return this.jenkinsHttpClient.get(this.toJobBaseUrl(jobName, promotionName) + "/config.xml");
    }
 
    private String toJobBaseUrl(String jobName, String promotionName) {
        return "/job/" + EncodingUtils.encode(jobName) + "/promotion/process/" + promotionName;
    }
 
    /**
     * promotion脚本的构建
     * @param jobName
     * @param promotionName
     * @param version
     * @param isFirstBuild
     * @throws IOException
     */
    public void build(String jobName,String promotionName,Integer version,boolean isFirstBuild) throws IOException{
        if (isFirstBuild) {
            this.jenkinsHttpClient.post("/job/"+ EncodingUtils.encode(jobName) + "/"+version+"/promotion/forcePromotion?name="+promotionName+"&json=%7B%7D&Submit=Force promotion");
        } else {
            this.jenkinsHttpClient.post("/job/"+ EncodingUtils.encode(jobName) + "/"+version+"/promotion/"+promotionName+"/build?json=%7B%7D&Submit=Re-execute promotion");
        }
    }
 
 
}