Merge pull request #34 from idoknow/version/1.0.0

Release: 1.0.0

.gitignore

@@ -51,4 +51,5 @@ pnpm-debug.log*
 *.sln
 *.sw?
 frontend/package-lock.json
-dist/
+dist/
+/data/

Dockerfile

@@ -5,7 +5,7 @@ WORKDIR /app
 COPY bin/campux /app/campux
 COPY frontend/dist /app/frontend/dist
 
-EXPOSE 8080
+EXPOSE 8081
 
 ENV GIN_MODE=release
 

backend/config/config.go

@@ -9,9 +9,11 @@ import (
 type Config struct {
 }
 
-func SetDefault() {
+// 设置初始值
+// 仅在配置文件不存在时调用
+func SetInitValue() {
 	viper.SetDefault("backend.host", "0.0.0.0")
-	viper.SetDefault("backend.port", "8080")
+	viper.SetDefault("backend.port", "8081")
 
 	// jwt
 	viper.SetDefault("auth.jwt.secret", uuid.New().String())
@@ -23,13 +25,23 @@ func SetDefault() {
 	viper.SetDefault("oauth2.server.ak_expire", 3600*24*14)
 
 	// 服务token
-	viper.SetDefault("service.token", "campux")
+	viper.SetDefault("service.token", "campux123456")
 	viper.SetDefault("service.bots", []int64{123456789})
+	viper.SetDefault("service.domain", "campux")
 
 	// 数据库
+	viper.SetDefault("database.use", "sqlite")
+
+	viper.SetDefault("database.sqlite.path", "./data/campux.db")
+
 	viper.SetDefault("database.mongo.uri", "mongodb://localhost:27017")
 	viper.SetDefault("database.mongo.db", "campux")
 
+	viper.SetDefault("oss.use", "local")
+
+	// local
+	viper.SetDefault("oss.local.dir", "./data/objects")
+
 	// minio
 	viper.SetDefault("oss.minio.endpoint", "localhost:9000")
 	viper.SetDefault("oss.minio.access_key", "minio")
@@ -38,17 +50,16 @@ func SetDefault() {
 	viper.SetDefault("oss.minio.use_ssl", false)
 
 	// redis
-	viper.SetDefault("mq.redis.addr", "localhost:6379")
-	viper.SetDefault("mq.redis.password", "")
+	viper.SetDefault("mq.redis.addr", "campux-redis:6379")
+	viper.SetDefault("mq.redis.password", "campux123456")
 	viper.SetDefault("mq.redis.db", 0)
-	viper.SetDefault("mq.redis.stream.publish_post", "campux_publish_post")
-	viper.SetDefault("mq.redis.stream.new_post", "campux_new_post")
-	viper.SetDefault("mq.redis.stream.post_cancel", "campux_post_cancel")
-	viper.SetDefault("mq.redis.hash.post_publish_status", "campux_post_publish_status")
-	viper.SetDefault("mq.redis.prefix.oauth2_code", "campux_oauth2_code")
 
 }
 
+func WriteConfig() error {
+	return viper.WriteConfigAs("./data/campux.yaml")
+}
+
 // 创建配置文件对象
 // 返回值1：配置文件对象
 // 返回值2：是否新建配置文件
@@ -59,13 +70,12 @@ func NewConfig() (*Config, bool, error) {
 	viper.SetConfigType("yaml")
 	viper.AddConfigPath("./data/")
 
-	// 设置默认配置
-	SetDefault()
-
 	if err := viper.ReadInConfig(); err != nil {
 		if _, ok := err.(viper.ConfigFileNotFoundError); ok {
+			// 设置默认配置
+			SetInitValue()
 			// Config file not found; write default config
-			if err := viper.WriteConfigAs("./data/campux.yaml"); err != nil {
+			if err := WriteConfig(); err != nil {
 				return nil, false, err
 			}
 			return nil, true, nil

backend/controller/admapi.go

@@ -8,12 +8,14 @@ import (
 
 type AdminRouter struct {
 	APIRouter
-	AdminService service.AdminService
+	AdminService   service.AdminService
+	AccountService service.AccountService
 }
 
-func NewAdminRouter(rg *gin.RouterGroup, as service.AdminService) *AdminRouter {
+func NewAdminRouter(rg *gin.RouterGroup, as service.AdminService, acs service.AccountService) *AdminRouter {
 	ar := &AdminRouter{
-		AdminService: as,
+		AdminService:   as,
+		AccountService: acs,
 	}
 
 	group := rg.Group("/admin")
@@ -22,6 +24,8 @@ func NewAdminRouter(rg *gin.RouterGroup, as service.AdminService) *AdminRouter {
 	group.POST("/add-oauth2-app", ar.AddOAuth2App)
 	group.GET("/get-oauth2-apps", ar.GetOAuth2AppList)
 	group.DELETE("/del-oauth2-app/:id", ar.DeleteOAuth2App)
+	group.GET("/init", ar.IsInit)
+	group.POST("/init", ar.Init)
 
 	return ar
 }
@@ -117,3 +121,56 @@ func (ar *AdminRouter) DeleteOAuth2App(c *gin.Context) {
 
 	ar.Success(c, nil)
 }
+
+// 检查是否初始化
+func (ar *AdminRouter) IsInit(c *gin.Context) {
+	// 检查是否初始化
+	init, err := ar.AdminService.IsInit()
+
+	if err != nil {
+		ar.Fail(c, 1, err.Error())
+		return
+	}
+
+	ar.Success(c, gin.H{
+		"initialized": init,
+	})
+}
+
+// 初始化
+func (ar *AdminRouter) Init(c *gin.Context) {
+	// 检查是否初始化
+	init, err := ar.AdminService.IsInit()
+
+	if err != nil {
+		ar.Fail(c, 1, err.Error())
+		return
+	}
+
+	if init {
+		ar.Fail(c, 2, "系统已有管理员账户")
+		return
+	}
+
+	// 取body的json里的appname
+	var body InitBody
+
+	if err := c.ShouldBindJSON(&body); err != nil {
+		ar.Fail(c, 3, err.Error())
+		return
+	}
+
+	// 创建管理员账户
+	err = ar.AccountService.AddAccount(
+		body.AdminUin,
+		body.AdminPasswd,
+		database.USER_GROUP_ADMIN,
+	)
+
+	if err != nil {
+		ar.Fail(c, 4, err.Error())
+		return
+	}
+
+	ar.Success(c, nil)
+}

backend/controller/api.go

@@ -32,7 +32,9 @@ func NewApiController(
 				cors.Config{
 					AllowOrigins: []string{
 						"http://localhost:3000",
+						"http://localhost:3001",
 						"http://127.0.0.1:3000",
+						"http://127.0.0.1:3001",
 					},
 					AllowMethods:     []string{"GET", "POST", "PUT", "DELETE", "OPTIONS", "HEAD"},
 					AllowHeaders:     []string{"Origin", "Content-Length", "Content-Type", "Authorization", "Cookie"},
@@ -65,7 +67,7 @@ func NewApiController(
 	NewAccountRouter(rg, as)
 	NewPostRouter(rg, ps, as)
 	NewMiscRouter(rg, ms)
-	NewAdminRouter(rg, ads)
+	NewAdminRouter(rg, ads, as)
 	NewOAuth2Router(rg, oas)
 
 	return &APIController{

backend/controller/dto.go

@@ -175,3 +175,24 @@ type OAuth2GetAccessTokenBody struct {
 	// 授权码
 	Code string `json:"code" binding:"required"`
 }
+
+type SetMetadataBody struct {
+	// 键
+	Key string `json:"key" binding:"required"`
+
+	// 值
+	Value string `json:"value" binding:"required"`
+}
+
+type SaveMetadataBody struct {
+	// 元数据列表
+	MetadataList []database.Metadata `json:"list" binding:"required"`
+}
+
+type InitBody struct {
+	// 管理员uin
+	AdminUin int64 `json:"admin_uin" binding:"required"`
+
+	// 管理员密码
+	AdminPasswd string `json:"admin_passwd" binding:"required"`
+}

backend/controller/miscapi.go

@@ -1,6 +1,7 @@
 package controller
 
 import (
+	"github.com/RockChinQ/Campux/backend/database"
 	"github.com/RockChinQ/Campux/backend/service"
 	"github.com/gin-gonic/gin"
 )
@@ -19,6 +20,9 @@ func NewMiscRouter(rg *gin.RouterGroup, ms service.MiscService) *MiscRouter {
 
 	// bind routes
 	group.GET("/get-metadata", mr.GetMetadata)
+	group.PUT("/set-metadata", mr.SetMetadata)
+	group.GET("/get-metadata-list", mr.GetMetadataList)
+	group.PUT("/save-metadatas", mr.SaveMetadata)
 
 	return mr
 }
@@ -43,3 +47,102 @@ func (mr *MiscRouter) GetMetadata(c *gin.Context) {
 		"value": value,
 	})
 }
+
+// 设置元数据
+func (mr *MiscRouter) SetMetadata(c *gin.Context) {
+	uin, err := mr.Auth(c, Both)
+
+	if err != nil {
+		return
+	}
+
+	// 检查用户权限
+	if !mr.MiscService.CheckUserGroup(uin, []database.UserGroup{
+		database.USER_GROUP_ADMIN,
+		database.USER_GROUP_MEMBER,
+	}) {
+		mr.StatusCode(c, 401, "权限不足")
+		return
+	}
+
+	var body SetMetadataBody
+
+	if err := c.ShouldBindJSON(&body); err != nil {
+		mr.Fail(c, 1, err.Error())
+		return
+	}
+
+	key := body.Key
+	value := body.Value
+
+	err = mr.MiscService.SetMetadata(key, value)
+
+	if err != nil {
+		mr.Fail(c, 1, err.Error())
+		return
+	}
+
+	mr.Success(c, nil)
+}
+
+// 获取元数据列表
+func (mr *MiscRouter) GetMetadataList(c *gin.Context) {
+	uin, err := mr.Auth(c, Both)
+
+	if err != nil {
+		return
+	}
+
+	// 检查用户权限
+	if !mr.MiscService.CheckUserGroup(uin, []database.UserGroup{
+		database.USER_GROUP_ADMIN,
+		database.USER_GROUP_MEMBER,
+	}) {
+		mr.StatusCode(c, 401, "权限不足")
+		return
+	}
+
+	list, err := mr.MiscService.GetMetadataList()
+
+	if err != nil {
+		mr.Fail(c, 1, err.Error())
+		return
+	}
+
+	mr.Success(c, gin.H{
+		"list": list,
+	})
+}
+
+// 保存元数据
+func (mr *MiscRouter) SaveMetadata(c *gin.Context) {
+	uin, err := mr.Auth(c, Both)
+
+	if err != nil {
+		return
+	}
+
+	// 检查用户权限
+	if !mr.MiscService.CheckUserGroup(uin, []database.UserGroup{
+		database.USER_GROUP_ADMIN,
+	}) {
+		mr.StatusCode(c, 401, "权限不足")
+		return
+	}
+
+	var body SaveMetadataBody
+
+	if err := c.ShouldBindJSON(&body); err != nil {
+		mr.Fail(c, 1, err.Error())
+		return
+	}
+
+	err = mr.MiscService.SaveMetadata(body.MetadataList)
+
+	if err != nil {
+		mr.Fail(c, 1, err.Error())
+		return
+	}
+
+	mr.Success(c, nil)
+}