php使用mongodb实现附近功能

红太狼 2022-06-14 12:10 148阅读 0赞

配置

return array (  
    'lbs' => array (  
        'host' => '88888888888888',  
        'username' => '',  
        'password' => '',  
        )  
);

连接

$constr=bizma\_cjfaster::ld\_config("lbs","lbs");

$connection  = new MongoClient("mongodb://$constr\[host\]");

选择表

$db=IM\_PREFIX.near;  
$m = $connection->selectDB("lbs")->selectCollection("$db");

操作

$gpshash = md5($data\_arr\[code\].$data\_arr\[lon\].$data\_arr\[lat\]);  
   
        $lbs\_arr = array(  
            "code" => $data\_arr\[code\],  
            "type" => $data\_arr\[type\],  
            "gpshash" => $gpshash,  
            "sex" => $data\_arr\[sex\],  
            "loc" => array( "type"=> "Point",  "coordinates"=> array(floatval($data\_arr\[lon\]), floatval($data\_arr\[lat\]))),  
        );

$obj = $m->findOne(array('code' => "$data\_arr\[code\]"));

if (!empty($obj)) \{  
            //$m->insert($user\_arr);  
            $m->update(array("code" => "$data\_arr\[code\]"), array('$set' => array("loc" =>  array( "type"=> "Point",  "coordinates"=> array(floatval($data\_arr\[lon\]),    floatval($data\_arr\[lat\]))),  "workstate" => '1')));  
            
        \} else \{  
              
              
            $m->insert($lbs\_arr);  
              
            try\{  
                //添加索引，注意经度和纬度的顺序，否则会报错  
                //$m->ensureIndex(array('loc' => '2dsphere'));  
                  
            \}catch(Exception $e)\{  
                //print $e->getMessage();  
            \};  
      
              
             
        \}

获取附近的数据

连接选择

$constr=bizma\_cjfaster::ld\_config("lbs","lbs");  
          
       $connection  = new MongoClient("mongodb://$constr\[host\]");  
         
         $db=IM\_PREFIX.near;  
   
        $m = $connection->selectDB("lbs")->selectCollection("$db");

搜索条件

$query = array(  
              "loc"=>array(  
            '$near'=>array(  
              '$geometry'=>array(  
                'type'=> "Point",  
                'coordinates'=>array($lon,$lat),  
               ),  
             '$maxDistance'=>5000  
            )  
          )  
         )

搜索

$cursor = $m->find($query)->limit(10);

转换数组

$r\_arr=iterator\_to\_array($cursor);