my batis 차단기 데이터 암호 화 복호화
25087 단어 필기 하 다.
package com.chashiyu.mybatisPlugin;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.lang.StringUtils;
import org.apache.ibatis.cache.CacheKey;
import org.apache.ibatis.executor.Executor;
import org.apache.ibatis.mapping.BoundSql;
import org.apache.ibatis.mapping.MappedStatement;
import org.apache.ibatis.plugin.*;
import org.apache.ibatis.session.ResultHandler;
import org.apache.ibatis.session.RowBounds;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.stereotype.Component;
import java.lang.reflect.Field;
import java.util.ArrayList;
import java.util.List;
import java.util.Map;
import java.util.Properties;
/**
* Created by shiyu.zha on 2018/11/21
*
*/
@Slf4j
@Component
@Intercepts({
@Signature(type = Executor.class, method = "update", args = {MappedStatement.class, Object.class}),
@Signature(type = Executor.class, method = "query", args = {MappedStatement.class, Object.class, RowBounds.class, ResultHandler.class}),
@Signature(type = Executor.class, method = "query", args = {MappedStatement.class, Object.class, RowBounds.class, ResultHandler.class, CacheKey.class, BoundSql.class})
})
public class MybatisInterceptorByEncrypt implements Interceptor {
@Value("${facepay.data.encryptKey}")
private String encryptKey;
@Override
public Object intercept(Invocation invocation) throws Throwable {
MappedStatement statement = (MappedStatement) invocation.getArgs()[0];
String methodName = invocation.getMethod().getName();
Object parameter = invocation.getArgs()[1];
BoundSql sql = statement.getBoundSql(parameter);
log.debug("======sql is {}", sql.getSql().replaceAll("(
)+", "").replaceAll(" +", " "));
log.debug("======param is {}", JSON.toJSONString(parameter));
//
encryptByOrder(methodName, parameter, sql);
//
Object returnValue = invocation.proceed();
if (returnValue instanceof ArrayList<?>) {
List<?> list = (ArrayList<?>) returnValue;
for (Object val : list) {
decryptByOrder(val);
}
}
return returnValue;
}
private void encryptByOrder(String methodName, Object parameter, BoundSql sql) throws Throwable {
if (!sql.getSql().contains("o_order")) {
return;
}
if (parameter instanceof PayOrder) {
PayOrder payOrder = (PayOrder) parameter;
if (methodName.equals("update")) {
if (StringUtils.isNotBlank(payOrder.getUserBankNumber())) {
payOrder.setUserBankNumber(AESUtils.encrypt(payOrder.getUserBankNumber(), encryptKey));
}
}
}
if (parameter instanceof PayOrderExample) {
PayOrderExample payOrderExample = (PayOrderExample) parameter;
List<PayOrderExample.Criteria> criteriaList = payOrderExample.getOredCriteria();
for (PayOrderExample.Criteria criteria : criteriaList) {
List<PayOrderExample.Criterion> criterionList = criteria.getCriteria();
for (PayOrderExample.Criterion criterion : criterionList) {
if (criterion.getCondition().contains("user_bank_number")) {
Field field = criterion.getClass().getDeclaredField("value");
field.setAccessible(true);
field.set(criterion, AESUtils.encrypt(String.valueOf(criterion.getValue()), encryptKey));
}
}
}
}
}
private void decryptByOrder(Object val) throws Throwable {
if (val instanceof PayOrder) {
PayOrder payOrder = (PayOrder) val;
if(payOrder.getUserBankNumber() != null)payOrder.setUserBankNumber(
AESUtils.decrypt(payOrder.getUserBankNumber(), encryptKey));
}
}
@Override
public Object plugin(Object target) {
return Plugin.wrap(target, this);
}
@Override
public void setProperties(Properties properties) {
}
}
이 내용에 흥미가 있습니까?
현재 기사가 여러분의 문제를 해결하지 못하는 경우 AI 엔진은 머신러닝 분석(스마트 모델이 방금 만들어져 부정확한 경우가 있을 수 있음)을 통해 가장 유사한 기사를 추천합니다:
Flutter 는 kotlin 프로젝트 에서 자바 방법 으로 데 이 터 를 제공 합 니 다.최근 안 드 로 이 드 프로젝트 를 쓸 때 다음 과 같은 문제 가 발생 했 습 니 다. Flutter 는 kotlin 프로젝트 에서 자바 방법 으로 데 이 터 를 제공 합 니 다. 이 수 요 는 정말 복잡 합 니 다...
텍스트를 자유롭게 공유하거나 복사할 수 있습니다.하지만 이 문서의 URL은 참조 URL로 남겨 두십시오.
CC BY-SA 2.5, CC BY-SA 3.0 및 CC BY-SA 4.0에 따라 라이센스가 부여됩니다.