fix：钢联化工文案调整为上海钢联

controllers/base_from_mysteel_chemical.go

@@ -11,14 +11,14 @@ import (
 	"time"
 )
 
-// MySteelChemicalController 钢联化工
+// MySteelChemicalController 上海钢联
 type MySteelChemicalController struct {
 	BaseAuthController
 }
 
 // Add
-// @Title 新增钢联化工指标接口
-// @Description 新增钢联化工指标接口
+// @Title 新增上海钢联指标接口
+// @Description 新增上海钢联指标接口
 // @Success 200 {object} models.AddEdbInfoReq
 // @router /add [post]
 func (this *MySteelChemicalController) Add() {
@@ -62,8 +62,8 @@ func (this *MySteelChemicalController) Add() {
 }
 
 // Refresh
-// @Title 刷新钢联化工指标接口
-// @Description 刷新钢联化工指标接口
+// @Title 刷新上海钢联指标接口
+// @Description 刷新上海钢联指标接口
 // @Success 200 {object} models.RefreshEdbInfoReq
 // @router /refresh [post]
 func (this *MySteelChemicalController) Refresh() {
@@ -183,8 +183,8 @@ func (this *MySteelChemicalController) QueryRefresh() {
 	br.Msg = "获取成功"
 }
 
-// @Title 检查钢联化工的api是否可用
-// @Description 检查钢联化工的api是否可用
+// @Title 检查上海钢联的api是否可用
+// @Description 检查上海钢联的api是否可用
 // @Success 200 {object} models.HandleMysteelIndexResp
 // @router /handle/mysteel/api/check [post]
 func (this *MySteelChemicalController) ApiHealthCheck() {
@@ -198,7 +198,7 @@ func (this *MySteelChemicalController) ApiHealthCheck() {
 	if err != nil {
 		br.Msg = "处理失败"
 		br.ErrMsg = "处理失败,Err:" + err.Error()
-		utils.FileLog.Info("钢联化工api接口不可用，Err:", err.Error())
+		utils.FileLog.Info("上海钢联api接口不可用，Err:", err.Error())
 		return
 	}
 

models/base_from_mysteel_chemical.go

@@ -200,7 +200,7 @@ func RefreshEdbDataFromMysteelChemical(edbInfoId int, edbCode, startDate string)
 	return
 }
 
-// 钢联化工指标数据
+// 上海钢联指标数据
 type BaseFromMysteelChemicalIndex struct {
 	BaseFromMysteelChemicalIndexId    int64     `orm:"column(base_from_mysteel_chemical_index_id);pk"`
 	BaseFromMysteelChemicalClassifyId int       `description:"分类id"`
@@ -431,7 +431,7 @@ type HandleMysteelIndexResp struct {
 	List []*HandleMysteelIndex
 }
 
-// 钢联化工指标数据
+// 上海钢联指标数据
 type BaseFromMysteelChemicalData struct {
 	BaseFromMysteelChemicalDataId  int64 `orm:"column(base_from_mysteel_chemical_data_id);pk"`
 	BaseFromMysteelChemicalIndexId int64

models/edb_info.go

@@ -1345,7 +1345,7 @@ func EdbInfoAdd(req *AddEdbInfoParams, serverUrl string, sysUserId int, sysUserR
 		utils.DATA_SOURCE_LT:                  "路透",
 		utils.DATA_SOURCE_COAL:                "中国煤炭市场网",
 		utils.DATA_SOURCE_GOOGLE_TRAVEL:       "our world in data",
-		utils.DATA_SOURCE_MYSTEEL_CHEMICAL:    "钢联化工",
+		utils.DATA_SOURCE_MYSTEEL_CHEMICAL:    "上海钢联",
 		utils.DATA_SOURCE_EIA_STEO:            "EIA STEO报告",
 		utils.DATA_SOURCE_COM_TRADE:           "UN",
 		utils.DATA_SOURCE_SCI:                 "SCI",
@@ -1375,7 +1375,7 @@ func EdbInfoAdd(req *AddEdbInfoParams, serverUrl string, sysUserId int, sysUserR
 
 	var sourceIndexName string
 
-	// 钢联化工需要校验下信息是否完整
+	// 上海钢联需要校验下信息是否完整
 	if source == utils.DATA_SOURCE_MYSTEEL_CHEMICAL {
 		indexObj := new(BaseFromMysteelChemicalIndex)
 		tmpItem, tmpErr := indexObj.GetIndexItem(req.EdbCode)

models/edb_info_relation.go

@@ -104,7 +104,7 @@ func UpdateSecondRelationEdbInfoId(edbRelationIds []int, relationList []*EdbInfo
 		}
 	}
 
-	//更新数据源钢联化工指标
+	//更新数据源上海钢联指标
 	if len(indexCodeList) > 0 {
 		// 更改数据源的更新状态
 		sql = ` UPDATE base_from_mysteel_chemical_index SET is_stop = 0 WHERE index_code IN (` + utils.GetOrmInReplace(len(indexCodeList)) + `) and is_stop=1`

services/base_from_mysteel_chemical.go

@@ -188,7 +188,7 @@ func HandleApiIndex(indexCodes []string) (errMsg string, err error) {
 			e := dataObj.ModifyMysteelIndexMaxAndMinInfo(items[0].IndexCode, mysteelIndexMaxItem)
 			if e != nil {
 				fmt.Println("ModifyMysteelIndexMaxAndMinInfo Err:" + e.Error())
-				utils.FileLog.Info("修改钢联化工的最大最小日期失败，Err:" + e.Error())
+				utils.FileLog.Info("修改上海钢联的最大最小日期失败，Err:" + e.Error())
 			}
 		}
 
@@ -534,7 +534,7 @@ type MySteelChemicalApiInfoBody struct {
 	IncludeInfo bool `json:"includeInfo"`
 }
 
-// GetEdbDataFromMySteelChemical 批量获得钢联化工的指标数据
+// GetEdbDataFromMySteelChemical 批量获得上海钢联的指标数据
 func GetEdbDataFromMySteelChemical(indexCodes []string, startTime, endTime, order string) (item *models.MySteelChemicalApiResp, err error) {
 	if utils.MysteelChemicalApiToken == "" {
 		err = errors.New("钢联接口token未配置")
@@ -562,7 +562,7 @@ func GetEdbDataFromMySteelChemical(indexCodes []string, startTime, endTime, orde
 	return
 }
 
-// GetMySteelChemicalIndexNameMap 获取钢联化工的所有指标的信息
+// GetMySteelChemicalIndexNameMap 获取上海钢联的所有指标的信息
 func GetMySteelChemicalIndexNameMap() (indexNameMap map[string]*models.MySteelChemicalApiInfoItem, err error) {
 	if utils.MysteelChemicalApiToken == "" {
 		err = errors.New("钢联接口token未配置")
@@ -653,7 +653,7 @@ func RefreshDataFromMysteelChemical(edbCode, startDate, endDate string) (err err
 
 	terminal, err := GetTerminal(utils.DATA_SOURCE_MYSTEEL_CHEMICAL, tmpIndex.TerminalCode)
 	if err != nil {
-		err = fmt.Errorf("获取钢联化工接口配置出错 Err: %s", err)
+		err = fmt.Errorf("获取上海钢联接口配置出错 Err: %s", err)
 		return
 	}
 

services/edb_info_stat.go

@@ -56,7 +56,7 @@ func AddEdbInfoUpdateLog(edbInfoId int, updateResult int, updateFailedReason str
 	return
 }
 
-// SetMysteelChemicalEdbInfoUpdateStat 定时统计钢联化工的数据源明细表
+// SetMysteelChemicalEdbInfoUpdateStat 定时统计上海钢联的数据源明细表
 func SetMysteelChemicalEdbInfoUpdateStat(needStat bool) (err error) {
 	defer func() {
 		if err != nil {
@@ -71,7 +71,7 @@ func SetMysteelChemicalEdbInfoUpdateStat(needStat bool) (err error) {
 	pars = append(pars, utils.DATA_SOURCE_MYSTEEL_CHEMICAL)
 	edbList, err := models.GetEdbInfoByCondition(condition, pars, 0)
 	if err != nil {
-		err = fmt.Errorf("查询钢联化工指标信息出错，err: %s", err)
+		err = fmt.Errorf("查询上海钢联指标信息出错，err: %s", err)
 		return
 	}
 	nowTime := time.Now()
@@ -81,7 +81,7 @@ func SetMysteelChemicalEdbInfoUpdateStat(needStat bool) (err error) {
 	//查询当日所有钢联指标的终端更新记录
 	updateLogList, err := data_stat.GetEdbUpdateSourceLogByCreateDate(utils.DATA_SOURCE_MYSTEEL_CHEMICAL, today, nextDay)
 	if err != nil {
-		err = fmt.Errorf("查询钢联化工指标终端更新日志报错，err: %s", err)
+		err = fmt.Errorf("查询上海钢联指标终端更新日志报错，err: %s", err)
 		return
 	}
 	fmt.Println(len(updateLogList))
@@ -102,7 +102,7 @@ func SetMysteelChemicalEdbInfoUpdateStat(needStat bool) (err error) {
 	//查询当日钢联所有的刷新记录
 	updateStatList, err := data_stat.GetEdbUpdateStatByCondition(statCond, statPars)
 	if err != nil {
-		err = fmt.Errorf("查询钢联化工数据源明细记录统计报错，err: %s", err)
+		err = fmt.Errorf("查询上海钢联数据源明细记录统计报错，err: %s", err)
 		return
 	}
 	updateStatMap := make(map[int]*data_stat.EdbInfoUpdateStat)
@@ -123,7 +123,7 @@ func SetMysteelChemicalEdbInfoUpdateStat(needStat bool) (err error) {
 		//查询所有需要当日刷新的周度指标
 		indexTotal, tErr := indexObj.GetIndexByCondition(cond, tmpPars)
 		if tErr != nil {
-			err = fmt.Errorf("查询钢联化工原始指标报错，err: %s", tErr)
+			err = fmt.Errorf("查询上海钢联原始指标报错，err: %s", tErr)
 			return
 		}
 		for _, v := range indexTotal {
@@ -136,7 +136,7 @@ func SetMysteelChemicalEdbInfoUpdateStat(needStat bool) (err error) {
 	//查询所有需要当日刷新的周度指标
 	indexStop, tErr := indexObj.GetIndexByCondition(tmpCond, []interface{}{})
 	if tErr != nil {
-		err = fmt.Errorf("查询钢联化工原始指标报错，err: %s", tErr)
+		err = fmt.Errorf("查询上海钢联原始指标报错，err: %s", tErr)
 		return
 	}
 	for _, v := range indexStop {
@@ -224,7 +224,7 @@ func SetMysteelChemicalEdbInfoUpdateStat(needStat bool) (err error) {
 			if len(addList) >= 500 {
 				err = logStat.Add(addList)
 				if err != nil {
-					err = fmt.Errorf("新增钢联化工明细记录报错，err: %s", err)
+					err = fmt.Errorf("新增上海钢联明细记录报错，err: %s", err)
 					return
 				}
 				addList = addList[:0]
@@ -233,7 +233,7 @@ func SetMysteelChemicalEdbInfoUpdateStat(needStat bool) (err error) {
 			if len(modifyList) >= 500 {
 				err = data_stat.UpdateEdbUpdateStatMulti(modifyList)
 				if err != nil {
-					err = fmt.Errorf("更新钢联化工明细记录报错，err: %s", err)
+					err = fmt.Errorf("更新上海钢联明细记录报错，err: %s", err)
 					return
 				}
 				modifyList = modifyList[:0]
@@ -299,7 +299,7 @@ func SetEdbSourceStat(needStat bool) (err error) {
 	//查询当日钢联所有的统计数据
 	updateStatList, err := data_stat.GetEdbUpdateStatByCondition(statCond, statPars)
 	if err != nil {
-		err = fmt.Errorf("查询钢联化工数据源明细记录统计报错，err: %s", err)
+		err = fmt.Errorf("查询上海钢联数据源明细记录统计报错，err: %s", err)
 		return
 	}
 	if !needStat && len(updateStatList) == 0 {
@@ -318,7 +318,7 @@ func SetEdbSourceStat(needStat bool) (err error) {
 	//查询当日钢联所有的统计数据
 	statList, err := data_stat.GetEdbSourceStatByCondition(cond, pars)
 	if err != nil {
-		err = fmt.Errorf("查询钢联化工数据源统计报错，err: %s", err)
+		err = fmt.Errorf("查询上海钢联数据源统计报错，err: %s", err)
 		return
 	}
 	statMap := make(map[string]*data_stat.EdbSourceStat)
@@ -395,7 +395,7 @@ func SetEdbSourceStat(needStat bool) (err error) {
 		if len(addList) >= 500 {
 			err = logStat.Add(addList)
 			if err != nil {
-				err = fmt.Errorf("新增钢联化工统计表报错，err: %s", err)
+				err = fmt.Errorf("新增上海钢联统计表报错，err: %s", err)
 				return
 			}
 			addList = addList[:0]
@@ -404,7 +404,7 @@ func SetEdbSourceStat(needStat bool) (err error) {
 		if len(modifyList) >= 500 {
 			err = data_stat.UpdateEdbSourceStatMulti(modifyList)
 			if err != nil {
-				err = fmt.Errorf("更新钢联化工统计表报错，err: %s", err)
+				err = fmt.Errorf("更新上海钢联统计表报错，err: %s", err)
 				return
 			}
 			modifyList = modifyList[:0]

utils/config.go

@@ -74,7 +74,7 @@ var (
 
 	ThsDataMethod           string //同花顺数据获取的方式，app是通过终端；api是通过接口
 	ThsRefreshToken         string // 同花顺的刷新token
-	MysteelChemicalApiToken string // 钢联化工的api数据token
+	MysteelChemicalApiToken string // 上海钢联的api数据token
 )
 
 type WindUrlMap struct {

utils/constants.go

@@ -56,7 +56,7 @@ const (
 	DATA_SOURCE_PREDICT_CALCULATE                               //预测指标运算->31
 	DATA_SOURCE_PREDICT_CALCULATE_TBZ                           //预测指标 - 同比值->32
 	DATA_SOURCE_PREDICT_CALCULATE_TCZ                           //预测指标 - 同差值->33
-	DATA_SOURCE_MYSTEEL_CHEMICAL                                //钢联化工->34
+	DATA_SOURCE_MYSTEEL_CHEMICAL                                //上海钢联->34
 	DATA_SOURCE_CALCULATE_CJJX                                  //超季节性->35
 	DATA_SOURCE_EIA_STEO                                        //eia steo报告->36
 	DATA_SOURCE_CALCULATE_NHCC                                  //计算指标（拟合残差）->37
@@ -110,7 +110,7 @@ const (
 	DATA_SOURCE_SCI99                                = 85 // 卓创资讯
 	DATA_SOURCE_CCF                                  = 86 // CCF化纤信息
 	DATA_SOURCE_SCI_HQ                               = 88 // 卓创红期->88
-	DATA_SOURCE_OILCHEM       = 89 // 隆众资讯 -> 89
+	DATA_SOURCE_OILCHEM                              = 89 // 隆众资讯 -> 89
 )
 
 // 指标来源的中文展示
@@ -148,7 +148,7 @@ const (
 	DATA_SOURCE_NAME_PREDICT_CALCULATE                    = `预测指标运算`            //预测指标运算->31
 	DATA_SOURCE_NAME_PREDICT_CALCULATE_TBZ                = `预测同比`              //预测指标 - 同比值->32
 	DATA_SOURCE_NAME_PREDICT_CALCULATE_TCZ                = `预测同差`              //预测指标 - 同差值->33
-	DATA_SOURCE_NAME_MYSTEEL_CHEMICAL                     = `钢联化工`              //钢联化工->34
+	DATA_SOURCE_NAME_MYSTEEL_CHEMICAL                     = `上海钢联`              //上海钢联->34
 	DATA_SOURCE_NAME_CALCULATE_CJJX                       = `超季节性`              //超季节性->35
 	DATA_SOURCE_NAME_EIA_STEO                             = `EIA STERO报告`       //eia stero报告->36
 	DATA_SOURCE_NAME_CALCULATE_NHCC                       = `拟合残差`              //计算指标（拟合残差）->37