Skip to content
体验新版
项目
组织
正在加载...
登录
切换导航
打开侧边栏
镜像
OpenAtomFoundation
pika
提交
e7a726dd
pika
项目概览
镜像
/
OpenAtomFoundation
/
pika
11 个月 前同步成功
通知
0
Star
0
Fork
0
代码
文件
提交
分支
Tags
贡献者
分支图
Diff
Issue
0
列表
看板
标记
里程碑
合并请求
0
DevOps
流水线
流水线任务
计划
Wiki
0
Wiki
分析
仓库
DevOps
项目成员
Pages
pika
项目概览
项目概览
详情
发布
仓库
仓库
文件
提交
分支
标签
贡献者
分支图
比较
Issue
0
Issue
0
列表
看板
标记
里程碑
合并请求
0
合并请求
0
Pages
DevOps
DevOps
流水线
流水线任务
计划
分析
分析
仓库分析
DevOps
Wiki
0
Wiki
成员
成员
收起侧边栏
关闭侧边栏
动态
分支图
创建新Issue
流水线任务
提交
Issue看板
体验新版 GitCode,发现更多精彩内容 >>
提交
e7a726dd
编写于
2月 26, 2017
作者:
Z
Zongzhi Chen
提交者:
GitHub
2月 26, 2017
浏览文件
操作
浏览文件
下载
差异文件
Merge pull request #66 from Leviathan1995/master
format code
上级
c8b9fa0e
8b90a97c
变更
1
隐藏空白更改
内联
并排
Showing
1 changed file
with
12 addition
and
12 deletion
+12
-12
src/pika_geo.cc
src/pika_geo.cc
+12
-12
未找到文件。
src/pika_geo.cc
浏览文件 @
e7a726dd
...
...
@@ -28,8 +28,8 @@ void GeoAddCmd::DoInitial(PikaCmdArgsType &argv, const CmdInfo* const ptr_info)
pos_
.
clear
();
size_t
index
=
2
;
for
(;
index
<
argc
;
index
+=
3
)
{
struct
GeoPoint
point
;
double
longitude
,
latitude
;
struct
GeoPoint
point
;
double
longitude
,
latitude
;
if
(
!
slash
::
string2d
(
argv
[
index
].
data
(),
argv
[
index
].
size
(),
&
longitude
))
{
res_
.
SetRes
(
CmdRes
::
kInvalidFloat
);
return
;
...
...
@@ -52,14 +52,14 @@ void GeoAddCmd::Do() {
const
std
::
shared_ptr
<
nemo
::
Nemo
>
db
=
g_pika_server
->
db
();
std
::
vector
<
GeoPoint
>::
const_iterator
iter
=
pos_
.
begin
();
for
(;
iter
!=
pos_
.
end
();
iter
++
)
{
// Convert coordinates to geohash
GeoHashBits
hash
;
// Convert coordinates to geohash
GeoHashBits
hash
;
geohashEncodeWGS84
(
iter
->
longitude
,
iter
->
latitude
,
GEO_STEP_MAX
,
&
hash
);
GeoHashFix52Bits
bits
=
geohashAlign52Bits
(
hash
);
// Convert uint64 to double
// Convert uint64 to double
double
score
;
std
::
string
str_bits
=
std
::
to_string
(
bits
);
slash
::
string2d
(
str_bits
.
data
(),
str_bits
.
size
(),
&
score
);
std
::
string
str_bits
=
std
::
to_string
(
bits
);
slash
::
string2d
(
str_bits
.
data
(),
str_bits
.
size
(),
&
score
);
s
=
db
->
ZAdd
(
key_
,
score
,
iter
->
member
,
&
ret
);
if
(
s
.
ok
())
{
count
+=
ret
;
...
...
@@ -155,9 +155,9 @@ void GeoDistCmd::DoInitial(PikaCmdArgsType &argv, const CmdInfo* const ptr_info)
first_pos_
=
argv
[
2
];
second_pos_
=
argv
[
3
];
if
(
argv
.
size
()
==
5
)
{
unit_
=
argv
[
4
];
unit_
=
argv
[
4
];
}
else
{
unit_
=
"m"
;
unit_
=
"m"
;
}
if
(
!
check_unit
(
unit_
))
{
res_
.
SetRes
(
CmdRes
::
kErrOther
,
"unsupported unit provided. please use m, km, ft, mi"
);
...
...
@@ -216,8 +216,8 @@ void GeoHashCmd::Do() {
const
char
*
geoalphabet
=
"0123456789bcdefghjkmnpqrstuvwxyz"
;
res_
.
AppendArrayLen
(
member_
.
size
());
for
(
auto
v
:
member_
)
{
double
score
;
nemo
::
Status
s
=
g_pika_server
->
db
()
->
ZScore
(
key_
,
v
,
&
score
);
double
score
;
nemo
::
Status
s
=
g_pika_server
->
db
()
->
ZScore
(
key_
,
v
,
&
score
);
if
(
s
.
ok
())
{
double
xy
[
2
];
GeoHashBits
hash
=
{
.
bits
=
(
uint64_t
)
score
,
.
step
=
GEO_STEP_MAX
};
...
...
@@ -474,4 +474,4 @@ void GeoRadiusByMemberCmd::Do() {
range_
.
latitude
=
xy
[
1
];
}
GetAllNeighbors
(
key_
,
range_
,
this
->
res_
);
}
\ No newline at end of file
}
编辑
预览
Markdown
is supported
0%
请重试
或
添加新附件
.
添加附件
取消
You are about to add
0
people
to the discussion. Proceed with caution.
先完成此消息的编辑!
取消
想要评论请
注册
或
登录