修改订单统计定时任务

ace-modules/ace-admin/src/main/java/com/github/wxiaoqi/security/admin/rest/AppUsersManageController.java

@@ -126,7 +126,5 @@ public class AppUsersManageController extends BaseController<AppUserManageBiz,Ap
         appUserLoginBiz.deleteAppUserById(id);
         return ObjectRestResponse.succ();
     }
-
-
 }
 

xx-order/xx-order-server/src/main/java/com/xxfc/platform/order/biz/DailyMembersOrderStatisticsBiz.java

@@ -9,11 +9,13 @@ import org.apache.commons.beanutils.BeanUtils;
 import org.springframework.stereotype.Service;
 
 import java.math.BigDecimal;
+import java.util.Date;
 import java.util.HashMap;
 import java.util.Map;
 
 /**
  * 每日购买会员订单统计
+ *
  * @author Administrator
  */
 @Service
@@ -23,10 +25,10 @@ public class DailyMembersOrderStatisticsBiz extends BaseBiz<DailyMembersOrderSta
     public boolean memberOrderStatistics() {
         try {
             HashMap<String, Object> resultMap = new HashMap<>();
-            Map<String,Object> travelGmv = mapper.getTravelGmv();
+            Map<String, Object> travelGmv = mapper.getTravelGmv();
             resultMap.putAll(travelGmv);
             DailyMembersOrderStatistics MembersStatistics = new DailyMembersOrderStatistics();
-            BeanUtils.copyProperties(MembersStatistics,resultMap);
+            BeanUtils.copyProperties(MembersStatistics, resultMap);
             insertSelective(MembersStatistics);
             return true;
         } catch (Exception e) {
@@ -34,4 +36,10 @@ public class DailyMembersOrderStatisticsBiz extends BaseBiz<DailyMembersOrderSta
             return false;
         }
     }
+
+    @Override
+    public int insertSelectiveRe(DailyMembersOrderStatistics entity) {
+        entity.setCrtTime(new Date());
+        return mapper.insertSelective(entity);
+    }
 }

xx-order/xx-order-server/src/main/java/com/xxfc/platform/order/biz/DailyOrderStatisticsBiz.java

@@ -25,7 +25,7 @@ public class DailyOrderStatisticsBiz extends BaseBiz<DailyOrderStatisticsMapper,
     @Autowired
     private DailyMembersOrderStatisticsBiz membersStatisticsBiz;
 
-//    @Scheduled(cron = "0 0/1 * * * ?")
+    @Scheduled(cron = "0 0 2 * * ?")
     public boolean statisticalOrder(){
         boolean vehicleFlag = vehicleStatisticsBiz.StatisticsOfCarRentalOrders();
         boolean travelFlag = travelStatisticsBiz.StatisticsOfTravelOrders();

xx-order/xx-order-server/src/main/java/com/xxfc/platform/order/biz/DailyTravelOrderStatisticsBiz.java

 package com.xxfc.platform.order.biz;
 
 import com.github.wxiaoqi.security.common.biz.BaseBiz;
+import com.github.wxiaoqi.security.common.util.EntityUtils;
 import com.xxfc.platform.order.entity.DailyTravelOrderStatistics;
 import com.xxfc.platform.order.mapper.DailyTravelOrderStatisticsMapper;
 import org.apache.commons.beanutils.BeanUtils;
 import org.springframework.stereotype.Service;
 
 import java.math.BigDecimal;
+import java.util.Date;
 import java.util.HashMap;
 import java.util.Map;
 
 /**
  * 每日旅游订单统计
+ *
  * @author Administrator
  */
 @Service
@@ -21,12 +24,12 @@ public class DailyTravelOrderStatisticsBiz extends BaseBiz<DailyTravelOrderStati
     public boolean StatisticsOfTravelOrders() {
         try {
             HashMap<String, Object> resultMap = new HashMap<>();
-            Map<String,Object> travelGmv = mapper.getTravelGmv();
+            Map<String, Object> travelGmv = mapper.getTravelGmv();
             BigDecimal travelPenalSum = mapper.getTravelPenalSum();
             resultMap.putAll(travelGmv);
-            resultMap.put("penalSum",travelPenalSum);
+            resultMap.put("penalSum", travelPenalSum);
             DailyTravelOrderStatistics TravelStatistics = new DailyTravelOrderStatistics();
-            BeanUtils.copyProperties(TravelStatistics,resultMap);
+            BeanUtils.copyProperties(TravelStatistics, resultMap);
             insertSelective(TravelStatistics);
             return true;
         } catch (Exception e) {
@@ -34,4 +37,10 @@ public class DailyTravelOrderStatisticsBiz extends BaseBiz<DailyTravelOrderStati
             return false;
         }
     }
+
+    @Override
+    public int insertSelectiveRe(DailyTravelOrderStatistics entity) {
+        entity.setCrtTime(new Date());
+        return mapper.insertSelective(entity);
+    }
 }

xx-order/xx-order-server/src/main/java/com/xxfc/platform/order/biz/DailyVehicleOrderStatisticsBiz.java

@@ -2,6 +2,7 @@ package com.xxfc.platform.order.biz;
 
 import com.alibaba.fastjson.JSON;
 import com.github.wxiaoqi.security.common.biz.BaseBiz;
+import com.xxfc.platform.order.entity.DailyMembersOrderStatistics;
 import com.xxfc.platform.order.entity.DailyVehicleOrderStatistics;
 import com.xxfc.platform.order.mapper.DailyVehicleOrderStatisticsMapper;
 import com.xxfc.platform.order.pojo.DedDetailDTO;
@@ -12,10 +13,7 @@ import org.springframework.transaction.annotation.Transactional;
 import org.springframework.transaction.interceptor.TransactionAspectSupport;
 
 import java.math.BigDecimal;
-import java.util.ArrayList;
-import java.util.HashMap;
-import java.util.List;
-import java.util.Map;
+import java.util.*;
 
 /** 每日租车订单统计
  * @author Administrator
@@ -102,4 +100,12 @@ public class DailyVehicleOrderStatisticsBiz extends BaseBiz<DailyVehicleOrderSta
         return null;
     }
 
+
+    @Override
+    public int insertSelectiveRe(DailyVehicleOrderStatistics entity) {
+        Date date = new Date();
+        entity.setCrtTime(new Date());
+        return mapper.insertSelective(entity);
+    }
+
 }

xx-order/xx-order-server/src/main/java/com/xxfc/platform/order/jobhandler/BaseOrderStatisticsJobHandler.java

@@ -28,17 +28,19 @@ public class BaseOrderStatisticsJobHandler extends IJobHandler {
 
             XxlJobLogger.log("-----定时器进入---baseOrderStatisticsHandler---");
             log.info("-----定时器进入---baseOrderStatisticsHandler---");
-            boolean flag = statisticsBiz.statisticalOrder();
+//            boolean flag = statisticsBiz.statisticalOrder();
             ReturnT returnT = new ReturnT();
-            if (flag) {
+//            if (flag) {
                 returnT.setCode(100);
                 returnT.setMsg("成功");
                 return returnT;
-            }else {
-                returnT.setCode(500);
-                returnT.setMsg("失败");
-                return returnT;
-            }
+//            }
+
+//            else {
+//                returnT.setCode(500);
+//                returnT.setMsg("失败");
+//                return returnT;
+//            }
         } catch (Exception e) {
             XxlJobLogger.log(e);
             return FAIL;