main_new_version.php 26 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521
  1. <?php
  2. $max_ec = ini_get('max_execution_time'); //set max_excution_time
  3. ini_set('max_execution_time', '600');
  4. $memory_limit = "";
  5. $action = "";
  6. if (isset($_GET['action']))
  7. $action = strtolower($_GET['action']);
  8. if (isset($_POST['action']))
  9. $action = strtolower($_POST['action']);
  10. include "include.ini.php";
  11. include 'service/ocean_booking.class.php';
  12. include 'service/ocean_order.class.php';
  13. include 'service/operation_log.class.php';
  14. include 'service/search.class.php';
  15. include 'service/column.class.php';
  16. include 'service/ajax.class.php';
  17. include 'service/login.class.php';
  18. include 'service/tools.class.php';
  19. //为了调用,临时做一个登录动作
  20. $_POST['uname'] = "ra.admin";
  21. $_POST['psw'] = "abc123456789";
  22. //login::getInstance()->do_login_auto();
  23. //验证路由权限
  24. common::securityCheckHandNew($action);
  25. if (_is_only_vgm()) {
  26. Header("Location:main.php?action=main");
  27. }
  28. error_log("--------------前端请求post参数---------------");
  29. error_log(utils::jsonFiltration("null", "\"\"", json_encode($_POST)));
  30. error_log("--------------前端请求get参数---------------");
  31. error_log(utils::jsonFiltration("null", "\"\"", json_encode($_GET)));
  32. //Operation log 日志记录
  33. utils::operation_log_records();
  34. switch ($action) {
  35. case 'ocean_booking':
  36. ocean_booking::getInstance()->ocean_booking();
  37. break;
  38. case 'ocean_order':
  39. include ONLINE_ROOT . 'libs' . DS . 'ams_config.ini.php';
  40. ocean_order::getInstance()->ocean_order();
  41. break;
  42. case 'ajax':
  43. echo ajax::getInstance()->run();
  44. break;
  45. case 'opreation_log':
  46. echo operation_log::getInstance()->operation_log();
  47. break;
  48. /* display index page */
  49. case 'main':
  50. //todo
  51. break;
  52. case 'main_report':
  53. $type = $_REQUEST["r_type"];
  54. $container_type = $_REQUEST["container_type"];
  55. if (empty($_REQUEST["b_date"])) {
  56. $bdate = "null";
  57. } else {
  58. $bdate = $_REQUEST["b_date"];
  59. $bdate = "'$bdate'";
  60. }
  61. if (empty($_REQUEST["e_date"])) {
  62. $edate = "null";
  63. } else {
  64. $edate = $_REQUEST["e_date"];
  65. $edate = "'$edate'";
  66. }
  67. //Demo测试数据 日期全为空 :前端是由日期过来来的
  68. $edate = "null";
  69. $bdate = "null";
  70. $sqlWhere = ' and ' . common::searchExtendHandNew("ocean", $_SESSION["ONLINE_USER"]);
  71. $sqlWhere = common::check_input($sqlWhere);
  72. $sqlWhere = " " . $sqlWhere;
  73. //online_order_status_date_new 与本地的区分,发布上去这去掉new
  74. $list = common::excuteListSql("select * from public.online_order_status_date_new('$type'::text, 'eta'::text, 'etd'::text, $bdate, $edate, '$sqlWhere'::text, '$container_type'::text) "
  75. . "r (c bigint, e integer, b integer, d text)");
  76. $key = "[";
  77. $value = "[";
  78. $totalValue = 0;
  79. foreach ($list as $vv) {
  80. if ($key != "[") {
  81. $key .= ",";
  82. $value .= ",";
  83. }
  84. if ($type == "r2" || $type == "r3" || $type == "r3_1" || $type == "r4" || $type == "r4_1") {
  85. $key .= '"' . $vv["d"] . '"';
  86. $value .= '{"value":"' . $vv["c"] . '","name":"' . $vv["d"] . '" }';
  87. $totalValue = $totalValue + $vv["c"];
  88. } else {
  89. if ($vv["e"] == -1) {
  90. $key .= '"Over 80 Days"';
  91. $value .= '{"value":"' . $vv["c"] . '","name":"Over 80 Days"}';
  92. } else {
  93. $key .= '"' . $vv["b"] . '-' . $vv["e"] . ' Days"';
  94. $value .= '{"value":"' . $vv["c"] . '","name":"' . $vv["b"] . '-' . $vv["e"] . ' Days"}';
  95. }
  96. $totalValue = $totalValue + $vv["c"];
  97. }
  98. }
  99. $key .= "]";
  100. $value .= "]";
  101. //处理返回原表数据格式
  102. $data = common::mian_repot_do($value,$type,$totalValue);
  103. common::echo_json_encode(200, $data);
  104. exit();
  105. break;
  106. case 'main_report_kpi':
  107. $type = $_REQUEST["r_type"];
  108. $container_type = $_REQUEST["container_type"];
  109. if (empty($_REQUEST["b_date"])) {
  110. $bdate = "null";
  111. } else {
  112. $bdate = $_REQUEST["b_date"];
  113. $bdate = "'$bdate'";
  114. }
  115. if (empty($_REQUEST["e_date"])) {
  116. $edate = "null";
  117. } else {
  118. $edate = $_REQUEST["e_date"];
  119. $edate = "'$edate'";
  120. }
  121. //Demo测试数据 日期全为空
  122. $edate = "null";
  123. $bdate = "null";
  124. $sqlWhere = ' and ' . common::searchExtendHandNew("ocean", $_SESSION["ONLINE_USER"]);
  125. $sqlWhere = common::check_input($sqlWhere);
  126. $sqlWhere = " " . $sqlWhere;
  127. $list = common::excuteListSql("select * from public.online_order_status_date_kpi_new('$type'::text,'$sqlWhere'::text) "
  128. . "r (c bigint, d text)");
  129. $key = "[";
  130. $value = "[";
  131. $totalValue = 0;
  132. foreach ($list as $vv) {
  133. if ($key != "[") {
  134. $key .= ",";
  135. $value .= ",";
  136. }
  137. if ($type == "ata_r3" || $type == "atd_r4" ) {
  138. $key .= '"' . $vv["d"] .'"';
  139. $value .= '{"value":"' . $vv["c"] . '","name":"' . $vv["d"] .'"}';
  140. $totalValue = $totalValue + $vv["c"];
  141. }
  142. }
  143. $key .= "]";
  144. $value .= "]";
  145. //处理返回原表数据格式
  146. $ETDList = array();
  147. $value_arr = json_decode($value,true);
  148. foreach($value_arr as $arr){
  149. $color = common::getItemStyle($type,$arr['name']);
  150. $ETDList[] = array("value" =>intval($arr['value']),"name" =>$arr['name'],"itemStyle" =>array("color" =>$color));
  151. }
  152. if($type == 'atd_r4'){
  153. $data = array("ETDList" =>$ETDList,"ETD_Radius"=>array('30%','50%'),"title1" =>"Departure","title2" =>"(ATD-ETD)");
  154. }
  155. if($type == 'ata_r3'){
  156. $data = array("ETDList" =>$ETDList,"ETD_Radius"=>array('30%','50%'),"title1" =>"Arrival","title2" =>"(ATD-ETD)");
  157. }
  158. common::echo_json_encode(200, $data);
  159. exit();
  160. break;
  161. case 'main_report_container_bar':
  162. //新UI 要ALL 20 40 45 四份数据同时查询,且是柱状图,所以与r3 r4查询分开
  163. $container_type_arr = array("20","40","45");
  164. $container_type_param = $_REQUEST["container_type"];
  165. $ContainerCounSeries = array();
  166. foreach($container_type_arr as $_container_type){
  167. $container_type = $_container_type;
  168. $type = $_REQUEST["r_type"];
  169. if (empty($_REQUEST["b_date"])) {
  170. $bdate = "null";
  171. } else {
  172. $bdate = $_REQUEST["b_date"];
  173. $bdate = "'$bdate'";
  174. }
  175. if (empty($_REQUEST["e_date"])) {
  176. $edate = "null";
  177. } else {
  178. $edate = $_REQUEST["e_date"];
  179. $edate = "'$edate'";
  180. }
  181. $list= array();
  182. //all 查询所有
  183. $sqlWhere = ' and ' . common::searchExtendHandNew("ocean", $_SESSION["ONLINE_USER"]);
  184. $sqlWhere = common::check_input($sqlWhere);
  185. $sqlWhere = " " . $sqlWhere;
  186. //如果页面查询的是ALL 这个20 40 45都查询出来。否则值查询都对应的size,其他的不查询
  187. if(strtolower($container_type_param) == "all"){
  188. $list = common::excuteListSql("select * from public.online_order_status_date('$type'::text, 'eta'::text, 'etd'::text, $bdate, $edate, '$sqlWhere'::text, '$container_type'::text) "
  189. . "r (c bigint, e integer, b integer, d text)");
  190. }else{
  191. if($container_type_param == $_container_type){
  192. $list = common::excuteListSql("select * from public.online_order_status_date('$type'::text, 'eta'::text, 'etd'::text, $bdate, $edate, '$sqlWhere'::text, '$container_type'::text) "
  193. . "r (c bigint, e integer, b integer, d text)");
  194. }
  195. }
  196. $key = "[";
  197. $value = "[";
  198. $totalValue = 0;
  199. foreach ($list as $vv) {
  200. if ($key != "[") {
  201. $key .= ",";
  202. $value .= ",";
  203. }
  204. if ($type == "r2" || $type == "r3" || $type == "r3_1" || $type == "r4" || $type == "r4_1") {
  205. $key .= '"' . $vv["d"] . '"';
  206. $value .= '{"value":"' . $vv["c"] . '","name":"' . $vv["d"] . '" }';
  207. $totalValue = $totalValue + $vv["c"];
  208. } else {
  209. if ($vv["e"] == -1) {
  210. $key .= '"Over 80 Days"';
  211. $value .= '{"value":"' . $vv["c"] . '","name":"Over 80 Days"}';
  212. } else {
  213. $key .= '"' . $vv["b"] . '-' . $vv["e"] . ' Days"';
  214. $value .= '{"value":"' . $vv["c"] . '","name":"' . $vv["b"] . '-' . $vv["e"] . ' Days"}';
  215. }
  216. $totalValue = $totalValue + $vv["c"];
  217. }
  218. }
  219. $key .= "]";
  220. $value .= "]";
  221. $key_arr = json_decode($key,true);
  222. $value_arr = json_decode($value,true);
  223. $data = array();
  224. //每一个size 的所有月份总计
  225. $total = 0;
  226. //每一个size 对应的最大值
  227. $max = 0;
  228. foreach($value_arr as $arr){
  229. $data[] = intval($arr['value']);
  230. $total = $total + intval($arr['value']);
  231. $max = $max < intval($arr['value']) ? intval($arr['value']) : $max;
  232. }
  233. $ContainerCounSeries[$container_type] = array("data"=>$data,"total"=>$total,"max"=>$max);
  234. }
  235. //处理返回时数据格式
  236. $ContainerCounSeries_return = array();
  237. //横坐标栏位
  238. $ContainerCount_Title = $key_arr;
  239. //所查的所有模式计算总和
  240. $total = 0;
  241. //所有size下的最大值,方便标注计算最长的Y坐标
  242. $max_all = 0;
  243. foreach($ContainerCounSeries as $k =>$v){
  244. //这个type 是页面传过来的。这个固定r2
  245. $color = common::getItemStyle($type,$k);
  246. $total = $total + $v['total'];
  247. $ContainerCounSeries_return[] = array("name"=>$k,"type"=>"bar","emphasis" => array("focus" =>"none"),
  248. "stack" =>"总计","data" =>$v['data'],"itemStyle" =>array("color" =>$color));
  249. $max_all = $max_all + $v['max'];
  250. }
  251. //计算Y坐标的间隔
  252. $interval = utils::calculateTicks(0,$max_all,5);
  253. if($interval == 0){
  254. //处理返回默认值
  255. $interval = 2;
  256. }
  257. $returnData = array("ContainerCount_Title"=>"Total: $total","ContainerCountList" =>$ContainerCount_Title,"ContainerCounSeries" =>$ContainerCounSeries_return,
  258. "min" => 0,"Max" =>$interval*5,"interval" =>$interval);
  259. common::echo_json_encode(200, $returnData);
  260. exit();
  261. break;
  262. case 'main_report_co2e_bar':
  263. $returnData = common::getCo2eBar();
  264. common::echo_json_encode(200, $returnData);
  265. exit();
  266. break;
  267. case 'main_report_top10_bar':
  268. $returnData = common::getTopBar();
  269. common::echo_json_encode(200, $returnData);
  270. exit();
  271. break;
  272. case 'main_map':
  273. $uncode = $_POST["uncode"];
  274. $serial_no = $_POST["serial_no"];
  275. $unall = explode("|", $uncode);
  276. $sql = "";
  277. if (!empty($unall[0]) && $unall[0] != "''") {
  278. $sql .= "select lon as lng, lat as lat, uncode, 'Place of receipt: '||name1 as location_namewo, 'por' as type from vessel.vt_unlocode where "
  279. . "lon<>0 and lat<>0 and lon is not null and lat is not null and uncode in "
  280. . "($unall[0])";
  281. }
  282. if (!empty($unall[1]) && $unall[1] != "''") {
  283. if (!empty($sql)) {
  284. $sql .= " union ";
  285. }
  286. $sql .= "select lon as lng, lat as lat, uncode, 'POL: '||name1 as location_namewo, 'pol' as type from vessel.vt_unlocode where "
  287. . "lon<>0 and lat<>0 and lon is not null and lat is not null and uncode in "
  288. . "($unall[1])";
  289. }
  290. if (!empty($unall[2]) && $unall[2] != "''") {
  291. if (!empty($sql)) {
  292. $sql .= " union ";
  293. }
  294. $sql .= "select lon as lng, lat as lat, uncode, 'POD: '||name1 as location_namewo, 'pod' as type from vessel.vt_unlocode where "
  295. . "lon<>0 and lat<>0 and lon is not null and lat is not null and uncode in "
  296. . "($unall[2])";
  297. }
  298. if (!empty($unall[3]) && $unall[3] != "''") {
  299. if (!empty($sql)) {
  300. $sql .= " union ";
  301. }
  302. $sql .= "select lon as lng, lat as lat, uncode, 'Place of delivery: '||name1 as location_namewo, 'poe' as type from vessel.vt_unlocode where "
  303. . "lon<>0 and lat<>0 and lon is not null and lat is not null and uncode in "
  304. . "($unall[3])";
  305. }
  306. $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,
  307. to_char(tl.upload_time, 'MM/DD/YYYY HH24:MI:SS') as utime
  308. from public.tk_general g, public.tk_commodity c left join public.tk_location tl on c.serial_no=tl.serial_no
  309. 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");
  310. foreach ($tkStatus as $vv) {
  311. $ll = explode(",", $vv["location"]);
  312. if ($vv["by_pickup"] == "t") {
  313. $pf = explode("\r\n", $vv["pickup_from_exp"]);
  314. $pf = common::check_input($pf[0]) . "(" . $vv["ctnr"] . ")";
  315. $dt = explode("\r\n", $vv["consignee_exp"]);
  316. $dt = common::check_input($dt[0]) . "(" . $vv["ctnr"] . ")";
  317. } else {
  318. $pf = explode("\r\n", $vv["consignee_exp"]);
  319. $pf = common::check_input($pf[0]) . "(" . $vv["ctnr"] . ")";
  320. $dt = explode("\r\n", $vv["deliveryto_exp"]);
  321. $dt = common::check_input($dt[0]) . "(" . $vv["ctnr"] . ")";
  322. }
  323. if ($vv["type"] == "26" && !empty($ll[1])) {
  324. if (!empty($sql)) {
  325. $sql .= " union ";
  326. }
  327. $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";
  328. } elseif ($vv["type"] == "25" && !empty($ll[1])) {
  329. if (!empty($sql)) {
  330. $sql .= " union ";
  331. }
  332. $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";
  333. }
  334. }
  335. if (!empty($sql)) {
  336. $gps = common::excuteListSql($sql . "");
  337. }
  338. if (!empty($serial_no)) {
  339. $all = explode(",", $serial_no);
  340. foreach ($all as $a) {
  341. $rs = common::excuteOneSql("select public.get_vessel_position('$a'::text)");
  342. if (!empty($rs)) {
  343. $rss = explode("|", $rs);
  344. $lng_lat = explode(",", $rss[1]);
  345. $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" => "");
  346. }
  347. }
  348. }
  349. $data = array("gps" => $gps);
  350. common::echo_json_encode("200", $data);
  351. exit();
  352. break;
  353. case 'main_map_new':
  354. //修改添加port_of_transshipment 和port_of_transshipment_name的坐标获取(有为空的可能)
  355. $serial_no = $_POST["serial_no"];
  356. $sql = "with ss as (select '$serial_no' as sn)
  357. , aa as (
  358. 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.*
  359. from public.online_ocean oo
  360. left join LATERAL (
  361. select (select uncode from ports where code = o.port_of_transshipment) as port_of_transshipment_un,
  362. port_of_transshipment_name
  363. from ocean o where o.serial_no=oo.serial_no order by id desc limit 1
  364. ) dd on true
  365. where serial_no=(select sn from ss) limit 1
  366. )
  367. , v1 as (select public.get_vessel_position(sn::text) bbb from ss)
  368. , t1 as (
  369. select tl.upload_time, tl.by_pickup, split_part(g.consignee_exp,'\n',1) as consignee_exp, split_part(g.pickup_from_exp,'\n',1) as pickup_from_exp,
  370. c.ctnr, split_part(g.deliveryto_exp,'\n',1) as deliveryto_exp,g.serial_no, tl.location, tl.type, tl.id,
  371. to_char(tl.upload_time, 'MM/DD/YYYY HH24:MI:SS') as utime
  372. from public.tk_general g, public.tk_commodity c
  373. left join public.tk_location tl on c.serial_no=tl.serial_no
  374. where g.serial_no=c.serial_no and g.bol=(select m_bol from public.ocean where serial_no=(select sn from ss)) order by tl.order_id)
  375. , rr as (
  376. 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
  377. 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
  378. union all
  379. 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
  380. 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
  381. union all
  382. 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
  383. 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
  384. )
  385. select * from rr order by sort, stime";
  386. $rss = common::excuteListSql($sql);
  387. //先固定死
  388. $json = '[{"lng":"100.78594000","lat":"13.68521000","label":"Origin","infor":"LAT KRABANG, THAILAND","sort":"0","stime":null,"ptype":"por"},
  389. {"lng":"100.88333333","lat":"13.08333333","label":"Destination","infor":"LAEM CHABANG PORT,THAILAND","sort":"1","stime":null,"ptype":"pol"},
  390. {"lng":"-122.28640000","lat":"37.79784000","label":"Transfer","infor":"OAKLAND, CA, USA","sort":"2","stime":null,"ptype":"pod"}]';
  391. $rss = json_decode($json,true);
  392. common::echo_json_encode(200, $rss);
  393. exit();
  394. break;
  395. case 'main_welcome':
  396. $cp = common::check_input($_POST ['cp']); //current_page
  397. $ps = common::check_input($_POST ['ps']); //ps
  398. if (empty($ps))
  399. $ps = 10;
  400. $sqlWhere = ' where ' . common::searchExtendHandNew("ocean", $_SESSION["ONLINE_USER"]);
  401. //默认初始条件:ALL& ETD& Current Month 当前月的1号到最后一天
  402. if(isset($_POST['is_default']) && strtolower($_POST['is_default']) == "yes"){
  403. $sqlWhere .= "and etd>='" . date("Y-m") . "-01' and etd<='" . date("Y-m") . "-01'::date + interval '1 month'";
  404. }else{
  405. $date_type = common::check_input($_POST ['date_type']);
  406. if (isset($_POST['date_start']) && !empty($_POST['date_start']))
  407. $sqlWhere .= " and $date_type >= '" . common::usDate2sqlDate($_POST['date_start']) . " 00:00:00'";
  408. if (isset($_POST['date_end']) && !empty($_POST['date_end']))
  409. $sqlWhere .= " and $date_type <= '" . common::usDate2sqlDate($_POST['date_end']) . " 23:59:59'";
  410. }
  411. if (isset($_POST['customer']) && !empty($_POST['customer'])){
  412. $sqlWhere .= " and (shipper ilike '%".common::check_input($_POST['customer'])."%' or shipper_id ilike '%".common::check_input($_POST['customer'])."%'
  413. or consignee ilike '%".common::check_input($_POST['customer'])."%' or consignee_id ilike '%".common::check_input($_POST['customer'])."%')";
  414. }
  415. $rc = $_POST ['rc'];
  416. if ($rc == - 1) {
  417. $sql = "SELECT count(1) from public.online_ocean" . $sqlWhere ." and last_status_315_update_time is not null";
  418. $rc = common::excuteOneSql($sql);
  419. error_log($sql);
  420. }
  421. $tp = ceil($rc / $ps);
  422. if ($rc > 0) {
  423. $sql = "SELECT serial_no,last_status_city, consignee, shipper, h_bol,
  424. to_char(etd, 'MM/DD/YYYY'::text) as etd, to_char(eta, 'MM/DD/YYYY'::text) AS eta,
  425. fport_of_loading_un, mport_of_discharge_un, place_of_receipt_un, place_of_delivery_un, ctnrs, count_cntr, last_status_ctnr,booking_no,
  426. 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,
  427. dd.status
  428. FROM public.online_ocean
  429. left join LATERAL (select case when a.description='Booking Confirmation' then 'Booked'
  430. when a.description='Cargo Pickup' then 'Cargo Received'
  431. when a.description='Cargo Arrived at Origin' then 'Cargo Received'
  432. when a.description='Departure' then 'Departed'
  433. when a.description='Arrived at Final Destination Port Arrived' then 'Arrived'
  434. when a.description='Arrived at Final Destination' then 'Completed'
  435. else 'Booked' END as status
  436. from ocean_milestone a
  437. where a.serial_no=online_ocean.serial_no
  438. and a.description in (
  439. select regexp_split_to_table('Booking Confirmation,Cargo Pickup,Cargo Arrived at Origin,Departure,Arrived at Final Destination Port,Arrived at Final Destination', ','))
  440. order by id desc limit 1) dd on true
  441. $sqlWhere and last_status_315_update_time is not null";
  442. if (_isDemo()) {
  443. $sql .= " ORDER BY eta DESC limit " . $ps . " offset " . ($cp - 1) * $ps;
  444. } else {
  445. $sql .= " ORDER BY last_status_315_update_time DESC limit " . $ps . " offset " . ($cp - 1) * $ps;
  446. }
  447. $rss = common::excuteListSql($sql);
  448. //RecentStatusList
  449. $RecentStatusList = array();
  450. foreach ($rss as $key => $value) {
  451. $Arrived = utils::outDisplayForMerge(common::getStatusDesc($value["last_status_315_code"]),common::_toString($value["last_status_loc"]),";");
  452. $RecentStatusList[] = array("Title"=>$value['h_bol'],
  453. "name"=>"MSC SHANVI III / HD433A",
  454. "bookingNumber" =>$value['booking_no'],
  455. "IsSubscribe" =>false,
  456. "shipperName"=>$value['shipper'],
  457. "consigneeName" =>$value['consignee'],
  458. "startStation"=>$value['fport_of_loading_un'],
  459. "endStation"=>$value['mport_of_discharge_un'],
  460. "ETD"=>$value['etd'],
  461. "ETA"=>$value['eta'],
  462. "type"=>$value['status'],
  463. "Arrived"=>$Arrived,
  464. "Time"=>$value["last_status_315_date"],
  465. "a" =>common::deCode($value['serial_no'], 'E'));
  466. }
  467. $arrTmp = array('searchData' => $RecentStatusList,
  468. 'Management' => common::getManagement(),
  469. 'is_customer' =>_isCustomerLogin(),
  470. 'rc' => $rc,
  471. 'ps' => $ps,
  472. 'cp' => $cp,
  473. 'tp' => $tp);
  474. } else {
  475. $arrTmp = array('searchData' => array(),
  476. 'Management' => common::getManagement());
  477. }
  478. common::echo_json_encode(200,$arrTmp);
  479. exit();
  480. break;
  481. case 'save_layout':
  482. $management = json_encode($_POST["management"]);
  483. common::excuteUpdateSql("update public.ra_online_user set management = '$management' where lower(user_login) = '" . strtolower(_getLoginName()) . "'");
  484. $returnData = array("msg" => "success");
  485. common::echo_json_encode(200, $returnData);
  486. exit();
  487. break;
  488. case 'password':
  489. tools::getInstance()->updatePassword();
  490. break;
  491. default:
  492. $data = array(
  493. 'msg' => 'Page not found',
  494. );
  495. common::echo_json_encode(500, $data);
  496. }
  497. $db->Close();
  498. $db = null;
  499. if ($max_ec > 0)
  500. ini_set('max_execution_time', $max_ec); //recover old value
  501. if (!empty($memory_limit))
  502. ini_set('memory_limit', $memory_limit);
  503. ?>