VM暫存
Nelze vybrat více než 25 témat Téma musí začínat písmenem nebo číslem, může obsahovat pomlčky („-“) a může být dlouhé až 35 znaků.

Cars_model.php 50KB

před 8 roky
před 8 roky
před 8 roky
před 8 roky
před 8 roky
před 8 roky
před 8 roky
před 8 roky
před 8 roky
před 8 roky
před 8 roky
před 8 roky
před 8 roky
před 8 roky
před 8 roky
před 8 roky
před 8 roky
před 8 roky
před 8 roky
před 8 roky
před 8 roky
před 8 roky
před 8 roky
před 8 roky
před 8 roky
před 8 roky
před 8 roky
před 8 roky
před 8 roky
před 8 roky
před 8 roky
před 8 roky
před 8 roky
před 8 roky
před 8 roky
před 8 roky
před 8 roky
před 8 roky
před 8 roky
před 8 roky
před 8 roky
před 8 roky
před 8 roky
před 8 roky
před 8 roky
před 8 roky
před 8 roky
před 8 roky
před 8 roky
před 8 roky
12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788899091929394959697989910010110210310410510610710810911011111211311411511611711811912012112212312412512612712812913013113213313413513613713813914014114214314414514614714814915015115215315415515615715815916016116216316416516616716816917017117217317417517617717817918018118218318418518618718818919019119219319419519619719819920020120220320420520620720820921021121221321421521621721821922022122222322422522622722822923023123223323423523623723823924024124224324424524624724824925025125225325425525625725825926026126226326426526626726826927027127227327427527627727827928028128228328428528628728828929029129229329429529629729829930030130230330430530630730830931031131231331431531631731831932032132232332432532632732832933033133233333433533633733833934034134234334434534634734834935035135235335435535635735835936036136236336436536636736836937037137237337437537637737837938038138238338438538638738838939039139239339439539639739839940040140240340440540640740840941041141241341441541641741841942042142242342442542642742842943043143243343443543643743843944044144244344444544644744844945045145245345445545645745845946046146246346446546646746846947047147247347447547647747847948048148248348448548648748848949049149249349449549649749849950050150250350450550650750850951051151251351451551651751851952052152252352452552652752852953053153253353453553653753853954054154254354454554654754854955055155255355455555655755855956056156256356456556656756856957057157257357457557657757857958058158258358458558658758858959059159259359459559659759859960060160260360460560660760860961061161261361461561661761861962062162262362462562662762862963063163263363463563663763863964064164264364464564664764864965065165265365465565665765865966066166266366466566666766866967067167267367467567667767867968068168268368468568668768868969069169269369469569669769869970070170270370470570670770870971071171271371471571671771871972072172272372472572672772872973073173273373473573673773873974074174274374474574674774874975075175275375475575675775875976076176276376476576676776876977077177277377477577677777877978078178278378478578678778878979079179279379479579679779879980080180280380480580680780880981081181281381481581681781881982082182282382482582682782882983083183283383483583683783883984084184284384484584684784884985085185285385485585685785885986086186286386486586686786886987087187287387487587687787887988088188288388488588688788888989089189289389489589689789889990090190290390490590690790890991091191291391491591691791891992092192292392492592692792892993093193293393493593693793893994094194294394494594694794894995095195295395495595695795895996096196296396496596696796896997097197297397497597697797897998098198298398498598698798898999099199299399499599699799899910001001100210031004100510061007100810091010101110121013101410151016101710181019102010211022102310241025102610271028102910301031103210331034103510361037103810391040104110421043104410451046104710481049105010511052105310541055105610571058105910601061106210631064106510661067106810691070107110721073107410751076107710781079108010811082108310841085108610871088108910901091109210931094109510961097109810991100110111021103110411051106110711081109111011111112111311141115111611171118111911201121112211231124112511261127112811291130113111321133113411351136113711381139114011411142114311441145114611471148114911501151115211531154115511561157115811591160116111621163116411651166116711681169117011711172117311741175117611771178117911801181118211831184118511861187118811891190119111921193119411951196119711981199120012011202120312041205120612071208120912101211121212131214121512161217121812191220122112221223122412251226122712281229123012311232123312341235123612371238123912401241124212431244124512461247124812491250125112521253125412551256125712581259126012611262126312641265126612671268126912701271127212731274127512761277127812791280128112821283128412851286128712881289129012911292129312941295129612971298129913001301130213031304130513061307130813091310131113121313131413151316131713181319132013211322132313241325132613271328132913301331133213331334133513361337133813391340134113421343134413451346134713481349135013511352135313541355135613571358135913601361136213631364136513661367136813691370137113721373137413751376137713781379138013811382138313841385138613871388138913901391139213931394139513961397139813991400140114021403140414051406140714081409141014111412141314141415141614171418
  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. 'out_before_time' => date('Y-m-d H:i:s', strtotime(" + 15 minutes")), // 15分鐘內, 可直接離場
  300. 'ticket_no' => $ticket_no
  301. );
  302. $this->db->insert('cario', $data);
  303. trigger_error("新增入場資料:".print_r($parms, true));
  304. $acer_parms = array
  305. (
  306. 'cario_no' => $this->db->insert_id(),
  307. 'in_time' => $this->now_str,
  308. 'ticket_no' => $ticket_no,
  309. 'lpr' => $parms['lpr'],
  310. 'ivs_no' => $parms['ivsno']
  311. );
  312. $this->call_acer('101', $acer_parms);
  313. // [acer] cmd:101 入場車辨成功流程 END
  314. // 傳送進場記錄
  315. $sync_agent = new AltobSyncAgent();
  316. $sync_agent->init($parms['sno'], $this->now_str);
  317. $sync_agent->cario_no = $this->db->insert_id(); // 進出編號
  318. $sync_agent->member_no = $rows['member_no']; // 會員編號
  319. $sync_result = $sync_agent->sync_st_in($parms);
  320. trigger_error( "..sync_st_in.." . $sync_result);
  321. }
  322. break;
  323. // 出場
  324. case 'CO':
  325. case 'MO':
  326. // 讀取最近一筆入場資料
  327. $rows_cario = $this->db
  328. ->select('cario_no, payed, in_time, pay_time, out_before_time')
  329. ->from('cario')
  330. //->where(array('in_out' => 'CI', 'obj_id' => $parms['lpr'], 'finished' => 0, 'err' => 0))
  331. ->where(array('obj_id' => $parms['lpr'], 'err' => 0))
  332. ->order_by('cario_no', 'desc')
  333. ->limit(1)
  334. ->get()
  335. ->row_array();
  336. trigger_error("opendoor={$opendoor}| 出場讀到資料:{$rows['member_no']}|".time().'|'.print_r($rows_cario, true));
  337. if (!empty($rows_cario['cario_no'])) // 在限時內可出場
  338. {
  339. $co_time_minutes = floor((strtotime($this->now_str) - strtotime($rows_cario['in_time'])) / 60); // 停車時數 (分鐘)
  340. // 合規定者開門放行
  341. switch(true)
  342. {
  343. case $rows['member_no'] != 0:
  344. // CO.A.1 會員車
  345. // 判斷時段租是否超時 (超過 12 小時)
  346. if($rows['park_time'] != 'RE' && $co_time_minutes > 720)
  347. {
  348. if($opendoor)
  349. {
  350. // 時段租超時字幕
  351. $this->mq_send(MQ_TOPIC_ALTOB, MQ_ALTOB_MSG.",16,{$parms['ivsno']},{$parms['lpr']}".MQ_ALTOB_MSG_END_TAG);
  352. // [acer] cmd:102 離場車辨成功流程 START
  353. $this->call_acer('102', array('cario_no' => $rows_cario['cario_no'], 'ivs_no' => $parms['ivsno'], 'msg_code' => 16));
  354. // [acer] cmd:102 離場車辨成功流程 END
  355. }
  356. else
  357. {
  358. $data = array
  359. (
  360. 'out_time' => $this->now_str,
  361. 'out_lane' => $parms['ivsno'],
  362. 'minutes' => $co_time_minutes,
  363. 'out_pic_name' => $parms['pic_name']
  364. );
  365. $this->db->update('cario', $data, array('cario_no' => $rows_cario['cario_no'])); // 記錄出場
  366. trigger_error("{$parms['lpr']}|時段租超時" . print_r($rows_cario, true));
  367. // 傳送離場記錄
  368. $sync_agent = new AltobSyncAgent();
  369. $sync_agent->init($parms['sno'], $this->now_str);
  370. $sync_agent->cario_no = $rows_cario['cario_no']; // 進出編號
  371. $sync_agent->member_no = $rows['member_no']; // 會員編號
  372. $sync_agent->in_time = $rows_cario['in_time']; // 入場時間
  373. $sync_result = $sync_agent->sync_st_out($parms);
  374. trigger_error( "..sync_st_out.." . $sync_result);
  375. }
  376. return false;
  377. }
  378. if($opendoor)
  379. {
  380. // 會員開門
  381. $this->member_opendoors($parms);
  382. // 會員字幕
  383. $this->mq_send(MQ_TOPIC_ALTOB, MQ_ALTOB_MSG.",5,{$parms['ivsno']},{$parms['lpr']}".MQ_ALTOB_MSG_END_TAG);
  384. // $this->mq_send(MQ_TOPIC_SUBTEXT, "{$parms['ivsno']},{$msg}謝謝光臨");
  385. // [acer] cmd:102 離場車辨成功流程 START
  386. $this->call_acer('102', array('cario_no' => $rows_cario['cario_no'], 'ivs_no' => $parms['ivsno'], 'msg_code' => 5));
  387. // [acer] cmd:102 離場車辨成功流程 END
  388. }
  389. else
  390. {
  391. $data = array
  392. (
  393. 'in_out' => $parms['io'],
  394. 'finished' => 1,
  395. 'out_time' => $this->now_str,
  396. 'out_lane' => $parms['ivsno'],
  397. 'minutes' => $co_time_minutes,
  398. 'out_pic_name' => $parms['pic_name']
  399. );
  400. $this->db->update('cario', $data, array('cario_no' => $rows_cario['cario_no']));
  401. trigger_error('會員車離場:' . print_r($rows, true));
  402. // 傳送離場記錄
  403. $sync_agent = new AltobSyncAgent();
  404. $sync_agent->init($parms['sno'], $this->now_str);
  405. $sync_agent->cario_no = $rows_cario['cario_no']; // 進出編號
  406. $sync_agent->member_no = $rows['member_no']; // 會員編號
  407. $sync_agent->in_time = $rows_cario['in_time']; // 入場時間
  408. $sync_agent->finished = 1; // 已離場
  409. $sync_result = $sync_agent->sync_st_out($parms);
  410. trigger_error( "..sync_st_out.." . $sync_result);
  411. }
  412. break;
  413. case strtotime($rows_cario['out_before_time']) >= time():
  414. if ($rows_cario['payed'])
  415. {
  416. // CO.B.1 臨停車已付款
  417. if($opendoor)
  418. {
  419. // 臨停開門
  420. $this->temp_opendoors($parms);
  421. // 臨停字幕
  422. $this->mq_send(MQ_TOPIC_ALTOB, MQ_ALTOB_MSG.",6,{$parms['ivsno']},{$parms['lpr']}".MQ_ALTOB_MSG_END_TAG);
  423. //// $this->mq_send(MQ_TOPIC_SUBTEXT, "{$parms['ivsno']},{$msg}付款確認請 離 場謝謝光臨");
  424. // $this->mq_send(MQ_TOPIC_SUBTEXT, "{$parms['ivsno']},{$msg}謝謝光臨");
  425. // [acer] cmd:102 離場車辨成功流程 START
  426. $this->call_acer('102', array('cario_no' => $rows_cario['cario_no'], 'ivs_no' => $parms['ivsno'], 'msg_code' => 6));
  427. // [acer] cmd:102 離場車辨成功流程 END
  428. }
  429. else
  430. {
  431. $data = array
  432. (
  433. 'in_out' => $parms['io'],
  434. 'finished' => 1,
  435. 'out_time' => $this->now_str,
  436. 'out_lane' => $parms['ivsno'],
  437. 'minutes' => $co_time_minutes,
  438. 'out_pic_name' => $parms['pic_name']
  439. );
  440. $this->db->update('cario', $data, array('cario_no' => $rows_cario['cario_no']));
  441. trigger_error('臨停車已付款:' . print_r($rows, true));
  442. // 傳送離場記錄
  443. $sync_agent = new AltobSyncAgent();
  444. $sync_agent->init($parms['sno'], $this->now_str);
  445. $sync_agent->cario_no = $rows_cario['cario_no']; // 進出編號
  446. $sync_agent->in_time = $rows_cario['in_time']; // 入場時間
  447. $sync_agent->finished = 1; // 已離場
  448. $sync_result = $sync_agent->sync_st_out($parms);
  449. trigger_error( "..sync_st_out.." . $sync_result);
  450. }
  451. }
  452. else
  453. {
  454. // CO.B.2 臨停車未付款
  455. if($opendoor)
  456. {
  457. // 臨停字幕
  458. $this->mq_send(MQ_TOPIC_ALTOB, MQ_ALTOB_MSG.",8,{$parms['ivsno']},{$parms['lpr']}".MQ_ALTOB_MSG_END_TAG);
  459. // $this->mq_send(MQ_TOPIC_SUBTEXT, "{$parms['ivsno']},{$msg}臨時車請投票卡或刷卡出場");
  460. // [acer] cmd:102 離場車辨成功流程 START
  461. $this->call_acer('102', array('cario_no' => $rows_cario['cario_no'], 'ivs_no' => $parms['ivsno'], 'msg_code' => 8));
  462. // [acer] cmd:102 離場車辨成功流程 END
  463. }
  464. else
  465. {
  466. // TODO: 歐pa卡離場記錄和臨停未付款一樣, 待更正
  467. $data = array
  468. (
  469. 'out_time' => $this->now_str,
  470. 'out_lane' => $parms['ivsno'],
  471. 'minutes' => $co_time_minutes,
  472. 'out_pic_name' => $parms['pic_name']
  473. );
  474. $this->db->update('cario', $data, array('cario_no' => $rows_cario['cario_no'])); // 記錄出場
  475. trigger_error('臨停未付款:' . print_r($rows, true));
  476. // 傳送離場記錄
  477. $sync_agent = new AltobSyncAgent();
  478. $sync_agent->init($parms['sno'], $this->now_str);
  479. $sync_agent->cario_no = $rows_cario['cario_no']; // 進出編號
  480. $sync_agent->in_time = $rows_cario['in_time']; // 入場時間
  481. $sync_result = $sync_agent->sync_st_out($parms);
  482. trigger_error( "..sync_st_out.." . $sync_result);
  483. // [mitac] 要求 mitac 扣款 START
  484. $this->call_mitac_pay($parms['lpr'], $parms['ivsno'], $rows_cario);
  485. // [mitac] 要求 mitac 扣款 END
  486. }
  487. }
  488. break;
  489. default:
  490. // CO.C.1 其它付款方式
  491. if($opendoor)
  492. {
  493. $in_time = strtotime($rows_cario['out_before_time']);
  494. $ck = md5($in_time. $parms['lpr'] . $parms['sno']);
  495. //$jdata = file_get_contents("http://localhost/allpa_service.html/allpa_go/{$in_time}/{$parms['lpr']}/{$parms['sno']}/{$ck}");
  496. $jdata = file_get_contents("http://localhost/allpa_service.html/allpa_go_remote/{$in_time}/{$parms['lpr']}/{$parms['sno']}/{$ck}");
  497. trigger_error("allpa回傳:{$jdata}|{$in_time}/{$parms['lpr']}/{$parms['sno']}/{$ck}");
  498. $results = json_decode($jdata, true);
  499. if (isset($results['result_code'])) // 歐pa卡, 點數足夠扣
  500. {
  501. if($results['result_code'] == 0)
  502. {
  503. // 臨停開門
  504. $this->temp_opendoors($parms);
  505. // 歐pa卡, 字幕
  506. $this->mq_send(MQ_TOPIC_ALTOB, MQ_ALTOB_MSG.",7,{$parms['ivsno']},{$parms['lpr']},{$results['amt']}".MQ_ALTOB_MSG_END_TAG);
  507. // // $this->mq_send(MQ_TOPIC_SUBTEXT, "{$parms['ivsno']},{$msg}扣{$results['amt']}點請離場");
  508. // $this->mq_send(MQ_TOPIC_SUBTEXT, "{$parms['ivsno']},{$msg}請離場歐pa卡扣:{$results['amt']}點謝謝光臨");
  509. // updated 2016/09/01
  510. $data = array(
  511. 'out_before_time' => date('Y-m-d H:i:s', strtotime(" + 15 minutes")),
  512. 'pay_time' => $this->now_str,
  513. 'pay_type' => 9, // 歐pa卡
  514. 'payed' => 1
  515. );
  516. $this->db->update('cario', $data, array('cario_no' => $rows_cario['cario_no'])); // 記錄出場
  517. // [acer] cmd:102 離場車辨成功流程 START
  518. $this->call_acer('102', array('cario_no' => $rows_cario['cario_no'], 'ivs_no' => $parms['ivsno'], 'msg_code' => 7));
  519. // [acer] cmd:102 離場車辨成功流程 END
  520. }
  521. else if ($results['result_code'] == 12) // 歐pa卡, 餘額不足
  522. {
  523. // 臨停字幕
  524. $this->mq_send(MQ_TOPIC_ALTOB, MQ_ALTOB_MSG.",12,{$parms['ivsno']},{$parms['lpr']}".MQ_ALTOB_MSG_END_TAG);
  525. // [acer] cmd:102 離場車辨成功流程 START
  526. $this->call_acer('102', array('cario_no' => $rows_cario['cario_no'], 'ivs_no' => $parms['ivsno'], 'msg_code' => 12));
  527. // [acer] cmd:102 離場車辨成功流程 END
  528. }
  529. else if ($results['result_code'] == 11) // 歐pa卡, 查無會員
  530. {
  531. // 臨停字幕
  532. $this->mq_send(MQ_TOPIC_ALTOB, MQ_ALTOB_MSG.",9,{$parms['ivsno']},{$parms['lpr']}".MQ_ALTOB_MSG_END_TAG);
  533. //// $this->mq_send(MQ_TOPIC_SUBTEXT, "{$parms['ivsno']},{$msg}其它付款方式");
  534. // $this->mq_send(MQ_TOPIC_SUBTEXT, "{$parms['ivsno']},{$msg}臨時車請投票卡或刷卡出場");
  535. // [acer] cmd:102 離場車辨成功流程 START
  536. $this->call_acer('102', array('cario_no' => $rows_cario['cario_no'], 'ivs_no' => $parms['ivsno'], 'msg_code' => 9));
  537. // [acer] cmd:102 離場車辨成功流程 END
  538. }
  539. else
  540. {
  541. // 臨停字幕
  542. $this->mq_send(MQ_TOPIC_ALTOB, MQ_ALTOB_MSG.",9,{$parms['ivsno']},{$parms['lpr']}".MQ_ALTOB_MSG_END_TAG);
  543. // [acer] cmd:102 離場車辨成功流程 START
  544. $this->call_acer('102', array('cario_no' => $rows_cario['cario_no'], 'ivs_no' => $parms['ivsno'], 'msg_code' => 9));
  545. // [acer] cmd:102 離場車辨成功流程 END
  546. }
  547. }
  548. else
  549. {
  550. // 臨停字幕
  551. $this->mq_send(MQ_TOPIC_ALTOB, MQ_ALTOB_MSG.",9,{$parms['ivsno']},{$parms['lpr']}".MQ_ALTOB_MSG_END_TAG);
  552. // [acer] cmd:102 離場車辨成功流程 START
  553. $this->call_acer('102', array('cario_no' => $rows_cario['cario_no'], 'ivs_no' => $parms['ivsno'], 'msg_code' => 9));
  554. // [acer] cmd:102 離場車辨成功流程 END
  555. }
  556. }
  557. else
  558. {
  559. $data = array
  560. (
  561. 'out_time' => $this->now_str,
  562. 'out_lane' => $parms['ivsno'],
  563. 'minutes' => $co_time_minutes,
  564. 'out_pic_name' => $parms['pic_name']
  565. );
  566. $this->db->update('cario', $data, array('cario_no' => $rows_cario['cario_no'])); // 記錄出場
  567. trigger_error("{$parms['lpr']}|其它付款方式:" . print_r($rows_cario, true));
  568. // 傳送離場記錄
  569. $sync_agent = new AltobSyncAgent();
  570. $sync_agent->init($parms['sno'], $this->now_str);
  571. $sync_agent->cario_no = $rows_cario['cario_no']; // 進出編號
  572. $sync_agent->in_time = $rows_cario['in_time']; // 入場時間
  573. $sync_result = $sync_agent->sync_st_out($parms);
  574. trigger_error( "..sync_st_out.." . $sync_result);
  575. // [mitac] 要求 mitac 扣款 START
  576. $this->call_mitac_pay($parms['lpr'], $parms['ivsno'], $rows_cario);
  577. // [mitac] 要求 mitac 扣款 END
  578. }
  579. break;
  580. }
  581. }
  582. else if ($rows['member_no'] != 0)
  583. {
  584. // CO.Z.1 月租車無入場資料
  585. if($opendoor)
  586. {
  587. // 會員開門
  588. $this->member_opendoors($parms);
  589. // 會員字幕
  590. $this->mq_send(MQ_TOPIC_ALTOB, MQ_ALTOB_MSG.",10,{$parms['ivsno']},{$parms['lpr']}".MQ_ALTOB_MSG_END_TAG);
  591. // $this->mq_send(MQ_TOPIC_SUBTEXT, "{$parms['ivsno']},{$msg}月租戶請離場謝謝光臨");
  592. // [acer] cmd:102 離場車辨成功流程 START
  593. $this->call_acer('102', array('cario_no' => $rows_cario['cario_no'], 'ivs_no' => $parms['ivsno'], 'msg_code' => 10));
  594. // [acer] cmd:102 離場車辨成功流程 END
  595. }
  596. else
  597. {
  598. trigger_error('月租車無入場資料:' . print_r($rows, true));
  599. // 傳送離場記錄
  600. $sync_agent = new AltobSyncAgent();
  601. $sync_agent->init($parms['sno'], $this->now_str);
  602. $sync_agent->member_no = $rows['member_no']; // 會員編號
  603. $sync_agent->finished = 1; // 已離場
  604. $sync_result = $sync_agent->sync_st_out($parms);
  605. trigger_error( "..sync_st_out.." . $sync_result);
  606. }
  607. }
  608. else
  609. {
  610. // CO.Z.Z 無入場資料
  611. if($opendoor)
  612. {
  613. $this->mq_send(MQ_TOPIC_ALTOB, MQ_ALTOB_MSG.",13,{$parms['ivsno']},{$parms['lpr']}".MQ_ALTOB_MSG_END_TAG);
  614. // [acer] cmd:102 離場車辨成功流程 START
  615. $this->call_acer('102', array('cario_no' => 0, 'ivs_no' => $parms['ivsno'], 'msg_code' => 13));
  616. // [acer] cmd:102 離場車辨成功流程 END
  617. }
  618. else
  619. {
  620. trigger_error('無入場資料:' . print_r($rows, true));
  621. // 傳送離場記錄
  622. $sync_agent = new AltobSyncAgent();
  623. $sync_agent->init($parms['sno'], $this->now_str);
  624. $sync_result = $sync_agent->sync_st_out($parms);
  625. trigger_error( "..sync_st_out.." . $sync_result);
  626. }
  627. }
  628. break;
  629. }
  630. }
  631. // 檢查是否合法會員或VIP資料
  632. public function get_member($lpr)
  633. {
  634. $where_arr = array
  635. (
  636. 'c.lpr' => $lpr,
  637. 'c.start_time <=' => $this->now_str,
  638. 'c.end_time >=' => $this->now_str
  639. );
  640. $sql = "select
  641. c.lpr_correct,
  642. c.member_no,
  643. m.member_name,
  644. m.member_type,
  645. m.locked,
  646. m.remarks,
  647. m.park_time,
  648. m.suspended,
  649. m.valid_time,
  650. c.etag,
  651. c.start_time,
  652. c.end_time
  653. from member_car c, members m
  654. where c.member_no = m.member_no
  655. and c.start_time <= '{$this->now_str}'
  656. and c.end_time >= '{$this->now_str}'
  657. and c.lpr = '{$lpr}'
  658. limit 1";
  659. $rows = $this->db->query($sql)->row_array();
  660. // 新增 park_time_check 2016/11/11
  661. $park_time_check = 0;
  662. if (!empty($rows['lpr_correct']))
  663. {
  664. $park_time = $rows['park_time'];
  665. $pt_arr = $this->vars['mcache']->get('pt');
  666. if(empty($pt_arr) || empty($park_time))
  667. {
  668. // ERROR: 無法驗証時段, 跳過時段限制判斷
  669. trigger_error("[ERROR] mcache.pt is empty !!");
  670. $park_time_check = 1;
  671. }
  672. else
  673. {
  674. $now_time = substr($this->now_str, 11); // 日期字串只取最後時間字串(13:25:32)
  675. $week_no = date('w',strtotime($this->now_str)); // 取星期幾
  676. $park_time_array = explode(',', $park_time); // 用 , 格開
  677. foreach($park_time_array as $idx => $park_time_value)
  678. {
  679. foreach($pt_arr[$park_time_value]['timex'] as $idx => $pt_rows)
  680. {
  681. if ($week_no >= $pt_rows['w_start'] &&
  682. $week_no <= $pt_rows['w_end'] &&
  683. $now_time >= $pt_rows['time_start'] &&
  684. $now_time <= $pt_rows['time_end'])
  685. {
  686. $park_time_check = 2;
  687. trigger_error("時段代碼:{$park_time_value} 星期:{$week_no}");
  688. break;
  689. }
  690. }
  691. }
  692. }
  693. }
  694. if (empty($rows['lpr_correct'])) // A. 非月租車
  695. {
  696. $rows = array
  697. (
  698. 'lpr_correct' => '',
  699. 'member_no' => 0,
  700. 'member_name' => '',
  701. 'member_type' => 9,
  702. 'etag' => '',
  703. 'start_time' => '',
  704. 'end_time' => '',
  705. );
  706. }
  707. else if(empty($park_time_check)) // B. 月租車, 時段無效
  708. {
  709. trigger_error("無效的時段!! " . print_r($rows, true));
  710. $rows = array
  711. (
  712. 'lpr_correct' => '',
  713. 'member_no' => 0,
  714. 'member_name' => '',
  715. 'member_type' => 9,
  716. 'etag' => '',
  717. 'start_time' => '',
  718. 'end_time' => '',
  719. );
  720. }
  721. else if(!empty($rows['suspended'])) // C. 月租車, 停權中
  722. {
  723. trigger_error("停權中!! " . print_r($rows, true));
  724. $rows = array
  725. (
  726. 'lpr_correct' => '',
  727. 'member_no' => 0,
  728. 'member_name' => '',
  729. 'member_type' => 9,
  730. 'etag' => '',
  731. 'start_time' => '',
  732. 'end_time' => '',
  733. );
  734. }
  735. else if(!empty($rows['valid_time']) && $rows['valid_time'] < $this->now_str) // D. 月租車, 已無效 (審核未通過)
  736. {
  737. trigger_error("已無效!! " . print_r($rows, true));
  738. $rows = array
  739. (
  740. 'lpr_correct' => '',
  741. 'member_no' => 0,
  742. 'member_name' => '',
  743. 'member_type' => 9,
  744. 'etag' => '',
  745. 'start_time' => '',
  746. 'end_time' => '',
  747. );
  748. }
  749. trigger_error('讀取會員:' . print_r($rows, true) . ", park_time_check: {$park_time_check}");
  750. // 20171025 強制先不導入會員
  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. trigger_error(__FUNCTION__ . '..force not found..');
  762. return $rows;
  763. }
  764. /*
  765. // 開門 (月租)
  766. public function member_opendoors($parms)
  767. {
  768. $this->mq_send(MQ_TOPIC_OPEN_DOOR, "DO{$parms['ivsno']},OPEN,{$parms['lpr']}");
  769. return true;
  770. }
  771. // 開門 (臨停)
  772. public function temp_opendoors($parms)
  773. {
  774. $this->mq_send(MQ_TOPIC_OPEN_DOOR, "DO{$parms['ivsno']},TICKET,{$parms['lpr']}");
  775. return true;
  776. }
  777. */
  778. // 用eTag讀出車號
  779. public function etag2lpr_2($etag)
  780. {
  781. // 用讀取eTag記錄(有double驗證過)
  782. $rows = $this->db->select('lpr')
  783. ->from('etag_lpr')
  784. ->where(array('etag' => $etag, 'confirms >' => 0))
  785. ->limit(1)
  786. ->get()
  787. ->row_array();
  788. // 讀出eTag資料
  789. if (!empty($rows['lpr']))
  790. {
  791. trigger_error("+++車牌NONE,以eTag讀入車牌:{$etag}|{$rows['lpr']}");
  792. return $rows['lpr'];
  793. }
  794. return 'NONE';
  795. }
  796. // 有車牌與eTag, 檢查資料庫 (2017/03/22 new)
  797. public function check_lpr_etag($lpr, $etag)
  798. {
  799. $ETAG_LOG_TITLE = 'etag://';
  800. $ETAG_WARMIN_TITLE = 'etag-warning://';
  801. trigger_error($ETAG_LOG_TITLE. "輸入: {$lpr},{$etag}");
  802. // 手動值上下限
  803. $max_admin_confirms_value = 99;
  804. $min_admin_confirms_value = 50;
  805. // 自動值上下限
  806. $max_system_confirms_value = 33;
  807. $min_system_confirms_value = 0;
  808. // 判斷對應加權
  809. $etag_confirms_bias_plus = 11; // etag 找 車牌, 對上一次可扺 11次
  810. $etag_confirms_bias_minus = -1;
  811. $lpr_confirms_bias_plus = 3; // 車牌 找 etag, 對上一次可扺 3次
  812. $lpr_confirms_bias_minus = -1;
  813. // eTag 找 車牌
  814. $lpr_info_from_etag = $this->db->select('lpr, confirms')
  815. ->from('etag_lpr')
  816. ->where(array('etag' => $etag))
  817. ->limit(1)
  818. ->get()
  819. ->row_array();
  820. if (!empty($lpr_info_from_etag['lpr']))
  821. {
  822. // B. etag 有找到 車牌
  823. if ($lpr_info_from_etag['lpr'] == $lpr)
  824. {
  825. // B.1. etag 有找到 車牌, 且 車牌 相符, confirms 上升
  826. $confirms_bias = $etag_confirms_bias_plus;
  827. }
  828. else
  829. {
  830. // B.2. etag 有找到 車牌, 但 車牌 不符, confirms 下降
  831. $confirms_bias = $etag_confirms_bias_minus;
  832. trigger_error($ETAG_WARMIN_TITLE . "etag 找 lpr | lpr error : {$lpr},{$etag} | query:" . print_r($lpr_info_from_etag, true));
  833. }
  834. $next_confirms_value = $lpr_info_from_etag['confirms'] + $confirms_bias;
  835. trigger_error($ETAG_LOG_TITLE . "etag 找 lpr | {$lpr},{$etag}, next_confirms: {$next_confirms_value}, bias:{$confirms_bias}");
  836. // 更新 confirms 資訊
  837. if($next_confirms_value > $max_admin_confirms_value)
  838. {
  839. // B.3.0 confirms 超過 max_admin_confirms_value, skip
  840. //trigger_error($ETAG_LOG_TITLE . "etag 找 lpr | {$lpr},{$etag} next_confirms_value > max_admin_confirms_value : {$max_admin_confirms_value}");
  841. }
  842. else if ($next_confirms_value >= $min_admin_confirms_value)
  843. {
  844. // B.3.1 人工確認過的記錄, 誤判多次後會停留在 min_admin_confirms_value, 或加到 max_admin_confirms_value
  845. $this->db->where('etag', $etag)->update('etag_lpr', array('confirms' => $next_confirms_value));
  846. }
  847. else if ($next_confirms_value > $max_system_confirms_value)
  848. {
  849. // B.3.2 confirms 超過 max_system_confirms_value, skip
  850. //trigger_error($ETAG_LOG_TITLE . "etag 找 lpr | {$lpr},{$etag} next_confirms_value > max_system_confirms_value : {$max_system_confirms_value}");
  851. }
  852. else if ($next_confirms_value <= $max_system_confirms_value && $next_confirms_value >= $min_system_confirms_value)
  853. {
  854. // B.3.3 confirms 不到 max_system_confirms_value 為系統生成記錄, 誤判多次後 confirms 會扣到 min_system_confirms_value
  855. $this->db->where('etag', $etag)->update('etag_lpr', array('confirms' => $next_confirms_value));
  856. }
  857. else
  858. {
  859. // B.3.4 若低於 min_system_confirms_value,刪除
  860. $this->db->delete('etag_lpr', array('etag' => $etag));
  861. trigger_error($ETAG_LOG_TITLE . "etag 找 lpr | etag confirms fail and removed : {$lpr_info_from_etag['lpr']}, {$etag}");
  862. trigger_error($ETAG_WARMIN_TITLE . "etag 找 lpr | etag confirms fail and removed : {$lpr_info_from_etag['lpr']}, {$etag}");
  863. }
  864. }
  865. else
  866. {
  867. // 車牌 找 etag
  868. $etag_info_form_lpr = $this->db->select('etag, confirms, member_no')
  869. ->from('etag_lpr')
  870. ->where(array('lpr' => $lpr))
  871. ->limit(1)
  872. ->get()
  873. ->row_array();
  874. if (!empty($etag_info_form_lpr['etag']))
  875. {
  876. // A. 車牌 有找到 etag
  877. if ($etag_info_form_lpr['etag'] == $etag)
  878. {
  879. // A.1. 車牌 有找到 etag, 且 etag 相符, confirms 上升
  880. $confirms_bias = $lpr_confirms_bias_plus;
  881. // 若尚未登記為會員
  882. if(empty($etag_info_form_lpr['member_no']))
  883. {
  884. // 檢查是否會員
  885. $member_info_from_lpr = $this->db->select('member_no, member_name')
  886. ->from('members')
  887. ->where(array('lpr' => $lpr))
  888. ->limit(1)
  889. ->get()
  890. ->row_array();
  891. // 確認為會員, 建立 eTag 資訊
  892. if (!empty($member_info_from_lpr['member_no']))
  893. {
  894. $data['member_no'] = $member_info_from_lpr['member_no'];
  895. $data['member_name'] = $member_info_from_lpr['member_name'];
  896. $this->db->where('member_no', $member_info_from_lpr['member_no'])->update('member_car', array('etag' => $etag));
  897. $this->db->where('member_no', $member_info_from_lpr['member_no'])->update('members', array('etag' => $etag));
  898. // 更新 etag_lpr
  899. $this->db->where('etag', $etag)->update('etag_lpr', $data);
  900. }
  901. }
  902. }
  903. else
  904. {
  905. // A.2. 車牌 有找到 etag, 但 etag 不符, confirms 下降
  906. $confirms_bias = $lpr_confirms_bias_minus;
  907. trigger_error($ETAG_WARMIN_TITLE . "lpr 找 etag | etag error : {$lpr},{$etag} | query:" . print_r($etag_info_form_lpr, true));
  908. }
  909. $next_confirms_value = $lpr_info_from_etag['confirms'] + $confirms_bias;
  910. trigger_error($ETAG_LOG_TITLE . "lpr 找 etag | {$lpr},{$etag}, next_confirms: {$next_confirms_value}, bias:{$confirms_bias}");
  911. // 更新 confirms 資訊
  912. if($next_confirms_value > $max_admin_confirms_value)
  913. {
  914. // A.3.0 confirms 超過 max_admin_confirms_value, skip
  915. //trigger_error($ETAG_LOG_TITLE . "lpr 找 etag | {$lpr},{$etag} next_confirms_value > max_admin_confirms_value : {$max_admin_confirms_value}");
  916. }
  917. else if ($next_confirms_value >= $min_admin_confirms_value)
  918. {
  919. // A.3.1 人工確認過的記錄, 誤判多次後會停留在 min_admin_confirms_value, 或加到 max_admin_confirms_value
  920. $this->db->where('lpr', $lpr)->update('etag_lpr', array('confirms' => $next_confirms_value));
  921. }
  922. else if ($next_confirms_value > $max_system_confirms_value)
  923. {
  924. // A.3.2 confirms 超過 max_system_confirms_value, skip
  925. //trigger_error($ETAG_LOG_TITLE . "lpr 找 etag | {$lpr},{$etag} next_confirms_value > max_system_confirms_value : {$max_system_confirms_value}");
  926. }
  927. else if ($next_confirms_value <= $max_system_confirms_value && $next_confirms_value >= $min_system_confirms_value)
  928. {
  929. // A.3.3 confirms 不到 max_system_confirms_value 為系統生成記錄, 誤判多次後 confirms 會扣到 min_system_confirms_value
  930. $this->db->where('lpr', $lpr)->update('etag_lpr', array('confirms' => $next_confirms_value));
  931. }
  932. else
  933. {
  934. // A.3.4 若低於 min_system_confirms_value,刪除
  935. $this->db->delete('etag_lpr', array('lpr' => $lpr));
  936. trigger_error($ETAG_LOG_TITLE . "lpr 找 etag | lpr confirms fail and removed : {$lpr}, {$etag_info_form_lpr['etag']}");
  937. trigger_error($ETAG_WARMIN_TITLE . "lpr 找 etag | lpr confirms fail and removed : {$lpr}, {$etag_info_form_lpr['etag']}");
  938. }
  939. }
  940. else
  941. {
  942. // C. 車牌 與 etag 都找不到記錄
  943. $data = array
  944. (
  945. 'lpr' => $lpr,
  946. 'lpr_correct' => $lpr,
  947. 'etag' => $etag
  948. );
  949. // 檢查是否會員
  950. $member_info_from_lpr = $this->db->select('member_no, member_name')
  951. ->from('members')
  952. ->where(array('lpr' => $lpr))
  953. ->limit(1)
  954. ->get()
  955. ->row_array();
  956. // 會員者, 將eTag update回去
  957. if (!empty($member_info_from_lpr['member_no']))
  958. {
  959. $data['member_no'] = $member_info_from_lpr['member_no'];
  960. $data['member_name'] = $member_info_from_lpr['member_name'];
  961. $this->db->where('member_no', $member_info_from_lpr['member_no'])->update('member_car', array('etag' => $etag));
  962. $this->db->where('member_no', $member_info_from_lpr['member_no'])->update('members', array('etag' => $etag));
  963. }
  964. // 建立第一筆記錄
  965. $this->db->insert('etag_lpr', $data);
  966. $etag_lpr_seqno = $this->db->insert_id();
  967. trigger_error($ETAG_LOG_TITLE . "create | insert seqno = {$etag_lpr_seqno}". print_r($data, true));
  968. }
  969. }
  970. }
  971. /*
  972. // 有車牌與eTag, 檢查資料庫
  973. public function check_lpr_etag($lpr, $etag)
  974. {
  975. // 用讀取eTag記錄(有double驗證過)
  976. $rows = $this->db->select('etag, confirms')
  977. ->from('etag_lpr')
  978. ->where(array('lpr' => $lpr))
  979. ->limit(1)
  980. ->get()
  981. ->row_array();
  982. // 讀出eTag資料
  983. if (!empty($rows['etag']))
  984. {
  985. // 車牌與eTag皆相符, 檢查是否confirms欄位若為0, 設成1(double驗證)
  986. if ($rows['etag'] == $etag)
  987. {
  988. if ($rows['confirms'] == 0) $this->db->where('lpr', $lpr)->update('etag_lpr', array('confirms' => 1));
  989. }
  990. else // eTag不相符
  991. {
  992. if ($rows['confirms'] == 1)
  993. {
  994. $this->db->where('lpr', $lpr)->update('etag_lpr', array('confirms' => 0));
  995. }
  996. else // 原confirms為0者, 刪除之
  997. {
  998. $this->db->delete('etag_lpr', array('lpr' => $lpr));
  999. }
  1000. }
  1001. }
  1002. else // 無資料, 新增一筆
  1003. {
  1004. // 再檢查一次是否有eTag ?
  1005. $rows_etag = $this->db->select('lpr, confirms')
  1006. ->from('etag_lpr')
  1007. ->where(array('etag' => $etag))
  1008. ->limit(1)
  1009. ->get()
  1010. ->row_array();
  1011. if (empty($rows_etag['lpr'])) // 無資料
  1012. {
  1013. $data = array
  1014. (
  1015. 'lpr' => $lpr,
  1016. 'lpr_correct' => $lpr,
  1017. 'etag' => $etag
  1018. );
  1019. // 檢查是否會員
  1020. $rows_members = $this->db->select('member_no, member_name')
  1021. ->from('members')
  1022. ->where(array('lpr' => $lpr))
  1023. ->limit(1)
  1024. ->get()
  1025. ->row_array();
  1026. // 會員者, 將eTag update回去
  1027. if (!empty($rows_members['member_no']))
  1028. {
  1029. $data['member_no'] = $rows_members['member_no'];
  1030. $data['member_name'] = $rows_members['member_name'];
  1031. $this->db->where('member_no', $rows_members['member_no'])->update('member_car', array('etag' => $etag));
  1032. $this->db->where('member_no', $rows_members['member_no'])->update('members', array('etag' => $etag));
  1033. }
  1034. $this->db->insert('etag_lpr', $data);
  1035. }
  1036. else
  1037. {
  1038. if ($rows_etag['confirms'] == 1)
  1039. {
  1040. $this->db->where('etag', $etag)->update('etag_lpr', array('confirms' => 0));
  1041. }
  1042. else // 原confirms為0者, 刪除之
  1043. {
  1044. $this->db->delete('etag_lpr', array('etag' => $etag));
  1045. }
  1046. }
  1047. }
  1048. }
  1049. */
  1050. // 送出至message queue(目前用mqtt)
  1051. public function mq_send($topic, $msg)
  1052. {
  1053. $this->vars['mqtt']->publish($topic, $msg, 0);
  1054. trigger_error("mqtt:{$topic}|{$msg}");
  1055. }
  1056. // 產生 CK
  1057. public function gen_opendoor_ck($parms, $function_name)
  1058. {
  1059. return md5($parms['ivsno']. 'alt' . date('dmh') . 'o' . $parms['lpr'] . 'b' . $function_name);
  1060. }
  1061. // 開門 (月租)
  1062. public function member_opendoors($parms)
  1063. {
  1064. //$this->mq_send_opendoor(MQ_TOPIC_OPEN_DOOR, "DO{$parms['ivsno']},OPEN,{$parms['lpr']}");
  1065. $ck = $this->gen_opendoor_ck($parms, __FUNCTION__);
  1066. get_headers("http://localhost/cars.html/" . __FUNCTION__ . "/{$parms['ivsno']}/{$parms['lpr']}/{$ck}");
  1067. return true;
  1068. }
  1069. // 開門 (臨停)
  1070. public function temp_opendoors($parms)
  1071. {
  1072. //$this->mq_send_opendoor(MQ_TOPIC_OPEN_DOOR, "DO{$parms['ivsno']},TICKET,{$parms['lpr']}");
  1073. $ck = $this->gen_opendoor_ck($parms, __FUNCTION__);
  1074. get_headers("http://localhost/cars.html/" . __FUNCTION__ ."/{$parms['ivsno']}/{$parms['lpr']}/{$ck}");
  1075. return true;
  1076. }
  1077. // 開門 (月租)
  1078. public function do_member_opendoor($parms)
  1079. {
  1080. if($parms['ck'] != $this->gen_opendoor_ck($parms, 'member_opendoors'))
  1081. {
  1082. return 'ck_error'; // 中斷
  1083. }
  1084. $this->mq_send(MQ_TOPIC_OPEN_DOOR, "DO{$parms['ivsno']},OPEN,{$parms['lpr']}");
  1085. return 'ok';
  1086. }
  1087. // 開門 (臨停)
  1088. public function do_temp_opendoor($parms)
  1089. {
  1090. if($parms['ck'] != $this->gen_opendoor_ck($parms, 'temp_opendoors'))
  1091. {
  1092. return 'ck_error'; // 中斷
  1093. }
  1094. $this->mq_send(MQ_TOPIC_OPEN_DOOR, "DO{$parms['ivsno']},TICKET,{$parms['lpr']}");
  1095. return 'ok';
  1096. }
  1097. // 指派車位
  1098. // http://203.75.167.89/parkingquery.html/get_valid_seat
  1099. // 註記現在時間, 並保留10分鐘
  1100. public function get_valid_seat()
  1101. {
  1102. $data = array();
  1103. //$data['result']['location_no'] = '0';
  1104. //$data['result_code'] = 'FAIL';
  1105. //return $data;
  1106. // 撈 roger db
  1107. /*
  1108. $sql = "
  1109. SELECT ParkingNum AS pksno FROM table_carpark
  1110. WHERE LPR = '' AND DisableSeat = 0 AND
  1111. (SELECT COUNT(*) FROM table_carpark WHERE LPR = '' AND DisableSeat = 0) <= 10
  1112. ORDER BY RAND() LIMIT 1 FOR UPDATE;
  1113. ";
  1114. $dsn_old_db = $this->load->database('old_db', true);
  1115. // 2016/12/14 roger_db 掛了的可能
  1116. if ($dsn_old_db->initialize())
  1117. {
  1118. $retults = $dsn_old_db->query($sql)->result_array();
  1119. }
  1120. if(!empty($retults[0]))
  1121. {
  1122. $data['result']['location_no'] = substr($retults[0]['pksno'], 1);
  1123. $data['result_code'] = 'OK';
  1124. $data['loc_name'] = 'B'.substr($retults[0]['pksno'], 0, 1);
  1125. $data['floors'] = 'B'.substr($retults[0]['pksno'], 0, 1);
  1126. }
  1127. else
  1128. {
  1129. $data['result']['location_no'] = '0';
  1130. $data['result_code'] = 'FAIL';
  1131. }
  1132. */
  1133. $this->db->trans_start();
  1134. $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;";
  1135. $rows = $this->db->query($sql)->row_array();
  1136. if (!empty($rows['pksno']))
  1137. {
  1138. $data['result']['location_no'] = substr($rows['pksno'], -3);
  1139. $data['result_code'] = 'OK';
  1140. $sql = "update pks set book_time = addtime(now(), '00:10:00') where pksno = {$rows['pksno']};";
  1141. $this->db->query($sql);
  1142. $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";
  1143. $rows = $this->db->query($sql)->row_array();
  1144. $data['loc_name'] = $rows['group_name'];
  1145. $data['floors'] = $rows['floors'];
  1146. }
  1147. else
  1148. {
  1149. $data['result']['location_no'] = '0';
  1150. $data['result_code'] = 'FAIL';
  1151. }
  1152. $this->db->trans_complete();
  1153. return $data;
  1154. }
  1155. // 取得出入口 888 資訊
  1156. public function get_888_info($parms)
  1157. {
  1158. $data = array();
  1159. $sql = "select availables as availables, tot as tot from pks_groups where group_id = 'C888' and station_no = {$parms['sno']}";
  1160. $rows = $this->db->query($sql)->row_array();
  1161. if (!empty($rows) && array_key_exists('availables', $rows))
  1162. {
  1163. $data['result_code'] = 'OK';
  1164. $data['availables'] = $rows['availables'];
  1165. $data['tot'] = $rows['tot'];
  1166. }
  1167. else
  1168. {
  1169. trigger_error(__FUNCTION__ . "..not found..".print_r($parms, true));
  1170. $data['result_code'] = 'FAIL';
  1171. $data['availables'] = 9999; // 如果拿不到就忽略這個流程
  1172. $data['tot'] = 0;
  1173. }
  1174. return $data;
  1175. }
  1176. // ===============================================
  1177. // acer cmd
  1178. // ===============================================
  1179. // 產生通行碼
  1180. function gen_pass_code()
  1181. {
  1182. return rand(100000,999999);
  1183. }
  1184. // 呼叫acer
  1185. function call_acer($cmd, $parms)
  1186. {
  1187. return false; // 尚未啟用
  1188. try{
  1189. $ch = curl_init();
  1190. curl_setopt($ch, CURLOPT_URL, 'http://localhost/acer_service.html/cmd_'. $cmd);
  1191. curl_setopt($ch, CURLOPT_HEADER, FALSE);
  1192. curl_setopt($ch, CURLOPT_RETURNTRANSFER, TRUE);
  1193. curl_setopt($ch, CURLOPT_SSL_VERIFYPEER, FALSE);
  1194. curl_setopt($ch, CURLOPT_POST, TRUE);
  1195. curl_setopt($ch, CURLOPT_CONNECTTIMEOUT ,3);
  1196. curl_setopt($ch, CURLOPT_TIMEOUT, 3); //timeout in seconds
  1197. curl_setopt($ch, CURLOPT_POSTFIELDS, http_build_query($parms));
  1198. $data = curl_exec($ch);
  1199. if(curl_errno($ch))
  1200. {
  1201. trigger_error(__FUNCTION__ . ', curl error: '. curl_error($ch));
  1202. }
  1203. curl_close($ch);
  1204. trigger_error(__FUNCTION__ . '..'. $data);
  1205. }catch (Exception $e){
  1206. trigger_error(__FUNCTION__ . 'error:'.$e->getMessage());
  1207. }
  1208. }
  1209. // ===============================================
  1210. // mitac cmd
  1211. // ===============================================
  1212. // 要求 mitac 扣款
  1213. function call_mitac_pay($lpr, $ivsno, $rows_cario)
  1214. {
  1215. $function_name = 'parking_fee_altob';
  1216. $seqno = $rows_cario['cario_no'];
  1217. $lpr = $lpr;
  1218. $in_time = $rows_cario['out_before_time'];
  1219. $out_time = $this->now_str;
  1220. $gate_id = $ivsno;
  1221. // 通訊內容
  1222. $parms = array(
  1223. 'seqno' => $seqno,
  1224. 'lpr' => $lpr,
  1225. 'in_time' => $in_time,
  1226. 'out_time' => $out_time,
  1227. 'gate_id' => $gate_id);
  1228. // 驗証碼
  1229. $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);
  1230. // 呼叫
  1231. try{
  1232. $ch = curl_init();
  1233. curl_setopt($ch, CURLOPT_URL, "http://localhost/mitac_service.html/{$function_name}");
  1234. curl_setopt($ch, CURLOPT_HEADER, FALSE);
  1235. curl_setopt($ch, CURLOPT_RETURNTRANSFER, TRUE);
  1236. curl_setopt($ch, CURLOPT_SSL_VERIFYPEER, FALSE);
  1237. curl_setopt($ch, CURLOPT_POST, TRUE);
  1238. curl_setopt($ch, CURLOPT_CONNECTTIMEOUT ,3);
  1239. curl_setopt($ch, CURLOPT_TIMEOUT, 3); //timeout in seconds
  1240. curl_setopt($ch, CURLOPT_POSTFIELDS, http_build_query($parms));
  1241. $data = curl_exec($ch);
  1242. if(curl_errno($ch))
  1243. {
  1244. trigger_error(__FUNCTION__ . ', curl error: '. curl_error($ch));
  1245. }
  1246. curl_close($ch);
  1247. trigger_error(__FUNCTION__ . '..'. $data);
  1248. }catch (Exception $e){
  1249. trigger_error(__FUNCTION__ . 'error:'.$e->getMessage());
  1250. }
  1251. }
  1252. }