From d0542b6f8b7ead9cea467f12d989eaabb8ec6e60 Mon Sep 17 00:00:00 2001
From: luodangjia <luodangjia>
Date: 星期二, 07 一月 2025 17:06:57 +0800
Subject: [PATCH] 添加车辆运输路线记录

---
 medicalWaste-system/src/main/java/com/sinata/system/service/impl/MwDisposalRecordServiceImpl.java |   71 ++++++++++++++++++++++++++++-------
 1 files changed, 56 insertions(+), 15 deletions(-)

diff --git a/medicalWaste-system/src/main/java/com/sinata/system/service/impl/MwDisposalRecordServiceImpl.java b/medicalWaste-system/src/main/java/com/sinata/system/service/impl/MwDisposalRecordServiceImpl.java
index dbbaa0c..b4bf3a5 100644
--- a/medicalWaste-system/src/main/java/com/sinata/system/service/impl/MwDisposalRecordServiceImpl.java
+++ b/medicalWaste-system/src/main/java/com/sinata/system/service/impl/MwDisposalRecordServiceImpl.java
@@ -3,21 +3,25 @@
 import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
 import com.sinata.common.entity.PageDTO;
-import com.sinata.common.utils.CollUtils;
 import com.sinata.common.utils.StringUtils;
 import com.sinata.system.domain.MwDisposalRecord;
+import com.sinata.system.domain.query.DisposalReportQuery;
 import com.sinata.system.domain.query.MwDisposalRecordItemQuery;
 import com.sinata.system.domain.query.MwDisposalRecordQuery;
+import com.sinata.system.domain.vo.DepartmentTagInfoVO;
 import com.sinata.system.domain.vo.DisposalRecordStaticsVO;
+import com.sinata.system.domain.vo.MwCollectRecordVO;
 import com.sinata.system.domain.vo.MwDisposalRecordItemVO;
+import com.sinata.system.domain.vo.MwDisposalRecordReportVO;
 import com.sinata.system.domain.vo.MwDisposalRecordVO;
+import com.sinata.system.domain.vo.MwDisposalRecordWarningVO;
+import com.sinata.system.mapper.MwDisposalHandleRecordMapper;
 import com.sinata.system.mapper.MwDisposalRecordMapper;
 import com.sinata.system.service.MwDisposalRecordService;
 import com.sinata.system.service.SysDepartmentService;
 import lombok.RequiredArgsConstructor;
 import org.springframework.stereotype.Service;
 
-import java.math.BigDecimal;
 import java.util.List;
 
 /**
@@ -32,6 +36,7 @@
 @RequiredArgsConstructor
 public class MwDisposalRecordServiceImpl extends ServiceImpl<MwDisposalRecordMapper, MwDisposalRecord> implements MwDisposalRecordService {
     private final SysDepartmentService sysDepartmentService;
+    private final MwDisposalHandleRecordMapper mwDisposalHandleRecordMapper;
 
     /**
      * 统计数据
@@ -41,20 +46,12 @@
      */
     @Override
     public DisposalRecordStaticsVO statics(MwDisposalRecordQuery query) {
-        String treeCode = sysDepartmentService.getTreeCode(query.getDepartmentId());
+        String treeCode = sysDepartmentService.getTreeCodeByDepartmentId(query.getDepartmentId());
+        DisposalRecordStaticsVO vo = null;
         if (StringUtils.isNotBlank(treeCode)) {
-            List<MwDisposalRecordVO> disposalRecordVOList = baseMapper.getStaticsData(query, treeCode);
-            if (CollUtils.isNotEmpty(disposalRecordVOList)) {
-                DisposalRecordStaticsVO vo = new DisposalRecordStaticsVO();
-                vo.setReceiveQuantity(disposalRecordVOList.stream().map(MwDisposalRecordVO::getReceiveQuantity).reduce(0, Integer::sum));
-                vo.setReceiveWeight(disposalRecordVOList.stream().map(MwDisposalRecordVO::getReceiveWeight).reduce(BigDecimal.ZERO, BigDecimal::add));
-                vo.setUnloadQuantity(disposalRecordVOList.stream().map(MwDisposalRecordVO::getUnloadQuantity).reduce(0, Integer::sum));
-                vo.setUnloadWeight(disposalRecordVOList.stream().map(MwDisposalRecordVO::getUnloadWeight).reduce(BigDecimal.ZERO, BigDecimal::add));
-                vo.setTotalHandledQuantity(disposalRecordVOList.stream().map(MwDisposalRecordVO::getTotalHandledQuantity).reduce(0, Integer::sum));
-                vo.setTotalHandledWeight(disposalRecordVOList.stream().map(MwDisposalRecordVO::getTotalHandledWeight).reduce(BigDecimal.ZERO, BigDecimal::add));
-            }
+            vo = baseMapper.getStaticsData(query, treeCode);
         }
-        return new DisposalRecordStaticsVO();
+        return vo;
     }
 
     /**
@@ -65,7 +62,7 @@
      */
     @Override
     public PageDTO<MwDisposalRecordVO> pageList(MwDisposalRecordQuery query) {
-        String treeCode = sysDepartmentService.getTreeCode(query.getDepartmentId());
+        String treeCode = sysDepartmentService.getTreeCodeByDepartmentId(query.getDepartmentId());
         if (StringUtils.isBlank(treeCode)) {
             return PageDTO.empty(0L, 0L);
         }
@@ -84,4 +81,48 @@
         Page<MwDisposalRecordItemVO> page = baseMapper.pageDetail(new Page<>(query.getPageCurr(), query.getPageSize()), query.getDisposalRecordId());
         return PageDTO.of(page);
     }
+
+    /**
+     * 处置报表
+     *
+     * @param query
+     * @return
+     */
+    @Override
+    public List<MwDisposalRecordReportVO> disposalReceiveReport(DisposalReportQuery query) {
+        return baseMapper.disposalReceiveReport(query);
+    }
+
+    /**
+     * 监管报表医疗废物处置列表
+     *
+     * @param query
+     * @return
+     */
+    @Override
+    public List<MwCollectRecordVO> getRegulationReportList(DisposalReportQuery query) {
+        String treeCode = sysDepartmentService.getTreeCodeByDepartmentId(query.getDepartmentId());
+        return baseMapper.getRegulationReportList(query, treeCode);
+    }
+
+    /**
+     * 处置单位存储量预警数据
+     *
+     * @return
+     */
+    @Override
+    public List<MwDisposalRecordWarningVO> queryDisposalListByDepartment() {
+        return baseMapper.queryDisposalListByDepartment();
+    }
+
+    /**
+     * 获取大屏单位标签信息
+     *
+     * @param id
+     * @return
+     */
+    @Override
+    public DepartmentTagInfoVO getTagInfo(Long id) {
+        return baseMapper.getTagInfo(id);
+    }
 }

--
Gitblit v1.7.1