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

269 lines
12 KiB
Raw Permalink Blame History 

  1. <?php

  2. /*

  3.  Author:fuhc

  4.  Compeny:Spiders Travel

  5.  */

  6. require_once '../Common/Mysql.php';

  7. if (ALLOW_ORIGIN)

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

  9. 

  10. $method = isset($_GET['method']) ? $_GET['method'] : "";

  11. $user_id = getUserId();

  12. //if ($user_id == false) {

  13. //	echo json_encode(array("code" => "1", "info" => "用户未登录"));

  14. //	exit ;

  15. //}

  16. $user_id=1;

  17. //取消订单原因

  18. if(isset($_GET['reason'])){

  19.     $reason=$_GET['reason'];

  20.     $order_id=$_GET['order_id'];

  21.     $clock=$_GET['clock'];

  22. //    $return_data = array();

  23. //    $return_data["code"] = 1;

  24. //    $return_data["info"] = $reason;

  25.     $pdo_insert = conn1();

  26.     $sql = "insert into order_comment(ORDER_ID,COMMENT_TXT,CREATE_TIME) VALUES ({$order_id},'{$reason}','{$clock}')";

  27.     $result = $pdo_insert->exec($sql);

  28. }

  29. 

  30. if ($method == "cancelOrder") {

  31.     $order_id = isset($_GET['order_id']) ? $_GET['order_id'] : "";

  32.     $pdo = conn1();

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

  34.     writeLog('cancelOrder=   sql='.$sql);

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

  36.     if($result){

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

  38.         $data['code']=isset($rowset[0]['errorcode'])?$rowset[0]['errorcode']:"499";

  39.         $data['info']=isset($rowset[0]['errorinfo'])?$rowset[0]['errorinfo']:"未从数据库中获得返回值";

  40. //		echo json_encode($data);exit();

  41.     }else{

  42.         $data['code']="500";

  43.         $data['info']="数据库错误";

  44.         echo json_encode($data);exit();

  45.     }

  46. 

  47. 

  48.     $result -> closeCursor();

  49. 

  50.     if (is_array($rowset) && $rowset['code'] == 0 && SEND_MESSAGE == true) {

  51.         $res_content = get_msg_info($order_id);

  52.         $name = isset($res_content[0])?$res_content[0]:"";

  53.         $tel = isset($res_content[1])?$res_content[1]:"";

  54.         $content = isset($res_content[2])?$res_content[2]:"";

  55.         //			$content = "单号：" . $order_id . '，订单状态变更为' . $order_status . "随机数" . rand(1, 10000);

  56.         writeLog("巴士取消短信模板内容：【" . $content . "】");

  57. 

  58.         //..取消发短信

  59.         $response=null;

  60.         $send_success="-100";

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

  62. //			writeLog(json_encode($response));

  63. //		    $send_success = (int)$response;

  64.         $comment_type=0;

  65.         $comment_text="";

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

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

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

  69.         $result1 -> closeCursor();

  70.         writeLog("order_list.php HT_ADD_MSG_COMMENT()::" . $sql1);

  71.     }

  72.     echo json_encode($data);

  73. }else if($method=="getOrderORG"){

  74.     $pdo=conn1();

  75.     $sql="SELECT ORG_ID AS org_id ,ORG_NAME as soure FROM base_organization where cancel_flag=0;";

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

  77. 

  78.     $rowset=array("code"=>"0","info"=>"");

  79.     $rowset['order_ORG_List']=$result->fetchAll(PDO::FETCH_ASSOC);

  80.     $result->closeCursor();

  81.     echo json_encode($rowset);exit();

  82. }

  83. else {

  84.     $timelimit = isset($_GET['timelimit']) ? $_GET['timelimit'] : '';

  85.     $starttime = isset($_GET['starttime']) ? $_GET['starttime'] : '';

  86.     $endtime = isset($_GET['endtime']) ? $_GET['endtime'] : '';

  87.     $ordersource = isset($_GET['ordersource']) ? (empty($_GET['ordersource']) ? 0 : $_GET['ordersource']) : 0;

  88.     $orderstatus = isset($_GET['orderstatus']) ? (empty($_GET['orderstatus']) ? 0 : $_GET['orderstatus']) : 0;

  89.     $paystatus = isset($_GET['paystatus']) ? (empty($_GET['paystatus']) ? -1 : $_GET['paystatus']) : -1;

  90.     $billingstatus = isset($_GET['billingstatus']) ? $_GET['billingstatus'] : '';

  91.     $mealbounce = isset($_GET['mealbounce']) ? $_GET['mealbounce'] : '';

  92.     $refund = isset($_GET['refund']) ? $_GET['refund'] : '';

  93.     $moresearch = isset($_GET['moresearch']) ? trim($_GET['moresearch']) : '';

  94.     $export = isset($_GET['export']) ? $_GET['export'] : '';

  95. 

  96.     //2016-07-15新增

  97.     $start_area=isset($_GET['start_area']) ? $_GET['start_area'] : '';

  98.     $end_area=isset($_GET['end_area']) ? $_GET['end_area'] : '';

  99.     $line=isset($_GET['line']) ? $_GET['line'] : '';

  100.     //..暂未加入存储过程

  101. 

  102.     $currpage = isset($_GET['currpage']) ? (empty($_GET['currpage']) ? 1 : $_GET['currpage']) : 1;

  103.     $pagesize = isset($_GET['pagesize']) ? (empty($_GET['pagesize']) ? 10 : $_GET['pagesize']) : 10;

  104.     $pdo = conn1();

  105.     $sql = "CALL XM_ORDER_GET_LIST_nj(".$user_id.",'" . $timelimit . "','" . $starttime . "','" . $endtime . "'," . $ordersource . "," . $orderstatus . "," . $paystatus . ",'" . $billingstatus . "','" . $mealbounce . "','" . $refund . "','" . $moresearch . "','" . $export . "'," . $currpage . "," . $pagesize . ",'".$line."','".$start_area."','".$end_area."')";

  106. //	writeLog('order_list.php -- sql==   '.$sql);

  107. 

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

  109.     $data = array();

  110.     do {

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

  112.         if ($rowset) {

  113.             $data[] = $rowset;

  114.         }

  115.     } while ($result->nextRowset());

  116.     $count = count($data);

  117. 

  118.     //		print_r(json_encode($data[3]));exit();

  119.     if ($count == 1 && isset($data[0][0]['code']) && $data[0][0]['code'] != 0) {

  120.         echo json_encode($data[0][0]);

  121.     } else if ($count == 4) {

  122. //	} else if ($count > 0) {

  123.         $data1 = array();

  124.         $data2 = array();

  125.         $data3 = array();

  126. 

  127.         $order_id_array = array();

  128.         $data1=isset($data[1])?$data[1]:array();

  129. 

  130.         foreach($data[1] as $k => $v){

  131.             $order_id_array[]=$v['parent_orderNo'];

  132.         }

  133.         $pdo2 = conn1();

  134.         $search_extra_sql = " SELECT * FROM order_extra_info WHERE order_id IN (".implode(",",$order_id_array).") ";

  135.         $result2 = $pdo2->query($search_extra_sql);

  136.         $order_extra_array = $result2->fetchAll();

  137.         if( $order_extra_array != false && count($order_extra_array) > 0  ) {

  138.             $order_extra_array2 = array();

  139.             foreach ( $order_extra_array as $order_extra_info ) {

  140.                 $order_extra_array2[$order_extra_info["order_id"]] = $order_extra_info;

  141.             }

  142.             $order_extra_array = $order_extra_array2;

  143.         }

  144.         $data1_temp = array();

  145.         foreach( $data1 as $k=>$data1_info ) {

  146.             if( isset($order_extra_array[$data1_info["M_ID"]]) ) {

  147.                 $data1_info["hotel_price"] = $order_extra_array[$data1_info["M_ID"]]["hotel_price"];

  148.                 $data1_info["gate_price"] = $order_extra_array[$data1_info["M_ID"]]["gate_price"];

  149.                 $extra_info_array = array();

  150.                 if( isset($data1_info["hotel_price"]) && mb_strlen($data1_info["hotel_price"]) > 0 ) {

  151.                     $extra_info_array[] ="酒店：".$data1_info["hotel_price"];

  152.                 }

  153.                 if( isset($data1_info["gate_price"]) && mb_strlen($data1_info["gate_price"]) > 0 ) {

  154.                     $extra_info_array[] ="门票：".$data1_info["gate_price"];

  155.                 }

  156.                 $data1_info["seat"] .= "[br /]".implode(" ", $extra_info_array);

  157.             }

  158.             $data1_temp[] = $data1_info;

  159. 

  160.         }

  161.         $data1 = $data1_temp;

  162.         //				echo json_encode($data[1]);exit();

  163.         $json = array("code" => "0", "info" => "");

  164.         $json['totalTickets'] = $data[2][0]['num'];

  165.         $json['totalPages'] = $data[2][0]['pagecount'];

  166.         $json['currentpage'] = isset($data[2][0]['CURRENTPAGE']) ? $data[2][0]['CURRENTPAGE'] : "1";

  167.         $json['pagesize'] = $data[2][0]['PAGESIZE'];

  168.         $json['orderSource'] = $data[0];

  169.         $json['orderList'] = array_values($data1);

  170.         $or_st = array();

  171.         $or_st['status_all'] = $data[2][0]['num'];

  172.         foreach ($data[3] as $da) {

  173.             $or_st[$da['order_status']] = $da['order_cnt'];

  174.         }

  175.         $json['orderStatus'][] = $or_st;

  176.         //		$json['orderStatus'][$data[3]['order_status']]=

  177.         //		$row_count_array = array();

  178.         //		foreach ($data[1] as $k => $v) {

  179.         //			if (!isset($row_count_array[$v["order_status"]])) {

  180.         //				$row_count_array[$v["order_status"]] = 0;

  181.         //			}

  182.         //			$row_count_array[$v["order_status"]]++;

  183.         //		}

  184.         //		$sum = (string)count($data[1]);

  185.         //		if ($sum == "0") {

  186.         //			$sum = "";

  187.         //		}

  188.         //		$row_count_array['status_all'] = $data[2][0]['num'];

  189.         //		if (count($row_count_array) > 0) {

  190.         //			$json['orderStatus'][] = $row_count_array;

  191.         //		} else {

  192.         //			$json['orderStatus'][] = array();

  193.         //		}

  194. 

  195.         //echo json_encode($data1);

  196.         echo json_encode($json);

  197.     } else {

  198.         echo json_encode(array("code" => "0", "info" => "", "searchInfo" => array()));

  199.     }

  200. }

  201. 

  202. function get_msg_info($ORDER_ID) {

  203.     $msg_pdo = conn1();

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

  205.     $content = '';

  206.     if (is_object($msg_pdo)) {

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

  208.         $i = 1;

  209.         $data = array();

  210.         if ($msg_result) {

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

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

  213.             do {

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

  215.                 if ($i == 1) {

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

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

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

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

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

  221.                 } else {

  222.                 }

  223.                 $i++;

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

  225.         }

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

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

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

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

  230.         //取消

  231.         $content = "您预订的{出发日期　出发时间}{出发地}-{目的地}{票种名}{张数}张，已成功退票，期待下次再为您服务！";

  232.         if ($seat) {

  233.             $seat_x = $seat['seat_x'];

  234.             $seat_y = $seat['seat_y'];

  235.             $seat_name = $seat['seat_name'];

  236.             $order_main_id = $seat['order_main_id'];

  237.         }

  238.         if ($run_info) {

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

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

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

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

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

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

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

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

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

  248.             $prod_name="标准票";

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

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

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

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

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

  254.             $content = str_replace("{出发日期　出发时间}", $start_end_date, $content);

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

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

  257.         }

  258.         if ($driver) {

  259.             $bus_no = $driver['bus_no'];

  260.             $driver_name = $driver['driver_name'];

  261.             $driver_mobile = $driver['driver_mobile'];

  262.         }

  263.         return array(isset($customer_name)?$customer_name:"", isset($customer_mobile)?$customer_mobile:"", isset($content)?$content:"短信错误!!!");

  264.     }

  265. 

  266. }

  267. 

  268. exit();