feat: add Member service, points, and Kasir Name tracking

controllers/member_controller.go

@@ -0,0 +1,160 @@
+package controllers
+
+import (
+	"net/http"
+	"service-warungpos-go/config"
+	"service-warungpos-go/models"
+
+	"github.com/gin-gonic/gin"
+)
+
+// ListMembers (GET /api/members)
+func ListMembers(c *gin.Context) {
+	companyIDRaw, exists := c.Get("company_id")
+	if !exists {
+		c.JSON(http.StatusUnauthorized, gin.H{"detail": "Unauthorized"})
+		return
+	}
+	companyID := companyIDRaw.(uint)
+
+	var members []models.Member
+	if err := config.DB.Where("company_id = ?", companyID).Order("created_at desc").Find(&members).Error; err != nil {
+		c.JSON(http.StatusInternalServerError, gin.H{"detail": "Gagal mengambil data member"})
+		return
+	}
+
+	c.JSON(http.StatusOK, members)
+}
+
+// CreateMember (POST /api/members)
+func CreateMember(c *gin.Context) {
+	companyIDRaw, exists := c.Get("company_id")
+	if !exists {
+		c.JSON(http.StatusUnauthorized, gin.H{"detail": "Unauthorized"})
+		return
+	}
+	companyID := companyIDRaw.(uint)
+
+	var input struct {
+		MemberID string `json:"member_id" binding:"required"`
+		Name     string `json:"name" binding:"required"`
+		Phone    string `json:"phone"`
+	}
+
+	if err := c.ShouldBindJSON(&input); err != nil {
+		c.JSON(http.StatusBadRequest, gin.H{"detail": "Data tidak valid", "error": err.Error()})
+		return
+	}
+
+	// Cek apakah member_id sudah dipakai di company ini
+	var existing models.Member
+	if err := config.DB.Where("company_id = ? AND member_id = ?", companyID, input.MemberID).First(&existing).Error; err == nil {
+		c.JSON(http.StatusBadRequest, gin.H{"detail": "ID Member sudah digunakan"})
+		return
+	}
+
+	newMember := models.Member{
+		CompanyID: companyID,
+		MemberID:  input.MemberID,
+		Name:      input.Name,
+		Phone:     input.Phone,
+		Points:    0,
+	}
+
+	if err := config.DB.Create(&newMember).Error; err != nil {
+		c.JSON(http.StatusInternalServerError, gin.H{"detail": "Gagal membuat member"})
+		return
+	}
+
+	c.JSON(http.StatusCreated, newMember)
+}
+
+// UpdateMember (PUT /api/members/:member_id)
+func UpdateMember(c *gin.Context) {
+	companyIDRaw, exists := c.Get("company_id")
+	if !exists {
+		c.JSON(http.StatusUnauthorized, gin.H{"detail": "Unauthorized"})
+		return
+	}
+	companyID := companyIDRaw.(uint)
+	memberID := c.Param("member_id")
+
+	var member models.Member
+	if err := config.DB.Where("company_id = ? AND id = ?", companyID, memberID).First(&member).Error; err != nil {
+		c.JSON(http.StatusNotFound, gin.H{"detail": "Member tidak ditemukan"})
+		return
+	}
+
+	var input struct {
+		Name  string `json:"name" binding:"required"`
+		Phone string `json:"phone"`
+	}
+
+	if err := c.ShouldBindJSON(&input); err != nil {
+		c.JSON(http.StatusBadRequest, gin.H{"detail": "Data tidak valid"})
+		return
+	}
+
+	member.Name = input.Name
+	member.Phone = input.Phone
+
+	if err := config.DB.Save(&member).Error; err != nil {
+		c.JSON(http.StatusInternalServerError, gin.H{"detail": "Gagal update member"})
+		return
+	}
+
+	c.JSON(http.StatusOK, member)
+}
+
+// SetPoints (PUT /api/members/:member_id/points) - Owner ONLY
+func SetPoints(c *gin.Context) {
+	companyIDRaw, exists := c.Get("company_id")
+	if !exists {
+		c.JSON(http.StatusUnauthorized, gin.H{"detail": "Unauthorized"})
+		return
+	}
+	companyID := companyIDRaw.(uint)
+	memberID := c.Param("member_id")
+
+	var member models.Member
+	if err := config.DB.Where("company_id = ? AND id = ?", companyID, memberID).First(&member).Error; err != nil {
+		c.JSON(http.StatusNotFound, gin.H{"detail": "Member tidak ditemukan"})
+		return
+	}
+
+	var input struct {
+		Points int `json:"points"`
+	}
+
+	if err := c.ShouldBindJSON(&input); err != nil {
+		c.JSON(http.StatusBadRequest, gin.H{"detail": "Data tidak valid"})
+		return
+	}
+
+	member.Points = input.Points
+
+	if err := config.DB.Save(&member).Error; err != nil {
+		c.JSON(http.StatusInternalServerError, gin.H{"detail": "Gagal update poin"})
+		return
+	}
+
+	c.JSON(http.StatusOK, member)
+}
+
+// DeleteMember (DELETE /api/members/:member_id)
+func DeleteMember(c *gin.Context) {
+	companyIDRaw, exists := c.Get("company_id")
+	if !exists {
+		c.JSON(http.StatusUnauthorized, gin.H{"detail": "Unauthorized"})
+		return
+	}
+	companyID := companyIDRaw.(uint)
+	memberID := c.Param("member_id")
+
+	if err := config.DB.Where("company_id = ? AND id = ?", companyID, memberID).Delete(&models.Member{}).Error; err != nil {
+		c.JSON(http.StatusInternalServerError, gin.H{"detail": "Gagal menghapus member"})
+		return
+	}
+
+	c.JSON(http.StatusOK, gin.H{"detail": "Member dihapus"})
+}

controllers/order_controller.go

@@ -59,6 +59,8 @@ type CashPaymentRequest struct {
 	PaidAmount    int    `json:"paid_amount" binding:"required,gt=0"`
 	CustomerName  string `json:"customer_name"`
 	CustomerPhone string `json:"customer_phone"`
+	ServedBy      string `json:"served_by"`
+	MemberID      *uint  `json:"member_id"`
 }
 
 type MidtransPaymentRequest struct {
@@ -66,6 +68,8 @@ type MidtransPaymentRequest struct {
 	CustomerName  string `json:"customer_name"`
 	CustomerEmail string `json:"customer_email"`
 	CustomerPhone string `json:"customer_phone"`
+	ServedBy      string `json:"served_by"`
+	MemberID      *uint  `json:"member_id"`
 }
 
 type PaymentStatusResponse struct {
@@ -367,6 +371,12 @@ func PayCash(c *gin.Context) {
 	order.PaymentStatus = "paid"
 	order.PaidAmount = req.PaidAmount
 	order.ChangeAmount = req.PaidAmount - order.TotalAmount
+	if req.ServedBy != "" {
+		order.ServedBy = req.ServedBy
+	}
+	if req.MemberID != nil {
+		order.MemberID = req.MemberID
+	}
 
 	// Hitung fee platform berdasarkan Company
 	var company models.Company
@@ -497,9 +507,15 @@ func PayTripay(c *gin.Context) {
 	// Simpan Tripay details ke DB
 	order.MidtransOrderID = tripayRes.Data.Reference // Simpan nomor referensi Tripay di midtrans_order_id demi kecocokan DB
 	order.MidtransToken = tripayRes.Data.CheckoutURL // Simpan checkout_url di midtrans_token demi kecocokan DB
-	order.PaymentMethod = "tripay"
+	order.PaymentStatus = "pending"
 	order.CustomerName = req.CustomerName
 	order.CustomerPhone = req.CustomerPhone
+	if req.ServedBy != "" {
+		order.ServedBy = req.ServedBy
+	}
+	if req.MemberID != nil {
+		order.MemberID = req.MemberID
+	}
 	config.DB.Save(&order)
 
 	expTime := tripayRes.Data.ExpiredTime

fix_db.go

@@ -0,0 +1,19 @@
+//go:build ignore
+
+package main
+
+import (
+	"log"
+	"gorm.io/driver/postgres"
+	"gorm.io/gorm"
+)
+
+func main() {
+	dsn := "postgres://postgres.gmzonnwzocuhtjhywtdd:Imtoky0d3vjava@aws-1-ap-south-1.pooler.supabase.com:5432/postgres"
+	db, err := gorm.Open(postgres.Open(dsn), &gorm.Config{})
+	if err != nil {
+		log.Fatal(err)
+	}
+
+	db.Exec("UPDATE orders SET total_amount = total_amount + 757, paid_amount = paid_amount + 757 WHERE payment_method IN ('tripay', 'midtrans') AND payment_status = 'paid' AND total_amount = 1000")
+}

main.go

@@ -35,6 +35,7 @@ func main() {
 		&models.OrderItem{},
 		&models.OTP{},
 		&models.Setting{},
+		&models.Member{},
 	)
 	if err != nil {
 		log.Fatalf("Gagal melakukan Auto-Migration: %v", err)
@@ -146,6 +147,19 @@ func main() {
 			}
 		}
 
+		// === MEMBERS ROUTES ===
+		members := api.Group("/members")
+		{
+			members.Use(middleware.GetCurrentUser(), middleware.RequireTenantContext())
+			{
+				members.GET("/", controllers.ListMembers)
+				members.POST("/", controllers.CreateMember)
+				members.PUT("/:member_id", controllers.UpdateMember)
+				members.PUT("/:member_id/points", middleware.RequireOwner(), controllers.SetPoints)
+				members.DELETE("/:member_id", middleware.RequireOwner(), controllers.DeleteMember)
+			}
+		}
+
 		// === PRODUCTS & CATEGORIES ROUTES ===
 		products := api.Group("/products")
 		{

models/models.go

@@ -26,6 +26,18 @@ type Company struct {
 	Categories        []Category     `gorm:"foreignKey:CompanyID;constraint:OnDelete:CASCADE" json:"-"`
 	Products          []Product      `gorm:"foreignKey:CompanyID;constraint:OnDelete:CASCADE" json:"-"`
 	Orders            []Order        `gorm:"foreignKey:CompanyID;constraint:OnDelete:CASCADE" json:"-"`
+	Members           []Member       `gorm:"foreignKey:CompanyID;constraint:OnDelete:CASCADE" json:"-"`
+}
+
+type Member struct {
+	ID        uint      `gorm:"primaryKey" json:"id"`
+	CompanyID uint      `gorm:"not null;index" json:"company_id"`
+	MemberID  string    `gorm:"type:varchar(50);not null;uniqueIndex:uq_company_member" json:"member_id"`
+	Name      string    `gorm:"type:varchar(100);not null" json:"name"`
+	Phone     string    `gorm:"type:varchar(20)" json:"phone"`
+	Points    int       `gorm:"default:0" json:"points"`
+	CreatedAt time.Time `gorm:"autoCreateTime" json:"created_at"`
+	Company   *Company  `gorm:"foreignKey:CompanyID" json:"company,omitempty"`
 }
 
 type Branch struct {
@@ -110,6 +122,9 @@ type Order struct {
 	CreatedAt       time.Time   `gorm:"autoCreateTime" json:"created_at"`
 	Company         *Company    `gorm:"foreignKey:CompanyID" json:"company,omitempty"`
 	Branch          *Branch     `gorm:"foreignKey:BranchID" json:"branch,omitempty"`
+	MemberID        *uint       `gorm:"index" json:"member_id"`
+	Member          *Member     `gorm:"foreignKey:MemberID" json:"member,omitempty"`
+	ServedBy        string      `gorm:"type:varchar(100)" json:"served_by"`
 	CustomerName    string      `gorm:"type:varchar(100)" json:"customer_name"`
 	CustomerPhone   string      `gorm:"type:varchar(50)" json:"customer_phone"`
 	Items           []OrderItem `gorm:"foreignKey:OrderID;constraint:OnDelete:CASCADE" json:"items"`

test_db.go

@@ -0,0 +1,35 @@
+//go:build ignore
+
+package main
+
+import (
+	"fmt"
+	"log"
+	"gorm.io/driver/postgres"
+	"gorm.io/gorm"
+	"time"
+)
+
+type Order struct {
+	ID            uint
+	OrderNumber   string
+	PaymentStatus string
+	TotalAmount   int
+	PaidAmount    int
+	PaymentMethod string
+	CreatedAt     time.Time
+}
+
+func main() {
+	dsn := "postgres://postgres.gmzonnwzocuhtjhywtdd:Imtoky0d3vjava@aws-1-ap-south-1.pooler.supabase.com:5432/postgres"
+	db, err := gorm.Open(postgres.Open(dsn), &gorm.Config{})
+	if err != nil {
+		log.Fatal(err)
+	}
+
+	var orders []Order
+	db.Order("id desc").Limit(5).Find(&orders)
+	for _, o := range orders {
+		fmt.Printf("ID: %d | Ref: %s | Status: %s | Total: %d | Paid: %d | Method: %s | Created: %v\n", o.ID, o.OrderNumber, o.PaymentStatus, o.TotalAmount, o.PaidAmount, o.PaymentMethod, o.CreatedAt)
+	}
+}