修改有色数据初始化

models/base_from_smm.go

@@ -315,3 +315,16 @@ func (m *BaseFromSmmIndex) GetIndexItem(indexCode string) (item *BaseFromSmmInde
 	err = o.Raw(sql, indexCode).QueryRow(&item)
 	return
 }
+
+// 修改
+func (m *BaseFromSmmIndex) Update(updateParams, whereParam map[string]interface{}) (err error) {
+	to := orm.NewOrm()
+	ptrStructOrTableName := "base_from_smm_index"
+
+	qs := to.QueryTable(ptrStructOrTableName)
+	for expr, exprV := range whereParam {
+		qs = qs.Filter(expr, exprV)
+	}
+	_, err = qs.Update(updateParams)
+	return
+}

routers/commentsRouter.go

@@ -835,6 +835,15 @@ func init() {
             Filters: nil,
             Params: nil})
 
+    beego.GlobalControllerRouter["eta/eta_index_lib/controllers:SmmController"] = append(beego.GlobalControllerRouter["eta/eta_index_lib/controllers:SmmController"],
+        beego.ControllerComments{
+            Method: "GetIndexDetailFromDataSourceByCode",
+            Router: `/index_detail/from_data_source`,
+            AllowHTTPMethods: []string{"post"},
+            MethodParams: param.Make(),
+            Filters: nil,
+            Params: nil})
+
     beego.GlobalControllerRouter["eta/eta_index_lib/controllers:SmmController"] = append(beego.GlobalControllerRouter["eta/eta_index_lib/controllers:SmmController"],
         beego.ControllerComments{
             Method: "Refresh",

services/base_from_smm.go

@@ -1,6 +1,7 @@
 package services
 
 import (
+	"errors"
 	"eta/eta_index_lib/logic"
 	"eta/eta_index_lib/models"
 	"eta/eta_index_lib/services/alarm_msg"
@@ -88,6 +89,23 @@ func SmmIndexHandle(baseFilePath, renameFilePath, indexName, indexCode, unit, fr
 			exitDataMap[v.DataTime] = v
 		}
 		indexId = item.BaseFromSmmIndexId
+		//修改指标信息
+		updateParams := make(map[string]interface{})
+		updateParams["index_name"] = indexName
+		updateParams["frequency"] = frequency
+		updateParams["unit"] = unit
+		updateParams["interface"] = source
+		updateParams["modify_time"] = time.Now()
+
+		whereParam := make(map[string]interface{})
+		whereParam["index_code"] = indexCode
+
+		smmIndexObj := new(models.BaseFromSmmIndex)
+		err = smmIndexObj.Update(updateParams, whereParam)
+		if err != nil {
+			err = errors.New("smm index update err:" + err.Error())
+			return
+		}
 	}
 
 	// 遍历excel数据，然后跟现有的数据做校验，不存在则入库