Method Publish

module/publish/iml.go:568–638

(ctx context.Context, serviceId string, id string)

}

func (i *imlPublishModule) Publish(ctx context.Context, serviceId string, id string) error {
	_, err := i.serviceService.Check(ctx, serviceId, asServer)
	if err != nil {
		return err
	}
	flow, err := i.publishService.Get(ctx, id)
	if err != nil {
		return err
	}
	if flow.Service != serviceId {
		return errors.New("服务不一致")
	}
	if flow.Status != publish.StatusAccept && flow.Status != publish.StatusDone {
		return errors.New("只有通过状态才能发布")
	}
	clusters, err := i.clusterService.List(ctx)
	if err != nil {
		return err
	}
	clusterIds := utils.SliceToSlice(clusters, func(i *cluster.Cluster) string {
		return i.Uuid
	})

	projectReleaseMap, err := i.getReleaseInfo(ctx, serviceId, flow.Release, flow.Release, clusterIds)
	if err != nil {
		return err
	}
	hasError := false
	return i.transaction.Transaction(ctx, func(ctx context.Context) error {
		for _, c := range clusters {
			err = i.publish(ctx, flow.Id, c.Uuid, projectReleaseMap[c.Uuid])
			if err != nil {
				hasError = true
				log.Error(err)
				continue
			}
		}
		err = i.releaseService.SetRunning(ctx, serviceId, flow.Release)
		if err != nil {
			return err
		}
		status := publish.StatusDone
		if hasError {
			status = publish.StatusPublishError
		}
		if status == publish.StatusDone {
			info, err := i.serviceService.Get(ctx, serviceId)
			if err != nil {
				return err
			}

			apiDocCommit, err := i.apiDocService.LatestDocCommit(ctx, serviceId)
			if err != nil {
				return err
			}
			isReleased := true
			i.serviceOverviewService.Update(ctx, serviceId, &service_overview.Update{
				ReleaseApiCount: &apiDocCommit.Data.APICount,