Skip to content
Projects
Groups
Snippets
Help
Loading...
Help
Support
Submit feedback
Contribute to GitLab
Sign in
Toggle navigation
A
asset-distribution
Project
Project
Details
Activity
Releases
Cycle Analytics
Repository
Repository
Files
Commits
Branches
Tags
Contributors
Graph
Compare
Charts
Issues
0
Issues
0
List
Boards
Labels
Milestones
Merge Requests
0
Merge Requests
0
CI / CD
CI / CD
Pipelines
Jobs
Schedules
Charts
Wiki
Wiki
Members
Members
Collapse sidebar
Close sidebar
Activity
Graph
Charts
Create a new issue
Jobs
Commits
Issue Boards
Open sidebar
data-spider
asset-distribution
Commits
7dc79a33
Commit
7dc79a33
authored
Sep 24, 2021
by
王业雄
Browse files
Options
Browse Files
Download
Email Patches
Plain Diff
fix
parent
2ef0e060
Changes
4
Hide whitespace changes
Inline
Side-by-side
Showing
4 changed files
with
10 additions
and
13 deletions
+10
-13
CrosFilter.java
.../com/quantgroup/asset/distribution/config/CrosFilter.java
+0
-2
WebMvcConfigure.java
...tgroup/asset/distribution/config/web/WebMvcConfigure.java
+0
-1
IChannelRuleRepository.java
...bution/service/jpa/repository/IChannelRuleRepository.java
+3
-3
ChannelRouteServiceImpl.java
...tribution/service/route/impl/ChannelRouteServiceImpl.java
+7
-7
No files found.
src/main/java/com/quantgroup/asset/distribution/config/CrosFilter.java
View file @
7dc79a33
...
@@ -46,11 +46,9 @@ public class CrosFilter implements Filter {
...
@@ -46,11 +46,9 @@ public class CrosFilter implements Filter {
"Accept,Access-Token,Account,Account-Name,Referer,sec-ch-ua,sec-ch-ua-mobile,sec-ch-ua-platform,User-Agent"
;
"Accept,Access-Token,Account,Account-Name,Referer,sec-ch-ua,sec-ch-ua-mobile,sec-ch-ua-platform,User-Agent"
;
response
.
setHeader
(
"Access-Control-Allow-Headers"
,
allowedHeaders
);
response
.
setHeader
(
"Access-Control-Allow-Headers"
,
allowedHeaders
);
response
.
setHeader
(
"Access-Control-Max-Age"
,
"3600"
);
response
.
setHeader
(
"Access-Control-Max-Age"
,
"3600"
);
log
.
info
(
"doFilter | 前端请求过滤,请求方法{},请求路径{}"
,
request
.
getMethod
(),
request
.
getRequestURI
());
if
(
DISALLOWED_METHOD
.
contains
(
request
.
getMethod
()))
{
if
(
DISALLOWED_METHOD
.
contains
(
request
.
getMethod
()))
{
return
;
return
;
}
}
log
.
info
(
"doFilter | 前端请求过滤,请求方法{}"
,
request
.
getMethod
());
filterChain
.
doFilter
(
servletRequest
,
servletResponse
);
filterChain
.
doFilter
(
servletRequest
,
servletResponse
);
}
}
...
...
src/main/java/com/quantgroup/asset/distribution/config/web/WebMvcConfigure.java
View file @
7dc79a33
...
@@ -32,7 +32,6 @@ public class WebMvcConfigure extends WebMvcConfigurerAdapter {
...
@@ -32,7 +32,6 @@ public class WebMvcConfigure extends WebMvcConfigurerAdapter {
@Override
@Override
public
void
addCorsMappings
(
CorsRegistry
registry
)
{
public
void
addCorsMappings
(
CorsRegistry
registry
)
{
log
.
info
(
"addCorsMappings | 前端请求过滤"
);
registry
.
addMapping
(
"/**"
)
registry
.
addMapping
(
"/**"
)
.
allowedOrigins
(
"*"
)
.
allowedOrigins
(
"*"
)
.
allowedMethods
(
"HEAD"
,
"GET"
,
"POST"
)
.
allowedMethods
(
"HEAD"
,
"GET"
,
"POST"
)
...
...
src/main/java/com/quantgroup/asset/distribution/service/jpa/repository/IChannelRuleRepository.java
View file @
7dc79a33
...
@@ -11,12 +11,12 @@ public interface IChannelRuleRepository extends JpaRepository<ChannelRuleEntity,
...
@@ -11,12 +11,12 @@ public interface IChannelRuleRepository extends JpaRepository<ChannelRuleEntity,
List
<
ChannelRuleEntity
>
getByChannelId
(
long
channelId
);
List
<
ChannelRuleEntity
>
getByChannelId
(
long
channelId
);
List
<
ChannelRuleEntity
>
getAllByEnableEquals
(
B
yte
enable
);
List
<
ChannelRuleEntity
>
getAllByEnableEquals
(
B
oolean
enable
);
List
<
ChannelRuleEntity
>
getAllByChannelIdEqualsAndEnableEquals
(
Long
channelId
,
B
yte
enable
);
List
<
ChannelRuleEntity
>
getAllByChannelIdEqualsAndEnableEquals
(
Long
channelId
,
B
oolean
enable
);
List
<
ChannelRuleEntity
>
getAllByIdIn
(
List
<
Long
>
ids
);
List
<
ChannelRuleEntity
>
getAllByIdIn
(
List
<
Long
>
ids
);
void
deleteAllByChannelIdEqualsAndEnableEquals
(
Long
channelId
,
B
yte
enable
);
void
deleteAllByChannelIdEqualsAndEnableEquals
(
Long
channelId
,
B
oolean
enable
);
}
}
src/main/java/com/quantgroup/asset/distribution/service/route/impl/ChannelRouteServiceImpl.java
View file @
7dc79a33
...
@@ -54,7 +54,7 @@ public class ChannelRouteServiceImpl implements IChannelRouteService {
...
@@ -54,7 +54,7 @@ public class ChannelRouteServiceImpl implements IChannelRouteService {
booleanExpression
=
booleanExpression
.
and
(
QChannelRuleEntity
.
channelRuleEntity
.
publishStatus
.
eq
(
channelRouteQueryVo
.
getPublishStatus
()));
booleanExpression
=
booleanExpression
.
and
(
QChannelRuleEntity
.
channelRuleEntity
.
publishStatus
.
eq
(
channelRouteQueryVo
.
getPublishStatus
()));
}
}
//只查有效数据
//只查有效数据
booleanExpression
=
booleanExpression
.
and
(
QChannelRuleEntity
.
channelRuleEntity
.
enable
);
booleanExpression
=
booleanExpression
.
and
(
QChannelRuleEntity
.
channelRuleEntity
.
enable
.
eq
(
Boolean
.
TRUE
)
);
//1.查询条件,2.索引和每页的大小,3.排序根据某个字段进行排序
//1.查询条件,2.索引和每页的大小,3.排序根据某个字段进行排序
//查询总条数
//查询总条数
...
@@ -98,7 +98,7 @@ public class ChannelRouteServiceImpl implements IChannelRouteService {
...
@@ -98,7 +98,7 @@ public class ChannelRouteServiceImpl implements IChannelRouteService {
@Override
@Override
public
List
<
Long
>
queryConfigChannelIds
()
{
public
List
<
Long
>
queryConfigChannelIds
()
{
List
<
ChannelRuleEntity
>
allByEnableEquals
=
channelRuleRepository
.
getAllByEnableEquals
(
B
yte
.
valueOf
(
"1"
)
);
List
<
ChannelRuleEntity
>
allByEnableEquals
=
channelRuleRepository
.
getAllByEnableEquals
(
B
oolean
.
TRUE
);
List
<
Long
>
channelIds
=
new
ArrayList
<>();
List
<
Long
>
channelIds
=
new
ArrayList
<>();
allByEnableEquals
.
stream
().
forEach
(
channelRuleEntity
->
{
allByEnableEquals
.
stream
().
forEach
(
channelRuleEntity
->
{
if
(!
channelIds
.
contains
(
channelRuleEntity
.
getChannelId
())){
if
(!
channelIds
.
contains
(
channelRuleEntity
.
getChannelId
())){
...
@@ -111,7 +111,7 @@ public class ChannelRouteServiceImpl implements IChannelRouteService {
...
@@ -111,7 +111,7 @@ public class ChannelRouteServiceImpl implements IChannelRouteService {
@Override
@Override
public
GlobalResponse
queryConfigChannelInfo
(
Long
channelId
)
{
public
GlobalResponse
queryConfigChannelInfo
(
Long
channelId
)
{
List
<
ChannelConfigInfoVo
>
channelConfigInfoVos
=
new
ArrayList
<>();
List
<
ChannelConfigInfoVo
>
channelConfigInfoVos
=
new
ArrayList
<>();
List
<
ChannelRuleEntity
>
allByChannelIdEqualsaAndEnableEquals
=
channelRuleRepository
.
getAllByChannelIdEqualsAndEnableEquals
(
channelId
,
B
yte
.
valueOf
(
"1"
)
);
List
<
ChannelRuleEntity
>
allByChannelIdEqualsaAndEnableEquals
=
channelRuleRepository
.
getAllByChannelIdEqualsAndEnableEquals
(
channelId
,
B
oolean
.
TRUE
);
if
(
CollectionUtils
.
isEmpty
(
allByChannelIdEqualsaAndEnableEquals
)){
if
(
CollectionUtils
.
isEmpty
(
allByChannelIdEqualsaAndEnableEquals
)){
return
GlobalResponse
.
error
(
"该渠道没有对应的路由配置信息"
);
return
GlobalResponse
.
error
(
"该渠道没有对应的路由配置信息"
);
}
else
{
}
else
{
...
@@ -176,7 +176,7 @@ public class ChannelRouteServiceImpl implements IChannelRouteService {
...
@@ -176,7 +176,7 @@ public class ChannelRouteServiceImpl implements IChannelRouteService {
* 编辑时要去掉所有该渠道有效性为0的其他配置(覆盖之前的未更新编辑信息)
* 编辑时要去掉所有该渠道有效性为0的其他配置(覆盖之前的未更新编辑信息)
*/
*/
if
(
0
!=
type
){
if
(
0
!=
type
){
channelRuleRepository
.
deleteAllByChannelIdEqualsAndEnableEquals
(
channelRouteSaveVoList
.
get
(
0
).
getChannelId
(),
B
yte
.
valueOf
(
"0"
)
);
channelRuleRepository
.
deleteAllByChannelIdEqualsAndEnableEquals
(
channelRouteSaveVoList
.
get
(
0
).
getChannelId
(),
B
oolean
.
FALSE
);
}
}
List
<
ChannelRuleEntity
>
channelRuleEntityList
=
getChannelRuleEntityList
(
channelRouteSaveVoList
);
List
<
ChannelRuleEntity
>
channelRuleEntityList
=
getChannelRuleEntityList
(
channelRouteSaveVoList
);
...
@@ -210,7 +210,7 @@ public class ChannelRouteServiceImpl implements IChannelRouteService {
...
@@ -210,7 +210,7 @@ public class ChannelRouteServiceImpl implements IChannelRouteService {
@Override
@Override
public
void
publishChannelConfig
(
Long
channelId
)
{
public
void
publishChannelConfig
(
Long
channelId
)
{
List
<
ChannelRuleEntity
>
all
=
channelRuleRepository
.
getAllByChannelIdEqualsAndEnableEquals
(
channelId
,
B
yte
.
valueOf
(
"1"
)
);
List
<
ChannelRuleEntity
>
all
=
channelRuleRepository
.
getAllByChannelIdEqualsAndEnableEquals
(
channelId
,
B
oolean
.
TRUE
);
all
.
stream
().
forEach
(
channelRuleEntity
->
{
all
.
stream
().
forEach
(
channelRuleEntity
->
{
channelRuleEntity
.
setPublishStatus
(
1
);
channelRuleEntity
.
setPublishStatus
(
1
);
...
@@ -221,8 +221,8 @@ public class ChannelRouteServiceImpl implements IChannelRouteService {
...
@@ -221,8 +221,8 @@ public class ChannelRouteServiceImpl implements IChannelRouteService {
@Override
@Override
@Transactional
@Transactional
public
void
updateChannelConfig
(
Long
channelId
)
{
public
void
updateChannelConfig
(
Long
channelId
)
{
channelRuleRepository
.
deleteAllByChannelIdEqualsAndEnableEquals
(
channelId
,
B
yte
.
valueOf
(
"1"
)
);
channelRuleRepository
.
deleteAllByChannelIdEqualsAndEnableEquals
(
channelId
,
B
oolean
.
TRUE
);
List
<
ChannelRuleEntity
>
allByChannelIdEqualsAndEnableEquals
=
channelRuleRepository
.
getAllByChannelIdEqualsAndEnableEquals
(
channelId
,
B
yte
.
valueOf
(
"0"
)
);
List
<
ChannelRuleEntity
>
allByChannelIdEqualsAndEnableEquals
=
channelRuleRepository
.
getAllByChannelIdEqualsAndEnableEquals
(
channelId
,
B
oolean
.
FALSE
);
allByChannelIdEqualsAndEnableEquals
.
stream
().
forEach
(
channelRuleEntity
->
{
allByChannelIdEqualsAndEnableEquals
.
stream
().
forEach
(
channelRuleEntity
->
{
channelRuleEntity
.
setEnable
(
true
);
channelRuleEntity
.
setEnable
(
true
);
channelRuleRepository
.
save
(
channelRuleEntity
);
channelRuleRepository
.
save
(
channelRuleEntity
);
...
...
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