package controllers

import (
	"github.com/tiptok/gocomm/pkg/log"
	"gitlab.fjmaimaimai.com/mmm-go/godevp/pkg/application/projectModuleFiles/command"
	"gitlab.fjmaimaimai.com/mmm-go/godevp/pkg/application/projectModuleFiles/query"
	"gitlab.fjmaimaimai.com/mmm-go/godevp/pkg/application/projectModuleFiles/service"
	"gitlab.fjmaimaimai.com/mmm-go/godevp/pkg/infrastructure/utils"
	"gitlab.fjmaimaimai.com/mmm-go/godevp/pkg/protocol"
)

type ProjectModuleFilesController struct {
	BaseController
}

// CreateProjectModuleFiles
// CreateProjectModuleFiles execute command  create  ProjectModuleFiles
func (controller *ProjectModuleFilesController) CreateProjectModuleFiles() {
	var (
		msg     *protocol.ResponseMessage
		svr     = service.NewProjectModuleFilesService(nil)
		request *command.CreateProjectModuleFilesRequest
	)
	defer func() {
		controller.Resp(msg)
	}()
	if err := controller.JsonUnmarshal(&request); err != nil {
		msg = protocol.NewResponseMessage(2, "")
		return
	}
	header := controller.GetRequestHeader(controller.Ctx)
	data, err := svr.CreateProjectModuleFiles(header, request)
	if err != nil {
		log.Error(err)
	}
	msg = protocol.NewResponseMessageData(data, err)
}

// UpdateProjectModuleFiles
// UpdateProjectModuleFiles execute command  update  ProjectModuleFiles
func (controller *ProjectModuleFilesController) UpdateProjectModuleFiles() {
	var (
		msg     *protocol.ResponseMessage
		svr     = service.NewProjectModuleFilesService(nil)
		request *command.UpdateProjectModuleFilesRequest
	)
	defer func() {
		controller.Resp(msg)
	}()
	if err := controller.JsonUnmarshal(&request); err != nil {
		msg = protocol.NewResponseMessage(2, "")
		return
	}
	request.Id, _ = controller.GetInt64(":projectModuleFilesId")
	header := controller.GetRequestHeader(controller.Ctx)
	data, err := svr.UpdateProjectModuleFiles(header, request)
	if err != nil {
		log.Error(err)
	}
	msg = protocol.NewResponseMessageData(data, err)
}

// GetProjectModuleFiles
// GetProjectModuleFiles execute query  get  ProjectModuleFiles
func (controller *ProjectModuleFilesController) GetProjectModuleFiles() {
	var (
		msg     *protocol.ResponseMessage
		svr     = service.NewProjectModuleFilesService(nil)
		request = &query.GetProjectModuleFilesRequest{}
	)
	defer func() {
		controller.Resp(msg)
	}()
	request.Id, _ = controller.GetInt64(":projectModuleFilesId")
	header := controller.GetRequestHeader(controller.Ctx)
	data, err := svr.GetProjectModuleFiles(header, request)
	if err != nil {
		log.Error(err)
	}
	msg = protocol.NewResponseMessageData(data, err)
}

// DeleteProjectModuleFiles
// DeleteProjectModuleFiles execute command  delete  ProjectModuleFiles
func (controller *ProjectModuleFilesController) DeleteProjectModuleFiles() {
	var (
		msg     *protocol.ResponseMessage
		svr     = service.NewProjectModuleFilesService(nil)
		request = &command.DeleteProjectModuleFilesRequest{}
	)
	defer func() {
		controller.Resp(msg)
	}()
	request.Id, _ = controller.GetInt64(":projectModuleFilesId")
	header := controller.GetRequestHeader(controller.Ctx)
	data, err := svr.DeleteProjectModuleFiles(header, request)
	if err != nil {
		log.Error(err)
	}
	msg = protocol.NewResponseMessageData(data, err)
}

// ListProjectModuleFiles
// ListProjectModuleFiles execute query  list  ProjectModuleFiles
func (controller *ProjectModuleFilesController) ListProjectModuleFiles() {
	var (
		msg     *protocol.ResponseMessage
		svr     = service.NewProjectModuleFilesService(nil)
		request = &query.ListProjectModuleFilesRequest{}
	)
	defer func() {
		controller.Resp(msg)
	}()
	request.ProjectModuleVersionId, _ = controller.GetInt64("projectModuleVersionId")
	request.ProjectModuleId, _ = controller.GetInt64("projectModuleId")
	request.StructType = controller.GetString("structType")

	request.ProjectKey = controller.GetString("projectKey")
	request.VersionKey = controller.GetString("versionKey")
	request.FileName = controller.GetString("fileName")
	header := controller.GetRequestHeader(controller.Ctx)
	data, err := svr.ListProjectModuleFiles(header, request)
	if err != nil {
		log.Error(err)
	}
	msg = protocol.NewResponseMessageData(data, err)
}

// Import
// 权限列表
func (controller *ProjectModuleFilesController) Import() {
	var (
		msg     *protocol.ResponseMessage
		svr     = service.NewProjectModuleFilesService(nil)
		request = &command.ImportRequest{}
	)
	defer func() {
		controller.Resp(msg)
	}()
	header := controller.GetRequestHeader(controller.Ctx)
	request.ProjectModuleId, _ = controller.GetInt64("projectModuleId")
	request.ProjectModuleVersionId, _ = controller.GetInt64("projectModuleVersionId")
	request.ParentId, _ = controller.GetInt64("parentId")
	for _, v := range utils.ReadMultipartFormFile(controller.Ctx.Request.MultipartForm.File, 5*1024) {
		request.ImportFiles = append(request.ImportFiles, command.ImportFile{
			FileName:    v.FileName,
			FileContent: v.FileContent,
		})
	}
	data, err := svr.Import(header, request)
	if err != nil {
		log.Error(err)
	}
	msg = protocol.NewResponseMessageData(data, err)
}

// ReviseTag
// 修订标签
func (controller *ProjectModuleFilesController) ReviseTag() {
	var (
		msg     *protocol.ResponseMessage
		svr     = service.NewProjectModuleFilesService(nil)
		request = &command.ReviseTagRequest{}
	)
	defer func() {
		controller.Resp(msg)
	}()

	if err := controller.JsonUnmarshal(request); err != nil {
		msg = protocol.NewResponseMessage(2, err.Error())
		return
	}

	header := controller.GetRequestHeader(controller.Ctx)
	data, err := svr.ReviseTag(header, request)
	if err != nil {
		log.Error(err)
	}
	msg = protocol.NewResponseMessageData(data, err)
}