wx_user.go 8.8 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206
  1. package models
  2. import (
  3. "rdluck_tools/orm"
  4. "time"
  5. )
  6. type WxUser struct {
  7. UserId int `orm:"column(user_id);pk"`
  8. OpenId string `description:"open_id"`
  9. UnionId string `description:"union_id"`
  10. Subscribe string `description:"是否关注"`
  11. CompanyId int `description:"客户id"`
  12. NickName string `description:"用户昵称"`
  13. RealName string `description:"用户实际名称"`
  14. UserCode string `description:"用户编码"`
  15. Mobile string `description:"手机号码"`
  16. BindAccount string `description:"绑定时的账号"`
  17. WxCode string `description:"微信号"`
  18. Profession string `description:"职业"`
  19. Email string `description:"邮箱"`
  20. Telephone string `description:"座机"`
  21. Sex int `description:"普通用户性别,1为男性,2为女性"`
  22. Province string `description:"普通用户个人资料填写的省份"`
  23. City string `description:"普通用户个人资料填写的城市"`
  24. Country string `description:"国家,如中国为CN"`
  25. SubscribeTime int `description:"关注时间"`
  26. Remark string `description:"备注"`
  27. Headimgurl string `description:"用户头像,最后一个数值代表正方形头像大小(有0、46、64、96、132数值可选,0代表640*640正方形头像),用户没有头像时该项为空"`
  28. Privilege string `description:"用户特权信息,json数组,如微信沃卡用户为(chinaunicom)"`
  29. Unionid string `description:"用户统一标识。针对一个微信开放平台帐号下的应用,同一用户的unionid是唯一的。"`
  30. FirstLogin int `description:"是否第一次登陆"`
  31. Enabled int `description:"是否可用"`
  32. CreatedTime time.Time `description:"创建时间"`
  33. LastUpdatedTime time.Time `description:"最新一次修改时间"`
  34. Seller string `description:"销售员"`
  35. Note string `description:"客户备份信息"`
  36. IsNote int `description:"是否备注过信息"`
  37. FromType string `description:"report' COMMENT 'report:研报,teleconference:电话会"`
  38. ApplyMethod int `description:"0:未申请,1:已付费客户申请试用,2:非客户申请试用"`
  39. RegisterTime time.Time `description:"注册时间"`
  40. RegisterPlatform int `description:"注册平台,1:微信端,2:PC网页端"`
  41. IsFreeLogin bool `description:"是否免登陆,true:免登陆,false:非免登陆"`
  42. LoginTime time.Time `description:"最近一次登录时间"`
  43. SessionKey string `description:"微信小程序会话密钥"`
  44. IsRegister int `description:"是否注册:1:已注册,0:未注册"`
  45. Source int `description:"绑定来源,1:微信端,2:pc网页端,3:查研观向小程序,4:每日咨询"`
  46. }
  47. //添加用户信息
  48. func AddWxUser(item *WxUser) (lastId int64, err error) {
  49. o := orm.NewOrm()
  50. lastId, err = o.Insert(item)
  51. return
  52. }
  53. type WxUserItem struct {
  54. UserId int `description:"用户id"`
  55. OpenId string `description:"open_id"`
  56. UnionId string `description:"union_id"`
  57. CompanyId int `description:"客户id"`
  58. NickName string `description:"用户昵称"`
  59. RealName string `description:"用户实际名称"`
  60. Mobile string `description:"手机号码"`
  61. BindAccount string `description:"绑定时的账号"`
  62. Email string `description:"邮箱"`
  63. Headimgurl string `description:"用户头像,最后一个数值代表正方形头像大小(有0、46、64、96、132数值可选,0代表640*640正方形头像),用户没有头像时该项为空"`
  64. ApplyMethod int `description:"0:未申请,1:已付费客户申请试用,2:非客户申请试用"`
  65. FirstLogin int `description:"是否第一次登陆"`
  66. IsFreeLogin int `description:"是否免登陆,true:免登陆,false:非免登陆"`
  67. LoginTime time.Time `description:"登录时间"`
  68. CreatedTime time.Time `description:"创建时间"`
  69. LastUpdatedTime time.Time `description:"最近一次修改时间"`
  70. SessionKey string `description:"微信小程序会话密钥"`
  71. CompanyName string `description:"公司名称"`
  72. IsRegister int `description:"是否注册:1:已注册,0:未注册"`
  73. Source int
  74. }
  75. func GetWxUserItemByUnionid(unionid string) (item *WxUserItem, err error) {
  76. sql := `SELECT * FROM wx_user WHERE union_id=? `
  77. err = orm.NewOrm().Raw(sql, unionid).QueryRow(&item)
  78. return
  79. }
  80. func GetWxUserItemByUserId(userId int) (item *WxUserItem, err error) {
  81. sql := `SELECT a.*,b.company_name FROM wx_user AS a
  82. LEFT JOIN company AS b on a.company_id=b.company_id
  83. WHERE a.user_id=? `
  84. err = orm.NewOrm().Raw(sql, userId).QueryRow(&item)
  85. return
  86. }
  87. func GetWxUserItemByOpenId(openId string) (item *WxUserItem, err error) {
  88. sql := `SELECT * FROM wx_user WHERE open_id=? `
  89. err = orm.NewOrm().Raw(sql, openId).QueryRow(&item)
  90. return
  91. }
  92. type WxLoginResp struct {
  93. Authorization string
  94. UserId int
  95. FirstLogin int
  96. Headimgurl string `description:"用户头像"`
  97. Mobile string `description:"手机号"`
  98. Email string `description:"邮箱"`
  99. CompanyName string `description:"客户名称"`
  100. Status string `description:"状态"`
  101. EndDate string `description:"到期日期"`
  102. ProductName string `description:"客户类型名称"`
  103. }
  104. type WxGetUserInfoReq struct {
  105. RawData string `description:"rawData"`
  106. Signature string `description:"signature"`
  107. EncryptedData string `description:"encryptedData"`
  108. Iv string `description:"iv"`
  109. }
  110. //修改用户会话key
  111. func ModifyWxUserSessionKey(sessionKey string, userId int) (err error) {
  112. o := orm.NewOrm()
  113. sql := `UPDATE wx_user SET session_key=? WHERE user_id=? `
  114. _, err = o.Raw(sql, sessionKey, userId).Exec()
  115. return
  116. }
  117. //添加用户信息
  118. func ModifyWxUserInfo(unionId, nickName, province, city, country, avatar string, gender, userId int) (err error) {
  119. o := orm.NewOrm()
  120. sql := `UPDATE wx_user SET union_id=?,unionid=?,nick_name=?,sex=?,province=?,city=?,country=?,headimgurl=? WHERE user_id=? `
  121. _, err = o.Raw(sql, unionId, unionId, nickName, gender, province, city, country, avatar, userId).Exec()
  122. return
  123. }
  124. //修改用户会话key
  125. func DeleteWxUserByUserId(userId int) (err error) {
  126. o := orm.NewOrm()
  127. sql := `DELETE FROM wx_user WHERE user_id=? `
  128. _, err = o.Raw(sql, userId).Exec()
  129. return
  130. }
  131. type WxGetUserInfoResp struct {
  132. //UsersId int `orm:"column(id);pk"`
  133. //Mobile string `description:"手机号"`
  134. //NickName string `description:"昵称"`
  135. //Gender int `description:"用户性别 1:男性,2:女性,0:未知(默认)"`
  136. //CreateTime time.Time `description:"注册时间"`
  137. //ModifyTime time.Time `description:"修改时间"`
  138. //AvatarUrl string `description:"头像地址"`
  139. //City string `description:"城市"`
  140. //Province string `description:"省"`
  141. //Country string `description:"国家"`
  142. //Language string `description:"语言"`
  143. //Appid string `description:"Appid"`
  144. //Timestamp int64 `description:"时间戳"`
  145. Authorization string `description:"登陆凭证,后续接口调用时,带在请求头里面Key:Authorization"`
  146. }
  147. type WxGetPhoneNumberReq struct {
  148. EncryptedData string `description:"encryptedData"`
  149. Iv string `description:"iv"`
  150. }
  151. func ModifyUsersMobile(usersId int, phoneNumber string) (err error) {
  152. o := orm.NewOrm()
  153. sql := `UPDATE wx_user SET mobile=? WHERE user_id=? `
  154. _, err = o.Raw(sql, phoneNumber, usersId).Exec()
  155. return
  156. }
  157. type WxGetPhoneNumberResp struct {
  158. PhoneNumber string `description:"用户绑定的手机号(国外手机号会有区号)"`
  159. PurePhoneNumber string `description:"没有区号的手机号"`
  160. CountryCode string `description:"区号"`
  161. }
  162. func GetWxUserItemByMobile(mobile string) (item *WxUserItem, err error) {
  163. sql := `SELECT a.*,b.company_name FROM wx_user AS a
  164. LEFT JOIN company AS b on a.company_id=b.company_id
  165. WHERE a.mobile=? `
  166. err = orm.NewOrm().Raw(sql, mobile).QueryRow(&item)
  167. return
  168. }
  169. func GetWxUserItemByEmail(email string) (item *WxUserItem, err error) {
  170. sql := `SELECT * FROM wx_user WHERE email=? `
  171. err = orm.NewOrm().Raw(sql, email).QueryRow(&item)
  172. return
  173. }
  174. func ModifyReportLastViewTime(uid int) (err error) {
  175. sql := ` UPDATE wx_user SET report_last_view_time=NOW()
  176. WHERE user_id=? `
  177. _, err = orm.NewOrm().Raw(sql, uid).Exec()
  178. return
  179. }
  180. //变更联系人是否已注册状态
  181. func ModifyWxUserRegisterStatus(userId int) (err error) {
  182. o := orm.NewOrm()
  183. sql := `UPDATE wx_user SET is_register=?,source=3,register_time=NOW() WHERE user_id = ? `
  184. _, err = o.Raw(sql, 1, userId).Exec()
  185. return
  186. }