nizongfeng
/
ZZCX_yii
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.
3 Commits
1 Branch
96 MiB
 
 
 
 
 
 
Branch: master
Branches Tags
${ item.name }
Create branch ${ searchTerm }
from 'master'
${ noResults }
ZZCX_yii/backend/modules/hotel/controllers/CtripController.php

1075 lines
53 KiB
Raw Permalink Blame History 

  1. <?php

  2. 

  3. namespace backend\modules\hotel\controllers;

  4. 

  5. use backend\common\Utils;

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

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

  8. use backend\modules\hotel\models\CtripRoomInfo;

  9. use backend\modules\hotel\models\HotelRelation;

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

  11. use backend\modules\hotel\models\OrderChannelInfo;

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

  13. use backend\modules\hotel\models\RoomRelation;

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

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

  16. use common\components\zOfficeWechat;

  17. use Yii;

  18. use yii\base\Module;

  19. use yii\filters\AccessControl;

  20. use yii\helpers\Json;

  21. 

  22. class CtripController extends HotelController

  23. {

  24.     public $enableCsrfValidation = false;

  25.     public $startTime = 0;

  26.     public $ctripUser;

  27.     public $data = [];

  28.     public $post = [];

  29. 

  30.     /**

  31.      * CtripController constructor.

  32.      * @param string $id

  33.      * @param Module $module

  34.      * @param array $config

  35.      */

  36.     public function __construct($id, $module, array $config = [])

  37.     {

  38.         $this->startTime = microtime(TRUE);

  39.         libxml_disable_entity_loader(false);

  40.         $this->ctripUser = Yii::$app->params['ctrip'];

  41.         parent::__construct($id, $module, $config);

  42.     }

  43. 

  44. 

  45.     public function behaviors()

  46.     {

  47.         return [

  48.             'access' => [

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

  50.                 'except' => ['set-room-price', 'set-room-info', 'update-room-quantity'],

  51.                 'rules' => [

  52.                     [

  53.                         'ips' => ['103.48.141.164', '210.13.114.57','114.80.1.*','140.207.218.*','114.80.10.*','140.206.211.*','103.48.141.160','210.13.114.32','45.251.106.192',

  54.                             '221.130.190.129','101.226.248.*','140.207.228.*' //携程IP访问白名单

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

  56.                             , '116.236.255.166',

  57.                             '222.65.108.254' //纳格兰临时允许访问，网络环境地址：张江炬芯研发大厦A栋215

  58.                         ],

  59.                         'allow' => true,

  60.                     ],

  61.                 ],/*'rules' => [

  62.                     [

  63.                         'ips' => ['101.226.248.76', '101.226.248.77', '101.226.248.78', '101.226.248.79', '140.207.228.76',

  64.                             '140.207.228.77', '140.207.228.78', '140.207.228.79', '103.48.141.164', '210.13.114.57', '114.80.10.1',

  65.                             '140.207.218.145', '221.130.190.129','101.226.248.*','140.207.228.*' //携程IP访问白名单

  66.                             , '127.0.0.1', '106.14.56.77', '180.168.4.58', '139.224.30.29'  //蜘蛛IP访问白名单

  67.                             , '116.236.255.166',

  68.                         ],

  69.                         'allow' => true,

  70.                     ],

  71.                 ],*/

  72.             ],

  73.         ];

  74.     }

  75. 

  76.     public function actions()

  77.     {

  78.         return [

  79.             'service' => [

  80.                 'class' => 'subdee\soapserver\SoapAction',

  81.                 'serviceVar' => 'WSDL'

  82.                 //                'serviceUrl' => 'http://cs1.yiireal.com/hotel/ctrip/service?WSDL'   请求示例

  83.             ],

  84.         ];

  85.     }

  86. 

  87.     protected function actionSoap($data_xml, $request_name)

  88.     {

  89.         $client = Yii::$app->soapClient;

  90.         $param = Utils::xml_encode($data_xml, $request_name);

  91.         $this->data = $data_xml;

  92.         $res = $client->AdapterRequest(['requestXml' => $param]);

  93. 

  94.         return $res->AdapterRequestResult;

  95.     }

  96. 

  97.     /**

  98.      * User: wangxj

  99.      *

  100.      * soap 对外接口

  101.      *

  102.      * @param string $xml

  103.      * @param string $Invoketype

  104.      *

  105.      * @return string

  106.      *

  107.      * @soap

  108.      */

  109.     public function Invoke($xml, $Invoketype)

  110.     {

  111.         $this->writeLog($Invoketype, $xml);

  112.         $request = Utils::xml_to_array($xml);   //将xml转化成数组

  113.         //        if($request[''])

  114.         $head = $request['HeaderInfo'];

  115.         $user = $head['Authentication']['@attributes'];

  116.         $soap = Yii::$app->params['ctrip']['soap'];

  117.         if ($user['UserName'] == $soap['UserName'] && $user['Password'] == $soap['Password']) {

  118.             //            $action = $head['RequestType']['@attributes']['Name'];

  119.             $body = $request[$Invoketype . 'Request'];

  120.             $data['Message'] = '操作成功';

  121.             $data['ResultCode'] = 0;

  122.             //携程!!!，这个接口大小写不规则，单独处理

  123.             $res = $this->$Invoketype($body);

  124.             if ($Invoketype == "DomesticCheckRoomAvail") {   //可定检查最有最外层的ResultCode，内层没有ReturnCode

  125.                 $data = $res;

  126.             } else {

  127.                 $data['ResultCode'] = isset($res['ReturnCode']) ? $res['ReturnCode'] : $data['ResultCode'];

  128.                 $data['Message'] = isset($res['ReturnDescript']) ? $res['ReturnDescript'] : $data['Message'];

  129.                 if ($Invoketype == 'DomesticCancelHotelOrder') {

  130.                     $data['DomesticCancelhotelOrderResponse'] = $res;

  131.                 } else {

  132.                     $data[$Invoketype . 'Response'] = $res;

  133.                 }

  134.             }

  135. 

  136.         } else {

  137.             $data = [

  138.                 'Message' => '用户认证或授权错误(程序错误) ',

  139.                 'ResultCode' => CtripOrder::RETURN_CODE_AUTH_FAIL,

  140.             ];

  141.         }

  142.         $data = Utils::data_to_xml($data);

  143.         $data = Utils::formatResult($data);

  144.         $this->writeLog($Invoketype, $data);

  145. 

  146.         return new \SoapVar($data, XSD_STRING);

  147.     }

  148. 

  149.     /**

  150.      * User:Steven

  151.      *

  152.      * Desc:DomesticCheckRoomAvail （可定检查）

  153.      * 1.接口调用方：携程

  154.      * 2.接口返回方：合作方

  155.      * 3.调用频率：订单量的10倍以上

  156.      * 4.使用说明：携程在给酒店下订单前，调用合作方接口。通过传入客人入住信息，得 到该房型是否可订。该接口响应时间（含网络）需要在3秒以内

  157.      * @param array $body

  158.      * @return mixed

  159.      */

  160.     protected function DomesticCheckRoomAvail($body)

  161.     {

  162.         //        $a='{"Hotel":"4386248","Arrival":"2018-07-12T00:00:00","Departure":"2018-07-13T00:00:00","Room":"145386478","RoomNumber":"1","Person":"1","BalanceType":"PP","RoomPrices":{"RoomPrice":{"EffectDate":"2018-07-12T00:00:00","Price":"729","CNYPrice":"0","Cost":"655.4","CNYCost":"0","BreakFast":"0"}},"Currency":"RMB","IsCompensate":"F","TraceLogID":"ChenckAfterOrder_6733588561","OperationType":"New","CheckAvailID":"0","CheckAvailType":"Query"}';

  163.         //        $body=json_decode($a,true);

  164.         $this->writeLog('DomesticCheckRoomAvail', \GuzzleHttp\json_encode($body));

  165.         $trip = new CtripOrder(['scenario' => 'check-room-avail']);

  166.         if (!$trip->load_valid($body, '') || !$trip->validate()) {

  167.             $roomInfo_arr['RequestResponse']['RequestResult'] = array();

  168.             $RequestResult['Message'] = '接受失败！缺少必要参数!';

  169.             $RequestResult['ResultCode'] = CtripOrder::RETURN_CODE_CHCEK_CANNOT_ANALYZE;

  170.             $RequestResult['DomesticCheckRoomAvailResponse'] = [

  171.                 "IsBookable" => 0,

  172.                 "ReturnDescript" => CtripOrder::RETURN_CODE_CHCEK_CANNOT_ANALYZE . ":返回无法解析",

  173.             ];

  174.             $arr = array(

  175.                 "agentid" => 1000002,

  176.                 "title" => '【报警】可定检查：',

  177.                 "msg" => "[{$RequestResult['ResultCode']}]" . $RequestResult['Message'] . "\n" . "请尽快联系技术，核实渠道上接口参数是否正确",

  178.                 "touser" => $this->_developerList,

  179.             );

  180.             zOfficeWechat::sendMsg($arr);

  181. 

  182.             return $RequestResult;

  183.         }

  184.         $res_arr = $trip->CheckRoomAvail();

  185.         $roomInfo_arr['RequestResponse']['RequestResult'] = array();

  186.         $RequestResult = $roomInfo_arr['RequestResponse']['RequestResult'];

  187.         $RequestResult['Message'] = '接受成功！';

  188.         $RequestResult['ResultCode'] = 0;

  189.         $availInfo['IsBookable'] = isset($res_arr['isBookable']) && $res_arr['isBookable'] === false ? 0 : 1;

  190.         $total_price = '';

  191.         $date_list = Utils::createDateRangeArray($body['Arrival'], $body['Departure']);

  192.         //$roomData = isset($body['RoomPrices']['RoomPrice']['EffectDate']) ? $body['RoomPrices'] : $body['RoomPrices']['RoomPrice'];

  193.         $IsBookable = 1;   //初始化可订

  194.         $ReturnDescript = "";

  195.         $ReturnCode = 0;

  196.         foreach ($date_list as $value) {

  197.             if (empty($res_arr)) {

  198.                 $IsBookable = 0;

  199.                 $ReturnCode = CtripOrder::RETURN_CODE_CHCEK_NO_ROOM_STATUS;

  200.                 $ReturnDescript = '房型信息不存在';

  201.             } else {

  202.                 foreach ($res_arr as $item) {

  203.                     if (date('Y-m-d', strtotime($value)) == $item['RUN_DATE']) {

  204.                         if ($item['AUTHORITY_STATUS'] != 1 || $item['IS_ONSALE'] != 1 || $item['CANCEL_FLAG_B'] != 0 || $item['CANCEL_FLAG_C'] != 0 || $item['RUN_STATUS'] == 329) {

  205.                             //不可订

  206.                             $availInfo['IsBookable'] = 0;

  207.                             $ReturnCode = CtripOrder::RETURN_CODE_CHCEK_STOCK_FAIL;

  208.                             $item['AUTHORITY_STATUS'] != 1 ? $availInfo['ReturnDescript'] = '未授权！' : ($item['IS_ONSALE'] != 1 ? $availInfo['ReturnDescript'] = '已下线' : ($item['RUN_STATUS'] == 329 ? $availInfo['ReturnDescript'] = ' 关房' : ''));

  209.                         } else {

  210.                             //*****（重要）注意：携程要求不做库存的校验，即如果库存大于0，那么就返回可订，同时返回可用房量，如果等于0，即不可订

  211.                             if ($body['IsHoldRoom'] == 'R') { //保留房

  212.                                 if ($item['REMAINING_COUNT'] > 0 && ($item['buyout'] + $item['retain'] + $item['inquiry']) > 0) {

  213.                                     $availInfo['IsBookable'] = 1;

  214.                                 } else {

  215.                                     $IsBookable = 0;//不可定

  216.                                     $ReturnCode = CtripOrder::RETURN_CODE_CHCEK_STOCK_LESS;

  217.                                     $ReturnDescript = $item['REMAINING_COUNT'] <= 0 ? '保留房库存不足！' : '基础房型库存不足！';

  218.                                 }

  219.                                 /* if ($item['REMAINING_COUNT'] < $body['RoomNumber']) {

  220.                                      $availInfo['IsBookable'] = 0;//不可定

  221.                                      $availInfo['ReturnDescript'] = '保留房库存不足！';    //错误描述：

  222.                                  } else {

  223.                                      if ($body['RoomNumber'] > ($item['buyout'] + $item['retain'])) {

  224.                                          $availInfo['IsBookable'] = 0;

  225.                                          $availInfo['ReturnDescript'] = '基础房型库存不足！';    //错误描述：

  226.                                      } else {

  227.                                          $availInfo['IsBookable'] = 1;

  228.                                      }

  229.                                  }*/

  230.                             } else {    //非保留房

  231.                                 if ($item['OVERSELL_FLAG'] == 1) { //开启超卖

  232.                                     if (($item['buyout'] + $item['retain'] + $item['inquiry']) > 0) {

  233.                                         $availInfo['IsBookable'] = 1;

  234.                                     } else {

  235.                                         $IsBookable = 0;//不可定

  236.                                         $ReturnCode = CtripOrder::RETURN_CODE_CHCEK_STOCK_LESS;

  237.                                         $ReturnDescript = '基础房型库存不足！(预订非保留)';

  238.                                     }

  239.                                 } else { //限量售卖

  240.                                     if ($item['REMAINING_COUNT'] > 0 && ($item['buyout'] + $item['retain'] + $item['inquiry']) > 0) {

  241.                                         $availInfo['IsBookable'] = 1;

  242.                                     } else {

  243.                                         $IsBookable = 0;//不可定

  244.                                         $ReturnCode = CtripOrder::RETURN_CODE_CHCEK_STOCK_LESS;

  245.                                         $ReturnDescript = '库存不足！(预订非保留)';

  246.                                     }

  247.                                 }

  248.                                 /*if ($item['OVERSELL_FLAG'] == 1 || $item['REMAINING_COUNT'] >= $body['RoomNumber']) {

  249.                                     if ($body['RoomNumber'] > ($item['buyout'] + $item['retain'] + $item['inquiry'])) {

  250.                                         $availInfo['IsBookable'] = 0;

  251.                                         $availInfo['ReturnDescript'] = '基础房型库存不足！(预订非保留)';    //错误描述：

  252.                                     } else {

  253.                                         //在渠道房量充足的情况下，判断基础房型的房量是否充足

  254.                                         $availInfo['IsBookable'] = 1;

  255.                                     }

  256.                                 } else {

  257.                                     $availInfo['IsBookable'] = 0;

  258.                                     $availInfo['ReturnDescript'] = '限量售卖，库存不足';    //错误描述：

  259.                                 }*/

  260.                             }

  261.                         }

  262.                         $total_price += $body['RoomNumber'] * $item['PROD_PRICE'];

  263.                         $roomPrice['RoomPrice'] = array();

  264.                         $roomPrice['RoomPrice']['EffectDate'] = $item['RUN_DATE'] . 'T00:00:00';

  265.                         $roomPrice['RoomPrice']['Cost'] = $item['PROD_PRICE'];  //取分销价

  266.                         $roomPrice['RoomPrice']['CNYCost'] = $item['PROD_PRICE'];

  267.                         $roomPrice['RoomPrice']['BreakFast'] = $item['BREAKFAST_INCLUDE'];

  268.                         $availInfo['RoomPrices'][] = $roomPrice;

  269.                         $AvailRoomQuantity['AvailRoomQuantity']['EffectDate'] = $item['RUN_DATE'] . 'T00:00:00';

  270.                         $AvailRoomQuantity['AvailRoomQuantity']['AvailQuantity'] = $item['OVERSELL_FLAG'] == 1 ? 99 : $item['REMAINING_COUNT'];

  271.                         $availInfo['AvailRoomQuantitys'][] = $AvailRoomQuantity;

  272.                     }

  273.                 }

  274.             }

  275.         }

  276.         $availInfo['IsBookable'] = $IsBookable;

  277.         $availInfo['ReturnDescript'] = $ReturnDescript;

  278. 

  279.         if ($availInfo['IsBookable'] == 0) {

  280.             $opera_hotel_room = new OperaHotelRoom();

  281.             $res = $opera_hotel_room->getHotelRoomInfo($body['Room']);

  282.             $user = $this->_developerList . "|" . $res[0]['USER_NAME'] . '|yangxt';

  283.             $msg = '酒店名称：' . $res[0]['HOTEL_NAME'] . "\n房型名称：" . $res[0]['ROOM_NAME'] . "\n内部标示：" . $res[0]['INNER_IDENTIFY'] . "\n开始日期：" . $body['Arrival'] . "\n结束日期：" . $body['Departure'] . "\n携程房型ID：" . $res[0]['ChannelRoomId'] . "\n原因：" . $availInfo['ReturnDescript'];

  284.             $arr = array(

  285.                 "agentid" => 1000002,

  286.                 "title" => '可定检查失败：',

  287.                 "msg" => $msg,

  288.                 "touser" => $user,

  289.             );

  290.             zOfficeWechat::sendMsg($arr);

  291.         }

  292.         $availInfo['Currency'] = 'RMB';

  293.         $availInfo['Room'] = $body['Room'];

  294.         $availInfo['InterFaceAmount'] = $total_price;//接口订单金额

  295.         $availInfos["DomesticCheckRoomAvailResponse"] = $availInfo;

  296.         $availInfos["ResultCode"] = $ReturnCode;

  297.         $availInfos['Message'] = $ReturnDescript;

  298. 

  299.         return $availInfos;

  300.     }

  301. 

  302.     /**

  303.      * User:Steven

  304.      *

  305.      * Desc: DomesticSubmitNewHotelOrder （新订订单）

  306.      * 1-1.接口调用方：携程/合作方

  307.      * 1-2.接口返回方：合作方/携程

  308.      * 1-3.调用频率：频繁

  309.      * 1-4.使用说明：通过该接口，提交订单给对方系统

  310.      * $user_id,$hotel_id,$room_type,$org_id,$org_num,$room_list,$cus_list,$checkin_time,$if_cancel,$benefit,$total_commission,$order_id

  311.      *

  312.      * @param array $body

  313.      *

  314.      * param $OrderID integer  订单号    订单号 Y

  315.      * param $InterFaceSendID integer  订单接口发送号    同一订单每次发送编号会不同，接收方需落 地保存 Y

  316.      * param $Hotel integer    Ctrip 酒店编号    酒店编号    Y

  317.      * param $HotelName string 酒店名    酒店名 Y

  318.      * param $Arrival string 入住日期    入住日期    Y

  319.      * param $Departure string   离店日期    离店日期    Y

  320.      * param $EarlyArrivalTime string    最早到店时间    最早到店时间  Y

  321.      * param $LastArrivalTime string 最晚到店时间    最晚到店时间  Y

  322.      * param $Person INT   实际入住人数    实际入住人数  Y

  323.      * param $Notice string    备注    备注  N

  324.      * param $IsHoldRoom string    是否保留房    是否保留房（F 或空-否，R-是）   N

  325.      * param $IsFlashLive string   是否闪住订单    是否闪住（F 或空-否，T-是）    N

  326.      * param $Guests object  用户集合     $GuestEntity array 单个用户    FirstName LastName ChinesName Y

  327.      * param $mobilePhone integer  手机号    Ctrip 客服号码  Y

  328.      * param $Currency string  币种    币种  N

  329.      * param $Amount float 订单卖价总金额    订单卖价总金额（预付一般不传或传 0） Y

  330.      * param $CNYAmount float  订单卖价总金额(人民 币)    订单卖价总金额（人民币），现付一般不传或 者传 0   Y

  331.      * param $GuaranteeType string 担保方式    担保方式    Y

  332.      * param $BalanceType string   价格类型    支付方式（PP 预付，FG 现付，PKG 包价）    Y

  333.      * param $Room integer Ctrip 房型编号    房型编号（供应商需要转成自己的对应编号）    Y

  334.      * param $RoomPerson INT   房型最大入住人数    房型最大入住人数    Y

  335.      * param $RoomName string  房型名称    房型名称    Y

  336.      * param $Quantity INT 预订间数    预订间数    Y

  337.      * param $CostAmount float 订单底价总金额(原币 种)    订单底价金额（原币种）,现付一般不传或者 传 0    Y

  338.      * param $CNYCostAmount float  订单底价总金额(人民 币)    订单底价金额（人民币）,现付一般不传或者 传 0

  339.      * param $RoomPrices object RoomPrice<> EffectDate Price 卖价 CNYPrice 订单卖价金额（原币种） Cost 底价 CNYCost 订单底价金额（原币种） BreakFast 早餐数量 ,预付一般不传或者 传 0 Y

  340.      * param $AddOptionals array    附加服务        N

  341.      * param $InterFaceConfirmNo integer   酒店确认号    酒店确认号   Y

  342.      * param $HotelConfirmNo integer   供应商确认号    供应商确认号  Y

  343.      * param $InterFaceAmount INT  接口订单金额    接口订单金额，现付产品卖价，预付产品底价    Y

  344.      * param $ReturnCode INT   错误代码    错误代码    Y

  345.      * param $ReturnDescript string    返回描述    返回描述    Y

  346.      * param $OrderStatus INT  订单状态    订单状态(1:待确认;2:失败;3:确认;4:拒绝)  Y

  347.      * param $FGToPP string    是否现转预订单    是否现转预订单（T：是，F：否）    Y

  348.      * param $DepositAmount float  押金    默认值 0   Y

  349.      * param $IsFreeSale string    是否 FreeSale    F 或空-否，T-是  N

  350.      * @return mixed

  351.      *

  352.      * @throws \yii\db\Exception

  353.      */

  354.     protected function DomesticSubmitNewHotelOrder($body)

  355.     {

  356.         $trip = new CtripOrder(['scenario' => 'new-order']);

  357.         if ($trip->load($body, '') && $trip->validate()) {

  358.             $res = $trip->makeOrder();

  359.             if ($res == CtripOrder::RETURN_CODE_SUCCESS) {

  360.                 //保存发送号

  361.                 $interFace = new OrderChannelInfo();

  362.                 $interFace->ORDER_ID = $trip->Spider_order_id;

  363.                 $interFace->InterFaceSendID = $trip->InterFaceSendID;

  364.                 //先置旧的数据cancel_flag为1

  365.                 OrderChannelInfo::updateAll(['CANCEL_FLAG' => 1], ['ORDER_ID' => $trip->Spider_order_id]);

  366.                 $interFace->save();

  367. 

  368.                 //需要修改订单的来源类型为对接

  369.                 //如果是保留房，直接是已确认，返回状态3:已确认

  370.                 if ($trip->IsHoldRoom == 'R') {

  371.                     $channel_status = CtripOrder::ORDER_STATUS_ACCEPT;

  372.                     $orderStatus = 3;

  373.                     $commonOrder = new CommonOrder();

  374.                     $commonOrder->setOrderLog($trip->Spider_order_id, $trip->Spider_parent_room_type, $trip->Spider_room_type, "该订单为保留房订单，系统自动接单", Yii::$app->params['ctrip']['base_user_id'], $trip->Spider_hotel);

  375.                 } else {

  376.                     $channel_status = CtripOrder::ORDER_STATUS_WAITING;

  377.                     $orderStatus = 1;

  378.                 }

  379.                 $data = [

  380.                     'OrderStatus' => $orderStatus,

  381.                     'InterFaceConfirmNO' => '',

  382.                     'HotelConfirmNo' => $trip->Spider_order_id,

  383.                     'InterFaceAmount' => $trip->CNYCostAmount,

  384.                     'ReturnCode' => CtripOrder::RETURN_CODE_SUCCESS,

  385.                     'ReturnDescript' => '预订成功',

  386.                 ];

  387.                 OrderMain::updateAll(['DOCKING_TYPE' => CtripOrder::ORDER_DOCKING_TYPE, 'CHANNEL_ORDER_STATUS' => $channel_status, 'IF_LAST_PROD' => $trip->IF_LAST_PROD, 'UPDATE_TIME' => date('Y-m-d H:i:s', time())],

  388.                     ['and', ['CANCEL_FLAG' => 0], ['or', ['ORDER_ID' => $trip->Spider_order_id], ['PARENT_ORDER_ID' => $trip->Spider_order_id]]]);

  389.             } else {

  390.                 if ($res == CtripOrder::RETURN_CODE_PROGRAM_FAIL) {

  391.                     $ctrip_status = 2;

  392.                 } else {

  393.                     $ctrip_status = 4;

  394.                 }

  395.                 $data = [

  396.                     'OrderStatus' => $ctrip_status,

  397.                     'InterFaceConfirmNO' => '',

  398.                     'HotelConfirmNo' => '',

  399.                     'InterFaceAmount' => $trip->CNYCostAmount,

  400.                     'ReturnCode' => $res,

  401.                     'ReturnDescript' => CtripOrder::RETURN_MSG[$res],

  402.                 ];

  403.             }

  404.         } else {

  405.             $code = Utils::getModelError($trip);

  406.             $data = [

  407.                 'OrderStatus' => 4,

  408.                 'InterFaceConfirmNO' => '',

  409.                 'HotelConfirmNo' => '',

  410.                 'InterFaceAmount' => $trip->CNYCostAmount,

  411.                 'ReturnCode' => $code,

  412.                 'ReturnDescript' => CtripOrder::RETURN_MSG[$code],

  413.             ];

  414.         }

  415.         //OrderStatus==2的情况会走ebk,不在需要人工搬单   为4的情况会直接拒单

  416.         if ($data['OrderStatus'] == 2 || $data['OrderStatus'] == 4) {

  417.             $msg = $data['OrderStatus'] == 2 ? "订单预定失败，失败原因：{$data['ReturnDescript']}，订单已进入携程ebooking，请关注！"

  418.                 : "订单预定失败，失败原因：{$data['ReturnDescript']}，订单已被拒绝，请核实该订单相关房态！";

  419.             $msg .= '订单号：' . $trip->OrderID;

  420.             $this->sendAliMsgToRtx('【携程直连】新订订单失败：', $msg, 4, self::AGENT_COMMON_HOTEL_ID);

  421.         }

  422.         //新订单进来，都推送一次房态和数量

  423.         $this->post['hotel_id'] = $trip->Spider_hotel;

  424.         $this->post['parent_room_type'] = $trip->Spider_parent_room_type;

  425.         $this->post['room_type'] = $trip->Spider_room_type;

  426.         $this->post['StartDate'] = substr($trip->Arrival, 0, 10);

  427.         $this->post['EndDate'] = substr($trip->Departure, 0, 10);

  428. 

  429.         /*$this->actionSetRoomInfo();

  430.         $this->actionUpdateRoomQuantity();*/

  431. 

  432.         return $data;

  433.     }

  434. 

  435.     /**

  436.      * Author:Steven

  437.      * User:wangxj

  438.      *

  439.      * Desc: DomesticCancelHotelOrder （取消订单）

  440.      * 1-1.接口调用方：携程/合作方

  441.      * 1-2.接口返回方：合作方/携程

  442.      * 1-3.调用频率：频繁

  443.      * 1-4.使用说明：通过该接口，提交订单给对方系统

  444.      *

  445.      * @param array $body

  446.      * @return array

  447.      * @throws \Exception

  448.      * @throws \yii\db\Exception

  449.      */

  450.     protected function DomesticCancelHotelOrder($body)

  451.     {

  452.         $trip = new CtripOrder(['scenario' => 'cancel-order']);

  453.         $trip->load($body, '');

  454.         $trip->saveLog($this->ctripUser['base_user_id'], "渠道商申请取消订单：" . $trip->Spider_order_id);

  455.         $res = $trip->applyCancel();

  456.         if ($res == CtripOrder::RETURN_CODE_SUCCESS) {

  457.             //保存发送号

  458.             $interFace = new OrderChannelInfo();

  459.             $interFace->ORDER_ID = $trip->Spider_order_id;

  460.             $interFace->InterFaceSendID = $trip->InterFaceSendID;

  461.             //先置旧的数据cancel_flag为1

  462.             OrderChannelInfo::updateAll(['CANCEL_FLAG' => 1], ['ORDER_ID' => $trip->Spider_order_id]);

  463.             $interFace->save();

  464.             $data = [

  465.                 'OrderStatus' => 3,

  466.                 'OrderID' => $trip->OrderID,

  467.                 'InterFaceConfirmNO' => $trip->InterFaceConfirmNO,

  468.                 'ReturnCode' => $res,

  469.                 'ReturnDescript' => '同意取消',

  470.             ];

  471. 

  472.             // $trip->saveLog(2, '同意渠道取消订单');

  473.             //取消成功通知客服

  474. 

  475.             /*if (in_array($res['data']->ORDER_STATUS, [OrderMain::ORDER_STATUS_WAITING_CONFIRM, OrderMain::ORDER_STATUS_CONFIRMED])) {

  476.                 $dict_type = DictType::findOne($res['data']->ORDER_STATUS);

  477.                 if ($dict_type !== null) {

  478.                     $extra = '（' . $dict_type->TYPE_NAME . '）';

  479.                 } else

  480.                     $extra = '（未知订单状态）';

  481.             } else {

  482.                 $extra = '';

  483.             }*/

  484.             /*$arr = array(

  485.                 "agentid" => 1000002,

  486.                 "title" => '取消订单：',

  487.                 "msg" => '携程取消订单：' . $trip->Spider_order_id,

  488.                 "touser" => $this->_messageList,

  489.             );

  490.             zOfficeWechat::sendMsg($arr);*/

  491.         } else {

  492.             //渠道接单状态变为取消被拒

  493.             $data = [

  494.                 'OrderStatus' => 4,

  495.                 'OrderID' => $trip->OrderID,

  496.                 'InterFaceConfirmNO' => $trip->InterFaceConfirmNO,

  497.                 'ReturnCode' => $res,

  498.                 'ReturnDescript' => CtripOrder::RETURN_MSG[$res],

  499.             ];

  500.         }

  501.         $notice = $res == CtripOrder::RETURN_CODE_SUCCESS ? "同意取消订单" : "拒绝取消订单";

  502.         $this->sendAliMsgToRtx('【携程直连】携程申请取消订单：', "携程申请取消订单【" . $trip->Spider_order_id . "】，" . $notice, 4, self::AGENT_COMMON_HOTEL_ID);

  503. 

  504.         return $data;

  505.     }

  506. 

  507.     /**

  508.      * User:Steven

  509.      * Desc:DomesticGetOrderStatus（订单状态查询)

  510.      * @param array $body

  511.      *

  512.      * @return mixed

  513.      */

  514.     protected function DomesticGetOrderStatus($body)

  515.     {

  516.         $trip = new CtripOrder(['scenario' => 'order-status']);

  517.         $rs['Message'] = '';

  518.         $rs['ResultCode'] = 0;

  519.         foreach ($body['Orders'] as $item) {

  520.             $trip->load($item, '');

  521.             $res = $trip->getOrderStatus();

  522.             $data['OrderID'] = $item['OrderID'];

  523.             $data['InterFaceSendID'] = $item['InterFaceSendID'];

  524.             $data['ReturnDescript'] = '接收成功';

  525.             if (!$res)   //1:待确认  2:订单未发送到合作方或返回代码 为失败 3 :合作方确认订单  4：合作方拒绝订单

  526.             {

  527.                 $rs['Message'] = "未查到订单号为{$item['OrderID']}的订单信息！";

  528.                 $order['Orders'] = array();

  529.                 $rs['ResultCode'] = 9999;

  530.             } else {

  531.                 switch ($res['CHANNEL_ORDER_STATUS']) {  //OrderStatus新订只能传1待确认、3确认、4拒绝

  532.                     case 550: //待处理

  533.                         $OrderStatus = 1;

  534.                         break;

  535.                     case 551: //已接单

  536.                         $OrderStatus = 3;

  537.                         break;

  538.                     case 552:   //已拒绝

  539.                         $OrderStatus = 4;

  540.                         break;

  541.                 }

  542.                 $dt = [

  543.                     'OrderStatus' => $OrderStatus,

  544.                     'HotelConfirmNo' => $res['ORDER_ID'],

  545.                     'ReturnCode' => 0,

  546.                 ];

  547.                 $data['OrderEntity'] = $dt;

  548.                 $order['Orders'][] = $data;

  549.             }

  550. 

  551.         }

  552. 

  553.         return $order;

  554.     }

  555. 

  556.     /**

  557.      * User:Steven

  558.      *

  559.      * Desc:SetRoomPrice（设置房型价格）

  560.      * 1.接口调用方：合作方

  561.      * 2.接口返回方：携程

  562.      * 3.调用频率：不限制，建议不大于50万次/分钟（QPS<1万）

  563.      * 4.使用说明：携程建议当价格变化时，立即进行推送。携程方面是异步处理价格。

  564.      *  param $begin_date string

  565.      *  param $end_date string

  566.      *  param $hotel_id string

  567.      *  param $base_room_id string

  568.      *  param $room_id string

  569.      * @return mixed

  570.      */

  571.     public function actionSetRoomPrice(array $param = [])

  572.     {

  573.         $this->post = ($this->post == []) ? Yii::$app->request->post() : $this->post;

  574.         if (!empty($param)) {

  575.             $this->post = $param;

  576.         }

  577. 

  578.         $post = $this->post;

  579.         $post['StartDate'] = empty($post['StartDate']) ? date('Y-m-d') : $post['StartDate'];

  580.         $post['EndDate'] = empty($post['EndDate']) ? date('Y-m-d', strtotime('+90 days')) : $post['EndDate'];

  581.         //至少提供90天的数据，一次最多推送120天的房价房态数据，超过120天数据需要分批推送

  582.         $PriceInfos = array();

  583.         //获取酒店房价数据

  584.         $runHotelDsitrib = new RunHotelDistrib();

  585.         $res = $runHotelDsitrib->getRoomPrice($post);

  586.         $HRInfo = OperaHotelRoom::find()->select(['a.ROOM_NAME', 'b.HOTEL_NAME'])->joinWith('operaHotel b')

  587.             ->from('opera_hotel_room a')

  588.             ->where(['a.HOTEL_ID' => $post['hotel_id'], 'a.BASE_ROOM_TYPE' => $post['parent_room_type'], 'a.ROOM_TYPE' => $post['room_type']]);

  589.         if ($res['code'] != 0) {

  590.             if ($res['code'] == 1 || $res['code'] == 3) {

  591.                 $arr = array(

  592.                     "agentid" => 1000002,

  593.                     "title" => $res['info'],

  594.                     "msg" => '酒店名称：' . $HRInfo['HOTEL_NAME'] . "\n" . '房型名称：' . $HRInfo['ROOM_NAME'] . '开始日期：' . $post['StartDate'] . "\n" . '结束日期：' . $post['EndDate'],

  595.                     "touser" => $this->_developerList,

  596.                 );

  597.                 zOfficeWechat::sendMsg($arr);

  598.             }

  599. 

  600.             return false;

  601.         }

  602. 

  603.         $dayZone = $this->dateGroup($res['data']);

  604.         if (isset($dayZone['code'])) {

  605.             //警报：推送RTX

  606.             $arr = array(

  607.                 "agentid" => 1000002,

  608.                 "title" => '(报警)设置房型价格接口：',

  609.                 "msg" => '酒店名称：' . $HRInfo['HOTEL_NAME'] . "\n" . '房型名称：' . $HRInfo['ROOM_NAME'] . '开始日期：' . $post['StartDate'] . "\n" . '结束日期：' . $post['EndDate'],

  610.                 "touser" => $this->_developerList,

  611.             );

  612.             zOfficeWechat::sendMsg($arr);

  613. 

  614.             return false;

  615.         }

  616.         $rs = '';

  617.         //将分段后的时间分别推送房价格

  618.         $ctrip_room_id = RoomRelation::getChannelId($res['data'][0]['ROOM_ID'], Yii::$app->params['ctrip']['relation_supplier_id']); //携程的房型ID

  619.         $ctrip_hotel_id = HotelRelation::getChannelId($post['hotel_id'], Yii::$app->params['ctrip']['relation_supplier_id']);    //携程的房型ID

  620.         foreach ($dayZone as $value) {

  621.             foreach ($res['data'] as $key => $item) {

  622.                 if ($item['RUN_DATE'] >= $value['StartDate'] && $item['RUN_DATE'] <= $value['EndDate']) {

  623.                     $Prices['Price'] = array(

  624.                         'AmountBeforeTaxFee' => $item['PROD_PRICE'],   //税前

  625.                         'AmountAfterTaxFee' => $item['PROD_PRICE'],    //税后

  626.                         'CostAmountBeforeTaxFee' => $item['PROD_PRICE'],//税前成本(底价)

  627.                         'CostAmountAfterTaxFee' => $item['PROD_PRICE'],    //税后成本

  628.                         'Day' => '1'           //连住天数，暂不用，默认为1

  629.                     );

  630.                     //PriceInfo节点代表一天的价格，每天的价格可以不同

  631.                     $PriceInfo['PriceInfo'] = array(

  632.                         'Prices' => $Prices,

  633.                         'Stays' => 1,  //连住，暂不用，默认为1

  634.                         'BlanceType' => Yii::$app->params['ctrip']['balance_type'], //支付类型

  635.                         'PriceType' => Yii::$app->params['ctrip']['price_type'],  //价格类型

  636.                         'Breakfast' => $item['BREAKFAST_INCLUDE'],  //早餐

  637.                         'Applicability' => '111111'   //适用人群

  638.                     );

  639.                     $PriceInfos['PriceInfos'][] = $PriceInfo;

  640.                     unset($res['data'][$key]);

  641.                 }

  642.             }

  643.             //根据日期范围生成多天的 SetRoomPriceItem（目前我们系统的业务逻辑是：每次只能录入单个房型多天的价格）

  644.             $SetRoomPriceItem['SetRoomPriceItem'] = array(

  645.                 'PriceInfos' => $PriceInfos['PriceInfos'],

  646.                 'RoomID' => $ctrip_room_id,

  647.                 'StartDate' => $value['StartDate'] . 'T00:00:00',

  648.                 'EndDate' => $value['EndDate'] . 'T00:00:00',

  649.                 'Currency' => Yii::$app->params['ctrip']['currency_type'],

  650.             );

  651.             $RoomTypeList = array(

  652.                 'SetRoomPriceItems' => $SetRoomPriceItem,

  653.                 'HotelID' => $ctrip_hotel_id,        //Ctrip的酒店编号

  654.                 'Submitor' => YII::$app->params['ctrip']['submitor'],       //提交人，集团名拼音

  655.                 'Title' => '房价推送成功',

  656.                 'Priority' => 'N'    //是否优先处理，暂不用，默认为N

  657.             );

  658. 

  659.             $soap = new SoapService($RoomTypeList, 'SetRoomPrice', 'SetAdaperRoomPriceRequest', '1.2');

  660.             $rs = $soap->exec(3, $post['user_id']);

  661.             unset($PriceInfos['PriceInfos']);

  662.             if (!$rs['flag'] || $rs['data']['RequestResult']['RequestResult'] != 0) {

  663.                 //警报：RTX通知

  664.                 $arr = array(

  665.                     "agentid" => 1000002,

  666.                     "title" => '(报警)房价推送失败：',

  667.                     "msg" => json_encode($post),

  668.                     "touser" => $this->_developerList,

  669.                 );

  670.                 zOfficeWechat::sendMsg($arr);

  671.             }

  672.         }

  673. 

  674.         return Json::encode($rs);

  675.     }

  676. 

  677.     /**

  678.      * User:Steven

  679.      * Desc:将日期按照连续不连续进行分组

  680.      * @param $data

  681.      * @return array

  682.      */

  683.     public function dateGroup($data)

  684.     {

  685.         //将房态按时间分段

  686.         $dayZone = [];

  687.         $firstDay = '';

  688.         $current = 0;

  689.         foreach ($data as $key => $value) {

  690.             if ($key == 0) {

  691.                 $dayZone[$current]['StartDate'] = $value['RUN_DATE'];

  692.                 $dayZone[$current]['EndDate'] = $value['RUN_DATE'];

  693.                 $firstDay = $value['RUN_DATE'];

  694.             } else {

  695.                 $firstDay = strtotime($firstDay);

  696.                 $secondDay = strtotime($value['RUN_DATE']);

  697.                 $days = ($secondDay - $firstDay) / 86400;

  698.                 //用于判断当前日期与该组数据的StartDate差值是否是120，一次最多推送120天数据，大于120天分组推送

  699.                 $diff = ($firstDay - strtotime($dayZone[$current]['StartDate'])) / 86400 / 90;

  700.                 if ($days == 1 && !($diff > 0 && is_int($diff))) {

  701.                     $dayZone[$current]['EndDate'] = $value['RUN_DATE'];

  702.                 } elseif ($diff > 0 && is_int($diff)) {

  703.                     $current++;

  704.                     $dayZone[$current]['StartDate'] = $value['RUN_DATE'];

  705.                     $dayZone[$current]['EndDate'] = $value['RUN_DATE'];

  706.                 } elseif ($days < 1) {

  707.                     return ['code' => 0, 'msg' => '子房型数据重复'];

  708.                 } else {

  709.                     $current++;

  710.                     $dayZone[$current]['StartDate'] = $value['RUN_DATE'];

  711.                     $dayZone[$current]['EndDate'] = $value['RUN_DATE'];

  712.                 }

  713.                 $firstDay = $value['RUN_DATE'];

  714.             }

  715.         }

  716. 

  717.         return $dayZone;

  718.     }

  719. 

  720.     /**

  721.      * User:Steven

  722.      *

  723.      * Desc:UpdateRoomQuantity（更新保留房数量）

  724.      * 1-1.接口调用方：合作方

  725.      * 1-2.接口返回方：携程

  726.      * 1-3.调用频率：限制， 建议10次/分钟，并会视情况调整

  727.      * 1-4.使用说明：携程建议当房量变化时，立即进行推送。携程方面是异步处理房量更新操作。

  728.      * 一个请求最多只允许更新 10 个酒店下的房型，一个请求只允许 120 天内的房量， 一个请求 只允许发送少于 100 个房型。

  729.      *

  730.      *  param StartDate

  731.      *  param EndDate

  732.      *  param hotel_id

  733.      *  param parent_room_type

  734.      *  param room_type

  735.      *

  736.      * @return mixed

  737.      *

  738.      */

  739.     public function actionUpdateRoomQuantity(array $param = [])

  740.     {

  741.         $this->post = ($this->post == []) ? Yii::$app->request->post() : $this->post;

  742.         if (!empty($param))

  743.             $this->post = $param;

  744.         $post = $this->post;

  745.         $runHotelDsitrib = new RunHotelDistrib();

  746.         $roomQuantity = $runHotelDsitrib->getRoomQuantity($post);

  747.         if ($roomQuantity['code'] != 0) {

  748.             //警报：RTX通知

  749.             if ($roomQuantity['code'] == 1 || $roomQuantity['code'] == 3) {

  750.                 $arr = array(

  751.                     "agentid" => 1000002,

  752.                     "title" => $roomQuantity['info'],

  753.                     "msg" => json_encode($post),

  754.                     "touser" => $this->_developerList,

  755.                 );

  756.                 zOfficeWechat::sendMsg($arr);

  757.             }

  758. 

  759.             return false;

  760.         }

  761. 

  762.         $RoomQuantityEntityList = array();

  763.         $dateZone = $this->divisionDate($roomQuantity['data']);

  764.         if (empty($roomQuantity['data']) || empty($dateZone)) {

  765.             return false;

  766.         }

  767. 

  768.         $push_rs = array();

  769.         $ctrip_room_id = RoomRelation::getChannelId($roomQuantity['data'][0]['ROOM_ID'], Yii::$app->params['ctrip']['relation_supplier_id']); //携程的房型ID

  770.         $ctrip_hotel_id = HotelRelation::getChannelId($post['hotel_id'], Yii::$app->params['ctrip']['relation_supplier_id']);    //携程的房型ID

  771.         foreach ($dateZone as $key => $val) {

  772.             foreach ($roomQuantity['data'] as $k => $value) {

  773.                 if ($val['StartDate'] <= $value['RUN_DATE'] && $val['EndDate'] >= $value['RUN_DATE']) {

  774.                     if ($value['RUN_STATUS'] == 329 || $value['AUTHORITY_STATUS'] == 0 || $value['IS_ONSALE'] == 0 || $value['BASE_ROOM_IS_ONSALE'] == 0 || $value['BASE_ROOM_RUN_STATUS'] != 1) {    //关房操作（如果没有临时保留房须推送0；关房的时候，需要同时推送保留房数量 为0）

  775.                         $RoomQuantityEntity['RoomQuantityEntity'] = array(

  776.                             'RoomTypeID' => $ctrip_room_id,     //Ctrip 房型编号

  777.                             'RoomQuantityCount' => '0',  //临时保留房数

  778.                             'RoomQuantityUpdateType' => 'AvailableCount',     //临时保留房数更 新方式

  779.                             'StartDate' => $value['RUN_DATE'] . 'T00:00:00',  //开始时间

  780.                             'EndDate' => $value['RUN_DATE'] . 'T00:00:00',

  781.                             'FreeSale' => 'F', //Free Sale  目前只支持以下 两种： T F

  782.                             'ReserveTime' => Utils::timeHour($value['ReserveTime']),  //保留房最晚预订 时间

  783.                             'RoomStatus' => 'N',   //保留房不可超  N,满房 NoRoom;G,良好 Good;L,不可超 Limited  G表示开房，N表示关房，L表示保留房限量售卖

  784.                             'Restorable' => 'F',   //保留房可恢复 目前只支持以下 两种：T，F

  785.                         );

  786.                     } else {

  787.                         if ($value['OVERSELL_FLAG'] != 1) {  // 1：允许超卖 0：不允许超卖

  788.                             if ($value['REMAINING_COUNT'] <= 0) {  //限量售卖（不超卖）的情况下 且库存为0 直接推成关房

  789.                                 $RoomStatus = 'N';  //G表示开房，N表示关房，L表示保留房限量售卖

  790.                             } else {

  791.                                 $RoomStatus = 'L';  //G表示开房，N表示关房，L表示保留房限量售卖

  792.                             }

  793.                         } else {

  794.                             $RoomStatus = 'G';

  795.                         }

  796.                         $RoomQuantityEntity['RoomQuantityEntity'] = array(

  797.                             'RoomTypeID' => $ctrip_room_id,     //Ctrip 房型编号

  798.                             'RoomQuantityCount' => $value['REMAINING_COUNT'] < 0 ? 0 : $value['REMAINING_COUNT'],  //临时保留房数

  799.                             'RoomQuantityUpdateType' => 'AvailableCount',     //临时保留房数更 新方式

  800.                             'StartDate' => $value['RUN_DATE'] . 'T00:00:00',  //开始时间

  801.                             'EndDate' => $value['RUN_DATE'] . 'T00:00:00',

  802.                             'FreeSale' => 'F', //Free Sale  目前只支持以下 两种： T F

  803.                             'ReserveTime' => Utils::timeHour($value['ReserveTime']),  //保留房最晚预订 时间

  804.                             'RoomStatus' => $RoomStatus,   //保留房不可超  N,满房 NoRoom;G,良好 Good;L,不可超 Limited  G表示开房，N表示关房，L表示保留房限量售卖

  805.                             'Restorable' => 'F',   //保留房可恢复 目前只支持以下 两种：T，F

  806.                         );

  807.                     }

  808.                     $RoomQuantityEntityList['room_info'][] = $RoomQuantityEntity;

  809.                     unset($roomQuantity['data'][$k]);

  810.                 }

  811.             }

  812. 

  813.             if (empty($RoomQuantityEntityList['room_info'])) {

  814.                 continue;

  815.             }

  816.             //一个酒店

  817.             $hotel_id['HotelID'] = $ctrip_hotel_id;

  818.             $SequenceID = \Yii::$app->cache->get('Ctrip_SequenceID');

  819.             if (!$SequenceID) {

  820.                 $rs = \Yii::$app->cache->set('Ctrip_SequenceID', time());

  821.                 if (!$rs) {

  822.                     $arr = array(

  823.                         "agentid" => 1000002,

  824.                         "title" => '保留房消息序号SequenceID写入缓存失败',

  825.                         "msg" => json_encode($post),

  826.                         "touser" => $this->_developerList,

  827.                     );

  828.                     zOfficeWechat::sendMsg($arr);

  829. 

  830.                     return false;

  831.                 }

  832.                 $SequenceID = \Yii::$app->cache->get('Ctrip_SequenceID');

  833.             }

  834.             \Yii::$app->cache->set('Ctrip_SequenceID', $SequenceID + 1);

  835. 

  836.             $UpdateRoomQuantityRequest = array(

  837.                 'SequenceID' => $SequenceID,

  838.                 'HotelIDList' => array(

  839.                     'HotelIDEntity' => $hotel_id,

  840.                 ),

  841.                 'RoomQuantityEntityList' => $RoomQuantityEntityList['room_info'],

  842.                 'Editer' => YII::$app->params['ctrip']['submitor'],

  843.             );

  844.             $soap = new SoapService($UpdateRoomQuantityRequest, 'UpdateRoomQuantity', 'UpdateRoomQuantityRequest', '1.2');

  845.             $res = $soap->exec(2, $post['user_id']);

  846.             if (!$res['flag'] || $res['data']['Response']['CtripSoapResponse']['ResultCode'] != 0) {

  847.                 $result['code'] = 1;

  848.                 $result['msg'] = urlencode('保留房数量推送失败！');

  849.                 $result['data'] = $res['data']['Response']; //将$begin_date, $end_date, $hotel_id, $base_room_id, $room_id信息拼接起来触发报警机制

  850.                 $arr = array(

  851.                     "agentid" => 1000002,

  852.                     "title" => '(报警)更新保留房数量接口：',

  853.                     "msg" => '保留房数量推送失败！' . "\n" . '错误信息：' . $res['data']['Response']['CtripSoapResponse']['Message'],            //json_encode($post),

  854.                     "touser" => $this->_developerList,

  855.                 );

  856.                 zOfficeWechat::sendMsg($arr);

  857.             }

  858.             unset($RoomQuantityEntityList['room_info']);

  859.             $push_rs[] = $res;

  860.         }

  861. 

  862.         return json_encode($push_rs);

  863.     }

  864. 

  865.     /**

  866.      * User: wangxj

  867.      *

  868.      * 将时间分段进行推送，因为携程不允许中间日期不连续

  869.      *  param int $hotel_id

  870.      *  param int $parent_room_type

  871.      *  param int $room_type

  872.      *  param string $StartDate

  873.      *  param string $EndDate

  874.      * @param

  875.      *

  876.      * @return string

  877.      *

  878.      */

  879.     public function actionSetRoomInfo(array $param = [])

  880.     {

  881.         $this->post = ($this->post == []) ? Yii::$app->request->post() : $this->post;

  882.         if (!empty($param))

  883.             $this->post = $param;

  884.         $post = $this->post;

  885.         $room = OperaHotelRoom::findOne(['HOTEL_ID' => $post['hotel_id'], 'PARENT_ROOM_TYPE' => $post['parent_room_type'], 'ROOM_TYPE' => $post['room_type'], 'CANCEL_FLAG' => 0]);

  886.         if ($room == null) {

  887.             return json_encode(['code' => 1, 'msg' => '子房型获取失败酒店id: ' . $post['hotel_id'] . ', 子房型id:' . $post['room_type']]);

  888.         }

  889.         $stocks = RunHotelDistrib::find()

  890.             ->select(['DISTINCT(RUN_DATE)', 'CREATE_USER_ID', 'CREATE_TIME', 'UPDATE_USER_ID', 'UPDATE_TIME', 'DISTRIB_ID', 'HOTEL_ID', 'BASE_ROOM_TYPE', 'ROOM_TYPE',

  891.                 'REMAINING_COUNT', 'SALED_COUNT', 'PROD_PRICE', 'CUS_PRICE', 'RUN_STATUS', 'OVERSELL_FLAG', 'CONSUME_STOCK_TYPE'])

  892.             ->where(['HOTEL_ID' => $post['hotel_id'], 'BASE_ROOM_TYPE' => $post['parent_room_type'], 'ROOM_TYPE' => $post['room_type'],

  893.                 'DISTRIB_ID' => Yii::$app->params['ctrip']['supplier_id']])

  894.             ->andFilterWhere(['between', 'RUN_DATE', $post['StartDate'], $post['EndDate']])

  895.             ->orderBy('RUN_DATE')

  896.             //            -> createCommand() -> getRawSql();

  897.             ->all();

  898.         //将房态按时间分段

  899.         $dayZone = [];

  900.         $firstDay = '';

  901.         $current = 0;

  902.         foreach ($stocks as $key => $stock) {

  903.             if ($key == 0) {

  904.                 $dayZone[$current]['StartDate'] = $stock['RUN_DATE'];

  905.                 $dayZone[$current]['EndDate'] = $stock['RUN_DATE'];

  906.                 $firstDay = $stock['RUN_DATE'];

  907.             } else {

  908.                 $firstDay = strtotime($firstDay);

  909.                 $secondDay = strtotime($stock['RUN_DATE']);

  910.                 $days = ($secondDay - $firstDay) / 86400;

  911.                 $diff = ($firstDay - strtotime($dayZone[$current]['StartDate'])) / 86400 / 90;

  912.                 if ($days == 1 && !($diff > 0 && is_int($diff))) {

  913.                     $dayZone[$current]['EndDate'] = $stock['RUN_DATE'];

  914.                 } elseif ($diff > 0 && is_int($diff)) {

  915.                     $current++;

  916.                     $dayZone[$current]['StartDate'] = $stock['RUN_DATE'];

  917.                     $dayZone[$current]['EndDate'] = $stock['RUN_DATE'];

  918.                 } elseif ($days < 1) {

  919.                     return json_encode(['code' => 1, 'msg' => '子房型数据重复，酒店：' . $post['hotel_id'] . "\n基础房型id：" . $post['parent_room_type'] . "\n子房型id：" . $post['room_type'] . "\n房型日期：" . $stock['RUN_DATE']]);

  920.                 } else {

  921.                     $current++;

  922.                     $dayZone[$current]['StartDate'] = $stock['RUN_DATE'];

  923.                     $dayZone[$current]['EndDate'] = $stock['RUN_DATE'];

  924.                 }

  925.                 $firstDay = $stock['RUN_DATE'];

  926.             }

  927.         }

  928. 

  929.         $result = ['code' => 0];

  930.         //将分段后的时间分别推送房态

  931.         foreach ($dayZone as $item) {

  932.             $res = $this->pushRoomInfo($room, $item['StartDate'], $item['EndDate']);

  933.             if ($res['code'] != 0) {

  934.                 $result = $res;

  935.             }

  936.         }

  937. 

  938.         return Json::encode($result);

  939.     }

  940. 

  941.     /**

  942.      * User: wangxj

  943.      *

  944.      * 推送房态

  945.      * @param OperaHotelRoom $room

  946.      * @param string $StartDate

  947.      * @param string $EndDate

  948.      * @param

  949.      *

  950.      * @return array

  951.      *

  952.      */

  953.     protected function pushRoomInfo($room, $StartDate, $EndDate)

  954.     {

  955.         $actionName = 'SetRoomInfo';

  956.         $post = $this->post;

  957. 

  958.         $post['Spider_room'] = $room->ID;

  959.         $post['StartDate'] = $StartDate;

  960.         $post['EndDate'] = $EndDate;

  961.         $model = new CtripRoomInfo();

  962.         if ($model->load($post, '') && $model->validate()) {

  963.             //将 CtripRoomInfo对象中的数据作为房态粒度进行推送

  964.             $data_xml['StartDate'] = $model->StartDate . 'T00:00:00';

  965.             $data_xml['EndDate'] = $model->EndDate . 'T00:00:00';

  966.             $data_xml['RoomID'] = $model->RoomID;

  967.             $data_xml['RoomInfoItems'] = $model->RoomInfoItems;

  968.             $soap = new SoapService($data_xml, $actionName, $actionName . 'Request');

  969.             $res = $soap->exec(3, $post['user_id']);

  970.             if ($res['data']['RequestResult']['ResultCode'] == 0) {

  971.                 $result['code'] = 0;

  972.             } else {

  973.                 $result['code'] = $res['data']['RequestResult']['ResultCode'];

  974.                 $result['msg'] = $res['data']['RequestResult']['Message'];

  975.             }

  976.         } else {

  977.             $result['code'] = 1;

  978.             $result['msg'] = Utils::getModelError($model);

  979.         }

  980. 

  981.         return $result;

  982. 

  983.     }

  984. 

  985.     /**

  986.      * User: wangxj

  987.      *

  988.      * 保存日志方便查询

  989.      * @param string $Invoketype

  990.      * @param string $string

  991.      *

  992.      */

  993.     protected function writeLog($Invoketype, $string)

  994.     {

  995.         $userIp = Yii::$app->request->userIP;

  996.         $string = date('Y-m-d H:i:s') . " $Invoketype " . "【" . $userIp . "】" . PHP_EOL . $string . PHP_EOL;

  997.         if (!file_exists(__DIR__ . '/../../../runtime/logs/soap/receive')) {

  998.             mkdir(__DIR__ . '/../../../runtime/logs/soap/receive', 0777, true);

  999.         }

  1000.         file_put_contents(__DIR__ . '/../../../runtime/logs/soap/receive/' . date('Y-m-d') . '.log', $string, FILE_APPEND);

  1001.     }

  1002. 

  1003.     /**

  1004.      * @param \yii\base\Action $action

  1005.      * @param mixed $result

  1006.      * @return mixed

  1007.      */

  1008.     public function afterAction($action, $result)

  1009.     {

  1010.         //发送rtx

  1011.         $tmp_result = json_decode($result, true);

  1012.         if (isset($tmp_result['code']) && $tmp_result['code'] != '0' && !in_array($action->id, ['set-room-price', 'update-room-quantity'])) {

  1013.             //获取mapping失败，不发送rtx，又没有标识，以文字区别

  1014.             if (isset($tmp_result['msg']) && $tmp_result['msg'] != '获取mapping失败') {

  1015.                 $arr = array(

  1016.                     "agentid" => 1000002,

  1017.                     "title" => $action->id . ' code ：' . $tmp_result['code'] . ' msg: ' . (isset($tmp_result['msg']) ? $tmp_result['msg'] : '无msg字段'),

  1018.                     "msg" => json_encode($this->data) . '\n' . json_encode($this->post),

  1019.                     "touser" => $this->_developerList,

  1020.                 );

  1021.                 zOfficeWechat::sendMsg($arr);

  1022.             }

  1023.         }

  1024.         $endTime = microtime(TRUE);

  1025.         $scTime = $endTime - $this->startTime;

  1026.         $incrementTime = round(floatval($scTime), 3);//时间差

  1027.         $string = date('Y-m-d H:i:s', time()) . '  ';

  1028.         $string .= $_SERVER['REQUEST_URI'] . PHP_EOL;

  1029.         $body = file_get_contents("php://input");

  1030.         if (empty($body) == false) {

  1031.             if (is_array($body)) {

  1032.                 $string .= 'body : ' . json_encode($body) . PHP_EOL;

  1033.             } else {

  1034.                 $string .= 'body : ' . $body . PHP_EOL;

  1035.             }

  1036.         }

  1037.         $string .= 'PUT : ' . $result . PHP_EOL;

  1038.         $string .= 'time：' . $incrementTime . 's' . PHP_EOL . PHP_EOL;

  1039. 

  1040.         //        file_put_contents(__DIR__ . '/../../../runtime/logs/getSoap/' . date('Y-m-d') . '.log', $string, FILE_APPEND);

  1041.         return parent::afterAction($action, $result);

  1042.     }

  1043. 

  1044.     public function divisionDate($data)

  1045.     {

  1046.         //将房态按时间分段

  1047.         $dayZone = [];

  1048.         $firstDay = '';

  1049.         $current = 0;

  1050.         foreach ($data as $key => $value) {

  1051.             if ($key == 0) {

  1052.                 $dayZone[$current]['StartDate'] = $value['RUN_DATE'];

  1053.                 $dayZone[$current]['EndDate'] = $value['RUN_DATE'];

  1054.                 $firstDay = $value['RUN_DATE'];

  1055.             } else {

  1056.                 $firstDay = strtotime($firstDay);

  1057.                 //用于判断当前日期与该组数据的StartDate差值是否是120，一次最多推送120天数据，大于120天分组推送

  1058.                 $diff = ($firstDay - strtotime($dayZone[$current]['StartDate'])) / 86400 / 99;

  1059.                 if ($diff < 1) {

  1060.                     $dayZone[$current]['EndDate'] = $value['RUN_DATE'];

  1061.                 } else {

  1062.                     $current++;

  1063.                     $dayZone[$current]['StartDate'] = $value['RUN_DATE'];

  1064.                     $dayZone[$current]['EndDate'] = $value['RUN_DATE'];

  1065.                 }

  1066.                 $firstDay = $value['RUN_DATE'];

  1067.             }

  1068.         }

  1069. 

  1070.         return $dayZone;

  1071.     }

  1072. 

  1073. }

  1074. 

  1075. ?>