加入报表定时任务

service-job/src/main/java/com/java110/job/task/report/GenerateFeeMonthStatisticsTemplate.java

@@ -0,0 +1,54 @@
+package com.java110.job.task.report;
+
+import com.java110.dto.community.CommunityDto;
+import com.java110.dto.task.TaskDto;
+import com.java110.intf.report.IGeneratorFeeMonthStatisticsInnerServiceSMO;
+import com.java110.job.quartz.TaskSystemQuartz;
+import com.java110.po.reportFeeMonthStatistics.ReportFeeMonthStatisticsPo;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Component;
+
+import java.util.List;
+
+/**
+ * @ClassName GenerateOwnerBillTemplate
+ * @Description TODO  房屋费用账单生成
+ * @Author wuxw
+ * @Date 2020/6/4 8:33
+ * @Version 1.0
+ * add by wuxw 2020/6/4
+ **/
+@Component
+public class GenerateFeeMonthStatisticsTemplate extends TaskSystemQuartz {
+    private static final Logger logger = LoggerFactory.getLogger(GenerateFeeMonthStatisticsTemplate.class);
+
+    @Autowired
+    private IGeneratorFeeMonthStatisticsInnerServiceSMO generatorFeeMonthStatisticsInnerServiceSMOImpl;
+
+
+    @Override
+    protected void process(TaskDto taskDto) throws Exception {
+
+        // 获取小区
+        List<CommunityDto> communityDtos = getAllCommunity();
+
+        for (CommunityDto communityDto : communityDtos) {
+            try {
+                GenerateFeeMonthStatistic(taskDto, communityDto);
+            } catch (Exception e) {
+                logger.error("生成月报表 失败", e);
+            }
+        }
+
+    }
+
+    private void GenerateFeeMonthStatistic(TaskDto taskDto, CommunityDto communityDto) {
+        ReportFeeMonthStatisticsPo reportFeeMonthStatisticsPo = new ReportFeeMonthStatisticsPo();
+        reportFeeMonthStatisticsPo.setCommunityId(communityDto.getCommunityId());
+        generatorFeeMonthStatisticsInnerServiceSMOImpl.generatorData(reportFeeMonthStatisticsPo);
+    }
+
+
+}

service-report/src/main/java/com/java110/report/smo/impl/GeneratorFeeMonthStatisticsInnerServiceSMOImpl.java

@@ -21,6 +21,7 @@ import com.java110.utils.util.ListUtil;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.scheduling.annotation.Async;
 import org.springframework.web.bind.annotation.RequestBody;
 import org.springframework.web.bind.annotation.RestController;
 
@@ -59,6 +60,12 @@ public class GeneratorFeeMonthStatisticsInnerServiceSMOImpl implements IGenerato
     @Override
     public int generatorData(@RequestBody ReportFeeMonthStatisticsPo reportFeeMonthStatisticsPo) {
 
+        doGeneratorData(reportFeeMonthStatisticsPo);
+        return 0;
+    }
+
+    @Async
+    private void doGeneratorData(ReportFeeMonthStatisticsPo reportFeeMonthStatisticsPo) {
         String communityId = reportFeeMonthStatisticsPo.getCommunityId();
 
         Assert.hasLength(communityId, "未包含小区信息");
@@ -68,8 +75,6 @@ public class GeneratorFeeMonthStatisticsInnerServiceSMOImpl implements IGenerato
 
         //处理车位费用
         dealCarFee(reportFeeMonthStatisticsPo);
-
-        return 0;
     }
 
     /**