wx_user.rb 7.4 KB

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