diff --git a/application/third_party/trainsystem/models/train_system_model.php b/application/third_party/trainsystem/models/train_system_model.php index c426969b..b6e5be91 100644 --- a/application/third_party/trainsystem/models/train_system_model.php +++ b/application/third_party/trainsystem/models/train_system_model.php @@ -193,6 +193,60 @@ class train_system_model extends CI_Model { "; $query =$this->INFO->query($sql,array($data->realname,$data->realname,$data->realname)); } + + //新增乘客,可以兼容带单引号的乘客名称。但是可能会影响汉特 + function add_passagers2($data){ + // 先检查是否存在 + $check_sql = "SELECT COUNT(*) as count FROM trainsystem_tickets + WHERE tst_ordernumber = ? + AND tst_numberid = ? + AND tst_realname = ?"; + + $check_params = array($data->ordernumber, $data->numberid, $data->realname); + $check_result = $this->INFO->query($check_sql, $check_params); + + if ($check_result && $check_result[0]['count'] > 0) { + // 更新 + $update_sql = "UPDATE trainsystem_tickets + SET tst_identitytype = ?, + tst_ticketype = ?, + tst_ticketprice = ?, + tst_seatstype = ?, + tst_seatdetail = ?, + tst_status = ?, + tst_LongTrainNo = ?, + tst_lanhaiData = ? + WHERE tst_ordernumber = ? + AND tst_numberid = ? + AND tst_realname = ?"; + + $update_params = array( + $data->identitytype, $data->ticketype, $data->ticketprice, + $data->seatype, $data->seatdetail, $data->status, + $data->longtrainno, $data->lanhaiData, + $data->ordernumber, $data->numberid, $data->realname + ); + + return $this->INFO->query($update_sql, $update_params); + } else { + // 插入 + $insert_sql = "INSERT INTO trainsystem_tickets ( + tst_ordernumber, tst_status, tst_realname, + tst_identitytype, tst_numberid, tst_ticketype, + tst_ticketprice, tst_seatstype, tst_seatdetail, + tst_LongTrainNo, tst_lanhaiData + ) VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)"; + + $insert_params = array( + $data->ordernumber, $data->status, $data->realname, + $data->identitytype, $data->numberid, $data->ticketype, + $data->ticketprice, $data->seatype, $data->seatdetail, + $data->longtrainno, $data->lanhaiData + ); + + return $this->INFO->query($insert_sql, $insert_params); + } + } //更新订单信息 public function update_orders($data){