nizongfeng
/
zzcx_line
1
0
Форк 0
Код Проблеми 0 Запити на злиття 0 Релізи 0 Вікі Активність
Ви не можете вибрати більше 25 тем Теми мають розпочинатися з літери або цифри, можуть містити дефіси (-) і не повинні перевищувати 35 символів.
2 Коміти
1 Гілка
17 MiB
 
 
 
 
Гілка: master
Гілки Теги
${ item.name }
Створити гілку ${ searchTerm }
з 'master'
${ noResults }
zzcx_line/coding/api1.0/qunar_get_order.php

690 рядки
39 KiB
Неформатований Постійне посилання Звинувачення Історія 

  1. <?php

  2. require_once __DIR__.'/../st-xm/Common/Mysql.php';

  3. require_once __DIR__.'/../st-xm/Common/config_api.inc';

  4. require_once __DIR__.'/../st-xm/Common/sinaAPI.php';

  5. require_once __DIR__.'/../st-xm/Common/zizai_orderAPI.php';

  6. require_once __DIR__.'/../st-xm/Common/dictionary.php';

  7. //require_once __DIR__.'/../st-xm/Common/api_common.php';

  8. 

  9. header("Access-Control-Allow-Origin:*");

  10. date_default_timezone_set('PRC');

  11. 

  12. $current_time = time();

  13. $current_hour = date("H:i:s",$current_time);

  14. $check_stock_time = date("Y-m-d H:i:s",$current_time);

  15. $tomorrow_day = date("Y-m-d",strtotime("+1 days"));

  16. $today = date("Y-m-d");

  17. $limit_time = date("H:i", strtotime("+1 minutes"));

  18. $limit_time1 = date("H:i", strtotime("+1 minutes"));

  19. $limit_time2 = date("H:i", strtotime("+1 minutes"));

  20. //拼接数组

  21. $post_data = array();

  22. $post_data["agentId"] = QUNAR_AGENT_ID;

  23. $post_data["time"] = $current_time;

  24. $post_data["auth"] = get_qunar_auth($post_data);

  25. $return_data = send_post( QUNAR_CHECK_ORDER_URL, $post_data);

  26. $return_array = json_decode($return_data,true);

  27. if( !isset($return_array["orderNum"]) || $return_array["orderNum"] <= 0 ) {

  28.     print_r($return_array);

  29.     return;

  30. }

  31. //print_r($return_array);exit();//test

  32. $no_sell_array = array(152739,152740,152741,152691,152697,152715,152709,152715,153133,153135,153137,152569,152570,152571,152572,152573,152575,152577,152579,152581,152582,152695,152696,152706,152707,448587,449825,449827,449829,449831,449832,449843,449847,449825,449827,449829,449831, 449876,449881);

  33. 

  34. $limit_sell_prod2 = array( 448568, 448569,450517,450522,450499,450504,448780,448781,450529,450530,450550,450551,450588,450698,450699,450700,450701,450702,450703 );

  35. 

  36. $userid = 2;

  37. $current_time = date("Y-m-d H:i:s");

  38. $pdo=conn1();

  39. $order_array = $return_array["data"];

  40. //获取往返优惠

  41. //$bothway_tickets_discount = array();

  42. //$bothway_tickets_discount = getTicketsDiscountArray( $pdo, $from_org_id );

  43. 

  44. foreach( $order_array as $order_info ) {

  45.     writeLog("-----qunar new order info:".json_encode($order_info));

  46.     $run_code = $order_info["coachNo"];

  47.     $run_code_array = explode("_",$run_code);

  48.     $back_run_code = false;

  49.     $back_prod_id = false;

  50.     $back_order_id = false;

  51.     if( isset($run_code_array[1]) ) {

  52.         if( isset($run_code_array[2]) && isset($run_code_array[3]) ) {

  53.             $run_code_array[0] = base_convert($run_code_array[0],36,10);

  54.             $run_code_array[1] = base_convert($run_code_array[1],36,10);

  55.             $run_code_array[2] = base_convert($run_code_array[2],36,10);

  56.             $run_code_array[3] = base_convert($run_code_array[3],36,10);

  57.             $back_run_code = $run_code_array[2];

  58.             $back_prod_id = $run_code_array[3];

  59.         }

  60.         $run_code = $run_code_array[0];

  61.         $prod_id = $run_code_array[1];

  62.     } else {

  63.         //zizai

  64.         //$run_code = $run_code_array[0];

  65.     }

  66.     $ticket_num = $order_info["ticketNum"];

  67.     $all_price = $order_info["ticketPrice"];

  68.     $per_price = $all_price / $ticket_num;

  69.     $customer_name = $order_info["contactName"];

  70.     $customer_mobile = descryption_by_shif($order_info["contactPhone"]);

  71.     $customer_id_no = descryption_by_shif($order_info["contactId"]);

  72.     $out_order_no = $order_info["orderNo"];

  73.     $passengers = $order_info["passengers"];

  74.     $passengers_array = array();

  75.     foreach( $passengers as $passenger_info ) {

  76.         $passengers_array[] = $passenger_info["passengerName"]."*".descryption_by_shif($passenger_info["passengerId"]);

  77.     }

  78.     $passengers_list = implode("/",$passengers_array);

  79.     $sql = " SELECT * FROM order_main WHERE OUTSIDE_ORDER_NO='{$out_order_no}' AND PARENT_ORDER_ID = 0 ";

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

  81.     $rowset = $result->fetchAll();

  82.     $result->closeCursor();

  83.     if ($rowset != false) {

  84.         continue;

  85.     }

  86.     if( isset($run_code_array[1]) ) {

  87.         $sql = " SELECT * FROM run_main WHERE RUN_ID={$run_code} ";

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

  89.         $rowset = $result->fetchAll();

  90.         $result->closeCursor();

  91.         $run_main_info = $rowset[0];

  92. 

  93.         if( $run_main_info["RUN_DATE"] != $order_info["date"] ) {

  94.             $sql = " SELECT * FROM run_main WHERE PROD_ID={$run_main_info["PROD_ID"]} AND RUN_DATE='{$order_info["date"]}' AND RUN_TIME= '{$run_main_info["RUN_TIME"]}' AND RUN_STATUS IN (138,139) ";

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

  96.             $rowset2 = false;

  97.             if( $result != false ) {

  98.                 $rowset2 = $result->fetchAll();

  99.                 $result->closeCursor();

  100.                 $run_main_info = $rowset2[0];

  101.                 $run_code = $run_main_info["RUN_ID"];

  102.             }

  103.             if( $rowset2 == false) {

  104.                 $post_data = array();

  105.                 $post_data["agentId"] = QUNAR_AGENT_ID;

  106.                 $post_data["time"] = $current_time;

  107.                 $post_data["comment"] = "出票失败:该线路已停售";

  108.                 $post_data["ticketInfo"] = json_encode(array( "ret" => false, "data" => array("orderNo" => $out_order_no, "ticketStatu" => 1)) );

  109.                 $post_data["auth"] = get_qunar_auth($post_data);

  110.                 $complete_result = send_post_qunar( QUNAR_COMPLETE_ORDER_URL, $post_data );

  111.                 continue;

  112.             }

  113.         }

  114.         $run_start_time = $run_main_info["RUN_DATE"]." ".$run_main_info["RUN_TIME"];

  115.     } else {

  116.         //zizai

  117.         $prod_id = $run_code_array[0];

  118.         $sql = " SELECT * FROM outside_run WHERE prod_code='".$prod_id."' AND cancel_flag = 0 ";

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

  120.         $rowset=$result->fetchAll();

  121.         $result->closeCursor();

  122.         if( false == $rowset ) {

  123.             $post_data = array();

  124.             $post_data["agentId"] = QUNAR_AGENT_ID;

  125.             $post_data["time"] = $current_time;

  126.             $post_data["comment"] = "出票失败:该线路已停售";

  127.             $post_data["ticketInfo"] = json_encode(array( "ret" => false, "data" => array("orderNo" => $out_order_no, "ticketStatu" => 1)) );

  128.             $post_data["auth"] = get_qunar_auth($post_data);

  129.             $complete_result = send_post_qunar( QUNAR_COMPLETE_ORDER_URL, $post_data );

  130.             continue;

  131.         }

  132.         $run_info = $rowset[0];

  133.         if( $run_info["start_date"] != $order_info["date"] ) {

  134.             $sql = " SELECT * FROM outside_run WHERE line_code='{$run_info["line_code"]}' AND start_date='{$order_info["date"]}' AND start_time='{$order_info["startTime"]}' AND prod_name='{$run_info["prod_name"]}'";

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

  136.             $rowset = $result == false ? false : $result->fetchAll();

  137.             $result->closeCursor();

  138.             if( false == $rowset ) {

  139.                 $post_data = array();

  140.                 $post_data["agentId"] = QUNAR_AGENT_ID;

  141.                 $post_data["time"] = $current_time;

  142.                 $post_data["comment"] = "出票失败:该线路已停售";

  143.                 $post_data["ticketInfo"] = json_encode(array( "ret" => false, "data" => array("orderNo" => $out_order_no, "ticketStatu" => 1)) );

  144.                 $post_data["auth"] = get_qunar_auth($post_data);

  145.                 $complete_result = send_post_qunar( QUNAR_COMPLETE_ORDER_URL, $post_data );

  146.                 continue;

  147.             }

  148.             $run_info = $rowset[0];

  149.             $prod_id = $run_info["prod_code"];

  150.         }

  151.         $line_code = $run_info["line_code"];

  152.         $run_start_time = $run_info["start_date"]." ".$run_info["start_time"];

  153.         $per_price = $run_info["cus_price"];

  154.         $all_price = $per_price * $ticket_num;

  155.     }

  156. 

  157.     $pdo_insert = conn1();

  158.     $sql_insert = " INSERT INTO outside_submit_order (from_org_id,outside_order_no,prod_id,ticket_num,per_price,all_price,customer_name,customer_mobile,customer_id_no,submit_status,opera_time,passenger) VALUE(" .

  159.         "28,'{$out_order_no}','{$order_info["coachNo"]}',{$ticket_num},{$per_price},{$all_price},'{$customer_name}','{$customer_mobile}','{$customer_id_no}',0,'{$current_time}','{$passengers_list}')  ";

  160.     $pdo_insert->exec($sql_insert);

  161. 

  162.     if( !isset($run_code_array[1]) ) {

  163.         $remain_count = $run_info["remain_count"];

  164.         $update_date = substr($run_info["update_time"],0,10);

  165.         $can_sale_time = date("Y-m-d H:i:00",  strtotime( $run_start_time." -1 hours" ));

  166.         $can_sale_time = $run_start_time.":00";

  167.         if( $check_stock_time > $can_sale_time ) {

  168.             $remain_count = 0;

  169.         }

  170.         if( $remain_count < $ticket_num ) {

  171.             $post_data = array();

  172.             $post_data["agentId"] = QUNAR_AGENT_ID;

  173.             $post_data["time"] = $current_time;

  174.             $post_data["comment"] = "出票失败:该线路余票不足";

  175.             $post_data["ticketInfo"] = json_encode(array( "ret" => false, "data" => array("orderNo" => $out_order_no, "ticketStatu" => 1)) );

  176.             $post_data["auth"] = get_qunar_auth($post_data);

  177.             $complete_result = send_post_qunar( QUNAR_COMPLETE_ORDER_URL, $post_data );

  178.             continue;

  179.         }

  180.         $run_code = $run_info["run_code"];

  181.         if( $run_info["org_id"] != 1286 ) {

  182.             //自在下票

  183.             $setOrder = new orderService();

  184.             //票务系统锁定

  185.             $zizai_cus = "{|" . $customer_name . "|" . $customer_mobile . "|" . $customer_id_no . "||}";

  186.             $lock_order = $setOrder->createOrder(zizaiArgs::$USER, $prod_id . "P" . $ticket_num . "|", $customer_name, $customer_mobile, $customer_id_no, '', 0);

  187.             //$lock_order = $setOrder->lock(zizaiArgs::$USER, 30, $prod_id."P".$ticket_num."|", $zizai_cus );

  188.             if (false == $lock_order || $lock_order['code'] != 0) {

  189.                 $post_data = array();

  190.                 $post_data["agentId"] = QUNAR_AGENT_ID;

  191.                 $post_data["time"] = $current_time;

  192.                 $post_data["comment"] = "出票失败:该线路已停售";

  193.                 $post_data["ticketInfo"] = json_encode(array("ret" => false, "data" => array("orderNo" => $out_order_no, "ticketStatu" => 1)));

  194.                 $post_data["auth"] = get_qunar_auth($post_data);

  195.                 $complete_result = send_post_qunar(QUNAR_COMPLETE_ORDER_URL, $post_data);

  196.                 continue;

  197.             }

  198.             $tradeno = $lock_order['tradeno'];

  199.             $customerlist = "";

  200.             foreach ($passengers as $passenger_info) {

  201.                 $customerlist .= '{' . $prod_id . '|' . $passenger_info["passengerName"] . '|' . $customer_mobile . '|' . descryption_by_shif($passenger_info["passengerId"]) . '}';

  202.             }

  203.             $return_info = $setOrder->customer(zizaiArgs::$USER, $tradeno, $customerlist);

  204.             $pdo_update3 = conn1();

  205.             $sql_update = " UPDATE outside_submit_order set supply_order_id='{$tradeno}' WHERE outside_order_no='{$out_order_no}'";

  206.             $pdo_update3->exec($sql_update);

  207. 

  208.             $post_data = array();

  209.             $post_data["agentId"] = QUNAR_AGENT_ID;

  210.             $post_data["time"] = $current_time;

  211.             $line_name = str_replace("舟山", "普陀山", $run_info["line_name"]);

  212.             $post_data["comment"] = "出票成功:您已成功订购了{$line_name}[{$run_info["prod_name"]}]{$ticket_num}张。订单号为：" . $tradeno . "。出发时间：{$run_info["start_date"]} {$run_info["start_time"]}。上车地点：{$run_info["start_res"]}。请于发车前到上车站点的服务台领票。咨询电话4008872626";

  213.             if ($line_code == "xn006") {

  214.                 $post_data["comment"] = "出票成功:您已成功订购了{$line_name}[{$run_info["prod_name"]}]{$ticket_num}张。订单号为：" . $tradeno . "。出发时间：{$run_info["start_date"]} {$run_info["start_time"]}。请于发车前到慈航广场舟山市旅游集散服务中心服务台报姓名和预定手机号取票，因取票点与上车点(慈航大酒店门口)距离较远，烦请提前20分钟前往取票。咨询电话4008872626。";

  215.             } else if ($line_code == "zsz101") {

  216.                 $post_data["comment"] = "出票成功:您已成功订购了{$line_name}[{$run_info["prod_name"]}]{$ticket_num}张。订单号为：" . $tradeno . "。出发时间：{$run_info["start_date"]} {$run_info["start_time"]}。请于发车前到上车站点（城北开发区学运路18号）的服务台报姓名和预定手机号取票。咨询电话4008872626。";

  217.             }

  218.             $ticketCode = sprintf("%d", $tradeno);

  219.             for ($ticket_index = 1; $ticket_index < $ticket_num; $ticket_index++) {

  220.                 $ticketCode .= "|" . sprintf("%d", $tradeno);

  221.             }

  222.             $post_data["ticketInfo"] = json_encode(array("ret" => true, "data" => array("orderNo" => $out_order_no, "ticketStatu" => 0, "ticketNum" => sprintf("%d", $ticket_num), "ticketPassword" => $ticketCode, "ticketCode" => $ticketCode)));

  223.             $post_data["auth"] = get_qunar_auth($post_data);

  224.             $complete_result = send_post_qunar(QUNAR_COMPLETE_ORDER_URL, $post_data);

  225.         }

  226.         //出发地和目的地的area_id

  227.         $sql = " SELECT ID,AREA_NAME FROM base_area WHERE AREA_NAME like \"".$run_info["start_area"]."%%\" AND cancel_flag = 0 ";

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

  229.         $rowset=$result->fetchAll();

  230.         $result->closeCursor();

  231.         if( $rowset == false ) {

  232.             $start_area_id = 791;

  233.         } else {

  234.             $start_area_id = $rowset[0]["ID"];

  235.         }

  236.         $sql = " SELECT ID,AREA_NAME FROM base_area WHERE AREA_NAME like \"".$run_info["end_area"]."%%\" AND cancel_flag = 0 ";

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

  238.         $rowset=$result->fetchAll();

  239.         $result->closeCursor();

  240.         if( $rowset == false ) {

  241.             $end_area_id = 791;

  242.         } else {

  243.             $end_area_id = $rowset[0]["ID"];

  244.         }

  245. 

  246.         $userid = 2;

  247.         $prod_id = 380001;

  248.         $run_code = 0;

  249.         $myprod = '{m'.$prod_id.'p'.$ticket_num.'|r'.$run_code.'}';

  250.         $mycustomer = "{,".$customer_name.",,".$customer_mobile.",150,".$customer_id_no.",,,,".$passengers_list."}";

  251.         $run_info_txt = "{0,普通座票,".$run_info["line_name"].",".$run_info["start_date"].",".$run_info["start_time"].",".$run_info["start_res"].",".$run_info["start_date"].",".$run_info["start_time"].",".$run_info["start_area"].",".$run_info["end_res"].",,,".$run_info["end_area"].",".$start_area_id.",".$end_area_id."}";

  252.         $sql_insert="call sp_make_order_for_zizai(".$userid.",'".$myprod."','".$mycustomer."', 28, '".$out_order_no."',".$run_info["cus_price"].", '".$run_info_txt."')";

  253.         writeLog($sql_insert);

  254.         $result=$pdo->query($sql_insert);

  255.         $rowset=$result->fetchAll(PDO::FETCH_ASSOC);

  256.         $result->closeCursor();

  257.         if (is_array($rowset) && $rowset[0]['errcode'] == 0 ) {

  258.             $order_id=$rowset[0]['order_id'];

  259.             //运游通下单

  260.             if( $run_info["org_id"] == 1286 ) {

  261.                 $njyyt_run_code = substr($run_info["prod_code"], 5);

  262.                 $njyyt_run_code = str_replace("T","_", $njyyt_run_code);

  263.                 $send_post_data = array( "auth_code" => "pM3E9XdSeOndP2kV", 'run_code' => $njyyt_run_code, 'ticket_num' => $ticket_num, 'per_price' => $per_price, 'all_price' => $all_price, 'customer_name' => $customer_name, 'customer_mobile' => $customer_mobile, 'customer_id_no' => $customer_id_no, 'ctrip_order_no' => "ZZCX".$order_id, 'passengers' => $_POST['passengers'] );

  264.                 $yyt_result = send_post("http://yytcs.njyunyoutong.com/api1.0/submit_order.php",$send_post_data);

  265.                 $yyt_order_info = json_decode($yyt_result,true);

  266.                 if( $yyt_order_info["code"] != 201 ) {

  267. 

  268.                     $user_id = 2;

  269.                     $sql = "CALL SP_CANCEL_ORDER(" . $user_id . "," . $order_id . ")";

  270.                     $pdo_cancel = conn1();

  271.                     $cancel_result = $pdo_cancel->query($sql);

  272.                     $cancel_result->closeCursor();

  273. 

  274.                     $post_data = array();

  275.                     $post_data["agentId"] = QUNAR_AGENT_ID;

  276.                     $post_data["time"] = $current_time;

  277.                     $post_data["comment"] = "出票失败:该线路已停售";

  278.                     $post_data["ticketInfo"] = json_encode(array("ret" => false, "data" => array("orderNo" => $out_order_no, "ticketStatu" => 1)));

  279.                     $post_data["auth"] = get_qunar_auth($post_data);

  280.                     $complete_result = send_post_qunar(QUNAR_COMPLETE_ORDER_URL, $post_data);

  281.                     continue;

  282.                 } else {

  283.                     $tradeno = $yyt_order_info["order_no"];

  284. 

  285.                     $post_data = array();

  286.                     $post_data["agentId"] = QUNAR_AGENT_ID;

  287.                     $post_data["time"] = $current_time;

  288.                     $line_name = $run_info["line_name"];

  289.                     $post_data["comment"] = $yyt_order_info["send_message_array"][0];

  290.                     $ticketCode = sprintf("%d", $tradeno);

  291.                     for ($ticket_index = 1; $ticket_index < $ticket_num; $ticket_index++) {

  292.                         $ticketCode .= "|" . sprintf("%d", $tradeno);

  293.                     }

  294.                     $post_data["ticketInfo"] = json_encode(array("ret" => true, "data" => array("orderNo" => $out_order_no, "ticketStatu" => 0, "ticketNum" => sprintf("%d", $ticket_num), "ticketPassword" => $ticketCode, "ticketCode" => $ticketCode)));

  295.                     $post_data["auth"] = get_qunar_auth($post_data);

  296.                     $complete_result = send_post_qunar(QUNAR_COMPLETE_ORDER_URL, $post_data);

  297.                 }

  298.             }

  299.             //update submit order

  300.             $pdo_update = conn1();

  301.             $sql_update = " UPDATE order_main set order_status =146,PROD_SUPPLY_ORG_NAME='自在旅行' WHERE ORDER_ID=".$order_id." OR PARENT_ORDER_ID=".$order_id;

  302.             $pdo_update->exec($sql_update);

  303.             $pdo_update2 = conn1();

  304.             $sql_update = " UPDATE outside_submit_order set submit_status=1 WHERE outside_order_no='{$out_order_no}'";

  305.             $pdo_update2->exec($sql_update);

  306. 

  307.             $opera_per_price = $per_price;

  308.             $opera_all_price = $all_price;

  309.             $pdo_insert2 = conn1();

  310.             $opera_detail = "创建订单，出发日期{$run_info["start_date"]}，订单渠道去哪儿汽车票，单价{$opera_per_price}，总额{$opera_all_price}，联系人信息：{$customer_name},{$customer_mobile},{$customer_id_no}，备注信息：";

  311.             $sql_log = "insert into order_opera_log(order_id,opera_user_id,opera_type,opera_time,opera_detail,opera_platform) VALUES ({$order_id},2,1,'{$current_time}','{$opera_detail}','OTA对接')";

  312.             $pdo_insert2->exec($sql_log);

  313. 

  314.             $status_post_data['order_id'] = "{$order_id}";

  315.             $status_post_data['order_status'] = "451,452,453";

  316.             post2("http://". CS_DOMAIN. "/st-xm/Api/add_order_status_log.php",$status_post_data);

  317. 

  318.             $baseprice_post_array = array();

  319.             $baseprice_post_array["action"] = "update_base_price";

  320.             $baseprice_post_array["order_id"] = $order_id;

  321.             $baseprice_post_array["base_price"] = round($opera_per_price*0.9);

  322.             $baseprice_post_array["people_num"] = $ticket_num;

  323.             post2("http://". CS1_DOMAIN. "/api/submit-order/",$baseprice_post_array);

  324. 

  325.             continue;

  326.         } else {

  327.             /*

  328.             $post_data = array();

  329.             $post_data["agentId"] = QUNAR_AGENT_ID;

  330.             $post_data["time"] = $current_time;

  331.             $post_data["comment"] = "出票失败:该线路已停售";

  332.             $post_data["ticketInfo"] = json_encode(array( "ret" => false, "data" => array("orderNo" => $out_order_no, "ticketStatu" => 1)) );

  333.             $post_data["auth"] = get_qunar_auth($post_data);

  334.             $complete_result = send_post( QUNAR_COMPLETE_ORDER_URL, $post_data );

  335.             */

  336.             continue;

  337.         }

  338.         continue;

  339.     }

  340. 

  341.     if( in_array($run_main_info["PROD_ID"], $__ary_special_line_array) ) {

  342.         $limit_time = $limit_time2;

  343.     } else {

  344.         $limit_time = $limit_time1;

  345.     }

  346. 

  347.     //get current time

  348.     $sql_get_station_time = "SELECT run_station.START_TIME

  349. from run_prod

  350. left join run_station on run_station.run_id = run_prod.run_id and run_station.STATION_RES_ID = run_prod.START_STATION_RES_ID 

  351. where run_prod.run_id = {$run_main_info["RUN_ID"]} and run_prod.prod_id = {$prod_id}";

  352.     $result = $pdo->query($sql_get_station_time);

  353.     $rowset2 = false;

  354.     if( $result != false ) {

  355.         $rowset2 = $result->fetchAll();

  356.         $result->closeCursor();

  357.     }

  358.     if( $rowset2 == false ) {

  359.         $post_data = array();

  360.         $post_data["agentId"] = QUNAR_AGENT_ID;

  361.         $post_data["time"] = $current_time;

  362.         $post_data["comment"] = "出票失败:该线路已停售";

  363.         $post_data["ticketInfo"] = json_encode(array( "ret" => false, "data" => array("orderNo" => $out_order_no, "ticketStatu" => 1)) );

  364.         $post_data["auth"] = get_qunar_auth($post_data);

  365.         $complete_result = send_post_qunar( QUNAR_COMPLETE_ORDER_URL, $post_data );

  366.         continue;

  367.     }

  368.     $station_run_time = $rowset2[0]["START_TIME"];

  369. 

  370.     if( in_array($run_main_info["PROD_ID"], $limit_sell_prod2) && (($current_hour >= "16:00" && $run_main_info["RUN_DATE"] <= $tomorrow_day) || $run_main_info["RUN_DATE"] < $tomorrow_day )) {

  371.         $post_data = array();

  372.         $post_data["agentId"] = QUNAR_AGENT_ID;

  373.         $post_data["time"] = $current_time;

  374.         $post_data["comment"] = "出票失败:该线路已停售";

  375.         $post_data["ticketInfo"] = json_encode(array( "ret" => false, "data" => array("orderNo" => $out_order_no, "ticketStatu" => 1)) );

  376.         $post_data["auth"] = get_qunar_auth($post_data);

  377.         $complete_result = send_post_qunar( QUNAR_COMPLETE_ORDER_URL, $post_data );

  378.         continue;

  379.     } else if( $run_main_info["RUN_DATE"] == $today && $limit_time >= $station_run_time ) {

  380.         $post_data = array();

  381.         $post_data["agentId"] = QUNAR_AGENT_ID;

  382.         $post_data["time"] = $current_time;

  383.         $post_data["comment"] = "出票失败:该线路已停售";

  384.         $post_data["ticketInfo"] = json_encode(array( "ret" => false, "data" => array("orderNo" => $out_order_no, "ticketStatu" => 1)) );

  385.         $post_data["auth"] = get_qunar_auth($post_data);

  386.         $complete_result = send_post_qunar( QUNAR_COMPLETE_ORDER_URL, $post_data );

  387.         continue;

  388.     }

  389.     if( in_array($prod_id,$no_sell_array) ) {

  390.         $post_data = array();

  391.         $post_data["agentId"] = QUNAR_AGENT_ID;

  392.         $post_data["time"] = $current_time;

  393.         $post_data["comment"] = "出票失败:该线路已停售";

  394.         $post_data["ticketInfo"] = json_encode(array( "ret" => false, "data" => array("orderNo" => $out_order_no, "ticketStatu" => 1)) );

  395.         $post_data["auth"] = get_qunar_auth($post_data);

  396.         $complete_result = send_post_qunar( QUNAR_COMPLETE_ORDER_URL, $post_data );

  397.         continue;

  398.     }

  399. 

  400.     $myprod = '{m'.$prod_id.'p'.$ticket_num.'|r'.$run_code.'}';

  401.     $mycustomer = '{,'.$customer_name.',,'.$customer_mobile.',150,'.$customer_id_no.',,,,'.$passengers_list.'}';

  402.     //if($prod_id== "449862" || $prod_id == "449867" ){

  403.     if( in_array($run_main_info["PROD_ID"], $__ary_special_line_array ) ) {

  404.         $start_end_array = explode( 'X', $prod_id );

  405.         if( count($start_end_array) < 2 ) {

  406.             if( !isset($__ary_new_ticket_array[$prod_id]) ) {

  407.                 $post_data = array();

  408.                 $post_data["agentId"] = QUNAR_AGENT_ID;

  409.                 $post_data["time"] = $current_time;

  410.                 $post_data["comment"] = "出票失败:该线路已停售";

  411.                 $post_data["ticketInfo"] = json_encode(array( "ret" => false, "data" => array("orderNo" => $out_order_no, "ticketStatu" => 1)) );

  412.                 $post_data["auth"] = get_qunar_auth($post_data);

  413.                 $complete_result = send_post_qunar( QUNAR_COMPLETE_ORDER_URL, $post_data );

  414.                 continue;

  415.             } else {

  416.                 $start_end_array = explode('X', $__ary_new_ticket_array[$prod_id]);

  417.             }

  418.         }

  419.         $start_area_id = $start_end_array[0];

  420.         $end_area_id = $start_end_array[1];

  421. 

  422.         $special_prod_id = $__ary_special_ticket_array[$run_main_info["PROD_ID"]];

  423.         $myprod = '{m'.$special_prod_id.'p'.$ticket_num.'|r'.$run_code.'}';

  424.         $start_station_info = $__array_line_info[$run_main_info["PROD_ID"]]["start"][$start_area_id];

  425.         $end_station_info = $__array_line_info[$run_main_info["PROD_ID"]]["end"][$end_area_id];

  426.         $run_start_time = $run_main_info["RUN_DATE"]." ".$run_main_info["RUN_TIME"];

  427. 

  428.         $start_time = date("Y-m-d H:i", strtotime( $run_start_time." + ".$start_station_info["alltime"]." minutes "));

  429.         $end_time = date("Y-m-d H:i", strtotime($run_start_time." + ".$end_station_info["alltime"]." minutes "));

  430.         $result = post2('wx.zhizhuchuxing.com/ZZDZ2/application/custom_made/control.php', array(

  431.             'type' => 'order_submitforout',

  432.             'prod_list' => $myprod,

  433.             'customer_info' => $mycustomer,

  434.             'start_id' => $start_area_id,

  435.             'end_id' => $end_area_id,

  436.             'line_id' => $run_main_info["PROD_ID"],

  437.             'start_time' => mb_substr($start_time,11,5),

  438.             'end_time' => mb_substr($end_time,11,5)

  439.         ));

  440. 

  441.         $result_array = json_decode($result,true);

  442. 

  443.         writeLog("submit order::result=".$result);

  444.         if( $result_array["code"] == 0 ) {

  445.             $order_id = $result_array['order_id'];

  446.             $sql_order_status = "update order_main set order_status =146,OUTSIDE_SALE_ORG_ID=28,OUTSIDE_ORDER_NO='".$out_order_no."' where  order_id= " . $order_id . " or parent_order_id = " . $order_id;

  447.             $pdo_update2 = conn1();

  448.             $pdo_update2->exec($sql_order_status);

  449. 

  450.             $res_content = get_msg_info($order_id);

  451.             $name = $res_content[0];

  452.             $tel = $res_content[1];

  453.             $content = $res_content[2];

  454.             $post_data = array();

  455.             $post_data["agentId"] = QUNAR_AGENT_ID;

  456.             $post_data["time"] = $current_time;

  457.             $post_data["comment"] = $content;

  458.             /*

  459.             $comment_type = 0;

  460.             $comment_text = "";

  461.             $send_success = 0;

  462.             $sql1 = "CALL HT_ADD_MSG_COMMENT(2,'addmsg'," . $order_id . "," . $comment_type . ",'" . $comment_text . "','" . $tel . "','" . $content . "','" . date("Y-m-d H:i:s") . "',{$send_success})";

  463.             $result1 = $pdo->query($sql1);

  464.             $rowset1 = $result1->fetchAll(PDO::FETCH_ASSOC);

  465.             $result1->closeCursor();*/

  466.             $pdo_update = conn1();

  467.             $sql_update = " UPDATE outside_submit_order set submit_status=1 WHERE outside_order_no='{$out_order_no}'";

  468.             $pdo_update->exec($sql_update);

  469. 

  470.             $ticketCode = sprintf("%d", $order_id);

  471.             for ($ticket_index = 1; $ticket_index < $ticket_num; $ticket_index++) {

  472.                 $ticketCode .= "|" . sprintf("%d", $order_id);

  473.             }

  474.             $post_data["ticketInfo"] = json_encode(array("ret" => true, "data" => array("orderNo" => $out_order_no, "ticketStatu" => 0, "ticketNum" => sprintf("%d", $ticket_num), "ticketPassword" => $ticketCode, "ticketCode" => $ticketCode)));

  475.             $post_data["auth"] = get_qunar_auth($post_data);

  476.             $complete_result = send_post_qunar(QUNAR_COMPLETE_ORDER_URL, $post_data);

  477.             $complete_result_array = json_decode($complete_result, true);

  478. 

  479.             $opera_per_price = $per_price;

  480.             $opera_all_price = $all_price;

  481.             $pdo_insert2 = conn1();

  482.             $opera_detail = "创建订单，出发日期{$run_main_info["RUN_DATE"]}，订单渠道去哪儿汽车票，单价{$opera_per_price}，总额{$opera_all_price}，联系人信息：{$customer_name},{$customer_mobile},{$customer_id_no}，备注信息：";

  483.             $sql_log = "insert into order_opera_log(order_id,opera_user_id,opera_type,opera_time,opera_detail,opera_platform) VALUES ({$order_id},2,1,'{$current_time}','{$opera_detail}','OTA对接')";

  484.             $pdo_insert2->exec($sql_log);

  485. 

  486. 

  487.             $status_post_data['order_id'] = "{$order_id}";

  488.             $status_post_data['order_status'] = "451,452,453";

  489.             post2("http://". CS_DOMAIN. "/st-xm/Api/add_order_status_log.php",$status_post_data);

  490. 

  491.             continue;

  492.         } else if( $result_array["code"] == 101 ) {

  493.             $post_data = array();

  494.             $post_data["agentId"] = QUNAR_AGENT_ID;

  495.             $post_data["time"] = $current_time;

  496.             $post_data["comment"] = "出票失败:该线路已停售";

  497.             $post_data["ticketInfo"] = json_encode(array( "ret" => false, "data" => array("orderNo" => $out_order_no, "ticketStatu" => 1)) );

  498.             $post_data["auth"] = get_qunar_auth($post_data);

  499.             $complete_result = send_post_qunar( QUNAR_COMPLETE_ORDER_URL, $post_data );

  500.             continue;

  501.         } else {

  502.             $post_data = array();

  503.             $post_data["agentId"] = QUNAR_AGENT_ID;

  504.             $post_data["time"] = $current_time;

  505.             $post_data["comment"] = "出票失败:该线路已停售";

  506.             $post_data["ticketInfo"] = json_encode(array( "ret" => false, "data" => array("orderNo" => $out_order_no, "ticketStatu" => 1)) );

  507.             $post_data["auth"] = get_qunar_auth($post_data);

  508.             $complete_result = send_post_qunar( QUNAR_COMPLETE_ORDER_URL, $post_data );

  509.             continue;

  510.         }

  511. 

  512.     } else {

  513.         $sql_insert = "call sp_make_order(" . $userid . ",'" . $myprod . "','" . $mycustomer . "', 28, '" . $out_order_no . "')";

  514.         $result = $pdo->query($sql_insert);

  515.         $rowset = $result->fetchAll(PDO::FETCH_ASSOC);

  516.         $result->closeCursor();

  517.         $post_data = array();

  518.         $post_data["agentId"] = QUNAR_AGENT_ID;

  519.         $post_data["time"] = $current_time;

  520.         if (is_array($rowset) && $rowset[0]['errcode'] == 0) {

  521.             $order_id = $rowset[0]['order_id'];

  522.             $res_content = get_msg_info($order_id);

  523.             $name = $res_content[0];

  524.             $tel = $res_content[1];

  525.             $content = $res_content[2];

  526.             $post_data["comment"] = $content;

  527.             $ticketCode = sprintf("%d", $order_id);

  528.             for ($ticket_index = 1; $ticket_index < $ticket_num; $ticket_index++) {

  529.                 $ticketCode .= "|" . sprintf("%d", $order_id);

  530.             }

  531.             $status_post_data['order_id'] = $order_id;

  532.             $opera_per_price = $per_price;

  533.             $opera_all_price = $all_price;

  534.             //both way

  535.             if( $back_run_code != false ) {

  536.                 $opera_per_price = $per_price / 2;

  537.                 $opera_all_price = $all_price / 2;

  538.                 $myprod2 = '{m'.$back_prod_id.'p'.$ticket_num.'|r'.$back_run_code.'}';

  539.                 $sql_insert2 = "call sp_make_order(" . $userid . ",'" . $myprod2 . "','" . $mycustomer . "', 28, '" . $out_order_no . "')";

  540.                 $result = $pdo->query($sql_insert2);

  541.                 if( $result != false ) {

  542.                     $rowset_back = $result->fetchAll(PDO::FETCH_ASSOC);

  543.                     $result->closeCursor();

  544.                 } else {

  545.                     $rowset_back = false;

  546.                 }

  547.                 if (is_array($rowset_back) && $rowset_back[0]['errcode'] == 0) {

  548.                     $back_order_id = $rowset_back[0]['order_id'];

  549.                     $res_content2 = get_msg_info($back_order_id);

  550.                     $content2 = $res_content2[2];

  551.                     $post_data["comment"] .= $content2 ;

  552.                     $status_post_data['order_id'] = "{$order_id},{$back_order_id}";

  553.                 } else {

  554.                     $sql = "CALL SP_CANCEL_ORDER(" . $user_id . "," . $order_id . ")";

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

  556.                     $result->closeCursor();

  557.                     $post_data["comment"] = "出票失败:" . $rowset[0]['errinfo'];

  558.                     $post_data["ticketInfo"] = json_encode(array("ret" => false, "data" => array("orderNo" => $out_order_no, "ticketStatu" => 1)));

  559.                     $post_data["auth"] = get_qunar_auth($post_data);

  560.                     $complete_result = send_post_qunar(QUNAR_COMPLETE_ORDER_URL, $post_data);

  561.                     $complete_result_array = json_decode($complete_result, true);

  562.                     continue;

  563.                 }

  564.             } else {

  565.                 $back_order_id = false;

  566.             }

  567. 

  568.             $pdo_insert2 = conn1();

  569.             $opera_detail = "创建订单，出发日期{$run_main_info["RUN_DATE"]}，订单渠道去哪儿汽车票，单价{$opera_per_price}，总额{$opera_all_price}，联系人信息：{$customer_name},{$customer_mobile},{$customer_id_no}，备注信息：";

  570.             $sql_log = "insert into order_opera_log(order_id,opera_user_id,opera_type,opera_time,opera_detail,opera_platform) VALUES ({$order_id},2,1,'{$current_time}','{$opera_detail}','OTA对接')";

  571.             $pdo_insert2->exec($sql_log);

  572.             if( $back_order_id != false ) {

  573.                 $sql2 = " SELECT RUN_DATE FROM run_main WHERE RUN_ID = {$back_run_code} ";

  574.                 $result=$pdo->query($sql2);

  575.                 $bak_rowset=$result->fetchAll();

  576.                 $result->closeCursor();

  577.                 $back_run_main_info = $bak_rowset[0];

  578.                 $pdo_insert3 = conn1();

  579.                 $opera_detail = "创建订单，出发日期{$back_run_main_info["RUN_DATE"]}，订单渠道去哪儿汽车票，单价{$opera_per_price}总额，{$opera_all_price}，联系人信息：{$customer_name},{$customer_mobile},{$customer_id_no}，备注信息：";

  580.                 $sql_log = "insert into order_opera_log(order_id,opera_user_id,opera_type,opera_time,opera_detail,opera_platform) VALUES ({$back_order_id},2,1,'{$current_time}','{$opera_detail}','OTA对接')";

  581.                 $pdo_insert3->exec($sql_log);

  582.                 $sql_log = "insert into to_from(to_orderid,back_orderid) VALUES ( {$order_id}, {$back_order_id})";

  583.                 $pdo_insert3->exec($sql_log);

  584.             }

  585. 

  586.             $status_post_data['order_status'] = "451,452,453";

  587.             post2("http://". CS_DOMAIN. "/st-xm/Api/add_order_status_log.php",$status_post_data);

  588. 

  589.             $send_post_data = array();

  590.             $send_post_data["order_id"] = $order_id;

  591.             $send_post_data["per_price"] = $opera_per_price;

  592.             $send_post_data["ticket_num"] = $ticket_num;

  593.             post2("http://". CS_DOMAIN. "/st-xm/Api/change_order_price.php",$send_post_data);

  594.             if( $back_order_id != false ) {

  595.                 $send_post_data = array();

  596.                 $send_post_data["order_id"] = $back_order_id;

  597.                 $send_post_data["per_price"] = $opera_per_price;

  598.                 $send_post_data["ticket_num"] = $ticket_num;

  599.                 post2("http://". CS_DOMAIN. "/st-xm/Api/change_order_price.php",$send_post_data);

  600.             }

  601. 

  602.             $post_data["comment"] .= "提前一天19点之前，如未收到司机电话，请速与021-52218088联系。";

  603.             //end of both way

  604.             $post_data["ticketInfo"] = json_encode(array("ret" => true, "data" => array("orderNo" => $out_order_no, "ticketStatu" => 0, "ticketNum" => sprintf("%d", $ticket_num), "ticketPassword" => $ticketCode, "ticketCode" => $ticketCode)));

  605.         } else {

  606.             $post_data["comment"] = "出票失败:" . $rowset[0]['errinfo'];

  607.             $post_data["ticketInfo"] = json_encode(array("ret" => false, "data" => array("orderNo" => $out_order_no, "ticketStatu" => 1)));

  608.         }

  609.         $post_data["auth"] = get_qunar_auth($post_data);

  610.         $complete_result = send_post_qunar(QUNAR_COMPLETE_ORDER_URL, $post_data);

  611.         $complete_result_array = json_decode($complete_result, true);

  612. 

  613.         if (is_array($rowset) && $rowset[0]['errcode'] == 0) {

  614.             $comment_type = 0;

  615.             $comment_text = "";

  616.             $send_success = 0;

  617.             //$sql1 = "CALL HT_ADD_MSG_COMMENT(2,'addmsg'," . $order_id . "," . $comment_type . ",'" . $comment_text . "','" . $tel . "','" . $content . "','" . date("Y-m-d H:i:s") . "',{$send_success})";

  618.             //$result1 = $pdo->query($sql1);

  619.             //$rowset1 = $result1->fetchAll(PDO::FETCH_ASSOC);

  620.             //$result1->closeCursor();

  621. 

  622.             $pdo_send_msg = conn1();

  623.             $sql1 = "insert into order_send_message(ORDER_ID,SEND_MOBILE,SEND_MESSAGE,SEND_TIME,SEND_ERROR,CREATE_USER_ID,CREATE_TIME,UPDATE_USER_ID,UPDATE_TIME) VALUES ({$order_id},'{$tel}', '{$content}','{$current_time}', {$send_success}, 2,'{$current_time}', 2,'{$current_time}' )";

  624.             $pdo_send_msg->exec( $sql1 );

  625. 

  626.             if( $back_run_code != false ) {

  627.                 //$sql1 = "CALL HT_ADD_MSG_COMMENT(2,'addmsg'," . $back_order_id . "," . $comment_type . ",'" . $comment_text . "','" . $tel . "','" . $content2 . "','" . date("Y-m-d H:i:s") . "',{$send_success})";

  628.                 //$result1 = $pdo->query($sql1);

  629.                 //$rowset1 = $result1->fetchAll(PDO::FETCH_ASSOC);

  630.                 //$result1->closeCursor();

  631.                 $sql1 = "insert into order_send_message(ORDER_ID,SEND_MOBILE,SEND_MESSAGE,SEND_TIME,SEND_ERROR,CREATE_USER_ID,CREATE_TIME,UPDATE_USER_ID,UPDATE_TIME) VALUES ({$back_order_id},'{$tel}', '{$content2}','{$current_time}', {$send_success}, 2,'{$current_time}', 2,'{$current_time}' )";

  632.                 $pdo_send_msg->exec( $sql1 );

  633.             }

  634.             $pdo_update = conn1();

  635.             $sql_update = " UPDATE outside_submit_order set submit_status=1 WHERE outside_order_no='{$out_order_no}'";

  636.             $pdo_update->exec($sql_update);

  637.             $sql_order_status = "update order_main set order_status =146 where  order_id= " . $order_id . " or parent_order_id = " . $order_id;

  638.             $pdo_update2 = conn1();

  639.             $pdo_update2->exec($sql_order_status);

  640.             if( $back_run_code != false ) {

  641.                 $sql_order_status2 = "update order_main set order_status =146 where  order_id= " . $back_order_id . " or parent_order_id = " . $back_order_id;

  642.                 $pdo_update3 = conn1();

  643.                 $pdo_update3->exec($sql_order_status2);

  644.             }

  645.         }

  646.     }

  647. }

  648. echo "success";

  649. exit();

  650. 

  651. function get_msg_info($ORDER_ID) {

  652.     $url='http://'. CS1_DOMAIN. '/api/msg/get-msg-info';

  653.     $sendInfo=array();

  654.     $sendInfo['order_id']=	$ORDER_ID;

  655.     $sendInfo['msg_type']='ota';

  656.     $res_content = httpRequest($url,$sendInfo);

  657.     $result_array = json_decode($res_content,true);

  658.     return array(isset($result_array['name']) ? $result_array['name'] : "", isset($result_array['mobile']) ? $result_array['mobile'] : "", isset($result_array['content']) ? $result_array['content'] : "短信错误，联系客服!!!");

  659. }

  660. 

  661. function post2($url, $post_data = '', $timeout = 5){//curl

  662.     $ch = curl_init();

  663.     curl_setopt ($ch, CURLOPT_URL, $url);

  664.     curl_setopt ($ch, CURLOPT_POST, 1);

  665.     if($post_data != ''){

  666.         curl_setopt($ch, CURLOPT_POSTFIELDS, $post_data);

  667.     }

  668.     curl_setopt ($ch, CURLOPT_RETURNTRANSFER, 1);

  669.     curl_setopt ($ch, CURLOPT_CONNECTTIMEOUT, $timeout);

  670.     curl_setopt($ch, CURLOPT_HEADER, false);

  671.     $file_contents = curl_exec($ch);

  672.     curl_close($ch);

  673.     return $file_contents;

  674. }

  675. 

  676. function send_post_qunar($url, $post_data) {

  677.     writeLog( "------qunar get order result:".json_encode($post_data) );

  678.     $postdata = http_build_query($post_data);

  679.     $options = array(

  680.         'http' => array(

  681.             'method' => 'POST',

  682.             'header' => 'Content-type:application/x-www-form-urlencoded',

  683.             'content' => $postdata,

  684.             'timeout' => 15 * 60 // 超时时间（单位:s）

  685.         )

  686.     );

  687.     $context = stream_context_create($options);

  688.     $result = file_get_contents($url, false, $context);

  689.     return $result;

  690. }