Light12306/Web12306/js/otn/queryticket.js

define(function (require, exports, module) {
	var ajax = require("../platform/webRequest.js");
	var param = require("../data.js");
	var parser = require("../platform/parser.js");
	var ev = require("../platform/EventObject.js");

	var extensionVersion = parseInt(document.body.dataset["targetExtensionVersion"].replace(/\./g, ""));

	exports.events = new ev();

	//记录参数
	var queryTicketUrl = null;
	var lastLogTime = null;
	var isLogOpen = false;

	var getTicketInfo = function (v) {
		var data = [], info = v.indexOf("#") === -1 ? v : /getSelected\(['"](.*?)['"]\)/i.exec(v)[1].split('#')[11],
			match = info.match(/([A-Z\d])0*?([\*\d]{5})0*?(\d{4})/gi);

		for (var j in match) {
			var m = /([A-Z\d])0*?([\*\d]{5})0*?(\d{4})/i.exec(match[j]);
			var sc = m[1];
			var sp = m[2][0] == '*' ? null : parseInt(m[2], 10);
			var st = parseInt(m[3], 10);
			var seat = { code: sc, name: param.toSeatTypeName(sc), price: sp, selected: false };
			if (st < 3000) {
				seat.count = st;

				//TODO 二等软座提交是否和二等座一样都用的MO？
				//一等软座 7， 二等软座 8
				if (sc === "7") {
					data.push({ code: 'M', name: param.toSeatTypeName('M'), price: sp, count: st, selected: false });
				}
				else if (sc === "8") {
					data.push({ code: 'O', name: param.toSeatTypeName('O'), price: sp, count: st, selected: false });
				} else {
					data.push(seat);
				}
			} else {
				seat.count = st - 3000;
				seat.code = '0';
				seat.name = "无座";
				data.push(seat);
			}
		};
		return data;
	};

	var transferData = function (date, data, noProcess, noAction) {
		var result = data;
		if (!Array.isArray(result.data) || !result.data.length || !result.data[0].queryLeftNewDTO) {
			exports.events.fireEvent("requestFailed");
		};

		var trainData = { raw: result, rawTrainMap: {}, trainMap: {}, auto: null, nextTime: null, noProcess: noProcess, noAction: noAction };

		_.each(result.data, function (t) {
			var train = {
				id: t.queryLeftNewDTO.train_no,
				code: t.queryLeftNewDTO.station_train_code,
				available: t.queryLeftNewDTO.canWebBuy === 'Y' ? 1 : 0,
				start: {
					code: t.queryLeftNewDTO.start_station_telecode,
					name: t.queryLeftNewDTO.start_station_name,
				},
				from: {
					code: t.queryLeftNewDTO.from_station_telecode,
					fromStationNo: t.queryLeftNewDTO.from_station_no,
					name: t.queryLeftNewDTO.from_station_name,
					endpoint: t.queryLeftNewDTO.from_station_telecode == t.queryLeftNewDTO.start_station_telecode,
					time: t.queryLeftNewDTO.start_time
				},
				to: {
					code: t.queryLeftNewDTO.to_station_telecode,
					toStationNo: t.queryLeftNewDTO.to_station_no,
					name: t.queryLeftNewDTO.to_station_name,
					endpoint: t.queryLeftNewDTO.end_station_telecode == t.queryLeftNewDTO.to_station_telecode,
					time: t.queryLeftNewDTO.arrive_time
				},
				elapsedTime: {
					days: t.queryLeftNewDTO.day_difference,
					total: t.queryLeftNewDTO.lishi
				},
				end: {
					code: t.queryLeftNewDTO.end_station_telecode,
					name: t.queryLeftNewDTO.end_station_name,
				},
				ypinfo: t.queryLeftNewDTO.yp_info,
				ypinfo_ex: t.queryLeftNewDTO.yp_ex,
				locationCode: t.queryLeftNewDTO.location_code,
				controlDay: t.queryLeftNewDTO.control_day,
				supportCard: t.queryLeftNewDTO.is_support_card,
				saleTime: t.queryLeftNewDTO.sale_time,
				secureStr: t.secretStr,
				selltime: null,
				date: date,
				limitSellInfo: t.buttonTextInfo && t.buttonTextInfo.indexOf("暂售") != -1 ? t.buttonTextInfo.replace(/<[^>]+>/i, "") : null
			};
			var kp = getTicketInfo(t.queryLeftNewDTO.yp_info);
			train.tickets = kp;
			train.ticketMap = _.mapObject(kp, function (e) { return e.code; });

			//起售时间
			var selltimem = /(0*(\d+)月0*(\d+)日)?(\d+)\s*点\s*((\d+)分)?\s*起售/i.exec(t.buttonTextInfo.replace(/<.*?>/g, ''));
			if (selltimem) {
				train.available = -1;
				train.selltime = new Date();
				train.selltime.setHours(parseInt(selltimem[4]));
				train.selltime.setMinutes(parseInt(selltimem[6] || "0", 10));
				train.selltime.setSeconds(0);
				if (selltimem[1]) {
					//带日期
					train.selltime.setMonth(parseInt(selltimem[2]) - 1);
					train.selltime.setDate(parseInt(selltimem[3]));
					if (train.selltime.getMonth() < new Date().getMonth()) {
						train.selltime.setFullYear(train.selltime.getFullYear() + 1);
					}
				}
			}

			trainData.rawTrainMap[train.id] = t;
			trainData.trainMap[train.id] = train;
		});
		trainData.original = _.values(trainData.trainMap);
		trainData.available = trainData.original;
		trainData.trainCodes = _.pluck(trainData.original, "code");
		trainData.filtered = [];
		trainData.include = trainData.available;

		if (!noProcess) {
			//执行车次预过滤。过滤内容：出发地，目标地，时间
			exports.events.fireEvent("filterTrains", trainData);
			//处理车次
			exports.events.fireEvent("processTrains", trainData);

			//过滤数据
			if (trainData.filtered && trainData.filtered.length) {
				//从原始数据中删除
				var orgMap = _.mapObject(result.data, function (e) {
					return e.queryLeftNewDTO.train_no;
				});
				var filtered = _.map(trainData.filtered, function (t) {
					return orgMap[t.id];
				});
				trainData.rawDataFiltered = _.without.apply(null, [result.data].concat(filtered));
				result.data = trainData.rawDataFiltered;
			}
		}

		return trainData;
	};

	exports.queryTicket = function (from, fromName, to, toName, date, student, resign, noProcess, noAction) {
		var def = new $.Deferred();
		var queryCount = 0;

		def.fail(function () {
			exports.events.fireEvent("requestFailed");
		});

		var sendQueryRequest = function () {
			var p = {
				"leftTicketDTO.train_date": date,
				"leftTicketDTO.from_station": from,
				"leftTicketDTO.to_station": to,
				"purpose_codes": student ? "0X00" : "ADULT"
			};
			var cookie = (function (obj) {
				var arr = [];
				_.forEach(obj, function (v, k) { arr.push(k + '=' + v); });
				return arr.join("; ");
			})(extensionVersion >= 720 ? {
				"_jc_save_fromStation": escape(fromName + "," + from),
				"_jc_save_toStation": escape(toName + "," + to),
				"_jc_save_fromDate": date,
				"_jc_save_toDate": date,
				"_jc_save_wfdc_flag": resign ? "gc" : "dc"
			} : {});
			if (isLogOpen) {
				exports.log(p, cookie);
			}
			ajax.sendGet(queryTicketUrl, "leftTicket/init", p, "json", function () {
				//url changed?
				if (!this.model.status && this.model.c_url) {
					queryTicketUrl = this.model.c_url;
					sendQueryRequest();
				} else if (!this.model.status) {
					var error = (this.model.messages || ["查询失败"]).join("");
					def.reject(error);
				} else {
					var data = transferData(date, this.model, noProcess, noAction);
					def.resolveWith(data);
				}
			}, function () {
				if (queryCount++ < 5) {
					def.notify("无法访问12306，正在第 " + queryCount + " 次重试...");
					setTimeout(sendQueryRequest, 2000);
				} else {
					def.reject("重试次数过多，请重新点击查询按钮");

				}
			}, false, {
				"Cookie": cookie,
				"If-Modified-Since": "0"
			});
		};
		var fetchTicketUrl = function () {
			ajax.sendGet("leftTicket/init", "/otn/", null, "text")
				.done(function () {
					var html = this.model;

					var r = /(CLeftTicketUrl|isSaveQueryLog)\s*=\s*['"]([^'"]+)['"]/gi;
					var m;
					while (m = r.exec(html)) {
						if (m[1] === "CLeftTicketUrl")
							queryTicketUrl = m[2];
						else if (m[1] === "isSaveQueryLog")
							isLogOpen = m[2] === "Y";
					}
					if (!queryTicketUrl) {
						document.dispatchEvent(new CustomEvent("platformError"));
						def.reject("未能初始化查询地址");
					}
					else sendQueryRequest();
				}).fail(function () {
					def.reject("网络错误");
				});
		};
		if (queryTicketUrl) {
			sendQueryRequest();
		}
		else {
			fetchTicketUrl();
		}

		return def.promise();
	};

	exports.log = function (data, cookies) {
		if (!isLogOpen || (lastLogTime && (new Date() - lastLogTime) < 5000))
			return;
		lastLogTime = new Date();
		ajax.sendGet("leftTicket/log", "leftTicket/init", data, "json", function () {

		}, function () {

		}, false, {
			"Cookie": cookies
		});
	};

	exports.queryTrainStop = function (id, from, to, date) {
		var data = {
			train_no: id,
			from_station_telecode: from,
			to_station_telecode: to,
			depart_date: date
		};
		var def = new $.Deferred();
		ajax.sendGet("czxx/queryByTrainNo", "leftTicket/init", data, "json", function (json) {
			if (!json || !json.data || !json.data.data) {
				def.reject((parser.getError(json) || { message: "查询失败" }).message);
			} else {
				def.resolve(json.data.data);
			}
		}, function () {
			def.reject("网络错误");
		});

		return def.promise();
	};
});