hongze_cygx/models/activity.go

package models

import (
	"fmt"
	"github.com/beego/beego/v2/client/orm"
	"github.com/rdlucklib/rdluck_tools/paging"
	"hongze/hongze_cygx/utils"
	"strings"
	"time"
)

// 活动详情
type CygxActivity struct {
	ActivityId                int       `orm:"column(activity_id);pk";description:"活动ID 等于0新增活动，大于0修改活动"`
	ActivityTypeId            int       `description:"活动类型id"`
	ActivityTypeName          string    `description:"活动类型名称"`
	ChartPermissionId         int       `description:"行业id"`
	ChartPermissionName       string    `description:"行业名称"`
	ChartPermissionNames      string    `description:"行业名称辅助字段，区分研选子分类"`
	IsShowHz                  int       `description:"是否同时在弘则展示  1是，0否"`
	ChartPermissionIdDeputy   int       `description:"行业id"`
	ChartPermissionNameDeputy string    `description:"副行业名称"`
	Body                      string    `description:"内容"`
	CreateTime                time.Time `description:"创建时间"`
	IsLimitPeople             int       `description:"是否限制人数 1是，0否"`
	LimitPeopleNum            int       `description:"限制的人数数量"`
	CustomerTypeIds           string    `description:"活动可见的客户类型，多个ID用 , 隔开"`
	PublishStatus             int       `description:"发布状态 1已发布，0未发布"`
	LastUpdatedTime           time.Time `description:"更新时间"`
	ActivityTime              string    `description:"活动时间"`
	ActivityTimeText          string    `description:"活动时间带文字"`
	DistinguishedGuest        string    `description:"嘉宾"`
	Host                      string    `description:"主持人"`
	MainlandTell              string    `description:"大陆拨入号"`
	HongKongTell              string    `description:"香港拨入号"`
	TaiwanTell                string    `description:"台湾拨入号"`
	AmericaTell               string    `description:"美国拨入号"`
	ParticipationCode         string    `description:"参会密码"`
	Theme                     string    `description:"主题"`
	Expert                    string    `description:"专家"`
	ActivityName              string    `description:"活动名称"`
	ActivityNameTask          string    `description:"活动名称定时任务同步的时候使用"`
	OnlineParticipation       string    `description:"网络参会"`
	ReportLink                string    `description:"报告链接"`
	City                      string    `description:"城市"`
	Address                   string    `description:"活动地址"`
	Highlights                string    `description:"活动亮点"`
	Remarks                   string    `description:"备注"`
	Speaker                   string    `description:"主讲人"`
	ArticleId                 int       `description:"关联报告id"`
	Label                     string    `description:"标签"`
	LinkParticipants          string    `description:"链接参会"`
	AppAttendance             string    `description:"App参会"`
	ConferencePassword        string    `description:"会议密码"`
	TemporaryLabel            string    `description:"临时标签"`
	IsMakerShow               int       `description:"是否仅决策人可见 0，否 、1，是"`
	VisibleRange              int       `description:"可见范围 1，仅本组可见 、2，全部客户可见"`
	Scale                     string    `description:"管理规模，空不填，1：:50亿以下，2：50~100亿，3：100亿以上。多个用, 隔开"`
	IsShowSubjectName         int       `description:"小程序内是否展示标的名称 1是 ，0 否 默认0 "`
	IsHideAppointment         int       `description:"是否隐藏预约纪要按钮 1是 ，0 否 默认0 "`
	AdminId                   int       `description:"销售/管理员ID"`
	AdminName                 string    `description:"销售/管理员姓名"`
	IsCanAppointmentMinutes   int       `description:"是否可预约纪要 1是 ，0 否 默认0 "`
	YidongActivityId          string    `description:"易董活动ID"`
	YidongActivityUrl         string    `description:"易董活动跳转地址"`
	YidongActivityEndTime     string    `description:"易董活动截止时间"`
	ActivityJoinType          string    `description:"活动入会类型01报名审核后可入会 02预约即可入会 03仅定向邀请人员可入会"`
	YidongSignUpEnd           string    `description:"易董活动截止时间"` // 报名结束时间，适应于报名审核后可入会，为空表示不限制报名时间
	YidongSignUpStart         string    `description:"易董活动截止时间"` // 报名开始时间，适应于报名审核后可入会，为空表示不限制报名时间
	IsExternalLabel           int       `description:"是否为外部资源 1是，0否"`
	YidongActivityIdByCygx    string    `description:"通过查研观向建会易董返回的活动ID"`
	JmcjRoadshowTitle         string    `description:"进门财经的活动标题"`
	JmcjActivityId            string    `description:"进门财经的活动ID"`
}

type ActivityCheck struct {
	CheckPermission   bool   `description:"权限是否通过校验"`
	HasPermission     int    `description:"操作方式，1:有该行业权限,正常展示，2：无该行业权限，3：潜在客户，未提交过申请，4：潜在客户,已提交过申请"`
	PopupMsg          string `description:"权限弹窗信息"`
	CancelPopupMsg    string `description:"取消报名时间弹窗信息"`
	SellerMobile      string `description:"销售电话"`
	SellerName        string `description:"销售姓名"`
	Mobile            string `description:"手机号"`
	IsResearch        bool   `description:"是否属于研选"`
	IsResearchSpecial bool   `description:"是否属于特殊的研选"`
	CheckTime         bool   `description:"时间是否通过校验"`
	CheckEmail        bool   `description:"邮箱是否通过校验"`
	CheckPoints       bool   `description:"扣点是否通过校验"`
	CompanyPoints     string `description:"公司剩余点数"`
	ActivityPoints    string `description:"本场活动要扣除的点数"`
}

type Activity struct {
	ActivityTypeId   int    `description:"活动类型id"`
	ActivityTypeName string `description:"活动名称"`
	TemplateP        string `description:"活动模板，带P标签"`
	Template         string `description:"活动模板"`
	ShowType         string `description:"人数限制类型，1不展示限制，2可选限制，3强制限制"`
}
type ActivityIdRep struct {
	ActivityId  int `description:"活动id"`
	PlaySeconds int `description:"播放时长"`
}

type ActivitySingnupRep struct {
	ActivityId int `description:"活动id"`
	SignupType int `description:"报名方式，1预约外呼，2自主拨入，3我要报名"`
}

type ActivityCcustomerType struct {
	CustomerTypeId  int    `description:"活动类型id"`
	CustomerName    string `description:"活动名称"`
	PermissionValue string `description:"用户权限对应的值"`
}

type ActivityCcustomerTypeList struct {
	List []*ActivityCcustomerType
}

// 列表
func GetActivityCcustomerTypeList() (items []*ActivityCcustomerType, err error) {
	o := orm.NewOrm()
	sql := `SELECT * FROM cygx_customer_type ORDER BY sort DESC`
	_, err = o.Raw(sql).QueryRows(&items)
	return
}

// 活动添加、修改入参
type ActivityRep struct {
	ActivityTypeId    int    `description:"活动类型id"`
	ChartPermissionId int    `description:"行业id"`
	Body              string `description:"内容"`
	LimitPeopleNum    int    `description:"限制的人数数量"`
	CustomerTypeIds   string `description:"活动可见的客户类型，多个ID用 , 隔开"`
	ActivityId        int    `description:"活动ID 等于0新增活动，大于0修改活动"`
	DoType            int    `description:"操作类型 0，保存 、1，发布"`
}

type ActivityArticleResp struct {
	ReportLink string `description:"报告链接"`
	ArticleId  int    `description:"报告id（报告链接跳转使用）"`
	Title      string `description:"报告id（报告链接跳转使用）"`
}

// 活动详情
type ActivityDetail struct {
	ActivityId                int                        `orm:"column(activity_id);pk";description:"活动ID "`
	ActivityTypeId            int                        `description:"活动类型id"`
	PublishStatus             int                        `description:"发布状态，0未发布，1已发布"`
	ActivityTypeName          string                     `description:"活动类型名称"`
	ChartPermissionId         int                        `description:"行业id"`
	ChartPermissionName       string                     `description:"行业名称"`
	ChartPermissionNames      string                     `description:"行业名称辅助字段，区分研选子分类"`
	Body                      string                     `description:"内容"`
	CreateTime                string                     `description:"创建时间"`
	IsLimitPeople             int                        `description:"是否限制人数 1是，0否"`
	LimitPeopleNum            int                        `description:"限制的人数数量"`
	LastUpdatedTime           string                     `description:"更新时间"`
	ActivityTime              string                     `description:"活动时间"`
	ActivityTimeText          string                     `description:"活动时间带文字"`
	DistinguishedGuest        string                     `description:"嘉宾"`
	Host                      string                     `description:"主持人"`
	Speaker                   string                     `description:"主讲人"`
	MainlandTell              string                     `description:"大陆拨入号"`
	HongKongTell              string                     `description:"香港拨入号"`
	TaiwanTell                string                     `description:"台湾拨入号"`
	AmericaTell               string                     `description:"美国拨入号"`
	ParticipationCode         string                     `description:"参会密码"`
	Theme                     string                     `description:"主题"`
	Expert                    string                     `description:"专家"`
	ActivityName              string                     `description:"活动名称"`
	OnlineParticipation       string                     `description:"网络参会"`
	ReportLink                string                     `description:"报告链接"`
	City                      string                     `description:"城市"`
	Address                   string                     `description:"活动地址"`
	Highlights                string                     `description:"活动亮点"`
	Remarks                   string                     `description:"备注"`
	ShowType                  string                     `description:"人数限制类型，1不展示限制，2可选限制，3强制限制"`
	IsSignup                  int                        `description:"是否已报名 1是 ，0 否"`
	IsAppointment             int                        `description:"是否已预约纪要 1是 ，0 否"`
	SignupNum                 int                        `description:"已报名人数"`
	SignupType                int                        `description:"报名方式，1预约外呼，2自主拨入，3我要报名"`
	ActiveState               string                     `description:"活动进行状态 未开始：1、进行中2、已结束3"`
	IsCancelMeetingReminder   int                        `description:"是否取消会议提醒 1展示取消会议提醒 ，0展示会议提醒"`
	ArticleId                 int                        `description:"报告id（报告链接跳转使用）"`
	CustomerTypeIds           string                     `description:"活动可见的客户类型，多个ID用 , 隔开"`
	IsShowSustainable         bool                       `description:"是否展示限免标签"`
	Description               string                     `description:"研选内容说明"`
	IsResearch                bool                       `description:"是否属于研选"`
	IsResearchSpecial         bool                       `description:"是否属于特殊的研选"`
	LinkParticipants          string                     `description:"链接参会"`
	AppAttendance             string                     `description:"App参会"`
	ConferencePassword        string                     `description:"会议密码"`
	Scale                     string                     `description:"管理规模，空不填，1：:50亿以下，2：50~100亿，3：100亿以上。多个用, 隔开"`
	IsShowAppointment         bool                       `description:"是否展示预约纪要"`
	IsHideAppointment         int                        `description:"是否隐藏预约纪要按钮  1是，0 否"`
	IsCClassMeeting           bool                       `description:"是否是c类电话会"`
	ArticleList               []*ActivityArticleResp     // 下面是列表添加的部分结构体
	IsBrackets                int                        `description:"是否有方括号 1是 ，0 否"`
	Label                     string                     `description:"主题标签"`
	ImgUrl                    string                     `description:"图片链接"`
	ImgUrlText                string                     `description:"图片链接文字"`
	ActivityType              int                        `description:"活动线上线下类型 1线上，0 线下"`
	JmcjRoadshowTitle         string                     `description:"进门财经手动匹配的活动名称"`
	Listndustrial             []*IndustrialManagementRep `description:"活动关联的产业信息"`
	IsShowOutboundCall        bool                       `description:"是否展示预约外呼"`
	IsShowMeetingReminder     bool                       `description:"是否展示会议提醒"`
	IsShowHelpSsk             bool                       `description:"是否展示帮我带问"`
	IsShowSignup              bool                       `description:"是否展示我要报名"`
	IsShowDetails             bool                       `description:"是否展示查看详情按钮"`
	TemporaryLabel            string                     `description:"临时标签"`
	IsCanAppointmentMinutes   int                        `description:"是否可预约纪要 1是 ，0 否 默认0 "`
	YidongActivityId          string                     `description:"易董活动ID"`
	YidongActivityUrl         string                     `description:"易董活动跳转地址"`
	AudioLink                 bool                       `description:"是否展示回放按钮"`
	VoiceList                 *CygxActivityVoiceReq      `description:"音频数据"`
	AdminId                   int                        `description:"管理员、销售ID "`
	IsMakerShow               int                        `description:"是否仅决策人可见 0，否 、1，是"`
	VisibleRange              int                        `description:"可见范围 1，仅本组可见 、2，全部客户可见"`
	VideoDetail               *CygxActivityVideoListResp `description:"视频数据"`
	FileType                  int                        `description:"类型: 1-音频; 2-视频"`
	IsCollect                 bool                       `description:"是否收藏"`
	SourceType                int                        `description:"活动来源。 1：活动 、2：专项产业调研"`
	TripImgLink               string                     `description:"专项产业调研行程链接"`
	ActivityTimeEnd           string                     `description:"专项产业调研活动预期结束时间"`
	IsShowFollowButton        bool                       `description:"是否展示关注取关按钮"`
	IsFollowButton            bool                       `description:"是否关注"`
	IsYidongConduct           bool                       `description:"是否属于易董办会 1：是 、0：否"`
	IsCanOutboundCall         int                        `description:"是否提供外呼 1：是 、0：否"`
	TencentConferenceNumber   string                     `description:"腾讯会议号"`
	YidongActivityIdByCygx    string                     `description:"通过查研观向建会易董返回的活动ID"`
	IsShowSigninButton        bool                       `description:"是否展示签到码按钮"`
	IsShowSignUpDetail        bool                       `description:"是否展示报名详情按钮"`
	SigninImg                 string                     `description:"签到码图片"`
	IsNeedEmail               int                        `description:"是否需要提供邮箱 1是，0否"`
	SiginupDeadline           string                     `description:"报名截止时间"`
	IsExternalLabel           bool                       `description:"是否为外部资源"`
	IsResearchPoints          bool                       `description:"是否为研选扣点"`
	ImgUrlBgYx                string                     `description:"研选背景图片"`
	CancelDeadline            string                     `description:"取消报名截止时间"`
	ChartPermissionNameDeputy string                     `description:"副行业名称"`
	TopTime                   int                        `description:"置顶时间"`
}
type ListArticleActivity struct {
	Title   string `description:"文章标题"`
	ArtleId int    `description:"产业id"`
}

type CygxActivityResp struct {
	HaqveJurisdiction bool   `description:"是否有权限"`
	OperationMode     string `description:"操作方式 Apply:立即申请、Call:拨号 为空则为有权限"`
	HasPermission     int    `description:"操作方式，1:有该行业权限,正常展示，2：无该行业权限，3：潜在客户，未提交过申请，4：潜在客户,已提交过申请，5：有IFCC、无权益"`
	PopupMsg          string `description:"权限弹窗信息"`
	MsgType           string `description:"Type ： 类型 , Industry ： 行业"`
	SellerMobile      string `description:"销售电话"`
	SellerName        string `description:"销售姓名"`
	IsResearch        bool   `description:"是否属于研选"`
	IsResearchSpecial bool   `description:"是否属于特殊的研选"`
	Detail            *ActivityDetail
}

// 通过纪要ID获取活动详情
func GetAddActivityInfoById(ActivityId int) (item *ActivityDetail, err error) {
	o := orm.NewOrm()
	sql := `SELECT * FROM cygx_activity  WHERE activity_id=? AND publish_status = 1 `
	err = o.Raw(sql, ActivityId).QueryRow(&item)
	return
}

// 通过纪要ID获取活动详情
func GetAddActivityInfoByActivityId(ActivityId int) (item *ActivityDetail, err error) {
	o := orm.NewOrm()
	sql := `SELECT * FROM cygx_activity  WHERE activity_id=?  `
	err = o.Raw(sql, ActivityId).QueryRow(&item)
	return
}

// 通过活动名称获取活动详情
func GetAddActivityInfoByTitle(title, startDate, endDate string) (item *ActivityDetail, err error) {
	o := orm.NewOrm()
	sql := `SELECT * FROM cygx_activity  WHERE  activity_time > '` + startDate + `' AND activity_time < '` + endDate + `' AND (activity_name_task LIKE '%` + title + `%' OR  jmcj_roadshow_title LIKE '%` + title + `%')   AND activity_id  NOT IN (1328)  LIMIT 1 `
	err = o.Raw(sql).QueryRow(&item)
	return
}

// 通过纪要ID获取活动详情
func GetAddActivityInfoByIdShow(uid, ActivityId int) (item *ActivityDetail, err error) {
	o := orm.NewOrm()
	sql := `SELECT *,( SELECT COUNT( 1 ) FROM cygx_activity_signup AS s WHERE s.activity_id = a.activity_id AND s.user_id = ?   AND s.is_cancel = 0  AND s.do_fail_type = 0) AS is_signup,
			( SELECT COUNT( DISTINCT user_id ) FROM cygx_activity_signup AS s WHERE s.activity_id = a.activity_id  AND s.is_cancel = 0 AND s.do_fail_type = 0) AS signup_num,
			( SELECT COUNT( 1 ) FROM cygx_activity_meeting_reminder AS m WHERE m.activity_id = a.activity_id AND m.user_id = ?  AND m.is_cancel = 0 ) AS is_cancel_meeting_reminder,
			( SELECT COUNT( 1 ) FROM cygx_activity_appointment AS ap WHERE ap.activity_id = a.activity_id AND ap.user_id = ? ) AS is_appointment
			FROM cygx_activity AS a  WHERE activity_id=? AND publish_status = 1 `
	err = o.Raw(sql, uid, uid, uid, ActivityId).QueryRow(&item)
	return
}

// 活动列表
type CygxActivityList struct {
	ActivityId              int    `orm:"column(activity_id);pk";description:"活动ID 等于0新增活动，大于0修改活动"`
	ActivityTypeId          int    `description:"活动类型id"`
	ActivityName            string `description:"活动名称"`
	ActivityTypeName        string `description:"活动类型名称"`
	Speaker                 string `description:"主讲人"`
	SignupType              int    `description:"报名方式，1预约外呼，2我要报名"`
	ChartPermissionId       int    `description:"行业id"`
	ChartPermissionName     string `description:"行业名称"`
	IsLimitPeople           int    `description:"是否限制人数 1是，0否"`
	LimitPeopleNum          int    `description:"限制的人数数量"`
	ActivityTime            string `description:"活动时间"`
	ActivityTimeText        string `description:"活动时间带文字"`
	City                    string `description:"城市"`
	Address                 string `description:"活动地址"`
	DistinguishedGuest      string `description:"嘉宾"`
	Expert                  string `description:"专家"`
	IsSignup                int    `description:"是否已报名 1是 ，0 否"`
	IsAppointment           int    `description:"是否已预约纪要 1是 ，0 否"`
	IsShowAppointment       bool   `description:"是否展示预约纪要"`
	SignupNum               int    `description:"已报名人数"`
	ActiveState             string `description:"活动进行状态 未开始：1、进行中2、已结束3"`
	IsCancelMeetingReminder int    `description:"是否取消会议提醒 1展示取消会议提醒 ，0展示会议提醒"`
	IsBrackets              int    `description:"是否有方括号 1是 ，0 否"`
	Label                   string `description:"主题标签"`
	IsShowSustainable       bool   `description:"是否展示限免标签"`
	ImgUrl                  string `description:"图片链接"`
	ImgUrlText              string `description:"图片链接文字"`
	ActivityType            int    `description:"活动线上线下类型 1线上，0 线下"`
	IsHideAppointment       int    `description:"是否隐藏预约纪要按钮  1是，0 否"`
	JmcjRoadshowTitle       string `description:"进门财经手动匹配的活动名称"`
	IsCClassMeeting         bool   `description:"是否是c类电话会"`
}

type GetCygxActivityListRep struct {
	Paging                 *paging.PagingItem `description:"分页数据"`
	List                   []*ActivityDetail
	Label                  string `description:"主题"`
	ImgUrl                 string `description:"图片路径"`
	IsResearch             bool   `description:"是否属于研选"`
	IsJump                 bool   `description:"是否跳转"`
	IndustrialManagementId int    `description:"产业ID"`
	IndustryNewLabel       bool   `description:"产业是否新标签"`
	IsShowResearchPoints   bool   `description:"是否展示研选扣点搜索"`
}

// 列表
func GetActivityListAll(condition string, pars []interface{}, uid, startSize, pageSize, playBack int) (items []*ActivityDetail, err error) {
	var sqlJiontable string
	if playBack == 1 {
		//sqlJiontable = ` INNER JOIN cygx_activity_voice AS ac ON ac.activity_id = art.activity_id `
	}
	o := orm.NewOrm()
	sql := `SELECT art.* ,t.activity_type,t.img_url_text,
		( SELECT COUNT( 1 ) FROM cygx_activity_signup AS s WHERE s.activity_id = art.activity_id AND s.user_id = ?   AND s.is_cancel = 0  AND s.do_fail_type = 0) AS is_signup,
		( SELECT COUNT( DISTINCT user_id ) FROM cygx_activity_signup AS s WHERE s.activity_id = art.activity_id   AND s.is_cancel = 0  AND s.do_fail_type = 0) AS signup_num,
		( SELECT COUNT( 1 ) FROM cygx_activity_meeting_reminder AS m WHERE m.activity_id = art.activity_id AND m.user_id = ?  AND m.is_cancel = 0  ) AS is_cancel_meeting_reminder,
		( SELECT COUNT( 1 ) FROM cygx_activity_appointment AS ap WHERE ap.activity_id = art.activity_id AND ap.user_id = ? ) AS is_appointment
		FROM cygx_activity as art
		INNER JOIN cygx_activity_type  as t ON t.activity_type_id = art.activity_type_id` + sqlJiontable + ` WHERE 1= 1 `
	if condition != "" {
		sql += condition
	}
	sql += ` LIMIT ?,?`
	_, err = o.Raw(sql, pars, uid, uid, uid, startSize, pageSize).QueryRows(&items)
	return
}

// 列表
func GetActivityListByDateTime(startDate, endDate, activityIds, activityIdsLongTime string) (items []*CygxActivityList, err error) {
	o := orm.NewOrm()
	sql := `SELECT * FROM cygx_activity WHERE activity_time > '` + startDate + `' AND activity_time < '` + endDate + `' `
	activityIds = strings.TrimRight(activityIds, ",")
	if activityIds != "" {
		sql += ` AND activity_id  NOT IN (` + activityIds + `,1328 )  `
	}
	sql += `  OR activity_id IN (` + activityIdsLongTime + `)`
	_, err = o.Raw(sql).QueryRows(&items)
	return
}

// 获取我的日程数量
func GetSpecialScheduleCount(uid int) (count int, err error) {
	o := orm.NewOrm()
	sqlCount := `
SELECT COUNT( 1 ) AS count FROM
			cygx_activity_special AS art
			INNER JOIN cygx_activity_special_trip AS my ON my.activity_id = art.activity_id 
		WHERE
			1 = 1 AND my.user_id = ? AND my.is_cancel = 0`
	err = o.Raw(sqlCount, uid).QueryRow(&count)
	return
}

// 获取数量
func GetActivityCount(condition string, playBack int, pars []interface{}, filter int) (count int, err error) {
	var sqlJiontable string
	if playBack == 1 {
		//sqlJiontable = ` INNER JOIN cygx_activity_voice AS ac ON ac.activity_id = art.activity_id `
	}

	if filter == 1 {
		sqlJiontable = ` INNER JOIN cygx_activity_video AS av ON av.activity_id = art.activity_id `
	} else if filter == 2 {
		sqlJiontable = ` INNER JOIN cygx_activity_voice AS ac ON ac.activity_id = art.activity_id `
	}
	sqlCount := ` SELECT COUNT(1) AS count  FROM cygx_activity as art ` + sqlJiontable + ` WHERE 1= 1  `
	if condition != "" {
		sqlCount += condition
	}
	o := orm.NewOrm()
	err = o.Raw(sqlCount, pars).QueryRow(&count)
	return
}

// 获取我的日程数量
func GetScheduleCount(condition string, uid int) (count int, err error) {
	o := orm.NewOrm()
	sqlCount := `SELECT COUNT( 1 ) AS count 
				FROM cygx_my_schedule AS m
				INNER JOIN cygx_activity AS art ON art.activity_id = m.activity_id 
				WHERE
				user_id = ?`
	if condition != "" {
		sqlCount += condition
	}
	err = o.Raw(sqlCount, uid).QueryRow(&count)
	return
}

// 我的日程列表
func GetScheduleList(condition string, pars []interface{}, uid, startSize, pageSize int) (items []*ActivityDetail, err error) {
	o := orm.NewOrm()
	sql := `SELECT art.*,t.activity_type,t.img_url_text,
			( SELECT COUNT( 1 ) FROM cygx_activity_signup AS s WHERE s.activity_id = art.activity_id AND s.user_id = ? AND s.is_cancel = 0 AND s.do_fail_type = 0) AS is_signup,
            ( SELECT COUNT( DISTINCT user_id ) FROM cygx_activity_signup AS s WHERE s.activity_id = art.activity_id AND  s.is_cancel = 0  AND s.do_fail_type = 0) AS signup_num ,
			( SELECT COUNT( 1 ) FROM cygx_activity_appointment AS ap WHERE ap.activity_id = art.activity_id AND ap.user_id = ? ) AS is_appointment,
			( SELECT COUNT( 1 ) FROM cygx_activity_meeting_reminder AS m WHERE m.activity_id = art.activity_id AND m.is_cancel = 0 AND m.user_id = ? ) AS is_cancel_meeting_reminder
            FROM cygx_activity AS art
			INNER JOIN cygx_my_schedule as my ON my.activity_id = art.activity_id 
			INNER JOIN cygx_activity_type  as t ON t.activity_type_id = art.activity_type_id
            WHERE 1=1 AND my.user_id = ? `
	if condition != "" {
		sql += condition
	}
	sql += ` ORDER BY art.active_state ASC,art.activity_time ASC  LIMIT ?,?`
	_, err = o.Raw(sql, pars, uid, uid, uid, uid, startSize, pageSize).QueryRows(&items)
	return
}

// 我的日程列表 活动以及专项调研一起
func GetScheduleAndSpecilList(condition string, pars []interface{}, conditionSpecil string, parsSpecil []interface{}, startSize, pageSize int) (items []*ActivityDetail, err error) {
	o := orm.NewOrm()
	sql := `SELECT
			art.activity_id,
			art.activity_time_text,
			art.activity_name,
			art.chart_permission_id,
			art.active_state,
			t.activity_type,
			art.chart_permission_name,
			art.distinguished_guest,
			art.expert,
			art.speaker,
			"" AS trip_img_link,
			"" AS activity_time_end,
			art.yidong_activity_id,
			art.is_can_appointment_minutes,
			art.activity_type_id,
			art.limit_people_num,
			art.is_limit_people,
			1 AS source_type,
			art.activity_time, 
			art.city,
			art.is_external_label,
			art.siginup_deadline,
			art.is_research_points,
			art.cancel_deadline
		FROM
			cygx_activity AS art
			INNER JOIN cygx_my_schedule AS my ON my.activity_id = art.activity_id
			INNER JOIN cygx_activity_type AS t ON t.activity_type_id = art.activity_type_id
		WHERE
			1 = 1 `
	if condition != `` {
		sql += condition
	}
	sql += ` UNION ALL
		SELECT
			art.activity_id,
			art.activity_time_text_by_day AS activity_time_text,
			art.research_theme AS activity_name,
			art.chart_permission_id,
			"",
			art.special_type AS activity_type,
			art.chart_permission_name,
			"",
			"",
			"",
			art.trip_img_link_fix AS trip_img_link,
			art.activity_time_end,
			"",
			"",
			"",
			"",
			"",
			2 AS source_type,
			art.activity_time,
			"",
			"",
			"",
			"",
			""
		FROM
			cygx_activity_special AS art
			INNER JOIN cygx_activity_special_trip AS my ON my.activity_id = art.activity_id 
		WHERE
			1 = 1`
	if conditionSpecil != "" {
		sql += conditionSpecil
	}
	sql += ` ORDER BY activity_time DESC   LIMIT ?,?`
	_, err = o.Raw(sql, pars, parsSpecil, startSize, pageSize).QueryRows(&items)
	return
}

// 获取数量
func GetActivityCountById(activityId int) (count int, err error) {
	o := orm.NewOrm()
	sqlCount := `SELECT COUNT(1) AS count  FROM cygx_activity WHERE activity_id = ?`
	err = o.Raw(sqlCount, activityId).QueryRow(&count)
	return
}

// 删除数据
func DeleteActivity(activityId int) (err error) {
	o := orm.NewOrm()
	sql := ` DELETE FROM cygx_activity WHERE activity_id = ?`
	_, err = o.Raw(sql, activityId).Exec()
	return
}

// 修改活动状态至进行中
func UpdateActivitySattusToHaveInHand() (err error) {
	defer func() {
		if err != nil {
			fmt.Println(err)
			go utils.SendAlarmMsg("修改活动状态至进行中失败"+err.Error(), 2)
			go utils.SendEmail(utils.APPNAME+"【"+utils.RunMode+"】"+"失败提醒", "修改活动状态至进行中失败 ErrMsg:"+err.Error(), utils.EmailSendToUsers)
		}
	}()
	o := orm.NewOrm()
	resultTime_30 := time.Now().Add(-time.Minute * 60).Format("2006-01-02 15:04:05") // 线上活动也改成60分钟之后结束了 2023.5.8
	resultTime_60 := time.Now().Add(-time.Minute * 60).Format("2006-01-02 15:04:05")
	var sqlOr string
	var condition string
	condition += ` AND activity_time < NOW()`
	sqlOr = condition
	condition += ` AND (activity_type_id IN ( 1, 2, 3, 7 ) AND  activity_time > ` + "'" + resultTime_30 + "'" + ")"
	condition += ` OR(activity_type_id IN ( 4, 5, 6, 8 ) AND  activity_time > ` + "'" + resultTime_60 + "'" + sqlOr + ")"
	msql := " UPDATE cygx_activity SET active_state = 2, top_time = 0  WHERE 1 = 1 " + condition
	_, err = o.Raw(msql).Exec()
	return
}

// 修改活动状态至已结束
func UpdateActivitySattusToComplete() (err error) {
	defer func() {
		if err != nil {
			fmt.Println(err)
			go utils.SendAlarmMsg("修改活动状态至已结束"+err.Error(), 2)
			go utils.SendEmail(utils.APPNAME+"【"+utils.RunMode+"】"+"失败提醒", "修改活动状态至已结束 ErrMsg:"+err.Error(), utils.EmailSendToUsers)
		}
	}()
	o := orm.NewOrm()
	resultTime_30 := time.Now().Add(-time.Minute * 60).Format("2006-01-02 15:04:05") // 线上活动也改成60分钟之后结束了 2023.5.8
	resultTime_60 := time.Now().Add(-time.Minute * 60).Format("2006-01-02 15:04:05")
	//var sqlOr string
	var condition string
	//condition += ` AND activity_time < NOW()`
	//sqlOr = condition
	condition += ` AND (activity_type_id IN ( 1, 2, 3, 7 ) AND  activity_time < ` + "'" + resultTime_30 + "'" + ")"
	condition += ` OR(activity_type_id IN ( 4, 5, 6 ,8 ) AND  activity_time < ` + "'" + resultTime_60 + "'" + ")"
	msql := " UPDATE cygx_activity SET active_state = 3 WHERE 1 = 1 " + condition
	_, err = o.Raw(msql).Exec()
	return
}

// 活动详情
type WxMsgCygxActivityList struct {
	Id                      int    `description:"报名ID"`
	UserId                  int    `description:"用户ID"`
	ActivityId              int    `description:"活动ID 等于0新增活动，大于0修改活动"`
	ActivityTypeId          int    `description:"活动类型id"`
	ActivityName            string `description:"活动名称"`
	ActivityTypeName        string `description:"活动类型名称"`
	Speaker                 string `description:"主讲人"`
	SignupType              int    `description:"报名方式，1预约外呼，2我要报名"`
	ChartPermissionId       int    `description:"行业id"`
	ChartPermissionName     string `description:"行业名称"`
	IsLimitPeople           int    `description:"是否限制人数 1是，0否"`
	LimitPeopleNum          int    `description:"限制的人数数量"`
	ActivityTime            string `description:"活动时间"`
	ActivityTimeText        string `description:"活动时间带文字"`
	City                    string `description:"城市"`
	Address                 string `description:"活动地址"`
	DistinguishedGuest      string `description:"嘉宾"`
	Expert                  string `description:"专家"`
	IsSignup                int    `description:"是否已报名 1是 ，0 否"`
	SignupNum               int    `description:"已报名人数"`
	ActiveState             string `description:"活动进行状态 未开始：1、进行中2、已结束3"`
	IsCancelMeetingReminder int    `description:"是否取消会议提醒 1展示取消会议提醒 ，0展示会议提醒"`
	IsBrackets              int    `description:"是否有方括号 1是 ，0 否"`
	OpenId                  string `description:"OenId"`
	FailType                int    `description:"失败原因，0，未失败，1总人数已满，2单机构超限制，3，爽约次数超限"`
}

// 列表 3o分钟
func GetActivitySendMsgListAll(endDate string) (items []*WxMsgCygxActivityList, err error) {
	o := orm.NewOrm()
	sql := `SELECT
	s.id,
	s.user_id,
	s.fail_type,
	cr.open_id,
	a.*
FROM
	cygx_activity AS a
	INNER JOIN cygx_activity_signup AS s ON s.activity_id = a.activity_id
	INNER JOIN cygx_user_record AS cr ON cr.cygx_bind_account = s.mobile 
WHERE
	1 = 1 
	AND s.is_send_wx_msg = 0 
	AND s.do_fail_type = 0 
	AND a.publish_status = 1
	AND a.activity_time <= ? AND a.activity_time >= NOW() 
	AND s.is_cancel = 0
	AND( a.activity_type_id IN (4,5,6,8) OR (a.activity_type_id = 3 AND a.is_limit_people = 1 )) 	GROUP BY s.id`
	_, err = o.Raw(sql, endDate).QueryRows(&items)
	return
}

// 买方研选会前一小时需要推送的Openid
func GetActivitySendMsgListAllMfyx(endDate string) (items []*WxMsgCygxActivityList, err error) {
	o := orm.NewOrm()
	sql := `SELECT
	s.id,
	s.user_id,
	s.fail_type,
	cr.open_id,
	a.activity_name,
	a.activity_id,
	a.activity_time
FROM
	cygx_activity AS a
	INNER JOIN cygx_activity_signup AS s ON s.activity_id = a.activity_id
	INNER JOIN cygx_mfyx_gzh_user_record AS cr ON cr.cygx_bind_account = s.mobile 
WHERE
	1 = 1 
	AND s.is_send_wx_msg = 0 
	AND s.do_fail_type = 0 
	AND a.publish_status = 1
  	AND a.chart_permission_id = 31 
	AND a.activity_time = ? AND a.activity_time >= NOW() 
	AND s.is_cancel = 0
	AND a.activity_type_id IN (5,8) 	GROUP BY s.id`
	_, err = o.Raw(sql, endDate).QueryRows(&items)
	return
}

// 列表 15分钟提醒
func GetActivitySendMsgListAllMeeting(endDate string) (items []*WxMsgCygxActivityList, err error) {
	o := orm.NewOrm()
	sql := `SELECT
	m.id,
	cr.open_id,
	a.* 
FROM
	cygx_activity AS a
	INNER JOIN cygx_activity_meeting_reminder AS m ON m.activity_id = a.activity_id
	INNER JOIN user_record AS c ON c.bind_account = m.mobile 
	INNER JOIN cygx_user_record AS cr ON cr.union_id = c.union_id 
WHERE
	1 = 1 
	AND m.is_send_wx_msg = 0 
	AND a.publish_status = 1 
	AND a.activity_time <= ? AND a.activity_time >= NOW() 
	AND m.is_cancel = 0 
	AND c.create_platform = 4
	AND (
	a.activity_type_id IN ( 1, 2 ) 
	OR ( a.activity_type_id = 3 AND a.is_limit_people = 0 ))
	GROUP BY m.id`
	_, err = o.Raw(sql, endDate).QueryRows(&items)
	return
}

// 修改是否推送消息状态
func UPdateSendedMsgStatus(signupIds string) (err error) {
	sql := ` UPDATE cygx_activity_signup SET  is_send_wx_msg= 1  WHERE id IN(` + signupIds + `)`
	o := orm.NewOrm()
	_, err = o.Raw(sql).Exec()
	return
}

// 修改是否推送消息状态
func UPdateSendedYiDongSignUp(activityId int) (err error) {
	sql := ` UPDATE cygx_activity SET  is_yidong_sign_up= 1  WHERE activity_id = ? `
	o := orm.NewOrm()
	_, err = o.Raw(sql, activityId).Exec()
	return
}

// 修改是否推送消息状态
func UPdateSendedMsgMeetingStatus(signupIds string) (err error) {
	sql := ` UPDATE cygx_activity_meeting_reminder SET  is_send_wx_msg= 1  WHERE id IN(` + signupIds + `)`
	o := orm.NewOrm()
	_, err = o.Raw(sql).Exec()
	return
}

// 获取满足推送的活动ID数量
func GetCountActivityIdToSendFile(endDate string) (count int, err error) {
	o := orm.NewOrm()
	sql := `SELECT
	COUNT(1) count
FROM
	cygx_activity AS a
	INNER JOIN cygx_activity_signup AS s ON s.activity_id = a.activity_id 
WHERE
	1 = 1 
	AND s.signup_type = 1 
	AND s.fail_type = 0 
	AND a.is_send_file_toemail = 0 
	AND a.activity_time <= ? AND a.activity_time >= NOW() 	GROUP BY a.activity_id `
	err = o.Raw(sql, endDate).QueryRow(&count)
	return
}

// 获取满足推送的活动ID
func GetActivityIdToSendFile(endDate string) (items []*ActivityIdRep, err error) {
	o := orm.NewOrm()
	sql := `SELECT
			* 
		FROM
			cygx_activity AS a
			INNER JOIN cygx_activity_signup AS s ON s.activity_id = a.activity_id 
			INNER JOIN cygx_activity_type AS t ON a.activity_type_id = t.activity_type_id
		WHERE
			1 = 1 
			AND s.signup_type = 1 
			AND a.yidong_activity_id = '' 
			AND t.activity_type = 1
			AND s.fail_type = 0 
			AND a.is_send_file_toemail = 0 
		 	AND a.publish_status = 1
			AND a.activity_time <= ? AND a.activity_time >= NOW() 	GROUP BY a.activity_id `
	_, err = o.Raw(sql, endDate).QueryRows(&items)
	return
}

type SignupExportRep struct {
	Mobile         string `description:"手机号"`
	CompanyName    string `description:"公司名称"`
	CompanyId      int    `description:"公司Id"`
	RealName       string `description:"姓名"`
	CountryCode    string `description:"区号"`
	OutboundMobile string `description:"外呼手机号"`
	SellerName     string `description:"销售姓名"`
}

type ActivityMsgExportRep struct {
	AskId       int    `description:"活动带问ID"`
	UserId      int    `description:"用户ID"`
	RealName    string `description:"姓名"`
	CompanyName string `description:"公司名称"`
	CompanyId   int    `description:"公司ID"`
	Content     string `description:"内容"`
	CreateTime  string `description:"提交时间"`
}

func GetSignupExport(activityId int) (item []*SignupExportRep, err error) {
	o := orm.NewOrm()
	sql := `SELECT
			s.outbound_mobile,
			s.country_code,
			a.is_limit_people,
			s.real_name,
			s.seller_name,
			s.company_id,
			s.company_name 
		FROM
			cygx_activity_signup AS s
			JOIN cygx_activity AS a ON a.activity_id = s.activity_id 
			WHERE a.activity_id = ?  AND s.do_fail_type = 0 AND s.signup_type = 1  GROUP BY s.id `
	_, err = o.Raw(sql, activityId).QueryRows(&item)
	return
}

// 修改文件是否推送状态
func UPdateActivityIdToSendFile(activityId int) (err error) {
	sql := ` UPDATE cygx_activity SET  is_send_file_toemail= 1  WHERE activity_id = ?`
	o := orm.NewOrm()
	_, err = o.Raw(sql, activityId).Exec()
	return
}

// 活动详情
type CygxActivityLabelList struct {
	KeyWord           string `orm:"column(label)";description:"主题"`
	Timesort          string `description:"最大时间"`
	Mintimesort       string `description:"最小时间"`
	ImgUrlBg          string `description:"背景图片"`
	ActivityId        int    `description:"活动ID "`
	IsShowSubjectName int    `description:"小程序内是否展示标的名称 1是 ，0否 默认0 "`
	Resource          int    `description:"位置 ，1：活动 ，2：专项产业调研"`
	TemporaryLabel    string `description:"临时标签"`
	IsNew             bool   `description:"是否为新：活动存在关联的的产业所关联的报告均在3个月内/无报告则标记新"`
	YidongActivityId  string `description:"易董活动ID"`
	IsExternalLabel   bool   `description:"是否为外部资源"`
	IsResearchPoints  bool   `description:"是否为研选扣点"`
	TripStatus        int    `description:"行程进行状态 1：预报名，2：确定行程"`
	City              string `description:"城市"`
	Days              int    `description:"天数"`
	ActivityTypeId    int    `description:"活动类型id"`
	IsResearch        bool   `description:"是否属于研选"`
	ChartPermissionId int    `description:"行业id"`
}

// 主题列表
func GetActivityLabelListAll(condition, sortTime string, pars []interface{}, startSize, pageSize int) (items []*CygxActivityLabelList, err error) {
	o := orm.NewOrm()
	sql := `SELECT	activity_id,activity_type_id, label,temporary_label,is_show_subject_name, MAX( art.activity_time ) AS timesort, MIn( art.activity_time ) AS mintimesort , yidong_activity_id,city,is_external_label,is_research_points,chart_permission_id
		FROM cygx_activity as art WHERE 1= 1 `
	if condition != "" {
		sql += condition
	}
	sql += ` GROUP BY art.activity_id ORDER BY ` + sortTime + ` ,art.activity_id DESC  LIMIT ?,? `

	_, err = o.Raw(sql, pars, startSize, pageSize).QueryRows(&items)
	return
}

// 主题列表
func GetActivityLabelListCity() (items []*CygxActivity, err error) {
	o := orm.NewOrm()
	sql := `SELECT
			activity_id,
			activity_type_id,
			activity_time,
			label,
			temporary_label,
			is_show_subject_name,
			yidong_activity_id,
			city 
		FROM
			cygx_activity AS art 
		WHERE
			1 = 1 
			AND art.active_state IN ( 1, 2 ) 
			AND city != '' 
		ORDER BY
			activity_time ASC  `
	_, err = o.Raw(sql).QueryRows(&items)
	return
}

type GetCygxActivityLabelListRep struct {
	Label  string `description:"主题"`
	ImgUrl string `description:"图片路径"`
	List   []*CygxActivityLabelList
}

// 获取研选系列专家电话会，会前1小时，满足推送的活动ID数量
func GetCountActivityResearchToSendFile(condition, endDate string) (count int, err error) {
	o := orm.NewOrm()
	sql := `SELECT
	COUNT(1) count
FROM
	cygx_activity AS a
	INNER JOIN cygx_activity_help_ask AS k ON k.activity_id = a.activity_id 
WHERE
	1 = 1 ` + condition + `
	AND a.is_send_ask_msg = 0 
	AND a.activity_time <= ? 
	AND a.activity_time >= NOW()`
	err = o.Raw(sql, endDate).QueryRow(&count)
	return
}

// 获取研选系列专家电话会，会前1小时，满足推送的活动ID
func GetActivityResearchToSendFile(condition, endDate string) (items []*ActivityIdRep, err error) {
	o := orm.NewOrm()
	sql := `SELECT
	* 
FROM
	cygx_activity AS a
	INNER JOIN cygx_activity_help_ask AS k ON k.activity_id = a.activity_id 
WHERE
	1 = 1 ` + condition + `
	AND a.is_send_ask_msg = 0 
	AND a.activity_time <= ? 
	AND a.activity_time >= NOW() 
GROUP BY
	a.activity_id `
	_, err = o.Raw(sql, endDate).QueryRows(&items)
	return
}

func GetActivityMsgExport(activityId int) (item []*ActivityMsgExportRep, err error) {
	o := orm.NewOrm()
	sql := `SELECT
			k.*
			FROM
			cygx_activity_help_ask AS k
			WHERE
			k.activity_id = ? 
			GROUP BY
			k.ask_id`
	_, err = o.Raw(sql, activityId).QueryRows(&item)
	return
}

// 修改文件带问消息是否推送状态
func UPdateActivityMsgToSendFile(activityId int) (err error) {
	sql := ` UPDATE cygx_activity SET  is_send_ask_msg= 1  WHERE activity_id = ?`
	o := orm.NewOrm()
	_, err = o.Raw(sql, activityId).Exec()
	return
}

type AskEmailRep struct {
	Name   string `description:"姓名"`
	Email  string `description:"邮箱"`
	Mobile string `description:"手机号"`
}

func GetAskEmail() (item []*AskEmailRep, err error) {
	o := orm.NewOrm()
	sql := `SELECT * FROM cygx_activity_ask_email`
	_, err = o.Raw(sql).QueryRows(&item)
	return
}

// 主题列表
func GetActivityLabelSpecialListAll(condition string, pars []interface{}, startSize, pageSize int) (items []*CygxActivityLabelList, err error) {
	o := orm.NewOrm()
	sql := `SELECT	label,activity_id,is_show_subject_name,days
		FROM cygx_activity_special as art WHERE 1= 1 `
	if condition != "" {
		sql += condition
	}
	sql += `  LIMIT ?,? `
	_, err = o.Raw(sql, pars, startSize, pageSize).QueryRows(&items)
	return
}

type GetCygxActivitySpecialDetailListResp struct {
	IsFollow        bool               `description:"是否关注新调研通知"`
	IsBindingMobile bool               `description:"是否绑定了手机号"`
	Paging          *paging.PagingItem `description:"分页数据"`
	List            []*CygxActivitySpecialDetail
}

type CygxActivitySpecialResp struct {
	HaqveJurisdiction bool   `description:"是否有权限"`
	OperationMode     string `description:"操作方式 Apply:立即申请、Call:拨号 为空则为有权限"`
	HasPermission     int    `description:"操作方式，1:有该行业权限,正常展示，2：无该行业权限，3：潜在客户，未提交过申请，4：潜在客户,已提交过申请，5：有IFCC、无权益"`
	PopupMsg          string `description:"权限弹窗信息"`
	MsgType           string `description:"Type ： 类型 , Industry ： 行业"`
	SellerMobile      string `description:"销售电话"`
	SellerName        string `description:"销售姓名"`
	IsFollow          bool   `description:"是否关注新调研通知"`
	Detail            *CygxActivitySpecialDetail
}

// 获取专项调研活动列表
func GetCygxActivitySpecialDetailList(condition string, pars []interface{}, uid, startSize, pageSize int) (items []*CygxActivitySpecialDetail, err error) {
	o := orm.NewOrm()
	sql := ` SELECT
	art.*,
	(
	SELECT
		COUNT( 1 ) 
	FROM
		cygx_activity_special_signup AS s 
	WHERE
		s.activity_id = art.activity_id 
		AND s.user_id = ?
	) AS is_signup
FROM
	cygx_activity_special AS art
WHERE
	1 = 1 `
	if condition != "" {
		sql += condition
	}
	sql += `  LIMIT ?,? `
	_, err = o.Raw(sql, uid, pars, startSize, pageSize).QueryRows(&items)
	return
}

// 通过活动ID获取活动详情
func GetCygxActivitySpecialDetailById(uid, ActivityId int) (item *CygxActivitySpecialDetail, err error) {
	o := orm.NewOrm()
	sql := `SELECT *,( SELECT COUNT( 1 ) FROM cygx_activity_special_signup AS s WHERE s.activity_id = a.activity_id AND s.user_id = ? ) AS is_signup 
FROM
	cygx_activity_special AS a 
WHERE
	activity_id = ?
	AND publish_status = 1 	AND is_offline = 0  `
	err = o.Raw(sql, uid, ActivityId).QueryRow(&item)
	return
}

// 通过活动ID获取活动详情
func GetCygxActivitySpecialDetail(ActivityId int) (item *CygxActivitySpecialDetail, err error) {
	o := orm.NewOrm()
	sql := `SELECT * FROM cygx_activity_special  WHERE activity_id=? AND publish_status = 1 `
	err = o.Raw(sql, ActivityId).QueryRow(&item)
	return
}

func UpdateCygxActivityName(activityId int, Name string) (err error) {
	o := orm.NewOrm()
	sql := `UPDATE cygx_activity SET activity_name_task = ? WHERE activity_id=?  `
	_, err = o.Raw(sql, Name, activityId).Exec()
	return
}

// 获取已发布但是为开始活动的权限
func GetActivityWeekPermission() (permission string, err error) {
	o := orm.NewOrm()
	sql := ` SELECT
			GROUP_CONCAT( DISTINCT chart_permission_name SEPARATOR ',' ) AS permission 
		FROM
			cygx_activity 
		WHERE
			active_state = 1`
	err = o.Raw(sql).QueryRow(&permission)
	return
}

// 列表
func GetIndustrialActivityGroupManagementList(activityId int) (items []*IndustrialManagementRep, err error) {
	o := orm.NewOrm()
	sql := `SELECT
			m.chart_permission_id,
			m.industrial_management_id,
			m.industry_name 
			FROM
			cygx_industrial_activity_group_management AS am
			INNER JOIN cygx_industrial_management AS m ON m.industrial_management_id = am.industrial_management_id
			WHERE
			am.activity_id = ? AND am.source = 1`
	_, err = o.Raw(sql, activityId).QueryRows(&items)
	return
}

// GetActivityListByYiDong 获取易董同步过来的活动列表
func GetActivityListByYiDong() (items []*CygxActivity, err error) {
	o := orm.NewOrm()
	sql := ` SELECT * FROM cygx_activity WHERE yidong_activity_id != '' `
	_, err = o.Raw(sql).QueryRows(&items)
	return
}

// GetActivityListByYiDong 获取易董同步过来的活动列表
func GetActivityListByYiDongByCygx() (items []*CygxActivity, err error) {
	o := orm.NewOrm()
	sql := ` SELECT * FROM cygx_activity WHERE yidong_activity_id_by_cygx != '' `
	_, err = o.Raw(sql).QueryRows(&items)
	return
}

// AddCygxActivity 添加活动
func AddCygxActivity(item *CygxActivity) (lastId int64, err error) {
	o := orm.NewOrm()
	lastId, err = o.Insert(item)
	return
}

// 列表
func GetActivityListByYidong(condition string) (items []*ActivityDetail, err error) {
	o := orm.NewOrm()
	sql := `SELECT * FROM cygx_activity WHERE 1 = 1 
	AND ( yidong_activity_id != '' OR yidong_activity_id_by_cygx != '' )  AND publish_status = 1  `
	if condition != "" {
		sql += condition
	}
	_, err = o.Raw(sql).QueryRows(&items)
	return
}

// 列表
func GetActivityListByCondition(condition string, pars []interface{}) (items []*CygxActivity, err error) {
	o := orm.NewOrm()
	sql := `SELECT * FROM cygx_activity WHERE  1 =1 `
	if condition != "" {
		sql += condition
	}
	_, err = o.Raw(sql, pars).QueryRows(&items)
	return
}

// UpdateCygxActivitySubmitMeetingByActivityId  ，修改活动提交到会状态
func UpdateCygxActivitySubmitMeetingByActivityId(activityId int) (err error) {
	o := orm.NewOrm()
	sql := `UPDATE cygx_activity SET is_submit_meeting = 1 WHERE activity_id  = ? `
	_, err = o.Raw(sql, activityId).Exec()
	return
}

// UpdateCygxActivitySubmitMeetingByYidong  ，跟易董返回的用户状态修改活动以提交到会状态
func UpdateCygxActivitySubmitMeetingByYidong(yidongActivityId string) (err error) {
	o := orm.NewOrm()
	sql := `UPDATE cygx_activity SET is_submit_meeting = 1 WHERE yidong_activity_id=? OR  yidong_activity_id_by_cygx = ? `
	_, err = o.Raw(sql, yidongActivityId, yidongActivityId).Exec()
	return
}

// UpdateActivityshowSubject 根据易董推过来的匹配信息，判断临时标签是否展示
func UpdateActivityshowSubject(activityId int) (err error) {
	sql := ` UPDATE cygx_activity SET  is_show_subject_name= 1 , temporary_label = ''  WHERE activity_id = ?`
	o := orm.NewOrm()
	_, err = o.Raw(sql, activityId).Exec()
	return
}

// GetActivitySpecialSearcheList 活动与专项调研的搜索
func GetActivitySpecialSearcheList(condition string, pars []interface{}, conditionSpecil string, parsSpecil []interface{}, startSize, pageSize int) (items []*ActivityDetail, total int, err error) {
	o := orm.NewOrm()
	sql := `SELECT
			art.activity_id,
			art.activity_time_text,
			art.activity_name,
			art.chart_permission_id,
			art.active_state,
			t.activity_type,
			t.img_url_text,
			art.chart_permission_name,
			art.distinguished_guest,
			art.expert,
			art.speaker,
			"" AS trip_img_link,
			"" AS activity_time_end,
			art.yidong_activity_id,
			art.is_can_appointment_minutes,
			art.activity_type_id,
			art.limit_people_num,
			art.is_limit_people,
			art.city,
			1 AS source_type,
			art.is_yidong_conduct,
			art.activity_time,
			art.is_external_label,
			art.siginup_deadline,
			art.is_research_points,
			art.cancel_deadline
		FROM
			cygx_activity AS art
			INNER JOIN cygx_activity_type AS t ON t.activity_type_id = art.activity_type_id
		WHERE
			1 = 1 `
	if condition != `` {
		sql += condition
	}
	sql += ` UNION ALL
		SELECT
			art.activity_id,
			art.activity_time_text_by_day AS activity_time_text,
			art.research_theme AS activity_name,
			art.chart_permission_id,
			"",
			art.special_type AS activity_type,
			"",
			art.chart_permission_name,
			"",
			"",
			"",
			art.trip_img_link_fix AS trip_img_link,
			art.activity_time_end,
			"",
			"",
			"",
			"",
			"",
			"",
			2 AS source_type,
			"",
			art.activity_time,
			"",
			"",
			"",
			""
		FROM
			cygx_activity_special AS art
		WHERE
			1 = 1 `
	if conditionSpecil != "" {
		sql += conditionSpecil
	}
	totalSql := `SELECT COUNT(1) total FROM (` + sql + `) z `
	err = o.Raw(totalSql, pars, parsSpecil).QueryRow(&total)
	if err != nil {
		return
	}
	sql += ` ORDER BY activity_time DESC   LIMIT ?,?`
	_, err = o.Raw(sql, pars, parsSpecil, startSize, pageSize).QueryRows(&items)
	return
}

// 列表
func GetActivityListNew(condition string, pars []interface{}, uid, startSize, pageSize, playBack, filter int, typeName string) (items []*ActivityDetail, err error) {
	var sqlJiontable string
	if playBack == 1 {
		//sqlJiontable = ` INNER JOIN cygx_activity_voice AS ac ON ac.activity_id = art.activity_id `
	}
	if filter == 1 {
		sqlJiontable = ` INNER JOIN cygx_activity_video AS av ON av.activity_id = art.activity_id `
	} else if filter == 2 {
		sqlJiontable = ` INNER JOIN cygx_activity_voice AS ac ON ac.activity_id = art.activity_id `
	}

	o := orm.NewOrm()
	sql := `SELECT art.* ,t.activity_type,t.img_url_text,t.img_url_bg_yx,
		( SELECT COUNT( 1 ) FROM cygx_activity_signup AS s WHERE s.activity_id = art.activity_id AND s.user_id = ?   AND s.is_cancel = 0  AND s.do_fail_type = 0) AS is_signup,
		( SELECT COUNT( DISTINCT user_id ) FROM cygx_activity_signup AS s WHERE s.activity_id = art.activity_id   AND s.is_cancel = 0  AND s.do_fail_type = 0) AS signup_num,
		( SELECT COUNT( 1 ) FROM cygx_activity_meeting_reminder AS m WHERE m.activity_id = art.activity_id AND m.user_id = ?  AND m.is_cancel = 0  ) AS is_cancel_meeting_reminder,
		( SELECT COUNT( 1 ) FROM cygx_activity_appointment AS ap WHERE ap.activity_id = art.activity_id AND ap.user_id = ? ) AS is_appointment
		FROM cygx_activity as art
		INNER JOIN cygx_activity_type  as t ON t.activity_type_id = art.activity_type_id ` + sqlJiontable + ` WHERE 1= 1 `
	if condition != "" {
		sql += condition
	}
	sql += ` LIMIT ?,?`

	if typeName != "" {
		typeSlice := strings.Split(typeName, ",")
		tempCondition := ""
		for _, s := range typeSlice {
			if s == "1" {
				tempCondition += "'专家电话会',"
			} else if s == "2" {
				tempCondition += "'分析师电话会',"
			} else if s == "1,2" {
				tempCondition += "'专家电话会','分析师电话会',"
			}
		}
		tempCondition = strings.TrimRight(tempCondition, ",")
		sql = `SELECT * FROM(` + sql + `) AS t WHERE t.activity_type_name IN (` + tempCondition + `)`
	}
	_, err = o.Raw(sql, uid, uid, uid, pars, startSize, pageSize).QueryRows(&items)
	return
}

// 列表
func GetActivityListHomeNew(condition string, startSize, pageSize int) (items []*ActivityDetail, err error) {
	o := orm.NewOrm()
	sql := `SELECT activity_id
		FROM cygx_activity as art
		INNER JOIN cygx_activity_type  as t ON t.activity_type_id = art.activity_type_id WHERE 1= 1 `
	if condition != "" {
		sql += condition
	}
	sql += ` LIMIT ?,?`
	_, err = o.Raw(sql, startSize, pageSize).QueryRows(&items)
	return
}

// 主题列表
func GetActivityLabelListAllNoLimit(condition, sortTime string, pars []interface{}, conditionSpecial string) (items []*CygxActivityLabelList, err error) {
	o := orm.NewOrm()
	sql := `SELECT	activity_id, label,temporary_label,is_show_subject_name, art.activity_time,	1 AS resource, yidong_activity_id 
		FROM cygx_activity as art WHERE 1= 1 `
	if condition != "" {
		sql += condition
	}
	sql += `  UNION ALL `
	sql += ` SELECT
			art.activity_id,
			art.label,
			art.temporary_label,
			is_show_subject_name,
			art.activity_time,
			2 AS resource,
			'' AS yidong_activity_id 
		FROM
			cygx_activity_special AS art   WHERE 1= 1 ` + conditionSpecial

	sql += ` GROUP BY label,resource  ORDER BY ` + sortTime + ` , activity_id DESC `

	_, err = o.Raw(sql, pars).QueryRows(&items)
	return
}

// 列表
func GetCygxActivityList(condition string, pars []interface{}, startSize, pageSize int) (items []*CygxActivity, err error) {
	o := orm.NewOrm()
	sql := `SELECT * FROM cygx_activity as art WHERE 1= 1 `
	if condition != "" {
		sql += condition
	}
	sql += ` LIMIT ?,?  `
	_, err = o.Raw(sql, pars, startSize, pageSize).QueryRows(&items)
	return
}

// 批量修改弘则活动与进门财经的一个活动关联
func UpdateJmcjActivityIdGroup(items map[int]string) (err error) {
	o := orm.NewOrm()
	p, err := o.Raw("UPDATE cygx_activity SET jmcj_activity_id = ? WHERE activity_id = ? AND jmcj_activity_id= '' ").Prepare()
	if err != nil {
		return
	}
	defer func() {
		_ = p.Close() // 别忘记关闭 statement
	}()
	for k, v := range items {
		_, err = p.Exec(v, k)
		if err != nil {
			return
		}
	}
	return
}

// UpdateActivityVmpRobotMeetingId 建立活动跟上海那边机器人助手参会信息的关联
func UpdateActivityVmpRobotMeetingId(vmpRobotMeetingId, activityId int) (err error) {
	sql := ` UPDATE cygx_activity SET   vmp_robot_meeting_id = ?  WHERE activity_id = ?`
	o := orm.NewOrm()
	_, err = o.Raw(sql, vmpRobotMeetingId, activityId).Exec()
	return
}

func GetYxActivitySendMsgListAll(endDate string) (items []*WxMsgCygxActivityList, err error) {
	o := orm.NewOrm()
	sql := `SELECT
	s.id,
	s.user_id,
	s.fail_type,
	cr.open_id,
	a.*
FROM
	cygx_activity AS a
	INNER JOIN cygx_activity_signup AS s ON s.activity_id = a.activity_id
	INNER JOIN cygx_user_record AS cr ON cr.cygx_bind_account = s.mobile 
WHERE
	1 = 1 
	AND s.is_send_wx_msg = 0 
	AND s.do_fail_type = 0 
	AND a.publish_status = 1
	AND a.chart_permission_id = 31
	AND a.activity_time <= ? AND a.activity_time >= NOW() 
	AND s.is_cancel = 0
	GROUP BY s.id`
	_, err = o.Raw(sql, endDate).QueryRows(&items)
	return
}

// 获取买方研选这边的openid
func GetMfyxActivitySendMsgListAll(endDate string) (items []*WxMsgCygxActivityList, err error) {
	o := orm.NewOrm()
	sql := `SELECT
	s.id,
	s.user_id,
	s.fail_type,
	cr.open_id,
	a.*
FROM
	cygx_activity AS a
	INNER JOIN cygx_activity_signup AS s ON s.activity_id = a.activity_id
	INNER JOIN cygx_mfyx_gzh_user_record AS cr ON cr.cygx_bind_account = s.mobile 
WHERE
	1 = 1 
	AND s.is_send_wx_msg = 0 
	AND s.do_fail_type = 0 
	AND a.publish_status = 1
	AND a.chart_permission_id = 31
	AND a.activity_time <= ? AND a.activity_time >= NOW() 
	AND s.is_cancel = 0
	GROUP BY s.id`
	_, err = o.Raw(sql, endDate).QueryRows(&items)
	return
}