From c3311d511bcb571dc92c31714d5b7b1e2fda47da Mon Sep 17 00:00:00 2001
From: 张天森 <1292933220@qq.com>
Date: 星期三, 13 七月 2022 16:51:46 +0800
Subject: [PATCH] 用户统计隐藏默认社区数据

---
 springcloud_k8s_panzhihuazhihuishequ/service_user/src/main/java/com/panzhihua/service_user/service/impl/UserServiceImpl.java |   56 +++++++++++++++++++++++++++++++++++++++++++++++++++++++-
 1 files changed, 55 insertions(+), 1 deletions(-)

diff --git a/springcloud_k8s_panzhihuazhihuishequ/service_user/src/main/java/com/panzhihua/service_user/service/impl/UserServiceImpl.java b/springcloud_k8s_panzhihuazhihuishequ/service_user/src/main/java/com/panzhihua/service_user/service/impl/UserServiceImpl.java
index fa844b1..e5f9158 100644
--- a/springcloud_k8s_panzhihuazhihuishequ/service_user/src/main/java/com/panzhihua/service_user/service/impl/UserServiceImpl.java
+++ b/springcloud_k8s_panzhihuazhihuishequ/service_user/src/main/java/com/panzhihua/service_user/service/impl/UserServiceImpl.java
@@ -3435,7 +3435,12 @@
         }
         List<UserProportion> userProportions = userDao.userAnalysis(type, date, streetId,areaCode);
         List<UserRateAnalysisVO> userRateAnalysisVOList=new ArrayList<>();
-        final Boolean monthRange=range.equals(1);
+        Boolean monthRange=false;
+        if (org.apache.commons.lang3.ObjectUtils.isNotEmpty(range)){
+            if (range.equals(1)){
+                monthRange=true;
+            }
+        }
         if (userProportions.size()>0){
             for (UserProportion userProportion : userProportions) {
                 if (org.apache.commons.lang3.ObjectUtils.isNotEmpty(userProportion)){
@@ -3466,6 +3471,7 @@
         userRate.setUserList(userRateAnalysisVOList);
         return R.ok(userRate);
     }
+
 
     @Override
     public R realUser(Integer type, Long streetId, Long areaCode, Integer range) {
@@ -3498,6 +3504,22 @@
             realUserList.add(vo);
         }
         realUserVO.setRealUserList(realUserList);
+        //使用索引迭代避免从列表移除数据后出现空指针异常
+        if (type.equals(BYSTREET) || type.equals(ALLCOMMUNITY)){
+            for (int i = 0; i <= realUserList.size() ; i++) {
+                RealUserAnalysisVO realUserAnalysisVO = realUserList.get(i);
+                if (org.apache.commons.lang3.ObjectUtils.isNotEmpty(realUserAnalysisVO)){
+                    if (StringUtils.isNotEmpty(realUserAnalysisVO.getName())){
+                        if (realUserAnalysisVO.getName().equals("请选择社区")){
+                            realUserList.remove(realUserAnalysisVO);
+                        }
+                    }
+                }
+            }
+        }else {
+            //只保留十条
+            realUserList.remove(10);
+        }
         return R.ok(realUserVO);
     }
 
@@ -3526,6 +3548,38 @@
     }
 
     @Override
+    public R uuPush(String washPhone,String phone,String washName,Integer orderStatus) {
+        if(StringUtils.isNotEmpty(phone)){
+            SysUserDO sysUserDO=userDao.selectOne(new QueryWrapper<SysUserDO>().lambda().eq(SysUserDO::getPhone,phone).orderByDesc(SysUserDO::getCreateAt).last("limit 1"));
+            if(sysUserDO!=null&&StringUtils.isNotEmpty(sysUserDO.getOpenid())){
+                String status="";
+                String accessToken="";
+                WxXCXTempSend util = new WxXCXTempSend();
+                try {
+                    accessToken = util.getAccessToken();
+                } catch (Exception e) {
+                    e.printStackTrace();
+                }
+                switch (orderStatus){
+                    case 3 : status="已分配车美";
+                        WxUtil.sendUuWash3(sysUserDO.getOpenid(),accessToken,status,washName,washPhone,phone,"sU18zbyzxFldHAdOREaQCR5uq_uMvCKTmGtklO1xw-w");
+                    break;
+                    case 4 : status="车美已开始服务";
+                        WxUtil.sendUuWash4(sysUserDO.getOpenid(),accessToken,status,washName,washPhone,phone,"Eft5ksvsnOQANy2uNOGY43CC3pb33eDGA_lgCEoxuiw");
+                    break;
+                    case 6 : status="订单确认完成";
+                        WxUtil.sendUuWash6(sysUserDO.getOpenid(),accessToken,status,washName,washPhone,phone,"k1aV97H3pDNNcNcDTeZBD9jQemNDADnRE801HhTXweI");
+                    break;
+                    case 9 : status="订单已取消";
+                        WxUtil.sendUuWash(sysUserDO.getOpenid(),accessToken,status,washName,washPhone,phone,"9_2FhQPDxZoUqmAuIZ1L1zjjYXokdNvu7A0gzKfvruI");
+                    break;
+                }
+            }
+        }
+        return R.ok();
+    }
+
+    @Override
     public R getAreaAndStreet() {
         List<Integer> areaCodeList=areaCodeList();
         List<AreaVO> areaVOList=new ArrayList<>();

--
Gitblit v1.7.1