Commit 827f12a8 authored by hanfeng's avatar hanfeng

Merge branch 'master-order-statistics' into dev

parents e419fc79 776d3587
...@@ -47,25 +47,27 @@ public class BaseOrderStatisticsJobHandler extends IJobHandler { ...@@ -47,25 +47,27 @@ public class BaseOrderStatisticsJobHandler extends IJobHandler {
public ReturnT<String> execute(String date) { public ReturnT<String> execute(String date) {
try { try {
log.info("-----定时器进入---baseOrderStatisticsHandler---" + date);
XxlJobLogger.log("-----定时器进入---baseOrderStatisticsHandler---" + date);
ArrayList<Integer> arrayList = Lists.newArrayList(); ArrayList<Integer> arrayList = Lists.newArrayList();
if (StringUtils.isBlank(date)) { if (StringUtils.isBlank(date)) {
arrayList.add(day); arrayList.add(day);
} else { } else {
arrayList = dateDifferenceSet(date); arrayList = dateDifferenceSet(date);
} }
log.info("-----定时器进入---baseOrderStatisticsHandler---" + date); log.info("获取到当前需要执行的日期,距离当前时间的天数集合" + arrayList);
XxlJobLogger.log("-----定时器进入---baseOrderStatisticsHandler---" + date); XxlJobLogger.log("获取到当前需要执行的日期,距离当前时间的天数集合" + arrayList);
for (Integer day : arrayList) { for (Integer day : arrayList) {
boolean flag = statisticsBiz.statisticalOrder(day); boolean flag = statisticsBiz.statisticalOrder(day);
log.info("执行状态" + date+"="+flag); log.info("执行状态:" + day+"="+flag);
XxlJobLogger.log("执行状态" + date+"="+flag); XxlJobLogger.log("执行状态:" + day+"="+flag);
} }
return ReturnT.SUCCESS; return new ReturnT<>(ReturnT.SUCCESS_CODE,"执行成功");
} catch (Exception e) { } catch (Exception e) {
XxlJobLogger.log(e); XxlJobLogger.log(e);
log.error(e.getMessage()); log.error(e.getMessage());
return ReturnT.FAIL; return new ReturnT<>(ReturnT.FAIL_CODE,"执行失败");
} }
} }
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment