package main

import (
	"gitee.com/aywc_1/aywc_judge/src/appinit"
	"gitee.com/aywc_1/aywc_judge/src/configuration"
	"gitee.com/aywc_1/aywc_judge/src/lib"
	"gitee.com/aywc_1/aywc_judge/src/mqtt2/service"
	"gitee.com/aywc_1/aywc_judge/src/mqttmessage"
	log "github.com/sirupsen/logrus"
)

func main() {
	configuration.InitLog("mqtt")
	c := make(chan error)
	go func() {
		err := appinit.DBInit()
		if err != nil {
			c <- err
		}

	}()
	go func() {
		err := GetMQTTData()
		if err != nil {
			c <- err
		}

	}()
	err := <-c
	log.Fatal(err)

}

const (
	clientId                 = "nurse-002"
	topicName                = "*/nursesub"
	actionNameNurseStart     = "nurse/start"
	actionNameNurseEnd       = "nurse/end"
	actionNameNurseException = "nurse/exception"
	actionNameLeaveException = "leave/exception"
)

func GetMQTTData() error {
	client := lib.NewClient(clientId)
	err := client.Connect()
	if err != nil {
		log.Error(err)
		return err
	}
	err = client.Subscribe(NurseHandle, 0, topicName)
	if err != nil {
		log.Error(err)
		return err
	}

	return nil
}

func NurseHandle(c *lib.Client, msg *lib.Message) {
	switch msg.Action {
	case actionNameNurseStart:
		message := &mqttmessage.NurseStartMessage{}
		err := service.MapToStruct(msg.Body, message)
		if err != nil {
			log.Error(err)
		} else {
			NurseStart(message)
		}
	default:
		log.Info("unkonwn action %s \n", msg.Action)
	}

}

func NurseStart(msg *mqttmessage.NurseStartMessage) {

}

func NurseEnd(c *lib.Client, msg *lib.Message) {

}

func NurseException(c *lib.Client, msg *lib.Message) {

}

func NurseLeaveException(c *lib.Client, msg *lib.Message) {

}