Commit 6e731a60 by liangyuzhe

init pusher

parent b3d25f2a
...@@ -36,7 +36,6 @@ class PushsController < ApplicationController ...@@ -36,7 +36,6 @@ class PushsController < ApplicationController
if token_array.blank? if token_array.blank?
return render json: { code: -1, message: 'token错误'} return render json: { code: -1, message: 'token错误'}
end end
byebug
if validate_token(params[:app_name], token_array.first) if validate_token(params[:app_name], token_array.first)
push_sync(params[:sync_push], {user_ids: Array(params[:user_id]), message: message, app_type: params[:app_type], igetui_opts: igetui_opts.merge(pusher_type: 'push_message_to_single')}) push_sync(params[:sync_push], {user_ids: Array(params[:user_id]), message: message, app_type: params[:app_type], igetui_opts: igetui_opts.merge(pusher_type: 'push_message_to_single')})
......
...@@ -6,7 +6,7 @@ module Igetui ...@@ -6,7 +6,7 @@ module Igetui
@template_data = opts[:message] @template_data = opts[:message]
@igetui_opts = opts[:igetui_opts] @igetui_opts = opts[:igetui_opts]
@user_device_ids = user_device_ids @user_device_ids = user_device_ids
@pusher = pusher(opts[:device_platform]) @pusher = pusher(opts[:device_platform], opts[:app_type])
@pusher_type = @igetui_opts[:pusher_type] @pusher_type = @igetui_opts[:pusher_type]
end end
...@@ -22,12 +22,16 @@ module Igetui ...@@ -22,12 +22,16 @@ module Igetui
end end
private private
def pusher(device_platform) def pusher(device_platform, app_type)
case device_platform case app_type
when 'android' when 'lx_duli'
$android_pusher device_platform == 'android' ? $lx_duli_android_pusher : $lx_duli_ios_pusher
when 'ios' when 'lx_yun'
$ios_pusher device_platform == 'android' ? $lx_yun_android_pusher : $lx_yun_ios_pusher
when 'aike_yun'
device_platform == 'android' ? $aike_yun_android_pusher : $aike_yun_ios_pusher
else 'ik_duli'
device_platform == 'android' ? $ik_duli_android_pusher : $ik_duli_ios_pusher
end end
end end
......
...@@ -12,21 +12,21 @@ class PushToolClient ...@@ -12,21 +12,21 @@ class PushToolClient
@push_device_collections ||= UserDevice.where(user_id: @user_ids).group_by(&:platform) @push_device_collections ||= UserDevice.where(user_id: @user_ids).group_by(&:platform)
@igetui_push_device_collections ||= @push_device_collections['igetui'].group_by(&:device_platform) if @push_device_collections['igetui'].is_a? Array @igetui_push_device_collections ||= @push_device_collections['igetui'].group_by(&:device_platform) if @push_device_collections['igetui'].is_a? Array
if @igetui_push_device_collections.is_a? Hash if @igetui_push_device_collections.is_a? Hash
igetui_android_device_ids = @igetui_push_device_collections['android'].map(&:device_id) if @igetui_push_device_collections['android'].is_a? Array igetui_android_client_ids = @igetui_push_device_collections['android'].map(&:client_id) if @igetui_push_device_collections['android'].is_a? Array
igetui_ios_device_ids = @igetui_push_device_collections['ios'].map(&:devendice_id) if @igetui_push_device_collections['ios'].is_a? Array igetui_ios_client_ids = @igetui_push_device_collections['ios'].map(&:client_id) if @igetui_push_device_collections['ios'].is_a? Array
end end
Igetui::Pusher.new(igetui_android_device_ids, @opts.merge(device_platform: 'android')).perform if igetui_android_device_ids.present? Igetui::Pusher.new(igetui_android_client_ids, @opts.merge(device_platform: 'android')).perform if igetui_android_client_ids.present?
Igetui::Pusher.new(igetui_ios_device_ids, @opts.merge(device_platform: 'ios')).perform if igetui_ios_device_ids.present? Igetui::Pusher.new(igetui_ios_client_ids, @opts.merge(device_platform: 'ios')).perform if igetui_ios_client_ids.present?
#现在好像不用了 #现在好像不用了
# Push::IgetuiIos.push(@push_collections[:igetui_ios], @opts) if @push_collections[:apns].present? # Push::IgetuiIos.push(@push_collections[:igetui_ios], @opts) if @push_collections[:apns].present?
# Push::IgetuiAndroid.push(@push_collections[:igetui_android], @opts) if @push_collections[:apns].present? # Push::IgetuiAndroid.push(@push_collections[:igetui_android], @opts) if @push_collections[:apns].present?
xiaomi_device_ids = @push_device_collections['xiaomi'].map(&:device_id) if @push_device_collections['xiaomi'].is_a? Array xiaomi_client_ids = @push_device_collections['xiaomi'].map(&:client_id) if @push_device_collections['xiaomi'].is_a? Array
huawei_device_ids = @push_device_collections['huawei'].map(&:device_id) if @push_device_collections['huawei'].is_a? Array huawei_client_ids = @push_device_collections['huawei'].map(&:client_id) if @push_device_collections['huawei'].is_a? Array
Xiaomi::Pusher.new(xiaomi_device_ids, @opts[:message]).perform if xiaomi_device_ids.present? Xiaomi::Pusher.new(xiaomi_client_ids, @opts[:message]).perform if xiaomi_client_ids.present?
Huawei::Pusher.new(huawei_device_ids, @opts[:message]).perform if huawei_device_ids.present? Huawei::Pusher.new(huawei_client_ids, @opts[:message]).perform if huawei_client_ids.present?
end end
end end
\ No newline at end of file
...@@ -8,7 +8,8 @@ default: &default ...@@ -8,7 +8,8 @@ default: &default
adapter: mysql2 adapter: mysql2
encoding: utf8 encoding: utf8
pool: 10 pool: 10
host: rdscbq34656z0ix59br0.mysql.rds.aliyuncs.com host: rm-m5eu4m6a4rugr22fcno.mysql.rds.aliyuncs.com
development: development:
<<: *default <<: *default
...@@ -16,9 +17,9 @@ development: ...@@ -16,9 +17,9 @@ development:
#host: 10.140.235.122 #host: 10.140.235.122
#username: vcooline_ikcrm_testing #username: vcooline_ikcrm_testing
#password: ikcrm_123 #password: ikcrm_123
database: crm_test database: crm_staging
username: lx_duli_test username: crm_staging
password: '@NshoftqW!$%0eFQ' password: rCxWfEbdJrEp3Mff
# Warning: The database defined as "test" will be erased and # Warning: The database defined as "test" will be erased and
# re-generated from your development database when you run "rake". # re-generated from your development database when you run "rake".
...@@ -30,3 +31,4 @@ test: ...@@ -30,3 +31,4 @@ test:
production: production:
<<: *default <<: *default
database: db/production.sqlite3 database: db/production.sqlite3
$android_pusher ||= $ik_duli_android_pusher ||=
IGeTui.pusher( IGeTui.pusher(
Settings.platform_settings.igetui.android['app_id'], Settings.ik_duli.igetui.android['app_id'],
Settings.platform_settings.igetui.android['app_key'], Settings.ik_duli.igetui.android['app_key'],
Settings.platform_settings.igetui.android['master_secret'] Settings.ik_duli.igetui.android['master_secret']
) )
$ios_pusher ||= $ik_duli_ios_pusher ||=
IGeTui.pusher( IGeTui.pusher(
Settings.platform_settings.igetui.ios['app_id'], Settings.ik_duli.igetui.ios['app_id'],
Settings.platform_settings.igetui.ios['app_key'], Settings.ik_duli.igetui.ios['app_key'],
Settings.platform_settings.igetui.ios['master_secret'] Settings.ik_duli.igetui.ios['master_secret']
) )
$lx_duli_android_pusher ||=
IGeTui.pusher(
Settings.lx_duli.igetui.android['app_id'],
Settings.lx_duli.igetui.android['app_key'],
Settings.lx_duli.igetui.android['master_secret']
)
$lx_duli_ios_pusher ||=
IGeTui.pusher(
Settings.lx_duli.igetui.ios['app_id'],
Settings.lx_duli.igetui.ios['app_key'],
Settings.lx_duli.igetui.ios['master_secret']
)
$lx_yun_android_pusher ||=
IGeTui.pusher(
Settings.lx_yun.igetui.android['app_id'],
Settings.lx_yun.igetui.android['app_key'],
Settings.lx_yun.igetui.android['master_secret']
)
$lx_yun_ios_pusher ||=
IGeTui.pusher(
Settings.lx_yun.igetui.ios['app_id'],
Settings.lx_yun.igetui.ios['app_key'],
Settings.lx_yun.igetui.ios['master_secret']
)
$aike_yun_android_pusher ||=
IGeTui.pusher(
Settings.aike_yun.igetui.android['app_id'],
Settings.aike_yun.igetui.android['app_key'],
Settings.aike_yun.igetui.android['master_secret']
)
$aike_yun_ios_pusher ||=
IGeTui.pusher(
Settings.aike_yun.igetui.ios['app_id'],
Settings.aike_yun.igetui.ios['app_key'],
Settings.aike_yun.igetui.ios['master_secret']
)
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment