222 changed files with 11950 additions and 4572 deletions
--- a/.gitea/workflows/build-image.yaml
+++ b/.gitea/workflows/build-image.yaml
@ -0,0 +1,54 @@
+name: BuildImage
+
+on:
+  push:
+#    branches:
+#      - main
+    tags:
+      - '*'
+
+jobs:
+  build-image:
+    runs-on: ubuntu-latest
+    container:
+      # 使用这个镜像，不然Docker无法打包镜像
+      image: catthehacker/ubuntu:act-latest
+
+    steps:
+      - name: Setup Golang
+        uses: actions/setup-go@v3
+        with:
+          go-version: '>=1.21.0'
+          cache: false
+
+      - name: Checkout Code
+        uses: actions/checkout@v3
+
+      - name: Gen Tags
+        id: gen_tags
+        uses: docker/metadata-action@98669ae865ea3cffbcbaa878cf57c20bbf1c6c38
+        with:
+          images: gitee.ltd/lxh/go-wxhelper
+          tags: |
+            type=ref,event=branch
+            type=ref,event=tag
+
+      - name: Print Tags
+        run: |
+          echo "${{ steps.gen_tags.outputs.tags }}"
+          echo "----------------- labels -----------------"
+          echo "${{ steps.meta.outputs.labels }}"
+
+      - name: Login to Repository
+        uses: docker/login-action@v2
+        with:
+          registry: gitee.ltd
+          username: ${{ secrets.USERNAME }}
+          password: ${{ secrets.PASSWORD }}
+
+      - name: Build image
+        uses: docker/build-push-action@v2
+        with:
+          push: true
+          tags: ${{ steps.gen_tags.outputs.tags }}
+          labels: ${{ steps.gen_tags.outputs.labels }}
--- a/.gitignore
+++ b/.gitignore
@ -1,10 +1,11 @@
 .idea
 vendor
 logs
-*build*
-debug
+*.exe
+*.pprof
+cache
+log
 dist
-
-*_deleted*
-
-config.yaml
+*.log
+blacklist.txt
+frontend.*
--- a/21
+++ b/21
@ -1,18 +1,21 @@
 FROM golang:alpine as builder
-
 WORKDIR /builder
 COPY . .
-RUN go mod download
-RUN go build -o app
-RUN ls -lh && chmod +x ./app
+
+#ENV GO111MODULE=on
+#ENV GOPROXY=https://goproxy.cn,direct
+
+RUN go version
+RUN go mod download && go build -o wxhelper
+RUN ls -lh && chmod -R +x ./*

 FROM code.hyxc1.com/open/alpine:3.16.0 as runner
 LABEL org.opencontainers.image.authors="lxh@cxh.cn"

-# 定义一下版本号
-ARG APP_VER
-ENV APP_VER=${APP_VER}
+EXPOSE 19099
+EXPOSE 8080

 WORKDIR /app
-COPY --from=builder /builder/app ./app
-CMD ./app
+COPY --from=builder /builder/wxhelper ./wxhelper
+COPY --from=builder /builder/views ./views
+CMD ./wxhelper
--- a/api/admin/aiassistant/delete.go
+++ b/api/admin/aiassistant/delete.go
@ -1,25 +0,0 @@
-package aiassistant
-
-import (
-	"github.com/gin-gonic/gin"
-	"unicode/utf8"
-	"wechat-robot/pkg/response"
-	aiAssistantService "wechat-robot/service/aiassistant"
-)
-
-// DeleteById
-// @description: 删除AI助手
-// @param ctx
-func DeleteById(ctx *gin.Context) {
-	var id = ctx.Param("id")
-	if utf8.RuneCountInString(id) != 32 {
-		response.New(ctx).SetMsg("参数错误").Fail()
-		return
-	}
-	// 删除数据
-	if err := aiAssistantService.DeleteById(id); err != nil {
-		response.New(ctx).SetMsg("删除失败").SetError(err).Fail()
-	} else {
-		response.New(ctx).SetMsg("删除成功").Success()
-	}
-}
--- a/api/admin/aiassistant/save.go
+++ b/api/admin/aiassistant/save.go
@ -1,25 +0,0 @@
-package aiassistant
-
-import (
-	"github.com/gin-gonic/gin"
-	"wechat-robot/model/param/aiassistant"
-	"wechat-robot/pkg/response"
-	aiAssistantService "wechat-robot/service/aiassistant"
-)
-
-// Save
-// @description: 保存AI助手
-// @param ctx
-func Save(ctx *gin.Context) {
-	var p aiassistant.Save
-	if err := ctx.ShouldBind(&p); err != nil {
-		response.New(ctx).SetMsg("参数错误").SetError(err).Fail()
-		return
-	}
-	// 保存数据
-	if err := aiAssistantService.Save(p); err != nil {
-		response.New(ctx).SetMsg("保存失败").SetError(err).Fail()
-		return
-	}
-	response.New(ctx).SetMsg("保存成功").Success()
-}
--- a/api/admin/aiassistant/select.go
+++ b/api/admin/aiassistant/select.go
@ -1,26 +0,0 @@
-package aiassistant
-
-import (
-	"github.com/gin-gonic/gin"
-	"wechat-robot/model/param/aiassistant"
-	"wechat-robot/pkg/response"
-	aiAssistantService "wechat-robot/service/aiassistant"
-)
-
-// GetAll
-// @description: 获取所有AI助手
-// @param ctx
-func GetAll(ctx *gin.Context) {
-	var p aiassistant.GetAll
-	if err := ctx.ShouldBind(&p); err != nil {
-		response.New(ctx).SetMsg("参数错误").SetError(err).Fail()
-		return
-	}
-
-	records, err := aiAssistantService.GetAll(p)
-	if err != nil {
-		response.New(ctx).SetMsg("获取失败").SetError(err).Fail()
-		return
-	}
-	response.New(ctx).SetData(records).Success()
-}
--- a/api/admin/login/captcha.go
+++ b/api/admin/login/captcha.go
@ -1,34 +0,0 @@
-package login
-
-import (
-	"github.com/gin-gonic/gin"
-	"github.com/mojocn/base64Captcha"
-	"wechat-robot/model/vo/login"
-	"wechat-robot/pkg/captcha"
-	"wechat-robot/pkg/response"
-)
-
-// GetImgCaptcha
-// @description: 获取图片验证码
-// @param ctx
-func GetImgCaptcha(ctx *gin.Context) {
-	store := new(captcha.RedisStore)
-	math := base64Captcha.DriverMath{
-		Height: 60,
-		Width:  240,
-		Fonts:  []string{"ApothecaryFont.ttf"},
-	}
-
-	driver := math.ConvertFonts()
-
-	// 验证码生成器
-	c := base64Captcha.NewCaptcha(driver, store)
-	id, imgStr, _, err := c.Generate()
-	if err != nil {
-		response.New(ctx).SetMsg("验证码生成失败").Fail()
-		return
-	}
-	// 数据返回
-	result := login.CaptchaCode{Id: id, Img: imgStr}
-	response.New(ctx).SetData(result).Success()
-}
--- a/api/admin/login/login.go
+++ b/api/admin/login/login.go
@ -1,120 +0,0 @@
-package login
-
-import (
-	"context"
-	"encoding/json"
-	"gitee.ltd/lxh/logger/log"
-	"github.com/gin-gonic/gin"
-	"net/http"
-	"net/url"
-	"wechat-robot/internal/redis"
-	"wechat-robot/model/param/login"
-	"wechat-robot/pkg/auth"
-	"wechat-robot/pkg/captcha"
-	"wechat-robot/pkg/response"
-	userService "wechat-robot/service/adminuser"
-)
-
-// Login
-// @description: 登录
-// @param ctx
-// @return err
-func Login(ctx *gin.Context) {
-	log.Debugf("收到登录请求")
-	var p login.GetTokenWithPassword
-	if err := ctx.ShouldBind(&p); err != nil {
-		response.New(ctx).SetMsg("参数错误").SetError(err).Fail()
-		return
-	}
-
-	// 验证验证码是否正确
-	if !new(captcha.RedisStore).Verify(p.VerifyId, p.VerifyCode, true) {
-		response.New(ctx).SetMsg("验证码错误").Fail()
-		return
-	}
-
-	// 重写参数
-	ctx.Request.Form = url.Values{
-		"username":   {p.Username},
-		"password":   {p.Password},
-		"scope":      {"ALL"},
-		"grant_type": {"password"},
-	}
-	// 参数解析成功，进行登录
-	if err := auth.OAuthServer.HandleTokenRequest(ctx.Writer, ctx.Request); err != nil {
-		log.Errorf("登录失败：%s", err.Error())
-		response.New(ctx).SetMsg("系统错误").SetError(err).Fail()
-		return
-	}
-
-	if ctx.Writer.Status() == http.StatusOK {
-		go userService.UpdateLastLoginInfo(p.Username, ctx.ClientIP())
-	}
-}
-
-// Refresh
-// @description: 刷新Token
-// @param ctx
-func Refresh(ctx *gin.Context) {
-	var p login.RefreshToken
-	if err := ctx.ShouldBind(&p); err != nil {
-		response.New(ctx).SetMsg("参数错误").SetError(err).Fail()
-		return
-	}
-
-	// 取出用户Id
-	userId := auth.GetUserIdWithRefreshToken(p.RefreshToken)
-
-	// 重写参数
-	ctx.Request.Form = url.Values{
-		"refresh_token": {p.RefreshToken},
-		"grant_type":    {"refresh_token"},
-	}
-
-	// 刷新Token
-	if err := auth.OAuthServer.HandleTokenRequest(ctx.Writer, ctx.Request); err != nil {
-		log.Errorf("Token数据返回失败: %v", err.Error())
-		response.New(ctx).SetMsg("系统错误").Fail()
-	}
-
-	// 登录成功才更新登录时间
-	if ctx.Writer.Status() == http.StatusOK {
-		// 登录成功，更新登录时间和IP
-		go userService.UpdateLastLoginInfo(userId, ctx.ClientIP())
-	}
-}
-
-// Logout
-// @description: 退出登录
-// @param ctx
-func Logout(ctx *gin.Context) {
-	log.Debug("退出登录啦")
-	// Token字符串前缀
-	const bearerSchema string = "Bearer "
-	// 取出Token
-	tokenHeader := ctx.GetHeader("Authorization")
-	tokenStr := tokenHeader[len(bearerSchema):]
-	// 取出原始RedisKey
-	baseDataId, err := redis.Client.Get(context.Background(), "oauth:token:"+tokenStr).Result()
-	if err != nil {
-		response.New(ctx).SetMsg("Token信息获取失败").Fail()
-		return
-	}
-	baseDataStr, err := redis.Client.Get(context.Background(), "oauth:token:"+baseDataId).Result()
-	if err != nil {
-		response.New(ctx).SetMsg("Token信息获取失败").Fail()
-		return
-	}
-	// 转换数据为Map
-	tokenData := make(map[string]interface{})
-	if err = json.Unmarshal([]byte(baseDataStr), &tokenData); err != nil {
-		response.New(ctx).SetMsg("系统错误").SetError(err).Fail()
-		return
-	}
-	// 删除Redis缓存的数据
-	redis.Client.Del(context.Background(), "oauth:token:"+baseDataId)
-	redis.Client.Del(context.Background(), "oauth:token:"+tokenData["Access"].(string))
-	redis.Client.Del(context.Background(), "oauth:token:"+tokenData["Refresh"].(string))
-
-	response.New(ctx).Success()
-}
--- a/api/admin/menu/menu.go
+++ b/api/admin/menu/menu.go
@ -1 +0,0 @@
-package menu
--- a/api/admin/menu/save.go
+++ b/api/admin/menu/save.go
@ -1,24 +0,0 @@
-package menu
-
-import (
-	"github.com/gin-gonic/gin"
-	menuParam "wechat-robot/model/param/menu"
-	"wechat-robot/pkg/response"
-	"wechat-robot/service/menu"
-)
-
-// Save
-// @description: 保存菜单
-// @param ctx
-func Save(ctx *gin.Context) {
-	var p menuParam.Save
-	if err := ctx.ShouldBind(&p); err != nil {
-		response.New(ctx).SetError(err).Fail()
-		return
-	}
-	if err := menu.Save(p); err != nil {
-		response.New(ctx).SetError(err).Fail()
-		return
-	}
-	response.New(ctx).Success()
-}
--- a/api/admin/menu/user.go
+++ b/api/admin/menu/user.go
@ -1,23 +0,0 @@
-package menu
-
-import (
-	"github.com/gin-gonic/gin"
-	"wechat-robot/pkg/response"
-	"wechat-robot/service/menu"
-)
-
-// GetUserMenuTree
-// @description: 获取用户权限内的菜单树
-// @param ctx
-func GetUserMenuTree(ctx *gin.Context) {
-	// 获取用户Id
-	userId := ctx.GetString("userId")
-	// 获取菜单树
-	tree, err := menu.GetUserMenus(userId)
-	if err != nil {
-		response.New(ctx).SetMsg("系统错误").SetError(err).Fail()
-		return
-	}
-	// 返回数据
-	response.New(ctx).SetData(tree).Success()
-}
--- a/api/admin/robot/delete.go
+++ b/api/admin/robot/delete.go
@ -1,25 +0,0 @@
-package robot
-
-import (
-	"github.com/gin-gonic/gin"
-	"unicode/utf8"
-	"wechat-robot/pkg/response"
-	robotService "wechat-robot/service/robot"
-)
-
-// DeleteById
-// @description: 删除机器人
-// @param ctx
-func DeleteById(ctx *gin.Context) {
-	var id = ctx.Param("id")
-	if utf8.RuneCountInString(id) != 32 {
-		response.New(ctx).SetMsg("参数错误").Fail()
-		return
-	}
-	// 删除数据
-	if err := robotService.DeleteById(id); err != nil {
-		response.New(ctx).SetMsg("删除失败").SetError(err).Fail()
-	} else {
-		response.New(ctx).SetMsg("删除成功").Success()
-	}
-}
--- a/api/admin/robot/save.go
+++ b/api/admin/robot/save.go
@ -1,31 +0,0 @@
-package robot
-
-import (
-	"github.com/gin-gonic/gin"
-	robotParam "wechat-robot/model/param/robot"
-	"wechat-robot/pkg/response"
-	robotService "wechat-robot/service/robot"
-)
-
-// Save
-// @description: 保存机器人
-// @param ctx
-func Save(ctx *gin.Context) {
-	var p robotParam.Save
-	if err := ctx.ShouldBind(&p); err != nil {
-		response.New(ctx).SetMsg("参数错误").SetError(err).Fail()
-		return
-	}
-
-	// 参数校验
-	if p.Id == "" && (p.HookApi == "" || p.Version == 0) {
-		response.New(ctx).SetMsg("参数错误").Fail()
-		return
-	}
-
-	if err := robotService.Save(p); err != nil {
-		response.New(ctx).SetMsg("保存失败").SetError(err).Fail()
-		return
-	}
-	response.New(ctx).SetMsg("保存成功").Success()
-}
--- a/api/admin/robot/select.go
+++ b/api/admin/robot/select.go
@ -1,26 +0,0 @@
-package robot
-
-import (
-	"github.com/gin-gonic/gin"
-	robotParam "wechat-robot/model/param/robot"
-	"wechat-robot/pkg/response"
-	robotService "wechat-robot/service/robot"
-)
-
-// GetAll
-// @description: 获取所有机器人
-// @param ctx
-func GetAll(ctx *gin.Context) {
-	var p robotParam.GetAll
-	if err := ctx.ShouldBind(&p); err != nil {
-		response.New(ctx).SetMsg("参数错误").SetError(err).Fail()
-		return
-	}
-
-	records, err := robotService.GetAll(p)
-	if err != nil {
-		response.New(ctx).SetMsg("数据获取失败").SetError(err).Fail()
-		return
-	}
-	response.New(ctx).SetData(records).Success()
-}
--- a/api/admin/role/role.go
+++ b/api/admin/role/role.go
@ -1,27 +0,0 @@
-package role
-
-import (
-	"github.com/gin-gonic/gin"
-	roleParam "wechat-robot/model/param/role"
-	"wechat-robot/pkg/response"
-	roleService "wechat-robot/service/role"
-)
-
-// GetAll
-// @description: 获取所有角色
-// @param ctx
-func GetAll(ctx *gin.Context) {
-	var p roleParam.GetAll
-	if err := ctx.ShouldBind(&p); err != nil {
-		response.New(ctx).SetMsg("参数错误").SetError(err).Fail()
-		return
-	}
-
-	records, err := roleService.GetAll(p)
-	if err != nil {
-		response.New(ctx).SetMsg("获取所有角色失败").SetError(err).Fail()
-		return
-	}
-
-	response.New(ctx).SetData(records).Success()
-}
--- a/api/callback/hook.go
+++ b/api/callback/hook.go
@ -1,21 +0,0 @@
-package callback
-
-import (
-	"gitee.ltd/lxh/logger/log"
-	"github.com/gin-gonic/gin"
-	"wechat-robot/model/param/callback"
-	"wechat-robot/pkg/response"
-)
-
-// RobotHookNotify
-// @description: 机器人HOOK后回调
-// @param ctx
-func RobotHookNotify(ctx *gin.Context) {
-	var param callback.RobotHook
-	if err := ctx.ShouldBind(&param); err != nil {
-		response.New(ctx).SetError(err).Fail()
-		return
-	}
-
-	log.Debugf("机器人已启动，Id: %s", param.Robot)
-}
--- a/app/assistant.go
+++ b/app/assistant.go
@ -0,0 +1,36 @@
+package app
+
+import (
+	"github.com/gin-gonic/gin"
+	"go-wechat/common/response"
+	"go-wechat/config"
+	"go-wechat/service"
+)
+
+// SaveAssistant
+// @description: 保存AI助手
+// @param ctx
+func SaveAssistant(ctx *gin.Context) {
+
+	//ctx.String(http.StatusOK, "操作成功")
+	ctx.Redirect(302, "/assistant.html")
+}
+
+// GetAssistants
+// @description: 获取AI助手列表
+// @param ctx
+func GetAssistants(ctx *gin.Context) {
+	records, err := service.GetAllAiAssistant()
+	if err != nil {
+		response.New(ctx).SetMsg("系统错误").SetError(err).Fail()
+		return
+	}
+	response.New(ctx).SetData(records).Success()
+}
+
+// GetAiModels
+// @description: 获取AI模型列表
+// @param ctx
+func GetAiModels(ctx *gin.Context) {
+	response.New(ctx).SetData(config.Conf.Ai.Models).Success()
+}
--- a/app/contact.go
+++ b/app/contact.go
@ -0,0 +1,33 @@
+package app
+
+import (
+	"github.com/gin-gonic/gin"
+	"go-wechat/common/response"
+	"go-wechat/service"
+)
+
+// GetFriends
+// @description: 获取好友列表
+// @param ctx
+func GetFriends(ctx *gin.Context) {
+	// 取出所有好友列表
+	friends, _, err := service.GetAllFriend()
+	if err != nil {
+		response.New(ctx).SetMsg("系统错误").SetError(err).Fail()
+	}
+
+	response.New(ctx).SetData(friends).Success()
+}
+
+// GetGroups
+// @description: 获取群列表
+// @param ctx
+func GetGroups(ctx *gin.Context) {
+	// 取出所有好友列表
+	_, groups, err := service.GetAllFriend()
+	if err != nil {
+		response.New(ctx).SetMsg("系统错误").SetError(err).Fail()
+	}
+
+	response.New(ctx).SetData(groups).Success()
+}
--- a/app/friend.go
+++ b/app/friend.go
@ -0,0 +1,259 @@
+package app
+
+import (
+	"github.com/gin-gonic/gin"
+	"go-wechat/client"
+	"go-wechat/model/entity"
+	"gorm.io/gorm"
+	"log"
+	"net/http"
+)
+
+// changeStatusParam
+// @description: 修改状态用的参数集
+type changeStatusParam struct {
+	WxId   string `json:"wxId" binding:"required"`
+	UserId string `json:"userId"`
+}
+
+// changeUseAiModelParam
+// @description: 修改使用的AI模型用的参数集
+type changeUseAiModelParam struct {
+	WxId  string `json:"wxid" binding:"required"`  // 群Id或微信Id
+	Model string `json:"model" binding:"required"` // 模型代码
+}
+
+// autoClearMembers
+// @description: 自动清理群成员
+type autoClearMembers struct {
+	WxId string `json:"wxid" binding:"required"` // 群Id
+	Days int    `json:"days"`                    // 多少天未发言
+}
+
+// ChangeEnableAiStatus
+// @description: 修改是否开启AI
+// @param ctx
+func ChangeEnableAiStatus(ctx *gin.Context) {
+	var p changeStatusParam
+	if err := ctx.ShouldBindJSON(&p); err != nil {
+		ctx.String(http.StatusBadRequest, "参数错误")
+		return
+	}
+	log.Printf("待修改的微信Id：%s", p.WxId)
+
+	err := client.MySQL.Model(&entity.Friend{}).
+		Where("wxid = ?", p.WxId).
+		Update("`enable_ai`", gorm.Expr(" !`enable_ai`")).Error
+	if err != nil {
+		log.Printf("修改是否开启AI失败：%s", err)
+		ctx.String(http.StatusInternalServerError, "操作失败: %s", err)
+		return
+	}
+
+	ctx.String(http.StatusOK, "操作成功")
+}
+
+// ChangeUseAiModel
+// @description: 修改使用的AI模型
+// @param ctx
+func ChangeUseAiModel(ctx *gin.Context) {
+	var p changeUseAiModelParam
+	if err := ctx.ShouldBind(&p); err != nil {
+		ctx.String(http.StatusBadRequest, "参数错误")
+		return
+	}
+	err := client.MySQL.Model(&entity.Friend{}).
+		Where("wxid = ?", p.WxId).
+		Update("`ai_model`", p.Model).Error
+	if err != nil {
+		log.Printf("修改【%s】的AI模型失败：%s", p.WxId, err)
+		ctx.String(http.StatusInternalServerError, "操作失败: %s", err)
+		return
+	}
+
+	ctx.String(http.StatusOK, "操作成功")
+}
+
+// ChangeUseAiAssistant
+// @description: 修改使用的AI助手
+// @param ctx
+func ChangeUseAiAssistant(ctx *gin.Context) {
+	// 此处复用一下结构体
+	var p changeUseAiModelParam
+	if err := ctx.ShouldBind(&p); err != nil {
+		ctx.String(http.StatusBadRequest, "参数错误")
+		return
+	}
+	err := client.MySQL.Model(&entity.Friend{}).
+		Where("wxid = ?", p.WxId).
+		Update("`prompt`", p.Model).Error
+	if err != nil {
+		log.Printf("修改【%s】的AI助手失败：%s", p.WxId, err)
+		ctx.String(http.StatusInternalServerError, "操作失败: %s", err)
+		return
+	}
+
+	ctx.String(http.StatusOK, "操作成功")
+}
+
+// ChangeEnableGroupRankStatus
+// @description: 修改是否开启水群排行榜
+// @param ctx
+func ChangeEnableGroupRankStatus(ctx *gin.Context) {
+	var p changeStatusParam
+	if err := ctx.ShouldBindJSON(&p); err != nil {
+		ctx.String(http.StatusBadRequest, "参数错误")
+		return
+	}
+	log.Printf("待修改的群Id：%s", p.WxId)
+
+	err := client.MySQL.Model(&entity.Friend{}).
+		Where("wxid = ?", p.WxId).
+		Update("`enable_chat_rank`", gorm.Expr(" !`enable_chat_rank`")).Error
+	if err != nil {
+		log.Printf("修改开启水群排行榜失败：%s", err)
+		ctx.String(http.StatusInternalServerError, "操作失败: %s", err)
+		return
+	}
+
+	ctx.String(http.StatusOK, "操作成功")
+}
+
+// ChangeEnableSummaryStatus
+// @description: 修改是否开启聊天记录总结
+// @param ctx
+func ChangeEnableSummaryStatus(ctx *gin.Context) {
+	var p changeStatusParam
+	if err := ctx.ShouldBindJSON(&p); err != nil {
+		ctx.String(http.StatusBadRequest, "参数错误")
+		return
+	}
+	log.Printf("待修改的群Id：%s", p.WxId)
+
+	err := client.MySQL.Model(&entity.Friend{}).
+		Where("wxid = ?", p.WxId).
+		Update("`enable_summary`", gorm.Expr(" !`enable_summary`")).Error
+	if err != nil {
+		log.Printf("修改开启聊天记录总结失败：%s", err)
+		ctx.String(http.StatusInternalServerError, "操作失败: %s", err)
+		return
+	}
+
+	ctx.String(http.StatusOK, "操作成功")
+}
+
+// ChangeEnableWelcomeStatus
+// @description: 修改是否开启迎新
+// @param ctx
+func ChangeEnableWelcomeStatus(ctx *gin.Context) {
+	var p changeStatusParam
+	if err := ctx.ShouldBindJSON(&p); err != nil {
+		ctx.String(http.StatusBadRequest, "参数错误")
+		return
+	}
+	log.Printf("待修改的群Id：%s", p.WxId)
+
+	err := client.MySQL.Model(&entity.Friend{}).
+		Where("wxid = ?", p.WxId).
+		Update("`enable_welcome`", gorm.Expr(" !`enable_welcome`")).Error
+	if err != nil {
+		log.Printf("修改开启迎新失败：%s", err)
+		ctx.String(http.StatusInternalServerError, "操作失败: %s", err)
+		return
+	}
+
+	ctx.String(http.StatusOK, "操作成功")
+}
+
+// ChangeEnableCommandStatus
+// @description: 修改是否开启指令
+// @param ctx
+func ChangeEnableCommandStatus(ctx *gin.Context) {
+	var p changeStatusParam
+	if err := ctx.ShouldBindJSON(&p); err != nil {
+		ctx.String(http.StatusBadRequest, "参数错误")
+		return
+	}
+	log.Printf("待修改的群Id：%s", p.WxId)
+
+	err := client.MySQL.Model(&entity.Friend{}).
+		Where("wxid = ?", p.WxId).
+		Update("`enable_command`", gorm.Expr(" !`enable_command`")).Error
+	if err != nil {
+		log.Printf("修改指令启用状态失败：%s", err)
+		ctx.String(http.StatusInternalServerError, "操作失败: %s", err)
+		return
+	}
+
+	ctx.String(http.StatusOK, "操作成功")
+}
+
+// ChangeSkipGroupRankStatus
+// @description: 修改是否跳过水群排行榜
+// @param ctx
+func ChangeSkipGroupRankStatus(ctx *gin.Context) {
+	var p changeStatusParam
+	if err := ctx.ShouldBindJSON(&p); err != nil {
+		ctx.String(http.StatusBadRequest, "参数错误")
+		return
+	}
+	log.Printf("待修改的群Id：%s -> %s", p.WxId, p.UserId)
+
+	err := client.MySQL.Model(&entity.GroupUser{}).
+		Where("group_id = ?", p.WxId).
+		Where("wxid = ?", p.UserId).
+		Update("`skip_chat_rank`", gorm.Expr(" !`skip_chat_rank`")).Error
+	if err != nil {
+		log.Printf("修改跳过水群排行榜失败：%s", err)
+		ctx.String(http.StatusInternalServerError, "操作失败: %s", err)
+		return
+	}
+
+	ctx.String(http.StatusOK, "操作成功")
+}
+
+// ChangeEnableNewsStatus
+// @description: 修改是否开启新闻
+// @param ctx
+func ChangeEnableNewsStatus(ctx *gin.Context) {
+	var p changeStatusParam
+	if err := ctx.ShouldBindJSON(&p); err != nil {
+		ctx.String(http.StatusBadRequest, "参数错误")
+		return
+	}
+	log.Printf("待修改的Id：%s", p.WxId)
+
+	err := client.MySQL.Model(&entity.Friend{}).
+		Where("wxid = ?", p.WxId).
+		Update("`enable_news`", gorm.Expr(" !`enable_news`")).Error
+	if err != nil {
+		log.Printf("修改早报启用状态失败：%s", err)
+		ctx.String(http.StatusInternalServerError, "操作失败: %s", err)
+		return
+	}
+
+	ctx.String(http.StatusOK, "操作成功")
+}
+
+// AutoClearMembers
+// @description: 自动清理群成员
+// @param ctx
+func AutoClearMembers(ctx *gin.Context) {
+	var p autoClearMembers
+	if err := ctx.ShouldBindJSON(&p); err != nil {
+		ctx.String(http.StatusBadRequest, "参数错误")
+		return
+	}
+	log.Printf("待修改的Id：%s", p.WxId)
+
+	err := client.MySQL.Model(&entity.Friend{}).
+		Where("wxid = ?", p.WxId).
+		Update("`clear_member`", p.Days).Error
+	if err != nil {
+		log.Printf("修改自动清理群成员阈值失败：%s", err)
+		ctx.String(http.StatusInternalServerError, "操作失败: %s", err)
+		return
+	}
+
+	ctx.String(http.StatusOK, "操作成功")
+}
--- a/app/group.go
+++ b/app/group.go
@ -0,0 +1,30 @@
+package app
+
+import (
+	"github.com/gin-gonic/gin"
+	"go-wechat/service"
+	"net/http"
+)
+
+type getGroupUser struct {
+	GroupId string `json:"groupId" form:"groupId" binding:"required"` // 群Id
+}
+
+// GetGroupUsers
+// @description: 获取群成员列表
+// @param ctx
+func GetGroupUsers(ctx *gin.Context) {
+	var p getGroupUser
+	if err := ctx.ShouldBind(&p); err != nil {
+		ctx.String(http.StatusBadRequest, "参数错误")
+		return
+	}
+	// 查询数据
+	records, err := service.GetGroupUsersByGroupId(p.GroupId)
+	if err != nil {
+		ctx.String(http.StatusInternalServerError, "查询失败: %s", err.Error())
+		return
+	}
+	// 暂时先就这样写着，跑通了再改
+	ctx.JSON(http.StatusOK, records)
+}
--- a/app/pages.go
+++ b/app/pages.go
@ -0,0 +1,116 @@
+package app
+
+import (
+	"fmt"
+	"github.com/gin-gonic/gin"
+	"go-wechat/config"
+	"go-wechat/service"
+	"net/http"
+)
+
+// Index
+// @description: 首页
+// @param ctx
+func Index(ctx *gin.Context) {
+	var result = gin.H{
+		"msg": "success",
+	}
+	// 取出所有好友列表
+	friends, groups, err := service.GetAllFriend()
+	if err != nil {
+		result["msg"] = fmt.Sprintf("数据获取失败: %s", err.Error())
+	}
+	var in, notIn int
+	for _, d := range friends {
+		if d.IsOk {
+			in++
+		} else {
+			notIn++
+		}
+	}
+	result["friendCount"] = in
+	result["friendWithoutCount"] = notIn
+
+	var gin, gnotIn int
+	for _, d := range groups {
+		if d.IsOk {
+			gin++
+		} else {
+			gnotIn++
+		}
+	}
+	result["groupCount"] = gin
+	result["groupWithoutCount"] = gnotIn
+
+	result["vnc"] = config.Conf.Wechat.VncUrl
+	result["isVnc"] = config.Conf.Wechat.VncUrl != ""
+	result["aiModels"] = config.Conf.Ai.Models
+
+	// 渲染页面
+	ctx.HTML(http.StatusOK, "index.html", result)
+}
+
+// Friend
+// @description: 好友列表
+// @param ctx
+func Friend(ctx *gin.Context) {
+	var result = gin.H{
+		"msg": "success",
+	}
+
+	// 取出所有好友列表
+	friends, _, err := service.GetAllFriend()
+	if err != nil {
+		result["msg"] = fmt.Sprintf("数据获取失败: %s", err.Error())
+	}
+	result["friends"] = friends
+	result["vnc"] = config.Conf.Wechat.VncUrl
+	result["aiModels"] = config.Conf.Ai.Models
+	result["assistant"], _ = service.GetAllAiAssistant()
+	// 渲染页面
+	ctx.HTML(http.StatusOK, "friend.html", result)
+}
+
+// Group
+// @description: 群组列表
+// @param ctx
+func Group(ctx *gin.Context) {
+	var result = gin.H{
+		"msg": "success",
+	}
+	// 取出所有好友列表
+	_, groups, err := service.GetAllFriend()
+	if err != nil {
+		result["msg"] = fmt.Sprintf("数据获取失败: %s", err.Error())
+	}
+	result["groups"] = groups
+	result["vnc"] = config.Conf.Wechat.VncUrl
+	result["aiModels"] = config.Conf.Ai.Models
+	result["assistant"], _ = service.GetAllAiAssistant()
+
+	// 渲染页面
+	ctx.HTML(http.StatusOK, "group.html", result)
+}
+
+// Assistant
+// @description: AI角色
+// @param ctx
+func Assistant(ctx *gin.Context) {
+	var result = gin.H{
+		"msg": "success",
+	}
+
+	result["aiModels"] = config.Conf.Ai.Models
+	result["assistant"], _ = service.GetAllAiAssistant()
+
+	// 渲染页面
+	ctx.HTML(http.StatusOK, "assistant.html", result)
+}
+
+// PageNotFound
+// @description: 404页面
+// @param ctx
+func PageNotFound(ctx *gin.Context) {
+	// 渲染页面
+	ctx.HTML(http.StatusOK, "404.html", nil)
+}
--- a/client/mysql.go
+++ b/client/mysql.go
@ -0,0 +1,38 @@
+package client
+
+import (
+	"go-wechat/config"
+	"gorm.io/driver/mysql"
+	"gorm.io/gorm"
+	"gorm.io/gorm/logger"
+	"log"
+	"os"
+	"strconv"
+)
+
+// MySQL MySQL客户端
+var MySQL *gorm.DB
+
+func InitMySQLClient() {
+	// 创建连接对象
+	mysqlConfig := mysql.Config{
+		DSN:                     config.Conf.MySQL.GetDSN(),
+		DontSupportRenameIndex:  true, // 重命名索引时采用删除并新建的方式
+		DontSupportRenameColumn: true, // 用 `change` 重命名列
+	}
+
+	// gorm 配置
+	gormConfig := gorm.Config{}
+	// 是否开启调试模式
+	if flag, _ := strconv.ParseBool(os.Getenv("GORM_DEBUG")); flag {
+		gormConfig.Logger = logger.Default.LogMode(logger.Info)
+	}
+
+	conn, err := gorm.Open(mysql.New(mysqlConfig), &gormConfig)
+	if err != nil {
+		log.Panicf("初始化MySQL连接失败, 错误信息: %v", err)
+	} else {
+		log.Println("MySQL连接成功")
+	}
+	MySQL = conn
+}
--- a/common/constant/wxid.go
+++ b/common/constant/wxid.go
@ -0,0 +1,6 @@
+package constant
+
+var SpecialId = []string{"filehelper", "newsapp", "fmessage", "weibo", "qqmail", "tmessage", "qmessage", "qqsync",
+	"floatbottle", "lbsapp", "shakeapp", "medianote", "qqfriend", "readerapp", "blogapp", "facebookapp", "masssendapp",
+	"meishiapp", "feedsapp", "voip", "blogappweixin", "weixin", "brandsessionholder", "weixinreminder", "officialaccounts",
+	"notification_messages", "wxitil", "userexperience_alarm", "notification_messages", "exmail_tool"}
--- a/common/current/robot.go
+++ b/common/current/robot.go
@ -0,0 +1,44 @@
+package current
+
+import (
+	"go-wechat/model/model"
+	plugin "go-wechat/plugin"
+)
+
+// robotInfo
+// @description: 机器人信息
+type robotInfo struct {
+	info           model.RobotUserInfo
+	MessageHandler plugin.MessageHandler // 启用的插件
+}
+
+// 当前接入的机器人信息
+var ri robotInfo
+
+// SetRobotInfo
+// @description: 设置机器人信息
+// @param info
+func SetRobotInfo(info model.RobotUserInfo) {
+	ri.info = info
+}
+
+// GetRobotInfo
+// @description: 获取机器人信息
+// @return model.RobotUserInfo
+func GetRobotInfo() model.RobotUserInfo {
+	return ri.info
+}
+
+// GetRobotMessageHandler
+// @description: 获取机器人插件信息
+// @return robotInfo
+func GetRobotMessageHandler() plugin.MessageHandler {
+	return ri.MessageHandler
+}
+
+// SetRobotMessageHandler
+// @description: 设置机器人插件信息
+// @param handler
+func SetRobotMessageHandler(handler plugin.MessageHandler) {
+	ri.MessageHandler = handler
+}
--- a/common/response/fail.go
+++ b/common/response/fail.go
--- a/common/response/page.go
+++ b/common/response/page.go
--- a/common/response/response.go
+++ b/common/response/response.go
@ -2,8 +2,8 @@ package response

 import (
 	"github.com/gin-gonic/gin"
+	"go-wechat/common/validator"
 	"net/http"
-	"wechat-robot/pkg/validator"
 )

 // 定义状态码
@ -70,8 +70,12 @@ func (r *Response) SetMsg(msg string) *Response {
 // @return *Response
 func (r *Response) SetError(err error) *Response {
 	if err != nil {
-		err = validator.Translate(err)
+		ne := validator.Translate(err)
+		if ne != nil {
+			r.errMsg = ne.Error()
+		} else {
 			r.errMsg = err.Error()
 		}
+	}
 	return r
 }
--- a/common/response/result.go
+++ b/common/response/result.go
--- a/common/response/success.go
+++ b/common/response/success.go
--- a/common/types/datetime.go
+++ b/common/types/datetime.go
@ -55,7 +55,7 @@ func (dt DateTime) Value() (dv driver.Value, err error) {

 // 用于 fmt.Println 和后续验证场景
 func (dt DateTime) String() string {
-	return dt.Format(dateTimeFormat)
+	return dt.Format("2006-01-02 15:04:05")
 }

 // Format 格式化
--- a/common/validator/validator.go
+++ b/common/validator/validator.go
@ -2,12 +2,12 @@ package validator

 import (
 	"errors"
-	"gitee.ltd/lxh/logger/log"
 	"github.com/gin-gonic/gin/binding"
 	"github.com/go-playground/locales/zh"
 	ut "github.com/go-playground/universal-translator"
 	"github.com/go-playground/validator/v10"
 	zhTranslations "github.com/go-playground/validator/v10/translations/zh"
+	"log"
 	"strings"
 )

@ -42,7 +42,8 @@ func Init() {
 func Translate(err error) error {
 	errorMsg := make([]string, 0)

-	ves, ok := err.(validator.ValidationErrors)
+	var ves validator.ValidationErrors
+	ok := errors.As(err, &ves)
 	if !ok {
 		return err
 	}
--- a/config.yaml
+++ b/config.yaml
@ -0,0 +1,123 @@
+system:
+  # 添加新好友或群之后通知给指定的人
+  newFriendNotify:
+    enable: true
+    toUser:
+      - "wxid_xxx"
+  # 默认AI等配置
+  defaultRule:
+    # 默认是否开启AI
+    ai: true
+    # 默认是否开启水群排行榜
+    chatRank: true
+    # 默认是否开启聊天记录总结
+    summary: true
+    # 默认是否开启新成员加群欢迎
+    welcome: true
+    # 每日早报
+    news: true
+
+# 微信HOOK配置
+wechat:
+  # 微信HOOK接口地址
+  host: 10.0.0.79:19088
+  # 微信容器映射出来的vnc页面地址，没有就不填
+  #  vncUrl: http://192.168.1.175:19087/vnc_lite.html
+  # 是否在启动的时候自动设置hook服务的回调
+  autoSetCallback: false
+  # 回调IP，如果是Docker运行，本参数必填(填auto表示自动，不适用于 docker 环境)，如果Docker修改了映射，格式为 ip:port
+  callback: 10.0.0.51
+  # 转发到其他地址
+  forward:
+#    - 10.0.0.247:4299
+
+# 数据库
+mysql:
+  drive: mysql # 使用的数据库驱动，支持 mysql、postgres
+  host: 10.0.0.31
+  port: 3307
+  user: wechat
+  password: wechat123
+  db: wechat
+  schema: public # postgres 专用
+
+task:
+  enable: false
+  news:
+    enable: true
+    cron: '14 11 * * *' # 每天0:30
+  syncFriends:
+    enable: false
+    cron: '*/5 * * * *' # 五分钟一次
+  groupSummary:
+    enable: false
+    cron: '30 0 * * *' # 每天0:30
+  waterGroup:
+    enable: false
+    cron:
+      yesterday: '30 9 * * *' # 每天9:30
+      week: '30 9 * * 1' # 每周一9:30
+      month: '30 9 1 * *' # 每月1号9:30
+      year: '0 9 1 1 *' # 每年1月1号9:30
+
+# MQ配置
+mq:
+  # 是否启用
+  enable: false
+  # RabbitMQ配置
+  rabbitmq:
+    host: 10.0.0.247
+    port: 5672
+    user: wechat
+    password: wechat123
+    vhost: wechat
+
+# AI回复
+ai:
+  # 是否启用
+  enable: false
+  # 模型，不填默认gpt-3.5-turbo-0613
+  model: gpt-3.5-turbo-0613
+  # 群聊总结模型
+  summaryModel: gpt-4-0613
+  # OpenAI Api key
+  apiKey: sk-xxxx
+  # 接口代理域名，不填默认ChatGPT官方地址
+  baseUrl: https://sxxx
+  # 人设
+  personality: 你的名字叫张三，你是一个百科机器人，你的爱好是看电影，你的性格是开朗的，你的专长是讲故事，你的梦想是当一名童话故事作家。你对政治没有一点儿兴趣，也不会讨论任何与政治相关的话题，你甚至可以拒绝回答这一类话题。
+  models:
+    - name: ChatGPT-4
+      model: gpt-4
+    - name: 讯飞星火v3.1
+      model: SparkDesk-v3.1
+    - name: 讯飞星火v3.5
+      model: SparkDesk-v3.5
+    - name: 月之暗面-8k
+      model: moonshot-v1-8k
+    - name: 月之暗面-32k
+      model: moonshot-v1-32k
+    - name: 月之暗面-128k
+      model: moonshot-v1-128k
+    - name: 跃问
+      model: StepChat
+    - name: 豆包Lite-4k
+      model: Doubao-lite-4k
+    - name: 豆包Pro-4k
+      model: Doubao-pro-4k
+
+# 资源配置
+# map[k]v结构，k 会变成全小写，所以这儿不能用大写字母
+resource:
+  # 欢迎新成员表情包
+  welcome-new:
+    type: emotion
+    path: 58e4150be2bba8f7b71974b10391f9e9
+  # 给新好友或者群的自我介绍，不配置就不发送
+  introduce:
+    type: text
+    path: "大家好，我是一个AI机器人，可以直接@我询问你想问的问题。"
+  # 水群排行榜词云，只能是图片，末尾的`\%s`也是必须的
+  wordcloud:
+    type: image
+    path: D:\Share\wordcloud\%s
--- a/config.yaml.example
+++ b/config.yaml.example
@ -1,15 +0,0 @@
-# 数据库配置
-database:
-  type: mysql # 使用的数据库类型，可选 mysql | postgresql
-  host: mysql # 数据库地址(使用docker-compose启动可以不用改)
-  port: 3306 # 数据库端口
-  username: pixiu # 数据库用户名
-  password: pixiu # 数据库密码
-  database: pixiu # 数据库名
-
-# Redis配置
-redis:
-  host: redis # Redis地址(使用docker-compose启动可以不用改)
-  port: 6379 # Redis端口
-  password: mNhgeSk32fUf69C6
-  db: 0
--- a/config/ai.go
+++ b/config/ai.go
@ -0,0 +1,20 @@
+package config
+
+// ai
+// @description: AI配置
+type ai struct {
+	Enable       bool      `json:"enable" yaml:"enable"`             // 是否启用AI
+	Model        string    `json:"model" yaml:"model"`               // 模型
+	SummaryModel string    `json:"summaryModel" yaml:"summaryModel"` // 总结模型
+	ApiKey       string    `json:"apiKey" yaml:"apiKey"`             // API Key
+	BaseUrl      string    `json:"baseUrl" yaml:"baseUrl"`           // API地址
+	Personality  string    `json:"personality" yaml:"personality"`   // 人设
+	Models       []aiModel `json:"models" yaml:"models"`             // 模型列表
+}
+
+// aiModel
+// @description: AI模型
+type aiModel struct {
+	Name  string `json:"name" yaml:"name"`   // 模型名称
+	Model string `json:"model" yaml:"model"` // 模型代码
+}
--- a/config/config.go
+++ b/config/config.go
@ -6,7 +6,11 @@ var Conf conf
 // Config
 // @description: 配置
 type conf struct {
-	Database db    `json:"database" yaml:"database"` // 数据库 配置
-	Redis    redis `json:"redis" yaml:"redis"`       // Redis 配置
+	System   system                  `json:"system" yaml:"system"`     // 系统配置
+	Task     task                    `json:"task" yaml:"task"`         // 定时任务配置
+	MySQL    mysql                   `json:"mysql" yaml:"mysql"`       // MySQL 配置
+	Wechat   wechat                  `json:"wechat" yaml:"wechat"`     // 微信助手
 	Mq       mq                      `json:"mq" yaml:"mq"`             // MQ 配置
+	Ai       ai                      `json:"ai" yaml:"ai"`             // AI配置
+	Resource map[string]resourceItem `json:"resource" yaml:"resource"` // 资源配置
 }
--- a/config/db.go
+++ b/config/db.go
@ -1,32 +0,0 @@
-package config
-
-import "fmt"
-
-// db
-// @description: 数据库配置
-type db struct {
-	Type     string `json:"type" yaml:"type" mapstructure:"type"`             // 数据库类型
-	Host     string `json:"host" yaml:"host" mapstructure:"host"`             // 数据库地址
-	Port     int    `json:"port" yaml:"port" mapstructure:"port"`             // 数据库端口
-	Username string `json:"username" yaml:"username" mapstructure:"username"` // 数据库用户名
-	Password string `json:"password" yaml:"password" mapstructure:"password"` // 数据库密码
-	Database string `json:"database" yaml:"database" mapstructure:"database"` // 数据库名称
-}
-
-// GetMysqlDSN
-// @description: 获取MySQL连接DSN
-// @receiver d
-// @return string
-func (d db) GetMysqlDSN() string {
-	return fmt.Sprintf("%s:%s@tcp(%s:%v)/%s?charset=utf8mb4&parseTime=True&loc=Local",
-		d.Username, d.Password, d.Host, d.Port, d.Database)
-}
-
-// GetPostgreSQLDSN
-// @description: 获取PostgreSQL连接DSN
-// @receiver d
-// @return string
-func (d db) GetPostgreSQLDSN() string {
-	return fmt.Sprintf("host=%s user=%s password=%s dbname=%s port=%d sslmode=disable TimeZone=Asia/Shanghai",
-		d.Host, d.Username, d.Password, d.Database, d.Port)
-}
--- a/config/mq.go
+++ b/config/mq.go
@ -5,6 +5,7 @@ import "fmt"
 // mq
 // @description: MQ配置
 type mq struct {
+	Enable   bool     `json:"enable" yaml:"enable"`     // 是否启用
 	RabbitMQ rabbitMq `json:"rabbitmq" yaml:"rabbitmq"` // RabbitMQ配置
 }

--- a/config/mysql.go
+++ b/config/mysql.go
@ -0,0 +1,24 @@
+package config
+
+import (
+	"fmt"
+)
+
+// mysql
+// @description: MySQL配置
+type mysql struct {
+	Host     string `mapstructure:"host" yaml:"host"`         // 主机
+	Port     int    `mapstructure:"port" yaml:"port"`         // 端口
+	User     string `mapstructure:"user" yaml:"user"`         // 用户名
+	Password string `mapstructure:"password" yaml:"password"` // 密码
+	Db       string `mapstructure:"db" yaml:"db"`             // 数据库名称
+}
+
+// GetDSN
+// @description: 返回 MySQL 连接字符串
+// @receiver c
+// @return string
+func (c mysql) GetDSN() string {
+	return fmt.Sprintf("%s:%s@tcp(%s:%v)/%s?charset=utf8mb4&parseTime=True&loc=Local",
+		c.User, c.Password, c.Host, c.Port, c.Db)
+}
--- a/config/redis.go
+++ b/config/redis.go
@ -1,15 +0,0 @@
-package config
-
-import "fmt"
-
-// Redis配置
-type redis struct {
-	Host     string `mapstructure:"host" yaml:"host"`         // 主机
-	Port     int    `mapstructure:"port" yaml:"port"`         // 端口
-	Password string `mapstructure:"password" yaml:"password"` // 密码
-	Db       int    `mapstructure:"db" yaml:"db"`             // 数据库名称
-}
-
-func (r redis) GetDSN() string {
-	return fmt.Sprintf("%s:%v", r.Host, r.Port)
-}
--- a/config/resource.go
+++ b/config/resource.go
@ -0,0 +1,8 @@
+package config
+
+// resourceItem
+// @description: 资源项
+type resourceItem struct {
+	Type string `json:"type" yaml:"type"` // 类型
+	Path string `json:"path" yaml:"path"` // 路径
+}
--- a/config/system.go
+++ b/config/system.go
@ -0,0 +1,22 @@
+package config
+
+// 系统配置
+type system struct {
+	NewFriendNotify newFriendNotify `json:"newFriendNotify" yaml:"newFriendNotify"` // 新好友通知
+	DefaultRule     defaultRule     `json:"defaultRule" yaml:"defaultRule"`         // 默认规则
+}
+
+// 添加新好友或群之后通知给指定的人
+type newFriendNotify struct {
+	Enable bool     `json:"enable" yaml:"enable"` // 是否启用
+	ToUser []string `json:"toUser" yaml:"toUser"` // 通知给谁
+}
+
+// 默认规则
+type defaultRule struct {
+	Ai       bool `json:"ai" yaml:"ai"`             // 是否启用AI
+	ChatRank bool `json:"chatRank" yaml:"chatRank"` // 是否启用聊天排行榜
+	Summary  bool `json:"summary" yaml:"summary"`   // 是否启用聊天总结
+	Welcome  bool `json:"welcome" yaml:"welcome"`   // 是否启用欢迎新成员
+	News     bool `json:"news" yaml:"news"`         // 是否启用每日早报
+}
--- a/config/task.go
+++ b/config/task.go
@ -0,0 +1,34 @@
+package config
+
+// task
+// @description: 定时任务
+type task struct {
+	Enable       bool        `json:"enable" yaml:"enable"`             // 是否启用
+	News         syncFriends `json:"news" yaml:"news"`                 // 每日早报
+	SyncFriends  syncFriends `json:"syncFriends" yaml:"syncFriends"`   // 同步好友
+	WaterGroup   waterGroup  `json:"waterGroup" yaml:"waterGroup"`     // 水群排行榜
+	GroupSummary syncFriends `json:"groupSummary" yaml:"groupSummary"` // 群聊总结
+}
+
+// syncFriends
+// @description: 同步好友
+type syncFriends struct {
+	Enable bool   `json:"enable" yaml:"enable"` // 是否启用
+	Cron   string `json:"cron" yaml:"cron"`     // 定时任务表达式
+}
+
+// waterGroup
+// @description: 水群排行榜
+type waterGroup struct {
+	Enable bool           `json:"enable" yaml:"enable"` // 是否启用
+	Cron   waterGroupCron `json:"cron" yaml:"cron"`     // 定时任务表达式
+}
+
+// waterGroupCron
+// @description: 水群排行榜定时任务
+type waterGroupCron struct {
+	Yesterday string `json:"yesterday" yaml:"yesterday"` // 昨日排行榜
+	Week      string `json:"week" yaml:"week"`           // 周排行榜
+	Month     string `json:"month" yaml:"month"`         // 月排行榜
+	Year      string `json:"year" yaml:"year"`           // 年排行榜
+}
--- a/config/wechat.go
+++ b/config/wechat.go
@ -0,0 +1,35 @@
+package config
+
+import "strings"
+
+// wxHelper
+// @description: 微信助手
+type wechat struct {
+	Host            string   `json:"host" yaml:"host"`                       // 接口地址
+	VncUrl          string   `json:"vncUrl" yaml:"vncUrl"`                   // vnc页面地址
+	AutoSetCallback bool     `json:"autoSetCallback" yaml:"autoSetCallback"` // 是否自动设置回调地址
+	Callback        string   `json:"callback" yaml:"callback"`               // 回调地址
+	Forward         []string `json:"forward" yaml:"forward"`                 // 转发地址
+}
+
+// Check
+// @description: 检查配置是否可用
+// @receiver w
+// @return bool
+func (w wechat) Check() bool {
+	if w.Host == "" {
+		return false
+	}
+	if w.AutoSetCallback && w.Callback == "" {
+		return false
+	}
+	return true
+}
+
+func (w wechat) GetURL(uri string) string {
+	host := w.Host
+	if !strings.HasPrefix(w.Host, "http://") {
+		host = "http://" + w.Host
+	}
+	return host + uri
+}
--- a/docker-compose.yaml
+++ b/docker-compose.yaml
@ -0,0 +1,46 @@
+version: '3.9'
+
+services:
+  wechat:
+    image: lxh01/wxhelper-docker:3.9.5.81-v11
+    container_name: gw-wechat
+    restart: unless-stopped
+    environment:
+      - WINEDEBUG=fixme-all
+    volumes:
+      - ./data/wechat:/home/app/.wine/drive_c/users/app/Documents/WeChat\ Files
+    ports:
+      - "19087:8080"
+      - "19088:19088"
+    healthcheck:
+      test: ["CMD", "curl", "-f", "http://localhost:19088/api/checkLogin"]
+      interval: 60s
+      timeout: 10s
+      retries: 5
+
+
+  mysql:
+    image: mysql:8
+    container_name: gw-db
+    restart: unless-stopped
+    environment:
+      - MYSQL_ROOT_PASSWORD=wechat
+      - MYSQL_USER=wechat
+      - MYSQL_PASSWORD=wechat
+      - MYSQL_DATABASE=wechat
+    volumes:
+      - ./data/db:/var/lib/mysql
+
+
+  wxhelper:
+    image: gitee.ltd/lxh/go-wxhelper:latest
+    container_name: gw-service
+    restart: unless-stopped
+    depends_on:
+      - mysql
+      - wechat
+    volumes:
+      # 配置文件请参阅项目根目录的config.yaml文件
+      - ./config/config.yaml:/app/config.yaml
+    ports:
+      - "19099:19099"
--- a/frontend/.eslintrc.cjs
+++ b/frontend/.eslintrc.cjs
@ -0,0 +1,18 @@
+/* eslint-env node */
+require('@rushstack/eslint-patch/modern-module-resolution')
+
+module.exports = {
+  env: {
+    node: true,
+  },
+  root: true,
+  'extends': [
+    'plugin:vue/vue3-essential',
+    'eslint:recommended',
+    '@vue/eslint-config-typescript',
+    '@vue/eslint-config-prettier/skip-formatting'
+  ],
+  parserOptions: {
+    ecmaVersion: 'latest'
+  }
+}
--- a/frontend/.gitignore
+++ b/frontend/.gitignore
@ -0,0 +1,30 @@
+# Logs
+logs
+*.log
+npm-debug.log*
+yarn-debug.log*
+yarn-error.log*
+pnpm-debug.log*
+lerna-debug.log*
+
+node_modules
+.DS_Store
+dist
+dist-ssr
+coverage
+*.local
+
+/cypress/videos/
+/cypress/screenshots/
+
+# Editor directories and files
+.vscode/*
+!.vscode/extensions.json
+.idea
+*.suo
+*.ntvs*
+*.njsproj
+*.sln
+*.sw?
+
+*.tsbuildinfo
--- a/frontend/.prettierrc.json
+++ b/frontend/.prettierrc.json
@ -0,0 +1,8 @@
+{
+  "$schema": "https://json.schemastore.org/prettierrc",
+  "semi": false,
+  "tabWidth": 2,
+  "singleQuote": true,
+  "printWidth": 100,
+  "trailingComma": "none"
+}
--- a/frontend/.vscode/extensions.json
+++ b/frontend/.vscode/extensions.json
@ -0,0 +1,7 @@
+{
+  "recommendations": [
+    "Vue.volar",
+    "dbaeumer.vscode-eslint",
+    "esbenp.prettier-vscode"
+  ]
+}
--- a/frontend/README.md
+++ b/frontend/README.md
@ -0,0 +1,39 @@
+# frontend
+
+This template should help get you started developing with Vue 3 in Vite.
+
+## Recommended IDE Setup
+
+[VSCode](https://code.visualstudio.com/) + [Volar](https://marketplace.visualstudio.com/items?itemName=Vue.volar) (and disable Vetur).
+
+## Type Support for `.vue` Imports in TS
+
+TypeScript cannot handle type information for `.vue` imports by default, so we replace the `tsc` CLI with `vue-tsc` for type checking. In editors, we need [Volar](https://marketplace.visualstudio.com/items?itemName=Vue.volar) to make the TypeScript language service aware of `.vue` types.
+
+## Customize configuration
+
+See [Vite Configuration Reference](https://vitejs.dev/config/).
+
+## Project Setup
+
+```sh
+npm install
+```
+
+### Compile and Hot-Reload for Development
+
+```sh
+npm run dev
+```
+
+### Type-Check, Compile and Minify for Production
+
+```sh
+npm run build
+```
+
+### Lint with [ESLint](https://eslint.org/)
+
+```sh
+npm run lint
+```
--- a/frontend/env.d.ts
+++ b/frontend/env.d.ts
@ -0,0 +1 @@
+/// <reference types="vite/client" />
--- a/frontend/index.html
+++ b/frontend/index.html
@ -0,0 +1,13 @@
+<!DOCTYPE html>
+<html lang="en" class="h-full bg-gray-100">
+  <head>
+    <meta charset="UTF-8">
+    <link rel="icon" href="/favicon.ico">
+    <meta name="viewport" content="width=device-width, initial-scale=1.0">
+    <title>一个微信机器人</title>
+  </head>
+  <body style="min-height: 911px" class="h-full">
+    <div id="app"></div>
+    <script type="module" src="/src/main.ts"></script>
+  </body>
+</html>
--- a/frontend/package-lock.json
+++ b/frontend/package-lock.json
--- a/frontend/package.json
+++ b/frontend/package.json
@ -0,0 +1,46 @@
+{
+  "name": "frontend",
+  "version": "0.0.0",
+  "private": true,
+  "type": "module",
+  "scripts": {
+    "dev": "vite",
+    "build": "run-p type-check \"build-only {@}\" --",
+    "preview": "vite preview",
+    "build-only": "vite build",
+    "type-check": "vue-tsc --build --force",
+    "lint": "eslint . --ext .vue,.js,.jsx,.cjs,.mjs,.ts,.tsx,.cts,.mts --fix --ignore-path .gitignore",
+    "format": "prettier --write src/"
+  },
+  "dependencies": {
+    "@headlessui/vue": "^1.7.22",
+    "@tailwindcss/forms": "^0.5.7",
+    "axios": "^1.7.2",
+    "pinia": "^2.1.7",
+    "qs": "^6.12.2",
+    "vue": "^3.4.29",
+    "vue-router": "^4.3.3"
+  },
+  "devDependencies": {
+    "@rushstack/eslint-patch": "^1.8.0",
+    "@tsconfig/node20": "^20.1.4",
+    "@types/node": "^20.14.5",
+    "@types/qs": "^6.9.15",
+    "@vitejs/plugin-vue": "^5.0.5",
+    "@vitejs/plugin-vue-jsx": "^4.0.0",
+    "@vue/eslint-config-prettier": "^9.0.0",
+    "@vue/eslint-config-typescript": "^13.0.0",
+    "@vue/tsconfig": "^0.5.1",
+    "autoprefixer": "^10.4.19",
+    "daisyui": "^4.12.10",
+    "eslint": "^8.57.0",
+    "eslint-plugin-vue": "^9.23.0",
+    "npm-run-all2": "^6.2.0",
+    "postcss": "^8.4.39",
+    "prettier": "^3.2.5",
+    "tailwindcss": "^3.4.4",
+    "typescript": "~5.4.0",
+    "vite": "^5.3.1",
+    "vue-tsc": "^2.0.21"
+  }
+}
--- a/frontend/postcss.config.js
+++ b/frontend/postcss.config.js
@ -0,0 +1,6 @@
+export default {
+  plugins: {
+    tailwindcss: {},
+    autoprefixer: {},
+  },
+};
--- a/frontend/public/favicon.ico
+++ b/frontend/public/favicon.ico
--- a/frontend/src/App.vue
+++ b/frontend/src/App.vue
@ -0,0 +1,10 @@
+<script setup lang="ts">
+import MainNav from '@/components/layout/MainNav.vue'
+</script>
+
+<template>
+  <MainNav />
+</template>
+
+<style scoped>
+</style>
--- a/frontend/src/api/base.ts
+++ b/frontend/src/api/base.ts
@ -0,0 +1,6 @@
+// 默认返回数据结构
+export type BaseResult<T> = {
+  code: number;
+  message: string;
+  data?: T;
+};
--- a/frontend/src/api/contact.ts
+++ b/frontend/src/api/contact.ts
@ -0,0 +1,43 @@
+import { http } from '@/utils/http'
+import type { BaseResult } from '@/api/base'
+
+/** 通讯录列表返回结果 */
+export type ContactItem = {
+  /** 微信号 */
+  CustomAccount: string,
+  /** 昵称 */
+  Nickname: string,
+  /** 昵称拼音大写首字母 */
+  Pinyin: string,
+  /** 昵称拼音全拼 */
+  PinyinAll: string,
+  /** 微信原始Id */
+  Wxid: string,
+  /** 最后活跃时间 */
+  LastActive: Date,
+  /** 是否使用AI */
+  EnableAi: boolean,
+  /** AI模型 */
+  AiModel: string,
+  /** AI助手或者自定义提示词 */
+  Prompt: string,
+  /** 是否使用聊天排行 */
+  EnableChatRank: boolean,
+  /** 是否使用迎新 */
+  EnableWelcome: boolean,
+  /** 是否启用指令 */
+  EnableCommand: boolean,
+  /** 是否启用总结 */
+  EnableSummary: boolean,
+  /** 是否启用新闻 */
+  EnableNews: boolean,
+  /** 清理成员配置（多少天未活跃的） */
+  ClearMember: number,
+  /** 是否还在通讯库(群聊是要还在群里也算) */
+  IsOk: boolean
+}
+
+/** 获取首页基础信息 */
+export const getFriendList = () => {
+  return http.request<BaseResult<Array<ContactItem>>>('get', '/api/contact/friend')
+}
--- a/frontend/src/assets/img/logo.png
+++ b/frontend/src/assets/img/logo.png
--- a/frontend/src/assets/img/status-fail.png
+++ b/frontend/src/assets/img/status-fail.png
--- a/frontend/src/assets/img/status-ok.png
+++ b/frontend/src/assets/img/status-ok.png
--- a/frontend/src/components/contact/index.vue
+++ b/frontend/src/components/contact/index.vue
@ -0,0 +1,3 @@
+<template>
+
+</template>
--- a/frontend/src/components/layout/MainNav.vue
+++ b/frontend/src/components/layout/MainNav.vue
@ -0,0 +1,73 @@
+<script setup lang="ts">
+import { RouterView } from 'vue-router'
+import { Disclosure, DisclosureButton, DisclosurePanel, Menu, MenuButton, MenuItem, MenuItems } from '@headlessui/vue'
+
+defineOptions({
+  name: 'MainNav'
+})
+
+const navigation = [
+  { name: '首页', href: '/', current: true },
+  { name: '好友列表', href: '/friend', current: false },
+  { name: '群组', href: '/group', current: false },
+  { name: 'AI角色', href: '/assistant', current: false }
+]
+
+// 设置当前选中的导航
+const setCurrent = (href: string) => {
+  navigation.forEach(item => {
+    item.current = item.href === href
+  })
+}
+</script>
+
+<template>
+  <div class="min-h-full">
+    <div class="bg-green-600 pb-32">
+      <Disclosure as="nav" class="border-b border-green-300 border-opacity-25 bg-green-600 lg:border-none">
+        <div class="mx-auto max-w-7xl px-2 sm:px-4 lg:px-8">
+          <div
+            class="relative flex h-16 items-center justify-between lg:border-b lg:border-green-400 lg:border-opacity-25">
+            <div class="flex items-center px-2 lg:px-0">
+              <div class="flex-shrink-0">
+                <img class="block h-8 w-8" src="../../assets/img/logo.png" alt="Your Company" />
+              </div>
+              <div class="hidden lg:ml-10 lg:block">
+                <div class="flex space-x-4">
+                  <a v-for="item in navigation" :key="item.name" :href="item.href"
+                     :class="[item.current ? 'bg-green-700 text-white' : 'text-white hover:bg-green-500 hover:bg-opacity-75', 'rounded-md px-3 py-2 text-sm font-medium']"
+                     :aria-current="item.current ? 'page' : undefined" @click="setCurrent(item.href)">{{ item.name }}</a>
+                </div>
+              </div>
+            </div>
+          </div>
+        </div>
+      </Disclosure>
+      <header class="py-10">
+        <div class="mx-auto max-w-7xl px-4 sm:px-6 lg:px-8">
+          <h1 class="text-3xl font-bold tracking-tight text-white">Dashboard</h1>
+        </div>
+      </header>
+    </div>
+
+    <main class="-mt-32">
+      <div class="mx-auto max-w-7xl px-4 pb-12 sm:px-6 lg:px-8">
+        <div class="rounded-lg bg-white px-5 py-6 shadow sm:px-6">
+          <RouterView />
+        </div>
+      </div>
+    </main>
+
+    <footer>
+      <div class="mx-auto max-w-3xl px-4 sm:px-6 lg:max-w-7xl lg:px-8">
+        <div class="border-t border-gray-200 py-8 text-center text-sm text-gray-500 sm:text-left">
+          <span class="block sm:inline">本项目完全开源，开源地址: </span>
+          <span class="block sm:inline text-red-500">
+        <a target="_blank" href="https://gitee.ltd/lxh/go-wxhelper">https://gitee.ltd</a>
+      </span>
+        </div>
+      </div>
+    </footer>
+
+  </div>
+</template>
--- a/frontend/src/main.ts
+++ b/frontend/src/main.ts
@ -0,0 +1,15 @@
+import { createApp } from 'vue'
+import { createPinia } from 'pinia'
+
+import App from './App.vue'
+import router from './router'
+
+// Tailwind CSS
+import "tailwindcss/tailwind.css";
+
+const app = createApp(App)
+
+app.use(createPinia())
+app.use(router)
+
+app.mount('#app')
--- a/frontend/src/router/index.ts
+++ b/frontend/src/router/index.ts
@ -0,0 +1,31 @@
+import { createRouter, createWebHistory } from 'vue-router'
+import IndexPage from '@/views/index/index.vue'
+
+const router = createRouter({
+  history: createWebHistory(import.meta.env.BASE_URL),
+  routes: [
+    {
+      path: '/',
+      name: 'home',
+      component: IndexPage
+    },
+    {
+      path: '/friend',
+      name: 'Friend',
+      // 这么写是为了实现懒加载
+      component: () => import('@/views/friend/index.vue')
+    },
+    {
+      path: '/group',
+      name: 'Group',
+      component: () => import('@/views/group/index.vue')
+    },
+    {
+      path: '/assistant',
+      name: 'Assistant',
+      component: () => import('@/views/assistant/index.vue')
+    }
+  ]
+})
+
+export default router
--- a/frontend/src/stores/counter.ts
+++ b/frontend/src/stores/counter.ts
@ -0,0 +1,12 @@
+import { ref, computed } from 'vue'
+import { defineStore } from 'pinia'
+
+export const useCounterStore = defineStore('counter', () => {
+  const count = ref(0)
+  const doubleCount = computed(() => count.value * 2)
+  function increment() {
+    count.value++
+  }
+
+  return { count, doubleCount, increment }
+})
--- a/frontend/src/utils/http/index.ts
+++ b/frontend/src/utils/http/index.ts
@ -0,0 +1,136 @@
+import Axios, {
+  type AxiosInstance,
+  type AxiosRequestConfig,
+  type CustomParamsSerializer,
+  type AxiosResponse
+} from 'axios'
+import type { HttpError, RequestMethods } from './types.d'
+import { stringify } from 'qs'
+
+// 相关配置请参考：www.axios-js.com/zh-cn/docs/#axios-request-config-1
+const defaultConfig: AxiosRequestConfig = {
+  // 请求超时时间
+  timeout: 10000,
+  headers: {
+    Accept: 'application/json, text/plain, */*',
+    'Content-Type': 'application/json',
+    'X-Requested-With': 'XMLHttpRequest'
+  },
+  // 数组格式参数序列化（https://github.com/axios/axios/issues/5142）
+  paramsSerializer: {
+    serialize: stringify as unknown as CustomParamsSerializer
+  }
+}
+
+class Http {
+  constructor() {
+    this.httpInterceptorsRequest()
+    this.httpInterceptorsResponse()
+  }
+
+  /** 初始化配置对象 */
+  private static initConfig: AxiosRequestConfig = {}
+
+  /** 保存当前`Axios`实例对象 */
+  private static axiosInstance: AxiosInstance = Axios.create(defaultConfig)
+
+  /** 请求拦截 */
+  private httpInterceptorsRequest(): void {
+    Http.axiosInstance.interceptors.request.use(
+      async (config: AxiosRequestConfig): Promise<any> => {
+        // 开启进度条动画
+        // NProgress.start();
+        // 优先判断post/get等方法是否传入回调，否则执行初始化设置等回调
+        // if (typeof config.beforeRequestCallback === 'function') {
+        //   config.beforeRequestCallback(config)
+        //   return config
+        // }
+        // if (Http.initConfig.beforeRequestCallback) {
+        //   Http.initConfig.beforeRequestCallback(config)
+        //   return config
+        // }
+        return config
+      },
+      (error: HttpError) => {
+        return Promise.reject(error)
+      }
+    )
+  }
+
+  /** 响应拦截 */
+  private httpInterceptorsResponse(): void {
+    const instance = Http.axiosInstance
+    instance.interceptors.response.use(
+      (response: AxiosResponse) => {
+        // const $config = response.config
+        // 关闭进度条动画
+        // NProgress.done()
+        // 优先判断post/get等方法是否传入回调，否则执行初始化设置等回调
+        // if (typeof $config.beforeResponseCallback === 'function') {
+        //   $config.beforeResponseCallback(response)
+        //   return response.data
+        // }
+        // if (Http.initConfig.beforeResponseCallback) {
+        //   Http.initConfig.beforeResponseCallback(response)
+        //   return response.data
+        // }
+        return response.data
+      },
+      (error: HttpError) => {
+        const $error = error
+        $error.isCancelRequest = Axios.isCancel($error)
+        // 关闭进度条动画
+        // NProgress.done()
+        // 所有的响应异常 区分来源为取消请求/非取消请求
+        return Promise.reject($error)
+      }
+    )
+  }
+
+  /** 通用请求工具函数 */
+  public request<T>(
+    method: RequestMethods,
+    url: string,
+    param?: AxiosRequestConfig,
+    axiosConfig?: AxiosRequestConfig
+  ): Promise<T> {
+    const config = {
+      method,
+      url,
+      ...param,
+      ...axiosConfig
+    } as AxiosRequestConfig
+
+    // 单独处理自定义请求/响应回调
+    return new Promise((resolve, reject) => {
+      Http.axiosInstance
+        .request<T>(config)
+        .then((response: any): void => {
+          return resolve(response)
+        })
+        .catch((error) => {
+          reject(error)
+        })
+    })
+  }
+
+  /** 单独抽离的`post`工具函数 */
+  public post<T, P>(
+    url: string,
+    params?: AxiosRequestConfig<P>,
+    config?: AxiosRequestConfig
+  ): Promise<T> {
+    return this.request<T>('post', url, params, config)
+  }
+
+  /** 单独抽离的`get`工具函数 */
+  public get<T, P>(
+    url: string,
+    params?: AxiosRequestConfig<P>,
+    config?: AxiosRequestConfig
+  ): Promise<T> {
+    return this.request<T>('get', url, params, config)
+  }
+}
+
+export const http = new Http()
--- a/frontend/src/utils/http/types.d.ts
+++ b/frontend/src/utils/http/types.d.ts
@ -0,0 +1,43 @@
+import type {
+  Method,
+  AxiosError,
+  AxiosResponse,
+  AxiosRequestConfig
+} from "axios";
+
+export type RequestMethods = Extract<
+  Method,
+  "get" | "post" | "put" | "delete" | "patch" | "option" | "head"
+>;
+
+export interface HttpError extends AxiosError {
+  isCancelRequest?: boolean;
+}
+
+export interface HttpResponse extends AxiosResponse {
+  config: HttpRequestConfig;
+}
+
+export interface HttpRequestConfig extends AxiosRequestConfig {
+  beforeRequestCallback?: (request: HttpRequestConfig) => void;
+  beforeResponseCallback?: (response: HttpResponse) => void;
+}
+
+export default class Http {
+  request<T>(
+    method: RequestMethods,
+    url: string,
+    param?: AxiosRequestConfig,
+    axiosConfig?: HttpRequestConfig
+  ): Promise<T>;
+  post<T, P>(
+    url: string,
+    params?: T,
+    config?: HttpRequestConfig
+  ): Promise<P>;
+  get<T, P>(
+    url: string,
+    params?: T,
+    config?: HttpRequestConfig
+  ): Promise<P>;
+}
--- a/frontend/src/views/assistant/index.vue
+++ b/frontend/src/views/assistant/index.vue
@ -0,0 +1,12 @@
+<script setup lang="ts">
+
+defineOptions({
+  name: "AssistantPage"
+});
+</script>
+
+<template>
+  <main>
+    <h1>AI角色</h1>
+  </main>
+</template>
--- a/frontend/src/views/friend/hook.tsx
+++ b/frontend/src/views/friend/hook.tsx
@ -0,0 +1,25 @@
+import { onMounted, ref } from 'vue'
+
+import { type ContactItem, getFriendList } from '@/api/contact'
+
+// 起飞
+export function useHook() {
+  const dataList = ref<ContactItem[]>([]);
+
+  // 获取数据
+  async function onSearch() {
+    const { data } = await getFriendList();
+    dataList.value = data;
+    console.log(data);
+  }
+
+  // 挂载时执行
+  onMounted(() => {
+    onSearch();
+  });
+
+  return {
+    dataList,
+    onSearch
+  }
+}
--- a/frontend/src/views/friend/index.vue
+++ b/frontend/src/views/friend/index.vue
@ -0,0 +1,47 @@
+<script setup lang="ts">
+
+import { useHook } from '@/views/friend/hook'
+
+defineOptions({
+  name: "FriendPage"
+});
+
+const { dataList, onSearch } = useHook()
+</script>
+
+<template>
+  <ul role="list" class="grid grid-cols-1 gap-x-6 gap-y-8 lg:grid-cols-3 xl:gap-x-8">
+    <li class="overflow-hidden rounded-xl border border-gray-200" v-for="item in dataList" :key="item.Wxid">
+      <div class="flex items-center gap-x-4 border-b border-gray-900/5 bg-gray-50 p-6">
+        <img v-if="item.IsOk" src="@/assets/img/status-ok.png" alt="Tuple" class="h-12 w-12 flex-none rounded-lg bg-white object-cover ring-1 ring-gray-900/10">
+        <img v-else src="@/assets/img/status-fail.png" alt="Tuple" class="h-12 w-12 flex-none rounded-lg bg-white object-cover ring-1 ring-gray-900/10">
+
+        <div class="flex-1">
+          <div class="text-sm font-medium leading-6 text-gray-900">{{ item.Nickname }}</div>
+          <span v-if="item.IsOk"
+            class="inline-flex items-center rounded-md bg-green-50 px-2 py-1 text-xs font-medium text-green-700 ring-1 ring-inset ring-green-600/20">在通讯录</span>
+          <span v-else
+            class="inline-flex items-center rounded-md bg-red-50 px-2 py-1 text-xs font-medium text-red-700 ring-1 ring-inset ring-red-600/20">不在通讯录</span>
+        </div>
+      </div>
+      <dl class="-my-3 divide-y divide-gray-100 px-6 py-4 text-sm leading-6">
+        <div class="flex justify-between gap-x-4 py-3">
+          <dt class="text-gray-500">原始微信Id<br/>微信号</dt>
+          <dd>
+            <div class="text-gray-700">{{ item.Wxid }}</div>
+            <div class="truncate text-gray-500">{{ item.CustomAccount }}</div>
+          </dd>
+        </div>
+        <div class="flex justify-between gap-x-4 py-3">
+          <dt class="text-gray-500">最后活跃时间</dt>
+          <dd class="flex items-start gap-x-2">
+            <div class="font-medium text-gray-900">
+              {{ item.LastActive }}
+            </div>
+          </dd>
+        </div>
+
+      </dl>
+    </li>
+  </ul>
+</template>
--- a/frontend/src/views/group/index.vue
+++ b/frontend/src/views/group/index.vue
@ -0,0 +1,12 @@
+<script setup lang="ts">
+
+defineOptions({
+  name: "GroupPage"
+});
+</script>
+
+<template>
+  <main>
+    <h1>群组</h1>
+  </main>
+</template>
--- a/frontend/src/views/index/index.vue
+++ b/frontend/src/views/index/index.vue
@ -0,0 +1,12 @@
+<script setup lang="ts">
+
+defineOptions({
+  name: "IndexPage"
+});
+</script>
+
+<template>
+  <main>
+    <h1 class="text-orange-700">首页</h1>
+  </main>
+</template>
--- a/frontend/tailwind.config.js
+++ b/frontend/tailwind.config.js
@ -0,0 +1,12 @@
+/** @type {import('tailwindcss').Config} */
+export default {
+  content: ['./index.html', './src/**/*.{vue,js,ts,jsx,tsx,md}'],
+  theme: {
+    container: {
+      center: true,
+      padding: '2rem',
+    },
+  },
+  plugins: [require('daisyui'), require('@tailwindcss/forms'),],
+}
+
--- a/frontend/tsconfig.app.json
+++ b/frontend/tsconfig.app.json
@ -0,0 +1,14 @@
+{
+  "extends": "@vue/tsconfig/tsconfig.dom.json",
+  "include": ["env.d.ts", "src/**/*", "src/**/*.vue"],
+  "exclude": ["src/**/__tests__/*"],
+  "compilerOptions": {
+    "composite": true,
+    "tsBuildInfoFile": "./node_modules/.tmp/tsconfig.app.tsbuildinfo",
+
+    "baseUrl": ".",
+    "paths": {
+      "@/*": ["./src/*"]
+    }
+  }
+}
--- a/frontend/tsconfig.json
+++ b/frontend/tsconfig.json
@ -0,0 +1,11 @@
+{
+  "files": [],
+  "references": [
+    {
+      "path": "./tsconfig.node.json"
+    },
+    {
+      "path": "./tsconfig.app.json"
+    }
+  ]
+}
--- a/frontend/tsconfig.node.json
+++ b/frontend/tsconfig.node.json
@ -0,0 +1,19 @@
+{
+  "extends": "@tsconfig/node20/tsconfig.json",
+  "include": [
+    "vite.config.*",
+    "vitest.config.*",
+    "cypress.config.*",
+    "nightwatch.conf.*",
+    "playwright.config.*"
+  ],
+  "compilerOptions": {
+    "composite": true,
+    "noEmit": true,
+    "tsBuildInfoFile": "./node_modules/.tmp/tsconfig.node.tsbuildinfo",
+
+    "module": "ESNext",
+    "moduleResolution": "Bundler",
+    "types": ["node"]
+  }
+}
--- a/frontend/vite.config.ts
+++ b/frontend/vite.config.ts
@ -0,0 +1,28 @@
+import { fileURLToPath, URL } from 'node:url'
+
+import { defineConfig } from 'vite'
+import vue from '@vitejs/plugin-vue'
+import vueJsx from '@vitejs/plugin-vue-jsx'
+
+// https://vitejs.dev/config/
+export default defineConfig({
+  server: {
+    proxy: {
+      "/api": {
+        // target: "https://graduate.frps.ltd",
+        target: "http://127.0.0.1:8080",
+        changeOrigin: true
+        // rewrite: path => path.replace(/^\/api/, "")
+      }
+    },
+  },
+  plugins: [
+    vue(),
+    vueJsx(),
+  ],
+  resolve: {
+    alias: {
+      '@': fileURLToPath(new URL('./src', import.meta.url))
+    }
+  }
+})
--- a/go.mod
+++ b/go.mod
@ -1,76 +1,44 @@
-module wechat-robot
+module go-wechat

 go 1.21

 require (
-	gitee.ltd/lxh/logger v1.0.15
+	github.com/duke-git/lancet/v2 v2.2.8
 	github.com/fsnotify/fsnotify v1.7.0
 	github.com/gin-gonic/gin v1.9.1
 	github.com/go-co-op/gocron v1.37.0
-	github.com/go-oauth2/oauth2/v4 v4.5.2
-	github.com/go-oauth2/redis/v4 v4.1.1
-	github.com/go-playground/locales v0.14.1
-	github.com/go-playground/universal-translator v0.18.1
-	github.com/go-playground/validator/v10 v10.17.0
-	github.com/go-redis/redis/v8 v8.11.5
 	github.com/go-resty/resty/v2 v2.11.0
-	github.com/google/uuid v1.6.0
-	github.com/mojocn/base64Captcha v1.3.6
-	github.com/rabbitmq/amqp091-go v1.2.0
+	github.com/rabbitmq/amqp091-go v1.9.0
+	github.com/sashabaranov/go-openai v1.17.11
 	github.com/spf13/viper v1.18.2
-	golang.org/x/crypto v0.18.0
 	gorm.io/driver/mysql v1.5.2
-	gorm.io/driver/postgres v1.5.4
-	gorm.io/gorm v1.25.6
-	gorm.io/plugin/soft_delete v1.2.1
+	gorm.io/gorm v1.25.5
 )

 require (
-	github.com/beorn7/perks v1.0.1 // indirect
 	github.com/bytedance/sonic v1.10.2 // indirect
-	github.com/caarlos0/env/v6 v6.10.1 // indirect
-	github.com/cespare/xxhash/v2 v2.2.0 // indirect
 	github.com/chenzhuoyu/base64x v0.0.0-20230717121745-296ad89f973d // indirect
 	github.com/chenzhuoyu/iasm v0.9.1 // indirect
-	github.com/dgryski/go-rendezvous v0.0.0-20200823014737-9f7001d12a5f // indirect
 	github.com/gabriel-vasile/mimetype v1.4.3 // indirect
 	github.com/gin-contrib/sse v0.1.0 // indirect
-	github.com/go-kit/kit v0.13.0 // indirect
-	github.com/go-kit/log v0.2.1 // indirect
-	github.com/go-logfmt/logfmt v0.6.0 // indirect
+	github.com/go-playground/locales v0.14.1 // indirect
+	github.com/go-playground/universal-translator v0.18.1 // indirect
+	github.com/go-playground/validator/v10 v10.16.0 // indirect
 	github.com/go-sql-driver/mysql v1.7.1 // indirect
 	github.com/goccy/go-json v0.10.2 // indirect
-	github.com/gogo/protobuf v1.3.2 // indirect
-	github.com/golang-jwt/jwt v3.2.2+incompatible // indirect
-	github.com/golang/freetype v0.0.0-20170609003504-e2365dfdc4a0 // indirect
-	github.com/golang/protobuf v1.5.3 // indirect
-	github.com/golang/snappy v0.0.4 // indirect
+	github.com/google/uuid v1.5.0 // indirect
 	github.com/hashicorp/hcl v1.0.0 // indirect
-	github.com/jackc/pgpassfile v1.0.0 // indirect
-	github.com/jackc/pgservicefile v0.0.0-20231201235250-de7065d80cb9 // indirect
-	github.com/jackc/pgx/v5 v5.5.2 // indirect
-	github.com/jackc/puddle/v2 v2.2.1 // indirect
 	github.com/jinzhu/inflection v1.0.0 // indirect
 	github.com/jinzhu/now v1.1.5 // indirect
-	github.com/jpillora/backoff v1.0.0 // indirect
 	github.com/json-iterator/go v1.1.12 // indirect
 	github.com/klauspost/cpuid/v2 v2.2.6 // indirect
-	github.com/leodido/go-urn v1.3.0 // indirect
-	github.com/lixh00/loki-client-go v1.0.1 // indirect
+	github.com/leodido/go-urn v1.2.4 // indirect
 	github.com/magiconair/properties v1.8.7 // indirect
 	github.com/mattn/go-isatty v0.0.20 // indirect
 	github.com/mitchellh/mapstructure v1.5.0 // indirect
 	github.com/modern-go/concurrent v0.0.0-20180306012644-bacd9c7ef1dd // indirect
 	github.com/modern-go/reflect2 v1.0.2 // indirect
-	github.com/mwitkow/go-conntrack v0.0.0-20190716064945-2f068394615f // indirect
-	github.com/natefinch/lumberjack v2.0.0+incompatible // indirect
 	github.com/pelletier/go-toml/v2 v2.1.1 // indirect
-	github.com/pkg/errors v0.9.1 // indirect
-	github.com/prometheus/client_golang v1.18.0 // indirect
-	github.com/prometheus/client_model v0.5.0 // indirect
-	github.com/prometheus/common v0.46.0 // indirect
-	github.com/prometheus/procfs v0.12.0 // indirect
-	github.com/prometheus/prometheus v1.8.2-0.20201028100903-3245b3267b24 // indirect
 	github.com/robfig/cron/v3 v3.0.1 // indirect
 	github.com/sagikazarmark/locafero v0.4.0 // indirect
 	github.com/sagikazarmark/slog-shim v0.1.0 // indirect
@ -79,32 +47,17 @@ require (
 	github.com/spf13/cast v1.6.0 // indirect
 	github.com/spf13/pflag v1.0.5 // indirect
 	github.com/subosito/gotenv v1.6.0 // indirect
-	github.com/tidwall/btree v1.7.0 // indirect
-	github.com/tidwall/buntdb v1.3.0 // indirect
-	github.com/tidwall/gjson v1.17.0 // indirect
-	github.com/tidwall/grect v0.1.4 // indirect
-	github.com/tidwall/match v1.1.1 // indirect
-	github.com/tidwall/pretty v1.2.1 // indirect
-	github.com/tidwall/rtred v0.1.2 // indirect
-	github.com/tidwall/tinyqueue v0.1.1 // indirect
 	github.com/twitchyliquid64/golang-asm v0.15.1 // indirect
 	github.com/ugorji/go/codec v1.2.12 // indirect
 	go.uber.org/atomic v1.11.0 // indirect
 	go.uber.org/multierr v1.11.0 // indirect
-	go.uber.org/zap v1.26.0 // indirect
 	golang.org/x/arch v0.7.0 // indirect
-	golang.org/x/exp v0.0.0-20240119083558-1b970713d09a // indirect
-	golang.org/x/image v0.15.0 // indirect
+	golang.org/x/crypto v0.18.0 // indirect
+	golang.org/x/exp v0.0.0-20240112132812-db7319d0e0e3 // indirect
 	golang.org/x/net v0.20.0 // indirect
-	golang.org/x/oauth2 v0.16.0 // indirect
-	golang.org/x/sync v0.6.0 // indirect
 	golang.org/x/sys v0.16.0 // indirect
 	golang.org/x/text v0.14.0 // indirect
-	google.golang.org/appengine v1.6.8 // indirect
-	google.golang.org/genproto/googleapis/rpc v0.0.0-20240125205218-1f4bbc51befe // indirect
-	google.golang.org/grpc v1.61.0 // indirect
 	google.golang.org/protobuf v1.32.0 // indirect
 	gopkg.in/ini.v1 v1.67.0 // indirect
-	gopkg.in/yaml.v2 v2.4.0 // indirect
 	gopkg.in/yaml.v3 v3.0.1 // indirect
 )
--- a/go.sum
+++ b/go.sum
--- a/internal/initialize/config.go
+++ b/internal/initialize/config.go
@ -1,20 +1,19 @@
-package initialize
+package initialization

 import (
-	"gitee.ltd/lxh/logger/log"
 	"github.com/fsnotify/fsnotify"
 	"github.com/spf13/viper"
-	"wechat-robot/config"
-	"wechat-robot/internal/database"
-	"wechat-robot/internal/redis"
+	"go-wechat/client"
+	"go-wechat/config"
+	"log"
 )

 // 配置管理工具
 var vp *viper.Viper

-// Config
+// InitConfig
 // @description: 初始化配置
-func initConfig() {
+func InitConfig() {
 	vp = viper.New()
 	vp.AddConfigPath(".")      // 设置配置文件路径
 	vp.SetConfigName("config") // 设置配置文件名
@ -27,21 +26,27 @@ func initConfig() {
 	if err := vp.Unmarshal(&config.Conf); err != nil {
 		log.Panicf("配置文件解析失败: %v", err)
 	}
-	log.Debugf("配置文件解析完成: %+v", config.Conf)
+	log.Printf("配置文件解析完成: %+v", config.Conf)
+	if !config.Conf.Wechat.Check() {
+		log.Panicf("微信HOOK配置缺失")
+	}
 	// 初始化数据库连接
-	database.Init()
-	redis.Init()
+	client.InitMySQLClient()
+	//redis.Init()

 	// 下面的代码是配置变动之后自动刷新的
 	vp.WatchConfig()
 	vp.OnConfigChange(func(e fsnotify.Event) {
 		// 绑定配置文件
 		if err := vp.Unmarshal(&config.Conf); err != nil {
-			log.Errorf("配置文件更新失败: %v", err)
+			log.Printf("配置文件更新失败: %v", err)
 		} else {
+			if !config.Conf.Wechat.Check() {
+				log.Panicf("微信HOOK配置缺失")
+			}
 			// 初始化数据库连接
-			database.Init()
-			redis.Init()
+			client.InitMySQLClient()
+			//redis.Init()
 		}
 	})
 }
--- a/initialization/plugin.go
+++ b/initialization/plugin.go
@ -0,0 +1,46 @@
+package initialization
+
+import (
+	"go-wechat/common/current"
+	"go-wechat/model/model"
+	plugin "go-wechat/plugin"
+	"go-wechat/plugin/plugins"
+	"go-wechat/service"
+)
+
+// Plugin
+// @description: 初始化插件
+func Plugin() {
+	// 定义一个处理器
+	dispatcher := plugin.NewMessageMatchDispatcher()
+	// 设置为异步处理
+	dispatcher.SetAsync(true)
+
+	// 注册插件
+
+	// 保存消息进数据库
+	dispatcher.RegisterHandler(func(*model.Message) bool {
+		return true
+	}, plugins.SaveToDb)
+
+	// 私聊指令消息
+	dispatcher.RegisterHandler(func(m *model.Message) bool {
+		// 私聊消息 或 群聊艾特机器人并且以/开头的消息
+		isGroupAt := m.IsAt() && !m.IsAtAll()
+		return (m.IsPrivateText() || isGroupAt) && m.CleanContentStartWith("/") && service.CheckIsEnableCommand(m.FromUser)
+	}, plugins.Command)
+
+	// AI消息插件
+	dispatcher.RegisterHandler(func(m *model.Message) bool {
+		// 群内@或者私聊文字消息
+		return (m.IsAt() && !m.IsAtAll()) || m.IsPrivateText()
+	}, plugins.AI)
+
+	// 欢迎新成员
+	dispatcher.RegisterHandler(func(m *model.Message) bool {
+		return m.IsNewUserJoin()
+	}, plugins.WelcomeNew)
+
+	// 注册消息处理器
+	current.SetRobotMessageHandler(plugin.DispatchMessage(dispatcher))
+}
--- a/initialization/wechat.go
+++ b/initialization/wechat.go
@ -0,0 +1,31 @@
+package initialization
+
+import (
+	"github.com/go-resty/resty/v2"
+	"go-wechat/common/current"
+	"go-wechat/config"
+	model2 "go-wechat/model/model"
+	"log"
+)
+
+// InitWechatRobotInfo
+// @description: 初始化微信机器人信息
+func InitWechatRobotInfo() {
+	// 获取数据
+	var base model2.Response[model2.RobotUserInfo]
+	_, err := resty.New().R().
+		SetHeader("Content-Type", "application/json;chartset=utf-8").
+		SetResult(&base).
+		Post(config.Conf.Wechat.GetURL("/api/userInfo"))
+	if err != nil {
+		log.Printf("获取机器人信息失败: %s", err.Error())
+		return
+	}
+
+	log.Printf("机器人Id: %s", base.Data.WxId)
+	log.Printf("机器人微信号: %s", base.Data.Account)
+	log.Printf("机器人名称: %s", base.Data.Name)
+
+	// 设置为单例
+	current.SetRobotInfo(base.Data)
+}
--- a/internal/database/database.go
+++ b/internal/database/database.go
@ -1,49 +0,0 @@
-package database
-
-import (
-	"gitee.ltd/lxh/logger"
-	"gitee.ltd/lxh/logger/log"
-	"gorm.io/driver/mysql"
-	"gorm.io/driver/postgres"
-	"gorm.io/gorm"
-	"os"
-	"strconv"
-	"wechat-robot/config"
-)
-
-// Client 客户端
-var Client *gorm.DB
-
-// Init
-// @description: 初始化数据库连接
-func Init() {
-	var dialector gorm.Dialector
-	switch config.Conf.Database.Type {
-	case "mysql":
-		// MySQL
-		dialector = mysql.Open(config.Conf.Database.GetMysqlDSN())
-	case "postgresql":
-		// PostgreSQL
-		dialector = postgres.Open(config.Conf.Database.GetPostgreSQLDSN())
-	default:
-		log.Panic("未配置数据库或数据库类型不支持")
-	}
-
-	// gorm 配置
-	gormConfig := gorm.Config{
-		DisableForeignKeyConstraintWhenMigrating: true,
-	}
-	// 是否开启调试模式
-	if flag, _ := strconv.ParseBool(os.Getenv("GORM_DEBUG")); flag {
-		gormConfig.Logger = logger.DefaultGormLogger()
-	}
-
-	// 初始化连接
-	conn, err := gorm.Open(dialector, &gormConfig)
-	if err != nil {
-		log.Panicf("数据库连接初始化失败: %v", err)
-	} else {
-		log.Debug("数据库连接初始化成功")
-	}
-	Client = conn
-}
--- a/internal/initialize/adminuser.go
+++ b/internal/initialize/adminuser.go
@ -1,72 +0,0 @@
-package initialize
-
-import (
-	"errors"
-	"gitee.ltd/lxh/logger/log"
-	"gorm.io/gorm"
-	"wechat-robot/internal/database"
-	"wechat-robot/model/entity"
-	"wechat-robot/utils"
-)
-
-// initDefaultAdminUser
-// @description: 初始化默认后台用户
-func initDefaultAdminUser() {
-	// 如果数据库没有有效用户，初始化一个默认账号
-	var count int64
-	if err := database.Client.Model(entity.AdminUser{}).Count(&count).Error; err != nil {
-		log.Panicf("初始化默认账号失败: %s", err.Error())
-	}
-	if count > 0 {
-		return
-	}
-
-	// 开启事务
-	var err error
-	tx := database.Client.Begin()
-	defer func() {
-		if recover() != nil {
-			tx.Rollback()
-		} else {
-			if err != nil {
-				tx.Rollback()
-			} else {
-				tx.Commit()
-			}
-		}
-	}()
-	// 判断角色是否存在
-	var role entity.Role
-	if err = tx.Where("code = ?", "admin").First(&role).Error; err != nil && !errors.Is(err, gorm.ErrRecordNotFound) {
-		log.Panicf("初始化默认账号失败: %s", err.Error())
-		return
-	}
-	// 如果角色不存在，创建角色
-	if role.Id == "" {
-		role.Name = "超级管理员"
-		role.Code = "admin"
-		role.Describe = "系统默认超级管理员"
-		if err = tx.Create(&role).Error; err != nil {
-			log.Panicf("初始化默认账号失败: %s", err.Error())
-			return
-		}
-	}
-
-	// 创建用户
-	var adminUser entity.AdminUser
-	adminUser.Username = "admin"
-	adminUser.Password = "admin123"
-	utils.PasswordUtils().HashPassword(&adminUser.Password)
-	if err = tx.Create(&adminUser).Error; err != nil {
-		log.Panicf("初始化默认账号失败: %s", err.Error())
-		return
-	}
-	// 绑定角色
-	var userRole entity.AdminUserRole
-	userRole.RoleId = role.Id
-	userRole.UserId = adminUser.Id
-	if err = tx.Create(&userRole).Error; err != nil {
-		log.Panicf("初始化默认账号失败: %s", err.Error())
-		return
-	}
-}
--- a/internal/initialize/datatable.go
+++ b/internal/initialize/datatable.go
@ -1,28 +0,0 @@
-package initialize
-
-import (
-	"gitee.ltd/lxh/logger/log"
-	"wechat-robot/internal/database"
-	"wechat-robot/model/entity"
-)
-
-// databaseTable
-// @description: 初始化数据库表
-func databaseTable() {
-	tables := []any{
-		new(entity.AdminUser),     // 用户表
-		new(entity.Menu),          // 菜单表
-		new(entity.Role),          // 角色表
-		new(entity.RoleMenu),      // 角色菜单表
-		new(entity.AdminUserRole), // 用户角色表
-		new(entity.SystemConfig),  // 系统配置表
-		new(entity.Robot),         // 机器人表
-		new(entity.AiAssistant),   // AI助手表
-		new(entity.Message),       // 微信消息表
-	}
-
-	// 同步表结构
-	if err := database.Client.AutoMigrate(tables...); err != nil {
-		log.Panicf("初始化数据库表失败: %v", err)
-	}
-}
--- a/internal/initialize/init.go
+++ b/internal/initialize/init.go
@ -1,18 +0,0 @@
-package initialize
-
-import (
-	"wechat-robot/internal/tasks"
-	"wechat-robot/mq"
-	"wechat-robot/pkg/auth"
-)
-
-// InitSystem
-// @description: 初始化系统
-func InitSystem() {
-	initConfig()            // 初始化配置
-	databaseTable()         // 初始化数据库表
-	initDefaultAdminUser()  // 初始化默认管理员用户
-	auth.InitOAuth2Server() // 初始化OAuth2服务
-	tasks.StartScheduled()  // 启动定时任务
-	mq.Init()               // 初始化MQ
-}
--- a/internal/message/handler.go
+++ b/internal/message/handler.go
@ -1,56 +0,0 @@
-package message
-
-import (
-	"encoding/json"
-	"log"
-	"strings"
-	"time"
-	"wechat-robot/model/entity"
-	"wechat-robot/model/robot"
-	"wechat-robot/pkg/types"
-	"wechat-robot/service/message"
-)
-
-// Message
-// @description: 处理消息
-// @param msg
-// @return err
-func Message(msg []byte) (err error) {
-	var m robot.Message
-	if err = json.Unmarshal(msg, &m); err != nil {
-		log.Printf("消息解析失败： %v", err)
-		log.Printf("消息内容： %d -> %v", len(msg), string(msg))
-		return
-	}
-	// 记录原始数据
-	m.Raw = string(msg)
-	// 提取出群成员信息
-	// Sys类型的消息正文不包含微信 Id，所以不需要处理
-	if m.IsGroup() && m.Type != types.MsgTypeSys {
-		// 群消息，处理一下消息和发信人
-		groupUser := strings.Split(m.Content, "\n")[0]
-		groupUser = strings.ReplaceAll(groupUser, ":", "")
-		// 如果两个id一致，说明是系统发的
-		if m.FromUser != groupUser {
-			m.GroupUser = groupUser
-		}
-		// 用户的操作单独提出来处理一下
-		m.Content = strings.Join(strings.Split(m.Content, "\n")[1:], "\n")
-	}
-	log.Printf("收到微信消息\n机器人Id: %s\n消息来源: %s\n群成员: %s\n消息类型: %v\n消息内容: %s", m.ToUser, m.FromUser, m.GroupUser, m.Type, m.Content)
-
-	// 消息入库
-	var ent entity.Message
-	ent.MsgId = m.MsgId
-	ent.Timestamp = m.CreateTime
-	ent.MessageTime = time.Unix(int64(m.CreateTime), 0)
-	ent.Content = m.Content
-	ent.FromUser = m.FromUser
-	ent.GroupUser = m.GroupUser
-	ent.ToUser = m.ToUser
-	ent.Type = m.Type
-	ent.DisplayFullContent = m.DisplayFullContent
-	ent.Raw = m.Raw
-	err = message.Save(ent)
-	return
-}
--- a/internal/orm/page.go
+++ b/internal/orm/page.go
@ -1,30 +0,0 @@
-package orm
-
-import "gorm.io/gorm"
-
-// Page
-// @description: 分页组件
-// @param current
-// @param size
-// @return func(db *gorm.DB) *gorm.DB
-func Page(current, size int) func(db *gorm.DB) *gorm.DB {
-	// 如果页码是-1，就不分页
-	if current == -1 {
-		return func(db *gorm.DB) *gorm.DB {
-			return db
-		}
-	}
-	// 分页
-	return func(db *gorm.DB) *gorm.DB {
-		if current == 0 {
-			current = 1
-		}
-		if size < 1 {
-			size = 10
-		}
-		// 计算偏移量
-		offset := (current - 1) * size
-		// 返回组装结果
-		return db.Offset(offset).Limit(size)
-	}
-}
--- a/internal/orm/sort.go
+++ b/internal/orm/sort.go
@ -1,148 +0,0 @@
-package orm
-
-import (
-	"fmt"
-	"gitee.ltd/lxh/logger/log"
-	"gorm.io/gorm"
-	"slices"
-)
-
-// @title checkHasDeletedAt
-// @description 检查指定表是否有id_del字段
-// @param tx *gorm.DB "已开启的事务对象"
-// @param tableName string "表名"
-// @return bool "是否包含"
-func checkHasDeletedAt(tx *gorm.DB, tableName string) bool {
-	var columns []string
-	// SQL语句
-	sql := fmt.Sprintf("select COLUMN_NAME from information_schema.COLUMNS where table_name = '%s'", tableName)
-	err := tx.Raw(sql).Scan(&columns).Error
-	if err != nil {
-		log.Errorf("查询表字段失败: %v", err.Error())
-		return false
-	}
-	return slices.Contains(columns, "id_del")
-}
-
-// @title checkHasUpdatedAt
-// @description 检查指定表是否有updated_at字段
-// @param tx *gorm.DB "已开启的事务对象"
-// @param tableName string "表名"
-// @return bool "是否包含"
-func checkHasUpdatedAt(tx *gorm.DB, tableName string) bool {
-	var columns []string
-	// SQL语句
-	sql := fmt.Sprintf("select COLUMN_NAME from information_schema.COLUMNS where table_name = '%s'", tableName)
-	err := tx.Raw(sql).Scan(&columns).Error
-	if err != nil {
-		log.Errorf("查询表字段失败: %v", err.Error())
-		return false
-	}
-	return slices.Contains(columns, "updated_at")
-}
-
-// UpdateSortBefore
-// @description 更新之前处理序号
-// @param tx *gorm.DB "已开启的事务对象"
-// @param model any "模型对象"
-// @return error "错误信息"
-func UpdateSortBefore(tx *gorm.DB, tableName, id string, sort int, param string) (err error) {
-	// 查出原来的排序号
-	var oldSort int
-	err = tx.Table(tableName).Select("`sort`").Where("id = ?", id).Scan(&oldSort).Error
-	if err != nil {
-		log.Errorf("查询老数据失败: %v", err.Error())
-		return
-	}
-	// 如果相等，啥都不干
-	if oldSort == sort {
-		return nil
-	}
-
-	// 查询是否包含 id_del 字段
-	hasDeletedAt := checkHasDeletedAt(tx, tableName)
-
-	// 处理排序
-	// 如果老的排序号小于新的，(老, 新]之间的排序号都要-1
-	// 如果老的大于新的，[老, 新)排序号-1
-	if oldSort < sort {
-		// 老的小于新的，[老, 新) + 1
-		sel := tx.Table(tableName).
-			Where("sort <= ? AND sort > ?", sort, oldSort)
-		if hasDeletedAt {
-			sel.Where("id_del = 0")
-		}
-		if param != "" {
-			sel.Where(param) // 自定义条件
-		}
-		err = sel.Update("sort", gorm.Expr("sort - 1")).Error
-	} else {
-		// 老的大于新的，[新, 老) + 1
-		sel := tx.Table(tableName).
-			Where("sort >= ? AND sort < ?", sort, oldSort)
-		if hasDeletedAt {
-			sel.Where("id_del = 0")
-		}
-		if param != "" {
-			sel.Where(param) // 自定义条件
-		}
-		err = sel.Update("sort", gorm.Expr("sort + 1")).Error
-	}
-	return
-}
-
-// CreateSortBefore
-// @description 新建之前处理序号
-// @param tx *gorm.DB "已开启的事务对象"
-// @param model any "模型对象"
-// @return error "错误信息"
-func CreateSortBefore(tx *gorm.DB, tableName string, sort int, param string) (err error) {
-	// 查询是否包含 id_del 字段
-	hasDeletedAt := checkHasDeletedAt(tx, tableName)
-
-	// 处理排序,如果没有传，就会是在最前面
-	sel := tx.Table(tableName).Where("sort >= ?", sort)
-	if hasDeletedAt {
-		sel.Where("id_del = 0")
-	}
-	if param != "" {
-		sel.Where(param)
-	}
-	err = sel.Update("sort", gorm.Expr("sort + 1")).Error
-	if err != nil {
-		log.Errorf("处理前置排序失败：%v", err)
-	}
-	return
-}
-
-// DealSortAfter
-// @description 处理序号之后
-// @param tx *gorm.DB "已开启的事务对象"
-// @param modelName string "表名"
-// @return error "错误信息"
-func DealSortAfter(tx *gorm.DB, modelName, param string) (err error) {
-	// 保存成功，刷新排序
-	if param != "" {
-		param = " AND " + param
-	}
-
-	// 查询是否包含 id_del 字段
-	hasDeletedAt := checkHasDeletedAt(tx, modelName)
-	if hasDeletedAt {
-		param += " AND id_del = 0"
-	}
-
-	// 如果有更新时间字段，也更新一下值
-	updateParam := ""
-	if checkHasUpdatedAt(tx, modelName) {
-		updateParam = ",updated_at = NOW()"
-	}
-
-	sql := fmt.Sprintf("UPDATE %s a, (SELECT (@i := @i + 1) i, id FROM %s WHERE 1=1 %s order by sort ASC) i, "+
-		"(SELECT @i := 0) ir SET a.sort = i.i %s WHERE a.id = i.id", modelName, modelName, param, updateParam)
-	err = tx.Exec(sql).Error
-	if err != nil {
-		log.Errorf("刷新排序失败: %v", err.Error())
-	}
-	return
-}
--- a/internal/redis/redis.go
+++ b/internal/redis/redis.go
@ -1,28 +0,0 @@
-package redis
-
-import (
-	"context"
-	"gitee.ltd/lxh/logger/log"
-	"github.com/go-redis/redis/v8"
-	"wechat-robot/config"
-)
-
-var Client *redis.Client
-
-// Init
-// @description: 初始化redis客户端
-func Init() {
-	conf := config.Conf.Redis
-	// 初始化连接
-	conn := redis.NewClient(&redis.Options{
-		Addr:     conf.GetDSN(),
-		Password: conf.Password,
-		DB:       conf.Db,
-	})
-	if err := conn.Ping(context.Background()).Err(); err != nil {
-		log.Panicf("Redis连接初始化失败: %v", err)
-	} else {
-		log.Debug("Redis连接初始化成功")
-	}
-	Client = conn
-}
--- a/internal/tasks/tasks.go
+++ b/internal/tasks/tasks.go
@ -1,20 +0,0 @@
-package tasks
-
-import (
-	"github.com/go-co-op/gocron"
-	"log"
-	"time"
-)
-
-var Scheduler *gocron.Scheduler
-
-// StartScheduled
-// @description: 启动定时任务
-func StartScheduled() {
-	// 定时任务发送消息
-	Scheduler = gocron.NewScheduler(time.Local)
-
-	// 开启定时任务
-	Scheduler.StartAsync()
-	log.Println("定时任务初始化成功")
-}
--- a/main.go
+++ b/main.go
@ -1,49 +1,85 @@
 package main

 import (
-	"gitee.ltd/lxh/logger"
-	"gitee.ltd/lxh/logger/log"
 	"github.com/gin-gonic/gin"
-	"wechat-robot/internal/initialize"
-	"wechat-robot/pkg/validator"
-	"wechat-robot/router/admin"
-	"wechat-robot/router/callback"
-	"wechat-robot/router/middleware"
+	"go-wechat/config"
+	"go-wechat/initialization"
+	"go-wechat/mq"
+	"go-wechat/router"
+	"go-wechat/tasks"
+	"go-wechat/tcpserver"
+	"go-wechat/utils"
+	"html/template"
+	"log"
+	"net/http"
+	"strings"
+	"time"
 )

-// init
-// @description: 初始系统
 func init() {
-	// 初始化日志工具
-	logger.InitLogger(logger.LogConfig{Mode: logger.Dev, LokiEnable: false, FileEnable: true})
-	// 初始化系统
-	initialize.InitSystem()
+	initialization.InitConfig()          // 初始化配置
+	initialization.InitWechatRobotInfo() // 初始化机器人信息
+	initialization.Plugin()              // 注册插件
+	tasks.InitTasks()                    // 初始化定时任务
+	mq.Init()                            // 初始化MQ
 }

-// main
-// @description: 启动入口
 func main() {
-	// 启动TCP服务
-	//go tcpserver.Start()
+	// 如果启用了自动配置回调，就设置一下
+	if config.Conf.Wechat.AutoSetCallback {
+		utils.ClearCallback()
+		time.Sleep(500 * time.Millisecond) // 休眠五百毫秒再设置
+		utils.SetCallback(config.Conf.Wechat.Callback)
+	}

-	// 注册参数绑定错误信息翻译器
-	validator.Init()
+	// 启动TCP服务
+	go tcpserver.Start()
+
+	// 启动HTTP服务
 	app := gin.Default()

-	// 开启自定义请求方式不允许处理函数
-	app.HandleMethodNotAllowed = true
-	// 处理请求方式不对
-	app.NoMethod(middleware.NoMethodHandler())
+	// 自定义模板引擎函数
+	app.SetFuncMap(template.FuncMap{
+		"codeToChinese": func(code string) string {
+			switch code {
+			case "friend":
+				return "好友列表"
+			case "group":
+				return "群组列表"
+			case "index":
+				return "首页"
+			case "assistant":
+				return "AI角色"
+			default:
+				return "其他页面"
+			}
+		},
+		"boolToChinese": func(flag bool) string {
+			if flag {
+				return "是"
+			}
+			return "否"
+		},
+	})
+
+	app.LoadHTMLGlob("views/*.html")
+	app.Static("/assets", "./views/static")
+	app.StaticFile("/favicon.ico", "./views/wechat.ico")
 	// 404返回数据
-	app.NoRoute(middleware.NoRouteHandler())
-
-	// 初始化接口路由
-	admin.InitRoute(app.Group("/admin/v1"))    // 后台接口
-	callback.InitRoute(app.Group("/callback")) // 回调接口
-
-	// 启动服务
-	if err := app.Run(":8080"); err != nil {
-		log.Errorf("服务启动失败：%v", err)
+	app.NoRoute(func(ctx *gin.Context) {
+		if strings.HasPrefix(ctx.Request.URL.Path, "/api") {
+			ctx.String(404, "接口不存在")
 			return
 		}
+		// 404直接跳转到首页
+		ctx.Redirect(302, "/404.html")
+	})
+	app.NoMethod(func(ctx *gin.Context) {
+		ctx.String(http.StatusMethodNotAllowed, "不支持的请求方式")
+	})
+	// 初始化路由
+	router.Init(app)
+	if err := app.Run(":8080"); err != nil {
+		log.Panicf("服务启动失败：%v", err)
+	}
 }
--- a/model/entity/adminuser.go
+++ b/model/entity/adminuser.go
@ -1,23 +0,0 @@
-package entity
-
-import "wechat-robot/pkg/types"
-
-// AdminUser
-// @description: 用户表
-type AdminUser struct {
-	types.BaseDbModel
-	Username    string          `json:"username" gorm:"index:deleted,unique;type:varchar(255); not null; comment:'登录账号'"`
-	Password    string          `json:"password" gorm:"type:varchar(255); comment:'密码'"`
-	Email       *string         `json:"email" gorm:"type:varchar(255); comment:'邮箱'"`
-	IsVerified  bool            `json:"isVerified" gorm:"type:tinyint(1); not null; default:0; comment:'是否验证邮箱'"`
-	LastLoginAt *types.DateTime `json:"lastLoginAt" gorm:"comment:'最后登录时间'"`
-	LastLoginIp *string         `json:"lastLoginIp" gorm:"type:varchar(255); comment:'最后登录ip'"`
-}
-
-// TableName
-// @description: 表名
-// @receiver User
-// @return string
-func (AdminUser) TableName() string {
-	return "t_admin_user"
-}
--- a/model/entity/aiassistant.go
+++ b/model/entity/aiassistant.go
@ -1,11 +1,17 @@
 package entity

-import "wechat-robot/pkg/types"
+import (
+	"github.com/google/uuid"
+	"go-wechat/common/types"
+	"gorm.io/gorm"
+	"strings"
+)

 // AiAssistant
 // @description: AI助手表
 type AiAssistant struct {
-	types.BaseDbModel
+	Id          string         `json:"id" gorm:"type:varchar(32);primarykey"`
+	CreatedAt   types.DateTime `json:"createdAt"`
 	Name        string         `json:"name" gorm:"type:varchar(10);not null;comment:'名称'"`
 	Personality string         `json:"personality" gorm:"type:varchar(999);not null;comment:'人设'"`
 	Model       string         `json:"model" gorm:"type:varchar(50);not null;comment:'使用的模型'"`
@ -19,3 +25,15 @@ type AiAssistant struct {
 func (AiAssistant) TableName() string {
 	return "t_ai_assistant"
 }
+
+// BeforeCreate
+// @description: 创建数据库对象之前生成UUID
+// @receiver m
+// @param *gorm.DB
+// @return err
+func (m *AiAssistant) BeforeCreate(*gorm.DB) (err error) {
+	if m.Id == "" {
+		m.Id = strings.ReplaceAll(uuid.New().String(), "-", "")
+	}
+	return
+}
--- a/model/entity/friend.go
+++ b/model/entity/friend.go
@ -0,0 +1,49 @@
+package entity
+
+import (
+	"time"
+)
+
+// Friend
+// @description: 好友列表
+type Friend struct {
+	Wxid           string    `json:"wxid"`                                                     // 微信原始Id
+	CustomAccount  string    `json:"customAccount"`                                            // 微信号
+	Nickname       string    `json:"nickname"`                                                 // 昵称
+	Pinyin         string    `json:"pinyin"`                                                   // 昵称拼音大写首字母
+	PinyinAll      string    `json:"pinyinAll"`                                                // 昵称全拼
+	LastActive     time.Time `json:"lastActive"`                                               // 最后活跃时间
+	EnableAi       bool      `json:"enableAI" gorm:"type:tinyint(1) default 0 not null"`       // 是否使用AI
+	AiModel        string    `json:"aiModel"`                                                  // AI模型
+	Prompt         string    `json:"prompt"`                                                   // 提示词
+	EnableChatRank bool      `json:"enableChatRank" gorm:"type:tinyint(1) default 0 not null"` // 是否使用聊天排行
+	EnableWelcome  bool      `json:"enableWelcome" gorm:"type:tinyint(1) default 0 not null"`  // 是否启用迎新
+	EnableSummary  bool      `json:"enableSummary" gorm:"type:tinyint(1) default 0 not null"`  // 是否启用总结
+	EnableNews     bool      `json:"enableNews" gorm:"type:tinyint(1) default 0 not null"`     // 是否启用新闻
+	ClearMember    int       `json:"clearMember"`                                              // 清理成员配置（多少天未活跃的）
+	IsOk           bool      `json:"isOk" gorm:"type:tinyint(1) default 0 not null"`           // 是否正常
+}
+
+func (Friend) TableName() string {
+	return "t_friend"
+}
+
+// GroupUser
+// @description: 群成员
+type GroupUser struct {
+	GroupId      string     `json:"groupId"`                                                // 群Id
+	Wxid         string     `json:"wxid"`                                                   // 微信Id
+	Account      string     `json:"account"`                                                // 账号
+	HeadImage    string     `json:"headImage"`                                              // 头像
+	Nickname     string     `json:"nickname"`                                               // 昵称
+	IsMember     bool       `json:"isMember" gorm:"type:tinyint(1) default 0 not null"`     // 是否群成员
+	IsAdmin      bool       `json:"isAdmin" gorm:"type:tinyint(1) default 0 not null"`      // 是否群主
+	JoinTime     time.Time  `json:"joinTime"`                                               // 加入时间
+	LastActive   time.Time  `json:"lastActive"`                                             // 最后活跃时间
+	LeaveTime    *time.Time `json:"leaveTime"`                                              // 离开时间
+	SkipChatRank bool       `json:"skipChatRank" gorm:"type:tinyint(1) default 0 not null"` // 是否跳过聊天排行
+}
+
+func (GroupUser) TableName() string {
+	return "t_group_user"
+}
--- a/model/entity/menu.go
+++ b/model/entity/menu.go
@ -1,24 +0,0 @@
-package entity
-
-import "wechat-robot/pkg/types"
-
-// Menu
-// @description: 菜单表
-type Menu struct {
-	types.BaseDbModel
-	Type     types.MenuType `json:"type" gorm:"type:enum('MENU','BUTTON'); default:'MENU'; not null; comment:'菜单类型(菜单或按钮)'"`
-	Name     string         `json:"name" gorm:"type:varchar(255);not null;comment:'页面组件名称'"`
-	Path     string         `json:"path" gorm:"type:varchar(255);comment:'路径'"`
-	Title    string         `json:"title" gorm:"type:varchar(255);not null;comment:'菜单标题'"`
-	Icon     string         `json:"icon" gorm:"type:varchar(255);comment:'菜单图标'"`
-	Sort     int            `json:"sort" gorm:"type:int(3);not null;comment:'排序值(数字越小约靠前)'"`
-	ParentId *string        `json:"parentId" gorm:"type:varchar(32);comment:'父级菜单ID(0表示顶级菜单)'"`
-}
-
-// TableName
-// @description: 表名
-// @receiver Menu
-// @return string
-func (Menu) TableName() string {
-	return "t_menu"
-}
--- a/model/entity/message.go
+++ b/model/entity/message.go
@ -1,24 +1,23 @@
 package entity

 import (
+	"go-wechat/types"
 	"time"
-	"wechat-robot/pkg/types"
 )

 // Message
 // @description: 消息数据库结构体
 type Message struct {
-	types.BaseDbModelWithReal
-	MsgId              int64             `gorm:"index:idx_msg_id,unique;type:bigint;not null;comment:'微信Id'"`      // 消息Id
-	Timestamp          int               `gorm:"type:bigint;not null;comment:'消息时间戳'"`                             // 发送时间戳
-	MessageTime        time.Time         `gorm:"type:datetime;not null;comment:'消息时间'"`                            // 发送时间
-	Type               types.MessageType `gorm:"type:int;not null;comment:'消息类型'"`                                 // 消息类型
-	Content            string            `gorm:"type:longtext;not null;comment:'消息内容'"`                            // 内容
-	DisplayFullContent string            `gorm:"type:longtext;not null;comment:'显示的完整内容'"`                         // 显示的完整内容
-	FromUser           string            `gorm:"type:varchar(100);not null;comment:'发送者'"`                         // 发送者
-	GroupUser          string            `gorm:"type:varchar(100);comment:'群成员'"`                                  // 群成员
-	ToUser             string            `gorm:"index:idx_msg_id,unique;type:varchar(100);not null;comment:'接收者'"` // 接收者
-	Raw                string            `gorm:"type:longtext;not null;comment:'原始通知字符串'"`                         // 原始通知字符串
+	MsgId              int64             `gorm:"primaryKey"` // 消息Id
+	CreateTime         int               // 发送时间戳
+	CreateAt           time.Time         // 发送时间
+	Type               types.MessageType // 消息类型
+	Content            string            // 内容
+	DisplayFullContent string            // 显示的完整内容
+	FromUser           string            // 发送者
+	GroupUser          string            // 群成员
+	ToUser             string            // 接收者
+	Raw                string            // 原始通知字符串
 }

 func (Message) TableName() string {
--- a/model/entity/plugindata.go
+++ b/model/entity/plugindata.go
@ -0,0 +1,13 @@
+package entity
+
+// PluginData
+// @description: 插件数据
+type PluginData struct {
+	UserId     string `json:"userId"`     // 用户Id
+	PluginCode string `json:"pluginCode"` // 插件编码
+	Data       string `json:"data"`       // 数据
+}
+
+func (PluginData) TableName() string {
+	return "t_plugin_data"
+}
--- a/model/entity/robot.go
+++ b/model/entity/robot.go
@ -1,30 +0,0 @@
-package entity
-
-import "wechat-robot/pkg/types"
-
-// Robot
-// @description: 机器人信息
-type Robot struct {
-	types.BaseDbModel
-	WxId            string `json:"wxid" gorm:"index:deleted,unique;column:wxid;type:varchar(255);not null;comment:'微信Id'"` // 微信Id
-	Account         string `json:"account" gorm:"type:varchar(255);comment:'微信号'"`                                         // 微信号
-	Nickname        string `json:"name" gorm:"type:varchar(255);comment:'昵称'"`                                             // 昵称
-	Avatar          string `json:"avatar" gorm:"type:varchar(255);comment:'头像'"`                                           // 头像
-	Mobile          string `json:"mobile" gorm:"type:varchar(255);comment:'手机号'"`                                          // 手机
-	CurrentDataPath string `json:"currentDataPath" gorm:"type:varchar(255);comment:'当前数据目录'"`                              // 当前数据目录,登录的账号目录
-	DataSavePath    string `json:"dataSavePath" gorm:"type:varchar(255);comment:'微信保存目录'"`                                 // 微信保存目录
-	DbKey           string `json:"dbKey" gorm:"type:varchar(255);comment:'数据库的SQLCipher的加密key'"`                           // 数据库的SQLCipher的加密key，可以使用该key配合decrypt.py解密数据库
-	HookApi         string `json:"hookApi" gorm:"type:varchar(255);comment:'hook接口地址'"`                                    // hook接口地址
-	Remark          string `json:"remark" gorm:"type:varchar(255);comment:'备注'"`                                           // 备注
-	Version         int    `json:"version" gorm:"type:int;comment:'版本号'"`                                                  // 版本号
-	VncUrl          string `json:"vncUrl" gorm:"type:varchar(255);comment:'vnc地址'"`                                        // vnc地址
-	Tag             string `json:"tag" gorm:"type:varchar(255);comment:'标签'"`                                              // 标签
-}
-
-// TableName
-// @description: 表名
-// @receiver Robot
-// @return string
-func (Robot) TableName() string {
-	return "t_robot"
-}
--- a/Show More
+++ b/Show More