// 釋出/回滾/滾動升級 公共方法
func HandlePRR(c *gin.Context, timesince time.Time, action, virtual_name, skyeye, workid string, fn func(*lcmongo.Program, lcmongo.Spec, chan error, string)) {
   // 更新資料庫 釋出時間/滾動升級時間/回滾時間  欄位
now, err := UpdateTimeField(action, virtual_name, skyeye)
   if err != nil {
      MongoDBError(c, 
 
Update, err, timesince)
      return
}
   
   ProgramQuery(c, skyeye, virtual_name, timesince, func(program *lcmongo.Program, value lcmongo.Spec) {
      // 針對action = "publish"進行判斷，禁止重複釋出
if action == "publish" && value.Status == 1 {
         message := fmt.Sprintf("Project: [%s] has been publish, Please don't republish!"
 
, virtual_name)
         GeneralError(c, conflict, message, timesince)
         return
}

      ch := make(chan error)
      ticker, timeout := TickerTimeOut(action)

      deployment_name := fmt.Sprintf("deployment-%s", value.Name)
      go func(p *lcmongo.Program, value lcmongo.Spec, ch_ chan error
 
, deployment_name string) {
            // 針對不同的action(publish/rollingupdate/rollback)
            // 自己寫處理邏輯
fn(p, value, ch_, deployment_name)
      }(program, value, ch, deployment_name)

      select {
      case err := <-ch:
         close(ch)
         // kubernetes統一錯誤錯誤
if err != nil {
            KubernetesError(c, Query, err, timesince)
            return
}

         // 開啟定時器，不斷輪詢查詢deployment的pod數量
         // 後續改成watche controller，效能更好
for {
            select {
            case <-ticker:
               deployment, err := K8s_Client.GetSpecNameSpaceDeployment(value.NameSpace, deployment_name)
               if err != nil {
                  KubernetesError(c, Query, err, timesince)
                  return
}

               // pod數量達到預期，釋出成功，後期處理
if deployment.Status.UpdatedReplicas == int32(value.Replicas) &&
                  deployment.Status.AvailableReplicas == int32(value.Replicas) &&
                  deployment.Status.Replicas == int32(value.Replicas){
                  end_time := strconv.FormatInt(time.Now().Unix(), 10)
                  his := &lcmongo.HistoryLog{
                     Id: bson.NewObjectId(),
WorkdId: workid,
Skyeye: skyeye,
Virtual_Name: virtual_name,
NameSpace: value.NameSpace,
Operation_Type: action,
Start_Time: now,
End_Time: end_time,
}

                  if err := lcmongo.InsertDocument(Collection_HisLog, reflect.ValueOf(his)); err != nil {
                     MongoDBError(c, Insert, err, timesince)
                     return
}

                  if err := UpdateCountField(action, virtual_name, skyeye); err != nil {
                     MongoDBError(c, Update, err, timesince)
                     return
}

                  GeneralAllOk(c, timesince)
                  return
}
            case <-timeout:
               // 超時處理
defer func() {
                  // 判斷action == "publish" && 釋出失敗
                  // 則刪除kubernetes已釋出資源
if action == "publish" {
                     if err := CleanK8sResource(value.Name, value.NameSpace); err != nil {
                        KubernetesError(c, Delete, err, timesince)
                        return
}
                  }
               }()

               GeneralError(c, internalserver_error, "timeout!", timesince)
               return
}
         }
      }
   })
}