From 8b7258c9427882bb1798f1502eaa35184c6e374e Mon Sep 17 00:00:00 2001
From: linwe <872216996@qq.com>
Date: Fri, 09 Aug 2024 14:29:18 +0800
Subject: [PATCH] 短信指定楼栋发送

---
 src/main/java/org/springblade/modules/task/service/impl/TaskReportForRepairsServiceImpl.java |   56 ++++++++++++++++++++++++++++++++++----------------------
 1 files changed, 34 insertions(+), 22 deletions(-)

diff --git a/src/main/java/org/springblade/modules/task/service/impl/TaskReportForRepairsServiceImpl.java b/src/main/java/org/springblade/modules/task/service/impl/TaskReportForRepairsServiceImpl.java
index 80e0a26..d81651c 100644
--- a/src/main/java/org/springblade/modules/task/service/impl/TaskReportForRepairsServiceImpl.java
+++ b/src/main/java/org/springblade/modules/task/service/impl/TaskReportForRepairsServiceImpl.java
@@ -18,7 +18,6 @@
 
 import com.baomidou.mybatisplus.core.metadata.IPage;
 import com.baomidou.mybatisplus.core.toolkit.Wrappers;
-import org.springblade.common.cache.SysCache;
 import org.springblade.common.param.CommonParamSet;
 import org.springblade.common.utils.RoleUtil;
 import org.springblade.common.utils.SpringUtils;
@@ -28,14 +27,12 @@
 import org.springblade.modules.district.entity.DistrictEntity;
 import org.springblade.modules.district.service.IDistrictService;
 import org.springblade.modules.grid.entity.GridmanEntity;
-import org.springblade.modules.grid.service.IGridService;
 import org.springblade.modules.property.entity.PropertyCompanyDistrictEntity;
 import org.springblade.modules.property.entity.PropertyCompanyEntity;
 import org.springblade.modules.property.service.IPropertyCompanyDistrictService;
 import org.springblade.modules.property.service.IPropertyCompanyService;
 import org.springblade.modules.property.service.IPropertyDistrictUserService;
 import org.springblade.modules.sse.server.SSEServer;
-import org.springblade.modules.system.service.IDeptService;
 import org.springblade.modules.task.entity.TaskEntity;
 import org.springblade.modules.task.entity.TaskReportForRepairsEntity;
 import org.springblade.modules.task.mapper.TaskReportForRepairsMapper;
@@ -43,7 +40,6 @@
 import org.springblade.modules.task.service.ITaskService;
 import org.springblade.modules.task.vo.TaskReportForRepairsVO;
 import org.springblade.modules.task.vo.TaskReportStatistics;
-import org.springblade.modules.taskPlaceSelfCheck.vo.TaskPlaceSelfCheckVO;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
 import org.springframework.transaction.annotation.Transactional;
@@ -64,11 +60,6 @@
 	@Autowired
 	private ITaskService taskService;
 
-	@Autowired
-	private IGridService gridService;
-
-	@Autowired
-	private IDeptService deptService;
 
 	/**
 	 * 自定义分页
@@ -80,18 +71,19 @@
 	@Override
 	public IPage<TaskReportForRepairsVO> selectTaskReportForRepairsPage(IPage<TaskReportForRepairsVO> page, TaskReportForRepairsVO taskReportForRepairs) {
 		// 公共参数设置
-		CommonParamSet commonParamSet = new CommonParamSet().invoke(TaskReportForRepairsVO.class,taskReportForRepairs);
-		taskReportForRepairs.setConfirmUserId(AuthUtil.getUserId());
-		List<String> addressCodeList = new ArrayList<>();
+		CommonParamSet commonParamSet = new CommonParamSet().invoke(TaskReportForRepairsVO.class, taskReportForRepairs);
+		String userRole = AuthUtil.getUserRole();
+		if (RoleUtil.isProperty(userRole) || RoleUtil.isWgy(userRole)){
+			taskReportForRepairs.setConfirmUserId(AuthUtil.getUserId());
+		}
 		if (null != taskReportForRepairs.getRoleName() && !taskReportForRepairs.getRoleName().equals("")) {
-			 if (taskReportForRepairs.getRoleName().equals("居民")) {
+			if (taskReportForRepairs.getRoleName().equals("inhabitant")) {
 				taskReportForRepairs.setCreateUser(AuthUtil.getUserId());
 				taskReportForRepairs.setConfirmUserId(null);
 				//
 				taskReportForRepairs.setRoleType("inhabitant");
 			}
 		}
-		String userRole = AuthUtil.getUserRole();
 		List<String> aoiCodeList = new ArrayList<>();
 		if (RoleUtil.isProperty(userRole)) {
 			taskReportForRepairs.setRoleType("wy");
@@ -100,7 +92,10 @@
 			List<String> districtIds = propertyDistrictUserService.selectPropertyDistrictByUserId(AuthUtil.getUserId());
 			// 通过用户机构查询用户的物业公司
 			IPropertyCompanyService bean = SpringUtil.getBean(IPropertyCompanyService.class);
-			PropertyCompanyEntity companyEntity = bean.getOne(Wrappers.<PropertyCompanyEntity>lambdaQuery().eq(PropertyCompanyEntity::getDeptId, AuthUtil.getDeptId()));
+			PropertyCompanyEntity companyEntity = bean.getOne(Wrappers.<PropertyCompanyEntity>lambdaQuery()
+				.eq(PropertyCompanyEntity::getDeptId, AuthUtil.getDeptId())
+				.eq(PropertyCompanyEntity::getIsDeleted, 0)
+				.last("limit 1"));
 			if (companyEntity != null) {
 				IPropertyCompanyDistrictService bean2 = SpringUtils.getBean(IPropertyCompanyDistrictService.class);
 				// 通过物业公司,查询小区
@@ -119,8 +114,9 @@
 			aoiCodeList = districtEntityList.stream().map(i -> i.getAoiCode()).collect(Collectors.toList());
 		}
 
-		return page.setRecords(baseMapper.selectTaskReportForRepairsPage(page, taskReportForRepairs, addressCodeList,
-			commonParamSet.getRegionChildCodesList(), commonParamSet.getIsAdministrator(), aoiCodeList,commonParamSet.getGridCodeList()));
+		List list = baseMapper.selectTaskReportForRepairsPage(page, taskReportForRepairs, commonParamSet.getRegionChildCodesList(),
+			commonParamSet.getIsAdministrator(), aoiCodeList, commonParamSet.getGridCodeList(),commonParamSet.getCommunityCode());
+		return page.setRecords(list);
 	}
 
 	/**
@@ -130,9 +126,10 @@
 	 */
 	@Override
 	public TaskReportStatistics getStatisticsCount(String houseCode) {
-		List<String> regionChildCodesList = SysCache.getRegionChildCodesByDeptId(AuthUtil.getDeptId());
-		Integer isAdministrator = AuthUtil.isAdministrator() == true ? 1 : 2;
-		return baseMapper.getStatisticsCount(AuthUtil.getUserId(), houseCode, regionChildCodesList, isAdministrator);
+		TaskReportForRepairsVO reportForRepairsVO = new TaskReportForRepairsVO();
+		reportForRepairsVO.setHouseCode(houseCode);
+		CommonParamSet invoke = new CommonParamSet<>().invoke(TaskReportForRepairsVO.class, reportForRepairsVO);
+		return baseMapper.getStatisticsCount(AuthUtil.getUserId(), houseCode, invoke.getRegionChildCodesList(), invoke.getIsAdministrator());
 	}
 
 	/**
@@ -156,6 +153,18 @@
 		// 新增
 		boolean save = taskService.save(taskEntity);
 		if (save) {
+			// 设置网格编码
+//			if (taskReportForRepairs.getHouseFlag().equals(CommonConstant.NUMBER_TWO)) {
+//				IPlaceService bean = SpringUtils.getBean(IPlaceService.class);
+//				PlaceEntity placeEntity = bean.getOne(Wrappers.<PlaceEntity>lambdaQuery()
+//					.eq(PlaceEntity::getHouseCode, taskReportForRepairs.getAddressCode()).last("limit 1"));
+//				taskReportForRepairs.setGridCode(placeEntity.getGridCode());
+//			} else {
+//				IHouseService bean = SpringUtils.getBean(IHouseService.class);
+//				HouseEntity houseEntity = bean.getOne(Wrappers.<HouseEntity>lambdaQuery()
+//					.eq(HouseEntity::getHouseCode, taskReportForRepairs.getAddressCode()));
+//				taskReportForRepairs.setGridCode(houseEntity.getGridCode());
+//			}
 			taskReportForRepairs.setTaskId(taskEntity.getId());
 			taskReportForRepairs.setConfirmFlag(1);
 			flag = save(taskReportForRepairs);
@@ -208,8 +217,11 @@
 	}
 
 	@Override
-	public Integer getStatistics(Long userId, String neiCode) {
-		return baseMapper.getStatistics(userId, neiCode);
+	public Integer getStatistics(Long userId, String neiCode, List<String> regionChildCodesList,
+								Integer isAdministrator,
+								 List<String> gridCodeList) {
+		String roleName = SpringUtils.getRequestParam("roleName");
+		return baseMapper.getStatistics(userId, neiCode,roleName, regionChildCodesList,isAdministrator, gridCodeList);
 	}
 
 	/**

--
Gitblit v1.9.3