hz_crm_api/models/cygx/activity_meet.go

package cygx

import (
	"fmt"
	"hongze/hz_crm_api/utils"

	//"hongze/hz_crm_api/models"
	"github.com/beego/beego/v2/client/orm"
	"github.com/rdlucklib/rdluck_tools/paging"
	"time"
)

// 活动详情
type CygxMeetList struct {
	ActivityId              int    `orm:"column(activity_id);pk";description:"活动ID 等于0新增活动，大于0修改活动"`
	ActivityName            string `description:"活动名称"`
	ActivityTypeName        string `description:"活动类型名称"`
	ActivityTypeId          int    `description:"活动类型ID"`
	ChartPermissionName     string `description:"行业名称"`
	ChartPermissionNames    string `description:"行业名称"`
	ActivityTime            string `description:"活动时间"`
	ActivityTimeText        string `description:"活动时间带文字"`
	SignupPeopleNum         int    `description:"报名人数/预约外呼人数"`
	MeetPeopleNum           int    `description:"实际参会人数"`
	PotentialPeopleNum      int    `description:"潜在参会人数"`
	OmeetPeopleNum          int    `description:"实际参会人数(辅助字段不使用)"`
	IsSubmitMeeting         int    `description:"是否提交过到会信息 ，1是，0否"`
	OperationStyle          int    `description:"操作方式，1提交到会情况/上传参会表格，2修改到会详情/重新上传"`
	UpdateTime              string `description:"更新时间"`
	IsCClassMeeting         bool   `description:"是否是c类电话会"`
	SubmitMeetingType       int    `description:"操作展示类型 ，1修改到会详情"`
	IsShowAttendanceDetails bool   `description:"是否展示到会详情"`
	IsShowHandMovement      bool   `description:"是否展示手动匹配"`
	IsShowSubmitMeeting     bool   `description:"是否展示提交到会情况"`
	IsShowUpdateMeeting     bool   `description:"是否展示修改到会情况"`
	YidongActivityId        string `description:"易董的活动ID"`
	ActivityJoinType        string `description:"易董活动入会类型01报名审核后可入会 02预约即可入会 03仅定向邀请人员可入会"`
	IsYidongConduct         int    `description:"是否属于易董办会 1：是 、0：否"`
	IsShowSigninButton      bool   `description:"是否展示签到码按钮"`
	SigninImg               string `description:"签到码图片"`
}

type GetCygxMeetListRep struct {
	Paging *paging.PagingItem `description:"分页数据"`
	List   []*CygxMeetList
}

// 获取数量
func GetCygxMeetCount(condition string, pars []interface{}) (count int, err error) {
	sqlCount := ` SELECT COUNT(1) AS count  FROM cygx_activity as a WHERE 1= 1  `
	if condition != "" {
		sqlCount += condition
	}
	o := orm.NewOrm()
	err = o.Raw(sqlCount, pars).QueryRow(&count)
	return
}

// 列表
func GetCygxMeetListAll(condition string, pars []interface{}, startSize, pageSize int) (items []*CygxMeetList, err error) {
	o := orm.NewOrm()
	sql := `SELECT 
		( SELECT COUNT( 1 ) FROM cygx_activity_signup AS s INNER JOIN wx_user as u ON  u.user_id = s.user_id   WHERE s.activity_id = a.activity_id AND s.is_cancel = 0 AND s.do_fail_type = 0 AND  s.company_id != 16 ) AS signup_people_num,
		( SELECT COUNT( 1 ) FROM cygx_activity_signin AS s INNER JOIN wx_user as u ON  u.user_id = s.user_id   WHERE s.activity_id = a.activity_id AND s.company_id <= 1  ) AS potential_people_num,
	    ( SELECT COUNT( DISTINCT d.mobile  ) FROM cygx_activity_attendance_detail  AS d  WHERE d.activity_id = a.activity_id  AND( is_meeting_str = 1 or d.company_id <= 1) ) AS meet_people_num,
	    ( SELECT COUNT( 1 ) FROM cygx_activity_offline_meeting_detail AS o WHERE o.activity_id = a.activity_id AND is_meeting = 1  ) AS omeet_people_num,
		a.*
		FROM cygx_activity as a
		WHERE 1= 1 `
	if condition != "" {
		sql += condition
	}
	sql += `   LIMIT ?,?`
	_, err = o.Raw(sql, pars, startSize, pageSize).QueryRows(&items)
	return
}

type CygxActivityMeet struct {
	Id          int       `orm:"column(id);pk"description:"ID"`
	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:"公司名称"`
	Source      int       `description:"来源，1小程序，2后台添加"`
}

// 获取用户报名数量
func GetActivityMeetCount(uid, activityId int) (count int, err error) {
	sqlCount := `SELECT COUNT(1) AS count FROM cygx_activity_signup WHERE is_cancel=0  AND activity_id=? `
	o := orm.NewOrm()
	err = o.Raw(sqlCount, uid, activityId).QueryRow(&count)
	return
}

// 报名信息Excel下载
type MeetExportRep struct {
	Mobile      string `description:"手机号"`
	CompanyName string `description:"公司名称"`
	RealName    string `description:"姓名"`
	CountryCode string `description:"区号"`
}

type MeetingDoRep struct {
	Ids        string `description:"报名ID，多个ID用 , 隔开"`
	ActivityId int    `description:"活动ID"`
}

type SignUpRestrictUid struct {
	UserId int `description:"用户ID"`
}

// 到会操作
func MeetingDo(meetingUids, noMeetingUids string, ActivityId int, items []*CygxActivityOfflineMeetingDetail) (err error) {
	o := orm.NewOrm()
	to, err := o.Begin()
	if err != nil {
		return
	}
	defer func() {
		if err != nil {
			fmt.Println(err)
			_ = to.Rollback()
		} else {
			_ = to.Commit()
		}
	}()
	fmt.Println("ActivityId", ActivityId)
	//修改报名表的参会记录
	sql := `UPDATE cygx_activity_signup SET is_meeting = 0  WHERE activity_id =? `
	_, err = to.Raw(sql, ActivityId).Exec()
	if err != nil {
		return
	}
	sql = `UPDATE cygx_activity_signup SET is_meeting = 1  WHERE activity_id =? AND  user_id IN  (` + meetingUids + `)`
	_, err = to.Raw(sql, ActivityId).Exec()
	if err != nil {
		return
	}
	sql = `UPDATE cygx_activity SET is_submit_meeting = 1 , submit_meeting_type = 1 WHERE activity_id = ? `
	_, err = to.Raw(sql, ActivityId).Exec()
	if err != nil {
		return
	}
	//删除老的记录并插入新的记录
	sql = `DELETE FROM cygx_activity_offline_meeting_detail   WHERE activity_id = ? `
	_, err = to.Raw(sql, ActivityId).Exec()
	if err != nil {
		return
	}
	if len(items) > 0 {
		//批量添加记录
		_, err = to.InsertMulti(len(items), items)
		if err != nil {
			return
		}
	}

	if len(noMeetingUids) > 0 {
		sql = `UPDATE cygx_activity_offline_meeting_detail SET is_meeting = 0  WHERE activity_id =? AND user_id IN (` + noMeetingUids + `)`
		_, err = to.Raw(sql, ActivityId).Exec()
		if err != nil {
			return
		}
	}
	//添加记录表的到会信息
	sql = `UPDATE cygx_activity_signup_detail SET is_meeting = 1  WHERE activity_id =? AND  user_id IN  (` + meetingUids + `)`
	_, err = to.Raw(sql, ActivityId).Exec()
	if err != nil {
		return
	}
	return
}

// 获取数量
func GetCygxBreakAppointmentCount(condition string, pars []interface{}) (count int, err error) {
	sqlCount := ` SELECT COUNT(1)  count FROM ( SELECT u.user_id 
				FROM
				cygx_activity_signup_break AS s
				INNER JOIN wx_user AS u ON u.user_id = s.user_id
				INNER JOIN cygx_activity AS a ON a.activity_id = s.activity_id
				INNER JOIN company_product AS p ON p.company_id = u.company_id WHERE 1 = 1 ` + condition + ` GROUP BY u.user_id) AS c  `
	o := orm.NewOrm()
	err = o.Raw(sqlCount, pars).QueryRow(&count)
	return
}

// 爽约记录列表
type CygxBreakAppointmentList struct {
	UserId              int    `description:"用户ID"`
	CompanyId           int    `description:"公司ID"`
	RealName            string `description:"姓名"`
	Mobile              string `description:"手机号"`
	CompanyName         string `description:"公司名称"`
	SellerName          string `description:"销售姓名"`
	BreakAppointmentNum int    `description:"爽约次数"`
	IsRestrict          int    `description:"是否被限制报名"`
	Operation           bool   `description:"是否被限制报名操作，true限制，false不限制"`
}

type GetCygxBreakAppointmentListRep struct {
	Paging *paging.PagingItem `description:"分页数据"`
	List   []*CygxBreakAppointmentList
}

func GetCygxBreakAppointmentList(condition string, pars []interface{}, startSize, pageSize int) (items []*CygxBreakAppointmentList, err error) {
	o := orm.NewOrm()
	sql := `SELECT
			( SELECT COUNT( 1 ) FROM cygx_activity_restrict_signup AS sig WHERE sig.user_id = u.user_id AND sig.is_restrict = 1 ) AS is_restrict,
			(
			SELECT
				COUNT( 1 ) count 
			FROM
				cygx_activity_signup_break AS s
				INNER JOIN cygx_activity AS a ON a.activity_id = s.activity_id 
			WHERE
				1 = 1
				AND s.user_id = u.user_id 
			) AS break_appointment_num,
			u.real_name,
			u.mobile,
			u.user_id,
			u.company_id,
			c.company_name,
			s.activity_id
		FROM
			cygx_activity_signup_break AS s
			INNER JOIN wx_user AS u ON u.user_id = s.user_id
			INNER JOIN cygx_activity AS a ON a.activity_id = s.activity_id
			INNER JOIN company_product AS p ON p.company_id = u.company_id 
			INNER JOIN company AS c ON c.company_id = u.company_id 
		WHERE
			1 = 1 `
	if condition != "" {
		sql += condition
	}
	sql += ` GROUP BY u.user_id ORDER BY break_appointment_num DESC,a.activity_time DESC LIMIT ?,?`
	_, err = o.Raw(sql, pars, startSize, pageSize).QueryRows(&items)
	return
}

// 获取爽约次数数量
func GetCygxBreakAppointmentUserCount(uid int) (count int, err error) {
	sqlCount := ` SELECT  COUNT(1) count
				FROM
				cygx_activity_signup AS s 
                LEFT JOIN wx_user AS u ON u.user_id = s.user_id
				LEFT JOIN cygx_activity AS a ON a.activity_id = s.activity_id
				WHERE
				s.activity_id = a.activity_id 
				AND s.is_meeting = 0 
				AND a.is_submit_meeting = 1 
				AND s.user_id = ? `
	o := orm.NewOrm()
	err = o.Raw(sqlCount, uid).QueryRow(&count)
	return
}

func GetCompanySellerName(companyId int) (sellerName string, err error) {
	sql := `SELECT
			GROUP_CONCAT( DISTINCT p.seller_name SEPARATOR '/' ) AS sellerName 
		FROM
			company_product AS p
		WHERE
			p.company_id = ?`
	o := orm.NewOrm()
	err = o.Raw(sql, companyId).QueryRow(&sellerName)
	return
}

//end

// 销售名称
type CygxSellerNameList struct {
	SellerName string `orm:"column(real_name);"description:"销售姓名"`
}
type GetCygxSellerNameListRep struct {
	List []*CygxSellerNameList
}

func GetCygxSellerNameList() (items []*CygxSellerNameList, err error) {
	o := orm.NewOrm()
	sql := `SELECT real_name FROM admin WHERE role = 'sales' `
	_, err = o.Raw(sql).QueryRows(&items)
	return
}

//end

// 活动详情
type CygxActivityBreakAppointment struct {
	ActivityName        string `description:"活动名称"`
	ActivityTypeName    string `description:"活动类型名称"`
	ChartPermissionName string `description:"行业名称"`
	ActivityTimeText    string `description:"活动时间带文字"`
}
type GetCygxActivityBreakAppointmentRep struct {
	List []*CygxActivityBreakAppointment
}

func GetCygxActivityBreakAppointmentList(mobile string) (items []*CygxActivityBreakAppointment, err error) {
	o := orm.NewOrm()
	sql := `SELECT a.activity_name,a.activity_type_name,a.chart_permission_name,a.activity_time_text
   			FROM cygx_activity AS a
			INNER JOIN cygx_activity_signup_break AS s ON s.activity_id = a.activity_id 
			WHERE 1 = 1
			AND s.mobile = ? `
	_, err = o.Raw(sql, mobile).QueryRows(&items)
	return
} //end

// 报名限制
func AddSignUpRestrict(uid int) (err error) {
	o := orm.NewOrm()
	to, err := o.Begin()
	if err != nil {
		return
	}
	defer func() {
		if err != nil {
			_ = to.Rollback()
		} else {
			_ = to.Commit()
		}
	}()

	var count int
	sql := `SELECT COUNT(1) AS count FROM cygx_activity_restrict_signup WHERE user_id=? `
	err = to.Raw(sql, uid).QueryRow(&count)
	if err != nil {
		return
	}
	//if count == 0 {
	//	sql = `DELETE  FROM cygx_my_schedule   WHERE user_id=?  AND activity_id=? `
	//	_, err = to.Raw(sql, item.UserId, item.ActivityId).Exec()
	//	if err != nil {
	//		return
	//	}
	//}
	//
	//sql := `UPDATE cygx_activity_signup SET is_meeting = 0  WHERE activity_id =? `
	//_, err = to.Raw(sql, uid).Exec()
	//if err != nil {
	//	return
	//}
	//sql = `UPDATE cygx_activity_signup SET is_meeting = 1  WHERE activity_id =? AND id IN `
	//_, err = to.Raw(sql, uid).Exec()
	//if err != nil {
	//	return
	//}
	sql = `UPDATE cygx_activity SET is_submit_meeting = 1  WHERE activity_id = ? `
	_, err = to.Raw(sql, uid).Exec()
	return
}

// 获取爽约次数
func GetUserBreakAppointmentCount(uid int) (count int, err error) {
	sqlCount := `SELECT COUNT(1)  count FROM (
				SELECT
				( SELECT COUNT( 1 ) FROM cygx_activity_signup AS s WHERE s.activity_id = a.activity_id AND s.is_meeting = 0 AND a.is_submit_meeting = 1 ) AS break_appointment_num 
				FROM
				cygx_activity_signup AS s
				INNER JOIN cygx_activity AS a ON a.activity_id = s.activity_id 
				WHERE
				1 = 1 
				AND s.is_meeting = 0 
				AND a.is_submit_meeting = 1 
				AND s.user_id = ? 
				GROUP BY
				s.user_id ) as cn `
	o := orm.NewOrm()
	err = o.Raw(sqlCount, uid).QueryRow(&count)
	return
}

func GetCygxActivityRestrictSignupCount(uid int) (count int, err error) {
	o := orm.NewOrm()
	sql := `SELECT COUNT(1) AS count FROM cygx_activity_restrict_signup WHERE user_id=? `
	err = o.Raw(sql, uid).QueryRow(&count)
	return
}

// 获取限制报名详情
func GetCygxActivityRestrictSignupInfo(uid int) (item *CygxActivityRestrictSignup, err error) {
	o := orm.NewOrm()
	sql := `SELECT * FROM cygx_activity_restrict_signup  WHERE user_id=?`
	err = o.Raw(sql, uid).QueryRow(&item)
	return
}

// 修改报名限制状态
func UpdateCygxActivityRestrictSignup(newIsRestrict, uid int) (err error) {
	sql := `UPDATE cygx_activity_restrict_signup SET  is_restrict=?  WHERE user_id=? `
	o := orm.NewOrm()
	_, err = o.Raw(sql, newIsRestrict, uid).Exec()
	return
}

type MeetingExportRep struct {
	CompanyName         string `description:"公司名称"`
	CompanyId           int    `description:"公司ID"`
	Status              string `description:"状态"`
	RealName            string `description:"姓名"`
	Mobile              string `description:"手机号"`
	PsellerName         string `description:"所属销售"`
	ActivityName        string `description:"活动名称"`
	ChartPermissionName string `description:"行业名称"`
	ActivityTypeName    string `description:"活动类型名称"`
	ActivityTimeText    string `description:"活动时间带文字"`
	Permission          string `description:"开通权限"`
}

func GetMeetingExport(sqlStr string) (item []*MeetingExportRep, err error) {
	o := orm.NewOrm()
	sql := `SELECT s.id, s.company_name,s.mobile,u.real_name,a.activity_name,a.chart_permission_name,a.activity_type_name,a.activity_time_text,p.status,p.seller_name,
			GROUP_CONCAT( DISTINCT p.seller_name SEPARATOR '/' ) AS pseller_name,
			GROUP_CONCAT( DISTINCT c.chart_permission_name SEPARATOR '/' ) AS permission,
			( SELECT COUNT( 1 ) FROM cygx_activity_signup AS s WHERE s.company_id = u.company_id AND s.is_cancel = 0 AND s.fail_type = 0 ) AS company_num,
			( SELECT COUNT( 1 ) FROM cygx_activity_signup AS s WHERE s.user_id = u.user_id AND s.is_cancel = 0 AND s.fail_type = 0 ) AS user_num 
			FROM
			cygx_activity_signup AS s
			INNER JOIN wx_user AS u ON u.user_id = s.user_id
			INNER JOIN cygx_activity AS a ON a.activity_id = s.activity_id
			LEFT JOIN company_product AS p ON p.company_id = s.company_id
			LEFT JOIN company_report_permission AS re ON re.company_id = s.company_id
			LEFT JOIN chart_permission AS c ON c.chart_permission_id = re.chart_permission_id 
			WHERE 1 = 1 
			AND s.fail_type = 0 
			AND s.is_cancel = 0 
			AND p.status IN ( '正式', '试用' ) 
			AND p.is_suspend = 0 
			AND c.is_report = 1 ` + sqlStr + ` GROUP BY s.id ORDER BY company_num DESC,user_num DESC,a.activity_time DESC `
	_, err = o.Raw(sql).QueryRows(&item)
	return
}

// 获取报名了的用户IDs
func GetSignupUserIds(activityId int, uIds string) (signupUids string, err error) {
	sql := ` SELECT
			GROUP_CONCAT( DISTINCT s.user_id SEPARATOR ',' ) AS signupUids 
			FROM cygx_activity_signup AS s
            WHERE s.activity_id = ? AND s.do_fail_type = 0 AND s.user_id not IN (` + uIds + `)`
	o := orm.NewOrm()
	err = o.Raw(sql, activityId).QueryRow(&signupUids)
	return
}

// 获取报名了的用户IDs
func GetSignupUserIdsFromOfflineMeeting(Ids string) (signupUids string, err error) {
	sql := ` SELECT
			GROUP_CONCAT( DISTINCT s.user_id SEPARATOR ',' ) AS signupUids 
			FROM cygx_activity_offline_meeting_detail AS s WHERE s.id  IN (` + Ids + `)`
	o := orm.NewOrm()
	err = o.Raw(sql).QueryRow(&signupUids)
	return
}

// 线下到会数据
func GetMeetingExportOffline(condition string) (items []*MeetingExportRep, err error) {
	o := orm.NewOrm()
	sql := `SELECT
			s.id,
			s.company_name,
			s.company_id,
			s.mobile,
			u.real_name,
			a.activity_name,
			a.chart_permission_name,
			a.activity_type_name,
			a.activity_time_text,
			p.status,
			p.seller_name,
			GROUP_CONCAT( DISTINCT p.seller_name SEPARATOR '/' ) AS pseller_name,
			GROUP_CONCAT( DISTINCT c.chart_permission_name SEPARATOR '/' ) AS permission,
			( SELECT COUNT( 1 ) FROM cygx_activity_offline_meeting_detail AS s WHERE s.company_id = u.company_id  AND s.is_meeting = 1 ) AS company_num,
			( SELECT COUNT( 1 ) FROM cygx_activity_offline_meeting_detail AS s WHERE s.user_id = u.user_id    AND s.is_meeting = 1 ) AS user_num 
		FROM
			cygx_activity_offline_meeting_detail AS s
			INNER JOIN wx_user AS u ON u.user_id = s.user_id
			INNER JOIN cygx_activity AS a ON a.activity_id = s.activity_id
			LEFT JOIN company_product AS p ON p.company_id = s.company_id
			LEFT JOIN company_report_permission AS re ON re.company_id = s.company_id
			LEFT JOIN chart_permission AS c ON c.chart_permission_id = re.chart_permission_id 
		WHERE
			1 = 1 
			AND p.status IN ( '正式', '试用' ) 
			AND p.is_suspend = 0 
			AND c.is_report = 1 
			AND a.active_state = 3
			AND s.is_meeting = 1 `
	if condition != "" {
		sql += condition
	}
	sql += ` GROUP BY s.id ORDER BY company_num DESC, user_num DESC, a.activity_time DESC, p.company_id DESC `
	_, err = o.Raw(sql).QueryRows(&items)
	return
}

// 线上到会数据
func GetMeetingExportOnline(condition string) (items []*MeetingExportRep, err error) {
	o := orm.NewOrm()
	sql := `SELECT
			s.attendance_id,
			s.company_name,
			s.company_id,
			s.mobile,
			u.real_name,
			a.activity_name,
			a.chart_permission_name,
			a.activity_type_name,
			a.activity_time_text,
			p.status,
			p.seller_name,
			GROUP_CONCAT( DISTINCT p.seller_name SEPARATOR '/' ) AS pseller_name,
			GROUP_CONCAT( DISTINCT c.chart_permission_name SEPARATOR '/' ) AS permission,
			( SELECT COUNT( 1 ) FROM cygx_activity_attendance_detail AS s WHERE s.company_id = p.company_id ) AS company_num,
			( SELECT COUNT( 1 ) FROM cygx_activity_attendance_detail AS s WHERE s.mobile = u.outbound_mobile ) AS user_num 
		FROM
			cygx_activity_attendance_detail AS s
			INNER JOIN wx_user AS u ON u.outbound_mobile = s.mobile
			INNER JOIN cygx_activity AS a ON a.activity_id = s.activity_id
			LEFT JOIN company_product AS p ON p.company_id = u.company_id
			LEFT JOIN company_report_permission AS re ON re.company_id = u.company_id
			LEFT JOIN chart_permission AS c ON c.chart_permission_id = re.chart_permission_id 
		WHERE
			1 = 1 
			AND p.status IN ( '正式', '试用' ) 
			AND p.is_suspend = 0 
			AND c.is_report = 1 
			AND a.active_state = 3  `
	if condition != "" {
		sql += condition
	}
	sql += `GROUP BY s.attendance_id ORDER BY company_num DESC, user_num DESC, a.activity_time DESC,p.company_id DESC  `
	_, err = o.Raw(sql).QueryRows(&items)
	return
}

// 到会数据
func GetMeetingExportAll(condition string) (items []*MeetingExportRep, err error) {
	o := orm.NewOrm()
	sql := `SELECT
			s.attendance_id,
			s.company_name,
			s.company_id,
			s.mobile,
			u.real_name,
			a.activity_name,
			a.chart_permission_name,
			a.activity_type_name,
			a.activity_time_text,
			p.status,
			p.seller_name,
			GROUP_CONCAT( DISTINCT p.seller_name SEPARATOR '/' ) AS pseller_name,
			GROUP_CONCAT( DISTINCT c.chart_permission_name SEPARATOR '/' ) AS permission
		FROM
			cygx_activity_meet_detail_log AS s
			INNER JOIN wx_user AS u ON u.outbound_mobile = s.mobile
			INNER JOIN cygx_activity AS a ON a.activity_id = s.activity_id
			INNER JOIN company_product AS p ON p.company_id = u.company_id
			INNER JOIN company_report_permission AS re ON re.company_id = u.company_id
			INNER JOIN chart_permission AS c ON c.chart_permission_id = re.chart_permission_id 
		WHERE
			1 = 1 
			AND p.status IN ( '正式', '试用' ) 
			AND p.is_suspend = 0 
			AND c.is_report = 1 
			AND s.company_name != ''
			AND a.active_state = 3   `
	if condition != "" {
		sql += condition
	}
	sql += ` GROUP BY s.attendance_id ORDER BY s.company_meet_num DESC, s.user_meet_num DESC, a.activity_time DESC,p.company_id DESC   `
	_, err = o.Raw(sql).QueryRows(&items)
	return
}

func GetCompanyAciviytyGroupDate() (item []*CreateTimesResp, err error) {
	o := orm.NewOrm()
	sql := ` SELECT date_format(activity_time,'%Y-%m') as create_times FROM cygx_activity WHERE 1=1  AND  activity_time <= NOW()  GROUP BY create_times ORDER BY create_times DESC `
	_, err = o.Raw(sql).QueryRows(&item)
	return
}

type CygxYidongActivityMeetingApiLog struct {
	Id               int    `orm:"column(id);pk"`
	Data             string `description:"返回结果数据"`
	YidongActivityId string `description:"易董活动ID"`
	CreateTime       string `description:"本地创建时间"`
}

// 获取限制报名详情
func GetCygxActivityYiDongUpdateTime(yidongActivityId string) (item *CygxYidongActivityMeetingApiLog, err error) {
	o := orm.NewOrm()
	sql := `SELECT * FROM cygx_yidong_activity_meeting_api_log  WHERE yidong_activity_id = ? ORDER BY id DESC  LIMIT 1`
	err = o.Raw(sql, yidongActivityId).QueryRow(&item)
	return
}

type CygxAtivityIdMeetNum struct {
	ActivityId int `description:"活动ID"`
	Num        int `description:"数量"`
}

// GetCygxActivityYiDongMeetNum 根据活动ID获取到会数量的列表
func GetCygxActivityYiDongMeetNum(activityId []int) (items []*CygxAtivityIdMeetNum, err error) {
	lenactivityId := len(activityId)
	if lenactivityId == 0 {
		return
	}
	sql := `SELECT
			activity_id,
			( SELECT count( 1 ) FROM cygx_activity_signup AS s WHERE s.activity_id = a.activity_id AND is_meeting = 1  AND  yidong_examine_status = 1 ) AS num 
		FROM
			cygx_activity AS a 
		WHERE
			a.activity_id IN  (` + utils.GetOrmInReplace(lenactivityId) + `) `
	o := orm.NewOrm()
	_, err = o.Raw(sql, activityId).QueryRows(&items)
	return
}

type GetSellerUserMobileResp struct {
	Mobile string `description:"手机号"`
}

// 获取销售所能查看到的手机号
func GetSellerUserMobile(condition string) (items []*GetSellerUserMobileResp, err error) {
	o := orm.NewOrm()
	_, err = o.Raw(condition).QueryRows(&items)
	return
}