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/ComparePriceController.php

707 lines
28 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\ChannelRoom;

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

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

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

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

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

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

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

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

  15. use Yii;

  16. use yii\db\Exception;

  17. use yii\web\Controller;

  18. use common\components\zOfficeWechat;

  19. use common\models\Msg;

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

  21. 

  22. class ComparePriceController extends Controller

  23. {

  24.     public $layout = "@backend/modules/motorcade/views/layouts/iframe_new";

  25.     public $enableCsrfValidation = false;

  26. 

  27.     /**

  28.      * User:Steven

  29.      * Desc:比价酒店列表

  30.      * @return string

  31.      */

  32.     public function actionIndex()

  33.     {

  34.         $comparePrice = new HotelPriceConversion();

  35.         $ctripHotel = new PriceComparedHotel();

  36. 

  37.         $filter = ['hotel_name' => '', 'cancel_flag' => '', 'channel_id' => '', 'channel' => ''];

  38. //        $request = Yii::$app->request;

  39.         if (Yii::$app->request->isAjax) {

  40.             $filter = Yii::$app->request->get('filter');

  41.         }

  42.         $dataProvider = $ctripHotel->index($filter);

  43. 

  44.         return $this->render('base', ['view' => 'index', 'data' => ['model' => $ctripHotel, 'comparePrice' => $comparePrice], 'dataProvider' => $dataProvider]);

  45.     }

  46. 

  47.     /**

  48.      * User:Steven

  49.      * Desc:酒店比价

  50.      * @return string

  51.      */

  52.     public function actionComparePrice()

  53.     {

  54.         $ctripHotelPrice = new CtripHotelPrice();

  55.         $hotel_list = $ctripHotelPrice->getDirectHotel();

  56.         if (Yii::$app->request->isPost || Yii::$app->request->isGet) {

  57.             $HOTEL_ID = is_null(Yii::$app->request->post('HOTEL_ID')) ? Yii::$app->request->get('HOTEL_ID') : Yii::$app->request->post('HOTEL_ID');

  58.         }

  59.         is_null($HOTEL_ID) ? $HOTEL_ID = $hotel_list[0]['HOTEL_ID'] : $HOTEL_ID;

  60.         $ctrip_data = $ctripHotelPrice->getCtripData($HOTEL_ID);

  61.         $data = array(

  62.             'ctrip_data' => [],

  63.             'update_time' => ''

  64.         );

  65.         if (!empty($ctrip_data)) {

  66.             $data['hotel_info'] = array(

  67.                 'ctrip_hotel_id' => $ctrip_data[0]['ctrip_hotel_id'],

  68.                 'hotel_name' => $ctrip_data[0]['hotel_name'],

  69.                 'spider_hotel_id' => $HOTEL_ID,

  70.             );

  71.             $last_up_time = $ctripHotelPrice->getHotelLastUpTime($HOTEL_ID);

  72. //            $price_conversion = $ctripHotelPrice->getHotelConversion($HOTEL_ID);

  73.             $res = $this->ctripDataService($ctrip_data, $HOTEL_ID);

  74.             foreach ($res[$HOTEL_ID] as $key => $item) {

  75.                 if (empty($item)) {

  76.                     unset($res[$HOTEL_ID][$key]);

  77.                 }

  78.             }

  79.         }

  80.         $data['hotel_list'] = $hotel_list;

  81.         $data['ctrip_data'] = $res;

  82.         $data['update_time'] = $last_up_time['max_create_time'];

  83. //        $data['update_time'] = '2017-08-31 00:00:00';

  84.         return $this->render('base', ['view' => 'priceCompared', 'data' => $data]);

  85.     }

  86. 

  87.     /**

  88.      * User:Steven

  89.      * Desc:酒店-房型比价列表

  90.      * @return string

  91.      */

  92.     public function actionRoomCompared()

  93.     {

  94.         $hotel_id = Yii::$app->request->get('hotel_id');

  95.         $channel_id = Yii::$app->request->get('channel_id');

  96.         if (!isset($hotel_id) || !isset($channel_id)) {

  97.             return false;

  98.         }

  99. 

  100.         $filter = ['hotel_id' => $hotel_id, 'cancel_flag' => '', 'channel_id' => '', 'channel' => $channel_id];

  101. 

  102.         if (Yii::$app->request->isAjax) {

  103.             $filter = Yii::$app->request->get('filter');

  104.             $filter['hotel_id'] = $hotel_id;

  105.         }

  106. 

  107.         $ctripHotel = new PriceComparedRoom();

  108.         $dataProvider = $ctripHotel->getComparedRoom($filter);

  109. //        $data['update_time'] = '2017-08-31 00:00:00';

  110.         return $this->render('base', ['view' => 'room_compared_list', 'data' => ['model' => $ctripHotel, 'channel_id' => $channel_id, 'hotel_id' => $hotel_id,], 'dataProvider' => $dataProvider]);

  111.     }

  112. 

  113.     /**

  114.      * User:Steven

  115.      * Desc:比价酒店数据总览页面

  116.      */

  117.     public function actionOverview()

  118.     {

  119.         $ctripHotel = new PriceComparedHotel();

  120.         $param = Yii::$app->request->get();

  121.         $channel_id = isset($param['channel_id']) ? $param['channel_id'] : Yii::$app->params['ctrip']['relation_supplier_id'];

  122.         $hotel_name = isset($param['hotel_name']) ? $param['hotel_name'] : '';

  123.         $hotel_pricipal = isset($param['hotel_pricipal']) ? $param['hotel_pricipal'] : -1;

  124.         $dataProvider = $ctripHotel->getHotelOverview($channel_id, $hotel_name, $hotel_pricipal);

  125.         $ctrip_hotel_price = new CtripHotelPrice();

  126.         $last_up_time = $ctrip_hotel_price->getHotelLastUpTime();

  127.         return $this->render('base', ['view' => 'overview', 'data' => ['dataProvider' => $dataProvider, 'last_up_time' => $last_up_time]]);

  128.     }

  129. 

  130.     /**

  131.      * User:Steven

  132.      * Desc:设置比价酒店的价差

  133.      * @return \yii\web\Response

  134.      */

  135.     public function actionSetPriceConversion()

  136.     {

  137.         if (Yii::$app->request->isPost) {

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

  139.             $comparePrice = empty(HotelPriceConversion::findOne($post['HotelPriceConversion']['hotel_id'])) ? new HotelPriceConversion() : HotelPriceConversion::findOne($post['HotelPriceConversion']['hotel_id']);

  140. 

  141.             if ($comparePrice->load($post) && $comparePrice->validate()) {

  142.                 if ($comparePrice->save()) {

  143.                     Yii::$app->session->setFlash('success', "添加成功");

  144.                     return $this->redirect(array('compare-price/index'));

  145.                 } else {

  146.                     Yii::$app->session->setFlash('success', "添加失败");

  147.                 }

  148.             }

  149.         }

  150.     }

  151. 

  152.     /**

  153.      * @author wanglg

  154.      * 修改酒店比价状态

  155.      */

  156.     public function actionModifyStatus()

  157.     {

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

  159. 

  160.         if (!(isset($post['id']) && isset($post['op']))) {

  161.             $data['code'] = 2;

  162.         }

  163. 

  164.         if ($post['field'] == 'cancel_flag') {

  165.             $transform = Yii::$app->db->beginTransaction();

  166. 

  167.             try {

  168.                 $pch = PriceComparedHotel::findOne($post['id']);

  169.                 $update['cancel_flag'] = $post['op'] == 'set' ? 0 : 1;

  170.                 if ($pch->load($update, '') && $pch->validate()) {

  171.                     if (!$pch->save()) {

  172.                         throw new \Exception();

  173.                     }

  174.                 }

  175. 

  176. //            $hotel_id = $pch -> HotelId;

  177.                 $ChannelHotelId = $pch->ChannelHotelId;

  178.                 $sync_hotel = SyncPriceComparedHotel::findOne(['ChannelHotelId' => $ChannelHotelId]);

  179.                 $new_update = $post['op'] == 'set' ? 0 : 1;

  180. 

  181.                 $sync_hotel->CancelFlag = $new_update;

  182.                 if (!$sync_hotel->update()) {

  183.                     throw new \Exception();

  184.                 }

  185. 

  186.                 $transform->commit();

  187.                 $data = 0;

  188.             } catch (\Exception $e) {

  189.                 $transform->rollBack();

  190.                 $data['code'] = 1;

  191.             }

  192.             echo json_encode($data);

  193.         }

  194. 

  195.         if ($post['field'] == 'send_msg') {

  196.             $pch = PriceComparedHotel::findOne($post['id']);

  197.             $update['SendMsg'] = $post['op'] == 'set' ? 1 : 0;

  198.             $pch->SendMsg = $update['SendMsg'];

  199.             if ($pch->update()) {

  200.                 $data = 0;

  201.             } else {

  202.                 $data = 1;

  203.             }

  204.             echo json_encode($data);

  205.         }

  206. 

  207.     }

  208. 

  209.     /**

  210.      * @Author wanglg

  211.      * @Desc 修改房型比价状态

  212.      */

  213.     public function actionRoomStatus()

  214.     {

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

  216. 

  217.         if (!(isset($post['id']) && isset($post['op']))) {

  218.             $data['code'] = 2;

  219.         }

  220. 

  221.         $pcr = PriceComparedRoom::findOne(['ID' => $post['id']]);

  222.         $update['cancel_flag'] = $post['op'] == 'set' ? 0 : 1;

  223.         if ($pcr->load($update, '') && $pcr->validate()) {

  224.             if (!$pcr->save()) {

  225.                 $data['code'] = 1;

  226.             } else {

  227.                 $data = 0;

  228.             }

  229.         }

  230.         echo json_encode($data);

  231.     }

  232. 

  233.     /**

  234.      * 添加比价酒店

  235.      */

  236.     public function actionAddComparedHotel()

  237.     {

  238.         $model = new PriceComparedHotel();

  239.         $sync_model = new SyncPriceComparedHotel();

  240. 

  241.         $transaction = Yii::$app->db->beginTransaction();

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

  243. 

  244.         try {

  245.             if ($model->load($request) && $model->validate()) {

  246.                 if (!$model->save()) {

  247.                     throw new \Exception();

  248.                 }

  249.             } else {

  250.                 throw new \Exception();

  251.             }

  252. 

  253.             $new_request = array('ChannelHotelId' => $request['PriceComparedHotel']['ChannelHotelId'], 'HotelId' => $request['PriceComparedHotel']['HotelId'], 'ChannelId' => $request['PriceComparedHotel']['ChannelId'],);

  254. 

  255.             if ($sync_model->load($new_request, '') && $sync_model->validate()) {

  256.                 if (!$sync_model->save()) {

  257.                     throw new \Exception();

  258.                 }

  259.             } else {

  260.                 throw new \Exception();

  261.             }

  262. 

  263.             $transaction->commit();

  264.             Yii::$app->session->setFlash('success', "添加比价酒店成功！");

  265. //            return '<script>z.pjaxFinish("success", "修改成功", "#float-div");$("#search-btn").trigger(\'click\');</script>';

  266. //            echo '<script type="text/javascript">easyAlert("添加比价酒店成功！", "success");</script>';

  267.         } catch (\Exception $e) {

  268.             $transaction->rollBack();

  269.             Yii::$app->session->setFlash('error', "添加比价酒店失败！");

  270.             $hotel_list = $model->getHotelList();

  271.             return $this->renderPartial('base', ['view' => '_addHotel', 'data' => ['hotel_list' => $hotel_list, 'model' => $model]]);

  272.         }

  273. 

  274.         return $this->redirect('/hotel/compare-price/index');

  275.     }

  276. 

  277.     /**

  278.      * @author wanglg

  279.      *  添加比价房型

  280.      */

  281.     public function actionAddComparedRoom()

  282.     {

  283.         $model = new PriceComparedRoom();

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

  285. 

  286.         if ($model->load($request) && $model->validate()) {

  287.             if (!$model->save()) {

  288.                 Yii::$app->session->setFlash('error', "添加比价房型失败！");

  289.             } else {

  290. //                return '<script>z.pjaxFinish("success", "添加比价房型成功", "#float-div")</script>';

  291.                 Yii::$app->session->setFlash('success', "添加比价房型成功！");

  292.             }

  293.         } else {

  294.             $room = new OperaHotelRoom();

  295.             $base_room = new OperaHotelBaseRoom();

  296.             $base_list = $base_room->getHotelBaseRoom($request['PriceComparedRoom']['hotel_id']);

  297.             $base_room_id = isset($base_room_id) ? $base_room_id : $base_list[0]->MAIN_ID;

  298.             $room_list = $room->getAllRoom($request['PriceComparedRoom']['hotel_id'], $base_room_id);

  299.             return $this->renderPartial('_form', ['data' => ['model' => $model, 'room_list' => $room_list, 'base_room' => $base_room, 'hotel_id' => $request['PriceComparedRoom']['hotel_id'], 'base_list' => $base_list]]);

  300.         }

  301. 

  302.         return $this->redirect('/hotel/compare-price/room-compared?hotel_id=' . $request['PriceComparedRoom']['hotel_id'] . '&channel_id=' . $request['PriceComparedRoom']['channel_id']);

  303.     }

  304. 

  305.     /**

  306.      * @author wanglg

  307.      * 修改比价房型信息

  308.      * @return \yii\web\Response

  309.      */

  310.     public function actionUpdateComparedRoom()

  311.     {

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

  313.         $model = PriceComparedRoom::findOne($request['PriceComparedRoom']['ID']);

  314.         if ($model->load($request) && $model->validate()) {

  315.             if (!$model->save()) {

  316.                 Yii::$app->session->setFlash('error', "修改比价房型失败！");

  317.             } else {

  318.                 Yii::$app->session->setFlash('success', "修改比价房型成功！");

  319.             }

  320.         }

  321. 

  322.         return $this->redirect('/hotel/compare-price/room-compared?hotel_id=' . $request['PriceComparedRoom']['hotel_id'] . '&channel_id=' . $request['PriceComparedRoom']['channel_id']);

  323.     }

  324. 

  325.     /**

  326.      * @author wanglg

  327.      * @return string

  328.      */

  329.     public function actionAddComparedHotelView()

  330.     {

  331. //        不需要参数，直接查询所有未添加的酒店

  332.         $model = new PriceComparedHotel();

  333.         $hotel_list = $model->getHotelList();

  334.         return $this->renderPartial('base', ['view' => '_addHotel', 'data' => ['hotel_list' => $hotel_list, 'model' => $model]]);

  335.     }

  336. 

  337.     /**

  338.      * @author wanglg

  339.      * 添加比价房型弹框显示

  340.      */

  341.     public function actionAddComparedRoomView()

  342.     {

  343.         $model = new PriceComparedRoom();

  344.         $hotel_id = Yii::$app->request->get('hotel_id');

  345.         $base_room = new OperaHotelBaseRoom();

  346.         $base_list = $base_room->getHotelBaseRoom($hotel_id);

  347.         $room = new OperaHotelRoom();

  348. 

  349.         if (!isset($hotel_id)) {

  350.             if (Yii::$app->request->isPjax && Yii::$app->request->post('base_room_id')) {

  351.                 $base_room_id = Yii::$app->request->post('base_room_id');

  352.                 $hotel_id = Yii::$app->request->post('hotel_id');

  353.             }

  354.         }

  355. 

  356.         $base_room_id = isset($base_room_id) ? $base_room_id : $base_list[0]->MAIN_ID;

  357.         $room_list = $room->getAllRoom($hotel_id, $base_room_id);

  358.         return $this->renderPartial('_form', ['data' => ['action' => 'add', 'model' => $model, 'room_list' => $room_list, 'base_room' => $base_room, 'hotel_id' => $hotel_id, 'base_list' => $base_list]]);

  359.     }

  360. 

  361.     /**

  362.      * @author wanglg

  363.      * @return bool|string

  364.      */

  365.     public function actionUpdateComparedRoomView()

  366.     {

  367.         $id = Yii::$app->request->get('id');

  368.         $hotel_id = Yii::$app->request->get('hotel_id');

  369. 

  370.         if (empty($hotel_id) || empty($id)) {

  371.             return false;

  372.         }

  373. 

  374.         $model = PriceComparedRoom::findOne($id);

  375. 

  376.         // 根据子房型查询基础房型id

  377.         $parent_room = OperaHotelRoom::findOne($model->room_id);

  378.         //根据基础房型id查询该基础房型id

  379.         $parent_room_id = OperaHotelBaseRoom::findOne($parent_room->PARENT_ROOM_TYPE);

  380.         $base_room = new OperaHotelBaseRoom();

  381.         $base_list = $base_room->getHotelBaseRoom($hotel_id);

  382. 

  383.         if (!isset($hotel_id)) {

  384.             if (Yii::$app->request->isPjax && Yii::$app->request->post('base_room_id')) {

  385.                 $base_room_id = Yii::$app->request->post('base_room_id');

  386.                 $hotel_id = Yii::$app->request->post('hotel_id');

  387.             }

  388.         }

  389. 

  390.         $room = new OperaHotelRoom();

  391.         $base_room_id = isset($base_room_id) ? $base_room_id : $parent_room->PARENT_ROOM_TYPE;

  392.         $room_list = $room->getAllRoom($hotel_id, $base_room_id);

  393.         return $this->renderPartial('_form', ['data' => ['action' => 'update', 'model' => $model, 'room_list' => $room_list, 'base_room' => $parent_room_id, 'hotel_id' => $hotel_id, 'base_list' => $base_list]]);

  394. 

  395.     }

  396. 

  397.     /**

  398.      * User:Steven

  399.      * Desc:获取代理IP 快代理

  400.      * @return bool

  401.      */

  402.     public function actionGetProxys()

  403.     {

  404.         //获取目前可用的IP个数

  405.         $max_count = 300;  //限制数据库

  406.         $model = new CtripHotelPrice();

  407.         $count = $model->getAbleProxyCount();

  408.         if ($count[0]['count'] >= $max_count) {

  409.             return false;

  410.         }

  411.         $i = 0;

  412.         $url = "http://ent.kuaidaili.com/api/getproxy/?orderid=990424805960893&num=300&b_pcchrome=1&b_pcie=1&b_pcff=1&protocol=1&method=1&an_an=1&an_ha=1&sp1=1&quality=2&format=json&sep=1";

  413.         $res = Utils::http_get($url);

  414.         $res = json_decode($res['content'], true);

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

  416.             foreach ($res['data']['proxy_list'] as $item) {

  417.                 if ($i >= ($max_count - $count[0]['count'])) {

  418.                     return false;

  419.                 }

  420.                 //这里验证代理IP的有效性

  421.                 $code = $this->GetHttpStatusCode($item);

  422.                 if ($code == 200) {

  423.                     $i++;

  424.                     $model->addProxyIp($item);

  425.                 }

  426.             }

  427.         }

  428.     }

  429. 

  430.     /**

  431.      * User:Steven

  432.      * Desc:定时统计房型未展示、价格有劣势的酒店房型统计数据，并通知到酒店运营

  433.      */

  434.     public function actionCronPriceWarning()

  435.     {

  436.         $ctripHotelPrice = new CtripHotelPrice();

  437.         $res = $ctripHotelPrice->getDirectHotel();

  438.         foreach ($res as $item) {

  439.             $ctrip_data = $ctripHotelPrice->getCtripData($item['HOTEL_ID']);

  440.             if (empty($ctrip_data)) {

  441.                 continue;

  442.             }

  443. //            $price_conversion = $ctripHotelPrice->getHotelConversion($item['HOTEL_ID']);

  444.             $rs = $this->ctripDataService($ctrip_data, $item['HOTEL_ID']);  //这里返回的数据是：1、价格有劣势的 2：价格未显示的

  445.             foreach ($rs as $key => $value) {

  446.                 $room_analysis = '';

  447.                 $flag = false;

  448.                 foreach ($value as $k => $v) { // $k

  449.                     if (empty($v)) {

  450.                         continue;

  451.                     }

  452.                     $inferiority = 0;//劣势房型

  453.                     $no_show = 0;//未展示房型

  454.                     foreach ($v as $k1 => $v1) {

  455.                         if (!is_null($v1['a_price']) && !is_null($v1['b_price'])) { //劣势

  456.                             $flag = true;

  457.                             $inferiority++;

  458.                         } elseif (!is_null($v1['a_price']) && is_null($v1['b_price'])) {

  459.                             $flag = true;

  460.                             $no_show++;

  461.                         }

  462.                     }

  463.                     if ($inferiority != 0 || $no_show != 0) {

  464.                         $str = str_replace(array("\r\n", "\r", " ", "\n"), "", $k);

  465.                         $room_analysis .= '● ' . preg_replace('/^([^\d]+).*/', '$1', $str) . ': 价格劣势天数:' . $inferiority . '; 未露出天数：' . $no_show . "\n";

  466.                     }

  467.                 }

  468.             }

  469.             if ($flag) {

  470.                 $url = "http://cs1.zhizhuchuxing.com/hotel/compare-price/compare-price?HOTEL_ID=" . $item['HOTEL_ID'];

  471.                 $msg = '【' . $item['HOTEL_NAME'] . '】' . '\n' . $room_analysis . '复制在浏览器中打开：' . Msg::sinaShortenUrl($url);

  472.                 //TODO:给运营发送消息通知

  473.                 if ($item['SendMsg'] == 1) {

  474.                     $arr = array("agentid" => 1000002,

  475.                         "title" => 'Ctrip渠道比价结果预警：',

  476.                         "msg" => $msg,

  477.                         "touser" => $item['user_name']);

  478. //                    "touser" => 'shifp');

  479.                     zOfficeWechat::sendMsg($arr);

  480.                 }

  481. 

  482.             }

  483.         }

  484.     }

  485. 

  486.     /**

  487.      * User:Steven

  488.      * Desc:提取字符串中的数字

  489.      * @param $string

  490.      * @return bool|string

  491.      */

  492.     function findNumber($string)

  493.     {

  494.         if (!is_string($string) || empty($string)) {

  495.             return '';

  496.         }

  497.         for ($i = 0; $i < strlen($string); $i++) {

  498.             $char = substr($string, $i, 1);

  499.             if (ctype_digit($char)) {

  500.                 return substr($string, 0, $i);

  501.             }

  502.         }

  503.         return '';

  504.     }

  505. 

  506.     /**

  507.      * Author:Steven

  508.      * Desc:比价数据处理

  509.      * @param $ctrip_data

  510.      * @param $price_conversion

  511.      * @param $flag 是否折算价差

  512.      * @return array

  513.      */

  514.     public function ctripDataService($ctrip_data, $HOTEL_ID, $flag = true)

  515.     {

  516.         //查询当前有直连关系的房型ID

  517.         $ctripHotelPrice = new CtripHotelPrice();

  518.         $room_arr = $ctripHotelPrice->getRelationRoom($ctrip_data[0]['spider_hotel_id']);

  519.         $room_list = [];

  520.         foreach ($room_arr as $room) {

  521.             $room_list[] = $room['channel_room_id'];

  522.         }

  523.         //a_表示携程  b_表示蜘蛛

  524.         $arr = array();

  525.         if ($flag) {

  526.             $ctripHotelPrice = new CtripHotelPrice();

  527.             $price_conversion = $ctripHotelPrice->getHotelConversion($HOTEL_ID);

  528.             $price_conversion = $price_conversion[0];

  529.         }

  530.         foreach ($ctrip_data as $item) {

  531.             $spider_price = $item['b_price'];

  532.             $ctrip_price = $item['a_price'];

  533.             $origin_spider_price = $item['b_price']; //用于记录没有折算价差的时候的价格

  534.             $origin_ctrip_price = $item['a_price'];

  535.             if ($flag) {//携程价格折算

  536.                 $remain_room_conversion = isset($price_conversion['remain_room_conversion']) ? $price_conversion['remain_room_conversion'] : 0;

  537.                 $breakfast_conversion = isset($price_conversion['breakfast_conversion']) ? $price_conversion['breakfast_conversion'] : 0;

  538.                 $cancel_rules_conversion = isset($price_conversion['cancel_rules_conversion']) ? $price_conversion['cancel_rules_conversion'] : 0;

  539.                 $pay_type_conversion = isset($price_conversion['pay_type_conversion']) ? $price_conversion['pay_type_conversion'] : 0;

  540.                 //早餐（非早餐类型的早餐折算）  以我们的价格为基数，加上或者减去早餐数之差*价差

  541.                 $ctrip_breakfast = $this->calBreakfastLevel($item['a_breakfast']);

  542.                 $spider_breakfast = $this->calBreakfastLevel($item['b_breakfast']);

  543.                 $spider_price = $spider_price - ($spider_breakfast - $ctrip_breakfast) * $breakfast_conversion;

  544.                 //别墅类型的早餐折算

  545.                 $ctrip_breakfast1 = $this->calbreakfast1($item['a_breakfast']);

  546.                 $spider_breakfast2 = $this->calbreakfast1($item['b_breakfast']);

  547.                 $ctrip_person = $this->number($item['a_room_person']);

  548.                 $spider_person = $this->number($item['b_room_person']);

  549.                 $spider_price = $spider_price + ($spider_breakfast2 * $spider_person - $ctrip_breakfast1 * $ctrip_person) * $breakfast_conversion;

  550. 

  551.                 //现预付  蜘蛛是预付

  552.                 if ($item['a_payment_txt'] == '到店付' || $item['a_payment_txt'] == '担保') {//现付

  553.                     $ctrip_price = $ctrip_price - $pay_type_conversion;

  554.                 }

  555.                 //保留房

  556.                 $item['a_confirm_info'] == '立即确认' ? '' : $ctrip_price = $ctrip_price + $remain_room_conversion;

  557.                 $item['b_confirm_info'] == '立即确认' ? '' : $spider_price = $spider_price + $remain_room_conversion;

  558.                 //取消规则

  559.                 $item['a_room_policy'] == '免费取消' ? '' : $ctrip_price = $ctrip_price + $cancel_rules_conversion;

  560.                 $item['b_room_policy'] == '免费取消' ? '' : $spider_price = $spider_price + $cancel_rules_conversion;

  561.             }

  562.             if ($spider_price > $ctrip_price || is_null($item['b_price'])) {   //蜘蛛价格为null时，即价格未在携程前台显示

  563.                 $room_type = preg_replace('/^([^\d]+).*/', '$1', str_replace(array("\r\n", "\r", " ", "\n"), "", $item['room_type']));

  564. 

  565.                 $arr[$item['spider_hotel_id']][$room_type][$item['start_date']] = array(

  566.                     'a_bed_type' => $item['a_bed_type'],

  567.                     'b_bed_type' => $item['b_bed_type'],

  568.                     'a_breakfast' => $item['a_breakfast'],

  569.                     'b_breakfast' => $item['b_breakfast'],

  570.                     'a_room_policy' => $item['a_room_policy'],

  571.                     'b_room_policy' => $item['b_room_policy'],

  572.                     'a_confirm_info' => $item['a_confirm_info'],

  573.                     'b_confirm_info' => $item['b_confirm_info'],

  574.                     'a_supply_id' => $item['a_supply_id'],

  575.                     'a_showdow_id' => $item['a_showdow_id'],

  576.                     'a_payment_txt' => $item['a_payment_txt'],

  577.                     'b_payment_txt' => $item['b_payment_txt'],

  578.                     'a_room_person' => $item['a_room_person'],

  579.                     'b_room_person' => $item['b_room_person'],

  580.                     'a_price' => $item['a_price'],

  581.                     'b_price' => $item['b_price'],

  582.                     'b_son_room_id' => $item['son_room_id'],

  583.                     'inferiority' => 2,

  584.                 );

  585.                 if (($origin_spider_price < $origin_ctrip_price) && !is_null($item['b_price'])) { //这种属于竞争力不足

  586.                     $arr[$item['spider_hotel_id']][$room_type][$item['start_date']]['inferiority'] = 3;

  587.                 }

  588.                 //判断当前房型是不是直连的房型

  589.                 if (!in_array($item['son_room_id'], $room_list)) {

  590.                     unset($arr[$item['spider_hotel_id']][$room_type][$item['start_date']]);

  591.                 }

  592.             }

  593.         }

  594. 

  595.         //当某个房型下所有的日期，蜘蛛的数据都是空的，表明我们没有合作此房型

  596.         foreach ($arr as $itmem_k => $item) {

  597.             foreach ($item as $key => $value) {

  598.                 $i = 0;

  599.                 foreach ($value as $k => $v) {

  600.                     if (is_null($v['b_price'])) {

  601.                         $i++;

  602.                         if ($i == count($value)) {

  603.                             unset($arr[$itmem_k][$key]);

  604.                         }

  605.                     }

  606.                 }

  607.             }

  608.         }

  609.         return $arr;

  610.     }

  611. 

  612.     /**

  613.      * User:Steven

  614.      * Desc:计算早餐级别

  615.      * @param $breakfast

  616.      * @return int

  617.      */

  618.     public function calBreakfastLevel($breakfast)

  619.     {

  620.         switch ($breakfast) {

  621.             case '无早':

  622.                 $breakfast_level = 0;

  623.                 break;

  624.             case '每天单早':

  625.                 $breakfast_level = 1;

  626.                 break;

  627.             case '每天双早':

  628.                 $breakfast_level = 2;

  629.                 break;

  630.             case '每天三早':

  631.                 $breakfast_level = 3;

  632.                 break;

  633.             case '每天四早':

  634.                 $breakfast_level = 4;

  635.                 break;

  636.             case '每天五早':

  637.                 $breakfast_level = 5;

  638.                 break;

  639.             case '每天六早':

  640.                 $breakfast_level = 6;

  641.                 break;

  642.             case '每天七早':

  643.                 $breakfast_level = 7;

  644.                 break;

  645.             case '每天八早':

  646.                 $breakfast_level = 8;

  647.                 break;

  648.             case '每天九早':

  649.                 $breakfast_level = 9;

  650.                 break;

  651.             case '每天十早':

  652.                 $breakfast_level = 10;

  653.                 break;

  654.             default:

  655.                 $breakfast_level = 0;

  656.                 break;

  657.         }

  658.         return $breakfast_level;

  659.     }

  660. 

  661.     /**

  662.      * User:Steven

  663.      * Desc:对于别墅类型的房，计算早餐个数的时候需要考虑到入住人数

  664.      * @param $breakfast

  665.      * @return int|string

  666.      */

  667.     public function calbreakfast1($breakfast)

  668.     {

  669.         $arr = array(1 => '一', 2 => '二', 3 => '三', 4 => '四', 5 => '五', 6 => '六', 7 => '七', 8 => '八', 9 => '九', 10 => '十', 11 => '十一', 12 => '十二');

  670.         foreach ($arr as $k => $v) {

  671.             if ($breakfast == '每天每人' . $v . '份早') {

  672.                 return $k;

  673.             } else {

  674.                 return 0;

  675.             }

  676.         }

  677.     }

  678. 

  679.     /**

  680.      * User:Steven

  681.      * Desc:获取字符串中的数字部分

  682.      * @param $str

  683.      * @return mixed

  684.      */

  685.     public function number($str)

  686.     {

  687.         return preg_replace('/\D/s', '', $str);

  688.     }

  689. 

  690.     public function GetHttpStatusCode($proxy)

  691.     {

  692.         $curl = curl_init();

  693.         curl_setopt($curl, CURLOPT_PROXY, $proxy);//使用代理访问

  694.         curl_setopt($curl, CURLOPT_URL, "http://www.baidu.com");//获取内容url

  695.         curl_setopt($curl, CURLOPT_HEADER, 1);//获取http头信息

  696.         curl_setopt($curl, CURLOPT_NOBODY, 1);//不返回html的body信息

  697.         curl_setopt($curl, CURLOPT_RETURNTRANSFER, 1);//返回数据流，不直接输出

  698.         curl_setopt($curl, CURLOPT_TIMEOUT, 5); //超时时长，单位秒

  699.         curl_exec($curl);

  700.         $rtn = curl_getinfo($curl, CURLINFO_HTTP_CODE);

  701.         curl_close($curl);

  702.         return $rtn;

  703.     }

  704. 

  705. }

  706. 

  707. ?>