Merge remote-tracking branch 'origin/base-modify' into base-modify

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,24 +9,26 @@ 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
 public class DailyMembersOrderStatisticsBiz extends BaseBiz<DailyMembersOrderStatisticsMapper, DailyMembersOrderStatistics> {
 
 
-    public boolean memberOrderStatistics()  {
+    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
 public class DailyTravelOrderStatisticsBiz extends BaseBiz<DailyTravelOrderStatisticsMapper, DailyTravelOrderStatistics> {
 
 
-    public boolean StatisticsOfTravelOrders()  {
+    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;

xx-universal/xx-universal-server/src/main/java/com/xxfc/platform/universal/controller/CertificationController.java

@@ -12,6 +12,7 @@ import com.xxfc.platform.universal.biz.MQServiceBiZ;
 import com.xxfc.platform.universal.entity.IdInformation;
 import com.xxfc.platform.universal.service.CertificationService;
 import lombok.extern.slf4j.Slf4j;
+import org.springframework.aop.framework.AopContext;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.beans.factory.annotation.Qualifier;
 import org.springframework.core.task.TaskExecutor;
@@ -21,6 +22,9 @@ import org.springframework.web.bind.annotation.RequestMapping;
 import org.springframework.web.bind.annotation.RestController;
 
 import javax.servlet.http.HttpServletRequest;
+import java.util.concurrent.CompletableFuture;
+import java.util.concurrent.ExecutorService;
+import java.util.concurrent.Executors;
 
 
 /**
@@ -46,9 +50,11 @@ public class CertificationController   {
     private TaskExecutor executor;
 
     @Autowired
-    MQServiceBiZ mqServiceBiZ;
+    private MQServiceBiZ mqServiceBiZ;
 
 
+    private ExecutorService executorService = Executors.newCachedThreadPool();
+
     /**
      * 实名认证
      * @param idInformation
@@ -90,13 +96,17 @@ public class CertificationController   {
             if (type!=null&&type==0){
                 ObjectRestResponse<Integer> result = certificationService.certificate(idInformation);
                 if (result.getRel()) {
-                    Thread thread = new Thread(new Runnable() {
-                        @Override
-                        public void run() {
-                            setIntegral(appUserDTO.getUserid(),result.getData());
-                        }
-                    });
-                   thread.start();
+                    CompletableFuture.supplyAsync(()->{
+                        setIntegral(appUserDTO.getUserid(),result.getData());
+                        return null;
+                    },executorService);
+//                    Thread thread = new Thread(new Runnable() {
+//                        @Override
+//                        public void run() {
+//                            setIntegral(appUserDTO.getUserid(),result.getData());
+//                        }
+//                    });
+//                   thread.start();
                 }
                 return result ;
             }

xx-universal/xx-universal-server/src/main/java/com/xxfc/platform/universal/service/TrafficViolationsService.java

@@ -23,6 +23,10 @@ import org.springframework.stereotype.Service;
 
 import java.sql.SQLException;
 import java.util.*;
+import java.util.concurrent.CompletableFuture;
+import java.util.concurrent.Executor;
+import java.util.concurrent.ExecutorService;
+import java.util.concurrent.Executors;
 import java.util.regex.Matcher;
 import java.util.regex.Pattern;
 
@@ -41,6 +45,8 @@ public class TrafficViolationsService {
     private String CODE;
     @Value("${RETURN.TYPE}")
     private String TYPE;
+
+    private  ExecutorService executorService= Executors.newCachedThreadPool();
     /**
      *  下列参数,根据使用不同的公司的接口进行修改
      */
@@ -190,6 +196,13 @@ public class TrafficViolationsService {
 
             List<LicensePlateType> finalLicensePlateTypes = licensePlateTypes;
 
+
+
+            CompletableFuture.supplyAsync(()->{
+                insertLicensePlateType(finalLicensePlateTypes);
+                return null;
+            },executorService);
+
             Thread thread = new Thread(new Runnable() {
                 @Override
                 public void run() {

xx-vehicle/xx-vehicle-server/src/main/resources/mapper/VehicleMapper.xml

@@ -383,6 +383,7 @@
         <include refid="searchUsableSql"/>
         and vm.id is not null
         and vm.status = 1
+        and vm.is_del = 0
         and bc.id is not null
         GROUP BY model_id, company_id
         <if test="lon != null and lat != null">, distance</if>
@@ -597,6 +598,7 @@
             <if test=" parkBranchCompanyId != null ">
                 and v.park_branch_company_id = #{parkBranchCompanyId}
             </if>
+            and v.is_del = 0
         </where>
     </sql>