fix bug

models/base_from_mysteel_chemical.go

@@ -490,3 +490,17 @@ func (m *BaseFromMysteelChemicalIndex) GetIndexPageByFrequency(condition string,
 	_, err = o.Raw(sql, pars, startSize, pageSize).QueryRows(&items)
 	return
 }
+
+func (d *BaseFromMysteelChemicalData) GetMysteelIndexInfoMaxAndMinInfo(indexCode string) (item *EdbInfoMaxAndMinInfo, err error) {
+	o := orm.NewOrm()
+	sql := ` SELECT MIN(data_time) AS min_date,MAX(data_time) AS max_date,MIN(value) AS min_value,MAX(value) AS max_value FROM base_from_mysteel_chemical_data WHERE index_code=? `
+	err = o.Raw(sql, indexCode).QueryRow(&item)
+	return
+}
+
+func (d *BaseFromMysteelChemicalData) ModifyMysteelIndexMaxAndMinInfo(indexCode string, item *EdbInfoMaxAndMinInfo) (err error) {
+	o := orm.NewOrm()
+	sql := ` UPDATE base_from_mysteel_chemical_index SET start_date=?,end_date=?,modify_time=NOW() WHERE index_code=? `
+	_, err = o.Raw(sql, item.MinDate, item.MaxDate, indexCode).Exec()
+	return
+}

services/base_from_mysteel_chemical.go

@@ -165,6 +165,15 @@ func handleIndex(indexItem *models.HandleMysteelIndex) (err error) {
 		}
 	}
 
+	//修改最大最小日期
+	mysteelIndexMaxItem, err := dataObj.GetMysteelIndexInfoMaxAndMinInfo(indexItem.IndexCode)
+	if err == nil && mysteelIndexMaxItem != nil {
+		e := dataObj.ModifyMysteelIndexMaxAndMinInfo(indexItem.IndexCode, mysteelIndexMaxItem)
+		if e != nil {
+			fmt.Println("ModifyMysteelIndexMaxAndMinInfo Err:" + e.Error())
+		}
+	}
+	
 	// 同步刷新图库钢联的指标
 	go func() {
 		var indexErr error