114 lines
3.9 KiB
Go
114 lines
3.9 KiB
Go
package main
|
|
|
|
import (
|
|
"log"
|
|
"net/http"
|
|
"time"
|
|
|
|
"github.com/gin-contrib/cors"
|
|
"github.com/gin-gonic/gin"
|
|
|
|
"mengyastore-backend/internal/auth"
|
|
"mengyastore-backend/internal/config"
|
|
"mengyastore-backend/internal/database"
|
|
"mengyastore-backend/internal/handlers"
|
|
"mengyastore-backend/internal/storage"
|
|
)
|
|
|
|
func main() {
|
|
cfg, err := config.Load("data/json/settings.json")
|
|
if err != nil {
|
|
log.Fatalf("load config failed: %v", err)
|
|
}
|
|
|
|
// Initialise database
|
|
db, err := database.Open(cfg.DatabaseDSN)
|
|
if err != nil {
|
|
log.Fatalf("init database failed: %v", err)
|
|
}
|
|
|
|
store, err := storage.NewJSONStore(db)
|
|
if err != nil {
|
|
log.Fatalf("init store failed: %v", err)
|
|
}
|
|
orderStore, err := storage.NewOrderStore(db)
|
|
if err != nil {
|
|
log.Fatalf("init order store failed: %v", err)
|
|
}
|
|
siteStore, err := storage.NewSiteStore(db)
|
|
if err != nil {
|
|
log.Fatalf("init site store failed: %v", err)
|
|
}
|
|
wishlistStore, err := storage.NewWishlistStore(db)
|
|
if err != nil {
|
|
log.Fatalf("init wishlist store failed: %v", err)
|
|
}
|
|
chatStore, err := storage.NewChatStore(db)
|
|
if err != nil {
|
|
log.Fatalf("init chat store failed: %v", err)
|
|
}
|
|
|
|
r := gin.Default()
|
|
r.Use(cors.New(cors.Config{
|
|
AllowOrigins: []string{"*"},
|
|
AllowMethods: []string{"GET", "POST", "PUT", "PATCH", "DELETE", "OPTIONS"},
|
|
AllowHeaders: []string{"Origin", "Content-Type", "Accept", "Authorization"},
|
|
ExposeHeaders: []string{"Content-Length"},
|
|
AllowCredentials: false,
|
|
MaxAge: 12 * time.Hour,
|
|
}))
|
|
|
|
r.GET("/api/health", func(c *gin.Context) {
|
|
c.JSON(http.StatusOK, gin.H{"status": "ok"})
|
|
})
|
|
|
|
authClient := auth.NewSproutGateClient(cfg.AuthAPIURL)
|
|
|
|
publicHandler := handlers.NewPublicHandler(store)
|
|
adminHandler := handlers.NewAdminHandler(store, cfg, siteStore, orderStore, chatStore)
|
|
orderHandler := handlers.NewOrderHandler(store, orderStore, siteStore, authClient)
|
|
statsHandler := handlers.NewStatsHandler(orderStore, siteStore)
|
|
wishlistHandler := handlers.NewWishlistHandler(wishlistStore, authClient)
|
|
chatHandler := handlers.NewChatHandler(chatStore, authClient)
|
|
|
|
r.GET("/api/products", publicHandler.ListProducts)
|
|
r.POST("/api/checkout", orderHandler.CreateOrder)
|
|
r.POST("/api/products/:id/view", publicHandler.RecordProductView)
|
|
r.GET("/api/stats", statsHandler.GetStats)
|
|
r.POST("/api/site/visit", statsHandler.RecordVisit)
|
|
r.GET("/api/site/maintenance", statsHandler.GetMaintenance)
|
|
r.GET("/api/orders", orderHandler.ListMyOrders)
|
|
r.POST("/api/orders/:id/confirm", orderHandler.ConfirmOrder)
|
|
|
|
r.GET("/api/admin/token", adminHandler.GetAdminToken)
|
|
r.GET("/api/admin/products", adminHandler.ListAllProducts)
|
|
r.POST("/api/admin/products", adminHandler.CreateProduct)
|
|
r.PUT("/api/admin/products/:id", adminHandler.UpdateProduct)
|
|
r.PATCH("/api/admin/products/:id/status", adminHandler.ToggleProduct)
|
|
r.DELETE("/api/admin/products/:id", adminHandler.DeleteProduct)
|
|
r.POST("/api/admin/site/maintenance", adminHandler.SetMaintenance)
|
|
r.GET("/api/admin/site/smtp", adminHandler.GetSMTPConfig)
|
|
r.POST("/api/admin/site/smtp", adminHandler.SetSMTPConfig)
|
|
r.GET("/api/admin/orders", adminHandler.ListAllOrders)
|
|
r.DELETE("/api/admin/orders/:id", adminHandler.DeleteOrder)
|
|
|
|
r.GET("/api/wishlist", wishlistHandler.GetWishlist)
|
|
r.POST("/api/wishlist", wishlistHandler.AddToWishlist)
|
|
r.DELETE("/api/wishlist/:id", wishlistHandler.RemoveFromWishlist)
|
|
|
|
// Chat routes (user)
|
|
r.GET("/api/chat/messages", chatHandler.GetMyMessages)
|
|
r.POST("/api/chat/messages", chatHandler.SendMyMessage)
|
|
|
|
// Chat routes (admin)
|
|
r.GET("/api/admin/chat", adminHandler.GetAllConversations)
|
|
r.GET("/api/admin/chat/:account", adminHandler.GetConversation)
|
|
r.POST("/api/admin/chat/:account", adminHandler.AdminReply)
|
|
r.DELETE("/api/admin/chat/:account", adminHandler.ClearConversation)
|
|
|
|
log.Println("萌芽小店后端启动于 http://localhost:8080")
|
|
if err := r.Run(":8080"); err != nil {
|
|
log.Fatalf("server run failed: %v", err)
|
|
}
|
|
}
|