hongze_cygx/models/wx_user_code.go

package models

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

type WxUserCode struct {
	Id             int `orm:"column(id);pk"`
	WxCode         string
	UserId         int
	Code           int
	FirstLogin     int
	Authorization  string
	UserPermission int
	CreateTime     time.Time
}

//添加联系人日志信息
func AddWxUserCode(item *WxUserCode) (lastId int64, err error) {
	o := orm.NewOrm()
	lastId, err = o.Insert(item)
	return
}

func GetWxUserCode(wxCode string) (item *WxUserCode, err error) {
	o := orm.NewOrm()
	sql := `SELECT * FROM wx_user_code WHERE wx_code=? `
	err = o.Raw(sql, wxCode).QueryRow(&item)
	return
}

//获取所有有权限的用户的opid
func GetCygxUserRecordPower(condition string, pars []interface{}) (items []*OpenIdList, err error) {
	o := orm.NewOrm()
	sql := `SELECT
			cr.open_id,
			u.user_id,
			u.company_id,
			u.real_name,
			u.mobile 
		FROM
			company_report_permission AS p
			INNER JOIN wx_user AS u ON u.company_id = p.company_id
			INNER JOIN user_record AS r ON r.user_id = u.user_id
			INNER JOIN cygx_user_record AS cr ON cr.union_id = r.union_id 
		WHERE
			 r.create_platform = 4 ` + condition + ` AND p.STATUS IN ('正式','试用','永续')  GROUP BY cr.open_id`
	_, err = o.Raw(sql, pars).QueryRows(&items)
	return
}

//获取关注这个文章对应产业的用户的 openid
func GetCygxUserFllowOpenid(articleId int) (items []*OpenIdList, err error) {
	o := orm.NewOrm()
	sql := `SELECT
			cr.open_id,
			f.user_id 
		FROM
			cygx_xzs_choose_send AS s
			INNER JOIN cygx_industry_fllow AS f ON f.user_id = s.user_id
			INNER JOIN user_record AS r ON r.user_id = f.user_id
			INNER JOIN cygx_user_record AS cr ON cr.union_id = r.union_id 
			INNER JOIN cygx_industrial_article_group_management as mg  ON mg.industrial_management_id = f.industrial_management_id
		WHERE
			r.create_platform = 4 
			AND mg.article_id  = ?`
	_, err = o.Raw(sql, articleId).QueryRows(&items)
	return
}

//获取拒绝接收推送的的用户的 openid
func GetCygxUserRefusetOpenid() (items []*OpenIdList, err error) {
	o := orm.NewOrm()
	sql := `SELECT
			cr.open_id,
			s.user_id
			FROM
			cygx_xzs_choose_send AS s
			INNER JOIN user_record AS r ON r.user_id = s.user_id
			INNER JOIN cygx_user_record AS cr ON cr.union_id = r.union_id
			WHERE
			r.create_platform = 4
			AND s.is_refuse = 1`
	_, err = o.Raw(sql).QueryRows(&items)
	return
}

//获取选择策略推送的用户的openid openid
func GetCygxUserFllowCeLueOpenid(categoryId int) (items []*OpenIdList, err error) {
	o := orm.NewOrm()
	sql := `SELECT
			cr.open_id,
			f.user_id 
		FROM
			cygx_xzs_choose_send AS s
			INNER JOIN cygx_xzs_choose_category AS f ON f.user_id = s.user_id
			INNER JOIN user_record AS r ON r.user_id = f.user_id
			INNER JOIN cygx_user_record AS cr ON cr.union_id = r.union_id 
		WHERE
			r.create_platform = 4
			AND s.is_refuse = 0
			AND (s.is_subjective = 1 OR s.is_objective = 1)
			AND f.category_id = ?`
	_, err = o.Raw(sql, categoryId).QueryRows(&items)
	return
}

//获取提交过推送规则用户的userId
func GetCygxXzsChooseSendOpenIdByUserIds(idStr string) (items []*OpenIdList, err error) {
	o := orm.NewOrm()
	sql := `SELECT ur.user_id, cr.open_id FROM user_record AS ur
INNER JOIN cygx_user_record AS cr
WHERE ur.user_id IN (` + idStr + `) AND create_platform=4 AND ur.union_id=cr.union_id `
	_, err = o.Raw(sql).QueryRows(&items)
	return
}