zoukankan      html  css  js  c++  java
  • 初探12306售票算法(一)- 理论(转)

    1.以G71列车为例,首先对车次站台进行占位编码(从1开始到最后一站递加)

           

       对以上占位简单描述以下:G71总共18个站点那么我们的单个座位的座位标识可以用十八位长度的二进制字符串表示10000000000000000每一位代表一个站点,每天放票前初始化到下面的订票表中,数据如下余票根据座位标识中的0的个数决定最大余票数量

     订票表中的始发受限站点和终到受限站点可以灵活搭配(这个就可以实现限制站点发售)

     限售渠道十进制 7 代表 1(车站)| 2(互联网)|4(电话)=7 即该票允许  车站, 互联网, 电话同时出售

        那么还可以是 1|4 = 5  即该票只接受在车站和电话预定

       扩展 8(代售点) 16 (手机端) 

    2.查询余票

    如果我们要用互联网渠道查询日期为2016-06-11,始发站保定东站(3)到韶关站(15)的G71二等座F座位余票情况只需要执行如下sql(该SQL可以实现选座位和选车厢等功能)

    复制代码
    select GUID,车次编码,车次类型,座位类型,车厢号码,座位编码,座位位置,车票版本号 from 订票表
    where  座位标识=~((~坐标标识)|000111111111111000)
    and 发车日期='2016-06-11'
    and 车次编码='G71'
    and 始发受限车站=始发受限车站|000100000000000000
    and 终到受限车站=终到受限车站|000000000000001000
    and 车次类型='二等座'
    and 座位位置='F'
    and 受限渠道=2|受限渠道
    order by 余票数量 asc ,车厢 asc --先卖余票少的,防止打乱更多的长途票
    复制代码

    3.预定票

      3.1根据第二步中查询条件获取一条记录然后将车票状态改为锁定

      3.2待锁定成功后进行支付

         

    update 订票表 set 座位标识=座位标识 | 000111111111111000,车票版本号=车票版本号+1,余票数量 = 余票数量-(15-3)
          where GUID = Md5(车次+座位编码+发车日期) and 座位标识=~((~坐标标识)|000111111111111000)--乐观锁
    
            根据更新结果是否为1则可以判定购票成功

      3.2支付成功后然后将保定到韶关的票保存到另外一张客户的车票表中

      3.3如果指定时间没有支付,那么直接调用退票sql

    4.退票

      获得该车次保定到韶关的票 (000111111111111000)与对应的票进行异或^运算,则即可回归票池子了

    5.选座

          

    update 订票表 set 座位标识=座位标识 ^000111111111111000,余票数量 = 余票数量+(15-3),车票版本号=车票版本号+1 where GUID = Md5(车次+座位编码+发车日期)  and 车票版本号=取得的版本号 --乐观锁
    
    
          根据返回结果为1则标识退票成功

    以下为相关java代码 

    复制代码
      1 import java.math.BigDecimal;
      2 
      3 public class MainTest {
      4     public static void main(String[] args) {
      5         String ticketFlag = "100000000000000000";
      6         int beginStation = 3;
      7         int endStation = 15;
      8         long beginTime = System.currentTimeMillis();
      9         String result = orderTicket(ticketFlag, beginStation, endStation);
     10         if (result.equals(ticketFlag)) {
     11             System.out.println("订票失败");
     12         } else {
     13             System.out.println("订票后的结果:" + result);
     14             // 如果要取消的话,就进行这个操作
     15             String b = buildTicket(ticketFlag.length(), beginStation,
     16                     endStation);
     17             System.out.println("释放后的结果:" + releaseTicket(ticketFlag, b));
     18 
     19         }
     20         long endTime = System.currentTimeMillis();
     21         System.out.println("耗时:" + (endTime - beginTime));
     22     }
     23 
     24     /**
     25      * 订票
     26      * 
     27      * @param ticketFlag
     28      * @param beginStation
     29      * @param endStation
     30      * @return
     31      */
     32     private static String orderTicket(String ticketFlag, int beginStation,
     33             int endStation) {
     34         String result = "";
     35         if (checkCanTicket(ticketFlag, beginStation, endStation)) {
     36             String b = buildTicket(ticketFlag.length(), beginStation,
     37                     endStation);
     38 
     39             String currentTicked = toTicket(ticketFlag, b);
     40             System.out.println("预占票前结果:" + ticketFlag);
     41             result = currentTicked;
     42         } else {
     43             result = ticketFlag;
     44         }
     45         ;
     46         return result;
     47     }
     48 
     49     /**
     50      * 取消已定票
     51      * 
     52      * @param ticketFlag
     53      * @param b
     54      * @return
     55      */
     56     private static String releaseTicket(String ticketFlag, String b) {
     57         StringBuilder tempSt = new StringBuilder("");
     58         int length = ticketFlag.length();
     59         for (int i = 0; i < length; i++) {
     60             char tempA = ticketFlag.charAt(i);
     61             char tempB = b.charAt(i);
     62             if (tempA == '1' && tempB == '1') {
     63                 tempSt.append("0");
     64             } else {
     65                 tempSt.append(tempA);
     66             }
     67         }
     68         return tempSt.toString();
     69     }
     70 
     71     /**
     72      * 创建区间占位票
     73      * 
     74      * @param length
     75      * @param beginStation
     76      * @param endStation
     77      * @return
     78      */
     79     private static String buildTicket(int length, int beginStation,
     80             int endStation) {
     81         StringBuilder st = new StringBuilder("");
     82         for (int i = 0; i < length; i++) {
     83             if (i >= beginStation && i < endStation) {
     84                 st.append("1");
     85             } else {
     86                 st.append("0");
     87             }
     88         }
     89         System.out.println("创建区间票:" + st.toString());
     90         return st.toString();
     91     }
     92 
     93     /**
     94      * 生成订票后的结果
     95      * 
     96      * @param ticketFlag
     97      * @param b
     98      * @return
     99      */
    100     private static String toTicket(String ticketFlag, String b) {
    101         StringBuilder tempSt = new StringBuilder("");
    102         int length = ticketFlag.length();
    103         for (int i = 0; i < length; i++) {
    104             char tempA = ticketFlag.charAt(i);
    105             char tempB = b.charAt(i);
    106             if (tempA == '1' || tempB == '1') {
    107                 tempSt.append("1");
    108             } else {
    109                 tempSt.append(tempA);
    110             }
    111         }
    112         return tempSt.toString();
    113     }
    114 
    115     /**
    116      * 是否可以订票
    117      * 
    118      * @param ticketFlag
    119      * @param beginStation
    120      * @param endStation
    121      * @return
    122      */
    123     private static boolean checkCanTicket(String ticketFlag, int beginStation,
    124             int endStation) {
    125         boolean result = false;
    126         String tempTicket = ticketFlag.substring(beginStation, endStation);
    127         BigDecimal b = new BigDecimal(tempTicket);
    128         if (b.equals(new BigDecimal("0"))) {
    129             result = true;
    130         }
    131         return result;
    132     }
    133 
    134 }
    复制代码

     

    本文原创:转载请注明出处 http://www.cnblogs.com/feichengwurao/p/5191253.html

    说一下本人的几点改进想法:
    1.guid 可以用 车次+车厢+座位编码+始发时间+(后4位递增的尾数序列) 的联合编码来替换,作为 “行健”。
    2. 设计的这张表是针对票的,那么就专注票本身建模就好,始发受限站点 和 终到受限站点 最好不要用 和售票逻辑耦合的二进制码作为字段,直接使用站点自己的编码更好。
    3.实现本文,生成韶关后面的票的算法,大可简单粗暴一些。把车次经过的站再设计一张表,存每个站的站编码和站位一一对应关系。生成后半段的票的时候,直接从这个表里去查那些站该座还可以卖就好了。当然站点编码和站位的关系是静态数据,放到读多写少的缓存里查询更快一些。
    4. 还有就是,这个新生成的票,最...


    非常感谢@MarsLeno提供的改进想法
    1.GUID本身就是Md5(车次+座位编码+发车日期)生成的,这样可以保证此票的唯一性,在高并发的情况下可以防止重复插入
    2.设计这张表的并不是针对票的,而是针对售票整个业务,在大数据量的情况下可以避免多表交叉查询,提高查询效率,而受限字段只是便于进行查询的一种手段。
    针对3,4,5 采用更新的手段,只是针对一条数据的更新操作,在大数据量的情况下更新的效率会比插入一条效率高很多

  • 相关阅读:
    感动于细节,记我的一个同学(君君)
    求职时,我问过的问题
    毕业留言,写给我的一个同学
    偶是一个如此善良的人
    温柔地对待仇人,就像对待情人一样!
    小改机箱,支持硬盘调头,让磁盘对拷更方便
    心中的女朋友:(标准)
    准备开始看以下书籍
    成都文化公园游后感
    ”中国的教育与计算机“读后感
  • 原文地址:https://www.cnblogs.com/softidea/p/5203114.html
Copyright © 2011-2022 走看看