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

refactor: 移除冗余错误日志，优化查询逻辑

Browse Source
This commit is contained in:
TsMask
2025-03-04 14:52:15 +08:00
parent 986624c48f
commit 8595a1c0cb
3 changed files with 10 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

1
src/modules/network_data/repository/udm_auth.go
View File

@@ -43,7 +43,6 @@ func (r *UDMAuthUser) SelectPage(query map[string]any) (int64, []model.UDMAuthUs
// 查询数量 长度为0直接返回 // 查询数量 长度为0直接返回
if err := tx.Count(&total).Error; err != nil || total <= 0 { if err := tx.Count(&total).Error; err != nil || total <= 0 {
logger.Errorf("total err => %v", err)
return total, rows return total, rows
} }

1
src/modules/network_data/repository/udm_sub.go
View File

@@ -46,7 +46,6 @@ func (r *UDMSubUser) SelectPage(query map[string]any) (int64, []model.UDMSubUser
// 查询数量 长度为0直接返回 // 查询数量 长度为0直接返回
if err := tx.Count(&total).Error; err != nil || total <= 0 { if err := tx.Count(&total).Error; err != nil || total <= 0 {
logger.Errorf("total err => %v", err)
return total, rows return total, rows
} }

15
src/modules/network_element/service/ne_info.go
View File

@@ -84,12 +84,17 @@ func (r *NeInfo) ClearNeCacheByNeType(neType string) bool {
func (r *NeInfo) SelectNeInfoByNeType(neType string) []model.NeInfo { func (r *NeInfo) SelectNeInfoByNeType(neType string) []model.NeInfo {
neInfo := make([]model.NeInfo, 0) neInfo := make([]model.NeInfo, 0)
key := fmt.Sprintf("%s%s:*", cachekey.NE_KEY, strings.ToUpper(neType)) key := fmt.Sprintf("%s%s:*", cachekey.NE_KEY, strings.ToUpper(neType))
jsonStr, _ := redis.Get("", key) cacheKeys, _ := redis.GetKeys("", key)
if len(jsonStr) > 7 { if len(cacheKeys) > 0 {
err := json.Unmarshal([]byte(jsonStr), &neInfo) for _, key := range cacheKeys {
if err != nil { var v model.NeInfo
return neInfo jsonStr, _ := redis.Get("", key)
if len(jsonStr) > 7 {
json.Unmarshal([]byte(jsonStr), &v)
}
neInfo = append(neInfo, v)
} }
return neInfo
} else { } else {
neInfo = r.neInfoRepository.SelectList(model.NeInfo{NeType: neType}) neInfo = r.neInfoRepository.SelectList(model.NeInfo{NeType: neType})
for _, v := range neInfo { for _, v := range neInfo {