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->loan_reference); log_message('critical', "AirFlow::processLoadData*parseLoadDetail ***customer_uid *** ". $loan_detail->customer_uid ); log_message('critical', "AirFlow::processLoadData*parseLoadDetail ***loan_reference*** ". $loan_detail_array->loan_reference ); return 0; } }