eta_data_analysis/services/base_from_yongyi.go

package services

import (
	"encoding/json"
	"eta/eta_data_analysis/models"
	"eta/eta_data_analysis/services/base_from_yongyi"
	"eta/eta_data_analysis/utils"
	"fmt"
	"github.com/tealeg/xlsx"
)

func HandleYongyiExcelDaily(uploadPath string) (err error) {
	xlFile, err := xlsx.OpenFile(uploadPath)
	if err != nil {
		err = fmt.Errorf("打开文件失败, Err: %s", err)
		return
	}
	defer func() {
		if err != nil {
			fmt.Println("file close err: " + err.Error())
		}
	}()

	for _, sheet := range xlFile.Sheet {
		var indexList []*models.YongyiExcelIndex

		switch sheet.Name {
		case "出栏价":
			indexList, err = base_from_yongyi.HandleYongyiExcelDaily1(sheet)
		case "标肥价差":
			indexList, err = base_from_yongyi.HandleYongyiExcelDaily2(sheet)
		case "价格+宰量":
			indexList, err = base_from_yongyi.HandleYongyiExcelDaily3(sheet)
		case "屠宰企业日度屠宰量":
			indexList, err = base_from_yongyi.HandleYongyiExcelDaily4(sheet)
		default:
			continue
		}

		if len(indexList) > 0 {
			params := make(map[string]interface{})
			params["List"] = indexList
			_, e := PostEdbLib(params, utils.LIB_ROUTE_YONGYI_HANDLE)
			if e != nil {
				b, _ := json.Marshal(params)
				utils.FileLog.Info("重置指标分类失败, err: %s, params: %s", e.Error(), string(b))
				return
			}
			/*resp := new(models.EdbInfoResp)
			if e := json.Unmarshal(result, &resp); e != nil {
				utils.FileLog.Info("MethodClassifyReset Unmarshal err: %s", e.Error())
				return
			}
			if resp.Ret != 200 {
				utils.FileLog.Info("重置指标分类失败, Msg: %s, ErrMsg: %s", resp.Msg, resp.ErrMsg)
				continue
			}*/
		}
	}

	return
}