Add notify new symbol job

app/jobs/notify_new_symbol_job.rb

@@ -0,0 +1,45 @@
+class NotifyNewSymbolJob < ApplicationJob
+  queue_as :daily_job
+
+  def perform
+    msgs = FetchNewSymbolService.execute
+    msgs.each{|msg| format_notice_blocks(msg)}
+
+    check_symbol_from_api
+  end
+
+  def check_symbol_from_api
+    symbols = BinanceFuturesService.new.get_ticker_price.map{|x| x['symbol']} rescue []
+    return if symbols.empty?
+
+    redis_key = 'binance_futures_symbols'
+    prev_symbols = JSON.parse($redis.get(redis_key)) rescue []
+    diff_symbols = symbols - prev_symbols
+    $redis.set(redis_key, symbols)
+    SlackService.send_notification(nil, format_blocks(diff_symbols)) if diff_symbols.any?
+  end
+
+  def format_notice_blocks(msg)
+    [
+      {
+        "type": "section",
+        "text": {
+          "type": "mrkdwn",
+          "text": msg
+        }
+      }
+    ]
+  end
+
+  def format_api_blocks(symbols)
+    [
+      {
+        "type": "section",
+        "text": {
+          "type": "mrkdwn",
+          "text": "*币安合约API新增币种: #{symbols.join(", ")}, 共#{symbols.length}个*"
+        }
+      }
+    ]
+  end
+end

app/services/binance_futures_service.rb

@@ -73,8 +73,9 @@ def get_24hr_tickers
     end.map{|k,v| v[0]}
   end
 
-  def get_ticker_price(symbol)
-    url = BASE_URL + "/fapi/v1/ticker/price?symbol=#{symbol}"
+  def get_ticker_price(symbol=nil)
+    url = BASE_URL + "/fapi/v1/ticker/price"
+    url += "?symbol=#{symbol}" if symbol
     response = RestClient.get(url)
     JSON.parse(response)
   end

app/services/fetch_new_symbol_service.rb

@@ -0,0 +1,20 @@
+require 'openssl'
+require 'rest-client'
+
+class FetchNewSymbolService
+  BASE_URL = ENV['BINANCE_ANNOUNCEMENT_URL']
+
+  class << self
+    def execute
+      redis_key = 'binance_announcement_fetch_time'
+      last_fetch_time = $redis.get(redis_key).to_i
+      page = Nokogiri::HTML(URI.open(BASE_URL))
+      data = JSON.parse(page.css("script").children[10])
+      catalog = data['appState']['loader']['dataByRouteId']['2a3f']['catalogs'].select{|c| c['catalogName'] == '数字货币及交易对上新'}.first rescue nil
+      return if catalog.nil?
+
+      $redis.set(redis_key, Time.current.to_i * 1000)
+      catalog['articles'].select{|a| a['releaseDate'] >= last_fetch_time && a['title'].match(/将上线.*永续合约/)}.map{|a| a['title']}
+    end
+  end
+end