From ccd28a0c35e8fff74da6ef63042fb8a896d78f7f Mon Sep 17 00:00:00 2001
From: huanghongfa <huanghongfa123456>
Date: 星期三, 29 六月 2022 09:45:52 +0800
Subject: [PATCH] 单位服务统计

---
 springcloud_k8s_panzhihuazhihuishequ/service_community/src/main/java/com/panzhihua/service_community/service/impl/ComActNeighborCircleServiceImpl.java |  129 ++++++++++++++++++++++++++++++++++++++++--
 1 files changed, 121 insertions(+), 8 deletions(-)

diff --git a/springcloud_k8s_panzhihuazhihuishequ/service_community/src/main/java/com/panzhihua/service_community/service/impl/ComActNeighborCircleServiceImpl.java b/springcloud_k8s_panzhihuazhihuishequ/service_community/src/main/java/com/panzhihua/service_community/service/impl/ComActNeighborCircleServiceImpl.java
index 2139a1d..ebb6550 100644
--- a/springcloud_k8s_panzhihuazhihuishequ/service_community/src/main/java/com/panzhihua/service_community/service/impl/ComActNeighborCircleServiceImpl.java
+++ b/springcloud_k8s_panzhihuazhihuishequ/service_community/src/main/java/com/panzhihua/service_community/service/impl/ComActNeighborCircleServiceImpl.java
@@ -1,11 +1,16 @@
 package com.panzhihua.service_community.service.impl;
 
-import java.util.ArrayList;
-import java.util.Date;
-import java.util.List;
+import java.util.*;
 
 import javax.annotation.Resource;
 
+import cn.hutool.core.collection.ListUtil;
+import cn.hutool.core.date.DateUtil;
+import com.panzhihua.common.model.vos.LoginUserInfoVO;
+import com.panzhihua.common.model.vos.common.ComPbCheckUnitVo;
+import com.panzhihua.common.service.user.UserService;
+import com.panzhihua.service_community.service.ComActNeighborCircleTopicService;
+import org.apache.commons.lang3.ObjectUtils;
 import org.springframework.beans.BeanUtils;
 import org.springframework.stereotype.Service;
 import org.springframework.transaction.annotation.Transactional;
@@ -61,7 +66,14 @@
     private ComActDAO comActDAO;
     @Resource
     private ComActNeighborCircleTopicMapper comActNeighborCircleTopicMapper;
-
+    @Resource
+    private ComActNeighborCircleTopicService comActNeighborCircleTopicService;
+    @Resource
+    private UserService userService;
+    @Resource
+    private ComPbMemberDAO comPbMemberDAO;
+    @Resource
+    private ComActNeighborCircleDAO comActNeighborCircleDAO;
     /**
      * 分页查询邻里圈列表
      *
@@ -71,6 +83,18 @@
      */
     @Override
     public R pageNeighborByApp(ComActNeighborCircleAppDTO neighborCircleAppDTO) {
+//        if(neighborCircleAppDTO.getCommunityId()==0L){
+//            R<LoginUserInfoVO> loginUserInfoVOR=userService.getUserInfoByUserId(neighborCircleAppDTO.getUserId().toString());
+//            if(R.isOk(loginUserInfoVOR)){
+//                LoginUserInfoVO loginUserInfoVO=loginUserInfoVOR.getData();
+//                if(loginUserInfoVO!=null){
+//                 ComPbMemberDO comPbMemberDO=comPbMemberDAO.selectOne(new QueryWrapper<ComPbMemberDO>().lambda().eq(ComPbMemberDO::getIdCard,loginUserInfoVO.getIdCard()));
+//                 if(comPbMemberDO!=null){
+//                     neighborCircleAppDTO.setCommunityId(comPbMemberDO.getCommunityId());
+//                 }
+//                }
+//            }
+//        }
         Page userPage = new Page(neighborCircleAppDTO.getPageNum(), neighborCircleAppDTO.getPageSize());
         IPage<ComActNeighborCircleAppVO> doPager = this.baseMapper.pageNeighborByApp(userPage, neighborCircleAppDTO);
         if (!doPager.getRecords().isEmpty()) {
@@ -95,6 +119,43 @@
                     ComActDO actDO = comActDAO.selectById(circleAppVO.getCommunityId());
                     if (actDO != null) {
                         circleAppVO.setName(actDO.getName());
+                    }
+                }
+
+            }
+        }
+        return R.ok(doPager);
+    }
+
+    @Override
+    public R selectSolve(ComActNeighborCircleAppDTO neighborCircleAppDTO) {
+        IPage<ComActNeighborCircleAppVO> doPager=this.baseMapper.selectSolve(new Page<ComActNeighborCircleDO>(neighborCircleAppDTO.getPageNum(),neighborCircleAppDTO.getPageSize()),neighborCircleAppDTO);
+        if (!doPager.getRecords().isEmpty()) {
+            for (ComActNeighborCircleAppVO circleAppVO : doPager.getRecords()) {
+                if (neighborCircleAppDTO.getSolveId() != null) {
+                    // 查询点赞信息
+                    ComActNeighborCircleFabulousDO circleFabulousDO =
+                            comActNeighborCircleFabulousDAO.selectOne(new QueryWrapper<ComActNeighborCircleFabulousDO>()
+                                    .lambda().eq(ComActNeighborCircleFabulousDO::getParentId, circleAppVO.getId())
+                                    .eq(ComActNeighborCircleFabulousDO::getUserId, neighborCircleAppDTO.getUserId())
+                                    .eq(ComActNeighborCircleFabulousDO::getType, ComActNeighborCircleFabulousDO.type.llq)
+                                    .eq(ComActNeighborCircleFabulousDO::getIsEffective,
+                                            ComActNeighborCircleFabulousDO.isEffective.yes));
+                    if (circleFabulousDO != null) {
+                        circleAppVO.setHaveSign(1);
+                    } else {
+                        circleAppVO.setHaveSign(2);
+                    }
+                }
+                ComActDO actDO = comActDAO.selectById(circleAppVO.getCommunityId());
+                if (circleAppVO.getType() != null && circleAppVO.getType().equals(ComActNeighborCircleDO.type.admin)) {
+                    if (actDO != null) {
+                        circleAppVO.setName(actDO.getName());
+                    }
+                }
+                else {
+                    if (actDO != null) {
+                        circleAppVO.setCommunityName(actDO.getName());
                     }
                 }
 
@@ -253,8 +314,10 @@
         Page page = new Page(neighborCircleAdminDTO.getPageNum(), neighborCircleAdminDTO.getPageSize());
         IPage<ComActNeighborCircleAdminVO> doPager = this.baseMapper.pageNeighborByAdmin(page, neighborCircleAdminDTO);
         doPager.getRecords().forEach(data -> {
-            if (data.getUserType() != 1) {
-                data.setReleaseName(data.getCommunityName());
+            if(data.getUserType()!=null){
+                if (data.getUserType() != 1) {
+                    data.setReleaseName(data.getCommunityName());
+                }
             }
         });
         return R.ok(doPager);
@@ -283,6 +346,7 @@
         comActNeighborCircleDO.setLastCommentNum(0);
         comActNeighborCircleDO.setLastFabulousNum(0);
         comActNeighborCircleDO.setLastViewsNum(0);
+        comActNeighborCircleDO.setBelongType(addVO.getBelongType());
         this.baseMapper.insert(comActNeighborCircleDO);
         return R.ok();
     }
@@ -317,7 +381,7 @@
     public R neighborExamineByApp(ComActNeighborCircleAppDTO neighborCircleAppDTO) {
         IPage<ComActNeighborCircleAppVO> neighborCircleIPage = this.baseMapper.neighborExamineByApp(
             new Page<>(neighborCircleAppDTO.getPageNum(), neighborCircleAppDTO.getPageSize()),
-            neighborCircleAppDTO.getUserId());
+            neighborCircleAppDTO.getUserId(),neighborCircleAppDTO.getBelongType());
         if (!neighborCircleIPage.getRecords().isEmpty()) {
             for (ComActNeighborCircleAppVO circleAppVO : neighborCircleIPage.getRecords()) {
                 // 查询点赞信息
@@ -633,7 +697,8 @@
 
     @Override
     public R detailNeighborByAdmin(Long id) {
-        ComActNeighborCircleDO comActNeighborCircleDO = this.baseMapper.selectById(id);
+        ComActNeighborCircleDetailAppVO comActNeighborCircleDO =
+                this.baseMapper.neighborDetailByApp(id);
         if (comActNeighborCircleDO == null) {
             return R.fail("id有误");
         }
@@ -641,6 +706,7 @@
         DetailNeighborCircleAdminVO vo = new DetailNeighborCircleAdminVO();
         BeanUtils.copyProperties(comActNeighborCircleDO, vo);
         vo.setReleaseName(user.getName());
+        vo.setImageUrl(user.getImageUrl());
 
         // 查询话题名称
         if (comActNeighborCircleDO.getTopicId() != null) {
@@ -697,6 +763,7 @@
         BeanUtils.copyProperties(commentDO, vo);
         String name = user.getName() == null ? user.getNickName() : user.getName();
         vo.setUserName(name);
+        vo.setUserPhone(user.getPhone());
         return R.ok(vo);
     }
 
@@ -900,4 +967,50 @@
         }
         return R.fail();
     }
+
+    @Override
+    public R orderAndSolve(EditNeighborCircleAdminVO editNeighborCircleAdminVO) {
+        ComActNeighborCircleDO comActNeighborCircleDO=new ComActNeighborCircleDO();
+        BeanUtils.copyProperties(editNeighborCircleAdminVO,comActNeighborCircleDO);
+        if(comActNeighborCircleDO.getSolveStatus()!=null){
+            comActNeighborCircleDO.setSolveTime(new Date());
+        }
+        if(comActNeighborCircleDO.getOrderStatus()!=null){
+            comActNeighborCircleDO.setOrderTime(new Date());
+        }
+        if(StringUtils.isNotEmpty(comActNeighborCircleDO.getComment())){
+            comActNeighborCircleDO.setCommentTime(new Date());
+        }
+        return R.ok(this.baseMapper.updateById(comActNeighborCircleDO));
+    }
+
+    @Override
+    public R institutionalUnitServiceAnalysis(Integer year,Long communityId) {
+        //根据年份获取一年的开始和结束时间
+        String beginTime=null;
+        String endTime=null;
+        if (null != year && 0 !=year){
+            beginTime= year.toString()+"-01-01" ;
+            endTime=year.toString()+"-12-31";
+        }
+        //根据communityId分组获取活动时长,活动次数
+        List<ComActNeighborCircleAnalysisVO> comActNeighborCircleAnalysisVOS = comActNeighborCircleDAO.institutionalUnitServiceAnalysis(beginTime,endTime,communityId);
+        //填充单位,社区信息
+        if (comActNeighborCircleAnalysisVOS.size()>0){
+            for (ComActNeighborCircleAnalysisVO vo : comActNeighborCircleAnalysisVOS) {
+                if (ObjectUtils.isNotEmpty(vo)){
+                    if (ObjectUtils.isNotEmpty(vo.getCommunityId())){
+                        vo.setCommunityName(comActDAO.selectById(vo.getCommunityId()).getName());
+                    }
+                    if (ObjectUtils.isNotEmpty(vo.getUnitId())){
+                        vo.setUnitName(comActDAO.getUnitName(vo.getUnitId()));
+                    }
+                }
+            }
+        }
+        ActivityAnalysisVO activityAnalysisVO=new ActivityAnalysisVO();
+        activityAnalysisVO.setDataList(comActNeighborCircleAnalysisVOS);
+        activityAnalysisVO.setUnitCount(comActDAO.getUnitCount());
+        return R.ok(activityAnalysisVO);
+    }
 }

--
Gitblit v1.7.1