wx_user.rb 7.5 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285
  1. # encoding:utf-8
  2. #微信用户表
  3. require 'redis'
  4. class WxUser < ActiveRecord::Base
  5. has_paper_trail
  6. self.table_name = "wx_users"
  7. belongs_to :user
  8. #has_many :channel_qrcode_results, :foreign_key => :mp_openid
  9. belongs_to :parent_signup_channel, :foreign_key => :channel_qrcode_id
  10. validates_presence_of :nickname, :unionid
  11. #belongs_to :channel_qrcode
  12. attr_accessor :invite, :v_head, :intro_user
  13. after_update :after_update
  14. SEX_ENUM= [["未知","0"], ["男性","1"], ["女性", "2"]]
  15. RANK_ENUM= [["普通会员","0"], ["群主","1"], ["店长", "2"]]
  16. COPARTNET_STATE_ENUM = [["否",0],["是",1],["曾经是",2]]
  17. IMG_STORE_PATH = "wx_user"
  18. after_destroy :after_destroy
  19. def after_update
  20. test_redis = Redis.new(:host=>"r-wz9dtt12y12ns2b97gpd.redis.rds.aliyuncs.com",:db=>"0",:user=>"root",:password=>"Fohow123!@#")
  21. redis = Redis.new(:host=>"r-wz9dtt12y12ns2b97gpd.redis.rds.aliyuncs.com",:db=>"0",:user=>"root",:password=>"Fohow123!@#")
  22. #test_redis = Redis.new(url: "redis://root:8c!Beg9ocFag@r-wz9nmvnbdsek8yl476pd.redis.rds.aliyuncs.com:6379/102")
  23. #redis = Redis.new(url: "redis://root:8c!Beg9ocFag@r-wz9nmvnbdsek8yl476pd.redis.rds.aliyuncs.com:6379/15")
  24. userKey= format("userinfo_%d",self.id)
  25. redis.del(userKey)
  26. test_redis.del(userKey)
  27. wxuserKey= format("user_model.GetWxUserById:%d",self.id)
  28. redis.del(wxuserKey)
  29. test_redis.del(wxuserKey)
  30. end
  31. def invite
  32. wu = WxUser.where("id = ?", invite_id).first
  33. if !wu.blank?
  34. return wu.nickname
  35. end
  36. end
  37. def intro_user
  38. wu = WxUser.where("id = ?", intro_user_id).first
  39. if !wu.blank?
  40. return wu.nickname
  41. end
  42. end
  43. def tel
  44. if self.user_id.to_i >0
  45. u = User.where("id=?",self.user_id).first
  46. return if u.blank?
  47. return u.tel
  48. end
  49. end
  50. def gzhOpenid
  51. if self.id.to_i >0
  52. u = WxUserGongzhonghao.where("wx_user_id=?",self.id).first
  53. return if u.blank?
  54. return u.gzh_open_id
  55. end
  56. return "-"
  57. end
  58. def gzhIsSub
  59. if self.id.to_i >0
  60. u = WxUserGongzhonghao.where("wx_user_id=?",self.id).first
  61. return false if u.blank?
  62. return u.subscribe
  63. end
  64. return false
  65. end
  66. def gzhSubTime
  67. if self.id.to_i >0
  68. u = WxUserGongzhonghao.where("wx_user_id=?",self.id).first
  69. return "-" if u.blank? || u.subscribe_time.blank? || u.subscribe_time == nil
  70. return Time.at(u.subscribe_time) if u.subscribe_time != nil
  71. end
  72. return "-"
  73. end
  74. def gzhUnSubTime
  75. if self.id.to_i >0
  76. u = WxUserGongzhonghao.where("wx_user_id=?",self.id).first
  77. return "-" if u.blank? || u.unsubscribe_time.blank? || u.unsubscribe_time == nil
  78. return Time.at(u.unsubscribe_time) if u.unsubscribe_time != nil
  79. end
  80. return "-"
  81. end
  82. def gzhLastConversationTime
  83. if self.id.to_i >0
  84. u = WxUserGongzhonghao.where("wx_user_id=?",self.id).first
  85. return "-" if u.blank? || u.last_conversation_at.blank? || u.last_conversation_at == nil
  86. return Time.at(u.last_conversation_at) if u.last_conversation_at != nil
  87. end
  88. return "-"
  89. end
  90. rails_admin do
  91. navigation_label '用户管理'
  92. # parent User
  93. weight -300
  94. list do
  95. filters [:id,:user_id,:nickname, :city, :parent_signup_channel, :sale_group, :sale_group_sum]
  96. field :id
  97. field :user_id do
  98. filterable true
  99. end
  100. field :tel
  101. # field :gzhOpenid
  102. field :gzhIsSub, :boolean
  103. field :gzhSubTime
  104. field :gzhUnSubTime
  105. field :gzhLastConversationTime
  106. field :nickname
  107. field :invite_id
  108. field :intro_user_id
  109. field :sex, :enum do
  110. enum do
  111. SEX_ENUM
  112. end
  113. end
  114. field :head do
  115. formatted_value do
  116. bindings[:view].tag(:img,{:src => bindings[:object].get_head_img,
  117. :style => 'width: 100px;height: 100px;cursor: pointer;display: block;max-width: 100px',
  118. :onClick => "javascript:window.open('#{bindings[:object].get_head_img}')"})
  119. end
  120. end
  121. # field :openid
  122. # field :unionid
  123. # field :province
  124. field :city
  125. # field :signup_ip
  126. field :parent_signup_channel
  127. field :show_invite_mode
  128. field :rank, :enum do
  129. enum do
  130. RANK_ENUM
  131. end
  132. end
  133. field :sale_group
  134. field :sale_group_sum
  135. # field :channel_qrcode_id
  136. field :created_at
  137. end
  138. show do
  139. field :id
  140. field :user
  141. field :user_id
  142. field :nickname
  143. field :invite
  144. field :invite_id
  145. field :intro_user
  146. field :intro_user_id
  147. field :sex, :enum do
  148. enum do
  149. SEX_ENUM
  150. end
  151. end
  152. field :head do
  153. formatted_value do
  154. bindings[:view].tag(:img,{:src => bindings[:object].get_head_img,
  155. :style => 'width: 100px;height: 100px;cursor: pointer;display: block;max-width: 100px',
  156. :onClick => "javascript:window.open('#{bindings[:object].get_head_img}')"})
  157. end
  158. end
  159. field :unionid
  160. field :openid
  161. field :gzhOpenid
  162. field :gzhIsSub, :boolean
  163. field :gzhSubTime
  164. field :gzhUnSubTime
  165. field :gzhLastConversationTime
  166. field :province
  167. field :city
  168. field :signup_ip
  169. # field :subscribe
  170. # field :subscribe_time do
  171. # formatted_value do
  172. # (value !=nil || value != 0) ? Time.at(value):Time.now
  173. # end
  174. # end
  175. # field :unsubscribe_time do
  176. # formatted_value do
  177. # (value !=nil || value != 0) ? Time.at(value):Time.now
  178. # end
  179. # end
  180. # field :last_conversation_at do
  181. # formatted_value do
  182. # (value !=nil || value != 0) ? Time.at(value):Time.now
  183. # end
  184. # end
  185. # field :channel_qrcode_id
  186. field :invite_qrcode_url
  187. field :show_invite_mode
  188. field :rank, :enum do
  189. enum do
  190. RANK_ENUM
  191. end
  192. end
  193. field :parent_signup_channel
  194. field :sale_group
  195. field :sale_group_sum
  196. field :created_at
  197. end
  198. edit do
  199. field :user_id
  200. field :nickname
  201. # field :unionid
  202. field :city
  203. field :country
  204. field :province
  205. field :sex, :enum do
  206. enum do
  207. SEX_ENUM
  208. end
  209. end
  210. field :v_head, :file_upload do
  211. pretty_value do
  212. bindings[:view].tag(:img, {:src => bindings[:object].get_head_img, :class => 'preview'})
  213. end
  214. end
  215. # field :subscribe
  216. # field :unsubscribe_time, :datetime do
  217. # formatted_value do
  218. # (value.blank?) ? Time.at(0) : Time.at(value)
  219. # end
  220. # end
  221. # field :subscribe_time, :datetime do
  222. # formatted_value do
  223. # (value.blank?) ? Time.at(0) : Time.at(value)
  224. # end
  225. # end
  226. # field :last_conversation_at
  227. field :invite_id
  228. field :signup_ip
  229. field :channel_qrcode_id
  230. field :invite_qrcode_url
  231. field :show_invite_mode
  232. field :rank, :enum do
  233. enum do
  234. RANK_ENUM
  235. end
  236. end
  237. end
  238. end
  239. def get_head_img
  240. url = "http://#{Ali::Oss::CDN_URL_FOR_HOST}/#{self.head}"
  241. return url
  242. end
  243. def v_head=file
  244. unless file.blank?
  245. clear_head_img
  246. file_name = "#{UUID.new.generate[0...8].downcase}.jpg"
  247. file_path = "#{IMG_STORE_PATH}/#{file_name}"
  248. Ali::Oss.store(Ali::Oss::BUCKET_NAME_PUBLIC_READ, file_path, file.read)
  249. self.head = file_path
  250. self.save
  251. end
  252. end
  253. def clear_head_img
  254. file_path = "#{self.head}"
  255. Ali::Oss.delete_object(Ali::Oss::BUCKET_NAME_PUBLIC_READ, file_path)
  256. end
  257. def after_destroy
  258. clear_head_img
  259. end
  260. end