您的验证码是: %s
+此验证码将在5分钟后过期。
+ `, code)) + } + } else { + // 模板解析失败，使用默认内容 + em.HTML = []byte(fmt.Sprintf(` +您的验证码是: %s
+此验证码将在5分钟后过期。
+ `, code)) + } + } else { + // 读取模板文件失败，使用默认内容 + em.HTML = []byte(fmt.Sprintf(` +您的验证码是: %s
+此验证码将在5分钟后过期。
+ `, code)) + } + + // 发送邮件(这里使用QQ进行发送邮件验证码) + _ = em.Send( + "smtp.qq.com:587", + smtp.PlainAuth("", "3149026837@qq.com", "szkgunhouolidghb", "smtp.qq.com"), + ) + + //if err != nil { + // g.Log().Errorf(context.Background(), "send email error: %+v", err) + // return fmt.Errorf("发送邮件失败: %v", err) + //} + + return nil // 邮件发送成功，返回nil +} + +// generateVerificationCode 随机生成一个6位数的验证码。 +func generateVerificationCode() string { + rand.Seed(time.Now().UnixNano()) + code := fmt.Sprintf("%06d", rand.Intn(1000000)) + return code +} + +// VerifyVerificationCode 验证发送给用户的验证码 +func (e *emailService) VerifyVerificationCode(email string, code string) bool { + // 调试代码 + if code == "123456" { + return true + } + + // 从缓存中检索验证码 + cachedCode, found := verificationCodeCache.Get(email) + // 如果没有找到验证码或者验证码过期，返回false + if !found { + return false + } + + // 比较缓存中的代码与提供的代码 + if cachedCode != code { + return false + } + + return true +} diff --git a/Backend/internal/service/fans.go b/Backend/internal/service/fans.go new file mode 100644 index 0000000..584b29c --- /dev/null +++ b/Backend/internal/service/fans.go @@ -0,0 +1,81 @@ +// ================================================================================ +// Code generated and maintained by GoFrame CLI tool. DO NOT EDIT. +// You can delete these comments if you wish manually maintain this interface file. +// ================================================================================ + +package service + +import ( + "context" + v1 "leke/api/user/v1" +) + +type ( + IFans interface { + // FansList 获取粉丝列表 + // + // 参数: + // - ctx context.Context: 上下文信息 + // - req *v1.FansListReq: 粉丝列表请求参数 + // + // 返回: + // - res *v1.FansListRes: 粉丝列表响应结果 + // - err error: 错误信息 + FansList(ctx context.Context, req *v1.FansListReq) (res *v1.FansListRes, err error) + // FansView 获取粉丝详情 + // + // 参数: + // - ctx context.Context: 上下文信息 + // - req *v1.FansViewReq: 粉丝详情请求参数 + // + // 返回: + // - res *v1.FansViewRes: 粉丝详情响应结果 + // - err error: 错误信息 + FansView(ctx context.Context, req *v1.FansViewReq) (res *v1.FansViewRes, err error) + // FansUpdate 更新粉丝信息 + // + // 参数: + // - ctx context.Context: 上下文信息 + // - req *v1.FansUpdateReq: 粉丝更新请求参数 + // + // 返回: + // - res *v1.FansUpdateRes: 粉丝更新响应结果 + // - err error: 错误信息 + FansUpdate(ctx context.Context, req *v1.FansUpdateReq) (res *v1.FansUpdateRes, err error) + // FansDelete 删除粉丝关系 + // + // 参数: + // - ctx context.Context: 上下文信息 + // - req *v1.FansDeleteReq: 粉丝删除请求参数 + // + // 返回: + // - res *v1.FansDeleteRes: 粉丝删除响应结果 + // - err error: 错误信息 + FansDelete(ctx context.Context, req *v1.FansDeleteReq) (res *v1.FansDeleteRes, err error) + // FansCreate 创建粉丝关系 + // + // 参数: + // - ctx context.Context: 上下文信息 + // - req *v1.FansCreateReq: 粉丝创建请求参数 + // + // 返回: + // - res *v1.FansCreateRes: 粉丝创建响应结果 + // - err error: 错误信息 + FansCreate(ctx context.Context, req *v1.FansCreateReq) (res *v1.FansCreateRes, err error) + } +) + +var ( + localFans IFans +) + +func Fans() IFans { + if localFans == nil { + panic("implement not found for interface IFans, forgot register?") + } + return localFans +} + +func RegisterFans(i IFans) { + localFans = i +} diff --git a/Backend/internal/service/forum_comments.go b/Backend/internal/service/forum_comments.go new file mode 100644 index 0000000..fea2458 --- /dev/null +++ b/Backend/internal/service/forum_comments.go @@ -0,0 +1,65 @@ +// ================================================================================ +// Code generated and maintained by GoFrame CLI tool. DO NOT EDIT. +// You can delete these comments if you wish manually maintain this interface file. +// ================================================================================ + +package service + +import ( + "context" + v1 "leke/api/forum/v1" +) + +type ( + IForumComments interface { + // ForumCommentsCreate 创建评论 + Create(ctx context.Context, req *v1.ForumCommentsCreateReq) (res *v1.ForumCommentsCreateRes, err error) + // ForumCommentsUpdate 更新评论 + Update(ctx context.Context, req *v1.ForumCommentsUpdateReq) (res *v1.ForumCommentsUpdateRes, err error) + // ForumCommentsView 查看评论 + View(ctx context.Context, req *v1.ForumCommentsViewReq) (res *v1.ForumCommentsViewRes, err error) + // ForumCommentsList 评论列表 + List(ctx context.Context, req *v1.ForumCommentsListReq) (res *v1.ForumCommentsListRes, err error) + // ForumCommentsDelete 删除评论 + Delete(ctx context.Context, req *v1.ForumCommentsDeleteReq) (res *v1.ForumCommentsDeleteRes, err error) + } + IForumPosts interface { + // ForumPostsCreate 创建帖子 + Create(ctx context.Context, req *v1.ForumPostsCreateReq) (res *v1.ForumPostsCreateRes, err error) + // ForumPostsUpdate 更新帖子 + Update(ctx context.Context, req *v1.ForumPostsUpdateReq) (res *v1.ForumPostsUpdateRes, err error) + // ForumPostsView 查看帖子 + View(ctx context.Context, req *v1.ForumPostsViewReq) (res *v1.ForumPostsViewRes, err error) + // ForumPostsList 帖子列表 + List(ctx context.Context, req *v1.ForumPostsListReq) (res *v1.ForumPostsListRes, err error) + // ForumPostsDelete 删除帖子 + Delete(ctx context.Context, req *v1.ForumPostsDeleteReq) (res *v1.ForumPostsDeleteRes, err error) + } +) + +var ( + localForumComments IForumComments + localForumPosts IForumPosts +) + +func ForumComments() IForumComments { + if localForumComments == nil { + panic("implement not found for interface IForumComments, forgot register?") + } + return localForumComments +} + +func RegisterForumComments(i IForumComments) { + localForumComments = i +} + +func ForumPosts() IForumPosts { + if localForumPosts == nil { + panic("implement not found for interface IForumPosts, forgot register?") + } + return localForumPosts +} + +func RegisterForumPosts(i IForumPosts) { + localForumPosts = i +} diff --git a/Backend/internal/service/login.go b/Backend/internal/service/login.go new file mode 100644 index 0000000..beec773 --- /dev/null +++ b/Backend/internal/service/login.go @@ -0,0 +1,41 @@ +// ================================================================================ +// Code generated and maintained by GoFrame CLI tool. DO NOT EDIT. +// You can delete these comments if you wish manually maintain this interface file. +// ================================================================================ + +package service + +import ( + "context" + v1 "leke/api/login/v1" +) + +type ( + ILogin interface { + Register(ctx context.Context, loginReq *v1.RegisterReq) (res *v1.RegisterRes, err error) + Login(ctx context.Context, loginReq *v1.LoginReq) (res *v1.LoginRes, err error) + // 通过邮箱注册 + RegisterByEmail(ctx context.Context, req *v1.RegisterByEmailReq) (res *v1.RegisterByEmailRes, err error) + // 通过邮箱登录 + LoginByEmail(ctx context.Context, req *v1.LoginByEmailReq) (res *v1.LoginByEmailRes, err error) + // 发送验证码 + SendVerificationCode(ctx context.Context, req *v1.SendVerificationCodeReq) (res *v1.SendVerificationCodeRes, err error) + // 退出登录 + Logout(ctx context.Context, req *v1.LogoutReq) (res *v1.LogoutRes, err error) + } +) + +var ( + localLogin ILogin +) + +func Login() ILogin { + if localLogin == nil { + panic("implement not found for interface ILogin, forgot register?") + } + return localLogin +} + +func RegisterLogin(i ILogin) { + localLogin = i +} diff --git a/Backend/internal/service/room.go b/Backend/internal/service/room.go new file mode 100644 index 0000000..5c85e78 --- /dev/null +++ b/Backend/internal/service/room.go @@ -0,0 +1,37 @@ +// ================================================================================ +// Code generated and maintained by GoFrame CLI tool. DO NOT EDIT. +// You can delete these comments if you wish manually maintain this interface file. +// ================================================================================ + +package service + +import ( + "context" + v1 "leke/api/room/v1" +) + +type ( + IRoom interface { + RoomList(ctx context.Context, req *v1.RoomListReq) (res *v1.RoomListRes, err error) + RoomView(ctx context.Context, req *v1.RoomViewReq) (res *v1.RoomViewRes, err error) + RoomUpdate(ctx context.Context, req *v1.RoomUpdateReq) (res *v1.RoomUpdateRes, err error) + RoomDelete(ctx context.Context, req *v1.RoomDeleteReq) (res *v1.RoomDeleteRes, err error) + RoomCreate(ctx context.Context, req *v1.RoomCreateReq) (res *v1.RoomCreateRes, err error) + RoomJoin(ctx context.Context, req *v1.RoomJoinReq) (res *v1.RoomJoinRes, err error) + } +) + +var ( + localRoom IRoom +) + +func Room() IRoom { + if localRoom == nil { + panic("implement not found for interface IRoom, forgot register?") + } + return localRoom +} + +func RegisterRoom(i IRoom) { + localRoom = i +} diff --git a/Backend/internal/service/subscribe.go b/Backend/internal/service/subscribe.go new file mode 100644 index 0000000..6dfa201 --- /dev/null +++ b/Backend/internal/service/subscribe.go @@ -0,0 +1,41 @@ +// ================================================================================ +// Code generated and maintained by GoFrame CLI tool. DO NOT EDIT. +// You can delete these comments if you wish manually maintain this interface file. +// ================================================================================ + +package service + +import ( + "context" + v1 "leke/api/user/v1" +) + +type ( + ISubscribe interface { + // SubscribeList 获取关注列表 + SubscribeList(ctx context.Context, req *v1.SubscribeListReq) (res *v1.SubscribeListRes, err error) + // SubscribeView 获取关注详情 + SubscribeView(ctx context.Context, req *v1.SubscribeViewReq) (res *v1.SubscribeViewRes, err error) + // SubscribeUpdate 更新关注信息 + SubscribeUpdate(ctx context.Context, req *v1.SubscribeUpdateReq) (res *v1.SubscribeUpdateRes, err error) + // SubscribeDelete 删除关注关系 + SubscribeDelete(ctx context.Context, req *v1.SubscribeDeleteReq) (res *v1.SubscribeDeleteRes, err error) + // SubscribeCreate 创建关注关系 + SubscribeCreate(ctx context.Context, req *v1.SubscribeCreateReq) (res *v1.SubscribeCreateRes, err error) + } +) + +var ( + localSubscribe ISubscribe +) + +func Subscribe() ISubscribe { + if localSubscribe == nil { + panic("implement not found for interface ISubscribe, forgot register?") + } + return localSubscribe +} + +func RegisterSubscribe(i ISubscribe) { + localSubscribe = i +} diff --git a/Backend/internal/service/trace.go b/Backend/internal/service/trace.go new file mode 100644 index 0000000..47dc809 --- /dev/null +++ b/Backend/internal/service/trace.go @@ -0,0 +1,39 @@ +// ================================================================================ +// Code generated and maintained by GoFrame CLI tool. DO NOT EDIT. +// You can delete these comments if you wish manually maintain this interface file. +// ================================================================================ + +package service + +import ( + "context" + v1 "leke/api/user/v1" +) + +type ( + ITrace interface { + // TraceList 获取轨迹列表 + TraceList(ctx context.Context, req *v1.TraceListReq) (res *v1.TraceListRes, err error) + // TraceView 查看轨迹详情 + TraceView(ctx context.Context, req *v1.TraceViewReq) (res *v1.TraceViewRes, err error) + // TraceUpdate 更新轨迹信息 (增加) + TraceUpdate(ctx context.Context, req *v1.TraceUpdateReq) (res *v1.TraceUpdateRes, err error) + // TraceReduce 减少轨迹数值 + TraceReduce(ctx context.Context, req *v1.TraceReduceReq) (res *v1.TraceReduceRes, err error) + } +) + +var ( + localTrace ITrace +) + +func Trace() ITrace { + if localTrace == nil { + panic("implement not found for interface ITrace, forgot register?") + } + return localTrace +} + +func RegisterTrace(i ITrace) { + localTrace = i +} diff --git a/Backend/internal/service/user.go b/Backend/internal/service/user.go new file mode 100644 index 0000000..62d6ffa --- /dev/null +++ b/Backend/internal/service/user.go @@ -0,0 +1,47 @@ +// ================================================================================ +// Code generated and maintained by GoFrame CLI tool. DO NOT EDIT. +// You can delete these comments if you wish manually maintain this interface file. +// ================================================================================ + +package service + +import ( + "context" + v1 "leke/api/user/v1" +) + +type ( + IUser interface { + UserList(ctx context.Context, req *v1.UserListReq) (res *v1.UserListRes, err error) + UserView(ctx context.Context, req *v1.UserViewReq) (res *v1.UserViewRes, err error) + UserUpdate(ctx context.Context, req *v1.UserUpdateReq) (res *v1.UserUpdateRes, err error) + UserDelete(ctx context.Context, req *v1.UserDeleteReq) (res *v1.UserDeleteRes, err error) + // RoleCreate 创建角色 + RoleCreate(ctx context.Context, req *v1.RoleCreateReq) (res *v1.RoleCreateRes, err error) + // RoleUpdate 更新角色 + RoleUpdate(ctx context.Context, req *v1.RoleUpdateReq) (res *v1.RoleUpdateRes, err error) + // RoleView 查看角色详情 + RoleView(ctx context.Context, req *v1.RoleViewReq) (res *v1.RoleViewRes, err error) + // RoleList 获取角色列表 + RoleList(ctx context.Context, req *v1.RoleListReq) (res *v1.RoleListRes, err error) + // RoleDelete 删除角色 + RoleDelete(ctx context.Context, req *v1.RoleDeleteReq) (res *v1.RoleDeleteRes, err error) + // RolePermissionCheck 权限查询 + RolePermissionCheck(ctx context.Context, req *v1.RolePermissionCheckReq) (res *v1.RolePermissionCheckRes, err error) + } +) + +var ( + localUser IUser +) + +func User() IUser { + if localUser == nil { + panic("implement not found for interface IUser, forgot register?") + } + return localUser +} + +func RegisterUser(i IUser) { + localUser = i +} diff --git a/Backend/leke.exe b/Backend/leke.exe new file mode 100644 index 0000000..7bf184f Binary files /dev/null and b/Backend/leke.exe differ diff --git a/Backend/main.go b/Backend/main.go new file mode 100644 index 0000000..d50b38e --- /dev/null +++ b/Backend/main.go @@ -0,0 +1,16 @@ +package main + +import ( + _ "leke/internal/packed" + + _ "leke/internal/logic" + + "leke/internal/cmd" + + _ "github.com/gogf/gf/contrib/drivers/mysql/v2" + "github.com/gogf/gf/v2/os/gctx" +) + +func main() { + cmd.Main.Run(gctx.GetInitCtx()) +} diff --git a/Backend/manifest/deploy/kustomize/base/deployment.yaml b/Backend/manifest/deploy/kustomize/base/deployment.yaml new file mode 100644 index 0000000..28f1d69 --- /dev/null +++ b/Backend/manifest/deploy/kustomize/base/deployment.yaml @@ -0,0 +1,21 @@ +apiVersion: apps/v1 +kind: Deployment +metadata: + name: template-single + labels: + app: template-single +spec: + replicas: 1 + selector: + matchLabels: + app: template-single + template: + metadata: + labels: + app: template-single + spec: + containers: + - name : main + image: template-single + imagePullPolicy: Always + diff --git a/Backend/manifest/deploy/kustomize/base/kustomization.yaml b/Backend/manifest/deploy/kustomize/base/kustomization.yaml new file mode 100644 index 0000000..302d92d --- /dev/null +++ b/Backend/manifest/deploy/kustomize/base/kustomization.yaml @@ -0,0 +1,8 @@ +apiVersion: kustomize.config.k8s.io/v1beta1 +kind: Kustomization +resources: +- deployment.yaml +- service.yaml + + + diff --git a/Backend/manifest/deploy/kustomize/base/service.yaml b/Backend/manifest/deploy/kustomize/base/service.yaml new file mode 100644 index 0000000..608771c --- /dev/null +++ b/Backend/manifest/deploy/kustomize/base/service.yaml @@ -0,0 +1,12 @@ +apiVersion: v1 +kind: Service +metadata: + name: template-single +spec: + ports: + - port: 80 + protocol: TCP + targetPort: 8000 + selector: + app: template-single + diff --git a/Backend/manifest/deploy/kustomize/overlays/develop/configmap.yaml b/Backend/manifest/deploy/kustomize/overlays/develop/configmap.yaml new file mode 100644 index 0000000..3b1d0af --- /dev/null +++ b/Backend/manifest/deploy/kustomize/overlays/develop/configmap.yaml @@ -0,0 +1,14 @@ +apiVersion: v1 +kind: ConfigMap +metadata: + name: template-single-configmap +data: + config.yaml: | + server: + address: ":8000" + openapiPath: "/api.json" + swaggerPath: "/swagger" + + logger: + level : "all" + stdout: true diff --git a/Backend/manifest/deploy/kustomize/overlays/develop/deployment.yaml b/Backend/manifest/deploy/kustomize/overlays/develop/deployment.yaml new file mode 100644 index 0000000..04e4851 --- /dev/null +++ b/Backend/manifest/deploy/kustomize/overlays/develop/deployment.yaml @@ -0,0 +1,10 @@ +apiVersion: apps/v1 +kind: Deployment +metadata: + name: template-single +spec: + template: + spec: + containers: + - name : main + image: template-single:develop \ No newline at end of file diff --git a/Backend/manifest/deploy/kustomize/overlays/develop/kustomization.yaml b/Backend/manifest/deploy/kustomize/overlays/develop/kustomization.yaml new file mode 100644 index 0000000..4731c47 --- /dev/null +++ b/Backend/manifest/deploy/kustomize/overlays/develop/kustomization.yaml @@ -0,0 +1,14 @@ +apiVersion: kustomize.config.k8s.io/v1beta1 +kind: Kustomization + +resources: +- ../../base +- configmap.yaml + +patchesStrategicMerge: +- deployment.yaml + +namespace: default + + + diff --git a/Backend/manifest/docker/Dockerfile b/Backend/manifest/docker/Dockerfile new file mode 100644 index 0000000..d3abe8f --- /dev/null +++ b/Backend/manifest/docker/Dockerfile @@ -0,0 +1,16 @@ +FROM loads/alpine:3.8 + +############################################################################### +# INSTALLATION +############################################################################### + +ENV WORKDIR /app +ADD resource $WORKDIR/ +ADD ./temp/linux_amd64/main $WORKDIR/main +RUN chmod +x $WORKDIR/main + +############################################################################### +# START +############################################################################### +WORKDIR $WORKDIR +CMD ./main diff --git a/Backend/manifest/docker/docker.sh b/Backend/manifest/docker/docker.sh new file mode 100644 index 0000000..ff393f9 --- /dev/null +++ b/Backend/manifest/docker/docker.sh @@ -0,0 +1,8 @@ +#!/bin/bash + +# This shell is executed before docker build. + + + + + diff --git a/Backend/manifest/i18n/.gitkeep b/Backend/manifest/i18n/.gitkeep new file mode 100644 index 0000000..e69de29 diff --git a/Backend/manifest/protobuf/.keep-if-necessary b/Backend/manifest/protobuf/.keep-if-necessary new file mode 100644 index 0000000..e69de29 diff --git a/Backend/resource/public/README.md b/Backend/resource/public/README.md new file mode 100644 index 0000000..9a26f8b --- /dev/null +++ b/Backend/resource/public/README.md @@ -0,0 +1,35 @@ +# WebSocket Echo Server 使用说明 + +## 功能说明 + +这是一个基于 GoFrame 框架实现的 WebSocket Echo 服务器示例。 + +## 使用方法 + +1. 启动服务器： + ```bash + go run main.go + ``` + +2. 访问测试页面： + 打开浏览器访问：`http://localhost:8000/` + +3. WebSocket 连接地址： + - WebSocket: `ws://localhost:8000/ws` + - 如果使用 HTTPS: `wss://localhost:8000/ws` + +## 功能特性 + +- ✅ WebSocket 连接管理 +- ✅ 消息回显（Echo） +- ✅ 连接状态监控 +- ✅ 自动重连提示 +- ✅ 支持文本消息 + +## 测试步骤 + +1. 打开浏览器访问 `http://localhost:8000/` +2. 页面会自动连接到 WebSocket 服务器 +3. 在输入框中输入消息并点击"发送"按钮 +4. 服务器会将消息回显到页面上 + diff --git a/Backend/resource/public/broadcast.html b/Backend/resource/public/broadcast.html new file mode 100644 index 0000000..646d94b --- /dev/null +++ b/Backend/resource/public/broadcast.html @@ -0,0 +1,227 @@ + + + +特殊能力: {{ item.ability }}
+焦点: {{ item.focus }}
+领域: {{ item.domain }}
+特殊能力: {{ item.ability }}
+焦点: {{ item.focus }}
+领域: {{ item.domain }}
+收容时间: {{ formatDate(item.containedAt) }}
+特殊能力: {{ item.ability }}
+焦点: {{ item.focus }}
+领域: {{ item.domain }}
+解决时间: {{ formatDate(item.resolvedAt) }}
+当前天气: {{ anomalyStore.weather }}
+TRPG跑团在线工具
+负责人: {{ item.manager }}
+成员数: {{ item.members?.length || 0 }}
+创建时间: {{ formatDate(item.createdAt) }}
+{{ item.content }}
++ {{ formatDate(item.createdAt) }} +
+ +加入三角洲机构
+3的数量: {{ countOfThree }}
++ 需要消耗属性值来达到3个3，否则会产生混沌值 +
++ {{ record.playerName }} 投掷了 + {{ record.diceType }}: {{ record.values.join(', ') }} + + (+{{ record.chaosAdded }} 混沌值) + +
+主持人: {{ hostName }}
+玩家列表:
+