添加金融数据库，实现创建用户双写-异常抛出

src/main/java/cn/quantgroup/xyqb/financial/repository/IFinancialUserRepository.java

@@ -7,6 +7,7 @@ import org.springframework.data.jpa.repository.Modifying;
 import org.springframework.data.jpa.repository.Query;
 import org.springframework.transaction.annotation.Transactional;
 
+import java.util.Date;
 import java.util.List;
 
 
@@ -15,5 +16,4 @@ import java.util.List;
  */
 public interface IFinancialUserRepository extends JpaRepository<User, Long>, JpaSpecificationExecutor<User> {
 
-
 }

src/main/java/cn/quantgroup/xyqb/service/register/impl/UserRegisterServiceImpl.java

@@ -162,6 +162,9 @@ public class UserRegisterServiceImpl implements IUserRegisterService {
         user = userService.saveUser(user);
         cn.quantgroup.xyqb.financial.entity.User financialUser = new cn.quantgroup.xyqb.financial.entity.User();
         BeanUtils.copyProperties(user, financialUser);
+        if (financialUserService.findOne(user.getId())) {
+            throw new RuntimeException("双写失败，数据已存在--" + user.getId());
+        }
         financialUserService.saveUser(financialUser);
         userRegisterParam.setUser(user);
         return user;

src/main/java/cn/quantgroup/xyqb/service/user/IFinancialUserService.java

@@ -16,4 +16,6 @@ import java.util.Map;
  */
 public interface IFinancialUserService {
     User saveUser(User user);
+
+    boolean findOne(Long id);
 }

src/main/java/cn/quantgroup/xyqb/service/user/impl/FinancialUserServiceImpl.java

@@ -29,4 +29,13 @@ public class FinancialUserServiceImpl implements IFinancialUserService, IBaseCon
     public User saveUser(User user) {
         return financialUserRepository.saveAndFlush(user);
     }
+
+    @Override
+    public boolean findOne(Long id) {
+        User user = financialUserRepository.findOne(id);
+        if (user != null) {
+            return true;
+        }
+        return false;
+    }
 }