nizongfeng
/
XMWX
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
29 MiB
 
 
 
 
 
Branch: master
Branches Tags
${ item.name }
Create branch ${ searchTerm }
from 'master'
${ noResults }
XMWX/ZZDZ2/application/custom_made/order/xiechengorder.php

553 lines
28 KiB
Raw Permalink Blame History 

  1. <?php

  2. /*

  3. 测试代码

  4. * wechat 2.0

  5. * Copyright (c) 2016 zhangs  http://zhizhuchuxing.com/

  6. * Date: 2016.9.21

  7. * Something is to pay QQ1062140302

  8. */

  9. date_default_timezone_set('PRC');

  10. require_once __DIR__ . '/../../api/common.php';

  11. require_once __DIR__ . '/../../api/create_order.php';

  12. //require_once __DIR__ . '/../../api/cancel_order.php';

  13. require_once __DIR__ . '/../../api/submitOrder.php';

  14. require_once __DIR__ . '/../dictionary.php';

  15. require_once __DIR__ . '/../../api/cancelOrder.php';

  16. 

  17. $array_line_info = $array_line_info;

  18. 

  19. class submit extends virtifyUsers

  20. {

  21.     //提交订单流程

  22.     public function execSubmit($prod_list, $customer_info, $start_id, $end_id, $line_id, $start_time, $end_time, $pdo, $array_line_info)

  23.     {

  24.         //获取要提交的详细信息

  25.         $prod_info = $this->get_prod_info($prod_list, $pdo);

  26. 

  27.         $ticket_id = $prod_info['ticket_id'];//票种ID

  28.         $tic_num = $prod_info['tic_num'];//订票数量

  29.         $run_id = $prod_info['run_id'];//班次ID

  30.         $userid = $prod_info['userid'];//用户ID

  31.         $member_id = $prod_info['member_id'];//会员号

  32.         $run_date = $prod_info['run_date'];//发车日期

  33.         $run_time = $prod_info['run_time'];//发车时间

  34.         $run_date_time = $prod_info['run_date_time'];//检验订单所需时间

  35. 

  36.         //判断会员号

  37.         if (!$member_id) {//

  38.             echo json_encode(array("code" => '1', "iflogin" => 1, "info" =>'请关注公众号蜘蛛出行','data'=>$array_line_info[$line_id]['start'][$start_id]['name']));

  39.             exit;

  40.         }

  41. 

  42.         //判断购票数量

  43.         if ($tic_num == 0) {

  44.             echo json_encode(array("code" => '1', "info" => "订票数量不可为0"));

  45.             exit;

  46.         }

  47. 

  48.         //获取站点详情

  49.         $start_name = $array_line_info[$line_id]['start'][$start_id]['name'];

  50.         $end_name = $array_line_info[$line_id]['end'][$end_id]['name'];

  51. 

  52.         //派车

  53.         $order_result = $this->send_car($line_id, $run_id, $run_date_time, $tic_num, $start_id, $end_id, $pdo);

  54.         writeLog("send_car:" . json_encode($order_result));

  55. 

  56. var_dump($order_result);

  57. die;

  58.         //派车失败

  59.         if ($order_result['code'] != 0) {

  60.             echo json_encode(array("code" => '1', "info" => $line_id . "--" . $run_id . "--" . $run_date_time . "--" . $tic_num . "--" . $start_id . "--" . $end_id));

  61.             exit();

  62.         }

  63. 

  64.         //派车成功

  65.         $order_result = $order_result['result'];

  66.         $order_id = $order_result['order_id'];//订单ID

  67.         $bus_no = $order_result['bus_no'];//车号

  68.         $order_from_org_id = 0;//订单渠道ID

  69.         $top_org_id = 0;//顶级订单渠道ID

  70.         $outside_order_id = isset($_POST['outside_order_id']) ? $_POST['outside_order_id'] : '1';//外部订单渠道ID

  71. 

  72.         //获取票种价格

  73.         $sql_price = "select cus_price from opera_product_price where prod_id =" . $ticket_id;

  74.         $result_price = $pdo->query($sql_price);

  75.         $row_p = $result_price->fetchAll(PDO::FETCH_ASSOC);

  76. 

  77.         $price_list = $ticket_id . ',' . $row_p[0]['cus_price'];//票种价格完整信息

  78. 

  79. 		

  80.         $sql = "CALL sp_make_order_for_business('" . $userid . "','" . $prod_list . "','" . $customer_info . "','1','0','" . $start_name . "','" . $end_name . "','" . $start_time . "','" . $end_time . "','" . $bus_no . "','" . $member_id . "','" . $order_id . "')";

  81. 	$sqlqq =$sql;

  82.         //提交order_main表

  83.         $rowset = $this->create_order($sql, $price_list, $pdo);

  84. //        echo json_encode(array('code' => '1', 'info' =>$rowset));

  85. //            exit();

  86.         //order_main提交失败

  87.         if (!$rowset || $rowset[0]['errcode']) {

  88.             $co = new cancelOrder();

  89.             $res = $co->cancel_order($run_id, $bus_no, $start_id, $end_id, $order_id, $tic_num);

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

  91.                 echo json_encode(array('code' => '1', 'info' => '服务器异常，请稍后重试！', 'info1' => '向数据库提交订单和退票算法都挂掉了！'));

  92.                 exit();

  93.             }

  94. 

  95.             echo json_encode(array('code' => '1', 'info' => '服务器异常，请稍后重试！','data'=>$sqlqq));

  96.             exit();

  97. 

  98.         }

  99. 

  100.         //获取订单详情

  101.         $order_info = $this->get_order_info($order_id, $pdo);

  102. 

  103.         $pay_main_id = $order_info[0]['order_pay_main_id'];//支付方式

  104.         $pay_price = $order_info[0]['order_price'];

  105.         if(($line_id ==450544 && $end_id == 7 )|| ($line_id ==450539 && $start_id == 0 )){

  106.              $price_change =150;

  107.          }

  108.         if(isset($price_change) && $price_change){

  109.             $price_huaian = ($pay_price/110)*150;

  110.             $sql_price_huaian = "UPDATE order_main

  111.                         SET ORDER_BOOK_STATUS = 1,

  112.                             order_price = " . $price_huaian . "

  113.                         WHERE

  114.                             order_id = " . $order_id;

  115.              $result = $pdo->exec($sql_price_huaian);

  116.             

  117.         }

  118. 

  119.         //修改订单

  120.         $this->update_order_info($order_id, $run_id, $bus_no, $member_id, $pay_main_id, $pdo);

  121. 

  122. 

  123.         echo json_encode(array('code' => '0', 'info' => '返回数据成功', 'order_id' => $order_id));

  124.         exit();

  125. 

  126.     }

  127. 

  128. 

  129.     //获取要提交订单的详细信息

  130.     public function get_prod_info($prod_list, $pdo)

  131.     {

  132.         $ticket_id = substr($prod_list, strpos($prod_list, 'm') + 1, strpos($prod_list, 'p') - 2);//票种ID

  133.         $tic_num = substr($prod_list, strpos($prod_list, 'p') + 1, strpos($prod_list, '|') - strpos($prod_list, 'p') - 1);//乘客数量

  134.         $run_id = substr(substr($prod_list, strpos($prod_list, 'r') + 1), 0, -1);//班次ID

  135. 

  136.         //$beginX_Y = isset($_POST['startx_y']) ? $_POST['startx_y'] : false;

  137.         $userid = 0;//用户ID

  138.         $member_id = 1;//会员号ID

  139. 

  140.         $sql_time = "select run_date,run_time from run_main where run_id  =" . $run_id;

  141.         $result_time = $pdo->query($sql_time);

  142.         $row_t = $result_time->fetchAll(PDO::FETCH_ASSOC);

  143. 

  144.         $run_date = $row_t[0]['run_date'];//出发日期

  145.         $run_time = $row_t[0]['run_time'];//出发时间

  146.         $run_date_time = $run_date . " " . $run_time;

  147.         $prod_info['ticket_id'] = $ticket_id;

  148.         $prod_info['tic_num'] = $tic_num;

  149.         $prod_info['run_id'] = $run_id;

  150.         $prod_info['userid'] = $userid;

  151.         $prod_info['member_id'] = $member_id;

  152.         $prod_info['run_date'] = $run_date;

  153.         $prod_info['run_time'] = $run_time;

  154.         $prod_info['run_date_time'] = $run_date_time;

  155.         return $prod_info;

  156.     }

  157. 

  158. 

  159.     //解析乘客信息

  160.     public function explode_cust_info($cust_info)

  161.     {

  162.         $cust_info_temp = explode(',', $cust_info);

  163.         $temp['name'] = $cust_info_temp['1'];

  164.         $temp['phone'] = $cust_info_temp['3'];

  165.         return $temp;

  166.     }

  167. 

  168.     //派车

  169.     public function send_car($line_id, $run_id, $run_date, $num, $station_start, $station_end, $pdo)

  170.     {

  171.         $submit_order = new submitOrder();

  172.         $order_id =473878 ;

  173.         $submit_set = $submit_order->setOrder($line_id, $run_id, $order_id, $run_date, $num, $station_start, $station_end);

  174. //        echo json_encode(array("code" => '1', "info" => "$submit_order->setOrder(" . $line_id . "--" . $run_id . "--" . $order_id . "--" . $run_date . "--" . $num . "--" . $station_start . "--" . $station_start . "--" . $station_end . ")"));

  175. //        exit();

  176.         return $submit_set;

  177.     }

  178. 

  179.     function getUniqeId($pdo)

  180.     {

  181.         $result = $pdo->query("select FUNC_GET_UNIQUE_ID('1','1') id");

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

  183.         return $rowset[0]['id'];

  184.     }

  185. 

  186. 

  187.     //检验订单

  188.     public function check_order($startx_y, $endx_y, $line_id, $run_id, $tic_num, $start_name, $end_name, $run_date_time)

  189.     {

  190.         $co = new createOrder();

  191.         $time = commonUtils::baiduShortTime($startx_y, $endx_y);

  192.         if (!$startx_y || !$endx_y) {

  193.             $result['status'] = 111;  //状态码：111为经纬度不能为空）

  194.             $result['info'] = "经纬度不能为空";

  195.             echo json_encode($result);

  196.             exit();

  197.         }

  198.         if ($time > 360)    //总时长不能超过360分钟

  199.         {

  200.             $result['status'] = 101;  //状态码：101为总时长不符合要求（超过360分钟）

  201.             $result['info'] = "总时长不能超过360分钟";

  202.             echo json_encode($result);

  203.             exit();

  204.         }

  205.         if ($tic_num > 6) {

  206.             $result['status'] = 108;  //状态码：人数不能超过6人

  207.             $result['info'] = "每个订单人数不能超过6人";

  208.             echo json_encode($result);

  209.             exit();

  210.         }

  211. 

  212.         //先判断是否属于规定的市区

  213.         $start_area = commonUtils::GeocodingAPI($startx_y);

  214.         $end_area = commonUtils::GeocodingAPI($endx_y);

  215.         if (($line_id == "449860" && $start_area == "南京市" && $end_area == "南通市") || ($line_id == "449865" && $start_area == "南通市" && $end_area == "南京市")) {

  216.             if ($line_id && $run_id && $tic_num && $startx_y && $endx_y && $run_date_time) {

  217.                 $orderID = commonUtils::produceOrderId($tic_num);   //获取订单号

  218.                 $res = $co->calShortTime($line_id, $run_id, $orderID, $tic_num, $startx_y, $start_name, $endx_y, $end_name, $run_date_time);

  219.                 return $res;

  220.             } else {

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

  222.                 $result['info'] = "订单提交信息不全";

  223.                 echo json_encode($result);

  224.                 exit();

  225.             }

  226.         } else {

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

  228.             $result['info'] = "所选地点不在规划范围内";

  229.             echo json_encode($result);

  230.             exit();

  231.         }

  232. 

  233.     }

  234. 

  235.     //..短信模板-改为17：30后OK，当天下单也OK

  236.     public function get_msg_info($ORDER_ID)

  237.     {

  238.         $msg_pdo = conn();

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

  240.         $content = '';

  241.         if (is_object($msg_pdo)) {

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

  243.             $i = 1;

  244.             $data = array();

  245.             if ($msg_result) {

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

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

  248.                 do {

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

  250.                     if ($i == 1) {

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

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

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

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

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

  256.                     } else if ($i == 4) {

  257.                         $data['dsn_prod'] = isset($row) ? $row : array();

  258.                     } else if ($i == 5) {

  259.                         $data['zhou_su_prod'] = isset($row) ? $row : array();

  260.                     }

  261.                     $i++;

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

  263.             }

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

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

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

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

  268.             $dsn_prod = isset($json_obj['dsn_prod']) ? $json_obj['dsn_prod'] : array();

  269.             $zhou_su_prod = isset($json_obj['zhou_su_prod']) ? $json_obj['zhou_su_prod'] : array();

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

  271.             $short_url = false;

  272.             if ($bus_res_id != 0) {

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

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

  275.                     $ticket_url = TICKET_QR_URL . $ORDER_ID;

  276.                     $short_url = sinaShortenUrl($ticket_url);

  277.                 }

  278.             }

  279.             $extra_message = "";

  280.             if ($short_url != false) {

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

  282.             }

  283. 

  284.             //出票成功

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

  286.             // 得到明天的时间

  287.             date_default_timezone_set('PRC');

  288.             //解决时区问题

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

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

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

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

  293.             //迪士尼特殊情况parent_prod_id

  294. 

  295.             //		$dsn_arr_prod = array(152752, 152759, 152763, 152770, 152777, 152784, 152791, 152801, 152808, 152815, 152822, 152832, 152842, 152852, 152859, 152866, 152873, 152877, 152884, 152891, 152898, 152905, 152915, 152922, 152929, 152936, 152946, 152956, 152966, 152973, 152980, 152990, 153003, 153016, 153023, 153033, 153034, 153044, 153057, 153070, 153083, 153090, 153100, 153110);

  296.             $dsn_arr_prod = array(); //用来保存迪士尼产品的prod_id

  297.             foreach ($dsn_prod as $temp) {

  298.                 $dsn_arr_prod[] = $temp['prod_id'];

  299.             }

  300. 

  301.             $zhou_su_arr_prod = array();

  302.             foreach ($zhou_su_prod as $temp) {

  303.                 $zhou_su_arr_prod[] = $temp['prod_id'];

  304.             }

  305. 

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

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

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

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

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

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

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

  313.                 if (in_array($run_info['parent_prod_id'], $dsn_arr_prod)) {

  314.                     $content = "您预订的{出发日期}{上车站点}-{下车站点}{票种名}{张数}张，已成功出票，请在{出发时间}前三十分钟到达{上车站点}。您的乘车订单号为{订单号}。请凭短信订单号乘车{$extra_message}，预祝您旅途愉快。（如需咨询请致电：021-33280578）【zhizhuchuxing】Congratulations! Your ticket from hotel to Disney has been approved. Your order number is {订单号}. Please keep it and arrive at the place before {出发时间}. Enjoy your trip and have a nice day! If you have any questions, please call: 021-33280578.";

  315.                     $content = str_replace("{上车站点}", $run_info['res_name'], $content);

  316.                     $content = str_replace("{下车站点}", $run_info['end_res_name'], $content);

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

  318.                 }

  319.             } else {

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

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

  322.                 if (in_array($run_info['parent_prod_id'], $dsn_arr_prod)) {

  323.                     $ticket_url = TICKET_QR_URL . $ORDER_ID;

  324.                     $short_url = sinaShortenUrl($ticket_url);

  325.                     $extra_content = "";

  326.                     if ($short_url != false) {

  327.                         $extra_content = "或点击以下链接获取乘车二维码扫码上车(" . $short_url . ")";

  328.                     }

  329.                     $content = "您预订的{出发日期}{上车站点}-{下车站点}{票种名}{张数}张，已成功出票，请在{出发时间}前三十分钟到达{上车站点}。您的乘车订单号为{订单号}。请凭短信订单号乘车{$extra_content}，预祝您旅途愉快。（如需咨询请致电：021-33280578）【zhizhuchuxing】Congratulations! Your ticket from hotel to Disney has been approved. Your order number is {订单号}. Please keep it and arrive at the place before {出发时间}. Enjoy your trip and have a nice day! If you have any questions, please call: 021-33280578.";

  330.                     $content = str_replace("{上车站点}", $run_info['res_name'], $content);

  331.                     $content = str_replace("{下车站点}", $run_info['end_res_name'], $content);

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

  333.                 }

  334.             }

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

  336.             if ($seat) {

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

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

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

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

  341.             } else {

  342. 

  343.             }

  344.             if ($run_info) {

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

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

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

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

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

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

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

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

  353.                 $parent_prod_id = $run_info['parent_prod_id'];

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

  355.                 $prod_name = "标准票";

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

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

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

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

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

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

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

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

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

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

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

  367.             } else {

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

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

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

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

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

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

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

  375.             }

  376.             if ($driver) {

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

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

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

  380. 

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

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

  383.                 } else {

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

  385.                 }

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

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

  388.                 } else {

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

  390.                     $driver_name_mobile = $driver_xing . $driver_mobile;

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

  392.                 }

  393.             } else {

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

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

  396.             }

  397.             /*

  398.             if( $now_time < "18:30:00" ) {

  399.                 //判断是不是苏州或周庄

  400.                 // 判断如果不是迪士尼的票就不发短信

  401.                 if (!in_array($run_info['parent_prod_id'], $dsn_arr_prod) && !in_array($run_info['parent_prod_id'], $zhou_su_arr_prod)) {

  402.                     return array("", "-1", "不是迪士尼、苏州、周庄的票，目前不发送短信");

  403.                 }

  404.             }*/

  405.             $content .= "【重要提示】：因G20峰会影响，7月1号开始实名登记安检，出行时请所有游客携带有效证件（身份证或户口本），凭有效证件上车，如被查出无有效证件，导致无法出行，责任自行承担，谢谢配合！";

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

  407.         }

  408.     }

  409. 

  410.     //发短信

  411.     public function send_msg($ORDER_ID)

  412.     {

  413.         $send_pdo = conn();

  414.         $order_id = $ORDER_ID;

  415.         $res_content = get_msg_info($order_id);

  416.         $name = $res_content[0];

  417.         $tel = $res_content[1];

  418.         $content = $res_content[2];

  419.         writeLog("短信模板内容：【" . $content . "】");

  420. 

  421.         //..发短信先取消

  422.         $response = sendTelMessage($tel, $name, $content, $order_id);

  423.         writeLog(json_encode($response));

  424. 

  425.         $comment_type = 0;

  426.         $comment_text = "";

  427.         $send_success = (int)$response;

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

  429.         $result1 = $send_pdo->query($sql1);

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

  431.         $result1->closeCursor();

  432.         writeLog("hotel_order_status.php HT_ADD_MSG_COMMENT()::" . $sql1);

  433.         //insert order extra

  434.         $hotelPrice = isset($_GET['hotelPrice']) ? $_GET['hotelPrice'] : "";

  435.         $doorPrice = isset($_GET["doorPrice"]) ? $_GET["doorPrice"] : "";

  436. 

  437.         if ($hotelPrice != "" || $doorPrice != "") {

  438.             $sqlInsert = " INSERT INTO order_extra_info (order_id,hotel_price,gate_price) VALUE(" . $ORDER_ID . ",'" . $hotelPrice . "','" . $doorPrice . "')  ";

  439.             writeLog("insert extra info: " . $sqlInsert);

  440.             $result = $send_pdo->exec($sqlInsert);

  441.         }

  442.     }

  443. 

  444.     //创建订单

  445.     public function create_order($sql, $price_list, $pdo)

  446.     {

  447.         if (is_object($pdo)) {

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

  449. 

  450.             if (!$result) {

  451.                 return false;

  452.             }

  453.             // echo json_encode(array('aa'=>$sql));die;

  454.             $rowset_create = $result->fetchAll(PDO::FETCH_ASSOC);

  455.             $result->closeCursor();

  456.             writeLog('下订单成功');

  457.             writeLog(json_encode($rowset_create));

  458. 

  459.             if (is_array($rowset_create) && $rowset_create[0]['errcode'] == 0 && SEND_MESSAGE == true) {

  460.                 //下订单成功再修改价格

  461.                 writeLog('change_price.php' . json_encode($_POST));

  462. 

  463.                 $sql_up_price = "call SP_CHANGE_PRICE(" . $rowset_create[0]['order_id'] . ",'" . $price_list . "')";

  464.                 //$sql="update order_main set order_price ='".$price_arr[$k]."' where PROD_ID=".$v." and PARENT_ORDER_ID=".$ordid." and RUN_ID>0";

  465.                 $result_up_price = $pdo->query($sql_up_price);

  466.                 $rowset_up_price = $result_up_price->fetchAll(PDO::FETCH_ASSOC);

  467.                 writeLog("change_price.php sql:: " . $sql_up_price . "::rowset ::" . json_encode($rowset_up_price));

  468.                 $result_up_price->closeCursor();

  469.             }

  470.         }

  471.         return $rowset_create;

  472.     }

  473. 

  474.     //获取订单详情

  475.     public function get_order_info($order_id, $pdo)

  476.     {

  477.         //根据订单号查找订单详情

  478.         $sql = "SELECT

  479.                     a.order_id,

  480.                     a.create_time,

  481.                     a.order_price,

  482.                     a.order_pay_main_id,

  483.                     a.customer_name,

  484.                     a.customer_mobile,

  485.                     count(b.order_id) AS num,

  486.                     b.PROD_START_STATION_DATE AS run_date,

  487.                     b.PROD_START_STATION_TIME AS run_time,

  488.                     b.PROD_START_STATION_AREA_NAME AS start_area,

  489.                     b.PROD_END_STATION_AREA_NAME AS end_area,

  490.                     b.PROD_START_STATION_RES_NAME AS start_res,

  491.                     b.PROD_END_STATION_RES_NAME AS end_res

  492.                 FROM

  493.                     order_main a,

  494.                     order_main b

  495.                 WHERE

  496.                     a.order_id = b.PARENT_ORDER_ID

  497.                 AND a.order_id = " . $order_id . "

  498.                 GROUP BY

  499.                     a.order_id";

  500. 

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

  502.         $order_info = $result->fetchAll(PDO::FETCH_ASSOC);

  503. 

  504.         return $order_info;

  505.     }

  506. 

  507.     //修改订单详情

  508.     public function update_order_info($order_id, $run_id, $bus_no, $member_id, $pay_main_id, $pdo)

  509.     {

  510.         $sql_pay = "UPDATE order_pay_detail

  511.                     SET pay_type_id_1 = 278

  512.                     WHERE

  513.                         pay_main_id = " . $pay_main_id;

  514. 

  515.         $sql_cancel = "UPDATE order_main

  516.                         SET ORDER_BOOK_STATUS = 1,

  517.                             member_id = " . $member_id . "

  518.                         WHERE

  519.                             order_id = " . $order_id . "

  520.                         OR parent_order_id = " . $order_id;

  521. 

  522.         $sql_check = "INSERT into order_check_tickets(order_id,run_id,bus_no,check_status,check_time,check_station)

  523.                          VALUES(" . $order_id . "," . $run_id . "," . $bus_no . ",1,'" . date("Y-m-d H:i:s", time()) . "',0)";

  524. 

  525.         $result = $pdo->exec($sql_cancel);

  526.         $result = $pdo->exec($sql_pay);

  527.         $result = $pdo->exec($sql_check);

  528.     }

  529. }

  530. 

  531. $prod_list = isset($_POST['prod_list']) ? $_POST['prod_list'] : '';//购票信息

  532. $customer_info = isset($_POST['customer_info']) ? $_POST['customer_info'] : '';//乘客信息

  533. $start_id = isset($_POST['start_id']) ? $_POST['start_id'] : '';//起点站点id

  534. $end_id = isset($_POST['end_id']) ? $_POST['end_id'] : '';//终点站点id

  535. $line_id = isset($_POST['line_id']) ? $_POST['line_id'] : '';;//线路ID

  536. 

  537. $start_time = isset($_POST['start_time']) ? $_POST['start_time'] : '';//开始时间

  538. $end_time = isset($_POST['end_time']) ? $_POST['end_time'] : '';//结束时间

  539. //判断是否有时间

  540. 

  541. if (empty($start_time) || empty($end_time)) {

  542.     echo json_encode(array('code' => '1', 'info' => '开始和结束时间均不能为空'));

  543.     exit();

  544. }

  545. //if($start_time <  date('Y-m-d H:i',time()+3600)){

  546. //    echo json_encode(array('code' => '1', 'info' => '发车前停止售票'));

  547. //    exit();

  548. //}

  549. 

  550. $submit = new submit();

  551. $res = $submit->execSubmit($prod_list, $customer_info, $start_id, $end_id, $line_id, $start_time, $end_time, $pdo, $array_line_info);

  552. 

  553. ?>