Function GetSyncProgress

api/controller/sync_organization.go:95–142

GetSyncProgress 获取同步进度 @Summary Get sync progress @Description Get synchronization progress @Tags Synchronization @Accept json @Produce json @Security BearerAuth @Param from path int true "Source: 1=WeCom, 2=DingTalk" @Success 200 {object} model.CommonResponse{data=interface{}} "Operation succeeded"

(c *gin.Context)

// @Failure 404 {object} model.CommonResponse "Enterprise not found"
// @Router /api/sync-progress/{from} [get]
func GetSyncProgress(c *gin.Context) {
	fromStr := c.Param("from")
	from, err := strconv.Atoi(fromStr)
	if err != nil {
		c.JSON(http.StatusBadRequest, model.ParamError.ToResponse(err))
		return
	}

	// 验证 from 参数
	if from != model.DepartmentFromWecom && from != model.DepartmentFromDingtalk {
		c.JSON(http.StatusBadRequest, model.ParamError.ToResponse(fmt.Errorf("invalid from parameter: %d", from)))
		return
	}

	var eid = config.GetEID(c)

	var progress interface{}

	switch from {
	case model.DepartmentFromWecom:
		wecomProgressManager := saas_wecom.GetWecomSyncProgressManager()
		progress = wecomProgressManager.GetProgress(from, eid)
	case model.DepartmentFromDingtalk:
		dingtalkProgressManager := saas_dingtalk.GetDingtalkSyncProgressManager()
		progress = dingtalkProgressManager.GetProgress(from, eid)
	default:
		c.JSON(http.StatusBadRequest, model.ParamError.ToResponse(fmt.Errorf("unsupported from parameter: %d", from)))
		return
	}

	// 检查指针类型的nil值
	if progress == nil || (progress.(*saas_wecom.SyncProgress)) == nil {
		// 默认返回同步失败状态
		defaultProgress := &saas_wecom.SyncProgress{
			From:      from,
			Eid:       eid,
			Progress:  0,
			Status:    "failed",
			Message:   "未找到同步进度记录",
			StartTime: time.Now(),
			EndTime:   time.Now(),
		}
		c.JSON(http.StatusOK, model.Success.ToResponse(defaultProgress))
		return
	}

	c.JSON(http.StatusOK, model.Success.ToResponse(progress))
}

// GetAllSyncProgress 获取所有同步进度
// @Summary Get all sync progress