package cn.besteam.modules.report.biz;
|
|
import cn.besteam.common.constant.CommonConstant;
|
import cn.besteam.common.constant.DepartmentEnum;
|
import cn.besteam.common.constant.MedicalWasteEnum;
|
import cn.besteam.common.constant.MedicalWasteEnum.MedicalWasteAuditStatusEnum;
|
import cn.besteam.common.util.DateUtil;
|
import cn.besteam.modules.medical.dto.MwDataStatisticsDTO;
|
import cn.besteam.modules.medical.entity.MwCollectRecord;
|
import cn.besteam.modules.medical.entity.MwDataStatistics;
|
import cn.besteam.modules.medical.mapper.MwDataStatisticsMapper;
|
import cn.besteam.modules.medical.service.IMwCheckoutRecordItemService;
|
import cn.besteam.modules.medical.service.IMwCheckoutRecordService;
|
import cn.besteam.modules.medical.service.IMwCollectRecordService;
|
import cn.besteam.modules.medical.service.IMwNoticeService;
|
import cn.besteam.modules.medical.vo.MwCollectCollectTrajectoryParamVO;
|
import cn.besteam.modules.report.vo.*;
|
import cn.besteam.modules.shiro.authc.util.EnvUtils;
|
import cn.besteam.modules.system.biz.SysDepartmentBiz;
|
import cn.besteam.modules.system.entity.SysDepartment;
|
import cn.besteam.modules.system.entity.SysDict;
|
import cn.besteam.modules.system.entity.SysDictItem;
|
import cn.besteam.modules.system.service.ISysDepartmentService;
|
import cn.besteam.modules.system.service.ISysDictItemService;
|
import cn.besteam.modules.system.service.ISysDictService;
|
import cn.besteam.modules.system.util.MybatisParameterUtils;
|
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
|
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
|
import com.baomidou.mybatisplus.core.metadata.IPage;
|
import com.google.common.collect.Lists;
|
import com.sun.org.apache.bcel.internal.generic.NEWARRAY;
|
import java.util.concurrent.CountDownLatch;
|
import lombok.extern.slf4j.Slf4j;
|
import net.sf.json.JSONArray;
|
import net.sf.json.JSONObject;
|
import org.apache.commons.collections.CollectionUtils;
|
import org.apache.commons.lang3.time.DateUtils;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.stereotype.Service;
|
|
import java.math.BigDecimal;
|
import java.text.ParseException;
|
import java.util.*;
|
import java.util.stream.Collectors;
|
|
/**
|
* 首页
|
*/
|
@Service
|
@Slf4j
|
public class IndexBiz {
|
|
@Autowired
|
private IMwCheckoutRecordService mwCheckoutRecordService;
|
|
@Autowired
|
private IMwCheckoutRecordItemService mwCheckoutRecordItemService;
|
|
@Autowired
|
private ISysDictService sysDictService;
|
|
@Autowired
|
private ISysDictItemService sysDictItemService;
|
|
@Autowired
|
private ISysDepartmentService sysDepartmentService;
|
|
@Autowired
|
private IMwCollectRecordService mwCollectRecordService;
|
|
@Autowired
|
private MwDataStatisticsMapper mwDataStatisticsMapper;
|
|
@Autowired
|
private SysDepartmentBiz sysDepartmentBiz;
|
|
@Autowired
|
private IMwNoticeService mwNoticeService;
|
|
/**
|
* 指标卡
|
*
|
* @return
|
*/
|
public IndexVO getIndex() {
|
|
IndexVO vo = new IndexVO();
|
Date todayBegin = DateUtil.beginDate(new Date());
|
Date todayEnd = DateUtil.endDate(new Date());
|
List<Integer> departmentIdList = getDepartmentList();
|
CountDownLatch latch = new CountDownLatch(5);
|
new Thread(() -> {
|
System.out.println("指标1开始执行"+Thread.currentThread().getName());
|
// 今日收集
|
LambdaQueryWrapper<MwCollectRecord> lambdaQueryWrapper = new LambdaQueryWrapper<MwCollectRecord>()//
|
.eq(MwCollectRecord::getDelFlag, CommonConstant.DEL_FLAG_0)//
|
.eq(MwCollectRecord::getAuditStatus,
|
MedicalWasteAuditStatusEnum.PASS.getStatus())//
|
.between(MwCollectRecord::getCreateTime, todayBegin, todayEnd);
|
try {
|
MybatisParameterUtils.cutInParameter(lambdaQueryWrapper, MwCollectRecord::getHospitalId,
|
departmentIdList);
|
} catch (Exception e) {
|
throw new RuntimeException(e);
|
}
|
List<MwCollectRecord> todayCollectRecordList = mwCollectRecordService.list(
|
lambdaQueryWrapper);
|
vo.setMedicalWasteTodayCollect(todayCollectRecordList.stream().filter(item ->
|
MedicalWasteEnum.getMedicalWasteTypes().contains(item.getWasteTypeStr())).map(MwCollectRecord::getWeight)
|
.reduce(BigDecimal::add).orElse(BigDecimal.ZERO));
|
vo.setBottleBagTodayCollect(todayCollectRecordList.stream().filter(item ->
|
MedicalWasteEnum.getBottleBagTypes().contains(item.getWasteTypeStr())).map(MwCollectRecord::getWeight)
|
.reduce(BigDecimal::add).orElse(BigDecimal.ZERO));
|
vo.setDangerousWasteTodayCollect(todayCollectRecordList.stream().filter(item ->
|
MedicalWasteEnum.getDangerousWasteTypes().contains(item.getWasteTypeStr())).map(MwCollectRecord::getWeight)
|
.reduce(BigDecimal::add).orElse(BigDecimal.ZERO));
|
latch.countDown();
|
}).start();
|
new Thread(() -> {
|
System.out.println("指标2开始执行"+Thread.currentThread().getName());
|
// 今日入库
|
LambdaQueryWrapper<MwCollectRecord> lambdaQueryWrapper = new LambdaQueryWrapper<MwCollectRecord>()//
|
.in(MwCollectRecord::getStatus, Arrays.asList(
|
MedicalWasteEnum.MedicalWasteStatusEnum.STORE.getStatus(),
|
MedicalWasteEnum.MedicalWasteStatusEnum.CHECKOUT.getStatus()))//
|
.eq(MwCollectRecord::getDelFlag, CommonConstant.DEL_FLAG_0)//
|
.eq(MwCollectRecord::getAuditStatus,
|
MedicalWasteEnum.MedicalWasteAuditStatusEnum.PASS.getStatus())//
|
.between(MwCollectRecord::getStoreTime, todayBegin, todayEnd);
|
|
try {
|
MybatisParameterUtils.cutInParameter(lambdaQueryWrapper, MwCollectRecord::getHospitalId,
|
departmentIdList);
|
} catch (Exception e) {
|
throw new RuntimeException(e);
|
}
|
List<MwCollectRecord> todayStoreRecordList = mwCollectRecordService.list(
|
lambdaQueryWrapper);
|
vo.setMedicalWasteTodayStore(todayStoreRecordList.stream().filter(item ->
|
MedicalWasteEnum.getMedicalWasteTypes().contains(item.getWasteTypeStr())).map(MwCollectRecord::getStoreWeight)
|
.reduce(BigDecimal::add).orElse(BigDecimal.ZERO));
|
vo.setBottleBagTodayStore(todayStoreRecordList.stream().filter(item ->
|
MedicalWasteEnum.getBottleBagTypes().contains(item.getWasteTypeStr())).map(MwCollectRecord::getStoreWeight)
|
.reduce(BigDecimal::add).orElse(BigDecimal.ZERO));
|
vo.setDangerousWasteTodayStore(todayStoreRecordList.stream().filter(item ->
|
MedicalWasteEnum.getDangerousWasteTypes().contains(item.getWasteTypeStr())).map(MwCollectRecord::getStoreWeight)
|
.reduce(BigDecimal::add).orElse(BigDecimal.ZERO));
|
latch.countDown();
|
}).start();
|
new Thread(() -> {
|
System.out.println("指标3始执行"+Thread.currentThread().getName());
|
// 今日出库
|
LambdaQueryWrapper<MwCollectRecord> lambdaQueryWrapper = new LambdaQueryWrapper<MwCollectRecord>()//
|
.eq(MwCollectRecord::getStatus,
|
MedicalWasteEnum.MedicalWasteStatusEnum.CHECKOUT.getStatus())//
|
.eq(MwCollectRecord::getDelFlag, CommonConstant.DEL_FLAG_0)//
|
.eq(MwCollectRecord::getAuditStatus,
|
MedicalWasteEnum.MedicalWasteAuditStatusEnum.PASS.getStatus())//
|
.between(MwCollectRecord::getCheckoutTime, todayBegin, todayEnd);
|
try {
|
MybatisParameterUtils.cutInParameter(lambdaQueryWrapper, MwCollectRecord::getHospitalId,
|
departmentIdList);
|
} catch (Exception e) {
|
throw new RuntimeException(e);
|
}
|
List<MwCollectRecord> todayCheckoutRecordList = mwCollectRecordService.list(
|
lambdaQueryWrapper);
|
vo.setMedicalWasteTodayCheckout(todayCheckoutRecordList.stream().filter(item ->
|
MedicalWasteEnum.getMedicalWasteTypes().contains(item.getWasteTypeStr())).map(MwCollectRecord::getCheckoutWeight)
|
.reduce(BigDecimal::add).orElse(BigDecimal.ZERO));
|
vo.setBottleBagTodayCheckout(todayCheckoutRecordList.stream().filter(item ->
|
MedicalWasteEnum.getBottleBagTypes().contains(item.getWasteTypeStr())).map(MwCollectRecord::getCheckoutWeight)
|
.reduce(BigDecimal::add).orElse(BigDecimal.ZERO));
|
vo.setDangerousWasteTodayCheckout(todayCheckoutRecordList.stream().filter(item ->
|
MedicalWasteEnum.getDangerousWasteTypes().contains(item.getWasteTypeStr())).map(MwCollectRecord::getCheckoutWeight)
|
.reduce(BigDecimal::add).orElse(BigDecimal.ZERO));
|
latch.countDown();
|
}).start();
|
new Thread(() -> {
|
System.out.println("指标4开始执行"+Thread.currentThread().getName());
|
// 累计未入库
|
LambdaQueryWrapper<MwCollectRecord> lambdaQueryWrapper = new LambdaQueryWrapper<MwCollectRecord>()//
|
.eq(MwCollectRecord::getStatus,
|
MedicalWasteEnum.MedicalWasteStatusEnum.COLLECT.getStatus())//
|
.isNull(MwCollectRecord::getStoreTime)//
|
.eq(MwCollectRecord::getDelFlag, CommonConstant.DEL_FLAG_0)//
|
.eq(MwCollectRecord::getAuditStatus,
|
MedicalWasteEnum.MedicalWasteAuditStatusEnum.PASS.getStatus());
|
try {
|
MybatisParameterUtils.cutInParameter(lambdaQueryWrapper, MwCollectRecord::getHospitalId,
|
departmentIdList);
|
} catch (Exception e) {
|
throw new RuntimeException(e);
|
}
|
List<MwCollectRecord> nonStoreRecordList = mwCollectRecordService.list(
|
lambdaQueryWrapper);//
|
vo.setMedicalWasteTotalNonStore(nonStoreRecordList.stream().filter(item ->
|
MedicalWasteEnum.getMedicalWasteTypes().contains(item.getWasteTypeStr())).map(MwCollectRecord::getWeight)
|
.reduce(BigDecimal::add).orElse(BigDecimal.ZERO));
|
vo.setBottleBagTotalNonStore(nonStoreRecordList.stream().filter(item ->
|
MedicalWasteEnum.getBottleBagTypes().contains(item.getWasteTypeStr())).map(MwCollectRecord::getWeight)
|
.reduce(BigDecimal::add).orElse(BigDecimal.ZERO));
|
vo.setDangerousWasteTotalNonStore(nonStoreRecordList.stream().filter(item ->
|
MedicalWasteEnum.getDangerousWasteTypes().contains(item.getWasteTypeStr())).map(MwCollectRecord::getWeight)
|
.reduce(BigDecimal::add).orElse(BigDecimal.ZERO));
|
latch.countDown();
|
}).start();
|
new Thread(() -> {
|
System.out.println("指标5开始执行" + Thread.currentThread().getName());
|
Double totalNonCheckout = mwCollectRecordService.getTotalNonCheckout(departmentIdList, MedicalWasteEnum.getMedicalWasteTypes());
|
vo.setMedicalWasteTotalNonCheckout(BigDecimal.valueOf(totalNonCheckout));
|
Double bottleBagTotalNonCheckout = mwCollectRecordService.getTotalNonCheckout(departmentIdList, MedicalWasteEnum.getBottleBagTypes());
|
vo.setBottleBagTotalNonCheckout(BigDecimal.valueOf(bottleBagTotalNonCheckout));
|
Double dangerousWasteTotalNonCheckout = mwCollectRecordService.getTotalNonCheckout(departmentIdList, MedicalWasteEnum.getDangerousWasteTypes());
|
vo.setDangerousWasteTotalNonCheckout(BigDecimal.valueOf(dangerousWasteTotalNonCheckout));
|
latch.countDown();
|
}).start();
|
try {
|
latch.await();
|
return vo;
|
} catch (InterruptedException e) {
|
throw new RuntimeException(e);
|
}
|
}
|
|
public IndexScheduleVO getIndexSchedule() {
|
return mwNoticeService.getIndexSchedule();
|
}
|
|
/**
|
* 今日排行榜
|
*
|
* @return
|
*/
|
public List<RankStatisticsVO> getTodayRankStatistics(String startTime_,String endTime_) {
|
|
Date startTime = DateUtil.beginDate(new Date());
|
if(startTime_!=null && startTime_!=""){
|
try {
|
startTime = DateUtils.parseDate(startTime_,"yyyy-MM-dd HH:mm:ss");
|
} catch (ParseException e) {
|
e.printStackTrace();
|
}
|
}
|
Date endTime = DateUtil.endDate(new Date());
|
if(endTime_!=null && endTime_!="") {
|
try {
|
endTime = DateUtils.parseDate(endTime_, "yyyy-MM-dd HH:mm:ss");
|
} catch (ParseException e) {
|
e.printStackTrace();
|
}
|
}
|
List<SysDepartment> sysDepartmentList;
|
SysDepartment myDepartment = sysDepartmentService.getMyDepartment(EnvUtils.getUser().getId());
|
// 如果当前用户所属组织的类型为医院、部门、科室 ，则获取医院下的科室列表
|
if (!myDepartment.getOrgType().equals(DepartmentEnum.OrgTypeEnum.AREA.getType())) {
|
if (!myDepartment.getOrgType().equals(DepartmentEnum.OrgTypeEnum.HOSPITAL.getType())) {
|
myDepartment = sysDepartmentService.getHospital(myDepartment.getParentId());
|
}
|
sysDepartmentList = sysDepartmentService.list(new QueryWrapper<SysDepartment>()//
|
.lambda()//
|
.eq(SysDepartment::getOrgType, DepartmentEnum.OrgTypeEnum.OFFICE.getType())//
|
.eq(SysDepartment::getIsWarehouse, 0)//
|
.likeRight(SysDepartment::getTreeCode, myDepartment.getTreeCode()));
|
if (CollectionUtils.isEmpty(sysDepartmentList)) {
|
return new ArrayList<>();
|
}
|
List<RankStatisticsVO> voList = mwCollectRecordService.getOfficeRankStatistics(sysDepartmentList.stream().map(SysDepartment::getId).collect(Collectors.toList()), startTime, endTime);
|
Integer index=0;
|
for(RankStatisticsVO rankStatisticsVO:voList){
|
index=index+1;
|
rankStatisticsVO.setRank(index);
|
rankStatisticsVO.setRanks(index);
|
}
|
return voList;
|
} else {// 否则获取医院列表
|
sysDepartmentList = sysDepartmentService.list(new QueryWrapper<SysDepartment>()//
|
.lambda()//
|
.eq(SysDepartment::getOrgType, DepartmentEnum.OrgTypeEnum.HOSPITAL.getType())//
|
.likeRight(SysDepartment::getTreeCode, myDepartment.getTreeCode()));
|
if (CollectionUtils.isEmpty(sysDepartmentList)) {
|
return new ArrayList<>();
|
}
|
IPage<RankStatisticsVO> vo = mwCollectRecordService.getRankStatisticsList(1, 10, sysDepartmentList.stream().map(SysDepartment::getId).collect(Collectors.toList()), startTime, endTime,null);
|
for (int i = 0; i < vo.getRecords().size(); i++) {
|
vo.getRecords().get(i).setKey(i);
|
}
|
List<RankStatisticsVO> voList = vo.getRecords();
|
Integer index=0;
|
for(RankStatisticsVO rankStatisticsVO:voList){
|
index=index+1;
|
rankStatisticsVO.setRank(index);
|
rankStatisticsVO.setRanks(index);
|
}
|
return voList;
|
}
|
}
|
|
/**
|
* 最近7日统计
|
*
|
* @return
|
*/
|
public LastSevenDaysStatisticsVO getLastSevenDaysStatistics(String startTime_,String endTime_) {
|
|
LastSevenDaysStatisticsVO vo = new LastSevenDaysStatisticsVO();
|
//
|
List<SysDictItem> wasteTypeList = getWasteTypeList();
|
if (CollectionUtils.isEmpty(wasteTypeList)) {
|
return vo;
|
}
|
Date startTime = DateUtils.addDays(DateUtil.beginDate(new Date()), -6);
|
if(startTime_!=null){
|
try {
|
startTime = DateUtils.parseDate(startTime_,"yyyy-MM-dd HH:mm:ss");
|
} catch (ParseException e) {
|
e.printStackTrace();
|
}
|
}
|
Date endTime = DateUtil.endDate(new Date());
|
if(endTime_!=null) {
|
try {
|
endTime = DateUtils.parseDate(endTime_, "yyyy-MM-dd HH:mm:ss");
|
} catch (ParseException e) {
|
e.printStackTrace();
|
}
|
}
|
//
|
List<SysDepartment> sysDepartmentList;
|
SysDepartment myDepartment = sysDepartmentService.getMyDepartment(EnvUtils.getUser().getId());
|
// 获取医院列表
|
if (myDepartment.getOrgType().equals(DepartmentEnum.OrgTypeEnum.DEPARTMENT.getType()) || myDepartment.getOrgType().equals(DepartmentEnum.OrgTypeEnum.OFFICE.getType())) {
|
myDepartment = sysDepartmentService.getHospital(myDepartment.getParentId());
|
}
|
sysDepartmentList = sysDepartmentService.list(new QueryWrapper<SysDepartment>()//
|
.lambda()//
|
.eq(SysDepartment::getOrgType, DepartmentEnum.OrgTypeEnum.HOSPITAL.getType())//
|
.likeRight(SysDepartment::getTreeCode, myDepartment.getTreeCode()));
|
if (CollectionUtils.isEmpty(sysDepartmentList)) {
|
return vo;
|
}
|
//最近7日的医废列表
|
List<MwCollectRecord> totalCollectRecordList = mwCollectRecordService.list(new QueryWrapper<MwCollectRecord>()//
|
.lambda()//
|
.eq(MwCollectRecord::getDelFlag, CommonConstant.DEL_FLAG_0)//
|
.eq(MwCollectRecord::getAuditStatus, MedicalWasteEnum.MedicalWasteAuditStatusEnum.PASS.getStatus())//
|
.in(MwCollectRecord::getHospitalId, sysDepartmentList.stream().map(SysDepartment::getId).collect(Collectors.toList()))//
|
.between(MwCollectRecord::getCreateTime, startTime, endTime));
|
//医废类型统计
|
WasteTypeStatisticsVO wasteTypeStatisticsVO = new WasteTypeStatisticsVO();
|
wasteTypeStatisticsVO.setLegend(wasteTypeList.stream().map(SysDictItem::getItemText).collect(Collectors.toList()));
|
List<WasteTypeStatisticsVO.InnerData> dataList = new ArrayList<>();
|
for (SysDictItem wasteType : wasteTypeList) {
|
BigDecimal weight = totalCollectRecordList.stream().filter(e -> e.getWasteType().equals(wasteType.getId())).map(MwCollectRecord::getWeight).reduce(BigDecimal::add).orElse(BigDecimal.ZERO);
|
dataList.add(WasteTypeStatisticsVO.InnerData.builder().name(wasteType.getItemText()).data(weight).build());
|
}
|
wasteTypeStatisticsVO.setDataList(dataList);
|
vo.setWasteTypeStatistics(wasteTypeStatisticsVO);
|
//柱状图
|
List<List<Object>> source = new ArrayList<>();
|
source.add(Arrays.asList("product", "重量", "袋"));
|
Date startTimeTemp = startTime;
|
while (startTimeTemp.before(endTime)) {
|
String key = DateUtil.format(startTimeTemp, "yyyy-MM-dd");
|
BigDecimal weight = totalCollectRecordList.stream().filter(e -> key.equals(DateUtil.format(e.getCreateTime(), "yyyy-MM-dd"))).map(MwCollectRecord::getWeight).reduce(BigDecimal::add).orElse(BigDecimal.ZERO);
|
long count = totalCollectRecordList.stream().filter(e -> key.equals(DateUtil.format(e.getCreateTime(), "yyyy-MM-dd"))).count();
|
source.add(Arrays.asList(key, weight, count));
|
//
|
startTimeTemp = DateUtils.addDays(startTimeTemp, 1);
|
}
|
vo.setSource(source);
|
//
|
return vo;
|
}
|
|
/**
|
* 最近7日统计(小程序)
|
*
|
* @return
|
*/
|
public LastSevenDaysStatisticsVO getLastSevenDaysStatisticsX(String startTime_,String endTime_,Integer type) {
|
|
LastSevenDaysStatisticsVO vo = new LastSevenDaysStatisticsVO();
|
//
|
List<SysDictItem> wasteTypeList = getWasteTypeList();
|
if (CollectionUtils.isEmpty(wasteTypeList)) {
|
return vo;
|
}
|
Date startTime = DateUtils.addDays(DateUtil.beginDate(new Date()), -6);
|
if(startTime_!=null && startTime_!=""){
|
try {
|
startTime = DateUtils.parseDate(startTime_,"yyyy-MM-dd HH:mm:ss");
|
} catch (ParseException e) {
|
e.printStackTrace();
|
}
|
}
|
Date endTime = DateUtil.endDate(new Date());
|
if(endTime_!=null && endTime_!="") {
|
try {
|
endTime = DateUtils.parseDate(endTime_, "yyyy-MM-dd HH:mm:ss");
|
} catch (ParseException e) {
|
e.printStackTrace();
|
}
|
}
|
List<SysDepartment> sysDepartmentList;
|
SysDepartment myDepartment = sysDepartmentService.getMyDepartment(EnvUtils.getUser().getId());
|
// 获取医院列表
|
if (myDepartment.getOrgType().equals(DepartmentEnum.OrgTypeEnum.DEPARTMENT.getType()) || myDepartment.getOrgType().equals(DepartmentEnum.OrgTypeEnum.OFFICE.getType())) {
|
myDepartment = sysDepartmentService.getHospital(myDepartment.getParentId());
|
}
|
sysDepartmentList = sysDepartmentService.list(new QueryWrapper<SysDepartment>()//
|
.lambda()//
|
.eq(SysDepartment::getOrgType, DepartmentEnum.OrgTypeEnum.HOSPITAL.getType())//
|
.likeRight(SysDepartment::getTreeCode, myDepartment.getTreeCode()));
|
if (CollectionUtils.isEmpty(sysDepartmentList)) {
|
return vo;
|
}
|
if(type==1){
|
//最近7日的医废列表
|
List<MwCollectRecord> totalCollectRecordList = mwCollectRecordService.list(new QueryWrapper<MwCollectRecord>()//
|
.lambda()//
|
.eq(MwCollectRecord::getDelFlag, CommonConstant.DEL_FLAG_0)//
|
.eq(MwCollectRecord::getAuditStatus, MedicalWasteEnum.MedicalWasteAuditStatusEnum.PASS.getStatus())//
|
.in(MwCollectRecord::getHospitalId, sysDepartmentList.stream().map(SysDepartment::getId).collect(Collectors.toList()))//
|
.between(MwCollectRecord::getCreateTime, startTime, endTime));
|
//柱状图
|
List<List<Object>> source = new ArrayList<>();
|
source.add(Arrays.asList("product", "重量", "袋"));
|
Date startTimeTemp = startTime;
|
while (startTimeTemp.before(endTime)) {
|
String key = DateUtil.format(startTimeTemp, "yyyy-MM-dd");
|
BigDecimal weight = totalCollectRecordList.stream().filter(e -> key.equals(DateUtil.format(e.getCreateTime(), "yyyy-MM-dd"))).map(MwCollectRecord::getWeight).reduce(BigDecimal::add).orElse(BigDecimal.ZERO);
|
long count = totalCollectRecordList.stream().filter(e -> key.equals(DateUtil.format(e.getCreateTime(), "yyyy-MM-dd"))).count();
|
source.add(Arrays.asList(key, weight, count));
|
//
|
startTimeTemp = DateUtils.addDays(startTimeTemp, 1);
|
}
|
vo.setSource(source);
|
}else {
|
MwCollectCollectTrajectoryParamVO trajectoryParamVO=new MwCollectCollectTrajectoryParamVO();
|
trajectoryParamVO.setHospitalIdList(sysDepartmentList.stream().map(SysDepartment::getId).collect(Collectors.toList()));
|
trajectoryParamVO.setStartTime(startTime);
|
trajectoryParamVO.setEndTime(endTime);
|
trajectoryParamVO.setDelFlag(CommonConstant.DEL_FLAG_0);
|
trajectoryParamVO.setAuditStatus(MedicalWasteEnum.MedicalWasteAuditStatusEnum.PASS.getStatus());
|
List<Map<String,Object>> totalCollectRecordList = mwCollectRecordService.getMedicalStatistics(trajectoryParamVO);
|
List<String> dateList=DateUtil.getMonthBetween(startTime_,endTime_);
|
//柱状图
|
List<List<Object>> source = new ArrayList<>();
|
source.add(Arrays.asList("product", "重量", "袋"));
|
for(String month : dateList){
|
String key =month;
|
BigDecimal weight = new BigDecimal(0);
|
long count=0l;
|
for(Map<String,Object> mv:totalCollectRecordList){
|
if(month.equals(mv.get("month").toString())){
|
weight = new BigDecimal(mv.get("weights").toString());
|
count = Integer.valueOf(mv.get("couns").toString());
|
continue;
|
}
|
}
|
source.add(Arrays.asList(key, weight, count));
|
}
|
vo.setSource(source);
|
}
|
return vo;
|
}
|
|
/**
|
* 获取所有医废类型
|
*
|
* @return
|
*/
|
private List<SysDictItem> getWasteTypeList() {
|
|
SysDict sysDict = sysDictService.getOne(new QueryWrapper<SysDict>().lambda().eq(SysDict::getDictCode, "MEDICAL_WASTE_TYPE"));
|
if (sysDict == null) {
|
return null;
|
}
|
//获取字典所有医废类型
|
return sysDictItemService.list(new QueryWrapper<SysDictItem>().lambda().eq(SysDictItem::getDictId, sysDict.getId()));
|
}
|
|
private List<Integer> getDepartmentList() {
|
|
List<Integer> list = null;
|
SysDepartment myDepartment = sysDepartmentService.getMyDepartment(EnvUtils.getUser().getId());
|
if (myDepartment.getOrgType().equals(DepartmentEnum.OrgTypeEnum.DEPARTMENT.getType()) || myDepartment.getOrgType().equals(DepartmentEnum.OrgTypeEnum.OFFICE.getType())) {
|
SysDepartment hospital = sysDepartmentService.getHospital(myDepartment.getParentId());
|
list = Lists.newArrayList(hospital.getId());
|
} else {
|
list = sysDepartmentService.getDeptIdListByTreeCode(myDepartment.getTreeCode());
|
}
|
return list;
|
}
|
|
/**
|
* 获取数据大屏
|
*
|
* @return
|
*/
|
public MwDataStatisticsDTO getDataStatistics() {
|
SysDepartment myDepartment = sysDepartmentService.getMyDepartment(EnvUtils.getUser().getId());
|
List<SysDepartment> sysDepartmentList = sysDepartmentService.list(new QueryWrapper<SysDepartment>().lambda().eq(SysDepartment::getParentId, myDepartment.getId()).eq(SysDepartment::getOrgType, DepartmentEnum.OrgTypeEnum.AREA.getType()).orderByAsc(SysDepartment::getTreeCode));
|
String departmentIds_="";
|
if(sysDepartmentList!=null && sysDepartmentList.size()>0){
|
for(SysDepartment sysDepartment: sysDepartmentList){
|
departmentIds_+=sysDepartment.getId()+",";
|
}
|
}
|
Integer type=1;
|
if(myDepartment.getId()==-1){//平台数据
|
type=2;
|
}
|
List<Integer> sysDepartmentDTOS=null;
|
if(type==1){
|
sysDepartmentDTOS=mwDataStatisticsMapper.getDepartmentIds(myDepartment.getId());
|
}else if(type==2){
|
sysDepartmentDTOS=mwDataStatisticsMapper.getDepartmentIdsAll(myDepartment.getId());
|
}
|
String departmentIds="";
|
if(sysDepartmentDTOS!=null && sysDepartmentDTOS.size()>0){
|
for(Integer id: sysDepartmentDTOS){
|
departmentIds+=id+",";
|
}
|
}
|
|
|
MwDataStatisticsDTO mwDataStatistics=new MwDataStatisticsDTO();
|
if(departmentIds!=null && !departmentIds.equals("")){
|
departmentIds=departmentIds.substring(0,departmentIds.length()-1);
|
List<MwDataStatistics> mwDataStatisticsList=mwDataStatisticsMapper.getDataStatisticsByParentIds(departmentIds,type);//=new MwDataStatistics();//
|
Integer hospitals=0;
|
BigDecimal totalWeight=new BigDecimal(0);
|
Integer totalNumber=0;
|
BigDecimal todayWeight=new BigDecimal(0);
|
BigDecimal todayWeightPut=new BigDecimal(0);
|
BigDecimal todayWeightOut=new BigDecimal(0);
|
BigDecimal weightNotout=new BigDecimal(0);
|
BigDecimal weightNotput=new BigDecimal(0);
|
BigDecimal todayWeightNotout=new BigDecimal(0);
|
BigDecimal todayWeightNotput=new BigDecimal(0);
|
Integer warningWithout=0;
|
Integer warningTimeoutPut=0;
|
Integer warningTimeoutOut=0;
|
Integer warningMissing=0;
|
for(MwDataStatistics mwDataStatistics1:mwDataStatisticsList){
|
hospitals+=mwDataStatistics1.getHospitals();
|
totalNumber+=mwDataStatistics1.getTotalNumber();
|
warningWithout+=mwDataStatistics1.getWarningWithout();
|
warningTimeoutPut+=mwDataStatistics1.getWarningTimeoutPut();
|
warningTimeoutOut+=mwDataStatistics1.getWarningTimeoutOut();
|
warningMissing+=mwDataStatistics1.getWarningMissing();
|
totalWeight=totalWeight.add(mwDataStatistics1.getTotalWeight());
|
todayWeight=todayWeight.add(mwDataStatistics1.getTodayWeight());
|
todayWeightPut=todayWeightPut.add(mwDataStatistics1.getTodayWeightPut());
|
todayWeightOut=todayWeightOut.add(mwDataStatistics1.getTodayWeightOut());
|
weightNotout=weightNotout.add(mwDataStatistics1.getWeightNotout());
|
weightNotput=weightNotput.add(mwDataStatistics1.getWeightNotput());
|
todayWeightNotout=todayWeightNotout.add(mwDataStatistics1.getTodayWeightNotout());
|
todayWeightNotput=todayWeightNotput.add(mwDataStatistics1.getTodayWeightNotput());
|
}
|
//最近七日数据列表
|
List<String> dateList=DateUtil.getSevenDate();//最近七日日期数据
|
List<Map<String,Object>> listSevendaysWeightAnalyse=new ArrayList<>();
|
List<Map<String,Object>> listSevendaysWeightAnalyseOut=new ArrayList<>();
|
List<Map<String,Object>> listSevendaysWeightAnalysePut=new ArrayList<>();
|
for(String date : dateList){
|
Map<String,Object> mapSevendaysWeightAnalyse=new HashMap<>();
|
Map<String,Object> mapSevendaysWeightAnalyseOut=new HashMap<>();
|
Map<String,Object> mapSevendaysWeightAnalysePut=new HashMap<>();
|
mapSevendaysWeightAnalyse.put("days",date);
|
mapSevendaysWeightAnalyseOut.put("days",date);
|
mapSevendaysWeightAnalysePut.put("days",date);
|
Double sevendaysWeightAnalyseSum = 0d;
|
Double sevendaysWeightAnalyseOutSum = 0d;
|
Double sevendaysWeightAnalysePutSum = 0d;
|
for(MwDataStatistics mwDataStatistics1:mwDataStatisticsList) {
|
if (!"".equals(mwDataStatistics1.getSevendaysWeightAnalyse())) {
|
JSONArray array = JSONArray.fromObject(mwDataStatistics1.getSevendaysWeightAnalyse());
|
for (int i = 0; i < array.size(); i++) {
|
JSONObject jsonObject = array.getJSONObject(i);
|
if (date.equals(jsonObject.get("days").toString()) || date == jsonObject.get("days").toString()) {
|
sevendaysWeightAnalyseSum+=Double.valueOf(jsonObject.get("sums").toString());
|
continue;
|
}
|
}
|
}
|
if (!"".equals(mwDataStatistics1.getSevendaysWeightAnalyseOut())) {
|
JSONArray array = JSONArray.fromObject(mwDataStatistics1.getSevendaysWeightAnalyseOut());
|
for (int i = 0; i < array.size(); i++) {
|
JSONObject jsonObject = array.getJSONObject(i);
|
if (date.equals(jsonObject.get("days").toString()) || date == jsonObject.get("days").toString()) {
|
sevendaysWeightAnalyseOutSum+=Double.valueOf(jsonObject.get("sums").toString());
|
continue;
|
}
|
}
|
}
|
if (!"".equals(mwDataStatistics1.getSevendaysWeightAnalysePut())) {
|
JSONArray array = JSONArray.fromObject(mwDataStatistics1.getSevendaysWeightAnalysePut());
|
for (int i = 0; i < array.size(); i++) {
|
JSONObject jsonObject = array.getJSONObject(i);
|
if (date.equals(jsonObject.get("days").toString()) || date == jsonObject.get("days").toString()) {
|
sevendaysWeightAnalysePutSum+=Double.valueOf(jsonObject.get("sums").toString());
|
continue;
|
}
|
}
|
}
|
}
|
mapSevendaysWeightAnalyse.put("weights",sevendaysWeightAnalyseSum);
|
listSevendaysWeightAnalyse.add(mapSevendaysWeightAnalyse);
|
mapSevendaysWeightAnalyseOut.put("weights",sevendaysWeightAnalyseOutSum);
|
listSevendaysWeightAnalyseOut.add(mapSevendaysWeightAnalyseOut);
|
mapSevendaysWeightAnalysePut.put("weights",sevendaysWeightAnalysePutSum);
|
listSevendaysWeightAnalysePut.add(mapSevendaysWeightAnalysePut);
|
}
|
mwDataStatistics.setHospitals(hospitals);
|
mwDataStatistics.setTotalWeight(totalWeight);
|
mwDataStatistics.setTotalNumber(totalNumber);
|
mwDataStatistics.setTodayWeight(todayWeight);
|
mwDataStatistics.setTodayWeightPut(todayWeightPut);
|
mwDataStatistics.setTodayWeightOut(todayWeightOut);
|
mwDataStatistics.setWeightNotout(weightNotout);
|
mwDataStatistics.setWeightNotput(weightNotput);
|
mwDataStatistics.setWarningWithout(warningWithout);
|
mwDataStatistics.setWarningTimeoutPut(warningTimeoutPut);
|
mwDataStatistics.setWarningTimeoutOut(warningTimeoutOut);
|
mwDataStatistics.setWarningMissing(warningMissing);
|
mwDataStatistics.setSevendaysWeightAnalyse(listSevendaysWeightAnalyse);
|
mwDataStatistics.setSevendaysWeightAnalysePut(listSevendaysWeightAnalysePut);
|
mwDataStatistics.setSevendaysWeightAnalyseOut(listSevendaysWeightAnalyseOut);
|
if(departmentIds_!=null && departmentIds_!=""){
|
departmentIds_=departmentIds_.substring(0,departmentIds_.length()-1);
|
List<Map<String,Object>> sevendaysWeightAnalyseList=mwDataStatisticsMapper.getTodayWeightAnalyse(departmentIds_,type,1);
|
List<Map<String,Object>> sevendaysWeightAnalysePutList=mwDataStatisticsMapper.getTodayWeightAnalyse(departmentIds_,type,2);
|
List<Map<String,Object>> sevendaysWeightAnalyseOutList=mwDataStatisticsMapper.getTodayWeightAnalyse(departmentIds_,type,3);
|
mwDataStatistics.setTodayWeightAnalyse(sevendaysWeightAnalyseList);
|
mwDataStatistics.setTodayWeightAnalyseNotput(sevendaysWeightAnalysePutList);
|
mwDataStatistics.setTodayWeightAnalyseNotout(sevendaysWeightAnalyseOutList);
|
}
|
}
|
return mwDataStatistics;
|
}
|
|
}
|
