eta_data_init/services/task.go

package services

import (
	"eta/eta_data_init/utils"
	"fmt"
)

var IndexSourceMap map[string]int

// IndexSourceRefreshMap 指标刷新地址的map
var IndexSourceRefreshMap = map[int]string{
	utils.DATA_SOURCE_THS:              "ths/refresh",
	utils.DATA_SOURCE_WIND:             "wind/refresh",
	utils.DATA_SOURCE_PB:               "pb/refresh",
	utils.DATA_SOURCE_LT:               "lt/refresh",
	utils.DATA_SOURCE_MYSTEEL_CHEMICAL: "mysteel_chemical/refresh",
	utils.DATA_SOURCE_YS:               "smm/refresh",
}

func Task() {
	fmt.Println("task start")
	//path, err := filepath.Abs(os.Args[0])
	//if err != nil {
	//	fmt.Println(err)
	//}
	//
	//dir := filepath.Dir(path)
	//fmt.Println(dir)

	IndexSourceMap = make(map[string]int)
	IndexSourceMap["ths"] = utils.DATA_SOURCE_THS
	IndexSourceMap["同花顺"] = utils.DATA_SOURCE_THS
	IndexSourceMap["wind"] = utils.DATA_SOURCE_WIND
	IndexSourceMap["万得"] = utils.DATA_SOURCE_WIND
	IndexSourceMap["钢联"] = utils.DATA_SOURCE_MYSTEEL_CHEMICAL
	IndexSourceMap["彭博"] = utils.DATA_SOURCE_PB
	IndexSourceMap["SMM"] = utils.DATA_SOURCE_YS
	IndexSourceMap["路透"] = utils.DATA_SOURCE_LT

	fmt.Println("task end")
}