OMC/be.ems
1
0
Fork 0
Code Issues Releases 3 Activity

feat: UDM查询接口排序imsi

Browse Source
This commit is contained in:
TsMask
2023-09-14 19:18:11 +08:00
parent 35b7ed587b
commit 71793dd94c
2 changed files with 38 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

21
features/udm_user/repo/repo_udm_auth_user.go
View File

@@ -59,11 +59,11 @@ func (r *RepoUdmAuthUser) SelectPage(query map[string]any) map[string]any {
var conditions []string
var params []any
if v, ok := query["msisdn"]; ok && v != "" {
conditions = append(conditions, "msisdn like concat(?, '%')")
conditions = append(conditions, "msisdn like concat(concat('%', ?), '%')")
params = append(params, v)
}
if v, ok := query["imsi"]; ok && v != "" {
conditions = append(conditions, "imsi like concat(?, '%')")
conditions = append(conditions, "imsi like concat(concat('%', ?), '%')")
params = append(params, v)
}
if v, ok := query["neId"]; ok && v != "" {
@@ -97,8 +97,23 @@ func (r *RepoUdmAuthUser) SelectPage(query map[string]any) map[string]any {
params = append(params, pageNum*pageSize)
params = append(params, pageSize)
// 排序
sortSql := ""
if v, ok := query["sortField"]; ok && v != "" {
if v == "imsi" {
sortSql += " order by imsi "
}
if v, ok := query["sortOrder"]; ok && v != nil {
if v == "desc" {
sortSql += " desc "
} else {
sortSql += " asc "
}
}
}
// 查询数据
querySql := r.selectSql + whereSql + pageSql
querySql := r.selectSql + whereSql + sortSql + pageSql
results, err := datasource.RawDB("", querySql, params)
if err != nil {
log.Errorf("query err => %v", err)

21
features/udm_user/repo/repo_udm_sub_user.go
View File

@@ -94,6 +94,10 @@ func (r *RepoUdmSubUser) SelectPage(query map[string]any) map[string]any {
totalRows, err := datasource.RawDB("", totalSql+whereSql, params)
if err != nil {
log.Errorf("total err => %v", err)
return map[string]any{
"total": 0,
"rows": nil,
}
}
total := parse.Number(totalRows[0]["total"])
if total == 0 {
@@ -109,8 +113,23 @@ func (r *RepoUdmSubUser) SelectPage(query map[string]any) map[string]any {
params = append(params, pageNum*pageSize)
params = append(params, pageSize)
// 排序
sortSql := ""
if v, ok := query["sortField"]; ok && v != "" {
if v == "imsi" {
sortSql += " order by imsi "
}
if v, ok := query["sortOrder"]; ok && v != nil {
if v == "desc" {
sortSql += " desc "
} else {
sortSql += " asc "
}
}
}
// 查询数据
querySql := r.selectSql + whereSql + pageSql
querySql := r.selectSql + whereSql + sortSql + pageSql
results, err := datasource.RawDB("", querySql, params)
if err != nil {
log.Errorf("query err => %v", err)