12306火车时刻表查询接口

摘要

本文讲解12306网站接口查询火车时刻表信息
接口中用到的方法在文章最后

一、 根据车次查询内部火车编号

接口：https://search.12306.cn/search/v1/train/search
参数： keyword， date
请求类型： GET

/**
 * 根据车次名称查询列车编号
 * @param keyword 车次名
 * @param date 发车日期 (格式: yyyyMMdd)
 */
private List<TrainInfo> searchTrainInfos(String keyword, String date) {
	date = checkTrainSearchDate(date, "yyyyMMdd")
    String response = HttpUtils.sendGet("https://search.12306.cn/search/v1/train/search",
    		"keyword=" + keyword.trim() + "&date=" + date);
    JSONObject object = new JSONObject(response);
    if (object.optBoolean("status")) {
        JSONArray data = object.optJSONArray("data");
        if (data != null) {
            return JSON.parseArray(data.toString(), TrainInfo.class);
        }
    }
    throw new RuntimeException("未查询到车次信息. " + object.optString("errorMsg"));
}

列车信息实体类 TrainInfo

import com.fasterxml.jackson.annotation.JsonProperty;
import lombok.Data;

import java.io.Serializable;

/**
 * 车次信息
 */
@Data
public class TrainInfo implements Serializable {
    private String date ;

    @JsonProperty(value = "from_station")
    private String fromStation ;

    @JsonProperty(value = "station_train_code")
    private String stationTrainCode ;

    @JsonProperty(value = "to_station")
    private String toStation ;

    @JsonProperty(value = "total_num")
    private String totalNum ;

    @JsonProperty(value = "train_no")
    private String trainNo ;
}

二、 根据列车编号查询时刻表信息

接口：https://kyfw.12306.cn/otn/queryTrainInfo/query
参数： trainNo， date
请求类型： GET

/**
 * 根据列车编号查询时刻表信息
 * @param trainNo 列车编号, 是上面接口返回数据中心的train_no
 * @param date 查询日期 (格式: yyyy-MM-dd)
 */
private List<TrainStation> searchTrainStations(String trainNo, String date) {
    if (StringUtils.isBlank(trainNo)) {
        throw new RuntimeException("未查询到相关列车信息");
    }
    date = checkTrainSearchDate(date, "yyyy-MM-dd");
    String response = HttpUtils.sendGet("https://kyfw.12306.cn/otn/queryTrainInfo/query",
            "leftTicketDTO.train_no="+ trainNo +"&leftTicketDTO.train_date="+date +"&rand_code=");
    JSONObject object = new JSONObject(response);
    if (object.optBoolean("status")) {
        JSONObject jsonObject = object.optJSONObject("data");
        if (jsonObject != null) {
            JSONArray array = jsonObject.optJSONArray("data");
            if (array != null) {
                List<TrainStation> list = JSON.parseArray(array.toString(), TrainStation.class);
                TrainStation station = list.get(0);
                list.forEach(i -> {
                    i.setStartStationName(station.getStartStationName());
                    i.setEndStationName(station.getEndStationName());
                    i.setTrainClassName(station.getTrainClassName());
                });
                return list;
            }
        }
    }
    throw new RuntimeException("未查询到相关列车信息. " + JSON.toJSONString(object.opt("messages")));
}

列车到站时刻详情

import com.fasterxml.jackson.annotation.JsonProperty;
import lombok.Data;

import java.io.Serializable;
import java.util.List;

/**
 * 列车到站时刻详情
 * @author xyang
 * @date 2021-08-02 9:15
 */
@Data
public class TrainStation implements Serializable {
    /** 车站名称 */
    @JsonProperty(value = "station_name")
    private String stationName;

    /** 列车类型 */
    @JsonProperty(value = "train_class_name")
    private String trainClassName;

    /** 是否起始站 (y/n)*/
    @JsonProperty(value = "is_start")
    private String isStart;

    @JsonProperty(value = "service_type")
    private String serviceType;

    /** 起始站点名称 */
    @JsonProperty(value = "start_station_name")
    private String startStationName;

    /** 终点站名称 */
    @JsonProperty(value = "end_station_name")
    private String endStationName;

    /** 发车时间 */
    @JsonProperty(value = "start_time")
    private String startTime;

    /** 到站时间 */
    @JsonProperty(value = "arrive_time")
    private String arriveTime;

    /** 车次编号 */
    @JsonProperty(value = "station_train_code")
    private String stationTrainCode;

    /** 到站顺序 */
    @JsonProperty(value = "station_no")
    private String stationNo;

    @JsonProperty(value = "wz_num")
    private String wzNum;

    /** 到站历时天数 (0:当天, 1:次日, 2:第三日, ....) */
    @JsonProperty(value = "arrive_day_diff")
    private Integer arriveDayDiff;

    /** 历时时长 */
    @JsonProperty(value = "running_time")
    private String runningTime;

    /** 历时 (当日到达, 次日到达...)*/
    @JsonProperty(value = "arrive_day_str")
    private String arriveDayStr;

    @JsonProperty(value = "OT")
    private List<Object> ot;
}

其他

时间校验 checkTrainSearchDate

/**
 * 校验时间格式是否正确, 并将字符串转为日期(防止日期格式未按要求)
 * @param date 日期字符串
 * @param format 描述日期和时间格式的模式
 */
private String checkTrainSearchDate(String date, String format) {
    if(StringUtils.isBlank(date)) {
        throw new RuntimeException("查询日期不能为空!");
    }
    if(StringUtils.isBlank(format)) {
        throw new RuntimeException("日期格式化参数错误!");
    }
    Date parseDate = DateUtils.parseDate(date);
    if (parseDate == null) {
        throw new RuntimeException("查询日期格式校验错误!");
    }

    if (DateUtils.truncatedCompareTo(parseDate, new Date(), Calendar.DATE) < 0) {
        throw new RuntimeException("查询日期不能早于当前日期");
    }
    return DateUtils.dateFormat(parseDate, format);
}

时间工具类 DateUtils

// 时间工具类
public class DateUtils extends org.apache.commons.lang3.time.DateUtils {
	public static String YYYY = "yyyy";
    public static String YYYY_MM = "yyyy-MM";
    public static String YYYY_MM_DD = "yyyy-MM-dd";
    public static String YYYYMMDDHHMMSS = "yyyyMMddHHmmss";
    public static String YYYY_MM_DD_HH_MM_SS = "yyyy-MM-dd HH:mm:ss";

    private static String[] parsePatterns = {
            "yyyy-MM-dd", "yyyy-MM-dd HH:mm:ss", "yyyy-MM-dd HH:mm", "yyyy-MM",
            "yyyy/MM/dd", "yyyy/MM/dd HH:mm:ss", "yyyy/MM/dd HH:mm", "yyyy/MM",
            "yyyy.MM.dd", "yyyy.MM.dd HH:mm:ss", "yyyy.MM.dd HH:mm", "yyyy.MM"};

	/**
     * 格式化日期
     */
	public static String dateFormat(Date date,String format) {
        try {
            SimpleDateFormat simpleDateFormat = new SimpleDateFormat(format);
            if(ObjectUtils.isEmpty(date)){
                date = new Date();
            }
            return simpleDateFormat.format(date);
        }catch (Exception e){
            e.printStackTrace();
            throw new RuntimeException("日期格式化失败");
        }
    }
    
	/**
     * 日期型字符串转化为日期 格式
     */
    public static Date parseDate(Object str) {
        if (str == null) {
            return null;
        }
        try{
            return parseDate(str.toString(), parsePatterns);
        }
        catch (ParseException e){
            return null;
        }
    }
}

**通用http发送方法 HttpUtils **

import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.PrintWriter;
import java.net.ConnectException;
import java.net.SocketTimeoutException;
import java.net.URL;
import java.net.URLConnection;
import java.nio.charset.StandardCharsets;

/**
 * 通用http发送方法
 *
 * @author ruoyi
 */
public class HttpUtils {
    private static final Logger log = LoggerFactory.getLogger(HttpUtils.class);

    /**
     * 向指定 URL 发送GET方法的请求
     *
     * @param url   发送请求的 URL
     * @param param 请求参数，请求参数应该是 name1=value1&name2=value2 的形式。
     * @return 所代表远程资源的响应结果
     */
    public static String sendGet(String url, String param) {
        return sendGet(url, param, "UTF-8");
    }

    /**
     * 向指定 URL 发送GET方法的请求
     *
     * @param url         发送请求的 URL
     * @param param       请求参数，请求参数应该是 name1=value1&name2=value2 的形式。
     * @param contentType 编码类型
     * @return 所代表远程资源的响应结果
     */
    public static String sendGet(String url, String param, String contentType) {
        StringBuilder result = new StringBuilder();
        BufferedReader in = null;
        try {
            String urlNameString = url + "?" + param;
            log.info("sendGet - {}", urlNameString);
            URL realUrl = new URL(urlNameString);
            URLConnection connection = realUrl.openConnection();
            connection.setRequestProperty("accept", "*/*");
            connection.setRequestProperty("connection", "Keep-Alive");
            connection.setRequestProperty("user-agent", "Mozilla/4.0 (compatible; MSIE 6.0; Windows NT 5.1;SV1)");
            connection.connect();
            in = new BufferedReader(new InputStreamReader(connection.getInputStream(), contentType));
            String line;
            while ((line = in.readLine()) != null) {
                result.append(line);
            }
            log.info("recv - {}", result);
        } catch (ConnectException e) {
            log.error("调用HttpUtils.sendGet ConnectException, url=" + url + ",param=" + param, e);
        } catch (SocketTimeoutException e) {
            log.error("调用HttpUtils.sendGet SocketTimeoutException, url=" + url + ",param=" + param, e);
        } catch (IOException e) {
            log.error("调用HttpUtils.sendGet IOException, url=" + url + ",param=" + param, e);
        } catch (Exception e) {
            log.error("调用HttpsUtil.sendGet Exception, url=" + url + ",param=" + param, e);
        } finally {
            try {
                if (in != null) {
                    in.close();
                }
            } catch (Exception ex) {
                log.error("调用in.close Exception, url=" + url + ",param=" + param, ex);
            }
        }
        return result.toString();
    }

    /**
     * 向指定 URL 发送POST方法的请求
     *
     * @param url   发送请求的 URL
     * @param param 请求参数，请求参数应该是 name1=value1&name2=value2 的形式。
     * @return 所代表远程资源的响应结果
     */
    public static String sendPost(String url, String param) {
        PrintWriter out = null;
        BufferedReader in = null;
        StringBuilder result = new StringBuilder();
        try {
            log.info("sendPost - {}", url);
            URL realUrl = new URL(url);
            URLConnection conn = realUrl.openConnection();
            conn.setRequestProperty("accept", "*/*");
            conn.setRequestProperty("connection", "Keep-Alive");
            conn.setRequestProperty("user-agent", "Mozilla/4.0 (compatible; MSIE 6.0; Windows NT 5.1;SV1)");
            conn.setRequestProperty("Accept-Charset", "utf-8");
            conn.setRequestProperty("contentType", "utf-8");
            conn.setDoOutput(true);
            conn.setDoInput(true);
            out = new PrintWriter(conn.getOutputStream());
            out.print(param);
            out.flush();
            in = new BufferedReader(new InputStreamReader(conn.getInputStream(), StandardCharsets.UTF_8));
            String line;
            while ((line = in.readLine()) != null) {
                result.append(line);
            }
            log.info("recv - {}", result);
        } catch (ConnectException e) {
            log.error("调用HttpUtils.sendPost ConnectException, url=" + url + ",param=" + param, e);
        } catch (SocketTimeoutException e) {
            log.error("调用HttpUtils.sendPost SocketTimeoutException, url=" + url + ",param=" + param, e);
        } catch (IOException e) {
            log.error("调用HttpUtils.sendPost IOException, url=" + url + ",param=" + param, e);
        } catch (Exception e) {
            log.error("调用HttpsUtil.sendPost Exception, url=" + url + ",param=" + param, e);
        } finally {
            try {
                if (out != null) {
                    out.close();
                }
                if (in != null) {
                    in.close();
                }
            } catch (IOException ex) {
                log.error("调用in.close Exception, url=" + url + ",param=" + param, ex);
            }
        }
        return result.toString();
    }

}