zzcx_line/coding/zz-fx/Model/retrieval/through.php

<?php
    header("Access-Control-Allow-Origin:*");
    //载入配置文件和连接数据库
    $pdo=conn();

    //区分是普通乘客还是分销员 0普通，1分销
    $user_type = 0;

    //判断出发地 目的地 时间是否为空
    $start_area = empty($_POST['start_area'])?"":" and a.property = ".$_POST['start_area'];
    $end_area = empty($_POST['end_area'])?"":" and b.property = ".$_POST['end_area'];
    $time = empty($_POST['go_time'])?date("Y-m-d",time()+24*3600):$_POST['go_time'];
    $current_day = date("Y-m-d");
    $limit_time = date("H:i", strtotime("+30 minutes"));

    $bus_type = $_POST['bus_type'];
    if($bus_type == 255){
        $bus_type = "255,0";
    }

    //$currpage = 1;
    //$pagesize = 2;
    $currpage = $_POST['currpage'];
    $pagesize = $_POST['pagesize'];
    $num = ($currpage - 1) * $pagesize;
    
    //$start_area = "";
    //$end_area = "";
    //$start_area = 791;//"上海"
    //$end_area = 3225;//"乌镇"
    //$time = date("Y-m-d",time());
    //$time = '2016-08-04';
    //通过出发点和目的地查询票种
    $sql = "select a.prod_id,a.property as s_area,b.property as e_area,c.property as up,d.property as down from opera_product_property as a,opera_product_property as b,opera_product_property as c,opera_product_property as d 
    where a.prod_id = b.prod_id and a.prod_id = c.prod_id and a.prod_id = d.prod_id 
    and a.type_id = 125 ".$start_area."  and b.type_id= 126 ".$end_area." and c.type_id = 112 and d.type_id = 113";
    $result = $pdo->query($sql);
    $prod = $result->fetchAll(PDO::FETCH_ASSOC);
    
    if(count($prod) > 0){
        //找到属于票种的信息

        //城市名
        $area_array = array();

        foreach($prod as $k => $v){
            $list[$k] = $v['prod_id'];
        }
        $prod_id = implode(',',$list);
        //从未删除的线路中找到属于自己线路的票种
        $sql = "select a.prod_id as ticket_id,b.prod_id as line_id from opera_product as a,opera_product as b where a.parent_id = b.prod_id and a.prod_id in (".$prod_id.") and a.if_disabled = 0 and a.ticket_mark in(0,1) and a.prod_type = 82 and a.cancel_flag = 0 and b.cancel_flag = 0 and b.bus_type in (" . $bus_type . ")";
        $result = $pdo->query($sql);
        $list = $result->fetchAll(PDO::FETCH_ASSOC);

        if(count($list) > 0){
            //获取票种的上下车站点，并打包
            
            //已票种ID为索引的数组
            $prod_array = array();

            //出发/目的地数组
            $all_area = array();

            foreach($prod as $k => $v){
                $all_area[] = $v['s_area'];
                $all_area[] = $v['e_area'];

                if( !isset($prod_array[$v['prod_id']]) ) { 
                    $prod_array[$v['prod_id']] = $v; 
                }
            }
            
            $all_area = array_unique($all_area);

            //获取所有地名
            $sql = "select id,area_name from base_area where id in(" . implode(",",$all_area) .")";
            $result = $pdo->query($sql);
            $area = $result->fetchAll(PDO::FETCH_ASSOC);
            foreach($area as $area_info) {
                $area_array[$area_info['id']] = $area_info['area_name'];
            }
            
            //合并后的票种数组，索引为票种ID
            $ticket_array = array();

            //票种的ID数组
            $ticket_id_array = array();

            //线路-（出发地-目的地）-（上车站-下车站）- 票种
            $line_ticket_array = array();

            //线路的ID数组
            $line_id_array = array();

            foreach($list as $k => $v){
                $ticket_id_array[] = $v["ticket_id"];
                $v2 = $prod_array[$v["ticket_id"]];
                $new_v = array_merge($v,$v2);
                $ticket_array[$v["ticket_id"]] = array_merge($v,$v2);

                //取出所有符合票种的全部线路信息
                if( !in_array($new_v["line_id"],$line_id_array)) { 
                    $line_id_array[] = $new_v["line_id"];
                }



                //创建线路索引
                if( !isset($line_ticket_array[$new_v["line_id"]])) {
                      $line_ticket_array[$new_v["line_id"]] = array();
                }
                
                $line_ticket_array[$new_v["line_id"]][$new_v["ticket_id"]] = $new_v;
                // //创建线路-（出发地-目的地）-（上车站-下车站）索引
                // if( !isset($line_ticket_array[$new_v["line_id"]][$new_v["s_area"]."_".$new_v["e_area"]])) { 
                //     $line_ticket_array[$new_v["line_id"]][$new_v["s_area"]."_".$new_v["e_area"]] = array();
                //  }

                // //将票种对应放入已创建的索引中
                // $line_ticket_array[$new_v["line_id"]][$new_v["s_area"]."_".$new_v["e_area"]][$new_v["up"]."_".$new_v["down"]] = $new_v;
            }
            //print_r($line_ticket_array);die;

            $sql = "select run_id,run_date,prod_id as line_id from run_main where run_status = 138 and prod_id in (" . implode(",", $line_id_array) . ") and run_date = '" . $time . "' ";
            if( $time == $current_day ) {
                $sql .= " and RUN_TIME > '{$limit_time}' ";
            }
            $sql .= " order by run_id desc ";


            $result = $pdo->query($sql);

            //班次线路票种
            $run_line_ticket = $result->fetchAll(PDO::FETCH_ASSOC);

            if(count($run_line_ticket) > 0) {
                $run_id_array = array();
                $run_info_array = array();
                foreach( $run_line_ticket as $run_line_info ) {
                    if( in_array($run_line_info["line_id"],$line_id_array) ) {
                        $run_id_array[] = $run_line_info["run_id"];
                        $run_info_array[$run_line_info["run_id"]] = $run_line_info;
                    }
                }
                
                $sql = "select id,run_id,station_order_id,start_time,station_res_id,station_inout_type from run_station where run_id in (" . implode(',',$run_id_array) . ") group by run_id,station_order_id order by run_id";
                $result = $pdo->query($sql);

                //获取线路的所有站点
                $station = $result->fetchAll(PDO::FETCH_ASSOC);

                //获取以班次为索引的所用站点及时间
                $run_station_array = array();
                foreach( $station as $station_info ) {
                    if( !isset($run_station_array[$station_info["run_id"]]) ) {
                        $run_station_array[$station_info["run_id"]]=array();
                    }
                    $run_station_array[$station_info["run_id"]][$station_info["station_res_id"]] = $station_info["start_time"];
                }


                //获取票种价格
                $sql = "select cus_price,cus_price,prod_id from opera_product_price where prod_id in (" . implode(",",$ticket_id_array) . ")";
                $result = $pdo->query($sql);
                $price = $result->fetchAll(PDO::FETCH_ASSOC);
                
                //价格-票种数据
                $price_array = array();
                foreach($price as $price_info){
                    if($user_type == 0){
                        $price_array[$price_info['prod_id']] = $price_info['cus_price'];
                    }else{
                        $price_array[$price_info['prod_id']] = $price_info['prod_price'];
                    }
                }


                //班次-线路-票种数组
                $run_line_ticket_array = array();
                //print_r($line_ticket_array);exit();
                foreach( $run_info_array as $run_id_key => $run_info ) {
                    if( in_array($run_info['line_id'],$line_id_array)) {
                        //$run_nav = array_merge($run_info,$line_ticket_array[$run_info['line_id']]);
                        $run_line_ticket_array[$run_id_key] = array();

                        foreach($line_ticket_array[$run_info['line_id']] as $run_ticket_array){
                            $t_nve = $run_ticket_array;

                            $t_nve['start_time'] = $run_station_array[$run_id_key][$t_nve['up']];
                            $t_nve['end_time'] = $run_station_array[$run_id_key][$t_nve['down']];
                            $t_nve['price'] = $price_array[$t_nve['ticket_id']];
                            //创建线路-（出发地-目的地）-（上车站-下车站）索引;

                            if( !isset($run_line_ticket_array[$run_id_key]['tickets'][$t_nve["s_area"]."_".$t_nve["e_area"]])) { 
                                $run_line_ticket_array[$run_id_key]['tickets'][$t_nve["s_area"]."_".$t_nve["e_area"]] = array();
                            }

                            //将票种对应放入已创建的索引中
                            $run_line_ticket_array[$run_id_key]['tickets'][$t_nve["s_area"]."_".$t_nve["e_area"]][$t_nve["up"]."_".$t_nve["down"]] = $t_nve;

                            $run_line_ticket_array[$run_id_key]['info'] = $run_info;
                        }
                        
                    }
                }
                //print_r($run_line_ticket_array);exit();
                $i = 0;
                $data = array();
                foreach($run_line_ticket_array as $k_run => $v_run){
                    foreach($v_run['tickets'] as $k_area => $v_area){
                        $araa_id_area = explode("_",$k_area);
                        $data[$i]['run_id'] = $k_run;
                        $data[$i]['line_id'] = $v_run['info']['line_id'];
                        $data[$i]['run_date'] = $v_run['info']['run_date'];
                        $data[$i]['start_area_id'] = $araa_id_area[0];
                        $data[$i]['start_area_name'] = $area_array[$araa_id_area[0]];
                        $data[$i]['end_area_id'] = $araa_id_area[1];
                        $data[$i]['end_area_name'] = $area_array[$araa_id_area[1]];
                        
                        $start_time_array = array();
                        $price_all_array = array();
                        //$ticket_all_str = array(); 
                        foreach($v_area as $k_sta => $v_sta) {
                            $start_time_array[] = $v_sta['start_time'];
                            $price_all_array[] = $v_sta['price'];
                            //$ticket_all_str[] = "{" . $v_sta['ticket_id'] . "," . $v_sta['up'] . "," . $v_sta['start_time'] . "," .$v_sta['down'] . "," . $v_sta['end_time'] . "," . $v_sta['price'] . "}";
                        }
                        
                        asort($start_time_array);
                        sort($start_time_array);

                        $price_all_array = array_unique($price_all_array);
                        $price_all_array = implode("/",$price_all_array);

                        //$ticket_all_str = implode("|",$ticket_all_str);

                        $data[$i]['start_time'] = $start_time_array[0];
                        $data[$i]['price'] = $price_all_array;
                        $data[$i]['ticket'] = $v_area;
                        $data[$i]['site_type'] = '普通座';
                        $i++;
                    }
                }
                $data2 = array_slice($data,$num,$pagesize);

                sort($data2);

                foreach($data2 as $data_key => $data_info){
                    $tickets_num_array = array();
                    $ticket_all_str = array();
                    $tic_status = 1;
                    foreach($data_info['ticket'] as $k => $v_sta){

                        $station_array = explode("_",$k);
                        $sql = "select a.res_id,a.seq_id,a.seat_type,a.total_count,a.saled_count 
                                from run_stock as a,
                                (select seq_id from run_stock where run_id = " . $data_info['run_id'] . " and res_id = " . $station_array[0] . " and seat_type = 72 and cancel_flag = 0 and prod_id = " . $data_info['line_id'] . ") as b,
                                (select seq_id from run_stock where run_id = " . $data_info['run_id'] . " and res_id = " . $station_array[1] . " and seat_type = 72 and cancel_flag = 0 and prod_id = " . $data_info['line_id'] . ") as c  
                                where a.run_id = " . $data_info['run_id'] . " and a.seat_type = 72 and a.cancel_flag = 0 and a.prod_id = " . $data_info['line_id'] . " and a.seq_id >= b.seq_id and a.seq_id < c.seq_id order by seq_id";
                        $result = $pdo->query($sql);
                        $stock = $result->fetchAll(PDO::FETCH_ASSOC);

                        $tickets_array = array();
                        foreach($stock as $kk => $v){
                            $tickets_array[] = $v['total_count'] - $v['saled_count'];
                        }

                        asort($tickets_array);
                        sort($tickets_array);

                        $tickets = $tickets_array[0];

                        $data2[$data_key]['ticket'][$k]['num'] = $tickets;
                        $ticket_all_str[] = "{" . $v_sta['ticket_id'] . "," . $v_sta['up'] . "," . $v_sta['start_time'] . "," .$v_sta['down'] . "," . $v_sta['end_time'] . "," . $v_sta['price'] . "," . $tickets . "}";

                        $tickets_num_array[] = $tickets;
                        if($tickets <= 20){
                            $tic_status = 0;
                        }
                    }

                    $tickets_num_array =  array_unique($tickets_num_array);

                    if($tic_status == 0){
                        $tickets_num_array = implode("/",$tickets_num_array);
                    }else{
                        $tickets_num_array = "充足";
                    }
                    
                    
                    $ticket_all_str = implode("|",$ticket_all_str);

                    $data2[$data_key]['num'] = $tickets_num_array;
                    $data2[$data_key]['ticket'] = $ticket_all_str;

                }

                //获取符合条件的线路-票种二位数组
                $code = 0;
                $info = $CODE[0];
                $list = $data2;

                //获取总条数
                

                //班次线路票种
                
                $totalnum = count($data);

            }else{
                $code = 0;
                $info = $CODE[7];
                $list = "";
                $totalnum = 0;
            }

        }else{
            //product表没有符合查询的线路及票种
            $code = 0;
            $info = $CODE[4];
            $list = "";
            $totalnum = 0;
        }      

    }else{
        //property表没有符合出发地目的地的数据
        $code = 0;
        $info = $CODE[3];
        $list = "";
        $totalnum = 0;
    }

    $json = array();
    $json['code'] = $code;
    $json['info'] = $info;
    $json['list'] = $list;
    $json['totalnum'] = $totalnum;
    //print_r($json);
    
    echo json_encode($json);
?>