|
@@ -43,7 +43,9 @@ func AddChartEdbMapping(items []*ChartEdbMapping) (err error) {
|
|
|
return
|
|
|
}
|
|
|
|
|
|
-func GetChartEdbMappingList(chartInfoId int) (list []*ChartEdbInfoMapping, err error) {
|
|
|
+func GetChartEdbMappingList(chartInfoId int) (items []*ChartEdbInfoMapping, err error) {
|
|
|
+ var ormList []*ChartEdbInfoMappingOrm
|
|
|
+ items = make([]*ChartEdbInfoMapping, 0)
|
|
|
o := orm.NewOrmUsingDB("data")
|
|
|
sql := ` SELECT a.*,b.source_name,b.source,b.sub_source,b.classify_id,b.edb_code,b.edb_name,b.edb_name_en,b.frequency,b.unit,b.unit_en,b.start_date,
|
|
|
b.end_date,b.modify_time,b.latest_date,b.latest_value,b.unique_code,b.edb_info_type AS edb_info_category_type,b.edb_type,b.is_join_permission,
|
|
@@ -52,7 +54,14 @@ a.is_convert, a.convert_type, a.convert_value, a.convert_unit, a.convert_en_unit
|
|
|
INNER JOIN edb_info AS b ON a.edb_info_id=b.edb_info_id
|
|
|
WHERE chart_info_id=?
|
|
|
ORDER BY chart_edb_mapping_id ASC `
|
|
|
- _, err = o.Raw(sql, chartInfoId).QueryRows(&list)
|
|
|
+ _, err = o.Raw(sql, chartInfoId).QueryRows(&ormList)
|
|
|
+ if err != nil {
|
|
|
+ return
|
|
|
+ }
|
|
|
+ for _, ormItem := range ormList {
|
|
|
+ items = append(items, ormItem.ToItem())
|
|
|
+ }
|
|
|
+
|
|
|
return
|
|
|
}
|
|
|
|
|
@@ -66,34 +75,56 @@ func GetChartMappingList(chartInfoId int) (list []*ChartEdbMapping, err error) {
|
|
|
return
|
|
|
}
|
|
|
|
|
|
-func GetChartEdbMappingListByChartInfoIds(chartInfoIds string) (list []*ChartEdbInfoMapping, err error) {
|
|
|
+func GetChartEdbMappingListByChartInfoIds(chartInfoIds string) (items []*ChartEdbInfoMapping, err error) {
|
|
|
+ var ormList []*ChartEdbInfoMappingOrm
|
|
|
+ items = make([]*ChartEdbInfoMapping, 0)
|
|
|
o := orm.NewOrmUsingDB("data")
|
|
|
sql := ` SELECT a.*,b.source_name,b.source,b.sub_source,b.edb_code,b.edb_name,b.edb_name_en,b.frequency,b.unit,b.unit_en,b.start_date,b.end_date,b.modify_time,b.latest_date,b.latest_value,b.unique_code,b.edb_info_type AS edb_info_category_type,b.edb_type,b.classify_id,b.is_join_permission
|
|
|
FROM chart_edb_mapping AS a
|
|
|
INNER JOIN edb_info AS b ON a.edb_info_id=b.edb_info_id
|
|
|
WHERE chart_info_id in (` + chartInfoIds + `)
|
|
|
ORDER BY chart_edb_mapping_id ASC `
|
|
|
- _, err = o.Raw(sql).QueryRows(&list)
|
|
|
+ _, err = o.Raw(sql).QueryRows(&ormList)
|
|
|
+ if err != nil {
|
|
|
+ return
|
|
|
+ }
|
|
|
+ for _, ormItem := range ormList {
|
|
|
+ items = append(items, ormItem.ToItem())
|
|
|
+ }
|
|
|
+
|
|
|
return
|
|
|
}
|
|
|
|
|
|
-func GetChartEdbMappingListByEdbInfoId(edbInfoStr string) (list []*ChartEdbInfoMapping, err error) {
|
|
|
+func GetChartEdbMappingListByEdbInfoId(edbInfoStr string) (items []*ChartEdbInfoMapping, err error) {
|
|
|
+ var ormList []*ChartEdbInfoMappingOrm
|
|
|
+ items = make([]*ChartEdbInfoMapping, 0)
|
|
|
+
|
|
|
o := orm.NewOrmUsingDB("data")
|
|
|
sql := ` SELECT edb_info_id,source_name,source,sub_source,edb_code,edb_name,edb_name_en,frequency,unit,unit_en,start_date,end_date,modify_time,latest_date,latest_value,unique_code,edb_info_type AS edb_info_category_type,max_value,min_value,edb_type,classify_id,is_join_permission
|
|
|
FROM edb_info
|
|
|
WHERE edb_info_id IN(` + edbInfoStr + `)
|
|
|
ORDER BY FIELD(edb_info_id,` + edbInfoStr + `)
|
|
|
`
|
|
|
- _, err = o.Raw(sql).QueryRows(&list)
|
|
|
+ _, err = o.Raw(sql).QueryRows(&ormList)
|
|
|
+ if err != nil {
|
|
|
+ return
|
|
|
+ }
|
|
|
+ for _, ormItem := range ormList {
|
|
|
+ items = append(items, ormItem.ToItem())
|
|
|
+ }
|
|
|
+
|
|
|
return
|
|
|
}
|
|
|
|
|
|
// GetChartEdbMappingListByEdbInfoIdList 根据指标id列表获取关联关系
|
|
|
-func GetChartEdbMappingListByEdbInfoIdList(edbIdList []int) (list []*ChartEdbInfoMapping, err error) {
|
|
|
+func GetChartEdbMappingListByEdbInfoIdList(edbIdList []int) (items []*ChartEdbInfoMapping, err error) {
|
|
|
num := len(edbIdList)
|
|
|
if num <= 0 {
|
|
|
return
|
|
|
}
|
|
|
+ var ormList []*ChartEdbInfoMappingOrm
|
|
|
+ items = make([]*ChartEdbInfoMapping, 0)
|
|
|
+
|
|
|
o := orm.NewOrmUsingDB("data")
|
|
|
|
|
|
if utils.DBDRIVER_NAME == "postgres" {
|
|
@@ -107,32 +138,52 @@ func GetChartEdbMappingListByEdbInfoIdList(edbIdList []int) (list []*ChartEdbInf
|
|
|
}
|
|
|
sql += ` END`
|
|
|
|
|
|
- _, err = o.Raw(sql, edbIdList).QueryRows(&list)
|
|
|
- return
|
|
|
+ _, err = o.Raw(sql, edbIdList).QueryRows(&ormList)
|
|
|
+ if err != nil {
|
|
|
+ return
|
|
|
+ }
|
|
|
+ for _, ormItem := range ormList {
|
|
|
+ items = append(items, ormItem.ToItem())
|
|
|
+ }
|
|
|
} else {
|
|
|
sql := ` SELECT edb_info_id,source_name,source,sub_source,edb_code,edb_name,edb_name_en,frequency,unit,unit_en,start_date,end_date,modify_time,latest_date,latest_value,unique_code,edb_info_type AS edb_info_category_type,max_value,min_value,edb_type,classify_id,is_join_permission
|
|
|
FROM edb_info
|
|
|
WHERE edb_info_id IN(` + utils.GetOrmInReplace(num) + `)
|
|
|
ORDER BY FIELD(edb_info_id,` + utils.GetOrmInReplace(num) + `) `
|
|
|
- _, err = o.Raw(sql, edbIdList, edbIdList).QueryRows(&list)
|
|
|
- return
|
|
|
+ _, err = o.Raw(sql, edbIdList, edbIdList).QueryRows(&ormList)
|
|
|
+ if err != nil {
|
|
|
+ return
|
|
|
+ }
|
|
|
+ for _, ormItem := range ormList {
|
|
|
+ items = append(items, ormItem.ToItem())
|
|
|
+ }
|
|
|
}
|
|
|
|
|
|
+ return
|
|
|
}
|
|
|
|
|
|
// GetChartEdbMappingListByIdList 通过图表id列表获取
|
|
|
-func GetChartEdbMappingListByIdList(chartInfoIdList []int) (list []*ChartEdbInfoMapping, err error) {
|
|
|
+func GetChartEdbMappingListByIdList(chartInfoIdList []int) (items []*ChartEdbInfoMapping, err error) {
|
|
|
num := len(chartInfoIdList)
|
|
|
if num <= 0 {
|
|
|
return
|
|
|
}
|
|
|
+ var ormList []*ChartEdbInfoMappingOrm
|
|
|
+ items = make([]*ChartEdbInfoMapping, 0)
|
|
|
o := orm.NewOrmUsingDB("data")
|
|
|
sql := ` SELECT a.*,b.source_name,b.source,b.sub_source,b.edb_code,b.edb_name,b.edb_name_en,b.frequency,b.unit,b.unit_en,b.start_date,b.end_date,b.modify_time,b.latest_date,b.latest_value,b.unique_code,b.edb_info_type,b.edb_type AS edb_info_category_type,b.classify_id,b.is_join_permission
|
|
|
FROM chart_edb_mapping AS a
|
|
|
INNER JOIN edb_info AS b ON a.edb_info_id=b.edb_info_id
|
|
|
WHERE chart_info_id in (` + utils.GetOrmInReplace(num) + `)
|
|
|
ORDER BY chart_edb_mapping_id ASC `
|
|
|
- _, err = o.Raw(sql, chartInfoIdList).QueryRows(&list)
|
|
|
+ _, err = o.Raw(sql, chartInfoIdList).QueryRows(&ormList)
|
|
|
+ if err != nil {
|
|
|
+ return
|
|
|
+ }
|
|
|
+ for _, ormItem := range ormList {
|
|
|
+ items = append(items, ormItem.ToItem())
|
|
|
+ }
|
|
|
+
|
|
|
return
|
|
|
}
|
|
|
|
|
@@ -142,7 +193,10 @@ type RelationEdbInfoListResp struct {
|
|
|
List []*ChartEdbInfoMapping
|
|
|
}
|
|
|
|
|
|
-func GetRelationEdbInfoListByCondition(condition string, pars []interface{}, startSize, pageSize int) (item []*ChartEdbInfoMapping, err error) {
|
|
|
+func GetRelationEdbInfoListByCondition(condition string, pars []interface{}, startSize, pageSize int) (items []*ChartEdbInfoMapping, err error) {
|
|
|
+ var ormList []*ChartEdbInfoMappingOrm
|
|
|
+ items = make([]*ChartEdbInfoMapping, 0)
|
|
|
+
|
|
|
o := orm.NewOrmUsingDB("data")
|
|
|
sql := ` SELECT a.* FROM edb_info AS a
|
|
|
JOIN edb_info_calculate_mapping AS b on a.edb_info_id = b.edb_info_id WHERE 1=1 `
|
|
@@ -151,7 +205,14 @@ func GetRelationEdbInfoListByCondition(condition string, pars []interface{}, sta
|
|
|
}
|
|
|
//sql += " ORDER BY sort ASC,chart_info_id DESC LIMIT ?,? "
|
|
|
sql += " ORDER BY a.create_time DESC LIMIT ?,? "
|
|
|
- _, err = o.Raw(sql, pars, startSize, pageSize).QueryRows(&item)
|
|
|
+ _, err = o.Raw(sql, pars, startSize, pageSize).QueryRows(&ormList)
|
|
|
+ if err != nil {
|
|
|
+ return
|
|
|
+ }
|
|
|
+ for _, ormItem := range ormList {
|
|
|
+ items = append(items, ormItem.ToItem())
|
|
|
+ }
|
|
|
+
|
|
|
return
|
|
|
}
|
|
|
|
|
@@ -168,6 +229,7 @@ func GetRelationEdbInfoListCountByCondition(condition string, pars []interface{}
|
|
|
|
|
|
// GetEtaEdbChartEdbMapping 商品曲线图查询对应的普通指标
|
|
|
func GetEtaEdbChartEdbMapping(chartInfoId int) (item *ChartEdbInfoMapping, err error) {
|
|
|
+ var chartEdbInfoMappingOrm *ChartEdbInfoMappingOrm
|
|
|
o := orm.NewOrmUsingDB("data")
|
|
|
aField := `a.chart_edb_mapping_id,a.chart_info_id,a.edb_info_id,a.create_time,a.modify_time,a.unique_code,a.max_data,a.min_data,a.is_order,a.is_axis,a.edb_info_type,a.lead_value,a.lead_unit,a.chart_style,a.chart_color,a.predict_chart_color,a.chart_width,a.source as mapping_source`
|
|
|
|
|
@@ -176,12 +238,20 @@ func GetEtaEdbChartEdbMapping(chartInfoId int) (item *ChartEdbInfoMapping, err e
|
|
|
INNER JOIN edb_info AS b ON a.edb_info_id=b.edb_info_id
|
|
|
WHERE a.chart_info_id=? AND a.source = ?
|
|
|
ORDER BY chart_edb_mapping_id ASC `
|
|
|
- err = o.Raw(sql, chartInfoId, utils.CHART_SOURCE_DEFAULT).QueryRow(&item)
|
|
|
+ err = o.Raw(sql, chartInfoId, utils.CHART_SOURCE_DEFAULT).QueryRow(&chartEdbInfoMappingOrm)
|
|
|
+ if err != nil {
|
|
|
+ return
|
|
|
+ }
|
|
|
+ item = chartEdbInfoMappingOrm.ToItem()
|
|
|
+
|
|
|
return
|
|
|
}
|
|
|
|
|
|
// GetEtaEdbChartEdbMappingList 商品曲线图查询对应的普通指标
|
|
|
func GetEtaEdbChartEdbMappingList(chartInfoId int) (items []*ChartEdbInfoMapping, err error) {
|
|
|
+ var ormList []*ChartEdbInfoMappingOrm
|
|
|
+ items = make([]*ChartEdbInfoMapping, 0)
|
|
|
+
|
|
|
o := orm.NewOrmUsingDB("data")
|
|
|
aField := `a.chart_edb_mapping_id,a.chart_info_id,a.edb_info_id,a.create_time,a.modify_time,a.unique_code,a.max_data,a.min_data,a.is_order,a.is_axis,a.edb_info_type,a.lead_value,a.lead_unit,a.chart_style,a.chart_color,a.predict_chart_color,a.chart_width,a.source as mapping_source`
|
|
|
|
|
@@ -190,12 +260,20 @@ func GetEtaEdbChartEdbMappingList(chartInfoId int) (items []*ChartEdbInfoMapping
|
|
|
INNER JOIN edb_info AS b ON a.edb_info_id=b.edb_info_id
|
|
|
WHERE a.chart_info_id=? AND a.source = ?
|
|
|
ORDER BY chart_edb_mapping_id ASC `
|
|
|
- _, err = o.Raw(sql, chartInfoId, utils.CHART_SOURCE_DEFAULT).QueryRows(&items)
|
|
|
+ _, err = o.Raw(sql, chartInfoId, utils.CHART_SOURCE_DEFAULT).QueryRows(&ormList)
|
|
|
+ if err != nil {
|
|
|
+ return
|
|
|
+ }
|
|
|
+ for _, ormItem := range ormList {
|
|
|
+ items = append(items, ormItem.ToItem())
|
|
|
+ }
|
|
|
+
|
|
|
return
|
|
|
}
|
|
|
|
|
|
// GetFutureGoodEdbChartEdbMapping 商品曲线图查询对应的商品指标
|
|
|
func GetFutureGoodEdbChartEdbMapping(chartInfoId int) (item *ChartEdbInfoMapping, err error) {
|
|
|
+ var chartEdbInfoMappingOrm *ChartEdbInfoMappingOrm
|
|
|
o := orm.NewOrmUsingDB("data")
|
|
|
aField := `a.chart_edb_mapping_id,a.chart_info_id,a.edb_info_id,a.create_time,a.modify_time,a.unique_code,a.max_data,a.min_data,a.is_order,a.is_axis,a.edb_info_type,a.lead_value,a.lead_unit,a.chart_style,a.chart_color,a.predict_chart_color,a.chart_width,a.source as mapping_source`
|
|
|
sql := ` SELECT ` + aField + `,b.future_good_edb_info_id,b.future_good_edb_code as edb_code,b.future_good_edb_name as edb_name,b.start_date,b.end_date,b.modify_time,b.latest_date,b.latest_value
|
|
@@ -203,12 +281,19 @@ func GetFutureGoodEdbChartEdbMapping(chartInfoId int) (item *ChartEdbInfoMapping
|
|
|
INNER JOIN future_good_edb_info AS b ON a.edb_info_id=b.future_good_edb_info_id
|
|
|
WHERE a.chart_info_id=? AND a.source = ?
|
|
|
ORDER BY chart_edb_mapping_id ASC `
|
|
|
- err = o.Raw(sql, chartInfoId, utils.CHART_SOURCE_FUTURE_GOOD).QueryRow(&item)
|
|
|
+ err = o.Raw(sql, chartInfoId, utils.CHART_SOURCE_FUTURE_GOOD).QueryRow(&chartEdbInfoMappingOrm)
|
|
|
+ if err != nil {
|
|
|
+ return
|
|
|
+ }
|
|
|
+ item = chartEdbInfoMappingOrm.ToItem()
|
|
|
+
|
|
|
return
|
|
|
}
|
|
|
|
|
|
// GetFutureGoodEdbChartEdbMappingList 商品曲线图查询对应的商品指标
|
|
|
func GetFutureGoodEdbChartEdbMappingList(chartInfoId int) (items []*ChartEdbInfoMapping, err error) {
|
|
|
+ var ormList []*ChartEdbInfoMappingOrm
|
|
|
+ items = make([]*ChartEdbInfoMapping, 0)
|
|
|
o := orm.NewOrmUsingDB("data")
|
|
|
aField := `a.chart_edb_mapping_id,a.chart_info_id,a.edb_info_id,a.create_time,a.modify_time,a.unique_code,a.max_data,a.min_data,a.is_order,a.is_axis,a.edb_info_type,a.lead_value,a.lead_unit,a.chart_style,a.chart_color,a.predict_chart_color,a.chart_width,a.source as mapping_source`
|
|
|
sql := ` SELECT ` + aField + `,b.future_good_edb_info_id,b.future_good_edb_code as edb_code,b.future_good_edb_name as edb_name,b.start_date,b.end_date,b.modify_time,b.latest_date,b.latest_value
|
|
@@ -216,46 +301,85 @@ func GetFutureGoodEdbChartEdbMappingList(chartInfoId int) (items []*ChartEdbInfo
|
|
|
INNER JOIN future_good_edb_info AS b ON a.edb_info_id=b.future_good_edb_info_id
|
|
|
WHERE a.chart_info_id=? AND a.source = ?
|
|
|
ORDER BY chart_edb_mapping_id ASC `
|
|
|
- _, err = o.Raw(sql, chartInfoId, utils.CHART_SOURCE_FUTURE_GOOD).QueryRows(&items)
|
|
|
+ _, err = o.Raw(sql, chartInfoId, utils.CHART_SOURCE_FUTURE_GOOD).QueryRows(&ormList)
|
|
|
+ if err != nil {
|
|
|
+ return
|
|
|
+ }
|
|
|
+ for _, ormItem := range ormList {
|
|
|
+ items = append(items, ormItem.ToItem())
|
|
|
+ }
|
|
|
+
|
|
|
return
|
|
|
}
|
|
|
|
|
|
// GetChartEdbMappingListV2 根据图表id获取指标信息,不连表查询指标表
|
|
|
-func GetChartEdbMappingListV2(chartInfoId int) (list []*ChartEdbInfoMapping, err error) {
|
|
|
+func GetChartEdbMappingListV2(chartInfoId int) (items []*ChartEdbInfoMapping, err error) {
|
|
|
+ var ormList []*ChartEdbInfoMappingOrm
|
|
|
+ items = make([]*ChartEdbInfoMapping, 0)
|
|
|
+
|
|
|
o := orm.NewOrmUsingDB("data")
|
|
|
sql := ` SELECT a.* FROM chart_edb_mapping AS a
|
|
|
WHERE chart_info_id=?
|
|
|
ORDER BY chart_edb_mapping_id ASC `
|
|
|
- _, err = o.Raw(sql, chartInfoId).QueryRows(&list)
|
|
|
+ _, err = o.Raw(sql, chartInfoId).QueryRows(&ormList)
|
|
|
+ if err != nil {
|
|
|
+ return
|
|
|
+ }
|
|
|
+ for _, ormItem := range ormList {
|
|
|
+ items = append(items, ormItem.ToItem())
|
|
|
+ }
|
|
|
+
|
|
|
return
|
|
|
}
|
|
|
|
|
|
// GetChartEdbMappingByEdbInfoId 根据指标id获取edb_mapping
|
|
|
func GetChartEdbMappingByEdbInfoId(edbInfoId int) (item *ChartEdbInfoMapping, err error) {
|
|
|
+ var chartEdbInfoMappingOrm *ChartEdbInfoMappingOrm
|
|
|
o := orm.NewOrmUsingDB("data")
|
|
|
sql := ` SELECT edb_info_id,source_name,classify_id,source,sub_source,edb_code,edb_name,edb_name_en,frequency,unit,unit_en,start_date,end_date,modify_time,latest_date,latest_value,unique_code,edb_info_type AS edb_info_category_type,edb_type,max_value,min_value,is_join_permission
|
|
|
FROM edb_info
|
|
|
WHERE edb_info_id = ? limit 1`
|
|
|
- err = o.Raw(sql, edbInfoId).QueryRow(&item)
|
|
|
+ err = o.Raw(sql, edbInfoId).QueryRow(&chartEdbInfoMappingOrm)
|
|
|
+ if err != nil {
|
|
|
+ return
|
|
|
+ }
|
|
|
+ item = chartEdbInfoMappingOrm.ToItem()
|
|
|
+
|
|
|
return
|
|
|
}
|
|
|
|
|
|
// GetEdbMappingListByEdbInfoId 根据指标id获取edb_mapping
|
|
|
-func GetEdbMappingListByEdbInfoId(edbInfoId int) (item []*ChartEdbInfoMapping, err error) {
|
|
|
+func GetEdbMappingListByEdbInfoId(edbInfoId int) (items []*ChartEdbInfoMapping, err error) {
|
|
|
+ var ormList []*ChartEdbInfoMappingOrm
|
|
|
+ items = make([]*ChartEdbInfoMapping, 0)
|
|
|
+
|
|
|
o := orm.NewOrmUsingDB("data")
|
|
|
sql := ` SELECT * FROM chart_edb_mapping
|
|
|
WHERE edb_info_id = ? `
|
|
|
- _, err = o.Raw(sql, edbInfoId).QueryRows(&item)
|
|
|
+ _, err = o.Raw(sql, edbInfoId).QueryRows(&ormList)
|
|
|
+ if err != nil {
|
|
|
+ return
|
|
|
+ }
|
|
|
+ for _, ormItem := range ormList {
|
|
|
+ items = append(items, ormItem.ToItem())
|
|
|
+ }
|
|
|
+
|
|
|
return
|
|
|
}
|
|
|
|
|
|
// GetChartEdbMappingByFutureGoodEdbInfoId 根据指标id获取edb_mapping
|
|
|
func GetChartEdbMappingByFutureGoodEdbInfoId(edbInfoId int) (item *ChartEdbInfoMapping, err error) {
|
|
|
+ var chartEdbInfoMappingOrm *ChartEdbInfoMappingOrm
|
|
|
o := orm.NewOrmUsingDB("data")
|
|
|
sql := ` SELECT future_good_edb_info_id as edb_info_id,future_good_edb_code as edb_code,b.future_good_edb_name as edb_name,b.start_date,b.end_date,b.modify_time,b.latest_date,b.latest_value,b.region_type
|
|
|
FROM future_good_edb_info b
|
|
|
WHERE future_good_edb_info_id = ? limit 1 `
|
|
|
- err = o.Raw(sql, edbInfoId).QueryRow(&item)
|
|
|
+ err = o.Raw(sql, edbInfoId).QueryRow(&chartEdbInfoMappingOrm)
|
|
|
+ if err != nil {
|
|
|
+ return
|
|
|
+ }
|
|
|
+ item = chartEdbInfoMappingOrm.ToItem()
|
|
|
+
|
|
|
return
|
|
|
}
|
|
|
|
|
@@ -357,13 +481,23 @@ func ModifyChartEdbMapping(chartInfoId int, edbInfoList []*EdbInfo) (err error)
|
|
|
return
|
|
|
}
|
|
|
|
|
|
-func GetRelationEdbInfoListMappingByCondition(condition string, pars []interface{}) (item []*ChartEdbInfoMapping, err error) {
|
|
|
+func GetRelationEdbInfoListMappingByCondition(condition string, pars []interface{}) (items []*ChartEdbInfoMapping, err error) {
|
|
|
+ var ormList []*ChartEdbInfoMappingOrm
|
|
|
+ items = make([]*ChartEdbInfoMapping, 0)
|
|
|
+
|
|
|
o := orm.NewOrmUsingDB("data")
|
|
|
sql := ` SELECT a.* FROM edb_info AS a
|
|
|
JOIN edb_info_calculate_mapping AS b on a.edb_info_id = b.edb_info_id WHERE 1=1 `
|
|
|
if condition != "" {
|
|
|
sql += condition
|
|
|
}
|
|
|
- _, err = o.Raw(sql, pars).QueryRows(&item)
|
|
|
+ _, err = o.Raw(sql, pars).QueryRows(&ormList)
|
|
|
+ if err != nil {
|
|
|
+ return
|
|
|
+ }
|
|
|
+ for _, ormItem := range ormList {
|
|
|
+ items = append(items, ormItem.ToItem())
|
|
|
+ }
|
|
|
+
|
|
|
return
|
|
|
}
|