Ghost User · @ghost · 李福中 · 李福中 · 李福中 · 李福中
--- a/config/database.yml
+++ b/config/database.yml
 #   gem 'sqlite3'
--- a/app/controllers/pushs_controller.rb
+++ b/app/controllers/pushs_controller.rb
  # igetui_opts 个推推送的额外选项
  def push
    param! :app_name, String, required: true
-    param! :device_ids_opts, String, required: true
+    # param! :device_ids_opts, String, required: true
    param! :message, String, required: true
    param! :igetui_opts, String
    param! :app_type, String
    param! :sync_push, String
+    param! :user_ids, Array, required: true

    igetui_opts = JSON.parse(params[:igetui_opts]) rescue {}
    message = JSON.parse(params[:message]) rescue {}
-    device_ids_opts = JSON.parse(params[:device_ids_opts]) rescue {}
+    user_ids = JSON.parse(params[:user_ids]) rescue {}
--- a/app/services/push_sync_client.rb 0 → 100644
+++ b/app/services/push_sync_client.rb 0 → 100644
+  end
+
+  def push_sync?
+    if @sync_push
+      timeout_seconds = $redis.get('push_timeout').to_i
+      if timeout_seconds > 0
+        Timeout.timeout(timeout_seconds) {
+          ::PushWorker.new.perform(@opts)
+        }
+      else
+        ::PushWorker.new.perform(@opts)
+      end
+    else
+      ::PushWorker.perform_async(@opts)
+    end
+  end
--- a/app/controllers/pushs_controller.rb
+++ b/app/controllers/pushs_controller.rb
-  # app_name 应用名称
-  # user_device_ids 设备ids
-  # message 推送信息的json 字符串
-  # igetui_opts 个推推送的额外选项
-  def push
-    param! :app_name, String, required: true
-    param! :device_ids_opts, String, required: true
+
+    igetui_opts = JSON.parse(params[:igetui_opts]) rescue {}
+    message = JSON.parse(params[:message]) rescue {}
+
+    db_role = fetch_db_role
+    user_device_exist = false
+    ActiveRecord::Base.connected_to(role: db_role) do
+      user_device_exist = UserDevice.where(user_id: params[:user_id]).exists?
+      byebug
--- a/app/controllers/pushs_controller.rb
+++ b/app/controllers/pushs_controller.rb
-  # user_device_ids 设备ids
-  # message 推送信息的json 字符串
-  # igetui_opts 个推推送的额外选项
-  def push
-    param! :app_name, String, required: true
-    param! :device_ids_opts, String, required: true
+
+    igetui_opts = JSON.parse(params[:igetui_opts]) rescue {}
+    message = JSON.parse(params[:message]) rescue {}
+
+    db_role = fetch_db_role
+    user_device_exist = false
+    ActiveRecord::Base.connected_to(role: db_role) do
+      user_device_exist = UserDevice.where(user_id: params[:user_id]).exists?
+      byebug
+      stale?(last_modified: UserDevice.where(user_id: params[:user_id]).last.updated_at)
--- a/app/services/token.rb → app/controllers/concerns/token_validate.rb
+++ b/app/services/token.rb → app/controllers/concerns/token_validate.rb
-module Token
+module TokenValidate
+  extend ActiveSupport::Concern
  ACCESS_TOEKN_EXPIRE_TIME = 7200
-  class << self
-    def key(app_name)
-      "push:api:#{app_name}:access_token"
-    end
+    
+  def validate_token(app_name, token)
+    !! (token == get_token(app_name))
--- a/app/controllers/pushs_controller.rb
+++ b/app/controllers/pushs_controller.rb
 class PushsController < ApplicationController
  include ActionController::HttpAuthentication::Token
-  skip_before_action :verify_authenticity_token
+  # skip_before_action :verify_authenticity_token
--- a/app/services/push_tool_client.rb 0 → 100644
+++ b/app/services/push_tool_client.rb 0 → 100644
+#push功能的代理选择用哪种推送工具1.个推 2.小米 3.华为
+class PushToolClient
+  
+  def initialize(opts={})
+    opts = HashWithIndifferentAccess.new(opts)
+    @user_ids = opts[:user_ids]
+    @opts = opts
+  end
+
+  def do_push
+    Settings.platform = @opts[:app_type] || Settings::DEFAULT
--- a/app/models/user_device.rb 0 → 100644
+++ b/app/models/user_device.rb 0 → 100644
+class UserDevice < ApplicationRecord
+  self.table_name = 'user_devices'
+  connects_to database: { dev: :dev_development, test: :test_development, staging: :staging_development, production: :production }
+  
+  
+  # 当前app端传递的platform的值:
+  # android: igetui, xiaomi, huawei
+  # iso: igetui 目前还不清楚为啥不用apns,暂时不修改
+  enum platform: %i[igetui apns xiaomi huawei]
+  
+  enum device_platform: %i[ios android]
+  
+  # 用于区分当前的应用，为了推送准备， 因为推送需要根据不同的应用使用不同的 id,secret等。
+  enum app_type: %i[ik_duli lx_duli lx_yun]
--- a/app/services/push_tool_client.rb 0 → 100644
+++ b/app/services/push_tool_client.rb 0 → 100644
+    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::IgetuiAndroid.push(@push_collections[:igetui_android], @opts) if @push_collections[:apns].present?
+
+    Xiaomi::Pusher.new(xiaomi_client_ids, @opts[:message]).perform if xiaomi_client_ids.present?
+    Huawei::Pusher.new(huawei_client_ids, @opts[:message]).perform if huawei_client_ids.present?
+  end
+  
+  def fetch_client_ids
+    igetui_android_client_ids = igetui_ios_client_ids = xiaomi_client_ids = huawei_client_ids = []
+    
+    if (@opts[:device_ids_opts].is_a? Hash) && @user_ids.blank?
+      push_devices = @opts[:device_ids_opts].keys.map(&:to_s)
+      if push_devices.include? "igetui"
--- a/app/workers/push_worker.rb
+++ b/app/workers/push_worker.rb
  include Sidekiq::Worker
  sidekiq_options queue: :push

-  def perform(device_ids_opts, message, igetui_opts, platform = nil)
-    Push.push(device_ids_opts, message, igetui_opts, platform)
+  def perform(opts)
--- a/app/services/push/huawei.rb → app/services/huawei/pusher.rb
+++ b/app/services/push/huawei.rb → app/services/huawei/pusher.rb
-        end
-        params_str
+      }
+      ::Log.info("huawei_payload: #{payload}, device_tokens: #{device_tokens}")
+      params = {
+        access_token: CGI.escape(access_token),
+        nsp_svc: CGI.escape('openpush.message.api.send'),
+        nsp_ts: CGI.escape(Time.now.to_i.to_s),
+        device_token_list: CGI.escape(device_tokens.to_s),
+        payload: CGI.escape(payload.to_json)
+      }
+      params_str = ''
+      params.each_with_index do |(key,value), index|
+        params_str += "#{key}=#{value}"
+        params_str += '&' if index + 1 < params.size
      end