用Node.JS分析steam所有的游戏!

from steamapiwrapper.SteamGames import Games
games = Games()
full_price = 0.0
discounted_price = 0.0
for game in games.get_all('US'):
	if game.price != 0:
		discounted_price += game.discounted_price
		full_price += game.full_price

ssh root@xxx.xxx.xx.x

$ mkdir /steamtuhao
$ cd /steamtuhao
$ pip install virtualenv
$ virtualenv venv
$ virtualenv -p /usr/bin/python2.7 venv

$ source venv/bin/activate
$ git clone git@github.com:naiyt/steamapiwrapper.git
$ cp -avr steamapiwrapper/steamapiwrapper ./temp
$ rm -rf steamapiwrapper
$ mv temp steamapiwrapper

# 需要复制的代码
from steamapiwrapper.SteamGames import Games
games = Games()
full_price = 0.0
discounted_price = 0.0
for game in games.get_all('US'):
	if game.price != 0:
		discounted_price += game.discounted_price
		full_price += game.full_price

$ vim calTotalPrices.py
# 进入 vim 
# 粘贴上面的代码并保存

$ python calTotalPrices.py

$ pip install requests

# 文件头部 import 进来
import requests

...

# 把两处 _open_url 都改过来
def _get_games_from(self, url):
        """Generator to create the actual game objects"""
        page = requests.get(url).json()    # ←第一处

...

def get_ids_and_names(self):
        """        Returns two dicts: one mapping appid->game name, and one game name->appid        TODO: Refactor the code so we don't need to seperate dicts        """
        Returns two dicts: one mapping appid->game name, and one game name->appid
        TODO: Refactor the code so we don't need to seperate dicts

        """
        url = "http://api.steampowered.com/ISteamApps/GetAppList/v2"
        url_info = requests.get(url).json()    # ←第二处

$ python calTotalPrices.py

http://store.steampowered.com/api/appdetails/?cc=US&appids=5%2C262150%2C7%2C8%2C10%2C20%2C393240%2C30%2C40%2C262190%2C50%2C393270%2C60%2C262210%2C70%2C393290%2C80%2C262230%2C90%2C92%2C262240%2C100%2C393320%2C393330%2C262260&l=english&v=1

http://store.steampowered.com/api/appdetails/?appids=218620&cc=US&l=english&v=1

def _create_url(self, appids, cc):
    """Given a list of appids, creates an API url to retrieve them"""
    appids = ','.join([str(x) for x in appids])
    data = {'appids': appids, 'cc': cc, 'l': 'english', 'v': '1'}
    return "http://store.steampowered.com/api/appdetails/?{}".format(urllib.urlencode(data))

def _create_url(self, appids, cc):
    """Given a list of appids, creates an API url to retrieve them"""
    appids = ','.join([str(x) for x in appids])
    data = (appids, cc, 'english')
    return "http://store.steampowered.com/api/appdetails/?appids=%s&cc=%s&l=%s&v=1" % data

http://store.steampowered.com/api/appdetails/?appids=218620,441600&cc=US&l=english&v=1

http://store.steampowered.com/api/appdetails/?appids=218620,441600&cc=US&l=english&v=1&filters=price_overview

def _create_url(self, appids, cc):
    """Given a list of appids, creates an API url to retrieve them"""
    appids = ','.join([str(x) for x in appids])
    data = (appids, cc, 'english')
    return "http://store.steampowered.com/api/appdetails/?appids=%s&cc=%s&l=%s&v=1&filters=price_overview" % data

for appid in page:
	game = Game(page[appid], appid)
	if game.success:
	    yield game

def _get_games_from(self, url):
    """Generator to create the actual game objects"""
    page = requests.get(url).json()
    for game in page:
        if page[game]['success'] and page[game]['data']:
            yield page[game]['data']['price_overview']

from steamapiwrapper.SteamGames import Games
games = Games()
full_price = 0.0
discounted_price = 0.0
for game in games.get_all('US'):
	if game['initial'] != 0:
		discounted_price += game['final']
		full_price += game['initial']
		print full_price, discounted_price

$ python calTotalPrices.py

import time

...

for url in urls:
    for game in self._get_games_from(url):
        yield game
    time.sleep(1)

def __init__(self,num=None):
    """    args:    num -- number of games to query per call. The default 150 should work in most cases.    """
    args:
    num -- number of games to query per call. The default 150 should work in most cases.

    """
    self.num = 25 if num is None else num

$ nohup python calTotalPrices.py > result &

15031825 14903412

<!DOCTYPE html>
<html lang="zh-CN">
<head>
	<meta charset="UTF-8">
	<title>买下 Steam 所有游戏要花多少钱？</title>
	<meta name="viewport" content="width=device-width, initial-scale=1,user-scalable=no">
    <style type="text/css">    ... 省略，可以直接查看我的网站源码    </style>
    ... 省略，可以直接查看我的网站源码
    
</head>
<body>
	<div class="main">
		<h2>买下Steam所有游戏需要</h2>
		<h1>${dollar} 或 ￥{cny}</h1>
		<h4>共有</h4>
		<h1>{us_number}(美区),{cn_number}(中区)个游戏和 DLC！</h1>
		<p class="date">更新日期：{date}</p>
		<p><a href="http://numbbbbb.com/2016/02/15/20160215_%E5%A6%82%E4%BD%95%E8%AE%A1%E7%AE%97%20Steam%20%E6%B8%B8%E6%88%8F%E6%80%BB%E4%BB%B7%EF%BC%9F/">原理详解</a></p>
	</div>
	<div class="footer">
		<span>
			<a href="http://numbbbbb.com">作者@梁杰_numbbbbb</a>
		</span>
	</div>
</body>
</html>

$ sudo npm install pm2 babel-cli -g
$ sudo npm install hapi

$ touch index.js
$ vim index.js

#!/usr/bin/env babel-node
import Hapi from 'hapi'
import fs from 'fs'

let server = new Hapi.Server()
server.connection({
  port: 3003,
  routes: {
    cors: {
      origin: ['*']
    }
  }
})

function numberWithCommas(x) {
    var parts = x.toString().split(".");
    parts[0] = parts[0].replace(/\B(?=(\d{3})+(?!\d))/g, ",");
    return parts.join(".");
}

server.route({
  method: 'GET',
  path: '/',
  handler: (request, reply) => {
    fs.readFile("finalResult", (err, data) => {
      if (err) throw err
      let rawData = data.toString().split('\n')
      fs.stat("finalResult", (err, data) => {
        let mtime = data.mtime
        fs.readFile("index.html", (err, data) => {
          var result = data.toString()
          result = result.replace("{dollar}", numberWithCommas(parseInt(rawData[1]) / 100))
          result = result.replace("{cny}", numberWithCommas(parseInt(rawData[4]) / 100))
          result = result.replace("{us_number}", numberWithCommas(rawData[2]))
          result = result.replace("{cn_number}", numberWithCommas(rawData[5]))
          result = result.replace("{date}", mtime.toISOString())
          reply(result).code(200)
        })
      })
    })
  }
})

server.start((err) => {
  console.log(err)
  console.log('Server running at:', server.info.uri)
})

$ vim /etc/nginx/nginx.conf

server {
  listen 80;
  server_name steamtuhao.com www.steamtuhao;    # ←写你的域名

  location / {
    proxy_pass http://127.0.0.1:3003;    # ←写你的端口
    proxy_http_version 1.1;
    proxy_set_header Upgrade $http_upgrade;      
    proxy_set_header Connection 'upgrade';
    proxy_set_header Host $host;
    proxy_cache_bypass $http_upgrade;
  }
}

$ service nginx restart

$ pm2 start index.js --interpreter babel-node

from steamapiwrapper.SteamGames import Games
games = Games()
us_full_price = 0
us_discounted_price = 0
us_gameTotal = 0
for game in games.get_all('US'):
	if game['initial'] != 0:
		us_gameTotal += 1
		us_discounted_price += game['final']
		us_full_price += game['initial']

cn_full_price = 0
cn_discounted_price = 0
cn_gameTotal = 0
for game in games.get_all('CN'):
	if game['initial'] != 0:
		cn_gameTotal += 1
		cn_discounted_price += game['final']
		cn_full_price += game['initial']

print "\n".join([str(us_full_price), str(us_discounted_price), str(us_gameTotal), str(cn_full_price), str(cn_discounted_price), str(cn_gameTotal)])

$ crontab -e
# 执行之后会打开一个文件，在文件倒数第二行写入以下内容
0 23 * * * cd /steamtuhao && python calTotalPrices.py > result && mv finalResult finalResult.bak && mv result finalResult

cron requires that each entry in a crontab end in a newline character. 
If the last entry in a crontab is missing the newline,
cron  will  consider the crontab (at least partially) broken and refuse to install it.