hz_crm_api/models/yb/activity.go

package yb

import (
	"github.com/beego/beego/v2/client/orm"
	"time"
)

// Activity 活动表
type Activity struct {
	ActivityId            int       `orm:"column(activity_id);pk" description:"活动ID"`
	FirstActivityTypeId   int       `description:"第一级的活动类型ID"`
	FirstActivityTypeName string    `description:"第一级的活动类型名称"`
	ActivityTypeId        int       `description:"活动类型ID"`
	ActivityTypeName      string    `description:"活动类型名称"`
	ActivityName          string    `description:"活动标题"`
	StartTime             time.Time `description:"活动开始时间"`
	EndTime               time.Time `description:"活动结束时间"`
	Speaker               string    `description:"主讲人"`
	SpeakerHeadPic        string    `description:"主讲人头像"`
	SpeakerBackgroundPic  string    `description:"主讲人背景图"`
	MainlandTel           string    `description:"大陆拨入"`
	HongKongTel           string    `description:"香港拨入"`
	TaiwanTel             string    `description:"台湾拨入"`
	AmericaTel            string    `description:"美国拨入"`
	SingaporeTel          string    `description:"新加坡拨入"`
	ParticipationCode     string    `description:"参会密码"`
	LinkParticipants      string    `description:"参会链接"`
	IsLimitPeople         int8      `description:"是否限制人数 1是，0否"`
	LimitPeopleNum        int       `description:"限制人数数量"`
	ReportId              int       `description:"报告链接所关联的文章ID"`
	ReportLink            string    `description:"报告链接"`
	ReportName            string    `description:"报告标题"`
	City                  string    `description:"城市"`
	Address               string    `description:"活动地址"`
	Remarks               string    `description:"备注"`
	UserId                int       `description:"创建者id"`
	PublishStatus         int8      `description:"发布状态，0未发布，1已发布"`
	IsSendWxMsg           int8      `description:"是否推送过会议提醒微信消息，未推送：0，已推送：1"`
	IsSendSalonWxMsg      int8      `description:"是否推送过沙龙提醒微信消息，未推送：0，已推送：1"`
	IsDelete              int8      `description:"是否删除，0：未删除，1：已删除"`
	ModifyTime            time.Time `description:"修改时间"`
	CreateTime            time.Time `description:"创建时间"`
	QsId                  int       `description:"全时会议关系id"`
	HostCode              string    `description:"主持人入会密码"`
	IsNewReport           int       `description:"是否关联新报告 0-否 1-是"`
}

// TableName 表名变更
func (activityInfo *Activity) TableName() string {
	return "yb_activity"
}

// GetById 根据id获取活动详情
func GetById(activityId int) (item *Activity, err error) {
	o := orm.NewOrm()
	sql := "select * from yb_activity where activity_id=? AND is_delete = 0 "
	err = o.Raw(sql, activityId).QueryRow(&item)
	return
}

type ActivityList struct {
	ActivityId            int                   `orm:"column(activity_id);pk" description:"活动ID"`
	FirstActivityTypeId   int                   `description:"第一级的活动类型ID"`
	FirstActivityTypeName string                `description:"第一级的活动类型名称"`
	ActivityTypeId        int                   `description:"活动类型ID"`
	ActivityTypeName      string                `description:"活动类型名称"`
	ActivityName          string                `description:"活动标题"`
	StartTime             time.Time             `description:"活动开始时间"`
	EndTime               time.Time             `description:"活动结束时间"`
	Speaker               string                `description:"主讲人"`
	MainlandTel           string                `description:"大陆拨入"`
	HongKongTel           string                `description:"香港拨入"`
	TaiwanTel             string                `description:"台湾拨入"`
	AmericaTel            string                `description:"美国拨入"`
	SingaporeTel          string                `description:"新加坡拨入"`
	ParticipationCode     string                `description:"参会密码"`
	LinkParticipants      string                `description:"参会链接"`
	IsLimitPeople         int8                  `description:"是否限制人数 1是，0否"`
	LimitPeopleNum        int                   `description:"限制人数数量"`
	ReportId              int                   `description:"报告链接所关联的文章ID"`
	ReportLink            string                `description:"报告链接"`
	ReportName            string                `description:"报告标题"`
	City                  string                `description:"城市"`
	Address               string                `description:"活动地址"`
	Remarks               string                `description:"备注"`
	UserId                int                   `description:"创建者id"`
	PublishStatus         int8                  `description:"发布状态，0未发布，1已发布"`
	IsSendWxMsg           int8                  `description:"是否推送过会议提醒微信消息，未推送：0，已推送：1"`
	IsSendSalonWxMsg      int8                  `description:"是否推送过沙龙提醒微信消息，未推送：0，已推送：1"`
	ModifyTime            time.Time             `description:"修改时间"`
	CreateTime            time.Time             `description:"创建时间"`
	VoiceList             []*ActivityVoice      `description:"音频文件列表"`
	PosterList            []*ActivityPoster     `description:"海报文件列表"`
	PermissionList        []*ActivityPermission `description:"权限列表"`
	QsId                  int                   `description:"全时关联会议id"`
	HostCode              string                `description:"主持人入会密码"`
	IsNewReport           int                   `description:"是否关联新报告 0-否 1-是"`
}

// GetList 获取活动列表数据
func GetList(condition, order string, pars []interface{}, startSize, pageSize int) (total int, list []*ActivityList, err error) {
	o := orm.NewOrm()
	sql := "select * from yb_activity where 1=1 AND is_delete = 0 "
	sql += condition
	sql += ` order by`
	if order == "" {
		order = " start_time ASC"
	}
	sql += order

	totalSql := `select count(1) total from (` + sql + `) z `
	err = o.Raw(totalSql, pars).QueryRow(&total)
	if err != nil {
		return
	}
	sql += ` LIMIT ?,? `
	_, err = o.Raw(sql, pars, startSize, pageSize).QueryRows(&list)
	return
}

// Update 更新活动
func (activityInfo *Activity) Update(cols []string) (err error) {
	o := orm.NewOrm()
	_, err = o.Update(activityInfo, cols...)
	return
}

// AddActivity 新增活动
func AddActivity(activity *Activity) (err error) {
	o := orm.NewOrm()
	id, err := o.Insert(activity)
	if err != nil {
		return
	}
	activity.ActivityId = int(id)
	return
}

// AddNewActivity 添加一个新的活动
func AddNewActivity(activity *Activity, activityPosterList []*ActivityPoster, activityPermissionList []*ActivityPermission) (err error) {
	o := orm.NewOrm()
	to, err := o.Begin()
	if err != nil {
		return
	}
	defer func() {
		if err != nil {
			_ = to.Rollback()
		} else {
			_ = to.Commit()
		}
	}()

	id, err := to.Insert(activity)
	if err != nil {
		return
	}
	activity.ActivityId = int(id)

	// 新增海报
	if len(activityPosterList) > 0 {
		for _, activityPoster := range activityPosterList {
			activityPoster.ActivityId = activity.ActivityId
		}
		_, tmpErr := to.InsertMulti(len(activityPosterList), activityPosterList)
		if tmpErr != nil {
			err = tmpErr
			return
		}
	}

	// 新增权限
	if len(activityPermissionList) > 0 {
		for _, activityPermission := range activityPermissionList {
			activityPermission.ActivityId = activity.ActivityId
		}
		_, tmpErr := to.InsertMulti(len(activityPermissionList), activityPermissionList)
		if tmpErr != nil {
			err = tmpErr
			return
		}
	}
	return
}

// UpdateActivity 更新活动
func (activityInfo *Activity) UpdateActivity(cols []string, activityPosterList []*ActivityPoster, activityVoiceList []*ActivityVoice, activityPermissionList []*ActivityPermission) (err error) {
	o := orm.NewOrm()
	to, err := o.Begin()
	if err != nil {
		return
	}
	defer func() {
		if err != nil {
			_ = to.Rollback()
		} else {
			_ = to.Commit()
		}
	}()
	_, err = to.Update(activityInfo, cols...)
	if err != nil {
		return
	}

	//海报处理
	//删除旧的海报
	sql := "delete from yb_activity_poster where activity_id=?"
	_, err = to.Raw(sql, activityInfo.ActivityId).Exec()
	if err != nil {
		return
	}
	//插入新的海报
	if len(activityPosterList) > 0 {
		_, tmpErr := to.InsertMulti(len(activityPosterList), activityPosterList)
		if tmpErr != nil {
			err = tmpErr
			return
		}
	}

	//权限处理
	//删除旧的权限
	sql = "delete from yb_activity_permission where activity_id=?"
	_, err = to.Raw(sql, activityInfo.ActivityId).Exec()
	//插入新的权限
	if len(activityPermissionList) > 0 {
		_, tmpErr := to.InsertMulti(len(activityPermissionList), activityPermissionList)
		if tmpErr != nil {
			err = tmpErr
			return
		}
	}

	//音频处理
	//删除旧的音频
	sql = "delete from yb_activity_voice where activity_id=?"
	_, err = to.Raw(sql, activityInfo.ActivityId).Exec()
	//插入新的音频
	if len(activityVoiceList) > 0 {
		_, tmpErr := to.InsertMulti(len(activityVoiceList), activityVoiceList)
		if tmpErr != nil {
			err = tmpErr
			return
		}
	}

	return
}

// GetCountBySpeaker 获取主讲人活动次数
func GetCountBySpeaker(speakerName string) (total int, err error) {
	o := orm.NewOrm()
	sql := `SELECT COUNT(1) FROM yb_activity WHERE speaker = ? AND is_delete = 0 `
	err = o.Raw(sql, speakerName).QueryRow(&total)
	return
}

// UpdateActivitySpeaker 更新主讲人冗余字段
func UpdateActivitySpeaker(name, headPic, originName string) (err error) {
	o := orm.NewOrm()
	sql := `UPDATE yb_activity SET speaker = ?, speaker_head_pic = ? WHERE speaker = ? `
	_, err = o.Raw(sql, name, headPic, originName).Exec()
	return
}