From 8796f34f80c0d96148637cc179d914f73c779a21 Mon Sep 17 00:00:00 2001
From: wxz <wangxianzhang1992@163.com>
Date: Thu, 18 Jun 2020 18:27:11 +0800
Subject: [PATCH] =?UTF-8?q?1.=E6=96=B0=E5=A2=9E=E5=B9=B4=E7=BB=B4=E5=BA=A6?=
 =?UTF-8?q?=E5=92=8C=E5=AD=A3=E7=BB=B4=E5=BA=A6?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../com/epmet/controller/DimController.java   | 18 ++++-
 .../service/impl/StatsDimServiceImpl.java     | 47 +++++++-----
 .../epmet/service/stats/DimYearService.java   |  3 +
 .../stats/impl/DimDateServiceImpl.java        | 46 ++++++++----
 .../stats/impl/DimMonthServiceImpl.java       | 58 ++++++++-------
 .../stats/impl/DimQuarterServiceImpl.java     | 29 +++++---
 .../stats/impl/DimYearServiceImpl.java        | 73 +++++++++++++++++++
 7 files changed, 200 insertions(+), 74 deletions(-)

diff --git a/epmet-module/data-statistical/data-statistical-server/src/main/java/com/epmet/controller/DimController.java b/epmet-module/data-statistical/data-statistical-server/src/main/java/com/epmet/controller/DimController.java
index 764c960452..0964efb49f 100644
--- a/epmet-module/data-statistical/data-statistical-server/src/main/java/com/epmet/controller/DimController.java
+++ b/epmet-module/data-statistical/data-statistical-server/src/main/java/com/epmet/controller/DimController.java
@@ -3,10 +3,7 @@ package com.epmet.controller;
 import com.epmet.commons.tools.utils.Result;
 import com.epmet.dto.AgencySubTreeDto;
 import com.epmet.service.StatsDimService;
-import com.epmet.service.stats.DimAgencyService;
-import com.epmet.service.stats.DimDateService;
-import com.epmet.service.stats.DimMonthService;
-import com.epmet.service.stats.DimQuarterService;
+import com.epmet.service.stats.*;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.web.bind.annotation.GetMapping;
 import org.springframework.web.bind.annotation.PostMapping;
@@ -28,6 +25,9 @@ public class DimController {
     @Autowired
     private DimQuarterService quarterService;
 
+    @Autowired
+    private DimYearService dimYearService;
+
     @Autowired
     private StatsDimService statsDimService;
 
@@ -104,6 +104,16 @@ public class DimController {
         return new Result();
     }
 
+    /**
+     * 年度维度
+     * @return
+     */
+    @PostMapping("/year/init")
+    public Result initYearDim() {
+        dimYearService.initYearDim();
+        return new Result();
+    }
+
     /**
      * @Description 所有机构
      * @param
diff --git a/epmet-module/data-statistical/data-statistical-server/src/main/java/com/epmet/service/impl/StatsDimServiceImpl.java b/epmet-module/data-statistical/data-statistical-server/src/main/java/com/epmet/service/impl/StatsDimServiceImpl.java
index 7d79ead2cf..d4b435a6d8 100644
--- a/epmet-module/data-statistical/data-statistical-server/src/main/java/com/epmet/service/impl/StatsDimServiceImpl.java
+++ b/epmet-module/data-statistical/data-statistical-server/src/main/java/com/epmet/service/impl/StatsDimServiceImpl.java
@@ -16,6 +16,7 @@ import com.epmet.service.org.CustomerGridService;
 import com.epmet.service.stats.*;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
+import org.springframework.util.CollectionUtils;
 
 import java.util.Date;
 import java.util.List;
@@ -53,6 +54,11 @@ public class StatsDimServiceImpl implements StatsDimService {
 
     @Override
     public void initGridDim() {
+        LastExecRecordEntity lastExecRecord = lastExecRecordService.getLastExecRecord(StatsSubject.DIM_GRID);
+        if (lastExecRecord == null) {
+            lastExecRecord = lastExecRecordService.createLastExecRecord(StatsSubject.DIM_GRID);
+        }
+
         DimGridEntity lastCreatedGridDim = dimGridService.getLastCreatedGridDim();
         List<CustomerGridEntity> grids;
         if (lastCreatedGridDim == null) {
@@ -68,7 +74,11 @@ public class StatsDimServiceImpl implements StatsDimService {
         }
 
         List<DimGridEntity> gridDims = convertCustomerGrid2GridDim(grids);
-        dimGridService.addGridDims(gridDims);
+        if (!CollectionUtils.isEmpty(gridDims)) {
+            dimGridService.addGridDims(gridDims);
+            lastExecRecord.setExecTime(new Date());
+            lastExecRecordService.updateById(lastExecRecord);
+        }
     }
 
     /**
@@ -112,11 +122,13 @@ public class StatsDimServiceImpl implements StatsDimService {
         }
 
         List<CustomerAgencyEntity> agencies = customerAgencyService.listAgenciesByCreateTime(statsStartTime, statsEndTime);
-        dimAgencyService.addAgencyDims(agencies);
-        lastExecRecord.setExecTime(new Date());
+        if (!CollectionUtils.isEmpty(agencies)) {
+            dimAgencyService.addAgencyDims(agencies);
+            lastExecRecord.setExecTime(new Date());
 
-        // 记录最后一次统计时间
-        lastExecRecordService.updateById(lastExecRecord);
+            // 记录最后一次统计时间
+            lastExecRecordService.updateById(lastExecRecord);
+        }
     }
 
     /**
@@ -136,12 +148,14 @@ public class StatsDimServiceImpl implements StatsDimService {
         }
 
         List<CustomerEntity> customers = customerService.listValidCustomersByCreateTime(statsStartTime, statsEndTime);
-        dimCustomerService.addCustomerDims(customers);
+        if (!CollectionUtils.isEmpty(customers)) {
+            dimCustomerService.addCustomerDims(customers);
 
-        lastExecRecord.setExecTime(new Date());
+            lastExecRecord.setExecTime(new Date());
 
-        // 记录最后一次统计时间
-        lastExecRecordService.updateById(lastExecRecord);
+            // 记录最后一次统计时间
+            lastExecRecordService.updateById(lastExecRecord);
+        }
     }
 
     @Override
@@ -158,14 +172,11 @@ public class StatsDimServiceImpl implements StatsDimService {
         }
 
         List<CustomerDepartmentEntity> departments = departmentService.listDepartmentsByCreatedTime(statsStartTime, statsEndTime);
-
-        dimDepartmentService.addDepartmentDims(departments);
-
-        lastExecRecord.setExecTime(new Date());
-
-        // 记录最后一次统计时间
-        lastExecRecordService.updateById(lastExecRecord);
-
+        if (!CollectionUtils.isEmpty(departments)) {
+            dimDepartmentService.addDepartmentDims(departments);
+            lastExecRecord.setExecTime(new Date());
+            // 记录最后一次统计时间
+            lastExecRecordService.updateById(lastExecRecord);
+        }
     }
-
 }
diff --git a/epmet-module/data-statistical/data-statistical-server/src/main/java/com/epmet/service/stats/DimYearService.java b/epmet-module/data-statistical/data-statistical-server/src/main/java/com/epmet/service/stats/DimYearService.java
index 516317f48a..ed840f7636 100644
--- a/epmet-module/data-statistical/data-statistical-server/src/main/java/com/epmet/service/stats/DimYearService.java
+++ b/epmet-module/data-statistical/data-statistical-server/src/main/java/com/epmet/service/stats/DimYearService.java
@@ -92,4 +92,7 @@ public interface DimYearService extends BaseService<DimYearEntity> {
      * @date 2020-06-16
      */
     void delete(String[] ids);
+
+
+    void initYearDim();
 }
\ No newline at end of file
diff --git a/epmet-module/data-statistical/data-statistical-server/src/main/java/com/epmet/service/stats/impl/DimDateServiceImpl.java b/epmet-module/data-statistical/data-statistical-server/src/main/java/com/epmet/service/stats/impl/DimDateServiceImpl.java
index 102111c92e..9f6281c20b 100644
--- a/epmet-module/data-statistical/data-statistical-server/src/main/java/com/epmet/service/stats/impl/DimDateServiceImpl.java
+++ b/epmet-module/data-statistical/data-statistical-server/src/main/java/com/epmet/service/stats/impl/DimDateServiceImpl.java
@@ -24,12 +24,17 @@ import com.epmet.commons.tools.page.PageData;
 import com.epmet.commons.tools.utils.ConvertUtils;
 import com.epmet.commons.tools.constant.FieldConstant;
 import com.epmet.commons.tools.utils.DateUtils;
+import com.epmet.constant.StatsSubject;
 import com.epmet.dao.stats.DimDateDao;
 import com.epmet.dto.stats.DimDateDTO;
 import com.epmet.entity.stats.DimDateEntity;
+import com.epmet.entity.stats.LastExecRecordEntity;
 import com.epmet.service.stats.DimDateService;
+import com.epmet.service.stats.LastExecRecordService;
 import com.epmet.util.DimIdGenerator;
 import org.apache.commons.lang3.StringUtils;
+import org.joda.time.LocalDate;
+import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
 import org.springframework.transaction.annotation.Transactional;
 
@@ -44,6 +49,9 @@ import java.util.*;
 @Service
 public class DimDateServiceImpl extends BaseServiceImpl<DimDateDao, DimDateEntity> implements DimDateService {
 
+    @Autowired
+    private LastExecRecordService lastExecRecordService;
+
     @Override
     public PageData<DimDateDTO> page(Map<String, Object> params) {
         IPage<DimDateEntity> page = baseDao.selectPage(
@@ -109,32 +117,44 @@ public class DimDateServiceImpl extends BaseServiceImpl<DimDateDao, DimDateEntit
 
     @Override
     public void initDimDate() {
-        DimDateDTO latestDimDateDto = baseDao.getLatestDimDate();
+        LastExecRecordEntity lastExecRecord = lastExecRecordService.getLastExecRecord(StatsSubject.DIM_DATE);
+        if (lastExecRecord == null) {
+            lastExecRecord = lastExecRecordService.createLastExecRecord(StatsSubject.DIM_DATE);
+        }
+
+        Date now = new Date();
 
         Date targetDate = DateUtils.addDateDays(DateUtils.parse(
-                DateUtils.format(new Date(), DateUtils.DATE_PATTERN_YYYYMMDD),
+                DateUtils.format(now, DateUtils.DATE_PATTERN_YYYYMMDD),
                 DateUtils.DATE_PATTERN_YYYYMMDD), -1);
 
-        Date lastDimDate;
+        Date lastDimDate = null;
 
-        if (latestDimDateDto == null) {
-            // 没有维度数据
+        if ((lastDimDate = lastExecRecord.getExecTime()) == null) {
+            // 首次初始化按日维度
             initDimDate(targetDate);
-        } else if(targetDate.after(lastDimDate = DateUtils.parse(latestDimDateDto.getId(), DateUtils.DATE_PATTERN_YYYYMMDD))) {
-            // 有维度数据，并且当前日期大于最大按日维度数据的id，需要连续生成至少一天的维度数据(补缺)
-            initDimDate(lastDimDate, targetDate);
+            lastExecRecord.setExecTime(now);
+            lastExecRecordService.updateById(lastExecRecord);
+        } else {
+            if (targetDate.equals(lastDimDate) || targetDate.after(lastDimDate)) {
+                initDimDate(lastDimDate, targetDate);
+                lastExecRecord.setExecTime(now);
+                lastExecRecordService.updateById(lastExecRecord);
+            }
         }
     }
 
     /**
      * 连续初始化
-     * @param lastDimDate
+     * @param startDate
      * @param targetDate
      */
-    private void initDimDate(Date lastDimDate, Date targetDate) {
-        while (lastDimDate.before(targetDate)) {
-            lastDimDate = DateUtils.addDateDays(lastDimDate, 1);
-            initDimDate(lastDimDate);
+    private void initDimDate(Date startDate, Date targetDate) {
+        LocalDate localStartDate = new LocalDate(startDate);
+        LocalDate localTargetDate = new LocalDate(targetDate);
+        while (localTargetDate.isEqual(localStartDate) || localTargetDate.isAfter(localStartDate)) {
+            initDimDate(localStartDate.toDate());
+            localStartDate = localStartDate.plusDays(1);
         }
     }
 
diff --git a/epmet-module/data-statistical/data-statistical-server/src/main/java/com/epmet/service/stats/impl/DimMonthServiceImpl.java b/epmet-module/data-statistical/data-statistical-server/src/main/java/com/epmet/service/stats/impl/DimMonthServiceImpl.java
index 8ebb21a439..1f09b868e9 100644
--- a/epmet-module/data-statistical/data-statistical-server/src/main/java/com/epmet/service/stats/impl/DimMonthServiceImpl.java
+++ b/epmet-module/data-statistical/data-statistical-server/src/main/java/com/epmet/service/stats/impl/DimMonthServiceImpl.java
@@ -34,6 +34,7 @@ import com.epmet.service.stats.LastExecRecordService;
 import com.epmet.util.DimIdGenerator;
 import org.apache.commons.lang3.StringUtils;
 import org.joda.time.LocalDate;
+import org.joda.time.LocalTime;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
 import org.springframework.transaction.annotation.Transactional;
@@ -116,52 +117,55 @@ public class DimMonthServiceImpl extends BaseServiceImpl<DimMonthDao, DimMonthEn
         }
 
         Date now = new Date();
-        String startTime;
-        String endTime = DateUtils.format(now, DateUtils.DATE_PATTERN_YYYYMM);
+        Date startMonth;
+        Date targetMonth = DateUtils.addDateMonths(DateUtils.integrate(now, DateUtils.DATE_PATTERN_YYYYMM), -1);
 
         if (lastExecRecord.getExecTime() == null) {
-            Date targetDate = new LocalDate(now).minusMonths(1).toDate();
-            initMonthDim(DateUtils.format(targetDate, DateUtils.DATE_PATTERN_YYYYMM));
+            initMonthDim(targetMonth);
+            lastExecRecord.setExecTime(now);
+            lastExecRecordService.updateById(lastExecRecord);
         } else {
-            startTime = DateUtils.format(lastExecRecord.getExecTime(), DateUtils.DATE_PATTERN_YYYYMM);
-            initMonthDims(startTime, endTime);
+            startMonth = DateUtils.integrate(lastExecRecord.getExecTime(), DateUtils.DATE_PATTERN_YYYYMM);
+            if (targetMonth.equals(startMonth) || targetMonth.after(startMonth)) {
+                initMonthDims(startMonth, targetMonth);
+                lastExecRecord.setExecTime(now);
+                lastExecRecordService.updateById(lastExecRecord);
+            }
         }
-
-        lastExecRecord.setExecTime(new Date());
-
-        // 记录最后一次统计时间
-        lastExecRecordService.updateById(lastExecRecord);
-
     }
 
-    public void initMonthDims(String startMonthStr, String endMonthStr) {
-        Integer startMonthInt = Integer.valueOf(startMonthStr);
-        Integer endMonthInt = Integer.valueOf(endMonthStr);
-        while(startMonthInt < endMonthInt) {
-            initMonthDim(startMonthInt + "");
-            ++ startMonthInt;
+    /**
+     * 按月维度连续生成
+     * @param startMonth
+     * @param targetMonth
+     */
+    public void initMonthDims(Date startMonth, Date targetMonth) {
+        LocalDate localstartMonth = new LocalDate(startMonth);
+        LocalDate localTargetMonth = new LocalDate(targetMonth);
+        while(localTargetMonth.isEqual(localstartMonth) || localTargetMonth.isAfter(localstartMonth)) {
+            initMonthDim(localstartMonth.toDate());
+            localstartMonth = localstartMonth.plusMonths(1);
         }
     }
 
-    public void initMonthDim(String startMonthStr) {
+    public void initMonthDim(Date targetMonth) {
         Date now = new Date();
-        Date startDate = DateUtils.stringToDate( startMonthStr, DateUtils.DATE_PATTERN_YYYYMM);
-        Date endDate = DateUtils.addDateDays(DateUtils.addDateMonths(startDate, 1), -1);
-        LocalDate localDate = new LocalDate(startDate);
+        Date endDate = DateUtils.addDateDays(DateUtils.addDateMonths(targetMonth, 1), -1);
+        LocalDate localDate = new LocalDate(targetMonth);
 
         DimMonthEntity dim = new DimMonthEntity();
-        dim.setStartDate(startDate);
+        dim.setStartDate(targetMonth);
         dim.setEndDate(endDate);
-        dim.setMonthName(DateUtils.format(startDate, DateUtils.MONTH_NAME_PATTERN));
-        dim.setMonthOrder(DateUtils.getMonthOfYear(startDate));
-        dim.setQuarterId(localDate.getYear() + "Q" + DateUtils.getQuarterIndex(startDate));
+        dim.setMonthName(DateUtils.format(targetMonth, DateUtils.MONTH_NAME_PATTERN));
+        dim.setMonthOrder(DateUtils.getMonthOfYear(targetMonth));
+        dim.setQuarterId(localDate.getYear() + "Q" + DateUtils.getQuarterIndex(targetMonth));
         dim.setYearId(localDate.getYear() + "");
         dim.setCreatedBy("APP_USER");
         dim.setUpdatedBy("APP_USER");
         dim.setCreatedTime(now);
         dim.setUpdatedTime(now);
         dim.setDelFlag("0");
-        dim.setId(DimIdGenerator.getMonthDimId(startDate));
+        dim.setId(DimIdGenerator.getMonthDimId(targetMonth));
         baseDao.insert(dim);
     }
 
diff --git a/epmet-module/data-statistical/data-statistical-server/src/main/java/com/epmet/service/stats/impl/DimQuarterServiceImpl.java b/epmet-module/data-statistical/data-statistical-server/src/main/java/com/epmet/service/stats/impl/DimQuarterServiceImpl.java
index 8d7a398aed..0b8bd424f4 100644
--- a/epmet-module/data-statistical/data-statistical-server/src/main/java/com/epmet/service/stats/impl/DimQuarterServiceImpl.java
+++ b/epmet-module/data-statistical/data-statistical-server/src/main/java/com/epmet/service/stats/impl/DimQuarterServiceImpl.java
@@ -32,6 +32,7 @@ import com.epmet.entity.stats.LastExecRecordEntity;
 import com.epmet.service.stats.DimQuarterService;
 import com.epmet.service.stats.LastExecRecordService;
 import com.epmet.util.DimIdGenerator;
+import com.sun.org.apache.xpath.internal.operations.Bool;
 import org.apache.commons.lang3.StringUtils;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
@@ -121,39 +122,43 @@ public class DimQuarterServiceImpl extends BaseServiceImpl<DimQuarterDao, DimQua
         //Date now = new Date();
         Date now = DateUtils.parse("20210430", DateUtils.DATE_PATTERN_YYYYMMDD);
 
-        Date targetQday;
-        Date startQday;
+        Date targetQuarter;
+        Date startQuarter;
 
-        targetQday = DateUtils.integrate(DateUtils.addDateMonths(now, -3), DateUtils.DATE_PATTERN_YYYYMM);
+        targetQuarter = DateUtils.integrate(DateUtils.addDateMonths(now, -3), DateUtils.DATE_PATTERN_YYYYMM);
 
         if (lastExecRecord.getExecTime() == null) {
             // 初始化上一个季度
-            initQuarterDim(targetQday);
+            initQuarterDim(targetQuarter);
+            lastExecRecord.setExecTime(new Date());
+            lastExecRecordService.updateById(lastExecRecord);
         } else {
             // 连续初始化多个季度
-            startQday = DateUtils.integrate(lastExecRecord.getExecTime(), DateUtils.DATE_PATTERN_YYYYMM);
-            initQuarterDim(startQday, targetQday);
+            startQuarter = DateUtils.integrate(lastExecRecord.getExecTime(), DateUtils.DATE_PATTERN_YYYYMM);
+            if (initQuarterDim(startQuarter, targetQuarter)) {
+                lastExecRecord.setExecTime(new Date());
+                lastExecRecordService.updateById(lastExecRecord);
+            }
         }
-
-        lastExecRecord.setExecTime(new Date());
-
-        // 记录最后一次统计时间
-        lastExecRecordService.updateById(lastExecRecord);
     }
 
     /**
      * 连续初始化多个季度维度数据
      * @param startQday
      * @param targetQday
+     * @return 是否产生新数据
      */
-    public void initQuarterDim(Date startQday, Date targetQday) {
+    public boolean initQuarterDim(Date startQday, Date targetQday) {
+        Boolean execed = false;
         Integer startQuarterIdx;
         Integer targetQuarterIdx;
         while ((startQuarterIdx = Integer.valueOf(DateUtils.format(startQday, DateUtils.DATE_PATTERN_YYYY) + DateUtils.getQuarterIndex(startQday)))
                 <= (targetQuarterIdx = Integer.valueOf(DateUtils.format(targetQday, DateUtils.DATE_PATTERN_YYYY) + DateUtils.getQuarterIndex(targetQday)))) {
             initQuarterDim(startQday);
             startQday = DateUtils.addDateMonths(startQday, 3);
+            execed = true;
         }
+        return execed;
     }
     /**
      * 初始化指定月份维度数据
diff --git a/epmet-module/data-statistical/data-statistical-server/src/main/java/com/epmet/service/stats/impl/DimYearServiceImpl.java b/epmet-module/data-statistical/data-statistical-server/src/main/java/com/epmet/service/stats/impl/DimYearServiceImpl.java
index 8c2b36ecf6..081f99b3f9 100644
--- a/epmet-module/data-statistical/data-statistical-server/src/main/java/com/epmet/service/stats/impl/DimYearServiceImpl.java
+++ b/epmet-module/data-statistical/data-statistical-server/src/main/java/com/epmet/service/stats/impl/DimYearServiceImpl.java
@@ -23,16 +23,22 @@ import com.epmet.commons.mybatis.service.impl.BaseServiceImpl;
 import com.epmet.commons.tools.page.PageData;
 import com.epmet.commons.tools.utils.ConvertUtils;
 import com.epmet.commons.tools.constant.FieldConstant;
+import com.epmet.commons.tools.utils.DateUtils;
+import com.epmet.constant.StatsSubject;
 import com.epmet.dao.stats.DimYearDao;
 import com.epmet.dto.stats.DimYearDTO;
 import com.epmet.entity.stats.DimYearEntity;
+import com.epmet.entity.stats.LastExecRecordEntity;
 import com.epmet.service.stats.DimYearService;
+import com.epmet.service.stats.LastExecRecordService;
 import org.apache.commons.lang3.StringUtils;
+import org.joda.time.LocalDate;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
 import org.springframework.transaction.annotation.Transactional;
 
 import java.util.Arrays;
+import java.util.Date;
 import java.util.List;
 import java.util.Map;
 
@@ -45,6 +51,9 @@ import java.util.Map;
 @Service
 public class DimYearServiceImpl extends BaseServiceImpl<DimYearDao, DimYearEntity> implements DimYearService {
 
+    @Autowired
+    private LastExecRecordService lastExecRecordService;
+
     @Override
     public PageData<DimYearDTO> page(Map<String, Object> params) {
         IPage<DimYearEntity> page = baseDao.selectPage(
@@ -97,4 +106,68 @@ public class DimYearServiceImpl extends BaseServiceImpl<DimYearDao, DimYearEntit
         baseDao.deleteBatchIds(Arrays.asList(ids));
     }
 
+    @Override
+    public void initYearDim() {
+        LastExecRecordEntity lastExecRecord = lastExecRecordService.getLastExecRecord(StatsSubject.DIM_YEAR);
+        if (lastExecRecord == null) {
+            lastExecRecord = lastExecRecordService.createLastExecRecord(StatsSubject.DIM_YEAR);
+        }
+
+        Date now = new Date();
+
+        Date startYear;
+        Date targetYear;
+
+        targetYear = DateUtils.integrate(DateUtils.addDateYears(now, -1), DateUtils.DATE_PATTERN_YYYY);
+        if (lastExecRecord.getExecTime() == null) {
+            // 第一次执行统计
+            initYearDim(targetYear);
+            lastExecRecord.setExecTime(now);
+            // 记录最后一次统计时间
+            lastExecRecordService.updateById(lastExecRecord);
+        } else {
+            startYear = DateUtils.integrate(lastExecRecord.getExecTime(), DateUtils.DATE_PATTERN_YYYY);
+            if (targetYear.equals(startYear) || targetYear.after(startYear)) {
+                initYearDims(startYear, targetYear);
+                lastExecRecord.setExecTime(now);
+                // 记录最后一次统计时间
+                lastExecRecordService.updateById(lastExecRecord);
+            }
+        }
+    }
+
+    /**
+     * 按年连续初始化
+     * @param startYear
+     * @param targetYear
+     */
+    private void initYearDims(Date startYear, Date targetYear) {
+        LocalDate localStartYear = new LocalDate(startYear);
+        LocalDate localTargetYear = new LocalDate(targetYear);
+        while (localStartYear.getYear() <= localTargetYear.getYear()) {
+            initYearDim(localStartYear.toDate());
+            localStartYear = localStartYear.plusYears(1);
+        }
+    }
+
+    /**
+     * 俺年单次统计
+     * @param targetYear
+     */
+    public void initYearDim(Date targetYear) {
+        String yyyy = DateUtils.format(targetYear, DateUtils.DATE_PATTERN_YYYY);
+        Date now = new Date();
+
+        DimYearEntity dim = new DimYearEntity();
+        dim.setId(yyyy);
+        dim.setYearName(yyyy.concat("年"));
+        //dim.setUpdatedTime(now);
+        //dim.setUpdatedBy("APP_USER");
+        //dim.setCreatedTime(now);
+        //dim.setCreatedBy("APP_USER");
+        //dim.setRevision(0);
+        //dim.setDelFlag("0");
+        baseDao.insert(dim);
+    }
+
 }
\ No newline at end of file