记得上下班打卡 | 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
f7ad99d1
Commit
f7ad99d1
authored
Jul 21, 2021
by
胡佳晨
Browse files
Options
Browse Files
Download
Email Patches
Plain Diff
修改 admin
parent
c351e5a0
Changes
2
Hide whitespace changes
Inline
Side-by-side
Showing
2 changed files
with
44 additions
and
11 deletions
+44
-11
KylinOrderTicketsServiceImpl.java
...vice/order/service/impl/KylinOrderTicketsServiceImpl.java
+29
-9
ObjectUtil.java
...in/java/com/liquidnet/service/order/utils/ObjectUtil.java
+15
-2
No files found.
liquidnet-bus-service/liquidnet-service-order/liquidnet-service-order-impl/src/main/java/com/liquidnet/service/order/service/impl/KylinOrderTicketsServiceImpl.java
View file @
f7ad99d1
...
...
@@ -678,7 +678,7 @@ public class KylinOrderTicketsServiceImpl implements IKylinOrderTicketsOrderServ
map
.
put
(
"changeDate"
,
orderTickets
.
getUpdatedAt
());
mongoTemplate
.
getCollection
(
KylinOrderTicketVo
.
class
.
getSimpleName
()).
updateOne
(
Query
.
query
(
Criteria
.
where
(
"orderTicketsId"
).
is
(
payAgainParam
.
getOrderId
())).
getQueryObject
(),
new
BasicDBObject
(
"$set"
,
mongoConverter
.
convertToMongoType
(
map
))
ObjectUtil
.
cloneBasicDBObject
().
append
(
"$set"
,
mongoConverter
.
convertToMongoType
(
map
))
);
LocalDateTime
strTime
=
orderTicketData
.
getChangeDate
();
...
...
@@ -690,13 +690,28 @@ public class KylinOrderTicketsServiceImpl implements IKylinOrderTicketsOrderServ
sqlsDataA
.
add
(
orderTickets
.
getPayAgainObject
(
strTime
,
strTime
));
sqls
.
add
(
SqlMapping
.
get
(
"kylin_order_ticket_status.payAgain"
));
LinkedList
<
Object
[]>
sqlsDataB
=
ObjectUtil
.
cloneLinkedListObj
();
sqlsDataB
.
add
(
new
Object
[]{
orderTickets
.
getUpdatedAt
(),
orderTickets
.
getOrderTicketsId
(),
strTime
,
strTime
});
Object
[]
objectB
=
ObjectUtil
.
cloneObjectsArray
();
objectB
[
0
]=
orderTickets
.
getUpdatedAt
();
objectB
[
1
]=
orderTickets
.
getOrderTicketsId
();
objectB
[
2
]=
strTime
;
objectB
[
3
]=
strTime
;
sqlsDataB
.
add
(
objectB
);
sqls
.
add
(
SqlMapping
.
get
(
"kylin_order_ticket_relation.payAgain"
));
LinkedList
<
Object
[]>
sqlsDataC
=
ObjectUtil
.
cloneLinkedListObj
();
sqlsDataC
.
add
(
new
Object
[]{
orderTickets
.
getUpdatedAt
(),
orderTickets
.
getOrderTicketsId
(),
strTime
,
strTime
});
Object
[]
objectC
=
ObjectUtil
.
cloneObjectsArray
();
objectC
[
0
]=
orderTickets
.
getUpdatedAt
();
objectC
[
1
]=
orderTickets
.
getOrderTicketsId
();
objectC
[
2
]=
strTime
;
objectC
[
3
]=
strTime
;
sqlsDataC
.
add
(
objectC
);
sqls
.
add
(
SqlMapping
.
get
(
"kylin_order_ticket_entities.payAgain"
));
LinkedList
<
Object
[]>
sqlsDataD
=
ObjectUtil
.
cloneLinkedListObj
();
sqlsDataD
.
add
(
new
Object
[]{
orderTickets
.
getUpdatedAt
(),
orderTickets
.
getOrderTicketsId
(),
strTime
,
strTime
});
Object
[]
objectD
=
ObjectUtil
.
cloneObjectsArray
();
objectD
[
0
]=
orderTickets
.
getUpdatedAt
();
objectD
[
1
]=
orderTickets
.
getOrderTicketsId
();
objectD
[
2
]=
strTime
;
objectD
[
3
]=
strTime
;
sqlsDataD
.
add
(
objectD
);
String
sqlData
=
SqlMapping
.
gets
(
sqls
,
sqlsDataA
,
sqlsDataB
,
sqlsDataC
,
sqlsDataD
);
rabbitTemplate
.
convertAndSend
(
MQConst
.
EXCHANGES_LIQUIDNET_SQL_ORDER_AGAIN
,
MQConst
.
ROUTING_KEY_SQL_ORDER_AGAIN
,
sqlData
);
...
...
@@ -783,7 +798,12 @@ public class KylinOrderTicketsServiceImpl implements IKylinOrderTicketsOrderServ
sqlsDataB
.
add
(
orderTicketStatus
.
getSynOrderObject
(
strTime
,
strTime
));
sqls
.
add
(
SqlMapping
.
get
(
"kylin_order_ticket_relation.synPay"
));
sqlsDataC
.
add
(
new
Object
[]{
orderTickets
.
getUpdatedAt
(),
orderTickets
.
getOrderTicketsId
(),
strTime
,
strTime
});
Object
[]
objectC
=
ObjectUtil
.
cloneObjectsArray
();
objectC
[
0
]=
orderTickets
.
getUpdatedAt
();
objectC
[
1
]=
orderTickets
.
getOrderTicketsId
();
objectC
[
2
]=
strTime
;
objectC
[
3
]=
strTime
;
sqlsDataC
.
add
(
objectC
);
orderTicketEntities
.
setOrderId
(
orderTicketData
.
getOrderTicketsId
());
orderTicketEntities
.
setIsPayment
(
KylinTableStatusConst
.
ENTITIES_IS_PAYMENT1
);
...
...
@@ -803,7 +823,7 @@ public class KylinOrderTicketsServiceImpl implements IKylinOrderTicketsOrderServ
orderTicketVo
.
put
(
"changeDate"
,
now
);
mongoTemplate
.
getCollection
(
KylinOrderTicketVo
.
class
.
getSimpleName
()).
updateOne
(
Query
.
query
(
Criteria
.
where
(
"orderTicketsId"
).
is
(
orderTickets
.
getOrderTicketsId
())).
getQueryObject
(),
new
BasicDBObject
(
"$set"
,
mongoConverter
.
convertToMongoType
(
orderTicketVo
))
ObjectUtil
.
cloneBasicDBObject
().
append
(
"$set"
,
mongoConverter
.
convertToMongoType
(
orderTicketVo
))
);
...
...
@@ -813,7 +833,7 @@ public class KylinOrderTicketsServiceImpl implements IKylinOrderTicketsOrderServ
orderTicketEntitiesVo
.
put
(
"changeDate"
,
now
);
mongoTemplate
.
getCollection
(
KylinOrderTicketEntitiesVo
.
class
.
getSimpleName
()).
updateMany
(
Query
.
query
(
Criteria
.
where
(
"orderId"
).
is
(
orderTicketData
.
getOrderTicketsId
())).
getQueryObject
(),
new
BasicDBObject
(
"$set"
,
mongoConverter
.
convertToMongoType
(
orderTicketEntitiesVo
))
ObjectUtil
.
cloneBasicDBObject
().
append
(
"$set"
,
mongoConverter
.
convertToMongoType
(
orderTicketEntitiesVo
))
);
rabbitTemplate
.
convertAndSend
(
MQConst
.
EXCHANGES_LIQUIDNET_SQL_ORDER_PAY
,
MQConst
.
ROUTING_KEY_SQL_ORDER_PAY
,
...
...
@@ -928,7 +948,7 @@ public class KylinOrderTicketsServiceImpl implements IKylinOrderTicketsOrderServ
KylinOrderTicketVo
orderVo
=
dataUtils
.
getOrderTicketVo
(
orderId
);
List
<
KylinOrderTicketEntitiesVo
>
listData
=
orderVo
.
getEntitiesVoList
();
AlibabaDamaiMevOpenBatchpushticketRequest
req
=
new
AlibabaDamaiMevOpenBatchpushticketRequest
();
List
<
AlibabaDamaiMevOpenBatchpushticketRequest
.
ThirdTicketPushOpenParam
>
list2
=
new
ArrayList
<
AlibabaDamaiMevOpenBatchpushticketRequest
.
ThirdTicketPushOpenParam
>();
List
<
AlibabaDamaiMevOpenBatchpushticketRequest
.
ThirdTicketPushOpenParam
>
list2
=
new
ArrayList
<>();
for
(
int
i
=
0
;
i
<
listData
.
size
();
i
++)
{
KylinOrderTicketEntitiesVo
item
=
listData
.
get
(
i
);
AlibabaDamaiMevOpenBatchpushticketRequest
.
ThirdTicketPushOpenParam
obj3
=
new
AlibabaDamaiMevOpenBatchpushticketRequest
.
ThirdTicketPushOpenParam
();
...
...
@@ -937,7 +957,7 @@ public class KylinOrderTicketsServiceImpl implements IKylinOrderTicketsOrderServ
obj3
.
setCertificateNo
(
item
.
getEnterIdCode
());
//证件号 入场人身份证
obj3
.
setOrderUserMobile
(
item
.
getEnterMobile
());
//用户手机号 入场人手机号
obj3
.
setCertificateType
(
item
.
getEnterType
().
longValue
());
//证件内容 入场人证件type
obj3
.
setPayTime
(
DateUtil
s
.
parseDate
(
orderData
.
getTimePay
(),
new
String
[]{
"yyyy-MM-dd HH:mm:ss"
}
));
//支付时间
obj3
.
setPayTime
(
DateUtil
.
parse
(
orderData
.
getTimePay
(),
"yyyy-MM-dd HH:mm:ss"
));
//支付时间
obj3
.
setPerformId
(
item
.
getTimemId
().
longValue
());
//场次id
obj3
.
setTicketItemId
(
item
.
getTicketsmId
().
longValue
());
obj3
.
setVoucherId
(
item
.
getMid
().
longValue
());
//票单号 入场人id
...
...
liquidnet-bus-service/liquidnet-service-order/liquidnet-service-order-impl/src/main/java/com/liquidnet/service/order/utils/ObjectUtil.java
View file @
f7ad99d1
package
com
.
liquidnet
.
service
.
order
.
utils
;
import
com.liquidnet.service.adam.dto.vo.AdamEntersVo
;
import
com.mongodb.BasicDBObject
;
import
org.springframework.stereotype.Component
;
import
org.springframework.util.LinkedMultiValueMap
;
...
...
@@ -25,7 +26,10 @@ public class ObjectUtil {
public
static
final
HashMap
<
String
,
String
>
hashMapStringAndString
=
new
HashMap
<
String
,
String
>();
public
static
final
HashMap
<
String
,
Object
>
hashMapStringAndObject
=
new
HashMap
<
String
,
Object
>();
public
static
final
List
<
AdamEntersVo
>
arrayListObject
=
new
ArrayList
<>();
public
static
final
LinkedMultiValueMap
<
String
,
String
>
linkedMultiValueMapStringAndString
=
new
LinkedMultiValueMap
<
String
,
String
>();
public
static
final
LinkedMultiValueMap
<
String
,
String
>
linkedMultiValueMapStringAndString
=
new
LinkedMultiValueMap
<
String
,
String
>();
public
static
final
BasicDBObject
basicDBObject
=
new
BasicDBObject
();
public
static
final
Object
[]
objectsArray
=
new
Object
[
100
];
public
static
LinkedList
<
Object
[]>
cloneLinkedListObj
()
{
linkedListObj
.
clear
();
...
...
@@ -52,8 +56,17 @@ public class ObjectUtil {
return
arrayListObject
;
}
public
static
LinkedMultiValueMap
<
String
,
String
>
cloneLinkedMultiValueMapStringAndString
()
{
public
static
LinkedMultiValueMap
<
String
,
String
>
cloneLinkedMultiValueMapStringAndString
()
{
linkedMultiValueMapStringAndString
.
clear
();
return
linkedMultiValueMapStringAndString
;
}
public
static
Object
[]
cloneObjectsArray
()
{
return
objectsArray
.
clone
();
}
public
static
BasicDBObject
cloneBasicDBObject
()
{
basicDBObject
.
clear
();
return
basicDBObject
;
}
}
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