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) ; 
 | 
            } 
 | 
        } 
 | 
    } 
 | 
  
 | 
} 
 |