|
@@ -47,6 +47,8 @@ func InitMysteelIndex() {
|
|
|
fmt.Println(err)
|
|
|
return
|
|
|
}
|
|
|
+ classifyMethod := "mysteel_classify/get_or_add"
|
|
|
+ indexMethod := "mysteel_chemical/handle/mysteel/index"
|
|
|
fmt.Println("rows len:", len(rows))
|
|
|
for rk, row := range rows {
|
|
|
if rk > 0 {
|
|
@@ -79,7 +81,6 @@ func InitMysteelIndex() {
|
|
|
unit != "" &&
|
|
|
frequency != "" {
|
|
|
|
|
|
- method := "mysteel_classify/get_or_add"
|
|
|
//classifyFirstMap := make(map[string]interface{})
|
|
|
//classifyFirstMap["ClassifyName"] = classifyFirst
|
|
|
//classifyFirstMap["ParentId"] = 0
|
|
@@ -106,7 +107,7 @@ func InitMysteelIndex() {
|
|
|
classifySecondMap["ClassifyName"] = classifySecond
|
|
|
classifySecondMap["ParentId"] = 0
|
|
|
classifySecondMap["Level"] = 0
|
|
|
- result, err := PostEdbLib(classifySecondMap, method)
|
|
|
+ result, err := PostEdbLib(classifySecondMap, classifyMethod)
|
|
|
if err != nil {
|
|
|
utils.FileLog.Info("初始化分类2失败:" + err.Error())
|
|
|
return
|
|
@@ -126,7 +127,7 @@ func InitMysteelIndex() {
|
|
|
classifyThreeMap["ClassifyName"] = classifyThree
|
|
|
classifyThreeMap["ParentId"] = resp.Data.BaseFromMysteelChemicalClassifyId
|
|
|
classifyThreeMap["Level"] = 1
|
|
|
- result, err = PostEdbLib(classifyThreeMap, method)
|
|
|
+ result, err = PostEdbLib(classifyThreeMap, classifyMethod)
|
|
|
if err != nil {
|
|
|
utils.FileLog.Info("初始化分类3失败:" + err.Error())
|
|
|
return
|
|
@@ -143,11 +144,10 @@ func InitMysteelIndex() {
|
|
|
return
|
|
|
}
|
|
|
|
|
|
- method = "mysteel_chemical/handle/mysteel/index"
|
|
|
indexMap := make(map[string]interface{})
|
|
|
indexMap["EdbCode"] = indexCode
|
|
|
indexMap["BaseFromMysteelChemicalClassifyId"] = resp.Data.BaseFromMysteelChemicalClassifyId
|
|
|
- result, err = PostEdbLib(indexMap, method)
|
|
|
+ result, err = PostEdbLib(indexMap, indexMethod)
|
|
|
if err != nil {
|
|
|
utils.FileLog.Info("初始化指标失败:" + err.Error() + " result:" + string(result))
|
|
|
return
|