xps-server-g5/pkg/system/controller/oc_controller.go

package controller

import (
    "github.com/kataras/iris/v12/mvc"
    "xps/pkg/system/datamodel"
    "xps/pkg/system/service"
    "xps/pkg/system/viewmodel"
)

type OcController struct {
    Base
    Service service.OcService
}

func (c *OcController) BeforeActivation(b mvc.BeforeActivation) {
    b.Handle("GET",     "/",                                            "GetList")
    b.Handle("GET",     "/page",                                        "GetPage")
    b.Handle("GET",     "/{ocId:int64}",                                "GetById")
    b.Handle("POST",    "/add",                                         "Create")
    b.Handle("PUT",     "/update",                                      "Update")
    b.Handle("DELETE",  "/{ocId:int64}",                                "DeleteByID")
    b.Handle("GET",     "/getAdmin/{ocId:int64}",                       "GetAdmin")
    b.Handle("POST",    "/addAdmin",                                    "CreateAdmin")
    b.Handle("PUT",     "/updateAdmin",                                 "UpdateAdmin")
    b.Handle("PUT",     "/resetAdminPwd/{ocId:int64}/{adminId:int64}",  "ResetAdminPwd")
    b.Handle("PUT",     "/updateStatus/{ocId:int64}/{status:int64}",    "UpdateStatus")
    b.Handle("PUT",     "/updateLicStatus/{ocId:int64}/{status:int64}", "UpdateLicStatus")
}

func (c *OcController) GetList() *JsonResult {
    params   := c.buildParams()
    ocTypeId := c.Ctx.URLParamInt64Default("ocTypeId", 0)
    if ocTypeId > 0 {
        params["ocTypeId"] = ocTypeId
    }

    ocCatId := c.Ctx.URLParamInt64Default("ocCatId", 0)
    if ocCatId > 0 {
        params["ocCatId"] = ocCatId
    }
    data, err := c.Service.GetList(params)
    if err != nil {
        return ResultErr(err.Error(), nil)
    } else {
        return ResultOk("获取成功", data)
    }
}

func (c *OcController) GetPage() *JsonResult {
    params   := c.buildParams()
    ocTypeId := c.Ctx.URLParamInt64Default("ocTypeId", 0)
    if ocTypeId > 0 {
        params["ocTypeId"] = ocTypeId
    }

    ocCatId := c.Ctx.URLParamInt64Default("ocCatId", 0)
    if ocCatId > 0 {
        params["ocCatId"] = ocCatId
    }
    data, err := c.Service.GetPage(params)
    if err != nil {
        return ResultErr(err.Error(), nil)
    } else {
        return ResultOk("获取成功", data)
    }
}

func (c *OcController) GetById(ocId int64) *JsonResult {
    data, err := c.Service.GetById(ocId)
    if err != nil {
        return ResultErr(err.Error(), nil)
    } else {
        return ResultOk("获取成功", data)
    }
}

func (c *OcController) Create() *JsonResult {
    userId := c.GetCurUserId()

    o := datamodel.Oc{}
    o.CreatedBy = userId
    if err := c.Ctx.ReadJSON(&o); err != nil {
        return ResultErr("读取数据失败", nil)
    }

    if err := c.Service.Create(&o); err != nil {
        return ResultErr(err.Error(), nil)
    } else {
        return ResultOk("新增成功", nil)
    }
}

func (c *OcController) Update() *JsonResult {
    userId := c.GetCurUserId()

    o := datamodel.Oc{}
    if err := c.Ctx.ReadJSON(&o); err != nil {
        return ResultErr("读取数据失败", nil)
    }

    o.UpdatedBy = userId
    if err := c.Service.Update(&o); err != nil {
        return ResultErr(err.Error(), nil)
    } else {
        return ResultOk("更新成功", nil)
    }
}

func (c *OcController) DeleteByID(ocId int64) *JsonResult {
    userId := c.GetCurUserId()

    m := make(map[string]interface{})
    m["ocId"]      = ocId
    m["deletedBy"] = userId
    if err := c.Service.Delete(m); err != nil {
        return ResultErr(err.Error(), nil)
    } else {
        return ResultOk("删除成功", nil)
    }
}

func (c *OcController) GetAdmin(ocId int64) *JsonResult {
    data, err := c.Service.GetAdmin(ocId)
    if err != nil {
        return ResultErr(err.Error(), nil)
    } else {
        return ResultOk("获取成功", data)
    }
}

func (c *OcController) CreateAdmin() *JsonResult {
    userId := c.GetCurUserId()

    o := viewmodel.OcAdminInfo{}
    o.CreatedBy = userId
    if err := c.Ctx.ReadJSON(&o); err != nil {
        return ResultErr("读取数据失败", nil)
    }

    if err := c.Service.CreateAdmin(&o); err != nil {
        return ResultErr(err.Error(), nil)
    } else {
        return ResultOk("新增成功", nil)
    }
}

func (c *OcController) UpdateAdmin() *JsonResult {
    userId := c.GetCurUserId()

    a := viewmodel.OcAdminInfo{}
    if err := c.Ctx.ReadJSON(&a); err != nil {
        return ResultErr("读取数据失败", nil)
    }

    a.UpdatedBy = userId
    if err := c.Service.UpdateAdmin(&a); err != nil {
        return ResultErr(err.Error(), nil)
    } else {
        return ResultOk("更新成功", nil)
    }
}

func (c *OcController) ResetAdminPwd(ocId, adminId int64) *JsonResult {
    if err := c.Service.ResetAdminPwd(ocId, adminId); err != nil {
        return ResultErr(err.Error(), nil)
    } else {
        return ResultOk("更新成功", nil)
    }
}

func (c *OcController) UpdateStatus(ocId, status int64) *JsonResult {
    if err := c.Service.UpdateStatus(ocId, status); err != nil {
        return ResultErr(err.Error(), nil)
    }
    if status == 1 {
        return ResultOk("激活成功", nil)
    } else {
        return ResultOk("锁定成功", nil)
    }
}

func (c *OcController) UpdateLicStatus(ocId, status int64) *JsonResult {
    if err := c.Service.UpdateLicStatus(ocId, status); err != nil {
        return ResultErr(err.Error(), nil)
    }
    if status == 1 {
        return ResultOk("使能成功", nil)
    } else {
        return ResultOk("关闭成功", nil)
    }
}