hz_crm_api/models/cygx/activity_help_ask.go

package cygx

import (
	"github.com/beego/beego/v2/client/orm"
	"hongze/hz_crm_api/utils"
)

type ActivityHelpAsk struct {
	AskId       int    `orm:"column(ask_id);主键ID"`
	ActivityId  int    `description:"活动ID"`
	UserId      int    `description:"用户ID"`
	CreateTime  string `description:"创建时间"`
	Mobile      string `description:"手机号"`
	CompanyName string `description:"公司名称"`
	RealName    string `description:"姓名"`
	Content     string `description:"内容"`
}

type ActivityHelpAskListResp struct {
	List []*ActivityHelpAsk
}

// 列表
func GetActivityHelpAskList(activityId int) (items []*ActivityHelpAsk, err error) {
	o := orm.NewOrm()
	sql := `SELECT k.*,u.real_name
			FROM cygx_activity_help_ask  as k
			INNER JOIN wx_user as u ON u.mobile = k.mobile
			WHERE activity_id = ? ORDER BY create_time DESC`
	_, err = o.Raw(sql, activityId).QueryRows(&items)
	return
}

// 获取活动带问的用户的openID
func GetActivityHelpAskOpenIdList(activityId int) (items []*OpenIdList, err error) {
	var sql string
	if utils.RunMode == "release" {
		sql = `SELECT DISTINCT cr.open_id,u.user_id
			FROM
			cygx_activity_help_ask AS m
			INNER JOIN user_record AS u ON u.bind_account = m.mobile 
			INNER JOIN cygx_user_record AS cr ON cr.union_id = u.union_id 
			WHERE m.activity_id = ? AND u.create_platform = 4 `
	} else {
		sql = `SELECT
			u.open_id,
			u.user_id 
		FROM
			cygx_activity_help_ask AS s
			INNER JOIN wx_user AS wx ON wx.user_id = s.user_id
			INNER JOIN user_record AS u ON u.bind_account = wx.mobile
			INNER JOIN company_product AS p ON p.company_id = wx.company_id 
		WHERE
			s.activity_id = ? 
			AND u.create_platform = 1 
			AND p.STATUS IN ( '正式', '试用', '永续' ) 
		GROUP BY
			u.open_id`
	}
	_, err = orm.NewOrm().Raw(sql, activityId).QueryRows(&items)
	return
}