wx_user.rb 7.4 KB

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