当前位置：首页 > news >正文

golang连接jenkins构建build

news 2025/6/21 12:01:02

1.安装jenkins依赖

go get github.com/bndr/gojenkins

2.代码

import ("context""file/utils/logs""github.com/bndr/gojenkins""github.com/gin-gonic/gin""net/http""time"
)// 接收单个静态文件上线参数
type ReceiveParametersForDeployingASingleStaticFile struct {StaticFileName string `json:"staticFileName"`BuildJobDate   string `json:"buildjobdate"`
}// 返回给前端数据
type ReturnJenkinsData struct {BuildResult interface{} `json:"buildResult"`BuildLog    interface{} `json:"buildLog"`BuildNumber interface{} `json:"buildNumber"`BuildName   interface{} `json:"buildName"`
}func UpdataSingleStaticFile(r *gin.Context) {//实例化接收参数的结构体var receiveParameters ReceiveParametersForDeployingASingleStaticFilectx := context.Background()//接收前端传递过来的参数error := r.ShouldBindBodyWithJSON(&receiveParameters)if error != nil {logs.Error(map[string]interface{}{"msg": error}, "接收更新参数失败！请检查前端选择的参数是否正确！")r.JSON(http.StatusBadRequest, gin.H{"msg": error})return}//创建jenkins连接jenkins := gojenkins.CreateJenkins(nil, JenkinsUrl, JenkinsUser, JenkinsPass)_, err := jenkins.Init(ctx)if err != nil {logs.Error(map[string]interface{}{"msg": err}, "连接jenkins失败，请检查用户名密码和Url地址是否正确！")r.JSON(http.StatusInternalServerError, gin.H{"msg": err})return}logs.Info(map[string]interface{}{"msg": "连接jenkins成功！"}, "jenkins已连接,更新正在继续！")//创建一个map将参数传递给jenkinsreturnParm := make(map[string]string)returnParm["static_project"] = receiveParameters.StaticFileNamereturnParm["buildJobDate"] = receiveParameters.BuildJobDate//调用jenkins构建job并将参数传递给jenkinsqueueId, buErr := jenkins.BuildJob(ctx, "update-static", returnParm)//fmt.Println(receiveParameters.StaticFileName, "------", receiveParameters.BuildJobDate)if buErr != nil {logs.Error(map[string]interface{}{"msg": "构建失败"}, "请检查配置或者服务是否存在！")r.JSON(http.StatusInternalServerError, gin.H{"msg": buErr})return} else {build, err := jenkins.GetBuildFromQueueID(ctx, queueId)if err != nil {logs.Error(map[string]interface{}{"msg": "获取构建信息失败！"}, "请检查Jenkins信息具体报错位置")r.JSON(http.StatusInternalServerError, gin.H{"msg": err})return}// 等待构建完成for build.IsRunning(ctx) {time.Sleep(5000 * time.Millisecond)build.Poll(ctx)}//fmt.Printf("build number %d with result: %v\n", build.GetBuildNumber(), build.GetResult())returnJenkinsData := ReturnJenkinsData{BuildResult: build.GetResult(),BuildLog:    ctx,BuildNumber: build.GetBuildNumber(),BuildName:   receiveParameters.StaticFileName,}//返回给前端构建结果r.JSON(http.StatusOK,gin.H{"status":  http.StatusOK,"message": "升级成功！","data":    returnJenkinsData,})}
}