From 87a2b299c7f00d458a9c63e44dc91386afea62bc Mon Sep 17 00:00:00 2001
From: TsMask <340112800@qq.com>
Date: Tue, 10 Dec 2024 17:59:10 +0800
Subject: [PATCH] =?UTF-8?q?feat:=20=E7=BD=91=E5=85=83=E4=BF=A1=E6=81=AF?=
 =?UTF-8?q?=E9=80=9A=E8=BF=87neType=E6=9F=A5=E8=AF=A2?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../network_element/service/ne_info.go        | 22 +++++++++++++++++++
 1 file changed, 22 insertions(+)

diff --git a/src/modules/network_element/service/ne_info.go b/src/modules/network_element/service/ne_info.go
index 244c5981..e01f5109 100644
--- a/src/modules/network_element/service/ne_info.go
+++ b/src/modules/network_element/service/ne_info.go
@@ -79,6 +79,28 @@ func (r *NeInfo) ClearNeCacheByNeType(neType string) bool {
 	return delOk
 }
 
+// SelectNeInfoByNeType 通过ne_type查询网元信息
+func (r *NeInfo) SelectNeInfoByNeType(neType string) []model.NeInfo {
+	neInfo := make([]model.NeInfo, 0)
+	key := fmt.Sprintf("%s%s:*", cachekey.NE_KEY, strings.ToUpper(neType))
+	jsonStr, _ := redis.Get("", key)
+	if len(jsonStr) > 7 {
+		err := json.Unmarshal([]byte(jsonStr), &neInfo)
+		if err != nil {
+			return neInfo
+		}
+	} else {
+		neInfo = r.neInfoRepository.SelectList(model.NeInfo{NeType: neType})
+		for _, v := range neInfo {
+			key := fmt.Sprintf("%s%s:%s", cachekey.NE_KEY, strings.ToUpper(v.NeType), v.NeId)
+			redis.Del("", key)
+			values, _ := json.Marshal(v)
+			redis.Set("", key, string(values))
+		}
+	}
+	return neInfo
+}
+
 // SelectNeInfoByRmuid 通过rmUID查询网元信息
 func (r *NeInfo) SelectNeInfoByRmuid(rmUid string) model.NeInfo {
 	var neInfo model.NeInfo