industry_fllow.go 2.9 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778
  1. package cygx
  2. import (
  3. "github.com/beego/beego/v2/client/orm"
  4. "time"
  5. //"time"
  6. )
  7. type CygxIndustryFllow struct {
  8. Id int `orm:"column(id);pk"`
  9. IndustrialManagementId int `description:"产业D"`
  10. UserId int `description:"用户ID"`
  11. Mobile string `description:"手机号"`
  12. Email string `description:"邮箱"`
  13. CompanyId int `description:"公司id"`
  14. CompanyName string `description:"公司名称"`
  15. Type int `description:"操作方式,1报名,2取消报名"`
  16. CreateTime time.Time `description:"创建时间"`
  17. ModifyTime time.Time `description:"更新时间"`
  18. RealName string `description:"用户实际名称"`
  19. Source int `description:"来源1查研观向,2查研观向小助手,3勾选全部赛道的用户进行自动关注"`
  20. }
  21. //关注产业列表
  22. func GetCygxIndustryFllowByUser(uid, startSize, pageSize int) (items []*UserInteraction, err error) {
  23. o := orm.NewOrm()
  24. sql := `SELECT
  25. m.industry_name,
  26. f.modify_time as create_time,
  27. ( SELECT GROUP_CONCAT( DISTINCT s.subject_name SEPARATOR '/' ) FROM cygx_industrial_subject AS s WHERE s.industrial_management_id = m.industrial_management_id ) AS subject_name_str
  28. FROM
  29. cygx_industry_fllow AS f
  30. INNER JOIN cygx_industrial_management AS m ON m.industrial_management_id = f.industrial_management_id
  31. WHERE
  32. user_id = ?
  33. AND type = 1
  34. ORDER BY
  35. f.create_time DESC LIMIT ?,? `
  36. _, err = o.Raw(sql, uid, startSize, pageSize).QueryRows(&items)
  37. return
  38. }
  39. //关注产业数量
  40. func GetCygxIndustryFllowCount(uid int) (count int, err error) {
  41. o := orm.NewOrm()
  42. sqlCount := ` SELECT COUNT(1) AS count FROM cygx_industry_fllow WHERE user_id = ? AND type = 1 `
  43. err = o.Raw(sqlCount, uid).QueryRow(&count)
  44. return
  45. }
  46. //判断用户是否关注这些产业ID
  47. func GetCygxIndustryFllowCountByUser(uid int, industrialManagementd string) (count int, err error) {
  48. o := orm.NewOrm()
  49. sqlCount := ` SELECT COUNT(1) AS count FROM cygx_industry_fllow WHERE user_id = ? AND type = 1 AND industrial_management_id IN (` + industrialManagementd + `)`
  50. err = o.Raw(sqlCount, uid).QueryRow(&count)
  51. return
  52. }
  53. //GetUserFllowIndustrialListByUserIdAndIndustrial 通过用户ID 跟产业ID获取用户关注的产业列表
  54. func GetUserFllowIndustrialListByUserIdAndIndustrial(userIds, industrials string) (items []*CygxIndustryFllow, err error) {
  55. o := orm.NewOrm()
  56. sql := `SELECT * FROM cygx_industry_fllow
  57. WHERE 1 = 1
  58. AND user_id IN ( ` + userIds + ` )
  59. AND industrial_management_id IN ( ` + industrials + `) `
  60. _, err = o.Raw(sql).QueryRows(&items)
  61. return
  62. }
  63. //批量添加
  64. func AddCygxIndustryFllowMulti(items []*CygxIndustryFllow) (err error) {
  65. o := orm.NewOrm()
  66. if len(items) > 0 {
  67. //批量添加新的关注记录
  68. _, err = o.InsertMulti(len(items), items)
  69. }
  70. return
  71. }