xps-server-go/web/controllers/api_gateway_controller.go

package controllers

import (
    "github.com/kataras/iris/v12/mvc"
    "xps/cache"
    "xps/constant"
    "xps/service"
)

type ApiGatewayController struct {
    Base
    Service service.ApiGatewayService
}

func (c *ApiGatewayController) BeforeActivation(b mvc.BeforeActivation) {
    b.Handle("GET",         "/{objectCode:string}/{oamCode:string}",           "Get"     )
    b.Handle("POST",        "/{objectCode:string}/{oamCode:string}",           "Post"    )
    b.Handle("PUT",         "/{objectCode:string}/{oamCode:string}",           "Put"     )
    b.Handle("PATCH",       "/{objectCode:string}/{oamCode:string}",           "Patch"   )
    b.Handle("DELETE",      "/{objectCode:string}/{oamCode:string}",           "Delete"  )
}

func (c *ApiGatewayController) Get(objectCode, oamCode string)*JsonResult {
    oamInfo, err := cache.GetApiData(objectCode, oamCode)
    if err != nil {
        return ResultErr(err.Error(), nil)
    }
    
    m       := c.buildParams()
    oamType := oamInfo.OamType
    if oamType == constant.OAM_GET_ONE {
        data, err := c.Service.Get(objectCode, oamCode, m)
        if err != nil {
            return ResultErr(err.Error(), nil)
        } else {
            return ResultOk("获取成功", data)
        }
    }
    if oamType == constant.OAM_GET_LIST{
        data, err := c.Service.GetList(objectCode, oamCode, m)
        if err != nil {
            return ResultErr(err.Error(), nil)
        } else {
            return ResultOk("获取成功", data)
        }
    }
    if oamType == constant.OAM_GET_PAGE {
        data, err := c.Service.GetPage(objectCode, oamCode, m)
        if err != nil {
            return ResultErr(err.Error(), nil)
        } else {
            return ResultOk("获取成功", data)
        }
    }
    
    return ResultErr("方法不存在", nil)
}


func (c *ApiGatewayController) Post(objectCode, oamCode string)*JsonResult {
    m, err := c.GetJsonData()
    if err != nil {
        return ResultErr(err.Error(), nil)
    }
    
    err = c.Service.Create(objectCode, oamCode, m)
    if err != nil {
        return ResultErr(err.Error(), nil)
    } else {
        return ResultOk("创建成功", nil)
    }
}

func (c *ApiGatewayController) Put(objectCode, oamCode string)*JsonResult {
    m, err := c.GetJsonData()
    if err != nil {
        return ResultErr(err.Error(), nil)
    }
    
    err = c.Service.Update(objectCode, oamCode, m)
    if err != nil {
        return ResultErr(err.Error(), nil)
    } else {
        return ResultOk("更新成功", nil)
    }
}

func (c *ApiGatewayController) Patch(objectCode, oamCode string)*JsonResult {
    m, err := c.GetJsonData()
    if err != nil {
        return ResultErr(err.Error(), nil)
    }
    
    err = c.Service.Patch(objectCode, oamCode, m)
    if err != nil {
        return ResultErr(err.Error(), nil)
    } else {
        return ResultOk("更新成功", nil)
    }
}

func (c *ApiGatewayController) Delete(objectCode, oamCode string)*JsonResult {
    m, err := c.GetJsonData()
    if err != nil {
        return ResultErr(err.Error(), nil)
    }
    
    err = c.Service.Delete(objectCode, oamCode, m)
    if err != nil {
        return ResultErr(err.Error(), nil)
    } else {
        return ResultOk("删除成功", nil)
    }
}