ArticleTopicDao.go 1.5 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758
  1. package manage
  2. import (
  3. "demo/configs"
  4. "demo/data/domain"
  5. "demo/data/domain/vo"
  6. )
  7. func GetInIdListArticleTopic(ids []int) ([]domain.ArticleTopic, error) {
  8. rows, err := configs.Engine.In("id", ids).Rows(&domain.ArticleTopic{})
  9. if err != nil {
  10. return make([]domain.ArticleTopic, 0), err
  11. }
  12. defer rows.Close()
  13. var list []domain.ArticleTopic
  14. for rows.Next() {
  15. var u domain.ArticleTopic
  16. list = append(list, u)
  17. }
  18. return list, nil
  19. }
  20. func GetListArticleTopic(articleTopic domain.ArticleTopic, pageNum, pageSize int) (vo.BaseListVo, error) {
  21. rows, err := configs.Engine.Limit(pageSize, (pageNum-1)*pageSize).Desc("id").Rows(&articleTopic)
  22. var vo vo.BaseListVo
  23. if err != nil {
  24. return vo, err
  25. }
  26. vo.PageNum = pageNum
  27. vo.PageSize = pageSize
  28. vo.List = make([]any, 0)
  29. for rows.Next() {
  30. var u domain.ArticleTopic
  31. rows.Scan(&u)
  32. vo.List = append(vo.List, u)
  33. }
  34. //查询数量
  35. count, err := configs.Engine.Count(&articleTopic)
  36. vo.Total = int(count)
  37. return vo, nil
  38. }
  39. func SaveArticleTopic(articleTopic *domain.ArticleTopic) (domain.ArticleTopic, error) {
  40. _, err := configs.Engine.Insert(&articleTopic)
  41. if err != nil {
  42. return *articleTopic, err
  43. }
  44. return *articleTopic, nil
  45. }
  46. func SetArticleTopic(articleTopicMap map[string]interface{}, id int) (domain.ArticleTopic, bool, error) {
  47. var articleTopic domain.ArticleTopic
  48. _, err := configs.Engine.Table("article_topic").Where("id = ?", id).Update(articleTopicMap)
  49. if err != nil {
  50. return articleTopic, false, err
  51. }
  52. return articleTopic, true, nil
  53. }