phone数据加密

src/main/java/cn/quantgroup/xyqb/entity/Contact.java

@@ -2,7 +2,7 @@ package cn.quantgroup.xyqb.entity;
 
 import cn.quantgroup.user.enums.BizType;
 import cn.quantgroup.user.enums.Relation;
-import cn.quantgroup.xyqb.entity.converter.EncryptConverter;
+import cn.quantgroup.xyqb.entity.converter.PhoneEncryptConverter;
 import cn.quantgroup.xyqb.model.Tuple;
 import cn.quantgroup.xyqb.util.ValidationUtil;
 import lombok.AllArgsConstructor;
@@ -33,7 +33,7 @@ public class Contact extends BaseEntity implements Serializable {
     @Column(name = "name")
     private String name;
     @Column(name = "phone_no")
-    @Convert(converter = EncryptConverter.class)
+    @Convert(converter = PhoneEncryptConverter.class)
     private String phoneNo;
     @Column(name = "biz_type")
     private BizType bizType = BizType.CASH;

src/main/java/cn/quantgroup/xyqb/entity/ModifyPhoneNo.java

 package cn.quantgroup.xyqb.entity;
 
-import cn.quantgroup.xyqb.entity.converter.EncryptConverter;
+import cn.quantgroup.xyqb.entity.converter.PhoneEncryptConverter;
 import com.fasterxml.jackson.annotation.JsonFormat;
 import lombok.Data;
 
@@ -45,14 +45,14 @@ public class ModifyPhoneNo extends BaseEntity implements Serializable {
      * 原手机号码
      */
     @Column(name = "prev_phone_no")
-    @Convert(converter = EncryptConverter.class)
+    @Convert(converter = PhoneEncryptConverter.class)
     private String prevPhoneNo;
 
     /**
      * 新手机号码
      */
     @Column(name = "cur_phone_no")
-    @Convert(converter = EncryptConverter.class)
+    @Convert(converter = PhoneEncryptConverter.class)
     private String curPhoneNo;
 
     /**

src/main/java/cn/quantgroup/xyqb/entity/User.java

 package cn.quantgroup.xyqb.entity;
 
-import cn.quantgroup.xyqb.entity.converter.EncryptConverter;
+import cn.quantgroup.xyqb.entity.converter.PhoneEncryptConverter;
 import lombok.Getter;
 import lombok.Setter;
 import lombok.ToString;
@@ -28,7 +28,7 @@ public class User extends BaseEntity implements Serializable {
      * 手机号
      */
     @Column(name = "phone_no")
-    @Convert(converter = EncryptConverter.class)
+    @Convert(converter = PhoneEncryptConverter.class)
     private String phoneNo;
 
     /**

src/main/java/cn/quantgroup/xyqb/entity/UserDetail.java

 package cn.quantgroup.xyqb.entity;
 
 import cn.quantgroup.motan.retbean.XUserDetail;
-import cn.quantgroup.xyqb.entity.converter.EncryptConverter;
+import cn.quantgroup.xyqb.entity.converter.PhoneEncryptConverter;
 import cn.quantgroup.xyqb.model.Gender;
 import cn.quantgroup.xyqb.model.IdType;
 import lombok.Getter;
@@ -10,7 +10,6 @@ import lombok.ToString;
 
 import javax.persistence.*;
 import java.io.Serializable;
-import java.sql.Timestamp;
 import java.util.Optional;
 
 /**
@@ -30,7 +29,7 @@ public class UserDetail extends BaseEntity implements Serializable {
     private Long userId;
 
     @Column(name = "phone_no")
-    @Convert(converter = EncryptConverter.class)
+    @Convert(converter = PhoneEncryptConverter.class)
     private String phoneNo;
 
     @Column(name = "name")

src/main/java/cn/quantgroup/xyqb/entity/UserSpouse.java

@@ -2,13 +2,12 @@ package cn.quantgroup.xyqb.entity;
 
 
 import cn.quantgroup.user.enums.MaritalStatus;
-import cn.quantgroup.xyqb.entity.converter.EncryptConverter;
+import cn.quantgroup.xyqb.entity.converter.PhoneEncryptConverter;
 import cn.quantgroup.xyqb.util.ValidationUtil;
 import lombok.*;
 
 import javax.persistence.*;
 import java.io.Serializable;
-import java.sql.Timestamp;
 
 @Data
 @Entity
@@ -25,7 +24,7 @@ public class UserSpouse extends BaseEntity implements Serializable {
     private Long userId;
 
     @Column(name = "spouse_phone")
-    @Convert(converter = EncryptConverter.class)
+    @Convert(converter = PhoneEncryptConverter.class)
     private String spousePhone;
 
     @Column(name = "spouse_name")

src/main/java/cn/quantgroup/xyqb/entity/UuidPhoneMapping.java

 package cn.quantgroup.xyqb.entity;
 
-import cn.quantgroup.xyqb.entity.converter.EncryptConverter;
+import cn.quantgroup.xyqb.entity.converter.PhoneEncryptConverter;
 import lombok.Getter;
 import lombok.Setter;
 import lombok.ToString;
@@ -29,7 +29,7 @@ public class UuidPhoneMapping implements Serializable {
     private String uuid;
 
     @Column(name = "phone_no")
-    @Convert(converter = EncryptConverter.class)
+    @Convert(converter = PhoneEncryptConverter.class)
     private String phoneNo;
 
 

src/main/java/cn/quantgroup/xyqb/entity/WechatUserInfo.java

 package cn.quantgroup.xyqb.entity;
 
-import cn.quantgroup.xyqb.entity.converter.EncryptConverter;
+import cn.quantgroup.xyqb.entity.converter.PhoneEncryptConverter;
 import cn.quantgroup.xyqb.util.EmojiUtil;
 import lombok.Data;
 import org.springframework.beans.BeanUtils;
 
 import javax.persistence.*;
 import java.io.Serializable;
-import java.sql.Timestamp;
 
 /**
  * Created by 11 on 2017/1/17.
@@ -24,7 +23,7 @@ public class WechatUserInfo extends BaseEntity implements Serializable {
     @Column(name = "open_id")
     private String openId;
     @Column(name = "phone_no")
-    @Convert(converter = EncryptConverter.class)
+    @Convert(converter = PhoneEncryptConverter.class)
     private String phoneNo = "";
     @Column(name = "app_name")
     private String appName = "xyqb";

src/main/java/cn/quantgroup/xyqb/entity/converter/EncryptConverter.java → src/main/java/cn/quantgroup/xyqb/entity/converter/PhoneEncryptConverter.java

@@ -2,37 +2,48 @@ package cn.quantgroup.xyqb.entity.converter;
 
 import cn.quantgroup.security.AESEncryption;
 import cn.quantgroup.xyqb.util.ApplicationContextHolder;
+import cn.quantgroup.xyqb.util.ValidationUtil;
+import lombok.extern.slf4j.Slf4j;
 import org.apache.commons.lang3.StringUtils;
 
 import javax.persistence.AttributeConverter;
 import javax.persistence.Converter;
 
 /**
- * 字段加解密转换器
+ * 手机号字段加解密转换器
+ * <b>此处只对有效手机号处理</b>
  *
  * @author killer
  * @date 2022年01月04日
  **/
+@Slf4j
 @Converter
-public class EncryptConverter implements AttributeConverter<String, String>  {
+public class PhoneEncryptConverter implements AttributeConverter<String, String> {
 
     @Override
     public String convertToDatabaseColumn(String entityAttribute) {
-        /* 加密 */
-        if (StringUtils.isBlank(entityAttribute)) {
+        /* 非手机号原样保存 */
+        if (!ValidationUtil.validatePhoneNo(entityAttribute)) {
             return entityAttribute;
         }
+        /* 加密 */
         AESEncryption aesEncryption = ApplicationContextHolder.getBean(AESEncryption.class);
         return aesEncryption.encryptBase64(entityAttribute);
     }
 
     @Override
     public String convertToEntityAttribute(String databaseColumn) {
-        /* 解密 */
-        if (StringUtils.isBlank(databaseColumn)) {
+        /* 明文手机号或者空原样返回 */
+        if (ValidationUtil.validatePhoneNo(databaseColumn) || StringUtils.isBlank(databaseColumn)) {
             return databaseColumn;
         }
+        /* 解密 */
         AESEncryption aesEncryption = ApplicationContextHolder.getBean(AESEncryption.class);
-        return aesEncryption.decryptBase64(databaseColumn);
+        try {
+            return aesEncryption.decryptBase64(databaseColumn);
+        } catch (IllegalArgumentException e) {
+            log.warn("手机号解密失败, 数据存在问题, 原样返回数据:{}", databaseColumn);
+        }
+        return databaseColumn;
     }
 }