activity_points_set.go 5.6 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107
  1. package cygx
  2. import (
  3. "github.com/beego/beego/v2/client/orm"
  4. "time"
  5. )
  6. type YanXuanActivityPointsRedis struct {
  7. UserId int `description:"用户ID"`
  8. ComapnyId int `description:"公司ID"`
  9. CompanyContractId int `description:"合同id"`
  10. ActivityId int `description:"活动ID"`
  11. PublishStatus int `description:"发布状态 1已发布,0未发布"`
  12. SourceType int `description:"1:报名、 2:取消报名、3:活动编辑、4:活动发布,取消发布、5:活动到会。"`
  13. AdminId int `description:"管理员、销售ID"`
  14. Source int `description:" 来源,1客户端,2后台添加, 3开发人员手动添加、4定时任务"`
  15. RegisterPlatform int `description:"来源 1小程序,2:网页"`
  16. CreateTime time.Time `description:"创建时间"`
  17. }
  18. type CygxActivityPointsSet struct {
  19. Id int `gorm:"column:id;primary_key;AUTO_INCREMENT" json:"id"`
  20. ActivityId int `gorm:"column:activity_id;NOT NULL" json:"activity_id"` // 活动ID
  21. PointsObject string `gorm:"column:points_object;default:1;NOT NULL" json:"points_object"` // 扣点对象,1:参会人、2:办会人、3:办会人和参会人
  22. CompanyId int `gorm:"column:company_id;default:0;NOT NULL" json:"company_id"` // 公司ID
  23. CompanyName string `gorm:"column:company_name;NOT NULL" json:"company_name"` // 公司名称
  24. UserPointsNum string `gorm:"column:user_points_num;default:0;NOT NULL" json:"user_points_num"` // 参会人扣点数量
  25. PointsType string `gorm:"column:points_type;default:0;NOT NULL" json:"points_type"` // 扣点形式,1:报名即扣点,2:到会即扣点
  26. CompanyPointsNum string `gorm:"column:company_points_num;default:0;NOT NULL" json:"company_points_num"` // 办会人扣点数量
  27. CancelDeadlineType string `gorm:"column:cancel_deadline_type;default:0;NOT NULL" json:"cancel_deadline_type"` // 取消报名截止时间类型,0:不设置,1:同报名截止时间, 2:24小时之前、3:48小时之前
  28. CreateTime time.Time `gorm:"column:create_time;NOT NULL" json:"create_time"` // 创建时间
  29. ModifyTime time.Time `gorm:"column:modify_time;NOT NULL" json:"modify_time"` // 更新时间
  30. }
  31. type CygxActivityPointsSetRsq struct {
  32. ActivityId int `gorm:"column:activity_id;NOT NULL" json:"ActivityId"` // 活动ID
  33. PointsObject string `gorm:"column:points_object;NOT NULL" json:"PointsObject"` // 扣点对象,1:参会人、2:办会人、3:办会人和参会人
  34. CompanyId int `gorm:"column:company_id;default:0;NOT NULL" json:"CompanyId"` // 公司ID
  35. CompanyName string `gorm:"column:company_name;NOT NULL" json:"CompanyName"` // 公司名称
  36. UserPointsNum string `gorm:"column:user_points_num;default:0;NOT NULL" json:"UserPointsNum"` // 参会人扣点数量
  37. PointsType string `gorm:"column:points_type;default:0;NOT NULL" json:"PointsType"` // 扣点形式,1:报名即扣点,2:到会即扣点
  38. CompanyPointsNum string `gorm:"column:company_points_num;default:0;NOT NULL" json:"CompanyPointsNum"` // 办会人扣点数量
  39. CancelDeadlineType string `description:"取消报名截止时间类型,0:不设置,1:同报名截止时间, 2:24小时之前、3:48小时之前"`
  40. }
  41. type CygxActivityPointsSetConfigListResp struct {
  42. List []*CygxActivityPointsSetConfigResp
  43. }
  44. type CygxActivityPointsSetConfigResp struct {
  45. PointsNum string `gorm:"column:user_points_num;default:0;NOT NULL" json:"PointsNum"` // 扣点数量
  46. }
  47. // 通过活动ID获取详情
  48. func GetCygxActivityPointsSetDetail(activityId int) (item *CygxActivityPointsSetRsq, err error) {
  49. o := orm.NewOrmUsingDB("hz_cygx")
  50. sql := `SELECT * FROM cygx_activity_points_set WHERE activity_id=? `
  51. err = o.Raw(sql, activityId).QueryRow(&item)
  52. return
  53. }
  54. // 通过活动ID获取详情
  55. func GetCygxActivityPointsSetUserNum(activityId int) (userPointsNum float64, err error) {
  56. o := orm.NewOrmUsingDB("hz_cygx")
  57. sql := `SELECT user_points_num FROM cygx_activity_points_set WHERE activity_id=? `
  58. err = o.Raw(sql, activityId).QueryRow(&userPointsNum)
  59. return
  60. }
  61. // 通过互动ID获取数量
  62. func GetCygxActivityPointsSetCountByActivityId(ActivityId int) (count int, err error) {
  63. sqlCount := ` SELECT COUNT(1) AS count FROM cygx_activity_points_set WHERE activity_id=? `
  64. o := orm.NewOrmUsingDB("hz_cygx")
  65. err = o.Raw(sqlCount, ActivityId).QueryRow(&count)
  66. return
  67. }
  68. type CygxActivitySearcCompanyListResp struct {
  69. List []*CygxActivitySearcCompanyResp
  70. }
  71. type CygxActivitySearcCompanyResp struct {
  72. CompanyId int `description:"公司ID"`
  73. CompanyName string `description:"公司名称"`
  74. RealName string `description:"用户实际名称"`
  75. AdminId int `description:"销售/管理员ID"`
  76. }
  77. // 搜索权益机构名称以及管理的销售
  78. func GetCygxActivitySearcCompanyList(companyName string) (items []*CygxActivitySearcCompanyResp, err error) {
  79. o := orm.NewOrm()
  80. sql := `SELECT
  81. c.company_id,
  82. c.company_name,
  83. a.admin_id,
  84. a.real_name
  85. FROM
  86. company AS c
  87. INNER JOIN company_product AS p ON p.company_id = c.company_id
  88. INNER JOIN admin AS a ON a.admin_id = p.seller_id
  89. WHERE
  90. 1 = 1
  91. AND p.product_id = 2
  92. AND c.company_name LIKE '%` + companyName + `%' `
  93. _, err = o.Raw(sql).QueryRows(&items)
  94. return
  95. }