Compare commits
No commits in common. "3c0adda9557b17d82aa343df6700cd8cbc637130" and "292580e0897c2f804ae5de947b69a5d770d53333" have entirely different histories.
3c0adda955
...
292580e089
@ -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,
|
||||||
},
|
},
|
||||||
})
|
})
|
||||||
}
|
}
|
||||||
Loading…
x
Reference in New Issue
Block a user