nizongfeng
/
ZZCX_yii
1
0
Rozštěpit 0
Zdrojový kód Úkoly 0 Požadavky na natažení 0 Vydání 0 Wiki Aktivita
Nelze vybrat více než 25 témat Téma musí začínat písmenem nebo číslem, může obsahovat pomlčky („-“) a může být dlouhé až 35 znaků.
3 Revize
1 Větev
96 MiB
 
 
 
 
 
 
Větev: master
Větve Značky
${ item.name }
Vytvořit větev ${ searchTerm }
z „master“
${ noResults }
ZZCX_yii/backend/modules/hotel/controllers/AliOrderController.php

600 řádky
31 KiB
Surový Trvalý odkaz Blame Historie 

  1. <?php

  2. /**

  3.  * Created by PhpStorm.

  4.  * User: Steven

  5.  * Date: 2017/10/30

  6.  * Time: 16:22

  7.  */

  8. 

  9. namespace backend\modules\hotel\controllers;

  10. 

  11. use backend\common\Utils;

  12. use backend\modules\hotel\models\Ali\AliExecute;

  13. use backend\modules\hotel\models\Ali\AliOrder;

  14. use backend\modules\hotel\models\Ali\TopLogger;

  15. use backend\modules\hotel\models\OperaHotelRoom;

  16. use backend\modules\hotel\models\OrderInvoiceInfo;

  17. use backend\modules\hotel\models\OrderMain;

  18. use backend\modules\hotel\models\RunHotelDistrib;

  19. use common\models\BaseSupplier;

  20. use common\models\BaseSupplierSale;

  21. use Yii;

  22. use yii\filters\AccessControl;

  23. use yii\filters\ContentNegotiator;

  24. use yii\web\Response;

  25. use backend\modules\hotel\models\OperaHotelLog;

  26. use backend\modules\hotel\models\OrderHtStatusLog;

  27. use backend\modules\hotel\models\CtripOrder;

  28. use backend\modules\hotel\models\CommonOrder;

  29. 

  30. class AliOrderController extends BaseController

  31. {

  32.     public $enableCsrfValidation = false;

  33.     private $apiParas = '';   //    接口参数

  34.     private $scTime = 0;        //请求响应时间差

  35.     public $agent_id = self::AGENT_ALI_HOTEL_ID;

  36. 

  37.     public function behaviors()

  38.     {

  39.         //配置ContentNegotiator支持JSON和XML响应格式

  40.         $behaviors['contentNegotiator'] = [

  41.             'class' => ContentNegotiator::className(),

  42.             'formats' => [

  43.                 'application/xml' => Response::FORMAT_XML

  44.             ],

  45.             //            'only' => ['index'],//指定只是针对于index有效

  46.             //            'except'=>['']  //只想剔除某个action

  47.         ];

  48.         $behaviors['access'] = [

  49.             'class' => AccessControl::className(),

  50.             'rules' => [

  51.                 [

  52.                     'ips' => [

  53.                         /*'106.11.229.*', '106.11.230.*', '106.11.231.*', '106.11.228.*', '106.11.224.*', '106.11.225.*', '106.11.226.*', '140.205.51.*', '140.205.56.*',

  54.                         '106.11.227.*', '106.11.242.*', '106.11.243.*', '140.205.51.*', '140.205.144.*', '140.205.145.*', '140.205.40.*', '140.205.39.*',//阿里IP访问白名单

  55.                         '127.0.0.1', '106.14.56.77', '180.168.4.58',  //蜘蛛及本地IP访问白名单

  56.                         '116.236.255.166'*/  //小黑鱼，测试功能用

  57.                     ],

  58.                      'allow' => true,

  59.                 ],

  60.             ],

  61.         ];

  62.         return $behaviors;

  63.     }

  64. 

  65. 

  66.     /**

  67.      * Notes:对外接口入口

  68.      * User: Steven

  69.      * Date: 2018/1/17

  70.      * Time: 15:16

  71.      * @return object

  72.      * @throws \yii\base\InvalidConfigException

  73.      */

  74.     public function actionIndex()

  75.     {

  76.         $startTime = microtime(TRUE);

  77.         $request = Yii::$app->request->getRawBody();

  78.         $exec = new AliExecute();

  79.         $valid_res = $exec->validAuth($request);

  80.         if (!$valid_res) {

  81.             $result = ['Message' => '账号权限验证失败', 'ResultCode' => '-4'];

  82.         } else {

  83.             $this->apiParas = $exec->action_param;

  84.             $action = $exec->action_id;

  85.             $result = $this->$action();

  86.         }

  87.         $rs = \Yii::createObject([

  88.             'class' => 'yii\web\Response',

  89.             'format' => \yii\web\Response::FORMAT_XML,

  90.             'formatters' => [

  91.                 \yii\web\Response::FORMAT_XML => [

  92.                     'class' => 'yii\web\XmlResponseFormatter',

  93.                     'rootTag' => 'Result', //根节点

  94.                 ],

  95.             ],

  96.             'data' => $result

  97.         ]);

  98.         $endTime = microtime(TRUE);

  99.         $this->scTime = round(floatval($endTime - $startTime), 3);//时间差

  100.         $logger = new TopLogger;

  101.         $logger->log([date("Y-m-d H:i:s"), json_encode($result) . "\n" . 'time：' . $this->scTime . 's' . PHP_EOL], 'ali/order');

  102.         return $rs;

  103.     }

  104. 

  105.     /**

  106.      * Author:Steven

  107.      * Desc:酒店试单请求 用户进入预定页面之前，会通过此接口到直连商家确认产品是否可售

  108.      * 1、响应时间2秒以内（超时认为试单通过） 2、有明确的成功或失败结果  3、价格、担保、退改规则有变化有正确的反馈

  109.      * @return array

  110.      */

  111.     public function ValidateRQ()

  112.     {

  113.         $ali_order = new AliOrder(['scenario' => 'ValidateRQ']);

  114.         $order = json_decode(json_encode($this->apiParas), true);

  115.         if (!$ali_order->load($order, '') || !$ali_order->validate()) {

  116.             $getError = $ali_order->getFirstErrors();

  117.             $msg = '';

  118.             foreach ($getError as $item) {

  119.                 $msg .= $item . ';';

  120.             }

  121.             return ['Message' => $msg, 'ResultCode' => '-116'];

  122.         }

  123.         $end_date = date('Y-m-d', strtotime("-1 day", strtotime($this->apiParas->CheckOut)));

  124.         $data = RunHotelDistrib::getAvailProduct($this->apiParas->RatePlanCode, $this->apiParas->CheckIn, $end_date);

  125.         $flag = empty($data) ? false : true;

  126.         $non_book_cn = 0;

  127.         foreach ($data as $item) {

  128.             if ($item['RUN_STATUS'] == 329 || $item['AUTHORITY_STATUS'] == 0 || $item['ROOM_RUN_STATUS'] == 0 || $item['ROOM_IS_ONSALE'] == 0 || $item['IS_ONSALE'] == 0) {

  129.                 $flag = false;

  130.                 $non_book_cn++;

  131.             }

  132.             if ($this->apiParas->RoomNum > $item['REMAINING_COUNT']) {

  133.                 $flag = false;

  134.             }

  135.             $price_list[] = [

  136.                 'date' => $item['RUN_DATE'],

  137.                 'price' => $item['PROD_PRICE'] * 100,

  138.                 'quota' => $item['REMAINING_COUNT']

  139.             ];

  140.         }

  141.         if ($flag) {

  142.             $result = [

  143.                 'Message' => '',

  144.                 'CreateOrderValidateKey' => time(),

  145.                 'ResultCode' => '0',

  146.                 'InventoryPrice' => json_encode($price_list)

  147.             ];

  148.         } else {

  149.             $days = Utils::diffBetweenTwoDays($this->apiParas->CheckIn, $this->apiParas->CheckOut);

  150.             $result = [

  151.                 'Message' => '',

  152.                 'CreateOrderValidateKey' => time(),

  153.                 'ResultCode' => $days <= $non_book_cn ? '-1' : '-3',

  154.                 'InventoryPrice' => json_encode($price_list)

  155.             ];

  156.             $msg = $days <= $non_book_cn ? '满房' : '房量不足（请求日期库存不全部为0，部分可售）';

  157.             // 查询酒店信息

  158.             $hotelInfo = OperaHotelRoom::find()

  159.                 ->select(["a.ROOM_NAME", "a.INNER_IDENTIFY", "b.HOTEL_NAME", "a.RP_ID"])

  160.                 ->leftJoin("opera_hotel as b", "a.HOTEL_ID = b.HOTEL_ID")

  161.                 ->from("opera_hotel_room as a")

  162.                 ->where(["a.ID" => $this->apiParas->RatePlanCode, "a.CANCEL_FLAG" => 0, "b.CANCEL_FLAG" => 0])

  163.                 ->asArray() ->one();

  164.             $this->sendAliMsgToRtx('【阿里直连】酒店可定检查失败：', '原因：' . $msg . "\n酒店：" . $hotelInfo['HOTEL_NAME'] .

  165.                 "\n房型：" . $hotelInfo['ROOM_NAME'] . "\n内部标识：" . $hotelInfo['INNER_IDENTIFY'] . "\nRP_ID：". $hotelInfo["RP_ID"] ."\n日期：" . $this->apiParas->CheckIn . '~' . $this->apiParas->CheckOut, 2);

  166.         }

  167.         return $result;

  168.     }

  169. 

  170. 

  171.     /**

  172.      * Notes: 预定订单 已经支付接口

  173.      * 1、预订接口（BookRQ）要求多次调用返回相同的结果，且相同阿里订单号不重复创建预订

  174.      * 2、支持同步和异步两种方式预订，如果需要异步处理，BookRQ返回接收成功，但不返回外部订单号即可

  175.      * 3、处理能力要有合理评估并告知，去啊会根据性能要求投放流量

  176.      * 4、 下单重试的时限为3分钟重试3次，查询重试的时限为30分钟重试30次，超过时限没有结果会当作失败处理，并给发出告警，需要人工处理避免占房

  177.      * User: Steven

  178.      * Date: 2018/1/16

  179.      * Time: 11:44

  180.      * @return array

  181.      * @throws \yii\db\Exception

  182.      */

  183.     public function BookRQ()

  184.     {

  185.         $ali_order = new AliOrder(['scenario' => 'BookRQ']);

  186.         $order = json_decode(json_encode($this->apiParas), true);

  187.         //这里会在load判断是否已经存在该订单

  188.         if ($ali_order->load($order, '') && $ali_order->validate()) {

  189.             $res = $ali_order->validateBook(); //检查产品是否可定

  190.             if ($res['ResultCode'] != 0) {

  191.                 $this->sendAliMsgToRtx('【阿里直连】酒店下单：', "下单失败" . "\n" . '淘宝单号' . $ali_order->TaoBaoOrderId . "\n" . '原因：' . json_decode($res["Message"], true)["reason"], 2);

  192. 

  193.                 return $res;  //这里会直接返回不可定的原因（价格或者库存校验失败）和code

  194.             }

  195.             $res_code = $ali_order->bookOrder();

  196.             if ($res_code == AliOrder::RESPONSE_SUCCESS) {  //下单成功

  197.                 $response = [

  198.                     'Message' => AliOrder::RESPONSE_MSG[$res_code],

  199.                     'ResultCode' => 0,

  200.                     'OrderId' => $ali_order->zz_order_id,

  201.                 ];

  202.                 OrderMain::updateAll(['DOCKING_TYPE' => CtripOrder::ORDER_DOCKING_TYPE, 'CHANNEL_ORDER_STATUS' => OrderMain::ORDER_CHANNEL_STATUS_WAITING, 'UPDATE_TIME' => date('Y-m-d H:i:s', time())],

  203.                     ['and', ['CANCEL_FLAG' => 0], ['or', ['ORDER_ID' => $ali_order->zz_order_id], ['PARENT_ORDER_ID' => $ali_order->zz_order_id]]]);

  204.             } else { //系统异常不能创建订单，请返回此错误码。第三方系统返回此错误码，去啊系统将自动将卖家从搜索中屏蔽。

  205.                 //这里我们还是返回预订成功，  然后进行异步下单（当Message和OrderId为空时表示异步下单）

  206.                 if ($res_code == AliOrder::RESPONSE_SYSERROR) {

  207.                     $ali_order->save();

  208.                     $response = [

  209.                         'Message' => '',

  210.                         'ResultCode' => 0,

  211.                         'OrderId' => '',

  212.                     ];

  213.                     $this->sendAliMsgToRtx('【阿里直连】酒店下单：', "接收数据成功，系统下单失败" . "\n" . '淘宝单号：' .

  214.                         $ali_order->TaoBaoOrderId . "\n处理办法：" . '正常搬单，再变更订单类型为直连，后续操作同其他直连订单一致', 4);

  215.                 } else {

  216.                     $response = [

  217.                         'Message' => AliOrder::RESPONSE_MSG[$res_code],

  218.                         'ResultCode' => $res_code,

  219.                         'OrderId' => '',

  220.                     ];

  221.                 }

  222.             }

  223. 

  224.             return $response;

  225.         } else {

  226.             $error = $ali_order->getErrors();

  227.             foreach ($error as $k => $v) {

  228.                 if ((array_key_exists($v[0], AliOrder::RESPONSE_MSG))) {

  229.                     $response = ['Message' => AliOrder::RESPONSE_MSG[$v[0]], 'ResultCode' => -$v[0]];

  230.                 } else {

  231.                     $response = ['Message' => AliOrder::RESPONSE_MSG[AliOrder::RESPONSE_PARAM_ERROR], 'ResultCode' => AliOrder::RESPONSE_PARAM_ERROR];

  232.                 }

  233. 

  234.                 return $response;

  235.             }

  236.         }

  237.     }

  238. 

  239.     /**

  240.      * Author:Steven

  241.      * Desc:下单接口

  242.      * @param $order

  243.      * @return array|bool

  244.      */

  245.     private function zzBook($order)

  246.     {

  247.         $params = [

  248.             'CreateUserID' => Yii::$app->params['ctrip']['base_user_id'],

  249.             'OrderID' => $this->OrderID, //渠道订单号

  250.             'HotelID' => $this->Spider_hotel, //酒店ID

  251.             'RoomID' => $this->Spider_room,  //房型ID

  252.             'DistribID' => Yii::$app->params['ctrip']['supplier_id'],//渠道ID

  253.             'RoomNum' => $this->Quantity, //房间数量

  254.             'CheckIn' => $this->Arrival,  //入住日期

  255.             'CheckOut' => $this->Departure,    //离店日期,

  256.             'TotalPrice' => $this->CostAmount,//订单总价

  257.             'Currency' => $this->Currency, //币种

  258.             'ContactName' => '',//联系人姓名

  259.             'ContactTel' => '',  //联系人电话

  260.             'PayType' => CommonOrder::PAY_TYPE_CREDIT,   // 638:支付宝支付; 221:现金支付 ;275:授信支付;278:微信支付

  261.             'PayTradeNo' => '', //支付流水号

  262.             'OrderGuests' => CtripOrder::getGuestsName($this->Guests), //入住人信息

  263.             'Comment' => $this->Notice,  //客人备注

  264.             'NeedInvoice' => 0,

  265.             'InvoiceInfos' => [  //发票信息

  266.             ],

  267.             'RoomPrices' => CtripOrder::getRoomPrices($this->RoomPrices)

  268.         ];

  269.         $new_order = new CommonOrder(['scenario' => 'BookHotelOrder']);

  270. 

  271. 

  272.         $room_type = OperaHotelRoom::findOne($order['RatePlanCode']);

  273.         //构造下单需要的参数

  274.         $user_id = Yii::$app->params['ali']['base_user_id'];

  275.         $hotel_id = $order['HotelId'];

  276.         $room_type = $room_type->ROOM_TYPE;

  277.         $org_id = Yii::$app->params['ali']['supplier_id'];      //携程渠道ID

  278.         $org_num = $order['TaoBaoOrderId'];    //渠道订单号

  279.         $Guest_list = '';

  280.         $OrderGuests = !isset($order['OrderGuests']['OrderGuest']['Name']) ? $order['OrderGuests']['OrderGuest'] : $order['OrderGuests'];

  281.         foreach ($OrderGuests as $OrderGuest) {

  282.             $Guest_list .= $OrderGuest['Name'] . ' ';

  283.         }

  284.         if (empty($Guest_list)) {

  285.             $Guest_list = $order['ContactName'];

  286.         }

  287.         $new_room_list = '';

  288.         $notes = empty($order['Comment']) ? '' : Yii::$app->params['ali']['base_user_id'] . "|" . time() . "|0|{$order['Comment']}}";

  289.         $cus_list = "{{$Guest_list}{$order['ContactEmail']}," . ($order['ContactTel']) . "," . $notes . '}';

  290.         $supplier = BaseSupplier::findOne(['ID' => Yii::$app->params['ali']['supplier_id']]);

  291.         if ($supplier == null) {

  292.             return false;

  293.         }

  294.         $commissionRule = $supplier->getCommissionRule(BaseSupplierSale::SALE_HOTEL);

  295.         if ($commissionRule != null && $commissionRule->COMMISION_TYPE == BaseSupplierSale::TYPE_CHANNEL) {

  296.             $base_com = $commissionRule->BACK_PERCENT;

  297.         } else if ($commissionRule == null) {

  298.             return false;

  299.         } else {

  300.             $base_com = 0;

  301.         }

  302.         $dailyInfo = !isset($order['DailyInfos']['DailyInfo']['Day']) ? $order['DailyInfos']['DailyInfo'] : $order['DailyInfos'];

  303.         foreach ($dailyInfo as $DailyInfo) {

  304.             $commission = round(($base_com / 100) * ($DailyInfo['Price'] / 100), 2);

  305.             $new_room_list .= "{''" . $DailyInfo['Day'] . "''," . $order['RoomNum'] . "," . ($DailyInfo['Price'] / 100) . "," . $commission . "}";

  306.         }

  307.         //ht_make_order(259,197,9,675,'444444444','{''2017-11-09'',1,100,3.5}','{石福鹏测试,17602134075,}','23:00',0,313)

  308.         //        ht_make_order CALL ht_make_order(640,125,4,669,'4960112824 ','{''2017-11-24'',1,780,0}','{徐文成,,640|1511416569|1|尽量安排双床房。}','23:00',0,313)

  309.         $checkin_time = date('H:i', strtotime($order['LatestArriveTime']));

  310.         $sql = "CALL ht_make_order({$user_id},{$hotel_id},{$room_type},{$org_id},'{$org_num}','{$new_room_list}','{$cus_list}','{$checkin_time}',0,145)";

  311.         $result = Yii::$app->db->createCommand($sql)->queryOne();

  312.         $logger = new TopLogger;

  313.         $logger->log([date("Y-m-d H:i:s"), "【阿里下单】" . "\n" . $sql . "\n" . json_encode($result)], 'ali/order');

  314.         if ($result['errcode'] == 0) {

  315.             //添加发票信息

  316.             if (isset($order['InvoiceInfo']['NeedInvoice']) && $order['InvoiceInfo']['NeedInvoice'] == 1) {

  317.                 $order_invoice_info = new OrderInvoiceInfo();

  318.                 if (!$order_invoice_info->load($order['InvoiceInfo'], '')) {

  319.                     //加载数据失败

  320.                     $this->sendAliMsgToRtx('【阿里直连】酒店下单：', "保存发票信息到数据库失败，请联系技术进行处理" . "\n" . '订单号' . $result['order_id'], 1);

  321.                 }

  322.                 $order_invoice_info->InvoiceMoney = $order['TotalPrice'] / 100;

  323.                 $order_invoice_info->CreateUseId = Yii::$app->params['ali']['base_user_id'];

  324.                 $order_invoice_info->Status = 1;

  325.                 $order_invoice_info->ChannelId = Yii::$app->params['ali']['supplier_id'];

  326.                 $order_invoice_info->OrderID = $result['order_id'];

  327.                 $order_invoice_info->save();

  328.             }

  329.             //写订单日志、状态日志

  330.             $orderLog = new OperaHotelLog();

  331.             $orderLog->CREATE_USER_ID = Yii::$app->params['ali']['base_user_id'];

  332.             $orderLog->HOTEL_ID = $order['HotelId'];

  333.             $orderLog->LOG_TYPE = OperaHotelLog::LOG_TYPE_ORDER;

  334.             $orderLog->ROOM_TYPE = $room_type;

  335.             $orderLog->PARENT_ROOM_TYPE = $order['RoomTypeId'];

  336.             $orderLog->LOG_DESC = "创建订单号为" . $result['order_id'] . "的订单";

  337.             $orderLog->ORDER_ID = $result['order_id'];

  338.             $orderLog->save();

  339.             $statusLog = new OrderHtStatusLog();

  340.             $statusLog->CREATE_USER_ID = Yii::$app->params['ali']['base_user_id'];

  341.             $statusLog->UPDATE_USER_ID = Yii::$app->params['ali']['base_user_id'];

  342.             $statusLog->ORDER_STATUS = OrderMain::ORDER_STATUS_WAITING_SEND;

  343.             $statusLog->ORDER_ID = $result['order_id'];

  344.             $statusLog->save();

  345.             $count = OrderMain::updateAll(['DOCKING_TYPE' => OrderMain::ORDER_TYPE_CHANNEL, 'ORDER_PAY_STATUS' => '0', 'CHANNEL_ORDER_STATUS' => OrderMain::ORDER_CHANNEL_STATUS_WAITING,

  346.                 'ORDER_STATUS' => OrderMain::ORDER_STATUS_WAITING_SEND],

  347.                 ['and', ['CANCEL_FLAG' => 0], ['or', ['ORDER_ID' => $result['order_id']], ['PARENT_ORDER_ID' => $result['order_id']]]]);

  348.             return ['OrderId' => $result['order_id']];

  349.         } else {   //下单失败

  350.             return false;

  351.         }

  352.     }

  353. 

  354. 

  355.     /**

  356.      * Author:Steven

  357.      * Desc:

  358.      * 使用场景：

  359.      * 1、预订之后，查询预订结果   9

  360.      * 2、补偿入住/NoShow状态

  361.      * 3、补偿离店状态

  362.      * 4、补偿账单

  363.      * 5、取消订单后，查询取消结果

  364.      * 要求：

  365.      * 1、同步接口

  366.      * 2、使用去啊订单号查询

  367.      * 3、数据必须准确，必须和订单实时数据一致

  368.      * 4、数据要全，预订状态、预订号、预订信息、结帐单（结帐状态后）等都需要

  369.      * @return array

  370.      */

  371.     public function QueryStatusRQ()

  372.     {

  373.         $status = ''; //系统订单状态

  374.         $flag = true;

  375.         //QueryType  查询类型。 1-普通查询；2-下单过程中的查询（一般是进行对订单状态的确认）；3-取消订单过程中的查询； 4:系统状态补偿查询

  376.         $req_param = json_decode(json_encode($this->apiParas), true);

  377.         if (empty($req_param['OrderId'])) {  //说明是异步下单

  378.             $res_order_id = OrderMain::find()->select(['ORDER_ID'])->where([

  379.                 'OUTSIDE_ORDER_NO' => "{$req_param['TaoBaoOrderId']}",

  380.                 'ORDER_PROD_TYPE' => OrderMain::ORDER_PROD_TYPE_MAIN,

  381.                 'PARENT_ORDER_ID' => 0,

  382.                 'CANCEL_FLAG' => 0,

  383.             ])->limit(1)->asArray()->one();

  384.         } else {

  385.             $res_order_id = OrderMain::find()->where([

  386.                 'ORDER_ID' => $req_param['OrderId'],

  387.                 'OUTSIDE_ORDER_NO' => "{$req_param['TaoBaoOrderId']}",

  388.                 'ORDER_PROD_TYPE' => OrderMain::ORDER_PROD_TYPE_MAIN,

  389.                 'PARENT_ORDER_ID' => 0,

  390.                 'CANCEL_FLAG' => 0,

  391.             ])->limit(1)->asArray()->one();

  392.         }

  393.         $PmsResID = "";

  394.         if (!empty($res_order_id)) {  //在ORDER_MAIN 中下单成功

  395.             $res = OrderMain::find()->select(['ORDER_ID', 'OUTSIDE_ORDER_NO', 'ORDER_VALID_STATUS', 'PROD_START_STATION_DATE', 'PROD_END_STATION_DATE',

  396.                 'CHANNEL_ORDER_STATUS', 'ORDER_STATUS', 'ORDER_CONFIRM_CODE', 'ORDER_PRICE', 'ORDER_DESCRIPTION', 'PARENT_PROD_NAME'])->where([

  397.                 'OUTSIDE_ORDER_NO' => $req_param['TaoBaoOrderId'],

  398.                 'ORDER_ID' => $res_order_id['ORDER_ID'],

  399.                 'CANCEL_FLAG' => 0,

  400.             ])->asArray()->one();

  401.             if ($res['CHANNEL_ORDER_STATUS'] == OrderMain::ORDER_CHANNEL_STATUS_PAYING || $res['CHANNEL_ORDER_STATUS'] == OrderMain::ORDER_CHANNEL_STATUS_APPLY_CANCEL

  402.                 || $res['CHANNEL_ORDER_STATUS'] == OrderMain::ORDER_CHANNEL_STATUS_WAITING) { //渠道待支付 待接单

  403.                 $status = 3;//订单等待处理中  待支付

  404.             } elseif ($res['CHANNEL_ORDER_STATUS'] == OrderMain::ORDER_CHANNEL_STATUS_ACCEPT) { //渠道已接单

  405.                 $status = 1;   //订单已经确认

  406.                 $PmsResID = $res['ORDER_CONFIRM_CODE'];   //酒店的确认号

  407.             } elseif ($res['CHANNEL_ORDER_STATUS'] == OrderMain::ORDER_CHANNEL_STATUS_REJECT

  408.                 || $res['CHANNEL_ORDER_STATUS'] == OrderMain::ORDER_CHANNEL_STATUS_APPLY_CANCEL_CONFIRMED) {   //已拒绝 拒单

  409.                 $status = 4; //订单已取消

  410.             } elseif ($res['CHANNEL_ORDER_STATUS'] == OrderMain::ORDER_CHANNEL_STATUS_APPLY_CANCEL_REJECT) { //渠道申请取消被拒

  411.                 if ($res['ORDER_STATUS'] == OrderMain::ORDER_STATUS_NO_PAID || $res['ORDER_STATUS'] == OrderMain::ORDER_STATUS_WAITING_SEND

  412.                     || $res['ORDER_STATUS'] = OrderMain::ORDER_STATUS_WAITING_CONFIRM) {//待支付 待发单

  413.                     $status = 3;//订单等待处理中

  414.                 } elseif ($res['ORDER_STATUS'] == OrderMain::ORDER_STATUS_CONFIRMED || $res['ORDER_STATUS'] == OrderMain::ORDER_STATUS_CHANGING

  415.                     || $res['ORDER_STATUS'] == OrderMain::ORDER_STATUS_FINISH) {

  416.                     $status = 1;   //订单已经确认

  417.                 } elseif ($res['ORDER_STATUS'] == OrderMain::ORDER_STATUS_CANCEL_BEFORE_CONFIRM || $res['ORDER_STATUS'] == OrderMain::ORDER_STATUS_CANCEL) {  //

  418.                     $status = 4; //订单已取消

  419.                 } else {

  420.                     $flag = false;

  421.                 }

  422.             } elseif ($res['CHANNEL_ORDER_STATUS'] == 0) {   //说明直连失败的订单，搬完单但是还没有变更成之直连的状态，这个时候也需要返回待确认

  423.                 $status = 3;

  424.             } else {

  425.                 $flag = false;

  426.             }

  427.         } else {  //order_main 中没有该订单

  428.             $order = AliOrder::find()->select(['TotalPrice'])->where(['TaoBaoOrderId' => "{$req_param['TaoBaoOrderId']}"])->asArray()->one();

  429.             if (empty($order)) {

  430.                 $result = ['ResultCode' => -302, 'Message' => '订单不存在', 'OrderId' => $req_param['OrderId']];

  431.             } else {

  432.                 $result = [

  433.                     'Message' => '',

  434.                     'ResultCode' => '0',

  435.                     'TaoBaoOrderId' => $req_param['TaoBaoOrderId'],

  436.                     'OrderId' => '',

  437.                     'Status' => 3,

  438.                     'TotalRoomPrice' => $order['TotalPrice'],

  439.                     'OtherFee' => 0,

  440.                 ];

  441.             }

  442.             return $result;

  443.         }

  444. 

  445.         if (!$flag) {   //查询订单状态的时候，有未判断到的其他状态，需要推送开发人员

  446.             $this->sendAliMsgToRtx('【阿里直连】阿里渠道直连订单状态查询失败：', "有未判断到的其他订单状态，请关注" . "\n" . $req_param['OrderId'], '');

  447.             $result = [];

  448.         } else {

  449.             $result = [

  450.                 'Message' => '',

  451.                 'ResultCode' => '0',

  452.                 'TaoBaoOrderId' => $req_param['TaoBaoOrderId'],

  453.                 'OrderId' => $res_order_id['ORDER_ID'],

  454.                 'Status' => $status,

  455.                 'PmsResID' => $PmsResID,

  456.                 'TotalRoomPrice' => $res['ORDER_PRICE'] * 100,

  457.                 'OtherFee' => 0,

  458.             ];

  459.             if ($res['PROD_START_STATION_DATE'] < date('Y-m-d', time())) {

  460.                 $desc = explode('|', $res['ORDER_DESCRIPTION']);

  461.                 $RoomQuantity = explode(',', $desc[0])[2];

  462.                 $result['OrderInfo'] = [

  463.                     'CheckIn' => $res['PROD_START_STATION_DATE'] . ' 00:00:00',

  464.                     'CheckOut' => $res['PROD_END_STATION_DATE'] . ' 00:00:00',

  465.                     'RoomQuantity' => $RoomQuantity,

  466.                     'Hotel' => $res['PARENT_PROD_NAME'],

  467.                 ];

  468.             }

  469.         }

  470. 

  471.         return $result;

  472.     }

  473. 

  474.     /**

  475.      * Author:Steven

  476.      * Desc:支付成功回调 由于我们跟阿里合作的形式是先付款后下单

  477.      * 根据此接口定义实现支付成功回调接口，并暴露成服务。

  478.      * 此接口用于预付订单用户支付成功后通知第三方系统，仅通知一次（超时原因会重试3次）

  479.      * @return array

  480.      */

  481.     public function PaySuccessRQ()

  482.     {

  483.         $flag = true;

  484.         $order = json_decode(json_encode($this->apiParas), true);

  485.         $res_order_id = OrderMain::find()

  486.             ->leftJoin('opera_hotel_room', 'order_main.PARENT_PROD_ID=opera_hotel_room.HOTEL_ID and order_main.PROD_ID=opera_hotel_room.ROOM_TYPE and opera_hotel_room.CANCEL_FLAG=0')

  487.             ->select(['ORDER_ID', 'PROD_ID', 'PARENT_PROD_ID', 'opera_hotel_room.PARENT_ROOM_TYPE'])->where([

  488.                 'OUTSIDE_ORDER_NO' => "{$order['TaoBaoOrderId']}",

  489.                 'ORDER_PROD_TYPE' => OrderMain::ORDER_PROD_TYPE_MAIN,

  490.                 'PARENT_ORDER_ID' => 0,

  491.                 'order_main.CANCEL_FLAG' => 0,

  492.             ])->limit(1)->asArray()->one();

  493.         if (empty($res_order_id)) { //order_main 说明订单是异步下单

  494.             $count = AliOrder::updateAll(['AlipayTradeNo' => $order['AlipayTradeNo']], ['TaoBaoOrderId' => $order['TaoBaoOrderId']]);

  495.             if ($count <= 0) {

  496.                 $flag = false;

  497.             }

  498.         } else {

  499.             $orderLog = new OperaHotelLog();

  500.             $orderLog->CREATE_USER_ID = Yii::$app->params['ali']['base_user_id'];

  501.             $orderLog->HOTEL_ID = $res_order_id['PARENT_PROD_ID'];

  502.             $orderLog->LOG_TYPE = OperaHotelLog::LOG_TYPE_ORDER;

  503.             $orderLog->ROOM_TYPE = $res_order_id['PROD_ID'];

  504.             $orderLog->PARENT_ROOM_TYPE = $res_order_id['PARENT_ROOM_TYPE'];

  505.             $orderLog->LOG_DESC = "支付订单，支付宝流水号：" . $order['AlipayTradeNo'];

  506.             $orderLog->ORDER_ID = $res_order_id['ORDER_ID'];

  507.             if (!$orderLog->save()) {

  508.                 $flag = false;

  509.             }

  510.         }

  511.         $result = $flag ? ['Message' => '处理成功', 'ResultCode' => 0] : ['Message' => '内部错误', 'ResultCode' => -400];

  512. 

  513.         return $result;

  514.     }

  515. 

  516.     /**

  517.      * Author:Steven

  518.      * Desc:酒店退款通知请求     此接口请求只作为退款通知申请，不会根据响应结果做退款处理。

  519.      * @return array

  520.      */

  521.     public function OrderRefundRQ()

  522.     {

  523.         $req_param = json_decode(json_encode($this->apiParas), true);

  524.         $res_order_id = OrderMain::find()->leftJoin('opera_hotel_room', 'order_main.PARENT_PROD_ID=opera_hotel_room.HOTEL_ID and order_main.PROD_ID=opera_hotel_room.ROOM_TYPE and opera_hotel_room.CANCEL_FLAG=0')

  525.             ->select(['ORDER_ID', 'PROD_ID', 'PARENT_PROD_ID', 'opera_hotel_room.PARENT_ROOM_TYPE'])->where([

  526.                 'OUTSIDE_ORDER_NO' => "{$req_param['TaoBaoOrderId']}",

  527.                 'ORDER_PROD_TYPE' => OrderMain::ORDER_PROD_TYPE_MAIN,

  528.                 'PARENT_ORDER_ID' => 0,

  529.                 'order_main.CANCEL_FLAG' => 0,

  530.             ])->limit(1)->asArray()->one();

  531.         $orderLog = new OperaHotelLog();

  532.         $orderLog->CREATE_USER_ID = Yii::$app->params['ali']['base_user_id'];

  533.         $orderLog->HOTEL_ID = $res_order_id['PARENT_PROD_ID'];

  534.         $orderLog->LOG_TYPE = OperaHotelLog::LOG_TYPE_ORDER;

  535.         $orderLog->ROOM_TYPE = $res_order_id['PROD_ID'];

  536.         $orderLog->PARENT_ROOM_TYPE = $res_order_id['PARENT_ROOM_TYPE'];

  537.         $orderLog->LOG_DESC = "买家申请退款，订单号：" . $res_order_id['ORDER_ID'];

  538.         $orderLog->ORDER_ID = $res_order_id['ORDER_ID'];

  539.         $orderLog->save();

  540. 

  541.         $Shipped = $req_param['Shipped'] ? '已发货' : '未发货';

  542.         $this->sendAliMsgToRtx('【阿里直连】买家申请退款通知：', '订单:' . $req_param['OrderId'] . ' ' . $Shipped . "\n" . '买家申请退款，请至淘宝后台进行处理', 4);

  543.         $result = ['Message' => '接受成功', 'ResultCode' => '0'];

  544. 

  545.         return $result;

  546.     }

  547. 

  548.     /**

  549.      * Author:Steven

  550.      * Desc:用户取消订单

  551.      * 1、由于我们的产品都是不可取消，所以客人申请取消，都需要我们同意或者拒绝，当同意退款的时候就会调用这个接口

  552.      * 2、订单未付款 关闭时也会请求该接口

  553.      * 3、我们拒单，或者我们确认无房 也会调用该接口

  554.      * 4、下单失败的情况也会调用该接口

  555.      * @return array

  556.      */

  557.     public function CancelRQ()

  558.     {

  559.         $req_param = json_decode(json_encode($this->apiParas), true);

  560.         $res_order_id = OrderMain::find()->leftJoin('opera_hotel_room', 'order_main.PARENT_PROD_ID=opera_hotel_room.HOTEL_ID and order_main.PROD_ID=opera_hotel_room.ROOM_TYPE and opera_hotel_room.CANCEL_FLAG=0')

  561.             ->select(['ORDER_ID', 'CHANNEL_ORDER_STATUS', 'PROD_ID', 'PARENT_PROD_ID', 'opera_hotel_room.PARENT_ROOM_TYPE'])->where([

  562.                 'OUTSIDE_ORDER_NO' => "{$req_param['TaoBaoOrderId']}",

  563.                 'ORDER_PROD_TYPE' => OrderMain::ORDER_PROD_TYPE_MAIN,

  564.                 'PARENT_ORDER_ID' => 0,

  565.                 'order_main.CANCEL_FLAG' => 0,

  566.             ])->limit(1)->asArray()->one();

  567.         if (empty($res_order_id)) {

  568.             return ['Message' => '', 'ResultCode' => '-204'];  //不存在该订单

  569.         }

  570.         $orderLog = new OperaHotelLog();

  571.         $orderLog->CREATE_USER_ID = Yii::$app->params['ali']['base_user_id'];

  572.         $orderLog->HOTEL_ID = $res_order_id['PARENT_PROD_ID'];

  573.         $orderLog->LOG_TYPE = OperaHotelLog::LOG_TYPE_ORDER;

  574.         $orderLog->ROOM_TYPE = $res_order_id['PROD_ID'];

  575.         $orderLog->PARENT_ROOM_TYPE = $res_order_id['PARENT_ROOM_TYPE'];

  576.         $orderLog->LOG_DESC = "买家申请取消订单，已同意取消（退款成功），订单号：" . $res_order_id['ORDER_ID'];

  577.         $orderLog->ORDER_ID = $res_order_id['ORDER_ID'];

  578.         $orderLog->save();

  579.         if ($res_order_id['CHANNEL_ORDER_STATUS'] != OrderMain::ORDER_CHANNEL_STATUS_APPLY_CANCEL_CONFIRMED) {

  580.             //当接收到取消通知的时候说明，订单已经同意取消或者超时自动取消，需要修改

  581.             $count = OrderMain::updateAll(['CHANNEL_ORDER_STATUS' => OrderMain::ORDER_CHANNEL_STATUS_APPLY_CANCEL_CONFIRMED],

  582.                 ['and', ['CANCEL_FLAG' => 0], ['or', ['ORDER_ID' => $res_order_id['ORDER_ID']], ['PARENT_ORDER_ID' => $res_order_id['ORDER_ID']]]]);

  583.             $orderLog = new OperaHotelLog();

  584.             $orderLog->CREATE_USER_ID = Yii::$app->params['ali']['base_user_id'];

  585.             $orderLog->HOTEL_ID = $res_order_id['PARENT_PROD_ID'];

  586.             $orderLog->LOG_TYPE = OperaHotelLog::LOG_TYPE_ORDER;

  587.             $orderLog->ROOM_TYPE = $res_order_id['PROD_ID'];

  588.             $orderLog->PARENT_ROOM_TYPE = $res_order_id['PARENT_ROOM_TYPE'];

  589.             $orderLog->LOG_DESC = "渠道订单状态变为已取消，订单号：" . $res_order_id['ORDER_ID'];

  590.             $orderLog->ORDER_ID = $res_order_id['ORDER_ID'];

  591.             $orderLog->save();

  592.         } else {

  593.             return ['Message' => '', 'ResultCode' => '-205']; //已取消

  594.         }

  595.         $this->sendAliMsgToRtx('【阿里直连】买家申请取消订单：', '订单号：' . $req_param['OrderId'] . "\n" . "阿里订单号：" . $req_param['TaoBaoOrderId'] . "\n" . '用户取消订单，请及时核实CS订单状态，如果订单在渠道上已经取消，请尽快取消CS订单', 4);

  596.         $result = ['Message' => '', 'ResultCode' => '-100'];

  597. 

  598.         return $result;

  599.     }

  600. }