nizongfeng
/
zzcx_line
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
17 MiB
 
 
 
 
Branch: master
Branches Tags
${ item.name }
Create branch ${ searchTerm }
from 'master'
${ noResults }
zzcx_line/coding/api1.0/qunar_get_order.php.bak

563 lines
30 KiB
Raw Permalink Blame History 

  1. <?php

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

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

  4. require_once '/usr/share/nginx/ZZCS/coding/st-xm/Common/sinaAPI.php';

  5. require_once '/usr/share/nginx/ZZCS/coding/st-xm/Common/zizai_orderAPI.php';

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

  7. $current_time = time();

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

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

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

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

  12. //拼接数组

  13. $post_data = array();

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

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

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

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

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

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

  20.     print_r($return_array);

  21.     return;

  22. }

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

  24. $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);

  25. 

  26. $limit_sell_prod = array( 448568, 448569,448778,448779,448780,448781);

  27. 

  28. $userid = 1;

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

  30. $pdo=conn1();

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

  32. foreach( $order_array as $order_info ) {

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

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

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

  36.         $run_code = $run_code_array[0];

  37.         $prod_id = $run_code_array[1];

  38.     } else {

  39.         //zizai

  40.         $run_code = $run_code_array[1];

  41.     }

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

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

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

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

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

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

  48.     $passengers_array = array();

  49.     foreach( $passengers as $passenger_info ) {

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

  51.     }

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

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

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

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

  56.     $result->closeCursor();

  57.     if ($rowset != false) {

  58.         continue;

  59.     }

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

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

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

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

  64.         $result->closeCursor();

  65.         $run_main_info = $rowset[0];

  66. 

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

  68.             $sql = " SELECT * FROM run_main WHERE PROD_ID={$run_main_info["PROD_ID"]} AND RUN_DATE='{$order_info["date"]}' ";

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

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

  71.             $result->closeCursor();

  72.             $run_main_info = $rowset[0];

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

  74.         }

  75. 

  76.         $sql = " SELECT * FROM opera_product_price WHERE PROD_ID={$prod_id} ";

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

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

  79.         $result->closeCursor();

  80.         $per_price = $rowset[0]["CUS_PRICE"];

  81.         $all_price = $per_price * $ticket_num;

  82.     } else {

  83.         //zizai

  84.         $prod_id = $run_code_array[0];

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

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

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

  88.         $result->closeCursor();

  89.         if( false == $rowset ) {

  90.             $post_data = array();

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

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

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

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

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

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

  97.             continue;

  98.         }

  99.         $run_info = $rowset[0];

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

  101.             $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"]}'";

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

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

  104.             $result->closeCursor();

  105.             if( false == $rowset ) {

  106.                 $post_data = array();

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

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

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

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

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

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

  113.                 continue;

  114.             }

  115.             $run_info = $rowset[0];

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

  117.         }

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

  119.         $all_price = $per_price * $ticket_num;

  120.     }

  121. 

  122.     $pdo_insert = conn1();

  123.     $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(" .

  124.         "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}')  ";

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

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

  127.         $remain_count = $run_info["remain_count"] > 3 ? $run_info["remain_count"] - 3 : 0;

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

  129.         if( $update_date < $today ) {

  130.             $remain_count = 0;

  131.         }

  132.         if( $remain_count < $ticket_num ) {

  133.             $post_data = array();

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

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

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

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

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

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

  140.             continue;

  141.         }

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

  143.         //自在下票

  144.         $setOrder = new orderService();

  145.         //票务系统锁定

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

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

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

  149.         if ($lock_order['code']!=0) {

  150.             $post_data = array();

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

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

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

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

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

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

  157.             continue;

  158.         }

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

  160.         $customerlist = "";

  161.         foreach( $passengers as $passenger_info ) {

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

  163.         }

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

  165.         $pdo_update3 = conn1();

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

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

  168. 

  169.         $post_data = array();

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

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

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

  173.         $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";

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

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

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

  177.         }

  178.         $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 )) );

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

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

  181. 

  182.         /*

  183.         $res_order = $setOrder->eticket(zizaiArgs::$USER, $tradeno);

  184.         if ($res_order['code']!=0) {

  185.             $post_data = array();

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

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

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

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

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

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

  192.             continue;

  193.         }*/

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

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

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

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

  198.         $result->closeCursor();

  199.         if( $rowset == false ) {

  200.             $start_area_id = 791;

  201.         } else {

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

  203.         }

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

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

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

  207.         $result->closeCursor();

  208.         if( $rowset == false ) {

  209.             $end_area_id = 791;

  210.         } else {

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

  212.         }

  213. 

  214.         $userid = 1;

  215.         $prod_id = 380001;

  216.         $run_code = 0;

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

  218.         $mycustomer = "{,".$customer_name.",,".$customer_mobile.",150,".$customer_id_no.",,,,".$passenger_txt."}";

  219.         $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."}";

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

  221.         writeLog($sql_insert);

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

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

  224.         $result->closeCursor();

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

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

  227.             //update submit order

  228.             $pdo_update = conn1();

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

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

  231.             $pdo_update2 = conn1();

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

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

  234.             continue;

  235.         } else {

  236.             /*

  237.             $post_data = array();

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

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

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

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

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

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

  244.             */

  245.             continue;

  246.         }

  247.         continue;

  248.     }

  249. 

  250.     if( in_array($run_main_info["PROD_ID"], $limit_sell_prod) && (($current_hour >= "15:00" && $run_main_info["RUN_DATE"] <= $tomorrow_day) || $run_main_info["RUN_DATE"] < $tomorrow_day )) {

  251.         $post_data = array();

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

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

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

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

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

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

  258.         continue;

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

  260.         $post_data = array();

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

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

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

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

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

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

  267.         continue;

  268.     }

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

  270.         $post_data = array();

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

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

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

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

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

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

  277.         continue;

  278.     }

  279. 

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

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

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

  283. 

  284.         if($prod_id== "449862") {

  285.             $result = post2('http://wx.zhizhuchuxing.com/ZZDZ/application/custom_made/control.php', array(

  286.                 'type' => 'order_submitforout',

  287.                 'prod_list' => $myprod,

  288.                 'customer_info' => $mycustomer,

  289.                 'start_name' => '南京五塘广场',

  290.                 'end_name' => '南通政务中心',

  291.                 'startx_y' => '32.116682,118.784105',

  292.                 'endx_y' => '32.011714,120.894448',

  293.                 'line_id' => '449860',

  294.                 'start_time' => '07:37',

  295.                 'end_time' => '10:30'

  296.             ));

  297.         } else {

  298.             $result =  post2('http://wx.zhizhuchuxing.com/ZZDZ/application/custom_made/control.php',array(

  299.                 'type' =>'order_submitforout',

  300.                 'prod_list'=>$myprod,

  301.                 'customer_info'=>$mycustomer,

  302.                 'start_name'=>'南通政务中心',

  303.                 'end_name'=>'南京五塘广场',

  304.                 'endx_y'=>'32.116682,118.784105',

  305.                 'startx_y'=>'32.011714,120.894448',

  306.                 'line_id'=>'449865',

  307.                 'start_time'=>'07:37',

  308.                 'end_time'=>'10:30'

  309.             ));

  310.         }

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

  312. 

  313.         writeLog($result);

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

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

  316.             $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;

  317.             $pdo_update2 = conn1();

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

  319.             $res_content = get_msg_info($order_id);

  320.             $name = $res_content[0];

  321.             $tel = $res_content[1];

  322.             $content = $res_content[2];

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

  324. 

  325.             $comment_type = 0;

  326.             $comment_text = "";

  327.             $send_success = 0;

  328.             $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})";

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

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

  331.             $result1->closeCursor();

  332.             $pdo_update = conn1();

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

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

  335. 

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

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

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

  339.             }

  340.             $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)));

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

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

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

  344.             continue;

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

  346.             $post_data = array();

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

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

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

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

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

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

  353.             continue;

  354.         } else {

  355.             $post_data = array();

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

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

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

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

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

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

  362.             continue;

  363.         }

  364. 

  365.     } else {

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

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

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

  369.         $result->closeCursor();

  370.         $post_data = array();

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

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

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

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

  375.             $res_content = get_msg_info($order_id);

  376.             $name = $res_content[0];

  377.             $tel = $res_content[1];

  378.             $content = $res_content[2];

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

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

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

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

  383.             }

  384.             $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)));

  385.         } else {

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

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

  388.         }

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

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

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

  392. 

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

  394.             $comment_type = 0;

  395.             $comment_text = "";

  396.             $send_success = 0;

  397.             $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})";

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

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

  400.             $result1->closeCursor();

  401.             $pdo_update = conn1();

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

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

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

  405.             $pdo_update2 = conn1();

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

  407.         }

  408.     }

  409. }

  410. echo "success";

  411. exit();

  412. 

  413. function get_msg_info($ORDER_ID) {

  414.     $msg_pdo = conn1();

  415.     $msg_sql = "CALL SP_GET_MESSAGE_TEMPLATE('" . $ORDER_ID . "')";

  416.     $content = '';

  417.     if (is_object($msg_pdo)) {

  418.         $msg_result = $msg_pdo -> query($msg_sql);

  419.         $i = 1;

  420.         $data = array();

  421.         if ($msg_result) {

  422.             $data['code'] = "0";

  423.             $data['info'] = "";

  424.             do {

  425.                 $row = $msg_result -> fetchAll(PDO::FETCH_ASSOC);

  426.                 if ($i == 1) {

  427.                     $data['seat'] = isset($row) ? $row : array();

  428.                 } else if ($i == 2) {

  429.                     $data['run_info'] = isset($row) ? $row : array();

  430.                 } else if ($i == 3) {

  431.                     $data['driver'] = isset($row) ? $row : array();

  432.                 } else {

  433.                 }

  434.                 $i++;

  435.             } while($msg_result->nextRowset());

  436.         }

  437.         $json_obj = json_decode(json_encode($data), TRUE);

  438.         $seat = isset($json_obj['seat'][0]) ? $json_obj['seat'][0] : array();

  439.         $run_info = isset($json_obj['run_info'][0]) ? $json_obj['run_info'][0] : array();

  440.         $driver = isset($json_obj['driver'][0]) ? $json_obj['driver'][0] : array();

  441.         $bus_res_id = isset($json_obj['driver'][0]) ? $json_obj['driver'][0]["bus_res_id"] : 0;

  442.         $short_url = false;

  443.         if( $bus_res_id != 0 ) {

  444.             $ary_sell_ary = array(916,917);

  445.             if( in_array( $bus_res_id, $ary_sell_ary ) ) {

  446.                 $ticket_url = TICKET_QR_URL.$ORDER_ID;

  447.                 $short_url = sinaShortenUrl($ticket_url);

  448.             }

  449.         }

  450.         $extra_message = "";

  451.         if( $short_url != false ) {

  452.             $extra_message = "点击以下链接获取您的电子票扫码上车：{$short_url}";

  453.         }

  454. 

  455.         //出票成功

  456.         //		$content = "您预订的{出发日期　出发时间}{出发地}-{目的地}{票种名}{张数}张，已购票成功。乘车订单号为{订单号}，请凭订单号或绑定微信（微信服务号“蜘蛛出行”）扫码上车，车牌号{车牌号}，司机电话{司机姓司机电话}。";

  457.         // 得到明天的时间

  458.         date_default_timezone_set('prc');

  459.         //解决时区问题

  460.         $tomorrow = date("Y-m-d", strtotime("+1 day"));

  461.         $now_time = date('H:i:s', time());

  462.         //判断当前时间是否在17:30:00之后

  463.         $cur_date = date('Y-m-d', time());

  464.         $new_message_array = array(448569,448568);

  465.         $new_message_array2 = array(449860,449865);

  466.         if( in_array( $run_info['parent_prod_id'], $new_message_array ) ) {

  467.             $content = "您预订的{出发日期}{出发地}-{目的地}{票种名}{张数}张，已成功出票，请在{出发时间}前十五分钟到达{上车站点}。出行前一天下午的18:00左右将会有导游和您联系，预祝您旅途愉快。";

  468.         }  else if( in_array( $run_info['parent_prod_id'], $new_message_array2 ) ) {

  469.             $content = "您已成功预订{出发地}-{目的地}城际商务车{张数}张车票，车型为奔驰7座，发车时间为{出发日期} {出发时间}，请提前10分钟到达{上车站点}。车辆和司机联系方式会在出行前一天18:30发送给您。";

  470.         }  else if (($now_time > "17:30:00" && $run_info['start_date'] == $tomorrow) || $cur_date == $run_info['start_date']) {//17：30之后的订单或者下单时间为今天出行为今天下午  发送短信模板

  471.             //		if("18:30:00">"17:30:00" && $run_info['start_date']==$tomorrow){	//17：30之后的订单  发送短信模板

  472.             //			$content = "您预订的{出发日期　出发时间}{出发地}-{目的地}{票种名}{张数}张，已购票成功。乘车订单号为{订单号}，请凭订单号或绑定微信（微信服务号“蜘蛛出行”）扫码上车，车牌号{车牌号}，司机电话{司机姓司机电话}。";

  473.             $content = "您预订的{出发日期}{出发地}-{目的地}{票种名}{张数}张，已成功出票，请在{出发时间}前三十分钟到达{上车站点}。您的乘车订单号为{订单号}，车牌号{车牌号}，司机电话{司机姓司机电话}，请凭短信订单号乘车".$extra_message."，预祝您旅途愉快。";

  474. 

  475.         } else {

  476.             //			$content = "您预订的{出发日期　出发时间}{出发地}-{目的地}{票种名}{张数}张，已购票成功。乘车订单号为{订单号}，请凭订单号或绑定微信（微信服务号“蜘蛛出行”）扫码上车。";

  477.             $content = "您预订的{出发日期}{出发地}-{目的地}{票种名}{张数}张，已成功出票，请在{出发时间}前三十分钟到达{上车站点}。您的乘车订单号为{订单号}，请凭短信订单号乘车".$extra_message."。出行前一天下午的18:30会将车牌号与司机电话发送给您，预祝您旅途愉快。";

  478.         }

  479.         //		$content = "您预订的{出发日期　出发时间}{出发地}-{目的地}{票种名}{张数}张，已购票成功。乘车订单号为{订单号}，请凭订单号或绑定微信（微信服务号“蜘蛛出行”）扫码上车。";

  480.         if ($seat) {

  481.             $seat_x = isset($seat['seat_x']) ? $seat['seat_x'] : "";

  482.             $seat_y = isset($seat['seat_y']) ? $seat['seat_y'] : "";

  483.             $seat_name = isset($seat['seat_name']) ? $seat['seat_name'] : "";

  484.             $order_main_id = isset($seat['order_main_id']) ? $seat['order_main_id'] : "";

  485.         } else {

  486. 

  487.         }

  488.         if ($run_info) {

  489.             $order_count = $run_info['order_count'];

  490.             $start_date = $run_info['start_date'];

  491.             $start_time = $run_info['start_time'];

  492.             $parent_order_id = $run_info['parent_order_id'];

  493.             $end_date = $run_info['end_date'];

  494.             $start_area = $run_info['start_area'];

  495.             $end_area = $run_info['end_area'];

  496.             $res_name = $run_info['res_name'];

  497.             $prod_name = $run_info['prod_name'];

  498.             $prod_name = "标准票";

  499.             $customer_name = $run_info['customer_name'];

  500.             $customer_mobile = $run_info['customer_mobile'];

  501.             $start_end_date = $start_date . "," . $start_time;

  502.             $content = str_replace("{出发日期}", $start_date, $content);

  503.             $content = str_replace("{出发时间}", $start_time, $content);

  504.             $content = str_replace("{上车站点}", $res_name, $content);

  505.             $content = str_replace("{出发地}", $start_area, $content);

  506.             $content = str_replace("{目的地}", $end_area, $content);

  507.             $content = str_replace("{票种名}", $prod_name, $content);

  508.             $content = str_replace("{张数}", $order_count, $content);

  509.             $content = str_replace("{订单号}", $ORDER_ID, $content);

  510.         } else {

  511.             $content = str_replace("{出发日期}", "", $content);

  512.             $content = str_replace("{出发时间}", "", $content);

  513.             $content = str_replace("{出发地}", "", $content);

  514.             $content = str_replace("{目的地}", "", $content);

  515.             $content = str_replace("{票种名}", "", $content);

  516.             $content = str_replace("{张数}", "", $content);

  517.             $content = str_replace("{订单号}", "", $content);

  518.         }

  519.         if ($driver) {

  520.             $bus_no = isset($driver['bus_no']) ? $driver['bus_no'] : "";

  521.             $driver_name = isset($driver['driver_name']) ? $driver['driver_name'] : "";

  522.             $driver_mobile = isset($driver['driver_mobile']) ? $driver['driver_mobile'] : "";

  523. 

  524.             if ($bus_no == "") {

  525.                 $content = str_replace("，车牌号{车牌号}", "", $content);

  526.             } else {

  527.                 $content = str_replace("{车牌号}", $bus_no, $content);

  528.             }

  529.             if ($driver_name == "") {

  530.                 $content = str_replace("，司机电话{司机姓司机电话}，", "。", $content);

  531.             } else {

  532.                 $driver_xing = mb_substr($driver_name, 0, 1, 'utf-8');

  533.                 $driver_name_mobile = $driver_xing . $driver_mobile;

  534.                 $content = str_replace("{司机姓司机电话}", $driver_name_mobile, $content);

  535.             }

  536.         } else {

  537.             $content = str_replace("车牌号{车牌号}，", "", $content);

  538.             $content = str_replace("司机电话{司机姓司机电话}，", "", $content);

  539.         }

  540.         return array(isset($customer_name) ? $customer_name : "", isset($customer_mobile) ? $customer_mobile : "", isset($content) ? $content : "短信错误，联系客服!!!");

  541.     }

  542. <<<<<<< .mine

  543. }

  544. =======

  545. }

  546. 

  547. function post2($url, $data){//file_get_content

  548.     $postdata = http_build_query(

  549.         $data

  550.     );

  551.     $opts = array('http' =>

  552.         array(

  553.             'method'  => 'POST',

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

  555.             'content' => $postdata

  556.         )

  557.     );

  558. 

  559.     $context = stream_context_create($opts);

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

  561.     return $result;

  562. }>>>>>>> .r1099