nizongfeng
/
ZZCX_yii
1
0
Fork 0
Código Issues 0 Pull requests 0 Versões 0 Wiki Atividade
Você não pode selecionar mais de 25 tópicos Os tópicos devem começar com uma letra ou um número, podem incluir traços ('-') e podem ter até 35 caracteres.
3 Commits
1 Branch
96 MiB
 
 
 
 
 
 
Branch: master
Branches Tags
${ item.name }
Criar branch ${ searchTerm }
de master
${ noResults }
ZZCX_yii/backend/modules/api/controllers/LvmamaController.php

942 linhas
43 KiB
Original Link permanente Anotar Histórico 

  1. <?php

  2. /**

  3.  * Function Description:驴妈妈对应的接口

  4.  * Function Name: ApiForLvmama

  5.  * @return ${TYPE_HINT}

  6.  * ${THROWS_DOC}

  7.  *

  8.  * @author 娄梦宁

  9.  */

  10. 

  11. namespace backend\modules\api\controllers;

  12. 

  13. use backend\modules\api\models\LvmamaOrderConnect;

  14. use backend\modules\api\models\LvmamaPushInfo;

  15. use backend\modules\api\models\OperaProduct;

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

  17. use backend\modules\api\models\OrderRefundLvmama;

  18. use backend\modules\api\models\OutsideTicket;

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

  20. use common\models\Msg;

  21. use common\models\Utils;

  22. use yii\base\Exception;

  23. use yii\web\Controller;

  24. use Yii;

  25. 

  26. 

  27. class LvmamaController extends Controller

  28. {

  29.     public $enableCsrfValidation = false;

  30. 

  31.     public function actionIndex()

  32.     {

  33.         return 'HELLO';

  34.     }

  35. 

  36.     /**

  37.      * Function Description:获取 批量景区基本信息接口(暂无相关数据处理)

  38.      * Function Name: actionGetScenicList

  39.      *

  40.      *

  41.      * @author 娄梦宁

  42.      */

  43.     public function actionGetScenicList()

  44.     {

  45.         $util = new Util();

  46.         //请求参数构建

  47.         $time = time();

  48.         $appKey = $util->getAppKey();

  49.         $timestamp = $time;

  50.         $sign = $util::SingForLvmama($time);

  51.         $currentPage = 1;

  52.         $url = $util->getBaseUrl() . '/ticketProd/scenicInfoListByPage' . "?appKey=" . $appKey . "&messageFormat=json&timestamp=" . $timestamp . "&sign=" . $sign . "&currentPage=" . $currentPage;

  53.         $result = Utils::httpRequest($url);

  54.         print_r($url);

  55.         print_r(json_decode($result, true));

  56.     }

  57. 

  58.     /**

  59.      * Function Description:批量产品/商品信息接口

  60.      * Function Name: actionGetProdList

  61.      *

  62.      *

  63.      * @author 娄梦宁

  64.      */

  65.     public function actionGetProdList()

  66.     {

  67.         set_time_limit(0);

  68.         $util = new Util();

  69.         $opera_prod = new OperaProduct();

  70.         $outside_ticket = new OutsideTicket();

  71.         //请求参数构建

  72.         $time = time();

  73.         $appKey = $util->getAppKey();

  74.         $timestamp = $time;

  75.         $sign = $util::SingForLvmama($time);

  76.         $currentPage = 1;

  77.         $url = $util->getBaseUrl() . '/ticketProd/productInfoListByPage' . "?appKey=" . $appKey . "&messageFormat=json&timestamp=" . $timestamp . "&sign=" . $sign . "&currentPage=" . $currentPage;

  78.         $result = Utils::httpRequest($url);

  79.         $prod_list = json_decode($result, true);

  80.         //查出opera_prod表中所有的主code（即驴妈妈的productId）

  81.         $code_arr = $opera_prod->getCodeArr();

  82.         $code_arr_son=$opera_prod->getCodeArrSon();

  83.         for ($currentPage = 1; $currentPage <= $prod_list['totalPage']; $currentPage++) {

  84.             if ($currentPage == 1) {//分页的循环

  85.                 $tmp_arr = $prod_list;

  86.             } else {

  87.                 $url = $util->getBaseUrl() . '/ticketProd/productInfoListByPage' . "?appKey=" . $appKey . "&messageFormat=json&timestamp=" . $timestamp . "&sign=" . $sign . "&currentPage=" . $currentPage;

  88.                 $result = Utils::httpRequest($url);

  89.                 $tmp_arr = json_decode($result, true);

  90.             }

  91.             foreach ($tmp_arr['productList'] as $val) {

  92.                 //如果产品在opera_prod表中，即产品信息已添加

  93.                 if (array_key_exists($val['productId'], $code_arr)) {//产品已经存在

  94.                     if ($val['productStatus'] == true) {//当前产品在驴妈妈上架

  95.                         $tmp_prod_name = $util::doCdada($val['productName']);

  96.                         $remark = '';

  97.                         if (isset($val['bookingInfo'])) {

  98.                             foreach ($val['bookingInfo'] as $book) {

  99.                                 $remark .= $util::doCdada($book);

  100.                             }

  101.                         }

  102.                         $remark .= $util::doCdada($val['goodsList'][0]['importentPoint']);

  103.                         $is_refund = $val['goodsList'][0]['rules'][0]['isChange'];

  104.                         $refund_limit_day = 1;

  105.                         $refund_limit_time = '23:00';

  106.                         if ($is_refund == 1 && isset($val['goodsList'][0]['rules'][0]['aheadTime'])) {//可以退款就同步退款规则

  107.                             $limit_day_time = $util::countRefundTime($val['goodsList'][0]['rules'][0]['aheadTime']);

  108.                             $refund_limit_day = $limit_day_time['day'];

  109.                             $refund_limit_time = $limit_day_time['time'];

  110.                         }

  111.                         $tmp_prod_code = $val['productId'];

  112. //

  113.                         $upt_main = $opera_prod->uptLvmamaProdDetail($tmp_prod_code, $tmp_prod_name, $remark, $refund_limit_day, $refund_limit_time, $is_refund);

  114.                         $parent_id = $code_arr[$val['productId']]['prod_id'];

  115. //                    }else{

  116. //                        $upt_main=$opera_prod->istLvmamaProdMain($tmp_prod_code, $tmp_prod_name, $remark, $refund_limit_day, $refund_limit_time, $is_refund);

  117. //                        $parent_id=$upt_main['prod_id'];

  118. //                    }

  119.                         if ($upt_main['code'] != 0) {

  120.                             file_put_contents(__DIR__ . '/../log/lvmama/' . date("Y-m-d") . '.log', date("Y-m-d H:i:s") . $upt_main['msg'] . $val['prod_code'] . "    批量定时更新产品出错" . PHP_EOL, FILE_APPEND);

  121.                             continue;

  122.                         }

  123.                         foreach ($val['goodsList'] as $goods) {//循环添加子产品

  124.                             if ($goods['status'] == true) {

  125.                                 $prod_name_son = $util::doCdada($goods['goodsName']);

  126.                                 $prod_code_son = $goods['goodsId'];

  127.                                 if (array_key_exists($prod_code_son, $code_arr_son)) {//商品已经存在

  128.                                     $son_prod = $opera_prod->uptLvmamaProdSon($prod_code_son, $prod_name_son, $remark, $refund_limit_day, $refund_limit_time, $is_refund, $parent_id);

  129.                                 } else {

  130.                                     $son_prod = $opera_prod->insLvmamaProdSon($parent_id, $prod_name_son, $prod_code_son, $refund_limit_day, $refund_limit_time, $is_refund);

  131.                                 }

  132.                                 if ($son_prod['code'] != 0) {

  133.                                     file_put_contents(__DIR__ . '/../log/lvmama/' . date("Y-m-d") . '.log', date("Y-m-d H:i:s") . $son_prod['msg'] . $prod_code_son . "   批量定时添加子门票产品出错" . PHP_EOL, FILE_APPEND);

  134.                                     continue;

  135.                                 }

  136.                             } else {//商品下架

  137.                                 $outside_ticket->cancelGoods($val['productId'], $goods['goodsId']);

  138.                             }

  139.                         }

  140.                     } else {//产品下架

  141.                         $opera_prod->cancelProductByCode($val['productId']);

  142.                     }

  143.                 }

  144.             }

  145.         }

  146.     }

  147. 

  148.     /**

  149.      * Function Description:批量价格、库存信息

  150.      * Function Name: actionGetProdPriceList

  151.      *

  152.      *

  153.      * @author 娄梦宁

  154.      */

  155.     public function actionGetProdPriceList()

  156.     {

  157.         set_time_limit(0);

  158.         $util = new Util();

  159.         $opera_prod = new OperaProduct();

  160.         $outside_ticket = new OutsideTicket();

  161.         //请求参数构建

  162.         $time = time();

  163.         $appKey = $util->getAppKey();

  164.         $timestamp = $time;

  165.         $sign = $util::SingForLvmama($time);

  166.         $currentPage = 1;

  167.         $beginDate = date('Y-m-d');

  168.         $endDate = date('Y-m-d', strtotime('+ 30 day'));

  169.         $url = $util->getBaseUrl() . '/ticketProd/productPriceListByPage' . "?appKey=" . $appKey . "&messageFormat=json&timestamp=" . $timestamp . "&sign=" . $sign .

  170.             "&currentPage=" . $currentPage . "&beginDate=" . $beginDate . "&endDate=" . $endDate;

  171.         $prod_list = Utils::httpRequest($url);

  172.         //查出opera_prod表中所有的code（即驴妈妈的productId）

  173.         $code_arr = $opera_prod->getCodeArr();

  174.         //循环所有页数,每次结果插入opera_ticket

  175.         $prod_list = json_decode($prod_list, true);

  176.         for ($currentPage = 1; $currentPage <= $prod_list['totalPage']; $currentPage++) {

  177.             if ($currentPage == 1) {

  178.                 $tmp_arr = $prod_list;

  179.             } else {

  180.                 $url = $util->getBaseUrl() . '/ticketProd/productPriceListByPage' . "?appKey=" . $appKey . "&messageFormat=json&timestamp=" . $timestamp . "&sign=" . $sign .

  181.                     "&currentPage=" . $currentPage . "&beginDate=" . $beginDate . "&endDate=" . $endDate;

  182.                 $tmp_arr = Utils::httpRequest($url);

  183.                 $tmp_arr = json_decode($tmp_arr, true);

  184.             }

  185.             foreach ($tmp_arr['priceList'] as $val) {

  186.                 //////////////////这层逻辑先不管

  187. //                if (array_key_exists($val['productId'], $code_arr)) {//如果产品在opera_prod表中，即在售

  188. //                }

  189. //                else {//加一层逻辑，获取到的产品都加到opera_prod表中，（前提是驴妈妈接口反馈都是有效数据）

  190. //                    //添加主产品

  191. //                    $prod_id = $val['productId'];

  192. //                    $prod_info = $this->GetProdById($prod_id);

  193. //                    try {

  194. //                        $prod_name = $util::doCdada($prod_info['productList'][0]['productName']);

  195. //                        //$remark = $util::doCdada($prod_info['productList'][0]['introdution']);暂不需要简介

  196. //                        $remark = '';

  197. //                        foreach ($prod_info['productList'][0]['bookinginfo'] as $book) {

  198. //                            $remark .= $util::doCdada($book);

  199. //                        }

  200. //                    } catch (Exception $e) {

  201. //                        file_put_contents(__DIR__ . '/../log/lvmama/' . date("Y-m-d") . '.log', date("Y-m-d H:i:s") . $prod_id . "   添加产品获取详情出错" . PHP_EOL, FILE_APPEND);

  202. //                        continue;

  203. //                    }

  204. //                    $main_prod_id = $opera_prod->istLvmamaProdMain($prod_id, $prod_name, $remark);

  205. //                    if ($main_prod_id['code'] != 0) {

  206. //                        file_put_contents(__DIR__ . '/../log/lvmama/' . date("Y-m-d") . '.log', date("Y-m-d H:i:s") . $main_prod_id['msg'] . $prod_id . "   添加主门票产品出错" . PHP_EOL, FILE_APPEND);

  207. //                        continue;

  208. //                    }

  209. //                    foreach ($val['goodsList']['goods'] as $goods) {//循环添加子产品

  210. //                        $parent_id_son = $main_prod_id['prod_id'];

  211. //                        $prod_name_son = $util::doCdada($goods['goodsName']);

  212. //                        $prod_code_son = $goods['goodsId'];

  213. //                        $son_prod = $opera_prod->insLvmamaProdSon($parent_id_son, $prod_name_son, $prod_code_son);

  214. //                        if ($son_prod['code'] != 0) {

  215. //                            file_put_contents(__DIR__ . '/../log/lvmama/' . date("Y-m-d") . '.log', date("Y-m-d H:i:s") . $son_prod['msg'] . $prod_code_son . "   添加子门票产品出错" . PHP_EOL, FILE_APPEND);

  216. //                            continue;

  217. //                        }

  218. //                    }

  219. //                    $code_arr = $opera_prod->getCodeArr();

  220. //                }

  221.                 if ($val['productStatus'] == true) {//产品上线中

  222.                     foreach ($val['goodsList']['goods'] as $v) {//循环prod下的商品，

  223.                         if ($v['goodsOnLine'] == true) {//商品上线中

  224.                             if (!empty($v['prices'])) {

  225.                                 foreach ($v['prices']['price'] as $value) {//循环不同的价格日历

  226.                                     $tmp_prod_code = $val['productId'];

  227.                                     $tmp_prod_name = $code_arr[$tmp_prod_code]['prod_name'];

  228.                                     $tmp_ticket_code = $v['goodsId'];

  229.                                     $tmp_ticket_date = $value['date'];

  230.                                     $tmp_ticket_name = $util::doCdada($v['goodsName']);

  231.                                     $tmp_ticket_num = $value['stock'] == -1 ? 9999 : $value['stock'];

  232.                                     $tmp_ticket_price = $value['b2bPrice'];

  233.                                     $tmp_agent_price = $value['sellPrice'];

  234.                                     $tmp_cs_prod_id = $code_arr[$tmp_prod_code]['prod_id'];

  235.                                     $tmp_insert = $outside_ticket->InsertData($tmp_prod_code, $tmp_prod_name, $tmp_ticket_code, $tmp_ticket_date, $tmp_ticket_name,

  236.                                         $tmp_ticket_num, $tmp_ticket_price, $tmp_agent_price, $tmp_cs_prod_id);

  237.                                     if (!$tmp_insert) {

  238.                                         file_put_contents(__DIR__ . '/../log/lvmama/' . date("Y-m-d") . '.log', date("Y-m-d H:i:s") . $tmp_prod_code . $tmp_prod_name . $tmp_ticket_date

  239.                                             . "批量接口插入更新失败" . PHP_EOL, FILE_APPEND);

  240.                                     }

  241.                                 }

  242.                             }

  243.                         } else {//商品已下线

  244.                             $outside_ticket->cancelGoods($val['productId'], $v['goodsId']);

  245.                         }

  246.                     }

  247.                 } else {//产品已下线

  248.                     $opera_prod->cancelProductByCode($val['productId']);

  249.                 }

  250.             }

  251.         }

  252.     }

  253. 

  254. 

  255.     /**

  256.      * Function Description:通过id获取产品信息

  257.      * Function Name: actionGetProdById

  258.      *

  259.      *

  260.      * @author 娄梦宁

  261.      */

  262.     public function GetProdById($productIds)

  263.     {

  264.         $util = new Util();

  265.         //请求参数构建

  266.         $time = time();

  267.         $appKey = $util->getAppKey();

  268.         $timestamp = $time;

  269.         $sign = $util::SingForLvmama($time);

  270.         $url = $util->getBaseUrl() . '/ticketProd/productInfoList' . "?appKey=" . $appKey . "&messageFormat=json&timestamp=" . $timestamp . "&sign=" . $sign . "&productIds=" . $productIds;

  271.         $result = Utils::httpRequest($url);

  272.         return json_decode($result, true);

  273.     }

  274. 

  275.     /**

  276.      * Function Description:定时任务通过id同步产品信息

  277.      * Function Name: actionGetProdById

  278.      *

  279.      *

  280.      * @author 娄梦宁

  281.      */

  282.     public function actionUptProdById()

  283.     {

  284.         set_time_limit(0);

  285.         $opera_prod = new OperaProduct();

  286.         $util = new Util();

  287.         //获取驴妈妈渠道下所有产品id

  288.         $prod_arr = $opera_prod->getIdForLvmama();

  289.         foreach ($prod_arr as $val) {//循环处理各产品

  290.             if ($val['productStatus'] == true) {//产品在驴妈妈上架

  291.                 $prod_info = $this->GetProdById($val['prod_code']);

  292.                 try {

  293.                     $prod_name = $util::doCdada($prod_info['productList'][0]['productName']);

  294.                     $remark = '';

  295.                     foreach ($prod_info['productList'][0]['bookingInfo'] as $book) {

  296.                         $remark .= $util::doCdada($book);

  297.                     }

  298.                 } catch (Exception $e) {

  299.                     file_put_contents(__DIR__ . '/../log/lvmama/' . date("Y-m-d") . '.log', date("Y-m-d H:i:s") . $val['prod_code'] . "   定时更新产品id获取详情出错" . PHP_EOL, FILE_APPEND);

  300.                     continue;

  301.                 }

  302.                 $main_prod_id = $opera_prod->uptLvmamaProdMain($val['prod_code'], $prod_name, $remark);

  303.                 if ($main_prod_id['code'] != 0) {

  304.                     file_put_contents(__DIR__ . '/../log/lvmama/' . date("Y-m-d") . '.log', date("Y-m-d H:i:s") . $main_prod_id['msg'] . $val['prod_code'] . "    定时更新产品id出错" . PHP_EOL, FILE_APPEND);

  305.                     continue;

  306.                 }

  307.             }

  308. //            else {//产品在驴妈妈下架

  309. //                $opera_prod->cancelProductByCode($val['productId']);

  310. //            }

  311.         }

  312.     }

  313. 

  314.     /**

  315.      * Function Description:通过id获取商品信息

  316.      * Function Name: actionGetGoodById

  317.      *

  318.      *

  319.      * @author 娄梦宁

  320.      */

  321.     public function GetGoodById($goodsIds)

  322.     {

  323.         $util = new Util();

  324.         //请求参数构建

  325.         $time = time();

  326.         $appKey = $util->getAppKey();

  327.         $timestamp = $time;

  328.         $sign = $util::SingForLvmama($time);

  329.         $url = $util->getBaseUrl() . '/ticketProd/goodInfoList' . "?appKey=" . $appKey . "&messageFormat=json&timestamp=" . $timestamp . "&sign=" . $sign . "&goodsIds=" . $goodsIds;

  330.         $result = Utils::httpRequest($url);

  331.         return json_decode($result, true);

  332.     }

  333. 

  334.     public function actionTest(){

  335.         $util = new Util();

  336.         //请求参数构建

  337.         $time = time();

  338.         $appKey = $util->getAppKey();

  339.         $timestamp = $time;

  340.         $beginDate = date('Y-m-d');

  341.         $endDate = date('Y-m-d', strtotime('+ 60 day'));

  342.         $sign = $util::SingForLvmama($time);

  343.         $url = $util->getBaseUrl() . '/ticketProd/productInfoList' . "?appKey=" . $appKey . "&messageFormat=json&timestamp=" . $timestamp . "&sign=" . $sign . "&productIds=" . 1040730;

  344.        // $url = $util->getBaseUrl() . '/ticketProd/goodInfoList' . "?appKey=" . $appKey . "&messageFormat=json&timestamp=" . $timestamp . "&sign=" . $sign . "&goodsIds=" . 934395;

  345.         $url = $util->getBaseUrl() . '/ticketProd/goodPriceList' . "?appKey=" . $appKey . "&messageFormat=json&timestamp=" . $timestamp . "&sign=" . $sign . "&goodsIds=" . 9992857 . "&beginDate=" . $beginDate . "&endDate=" . $endDate;

  346.         $result = Utils::httpRequest($url);

  347.         print_r(json_decode($result, true));

  348.     }

  349. 

  350.     /**

  351.      * Function Description:定时任务通过id同步商品信息

  352.      * Function Name: actionGetProdById

  353.      *

  354.      *

  355.      * @author 娄梦宁

  356.      */

  357.     public function actionUptGoodById()

  358.     {

  359.         set_time_limit(0);

  360.         $opera_prod = new OperaProduct();

  361.         $outside_ticket = new OutsideTicket();

  362.         $util = new Util();

  363.         //获取驴妈妈渠道下所有子产品code

  364.         $prod_arr = $opera_prod->getSonIdForLvmama();

  365.         foreach ($prod_arr as $val) {

  366.             $prod_info = $this->GetGoodById($val['prod_code']);

  367.             if ($prod_info['goodsList'][0]['status'] == true) {//商品在驴妈妈上架则更新信息

  368.                 try {

  369.                     $prod_name = $util::doCdada($prod_info['goodsList'][0]['goodsName']);

  370.                     $remark = $util::doCdada($prod_info['goodsList'][0]['importentPoint']);

  371.                     $is_refund = $prod_info['goodsList'][0]['rules'][0]['isChange'];

  372.                     $refund_limit_day = 1;

  373.                     $refund_limit_time = '23:00';

  374.                     if ($is_refund == 1 && isset($prod_info['goodsList'][0]['rules'][0]['aheadTime'])) {//可以退款就同步退款规则

  375.                         $limit_day_time = $util::countRefundTime($prod_info['goodsList'][0]['rules'][0]['aheadTime']);

  376.                         $refund_limit_day = $limit_day_time['day'];

  377.                         $refund_limit_time = $limit_day_time['time'];

  378.                     }

  379.                 } catch (Exception $e) {

  380.                     file_put_contents(__DIR__ . '/../log/lvmama/' . date("Y-m-d") . '.log', date("Y-m-d H:i:s") . $val['prod_code'] . "   定时更新产品id获取详情出错" . PHP_EOL, FILE_APPEND);

  381.                     continue;

  382.                 }

  383.                 $main_prod_id = $opera_prod->uptLvmamaProdSon($val['prod_code'], $prod_name, $remark, $refund_limit_day, $refund_limit_time, $is_refund);

  384.                 if ($main_prod_id['code'] != 0) {

  385.                     file_put_contents(__DIR__ . '/../log/lvmama/' . date("Y-m-d") . '.log', date("Y-m-d H:i:s") . $main_prod_id['msg'] . $val['prod_code'] . "    定时更新产品id出错" . PHP_EOL, FILE_APPEND);

  386.                     continue;

  387.                 }

  388.                 //同步两天后价格日历信息

  389.                 $this->GetGoodPriceList($val['prod_code']);

  390.             } else {//商品在驴妈妈下架

  391.                 $outside_ticket->cancelGoods($val['productId'], $val['goodsId']);

  392.             }

  393.         }

  394.     }

  395.     /**

  396.      * Function Description:按 ID 获取价格库存接口

  397.      * Function Name: GetGoodPriceList

  398.      * @param $goodsIds

  399.      *

  400.      *

  401.      * @author 娄梦宁

  402.      */

  403.     public function GetGoodPriceList($goodsIds)

  404.     {

  405.         $util = new Util();

  406.         $outside_ticket = new OutsideTicket();

  407.         $opera_prod = new OperaProduct();

  408.         //请求参数构建

  409.         $time = time();

  410.         $appKey = $util->getAppKey();

  411.         $timestamp = $time;

  412.         $beginDate = date('Y-m-d');

  413.         $endDate = date('Y-m-d', strtotime('+ 2 day'));

  414.         $sign = $util::SingForLvmama($time);

  415.         $url = $util->getBaseUrl() . '/ticketProd/goodPriceList' . "?appKey=" . $appKey . "&messageFormat=json&timestamp=" . $timestamp . "&sign=" . $sign . "&goodsIds=" . $goodsIds . "&beginDate=" . $beginDate . "&endDate=" . $endDate;

  416.         $result = Utils::httpRequest($url);

  417.         $result = json_decode($result, true);

  418.         //查出opera_prod表中所有的code（即驴妈妈的productId）

  419. 

  420.         $code_arr = $opera_prod->getCodeArr();

  421.         if ($result['state']['code'] != 1000) {

  422.             file_put_contents(__DIR__ . '/../log/lvmama/' . date("Y-m-d") . '.log', date("Y-m-d H:i:s") . '按 ID 获取商品价格库存接口接口访问失败  ' . $result['state']['solution'] . PHP_EOL, FILE_APPEND);

  423.         }

  424.         foreach ($result['priceList'] as $val) {

  425.             if ($val['productStatus'] == true) {

  426.                 foreach ($val['goodsList']['goods'] as $v) {

  427.                     if ($v['goodsOnLine'] == true) {

  428.                         if ($v['prices']['price']) {

  429.                             foreach ($v['prices']['price'] as $value) {

  430.                                 $tmp_prod_code = $val['productId'];

  431.                                 $tmp_prod_name = $code_arr[$tmp_prod_code]['prod_name'];

  432.                                 $tmp_ticket_code = $v['goodsId'];

  433.                                 $tmp_ticket_date = $value['date'];

  434.                                 $tmp_ticket_name = $util::doCdada($v['goodsName']);

  435.                                 $tmp_ticket_num = $value['stock'] == -1 ? 9999 : $value['stock'];

  436.                                 $tmp_ticket_price = $value['b2bPrice'];

  437.                                 $tmp_agent_price = $value['sellPrice'];

  438.                                 $tmp_cs_prod_id = $code_arr[$tmp_prod_code]['prod_id'];

  439.                                 $tmp_insert = $outside_ticket->InsertData($tmp_prod_code, $tmp_prod_name, $tmp_ticket_code, $tmp_ticket_date, $tmp_ticket_name,

  440.                                     $tmp_ticket_num, $tmp_ticket_price, $tmp_agent_price, $tmp_cs_prod_id);

  441.                                 if (!$tmp_insert) {

  442.                                     file_put_contents(__DIR__ . '/../log/lvmama/' . date("Y-m-d") . '.log', date("Y-m-d H:i:s") . $tmp_prod_code . $tmp_prod_name . $tmp_ticket_date

  443.                                         . "单产品插入更新失败" . PHP_EOL, FILE_APPEND);

  444.                                 }

  445.                             }

  446.                         }

  447.                     } else {//商品下架不在此处理

  448.                         continue;

  449.                     }

  450.                 }

  451.             } else {//产品下架不在此处理

  452.                 continue;

  453.             }

  454.         }

  455.     }

  456. 

  457.     /**

  458.      * Function Description:按 ID 获取景区信息接口(不通)

  459.      * Function Name: actionGetScenicListById

  460.      *

  461.      *

  462.      * @author 娄梦宁

  463.      */

  464.     public function actionGetScenicListById()

  465.     {

  466.         $util = new Util();

  467.         //请求参数构建

  468.         $time = time();

  469.         $appKey = $util->getAppKey();

  470.         $timestamp = $time;

  471.         $scenicId = 1;

  472.         $sign = $util::SingForLvmama($time);

  473.         $url = $util->getBaseUrl() . '/ticketProd/scenicInfoList' . "?appKey=" . $appKey . "&messageFormat=json&timestamp=" . $timestamp . "&sign=" . $sign . "&scenicId=" . $scenicId;

  474.         $result = Utils::httpRequest($url);

  475.         print_r($result);

  476.     }

  477. 

  478.     /**

  479.      * Function Description:订单校验接口

  480.      * Function Name: actionValidateOrder

  481.      *

  482.      *

  483.      * @author 娄梦宁

  484.      */

  485.     public function actionValidateOrder()

  486.     {

  487.         $util = new Util();

  488.         //请求参数构建

  489.         $time = time();

  490.         $appKey = $util->getAppKey();

  491.         $timestamp = $time;

  492.         $sign = $util::SingForLvmama($time);

  493.         $order_info = [

  494.             'request' => [

  495.                 'orderInfo' => [

  496.                     'partnerOrderNo' => 5633325,

  497.                     'orderAmount' => 160,

  498.                     'product' => [

  499.                         'productId' => 434492,

  500.                         'goodsId' => 1646663,

  501.                         'quantity' => 2,

  502.                         'visitDate' => '2017-04-12',

  503.                         'sellPrice' => 80

  504.                     ],

  505.                     'booker' => [

  506.                         'name' => '名字',

  507.                         'mobile' => '18616307052',

  508.                         'email' => '326017639@qq.com'

  509.                     ],

  510.                     'travellers' => [

  511.                         'traveller' => [

  512.                             'name' => '中文',

  513.                             'enName' => 'TYPE_NUM_NO',

  514.                             'credentialsType' => 'ID_CARD',

  515.                             'credentials' => '430321199212251717',

  516.                             'mobile' => '18616307052',

  517.                         ],

  518.                     ]

  519.                 ]]];

  520.         $order_info = $util::arrayToXml($order_info);

  521.         $url = $util->getBaseUrl() . '/ticket/validateOrder' . "?appKey=" . $appKey . "&messageFormat=Xml&timestamp=" . $timestamp . "&sign=" . $sign . "&request=" . $order_info;

  522.         $result = Utils::httpRequest($url);

  523.         $result = $util::xmlToJson($result);

  524.         print_r($url);

  525.         print_r(json_decode($result, true));

  526.     }

  527. 

  528.     /**

  529.      * Function Description:创建订单接口

  530.      * Function Name: actionCreateOrder

  531.      *

  532.      *

  533.      * @author 娄梦宁

  534.      */

  535.     public function actionCreateOrder()

  536.     {

  537.         $util = new Util();

  538.         //请求参数构建

  539.         $time = time();

  540.         $appKey = $util->getAppKey();

  541.         $timestamp = $time;

  542.         $sign = $util::SingForLvmama($time);

  543.         $order_info = [

  544.             'request' => [

  545.                 'orderInfo' => [

  546.                     'partnerOrderNo' => 812437,

  547.                     'orderAmount' => 20,

  548.                     'product' => [

  549.                         'productId' => 434492,

  550.                         'goodsId' => 1646663,

  551.                         'quantity' => 2,

  552.                         'visitDate' => '2017-04-14',

  553.                         'sellPrice' => 80

  554.                     ],

  555.                     'booker' => [

  556.                         'name' => '名字',

  557.                         'mobile' => '18616307052',

  558.                         'email' => '326017639@qq.com'

  559.                     ],

  560.                     'travellers' => [

  561.                         'traveller' => [

  562.                             'name' => '中文',

  563.                             'enName' => 'TYPE_NUM_NO',

  564.                             'credentialsType' => 'ID_CARD',

  565.                             'credentials' => '430321199212251717',

  566.                             'mobile' => '18616307052',

  567.                             'email' => '326017639@qq.com'

  568.                         ],

  569.                     ]

  570.                 ]]];

  571.         $order_info = $util::arrayToXml($order_info);

  572.         $url = $util->getBaseUrl() . '/ticket/createOrder' . "?appKey=" . $appKey . "&messageFormat=Xml&timestamp=" . $timestamp . "&sign=" . $sign . "&request=" . $order_info;

  573.         $result = Utils::httpRequest($url);

  574.         $result = $util::xmlToJson($result);

  575.         print_r($url);

  576.         print_r(json_decode($result, true));

  577.     }

  578. 

  579.     /**

  580.      * Function Description:订单支付接口

  581.      * Function Name: actionOrderPayment

  582.      *

  583.      *

  584.      * @author 娄梦宁

  585.      */

  586.     public function actionOrderPayment()

  587.     {

  588.         $util = new Util();

  589.         //请求参数构建

  590.         $time = time();

  591.         $appKey = $util->getAppKey();

  592.         $timestamp = $time;

  593.         $sign = $util::SingForLvmama($time);

  594.         $order = [

  595.             'request' => [

  596.                 'order' => [

  597.                     'partnerOrderNo' => 633333,

  598.                     'orderId' => 20060214,

  599.                     'serialNum' => 111111111111111111

  600.                 ]

  601.             ]

  602.         ];

  603.         $order = $util::arrayToXml($order);

  604.         $url = $util->getBaseUrl() . '/order/orderPayment' . "?appKey=" . $appKey . "&messageFormat=Xml&timestamp=" . $timestamp . "&sign=" . $sign . "&request=" . $order;

  605.         $result = Utils::httpRequest($url);

  606.         print_r($url);

  607.         print_r($result);

  608.     }

  609. 

  610.     /**

  611.      * Function Description:获取订单详情

  612.      * Function Name: actionGetOrderInfo

  613.      *

  614.      *

  615.      * @author 娄梦宁

  616.      */

  617.     public function actionGetOrderInfo()

  618.     {

  619.         $main_order_id=Yii::$app->request->get('order_id');

  620.         $order_ids=OrderMain::find()->select('order_id')->from(OrderMain::tableName())

  621.             ->where(['parent_order_id'=>$main_order_id])->asArray()->all();

  622.         $tmp_id=[];

  623.         foreach($order_ids as $v){

  624.             $tmp_id[]=$v['order_id'];

  625.         }

  626.         $ids=LvmamaOrderConnect::find()->select('GROUP_CONCAT(partner_id) as ids')->from(LvmamaOrderConnect::tableName())

  627.             ->where(['in','partner_id',$tmp_id])

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

  629.         $util = new Util();

  630.         //请求参数构建

  631.         $time = time();

  632.         $appKey = $util->getAppKey();

  633.         $sign = $util::SingForLvmama($time);

  634.         $order = [

  635.             'request' => [

  636.                 'order' => [

  637.                     'partnerOrderNos' => $ids['ids']

  638.                 ]

  639.             ]

  640.         ];

  641.         $order = $util::arrayToXmlForLvmama($order);

  642.         $get_data=array(

  643.             "appKey" =>$appKey,

  644.             'messageFormat'=>'Xml',

  645.             'timestamp'=>$time,

  646.             'sign'=>$sign,

  647.             'request'=>$order,

  648.         );

  649.         $url_param = http_build_query($get_data);

  650.         $result=file_get_contents( util::getBaseUrl(). 'order/getOrderInfo?'.$url_param);

  651. //        $url = $util->getBaseUrl() . '/order/getOrderInfo' . "?appKey=" . $appKey . "&messageFormat=Xml&timestamp=" . $timestamp . "&sign=" . $sign . "&request=" . $order;

  652. //        $result = Utils::httpRequest($url);

  653.         $result=$util::xmlToArray($result);

  654.         var_dump($result);

  655.     }

  656. 

  657.     /**

  658.      * Function Description:申请退款接口

  659.      * Function Name: actionOrderCancel

  660.      *

  661.      *

  662.      * @author 娄梦宁

  663.      */

  664.     public function actionOrderCancel()

  665.     {

  666.         $util = new Util();

  667.         //请求参数构建

  668.         $time = time();

  669.         $appKey = $util->getAppKey();

  670.         $timestamp = $time;

  671.         $sign = $util::SingForLvmama($time);

  672.         $PartnerOrderNo = 812499;

  673.         $orderId = 20060329;

  674.         $url = $util->getBaseUrl() . '/ticket/orderCancel' . "?appKey=" . $appKey . "&messageFormat=json&timestamp=" . $timestamp . "&sign=" . $sign . "&PartnerOrderNo=" . $PartnerOrderNo . "&orderId=" . $orderId;

  675.         $result = Utils::httpRequest($url);

  676.         $result = json_decode($result, true);

  677.         print_r($url);

  678.         print_r($result);

  679.         if ($result['state']['code'] == '1000') {

  680.             if ($result['order']['requestStatus'] == 'PASS') {

  681.                 return '已退款';

  682.             } elseif ($result['order']['requestStatus'] == 'REVIEWING') {

  683.                 return '审核中';

  684.             } else {

  685.                 return '申请驳回  ' . $result['order']['refundInfo'];

  686.             }

  687.         }

  688.         return false;

  689.     }

  690. 

  691.     /**

  692.      * Function Description:退款推送接口

  693.      * Function Name: actionPushOrderCancel

  694.      *

  695.      * @return string

  696.      *

  697.      * @author 娄梦宁

  698.      */

  699.     public function actionPushOrderCancel()

  700.     {

  701.         $util = new Util();

  702.         $lvmama_push_info = new LvmamaPushInfo();

  703.         $order = Yii::$app->request->post('order', '');

  704.         $order = Util::xmlToJson($order);

  705.         file_put_contents(__DIR__ . '/../log/lvmama/' . date("Y-m-d") . '.log', date("Y-m-d H:i:s") . '退款推送接口  ' . $order . PHP_EOL, FILE_APPEND);

  706.         $lvmama_push_info->istPush('退款推送接口', $order);

  707.         $order = json_decode($order, true);

  708.         $order_id = $order['body']['order']['orderId'];

  709.         $secret = $util::getSecret();

  710.         if (md5($secret . $order_id) == $order['header']['signed']) {

  711.             if ($order) {

  712.                 if($order['requestStatus'] =='REJECT'){//申请已驳回，发送短信通知

  713.                     $content="预警：驴妈妈后台直连取消门票失败，订单号({$order['partnerOrderID']})，请及时处理。";

  714.                     $phone_arr=[

  715.                         '18367152515',

  716.                         '18667946782',

  717.                         '13872284051',

  718. //                        '18874559393',

  719.                     ];

  720.                     foreach($phone_arr as $phone){

  721.                         $send_result=Msg::sendTelMsg($phone,$content);

  722.                         if($send_result !==0){

  723.                             file_put_contents(__DIR__ . '/../log/lvmama/' . date("Y-m-d") . '.log', date("Y-m-d H:i:s") . '退款推送接口   短信发送失败  ' . $order .'  '.$send_result. PHP_EOL, FILE_APPEND);

  724.                         }

  725.                     }

  726.                 }

  727.                 $result = [

  728.                     'response' => [

  729.                         'state' => [

  730.                             'code' => 1000,

  731.                             'message' => '接收成功'

  732.                         ]

  733.                     ]

  734.                 ];

  735.                 return '<?xml version="1.0" encoding="utf-8"?>' . Util::arrayToXml($result);

  736.             }

  737.         }

  738.         $result = [

  739.             'response' => [

  740.                 'state' => [

  741.                     'code' => 25,

  742.                     'message' => '签名错误'

  743.                 ]

  744.             ]

  745.         ];

  746.         return '<?xml version="1.0" encoding="utf-8"?>' . Util::arrayToXml($result);

  747.     }

  748. 

  749.     /**

  750.      * Function Description:接收产品推送接口

  751.      * Function Name: actionPushProductChange

  752.      *

  753.      * @return string

  754.      *

  755.      * @author 娄梦宁

  756.      */

  757.     public function actionPushProductChange()

  758.     {

  759.         $result = [

  760.             'response' => [

  761.                 'state' => [

  762.                     'code' => 1000,

  763.                     'message' => '接收成功'

  764.                 ]

  765.             ]

  766.         ];

  767.         return '<?xml version="1.0" encoding="utf-8"?>' . Util::arrayToXml($result);

  768.         $lvmama_push_info = new LvmamaPushInfo();

  769.         $product = Yii::$app->request->post('product', '');

  770.         $product = Util::xmlToJson($product);

  771.         file_put_contents(__DIR__ . '/../log/lvmama/' . date("Y-m-d") . '.log', date("Y-m-d H:i:s") . '产品变更接收推送接口  ' . $product . PHP_EOL, FILE_APPEND);

  772.         $lvmama_push_info->istPush('产品推送接口', $product);

  773.         $product = json_decode($product, true);

  774.         $secret = Util::getSecret();

  775.         $changeType = $product['body']['changeType'];

  776.         if (md5($secret . $changeType) != $product['header']['signed']) {

  777.             $result = [

  778.                 'response' => [

  779.                     'state' => [

  780.                         'code' => 25,

  781.                         'message' => '签名错误'

  782.                     ]

  783.                 ]

  784.             ];

  785.             return '<?xml version="1.0" encoding="utf-8"?>' . Util::arrayToXml($result);

  786.         }

  787.         if ($changeType == 'price_change') {//价格日历变更时处理

  788.             $prod=$product['body']['product'];

  789.             if(isset($prod['productId'])){

  790.                 $this->GetGoodPriceList($prod['goodsId']);

  791.             }else{

  792.                 foreach($prod as $val){

  793.                     $this->GetGoodPriceList($val['goodsId']);

  794.                 }

  795.             }

  796.         } elseif ($changeType == 'product_create') {//新增产品

  797.             $this->AddNewProd($product['body']['product']['productId']);

  798.         }

  799.         $result = [

  800.             'response' => [

  801.                 'state' => [

  802.                     'code' => 1000,

  803.                     'message' => '接收成功'

  804.                 ]

  805.             ]

  806.         ];

  807.         return '<?xml version="1.0" encoding="utf-8"?>' . Util::arrayToXml($result);

  808.     }

  809. 

  810.     /**

  811.      * Function Description:新增产品时操作

  812.      * Function Name: AddNewProd

  813.      * @param $prod_id

  814.      *

  815.      * @return bool

  816.      *

  817.      * @author 娄梦宁

  818.      */

  819.     public function AddNewProd($prod_id)

  820.     {

  821.         //添加主产品

  822.         $util = new Util();

  823.         $opera_prod = new OperaProduct();

  824.         $prod_info = $this->GetProdById($prod_id);

  825.         try {

  826.             $prod_name = $util::doCdada($prod_info['productList'][0]['productName']);

  827.             $remark = $util::doCdada($prod_info['productList'][0]['introdution']);

  828.         } catch (Exception $e) {

  829.             return false;

  830.         }

  831.         $main_prod_id = $opera_prod->istLvmamaProdMain($prod_id, $prod_name, $remark);

  832.         if ($main_prod_id['code'] != 0) {

  833.             file_put_contents(__DIR__ . '/../log/lvmama/' . date("Y-m-d") . '.log', date("Y-m-d H:i:s") . $main_prod_id['msg'] . $prod_id . "   添加单个主门票产品出错" . PHP_EOL, FILE_APPEND);

  834.         }

  835.         return true;

  836.     }

  837. 

  838.     /**

  839.      * Function Description:重发凭证接口

  840.      * Function Name: actionResendCode

  841.      *

  842.      *

  843.      * @author 娄梦宁

  844.      */

  845.     public function actionResendCode()

  846.     {

  847.         $util = new Util();

  848.         //请求参数构建

  849.         $time = time();

  850.         $appKey = $util->getAppKey();

  851.         $timestamp = $time;

  852.         $sign = $util::SingForLvmama($time);

  853.         $request = [

  854.             'request' => [

  855.                 'order' => [

  856.                     'partnerOrderNos' => 633333,

  857.                     'orderId' => 20060214

  858.                 ]

  859.             ]

  860.         ];

  861.         $request = $util::arrayToXml($request);

  862.         $url = $util->getBaseUrl() . '/order/resendCode' . "?appKey=" . $appKey . "&messageFormat=xml&timestamp=" . $timestamp . "&sign=" . $sign . "&request=" . $request;

  863.         $result = Utils::httpRequest($url);

  864.         print_r($url);

  865.         print_r($result);

  866.     }

  867. 

  868.     /**

  869.      * Function Description:订单信息推送接口

  870.      * Function Name: actionPushOrderInfo

  871.      *

  872.      * @return string

  873.      *

  874.      * @author 娄梦宁

  875.      */

  876.     public function actionPushOrderInfo()

  877.     {

  878.         $util = new Util();

  879.         $lvmama_push_info = new LvmamaPushInfo();

  880.         $order_refund_lvmama = new OrderRefundLvmama();

  881.         $order = Yii::$app->request->post('order', '');

  882.         $order = Util::xmlToJson($order);

  883.         file_put_contents(__DIR__ . '/../log/lvmama/' . date("Y-m-d") . '.log', date("Y-m-d H:i:s") . '订单信息推送接收的json  ' . $order . PHP_EOL, FILE_APPEND);

  884.         // $order='{"header":{"signed":"dc0914aed23133d528ae4cd2779d484a"},"body":{"order":{"orderId":"20060214","status":"CANCEL","approveStatus":"true","paymentStatus":"PAYED","credenctStatus":"CREDENCE_SEND","waitPayment":{},"performStatus":"USED","credentials":"CREDENCE_SEND"}}}';

  885.         $lvmama_push_info->istPush('订单信息推送接口', $order);

  886.         $order = json_decode($order, true);

  887.         $order_id = $order['body']['order']['orderId'];

  888.         $secret = $util::getSecret();

  889.         file_put_contents(__DIR__ . '/../log/lvmama/' . date("Y-m-d") . '.log', date("Y-m-d H:i:s") . '订单信息推送接收的json  ' . $order_id . PHP_EOL, FILE_APPEND);

  890.         file_put_contents(__DIR__ . '/../log/lvmama/' . date("Y-m-d") . '.log', date("Y-m-d H:i:s") . '订单信息推送接收的json  ' . md5($secret . $order_id) . PHP_EOL, FILE_APPEND);

  891.         file_put_contents(__DIR__ . '/../log/lvmama/' . date("Y-m-d") . '.log', date("Y-m-d H:i:s") . '订单信息推送接收的json  ' . $order['header']['signed'] . PHP_EOL, FILE_APPEND);

  892. 

  893. 

  894. 

  895.         if (md5($secret . $order_id) == $order['header']['signed']) {

  896.             if ($order['body']['order']['status'] == 'CANCEL' || $order['body']['order']['status'] == 'REFUND') {//订单信息推送操作

  897.                 $status = $order['body']['order']['status'];

  898.                 $approve_status = $order['body']['order']['approveStatus'] == true ? 1 : 0;

  899.                 $payment_status = $order['body']['order']['paymentStatus'] == 'PAYED' ? 1 : 0;

  900.                 $istRefund = $order_refund_lvmama->istRefund($order_id, $status, $approve_status, $payment_status);

  901.                 if ($istRefund == false) {

  902.                     file_put_contents(__DIR__ . '/../log/lvmama/' . date("Y-m-d") . '.log', date("Y-m-d H:i:s") . '订单信息推送录入数据库失败 ' . $order_id . PHP_EOL, FILE_APPEND);

  903.                 }

  904.             }

  905.             $result = [

  906.                 'response' => [

  907.                     'state' => [

  908.                         'code' => 1000,

  909.                         'message' => '接收成功'

  910.                     ]

  911.                 ]

  912.             ];

  913.         } else {

  914.             $result = [

  915.                 'response' => [

  916.                     'state' => [

  917.                         'code' => 25,

  918.                         'message' => '签名错误'

  919.                     ]

  920.                 ]

  921.             ];

  922.         }

  923.         return '<?xml version="1.0" encoding="utf-8"?>' . Util::arrayToXml($result);

  924.     }

  925. 

  926.     public function actionTest1(){

  927. 

  928. 

  929. //        $time=time();

  930. ////        $url="http://api.lvmama.com/distributorApi/2.0/api//ticket/createOrder?appKey=ZHIZHUCHUXING&messageFormat=Xml&timestamp=1510279231&sign=eb2c9be41fc8b923d1e81a6f7594f68a&request=<request><orderInfo><partnerOrderNo>1803444</partnerOrderNo><orderAmount>453</orderAmount><product><productId>622407</productId><goodsId>3081796</goodsId><quantity>1</quantity><visitDate>2017-11-11</visitDate><sellPrice>453.00</sellPrice></product><booker><name>陈梦云</name><mobile>18951971757</mobile></booker><travellers><traveller><name>陈梦云</name><credentialsType>ID_CARD</credentialsType><credentials>46010319920707034X</credentials><mobile>18951971757</mobile></traveller></travellers></orderInfo></request>";

  931. //        $sign=Util::SingForLvmama($time);

  932. //        ini_set('user_agent','Mozilla/4.0 (compatible; MSIE 7.0; Windows NT 5.1; .NET CLR 2.0.50727; .NET CLR 3.0.04506.30; GreenBrowser)');

  933. //        $url='http://api.lvmama.com/distributorApi/2.0/api/ticket/createOrder?appKey=ZHIZHUCHUXING&messageFormat=Xml&timestamp=1510292787&sign=6a9c59bb3b273b7e3b41e7baa23a003b&request=<request><orderInfo><partnerOrderNo>1804849</partnerOrderNo><orderAmount>453</orderAmount><product><productId>622407</productId><goodsId>3081796</goodsId><quantity>1</quantity><visitDate>2017-11-11</visitDate><sellPrice>453.00</sellPrice></product><booker><name>丁倩</name><mobile>13815403234</mobile></booker><travellers><traveller><name>丁倩</name><credentialsType>ID_CARD</credentialsType><credentials>330903199209090226</credentials><mobile>13815403234</mobile></traveller></travellers></orderInfo></request>';

  934. //        $result=file_get_contents($url);

  935. //       // $result=Util::OrderPayment(56614790,1803444,'56614790'.'1803444_'.time());

  936. //        print_r($result);

  937.         $result=Util::OrderPayment(1804849,56626116,'1804849'.'56626116_'.time());

  938.         print_r($result);

  939.     }

  940. 

  941. }