nizongfeng
/
ZZCX_yii
1
0
Форкнуть 0
Код Задачи 0 Pull Request'ы 0 Релизы 0 Вики Активность
Вы не можете выбрать более 25 тем Темы должны начинаться с буквы или цифры, могут содержать дефисы(-) и должны содержать не более 35 символов.
3 коммитов
1 ветка
96 MiB
 
 
 
 
 
 
ветка: master
Ветки Теги
${ item.name }
Создать ветку ${ searchTerm }
из 'master'
${ noResults }
ZZCX_yii/backend/modules/api/logic/CtripBus.php

502 строки
19 KiB
Исходник Постоянная ссылка Вина История 

  1. <?php

  2. /**

  3.  *

  4.  * ============================================================================

  5.  * * 版权所有 蜘蛛出行 * *

  6.  * 网站地址: http://www.zhizhuchuxing.com

  7.  * ----------------------------------------------------------------------------

  8.  * 这不是一个自由软件！您只能在不用于商业目的的前提下对程序代码进行修改和

  9.  * 使用；不允许对程序代码以任何形式任何目的的再发布。

  10.  * ============================================================================

  11.  * Author By: 倪宗锋

  12.  * PhpStorm CtripBus.php

  13.  * Create By 2018/4/17 9:33 $

  14.  */

  15. 

  16. namespace backend\modules\api\logic;

  17. 

  18. 

  19. use backend\modules\api\models\BaseArea;

  20. use backend\modules\api\models\BaseResource;

  21. use backend\modules\api\models\OperaLine;

  22. use backend\modules\api\models\OperaStation;

  23. use backend\modules\api\models\OperaTickets;

  24. use backend\modules\api\models\OrderCustomerInfo;

  25. use backend\modules\api\models\OrderMain;

  26. use backend\modules\api\models\OutsideSubmitOrder;

  27. use backend\modules\api\models\RunMain;

  28. use backend\modules\api\models\RunProd;

  29. use backend\modules\api\models\RunStation;

  30. use backend\modules\api\util\Util;

  31. use backend\modules\api\models\OperaMessageTemplate;

  32. use backend\modules\api\models\OrderSendMessage;

  33. use common\util\CtripBusUtil;

  34. use common\util\CurlInterface;

  35. 

  36. class CtripBus

  37. {

  38.     /**

  39.      * Function Description:获取出发城市列表

  40.      * Function Name: GetFromCityList

  41.      * @param $params

  42.      * @return array

  43.      * @author 田玲菲

  44.      */

  45.     public function GetFromCityList($params)

  46.     {

  47.         $baseResource = new BaseResource();

  48.         $res = $baseResource->getFromCity();

  49.         $result = [];

  50.         foreach ($res as $val) {

  51.             $result[] = $val['AREA_NAME'];

  52.         }

  53.         return Util::returnArrSu('', ['fromCityList' => array_values($result)]);

  54.     }

  55. 

  56. 

  57.     /**

  58.      * Function Description:获取到达城市列表

  59.      * Function Name: GetToCityList

  60.      * @param $params

  61.      * @return array

  62.      * @author 田玲菲

  63.      */

  64.     public function GetToCityList($params)

  65.     {

  66.         //1. 验证参数

  67.         if (empty($params['fromCity'])) { //出发城市

  68.             return Util::returnArrEr("参数为空【fromCity】", [], '2100');

  69.         }

  70.         $baseArea = new BaseArea();

  71.         $fromCity = $baseArea->getInfoByName($params['fromCity']);

  72.         if (empty($fromCity['ID'])) {

  73.             return Util::returnArrEr("查询出错", [], '2101');

  74.         }

  75.         $fromCityId = $fromCity['ID'];

  76.         //2.获取近期出发的所有线路的上下车城市

  77.         $baseResource = new BaseResource();

  78.         $result = $baseResource->getInOutCity($fromCityId);

  79.         return Util::returnArrSu('', ['toCityList' => $result]);

  80.     }

  81. 

  82.     /**

  83.      * Des:获取线路数据

  84.      * Name: GetLine

  85.      * @param $params

  86.      * @return array

  87.      * @author 倪宗锋

  88.      */

  89.     public function GetLine($params)

  90.     {

  91.         if (empty($params['fromCity'])) {//出发城市

  92.             return Util::returnArrEr("参数为空【fromCity】", [], '1005');

  93.         }

  94.         if (empty($params['fromDate'])) {//出发日期

  95.             return Util::returnArrEr("参数为空【fromDate】", [], '1005');

  96.         }

  97.         if (empty($params['toCity'])) {//到达城市

  98.             return Util::returnArrEr("参数为空【toCity】", [], '1005');

  99.         }

  100.         $fromDate = $params['fromDate'];

  101.         // 1.查询出发城市和到达城市的res_id

  102.         $baseArea = new BaseArea();

  103.         $fromCity = $baseArea->getInfoByName($params['fromCity']);

  104.         if (empty($fromCity['ID'])) {

  105.             return Util::returnArrEr("查询出错", [], '2101');

  106.         }

  107.         $fromCityId = $fromCity['ID'];

  108.         $toCity = $baseArea->getInfoByName($params['toCity']);

  109.         if (empty($toCity['ID'])) {

  110.             return Util::returnArrEr("查询出错", [], '2101');

  111.         }

  112.         $toCityId = $toCity['ID'];

  113.         // 2.根据出发日期查出当天有哪些线路

  114.         //todo

  115.         $return = [

  116.             'fromCity' => $params['fromCity'],

  117.             'toCity' => $params['toCity'],

  118.             'lineSchedule' => [

  119.             ],

  120. 

  121.         ];

  122.         $runMain = new RunMain();

  123.         $lineIdArr = $runMain->getLineArrayByDateAndArea($fromDate, $fromCityId, $toCityId);

  124.         if (empty($lineIdArr[0]['line_id'])) {//没有获取到 可以售卖的线路

  125.             return Util::returnArrEr('未获取到数据', $return, '1');

  126.         }

  127.         $runProd = new RunProd();

  128.         #3设置线路信息

  129.         $operaLine = new OperaLine();

  130.         $runStation = new OperaStation();

  131.         foreach ($lineIdArr as $v) {

  132.             $line_id = $v['line_id'];

  133.             //校验黑名单

  134.             $blackLine = [454085, 453973];

  135.             if (in_array($line_id, $blackLine)) {

  136.                 continue;

  137.             }

  138.             $lineListInfo['schedule'] = $runProd->getSchedule($fromDate, $fromCityId, $toCityId, $line_id);

  139.             $line_info = $operaLine->getLineInfo($line_id);

  140.             $line_station = $runStation->getStationList($line_id, $fromCityId, $toCityId);

  141.             $ticket_array = $operaLine->getOperaLineTicketsFromLine($line_id, $fromCityId, $toCityId);

  142.             $bottomPrice = 0;

  143.             foreach ($ticket_array as $val) {

  144.                 if ($bottomPrice == 0) {

  145.                     $bottomPrice = $val['price'];

  146.                 }

  147.                 if ($val['price'] < $bottomPrice) {

  148.                     $bottomPrice = $val['price'];

  149.                 }

  150.             }

  151.             $lineListInfo['line'] = [

  152.                 'id' => $line_id . '_' . $fromCityId . '_' . $toCityId,//线路ID

  153.                 'desc' => $line_info['desc'],//线路 说明

  154.                 'name' => $line_info['name'],//线路名称

  155.                 'distance' => intval($line_info['distance']),//总路程

  156.                 'timeExpendMinutes' => $line_info['timeExpendMinutes'],//时间

  157.                 'bottomPrice' => $bottomPrice,//最低价

  158.                 'segmentPrices' => $ticket_array,//特殊站点价格

  159. //                'commissionRule' => [],//佣金规则

  160.                 'checkTicketMethods' => ['短信'],//验票方式

  161.                 'stations' => $line_station,//站点信息

  162.                 'limitTicketCntMin' => 1,//最少购买数量

  163.                 'limitTicketCntMax' => 20,//最多购买 数量

  164. //                'luggageLimit' => [],//行李大小设置

  165. //                'obtainTicket' => [],//取票地址

  166. //                'refundTicketRules' => [],//取消规则

  167. //                'specialTickets' => [],//儿童设置

  168. //                'parkingPoints' => [],//游玩点

  169. //                'TransferPoint' => [],//换车说明

  170. //                'ScenicTicket' => [],//景点信息

  171. //                'Gift' => [],//礼物 信息

  172.             ];

  173. 

  174.             $return['lineSchedule'][] = $lineListInfo;

  175.         }

  176.         return util::returnArrSu('成功', $return);

  177.     }

  178. 

  179.     /**

  180.      * Des:取消订单

  181.      * Name: refundTicket

  182.      * @param $params

  183.      * @return array

  184.      * @author 倪宗锋

  185.      */

  186.     public function refundTicket($params)

  187.     {

  188.         if (empty($params['corpOrderId'])) {

  189.             return Util::returnArrEr('params error', '', '301');

  190.         }

  191.         $orderMain = new OrderMain();

  192.         $checkOutsideOrderNo = $orderMain->checkOutsideOrderNo($params['corpOrderId'], CtripBusUtil::util()->getSupplierId());

  193.         if (empty($checkOutsideOrderNo['0']['order_id'])) {

  194.             return Util::returnArrEr('order not exist', '', '301');

  195.         }

  196.         if ($checkOutsideOrderNo[0]['order_status'] == '148') {

  197.             $orderDetail = $this->orderDetail(['corpOrderId' => $params['corpOrderId']]);

  198.             return Util::returnArrSu('success', $orderDetail['data']);

  199.         }

  200.         $data = [

  201.             'order_id' => $checkOutsideOrderNo['0']['order_id'],

  202.         ];

  203.         $curl = new CurlInterface($data, 4);

  204.         $result = $curl->execute('http://' . CS1_DOMAIN . '/api/submit-order/cancel-bus-order', 'POST');

  205.         if (!isset($result['code']) || $result['code'] != '0') {

  206.             $msg = empty($result['info']) ? '取消订单失败！' : $result['info'];

  207.             return Util::returnArrEr($msg, '', $result['code']);

  208.         }

  209.         $orderDetail = $this->orderDetail(['corpOrderId' => $params['corpOrderId']]);

  210.         return Util::returnArrSu('success', $orderDetail['data']);

  211.     }

  212. 

  213.     /**

  214.      * Des:出票信息

  215.      * Name: orderDetail

  216.      * @param $params

  217.      * @return array

  218.      * @author 倪宗锋

  219.      */

  220.     public function orderDetail($params)

  221.     {

  222.         if (empty($params['corpOrderId'])) {

  223.             return Util::returnArrEr('params error', '', '301');

  224.         }

  225.         $orderMain = new OrderMain();

  226.         $checkOutsideOrderNo = $orderMain->checkOutsideOrderNo($params['corpOrderId'], CtripBusUtil::util()->getSupplierId());

  227.         if (empty($checkOutsideOrderNo['0']['order_id'])) {

  228.             return Util::returnArrEr('order not exist', '', '301');

  229.         }

  230.         /*******设置订单状态**********/

  231.         $message = '';

  232.         if (in_array($checkOutsideOrderNo['0']['order_status'], [146, 117, 314])) {

  233.             $order_status = 2;

  234.         } else if ($checkOutsideOrderNo['0']['order_status'] == 148) {

  235.             $order_status = 5;

  236.         } else {

  237.             $order_status = 4;

  238.             $message = '未支付';

  239.         }

  240.         #获取出行人 信息

  241.         $order_id = $checkOutsideOrderNo['0']['order_id'];

  242.         $orderCustomer = new OrderCustomerInfo();

  243.         $getCustomer = $orderCustomer->getCustomer($order_id);

  244.         $tickets = [];

  245.         foreach ($getCustomer as $val) {

  246.             $array = [

  247.                 'certificateNo' => $val['cus_id_no'],//乘客证件号码

  248.                 'ticketStatus' => $order_status,//订单出票状态，1出票中，2已出票，3 无票，4退票中，5已退票，6退票失败

  249.             ];

  250.             if (empty($message) == false) {

  251.                 $array['noTicketReason'] = $message;//无票原因。ticketStatus=3时必填

  252.             }

  253.             if ($order_status == 2) {

  254.                 $array['ticketNo'] = $order_id;//出票号

  255.                 $array['ticketPwd'] = $order_id;//票密码／验证码

  256.             }

  257.             $tickets[] = $array;

  258.         }

  259.         //获取出票短信

  260. 

  261. 

  262.         //返回值

  263.         $return = [

  264.             'orderId' => $order_id,

  265.             'corpOrderId' => $params['corpOrderId'],

  266.             'smsTemplate' => $params['send_message'],

  267.             'tickets' => $tickets

  268.         ];

  269.         return Util::returnArrSu('', $return);

  270.     }

  271. 

  272.     /**

  273.      * Des:下单

  274.      * Name: order

  275.      * @param $params

  276.      * @return array

  277.      * @author 倪宗锋

  278.      */

  279.     public function makeOrder($params)

  280.     {

  281.         $checkParams = $this->checkOrderParams($params);//参数 校验并返回产品详情

  282.         if ($checkParams['flag'] == false) {

  283.             return $checkParams;

  284.         }

  285. 

  286.         $params['lineId'] = explode('_', $params['lineId'])[0];

  287.         $prodInfo = $checkParams['data'];

  288.         //错误返回值

  289.         $errorTicketArray = [];

  290.         foreach ($params["tickets"] as $val) {

  291.             $errorTicket = [

  292.                 "certificateNo" => $val["certificateNo"],

  293.                 "ticketStatus" => 3,

  294.                 "noTicketReason" => "无票"

  295.             ];

  296.             $errorTicketArray[] = $errorTicket;

  297.         }

  298.         $errorReturn = [

  299.             "order_id" => "",

  300.             "corpOrderId" => $params["corpOrderId"],

  301.             'smsTemplate' => '',

  302.             "tickets" => $errorTicketArray

  303.         ];

  304.         #校验订单是否已经存在

  305.         $orderDetail = $this->orderDetail(['corpOrderId' => $params['corpOrderId']]);//获取定下详情，如果存在则直接返回

  306.         if ($orderDetail['flag'] == true) {

  307.             return Util::returnArrSu('error', $errorReturn);

  308.         }

  309.         #不存在则去下单

  310.         #获取班次ID

  311.         $runMain = new RunMain();

  312.         $run_id = $runMain->getRunIdByLine($params['lineId'], $params['fromDate'], $params['fromTime']);

  313.         if (empty($run_id)) {

  314.             return Util::returnArrSu('get run error', $errorReturn);

  315.         }

  316.         #获取票种ID

  317.         $operaTicket = new OperaTickets();

  318.         $getTicket = $operaTicket->getTicketByRes($params['lineId'], $params['fromStationCode'], $params['toStationCode']);

  319.         if (empty($getTicket['ticket_id'])) {

  320.             return Util::returnArrSu('get ticket error', $errorReturn);

  321.         }

  322.         $ticket_id = $getTicket['ticket_id'];

  323.         $outSideSubmitOrder = new OutsideSubmitOrder();

  324.         $date = [

  325.             'from_org_id' => CtripBusUtil::util()->getSupplierId(),

  326.             'outside_order_no' => $params['corpOrderId'],

  327.             'ticket_id' => $ticket_id,

  328.             'ticket_num' => $prodInfo['prod_cnt'],

  329.             'price' => $prodInfo['price'],

  330.             'all_price' => $prodInfo['total_money'],

  331.             'customer_name' => $params['contactName'],

  332.             'customer_mobile' => $params['contactMobile'],

  333.             'customer_id_no' => '',

  334.             'passenger' => $prodInfo['passenger_str']

  335.         ];

  336.         $submitOrderId = $outSideSubmitOrder->addRow($date);

  337.         #设置 返回下单接口参数

  338.         $prod_str = [1, $run_id, $ticket_id, $prodInfo['price'], $prodInfo['prod_cnt']];

  339.         $order_info_str = [2, 0, CtripBusUtil::util()->getSupplierId(), $params['corpOrderId'], 0, 275, 1, '李秉臻'];

  340.         $customer_info_str = [$params['contactName'], $params['contactMobile'], 1, '', ''];

  341.         $passenger_info = $prodInfo['passenger_info'];

  342.         $data = [

  343.             'prod_str' => '{' . implode(',', $prod_str) . '}',

  344.             'order_info_str' => '{' . implode(',', $order_info_str) . '}',

  345.             'customer_info_str' => '{' . implode(',', $customer_info_str) . '}',

  346.             'passenger_info' => json_encode($passenger_info),

  347.             'is_send_msg' => 0

  348.         ];

  349.         $curl = new  CurlInterface($data, 4);

  350.         $result = $curl->execute('http://' . CS1_DOMAIN . '/api/submit-order/submit-bus-order', 'POST');

  351.         if (!isset($result['code']) || $result['code'] != '0') {

  352.             $msg = empty($result['info']) ? '取消订单失败！' : $result['info'];

  353.             $outSideSubmitOrder->editInfo(['status' => 2, 'ID' => $submitOrderId]);

  354.             return Util::returnArrSu($msg, $errorReturn);

  355.         }

  356.         $outSideSubmitOrder->editInfo(['status' => 1, 'ID' => $submitOrderId]);

  357.         //获取短信内容，同时模拟插入发送短信履历

  358.         $order_id_array = explode(",", $result['data']);

  359.         $send_message = $this->getSendMessageAndSimulateSend($order_id_array[0]);

  360.         return $this->orderDetail(['corpOrderId' => $params['corpOrderId'], 'send_message' => $send_message]);

  361.     }

  362. 

  363. 

  364.     /**

  365.      * Des:下单参数校验并返回整理后的数据

  366.      * Name: checkOrderParams

  367.      * @param $params

  368.      * @return array

  369.      * @author 倪宗锋

  370.      */

  371.     public function checkOrderParams($params)

  372.     {

  373.         if (empty($params['corpOrderId'])) {

  374.             return Util::returnArrEr('params error', '', '301');

  375.         }

  376.         if (empty($params['contactMobile'])) {

  377.             return Util::returnArrEr('params error', '', '301');

  378.         }

  379.         if (empty($params['contactName'])) {

  380.             return Util::returnArrEr('params error', '', '301');

  381.         }

  382.         if (empty($params['fromDate'])) {

  383.             return Util::returnArrEr('params error', '', '301');

  384.         }

  385.         if (empty($params['fromTime'])) {

  386.             return Util::returnArrEr('params error', '', '301');

  387.         }

  388.         if (empty($params['fromStationCode'])) {

  389.             return Util::returnArrEr('params error', '', '301');

  390.         }

  391.         if (empty($params['toStationCode'])) {

  392.             return Util::returnArrEr('params error', '', '301');

  393.         }

  394.         if (empty($params['lineId'])) {

  395.             return Util::returnArrEr('params error', '', '301');

  396.         }

  397.         if (empty($params['tickets']) || !is_array($params['tickets'])) {

  398.             return Util::returnArrEr('params error', '', '301');

  399.         }

  400.         //购买的产品数量

  401.         $prod_info = [

  402.             'total_money' => 0,

  403.             'price' => 0,

  404.             'prod_cnt' => 0,

  405.             'passenger_info' => []

  406.         ];

  407.         foreach ($params['tickets'] as $val) {

  408.             if (empty($val['certificateNo'])) {

  409.                 return Util::returnArrEr('params error', '', '301');

  410.             }

  411.             if (empty($val['passengerName'])) {

  412.                 return Util::returnArrEr('params error', '', '301');

  413.             }

  414.             #产品信息

  415.             $prod_info['price'] = $val['price'];

  416.             $prod_info['total_money'] += intval($val['price']);

  417.             $prod_info['prod_cnt'] += 1;

  418.             #出行人信息

  419.             $pass = [

  420.                 'passenger_name' => $val['passengerName'],

  421.                 'passenger_cardid' => $val['certificateNo'],

  422.             ];

  423.             $pass_str = $val['passengerName'] . '*' . $val['certificateNo'];

  424.             $prod_info['passenger_info'][] = $pass;

  425.             if (empty($prod_info['passenger_str'])) {

  426.                 $prod_info['passenger_str'] = $pass_str;

  427.             } else {

  428.                 $prod_info['passenger_str'] .= '/' . $pass_str;

  429.             }

  430.         }

  431.         return Util::returnArrSu('', $prod_info);

  432.     }

  433. 

  434.     /**

  435.      * Des:查询余票

  436.      * Name: remainTicket

  437.      * @param $params

  438.      * @return array

  439.      * @author 倪宗锋

  440.      */

  441.     public function remainTicket($params)

  442.     {

  443.         #参数校验

  444.         if (empty($params['fromDate'])) {

  445.             return Util::returnArrEr('params error', '', '301');

  446.         }

  447.         if (empty($params['fromTime'])) {

  448.             return Util::returnArrEr('params error', '', '301');

  449.         }

  450.         if (empty($params['fromStationCode'])) {

  451.             return Util::returnArrEr('params error', '', '301');

  452.         }

  453.         if (empty($params['toStationCode'])) {

  454.             return Util::returnArrEr('params error', '', '301');

  455.         }

  456.         if (empty($params['lineId'])) {

  457.             return Util::returnArrEr('params error', '', '301');

  458.         }

  459.         $params['lineId'] = explode('_', $params['lineId'])[0];

  460.         #获取库存

  461.         $runMain = new RunMain();

  462.         $getStock = $runMain->getStockByDateLineIdRes($params['lineId'], $params['fromDate'], $params['fromTime'], $params['fromStationCode'], $params['toStationCode']);

  463.         if (empty($getStock[0]['count'])) {

  464.             $count = 0;

  465.         } else {

  466.             $count = $getStock[0]['count'];

  467.         }

  468.         return Util::returnArrSu('', ['leftTicketCnt' => $count]);

  469.     }

  470. 

  471.     /**

  472.      *

  473.      */

  474.     public function getSendMessageAndSimulateSend($order_id)

  475.     {

  476.         $msg = new OperaMessageTemplate();

  477.         $res = $msg->otaGetMsgInfo($order_id);

  478.         if (!isset($res["code"]) || $res["code"] != 0) {

  479.             return "获取短信错误，请联系客服!!!";

  480.         } else {

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

  482.             $send_message = $res["content"];

  483.             $send_tel = $res["mobile"];

  484.             $send_msg_values = [

  485.                 'ORDER_ID' => $order_id,

  486.                 'SEND_MOBILE' => $send_tel,

  487.                 'SEND_MESSAGE' => $send_message,

  488.                 'SEND_TIME' => $current_time,

  489.                 'SEND_ERROR' => 1,

  490.                 'CREATE_USER_ID' => 2,

  491.                 'CREATE_TIME' => $current_time,

  492.                 'UPDATE_USER_ID' => 2,

  493.                 'UPDATE_TIME' => $current_time

  494.             ];

  495.             $msgRecord = new OrderSendMessage();

  496.             $msgRecord->attributes = $send_msg_values;

  497.             $res = $msgRecord->insert();

  498.             return $send_message;

  499.         }

  500.     }

  501. 

  502. }