VM暫存
Вы не можете выбрать более 25 тем Темы должны начинаться с буквы или цифры, могут содержать дефисы(-) и должны содержать не более 35 символов.

1676 строки
55KB

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