nizongfeng
/
ZZCX_yii
1
0
Fork 0
Koodi Ongelmat 0 Pull-pyynnöt 0 Julkaisut 0 Wiki Toiminta
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 Commitit
1 Haara
96 MiB
 
 
 
 
 
 
Haara: master
Branchit Tagit
${ item.name }
Create branch ${ searchTerm }
from 'master'
${ noResults }
ZZCX_yii/backend/modules/api/logic/SubmitGroupData.php

839 rivejä
34 KiB
Raaka Pysyvä linkki Blame Historia 

  1. <?php

  2. /**

  3.  *

  4.  * ============================================================================

  5.  * * 版权所有 蜘蛛出行 * *

  6.  * 网站地址: http://www.zhizhuchuxing.com

  7.  * ----------------------------------------------------------------------------

  8.  * 这不是一个自由软件！您只能在不用于商业目的的前提下对程序代码进行修改和

  9.  * 使用；不允许对程序代码以任何形式任何目的的再发布。

  10.  * ============================================================================

  11.  * Author By: 张帅

  12.  * PhpStorm SubmitData.php

  13.  * Create By 2017/4/20 10:48 $

  14.  */

  15. 

  16. namespace backend\modules\api\logic;

  17. 

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

  19. use backend\modules\api\models\OrderComment;

  20. use backend\modules\api\models\OrderGroupConnect;

  21. use backend\modules\api\models\OrderHtConsumeStock;

  22. use backend\modules\api\models\OrderOperaLog;

  23. use backend\modules\api\models\OrderPayDetail;

  24. use backend\modules\api\models\OrderPayMain;

  25. use backend\modules\api\models\OrderStatusLog;

  26. use backend\modules\api\models\OrderTitle;

  27. use backend\modules\api\models\RunBus;

  28. use backend\modules\api\models\RunHotel;

  29. use backend\modules\api\models\RunHotelDistrib;

  30. use backend\modules\api\models\RunProd;

  31. use backend\modules\api\models\RunStock;

  32. use backend\modules\api\models\OrderHtStatusLog;

  33. use backend\modules\api\models\OperaHotelLog;

  34. use yii\db\Exception;

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

  36. use yii\db\Expression;

  37. use yii\db\Query;

  38. use Yii;

  39. 

  40. class SubmitGroupData extends Query

  41. {

  42.     public $order_title_base;//组合订单数据配置

  43. 

  44.     public $order_group_connect_base;//组合订单关联配置

  45. 

  46.     public $order_main_base = [];//订单基础配置

  47. 

  48.     public $pay_main_base = [];//主支付记录基础配置

  49. 

  50.     public $pay_detail_base = [];//支付明细基础配置

  51. 

  52.     public $order_id_arr = [];//订单id数组

  53. 

  54.     public $order_main_arr = [];//订单数组

  55. 

  56.     public $pay_main_arr = [];//主支付记录数组

  57. 

  58.     public $pay_detail_arr = [];//支付明细记录

  59. 

  60.     public $stock_order_arr = [];//库存相关修改数组

  61. 

  62.     public $order_title_id = 0;//组合订单号

  63. 

  64.     public $product_result;//预定产品信息

  65. 

  66.     /**

  67.      * Function Description:获取基础信息

  68.      * Function Name: getBaseData

  69.      * @param array $order_title_base 组合订单数据配置

  70.      * @param array $order_group_connect_base 组合订单关联配置

  71.      * @param array $order_main_base 订单基础配置

  72.      * @param array $order_main_arr 订单数组

  73.      * @param array $pay_main_base 主支付记录基础配置

  74.      * @param array $pay_main_arr 主支付记录数组

  75.      * @param array $pay_detail_base 支付明细基础配置

  76.      * @param array $pay_detail_arr 支付明细记录

  77.      * @param array $order_id_arr 订单id数组

  78.      * @param array $stock_order_arr 库存相关修改数组

  79.      * @param array $product_result 预定产品信息

  80.      *

  81.      * @author 张帅

  82.      */

  83.     public function getBaseData($order_title_base, $order_group_connect_base, $order_main_base, $order_main_arr, $pay_main_base, $pay_main_arr, $pay_detail_base, $pay_detail_arr, $order_id_arr, $stock_order_arr, $product_result)

  84.     {

  85.         $this->order_title_base = $order_title_base;//组合订单数据配置

  86.         $this->order_group_connect_base = $order_group_connect_base;//组合订单关联配置

  87.         $this->order_main_base = $order_main_base;//订单基础配置

  88. 

  89.         $order_arr = [];//订单数组

  90.         foreach ($order_main_arr as $key => $vel) {

  91.             $order_arr[$vel['ID']] = $vel;

  92.         }

  93.         $this->order_main_arr = $order_arr;//订单数组

  94. 

  95.         $this->pay_main_base = $pay_main_base;//主支付记录基础配置

  96.         $this->pay_main_arr = $pay_main_arr;//主支付记录数组

  97.         $this->pay_detail_base = $pay_detail_base;//支付明细基础配置

  98.         $this->pay_detail_arr = $pay_detail_arr;//支付明细记录

  99.         $this->order_id_arr = $order_id_arr;//订单id数组

  100.         $this->stock_order_arr = $stock_order_arr;//库存相关修改数组

  101. 

  102.         $this->product_result = $product_result;//预定产品信息

  103.     }

  104. 

  105.     /**

  106.      * Function Description:提交order_main数据

  107.      * Function Name: submitOrderMain

  108.      *

  109.      *

  110.      * @author 张帅

  111.      */

  112.     public function submitOrderMain()

  113.     {

  114.         try {

  115.             #region 获取提交的表头和值

  116.             $order_main_base = $this->order_main_base;

  117.             $order_main_key = array_keys($order_main_base);

  118.             $order_main_vel = $this->order_main_arr;

  119.             #endregion

  120. 

  121.             #region 组合订单下单更新ORDER_TITLE_ID

  122.             if ($this->order_title_id != 0) {

  123.                 foreach ($order_main_vel as $key => $vel) {

  124.                     if ($vel['AGENT_LEVEL'] == 1) {  //只有终端订单才加上order_title_id

  125.                         $order_main_vel[$key]['ORDER_TITLE_ID'] = $this->order_title_id;

  126.                     }

  127.                 }

  128.             }

  129.             #endregion

  130. 

  131.             $this->order_main_arr = $order_main_vel;

  132. 

  133.             #region 提交数据

  134.             $order_main = new OrderMain();

  135.             $res = $order_main::find()->createCommand()->batchInsert(OrderMain::tableName(), $order_main_key, $order_main_vel)->execute();

  136.             if (!$res) {

  137.                 $error = $order_main->getErrors();

  138.                 throw new Exception(json_encode($error));

  139.             }

  140.             #endregion

  141. 

  142.             $json['code'] = '0';

  143.             $json['info'] = '成功';

  144. 

  145.         } catch (Exception $e) {

  146.             $json['code'] = '1';

  147.             $json['info'] = '失败';

  148.             $json['error'] = '提交order_main数据:' . $e->getMessage();

  149.         }

  150. 

  151.         return $json;

  152.     }

  153. 

  154.     /**

  155.      * Function Description:提交order_pay_main数据

  156.      * Function Name: submitOrderPayMain

  157.      *

  158.      * @return mixed

  159.      *

  160.      * @author 张帅

  161.      */

  162.     public function submitOrderPayMain()

  163.     {

  164.         try {

  165.             #region 获取提交的表头和值

  166.             $pay_main_base = $this->pay_main_base;

  167.             $pay_main_key = array_keys($pay_main_base);

  168.             $pay_main_vel = $this->pay_main_arr;

  169.             #endregion

  170. 

  171.             #region 提交数据

  172.             $order_pay_main = new OrderPayMain();

  173.             $res = $order_pay_main::find()->createCommand()->batchInsert(OrderPayMain::tableName(), $pay_main_key, $pay_main_vel)->execute();

  174.             if (!$res) {

  175.                 $error = $order_pay_main->getErrors();

  176.                 throw new Exception(json_encode($error));

  177.             }

  178.             #endregion

  179. 

  180.             $json['code'] = '0';

  181.             $json['info'] = '成功';

  182. 

  183.         } catch (Exception $e) {

  184.             $json['code'] = '1';

  185.             $json['info'] = '失败';

  186.             $json['error'] = '提交order_pay_main数据:' . $e->getMessage();

  187.         }

  188. 

  189.         return $json;

  190.     }

  191. 

  192.     /**

  193.      * Function Description:提交order_pay_detail数据

  194.      * Function Name: submitOrderPayDetail

  195.      *

  196.      * @return mixed

  197.      *

  198.      * @author 张帅

  199.      */

  200.     public function submitOrderPayDetail()

  201.     {

  202.         try {

  203.             #region 获取提交的表头和值

  204.             $pay_detail_base = $this->pay_detail_base;

  205.             $pay_detail_key = array_keys($pay_detail_base);

  206.             $pay_detail_vel = $this->pay_detail_arr;

  207.             #endregion

  208. 

  209.             #region 提交数据

  210.             $order_pay_detail = new OrderPayDetail();

  211.             $res = $order_pay_detail::find()->createCommand()->batchInsert(OrderPayDetail::tableName(), $pay_detail_key, $pay_detail_vel)->execute();

  212.             if (!$res) {

  213.                 $error = $order_pay_detail->getErrors();

  214.                 throw new Exception(json_encode($error));

  215.             }

  216.             #endregion

  217. 

  218.             $json['code'] = '0';

  219.             $json['info'] = '成功';

  220. 

  221.         } catch (Exception $e) {

  222.             $json['code'] = '1';

  223.             $json['info'] = '失败';

  224.             $json['error'] = '提交order_pay_detail数据:' . $e->getMessage();

  225.         }

  226. 

  227.         return $json;

  228.     }

  229. 

  230.     /**

  231.      * Function Description:修改巴士库存

  232.      * Function Name: updateBusStockInfo

  233.      *

  234.      * @return mixed

  235.      *

  236.      * @author 张帅

  237.      */

  238.     public function updateBusStockInfo()

  239.     {

  240.         try {

  241.             #region 1.更新run_x

  242.             $run_x_arr = $this->stock_order_arr['run_x_arr'];

  243.             foreach ($run_x_arr as $key => $vel) {

  244.                 $run_month = date('Ym', strtotime($vel['run_date']));//run_x表名

  245.                 $update_sql = 'update run_' . $run_month . '

  246.                                 set order_main_id = ' . $vel['order_main_id'] . ',

  247.                                 order_main_prod_id = ' . $vel['order_main_prod_id'] . ',

  248.                                 order_prod_id = ' . $vel['order_prod_id'] . ',

  249.                                 seat_status = ' . $vel['seat_status'] . ',

  250.                                 order_lock_user_id = ' . $vel['order_lock_user_id'] . ',

  251.                                 order_lock_time = \'' . $vel['order_lock_time'] . '\'

  252.                                 where id in (' . implode(',', $vel['run_x_id']) . ')';

  253. 

  254.                 $res = Yii::$app->db->createCommand($update_sql)->execute();

  255.                 if (!$res) {

  256.                     throw new Exception('占位失败');

  257.                 }

  258.             }

  259.             #endregion

  260. 

  261.             #region 2.更新run_bus

  262.             $run_bus = new RunBus();

  263.             $run_bus_arr = $this->stock_order_arr['run_bus_arr'];

  264.             foreach ($run_bus_arr as $key => $vel) {

  265.                 $update_value = [

  266.                     'UPDATE_USER_ID' => $vel['update_user_id'],

  267.                     'UPDATE_TIME' => $vel['update_time'],

  268.                     'SALED_COUNT' => new Expression('SALED_COUNT+' . $vel['num']),

  269.                 ];

  270.                 $update_where = [

  271.                     'and',

  272.                     ['=', 'run_id', $vel['run_id']],

  273.                     ['=', 'bus_order_id', $vel['bus_order_id']],

  274.                     ['=', 'cancel_flag', 0],

  275.                 ];

  276.                 $res = $run_bus::updateAll($update_value, $update_where);

  277.                 if (!$res) {

  278.                     $error = $run_bus->getErrors();

  279.                     throw new Exception(json_encode($error));

  280.                 }

  281.             }

  282.             #endregion

  283. 

  284.             #region 2.1 更新bus_cost

  285.             foreach ($run_bus_arr as $k => $v) {

  286.                 $res = SubmitBusAgentOrder::updateBusCost($v['run_id'], $v['bus_order_id']);

  287.                 if (!file_exists(__DIR__ . '/../log/bus_cost')) {

  288.                     mkdir(__DIR__ . '/../log/bus_cost');

  289.                 }

  290.                 file_put_contents(__DIR__ . '/../log/bus_cost/' . date("Y-m-d") . '.log', date("Y-m-d H:i:s") . json_encode($res) . PHP_EOL, FILE_APPEND);

  291.             }

  292.             #endregion

  293. 

  294.             #region 3.更新run_prod

  295.             $run_prod = new RunProd();

  296.             $run_prod_arr = $this->stock_order_arr['run_prod_arr'];

  297.             foreach ($run_prod_arr as $key => $vel) {

  298.                 $update_value = [

  299.                     'UPDATE_USER_ID' => $vel['update_user_id'],

  300.                     'UPDATE_TIME' => $vel['update_time'],

  301.                     'SALED_COUNT' => new Expression('SALED_COUNT+' . $vel['num']),

  302.                 ];

  303.                 $update_where = [

  304.                     'and',

  305.                     ['=', 'run_id', $vel['run_id']],

  306.                     ['=', 'prod_id', $vel['ticket_id']],

  307.                     ['=', 'cancel_flag', 0],

  308.                 ];

  309.                 $res = $run_prod::updateAll($update_value, $update_where);

  310.                 if (!$res) {

  311.                     $error = $run_prod->getErrors();

  312.                     throw new Exception(json_encode($error));

  313.                 }

  314.             }

  315.             #endregion

  316. 

  317.             #region 4.更新run_stock

  318.             $run_stock = new RunStock();

  319.             $run_stock_arr = $this->stock_order_arr['run_stock_arr'];

  320.             foreach ($run_stock_arr as $key => $vel) {

  321.                 $update_value = [

  322.                     'UPDATE_USER_ID' => $vel['update_user_id'],

  323.                     'UPDATE_TIME' => $vel['update_time'],

  324.                     'SALED_COUNT' => new Expression('SALED_COUNT+' . $vel['num']),

  325.                 ];

  326.                 $update_where = [

  327.                     'and',

  328.                     ['=', 'run_id', $vel['run_id']],

  329.                     ['=', 'seq_id', $vel['seq_id']],

  330.                     ['=', 'seat_type', $vel['seat_type']],

  331.                     ['=', 'cancel_flag', 0],

  332.                 ];

  333.                 $res = $run_stock::updateAll($update_value, $update_where);

  334.                 if (!$res) {

  335.                     $error = $run_stock->getErrors();

  336.                     throw new Exception(json_encode($error));

  337.                 }

  338.             }

  339.             #endregion

  340. 

  341.             $json['code'] = '0';

  342.             $json['info'] = '成功';

  343.         } catch (Exception $e) {

  344.             $json['code'] = '1';

  345.             $json['info'] = '失败';

  346.             $json['error'] = '修改巴士库存失败:' . $e->getMessage();

  347.         }

  348. 

  349.         return $json;

  350.     }

  351. 

  352.     /**

  353.      * Function Description:修改酒店库存

  354.      * Function Name: updateHotelStockInfo

  355.      *

  356.      * @return mixed

  357.      *

  358.      * @author 张帅

  359.      */

  360.     public function updateHotelStockInfo()

  361.     {

  362. 

  363.         try {

  364.             #region 1.更新run_hotel

  365.             $run_hotel = new RunHotel();

  366.             $run_hotel_arr = $this->stock_order_arr['run_hotel_arr'];

  367.             foreach ($run_hotel_arr as $key => $vel) {

  368.                 $update_value = [

  369.                     'UPDATE_USER_ID' => $vel['update_user_id'],

  370.                     'UPDATE_TIME' => $vel['update_time'],

  371.                     'REMAINING_COUNT' => new Expression('REMAINING_COUNT-' . $vel['num']),

  372.                     'SALED_COUNT' => new Expression('SALED_COUNT+' . $vel['num']),

  373.                 ];

  374.                 $update_where = [

  375.                     'and',

  376.                     ['=', 'hotel_id', $vel['hotel_id']],

  377.                     ['=', 'base_room_type', $vel['base_room_type']],

  378.                     ['=', 'run_date', $vel['run_date']],

  379.                     ['=', 'stock_type', $vel['stock_type']],

  380.                 ];

  381.                 $res = $run_hotel::updateAll($update_value, $update_where);

  382.                 if (!$res) {

  383.                     $error = $run_hotel->getErrors();

  384.                     throw new Exception(json_encode($error));

  385.                 }

  386.             }

  387.             #endregion

  388. 

  389.             #region 2.更新run_hotel_distrib

  390.             $run_hotel_distrib = new RunHotelDistrib();

  391.             $run_hotel_distrib_arr = $this->stock_order_arr['run_hotel_distrib_arr'];

  392.             foreach ($run_hotel_distrib_arr as $key => $vel) {

  393.                 $update_value = [

  394.                     'UPDATE_USER_ID' => $vel['update_user_id'],

  395.                     'UPDATE_TIME' => $vel['update_time'],

  396.                     'REMAINING_COUNT' => new Expression('REMAINING_COUNT-' . $vel['num']),

  397.                     'SALED_COUNT' => new Expression('SALED_COUNT+' . $vel['saled_count']),

  398.                 ];

  399.                 $update_where = [

  400.                     'and',

  401.                     ['=', 'distrib_id', $vel['channel_id']],

  402.                     ['=', 'hotel_id', $vel['hotel_id']],

  403.                     ['=', 'base_room_type', $vel['base_room_type']],

  404.                     ['=', 'room_type', $vel['room_type']],

  405.                     ['=', 'run_date', $vel['run_date']],

  406.                 ];

  407.                 $res = $run_hotel_distrib::updateAll($update_value, $update_where);

  408.                 if (!$res) {

  409.                     $error = $run_hotel_distrib->getErrors();

  410.                     throw new Exception(json_encode($error));

  411.                 }

  412.             }

  413.             #endregion

  414. 

  415.             #region 3.修改渠道库存

  416.             $run_hotel_disperse_result = $this->stock_order_arr['run_hotel_disperse_result'];

  417.             #region 3.1 渠道借房

  418.             if (count($run_hotel_disperse_result['run_hotel_distrib_disperse_arr']) > 0) {

  419.                 foreach ($run_hotel_disperse_result['run_hotel_distrib_disperse_arr'] as $key => $vel) {

  420.                     $update_value = [

  421.                         'UPDATE_USER_ID' => $vel['update_user_id'],

  422.                         'UPDATE_TIME' => $vel['update_time'],

  423.                         'REMAINING_COUNT' => new Expression('REMAINING_COUNT-' . $vel['num']),

  424.                     ];

  425.                     $update_where = [

  426.                         'and',

  427.                         ['=', 'distrib_id', $vel['distrib_id']],

  428.                         ['=', 'hotel_id', $vel['hotel_id']],

  429.                         ['=', 'base_room_type', $vel['base_room_type']],

  430.                         ['=', 'room_type', $vel['room_type']],

  431.                         ['=', 'run_date', $vel['run_date']],

  432.                     ];

  433.                     $res = $run_hotel_distrib::updateAll($update_value, $update_where);

  434.                     if (!$res) {

  435.                         $error = $run_hotel_distrib->getErrors();

  436.                         throw new Exception(json_encode($error));

  437.                     }

  438.                 }

  439.             }

  440.             #endregion

  441. 

  442.             #region 3.2 订单借房记录

  443.             if (count($run_hotel_disperse_result['order_ht_consume_stock']) > 0) {

  444.                 $order_ht_consume_stock = new OrderHtConsumeStock();

  445.                 $order_ht_consume_stock_vel = [];

  446.                 $order_ht_consume_stock_key = ['order_id', 'distrib_id', 'run_date', 'consume_stock_count'];

  447.                 foreach ($run_hotel_disperse_result['order_ht_consume_stock'] as $key => $vel) {

  448.                     $order_ht_consume_stock_vel[] = [

  449.                         'order_id' => $vel['order_id'],

  450.                         'distrib_id' => $vel['distrib_id'],

  451.                         'run_date' => $vel['run_date'],

  452.                         'consume_stock_count' => $vel['num'],

  453.                     ];

  454.                 }

  455.                 $res = $order_ht_consume_stock::find()->createCommand()->batchInsert(OrderHtConsumeStock::tableName(), $order_ht_consume_stock_key, $order_ht_consume_stock_vel)->execute();

  456.                 if (!$res) {

  457.                     $error = $order_ht_consume_stock->getErrors();

  458.                     throw new Exception(json_encode($error));

  459.                 }

  460.             }

  461.             #endregion

  462. 

  463.             #region 4.更新order_comment

  464.             if (count($this->stock_order_arr['order_comment_arr']) > 0) {

  465.                 $order_comment_vel = $this->stock_order_arr['order_comment_arr'];

  466.                 $order_comment_key = array_keys($order_comment_vel[0]);

  467.                 #region 提交数据

  468.                 $order_comment = new OrderComment();

  469.                 $res = $order_comment::find()->createCommand()->batchInsert(OrderComment::tableName(), $order_comment_key, $order_comment_vel)->execute();

  470.                 if (!$res) {

  471.                     $error = $order_comment->getErrors();

  472.                     throw new Exception(json_encode($error));

  473.                 }

  474.                 #endregion

  475.             }

  476.             #endregion

  477. 

  478.             #endregion

  479. 

  480.             $json['code'] = '0';

  481.             $json['info'] = '成功';

  482.         } catch (Exception $e) {

  483.             $json['code'] = '1';

  484.             $json['info'] = '失败';

  485.             $json['error'] = '修改酒店库存:' . $e->getMessage();

  486.         }

  487. 

  488.         return $json;

  489.     }

  490. 

  491.     /**

  492.      * Function Description:修改门票库存

  493.      * Function Name: updateTicketStockInfo

  494.      *

  495.      * @return mixed

  496.      *

  497.      * @author 张帅

  498.      */

  499.     public function updateTicketStockInfo()

  500.     {

  501.         try {

  502.             #region 更新opera_product_run

  503.             $opera_product_run = new OperaProductRun();

  504.             $opera_product_run_arr = $this->stock_order_arr['opera_product_run_arr'];

  505.             foreach ($opera_product_run_arr as $key => $vel) {

  506.                 $update_value = [

  507.                     'UPDATE_USER_ID' => $vel['update_user_id'],

  508.                     'UPDATE_TIME' => $vel['update_time'],

  509.                     'SALED_COUNT' => new Expression('SALED_COUNT+' . $vel['num']),

  510.                 ];

  511.                 $update_where = [

  512.                     'and',

  513.                     ['=', 'prod_id', $vel['ticket_id']],

  514.                     ['=', 'run_date', $vel['run_date']],

  515.                     ['=', 'cancel_flag', 0],

  516.                 ];

  517.                 $res = $opera_product_run::updateAll($update_value, $update_where);

  518. 

  519.                 if (!$res) {

  520.                     $error = $opera_product_run->getErrors();

  521.                     throw new Exception(json_encode($error));

  522.                 }

  523.             }

  524.             #endregion

  525. 

  526.             $json['code'] = '0';

  527.             $json['info'] = '成功';

  528.         } catch (Exception $e) {

  529.             $json['code'] = '1';

  530.             $json['info'] = '失败';

  531.             $json['error'] = '修改门票库存:' . $e->getMessage();

  532.         }

  533. 

  534.         return $json;

  535.     }

  536. 

  537.     /**

  538.      * Function Description:提交组合订单信息

  539.      * Function Name: submitOrderTitle

  540.      *

  541.      * @return mixed

  542.      *

  543.      * @author 张帅

  544.      */

  545.     public function submitOrderTitle()

  546.     {

  547.         try {

  548.             $order_title = new OrderTitle();

  549.             $order_group_connect = new OrderGroupConnect();

  550. 

  551.             $order_group_connect_vel = [];//组合订单关联数组

  552.             $order_group_connect_key = array_keys($this->order_group_connect_base);//组合订单关联表头

  553. 

  554. 

  555.             $order_title_base = $this->order_title_base;//组合订单数据配置

  556.             $order_id_arr = $this->order_id_arr;//订单id数组

  557. 

  558.             #region 提交order_title数据

  559. 

  560.             #region 巴士产品订单号

  561.             if (isset($order_id_arr['bus_product'])) {

  562.                 $order_title_base['bus_order'] = implode(',', $order_id_arr['bus_product']);//对应子巴士产品订单号，多个用逗号隔开

  563.                 #region 获取组合订单关联数组

  564.                 foreach ($order_id_arr['bus_product'] as $key => $vel) {

  565.                     $order_group_connect_one = $this->order_group_connect_base;

  566.                     $order_group_connect_one['order_main_id'] = $vel;

  567.                     $order_group_connect_one['order_type'] = 1;

  568.                     $order_group_connect_vel[] = $order_group_connect_one;

  569.                 }

  570.                 #endregion

  571.             }

  572.             #endregion

  573. 

  574.             #region 酒店产品订单号

  575.             if (isset($order_id_arr['hotel_product'])) {

  576.                 $order_title_base['hotel_order'] = implode(',', $order_id_arr['hotel_product']);//对应酒店子产品订单号，多个用逗号隔开

  577.                 #region 获取组合订单关联数组

  578.                 foreach ($order_id_arr['hotel_product'] as $key => $vel) {

  579.                     $order_group_connect_one = $this->order_group_connect_base;

  580.                     $order_group_connect_one['order_main_id'] = $vel;

  581.                     $order_group_connect_one['order_type'] = 2;

  582.                     $order_group_connect_vel[] = $order_group_connect_one;

  583.                 }

  584.                 #endregion

  585.             }

  586.             #endregion

  587. 

  588.             #region 门票产品订单号

  589.             if (isset($order_id_arr['ticket_product'])) {

  590.                 $order_title_base['ticket_order'] = implode(',', $order_id_arr['ticket_product']);//对应门票子产品订单号，多个用逗号隔开

  591.                 #region 获取组合订单关联数组

  592.                 foreach ($order_id_arr['ticket_product'] as $key => $vel) {

  593.                     $order_group_connect_one = $this->order_group_connect_base;

  594.                     $order_group_connect_one['order_main_id'] = $vel;

  595.                     $order_group_connect_one['order_type'] = 3;

  596.                     $order_group_connect_vel[] = $order_group_connect_one;

  597.                 }

  598.                 #endregion

  599.             }

  600.             #endregion

  601. 

  602.             $order_title->attributes = $order_title_base;

  603.             $res = $order_title->insert();

  604.             if (!$res) {

  605.                 $error = $order_title->getErrors();

  606.                 throw new Exception(json_encode($error));

  607.             }

  608. 

  609.             $order_title_id = $order_title->order_title_id;

  610. 

  611.             $this->order_title_id = $order_title_id;

  612. 

  613.             #endregion

  614. 

  615.             #region 提交order_group_connect数据

  616.             foreach ($order_group_connect_vel as $key => $vel) {

  617.                 $order_group_connect_vel[$key]['order_title_id'] = $order_title_id;

  618.             }

  619. 

  620.             $res = $order_group_connect::find()->createCommand()->batchInsert(OrderGroupConnect::tableName(), $order_group_connect_key, $order_group_connect_vel)->execute();

  621.             if (!$res) {

  622.                 $error = $order_group_connect->getErrors();

  623.                 throw new Exception(json_encode($error));

  624.             }

  625.             #endregion

  626. 

  627. 

  628.             $json['code'] = '0';

  629.             $json['info'] = '成功';

  630.             $json['order_title_id'] = $order_title_id;

  631.         } catch (Exception $e) {

  632.             $json['code'] = '1';

  633.             $json['info'] = '失败';

  634.             $json['error'] = '提交组合订单信息:' . $e->getMessage();

  635.         }

  636. 

  637.         return $json;

  638.     }

  639. 

  640.     /**

  641.      * Function Description:提交巴士日志

  642.      * Function Name: submitBusLog

  643.      *

  644.      * @return mixed

  645.      *

  646.      * @author 温依莅

  647.      */

  648.     public function submitBusLog()

  649.     {

  650.         $order_id_arr = $this->order_id_arr;//订单id数组

  651.         $bus_order_arr = $order_id_arr['bus_product'];//巴士订单数组

  652.         $order_main_arr = $this->order_main_arr;//订单数据

  653.         $order_base_info = $this->product_result['order_info'];//订单基础配置

  654. 

  655.         $bus_product_list = array();//巴士产品信息（包含代售信息）

  656.         //这里对巴士产品信息按主订单号重排，方便下面订单日志对代售信息插入对应数据

  657.         foreach ($this->product_result['bus_product'] as $bk => $bv) {

  658.             $bus_product_list[$bv['order_id']] = $bv;

  659.         }

  660. 

  661.         $order_opera_log_vel = [];//巴士操作日志

  662.         $order_opera_log_key = [];//巴士操作日志表头

  663.         $order_status_log_vel = [];//巴士状态日志

  664.         $order_status_log_key = [];//巴士状态日志表头

  665. 

  666.         try {

  667.             foreach ($bus_order_arr as $key => $vel) {

  668.                 $order_info = $order_main_arr[$vel];//订单详情

  669.                 /*$order_num = explode('|', $order_info['ORDER_DESCRIPTION']);

  670.                 $order_num = end($order_num);//订单人数*/

  671. 

  672.                 #region 添加巴士日志

  673.                 foreach ($bus_product_list[$key]['agent_list'] as $ik => $iv) {

  674.                     $title_info = ($iv['agent_level'] == 1 ? '【组合订单号：' . $order_info['ORDER_TITLE_ID'] . '】' : '');

  675.                     $order_opera_log_one = [

  676.                         'order_id' => $iv['order_id'],

  677.                         'opera_user_id' => $iv['agent_level'] == 1 ? $order_info['CREATE_USER_ID'] : 2,

  678.                         'opera_type' => 1,

  679.                         'opera_time' => date('Y-m-d H:i:s'),

  680.                         'opera_detail' => '创建订单，出发日期' . $order_info['RUN_DATE'] . '，订单渠道:' . $iv['outside_sale_org_name'] . '，单价' . $iv['price'] . '，总额' . $iv['total_order_price'] . '，联系人信息：' . $order_info['CUSTOMER_NAME'] . ',' . $order_info['CUSTOMER_MOBILE'] . ',' . $order_info['CUSTOMER_ID_NO'] . '，备注信息：' . $order_info['CUSTOMER_MEMO'] . $title_info,

  681.                         'member_id' => $order_info['MEMBER_ID'],

  682.                         'opera_platform' => '统一下单',

  683.                     ];

  684.                     if (count($order_opera_log_key) == 0) {

  685.                         $order_opera_log_key = array_keys($order_opera_log_one);//巴士操作日志表头

  686.                     }

  687.                     $order_opera_log_vel[] = $order_opera_log_one;//巴士操作日志

  688.                 }

  689. 

  690.                 #endregion

  691. 

  692.                 #region 添加巴士订单状态

  693.                 $order_status = $order_info['ORDER_PAY_STATUS'] == 1 ? [451, 452, 453] : [451];

  694.                 foreach ($order_status as $status_key => $status_vel) {

  695.                     foreach ($bus_product_list[$key]['agent_list'] as $ik => $iv) {

  696.                         $order_status_log_one = [

  697.                             'order_id' => $iv['order_id'],

  698.                             'new_status' => $status_vel,

  699.                             'change_time' => date('Y-m-d H:i:s'),

  700.                         ];

  701.                         if (count($order_status_log_key) == 0) {

  702.                             $order_status_log_key = array_keys($order_status_log_one);//巴士状态日志表头

  703.                         }

  704.                         $order_status_log_vel[] = $order_status_log_one;//巴士状态日志

  705.                     }

  706.                 }

  707.                 #endregion

  708.             }

  709. 

  710.             #region 提交巴士日志

  711.             $order_opera_log = new OrderOperaLog();

  712.             $res = $order_opera_log::find()->createCommand()->batchInsert(OrderOperaLog::tableName(), $order_opera_log_key, $order_opera_log_vel)->execute();

  713.             if (!$res) {

  714.                 $error = $order_opera_log->getErrors();

  715.                 throw new Exception(json_encode($error));

  716.             }

  717.             #endregion

  718. 

  719.             #region 提交巴士订单状态

  720.             $order_status_log = new OrderStatusLog();

  721.             $res = $order_status_log::find()->createCommand()->batchInsert(OrderStatusLog::tableName(), $order_status_log_key, $order_status_log_vel)->execute();

  722.             if (!$res) {

  723.                 $error = $order_status_log->getErrors();

  724.                 throw new Exception(json_encode($error));

  725.             }

  726. 

  727.             $json['code'] = '0';

  728.             $json['info'] = '成功';

  729.             #endregion

  730. 

  731.         } catch (Exception $e) {

  732.             $json['code'] = '1';

  733.             $json['info'] = '失败';

  734.             $json['error'] = '提交巴士日志:' . $e->getMessage();

  735.         }

  736. 

  737.         return $json;

  738.     }

  739. 

  740.     /**

  741.      * Function Description:提交酒店日志

  742.      * Function Name: submitHotelLog

  743.      *

  744.      * @return mixed

  745.      *

  746.      * @author 温依莅

  747.      */

  748.     public function submitHotelLog()

  749.     {

  750.         $order_id_arr = $this->order_id_arr;//订单id数组

  751.         $hotel_order_arr = $order_id_arr['hotel_product'];//酒店订单数组

  752.         $order_main_arr = $this->order_main_arr;//订单数据

  753. 

  754.         $opera_hotel_log_vel = [];//酒店操作日志

  755.         $opera_hotel_log_key = [];//酒店操作日志表头

  756.         $order_ht_status_log_vel = [];//酒店状态日志

  757.         $order_ht_status_log_key = [];//酒店状态日志表头

  758. 

  759.         try {

  760.             foreach ($hotel_order_arr as $key => $vel) {

  761.                 $order_info = $order_main_arr[$vel];//订单详情

  762. 

  763.                 #region 添加酒店日志

  764.                 $opera_hotel_log_one = [

  765.                     'CREATE_USER_ID' => $order_info['CREATE_USER_ID'],

  766.                     'CREATE_TIME' => $order_info['CREATE_TIME'],

  767.                     'LOG_TYPE' => 3,

  768.                     'HOTEL_ID' => $order_info['PARENT_PROD_ID'],

  769.                     'PARENT_ROOM_TYPE' => 0,

  770.                     'ROOM_TYPE' => $order_info['PROD_ID'],

  771.                     'LOG_DESC' => '组合订单：创建订单号为' . $order_info['ORDER_ID'] . '的订单,组合订单号:' . $order_info['ORDER_TITLE_ID'],

  772.                     'ORDER_ID' => $order_info['ORDER_ID'],

  773.                 ];

  774.                 if (count($opera_hotel_log_key) == 0) {

  775.                     $opera_hotel_log_key = array_keys($opera_hotel_log_one);//酒店操作日志表头

  776.                 }

  777.                 $opera_hotel_log_vel[] = $opera_hotel_log_one;//酒店操作日志

  778.                 #endregion

  779. 

  780.                 #region 添加酒店订单状态

  781.                 $order_ht_status_log_one = [

  782.                     'ORDER_ID' => $order_info['ORDER_ID'],

  783.                     'ORDER_STATUS' => 313,

  784.                     'BEFORE_STATUS' => 0,

  785.                     'CREATE_USER_ID' => $order_info['CREATE_USER_ID'],

  786.                     'CREATE_TIME' => $order_info['CREATE_TIME'],

  787.                     'UPDATE_USER_ID' => $order_info['CREATE_USER_ID'],

  788.                     'UPDATE_TIME' => $order_info['CREATE_TIME'],

  789.                     'CANCEL_FLAG' => 1,

  790.                 ];

  791.                 $order_ht_status_log_two = [

  792.                     'ORDER_ID' => $order_info['ORDER_ID'],

  793.                     'ORDER_STATUS' => 198,

  794.                     'BEFORE_STATUS' => 313,

  795.                     'CREATE_USER_ID' => $order_info['CREATE_USER_ID'],

  796.                     'CREATE_TIME' => $order_info['CREATE_TIME'],

  797.                     'UPDATE_USER_ID' => $order_info['CREATE_USER_ID'],

  798.                     'UPDATE_TIME' => $order_info['CREATE_TIME'],

  799.                     'CANCEL_FLAG' => 0,

  800.                 ];

  801.                 if (count($order_ht_status_log_key) == 0) {

  802.                     $order_ht_status_log_key = array_keys($order_ht_status_log_one);//酒店状态日志表头

  803.                 }

  804.                 $order_ht_status_log_vel[] = $order_ht_status_log_one;//酒店状态日志

  805. 

  806.                 $order_ht_status_log_vel[] = $order_ht_status_log_two;//酒店状态日志

  807.                 #endregion

  808.             }

  809. 

  810.             #region 提交酒店日志

  811.             $opera_hotel_log = new OperaHotelLog();

  812.             $res = $opera_hotel_log::find()->createCommand()->batchInsert(OperaHotelLog::tableName(), $opera_hotel_log_key, $opera_hotel_log_vel)->execute();

  813.             if (!$res) {

  814.                 $error = $opera_hotel_log->getErrors();

  815.                 throw new Exception(json_encode($error));

  816.             }

  817.             #endregion

  818. 

  819.             #region 提交酒店订单状态

  820.             $order_ht_status_log = new OrderHtStatusLog();

  821.             $res = $order_ht_status_log::find()->createCommand()->batchInsert(OrderHtStatusLog::tableName(), $order_ht_status_log_key, $order_ht_status_log_vel)->execute();

  822.             if (!$res) {

  823.                 $error = $order_ht_status_log->getErrors();

  824.                 throw new Exception(json_encode($error));

  825.             }

  826. 

  827.             $json['code'] = '0';

  828.             $json['info'] = '成功';

  829.             #endregion

  830. 

  831.         } catch (Exception $e) {

  832.             $json['code'] = '1';

  833.             $json['info'] = '失败';

  834.             $json['error'] = '提交酒店日志:' . $e->getMessage();

  835.         }

  836. 

  837.         return $json;

  838.     }

  839. }