smartor.git - Gitblit

			@@ -2,6 +2,8 @@

			import com.github.pagehelper.ISelect;
			import com.ruoyi.common.annotation.Log;
			import com.ruoyi.common.constant.CacheConstants;
			import com.ruoyi.common.constant.Constants;
			import com.ruoyi.common.constant.HttpStatus;
			import com.ruoyi.common.core.controller.BaseController;
			import com.ruoyi.common.core.domain.AjaxResult;
			@@ -15,6 +17,8 @@
			import com.ruoyi.common.utils.DtoConversionUtils;
			import com.ruoyi.common.utils.PageUtils;
			import com.ruoyi.common.utils.poi.ExcelUtil;
			import com.ruoyi.common.utils.reflect.ReflectUtils;
			import com.ruoyi.common.utils.uuid.IdUtils;
			import com.smartor.domain.*;
			import com.smartor.mapper.PatMedInhospMapper;
			import com.smartor.mapper.PatMedOuthospMapper;
			@@ -27,6 +31,7 @@
			import lombok.extern.slf4j.Slf4j;
			import net.bytebuddy.implementation.bytecode.Throw;
			import org.apache.commons.collections4.CollectionUtils;
			import org.apache.commons.collections4.MapUtils;
			import org.apache.commons.lang3.ObjectUtils;
			import org.springframework.beans.factory.annotation.Autowired;
			import org.springframework.beans.factory.annotation.Value;
			@@ -39,6 +44,7 @@
			import java.util.HashMap;
			import java.util.List;
			import java.util.Map;
			import java.util.concurrent.TimeUnit;
			import java.util.stream.Collectors;

			/**
			@@ -63,6 +69,9 @@

			@Value("${spring.profiles.active}")
			private String active;

			@Autowired
			private RedisCache redisCache;

			/**
			* 查询患者随访信息
			@@ -90,7 +99,17 @@
			ServiceTask serviceTask = serviceTaskService.selectServiceTaskByTaskid(serviceSubtask.getTaskid());
			if (ObjectUtils.isNotEmpty(serviceTask)) serviceSubtask.setPreachform(serviceTask.getPreachform());
			}
			Map<String, Object> map = serviceSubtaskService.patItemCount(serviceSubtaskVO);

			/**
			* 代码优化分离统计
			Map<String, Object> map = new HashMap<>();
			map.put("serviceSubtaskList", serviceSubtaskList);
			List<Map<String, Object>> list = new ArrayList<>();
			list.add(map);
			**/
			//Map<String, Object> map = serviceSubtaskService.patItemCount(serviceSubtaskVO);
			//patItemCount 调用redisCache记录统计数据
			Map<String, Object> map = patItemCount(serviceSubtaskVO);
			map.put("serviceSubtaskList", serviceSubtaskList);
			List<Map<String, Object>> list = new ArrayList<>();
			list.add(map);
			@@ -104,6 +123,69 @@
			}
			});
			return getDataTable2(total, list);
			}

			/**
			* 统计随访数据
			*/
			@ApiOperation("统计随访数据")
			@PostMapping("/patItemCount")
			public Map<String, Object> patItemCount(@RequestBody ServiceSubtaskVO serviceSubtaskVO) {
			Map<String, Object> map = new HashMap<>();
			// 通过redis记录结果
			Map<String, Object> redisMap = new HashMap<>();
			LoginUser loginUser = getLoginUser();
			SysUser user = null;
			Long userId = null;
			if(ObjectUtils.isNotEmpty(loginUser)){
			user = loginUser.getUser();
			if(ObjectUtils.isNotEmpty(user)){
			userId = user.getUserId();
			}
			}
			if(ObjectUtils.isNotEmpty(userId)){
			redisMap = redisCache.getCacheObject(userId + "patItemCount");
			//记录是否有可用缓存
			Boolean redisFlag = false;
			ServiceSubtaskVO oldCondition = null;
			if(MapUtils.isNotEmpty(redisMap)){
			oldCondition = (ServiceSubtaskVO)redisMap.get(userId + "searchCondition");
			// 比较查询条件是否一致
			if(ObjectUtils.isNotEmpty(oldCondition) &&
			isSameCondition(oldCondition, serviceSubtaskVO)){
			// 条件一致，使用缓存
			redisFlag = true;
			map = redisMap;
			redisCache.setCacheObject(userId + "patItemCount", map, 120, TimeUnit.MINUTES);
			}
			}

			// 如果没有缓存或者条件不一致，重新查询
			if(!redisFlag){
			map = serviceSubtaskService.patItemCount(serviceSubtaskVO);
			map.put(userId + "searchCondition", serviceSubtaskVO);
			redisCache.setCacheObject(userId + "patItemCount", map, 120, TimeUnit.MINUTES);
			}
			}

			map.put("code", HttpStatus.SUCCESS);
			return map;
			}

			/**
			* 比较两个ServiceSubtaskVO的查询条件是否一致
			* 使用反射比较所有字段，排除分页参数和无关字段
			*/
			private boolean isSameCondition(ServiceSubtaskVO oldCondition, ServiceSubtaskVO newCondition) {
			// 使用ReflectUtils的通用方法比较，排除分页参数等无关字段
			return ReflectUtils.equalsAllFields(
			oldCondition,
			newCondition,
			// 排除的字段：分页参数、序列化ID、时间戳等
			"pageNum", "pageSize", "serialVersionUID",
			"createBy", "createTime", "updateBy", "updateTime",
			"searchValue", "params"
			);
			}


			@@ -152,7 +234,9 @@
			serviceSubtaskRecord.setTaskid(serviceSubtask.getTaskid().toString());
			serviceSubtask.setServiceSubtaskRecordList(serviceSubtaskRecordService.selectServiceSubtaskRecordList(serviceSubtaskRecord));
			}
			//todo 代码优化
			Map<String, Object> map = serviceSubtaskService.patItemCount(serviceSubtaskVO);
			// Map<String, Object> map = patItemCount(serviceSubtaskVO);
			map.put("serviceSubtaskList", serviceSubtaskList);
			List<Map<String, Object>> list = new ArrayList<>();
			list.add(map);
			@@ -419,10 +503,14 @@

			ExcelUtil<ServiceSubtaskStatistic> util = new ExcelUtil<ServiceSubtaskStatistic>(ServiceSubtaskStatistic.class);

			String sheetName = "";
			String fileName = "";
			if (active.equals("ls") \|\| active.equals("druid")) {
			util.exportExcel(response, sfStatistics, LocalDate.now().getMonthValue() + "月出院随访统计表");
			fileName = sheetName = LocalDate.now().getMonthValue() + "月出院随访统计表";
			util.exportExcelWithFileName(response, sfStatistics, sheetName, fileName);
			} else {
			util.exportExcel(response, sfStatistics, "随访统计导出");
			sheetName = "随访统计导出";
			util.exportExcel(response, sfStatistics, sheetName);
			}
			}