新增是否停更标识

controllers/base_from_mysteel_chemical.go

@@ -168,8 +168,9 @@ func (this *MySteelChemicalController) HandleMysteelIndex() {
 		this.Data["json"] = br
 		this.ServeJSON()
 	}()
+	body := this.Ctx.Input.RequestBody
 	var req models.HandleMysteelIndexResp
-	err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
+	err := json.Unmarshal(body, &req)
 	if err != nil {
 		br.Msg = "参数解析异常！"
 		br.ErrMsg = "参数解析失败，Err:" + err.Error()

models/base_from_mysteel_chemical.go

@@ -222,6 +222,7 @@ type BaseFromMysteelChemicalIndex struct {
 	UpdateDate                        string    `description:"更新日期"`
 	CreateTime                        time.Time `description:"创建时间"`
 	ModifyTime                        time.Time `description:"修改时间"`
+	IsStop                            int       `description:"是否停更:1:停更,0:未停更"`
 }
 
 // GetIndexRefreshAllByMergeFile 根据合并文件去分组查询需要刷新的文件

services/base_from_mysteel_chemical.go

@@ -83,6 +83,13 @@ func handleIndex(indexItem *models.HandleMysteelIndex) (err error) {
 		indexObj.Frequency = indexItem.Frequency
 		indexObj.ModifyTime = time.Now()
 		indexId = item.BaseFromMysteelChemicalIndexId
+
+		var isStop int
+		if strings.Contains(indexItem.IndexName, "停") {
+			isStop = 1
+		}
+		indexObj.IsStop = isStop
+
 		//修改数据
 		updateColsArr := make([]string, 0)
 		updateColsArr = append(updateColsArr, "index_name")
@@ -93,6 +100,7 @@ func handleIndex(indexItem *models.HandleMysteelIndex) (err error) {
 		updateColsArr = append(updateColsArr, "end_date")
 		updateColsArr = append(updateColsArr, "describe")
 		updateColsArr = append(updateColsArr, "end_date")
+		updateColsArr = append(updateColsArr, "is_stop")
 		updateColsArr = append(updateColsArr, "modify_time")
 
 		e := indexObj.Update(updateColsArr)