Feat/v0.12.0 (#57)

* feat: support blog

Author: xbingW

backend/docs/docs.go

@@ -72,8 +72,7 @@ const docTemplate = `{
                     {
                         "type": "string",
                         "name": "unknown_prompt",
-                        "in": "formData",
-                        "required": true
+                        "in": "formData"
                     }
                 ],
                 "responses": {
@@ -2765,6 +2764,11 @@ const docTemplate = `{
                         "name": "name",
                         "in": "query"
                     },
+                    {
+                        "type": "integer",
+                        "name": "org_id",
+                        "in": "query"
+                    },
                     {
                         "minimum": 1,
                         "type": "integer",
@@ -2845,7 +2849,7 @@ const docTemplate = `{
                                     "type": "object",
                                     "properties": {
                                         "data": {
-                                            "$ref": "#/definitions/svc.UserListItem"
+                                            "$ref": "#/definitions/model.User"
                                         }
                                     }
                                 }
@@ -4874,6 +4878,50 @@ const docTemplate = `{
                 }
             }
         },
+        "model.User": {
+            "type": "object",
+            "properties": {
+                "avatar": {
+                    "type": "string"
+                },
+                "builtin": {
+                    "type": "boolean"
+                },
+                "created_at": {
+                    "type": "integer"
+                },
+                "email": {
+                    "type": "string"
+                },
+                "id": {
+                    "type": "integer"
+                },
+                "invisible": {
+                    "type": "boolean"
+                },
+                "key": {
+                    "type": "string"
+                },
+                "last_login": {
+                    "type": "integer"
+                },
+                "name": {
+                    "type": "string"
+                },
+                "org_id": {
+                    "type": "integer"
+                },
+                "password": {
+                    "type": "string"
+                },
+                "role": {
+                    "$ref": "#/definitions/model.UserRole"
+                },
+                "updated_at": {
+                    "type": "integer"
+                }
+            }
+        },
         "model.UserInfo": {
             "type": "object",
             "properties": {
@@ -5897,6 +5945,12 @@ const docTemplate = `{
                 "name": {
                     "type": "string"
                 },
+                "org_id": {
+                    "type": "integer"
+                },
+                "org_name": {
+                    "type": "string"
+                },
                 "role": {
                     "$ref": "#/definitions/model.UserRole"
                 },

backend/model/org.go

@@ -0,0 +1,11 @@
+package model
+
+type Org struct {
+	Base
+
+	Name string `json:"name" gorm:"cloumn:name;type:text"`
+}
+
+func init() {
+	registerAutoMigrate(&Org{})
+}

backend/model/user.go

@@ -13,6 +13,7 @@ const (
 type User struct {
 	Base
 
+	OrgID     uint      `gorm:"column:org_id;type:bigint;default:0" json:"org_id"`
 	Name      string    `gorm:"column:name;type:text" json:"name"`
 	Email     string    `gorm:"column:email;type:text;default:null;uniqueIndex" json:"email"`
 	Avatar    string    `gorm:"column:avatar;type:text" json:"avatar"`

backend/pkg/llm/discussion.go

@@ -42,26 +42,13 @@ type KnowledgeDocument struct {
 
 // 帖子模版常量（包含帖子信息和评论楼层结构）
 const discussionPostTemplate = `
-## 当前帖子信息
-### 帖子ID：{{.Discussion.ID}}
-### 帖子标题：{{.Discussion.Title}}
-### 帖子内容：{{.Discussion.Content}}
-### 发帖人：{{.Discussion.UserName}}
-### 发帖时间：{{formatTime .Discussion.CreatedAt}}
+### ID：{{.Discussion.ID}}
+### 标题：{{.Discussion.Title}}
+### 内容：{{.Discussion.Content}}
+### 时间：{{formatTime .Discussion.CreatedAt}}
 {{- if .Discussion.Tags}}
-### 帖子标签：{{join .Discussion.Tags ", "}}
+### 标签：{{join .Discussion.Tags ", "}}
 {{- end}}
-### 解决状态：{{if .Discussion.Resolved}}已解决{{else}}待解决{{end}}
-
-## 评论楼层结构
-{{- if .CommentTree}}
-{{- range $i, $node := .CommentTree}}
-楼层{{add $i 1}} {{renderComment $node ""}}
-{{- end}}
-{{- else}}
-暂无评论
-{{- end}}
-
 `
 
 // 回复模版常量（针对新评论的回复）
@@ -137,20 +124,13 @@ func (t *DiscussionPromptTemplate) BuildPrompt() (string, error) {
 	return buf.String(), nil
 }
 
-// BuildPostPrompt 构建帖子提示词（用于回复帖子）
+// BuildPostPrompt 构建帖子提示词
 func (t *DiscussionPromptTemplate) BuildPostPrompt() (string, error) {
 	// 初始化帖子模版
 	if err := t.initPostTemplate(); err != nil {
 		return "", fmt.Errorf("初始化帖子模版失败: %w", err)
 	}
 
-	// 构建评论树
-	t.CommentTree = t.buildCommentTree()
-
-	// 提取BOT历史回复
-	t.ExtractBotReplies()
-
-	// 执行模版
 	var buf bytes.Buffer
 	if err := t.template.Execute(&buf, t); err != nil {
 		return "", fmt.Errorf("执行帖子模版失败: %w", err)

backend/pkg/llm/prompt.go

@@ -69,3 +69,20 @@ var SystemAnswerSummaryPrompt = `
 ## 回复要求
 只输出答案内容，不要任何解释、分析过程或其他额外内容，不要添加 "## 最佳答案" 等标题格式
 `
+
+var SystemBlogSummaryPrompt = `
+你是一个专业的博客内容总结助手，负责为技术博客生成简洁的内容概览。
+
+## 任务要求
+根据文章标题和内容，生成一段简洁的内容概览，帮助读者快速了解此文章的主要内容和价值。
+
+## 总结规则
+1. **客观准确**：严格基于博客原文内容，不添加任何博客中没有的信息
+2. **简洁明了**：用 2-3 句话概括博客的核心内容和主要观点
+3. **突出价值**：重点说明博客对读者的实用价值或解决的问题
+
+## 输出要求
+- 只输出内容概览，不要标题、解释或其他额外内容
+- 使用简洁的文字描述，无需 Markdown 格式
+- 字数控制在 100-150 字以内
+`

backend/pkg/webhook/message/discuss.go

@@ -114,8 +114,8 @@ func NewCreateBlog(body Common) Message {
 	return &discussMsg{
 		Header: Header{
 			MsgType:       TypeNewBlog,
-			MsgTitle:      "你有新的博客",
-			HeadingPrefix: "博客",
+			MsgTitle:      "你有新的文章",
+			HeadingPrefix: "标题",
 		},
 		Common: body,
 	}

backend/repo/org.go

@@ -0,0 +1,40 @@
+package repo
+
+import (
+	"context"
+
+	"github.com/chaitin/koalaqa/model"
+	"github.com/chaitin/koalaqa/pkg/database"
+	"gorm.io/gorm/clause"
+)
+
+type Org struct {
+	base[*model.Org]
+}
+
+func (o *Org) List(ctx context.Context, res any, queryFuncs ...QueryOptFunc) error {
+	quertOpt := getQueryOpt(queryFuncs...)
+
+	return o.model(ctx).Joins("LEFT JOIN (SELECT org_id, COUNT(*) AS count FROM users GROUP BY org_id) AS org_user ON org_user.org_id = orgs.id").
+		Scopes(quertOpt.Scopes()...).
+		Find(&res).Error
+}
+
+func (o *Org) Create(ctx context.Context, org *model.Org) error {
+	return o.model(ctx).Clauses(clause.OnConflict{
+		Columns:   []clause.Column{{Name: "id"}},
+		DoUpdates: clause.AssignmentColumns([]string{"name"}),
+	}).Create(org).Error
+}
+
+func newOrg(db *database.DB) *Org {
+	return &Org{
+		base: base[*model.Org]{
+			m: &model.Org{}, db: db,
+		},
+	}
+}
+
+func init() {
+	register(newOrg)
+}

backend/repo/user.go

@@ -16,6 +16,13 @@ type User struct {
 	base[*model.User]
 }
 
+func (u *User) ListWithOrg(ctx context.Context, res any, queryFuncs ...QueryOptFunc) error {
+	queryOpt := getQueryOpt(queryFuncs...)
+	return u.model(ctx).Select("users.*, orgs.name AS org_name").
+		Joins("LEFT JOIN orgs ON orgs.id = users.org_id").
+		Scopes(queryOpt.Scopes()...).Find(&res).Error
+}
+
 func (u *User) GetByEmail(ctx context.Context, res any, email string) error {
 	return u.model(ctx).Where("email = ?", email).First(&res).Error
 }

backend/repo/util.go

@@ -18,6 +18,7 @@ const (
 	EqualOPInclude
 	EqualOPContainAny
 	EqualOPValIn
+	EqualOPNotEqAny
 )
 
 type eqVal struct {
@@ -131,6 +132,8 @@ func equalScope(kv []kv) database.Scope {
 				db = db.Where(data.key+" IN (?)", data.value.v)
 			case EqualOPEqAny:
 				db = db.Where(data.key+" = ANY(?)", data.value.v)
+			case EqualOPNotEqAny:
+				db = db.Where(data.key+" != ALL(?)", data.value.v)
 			case EqualOPIntesect:
 				db = db.Where(data.key+" && ?", data.value.v)
 			case EqualOPInclude:

backend/router/admin/org.go

@@ -0,0 +1,74 @@
+package admin
+
+import (
+	"github.com/chaitin/koalaqa/pkg/context"
+	"github.com/chaitin/koalaqa/server"
+	"github.com/chaitin/koalaqa/svc"
+)
+
+type org struct {
+	svcOrg *svc.Org
+}
+
+func (o *org) List(ctx *context.Context) {
+	res, err := o.svcOrg.List(ctx)
+	if err != nil {
+		ctx.InternalError(err, "list org failed")
+		return
+	}
+
+	ctx.Success(res)
+}
+
+func (o *org) Upsert(ctx *context.Context) {
+	var req svc.OrgUpsertReq
+	err := ctx.ShouldBindJSON(&req)
+	if err != nil {
+		ctx.BadRequest(err)
+		return
+	}
+
+	res, err := o.svcOrg.Upsert(ctx, req)
+	if err != nil {
+		ctx.InternalError(err, "upsert org failed")
+		return
+	}
+
+	ctx.Success(res)
+}
+
+func (o *org) Delete(ctx *context.Context) {
+	orgID, err := ctx.ParamUint("org_id")
+	if err != nil {
+		ctx.BadRequest(err)
+		return
+	}
+
+	err = o.svcOrg.Delete(ctx, orgID)
+	if err != nil {
+		ctx.InternalError(err, "delete org failed")
+		return
+	}
+
+	ctx.Success(nil)
+}
+
+func (o *org) Route(h server.Handler) {
+	g := h.Group("/org")
+	g.GET("", o.List)
+	g.POST("", o.Upsert)
+	{
+		detailG := g.Group("/:org_id")
+		detailG.DELETE("", o.Delete)
+	}
+}
+
+func newOrg(o *svc.Org) server.Router {
+	return &org{
+		svcOrg: o,
+	}
+}
+
+func init() {
+	registerAdminAPIRouter(newOrg)
+}