记得上下班打卡 | 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
93816f3a
Commit
93816f3a
authored
Mar 22, 2022
by
zhengfuxin
Browse files
Options
Browse Files
Download
Email Patches
Plain Diff
加入 try
parent
ca458ce2
Changes
1
Hide whitespace changes
Inline
Side-by-side
Showing
1 changed file
with
51 additions
and
45 deletions
+51
-45
SellDataInfoImpl.java
...service/platform/service/impl/smile/SellDataInfoImpl.java
+51
-45
No files found.
liquidnet-bus-service/liquidnet-service-platform/liquidnet-service-platform-impl/src/main/java/com/liquidnet/service/platform/service/impl/smile/SellDataInfoImpl.java
View file @
93816f3a
...
...
@@ -65,53 +65,59 @@ public class SellDataInfoImpl {
for
(
SmileUser
smileUser:
list
){
//-- 看这个人有哪些演出维度的订单 (支付的、演出id,该用户的。)
if
(
StringUtil
.
isNotBlank
(
smileUser
.
getUid
())){
// //获取 该人 该演出 的所有订单 (6个月)
List
<
Map
>
list1
=
orderTicketsMapper
.
getUserOrder
(
smileUser
.
getUid
());
for
(
Map
a:
list1
){
String
performanceId
=
a
.
get
(
"yanchuId"
)==
null
?
""
:
a
.
get
(
"yanchuId"
).
toString
();
String
yanChuName
=
a
.
get
(
"title"
)==
null
?
""
:
a
.
get
(
"title"
).
toString
();
//获取 该人 该演出 的所有订单
List
<
Map
>
list2
=
orderTicketsMapper
.
getUserSellOneDate
(
smileUser
.
getUid
(),
performanceId
);
ArrayList
<
SellDataOneVO
>
listSellDataOneVo
=
ObjectUtil
.
getSellDataOneVOArrayList
();
for
(
Map
a1:
list2
){
SellDataOneVO
sellDataOneVO
=
SellDataOneVO
.
getNew
();
//票务类型
sellDataOneVO
.
setTicketName
(
a1
.
get
(
"title"
)==
null
?
""
:
a1
.
get
(
"title"
).
toString
());
//数量
sellDataOneVO
.
setTicketNumber
(
a1
.
get
(
"number"
)==
null
?
0
:
Integer
.
parseInt
(
a1
.
get
(
"number"
).
toString
()));
//总金额
sellDataOneVO
.
setSellPrice
(
new
BigDecimal
(
a1
.
get
(
"price"
)==
null
?
"0"
:
a1
.
get
(
"price"
).
toString
()));
//票提
sellDataOneVO
.
setPiaoTi
(
new
BigDecimal
(
a1
.
get
(
"paioTi"
)==
null
?
""
:
a1
.
get
(
"paioTi"
).
toString
()));
//佣金
sellDataOneVO
.
setCommission
(
new
BigDecimal
(
a1
.
get
(
"commiss"
)==
null
?
"0"
:
a1
.
get
(
"commiss"
).
toString
()));
sellDataOneVO
.
setTicketId
(
a1
.
get
(
"ticketId"
)==
null
?
""
:
a1
.
get
(
"ticketId"
).
toString
());
listSellDataOneVo
.
add
(
sellDataOneVO
);
if
(
StringUtils
.
isNotBlank
(
sellDataOneVO
.
getTicketId
())){
setDataDetial
(
smileUser
.
getUid
(),
a1
.
get
(
"ticketId"
).
toString
());
try
{
// //获取 该人 该演出 的所有订单 (6个月)
List
<
Map
>
list1
=
orderTicketsMapper
.
getUserOrder
(
smileUser
.
getUid
());
for
(
Map
a:
list1
){
String
performanceId
=
a
.
get
(
"yanchuId"
)==
null
?
""
:
a
.
get
(
"yanchuId"
).
toString
();
String
yanChuName
=
a
.
get
(
"title"
)==
null
?
""
:
a
.
get
(
"title"
).
toString
();
//获取 该人 该演出 的所有订单
List
<
Map
>
list2
=
orderTicketsMapper
.
getUserSellOneDate
(
smileUser
.
getUid
(),
performanceId
);
ArrayList
<
SellDataOneVO
>
listSellDataOneVo
=
ObjectUtil
.
getSellDataOneVOArrayList
();
for
(
Map
a1:
list2
){
SellDataOneVO
sellDataOneVO
=
SellDataOneVO
.
getNew
();
//票务类型
sellDataOneVO
.
setTicketName
(
a1
.
get
(
"title"
)==
null
?
""
:
a1
.
get
(
"title"
).
toString
());
//数量
sellDataOneVO
.
setTicketNumber
(
a1
.
get
(
"number"
)==
null
?
0
:
Integer
.
parseInt
(
a1
.
get
(
"number"
).
toString
()));
//总金额
sellDataOneVO
.
setSellPrice
(
new
BigDecimal
(
a1
.
get
(
"price"
)==
null
?
"0"
:
a1
.
get
(
"price"
).
toString
()));
//票提
sellDataOneVO
.
setPiaoTi
(
new
BigDecimal
(
a1
.
get
(
"paioTi"
)==
null
?
""
:
a1
.
get
(
"paioTi"
).
toString
()));
//佣金
sellDataOneVO
.
setCommission
(
new
BigDecimal
(
a1
.
get
(
"commiss"
)==
null
?
"0"
:
a1
.
get
(
"commiss"
).
toString
()));
sellDataOneVO
.
setTicketId
(
a1
.
get
(
"ticketId"
)==
null
?
""
:
a1
.
get
(
"ticketId"
).
toString
());
listSellDataOneVo
.
add
(
sellDataOneVO
);
if
(
StringUtils
.
isNotBlank
(
sellDataOneVO
.
getTicketId
())){
setDataDetial
(
smileUser
.
getUid
(),
a1
.
get
(
"ticketId"
).
toString
());
}
}
}
Map
allDate
=
orderTicketsMapper
.
getUserSellAllDate
(
smileUser
.
getUid
(),
performanceId
);
SellDataVO
sellDataVO
=
SellDataVO
.
getNew
();
if
(
null
!=
allDate
){
//活动名称 需要再查 目前没有
sellDataVO
.
setDeltag
(
0
);
sellDataVO
.
setSellDataId
(
smileUser
.
getUid
().
concat
(
performanceId
));
sellDataVO
.
setActiveName
(
yanChuName
);
sellDataVO
.
setSellAmount
(
new
BigDecimal
(
allDate
.
get
(
"price"
)==
null
?
"0"
:
allDate
.
get
(
"price"
).
toString
()));
sellDataVO
.
setSellNumber
(
new
BigDecimal
(
allDate
.
get
(
"number"
)==
null
?
"0"
:
allDate
.
get
(
"number"
).
toString
()));
sellDataVO
.
setTotalCommission
(
new
BigDecimal
(
allDate
.
get
(
"commiss"
)==
null
?
"0"
:
allDate
.
get
(
"commiss"
).
toString
()));
sellDataVO
.
setSellDataOneVO
(
listSellDataOneVo
);
//redis 里面放入
redisDataSourceUtil
.
getRedisSweetUtil
().
set
(
SmileRedisConst
.
SELL_DATA
.
concat
(
smileUser
.
getUid
()).
concat
(
performanceId
),
sellDataVO
);
if
(
mongoTemplate
.
exists
(
Query
.
query
(
Criteria
.
where
(
"sellDataId"
).
is
(
sellDataVO
.
getSellDataId
())),
SellDataVO
.
class
,
SellDataVO
.
class
.
getSimpleName
())){
mongoTemplate
.
remove
(
Query
.
query
(
Criteria
.
where
(
"sellDataId"
).
is
(
sellDataVO
.
getSellDataId
())),
SellDataVO
.
class
,
SellDataVO
.
class
.
getSimpleName
());
Map
allDate
=
orderTicketsMapper
.
getUserSellAllDate
(
smileUser
.
getUid
(),
performanceId
);
SellDataVO
sellDataVO
=
SellDataVO
.
getNew
();
if
(
null
!=
allDate
){
//活动名称 需要再查 目前没有
sellDataVO
.
setDeltag
(
0
);
sellDataVO
.
setSellDataId
(
smileUser
.
getUid
().
concat
(
performanceId
));
sellDataVO
.
setActiveName
(
yanChuName
);
sellDataVO
.
setSellAmount
(
new
BigDecimal
(
allDate
.
get
(
"price"
)==
null
?
"0"
:
allDate
.
get
(
"price"
).
toString
()));
sellDataVO
.
setSellNumber
(
new
BigDecimal
(
allDate
.
get
(
"number"
)==
null
?
"0"
:
allDate
.
get
(
"number"
).
toString
()));
sellDataVO
.
setTotalCommission
(
new
BigDecimal
(
allDate
.
get
(
"commiss"
)==
null
?
"0"
:
allDate
.
get
(
"commiss"
).
toString
()));
sellDataVO
.
setSellDataOneVO
(
listSellDataOneVo
);
//redis 里面放入
redisDataSourceUtil
.
getRedisSweetUtil
().
set
(
SmileRedisConst
.
SELL_DATA
.
concat
(
smileUser
.
getUid
()).
concat
(
performanceId
),
sellDataVO
);
if
(
mongoTemplate
.
exists
(
Query
.
query
(
Criteria
.
where
(
"sellDataId"
).
is
(
sellDataVO
.
getSellDataId
())),
SellDataVO
.
class
,
SellDataVO
.
class
.
getSimpleName
())){
mongoTemplate
.
remove
(
Query
.
query
(
Criteria
.
where
(
"sellDataId"
).
is
(
sellDataVO
.
getSellDataId
())),
SellDataVO
.
class
,
SellDataVO
.
class
.
getSimpleName
());
}
//mongodb 里面放入
mongoTemplate
.
insert
(
sellDataVO
,
SellDataVO
.
class
.
getSimpleName
());
}
//mongodb 里面放入
mongoTemplate
.
insert
(
sellDataVO
,
SellDataVO
.
class
.
getSimpleName
());
}
}
}
catch
(
Exception
e
){
log
.
info
(
String
.
valueOf
(
e
));
log
.
info
(
"用户的uid{}"
,
smileUser
.
getUid
());
}
}
}
...
...
@@ -147,8 +153,8 @@ public class SellDataInfoImpl {
//已结算(已完成)
a
.
put
(
"status"
,
"3"
);
}
else
{
java
.
sql
.
Timestamp
timeEnd
=
(
java
.
sql
.
Timestamp
)
a
.
get
(
"timeEnd"
);
if
(
null
!=
timeEnd
){
if
(
null
!=
a
.
get
(
"timeEnd"
)){
java
.
sql
.
Timestamp
timeEnd
=
(
java
.
sql
.
Timestamp
)
a
.
get
(
"timeEnd"
);
if
(
timeEnd
.
after
(
new
Date
(
System
.
currentTimeMillis
()))){
//待入账(项目未结束)
a
.
put
(
"status"
,
"1"
);
...
...
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