gorm函数修改

models/base_from_com_trade.go

@@ -40,7 +40,7 @@ func GetComTradeIndex(indexCode string) (item *ComTradeCodeMapping, err error) {
 	//o := orm.NewOrm()
 	sql := `SELECT * FROM com_trade_code_mapping WHERE code=? `
 	//err = o.Raw(sql, indexCode).QueryRow(&item)
-	err = global.DEFAULT_DmSQL.Raw(sql, indexCode).Find(&item).Error
+	err = global.DEFAULT_DmSQL.Raw(sql, indexCode).First(&item).Error
 	return
 }
 

models/base_from_edb_mapping.go

@@ -130,7 +130,7 @@ func (m *BaseFromEdbMapping) GetItemById(id int) (item *BaseFromEdbMapping, err
 	//o := orm.NewOrm()
 	sql := fmt.Sprintf(`SELECT * FROM %s WHERE %s = ? LIMIT 1`, m.TableName(), m.Cols().PrimaryId)
 	//err = o.Raw(sql, id).QueryRow(&item)
-	err = global.DEFAULT_DmSQL.Raw(sql, id).Find(&item).Error
+	err = global.DEFAULT_DmSQL.Raw(sql, id).First(&item).Error
 	return
 }
 
@@ -142,7 +142,7 @@ func (m *BaseFromEdbMapping) GetItemByCondition(condition string, pars []interfa
 	}
 	sql := fmt.Sprintf(`SELECT * FROM %s WHERE 1=1 %s %s LIMIT 1`, m.TableName(), condition, order)
 	//err = o.Raw(sql, pars).QueryRow(&item)
-	err = global.DEFAULT_DmSQL.Raw(sql, pars...).Find(&item).Error
+	err = global.DEFAULT_DmSQL.Raw(sql, pars...).First(&item).Error
 	return
 }
 

models/base_from_fenwei.go

@@ -278,7 +278,7 @@ func (m *BaseFromFenweiIndex) GetByIndexCode(indexCode string) (item *BaseFromFe
 	//o := orm.NewOrm()
 	sql := ` SELECT * FROM base_from_fenwei_index WHERE index_code=? `
 	//err = o.Raw(sql, indexCode).QueryRow(&item)
-	err = global.DEFAULT_DmSQL.Raw(sql, indexCode).Find(&item).Error
+	err = global.DEFAULT_DmSQL.Raw(sql, indexCode).First(&item).Error
 	return
 }
 
@@ -512,7 +512,7 @@ func GetBaseFromFenWeiIndexByIndexName(indexName string) (item *BaseFromFenweiIn
 	//o := orm.NewOrm()
 	sql := ` SELECT * FROM base_from_fenwei_index WHERE index_name=? `
 	//err = o.Raw(sql, indexName).QueryRow(&item)
-	err = global.DEFAULT_DmSQL.Raw(sql, indexName).Find(&item).Error
+	err = global.DEFAULT_DmSQL.Raw(sql, indexName).First(&item).Error
 	if errors.Is(err, orm.ErrNoRows) {
 		return nil, nil
 	}
@@ -524,7 +524,7 @@ func GetBaseFromFenweiDataByIndexCodeAndDataTime(indexCode, dataTime string) (it
 	//o := orm.NewOrm()
 	sql := ` SELECT * FROM base_from_fenwei_data WHERE index_code=? AND data_time=? `
 	//err = o.Raw(sql, indexCode, dataTime).QueryRow(&item)
-	err = global.DEFAULT_DmSQL.Raw(sql, indexCode, dataTime).Find(&item).Error
+	err = global.DEFAULT_DmSQL.Raw(sql, indexCode, dataTime).First(&item).Error
 
 	if errors.Is(err, orm.ErrNoRows) {
 		return nil, nil
@@ -559,7 +559,7 @@ func GetBaseFromFenWeiIndexByIndexCode(indexCode string) (item *BaseFromFenweiIn
 	//o := orm.NewOrm()
 	sql := ` SELECT * FROM base_from_fenwei_index WHERE index_code=? `
 	//err = o.Raw(sql, indexCode).QueryRow(&item)
-	err = global.DEFAULT_DmSQL.Raw(sql, indexCode).Find(&item).Error
+	err = global.DEFAULT_DmSQL.Raw(sql, indexCode).First(&item).Error
 
 	if errors.Is(err, orm.ErrNoRows) {
 		return nil, nil

models/base_from_ly_index.go

@@ -67,7 +67,7 @@ func GetLyIndexByCode(indexCode string) (item *BaseFromLyIndex, err error) {
 	//o := orm.NewOrm()
 	sql := `SELECT * FROM base_from_ly_index WHERE index_code=?`
 	//err = o.Raw(sql, indexCode).QueryRow(&item)
-	err = global.DEFAULT_DmSQL.Raw(sql, indexCode).Scan(&item).Error
+	err = global.DEFAULT_DmSQL.Raw(sql, indexCode).First(&item).Error
 
 	if errors.Is(err, orm.ErrNoRows) {
 		return nil, nil

models/base_from_ly_index_record.go

@@ -53,7 +53,7 @@ func GetLyIndexRecordByUrl(url string) (item *BaseFromLyIndexRecord, err error)
 	//o := orm.NewOrm()
 	sql := `SELECT * FROM base_from_ly_index_record WHERE url=?`
 	//err = o.Raw(sql, url).QueryRow(&item)
-	err = global.DEFAULT_DmSQL.Raw(sql, url).Scan(&item).Error
+	err = global.DEFAULT_DmSQL.Raw(sql, url).First(&item).Error
 
 	if errors.Is(err, orm.ErrNoRows) {
 		return nil, nil

models/base_from_mtjh.go

@@ -124,7 +124,7 @@ func UpdateBaseFromMtjhIndex(item *BaseFromMtjhIndex) (err error) {
 	//o := orm.NewOrm()
 	sql := `UPDATE base_from_mtjh_index SET deal_value=?  WHERE index_name=?  AND  data_time = ?`
 	//_, err = o.Raw(sql, item.DealValue, item.IndexName, item.DataTime).Exec()
-	err = global.DEFAULT_DmSQL.Raw(sql, item.DealValue, item.IndexName, item.DataTime).Scan(&item).Error
+	err = global.DEFAULT_DmSQL.Exec(sql, item.DealValue, item.IndexName, item.DataTime).Error
 	return
 }
 

models/base_from_mysteel_chemical.go

@@ -356,7 +356,7 @@ func (m *BaseFromMysteelChemicalIndex) GetMaxFileIndex(frequency string) (item *
 	//o := orm.NewOrm()
 	sql := `SELECT * FROM base_from_mysteel_chemical_index WHERE frequency=? AND index_name NOT LIKE "%停%" ORDER BY file_index DESC `
 	//err = o.Raw(sql, frequency).QueryRow(&item)
-	err = global.DEFAULT_DmSQL.Raw(sql, frequency).Scan(&item).Error
+	err = global.DEFAULT_DmSQL.Raw(sql, frequency).First(&item).Error
 
 	return
 }

models/base_from_mysteel_chemical_classify.go

@@ -40,7 +40,7 @@ func GetMysteelClassify(classifyName string, parentId int) (item *BaseFromMystee
 	//o := orm.NewOrm()
 	sql := `SELECT * FROM base_from_mysteel_chemical_classify WHERE parent_id=? AND classify_name=? `
 	//err = o.Raw(sql, parentId, classifyName).QueryRow(&item)
-	err = global.DEFAULT_DmSQL.Raw(sql, parentId, classifyName).Scan(&item).Error
+	err = global.DEFAULT_DmSQL.Raw(sql, parentId, classifyName).First(&item).Error
 	return
 }
 

models/base_from_oilchem.go

@@ -301,7 +301,7 @@ func GetBaseFromOilchemData(indexCode, dataTime string) (item *BaseFromOilchemDa
 	//o := orm.NewOrm()
 	sql := `SELECT * FROM base_from_oilchem_data where index_code=? And data_time = ? `
 	//err = o.Raw(sql, indexCode, dataTime).QueryRow(&item)
-	err = global.DEFAULT_DmSQL.Raw(sql, indexCode, dataTime).Scan(&item).Error
+	err = global.DEFAULT_DmSQL.Raw(sql, indexCode, dataTime).First(&item).Error
 	return
 }
 

models/base_from_sci_hq.go

@@ -285,7 +285,7 @@ func GetSciHqIndexInfoMaxAndMinInfo(indexCode string) (item *EdbInfoMaxAndMinInf
 	//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_sci_hq_data WHERE index_code=? `
 	//err = o.Raw(sql, indexCode).QueryRow(&item)
-	err = global.DEFAULT_DmSQL.Raw(sql, indexCode).Scan(&item).Error
+	err = global.DEFAULT_DmSQL.Raw(sql, indexCode).First(&item).Error
 
 	if err != nil {
 		return

models/base_from_smm.go

@@ -82,7 +82,7 @@ func GetBaseFromSmmDataByCodeAndDate(indexCode string, dataTime string) (item *B
 	//o := orm.NewOrm()
 	sql := `SELECT * FROM base_from_smm_data WHERE 1=1 AND index_code=? AND data_time=? `
 	//err = o.Raw(sql, indexCode, dataTime).QueryRow(&item)
-	err = global.DEFAULT_DmSQL.Raw(sql, indexCode, dataTime).Scan(&item).Error
+	err = global.DEFAULT_DmSQL.Raw(sql, indexCode, dataTime).First(&item).Error
 	return
 }
 
@@ -275,7 +275,7 @@ func (d *BaseFromSmmIndex) GetSmmIndexItem(indexCode string) (item *BaseFromSmmI
 
 	//fmt.Println(sql, indexCode)
 	//err = o.Raw(sql, indexCode).QueryRow(&item)
-	err = global.DEFAULT_DmSQL.Raw(sql, indexCode).Scan(&item).Error
+	err = global.DEFAULT_DmSQL.Raw(sql, indexCode).First(&item).Error
 	return
 }
 
@@ -385,7 +385,7 @@ func (m *BaseFromSmmIndex) GetIndexItem(indexCode string) (item *BaseFromSmmInde
 	//o := orm.NewOrm()
 	sql := `SELECT * FROM base_from_smm_index WHERE index_code = ? `
 	//err = o.Raw(sql, indexCode).QueryRow(&item)
-	err = global.DEFAULT_DmSQL.Raw(sql, indexCode).Scan(&item).Error
+	err = global.DEFAULT_DmSQL.Raw(sql, indexCode).First(&item).Error
 	return
 }
 

models/base_from_smm_classify.go

@@ -42,7 +42,7 @@ func GetSmmClassify(classifyName string, parentId int) (item *BaseFromSmmClassif
 	//o := orm.NewOrm()
 	sql := `SELECT * FROM base_from_smm_classify WHERE parent_id=? AND classify_name=? `
 	//err = o.Raw(sql, parentId, classifyName).QueryRow(&item)
-	err = global.DEFAULT_DmSQL.Raw(sql, parentId, classifyName).Scan(&item).Error
+	err = global.DEFAULT_DmSQL.Raw(sql, parentId, classifyName).First(&item).Error
 	return
 }