Skip to content
GitLab
Explore
Sign in
Register
Primary navigation
Search or go to…
Project
proxy-manager-backend
Manage
Activity
Members
Labels
Plan
Issues
Issue boards
Milestones
Wiki
Code
Merge requests
Repository
Branches
Commits
Tags
Repository graph
Compare revisions
Snippets
Build
Pipelines
Jobs
Pipeline schedules
Artifacts
Deploy
Releases
Package registry
Container registry
Model registry
Operate
Environments
Terraform modules
Monitor
Incidents
Analyze
Value stream analytics
Contributor analytics
CI/CD analytics
Repository analytics
Model experiments
Help
Help
Support
GitLab documentation
Compare GitLab plans
GitLab community forum
Contribute to GitLab
Provide feedback
Terms and privacy
Keyboard shortcuts
?
Snippets
Groups
Projects
Show more breadcrumbs
aolda
proxy-manager-backend
Merge requests
!11
Feat/log 사용자 CUD 활동 로그 생성 및 조회
Code
Review changes
Check out branch
Download
Patches
Plain diff
Expand sidebar
Closed
Feat/log 사용자 CUD 활동 로그 생성 및 조회
feat/log
into
dev
Overview
0
Commits
4
Pipelines
0
Changes
26
Closed
천 진강
requested to merge
feat/log
into
dev
4 months ago
Overview
0
Commits
4
Pipelines
0
Changes
26
변경 사항
사용자 CUD 활동 로그 생성
로그 조회
프로젝트 권한 검증
PR 유형
어떤 변경 사항이 있나요?
새로운 기능 추가
버그 수정
코드에 영향을 주지 않는 변경사항(오타 수정, 탭 사이즈 변경, 변수명 변경)
코드 리팩토링
주석 추가 및 수정
문서 수정
테스트 추가, 테스트 리팩토링
빌드 부분 혹은 패키지 매니저 수정
파일 , 폴더명 , 파일 경로 수정
파일 혹은 폴더 삭제
반영 브랜치
feat/user-> dev
기타
0
0
Merge request reports
Compare
dev
version 1
ad7d22e6
4 months ago
dev (base)
and
latest version
latest version
8207b91f
4 commits,
4 months ago
version 1
ad7d22e6
3 commits,
4 months ago
26 files
+
787
−
67
Side-by-side
Compare changes
Side-by-side
Inline
Show whitespace changes
Show one file at a time
Files
26
src/main/java/com/aolda/itda/aspect/ForwardingLogAspect.java
0 → 100644
+
155
−
0
View file @ 8207b91f
Edit in single-file editor
Open in Web IDE
package
com.aolda.itda.aspect
;
import
com.aolda.itda.dto.forwarding.ForwardingDTO
;
import
com.aolda.itda.entity.forwarding.Forwarding
;
import
com.aolda.itda.entity.log.Action
;
import
com.aolda.itda.entity.log.Log
;
import
com.aolda.itda.entity.log.ObjectType
;
import
com.aolda.itda.entity.user.User
;
import
com.aolda.itda.exception.CustomException
;
import
com.aolda.itda.exception.ErrorCode
;
import
com.aolda.itda.repository.certificate.CertificateRepository
;
import
com.aolda.itda.repository.forwarding.ForwardingRepository
;
import
com.aolda.itda.repository.log.LogRepository
;
import
com.aolda.itda.repository.routing.RoutingRepository
;
import
com.aolda.itda.repository.user.UserRepository
;
import
com.aolda.itda.service.AuthService
;
import
jakarta.persistence.EntityManager
;
import
jakarta.servlet.http.HttpServletRequest
;
import
lombok.RequiredArgsConstructor
;
import
org.aspectj.lang.JoinPoint
;
import
org.aspectj.lang.ProceedingJoinPoint
;
import
org.aspectj.lang.annotation.AfterReturning
;
import
org.aspectj.lang.annotation.Around
;
import
org.aspectj.lang.annotation.Aspect
;
import
org.springframework.stereotype.Component
;
import
org.springframework.transaction.annotation.Transactional
;
import
org.springframework.web.context.request.RequestContextHolder
;
import
org.springframework.web.context.request.ServletRequestAttributes
;
import
java.util.Map
;
import
java.util.Objects
;
@Aspect
@Component
@RequiredArgsConstructor
public
class
ForwardingLogAspect
{
private
final
ForwardingRepository
forwardingRepository
;
private
final
LogRepository
logRepository
;
private
final
EntityManager
entityManager
;
private
final
UserRepository
userRepository
;
/* Create 로깅 */
@AfterReturning
(
pointcut
=
"execution(* com.aolda.itda.service.forwarding.*Service.*create*(..))"
,
returning
=
"result"
)
public
void
createLogging
(
JoinPoint
joinPoint
,
ForwardingDTO
result
)
{
/* 사용자 조회 */
HttpServletRequest
request
=
((
ServletRequestAttributes
)
Objects
.
requireNonNull
(
RequestContextHolder
.
getRequestAttributes
())).
getRequest
();
Map
<
String
,
String
>
tmp
=
(
Map
<
String
,
String
>)
request
.
getAttribute
(
"user"
);
User
user
=
userRepository
.
findByKeystoneId
(
tmp
.
get
(
"id"
)).
orElseThrow
(
()
->
new
CustomException
(
ErrorCode
.
NOT_FOUND_USER
)
);
/* 생성된 엔티티 조회 */
Forwarding
forwarding
=
forwardingRepository
.
findByForwardingIdAndIsDeleted
(
result
.
getId
(),
false
).
orElse
(
null
);
/* 로그 메세지 작성 */
String
description
=
"name: "
+
forwarding
.
getName
()
+
"\n"
+
"serverPort: "
+
forwarding
.
getServerPort
()
+
"\n"
+
"instanceIp: "
+
forwarding
.
getInstanceIp
()
+
"\n"
+
"instancePort: "
+
forwarding
.
getInstancePort
();
/* 로그 엔티티 저장 */
logRepository
.
save
(
Log
.
builder
()
.
user
(
user
)
.
objectType
(
ObjectType
.
FORWARDING
)
.
objectId
(
forwarding
.
getForwardingId
())
.
action
(
Action
.
CREATE
)
.
projectId
(
forwarding
.
getProjectId
())
.
description
(
description
)
.
build
());
}
/* Delete 로깅 */
@AfterReturning
(
pointcut
=
"execution(* com.aolda.itda.service.forwarding.*Service.*delete*(..))"
)
public
void
deleteLogging
(
JoinPoint
joinPoint
)
{
/* 사용자 조회 */
HttpServletRequest
request
=
((
ServletRequestAttributes
)
Objects
.
requireNonNull
(
RequestContextHolder
.
getRequestAttributes
())).
getRequest
();
Map
<
String
,
String
>
tmp
=
(
Map
<
String
,
String
>)
request
.
getAttribute
(
"user"
);
User
user
=
userRepository
.
findByKeystoneId
(
tmp
.
get
(
"id"
)).
orElseThrow
(
()
->
new
CustomException
(
ErrorCode
.
NOT_FOUND_USER
)
);
/* 삭제된 엔티티 조회 */
Object
[]
args
=
joinPoint
.
getArgs
();
Long
id
=
(
Long
)
args
[
0
];
Forwarding
forwarding
=
forwardingRepository
.
findByForwardingIdAndIsDeleted
(
id
,
true
).
orElse
(
null
);
/* 로그 메세지 작성 */
String
description
=
"name: "
+
forwarding
.
getName
()
+
"\n"
+
"serverPort: "
+
forwarding
.
getServerPort
()
+
"\n"
+
"instanceIp: "
+
forwarding
.
getInstanceIp
()
+
"\n"
+
"instancePort: "
+
forwarding
.
getInstancePort
();
/* 로그 엔티티 저장 */
logRepository
.
save
(
Log
.
builder
()
.
user
(
user
)
.
objectType
(
ObjectType
.
FORWARDING
)
.
objectId
(
forwarding
.
getForwardingId
())
.
action
(
Action
.
DELETE
)
.
projectId
(
forwarding
.
getProjectId
())
.
description
(
description
)
.
build
());
}
/* Update(edit) 로깅 */
@Around
(
"execution(* com.aolda.itda.service.forwarding.*Service.*edit*(..))"
)
public
Object
editLogging
(
ProceedingJoinPoint
joinPoint
)
throws
Throwable
{
/* 사용자 조회 */
HttpServletRequest
request
=
((
ServletRequestAttributes
)
Objects
.
requireNonNull
(
RequestContextHolder
.
getRequestAttributes
())).
getRequest
();
Map
<
String
,
String
>
tmp
=
(
Map
<
String
,
String
>)
request
.
getAttribute
(
"user"
);
User
user
=
userRepository
.
findByKeystoneId
(
tmp
.
get
(
"id"
)).
orElseThrow
(
()
->
new
CustomException
(
ErrorCode
.
NOT_FOUND_USER
)
);
/* 변경 전 엔티티 조회 */
Object
[]
args
=
joinPoint
.
getArgs
();
Long
id
=
(
Long
)
args
[
0
];
Forwarding
old
=
forwardingRepository
.
findByForwardingIdAndIsDeleted
(
id
,
false
).
orElse
(
null
);
if
(
old
!=
null
)
{
entityManager
.
detach
(
old
);
}
/* 메소드 진행 */
Object
result
=
joinPoint
.
proceed
();
/* 변경 후 엔티티 조회*/
Forwarding
newObj
=
forwardingRepository
.
findByForwardingIdAndIsDeleted
(
id
,
false
).
orElse
(
null
);
/* 로그 메세지 작성 */
String
description
=
"name: "
+
old
.
getName
()
+
(
old
.
getName
().
equals
(
newObj
.
getName
())
?
""
:
(
" -> "
+
newObj
.
getName
()))
+
"\n"
+
"serverPort: "
+
old
.
getServerPort
()
+
(
old
.
getServerPort
().
equals
(
newObj
.
getServerPort
())
?
""
:
(
" -> "
+
newObj
.
getServerPort
()))
+
"\n"
+
"instanceIp: "
+
old
.
getInstanceIp
()
+
(
old
.
getInstanceIp
().
equals
(
newObj
.
getInstanceIp
())
?
""
:
(
" -> "
+
newObj
.
getInstanceIp
()))
+
"\n"
+
"instancePort: "
+
old
.
getInstancePort
()
+
(
old
.
getInstancePort
().
equals
(
newObj
.
getInstancePort
())
?
""
:
(
" -> "
+
newObj
.
getInstancePort
()));
/* 로그 엔티티 저장 */
logRepository
.
save
(
Log
.
builder
()
.
user
(
user
)
.
objectType
(
ObjectType
.
FORWARDING
)
.
objectId
(
newObj
.
getForwardingId
())
.
action
(
Action
.
UPDATE
)
.
projectId
(
newObj
.
getProjectId
())
.
description
(
description
)
.
build
());
return
result
;
}
}
Loading