Function ImportChannels

controller/channel_import.go:16–216

(c *gin.Context)

)

func ImportChannels(c *gin.Context) {
	// 从请求中获取上传的文件
	file, err := c.FormFile("file")
	if err != nil {
		common.ApiError(c, fmt.Errorf("failed to get file: %w", err))
		return
	}

	// 打开文件
	src, err := file.Open()
	if err != nil {
		common.ApiError(c, fmt.Errorf("failed to open file: %w", err))
		return
	}
	defer src.Close()

	// 读取Excel文件
	f, err := excelize.OpenReader(src)
	if err != nil {
		common.ApiError(c, fmt.Errorf("failed to open Excel file: %w", err))
		return
	}
	defer func() {
		if err := f.Close(); err != nil {
			common.SysError("Error closing Excel file: " + err.Error())
		}
	}()

	// 获取第一个工作表
	sheetName := f.GetSheetName(0)
	if sheetName == "" {
		common.ApiError(c, fmt.Errorf("no sheets found in Excel file"))
		return
	}

	// 读取所有行
	rows, err := f.GetRows(sheetName)
	if err != nil {
		common.ApiError(c, fmt.Errorf("failed to read rows: %w", err))
		return
	}

	// 检查是否有数据
	if len(rows) <= 1 {
		common.ApiError(c, fmt.Errorf("no data found in Excel file"))
		return
	}

	// 解析表头
	headers := rows[0]
	headerMap := make(map[string]int)
	for i, header := range headers {
		headerMap[header] = i
	}

	// 解析数据行
	channels := make([]model.Channel, 0, len(rows)-1)
	for i := 1; i < len(rows); i++ {