ManagerController.go 30 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495969798991001011021031041051061071081091101111121131141151161171181191201211221231241251261271281291301311321331341351361371381391401411421431441451461471481491501511521531541551561571581591601611621631641651661671681691701711721731741751761771781791801811821831841851861871881891901911921931941951961971981992002012022032042052062072082092102112122132142152162172182192202212222232242252262272282292302312322332342352362372382392402412422432442452462472482492502512522532542552562572582592602612622632642652662672682692702712722732742752762772782792802812822832842852862872882892902912922932942952962972982993003013023033043053063073083093103113123133143153163173183193203213223233243253263273283293303313323333343353363373383393403413423433443453463473483493503513523533543553563573583593603613623633643653663673683693703713723733743753763773783793803813823833843853863873883893903913923933943953963973983994004014024034044054064074084094104114124134144154164174184194204214224234244254264274284294304314324334344354364374384394404414424434444454464474484494504514524534544554564574584594604614624634644654664674684694704714724734744754764774784794804814824834844854864874884894904914924934944954964974984995005015025035045055065075085095105115125135145155165175185195205215225235245255265275285295305315325335345355365375385395405415425435445455465475485495505515525535545555565575585595605615625635645655665675685695705715725735745755765775785795805815825835845855865875885895905915925935945955965975985996006016026036046056066076086096106116126136146156166176186196206216226236246256266276286296306316326336346356366376386396406416426436446456466476486496506516526536546556566576586596606616626636646656666676686696706716726736746756766776786796806816826836846856866876886896906916926936946956966976986997007017027037047057067077087097107117127137147157167177187197207217227237247257267277287297307317327337347357367377387397407417427437447457467477487497507517527537547557567577587597607617627637647657667677687697707717727737747757767777787797807817827837847857867877887897907917927937947957967977987998008018028038048058068078088098108118128138148158168178188198208218228238248258268278288298308318328338348358368378388398408418428438448458468478488498508518528538548558568578588598608618628638648658668678688698708718728738748758768778788798808818828838848858868878888898908918928938948958968978988999009019029039049059069079089099109119129139149159169179189199209219229239249259269279289299309319329339349359369379389399409419429439449459469479489499509519529539549559569579589599609619629639649659669679689699709719729739749759769779789799809819829839849859869879889899909919929939949959969979989991000100110021003100410051006100710081009101010111012101310141015101610171018101910201021102210231024102510261027102810291030103110321033103410351036103710381039104010411042104310441045104610471048104910501051105210531054105510561057105810591060106110621063106410651066106710681069107010711072107310741075107610771078107910801081108210831084108510861087108810891090109110921093109410951096109710981099110011011102110311041105110611071108110911101111111211131114111511161117111811191120112111221123112411251126112711281129113011311132113311341135113611371138113911401141114211431144114511461147114811491150115111521153115411551156115711581159116011611162116311641165116611671168116911701171117211731174117511761177117811791180118111821183118411851186118711881189119011911192119311941195119611971198119912001201120212031204120512061207120812091210
  1. package controllers
  2. import (
  3. "encoding/json"
  4. "html/template"
  5. "regexp"
  6. "strings"
  7. "math"
  8. "path/filepath"
  9. "strconv"
  10. "io/ioutil"
  11. "os"
  12. "github.com/beego/beego/v2/client/orm"
  13. "github.com/beego/beego/v2/core/logs"
  14. "github.com/beego/beego/v2/server/web"
  15. "github.com/beego/i18n"
  16. "github.com/mindoc-org/mindoc/conf"
  17. "github.com/mindoc-org/mindoc/models"
  18. "github.com/mindoc-org/mindoc/utils"
  19. "github.com/mindoc-org/mindoc/utils/filetil"
  20. "github.com/mindoc-org/mindoc/utils/pagination"
  21. "github.com/russross/blackfriday/v2"
  22. )
  23. type ManagerController struct {
  24. BaseController
  25. }
  26. func (c *ManagerController) Prepare() {
  27. c.BaseController.Prepare()
  28. if !c.Member.IsAdministrator() {
  29. c.Abort("403")
  30. }
  31. }
  32. func (c *ManagerController) Index() {
  33. c.TplName = "manager/index.tpl"
  34. c.Data["Model"] = models.NewDashboard().Query()
  35. c.Data["Action"] = "index"
  36. }
  37. // 用户列表.
  38. func (c *ManagerController) Users() {
  39. c.TplName = "manager/users.tpl"
  40. c.Data["Action"] = "users"
  41. pageIndex, _ := c.GetInt("page", 0)
  42. tempMember := models.NewMember()
  43. tempMember.Lang = c.Lang
  44. members, totalCount, err := tempMember.FindToPager(pageIndex, conf.PageSize)
  45. if err != nil {
  46. c.Data["ErrorMessage"] = err.Error()
  47. return
  48. }
  49. if totalCount > 0 {
  50. pager := pagination.NewPagination(c.Ctx.Request, totalCount, conf.PageSize, c.BaseUrl())
  51. c.Data["PageHtml"] = pager.HtmlPages()
  52. for _, item := range members {
  53. item.Avatar = conf.URLForWithCdnImage(item.Avatar)
  54. }
  55. } else {
  56. c.Data["PageHtml"] = ""
  57. }
  58. b, err := json.Marshal(members)
  59. if err != nil {
  60. c.Data["Result"] = template.JS("[]")
  61. } else {
  62. c.Data["Result"] = template.JS(string(b))
  63. }
  64. }
  65. // 添加用户.
  66. func (c *ManagerController) CreateMember() {
  67. account := strings.TrimSpace(c.GetString("account"))
  68. password1 := strings.TrimSpace(c.GetString("password1"))
  69. password2 := strings.TrimSpace(c.GetString("password2"))
  70. email := strings.TrimSpace(c.GetString("email"))
  71. phone := strings.TrimSpace(c.GetString("phone"))
  72. role, _ := c.GetInt("role", 1)
  73. status, _ := c.GetInt("status", 0)
  74. if ok, err := regexp.MatchString(conf.RegexpAccount, account); account == "" || !ok || err != nil {
  75. c.JsonResult(6001, i18n.Tr(c.Lang, "message.username_invalid_format"))
  76. }
  77. if l := strings.Count(password1, ""); password1 == "" || l > 50 || l < 6 {
  78. c.JsonResult(6002, i18n.Tr(c.Lang, "message.pwd_length_tips"))
  79. }
  80. if password1 != password2 {
  81. c.JsonResult(6003, i18n.Tr(c.Lang, "message.wrong_confirm_pwd"))
  82. }
  83. if ok, err := regexp.MatchString(conf.RegexpEmail, email); !ok || err != nil || email == "" {
  84. c.JsonResult(6004, i18n.Tr(c.Lang, "message.email_invalid_format"))
  85. }
  86. if role != 0 && role != 1 && role != 2 {
  87. role = 1
  88. }
  89. if status != 0 && status != 1 {
  90. status = 0
  91. }
  92. member := models.NewMember()
  93. if _, err := member.FindByAccount(account); err == nil && member.MemberId > 0 {
  94. c.JsonResult(6005, i18n.Tr(c.Lang, "message.account_existed"))
  95. }
  96. member.Account = account
  97. member.Password = password1
  98. member.Role = conf.SystemRole(role)
  99. member.Avatar = conf.GetDefaultAvatar()
  100. member.CreateAt = c.Member.MemberId
  101. member.Email = email
  102. member.RealName = strings.TrimSpace(c.GetString("real_name", ""))
  103. member.Lang = c.Lang
  104. if phone != "" {
  105. member.Phone = phone
  106. }
  107. if err := member.Add(); err != nil {
  108. c.JsonResult(6006, err.Error())
  109. }
  110. c.JsonResult(0, "ok", member)
  111. }
  112. // 更新用户状态.
  113. func (c *ManagerController) UpdateMemberStatus() {
  114. c.Prepare()
  115. member_id, _ := c.GetInt("member_id", 0)
  116. status, _ := c.GetInt("status", 0)
  117. if member_id <= 0 {
  118. c.JsonResult(6001, i18n.Tr(c.Lang, "message.param_error"))
  119. }
  120. if status != 0 && status != 1 {
  121. status = 0
  122. }
  123. member := models.NewMember()
  124. if _, err := member.Find(member_id); err != nil {
  125. c.JsonResult(6002, i18n.Tr(c.Lang, "message.user_not_existed"))
  126. }
  127. if member.MemberId == c.Member.MemberId {
  128. c.JsonResult(6004, i18n.Tr(c.Lang, "message.cannot_change_own_status"))
  129. }
  130. if member.Role == conf.MemberSuperRole {
  131. c.JsonResult(6005, i18n.Tr(c.Lang, "message.cannot_change_super_status"))
  132. }
  133. member.Status = status
  134. if err := member.Update(); err != nil {
  135. logs.Error("", err)
  136. c.JsonResult(6003, i18n.Tr(c.Lang, "message.failed"))
  137. }
  138. c.JsonResult(0, "ok", member)
  139. }
  140. // 变更用户权限.
  141. func (c *ManagerController) ChangeMemberRole() {
  142. c.Prepare()
  143. memberId, _ := c.GetInt("member_id", 0)
  144. role, _ := c.GetInt("role", 0)
  145. if memberId <= 0 {
  146. c.JsonResult(6001, i18n.Tr(c.Lang, "message.param_error"))
  147. }
  148. if role != int(conf.MemberAdminRole) && role != int(conf.MemberGeneralRole) && role != int(conf.MemberReaderRole) {
  149. c.JsonResult(6001, i18n.Tr(c.Lang, "message.no_permission"))
  150. }
  151. member := models.NewMember()
  152. if _, err := member.Find(memberId); err != nil {
  153. c.JsonResult(6002, i18n.Tr(c.Lang, "message.user_not_existed"))
  154. }
  155. if member.MemberId == c.Member.MemberId {
  156. c.JsonResult(6004, i18n.Tr(c.Lang, "message.cannot_change_own_priv"))
  157. }
  158. if member.Role == conf.MemberSuperRole {
  159. c.JsonResult(6005, i18n.Tr(c.Lang, "message.cannot_change_super_priv"))
  160. }
  161. member.Role = conf.SystemRole(role)
  162. if err := member.Update(); err != nil {
  163. c.JsonResult(6003, i18n.Tr(c.Lang, "message.failed"))
  164. }
  165. member.Lang = c.Lang
  166. member.ResolveRoleName()
  167. c.JsonResult(0, "ok", member)
  168. }
  169. // 编辑用户信息.
  170. func (c *ManagerController) EditMember() {
  171. c.Prepare()
  172. c.TplName = "manager/edit_users.tpl"
  173. c.Data["Action"] = "users"
  174. member_id, _ := c.GetInt(":id", 0)
  175. if member_id <= 0 {
  176. c.Abort("404")
  177. }
  178. member, err := models.NewMember().Find(member_id)
  179. if err != nil {
  180. logs.Error(err)
  181. c.Abort("404")
  182. }
  183. if c.Ctx.Input.IsPost() {
  184. password1 := c.GetString("password1")
  185. password2 := c.GetString("password2")
  186. email := c.GetString("email")
  187. phone := c.GetString("phone")
  188. description := c.GetString("description")
  189. member.Email = email
  190. member.Phone = phone
  191. member.Description = description
  192. member.RealName = c.GetString("real_name")
  193. if password1 != "" && password2 != password1 {
  194. c.JsonResult(6001, i18n.Tr(c.Lang, "message.wrong_confirm_pwd"))
  195. }
  196. if password1 != "" && member.AuthMethod != conf.AuthMethodLDAP {
  197. member.Password = password1
  198. }
  199. if err := member.Valid(password1 == ""); err != nil {
  200. c.JsonResult(6002, err.Error())
  201. }
  202. if password1 != "" {
  203. password, err := utils.PasswordHash(password1)
  204. if err != nil {
  205. logs.Error(err)
  206. c.JsonResult(6003, i18n.Tr(c.Lang, "message.pwd_encrypt_failed"))
  207. }
  208. member.Password = password
  209. }
  210. if err := member.Update(); err != nil {
  211. c.JsonResult(6004, err.Error())
  212. }
  213. c.JsonResult(0, "ok")
  214. }
  215. c.Data["Model"] = member
  216. }
  217. // 删除一个用户,并将该用户的所有信息转移到超级管理员上.
  218. func (c *ManagerController) DeleteMember() {
  219. c.Prepare()
  220. member_id, _ := c.GetInt("id", 0)
  221. if member_id <= 0 {
  222. c.JsonResult(404, i18n.Tr(c.Lang, "message.param_error"))
  223. }
  224. member, err := models.NewMember().Find(member_id)
  225. if err != nil {
  226. logs.Error(err)
  227. c.JsonResult(500, i18n.Tr(c.Lang, "message.user_not_existed"))
  228. }
  229. if member.Role == conf.MemberSuperRole {
  230. c.JsonResult(500, "不能删除超级管理员")
  231. }
  232. superMember, err := models.NewMember().FindByFieldFirst("role", 0)
  233. if err != nil {
  234. logs.Error(err)
  235. c.JsonResult(5001, "未能找到超级管理员")
  236. }
  237. err = models.NewMember().Delete(member_id, superMember.MemberId)
  238. if err != nil {
  239. logs.Error(err)
  240. c.JsonResult(5002, i18n.Tr(c.Lang, "message.failed"))
  241. }
  242. c.JsonResult(0, "ok")
  243. }
  244. // 项目列表.
  245. func (c *ManagerController) Books() {
  246. c.Prepare()
  247. c.TplName = "manager/books.tpl"
  248. c.Data["Action"] = "books"
  249. pageIndex, _ := c.GetInt("page", 1)
  250. books, totalCount, err := models.NewBookResult().FindToPager(pageIndex, conf.PageSize)
  251. if err != nil {
  252. c.Abort("500")
  253. }
  254. if totalCount > 0 {
  255. //html := utils.GetPagerHtml(c.Ctx.Request.RequestURI, pageIndex, 8, totalCount)
  256. pager := pagination.NewPagination(c.Ctx.Request, totalCount, conf.PageSize, c.BaseUrl())
  257. c.Data["PageHtml"] = pager.HtmlPages()
  258. } else {
  259. c.Data["PageHtml"] = ""
  260. }
  261. for i, book := range books {
  262. books[i].Description = utils.StripTags(string(blackfriday.Run([]byte(book.Description))))
  263. books[i].ModifyTime = book.ModifyTime.Local()
  264. books[i].CreateTime = book.CreateTime.Local()
  265. }
  266. c.Data["Lists"] = books
  267. }
  268. // 编辑项目.
  269. func (c *ManagerController) EditBook() {
  270. c.Prepare()
  271. c.TplName = "manager/edit_book.tpl"
  272. c.Data["Action"] = "books"
  273. identify := c.GetString(":key")
  274. if identify == "" {
  275. c.Abort("404")
  276. }
  277. book, err := models.NewBook().FindByFieldFirst("identify", identify)
  278. if err != nil {
  279. c.Abort("500")
  280. }
  281. if c.Ctx.Input.IsPost() {
  282. bookName := strings.TrimSpace(c.GetString("book_name"))
  283. description := strings.TrimSpace(c.GetString("description", ""))
  284. commentStatus := c.GetString("comment_status")
  285. tag := strings.TrimSpace(c.GetString("label"))
  286. orderIndex, _ := c.GetInt("order_index", 0)
  287. isDownload := strings.TrimSpace(c.GetString("is_download")) == "on"
  288. enableShare := strings.TrimSpace(c.GetString("enable_share")) == "on"
  289. isUseFirstDocument := strings.TrimSpace(c.GetString("is_use_first_document")) == "on"
  290. autoRelease := strings.TrimSpace(c.GetString("auto_release")) == "on"
  291. publisher := strings.TrimSpace(c.GetString("publisher"))
  292. historyCount, _ := c.GetInt("history_count", 0)
  293. itemId, _ := c.GetInt("itemId")
  294. if strings.Count(description, "") > 500 {
  295. c.JsonResult(6004, i18n.Tr(c.Lang, "message.project_desc_tips"))
  296. }
  297. if commentStatus != "open" && commentStatus != "closed" && commentStatus != "group_only" && commentStatus != "registered_only" {
  298. commentStatus = "closed"
  299. }
  300. if tag != "" {
  301. tags := strings.Split(tag, ";")
  302. if len(tags) > 10 {
  303. c.JsonResult(6005, "最多允许添加10个标签")
  304. }
  305. }
  306. if !models.NewItemsets().Exist(itemId) {
  307. c.JsonResult(6006, i18n.Tr(c.Lang, "message.project_space_not_exist"))
  308. }
  309. book.Publisher = publisher
  310. book.HistoryCount = historyCount
  311. book.BookName = bookName
  312. book.Description = description
  313. book.CommentStatus = commentStatus
  314. book.Label = tag
  315. book.OrderIndex = orderIndex
  316. book.ItemId = itemId
  317. book.BookPassword = strings.TrimSpace(c.GetString("bPassword"))
  318. if autoRelease {
  319. book.AutoRelease = 1
  320. } else {
  321. book.AutoRelease = 0
  322. }
  323. if isDownload {
  324. book.IsDownload = 0
  325. } else {
  326. book.IsDownload = 1
  327. }
  328. if enableShare {
  329. book.IsEnableShare = 0
  330. } else {
  331. book.IsEnableShare = 1
  332. }
  333. if isUseFirstDocument {
  334. book.IsUseFirstDocument = 1
  335. } else {
  336. book.IsUseFirstDocument = 0
  337. }
  338. if err := book.Update(); err != nil {
  339. c.JsonResult(6006, i18n.Tr(c.Lang, "message.failed"))
  340. }
  341. c.JsonResult(0, "ok")
  342. }
  343. if book.PrivateToken != "" {
  344. book.PrivateToken = conf.URLFor("DocumentController.Index", ":key", book.Identify, "token", book.PrivateToken)
  345. }
  346. bookResult := models.NewBookResult()
  347. bookResult.ToBookResult(*book)
  348. c.Data["Model"] = bookResult
  349. }
  350. // 删除项目.
  351. func (c *ManagerController) DeleteBook() {
  352. c.Prepare()
  353. bookId, _ := c.GetInt("book_id", 0)
  354. if bookId <= 0 {
  355. c.JsonResult(6001, i18n.Tr(c.Lang, "message.param_error"))
  356. }
  357. book := models.NewBook()
  358. err := book.ThoroughDeleteBook(bookId)
  359. if err == orm.ErrNoRows {
  360. c.JsonResult(6002, i18n.Tr(c.Lang, "message.item_not_exist"))
  361. }
  362. if err != nil {
  363. logs.Error("删除失败 -> ", err)
  364. c.JsonResult(6003, i18n.Tr(c.Lang, "message.failed"))
  365. }
  366. c.JsonResult(0, "ok")
  367. }
  368. // CreateToken 创建访问来令牌.
  369. func (c *ManagerController) CreateToken() {
  370. c.Prepare()
  371. action := c.GetString("action")
  372. identify := c.GetString("identify")
  373. book, err := models.NewBook().FindByFieldFirst("identify", identify)
  374. if err != nil {
  375. c.JsonResult(6001, i18n.Tr(c.Lang, "message.item_not_exist"))
  376. }
  377. if action == "create" {
  378. if book.PrivatelyOwned == 0 {
  379. c.JsonResult(6001, "公开项目不能创建阅读令牌")
  380. }
  381. book.PrivateToken = string(utils.Krand(conf.GetTokenSize(), utils.KC_RAND_KIND_ALL))
  382. if err := book.Update(); err != nil {
  383. logs.Error("生成阅读令牌失败 => ", err)
  384. c.JsonResult(6003, i18n.Tr(c.Lang, "message.failed"))
  385. }
  386. c.JsonResult(0, "ok", conf.URLFor("DocumentController.Index", ":key", book.Identify, "token", book.PrivateToken))
  387. } else {
  388. book.PrivateToken = ""
  389. if err := book.Update(); err != nil {
  390. logs.Error("CreateToken => ", err)
  391. c.JsonResult(6004, i18n.Tr(c.Lang, "message.failed"))
  392. }
  393. c.JsonResult(0, "ok", "")
  394. }
  395. }
  396. // 项目设置.
  397. func (c *ManagerController) Setting() {
  398. c.Prepare()
  399. c.TplName = "manager/setting.tpl"
  400. c.Data["Action"] = "setting"
  401. options, err := models.NewOption().All()
  402. if c.Ctx.Input.IsPost() {
  403. for _, item := range options {
  404. item.OptionValue = c.GetString(item.OptionName)
  405. item.InsertOrUpdate()
  406. }
  407. c.JsonResult(0, "ok")
  408. }
  409. if err != nil {
  410. c.Abort("500")
  411. }
  412. c.Data["SITE_TITLE"] = c.Option["SITE_NAME"]
  413. for _, item := range options {
  414. c.Data[item.OptionName] = item.OptionValue
  415. }
  416. i18nMapStrs, err := web.AppConfig.String("i18n_map")
  417. if err != nil {
  418. logs.Error("web.AppConfig `i18n_map` not found")
  419. i18nMapStrs = "{}"
  420. }
  421. var i18nMap map[string]string
  422. err = json.Unmarshal([]byte(i18nMapStrs), &i18nMap)
  423. if err != nil {
  424. logs.Error("json `i18nList` Unmarshal fail")
  425. i18nMap = make(map[string]string)
  426. }
  427. c.Data["i18n_map"] = i18nMap
  428. }
  429. // Transfer 转让项目.
  430. func (c *ManagerController) Transfer() {
  431. c.Prepare()
  432. account := c.GetString("account")
  433. if account == "" {
  434. c.JsonResult(6004, i18n.Tr(c.Lang, "message.receive_account_empty"))
  435. }
  436. member, err := models.NewMember().FindByAccount(account)
  437. if err != nil {
  438. logs.Error("FindByAccount => ", err)
  439. c.JsonResult(6005, i18n.Tr(c.Lang, "message.receive_account_not_exist"))
  440. }
  441. if member.Status != 0 {
  442. c.JsonResult(6006, i18n.Tr(c.Lang, "message.receive_account_disabled"))
  443. }
  444. if !c.Member.IsAdministrator() {
  445. c.Abort("403")
  446. }
  447. identify := c.GetString("identify")
  448. book, err := models.NewBook().FindByFieldFirst("identify", identify)
  449. if err != nil {
  450. c.JsonResult(6001, err.Error())
  451. }
  452. rel, err := models.NewRelationship().FindFounder(book.BookId)
  453. if err != nil {
  454. logs.Error("FindFounder => ", err)
  455. c.JsonResult(6009, "查询项目创始人失败")
  456. }
  457. if member.MemberId == rel.MemberId {
  458. c.JsonResult(6007, "不能转让给自己")
  459. }
  460. err = models.NewRelationship().Transfer(book.BookId, rel.MemberId, member.MemberId)
  461. if err != nil {
  462. logs.Error("Transfer => ", err)
  463. c.JsonResult(6008, err.Error())
  464. }
  465. c.JsonResult(0, "ok")
  466. }
  467. func (c *ManagerController) Comments() {
  468. c.Prepare()
  469. c.TplName = "manager/comments.tpl"
  470. if !c.Member.IsAdministrator() {
  471. c.Abort("403")
  472. }
  473. }
  474. // DeleteComment 标记评论为已删除
  475. func (c *ManagerController) DeleteComment() {
  476. c.Prepare()
  477. comment_id, _ := c.GetInt("comment_id", 0)
  478. if comment_id <= 0 {
  479. c.JsonResult(6001, i18n.Tr(c.Lang, "message.param_error"))
  480. }
  481. comment := models.NewComment()
  482. if _, err := comment.Find(comment_id); err != nil {
  483. c.JsonResult(6002, "评论不存在")
  484. }
  485. comment.Approved = 3
  486. if err := comment.Update("approved"); err != nil {
  487. c.JsonResult(6003, "删除评论失败")
  488. }
  489. c.JsonResult(0, "ok", comment)
  490. }
  491. // 设置项目私有状态.
  492. func (c *ManagerController) PrivatelyOwned() {
  493. c.Prepare()
  494. status := c.GetString("status")
  495. identify := c.GetString("identify")
  496. if status != "open" && status != "close" {
  497. c.JsonResult(6003, i18n.Tr(c.Lang, "message.param_error"))
  498. }
  499. state := 0
  500. if status == "open" {
  501. state = 0
  502. } else {
  503. state = 1
  504. }
  505. if !c.Member.IsAdministrator() {
  506. c.Abort("403")
  507. }
  508. book, err := models.NewBook().FindByFieldFirst("identify", identify)
  509. if err != nil {
  510. c.JsonResult(6001, err.Error())
  511. }
  512. book.PrivatelyOwned = state
  513. logs.Info("", state, status)
  514. err = book.Update()
  515. if err != nil {
  516. logs.Error("PrivatelyOwned => ", err)
  517. c.JsonResult(6004, i18n.Tr(c.Lang, "message.failed"))
  518. }
  519. c.JsonResult(0, "ok")
  520. }
  521. // 附件列表.
  522. func (c *ManagerController) AttachList() {
  523. c.Prepare()
  524. c.TplName = "manager/attach_list.tpl"
  525. c.Data["Action"] = "attach"
  526. pageIndex, _ := c.GetInt("page", 1)
  527. attachList, totalCount, err := models.NewAttachment().FindToPager(pageIndex, conf.PageSize)
  528. if err != nil {
  529. c.Abort("500")
  530. }
  531. if totalCount > 0 {
  532. pager := pagination.NewPagination(c.Ctx.Request, totalCount, conf.PageSize, c.BaseUrl())
  533. c.Data["PageHtml"] = pager.HtmlPages()
  534. } else {
  535. c.Data["PageHtml"] = ""
  536. }
  537. for _, item := range attachList {
  538. p := filepath.Join(conf.WorkingDirectory, item.FilePath)
  539. item.IsExist = filetil.FileExists(p)
  540. }
  541. c.Data["Lists"] = attachList
  542. }
  543. // 附件清理.
  544. func (c *ManagerController) AttachClean() {
  545. c.Prepare()
  546. attachList, _, err := models.NewAttachment().FindToPager(0, 0)
  547. if err != nil {
  548. c.Abort("500")
  549. }
  550. for _, item := range attachList {
  551. p := filepath.Join(conf.WorkingDirectory, item.FilePath)
  552. item.IsExist = filetil.FileExists(p)
  553. if item.IsExist {
  554. // 判断
  555. searchList, err := models.NewDocumentSearchResult().SearchAllDocument(item.HttpPath)
  556. if err != nil {
  557. c.Abort("500")
  558. } else if len(searchList) == 0 {
  559. logs.Info("delete file:", item.FilePath)
  560. item.FilePath = p
  561. if err := item.Delete(); err != nil {
  562. logs.Error("AttachDelete => ", err)
  563. c.JsonResult(6002, err.Error())
  564. break
  565. }
  566. }
  567. }
  568. }
  569. c.JsonResult(0, "ok")
  570. }
  571. // 附件详情.
  572. func (c *ManagerController) AttachDetailed() {
  573. c.Prepare()
  574. c.TplName = "manager/attach_detailed.tpl"
  575. c.Data["Action"] = "attach"
  576. attach_id, _ := strconv.Atoi(c.Ctx.Input.Param(":id"))
  577. if attach_id <= 0 {
  578. c.Abort("404")
  579. }
  580. attach, err := models.NewAttachmentResult().Find(attach_id)
  581. if err != nil {
  582. logs.Error("AttachDetailed => ", err)
  583. if err == orm.ErrNoRows {
  584. c.Abort("404")
  585. } else {
  586. c.Abort("500")
  587. }
  588. }
  589. attach.FilePath = filepath.Join(conf.WorkingDirectory, attach.FilePath)
  590. attach.HttpPath = conf.URLForWithCdnImage(attach.HttpPath)
  591. attach.IsExist = filetil.FileExists(attach.FilePath)
  592. c.Data["Model"] = attach
  593. }
  594. // 删除附件.
  595. func (c *ManagerController) AttachDelete() {
  596. c.Prepare()
  597. attachId, _ := c.GetInt("attach_id")
  598. if attachId <= 0 {
  599. c.Abort("404")
  600. }
  601. attach, err := models.NewAttachment().Find(attachId)
  602. if err != nil {
  603. logs.Error("AttachDelete => ", err)
  604. c.JsonResult(6001, err.Error())
  605. }
  606. attach.FilePath = filepath.Join(conf.WorkingDirectory, attach.FilePath)
  607. if err := attach.Delete(); err != nil {
  608. logs.Error("AttachDelete => ", err)
  609. c.JsonResult(6002, err.Error())
  610. }
  611. c.JsonResult(0, "ok")
  612. }
  613. // 标签列表
  614. func (c *ManagerController) LabelList() {
  615. c.Prepare()
  616. c.TplName = "manager/label_list.tpl"
  617. c.Data["Action"] = "label"
  618. pageIndex, _ := c.GetInt("page", 1)
  619. labels, totalCount, err := models.NewLabel().FindToPager(pageIndex, conf.PageSize)
  620. if err != nil {
  621. c.ShowErrorPage(50001, err.Error())
  622. }
  623. if totalCount > 0 {
  624. pager := pagination.NewPagination(c.Ctx.Request, totalCount, conf.PageSize, c.BaseUrl())
  625. c.Data["PageHtml"] = pager.HtmlPages()
  626. } else {
  627. c.Data["PageHtml"] = ""
  628. }
  629. c.Data["TotalPages"] = int(math.Ceil(float64(totalCount) / float64(conf.PageSize)))
  630. c.Data["Lists"] = labels
  631. }
  632. // 删除标签
  633. func (c *ManagerController) LabelDelete() {
  634. labelId, err := strconv.Atoi(c.Ctx.Input.Param(":id"))
  635. if err != nil {
  636. logs.Error("获取删除标签参数时出错:", err)
  637. c.JsonResult(50001, i18n.Tr(c.Lang, "message.param_error"))
  638. }
  639. if labelId <= 0 {
  640. c.JsonResult(50001, i18n.Tr(c.Lang, "message.param_error"))
  641. }
  642. label, err := models.NewLabel().FindFirst("label_id", labelId)
  643. if err != nil {
  644. logs.Error("查询标签时出错:", err)
  645. c.JsonResult(50001, "查询标签时出错:"+err.Error())
  646. }
  647. if err := label.Delete(); err != nil {
  648. c.JsonResult(50002, "删除失败:"+err.Error())
  649. } else {
  650. c.JsonResult(0, "ok")
  651. }
  652. }
  653. func (c *ManagerController) Config() {
  654. c.Prepare()
  655. c.TplName = "manager/config.tpl"
  656. c.Data["Action"] = "config"
  657. if c.Ctx.Input.IsPost() {
  658. content := strings.TrimSpace(c.GetString("configFileTextArea"))
  659. if content == "" {
  660. c.JsonResult(500, "配置文件不能为空")
  661. }
  662. tf, err := ioutil.TempFile(os.TempDir(), "mindoc")
  663. if err != nil {
  664. logs.Error("创建临时文件失败 ->", err)
  665. c.JsonResult(5001, "创建临时文件失败")
  666. }
  667. defer tf.Close()
  668. tf.WriteString(content)
  669. err = web.LoadAppConfig("ini", tf.Name())
  670. if err != nil {
  671. logs.Error("加载配置文件失败 ->", err)
  672. c.JsonResult(5002, "加载配置文件失败")
  673. }
  674. err = filetil.CopyFile(tf.Name(), conf.ConfigurationFile)
  675. if err != nil {
  676. logs.Error("保存配置文件失败 ->", err)
  677. c.JsonResult(5003, "保存配置文件失败")
  678. }
  679. c.JsonResult(0, "保存成功")
  680. }
  681. c.Data["ConfigContent"] = ""
  682. if b, err := ioutil.ReadFile(conf.ConfigurationFile); err == nil {
  683. c.Data["ConfigContent"] = string(b)
  684. }
  685. }
  686. func (c *ManagerController) Team() {
  687. c.Prepare()
  688. c.TplName = "manager/team.tpl"
  689. c.Data["Action"] = "team"
  690. pageIndex, _ := c.GetInt("page", 0)
  691. teams, totalCount, err := models.NewTeam().FindToPager(pageIndex, conf.PageSize)
  692. if err != nil && err != orm.ErrNoRows {
  693. c.ShowErrorPage(500, err.Error())
  694. }
  695. if err == orm.ErrNoRows || len(teams) <= 0 {
  696. c.Data["Result"] = template.JS("[]")
  697. c.Data["PageHtml"] = ""
  698. return
  699. }
  700. if totalCount > 0 {
  701. pager := pagination.NewPagination(c.Ctx.Request, totalCount, conf.PageSize, c.BaseUrl())
  702. c.Data["PageHtml"] = pager.HtmlPages()
  703. } else {
  704. c.Data["PageHtml"] = ""
  705. }
  706. b, err := json.Marshal(teams)
  707. if err != nil {
  708. c.Data["Result"] = template.JS("[]")
  709. } else {
  710. c.Data["Result"] = template.JS(string(b))
  711. }
  712. }
  713. func (c *ManagerController) TeamCreate() {
  714. c.Prepare()
  715. teamName := c.GetString("teamName")
  716. if teamName == "" {
  717. c.JsonResult(5001, i18n.Tr(c.Lang, "message.team_name_empty"))
  718. }
  719. team := models.NewTeam()
  720. team.MemberId = c.Member.MemberId
  721. team.TeamName = teamName
  722. if err := team.Save(); err == nil {
  723. c.JsonResult(0, "OK", team)
  724. } else {
  725. c.JsonResult(5002, err.Error())
  726. }
  727. }
  728. func (c *ManagerController) TeamEdit() {
  729. c.Prepare()
  730. teamName := c.GetString("teamName")
  731. teamId, _ := c.GetInt("teamId")
  732. if teamName == "" {
  733. c.JsonResult(5001, i18n.Tr(c.Lang, "message.team_name_empty"))
  734. }
  735. if teamId <= 0 {
  736. c.JsonResult(5002, i18n.Tr(c.Lang, "message.team_id_empty"))
  737. }
  738. team, err := models.NewTeam().First(teamId)
  739. c.CheckJsonError(5003, err)
  740. team.TeamName = teamName
  741. err = team.Save()
  742. c.CheckJsonError(5004, err)
  743. c.JsonResult(0, "OK", team)
  744. }
  745. func (c *ManagerController) TeamDelete() {
  746. c.Prepare()
  747. teamId, _ := c.GetInt("teamId")
  748. if teamId <= 0 {
  749. c.JsonResult(5002, i18n.Tr(c.Lang, "message.team_id_empty"))
  750. }
  751. err := models.NewTeam().Delete(teamId)
  752. c.CheckJsonError(5001, err)
  753. c.JsonResult(0, "OK")
  754. }
  755. func (c *ManagerController) TeamMemberList() {
  756. c.Prepare()
  757. c.TplName = "manager/team_member_list.tpl"
  758. c.Data["Action"] = "team"
  759. teamId, _ := strconv.Atoi(c.Ctx.Input.Param(":id"))
  760. if teamId <= 0 {
  761. c.ShowErrorPage(500, i18n.Tr(c.Lang, "message.param_error"))
  762. }
  763. pageIndex, _ := c.GetInt("page", 0)
  764. team, err := models.NewTeam().First(teamId)
  765. if err == orm.ErrNoRows {
  766. c.ShowErrorPage(404, "团队不存在")
  767. }
  768. c.CheckErrorResult(500, err)
  769. c.Data["Model"] = team
  770. teams, totalCount, err := models.NewTeamMember().SetLang(c.Lang).FindToPager(teamId, pageIndex, conf.PageSize)
  771. if err != nil && err != orm.ErrNoRows {
  772. c.ShowErrorPage(500, err.Error())
  773. }
  774. if err == orm.ErrNoRows || len(teams) <= 0 {
  775. c.Data["Result"] = template.JS("[]")
  776. c.Data["PageHtml"] = ""
  777. return
  778. }
  779. if totalCount > 0 {
  780. pager := pagination.NewPagination(c.Ctx.Request, totalCount, conf.PageSize, c.BaseUrl())
  781. c.Data["PageHtml"] = pager.HtmlPages()
  782. } else {
  783. c.Data["PageHtml"] = ""
  784. }
  785. b, err := json.Marshal(teams)
  786. if err != nil {
  787. logs.Error("编码 JSON 结果失败 ->", err)
  788. c.Data["Result"] = template.JS("[]")
  789. } else {
  790. c.Data["Result"] = template.JS(string(b))
  791. }
  792. }
  793. // 搜索团队用户.
  794. func (c *ManagerController) TeamSearchMember() {
  795. c.Prepare()
  796. teamId, _ := c.GetInt("teamId")
  797. keyword := strings.TrimSpace(c.GetString("q"))
  798. if teamId <= 0 {
  799. c.JsonResult(500, i18n.Tr(c.Lang, "message.param_error"))
  800. }
  801. searchResult, err := models.NewTeamMember().FindNotJoinMemberByAccount(teamId, keyword, 10)
  802. if err != nil {
  803. c.JsonResult(500, err.Error())
  804. }
  805. c.JsonResult(0, "OK", searchResult)
  806. }
  807. func (c *ManagerController) TeamMemberAdd() {
  808. c.Prepare()
  809. teamId, _ := c.GetInt("teamId")
  810. memberId, _ := c.GetInt("memberId")
  811. roleId, _ := c.GetInt("roleId")
  812. if teamId <= 0 || memberId <= 0 || roleId <= 0 || roleId > int(conf.BookObserver) {
  813. c.JsonResult(5001, i18n.Tr(c.Lang, "message.system_error"))
  814. }
  815. teamMember := models.NewTeamMember()
  816. teamMember.MemberId = memberId
  817. teamMember.TeamId = teamId
  818. teamMember.RoleId = conf.BookRole(roleId)
  819. if err := teamMember.Save(); err != nil {
  820. c.CheckJsonError(5001, err)
  821. }
  822. teamMember.Include()
  823. c.JsonResult(0, "OK", teamMember)
  824. }
  825. func (c *ManagerController) TeamMemberDelete() {
  826. c.Prepare()
  827. memberId, _ := c.GetInt("memberId")
  828. teamId, _ := c.GetInt("teamId")
  829. teamMember, err := models.NewTeamMember().FindFirst(teamId, memberId)
  830. if err != nil {
  831. c.JsonResult(5001, "用户不存在或已禁用")
  832. }
  833. err = teamMember.Delete(teamMember.TeamMemberId)
  834. if err != nil {
  835. c.JsonResult(5002, i18n.Tr(c.Lang, "message.failed"))
  836. }
  837. c.JsonResult(0, "ok")
  838. }
  839. func (c *ManagerController) TeamChangeMemberRole() {
  840. c.Prepare()
  841. memberId, _ := c.GetInt("memberId")
  842. roleId, _ := c.GetInt("roleId")
  843. teamId, _ := c.GetInt("teamId")
  844. if memberId <= 0 || roleId <= 0 || teamId <= 0 || roleId > int(conf.BookObserver) {
  845. c.JsonResult(5001, i18n.Tr(c.Lang, "message.param_error"))
  846. }
  847. teamMember, err := models.NewTeamMember().ChangeRoleId(teamId, memberId, conf.BookRole(roleId))
  848. if err != nil {
  849. c.JsonResult(5002, err.Error())
  850. } else {
  851. teamMember.SetLang(c.Lang).Include()
  852. c.JsonResult(0, "OK", teamMember)
  853. }
  854. }
  855. // 团队项目列表.
  856. func (c *ManagerController) TeamBookList() {
  857. c.Prepare()
  858. c.TplName = "manager/team_book_list.tpl"
  859. c.Data["Action"] = "team"
  860. teamId, _ := strconv.Atoi(c.Ctx.Input.Param(":id"))
  861. pageIndex, _ := c.GetInt("page", 0)
  862. if teamId <= 0 {
  863. c.JsonResult(5002, i18n.Tr(c.Lang, "message.team_id_empty"))
  864. }
  865. team, err := models.NewTeam().First(teamId)
  866. if err == orm.ErrNoRows {
  867. c.ShowErrorPage(404, "团队不存在")
  868. }
  869. c.CheckErrorResult(500, err)
  870. c.Data["Model"] = team
  871. teams, totalCount, err := models.NewTeamRelationship().FindToPager(teamId, pageIndex, conf.PageSize)
  872. if err != nil && err != orm.ErrNoRows {
  873. c.ShowErrorPage(500, err.Error())
  874. }
  875. if err == orm.ErrNoRows || len(teams) <= 0 {
  876. c.Data["Result"] = template.JS("[]")
  877. c.Data["PageHtml"] = ""
  878. return
  879. }
  880. if totalCount > 0 {
  881. pager := pagination.NewPagination(c.Ctx.Request, totalCount, conf.PageSize, c.BaseUrl())
  882. c.Data["PageHtml"] = pager.HtmlPages()
  883. } else {
  884. c.Data["PageHtml"] = ""
  885. }
  886. b, err := json.Marshal(teams)
  887. if err != nil {
  888. logs.Error("编码 JSON 结果失败 ->", err)
  889. c.Data["Result"] = template.JS("[]")
  890. } else {
  891. c.Data["Result"] = template.JS(string(b))
  892. }
  893. }
  894. // 给团队增加项目.
  895. func (c *ManagerController) TeamBookAdd() {
  896. c.Prepare()
  897. teamId, _ := c.GetInt("teamId")
  898. bookId, _ := c.GetInt("bookId")
  899. if teamId <= 0 || bookId <= 0 {
  900. c.JsonResult(500, i18n.Tr(c.Lang, "message.param_error"))
  901. }
  902. teamRel := models.NewTeamRelationship()
  903. teamRel.BookId = bookId
  904. teamRel.TeamId = teamId
  905. err := teamRel.Save()
  906. if err != nil {
  907. c.JsonResult(5001, err.Error())
  908. } else {
  909. teamRel.Include()
  910. c.JsonResult(0, "OK", teamRel)
  911. }
  912. }
  913. // 搜索未参与的项目.
  914. func (c *ManagerController) TeamSearchBook() {
  915. c.Prepare()
  916. teamId, _ := c.GetInt("teamId")
  917. keyword := strings.TrimSpace(c.GetString("q"))
  918. if teamId <= 0 {
  919. c.JsonResult(500, i18n.Tr(c.Lang, "message.param_error"))
  920. }
  921. searchResult, err := models.NewTeamRelationship().FindNotJoinBookByName(teamId, keyword, 10)
  922. if err != nil {
  923. c.JsonResult(500, err.Error())
  924. }
  925. c.JsonResult(0, "OK", searchResult)
  926. }
  927. // 删除团队项目.
  928. func (c *ManagerController) TeamBookDelete() {
  929. c.Prepare()
  930. teamRelationshipId, _ := c.GetInt("teamRelId")
  931. if teamRelationshipId <= 0 {
  932. c.JsonResult(500, i18n.Tr(c.Lang, "message.param_error"))
  933. }
  934. err := models.NewTeamRelationship().Delete(teamRelationshipId)
  935. if err != nil {
  936. c.JsonResult(5001, i18n.Tr(c.Lang, "message.failed"))
  937. }
  938. c.JsonResult(0, "OK")
  939. }
  940. // 项目空间列表.
  941. func (c *ManagerController) Itemsets() {
  942. c.Prepare()
  943. c.TplName = "manager/itemsets.tpl"
  944. c.Data["Action"] = "itemsets"
  945. pageIndex, _ := c.GetInt("page", 0)
  946. items, totalCount, err := models.NewItemsets().FindToPager(pageIndex, conf.PageSize)
  947. if err != nil && err != orm.ErrNoRows {
  948. c.ShowErrorPage(500, err.Error())
  949. }
  950. if err == orm.ErrNoRows || len(items) <= 0 {
  951. c.Data["Lists"] = items
  952. c.Data["PageHtml"] = ""
  953. return
  954. }
  955. if totalCount > 0 {
  956. pager := pagination.NewPagination(c.Ctx.Request, totalCount, conf.PageSize, c.BaseUrl())
  957. c.Data["PageHtml"] = pager.HtmlPages()
  958. } else {
  959. c.Data["PageHtml"] = ""
  960. }
  961. c.Data["Lists"] = items
  962. }
  963. // 编辑或添加项目空间.
  964. func (c *ManagerController) ItemsetsEdit() {
  965. c.Prepare()
  966. itemId, _ := c.GetInt("itemId")
  967. itemName := strings.TrimSpace(c.GetString("itemName"))
  968. itemKey := strings.TrimSpace(c.GetString("itemKey"))
  969. if itemName == "" || itemKey == "" {
  970. c.JsonResult(5001, i18n.Tr(c.Lang, "message.param_error"))
  971. }
  972. var item *models.Itemsets
  973. var err error
  974. if itemId > 0 {
  975. if item, err = models.NewItemsets().First(itemId); err != nil {
  976. if err == orm.ErrNoRows {
  977. c.JsonResult(5002, i18n.Tr(c.Lang, "message.project_space_not_exist"))
  978. } else {
  979. c.JsonResult(5003, "查询项目空间出错")
  980. }
  981. }
  982. } else {
  983. item = models.NewItemsets()
  984. }
  985. item.ItemKey = itemKey
  986. item.ItemName = itemName
  987. item.MemberId = c.Member.MemberId
  988. item.ModifyAt = c.Member.MemberId
  989. if err := item.Save(); err != nil {
  990. c.JsonResult(5004, err.Error())
  991. }
  992. c.JsonResult(0, "OK")
  993. }
  994. // 删除项目空间.
  995. func (c *ManagerController) ItemsetsDelete() {
  996. c.Prepare()
  997. itemId, _ := c.GetInt("itemId")
  998. if err := models.NewItemsets().Delete(itemId); err != nil {
  999. c.JsonResult(5001, err.Error())
  1000. }
  1001. c.JsonResult(0, "OK")
  1002. }