VM暫存
Nie możesz wybrać więcej, niż 25 tematów Tematy muszą się zaczynać od litery lub cyfry, mogą zawierać myślniki ('-') i mogą mieć do 35 znaków.

1418 wiersze
50KB

  1. <?php
  2. /*
  3. file: cars_model.php
  4. */
  5. require_once(ALTOB_SYNC_FILE) ;
  6. define('CARS_TMP_LOG', 'cars_tmp_log'); // 暫存進出車號
  7. class Cars_model extends CI_Model
  8. {
  9. var $vars = array();
  10. var $io_name = array('I' => '車入', 'O' => '車出', 'MI' => '機入', 'MO' => '機出', 'FI' => '樓入', 'FO' => '樓出');
  11. var $now_str;
  12. function __construct()
  13. {
  14. parent::__construct();
  15. $this->load->database();
  16. $this->now_str = date('Y-m-d H:i:s');
  17. }
  18. public function init($vars)
  19. {
  20. $this->vars = $vars;
  21. }
  22. // 車輛進出傳入車牌號碼 (2016/07/27)
  23. public function opendoor_lprio($parms)
  24. {
  25. $parms['lpr'] = urldecode($parms['lpr']);
  26. $rows = array();
  27. // $parms['ts'] = date('Y-m-d H:i:s', $parms['ts']);
  28. trigger_error(__FUNCTION__ . '|車牌傳入:' . print_r($parms, true));
  29. if ($parms['etag'] != 'NONE')
  30. {
  31. if ($parms['lpr'] != 'NONE')
  32. {
  33. // do nothing
  34. }
  35. else // 車辨失敗但有eTag, 查詢是否有車號
  36. {
  37. //$parms['lpr'] = $this->etag2lpr_2($parms['etag']); // 2017/01/10 預設都不用 ETAG 找車牌
  38. }
  39. }
  40. $rows = $this->get_member($parms['lpr']);
  41. $this->save_db_io($parms, $rows, true);
  42. return true;
  43. }
  44. // 車輛進出傳入車牌號碼
  45. public function lprio($parms)
  46. {
  47. //$parms['lpr'] = urldecode($parms['lpr']);
  48. $rows = array();
  49. // $parms['ts'] = date('Y-m-d H:i:s', $parms['ts']);
  50. trigger_error('車牌傳入:' . print_r($parms, true));
  51. if ($parms['etag'] != 'NONE')
  52. {
  53. if ($parms['lpr'] != 'NONE')
  54. {
  55. // 有車牌有eTag, 檢查資料庫是否double驗證
  56. //get_headers("http://192.168.10.201/cars.html/check_lpr_etag/{$parms['lpr']}/{$parms['etag']}");
  57. get_headers("http://localhost/cars.html/check_lpr_etag/{$parms['lpr']}/{$parms['etag']}"); // update 2016/07/26
  58. }
  59. else // 車辨失敗但有eTag, 查詢是否有車號
  60. {
  61. // $parms['lpr'] = $this->etag2lpr_2($parms['etag']); // 2017/01/10 預設都不用 ETAG 找車牌
  62. }
  63. }
  64. $rows = $this->get_member($parms['lpr']);
  65. $this->save_db_io($parms, $rows);
  66. return true;
  67. }
  68. // 入出口異動cario
  69. public function save_db_io($parms, $rows, $opendoor=false)
  70. {
  71. if (!empty($rows['lpr_correct'])) $parms['lpr'] = $rows['lpr_correct'];
  72. // [START] 擋重覆 20170912 前端不止一筆 opendoor 送來時, 只處理第一個 (限 2 sec 內)
  73. if($opendoor)
  74. {
  75. $skip_or_not = false;
  76. $new_cars_tmp = array
  77. (
  78. 'timestamp' => time(),
  79. 'sno_io' => $parms['sno'] . $parms['io'],
  80. 'lpr' => $parms['lpr']
  81. );
  82. $cars_tmp_arr = array();
  83. $cars_tmp_log_arr = $this->vars['mcache']->get(CARS_TMP_LOG);
  84. if(!empty($cars_tmp_log_arr))
  85. {
  86. foreach($cars_tmp_log_arr as $tmp)
  87. {
  88. if(isset($tmp['timestamp']) && $tmp['timestamp'] > time() - 2) // 時限內才判斷
  89. {
  90. array_push($cars_tmp_arr, $tmp);
  91. }
  92. }
  93. }
  94. // 判斷是否繼續
  95. foreach($cars_tmp_arr as $tmp)
  96. {
  97. if( $new_cars_tmp['lpr'] == $tmp['lpr'] &&
  98. $new_cars_tmp['sno_io'] == $tmp['sno_io'])
  99. {
  100. $skip_or_not = true;
  101. }
  102. }
  103. // 更新
  104. array_push($cars_tmp_arr, $new_cars_tmp);
  105. $this->vars['mcache']->set(CARS_TMP_LOG, $cars_tmp_arr);
  106. trigger_error(__FUNCTION__ . '..new ' . CARS_TMP_LOG . " |s:{$skip_or_not}|" . print_r($cars_tmp_arr, true));
  107. // 跳過
  108. if($skip_or_not)
  109. {
  110. trigger_error(__FUNCTION__ . '..skip..');
  111. return false;
  112. }
  113. }
  114. // [END] 擋重覆
  115. // 車辨失敗, 結束
  116. if ($parms['lpr'] == 'NONE')
  117. {
  118. if($opendoor)
  119. {
  120. $this->mq_send(MQ_TOPIC_ALTOB, MQ_ALTOB_MSG.",1,{$parms['ivsno']}".MQ_ALTOB_MSG_END_TAG);
  121. // $this->mq_send(MQ_TOPIC_SUBTEXT, "{$parms['ivsno']},車辨失敗");
  122. if(substr($parms['io'], -strlen('O')) === 'O')
  123. {
  124. // [acer] cmd:102 離場車辨失敗流程 START
  125. $this->call_acer('102', array('cario_no' => 0, 'ivs_no' => $parms['ivsno'], 'msg_code' => 1));
  126. // [acer] cmd:102 離場車辨失敗流程 END
  127. }
  128. }
  129. else
  130. {
  131. if(substr($parms['io'], -strlen('I')) === 'I')
  132. {
  133. // [acer] cmd:101 入場車辨失敗流程 START
  134. $ticket_no = $this->gen_pass_code();
  135. $data = array
  136. (
  137. 'station_no' => $parms['sno'],
  138. 'obj_type' => 1,
  139. 'obj_id' => $parms['lpr'],
  140. 'etag' => $parms['etag'] == 'NONE' ? '' : $parms['etag'],
  141. 'in_out' => $parms['io'],
  142. 'member_no' => 0,
  143. 'finished' => 0,
  144. 'in_time' => $this->now_str,
  145. 'in_lane' => $parms['ivsno'],
  146. 'in_pic_name' => empty($parms['pic_name']) ? '' : $parms['pic_name'],
  147. 'out_before_time' => date("Y-m-d H:i:s"),
  148. 'ticket_no' => $ticket_no
  149. );
  150. $this->db->insert('cario', $data);
  151. trigger_error("[車辨失敗] 新增入場資料:".print_r($parms, true));
  152. $acer_parms = array
  153. (
  154. 'cario_no' => $this->db->insert_id(),
  155. 'in_time' => $this->now_str,
  156. 'ticket_no' => $ticket_no,
  157. 'lpr' => '',
  158. 'ivs_no' => $parms['ivsno']
  159. );
  160. $this->call_acer('101', $acer_parms);
  161. // [acer] cmd:101 入場車辨失敗流程 END
  162. }
  163. }
  164. return false;
  165. }
  166. $msg = $rows['member_no'] != 0 ? "{$parms['lpr']}." : $parms['lpr']; // 月租車號加.符號
  167. // 月租鎖車, 結束
  168. //if (($parms['io'] == 'CO' || $parms['io'] == 'MO') && $rows['member_no'] != 0 && !empty($rows['locked']) && $rows['locked'] == 1)
  169. if ((substr($parms['io'], -strlen('O')) === 'O') && $rows['member_no'] != 0 && !empty($rows['locked']) && $rows['locked'] == 1)
  170. {
  171. if($opendoor){
  172. //// $this->mq_send(MQ_TOPIC_SUBTEXT, "{$parms['ivsno']},{$msg}已鎖車!");
  173. $this->mq_send(MQ_TOPIC_ALTOB, MQ_ALTOB_MSG.",2,{$parms['ivsno']},{$parms['lpr']}".MQ_ALTOB_MSG_END_TAG);
  174. // $this->mq_send(MQ_TOPIC_SUBTEXT, "{$parms['ivsno']},{$msg}禁止離場請後退");
  175. // [acer] cmd:102 離場車辨已鎖車 START
  176. $this->call_acer('102', array('cario_no' => 0, 'ivs_no' => $parms['ivsno'], 'msg_code' => 2));
  177. // [acer] cmd:102 離場車辨已鎖車 END
  178. }
  179. return false;
  180. }
  181. // 取得會員資訊
  182. $parms['member_no'] = $rows['member_no'];
  183. switch($parms['io'])
  184. {
  185. case 'CI':
  186. case 'MI':
  187. if($opendoor){
  188. // 開門
  189. /*
  190. if ($rows['member_no'] != 0)
  191. {
  192. $this->member_opendoors($parms);
  193. }
  194. else
  195. {
  196. $this->temp_opendoors($parms);
  197. }
  198. */
  199. // 取得出入口 888 資訊
  200. /*
  201. $pks_888_arr = $this->get_888_info($parms);
  202. if ($pks_888_arr['availables'] == 0)
  203. {
  204. if ($rows['member_no'] == 0)
  205. {
  206. // 滿車訊號 (臨停)
  207. $this->mq_send(MQ_TOPIC_ALTOB, MQ_ALTOB_MSG.",14,{$parms['ivsno']},{$parms['lpr']}".MQ_ALTOB_MSG_END_TAG);
  208. // 開門訊號 (臨停)
  209. $this->temp_opendoors($parms);
  210. return false;
  211. }
  212. else
  213. {
  214. // 滿車訊號 (會員)
  215. $this->mq_send(MQ_TOPIC_ALTOB, MQ_ALTOB_MSG.",15,{$parms['ivsno']},{$parms['lpr']}".MQ_ALTOB_MSG_END_TAG);
  216. }
  217. }
  218. */
  219. // 空車位導引
  220. $pks_arr = $this->get_valid_seat();
  221. if ($pks_arr['result']['location_no'] != 0)
  222. {
  223. $pks_loc_name = $pks_arr['loc_name'];
  224. $pks_loc_no = $pks_arr['result']['location_no'];
  225. $pks_floors = $pks_arr['floors'];
  226. }
  227. else
  228. {
  229. $pks_loc_name = 0;
  230. $pks_loc_no = 0;
  231. $pks_floors = 0;
  232. }
  233. // 訊息
  234. if ($rows['member_no'] == 0)
  235. {
  236. $ck = md5($parms['lpr']);
  237. $jdata = file_get_contents("http://localhost/allpa_service.html/get_allpa_valid_user/{$parms['lpr']}/{$ck}");
  238. $results = json_decode($jdata, true);
  239. if($results['result_code'] == 0)
  240. {
  241. // 歐pa, 開門
  242. $this->member_opendoors($parms);
  243. // 歐pa, 進場
  244. $this->mq_send(MQ_TOPIC_ALTOB, MQ_ALTOB_MSG.",3,{$parms['ivsno']},{$parms['lpr']},{$pks_floors},{$pks_loc_no}".MQ_ALTOB_MSG_END_TAG);
  245. // old msg
  246. // $this->mq_send(MQ_TOPIC_SUBTEXT, "{$parms['ivsno']},{$msg},歐pa卡用戶您好:請停{$pks_loc_name}{$pks_loc_no}車位");
  247. }
  248. else
  249. {
  250. // 臨停車, 開門 (同會員)
  251. $this->temp_opendoors($parms);
  252. // 臨停車, 進場
  253. $this->mq_send(MQ_TOPIC_ALTOB, MQ_ALTOB_MSG.",11,{$parms['ivsno']},{$parms['lpr']},{$pks_floors},{$pks_loc_no}".MQ_ALTOB_MSG_END_TAG);
  254. // old msg
  255. // $this->mq_send(MQ_TOPIC_SUBTEXT, "{$parms['ivsno']},{$msg}請停{$pks_loc_name}{$pks_loc_no}車位");
  256. }
  257. }
  258. else
  259. {
  260. // 會員, 開門
  261. $this->member_opendoors($parms);
  262. // 會員, 進場
  263. $this->mq_send(MQ_TOPIC_ALTOB, MQ_ALTOB_MSG.",4,{$parms['ivsno']},{$parms['lpr']},{$pks_floors},{$pks_loc_no}".MQ_ALTOB_MSG_END_TAG);
  264. // old msg
  265. // $this->mq_send(MQ_TOPIC_SUBTEXT, "{$parms['ivsno']},{$msg},月租戶請進場:請停{$pks_loc_name}{$pks_loc_no}車位");
  266. }
  267. }else{
  268. // 資料流
  269. if ($parms['lpr'] != 'NONE')
  270. {
  271. $data = array
  272. (
  273. 'err' => 1,
  274. 'finished' => 1
  275. );
  276. // 原有歷史記錄, 設定錯誤碼為1(入場不應該有歷史記錄)
  277. $this->db->update('cario', $data, array('obj_id' => $parms['lpr'], 'finished' => 0, 'err' => 0, 'obj_type' => 1));
  278. $affect_rows = $this->db->affected_rows();
  279. if ($affect_rows > 0)
  280. {
  281. trigger_error("err://入場郤已有歷史進場記錄[{$affect_rows}]筆,已設成錯誤並結清記錄".print_r($parms, true));
  282. }
  283. }
  284. // [acer] cmd:101 入場車辨成功流程 START
  285. $ticket_no = $this->gen_pass_code();
  286. $data = array
  287. (
  288. 'station_no' => $parms['sno'],
  289. 'obj_type' => 1,
  290. 'obj_id' => $parms['lpr'],
  291. 'etag' => $parms['etag'] == 'NONE' ? '' : $parms['etag'],
  292. 'in_out' => $parms['io'],
  293. 'member_no' => $rows['member_no'],
  294. 'finished' => 0,
  295. 'in_time' => $this->now_str,
  296. 'in_lane' => $parms['ivsno'],
  297. 'in_pic_name' => empty($parms['pic_name']) ? '' : $parms['pic_name'],
  298. 'out_before_time' => date("Y-m-d H:i:s"),
  299. 'ticket_no' => $ticket_no
  300. );
  301. $this->db->insert('cario', $data);
  302. trigger_error("新增入場資料:".print_r($parms, true));
  303. $acer_parms = array
  304. (
  305. 'cario_no' => $this->db->insert_id(),
  306. 'in_time' => $this->now_str,
  307. 'ticket_no' => $ticket_no,
  308. 'lpr' => $parms['lpr'],
  309. 'ivs_no' => $parms['ivsno']
  310. );
  311. $this->call_acer('101', $acer_parms);
  312. // [acer] cmd:101 入場車辨成功流程 END
  313. // 傳送進場記錄
  314. $sync_agent = new AltobSyncAgent();
  315. $sync_agent->init($parms['sno'], $this->now_str);
  316. $sync_agent->cario_no = $this->db->insert_id(); // 進出編號
  317. $sync_agent->member_no = $rows['member_no']; // 會員編號
  318. $sync_result = $sync_agent->sync_st_in($parms);
  319. trigger_error( "..sync_st_in.." . $sync_result);
  320. }
  321. break;
  322. // 出場
  323. case 'CO':
  324. case 'MO':
  325. // 讀取最近一筆入場資料
  326. $rows_cario = $this->db
  327. ->select('cario_no, payed, in_time, pay_time, out_before_time')
  328. ->from('cario')
  329. //->where(array('in_out' => 'CI', 'obj_id' => $parms['lpr'], 'finished' => 0, 'err' => 0))
  330. ->where(array('obj_id' => $parms['lpr'], 'err' => 0))
  331. ->order_by('cario_no', 'desc')
  332. ->limit(1)
  333. ->get()
  334. ->row_array();
  335. trigger_error("opendoor={$opendoor}| 出場讀到資料:{$rows['member_no']}|".time().'|'.print_r($rows_cario, true));
  336. if (!empty($rows_cario['cario_no'])) // 在限時內可出場
  337. {
  338. $co_time_minutes = floor((strtotime($this->now_str) - strtotime($rows_cario['in_time'])) / 60); // 停車時數 (分鐘)
  339. // 合規定者開門放行
  340. switch(true)
  341. {
  342. case $rows['member_no'] != 0:
  343. // CO.A.1 會員車
  344. // 判斷時段租是否超時 (超過 12 小時)
  345. if($rows['park_time'] != 'RE' && $co_time_minutes > 720)
  346. {
  347. if($opendoor)
  348. {
  349. // 時段租超時字幕
  350. $this->mq_send(MQ_TOPIC_ALTOB, MQ_ALTOB_MSG.",16,{$parms['ivsno']},{$parms['lpr']}".MQ_ALTOB_MSG_END_TAG);
  351. // [acer] cmd:102 離場車辨成功流程 START
  352. $this->call_acer('102', array('cario_no' => $rows_cario['cario_no'], 'ivs_no' => $parms['ivsno'], 'msg_code' => 16));
  353. // [acer] cmd:102 離場車辨成功流程 END
  354. }
  355. else
  356. {
  357. $data = array
  358. (
  359. 'out_time' => $this->now_str,
  360. 'out_lane' => $parms['ivsno'],
  361. 'minutes' => $co_time_minutes,
  362. 'out_pic_name' => $parms['pic_name']
  363. );
  364. $this->db->update('cario', $data, array('cario_no' => $rows_cario['cario_no'])); // 記錄出場
  365. trigger_error("{$parms['lpr']}|時段租超時" . print_r($rows_cario, true));
  366. // 傳送離場記錄
  367. $sync_agent = new AltobSyncAgent();
  368. $sync_agent->init($parms['sno'], $this->now_str);
  369. $sync_agent->cario_no = $rows_cario['cario_no']; // 進出編號
  370. $sync_agent->member_no = $rows['member_no']; // 會員編號
  371. $sync_agent->in_time = $rows_cario['in_time']; // 入場時間
  372. $sync_result = $sync_agent->sync_st_out($parms);
  373. trigger_error( "..sync_st_out.." . $sync_result);
  374. }
  375. return false;
  376. }
  377. if($opendoor)
  378. {
  379. // 會員開門
  380. $this->member_opendoors($parms);
  381. // 會員字幕
  382. $this->mq_send(MQ_TOPIC_ALTOB, MQ_ALTOB_MSG.",5,{$parms['ivsno']},{$parms['lpr']}".MQ_ALTOB_MSG_END_TAG);
  383. // $this->mq_send(MQ_TOPIC_SUBTEXT, "{$parms['ivsno']},{$msg}謝謝光臨");
  384. // [acer] cmd:102 離場車辨成功流程 START
  385. $this->call_acer('102', array('cario_no' => $rows_cario['cario_no'], 'ivs_no' => $parms['ivsno'], 'msg_code' => 5));
  386. // [acer] cmd:102 離場車辨成功流程 END
  387. }
  388. else
  389. {
  390. $data = array
  391. (
  392. 'in_out' => $parms['io'],
  393. 'finished' => 1,
  394. 'out_time' => $this->now_str,
  395. 'out_lane' => $parms['ivsno'],
  396. 'minutes' => $co_time_minutes,
  397. 'out_pic_name' => $parms['pic_name']
  398. );
  399. $this->db->update('cario', $data, array('cario_no' => $rows_cario['cario_no']));
  400. trigger_error('會員車離場:' . print_r($rows, true));
  401. // 傳送離場記錄
  402. $sync_agent = new AltobSyncAgent();
  403. $sync_agent->init($parms['sno'], $this->now_str);
  404. $sync_agent->cario_no = $rows_cario['cario_no']; // 進出編號
  405. $sync_agent->member_no = $rows['member_no']; // 會員編號
  406. $sync_agent->in_time = $rows_cario['in_time']; // 入場時間
  407. $sync_agent->finished = 1; // 已離場
  408. $sync_result = $sync_agent->sync_st_out($parms);
  409. trigger_error( "..sync_st_out.." . $sync_result);
  410. }
  411. break;
  412. case strtotime($rows_cario['out_before_time']) >= time():
  413. if ($rows_cario['payed'])
  414. {
  415. // CO.B.1 臨停車已付款
  416. if($opendoor)
  417. {
  418. // 臨停開門
  419. $this->temp_opendoors($parms);
  420. // 臨停字幕
  421. $this->mq_send(MQ_TOPIC_ALTOB, MQ_ALTOB_MSG.",6,{$parms['ivsno']},{$parms['lpr']}".MQ_ALTOB_MSG_END_TAG);
  422. //// $this->mq_send(MQ_TOPIC_SUBTEXT, "{$parms['ivsno']},{$msg}付款確認請 離 場謝謝光臨");
  423. // $this->mq_send(MQ_TOPIC_SUBTEXT, "{$parms['ivsno']},{$msg}謝謝光臨");
  424. // [acer] cmd:102 離場車辨成功流程 START
  425. $this->call_acer('102', array('cario_no' => $rows_cario['cario_no'], 'ivs_no' => $parms['ivsno'], 'msg_code' => 6));
  426. // [acer] cmd:102 離場車辨成功流程 END
  427. }
  428. else
  429. {
  430. $data = array
  431. (
  432. 'in_out' => $parms['io'],
  433. 'finished' => 1,
  434. 'out_time' => $this->now_str,
  435. 'out_lane' => $parms['ivsno'],
  436. 'minutes' => $co_time_minutes,
  437. 'out_pic_name' => $parms['pic_name']
  438. );
  439. $this->db->update('cario', $data, array('cario_no' => $rows_cario['cario_no']));
  440. trigger_error('臨停車已付款:' . print_r($rows, true));
  441. // 傳送離場記錄
  442. $sync_agent = new AltobSyncAgent();
  443. $sync_agent->init($parms['sno'], $this->now_str);
  444. $sync_agent->cario_no = $rows_cario['cario_no']; // 進出編號
  445. $sync_agent->in_time = $rows_cario['in_time']; // 入場時間
  446. $sync_agent->finished = 1; // 已離場
  447. $sync_result = $sync_agent->sync_st_out($parms);
  448. trigger_error( "..sync_st_out.." . $sync_result);
  449. }
  450. }
  451. else
  452. {
  453. // CO.B.2 臨停車未付款
  454. if($opendoor)
  455. {
  456. // 臨停字幕
  457. $this->mq_send(MQ_TOPIC_ALTOB, MQ_ALTOB_MSG.",8,{$parms['ivsno']},{$parms['lpr']}".MQ_ALTOB_MSG_END_TAG);
  458. // $this->mq_send(MQ_TOPIC_SUBTEXT, "{$parms['ivsno']},{$msg}臨時車請投票卡或刷卡出場");
  459. // [acer] cmd:102 離場車辨成功流程 START
  460. $this->call_acer('102', array('cario_no' => $rows_cario['cario_no'], 'ivs_no' => $parms['ivsno'], 'msg_code' => 8));
  461. // [acer] cmd:102 離場車辨成功流程 END
  462. }
  463. else
  464. {
  465. // TODO: 歐pa卡離場記錄和臨停未付款一樣, 待更正
  466. $data = array
  467. (
  468. 'out_time' => $this->now_str,
  469. 'out_lane' => $parms['ivsno'],
  470. 'minutes' => $co_time_minutes,
  471. 'out_pic_name' => $parms['pic_name']
  472. );
  473. $this->db->update('cario', $data, array('cario_no' => $rows_cario['cario_no'])); // 記錄出場
  474. trigger_error('臨停未付款:' . print_r($rows, true));
  475. // 傳送離場記錄
  476. $sync_agent = new AltobSyncAgent();
  477. $sync_agent->init($parms['sno'], $this->now_str);
  478. $sync_agent->cario_no = $rows_cario['cario_no']; // 進出編號
  479. $sync_agent->in_time = $rows_cario['in_time']; // 入場時間
  480. $sync_result = $sync_agent->sync_st_out($parms);
  481. trigger_error( "..sync_st_out.." . $sync_result);
  482. // [mitac] 要求 mitac 扣款 START
  483. $this->call_mitac_pay($parms['lpr'], $parms['ivsno'], $rows_cario);
  484. // [mitac] 要求 mitac 扣款 END
  485. }
  486. }
  487. break;
  488. default:
  489. // CO.C.1 其它付款方式
  490. if($opendoor)
  491. {
  492. $in_time = strtotime($rows_cario['out_before_time']);
  493. $ck = md5($in_time. $parms['lpr'] . $parms['sno']);
  494. //$jdata = file_get_contents("http://localhost/allpa_service.html/allpa_go/{$in_time}/{$parms['lpr']}/{$parms['sno']}/{$ck}");
  495. $jdata = file_get_contents("http://localhost/allpa_service.html/allpa_go_remote/{$in_time}/{$parms['lpr']}/{$parms['sno']}/{$ck}");
  496. trigger_error("allpa回傳:{$jdata}|{$in_time}/{$parms['lpr']}/{$parms['sno']}/{$ck}");
  497. $results = json_decode($jdata, true);
  498. if (isset($results['result_code'])) // 歐pa卡, 點數足夠扣
  499. {
  500. if($results['result_code'] == 0)
  501. {
  502. // 臨停開門
  503. $this->temp_opendoors($parms);
  504. // 歐pa卡, 字幕
  505. $this->mq_send(MQ_TOPIC_ALTOB, MQ_ALTOB_MSG.",7,{$parms['ivsno']},{$parms['lpr']},{$results['amt']}".MQ_ALTOB_MSG_END_TAG);
  506. // // $this->mq_send(MQ_TOPIC_SUBTEXT, "{$parms['ivsno']},{$msg}扣{$results['amt']}點請離場");
  507. // $this->mq_send(MQ_TOPIC_SUBTEXT, "{$parms['ivsno']},{$msg}請離場歐pa卡扣:{$results['amt']}點謝謝光臨");
  508. // updated 2016/09/01
  509. $data = array(
  510. 'out_before_time' => date('Y-m-d H:i:s', strtotime(" + 15 minutes")),
  511. 'pay_time' => $this->now_str,
  512. 'pay_type' => 9, // 歐pa卡
  513. 'payed' => 1
  514. );
  515. $this->db->update('cario', $data, array('cario_no' => $rows_cario['cario_no'])); // 記錄出場
  516. // [acer] cmd:102 離場車辨成功流程 START
  517. $this->call_acer('102', array('cario_no' => $rows_cario['cario_no'], 'ivs_no' => $parms['ivsno'], 'msg_code' => 7));
  518. // [acer] cmd:102 離場車辨成功流程 END
  519. }
  520. else if ($results['result_code'] == 12) // 歐pa卡, 餘額不足
  521. {
  522. // 臨停字幕
  523. $this->mq_send(MQ_TOPIC_ALTOB, MQ_ALTOB_MSG.",12,{$parms['ivsno']},{$parms['lpr']}".MQ_ALTOB_MSG_END_TAG);
  524. // [acer] cmd:102 離場車辨成功流程 START
  525. $this->call_acer('102', array('cario_no' => $rows_cario['cario_no'], 'ivs_no' => $parms['ivsno'], 'msg_code' => 12));
  526. // [acer] cmd:102 離場車辨成功流程 END
  527. }
  528. else if ($results['result_code'] == 11) // 歐pa卡, 查無會員
  529. {
  530. // 臨停字幕
  531. $this->mq_send(MQ_TOPIC_ALTOB, MQ_ALTOB_MSG.",9,{$parms['ivsno']},{$parms['lpr']}".MQ_ALTOB_MSG_END_TAG);
  532. //// $this->mq_send(MQ_TOPIC_SUBTEXT, "{$parms['ivsno']},{$msg}其它付款方式");
  533. // $this->mq_send(MQ_TOPIC_SUBTEXT, "{$parms['ivsno']},{$msg}臨時車請投票卡或刷卡出場");
  534. // [acer] cmd:102 離場車辨成功流程 START
  535. $this->call_acer('102', array('cario_no' => $rows_cario['cario_no'], 'ivs_no' => $parms['ivsno'], 'msg_code' => 9));
  536. // [acer] cmd:102 離場車辨成功流程 END
  537. }
  538. else
  539. {
  540. // 臨停字幕
  541. $this->mq_send(MQ_TOPIC_ALTOB, MQ_ALTOB_MSG.",9,{$parms['ivsno']},{$parms['lpr']}".MQ_ALTOB_MSG_END_TAG);
  542. // [acer] cmd:102 離場車辨成功流程 START
  543. $this->call_acer('102', array('cario_no' => $rows_cario['cario_no'], 'ivs_no' => $parms['ivsno'], 'msg_code' => 9));
  544. // [acer] cmd:102 離場車辨成功流程 END
  545. }
  546. }
  547. else
  548. {
  549. // 臨停字幕
  550. $this->mq_send(MQ_TOPIC_ALTOB, MQ_ALTOB_MSG.",9,{$parms['ivsno']},{$parms['lpr']}".MQ_ALTOB_MSG_END_TAG);
  551. // [acer] cmd:102 離場車辨成功流程 START
  552. $this->call_acer('102', array('cario_no' => $rows_cario['cario_no'], 'ivs_no' => $parms['ivsno'], 'msg_code' => 9));
  553. // [acer] cmd:102 離場車辨成功流程 END
  554. }
  555. }
  556. else
  557. {
  558. $data = array
  559. (
  560. 'out_time' => $this->now_str,
  561. 'out_lane' => $parms['ivsno'],
  562. 'minutes' => $co_time_minutes,
  563. 'out_pic_name' => $parms['pic_name']
  564. );
  565. $this->db->update('cario', $data, array('cario_no' => $rows_cario['cario_no'])); // 記錄出場
  566. trigger_error("{$parms['lpr']}|其它付款方式:" . print_r($rows_cario, true));
  567. // 傳送離場記錄
  568. $sync_agent = new AltobSyncAgent();
  569. $sync_agent->init($parms['sno'], $this->now_str);
  570. $sync_agent->cario_no = $rows_cario['cario_no']; // 進出編號
  571. $sync_agent->in_time = $rows_cario['in_time']; // 入場時間
  572. $sync_result = $sync_agent->sync_st_out($parms);
  573. trigger_error( "..sync_st_out.." . $sync_result);
  574. // [mitac] 要求 mitac 扣款 START
  575. $this->call_mitac_pay($parms['lpr'], $parms['ivsno'], $rows_cario);
  576. // [mitac] 要求 mitac 扣款 END
  577. }
  578. break;
  579. }
  580. }
  581. else if ($rows['member_no'] != 0)
  582. {
  583. // CO.Z.1 月租車無入場資料
  584. if($opendoor)
  585. {
  586. // 會員開門
  587. $this->member_opendoors($parms);
  588. // 會員字幕
  589. $this->mq_send(MQ_TOPIC_ALTOB, MQ_ALTOB_MSG.",10,{$parms['ivsno']},{$parms['lpr']}".MQ_ALTOB_MSG_END_TAG);
  590. // $this->mq_send(MQ_TOPIC_SUBTEXT, "{$parms['ivsno']},{$msg}月租戶請離場謝謝光臨");
  591. // [acer] cmd:102 離場車辨成功流程 START
  592. $this->call_acer('102', array('cario_no' => $rows_cario['cario_no'], 'ivs_no' => $parms['ivsno'], 'msg_code' => 10));
  593. // [acer] cmd:102 離場車辨成功流程 END
  594. }
  595. else
  596. {
  597. trigger_error('月租車無入場資料:' . print_r($rows, true));
  598. // 傳送離場記錄
  599. $sync_agent = new AltobSyncAgent();
  600. $sync_agent->init($parms['sno'], $this->now_str);
  601. $sync_agent->member_no = $rows['member_no']; // 會員編號
  602. $sync_agent->finished = 1; // 已離場
  603. $sync_result = $sync_agent->sync_st_out($parms);
  604. trigger_error( "..sync_st_out.." . $sync_result);
  605. }
  606. }
  607. else
  608. {
  609. // CO.Z.Z 無入場資料
  610. if($opendoor)
  611. {
  612. $this->mq_send(MQ_TOPIC_ALTOB, MQ_ALTOB_MSG.",13,{$parms['ivsno']},{$parms['lpr']}".MQ_ALTOB_MSG_END_TAG);
  613. // [acer] cmd:102 離場車辨成功流程 START
  614. $this->call_acer('102', array('cario_no' => 0, 'ivs_no' => $parms['ivsno'], 'msg_code' => 13));
  615. // [acer] cmd:102 離場車辨成功流程 END
  616. }
  617. else
  618. {
  619. trigger_error('無入場資料:' . print_r($rows, true));
  620. // 傳送離場記錄
  621. $sync_agent = new AltobSyncAgent();
  622. $sync_agent->init($parms['sno'], $this->now_str);
  623. $sync_result = $sync_agent->sync_st_out($parms);
  624. trigger_error( "..sync_st_out.." . $sync_result);
  625. }
  626. }
  627. break;
  628. }
  629. }
  630. // 檢查是否合法會員或VIP資料
  631. public function get_member($lpr)
  632. {
  633. $where_arr = array
  634. (
  635. 'c.lpr' => $lpr,
  636. 'c.start_time <=' => $this->now_str,
  637. 'c.end_time >=' => $this->now_str
  638. );
  639. $sql = "select
  640. c.lpr_correct,
  641. c.member_no,
  642. m.member_name,
  643. m.member_type,
  644. m.locked,
  645. m.remarks,
  646. m.park_time,
  647. m.suspended,
  648. m.valid_time,
  649. c.etag,
  650. c.start_time,
  651. c.end_time
  652. from member_car c, members m
  653. where c.member_no = m.member_no
  654. and c.start_time <= '{$this->now_str}'
  655. and c.end_time >= '{$this->now_str}'
  656. and c.lpr = '{$lpr}'
  657. limit 1";
  658. $rows = $this->db->query($sql)->row_array();
  659. // 新增 park_time_check 2016/11/11
  660. $park_time_check = 0;
  661. if (!empty($rows['lpr_correct']))
  662. {
  663. $park_time = $rows['park_time'];
  664. $pt_arr = $this->vars['mcache']->get('pt');
  665. if(empty($pt_arr) || empty($park_time))
  666. {
  667. // ERROR: 無法驗証時段, 跳過時段限制判斷
  668. trigger_error("[ERROR] mcache.pt is empty !!");
  669. $park_time_check = 1;
  670. }
  671. else
  672. {
  673. $now_time = substr($this->now_str, 11); // 日期字串只取最後時間字串(13:25:32)
  674. $week_no = date('w',strtotime($this->now_str)); // 取星期幾
  675. $park_time_array = explode(',', $park_time); // 用 , 格開
  676. foreach($park_time_array as $idx => $park_time_value)
  677. {
  678. foreach($pt_arr[$park_time_value]['timex'] as $idx => $pt_rows)
  679. {
  680. if ($week_no >= $pt_rows['w_start'] &&
  681. $week_no <= $pt_rows['w_end'] &&
  682. $now_time >= $pt_rows['time_start'] &&
  683. $now_time <= $pt_rows['time_end'])
  684. {
  685. $park_time_check = 2;
  686. trigger_error("時段代碼:{$park_time_value} 星期:{$week_no}");
  687. break;
  688. }
  689. }
  690. }
  691. }
  692. }
  693. if (empty($rows['lpr_correct'])) // A. 非月租車
  694. {
  695. $rows = array
  696. (
  697. 'lpr_correct' => '',
  698. 'member_no' => 0,
  699. 'member_name' => '',
  700. 'member_type' => 9,
  701. 'etag' => '',
  702. 'start_time' => '',
  703. 'end_time' => '',
  704. );
  705. }
  706. else if(empty($park_time_check)) // B. 月租車, 時段無效
  707. {
  708. trigger_error("無效的時段!! " . print_r($rows, true));
  709. $rows = array
  710. (
  711. 'lpr_correct' => '',
  712. 'member_no' => 0,
  713. 'member_name' => '',
  714. 'member_type' => 9,
  715. 'etag' => '',
  716. 'start_time' => '',
  717. 'end_time' => '',
  718. );
  719. }
  720. else if(!empty($rows['suspended'])) // C. 月租車, 停權中
  721. {
  722. trigger_error("停權中!! " . print_r($rows, true));
  723. $rows = array
  724. (
  725. 'lpr_correct' => '',
  726. 'member_no' => 0,
  727. 'member_name' => '',
  728. 'member_type' => 9,
  729. 'etag' => '',
  730. 'start_time' => '',
  731. 'end_time' => '',
  732. );
  733. }
  734. else if(!empty($rows['valid_time']) && $rows['valid_time'] < $this->now_str) // D. 月租車, 已無效 (審核未通過)
  735. {
  736. trigger_error("已無效!! " . print_r($rows, true));
  737. $rows = array
  738. (
  739. 'lpr_correct' => '',
  740. 'member_no' => 0,
  741. 'member_name' => '',
  742. 'member_type' => 9,
  743. 'etag' => '',
  744. 'start_time' => '',
  745. 'end_time' => '',
  746. );
  747. }
  748. trigger_error('讀取會員:' . print_r($rows, true) . ", park_time_check: {$park_time_check}");
  749. // 20171025 強制先不導入會員
  750. $rows = array
  751. (
  752. 'lpr_correct' => '',
  753. 'member_no' => 0,
  754. 'member_name' => '',
  755. 'member_type' => 9,
  756. 'etag' => '',
  757. 'start_time' => '',
  758. 'end_time' => '',
  759. );
  760. trigger_error(__FUNCTION__ . '..force not found..');
  761. return $rows;
  762. }
  763. /*
  764. // 開門 (月租)
  765. public function member_opendoors($parms)
  766. {
  767. $this->mq_send(MQ_TOPIC_OPEN_DOOR, "DO{$parms['ivsno']},OPEN,{$parms['lpr']}");
  768. return true;
  769. }
  770. // 開門 (臨停)
  771. public function temp_opendoors($parms)
  772. {
  773. $this->mq_send(MQ_TOPIC_OPEN_DOOR, "DO{$parms['ivsno']},TICKET,{$parms['lpr']}");
  774. return true;
  775. }
  776. */
  777. // 用eTag讀出車號
  778. public function etag2lpr_2($etag)
  779. {
  780. // 用讀取eTag記錄(有double驗證過)
  781. $rows = $this->db->select('lpr')
  782. ->from('etag_lpr')
  783. ->where(array('etag' => $etag, 'confirms >' => 0))
  784. ->limit(1)
  785. ->get()
  786. ->row_array();
  787. // 讀出eTag資料
  788. if (!empty($rows['lpr']))
  789. {
  790. trigger_error("+++車牌NONE,以eTag讀入車牌:{$etag}|{$rows['lpr']}");
  791. return $rows['lpr'];
  792. }
  793. return 'NONE';
  794. }
  795. // 有車牌與eTag, 檢查資料庫 (2017/03/22 new)
  796. public function check_lpr_etag($lpr, $etag)
  797. {
  798. $ETAG_LOG_TITLE = 'etag://';
  799. $ETAG_WARMIN_TITLE = 'etag-warning://';
  800. trigger_error($ETAG_LOG_TITLE. "輸入: {$lpr},{$etag}");
  801. // 手動值上下限
  802. $max_admin_confirms_value = 99;
  803. $min_admin_confirms_value = 50;
  804. // 自動值上下限
  805. $max_system_confirms_value = 33;
  806. $min_system_confirms_value = 0;
  807. // 判斷對應加權
  808. $etag_confirms_bias_plus = 11; // etag 找 車牌, 對上一次可扺 11次
  809. $etag_confirms_bias_minus = -1;
  810. $lpr_confirms_bias_plus = 3; // 車牌 找 etag, 對上一次可扺 3次
  811. $lpr_confirms_bias_minus = -1;
  812. // eTag 找 車牌
  813. $lpr_info_from_etag = $this->db->select('lpr, confirms')
  814. ->from('etag_lpr')
  815. ->where(array('etag' => $etag))
  816. ->limit(1)
  817. ->get()
  818. ->row_array();
  819. if (!empty($lpr_info_from_etag['lpr']))
  820. {
  821. // B. etag 有找到 車牌
  822. if ($lpr_info_from_etag['lpr'] == $lpr)
  823. {
  824. // B.1. etag 有找到 車牌, 且 車牌 相符, confirms 上升
  825. $confirms_bias = $etag_confirms_bias_plus;
  826. }
  827. else
  828. {
  829. // B.2. etag 有找到 車牌, 但 車牌 不符, confirms 下降
  830. $confirms_bias = $etag_confirms_bias_minus;
  831. trigger_error($ETAG_WARMIN_TITLE . "etag 找 lpr | lpr error : {$lpr},{$etag} | query:" . print_r($lpr_info_from_etag, true));
  832. }
  833. $next_confirms_value = $lpr_info_from_etag['confirms'] + $confirms_bias;
  834. trigger_error($ETAG_LOG_TITLE . "etag 找 lpr | {$lpr},{$etag}, next_confirms: {$next_confirms_value}, bias:{$confirms_bias}");
  835. // 更新 confirms 資訊
  836. if($next_confirms_value > $max_admin_confirms_value)
  837. {
  838. // B.3.0 confirms 超過 max_admin_confirms_value, skip
  839. //trigger_error($ETAG_LOG_TITLE . "etag 找 lpr | {$lpr},{$etag} next_confirms_value > max_admin_confirms_value : {$max_admin_confirms_value}");
  840. }
  841. else if ($next_confirms_value >= $min_admin_confirms_value)
  842. {
  843. // B.3.1 人工確認過的記錄, 誤判多次後會停留在 min_admin_confirms_value, 或加到 max_admin_confirms_value
  844. $this->db->where('etag', $etag)->update('etag_lpr', array('confirms' => $next_confirms_value));
  845. }
  846. else if ($next_confirms_value > $max_system_confirms_value)
  847. {
  848. // B.3.2 confirms 超過 max_system_confirms_value, skip
  849. //trigger_error($ETAG_LOG_TITLE . "etag 找 lpr | {$lpr},{$etag} next_confirms_value > max_system_confirms_value : {$max_system_confirms_value}");
  850. }
  851. else if ($next_confirms_value <= $max_system_confirms_value && $next_confirms_value >= $min_system_confirms_value)
  852. {
  853. // B.3.3 confirms 不到 max_system_confirms_value 為系統生成記錄, 誤判多次後 confirms 會扣到 min_system_confirms_value
  854. $this->db->where('etag', $etag)->update('etag_lpr', array('confirms' => $next_confirms_value));
  855. }
  856. else
  857. {
  858. // B.3.4 若低於 min_system_confirms_value,刪除
  859. $this->db->delete('etag_lpr', array('etag' => $etag));
  860. trigger_error($ETAG_LOG_TITLE . "etag 找 lpr | etag confirms fail and removed : {$lpr_info_from_etag['lpr']}, {$etag}");
  861. trigger_error($ETAG_WARMIN_TITLE . "etag 找 lpr | etag confirms fail and removed : {$lpr_info_from_etag['lpr']}, {$etag}");
  862. }
  863. }
  864. else
  865. {
  866. // 車牌 找 etag
  867. $etag_info_form_lpr = $this->db->select('etag, confirms, member_no')
  868. ->from('etag_lpr')
  869. ->where(array('lpr' => $lpr))
  870. ->limit(1)
  871. ->get()
  872. ->row_array();
  873. if (!empty($etag_info_form_lpr['etag']))
  874. {
  875. // A. 車牌 有找到 etag
  876. if ($etag_info_form_lpr['etag'] == $etag)
  877. {
  878. // A.1. 車牌 有找到 etag, 且 etag 相符, confirms 上升
  879. $confirms_bias = $lpr_confirms_bias_plus;
  880. // 若尚未登記為會員
  881. if(empty($etag_info_form_lpr['member_no']))
  882. {
  883. // 檢查是否會員
  884. $member_info_from_lpr = $this->db->select('member_no, member_name')
  885. ->from('members')
  886. ->where(array('lpr' => $lpr))
  887. ->limit(1)
  888. ->get()
  889. ->row_array();
  890. // 確認為會員, 建立 eTag 資訊
  891. if (!empty($member_info_from_lpr['member_no']))
  892. {
  893. $data['member_no'] = $member_info_from_lpr['member_no'];
  894. $data['member_name'] = $member_info_from_lpr['member_name'];
  895. $this->db->where('member_no', $member_info_from_lpr['member_no'])->update('member_car', array('etag' => $etag));
  896. $this->db->where('member_no', $member_info_from_lpr['member_no'])->update('members', array('etag' => $etag));
  897. // 更新 etag_lpr
  898. $this->db->where('etag', $etag)->update('etag_lpr', $data);
  899. }
  900. }
  901. }
  902. else
  903. {
  904. // A.2. 車牌 有找到 etag, 但 etag 不符, confirms 下降
  905. $confirms_bias = $lpr_confirms_bias_minus;
  906. trigger_error($ETAG_WARMIN_TITLE . "lpr 找 etag | etag error : {$lpr},{$etag} | query:" . print_r($etag_info_form_lpr, true));
  907. }
  908. $next_confirms_value = $lpr_info_from_etag['confirms'] + $confirms_bias;
  909. trigger_error($ETAG_LOG_TITLE . "lpr 找 etag | {$lpr},{$etag}, next_confirms: {$next_confirms_value}, bias:{$confirms_bias}");
  910. // 更新 confirms 資訊
  911. if($next_confirms_value > $max_admin_confirms_value)
  912. {
  913. // A.3.0 confirms 超過 max_admin_confirms_value, skip
  914. //trigger_error($ETAG_LOG_TITLE . "lpr 找 etag | {$lpr},{$etag} next_confirms_value > max_admin_confirms_value : {$max_admin_confirms_value}");
  915. }
  916. else if ($next_confirms_value >= $min_admin_confirms_value)
  917. {
  918. // A.3.1 人工確認過的記錄, 誤判多次後會停留在 min_admin_confirms_value, 或加到 max_admin_confirms_value
  919. $this->db->where('lpr', $lpr)->update('etag_lpr', array('confirms' => $next_confirms_value));
  920. }
  921. else if ($next_confirms_value > $max_system_confirms_value)
  922. {
  923. // A.3.2 confirms 超過 max_system_confirms_value, skip
  924. //trigger_error($ETAG_LOG_TITLE . "lpr 找 etag | {$lpr},{$etag} next_confirms_value > max_system_confirms_value : {$max_system_confirms_value}");
  925. }
  926. else if ($next_confirms_value <= $max_system_confirms_value && $next_confirms_value >= $min_system_confirms_value)
  927. {
  928. // A.3.3 confirms 不到 max_system_confirms_value 為系統生成記錄, 誤判多次後 confirms 會扣到 min_system_confirms_value
  929. $this->db->where('lpr', $lpr)->update('etag_lpr', array('confirms' => $next_confirms_value));
  930. }
  931. else
  932. {
  933. // A.3.4 若低於 min_system_confirms_value,刪除
  934. $this->db->delete('etag_lpr', array('lpr' => $lpr));
  935. trigger_error($ETAG_LOG_TITLE . "lpr 找 etag | lpr confirms fail and removed : {$lpr}, {$etag_info_form_lpr['etag']}");
  936. trigger_error($ETAG_WARMIN_TITLE . "lpr 找 etag | lpr confirms fail and removed : {$lpr}, {$etag_info_form_lpr['etag']}");
  937. }
  938. }
  939. else
  940. {
  941. // C. 車牌 與 etag 都找不到記錄
  942. $data = array
  943. (
  944. 'lpr' => $lpr,
  945. 'lpr_correct' => $lpr,
  946. 'etag' => $etag
  947. );
  948. // 檢查是否會員
  949. $member_info_from_lpr = $this->db->select('member_no, member_name')
  950. ->from('members')
  951. ->where(array('lpr' => $lpr))
  952. ->limit(1)
  953. ->get()
  954. ->row_array();
  955. // 會員者, 將eTag update回去
  956. if (!empty($member_info_from_lpr['member_no']))
  957. {
  958. $data['member_no'] = $member_info_from_lpr['member_no'];
  959. $data['member_name'] = $member_info_from_lpr['member_name'];
  960. $this->db->where('member_no', $member_info_from_lpr['member_no'])->update('member_car', array('etag' => $etag));
  961. $this->db->where('member_no', $member_info_from_lpr['member_no'])->update('members', array('etag' => $etag));
  962. }
  963. // 建立第一筆記錄
  964. $this->db->insert('etag_lpr', $data);
  965. $etag_lpr_seqno = $this->db->insert_id();
  966. trigger_error($ETAG_LOG_TITLE . "create | insert seqno = {$etag_lpr_seqno}". print_r($data, true));
  967. }
  968. }
  969. }
  970. /*
  971. // 有車牌與eTag, 檢查資料庫
  972. public function check_lpr_etag($lpr, $etag)
  973. {
  974. // 用讀取eTag記錄(有double驗證過)
  975. $rows = $this->db->select('etag, confirms')
  976. ->from('etag_lpr')
  977. ->where(array('lpr' => $lpr))
  978. ->limit(1)
  979. ->get()
  980. ->row_array();
  981. // 讀出eTag資料
  982. if (!empty($rows['etag']))
  983. {
  984. // 車牌與eTag皆相符, 檢查是否confirms欄位若為0, 設成1(double驗證)
  985. if ($rows['etag'] == $etag)
  986. {
  987. if ($rows['confirms'] == 0) $this->db->where('lpr', $lpr)->update('etag_lpr', array('confirms' => 1));
  988. }
  989. else // eTag不相符
  990. {
  991. if ($rows['confirms'] == 1)
  992. {
  993. $this->db->where('lpr', $lpr)->update('etag_lpr', array('confirms' => 0));
  994. }
  995. else // 原confirms為0者, 刪除之
  996. {
  997. $this->db->delete('etag_lpr', array('lpr' => $lpr));
  998. }
  999. }
  1000. }
  1001. else // 無資料, 新增一筆
  1002. {
  1003. // 再檢查一次是否有eTag ?
  1004. $rows_etag = $this->db->select('lpr, confirms')
  1005. ->from('etag_lpr')
  1006. ->where(array('etag' => $etag))
  1007. ->limit(1)
  1008. ->get()
  1009. ->row_array();
  1010. if (empty($rows_etag['lpr'])) // 無資料
  1011. {
  1012. $data = array
  1013. (
  1014. 'lpr' => $lpr,
  1015. 'lpr_correct' => $lpr,
  1016. 'etag' => $etag
  1017. );
  1018. // 檢查是否會員
  1019. $rows_members = $this->db->select('member_no, member_name')
  1020. ->from('members')
  1021. ->where(array('lpr' => $lpr))
  1022. ->limit(1)
  1023. ->get()
  1024. ->row_array();
  1025. // 會員者, 將eTag update回去
  1026. if (!empty($rows_members['member_no']))
  1027. {
  1028. $data['member_no'] = $rows_members['member_no'];
  1029. $data['member_name'] = $rows_members['member_name'];
  1030. $this->db->where('member_no', $rows_members['member_no'])->update('member_car', array('etag' => $etag));
  1031. $this->db->where('member_no', $rows_members['member_no'])->update('members', array('etag' => $etag));
  1032. }
  1033. $this->db->insert('etag_lpr', $data);
  1034. }
  1035. else
  1036. {
  1037. if ($rows_etag['confirms'] == 1)
  1038. {
  1039. $this->db->where('etag', $etag)->update('etag_lpr', array('confirms' => 0));
  1040. }
  1041. else // 原confirms為0者, 刪除之
  1042. {
  1043. $this->db->delete('etag_lpr', array('etag' => $etag));
  1044. }
  1045. }
  1046. }
  1047. }
  1048. */
  1049. // 送出至message queue(目前用mqtt)
  1050. public function mq_send($topic, $msg)
  1051. {
  1052. $this->vars['mqtt']->publish($topic, $msg, 0);
  1053. trigger_error("mqtt:{$topic}|{$msg}");
  1054. }
  1055. // 產生 CK
  1056. public function gen_opendoor_ck($parms, $function_name)
  1057. {
  1058. return md5($parms['ivsno']. 'alt' . date('dmh') . 'o' . $parms['lpr'] . 'b' . $function_name);
  1059. }
  1060. // 開門 (月租)
  1061. public function member_opendoors($parms)
  1062. {
  1063. //$this->mq_send_opendoor(MQ_TOPIC_OPEN_DOOR, "DO{$parms['ivsno']},OPEN,{$parms['lpr']}");
  1064. $ck = $this->gen_opendoor_ck($parms, __FUNCTION__);
  1065. get_headers("http://localhost/cars.html/" . __FUNCTION__ . "/{$parms['ivsno']}/{$parms['lpr']}/{$ck}");
  1066. return true;
  1067. }
  1068. // 開門 (臨停)
  1069. public function temp_opendoors($parms)
  1070. {
  1071. //$this->mq_send_opendoor(MQ_TOPIC_OPEN_DOOR, "DO{$parms['ivsno']},TICKET,{$parms['lpr']}");
  1072. $ck = $this->gen_opendoor_ck($parms, __FUNCTION__);
  1073. get_headers("http://localhost/cars.html/" . __FUNCTION__ ."/{$parms['ivsno']}/{$parms['lpr']}/{$ck}");
  1074. return true;
  1075. }
  1076. // 開門 (月租)
  1077. public function do_member_opendoor($parms)
  1078. {
  1079. if($parms['ck'] != $this->gen_opendoor_ck($parms, 'member_opendoors'))
  1080. {
  1081. return 'ck_error'; // 中斷
  1082. }
  1083. $this->mq_send(MQ_TOPIC_OPEN_DOOR, "DO{$parms['ivsno']},OPEN,{$parms['lpr']}");
  1084. return 'ok';
  1085. }
  1086. // 開門 (臨停)
  1087. public function do_temp_opendoor($parms)
  1088. {
  1089. if($parms['ck'] != $this->gen_opendoor_ck($parms, 'temp_opendoors'))
  1090. {
  1091. return 'ck_error'; // 中斷
  1092. }
  1093. $this->mq_send(MQ_TOPIC_OPEN_DOOR, "DO{$parms['ivsno']},TICKET,{$parms['lpr']}");
  1094. return 'ok';
  1095. }
  1096. // 指派車位
  1097. // http://203.75.167.89/parkingquery.html/get_valid_seat
  1098. // 註記現在時間, 並保留10分鐘
  1099. public function get_valid_seat()
  1100. {
  1101. $data = array();
  1102. //$data['result']['location_no'] = '0';
  1103. //$data['result_code'] = 'FAIL';
  1104. //return $data;
  1105. // 撈 roger db
  1106. /*
  1107. $sql = "
  1108. SELECT ParkingNum AS pksno FROM table_carpark
  1109. WHERE LPR = '' AND DisableSeat = 0 AND
  1110. (SELECT COUNT(*) FROM table_carpark WHERE LPR = '' AND DisableSeat = 0) <= 10
  1111. ORDER BY RAND() LIMIT 1 FOR UPDATE;
  1112. ";
  1113. $dsn_old_db = $this->load->database('old_db', true);
  1114. // 2016/12/14 roger_db 掛了的可能
  1115. if ($dsn_old_db->initialize())
  1116. {
  1117. $retults = $dsn_old_db->query($sql)->result_array();
  1118. }
  1119. if(!empty($retults[0]))
  1120. {
  1121. $data['result']['location_no'] = substr($retults[0]['pksno'], 1);
  1122. $data['result_code'] = 'OK';
  1123. $data['loc_name'] = 'B'.substr($retults[0]['pksno'], 0, 1);
  1124. $data['floors'] = 'B'.substr($retults[0]['pksno'], 0, 1);
  1125. }
  1126. else
  1127. {
  1128. $data['result']['location_no'] = '0';
  1129. $data['result_code'] = 'FAIL';
  1130. }
  1131. */
  1132. $this->db->trans_start();
  1133. $sql = "select pksno from pks where status = 'VA' and prioritys != 0 and (book_time is null or book_time <= now()) order by prioritys asc limit 1 for update;";
  1134. $rows = $this->db->query($sql)->row_array();
  1135. if (!empty($rows['pksno']))
  1136. {
  1137. $data['result']['location_no'] = substr($rows['pksno'], -3);
  1138. $data['result_code'] = 'OK';
  1139. $sql = "update pks set book_time = addtime(now(), '00:10:00') where pksno = {$rows['pksno']};";
  1140. $this->db->query($sql);
  1141. $sql = "select g.group_name, g.floors from pks_groups g, pks_group_member m where m.pksno = {$rows['pksno']} and g.group_id = m.group_id and g.group_type = 1 limit 1";
  1142. $rows = $this->db->query($sql)->row_array();
  1143. $data['loc_name'] = $rows['group_name'];
  1144. $data['floors'] = $rows['floors'];
  1145. }
  1146. else
  1147. {
  1148. $data['result']['location_no'] = '0';
  1149. $data['result_code'] = 'FAIL';
  1150. }
  1151. $this->db->trans_complete();
  1152. return $data;
  1153. }
  1154. // 取得出入口 888 資訊
  1155. public function get_888_info($parms)
  1156. {
  1157. $data = array();
  1158. $sql = "select availables as availables, tot as tot from pks_groups where group_id = 'C888' and station_no = {$parms['sno']}";
  1159. $rows = $this->db->query($sql)->row_array();
  1160. if (!empty($rows) && array_key_exists('availables', $rows))
  1161. {
  1162. $data['result_code'] = 'OK';
  1163. $data['availables'] = $rows['availables'];
  1164. $data['tot'] = $rows['tot'];
  1165. }
  1166. else
  1167. {
  1168. trigger_error(__FUNCTION__ . "..not found..".print_r($parms, true));
  1169. $data['result_code'] = 'FAIL';
  1170. $data['availables'] = 9999; // 如果拿不到就忽略這個流程
  1171. $data['tot'] = 0;
  1172. }
  1173. return $data;
  1174. }
  1175. // ===============================================
  1176. // acer cmd
  1177. // ===============================================
  1178. // 產生通行碼
  1179. function gen_pass_code()
  1180. {
  1181. return rand(100000,999999);
  1182. }
  1183. // 呼叫acer
  1184. function call_acer($cmd, $parms)
  1185. {
  1186. return false; // 尚未啟用
  1187. try{
  1188. $ch = curl_init();
  1189. curl_setopt($ch, CURLOPT_URL, 'http://localhost/acer_service.html/cmd_'. $cmd);
  1190. curl_setopt($ch, CURLOPT_HEADER, FALSE);
  1191. curl_setopt($ch, CURLOPT_RETURNTRANSFER, TRUE);
  1192. curl_setopt($ch, CURLOPT_SSL_VERIFYPEER, FALSE);
  1193. curl_setopt($ch, CURLOPT_POST, TRUE);
  1194. curl_setopt($ch, CURLOPT_CONNECTTIMEOUT ,3);
  1195. curl_setopt($ch, CURLOPT_TIMEOUT, 3); //timeout in seconds
  1196. curl_setopt($ch, CURLOPT_POSTFIELDS, http_build_query($parms));
  1197. $data = curl_exec($ch);
  1198. if(curl_errno($ch))
  1199. {
  1200. trigger_error(__FUNCTION__ . ', curl error: '. curl_error($ch));
  1201. }
  1202. curl_close($ch);
  1203. trigger_error(__FUNCTION__ . '..'. $data);
  1204. }catch (Exception $e){
  1205. trigger_error(__FUNCTION__ . 'error:'.$e->getMessage());
  1206. }
  1207. }
  1208. // ===============================================
  1209. // mitac cmd
  1210. // ===============================================
  1211. // 要求 mitac 扣款
  1212. function call_mitac_pay($lpr, $ivsno, $rows_cario)
  1213. {
  1214. $function_name = 'parking_fee_altob';
  1215. $seqno = $rows_cario['cario_no'];
  1216. $lpr = $lpr;
  1217. $in_time = $rows_cario['out_before_time'];
  1218. $out_time = $this->now_str;
  1219. $gate_id = $ivsno;
  1220. // 通訊內容
  1221. $parms = array(
  1222. 'seqno' => $seqno,
  1223. 'lpr' => $lpr,
  1224. 'in_time' => $in_time,
  1225. 'out_time' => $out_time,
  1226. 'gate_id' => $gate_id);
  1227. // 驗証碼
  1228. $parms['ck'] = md5($parms['seqno']. 'a' . date('dmh') . 'l' . $parms['lpr'] . 't'. $parms['in_time']. 'o'. $parms['out_time'] . 'b'. $parms['gate_id'] . $function_name);
  1229. // 呼叫
  1230. try{
  1231. $ch = curl_init();
  1232. curl_setopt($ch, CURLOPT_URL, "http://localhost/mitac_service.html/{$function_name}");
  1233. curl_setopt($ch, CURLOPT_HEADER, FALSE);
  1234. curl_setopt($ch, CURLOPT_RETURNTRANSFER, TRUE);
  1235. curl_setopt($ch, CURLOPT_SSL_VERIFYPEER, FALSE);
  1236. curl_setopt($ch, CURLOPT_POST, TRUE);
  1237. curl_setopt($ch, CURLOPT_CONNECTTIMEOUT ,3);
  1238. curl_setopt($ch, CURLOPT_TIMEOUT, 3); //timeout in seconds
  1239. curl_setopt($ch, CURLOPT_POSTFIELDS, http_build_query($parms));
  1240. $data = curl_exec($ch);
  1241. if(curl_errno($ch))
  1242. {
  1243. trigger_error(__FUNCTION__ . ', curl error: '. curl_error($ch));
  1244. }
  1245. curl_close($ch);
  1246. trigger_error(__FUNCTION__ . '..'. $data);
  1247. }catch (Exception $e){
  1248. trigger_error(__FUNCTION__ . 'error:'.$e->getMessage());
  1249. }
  1250. }
  1251. }