|
@@ -42,7 +42,7 @@ type SignupStatus struct {
|
|
|
GoBindEmail bool `description:"是否去绑定邮箱"`
|
|
|
}
|
|
|
|
|
|
-//我的日程
|
|
|
+// 我的日程
|
|
|
type CygxMySchedule struct {
|
|
|
Id int `orm:"column(id);pk"`
|
|
|
ActivityId int `description:"活动ID"`
|
|
@@ -54,7 +54,7 @@ type CygxMySchedule struct {
|
|
|
CompanyName string `description:"公司名称"`
|
|
|
}
|
|
|
|
|
|
-//报名记录日志
|
|
|
+// 报名记录日志
|
|
|
type CygxActivitySignupLog struct {
|
|
|
Id int `orm:"column(id);pk"`
|
|
|
ActivityId int `description:"活动ID"`
|
|
@@ -67,7 +67,7 @@ type CygxActivitySignupLog struct {
|
|
|
Type int `description:"操作方式,1报名,2取消报名"`
|
|
|
}
|
|
|
|
|
|
-//添加报名信息
|
|
|
+// 添加报名信息
|
|
|
func AddActivitySignup(item *CygxActivitySignup) (lastId int64, err error) {
|
|
|
o, err := orm.NewOrm().Begin()
|
|
|
if err != nil {
|
|
@@ -129,7 +129,7 @@ func AddActivitySignup(item *CygxActivitySignup) (lastId int64, err error) {
|
|
|
return
|
|
|
}
|
|
|
|
|
|
-//仅绑定邮箱的用户修改报名后,添加报名信息
|
|
|
+// 仅绑定邮箱的用户修改报名后,添加报名信息
|
|
|
func AddActivitySignupFromEmail(item *CygxActivitySignup) (lastId int64, err error) {
|
|
|
o, err := orm.NewOrm().Begin()
|
|
|
if err != nil {
|
|
@@ -196,7 +196,7 @@ func AddActivitySignupFromEmail(item *CygxActivitySignup) (lastId int64, err err
|
|
|
return
|
|
|
}
|
|
|
|
|
|
-//添加报名信息
|
|
|
+// 添加报名信息
|
|
|
func AddActivitySignupNoSchedule(item *CygxActivitySignup) (lastId int64, err error) {
|
|
|
o, err := orm.NewOrm().Begin()
|
|
|
if err != nil {
|
|
@@ -227,7 +227,7 @@ func AddActivitySignupNoSchedule(item *CygxActivitySignup) (lastId int64, err er
|
|
|
return
|
|
|
}
|
|
|
|
|
|
-//获取用户报名成功数量
|
|
|
+// 获取用户报名成功数量
|
|
|
func GetActivitySignupCount(uid, activityId int) (count int, err error) {
|
|
|
sqlCount := `SELECT COUNT(1) AS count FROM cygx_activity_signup WHERE is_cancel=0 AND do_fail_type = 0 AND user_id=? AND activity_id=? `
|
|
|
o := orm.NewOrm()
|
|
@@ -235,7 +235,7 @@ func GetActivitySignupCount(uid, activityId int) (count int, err error) {
|
|
|
return
|
|
|
}
|
|
|
|
|
|
-//获取用户报名数量
|
|
|
+// 获取用户报名数量
|
|
|
func GetActivitySignupByUserCount(uid, activityId int) (count int, err error) {
|
|
|
sqlCount := `SELECT COUNT(1) AS count FROM cygx_activity_signup WHERE is_cancel=0 AND user_id=? AND activity_id=? `
|
|
|
o := orm.NewOrm()
|
|
@@ -243,7 +243,7 @@ func GetActivitySignupByUserCount(uid, activityId int) (count int, err error) {
|
|
|
return
|
|
|
}
|
|
|
|
|
|
-//获取用户报名禁止数量
|
|
|
+// 获取用户报名禁止数量
|
|
|
func GetActivitySignupByUserRestrictCount(uid, activityId int) (count int, err error) {
|
|
|
sqlCount := `SELECT COUNT(1) AS count FROM cygx_activity_signup WHERE do_fail_type=3 AND user_id=? AND activity_id=? `
|
|
|
o := orm.NewOrm()
|
|
@@ -251,7 +251,7 @@ func GetActivitySignupByUserRestrictCount(uid, activityId int) (count int, err e
|
|
|
return
|
|
|
}
|
|
|
|
|
|
-//获取某一活动已经报名的数量
|
|
|
+// 获取某一活动已经报名的数量
|
|
|
func GetActivitySignupSuccessCount(activityId int) (count int, err error) {
|
|
|
sqlCount := `SELECT COUNT(1) AS count FROM cygx_activity_signup WHERE is_cancel=0 AND do_fail_type = 0 AND activity_id=? `
|
|
|
o := orm.NewOrm()
|
|
@@ -259,7 +259,7 @@ func GetActivitySignupSuccessCount(activityId int) (count int, err error) {
|
|
|
return
|
|
|
}
|
|
|
|
|
|
-//获取某一活动某个机构已经报名的数量
|
|
|
+// 获取某一活动某个机构已经报名的数量
|
|
|
func GetActivitySignupCompanyCount(activityId, companyId int) (count int, err error) {
|
|
|
sqlCount := `SELECT COUNT(1) AS count FROM cygx_activity_signup WHERE is_cancel=0 AND fail_type = 0 AND activity_id=? AND company_id=? `
|
|
|
o := orm.NewOrm()
|
|
@@ -267,7 +267,7 @@ func GetActivitySignupCompanyCount(activityId, companyId int) (count int, err er
|
|
|
return
|
|
|
}
|
|
|
|
|
|
-//获取某一用户是否被限制报名
|
|
|
+// 获取某一用户是否被限制报名
|
|
|
func GetUserRestrictCount(mobile string) (count int, err error) {
|
|
|
sqlCount := `SELECT COUNT(1) AS count FROM cygx_activity_restrict_signup WHERE is_restrict=1 AND mobile=? `
|
|
|
o := orm.NewOrm()
|
|
@@ -275,7 +275,7 @@ func GetUserRestrictCount(mobile string) (count int, err error) {
|
|
|
return
|
|
|
}
|
|
|
|
|
|
-//获取某一用户的日程数量
|
|
|
+// 获取某一用户的日程数量
|
|
|
func GetUserMeetingReminderCount(uid int) (count int, err error) {
|
|
|
sqlCount := `SELECT COUNT(1) AS count FROM cygx_my_schedule WHERE user_id=? `
|
|
|
o := orm.NewOrm()
|
|
@@ -283,7 +283,7 @@ func GetUserMeetingReminderCount(uid int) (count int, err error) {
|
|
|
return
|
|
|
}
|
|
|
|
|
|
-//获取某一用户的报名的数量
|
|
|
+// 获取某一用户的报名的数量
|
|
|
func GetUserSignupCount(uid int) (count int, err error) {
|
|
|
sqlCount := `SELECT COUNT(1) AS count FROM cygx_activity_signup_log WHERE user_id=? `
|
|
|
o := orm.NewOrm()
|
|
@@ -291,7 +291,7 @@ func GetUserSignupCount(uid int) (count int, err error) {
|
|
|
return
|
|
|
}
|
|
|
|
|
|
-//取消报名
|
|
|
+// 取消报名
|
|
|
func CancelActivitySignup(item *CygxActivitySignup) (lastId int64, err error) {
|
|
|
o, err := orm.NewOrm().Begin()
|
|
|
if err != nil {
|
|
@@ -341,7 +341,7 @@ func CancelActivitySignup(item *CygxActivitySignup) (lastId int64, err error) {
|
|
|
return
|
|
|
}
|
|
|
|
|
|
-//详情
|
|
|
+// 详情
|
|
|
func GetActivitySignupDetail(activityId, uid int) (item *CygxActivitySignup, err error) {
|
|
|
o := orm.NewOrm()
|
|
|
sql := `SELECT * FROM cygx_activity_signup WHERE activity_id = ? AND user_id =? `
|
|
@@ -359,7 +359,7 @@ func GetActivitySignuListByUser(condition string, pars []interface{}) (item []*C
|
|
|
return
|
|
|
}
|
|
|
|
|
|
-//解除报名限制之后二次报名
|
|
|
+// 解除报名限制之后二次报名
|
|
|
func AddActivitySignupByRestrict(item *CygxActivitySignup) (lastId int64, err error) {
|
|
|
o, err := orm.NewOrm().Begin()
|
|
|
if err != nil {
|
|
@@ -400,7 +400,7 @@ func AddActivitySignupByRestrict(item *CygxActivitySignup) (lastId int64, err er
|
|
|
return
|
|
|
}
|
|
|
|
|
|
-//列表
|
|
|
+// 列表
|
|
|
func GetActivitySignupListAll() (items []*CygxActivitySignup, err error) {
|
|
|
o := orm.NewOrm()
|
|
|
sql := `SELECT * FROM cygx_activity_signup `
|
|
@@ -408,7 +408,7 @@ func GetActivitySignupListAll() (items []*CygxActivitySignup, err error) {
|
|
|
return
|
|
|
}
|
|
|
|
|
|
-//修改是否推送消息状态
|
|
|
+// 修改是否推送消息状态
|
|
|
func UPdateSignup(item *CygxActivitySignup) (err error) {
|
|
|
sql := ` UPDATE cygx_activity_signup SET outbound_mobile= ? , country_code=86 WHERE id = ?`
|
|
|
o := orm.NewOrm()
|
|
@@ -416,7 +416,7 @@ func UPdateSignup(item *CygxActivitySignup) (err error) {
|
|
|
return
|
|
|
}
|
|
|
|
|
|
-//获取数量
|
|
|
+// 获取数量
|
|
|
func GetActivityCountByIdWithUid(activityId, Uid int) (count int, err error) {
|
|
|
o := orm.NewOrm()
|
|
|
sqlCount := `SELECT COUNT(1) AS count FROM cygx_activity_signup WHERE activity_id = ? AND user_id = ?`
|
|
@@ -424,7 +424,7 @@ func GetActivityCountByIdWithUid(activityId, Uid int) (count int, err error) {
|
|
|
return
|
|
|
}
|
|
|
|
|
|
-//获取用户报名数量
|
|
|
+// 获取用户报名数量
|
|
|
func GetActivitySignupNomeetingCount(activityId int) (count int, err error) {
|
|
|
sqlCount := `SELECT
|
|
|
COUNT( 1 ) count
|
|
@@ -454,7 +454,7 @@ WHERE
|
|
|
return
|
|
|
}
|
|
|
|
|
|
-//获取用户是否被限制报名
|
|
|
+// 获取用户是否被限制报名
|
|
|
func GetRestrictSignupCountByUid(uid int) (count int, err error) {
|
|
|
sqlCount := `SELECT COUNT( 1 ) count FROM cygx_activity_restrict_signup WHERE user_id = ?`
|
|
|
o := orm.NewOrm()
|
|
@@ -462,7 +462,7 @@ func GetRestrictSignupCountByUid(uid int) (count int, err error) {
|
|
|
return
|
|
|
}
|
|
|
|
|
|
-//获取用户爽约次数
|
|
|
+// 获取用户爽约次数
|
|
|
func GetActivitySignupNomeetingCountByUid(uid int) (count int, err error) {
|
|
|
sqlCount := `SELECT
|
|
|
COUNT( 1 ) count
|
|
@@ -481,7 +481,7 @@ WHERE
|
|
|
return
|
|
|
}
|
|
|
|
|
|
-//删除
|
|
|
+// 删除
|
|
|
func DeleteCygxActivityRestrictSignup(uid int) (err error) {
|
|
|
o := orm.NewOrm()
|
|
|
sql := ` DELETE FROM cygx_activity_restrict_signup WHERE user_id=?`
|
|
@@ -501,7 +501,7 @@ type CygxActivitySignupList struct {
|
|
|
Channel int `description:"报名渠道,0 空降、 1小程序报名"`
|
|
|
}
|
|
|
|
|
|
-//获取用户报名列表
|
|
|
+// 获取用户报名列表
|
|
|
func GetActivitySignupNomeetingCountList(activityId int) (items []*CygxActivitySignupList, err error) {
|
|
|
o := orm.NewOrm()
|
|
|
sql := `SELECT
|
|
@@ -551,14 +551,14 @@ type CygxActivityRestrictSignup struct {
|
|
|
IsRestrict int `description:"是否限制报名,1是,0否"`
|
|
|
}
|
|
|
|
|
|
-//添加
|
|
|
+// 添加
|
|
|
func AddCygxActivityRestrictSignup(item *CygxActivityRestrictSignup) (err error) {
|
|
|
o := orm.NewOrm()
|
|
|
_, err = o.Insert(item)
|
|
|
return
|
|
|
}
|
|
|
|
|
|
-//获取列表信息根据手机号分组
|
|
|
+// 获取列表信息根据手机号分组
|
|
|
func GetCygxActivitySignupByMobileList(condition string) (items []*CygxActivitySignup, err error) {
|
|
|
o := orm.NewOrm()
|
|
|
sql := `SELECT * FROM cygx_activity_signup_detail WHERE 1= 1 ` + condition + ` GROUP BY mobile `
|
|
@@ -566,7 +566,7 @@ func GetCygxActivitySignupByMobileList(condition string) (items []*CygxActivityS
|
|
|
return
|
|
|
}
|
|
|
|
|
|
-//修改用户报名的相关信息
|
|
|
+// 修改用户报名的相关信息
|
|
|
func UpdateCygxActivitySignup(wxUser *WxUserItem) (err error) {
|
|
|
o := orm.NewOrm()
|
|
|
sql := `UPDATE cygx_activity_signup_detail SET email=?,company_id=?,company_name=?,user_id=?,real_name=? WHERE mobile=? `
|
|
@@ -574,7 +574,7 @@ func UpdateCygxActivitySignup(wxUser *WxUserItem) (err error) {
|
|
|
return
|
|
|
}
|
|
|
|
|
|
-//UpdateCygxActivitySignupisMeet 修改易董的活动,用户已到会
|
|
|
+// UpdateCygxActivitySignupisMeet 修改易董的活动,用户已到会
|
|
|
func UpdateCygxActivitySignupisMeet(activityId int, mobile string) (err error) {
|
|
|
o := orm.NewOrm()
|
|
|
sql := `UPDATE cygx_activity_signup SET is_meeting=1 WHERE activity_id=? AND mobile = ? `
|
|
@@ -582,7 +582,7 @@ func UpdateCygxActivitySignupisMeet(activityId int, mobile string) (err error) {
|
|
|
return
|
|
|
}
|
|
|
|
|
|
-//UpdateCygxActivitySignupisMeetList 批量修改易董的活动,用户已到会
|
|
|
+// UpdateCygxActivitySignupisMeetList 批量修改易董的活动,用户已到会
|
|
|
func UpdateCygxActivitySignupisMeetList(condition string, pars []interface{}) (err error) {
|
|
|
if condition == "" {
|
|
|
return
|
|
@@ -592,3 +592,16 @@ func UpdateCygxActivitySignupisMeetList(condition string, pars []interface{}) (e
|
|
|
_, err = o.Raw(sql, pars).Exec()
|
|
|
return
|
|
|
}
|
|
|
+
|
|
|
+// GetCygxCygxActivitySignupList 获取报名列表信息
|
|
|
+func GetActivitySignupList(condition string, pars []interface{}) (items []*CygxActivitySignup, err error) {
|
|
|
+ sql := `SELECT
|
|
|
+ signup_type,activity_id
|
|
|
+ FROM
|
|
|
+ cygx_activity_signup AS v
|
|
|
+ WHERE
|
|
|
+ 1 = 1 ` + condition
|
|
|
+ o := orm.NewOrm()
|
|
|
+ _, err = o.Raw(sql, pars).QueryRows(&items)
|
|
|
+ return
|
|
|
+}
|