lidongdong
2024-07-11 eef6d2bcdb29348efe4ef17bc45a4c6886b487b1
springcloud_k8s_panzhihuazhihuishequ/service_community/src/main/java/com/panzhihua/service_community/service/impl/ComStreetServiceImpl.java
@@ -1,9 +1,6 @@
package com.panzhihua.service_community.service.impl;
import java.util.ArrayList;
import java.util.Comparator;
import java.util.List;
import java.util.TreeSet;
import java.util.*;
import java.util.stream.Collectors;
@@ -37,6 +34,7 @@
import com.panzhihua.service_community.util.WxDataUtil;
import org.springframework.beans.BeanUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.redis.core.StringRedisTemplate;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
import org.springframework.util.ObjectUtils;
@@ -76,6 +74,9 @@
    @Autowired
    private CommunityService communityService;
    @Resource
    private StringRedisTemplate stringRedisTemplate;
    /**
     * 新增社区
@@ -324,8 +325,23 @@
    public R getScreenStatics() {
        ScreenStatics screenStatics = comActDAO.getScreenStatics();
        WxDataUtil wxDataUtil=new WxDataUtil();
        screenStatics.setDayUser(wxDataUtil.getDayUser());
        screenStatics.setCountUser(wxDataUtil.getMonthUser());
        //微信查询较慢 数据时有 时没有  缓存到 redis 里
        //日 活跃
        if(null != wxDataUtil.getDayUser()){
            stringRedisTemplate.opsForValue().set("WxDataUtil_Day",String.valueOf(wxDataUtil.getDayUser()));
            screenStatics.setDayUser(wxDataUtil.getDayUser());
        }else {
            Object obj = stringRedisTemplate.opsForValue().get("WxDataUtil_Day");
            screenStatics.setDayUser(Integer.valueOf((String)obj));
        }
        //月 活跃
        if(null != wxDataUtil.getMonthUser()){
            stringRedisTemplate.opsForValue().set("WxDataUtil_Month",String.valueOf(wxDataUtil.getMonthUser()));
            screenStatics.setCountUser(wxDataUtil.getMonthUser());
        }else {
            Object obj = stringRedisTemplate.opsForValue().get("WxDataUtil_Month");
            screenStatics.setCountUser(Integer.valueOf((String)obj));
        }
        return R.ok(screenStatics);
    }
@@ -392,7 +408,7 @@
        if(type.equals("3")){// 3 查询 小区
            qry.eq( !StringUtils.isEmpty(code),ComActDO::getCommunityId,code);
        }
        qry.eq(ComActDO::getAppId,"wx118de8a734d269f0");
//        qry.eq(ComActDO::getAppId,"wx118de8a734d269f0");
        List<ComActDO> doList = comActDAO.selectList(qry);
        //解析 社区id
        List<Long> ids = doList.stream().map(ComActDO::getCommunityId).collect(Collectors.toList());