增加日志

src/main/java/com/entity/jpa/BaseRepositoryEntry.java

@@ -20,6 +20,8 @@ import java.sql.Timestamp;
 @Data
 public class BaseRepositoryEntry implements Serializable {
 
+    private static final long serialVersionUID = 6428836373638907908L;
+
     @Column(name = "create_at")
     private Timestamp createdAt;
     @Column(name = "update_at")

src/main/java/com/service/statistics/impl/BaiHangReportAndSearchNum.java

@@ -8,6 +8,7 @@ import com.jpa.repository.QueryStatisticsRepository;
 import com.mapper.report.BaiHangMapper;
 import com.service.statistics.GetReportAndSearchNum;
 import com.util.DateUtil;
+import lombok.extern.slf4j.Slf4j;
 import org.springframework.stereotype.Service;
 
 import javax.annotation.Resource;
@@ -24,6 +25,7 @@ import java.util.stream.Collectors;
  * @modified By：
  * @version: 1.0
  */
+@Slf4j
 @Service
 public class BaiHangReportAndSearchNum implements GetReportAndSearchNum {
 
@@ -41,7 +43,7 @@ public class BaiHangReportAndSearchNum implements GetReportAndSearchNum {
 
     @Override
     public List<QueryStatisticsEntry> getByDate(Date date) {
-
+        log.info("百行上报查询余量统计开始,date:{} ",date);
         Date start = DateUtil.getDate(date, DateUtil.YYYY_MM_DD);
 
         Calendar calendar = Calendar.getInstance();
@@ -101,6 +103,7 @@ public class BaiHangReportAndSearchNum implements GetReportAndSearchNum {
                 zxlm.setMaxQueryNum(sum * 10);
             }
         });
+        log.info("百行上报查询余量统计结束,date:{} ,zxlm: {} ,gdxd: {} ",date,zxlm,gdxd);
 
         return Lists.newArrayList(zxlm, gdxd);
     }

src/main/java/com/service/statistics/impl/QueryStatisticsServiceImpl.java

@@ -71,7 +71,8 @@ public class QueryStatisticsServiceImpl implements QueryStatisticsService {
             List<QueryStatisticsEntry> byDate = v.getByDate(time);
             //查询本日有没有
             List<QueryStatisticsEntry> byReportTime = queryStatisticsRepository
-                    .findByReportTimeAndDataSource(new Timestamp(DateUtil.getDate(time,DateUtil.YYYY_MM_DD).getTime()), v.getDataSource());
+                    .findByReportTimeAndDataSource(new Timestamp(DateUtil.getDate(time,DateUtil.YYYY_MM_DD).getTime()),
+                            v.getDataSource());
 
             byDate.stream().forEach(o -> {
 
@@ -79,7 +80,7 @@ public class QueryStatisticsServiceImpl implements QueryStatisticsService {
                     if (o.getCorporation() == q.getCorporation()) {
                         o.setId(q.getId());
                         o.setCreatedAt(q.getCreatedAt());
-                        o.setUpdatedAt(q.getUpdatedAt());
+                        o.setUpdatedAt(new Timestamp(System.currentTimeMillis()));
                     }
                 });
 

src/main/java/com/service/statistics/impl/ZhjReportAndSearchNum.java

@@ -11,6 +11,7 @@ import com.mapper.report.ZhjMapper;
 import com.service.report.ReportService;
 import com.service.statistics.GetReportAndSearchNum;
 import com.util.DateUtil;
+import lombok.extern.slf4j.Slf4j;
 import org.springframework.stereotype.Service;
 
 import javax.annotation.Resource;
@@ -27,6 +28,7 @@ import java.util.stream.Collectors;
  * @modified By：
  * @version: 1.0
  */
+@Slf4j
 @Service
 public class ZhjReportAndSearchNum implements GetReportAndSearchNum {
 
@@ -39,6 +41,7 @@ public class ZhjReportAndSearchNum implements GetReportAndSearchNum {
 
     @Override
     public List<QueryStatisticsEntry> getByDate(Date date) {
+        log.info("中互金上报查询余量统计开始,date:{} ",date);
 
         Date start = DateUtil.getDate(date, DateUtil.YYYY_MM_DD);
 
@@ -92,6 +95,7 @@ public class ZhjReportAndSearchNum implements GetReportAndSearchNum {
 
             });
         }
+        log.info("百行上报查询余量统计结束,date:{} , gdxd: {} ", date, entry);
         return Lists.newArrayList(entry);
     }
 

src/main/java/com/timer/QueryStatisticsTimer.java

@@ -4,6 +4,7 @@ import cn.quantgroup.tech.elastic.job.lite.annotation.ElasticSimpleJob;
 import com.dangdang.ddframe.job.api.ShardingContext;
 import com.dangdang.ddframe.job.api.simple.SimpleJob;
 import com.service.statistics.QueryStatisticsService;
+import lombok.extern.slf4j.Slf4j;
 import org.springframework.stereotype.Component;
 
 import javax.annotation.Resource;
@@ -15,9 +16,9 @@ import java.util.Calendar;
  * @description：统计定时器
  * @modified By：
  * @version: 1.0
- *每天凌晨泡一下
+ *每天凌晨跑一下
  */
-
+@Slf4j
 @Component
 @ElasticSimpleJob(cron = "0  1  0  *  * ?", jobName = "QueryStatisticsTimer")
 public class QueryStatisticsTimer implements SimpleJob {
@@ -28,6 +29,7 @@ public class QueryStatisticsTimer implements SimpleJob {
 
     @Override
     public void execute(ShardingContext shardingContext) {
+        log.info("开始统计数据源查询量");
         Calendar calendar = Calendar.getInstance();
 
         calendar.add(Calendar.DATE, -1);