project.go

package project

import (
	"net/http"
	"strconv"

	goku_handler "github.com/eolinker/goku-api-gateway/goku-handler"

	"github.com/eolinker/goku-api-gateway/console/controller"
	"github.com/eolinker/goku-api-gateway/console/module/project"
)

const operationProject = "apiManagement"

//Handlers handlers
type Handlers struct {
}

//Handlers handlers
func (h *Handlers) Handlers(factory *goku_handler.AccountHandlerFactory) map[string]http.Handler {
	return map[string]http.Handler{
		"/add":              factory.NewAccountHandleFunction(operationProject, true, AddProject),
		"/edit":             factory.NewAccountHandleFunction(operationProject, true, EditProject),
		"/delete":           factory.NewAccountHandleFunction(operationProject, true, DeleteProject),
		"/getInfo":          factory.NewAccountHandleFunction(operationProject, false, GetProjectInfo),
		"/getList":          factory.NewAccountHandleFunction(operationProject, false, GetProjectList),
		"/strategy/getList": factory.NewAccountHandleFunction(operationProject, false, GetAPIListFromProjectNotInStrategy),
		"/batchDelete":      factory.NewAccountHandleFunction(operationProject, true, BatchDeleteProject),
	}
}

//NewHandlers new handlers
func NewHandlers() *Handlers {
	return &Handlers{}
}

//AddProject 新建项目
func AddProject(httpResponse http.ResponseWriter, httpRequest *http.Request) {

	projectName := httpRequest.PostFormValue("projectName")
	if projectName == "" {
		controller.WriteError(httpResponse,
			"270002",
			"project",
			"[ERROR]Illegal projectName!",
			nil)
		return
	}
	flag, result, err := project.AddProject(projectName)
	if !flag {

		controller.WriteError(httpResponse,
			"270000",
			"project",
			result.(string),
			err)
		return

	}

	controller.WriteResultInfo(httpResponse, "project", "projectID", result)

	return
}

//EditProject 修改项目信息
func EditProject(httpResponse http.ResponseWriter, httpRequest *http.Request) {

	projectName := httpRequest.PostFormValue("projectName")
	projectID := httpRequest.PostFormValue("projectID")
	if projectName == "" {
		controller.WriteError(httpResponse,
			"270002",
			"project",
			"[ERROR]Illegal projectName!",
			nil)
		return
	}
	id, err := strconv.Atoi(projectID)
	if err != nil {
		controller.WriteError(httpResponse,
			"270001",
			"project",
			"[ERROR]Illegal projectID!",
			err)
		return

	}
	flag, result, err := project.EditProject(projectName, id)
	if !flag {

		controller.WriteError(httpResponse,
			"270000",
			"project",
			result,
			err)
		return

	}

	controller.WriteResultInfo(httpResponse, "project", "", nil)

	return
}

//DeleteProject 删除项目信息
func DeleteProject(httpResponse http.ResponseWriter, httpRequest *http.Request) {

	projectID := httpRequest.PostFormValue("projectID")

	id, err := strconv.Atoi(projectID)
	if err != nil {
		controller.WriteError(httpResponse,
			"270001",
			"project",
			"[ERROR]Illegal projectID!",
			err)
		return

	}
	flag, result, err := project.DeleteProject(id)
	if !flag {

		controller.WriteError(httpResponse,
			"270000",
			"project",
			result,
			err)
		return

	}
	controller.WriteResultInfo(httpResponse, "project", "", nil)

	return
}

//BatchDeleteProject 删除项目信息
func BatchDeleteProject(httpResponse http.ResponseWriter, httpRequest *http.Request) {

	projectIDList := httpRequest.PostFormValue("projectIDList")

	flag, result, err := project.BatchDeleteProject(projectIDList)
	if !flag {

		controller.WriteError(httpResponse,
			"270000",
			"project",
			result,
			err)
		return

	}

	controller.WriteResultInfo(httpResponse, "project", "", nil)
	return
}

//GetProjectInfo 获取项目信息
func GetProjectInfo(httpResponse http.ResponseWriter, httpRequest *http.Request) {

	projectID := httpRequest.PostFormValue("projectID")

	id, err := strconv.Atoi(projectID)
	if err != nil {
		controller.WriteError(httpResponse,
			"270001",
			"project",
			"[ERROR]Illegal projectID!",
			err)
		return
	}
	flag, result, err := project.GetProjectInfo(id)
	if !flag {

		controller.WriteError(httpResponse,
			"270000",
			"project",
			"[ERROR]The project information does not exist!",
			err)
		return

	}
	controller.WriteResultInfo(httpResponse, "project", "projectInfo", result)

	return
}

//GetProjectList 获取项目列表
func GetProjectList(httpResponse http.ResponseWriter, httpRequest *http.Request) {

	httpRequest.ParseForm()
	keyword := httpRequest.FormValue("keyword")

	flag, result, err := project.GetProjectList(keyword)
	if !flag {

		controller.WriteError(httpResponse,
			"270000",
			"project",
			"[ERROR]Empty project list!",
			err)
		return

	}

	controller.WriteResultInfo(httpResponse, "project", "projectList", result)

	return
}

//GetAPIListFromProjectNotInStrategy 获取项目列表中没有被策略组绑定的接口
func GetAPIListFromProjectNotInStrategy(httpResponse http.ResponseWriter, httpRequest *http.Request) {

	flag, result, err := project.GetAPIListFromProjectNotInStrategy()
	if !flag {

		controller.WriteError(httpResponse,
			"270000",
			"project",
			"[ERROR]Empty project list!",
			err)
		return

	}
	controller.WriteResultInfo(httpResponse, "project", "projectList", result)

}