Skip to content
Projects
Groups
Snippets
Help
Loading...
Help
Support
Submit feedback
Contribute to GitLab
Sign in
Toggle navigation
C
cash-loan-flow-boss
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
QG
cash-loan-flow-boss
Commits
5634c66d
Commit
5634c66d
authored
Sep 25, 2019
by
suntao
Browse files
Options
Browse Files
Download
Email Patches
Plain Diff
未登录 msg 提示
parent
9bb15646
Changes
8
Show whitespace changes
Inline
Side-by-side
Showing
8 changed files
with
29 additions
and
46 deletions
+29
-46
ChannelConfController.java
...lowboss/api/channel/controller/ChannelConfController.java
+1
-1
OrderController.java
...ashloanflowboss/api/order/controller/OrderController.java
+1
-1
SecurityInterceptor.java
...hloanflowboss/component/security/SecurityInterceptor.java
+1
-2
ChannelRoleCheckAspect.java
.../cashloanflowboss/core/aspect/ChannelRoleCheckAspect.java
+8
-19
ChannelRoleLoadAspect.java
...p/cashloanflowboss/core/aspect/ChannelRoleLoadAspect.java
+5
-17
Result.java
...java/cn/quantgroup/cashloanflowboss/core/base/Result.java
+10
-5
ApplicationSecurityHandler.java
...owboss/core/configuration/ApplicationSecurityHandler.java
+1
-1
ApplicationStatus.java
...p/cashloanflowboss/core/dictionary/ApplicationStatus.java
+2
-0
No files found.
src/main/java/cn/quantgroup/cashloanflowboss/api/channel/controller/ChannelConfController.java
View file @
5634c66d
...
...
@@ -41,7 +41,7 @@ public class ChannelConfController {
@PostMapping
(
"/info"
)
public
Result
channelList
(
Long
channelId
,
String
channelName
,
Integer
pageNumber
,
Integer
pageSize
)
{
if
(
pageNumber
==
null
||
pageSize
==
null
)
{
return
Result
.
buildF
ia
l
(
"page信息不对"
);
return
Result
.
buildF
ai
l
(
"page信息不对"
);
}
return
Result
.
buildSuccess
(
channelConfService
.
getChannelInfo
(
pageNumber
,
pageSize
,
channelId
,
channelName
));
}
...
...
src/main/java/cn/quantgroup/cashloanflowboss/api/order/controller/OrderController.java
View file @
5634c66d
...
...
@@ -45,7 +45,7 @@ public class OrderController {
@GetMapping
(
"/list"
)
public
Result
orderList
(
Long
channelId
,
String
channelOrderNumber
,
String
applyNo
,
Long
loanId
,
Integer
pageNumber
,
Integer
pageSize
)
{
if
(
pageNumber
==
null
||
pageSize
==
null
)
{
return
Result
.
buildF
ia
l
(
"page信息不对"
);
return
Result
.
buildF
ai
l
(
"page信息不对"
);
}
return
Result
.
buildSuccess
(
orderService
.
orderList
(
channelId
,
channelOrderNumber
,
applyNo
,
loanId
,
pageNumber
,
pageSize
));
}
...
...
src/main/java/cn/quantgroup/cashloanflowboss/component/security/SecurityInterceptor.java
View file @
5634c66d
...
...
@@ -3,7 +3,6 @@ package cn.quantgroup.cashloanflowboss.component.security;
import
cn.quantgroup.cashloanflowboss.component.security.annotiation.Security
;
import
cn.quantgroup.cashloanflowboss.core.base.Result
;
import
cn.quantgroup.cashloanflowboss.core.dictionary.ApplicationStatus
;
import
cn.quantgroup.cashloanflowboss.core.exception.ApplicationException
;
import
org.aopalliance.intercept.MethodInterceptor
;
import
org.aopalliance.intercept.MethodInvocation
;
import
org.springframework.context.support.ApplicationObjectSupport
;
...
...
@@ -21,7 +20,7 @@ public class SecurityInterceptor extends ApplicationObjectSupport implements Met
Security
security
=
invocation
.
getMethod
().
getAnnotation
(
Security
.
class
);
if
(!
this
.
getApplicationContext
().
getBean
(
SecurityHandler
.
class
).
doAuthentication
(
invocation
,
security
.
authorityId
(),
security
.
authorities
()))
{
return
Result
.
buildF
ia
l
(
ApplicationStatus
.
INVALID_AUTHORITY
);
return
Result
.
buildF
ai
l
(
ApplicationStatus
.
INVALID_AUTHORITY
);
}
return
invocation
.
proceed
();
...
...
src/main/java/cn/quantgroup/cashloanflowboss/core/aspect/ChannelRoleCheckAspect.java
View file @
5634c66d
...
...
@@ -9,7 +9,6 @@ import cn.quantgroup.cashloanflowboss.spi.clf.entity.ClfOrderMapping;
import
cn.quantgroup.cashloanflowboss.spi.clf.repository.ClfOrderMappingRepository
;
import
lombok.extern.slf4j.Slf4j
;
import
org.apache.commons.lang3.StringUtils
;
import
org.apache.commons.lang3.exception.ExceptionUtils
;
import
org.aspectj.lang.ProceedingJoinPoint
;
import
org.aspectj.lang.annotation.Around
;
import
org.aspectj.lang.annotation.Aspect
;
...
...
@@ -33,7 +32,7 @@ import java.lang.reflect.Method;
@Slf4j
@Component
@Aspect
@Order
(
2
)
@Order
(
4
)
public
class
ChannelRoleCheckAspect
{
...
...
@@ -50,19 +49,14 @@ public class ChannelRoleCheckAspect {
* @param pjp
*/
@Around
(
value
=
"checkRole()"
)
public
Object
checkRoleBefore
(
ProceedingJoinPoint
pjp
)
{
public
Object
checkRoleBefore
(
ProceedingJoinPoint
pjp
)
throws
Throwable
{
Object
[]
args
=
pjp
.
getArgs
();
MethodSignature
methodSignature
=
(
MethodSignature
)
pjp
.
getSignature
();
Method
method
=
methodSignature
.
getMethod
();
Principal
principal
=
Application
.
getPrincipal
();
if
(
principal
==
null
)
{
try
{
return
pjp
.
proceed
(
args
);
}
catch
(
Throwable
throwable
)
{
log
.
error
(
"请求失败,e={}"
,
ExceptionUtils
.
getStackTrace
(
throwable
));
return
Result
.
buildFial
();
}
}
// 如果是渠道用户登陆,参数中channelId 不是登陆用户channelId,返回 拒绝请求
...
...
@@ -74,7 +68,7 @@ public class ChannelRoleCheckAspect {
if
(
StringUtils
.
isAllEmpty
(
channelIdSPEL
,
channelOrderNumberSPEL
))
{
log
.
error
(
"[CheckChannelRole]channelIdSPEL, channelOrderNumberSPEL 不能都为空"
);
return
Result
.
buildF
ia
l
(
ApplicationStatus
.
ARGUMENT_VALID_EXCEPTION
);
return
Result
.
buildF
ai
l
(
ApplicationStatus
.
ARGUMENT_VALID_EXCEPTION
);
}
if
(
principal
.
isChannel
())
{
...
...
@@ -86,7 +80,7 @@ public class ChannelRoleCheckAspect {
if
(!
Application
.
getPrincipal
().
getChannelId
().
equals
(
expression
.
getValue
(
args
,
Long
.
class
)))
{
log
.
info
(
"[CheckChannelRole]渠道用户,登陆channelId与查询channelId不是同一个"
);
return
Result
.
buildF
ia
l
(
ApplicationStatus
.
INVALID_AUTHORITY
);
return
Result
.
buildF
ai
l
(
ApplicationStatus
.
INVALID_AUTHORITY
);
}
}
else
{
log
.
warn
(
"[CheckChannelRole]channelIdSPEL取值失败"
);
...
...
@@ -109,11 +103,11 @@ public class ChannelRoleCheckAspect {
ClfOrderMapping
clfOrderMapping
=
clfOrderMappingRepository
.
findByChannelOrderNoLastOne
(
channelOrderNumber
);
if
(
clfOrderMapping
==
null
)
{
log
.
info
(
"[CheckChannelRoleByChannelOrderNumber]无channelOrderNumber数据,channelOrderNumber={}"
,
channelOrderNumber
);
return
Result
.
buildF
ia
l
(
ApplicationStatus
.
ARGUMENT_VALID_EXCEPTION
,
"未找到该订单"
);
return
Result
.
buildF
ai
l
(
ApplicationStatus
.
ARGUMENT_VALID_EXCEPTION
,
"未找到该订单"
);
}
if
(!
clfOrderMapping
.
getRegisteredFrom
().
equals
(
principal
.
getChannelId
()))
{
log
.
info
(
"[CheckChannelRoleByChannelOrderNumber]不是该渠道的订单,channelOrderNumber={}"
,
channelOrderNumber
);
return
Result
.
buildF
ia
l
(
ApplicationStatus
.
INVALID_AUTHORITY
);
return
Result
.
buildF
ai
l
(
ApplicationStatus
.
INVALID_AUTHORITY
);
}
}
}
...
...
@@ -122,12 +116,7 @@ public class ChannelRoleCheckAspect {
}
try
{
return
pjp
.
proceed
(
args
);
}
catch
(
Throwable
throwable
)
{
log
.
error
(
"请求失败,e={}"
,
ExceptionUtils
.
getStackTrace
(
throwable
));
return
Result
.
buildFial
();
}
}
...
...
src/main/java/cn/quantgroup/cashloanflowboss/core/aspect/ChannelRoleLoadAspect.java
View file @
5634c66d
package
cn
.
quantgroup
.
cashloanflowboss
.
core
.
aspect
;
import
cn.quantgroup.cashloanflowboss.api.channel.util.ChannelConfUtil
;
import
cn.quantgroup.cashloanflowboss.api.login.model.Principal
;
import
cn.quantgroup.cashloanflowboss.core.Application
;
import
cn.quantgroup.cashloanflowboss.core.annotation.channelrole.ChannelIdInit
;
import
cn.quantgroup.cashloanflowboss.core.base.Result
;
import
cn.quantgroup.cashloanflowboss.
utils.JSONTools
;
import
cn.quantgroup.cashloanflowboss.
core.exception.ApplicationException
;
import
lombok.extern.slf4j.Slf4j
;
import
org.apache.commons.lang3.StringUtils
;
import
org.apache.commons.lang3.exception.ExceptionUtils
;
import
org.aspectj.lang.JoinPoint
;
import
org.aspectj.lang.ProceedingJoinPoint
;
import
org.aspectj.lang.annotation.Around
;
import
org.aspectj.lang.annotation.Aspect
;
...
...
@@ -33,7 +31,7 @@ import java.lang.reflect.Method;
@Slf4j
@Component
@Aspect
@Order
(
1
)
@Order
(
3
)
public
class
ChannelRoleLoadAspect
{
@Pointcut
(
"@annotation(cn.quantgroup.cashloanflowboss.core.annotation.channelrole.ChannelIdInit)"
)
...
...
@@ -41,19 +39,14 @@ public class ChannelRoleLoadAspect {
@Around
(
value
=
"channelIdInit()"
)
public
Object
channelIdInitBefore
(
ProceedingJoinPoint
pjp
)
{
public
Object
channelIdInitBefore
(
ProceedingJoinPoint
pjp
)
throws
Throwable
{
Object
[]
args
=
pjp
.
getArgs
();
MethodSignature
methodSignature
=
(
MethodSignature
)
pjp
.
getSignature
();
Method
method
=
methodSignature
.
getMethod
();
Principal
principal
=
Application
.
getPrincipal
();
if
(
principal
==
null
)
{
try
{
return
pjp
.
proceed
(
args
);
}
catch
(
Throwable
throwable
)
{
log
.
error
(
"请求失败,e={}"
,
ExceptionUtils
.
getStackTrace
(
throwable
));
return
Result
.
buildFial
();
}
}
// 如果是渠道用户登陆 默认加载channelId
...
...
@@ -80,12 +73,7 @@ public class ChannelRoleLoadAspect {
}
}
try
{
return
pjp
.
proceed
(
args
);
}
catch
(
Throwable
throwable
)
{
log
.
error
(
"请求失败,e={}"
,
ExceptionUtils
.
getStackTrace
(
throwable
));
return
Result
.
buildFial
();
}
}
}
src/main/java/cn/quantgroup/cashloanflowboss/core/base/Result.java
View file @
5634c66d
...
...
@@ -62,27 +62,32 @@ public class Result<T> {
}
@SuppressWarnings
(
"unchecked"
)
public
static
<
T
>
Result
<
T
>
buildF
ia
l
(
T
data
)
{
public
static
<
T
>
Result
<
T
>
buildF
ai
l
(
T
data
)
{
return
new
Result
(
ApplicationStatus
.
FAILURE
,
data
);
}
@SuppressWarnings
(
"unchecked"
)
public
static
<
T
>
Result
<
T
>
buildFial
(
String
message
)
{
public
static
<
T
>
Result
<
T
>
buildApplicationException
(
T
data
)
{
return
new
Result
(
ApplicationStatus
.
FAILURE
,
data
);
}
@SuppressWarnings
(
"unchecked"
)
public
static
<
T
>
Result
<
T
>
buildFail
(
String
message
)
{
return
new
Result
(
ApplicationStatus
.
FAILURE
,
null
,
message
);
}
@SuppressWarnings
(
"unchecked"
)
public
static
<
T
>
Result
<
T
>
buildF
ia
l
()
{
public
static
<
T
>
Result
<
T
>
buildF
ai
l
()
{
return
new
Result
(
ApplicationStatus
.
FAILURE
,
null
,
null
);
}
@SuppressWarnings
(
"unchecked"
)
public
static
<
T
>
Result
<
T
>
buildF
ia
l
(
ApplicationStatus
applicationStatus
)
{
public
static
<
T
>
Result
<
T
>
buildF
ai
l
(
ApplicationStatus
applicationStatus
)
{
return
new
Result
(
applicationStatus
,
null
,
null
);
}
@SuppressWarnings
(
"unchecked"
)
public
static
<
T
>
Result
<
T
>
buildF
ia
l
(
T
data
,
String
message
)
{
public
static
<
T
>
Result
<
T
>
buildF
ai
l
(
T
data
,
String
message
)
{
return
new
Result
(
ApplicationStatus
.
FAILURE
,
data
,
message
);
}
...
...
src/main/java/cn/quantgroup/cashloanflowboss/core/configuration/ApplicationSecurityHandler.java
View file @
5634c66d
...
...
@@ -29,7 +29,7 @@ public class ApplicationSecurityHandler implements SecurityHandler {
Principal
principal
=
Application
.
getPrincipal
();
// 检查是否已登录
Assert
.
isNull
(
principal
,
ApplicationStatus
.
AUTHENTICATION_
FAILURE
);
Assert
.
isNull
(
principal
,
ApplicationStatus
.
AUTHENTICATION_
LOGIN
);
// 如果是超级管理员跳过权限验证
...
...
src/main/java/cn/quantgroup/cashloanflowboss/core/dictionary/ApplicationStatus.java
View file @
5634c66d
...
...
@@ -25,6 +25,8 @@ public enum ApplicationStatus implements Status<ApplicationStatus> {
JSON_DATA_EXCEPTION
(
500005
,
"无效的JSON数据"
),
AUTHENTICATION_LOGIN
(
500006
,
"请登录..."
),
INVALID_AUTHORITY
(
501001
,
"无效的授权"
),
INVALID_USER
(
501002
,
"无效的用户"
),
...
...
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