From c4dba41edb468a2bdf61e7ae0ca3fe6030e4d987 Mon Sep 17 00:00:00 2001
From: TsMask <340112800@qq.com>
Date: Fri, 22 Mar 2024 16:35:40 +0800
Subject: [PATCH] =?UTF-8?q?feat:=20=E9=85=8D=E7=BD=AE=E4=BF=AE=E6=94=B9?=
 =?UTF-8?q?=E6=8E=A8=E5=85=A5kafka?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 src/modules/nms_cxy/service/config.impl.go | 14 ++++++++++++++
 1 file changed, 14 insertions(+)

diff --git a/src/modules/nms_cxy/service/config.impl.go b/src/modules/nms_cxy/service/config.impl.go
index e752614..5f68477 100644
--- a/src/modules/nms_cxy/service/config.impl.go
+++ b/src/modules/nms_cxy/service/config.impl.go
@@ -2,22 +2,26 @@ package service
 
 import (
 	"fmt"
+	"nms_cxy/lib/core/utils/date"
 	"nms_cxy/src/framework/constants/uploadsubpath"
 	"nms_cxy/src/framework/logger"
 	"nms_cxy/src/framework/utils/cmd"
 	"nms_cxy/src/framework/utils/file"
+	"nms_cxy/src/framework/utils/generate"
 	"nms_cxy/src/framework/utils/ssh"
 	neModel "nms_cxy/src/modules/network_element/model"
 	neService "nms_cxy/src/modules/network_element/service"
 	"nms_cxy/src/modules/nms_cxy/utils/common"
 	"path/filepath"
 	"strings"
+	"time"
 )
 
 // 实例化数据层 ConfigImpl 结构体
 var NewConfigImpl = &ConfigImpl{
 	neInfoService:    neService.NewNeInfoImpl,
 	neVersionService: neService.NewNeVersionImpl,
+	resourceService:  NewResourceImpl,
 }
 
 // 配置数据处理服务 服务层处理
@@ -26,6 +30,8 @@ type ConfigImpl struct {
 	neInfoService neService.INeInfo
 	// 网元版本信息服务
 	neVersionService neService.INeVersion
+	// 资源数据处理服务
+	resourceService IResource
 }
 
 // ConfigUploadOSS 配置数据上报
@@ -438,6 +444,14 @@ func (s *ConfigImpl) ConfigParamModify(neInfo neModel.NeInfo, operType string, o
 	// 新增
 	// if operType == "add" {}
 
+	// 操作记录推送 Kafka
+	pushData := operPara
+	pushData["MsgID"] = generate.Code(9)
+	pushData["Ruid"] = neInfo.RmUID
+	pushData["ChangeTime"] = date.ParseDateToStr(time.Now(), date.YYYY_MM_DD_HH_MM_SS)
+	pushData["ChangeType"] = operType
+	s.resourceService.KafkaPush(neInfo.NeType, "", pushData)
+
 	return failPara
 }