|
@@ -502,6 +502,15 @@ func (e *EdbData) AfterFind(db *gorm.DB) (err error) {
|
|
|
return nil
|
|
|
}
|
|
|
|
|
|
+// ConvertToResp
|
|
|
+// @Description: 转成需要输出的格式
|
|
|
+// @receiver m
|
|
|
+func (e *EdbData) ConvertToResp() {
|
|
|
+ e.DataTime = utils.GormDateStrToDateTimeStr(e.DataTime)
|
|
|
+
|
|
|
+ return
|
|
|
+}
|
|
|
+
|
|
|
type EdbInfoListResp struct {
|
|
|
Paging *paging.PagingItem
|
|
|
Item *EdbInfoList
|
|
@@ -568,7 +577,7 @@ func GetEdbDataCountByCondition(condition string, pars []interface{}, source, su
|
|
|
return
|
|
|
}
|
|
|
|
|
|
-func GetEdbDataListByCondition(condition string, pars []interface{}, source, subSource, pageSize, startSize int) (item []*EdbData, err error) {
|
|
|
+func GetEdbDataListByCondition(condition string, pars []interface{}, source, subSource, pageSize, startSize int) (items []*EdbData, err error) {
|
|
|
o := global.DmSQL["data"]
|
|
|
tableName := GetEdbDataTableName(source, subSource)
|
|
|
sql := ` SELECT * FROM %s WHERE 1=1 `
|
|
@@ -581,13 +590,20 @@ func GetEdbDataListByCondition(condition string, pars []interface{}, source, sub
|
|
|
sql += ` LIMIT ?,? `
|
|
|
pars = append(pars, startSize)
|
|
|
pars = append(pars, pageSize)
|
|
|
- err = o.Raw(sql, pars...).Find(&item).Error
|
|
|
+ err = o.Raw(sql, pars...).Find(&items).Error
|
|
|
+ if err != nil {
|
|
|
+ return
|
|
|
+ }
|
|
|
+ // 日期处理
|
|
|
+ for _, v := range items {
|
|
|
+ v.ConvertToResp()
|
|
|
+ }
|
|
|
|
|
|
return
|
|
|
}
|
|
|
|
|
|
// GetAllEdbDataListByCondition 根据条件获取所有的数据
|
|
|
-func GetAllEdbDataListByCondition(condition string, pars []interface{}, source, subSource int) (item []*EdbData, err error) {
|
|
|
+func GetAllEdbDataListByCondition(condition string, pars []interface{}, source, subSource int) (items []*EdbData, err error) {
|
|
|
tableName := GetEdbDataTableName(source, subSource)
|
|
|
sql := ` SELECT * FROM %s WHERE 1=1 `
|
|
|
sql = fmt.Sprintf(sql, tableName)
|
|
@@ -596,7 +612,14 @@ func GetAllEdbDataListByCondition(condition string, pars []interface{}, source,
|
|
|
sql += condition
|
|
|
}
|
|
|
sql += ` ORDER BY data_time DESC `
|
|
|
- err = global.DmSQL["data"].Raw(sql, pars...).Scan(&item).Error
|
|
|
+ err = global.DmSQL["data"].Raw(sql, pars...).Scan(&items).Error
|
|
|
+ if err != nil {
|
|
|
+ return
|
|
|
+ }
|
|
|
+ // 日期处理
|
|
|
+ for _, v := range items {
|
|
|
+ v.ConvertToResp()
|
|
|
+ }
|
|
|
|
|
|
return
|
|
|
}
|