nizongfeng
/
ZZCX_yii
1
0
Förgrening 0
Kod Ärenden 0 Pull-förfrågningar 0 Släpp 0 Wiki Aktiviteter
Du kan inte välja fler än 25 ämnen Ämnen måste starta med en bokstav eller siffra, kan innehålla bindestreck ('-') och vara max 35 tecken långa.
3 Incheckningar
1 Gren
96 MiB
 
 
 
 
 
 
Gren: master
Grenar Taggar
${ item.name }
Skapa branchen ${ searchTerm }
från 'master'
${ noResults }
ZZCX_yii/backend/modules/hotel/controllers/AliController.php

682 rader
32 KiB
Rå Permalänk Blame Historik 

  1. <?php

  2. /**

  3.  * Created by PhpStorm.

  4.  * User: Steven

  5.  * Date: 2017/10/10

  6.  * Time: 14:42

  7.  *

  8.  * 阿里-飞猪（酒店）对接

  9.  */

  10. 

  11. namespace backend\modules\hotel\controllers;

  12. 

  13. use backend\common\Utils;

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

  15. use backend\modules\hotel\models\Ali\XhotelRoomtypeUpdateRequest;

  16. use backend\modules\hotel\models\Ali\XhotelUpdateRequest;

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

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

  19. use backend\modules\hotel\models\OperaHotelBaseRoom;

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

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

  22. use backend\modules\hotel\models\Ali\XhotelRateplanUpdateRequest;

  23. use backend\modules\hotel\models\Ali\XhotelRateUpdateRequest;

  24. use backend\modules\hotel\models\Ali\XhotelRatesUpdateRequest;

  25. use backend\modules\hotel\models\Ali\XhotelRateRelationshipwithroomGetRequest;

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

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

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

  29. use common\models\Msg;

  30. use Yii;

  31. use yii\filters\AccessControl;

  32. use backend\modules\hotel\models\Ali\XhotelOrderUpdateRequest;

  33. 

  34. 

  35. class AliController extends BaseController

  36. {

  37.     public $enableCsrfValidation = false;

  38.     public $agent_id = self::AGENT_ALI_HOTEL_ID;

  39. 

  40.     /*public function behaviors()

  41.     {

  42.         return [

  43.             'access' => [

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

  45.                 'rules' => [

  46.                     [

  47.                         'ips' => ['101.226.248.76' //阿里IP访问白名单

  48.                             ,'127.0.0.1', '106.14.56.77', '180.168.4.58', '139.224.30.29'

  49.                         ],

  50.                         'allow' => true,

  51.                     ],

  52.                 ],

  53.             ],

  54.         ];

  55.     }*/

  56. 

  57.     /**

  58.      * Author:Steven

  59.      * Desc:添加酒店或更新酒店

  60.      * taobao.xhotel.add (酒店新增接口（ID重复自动更新）)

  61.      */

  62.     public function actionAddHotel($hotel_id = 0)

  63.     {

  64.         $id = empty($hotel_id) ? Yii::$app->request->get('hotel_id') : $hotel_id;

  65.         $hotel = new OperaHotel();

  66.         $hotel_info = $hotel->getPushHotelInfo($id);

  67.         //判断该酒店的直连渠道有没有阿里

  68.         $channel_arr = explode(',', $hotel_info['DRIECT_CONNNECT_CHANNEL']);

  69.         if (!in_array(Yii::$app->params['ali']['relation_supplier_id'], $channel_arr)) {

  70.             return json_encode(['code' => 203, 'msg' => '该酒店的直连渠道中不包含阿里飞猪，请确认', 'data' => '']);

  71.         }

  72.         // 转换星级表示

  73.         $star = $this->hotelStarConversions($hotel_info['STAR_LEVEL']);

  74.         // 酒店直连信息查询

  75.         $already_connenct = HotelRelation::findOne(['HotelId' => $id, 'ChannelId' => Yii::$app->params['ali']['relation_supplier_id']]);

  76. 

  77.         $param = ['outer_id' => "{$hotel_info['HOTEL_ID']}", 'name' => "{$hotel_info['HOTEL_NAME']}", 'city' => "{$hotel_info['POSTCODE']}", 'address' => "{$hotel_info['HOTEL_ADDRESS']}", 'tel' => '021-33280550', 'star' => "$star"];

  78.         if ($already_connenct) {

  79.             $param['status'] = $hotel_info['HOTEL_STATUS'] == 0 ? -2 : 0;

  80.             $req = new XhotelUpdateRequest(['scenario' => 'update_hotel']);

  81.         } else {

  82.             $req = new XhotelUpdateRequest();

  83.             $already_connenct = new HotelRelation();

  84.         }

  85. 

  86.         if ($req->load($param, '') && $req->validate()) {

  87.             $rs = new AliExecute();

  88.             $res = $rs->execute($req, true);

  89.             if (!$res->xhotel) {

  90.                 return json_encode(['code' => $res->code, 'msg' => XhotelUpdateRequest::ERROR_MSG[$res->code], 'data' => '']);

  91.             }

  92. 

  93.             // 阿里直连成功，本地建立关联关系

  94.             $params = array('ChannelHotelId' => (string)$res->xhotel->hid, 'HotelId' => $id, 'ChannelId' => Yii::$app->params['ali']['relation_supplier_id']);

  95.             if ($already_connenct->load($params, '') && $already_connenct->validate()) {

  96.                 if ($already_connenct->save()) {

  97.                     $logger = new TopLogger;

  98.                     $logger->log(array(

  99.                         date("Y-m-d H:i:s"),

  100.                         '阿里渠道新增直连酒店：' . __FUNCTION__ . json_encode($res)

  101.                     ));

  102.                     $result = ['code' => 0, 'msg' => '推送酒店成功', 'data' => $res];

  103.                 } else {

  104.                     $result = ['code' => 204, 'msg' => 'mapping失败', 'data' => $res];

  105.                 }

  106.                 return json_encode($result);

  107.             }

  108.         } else {

  109.             $logger = new TopLogger;

  110.             $msg = '';

  111.             if (!empty($req->getFirstErrors())) {

  112.                 $msg = $req->getErrorMsg();

  113.             }

  114.             $logger->log(array(

  115.                 date("Y-m-d H:i:s"),

  116.                 '参数验证失败：' . __FUNCTION__ . $msg

  117.             ));

  118.         }

  119.     }

  120. 

  121.     /**

  122.      * @Author wanglg

  123.      * @Desc 房型添加、修改接口（新房型添加，重复房型修改）

  124.      * @param hotel_id // 酒店ID

  125.      * @param PARENT_ROOM_TYPE // 基础房型房型ID

  126.      * @param room_type // 子房型ID

  127.      */

  128.     public function actionRoomUpdate(array $params = [])

  129.     {

  130.         $request = empty($params) ? Yii::$app->request->post() : $params;

  131. 

  132.         // 通过渠道基础房型和子房型type查询房型，将子房型信息推送( 推送前判断是否直连，直连则解除关联，未直连则推送)

  133.         $hotel_is_mapping = HotelRelation::findOne(['HotelId' => $request['hotel_id'], 'ChannelId' => Yii::$app->params['ali']['relation_supplier_id']]);

  134. 

  135. //        首先判断酒店是否直连

  136.         if (!$hotel_is_mapping) {

  137.             return json_encode(array('code' => 207, 'msg' => '该房型所属酒店还未直连', 'data' => ''));

  138.         }

  139. 

  140.         //推送基础房型

  141.         $room_info = OperaHotelBaseRoom::find()

  142.             ->select(['a.MAIN_ID', 'a.HOTEL_ID', 'a.BASE_ROOM_NAME', 'a.BED_TYPE', 'b.ChannelRoomId', 'c.HOTEL_NAME'])

  143.             ->leftJoin('channel_room_relation as b', 'a.MAIN_ID=b.RoomId and b.ChannelId=' . Yii::$app->params['ali']['relation_supplier_id'])

  144.             ->leftJoin('opera_hotel c', 'a.HOTEL_ID=c.HOTEL_ID and a.cancel_flag=0')

  145.             ->where(['a.MAIN_ID' => $request['parent_room_type'], 'a.HOTEL_ID' => $request['hotel_id']])

  146.             ->from('opera_hotel_base_room as a')

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

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

  149. 

  150.         $bed_name = $this->getBedTypeName($room_info['BED_TYPE']);

  151. 

  152.         $param = array('outer_id' => (string)$room_info['MAIN_ID'], 'hotel_code' => (string)$room_info['HOTEL_ID'], 'name' => $room_info['BASE_ROOM_NAME'], 'bed_type' => $bed_name);

  153. 

  154.         if ($room_info['ChannelRoomId']) {

  155.             $param['status'] = $room_info['IS_ONSALE'] == 1 ? 0 : -2;

  156.             $scenario = 'update_room';

  157.         } else {

  158.             $scenario = 'add_room';

  159.         }

  160. 

  161.         $room = new XhotelRoomtypeUpdateRequest(['scenario' => $scenario]);

  162. 

  163.         if ($room->load($param, '') && $room->validate()) {

  164.             $rs = new AliExecute();

  165.             $res = $rs->execute($room, true);

  166.             if ($res->code != 0) {

  167.                 return json_encode(['code' => 1, 'msg' => XhotelRoomtypeUpdateRequest::ERROR_MSG[$res->code], 'data' => '']);

  168.             }

  169.             $logger = new TopLogger;

  170.             if (!$room_info['ChannelRoomId']) // 推送成功且未直连添加本地记录

  171.             {

  172.                 $channel_room_relation = new RoomRelation();

  173.                 $save_arr = array('channelRoomId' => (string)$res->xroomtype->rid, 'channelId' => Yii::$app->params['ali']['relation_supplier_id'], 'roomId' => $room_info['MAIN_ID']);

  174.                 $room_res = $channel_room_relation->mapping($save_arr);

  175.                 if ($room_res) {

  176.                     $logger->log(array(

  177.                         date("Y-m-d H:i:s"),

  178.                         '阿里渠道直连房型成功：' . __FUNCTION__ . json_encode($res)

  179.                     ));

  180.                     return json_encode(['code' => 0, 'msg' => 'success', 'data' => $res]);

  181.                 } else {

  182.                     $this->sendAliMsgToRtx('【阿里直连】阿里渠道直连房型成功，建立本地关联关系失败，渠道房型id:',

  183.                         "酒店名称：" . $room_info['HOTEL_NAME'] . "\n房型名称：" . $room_info['BASE_ROOM_NAME'] . "\n渠道房型ID：" . $res->xroomtype->rid, 2);

  184.                     $logger->log(array(

  185.                         date("Y-m-d H:i:s"),

  186.                         '阿里渠道直连房型失败：' . __FUNCTION__ . json_encode($res)

  187.                     ));

  188.                     return json_encode(['code' => 0, 'msg' => 'success', 'data' => $res]);

  189.                 }

  190.             } /*else {

  191.                 if ($is_connect->delete()) {

  192.                     $logger->log(array(

  193.                         date("Y-m-d H:i:s"),

  194.                         '阿里渠道解除直连房型成功：' . __FUNCTION__ . json_encode($res)

  195.                     ));

  196.                     return json_encode(['code' => 200, 'msg' => '阿里渠道解除直连房型成功', 'data' => $res]);

  197.                 } else {

  198.                     $logger->log(array(

  199.                         date("Y-m-d H:i:s"),

  200.                         '阿里渠道解除直连房型失败, 本地记录删除失败：' . __FUNCTION__ . json_encode($res)

  201.                     ));

  202.                     return json_encode(['code' => 205, 'msg' => '阿里渠道解除直连房型失败', 'data' => $res]);

  203.                 }

  204.             }*/

  205.         } else {

  206.             $logger = new TopLogger;

  207.             $msg = '';

  208.             if (!empty($room->getFirstErrors())) {

  209.                 $msg = $room->getErrorMsg();

  210.             }

  211. 

  212.             $logger->log(array(

  213.                 date("Y-m-d H:i:s"),

  214.                 '参数验证失败：' . __FUNCTION__ . $msg

  215.             ));

  216. 

  217.             return json_encode(['code' => 1, 'msg' => $msg]);

  218.         }

  219.     }

  220. 

  221.     /**

  222.      * Author:Steven

  223.      * @Desc 产品库接口  支持房价信息的新增和修改

  224.      * taobao.xhotel.rateplan.add

  225.      * 接口返回值 rpid

  226.      * @param hotel_id //酒店ID

  227.      * @param parent_room_type //基础房型ID

  228.      * @param room_type //子房型ID

  229.      * @return bool

  230.      */

  231.     public function actionUpdateRateplan()

  232.     {

  233.         //当修改子房型、变更子房型的直连开关的时候需要调用该接口

  234.         $request = Yii::$app->request->post();

  235.         if (!isset($request['hotel_id']) || !isset($request['parent_room_type']) || !isset($request['room_type'])) {

  236.             return json_encode(['code' => 207, 'msg' => '参数错误', 'data' => '']);

  237.         }

  238.         $user_id = empty(Yii::$app->user->id) ? $request['user_id'] : Yii::$app->user->id;

  239.         //先判断酒店是否与渠道直连，房型是否直连

  240.         $diret = OperaHotelRoom::find()->select(['a.ID', 'a.HOTEL_ID', 'a.PARENT_ROOM_TYPE', 'c.ChannelHotelId', 'b.ChannelRoomId', 'a.RP_ID'])

  241.             ->leftJoin('channel_room_relation b', 'a.PARENT_ROOM_TYPE=RoomId and b.ChannelId=' . Yii::$app->params['ali']['relation_supplier_id'])

  242.             ->leftJoin('channel_hotel_relation c', 'a.HOTEL_ID=c.HotelId and c.ChannelId=' . Yii::$app->params['ali']['relation_supplier_id'])

  243.             ->from('opera_hotel_room a')

  244.             ->where([

  245.                 'a.HOTEL_ID' => $request['hotel_id'],

  246.                 'a.PARENT_ROOM_TYPE' => $request['parent_room_type'],

  247.                 'a.ROOM_TYPE' => $request['room_type'],

  248.                 'a.CANCEL_FLAG' => 0

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

  250.         if (is_null($diret['ChannelHotelId']) || is_null($diret['ChannelRoomId'])) {

  251.             $msg = is_null($diret['ChannelHotelId']) ? '【阿里】该酒店未直连' : (is_null($diret['ChannelRoomId']) ? '【阿里】该房型未直连' : '');

  252.             return json_encode(['code' => 1, 'msg' => $msg, 'data' => '']);

  253.         }

  254.         //构造RP接口需要的数据 // 1 为 开启，2为关闭//借助参数修改rp，不能根据RP是否存在判断打开或关闭RP，存在修改的情况

  255.         $status = empty($request['status']) || is_null($request['status']) ? 1 : $request['status'];

  256.         $ohr = OperaHotelRoom::find()->select(['a.ID', 'a.HOTEL_ID', 'a.PARENT_ROOM_TYPE', 'a.ROOM_TYPE', 'a.ROOM_NAME', 'a.OCCUPANCY_LIMIT', 'a.BREAKFAST_INCLUDE', 'a.IS_ONSALE',

  257.             'a.LASTEST_BOOK_TIME', 'a.LASTEST_CANCEL_DAY', 'a.INNER_IDENTIFY', 'c.EARLIEST_CHECKIN_TIME', 'c.LASTEST_BOOK_TIME as REMAIN_TIME', 'c.HOTEL_NAME', 'a.INNER_IDENTIFY', 'd.DISTRIB_ROOM_NAME'])

  258.             ->leftJoin('opera_hotel c', 'a.HOTEL_ID=c.HOTEL_ID and c.cancel_flag=0')

  259.             ->leftJoin('opera_room_distrib d', 'a.ID=d.ROOM_ID and d.CANCEL_FLAG=0 and d.DISTRIB_ID=' . Yii::$app->params['ali']['relation_supplier_id'])

  260.             ->where(['a.HOTEL_ID' => $request['hotel_id'],

  261.                 'a.PARENT_ROOM_TYPE' => $request['parent_room_type'],

  262.                 'a.ROOM_TYPE' => $request['room_type'],

  263.                 'a.CANCEL_FLAG' => 0])->from('opera_hotel_room a')->asArray()->one();

  264. 

  265.         $rp_name = '';

  266.         // 判断如果有渠道房型名称RP名称就不使用酒店内部标识

  267.         if (empty($ohr['DISTRIB_ROOM_NAME'])) {

  268.             $ohr['INNER_IDENTIFY'] = str_replace('）', ')', str_replace('（', '(', $ohr['INNER_IDENTIFY']));

  269.             preg_match_all("#\((.*?)\)#us", $ohr['INNER_IDENTIFY'], $inner_identify);

  270.             foreach ($inner_identify[1] as $item) {

  271.                 $rp_name .= $item . ' ';

  272.             }

  273.         } else {

  274.             $rp_name = $ohr['DISTRIB_ROOM_NAME'];

  275.         }

  276. 

  277.         $min_adv_hours = Utils::timeHour($ohr['LASTEST_BOOK_TIME']);

  278.         $param = array(

  279.             'rateplan_code' => "{$ohr['ID']}",

  280.             'name' => $rp_name == '' ? $ohr['INNER_IDENTIFY'] : $rp_name,

  281.             'payment_type' => '1',  //只支持：1：预付5：现付6: 信用住7:预付在线预约8:信用住在线预约。其中5,6,7,8四种类型需要申请权限

  282.             'breakfast_count' => $ohr['BREAKFAST_INCLUDE'],

  283.             'min_adv_hours' => "{$min_adv_hours}",//最小提前预定小时数，从入住当天的24点往前计算。例如如果这个字段设置了48，代表必须至少提前两天预定，那么如果想预定24号入住，,必须在23号零点前下单。

  284.             'end_time' => '', //产品每日结束销售时间

  285.             'cancel_policy' => '{"cancelPolicyType":2}',

  286.             'status' => "{$status}", //1：开启（默认）2：关闭。如果没传值那么默认默认值为1

  287.             'breakfast_cal' => '{"date": null,"startDate": "' . date('Y-m-d', time()) . '","endDate": "' . date('Y-m-d', strtotime('+3 month')) . '","breakfast_count":' . $ohr['BREAKFAST_INCLUDE'] . '}',

  288.             'guarantee_type' => '0',    //	担保类型，只支持： 0 无担保 1 峰时首晚担保 2峰时全额担保 3全天首晚担保 4全天全额担保

  289.             'out_rid' => "{$ohr['PARENT_ROOM_TYPE']}",  //外部房型id   基础房型ID

  290.             'out_hid' => "{$ohr['HOTEL_ID']}", //	外部酒店id

  291.             'operator' => Yii::$app->params['ali']['operator'],

  292.             'common_allot_release_time' => Utils::timeHour($ohr['REMAIN_TIME'])

  293.         );

  294.         $rateplan = new XhotelRateplanUpdateRequest(['scenario' => 'create']);

  295. 

  296.         if ($rateplan->load($param, '') && $rateplan->validate()) {

  297.             $rs = new AliExecute();

  298.             $res = $rs->execute($rateplan, true);

  299.             if ($res->code != 0) {

  300.                 return json_encode(['code' => 0, 'msg' => XhotelRateplanUpdateRequest::ERROR_MSG[$res->code], 'data' => '']);

  301.             }

  302.             return json_encode(['code' => 0, 'msg' => 'success', 'data' => $res->rpid]);

  303.         } else {

  304.             $logger = new TopLogger;

  305.             $msg = '';

  306.             if (!empty($rateplan->getFirstErrors())) {

  307.                 $msg = $rateplan->getErrorMsg();

  308.             }

  309.             $logger->log(array(

  310.                 date("Y-m-d H:i:s"),

  311.                 '参数验证失败：' . __FUNCTION__ . $msg . '--' . $user_id

  312.             ));

  313.         }

  314.     }

  315. 

  316. 

  317.     /**

  318.      * Author:Steven

  319.      * Desc:单个房型和房价的全量价格更新接口   第一次设置RP的时候会推送

  320.      */

  321.     public function actionRateUpdate()

  322.     {

  323.         $request = Yii::$app->request->post();

  324. 

  325.         if (!isset($request['hotel_id']) || !isset($request['parent_room_type']) || !isset($request['room_type'])) {

  326.             return json_encode(['code' => 207, 'msg' => '参数错误', 'data' => '']);

  327.         }

  328.         $user_id = empty(Yii::$app->user->id) ? $request['user_id'] : Yii::$app->user->id;

  329.         //先判断酒店是否与渠道直连，房型是否直连

  330.         $res = OperaHotelRoom::find()->select(['a.ID', 'a.HOTEL_ID', 'a.PARENT_ROOM_TYPE', 'c.ChannelHotelId', 'b.ChannelRoomId', 'a.RP_ID', 'd.HOTEL_NAME', 'a.ROOM_NAME', 'a.INNER_IDENTIFY'])

  331.             ->leftJoin('channel_room_relation b', 'a.PARENT_ROOM_TYPE=RoomId and b.ChannelId=' . Yii::$app->params['ali']['relation_supplier_id'])

  332.             ->leftJoin('channel_hotel_relation c', 'a.HOTEL_ID=c.HotelId and c.ChannelId=' . Yii::$app->params['ali']['relation_supplier_id'])

  333.             ->leftJoin('opera_hotel d', 'a.HOTEL_ID=d.HOTEL_ID and d.cancel_flag=0')

  334.             ->from('opera_hotel_room a')

  335.             ->where([

  336.                 'a.HOTEL_ID' => $request['hotel_id'],

  337.                 'a.PARENT_ROOM_TYPE' => $request['parent_room_type'],

  338.                 'a.ROOM_TYPE' => $request['room_type'],

  339.                 'a.CANCEL_FLAG' => 0

  340.             ])

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

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

  343. 

  344.         if (is_null($res['ChannelHotelId']) || is_null($res['ChannelRoomId']) || empty($res['RP_ID'])) {

  345.             //酒店或者房型未直连

  346.             $msg = is_null($res['ChannelHotelId']) ? '【阿里】该酒店未直连' : (is_null($res['ChannelRoomId']) ? '【阿里】该房型未直连' : '');

  347.             return json_encode(['code' => 1, 'msg' => $msg, 'data' => '']);

  348.         }

  349. 

  350.         $begin_date = date('Y-m-d', time());

  351.         $end_date = date('Y-m-d', strtotime('+3month'));

  352. 

  353.         // 查出该子房型的信息及渠道房型信息

  354.         $model = new RunHotelDistrib();

  355.         $data = $model->getAvailProduct($res['ID'], $begin_date, $end_date);

  356.         if (empty($data)) {

  357.             return false;

  358.         }

  359. 

  360.         //构造接口需要的数据

  361.         foreach ($data as $item) {

  362.             $inventory_price[] = array(

  363.                 'date' => $item['RUN_DATE'],  //日期必须为 T---T+180 日内的日期（T为当天），且不能重复

  364.                 'quota' => $item['REMAINING_COUNT'],//库存 int 类型 取值范围 0-999（数量库存）60000(状态库存关) 61000(状态库存开)

  365.                 'price' => $item['PROD_PRICE'] * 100,//价格 int类型 取值范围1-99999999 单位为分

  366.             );

  367.             if ($item['IS_ONSALE'] == 0 || $item['RUN_STATUS'] == 329 || $item['AUTHORITY_STATUS'] == 0 || $item['ROOM_IS_ONSALE'] == 0

  368.                 || $item['ROOM_RUN_STATUS'] == 0) {// 当子房型下线|渠道关房|渠道未授权|子房型关房，关闭价格

  369.                 $rate_status = 0;

  370.             } else {

  371.                 $rate_status = 1;

  372.             }

  373.             $rate_switch_cal[] = array(

  374.                 "date" => $item['RUN_DATE'], //开关状态控制的那一天

  375.                 "rate_status" => $rate_status,  //开关状态(0，关闭；1，打开)

  376.             );

  377.         }

  378. 

  379.         if (!isset($inventory_price)) {

  380.             return false;

  381.         }

  382. 

  383.         $inventory_price = array(  //每日价格和房价专有库存信息

  384.             'use_room_inventory' => false, //是否使用房型共享库存 ,false时：使用房价专有库存 此时要求价格和库存必填

  385.             'inventory_price' => $inventory_price

  386.         );

  387.         $param = array(

  388.             'out_rid' => "{$res['PARENT_ROOM_TYPE']}",  //卖家房型ID

  389.             'rateplan_code' => "{$res['ID']}",  //商家价格计划编码

  390.             'inventory_price' => json_encode($inventory_price),

  391.             'rate_switch_cal' => json_encode($rate_switch_cal)

  392.         );

  393. 

  394.         $model = new XhotelRateUpdateRequest();

  395.         if ($model->load($param, '') && $model->validate()) {

  396.             $rs = new AliExecute();

  397.             $exec_res = $rs->execute($model, true);

  398.             if ($exec_res->code != 0) {

  399.                 return json_encode(['code' => 1, 'msg' => XhotelRateUpdateRequest::ERROR_MSG[$exec_res->code], 'data' => '']);

  400.             }

  401.             return json_encode(['code' => 0, 'msg' => 'success', 'data' => '']);

  402.         } else {

  403.             $logger = new TopLogger;

  404.             $msg = '';

  405.             if (!empty($model->getFirstErrors())) {

  406.                 $msg = $model->getErrorMsg();

  407.             }

  408.             $logger->log(array(

  409.                 date("Y-m-d H:i:s"),

  410.                 '参数验证失败：' . __FUNCTION__ . $msg

  411.             ));

  412.         }

  413.     }

  414. 

  415.     /**

  416.      * Author:Steven

  417.      * Desc:多个房型和房价的价格更新接口

  418.      * @param $flag  当flag为true的时候，全量更新，当flag=false时，增量更新

  419.      * @return bool

  420.      */

  421.     public function actionRatesUpdate(array $param = [], $flag = false)

  422.     {

  423.         $request = empty(Yii::$app->request->post()) ? $param : Yii::$app->request->post();

  424.         if (!isset($request['room_info'])) {

  425.             return json_encode(['code' => 207, 'msg' => '参数错误', 'data' => '']);

  426.         }

  427.         $room_info = json_decode($request['room_info'], true);

  428.         /*$room_info = [

  429.             0 => [

  430.                 'hotel_id' => '81',

  431.                 'parent_room_type' => '100076',

  432.                 'room_type' => '82',

  433.                 'begin_date' => '2017-11-22',

  434.                 'end_date' => '2017-11-25'

  435.             ],

  436.             1 => [

  437.                 'hotel_id' => '197',

  438.                 'parent_room_type' => '150246',

  439.                 'room_type' => '9',

  440.                 'begin_date' => '2017-10-30',

  441.                 'end_date' => '2017-11-11'

  442.             ]

  443.         ];*/

  444.         //先判断酒店是否与渠道直连，房型是否直连

  445.         $res = OperaHotelRoom::find()->select(['a.ID', 'a.HOTEL_ID', 'a.PARENT_ROOM_TYPE', 'a.ROOM_TYPE', 'c.ChannelHotelId', 'b.ChannelRoomId', 'a.RP_ID', 'd.HOTEL_NAME', 'a.ROOM_NAME', 'a.INNER_IDENTIFY'])

  446.             ->leftJoin('channel_room_relation b', 'a.PARENT_ROOM_TYPE=RoomId and b.ChannelId=' . Yii::$app->params['ali']['relation_supplier_id'])

  447.             ->leftJoin('channel_hotel_relation c', 'a.HOTEL_ID=c.HotelId and c.ChannelId=' . Yii::$app->params['ali']['relation_supplier_id'])

  448.             ->leftJoin('opera_hotel d', 'a.HOTEL_ID=d.HOTEL_ID and d.cancel_flag=0')

  449.             ->from('opera_hotel_room a');

  450. //            ->andFilterWhere(['in', 'a.ID', [1897, 2284]]);

  451.         foreach ($room_info as $item) {

  452.             $res->orFilterWhere(['a.HOTEL_ID' => $item['hotel_id'], 'a.PARENT_ROOM_TYPE' => $item['parent_room_type'], 'a.ROOM_TYPE' => $item['room_type'], 'a.CANCEL_FLAG' => 0]);

  453.         }

  454.         $user_id = empty(Yii::$app->user->id) ? $room_info[0]['user_id'] : Yii::$app->user->id;

  455.         $res = $res->asArray()->all();

  456.         $diret_hid = [];

  457.         foreach ($res as $item) {

  458.             if (!is_null($item['ChannelHotelId']) && !is_null($item['ChannelRoomId']) && !empty($item['RP_ID'])) {  //酒店和房型都直连

  459.                 foreach ($room_info as $v) {

  460.                     if ($item['HOTEL_ID'] == $v['hotel_id'] && $item['PARENT_ROOM_TYPE'] == $v['parent_room_type'] && $item['ROOM_TYPE'] == $v['room_type']) {

  461.                         $diret_hid[] = array(

  462.                             'ID' => $item['ID'],

  463.                             'BEGIN_DATE' => $v['begin_date'],

  464.                             'END_DATE' => $v['end_date']

  465.                         );

  466.                     }

  467.                 }

  468.             }

  469.         }

  470.         if (empty($diret_hid)) {

  471.             return json_encode(['code' => 1, 'msg' => '暂无可推送数据', 'data' => '']);

  472.         }

  473.         $run_hotel_distrib = new RunHotelDistrib();

  474.         foreach ($diret_hid as $room) {

  475.             // 查询该房型在某日期段房态信息

  476.             $data = $run_hotel_distrib->getAvailProduct($room['ID'], $room['BEGIN_DATE'], $room['END_DATE']);

  477.             foreach ($data as $value) {

  478.                 $rs['rateplan_code'] = $value['RP_CODE'];

  479.                 $rs['vendor'] = "";

  480.                 $rs['lock_start_time'] = "";

  481.                 $rs['lock_end_time'] = "";

  482.                 $data = [

  483.                     "date" => $value['RUN_DATE'], //:date 日期必须为 T---T+180 日内的日期（T为当天），不能重复

  484.                     "quota" => $value['REMAINING_COUNT'], //房价专有库存 int 类型 取值范围 0-999（数量库存） 60000(状态库存关) 61000(状态库存开)

  485.                     "price" => $value['PROD_PRICE'] * 100, //价格 int类型 取值范围1-99999999 单位为分

  486.                     "status" => ($value['IS_ONSALE'] == 0 || $value['RUN_STATUS'] == 329 || $value['AUTHORITY_STATUS'] == 0 || $value['ROOM_IS_ONSALE'] == 0 || $value['ROOM_RUN_STATUS'] == 0) ? 0 : 1//status 价格开关，0为关，1为开

  487.                 ];

  488.                 $rs['out_rid'] = $value['PARENT_ROOM_TYPE'];

  489.                 $rs['data']['inventory_price'][] = $data;

  490.                 $rs['data']['use_room_inventory'] = false;

  491.             }

  492. 

  493.             if (empty($rs['data']['inventory_price'])) {

  494.                 continue;

  495.             }

  496.             $req[] = $rs;

  497.         }

  498. 

  499.         if (empty($req[0]['data']['inventory_price'])) {

  500.             return json_encode(['code' => 2, 'msg' => '子房型:' . $req[0]['rateplan_code'] . '推送失败', 'data' => json_encode($req)]);

  501.         }

  502. 

  503.         $param['rate_inventory_price_map'] = json_encode($req);

  504.         $model = $flag ? new XhotelRatesUpdateRequest() : new XhotelRatesIncrementRequest;

  505.         if ($model->load($param, '') && $model->validate()) {

  506.             $rs = new AliExecute();

  507.             $exec_res = $rs->execute($model, true);

  508.             if ($exec_res->code != 0) {

  509.                 return json_encode(['code' => $exec_res->code, 'msg' => XhotelRatesIncrementRequest::ERROR_MSG[$exec_res->code], 'data' => '']);

  510.             }

  511.             return json_encode(['code' => 0, 'msg' => 'success', 'data' => '']);

  512.         } else {

  513.             $logger = new TopLogger;

  514.             $msg = '';

  515.             if (!empty($model->getFirstErrors())) {

  516.                 $msg = $model->getErrorMsg();

  517.             }

  518.             $logger->log(array(

  519.                 date("Y-m-d H:i:s"),

  520.                 '参数验证失败：' . __FUNCTION__ . $msg

  521.             ));

  522.         }

  523. 

  524.     }

  525. 

  526.     /**

  527.      * @Author wanglg

  528.      * @Desc获取阿里后台的Rpid

  529.      */

  530.     public function actionGetRpid($request)

  531.     {

  532.         $xmotel = new XhotelRateRelationshipwithroomGetRequest();

  533.         if ($xmotel->load($request, '') && $xmotel->validate()) {

  534.             $rs = new AliExecute();

  535.             $exec_res = $rs->execute($xmotel, true);

  536. 

  537.             if ($exec_res->code != 0 || $exec_res->total_results == 0) {

  538.                 return false;

  539.             }

  540.             return true;

  541.         } else {

  542.             return false;

  543.         }

  544.     }

  545. 

  546.     /**

  547.      * Author:Steven

  548.      * Desc:酒店订单发货接口  即确认订单或者拒绝订单

  549.      * @param $tid

  550.      * @param $opt_type

  551.      * @return string

  552.      */

  553.     public function actionConfirmOrder($tid, $opt_type)

  554.     {

  555.         $model = new XhotelOrderUpdateRequest();

  556.         $logger = new TopLogger;

  557.         //操作的类型：1.确认无房（取消预订，710发送短信提醒买家申请退款）,2.确认预订    这里的订单号是指淘宝订单号

  558.         $param = ['tid' => "{$tid}", 'opt_type' => $opt_type];

  559.         $logger->log([date("Y-m-d H:i:s"), '酒店确认,未通过参数验证,渠道订单号：' . $tid . "\n" . PHP_EOL], 'ali/error');

  560.         if ($model->load($param, '') && $model->validate()) {

  561.             $logger->log([date("Y-m-d H:i:s"), '酒店确认,通过参数验证,渠道订单号：' . $tid . "\n" . PHP_EOL], 'ali/error');

  562.             $exec = new AliExecute();

  563.             $res = $exec->execute($model, true);

  564.             if ($res->code != 0) {

  565.                 //失败消息提醒开发人员的企业微信

  566.                 $this->sendAliMsgToRtx('【阿里直连】确认订单失败：', $res->sub_msg . "\n" . '渠道单号：' . $tid, 4);

  567.                 return json_encode(['code' => 0, 'msg' => $res->sub_msg . $tid, 'data' => '']);

  568.             }

  569.             $logger->log([date("Y-m-d H:i:s"), '酒店确认, 确认阿里订单成功：' . $tid . "\n" . PHP_EOL], 'ali/error');

  570.             //确认成功

  571.             return json_encode(['code' => 0, 'msg' => 'success', 'data' => $res->rpid]);

  572.         } else {

  573.             $this->sendAliMsgToRtx('【阿里直连】确认订单失败：', '参数验证失败，渠道单号：' . $tid);

  574.             $logger = new TopLogger;

  575.             $msg = '';

  576.             if (!empty($model->getFirstErrors())) {

  577.                 $msg = $model->getErrorMsg();

  578.             }

  579.             $logger->log(array(date("Y-m-d H:i:s"), '参数验证失败：' . __FUNCTION__ . $msg));

  580. 

  581.             return json_encode(['code' => 0, 'msg' => 'fail']);

  582.         }

  583.     }

  584. 

  585.     /**

  586.      * @Author wanglg

  587.      * @Desc 酒店星级转化

  588.      * @param $star

  589.      * @return int|string

  590.      */

  591.     public function hotelStarConversions($star)

  592.     {

  593.         switch ($star) {

  594.             case 33:

  595.                 $star_level = 1;

  596.                 break;

  597.             case 35:

  598.                 $star_level = 2;

  599.                 break;

  600.             case 37:

  601.                 $star_level = 3;

  602.                 break;

  603.             case 38:

  604.                 $star_level = 4;

  605.                 break;

  606.             case 39:

  607.                 $star_level = 5;

  608.                 break;

  609.             case 40:

  610.                 $star_level = 6;

  611.                 break;

  612.             case 41:

  613.                 $star_level = 7;

  614.                 break;

  615.             case 34:

  616.                 $star_level = 1.5;

  617.                 break;

  618.             case 36:

  619.                 $star_level = 2.5;

  620.                 break;

  621.             default:

  622.                 $star_level = 1;

  623.         }

  624. 

  625.         return $star_level;

  626.     }

  627. 

  628.     /**

  629.      * @Author wanglg

  630.      * @Desc获取床型名称

  631.      * @param $str床型id拼接的字符串

  632.      * @return string 床型名称字符串

  633.      */

  634.     public function getBedTypeName($str)

  635.     {

  636.         $bed_name = '';

  637.         $bed_types = explode(',', $str);

  638.         $bed_name .= in_array(1, $bed_types) ? '大床' : '';

  639.         $bed_name .= in_array(2, $bed_types) ? '双床' : '';

  640.         $bed_name .= in_array(10, $bed_types) ? '多床' : '';

  641.         return $bed_name;

  642. 

  643.     }

  644. 

  645.     /**

  646.      * Author:Steven

  647.      * Desc:阿里酒店直连回调地址

  648.      */

  649.     public function actionCallback()

  650.     {

  651.         $url = 'http://' . $_SERVER['HTTP_HOST'] . $_SERVER['PHP_SELF'] . '?' . $_SERVER['QUERY_STRING'];

  652.         $logger = new TopLogger;

  653.         $logger->conf["log_file"] = dirname(dirname(dirname(__DIR__))) . "/runtime/logs/Ali/callback.log";

  654.         $logger->log(array(

  655.             date("Y-m-d H:i:s"),

  656.             $url

  657.         ));

  658.     }

  659. 

  660.     /**

  661.      * Author:Steven

  662.      * Desc:阿里控制台创建的应用，未上线sessionKey有效期为1天，上线后为三个月，

  663.      */

  664.     public function actionCheckExpireTime()

  665.     {

  666.         $exec = new AliExecute();

  667.         $res = $exec->checkExpireTime();

  668.         if ($res > 85) {

  669.             $this->sendAliMsgToRtx('【阿里直连】sessionKey过期通知：：', "sessionKey即将过期，请及时获取最新的sesionKey;\nhttps://open.alitrip.com/docs/doc.htm?spm=a21tt.7629140.0.0.mhPqhk&treeId=164&articleId=104995&docType=1", '');

  670.             $send_txt = "【蜘蛛出行】SessionKey过期通知：sessionKey即将过期，请及时获取最新的sesionKey;\nhttps://open.alitrip.com/docs/doc.htm?spm=a21tt.7629140.0.0.mhPqhk&treeId=164&articleId=104995&docType=1";

  671.             // $send_mobile = "17602134075,18691077519,18257110363,18667946782,18855970997";

  672.             // Msg::sendTelMsg($send_mobile, $send_txt);

  673.         }

  674.         return $res;

  675. 

  676.     }

  677. 

  678. 

  679. }

  680. 

  681. ?>