调整实名信息保存消息触发点

src/main/java/cn/quantgroup/xyqb/event/DetailRegisteredEventListener.java

@@ -6,11 +6,9 @@ import javax.annotation.Resource;
 
 import org.apache.commons.lang3.StringUtils;
 
-import org.springframework.context.ApplicationEventPublisher;
 import org.springframework.context.ApplicationListener;
 import org.springframework.stereotype.Component;
 
-import cn.quantgroup.acolyte.buddhistscriptures.pojo.UserRealInfo;
 import lombok.extern.slf4j.Slf4j;
 
 import cn.quantgroup.xyqb.entity.User;
@@ -30,8 +28,6 @@ public class DetailRegisteredEventListener implements ApplicationListener<Regist
     private IIdCardService idCardService;
     @Resource
     private IUserDetailService userDetailService;
-    @Resource
-    private ApplicationEventPublisher applicationEventPublisher;
 
     @Override
     public void onApplicationEvent(RegisterEvent event) {
@@ -61,8 +57,5 @@ public class DetailRegisteredEventListener implements ApplicationListener<Regist
         userDetail.setUserId(user.getId());
         userDetail.setGender(cardInfo.getGender());
         userDetailService.saveUserDetail(userDetail);
-        // 发送实名登记统计消息
-        UserRealInfo userRealInfo = new UserRealInfo(userDetail.getUserId(), userDetail.getName(), userDetail.getIdNo(), userDetail.getIdType().ordinal());
-        applicationEventPublisher.publishEvent(new StatisticsEvent(this, userRealInfo));
     }
 }

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

 package cn.quantgroup.xyqb.service.user.impl;
 
+import java.util.*;
+import java.util.stream.Collectors;
+
+import javax.annotation.Resource;
+import javax.persistence.criteria.Predicate;
+
+import org.apache.commons.lang.StringUtils;
+
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.context.ApplicationEventPublisher;
+import org.springframework.dao.DataIntegrityViolationException;
+import org.springframework.data.domain.Page;
+import org.springframework.data.domain.PageRequest;
+import org.springframework.data.domain.Sort;
+import org.springframework.data.jpa.domain.Specification;
+import org.springframework.stereotype.Service;
+import org.springframework.util.CollectionUtils;
+
+import com.google.common.collect.Maps;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+import cn.quantgroup.acolyte.buddhistscriptures.pojo.UserRealInfo;
 import cn.quantgroup.xyqb.Constants;
 import cn.quantgroup.xyqb.entity.User;
 import cn.quantgroup.xyqb.entity.UserDetail;
+import cn.quantgroup.xyqb.event.StatisticsEvent;
 import cn.quantgroup.xyqb.model.Gender;
 import cn.quantgroup.xyqb.model.IdCardInfo;
 import cn.quantgroup.xyqb.repository.IUserDetailRepository;
@@ -11,25 +35,6 @@ import cn.quantgroup.xyqb.service.auth.IIdCardService;
 import cn.quantgroup.xyqb.service.user.IUserDetailService;
 import cn.quantgroup.xyqb.service.user.vo.UserDetailVO;
 import cn.quantgroup.xyqb.util.ValidationUtil;
-import com.google.common.collect.Maps;
-import org.apache.commons.lang.StringUtils;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
-import org.springframework.beans.factory.annotation.Autowired;
-import org.springframework.dao.DataIntegrityViolationException;
-import org.springframework.data.domain.Page;
-import org.springframework.data.domain.PageRequest;
-import org.springframework.data.domain.Sort;
-import org.springframework.data.jpa.domain.Specification;
-import org.springframework.stereotype.Service;
-import org.springframework.util.CollectionUtils;
-
-import javax.persistence.criteria.Predicate;
-import java.util.ArrayList;
-import java.util.List;
-import java.util.Map;
-import java.util.Optional;
-import java.util.stream.Collectors;
 
 /**
  * Created by 11 on 2016/12/29.
@@ -43,6 +48,8 @@ public class UserDetailServiceImpl implements IUserDetailService {
     private IUserRepository userRepository;
     @Autowired
     private IIdCardService idCardService;
+    @Resource
+    private ApplicationEventPublisher applicationEventPublisher;
 
     @Override
     public UserDetail findByUserId(Long userId) {
@@ -51,7 +58,13 @@ public class UserDetailServiceImpl implements IUserDetailService {
 
     @Override
     public UserDetail saveUserDetail(UserDetail userDetail) throws DataIntegrityViolationException {
-        return userDetailRepository.save(userDetail);
+        UserDetail userDetail1 = userDetailRepository.save(userDetail);
+        if(Objects.nonNull(userDetail)){
+            // 发送实名登记统计消息
+            UserRealInfo userRealInfo = new UserRealInfo(userDetail.getUserId(), userDetail.getName(), userDetail.getIdNo(), userDetail.getIdType().ordinal());
+            applicationEventPublisher.publishEvent(new StatisticsEvent(this, userRealInfo));
+        }
+        return userDetail1;
     }
 
     @Override