|  |  | 
 |  |  | import com.dy.pipIrrGlobal.pojoSt.StIntakeAmountMonth; | 
 |  |  | import com.dy.pipIrrGlobal.pojoSt.StIntakeAmountYear; | 
 |  |  | import com.dy.pipIrrGlobal.voSt.VoIntake; | 
 |  |  | import com.dy.pipIrrGlobal.voTmp.VoRmIntakeAmountDay; | 
 |  |  | import com.dy.pipIrrTemp.util.StClientAmountConstant; | 
 |  |  | import lombok.extern.slf4j.Slf4j; | 
 |  |  | import org.springframework.beans.factory.annotation.Autowired; | 
 |  |  | 
 |  |  |      * 删除所有取水口日取水量统计 | 
 |  |  |      * @throws Exception | 
 |  |  |      */ | 
 |  |  |     //@Transactional | 
 |  |  |     //public void deleteAllIntakeAmountDay(){ | 
 |  |  |     //    dao.deleteAllIntakeAmountDay(); | 
 |  |  |     //} | 
 |  |  |     /** | 
 |  |  |      * 删除一些取水口日取水量统计 | 
 |  |  |      * @throws Exception | 
 |  |  |      */ | 
 |  |  |     @Transactional | 
 |  |  |     public void deleteAllIntakeAmountDay(){ | 
 |  |  |         dao.deleteAllIntakeAmountDay(); | 
 |  |  |     public void deleteSomeIntakeAmountDay(){ | 
 |  |  |         dao.deleteSomeIntakeAmountDay(); | 
 |  |  |     } | 
 |  |  |  | 
 |  |  |  | 
 |  |  |     /** | 
 |  |  |      * 统计取水口日取水量 | 
 |  |  | 
 |  |  |      */ | 
 |  |  |     public void statisticsIntakeAmountDay() throws Exception{ | 
 |  |  |         int nowYear = Integer.parseInt(DateTime.yyyy()) ; | 
 |  |  |         int nowMonth = Integer.parseInt(DateTime.mm()) ; | 
 |  |  |         int nowMonth = Integer.parseInt(DateTime.MM()) ; | 
 |  |  |         int nowDay = Integer.parseInt(DateTime.dd()) ; | 
 |  |  |         Date startDt ; | 
 |  |  |         Date endDt ; | 
 |  |  |         List<RmIntakeAmountDay> list ; | 
 |  |  |         List<VoRmIntakeAmountDay> list ; | 
 |  |  |         boolean stop = false ; | 
 |  |  |         for(int[] ym : StClientAmountConstant.yearMonthGrp) { | 
 |  |  |             int[] dates = DateTime.dayGrpInMonth(ym[0], ym[1]); | 
 |  |  | 
 |  |  |                 } | 
 |  |  |                 if(!stop){ | 
 |  |  |                     startDt = DateTime.dateFrom_yyyy_MM_dd_HH_mm_ss(ym[0] + "-" + ym[1] + "-" + day + " 00:00:00") ; | 
 |  |  |                     endDt = DateTime.dateFrom_yyyy_MM_dd(ym[0] + "-" + ym[1] + "-" + day + " 23:59:59") ; | 
 |  |  |                     endDt = DateTime.dateFrom_yyyy_MM_dd_HH_mm_ss(ym[0] + "-" + ym[1] + "-" + day + " 23:59:59") ; | 
 |  |  |                     list = dao.statisticAllIntakeAmountDayFromOpenCloseValveHistory(startDt, endDt) ; | 
 |  |  |                     this.doStatisticsIntakeAmountDay(ym[0], ym[1], day, list) ; | 
 |  |  |                 }else{ | 
 |  |  | 
 |  |  |         } | 
 |  |  |     } | 
 |  |  |     @Transactional | 
 |  |  |     protected void doStatisticsIntakeAmountDay(int year, int month, int day, List<RmIntakeAmountDay> list) throws Exception{ | 
 |  |  |     protected void doStatisticsIntakeAmountDay(int year, int month, int day, List<VoRmIntakeAmountDay> list) throws Exception{ | 
 |  |  |         if(list != null && list.size() > 0){ | 
 |  |  |             Date date = DateTime.dateFrom_yyyy_MM_dd(year + "-" + month + "-" + day) ; | 
 |  |  |             for(RmIntakeAmountDay po : list){ | 
 |  |  |                 dao.updateOneIntakeAmountDay1(po.intakeId, date, po.amount, po.money, po.times); | 
 |  |  |             for(VoRmIntakeAmountDay vo : list){ | 
 |  |  |                 dao.updateOneIntakeAmountDay1(vo.intakeId, date, vo.amount, vo.money, vo.times); | 
 |  |  |             } | 
 |  |  |         } | 
 |  |  |     } | 
 |  |  | 
 |  |  |      */ | 
 |  |  |     public void statisticsIntakeAmountMonth() throws Exception{ | 
 |  |  |         int nowYear = Integer.parseInt(DateTime.yyyy()) ; | 
 |  |  |         int nowMonth = Integer.parseInt(DateTime.mm()) ; | 
 |  |  |         int nowMonth = Integer.parseInt(DateTime.MM()) ; | 
 |  |  |         Date startDt ; | 
 |  |  |         Date endDt ; | 
 |  |  |         List<StIntakeAmountMonth> list ; |