eta_task/services/data/base_from_jiayue.go

package data

import (
	"context"
	"eta/eta_task/services/alarm_msg"
	"eta/eta_task/utils"
	"fmt"
)

// SyncJiaYueNewIndex 同步嘉悦物产增量指标-每分钟
func SyncJiaYueNewIndex(cont context.Context) (err error) {
	defer func() {
		if err != nil {
			tips := "SyncJiaYueNewIndex-同步嘉悦物产增量指标失败, ErrMsg:\n" + err.Error()
			utils.FileLog.Info(tips)
			go alarm_msg.SendAlarmMsg(tips, 3)
		}
	}()

	param := make(map[string]interface{})
	uri := "jiayue_index/sync_new_index"
	res, e := postRefreshEdbData(param, uri)
	if e != nil {
		err = fmt.Errorf("postRefreshEdbData err: %s", e.Error())
		return
	}
	if res != nil && res.Ret != 200 {
		err = fmt.Errorf("postRefreshEdbData fail")
		return
	}
	return
}