package com.kcim.service.impl; import cn.hutool.core.util.StrUtil; import com.baomidou.mybatisplus.extension.plugins.pagination.Page; import com.kcim.common.constants.Constant; import com.kcim.common.constants.NumberConstant; import com.kcim.common.constants.ParameterConstant; import com.kcim.common.constants.SQLParameter; import com.kcim.common.enums.CustomSqlTypeEnum; import com.kcim.common.exception.CostException; import com.kcim.common.util.BeanUtil; import com.kcim.common.util.PageUtils; import com.kcim.common.util.UserContext; import com.kcim.dao.model.*; import com.kcim.dao.model.dto.PatientItemDepartmentGroupVo; import com.kcim.dao.repository.*; import com.kcim.service.*; import com.kcim.vo.*; import com.kcim.web.reponse.ShareParamCostResponse; import lombok.extern.slf4j.Slf4j; import org.jetbrains.annotations.NotNull; import org.springframework.stereotype.Service; import org.springframework.util.CollectionUtils; import org.springframework.util.ObjectUtils; import org.springframework.util.StringUtils; import java.math.BigDecimal; import java.math.RoundingMode; import java.util.*; import java.util.concurrent.atomic.AtomicReference; import java.util.stream.Collectors; import static com.kcim.common.enums.DefaultComputeColumnEnum.*; import static com.kcim.service.impl.DrugMaterialCalculateServiceImpl.getVisitNoResponsibilityMaps; /** * @program: CostAccount * @description: * @author: Wang.YS * @create: 2024-01-15 20:40 **/ @Service("ShareParamService") @Slf4j public class ShareParamServiceImpl implements ShareParamService { /** * 项目分摊参数主表 */ ComputeShareParamRepository repository; /** * 项目分摊参数明细表 */ ComputeShareParamDetailRepository detailRepository; /** * 项目导入数据 */ ImportPatientItemRepository importPatientItemRepository; /** * 医疗服务项目字典 */ ItemRepository itemRepository; ItemEmpMapRepository itemEmpMapRepository; ItemEquipmentMapRepository itemEquipmentMapRepository; ItemSpaceMapRepository itemSpaceMapRepository; StandItemEmpMapRepository standItemEmpMapRepository; StandItemEquipmentMapRepository standItemEquipmentMapRepository; StandItemSpaceMapRepository standItemSpaceMapRepository; ShareParamTypeMapRepository shareParamTypeMapRepository; ResponsibilityDepartmentRepository responsibilityDepartmentRepository; CenterService centerService; ComputeStandShareParamRepository computeStandShareParamRepository; ComputeStandShareParamDetailRepository computeStandShareParamDetailRepository; StandItemService standItemService; SqlService sqlService; ResponsibilityDepartmentService responsibilityDepartmentService; public ShareParamServiceImpl(ComputeShareParamRepository repository, ComputeShareParamDetailRepository detailRepository, ImportPatientItemRepository importPatientItemRepository, ItemRepository itemRepository, ItemEmpMapRepository itemEmpMapRepository, ItemEquipmentMapRepository itemEquipmentMapRepository, ItemSpaceMapRepository itemSpaceMapRepository, ShareParamTypeMapRepository shareParamTypeMapRepository, ResponsibilityDepartmentRepository responsibilityDepartmentRepository, CenterService centerService, ComputeStandShareParamRepository computeStandShareParamRepository, ComputeStandShareParamDetailRepository computeStandShareParamDetailRepository, StandItemService standItemService,SqlService sqlService,ResponsibilityDepartmentService responsibilityDepartmentService ,StandItemEmpMapRepository standItemEmpMapRepository,StandItemEquipmentMapRepository standItemEquipmentMapRepository,StandItemSpaceMapRepository standItemSpaceMapRepository) { this.repository = repository; this.detailRepository = detailRepository; this.importPatientItemRepository = importPatientItemRepository; this.itemRepository = itemRepository; this.standItemEmpMapRepository = standItemEmpMapRepository; this.standItemEquipmentMapRepository = standItemEquipmentMapRepository; this.standItemSpaceMapRepository = standItemSpaceMapRepository; this.itemEmpMapRepository = itemEmpMapRepository; this.itemEquipmentMapRepository = itemEquipmentMapRepository; this.itemSpaceMapRepository = itemSpaceMapRepository; this.shareParamTypeMapRepository = shareParamTypeMapRepository; this.responsibilityDepartmentRepository = responsibilityDepartmentRepository; this.centerService = centerService; this.computeStandShareParamRepository = computeStandShareParamRepository; this.computeStandShareParamDetailRepository = computeStandShareParamDetailRepository; this.standItemService = standItemService; this.sqlService=sqlService; this.responsibilityDepartmentService=responsibilityDepartmentService; } /** * 获取项目分摊参数 * * @param current 当前页 * @param pageSize 页容量 * @param computeDate 核算年月 * @param itemType 项目类型 * @param responsibility 责任中心 * @param itemFilter 项目过滤条件 * @return 分页数据 */ @Override public Object getShareParamCostList(Integer current, Integer pageSize, String computeDate, String itemType, String responsibility, String itemFilter) { Page page = repository.getPage(current, pageSize, computeDate, itemType, responsibility, itemFilter); List records = page.getRecords(); ShareParamCostResponse response = new ShareParamCostResponse(); List titleVos = getCommonTitleVos(); response.setTitle(titleVos); if (CollectionUtils.isEmpty(records)) { response.setPageData(new PageUtils(new ArrayList<>(), NumberConstant.ZERO, pageSize, current)); return response; } List collect1 = records.stream().map(ComputeShareParam::getId).collect(Collectors.toList()); List shareParamDetails = detailRepository.getByShareParamId(computeDate, collect1); Map typeNameMap = getTypeNameDict(); shareParamDetails.forEach(record -> record.setItemTypeName(typeNameMap.get(record.getItemType()))); Map> collect = shareParamDetails.stream().collect(Collectors.groupingBy(ComputeDateShareParamVo::getCode)); List> returnList = new ArrayList<>(); //按报表头组装值 for (ComputeShareParam itemCode : records) { setResultData(titleVos, collect, returnList, itemCode.getCode()); } PageUtils pageUtils = new PageUtils(returnList, Math.toIntExact(page.getTotal()), pageSize, current); response.setPageData(pageUtils); return response; } /** * 完全法项目分摊参数计算 * @param computeDate */ @Override public void computeShareParamCost(String computeDate){ String parameterValue = centerService.getParameterValueByIndex(ParameterConstant.ITEM_CALC_TYPE,NumberConstant.ZERO); //走系统计算逻辑 if(StringUtils.isEmpty(parameterValue)|| NumberConstant.ONE_S.equals(parameterValue)||NumberConstant.THREE_S.equals(parameterValue)) { //根据参数判断是否走新的计算流程 if (NumberConstant.ONE_S.equals(centerService.getParameterValue(ParameterConstant.USER_HOSP_ITEM_CALC))) { //完全法项目分摊参数计算 calcShareParamCost(computeDate); } else { computeShareParamCostAction(computeDate); } } //走自定义SQL计算逻辑 if(NumberConstant.TWO_S.equals(parameterValue)||NumberConstant.THREE_S.equals(parameterValue)) { //执行完全法项目分摊参数计算后续处理脚本 execShareParamCostSQL(computeDate); } } /** * 项目分摊参数计算 * * @param computeDate 核算年月 */ public void computeShareParamCostAction(String computeDate) { SessionUserVO currentUser = UserContext.getCurrentUser(); //获取收费项目数据（项目） checkItemCount(computeDate, currentUser); //作废上次计算记录 repository.removeByComputeDate(computeDate, currentUser); detailRepository.removeByComputeDate(computeDate, currentUser); //获到科室与责任中心对照 List patientResponsibility = getPatientResponsibility(currentUser); Map responsibilityCodeMap = new HashMap<>(); Map responsibilityNameMap = new HashMap<>(); patientResponsibility.forEach(visitNoResponsibilityMap -> { responsibilityCodeMap.put(visitNoResponsibilityMap.getDepartmentCode(), visitNoResponsibilityMap.getResponsibilityCode()); responsibilityNameMap.put(visitNoResponsibilityMap.getDepartmentCode(), visitNoResponsibilityMap.getResponsibilityName()); }); //医疗服务项目字典 Map> itemMap = getItemMap(); //获取计算列 List shareParamType = shareParamTypeMapRepository.getList(); //主表公共对象 ComputeShareParam computeShareCost = new ComputeShareParam(); computeShareCost.setComputeDate(computeDate); computeShareCost.setHospId(currentUser.getHospId()); computeShareCost.setCreateUser(String.valueOf(currentUser.getId())); computeShareCost.setCreateTime(new Date()); //明细表公共对象 ComputeShareParamDetail costDetail = new ComputeShareParamDetail(); costDetail.setComputeDate(computeDate); costDetail.setHospId(currentUser.getHospId()); costDetail.setCreateUser(String.valueOf(currentUser.getId())); costDetail.setCreateTime(new Date()); // long count = (itemSize + LIMIT - 1) / LIMIT; // for (int j = 0; j < count; j++) { List items = importPatientItemRepository.getByDepartGroupComputeDateItem(computeDate, currentUser); List saveDetails = new ArrayList<>(); List saveCost = new ArrayList<>(); if (!CollectionUtils.isEmpty(items)) { for (int i = 0; i < items.size(); i++) { PatientItemDepartmentGroupVo item = items.get(i); ComputeShareParam itemCost = BeanUtil.convertObj(computeShareCost, ComputeShareParam.class); itemCost.setCode(item.getItemCode()); itemCost.setName(item.getItemName()); itemCost.setNum(item.getNum()); Map departmentItem = itemMap.get(item.getExecuteDepartmentCode()); if (CollectionUtils.isEmpty(departmentItem)) { continue; } Item itemData = departmentItem.get(item.getItemCode()); if (Objects.isNull(itemData)) { continue; } itemCost.setItemType(itemData.getItemType()); itemCost.setResponsibilityCode(responsibilityCodeMap.get(item.getExecuteDepartmentCode())); itemCost.setResponsibilityName(responsibilityNameMap.get(item.getExecuteDepartmentCode())); itemCost.setIndex(i); saveCost.add(itemCost); costDetail.setIndex(i); saveDetails.addAll(setDetails(costDetail, item, shareParamType, itemMap)); } if (!CollectionUtils.isEmpty(saveCost)) { //作废当前核算年月已有数据 repository.saveBatch(saveCost, 500); if (!CollectionUtils.isEmpty(saveDetails)) { Map indexId = saveCost.stream().collect(Collectors.toMap(ComputeShareParam::getIndex, ComputeShareParam::getId, (a, b) -> b)); Map> collect = saveDetails.stream().collect(Collectors.groupingBy(ComputeShareParamDetail::getIndex)); List saveCostDetails = new ArrayList<>(); collect.forEach((k, v) -> { v.forEach(detail -> detail.setShareParamId(indexId.get(k))); saveCostDetails.addAll(v); }); detailRepository.saveBatch(saveCostDetails, 500); } } } } /** * 项目分摊参数计算 * @param computeDate */ public void calcShareParamCost(String computeDate){ SessionUserVO currentUser = UserContext.getCurrentUser(); //获取收费项目数据（项目） checkItemCount(computeDate, currentUser); //作废上次计算记录 repository.removeByComputeDate(computeDate, currentUser); detailRepository.removeByComputeDate(computeDate, currentUser); //医疗服务项目字典 List itemList = itemRepository.getList(); if (CollectionUtils.isEmpty(itemList)) { throw new CostException("医疗服务项目未维护，请先添加医疗服务项目再进行计算，当前计算中止"); } //医疗服务项目的参与人员信息 List itemEmpMaps = itemEmpMapRepository.getList(); //医疗服务项目的使用设备信息 List itemEquipmentMaps = itemEquipmentMapRepository.getList(); //医疗服务项目的使用空间信息 List itemSpaceMaps = itemSpaceMapRepository.getList(); //标准项目字典人员对照 List standItemEmpMaps = standItemEmpMapRepository.getList(); //标准项目字典设备对照 List standItemEquipmentMaps = standItemEquipmentMapRepository.getList(); //标准项目字典空间对照 List standItemSpaceMaps = standItemSpaceMapRepository.getList(); //科室责任中心对照信息 List responsibilityDeptMaps = responsibilityDepartmentService.getResponsibilityDepart(); //分摊参数设置信息 List shareParamTypeMaps = shareParamTypeMapRepository.getList(); //医疗服务项目分类字典 DictDataVo itemTypeDict = centerService.getDict(Constant.MED_SERVICE_ITEM_TYPE); //月度患者收费项目信息(按执行科室+收费项目代码汇总过) List ptChargeItems = importPatientItemRepository.getByDepartGroupComputeDateItem(computeDate, currentUser); if (CollectionUtils.isEmpty(ptChargeItems)){ throw new CostException("没有可计算的收费项目"); } // //筛选出字典维护了的项目 // List activePtChargeItems = ptChargeItems.stream().filter(ptItem -> { // //科室项目字典维护了的数据 // if (itemList.stream().anyMatch(item -> item.getCode().equals(ptItem.getItemCode()) && item.getDepartmentCode().equals(ptItem.getExecuteDepartmentCode()))) { // return true; // } // //全院项目字典维护了的数据 // if (itemList.stream().anyMatch(item -> item.getCode().equals(ptItem.getItemCode()) && item.getDepartmentCode().equals(NumberConstant.ZERO))) { // return true; // } // return false; // }).collect(Collectors.toList()); // if (CollectionUtils.isEmpty(activePtChargeItems)){ // throw new CostException("所有收费项目都没有对应的字典数据，请联系管理员"); // } //绑定收费项目对应的医疗服务型项目字典对象 ptChargeItems.stream().forEach(ptItem->{ Item item = getDicItem(ptItem,itemList); ptItem.setDicItem(item); }); List computeShareParamList = new ArrayList(); List ComputeShareParamDetailList = new ArrayList(); ptChargeItems.stream().forEach(ptItem->{ //只处理字典有项目 if(!Objects.isNull(ptItem.getDicItem())) { //根据收费项目创建分摊参数主表对象 ComputeShareParam computeShareCost = creatComputeShareParam(currentUser, computeDate, ptItem, itemTypeDict, responsibilityDeptMaps); computeShareParamList.add(computeShareCost); //创建分摊参数主表对象对应的明细对象 shareParamTypeMaps.stream().forEach(shareParamType -> { ComputeShareParamDetail computeShareParamDetail = createComputeShareParamDetail(currentUser, computeDate, ptItem, computeShareCost, shareParamType, itemEmpMaps, itemEquipmentMaps, itemSpaceMaps,standItemEmpMaps, standItemEquipmentMaps, standItemSpaceMaps); ComputeShareParamDetailList.add(computeShareParamDetail); }); } }); //没有任何可保存的数据 if (CollectionUtils.isEmpty(computeShareParamList)) { throw new CostException("没有任何可保存的数据"); } //保存分摊参数主表对象数据 repository.saveBatch(computeShareParamList, 500); if (CollectionUtils.isEmpty(ComputeShareParamDetailList)) { return; } //保存分摊参数明细表对象数据 ComputeShareParamDetailList.stream().forEach(shareParamDetailL->shareParamDetailL.setShareParamId(shareParamDetailL.getComputeShareCost().getId())); detailRepository.saveBatch(ComputeShareParamDetailList, 500); } /** * 获取收费项目对应的医疗服务项目字典对象 * @param ptItem * @param itemList * @return */ public Item getDicItem(PatientItemDepartmentGroupVo ptItem,List itemList){ //优先取科室项目字典的记录 Optional first = itemList.stream().filter(dicItem -> dicItem.getCode().equals(ptItem.getItemCode()) && dicItem.getDepartmentCode().equals(ptItem.getExecuteDepartmentCode())).findFirst(); if(first.isPresent()) { return first.get(); } //取全院通用的字典记录 first = itemList.stream().filter(dicItem -> dicItem.getCode().equals(ptItem.getItemCode()) && dicItem.getDepartmentCode().equals(NumberConstant.ZERO)).findFirst(); if(first.isPresent()) { return first.get(); } return null; } /** * 根据收费项目创建分摊参数主表对象 * @param currentUser * @param computeDate * @param itemTypeDict * @param ptItem * @param responsibilityDeptMaps * @return */ public ComputeShareParam creatComputeShareParam(SessionUserVO currentUser,String computeDate,PatientItemDepartmentGroupVo ptItem,DictDataVo itemTypeDict, List responsibilityDeptMaps){ ComputeShareParam computeShareCost = new ComputeShareParam(); computeShareCost.setComputeDate(computeDate); computeShareCost.setHospId(currentUser.getHospId()); computeShareCost.setCreateUser(String.valueOf(currentUser.getId())); computeShareCost.setCreateTime(new Date()); computeShareCost.setCode(ptItem.getItemCode()); computeShareCost.setName(ptItem.getItemName()); computeShareCost.setNum(ptItem.getNum()); //获取执行科室对应的责任中心 Optional firstResponsibilityDepartIdVO = responsibilityDeptMaps.stream().filter(respDeptmap -> !Objects.isNull(respDeptmap.getDepartmentCode())&& respDeptmap.getDepartmentCode().equals(ptItem.getExecuteDepartmentCode())).findFirst(); if(!firstResponsibilityDepartIdVO.isPresent()){ String errMsg = String.format("【%s(%s)】没有对应的责任中心，计算中止", ptItem.getExecuteDepartmentName(), ptItem.getExecuteDepartmentCode()); throw new CostException(errMsg); } ResponsibilityDepartIdVO responsibilityDepartIdVO=firstResponsibilityDepartIdVO.get(); computeShareCost.setResponsibilityCode(responsibilityDepartIdVO.getResponsibilityCode()); computeShareCost.setResponsibilityName(responsibilityDepartIdVO.getResponsibilityName()); // computeShareCost.setItemType(getChargeItemType(itemTypeDict,responsibilityDepartIdVO.getShareId())); computeShareCost.setItemType(ptItem.getDicItem().getItemType()); return computeShareCost; } /** * 根据收费项目创建分摊参数明细表对象 * @param currentUser * @param computeDate * @param ptItem * @param computeShareCost * @param shareParamType * @param itemEmpMaps * @param itemEquipmentMaps * @param itemSpaceMaps * @return */ public ComputeShareParamDetail createComputeShareParamDetail( SessionUserVO currentUser,String computeDate,PatientItemDepartmentGroupVo ptItem,ComputeShareParam computeShareCost,ShareParamTypeMap shareParamType, List itemEmpMaps,List itemEquipmentMaps ,List itemSpaceMaps, List standItemEmpMaps,List standItemEquipmentMaps ,List standItemSpaceMaps){ //明细表公共对象 ComputeShareParamDetail costDetail = new ComputeShareParamDetail(); costDetail.setComputeDate(computeDate); costDetail.setHospId(currentUser.getHospId()); costDetail.setCreateUser(String.valueOf(currentUser.getId())); costDetail.setCreateTime(new Date()); costDetail.setShareParamCode(shareParamType.getShareParamCode()); if(shareParamType.getSourceType().equals(NumberConstant.ONE_S)){ //计算参与人员的参数值 BigDecimal computeSingleResult = calcEmpParamValue(shareParamType, ptItem, itemEmpMaps); costDetail.setComputeSingleResult(computeSingleResult); costDetail.setComputeResult(computeSingleResult.multiply(ptItem.getNum())); //计算标准法参与人员的参数值 BigDecimal standComputeSingleResult = calcStandEmpParamValue(shareParamType, ptItem, standItemEmpMaps); costDetail.setStandComputeSingleResult(standComputeSingleResult); costDetail.setStandComputeResult(standComputeSingleResult.multiply(ptItem.getNum())); }else if(shareParamType.getSourceType().equals(NumberConstant.TWO_S)){ //计算使用设备的参数值 BigDecimal computeSingleResult = calcEquipmentParamValue(shareParamType, ptItem, itemEquipmentMaps); costDetail.setComputeSingleResult(computeSingleResult); costDetail.setComputeResult(computeSingleResult.multiply(ptItem.getNum())); //计算标准法使用设备的参数值 BigDecimal standComputeSingleResult = calcStandEquipmentParamValue(shareParamType, ptItem, standItemEquipmentMaps); costDetail.setStandComputeSingleResult(standComputeSingleResult); costDetail.setStandComputeResult(standComputeSingleResult.multiply(ptItem.getNum())); }else if(shareParamType.getSourceType().equals(NumberConstant.THREE_S)){ //计算使用空间的参数值 BigDecimal computeSingleResult = calcSpaceParamValue(shareParamType, ptItem, itemSpaceMaps); costDetail.setComputeSingleResult(computeSingleResult); costDetail.setComputeResult(computeSingleResult.multiply(ptItem.getNum())); //计算标准法使用空间的参数值 BigDecimal standComputeSingleResult = calcStandSpaceParamValue(shareParamType, ptItem,standItemSpaceMaps); costDetail.setStandComputeSingleResult(standComputeSingleResult); costDetail.setStandComputeResult(standComputeSingleResult.multiply(ptItem.getNum())); }else if(shareParamType.getSourceType().equals(NumberConstant.FOUR_S)){ //计算项目收入的参数值 BigDecimal computeResult = ptItem.getAmount(); if (!ptItem.getNum().equals(BigDecimal.ZERO.setScale(NumberConstant.TWO, RoundingMode.HALF_UP))) { costDetail.setComputeSingleResult(computeResult.divide(ptItem.getNum(), NumberConstant.FOUR, RoundingMode.HALF_UP)); costDetail.setStandComputeSingleResult(computeResult.divide(ptItem.getNum(), NumberConstant.FOUR, RoundingMode.HALF_UP)); } else { costDetail.setComputeSingleResult(BigDecimal.ZERO.setScale(NumberConstant.FOUR, RoundingMode.HALF_UP)); costDetail.setStandComputeSingleResult(BigDecimal.ZERO.setScale(NumberConstant.FOUR, RoundingMode.HALF_UP)); } costDetail.setComputeResult(computeResult); costDetail.setStandComputeResult(computeResult); }else if(shareParamType.getSourceType().equals(NumberConstant.FIVE_S)){ //计算项目数量的参数值 BigDecimal computeResult = ptItem.getNum(); costDetail.setComputeSingleResult(BigDecimal.ONE.setScale(NumberConstant.FOUR, RoundingMode.HALF_UP)); costDetail.setComputeResult(computeResult); //计算标准法项目数量的参数值 costDetail.setStandComputeSingleResult(BigDecimal.ONE.setScale(NumberConstant.FOUR, RoundingMode.HALF_UP)); costDetail.setStandComputeResult(computeResult); } costDetail.setComputeShareCost(computeShareCost); return costDetail; } /** * 计算参与人员的参数值 * @param ptItem * @param itemEmpMaps * @return */ public BigDecimal calcEmpParamValue(ShareParamTypeMap shareParamType,PatientItemDepartmentGroupVo ptItem,List itemEmpMaps){ //没有人员配置 if(CollectionUtils.isEmpty(itemEmpMaps)){ return BigDecimal.ZERO; } String sourceCode = shareParamType.getSourceCode(); //没有维护对应的来源代码 if(Objects.isNull(sourceCode)||sourceCode.equals(Constant.EMPTY_STR)){ return BigDecimal.ZERO; } //获取项目对应的参与人员配置 List itemEmpList = itemEmpMaps.stream().filter(itemEmp -> itemEmp.getItemCode().equals(ptItem.getDicItem().getCode()) && itemEmp.getDepartmentCode().equals(ptItem.getDicItem().getDepartmentCode())).collect(Collectors.toList()); if(CollectionUtils.isEmpty(itemEmpList)){ return BigDecimal.ZERO; } BigDecimal paramValue=BigDecimal.ZERO; //全部项目 if(sourceCode.equals(NumberConstant.ZERO_S)){ paramValue = itemEmpList.stream().map(itemEmp -> itemEmp.getExecuteTime().multiply(itemEmp.getNum())).reduce(BigDecimal.ZERO, BigDecimal::add); return paramValue; } //不是全部的项目时，有可能会是多个 List sourceCodeList = StrUtil.split(sourceCode, "|"); //获取符合条件的项目 List activeItemEmpList = itemEmpList.stream().filter(itemEmp -> sourceCodeList.contains(itemEmp.getEmpTypeCode())).collect(Collectors.toList()); if(CollectionUtils.isEmpty(activeItemEmpList)){ return paramValue; } //只统计符合条件的项目 paramValue = activeItemEmpList.stream().map(itemEmp -> itemEmp.getExecuteTime().multiply(itemEmp.getNum())).reduce(BigDecimal.ZERO, BigDecimal::add); return paramValue; } /** * 计算标准项目参与人员的参数值 * @param ptItem * @param standItemEmpMaps * @return */ public BigDecimal calcStandEmpParamValue(ShareParamTypeMap shareParamType,PatientItemDepartmentGroupVo ptItem,List standItemEmpMaps){ //没有人员配置 if(CollectionUtils.isEmpty(standItemEmpMaps)){ return BigDecimal.ZERO; } String sourceCode = shareParamType.getSourceCode(); //没有维护对应的来源代码 if(Objects.isNull(sourceCode)||sourceCode.equals(Constant.EMPTY_STR)){ return BigDecimal.ZERO; } //获取项目对应的标准项目的参与人员配置 List itemEmpList = standItemEmpMaps.stream().filter(itemEmp ->!ObjectUtils.isEmpty(ptItem.getDicItem())&& ptItem.getDicItem().getStandItemCode().equals(itemEmp.getStandItemCode())).collect(Collectors.toList()); if(CollectionUtils.isEmpty(itemEmpList)){ return BigDecimal.ZERO; } BigDecimal paramValue=BigDecimal.ZERO; //全部项目 if(sourceCode.equals(NumberConstant.ZERO_S)){ paramValue = itemEmpList.stream().map(itemEmp -> itemEmp.getExecuteTime().multiply(itemEmp.getNum())).reduce(BigDecimal.ZERO, BigDecimal::add); return paramValue; } //不是全部的项目时，有可能会是多个 List sourceCodeList = StrUtil.split(sourceCode, "|"); //获取符合条件的项目 List activeItemEmpList = itemEmpList.stream().filter(itemEmp -> sourceCodeList.contains(itemEmp.getEmpTypeCode())).collect(Collectors.toList()); if(CollectionUtils.isEmpty(activeItemEmpList)){ return paramValue; } //只统计符合条件的项目 paramValue = activeItemEmpList.stream().map(itemEmp -> itemEmp.getExecuteTime().multiply(itemEmp.getNum())).reduce(BigDecimal.ZERO, BigDecimal::add); return paramValue; } /** * 计算使用设备参数值 * @param shareParamType * @param ptItem * @param itemEquipmentMaps * @return */ public BigDecimal calcEquipmentParamValue(ShareParamTypeMap shareParamType,PatientItemDepartmentGroupVo ptItem,List itemEquipmentMaps){ //没有人员配置 if(CollectionUtils.isEmpty(itemEquipmentMaps)){ return BigDecimal.ZERO; } String sourceCode = shareParamType.getSourceCode(); //没有维护对应的来源代码 if(Objects.isNull(sourceCode)||sourceCode.equals(Constant.EMPTY_STR)){ return BigDecimal.ZERO; } //获取项目对应的使用设备配置 List itemEquipmentList = itemEquipmentMaps.stream().filter(itemEmp -> itemEmp.getItemCode().equals(ptItem.getDicItem().getCode()) && itemEmp.getDepartmentCode().equals(ptItem.getDicItem().getDepartmentCode())).collect(Collectors.toList()); if(CollectionUtils.isEmpty(itemEquipmentList)){ return BigDecimal.ZERO; } BigDecimal paramValue=BigDecimal.ZERO; //全部项目 if(sourceCode.equals(NumberConstant.ZERO_S)){ paramValue = itemEquipmentList.stream().map(itemEmp -> itemEmp.getExecuteTime().multiply(itemEmp.getNum())).reduce(BigDecimal.ZERO, BigDecimal::add); return paramValue; } //不是全部的项目时，有可能会是多个 List sourceCodeList = StrUtil.split(sourceCode, "|"); //获取符合条件的项目 List activeItemEquipmentList = itemEquipmentList.stream().filter(itemEmp -> sourceCodeList.contains(itemEmp.getEquipmentCode())).collect(Collectors.toList()); if(CollectionUtils.isEmpty(activeItemEquipmentList)){ return paramValue; } //只统计符合条件的项目 paramValue = activeItemEquipmentList.stream().map(itemEmp -> itemEmp.getExecuteTime().multiply(itemEmp.getNum())).reduce(BigDecimal.ZERO, BigDecimal::add); return paramValue; } /** * 计算标准项目使用设备参数值 * @param shareParamType * @param ptItem * @param standItemEquipmentMaps * @return */ public BigDecimal calcStandEquipmentParamValue(ShareParamTypeMap shareParamType,PatientItemDepartmentGroupVo ptItem,List standItemEquipmentMaps){ //没有人员配置 if(CollectionUtils.isEmpty(standItemEquipmentMaps)){ return BigDecimal.ZERO; } String sourceCode = shareParamType.getSourceCode(); //没有维护对应的来源代码 if(Objects.isNull(sourceCode)||sourceCode.equals(Constant.EMPTY_STR)){ return BigDecimal.ZERO; } //获取项目对应的标准项目的使用设备配置 List itemEquipmentList = standItemEquipmentMaps.stream().filter(itemEmp ->!ObjectUtils.isEmpty(ptItem.getDicItem())&& itemEmp.getStandItemCode().equals(ptItem.getDicItem().getStandItemCode())).collect(Collectors.toList()); if(CollectionUtils.isEmpty(itemEquipmentList)){ return BigDecimal.ZERO; } BigDecimal paramValue=BigDecimal.ZERO; //全部项目 if(sourceCode.equals(NumberConstant.ZERO_S)){ paramValue = itemEquipmentList.stream().map(itemEmp -> itemEmp.getExecuteTime().multiply(itemEmp.getNum())).reduce(BigDecimal.ZERO, BigDecimal::add); return paramValue; } //不是全部的项目时，有可能会是多个 List sourceCodeList = StrUtil.split(sourceCode, "|"); //获取符合条件的项目 List activeItemEquipmentList = itemEquipmentList.stream().filter(itemEmp -> sourceCodeList.contains(itemEmp.getEquipmentCode())).collect(Collectors.toList()); if(CollectionUtils.isEmpty(activeItemEquipmentList)){ return paramValue; } //只统计符合条件的项目 paramValue = activeItemEquipmentList.stream().map(itemEmp -> itemEmp.getExecuteTime().multiply(itemEmp.getNum())).reduce(BigDecimal.ZERO, BigDecimal::add); return paramValue; } /** * 计算使用空间参数值 * @param shareParamType * @param ptItem * @param itemSpaceMaps * @return */ public BigDecimal calcSpaceParamValue(ShareParamTypeMap shareParamType,PatientItemDepartmentGroupVo ptItem,List itemSpaceMaps){ //没有人员配置 if(CollectionUtils.isEmpty(itemSpaceMaps)){ return BigDecimal.ZERO; } String sourceCode = shareParamType.getSourceCode(); //没有维护对应的来源代码 if(Objects.isNull(sourceCode)||sourceCode.equals(Constant.EMPTY_STR)){ return BigDecimal.ZERO; } //获取项目对应的使用空间配置 List itemSpaceList = itemSpaceMaps.stream().filter(itemEmp -> itemEmp.getItemCode().equals(ptItem.getDicItem().getCode()) && itemEmp.getDepartmentCode().equals(ptItem.getDicItem().getDepartmentCode())).collect(Collectors.toList()); if(CollectionUtils.isEmpty(itemSpaceList)){ return BigDecimal.ZERO; } BigDecimal paramValue=BigDecimal.ZERO; //全部项目 if(sourceCode.equals(NumberConstant.ZERO_S)){ paramValue = itemSpaceList.stream().map(itemEmp -> itemEmp.getExecuteTime().multiply(itemEmp.getNum())).reduce(BigDecimal.ZERO, BigDecimal::add); return paramValue; } //不是全部的项目时，有可能会是多个 List sourceCodeList = StrUtil.split(sourceCode, "|"); //获取符合条件的项目 List activeItemSpaceList = itemSpaceList.stream().filter(itemEmp -> sourceCodeList.contains(itemEmp.getSpaceCode())).collect(Collectors.toList()); if(CollectionUtils.isEmpty(activeItemSpaceList)){ return paramValue; } //只统计符合条件的项目 paramValue = activeItemSpaceList.stream().map(itemEmp -> itemEmp.getExecuteTime().multiply(itemEmp.getNum())).reduce(BigDecimal.ZERO, BigDecimal::add); return paramValue; } /** * 计算标准项目使用空间参数值 * @param shareParamType * @param ptItem * @param standItemSpaceMaps * @return */ public BigDecimal calcStandSpaceParamValue(ShareParamTypeMap shareParamType,PatientItemDepartmentGroupVo ptItem,List standItemSpaceMaps){ //没有人员配置 if(CollectionUtils.isEmpty(standItemSpaceMaps)){ return BigDecimal.ZERO; } String sourceCode = shareParamType.getSourceCode(); //没有维护对应的来源代码 if(Objects.isNull(sourceCode)||sourceCode.equals(Constant.EMPTY_STR)){ return BigDecimal.ZERO; } //获取项目对应的使用空间配置 List itemSpaceList = standItemSpaceMaps.stream().filter(itemEmp ->!ObjectUtils.isEmpty(ptItem.getDicItem())&&itemEmp.getStandItemCode().equals(ptItem.getDicItem().getStandItemCode())).collect(Collectors.toList()); if(CollectionUtils.isEmpty(itemSpaceList)){ return BigDecimal.ZERO; } BigDecimal paramValue=BigDecimal.ZERO; //全部项目 if(sourceCode.equals(NumberConstant.ZERO_S)){ paramValue = itemSpaceList.stream().map(itemEmp -> itemEmp.getExecuteTime().multiply(itemEmp.getNum())).reduce(BigDecimal.ZERO, BigDecimal::add); return paramValue; } //不是全部的项目时，有可能会是多个 List sourceCodeList = StrUtil.split(sourceCode, "|"); //获取符合条件的项目 List activeItemSpaceList = itemSpaceList.stream().filter(itemEmp -> sourceCodeList.contains(itemEmp.getSpaceCode())).collect(Collectors.toList()); if(CollectionUtils.isEmpty(activeItemSpaceList)){ return paramValue; } //只统计符合条件的项目 paramValue = activeItemSpaceList.stream().map(itemEmp -> itemEmp.getExecuteTime().multiply(itemEmp.getNum())).reduce(BigDecimal.ZERO, BigDecimal::add); return paramValue; } /** * 根据责任中心获取医疗服务项目分类 * @param dict * @param shareLevelId * @return */ public String getChargeItemType(DictDataVo dict,Long shareLevelId){ List dataVoList= dict.getDataVoList(); if(CollectionUtils.isEmpty(dataVoList)){ return NumberConstant.ONE_S; } DictDataVo dictDataVo = dataVoList.stream().filter(dataVo -> dataVo.getValue().equals(shareLevelId.toString())).findFirst().get(); return NumberConstant.ONE_S; } /** * 执行完全法项目分摊参数计算后续处理脚本 * @param computeDate */ public void execShareParamCostSQL(String computeDate){ Map sqlParameter = new HashMap<>(); sqlParameter.put(SQLParameter.COMPUTE_DATE_CODE,computeDate); sqlService.autoExecuteSql(CustomSqlTypeEnum.FULL_PROJECT_PARAM_CALC.getCode(),sqlParameter); } /** * 获取标准项目分摊参数 * * @param current 当前页 * @param pageSize 页容量 * @param computeDate 核算年月 * @param itemType 项目类型 * @param responsibility 责任中心 * @param itemFilter 项目过滤条件 * @return 分页数据 */ @Override public Object getStandShareParamCostList(Integer current, Integer pageSize, String computeDate, String itemType, String responsibility, String itemFilter) { Page page = computeStandShareParamRepository.getPage(current, pageSize, computeDate, itemType, responsibility, itemFilter); List records = page.getRecords(); ShareParamCostResponse response = new ShareParamCostResponse(); List titleVos = getCommonTitleVos(); response.setTitle(titleVos); if (CollectionUtils.isEmpty(records)) { response.setPageData(new PageUtils(new ArrayList<>(), NumberConstant.ZERO, pageSize, current)); return response; } List collect1 = records.stream().map(ComputeStandShareParam::getId).collect(Collectors.toList()); List shareParamDetails = computeStandShareParamDetailRepository.getByShareParamId(computeDate, collect1); Map typeNameMap = getTypeNameDict(); shareParamDetails.forEach(record -> record.setItemTypeName(typeNameMap.get(record.getItemType()))); List> returnList = new ArrayList<>(); //按报表头组装值 Map> collect = shareParamDetails.stream().collect(Collectors.groupingBy(ComputeDateShareParamVo::getCode)); for (ComputeStandShareParam itemCode : records) { setResultData(titleVos, collect, returnList, itemCode.getCode()); } PageUtils pageUtils = new PageUtils(returnList, Math.toIntExact(page.getTotal()), pageSize, current); response.setPageData(pageUtils); return response; } private @NotNull Map getTypeNameDict() { DictDataVo centerDict = centerService.getCenterDict(Constant.MED_SERVICE_ITEM_TYPE); List dataVoList = centerDict.getDataVoList(); return dataVoList.stream().collect(Collectors.toMap(DictDataVo::getCode, DictDataVo::getName, (a, b) -> b)); } private @NotNull List getCommonTitleVos() { List titleVos = new ArrayList<>(); titleVos.add(new CommonTitleVo(RESPONSIBILITY_CODE.getCode(), RESPONSIBILITY_CODE.getName())); titleVos.add(new CommonTitleVo(RESPONSIBILITY_NAME.getCode(), RESPONSIBILITY_NAME.getName())); titleVos.add(new CommonTitleVo(ITEM_CODE.getCode(), ITEM_CODE.getName())); titleVos.add(new CommonTitleVo(ITEM_NAME.getCode(), ITEM_NAME.getName())); titleVos.add(new CommonTitleVo(ITEM_TYPE.getCode(), ITEM_TYPE.getName())); List shareParamType = shareParamTypeMapRepository.getList(); for (ShareParamTypeMap shareParamTypeMap : shareParamType) { titleVos.add(getTitle(shareParamTypeMap.getShareParamCode(), shareParamTypeMap.getShareParamName())); } return titleVos; } private void setResultData(List titleVos, Map> collect, List> returnList, String code) { List computeDateShareParamVos = collect.get(code); Map computeResultMap = computeDateShareParamVos.stream().collect(Collectors.toMap(ComputeDateShareParamVo::getShareParamCode, ComputeDateShareParamVo::getComputeResult, (a, b) -> b)); List dataList = new ArrayList<>(); for (CommonTitleVo titleVo : titleVos) { if (titleVo.getCode().equals(RESPONSIBILITY_CODE.getCode())) { dataList.add(getData(titleVo.getCode(), computeDateShareParamVos.get(0).getResponsibilityCode())); } else if (titleVo.getCode().equals(RESPONSIBILITY_NAME.getCode())) { dataList.add(getData(titleVo.getCode(), computeDateShareParamVos.get(0).getResponsibilityName())); } else if (titleVo.getCode().equals(ITEM_CODE.getCode())) { dataList.add(getData(titleVo.getCode(), code)); } else if (titleVo.getCode().equals(ITEM_NAME.getCode())) { dataList.add(getData(titleVo.getCode(), computeDateShareParamVos.get(0).getName())); } else if (titleVo.getCode().equals(ITEM_TYPE.getCode())) { dataList.add(getData(titleVo.getCode(), computeDateShareParamVos.get(0).getItemTypeName())); } else { dataList.add(getData(titleVo.getCode(), computeResultMap.get(titleVo.getCode()))); } } returnList.add(dataList); } /** * 标准法项目分摊参数计算 * @param computeDate */ @Override public void computeStandShareParamCost(String computeDate){ String parameterValue = centerService.getParameterValueByIndex(ParameterConstant.ITEM_CALC_TYPE,NumberConstant.TWO); //走系统计算逻辑 if(StringUtils.isEmpty(parameterValue)|| NumberConstant.ONE_S.equals(parameterValue)||NumberConstant.THREE_S.equals(parameterValue)) { //标准法项目分摊参数计算 computeStandShareParamCostAction(computeDate); } //走自定义SQL计算逻辑 if(NumberConstant.TWO_S.equals(parameterValue)||NumberConstant.THREE_S.equals(parameterValue)) { //执行标准法项目分摊参数计算后续处理脚本 execStandShareParamCostSQL(computeDate); } } /** * 计算标准项目分摊参数 * * @param computeDate 核算年月 */ public void computeStandShareParamCostAction(String computeDate) { SessionUserVO currentUser = UserContext.getCurrentUser(); //把当月需要计算数据置成0 // importPatientItemRepository.updateGroupCalculateFlag(computeDate, currentUser); //获取收费项目数据（项目） checkItemCount(computeDate, currentUser); //获取计算列 List shareParamType = shareParamTypeMapRepository.getList(); if (CollectionUtils.isEmpty(shareParamType)) { throw new CostException("分摊参数来源项目未对照【com_share_param_type_map】表无数据"); } //作废上次计算记录 computeStandShareParamRepository.removeByComputeDate(computeDate, currentUser); computeStandShareParamDetailRepository.removeByComputeDate(computeDate, currentUser); //获到科室与责任中心对照 List patientResponsibility = getPatientResponsibility(currentUser); Map responsibilityCodeMap = new HashMap<>(); Map responsibilityNameMap = new HashMap<>(); patientResponsibility.forEach(visitNoResponsibilityMap -> { responsibilityCodeMap.put(visitNoResponsibilityMap.getDepartmentCode(), visitNoResponsibilityMap.getResponsibilityCode()); responsibilityNameMap.put(visitNoResponsibilityMap.getDepartmentCode(), visitNoResponsibilityMap.getResponsibilityName()); }); //医疗服务项目字典 Map> itemMap = getStandItemMap(); //主表公共对象 ComputeStandShareParam computeShareCost = new ComputeStandShareParam(); computeShareCost.setComputeDate(computeDate); computeShareCost.setHospId(currentUser.getHospId()); computeShareCost.setCreateUser(String.valueOf(currentUser.getId())); computeShareCost.setCreateTime(new Date()); //明细表公共对象 ComputeStandShareParamDetail costDetail = new ComputeStandShareParamDetail(); costDetail.setComputeDate(computeDate); costDetail.setHospId(currentUser.getHospId()); costDetail.setCreateUser(String.valueOf(currentUser.getId())); costDetail.setCreateTime(new Date()); List items = importPatientItemRepository.getByDepartGroupComputeDateItem(computeDate, currentUser); List saveDetails = new ArrayList<>(); List saveCost = new ArrayList<>(); if (!CollectionUtils.isEmpty(items)) { for (int i = 0; i < items.size(); i++) { PatientItemDepartmentGroupVo item = items.get(i); ComputeStandShareParam itemCost = BeanUtil.convertObj(computeShareCost, ComputeStandShareParam.class); itemCost.setCode(item.getItemCode()); itemCost.setName(item.getItemName()); itemCost.setNum(item.getNum()); Map departmentItem = itemMap.get(item.getExecuteDepartmentCode()); if (CollectionUtils.isEmpty(departmentItem)) { continue; } Item itemData = departmentItem.get(item.getItemCode()); if (Objects.isNull(itemData)) { continue; } itemCost.setItemType(itemData.getItemType()); itemCost.setResponsibilityCode(responsibilityCodeMap.get(item.getExecuteDepartmentCode())); itemCost.setResponsibilityName(responsibilityNameMap.get(item.getExecuteDepartmentCode())); itemCost.setIndex(i); saveCost.add(itemCost); costDetail.setIndex(i); saveDetails.addAll(setStandDetails(costDetail, item, shareParamType, itemMap)); } if (!CollectionUtils.isEmpty(saveCost)) { //作废当前核算年月已有数据 computeStandShareParamRepository.saveBatch(saveCost, 500); if (!CollectionUtils.isEmpty(saveDetails)) { Map indexId = saveCost.stream().collect(Collectors.toMap(ComputeStandShareParam::getIndex, ComputeStandShareParam::getId, (a, b) -> b)); Map> collect = saveDetails.stream().collect(Collectors.groupingBy(ComputeStandShareParamDetail::getIndex)); List saveCostDetails = new ArrayList<>(); collect.forEach((k, v) -> { v.forEach(detail -> detail.setShareParamId(indexId.get(k))); saveCostDetails.addAll(v); }); computeStandShareParamDetailRepository.saveBatch(saveCostDetails, 500); } } } } /** * 执行标准法项目分摊参数计算后续处理脚本 * @param computeDate */ public void execStandShareParamCostSQL(String computeDate){ Map sqlParameter = new HashMap<>(); sqlParameter.put(SQLParameter.COMPUTE_DATE_CODE,computeDate); sqlService.autoExecuteSql(CustomSqlTypeEnum.STAND_PROJECT_PARAM_CALC.getCode(),sqlParameter); } private void checkItemCount(String computeDate, SessionUserVO currentUser) { long itemSize = importPatientItemRepository.getItemCount(computeDate, currentUser); if (Objects.equals(itemSize, NumberConstant.ZERO_L)) { log.error("当前核算年月【{}】未导入收费项目数据，计算中止", computeDate); throw new CostException("当前核算年月【" + computeDate + "】未导入收费项目数据，计算中止"); } } private @NotNull Map> getStandItemMap() { List itemList = itemRepository.getList(); if (CollectionUtils.isEmpty(itemList)) { throw new CostException("医疗服务项目未维护，请先添加医疗服务项目再进行计算，当前计算中止"); } //去除未对照标准项目的数据 //获取标准项目字典 List standItemDict = standItemService.getStandItemDict(); if (CollectionUtils.isEmpty(standItemDict)) { log.error("当前院区未找到标准项目数据，计算中止"); throw new CostException("当前院区未找到标准项目数据，计算中止"); } Map standItemMap = standItemDict.stream().collect(Collectors.toMap(StandItem::getCode, standItem -> standItem, (a, b) -> b)); for (Item item1 : itemList) { String standItemCode = item1.getStandItemCode(); if (!StringUtils.isEmpty(standItemCode)) { if (Objects.nonNull(standItemMap.get(standItemCode))) { item1.setStandItem(standItemMap.get(standItemCode)); } } } Map> itemMap = new HashMap<>(); Map> collect = itemList.stream().collect(Collectors.groupingBy(Item::getDepartmentCode)); collect.forEach((k, v) -> itemMap.put(k, v.stream().collect(Collectors.toMap(Item::getCode, item -> item, (a, b) -> b)))); return itemMap; } private CommonTitleVo getTitle(String code, String name) { return new CommonTitleVo(code, name); } private ReportVo getData(String code, Object name) { ReportVo vo = new ReportVo(); vo.setCode(code); vo.setValue(name); return vo; } private List setDetails(ComputeShareParamDetail costDetail, PatientItemDepartmentGroupVo patientItem, List shareParamType, Map> itemMap) { List details = new ArrayList<>(); Item item = itemMap.get(patientItem.getExecuteDepartmentCode()).get(patientItem.getItemCode()); // Item item = itemMap.get(patientItem.getItemCode()); for (ShareParamTypeMap shareParam : shareParamType) { ComputeShareParamDetail result = BeanUtil.convertObj(costDetail, ComputeShareParamDetail.class); switch (shareParam.getSourceType()) { case NumberConstant.ONE_S: { //参与人员、 List empMaps = item.getEmpMaps(); if (!CollectionUtils.isEmpty(empMaps)) { Map> collect = empMaps.stream().collect(Collectors.groupingBy(ItemEmpMap::getEmpTypeCode)); // Map map = empMaps.stream().collect(Collectors.toMap(ItemEmpMap::getEmpTypeCode, empMap -> empMap, (a, b) -> b)); String sourceCode = shareParam.getSourceCode(); if (sourceCode.equals(NumberConstant.ZERO_S)) { AtomicReference sum = new AtomicReference<>(new BigDecimal("0.0000")); AtomicReference singleSum = new AtomicReference<>(new BigDecimal("0.0000")); for (ItemEmpMap empMap : empMaps) { BigDecimal multiply = patientItem.getNum().multiply(empMap.getExecuteTime()).multiply(empMap.getNum()); sum.updateAndGet(v -> v.add(multiply)); singleSum.updateAndGet(v -> v.add(empMap.getExecuteTime().multiply(empMap.getNum()))); } result.setComputeResult(sum.get()); result.setComputeSingleResult(singleSum.get()); result.setShareParamCode(shareParam.getShareParamCode()); details.add(result); } else if (sourceCode.contains("|")) { List split = StrUtil.split(sourceCode, "|"); AtomicReference sum = new AtomicReference<>(new BigDecimal("0.0000")); AtomicReference singleSum = new AtomicReference<>(new BigDecimal("0.0000")); for (String s : split) { List itemEmpMaps = collect.get(s); if (!CollectionUtils.isEmpty(itemEmpMaps)) { for (ItemEmpMap itemEmpMap : itemEmpMaps) { if (Objects.nonNull(itemEmpMap)) { BigDecimal multiply = patientItem.getNum().multiply(itemEmpMap.getExecuteTime()).multiply(itemEmpMap.getNum()); sum.updateAndGet(v -> v.add(multiply)); singleSum.updateAndGet(v -> v.add(itemEmpMap.getExecuteTime().multiply(itemEmpMap.getNum()))); } else { sum.updateAndGet(v -> v.add(BigDecimal.ZERO)); singleSum.updateAndGet(v -> v.add(BigDecimal.ZERO)); } } } else { sum.updateAndGet(v -> v.add(BigDecimal.ZERO)); singleSum.updateAndGet(v -> v.add(BigDecimal.ZERO)); } } result.setShareParamCode(shareParam.getShareParamCode()); result.setComputeResult(sum.get()); result.setComputeSingleResult(singleSum.get()); details.add(result); } else { List itemEmpMaps = collect.get(sourceCode); AtomicReference sum = new AtomicReference<>(new BigDecimal("0.0000")); AtomicReference singleSum = new AtomicReference<>(new BigDecimal("0.0000")); if (!CollectionUtils.isEmpty(itemEmpMaps)) { for (ItemEmpMap itemEmpMap : itemEmpMaps) { if (Objects.nonNull(itemEmpMap)) { BigDecimal multiply = patientItem.getNum().multiply(itemEmpMap.getExecuteTime()).multiply(itemEmpMap.getNum()); sum.updateAndGet(v -> v.add(multiply)); singleSum.updateAndGet(v -> v.add(itemEmpMap.getExecuteTime().multiply(itemEmpMap.getNum()))); } else { sum.updateAndGet(v -> v.add(BigDecimal.ZERO)); singleSum.updateAndGet(v -> v.add(BigDecimal.ZERO)); } } } else { sum.updateAndGet(v -> v.add(BigDecimal.ZERO)); singleSum.updateAndGet(v -> v.add(BigDecimal.ZERO)); } result.setComputeResult(sum.get()); result.setShareParamCode(shareParam.getShareParamCode()); result.setComputeSingleResult(singleSum.get()); details.add(result); } } else { result.setComputeResult(BigDecimal.ZERO); result.setComputeSingleResult(BigDecimal.ZERO); result.setShareParamCode(shareParam.getShareParamCode()); details.add(result); } break; } case NumberConstant.TWO_S: { //使用设备 List equipmentMaps = item.getEquipmentMaps(); if (!CollectionUtils.isEmpty(equipmentMaps)) { Map> collect = equipmentMaps.stream().collect(Collectors.groupingBy(ItemEquipmentMap::getEquipmentCode)); // Map map = equipmentMaps.stream().collect(Collectors.toMap(ItemEquipmentMap::getEquipmentCode, empMap -> empMap, (a, b) -> b)); String sourceCode = shareParam.getSourceCode(); if (sourceCode.equals(NumberConstant.ZERO_S)) { AtomicReference sum = new AtomicReference<>(new BigDecimal("0.0000")); AtomicReference singleSum = new AtomicReference<>(new BigDecimal("0.0000")); for (ItemEquipmentMap empMap : equipmentMaps) { BigDecimal multiply = patientItem.getNum().multiply(empMap.getExecuteTime()).multiply(empMap.getNum()); sum.updateAndGet(v -> v.add(multiply)); singleSum.updateAndGet(v -> v.add(empMap.getExecuteTime().multiply(empMap.getNum()))); } result.setComputeResult(sum.get()); result.setComputeSingleResult(singleSum.get()); result.setShareParamCode(shareParam.getShareParamCode()); details.add(result); } else if (sourceCode.contains("|")) { List split = StrUtil.split(sourceCode, "|"); AtomicReference sum = new AtomicReference<>(new BigDecimal("0.0000")); AtomicReference singleSum = new AtomicReference<>(new BigDecimal("0.0000")); for (String s : split) { List itemEquipmentMaps = collect.get(s); if (!CollectionUtils.isEmpty(itemEquipmentMaps)) { for (ItemEquipmentMap equipmentMap : itemEquipmentMaps) { if (Objects.nonNull(equipmentMap)) { BigDecimal multiply = patientItem.getNum().multiply(equipmentMap.getExecuteTime()).multiply(equipmentMap.getNum()); sum.updateAndGet(v -> v.add(multiply)); singleSum.updateAndGet(v -> v.add(equipmentMap.getExecuteTime().multiply(equipmentMap.getNum()))); } else { sum.updateAndGet(v -> v.add(BigDecimal.ZERO)); singleSum.updateAndGet(v -> v.add(BigDecimal.ZERO)); } } } else { sum.updateAndGet(v -> v.add(BigDecimal.ZERO)); singleSum.updateAndGet(v -> v.add(BigDecimal.ZERO)); } } result.setShareParamCode(shareParam.getShareParamCode()); result.setComputeResult(sum.get()); result.setComputeSingleResult(singleSum.get()); details.add(result); } else { List itemEquipmentMaps = collect.get(sourceCode); AtomicReference sum = new AtomicReference<>(new BigDecimal("0.0000")); AtomicReference singleSum = new AtomicReference<>(new BigDecimal("0.0000")); for (ItemEquipmentMap equipmentMap : itemEquipmentMaps) { if (Objects.nonNull(equipmentMap)) { BigDecimal multiply = patientItem.getNum().multiply(equipmentMap.getExecuteTime()).multiply(equipmentMap.getNum()); sum.updateAndGet(v -> v.add(multiply)); singleSum.updateAndGet(v -> v.add(equipmentMap.getExecuteTime().multiply(equipmentMap.getNum()))); } else { sum.updateAndGet(v -> v.add(BigDecimal.ZERO)); singleSum.updateAndGet(v -> v.add(BigDecimal.ZERO)); } } result.setComputeResult(sum.get()); result.setComputeSingleResult(singleSum.get()); result.setShareParamCode(shareParam.getShareParamCode()); details.add(result); } } else { result.setComputeResult(BigDecimal.ZERO); result.setComputeSingleResult(BigDecimal.ZERO); result.setShareParamCode(shareParam.getShareParamCode()); details.add(result); } break; } case NumberConstant.THREE_S: { //使用空间 List spaceMaps = item.getSpaceMaps(); if (!CollectionUtils.isEmpty(spaceMaps)) { // Map map = spaceMaps.stream().collect(Collectors.toMap(ItemSpaceMap::getSpaceCode, f -> f, (a, b) -> b)); Map> collect = spaceMaps.stream().collect(Collectors.groupingBy(ItemSpaceMap::getSpaceCode)); String sourceCode = shareParam.getSourceCode(); if (sourceCode.equals(NumberConstant.ZERO_S)) { AtomicReference sum = new AtomicReference<>(new BigDecimal("0.0000")); AtomicReference singleSum = new AtomicReference<>(new BigDecimal("0.0000")); for (ItemSpaceMap empMap : spaceMaps) { BigDecimal multiply = patientItem.getNum().multiply(empMap.getExecuteTime()).multiply(empMap.getNum()); sum.updateAndGet(v -> v.add(multiply)); singleSum.updateAndGet(v -> v.add(empMap.getExecuteTime().multiply(empMap.getNum()))); } result.setComputeResult(sum.get()); result.setComputeSingleResult(singleSum.get()); result.setShareParamCode(shareParam.getShareParamCode()); details.add(result); } else if (sourceCode.contains("|")) { List split = StrUtil.split(sourceCode, "|"); AtomicReference sum = new AtomicReference<>(new BigDecimal("0.0000")); AtomicReference singleSum = new AtomicReference<>(new BigDecimal("0.0000")); for (String s : split) { List itemSpaceMaps = collect.get(s); if (!CollectionUtils.isEmpty(itemSpaceMaps)) { for (ItemSpaceMap spaceMap : itemSpaceMaps) { if (Objects.nonNull(spaceMap)) { BigDecimal multiply = patientItem.getNum().multiply(spaceMap.getExecuteTime()).multiply(spaceMap.getNum()); sum.updateAndGet(v -> v.add(multiply)); singleSum.updateAndGet(v -> v.add(spaceMap.getExecuteTime().multiply(spaceMap.getNum()))); } else { sum.updateAndGet(v -> v.add(BigDecimal.ZERO)); singleSum.updateAndGet(v -> v.add(BigDecimal.ZERO)); } } } else { sum.updateAndGet(v -> v.add(BigDecimal.ZERO)); singleSum.updateAndGet(v -> v.add(BigDecimal.ZERO)); } } result.setShareParamCode(shareParam.getShareParamCode()); result.setComputeResult(sum.get()); result.setComputeSingleResult(singleSum.get()); details.add(result); } else { List itemSpaceMaps = collect.get(sourceCode); AtomicReference sum = new AtomicReference<>(new BigDecimal("0.0000")); AtomicReference singleSum = new AtomicReference<>(new BigDecimal("0.0000")); if (!CollectionUtils.isEmpty(itemSpaceMaps)) { for (ItemSpaceMap spaceMap : itemSpaceMaps) { if (Objects.nonNull(spaceMap)) { BigDecimal multiply = patientItem.getNum().multiply(spaceMap.getExecuteTime()).multiply(spaceMap.getNum()); sum.updateAndGet(v -> v.add(multiply)); singleSum.updateAndGet(v -> v.add(spaceMap.getExecuteTime().multiply(spaceMap.getNum()))); } else { sum.updateAndGet(v -> v.add(BigDecimal.ZERO)); singleSum.updateAndGet(v -> v.add(BigDecimal.ZERO)); } } } else { sum.updateAndGet(v -> v.add(BigDecimal.ZERO)); singleSum.updateAndGet(v -> v.add(BigDecimal.ZERO)); } result.setComputeResult(sum.get()); result.setComputeSingleResult(singleSum.get()); result.setShareParamCode(shareParam.getShareParamCode()); details.add(result); } } else { result.setShareParamCode(shareParam.getShareParamCode()); result.setComputeResult(BigDecimal.ZERO); result.setComputeSingleResult(BigDecimal.ZERO); details.add(result); } break; } case NumberConstant.FOUR_S: //项目收入 result.setShareParamCode(shareParam.getShareParamCode()); result.setComputeResult(patientItem.getAmount()); if (!patientItem.getNum().equals(BigDecimal.ZERO.setScale(2, RoundingMode.HALF_UP))) { result.setComputeSingleResult(patientItem.getAmount().divide(patientItem.getNum(), 4, RoundingMode.HALF_UP)); } else { result.setComputeSingleResult(BigDecimal.ZERO); } details.add(result); break; case NumberConstant.FIVE_S: result.setShareParamCode(shareParam.getShareParamCode()); result.setComputeResult(patientItem.getNum()); details.add(result); break; } } return details; } private List setStandDetails(ComputeStandShareParamDetail costDetail, PatientItemDepartmentGroupVo patientItem, List shareParamType, Map> itemMap) { List details = new ArrayList<>(); Item item = itemMap.get(patientItem.getExecuteDepartmentCode()).get(patientItem.getItemCode()); StandItem standItem = item.getStandItem(); for (ShareParamTypeMap shareParam : shareParamType) { ComputeStandShareParamDetail result = BeanUtil.convertObj(costDetail, ComputeStandShareParamDetail.class); switch (shareParam.getSourceType()) { case NumberConstant.ONE_S: { //参与人员、 if (Objects.nonNull(standItem)) { List empMaps = standItem.getEmpMaps(); if (!CollectionUtils.isEmpty(empMaps)) { Map> collect = empMaps.stream().collect(Collectors.groupingBy(StandItemEmpMap::getEmpTypeCode)); String sourceCode = shareParam.getSourceCode(); if (sourceCode.equals(NumberConstant.ZERO_S)) { AtomicReference sum = new AtomicReference<>(new BigDecimal("0.0000")); AtomicReference singleSum = new AtomicReference<>(new BigDecimal("0.0000")); for (StandItemEmpMap empMap : empMaps) { BigDecimal multiply = patientItem.getNum().multiply(empMap.getExecuteTime()).multiply(empMap.getNum()); sum.updateAndGet(v -> v.add(multiply)); singleSum.updateAndGet(v -> v.add(empMap.getExecuteTime().multiply(empMap.getNum()))); } result.setComputeResult(sum.get()); result.setComputeSingleResult(singleSum.get()); result.setShareParamCode(shareParam.getShareParamCode()); details.add(result); } else if (sourceCode.contains("|")) { List split = StrUtil.split(sourceCode, "|"); AtomicReference sum = new AtomicReference<>(new BigDecimal("0.0000")); AtomicReference singleSum = new AtomicReference<>(new BigDecimal("0.0000")); for (String s : split) { List itemEmpMaps = collect.get(s); if (!CollectionUtils.isEmpty(itemEmpMaps)) { for (StandItemEmpMap itemEmpMap : itemEmpMaps) { if (Objects.nonNull(itemEmpMap)) { BigDecimal multiply = patientItem.getNum().multiply(itemEmpMap.getExecuteTime()).multiply(itemEmpMap.getNum()); sum.updateAndGet(v -> v.add(multiply)); singleSum.updateAndGet(v -> v.add(itemEmpMap.getExecuteTime().multiply(itemEmpMap.getNum()))); } else { sum.updateAndGet(v -> v.add(BigDecimal.ZERO)); singleSum.updateAndGet(v -> v.add(BigDecimal.ZERO)); } } } else { sum.updateAndGet(v -> v.add(BigDecimal.ZERO)); singleSum.updateAndGet(v -> v.add(BigDecimal.ZERO)); } } result.setShareParamCode(shareParam.getShareParamCode()); result.setComputeResult(sum.get()); result.setComputeSingleResult(singleSum.get()); details.add(result); } else { List itemEmpMaps = collect.get(sourceCode); AtomicReference sum = new AtomicReference<>(new BigDecimal("0.0000")); AtomicReference singleSum = new AtomicReference<>(new BigDecimal("0.0000")); if (!CollectionUtils.isEmpty(itemEmpMaps)) { for (StandItemEmpMap itemEmpMap : itemEmpMaps) { if (Objects.nonNull(itemEmpMap)) { BigDecimal multiply = patientItem.getNum().multiply(itemEmpMap.getExecuteTime()).multiply(itemEmpMap.getNum()); sum.updateAndGet(v -> v.add(multiply)); singleSum.updateAndGet(v -> v.add(itemEmpMap.getExecuteTime().multiply(itemEmpMap.getNum()))); } else { sum.updateAndGet(v -> v.add(BigDecimal.ZERO)); singleSum.updateAndGet(v -> v.add(BigDecimal.ZERO)); } } } else { sum.updateAndGet(v -> v.add(BigDecimal.ZERO)); singleSum.updateAndGet(v -> v.add(BigDecimal.ZERO)); } result.setComputeResult(sum.get()); result.setShareParamCode(shareParam.getShareParamCode()); result.setComputeSingleResult(singleSum.get()); details.add(result); } } else { result.setComputeResult(BigDecimal.ZERO); result.setComputeSingleResult(BigDecimal.ZERO); result.setShareParamCode(shareParam.getShareParamCode()); details.add(result); } } else { if (result != null) { result.setComputeResult(BigDecimal.ZERO); } result.setComputeSingleResult(BigDecimal.ZERO); result.setShareParamCode(shareParam.getShareParamCode()); details.add(result); } break; } case NumberConstant.TWO_S: { //使用设备 if (Objects.nonNull(standItem)) { List equipmentMaps = standItem.getEquipmentMaps(); if (!CollectionUtils.isEmpty(equipmentMaps)) { Map> collect = equipmentMaps.stream().collect(Collectors.groupingBy(StandItemEquipmentMap::getEquipmentCode)); // Map map = equipmentMaps.stream().collect(Collectors.toMap(ItemEquipmentMap::getEquipmentCode, empMap -> empMap, (a, b) -> b)); String sourceCode = shareParam.getSourceCode(); if (sourceCode.equals(NumberConstant.ZERO_S)) { AtomicReference sum = new AtomicReference<>(new BigDecimal("0.0000")); AtomicReference singleSum = new AtomicReference<>(new BigDecimal("0.0000")); for (StandItemEquipmentMap empMap : equipmentMaps) { BigDecimal multiply = patientItem.getNum().multiply(empMap.getExecuteTime()).multiply(empMap.getNum()); sum.updateAndGet(v -> v.add(multiply)); singleSum.updateAndGet(v -> v.add(empMap.getExecuteTime().multiply(empMap.getNum()))); } result.setComputeResult(sum.get()); result.setComputeSingleResult(singleSum.get()); result.setShareParamCode(shareParam.getShareParamCode()); details.add(result); } else if (sourceCode.contains("|")) { List split = StrUtil.split(sourceCode, "|"); AtomicReference sum = new AtomicReference<>(new BigDecimal("0.0000")); AtomicReference singleSum = new AtomicReference<>(new BigDecimal("0.0000")); for (String s : split) { List itemEquipmentMaps = collect.get(s); if (!CollectionUtils.isEmpty(itemEquipmentMaps)) { for (StandItemEquipmentMap equipmentMap : itemEquipmentMaps) { if (Objects.nonNull(equipmentMap)) { BigDecimal multiply = patientItem.getNum().multiply(equipmentMap.getExecuteTime()).multiply(equipmentMap.getNum()); sum.updateAndGet(v -> v.add(multiply)); singleSum.updateAndGet(v -> v.add(equipmentMap.getExecuteTime().multiply(equipmentMap.getNum()))); } else { sum.updateAndGet(v -> v.add(BigDecimal.ZERO)); singleSum.updateAndGet(v -> v.add(BigDecimal.ZERO)); } } } else { sum.updateAndGet(v -> v.add(BigDecimal.ZERO)); singleSum.updateAndGet(v -> v.add(BigDecimal.ZERO)); } } result.setShareParamCode(shareParam.getShareParamCode()); result.setComputeResult(sum.get()); result.setComputeSingleResult(singleSum.get()); details.add(result); } else { List itemEquipmentMaps = collect.get(sourceCode); AtomicReference sum = new AtomicReference<>(new BigDecimal("0.0000")); AtomicReference singleSum = new AtomicReference<>(new BigDecimal("0.0000")); for (StandItemEquipmentMap equipmentMap : itemEquipmentMaps) { if (Objects.nonNull(equipmentMap)) { BigDecimal multiply = patientItem.getNum().multiply(equipmentMap.getExecuteTime()).multiply(equipmentMap.getNum()); sum.updateAndGet(v -> v.add(multiply)); singleSum.updateAndGet(v -> v.add(equipmentMap.getExecuteTime().multiply(equipmentMap.getNum()))); } else { sum.updateAndGet(v -> v.add(BigDecimal.ZERO)); singleSum.updateAndGet(v -> v.add(BigDecimal.ZERO)); } } result.setComputeResult(sum.get()); result.setComputeSingleResult(singleSum.get()); result.setShareParamCode(shareParam.getShareParamCode()); details.add(result); } } else { result.setComputeResult(BigDecimal.ZERO); result.setComputeSingleResult(BigDecimal.ZERO); result.setShareParamCode(shareParam.getShareParamCode()); details.add(result); } } else { result.setComputeResult(BigDecimal.ZERO); result.setComputeSingleResult(BigDecimal.ZERO); result.setShareParamCode(shareParam.getShareParamCode()); details.add(result); } break; } case NumberConstant.THREE_S: { //使用空间 if (Objects.nonNull(standItem)) { List spaceMaps = standItem.getSpaceMaps(); if (!CollectionUtils.isEmpty(spaceMaps)) { // Map map = spaceMaps.stream().collect(Collectors.toMap(ItemSpaceMap::getSpaceCode, f -> f, (a, b) -> b)); Map> collect = spaceMaps.stream().collect(Collectors.groupingBy(StandItemSpaceMap::getSpaceCode)); String sourceCode = shareParam.getSourceCode(); if (sourceCode.equals(NumberConstant.ZERO_S)) { AtomicReference sum = new AtomicReference<>(new BigDecimal("0.0000")); AtomicReference singleSum = new AtomicReference<>(new BigDecimal("0.0000")); for (StandItemSpaceMap empMap : spaceMaps) { BigDecimal multiply = patientItem.getNum().multiply(empMap.getExecuteTime()).multiply(empMap.getNum()); sum.updateAndGet(v -> v.add(multiply)); singleSum.updateAndGet(v -> v.add(empMap.getExecuteTime().multiply(empMap.getNum()))); } result.setComputeResult(sum.get()); result.setComputeSingleResult(singleSum.get()); result.setShareParamCode(shareParam.getShareParamCode()); details.add(result); } else if (sourceCode.contains("|")) { List split = StrUtil.split(sourceCode, "|"); AtomicReference sum = new AtomicReference<>(new BigDecimal("0.0000")); AtomicReference singleSum = new AtomicReference<>(new BigDecimal("0.0000")); for (String s : split) { List itemSpaceMaps = collect.get(s); if (!CollectionUtils.isEmpty(itemSpaceMaps)) { for (StandItemSpaceMap spaceMap : itemSpaceMaps) { if (Objects.nonNull(spaceMap)) { BigDecimal multiply = patientItem.getNum().multiply(spaceMap.getExecuteTime()).multiply(spaceMap.getNum()); sum.updateAndGet(v -> v.add(multiply)); singleSum.updateAndGet(v -> v.add(spaceMap.getExecuteTime().multiply(spaceMap.getNum()))); } else { sum.updateAndGet(v -> v.add(BigDecimal.ZERO)); singleSum.updateAndGet(v -> v.add(BigDecimal.ZERO)); } } } else { sum.updateAndGet(v -> v.add(BigDecimal.ZERO)); singleSum.updateAndGet(v -> v.add(BigDecimal.ZERO)); } } result.setShareParamCode(shareParam.getShareParamCode()); result.setComputeResult(sum.get()); result.setComputeSingleResult(singleSum.get()); details.add(result); } else { List itemSpaceMaps = collect.get(sourceCode); AtomicReference sum = new AtomicReference<>(new BigDecimal("0.0000")); AtomicReference singleSum = new AtomicReference<>(new BigDecimal("0.0000")); if (!CollectionUtils.isEmpty(itemSpaceMaps)) { for (StandItemSpaceMap spaceMap : itemSpaceMaps) { if (Objects.nonNull(spaceMap)) { BigDecimal multiply = patientItem.getNum().multiply(spaceMap.getExecuteTime()).multiply(spaceMap.getNum()); sum.updateAndGet(v -> v.add(multiply)); singleSum.updateAndGet(v -> v.add(spaceMap.getExecuteTime().multiply(spaceMap.getNum()))); } else { sum.updateAndGet(v -> v.add(BigDecimal.ZERO)); singleSum.updateAndGet(v -> v.add(BigDecimal.ZERO)); } } } else { sum.updateAndGet(v -> v.add(BigDecimal.ZERO)); singleSum.updateAndGet(v -> v.add(BigDecimal.ZERO)); } result.setComputeResult(sum.get()); result.setComputeSingleResult(singleSum.get()); result.setShareParamCode(shareParam.getShareParamCode()); details.add(result); } } else { result.setShareParamCode(shareParam.getShareParamCode()); result.setComputeResult(BigDecimal.ZERO); result.setComputeSingleResult(BigDecimal.ZERO); details.add(result); } } else { result.setShareParamCode(shareParam.getShareParamCode()); result.setComputeResult(BigDecimal.ZERO); result.setComputeSingleResult(BigDecimal.ZERO); details.add(result); } break; } case NumberConstant.FOUR_S: //项目收入 result.setShareParamCode(shareParam.getShareParamCode()); result.setComputeResult(patientItem.getAmount()); if (!patientItem.getNum().equals(BigDecimal.ZERO.setScale(2, RoundingMode.HALF_UP))) { result.setComputeSingleResult(patientItem.getAmount().divide(patientItem.getNum(), 4, RoundingMode.HALF_UP)); } else { result.setComputeSingleResult(BigDecimal.ZERO); } details.add(result); break; case NumberConstant.FIVE_S: result.setShareParamCode(shareParam.getShareParamCode()); result.setComputeResult(patientItem.getNum()); details.add(result); break; } } return details; } private Map> getItemMap() { List list = itemRepository.getList(); if (CollectionUtils.isEmpty(list)) { throw new CostException("医疗服务项目未维护，请先添加医疗服务项目再进行计算，当前计算中止"); } List list1 = itemEmpMapRepository.getList(); //医疗服务项目字典人员对照 Map>> empMapGroup = new HashMap<>(); if (!CollectionUtils.isEmpty(list1)) { Map> collect = list1.stream().collect(Collectors.groupingBy(ItemEmpMap::getDepartmentCode)); collect.forEach((k, v) -> { Map> collect1 = v.stream().collect(Collectors.groupingBy(ItemEmpMap::getItemCode)); empMapGroup.put(k, collect1); }); // empMapGroup = list1.stream().collect(Collectors.groupingBy(ItemEmpMap::getItemCode)); } List list2 = itemEquipmentMapRepository.getList(); //医疗服务项目字典设备对照 // Map> equipmentGroup = new HashMap<>(); Map>> equipmentGroup = new HashMap<>(); if (!CollectionUtils.isEmpty(list2)) { Map> collect = list2.stream().collect(Collectors.groupingBy(ItemEquipmentMap::getDepartmentCode)); collect.forEach((k, v) -> { Map> collect1 = v.stream().collect(Collectors.groupingBy(ItemEquipmentMap::getItemCode)); equipmentGroup.put(k, collect1); }); // equipmentGroup = list2.stream().collect(Collectors.groupingBy(ItemEquipmentMap::getItemCode)); } List list3 = itemSpaceMapRepository.getList(); //医疗服务项目字典设备对照 // Map> spaceGroup = new HashMap<>(); Map>> spaceGroup = new HashMap<>(); if (!CollectionUtils.isEmpty(list3)) { Map> collect = list3.stream().collect(Collectors.groupingBy(ItemSpaceMap::getDepartmentCode)); collect.forEach((k, v) -> { Map> collect1 = v.stream().collect(Collectors.groupingBy(ItemSpaceMap::getItemCode)); spaceGroup.put(k, collect1); }); // spaceGroup = list3.stream().collect(Collectors.groupingBy(ItemSpaceMap::getItemCode)); } Map> map = new HashMap<>(); Map> collect = list.stream().collect(Collectors.groupingBy(Item::getDepartmentCode)); collect.forEach((k, v) -> { Map> empMap = empMapGroup.get(k); Map> equipmentMap = equipmentGroup.get(k); Map> spaceMap = spaceGroup.get(k); Map itemCodeMap = new HashMap<>(); for (Item item : v) { if (!CollectionUtils.isEmpty(empMap)) { item.setEmpMaps(empMap.get(item.getCode())); } if (!CollectionUtils.isEmpty(equipmentMap)) { item.setEquipmentMaps(equipmentMap.get(item.getCode())); } if (!CollectionUtils.isEmpty(spaceMap)) { item.setSpaceMaps(spaceMap.get(item.getCode())); } itemCodeMap.put(item.getCode(), item); } map.put(k, itemCodeMap); }); return map; } private List getPatientResponsibility(SessionUserVO currentUser) { return getVisitNoResponsibilityMaps(currentUser, responsibilityDepartmentRepository, centerService, log); } private @NotNull Map> getPatientItemGroup(String computeDate, SessionUserVO currentUser, Map responsibilityCodeMap) { List items = importPatientItemRepository.getByDepartGroupComputeDateItem(computeDate, currentUser); //移除执行科室为空的 List removeDepartmentList = new ArrayList<>(); for (PatientItemDepartmentGroupVo item : items) { if(StringUtils.isEmpty(item.getExecuteDepartmentCode())){ removeDepartmentList.add(item); } } if(!CollectionUtils.isEmpty(removeDepartmentList)){ List logs = new ArrayList<>(); for (PatientItemDepartmentGroupVo patientItemDepartmentGroupVo : removeDepartmentList) { logs.add(patientItemDepartmentGroupVo.getItemCode()); } List collect2 = logs.stream().distinct().collect(Collectors.toList()); log.info("以下项目数据【{}】执行科室为空", collect2); items.removeAll(removeDepartmentList); } items.forEach(item -> item.setResponsibilityCode(responsibilityCodeMap.get(item.getExecuteDepartmentCode()))); //移除责任中心为空的 List removeList = new ArrayList<>(); for (PatientItemDepartmentGroupVo item : items) { if(StringUtils.isEmpty(item.getResponsibilityCode())){ removeList.add(item); } } if(!CollectionUtils.isEmpty(removeList)){ List logs = new ArrayList<>(); for (PatientItemDepartmentGroupVo patientItemDepartmentGroupVo : removeList) { logs.add(patientItemDepartmentGroupVo.getExecuteDepartmentCode()); } List collect2 = logs.stream().distinct().collect(Collectors.toList()); log.info("以下执行科室【{}】科室代码未对照责任中心", collect2); items.removeAll(removeList); } Map> collect2 = items.stream().collect(Collectors.groupingBy(PatientItemDepartmentGroupVo::getResponsibilityCode)); Map> responsibilityItemGroupMap = new HashMap<>(); collect2.forEach((k,v)->{ Map> collect3 = v.stream().collect(Collectors.groupingBy(PatientItemDepartmentGroupVo::getItemCode)); if(!CollectionUtils.isEmpty(collect3)){ Map itemGroupMap = new HashMap<>(); collect3.forEach((itemCode,itemList)->{ PatientItemDepartmentGroupVo vo = new PatientItemDepartmentGroupVo(); vo.setItemCode(itemCode); vo.setItemName(itemList.get(0).getItemName()); vo.setResponsibilityCode(k); AtomicReference sumNum = new AtomicReference<>(new BigDecimal("0.00")); AtomicReference sumAmount = new AtomicReference<>(new BigDecimal("0.0000")); for (PatientItemDepartmentGroupVo vo1 : itemList) { sumNum.updateAndGet(s -> s.add(vo1.getNum())); sumAmount.updateAndGet(s -> s.add(vo1.getAmount())); } vo.setNum(sumNum.get()); vo.setAmount(sumAmount.get()); vo.setExecuteDepartmentCode(itemList.get(0).getExecuteDepartmentCode()); itemGroupMap.put(itemCode,vo); }); responsibilityItemGroupMap.put(k,itemGroupMap); } }); return responsibilityItemGroupMap; } }