k_online_backend/main_new_version.php

<?php

$max_ec = ini_get('max_execution_time'); //set max_excution_time
ini_set('max_execution_time', '600');
$memory_limit = "";
$action = "";
if (isset($_GET['action']))
    $action = strtolower($_GET['action']);
if (isset($_POST['action']))
    $action = strtolower($_POST['action']);

include "include.ini.php";
include 'service/ocean_booking.class.php';
include 'service/ocean_order.class.php';
include 'service/operation_log.class.php';
include 'service/search.class.php';
include 'service/column.class.php';
include 'service/ajax.class.php';
include 'service/login.class.php';
include 'service/tools.class.php';

//为了调用，临时做一个登录动作
//  $_POST['uname'] = "ra.admin";
//  $_POST['psw'] = common::excuteOneSql("select ra_password from ra_online_user where user_login = 'ra.admin'");
//  login::getInstance()->do_login_auto();
//验证路由权限
common::securityCheckHandNew($action);
if (_is_only_vgm()) {
    Header("Location:main.php?action=main");
}
error_log("--------------前端请求post参数---------------");
error_log(utils::jsonFiltration("null", "\"\"", json_encode($_POST)));
error_log("--------------前端请求get参数---------------");
error_log(utils::jsonFiltration("null", "\"\"", json_encode($_GET)));
//Operation log 日志记录
utils::operation_log_records();
switch ($action) {
    case 'ocean_booking':
        ocean_booking::getInstance()->ocean_booking();
        break;
    case 'ocean_order':
        include ONLINE_ROOT . 'libs' . DS . 'ams_config.ini.php';
        ocean_order::getInstance()->ocean_order();
        break;
    case 'ajax':
        echo ajax::getInstance()->run();
        break;
    case 'opreation_log':
        echo operation_log::getInstance()->operation_log();
        break;
    case 'main':
        //如果在没有登录前，没有登录信息，指定用户
        if(!isset($_SESSION['ONLINE_USER'])){
            $menuList = array();
            $menuList[] = array("index"=>'1',"label"=>"Dashboard","icon"=>"icon_data_fill_b","path"=>"/dashboard");
            $menuList[] = array("index"=>'2',"label"=>"Booking","icon"=>"icon_booking__fill_b","path"=>"/booking");
            $menuList[] = array("index"=>'3',"label"=>"Tracking","icon"=>"icon_tracking__fill_b","path"=>"/tracking");
        } else {
            //d登录后，根据配置的权限，是否显示
            if (_isAdmin())
                $sql = "select f_column, min(menu_id) as menu_id, max(menu_icon_font) as menu_icon_font from public.ra_online_permission where has_new_version=true group by f_column order by min(order_by)";
            elseif (_isNewUser())
                $sql = "select f_column, min(menu_id) as menu_id, max(menu_icon_font) as menu_icon_font from public.ra_online_permission where has_new_version=true and customer_check = true group by f_column ORDER BY min(order_by)";
            else
                $sql = "select p.f_column, min(menu_id) as menu_id, max(menu_icon_font) as menu_icon_font from public.ra_online_user_permission up left join public.ra_online_permission p on up.p_id = p.id where  has_new_version=true and lower(user_name) = '" . common::check_input(strtolower(_getLoginName())) . "' group by p.f_column ORDER BY min(p.order_by)";
            $rs = common::excuteListSql($sql);
            if (empty($rs) && _isApexLogin()) {
                $sql = "select f_column, min(menu_id) as menu_id, max(menu_icon_font) as menu_icon_font from public.ra_online_permission where has_new_version=true and default_check = true group by f_column ORDER BY min(order_by)";
                $rs = common::excuteListSql($sql);
            }
            $menuSetting = array("Ocean Booking" => array("label"=>"Booking","path"=>"/booking"),
                                "Ocean B/L Info." => array("label"=>"Tracking","path"=>"/tracking"));
            $menuList = array();
            $menuList[] = array("index"=>'1',"label"=>"Dashboard","icon"=>"icon_data_fill_b","path"=>"/dashboard");
            $index = 2;
            foreach ($rs as $value) {
                if ($value['f_column'] == "Shipment Info."){
                    if (_isAdmin())
                        $ll = common::excuteListSql("select s_column, url_action, sub_menu_id from public.ra_online_permission where has_new_version=true and f_column = '" . common::check_input($value['f_column']) . "' ORDER BY order_by");
                    elseif (_isNewUser())
                        $ll = common::excuteListSql("select s_column, url_action, sub_menu_id from public.ra_online_permission where has_new_version=true and customer_check = true and f_column = '" . common::check_input($value['f_column']) . "' ORDER BY order_by");
                    else
                        $ll = common::excuteListSql("select s_column, url_action, sub_menu_id from public.ra_online_permission p left join public.ra_online_user_permission gp on gp.p_id = p.id where has_new_version=true and f_column = '" . common::check_input($value['f_column']) . "' and lower(gp.user_name) = '" . common::check_input(strtolower(_getLoginName())) . "' ORDER BY p.order_by");
                    if (empty($ll) && _isApexLogin()) {
                        $ll = common::excuteListSql("select s_column, url_action, sub_menu_id from public.ra_online_permission where has_new_version=true and f_column = '" . common::check_input($value['f_column']) . "' and default_check = true ORDER BY order_by");
                    }
                    //单独拼接URL
                    foreach ($ll as $v) {
                        if($v['s_column'] =="Ocean Booking" || $v['s_column'] =="Ocean B/L Info."){
                            $urlData = $menuSetting[$v['s_column']];
                            $menuList[] = array("index"=>$index,"label"=>$urlData['label'],"icon"=>"icon_booking__fill_b","path"=>$urlData['path']);
                            $index = $index + 1;
                        }
                    }
                }
            }
            //只有chud的账户可以看日志记录
            if(_getLoginName() == "chud" || _getLoginName() == "IT.Andywu" || _getLoginName() == "ra.admin"){
                $menuList[] = array("index"=>$index,"label"=>"System Management","icon"=>"icon_system__management_fill_b","type"=>"list",
                    "children"=>array(array("index" =>$index.'-1',"label" =>"Operation Log","path"=>"/Operationlog")));
            }
        }
        common::echo_json_encode(200, $menuList);
        exit();
        break;
    case 'main_filter':
        $data  = common::getManagement();
        common::echo_json_encode(200, $data['dashboard_filter']);
        exit();
        break;    
    case 'main_report':
        $type = $_REQUEST["r_type"];
        $container_type = $_REQUEST["container_type"];
        if (empty($_REQUEST["b_date"])) {
            $bdate = "null";
        } else {
            $bdate = $_REQUEST["b_date"];
            $bdate = "'$bdate'";
        }
        if (empty($_REQUEST["e_date"])) {
            $edate = "null";
        } else {
            $edate = $_REQUEST["e_date"];
            $edate = "'$edate'";
        }
        //Demo测试数据 日期全为空 :前端是由日期过来来的
        // $edate = "null";
        // $bdate = "null";

        $sqlWhere = ' and ' . common::searchExtendHandNew("ocean", $_SESSION["ONLINE_USER"]);
        $sqlWhere = common::check_input($sqlWhere);
        $sqlWhere = " " . $sqlWhere;

        $transportation = $_REQUEST["transportation"];
        if(!is_array($transportation)){
            $transportation = array($transportation);
        }

        $list = array();
        if(count($transportation) == 1 && strtolower($transportation[0]) == 'all' ){
            $transportation = array("Sea","Air","Road");         
        }
        foreach($transportation as $mode){
            if($mode == 'Sea'){
                $Sealist = common::excuteListSql("select * from public.online_order_status_date('$type'::text, 'eta'::text, 'etd'::text, $bdate, $edate, '$sqlWhere'::text, '$container_type'::text) "
                    . "r (c bigint, e integer, b integer, d text)");
                //拼接数据     
                if(empty($list)){
                    $list = $Sealist;
                }else{
                    foreach($list as $lk =>$lv){
                        $list[$lk]['c'] = $list[$lk]['c'] + $Sealist[$lk]['c'];
                    }
                }  
            }
            if($mode == 'Air'){
                //暂时查询空数据 
                $sqlWhere_air = $sqlWhere ." and 1<>1 ";
                $Airlist = common::excuteListSql("select * from public.online_order_status_date('$type'::text, 'eta'::text, 'etd'::text, $bdate, $edate, '$sqlWhere_air'::text, '$container_type'::text) "
                    . "r (c bigint, e integer, b integer, d text)");
                //拼接数据     
                if(empty($list)){
                    $list = $Airlist;
                }else{
                    foreach($list as $lk =>$lv){
                        $list[$lk]['c'] = $list[$lk]['c'] + $Airlist[$lk]['c'];
                    }
                }       
            }
            if($mode == 'Road'){
                $sqlWhere_road = $sqlWhere ." and 1<>1 ";
                $roadlist = common::excuteListSql("select * from public.online_order_status_date('$type'::text, 'eta'::text, 'etd'::text, $bdate, $edate, '$sqlWhere_road'::text, '$container_type'::text) "
                    . "r (c bigint, e integer, b integer, d text)");  
                //拼接数据     
                if(empty($list)){
                    $list = $roadlist;
                }else{
                    foreach($list as $lk =>$lv){
                        $list[$lk]['c'] = $list[$lk]['c'] + $Airlist[$lk]['c'];
                    }
                }      
            }
        }
        //online_order_status_date_new 与本地的区分，发布上去这去掉new
        // $list = common::excuteListSql("select * from public.online_order_status_date('$type'::text, 'eta'::text, 'etd'::text, $bdate, $edate, '$sqlWhere'::text, '$container_type'::text) "
        //                 . "r (c bigint, e integer, b integer, d text)");               
        $key = "[";
        $value = "[";
        $totalValue = 0;
        foreach ($list as $vv) {
            if ($key != "[") {
                $key .= ",";
                $value .= ",";
            }
            if ($type == "r2" || $type == "r3" || $type == "r3_1" || $type == "r4" || $type == "r4_1") {
                $key .= '"' . $vv["d"] . '"';
                $value .= '{"value":"' . $vv["c"] . '","name":"' . $vv["d"] . '" }';
                $totalValue = $totalValue + $vv["c"];
            } else {
                if ($vv["e"] == -1) {
                    $key .= '"Over 80 Days"';
                    $value .= '{"value":"' . $vv["c"] . '","name":"Over 80 Days"}';
                } else {
                    $key .= '"' . $vv["b"] . '-' . $vv["e"] . ' Days"';
                    $value .= '{"value":"' . $vv["c"] . '","name":"' . $vv["b"] . '-' . $vv["e"] . ' Days"}';
                }
                $totalValue = $totalValue + $vv["c"];
            }
        }
        $key .= "]";
        $value .= "]";
        //处理返回原表数据格式
        $data = common::mian_repot_do($value,$type,$totalValue);
        common::echo_json_encode(200, $data);
        exit();
        break;
    case 'main_report_etd':
        //这里只有r1查询
        $type = "r1";
        $container_type = "";
        $date_type = strtolower($_REQUEST["date_type"]);
        if (empty($_REQUEST["date_start"])) {
            $bdate = "null";
        } else {
            $bdate = $_REQUEST["date_start"];
            $bdate = "'$bdate'";
        }
        if (empty($_REQUEST["date_end"])) {
            $edate = "null";
        } else {
            $edate = $_REQUEST["date_end"];
            $edate = "'$edate'";
        }
        $sqlWhere = ' and ' . common::searchExtendHandNew("ocean", $_SESSION["ONLINE_USER"]);
        $sqlWhere = common::check_input($sqlWhere);
        $sqlWhere = " " . $sqlWhere;

        $transportation = $_REQUEST["transportation"];
        if(!is_array($transportation)){
            $transportation = array($transportation);
        }
        $list = array();
        if(count($transportation) == 1 && strtolower($transportation[0]) == 'all' ){
            $transportation = array("Sea","Air","Road");         
        }
        foreach($transportation as $mode){
            if($mode == 'Sea'){
                $Sealist = common::excuteListSql("select * from public.online_order_status_date_new_r1_r2('$type'::text, 'eta'::text, 'etd'::text, $bdate, $edate, '$sqlWhere'::text, '$container_type'::text,'$date_type'::text) "
                    . "r (c bigint, e integer, b integer, d text)");
                //拼接数据     
                if(empty($list)){
                    $list = $Sealist;
                }else{
                    foreach($list as $lk =>$lv){
                        $list[$lk]['c'] = $list[$lk]['c'] + $Sealist[$lk]['c'];
                    }
                }  
            }
            if($mode == 'Air'){
                //暂时查询空数据 
                $sqlWhere_air = $sqlWhere ." and 1<>1 ";
                $Airlist = common::excuteListSql("select * from public.online_order_status_date_new_r1_r2('$type'::text, 'eta'::text, 'etd'::text, $bdate, $edate, '$sqlWhere_air'::text, '$container_type'::text,'$date_type'::text) "
                    . "r (c bigint, e integer, b integer, d text)");
                //拼接数据     
                if(empty($list)){
                    $list = $Airlist;
                }else{
                    foreach($list as $lk =>$lv){
                        $list[$lk]['c'] = $list[$lk]['c'] + $Airlist[$lk]['c'];
                    }
                }       
            }
            if($mode == 'Road'){
                $sqlWhere_road = $sqlWhere ." and 1<>1 ";
                $roadlist = common::excuteListSql("select * from public.online_order_status_date_new_r1_r2('$type'::text, 'eta'::text, 'etd'::text, $bdate, $edate, '$sqlWhere_road'::text, '$container_type'::text,'$date_type'::text) "
                    . "r (c bigint, e integer, b integer, d text)");  
                //拼接数据     
                if(empty($list)){
                    $list = $roadlist;
                }else{
                    foreach($list as $lk =>$lv){
                        $list[$lk]['c'] = $list[$lk]['c'] + $roadlist[$lk]['c'];
                    }
                }      
            }
        }
        // $list = common::excuteListSql("select * from public.online_order_status_date_new_r1_r2('$type'::text, 'eta'::text, 'etd'::text, $bdate, $edate, '$sqlWhere'::text, '$container_type'::text,'$date_type'::text) "
        //                     . "r (c bigint, e integer, b integer, d text)");               
        $key = "[";
        $value = "[";
        $totalValue = 0;
        foreach ($list as $vv) {
            if ($key != "[") {
                $key .= ",";
                $value .= ",";
            }
            if ($type == "r2" || $type == "r3" || $type == "r3_1" || $type == "r4" || $type == "r4_1") {
                $key .= '"' . $vv["d"] . '"';
                $value .= '{"value":"' . $vv["c"] . '","name":"' . $vv["d"] . '" }';
                $totalValue = $totalValue + $vv["c"];
            } else {
                if ($vv["e"] == -1) {
                    $key .= '"Over 80 Days"';
                    $value .= '{"value":"' . $vv["c"] . '","name":"Over 80 Days"}';
                } else {
                    $key .= '"' . $vv["b"] . '-' . $vv["e"] . ' Days"';
                    $value .= '{"value":"' . $vv["c"] . '","name":"' . $vv["b"] . '-' . $vv["e"] . ' Days"}';
                }
                $totalValue = $totalValue + $vv["c"];
            }
        }
        $key .= "]";
        $value .= "]";
        //处理返回原表数据格式
        $data = common::mian_repot_do($value,$type,$totalValue);
        common::echo_json_encode(200, $data);
        exit();
        break;    
    case 'main_report_kpi':
        $type = $_REQUEST["r_type"];
        $sqlWhere = ' and ' . common::searchExtendHandNew("ocean", $_SESSION["ONLINE_USER"]);
        $sqlWhere = common::check_input($sqlWhere);
        $sqlWhere = " " . $sqlWhere;
        
        $date_type = strtolower($_REQUEST["date_type"]);
        if (isset($_REQUEST['date_start']) && !empty($_REQUEST['date_start']))
            $sqlWhere .= " and $date_type >= ''" . common::usDate2sqlDate($_REQUEST['date_start']) . " 00:00:00''";
        if (isset($_REQUEST['date_end']) && !empty($_REQUEST['date_end']))
            $sqlWhere .= " and $date_type <= ''" . common::usDate2sqlDate($_REQUEST['date_end']) . " 23:59:59''";
        
        $transportation = $_REQUEST["transportation"];
        if(!is_array($transportation)){
            $transportation = array($transportation);
        }

        $list = array();
        if(count($transportation) == 1 && strtolower($transportation[0]) == 'all' ){
            $transportation = array("Sea","Air","Road");         
        }
        foreach($transportation as $mode){
            if($mode == 'Sea'){
                $Sealist = common::excuteListSql("select * from public.online_order_status_date_kpi_new('$type'::text,'$sqlWhere'::text) "
                    . "r (c bigint, d text)");
                //拼接数据     
                if(empty($list)){
                    $list = $Sealist;
                }else{
                    foreach($list as $lk =>$lv){
                        $list[$lk]['c'] = $list[$lk]['c'] + $Sealist[$lk]['c'];
                    }
                }     
            }
            if($mode == 'Air'){
                //暂时查询空数据
                $sqlWhere_air = $sqlWhere ." and 1<>1 ";
                //拼接的date_start数据
                //todo 根据权限信息获取一共air查询的总表的整合，因为air信息是分别存在public 和sfs 两个模式中的
                // $air_view = "";
                // $air_sql = common::getAirSql($air_view,$type,$sql_where);
                // $Airlist = common::excuteListSql("select count as c, distext as d from ($air_sql) aa ");
                $Airlist = common::excuteListSql("select * from public.online_order_status_date_kpi_new('$type'::text,'$sqlWhere_air'::text) "
                    . "r (c bigint, d text)");
                //拼接数据     
                if(empty($list)){
                    $list = $Airlist;
                }else{
                    foreach($list as $lk =>$lv){
                        $list[$lk]['c'] = $list[$lk]['c'] + $Airlist[$lk]['c'];
                    }
                }       
            }
            if($mode == 'Road'){
                $sqlWhere_road = $sqlWhere ." and 1<>1 ";
                //拼接的date_start数据  road 没有数据  可以置为1<>1
                //todo 根据权限信息获取一共air查询的总表的整合，因为air信息是分别存在sspublic 和sfs 两个模式中的
                // $air_view = "";
                // $air_sql = common::getAirSql($air_view,$type,$sql_where);
                // $Airlist = common::excuteListSql("select count as c, distext as d from ($air_sql) aa ");
                $roadlist = common::excuteListSql("select * from public.online_order_status_date_kpi_new('$type'::text,'$sqlWhere_road'::text) "
                 . "r (c bigint, d text)");  
                //拼接数据     
                if(empty($list)){
                    $list = $roadlist;
                }else{
                    foreach($list as $lk =>$lv){
                        $list[$lk]['c'] = $list[$lk]['c'] + $roadlist[$lk]['c'];
                    }
                }       
            }
        }
         
        $key = "[";
        $value = "[";
        $totalValue = 0;
        foreach ($list as $vv) {
            if ($key != "[") {
                $key .= ",";
                $value .= ",";
            }
            if ($type == "ata_r3" || $type == "atd_r4" ) {
                $key .= '"' . $vv["d"] .'"';
                $value .= '{"value":"' . $vv["c"] . '","name":"' . $vv["d"] .'"}';
                $totalValue = $totalValue + $vv["c"];
            }
        }
        $key .= "]";
        $value .= "]";
        
        //处理返回原表数据格式
        $ETDList = array();
        $value_arr = json_decode($value,true);
        
        foreach($value_arr as $arr){
            $color = common::getItemStyle($type,$arr['name']);
            if($arr['name'] == "0 Day"){
                $arr['name'] = "≤1 Day";
            }
            if($arr['name'] == "7 Days"){
                $arr['name'] = "≥7 Days";
            }
            $ETDList[] = array("value" =>intval($arr['value']),"name" =>$arr['name'],"itemStyle" =>array("color" =>$color));
        }
        if($type == 'atd_r4'){
            $data = array("ETDList" =>$ETDList,"ETD_Radius"=>array('30%','50%'),"title1" =>"Departure","title2" =>"(ATD-ETD)","download_name" => "KPI Departure");
        }
        if($type == 'ata_r3'){
            $data = array("ETDList" =>$ETDList,"ETD_Radius"=>array('30%','50%'),"title1" =>"Arrival","title2" =>"(ATA-ETA)","download_name" => "KPI Arrival");
        }
        common::echo_json_encode(200, $data);
        exit();
        break;  
    case 'main_report_container_bar':
        //新UI 要ALL  20  40  45 四份数据同时查询，且是柱状图，所以与r3 r4查询分开
        $container_type_arr = array("20","40","45");
        $container_type_param = "all";
        $ContainerCounSeries = array();

        foreach($container_type_arr as $_container_type){
            $container_type = $_container_type;
            $date_type = strtolower($_REQUEST["date_type"]);
            $type = $_REQUEST["r_type"];
            if (empty($_REQUEST["date_start"])) {
                $bdate = "null";
            } else {
                $bdate = $_REQUEST["date_start"];
                $bdate = "'$bdate'";
            }
            if (empty($_REQUEST["date_end"])) {
                $edate = "null";
            } else {
                $edate = $_REQUEST["date_end"];
                $edate = "'$edate'";
            }
            $list= array();
            //all 查询所有
            $sqlWhere = ' and ' . common::searchExtendHandNew("ocean", $_SESSION["ONLINE_USER"]);
            $sqlWhere = common::check_input($sqlWhere);
            $sqlWhere = " " . $sqlWhere;
            //如果页面查询的是ALL 这个20  40  45都查询出来。否则值查询都对应的size,其他的不查询
            if(strtolower($container_type_param) == "all"){
                $list = common::excuteListSql("select * from public.online_order_status_date_new_r1_r2('$type'::text, 'eta'::text, 'etd'::text, $bdate, $edate, '$sqlWhere'::text, '$container_type'::text, '$date_type'::text) "
                                . "r (c bigint, e integer, b integer, d text)");               
            }else{
                if($container_type_param == $_container_type){
                    $list = common::excuteListSql("select * from public.online_order_status_date_new_r1_r2('$type'::text, 'eta'::text, 'etd'::text, $bdate, $edate, '$sqlWhere'::text, '$container_type'::text, '$date_type'::text) "
                                . "r (c bigint, e integer, b integer, d text)");
                }
            }
            
            $key = "[";
            $value = "[";
            $totalValue = 0;
            foreach ($list as $vv) {
                if ($key != "[") {
                    $key .= ",";
                    $value .= ",";
                }
                if ($type == "r2" || $type == "r3" || $type == "r3_1" || $type == "r4" || $type == "r4_1") {
                    $key .= '"' . $vv["d"] . '"';
                    $value .= '{"value":"' . $vv["c"] . '","name":"' . $vv["d"] . '" }';
                    $totalValue = $totalValue + $vv["c"];
                } else {
                    if ($vv["e"] == -1) {
                        $key .= '"Over 80 Days"';
                        $value .= '{"value":"' . $vv["c"] . '","name":"Over 80 Days"}';
                    } else {
                        $key .= '"' . $vv["b"] . '-' . $vv["e"] . ' Days"';
                        $value .= '{"value":"' . $vv["c"] . '","name":"' . $vv["b"] . '-' . $vv["e"] . ' Days"}';
                    }
                    $totalValue = $totalValue + $vv["c"];
                }
            }
            $key .= "]";
            $value .= "]";
            $key_arr = json_decode($key,true);
            $value_arr = json_decode($value,true);

            $data = array();
            //每一个size 的所有月份总计
            $total = 0;
            //每一个size 对应的最大值
            $max = 0;
            foreach($value_arr as $arr){
                $data[] = intval($arr['value']);
                $total = $total + intval($arr['value']);
                $max = $max < intval($arr['value']) ? intval($arr['value']) : $max;
            }
            $ContainerCounSeries[$container_type] = array("data"=>$data,"total"=>$total,"max"=>$max);
        }
        
        //处理返回时数据格式
        $ContainerCounSeries_return = array();
        //横坐标栏位
        $ContainerCount_Title = $key_arr;

        //所查的所有模式计算总和
        $total = 0;
        //所有size下的最大值，方便标注计算最长的Y坐标
        $max_all = 0;
        foreach($ContainerCounSeries as $k =>$v){
            //这个type 是页面传过来的。这个固定r2
            $color = common::getItemStyle($type,$k);
            $total = $total + $v['total'];
            $ContainerCounSeries_return[] = array("name"=>strval($k),"type"=>"bar","emphasis" => array("focus" =>"none"),
                "stack" =>"总计","data" =>$v['data'],"itemStyle" =>array("color" =>$color));
            $max_all = $max_all +  $v['max'];
        }
        //计算Y坐标的间隔
        $interval = utils::calculateTicks(0,$max_all,5);
        if($interval == 0){
            //处理返回默认值
            $interval = 2;
        }
        $returnData = array("ContainerCount_Title"=>"Total: $total","ContainerCountList" =>$ContainerCount_Title,"ContainerCounSeries" =>$ContainerCounSeries_return,
            "min" => 0,"Max" =>$interval*5,"interval" =>$interval,"download_name" => "Container Count");
        //demo    
        //  $json = '{"code":200,"data":{"ContainerCount_Title":"Total: 463518","ContainerCountList":["OCT,23","NOV,23","DEC,23","JAN,24","FEB,24","MAR,24","APR,24","MAY,24","JUN,24","JUL,24","AUG,24","SEP,24","OCT,24"],"ContainerCounSeries":[{"name":"20","type":"bar","emphasis":{"focus":"none"},"stack":"\u603b\u8ba1","data":[4400,8600,8804,9271,8961,8793,8534,9476,9530,10277,10081,8997,5784],"itemStyle":{"color":"#FF7500"}},{"name":"40","type":"bar","emphasis":{"focus":"none"},"stack":"\u603b\u8ba1","data":[13652,28021,30422,30136,26320,27035,23979,26494,28406,33318,32318,30962,16369],"itemStyle":{"color":"#FFAC66"}},{"name":"45","type":"bar","emphasis":{"focus":"none"},"stack":"\u603b\u8ba1","data":[189,337,415,437,439,321,250,320,324,603,328,415,200],"itemStyle":{"color":"#FFE3CC"}}],"min":0,"Max":45000,"interval":9000}}';    
        //  $returnData = json_decode($json,true);
        //  echo json_encode($returnData);
        //  exit();
        common::echo_json_encode(200, $returnData);
        exit();
        break;
    
    case 'main_report_co2e_bar':
        $returnData = common::getCo2eBar();
        common::echo_json_encode(200, $returnData);
        exit();
        break;   
    case 'main_report_top10_bar':
        $returnData = common::getTopBar();
        common::echo_json_encode(200, $returnData);
        exit();
        break;
    case 'main_report_revenue':
        $returnData = common::getRevenue();
        common::echo_json_encode(200, $returnData);
        exit();
        break;            
    case 'main_map':
        $uncode = $_POST["uncode"];
        $serial_no = $_POST["serial_no"];
        $unall = explode("|", $uncode);
        $sql = "";
        if (!empty($unall[0]) && $unall[0] != "''") {
            $sql .= "select lon as lng, lat as lat, uncode, 'Place of receipt: '||name1 as location_namewo, 'por' as type from vessel.vt_unlocode where "
                    . "lon<>0 and lat<>0 and lon is not null and lat is not null and uncode in "
                    . "($unall[0])";
        }
        if (!empty($unall[1]) && $unall[1] != "''") {
            if (!empty($sql)) {
                $sql .= " union ";
            }
            $sql .= "select lon as lng, lat as lat, uncode, 'POL: '||name1 as location_namewo, 'pol' as type from vessel.vt_unlocode where "
                    . "lon<>0 and lat<>0 and lon is not null and lat is not null and uncode in "
                    . "($unall[1])";
        }
        if (!empty($unall[2]) && $unall[2] != "''") {
            if (!empty($sql)) {
                $sql .= " union ";
            }
            $sql .= "select lon as lng, lat as lat, uncode, 'POD: '||name1 as location_namewo, 'pod' as type from vessel.vt_unlocode where "
                    . "lon<>0 and lat<>0 and lon is not null and lat is not null and uncode in "
                    . "($unall[2])";
        }
        if (!empty($unall[3]) && $unall[3] != "''") {
            if (!empty($sql)) {
                $sql .= " union ";
            }
            $sql .= "select lon as lng, lat as lat, uncode, 'Place of delivery: '||name1 as location_namewo, 'poe' as type from vessel.vt_unlocode where "
                    . "lon<>0 and lat<>0 and lon is not null and lat is not null and uncode in "
                    . "($unall[3])";
        }
        $tkStatus = common::excuteListSql("select tl.by_pickup, g.consignee_exp, g.pickup_from_exp, c.ctnr, g.deliveryto_exp, g.serial_no, tl.location, tl.type, tl.id, 
            to_char(tl.upload_time, 'MM/DD/YYYY HH24:MI:SS') as utime 
            from public.tk_general g, public.tk_commodity c left join public.tk_location tl on c.serial_no=tl.serial_no 
            where g.serial_no=c.serial_no and g.bol=(select m_bol from public.ocean where serial_no='$serial_no') order by tl.order_id");
        foreach ($tkStatus as $vv) {
            $ll = explode(",", $vv["location"]);
            if ($vv["by_pickup"] == "t") {
                $pf = explode("\r\n", $vv["pickup_from_exp"]);
                $pf = common::check_input($pf[0]) . "(" . $vv["ctnr"] . ")";
                $dt = explode("\r\n", $vv["consignee_exp"]);
                $dt = common::check_input($dt[0]) . "(" . $vv["ctnr"] . ")";
            } else {
                $pf = explode("\r\n", $vv["consignee_exp"]);
                $pf = common::check_input($pf[0]) . "(" . $vv["ctnr"] . ")";
                $dt = explode("\r\n", $vv["deliveryto_exp"]);
                $dt = common::check_input($dt[0]) . "(" . $vv["ctnr"] . ")";
            }
            if ($vv["type"] == "26" && !empty($ll[1])) {
                if (!empty($sql)) {
                    $sql .= " union ";
                }
                $sql .= "select '" . $ll[1] . "' as lng, '" . $ll[0] . "' as lat, '" . $vv["ctnr"] . "' as uncode, 'Pick up: " . $vv["utime"] . "<br>'||'" . $pf . "' as location_namewo, 'pickup' as type";
            } elseif ($vv["type"] == "25" && !empty($ll[1])) {
                if (!empty($sql)) {
                    $sql .= " union ";
                }
                $sql .= "select '" . $ll[1] . "' as lng, '" . $ll[0] . "' as lat, '" . $vv["ctnr"] . "' as uncode, 'Delivery: " . $vv["utime"] . "<br>'||'" . $dt . "' as location_namewo, 'delivery' as type";
            }
        }

        if (!empty($sql)) {
            $gps = common::excuteListSql($sql . "");
        }
        if (!empty($serial_no)) {
            $all = explode(",", $serial_no);
            foreach ($all as $a) {
                $rs = common::excuteOneSql("select public.get_vessel_position('$a'::text)");
                if (!empty($rs)) {
                    $rss = explode("|", $rs);
                    $lng_lat = explode(",", $rss[1]);
                    $gps[] = array("lng" => $lng_lat[0], "lat" => $lng_lat[1], "uncode" => "", "location_namewo" => "", "type" => "vessel", "vessel_name" => $rss[2], "m_shipname" => "", "mmsi" => "", "imo" => "", "m_shipstate" => "", "m_shiptype" => "", "m_dest" => "", "m_newshiparrive" => "", "m_newlasttime" => "", "lasttime" => "", "sub" => "");
                }
            }
        }
        $data = array("gps" => $gps);
        common::echo_json_encode("200", $data);
        exit();
        break;
    case 'main_map_new':
        //include ONLINE_ROOT . 'libs' . DS . 'map_config.ini.php';
        //修改添加port_of_transshipment 和port_of_transshipment_name的坐标获取(有为空的可能)
        $serial_no = $_REQUEST["serial_no"];
        //$serial_no = "F41E6016-1A97-4C93-8198-53D8B3B26220";
        $sql = "with ss as (select '$serial_no' as sn)
                , aa as (
                    select place_of_receipt_un, place_of_delivery_un, fport_of_loading_un, mport_of_discharge_un, port_of_loading, port_of_discharge, place_of_delivery_exp, place_of_receipt_exp,dd.*
                        from public.online_ocean oo 
                        left join LATERAL (
                            select (select uncode from ports where  code = o.port_of_transshipment) as port_of_transshipment_un,
                                    port_of_transshipment_name
                                from  ocean o where o.serial_no=oo.serial_no order by id desc limit 1
                        ) dd on true
                        where serial_no=(select sn from ss) limit 1
                )
                , rr as (
                        select lon as lng, lat as lat, 'Origin' as label, port_of_loading as infor, 1 as sort, null::timestamp without time zone as stime, 'pol'::text as ptype 
                            from vessel.vt_unlocode, aa where lon<>0 and lat<>0 and lon is not null and lat is not null and uncode=fport_of_loading_un
                        union all
                        select lon as lng, lat as lat, 'Destination' as label, port_of_discharge as infor, 2 as sort, null::timestamp without time zone as stime, 'pod'::text as ptype 
                            from vessel.vt_unlocode, aa where lon<>0 and lat<>0 and lon is not null and lat is not null and uncode=mport_of_discharge_un
                        union all
                        select lon as lng, lat as lat,  'Transfer' as label, port_of_transshipment_name as infor, 3 as sort, null::timestamp without time zone as stime, 'poe'::text as ptype 
                            from vessel.vt_unlocode, aa where lon<>0 and lat<>0 and lon is not null and lat is not null and uncode=port_of_transshipment_un
                    )
            select * from rr order by sort, stime";
        $rss = common::excuteListSql($sql);
        //$rss = $mapdb->GetAll($sql);
        //先固定死
        // $json = '[{"lng":"100.78594000","lat":"13.68521000","label":"Origin","infor":"LAT KRABANG, THAILAND","sort":"0","stime":null,"ptype":"por"},
        //           {"lng":"100.88333333","lat":"13.08333333","label":"Destination","infor":"LAEM CHABANG PORT,THAILAND","sort":"1","stime":null,"ptype":"pol"},
        //           {"lng":"-122.28640000","lat":"37.79784000","label":"Transfer","infor":"OAKLAND, CA, USA","sort":"2","stime":null,"ptype":"pod"}]';
        //$rss = json_decode($json,true);
        // global $mapdb;
        // //查询线(包含所有的线)
        // error_log("select * from get_track_data('$serial_no',true)");
        // $map_sql = "select * from get_track_data('$serial_no',true)";
        // $Line = $mapdb->GetAll($map_sql) or ( (!$mapdb->ErrorMsg()) or error_log(common::dbLog($mapdb, $map_sql), 0));

        // error_log("total:".count($Line));
        // $solidLine = array();
        // $dottedLine = array();
        // $rangePoint = array();
        // foreach($Line as $line){
        //     if($line['tp'] == "1"){
        //         $solidLine[] = $line;
        //     }elseif($line['tp'] == "0"){
        //         $dottedLine[] = $line;
        //     }else{
        //         $rangePoint[] = $line;
        //     }
        // }
        // error_log("total_1:".count($solidLine));
        // error_log("total_2:".count($dottedLine));
        // error_log("total_3:".count($rangePoint));
        // //如果没有虚线，这这个范围点也是异常的，不需要显示
        // if(empty($dottedLine)){
        //     $rangePoint = array();
        // }
        // $data = array("point"=>$rss,"solidLine"=>$solidLine,"dottedLine"=>$dottedLine,"rangePoint"=>$rangePoint);
        // common::echo_json_encode(200, $data);
        common::echo_json_encode(200, $rss);
        exit();
        break;
    case 'main_welcome':
        $cp = common::check_input($_POST ['cp']); //current_page
        $ps = common::check_input($_POST ['ps']); //ps
        if (empty($ps))
            $ps = 10;

        $sqlWhere = ' where ' . common::searchExtendHandNew("ocean", $_SESSION["ONLINE_USER"]);
        $transportation = $_REQUEST["transportation"];
        if(!is_array($transportation)){
            $transportation = array($transportation);
        }

        $list = array();
        if(count($transportation) == 1 && strtolower($transportation[0]) == 'all' ){
            $transportation = array("Sea","Air","Road");         
        }else{
            if(!in_array("Sea",$transportation)){
                $sqlWhere .= " and 1<>1 ";
            }
        }
        // test dome 
        // $_POST['is_default'] = "no";
        // $_POST['date_start'] =null;
        // $_POST['date_end'] = null;
        //默认初始条件：ALL& ETD& Current Month 当前月的1号到最后一天 这个默认条件已经废除，前端不会这样传参数
        if (isset($_POST['is_default']) && strtolower($_POST['is_default']) == "yes" && false){
            $sqlWhere .= "and etd>='" . date("Y-m") . "-01' and etd<='" . date("Y-m") . "-01'::date + interval '1 month'";
        } else {
            $date_type = strtolower(common::check_input($_POST ['date_type']));
            if (isset($_POST['date_start']) && !empty($_POST['date_start']))
                $sqlWhere .= " and $date_type >= '" . common::usDate2sqlDate($_POST['date_start']) . " 00:00:00'";
            if (isset($_POST['date_end']) && !empty($_POST['date_end']))
                $sqlWhere .= " and $date_type <= '" . common::usDate2sqlDate($_POST['date_end']) . " 23:59:59'";
        }
        if (isset($_POST['customer']) && !empty($_POST['customer'])){
            $sqlWhere .= " and (shipper ilike '%".common::check_input($_POST['customer'])."%' or shipper_id ilike '%".common::check_input($_POST['customer'])."%' 
                or consignee ilike '%".common::check_input($_POST['customer'])."%' or consignee_id ilike '%".common::check_input($_POST['customer'])."%')";
        }

        $rc = $_POST ['rc'];
        if ($rc == - 1) {
            $sql = "SELECT count(1) from public.online_ocean" . $sqlWhere ." and last_status_315_update_time is not null";
            $rc = common::excuteOneSql($sql);
            //error_log($sql);
        }
        $tp = ceil($rc / $ps);
        if ($rc > 0) {
            $sql = "SELECT order_from as _schemas,serial_no,last_status_city, consignee, shipper, h_bol,final_desination_uncode, 
                    to_char(etd, 'MM/DD/YYYY'::text) as etd, to_char(eta, 'MM/DD/YYYY'::text) AS eta, 
                    fport_of_loading_un, mport_of_discharge_un, place_of_receipt_un, place_of_delivery_un, ctnrs, count_cntr, last_status_ctnr,booking_no,
                    to_char(last_status_315_date, 'MM/DD/YYYY'::text) as last_status_315_date,last_status_315_code, last_status_loc, last_status_city, order_from,
                    f_vessel,f_voyage,
                    CASE
	    	            WHEN dd.status is null THEN 'Created'::text
	    	            ELSE dd.status::text
		            END AS new_status,
                    dd.act_date,dd.act_time,dd.description,
                    dd.timezone,dd.code as dd_code
                    FROM public.online_ocean
                    left join LATERAL (select case when a.code='IFFBCF' then 'Created'
                                    when a.code='IFFCPU' then 'Cargo Received'
                                    when a.code='IFFREC' then 'Cargo Received'
                                    when a.code='IFFDEP' then 'Departure'
                                    when a.code='IFFARR' then 'Arrived'
                                    when a.code='IFFDEL' then 'Completed'
                                    else 'Created' END as status,
                                    act_date,act_time,
                                    _dd.description as description,
                                    timezone,code
                            from  public.ocean_milestone a 
                                left join LATERAL (select sno,description  from  milestone where code=a.code and project_no = '*'  order by sno limit 1) _dd on true
                    where a.serial_no=online_ocean.serial_no 
                        and a.code in (select regexp_split_to_table('IFFBCF,IFFCPU,IFFREC,IFFDEP,IFFARR,IFFDEL', ','))
                        and a.act_date is not null
                    order by id desc limit 1) dd on true 
                    $sqlWhere  and last_status_315_update_time is not null";
            if (_isDemo()) {
                $sql .= " ORDER BY eta DESC limit " . $ps . " offset " . ($cp - 1) * $ps;
            } else {
                $sql .= " ORDER BY last_status_315_update_time DESC limit " . $ps . " offset " . ($cp - 1) * $ps;
            }
            $rss = common::excuteListSql($sql);
            //RecentStatusList
            $RecentStatusList = array();
            foreach ($rss as $key => $value) {
                $_schemas = $value['_schemas'];
                if($_schemas == "public"){
                    $_schemas = "ocean";
                }
                $timezone = "";
                //按照最新execl Timezone From 来自于origin 
                if($value['dd_code'] == "IFFBCF" || $value['dd_code'] == "IFFCPU"){
                    $sql = "SELECT (select time_zone from public.city_timezone where uncode = LEFT(country, 2) || COALESCE(city_code,'')) as timezone
                         FROM $_schemas.contacts c WHERE  c.contact_id = '".$value['origin']."'";
                    $timezone = common::excuteOneSql($sql);     
                }
                //按照最新execl Timezone From 来自于final_destination
                if($value['dd_code'] == "IFFDEL"){
                    $sql = "select time_zone from public.city_timezone where uncode = '".$value['final_desination_uncode']."'"; 
                    $timezone = common::excuteOneSql($sql);     
                }

                if($value['dd_code'] == "IFFREC" || $value['dd_code'] == "IFFDEP" || $value['dd_code'] == "IFFARR"){
                    //Timezone From 来自于EDI315
                    $serial_no = $value["serial_no"];
                    $EDI315Time = common::getEDI315Time($serial_no,$value['_schemas']);

                    if($value['dd_code'] == "IFFREC" || $value['dd_code'] == "IFFDEP"){
                        //先以EDI315 时区为准，如果没有这代表数据是手动输入，或者没有同步情况
                        $timezone = $EDI315Time[$value['dd_code']]['timezone'];
                        if(empty($timezone)){
                            if($value['dd_code'] == "IFFREC"){
                                $sql = "select time_zone from public.city_timezone where uncode = '".$value['place_of_receipt_un']."'"; 
                            }else{
                                $sql = "select time_zone from public.city_timezone where uncode = '".$value['fport_of_loading_un']."'";
                            }
                            $timezone = common::excuteOneSql($sql);
                        }     
                    }
                    if($value['dd_code'] == "IFFARR"){
                        $timezone = $EDI315Time[$value['dd_code']]['timezone'];
                        if(empty($timezone)){
                            $sql = "select time_zone from public.city_timezone where uncode = '".$value['mport_of_discharge_un']."'";
                            $timezone = common::excuteOneSql($sql);
                        }
                    }
    
                    // 根据IFFDEL这个milestone来判断是否转变为completed
                    // if($value['dd_code'] == "IFFAFD"){
                    //     $timezone = $EDI315Time[$value['dd_code']]['timezone'];
                    //     if(empty($timezone)){
                    //         $sql = "select time_zone from public.city_timezone where uncode = '".$value['place_of_delivery_un']."'";
                    //         $timezone = common::excuteOneSql($sql);
                    //     }
                    // }
                }
                
                $Arrived = $value['description'];
                $RecentStatusList[] = array("Title"=>$value['h_bol'],
                    "name"=>utils::outDisplayForMerge($value['f_vessel'],$value['f_voyage']),
                    "bookingNumber" =>$value['booking_no'],
                    "IsSubscribe" =>false,
                    "shipperName"=>$value['shipper'],
                    "consigneeName" =>$value['consignee'],
                    "startStation"=>$value['fport_of_loading_un'],
                    "endStation"=>$value['mport_of_discharge_un'],
                    "ETD"=>$value['etd'],
                    "ETA"=>$value['eta'],
                    "type"=>$value['new_status'],
                    "Arrived"=>$Arrived,
                    "Time"=>$value["act_date"],
                    "act_time" =>$value["act_time"],
                    "timezone"=>$timezone,
                    "_schemas"=>$value["_schemas"],
                    "a" =>common::deCode($value['serial_no'], 'E'));
            }
            $data  = common::getManagement();
            $arrTmp = array('searchData' => $RecentStatusList, 
               'Management' => $data['Management'],
               'dashboard_filter' => $data['dashboard_filter'],
               'is_customer' =>_isCustomerLogin(),
               'rc' => $rc,
               'ps' => $ps,
               'cp' => $cp,
               'tp' => $tp);
        } else {
            $data  = common::getManagement();
            $arrTmp = array('searchData' => array(),
                'Management' => $data['Management'],
                'dashboard_filter' => $data['dashboard_filter']);
        }
        common::echo_json_encode(200,$arrTmp);
        exit();
        break;
    case 'save_layout':
        $management = json_encode($_POST["management"]);
        $dashboard_filter = json_encode($_POST["dashboardObj"]);
        $_param = "";
        if(!empty($_POST["management"])){
            $_param .= " management = '$management' ";
        }
        if(!empty($dashboard_filter)){
            $_param .= ",dashboard_filter = '$dashboard_filter' ";
        }
        if(!empty($_param)){
            common::excuteUpdateSql("update public.ra_online_user set $_param where lower(user_login) = '" . strtolower(_getLoginName()) . "'");
        }
        $returnData = array("msg" => "success");
        common::echo_json_encode(200, $returnData);
        exit();
        break; 
    case 'password':
        tools::getInstance()->updatePassword();
        break;    
    case 'tools':
        tools::getInstance()->markSystem();
        break; 
    case 'user_guide':
        $rootPath = realpath(dirname(__FILE__)) . DS;
        //common::download_file($rootPath."images\ACE-M1_ISF_ACI_User_Guide\ACE-M1_ISF_ACI_User_Guide.pdf", "ACE-M1_ISF_ACI_User_Guide_V2.0.pdf");
        // PDF文件在服务器上的位置
        $filename = $rootPath."userFile". DS."KLN_Online_User_Guide_24.11.26.pdf";
        $display_name = "KLN_Online_User_Guide_24_11_26.pdf";
        // Header content type
        header("Content-type: application/pdf");
        header("Content-Length: " . filesize($filename));
        header("Content-Disposition:attachment;filename=\"" . $display_name . "\"");
        // 将文件发送到浏览器。
        readfile($filename);
        break;           
    default:
        $data = array(
            'msg' => 'Page not found',
        );
        common::echo_json_encode(500, $data);  
}
$db->Close();
$db = null;
if ($max_ec > 0)
    ini_set('max_execution_time', $max_ec); //recover old value
if (!empty($memory_limit))
    ini_set('memory_limit', $memory_limit);
?>