Function SyncOrganization

api/controller/sync_organization.go:33–81

@Summary Sync organization structure @Description Synchronize enterprise organization structure based on source @Tags Department @Accept json @Produce json @Security BearerAuth @Param from path int true "Source identifier (1=WeCom, 2=DingTalk)" @Param body body service.SyncOrganizationParams true "S

(c *gin.Context)

// @Failure 500 {object} model.CommonResponse "Server error"
// @Router /api/departments/sync/{from} [post]
func SyncOrganization(c *gin.Context) {
	fromStr := c.Param("from")
	from, err := strconv.Atoi(fromStr)
	if err != nil {
		c.JSON(http.StatusBadRequest, model.ParamError.ToResponse(err))
		return
	}
	eid := config.GetEID(c)
	enterprise, err := model.GetEnterpriseByID(eid)
	if err != nil {
		c.JSON(http.StatusInternalServerError, model.DBError.ToResponse(err))
		return
	}

	var params service.SyncOrganizationParams
	if err = c.ShouldBindJSON(&params); err != nil {
		c.JSON(http.StatusBadRequest, model.ParamError.ToResponse(err))
		return
	}

	lockKey := fmt.Sprintf("%s:%s:%d", model.LockOrganizationKeyPre, fromStr, enterprise.Eid)
	isLock := common.LOCKER.TryLock(lockKey, 60*5*time.Second)
	if !isLock {
		c.JSON(http.StatusNotFound, model.OperateTooFast.ToResponse(nil))
		return
	}

	switch from {
	case model.DepartmentFromWecom:
		go func() {
			err := service.WeComRunSyncOrganization(enterprise, params)
			if err != nil {
				logger.SysErrorf("sync organization from wecom failed: %v", err)
			}
		}()
	case model.DepartmentFromDingtalk:
		go func() {
			params.SuiteID = config.GetDingtalkSuiteID()
			err := service.DingtalkRunSyncOrganization(enterprise, params)
			if err != nil {
				// 当同步失败时，删除锁
				common.LOCKER.Unlock(lockKey)
				logger.SysErrorf("sync organization from dingtalk failed: %v", err)
			}
		}()
	}

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

// GetSyncProgress 获取同步进度
// @Summary Get sync progress