processLoadData(); log_message('critical', "AirFlow::flowNewAccount ********* ALL ".serialize($in) ); return []; //json_encode( $final_out ); } private function processLoadData(){ $mysql ="SELECT uid,customer_uid,loan_detail FROM applications WHERE pc = 0 limit 2"; $query = $this->db->query($mysql); // $row = $query->getRowArray(); while ($row = $query->getUnbufferedRow()) { log_message('critical', "AirFlow::processLoadData ********* ALL 0000 ". $row->customer_uid ); $this->parseLoadDetail($row->uid,$row->customer_uid,$row->loan_detail); // echo $row->customer_uid; // echo $row->name; // echo $row->body; } // foreach ($row as $rw){ // log_message('critical', "AirFlow::processLoadData ********* =========================in " ); // log_message('critical', "AirFlow::flowNewAccount ********* ALL ".serialize($rw) ); // // log_message('critical', "AirFlow::processLoadData ********* ALL ". $rw["customer_uid"] ); // log_message('critical', "AirFlow::processLoadData ********* ALL 0000 ". $rw[0]["customer_uid"] ); // log_message('critical', "AirFlow::processLoadData ********* ALL 0000 ". $rw->customer_uid ); // log_message('critical', "AirFlow::processLoadData ********* =========================out" ); // // } return 0; } private function parseLoadDetail($uid,$customer_uid,$loan_detail){ $loan_detail_array = unserialize($loan_detail); log_message('critical', "AirFlow::processLoadData*parseLoadDetail ***loan_detail *** ". $loan_detail ); log_message('critical', "AirFlow::processLoadData*parseLoadDetail ***loan_reference*** ". $loan_detail_array["loan_reference"] ); return 0; } }