Compare commits

..

No commits in common. "3c0adda9557b17d82aa343df6700cd8cbc637130" and "292580e0897c2f804ae5de947b69a5d770d53333" have entirely different histories.

View File

@ -7,11 +7,9 @@ import (
"net/http" "net/http"
"os" "os"
"strconv" // Digunakan untuk mengubah teks Watt menjadi angka "strconv" // Digunakan untuk mengubah teks Watt menjadi angka
"strings" // Digunakan untuk manipulasi string (ToUpper/Trim)
"time" "time"
"s-class-backend/config" // Import database "s-class-backend/config" // Import database
"s-class-backend/models" // Import models untuk query database
mqtt "github.com/eclipse/paho.mqtt.golang" mqtt "github.com/eclipse/paho.mqtt.golang"
"github.com/gin-gonic/gin" "github.com/gin-gonic/gin"
@ -27,6 +25,7 @@ type VerifyRequest struct {
Token string `json:"token"` Token string `json:"token"`
} }
// Tambahan untuk kontrol daya global (ON/OFF)
type GlobalPowerRequest struct { type GlobalPowerRequest struct {
Action string `json:"action"` // "on" atau "off" Action string `json:"action"` // "on" atau "off"
} }
@ -42,7 +41,7 @@ var DeviceStatusCache = map[string]string{
} }
// ========================================================================= // =========================================================================
// FUNGSI 1: VERIFIKASI TOKEN & KODE MATA KULIAH (ON-DEMAND) // FUNGSI 1: VERIFIKASI TOKEN (Bisa Master & Mahasiswa)
// ========================================================================= // =========================================================================
func VerifyHardwareCode(c *gin.Context) { func VerifyHardwareCode(c *gin.Context) {
var req VerifyRequest var req VerifyRequest
@ -52,9 +51,8 @@ func VerifyHardwareCode(c *gin.Context) {
return return
} }
tokenInput := strings.ToUpper(strings.TrimSpace(req.Token)) tokenInput := req.Token
loc, _ := time.LoadLocation("Asia/Jakarta") sekarang := time.Now()
sekarang := time.Now().In(loc)
sisaMenit := 0 sisaMenit := 0
isTokenValid := false isTokenValid := false
@ -63,78 +61,75 @@ func VerifyHardwareCode(c *gin.Context) {
// ========================================================= // =========================================================
if tokenInput == "CS2026" { if tokenInput == "CS2026" {
fmt.Printf("[VERIFY] Master Token CS digunakan\n") fmt.Printf("[VERIFY] Master Token CS digunakan\n")
sisaMenit = 120 sisaMenit = 60
isTokenValid = true isTokenValid = true
} else if tokenInput == "ADM999" { } else if tokenInput == "ADM999" {
fmt.Printf("[VERIFY] Master Token Admin digunakan\n") fmt.Printf("[VERIFY] Master Token Admin digunakan\n")
sisaMenit = 720 // 24 Jam sisaMenit = 999
isTokenValid = true isTokenValid = true
} else { } else {
// ========================================================= // =========================================================
// 2. CEK TOKEN BOOKING VIA WEB (6 DIGIT) // 2. PENGECEKAN KELOMPOK TOKEN MAHASISWA (Cek Database & Waktu)
// ========================================================= // =========================================================
var booking models.Booking var jamMulai time.Time
errBooking := config.DB.First(&booking, "redeem_code = ? AND status = 'Approved'", tokenInput).Error var jamSelesai time.Time
type ResultTime struct {
JamMulai time.Time `gorm:"column:start_time"`
JamSelesai time.Time `gorm:"column:end_time"`
}
var result ResultTime
if errBooking == nil { // Cek Bookings
// Cek apakah hari ini (tanggal) sama dengan hari booking errBooking := config.DB.Table("bookings").
if booking.StartTime.Format("2006-01-02") != sekarang.Format("2006-01-02") { Select("start_time, end_time").
c.JSON(http.StatusForbidden, gin.H{"error": "Peminjaman bukan untuk hari ini"}) Where("redeem_code = ?", tokenInput).
return Scan(&result).Error
}
toleransiMasuk := booking.StartTime.Add(-15 * time.Minute) if errBooking == nil && !result.JamSelesai.IsZero() {
if sekarang.Before(toleransiMasuk) { jamMulai = result.JamMulai
c.JSON(http.StatusForbidden, gin.H{"error": "Belum waktunya. Bisa masuk 15 mnt sblm jam peminjaman!"}) jamSelesai = result.JamSelesai
return
}
if sekarang.After(booking.EndTime) {
c.JSON(http.StatusForbidden, gin.H{"error": "Waktu peminjaman sudah habis!"})
return
}
sisaMenit = int(booking.EndTime.Sub(sekarang).Minutes())
if sisaMenit <= 0 {
sisaMenit = 1
}
isTokenValid = true isTokenValid = true
} else { } else {
// ========================================================= // Cek Jadwal Kelas Tetap
// 3. CEK KODE MATA KULIAH (ON-DEMAND FLEKSIBEL) errSchedule := config.DB.Table("class_schedules").
// ========================================================= Select("start_time, end_time").
var schedule models.ClassSchedule Where("kode_mk = ?", tokenInput).
// Abaikan hari dan jam, cukup cek apakah kode matkul eksis di database Scan(&result).Error
errSchedule := config.DB.First(&schedule, "kode_mk = ?", tokenInput).Error
if errSchedule == nil { if errSchedule == nil && !result.JamSelesai.IsZero() {
// KODE MATKUL EKSIS. jamMulai = result.JamMulai
// CEK BENTROK: Apakah ada orang yang SEDANG booking via web sekarang? jamSelesai = result.JamSelesai
var countBookingAktif int64
config.DB.Model(&models.Booking{}).Where(
"room_id = ? AND status = 'Approved' AND start_time <= ? AND end_time >= ?",
schedule.RoomID, sekarang, sekarang,
).Count(&countBookingAktif)
if countBookingAktif > 0 {
c.JSON(http.StatusConflict, gin.H{"error": "Ruangan sedang dipakai peminjam resmi (Web)!"})
return
}
// Jika aman (tidak ada yang booking), berikan akses 120 Menit!
sisaMenit = 120
isTokenValid = true isTokenValid = true
} }
} }
if !isTokenValid { if !isTokenValid {
c.JSON(http.StatusUnauthorized, gin.H{"error": "Token atau Kode MK tidak ditemukan / salah!"}) c.JSON(http.StatusUnauthorized, gin.H{"error": "Token salah atau tidak ditemukan"})
return
}
jamMulaiHariIni := time.Date(sekarang.Year(), sekarang.Month(), sekarang.Day(),
jamMulai.Hour(), jamMulai.Minute(), jamMulai.Second(), 0, sekarang.Location())
jamSelesaiHariIni := time.Date(sekarang.Year(), sekarang.Month(), sekarang.Day(),
jamSelesai.Hour(), jamSelesai.Minute(), jamSelesai.Second(), 0, sekarang.Location())
batasMasukAwal := jamMulaiHariIni.Add(-15 * time.Minute)
if sekarang.Before(batasMasukAwal) {
c.JSON(http.StatusForbidden, gin.H{"error": "Jadwal kelas belum dimulai"})
return
}
selisihWaktu := jamSelesaiHariIni.Sub(sekarang)
sisaMenit = int(selisihWaktu.Minutes())
if sisaMenit <= 0 {
c.JSON(http.StatusForbidden, gin.H{"error": "Waktu peminjaman sudah habis"})
return return
} }
} }
// ========================================================= // =========================================================
// 4. JIKA VALID (Master / Matkul / Web), BUKA GEMBOK VIA MQTT // 3. JIKA VALID (Master / Mahasiswa), BUKA GEMBOK VIA MQTT
// ========================================================= // =========================================================
DeviceStatusCache["lampu1"] = "on" DeviceStatusCache["lampu1"] = "on"
DeviceStatusCache["lampu2"] = "on" DeviceStatusCache["lampu2"] = "on"
@ -162,7 +157,7 @@ func VerifyHardwareCode(c *gin.Context) {
c.JSON(http.StatusOK, gin.H{ c.JSON(http.StatusOK, gin.H{
"status": "success", "status": "success",
"message": "Akses Diberikan", "message": "Token Valid",
"duration_minutes": sisaMenit, "duration_minutes": sisaMenit,
}) })
} }
@ -177,6 +172,7 @@ func ControlHardware(c *gin.Context) {
return return
} }
// 🌟 BLOK 1: KONTROL GEMBOK / OTORISASI RELAY
if req.Device == "auth" { if req.Device == "auth" {
broker := os.Getenv("MQTT_BROKER") broker := os.Getenv("MQTT_BROKER")
user := os.Getenv("MQTT_USER") user := os.Getenv("MQTT_USER")
@ -195,6 +191,7 @@ func ControlHardware(c *gin.Context) {
return return
} }
// --- BLOK 2: KONTROL LAMPU ---
if req.Device == "lampu1" || req.Device == "lampu2" { if req.Device == "lampu1" || req.Device == "lampu2" {
broker := os.Getenv("MQTT_BROKER") broker := os.Getenv("MQTT_BROKER")
user := os.Getenv("MQTT_USER") user := os.Getenv("MQTT_USER")
@ -222,6 +219,7 @@ func ControlHardware(c *gin.Context) {
return return
} }
// --- BLOK 3: KONTROL AC & PROYEKTOR ---
if req.Device == "ac" || req.Device == "projector" { if req.Device == "ac" || req.Device == "projector" {
haURL := os.Getenv("HA_URL") haURL := os.Getenv("HA_URL")
haToken := os.Getenv("HA_TOKEN") haToken := os.Getenv("HA_TOKEN")
@ -266,7 +264,7 @@ func ControlHardware(c *gin.Context) {
} }
// ========================================================================= // =========================================================================
// HELPER 1 & 2: HTTP GET KE HOME ASSISTANT // HELPER 1: MENGAMBIL ANGKA DARI HOME ASSISTANT (Untuk Daya/Watt)
// ========================================================================= // =========================================================================
func fetchHAState(haURL string, haToken string, entityID string) float64 { func fetchHAState(haURL string, haToken string, entityID string) float64 {
apiURL := fmt.Sprintf("%s/api/states/%s", haURL, entityID) apiURL := fmt.Sprintf("%s/api/states/%s", haURL, entityID)
@ -296,6 +294,9 @@ func fetchHAState(haURL string, haToken string, entityID string) float64 {
return val return val
} }
// =========================================================================
// HELPER 2: MENGAMBIL STATUS TEKS DARI HOME ASSISTANT (Untuk ON/OFF)
// =========================================================================
func fetchHAStringState(haURL string, haToken string, entityID string) string { func fetchHAStringState(haURL string, haToken string, entityID string) string {
apiURL := fmt.Sprintf("%s/api/states/%s", haURL, entityID) apiURL := fmt.Sprintf("%s/api/states/%s", haURL, entityID)
@ -324,7 +325,7 @@ func fetchHAStringState(haURL string, haToken string, entityID string) string {
} }
// ========================================================================= // =========================================================================
// FUNGSI 3: MENDAPATKAN STATUS DAYA // FUNGSI 3: MENDAPATKAN STATUS DAYA DARI 3 MCB SEKALIGUS
// ========================================================================= // =========================================================================
func GetPowerStatus(c *gin.Context) { func GetPowerStatus(c *gin.Context) {
haURL := os.Getenv("HA_URL") haURL := os.Getenv("HA_URL")
@ -342,7 +343,7 @@ func GetPowerStatus(c *gin.Context) {
} }
// ========================================================================= // =========================================================================
// FUNGSI 4: GLOBAL POWER CONTROL // FUNGSI 4: GLOBAL POWER CONTROL (Sequential ON/OFF dengan Jeda 1 Detik)
// ========================================================================= // =========================================================================
func GlobalPowerControl(c *gin.Context) { func GlobalPowerControl(c *gin.Context) {
var req GlobalPowerRequest var req GlobalPowerRequest
@ -403,25 +404,31 @@ func GlobalPowerControl(c *gin.Context) {
} }
// ========================================================================= // =========================================================================
// FUNGSI 5: SENSOR FUSION FRONTEND // FUNGSI 5: MENGIRIM STATUS REAL-TIME KE WEB FRONTEND (SENSOR FUSION)
// ========================================================================= // =========================================================================
func GetHardwareStatus(c *gin.Context) { func GetHardwareStatus(c *gin.Context) {
haURL := os.Getenv("HA_URL") haURL := os.Getenv("HA_URL")
haToken := os.Getenv("HA_TOKEN") haToken := os.Getenv("HA_TOKEN")
// 1. Cek status fisik MCB di Home Assistant
mcbUmum := fetchHAStringState(haURL, haToken, "switch.wifi_smart_meter_pro_switch") mcbUmum := fetchHAStringState(haURL, haToken, "switch.wifi_smart_meter_pro_switch")
mcbAC1 := fetchHAStringState(haURL, haToken, "switch.wifi_smart_meter_pro_2_switch") mcbAC1 := fetchHAStringState(haURL, haToken, "switch.wifi_smart_meter_pro_2_switch")
// 2. Ambil data dari Cache (Perintah terakhir dari Web/ESP32 melalui IR/MQTT)
statusLampu1 := DeviceStatusCache["lampu1"] statusLampu1 := DeviceStatusCache["lampu1"]
statusLampu2 := DeviceStatusCache["lampu2"] statusLampu2 := DeviceStatusCache["lampu2"]
statusProyektor := DeviceStatusCache["projector"] statusProyektor := DeviceStatusCache["projector"]
statusAC := DeviceStatusCache["ac"] statusAC := DeviceStatusCache["ac"]
// 3. LOGIKA SENSOR FUSION (Penggabungan Fisik & Virtual)
// Jika listrik MCB fisik terputus, maka otomatis perangkat di jalur tersebut PASTI MATI (off),
// mengabaikan apapun status terakhir yang ada di memori Cache.
if mcbUmum == "off" { if mcbUmum == "off" {
statusLampu1 = "off" statusLampu1 = "off"
statusLampu2 = "off" statusLampu2 = "off"
statusProyektor = "off" statusProyektor = "off"
// Sinkronkan kembali cache agar tidak ada "state" nyangkut
DeviceStatusCache["lampu1"] = "off" DeviceStatusCache["lampu1"] = "off"
DeviceStatusCache["lampu2"] = "off" DeviceStatusCache["lampu2"] = "off"
DeviceStatusCache["projector"] = "off" DeviceStatusCache["projector"] = "off"
@ -432,6 +439,7 @@ func GetHardwareStatus(c *gin.Context) {
DeviceStatusCache["ac"] = "off" DeviceStatusCache["ac"] = "off"
} }
// Kirim data yang sudah divalidasi ke Web dan Layar ESP32
c.JSON(http.StatusOK, gin.H{ c.JSON(http.StatusOK, gin.H{
"status": "success", "status": "success",
"data": map[string]string{ "data": map[string]string{
@ -441,4 +449,4 @@ func GetHardwareStatus(c *gin.Context) {
"ac": statusAC, "ac": statusAC,
}, },
}) })
} }