package models import ( "github.com/beego/beego/v2/client/orm" "time" ) type WxUser struct { UserId int `orm:"column(user_id);pk"` OpenId string `description:"open_id"` UnionId string `description:"union_id"` Subscribe string `description:"是否关注"` CompanyId int `description:"客户id"` NickName string `description:"用户昵称"` RealName string `description:"用户实际名称"` UserCode string `description:"用户编码"` Mobile string `description:"手机号码"` BindAccount string `description:"绑定时的账号"` WxCode string `description:"微信号"` Profession string `description:"职业"` Email string `description:"邮箱"` Telephone string `description:"座机"` Sex int `description:"普通用户性别,1为男性,2为女性"` Province string `description:"普通用户个人资料填写的省份"` City string `description:"普通用户个人资料填写的城市"` Country string `description:"国家,如中国为CN"` SubscribeTime int `description:"关注时间"` Remark string `description:"备注"` Headimgurl string `description:"用户头像,最后一个数值代表正方形头像大小(有0、46、64、96、132数值可选,0代表640*640正方形头像),用户没有头像时该项为空"` Privilege string `description:"用户特权信息,json数组,如微信沃卡用户为(chinaunicom)"` Unionid string `description:"用户统一标识。针对一个微信开放平台帐号下的应用,同一用户的unionid是唯一的。"` FirstLogin int `description:"是否第一次登陆"` Enabled int `description:"是否可用"` CreatedTime time.Time `description:"创建时间"` LastUpdatedTime time.Time `description:"最新一次修改时间"` Seller string `description:"销售员"` Note string `description:"客户备份信息"` IsNote int `description:"是否备注过信息"` FromType string `description:"report' COMMENT 'report:研报,teleconference:电话会"` ApplyMethod int `description:"0:未申请,1:已付费客户申请试用,2:非客户申请试用"` RegisterTime time.Time `description:"注册时间"` RegisterPlatform int `description:"注册平台,1:微信端,2:PC网页端"` IsFreeLogin bool `description:"是否免登陆,true:免登陆,false:非免登陆"` LoginTime time.Time `description:"最近一次登录时间"` SessionKey string `description:"微信小程序会话密钥"` IsRegister int `description:"是否注册:1:已注册,0:未注册"` Source int `description:"绑定来源,1:微信端,2:pc网页端,3:查研观向小程序,4:每日咨询"` CountryCode string `description:"区号"` OutboundMobile string `description:"外呼手机号"` OutboundCountryCode string `description:"外呼手机号区号"` } type WxUserItem struct { UserId int `description:"用户id"` OpenId string `description:"open_id"` UnionId string `description:"union_id"` CompanyId int `description:"客户id"` NickName string `description:"用户昵称"` RealName string `description:"用户实际名称"` Mobile string `description:"手机号码"` BindAccount string `description:"绑定时的账号"` Email string `description:"邮箱"` Headimgurl string `description:"用户头像,最后一个数值代表正方形头像大小(有0、46、64、96、132数值可选,0代表640*640正方形头像),用户没有头像时该项为空"` HeadimgurlRecord string `description:"用户头像,最后一个数值代表正方形头像大小(有0、46、64、96、132数值可选,0代表640*640正方形头像),用户没有头像时该项为空"` ApplyMethod int `description:"0:未申请,1:已付费客户申请试用,2:非客户申请试用"` FirstLogin int `description:"是否第一次登陆"` IsFreeLogin int `description:"是否免登陆,true:免登陆,false:非免登陆"` LoginTime time.Time `description:"登录时间"` CreatedTime time.Time `description:"创建时间"` LastUpdatedTime time.Time `description:"最近一次修改时间"` SessionKey string `description:"微信小程序会话密钥"` CompanyName string `description:"公司名称"` IsRegister int `description:"是否注册:1:已注册,0:未注册"` CountryCode string `description:"手机国家区号"` OutboundMobile string `description:"外呼手机号"` OutboundCountryCode string `description:"外呼手机号区号"` IsMsgOutboundMobile int `description:"是否弹窗过绑定外呼手机号区号"` Source int } type WxLoginResp struct { Authorization string UserId int FirstLogin int Headimgurl string `description:"用户头像"` Mobile string `description:"手机号"` Email string `description:"邮箱"` CompanyName string `description:"客户名称"` Status string `description:"状态"` EndDate string `description:"到期日期"` ProductName string `description:"客户类型名称"` } type WxGetUserInfoReq struct { RawData string `description:"rawData"` Signature string `description:"signature"` EncryptedData string `description:"encryptedData"` Iv string `description:"iv"` } func GetWxUserItemByUserUnionId(unionId string) (item *WxUserItem, err error) { o := orm.NewOrmUsingDB("weekly_report") sql := `SELECT a.*,r.headimgurl as headimgurl_record, b.company_name FROM wx_user AS a INNER JOIN company AS b on a.company_id=b.company_id INNER JOIN user_record as r ON r.user_id = a.user_id WHERE r.union_id=? GROUP BY a.user_id` err = o.Raw(sql, unionId).QueryRow(&item) return } // 根据用户手机号获取相关信息 func GetWxUserItemByUserMobile(mobile string) (item *WxUserItem, err error) { o := orm.NewOrmUsingDB("weekly_report") sql := `SELECT a.user_id, a.real_name, a.headimgurl, a.company_id, a.mobile, a.email, b.company_name FROM wx_user AS a INNER JOIN company AS b ON a.company_id = b.company_id WHERE a.mobile = ? GROUP BY a.mobile ` err = o.Raw(sql, mobile).QueryRow(&item) return } // 获取这个公司下面所有用户的手机号 func SetUserSubscribeByMobile(mobile string) (err error) { o := orm.NewOrmUsingDB("weekly_report") sql := ` UPDATE wx_user SET cygx_subscribe=1,cygx_subscribe_time=NOW() WHERE mobile=? ` _, err = o.Raw(sql, mobile).Exec() return } // 根据用户ID获取相关信息 func GetWxUserItemByUserId(userId int) (item *WxUserItem, err error) { o := orm.NewOrmUsingDB("weekly_report") sql := `SELECT a.*,b.company_name FROM wx_user AS a LEFT JOIN company AS b on a.company_id=b.company_id WHERE a.user_id=? ` err = o.Raw(sql, userId).QueryRow(&item) return }