| package com.dy.pipIrrStatistics.statistics; | 
|   | 
| import com.dy.pipIrrGlobal.daoRm.RmIntakeAmountDayMapper; | 
| import com.dy.pipIrrGlobal.daoSt.StIntakeAmountMonthMapper; | 
| import com.dy.pipIrrGlobal.daoSt.StIntakeAmountYearMapper; | 
| import com.dy.pipIrrGlobal.pojoSt.StIntakeAmountMonth; | 
| import com.dy.pipIrrGlobal.pojoSt.StIntakeAmountYear; | 
| import com.dy.pipIrrGlobal.pojoSt.StLossYear; | 
| import com.dy.pipIrrGlobal.voSt.VoIntakeAmountStatistics; | 
| import com.dy.pipIrrGlobal.voSt.VoIntakeLossStatistics; | 
| import org.springframework.beans.factory.annotation.Autowired; | 
| import org.springframework.stereotype.Component; | 
| import org.springframework.transaction.annotation.Transactional; | 
|   | 
| import java.util.List; | 
|   | 
| /** | 
|  * @Author: liurunyu | 
|  * @Date: 2024/7/24 16:28 | 
|  * @Description | 
|  */ | 
| @Component | 
| public class StIntakeSv { | 
|   | 
|     @Autowired | 
|     protected RmIntakeAmountDayMapper rmIntakeAmountDayDao; | 
|   | 
|     @Autowired | 
|     protected StIntakeAmountMonthMapper stIntakeAmountMonthDao ; | 
|   | 
|     @Autowired | 
|     protected StIntakeAmountYearMapper stIntakeAmountYearDao ; | 
|   | 
|     /** | 
|      * 月统计---漏损 | 
|      */ | 
|     @Transactional | 
|     protected void statisticsMonth(Integer statisticsYear, Integer statisticsMonth, Long statisticsStartId, Long statisticsEndId){ | 
|         List<VoIntakeAmountStatistics> list = rmIntakeAmountDayDao.statisticsByIntake(statisticsStartId, statisticsEndId) ; | 
|         if(list != null && list.size() > 0){ | 
|             for(VoIntakeAmountStatistics vo : list){ | 
|                 StIntakeAmountMonth po = new StIntakeAmountMonth() ; | 
|                 po.intakeId = vo.intakeId ; | 
|                 po.year = statisticsYear ; | 
|                 po.month = statisticsMonth ; | 
|                 po.amount = vo.amount; | 
|                 stIntakeAmountMonthDao.insert(po) ; | 
|             } | 
|         } | 
|     } | 
|   | 
|     /** | 
|      * 年统计---漏损 | 
|      */ | 
|     @Transactional | 
|     protected void statisticsYear(Integer statisticsYear){ | 
|         List<VoIntakeAmountStatistics> list = stIntakeAmountMonthDao.statisticsByIntake(statisticsYear) ; | 
|         if(list != null && list.size() > 0){ | 
|             for(VoIntakeAmountStatistics vo : list){ | 
|                 StIntakeAmountYear po = new StIntakeAmountYear() ; | 
|                 po.intakeId = vo.intakeId ; | 
|                 po.year = statisticsYear ; | 
|                 po.amount = vo.amount; | 
|                 stIntakeAmountYearDao.insert(po) ; | 
|             } | 
|         } | 
|     } | 
|   | 
| } |