zwxi 5 months ago
parent
commit
949cab4f87
3 changed files with 3 additions and 3 deletions
  1. 1 1
      models/base_from_com_trade.go
  2. 1 1
      models/base_from_ths_hf.go
  3. 1 1
      models/base_from_ths_hf_data.go

+ 1 - 1
models/base_from_com_trade.go

@@ -89,7 +89,7 @@ func GetComTradeDataByCondition(condition string, pars []interface{}) (item []*C
 		sql1 += condition
 	}
 	sql := `select trade_value AS value,data_time from (` + sql1 + ` having 1 order by modify_time DESC ) tmp GROUP BY data_time ORDER BY data_time DESC `
-	_, err = o.Raw(sql, pars).QueryRows(&item)
+	_, err = o.Raw(sql, pars...).QueryRows(&item)
 	return
 }
 

+ 1 - 1
models/base_from_ths_hf.go

@@ -149,7 +149,7 @@ func (m *BaseFromThsHfIndex) RemoveByCondition(condition string, pars []interfac
 	//o := orm.NewOrm()
 	sql := fmt.Sprintf(`DELETE FROM %s WHERE %s`, m.TableName(), condition)
 	//_, err = o.Raw(sql, pars).Exec()
-	err = global.DEFAULT_DmSQL.Exec(sql, pars).Error
+	err = global.DEFAULT_DmSQL.Exec(sql, pars...).Error
 	return
 }
 

+ 1 - 1
models/base_from_ths_hf_data.go

@@ -105,7 +105,7 @@ func (m *BaseFromThsHfData) RemoveByCondition(condition string, pars []interface
 	//o := orm.NewOrm()
 	sql := fmt.Sprintf(`DELETE FROM %s WHERE %s`, m.TableName(), condition)
 	//_, err = o.Raw(sql, pars).Exec()
-	err = global.DEFAULT_DmSQL.Exec(sql, pars).Error
+	err = global.DEFAULT_DmSQL.Exec(sql, pars...).Error
 	return
 }