hz_crm_api/models/cygx/activity_signup.go

package cygx

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

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

// 活动详情
type CygxSignupList struct {
	ActivityId              int    `orm:"column(activity_id);pk";description:"活动ID 等于0新增活动，大于0修改活动"`
	ActivityName            string `description:"活动名称"`
	ActivityTypeName        string `description:"活动类型名称"`
	ChartPermissionName     string `description:"行业名称"`
	ChartPermissionNames    string `description:"行业名称辅助字段，区分研选子分类"`
	LimitPeopleNum          int    `description:"限制的人数数量"`
	ActivityTime            string `description:"活动时间"`
	ActivityTimeText        string `description:"活动时间带文字"`
	SignupPeopleNum         int    `description:"报名人数/预约外呼人数"`
	SignupFailPeopleNum     int    `description:"报名/预约外呼失败人数"`
	AskNum                  int    `description:"带问人数"`
	AppointmentPeopleNum    int    `description:"预约纪要人数"`
	ReminderPeopleNum       int    `description:"设置会议提醒人数"`
	IsShowAppointment       bool   `description:"是否展示预约纪要"`
	IsHideAppointment       int    `description:"是否隐藏预约纪要按钮  1是，0 否"`
	ActivityTypeId          int    `description:"活动类型id"`
	Label                   string `description:"标签"`
	ActiveState             int    `description:"活动进行状态 未开始：1、进行中2、已结束3"`
	PublishStatus           int    `description:"发布状态 1已发布，0未发布"`
	TemporaryLabel          string `description:"临时标签"`
	YidongActivityId        string `description:"易董的活动ID"`
	IsCanAppointmentMinutes int    `description:"是否可预约纪要 1是 ，0 否 默认0 "`
	IsCancel                int    `description:"是否取消，1是，0否"`
	IsYidongConduct         int    `description:"是否属于易董办会 1：是 、0：否"`
	IsResearchPoints        int    `description:"是否为研选扣点  1是，0否"`
}

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

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

// 列表
func GetCygxSignupListAll(condition string, pars []interface{}, startSize, pageSize int) (items []*CygxSignupList, 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 = art.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_signup AS s INNER JOIN wx_user as u ON u.user_id = s.user_id WHERE s.activity_id = art.activity_id  AND s.is_cancel = 0 AND  s.fail_type >= 1) AS signup_fail_people_num, 
		( SELECT COUNT( 1 ) FROM cygx_activity_help_ask AS k INNER JOIN wx_user as u ON u.user_id = k.user_id WHERE k.activity_id = art.activity_id ) AS ask_num, 
		( SELECT COUNT( 1 ) FROM cygx_activity_appointment AS ap INNER JOIN wx_user as u ON u.user_id = ap.user_id WHERE ap.activity_id = art.activity_id ) AS appointment_people_num,
		( SELECT COUNT( 1 ) FROM cygx_activity_meeting_reminder AS ap   INNER JOIN wx_user as u ON u.user_id = ap.user_id WHERE ap.activity_id = art.activity_id ) AS reminder_people_num,
		art.* FROM cygx_activity as art
		WHERE 1= 1 `
	if condition != "" {
		sql += condition
	}
	sql += ` LIMIT ?,?`
	_, err = o.Raw(sql, pars, startSize, pageSize).QueryRows(&items)
	return
}

type CygxAppointmentList struct {
	Id             int    `orm:"column(id);pk"`
	ActivityId     int    `description:"活动ID"`
	ActivityTime   string `description:"活动时间"`
	UserId         int    `description:"用户ID"`
	CreateTime     string `description:"创建时间"`
	Mobile         string `description:"手机号"`
	OutboundMobile string `description:"外呼手机号"`
	CountryCode    string `description:"手机国家区号"`
	CompanyName    string `description:"公司名称"`
	CompanyId      int    `description:"公司ID"`
	RealName       string `description:"姓名"`
	FailType       int    `description:"失败原因，0，未失败，1总人数已满，2单机构超限制，3，爽约次数超限"`
	//MeetingType int    `description:"参会方式，0，无，1预约外呼，2自主拨入"`
	SellerName          string `description:"销售姓名"`
	PsellerName         string `description:"销售姓名"`
	SignupType          int    `description:"报名方式，1预约外呼，2自主拨入，3我要报名"`
	YidongExamineStatus int    `description:"易董活动报名审核状态0审核中，1：审核通过、2审核不通过"`
	Email               string `description:"邮箱"`
}

type CygxSignupUser struct {
	UserId     int `description:"用户ID"`
	ActivityId int `description:"活动ID"`
}

type CygxSignupId struct {
	SignupId    int `description:"报名ID"`
	CancelClass int `description:"取消类型 0取消报名，1取消外呼"`
}

// 预约外呼列表
func GetCygxAppointmentLisssst(activityId int) (items []*CygxAppointmentList, err error) {
	o := orm.NewOrm()
	sql := `SELECT * FROM cygx_activity_signup  WHERE activity_id= ? `
	_, err = o.Raw(sql, activityId).QueryRows(&items)
	return
}

func GetCygxAppointmentList(article_id int, sqlStr string) (item []*CygxAppointmentList, err error) {
	o := orm.NewOrm()
	sql := `SELECT s.id,s.activity_id,s.user_id,s.create_time,s.mobile,s.outbound_mobile,s.company_id,s.fail_type ,s.fail_type,s.signup_type,a.is_limit_people,u.real_name,c.company_name,a.activity_time,s.country_code,s.yidong_examine_status,s.email,
			(SELECT p.seller_name from company_product as p WHERE p.company_id = u.company_id  AND  p.product_id = 2 )  AS seller_name,
			GROUP_CONCAT( DISTINCT p.seller_name SEPARATOR '/' ) AS pseller_name
			FROM
			cygx_activity_signup AS s
			INNER 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
			LEFT JOIN company_product AS p ON p.company_id = u.company_id 
			LEFT JOIN company AS c ON c.company_id = u.company_id 
			WHERE a.activity_id = ?  AND s.do_fail_type = 0 ` + sqlStr + `  GROUP BY s.user_id   ORDER BY s.create_time DESC `
	_, err = o.Raw(sql, article_id).QueryRows(&item)
	return
}

type GetAppointmentListRep struct {
	ExcelType        string `description:"EXcel下载类型 AppointmentCall：预约外呼、ExpertSalon：专家沙龙报名、Teleconference：公司调研电话会、OfflineResearch：公司线下调研 、CClass： C类电话会 、YiDong：易董 "`
	ActivityId       int    `description:"活动ID"`
	Total            int    `description:"总人数"`
	MyTotal          int    `description:"本人名下客户"`
	IsLimitPeople    int    `description:"是否限制人数 1是，0否"`
	MemberType       string `description:"管理员身份 Admin：超级管理员、权益管理员、权益研究员、专家组;GroupLeader:组长；Sale:销售"`
	ActivityType     int    `description:"1线上 ，0 线下"`
	IsYidongConduct  int    `description:"是否属于易董办会 1：是 、0：否"`
	IsResearchPoints int    `description:"是否为研选扣点  1是，0否"`
	List             []*CygxAppointmentList
}

func GetCygxAppointmentCount(articleId int, sqlStr string) (count int, err error) {
	o := orm.NewOrm()
	sql := `SELECT COUNT(*) FROM
			cygx_activity_signup AS s
			INNER  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
			LEFT JOIN company_product AS p ON p.company_id = u.company_id 
			WHERE
			s.activity_id = ? ` + sqlStr + `
            GROUP BY s.user_id)`
	sql = `SELECT COUNT(*)  as count FROM (` + sql + ` a`

	err = o.Raw(sql, articleId).QueryRow(&count)
	return
}

// 新增外呼人员
type GetOutboundPersonnelListRep struct {
	List []*GetOutboundPersonnelRep
}

type GetOutboundPersonnelRep struct {
	UserId      int    `description:"用户id"`
	RealName    string `description:"姓名"`
	Mobile      string `description:"手机号"`
	CompanyName string `description:"公司名称"`
}

// 列表
func GetOutboundPersonnelList(name string) (items []*GetOutboundPersonnelRep, err error) {
	o := orm.NewOrm()
	sql := `SELECT u.user_id,u.real_name,u.mobile,p.company_name FROM wx_user as u INNER JOIN company AS p ON p.company_id = u.company_id WHERE  real_name LIKE '%` + name + `%'  AND u.company_id >1   GROUP BY u.user_id  ORDER BY user_id ASC`
	_, err = o.Raw(sql).QueryRows(&items)
	return
}

type AddOutboundPersonnelItm struct {
	UserIds     string `description:"用户id,多个用,隔开"`
	ActivityIds string `description:"活动ID，多个用,隔开"`
}

type AddOutboundPersonnelJsonItm struct {
	JsonStar    string `description:"报名信息json字符串 ：Uid 用户ID，int类型 。Type string类型，报名方式，1预约外呼，2自主拨入 "`
	ActivityIds string `description:"活动ID，多个用,隔开"`
}

type CygxActivitySignup 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:"公司名称"`
	OutboundMobile string    `description:"外呼手机号"`
	CountryCode    string    `description:"手机国家区号"`
	Source         int       `description:"来源，1小程序，2后台添加"`
	SignupType     int       `description:"报名方式，1预约外呼，2自主拨入，3我要报名"`
	RealName       string    `description:"用户实际名称"`
	SellerName     string    `description:"所属销售"`
}

// 我的日程
type CygxMySchedule struct {
	Id          int       `orm:"column(id);pk"`
	ActivityId  int       `description:"活动ID"`
	UserId      int       `description:"用户ID"`
	CreateTime  time.Time `description:"创建时间"`
	Mobile      string    `description:"手机号"`
	Email       string    `description:"邮箱"`
	CompanyId   int       `description:"公司id"`
	CompanyName string    `description:"公司名称"`
}

type UserAndCompanyName struct {
	UserId              int `orm:"column(user_id);pk"`
	Mobile              string
	Email               string
	CompanyId           int
	CompanyName         string `description:"公司名称"`
	CountryCode         string `description:"手机国家区号"`
	OutboundMobile      string `description:"外呼手机号"`
	OutboundCountryCode string `description:"外呼手机号区号"`
	SellerName          string `description:"所属销售"`
	RealName            string `description:"真实姓名"`
}

func GetUserAndCompanyNameList(uid int) (item *UserAndCompanyName, err error) {
	o := orm.NewOrm()
	sql := ` SELECT
			u.*,
			c.company_name,
			GROUP_CONCAT( DISTINCT p.seller_name SEPARATOR '/' ) AS seller_name 
		FROM
			wx_user AS u
			INNER JOIN company AS c ON c.company_id = u.company_id
			LEFT JOIN company_product AS p ON p.company_id = u.company_id 
		WHERE
			user_id = ?`
	err = o.Raw(sql, uid).QueryRow(&item)
	return
}

func GetUserAndCompanyNameListByUids(uids string) (items []*UserAndCompanyName, err error) {
	o := orm.NewOrm()
	sql := ` SELECT u.*,c.company_name FROM wx_user AS u
	INNER JOIN company AS c ON c.company_id = u.company_id
	WHERE user_id IN (` + uids + `)`
	_, err = o.Raw(sql).QueryRows(&items)
	return
}

// 新增预约人数
func AddCygxActivitySignup(items []*CygxActivitySignup, itemsAppointment []*CygxActivityAppointment, mapYidongActivity map[int]int) (err error) {
	o := orm.NewOrm()
	to, err := o.Begin()
	if err != nil {
		return
	}
	defer func() {
		if err != nil {
			_ = to.Rollback()
		} else {
			_ = to.Commit()
		}
	}()
	//添加预约纪要部分
	if len(itemsAppointment) > 0 {
		for _, item := range itemsAppointment {
			var count int
			sql := `SELECT COUNT(1) AS count FROM cygx_activity_appointment WHERE user_id=? AND activity_id=? `
			err = to.Raw(sql, item.UserId, item.ActivityId).QueryRow(&count)
			if err != nil {
				return
			}
			if count == 0 {
				_, err = to.Insert(item)
				if err != nil {
					return
				}
			}
		}
	}
	//添加会议提醒
	for _, item := range items {
		var count int
		sql := `SELECT COUNT(1) AS count FROM cygx_my_schedule WHERE user_id=? AND activity_id=? `
		err = to.Raw(sql, item.UserId, item.ActivityId).QueryRow(&count)
		if err != nil {
			return
		}
		//如果是易懂的活动就不加入日程
		if count == 0 && mapYidongActivity[item.ActivityId] == 0 {
			itemMy := new(CygxMySchedule)
			itemMy.UserId = item.UserId
			itemMy.ActivityId = item.ActivityId
			itemMy.CreateTime = time.Now()
			itemMy.Mobile = item.Mobile
			itemMy.Email = item.Email
			itemMy.CompanyId = item.CompanyId
			itemMy.CompanyName = item.CompanyName
			_, err = to.Insert(itemMy)
			if err != nil {
				return
			}
		}
		sql = `SELECT COUNT(1) AS count FROM cygx_activity_signup WHERE user_id=? AND activity_id=? `
		err = to.Raw(sql, item.UserId, item.ActivityId).QueryRow(&count)
		if err != nil {
			return
		}
		if count == 0 {
			_, err = to.Insert(item)
		} else {
			sql := `UPDATE cygx_activity_signup SET  is_cancel=0, do_fail_type = 0 ,create_time = NOW() WHERE user_id=? AND activity_id=? `
			_, err = to.Raw(sql, item.UserId, item.ActivityId).Exec()
		}
	}
	return
}

func AddCygxActivitySignup2(item *CygxActivitySignup) (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()
		}
	}()
	var count int
	sql := `SELECT COUNT(1) AS count FROM cygx_my_schedule WHERE user_id=? AND activity_id=? `
	err = to.Raw(sql, item.UserId, item.ActivityId).QueryRow(&count)
	if err != nil {
		return
	}
	if count == 0 {
		itemMy := new(CygxMySchedule)
		itemMy.UserId = item.UserId
		itemMy.ActivityId = item.ActivityId
		itemMy.CreateTime = time.Now()
		itemMy.Mobile = item.Mobile
		itemMy.Email = item.Email
		itemMy.CompanyId = item.CompanyId
		itemMy.CompanyName = item.CompanyName
		_, err = to.Insert(itemMy)
		if err != nil {
			return
		}
	}
	sql = `SELECT COUNT(1) AS count FROM cygx_activity_signup WHERE user_id=? AND activity_id=? `
	err = to.Raw(sql, item.UserId, item.ActivityId).QueryRow(&count)
	if err != nil {
		return
	}
	if count == 0 {
		_, err = to.Insert(item)
	} else {
		sql := `UPDATE cygx_activity_signup SET  is_cancel=0, do_fail_type = 0 ,create_time = NOW() WHERE user_id=? AND activity_id=? `
		_, err = to.Raw(sql, item.UserId, item.ActivityId).Exec()
	}
	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()
	err = o.Raw(sqlCount, uid, activityId).QueryRow(&count)
	return
}

func GetActivitySignupCountByActivityId(activityId int) (count int, err error) {
	sqlCount := `SELECT
					COUNT( 1 ) AS count 
				FROM
					cygx_activity_signup AS s
					INNER JOIN wx_user AS u ON u.user_id = s.user_id 
				WHERE
					s.do_fail_type = 0 
					AND s.company_id != 16 
					AND s.activity_id = ? `
	o := orm.NewOrm()
	err = o.Raw(sqlCount, activityId).QueryRow(&count)
	return
}

func GetActivitySignupCountByThisUser(activityId int, uids string) (count int, err error) {
	sqlCount := `SELECT COUNT(1) AS count FROM cygx_activity_signup WHERE do_fail_type = 0 AND activity_id=? AND user_id IN (` + uids + `) `
	o := orm.NewOrm()
	err = o.Raw(sqlCount, activityId).QueryRow(&count)
	return
}

//end

// 报名失败
type FailSignupListRep struct {
	Id               int    `orm:"column(id);pk;"description:"报名ID"`
	ActivityId       int    `description:"活动ID"`
	CreateTime       string `description:"创建时间"`
	Mobile           string `description:"手机号"`
	CompanyName      string `description:"公司名称"`
	CompanyId        int    `description:"公司ID"`
	RealName         string `description:"姓名"`
	UserId           int    `description:"用户id"`
	SellerName       string `description:"销售姓名"`
	PsellerName      string `description:"销售姓名"`
	FailType         int    `description:"失败原因，0，未失败，1总人数已满，2单机构超限制，3，爽约次数超限"`
	DoFailType       int    `description:"报名失败之后的操作，失败原因，0，未失败，1总人数已满，2单机构超限制，3，爽约次数超限"`
	SalonOperation   bool   `description:"操作按钮1，true,加入报名，false 限制报名"`
	CallOperation    int    `description:"操作按钮2，1预约外呼，2自主拨入，3限制报名"`
	IsAdminAddSignup int    `description:"（多余字段不使用）"`
	MeetingType      int    `description:"（多余字段不使用）"`
	IsMeeting        int    `description:"是否到会 ，1是， 0否"`
	SignupType       int    `description:"报名方式，1预约外呼，2自主拨入，3我要报名"`
}

type GetFailSignupListRep struct {
	ExcelType  string `description:"EXcel下载类型 AppointmentCall：预约外呼、ExpertSalon：专家沙龙报名、Teleconference：公司调研电话会、OfflineResearch：公司线下调研 "`
	MemberType string `description:"管理员身份 Admin：超级管理员、权益管理员、权益研究员、专家组;GroupLeader:组长；Sale:销售"`
	//ActivityId    int    `description:"活动ID"`
	Total         int  `description:"预约外呼总人数"`
	MyTotal       int  `description:"预约外呼本人名下客户"`
	IsLimitPeople int  `description:"是否限制人数 1是，0否"`
	IsFull        bool `description:"报名人数是否已满"`
	List          []*FailSignupListRep
}

func GetFailSignupList(activity_id int, sqlStr string) (item []*FailSignupListRep, err error) {
	o := orm.NewOrm()
	sql := `SELECT s.* ,a.is_limit_people
			FROM
			cygx_activity_signup AS s
			INNER 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
			LEFT JOIN company_product AS p ON p.company_id = u.company_id 
			WHERE a.activity_id = ?` + sqlStr + ` GROUP BY s.id  ORDER BY s.create_time DESC `
	_, err = o.Raw(sql, activity_id).QueryRows(&item)
	return
}

//end

type SignupId struct {
	Id int `orm:"column(id);pk;"description:"报名ID"`
}

type SignupIdCall struct {
	Id              int `description:"报名ID"`
	OperationStatus int `description:"操作方式：1预约外呼，2自主拨入，3限制报名"`
}

// 获取失败数量
func GetCygxSignupCountFile(id int) (count int, err error) {
	sqlCount := ` SELECT COUNT(1) AS count  FROM cygx_activity_signup  WHERE id= ?`
	o := orm.NewOrm()
	err = o.Raw(sqlCount, id).QueryRow(&count)
	return
}
func GetCygxSignupDetailById(id int) (item *FailSignupListRep, err error) {
	o := orm.NewOrm()
	sql := `SELECT * FROM cygx_activity_signup  WHERE id=?`
	err = o.Raw(sql, id).QueryRow(&item)
	return
}

func GetCygxSignupDetailByUid(id int) (item *FailSignupListRep, err error) {
	o := orm.NewOrm()
	sql := `SELECT * FROM cygx_activity_signup  WHERE user_id=? LIMIT 1`
	err = o.Raw(sql, id).QueryRow(&item)
	return
}

// 加入报名限制报名
func SalonSignupEdit(newIsAdminAddSignup, doFailType, id int, item *CygxActivitySignup) (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()
		}
	}()

	var count int
	sql := `SELECT COUNT(1) AS count FROM cygx_activity_meeting_reminder  WHERE user_id=?  AND activity_id=?  `
	err = to.Raw(sql, item.UserId, item.ActivityId).QueryRow(&count)
	if err != nil {
		return
	}
	sql = `UPDATE cygx_activity_signup SET is_admin_add_signup=?,do_fail_type=? WHERE id=? `
	_, err = to.Raw(sql, newIsAdminAddSignup, doFailType, id).Exec()
	if doFailType == 0 && count == 0 {
		//加入报名后并添加到我的日程
		itemMy := new(CygxMySchedule)
		itemMy.UserId = item.UserId
		itemMy.ActivityId = item.ActivityId
		itemMy.CreateTime = time.Now()
		itemMy.Mobile = item.Mobile
		itemMy.Email = item.Email
		itemMy.CompanyId = item.CompanyId
		itemMy.CompanyName = item.CompanyName
		_, err = to.Insert(itemMy)
		if err != nil {
			return
		}
	} else {
		//删除我的日程
		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
			}
		}
	}
	return
}

func CallSignupEditByStatus3(doFailType, id int, item *CygxMySchedule) (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()
		}
	}()
	sql := `UPDATE cygx_activity_signup SET is_admin_add_signup=0, do_fail_type = ?  WHERE id=? `
	_, err = to.Raw(sql, id, doFailType).Exec()
	if err != nil {
		return
	}
	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
	}
	return
}

func CallSignupEditByStatus1_2(operationStatus, id int, item *CygxMySchedule) (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()
		}
	}()
	var count int
	sql := `UPDATE cygx_activity_signup SET is_admin_add_signup = 1,do_fail_type=0, signup_type =?  WHERE id=? `
	_, err = to.Raw(sql, operationStatus, id).Exec()
	if err != nil {
		return
	}
	sql = `SELECT COUNT(1) AS count FROM cygx_my_schedule WHERE user_id=? AND activity_id=? `
	err = to.Raw(sql, item.UserId, item.ActivityId).QueryRow(&count)
	if err != nil {
		return
	}
	if count == 0 {
		//添加我的日程
		_, err = to.Insert(item)
	}

	return
}

//报名信息Excel下载

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

func GetSignupExport(activity_id int, sqlStr string) (item []*SignupExportRep, err error) {
	o := orm.NewOrm()
	sql := `SELECT s.*  ,a.is_limit_people,u.real_name,
			(SELECT p.seller_name from company_product as p WHERE p.company_id = u.company_id  AND  p.product_id = 2 )  AS seller_name
			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
			INNER JOIN company_product AS p ON p.company_id = u.company_id 
			WHERE a.activity_id = ?` + sqlStr
	_, err = o.Raw(sql, activity_id).QueryRows(&item)
	return
}

type CygxActivitySignupList struct {
	Id          int    `orm:"column(id);pk"`
	UserId      int    `description:"用户id"`
	ActivityId  int    `description:"活动ID"`
	CompanyName string `description:"公司名称"`
	RealName    string `description:"姓名"`
	CreateTime  string `description:"创建时间"`
	IsMeeting   int    `description:"是否到会 ，1是， 0否"`
	Operation   bool   `description:"操作按钮，true,到会，false 未到会"`
	Channel     int    `description:"报名渠道，0 空降、 1小程序报名"`
	SigninTime  string `description:"签到时间"`
	SellerName  string `description:"所属销售"`
	Mobile      string `description:"手机号"`
	Email       string `description:"邮箱"`
	CompanyId   int    `description:"公司id"`
	IsAirborne  int    `description:"是否属于空降  1.是 ，0否"`
}
type CygxActivitySignupListRep struct {
	ActivityId int `description:"活动ID"`
	List       []*CygxActivitySignupList
	ListSignin []*CygxActivitySignin
}

// 预约外呼列表
func GetCygxActivitySignup(condition string) (items []*CygxActivitySignupList, err error) {
	o := orm.NewOrm()
	sql := `SELECT s.* , u.real_name FROM cygx_activity_signup  as s 
	INNER JOIN wx_user as u ON u.user_id = s.user_id  WHERE 1 =1 ` + condition
	_, err = o.Raw(sql).QueryRows(&items)
	return
}

// 获取用户报名数量
func GetActivitySignupNomeetingCount(activityId int) (count int, err error) {
	sqlCount := `SELECT
	COUNT( 1 ) count 
FROM
	cygx_activity_signup AS s
	INNER JOIN cygx_activity AS a ON a.activity_id = s.activity_id 
WHERE
	1 = 1 
	AND a.is_limit_people > 0 
	AND s.is_meeting = 0 
	AND a.is_submit_meeting = 1
	AND a.activity_id = ?`
	o := orm.NewOrm()
	err = o.Raw(sqlCount, activityId).QueryRow(&count)
	return
}

// 获取用户报名列表
func GetActivitySignupNomeetingCountList(activityId int) (items []*CygxActivitySignupList, err error) {
	o := orm.NewOrm()
	sql := `SELECT
	s.*
FROM
	cygx_activity_signup AS s
	INNER JOIN cygx_activity AS a ON a.activity_id = s.activity_id 
WHERE
	1 = 1 
	AND s.do_fail_type = 0
	AND s.is_meeting = 0
	AND a.activity_id = ?`
	_, err = o.Raw(sql, activityId).QueryRows(&items)
	return
}

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

func GetUserMeetingMobile(activityId int) (items []*CygxActivitySignup, err error) {
	o := orm.NewOrm()
	sql := `SELECT *
FROM
	cygx_activity_signup AS s 
WHERE
	s.is_meeting = 1 
	AND s.activity_id = ?`
	_, err = o.Raw(sql, activityId).QueryRows(&items)
	return
}

// 修改外呼电话以及区号
type OutboundMobileEditResp struct {
	Id             int    `description:"报名ID"`
	OutboundMobile string `description:"外呼手机号"`
	CountryCode    string `description:"手机国家区号"`
}

func OutboundMobileEdit(id int, outboundMobile, countryCode string) (err error) {
	o := orm.NewOrm()
	sql := `UPDATE cygx_activity_signup SET outbound_mobile = ?,country_code=?  WHERE id=? `
	_, err = o.Raw(sql, outboundMobile, countryCode, id).Exec()
	return
}

//end

func AddCygxActivitySignupUser(items []*CygxActivitySignup) (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()
		}
	}()
	for _, item := range items {
		var count int
		sql := `SELECT COUNT(1) AS count FROM cygx_my_schedule WHERE user_id=? AND activity_id=? `
		err = to.Raw(sql, item.UserId, item.ActivityId).QueryRow(&count)
		if err != nil {
			return
		}
		if count == 0 {
			itemMy := new(CygxMySchedule)
			itemMy.UserId = item.UserId
			itemMy.ActivityId = item.ActivityId
			itemMy.CreateTime = time.Now()
			itemMy.Mobile = item.Mobile
			itemMy.Email = item.Email
			itemMy.CompanyId = item.CompanyId
			itemMy.CompanyName = item.CompanyName
			_, err = to.Insert(itemMy)
			if err != nil {
				return
			}
		}
		sql = `SELECT COUNT(1) AS count FROM cygx_activity_signup WHERE user_id=? AND activity_id=? `
		err = to.Raw(sql, item.UserId, item.ActivityId).QueryRow(&count)
		if err != nil {
			return
		}
		if count == 0 {
			_, err = to.Insert(item)
		} else {
			sql := `UPDATE cygx_activity_signup SET  is_cancel=0, do_fail_type = 0 ,create_time = NOW()  WHERE user_id=? AND activity_id=? `
			_, err = to.Raw(sql, item.UserId, item.ActivityId).Exec()
		}
	}
	return
}

// 通过ID获取报名详情
func GetActivitySignupInfoById(id int) (item *CygxActivitySignup, err error) {
	o := orm.NewOrm()
	sql := `SELECT * FROM cygx_activity_signup  WHERE id=?`
	err = o.Raw(sql, id).QueryRow(&item)
	return
}

type RequestCommonPolicyConfigrep struct {
	Type string `description:"报名方式 ，1 预约外呼 ，2 自主拨入"`
	Uid  int    `description:"用户ID"`
}

type RequestCommonPolicyConfig struct {
	CommonPolicyconfig  []interface{}                  `json:"common_policy_config"`
	CommonPolicyconfigs []RequestCommonPolicyConfigrep `json:"common_policy_configs"`
}

// 取消报名
func CancelActivitySignup(item *CygxActivitySignup) (lastId int64, 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()
		}
	}()
	//判断是否删除我的日程
	var count int
	sql := `SELECT COUNT(1) AS count FROM cygx_activity_meeting_reminder WHERE is_cancel = 0  AND  user_id=? AND activity_id=? `
	err = to.Raw(sql, item.UserId, item.ActivityId).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 = `DELETE  FROM cygx_activity_signup   WHERE user_id=?  AND activity_id=? `
	_, err = to.Raw(sql, item.UserId, item.ActivityId).Exec()
	if err != nil {
		return
	}
	return
}

func GetCompanyPermission(companyId int) (permission string, err error) {
	sql := ` SELECT GROUP_CONCAT(DISTINCT b.remark  ORDER BY b.sort ASC SEPARATOR ',') AS permission
			FROM company_report_permission AS a
			INNER JOIN chart_permission AS b ON a.chart_permission_id=b.chart_permission_id
			INNER JOIN company_product AS c ON a.company_id=c.company_id AND a.product_id=c.product_id
			WHERE  a.company_id=?
			AND c.is_suspend=0
            AND b.cygx_auth=1 
			AND c.status IN('正式','试用','永续')
			AND a.status IN('正式','试用','永续') `
	o := orm.NewOrm()
	err = o.Raw(sql, companyId).QueryRow(&permission)
	return
}

// 获取可查看升级权限的正式权限
func GetCompanyPermissionByUserZhengShiTrip(companyId int) (permission string, err error) {
	sql := ` SELECT GROUP_CONCAT(DISTINCT b.chart_permission_name  ORDER BY b.sort ASC  SEPARATOR ',') AS permission
			FROM company_report_permission AS a
			INNER JOIN chart_permission AS b ON a.chart_permission_id=b.chart_permission_id
			INNER JOIN company_product AS c ON a.company_id=c.company_id AND a.product_id=c.product_id
			WHERE  a.company_id=?
			AND c.is_suspend=0
            AND b.cygx_auth=1
			AND ( a.is_upgrade = 1 AND c.STATUS = '正式' OR c.STATUS = '永续' ) `
	o := orm.NewOrm()
	err = o.Raw(sql, companyId).QueryRow(&permission)
	return
}

func GetCountCompanyDetailByIdGroup(companyId int) (count int, err error) {
	sql := ` SELECT COUNT(1) AS count
            FROM company AS a
			INNER JOIN company_product AS b ON a.company_id=b.company_id
			INNER JOIN company_report_permission AS p ON p.company_id = a.company_id
			INNER JOIN chart_permission AS cp ON cp.chart_permission_id = p.chart_permission_id
			LEFT JOIN admin AS c ON b.seller_id=c.admin_id
			WHERE a.company_id=? AND b.product_id = 2    OR (a.company_id = ? AND  cp.permission_name = '策略' )   `
	o := orm.NewOrm()
	err = o.Raw(sql, companyId, companyId).QueryRow(&count)
	return
}

type CompanyDetail struct {
	CompanyId   int    `orm:"column(company_id);pk"`
	CompanyName string `description:"客户名称"`
	Status      string `description:"客户状态"`
	SellerId    int    `description:"销售id"`
	SellerName  string `description:"销售名称"`
	Mobile      string `description:"销售手机号"`
	ProductId   int    `description:"1,FICC,2权益"`
}

func GetCompanyDetailByIdGroup(companyId int) (item *CompanyDetail, err error) {
	sql := ` SELECT a.company_id,a.company_name,b.status,b.seller_id,b.seller_name,c.mobile
            FROM company AS a
			INNER JOIN company_product AS b ON a.company_id=b.company_id
			INNER JOIN company_report_permission AS p ON p.company_id = a.company_id
			INNER JOIN chart_permission AS cp ON cp.chart_permission_id = p.chart_permission_id
			LEFT JOIN admin AS c ON b.seller_id=c.admin_id
			WHERE a.company_id=? AND b.product_id = 2
			OR (a.company_id = ? AND  cp.permission_name = '策略' )
			ORDER BY b.product_id DESC  LIMIT 0,1 `
	o := orm.NewOrm()
	err = o.Raw(sql, companyId, companyId).QueryRow(&item)
	return
}

func GetCompanyPermissionByUser(companyId int) (permission string, err error) {
	sql := ` SELECT GROUP_CONCAT(DISTINCT b.remark  ORDER BY b.sort ASC  SEPARATOR ',') AS permission
			FROM company_report_permission AS a
			INNER JOIN chart_permission AS b ON a.chart_permission_id=b.chart_permission_id
			INNER JOIN company_product AS c ON a.company_id=c.company_id AND a.product_id=c.product_id
			WHERE  a.company_id=?
			AND c.is_suspend=0
            AND b.cygx_auth=1`
	o := orm.NewOrm()
	err = o.Raw(sql, companyId).QueryRow(&permission)
	return
}

// 获取正式权限
func GetCompanyPermissionByUserZhengShi(companyId int) (permission string, err error) {
	sql := ` SELECT GROUP_CONCAT(DISTINCT b.remark  ORDER BY b.sort ASC  SEPARATOR ',') AS permission
			FROM company_report_permission AS a
			INNER JOIN chart_permission AS b ON a.chart_permission_id=b.chart_permission_id
			INNER JOIN company_product AS c ON a.company_id=c.company_id AND a.product_id=c.product_id
			WHERE  a.company_id=?
			AND c.is_suspend=0
            AND b.cygx_auth=1
			AND c.status IN('正式')
			AND a.status IN('正式') `
	o := orm.NewOrm()
	err = o.Raw(sql, companyId).QueryRow(&permission)
	return
}

// 活动模板消息推送，权限处理start
// GetCompanyDetailByIdGroupList 根据公司ID获取公司对应状态
func GetCompanyDetailByIdGroupList(companyIds []int) (items []*CompanyDetail, err error) {
	lenCompanyId := len(companyIds)
	if lenCompanyId == 0 {
		return
	}
	sql := ` SELECT a.company_id,a.company_name,b.status
            FROM company AS a
			INNER JOIN company_product AS b ON a.company_id=b.company_id
			WHERE a.company_id IN (` + utils.GetOrmInReplace(lenCompanyId) + `)  AND b.product_id = 2
			GROUP BY a.company_id  `
	o := orm.NewOrm()
	_, err = o.Raw(sql, companyIds).QueryRows(&items)
	return
}

type CompanyPermission struct {
	CompanyId      int    `description:"公司ID"`
	PermissionName string `description:"权限名称"`
}

// 公司权限结构体
type CompanyPermissionPower struct {
	CompanyId              int    `description:"公司ID"`
	UserType               int    `description:"用户类型   //1、永续客户 //2、大套餐客户（4个行业全开通的正式客户） //3、分行业套餐客户（开通对应行业的正式客户） //4、仅开通专家套餐的正式客户 //5、开通对应行业套餐或专家套餐的试用客户"`
	Status                 string `description:"客户状态"`
	PermissionName         string `description:"权限名称"`
	PermissionNameZhengShi string `description:"权限名称（正式）"`
	HavePower              bool   `description:"是否有权限"`
}

// GetCompanyPermissionByCompanyIds 根据公司ID获取公司对应的权限
func GetCompanyPermissionByCompanyIds(companyIds []int) (items []*CompanyPermission, err error) {
	lenCompanyId := len(companyIds)
	if lenCompanyId == 0 {
		return
	}
	sql := ` SELECT
			GROUP_CONCAT( DISTINCT b.remark ORDER BY b.sort ASC SEPARATOR ',' ) AS permission_name,
			a.company_id 
		FROM
			company_report_permission AS a
			INNER JOIN chart_permission AS b ON a.chart_permission_id = b.chart_permission_id
			INNER JOIN company_product AS c ON a.company_id = c.company_id 
			AND a.product_id = c.product_id 
		WHERE
			a.company_id IN  (` + utils.GetOrmInReplace(lenCompanyId) + `)
			AND c.is_suspend = 0 
			AND b.cygx_auth = 1
		GROUP BY
			a.company_id `
	o := orm.NewOrm()
	_, err = o.Raw(sql, companyIds).QueryRows(&items)
	return
}

// GetCompanyPermissionZhenShiByCompanyIds 根据公司ID获取正式公司对应的权限
func GetCompanyPermissionZhenShiByCompanyIds(companyIds []int) (items []*CompanyPermission, err error) {
	lenCompanyId := len(companyIds)
	if lenCompanyId == 0 {
		return
	}
	sql := ` SELECT
			GROUP_CONCAT( DISTINCT b.remark ORDER BY b.sort ASC SEPARATOR ',' ) AS permission_name,
			a.company_id 
		FROM
			company_report_permission AS a
			INNER JOIN chart_permission AS b ON a.chart_permission_id = b.chart_permission_id
			INNER JOIN company_product AS c ON a.company_id = c.company_id 
			AND a.product_id = c.product_id 
		WHERE
			a.company_id IN  (` + utils.GetOrmInReplace(lenCompanyId) + `)
			AND c.is_suspend = 0 
			AND b.cygx_auth = 1 
			AND c.STATUS IN ( '正式' ) 
			AND a.STATUS IN ( '正式' ) 
		GROUP BY
			a.company_id `
	o := orm.NewOrm()
	_, err = o.Raw(sql, companyIds).QueryRows(&items)
	return
}

type YidongActivitySignup struct {
	YidongActivityId string `description:"易董的活动ID"`
	Mobile           string `description:"手机号"`
	RealName         string `description:"用户实际名称"`
	CompanyName      string `description:"公司名称"`
	CountryCode      string `description:"手机国家区号"`
	ActivityJoinType string `description:"活动入会类型01报名审核后可入会 02预约即可入会 03仅定向邀请人员可入会"`
}

// GetCompanyByUserSignUp 获取客户ID列表
func GetCompanyByUserSignUp(condition string, pars []interface{}) (items []*company.CompanyNameAndId, err error) {
	sql := `SELECT
	s.company_id
FROM
	cygx_activity_signup AS s
	INNER JOIN cygx_activity AS a ON a.activity_id = s.activity_id
	INNER JOIN wx_user AS u ON u.mobile = s.mobile 
	INNER JOIN cygx_activity_type AS t ON t.activity_type_id = a.activity_type_id 
WHERE
	1 = 1 
	AND s.is_meeting = 1 
	AND t.activity_type = 1 `
	if condition != `` {
		sql += condition
	}
	sql += ` GROUP BY s.company_id `
	_, err = orm.NewOrm().Raw(sql, pars).QueryRows(&items)
	return
}

type UserSignUpLossResp struct {
	Mobile       string `description:"手机号"`
	RealName     string `description:"姓名"`
	TotalMeeting int    `description:"参会次数"`
}

type UserSignUpLossListResp struct {
	CompanyId   int    `description:"公司Id"`
	CompanyName string `description:"公司名称"`
	SellerName  string `description:"销售名称"`
	List        []*UserSignUpLossResp
}

// GetUserSignUpList 获取用户报名列表
func GetUserSignUpList(condition string, pars []interface{}) (items []*UserSignUpLossResp, err error) {
	sql := `SELECT
	s.real_name,
	s.mobile 
FROM
	cygx_activity_signup_detail AS s
	INNER JOIN cygx_activity AS a ON a.activity_id = s.activity_id
	INNER JOIN cygx_activity_type AS t ON t.activity_type_id = a.activity_type_id 
	INNER JOIN wx_user AS u ON u.mobile = s.mobile
WHERE
	1 = 1 
	AND s.is_meeting = 1 
	AND t.activity_type = 1  `
	if condition != `` {
		sql += condition
	}
	_, err = orm.NewOrm().Raw(sql, pars).QueryRows(&items)
	return
}

type UserSignUpMeetLossListResp struct {
	Mobile   string              `description:"手机号"`
	RealName string              `description:"姓名"`
	List     []*AttendanceDetail `description:"预约客户"`
}

type ActivitySignupTempMsgReq struct {
	ActivityIds  string `description:"活动id，用,隔开"`
	SendGroup    string `description:"发送对象，1全部 2永续 3大套餐 4行业套餐 5其他行业正式 6试用 7已参与互动 用,隔开"`
	FirstText    string `description:"首段提示文字"`
	ActivityName string `description:"活动名称"`
	Content      string `description:"变更内容"`
}

type SendGroup struct {
	Id   int
	Name string
}

type SendGroupStr struct {
	Id   string
	Name string
}

type PermissionList struct {
	CompanyId  int
	Permission string
}

// 获取正式权限
func GetCompanyPermissionByUsersZhengShi(companyIds string) (items []*PermissionList, err error) {
	sql := ` SELECT a.company_id, b.remark  AS permission
			FROM company_report_permission AS a
			INNER JOIN chart_permission AS b ON a.chart_permission_id=b.chart_permission_id
			INNER JOIN company_product AS c ON a.company_id=c.company_id AND a.product_id=c.product_id
			WHERE  a.company_id IN (` + companyIds + `)
			AND c.is_suspend=0
            AND b.cygx_auth=1
			AND c.status IN('正式')
			AND a.status IN('正式') `
	o := orm.NewOrm()
	_, err = o.Raw(sql).QueryRows(&items)
	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 do_fail_type = 0 AND activity_id=? AND company_id=? `
	o := orm.NewOrm()
	err = o.Raw(sqlCount, activityId, companyId).QueryRow(&count)
	return
}

func GetCompanyPermissionByUserTrip(companyId int) (permission string, err error) {
	o := orm.NewOrm()
	sql := ` SELECT
			GROUP_CONCAT( DISTINCT b.remark ORDER BY b.sort ASC SEPARATOR ',' ) AS permission 
		FROM
			company_report_permission AS a
			INNER JOIN chart_permission AS b ON a.chart_permission_id = b.chart_permission_id
			INNER JOIN company_product AS c ON a.company_id = c.company_id 
			AND a.product_id = c.product_id 
		WHERE
			a.company_id = ? 
			AND c.is_suspend = 0 
			AND b.cygx_auth = 1 
			AND a.is_upgrade = 1 
			AND c.STATUS IN ( '正式' ) 
			OR ( a.company_id = ? AND c.is_suspend = 0 AND b.cygx_auth = 1 AND c.STATUS IN ( '永续' ) ) 
			OR ( a.company_id = ? AND c.is_suspend = 0 AND b.cygx_auth = 1 AND b.chart_permission_name = '策略' AND c.STATUS IN ( '正式' ) )`
	err = o.Raw(sql, companyId, companyId, companyId).QueryRow(&permission)
	return
}

// GetCygxCygxActivitySignupList 获取报名列表信息
func GetActivitySignupList(condition string, pars []interface{}) (items []*CygxActivitySignup, err error) {
	sql := `SELECT
			*
		FROM
			cygx_activity_signup AS v
		WHERE
			1 = 1 	` + condition
	o := orm.NewOrm()
	_, err = o.Raw(sql, pars).QueryRows(&items)
	return
}

// GetCygxCygxActivitySignupList 获取报名列表信息
func GetActivitySignupInnerActivityList(condition string, pars []interface{}) (items []*CygxActivitySignup, err error) {
	sql := `SELECT
			*
		FROM
			cygx_activity_signup AS v 
			INNER JOIN cygx_activity as a ON v.activity_id = a.activity_id
		WHERE
			1 = 1 	` + condition
	o := orm.NewOrm()
	_, err = o.Raw(sql, pars).QueryRows(&items)
	return
}