package controllers

import (
	"basic.com/pubsub/protomsg.git"
	"basic.com/valib/bhomeclient.git"
	"encoding/json"
	"github.com/satori/go.uuid"
	"vamicro/system-service/models"
	"vamicro/system-service/service"
)

type VoiceController struct{}

type VoiceMenu struct {
	Id   string `json:"id"`
	Name string `json:"name"`
	Path string `json:"path"`
}

// @Summary 查找所有报警声音
// @Description 查找所有报警声音
// @Produce json
// @Tags 报警声音
// @Success 200 {string} json "{"code":200, msg:"",data:"",success:true}"
// @Failure 500 {string} json "{"code":500, msg:"",data:"[]",success:false}"
// @Router /data/api-v/voice/findAll [GET]
func (vc *VoiceController) FindAll(h *bhomeclient.WrapperHandler, c *bhomeclient.Request) *bhomeclient.Reply {
	var voiceMenus = make([]VoiceMenu, 0)
	var voice models.Voice
	voices, err := voice.FindAll()
	//config.Server.Voices
	if err == nil {
		for _, v := range voices {
			voiceMenus = append(voiceMenus, VoiceMenu{
				Id:   v.Id,
				Name: v.Name,
				Path: v.Path,
			})
		}
	}
	return &bhomeclient.Reply{Success: true, Data: voiceMenus}
}

// @Summary 获取报警声音列表
// @Description 获取报警声音列表
// @Security ApiKeyAuth
// @Produce json
// @Tags 报警声音
// @Param id formData string false "id"
// @Param name formData string true "名称"
// @Param mp3File formData string true "mp3文件地址"
// @Param g711aFile formData string true "g711a文件地址"
// @Success 200 {string} json "{"code":200, success:true, msg:"", data:""}"
// @Failure 500 {string} json "{"code":500, success:false, msg:"",data:""}"
// @Router /data/api-v/voice/add [post]
func (vc *VoiceController) Add(h *bhomeclient.WrapperHandler, c *bhomeclient.Request) *bhomeclient.Reply {
	id := c.PostForm("id")
	name := c.PostForm("name")
	mp3File := c.PostForm("mp3File")
	//g711aFile := c.PostForm("g711aFile")
	if name == "" {
		return &bhomeclient.Reply{Msg: "name不能为空"}
	}
	if mp3File == "" {
		return &bhomeclient.Reply{Msg: "音频文件不能为空"}
	}
	b := false
	var err error
	v := models.Voice{
		Name: name,
		Path: mp3File,
	}

	dbMsg := protomsg.DbChangeMessage{
		Table: protomsg.TableChanged_T_Voice,
	}

	if id == "" { //新增
		v.Id = uuid.NewV4().String()
		b, err = v.Insert()

		dbMsg.Action = protomsg.DbAction_Insert
		dbMsg.Id = v.Id
	} else { //更新
		v.Id = id
		b, err = v.Update()

		dbMsg.Action = protomsg.DbAction_Update
		dbMsg.Id = id
	}

	if err == nil {
		pb, _ := json.Marshal(dbMsg)
		h.Bk.Publish(service.ProcName, pb)
		return &bhomeclient.Reply{Success: b, Msg: "保存成功"}
	} else {
		return &bhomeclient.Reply{Msg: err.Error()}
	}
}

// @Summary 删除报警声音
// @Description 删除报警声音
// @Security ApiKeyAuth
// @Produce json
// @Tags 报警声音
// @Param id query string true "id"
// @Success 200 {string} json "{"code":200, success:true, msg:"", data:""}"
// @Failure 500 {string} json "{"code":500, success:false, msg:"",data:""}"
// @Router /data/api-v/voice/del [delete]
func (vc *VoiceController) Del(h *bhomeclient.WrapperHandler, c *bhomeclient.Request) *bhomeclient.Reply {
	id := c.Query("id")
	if id == "" {
		return &bhomeclient.Reply{Msg: "id不能为空"}
	}
	var v models.Voice
	b, err := v.DeleteById(id)
	if b {
		dbMsg := protomsg.DbChangeMessage{
			Table:  protomsg.TableChanged_T_Voice,
			Id:     id,
			Action: protomsg.DbAction_Delete,
		}
		pb, _ := json.Marshal(dbMsg)
		h.Bk.Publish(service.ProcName, pb)
		return &bhomeclient.Reply{Success: true, Msg: "删除成功"}
	} else {
		return &bhomeclient.Reply{Msg: err.Error()}
	}
}

// @Security ApiKeyAuth
// @Summary 上传音频
// @Description 上传音频
// @Accept x-www-form-urlencoded
// @Produce json
// @Tags 报警声音
// @Success 200 {string} json "{"code":200, success:true, msg:"", data:""}"
// @Failure 500 {string} json "{"code":500, success:false, msg:"", data:""}"
// @Router /data/api-v/voice/upload [post]
func (vc *VoiceController) Upload(h *bhomeclient.WrapperHandler, c *bhomeclient.Request) *bhomeclient.Reply {
	file, err := c.FormFile()
	if err == nil {
		var sv service.SysService
		if file.Name == "" || len(file.Bytes) == 0 {
			return &bhomeclient.Reply{Msg: "音频上传错误"}
		}
		filename := file.Name
		audioPath, err := sv.UploadVoice(file.Bytes, filename)
		if err != nil {
			if err.Error() == "audio format error" {
				return &bhomeclient.Reply{Msg: "声音只允许mp3,wav,wma的格式"}
			} else {
				return &bhomeclient.Reply{Msg: "声音上传失败:" + err.Error()}
			}
		}
		return &bhomeclient.Reply{Success: true, Data: audioPath}
	}
	return &bhomeclient.Reply{Msg: "未找到上传声音文件"}
}