72 lines
2.3 KiB
Go
72 lines
2.3 KiB
Go
|
package entity
|
|||
|
|
|
|||
|
|
import (
|
|||
|
|
"time"
|
|||
|
|
|
|||
|
|
"gitea.com/red-future/common/beans"
|
|||
|
|
)
|
|||
|
|
|
|||
|
|
// ConversationArchiveTempCollection 归档临时表名
|
|||
|
|
const ConversationArchiveTempCollection = "conversation_archive_temp"
|
|||
|
|
|
|||
|
|
// ConversationArchiveTemp 归档临时表实体（与 Conversation 结构相同）
|
|||
|
|
type ConversationArchiveTemp struct {
|
|||
|
|
beans.MongoBaseDO `bson:",inline"`
|
|||
|
|
|
|||
|
|
UserId string `bson:"userId" json:"userId"`
|
|||
|
|
Platform string `bson:"platform" json:"platform"`
|
|||
|
|
SessionId string `bson:"sessionId" json:"sessionId"`
|
|||
|
|
Question string `bson:"question" json:"question"`
|
|||
|
|
Answer string `bson:"answer" json:"answer"`
|
|||
|
|
MessageId string `bson:"messageId" json:"messageId"`
|
|||
|
|
MsgTime *time.Time `bson:"msgTime" json:"msgTime"` // 指针类型，与MongoBaseDO一致
|
|||
|
|
|
|||
|
|
// 原始文档 ID，用于删除原表数据
|
|||
|
|
OriginalId string `bson:"originalId" json:"originalId"`
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
// ConversationES ES 索引文档结构
|
|||
|
|
type ConversationES struct {
|
|||
|
|
Id string `json:"id"` // MongoDB 原始 ID
|
|||
|
|
UserId string `json:"userId"` // 用户ID
|
|||
|
|
Platform string `json:"platform"` // 平台
|
|||
|
|
SessionId string `json:"sessionId"` // Session ID
|
|||
|
|
Question string `json:"question"` // 问题
|
|||
|
|
Answer string `json:"answer"` // 回复
|
|||
|
|
MessageId string `json:"messageId"` // 消息ID
|
|||
|
|
MsgTime time.Time `json:"msgTime"` // 消息时间
|
|||
|
|
TenantId string `json:"tenantId"` // 租户ID
|
|||
|
|
CreatedAt time.Time `json:"createdAt"` // 创建时间
|
|||
|
|
UpdatedAt time.Time `json:"updatedAt"` // 更新时间
|
|||
|
|
ArchivedAt time.Time `json:"archivedAt"` // 归档时间
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
// ConversationESMapping ES 索引映射
|
|||
|
|
const ConversationESMapping = `
|
|||
|
|
{
|
|||
|
|
"settings": {
|
|||
|
|
"number_of_shards": 3,
|
|||
|
|
"number_of_replicas": 1
|
|||
|
|
},
|
|||
|
|
"mappings": {
|
|||
|
|
"properties": {
|
|||
|
|
"id": { "type": "keyword" },
|
|||
|
|
"userId": { "type": "keyword" },
|
|||
|
|
"platform": { "type": "keyword" },
|
|||
|
|
"sessionId": { "type": "keyword" },
|
|||
|
|
"question": { "type": "text", "analyzer": "standard" },
|
|||
|
|
"answer": { "type": "text", "analyzer": "standard" },
|
|||
|
|
"messageId": { "type": "keyword" },
|
|||
|
|
"msgTime": { "type": "date" },
|
|||
|
|
"tenantId": { "type": "keyword" },
|
|||
|
|
"createdAt": { "type": "date" },
|
|||
|
|
"updatedAt": { "type": "date" },
|
|||
|
|
"archivedAt": { "type": "date" }
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
`
|
|||
|
|
|
|||
|
|
// ConversationESIndex ES 索引名
|
|||
|
|
const ConversationESIndex = "conversations"
|