SystemController.go 24 KB

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