phone数据加密

pom.xml

@@ -412,6 +412,13 @@
             </exclusions>
         </dependency>
 
+        <!-- 统一加解密包 -->
+        <dependency>
+            <groupId>cn.quantgroup</groupId>
+            <artifactId>security</artifactId>
+            <version>0.1.2</version>
+        </dependency>
+
     </dependencies>
 
     <build>

src/main/java/cn/quantgroup/xyqb/config/SecurityConfig.java

+package cn.quantgroup.xyqb.config;
+
+import cn.quantgroup.security.AESEncryption;
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+
+/**
+ * 统一加解密配置
+ *
+ * @author killer
+ * @date 2022年01月04日
+ **/
+@Configuration
+public class SecurityConfig {
+
+    @Value("${keystone.security.key}")
+    private String key;
+
+    @Value("${keystone.security.iv}")
+    private String iv;
+
+    @Bean
+    public AESEncryption encryption() {
+        return new AESEncryption(key, iv, true);
+    }
+}

src/main/java/cn/quantgroup/xyqb/controller/TestController.java

+package cn.quantgroup.xyqb.controller;
+
+import cn.quantgroup.xyqb.entity.User;
+import cn.quantgroup.xyqb.model.JsonResult;
+import cn.quantgroup.xyqb.repository.IUserRepository;
+import lombok.RequiredArgsConstructor;
+import org.springframework.web.bind.annotation.*;
+
+/**
+ * 测试类
+ *
+ * @author killer
+ * @date 2022年01月04日
+ **/
+@RestController
+@RequestMapping("/v1/test")
+@RequiredArgsConstructor
+public class TestController {
+
+    private final IUserRepository userRepository;
+
+    @PostMapping(value = "/save/user")
+    public JsonResult<?> saveUser(@RequestBody User user) {
+        User result = userRepository.save(user);
+        return JsonResult.buildSuccessResult("保存成功", result);
+    }
+
+    @GetMapping(value = "/query/user/{id}")
+    public JsonResult<?> saveUser(@PathVariable("id") Long id) {
+        User result = userRepository.findById(id);
+        return JsonResult.buildSuccessResult("查询成功", result);
+    }
+}

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

@@ -2,6 +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.model.Tuple;
 import cn.quantgroup.xyqb.util.ValidationUtil;
 import lombok.AllArgsConstructor;
@@ -10,6 +11,7 @@ import lombok.Data;
 import lombok.NoArgsConstructor;
 
 import javax.persistence.Column;
+import javax.persistence.Convert;
 import javax.persistence.Entity;
 import javax.persistence.Table;
 import java.io.Serializable;
@@ -31,6 +33,7 @@ public class Contact extends BaseEntity implements Serializable {
     @Column(name = "name")
     private String name;
     @Column(name = "phone_no")
+    @Convert(converter = EncryptConverter.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 com.fasterxml.jackson.annotation.JsonFormat;
 import lombok.Data;
 
 import javax.persistence.Column;
+import javax.persistence.Convert;
 import javax.persistence.Entity;
 import javax.persistence.Table;
 import java.io.Serializable;
@@ -43,12 +45,14 @@ public class ModifyPhoneNo extends BaseEntity implements Serializable {
      * 原手机号码
      */
     @Column(name = "prev_phone_no")
+    @Convert(converter = EncryptConverter.class)
     private String prevPhoneNo;
 
     /**
      * 新手机号码
      */
     @Column(name = "cur_phone_no")
+    @Convert(converter = EncryptConverter.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 lombok.Getter;
 import lombok.Setter;
 import lombok.ToString;
 
-import javax.persistence.Column;
-import javax.persistence.Entity;
-import javax.persistence.Table;
-import javax.persistence.UniqueConstraint;
+import javax.persistence.*;
 import java.io.Serializable;
 import java.util.Objects;
 
 /**
- * Created by Miraculous on 15/7/4.
+ * 用户表
+ *
+ * @author Miraculous
+ * @date 2015年07月04日
  */
 @Getter
 @Setter
 @ToString
 @Entity
-@Table(name = "user",
-       uniqueConstraints = @UniqueConstraint(columnNames = "phone_no"))
+@Table(name = "user", uniqueConstraints = @UniqueConstraint(columnNames = "phone_no"))
 public class User extends BaseEntity implements Serializable {
+
     private static final long serialVersionUID = -1L;
 
-    //手机号
+    /**
+     * 手机号
+     */
     @Column(name = "phone_no")
+    @Convert(converter = EncryptConverter.class)
     private String phoneNo;
 
-    //uuid
+    /**
+     * password
+     */
     @Column(name = "password")
     private String password;
 
-    //第一次用户来源 channel_id
+    /**
+     * 第一次用户来源 channel_id
+     */
     @Column(name = "registered_from")
     private Long registeredFrom;
 
-    //uuid
+    /**
+     * uuid
+     */
     @Column(name = "uuid")
     private String uuid;
 
+    /**
+     * 是否禁用
+     */
     @Column(name = "enable")
     private Boolean enable;
 
     /**
      * 是否有密码
      *
-     * @return
+     * @return true/false
      */
     public boolean getHasPassword() {
         return Objects.nonNull(password) && !Objects.equals("", password);

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.model.Gender;
 import cn.quantgroup.xyqb.model.IdType;
 import lombok.Getter;
 import lombok.Setter;
 import lombok.ToString;
 
-import javax.persistence.Column;
-import javax.persistence.Entity;
-import javax.persistence.Table;
-import javax.persistence.UniqueConstraint;
+import javax.persistence.*;
 import java.io.Serializable;
 import java.sql.Timestamp;
 import java.util.Optional;
@@ -32,6 +30,7 @@ public class UserDetail extends BaseEntity implements Serializable {
     private Long userId;
 
     @Column(name = "phone_no")
+    @Convert(converter = EncryptConverter.class)
     private String phoneNo;
 
     @Column(name = "name")

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

@@ -2,6 +2,7 @@ package cn.quantgroup.xyqb.entity;
 
 
 import cn.quantgroup.user.enums.MaritalStatus;
+import cn.quantgroup.xyqb.entity.converter.EncryptConverter;
 import cn.quantgroup.xyqb.util.ValidationUtil;
 import lombok.*;
 
@@ -24,6 +25,7 @@ public class UserSpouse extends BaseEntity implements Serializable {
     private Long userId;
 
     @Column(name = "spouse_phone")
+    @Convert(converter = EncryptConverter.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 lombok.Getter;
 import lombok.Setter;
 import lombok.ToString;
@@ -28,6 +29,7 @@ public class UuidPhoneMapping implements Serializable {
     private String uuid;
 
     @Column(name = "phone_no")
+    @Convert(converter = EncryptConverter.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.util.EmojiUtil;
 import lombok.Data;
 import org.springframework.beans.BeanUtils;
@@ -23,6 +24,7 @@ public class WechatUserInfo extends BaseEntity implements Serializable {
     @Column(name = "open_id")
     private String openId;
     @Column(name = "phone_no")
+    @Convert(converter = EncryptConverter.class)
     private String phoneNo = "";
     @Column(name = "app_name")
     private String appName = "xyqb";

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

+package cn.quantgroup.xyqb.entity.converter;
+
+import cn.quantgroup.security.AESEncryption;
+import cn.quantgroup.xyqb.util.ApplicationContextHolder;
+import org.apache.commons.lang3.StringUtils;
+
+import javax.persistence.AttributeConverter;
+import javax.persistence.Converter;
+
+/**
+ * 字段加解密转换器
+ *
+ * @author killer
+ * @date 2022年01月04日
+ **/
+@Converter
+public class EncryptConverter implements AttributeConverter<String, String>  {
+
+    @Override
+    public String convertToDatabaseColumn(String entityAttribute) {
+        /* 加密 */
+        if (StringUtils.isBlank(entityAttribute)) {
+            return entityAttribute;
+        }
+        AESEncryption aesEncryption = ApplicationContextHolder.getBean(AESEncryption.class);
+        return aesEncryption.encryptBase64(entityAttribute);
+    }
+
+    @Override
+    public String convertToEntityAttribute(String databaseColumn) {
+        /* 解密 */
+        if (StringUtils.isBlank(databaseColumn)) {
+            return databaseColumn;
+        }
+        AESEncryption aesEncryption = ApplicationContextHolder.getBean(AESEncryption.class);
+        return aesEncryption.decryptBase64(databaseColumn);
+    }
+}