ManagerController.go 30 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788899091929394959697989910010110210310410510610710810911011111211311411511611711811912012112212312412512612712812913013113213313413513613713813914014114214314414514614714814915015115215315415515615715815916016116216316416516616716816917017117217317417517617717817918018118218318418518618718818919019119219319419519619719819920020120220320420520620720820921021121221321421521621721821922022122222322422522622722822923023123223323423523623723823924024124224324424524624724824925025125225325425525625725825926026126226326426526626726826927027127227327427527627727827928028128228328428528628728828929029129229329429529629729829930030130230330430530630730830931031131231331431531631731831932032132232332432532632732832933033133233333433533633733833934034134234334434534634734834935035135235335435535635735835936036136236336436536636736836937037137237337437537637737837938038138238338438538638738838939039139239339439539639739839940040140240340440540640740840941041141241341441541641741841942042142242342442542642742842943043143243343443543643743843944044144244344444544644744844945045145245345445545645745845946046146246346446546646746846947047147247347447547647747847948048148248348448548648748848949049149249349449549649749849950050150250350450550650750850951051151251351451551651751851952052152252352452552652752852953053153253353453553653753853954054154254354454554654754854955055155255355455555655755855956056156256356456556656756856957057157257357457557657757857958058158258358458558658758858959059159259359459559659759859960060160260360460560660760860961061161261361461561661761861962062162262362462562662762862963063163263363463563663763863964064164264364464564664764864965065165265365465565665765865966066166266366466566666766866967067167267367467567667767867968068168268368468568668768868969069169269369469569669769869970070170270370470570670770870971071171271371471571671771871972072172272372472572672772872973073173273373473573673773873974074174274374474574674774874975075175275375475575675775875976076176276376476576676776876977077177277377477577677777877978078178278378478578678778878979079179279379479579679779879980080180280380480580680780880981081181281381481581681781881982082182282382482582682782882983083183283383483583683783883984084184284384484584684784884985085185285385485585685785885986086186286386486586686786886987087187287387487587687787887988088188288388488588688788888989089189289389489589689789889990090190290390490590690790890991091191291391491591691791891992092192292392492592692792892993093193293393493593693793893994094194294394494594694794894995095195295395495595695795895996096196296396496596696796896997097197297397497597697797897998098198298398498598698798898999099199299399499599699799899910001001100210031004100510061007100810091010101110121013101410151016101710181019102010211022102310241025102610271028102910301031103210331034103510361037103810391040104110421043104410451046104710481049105010511052105310541055105610571058105910601061106210631064106510661067106810691070107110721073107410751076107710781079108010811082108310841085108610871088108910901091109210931094109510961097109810991100110111021103110411051106110711081109111011111112111311141115111611171118111911201121112211231124112511261127112811291130113111321133113411351136113711381139114011411142114311441145114611471148114911501151115211531154115511561157115811591160116111621163116411651166116711681169117011711172117311741175117611771178117911801181118211831184118511861187118811891190119111921193119411951196119711981199120012011202120312041205120612071208120912101211
  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) {
  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. c.JsonResult(0, "OK", teamMember)
  852. }
  853. }
  854. // 团队项目列表.
  855. func (c *ManagerController) TeamBookList() {
  856. c.Prepare()
  857. c.TplName = "manager/team_book_list.tpl"
  858. c.Data["Action"] = "team"
  859. teamId, _ := strconv.Atoi(c.Ctx.Input.Param(":id"))
  860. pageIndex, _ := c.GetInt("page", 0)
  861. if teamId <= 0 {
  862. c.JsonResult(5002, i18n.Tr(c.Lang, "message.team_id_empty"))
  863. }
  864. team, err := models.NewTeam().First(teamId)
  865. if err == orm.ErrNoRows {
  866. c.ShowErrorPage(404, "团队不存在")
  867. }
  868. c.CheckErrorResult(500, err)
  869. c.Data["Model"] = team
  870. teams, totalCount, err := models.NewTeamRelationship().FindToPager(teamId, pageIndex, conf.PageSize)
  871. if err != nil && err != orm.ErrNoRows {
  872. c.ShowErrorPage(500, err.Error())
  873. }
  874. if err == orm.ErrNoRows || len(teams) <= 0 {
  875. c.Data["Result"] = template.JS("[]")
  876. c.Data["PageHtml"] = ""
  877. return
  878. }
  879. if totalCount > 0 {
  880. pager := pagination.NewPagination(c.Ctx.Request, totalCount, conf.PageSize, c.BaseUrl())
  881. c.Data["PageHtml"] = pager.HtmlPages()
  882. } else {
  883. c.Data["PageHtml"] = ""
  884. }
  885. b, err := json.Marshal(teams)
  886. if err != nil {
  887. logs.Error("编码 JSON 结果失败 ->", err)
  888. c.Data["Result"] = template.JS("[]")
  889. } else {
  890. c.Data["Result"] = template.JS(string(b))
  891. }
  892. }
  893. // 给团队增加项目.
  894. func (c *ManagerController) TeamBookAdd() {
  895. c.Prepare()
  896. teamId, _ := c.GetInt("teamId")
  897. bookId, _ := c.GetInt("bookId")
  898. if teamId <= 0 || bookId <= 0 {
  899. c.JsonResult(500, i18n.Tr(c.Lang, "message.param_error"))
  900. }
  901. teamRel := models.NewTeamRelationship()
  902. teamRel.BookId = bookId
  903. teamRel.TeamId = teamId
  904. err := teamRel.Save()
  905. if err != nil {
  906. c.JsonResult(5001, err.Error())
  907. } else {
  908. teamRel.Include()
  909. c.JsonResult(0, "OK", teamRel)
  910. }
  911. }
  912. // 搜索未参与的项目.
  913. func (c *ManagerController) TeamSearchBook() {
  914. c.Prepare()
  915. teamId, _ := c.GetInt("teamId")
  916. keyword := strings.TrimSpace(c.GetString("q"))
  917. if teamId <= 0 {
  918. c.JsonResult(500, i18n.Tr(c.Lang, "message.param_error"))
  919. }
  920. searchResult, err := models.NewTeamRelationship().FindNotJoinBookByName(teamId, keyword, 10)
  921. if err != nil {
  922. c.JsonResult(500, err.Error())
  923. }
  924. c.JsonResult(0, "OK", searchResult)
  925. }
  926. // 删除团队项目.
  927. func (c *ManagerController) TeamBookDelete() {
  928. c.Prepare()
  929. teamRelationshipId, _ := c.GetInt("teamRelId")
  930. if teamRelationshipId <= 0 {
  931. c.JsonResult(500, i18n.Tr(c.Lang, "message.param_error"))
  932. }
  933. err := models.NewTeamRelationship().Delete(teamRelationshipId)
  934. if err != nil {
  935. c.JsonResult(5001, i18n.Tr(c.Lang, "message.failed"))
  936. }
  937. c.JsonResult(0, "OK")
  938. }
  939. // 项目空间列表.
  940. func (c *ManagerController) Itemsets() {
  941. c.Prepare()
  942. c.TplName = "manager/itemsets.tpl"
  943. c.Data["Action"] = "itemsets"
  944. pageIndex, _ := c.GetInt("page", 0)
  945. items, totalCount, err := models.NewItemsets().FindToPager(pageIndex, conf.PageSize)
  946. if err != nil && err != orm.ErrNoRows {
  947. c.ShowErrorPage(500, err.Error())
  948. }
  949. if err == orm.ErrNoRows || len(items) <= 0 {
  950. c.Data["Lists"] = items
  951. c.Data["PageHtml"] = ""
  952. return
  953. }
  954. if totalCount > 0 {
  955. pager := pagination.NewPagination(c.Ctx.Request, totalCount, conf.PageSize, c.BaseUrl())
  956. c.Data["PageHtml"] = pager.HtmlPages()
  957. } else {
  958. c.Data["PageHtml"] = ""
  959. }
  960. c.Data["Lists"] = items
  961. }
  962. // 编辑或添加项目空间.
  963. func (c *ManagerController) ItemsetsEdit() {
  964. c.Prepare()
  965. itemId, _ := c.GetInt("itemId")
  966. itemName := strings.TrimSpace(c.GetString("itemName"))
  967. itemKey := strings.TrimSpace(c.GetString("itemKey"))
  968. if itemName == "" || itemKey == "" {
  969. c.JsonResult(5001, i18n.Tr(c.Lang, "message.param_error"))
  970. }
  971. var item *models.Itemsets
  972. var err error
  973. if itemId > 0 {
  974. if item, err = models.NewItemsets().First(itemId); err != nil {
  975. if err == orm.ErrNoRows {
  976. c.JsonResult(5002, i18n.Tr(c.Lang, "message.project_space_not_exist"))
  977. } else {
  978. c.JsonResult(5003, "查询项目空间出错")
  979. }
  980. }
  981. } else {
  982. item = models.NewItemsets()
  983. }
  984. item.ItemKey = itemKey
  985. item.ItemName = itemName
  986. item.MemberId = c.Member.MemberId
  987. item.ModifyAt = c.Member.MemberId
  988. if err := item.Save(); err != nil {
  989. c.JsonResult(5004, err.Error())
  990. }
  991. c.JsonResult(0, "OK")
  992. }
  993. // 删除项目空间.
  994. func (c *ManagerController) ItemsetsDelete() {
  995. c.Prepare()
  996. itemId, _ := c.GetInt("itemId")
  997. if err := models.NewItemsets().Delete(itemId); err != nil {
  998. c.JsonResult(5001, err.Error())
  999. }
  1000. c.JsonResult(0, "OK")
  1001. }