bot.php

<?php
/**
 * 12306 刷票
 * Special thx 2 @也云
 * 
 * @author sskaje sskaje@gmail.com http://weibo.com/sskaje 
 */

date_default_timezone_set('Asia/Shanghai');

define('SPBOT_12306_DECAPTCHA_MODE_INPUT',     1);
define('SPBOT_12306_DECAPTCHA_MODE_TESSERACT', 2);

$config_file = __DIR__ . '/config.php';
if (isset($argv[2]) && ($cfg = trim($argv[2]))) {
	if (file_exists($cfg)) {
		$config_file = $cfg;
	} else if (file_exists(__DIR__ . "/config/{$cfg}.php")) {
		$config_file = __DIR__ . "/config/{$cfg}.php";
	}
}

$config = include($config_file);

PHP_OS == "WINNT" or die("Sorry, but Windows only unless you are about to change the default image viewer program.");

$bot = new sp12306bot;
$bot->set_config($config);
$bot->init();

$bot->login();

if (!isset($argv[1]) || !in_array($argv[1], array('pay', 'simple_pay', 'cookie'))) {
query_ticket:
	$t = $bot->query_ticket();
	if (!isset($argv[1]) || !isset($t[$argv[1]])) {
		MessageBox::msgbox('Check ur ticket now!');
		do {
			Logger::Out('Available options: ' . implode(', ', array_keys($t)) . ' E(x)it (R)etry (S2)=>Sleep 2 seconds');
			$opt = stdin();
		} while(!isset($t[$opt]));
		Logger::Out("Option selected: {$opt}");
	} else {
		$opt = $argv[1];
	}
	
	$confirm = $bot->confirm($t[$opt]);
	Logger::Out("Option selected: {$opt}");
	
	if (!$confirm) {
		goto query_ticket;
	}
} else if ($argv[1] == 'simple_pay') {
	$bot->simple_pay($config['ticket_key'], $config['sequence_no']);
	exit;
} else if ($argv[1] == 'cookie') {
	$bot->show_cookie_js();
	exit;
}
Logger::Out('Finished ? ');

MessageBox::msgbox('订票成功！！！正在尝试获取支付页面！！！');

# request for pay link
$s = $bot->pay_order();


define('SPBOT_12306_DECAPTCHA_MODE_INPUT',     1);
define('SPBOT_12306_DECAPTCHA_MODE_TESSERACT', 2);

class sp12306bot
{
	protected $convert_path		= '"C:/Program Files/ImageMagick-6.7.3-Q16/convert.exe"';
	protected $tesseract_path	= 'd:/Apps/Tesseract/tesseract.exe -l hcp -psm 7';
	protected $browser_path     = '"C:/Program Files (x86)/Internet Explorer/iexplore.exe"';
	
	protected $login_user;
	protected $login_pass;
	protected $login_realname;
	
	protected $train_date;
	protected $train_from;
	protected $train_to;
	protected $train_time;
	
	protected $train_no;
	protected $train_passtype;
	protected $train_class;
	
	protected $return_train_date;
	protected $return_train_time;
	
	protected $return_train_passtype;
	protected $return_train_class;
	
	protected $single_round_type = 1;# 1 单程 2 返程
	
	protected $tickets_info = array();
	
	protected $seats;
	
	protected $seat_detail = array(
		 array(
	 		'seat'		=>	4,	# @see $seatnames
	 		'ticket'	=>	1,
	 		'name'		=>	'测试',
	 		'cardtype'	=>	2,	# 1二代身份证,2一代身份证,C港澳通行证,G台湾通行证,B护照
	 		'cardno'	=>	'110110800101123',
	 		'mobileno'	=>	'13011112222',
		 ),
	);
	
	protected $seat_order = array();
	
	/**
	 * 座位编号名称
	 *
	 * @var array
	 */
	protected $seat_names = array(
		'S' =>  '一等包座',
		'M' =>  '一等座',
		'O' =>  '二等座',
		'P' =>  '特等座',
		'Q' =>  '观光座',
		1   =>  '硬座',
		2   =>  '软座',
		3   =>  '硬卧',
		4   =>  '软卧',
		6   =>  '高级软卧',
		9   =>  '商务座',
	);
	/**
	 * 查票的查询字段
	 *
	 * @var array
	 */
	protected $query_fields = array(
		array('序号', null),
		array('车次', null),
		array('始发', null),
		array('到达', null),
		array('历时', null),
		array('商务座', 9),
		array('特等座', 'P'),
		array('一等座', 'M'),
		array('二等座', 'O'),
		array('高级软卧', 6),
		array('软卧', 4),
		array('硬卧', 3),
		array('软座', 2),
		array('硬座', 1),
		array('无座', null),
		array('其他', null),
		array('购票', null),
	);
	
	protected $seat_field_map = array();
	
	public function __construct()
	{
	}
	
	public function init()
	{
		$this->init_seat_field_map();
		$this->init_curl();
		# request for station names
		$this->request_station_names();
	}
	
	protected function init_seat_field_map() 
	{
		foreach ($this->query_fields as $k=>$v) {
			if ($v[1] !== null) {
				$this->seat_field_map[$v[1]] = $k;
			}
		}
	}
	
	protected $curl;
	
	protected function init_curl() 
	{
		$header = array(
			'Accept: text/html,application/xhtml+xml,application/xml;q=0.9,*/*;q=0.8',
			'Accept-Language: zh-cn,zh;q=0.5',
			'Accept-Charset: GB2312,utf-8;q=0.7,*;q=0.7',
			'Connection: keep-alive',
			'Cache-Control: max-age=0',
		);
	
		$this->curl = curl_init();
		
		$cookiefile = $this->get_cookie_file();
		curl_setopt($this->curl, CURLOPT_COOKIEJAR,  $cookiefile);
		curl_setopt($this->curl, CURLOPT_COOKIEFILE, $cookiefile);
		curl_setopt($this->curl, CURLOPT_VERBOSE, 1);
		curl_setopt($this->curl, CURLOPT_USERAGENT, 'Mozilla/5.0 (Windows NT 6.1; WOW64; rv:8.0) Gecko/20100101 Firefox/8.0');
		curl_setopt($this->curl, CURLOPT_SSL_VERIFYPEER, 0);
		curl_setopt($this->curl, CURLOPT_SSL_VERIFYHOST, 0);
		curl_setopt($this->curl, CURLOPT_RETURNTRANSFER, 1);
		curl_setopt($this->curl, CURLOPT_HEADER, 0);
		curl_setopt($this->curl, CURLOPT_HTTPHEADER, $header);
		curl_setopt($this->curl, CURLOPT_COOKIESESSION, 1);
		curl_setopt($this->curl, CURLOPT_TIMEOUT, 60);
		curl_setopt($this->curl, CURLOPT_ENCODING, 'gzip');
	
		return $this->curl;
	}
	
	protected function get_cookie_file()
	{
		return $this->login_user . $this->cookiejar;
	}
	
	protected $cookiejar = '_cookie.txt';
	
	public function __destruct()
	{
		$this->flush_curl();
	}
	
	protected function exec_curl()
	{
		$ret = curl_exec($this->curl);
		if (false === $ret) {
			Logger::Out('Curl Exec failed, retrying...');
			return $this->exec_curl();
		} else {
			return $ret;
		}
	}
	
    protected function is_403()
    {
    	$info = curl_getinfo($this->curl, CURLINFO_HTTP_CODE);
    	return $info == '403';
    }
    
    protected function test_403()
    {
    	if ($this->is_403()) {
            Logger::Out('403 Forbidden');
            return true;
        } else {
            return false;
        }
    }
	protected function is_200()
	{
		$info = curl_getinfo($this->curl, CURLINFO_HTTP_CODE);
		return $info == '200';
	}
	
	protected function flush_curl()
	{
		curl_close($this->curl);
		if (!file_exists($this->get_cookie_file())) {
			Logger::Out('Cookie jar file not found');
		}
		
		$time = time() + 3600 * 24;
		# update expiration
		file_put_contents(
			$this->get_cookie_file(),
			str_replace(
				"\t0\t",
				"\t{$time}\t",
				file_get_contents($this->get_cookie_file()) 
			)
		);
        Logger::Out('Cookie jar updated. (Expiration only)');
	}
	
	public function show_cookie_js()
	{
		$f = $this->get_cookie_file();
		if (!is_file($f)) {
			Logger::Out("Cookie File '{$f}' Not Found.");
			return false;
		}
		
		$s = file($f);
		if (isset($s[4])) {
			for ($i=4; isset($s[$i]); $i++) {
				$tmp = explode("\t", trim($s[$i]));
				Logger::Out("INLINE SCRIPT: javascript:alert(document.cookie=\"{$tmp[5]}={$tmp[6]}; path=/\")");
			}
		}
	}
	/**
	 * 加载配置
	 * 
	 * @param array $config
	 */
	public function set_config($config)
	{
		$this->login_user		= $config['login_user'];
		$this->login_pass		= $config['login_pass'];
		$this->login_realname	= $config['login_realname'];
		
		$this->train_date		= $config['train_date'] ? : date('Y-m-d', time()+86400*11);
		$this->train_from		= $config['train_from'];
		$this->train_to			= $config['train_to'];
		$this->train_time		= $config['train_time'];
		$this->train_no			= $config['train_no'];
		$this->train_passtype	= $config['train_passtype'];
		$this->train_class		= $config['train_class'];
		$this->seat_detail		= $config['seat_detail'];
		
		$this->single_round_type= $config['single_round_type'];
		
		$this->return_train_date		= $config['return_train_date'];
		$this->return_train_time		= $config['return_train_time'];
		
		$this->return_train_passtype	= $config['return_train_passtype'];
		$this->return_train_class		= $config['return_train_class'];
		
		$this->tickets_info		= $config['tickets_info'];
		
		return true;
	}
	
	/**
	 * 验证码识别
	 * 
	 * @param string $url
	 * @param int $hit
	 */
	protected function decaptcha($url, $is_login=true, $hit=0) 
	{
        $flag_input =
            $is_login ?
                defined('SPBOT_12306_DECAPTCHA_LOGIN') && SPBOT_12306_DECAPTCHA_LOGIN == SPBOT_12306_DECAPTCHA_MODE_INPUT
                :
                defined('SPBOT_12306_DECAPTCHA_CONFIRM') && SPBOT_12306_DECAPTCHA_CONFIRM == SPBOT_12306_DECAPTCHA_MODE_INPUT
            ;
            
        #$flag_input = 1;
		
		curl_setopt($this->curl, CURLOPT_URL, $url . (strpos($url, '?') === false ? '?' : '&') . mt_rand());
		curl_setopt($this->curl, CURLOPT_TIMEOUT, $flag_input ? 20 : 15);
		curl_setopt($this->curl, CURLOPT_HTTPGET, 1);
		curl_setopt($this->curl, CURLOPT_POST,    0);
		
		do {
			$o = $this->exec_curl();
		} while (stripos($o, '<html') !== false && false !== sleep(1));
		
		Logger::File('out.jpg', $o);
	
		if ($flag_input) {
			Logger::Out("Trying to open image...");
#			exec("C:/windows/system32/mspaint.exe out.jpg");
			exec("out.jpg");
			Logger::Out("Input captcha you read:");
			$decaptcha = stdin();
		} else {
#			exec("{$this->convert_path} out.jpg out.tiff 2>&1 >nul");
#			exec("{$this->tesseract_path} out.tiff out 2>&1 >nul");

#			passthru("{$this->convert_path} -compress none -depth 8 -alpha off -colorspace Gray out.jpg out.tif 2>&1 >nul");
#			passthru("{$this->convert_path} out.tif -scale 110% out.tif 2>&1 >nul");
#			passthru("{$this->tesseract_path} out.tif out 2>&1");

			exec("{$this->tesseract_path} out.jpg out 2>&1 >nul");
		
			$decaptcha = str_replace(' ', '', trim(file_get_contents('out.txt')));
			Logger::Out('Decaptcha: hit ' . $hit);
		}
		
		if (!$this->decaptcha_valid($decaptcha)) {
			return $this->decaptcha($url, $is_login, ++$hit);
		} else {
			#rename('out.jpg', 'decaptcha_' . $decaptcha . '.jpg');
			return $decaptcha;
		}
	}
	/**
	 * 判断验证码结果是否合法
	 * 
	 * @param string $decaptcha
	 * @return boolean
	 */
	protected function decaptcha_valid($decaptcha) 
	{
		return preg_match('#^[A-Z0-9]{4}$#', $decaptcha);
	}
	
	protected function get_message($o)
	{
		$m = array();
		if (preg_match('#var message = "(.+)";#', $o, $m)) {
			return $m[1];
		} else {
			return null;
		}
	}
	protected function get_formtoken($o)
	{
	    $m = array();
	    if (preg_match('#<input type="hidden" name="org.apache.struts.taglib.html.TOKEN" value="(.+)">#', $o, $m)) {
	        return $m[1];
	    } else {
	        return null;
	    }
	}
	protected function get_sequence_no($o)
	{
	    $m = array();
	    if (preg_match('#<input type="hidden" name="sequence_no" value="(.+)">#', $o, $m)) {
	        return $m[1];
	    } else {
	        return null;
	    }
	}
	
	
	protected function is_logged_in($html = '')
	{
		if (!empty($html)) {
			# 比较串
			if (strpos($html, 'isLogin= true')) {
				Logger::Out('Login: Already logged in as ' . $this->login_user);
				return true;
			} else {
				Logger::Out('Login required. ');
				return false;
			}
        } else {

            $test_login_url = 'https://dynamic.12306.cn/otsweb/passengerAction.do?method=initUsualPassenger';
			$test_login_url = 'https://dynamic.12306.cn/otsweb/loginAction.do?method=initForMy12306';
			curl_setopt($this->curl, CURLOPT_URL,     $test_login_url);
            curl_setopt($this->curl, CURLOPT_REFERER, $test_login_url);
            $count_403 = 0;
retry_test_login:
            $o = $this->exec_curl();
            Logger::File('test_login.txt', $o);
            if ($this->test_403()) {
                Logger::Out("Retry test login: " . ++$count_403);
                if ($count_403 < 10) {
                    if ($count_403 % 5 == 0) {
                        sleep(1);
                    }
                    goto retry_test_login;
                }
            }

			if (!$o || !$this->is_200()) {
				return false;
			} else {
				$m = array();
				if (null !== ($m = $this->get_message($o))) {
				    Logger::Out('Login required. ' . $m);
				    return false;
				} else {
				    Logger::Out('Login: Already logged in as ' . $this->login_user);
				    return true;
				}
		}
		}
	}
	/**
	 * 登录尝试
	 */
	public function login()
	{
		if (!$this->is_logged_in()) {
			$login = false;
			$login_attempts = 0;
			$refresh_captcha = true;
			do {
				Logger::Out("Login Attempts: {$login_attempts}");
				if ($refresh_captcha) {
					$decaptcha = $this->decaptcha('https://dynamic.12306.cn/otsweb/passCodeAction.do?rand=lrand', true);
					Logger::Out("Login Captcha: {$decaptcha}");
				} else {
					Logger::Out("Reuse Login Captcha: {$decaptcha}");
				}
				
				$o = '';
				$login = $this->do_login($decaptcha, $o, $refresh_captcha);
				++ $login_attempts;
				
				if ($login_attempts % 10 == 0) {
					Logger::Out("Login Sleep: 2");
					sleep(2);
				}
			} while (!$login || !$this->is_logged_in($o));
		}
		
		# 成功后先关闭curl再重开
		$this->flush_curl();
		$this->init_curl();
		
		Logger::Out('Login success.');
		return true;
	}
	/**
	 * 执行登录
	 * 
	 * @param string $decaptcha
	 */
	protected function do_login($decaptcha, &$o=null, &$refresh_captcha=true) 
	{
		if (empty($this->login_user) || empty($this->login_pass)) {
			_err('登录用户名密码未指定');
			exit;
		}
		Logger::Out("Login in as {$this->login_user}");
		$postfields = '';
		$postfields .= 'loginUser.user_name='.urlencode($this->login_user);
		$postfields .= '&nameErrorFocus=&user.password=' . urlencode($this->login_pass);
		$postfields .= '&passwordErrorFocus=&randCode='.urlencode($decaptcha);
		$postfields .= '&randErrorFocus=';
		
		curl_setopt($this->curl, CURLOPT_REFERER, 'https://dynamic.12306.cn/otsweb/loginAction.do?method=init');
		curl_setopt($this->curl, CURLOPT_URL, 'https://dynamic.12306.cn/otsweb/loginAction.do?method=login');
		curl_setopt($this->curl, CURLOPT_POST, 1);
		curl_setopt($this->curl, CURLOPT_POSTFIELDS, $postfields);
		curl_setopt($this->curl, CURLOPT_TIMEOUT, 30);
		$o = $this->exec_curl();
		
	    Logger::File('login.html', $o);
	    
        if ($this->test_403()) {
            sleep(1);
            return false;
        }
        
        if (strpos($o, 'var isLogin= false')) {
	    	if (strpos($o, '请输入正确的验证码') !== false) {
	    		$refresh_captcha = true;
	    		Logger::Out('Login failed: bad captcha');
	    	} else {
	    		$refresh_captcha = false;
	    	}
	    	
        	if (null !== ($m = $this->get_message($o))) {
	    		Logger::Out("Login failed: {$m}");
	    		if (strpos($m, '密码错误') !== false) {
	    			exit;
	    		}
        	}
        	return false;
        } else {
        	return true;
        }
	}
	/**
	 * 查询余票
	 */
	public function query_ticket()
	{
		$ret = array();
		foreach ($this->tickets_info as $k=>$row) {
			$tmp = explode('#', $row);
			Logger::Out("Query ticket[preset]: [{$k}] {$tmp[0]}({$row})");
			$ret[$k] = $tmp;
		}
		return $ret;
	}
	
	protected $station_names;
	
	public function request_station_names() 
	{
		if (!($data = cache_get('station_name'))) {	
			$url = 'https://dynamic.12306.cn/otsweb/js/common/station_name.js?rand='.mt_rand();
			curl_setopt($this->curl, CURLOPT_URL, $url);
			curl_setopt($this->curl, CURLOPT_HTTPGET, 1);
			curl_setopt($this->curl, CURLOPT_POST, 0);
			curl_setopt($this->curl, CURLOPT_TIMEOUT, 60);
			$o = $this->exec_curl();
			
			$m = array();
			if (!preg_match('#\'(.+)\'#', $o, $m)) {
				return false;
			}
			$s = explode('@', $m[1]);
			$data = array();
			foreach ($s as $_s) {
				if (!$_s) {
					continue;
				}
	
				$t = explode('|', $_s);
				$data[$t[2]] = $t;
			}
	
			cache_set('station_name', $data, 86400 * 10);
		}
		return $this->station_names = $data;
	}
	
	protected function parse_submit($o, &$refresh_captcha=false)
	{
		$refresh_captcha = false;
		if (null !== ($m = $this->get_message($o))) {
			Logger::Out('Error: ' . $m);
			if (false !== strpos($m, '验证码')) {
				$refresh_captcha = true;
            } else if (
                false === strpos($m, '提交订单用户过多')
                && false === strpos($m, '重复提交')
            ) {
				exit;
			}
		}

		return $this->get_formtoken($o);
	}
	
	public function confirm($opt)
	{
		# request for order
		$confirm = false;
		$confirm_attempts = 0;
		$refresh_captcha = true;
		$last_token = '';
		$token = '';
		
		do {
			Logger::Out("Confirm Attempts: {$confirm_attempts}");
			if ($refresh_captcha) {
				$decaptcha = $this->decaptcha('https://dynamic.12306.cn/otsweb/passCodeAction.do?rand=randp', false);
				Logger::Out("Confirm Captcha: {$decaptcha}");
			} else {
				Logger::Out("Reuse Confirm Captcha: {$decaptcha}");
			}
			if ($last_token == $token || empty($token)) {
				$token = '';
				do {
					$r = $this->fetch_incompleted();
					#$r = $this->fetch_incompleted('https://dynamic.12306.cn/otsweb/order/myOrderAction.do?method=init&showMessage=Y');
					$token = $r['token'];
					 
					if (isset($r['ticket_key'])) {
						Logger::Out("Ticket key found on incompleted order.");
						return true;
					}
				} while (!$token);
				Logger::Out("Read token from incompleted-orders");
			}
			
			$last_token = $token;
			Logger::Out("Using token: {$token}");
			$confirm = $this->do_confirm_order($opt, $token, $decaptcha, $refresh_captcha);
			
			++ $confirm_attempts;
		} while (!$confirm);
		
		return $confirm;
	}
	
	protected function do_confirm_order($req, & $token, $decaptcha, &$refresh_captcha)
	{
		# 单程票
		$url = 'https://dynamic.12306.cn/otsweb/order/confirmPassengerAction.do?method=confirmPassengerInfoSingle';
		
		# Z65#10:15#20:00#2400000Z6505#BXP#JJG#06:15#北京西#九江#302910002440458000026084200001
		$post[] = 'org.apache.struts.taglib.html.TOKEN=' . urlencode($token);
		$post[] = 'orderRequest.reserve_flag=A';
		$post[] = 'orderRequest.train_date=' . urlencode($this->train_date);
		$post[] = 'orderRequest.train_no=' . urlencode($req[3]); # 240000Z13304';
		$post[] = 'orderRequest.station_train_code=' . urlencode($req[0]); #Z133';
		$post[] = 'orderRequest.from_station_telecode=' . urlencode($req[4]); #BXP';
		$post[] = 'orderRequest.to_station_telecode=' . urlencode($req[5]); #JJG';
		$post[] = 'orderRequest.seat_type_code=';
		$post[] = 'orderRequest.ticket_type_order_num=';
		$post[] = 'orderRequest.bed_level_order_num=000000000000000000000000000000';
		$post[] = 'orderRequest.start_time=' . urlencode($req[2]); #19%3A45';
		$post[] = 'orderRequest.end_time=' . urlencode($req[6]); #06%3A09';
		$post[] = 'orderRequest.from_station_name=' . urlencode($req[7]); #%E5%8C%97%E4%BA%AC%E8%A5%BF';
		$post[] = 'orderRequest.to_station_name=' . urlencode($req[8]); #%E4%B9%9D%E6%B1%9F';
		$post[] = 'orderRequest.cancel_flag=1';
		$post[] = 'orderRequest.id_mode=Y';
		$post[] = 'randCode=' . $decaptcha;
		
		$post[] = 'checkbox0=0';
		$post[] = 'textfield=%E4%B8%AD%E6%96%87%E6%88%96%E6%8B%BC%E9%9F%B3%E9%A6%96%E5%AD%97%E6%AF%8D';
		$i = 0;
		foreach ($this->seat_detail as $s) {
			++$i;
			$post[] = 'passengerTickets='.urlencode("{$s['seat']},{$s['ticket']},{$s['name']},{$s['cardtype']},{$s['cardno']},{$s['mobileno']},Y");
			$post[] = 'oldPassengers=' . urlencode("{$s['name']},{$s['cardtype']},{$s['cardno']}");
			$post[] = "passenger_{$i}_seat={$s['seat']}";
			$post[] = "passenger_{$i}_ticket={$s['ticket']}";
			$post[] = "passenger_{$i}_name=" . urlencode($s['name']);
			$post[] = "passenger_{$i}_cardtype={$s['cardtype']}";
			$post[] = "passenger_{$i}_cardno={$s['cardno']}";
			$post[] = "passenger_{$i}_mobileno={$s['mobileno']}";
		}

		for ($c=5-$i; $c>0; $c--) {
			$post[] = 'oldPassengers=&checkbox9=Y';
		}
		$postfields = implode('&', $post);
		
		Logger::Out("post fields: {$postfields}");
		curl_setopt($this->curl, CURLOPT_URL, $url);
		curl_setopt($this->curl, CURLOPT_POST, 1);
		curl_setopt($this->curl, CURLOPT_POSTFIELDS, $postfields);
		curl_setopt($this->curl, CURLOPT_REFERER, 'https://dynamic.12306.cn/otsweb/order/confirmPassengerAction.do?method=init');
		curl_setopt($this->curl, CURLOPT_TIMEOUT, 180);
		
		$o = $this->exec_curl();
		$msg = $this->get_message($o);
		$refresh_captcha = false;
		if ($msg) {
			Logger::Out("Message: {$msg}");
			if (strpos($msg, '验证码') !== false) {
				$refresh_captcha = true;
			}
		}
		# 验证码策略改了
		$refresh_captcha = true;
		
		if (strpos($o, '席位已成功锁定')) {
			Logger::File('cfm_success.txt', $o);
			Logger::Out('Done: 支付去吧');
			return $o;
		} else if (strpos($msg, '未处理的订单') !== false) {
			MessageBox::msgbox('有未支付订单');
			return $o;
		} else {
			Logger::File('cfm_fail.txt', $o);
			$token = $this->get_formtoken($o);
			return false;
		}
	}
	
	protected function fetch_incompleted($url = null)
	{
		$referer = 'https://dynamic.12306.cn/otsweb/loginAction.do?method=initForMy12306';

		if ($url === null) {
			$url = 'https://dynamic.12306.cn/otsweb/order/myOrderAction.do?method=queryMyOrderNotComplete';
		}
		curl_setopt($this->curl, CURLOPT_URL, $url);
		curl_setopt($this->curl, CURLOPT_REFERER, $referer);
		curl_setopt($this->curl, CURLOPT_POST, 0);
		curl_setopt($this->curl, CURLOPT_HTTPGET, 1);
		curl_setopt($this->curl, CURLOPT_TIMEOUT, 60);
		
		$o = $this->exec_curl();
		Logger::File('incompleted.html', $o);

		$m = array();
		if (preg_match('#cancelOrder\(\'(.+)\'\)#', $o, $m)) {
			$ret = array();
			$ret['seq'] = $m[1];
			preg_match('#value="('.$ret['seq'].'.+)"#', $o, $m);
			$ret['ticket_key'] = $m[1];
			$ret['token'] = $this->get_formtoken($o);
			return $ret;
		} else if (null === ($m = $this->get_message($o))) {
			return array(
				'token'	=>	$this->get_formtoken($o),
			);
		} else {
			Logger::Out('Read incompleted order failed');
			usleep(300000);
			return $this->fetch_incompleted();
		}
	}
	
	public function pay_order()
	{
	    $ret = $this->fetch_incompleted();
	    if (!isset($ret['ticket_key']) || empty($ret['ticket_key'])) {
	    	Logger::Out('Error: 没有待支付订单');
	    	exit;
	    }
	    $url = 'https://dynamic.12306.cn/otsweb/order/myOrderAction.do?method=laterEpay&orderSequence_no=' . urlencode($ret['seq']) . '&con_pay_type=epay';
	    
	    $postfields = 'queryOrderDTO.from_order_date=&queryOrderDTO.to_order_date=';
	    $postfields .= '&org.apache.struts.taglib.html.TOKEN='.urlencode($ret['token']);
	    $postfields .= '&ticket_key='.urlencode($ret['ticket_key']);
	
	    curl_setopt($this->curl, CURLOPT_URL, $url);
	    curl_setopt($this->curl, CURLOPT_POST, 1);
	    curl_setopt($this->curl, CURLOPT_POSTFIELDS, $postfields);
	    curl_setopt($this->curl, CURLOPT_TIMEOUT, 60);
	    
	    $o = $this->exec_curl();
	    Logger::File('pay_order.txt', $o);
	    
	    if (!strpos($o, '席位已成功锁定')) {
	    	$m = $this->get_message($o);
	    	Logger::Out('Pay order: 支付失败，重试中...' . $m);
	    	usleep(500000);
	    	return $this->pay_order();
	    }
	    $m = array();
	    if (preg_match('#<form id="epayForm".+</form>#sU', $o, $m)) {
			$pay_script = <<<HTML
<script type="text/javascript">
function pay() {
	var form =document.getElementById("epayForm");
	    form.submit();
	}
pay();
</script>
HTML;
	    	Logger::File('payorder.html', $m[0] . $pay_script);
			
			Logger::Out('Trying to popup browser');
			 
			$cmd = $this->browser_path.' '.getcwd().'/payorder.html';
			system($cmd);
			exit;
	    } else {
	    	Logger::Out('Pay error: 无法找到支付表单');
	    	return $this->pay_order();
	    }
	    
	    $token = $this->get_formtoken($o);
	    $seq   = $this->get_sequence_no($o);
	    $batch_no = '1#';
	
	    $postfields = '';
	    $postfields .= 'org.apache.struts.taglib.html.TOKEN='.urlencode($token);
	    $postfields .= '&sequence_no='.urlencode($seq);
	    $postfields .= '&batch_no='.urlencode($batch_no);
	    
	    $url = 'https://dynamic.12306.cn/otsweb/order/payConfirmOnlineSingleAction.do?method=payConfirmOnlineSingleEPay';
	    curl_setopt($this->curl, CURLOPT_URL, $url);
	    curl_setopt($this->curl, CURLOPT_POST, 1);
	    curl_setopt($this->curl, CURLOPT_POSTFIELDS, $postfields);
	    
	    $o = $this->exec_curl();
	    Logger::File('pay_order_2.html', $o);
	
	    if (!strpos($o, 'interfaceName')) {
	    	Logger::Out('Pay order: 支付请求提交失败，重试中...' );
	    	return $this->pay_order();
	    }
	    Logger::Out('Trying to popup browser');
	    
	    $cmd = $this->browser_path.' '.getcwd().'/pay_order_2.html';
	    system($cmd);
	    exit;
	}
	
	public function simple_pay($ticket_key, $sequence_no, $batch_no='1#')
	{
		$token = '';
		do {
			#$r = $this->fetch_incompleted();
			$r = $this->fetch_incompleted('https://dynamic.12306.cn/otsweb/order/myOrderAction.do?method=init&showMessage=Y');
			$token = $r['token']; 
		} while (!$token);
		
		$postfields = '';
		$postfields .= 'org.apache.struts.taglib.html.TOKEN='.urlencode($token);
		$postfields .= '&sequence_no='.urlencode($sequence_no);
		$postfields .= '&batch_no='.urlencode($batch_no);
		 
		$url = 'https://dynamic.12306.cn/otsweb/order/payConfirmOnlineSingleAction.do?method=payConfirmOnlineSingleEPay';
		curl_setopt($this->curl, CURLOPT_URL, $url);
		curl_setopt($this->curl, CURLOPT_POST, 1);
		curl_setopt($this->curl, CURLOPT_POSTFIELDS, $postfields);
		
		
		$o = $this->exec_curl();
		Logger::File('pay_order_2.html', $o);
		
		if (!strpos($o, 'interfaceName')) {
			Logger::Out('Pay order: 支付请求提交失败，重试中...' );
			return $this->simple_pay($ticket_key, $sequence_no, $batch_no);
		}
		Logger::Out('Trying to popup browser');
		 
		$cmd = $this->browser_path.' '.getcwd().'/pay_order_2.html';
		system($cmd);
		exit;
	}
	
	public function cancel_order()
	{
		$ret = $this->fetch_incompleted();
		if (!isset($ret['ticket_key']) || empty($ret['ticket_key'])) {
			Logger::Out('Error: 没有待支付订单');
			exit;
		}
		$url = 'https://dynamic.12306.cn/otsweb/order/orderAction.do?method=cancelMyOrderNotComplete';
		$postfields = '';
		$postfields .= 'org.apache.struts.taglib.html.TOKEN='.urlencode($ret['token']);
		$postfields .= '&sequence_no='.urlencode($ret['seq']);
		
		curl_setopt($this->curl, CURLOPT_URL, $url);
		curl_setopt($this->curl, CURLOPT_POST, 1);
		curl_setopt($this->curl, CURLOPT_POSTFIELDS, $postfields);
		curl_setopt($this->curl, CURLOPT_TIMEOUT, 60);
		
		$o = $this->exec_curl();
		Logger::File('cancel.txt', $o);
		
		if (null === ($m = $this->get_message($o)) || false === strpos($m, '成功')) {
			Logger::Out('Cancel Order Failed: ' . $m);
			exit;
		} else {
			Logger::Out('Cancel Order: ' . $m);
		}
		usleep(500000);
	}
}


function stdin()
{
	$opt = fgets(STDIN);
	$opt = strtoupper(trim($opt));
	if ($opt === 'X' || $opt === ':X') {
		exit;
	} else if ($opt === ':MOFF') {
		MessageBox::moff();
	} else if ($opt === ':MON') {
		MessageBox::mon();
	}
	return $opt;
}

class Logger
{
	static public function File($file, $content)
	{
		return file_put_contents($file, $content);
	}
	
	static public function Out($msg)
	{
		$msg = date('[H:i:s] ') . trim($msg) . "\r\n";
		file_put_contents('_log_out.txt', $msg, FILE_APPEND);
		return fwrite(
			STDOUT, 
			iconv('UTF-8', 'GBK', $msg)
		);
	}
	
	static public function Err($msg)
	{
		$msg = date('[H:i:s] ') . trim($msg) . "\r\n";
		file_put_contents('_log_err.txt', $msg, FILE_APPEND);
		return fwrite(
			STDERR, 
			iconv('UTF-8', 'GBK', $msg)
		);
	}
}

class MessageBox
{
	static public function msgbox($message)
	{
		if (PHP_OS == 'WINNT' && self::$on) {
			system(__DIR__ . '/messagebox.vbs "' . iconv('utf-8', 'gbk', $message) . '"');
		}
	}

	static protected $on = true;

	static public function mon()
	{
		self::$on = true;
	}

	static public function moff()
	{
		self::$on = false;
	}
}

function cache_set($key, $val, $expire=864000)
{
	$f = cache_file($key);
	return file_put_contents(
		$f,
		serialize(array(
			'expire'	=>  time() + $expire,
			'data'	  =>  $val,
		))
	);
}

function cache_get($key)
{
	$f = cache_file($key);
	if (!is_file($f)) {
		return false;
	}
	$d = unserialize(file_get_contents($f));

	if ($d['expire'] < time()) {
		return false;
	} else {
		return $d['data'];
	}
}

function cache_file($key)
{
	if (!is_dir(__DIR__ . '/caches')) {
		mkdir(__DIR__ . '/caches');
	}

	return realpath(__DIR__ . '/caches/c_' . strval($key));
}

# EOF