SystemController.go 24 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948
  1. package partial
  2. import (
  3. "fmt"
  4. "time"
  5. //"git.qianqiusoft.com/qianqiusoft/light-apiengine/db"
  6. "git.qianqiusoft.com/qianqiusoft/light-apiengine/entitys"
  7. sysmodel "git.qianqiusoft.com/qianqiusoft/light-apiengine/models"
  8. "git.qianqiusoft.com/qianqiusoft/light-apiengine/utils"
  9. )
  10. //https://www.kancloud.cn/xormplus/xorm/167077
  11. // _GetNavTree
  12. // @Title _GetNavTree
  13. // @Description 获取导航菜单
  14. // @Param user string false "用户id"
  15. // @Success 200 {object} models.Account
  16. // @Failure 403 :id is empty
  17. func System_GetNavTree(c *entitys.CtrlContext) {
  18. // set in the login_ware.go
  19. user_id := c.Ctx.GetString("user_id")
  20. var menus []sysmodel.SysMenuTree
  21. if user_id == "187c50a4-caad-4557-80c8-aca81af9f370" {
  22. c.Db.SQL(sysmodel.Selectall_nav_tree_admin).Find(&menus)
  23. } else {
  24. c.Db.SQL(sysmodel.Selectall_nav_tree, user_id).Find(&menus)
  25. }
  26. var menutree []sysmodel.SysMenuTree
  27. finChildrenMenu(&menus, "", nil, &menutree)
  28. for i := 0; i < len(menutree); i++ {
  29. finChildrenMenu(&menus, menutree[i].Id, &menutree[i], &menutree)
  30. }
  31. fmt.Println(menutree)
  32. c.Ctx.JSON(200, sysmodel.SysReturn{200, "", menutree})
  33. }
  34. // _GetMenuTree
  35. // @Title _GetMenuTree
  36. // @Description 获取系统菜单
  37. // @Param user string false "用户id"
  38. // @Success 200 {object} sysmodel.Account
  39. // @Failure 403 :id is empty
  40. func System_GetMenuTree(c *entitys.CtrlContext) {
  41. user := c.Ctx.Param(":user")
  42. ret := __none_func_system__(user)
  43. var menus []sysmodel.SysMenuTree
  44. c.Db.SQL(sysmodel.Selectall_sys_menu).Find(&menus)
  45. var menutree []sysmodel.SysMenuTree
  46. finChildrenMenu(&menus, "", nil, &menutree)
  47. fmt.Println(menutree)
  48. for i := 0; i < len(menutree); i++ {
  49. finChildrenMenu(&menus, menutree[i].Id, &menutree[i], &menutree)
  50. }
  51. if ret {
  52. c.Ctx.JSON(200, sysmodel.SysReturn{200, "", menutree})
  53. }
  54. }
  55. // _GetOrgTree
  56. // @Title _GetOrgTree
  57. // @Description 获取组织架构树
  58. // @Success 200 {object} sysmodel.Account
  59. // @Failure 403 :id is empty
  60. func System_GetOrgTree(c *entitys.CtrlContext) {
  61. ret := __none_func_system__()
  62. var orgs []sysmodel.SysOrgTree
  63. c.Db.SQL(sysmodel.Selectall_sys_org).Find(&orgs)
  64. var orgtree []sysmodel.SysOrgTree
  65. finChildrenOrg(&orgs, "", nil, &orgtree)
  66. for i := 0; i < len(orgtree); i++ {
  67. finChildrenOrg(&orgs, orgtree[i].Id, &orgtree[i], &orgtree)
  68. }
  69. if ret {
  70. c.Ctx.JSON(200, sysmodel.SysReturn{200, "", orgtree})
  71. } else {
  72. c.Ctx.JSON(200, sysmodel.SysReturn{500, "", nil})
  73. }
  74. }
  75. func finChildrenOrg(menus *[]sysmodel.SysOrgTree, parent string, parent_menu *sysmodel.SysOrgTree, menutree *[]sysmodel.SysOrgTree) {
  76. for _, m := range *menus {
  77. if m.Parent == parent {
  78. if parent_menu == nil {
  79. *menutree = append(*menutree, m)
  80. //finChildrenMenu(menus, m.Id, menutree[len(*menutree)-1], menutree)
  81. } else {
  82. parent_menu.Children = append(parent_menu.Children, m)
  83. finChildrenOrg(menus, m.Id, &parent_menu.Children[len(parent_menu.Children)-1], menutree)
  84. }
  85. }
  86. }
  87. }
  88. func finChildrenMenu(menus *[]sysmodel.SysMenuTree, parent string, parent_menu *sysmodel.SysMenuTree, menutree *[]sysmodel.SysMenuTree) {
  89. for _, m := range *menus {
  90. if m.Parent == parent {
  91. if parent_menu == nil {
  92. m.Level = 0
  93. m.ParentName = ""
  94. *menutree = append(*menutree, m)
  95. //finChildrenMenu(menus, m.Id, menutree[len(*menutree)-1], menutree)
  96. } else {
  97. m.Level = parent_menu.Level + 1
  98. m.ParentName = parent_menu.Name
  99. parent_menu.Children = append(parent_menu.Children, m)
  100. finChildrenMenu(menus, m.Id, &parent_menu.Children[len(parent_menu.Children)-1], menutree)
  101. }
  102. }
  103. }
  104. }
  105. // _FindUserPage
  106. // @Title _FindUserPage
  107. // @Description 获取用户分布数据
  108. // @Param page false "分页参数"
  109. // @Success 200 {object} sysmodel.Account
  110. // @Failure 403 :id is empty
  111. func System_FindUserPage(c *entitys.CtrlContext) {
  112. var getpageinfo sysmodel.GetPageInfo
  113. c.Ctx.BindJSON(&getpageinfo)
  114. err := __none_func_system__(getpageinfo)
  115. if err {
  116. c.Ctx.JSON(200, sysmodel.SysReturn{200, "", nil})
  117. } else {
  118. c.Ctx.JSON(200, sysmodel.SysReturn{500, "", nil})
  119. }
  120. }
  121. // _AddUser
  122. // @Title _AddUser
  123. // @Description 添加用户
  124. // @Param login_id string false "登录ID"
  125. // @Param password string false "密码"
  126. // @Param org_id string false "组织ID"
  127. // @Param email string false "邮箱"
  128. // @Success 200 {object} models.Account
  129. // @Failure 403 :id is empty
  130. func System_AddUser(c *entitys.CtrlContext) {
  131. var user sysmodel.SysUser
  132. err := c.Ctx.ShouldBindJSON(&user)
  133. if err != nil {
  134. c.Ctx.JSON(500, sysmodel.SysReturn{200, "c.Ctx.ShouldBindJSON error " + err.Error(), nil})
  135. return
  136. }
  137. fmt.Println(user.LoginId, "-----add user-----", user.Password, " --- ", user.OrgId)
  138. //查找login_id是否存在
  139. oldUser := new(sysmodel.SysUser)
  140. count, _ := c.Db.SQL("select * from sys_user").Where("login_id = ?", user.LoginId).Count(&oldUser)
  141. if count > 1 {
  142. if oldUser.DelFlag == 1 {
  143. oldUser.DelFlag = 0
  144. _, err := c.Db.Id("id").Cols("del_flag").Update(&oldUser)
  145. if err != nil {
  146. c.Ctx.JSON(500, sysmodel.SysReturn{500, "login_id exit, update err: " + err.Error(), nil})
  147. }
  148. return
  149. } else {
  150. c.Ctx.JSON(200, sysmodel.SysReturn{200, "login_id exit", nil})
  151. return
  152. }
  153. }
  154. user_id := c.Ctx.GetString("user_id")
  155. user.Id = utils.NewUUID()
  156. //when name is null
  157. if user.Name == "" {
  158. user.Name = user.LoginId
  159. }
  160. user.CreateTime = time.Now()
  161. user.LastUpdateDate = time.Now()
  162. user.CreateBy = user_id
  163. user.LastUpdateBy = user_id
  164. user.DelFlag = 0
  165. user.Password = utils.HashPassword(user.Password, "")
  166. _, err = c.Db.Insert(&user)
  167. ret := __none_func_system__(user.LoginId, user.Password, user.OrgId, user.Email)
  168. if ret && err == nil {
  169. c.Ctx.JSON(200, sysmodel.SysReturn{200, "", nil})
  170. } else {
  171. c.Ctx.JSON(500, sysmodel.SysReturn{500, err.Error(), nil})
  172. }
  173. }
  174. // _DelUser
  175. // @Title _DelUser
  176. // @Description 删除用户
  177. // @Param id string false "用户ID"
  178. // @Success 200 {object} models.Account
  179. // @Failure 403 :id is empty
  180. func System_DelUser(c *entitys.CtrlContext) {
  181. type Param struct {
  182. Id string `json:"id"`
  183. }
  184. var params []Param
  185. c.Ctx.BindJSON(&params)
  186. ids := []string{}
  187. for _, param := range params {
  188. ids = append(ids, param.Id)
  189. }
  190. session := c.Db.NewSession()
  191. defer session.Close()
  192. //_, err := c.Db.Table(new(models.SysUser)).ID(param.Id).Update(map[string]interface{}{"del_flag": 0})
  193. _, err := c.Db.Table(new(sysmodel.SysUser)).In("id", ids).Update(map[string]interface{}{"del_flag": 1})
  194. if err != nil {
  195. session.Rollback()
  196. c.Ctx.JSON(200, sysmodel.SysReturn{500, err.Error(), nil})
  197. return
  198. }
  199. _, err = c.Db.Table(new(sysmodel.SysUserRole)).In("user_id", ids).Update(map[string]interface{}{"del_flag": 1})
  200. if err != nil {
  201. session.Rollback()
  202. c.Ctx.JSON(200, sysmodel.SysReturn{500, err.Error(), nil})
  203. return
  204. }
  205. session.Commit()
  206. ret := __none_func_system__()
  207. if ret {
  208. c.Ctx.JSON(200, sysmodel.SysReturn{200, "", nil})
  209. } else {
  210. c.Ctx.JSON(200, sysmodel.SysReturn{500, "", nil})
  211. }
  212. }
  213. // _UpdateUser
  214. // @Title _UpdateUser
  215. // @Description 修改用户
  216. // @Param login_id string false "登录ID"
  217. // @Param password string false "密码"
  218. // @Param org_id string false "组织ID"
  219. // @Param email string false "邮箱"
  220. // @Success 200 {object} models.Account
  221. // @Failure 403 :id is empty
  222. func System_UpdateUser(c *entitys.CtrlContext) {
  223. user_id := c.Ctx.GetString("user_id")
  224. user_id = user_id
  225. /*var userInfo sysmodel.UserInfo
  226. err := c.Ctx.BindJSON(&userInfo)
  227. if err != nil {
  228. c.Ctx.JSON(500, sysmodel.SysReturn{500, err.Error(), nil})
  229. return
  230. }
  231. session := c.Db.NewSession()
  232. defer session.Close()
  233. //1、删除用户角色
  234. _, err = c.Db.SQL(sysmodel.SqlDeleteUserRoles, userInfo.Id).Execute()
  235. if err != nil {
  236. session.Rollback()
  237. c.Ctx.JSON(200, sysmodel.SysReturn{500, err.Error(), nil})
  238. return
  239. }
  240. //2、修改角色
  241. userRoles := []sysmodel.SysUserRole{}
  242. roles := []string{}
  243. if userInfo.UserRole != "" {
  244. err = json.Unmarshal([]byte(userInfo.UserRole), &roles)
  245. if err != nil {
  246. session.Rollback()
  247. c.Ctx.JSON(200, sysmodel.SysReturn{500, err.Error(), nil})
  248. return
  249. }
  250. }
  251. for _, role := range roles {
  252. userRole := sysmodel.SysUserRole{}
  253. userRole.Id = utils.NewUUID()
  254. userRole.RoleId = role
  255. userRole.UserId = userInfo.Id
  256. userRole.CreateBy = user_id
  257. userRole.LastUpdateBy = user_id
  258. userRole.CreateTime = time.Now()
  259. userRole.LastUpdateDate = time.Now()
  260. userRole.DelFlag = 0
  261. userRoles = append(userRoles, userRole)
  262. }
  263. _, err = c.Db.Insert(userRoles)
  264. if err != nil {
  265. session.Rollback()
  266. c.Ctx.JSON(200, sysmodel.SysReturn{500, err.Error(), nil})
  267. return
  268. }
  269. var updateUser sysmodel.SysUser
  270. updateUser.Name = userInfo.Name
  271. updateUser.FullName = userInfo.FullName
  272. updateUser.Mobile = userInfo.Mobile
  273. updateUser.OrgId = userInfo.OrgId
  274. updateUser.Type = userInfo.Type
  275. updateUser.Status = userInfo.Status
  276. updateUser.Domain = userInfo.Domain
  277. updateUser.OptionA = userInfo.OptionA
  278. updateUser.OptionB = userInfo.OptionB
  279. updateUser.LastUpdateBy = user_id
  280. updateUser.LastUpdateDate = time.Now()
  281. //3、更新用户信息
  282. //_, 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()})
  283. _, err = c.Db.Id(userInfo.Id).Update(&updateUser)
  284. if err != nil {
  285. session.Rollback()
  286. c.Ctx.JSON(200, sysmodel.SysReturn{500, err.Error(), nil})
  287. return
  288. }
  289. session.Commit()
  290. */
  291. ret := __none_func_system__()
  292. if ret {
  293. c.Ctx.JSON(200, sysmodel.SysReturn{200, "", nil})
  294. } else {
  295. c.Ctx.JSON(200, sysmodel.SysReturn{500, "", nil})
  296. }
  297. }
  298. // _AddRole
  299. // @Title _AddRole
  300. // @Description 添加角色
  301. // @Param name string false "角色名称"
  302. // @Param remark string false "备注"
  303. // @Success 200 {object} models.Account
  304. // @Failure 403 :id is empty
  305. func System_AddRole(c *entitys.CtrlContext) {
  306. var role sysmodel.SysRole
  307. c.Ctx.BindJSON(&role)
  308. user_id := c.Ctx.GetString("user_id")
  309. role.Id = utils.NewUUID()
  310. role.DelFlag = 0
  311. role.CreateBy = user_id
  312. role.LastUpdateBy = user_id
  313. role.CreateTime = time.Now()
  314. role.LastUpdateDate = time.Now()
  315. _, err := c.Db.Insert(&role)
  316. ret := __none_func_system__()
  317. if ret && err == nil {
  318. c.Ctx.JSON(200, sysmodel.SysReturn{200, "", nil})
  319. } else {
  320. c.Ctx.JSON(200, sysmodel.SysReturn{500, err.Error(), nil})
  321. }
  322. }
  323. // _DelRole
  324. // @Title _DelRole
  325. // @Description 添加角色
  326. // @Param id string false "角色ID"
  327. // @Success 200 {object} models.Account
  328. // @Failure 403 :id is empty
  329. func System_DelRole(c *entitys.CtrlContext) {
  330. type Param struct {
  331. Id string `json:"id"`
  332. }
  333. var params []Param
  334. c.Ctx.BindJSON(&params)
  335. fmt.Println(params, "-----------")
  336. ids := []string{}
  337. for _, param := range params {
  338. ids = append(ids, param.Id)
  339. }
  340. _, err := c.Db.Table(new(sysmodel.SysRole)).In("id", ids).Update(map[string]interface{}{"del_flag": 1})
  341. if err != nil {
  342. c.Ctx.JSON(200, sysmodel.SysReturn{500, err.Error(), nil})
  343. return
  344. }
  345. ret := __none_func_system__()
  346. if ret {
  347. c.Ctx.JSON(200, sysmodel.SysReturn{200, "", nil})
  348. } else {
  349. c.Ctx.JSON(200, sysmodel.SysReturn{500, "", nil})
  350. }
  351. }
  352. // _UpdateRole
  353. // @Title _UpdateRole
  354. // @Description 修改角色
  355. // @Param id string false "角色ID"
  356. // @Param name string false "角色名称"
  357. // @Param remark string false "备注"
  358. // @Success 200 {object} models.Account
  359. // @Failure 403 :id is empty
  360. func System_UpdateRole(c *entitys.CtrlContext) {
  361. var role sysmodel.SysRole
  362. c.Ctx.BindJSON(&role)
  363. user_id := c.Ctx.GetString("user_id")
  364. role.LastUpdateBy = user_id
  365. role.LastUpdateDate = time.Now()
  366. c.Db.ID(role.Id).Update(&role)
  367. ret := __none_func_system__()
  368. if ret {
  369. c.Ctx.JSON(200, sysmodel.SysReturn{200, "", nil})
  370. } else {
  371. c.Ctx.JSON(200, sysmodel.SysReturn{500, "", nil})
  372. }
  373. }
  374. // _FindRolePage
  375. // @Title _FindRolePage
  376. // @Description 角色分页
  377. // @Param page false "分页参数"
  378. // @Success 200 {object} models.Account
  379. // @Failure 403 :id is empty
  380. func System_FindRolePage(c *entitys.CtrlContext) {
  381. var getpageinfo sysmodel.GetPageInfo
  382. c.Ctx.BindJSON(&getpageinfo)
  383. page := sysmodel.PageResult{}
  384. var roles []sysmodel.SysRole
  385. err := c.Db.SQL(sysmodel.Selectall_sys_role).Limit(getpageinfo.PageSize, (getpageinfo.PageNum-1)*getpageinfo.PageSize).Find(&roles)
  386. if err != nil {
  387. c.Ctx.JSON(200, sysmodel.SysReturn{500, err.Error(), nil})
  388. return
  389. }
  390. fmt.Println("-----------", len(roles))
  391. page.Content = roles
  392. page.PageSize = getpageinfo.PageSize
  393. page.PageNum = getpageinfo.PageNum
  394. page.TotalSize = 1
  395. ret := __none_func_system__(getpageinfo)
  396. if ret {
  397. c.Ctx.JSON(200, sysmodel.SysReturn{200, "", page})
  398. } else {
  399. c.Ctx.JSON(200, sysmodel.SysReturn{500, "", nil})
  400. }
  401. }
  402. // _FindRoleMenu
  403. // @Title _FindRoleMenu
  404. // @Description 查找角色权限
  405. // @Param user string false "用户id"
  406. // @Success 200 {object} models.Account
  407. // @Failure 403 :id is empty
  408. func System_FindRoleMenu(c *entitys.CtrlContext) {
  409. role_id, b := c.Ctx.GetQuery("roleId")
  410. if !b {
  411. c.Ctx.JSON(200, sysmodel.SysReturn{500, "roleId is null", nil})
  412. return
  413. }
  414. menus := []sysmodel.SysMenu{}
  415. c.Db.SQL(sysmodel.SqlFindRoleMenu, role_id).Find(&menus)
  416. ret := __none_func_system__()
  417. if ret {
  418. c.Ctx.JSON(200, sysmodel.SysReturn{200, "", menus})
  419. } else {
  420. c.Ctx.JSON(200, sysmodel.SysReturn{500, "", nil})
  421. }
  422. }
  423. // _SaveRoleMenu
  424. // @Title _SaveRoleMenu
  425. // @Description 保存角色权限
  426. // @Param role_menu string false "角色权限"
  427. // @Success 200 {object} models.Account
  428. // @Failure 403 :id is empty
  429. func System_SaveRoleMenu(c *entitys.CtrlContext) {
  430. var saverolemenu []sysmodel.SysRoleMenu
  431. c.Ctx.BindJSON(&saverolemenu)
  432. if len(saverolemenu) < 1 {
  433. c.Ctx.JSON(200, sysmodel.SysReturn{500, "role menu length is error", nil})
  434. return
  435. }
  436. session := c.Db.NewSession()
  437. defer session.Close()
  438. err := session.Begin()
  439. //删除角色下的menu
  440. _, err = c.Db.Exec("delete from sys_role_menu where role_id = ?", saverolemenu[0].RoleId)
  441. //_, err = c.Db.Exec("delete from sys_role_menu where id = 1")
  442. if err != nil {
  443. session.Rollback()
  444. c.Ctx.JSON(200, sysmodel.SysReturn{500, err.Error(), nil})
  445. return
  446. }
  447. for i, _ := range saverolemenu {
  448. saverolemenu[i].Id = utils.NewUUID()
  449. saverolemenu[i].DelFlag = 1
  450. }
  451. _, err = c.Db.Insert(&saverolemenu)
  452. if err != nil {
  453. session.Rollback()
  454. c.Ctx.JSON(200, sysmodel.SysReturn{500, err.Error(), nil})
  455. return
  456. }
  457. session.Commit()
  458. ret := __none_func_system__(&saverolemenu)
  459. if ret {
  460. c.Ctx.JSON(200, sysmodel.SysReturn{200, "", nil})
  461. } else {
  462. c.Ctx.JSON(200, sysmodel.SysReturn{500, "", nil})
  463. }
  464. }
  465. // _RoleAll
  466. // @Title _RoleAll
  467. // @Description 查找所有角色
  468. // @Success 200 {object} models.Account
  469. // @Failure 403 :id is empty
  470. func System_RoleAll(c *entitys.CtrlContext) {
  471. var roles []sysmodel.SysRole
  472. err := c.Db.SQL(sysmodel.Selectall_sys_role).Find(&roles)
  473. ret := __none_func_system__()
  474. if ret && err == nil {
  475. c.Ctx.JSON(200, sysmodel.SysReturn{200, "", roles})
  476. } else {
  477. c.Ctx.JSON(200, sysmodel.SysReturn{500, err.Error(), nil})
  478. }
  479. }
  480. // _FindPermissions
  481. // @Title _FindPermissions
  482. // @Description 查找用户权限
  483. // @Success 200 {object} models.Account
  484. // @Failure 403 :id is empty
  485. func System_FindPermissions(c *entitys.CtrlContext) {
  486. user_id := c.Ctx.GetString("user_id")
  487. //result, err := c.Db.Query(models.SqlFindUserPermissions, op.UserId)
  488. result, err := c.Db.QueryString(sysmodel.SqlFindUserPermissions, user_id)
  489. strs := []string{}
  490. for _, v := range result {
  491. strs = append(strs, v["perms"])
  492. }
  493. if err != nil {
  494. c.Ctx.JSON(200, sysmodel.SysReturn{500, err.Error(), nil})
  495. }
  496. ret := __none_func_system__()
  497. //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"}
  498. if ret {
  499. c.Ctx.JSON(200, sysmodel.SysReturn{200, "", strs})
  500. } else {
  501. c.Ctx.JSON(200, sysmodel.SysReturn{500, "", nil})
  502. }
  503. }
  504. // _AddMenu
  505. // @Title _AddMenu
  506. // @Description 添加菜单
  507. // @Param string false "菜单"
  508. // @Success 200 {object} models.Account
  509. // @Failure 403 :id is empty
  510. func System_AddMenu(c *entitys.CtrlContext) {
  511. var sysmenu sysmodel.SysMenu
  512. c.Ctx.BindJSON(&sysmenu)
  513. user_id := c.Ctx.GetString("user_id")
  514. sysmenu.Id = utils.NewUUID()
  515. sysmenu.CreateBy = user_id
  516. sysmenu.LastUpdateBy = user_id
  517. sysmenu.LastUpdateDate = time.Now()
  518. sysmenu.CreateTime = time.Now()
  519. sysmenu.DelFlag = 0
  520. _, err := c.Db.Insert(&sysmenu)
  521. if err != nil {
  522. c.Ctx.JSON(500, sysmodel.SysReturn{500, err.Error(), nil})
  523. return
  524. }
  525. ret := __none_func_system__(sysmenu)
  526. if ret {
  527. c.Ctx.JSON(200, sysmodel.SysReturn{200, "", nil})
  528. } else {
  529. c.Ctx.JSON(500, sysmodel.SysReturn{500, "", nil})
  530. }
  531. }
  532. // _DelMenu
  533. // @Title _DelMenu
  534. // @Description 删除菜单
  535. // @Param id string false "菜单ID"
  536. // @Success 200 {object} models.Account
  537. // @Failure 403 :id is empty
  538. func System_DelMenu(c *entitys.CtrlContext) {
  539. type Param struct {
  540. Id string `json:"id"`
  541. }
  542. var params []Param
  543. c.Ctx.BindJSON(&params)
  544. fmt.Println(params, "-----------")
  545. ids := []string{}
  546. for _, param := range params {
  547. ids = append(ids, param.Id)
  548. }
  549. _, err := c.Db.Table(new(sysmodel.SysMenu)).In("id", ids).Update(map[string]interface{}{"del_flag": 0})
  550. if err != nil {
  551. c.Ctx.JSON(200, sysmodel.SysReturn{500, err.Error(), nil})
  552. return
  553. }
  554. ret := __none_func_system__()
  555. if ret {
  556. c.Ctx.JSON(200, sysmodel.SysReturn{200, "", nil})
  557. } else {
  558. c.Ctx.JSON(200, sysmodel.SysReturn{500, "", nil})
  559. }
  560. }
  561. // _UpdateMenu
  562. // @Title _UpdateMenu
  563. // @Description 更新菜单
  564. // @Param string false "菜单"
  565. // @Success 200 {object} models.Account
  566. // @Failure 403 :id is empty
  567. func System_UpdateMenu(c *entitys.CtrlContext) {
  568. var sysmenu sysmodel.SysMenu
  569. err := c.Ctx.BindJSON(&sysmenu)
  570. if err != nil{
  571. c.Ctx.JSON(500, sysmodel.SysReturn{500, err.Error(), nil})
  572. return
  573. }
  574. user_id := c.Ctx.GetString("user_id")
  575. whereMenu := &sysmodel.SysMenu{}
  576. whereMenu.Id = sysmenu.Id
  577. sysmenu.LastUpdateBy = user_id
  578. sysmenu.LastUpdateDate = time.Now()
  579. _, err = c.Db.Update(&sysmenu, whereMenu)
  580. if err != nil {
  581. c.Ctx.JSON(200, sysmodel.SysReturn{500, err.Error(), nil})
  582. return
  583. }
  584. ret := __none_func_system__(sysmenu)
  585. if ret {
  586. c.Ctx.JSON(200, sysmodel.SysReturn{200, "", nil})
  587. } else {
  588. c.Ctx.JSON(200, sysmodel.SysReturn{500, "", nil})
  589. }
  590. }
  591. // _AddOrg
  592. // @Title _AddOrg
  593. // @Description 添加组织
  594. // @Param string false "组织"
  595. // @Success 200 {object} models.Account
  596. // @Failure 403 :id is empty
  597. func System_AddOrg(c *entitys.CtrlContext) {
  598. var sysorg sysmodel.SysOrg
  599. c.Ctx.BindJSON(&sysorg)
  600. user_id := c.Ctx.GetString("user_id")
  601. sysorg.Id = utils.NewUUID()
  602. sysorg.CreateBy = user_id
  603. sysorg.LastUpdateBy = user_id
  604. sysorg.LastUpdateDate = time.Now()
  605. sysorg.CreateTime = time.Now()
  606. sysorg.DelFlag = 0
  607. _, err := c.Db.Insert(&sysorg)
  608. if err != nil {
  609. c.Ctx.JSON(500, sysmodel.SysReturn{500, err.Error(), nil})
  610. return
  611. }
  612. ret := __none_func_system__(sysorg)
  613. if ret {
  614. c.Ctx.JSON(200, sysmodel.SysReturn{200, "", nil})
  615. } else {
  616. c.Ctx.JSON(500, sysmodel.SysReturn{500, "", nil})
  617. }
  618. }
  619. // _DelOrg
  620. // @Title _DelOrg
  621. // @Description 删除组织
  622. // @Param id string false "组织ID"
  623. // @Success 200 {object} models.Account
  624. // @Failure 403 :id is empty
  625. func System_DelOrg(c *entitys.CtrlContext) {
  626. type Param struct {
  627. Id string `json:"id"`
  628. }
  629. var params []Param
  630. c.Ctx.BindJSON(&params)
  631. fmt.Println(params, "-----------")
  632. ids := []string{}
  633. for _, param := range params {
  634. ids = append(ids, param.Id)
  635. }
  636. _, err := c.Db.Table(new(sysmodel.SysOrg)).In("id", ids).Update(map[string]interface{}{"del_flag": 0})
  637. if err != nil {
  638. c.Ctx.JSON(200, sysmodel.SysReturn{500, err.Error(), nil})
  639. return
  640. }
  641. ret := __none_func_system__()
  642. if ret {
  643. c.Ctx.JSON(200, sysmodel.SysReturn{200, "", nil})
  644. } else {
  645. c.Ctx.JSON(200, sysmodel.SysReturn{500, "", nil})
  646. }
  647. }
  648. // _UpdateOrg
  649. // @Title _UpdateOrg
  650. // @Description 更新组织
  651. // @Param string false "组织"
  652. // @Success 200 {object} models.Account
  653. // @Failure 403 :id is empty
  654. func System_UpdateOrg(c *entitys.CtrlContext) {
  655. var sysorg sysmodel.SysOrg
  656. c.Ctx.BindJSON(&sysorg)
  657. user_id := c.Ctx.GetString("user_id")
  658. sysorg.LastUpdateBy = user_id
  659. sysorg.LastUpdateDate = time.Now()
  660. _, err := c.Db.ID(sysorg.Id).Update(&sysorg)
  661. if err != nil {
  662. c.Ctx.JSON(200, sysmodel.SysReturn{500, err.Error(), nil})
  663. return
  664. }
  665. ret := __none_func_system__(sysorg)
  666. if ret {
  667. c.Ctx.JSON(200, sysmodel.SysReturn{200, "", nil})
  668. } else {
  669. c.Ctx.JSON(200, sysmodel.SysReturn{500, "", nil})
  670. }
  671. }
  672. // _GetOrg
  673. // @Title _GetOrg
  674. // @Description 根据ID获取组织
  675. // @Param string false "组织ID"
  676. // @Success 200 {object} models.Account
  677. // @Failure 403 :id is empty
  678. func System_GetOrg(c *entitys.CtrlContext) {
  679. var param struct {
  680. Id string `json:"id"`
  681. }
  682. c.Ctx.BindJSON(&param)
  683. fmt.Println(param, "-----------")
  684. org := sysmodel.SysOrg{}
  685. err := c.Db.Table(new(sysmodel.SysOrg)).ID(param.Id).Find(&org)
  686. if err != nil {
  687. c.Ctx.JSON(200, sysmodel.SysReturn{500, err.Error(), nil})
  688. return
  689. }
  690. ret := __none_func_system__()
  691. if ret {
  692. c.Ctx.JSON(200, sysmodel.SysReturn{200, "", org})
  693. } else {
  694. c.Ctx.JSON(200, sysmodel.SysReturn{500, "", nil})
  695. }
  696. }
  697. // _PageOrg
  698. // @Title _PageOrg
  699. // @Description 分页获取组织
  700. // @Param string false "组织"
  701. // @Success 200 {object} models.Account
  702. // @Failure 403 :id is empty
  703. func System_PageOrg(c *entitys.CtrlContext) {
  704. var getpageinfo sysmodel.GetPageInfo
  705. c.Ctx.BindJSON(&getpageinfo)
  706. /*
  707. ret := __none_func_system__(getpageinfo)
  708. page := sysmodel.PageResult{}
  709. var orgs []sysmodel.SysOrg
  710. dbSession := c.Db.Table("sys_organization")
  711. dbSession = dbSession.Select("sys_organization.*")
  712. countSession := c.Db.Table("sys_organization")
  713. JoinTables := []sysmodel.Join{}
  714. //JoinTables = append(JoinTables, sysmodel.Join{TabelName: "subject", Condition: "lesson.subject_id = subject.id", JoinOperator: "left"})
  715. for _, join := range JoinTables {
  716. dbSession = dbSession.Join(join.JoinOperator, join.TabelName, join.Condition)
  717. countSession = countSession.Join(join.JoinOperator, join.TabelName, join.Condition)
  718. }
  719. whereStr, datas, err := getpageinfo.Filter.Parse("")
  720. if err != nil {
  721. c.Ctx.JSON(200, sysmodel.SysReturn{500, err.Error(), nil})
  722. return
  723. }
  724. dbSession = dbSession.Where(whereStr, datas...)
  725. countSession = countSession.Where(whereStr, datas...)
  726. sidx := strings.Split(getpageinfo.Sidx, ",")
  727. for _, order := range sidx {
  728. order = strings.TrimSpace(order)
  729. if len(order) == 0 {
  730. continue
  731. }
  732. if strings.ToLower(getpageinfo.Sord) == "desc" {
  733. dbSession = dbSession.OrderBy(order + " desc")
  734. } else {
  735. dbSession = dbSession.OrderBy(order + " asc")
  736. }
  737. }
  738. totalPage, _ := countSession.Count()
  739. err = dbSession.Limit(getpageinfo.PageSize, (getpageinfo.PageNum-1)*getpageinfo.PageSize).Find(&orgs)
  740. if err != nil {
  741. c.Ctx.JSON(200, sysmodel.SysReturn{500, err.Error(), nil})
  742. }
  743. page.Content = orgs
  744. page.PageSize = getpageinfo.PageSize
  745. page.PageNum = getpageinfo.PageNum
  746. page.TotalSize = int(totalPage)
  747. */
  748. if true {
  749. c.Ctx.JSON(200, sysmodel.SysReturn{200, "", nil})
  750. } else {
  751. c.Ctx.JSON(200, sysmodel.SysReturn{500, "", nil})
  752. }
  753. }
  754. func System_TreeList(c *entitys.CtrlContext) {
  755. /*tbName := c.Ctx.Query("tb_name")
  756. parentFiled := c.Ctx.Query("parent_filed")
  757. if parentFiled == "" {
  758. parentFiled = c.Ctx.Query("parent_field")
  759. }
  760. parentValue := c.Ctx.Query("parent_value")
  761. textFiled := c.Ctx.Query("text_filed")
  762. if textFiled == "" {
  763. textFiled = c.Ctx.Query("text_field")
  764. if textFiled == "" {
  765. textFiled = c.Ctx.Query("name_field")
  766. }
  767. }
  768. valueFiled := c.Ctx.Query("value_filed")
  769. if valueFiled == "" {
  770. valueFiled = c.Ctx.Query("value_field")
  771. if valueFiled == "" {
  772. valueFiled = c.Ctx.Query("id_field")
  773. }
  774. }
  775. domainchk := c.Ctx.Query("domainchk")
  776. if domainchk == "" {
  777. domainchk = "1" // 默认需要domain过滤
  778. }
  779. cntparent := c.Ctx.Query("cnt_parent")
  780. if cntparent == "" {
  781. cntparent = "0"
  782. }
  783. filter := c.Ctx.Query("filters")
  784. if filter == "" {
  785. filter = c.Ctx.Query("filter")
  786. }
  787. sord := c.Ctx.Query("sord")
  788. user, exists := c.Ctx.Get("token")
  789. if !exists {
  790. c.Ctx.JSON(200, sysmodel.SysReturn{500, "token is not exists", nil})
  791. return
  792. }
  793. nodes, err := sysdb.TreeList(c, user.(*entitys.Token), tbName, parentFiled, parentValue, textFiled, valueFiled, cntparent, domainchk, filter, sord)
  794. if err == nil {
  795. c.Ctx.JSON(200, sysmodel.SysReturn{200, "", nodes})
  796. } else {
  797. c.Ctx.JSON(200, sysmodel.SysReturn{500, "", nil})
  798. }
  799. */
  800. }
  801. func __none_func_system__(params ...interface{}) bool {
  802. return true
  803. }