软件版本

• idea 2017.2
• mybatis:3.2.8
• java version "1.8.0_51"

common-config/src/main/resources/mybatis-config.xml

<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE configuration PUBLIC "-//mybatis.org//DTD Config 3.0//EN" "http://mybatis.org/dtd/mybatis-3-config.dtd">
<configuration><!-- 省略若干配置 --><!-- 插件配置 --><plugins><plugin interceptor="com.rd.ifaes.common.orm.interceptor.PaginationInterceptor" /><!-- 下面两个是我添加的 --><plugin interceptor="com.rd.ifaes.core.core.interceptor.UpdateInterceptor"/><plugin interceptor="com.rd.ifaes.core.core.interceptor.ResultInterceptor"/></plugins>
</configuration>

core/src/main/java/com/rd/ifaes/core/core/interceptor/ResultInterceptor.java

package com.rd.ifaes.core.core.interceptor;import java.lang.reflect.Field;
import java.sql.ResultSet;
import java.sql.Statement;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
import java.util.Properties;import com.rd.ifaes.common.util.StringUtils;
import org.apache.ibatis.executor.resultset.ResultSetHandler;
import org.apache.ibatis.mapping.BoundSql;
import org.apache.ibatis.plugin.Interceptor;
import org.apache.ibatis.plugin.Intercepts;
import org.apache.ibatis.plugin.Invocation;
import org.apache.ibatis.plugin.Plugin;
import org.apache.ibatis.plugin.Signature;import com.rd.ifaes.common.orm.interceptor.BaseInterceptor;
import com.rd.ifaes.common.util.ReflectionUtils;
import com.rd.ifaes.common.util.AESUtils;
import com.rd.ifaes.core.user.domain.UserCache;/*** Mybatis 拦截组件* @author leeyi* @version V1.0, 2018-01-10 11:16:20*/
@Intercepts(
{@Signature(method = "handleResultSets", type = ResultSetHandler.class, args = {Statement.class})}
)
public class ResultInterceptor extends BaseInterceptor {@Overridepublic Object intercept(Invocation invocation) throws Throwable {Object returnValue = invocation.proceed();if (returnValue instanceof ArrayList<?>) {List<?> list = (ArrayList<?>)returnValue;for(Object obj: list){if (obj instanceof UserCache) {// 查询UserCache结果解密处理dealUserCacheReturnValue(obj);}}}return returnValue;}/*** 查询UserCache结果解密处理*/private void dealUserCacheReturnValue(Object obj) {UserCache userCache = (UserCache)obj;// 这里只处理 addressString address = (String) ReflectionUtils.getFieldValue(obj, "address");userCache.setAddress(AESUtils.decryptForUsercache(address));// 这里只处理 idNoString idNo = (String) ReflectionUtils.getFieldValue(obj, "idNo");userCache.setIdNo(AESUtils.decryptForUsercache(idNo));}@Overridepublic Object plugin(Object target) {return Plugin.wrap(target, this);}@Overridepublic void setProperties(Properties properties) {System.out.println(properties.getProperty("databaseType"));}
}

core/src/main/java/com/rd/ifaes/core/core/interceptor/UpdateInterceptor.java

package com.rd.ifaes.core.core.interceptor;import java.util.Properties;
import java.util.logging.Logger;import org.apache.ibatis.executor.Executor;
import org.apache.ibatis.executor.resultset.ResultSetHandler;
import org.apache.ibatis.mapping.BoundSql;
import org.apache.ibatis.mapping.MappedStatement;
import org.apache.ibatis.mapping.SqlSource;
import org.apache.ibatis.plugin.Intercepts;
import org.apache.ibatis.plugin.Invocation;
import org.apache.ibatis.plugin.Plugin;
import org.apache.ibatis.plugin.Signature;import com.rd.ifaes.common.orm.interceptor.BaseInterceptor;
import com.rd.ifaes.common.util.ReflectionUtils;
import com.rd.ifaes.common.util.PropertiesUtils;
import com.rd.ifaes.common.util.AESUtils;
import com.rd.ifaes.core.user.domain.UserCache;/*** Mybatis 拦截组件* @author leeyi* @version V1.0, 2018-01-10 11:16:20*/@Intercepts({@Signature(type = Executor.class, method = "update", args = {MappedStatement.class, Object.class})
})
public class UpdateInterceptor extends BaseInterceptor {private final Logger logger = Logger.getLogger(String.valueOf(this.getClass()));private static final long serialVersionUID = 1L;private Object parameter;@Overridepublic Object intercept(Invocation invocation) throws Throwable {final MappedStatement mappedStatement = (MappedStatement) invocation.getArgs()[0];//拦截需要的SQLparameter = invocation.getArgs()[1];BoundSql boundSql = mappedStatement.getBoundSql(parameter);// 这里只捕获 UserCache 其他 类型的不处理if (parameter instanceof UserCache) {Object obj = boundSql.getParameterObject();// UserCache 加密处理dealUserCacheValue(obj);}return invocation.proceed();}/***  UserCache 加密处理*/private void dealUserCacheValue(Object obj) {UserCache userCache = (UserCache)parameter;// 这里只处理 addressString address = (String) ReflectionUtils.getFieldValue(obj, "address");userCache.setAddress(AESUtils.encryptForUsercache(address));// 这里只处理 id_noString idNo = (String) ReflectionUtils.getFieldValue(obj, "idNo");userCache.setIdNo(AESUtils.encryptForUsercache(idNo));}@Overridepublic Object plugin(Object target) {return Plugin.wrap(target, this);}@Overridepublic void setProperties(Properties properties) {super.initProperties(properties);}
}

common-supports/src/main/java/com/rd/ifaes/common/util/AESUtils.java

package com.rd.ifaes.common.util;import javax.crypto.Cipher;
import javax.crypto.spec.IvParameterSpec;
import javax.crypto.spec.SecretKeySpec;import sun.misc.BASE64Decoder;
import sun.misc.BASE64Encoder;import com.rd.ifaes.common.util.PropertiesUtils;public class AESUtils {protected static String thisiv = "abc2030405060708";// iv 必须要是一个16为的字符串public static void setIv(String iv) {thisiv =  iv;}/*** 加密* @method encrypt* @param strIn   需要加密的内容* @param strKey  加密密码* @return* @throws* @since v1.0*/public static String encrypt(String strKey, String strIn) throws Exception {SecretKeySpec skeySpec = getKey(strKey);Cipher cipher = Cipher.getInstance("AES/CBC/PKCS5Padding");IvParameterSpec iv = new IvParameterSpec(thisiv.getBytes());cipher.init(Cipher.ENCRYPT_MODE, skeySpec, iv);byte[] encrypted = cipher.doFinal(strIn.getBytes());return new BASE64Encoder().encode(encrypted);}/*** 解密* @method decrypt* @param strIn   待解密内容* @param strKey  解密密钥* @return* @throws* @since v1.0*/public static String decrypt(String strKey, String strIn) throws Exception {SecretKeySpec skeySpec = getKey(strKey);Cipher cipher = Cipher.getInstance("AES/CBC/PKCS5Padding");IvParameterSpec iv = new IvParameterSpec(thisiv.getBytes());cipher.init(Cipher.DECRYPT_MODE, skeySpec, iv);byte[] encrypted1 = new BASE64Decoder().decodeBuffer(strIn);byte[] original = cipher.doFinal(encrypted1);String originalString = new String(original);return originalString;}/*** 将二进制转换成16进制* @method parseByte2HexStr* @param buf* @return* @throws* @since v1.0*/private static String parseByte2HexStr(byte buf[]){StringBuffer sb = new StringBuffer();for(int i = 0; i < buf.length; i++){String hex = Integer.toHexString(buf[i] & 0xFF);if (hex.length() == 1) {hex = '0' + hex;}sb.append(hex.toUpperCase());}return sb.toString();}/*** 转换密钥<br>** @param strKey* @return* @throws Exception*/private static SecretKeySpec getKey(String strKey) throws Exception {byte[] arrBTmp = strKey.getBytes();byte[] arrB = new byte[16]; // 创建一个空的16位字节数组（默认值为0）for (int i = 0; i < arrBTmp.length && i < arrB.length; i++) {arrB[i] = arrBTmp[i];}SecretKeySpec skeySpec = new SecretKeySpec(arrB, "AES");return skeySpec;}/*** 在获取数据之前给数据解密 解密没有成功的话，返回原来的值* @param  param 需要加密的內容* @return       解密后的字符串*/public static String decryptForUsercache(String param) {if (param == null || param.length() == 0) {return "";}if (param.length() < 4) {return param;}String prefix = param.substring(0,4);// 表示没有加密if (!prefix.equals("aes:")) {return param;}try {final String key = PropertiesUtils.getValue("user_aes_encrypt_key");String ciphertext = param.substring(4);String plaintext  = AESUtils.decrypt(key, ciphertext);param = plaintext;} catch(Exception e) {}return param;}/*** 在更新数据之前给数据加密* @param  param 需要界面的內容* @return       以 "aes:"开头的字符串*/public static String encryptForUsercache(String param) {if (param == null || param.length() == 0) {return "";}if (param.length() < 4) {return param;}String prefix = param.substring(0,4);// 表示已经加密过了if (prefix.equals("aes:")) {return param;}try {final String key = PropertiesUtils.getValue("user_aes_encrypt_key");param = "aes:" +  AESUtils.encrypt(key, param);} catch(Exception e) {}return param;}public static void main(String[] args) throws Exception {String Code = "abcd";// String key = "1q2w3e4r*?";// String key = "1q2w3e4rei1q2w3e4rei";String key = "a3aMbVs6e6t2Ucy7";String codE, codePhp, codeObjc;AESUtils.setIv("abc2030405060708");codE = AESUtils.encrypt(key, Code);codePhp = "u6qq89cZALmD+1PX6dXRgA==";codeObjc = "MSVbpcJlzq/HqcpSoHA4SA==";System.out.println("原文：" + Code);System.out.println("密钥：" + key);System.out.println("密文：" + codE);System.out.println("解密java：" + AESUtils.decrypt(key, codE));//System.out.println("解密php：" + AESUtils.decrypt(key, codePhp));//System.out.println("解密objc：" + AESUtils.decrypt(key, codeObjc));String address = "aes:peN5NYRurQT0deSQZ/SHwg==";String plaintext  = AESUtils.decrypt("a3aMbVs6e6t2Ucy7", address.substring(4));System.out.println("ddd:  " + plaintext);//String con2 = "5CxL+rE6Gh/zKPcffYExDg==";//System.out.println("解密objc：" + AESUtils.decrypt(key, con2));// String res = webview.postUrl("http://127.0.0.1:80","data=dhfakjsdfhksdhf+dfasjkdhf+adsfkhasld");// System.out.println("webview文：" + res);}
}