From 8ac572b21513d66177ecb4d6ddc8a1d22c314420 Mon Sep 17 00:00:00 2001
From: simonzhangsz <simonzhangsz@outlook.com>
Date: Thu, 24 Aug 2023 10:52:26 +0800
Subject: [PATCH] cm

---
 crontask/gencmxml.go |  4 ++++
 lib/dborm/dborm.go   | 43 +++++++++++++++++++++++++++++++++++++++++++
 2 files changed, 47 insertions(+)

diff --git a/crontask/gencmxml.go b/crontask/gencmxml.go
index 2add655d..cb1047c0 100644
--- a/crontask/gencmxml.go
+++ b/crontask/gencmxml.go
@@ -10,6 +10,7 @@ import (
 	"time"
 
 	cmschema "ems.agt/crontask/cm/schema"
+	"ems.agt/lib/dborm"
 	"ems.agt/lib/global"
 	"ems.agt/lib/log"
 
@@ -69,6 +70,9 @@ func (t *TaskFunc) GenNFXmlFile(neType string) error {
 
 	resultMap, _ := t.ReadCmYaml(cmfile)
 
+	var cmResults []dborm.NorthboundCm
+	err = dborm.XormGetNorthboundCm(neType, &cmResults)
+
 	ti := time.Now()
 	timestamp := ti.Format("2006-01-02 15:04:05")
 	timefile := ti.Format("20060102150405")
diff --git a/lib/dborm/dborm.go b/lib/dborm/dborm.go
index dcf3fd95..ec3b9909 100644
--- a/lib/dborm/dborm.go
+++ b/lib/dborm/dborm.go
@@ -1622,3 +1622,46 @@ func XormUpdateNeLicense(neType, neID string, capcity int) (int64, error) {
 	affected, err := res.RowsAffected()
 	return affected, err
 }
+
+type NorthboundCm struct {
+	ID            int         `json:"-" xorm:"pk 'id' autoincr"`
+	Timestamp     string      `json:"timestamp" xorm:"timestamp"`
+	TimeZone      string      `json:"timeZone" xorm:"time_zone"`
+	VendorName    string      `json:"vendorName" xorm:"vendor_name"`
+	NeType        string      `json:"neType" xorm:"ne_type"`
+	CmVersion     string      `json:"cmVersion" xorm:"cm_version"`
+	RmUID         string      `json:"rmUID" xorm:"rm_uid"`
+	NeID          string      `json:"neID" xorm:"ne_id"`
+	UserLabel     string      `json:"userLabel" xorm:"user_label"`
+	ObjectType    string      `json:"objectType" xorm:"object_type"`
+	PvFlag        string      `json:"pvFlag" xorm:"pv_flag"`
+	VMID          string      `json:"vmID" xorm:"vm_id"`
+	VnfInstanceID string      `json:"vnf_instance_id"`
+	ValueJSON     interface{} `json:"valueJson" xorm:"value_json"`
+	Status        string      `json:"status" xorm:"status"`
+}
+
+func XormGetNorthboundCm(neType string, cmResults *[]NorthboundCm) error {
+	log.Info("XormGetNorthboundCm processing... ")
+
+	cmResult := new(NorthboundCm)
+	rows, err := xEngine.Table("northbound_cm").
+		Where("`ne_type` = ?", neType).
+		Distinct("object_type").
+		Desc("timestamp").
+		Rows(cmResult)
+	if err != nil {
+		log.Error("Failed to get table northbound_cm:", err)
+		return err
+	}
+	defer rows.Close()
+	for rows.Next() {
+		err := rows.Scan(cmResult)
+		if err != nil {
+			log.Error("Failed to get table northbound_cm:", err)
+			return err
+		}
+		*cmResults = append(*cmResults, *cmResult)
+	}
+	return nil
+}