网格统计

epmet-module/gov-org/gov-org-client/src/main/java/com/epmet/dto/result/CustomerGridStatisticsReulstDTO.java

@@ -0,0 +1,29 @@
+package com.epmet.dto.result;
+
+import lombok.Data;
+
+import java.io.Serializable;
+import java.util.Date;
+
+
+/**
+ * 网格治理人员统计
+ *
+ * @author generator generator@elink-cn.com
+ * @since v1.0.0 2023-11-27
+ */
+@Data
+public class CustomerGridStatisticsReulstDTO implements Serializable {
+
+    private static final long serialVersionUID = 1L;
+
+    private Integer girdNum;
+
+    private Integer girdShujiNum;
+
+    private Integer girdHeadNum;
+
+    private Integer girdZhuanzhiNum;
+
+    private Integer girdZhuanyeNum;
+}

epmet-module/gov-org/gov-org-server/src/main/java/com/epmet/controller/CustomerGridManageUserController.java

@@ -11,6 +11,7 @@ import com.epmet.commons.tools.validator.group.UpdateGroup;
 import com.epmet.commons.tools.validator.group.DefaultGroup;
 import com.epmet.dto.CustomerCommunityManageUserDTO;
 import com.epmet.dto.CustomerGridManageUserDTO;
+import com.epmet.dto.result.CustomerGridStatisticsReulstDTO;
 import com.epmet.excel.CustomerGridManageUserExcel;
 import com.epmet.service.CustomerGridManageUserService;
 import org.springframework.beans.factory.annotation.Autowired;
@@ -85,5 +86,12 @@ public class CustomerGridManageUserController {
     }
 
 
+    @GetMapping("screen/communityStatistics")
+    public Result<CustomerGridStatisticsReulstDTO> communityStatistics(String communityId){
+        CustomerGridStatisticsReulstDTO result = customerGridManageUserService.communityStatistics(communityId);
+        return new Result<CustomerGridStatisticsReulstDTO>().ok(result);
+    }
+
+
 
 }

epmet-module/gov-org/gov-org-server/src/main/java/com/epmet/service/CustomerGridManageUserService.java

@@ -3,6 +3,7 @@ package com.epmet.service;
 import com.epmet.commons.mybatis.service.BaseService;
 import com.epmet.commons.tools.page.PageData;
 import com.epmet.dto.CustomerGridManageUserDTO;
+import com.epmet.dto.result.CustomerGridStatisticsReulstDTO;
 import com.epmet.entity.CustomerGridManageUserEntity;
 
 import java.util.List;
@@ -77,4 +78,6 @@ public interface CustomerGridManageUserService extends BaseService<CustomerGridM
     void delete(String[] ids);
 
     List<CustomerGridManageUserDTO> listForCommnity(String gridId, String type);
+
+    CustomerGridStatisticsReulstDTO communityStatistics(String communityId);
 }

epmet-module/gov-org/gov-org-server/src/main/java/com/epmet/service/impl/CustomerGridManageUserServiceImpl.java

@@ -7,10 +7,13 @@ import com.epmet.commons.mybatis.service.impl.BaseServiceImpl;
 import com.epmet.commons.tools.page.PageData;
 import com.epmet.commons.tools.utils.ConvertUtils;
 import com.epmet.commons.tools.constant.FieldConstant;
+import com.epmet.dao.CustomerGridDao;
 import com.epmet.dao.CustomerGridManageUserDao;
 import com.epmet.dto.CustomerCommunityManageUserDTO;
 import com.epmet.dto.CustomerGridManageUserDTO;
+import com.epmet.dto.result.CustomerGridStatisticsReulstDTO;
 import com.epmet.entity.CustomerCommunityManageUserEntity;
+import com.epmet.entity.CustomerGridEntity;
 import com.epmet.entity.CustomerGridManageUserEntity;
 import com.epmet.redis.CustomerGridManageUserRedis;
 import com.epmet.service.CustomerGridManageUserService;
@@ -22,6 +25,7 @@ import org.springframework.transaction.annotation.Transactional;
 import java.util.Arrays;
 import java.util.List;
 import java.util.Map;
+import java.util.stream.Collectors;
 
 /**
  * 网格治理人员
@@ -35,6 +39,9 @@ public class CustomerGridManageUserServiceImpl extends BaseServiceImpl<CustomerG
     @Autowired
     private CustomerGridManageUserRedis customerGridManageUserRedis;
 
+    @Autowired
+    private CustomerGridDao customerGridDao;
+
     @Override
     public PageData<CustomerGridManageUserDTO> page(Map<String, Object> params) {
         IPage<CustomerGridManageUserEntity> page = baseDao.selectPage(
@@ -99,4 +106,31 @@ public class CustomerGridManageUserServiceImpl extends BaseServiceImpl<CustomerG
         return ConvertUtils.sourceToTarget(entityList, CustomerGridManageUserDTO.class);
     }
 
+    @Override
+    public CustomerGridStatisticsReulstDTO communityStatistics(String communityId) {
+
+        CustomerGridStatisticsReulstDTO customerGridStatisticsReulstDTO = new CustomerGridStatisticsReulstDTO();
+
+        LambdaQueryWrapper<CustomerGridEntity> gridEntityLambdaQueryWrapper = new LambdaQueryWrapper<CustomerGridEntity>()
+                .eq(CustomerGridEntity::getPid,communityId);
+        List<CustomerGridEntity> gridEntityList = customerGridDao.selectList(gridEntityLambdaQueryWrapper);
+        customerGridStatisticsReulstDTO.setGirdNum(gridEntityList.size());
+        customerGridStatisticsReulstDTO.setGirdHeadNum(gridEntityList.size());
+        customerGridStatisticsReulstDTO.setGirdShujiNum(gridEntityList.size());
+
+        List<String> gridIds = gridEntityList.stream().map(CustomerGridEntity::getId).collect(Collectors.toList());
+        if (gridIds.size() > 0){
+            LambdaQueryWrapper<CustomerGridManageUserEntity> lambdaQueryWrapper = new LambdaQueryWrapper<CustomerGridManageUserEntity>()
+                    .eq(CustomerGridManageUserEntity::getType,"1").in(CustomerGridManageUserEntity::getGridId,gridIds);
+            List<CustomerGridManageUserEntity> zhuanzhi = baseDao.selectList(lambdaQueryWrapper);
+            customerGridStatisticsReulstDTO.setGirdZhuanzhiNum(zhuanzhi.size());
+
+            lambdaQueryWrapper = new LambdaQueryWrapper<CustomerGridManageUserEntity>()
+                    .eq(CustomerGridManageUserEntity::getType,"3").in(CustomerGridManageUserEntity::getGridId,gridIds);
+            List<CustomerGridManageUserEntity> zhuanye = baseDao.selectList(lambdaQueryWrapper);
+            customerGridStatisticsReulstDTO.setGirdZhuanyeNum(zhuanye.size());
+        }
+        return customerGridStatisticsReulstDTO;
+    }
+
 }