| 123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800 |
- package controllers
- import (
- "encoding/json"
- "fmt"
- "strconv"
- "strings"
- "time"
- "git.qianqiusoft.com/qianqiusoft/light-apiengine/models"
- "git.qianqiusoft.com/qianqiusoft/light-apiengine/entitys"
- sysmodel "git.qianqiusoft.com/qianqiusoft/light-apiengine/models"
- "git.qianqiusoft.com/qianqiusoft/light-apiengine/utils"
- )
- //https://www.kancloud.cn/xormplus/xorm/167077
- // _Login
- // @Title _Login
- // @Description 用户登录
- // @Param logininfo false "登录信息"
- // @Success 200 {object} sysmodel.Account
- // @Failure 403 :id is empty
- func System_Login(c *SystemController) {
- var logininfo sysmodel.LoginInfo
- c.Ctx.BindJSON(&logininfo)
- __none_func_system__(logininfo)
- fmt.Println(logininfo)
- var user sysmodel.SysUser
- ret, err := c.Db.SQL(sysmodel.SqlUserLogin, logininfo.Account).Get(&user)
- if ret && err == nil {
- //TODO check password
- timestamp := uint64(time.Now().UnixNano())
- md5Pwd := utils.HashPassword(logininfo.Password, "")
- //密码错误
- if !strings.EqualFold(user.Password, md5Pwd) {
- c.Ctx.JSON(200, sysmodel.SysReturn{400, "passowrd incorrect!", nil})
- return
- }
- token := &entitys.Token{}
- if v := utils.GlobalTokenStore.Get(logininfo.Account + user.Domain); v == nil {
- timestamp_str := strconv.FormatUint(timestamp, 10)
- sec_tooken := utils.GenerateToken(logininfo.Account + timestamp_str)
- token.AccessToken = sec_tooken
- token.RefreshToken = sec_tooken
- token.LoginID = logininfo.Account
- token.UserId = user.Id
- token.Result = 200
- //token.Password = pwd
- token.ServerIp = ""
- token.Domain = user.Domain
- utils.GlobalTokenStore.Set(sec_tooken, token)
- //设置session
- //fmt.Println("----------set token ----------", token.AccessToken)
- //session := sessions.Default(c.Ctx)
- //session.Set("token", token.AccessToken)
- //session.Save()
- } else {
- token = v
- }
- data := sysmodel.LoginReturnInfo{user.Id, user.LoginId, token.AccessToken,user.Type}
- c.Ctx.JSON(200, sysmodel.SysReturn{200, "", data})
- } else {
- //fmt.Println(err.Error())
- c.Ctx.JSON(200, sysmodel.SysReturn{400, "username or passowrd incorrect!", nil})
- }
- }
- // _Logout
- // @Title _Logout
- // @Description 用户退出
- // @Success 200 {object} sysmodel.Account
- // @Failure 403 :id is empty
- func System_Logout(c *SystemController) {
- token := c.Ctx.GetHeader("token")
- fmt.Println("delete token: ", token)
- utils.GlobalTokenStore.Remove(token)
- ret := __none_func_system__()
- if ret {
- c.Ctx.JSON(200, sysmodel.SysReturn{200, "", nil})
- } else {
- c.Ctx.JSON(200, sysmodel.SysReturn{500, "", nil})
- }
- }
- // _GetNavTree
- // @Title _GetNavTree
- // @Description 获取导航菜单
- // @Param user string false "用户id"
- // @Success 200 {object} models.Account
- // @Failure 403 :id is empty
- func System_GetNavTree(c *SystemController) {
- user_id := c.Ctx.GetString("user_id")
- ret := __none_func_system__(user_id)
- var menus []sysmodel.SysMenuTree
- c.Db.SQL(sysmodel.Selectall_nav_tree, user_id).Find(&menus)
- var menutree []sysmodel.SysMenuTree
- finChildrenMenu(&menus, "", nil, &menutree)
- for i := 0; i < len(menutree); i++ {
- finChildrenMenu(&menus, menutree[i].Id, &menutree[i], &menutree)
- }
- if ret {
- c.Ctx.JSON(200, sysmodel.SysReturn{200, "", menutree})
- }
- }
- // _GetMenuTree
- // @Title _GetMenuTree
- // @Description 获取系统菜单
- // @Param user string false "用户id"
- // @Success 200 {object} sysmodel.Account
- // @Failure 403 :id is empty
- func System_GetMenuTree(c *SystemController) {
- user := c.Ctx.Param(":user")
- ret := __none_func_system__(user)
- var menus []sysmodel.SysMenuTree
- c.Db.SQL(sysmodel.Selectall_sys_menu).Find(&menus)
- var menutree []sysmodel.SysMenuTree
- finChildrenMenu(&menus, "", nil, &menutree)
- for i := 0; i < len(menutree); i++ {
- finChildrenMenu(&menus, menutree[i].Id, &menutree[i], &menutree)
- }
- if ret {
- c.Ctx.JSON(200, sysmodel.SysReturn{200, "", menutree})
- }
- }
- // _GetOrgTree
- // @Title _GetOrgTree
- // @Description 获取组织架构树
- // @Success 200 {object} sysmodel.Account
- // @Failure 403 :id is empty
- func System_GetOrgTree(c *SystemController) {
- ret := __none_func_system__()
- var orgs []sysmodel.SysOrgTree
- c.Db.SQL(sysmodel.Selectall_sys_org).Find(&orgs)
- var orgtree []sysmodel.SysOrgTree
- finChildrenOrg(&orgs, "", nil, &orgtree)
- for i := 0; i < len(orgtree); i++ {
- finChildrenOrg(&orgs, orgtree[i].Id, &orgtree[i], &orgtree)
- }
- if ret {
- c.Ctx.JSON(200, sysmodel.SysReturn{200, "", orgtree})
- } else {
- c.Ctx.JSON(200, sysmodel.SysReturn{500, "", nil})
- }
- }
- func finChildrenOrg(menus *[]sysmodel.SysOrgTree, parent string, parent_menu *sysmodel.SysOrgTree, menutree *[]sysmodel.SysOrgTree) {
- for _, m := range *menus {
- if m.Parent == parent {
- if parent_menu == nil {
- *menutree = append(*menutree, m)
- //finChildrenMenu(menus, m.Id, menutree[len(*menutree)-1], menutree)
- } else {
- parent_menu.Children = append(parent_menu.Children, m)
- finChildrenOrg(menus, m.Id, &parent_menu.Children[len(parent_menu.Children)-1], menutree)
- }
- }
- }
- }
- func finChildrenMenu(menus *[]sysmodel.SysMenuTree, parent string, parent_menu *sysmodel.SysMenuTree, menutree *[]sysmodel.SysMenuTree) {
- for _, m := range *menus {
- if m.Parent == parent {
- if parent_menu == nil {
- m.Level = 0
- m.ParentName = ""
- *menutree = append(*menutree, m)
- //finChildrenMenu(menus, m.Id, menutree[len(*menutree)-1], menutree)
- } else {
- m.Level = parent_menu.Level + 1
- m.ParentName = parent_menu.Name
- parent_menu.Children = append(parent_menu.Children, m)
- finChildrenMenu(menus, m.Id, &parent_menu.Children[len(parent_menu.Children)-1], menutree)
- }
- }
- }
- }
- // _FindUserPage
- // @Title _FindUserPage
- // @Description 获取用户分布数据
- // @Param page false "分页参数"
- // @Success 200 {object} sysmodel.Account
- // @Failure 403 :id is empty
- func System_FindUserPage(c *SystemController) {
- var getpageinfo sysmodel.GetPageInfo
- c.Ctx.BindJSON(&getpageinfo)
- __none_func_system__(getpageinfo)
- page := sysmodel.PageResult{}
- var users []sysmodel.UserInfo
- dbSession := c.Db.Table("sys_user")
- dbSession.Select("sys_user.*, sys_org.name org_name")
- countSession := c.Db.Table("sys_user")
- JoinTables := []models.Join{}
- //JoinTables = append(JoinTables, models.Join{TabelName: "sys_user_role", Condition: "sys_user_role.user_id = sys_user.id", JoinOperator: "left"})
- //JoinTables = append(JoinTables, models.Join{TabelName: "sys_role", Condition: "sys_user_role.role_id = sys_role.id", JoinOperator: "left"})
- JoinTables = append(JoinTables, models.Join{TabelName: "sys_org", Condition: "sys_org.id = sys_user.org_id", JoinOperator: "left"})
- for _, join := range JoinTables {
- dbSession = dbSession.Join(join.JoinOperator, join.TabelName, join.Condition)
- countSession = countSession.Join(join.JoinOperator, join.TabelName, join.Condition)
- }
- whereStr, datas, err := getpageinfo.Filter.Parse("")
- dbSession = dbSession.Where(whereStr, datas...)
- countSession = countSession.Where(whereStr, datas...)
- sidx := strings.Split(getpageinfo.Sidx, ",")
- for _, order := range sidx {
- order = strings.TrimSpace(order)
- if len(order) == 0 {
- continue
- }
- if strings.ToLower(getpageinfo.Sord) == "desc" {
- dbSession = dbSession.OrderBy(order + " desc")
- } else {
- dbSession = dbSession.OrderBy(order + " asc")
- }
- }
- totalPage, _ := countSession.Count()
- dbSession.Limit(getpageinfo.PageSize, (getpageinfo.PageNum-1)*getpageinfo.PageSize).Find(&users)
- //查找每个用户的角色
- for i, user := range users {
- roles := []sysmodel.UserInfo{}
- err := c.Db.SQL(sysmodel.SqlSelectUserRoles, user.Id).Find(&roles)
- if err != nil {
- fmt.Println("----", err.Error())
- continue
- }
- users[i].UserRole = roles[0].UserRole
- users[i].RoleName = roles[0].RoleName
- }
- page.Content = users
- page.PageSize = getpageinfo.PageSize
- page.PageNum = getpageinfo.PageNum
- page.TotalSize = int(totalPage)
- if err == nil {
- c.Ctx.JSON(200, sysmodel.SysReturn{200, "", page})
- } else {
- fmt.Println(err.Error())
- c.Ctx.JSON(200, sysmodel.SysReturn{500, "", nil})
- }
- }
- // _AddUser
- // @Title _AddUser
- // @Description 添加用户
- // @Param login_id string false "登录ID"
- // @Param password string false "密码"
- // @Param org_id string false "组织ID"
- // @Param email string false "邮箱"
- // @Success 200 {object} models.Account
- // @Failure 403 :id is empty
- func System_AddUser(c *SystemController) {
- var user sysmodel.SysUser
- c.Ctx.BindJSON(&user)
- fmt.Println(user.LoginId, "-----add user-----", user.Password, " --- ", user.OrgId)
- //查找login_id是否存在
- oldUser := new(sysmodel.SysUser)
- count, _ := c.Db.SQL("select * from sys_user").Where("login_id = ?", user.LoginId).Count(&oldUser)
- if count > 1 {
- if oldUser.DelFlag == 1 {
- oldUser.DelFlag = 0
- _, err := c.Db.Id("id").Cols("del_flag").Update(&oldUser)
- if err != nil {
- c.Ctx.JSON(200, sysmodel.SysReturn{500, "login_id exit, update err: " + err.Error(), nil})
- }
- return
- } else {
- c.Ctx.JSON(200, sysmodel.SysReturn{500, "login_id exit", nil})
- return
- }
- }
- user_id := c.Ctx.GetString("user_id")
- user.Id = utils.NewUUID()
- user.Name = user.LoginId
- user.CreateTime = time.Now()
- user.LastUpdateDate = time.Now()
- user.CreateBy = user_id
- user.LastUpdateBy = user_id
- user.DelFlag = 0
- user.Password = utils.HashPassword(user.Password, "")
- _, err := c.Db.Insert(&user)
- ret := __none_func_system__(user.LoginId, user.Password, user.OrgId, user.Email)
- if ret && err == nil {
- c.Ctx.JSON(200, sysmodel.SysReturn{200, "", nil})
- } else {
- c.Ctx.JSON(200, sysmodel.SysReturn{500, err.Error(), nil})
- }
- }
- // _DelUser
- // @Title _DelUser
- // @Description 删除用户
- // @Param id string false "用户ID"
- // @Success 200 {object} models.Account
- // @Failure 403 :id is empty
- func System_DelUser(c *SystemController) {
- type Param struct {
- Id string `json:"id"`
- }
- var params []Param
- c.Ctx.BindJSON(¶ms)
- ids := []string{}
- for _, param := range params {
- ids = append(ids, param.Id)
- }
- session := c.Db.NewSession()
- defer session.Close()
- //_, err := c.Db.Table(new(models.SysUser)).ID(param.Id).Update(map[string]interface{}{"del_flag": 0})
- _, err := c.Db.Table(new(models.SysUser)).In("id", ids).Update(map[string]interface{}{"del_flag": 1})
- if err != nil {
- session.Rollback()
- c.Ctx.JSON(200, sysmodel.SysReturn{500, err.Error(), nil})
- return
- }
- _, err = c.Db.Table(new(models.SysUserRole)).In("user_id", ids).Update(map[string]interface{}{"del_flag": 1})
- if err != nil {
- session.Rollback()
- c.Ctx.JSON(200, sysmodel.SysReturn{500, err.Error(), nil})
- return
- }
- session.Commit()
- ret := __none_func_system__()
- if ret {
- c.Ctx.JSON(200, sysmodel.SysReturn{200, "", nil})
- } else {
- c.Ctx.JSON(200, sysmodel.SysReturn{500, "", nil})
- }
- }
- // _UpdateUser
- // @Title _UpdateUser
- // @Description 修改用户
- // @Param login_id string false "登录ID"
- // @Param password string false "密码"
- // @Param org_id string false "组织ID"
- // @Param email string false "邮箱"
- // @Success 200 {object} models.Account
- // @Failure 403 :id is empty
- func System_UpdateUser(c *SystemController) {
- user_id := c.Ctx.GetString("user_id")
- var userInfo sysmodel.UserInfo
- err := c.Ctx.BindJSON(&userInfo)
- if err != nil{
- c.Ctx.JSON(500, sysmodel.SysReturn{500, err.Error(), nil})
- return;
- }
- session := c.Db.NewSession()
- defer session.Close()
- //1、删除用户角色
- _, err = c.Db.SQL(sysmodel.SqlDeleteUserRoles, userInfo.Id).Execute()
- if err != nil {
- session.Rollback()
- c.Ctx.JSON(200, sysmodel.SysReturn{500, err.Error(), nil})
- return
- }
- //2、修改角色
- userRoles := []models.SysUserRole{}
- if userInfo.UserRole != "" {
- err = json.Unmarshal([]byte(userInfo.UserRole), &userRoles)
- if err != nil {
- session.Rollback()
- c.Ctx.JSON(200, sysmodel.SysReturn{500, err.Error(), nil})
- return
- }
- }
- for i, _ := range userRoles {
- userRoles[i].Id = utils.NewUUID()
- userRoles[i].CreateBy = user_id
- userRoles[i].LastUpdateBy = user_id
- userRoles[i].CreateTime = time.Now()
- userRoles[i].LastUpdateDate = time.Now()
- userRoles[i].DelFlag = 0
- }
- _, err = c.Db.Insert(userRoles)
- if err != nil {
- session.Rollback()
- c.Ctx.JSON(200, sysmodel.SysReturn{500, err.Error(), nil})
- return
- }
- //3、更新用户信息
- _, err = c.Db.Table(new(models.SysUser)).ID(userInfo.Id).Update(map[string]interface{}{"name": userInfo.Name, "email": userInfo.Email, "org_id": userInfo.OrgId, "last_update_by": user_id, "last_update_date": time.Now()})
- if err != nil {
- session.Rollback()
- c.Ctx.JSON(200, sysmodel.SysReturn{500, err.Error(), nil})
- return
- }
- session.Commit()
- ret := __none_func_system__()
- if ret {
- c.Ctx.JSON(200, sysmodel.SysReturn{200, "", nil})
- } else {
- c.Ctx.JSON(200, sysmodel.SysReturn{500, "", nil})
- }
- }
- // _AddRole
- // @Title _AddRole
- // @Description 添加角色
- // @Param name string false "角色名称"
- // @Param remark string false "备注"
- // @Success 200 {object} models.Account
- // @Failure 403 :id is empty
- func System_AddRole(c *SystemController) {
- var role models.SysRole
- c.Ctx.BindJSON(&role)
- user_id := c.Ctx.GetString("user_id")
- role.Id = utils.NewUUID()
- role.DelFlag = 0
- role.CreateBy = user_id
- role.LastUpdateBy = user_id
- role.CreateTime = time.Now()
- role.LastUpdateDate = time.Now()
- _, err := c.Db.Insert(&role)
- ret := __none_func_system__()
- if ret && err == nil {
- c.Ctx.JSON(200, sysmodel.SysReturn{200, "", nil})
- } else {
- c.Ctx.JSON(200, sysmodel.SysReturn{500, err.Error(), nil})
- }
- }
- // _DelRole
- // @Title _DelRole
- // @Description 添加角色
- // @Param id string false "角色ID"
- // @Success 200 {object} models.Account
- // @Failure 403 :id is empty
- func System_DelRole(c *SystemController) {
- type Param struct {
- Id string `json:"id"`
- }
- var params []Param
- c.Ctx.BindJSON(¶ms)
- fmt.Println(params, "-----------")
- ids := []string{}
- for _, param := range params {
- ids = append(ids, param.Id)
- }
- _, err := c.Db.Table(new(models.SysRole)).In("id", ids).Update(map[string]interface{}{"del_flag": 1})
- if err != nil {
- c.Ctx.JSON(200, sysmodel.SysReturn{500, err.Error(), nil})
- return
- }
- ret := __none_func_system__()
- if ret {
- c.Ctx.JSON(200, sysmodel.SysReturn{200, "", nil})
- } else {
- c.Ctx.JSON(200, sysmodel.SysReturn{500, "", nil})
- }
- }
- // _UpdateRole
- // @Title _UpdateRole
- // @Description 修改角色
- // @Param id string false "角色ID"
- // @Param name string false "角色名称"
- // @Param remark string false "备注"
- // @Success 200 {object} models.Account
- // @Failure 403 :id is empty
- func System_UpdateRole(c *SystemController) {
- var role models.SysRole
- c.Ctx.BindJSON(&role)
- user_id := c.Ctx.GetString("user_id")
- role.LastUpdateBy = user_id
- role.LastUpdateDate = time.Now()
- c.Db.ID(role.Id).Update(&role)
- ret := __none_func_system__()
- if ret {
- c.Ctx.JSON(200, sysmodel.SysReturn{200, "", nil})
- } else {
- c.Ctx.JSON(200, sysmodel.SysReturn{500, "", nil})
- }
- }
- // _FindRolePage
- // @Title _FindRolePage
- // @Description 角色分页
- // @Param page false "分页参数"
- // @Success 200 {object} models.Account
- // @Failure 403 :id is empty
- func System_FindRolePage(c *SystemController) {
- var getpageinfo models.GetPageInfo
- c.Ctx.BindJSON(&getpageinfo)
- page := sysmodel.SysRolePageInfo{}
- var roles []sysmodel.SysRole
- err := c.Db.SQL(sysmodel.Selectall_sys_role).Limit(getpageinfo.PageSize, (getpageinfo.PageNum-1)*getpageinfo.PageSize).Find(&roles)
- if err != nil {
- c.Ctx.JSON(200, sysmodel.SysReturn{500, err.Error(), nil})
- return
- }
- fmt.Println("-----------", len(roles))
- page.Content = roles
- page.PageSize = getpageinfo.PageSize
- page.PageNum = getpageinfo.PageNum
- page.TotalSize = 1
- ret := __none_func_system__(getpageinfo)
- if ret {
- c.Ctx.JSON(200, sysmodel.SysReturn{200, "", page})
- } else {
- c.Ctx.JSON(200, sysmodel.SysReturn{500, "", nil})
- }
- }
- // _FindRoleMenu
- // @Title _FindRoleMenu
- // @Description 查找角色权限
- // @Param user string false "用户id"
- // @Success 200 {object} models.Account
- // @Failure 403 :id is empty
- func System_FindRoleMenu(c *SystemController) {
- role_id, b := c.Ctx.GetQuery("roleId")
- if !b {
- c.Ctx.JSON(200, sysmodel.SysReturn{500, "roleId is null", nil})
- return
- }
- menus := []models.SysMenu{}
- c.Db.SQL(models.SqlFindRoleMenu, role_id).Find(&menus)
- ret := __none_func_system__()
- if ret {
- c.Ctx.JSON(200, sysmodel.SysReturn{200, "", menus})
- } else {
- c.Ctx.JSON(200, sysmodel.SysReturn{500, "", nil})
- }
- }
- // _SaveRoleMenu
- // @Title _SaveRoleMenu
- // @Description 保存角色权限
- // @Param role_menu string false "角色权限"
- // @Success 200 {object} models.Account
- // @Failure 403 :id is empty
- func System_SaveRoleMenu(c *SystemController) {
- var saverolemenu []models.SysRoleMenu
- c.Ctx.BindJSON(&saverolemenu)
- if len(saverolemenu) < 1 {
- c.Ctx.JSON(200, sysmodel.SysReturn{500, "role menu length is error", nil})
- return
- }
- session := c.Db.NewSession()
- defer session.Close()
- err := session.Begin()
- //删除角色下的menu
- _, err = c.Db.Exec("delete from sys_role_menu where role_id = ?", saverolemenu[0].RoleId)
- //_, err = c.Db.Exec("delete from sys_role_menu where id = 1")
- if err != nil {
- session.Rollback()
- c.Ctx.JSON(200, sysmodel.SysReturn{500, err.Error(), nil})
- return
- }
- for i, _ := range saverolemenu {
- saverolemenu[i].Id = utils.NewUUID()
- saverolemenu[i].DelFlag = 1
- }
- _, err = c.Db.Insert(&saverolemenu)
- if err != nil {
- session.Rollback()
- c.Ctx.JSON(200, sysmodel.SysReturn{500, err.Error(), nil})
- return
- }
- session.Commit()
- ret := __none_func_system__(&saverolemenu)
- if ret {
- c.Ctx.JSON(200, sysmodel.SysReturn{200, "", nil})
- } else {
- c.Ctx.JSON(200, sysmodel.SysReturn{500, "", nil})
- }
- }
- // _RoleAll
- // @Title _RoleAll
- // @Description 查找所有角色
- // @Success 200 {object} models.Account
- // @Failure 403 :id is empty
- func System_RoleAll(c *SystemController) {
- var roles []sysmodel.SysRole
- err := c.Db.SQL(sysmodel.Selectall_sys_role).Find(&roles)
- ret := __none_func_system__()
- if ret && err == nil {
- c.Ctx.JSON(200, sysmodel.SysReturn{200, "", roles})
- } else {
- c.Ctx.JSON(200, sysmodel.SysReturn{500, err.Error(), nil})
- }
- }
- // _FindPermissions
- // @Title _FindPermissions
- // @Description 查找用户权限
- // @Success 200 {object} models.Account
- // @Failure 403 :id is empty
- func System_FindPermissions(c *SystemController) {
- user_id := c.Ctx.GetString("user_id")
- //result, err := c.Db.Query(models.SqlFindUserPermissions, op.UserId)
- result, err := c.Db.QueryString(models.SqlFindUserPermissions, user_id)
- strs := []string{}
- for _, v := range result {
- strs = append(strs, v["perms"])
- }
- if err != nil {
- c.Ctx.JSON(200, sysmodel.SysReturn{500, err.Error(), nil})
- }
- ret := __none_func_system__()
- //strs = []string{"sys:menu:add", "sys:menu:view", "sys:menu:edit", "sys:menu:delete", "sys:user:edit", "sys:user:delete", "sys:user:add", "sys:role:view", "sys:role:edit", "sys:role:delete", "sys:role:add"}
- if ret {
- c.Ctx.JSON(200, sysmodel.SysReturn{200, "", strs})
- } else {
- c.Ctx.JSON(200, sysmodel.SysReturn{500, "", nil})
- }
- }
- // _AddMenu
- // @Title _AddMenu
- // @Description 添加菜单
- // @Param string false "菜单"
- // @Success 200 {object} models.Account
- // @Failure 403 :id is empty
- func System_AddMenu(c *SystemController) {
- var sysmenu models.SysMenu
- c.Ctx.BindJSON(&sysmenu)
- user_id := c.Ctx.GetString("user_id")
- sysmenu.Id = utils.NewUUID()
- sysmenu.CreateBy = user_id
- sysmenu.LastUpdateBy = user_id
- sysmenu.LastUpdateDate = time.Now()
- sysmenu.CreateTime = time.Now()
- sysmenu.DelFlag = 0
- _, err := c.Db.Insert(&sysmenu)
- if err != nil {
- c.Ctx.JSON(200, sysmodel.SysReturn{500, err.Error(), nil})
- return
- }
- ret := __none_func_system__(sysmenu)
- if ret {
- c.Ctx.JSON(200, sysmodel.SysReturn{200, "", nil})
- } else {
- c.Ctx.JSON(200, sysmodel.SysReturn{500, "", nil})
- }
- }
- // _DelMenu
- // @Title _DelMenu
- // @Description 删除菜单
- // @Param id string false "菜单ID"
- // @Success 200 {object} models.Account
- // @Failure 403 :id is empty
- func System_DelMenu(c *SystemController) {
- type Param struct {
- Id string `json:"id"`
- }
- var params []Param
- c.Ctx.BindJSON(¶ms)
- fmt.Println(params, "-----------")
- ids := []string{}
- for _, param := range params {
- ids = append(ids, param.Id)
- }
- _, err := c.Db.Table(new(models.SysMenu)).In("id", ids).Update(map[string]interface{}{"del_flag": 0})
- if err != nil {
- c.Ctx.JSON(200, sysmodel.SysReturn{500, err.Error(), nil})
- return
- }
- ret := __none_func_system__()
- if ret {
- c.Ctx.JSON(200, sysmodel.SysReturn{200, "", nil})
- } else {
- c.Ctx.JSON(200, sysmodel.SysReturn{500, "", nil})
- }
- }
- // _UpdateMenu
- // @Title _UpdateMenu
- // @Description 更新菜单
- // @Param string false "菜单"
- // @Success 200 {object} models.Account
- // @Failure 403 :id is empty
- func System_UpdateMenu(c *SystemController) {
- var sysmenu models.SysMenu
- c.Ctx.BindJSON(&sysmenu)
- user_id := c.Ctx.GetString("user_id")
- sysmenu.LastUpdateBy = user_id
- sysmenu.LastUpdateDate = time.Now()
- _, err := c.Db.ID(sysmenu.Id).Update(&sysmenu)
- if err != nil {
- c.Ctx.JSON(200, sysmodel.SysReturn{500, err.Error(), nil})
- return
- }
- ret := __none_func_system__(sysmenu)
- if ret {
- c.Ctx.JSON(200, sysmodel.SysReturn{200, "", nil})
- } else {
- c.Ctx.JSON(200, sysmodel.SysReturn{500, "", nil})
- }
- }
- func __none_func_system__(params ...interface{}) bool {
- return true
- }
|