记得上下班打卡 | 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
e42033b7
Commit
e42033b7
authored
Oct 15, 2021
by
刘喆
Browse files
Options
Browse Files
Download
Plain Diff
Merge branch 'pre' into 'k8s-test'
Pre See merge request
!86
parents
ac35561f
79482ac8
Changes
7
Hide whitespace changes
Inline
Side-by-side
Showing
7 changed files
with
29 additions
and
14 deletions
+29
-14
add1.html
...n/resources/templates/zhengzai/candy/coupon/mgt/add1.html
+2
-2
add101.html
...resources/templates/zhengzai/candy/coupon/mgt/add101.html
+2
-2
add2.html
...n/resources/templates/zhengzai/candy/coupon/mgt/add2.html
+2
-2
add3.html
...n/resources/templates/zhengzai/candy/coupon/mgt/add3.html
+2
-2
ChimePerformanceServiceImpl.java
...rvice/chime/service/impl/ChimePerformanceServiceImpl.java
+7
-0
PerformancesExpressCallbackServiceImpl.java
...ress/shunfeng/PerformancesExpressCallbackServiceImpl.java
+3
-0
SweetWechatActionCallbackController.java
...sweet/controller/SweetWechatActionCallbackController.java
+11
-6
No files found.
liquidnet-bus-client/liquidnet-client-admin/liquidnet-client-admin-web/src/main/resources/templates/zhengzai/candy/coupon/mgt/add1.html
View file @
e42033b7
...
...
@@ -328,7 +328,7 @@
filterData
.
reduce
((
cur
,
next
)
=>
{
if
(
!
obj
[
next
.
timeId
])
{
obj
[
next
.
timeId
]
=
true
str
+=
`<option value='
${
next
.
timeId
}
' label=
${
next
.
timeTitle
}
>
${
next
.
timeTitle
}
</option>`
str
+=
`<option value='
${
next
.
timeId
}
' label=
'
${
next
.
timeTitle
}
'
>
${
next
.
timeTitle
}
</option>`
}
},
[])
selectTwoId
=
''
;
// 选中演出下级的ID
...
...
@@ -368,7 +368,7 @@
let
str
=
`<option value="0" label="" >所有</option>`
;
searchData
.
forEach
(
item
=>
{
if
(
item
.
timeId
==
selectTwoId
)
{
str
+=
`<option value='
${
item
.
ticketId
}
' label=
${
item
.
ticketTitle
}
>
${
item
.
ticketTitle
}
</option>`
str
+=
`<option value='
${
item
.
ticketId
}
' label=
'
${
item
.
ticketTitle
}
'
>
${
item
.
ticketTitle
}
</option>`
}
})
selectThreeId
=
''
;
// 选中演出三级的ID
...
...
liquidnet-bus-client/liquidnet-client-admin/liquidnet-client-admin-web/src/main/resources/templates/zhengzai/candy/coupon/mgt/add101.html
View file @
e42033b7
...
...
@@ -309,7 +309,7 @@
let
str
=
`<option value="0" label="">所有</option>`
;
searchData
.
forEach
(
item
=>
{
if
(
item
.
performancesId
==
id
)
{
str
+=
`<option value='
${
item
.
timeId
}
' label=
${
item
.
timeTitle
}
>
${
item
.
timeTitle
}
</option>`
str
+=
`<option value='
${
item
.
timeId
}
' label=
'
${
item
.
timeTitle
}
'
>
${
item
.
timeTitle
}
</option>`
}
})
selectTwoId
=
''
;
// 选中演出下级的ID
...
...
@@ -343,7 +343,7 @@
let
str
=
`<option value="0" label="" >所有</option>`
;
searchData
.
forEach
(
item
=>
{
if
(
item
.
timeId
==
selectTwoId
)
{
str
+=
`<option value='
${
item
.
ticketId
}
' label=
${
item
.
ticketTitle
}
>
${
item
.
ticketTitle
}
</option>`
str
+=
`<option value='
${
item
.
ticketId
}
' label=
'
${
item
.
ticketTitle
}
'
>
${
item
.
ticketTitle
}
</option>`
}
})
selectThreeId
=
''
;
// 选中演出三级的ID
...
...
liquidnet-bus-client/liquidnet-client-admin/liquidnet-client-admin-web/src/main/resources/templates/zhengzai/candy/coupon/mgt/add2.html
View file @
e42033b7
...
...
@@ -329,7 +329,7 @@
filterData
.
reduce
((
cur
,
next
)
=>
{
if
(
!
obj
[
next
.
timeId
])
{
obj
[
next
.
timeId
]
=
true
str
+=
`<option value='
${
next
.
timeId
}
' label=
${
next
.
timeTitle
}
>
${
next
.
timeTitle
}
</option>`
str
+=
`<option value='
${
next
.
timeId
}
' label=
'
${
next
.
timeTitle
}
'
>
${
next
.
timeTitle
}
</option>`
}
},
[])
selectTwoId
=
''
;
// 选中演出下级的ID
...
...
@@ -369,7 +369,7 @@
let
str
=
`<option value="0" label="" >所有</option>`
;
searchData
.
forEach
(
item
=>
{
if
(
item
.
timeId
==
selectTwoId
)
{
str
+=
`<option value='
${
item
.
ticketId
}
' label=
${
item
.
ticketTitle
}
>
${
item
.
ticketTitle
}
</option>`
str
+=
`<option value='
${
item
.
ticketId
}
' label=
'
${
item
.
ticketTitle
}
'
>
${
item
.
ticketTitle
}
</option>`
}
})
selectThreeId
=
''
;
// 选中演出三级的ID
...
...
liquidnet-bus-client/liquidnet-client-admin/liquidnet-client-admin-web/src/main/resources/templates/zhengzai/candy/coupon/mgt/add3.html
View file @
e42033b7
...
...
@@ -246,7 +246,7 @@
filterData
.
reduce
((
cur
,
next
)
=>
{
if
(
!
obj
[
next
.
timeId
])
{
obj
[
next
.
timeId
]
=
true
str
+=
`<option value='
${
next
.
timeId
}
' label=
${
next
.
timeTitle
}
>
${
next
.
timeTitle
}
</option>`
str
+=
`<option value='
${
next
.
timeId
}
' label=
'
${
next
.
timeTitle
}
'
>
${
next
.
timeTitle
}
</option>`
}
},
[])
selectTwoId
=
''
;
// 选中演出下级的ID
...
...
@@ -279,7 +279,7 @@
let
str
=
`<option value="0" label="" >所有</option>`
;
searchData
.
forEach
(
item
=>
{
if
(
item
.
timeId
==
selectTwoId
)
{
str
+=
`<option value='
${
item
.
ticketId
}
' label=
${
item
.
ticketTitle
}
>
${
item
.
ticketTitle
}
</option>`
str
+=
`<option value='
${
item
.
ticketId
}
' label=
'
${
item
.
ticketTitle
}
'
>
${
item
.
ticketTitle
}
</option>`
}
})
selectThreeId
=
''
;
// 选中演出三级的ID
...
...
liquidnet-bus-service/liquidnet-service-chime/liquidnet-service-chime-impl/src/main/java/com/liquidnet/service/chime/service/impl/ChimePerformanceServiceImpl.java
View file @
e42033b7
...
...
@@ -17,6 +17,7 @@ import lombok.extern.slf4j.Slf4j;
import
org.springframework.beans.factory.annotation.Autowired
;
import
org.springframework.data.domain.PageRequest
;
import
org.springframework.data.domain.Pageable
;
import
org.springframework.data.domain.Sort
;
import
org.springframework.data.mongodb.core.MongoTemplate
;
import
org.springframework.data.mongodb.core.query.Criteria
;
import
org.springframework.data.mongodb.core.query.Query
;
...
...
@@ -24,6 +25,7 @@ import org.springframework.stereotype.Service;
import
java.util.ArrayList
;
import
java.util.Arrays
;
import
java.util.Collections
;
import
java.util.List
;
import
java.util.stream.Collectors
;
...
...
@@ -90,9 +92,14 @@ public class ChimePerformanceServiceImpl implements IChimePerformanceService {
Pageable
pageable
=
PageRequest
.
of
(
pageNum
,
pageSize
);
// get 5 profiles on a page
Query
query
=
Query
.
query
(
criteria
);
query
.
with
(
pageable
);
query
.
with
(
Sort
.
by
(
//根据集合中对象的某个字段排序
Sort
.
Order
.
desc
(
"createdAt"
)
));
startTime
=
System
.
currentTimeMillis
();
List
<
ChimeUserInfoVo
>
chimeUserInfoVoList
=
mongoTemplate
.
find
(
query
,
ChimeUserInfoVo
.
class
,
ChimeUserInfoVo
.
class
.
getSimpleName
());
//打乱排序
Collections
.
shuffle
(
chimeUserInfoVoList
);
endTime
=
System
.
currentTimeMillis
();
log
.
info
(
"查询标签数据 分页数据 耗时:{}ms"
,
endTime
-
startTime
);
...
...
liquidnet-bus-service/liquidnet-service-platform/liquidnet-service-platform-impl/src/main/java/com/liquidnet/service/platform/service/express/shunfeng/PerformancesExpressCallbackServiceImpl.java
View file @
e42033b7
...
...
@@ -64,6 +64,7 @@ public class PerformancesExpressCallbackServiceImpl extends ServiceImpl<KylinOrd
private
DataUtils
dataUtils
;
public
boolean
orderStatus
(
@RequestBody
String
params
)
{
log
.
info
(
"接收ExpressOrderStatus请求:[params={}]"
,
params
);
boolean
res
=
shunfengSignUtils
.
receiveRequestAndCheckSign
(
params
,
httpServletRequest
);
if
(
res
)
{
PerformanceExpressPushStatusParam
performanceExpressPushStatusParam
=
JsonUtils
.
fromJson
(
params
,
PerformanceExpressPushStatusParam
.
class
);
...
...
@@ -90,6 +91,7 @@ public class PerformancesExpressCallbackServiceImpl extends ServiceImpl<KylinOrd
}
public
boolean
orderFreightList
(
@RequestBody
String
params
)
{
log
.
info
(
"接收ExpressOrderFreightList请求:[params={}]"
,
params
);
boolean
res
=
shunfengSignUtils
.
receiveRequestAndCheckSign
(
params
,
httpServletRequest
);
if
(
res
)
{
PerformanceExpressPushFreightParam
performanceExpressPushFreightParam
=
JsonUtils
.
fromJson
(
params
,
PerformanceExpressPushFreightParam
.
class
);
...
...
@@ -117,6 +119,7 @@ public class PerformancesExpressCallbackServiceImpl extends ServiceImpl<KylinOrd
}
public
boolean
orderRoute
(
@RequestBody
String
params
)
{
log
.
info
(
"接收ExpressOrderRoute请求:[params={}]"
,
params
);
boolean
res
=
shunfengSignUtils
.
receiveRequestAndCheckSign
(
params
,
httpServletRequest
);
// {"id":"123","mailno":"SF1020099313222","orderid":"NEW127745085969203221966686005","acceptTime":"2021-06-20 11:37:33","acceptAddress":"深圳市","remark":"顺丰已收件(测试推送)","opCode":"80","companyId":"557104628450889728","routeAddress":"https://devplatform.zhengzai.tv/platform/performancesExpress/orderRoute"}
if
(
res
)
{
...
...
liquidnet-bus-service/liquidnet-service-sweet/src/main/java/com/liquidnet/service/sweet/controller/SweetWechatActionCallbackController.java
View file @
e42033b7
...
...
@@ -59,13 +59,18 @@ public class SweetWechatActionCallbackController {
@RequestParam
(
name
=
"encrypt_type"
,
required
=
false
)
String
encType
,
@RequestParam
(
name
=
"msg_signature"
,
required
=
false
)
String
msgSignature
)
{
log
.
info
(
"\n接收微信请求:[type=[{}], openid=[{}], [signature=[{}], encType=[{}], msgSignature=[{}],"
+
" timestamp=[{}], nonce=[{}], requestBody=[\n{}\n] "
,
type
,
openid
,
signature
,
encType
,
msgSignature
,
timestamp
,
nonce
,
requestBody
);
if
(!
wechatSignUtils
.
checkSignature
(
signature
,
timestamp
,
nonce
))
{
log
.
info
(
"验签未通过,非法请求,可能属于伪造的请求!"
);
try
{
log
.
info
(
"\n接收微信请求:[type=[{}], openid=[{}], [signature=[{}], encType=[{}], msgSignature=[{}],"
+
" timestamp=[{}], nonce=[{}], requestBody=[\n{}\n] "
,
type
,
openid
,
signature
,
encType
,
msgSignature
,
timestamp
,
nonce
,
requestBody
);
if
(!
wechatSignUtils
.
checkSignature
(
signature
,
timestamp
,
nonce
))
{
log
.
info
(
"验签未通过,非法请求,可能属于伪造的请求!"
);
return
""
;
}
return
sweetWechatCallbackService
.
record
(
requestBody
,
type
,
timestamp
,
nonce
,
encType
,
msgSignature
);
}
catch
(
Exception
e
)
{
log
.
error
(
"用户动作微信回调Exception:[msg=[{}], e=[{}]]"
,
e
.
getMessage
(),
e
);
return
""
;
}
return
sweetWechatCallbackService
.
record
(
requestBody
,
type
,
timestamp
,
nonce
,
encType
,
msgSignature
);
}
}
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