123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195 |
- package models
- import (
- "fmt"
- //"hongze/hongze_admin/models"
- "github.com/beego/beego/v2/client/orm"
- "time"
- )
- type CygxActivitySpecialTrip struct {
- Id int `orm:"column(id);pk"`
- UserId int `description:"用户id,多个用,隔开"`
- ActivityId int `description:"活动ID"`
- CreateTime time.Time `description:"创建时间"`
- Mobile string `description:"手机号"`
- Email string `description:"邮箱号"`
- CompanyId int `description:"公司ID"`
- CompanyName string `description:"公司名称"`
- RealName string `description:"用户实际名称"`
- SellerName string `description:"所属销售"`
- AdminId int `description:"销售/管理员ID"`
- Source int `description:"来源,1小程序,2后台添加"`
- OutboundMobile string `description:"外呼手机号"`
- CountryCode string `description:"手机国家区号"`
- IsCancel string `description:"是否取消,1是,0否"`
- IsValid int `description:"参会报名是否有效 1:是,0"`
- }
- type CygxActivitySpecialTripResp struct {
- Id int `description:"ID"`
- UserId int `description:"用户id"`
- ActivityId int `description:"活动ID"`
- CreateTime string `description:"创建时间"`
- Mobile string `description:"手机号"`
- Email string `description:"邮箱号"`
- CompanyId int `description:"公司ID"`
- CompanyName string `description:"公司名称"`
- RealName string `description:"用户实际名称"`
- SellerName string `description:"所属销售"`
- OutboundMobile string `description:"外呼手机号"`
- CountryCode string `description:"手机国家区号"`
- }
- func GetCygxActivitySpecialTripList(condition string, pars []interface{}) (item []*CygxActivitySpecialTripResp, err error) {
- o := orm.NewOrm()
- sql := `SELECT *
- FROM
- cygx_activity_special_trip
- WHERE 1 = 1 ` + condition
- _, err = o.Raw(sql, pars).QueryRows(&item)
- return
- }
- func GetCygxActivitySpecialmeetingDetailList(condition string, pars []interface{}) (item []*CygxActivitySpecialTripResp, err error) {
- o := orm.NewOrm()
- sql := `SELECT *
- FROM
- cygx_activity_special_meeting_detail
- WHERE 1 = 1 ` + condition
- _, err = o.Raw(sql, pars).QueryRows(&item)
- return
- }
- // 获取某一用户的报名的数量
- func GetUserActivitySpecialTripCount(uid, activityId int) (count int, err error) {
- sqlCount := `SELECT COUNT(1) AS count FROM cygx_activity_special_trip WHERE user_id=? AND activity_id =? `
- o := orm.NewOrm()
- err = o.Raw(sqlCount, uid, activityId).QueryRow(&count)
- return
- }
- // 获取某一活动的报名的数量
- func GetActivitySpecialTripCountByActivityId(condition string, pars []interface{}) (count int, err error) {
- sqlCount := `SELECT COUNT(1) AS count FROM cygx_activity_special_trip as t WHERE 1 = 1 ` + condition
- o := orm.NewOrm()
- err = o.Raw(sqlCount, pars).QueryRow(&count)
- return
- }
- // 获取某一活动的报名的数量 (同时关联活动类型进行获取)
- func GetActivitySpecialTripCountByActivitySpecial(condition string, pars []interface{}) (count int, err error) {
- sqlCount := ` SELECT COUNT(1) AS count
- FROM
- cygx_activity_special_trip AS t
- INNER JOIN cygx_activity_special AS a ON a.activity_id = t.activity_id
- WHERE
- 1= 1 ` + condition
- o := orm.NewOrm()
- err = o.Raw(sqlCount, pars).QueryRow(&count)
- return
- }
- // 获取空降的公司报名的记录
- func GetActivitySpecialTripAirborneCountByActivitySpecial(condition string, pars []interface{}) (count int, err error) {
- sqlCount := ` SELECT COUNT(1) AS count
- FROM
- cygx_activity_special_meeting_detail AS t
- INNER JOIN cygx_activity_special AS a ON a.activity_id = t.activity_id
- WHERE
- 1= 1 AND YEAR ( t.create_time )= YEAR (NOW()) ` + condition
- o := orm.NewOrm()
- err = o.Raw(sqlCount, pars).QueryRow(&count)
- return
- }
- // 添加
- func AddCygxActivitySpecialTrip(item *CygxActivitySpecialTrip) (err error) {
- o, err := orm.NewOrm().Begin()
- if err != nil {
- return
- }
- defer func() {
- fmt.Println(err)
- if err == nil {
- o.Commit()
- } else {
- o.Rollback()
- }
- }()
- _, err = o.Insert(item)
- if err != nil {
- return
- }
- //itemBill := new(CygxActivitySpecialTripBill)
- //itemBill.UserId = item.UserId
- //itemBill.ActivityId = item.ActivityId
- //itemBill.CreateTime = time.Now()
- //itemBill.Mobile = item.Mobile
- //itemBill.Email = item.Email
- //itemBill.CompanyId = item.CompanyId
- //itemBill.CompanyName = item.CompanyName
- //itemBill.RealName = item.RealName
- //itemBill.Source = 1
- //itemBill.BillDetailed = -1 // 流水减一
- //itemBill.DoType = 1
- //itemBill.RegisterPlatform = 1
- //itemBill.ChartPermissionId = itemActivity.ChartPermissionId
- //
- //_, err = o.Insert(itemBill)
- //if err != nil {
- // return
- //}
- return
- }
- // 取消
- func CancelActivitySpecialTrip(uid int, item *CygxActivitySpecialDetail) (err error) {
- o := orm.NewOrm()
- sql := `DELETE FROM cygx_activity_special_trip WHERE user_id=? AND activity_id=? `
- _, err = o.Raw(sql, uid, item.ActivityId).Exec()
- return
- }
- // CancelActivitySpecialTripIsValid 处理活动报名是否有效
- func CancelActivitySpecialTripIsValid(isValid, activityId, userId int) (err error) {
- sql := ` UPDATE cygx_activity_special_trip SET is_valid= ?,is_cancel = 1 WHERE activity_id = ? AND user_id = ? `
- o := orm.NewOrm()
- _, err = o.Raw(sql, isValid, activityId, userId).Exec()
- return
- }
- type CygxActivitySpecialTripInit struct {
- Id int `orm:"column(id);pk"`
- UserId int `description:"用户id,多个用,隔开"`
- ActivityId int `description:"活动ID"`
- CreateTime time.Time `description:"创建时间"`
- Mobile string `description:"手机号"`
- Email string `description:"邮箱号"`
- CompanyId int `description:"公司ID"`
- CompanyName string `description:"公司名称"`
- RealName string `description:"用户实际名称"`
- SellerName string `description:"所属销售"`
- AdminId int `description:"销售/管理员ID"`
- Source int `description:"来源,1小程序,2后台添加"`
- OutboundMobile string `description:"外呼手机号"`
- CountryCode string `description:"手机国家区号"`
- IsCancel string `description:"是否取消,1是,0否"`
- IsValid int `description:"参会报名是否有效 1:是,0"`
- ChartPermissionId int `description:"行业Id"`
- }
- func GetCygxActivitySpecialTripListinit(condition string, pars []interface{}) (item []*CygxActivitySpecialTripInit, err error) {
- o := orm.NewOrm()
- sql := `SELECT
- t.*,
- a.chart_permission_id
- FROM
- cygx_activity_special_trip AS t
- INNER JOIN cygx_activity_special AS a ON a.activity_id = t.activity_id
- WHERE
- 1 = 1
- AND is_valid = 1 ` + condition
- _, err = o.Raw(sql, pars).QueryRows(&item)
- return
- }
|