nizongfeng
/
zzcx_line
1
0
Vork 0
Code Kwesties 0 Pull-aanvragen 0 Publicaties 0 Wiki Activiteit
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.
2 Commits
1 Branch
17 MiB
 
 
 
 
Branch: master
Branches Labels
${ item.name }
Maak branch ${ searchTerm }
van 'master'
${ noResults }
zzcx_line/coding/application/lineManager/singleLine.class.php

499 regels
22 KiB
Ruw Permalink Blame Geschiedenis 

  1. <?php

  2. 

  3. /**

  4.  * Created by PhpStorm.

  5.  * User: 张帅

  6.  * Date: 2016/10/12

  7.  * Time: 14:30

  8.  */

  9. class singleLine extends base

  10. {

  11.     /**

  12.      * @param line_id 线路id

  13.      * @param line_name 线路名称

  14.      * @param line_code 线路代码

  15.      * @param line_type 线路类型1

  16.      * @param line_sub_type 线路类型2

  17.      * @param time_type 时间类型

  18.      * @param time_info 时间

  19.      * @param supply_id 供应商id

  20.      * @param station_list 线路id  格式{上下车类型，站点顺序，到达用时，检票口，站点RES_ID,站点AREA_ID} 上下车类型： 108：上车 109:同时上下车 110：下客 114：不停靠；检票口目前默认都为0，如果有检票口需要在base_resource中配置

  21.      * @return array|null

  22.      * User: Steven

  23.      */

  24.     function addLine($param)

  25.     {

  26.         $valid = zzcsUtils::validateParams(array('line_name,line_code,line_type,line_sub_type,time_type,time_info,supply_id,station_list' => 'empty'), $param);

  27.         if (!$valid['status']) {

  28.             $result['code'] = (string)$valid['status'];

  29.             $result['info'] = $valid['info'];

  30.             return $result;

  31.         }

  32.         $line_name = isset($param['line_name']) ? trim($param['line_name']) : false;//线路名称

  33.         $line_code = isset($param['line_code']) ? trim($param['line_code']) : false;//线路代码

  34.         $line_type = isset($param['line_type']) ? trim($param['line_type']) : false;//线路类型1

  35.         $line_sub_type = isset($param['line_sub_type']) ? trim($param['line_sub_type']) : false;//线路类型2

  36.         $time_type = isset($param['time_type']) ? trim($param['time_type']) : false;//时间类型

  37.         $time_info = isset($param['time_info']) ? trim($param['time_info']) : false;//时间

  38.         $supply_id = isset($param['supply_id']) ? trim($param['supply_id']) : false;//供应商id

  39.         //格式{上下车类型，站点顺序，到达用时，检票口，站点RES_ID,站点AREA_ID} 上下车类型： 108：上车 109:同时上下车 110：下客 114：不停靠；检票口目前默认都为0，如果有检票口需要在base_resource中配置

  40.         $station_list = isset($param['station_list']) ? trim($param['station_list']) : false;//站点列表

  41.         $distance_list = isset($param['distance_list']) ? trim($param['distance_list']) : false;//站点列表

  42.         $user_id = $this->user_id;

  43.         $sql_check = 'SELECT line_id count from opera_line WHERE line_code = \'' . $line_code . '\' AND cancel_flag = 0';

  44.         $res_check = $this->query($sql_check);

  45.         if (count($res_check) > 0) {

  46.             $result['code'] = '3';

  47.             $result['info'] = "线路编号已存在";

  48.             return $result;

  49.         }

  50.         $sql = "CALL sp_add_line_station_xm(" . $user_id . ",'" . $line_name . "','" . $line_code . "'," . $line_type . "," . $line_sub_type . "," . $time_type . ",'" . $time_info . "'," . $supply_id . ",'" . $station_list . "')";

  51.         zzcsUtils::writeLog($sql);

  52.         $result = $this->procQuery($sql);

  53.         if ($result['code'] == 0) {

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

  55.             $json['info'] = '添加线路成功';

  56.             $json['line_id'] = $result['data'][0][0]['line_id'];

  57.             $json['line_type'] = $line_type;

  58.         } else {

  59.             $json['code'] = $result['code'];

  60.             $json['info'] = $result['info'];

  61.         }

  62.         return $json;

  63.     }

  64. 

  65.     /**

  66.      * 单一线路详情

  67.      * @param $param

  68.      */

  69.     function getLineDetail($param)

  70.     {

  71.         $line_id = isset($param['line_id']) ? trim($param['line_id']) : false;//线路id

  72.         if (!$line_id) {

  73.             $json['code'] = '2';

  74.             $json['info'] = '缺少必要参数';

  75.             return $json;

  76.         }

  77.         $sql = "SELECT

  78.                     l.line_id,l.line_name,l.line_code,l.line_type,l.org_id,l.sale_expired_type,l.sale_expired_time,s.order_id,s.res_id,s.start_minutes,s.inout_type,s.checkport_res_id,s.area_id,s.distance

  79.                 FROM

  80.                     opera_line AS l,

  81.                     opera_station AS s

  82.                 WHERE

  83.                     l.line_id = s.line_id

  84.                 AND l.cancel_flag = 0

  85.                 AND s.cancel_flag = 0

  86.                 AND l.line_id = " . $line_id;

  87.         $line_info = $this->query($sql);

  88.         if (count($line_info) == 0) {

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

  90.             $json['info'] = '该线路配置不全';

  91.             return $json;

  92.         }

  93.         foreach ($line_info as $k => $v) {

  94.             if (!isset($line_base_info)) {

  95.                 $line_base_info['line_id'] = $v['line_id'];

  96.                 $line_base_info['line_name'] = $v['line_name'];

  97.                 $line_base_info['line_code'] = $v['line_code'];

  98.                 $line_base_info['line_type'] = $v['line_type'];

  99.                 $line_base_info['org_id'] = $v['org_id'];

  100.                 $line_base_info['sale_expired_type'] = $v['sale_expired_type'];

  101.                 $line_base_info['sale_expired_time'] = $v['sale_expired_time'];

  102.             }

  103.             $res_base_info[$v['order_id']]['res_id'] = $v['res_id'];

  104.             $res_base_info[$v['order_id']]['inout_type'] = $v['inout_type'];

  105.             $res_base_info[$v['order_id']]['checkport_res_id'] = $v['checkport_res_id'];

  106.             $res_base_info[$v['order_id']]['area_id'] = $v['area_id'];

  107.             $res_base_info[$v['order_id']]['start_minutes'] = $v['start_minutes'];

  108.             $res_base_info[$v['order_id']]['distance'] = $v['distance'];

  109.         }

  110.         ksort($res_base_info);

  111.         foreach ($res_base_info as $order_id => $res_v) {

  112.             $res_detail_info = $this->getStationInfo(array('res_id' => $res_v['res_id']));

  113.             if ($res_detail_info['code'] != '0') {

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

  115.                 $json['info'] = '站点信息有误';

  116.                 return $json;

  117.             }

  118.             $res_detail_info = $res_detail_info['res_info'];

  119.             foreach ($res_detail_info['parent_area'] as $k => $v) {

  120.                 if ($v['id'] == $res_v['area_id']) {

  121.                     $res_detail_info['parent_area'][$k]['checked'] = '1';

  122.                 } else {

  123.                     $res_detail_info['parent_area'][$k]['checked'] = '0';

  124.                 }

  125.             }

  126.             foreach ($res_detail_info['inout_type'] as $k => $v) {

  127.                 if ($v['id'] == $res_v['inout_type']) {

  128.                     $res_detail_info['inout_type'][$k]['checked'] = '1';

  129.                 } else {

  130.                     $res_detail_info['inout_type'][$k]['checked'] = '0';

  131.                 }

  132.             }

  133.             foreach ($res_detail_info['check_port'] as $k => $v) {

  134.                 if ($v['id'] == $res_v['checkport_res_id']) {

  135.                     $res_detail_info['check_port'][$k]['checked'] = '1';

  136.                 } else {

  137.                     $res_detail_info['check_port'][$k]['checked'] = '0';

  138.                 }

  139.             }

  140.             $res_detail_info['start_minutes'] = $res_v['start_minutes'];

  141.             $res_detail_info['distance'] = $res_v['distance'];

  142.             $res_array[$order_id] = $res_detail_info;

  143.         }

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

  145.         $json['info'] = '返回数据成功';

  146.         $json['line_info'] = $line_base_info;

  147.         $json['station_info'] = array_merge($res_array);

  148.         return $json;

  149.     }

  150. 

  151.     /**

  152.      * 获取线路列表配置信息

  153.      * @return mixed

  154.      */

  155.     function getLineListBase()

  156.     {

  157.         $res = $this->productLine();  //获取产品线

  158.         $supply = $this->getSupply();

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

  160.         $json['info'] = '获取供应商列表成功';

  161.         $json['product_list'] = $res;

  162.         $json['supply_list'] = $supply;

  163.         return $json;

  164.     }

  165. 

  166.     /**

  167.      * 单一线路列表

  168.      * @param $param

  169.      */

  170.     function getLineList($post)

  171.     {

  172.         $page_size = isset($post['page_size']) ? trim($post['page_size']) : false;

  173.         $current_page = isset($post['current_page']) ? trim($post['current_page']) : false;

  174.         $line_code = isset($post['line_code']) ? (empty($post['line_code']) ? "''" : "'" . trim($post['line_code']) . "'") : false;

  175.         $supply_id = isset($post['supply_id']) ? trim($post['supply_id']) : false;

  176.         $line_status = isset($post['line_status']) ? trim($post['line_status']) : false;

  177.         $line_type = isset($post['line_type']) ? trim($post['line_type']) : false;

  178.         if (!$page_size || !$current_page || !$line_code || !$supply_id || !$line_type) {

  179.             $json['code'] = '2';

  180.             $json['info'] = '缺少必要参数';

  181.             return $json;

  182.         }

  183.         $where['line_type'] = $line_type;

  184.         $where['line_code'] = $line_code;

  185.         $where['supply_id'] = $supply_id;

  186.         $where['line_status'] = $line_status;

  187.         $start_row = ($current_page - 1) * $page_size;

  188. 

  189.         $extra_sql = "";

  190.         if (isset($_COOKIE["opera_org_id"]) && mb_strlen($_COOKIE["opera_org_id"]) > 0) {

  191.             $extra_sql .= ' AND ORG_ID IN( ' . $_COOKIE["opera_org_id"] . ' ) ';

  192.         }

  193.         if (isset($_COOKIE["user_main_corp"]) && mb_strlen($_COOKIE["user_main_corp"]) > 0 && $_COOKIE["user_main_corp"] > 0 ) {

  194.             $extra_sql .= ' AND MAIN_CORP_ID IN( ' . $_COOKIE["user_main_corp"] . ' ) ';

  195.         }

  196. 

  197.         $search_line_type = "l.line_type = " . $where['line_type'];

  198.         if( $where['line_type'] == 255 ) {

  199.             $search_line_type = "l.line_type IN (255,368) " ;//一日游线路

  200.         }

  201.         $sql = "SELECT

  202.                     l.line_id,l.line_code,l.line_name,

  203.                     IFNULL((SELECT type_name FROM dict_type WHERE id = l.line_sub_type),'') AS line_sub_type,

  204.                     IFNULL((SELECT supplier_name FROM base_supplier WHERE id = l.org_id ), '' ) AS org_name,

  205.                     CASE l.if_disabled WHEN 0 THEN '启用' ELSE '停用' END AS disabled_status,

  206.                     count(t.id) AS cnt

  207.                 FROM

  208.                     opera_line AS l LEFT JOIN       

  209.                     (SELECT id,line_id FROM opera_tickets_group WHERE cancel_flag = 0) AS t

  210.                     ON l.line_id = t.line_id

  211.                 WHERE

  212.                     l.cancel_flag = 0

  213.                 AND {$search_line_type} 

  214.                 AND IF(TRIM(" . $where['line_code'] . ")='',0=0,(l.line_code LIKE CONCAT('%'," . $where['line_code'] . ",'%') OR l.line_name LIKE CONCAT('%'," . $where['line_code'] . ",'%')))

  215.                 AND IF(TRIM(" . $where['supply_id'] . ")=-1,0=0,l.org_id = " . $where['supply_id'] . ")

  216.                 AND IF(TRIM(" . $where['line_status'] . ")=-1,0=0,l.if_disabled = " . $where['line_status'] . ")" . $extra_sql . "

  217.                 GROUP BY

  218.                     l.line_id,l.line_code,l.line_name,l.line_sub_type,l.org_id,l.if_disabled

  219.                 ORDER BY

  220.                     l.line_id DESC

  221.                 LIMIT " . $start_row . "," . $page_size;

  222.         $line_list = $this->query($sql);

  223.         if (count($line_list) == 0) {

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

  225.             $json['info'] = '没有符合的线路';

  226.             $json['line_list'] = array();

  227.             $json['page']['page_size'] = $page_size;

  228.             $json['page']['current_page'] = $current_page;

  229.             $json['page']['total_count'] = '0';

  230.             $json['page']['total_page'] = '0';

  231.             return $json;

  232.         }

  233. 

  234.         $count_sql = "SELECT

  235.                             count(line_id) as total_count

  236.                         FROM

  237.                             opera_line as l

  238.                         WHERE

  239.                             cancel_flag = 0

  240.                         AND {$search_line_type} 

  241.                         AND IF(TRIM(" . $where['line_code'] . ")='',0=0,(line_code LIKE CONCAT('%'," . $where['line_code'] . ",'%') OR line_name LIKE CONCAT('%'," . $where['line_code'] . ",'%')))

  242.                         AND IF(TRIM(" . $where['supply_id'] . ")=-1,0=0,org_id = " . $where['supply_id'] . ")

  243.                         AND IF(TRIM(" . $where['line_status'] . ")=-1,0=0,if_disabled = " . $where['line_status'] . ") " . $extra_sql ;

  244.         $total_count = $this->query($count_sql);

  245.         $total_count = $total_count[0]['total_count'];

  246.         $total_page = ceil($total_count / $page_size);

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

  248.         $json['info'] = '返回线路列表成功符合的线路';

  249.         $json['line_list'] = $line_list;

  250.         $json['page']['page_size'] = $page_size;

  251.         $json['page']['current_page'] = $current_page;

  252.         $json['page']['total_count'] = $total_count;

  253.         $json['page']['total_page'] = $total_page;

  254.         return $json;

  255.     }

  256. 

  257.     /**

  258.      * @param line_id 线路id

  259.      * @param line_name 线路名称

  260.      * @param line_code 线路代码

  261.      * @param line_type 线路类型1

  262.      * @param line_sub_type 线路类型2

  263.      * @param time_type 时间类型

  264.      * @param time_info 时间

  265.      * @param supply_id 供应商id

  266.      * @param station_list 线路id  格式{上下车类型，站点顺序，到达用时，检票口，站点RES_ID,站点AREA_ID} 上下车类型： 108：上车 109:同时上下车 110：下客 114：不停靠；检票口目前默认都为0，如果有检票口需要在base_resource中配置

  267.      * @return array|null

  268.      * User: Steven

  269.      */

  270.     function lineUpdate($param)

  271.     {

  272.         $valid = zzcsUtils::validateParams(array('line_id,line_name,line_code,line_type,line_sub_type,time_type,time_info,supply_id,station_list' => 'empty'), $param);

  273.         if (!$valid['status']) {

  274.             $result['code'] = (string)$valid['status'];

  275.             $result['info'] = $valid['info'];

  276.             return $result;

  277.         }

  278.         $user_id = $this->user_id;

  279.         $sql_check = 'SELECT line_id count from opera_line WHERE  cancel_flag = 0 AND line_code = \'' . $param['line_code'] . '\' and line_id != ' . $param['line_id'];

  280.         $res_check = $this->query($sql_check);

  281.         if (count($res_check) > 0) {

  282.             $result['code'] = '3';

  283.             $result['info'] = "线路编号已存在";

  284.             return $result;

  285.         }

  286.         $sql = "CALL sp_update_line_station_xm(" . $user_id . "," . $param['line_id'] . ",'" . $param['line_name'] . "','" . $param['line_code'] . "'," . $param['line_type'] . "," . $param['line_sub_type'] . "," . $param['time_type'] . ",'" . $param['time_info'] . "'," . $param['supply_id'] . ",'" . $param['station_list'] . "')";

  287.         zzcsUtils::writeLog($sql);

  288.         $result = $this->procQuery($sql);

  289.         if ($result['code'] == 0) {

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

  291.             $json['info'] = '修改线路成功';

  292.             $json['line_id'] = $param['line_id'];

  293.             $json['line_type'] = $param['line_type'];

  294.         } else {

  295.             $json['code'] = $result['code'];

  296.             $json['info'] = $result['info'];

  297.         }

  298.         return $json;

  299.     }

  300. 

  301.     /**

  302.      * 单一线路启用

  303.      * @param $param

  304.      */

  305.     function lineStart($param)

  306.     {

  307.         //hyk

  308.         $line_id = isset($param['line_id']) ? trim($param['line_id']) : false;

  309.         if (!$line_id) {

  310.             $json['code'] = '2';

  311.             $json['info'] = '缺少必要参数';

  312.             return $json;

  313.         }

  314.         $update_time = date('Y-m-d h:i:s');//更新时间

  315.         $sql = "update opera_line set if_disabled= 0 ,update_user_id=" . $this->user_id . " , update_time= '" . $update_time . "'  where line_id in(" . $line_id . ") and cancel_flag =0";

  316.         $result = $this->exec($sql);

  317.         if ($result === false) {

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

  319.             $json['info'] = '数据库异常';

  320.             return $json;

  321.         } else {

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

  323.             $json['info'] = '更新成功';

  324.             return $json;

  325. 

  326.         }

  327.     }

  328. 

  329.     /**

  330.      * 单一线路停用

  331.      * @param $param

  332.      */

  333.     function lineStop($param)

  334.     {

  335.         //hyk

  336.         $line_id = isset($param['line_id']) ? trim($param['line_id']) : false;

  337.         if (!$line_id) {

  338.             $json['code'] = '2';

  339.             $json['info'] = '缺少必要参数';

  340.             return $json;

  341.         }

  342.         $update_time = date('Y-m-d h:i:s');//更新时间

  343.         $sql = "update opera_line set if_disabled= 1,update_user_id=" . $this->user_id . " , update_time= '" . $update_time . "' where line_id in(" . $line_id . ") and cancel_flag =0";

  344.         $result = $this->exec($sql);

  345.         if ($result === false) {

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

  347.             $json['info'] = '数据库异常';

  348.             return $json;

  349.         } else {

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

  351.             $json['info'] = '更新成功';

  352.             return $json;

  353. 

  354.         }

  355.     }

  356. 

  357.     /**

  358.      * 获取添加线路的基础信息

  359.      * @param $param OK

  360.      */

  361.     function getBaseManager()

  362.     {

  363.         //1.售卖情况时间列表

  364.         $time_type = $this->getTimeType();

  365.         //2.巴士类型表

  366.         $bus_type = $this->getBusType();

  367.         //3.供应商列表

  368.         $supply_list = $this->getSupply();

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

  370.         $json['info'] = '返回数据成功';

  371.         $json['bus_type'] = $bus_type;

  372.         $json['supply_list'] = $supply_list;

  373.         $json['time_type'] = $time_type;

  374.         return $json;

  375.     }

  376. 

  377.     /**

  378.      * 获取全部站点

  379.      * @param $param

  380.      */

  381.     function getLineStation($post)

  382.     {

  383.         $res_name = trim($post['res_name']);//输入框输入的站点信息

  384.         $sql = "SELECT

  385.                     res_id,

  386.                     res_name

  387.                 FROM

  388.                     base_resource

  389.                 WHERE

  390.                     res_type_id = 24

  391.                 AND cancel_flag = 0

  392.                 AND res_name like '%" . $res_name . "%'";

  393.         $res_list = $this->query($sql);//场站列表

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

  395.         $json['info'] = '返回数据成功';

  396.         $json['res_list'] = $res_list;

  397.         return $json;

  398.     }

  399. 

  400.     /**

  401.      * 获取站点详情

  402.      * @param $param

  403.      */

  404.     function getStationInfo($post)

  405.     {

  406.         $res_id = trim($post['res_id']);//站点id

  407.         $check_area = "SELECT

  408.                             ifnull(area_id, 0) as area_id

  409.                         FROM

  410.                             base_resource

  411.                         WHERE

  412.                             res_id = " . $res_id;

  413.         $area = $this->query($check_area);//场站列表

  414.         if ($area[0]['area_id'] == 0) {

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

  416.             $json['info'] = '该站点无应用POI，请先配置应用POI！';

  417.             return $json;

  418.         }

  419. 

  420.         //获取站点信息详情

  421.         $station_info = "SELECT

  422.                             a.res_id,

  423.                             a.res_name,

  424.                             IFNULL(concat(b.parent_area_id_list,'{',b.area_id,'}'),'') AS parent_area_id_list,

  425.                             IFNULL(concat(b.parent_area_name_list,'{',b.area_name,'}'),'') AS parent_area_name_list,

  426.                             IFNULL(

  427.                                 (

  428.                                     SELECT

  429.                                         group_concat(res_id)

  430.                                     FROM

  431.                                         base_resource

  432.                                     WHERE

  433.                                         res_type_id = 79

  434.                                     AND cancel_flag = 0

  435.                                     AND parent_id = a.res_id

  436.                                 ),

  437.                                 0

  438.                             ) AS checkport_res_id,

  439.                             IFNULL(

  440.                                 (

  441.                                     SELECT

  442.                                         group_concat(res_name)

  443.                                     FROM

  444.                                         base_resource

  445.                                     WHERE

  446.                                         res_type_id = 79

  447.                                     AND cancel_flag = 0

  448.                                     AND parent_id = a.res_id

  449.                                 ),

  450.                                 ''

  451.                             ) AS checkport_res_name

  452.                         FROM

  453.                             base_resource a

  454.                         LEFT JOIN base_area_view b ON a.area_id = b.area_id

  455.                         WHERE

  456.                             a.cancel_flag = 0

  457.                         AND a.res_id = " . $res_id;

  458.         $res_info = $this->query($station_info);//场站详情

  459.         $res_info = $res_info[0];

  460.         $res_info['parent_area_id_list'] = substr($res_info['parent_area_id_list'], 1, -1);

  461.         $res_info['parent_area_name_list'] = substr($res_info['parent_area_name_list'], 1, -1);

  462.         $res_info['parent_area_id_list'] = explode("}{", $res_info['parent_area_id_list']);//应用POI站点id数组

  463.         $res_info['parent_area_name_list'] = explode("}{", $res_info['parent_area_name_list']);//应用POI站点name数组

  464.         $res_info['checkport_res_id'] = explode(",", $res_info['checkport_res_id']);//检票口id数组

  465.         $res_info['checkport_res_name'] = explode(",", $res_info['checkport_res_name']);//检票口name数组

  466.         //规整返回前端的站点数据

  467.         $res = array();

  468.         $res['res_id'] = $res_info['res_id'];

  469.         $res['res_name'] = $res_info['res_name'];

  470.         foreach ($res_info['parent_area_id_list'] as $k => $v) {

  471.             $res['parent_area'][$k]['id'] = $v;

  472.             $res['parent_area'][$k]['name'] = $res_info['parent_area_name_list'][$k];

  473.         }

  474.         foreach ($res_info['checkport_res_id'] as $k => $v) {

  475.             $res['check_port'][$k]['id'] = $v;

  476.             $res['check_port'][$k]['name'] = $res_info['checkport_res_name'][$k];

  477.         }

  478.         $res['inout_type'] = array(

  479.             0 => array(

  480.                 'id' => '108',

  481.                 'name' => '上'

  482.             ),

  483.             1 => array(

  484.                 'id' => '109',

  485.                 'name' => '上下'

  486.             ),

  487.             2 => array(

  488.                 'id' => '110',

  489.                 'name' => '下'

  490.             )

  491.         );

  492. 

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

  494.         $json['info'] = '返回数据成功';

  495.         $json['res_info'] = $res;

  496.         return $json;

  497.     }

  498. 

  499. }