记得上下班打卡 | git大法好,push需谨慎
Skip to content
Projects
Groups
Snippets
Help
Loading...
Help
Submit feedback
Contribute to GitLab
Sign in
Toggle navigation
L
liquidnet-bus-v1
Project
Project
Details
Activity
Releases
Cycle Analytics
Repository
Repository
Files
Commits
Branches
Tags
Contributors
Graph
Compare
Charts
Issues
0
Issues
0
List
Board
Labels
Milestones
Merge Requests
0
Merge Requests
0
CI / CD
CI / CD
Pipelines
Jobs
Schedules
Charts
Wiki
Wiki
Snippets
Snippets
Members
Members
Collapse sidebar
Close sidebar
Activity
Graph
Charts
Create a new issue
Jobs
Commits
Issue Boards
Open sidebar
董敬伟
liquidnet-bus-v1
Commits
44d7ac68
Commit
44d7ac68
authored
Apr 21, 2022
by
GaoHu
Browse files
Options
Browse Files
Download
Email Patches
Plain Diff
获取基本信息查询redis查询优化
parent
64d18bcf
Changes
2
Hide whitespace changes
Inline
Side-by-side
Showing
2 changed files
with
11 additions
and
11 deletions
+11
-11
GoblinGoodsAnticipateServiceImpl.java
...goblin/service/impl/GoblinGoodsAnticipateServiceImpl.java
+6
-6
GoblinGoodsAnticipateMgServiceImpl.java
...rvice/impl/manage/GoblinGoodsAnticipateMgServiceImpl.java
+5
-5
No files found.
liquidnet-bus-service/liquidnet-service-goblin/liquidnet-service-goblin-impl/src/main/java/com/liquidnet/service/goblin/service/impl/GoblinGoodsAnticipateServiceImpl.java
View file @
44d7ac68
...
...
@@ -66,20 +66,20 @@ public class GoblinGoodsAnticipateServiceImpl implements IGoblinGoodsAnticipateS
if
(
userVo
==
null
)
{
//接入助力人数判断
//获取需要多少人助力
GoblinGoodsAnticipateHelp
sharePeopleBySkuId
=
goblinRedisUtils
.
getSharePeopleBySkuId
(
skuId
);
//
GoblinGoodsAnticipateHelp sharePeopleBySkuId = goblinRedisUtils.getSharePeopleBySkuId(skuId);
//判断如果所需助力人数
if
(
sharePeopleBySkuId
.
getPeopl
e
()
!=
0
)
{
if
(
anticipateValueVo
.
getPeopleTyp
e
()
!=
0
)
{
//用户得到助力人数
String
sid
=
goblinRedisUtils
.
getShare
(
skuId
,
uid
);
if
(
sid
!=
null
)
{
Integer
people
=
goblinRedisUtils
.
getHelpSidAddHelp
(
sid
);
if
(
sharePeopleBySkuId
.
getPeopl
e
()
>
people
)
{
int
num
=
sharePeopleBySkuId
.
getPeopl
e
()
-
people
;
log
.
debug
(
" skuId:{},分享sid:{},预约uid:{},需要助力人数:{},助力人数:{}"
,
skuId
,
sid
,
uid
,
sharePeopleBySkuId
.
getPeopl
e
(),
people
);
if
(
anticipateValueVo
.
getPeopleTyp
e
()
>
people
)
{
int
num
=
anticipateValueVo
.
getPeopleTyp
e
()
-
people
;
log
.
debug
(
" skuId:{},分享sid:{},预约uid:{},需要助力人数:{},助力人数:{}"
,
skuId
,
sid
,
uid
,
anticipateValueVo
.
getPeopleTyp
e
(),
people
);
return
ResponseDto
.
failure
(
"预约失败!"
);
}
}
else
{
log
.
debug
(
"skuId:{},需要助力人数:{},uid:{},该用户未开启分享助力!"
,
skuId
,
sharePeopleBySkuId
.
getPeopl
e
(),
uid
);
log
.
debug
(
"skuId:{},需要助力人数:{},uid:{},该用户未开启分享助力!"
,
skuId
,
anticipateValueVo
.
getPeopleTyp
e
(),
uid
);
return
ResponseDto
.
failure
(
"预约失败!"
);
}
...
...
liquidnet-bus-service/liquidnet-service-goblin/liquidnet-service-goblin-impl/src/main/java/com/liquidnet/service/goblin/service/impl/manage/GoblinGoodsAnticipateMgServiceImpl.java
View file @
44d7ac68
...
...
@@ -67,6 +67,7 @@ public class GoblinGoodsAnticipateMgServiceImpl implements IGoblinGoodsAnticipat
return
ResponseDto
.
failure
(
vo
.
getSkuName
().
concat
(
"该商品预约时间在结束时间之后,不可创建!"
));
}
}
//生成的antId
String
antId
=
IDGenerator
.
nextTimeId2
();
GoblinGoodsAnticipateVo
goodsAnticipateVo
=
new
GoblinGoodsAnticipateVo
();
...
...
@@ -113,19 +114,21 @@ public class GoblinGoodsAnticipateMgServiceImpl implements IGoblinGoodsAnticipat
goodsAnticipateValueVo
.
setDelTag
(
0
);
goodsAnticipateValueVo
.
setAboutPeople
(
BigInteger
.
valueOf
(
0
));
goodsAnticipateValueVo
.
setActualPeople
(
BigInteger
.
valueOf
(
0
));
goodsAnticipateValueVo
.
setType
(
type
);
goodsAnticipateValueVo
.
setPeopleType
(
people
);
//redis消息
//redis标识存入该sku处于预约列表
goblinRedisUtils
.
setValue
(
goodsAnticipateValueVo
);
//redis缓存预约条件
GoblinGoodsAnticipateHelp
goodsAnticipateHelp
=
GoblinGoodsAnticipateHelp
.
getNew
();
/*
GoblinGoodsAnticipateHelp goodsAnticipateHelp = GoblinGoodsAnticipateHelp.getNew();
goodsAnticipateHelp.setSkuId(goodsAnticipateValueVo.getSkuId());
goodsAnticipateHelp.setType(type);
goodsAnticipateHelp.setPeople(people);
goodsAnticipateHelp.setAboutStartDate(goodsAnticipateValueVo.getAboutStartDate());
goodsAnticipateHelp.setAboutEndDate(goodsAnticipateValueVo.getAboutEndDate());
goblinRedisUtils
.
setSharePeopleBySkuId
(
item
.
getSkuId
(),
goodsAnticipateHelp
);
goblinRedisUtils.setSharePeopleBySkuId(item.getSkuId(), goodsAnticipateHelp);
*/
//保存mysql中间表
LinkedList
<
Object
[]>
sqlValue
=
CollectionUtil
.
linkedListObjectArr
();
...
...
@@ -226,10 +229,7 @@ public class GoblinGoodsAnticipateMgServiceImpl implements IGoblinGoodsAnticipat
GoblinGoodsAnticipateValueVo
anticipateValueVo
=
goblinRedisUtils
.
getValueBySkuId
(
skuId
);
AnticipateValueVo
valueVo
=
AnticipateValueVo
.
getNew
();
if
(
anticipateValueVo
!=
null
)
{
GoblinGoodsAnticipateHelp
help
=
goblinRedisUtils
.
getSharePeopleBySkuId
(
skuId
);
valueVo
=
valueVo
.
copy
(
anticipateValueVo
);
valueVo
.
setType
(
help
.
getType
());
valueVo
.
setPeopleType
(
help
.
getPeople
());
valueVo
.
setState
(
GoblinAnticipateUtils
.
setState
(
valueVo
.
getAboutStartDate
(),
valueVo
.
getAboutEndDate
()));
}
else
{
valueVo
.
setState
(
null
);
...
...
Write
Preview
Markdown
is supported
0%
Try again
or
attach a new file
Attach a file
Cancel
You are about to add
0
people
to the discussion. Proceed with caution.
Finish editing this message first!
Cancel
Please
register
or
sign in
to comment