From ac5be2f1b7143a77e7db74022ef1c808520b3add Mon Sep 17 00:00:00 2001
From: CeDo <cedoogle@gmail.com>
Date: 星期五, 07 五月 2021 10:57:13 +0800
Subject: [PATCH] add:党员认证消息提示;

---
 springcloud_k8s_panzhihuazhihuishequ/applets/src/main/java/com/panzhihua/applets/api/UserApi.java |   36 ++++++++++++++++++++++++++----------
 1 files changed, 26 insertions(+), 10 deletions(-)

diff --git a/springcloud_k8s_panzhihuazhihuishequ/applets/src/main/java/com/panzhihua/applets/api/UserApi.java b/springcloud_k8s_panzhihuazhihuishequ/applets/src/main/java/com/panzhihua/applets/api/UserApi.java
index f90f2c3..082fa57 100644
--- a/springcloud_k8s_panzhihuazhihuishequ/applets/src/main/java/com/panzhihua/applets/api/UserApi.java
+++ b/springcloud_k8s_panzhihuazhihuishequ/applets/src/main/java/com/panzhihua/applets/api/UserApi.java
@@ -4,6 +4,7 @@
 import com.alibaba.fastjson.JSONObject;
 import com.panzhihua.applets.weixin.CheckService;
 import com.panzhihua.applets.model.dtos.ComPbMemberCertificationDTO;
+import com.panzhihua.common.model.dtos.shop.ExcelShopOrderDTO;
 import com.panzhihua.common.model.dtos.user.SysUserEditTipsDTO;
 import com.panzhihua.common.model.dtos.user.SysUserFeedbackDTO;
 import com.panzhihua.common.model.vos.community.*;
@@ -26,10 +27,8 @@
 import org.springframework.web.bind.annotation.*;
 
 import javax.annotation.Resource;
-import java.util.ArrayList;
-import java.util.Comparator;
-import java.util.Date;
-import java.util.List;
+import java.util.*;
+import java.util.concurrent.atomic.AtomicBoolean;
 import java.util.stream.Collectors;
 
 /**
@@ -340,16 +339,20 @@
         R certUser = partyBuildingService.userCertification(userId);
 
         Object certUserInfo = certUser.getData();
-        boolean userCertified = false;
-        if (certUserInfo != null) {
+        AtomicBoolean userCertified = new AtomicBoolean(false);
+        if (R.isOk(certUser) && certUserInfo != null) {
             try {
-                PartyBuildingMemberVO certUserVo = JSONObject.parseObject(JSONObject.toJSONString(certUser.getData()), PartyBuildingMemberVO.class);
+                List<PartyBuildingMemberVO> partyBuildingMemberVOList = JSONArray.parseArray(JSONArray.toJSONString(certUser.getData()), PartyBuildingMemberVO.class);
                 //已认证党员身份,直接返回
-                userCertified = certUserVo.getAuditResult() == 1;
+                if(partyBuildingMemberVOList!=null && partyBuildingMemberVOList.size()>0) {
+                    partyBuildingMemberVOList.forEach(vo -> {
+                        userCertified.set(vo.getAuditResult() == 1);
+                    });
+                }
             }catch (Exception e){}
         }
         //匹配手机,验证是否进行自动确认
-        if (userCertified) {
+        if (userCertified.get()) {
             return R.fail("您已审核通过,无需重复提交");
         }
 
@@ -378,7 +381,20 @@
         //党员认证查询
         LoginUserInfoVO loginUserInfo = this.getLoginUserInfo();
         Long userId = loginUserInfo.getUserId();
-        return partyBuildingService.userCertification(userId);
+        R r = partyBuildingService.userCertification(userId);
+
+        if(R.isOk(r)) {
+            List<PartyBuildingMemberVO> partyBuildingMemberVOList = JSONArray.parseArray(JSONArray.toJSONString(r.getData()), PartyBuildingMemberVO.class);
+            if(partyBuildingMemberVOList!=null && partyBuildingMemberVOList.size()>0){
+                Optional<PartyBuildingMemberVO> ot = partyBuildingMemberVOList.stream().filter(partyBuildingMemberVO -> partyBuildingMemberVO.getAuditResult()==1).findFirst();
+                if(ot.isPresent()){
+                    return R.ok(ot.get());
+                }else{
+                    return R.ok(partyBuildingMemberVOList.get(0));
+                }
+            }
+        }
+        return R.ok();
     }
 
 

--
Gitblit v1.7.1