hongze_open_api/models/tables/wx_user/wx_user.go

package wx_user

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

type WxUser struct {
	UserId              int64 `orm:"column(user_id);pk"`
	Mobile              string
	Email               string
	CompanyId           int
	RealName            string `description:"姓名"`
	CreatedTime         time.Time
	MobileTwo           string `description:"备用手机号"`
	BusinessCardUrl     string `description:"名片"`
	IsMaker             int    `description:"是否决策人，1:是，0:否"`
	Position            string `description:"职位"`
	Sex                 int    `description:"普通用户性别，1为男性，2为女性"`
	DepartmentName      string `description:"联系人部门"`
	RegisterTime        time.Time
	RegisterPlatform    int
	Enabled             int8   `description:"用户状态"`
	FirstLogin          int    `description:"是否第一次登陆"`
	CountryCode         string `description:"区号，86、852、886等"`
	OutboundMobile      string `description:"外呼手机号"`
	OutboundCountryCode string `description:"外呼手机号区号，86、852、886等"`
}

type OpenIdList struct {
	OpenId string
}

// 添加日志记录
func AddWxUser(item *WxUser) (lastId int64, err error) {
	o := orm.NewOrm()
	lastId, err = o.Insert(item)
	return
}

// 获取所有的用户openid列表
func GetOpenIdList(openIdStr string) (items []*OpenIdList, err error) {
	sql := `SELECT DISTINCT ur.open_id FROM wx_user AS wu 
          INNER JOIN company AS c ON c.company_id = wu.company_id 
          INNER JOIN company_product AS d ON c.company_id=d.company_id
		INNER join user_record  as ur on wu.user_id=ur.user_id
          WHERE ur.open_id != "" and ur.create_platform=1 AND  d.status IN('正式','试用','永续') `
	if openIdStr != "" {
		sql += ` AND ur.open_id in (` + openIdStr + `) `
	}
	_, err = orm.NewOrm().Raw(sql).QueryRows(&items)
	return
}

// 根据手机号获取用户的openid列表
func GetOpenIdListByMobile(mobile, openIdStr string) (items []*OpenIdList, err error) {
	sql := `SELECT DISTINCT ur.open_id FROM wx_user AS wu 
          INNER JOIN company AS c ON c.company_id = wu.company_id 
          INNER join user_record  as ur on wu.user_id=ur.user_id
          WHERE ur.open_id != "" and ur.create_platform=1 AND wu.mobile=? `
	if openIdStr != "" {
		sql += ` AND ur.open_id in (` + openIdStr + `) `
	}
	_, err = orm.NewOrm().Raw(sql, mobile).QueryRows(&items)
	return
}

type WxUserItem struct {
	UserId      int
	RealName    string
	Mobile      string
	Email       string
	CompanyName string
}

// GetWxUserByMobile 根据手机号获取用户信息
func GetWxUserByMobile(mobile string) (item *WxUserItem, err error) {
	sql := `SELECT a.user_id,a.real_name,a.mobile,b.company_name FROM wx_user AS a 
          INNER JOIN company AS b ON a.company_id = b.company_id 
          WHERE a.mobile=? `
	err = orm.NewOrm().Raw(sql, mobile).QueryRow(&item)
	return
}

// GetWxUserByEmail 根据邮箱获取用户信息
func GetWxUserByEmail(email string) (item *WxUserItem, err error) {
	sql := `SELECT a.user_id,a.real_name,a.mobile,b.company_name FROM wx_user AS a 
          INNER JOIN company AS b ON a.company_id = b.company_id 
          WHERE a.email=? `
	err = orm.NewOrm().Raw(sql, email).QueryRow(&item)
	return
}

// GetWxUserByMobile 根据手机号获取用户信息
func GetWxUserByMobileStr(mobile string) (item *WxUserItem, err error) {
	sql := `SELECT a.user_id,a.real_name,a.mobile,b.company_name FROM wx_user AS a 
          INNER JOIN company AS b ON a.company_id = b.company_id 
          WHERE a.mobile IN (` + mobile + `) LIMIT 1 `
	err = orm.NewOrm().Raw(sql).QueryRow(&item)
	return
}

// GetWxUserByMobileCountryCode 根据手机号和区号获取用户信息
func GetWxUserByMobileCountryCode(mobile, countryCode string) (item *WxUser, err error) {
	o := orm.NewOrm()
	sql := `SELECT * FROM wx_user WHERE mobile = ? `
	sql += ` and country_code in ("","` + countryCode + `") `
	sql += ` LIMIT 1 `
	err = o.Raw(sql, mobile).QueryRow(&item)
	return
}

// GetByUserId 根据user_id获取用户信息
func GetByUserId(userId int) (wxUser *WxUser, err error) {
	o := orm.NewOrm()
	sql := `SELECT * FROM wx_user WHERE user_id = ? LIMIT 1 `
	err = o.Raw(sql, userId).QueryRow(&wxUser)
	return
}

// GetByUserMobile 根据mobile获取用户信息
func GetByUserMobile(mobile string) (wxUser *WxUser, err error) {
	o := orm.NewOrm()
	sql := `SELECT * FROM wx_user WHERE mobile = ? LIMIT 1 `
	err = o.Raw(sql, mobile).QueryRow(&wxUser)
	return
}

// GetWxUserCountByMobile 查询系统中是否存在该手机号
func GetWxUserCountByMobile(mobile string) (count int, err error) {
	sql := `SELECT COUNT(1) AS count FROM wx_user WHERE mobile=? `
	o := orm.NewOrm()
	err = o.Raw(sql, mobile).QueryRow(&count)
	return
}