From bee0055f9d33ec0e8cd307c7b087e64f96f7a750 Mon Sep 17 00:00:00 2001
From: liurunyu <lry9898@163.com>
Date: 星期四, 26 十二月 2024 18:43:36 +0800
Subject: [PATCH] 1、一个springboot模块只能有一个listener，所以删除OrgListener.java 2、IC卡充值和消费日、月、年自动化统计,农户充值和消费日、月、年自动化统计中数据库查询一般返回list的bug修改

---
 pipIrr-platform/pipIrr-web/pipIrr-web-statistics/src/main/java/com/dy/pipIrrStatistics/statistics/StatisticsJob.java |   84 +++++++++++++++++++++++++-----------------
 1 files changed, 50 insertions(+), 34 deletions(-)

diff --git a/pipIrr-platform/pipIrr-web/pipIrr-web-statistics/src/main/java/com/dy/pipIrrStatistics/statistics/StatisticsJob.java b/pipIrr-platform/pipIrr-web/pipIrr-web-statistics/src/main/java/com/dy/pipIrrStatistics/statistics/StatisticsJob.java
index 9f82f04..ce95708 100644
--- a/pipIrr-platform/pipIrr-web/pipIrr-web-statistics/src/main/java/com/dy/pipIrrStatistics/statistics/StatisticsJob.java
+++ b/pipIrr-platform/pipIrr-web/pipIrr-web-statistics/src/main/java/com/dy/pipIrrStatistics/statistics/StatisticsJob.java
@@ -9,6 +9,7 @@
 import com.dy.pipIrrGlobal.util.Org;
 import org.apache.logging.log4j.LogManager;
 import org.apache.logging.log4j.Logger;
+import org.quartz.JobDataMap;
 import org.quartz.JobExecutionContext;
 import org.quartz.JobExecutionException;
 
@@ -24,6 +25,8 @@
 
     private static Logger log = LogManager.getLogger(Test.class.getName()) ;
 
+    private String orgTag ;
+
     private StLoss stLoss ;
     private StIntake stIntake ;
     private StClient stClient ;
@@ -35,13 +38,25 @@
     private Integer statisticsYear;
     private Integer statisticsMonth;
     private Integer statisticsDay;
-    private Long statisticsStartId ;
-    private Long statisticsEndId ;
-    private Date statisticsStartDt ;
-    private Date statisticsEndDt ;
+    private Long statistics4DayStartId ;
+    private Long statistics4DayEndId ;
+    private Date statistics4DayStartDt ;
+    private Date statistics4DayEndDt ;
+    private Long statistics4MonthYearStartId ;
+    private Long statistics4MonthYearEndId ;
+    //private Date statistics4MonthYearStartDt ;
+    //private Date statistics4MonthYearEndDt ;
+
 
     @Override
     public void execute(JobExecutionContext ctx) throws JobExecutionException {
+        JobDataMap jobDataMap = ctx.getJobDetail().getJobDataMap() ;
+        if(jobDataMap != null){
+            orgTag = (String)jobDataMap.get(StatisticsListener.orgKey) ;
+        }
+        if(orgTag == null){
+            return ;
+        }
         stLoss = SpringContextUtil.getBean(StLoss.class);
         stIntake = SpringContextUtil.getBean(StIntake.class);
         stClient = SpringContextUtil.getBean(StClient.class);
@@ -57,10 +72,10 @@
             statisticsYear = yesterdayGrp[0] ;//缁熻骞�
             statisticsMonth = yesterdayGrp[1] ;//缁熻鏈�
             statisticsDay = yesterdayGrp[2] ;//缁熻鏃�
-            statisticsStartId = IDLongGenerator.generateOneDayStartId(statisticsYear, statisticsMonth, 1) ;
-            statisticsEndId = IDLongGenerator.generateOneDayEndId(statisticsYear, statisticsMonth, DateTime.endDayOfMonth(statisticsYear, statisticsMonth)) ;
-            statisticsStartDt = DateTime.startOfDay(statisticsYear, statisticsMonth, statisticsDay) ;
-            statisticsEndDt = DateTime.endOfDay(statisticsYear, statisticsMonth, statisticsDay) ;
+            statistics4DayStartId = IDLongGenerator.generateOneDayStartId(statisticsYear, statisticsMonth, 1) ;
+            statistics4DayEndId = IDLongGenerator.generateOneDayEndId(statisticsYear, statisticsMonth, DateTime.endDayOfMonth(statisticsYear, statisticsMonth)) ;
+            statistics4DayStartDt = DateTime.startOfDay(statisticsYear, statisticsMonth, statisticsDay) ;
+            statistics4DayEndDt = DateTime.endOfDay(statisticsYear, statisticsMonth, statisticsDay) ;
             //缁熻鏃ョ殑閲�
             doStatisticsDay() ;
 
@@ -70,18 +85,18 @@
                 String statisticsYyyy_mm = DateTime.lastMonth_ym() ; //缁熻骞存湀
                 statisticsYear = Integer.parseInt(statisticsYyyy_mm.substring(0, 4)) ;//缁熻骞�
                 statisticsMonth = Integer.parseInt(statisticsYyyy_mm.substring(5, 7)) ;//缁熻鏈�
-                statisticsStartId = IDLongGenerator.generateOneDayStartId(statisticsYear, statisticsMonth, 1) ;
-                statisticsEndId = IDLongGenerator.generateOneDayEndId(statisticsYear, statisticsMonth, DateTime.endDayOfMonth(statisticsYear, statisticsMonth)) ;
-                statisticsStartDt = DateTime.startOfDay(statisticsYear, statisticsMonth, 1) ;
-                statisticsEndDt = DateTime.endOfDay(statisticsYear, statisticsMonth, DateTime.endDayOfMonth(statisticsYear, statisticsMonth)) ;
+                statistics4MonthYearStartId = IDLongGenerator.generateOneDayStartId(statisticsYear, statisticsMonth, 1) ;
+                statistics4MonthYearEndId = IDLongGenerator.generateOneDayEndId(statisticsYear, statisticsMonth, DateTime.endDayOfMonth(statisticsYear, statisticsMonth)) ;
+                //statistics4MonthYearStartDt = DateTime.startOfDay(statisticsYear, statisticsMonth, 1) ;
+                //statistics4MonthYearEndDt = DateTime.endOfDay(statisticsYear, statisticsMonth, DateTime.endDayOfMonth(statisticsYear, statisticsMonth)) ;
             }else{
                 //缁熻鏈湀鐨�
                 statisticsYear = ymd[0] ;//缁熻骞�
                 statisticsMonth =  ymd[1] ;//缁熻鏈�
-                statisticsStartId = IDLongGenerator.generateOneDayStartId(ymd[0], ymd[1], 1) ;
-                statisticsEndId = IDLongGenerator.generateOneDayEndId(ymd[0], ymd[1], DateTime.endDayOfMonth(statisticsYear, statisticsMonth)) ;
-                statisticsStartDt = DateTime.startOfDay(statisticsYear, statisticsMonth, 1) ;
-                statisticsEndDt = DateTime.endOfDay(statisticsYear, statisticsMonth, DateTime.endDayOfMonth(statisticsYear, statisticsMonth)) ;
+                statistics4MonthYearStartId = IDLongGenerator.generateOneDayStartId(ymd[0], ymd[1], 1) ;
+                statistics4MonthYearEndId = IDLongGenerator.generateOneDayEndId(ymd[0], ymd[1], DateTime.endDayOfMonth(statisticsYear, statisticsMonth)) ;
+                //statistics4MonthYearStartDt = DateTime.startOfDay(statisticsYear, statisticsMonth, 1) ;
+                //statistics4MonthYearEndDt = DateTime.endOfDay(statisticsYear, statisticsMonth, DateTime.endDayOfMonth(statisticsYear, statisticsMonth)) ;
             }
             doStatisticsMonthAndYear() ;
         }else{
@@ -93,34 +108,35 @@
      * 缁熻
      */
     private void doStatisticsDay(){
+        /*
         List<Org.OrgVo> orgList = Org.OrgList ;
         if(orgList != null && orgList.size() >0){
             for(Org.OrgVo vo : orgList){
                 DataSourceContext.set(vo.tag);//璁剧疆鏁版嵁婧�
-                stChargeByIc.statistics4Day(statisticsYear, statisticsMonth, statisticsDay, statisticsStartId, statisticsEndId);
-                stChargeByClient.statistics4Day(statisticsYear, statisticsMonth, statisticsDay, statisticsStartId, statisticsEndId);
-                stConsumeByIc.statistics4Day(statisticsYear, statisticsMonth, statisticsDay, statisticsStartDt, statisticsEndDt);
-                stConsumeByClient.statistics4Day(statisticsYear, statisticsMonth, statisticsDay, statisticsStartDt, statisticsEndDt);
+                stChargeByIc.statistics4Day(statisticsYear, statisticsMonth, statisticsDay, statistics4DayStartId, statistics4DayEndId);
+                stChargeByClient.statistics4Day(statisticsYear, statisticsMonth, statisticsDay, statistics4DayStartId, statistics4DayEndId);
+                stConsumeByIc.statistics4Day(statisticsYear, statisticsMonth, statisticsDay, statistics4DayStartDt, statistics4DayEndDt);
+                stConsumeByClient.statistics4Day(statisticsYear, statisticsMonth, statisticsDay, statistics4DayStartDt, statistics4DayEndDt);
             }
-        }
+        } */
+        DataSourceContext.set(orgTag);//璁剧疆鏁版嵁婧�
+        stChargeByIc.statistics4Day(statisticsYear, statisticsMonth, statisticsDay, statistics4DayStartId, statistics4DayEndId);
+        stChargeByClient.statistics4Day(statisticsYear, statisticsMonth, statisticsDay, statistics4DayStartId, statistics4DayEndId);
+        stConsumeByIc.statistics4Day(statisticsYear, statisticsMonth, statisticsDay, statistics4DayStartDt, statistics4DayEndDt);
+        stConsumeByClient.statistics4Day(statisticsYear, statisticsMonth, statisticsDay, statistics4DayStartDt, statistics4DayEndDt);
     }
     /**
      * 缁熻
      */
     private void doStatisticsMonthAndYear(){
-        List<Org.OrgVo> orgList = Org.OrgList ;
-        if(orgList != null && orgList.size() >0){
-            for(Org.OrgVo vo : orgList){
-                DataSourceContext.set(vo.tag);//璁剧疆鏁版嵁婧�
-                stLoss.statistics(statisticsYear, statisticsMonth, statisticsStartId, statisticsEndId) ;
-                stIntake.statistics(statisticsYear, statisticsMonth, statisticsStartId, statisticsEndId) ;
-                stClient.statistics(statisticsYear, statisticsMonth, statisticsStartId, statisticsEndId) ;
+        DataSourceContext.set(orgTag);//璁剧疆鏁版嵁婧�
+        stLoss.statistics(statisticsYear, statisticsMonth, statistics4MonthYearStartId, statistics4MonthYearEndId) ;
+        stIntake.statistics(statisticsYear, statisticsMonth, statistics4MonthYearStartId, statistics4MonthYearEndId) ;
+        stClient.statistics(statisticsYear, statisticsMonth, statistics4MonthYearStartId, statistics4MonthYearEndId) ;
 
-                stChargeByIc.statistics4MonthAndYear(statisticsYear, statisticsMonth);
-                stChargeByClient.statistics4MonthAndYear(statisticsYear, statisticsMonth);
-                stConsumeByIc.statistics4MonthAndYear(statisticsYear, statisticsMonth);
-                stConsumeByClient.statistics4MonthAndYear(statisticsYear, statisticsMonth);
-            }
-        }
+        stChargeByIc.statistics4MonthAndYear(statisticsYear, statisticsMonth);
+        stChargeByClient.statistics4MonthAndYear(statisticsYear, statisticsMonth);
+        stConsumeByIc.statistics4MonthAndYear(statisticsYear, statisticsMonth);
+        stConsumeByClient.statistics4MonthAndYear(statisticsYear, statisticsMonth);
     }
 }

--
Gitblit v1.8.0