裁剪北向接口

lib/dborm/dborm.go

@@ -1727,3 +1727,45 @@ func XormGetNorthboundCmLatestObject(neType, neID, objectType string) (*Northbou
 
 	return cmResult, nil
 }
+
+type TraceData struct {
+	ID        int    `json:"id" xorm:"pk 'id' autoincr"`
+	TaskID    int    `json:"taskID" xorm:"task_id"`
+	Imsi      string `json:"imsi" xorm:"imsi"`
+	Msisdn    string `json:"msisdn" xorm:"msisdn"`
+	SrcAddr   string `json:"srcAddr" xorm:"src_addr"`
+	DstAddr   string `json:"dstAddr" xorm:"dst_addr"`
+	IfType    int    `json:"ifType" xorm:"if_type"`
+	MsgType   int    `json:"msgType" xorm:"msg_type"`
+	MsgDirect int    `json:"msgDirect" xorm:"msg_direct"`
+	Timestamp int64  `json:"timestamp" xorm:"timestamp"`
+	RawMsg    []byte `json:"rawMsg" xorm:"raw_msg"`
+	DecMsg    string `json:"decMsg" xorm:"dec_msg"`
+}
+
+func XormGetTraceData(id int) (*TraceData, error) {
+	result := new(TraceData)
+	_, err := xEngine.Table("trace_data").
+		ID(id).
+		Get(result)
+	if err != nil {
+		log.Error("Failed to get table trace_data:", err)
+		return nil, err
+	}
+
+	return result, nil
+}
+
+func XormGetTraceRawMsg(id int) ([]byte, error) {
+	var rawMsg []byte
+	_, err := xEngine.Table("trace_data").
+		ID(id).
+		Cols("HEX(raw_msg)").
+		Get(&rawMsg)
+	if err != nil {
+		log.Error("Failed to get table trace_data:", err)
+		return nil, err
+	}
+
+	return rawMsg, nil
+}