industrial_subject.go 2.7 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576
  1. package models
  2. import (
  3. "github.com/beego/beego/v2/client/orm"
  4. "time"
  5. )
  6. type IndustrialSubjectByArticle struct {
  7. IndustrialSubjectId int `description:"标的id"`
  8. IndustrialManagementId int `description:"产业id"`
  9. SubjectName string `description:"标的名称"`
  10. IndustryName string `description:"产业名称"`
  11. ArticleId int `description:"文章ID"`
  12. }
  13. type SubjectArticlGroupList struct {
  14. SubjectName string `description:"标的名称"`
  15. ArticleId int `description:"cygx_article表的文章ID"`
  16. IndustrialSubjectId int `description:"cygx_industrial_subject表的文章ID"`
  17. }
  18. type CygxIndustrialSubject struct {
  19. IndustrialSubjectId int `orm:"column(industrial_subject_id);pk" description:"标的id"`
  20. IndustrialManagementId int `description:"产业id"`
  21. SubjectName string `description:"标的名称"`
  22. CreateTime time.Time `description:"创建时间"`
  23. Source int `description:"来源,1正常添加,2:通过文章添加,3通过活动添加(默认为1)"`
  24. }
  25. // 获取标的列表
  26. func GetArticleGroupSubjectList(pars []interface{}, condition string) (items []*IndustrialSubjectByArticle, err error) {
  27. o := orm.NewOrm()
  28. sql := `SELECT
  29. s.subject_name,
  30. s.industrial_subject_id,
  31. s.industrial_management_id,
  32. g.article_id
  33. FROM
  34. cygx_industrial_article_group_subject AS g
  35. INNER JOIN cygx_industrial_subject AS s ON s.industrial_subject_id = g.industrial_subject_id
  36. WHERE
  37. 1 = 1 ` + condition
  38. _, err = o.Raw(sql, pars).QueryRows(&items)
  39. return
  40. }
  41. // 列表
  42. func GetSubjectArticlGroupList(condition string, pars []interface{}) (items []*SubjectArticlGroupList, err error) {
  43. o := orm.NewOrm()
  44. sql := `SELECT
  45. s.subject_name,
  46. s.industrial_subject_id,
  47. ag.article_id
  48. FROM
  49. cygx_industrial_article_group_subject AS ag
  50. INNER JOIN cygx_industrial_subject AS s ON s.industrial_subject_id = ag.industrial_subject_id
  51. WHERE 1= 1 ` + condition
  52. _, err = o.Raw(sql, pars).QueryRows(&items)
  53. return
  54. }
  55. func GetcygxIndustrialSubject(industrialManagementId int) (items []*IndustrialSubject, err error) {
  56. o := orm.NewOrm()
  57. sql := `SELECT subject_name,industrial_subject_id FROM cygx_industrial_subject WHERE industrial_management_id = ?`
  58. _, err = o.Raw(sql, industrialManagementId).QueryRows(&items)
  59. return
  60. }
  61. // GetCygxIndustrialSubjectList 获取标的列表
  62. func GetCygxIndustrialSubjectListCondition(condition string, pars []interface{}) (items []*CygxIndustrialSubject, err error) {
  63. sql := `SELECT * FROM cygx_industrial_subject WHERE 1 = 1 `
  64. if condition != `` {
  65. sql += condition
  66. }
  67. _, err = orm.NewOrm().Raw(sql, pars).QueryRows(&items)
  68. return
  69. }