nizongfeng
/
ZZCS
1
0
Fork 0
Code Issues 0 Pull Requests 0 Releases 0 Wiki Activity
You can not select more than 25 topics Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
2 Commits
1 Branch
14 MiB
 
 
 
 
Branch: master
Branches Tags
${ item.name }
Create branch ${ searchTerm }
from 'master'
${ noResults }
ZZCS/coding/application/carDispatchManager/groupDispatch.class.php

1959 lines
102 KiB
Raw Permalink Blame History 

  1. <?php

  2. 

  3. /**

  4.  * Created by PhpStorm.

  5.  * User: Steven

  6.  * Date: 2016/10/28

  7.  * Time: 9:17

  8.  * 组合线路车次调度

  9.  */

  10. require 'dispatchAlgorithm.class.php';

  11. 

  12. class groupDispatch extends base

  13. {

  14. 

  15.     /**

  16.      * 获取产品线信息

  17.      * @return mixed

  18.      * User: Steven

  19.      */

  20.     public function getBaseInfo()

  21.     {

  22.         $res = $this->productLine();

  23.         if ($res) {

  24.             $json['code'] = '0';

  25.             $json['info'] = '产品线获取成功';

  26.             $json['base_info'] = $res;

  27.             return $json;

  28.         }

  29.     }

  30. 

  31.     /**

  32.      * 获取某天某特定组合线路的订单信息

  33.      * 温依莅

  34.      * 2016.11.03

  35.      * @param $param

  36.      * start_date(date)      出发日期

  37.      * line_id(int)          组合订单id

  38.      * @return

  39.      * 成功返回参数

  40.      * code(str)

  41.      * info(str)

  42.      * list_order(array):

  43.      * order_id(int)                 订单id

  44.      * run_bus_id(int)               车次id，如果无，返回''

  45.      * line_codes(str)               订单所对应组合线路编码

  46.      * day(int)                      标示今天是该订单第几天的行程

  47.      * start_station(str)            订单所对应组合线路出发站点

  48.      * tran_id(int)                  接驳线路id

  49.      * num(int)                      符合条件该线路订单人数

  50.      * list_bus(array):        车次及相应剩余座位数

  51.      * --run_bus_id(int)               车次id

  52.      * --stock(int)                    余票数

  53.      */

  54.     public function getOrderDetail($param)

  55.     {

  56.         /*

  57.          start_date:出发日期

  58.          line_id:组合订单id

  59.         */

  60.         $start_date = isset($param['start_date']) ? $param['start_date'] : false;

  61.         $line_id = isset($param['line_id']) ? $param['line_id'] : false;

  62.         $product_id = isset($param['product_id']) ? $param['product_id'] : false;

  63.         //判断参数是否缺少

  64.         if (false === $start_date || false === $line_id || !trim($start_date) || !trim($line_id)) {

  65.             $json['code'] = '2';

  66.             $json['info'] = '缺少必要参数';

  67.             return $json;

  68.         }

  69.         //判断日期格式正确

  70.         $tmp_arr = explode('-', $start_date);

  71.         $bool = checkdate($tmp_arr[1], $tmp_arr[2], $tmp_arr[0]);//判断日期是否是合法日期

  72.         if (!$bool) {

  73.             $json['code'] = '1';

  74.             $json['info'] = '日期格式不正确';

  75.             return $json;

  76.         }

  77.         //根据日期和组合线路id得到该日组合订单 分拆后的 订单信息

  78.         if($line_id== -1){

  79.             $where='';

  80.         }else{

  81.             $where=" a.PARENT_PROD_ID=$line_id AND ";

  82.         }

  83.         $sql = "

  84.             SELECT *,convert(x.trans_name using gbk) 't1',convert(x.start_station using gbk) 't2'

  85.             from(

  86.                 SELECT

  87.                     a.order_id,

  88.                     a.customer_mobile as tel,

  89.                     (DATEDIFF('$start_date',a.prod_start_station_date)+1) as day,

  90.                     IFNULL((SELECT h.line_id FROM order_main g LEFT JOIN opera_line h ON g.parent_prod_id=h.line_id WHERE h.LINE_TYPE=256 AND g.PARENT_ORDER_ID=a.order_id limit 1),'') AS tran_id,

  91.                     IFNULL((select res_name from base_resource where res_id=(select parent_id from base_resource where res_id=(SELECT p.prod_start_station_res_id FROM order_main p LEFT JOIN opera_line q ON p.parent_prod_id=q.line_id WHERE q.LINE_TYPE=256 AND p.PARENT_ORDER_ID=a.order_id  limit 1))),'') as trans_name,

  92.                     IFNULL((SELECT o.run_bus_order_id FROM order_main o LEFT JOIN opera_line v ON o.parent_prod_id=v.line_id WHERE v.LINE_TYPE=255 AND o.PARENT_ORDER_ID=a.order_id AND o.PROD_START_STATION_DATE='$start_date' limit 1),'') AS run_bus_id,

  93.                     a.prod_start_station_res_name AS start_station,

  94.                     b.line_code AS line_codes,

  95.                     IFNULL(SUBSTRING_INDEX(a.order_description,'|',-1),0) AS num 

  96.                 FROM 

  97.                     order_main a LEFT JOIN opera_line b

  98.                 ON

  99.                     a.parent_prod_id = b.line_id

  100.                 WHERE 

  101.                     $where '$start_date' IN ( SELECT prod_start_station_date FROM order_main  WHERE parent_order_id=a.order_id)

  102.                     AND a.order_valid_status=1 AND a.order_status<>148

  103.                     AND b.line_type=316 AND b.cancel_flag=0 AND b.if_disabled=0 AND b.is_onsale=1

  104.             ) x

  105.             ORDER BY t1,t2;";

  106. 

  107.         $order_info = $this->query($sql);

  108.         if (false === $order_info) {

  109.             $json['code'] = '1';

  110.             $json['info'] = '数据库错误';

  111.             return $json;

  112.         }

  113.         //若查询无信息

  114.         if (count($order_info) == 0) {

  115.             $json['code'] = '1';

  116.             $json['info'] = '无符合条件的线路订单信息';

  117.             $json['list'] = array();

  118.             return $json;

  119.         }

  120.         //处理得到今日车次信息

  121.         $sql2 = "SELECT

  122.                     a.order_id,a.parent_order_id,a.run_id,b.BUS_ORDER_ID as run_bus_id,(b.seat_count - b.saled_count) AS stock

  123.                 FROM

  124.                     order_main a,run_bus b,

  125.                     opera_line c,run_main d

  126.                 WHERE

  127.                         a.run_id = b.run_id

  128.                     AND a.PARENT_PROD_ID = c.line_id

  129.                     AND b.run_id = d.run_id

  130.                     AND d.prod_id = 0

  131.                     AND d.run_date = '$start_date'

  132.                     AND c.line_type = 255

  133.                     AND b.cancel_flag = 0

  134. 				group by b.bus_order_id

  135. 				having  $product_id=(SELECT l.product_type FROM opera_line l LEFT JOIN order_main m ON l.line_id = m.PARENT_PROD_ID WHERE m.order_id = a.PARENT_ORDER_ID limit 1);";

  136.         $bus_info = $this->query($sql2);

  137.         if (false === $bus_info) {

  138.             $json['code'] = '1';

  139.             $json['info'] = '数据库出错';

  140.             $json['list'] = array();

  141.             return $json;

  142.         }

  143.         //若查询无车次信息

  144.         if (count($bus_info) == 0) {

  145.             //这里如果尚未派车，无车次信息，则返回一个空的bus_info数组

  146.             /*$json['code'] = '1';

  147.             $json['info'] = '无符合条件的车次信息';

  148.             $json['list'] = array();

  149.             return $json;*/

  150.             $bus_info = array();

  151. 

  152.         }

  153.         //处理run_bus_id返回值

  154.         foreach ($order_info as $k => $v) {

  155.             if ($v['run_bus_id'] == 0) {

  156.                 $order_info[$k]['run_bus_id'] = '';

  157.             }

  158.         }

  159.         $json['code'] = '0';

  160.         $json['info'] = '返回线路订单信息成功';

  161.         $json['list_order'] = $order_info;

  162.         $json['list_bus'] = $bus_info;

  163.         return $json;

  164.     }

  165. 

  166.     /**

  167.      * 获取某一天的组合线路的所有线路的订单统计信息

  168.      * 温依莅

  169.      * 2016.11.01

  170.      * @param $param

  171.      * start_date(date)      出发日期

  172.      * product_type(int)     产品线 --若为'-1'则表示所有

  173.      * @return

  174.      * 成功返回参数

  175.      * code(str)

  176.      * info(str)

  177.      * total_num(int)         符合条件订单总人数

  178.      * list(array):

  179.      * line_id(int)                    订单id

  180.      * line_name(str)                  订单名字

  181.      * line_code(str)                  订单编码

  182.      * num(int)                        符合条件该线路订单总人数

  183.      */

  184.     public function getOrderList($param)

  185.     {

  186.         /*

  187.          start_date:出发日期

  188.          product_type:产品线 --若为'-1'则表示所有

  189.          */

  190.         $start_date = isset($param['start_date']) ? $param['start_date'] : false;

  191.         $product_type = isset($param['product_type']) ? $param['product_type'] : false;

  192.         //判断参数是否缺少

  193.         if (false === $start_date || false === $product_type || !trim($start_date) || !trim($product_type)) {

  194.             $json['code'] = '2';

  195.             $json['info'] = '缺少必要参数';

  196.             return $json;

  197.         }

  198.         //判断日期格式正确

  199.         $tmp_arr = explode('-', $start_date);

  200.         $bool = checkdate($tmp_arr[1], $tmp_arr[2], $tmp_arr[0]);//判断日期是否是合法日期

  201.         if (!$bool) {

  202.             $json['code'] = '1';

  203.             $json['info'] = '日期格式不正确';

  204.             return $json;

  205.         }

  206. 

  207.         //从数据库取得该天组合线路统计信息

  208.         //如果是所有产品线

  209.         $sql = "SELECT

  210.                     b.line_id,b.line_code,IFNULL(sum(SUBSTRING_INDEX(a.order_description,'|',-1)),0) AS num

  211.                 FROM

  212.                     order_main a 

  213.                 RIGHT JOIN

  214.                     opera_line b

  215.                 ON

  216.                     a.parent_prod_id = b.line_id AND a.cancel_flag=0  AND a.order_valid_status=1 AND a.order_status<>148 AND a.parent_order_id=0  AND '$start_date' IN ( select c.prod_start_station_date from order_main c where c.parent_order_id=a.order_id)

  217.                 WHERE

  218.                     b.line_type=316 AND b.cancel_flag=0 AND b.if_disabled=0 AND b.is_onsale=1 AND ";

  219.         if ($product_type == '-1') {

  220.             $sql .= "b.product_type IN (select id from dict_type where parent_id=323) GROUP BY b.line_id;";

  221.         } else {

  222.             $sql .= "b.product_type=$product_type GROUP BY b.line_id;";

  223.         }

  224. 

  225.         $order_info = $this->query($sql);

  226.         if (false === $order_info) {

  227.             $json['code'] = '1';

  228.             $json['info'] = '数据库错误';

  229.             return $json;

  230.         }

  231.         //若查询无信息

  232.         if (count($order_info) == 0) {

  233.             $json['code'] = '1';

  234.             $json['info'] = '无符合条件的线路信息';

  235.             $json['list'] = array();

  236.             return $json;

  237.         }

  238.         //处理得到符合条件总计数

  239.         $total_num = 0;

  240.         foreach ($order_info as $k => $v) {

  241.             $total_num += $v['num'];

  242.         }

  243. 

  244.         $json['code'] = '0';

  245.         $json['info'] = '返回票种信息成功';

  246.         $json['total_num'] = $total_num;

  247.         $json['list'] = $order_info;

  248.         return $json;

  249.     }

  250. 

  251.     /**

  252.      * 获取组合线路接驳段的分车信息

  253.      * @param run_date 出发日期

  254.      * @param product_id 产品线ID

  255.      * @param current_page 当前页

  256.      * @param page_size 每页显示条数

  257.      * @return mixed

  258.      * User: Steven

  259.      */

  260.     public function getSingleResult($param)

  261.     {

  262.         $valid = zzcsUtils::validateParams(array('run_date,product_id,current_page,page_size' => 'empty'), $param);   //参数验证

  263.         if (!$valid['status']) {

  264.             $result['code'] = (string)$valid['status'];

  265.             $result['info'] = $valid['info'];

  266.             return $result;

  267.         }

  268.         $start_row = ($param['current_page'] - 1) * $param['page_size'];

  269.         //SQL:查询组合线路中接驳段的分车结果

  270.         $sql = "select b.id,

  271.                       (select RES_NAME from base_resource where res_id=b.start_zone_id limit 1) as line_code,

  272.                              b.run_id, -- 班次ID

  273.                              m.run_date, -- 出发日期

  274.                              b.bus_order_id as run_bus_order_id, -- 车号

  275.                              (SELECT BASE_RESOURCE.RES_NAME FROM BASE_RESOURCE WHERE BASE_RESOURCE.CANCEL_FLAG = 0 AND BASE_RESOURCE.RES_ID = IF(b.SEND_BUS_TYPE_RES_ID = 0,b.BUS_TYPE_RES_ID,b.SEND_BUS_TYPE_RES_ID)) AS res_name, -- 指派车型名称

  276.                              b.SEAT_COUNT AS seat_count,

  277.                              b.SALED_COUNT AS order_cnt, -- 已售座位数  

  278.                              (b.SEAT_COUNT-b.SALED_COUNT) AS remain_cnt,

  279.                              b.SEND_BUS_RES_ID AS send_bus_res_id, -- 实派车辆资源ID    

  280.                              b.SEND_BUS_NO AS send_bus_res_name, -- 实派车辆车牌号

  281.                              b.SEND_BUS_DRIVER_RES_ID AS send_bus_driver_res_id, -- 司机资源ID

  282.                              b.SEND_DRIVER_NAME AS send_driver_name, -- 司机姓名   

  283.                              b.SEND_TOUR_GUIDE_RES_ID AS send_tour_guide_res_id,            -- 导游 

  284.                              b.SEND_TOUR_GUIDE_NAME As send_tour_guide_name -- 导游  

  285.                 from run_bus b left join 

  286.                      run_main m on b.run_id = m.run_id 

  287.                 where m.run_date = '{$param['run_date']}' and b.group_line_flag = 1 and b.cancel_flag = 0 and m.prod_id > 0

  288.                   and b.run_id in (

  289.                 select distinct run_id from order_main where parent_order_id > 0 and prod_id in (select ticket_id from opera_tickets t, opera_line l where t.line_id = l.line_id and l.line_type = 316 and l.product_type =  {$param['product_id']})

  290.                 ) order by b.bus_order_id";

  291.         /*$sql = "select distinct s.id as id,

  292.                        -- CONCAT(l.LINE_CODE,' ',l.LINE_NAME) as line_code, 

  293.                                   (select RES_NAME from base_resource where res_id=s.start_zone_id limit 1) as line_code,

  294.                                  b.run_id, -- 班次ID

  295.                                  b.run_date, -- 出发日期

  296.                                  b.run_bus_order_id, -- 车号

  297.                                  (SELECT BASE_RESOURCE.RES_NAME FROM BASE_RESOURCE WHERE BASE_RESOURCE.CANCEL_FLAG = 0 AND BASE_RESOURCE.RES_ID = IF(s.SEND_BUS_TYPE_RES_ID = 0,s.BUS_TYPE_RES_ID,s.SEND_BUS_TYPE_RES_ID)) AS res_name, -- 指派车型名称

  298.                                  s.SEAT_COUNT AS seat_count,

  299. 								 s.SALED_COUNT AS order_cnt, -- 已售座位数  

  300. 								 (s.SEAT_COUNT-s.SALED_COUNT) AS remain_cnt,

  301.                                  s.SEND_BUS_RES_ID AS send_bus_res_id, -- 实派车辆资源ID    

  302.                                  s.SEND_BUS_NO AS send_bus_res_name, -- 实派车辆车牌号

  303.                                  s.SEND_BUS_DRIVER_RES_ID AS send_bus_driver_res_id, -- 司机资源ID

  304.                                  s.SEND_DRIVER_NAME AS send_driver_name, -- 司机姓名   

  305.                                  s.SEND_TOUR_GUIDE_RES_ID AS send_tour_guide_res_id,		-- 导游 

  306.                                  s.SEND_TOUR_GUIDE_NAME As send_tour_guide_name	-- 导游  

  307.                 from opera_tickets a, run_bus s,order_main b, opera_line l

  308.                 where a.ticket_id = b.prod_id 

  309.                   and s.run_id = b.RUN_ID

  310.                   and s.bus_order_id = b.run_bus_order_id

  311.                   and b.parent_prod_id = l.LINE_ID

  312.                   and l.line_type = 256 

  313.                   and l.cancel_flag =0

  314.                   and a.line_id in (select line_id from opera_line where line_type = 316 and product_type = {$param['product_id']} and cancel_flag = 0) -- 组合线路

  315.                   and b.run_date = '{$param['run_date']}' order by  b.run_bus_order_id,s.SEAT_COUNT";*/

  316.         $sql_query = $sql . " limit $start_row,{$param['page_size']}";

  317.         $sql_count = "SELECT COUNT(*) as count  from (" . $sql . ") as a";

  318.         zzcsUtils::writeLog($sql_query);

  319.         $res_query = $this->query($sql_query);

  320.         $res_count = $this->query($sql_count);

  321.         if (false === $sql_query) {

  322.             $result['code'] = '1';

  323.             $result['info'] = '获取接驳段自动分车结果失败';

  324.             return $result;

  325.         }

  326.         $total_page = ceil($res_count[0]['count'] / $param['page_size']);

  327.         $result['code'] = '0';

  328.         $result['info'] = '获取接驳段自动分车结果成功';

  329.         $result['data'] = $res_query;

  330.         $result['page'] = array(

  331.             'page_size' => $param['page_size'],

  332.             'current_page' => $param['current_page'],

  333.             'total_count' => $res_count[0]['count'],

  334.             'total_page' => $total_page

  335.         );

  336.         return $result;

  337.     }

  338. 

  339. 

  340.     /**

  341.      * 获取组合线路直通段分车的结果

  342.      * @param run_date 出发日期

  343.      * @param product_id 产品线ID

  344.      * @param current_page 当前页

  345.      * @param page_size 每页显示条数

  346.      * @return mixed

  347.      * User: Steven

  348.      */

  349.     public function getDispatchResult($param)

  350.     {

  351.         $valid = zzcsUtils::validateParams(array('run_date,product_id,current_page,page_size' => 'empty'), $param);   //参数验证

  352.         if (!$valid['status']) {

  353.             $result['code'] = (string)$valid['status'];

  354.             $result['info'] = $valid['info'];

  355.             return $result;

  356.         }

  357.         $start_row = ($param['current_page'] - 1) * $param['page_size'];

  358.         //SQL:查询组合线路直通段的分车后的结果

  359.         $sql = "select  r.run_id, r.bus_order_id as run_bus_order_id, r.seat_count, ifnull(sum(order_cnt),0) as order_cnt,(seat_count-saled_count) as remain_cnt,

  360.                             ifnull(group_concat(DISTINCT line_code),'') as line_code,r.id,r.SEND_BUS_NO as send_bus_res_name, r.send_driver_name, r.send_tour_guide_name

  361.                     from (select s.id,s.run_id,s.bus_order_id,s.seat_count,s.SEND_BUS_NO,s.send_driver_name,s.send_tour_guide_name,s.saled_count

  362.                           from run_main m,run_bus s 

  363.                           where m.run_id = s.run_id and m.run_date = '{$param['run_date']}' and m.prod_id = 0 AND s.cancel_flag=0) r 

  364.                           left join

  365.                              (select distinct a.parent_order_id, b.parent_prod_id,b.line_code, b.order_cnt, a.run_id,a.run_bus_order_id

  366.                               from order_main a,

  367.                                    (select order_id,parent_prod_id,l.line_code,l.line_name, substring_index(order_description,'|',-1) as order_cnt

  368.                                    from order_main m,opera_line l

  369.                                    where m.parent_prod_id = l.line_id and m.parent_order_id = 0 and m.cancel_flag = 0 and m.order_valid_status = 1 and l.line_type = 316 and l.PRODUCT_TYPE={$param['product_id']} and l.cancel_flag = 0 ) b		

  370.                               where a.parent_order_id = b.order_id

  371.                               and a.run_date = '{$param['run_date']}'

  372.                               and a.cancel_flag = 0

  373.                               and a.order_valid_status = 1

  374.                               and a.parent_prod_id not in (select line_id from opera_line where line_type = 256 and cancel_flag = 0)

  375.                               ) t on r.run_id = t.run_id and r.bus_order_id = t.run_bus_order_id

  376.                     group by r.run_id, r.bus_order_id, r.seat_count";

  377.         //SQL:查询组合线路直通段的分车结果包括分页

  378.         $sql_query = $sql . " LIMIT $start_row,{$param['page_size']}";

  379.         $sql_count = "SELECT COUNT(*) as count  from (" . $sql . ") as a";

  380.         zzcsUtils::writeLog($sql_query);

  381.         $res_query = $this->query($sql_query);

  382.         $res_count = $this->query($sql_count);

  383.         if (false === $sql_query) {

  384.             $result['code'] = '1';

  385.             $result['info'] = '获取直通段自动分车结果失败';

  386.             return $result;

  387.         }

  388.         $total_page = ceil($res_count[0]['count'] / $param['page_size']);

  389.         $result['code'] = '0';

  390.         $result['info'] = '获取直通段自动分车结果成功';

  391.         $result['data'] = $res_query;

  392.         $result['page'] = array(

  393.             'page_size' => $param['page_size'],

  394.             'current_page' => $param['current_page'],

  395.             'total_count' => $res_count[0]['count'],

  396.             'total_page' => $total_page

  397.         );

  398.         return $result;

  399.     }

  400. 

  401. 

  402.     /**

  403.      * 组合线路车辆调度算法

  404.      * @param run_date 出发日期

  405.      * @param product_id 产品线ID

  406.      * @return mixed

  407.      * User: Steven

  408.      */

  409.     public function dispatch($param)

  410.     {

  411.         $user_id = $this->user_id;

  412.         $valid = zzcsUtils::validateParams(array('run_date,product_id' => 'empty'), $param);   //参数验证

  413.         if (!$valid['status']) {

  414.             $result['code'] = (string)$valid['status'];

  415.             $result['info'] = $valid['info'];

  416.             return $result;

  417.         }

  418.         //接驳段的分车算法 并返回被占用的车辆信息

  419.         $sql_jiebo = "CALL sp_bus_dispatch_for_group_line($user_id,'{$param['run_date']}',{$param['product_id']})";

  420.         zzcsUtils::writeLog($sql_jiebo);

  421.         $res_jiebo = $this->procQuery($sql_jiebo);

  422.         if ($res_jiebo['code'] != 0) {  //存储过程执行出错

  423.             $json["code"] = (string)$res_jiebo['code'];

  424.             $json["info"] = $res_jiebo['info'];

  425.             return $json;

  426.         }

  427.         $car_list1 = $res_jiebo['data'][0];  //得到接驳段的车辆信息列表

  428.         //TODO:进行组合线路直通段的分车

  429.         //sql:获取需要加入分车算法的订单信息

  430.         $sql_zhitong = "CALL SP_GET_LINE_GROUP_DISTRIB_RULE('{$param['run_date']}',{$param['product_id']})";

  431.         zzcsUtils::writeLog($sql_zhitong);

  432.         $res = $this->procQuery($sql_zhitong);

  433.         if ($res['code'] != 0) {

  434.             $json['code'] = '1';

  435.             $json['info'] = '订单数据获取失败';

  436.             return $json;

  437.         }

  438.         #region TODO: 以下是组合线路分车算法

  439.         $Ta = array();

  440.         $Tb = array();

  441.         $Tc = array();

  442.         $Te = array();

  443.         $Za = array();

  444.         $Zb = array();

  445.         $Zc = array();

  446.         $Ze = array();

  447.         $Taeab = array();

  448.         $Tbcbe = array();

  449.         if ($res['data'][0]) {

  450.             foreach ($res['data'][0] as $k => $v) {

  451.                 $order = array(

  452.                     'order_number' => $v['parent_order_id'],    // 组合订单ID

  453.                     'sub_order_id' => $v['sub_order_id'],         //单一线路ID

  454.                     'passenger_number' => $v['order_cnt'],      //订单中的人数

  455.                     'superior_hotel' => $v['start_res_id'],       //上车站点ID（酒店ID）

  456.                     'superior_product' => $v['sub_line_id'],    //组合线路ID  A+B+E(两天) 第一天A+B该字段显示的是A+B线路的ID

  457.                     'group_line_id' => $v['group_line_id'],   //组合线路ID

  458.                     'start_time' => $v['start_time']      //发车时间

  459.                 );

  460.                 switch ($v['sub_line_id']) {

  461.                     case ZA:  //纯玩产品a $Ta对应ZA

  462.                         $Ta['hotel_list'][$v['start_res_id']]['order_list'][] = $order;

  463.                         break;

  464.                     case ZB:

  465.                         $Tb['hotel_list'][$v['start_res_id']]['order_list'][] = $order;

  466.                         break;

  467.                     case ZC:

  468.                         $Tc['hotel_list'][$v['start_res_id']]['order_list'][] = $order;

  469.                         break;

  470.                     case ZE:

  471.                         $Te['hotel_list'][$v['start_res_id']]['order_list'][] = $order;

  472.                         break;

  473.                     case TA:

  474.                         $Za['hotel_list'][$v['start_res_id']]['order_list'][] = $order;

  475.                         break;

  476.                     case TB:

  477.                         $Zb['hotel_list'][$v['start_res_id']]['order_list'][] = $order;

  478.                         break;

  479.                     case TC:

  480.                         $Zc['hotel_list'][$v['start_res_id']]['order_list'][] = $order;

  481.                         break;

  482.                     case TE:

  483.                         $Ze['hotel_list'][$v['start_res_id']]['order_list'][] = $order;

  484.                         break;

  485. 

  486.                     //纯玩产品aeab  包含A+B|A+E|A+E+B（两日）

  487.                     case ZAB :

  488.                     case ZAE:

  489.                     case ZAEB:

  490.                         $Taeab['hotel_list'][$v['start_res_id']]['order_list'][] = $order;

  491.                         break;

  492.                     case ZBC:

  493.                     case ZBE:

  494.                         $Tbcbe['hotel_list'][$v['start_res_id']]['order_list'][] = $order;

  495.                         break;

  496.                 }

  497.             }

  498.         }

  499.         $dispatch = new dispatchAlgorithm();

  500.         #region 车次库存列表

  501.         $bus_stock = array();

  502.         $bus_detail = array();

  503.         //sql:查询所有可用的车次列表

  504.         $run_date = $param['run_date'];

  505.         $sql_enable_car = $this->getEnableCar($run_date);  //获取当前可用的车次

  506.         $car_list2 = $this->query($sql_enable_car);

  507.         if ($car_list2) {

  508.             #region 将接驳段的车运用到直通段的派车中

  509.             $car_list = array_merge($car_list1, $car_list2);

  510.             usort($car_list, function ($a, $b) {

  511.                 $car_list = ($b['seat_count'] - $a['seat_count']);

  512.                 return $car_list != 0 ? $car_list : ($a['sort_id'] - $b['sort_id']);

  513.             });

  514.             #endregion

  515.             foreach ($car_list as $k1 => $v1) {

  516.                 $bus_stock[$k1] = $v1['seat_count'];

  517.                 $bus_detail[$k1] = array(

  518.                     0 => $v1['seat_count'],

  519.                     1 => $v1['bus_id'],

  520.                     2 => $v1['brand_id'],

  521.                     3 => $v1['bus_type_res_id']

  522.                 );

  523.             }

  524.         }

  525.         #endregion

  526. 

  527.         $temp_order_pool = array();

  528.         $white_bus_pool = array();

  529.         $Te_black_order_pool = array();// 创建产品Te的黑订单池订单池

  530.         $Tb_black_order_pool = array();// 创建产品Tb的黑订单池订单池

  531.         $Tc_black_order_pool = array();// 创建产品Tc的黑订单池订单池

  532.         $Ta_black_order_pool = array();// 创建产品Ta的黑订单池订单池

  533.         $Ze_black_order_pool = array();// 创建产品Ze的黑订单池订单池->购物

  534.         $Zb_black_order_pool = array();// 创建产品Zb的黑订单池订单池->购物

  535.         $Zc_black_order_pool = array();// 创建产品Zc的黑订单池订单池->购物

  536.         $Za_black_order_pool = array();// 创建产品Za的黑订单池订单池->购物

  537.         $Taeab_two_scenic_black_order_pool = array();//a+e和a+b单日双景点黑池子

  538.         $Tbcbe_two_scenic_black_order_pool = array();//b+c和b+e单日双景点黑池子

  539.         /**

  540.          * 以下是分别派车

  541.          */

  542.         if (!empty($Ze)) {

  543.             // 存在Ze产品订单

  544.             ZM:

  545.             for (; ;) {

  546.                 if (!empty($Ze['hotel_list'])) {

  547.                     sort($Ze['hotel_list']);

  548.                     $tt_people = 0;

  549.                     for ($temp_peo_i = 0; $temp_peo_i < count($temp_order_pool); $temp_peo_i++) {

  550.                         if (isset($temp_order_pool[$temp_peo_i]["passenger_number"])) {

  551.                             $tt_people = $tt_people + $temp_order_pool[$temp_peo_i]["passenger_number"];

  552.                         }

  553. 

  554.                     }

  555.                     if ($tt_people < $bus_stock["0"]) {

  556.                         for ($i = 0; $i < count($Ze['hotel_list']["0"]["order_list"]); $i++) {

  557.                             $temp_order_pool[] = $Ze['hotel_list']["0"]["order_list"][$i];

  558.                         }

  559.                         array_splice($Ze['hotel_list'], 0, 1);

  560.                         if (!empty($Ze['hotel_list'])) {

  561.                             goto ZM;

  562.                         }

  563.                     }

  564.                 }

  565.                 $orders = $dispatch->change_data_type($temp_order_pool);

  566.                 if (empty($bus_stock)) {

  567.                     $result['code'] = '1';

  568.                     $result['info'] = '车辆库存不足，无法自动派车！';

  569.                     return $result;

  570.                 }

  571.                 $answer = $dispatch->dp($orders, $bus_stock["0"]);

  572.                 if ($answer["achieved_attendance"] < 0.9) {

  573.                     $temp_pool_answe = $dispatch->path_to_update_temp_and_black_pool($answer, $temp_order_pool, $Ze_black_order_pool);

  574.                     $temp_order_pool = $temp_pool_answe["temp_order_pool"];

  575.                     $Ze_black_order_pool = $temp_pool_answe["black_order_pool"];

  576.                 } else {

  577.                     $temp_bus_and_pool_answer = $dispatch->path_to_update_temp_order_and_aboard($answer, $temp_order_pool, $bus_stock);

  578.                     $white_bus_pool[] = $temp_bus_and_pool_answer["bus"];

  579.                     $temp_order_pool = $temp_bus_and_pool_answer["temp_order_pool"];

  580.                     $bus_stock = $temp_bus_and_pool_answer["bus_stock"];

  581.                 }

  582.                 if (empty($temp_order_pool) && empty($Ze['hotel_list'])) {

  583.                     break;

  584.                 }

  585. 

  586.             }

  587.         }

  588. 

  589.         if (!empty($Zb)) {

  590.             // 存在Zb产品订单

  591.             ZQ:

  592.             for (; ;) {

  593.                 if (!empty($Zb['hotel_list'])) {

  594.                     sort($Zb['hotel_list']);

  595.                     $tt_people = 0;

  596.                     for ($temp_peo_i = 0; $temp_peo_i < count($temp_order_pool); $temp_peo_i++) {

  597.                         if (isset($temp_order_pool[$temp_peo_i]["passenger_number"])) {

  598.                             $tt_people = $tt_people + $temp_order_pool[$temp_peo_i]["passenger_number"];

  599.                         }

  600.                     }

  601.                     if ($tt_people < $bus_stock["0"]) {

  602.                         for ($i = 0; $i < count($Zb['hotel_list']["0"]["order_list"]); $i++) {

  603.                             $temp_order_pool[] = $Zb['hotel_list']["0"]["order_list"][$i];

  604.                         }

  605.                         array_splice($Zb['hotel_list'], 0, 1);

  606.                         if (!empty($Zb['hotel_list'])) {

  607.                             goto ZQ;

  608.                         }

  609.                     }

  610.                 }

  611.                 $orders = $dispatch->change_data_type($temp_order_pool);

  612.                 if (empty($bus_stock)) {

  613.                     $result['code'] = '1';

  614.                     $result['info'] = '车辆库存不足，无法自动派车！';

  615.                     return $result;

  616.                 }

  617.                 $answer = $dispatch->dp($orders, $bus_stock["0"]);

  618.                 if ($answer["achieved_attendance"] < 0.9) {

  619.                     $temp_pool_answe = $dispatch->path_to_update_temp_and_black_pool($answer, $temp_order_pool, $Zb_black_order_pool);

  620.                     $temp_order_pool = $temp_pool_answe["temp_order_pool"];

  621.                     $Zb_black_order_pool = $temp_pool_answe["black_order_pool"];

  622. 

  623.                 } else {

  624.                     $temp_bus_and_pool_answer = $dispatch->path_to_update_temp_order_and_aboard($answer, $temp_order_pool, $bus_stock);

  625.                     $white_bus_pool[] = $temp_bus_and_pool_answer["bus"];

  626.                     $temp_order_pool = $temp_bus_and_pool_answer["temp_order_pool"];

  627.                     $bus_stock = $temp_bus_and_pool_answer["bus_stock"];

  628.                 }

  629.                 if (empty($temp_order_pool) && empty($Zb['hotel_list'])) {

  630.                     break;

  631.                 }

  632. 

  633.             }

  634.         }

  635. 

  636.         if (!empty($Zc)) {

  637.             // 存在Zc产品订单

  638.             ZC:

  639.             for (; ;) {

  640.                 if (!empty($Zc['hotel_list'])) {

  641.                     sort($Zc['hotel_list']);

  642.                     $tt_people = 0;

  643.                     for ($temp_peo_i = 0; $temp_peo_i < count($temp_order_pool); $temp_peo_i++) {

  644.                         if (isset($temp_order_pool[$temp_peo_i]["passenger_number"])) {

  645.                             $tt_people = $tt_people + $temp_order_pool[$temp_peo_i]["passenger_number"];

  646.                         }

  647. 

  648.                     }

  649.                     if ($tt_people < $bus_stock["0"]) {

  650.                         for ($i = 0; $i < count($Zc['hotel_list']["0"]["order_list"]); $i++) {

  651.                             $temp_order_pool[] = $Zc['hotel_list']["0"]["order_list"][$i];

  652.                         }

  653.                         array_splice($Zc['hotel_list'], 0, 1);

  654.                         if (!empty($Zc['hotel_list'])) {

  655.                             goto ZC;

  656.                         }

  657.                     }

  658.                 }

  659.                 // 订单池加到满足要求

  660.                 $orders = $dispatch->change_data_type($temp_order_pool);

  661.                 if (empty($bus_stock)) {

  662.                     $result['code'] = '1';

  663.                     $result['info'] = '车辆库存不足，无法自动派车！';

  664.                     return $result;

  665.                 }

  666.                 $answer = $dispatch->dp($orders, $bus_stock["0"]);

  667.                 if ($answer["achieved_attendance"] < 0.9) {

  668.                     $temp_pool_answe = $dispatch->path_to_update_temp_and_black_pool($answer, $temp_order_pool, $Zc_black_order_pool);

  669.                     $temp_order_pool = $temp_pool_answe["temp_order_pool"];

  670.                     $Zc_black_order_pool = $temp_pool_answe["black_order_pool"];

  671. 

  672.                 } else {

  673.                     $temp_bus_and_pool_answer = $dispatch->path_to_update_temp_order_and_aboard($answer, $temp_order_pool, $bus_stock);

  674.                     $white_bus_pool[] = $temp_bus_and_pool_answer["bus"];

  675.                     $temp_order_pool = $temp_bus_and_pool_answer["temp_order_pool"];

  676.                     $bus_stock = $temp_bus_and_pool_answer["bus_stock"];

  677.                 }

  678.                 if (empty($temp_order_pool) && empty($Zc['hotel_list'])) {

  679.                     break;

  680.                 }

  681.             }

  682.         }

  683. 

  684.         if (!empty($Za)) {

  685.             // 存在Za产品订单

  686.             ZA:

  687.             for (; ;) {

  688.                 if (!empty($Za['hotel_list'])) {

  689.                     sort($Za['hotel_list']);

  690.                     $tt_people = 0;

  691.                     for ($temp_peo_i = 0; $temp_peo_i < count($temp_order_pool); $temp_peo_i++) {

  692.                         if (isset($temp_order_pool[$temp_peo_i]["passenger_number"])) {

  693.                             $tt_people = $tt_people + $temp_order_pool[$temp_peo_i]["passenger_number"];

  694.                         }

  695.                     }

  696.                     if ($tt_people < $bus_stock["0"]) {

  697.                         for ($i = 0; $i < count($Za['hotel_list']["0"]["order_list"]); $i++) {

  698.                             $temp_order_pool[] = $Za['hotel_list']["0"]["order_list"][$i];

  699.                         }

  700.                         array_splice($Za['hotel_list'], 0, 1);

  701.                         if (!empty($Za['hotel_list'])) {

  702.                             goto ZA;

  703.                         }

  704.                     }

  705.                 }

  706.                 $orders = $dispatch->change_data_type($temp_order_pool);

  707.                 if (empty($bus_stock)) {

  708.                     $result['code'] = '1';

  709.                     $result['info'] = '车辆库存不足，无法自动派车！';

  710.                     return $result;

  711.                 }

  712.                 $answer = $dispatch->dp($orders, $bus_stock["0"]);

  713.                 if ($answer["achieved_attendance"] < 0.9) {

  714.                     $temp_pool_answe = $dispatch->path_to_update_temp_and_black_pool($answer, $temp_order_pool, $Za_black_order_pool);

  715.                     $temp_order_pool = $temp_pool_answe["temp_order_pool"];

  716.                     $Za_black_order_pool = $temp_pool_answe["black_order_pool"];

  717.                 } else {

  718.                     $temp_bus_and_pool_answer = $dispatch->path_to_update_temp_order_and_aboard($answer, $temp_order_pool, $bus_stock);

  719.                     $white_bus_pool[] = $temp_bus_and_pool_answer["bus"];

  720.                     $temp_order_pool = $temp_bus_and_pool_answer["temp_order_pool"];

  721.                     $bus_stock = $temp_bus_and_pool_answer["bus_stock"];

  722.                 }

  723.                 if (empty($temp_order_pool) && empty($Za['hotel_list'])) {

  724.                     break;

  725.                 }

  726. 

  727.             }

  728.         }

  729. 

  730.         $Min_bus_seat_number = 30;

  731.         $Z_b_c_black_pool = $dispatch->merge_black_pool($Zb_black_order_pool, $Zc_black_order_pool);

  732.         while (true) {

  733.             if (empty($bus_stock)) {

  734.                 $result['code'] = '1';

  735.                 $result['info'] = '车辆库存不足，无法自动派车！';

  736.                 return $result;

  737.             }

  738.             $stock_change_style = $dispatch->bus_stock_change_style($bus_stock, $Min_bus_seat_number);

  739.             if ($dispatch->pool_count_people_number($Z_b_c_black_pool) < $stock_change_style[count($dispatch->bus_stock_change_style($bus_stock, $Min_bus_seat_number)) - 1]["bus_seat_number"] * 0.9) {

  740.                 break;

  741.             }

  742.             $attendance_arr = array();

  743.             for ($temp_ii = 0; $temp_ii < count($dispatch->bus_stock_change_style($bus_stock, $Min_bus_seat_number)); $temp_ii++) {

  744.                 $orders = $dispatch->change_data_type($Z_b_c_black_pool);

  745.                 $temp_data = $dispatch->bus_stock_change_style($bus_stock, $Min_bus_seat_number);

  746.                 $temp_answer = $dispatch->dp($orders, $temp_data[$temp_ii]["bus_seat_number"]);

  747.                 $attendance_arr[$temp_ii] = $temp_answer["achieved_attendance"];

  748.             }

  749.             $existence_best = 0;

  750.             $best_attendance = 0;

  751.             $best_attendance_jj = 0;

  752.             $Max_attendance = 0;

  753.             $Max_attendance_jj = 0;

  754.             for ($temp_jj = 0; $temp_jj < count($attendance_arr); $temp_jj++) {

  755.                 if ($attendance_arr[$temp_jj] > 0.7 && ($temp_data[$temp_jj]["bus_seat_number"] > $dispatch->pool_count_people_number($Z_b_c_black_pool) || $temp_data[$temp_jj]["bus_seat_number"] == $dispatch->pool_count_people_number($Z_b_c_black_pool))) {

  756.                     if ($existence_best == 1) {

  757.                         if ($temp_data[$temp_jj]["bus_seat_number"] < $temp_data[$best_attendance_jj]["bus_seat_number"]) {

  758.                             $best_attendance = $attendance_arr[$temp_jj];

  759.                             $best_attendance_jj = $temp_jj;

  760.                         }

  761.                     } else {

  762.                         $existence_best = 1;

  763.                         $best_attendance = $attendance_arr[$temp_jj];

  764.                         $best_attendance_jj = $temp_jj;

  765.                     }

  766.                 }

  767.                 if ($attendance_arr[$temp_jj] > $Max_attendance) {

  768.                     $Max_attendance = $attendance_arr[$temp_jj];

  769.                     $Max_attendance_jj = $temp_jj;

  770.                 }

  771.             }

  772.             $optimal_answer = array();

  773.             $temp_data = $dispatch->bus_stock_change_style($bus_stock, $Min_bus_seat_number);

  774.             if ($existence_best) {

  775.                 $optimal_answer = $dispatch->dp($orders, $temp_data[$best_attendance_jj]["bus_seat_number"]);

  776.             } else {

  777.                 $optimal_answer = $dispatch->dp($orders, $temp_data[$Max_attendance_jj]["bus_seat_number"]);

  778.             }

  779.             $optimal_bus_and_pool_answer = array();

  780. 

  781. 

  782.             if ($existence_best) {

  783.                 $optimal_bus_and_pool_answer = $dispatch->path_to_update_mix_order_and_aboard($optimal_answer, $Z_b_c_black_pool, $bus_stock,

  784.                     $temp_data[$best_attendance_jj]["bus_seat_number"]);

  785.             } else {

  786.                 $optimal_bus_and_pool_answer = $dispatch->path_to_update_mix_order_and_aboard($optimal_answer, $Z_b_c_black_pool, $bus_stock,

  787.                     $temp_data[$Max_attendance_jj]["bus_seat_number"]);

  788.             }

  789.             $white_bus_pool[] = $optimal_bus_and_pool_answer["bus"];

  790.             $Z_b_c_black_pool = $optimal_bus_and_pool_answer["temp_order_pool"];

  791.             $bus_stock = $optimal_bus_and_pool_answer["bus_stock"];

  792.         }

  793. 

  794. 

  795.         $Z_a_e_black_pool = $dispatch->merge_black_pool($Za_black_order_pool, $Ze_black_order_pool);

  796.         while (true) {

  797.             if (empty($bus_stock)) {

  798.                 $result['code'] = '1';

  799.                 $result['info'] = '车辆库存不足，无法自动派车！';

  800.                 return $result;

  801.             }

  802.             $stock_change_style = $dispatch->bus_stock_change_style($bus_stock, $Min_bus_seat_number);

  803.             if ($dispatch->pool_count_people_number($Z_a_e_black_pool) < $stock_change_style[count($dispatch->bus_stock_change_style($bus_stock, $Min_bus_seat_number)) - 1]["bus_seat_number"] * 0.9) {

  804.                 break;

  805.             }

  806.             $attendance_arr = array();

  807.             for ($temp_ii = 0; $temp_ii < count($dispatch->bus_stock_change_style($bus_stock, $Min_bus_seat_number)); $temp_ii++) {

  808.                 $orders = $dispatch->change_data_type($Z_a_e_black_pool);

  809.                 $temp_data = $dispatch->bus_stock_change_style($bus_stock, $Min_bus_seat_number);

  810.                 $temp_answer = $dispatch->dp($orders, $temp_data[$temp_ii]["bus_seat_number"]);

  811.                 $attendance_arr[$temp_ii] = $temp_answer["achieved_attendance"];

  812.             }

  813.             $existence_best = 0;

  814.             $best_attendance = 0;

  815.             $best_attendance_jj = 0;

  816.             $Max_attendance = 0;

  817.             $Max_attendance_jj = 0;

  818.             for ($temp_jj = 0; $temp_jj < count($attendance_arr); $temp_jj++) {

  819. 

  820.                 if ($attendance_arr[$temp_jj] > 0.7 && ($temp_data[$temp_jj]["bus_seat_number"] > $dispatch->pool_count_people_number($Z_a_e_black_pool) || $temp_data[$temp_jj]["bus_seat_number"] == $dispatch->pool_count_people_number($Z_a_e_black_pool))) {

  821.                     if ($existence_best == 1) {

  822.                         if ($temp_data[$temp_jj]["bus_seat_number"] < $temp_data[$best_attendance_jj]["bus_seat_number"]) {

  823.                             $best_attendance = $attendance_arr[$temp_jj];

  824.                             $best_attendance_jj = $temp_jj;

  825.                         }

  826.                     } else {

  827.                         $existence_best = 1;

  828.                         $best_attendance = $attendance_arr[$temp_jj];

  829.                         $best_attendance_jj = $temp_jj;

  830.                     }

  831.                 }

  832. 

  833.                 if ($attendance_arr[$temp_jj] > $Max_attendance) {

  834.                     $Max_attendance = $attendance_arr[$temp_jj];

  835.                     $Max_attendance_jj = $temp_jj;

  836.                 }

  837.             }

  838.             $optimal_answer = array();

  839.             $temp_data = $dispatch->bus_stock_change_style($bus_stock, $Min_bus_seat_number);

  840.             if ($existence_best) {

  841.                 $optimal_answer = $dispatch->dp($orders, $temp_data[$best_attendance_jj]["bus_seat_number"]);

  842.             } else {

  843.                 $optimal_answer = $dispatch->dp($orders, $temp_data[$Max_attendance_jj]["bus_seat_number"]);

  844.             }

  845.             $optimal_bus_and_pool_answer = array();

  846.             if ($existence_best) {

  847.                 $optimal_bus_and_pool_answer = $dispatch->path_to_update_mix_order_and_aboard($optimal_answer, $Z_a_e_black_pool, $bus_stock,

  848.                     $temp_data[$best_attendance_jj]["bus_seat_number"]);

  849.             } else {

  850.                 $optimal_bus_and_pool_answer = $dispatch->path_to_update_mix_order_and_aboard($optimal_answer, $Z_a_e_black_pool, $bus_stock,

  851.                     $temp_data[$Max_attendance_jj]["bus_seat_number"]);

  852.             }

  853.             $white_bus_pool[] = $optimal_bus_and_pool_answer["bus"];

  854.             $Z_a_e_black_pool = $optimal_bus_and_pool_answer["temp_order_pool"];

  855.             $bus_stock = $optimal_bus_and_pool_answer["bus_stock"];

  856.         }

  857. 

  858. 

  859.         $Z_all_black_pool = $dispatch->merge_black_pool($Z_a_e_black_pool, $Z_b_c_black_pool);

  860.         while ($dispatch->pool_count_people_number($Z_all_black_pool) != 0) {

  861.             if (empty($bus_stock)) {

  862.                 $result['code'] = '1';

  863.                 $result['info'] = '车辆库存不足，无法自动派车！';

  864.                 return $result;

  865.             }

  866.             $attendance_arr = array();

  867.             for ($temp_ii = 0; $temp_ii < count($dispatch->bus_stock_change_style($bus_stock, $Min_bus_seat_number)); $temp_ii++) {

  868.                 $orders = $dispatch->change_data_type($Z_all_black_pool);

  869.                 $temp_data = $dispatch->bus_stock_change_style($bus_stock, $Min_bus_seat_number);

  870.                 $temp_answer = $dispatch->dp($orders, $temp_data[$temp_ii]["bus_seat_number"]);

  871.                 $attendance_arr[$temp_ii] = $temp_answer["achieved_attendance"];

  872.             }

  873.             $existence_best = 0;

  874.             $best_attendance = 0;

  875.             $best_attendance_jj = 0;

  876.             $Max_attendance = 0;

  877.             $Max_attendance_jj = 0;

  878.             for ($temp_jj = 0; $temp_jj < count($attendance_arr); $temp_jj++) {

  879.                 if ($attendance_arr[$temp_jj] > 0.7 && ($temp_data[$temp_jj]["bus_seat_number"] > $dispatch->pool_count_people_number($Z_all_black_pool) || $temp_data[$temp_jj]["bus_seat_number"] == $dispatch->pool_count_people_number($Z_all_black_pool))) {

  880.                     if ($existence_best == 1) {

  881.                         if ($temp_data[$temp_jj]["bus_seat_number"] < $temp_data[$best_attendance_jj]["bus_seat_number"]) {

  882.                             $best_attendance = $attendance_arr[$temp_jj];

  883.                             $best_attendance_jj = $temp_jj;

  884.                         }

  885.                     } else {

  886.                         $existence_best = 1;

  887.                         $best_attendance = $attendance_arr[$temp_jj];

  888.                         $best_attendance_jj = $temp_jj;

  889.                     }

  890.                 }

  891.                 if ($attendance_arr[$temp_jj] > $Max_attendance) {

  892.                     $Max_attendance = $attendance_arr[$temp_jj];

  893.                     $Max_attendance_jj = $temp_jj;

  894.                 }

  895.             }

  896.             $optimal_answer = array();

  897.             $temp_data = $dispatch->bus_stock_change_style($bus_stock, $Min_bus_seat_number);

  898.             if ($existence_best) {

  899.                 $optimal_answer = $dispatch->dp($orders, $temp_data[$best_attendance_jj]["bus_seat_number"]);

  900.             } else {

  901.                 $optimal_answer = $dispatch->dp($orders, $temp_data[$Max_attendance_jj]["bus_seat_number"]);

  902.             }

  903.             $optimal_bus_and_pool_answer = array();

  904. 

  905.             if ($existence_best) {

  906.                 $optimal_bus_and_pool_answer = $dispatch->path_to_update_mix_order_and_aboard($optimal_answer, $Z_all_black_pool, $bus_stock,

  907.                     $temp_data[$best_attendance_jj]["bus_seat_number"]);

  908.             } else {

  909.                 $optimal_bus_and_pool_answer = $dispatch->path_to_update_mix_order_and_aboard($optimal_answer, $Z_all_black_pool, $bus_stock,

  910.                     $temp_data[$Max_attendance_jj]["bus_seat_number"]);

  911.             }

  912.             $white_bus_pool[] = $optimal_bus_and_pool_answer["bus"];

  913.             $Z_all_black_pool = $optimal_bus_and_pool_answer["temp_order_pool"];

  914.             $bus_stock = $optimal_bus_and_pool_answer["bus_stock"];

  915.         }

  916. 

  917. 

  918.         if (!empty($Te)) {

  919.             // 存在Te产品订单

  920.             M:

  921.             for (; ;) {

  922.                 if (!empty($Te['hotel_list'])) {

  923.                     sort($Te['hotel_list']);

  924.                     $tt_people = 0;

  925.                     for ($temp_peo_i = 0; $temp_peo_i < count($temp_order_pool); $temp_peo_i++) {

  926.                         if (isset($temp_order_pool[$temp_peo_i]["passenger_number"])) {

  927.                             $tt_people = $tt_people + $temp_order_pool[$temp_peo_i]["passenger_number"];

  928.                         }

  929.                     }

  930.                     if ($tt_people < $bus_stock["0"]) {

  931.                         for ($i = 0; $i < count($Te['hotel_list']["0"]["order_list"]); $i++) {

  932.                             $temp_order_pool[] = $Te['hotel_list']["0"]["order_list"][$i];

  933.                         }

  934.                         array_splice($Te['hotel_list'], 0, 1);

  935.                         if (!empty($Te['hotel_list'])) {

  936.                             goto M;

  937.                         }

  938.                     }

  939.                 }

  940.                 $orders = $dispatch->change_data_type($temp_order_pool);

  941.                 if (empty($bus_stock)) {

  942.                     $result['code'] = '1';

  943.                     $result['info'] = '车辆库存不足，无法自动派车！';

  944.                     return $result;

  945.                 }

  946.                 $answer = $dispatch->dp($orders, $bus_stock["0"]);

  947.                 if ($answer["achieved_attendance"] < 0.9) {

  948.                     $temp_pool_answe = $dispatch->path_to_update_temp_and_black_pool($answer, $temp_order_pool, $Te_black_order_pool);

  949.                     $temp_order_pool = $temp_pool_answe["temp_order_pool"];

  950.                     $Te_black_order_pool = $temp_pool_answe["black_order_pool"];

  951.                 } else {

  952.                     $temp_bus_and_pool_answer = $dispatch->path_to_update_temp_order_and_aboard($answer, $temp_order_pool, $bus_stock);

  953.                     $white_bus_pool[] = $temp_bus_and_pool_answer["bus"];

  954.                     $temp_order_pool = $temp_bus_and_pool_answer["temp_order_pool"];

  955.                     $bus_stock = $temp_bus_and_pool_answer["bus_stock"];

  956.                 }

  957.                 if (empty($temp_order_pool) && empty($Te['hotel_list'])) {

  958.                     break;

  959.                 }

  960. 

  961.             }

  962.         }

  963. 

  964.         if (!empty($Tb)) {

  965.             // 存在Tb产品订单

  966.             N:

  967.             for (; ;) {

  968.                 if (!empty($Tb['hotel_list'])) {

  969.                     sort($Tb['hotel_list']);

  970.                     $tt_people = 0;

  971.                     for ($temp_peo_i = 0; $temp_peo_i < count($temp_order_pool); $temp_peo_i++) {

  972.                         if (isset($temp_order_pool[$temp_peo_i]["passenger_number"])) {

  973.                             $tt_people = $tt_people + $temp_order_pool[$temp_peo_i]["passenger_number"];

  974.                         }

  975.                     }

  976.                     if ($tt_people < $bus_stock["0"]) {

  977.                         for ($i = 0; $i < count($Tb['hotel_list']["0"]["order_list"]); $i++) {

  978.                             $temp_order_pool[] = $Tb['hotel_list']["0"]["order_list"][$i];

  979.                         }

  980.                         array_splice($Tb['hotel_list'], 0, 1);

  981.                         if (!empty($Tb['hotel_list'])) {

  982.                             goto N;

  983.                         }

  984.                     }

  985.                 }

  986.                 $orders = $dispatch->change_data_type($temp_order_pool);

  987.                 if (empty($bus_stock)) {

  988.                     $result['code'] = '1';

  989.                     $result['info'] = '车辆库存不足，无法自动派车！';

  990.                     return $result;

  991.                 }

  992.                 $answer = $dispatch->dp($orders, $bus_stock["0"]);

  993.                 if ($answer["achieved_attendance"] < 0.9) {

  994.                     $temp_pool_answe = $dispatch->path_to_update_temp_and_black_pool($answer, $temp_order_pool, $Tb_black_order_pool);

  995.                     $temp_order_pool = $temp_pool_answe["temp_order_pool"];

  996.                     $Tb_black_order_pool = $temp_pool_answe["black_order_pool"];

  997.                 } else {

  998.                     $temp_bus_and_pool_answer = $dispatch->path_to_update_temp_order_and_aboard($answer, $temp_order_pool, $bus_stock);

  999.                     $white_bus_pool[] = $temp_bus_and_pool_answer["bus"];

  1000.                     $temp_order_pool = $temp_bus_and_pool_answer["temp_order_pool"];

  1001.                     $bus_stock = $temp_bus_and_pool_answer["bus_stock"];

  1002.                 }

  1003.                 if (empty($temp_order_pool) && empty($Tb['hotel_list'])) {

  1004.                     break;

  1005.                 }

  1006. 

  1007.             }

  1008.         }

  1009. 

  1010.         if (!empty($Tc)) {

  1011.             // 存在Tc产品订单

  1012.             Q:

  1013.             for (; ;) {

  1014.                 if (!empty($Tc['hotel_list'])) {

  1015.                     sort($Tc['hotel_list']);

  1016.                     $tt_people = 0;

  1017.                     for ($temp_peo_i = 0; $temp_peo_i < count($temp_order_pool); $temp_peo_i++) {

  1018.                         if (isset($temp_order_pool[$temp_peo_i]["passenger_number"])) {

  1019.                             $tt_people = $tt_people + $temp_order_pool[$temp_peo_i]["passenger_number"];

  1020.                         }

  1021. 

  1022.                     }

  1023.                     if ($tt_people < $bus_stock["0"]) {

  1024.                         for ($i = 0; $i < count($Tc['hotel_list']["0"]["order_list"]); $i++) {

  1025.                             $temp_order_pool[] = $Tc['hotel_list']["0"]["order_list"][$i];

  1026.                         }

  1027.                         array_splice($Tc['hotel_list'], 0, 1);

  1028.                         if (!empty($Tc['hotel_list'])) {

  1029.                             goto Q;

  1030.                         }

  1031.                     }

  1032.                 }

  1033.                 $orders = $dispatch->change_data_type($temp_order_pool);

  1034.                 if (empty($bus_stock)) {

  1035.                     $result['code'] = '1';

  1036.                     $result['info'] = '车辆库存不足，无法自动派车！';

  1037.                     return $result;

  1038.                 }

  1039.                 $answer = $dispatch->dp($orders, $bus_stock["0"]);

  1040.                 if ($answer["achieved_attendance"] < 0.9) {

  1041.                     $temp_pool_answe = $dispatch->path_to_update_temp_and_black_pool($answer, $temp_order_pool, $Tc_black_order_pool);

  1042.                     $temp_order_pool = $temp_pool_answe["temp_order_pool"];

  1043.                     $Tc_black_order_pool = $temp_pool_answe["black_order_pool"];

  1044. 

  1045.                 } else {

  1046.                     $temp_bus_and_pool_answer = $dispatch->path_to_update_temp_order_and_aboard($answer, $temp_order_pool, $bus_stock);

  1047.                     $white_bus_pool[] = $temp_bus_and_pool_answer["bus"];

  1048.                     $temp_order_pool = $temp_bus_and_pool_answer["temp_order_pool"];

  1049.                     $bus_stock = $temp_bus_and_pool_answer["bus_stock"];

  1050.                 }

  1051.                 if (empty($temp_order_pool) && empty($Tc['hotel_list'])) {

  1052.                     break;

  1053.                 }

  1054. 

  1055.             }

  1056.         }

  1057. 

  1058.         if (!empty($Ta)) {

  1059.             // 存在Ta产品订单

  1060.             E:

  1061.             for (; ;) {

  1062.                 if (!empty($Ta['hotel_list'])) {

  1063.                     sort($Ta['hotel_list']);

  1064.                     $tt_people = 0;

  1065.                     for ($temp_peo_i = 0; $temp_peo_i < count($temp_order_pool); $temp_peo_i++) {

  1066.                         if (isset($temp_order_pool[$temp_peo_i]["passenger_number"])) {

  1067.                             $tt_people = $tt_people + $temp_order_pool[$temp_peo_i]["passenger_number"];

  1068.                         }

  1069. 

  1070.                     }

  1071.                     if ($tt_people < $bus_stock["0"]) {

  1072.                         for ($i = 0; $i < count($Ta['hotel_list']["0"]["order_list"]); $i++) {

  1073.                             $temp_order_pool[] = $Ta['hotel_list']["0"]["order_list"][$i];

  1074.                         }

  1075.                         array_splice($Ta['hotel_list'], 0, 1);

  1076.                         if (!empty($Ta['hotel_list'])) {

  1077.                             goto E;

  1078.                         }

  1079.                     }

  1080.                 }

  1081.                 $orders = $dispatch->change_data_type($temp_order_pool);

  1082.                 if (empty($bus_stock)) {

  1083.                     $result['code'] = '1';

  1084.                     $result['info'] = '车辆库存不足，无法自动派车！';

  1085.                     return $result;

  1086.                 }

  1087.                 $answer = $dispatch->dp($orders, $bus_stock["0"]);

  1088.                 if ($answer["achieved_attendance"] < 0.9) {

  1089.                     $temp_pool_answe = $dispatch->path_to_update_temp_and_black_pool($answer, $temp_order_pool, $Ta_black_order_pool);

  1090.                     $temp_order_pool = $temp_pool_answe["temp_order_pool"];

  1091.                     $Ta_black_order_pool = $temp_pool_answe["black_order_pool"];

  1092.                 } else {

  1093.                     $temp_bus_and_pool_answer = $dispatch->path_to_update_temp_order_and_aboard($answer, $temp_order_pool, $bus_stock);

  1094.                     $white_bus_pool[] = $temp_bus_and_pool_answer["bus"];

  1095.                     $temp_order_pool = $temp_bus_and_pool_answer["temp_order_pool"];

  1096.                     $bus_stock = $temp_bus_and_pool_answer["bus_stock"];

  1097.                 }

  1098.                 if (empty($temp_order_pool) && empty($Ta['hotel_list'])) {

  1099.                     break;

  1100.                 }

  1101. 

  1102.             }

  1103.         }

  1104. 

  1105.         $Min_bus_seat_number = 30;

  1106.         $b_c_black_pool = $dispatch->merge_black_pool($Tb_black_order_pool, $Tc_black_order_pool);

  1107.         while (true) {

  1108.             if (empty($bus_stock)) {

  1109.                 $result['code'] = '1';

  1110.                 $result['info'] = '车辆库存不足，无法自动派车！';

  1111.                 return $result;

  1112.             }

  1113.             $stock_change_style = $dispatch->bus_stock_change_style($bus_stock, $Min_bus_seat_number);

  1114.             if ($dispatch->pool_count_people_number($b_c_black_pool) < $stock_change_style[count($dispatch->bus_stock_change_style($bus_stock, $Min_bus_seat_number)) - 1]["bus_seat_number"] * 0.9) {

  1115.                 break;

  1116.             }

  1117.             $attendance_arr = array();

  1118.             for ($temp_ii = 0; $temp_ii < count($dispatch->bus_stock_change_style($bus_stock, $Min_bus_seat_number)); $temp_ii++) {

  1119.                 $orders = $dispatch->change_data_type($b_c_black_pool);

  1120.                 $temp_data = $dispatch->bus_stock_change_style($bus_stock, $Min_bus_seat_number);

  1121.                 $temp_answer = $dispatch->dp($orders, $temp_data[$temp_ii]["bus_seat_number"]);

  1122.                 $attendance_arr[$temp_ii] = $temp_answer["achieved_attendance"];

  1123.             }

  1124.             $existence_best = 0;

  1125.             $best_attendance = 0;

  1126.             $best_attendance_jj = 0;

  1127.             $Max_attendance = 0;

  1128.             $Max_attendance_jj = 0;

  1129.             for ($temp_jj = 0; $temp_jj < count($attendance_arr); $temp_jj++) {

  1130.                 if ($attendance_arr[$temp_jj] > 0.7 && ($temp_data[$temp_jj]["bus_seat_number"] > $dispatch->pool_count_people_number($b_c_black_pool) || $temp_data[$temp_jj]["bus_seat_number"] == $dispatch->pool_count_people_number($b_c_black_pool))) {

  1131.                     if ($existence_best == 1) {

  1132.                         if ($temp_data[$temp_jj]["bus_seat_number"] < $temp_data[$best_attendance_jj]["bus_seat_number"]) {

  1133.                             $best_attendance = $attendance_arr[$temp_jj];

  1134.                             $best_attendance_jj = $temp_jj;

  1135.                         }

  1136.                     } else {

  1137.                         $existence_best = 1;

  1138.                         $best_attendance = $attendance_arr[$temp_jj];

  1139.                         $best_attendance_jj = $temp_jj;

  1140.                     }

  1141.                 }

  1142.                 if ($attendance_arr[$temp_jj] > $Max_attendance) {

  1143.                     $Max_attendance = $attendance_arr[$temp_jj];

  1144.                     $Max_attendance_jj = $temp_jj;

  1145.                 }

  1146.             }

  1147.             $optimal_answer = array();

  1148.             $temp_data = $dispatch->bus_stock_change_style($bus_stock, $Min_bus_seat_number);

  1149.             if ($existence_best) {

  1150.                 $optimal_answer = $dispatch->dp($orders, $temp_data[$best_attendance_jj]["bus_seat_number"]);

  1151.             } else {

  1152.                 $optimal_answer = $dispatch->dp($orders, $temp_data[$Max_attendance_jj]["bus_seat_number"]);

  1153.             }

  1154.             $optimal_bus_and_pool_answer = array();

  1155.             if ($existence_best) {

  1156.                 $optimal_bus_and_pool_answer = $dispatch->path_to_update_mix_order_and_aboard($optimal_answer, $b_c_black_pool, $bus_stock,

  1157.                     $temp_data[$best_attendance_jj]["bus_seat_number"]);

  1158.             } else {

  1159.                 $optimal_bus_and_pool_answer = $dispatch->path_to_update_mix_order_and_aboard($optimal_answer, $b_c_black_pool, $bus_stock,

  1160.                     $temp_data[$Max_attendance_jj]["bus_seat_number"]);

  1161.             }

  1162.             $white_bus_pool[] = $optimal_bus_and_pool_answer["bus"];

  1163.             $b_c_black_pool = $optimal_bus_and_pool_answer["temp_order_pool"];

  1164.             $bus_stock = $optimal_bus_and_pool_answer["bus_stock"];

  1165.         }

  1166. 

  1167.         $a_e_black_pool = $dispatch->merge_black_pool($Ta_black_order_pool, $Te_black_order_pool);

  1168.         while (true) {

  1169.             if (empty($bus_stock)) {

  1170.                 $result['code'] = '1';

  1171.                 $result['info'] = '车辆库存不足，无法自动派车！';

  1172.                 return $result;

  1173.             }

  1174.             $stock_change_style = $dispatch->bus_stock_change_style($bus_stock, $Min_bus_seat_number);

  1175.             if ($dispatch->pool_count_people_number($a_e_black_pool) < $stock_change_style[count($dispatch->bus_stock_change_style($bus_stock, $Min_bus_seat_number)) - 1]["bus_seat_number"] * 0.9) {

  1176.                 break;

  1177.             }

  1178.             $attendance_arr = array();

  1179.             for ($temp_ii = 0; $temp_ii < count($dispatch->bus_stock_change_style($bus_stock, $Min_bus_seat_number)); $temp_ii++) {

  1180.                 $orders = $dispatch->change_data_type($a_e_black_pool);

  1181.                 $temp_data = $dispatch->bus_stock_change_style($bus_stock, $Min_bus_seat_number);

  1182.                 $temp_answer = $dispatch->dp($orders, $temp_data[$temp_ii]["bus_seat_number"]);

  1183.                 $attendance_arr[$temp_ii] = $temp_answer["achieved_attendance"];

  1184.             }

  1185.             $existence_best = 0;

  1186.             $best_attendance = 0;

  1187.             $best_attendance_jj = 0;

  1188.             $Max_attendance = 0;

  1189.             $Max_attendance_jj = 0;

  1190.             for ($temp_jj = 0; $temp_jj < count($attendance_arr); $temp_jj++) {

  1191.                 if ($attendance_arr[$temp_jj] > 0.7 && ($temp_data[$temp_jj]["bus_seat_number"] > $dispatch->pool_count_people_number($a_e_black_pool) || $temp_data[$temp_jj]["bus_seat_number"] == $dispatch->pool_count_people_number($a_e_black_pool))) {

  1192.                     if ($existence_best == 1) {

  1193.                         if ($temp_data[$temp_jj]["bus_seat_number"] < $temp_data[$best_attendance_jj]["bus_seat_number"]) {

  1194.                             $best_attendance = $attendance_arr[$temp_jj];

  1195.                             $best_attendance_jj = $temp_jj;

  1196.                         }

  1197.                     } else {

  1198.                         $existence_best = 1;

  1199.                         $best_attendance = $attendance_arr[$temp_jj];

  1200.                         $best_attendance_jj = $temp_jj;

  1201.                     }

  1202.                 }

  1203.                 if ($attendance_arr[$temp_jj] > $Max_attendance) {

  1204.                     $Max_attendance = $attendance_arr[$temp_jj];

  1205.                     $Max_attendance_jj = $temp_jj;

  1206.                 }

  1207.             }

  1208.             $optimal_answer = array();

  1209.             $temp_data = $dispatch->bus_stock_change_style($bus_stock, $Min_bus_seat_number);

  1210.             if ($existence_best) {

  1211.                 $optimal_answer = $dispatch->dp($orders, $temp_data[$best_attendance_jj]["bus_seat_number"]);

  1212.             } else {

  1213.                 $optimal_answer = $dispatch->dp($orders, $temp_data[$Max_attendance_jj]["bus_seat_number"]);

  1214.             }

  1215.             $optimal_bus_and_pool_answer = array();

  1216.             if ($existence_best) {

  1217.                 $optimal_bus_and_pool_answer = $dispatch->path_to_update_mix_order_and_aboard($optimal_answer, $a_e_black_pool, $bus_stock,

  1218.                     $temp_data[$best_attendance_jj]["bus_seat_number"]);

  1219.             } else {

  1220.                 $optimal_bus_and_pool_answer = $dispatch->path_to_update_mix_order_and_aboard($optimal_answer, $a_e_black_pool, $bus_stock,

  1221.                     $temp_data[$Max_attendance_jj]["bus_seat_number"]);

  1222.             }

  1223.             $white_bus_pool[] = $optimal_bus_and_pool_answer["bus"];

  1224.             $a_e_black_pool = $optimal_bus_and_pool_answer["temp_order_pool"];

  1225.             $bus_stock = $optimal_bus_and_pool_answer["bus_stock"];

  1226.         }

  1227. 

  1228.         $all_black_pool = $dispatch->merge_black_pool($a_e_black_pool, $b_c_black_pool);// 得到ae的合并拼车pool

  1229.         while ($dispatch->pool_count_people_number($all_black_pool) != 0) {

  1230.             if (empty($bus_stock)) {

  1231.                 $result['code'] = '1';

  1232.                 $result['info'] = '车辆库存不足，无法自动派车！';

  1233.                 return $result;

  1234.             }

  1235.             $attendance_arr = array();//判断筛选最优上座率

  1236.             for ($temp_ii = 0; $temp_ii < count($dispatch->bus_stock_change_style($bus_stock, $Min_bus_seat_number)); $temp_ii++) {

  1237.                 $orders = $dispatch->change_data_type($all_black_pool);

  1238.                 $temp_data = $dispatch->bus_stock_change_style($bus_stock, $Min_bus_seat_number);

  1239.                 $temp_answer = $dispatch->dp($orders, $temp_data[$temp_ii]["bus_seat_number"]);

  1240.                 $attendance_arr[$temp_ii] = $temp_answer["achieved_attendance"];// 记录每种车型的上座率

  1241.             }

  1242.             $existence_best = 0;

  1243.             $best_attendance = 0;

  1244.             $best_attendance_jj = 0;

  1245.             $Max_attendance = 0;

  1246.             $Max_attendance_jj = 0;

  1247.             for ($temp_jj = 0; $temp_jj < count($attendance_arr); $temp_jj++) {

  1248.                 if ($attendance_arr[$temp_jj] > 0.7 && ($temp_data[$temp_jj]["bus_seat_number"] > $dispatch->pool_count_people_number($all_black_pool) || $temp_data[$temp_jj]["bus_seat_number"] == $dispatch->pool_count_people_number($all_black_pool))) {

  1249.                     if ($existence_best == 1) {

  1250.                         if ($temp_data[$temp_jj]["bus_seat_number"] < $temp_data[$best_attendance_jj]["bus_seat_number"]) {

  1251.                             $best_attendance = $attendance_arr[$temp_jj];

  1252.                             $best_attendance_jj = $temp_jj;

  1253.                         }

  1254.                     } else {

  1255.                         $existence_best = 1;

  1256.                         $best_attendance = $attendance_arr[$temp_jj];

  1257.                         $best_attendance_jj = $temp_jj;

  1258.                     }

  1259.                 }

  1260.                 if ($attendance_arr[$temp_jj] > $Max_attendance) {

  1261.                     $Max_attendance = $attendance_arr[$temp_jj];

  1262.                     $Max_attendance_jj = $temp_jj;

  1263.                 }

  1264.             }

  1265.             $optimal_answer = array();

  1266.             $temp_data = $dispatch->bus_stock_change_style($bus_stock, $Min_bus_seat_number);

  1267.             if ($existence_best) {

  1268.                 $optimal_answer = $dispatch->dp($orders, $temp_data[$best_attendance_jj]["bus_seat_number"]);

  1269.             } else {

  1270.                 $optimal_answer = $dispatch->dp($orders, $temp_data[$Max_attendance_jj]["bus_seat_number"]);

  1271.             }

  1272.             $optimal_bus_and_pool_answer = array();

  1273.             if ($existence_best) {

  1274.                 $optimal_bus_and_pool_answer = $dispatch->path_to_update_mix_order_and_aboard($optimal_answer, $all_black_pool, $bus_stock,

  1275.                     $temp_data[$best_attendance_jj]["bus_seat_number"]);

  1276.             } else {

  1277.                 $optimal_bus_and_pool_answer = $dispatch->path_to_update_mix_order_and_aboard($optimal_answer, $all_black_pool, $bus_stock,

  1278.                     $temp_data[$Max_attendance_jj]["bus_seat_number"]);

  1279.             }

  1280.             $white_bus_pool[] = $optimal_bus_and_pool_answer["bus"];

  1281.             $all_black_pool = $optimal_bus_and_pool_answer["temp_order_pool"];

  1282.             $bus_stock = $optimal_bus_and_pool_answer["bus_stock"];

  1283.         }

  1284. 

  1285.         if (!empty($Taeab)) {

  1286.             // 存在$Taeab产品订单

  1287.             P:

  1288.             for (; ;) {

  1289.                 if (!empty($Taeab['hotel_list'])) {

  1290.                     sort($Taeab['hotel_list']);

  1291.                     $tt_people = 0;

  1292.                     for ($temp_peo_i = 0; $temp_peo_i < count($temp_order_pool); $temp_peo_i++) {

  1293.                         if (isset($temp_order_pool[$temp_peo_i]["passenger_number"])) {

  1294.                             $tt_people = $tt_people + $temp_order_pool[$temp_peo_i]["passenger_number"];

  1295.                         }

  1296. 

  1297.                     }

  1298.                     if ($tt_people < $bus_stock["0"]) {

  1299.                         for ($i = 0; $i < count($Taeab['hotel_list']["0"]["order_list"]); $i++) {

  1300.                             $temp_order_pool[] = $Taeab['hotel_list']["0"]["order_list"][$i];

  1301.                         }

  1302.                         array_splice($Taeab['hotel_list'], 0, 1);

  1303.                         if (!empty($Taeab['hotel_list'])) {

  1304.                             goto P;

  1305.                         }

  1306.                     }

  1307.                 }

  1308.                 $orders = $dispatch->change_data_type($temp_order_pool);

  1309.                 if (empty($bus_stock)) {

  1310.                     $result['code'] = '1';

  1311.                     $result['info'] = '车辆库存不足，无法自动派车！';

  1312.                     return $result;

  1313.                 }

  1314.                 $answer = $dispatch->dp($orders, $bus_stock["0"]);

  1315.                 if ($answer["achieved_attendance"] < 0.9) {

  1316.                     $temp_pool_answe = $dispatch->path_to_update_temp_and_black_pool($answer, $temp_order_pool, $Taeab_two_scenic_black_order_pool);

  1317.                     $temp_order_pool = $temp_pool_answe["temp_order_pool"];

  1318.                     $Taeab_two_scenic_black_order_pool = $temp_pool_answe["black_order_pool"];

  1319. 

  1320.                 } else {

  1321.                     $temp_bus_and_pool_answer = $dispatch->path_to_update_temp_order_and_aboard($answer, $temp_order_pool, $bus_stock);

  1322.                     $white_bus_pool[] = $temp_bus_and_pool_answer["bus"];

  1323.                     $temp_order_pool = $temp_bus_and_pool_answer["temp_order_pool"];

  1324.                     $bus_stock = $temp_bus_and_pool_answer["bus_stock"];

  1325.                 }

  1326.                 if (empty($temp_order_pool) && empty($Taeab['hotel_list'])) {

  1327.                     break;

  1328.                 }

  1329. 

  1330.             }

  1331.         }

  1332. 

  1333.         if (!empty($Tbcbe)) {

  1334.             // 存在$Tbcbe产品订单

  1335.             O:

  1336.             for (; ;) {

  1337.                 if (!empty($Tbcbe['hotel_list'])) {

  1338.                     sort($Tbcbe['hotel_list']);

  1339.                     $tt_people = 0;

  1340.                     for ($temp_peo_i = 0; $temp_peo_i < count($temp_order_pool); $temp_peo_i++) {

  1341.                         if (isset($temp_order_pool[$temp_peo_i]["passenger_number"])) {

  1342.                             $tt_people = $tt_people + $temp_order_pool[$temp_peo_i]["passenger_number"];

  1343.                         }

  1344. 

  1345.                     }

  1346.                     if ($tt_people < $bus_stock["0"]) {

  1347.                         for ($i = 0; $i < count($Tbcbe['hotel_list']["0"]["order_list"]); $i++) {

  1348.                             $temp_order_pool[] = $Tbcbe['hotel_list']["0"]["order_list"][$i];

  1349.                         }

  1350.                         array_splice($Tbcbe['hotel_list'], 0, 1);

  1351.                         if (!empty($Tbcbe['hotel_list'])) {

  1352.                             goto O;

  1353.                         }

  1354.                     }

  1355.                 }

  1356.                 $orders = $dispatch->change_data_type($temp_order_pool);

  1357.                 if (empty($bus_stock)) {

  1358.                     $result['code'] = '1';

  1359.                     $result['info'] = '车辆库存不足，无法自动派车！';

  1360.                     return $result;

  1361.                 }

  1362.                 $answer = $dispatch->dp($orders, $bus_stock["0"]);

  1363.                 if ($answer["achieved_attendance"] < 0.9) {

  1364.                     $temp_pool_answe = $dispatch->path_to_update_temp_and_black_pool($answer, $temp_order_pool, $Tbcbe_two_scenic_black_order_pool);

  1365.                     $temp_order_pool = $temp_pool_answe["temp_order_pool"];

  1366.                     $Tbcbe_two_scenic_black_order_pool = $temp_pool_answe["black_order_pool"];

  1367.                 } else {

  1368.                     $temp_bus_and_pool_answer = $dispatch->path_to_update_temp_order_and_aboard($answer, $temp_order_pool, $bus_stock);

  1369.                     $white_bus_pool[] = $temp_bus_and_pool_answer["bus"];

  1370.                     $temp_order_pool = $temp_bus_and_pool_answer["temp_order_pool"];

  1371.                     $bus_stock = $temp_bus_and_pool_answer["bus_stock"];

  1372.                 }

  1373.                 if (empty($temp_order_pool) && empty($Tbcbe['hotel_list'])) {

  1374.                     break;

  1375.                 }

  1376. 

  1377.             }

  1378.         }

  1379. 

  1380.         $two_scenic_all_black_pool = $dispatch->merge_black_pool($Taeab_two_scenic_black_order_pool, $Tbcbe_two_scenic_black_order_pool);// 得到ae ab和bcbe的合并拼车pool

  1381.         while ($dispatch->pool_count_people_number($two_scenic_all_black_pool) != 0) {

  1382.             if (empty($bus_stock)) {

  1383.                 $result['code'] = '1';

  1384.                 $result['info'] = '车辆库存不足，无法自动派车！';

  1385.                 return $result;

  1386.             }

  1387.             $attendance_arr = array();

  1388.             for ($temp_ii = 0; $temp_ii < count($dispatch->bus_stock_change_style($bus_stock, $Min_bus_seat_number)); $temp_ii++) {

  1389.                 $orders = $dispatch->change_data_type($two_scenic_all_black_pool);

  1390.                 $temp_data = $dispatch->bus_stock_change_style($bus_stock, $Min_bus_seat_number);

  1391.                 $temp_answer = $dispatch->dp($orders, $temp_data[$temp_ii]["bus_seat_number"]);

  1392.                 $attendance_arr[$temp_ii] = $temp_answer["achieved_attendance"];

  1393.             }

  1394.             $existence_best = 0;

  1395.             $best_attendance = 0;

  1396.             $best_attendance_jj = 0;

  1397.             $Max_attendance = 0;

  1398.             $Max_attendance_jj = 0;

  1399.             for ($temp_jj = 0; $temp_jj < count($attendance_arr); $temp_jj++) {

  1400.                 if ($attendance_arr[$temp_jj] > 0.7 && ($temp_data[$temp_jj]["bus_seat_number"] > $dispatch->pool_count_people_number($two_scenic_all_black_pool) || $temp_data[$temp_jj]["bus_seat_number"] == $dispatch->pool_count_people_number($two_scenic_all_black_pool))) {

  1401.                     if ($existence_best == 1) {

  1402.                         if ($temp_data[$temp_jj]["bus_seat_number"] < $temp_data[$best_attendance_jj]["bus_seat_number"]) {

  1403.                             $best_attendance = $attendance_arr[$temp_jj];

  1404.                             $best_attendance_jj = $temp_jj;

  1405.                         }

  1406.                     } else {

  1407.                         $existence_best = 1;

  1408.                         $best_attendance = $attendance_arr[$temp_jj];

  1409.                         $best_attendance_jj = $temp_jj;

  1410.                     }

  1411.                 }

  1412.                 if ($attendance_arr[$temp_jj] > $Max_attendance) {

  1413.                     $Max_attendance = $attendance_arr[$temp_jj];

  1414.                     $Max_attendance_jj = $temp_jj;

  1415.                 }

  1416.             }

  1417.             $temp_data = $dispatch->bus_stock_change_style($bus_stock, $Min_bus_seat_number);

  1418.             if ($existence_best) {

  1419.                 $optimal_answer = $dispatch->dp($orders, $temp_data[$best_attendance_jj]["bus_seat_number"]);

  1420.             } else {

  1421.                 $optimal_answer = $dispatch->dp($orders, $temp_data[$Max_attendance_jj]["bus_seat_number"]);

  1422.             }

  1423.             if ($existence_best) {

  1424.                 $optimal_bus_and_pool_answer = $dispatch->path_to_update_mix_order_and_aboard($optimal_answer, $two_scenic_all_black_pool, $bus_stock,

  1425.                     $temp_data[$best_attendance_jj]["bus_seat_number"]);

  1426.             } else {

  1427.                 $optimal_bus_and_pool_answer = $dispatch->path_to_update_mix_order_and_aboard($optimal_answer, $two_scenic_all_black_pool, $bus_stock,

  1428.                     $temp_data[$Max_attendance_jj]["bus_seat_number"]);

  1429.             }

  1430.             $white_bus_pool[] = $optimal_bus_and_pool_answer["bus"];

  1431.             $two_scenic_all_black_pool = $optimal_bus_and_pool_answer["temp_order_pool"];

  1432.             $bus_stock = $optimal_bus_and_pool_answer["bus_stock"];

  1433.         }

  1434.         $sql_dispatch = '';

  1435.         $final_info = array();

  1436.         foreach ($white_bus_pool as $temp11) {

  1437.             foreach ($bus_detail as $k => $detail) {

  1438.                 if ($temp11['bus_seat_number'] == $detail[0]) {

  1439.                     $temp11['info'] = $detail;

  1440.                     $final_info[] = $temp11;

  1441.                     unset($bus_detail[$k]);

  1442.                     break;

  1443.                 }

  1444.             }

  1445.         }

  1446.         #endregion

  1447.         $bus_order_id = 1;  //初始化车次编号

  1448.         //SQL:查询order_main中有没有当前的班次，如果有，说明不是第一次点击分成

  1449.         $sql_exist = "select run_id from run_main where RUN_DATE='{$param['run_date']}' AND PROD_ID=0 LIMIT 1";

  1450.         $res_exist = $this->query($sql_exist);

  1451.         if ($res_exist) {//如果是今天的第二次或者多次点击自动分车  更新run_bus

  1452.             #----以下---这里要对已分车的订单做处理，否则形如z(j)这样的线路订单在二次分车时会出现错误，因为它不在分车算法内，所以仅用覆盖的方法会漏掉。---温依莅

  1453.             //首先得到分车算法覆盖的订单，和今日的订单做比对

  1454.             #分车算法已分的子订单集合

  1455.             $str_order_id = '';

  1456.             foreach ($final_info as $k => $v) {  //$k:派了第几辆车

  1457.                 $sub_order_id = '';

  1458.                 foreach ($v['order_list'] as $k1 => $v1) {  // $v1: 订单信息

  1459.                     $sub_order_id .= $v1['sub_order_id'] . ',';  //单一线路订单ID列表

  1460.                 }

  1461.                 $str_order_id .= $sub_order_id;

  1462.             }

  1463.             $after_order_arr = explode(',', trim($str_order_id, ','));

  1464.             #今日所有应分配的子订单集合

  1465.             $all_sub_order_id = '';

  1466.             foreach ($res['data'][0] as $k2 => $v2) {  //$k:派了第几辆车

  1467.                 $all_sub_order_id .= $v2['sub_order_id'] . ',';  //单一线路订单ID列表

  1468.             }

  1469.             $all_str_order_id = substr($all_sub_order_id, 0, -1);

  1470.             $all_order_arr = explode(',', $all_str_order_id);

  1471. 

  1472.             //作比较得到未参与分车的订单集合

  1473.             $diff_arr = array_diff($all_order_arr, $after_order_arr);

  1474.             $diff_str = implode(',', $diff_arr);

  1475.             //如果非空则设置run_bus_order_id为0

  1476.             if (!empty($diff_arr)) {

  1477.                 $sql = "update order_main set run_bus_order_id=0 where order_id in ($diff_str);";

  1478.                 zzcsUtils::writeLog($sql);

  1479.                 $tmres = $this->exec($sql);

  1480.                 if (false === $tmres) {

  1481.                     $result['code'] = '5';

  1482.                     $result['info'] = '重置部分订单失败';

  1483.                     return $result;

  1484.                 }

  1485.             }

  1486.             #----以上----#

  1487.             //SQL:获取当前已经存在的所有车次

  1488.             $sql_bus_order_id = "select bus_order_id from run_bus where run_id={$res_exist[0]['run_id']} AND CANCEL_FLAG=0";

  1489.             $res_bus_order_id = $this->query($sql_bus_order_id);

  1490.             $arr_bus_order_id = array();

  1491.             foreach ($res_bus_order_id as $bus_id) {

  1492.                 $arr_bus_order_id[] = $bus_id['bus_order_id'];

  1493.             }

  1494.             //$sql_dispatch .= "delete  from run_bus WHERE run_id={$res_exist[0]['run_id']};";

  1495.             foreach ($final_info as $k => $v) {  //$k:派了第几辆车

  1496.                 $seat_type = $v['bus_seat_number'];//车辆座位类型

  1497.                 $seated_count = $v["already_seat_number"];  //已经入坐的人数

  1498.                 $brand_id = $v['info'][2];    //车辆品牌ID   info[0]:seat_count;info[1]:bus_id ;info[2]:brand_id

  1499.                 if (in_array($bus_order_id, $arr_bus_order_id)) {   //当前车次号已经存在，不需要在run_bus中添加，更新就可以了

  1500.                     $sql_dispatch .= "update run_bus SET UPDATE_USER_ID={$user_id},UPDATE_TIME=NOW(),run_id={$res_exist[0]['run_id']},bus_order_id={$bus_order_id},

  1501.                                       bus_type_res_id={$v['info'][3]},seat_count={$seat_type},saled_count={$seated_count},brand_res_id={$brand_id},RUN_BUS_STATUS=138,send_bus_res_id=0,send_bus_type_res_id=0,send_bus_driver_res_id=0,send_bus_no='',send_driver_name='',send_driver_mobile='',send_tour_guide_name='',send_tour_guide_res_id=0,send_tour_guide_mobile='',GROUP_LINE_FLAG=1,REAL_TOTAL_COUNT={$seated_count} WHERE run_id={$res_exist[0]['run_id']} AND BUS_ORDER_ID={$bus_order_id};";

  1502.                     foreach ($arr_bus_order_id as $bus_k => $bus_v) {

  1503.                         if ($bus_v == $bus_order_id) {

  1504.                             unset($arr_bus_order_id[$bus_k]);

  1505.                         }

  1506.                     }

  1507.                 } else {

  1508.                     $sql_dispatch .= "INSERT INTO run_bus(CREATE_USER_ID,CREATE_TIME,UPDATE_USER_ID,UPDATE_TIME,run_id,bus_order_id,bus_type_res_id,

  1509.                                       seat_count,saled_count,brand_res_id,RUN_BUS_STATUS,GROUP_LINE_FLAG,REAL_TOTAL_COUNT) VALUES($user_id,now(),$user_id,now(),{$res_exist[0]['run_id']},$bus_order_id,{$v['info'][3]},$seat_type,$seated_count,$brand_id,138,1,{$seated_count});";

  1510.                 }

  1511.                 $sub_order_id = '';

  1512.                 foreach ($v['order_list'] as $k1 => $v1) {  // $v1: 订单信息

  1513.                     $sub_order_id .= $v1['sub_order_id'] . ',';  //单一线路订单ID列表

  1514.                 }

  1515.                 $str_order_id = substr($sub_order_id, 0, -1);

  1516.                 $sql_dispatch .= "update order_main set UPDATE_USER_ID=$user_id,UPDATE_TIME=now(),RUN_ID={$res_exist[0]['run_id']},RUN_BUS_ORDER_ID=$bus_order_id WHERE order_id IN($str_order_id);";

  1517.                 $bus_order_id++;

  1518.             }

  1519.             $arr_bus_order_id;

  1520.             if (!empty($arr_bus_order_id)) {    //TODO:多次点击派车时，需要将之前派出的车次但是本次并没有用到的车的cancel_flag置为1

  1521.                 $cancel_bus_id = '';

  1522.                 foreach ($arr_bus_order_id as $v_bus) {

  1523.                     $cancel_bus_id .= $v_bus . ',';

  1524.                 }

  1525.                 $cancel_bus_id = substr($cancel_bus_id, 0, -1);

  1526.                 $sql_dispatch .= "update run_bus set CANCEL_FLAG=1 WHERE run_id={$res_exist[0]['run_id']} AND BUS_ORDER_ID in ($cancel_bus_id);";

  1527.             }

  1528.         } else {//第一次点击自动分车

  1529.             $sql_get_run_id = "SELECT FUNC_GET_UNIQUE_ID(3,1) as run_id";       //生成新的run_id

  1530.             $res_run_id = $this->query($sql_get_run_id);  //得到run_id

  1531.             $start_time = '';

  1532.             foreach ($final_info as $k => $v) {  //$k:派了第几辆车

  1533.                 $seat_type = $v['bus_seat_number'];//车辆座位类型

  1534.                 $seated_count = $v["already_seat_number"];  //已经入坐的人数

  1535.                 $brand_id = $v['info'][2];    //车辆品牌ID   info[0]:seat_count;info[1]:bus_id ;info[2]:brand_id

  1536.                 $sql_dispatch .= "INSERT INTO run_bus(CREATE_USER_ID,CREATE_TIME,UPDATE_USER_ID,UPDATE_TIME,run_id,bus_order_id,bus_type_res_id,saled_count,seat_count,brand_res_id,RUN_BUS_STATUS,GROUP_LINE_FLAG,REAL_TOTAL_COUNT) VALUES($user_id,now(),$user_id,now(),{$res_run_id[0]['run_id']},$bus_order_id,{$v['info'][3]},$seated_count,$seat_type,$brand_id,138,1,{$seated_count});";

  1537.                 $sub_order_id = '';

  1538.                 foreach ($v['order_list'] as $k1 => $v1) {  // $v1: 订单信息

  1539.                     $sub_order_id .= $v1['sub_order_id'] . ',';  //单一线路订单ID列表

  1540.                 }

  1541.                 $start_time = $v['order_list'][0]['start_time'];

  1542.                 $str_order_id = substr($sub_order_id, 0, -1);

  1543.                 $sql_dispatch .= "update order_main set UPDATE_USER_ID=$user_id,UPDATE_TIME=now(),RUN_ID={$res_run_id[0]['run_id']},RUN_BUS_ORDER_ID=$bus_order_id WHERE order_id IN($str_order_id);";

  1544.                 $bus_order_id++;

  1545.             }

  1546.             $time = explode(':', $start_time);

  1547.             $run_minutes = $time[0] * 60 + $time[1];

  1548.             $sql_dispatch .= "INSERT INTO run_main(run_id,run_lock_type,run_date,run_time,run_minutes,create_user_id,create_time,run_status) VALUES({$res_run_id[0]['run_id']},121,'{$param['run_date']}','{$start_time}','{$run_minutes}',$user_id,NOW(),138);";

  1549.             $sql = "SELECT l.line_id,l.line_name,l.line_code,l.line_type,l.org_id,l.sale_expired_type,l.sale_expired_time,s.order_id,s.res_id,s.start_minutes,s.inout_type,s.checkport_res_id,s.area_id

  1550.                     FROM

  1551.                         opera_line AS l,

  1552.                         opera_station AS s

  1553.                     WHERE

  1554.                         l.line_id = s.line_id

  1555.                     AND l.cancel_flag = 0

  1556.                     AND s.cancel_flag = 0

  1557.                     AND l.line_id =451483";//土楼专线岛外上车(Z00): waice(450890) -> ctsdata(451483)

  1558.             $res_station = $this->query($sql);

  1559.             foreach ($res_station as $k_s => $v_s) {

  1560.                 $start_minutes = $run_minutes + $v_s['start_minutes'];

  1561.                 $sql_dispatch .= "insert into run_station(run_id,STATION_ORDER_ID,START_TIME,START_MINUTES,STATION_RES_ID,STATION_INOUT_TYPE,CREATE_USER_ID,CREATE_TIME,AREA_ID) 

  1562.                                   VALUES({$res_run_id[0]['run_id']},{$v_s['order_id']},'{$start_time}','{$start_minutes}',{$v_s['res_id']},{$v_s['inout_type']},$user_id,now(),{$v_s['area_id']});";

  1563.             }

  1564.         }

  1565.         //将分车后的结果反应到相应的表中

  1566.         zzcsUtils::writeLog($sql_dispatch);

  1567.         $res_exec = $this->exec($sql_dispatch);

  1568.         if (!$res_exec) {

  1569.             $result['code'] = '1';

  1570.             $result['info'] = '自动分车执行失败';

  1571.             return $result;

  1572.         }

  1573.         $result['code'] = '0';

  1574.         $result['info'] = '自动分车执行成功';;

  1575.         return $result;

  1576.     }

  1577. 

  1578.     /*

  1579.      * wangxj

  1580.      * 组合线路+车，影响run_bus表

  1581.      * @run_id 班次ID

  1582.      *

  1583.      */

  1584.     public function addBus($params)

  1585.     {

  1586.         $user_id = $this->user_id;

  1587.         $valid = zzcsUtils::validateParams(array(

  1588.             'run_date' => 'empty'

  1589.         ));

  1590.         if (!$valid['status']) {

  1591.             $result['code'] = (string)$valid['status'];

  1592.             $result['info'] = $valid['info'];

  1593.             return $result;

  1594.         }

  1595.         $run_date = $params['run_date'];

  1596.         //$sql = "select bus_id,brand_id,seat_count from base_bus WHERE BUS_STATE=336 ORDER BY seat_count DESC LIMIT 1";

  1597.         $sql = $this->getEnableCar($run_date);  //获取当前可用的车次

  1598.         $res = $this->query($sql);

  1599.         if ($res) {

  1600.             $seat_count = $res[0]['seat_count'];

  1601.             $bus_type_res_id = $res[0]['bus_type_res_id'];

  1602. 

  1603.             $sql = "SELECT b.run_id,BUS_ORDER_ID,BUS_TYPE_RES_ID from run_bus b LEFT join run_main m on m.run_id = b.run_id where m.RUN_DATE='$run_date' and m.PROD_ID = 0 ORDER BY b.BUS_ORDER_ID DESC LIMIT 1";

  1604.             $run_bus = $this->query($sql);

  1605.             if ($run_bus) {

  1606.                 $bus_order_id = $run_bus[0]['BUS_ORDER_ID'] + 1;

  1607.                 $run_id = $run_bus[0]['run_id'];

  1608.                 $sql = "insert into run_bus( create_user_id, create_time, update_user_id, update_time, run_id, bus_order_id, saled_count, seat_count, brand_res_id,run_bus_status, BUS_TYPE_RES_ID)"

  1609.                     . "VALUES( $user_id, now(), $user_id, now(), $run_id, $bus_order_id, 0, $seat_count, 0,138, $bus_type_res_id)";

  1610. 

  1611.                 $result = $this->insert($sql);

  1612.                 if ($result === false) {

  1613.                     $json["code"] = "1";

  1614.                     $json["info"] = "加车失败!";

  1615.                     return $json;

  1616.                 } else {

  1617.                     $json["code"] = "0";

  1618.                     $json["info"] = "加车成功!";

  1619.                     return $json;

  1620.                 }

  1621.             } else {

  1622.                 $json["code"] = "1";

  1623.                 $json["info"] = "加车失败!";

  1624.                 return $json;

  1625.             }

  1626. 

  1627.         } else {

  1628.             $result['code'] = '1';

  1629.             $result['info'] = '车辆库存不足！';

  1630.             return $result;

  1631.         }

  1632. 

  1633.     }

  1634. 

  1635.     /*

  1636.      * wangxj

  1637.      * 组合线路减车，影响run_bus表

  1638.      * @run_date    日期

  1639.      * @bus_order_id    序号

  1640.      *

  1641.      */

  1642.     public function delBus($params)

  1643.     {

  1644.         $user_id = $this->user_id;

  1645.         $valid = zzcsUtils::validateParams(array(

  1646.             'run_date,bus_order_id' => 'empty',

  1647.         ));

  1648.         if (!$valid['status']) {

  1649.             $result['code'] = (string)$valid['status'];

  1650.             $result['info'] = $valid['info'];

  1651.             return $result;

  1652.         }

  1653.         $run_date = $params['run_date'];

  1654.         $bus_order_id = $params['bus_order_id'];

  1655.         $sql = "select id, b.SALED_COUNT SALED_COUNT from run_bus b right JOIN run_main m on m.run_id = b.run_id "

  1656.             . "where  m.run_date='$run_date' and m.prod_id=0 and b.bus_order_id in ($bus_order_id) ";

  1657.         $res = $this->query($sql);

  1658.         if ($res) {

  1659.             if ($res[0]['SALED_COUNT'] == 0) {

  1660.                 $id = $res[0]['id'];

  1661.                 $sql = "update run_bus b set cancel_flag = 1, update_user_id=$user_id and update_time=now() where id=$id";

  1662.                 $result = $this->exec($sql);

  1663.                 zzcsUtils::writeLog($sql);

  1664. 

  1665.                 if ($result === false) {

  1666.                     $json["code"] = "1";

  1667.                     $json["info"] = "减车失败!";

  1668.                     return $json;

  1669.                 } else {

  1670.                     $json["code"] = "0";

  1671.                     $json["info"] = "减车成功!";

  1672.                     return $json;

  1673.                 }

  1674.             } else {

  1675.                 $json["code"] = "1";

  1676.                 $json["info"] = "座位没有清空，无法减车!";

  1677.                 return $json;

  1678.             }

  1679. 

  1680.         } else {

  1681.             $result['code'] = '1';

  1682.             $result['info'] = '无法减车！';

  1683.             return $result;

  1684.         }

  1685.     }

  1686. 

  1687.     /**

  1688.      * 组合线路获取可用车次::这里限制组合线路分车车次仅限佰廉车队

  1689.      * @param $run_date 日期

  1690.      * @return $sql

  1691.      * User: Steven

  1692.      */

  1693.     private function getEnableCar($run_date)

  1694.     {

  1695.         if (date('Y-m-d', strtotime($run_date)) == date('Y-m-d', time())) {  //派今天的车

  1696.             //SQL:查询今日可用车次

  1697.             $sql = "select bus_id,bus_type_res_id,bus_no, seat_count, brand_id ,2 as sort_id

  1698.                                from base_bus

  1699.                                where bus_state = 336 and cancel_flag = 0 and org_id=417 and bus_id not in (

  1700.                                     select b.send_bus_res_id 

  1701.                                     from run_main m, run_bus b 

  1702.                                     where m.run_id = b.run_id and m.run_date = '{$run_date}' and b.run_bus_status in (138,139,140) and b.send_bus_res_id > 0)

  1703.                               order by seat_count desc;";

  1704.         } else {

  1705.             //SQL:查询非今日可用车次

  1706.             $sql = "select bus_id,bus_type_res_id,bus_no, seat_count, brand_id,2 as sort_id

  1707.                     from base_bus a

  1708.                     where a.bus_state = 336 and a.cancel_flag = 0 and a.org_id=417 and a.bus_id not in (

  1709.                           select b.send_bus_res_id 

  1710.                           from run_main m, run_bus b, run_station s

  1711.                           where m.run_id = b.run_id and m.run_id = s.RUN_ID and m.prod_id = s.prod_id and m.run_date = '{$run_date}' and m.prod_id > 0 and b.send_bus_res_id > 0 

  1712.                           group by m.run_id,b.send_bus_res_id

  1713.                           having max(START_MINUTES) > (

  1714.                                  select min(prod_start_station_time_minutes) 

  1715.                                  from order_main 

  1716.                                  where parent_order_id = 0 and prod_start_station_date = '{$run_date}' and parent_prod_id in (

  1717.                                        select line_id 

  1718.                                        from opera_line 

  1719.                                        where line_type = 316 and cancel_flag = 0) and order_valid_status = 1 and cancel_flag = 0))

  1720.                     order by seat_count desc;";

  1721.         }

  1722.         return $sql;

  1723.     }

  1724. 

  1725.     /**

  1726.      * 组合线路可派车次列表

  1727.      * @param $param

  1728.      * @return mixed

  1729.      * User: Steven

  1730.      */

  1731.     public function getVehicleList($param)

  1732.     {

  1733.         #region 获取渠道权限

  1734.         $user_id = $this->user_id;

  1735.         $opera_org_id_sql = "select opera_org_id from base_user where id = " . $user_id . " and cancel_flag = 0";

  1736.         $opera_org_id_result = $this->query($opera_org_id_sql);

  1737.         $opera_org_id = $opera_org_id_result[0]['opera_org_id'];

  1738.         if($opera_org_id == ''){

  1739.             $and_sql = '';

  1740.         }else{

  1741.             $and_sql = " and org_id in (" . $opera_org_id . ") ";

  1742.         }

  1743.         #endregion

  1744. 

  1745.         $keyword = isset($param['keyword']) ? "'" . $param['keyword'] . "'" : "''";

  1746.         $company = isset($param['company']) ? (empty($param['company']) ? "0" : $param['company']) : "0";

  1747.         $salecount = isset($param['salecount']) ? (empty($param['salecount']) ? "0" : $param['salecount']) : "0";

  1748.         $run_date = isset($param['run_date']) ? (empty($param['run_date']) ? "" : $param['run_date']) : "";

  1749.         //$run_time = isset($param['run_time']) ? (empty($param['run_time']) ? "" : $param['run_time']) : "";

  1750.         $run_id1 = isset($param['run_id1']) ? $param['run_id1'] : '';

  1751.         $run_id2 = isset($param['run_id2']) ? $param['run_id2'] : '';

  1752.         if ($run_id1 == '' || $run_id2 == '') {

  1753.             $sql = "select bus_id as res_id,bus_no as vihicle_number,

  1754.                                  ifnull((select res_name from base_resource where res_id = base_bus.brand_id and res_type_id = 134 and cancel_flag =0),'') as vihicle_brand,seat_desc as vihicle_seat,

  1755.                                  ifnull((select res_name from base_resource where res_id = base_bus.org_id and res_type_id = 18 and cancel_flag =0),'') as company_name,seat_count,bus_state as bus_status

  1756.                     from base_bus 

  1757.                     where cancel_flag = 0 and bus_state = 336 and bus_id not in (

  1758.                         select ifnull(b.send_bus_res_id,0) as send_bus_res_id

  1759.                         from run_main m, run_station s ,run_bus b

  1760.                         where m.run_id = s.run_id and m.run_id = b.run_id and m.run_date = '{$run_date}' 

  1761.                               and m.prod_id > 0 -- 单一线路

  1762.                               and m.prod_id not in (select distinct sub_line_id from opera_line a,opera_line_group b where a.line_id = b.sub_line_id and a.line_type = 256 )

  1763.                               and b.send_bus_res_id > 0 and b.cancel_flag = 0

  1764.                         group by m.run_id,b.bus_order_id

  1765.                         having max(s.start_minutes) > (select min(prod_start_station_time_minutes) 

  1766.                               from order_main 

  1767.                               where parent_order_id = 0 and prod_start_station_date = '{$run_date}'  

  1768.                               and parent_prod_id in (select line_id from opera_line where line_type = 316 and cancel_flag = 0) and order_valid_status = 1 and cancel_flag = 0)                         

  1769.                         )

  1770.                      and if(length(trim({$keyword}))=0,0=0,bus_no like concat('%',{$keyword},'%'))

  1771.                      " . $and_sql . "

  1772.                      and if({$company}<=0,0=0,org_id = {$company}) ";

  1773.         } else {

  1774.             $sql = "select bus_id as res_id,bus_no as vihicle_number,

  1775.                          ifnull((select res_name from base_resource where res_id = base_bus.brand_id and res_type_id = 134 and cancel_flag =0),'') as vihicle_brand,seat_desc as vihicle_seat,

  1776.                          ifnull((select res_name from base_resource where res_id = base_bus.org_id and res_type_id = 18 and cancel_flag =0),'') as company_name,seat_count,bus_state as bus_status

  1777.                     from base_bus 

  1778.                     where cancel_flag = 0 and bus_state = 336 and bus_id not in (

  1779.                           select ifnull(b.send_bus_res_id,0) as send_bus_res_id

  1780.                           from run_main m, run_station s ,run_bus b

  1781.                           where m.run_id = s.run_id and m.run_id = b.run_id and m.run_date = '{$run_date}' and m.run_id not in ($run_id1,$run_id2) and m.prod_id > 0 -- 单一线路

  1782.                                and b.send_bus_res_id > 0

  1783.                                and b.cancel_flag = 0

  1784.                           group by m.run_id,b.bus_order_id

  1785.                           having max(s.start_minutes) > (select run_minutes from run_main where run_id = $run_id1)

  1786.                           union all 

  1787.                           select send_bus_res_id

  1788.                           from run_bus 

  1789.                           where run_id = $run_id1)

  1790.                           and seat_count >= $salecount

  1791.                           " . $and_sql . "

  1792.                                 and if(length(trim({$keyword}))=0,0=0,bus_no like concat('%',{$keyword},'%'))

  1793.                                 and if({$company}<=0,0=0,org_id = {$company}) ";

  1794.         }

  1795.         zzcsUtils::writeLog($sql);

  1796.         $result = $this->query($sql);

  1797.         if (false === $result) {

  1798.             $json['code'] = '1';

  1799.             $json['info'] = '获取可派车次列表失败';

  1800.         } else {

  1801.             $json['code'] = '0';

  1802.             $json['info'] = '获取可派车次列表成功';

  1803.             $json['vehicle_list'] = $result;

  1804.         }

  1805.         return $json;

  1806.     }

  1807. 

  1808.     /**

  1809.      * 组合线路(根据导游姓名手机号和公司)获取可用导游列表

  1810.      * @param $param

  1811.      * @return mixed

  1812.      * User: Steven

  1813.      */

  1814.     public function getGuideList($param)

  1815.     {

  1816.         #region 获取渠道权限

  1817.         $user_id = $this->user_id;

  1818.         $opera_org_id_sql = "select opera_org_id from base_user where id = " . $user_id . " and cancel_flag = 0";

  1819.         $opera_org_id_result = $this->query($opera_org_id_sql);

  1820.         $opera_org_id = $opera_org_id_result[0]['opera_org_id'];

  1821.         if($opera_org_id == ''){

  1822.             $and_sql = '';

  1823.         }else{

  1824.             $and_sql = " and org_id in (" . $opera_org_id . ") ";

  1825.         }

  1826.         #endregion

  1827. 

  1828.         $keyword = isset($param['keyword']) ? "'" . $param['keyword'] . "'" : "''";

  1829.         $company = isset($param['company']) ? (empty($param['company']) ? '0' : $param['company']) : '0';

  1830.         $run_date = isset($param['run_date']) ? (empty($param['run_date']) ? "" : $param['run_date']) : "";

  1831.         $run_id1 = isset($param['run_id1']) ? $param['run_id1'] : '';

  1832.         $run_id2 = isset($param['run_id2']) ? $param['run_id2'] : '';

  1833. 

  1834.         //SQL:获取组合线路可用导游列表（包括接驳段用过的导游）

  1835.         if ($run_id1 == '' || $run_id2 == '') { //初始加载(不传入run_id)

  1836.             $sql = "select  guide_id as res_id,guide_name,phone_no as guide_phone,(select supplier_name from base_supplier where id = a.org_id) as company_name

  1837.                         from base_guide a

  1838.                         where a.cancel_flag = 0 

  1839.                         " . $and_sql . "

  1840.                         and a.guide_id not in (

  1841.                               select b.send_tour_guide_res_id

  1842.                               from run_main m, run_bus b, run_station s

  1843.                               where m.run_id = b.run_id and m.run_id = s.RUN_ID and m.prod_id = s.prod_id and m.run_date = '{$run_date}' and m.prod_id > 0 and b.send_tour_guide_res_id > 0 

  1844.                               group by m.run_id,b.send_tour_guide_res_id

  1845.                               having max(START_MINUTES) > (

  1846.                                      select min(prod_start_station_time_minutes) 

  1847.                                      from order_main 

  1848.                                      where parent_order_id = 0 and prod_start_station_date = '{$run_date}' 

  1849.                                      and parent_prod_id in (select line_id from opera_line where line_type = 316 and cancel_flag = 0) and order_valid_status = 1 and cancel_flag = 0))

  1850.                                AND IF(length(trim({$keyword}))<=0,0=0,(guide_name LIKE CONCAT('%',{$keyword},'%') OR phone_no LIKE CONCAT('%',{$keyword},'%')))

  1851.                                AND IF({$company}<=0,0=0,a.org_id={$company})";

  1852.         } else {

  1853.             $sql = "select  guide_id as res_id,guide_name,phone_no as guide_phone,(select supplier_name from base_supplier where id = a.org_id) as company_name

  1854.                     from base_guide a

  1855.                     where a.cancel_flag = 0 

  1856.                     " . $and_sql . "

  1857.                     and a.guide_id not in (

  1858.                           select b.send_tour_guide_res_id

  1859.                           from run_main m, run_station s ,run_bus b

  1860.                           where m.run_id = s.run_id and m.run_id = b.run_id and m.run_date = '{$run_id1}' and m.run_id not in ($run_id1,$run_id2) and m.prod_id > 0 -- 单一线路

  1861.                                and b.send_tour_guide_res_id > 0 and b.cancel_flag = 0

  1862.                           group by m.run_id,b.bus_order_id

  1863.                           having max(s.start_minutes) > (select run_minutes from run_main where run_id = {$run_id1})

  1864.                           union all 

  1865.                             select send_tour_guide_res_id

  1866.                             from run_bus 

  1867.                             where run_id = {$run_id1})

  1868.                             AND IF(length(trim({$keyword}))<=0,0=0,(guide_name LIKE CONCAT('%',{$keyword},'%') OR phone_no LIKE CONCAT('%',{$keyword},'%')))

  1869.                             AND IF({$company}<=0,0=0,org_id={$company})";

  1870.         }

  1871.         zzcsUtils::writeLog($sql);

  1872.         $result = $this->query($sql);

  1873.         if (false === $result) {

  1874.             $json['code'] = '1';

  1875.             $json['info'] = '数据库错误';

  1876.         } else {

  1877.             $json['code'] = '0';

  1878.             $json['info'] = '返回数据成功';

  1879.             $json['guide_list'] = $result;

  1880.         }

  1881.         return $json;

  1882.     }

  1883. 

  1884. 

  1885.     /**

  1886.      * 组合线路(根据导游姓名手机号和公司)获取可用司机列表

  1887.      * @param $param

  1888.      * @return mixed

  1889.      * User: Steven

  1890.      */

  1891.     public function getDriverList($param)

  1892.     {

  1893.         #region 获取渠道权限

  1894.         $user_id = $this->user_id;

  1895.         $opera_org_id_sql = "select opera_org_id from base_user where id = " . $user_id . " and cancel_flag = 0";

  1896.         $opera_org_id_result = $this->query($opera_org_id_sql);

  1897.         $opera_org_id = $opera_org_id_result[0]['opera_org_id'];

  1898.         if($opera_org_id == ''){

  1899.             $and_sql = '';

  1900.         }else{

  1901.             $and_sql = " and org_id in (" . $opera_org_id . ") ";

  1902.         }

  1903.         #endregion

  1904. 

  1905.         $keyword = isset($param['keyword']) ? "'" . $param['keyword'] . "'" : "''";

  1906.         $company = isset($param['company']) ? (empty($param['company']) ? '0' : $param['company']) : '0';

  1907.         $run_date = isset($param['run_date']) ? (empty($param['run_date']) ? "" : $param['run_date']) : "";

  1908.         $run_id1 = isset($param['run_id1']) ? $param['run_id1'] : '';

  1909.         $run_id2 = isset($param['run_id2']) ? $param['run_id2'] : '';

  1910.         if ($run_id1 == '' || $run_id2 == '') { //初始加载(不传入run_id)

  1911.             $sql = "select driver_id as res_id,driver_name,driver_number,ifnull(phone_no,'') as driver_phone,(select supplier_name from base_supplier where id = a.org_id) as company_name

  1912.               from base_driver a

  1913.               where a.cancel_flag = 0 

  1914.               " . $and_sql . "

  1915.               and a.driver_id not in (

  1916.                     select b.send_bus_driver_res_id

  1917.                     from run_main m, run_bus b, run_station s

  1918.                     where m.run_id = b.run_id and m.run_id = s.RUN_ID and m.prod_id = s.prod_id and m.run_date = '{$run_date}' and m.prod_id > 0 and b.send_bus_driver_res_id > 0 

  1919.                     group by m.run_id,b.send_bus_driver_res_id

  1920.                     having max(START_MINUTES) > (

  1921.                                select min(prod_start_station_time_minutes) 

  1922.                                from order_main 

  1923.                                where parent_order_id = 0 and prod_start_station_date = '{$run_date}' 

  1924.                                and parent_prod_id in (select line_id from opera_line where line_type = 316 and cancel_flag = 0) and order_valid_status = 1 and cancel_flag = 0))

  1925.                	               AND IF(length(trim({$keyword}))<=0,0=0,(driver_name LIKE CONCAT('%',{$keyword},'%') OR phone_no LIKE CONCAT('%',{$keyword},'%')))

  1926.                                AND IF({$company}<=0,0=0,a.org_id={$company})";

  1927.         } else {  //点击输入框（传入run_id）

  1928.             $sql = "select driver_id as res_id,driver_name,driver_number,ifnull(phone_no,'') as driver_phone,(select supplier_name from base_supplier where id = base_driver.org_id) as company_name

  1929.                     from base_driver 

  1930.                     where cancel_flag = 0 

  1931.                     " . $and_sql . "

  1932.                     and driver_id not in (

  1933.                         select ifnull(b.send_bus_driver_res_id,0) as send_bus_driver_res_id

  1934.                         from run_main m, run_station s ,run_bus b

  1935.                         where m.run_id = s.run_id and m.run_id = b.run_id and m.run_date = '{$run_date}' and m.run_id not in ($run_id1,$run_id2) and m.prod_id > 0 -- 单一线路

  1936.                               and b.send_bus_driver_res_id > 0 and b.cancel_flag = 0

  1937.                         group by m.run_id,b.bus_order_id

  1938.                         having max(s.start_minutes) > (select run_minutes from run_main where run_id = {$run_id1})

  1939.                         union all 

  1940.                         select send_bus_driver_res_id

  1941.                         from run_bus 

  1942.                         where run_id = {$run_id1})

  1943.                         AND IF(length(trim({$keyword}))<=0,0=0,(driver_name LIKE CONCAT('%',{$keyword},'%') OR phone_no LIKE CONCAT('%',{$keyword},'%')))

  1944.                                    AND IF({$company}<=0,0=0,org_id={$company});";

  1945.         }

  1946.         zzcsUtils::writeLog($sql);

  1947.         $result = $this->query($sql);

  1948.         if (false === $result) {

  1949.             $json['code'] = '1';

  1950.             $json['info'] = '司机列表获取失败';

  1951.         } else {

  1952.             $json['code'] = '0';

  1953.             $json['info'] = '司机列表获取成功';

  1954.             $json['driver_list'] = $result;

  1955.         }

  1956.         return $json;

  1957.     }

  1958. 

  1959. }