清除用户数据修改

src/main/java/cn/quantgroup/cashloanflowboss/spi/user/entity/Address.java

+package cn.quantgroup.cashloanflowboss.spi.user.entity;
+
+import javax.persistence.Column;
+import javax.persistence.Entity;
+import javax.persistence.GeneratedValue;
+import javax.persistence.GenerationType;
+import javax.persistence.Id;
+import javax.persistence.Table;
+import lombok.Data;
+
+@Data
+@Entity
+@Table(name = "address")
+public class Address {
+  @Id
+  @Column(name = "id")
+  @GeneratedValue(strategy = GenerationType.IDENTITY)
+  private Long id;
+
+  @Column(name = "user_id")
+  private Long userId;
+
+  @Column(name = "province_code")
+  private String name;
+
+  @Column(name = "province")
+  private String province;
+
+  @Column(name = "city_code")
+  private String city_code;
+
+  @Column(name = "city")
+  private Integer city;
+
+  @Column(name = "district_code")
+  private Integer district_code;
+
+  @Column(name = "district")
+  private Integer district;
+
+  @Column(name = "address")
+  private Integer address;
+
+  @Column(name = "created_at")
+  private Integer created_at;
+
+  @Column(name = "updated_at")
+  private Integer updated_at;
+
+}

src/main/java/cn/quantgroup/cashloanflowboss/spi/user/entity/UserContact.java

+package cn.quantgroup.cashloanflowboss.spi.user.entity;
+
+import java.sql.Timestamp;
+import javax.persistence.Column;
+import javax.persistence.Entity;
+import javax.persistence.GeneratedValue;
+import javax.persistence.GenerationType;
+import javax.persistence.Id;
+import javax.persistence.Table;
+import lombok.Data;
+
+@Data
+@Entity
+@Table(name = "contact")
+public class UserContact {
+  @Id
+  @Column(name = "id")
+  @GeneratedValue(strategy = GenerationType.IDENTITY)
+  private Long id;
+
+  @Column(name = "user_id")
+  private Long userId;
+
+  @Column(name = "name")
+  private String name;
+
+  @Column(name = "relation")
+  private String relation;
+
+  @Column(name = "created_at")
+  private String created_at;
+
+  @Column(name = "updated_at")
+  private Integer updated_at;
+
+}

src/main/java/cn/quantgroup/cashloanflowboss/spi/user/service/XyqbUserServiceImpl.java

@@ -4,6 +4,7 @@ import cn.quantgroup.cashloanflowboss.api.optlog.model.OptEnumName;
 import cn.quantgroup.cashloanflowboss.core.annotation.opt.OperationAnno;
 import cn.quantgroup.cashloanflowboss.core.base.Tuple;
 import cn.quantgroup.cashloanflowboss.spi.jolyne.JolyneCenter;
+import cn.quantgroup.cashloanflowboss.spi.jolyne.JolyneUtil;
 import cn.quantgroup.cashloanflowboss.spi.user.repository.UserDetailRepository;
 import cn.quantgroup.cashloanflowboss.spi.user.repository.UserExtInfoRepository;
 import cn.quantgroup.cashloanflowboss.spi.util.HttpService;
@@ -49,6 +50,8 @@ public class XyqbUserServiceImpl implements XyqbUserService {
     private StringRedisTemplate redisTemplate;
     @Value("${passportapi.http}")
     private String passportapiHttp;
+    @Autowired
+    private JolyneCenter jolyneCenter;
 
 
 
@@ -142,8 +145,15 @@ public class XyqbUserServiceImpl implements XyqbUserService {
                 return new Tuple<>(false,"删除用户信息失败，未找到用户");
             }
             Long userId = xUser.getData().getId();
-            int i = userDetailRepository.deleteByUserId(userId);
-            userExtInfoRepository.deleteByUserId(userId);
+            ArrayList<String> cancelList = Lists.newArrayList();
+            cancelList.add("delete from user_detail where user_id=" + userId);
+            cancelList.add("delete from user_ext_info where user_id=" + userId);
+            cancelList.add("delete from contact where user_id=" + userId);
+            cancelList.add("delete from address where user_id=" + userId);
+
+            String cancelResult = jolyneCenter.executeXYQBSQL(JolyneUtil.getJolneSql(cancelList));
+            JSONObject resp = JSONObject.parseObject(cancelResult);
+
             Set<String> phoneNoKeys = redisTemplate.keys(phoneNo);
             if(phoneNoKeys!=null){
                 redisTemplate.delete(phoneNoKeys);