|
@@ -137,22 +137,25 @@ func GetSciHqIndexCountByClassifyIds(classifyIds []int) (count int, err error) {
|
|
|
}
|
|
|
|
|
|
// GetSciHqIndexByClassifyId 根据分类id获取卓创红期指标列表
|
|
|
-func GetSciHqIndexByClassifyId(classifyId, startSize, pageSize int) (items []*BaseFromSciHqIndexView, err error) {
|
|
|
+func GetSciHqIndexByClassifyId(classifyIds []int, startSize, pageSize int) (items []*BaseFromSciHqIndexView, err error) {
|
|
|
o := orm.NewOrmUsingDB("data")
|
|
|
sql := ` SELECT b.*, e.edb_info_id,
|
|
|
CASE WHEN e.edb_info_id IS NULL THEN 0 ELSE 1 END AS edb_exist
|
|
|
FROM base_from_sci_hq_index AS b
|
|
|
LEFT JOIN edb_info AS e ON b.index_code=e.edb_code AND e.source=88
|
|
|
- WHERE b.classify_id = ? ORDER BY b.sort ASC LIMIT ?,? `
|
|
|
- _, err = o.Raw(sql, classifyId, startSize, pageSize).QueryRows(&items)
|
|
|
+ WHERE b.classify_id IN (` + utils.GetOrmInReplace(len(classifyIds)) + `) ORDER BY b.sort ASC LIMIT ?,? `
|
|
|
+ _, err = o.Raw(sql, classifyIds, startSize, pageSize).QueryRows(&items)
|
|
|
return
|
|
|
}
|
|
|
|
|
|
// GetSciHqIndexCountByClassifyId 根据分类id获取卓创红期指标数量
|
|
|
-func GetSciHqIndexCountByClassifyId(classifyId int) (count int, err error) {
|
|
|
+func GetSciHqIndexCountByClassifyId(classifyIds []int) (count int, err error) {
|
|
|
+ if len(classifyIds) == 0 {
|
|
|
+ return
|
|
|
+ }
|
|
|
o := orm.NewOrmUsingDB("data")
|
|
|
- sql := ` SELECT COUNT(*) AS count FROM base_from_sci_hq_index WHERE classify_id = ? `
|
|
|
- err = o.Raw(sql, classifyId).QueryRow(&count)
|
|
|
+ sql := ` SELECT COUNT(*) AS count FROM base_from_sci_hq_index WHERE classify_id IN (` + utils.GetOrmInReplace(len(classifyIds)) + `) `
|
|
|
+ err = o.Raw(sql, classifyIds).QueryRow(&count)
|
|
|
return
|
|
|
}
|
|
|
|