Toggle navigation
Toggle navigation
This project
Loading...
Sign in
yoho-search
/
yoho-search-consumer
·
Commits
Go to a project
GitLab
Go to group
Project
Activity
Files
Commits
Pipelines
0
Builds
0
Graphs
Milestones
Issues
0
Merge Requests
0
Members
Labels
Wiki
Forks
Network
Create a new issue
Download as
Email Patches
Plain Diff
Browse Files
Authored by
wangnan
8 years ago
Commit
71fa7e973b3da34736eabf9df95641ea5956c7d1
1 parent
5071ec5d
fix log
Hide whitespace changes
Inline
Side-by-side
Showing
1 changed file
with
2 additions
and
2 deletions
consumer/src/main/java/com/yoho/search/mq/ProductPoolDetailMqListener.java
consumer/src/main/java/com/yoho/search/mq/ProductPoolDetailMqListener.java
View file @
71fa7e9
...
...
@@ -224,7 +224,7 @@ public class ProductPoolDetailMqListener extends AbstractMqListener implements C
List
<
ProductSizes
>
productSizesList
=
iProductIndexBuildService
.
getProductSizes
(
ids
);
if
(
CollectionUtils
.
isNotEmpty
(
productSizesList
))
{
ProductSizes
productSizes
=
productSizesList
.
get
(
0
);
logger
.
info
(
"[
4
][query ProductSizes][cost={}ms]"
,
(
System
.
currentTimeMillis
()
-
begin
));
logger
.
info
(
"[
3
][query ProductSizes][cost={}ms]"
,
(
System
.
currentTimeMillis
()
-
begin
));
if
(
productSizes
!=
null
)
{
indexData
.
put
(
"storageNum"
,
productSizes
.
getStorageNum
());
indexData
.
put
(
"salesNum"
,
productSizes
.
getSalesNum
());
...
...
@@ -235,7 +235,7 @@ public class ProductPoolDetailMqListener extends AbstractMqListener implements C
try
{
//5)更新数据到ES
this
.
updateProductPoolIndexWithDataMap
(
indexData
,
productPoolDetail
.
getId
(),
key
,
System
.
currentTimeMillis
());
logger
.
info
(
"[
5
][updateToES][cost={}ms]"
,
(
System
.
currentTimeMillis
()
-
begin
));
logger
.
info
(
"[
4
][updateToES][cost={}ms]"
,
(
System
.
currentTimeMillis
()
-
begin
));
}
catch
(
Exception
e
)
{
logger
.
error
(
"[func=updateProductPoolIndex][step=error][indexName={}][id={}][cost={}ms][error={}]"
,
ISearchConstans
.
INDEX_NAME_PRODUCT_POOL
,
productPoolDetail
.
getId
().
toString
(),
(
System
.
currentTimeMillis
()
-
begin
),
e
.
getMessage
());
...
...
Please
register
or
login
to post a comment