nizongfeng
/
ZZCS
1
0
Vork 0
Code Kwesties 0 Pull-aanvragen 0 Publicaties 0 Wiki Activiteit
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 Labels
${ item.name }
Maak branch ${ searchTerm }
van 'master'
${ noResults }
ZZCS/coding/st-xm/Api/update_car_no.php

381 regels
15 KiB
Ruw Permalink Blame Geschiedenis 

  1. 

  2. <?php

  3. /*

  4.  Author:fuhc

  5.  Compeny:修改车号

  6.  */

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

  8. if (ALLOW_ORIGIN)

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

  10. 

  11. $user_id=getUserId();

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

  13. 	$data['code']="-3";

  14. 	$data['info']="未登录";

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

  16. }

  17. //$user_id=1;

  18. 

  19. 

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

  21. if($method==""){

  22. 	$data['code']="-2";

  23. 	$data['info']="缺少method";

  24. 	echo json_encode($data);

  25. 	exit();

  26. }

  27. 

  28. 

  29. $pdo=conn();

  30. switch($method){

  31. 	case "getStations":

  32. 		$run_id=isset($_GET['run_id'])?$_GET['run_id']:"";

  33. 		if($run_id==""){

  34. 			$data['code']="-1";

  35. 			$data['info']="缺少参数";

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

  37. 		}

  38. 		//这里加一个对该班次时间的判断，只有在发车前一天的18：30之前才可以修改订单车次

  39.         $run_id=$run_id+0;

  40.         $sql_c="select concat(substring(run_date,1,4),substring(run_date,6,2))  as x_name,run_id,run_date from run_main where run_id=$run_id limit 1;";

  41.         $check=$pdo->query($sql_c);

  42.         $res1=$check->fetch(PDO::FETCH_ASSOC);

  43.         $check->closeCursor();

  44.         $run_date=$res1['run_date'];

  45.         $now=time();

  46.         $yesStamp=strtotime('-1 day',strtotime("$run_date 18:30:00"));//得到run_date前一天18：30的时间戳

  47.         $diffTime=$now-$yesStamp;

  48. 

  49. 		/*

  50.         if($diffTime>=0){

  51.             $data['code']="666";

  52.             $data['info']="只能在班次发车日期前一天18：30之前重置车次订单！";

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

  54.         }

  55. 		*/

  56. 

  57. //		$sql="CALL XM_GET_STATION_BY_RUNID('".$run_id."');";

  58. //		writeLog("getStations  sql=".$sql);

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

  60. //		$data=array();

  61. //		$data['code']="0";

  62. //		$data['info']="";

  63. //		$re_data=array();

  64. //		do{

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

  66. //			$re_data[]=$rowset;

  67. //		}while($result->nextRowset());

  68. //		$data['start_station']=isset($re_data[0])?$re_data[0]:array();

  69. //		$data['end_station']=isset($re_data[1])?$re_data[1]:array();

  70. //      $result->closeCursor();

  71. 

  72. 		$sql_start = "select  t2.RES_NAME as start_station,t1.STATION_RES_ID as start_station_id

  73.                       from  run_station t1

  74.                       left join  base_resource t2 on t1.station_res_id = t2.res_id

  75.                       where  t1.run_id = {$run_id} and t1.STATION_INOUT_TYPE in (108,109)";

  76. 

  77. 		$sql_end = "select  t2.RES_NAME as end_station,t1.STATION_RES_ID as end_station_id

  78.                       from  run_station t1

  79.                       left join  base_resource t2 on t1.station_res_id = t2.res_id

  80.                       where  t1.run_id = {$run_id} and t1.STATION_INOUT_TYPE in (110)";

  81. 

  82. 		$data=array();

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

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

  85. 		$data['start_station']=array();

  86. 		$data['end_station']=array();

  87. 		$start_result = $pdo->query($sql_start);

  88. 		if( false != $start_result ) {

  89. 			$res_start = $start_result->fetchAll(PDO::FETCH_ASSOC);

  90. 			$start_result->closeCursor();

  91. 			$data['start_station']= $res_start == false ? array() : $res_start;

  92. 		}

  93. 		$end_result = $pdo->query($sql_end);

  94. 		if( false != $end_result ) {

  95. 			$res_end = $end_result->fetchAll(PDO::FETCH_ASSOC);

  96. 			$end_result->closeCursor();

  97. 			$data['end_station']= $res_end == false ? array() : $res_end;

  98. 		}

  99. 

  100. 

  101. 		echo json_encode($data);

  102. 		exit();

  103. 		break;

  104. 	case "getOrderList":

  105. 		$run_id=isset($_GET['run_id'])?$_GET['run_id']:"";

  106. 		$start_station_id=isset($_GET['start_station_id'])?$_GET['start_station_id']:"";

  107. 		$end_station_id=isset($_GET['end_station_id'])?$_GET['end_station_id']:"";

  108. 		if($run_id==""){

  109. 			$data['code']="-1";

  110. 			$data['info']="缺少参数";

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

  112. 		}

  113. //		$sql="CALL GET_ORDERLIST_FOR_SETBUS('".$run_id."','".$start_station_id."','".$end_station_id."');";

  114. //		writeLog('getOrderList  sql='.$sql);

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

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

  117. 

  118. 		$sql = " SELECT parent_order_id,create_time,order_description,outside_sale_org_id,outside_order_no,prod_name, parent_prod_name,count(order_id) as passenger_num,

  119.                         run_date,run_time,run_bus_order_id,order_status,prod_start_station_res_name as start_station,prod_end_station_res_name as end_station,

  120.                         customer_name,customer_mobile

  121.                  FROM order_main 

  122.                  WHERE run_id={$run_id} AND cancel_flag=0 AND order_status <> 148 AND order_prod_type IN (81,82) AND parent_order_id > 0 and agent_level=1 GROUP BY parent_order_id ORDER BY run_bus_order_id ";

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

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

  125. 		if( false != $rowset && count($rowset) > 0 ) {

  126. 			$all_supplier_array = get_memcache("ARY_ALL_SUPPLIER");

  127. 			$rowset_tmp = array();

  128. 			foreach( $rowset as $order_info ) {

  129. 				if( isset($all_supplier_array[$order_info["org_id"]]) ) {

  130. 					$order_info["org_name"] = $all_supplier_array[$order_info["outside_sale_org_id"]]["supplier_name"];

  131. 				} else {

  132. 					$order_info["org_name"] = "";

  133. 				}

  134. 				$order_info["travel_time"] = $order_info["run_date"]." ".$order_info["run_time"];

  135. 				$rowset_tmp[] = $order_info;

  136. 			}

  137. 			$rowset = $rowset_tmp;

  138. 		}

  139. 

  140. 		$data=array();

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

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

  143. 		$data['orderList']=isset($rowset)?$rowset:array();

  144. 		$result->closeCursor();

  145. 		echo json_encode($data);

  146. 		exit();

  147. 		break;

  148. 	case "getCarList":

  149. 		$run_id=isset($_GET['run_id'])?$_GET['run_id']:"";

  150. 		if($run_id==""){

  151. 			$data['code']="-1";

  152. 			$data['info']="缺少参数";

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

  154. 		}

  155. 		$sql="CALL SP_GET_RUN_BUS(".$run_id.");";

  156. 		writeLog('carList sql='.$sql);

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

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

  159. 		$result->closeCursor();

  160. 		$data=array();

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

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

  163. 		$data['carList']=isset($rowset)?$rowset:array();

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

  165. 		break;

  166. 	case "reset":

  167. 		$run_id=isset($_GET['run_id'])?$_GET['run_id']:"";

  168. 		$order_ids=isset($_GET['order_ids'])?$_GET['order_ids']:"";

  169. 		

  170. 		if($run_id=="" || $order_ids==""){

  171. 			$data['code']="-1";

  172. 			$data['info']="缺少参数";

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

  174. 		}

  175. 		//对重置做一个判断，班次只有在发车前一天的18：30之前才可以重置订单车次

  176.         $run_id=$run_id+0;

  177.         $sql_c="select concat(substring(run_date,1,4),substring(run_date,6,2))  as x_name,run_id,run_date from run_main where run_id=$run_id limit 1;";

  178.         $check=$pdo->query($sql_c);

  179.         $res1=$check->fetch(PDO::FETCH_ASSOC);

  180.         $check->closeCursor();

  181.         $run_date=$res1['run_date'];

  182.         $now=time();

  183.         $yesStamp=strtotime('-1 day',strtotime("$run_date 18:30:00"));//得到run_date前一天18：30的时间戳

  184.         $diffTime=$now-$yesStamp;

  185. 		/*

  186.         if($diffTime>=0){

  187.             $data['code']="-2";

  188.             $data['info']="只能在班次发车日期前一天18：30之前重置车次订单！";

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

  190.         }

  191. 		*/

  192. 

  193. 		$sql="CALL SP_RESET_BUS_FOR_ORDER(".$run_id.",'".$order_ids."');";

  194. 		writeLog('reset sql='.$sql);

  195. 		writelog_update_car(' reset::::user_id='.$user_id."|run_id=".$run_id."|order_ids=".$order_ids);

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

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

  198. 		$result->closeCursor();

  199. 		$data=array();

  200. 		writeLog(json_encode($rowset));

  201. 		writelog_update_car(json_encode($rowset));

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

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

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

  205. 		break;

  206. 	case "updateCar":

  207. 		$run_id=isset($_GET['run_id'])?$_GET['run_id']:"";

  208. 		$order_ids=isset($_GET['order_ids'])?$_GET['order_ids']:"";

  209. 		$bus_order_id=isset($_GET['bus_order_id'])?$_GET['bus_order_id']:"";

  210. 		if($run_id=="" || $order_ids=="" || $bus_order_id==""){

  211. 			$data['code']="-1";

  212. 			$data['info']="缺少参数";

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

  214. 		}

  215. 		$sql="CALL SP_REASSIGN_BUS_FOR_ORDER(".$run_id.",'".$order_ids."',".$bus_order_id.");";

  216. 		$sql_set="CALL SP_RESET_BUS_FOR_ORDER(".$run_id.",'".$order_ids."');";

  217. 

  218.         //这里增加两个校验：1，班次只有在发车前一天的18：30之前才可以修改订单车次；2，只有在该车次的run_x数据全被重置的情况下才允许修改订单的车次。

  219.         #1，班次只有在发车前一天的18：30之前才可以修改订单车次

  220.         $run_id=$run_id+0;

  221.         $sql_c="select concat(substring(run_date,1,4),substring(run_date,6,2))  as x_name,run_id,run_date from run_main where run_id=$run_id limit 1;";

  222.         $check=$pdo->query($sql_c);

  223.         $res1=$check->fetch(PDO::FETCH_ASSOC);

  224.         $check->closeCursor();

  225.         $run_date=$res1['run_date'];

  226.         $now=time();

  227.         $yesStamp=strtotime('-1 day',strtotime("$run_date 18:30:00"));//得到run_date前一天18：30的时间戳

  228.         $diffTime=$now-$yesStamp;

  229. 		/*

  230.         if($diffTime>=0){

  231.             $data['code']="-2";

  232.             $data['info']="只能在班次发车日期前一天18：30之前修改车次订单！";

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

  234.         }

  235. 		*/

  236. 

  237.         #2，只有在该车次的run_x数据全被重置的情况下才允许修改订单的车次。

  238.         $x_name='run_'.$res1['x_name'];

  239.         $sql_c2="select * from $x_name where run_id=$run_id and bus_order_id=$bus_order_id and cancel_flag=0 and seat_type=72 and seat_status=2 limit 1";

  240.         $check2=$pdo->query($sql_c2);

  241.         $res2=$check2->fetch(PDO::FETCH_ASSOC);

  242.         $check2->closeCursor();

  243. 

  244.         if($res2){

  245.             $data['code']="-3";

  246.             $data['info']="目标车次全部订单重置后才可修改订单车次";

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

  248.         }

  249. 

  250. 

  251. 		writeLog('reset sql='.$sql);

  252. 		writelog_update_car(' reset::::user_id='.$user_id."|run_id=".$run_id."|order_ids=".$order_ids);

  253. 		$result2=$pdo->query($sql_set);

  254. 		$rowset2=$result2->fetchAll(PDO::FETCH_ASSOC);

  255. 		$result2->closeCursor();

  256. 		writeLog(json_encode($rowset2));

  257. 		writelog_update_car(json_encode($rowset2));

  258. 		if($rowset2[0]['errorcode']=="0"){

  259. 			writeLog('updateCar sql='.$sql);

  260. 			writelog_update_car('update::::user_id='.$user_id."|run_id=".$run_id."|order_ids=".$order_ids."|bus_order_id=".$bus_order_id);

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

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

  263. 			$result->closeCursor();

  264. 			writeLog(json_encode($rowset));

  265. 			writelog_update_car(json_encode($rowset));

  266. 			$data=array();

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

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

  269. 

  270. 			//update connect orders' info

  271. 			$sql_connect_order = " SELECT order_id,parent_order_id,sale_path,run_bus_order_id,run_bus_seat_seq_id,run_bus_seat_name FROM order_main WHERE ( order_id IN ({$order_ids}) OR parent_order_id IN ({$order_ids}))  and sale_path <> '' and cancel_flag=0 and order_status <> 148 ORDER BY order_id ";

  272. 			writelog_update_car("update_car_no extra_sql:".$sql_connect_order);

  273. 			$pdo_connect = conn();

  274. 			$result2_connect = $pdo_connect->query($sql_connect_order);

  275. 			if( false != $result2_connect ) {

  276. 				$order_array=$result2_connect->fetchAll(PDO::FETCH_ASSOC);

  277. 				$result2_connect->closeCursor();

  278. 				if( false != $order_array && count($order_array) > 0 ) {

  279. 					$order_detail_array = array();

  280. 					$connect_order_id = array();

  281. 					$order_reflect_array = array();

  282. 					//收集新车号，座位号，座位名

  283. 					foreach( $order_array as $order_detail_info ) {

  284. 						$order_id = $order_detail_info["order_id"];

  285. 						$parent_order_id = $order_detail_info["parent_order_id"];

  286. 						if( $parent_order_id == 0 ) {

  287. 							if( !isset($order_detail_array[$order_id]) ) {

  288. 								$order_detail_array[$order_id] = array();

  289. //								$order_detail_array[$order_id]["bus_order_id"] = $order_detail_info["run_bus_order_id"];

  290. 								$order_detail_array[$order_id]["seat_id"] = array();

  291. 								$order_detail_array[$order_id]["seat_name"] = array();

  292. 							}

  293. 							$sale_path_id = explode( ",", $order_detail_info["sale_path"] );

  294. 							foreach( $sale_path_id as $order_id_tmp ) {

  295. 								$order_reflect_array[$order_id_tmp] = $order_id;

  296. 							}

  297. 							$connect_order_id = array_merge( $connect_order_id, $sale_path_id);

  298. 						} else {

  299. 							if( !isset($order_detail_array[$parent_order_id]) ) {

  300. 								$order_detail_array[$parent_order_id] = array();

  301. 								$order_detail_array[$parent_order_id]["bus_order_id"] = $order_detail_info["run_bus_order_id"];

  302. 								$order_detail_array[$parent_order_id]["seat_no"] = array();

  303. 							}

  304. 							$order_detail_array[$parent_order_id]["bus_order_id"] = $order_detail_info["run_bus_order_id"];

  305. 							$order_detail_array[$parent_order_id]["seat_id"][] = $order_detail_info["run_bus_seat_seq_id"];

  306. 							$order_detail_array[$parent_order_id]["seat_name"][] = $order_detail_info["run_bus_seat_name"];

  307. 						}

  308. 					}

  309. 					//查找所有需要

  310. 					$search_order_ids = implode( ",",  $connect_order_id );

  311. 					$sql_connect_order = " SELECT order_id,parent_order_id,sale_path,run_bus_order_id,run_bus_seat_seq_id,run_bus_seat_name FROM order_main WHERE ( order_id IN ({$search_order_ids}) OR parent_order_id IN ({$search_order_ids}) )  and sale_path <> '' and agent_level > 1 and cancel_flag=0 and order_status <> 148 ORDER BY id ASC ";

  312. 					writelog_update_car("update_car_no extra_sql2:".$sql_connect_order);

  313. 					$result2_connect = $pdo_connect->query($sql_connect_order);

  314. 					if( $result2_connect == false ) {

  315. 						break;

  316. 					}

  317. 					$order_connect_array=$result2_connect->fetchAll(PDO::FETCH_ASSOC);

  318. 					$result2_connect->closeCursor();

  319. 					if( $order_connect_array == false ) {

  320. 						break;

  321. 					}

  322. 					//遍历：目的1 查找相关子记录并修改座位信息 2修改车号

  323. 					$excute_sql_array = array();

  324. 					$sub_order_count_array = array();

  325. 					foreach( $order_connect_array as $order_info_temp ) {

  326. 						$order_id = $order_info_temp["order_id"];

  327. 						$parent_order_id = $order_info_temp["parent_order_id"];

  328. 						$reflect_order_id = $parent_order_id == 0 ? $order_reflect_array[$order_id] : $order_reflect_array[$parent_order_id];

  329. 						$order_detail_info2 = $order_detail_array[$reflect_order_id];

  330. 						if( $parent_order_id == 0 ) {

  331. //							$sql = " UPDATE order_main SET run_bus_order_id={$order_detail_info2["bus_order_id"]} WHERE parent_order_id = {$order_id}  ";

  332. //							$excute_sql_array[] = $sql;

  333. 						} else {

  334. 							if( !isset($sub_order_count_array[$parent_order_id]) ) {

  335. 								$sub_order_count_array[$parent_order_id] = 0;

  336. 							}

  337. 							$sub_order_index = $sub_order_count_array[$parent_order_id];

  338. 							$sub_order_count_array[$parent_order_id]++;

  339. 							$seat_id = $order_detail_info2["seat_id"][$sub_order_index];

  340. 							$seat_name = $order_detail_info2["seat_name"][$sub_order_index];

  341. 							$sql = " UPDATE order_main SET run_bus_order_id={$order_detail_info2["bus_order_id"]}, run_bus_seat_seq_id={$seat_id},run_bus_seat_name='{$seat_name}' WHERE order_id = {$order_id} ";

  342. 							$excute_sql_array[] = $sql;

  343. 						}

  344. 					}

  345. 					//执行SQL语句

  346. 					foreach( $excute_sql_array as $excute_sql_tmp ) {

  347. 						writelog_update_car("excute sql:".$excute_sql_tmp);

  348. 						$pdo_exe = conn();

  349. 						$pdo_exe->exec( $excute_sql_tmp );

  350. 					}

  351. 				}

  352. 			}

  353. 			//end of update connect orders' info

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

  355. 		}

  356. 

  357. 		break;

  358. 	default :

  359. 		break;

  360. 	

  361. }

  362. function writelog_update_car($log){

  363. 	$dir=__DIR__."/../Log/";

  364. 	if (!is_dir($dir)){

  365. 		mkdir($dir);

  366. 	}

  367. 	$filename=$dir.date("Y-m-d").".logtemp";

  368. 	file_put_contents($filename, date("Y-m-d H:i:s")."\t".$log.PHP_EOL,FILE_APPEND);

  369. }

  370. 

  371. function writelog_connect_log($log) {

  372. 	$dir=__DIR__."/../Log/";

  373. 	if (!is_dir($dir)){

  374. 		mkdir($dir);

  375. 	}

  376. 	$filename=$dir.'connent_'.date("Y-m-d").".log";

  377. 	file_put_contents($filename, date("Y-m-d H:i:s")."\t".$log.PHP_EOL,FILE_APPEND);

  378. }

  379. 

  380. exit();