修改实名认证

xx-universal/xx-universal-server/src/main/java/com/xxfc/platform/universal/controller/CertificationController.java

@@ -2,14 +2,18 @@ package com.xxfc.platform.universal.controller;
 
 
 import com.alibaba.druid.util.StringUtils;
+import com.alibaba.fastjson.JSONObject;
 import com.github.wxiaoqi.security.admin.feign.UserFeign;
 import com.github.wxiaoqi.security.admin.feign.dto.AppUserDTO;
 import com.github.wxiaoqi.security.common.msg.ObjectRestResponse;
 import com.github.wxiaoqi.security.common.util.process.ResultCode;
+import com.xxfc.platform.universal.constant.MQconstant;
 import com.xxfc.platform.universal.entity.IdInformation;
 import com.xxfc.platform.universal.service.CertificationService;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.beans.factory.annotation.Qualifier;
+import org.springframework.core.task.TaskExecutor;
 import org.springframework.web.bind.annotation.PostMapping;
 import org.springframework.web.bind.annotation.RequestBody;
 import org.springframework.web.bind.annotation.RequestMapping;
@@ -35,6 +39,11 @@ public class CertificationController {
     @Autowired
     private UserFeign userFeign;
 
+    @Qualifier("applicationTaskExecutor")
+    @Autowired
+    private TaskExecutor executor;
+
+   
 
 
 
@@ -84,7 +93,16 @@ public class CertificationController {
         log.info("----type========="+type);
         try {
             if (type!=null&&type==0){
-                 return certificationService.certificate(idInformation);
+                ObjectRestResponse certificate = certificationService.certificate(idInformation);
+                if (certificate.getRel()) {
+                    executor.execute(new Runnable() {
+                        @Override
+                        public void run() {
+                            setIntegral(appUserDTO.getUserid());
+                        }
+                    });
+                }
+                return certificate ;
             }
         } catch (Exception e) {
             e.printStackTrace();
@@ -94,5 +112,7 @@ public class CertificationController {
 
     }
 
+    private void setIntegral(Integer userid){
+    }
 
 }

xx-universal/xx-universal-server/src/main/java/com/xxfc/platform/universal/service/CertificationService.java

@@ -22,6 +22,7 @@ import org.apache.poi.ss.usermodel.DateUtil;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.beans.factory.annotation.Value;
 import org.springframework.stereotype.Service;
+import org.springframework.transaction.interceptor.TransactionAspectSupport;
 
 import java.text.ParseException;
 import java.text.SimpleDateFormat;
@@ -474,19 +475,21 @@ public class CertificationService {
         //保存认证信息
         try {
             idInformationMapper.addIdInformation(idInformation);
+            //认证成功后修改用户,用户认证状态
+            ObjectRestResponse authentication = userFeign.authentication(idInformation.getUserLonginId(), idInformation.getName(), idInformation.getIdNumber(), 1);
+            return true;
         } catch (Exception e) {
             e.printStackTrace();
             return false;
         }
 
 
-        //认证成功后修改用户,用户认证状态
-        ObjectRestResponse authentication = userFeign.authentication(idInformation.getUserLonginId(), idInformation.getName(), idInformation.getIdNumber(), 1);
 
-        return authentication.getRel();
+
     }
 
 
+
 }