selectCollection("social","user_live"); //search on accessToken $conditionArray = array(); if($referrer != "" && $oauth_site_id!= "0" && $accessToken != ""){ $conditionArray['profile_data.external_auth'] = array('$elemMatch'=>array("oauth_site_id"=>$oauth_site_id,"oauth_user_id"=>substr($userDataArr['_id'],3))); }else{ $conditionArray['_id'] = $userDataArr['_id']; } $cursor = $userMongoConnection->find($conditionArray); if($cursor){ $data = iterator_to_array($cursor); if(count($data) > 0){ //record exists #$rs = $userMongoConnection->update($conditionArray,array("$set"=>$updateOnlyValues),array("upsert"=>TRUE)); $rs = 1; }else{ //perform search on _id value $conditionArray = array(); $conditionArray['_id'] = $userDataArr['_id']; $cursor = $userMongoConnection->find($conditionArray); if($cursor){ $data = iterator_to_array($cursor); if(count($data) > 0){ $rs = 1; }else{ // no record exists therefore perform insert unset($userDataArr['profile_data']['user_establishment_status'],$userDataArr['profile_data']['user_establishment_lists'], $userDataArr['profile_data']['user_entity_status']); $rs = $userMongoConnection->insert($userDataArr); $data[$userDataArr['_id']] = $userDataArr; } } } if($rs){ $responseData['STATUS_CODE'] = 1; $responseData['RESPONSE'] = $data; $responseData['RESPONSE_COUNT'] = 1; $responseData['MSG'] = "Successful"; }else{ $responseData['RESPONSE'] = array("0"); $responseData['MSG'] = "Error: Mongo insert"; } }else{ $responseData['RESPONSE'] = array("0"); $responseData['MSG'] = "Error: Mongo Response invalid"; } } echo json_encode($responseData); exit; ?>