修改实名认证

ace-common/src/main/java/com/github/wxiaoqi/security/common/util/StringToolsUtil.java

+package com.github.wxiaoqi.security.common.util;
+
+import org.apache.commons.lang3.StringUtils;
+
+import java.util.regex.Matcher;
+import java.util.regex.Pattern;
+
+public class StringToolsUtil {
+
+    /**
+     * 验证手机号码
+     * @param mobiles
+     * @return
+     */
+    public static boolean isMobileNO(  String mobiles){
+        boolean flag = false;
+        try{
+            if(StringUtils.isBlank(mobiles)) {
+                flag = false;
+            }
+            Pattern regex = Pattern.compile("^((16[0-9])|(13[0-9])|(15[^4,\\D])|(17[0-9])|(18[0-9])|(19[0-9]))\\d{8}$");
+            Matcher m = regex .matcher(mobiles);
+            flag = m.matches();
+        }catch(Exception e){
+            flag = false;
+        }
+        return flag;
+    }
+
+    /**
+     * 校验身份证
+     *
+     * @param idCard
+     * @return 校验通过返回true，否则返回false
+     */
+    public static boolean isIDCard(String idCard) {
+        if(StringUtils.isBlank(idCard)) {
+            return false;
+        }
+        String REGEX_ID_CARD = "(^\\d{18}$)|(^\\d{15}$)";
+        return Pattern.matches(REGEX_ID_CARD, idCard);
+    }
+}

ace-modules/ace-admin-api/src/main/java/com/github/wxiaoqi/security/admin/feign/rest/UserRestInterface.java

@@ -35,4 +35,10 @@ public interface UserRestInterface {
             return null;
         }
     }
+
+    default void checkAdminUser(){
+        if(null == getAdminUserInfo()) {
+            throw new BaseException(ResultCode.DB_OPERATION_FAIL_CODE);
+        }
+    }
 }

ace-modules/ace-admin/src/main/java/com/github/wxiaoqi/security/admin/biz/AppUserLoginBiz.java

@@ -2,24 +2,29 @@ package com.github.wxiaoqi.security.admin.biz;
 
 import com.ace.cache.annotation.Cache;
 import com.ace.cache.annotation.CacheClear;
+import com.alibaba.fastjson.JSONObject;
 import com.github.wxiaoqi.security.admin.entity.AppUserLogin;
 import com.github.wxiaoqi.security.admin.mapper.AppUserLoginMapper;
 import com.github.wxiaoqi.security.common.biz.BaseBiz;
+import com.github.wxiaoqi.security.common.config.rabbit.RabbitConstant;
 import com.github.wxiaoqi.security.common.constant.UserConstant;
+import com.xxfc.platform.universal.entity.IdInformation;
+import com.xxfc.platform.universal.feign.MQSenderFeign;
+import com.xxfc.platform.universal.feign.ThirdFeign;
 import org.apache.commons.collections.CollectionUtils;
+import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.security.crypto.bcrypt.BCryptPasswordEncoder;
 import org.springframework.stereotype.Service;
 import org.springframework.transaction.annotation.Propagation;
 import org.springframework.transaction.annotation.Transactional;
 import tk.mybatis.mapper.entity.Example;
-import tk.mybatis.mapper.weekend.WeekendSqls;
 
 import java.time.Instant;
 import java.util.HashMap;
 import java.util.List;
 import java.util.Map;
-import java.util.Optional;
-import java.util.concurrent.atomic.AtomicReference;
+import java.util.concurrent.ExecutorService;
+import java.util.concurrent.Executors;
 import java.util.function.Function;
 import java.util.stream.Collectors;
 
@@ -36,6 +41,11 @@ public class AppUserLoginBiz extends BaseBiz<AppUserLoginMapper, AppUserLogin> {
     private static final  String WX_TYPE="wx";
     private static final  String QQ_TYPE="q";
 
+    @Autowired
+    ThirdFeign thirdFeign;
+    @Autowired
+    MQSenderFeign mqSenderFeign;
+
     @Transactional(rollbackFor = Exception.class,propagation = Propagation.REQUIRED)
     @Override
     public void insertSelective(AppUserLogin entity) {
@@ -62,6 +72,44 @@ public class AppUserLoginBiz extends BaseBiz<AppUserLoginMapper, AppUserLogin> {
         super.updateSelectiveById(entity);
     }
 
+    public Object test() {
+        threadRunner();
+        return "success";
+    }
+
+    public void threadRunner() {
+        List<AppUserLogin> list = mapper.selectAll();
+        ExecutorService executorService = Executors.newCachedThreadPool();
+        executorService.execute(new Runnable() {
+             @Override
+              public void run() {
+                 if(list != null && list.size() > 0) {
+                     for(AppUserLogin appUserLogin : list) {
+                         try {
+                             Thread.sleep(3000);
+                         } catch (Exception e){}
+                         IdInformation idInformation = thirdFeign.getOneByUserId(appUserLogin.getId());
+                         if(idInformation != null) { //实名认证
+                             JSONObject jsonObject = new JSONObject();
+                             jsonObject.put("userId", appUserLogin.getId());
+                             jsonObject.put("integralRuleCode", "CRETIFICATION");
+                             jsonObject.put("channelId", idInformation.getId());
+                             mqSenderFeign.sendMessage(RabbitConstant.INTEGRAL_TOPIC, RabbitConstant.INTEGRAL_ROUTING_KEY, jsonObject.toJSONString());
+                         }
+                         try {
+                             Thread.sleep(3000);
+                         } catch (Exception e){}
+                         JSONObject jsonObject = new JSONObject();
+                         jsonObject.put("userId", appUserLogin.getId());
+                         jsonObject.put("integralRuleCode", "REGISTER");
+                         jsonObject.put("channelId", appUserLogin.getId());
+                         mqSenderFeign.sendMessage(RabbitConstant.INTEGRAL_TOPIC, RabbitConstant.INTEGRAL_ROUTING_KEY, jsonObject.toJSONString());
+
+                     }
+                 }
+               }
+        });
+    }
 
     /**
      * 根据用户名获取用户信息

ace-modules/ace-admin/src/main/java/com/github/wxiaoqi/security/admin/biz/AppUserRelationBiz.java

@@ -66,6 +66,16 @@ public class AppUserRelationBiz extends BaseBiz<AppUserRelationMapper,AppUserRel
             log.info("----userId==="+userId+"----parentId===="+parentId+"----自己不能成为自己的上线");
             return;
         }
+        AppUserVo appUserVo=userDetailBiz.getUserInfoById(userId);
+        if (appUserVo==null){
+            log.info("----userId==="+userId+"----parentId===="+parentId+"----该用户不存在");
+            return;
+        }
+         appUserVo=userDetailBiz.getUserInfoById(parentId);
+        if (appUserVo==null){
+            log.info("----userId==="+userId+"----parentId===="+parentId+"----该上线用户不存在");
+            return;
+        }
         AppUserRelation relation=getMyBiz().getRelationByUserId(parentId);
         Long time=System.currentTimeMillis();
          if(relation==null){
@@ -122,7 +132,6 @@ public class AppUserRelationBiz extends BaseBiz<AppUserRelationMapper,AppUserRel
         }
 
     }
-
     /**
      * 小程序分享上下线绑定
      * @param userid  当前人小程序id
@@ -218,9 +227,10 @@ public class AppUserRelationBiz extends BaseBiz<AppUserRelationMapper,AppUserRel
 
     //获取用户的下线总数
     public  int getCountByParentId(Integer parentId,Long time){
-        Example example=new Example(AppUserRelation.class);
-        example.createCriteria().andEqualTo("parentId",parentId).andNotEqualTo("isForever",1).andGreaterThan("bindTime",time);
-        return  mapper.selectCountByExample(example);
+         if (validTime<=0){
+             time= validTime;
+         }
+        return  mapper.countByParentId(parentId,time);
     }
 
      @CacheClear(key="user:relation{1.userId}")

ace-modules/ace-admin/src/main/java/com/github/wxiaoqi/security/admin/mapper/AppUserRelationMapper.java

 package com.github.wxiaoqi.security.admin.mapper;
 
 import com.github.wxiaoqi.security.admin.entity.AppUserRelation;
+import org.apache.ibatis.annotations.Param;
 import tk.mybatis.mapper.common.Mapper;
 
 import java.util.List;
@@ -16,4 +17,7 @@ public interface AppUserRelationMapper extends Mapper<AppUserRelation> {
 
 
     List<AppUserRelation> selectByLeaderId(Integer leaderId);
+
+    //获取有效的下级
+    public  int countByParentId(@Param("parentId")Integer parentId,@Param("bindTime")Long bindTime);
 }

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

 package com.github.wxiaoqi.security.admin.rest;
 
-import com.ace.cache.annotation.Cache;
 import com.github.wxiaoqi.security.admin.biz.*;
 import com.github.wxiaoqi.security.admin.entity.*;
 import com.github.wxiaoqi.security.admin.feign.dto.AppUserDTO;
-import com.github.wxiaoqi.security.admin.feign.rest.UserRestInterface;
 import com.github.wxiaoqi.security.admin.vo.AppUserGroups;
 import com.github.wxiaoqi.security.admin.vo.AppUserInfoVo;
 import com.github.wxiaoqi.security.admin.vo.AppUserVo;
@@ -14,24 +12,20 @@ import com.github.wxiaoqi.security.auth.client.annotation.IgnoreUserToken;
 import com.github.wxiaoqi.security.auth.client.config.UserAuthConfig;
 import com.github.wxiaoqi.security.auth.client.jwt.UserAuthUtil;
 import com.github.wxiaoqi.security.auth.common.util.jwt.IJWTInfo;
-import com.github.wxiaoqi.security.common.context.BaseContextHandler;
 import com.github.wxiaoqi.security.common.exception.BaseException;
 import com.github.wxiaoqi.security.common.msg.ObjectRestResponse;
 import com.github.wxiaoqi.security.common.msg.TableResultResponse;
 import com.github.wxiaoqi.security.common.rest.CommonBaseController;
 import com.github.wxiaoqi.security.common.util.Query;
 import com.github.wxiaoqi.security.common.util.process.ResultCode;
-import com.xxfc.platform.order.entity.BaseOrder;
 import com.xxfc.platform.order.feign.OrderFeign;
 import io.swagger.annotations.ApiOperation;
 import lombok.extern.slf4j.Slf4j;
 import org.apache.commons.beanutils.BeanUtils;
 import org.springframework.beans.factory.annotation.Autowired;
-import org.springframework.beans.factory.annotation.Value;
 import org.springframework.web.bind.annotation.*;
 
 import javax.servlet.http.HttpServletRequest;
-import javax.ws.rs.GET;
 import java.util.List;
 import java.util.Map;
 
@@ -285,4 +279,11 @@ public class AppUserController extends CommonBaseController{
          AppUserInfoVo appUserInfoVo = userDetailBiz.findUserInfoByCode(code);
          return ObjectRestResponse.succ(appUserInfoVo);
     }
+
+    @GetMapping("/app/unauth/test")
+    @IgnoreUserToken
+    @IgnoreClientToken
+    public Object test() {
+        return appUserLoginBiz.test();
+    }
 }

ace-modules/ace-admin/src/main/resources/mapper/AppUserRelationMapper.xml

@@ -6,4 +6,12 @@
     <select id="selectByLeaderId" resultType="com.github.wxiaoqi.security.admin.entity.AppUserRelation">
         select `parent_id` as `parentId`,`user_id`as `userId`,`bind_time` as `bindTime` from `app_user_relation` where `parent_id`=#{leaderId} and `is_del`=0 order by `bind_time` DESC
     </select>
+
+    <select id="countByParentId" resultType="Integer">
+        select count(*)  from `app_user_relation` where
+        `parent_id`=#{parentId} and `is_del`=0
+         <if test="bindTime!='' and bindTime!=null and bindTime>0">
+             and (is_forever=1 or bind_time>#{bindTime})
+         </if>
+    </select>
 </mapper>
\ No newline at end of file

xx-activity/xx-activity-server/src/main/java/com/xxfc/platform/activity/biz/IntegralUserRecordBiz.java

@@ -181,7 +181,7 @@ public class IntegralUserRecordBiz extends BaseBiz<IntegralUserRecordMapper, Int
         } else {
             integralUserRecordDto.setStartTime(null);
             Integer count = mapper.countByUserAndCode(integralUserRecordDto);
-            integralUserStatus.setIntegralStatus(count == number);
+            integralUserStatus.setIntegralStatus(true);
         }
         integralUserStatusBiz.save(integralUserStatus);
     }

xx-activity/xx-activity-server/src/main/java/com/xxfc/platform/activity/rest/IntegralUserRecordController.java

@@ -38,4 +38,6 @@ public class IntegralUserRecordController {
     public ObjectRestResponse getListByCode(IntegralUserRecordDto integralUserRecordDto) {
         return integralUserRecordBiz.getByUserAndTime(integralUserRecordDto);
     }
+
+
 }

xx-app/xx-app-server/src/main/java/com/xxfc/platform/app/biz/CofigBiz.java

@@ -77,7 +77,7 @@ public class CofigBiz extends BaseBiz<CofigMapper, Cofig> {
         Example example = new Example(Cofig.class);
         Example.Criteria criteria = example.createCriteria();
         criteria.andEqualTo("isDel", 0);
-
+        example.setOrderByClause("type");
         PageDataVO<Cofig> cofigPage = PageDataVO.pageInfo(query.getPage(), query.getLimit(), () -> mapper.selectByExample(example));
 
         return new TableResultResponse<>(cofigPage.getTotalCount(), cofigPage.getData());

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

@@ -41,6 +41,7 @@ import org.springframework.stereotype.Service;
 import org.springframework.transaction.annotation.Transactional;
 
 import java.math.BigDecimal;
+import java.util.ArrayList;
 import java.util.List;
 import java.util.Map;
 import java.util.TimeZone;
@@ -169,7 +170,7 @@ public class BaseOrderBiz extends BaseBiz<BaseOrderMapper, BaseOrder> {
                 ids.add(Integer.parseInt(orderPageVo.getOrderTourDetail().getTourUserIds()));
             }
             List<AppUserVo> list = userFeign.getByUserIds(ids).getData();
-            orderPageVo.getOrderTourDetail().setUserVoList(list == null || list.size() <= 0 ? null : list);
+            orderPageVo.getOrderTourDetail().setUserVoList(list == null || list.size() <= 0 ? new ArrayList<>() : list);
         }
         //设置保留金
         Map<String, Dictionary> dictionaryMap = thirdFeign.dictionaryGetAll4Map().getData();
@@ -259,7 +260,7 @@ public class BaseOrderBiz extends BaseBiz<BaseOrderMapper, BaseOrder> {
                 ids.add(Integer.parseInt(orderPageVo.getOrderTourDetail().getTourUserIds()));
             }
             List<AppUserVo> list = userFeign.getByUserIds(ids).getData();
-            orderPageVo.getOrderTourDetail().setUserVoList(list == null || list.size() <= 0 ? null : list);
+            orderPageVo.getOrderTourDetail().setUserVoList(list == null || list.size() <= 0 ? new ArrayList<>() : list);
         }
         //设置保留金
         Map<String, Dictionary> dictionaryMap = thirdFeign.dictionaryGetAll4Map().getData();
@@ -322,7 +323,7 @@ public class BaseOrderBiz extends BaseBiz<BaseOrderMapper, BaseOrder> {
                     setOrderId(baseOrder.getId());
                 }});
                 //车辆预定审核通过
-                vehicleFeign.proveVehicleBooking(orvd.getBookRecordId());
+                RestResponse<Integer> result = vehicleFeign.rentProveVehicleBooking(orvd.getBookRecordId());
 
                 //确认免费天数
                 if (orvd.getFreeDays() > 0) {

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

 package com.xxfc.platform.order.biz.inner;
 
-import cn.hutool.core.date.DateUtil;
-import cn.hutool.core.util.StrUtil;
 import com.github.wxiaoqi.security.admin.feign.UserFeign;
 import com.github.wxiaoqi.security.admin.feign.dto.AppUserDTO;
 import com.github.wxiaoqi.security.common.exception.BaseException;
-import com.github.wxiaoqi.security.common.util.IntervalUtil;
 import com.github.wxiaoqi.security.common.util.process.ResultCode;
 import com.xxfc.platform.order.biz.*;
 import com.xxfc.platform.order.contant.enumerate.*;
 import com.xxfc.platform.order.entity.*;
 import com.xxfc.platform.order.pojo.mq.OrderMQDTO;
 import com.xxfc.platform.tour.feign.TourFeign;
-import com.xxfc.platform.universal.dto.SmsTemplateDTO;
-import com.xxfc.platform.universal.entity.Dictionary;
 import com.xxfc.platform.universal.feign.ThirdFeign;
-import com.xxfc.platform.universal.vo.OrderRefundVo;
 import com.xxfc.platform.vehicle.common.RestResponse;
 import com.xxfc.platform.vehicle.feign.VehicleFeign;
-import com.xxfc.platform.vehicle.pojo.CompanyDetail;
 import lombok.extern.slf4j.Slf4j;
-import org.apache.commons.jexl2.MapContext;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
 import org.springframework.transaction.annotation.Transactional;
@@ -28,7 +20,6 @@ import org.springframework.transaction.annotation.Transactional;
 import java.math.BigDecimal;
 import java.util.*;
 
-import static com.github.wxiaoqi.security.common.constant.CommonConstants.SYS_FALSE;
 import static com.github.wxiaoqi.security.common.constant.CommonConstants.SYS_TRUE;
 import static com.xxfc.platform.universal.constant.DictionaryKey.*;
 
@@ -182,8 +173,8 @@ public class OrderCancelBiz {
 
                 //取消租车预定
                 //已支付,并且是待出行状态，取消预约
-                if(OrderStatusEnum.ORDER_TOSTART.equals(baseOrder.getType()) && SYS_TRUE.equals(baseOrder.getHasPay())){
-                    vehicleFeign.unbookVehicle(orvd.getBookRecordId());
+                if(OrderStatusEnum.ORDER_TOSTART.equals(baseOrder.getStatus()) && SYS_TRUE.equals(baseOrder.getHasPay())){
+                    vehicleFeign.rentUnbookVehicle(orvd.getBookRecordId());
                 }else {
                     //未支付，拒绝之前的预约
                     RestResponse<Integer> restResponse = vehicleFeign.rentRejectVehicleBooking(orvd.getBookRecordId());

xx-order/xx-order-server/src/main/java/com/xxfc/platform/order/rest/BackStageOrderController.java

@@ -199,6 +199,7 @@ public class BackStageOrderController extends CommonBaseController implements Us
                 companyIds.add(dto.getStartCompanyId());
             }
         }
+        dto.setCompanyIds(companyIds);
         Query query = new Query(dto);
         PageDataVO<OrderPageVO> pageDataVO = PageDataVO.pageInfo(query, () -> baseOrderBiz.getRentVehicle(query.getSuper()));
         for (OrderPageVO orderPageVO : pageDataVO.getData()) {
@@ -264,6 +265,22 @@ public class BackStageOrderController extends CommonBaseController implements Us
         return new ObjectRestResponse<>().data(page.getData().get(0));
     }
 
+    @ApiOperation("更換車輛")
+    @RequestMapping(value = "/bg/change-vehicle", method = RequestMethod.POST)
+    @IgnoreClientToken
+    @ResponseBody
+    public ObjectRestResponse<OrderPageVO> changeVehicle(@RequestBody ChangeVehicleDTO dto) {
+        checkAdminUser();
+        //根据订单号获取
+        return ObjectRestResponse.succ();
+    }
+
+    @Data
+    public static class ChangeVehicleDTO {
+        String no;
+        String numberPlate;
+    }
+
     private Query initCompanyQuery(String no) {
         BackStageOrderController.QueryOrderDetailDTO qodd = new BackStageOrderController.QueryOrderDetailDTO();
         //查询公司id

xx-order/xx-order-server/src/main/java/com/xxfc/platform/order/service/OrderRentVehicleService.java

@@ -420,6 +420,7 @@ public class OrderRentVehicleService extends AbstractOrderHandle<OrderRentVehicl
         rentVehicleBookDTO.setLiftCompany(detail.getStartCompanyId());
         rentVehicleBookDTO.setLiftAddr(detail.getStartAddr());
         rentVehicleBookDTO.setRetCompany(detail.getEndCompanyId());
+//        rentVehicleBookDTO.setOrderNo(detail.getO);
         if(null != detail.getAccompanyItems()) {
             rentVehicleBookDTO.setSelectedAccItem(detail.getAccompanyItems().parallelStream().collect(Collectors.toMap(OrderAccompanyDTO::getId, OrderAccompanyDTO::getNum)));
         }

xx-universal/xx-universal-api/src/main/java/com/xxfc/platform/universal/feign/ThirdFeign.java

@@ -4,6 +4,7 @@ import com.alibaba.fastjson.JSONObject;
 import com.github.wxiaoqi.security.common.msg.ObjectRestResponse;
 import com.xxfc.platform.universal.dto.SmsTemplateDTO;
 import com.xxfc.platform.universal.entity.Dictionary;
+import com.xxfc.platform.universal.entity.IdInformation;
 import com.xxfc.platform.universal.vo.OrderPayVo;
 import com.xxfc.platform.universal.vo.OrderRefundVo;
 import com.xxfc.platform.universal.vo.TrafficViolations;
@@ -74,7 +75,8 @@ public interface ThirdFeign {
     @PostMapping("/dictionary/type_code")
     public  Dictionary findDictionaryByTypeAndCode(@RequestParam(value = "type") String type,@RequestParam(value = "code") String code);
 
-
+    @GetMapping(value = "/certif/app/unauth/selectByUser")
+    public IdInformation getOneByUserId(@RequestParam(value = "userId")Integer userId);
 
     /*****************************************  违章 ********************************************/
     @GetMapping("/3p/tv/getRentViolation")

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

@@ -12,14 +12,10 @@ 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;
-import org.springframework.web.bind.annotation.PostMapping;
-import org.springframework.web.bind.annotation.RequestBody;
-import org.springframework.web.bind.annotation.RequestMapping;
-import org.springframework.web.bind.annotation.RestController;
+import org.springframework.web.bind.annotation.*;
 
 import javax.servlet.http.HttpServletRequest;
 import java.util.concurrent.CompletableFuture;
@@ -78,11 +74,11 @@ public class CertificationController   {
             return ObjectRestResponse.createFailedResult(ResultCode.GET_APPUSER_FAILED_CODE,"无法识别,请重新上传");
         }
         AppUserDTO appUserDTO = appUserDTOObjectRestResponse.getData();
-        idInformation.setUserLonginId(appUserDTO.getUserid());
+        idInformation.setUserLoginId(appUserDTO.getUserid());
         //获取用户认证信息
         ObjectRestResponse orr = null;
         try {
-            orr = userFeign.authentication(idInformation.getUserLonginId(), null,null, 0);
+            orr = userFeign.authentication(idInformation.getUserLoginId(), null,null, 0);
         } catch (Exception e) {
             e.printStackTrace();
         }
@@ -124,4 +120,8 @@ public class CertificationController   {
         mqServiceBiZ.sendMessage(RabbitConstant.INTEGRAL_TOPIC, RabbitConstant.INTEGRAL_ROUTING_KEY, jsonObject.toJSONString());
     }
 
+    @GetMapping(value = "/app/unauth/selectByUser")
+    public IdInformation getOneByUserId(Integer userId) {
+        return certificationService.getByUser(userId);
+    }
 }

xx-universal/xx-universal-server/src/main/java/com/xxfc/platform/universal/mapper/IdInformationMapper.java

@@ -2,8 +2,6 @@ package com.xxfc.platform.universal.mapper;
 
 import com.xxfc.platform.universal.entity.IdInformation;
 import org.apache.ibatis.annotations.Insert;
-import org.apache.ibatis.annotations.Options;
-import org.apache.ibatis.annotations.Select;
 import org.springframework.stereotype.Repository;
 import tk.mybatis.mapper.common.Mapper;
 
@@ -11,6 +9,8 @@ import tk.mybatis.mapper.common.Mapper;
 public interface IdInformationMapper extends Mapper<IdInformation> {
 
     @Insert(value = "insert into id_information (user_login_id,name,id_number,certificate_type,front_url,back_url,expiration_date) " +
-                                       "values (#{userLonginId},#{name},#{idNumber},#{certificateType},#{frontUrl},#{backUrl},#{expirationDate})")
+                                       "values (#{userLoginId},#{name},#{idNumber},#{certificateType},#{frontUrl},#{backUrl},#{expirationDate})")
      void addIdInformation(IdInformation idInformation);
+
+    IdInformation selectByUserId(Integer userLoginId);
 }

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

@@ -11,7 +11,6 @@ import com.xxfc.platform.universal.entity.IdInformation;
 import com.xxfc.platform.universal.mapper.IdInformationMapper;
 import com.xxfc.platform.universal.utils.CertifHttpUtils;
 import com.xxfc.platform.universal.utils.Validation;
-import javafx.application.Application;
 import lombok.extern.slf4j.Slf4j;
 import org.apache.commons.collections4.CollectionUtils;
 import org.apache.commons.collections4.map.HashedMap;
@@ -23,7 +22,6 @@ import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.beans.factory.annotation.Value;
 import org.springframework.context.ApplicationContext;
 import org.springframework.stereotype.Service;
-import org.springframework.transaction.TransactionStatus;
 import org.springframework.transaction.annotation.Transactional;
 import org.springframework.transaction.interceptor.TransactionAspectSupport;
 import tk.mybatis.mapper.entity.Example;
@@ -357,13 +355,11 @@ public class CertificationService {
             TransactionAspectSupport.currentTransactionStatus();
             return ObjectRestResponse.createFailedResult(ResultCode.INCOMPLETE_DATA,"无法识别,请重新上传");
         }
-
-
-
-
     }
 
-
+    public IdInformation getByUser(Integer userId) {
+        return idInformationMapper.selectByUserId(userId);
+    }
 
 }
 

xx-universal/xx-universal-server/src/main/resources/mapper/IdInformationMapper.xml

@@ -6,14 +6,16 @@
         <result property="id" column="id"/>
         <result property="idNumber" column="id_number"/>
         <result property="name" column="name"/>
-        <result property="userLonginId" column="user_login_id"/>
+        <result property="userLoginId" column="user_login_id"/>
         <result property="certificateType" column="certificate_type"/>
         <result property="frontUrl" column="front_url"/>
         <result property="backUrl" column="back_url"/>
         <result property="expirationDate" column="expiration_date"/>
         <result property="authenticationMethods" column="authentication_methods"/>
     </resultMap>
-
+    <select id="selectByUserId" resultType="com.xxfc.platform.universal.entity.IdInformation" parameterType="java.lang.Integer">
+        select * from id_information where user_login_id = #{userLoginId}
+    </select>
 
 
 </mapper>
\ No newline at end of file

xx-user-behavior-collect/xx-user-behavior-server/src/main/java/com/xxfc/platform/user/behavior/biz/CustomerBehaviorNotesBiz.java

@@ -125,7 +125,7 @@ public class CustomerBehaviorNotesBiz extends BaseBiz<CustomerBehaviorNotesMappe
                 //App访问量统计
                 case APP_VISIT_COUNT:
                     actionAcount = new ActionAcount();
-                    default_p_total = mapper.selectAppVvisitsByType(BehaviorEnum.APP_VISIT_COUNT.getCode());
+                    default_p_total = mapper.selectAppVvisitsByTypeAndTime(BehaviorEnum.APP_VISIT_COUNT.getCode(),startAtomic.get(),endAtomic.get());
                     default_p_avg = default_p_total / between_day;
                     actionAcount.setDefault_p_total(default_p_total);
                     actionAcount.setDefault_p_avg(default_p_avg);
@@ -150,24 +150,26 @@ public class CustomerBehaviorNotesBiz extends BaseBiz<CustomerBehaviorNotesMappe
             behaviorNoteCollectVo.setU_avg_count(actionAcount.getDefault_u_avg());
             behaviorNoteCollectVos.add(behaviorNoteCollectVo);
         }
+        behaviorNoteCollectVos.sort(Comparator.comparing(BehaviorNoteCollectVo::getBehavior));
         return behaviorNoteCollectVos;
     }
 
     /**
-     *   获取时间间隔 和 开始与结束时间的处理
-     * @param activityId  活动id
-     * @param startTime 筛选的开始时间
-     * @param endTime  筛选的结束时间
+     * 获取时间间隔 和 开始与结束时间的处理
+     *
+     * @param activityId 活动id
+     * @param startTime  筛选的开始时间
+     * @param endTime    筛选的结束时间
      * @return
      */
     private long getBetweenDayAndprocessStartTimeAndEndTime(Integer activityId, AtomicLong startTime, AtomicLong endTime) {
         if (startTime.get() == 0 || endTime.get() == 0) {
             ActivityListDTO activityListDTO = activityFeign.findActivityStartTimeAndEndTimeById(activityId);
             Instant now = Instant.now();
-            if (startTime.get() != 0) {
+            if (startTime.get() != 0 && endTime.get() == 0) {
                 endTime.set(now.toEpochMilli());
             }
-            if (endTime.get() != 0) {
+            if (endTime.get() != 0 && startTime.get() == 0) {
                 startTime.set(activityListDTO.getActivity_startTime());
             }
             if (startTime.get() == 0 && endTime.get() == 0) {

xx-user-behavior-collect/xx-user-behavior-server/src/main/java/com/xxfc/platform/user/behavior/mapper/CustomerBehaviorNotesMapper.java

@@ -17,7 +17,7 @@ public interface CustomerBehaviorNotesMapper extends Mapper<CustomerBehaviorNote
 
     List<CustomerBehaviorNotes> selectByActivityIdAndTime(@Param("activityId") Integer activityId,@Param("startTime") Long startTime,@Param("endTime") Long endTime);
 
-    long selectAppVvisitsByType(@Param("code") int code);
+    long selectAppVvisitsByTypeAndTime(@Param("code") int code,@Param("startTime") Long startTime,@Param("endTime") Long endTime);
 
     List<CustomerBehaviorNotes> selectAllByTypeIdsAndTime(@Param("bizIds") List<Integer> bizIds,@Param("startTime") Long startTime,@Param("endTime") Long endTime);
 }

xx-user-behavior-collect/xx-user-behavior-server/src/main/resources/mapper/CustomerBehaviorNotesMapper.xml

@@ -27,8 +27,17 @@
         </if>
     </select>
 
-    <select id="selectAppVvisitsByType" resultType="long">
+    <select id="selectAppVvisitsByTypeAndTime" resultType="long">
         select count(id) from `customer_behavior_notes` where `type`=#{code}
+        <if test="startTime != null != null and endTime !=null">
+            and `crt_time` between #{startTime} and #{endTime}
+        </if>
+        <if test="startTime != null and endTime == null">
+            and <![CDATA[`crt_time` >= #{startTime}]]>
+        </if>
+        <if test="endTime != null and startTime == null">
+            and <![CDATA[ `crt_time` <= #{endTime}]]>
+        </if>
     </select>
 
     <select id="selectAllByTypeIdsAndTime" resultMap="customerBehaviorNotesMap">

xx-vehicle/xx-vehicle-api/src/main/java/com/xxfc/platform/vehicle/constant/ResCode/ResCode.java

@@ -24,11 +24,14 @@ public enum ResCode {
     VEHICLE_BOOKED_RECORD_STATUS_CHANGED(103002,"车辆预定申请状态已变更"),
     VEHICLE_BOOKED_RECORD_MILEAGE_CHANGED(103003,"请输入仪表盘内当前显示的公里数"),
 
+    CHECKUSER_AND_PHONE_NOT_NULL(103999, "收车或交车人姓名和电话不能为空"),
+    USERNAME_AND_TELE_NOT_NULL(104000, "使用人和电话不能为空"),
     VEHICLE_DEPARTURE_VEHICLE_UNEXIST(104001,"车辆不存在"),
     VEHICLE_DEPARTURE_VEHICLE_DISABLE(104002,"车辆不可用"),
     VEHICLE_DEPARTURE_VEHICLE_UNDEPARTURE(104003,"车辆未出车"),
 
     VEHICLE_BOOK_RECORD_IS_NOT_EXIST(104004, "预约记录不存在"),
+    VEHICLE_UNBOOK_FAIL(104005, "取消预定失败！"),
 
     BRANCH_COMPANY_UNEXIST(105001, "分公司信息不存在"),
     BRANCH_COMPANY_STOCK_EXISTED(105002, "分公司股权信息已存在"),

xx-vehicle/xx-vehicle-api/src/main/java/com/xxfc/platform/vehicle/feign/VehicleFeign.java

@@ -54,12 +54,12 @@ public interface VehicleFeign {
     public RestResponse<Integer> rentRejectVehicleBooking(@PathVariable(value = "bookRecordId") Long bookRecordId);
 
     //取消预约
-    @RequestMapping(value = "/vehicleInfo/unbook/4employee/{bookRecordId}", method = RequestMethod.DELETE)
-    public RestResponse<Integer> unbookVehicle(@PathVariable(value = "bookRecordId") Long bookRecordId);
+    @RequestMapping(value = "/vehicleInfo/rent/unbook/{bookRecordId}", method = RequestMethod.DELETE)
+    public RestResponse<Integer> rentUnbookVehicle(@PathVariable(value = "bookRecordId") Long bookRecordId);
 
     //通过预约
-    @RequestMapping(value = "/vehicleInfo/book/4employee/prove/{bookRecordId}", method = RequestMethod.PUT)
-    public RestResponse<Integer> proveVehicleBooking(@PathVariable(value = "bookRecordId") Long bookRecordId);
+    @RequestMapping(value = "/vehicleInfo/rent/book/prove/{bookRecordId}", method = RequestMethod.PUT)
+    public RestResponse<Integer> rentProveVehicleBooking(@PathVariable(value = "bookRecordId") Long bookRecordId);
 
     //获取分公司列表
     @GetMapping("/branchCompany/all")

xx-vehicle/xx-vehicle-api/src/main/java/com/xxfc/platform/vehicle/pojo/BookVehicleVO.java

@@ -103,4 +103,9 @@ public class BookVehicleVO {
     private String upkeepIds;
 
     private String orderNo;
+
+    /**
+     * book_record状态
+     */
+    private Integer status;
 }
\ No newline at end of file

xx-vehicle/xx-vehicle-api/src/main/java/com/xxfc/platform/vehicle/pojo/CompanyDetail.java

@@ -14,9 +14,6 @@ public class CompanyDetail extends BranchCompany {
         StringBuilder detailAddrStr = new StringBuilder("");
         if(null != this.getSysRegions() && this.getSysRegions().size() > 0) {
             for(SysRegion sysRegion : this.getSysRegions()) {
-//                if(0 != detailAddrStr.length()) {
-//
-//                }
                 String name = sysRegion.getName()
                         .replace("省", "")
                         .replace("市", "")
@@ -27,7 +24,9 @@ public class CompanyDetail extends BranchCompany {
                 }
             }
         }
-
+        if(this.getAddrDetail().contains(detailAddrStr)) {
+            return this.getAddrDetail();
+        }
         detailAddrStr.append(this.getAddrDetail());
         return detailAddrStr.toString();
     }

xx-vehicle/xx-vehicle-api/src/main/java/com/xxfc/platform/vehicle/pojo/QueryVehicleWarningMsgVo.java

@@ -2,6 +2,8 @@ package com.xxfc.platform.vehicle.pojo;
 
 import lombok.Data;
 
+import java.util.List;
+
 /**
  *车辆相关预警消息
  *
@@ -29,4 +31,8 @@ public class QueryVehicleWarningMsgVo {
     private Integer page;
 
     private Integer limit;
+
+    private Integer colorType;
+
+    private List<Integer> companyIds;
 }

xx-vehicle/xx-vehicle-server/src/main/java/com/xxfc/platform/vehicle/biz/VehicleActiveService.java

@@ -10,6 +10,7 @@ import com.xxfc.platform.vehicle.constant.VehicleStatus;
 import com.xxfc.platform.vehicle.entity.*;
 import com.xxfc.platform.vehicle.mapper.*;
 import com.xxfc.platform.vehicle.pojo.*;
+import org.apache.commons.lang3.StringUtils;
 import org.springframework.beans.BeanUtils;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.beans.factory.annotation.Value;
@@ -55,8 +56,16 @@ public class VehicleActiveService {
             throw new BaseException(ResCode.VEHICLE_DEPARTURE_VEHICLE_UNEXIST.getDesc(),
                     ResCode.VEHICLE_DEPARTURE_VEHICLE_UNEXIST.getCode());
         }
+        if(StringUtils.isBlank(departureVo.getUser()) || StringUtils.isBlank(departureVo.getUserTel())) {
+            throw new BaseException(ResCode.USERNAME_AND_TELE_NOT_NULL.getDesc(),
+                    ResCode.USERNAME_AND_TELE_NOT_NULL.getCode());
+        }
+        if(StringUtils.isBlank(departureVo.getCheckMan()) || StringUtils.isBlank(departureVo.getCheckManTel())) {
+            throw new BaseException(ResCode.CHECKUSER_AND_PHONE_NOT_NULL.getDesc(),
+                    ResCode.CHECKUSER_AND_PHONE_NOT_NULL.getCode());
+        }
         if (!vehicle.getStatus().equals(VehicleStatus.NORMAL.getCode())) {
-            throw new BaseException(ResCode.VEHICLE_DEPARTURE_VEHICLE_DISABLE.getDesc(),
+            throw new BaseException(ResCode.VEHICLE_DEPARTURE_VEHICLE_DISABLE.getDesc() + ", 车辆状态是：" + getVehicleStatus(vehicle.getStatus(), vehicle.getId()),
                     ResCode.VEHICLE_DEPARTURE_VEHICLE_DISABLE.getCode());
         }
         Integer MileageLift=vehicle.getMileageLastUpdate();
@@ -75,8 +84,8 @@ public class VehicleActiveService {
             int result = vehicleMapper.updateStatusByIdAndStatus(departureVo.getVehicleId(), VehicleStatus.DEPARTURE.getCode(),
                     VehicleStatus.NORMAL.getCode());
 
-            if (result == 0) {
-                throw new BaseException(ResCode.VEHICLE_DEPARTURE_VEHICLE_DISABLE.getDesc(),
+            if (!vehicle.getStatus().equals(VehicleStatus.NORMAL.getCode())) {
+                throw new BaseException(ResCode.VEHICLE_DEPARTURE_VEHICLE_DISABLE.getDesc() + ", 车辆状态是：" + getVehicleStatus(vehicle.getStatus(), vehicle.getId()),
                         ResCode.VEHICLE_DEPARTURE_VEHICLE_DISABLE.getCode());
             }
             //修改预约记录状态
@@ -117,10 +126,35 @@ public class VehicleActiveService {
             throw new BaseException(ResCode.VEHICLE_BOOKED_RECORD_MILEAGE_CHANGED.getDesc(),
                     ResCode.VEHICLE_BOOKED_RECORD_MILEAGE_CHANGED.getCode());
         }
+    }
 
-
-
-
+    public String getVehicleStatus(Integer status, String vehicleId) {
+        StringBuilder stringBuilder = new StringBuilder();
+        switch (status) {
+            case 1:
+                stringBuilder.append("正常运行");
+                break;
+            case 2:
+                stringBuilder.append("维修");
+                break;
+            case 3:
+                stringBuilder.append("报废");
+                break;
+            case 4:
+                stringBuilder.append("出车");
+                break;
+            case 5:
+                stringBuilder.append("保养");
+                break;
+        }
+            List<VehicleBookRecordVo> vehicleBookRecordVos = vehicleBookRecordBiz.selectByVehicleId(vehicleId);
+            if(vehicleBookRecordVos != null && vehicleBookRecordVos.size() > 0) {
+                stringBuilder.append("中，使用人：");
+                stringBuilder.append(vehicleBookRecordVos.get(0).getVehicleUsername());
+                stringBuilder.append(" 使用人电话：");
+                stringBuilder.append(vehicleBookRecordVos.get(0).getVehicleUserPhone());
+            }
+        return stringBuilder.toString();
     }
 
     @Transactional
@@ -130,8 +164,12 @@ public class VehicleActiveService {
             throw new BaseException(ResCode.VEHICLE_DEPARTURE_VEHICLE_UNEXIST.getDesc(),
                     ResCode.VEHICLE_DEPARTURE_VEHICLE_UNEXIST.getCode());
         }
+        if(StringUtils.isBlank(arrivalVo.getRecycleMan()) || StringUtils.isBlank(arrivalVo.getRecycleManTel())) {
+            throw new BaseException(ResCode.CHECKUSER_AND_PHONE_NOT_NULL.getDesc(),
+                    ResCode.CHECKUSER_AND_PHONE_NOT_NULL.getCode());
+        }
         if (!vehicle.getStatus().equals(VehicleStatus.DEPARTURE.getCode())) {
-            throw new BaseException(ResCode.VEHICLE_DEPARTURE_VEHICLE_UNDEPARTURE.getDesc(),
+            throw new BaseException(ResCode.VEHICLE_DEPARTURE_VEHICLE_UNDEPARTURE.getDesc() + ", 车辆状态是：" + getVehicleStatus(vehicle.getStatus(), vehicle.getId()),
                     ResCode.VEHICLE_DEPARTURE_VEHICLE_UNDEPARTURE.getCode());
         }
         Integer Mileagerest = vehicle.getMileageLastUpdate();

xx-vehicle/xx-vehicle-server/src/main/java/com/xxfc/platform/vehicle/biz/VehicleBiz.java

@@ -24,10 +24,7 @@ import com.xxfc.platform.vehicle.constant.RedisKey;
 import com.xxfc.platform.vehicle.constant.ResCode.ResCode;
 import com.xxfc.platform.vehicle.constant.VehicleBookRecordStatus;
 import com.xxfc.platform.vehicle.constant.VehicleStatus;
-import com.xxfc.platform.vehicle.entity.BranchCompany;
-import com.xxfc.platform.vehicle.entity.Vehicle;
-import com.xxfc.platform.vehicle.entity.VehicleBookInfo;
-import com.xxfc.platform.vehicle.entity.VehicleBookRecord;
+import com.xxfc.platform.vehicle.entity.*;
 import com.xxfc.platform.vehicle.mapper.BookRecordAccItemMapper;
 import com.xxfc.platform.vehicle.mapper.VehicleBookInfoMapper;
 import com.xxfc.platform.vehicle.mapper.VehicleMapper;
@@ -314,180 +311,94 @@ public class VehicleBiz extends BaseBiz<VehicleMapper, Vehicle> implements UserR
         return RestResponse.suc();
     }
 
-    /**
-     * 申请汽车预定（内部）
-     * 检查是否可预定，修改相关预定记录状态
-     * @param userId
-     * @param bookVehicleVo
-     * @return
-     */
-    @Transactional
-    public VehicleBookRecord applyVehicle4Employee(Integer userId, BookVehicleVO bookVehicleVo, String userName) throws Exception{
-        //检查车辆信息是否合法
-        checkIfVehicleExists(bookVehicleVo.getVehicleId());
-        //提取日期和相应的预定目标日期
-        Map<String,List<String>> yearMonthAndDate = Maps.newHashMap();
-        //预定时间不能为空
-        if(StringUtils.isBlank(bookVehicleVo.getBookStartDate()) || StringUtils.isBlank(bookVehicleVo.getBookEndDate())){
-            throw new BaseException(ResultCode.DATE_TIME_IS_NULL);
-        }
-        String[] bookStartDateArray = bookVehicleVo.getBookStartDate().split(" ");
-        String[] bookEndDateArray = bookVehicleVo.getBookEndDate().split(" ");
-
-        DateTime startDay =DateTime.parse(bookStartDateArray[0],DEFAULT_DATE_TIME_FORMATTER);
-        DateTime endDay =DateTime.parse(bookEndDateArray[0], DEFAULT_DATE_TIME_FORMATTER);
-
-
-        //转换日期范围为列表，并检查是否合法
-        fillDateList4DatePeriod(yearMonthAndDate,startDay,endDay);
-        if(yearMonthAndDate.size()>3){//连续的日期最多夸3个月
-            throw new BaseException(ResultCode.ONLY_BOOK_TWO_MONTH);
-        }
-        for(Map.Entry<String,List<String>> entry:yearMonthAndDate.entrySet()){
-            Boolean rsEach = applyVehicle4EmployeePerMonth(bookVehicleVo.getVehicleId(),entry.getValue(),entry.getKey());
-            if(Boolean.FALSE.equals(rsEach)){
-                throw new BaseException(ResultCode.VEHICLE_IS_BOOKED);
-            }
-        }
-
-        //加入预定申请记录
-        VehicleBookRecord vehicleBookRecord = new VehicleBookRecord();
-        vehicleBookRecord.setVehicleId(bookVehicleVo.getVehicleId());
-        vehicleBookRecord.setBookType(bookVehicleVo.getBookType());
-        vehicleBookRecord.setStatus(VehicleBookRecordStatus.APPLY.getCode());
-        vehicleBookRecord.setBookUser(userId);
-        vehicleBookRecord.setBookUserName(userName);
-        vehicleBookRecord.setBookStartDate(DateTime.
-                parse(bookStartDateArray[0],DEFAULT_DATE_TIME_FORMATTER).toDate());
-        vehicleBookRecord.setBookEndDate(DateTime.
-                parse(bookEndDateArray[0],DEFAULT_DATE_TIME_FORMATTER).toDate());
-        vehicleBookRecord.setLiftAddr(bookVehicleVo.getLiftAddr());
-        vehicleBookRecord.setRemark(bookVehicleVo.getRemark());
-        vehicleBookRecord.setDestination(bookVehicleVo.getDestination());
-        vehicleBookRecord.setLiftCompany(bookVehicleVo.getLiftCompany());
-        vehicleBookRecord.setRetCompany(bookVehicleVo.getRetCompany());
-        vehicleBookRecord.setOrderNo(bookVehicleVo.getOrderNo());
-        vehicleBookRecordBiz.save(vehicleBookRecord);
-//        //添加预定时间记录
+//    /**
+//     * 申请汽车预定（内部）
+//     * 检查是否可预定，修改相关预定记录状态
+//     * @param userId
+//     * @param bookVehicleVo
+//     * @return
+//     */
+//    @Transactional
+//    public VehicleBookRecord applyVehicle4Employee(Integer userId, BookVehicleVO bookVehicleVo, String userName) throws Exception{
+//        //检查车辆信息是否合法
+//        checkIfVehicleExists(bookVehicleVo.getVehicleId());
+//        //提取日期和相应的预定目标日期
+//        Map<String,List<String>> yearMonthAndDate = Maps.newHashMap();
+//        //预定时间不能为空
+//        if(StringUtils.isBlank(bookVehicleVo.getBookStartDate()) || StringUtils.isBlank(bookVehicleVo.getBookEndDate())){
+//            throw new BaseException(ResultCode.DATE_TIME_IS_NULL);
+//        }
+//        String[] bookStartDateArray = bookVehicleVo.getBookStartDate().split(" ");
+//        String[] bookEndDateArray = bookVehicleVo.getBookEndDate().split(" ");
+//
+//        DateTime startDay =DateTime.parse(bookStartDateArray[0],DEFAULT_DATE_TIME_FORMATTER);
+//        DateTime endDay =DateTime.parse(bookEndDateArray[0], DEFAULT_DATE_TIME_FORMATTER);
+//
 //
-//            Map<String, Integer> map = vehicleBookHourInfoBiz.getPredictableHours(bookVehicleVo.getBookStartDate(), bookVehicleVo.getBookEndDate());
-//            for(Map.Entry<String, Integer> entry : map.entrySet()) {
-//                VehicleBookHourInfoDto vehicleBookHourInfoDto = new VehicleBookHourInfoDto();
-//                vehicleBookHourInfoDto.setVehicleId(bookVehicleVo.getVehicleId());
-//                vehicleBookHourInfoDto.setYearMonthDay(entry.getKey());
-//                vehicleBookHourInfoDto.setBookedHour(entry.getValue());
-//                vehicleBookHourInfoBiz.save(vehicleBookHourInfoDto);
+//        //转换日期范围为列表，并检查是否合法
+//        fillDateList4DatePeriod(yearMonthAndDate,startDay,endDay);
+//        if(yearMonthAndDate.size()>3){//连续的日期最多夸3个月
+//            throw new BaseException(ResultCode.ONLY_BOOK_TWO_MONTH);
+//        }
+//        Map<String, Integer> map = vehicleBookHourInfoBiz.getPredictableHours(bookVehicleVo.getBookStartDate(), bookVehicleVo.getBookEndDate());
+//        //检查车辆是否可以预定
+//        for(Map.Entry<String,List<String>> entry:yearMonthAndDate.entrySet()){
+//            Boolean rsEach = applyVehicle4EmployeePerMonth(bookVehicleVo.getVehicleId(),entry.getValue(),entry.getKey(), map);
+//            if(Boolean.FALSE.equals(rsEach)){
+//                throw new BaseException(ResultCode.VEHICLE_IS_BOOKED);
 //            }
-
-        //修改相关车辆预定记录
-        Boolean hasSuc = bookedVehicle(bookVehicleVo);
-        if(!hasSuc){
-            throw new BaseException(ResultCode.BOOKED_FAILED_CODE);
-        }
-
-        //添加随车物品
-        List<Map<String,Object>> params = Lists.newArrayList();
-        if(MapUtils.isNotEmpty(bookVehicleVo.getSelectedAccItem())){
-            for(Map.Entry<Integer,Integer> idAndAmount : bookVehicleVo.getSelectedAccItem().entrySet()){
-                Map<String,Object> row = Maps.newHashMap();
-                row.put("id",idAndAmount.getKey());
-                row.put("amount",idAndAmount.getValue());
-                row.put("bookRecordId",vehicleBookRecord.getId());
-                params.add(row);
-            }
-            bookRecordAccItemMapper.batchAdd(params);
-        }
-
-        return vehicleBookRecord;
-    }
-
-    /**
-     * 需要审核
-     * @param userId
-     * @param bookVehicleVo
-     * @param userName
-     * @return
-     * @throws Exception
-     */
-    @Transactional
-    public VehicleBookRecord applyForVehicle(Integer userId, BookVehicleVO bookVehicleVo, String userName) throws Exception{
-        log.info("预定车辆参数：userId = {}, bookVehicleVo = {},username = {}", userId, bookVehicleVo, userName);
-        //检查车辆信息是否合法
-        checkIfVehicleExists(bookVehicleVo.getVehicleId());
-        //提取日期和相应的预定目标日期
-        Map<String,List<String>> yearMonthAndDate = Maps.newHashMap();
-        //预定时间不能为空
-        if(StringUtils.isBlank(bookVehicleVo.getBookStartDate()) || StringUtils.isBlank(bookVehicleVo.getBookEndDate())){
-            throw new BaseException(ResultCode.DATE_TIME_IS_NULL);
-        }
-        DateTime startDay =DateTime.parse(bookVehicleVo.getBookStartDate(),DATE_TIME_FORMATTER);
-        DateTime endDay =DateTime.parse(bookVehicleVo.getBookEndDate(), DATE_TIME_FORMATTER);
-
-
-        //转换日期范围为列表，并检查是否合法
-        fillDateList4DatePeriod(yearMonthAndDate,startDay,endDay);
-        if(yearMonthAndDate.size()>3){//连续的日期最多夸3个月
-            throw new BaseException(ResultCode.ONLY_BOOK_TWO_MONTH);
-        }
-        //检查车辆是否可以预定
-        for(Map.Entry<String,List<String>> entry:yearMonthAndDate.entrySet()){
-            Boolean rsEach = applyVehicle4EmployeePerMonth(bookVehicleVo.getVehicleId(),entry.getValue(),entry.getKey());
-            if(Boolean.FALSE.equals(rsEach)){
-                throw new BaseException(ResultCode.VEHICLE_IS_BOOKED);
-            }
-        }
-
-        //加入预定申请记录
-        VehicleBookRecord vehicleBookRecord = null;
-        if(bookVehicleVo.getVehicleBookRecordId() == null) {
-            vehicleBookRecord = new VehicleBookRecord();
-            BeanUtil.copyProperties(bookVehicleVo, vehicleBookRecord, CopyOptions.create().setIgnoreNullValue(true).setIgnoreError(true));
-            vehicleBookRecord.setBookStartDate(startDay.toDate());
-            vehicleBookRecord.setBookEndDate(endDay.toDate());
-            vehicleBookRecord.setStatus(VehicleBookRecordStatus.APPLY.getCode());
-            vehicleBookRecord.setBookUser(userId);
-            vehicleBookRecord.setBookUserName(userName);
-            vehicleBookRecordBiz.save(vehicleBookRecord);
-        } else {
-            vehicleBookRecord = vehicleBookRecordBiz.selectById(bookVehicleVo.getVehicleBookRecordId());
-            vehicleBookRecord.setBookStartDate(startDay.toDate());
-            vehicleBookRecord.setBookEndDate(endDay.toDate());
-            vehicleBookRecordBiz.updateSelectiveByIdRe(vehicleBookRecord);
-        }
-
-//        //添加预定时间记录
-            VehicleBookRecord newValue = vehicleBookRecordBiz.selectOne(vehicleBookRecord);
-            Map<String, Integer> map = vehicleBookHourInfoBiz.getPredictableHours(bookVehicleVo.getBookStartDate(), bookVehicleVo.getBookEndDate());
-            for(Map.Entry<String, Integer> entry : map.entrySet()) {
-                VehicleBookHourInfoDto vehicleBookHourInfoDto = new VehicleBookHourInfoDto();
-                vehicleBookHourInfoDto.setVehicleId(bookVehicleVo.getVehicleId());
-                vehicleBookHourInfoDto.setYearMonthDay(entry.getKey());
-                vehicleBookHourInfoDto.setBookedHour(entry.getValue());
-                vehicleBookHourInfoDto.setBookRecordId(newValue.getId());
-                vehicleBookHourInfoBiz.save(vehicleBookHourInfoDto);
-            }
-
-        //修改相关车辆预定记录
-        Boolean hasSuc = bookedVehicle(bookVehicleVo);
-        if(!hasSuc){
-            throw new BaseException(ResultCode.BOOKED_FAILED_CODE);
-        }
-
-        //添加随车物品
-        List<Map<String,Object>> params = Lists.newArrayList();
-        if(MapUtils.isNotEmpty(bookVehicleVo.getSelectedAccItem())){
-            for(Map.Entry<Integer,Integer> idAndAmount : bookVehicleVo.getSelectedAccItem().entrySet()){
-                Map<String,Object> row = Maps.newHashMap();
-                row.put("id",idAndAmount.getKey());
-                row.put("amount",idAndAmount.getValue());
-                row.put("bookRecordId",vehicleBookRecord.getId());
-                params.add(row);
-            }
-            bookRecordAccItemMapper.batchAdd(params);
-        }
-
-        return vehicleBookRecord;
-    }
+//        }
+//
+//        //加入预定申请记录
+//        VehicleBookRecord vehicleBookRecord = new VehicleBookRecord();
+//        vehicleBookRecord.setVehicleId(bookVehicleVo.getVehicleId());
+//        vehicleBookRecord.setBookType(bookVehicleVo.getBookType());
+//        vehicleBookRecord.setStatus(VehicleBookRecordStatus.APPLY.getCode());
+//        vehicleBookRecord.setBookUser(userId);
+//        vehicleBookRecord.setBookUserName(userName);
+//        vehicleBookRecord.setBookStartDate(DateTime.
+//                parse(bookStartDateArray[0],DEFAULT_DATE_TIME_FORMATTER).toDate());
+//        vehicleBookRecord.setBookEndDate(DateTime.
+//                parse(bookEndDateArray[0],DEFAULT_DATE_TIME_FORMATTER).toDate());
+//        vehicleBookRecord.setLiftAddr(bookVehicleVo.getLiftAddr());
+//        vehicleBookRecord.setRemark(bookVehicleVo.getRemark());
+//        vehicleBookRecord.setDestination(bookVehicleVo.getDestination());
+//        vehicleBookRecord.setLiftCompany(bookVehicleVo.getLiftCompany());
+//        vehicleBookRecord.setRetCompany(bookVehicleVo.getRetCompany());
+//        vehicleBookRecord.setOrderNo(bookVehicleVo.getOrderNo());
+//        vehicleBookRecordBiz.save(vehicleBookRecord);
+////        //添加预定时间记录
+////
+////            Map<String, Integer> map = vehicleBookHourInfoBiz.getPredictableHours(bookVehicleVo.getBookStartDate(), bookVehicleVo.getBookEndDate());
+////            for(Map.Entry<String, Integer> entry : map.entrySet()) {
+////                VehicleBookHourInfoDto vehicleBookHourInfoDto = new VehicleBookHourInfoDto();
+////                vehicleBookHourInfoDto.setVehicleId(bookVehicleVo.getVehicleId());
+////                vehicleBookHourInfoDto.setYearMonthDay(entry.getKey());
+////                vehicleBookHourInfoDto.setBookedHour(entry.getValue());
+////                vehicleBookHourInfoBiz.save(vehicleBookHourInfoDto);
+////            }
+//
+//        //修改相关车辆预定记录
+//        Boolean hasSuc = bookedVehicle(bookVehicleVo);
+//        if(!hasSuc){
+//            throw new BaseException(ResultCode.BOOKED_FAILED_CODE);
+//        }
+//
+//        //添加随车物品
+//        List<Map<String,Object>> params = Lists.newArrayList();
+//        if(MapUtils.isNotEmpty(bookVehicleVo.getSelectedAccItem())){
+//            for(Map.Entry<Integer,Integer> idAndAmount : bookVehicleVo.getSelectedAccItem().entrySet()){
+//                Map<String,Object> row = Maps.newHashMap();
+//                row.put("id",idAndAmount.getKey());
+//                row.put("amount",idAndAmount.getValue());
+//                row.put("bookRecordId",vehicleBookRecord.getId());
+//                params.add(row);
+//            }
+//            bookRecordAccItemMapper.batchAdd(params);
+//        }
+//
+//        return vehicleBookRecord;
+//    }
 
     /**
      * 不需要审核
@@ -506,15 +417,14 @@ public class VehicleBiz extends BaseBiz<VehicleMapper, Vehicle> implements UserR
         Map<String,List<String>> yearMonthAndDate = Maps.newHashMap();
         DateTime startDay =DateTime.parse(bookVehicleVo.getBookStartDate(),DATE_TIME_FORMATTER);
         DateTime endDay =DateTime.parse(bookVehicleVo.getBookEndDate(), DATE_TIME_FORMATTER);
-
-
         //转换日期范围为列表，并检查是否合法
         fillDateList4DatePeriod(yearMonthAndDate,startDay,endDay);
         if(yearMonthAndDate.size()>3){//连续的日期最多夸3个月
             throw new BaseException(ResultCode.ONLY_BOOK_TWO_MONTH);
         }
+        Map<String, Integer> map = vehicleBookHourInfoBiz.getPredictableHours(bookVehicleVo.getBookStartDate(), bookVehicleVo.getBookEndDate());
         for(Map.Entry<String,List<String>> entry:yearMonthAndDate.entrySet()){
-            Boolean rsEach = applyVehicle4EmployeePerMonth(bookVehicleVo.getVehicleId(),entry.getValue(),entry.getKey());
+            Boolean rsEach = applyVehicle4EmployeePerMonth(bookVehicleVo.getVehicleId(),entry.getValue(),entry.getKey(), map);
             if(Boolean.FALSE.equals(rsEach)){
                 throw new BaseException(ResultCode.VEHICLE_IS_BOOKED);
             }
@@ -527,7 +437,7 @@ public class VehicleBiz extends BaseBiz<VehicleMapper, Vehicle> implements UserR
             BeanUtil.copyProperties(bookVehicleVo, vehicleBookRecord, CopyOptions.create().setIgnoreNullValue(true).setIgnoreError(true));
             vehicleBookRecord.setBookStartDate(startDay.toDate());
             vehicleBookRecord.setBookEndDate(endDay.toDate());
-            vehicleBookRecord.setStatus(VehicleBookRecordStatus.APPROVE.getCode());
+            vehicleBookRecord.setStatus(bookVehicleVo.getStatus());
             vehicleBookRecord.setBookUser(userId);
             vehicleBookRecord.setBookUserName(userName);
             vehicleBookRecordBiz.save(vehicleBookRecord);
@@ -539,14 +449,11 @@ public class VehicleBiz extends BaseBiz<VehicleMapper, Vehicle> implements UserR
         }
 
 //        //添加预定时间记录
-        VehicleBookRecord newValue = vehicleBookRecordBiz.selectOne(vehicleBookRecord);
-        Map<String, Integer> map = vehicleBookHourInfoBiz.getPredictableHours(bookVehicleVo.getBookStartDate(), bookVehicleVo.getBookEndDate());
         for(Map.Entry<String, Integer> entry : map.entrySet()) {
             VehicleBookHourInfoDto vehicleBookHourInfoDto = new VehicleBookHourInfoDto();
             vehicleBookHourInfoDto.setVehicleId(bookVehicleVo.getVehicleId());
             vehicleBookHourInfoDto.setYearMonthDay(entry.getKey());
             vehicleBookHourInfoDto.setBookedHour(entry.getValue());
-            vehicleBookHourInfoDto.setBookRecordId(newValue.getId());
             vehicleBookHourInfoBiz.save(vehicleBookHourInfoDto);
         }
 
@@ -574,7 +481,7 @@ public class VehicleBiz extends BaseBiz<VehicleMapper, Vehicle> implements UserR
 
 
     @Transactional
-    public Boolean applyVehicle4EmployeePerMonth(String vehicleId, List<String> bookedDates, String yearMonth){
+    public Boolean applyVehicle4EmployeePerMonth(String vehicleId, List<String> bookedDates, String yearMonth, Map<String, Integer> hourInfo){
         //检查车辆是否有空档
         //获得当月预定记录
         VehicleBookInfo vehicleBookInfo = getByVehicleIdAndYearMonth(vehicleId,yearMonth);
@@ -587,14 +494,31 @@ public class VehicleBiz extends BaseBiz<VehicleMapper, Vehicle> implements UserR
         Map<String,Integer> andOpratorParam  = yearMonthAndParam.get(yearMonth);
         Integer andOperationFactor = andOpratorParam.get("andOperationFactor");
         Integer andOperationRs = andOpratorParam.get("andOperationRs");
-        if(vehicleBookInfo!=null&&vehicleBookInfo.getBookedDate()!=null &&
+        if(vehicleBookInfo != null && vehicleBookInfo.getBookedDate() != null &&
                 ((vehicleBookInfo.getBookedDate() & andOperationFactor) != andOperationRs)){
-            return Boolean.FALSE;
+            //当天已经被预定检查小时是否也被预定
+            return filterHourInfoBooked(vehicleId, hourInfo);
         }
         return Boolean.TRUE;
     }
 
 
+    public boolean filterHourInfoBooked(String vehicleId, Map<String, Integer> hourInfo) {
+        for(Map.Entry<String, Integer> entry : hourInfo.entrySet()) {
+            VehicleBookHourInfoDto vehicleBookHourInfoDto = new VehicleBookHourInfoDto();
+            vehicleBookHourInfoDto.setYearMonthDay(entry.getKey());
+            vehicleBookHourInfoDto.setVehicleId(vehicleId);
+            List<VehicleBookHourInfo> vehicleBookHourInfos = vehicleBookHourInfoBiz.selectByVehicleAndDate(vehicleBookHourInfoDto);
+            if(vehicleBookHourInfos != null && vehicleBookHourInfos.size() >0) {
+                if((vehicleBookHourInfos.get(0).getBookedHour() & entry.getValue()) == entry.getValue()) { // 已经被预定
+                    log.info(entry.getKey() + "预定的时间段已经被预约！");
+                    return Boolean.FALSE;
+                }
+            }
+        }
+        return Boolean.TRUE;
+    }
+
     /**
      * 批准预定车辆预定
      * @param operatorId
@@ -616,24 +540,9 @@ public class VehicleBiz extends BaseBiz<VehicleMapper, Vehicle> implements UserR
         //转换为相应预定参数
         BookVehicleVO bookVehicleVo = new BookVehicleVO();
         BeanUtils.copyProperties(bookVehicleVo,vehicleBookRecord);
-        bookVehicleVo.setBookStartDate(new DateTime(vehicleBookRecord.getBookStartDate()).toString(DEFAULT_DATE_TIME_FORMATTER));
-        bookVehicleVo.setBookEndDate(new DateTime(vehicleBookRecord.getBookEndDate()).toString(DEFAULT_DATE_TIME_FORMATTER));
-//        //审核通过的话，需要修改相关车辆预定记录
-//        if(VehicleBookRecordStatus.APPROVE.getCode().equals(rsStatus)) {
-//            Boolean hasSuc = bookedVehicle(bookVehicleVo);
-//            if(!hasSuc){
-//                return RestResponse.code(ResCode.VEHICLE_BOOKED_INFO_ALREADY_CHANGED.getCode());
-//            }
-//        }
-//        //如果拒绝预定，删除预定时间记录
-//        if(VehicleBookRecordStatus.APPLY.getCode().equals(vehicleBookRecord.getStatus())) {
-//            //删除预定时间记录
-//            List<String> list = null;
-//            for( DateTime curDate = new DateTime(vehicleBookRecord.getBookStartDate());curDate.compareTo(new DateTime(vehicleBookRecord.getBookEndDate()))<=0;curDate=curDate.plusDays(1)) {
-//                list.add(curDate.toString(DEFAULT_DATE_TIME_FORMATTER));
-//            }
-//            vehicleBookHourInfoBiz.delete(vehicleBookRecord.getVehicleId(),list);
-//        }
+        bookVehicleVo.setBookStartDate(new DateTime(vehicleBookRecord.getBookStartDate()).toString(DATE_TIME_FORMATTER));
+        bookVehicleVo.setBookEndDate(new DateTime(vehicleBookRecord.getBookEndDate()).toString(DATE_TIME_FORMATTER));
+
             //成功后修改预定记录状态
             Map<String,Object> updateParam = Maps.newHashMap();
             updateParam.put("id",bookRecordId);
@@ -682,12 +591,12 @@ public class VehicleBiz extends BaseBiz<VehicleMapper, Vehicle> implements UserR
         BeanUtils.copyProperties(bookVehicleVo,vehicleBookRecord);
         bookVehicleVo.setBookStartDate(null);
         bookVehicleVo.setBookEndDate(null);
-        bookVehicleVo.setUnbookStartDate(new DateTime(vehicleBookRecord.getBookStartDate()).toString(DEFAULT_DATE_TIME_FORMATTER));
-        bookVehicleVo.setUnbookEndDate(new DateTime(vehicleBookRecord.getBookEndDate()).toString(DEFAULT_DATE_TIME_FORMATTER));
+        bookVehicleVo.setUnbookStartDate(new DateTime(vehicleBookRecord.getBookStartDate()).toString(DATE_TIME_FORMATTER));
+        bookVehicleVo.setUnbookEndDate(new DateTime(vehicleBookRecord.getBookEndDate()).toString(DATE_TIME_FORMATTER));
         //取消预定
         Boolean hasSuc = unbookVehicle(bookVehicleVo);
         if(!hasSuc){
-            return RestResponse.codeAndMessage(ResCode.VEHICLE_BOOK_RECORD_IS_NOT_EXIST.getCode(), ResCode.VEHICLE_BOOK_RECORD_IS_NOT_EXIST.getDesc());
+            return RestResponse.codeAndMessage(ResCode.VEHICLE_UNBOOK_FAIL.getCode(), ResCode.VEHICLE_UNBOOK_FAIL.getDesc());
         }
         //修改预定状态，写入取消人
         Map<String,Object> updateParam = Maps.newHashMap();
@@ -753,7 +662,6 @@ public class VehicleBiz extends BaseBiz<VehicleMapper, Vehicle> implements UserR
     public Boolean bookedVehicle( BookVehicleVO bookVehicleVo) throws Exception{
         //提取日期和相应的预定目标日期
         Map<String,List<String>> yearMonthAndDate = Maps.newHashMap();
-
         DateTime startDay =DateTime.parse(bookVehicleVo.getBookStartDate(), DATE_TIME_FORMATTER);
         DateTime endDay =DateTime.parse(bookVehicleVo.getBookEndDate(), DATE_TIME_FORMATTER);
         //转换日期范围为列表，并检查是否合法
@@ -785,11 +693,18 @@ public class VehicleBiz extends BaseBiz<VehicleMapper, Vehicle> implements UserR
         vehicleBookInfo.setVehicle(vehicleId);
         vehicleBookInfo.setYearMonth(yearMonth);
         //检查是否存在相关车辆
-        Vehicle param = new Vehicle();
-        param.setId(vehicleId);
         checkIfVehicleExists(vehicleId);
         Integer orRsOperationFactor = getBitOpratorFactor4Booked(bookedDates);//预定的相关或运算因子，当前月份没有预定记录时同时也是结果
         vehicleBookInfo.setBookedDate(orRsOperationFactor);
+        Map<String,Object> map = new HashMap<>();
+        map.put("vehicle", vehicleId);
+        map.put("yearMonth", yearMonth);
+        List<VehicleBookInfo> vehicleBookInfos = vehicleBookInfoMapper.getByVehicleIdAndYearMonth(map);
+        if(vehicleBookInfos != null && vehicleBookInfos.size() > 0) {
+            if((vehicleBookInfos.get(0).getBookedDate() & orRsOperationFactor) == orRsOperationFactor) {
+                return Boolean.TRUE;
+            }
+        }
         Integer effected = vehicleBookInfoMapper.insertIgnore(vehicleBookInfo);
         if(effected == 0){//已存在则需要更新
             Map<String,Object> params = Maps.newHashMap();
@@ -881,17 +796,17 @@ public class VehicleBiz extends BaseBiz<VehicleMapper, Vehicle> implements UserR
         //提取日期参数，改为每月一份
         //提取日期和相应的预定目标日期
         Map<String,List<String>> yearMonthAndDate = Maps.newHashMap();
-        DateTime startDay =DateTime.parse(bookVehicleVo.getUnbookStartDate(), DEFAULT_DATE_TIME_FORMATTER);
-        DateTime endDay =DateTime.parse(bookVehicleVo.getUnbookEndDate(), DEFAULT_DATE_TIME_FORMATTER);
+        DateTime startDay =DateTime.parse(bookVehicleVo.getUnbookStartDate(), DATE_TIME_FORMATTER);
+        DateTime endDay =DateTime.parse(bookVehicleVo.getUnbookEndDate(), DATE_TIME_FORMATTER);
         //转换日期范围为列表，并检查是否合法
         uinbookDateList4DatePeriod(yearMonthAndDate,startDay,endDay);
-
+        Map<String, Integer> map = vehicleBookHourInfoBiz.getPredictableHours(bookVehicleVo.getUnbookStartDate(), bookVehicleVo.getUnbookEndDate());
         if(yearMonthAndDate.size()>3){//连续的日期最多夸3个月
             throw new BaseException(ResultCode.ONLY_UNBOOK_TWO_MONTH);
         }
         Boolean rs = Boolean.TRUE;
         for(Map.Entry<String,List<String>> entry:yearMonthAndDate.entrySet()){
-            Boolean rsEach = unbookVehiclePerMonth(bookVehicleVo.getVehicleId(),entry.getValue(),entry.getKey());
+            Boolean rsEach = unbookVehiclePerMonth(bookVehicleVo.getVehicleId(),entry.getValue(),entry.getKey(), map);
             if(Boolean.FALSE.equals(rsEach)){
                 rs = Boolean.FALSE;
                 TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();//手动回滚
@@ -900,8 +815,9 @@ public class VehicleBiz extends BaseBiz<VehicleMapper, Vehicle> implements UserR
         return rs;
     }
 
+
     @Transactional
-    public Boolean unbookVehiclePerMonth(String vehicleId, List<String> unbookDates, String yearMonth){
+    public Boolean unbookVehiclePerMonth(String vehicleId, List<String> unbookDates, String yearMonth, Map<String, Integer> hourInfo){
         checkIfVehicleExists(vehicleId);
         Map<String,Object> params = Maps.newHashMap();
         params.put("vehicleId",vehicleId);
@@ -921,10 +837,34 @@ public class VehicleBiz extends BaseBiz<VehicleMapper, Vehicle> implements UserR
         Integer andRsOperationFactor = getBitOpratorFactor4UnBooked(unbookDates);//预定的相关或运算因子，当前月份没有预定记录时同时也是结果
         params.put("andRsOperationFactor",
                 andRsOperationFactor);
-        Integer effected = vehicleBookInfoMapper.updateBookedInfo(params);
-        return effected>0?Boolean.TRUE:Boolean.FALSE;
+        if(hourInfo.size() == 1) { //取消当天的小时，不取消当天的预定
+            return unbookHourInfo(vehicleId, hourInfo);
+        } else {
+            Integer effected = vehicleBookInfoMapper.updateBookedInfo(params);
+                return unbookHourInfo(vehicleId, hourInfo);
+        }
     }
 
+    public boolean unbookHourInfo(String vehicleId, Map<String, Integer> hourInfo) {
+        for (Map.Entry<String, Integer> entry : hourInfo.entrySet()) {
+            VehicleBookHourInfoDto vehicleBookHourInfoDto = new VehicleBookHourInfoDto();
+            vehicleBookHourInfoDto.setYearMonthDay(entry.getKey());
+            vehicleBookHourInfoDto.setVehicleId(vehicleId);
+            List<VehicleBookHourInfo> vehicleBookHourInfos = vehicleBookHourInfoBiz.selectByVehicleAndDate(vehicleBookHourInfoDto);
+            if (vehicleBookHourInfos != null && vehicleBookHourInfos.size() > 0) {
+                vehicleBookHourInfos.get(0).setBookedHour((vehicleBookHourInfos.get(0).getBookedHour() & ~entry.getValue()));
+                int effect = vehicleBookHourInfoBiz.updateByIdRe(vehicleBookHourInfos.get(0));
+                if (effect < 1) {
+                    return Boolean.FALSE;
+                } else {
+                    continue;
+                }
+            } else {
+                return Boolean.FALSE;
+            }
+        }
+        return Boolean.TRUE;
+    }
 
     /**
      * 获取某月份相应预定日期查询条件

xx-vehicle/xx-vehicle-server/src/main/java/com/xxfc/platform/vehicle/biz/VehicleBookHourInfoBiz.java

@@ -31,7 +31,7 @@ public class VehicleBookHourInfoBiz extends BaseBiz<VehicleBookHourInfoMapper, V
     public static final DateTimeFormatter DEFAULT_DATE_TIME_FORMATTER = DateTimeFormat.forPattern("yyyy-MM-dd HH:mm:ss");
     public static final DateTimeFormatter DATE_TIME_FORMATTER = DateTimeFormat.forPattern("yyyy-MM-dd");
 
-    public static  Map<String, Integer>  getPredictableHours(String bookStartDate, String bookEndDate) {
+    public  Map<String, Integer>  getPredictableHours(String bookStartDate, String bookEndDate) {
         SimpleDateFormat simpleDateFormat = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
         Date startDate = null;
         Date endDate = null;
@@ -68,12 +68,14 @@ public class VehicleBookHourInfoBiz extends BaseBiz<VehicleBookHourInfoMapper, V
                 endPredictableHour |= 1 << (curentHour);
             }
         }
-
-        predictableHours.put(DateTime.parse(bookStartDate, DEFAULT_DATE_TIME_FORMATTER).toString(DATE_TIME_FORMATTER), startPredictableHour);
-        predictableHours.put(DateTime.parse(bookEndDate, DEFAULT_DATE_TIME_FORMATTER).toString(DATE_TIME_FORMATTER), endPredictableHour);
+        if(DateTime.parse(bookStartDate, DEFAULT_DATE_TIME_FORMATTER).toString(DATE_TIME_FORMATTER).equals(DateTime.parse(bookEndDate, DEFAULT_DATE_TIME_FORMATTER).toString(DATE_TIME_FORMATTER))) {//同一天预定
+            predictableHours.put(DateTime.parse(bookStartDate, DEFAULT_DATE_TIME_FORMATTER).toString(DATE_TIME_FORMATTER), startPredictableHour & endPredictableHour);
+        } else {
+            predictableHours.put(DateTime.parse(bookStartDate, DEFAULT_DATE_TIME_FORMATTER).toString(DATE_TIME_FORMATTER), startPredictableHour);
+            predictableHours.put(DateTime.parse(bookEndDate, DEFAULT_DATE_TIME_FORMATTER).toString(DATE_TIME_FORMATTER), endPredictableHour);
+        }
         DateTime startDay = DateTime.parse(DateTime.parse(bookStartDate, DEFAULT_DATE_TIME_FORMATTER).toString(DATE_TIME_FORMATTER), DATE_TIME_FORMATTER);
         DateTime endDay = DateTime.parse(DateTime.parse(bookEndDate, DEFAULT_DATE_TIME_FORMATTER).toString(DATE_TIME_FORMATTER), DATE_TIME_FORMATTER);
-
         if(endDay.getDayOfMonth() - startDay.getDayOfMonth() >1){ //
             for (DateTime curDate = startDay.plusDays(1); curDate.compareTo(endDay) < 0; curDate = curDate.plusDays(1)) {
                 String curDateStr = curDate.toString(DATE_TIME_FORMATTER);
@@ -143,18 +145,9 @@ public class VehicleBookHourInfoBiz extends BaseBiz<VehicleBookHourInfoMapper, V
     }
 
     public static void main(String[] args) throws Exception{
-        String result = Integer.toBinaryString(16777200);
-        String newString = new StringBuilder(result).reverse().toString();
-        int i=newString.length()-result.replace("1", "").length();
-       System.out.println(i);
-
-        Map<String, Integer> map = getPredictableHours("2019-07-28 00:00:00","2019-07-29 00:00:00");
-        for (Map.Entry<String, Integer> entry : map.entrySet()) {
-            log.info(entry.getKey());
-            log.info(entry.getValue() + "");
-        }
-
-
+        int b = 16744448;
+        Integer a = b | 31;
+        System.out.println(a);
     }
 
 }

xx-vehicle/xx-vehicle-server/src/main/java/com/xxfc/platform/vehicle/biz/VehicleBookRecordBiz.java

@@ -299,7 +299,9 @@ public class VehicleBookRecordBiz extends BaseBiz<VehicleBookRecordMapper, Vehic
         return PageDataVO.pageInfo(vehiclePageInfo);
     }
 
-
+    public List<VehicleBookRecordVo> selectByVehicleId(String vehicleId) {
+        return mapper.selectByVehicleId(vehicleId);
+    }
 
 
     /**

xx-vehicle/xx-vehicle-server/src/main/java/com/xxfc/platform/vehicle/biz/VehicleWarningMsgBiz.java

@@ -4,6 +4,9 @@ import com.alibaba.fastjson.JSON;
 import com.alibaba.fastjson.JSONException;
 import com.github.pagehelper.PageHelper;
 import com.github.pagehelper.PageInfo;
+import com.github.wxiaoqi.security.admin.feign.UserFeign;
+import com.github.wxiaoqi.security.admin.feign.dto.UserDTO;
+import com.github.wxiaoqi.security.admin.feign.rest.UserRestInterface;
 import com.github.wxiaoqi.security.common.biz.BaseBiz;
 import com.github.wxiaoqi.security.common.vo.PageDataVO;
 import com.google.common.collect.Maps;
@@ -44,7 +47,7 @@ import java.util.concurrent.TimeUnit;
 
 @Slf4j
 @Service
-public class VehicleWarningMsgBiz extends BaseBiz<VehicleWarningMsgMapper, VehicleWarningMsg> {
+public class VehicleWarningMsgBiz extends BaseBiz<VehicleWarningMsgMapper, VehicleWarningMsg> implements UserRestInterface {
 
 
     private static final Integer CHECK_BATCH_SIZE_VEHICLE = 100;//每批次检查多少辆车
@@ -67,7 +70,15 @@ public class VehicleWarningMsgBiz extends BaseBiz<VehicleWarningMsgMapper, Vehic
 
     @Autowired
     private RedisTemplate customRedisTemplate;
+    @Autowired
+    UserFeign userFeign;
+    @Autowired
+    VehicleBiz vehicleBiz;
 
+    @Override
+    public UserFeign getUserFeign() {
+        return userFeign;
+    }
     /**
      * 增加自定义预警消息
      * @param addVehicleWarningMsgVo
@@ -94,7 +105,18 @@ public class VehicleWarningMsgBiz extends BaseBiz<VehicleWarningMsgMapper, Vehic
         try {
             QueryVehicleWarningMsgVo queryVehicleWarningMsgVo = JSON.parseObject(queryVehicleWarningMsgVoJson, QueryVehicleWarningMsgVo.class);
             PageHelper.startPage(queryVehicleWarningMsgVo.getPage(),queryVehicleWarningMsgVo.getLimit());
-            List<VehicleWarningMsg> vehicleWarningMsgs = mapper.getByPages(queryVehicleWarningMsgVo);
+            UserDTO userDTO = getAdminUserInfo();
+            if (userDTO != null) {
+                if (userDTO.getDataAll() == 2) {
+                    List<Integer> companyList = vehicleBiz.dataCompany(userDTO.getDataZone(), userDTO.getDataCompany());
+                    if(companyList != null && companyList.size() > 0) {
+                        queryVehicleWarningMsgVo.setCompanyIds(companyList);
+                    }
+                }
+            } else {
+                return RestResponse.codeAndMessage(1032,"token失效");
+            }
+            List<VehicleWarningMsg> vehicleWarningMsgs = mapper.getByPage(queryVehicleWarningMsgVo);
             PageInfo<VehicleWarningMsg> vehicleWarningMsgPageInfo = new PageInfo<>(vehicleWarningMsgs);
             return RestResponse.data(PageDataVO.pageInfo(vehicleWarningMsgPageInfo));
         } catch (JSONException ex) {
@@ -230,4 +252,5 @@ public class VehicleWarningMsgBiz extends BaseBiz<VehicleWarningMsgMapper, Vehic
         return list;
     }
 
+
 }

xx-vehicle/xx-vehicle-server/src/main/java/com/xxfc/platform/vehicle/mapper/VehicleBookRecordMapper.java

@@ -30,7 +30,7 @@ public interface VehicleBookRecordMapper extends Mapper<VehicleBookRecord> {
 
     public List<VehicleRecordInfoVo> getByParam(Map<String, Object> params);
 
-    public List<VehicleBookRecord> getByVehicleId(String vehicleId);
+    public List<VehicleBookRecordVo> selectByVehicleId(String vehicleId);
 
     public List<VehicleBookRecordVo> getBookRecord(VehicleBookRecordQueryVo vehicleBookRecordQueryVo);
 

xx-vehicle/xx-vehicle-server/src/main/java/com/xxfc/platform/vehicle/rest/RentVehicleController.java

+package com.xxfc.platform.vehicle.rest;
+
+import cn.hutool.core.bean.BeanUtil;
+import com.alibaba.fastjson.JSON;
+import com.alibaba.fastjson.JSONException;
+import com.github.wxiaoqi.security.admin.feign.UserFeign;
+import com.github.wxiaoqi.security.admin.feign.dto.UserDTO;
+import com.github.wxiaoqi.security.admin.feign.rest.UserRestInterface;
+import com.github.wxiaoqi.security.auth.client.annotation.IgnoreClientToken;
+import com.github.wxiaoqi.security.auth.client.annotation.IgnoreUserToken;
+import com.github.wxiaoqi.security.auth.client.config.UserAuthConfig;
+import com.github.wxiaoqi.security.common.context.BaseContextHandler;
+import com.github.wxiaoqi.security.common.exception.BaseException;
+import com.github.wxiaoqi.security.common.msg.ObjectRestResponse;
+import com.github.wxiaoqi.security.common.util.process.ResultCode;
+import com.github.wxiaoqi.security.common.vo.PageDataVO;
+import com.google.common.collect.Lists;
+import com.google.common.collect.Maps;
+import com.xxfc.platform.vehicle.biz.*;
+import com.xxfc.platform.vehicle.common.BaseController;
+import com.xxfc.platform.vehicle.common.CustomIllegalParamException;
+import com.xxfc.platform.vehicle.common.RestResponse;
+import com.xxfc.platform.vehicle.constant.BookType;
+import com.xxfc.platform.vehicle.constant.ResCode.ResCode;
+import com.xxfc.platform.vehicle.constant.VehicleBookRecordStatus;
+import com.xxfc.platform.vehicle.entity.BranchCompany;
+import com.xxfc.platform.vehicle.entity.Vehicle;
+import com.xxfc.platform.vehicle.entity.VehicleBookInfo;
+import com.xxfc.platform.vehicle.entity.VehicleBookRecord;
+import com.xxfc.platform.vehicle.jobhandler.VehicleJobHandler;
+import com.xxfc.platform.vehicle.pojo.*;
+import com.xxfc.platform.vehicle.pojo.dto.VehiclePlanDto;
+import io.swagger.annotations.Api;
+import io.swagger.annotations.ApiOperation;
+import lombok.extern.slf4j.Slf4j;
+import org.apache.commons.lang3.StringUtils;
+import org.joda.time.DateTime;
+import org.joda.time.format.DateTimeFormat;
+import org.joda.time.format.DateTimeFormatter;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.http.ResponseEntity;
+import org.springframework.web.bind.annotation.*;
+import org.springframework.web.multipart.MultipartFile;
+
+import java.util.ArrayList;
+import java.util.HashSet;
+import java.util.List;
+import java.util.Map;
+import java.util.stream.Collectors;
+
+import static com.xxfc.platform.vehicle.constant.VehicleConstant.USER_APP;
+import static com.xxfc.platform.vehicle.constant.VehicleConstant.USER_APP_NAME;
+
+@RestController
+@RequestMapping("/vehicleInfo")
+@Slf4j
+@IgnoreClientToken
+@Api(value="租车相关车辆管理controller",tags={"租车相关车辆管理接口"})
+public class RentVehicleController extends BaseController<VehicleBiz> implements UserRestInterface {
+
+    @Autowired
+    private VehiclePlatCataBiz vehiclePlatCataBiz;
+
+    @Autowired
+    UserFeign userFeign;
+
+    @Autowired
+    VehicleBiz vehicleBiz;
+
+    public UserFeign getUserFeign() {
+        return userFeign;
+    }
+
+    /**
+     * 租车拒绝预定车辆申请
+     *
+     * @param bookRecordId
+     * @return
+     */
+    @RequestMapping(value = "/rent/book/reject/{bookRecordId}", method = RequestMethod.PUT)
+    @ApiOperation(value = "租车拒绝预定车辆")
+    @IgnoreUserToken
+    public RestResponse<Integer> rentRejectVehicleBooking(@PathVariable Long bookRecordId) throws Exception {
+        //默认USER_APP 预约
+        Integer operatorId = USER_APP;
+        String userName = USER_APP_NAME;
+        return baseBiz.reviewVehicleBooking(operatorId, bookRecordId, VehicleBookRecordStatus.REJECTED.getCode(), userName);
+    }
+
+    /**
+     * 取消车辆预订
+     *
+     * @param bookRecordId
+     * @return
+     */
+    @RequestMapping(value = "/rent/unbook/{bookRecordId}", method = RequestMethod.DELETE)
+    @ApiOperation(value = "取消预定车辆")
+    public RestResponse<Integer> rentUnbookVehicle(@PathVariable Long bookRecordId) throws Exception {
+        //默认USER_APP 预约
+        Integer operatorId = USER_APP;
+        String userName = USER_APP_NAME;
+        return baseBiz.unbookVehicle4Employee(operatorId, bookRecordId, userName);
+    }
+
+    /**
+     * 批准预定车辆预定
+     *
+     * @param bookRecordId
+     * @return
+     */
+    @RequestMapping(value = "/rent/book/prove/{bookRecordId}", method = RequestMethod.PUT)
+    @ApiOperation(value = "预定车辆审核通过")
+    public RestResponse<Integer> rentProveVehicleBooking(@PathVariable Long bookRecordId) throws Exception {
+        //默认USER_APP 预约
+        Integer operatorId = USER_APP;
+        String userName = USER_APP_NAME;
+        return baseBiz.reviewVehicleBooking(operatorId, bookRecordId, VehicleBookRecordStatus.APPROVE.getCode(), userName);
+    }
+
+    /**
+     * 可用车辆查询
+     *
+     * @param dto
+     * @return
+     */
+    @ApiOperation("可用车辆查询")
+    @RequestMapping(value = "/rent/usable-vehicle", method = RequestMethod.GET)
+    @IgnoreUserToken
+    public ObjectRestResponse<PageDataVO<UsableVehicleModelVO>> rentUsableVehicle(UsableVeicleDTO dto) throws Exception {
+        //根据时间 获得 可用车辆
+        //结合车型
+        if (StringUtils.isNotBlank(dto.getCatasStr())) {
+            dto.setCatas(vehiclePlatCataBiz.groupCatasByParent(dto.getCatasStr()));
+        }
+        //设置显示是否有车
+        dto.setYearNo4Where(Boolean.TRUE);
+        return ObjectRestResponse.succ(vehicleBiz.searchUsableModel(dto));
+    }
+
+    /**
+     * 热门车型
+     *
+     * @param dto
+     * @return
+     */
+    @ApiOperation("热门车型")
+    @RequestMapping(value = "/rent/hot-vehicle", method = RequestMethod.GET)
+    @IgnoreUserToken
+    public ObjectRestResponse<PageDataVO<UsableVehicleModelVO>> hotVehicle(HotVeicleDTO dto) throws Exception {
+        return ObjectRestResponse.succ(vehicleBiz.hotModel(dto));
+    }
+
+    /**
+     * 租车触发的申请预定车辆
+     *
+     * @param dto
+     * @return
+     */
+    @ApiOperation("租车触发的申请预定车辆")
+    @RequestMapping(value = "/rent/book/vehicle", method = RequestMethod.POST)
+    @IgnoreClientToken
+    @IgnoreUserToken
+    public ObjectRestResponse<VehicleBookRecord> rentApplyVehicle(@RequestBody RentVehicleBookDTO dto) throws Exception {
+        //默认USER_APP 预约
+        Integer operatorId = USER_APP;
+        String userName = dto.getUserName();
+        //BaseContextHandler.getName();
+        dto.setLimit(1);
+        dto.setPage(1);
+        //查询可车辆信息
+        PageDataVO<Vehicle> pageDataVO = vehicleBiz.searchUsableVehicle(dto);
+        if (pageDataVO.getData().size() <= 0) {
+            throw new BaseException(ResultCode.NOTEXIST_CODE, new HashSet<String>(){{
+                add("可用车辆不存在");
+            }});
+        }
+        dto.setBookStartDate(dto.getBookStartDate()+ " 00:00:00");
+        dto.setBookEndDate(dto.getBookEndDate()+ " 23:59:59");
+        BookVehicleVO bookVehicleVo = BeanUtil.toBean(dto, BookVehicleVO.class);
+        bookVehicleVo.setBookType(BookType.USER_RENT.getCode());
+        bookVehicleVo.setVehicleId(pageDataVO.getData().get(0).getId());
+        bookVehicleVo.setStatus(VehicleBookRecordStatus.APPLY.getCode());
+        VehicleBookRecord vehicleBookRecord = baseBiz.applyVehicle(operatorId, bookVehicleVo, userName);
+        return ObjectRestResponse.succ(vehicleBookRecord);
+    }
+}

xx-vehicle/xx-vehicle-server/src/main/java/com/xxfc/platform/vehicle/rest/VehicleController.java

@@ -5,6 +5,7 @@ import com.alibaba.fastjson.JSON;
 import com.alibaba.fastjson.JSONException;
 import com.github.wxiaoqi.security.admin.feign.UserFeign;
 import com.github.wxiaoqi.security.admin.feign.dto.UserDTO;
+import com.github.wxiaoqi.security.admin.feign.rest.UserRestInterface;
 import com.github.wxiaoqi.security.auth.client.annotation.IgnoreClientToken;
 import com.github.wxiaoqi.security.auth.client.annotation.IgnoreUserToken;
 import com.github.wxiaoqi.security.auth.client.config.UserAuthConfig;
@@ -13,17 +14,16 @@ import com.github.wxiaoqi.security.common.exception.BaseException;
 import com.github.wxiaoqi.security.common.msg.ObjectRestResponse;
 import com.github.wxiaoqi.security.common.util.process.ResultCode;
 import com.github.wxiaoqi.security.common.vo.PageDataVO;
+import com.google.common.collect.Lists;
 import com.google.common.collect.Maps;
-import com.xxfc.platform.vehicle.biz.VehicleBiz;
-import com.xxfc.platform.vehicle.biz.VehicleBookRecordBiz;
-import com.xxfc.platform.vehicle.biz.VehiclePlatCataBiz;
-import com.xxfc.platform.vehicle.biz.VehicleWarningMsgBiz;
+import com.xxfc.platform.vehicle.biz.*;
 import com.xxfc.platform.vehicle.common.BaseController;
 import com.xxfc.platform.vehicle.common.CustomIllegalParamException;
 import com.xxfc.platform.vehicle.common.RestResponse;
 import com.xxfc.platform.vehicle.constant.BookType;
 import com.xxfc.platform.vehicle.constant.ResCode.ResCode;
 import com.xxfc.platform.vehicle.constant.VehicleBookRecordStatus;
+import com.xxfc.platform.vehicle.entity.BranchCompany;
 import com.xxfc.platform.vehicle.entity.Vehicle;
 import com.xxfc.platform.vehicle.entity.VehicleBookInfo;
 import com.xxfc.platform.vehicle.entity.VehicleBookRecord;
@@ -46,6 +46,7 @@ import java.util.ArrayList;
 import java.util.HashSet;
 import java.util.List;
 import java.util.Map;
+import java.util.stream.Collectors;
 
 import static com.xxfc.platform.vehicle.constant.VehicleConstant.USER_APP;
 import static com.xxfc.platform.vehicle.constant.VehicleConstant.USER_APP_NAME;
@@ -55,7 +56,7 @@ import static com.xxfc.platform.vehicle.constant.VehicleConstant.USER_APP_NAME;
 @Slf4j
 @IgnoreClientToken
 @Api(value="车辆管理controller",tags={"车辆管理接口"})
-public class VehicleController extends BaseController<VehicleBiz> {
+public class VehicleController extends BaseController<VehicleBiz> implements UserRestInterface {
 
     @Autowired
     private VehicleBookRecordBiz vehicleBookRecordBiz;
@@ -78,7 +79,11 @@ public class VehicleController extends BaseController<VehicleBiz> {
     @Autowired
     private VehicleJobHandler vehicleJobHandler;
 
-
+    @Autowired
+    BranchCompanyBiz branchCompanyBiz;
+    public UserFeign getUserFeign() {
+        return userFeign;
+    }
     private static Integer MAX_DRIVING_LICENSE_SIZE = 10 * 1024 * 1024;//10M
 
     public static final DateTimeFormatter DEFAULT_FORMATTER = DateTimeFormat.forPattern("yyyy-MM-dd HH:mm:ss");
@@ -213,6 +218,7 @@ public class VehicleController extends BaseController<VehicleBiz> {
     public RestResponse<Integer> applyVehicle(@RequestBody  BookVehicleVO bookVehicleVo) throws Exception {
         Integer operatorId = Integer.parseInt(BaseContextHandler.getUserID());
         String userName = BaseContextHandler.getName();
+        bookVehicleVo.setStatus(VehicleBookRecordStatus.APPLY.getCode());
         baseBiz.applyVehicle(operatorId, bookVehicleVo, userName);
         return RestResponse.suc();
     }
@@ -228,7 +234,8 @@ public class VehicleController extends BaseController<VehicleBiz> {
     public RestResponse<Integer> applyForVehicle(@RequestBody  BookVehicleVO bookVehicleVo) throws Exception {
         Integer operatorId = Integer.parseInt(BaseContextHandler.getUserID());
         String userName = BaseContextHandler.getName();
-        baseBiz.applyForVehicle(operatorId, bookVehicleVo, userName);
+        bookVehicleVo.setStatus(VehicleBookRecordStatus.APPLY.getCode());
+        baseBiz.applyVehicle(operatorId, bookVehicleVo, userName);
         return RestResponse.suc();
     }
 
@@ -260,23 +267,6 @@ public class VehicleController extends BaseController<VehicleBiz> {
         return baseBiz.reviewVehicleBooking(operatorId, bookRecordId, VehicleBookRecordStatus.REJECTED.getCode(), userName);
     }
 
-    /**
-     * 租车拒绝预定车辆申请
-     *
-     * @param bookRecordId
-     * @return
-     */
-    @RequestMapping(value = "/rent/book/reject/{bookRecordId}", method = RequestMethod.PUT)
-    @ApiOperation(value = "租车拒绝预定车辆")
-    @IgnoreUserToken
-    public RestResponse<Integer> rentRejectVehicleBooking(@PathVariable Long bookRecordId) throws Exception {
-        //默认USER_APP 预约
-        Integer operatorId = USER_APP;
-        String userName = USER_APP_NAME;
-        return baseBiz.reviewVehicleBooking(operatorId, bookRecordId, VehicleBookRecordStatus.REJECTED.getCode(), userName);
-    }
-
-
 //    /**
 //     * 车辆归还
 //     * @param bookRecordId
@@ -370,86 +360,45 @@ public class VehicleController extends BaseController<VehicleBiz> {
         return vehicleBookRecordBiz.retVehicle(operatorId, userName, retVehicleVo);
     }
 
-    /**
-     * 可用车辆查询
-     *
-     * @param dto
-     * @return
-     */
-    @ApiOperation("可用车辆查询")
-    @RequestMapping(value = "/rent/usable-vehicle", method = RequestMethod.GET)
-    @IgnoreUserToken
-    public ObjectRestResponse<PageDataVO<UsableVehicleModelVO>> rentUsableVehicle(UsableVeicleDTO dto) throws Exception {
-        //根据时间 获得 可用车辆
-        //结合车型
-        if (StringUtils.isNotBlank(dto.getCatasStr())) {
-            dto.setCatas(vehiclePlatCataBiz.groupCatasByParent(dto.getCatasStr()));
-        }
-        //设置显示是否有车
-        dto.setYearNo4Where(Boolean.TRUE);
-        return ObjectRestResponse.succ(vehicleBiz.searchUsableModel(dto));
-    }
-
     @ApiOperation("根据权限获取所有车辆")
     @GetMapping(value = "/info/getVehicle")
     public ObjectRestResponse<PageDataVO<VehicleAndModelInfoVo>> getVehicle(VehiclePlanDto vehiclePlanDto) {
         return vehicleBiz.getVehicle(vehiclePlanDto);
     }
 
-
-
-    /**
-     * 热门车型
-     *
-     * @param dto
-     * @return
-     */
-    @ApiOperation("热门车型")
-    @RequestMapping(value = "/rent/hot-vehicle", method = RequestMethod.GET)
-    @IgnoreUserToken
-    public ObjectRestResponse<PageDataVO<UsableVehicleModelVO>> hotVehicle(HotVeicleDTO dto) throws Exception {
-        return ObjectRestResponse.succ(vehicleBiz.hotModel(dto));
-    }
-
-    /**
-     * 租车触发的申请预定车辆
-     *
-     * @param dto
-     * @return
-     */
-    @ApiOperation("租车触发的申请预定车辆")
-    @RequestMapping(value = "/rent/book/vehicle", method = RequestMethod.POST)
-    @IgnoreClientToken
-    @IgnoreUserToken
-    public ObjectRestResponse<VehicleBookRecord> rentApplyVehicle(@RequestBody RentVehicleBookDTO dto) throws Exception {
-        //默认USER_APP 预约
-        Integer operatorId = USER_APP;
-        String userName = dto.getUserName();
-        //BaseContextHandler.getName();
-        dto.setLimit(1);
-        dto.setPage(1);
-        //查询可车辆信息
-        PageDataVO<Vehicle> pageDataVO = vehicleBiz.searchUsableVehicle(dto);
-        if (pageDataVO.getData().size() <= 0) {
-            throw new BaseException(ResultCode.NOTEXIST_CODE, new HashSet<String>(){{
-                add("可用车辆不存在");
-            }});
-        }
-        dto.setBookStartDate(dto.getBookStartDate()+ " 00:00:00");
-        dto.setBookEndDate(dto.getBookEndDate()+ " 23:59:59");
-        BookVehicleVO bookVehicleVo = BeanUtil.toBean(dto, BookVehicleVO.class);
-        bookVehicleVo.setBookType(BookType.USER_RENT.getCode());
-        bookVehicleVo.setVehicleId(pageDataVO.getData().get(0).getId());
-        VehicleBookRecord vehicleBookRecord = baseBiz.applyVehicle4Employee(operatorId, bookVehicleVo, userName);
-        return ObjectRestResponse.succ(vehicleBookRecord);
-    }
-
-
     @RequestMapping(value = "/app/unauth/getVehiclePlanList", method = RequestMethod.GET)
     @ApiOperation(value = "获取排车信息")
     @IgnoreClientToken
     @IgnoreUserToken
     public ObjectRestResponse<Map<String, Object>> getVehiclePlanList(VehiclePlanDto vehiclePlanDto) {
+        UserDTO userDTO = getAdminUserInfo();
+        if(userDTO == null) {
+            return ObjectRestResponse.createFailedResult(ResultCode.RSTOKEN_EXPIRED_CODE, "token失效");
+        }
+        List<Integer> companyList =  Lists.newArrayList();
+        List<BranchCompany> branchCompany = branchCompanyBiz.getListByUser(userDTO);
+        companyList = branchCompany.stream().map(BranchCompany::getId).collect(Collectors.toList());
+        if(vehiclePlanDto.getParkBranchCompanyId() != null) {
+            if(companyList.size() > 0) {
+                if(companyList.contains(vehiclePlanDto.getParkBranchCompanyId())) {
+                    companyList.clear();
+                    companyList.add(vehiclePlanDto.getParkBranchCompanyId());
+                } else {
+                    return ObjectRestResponse.succ();
+                }
+            }
+        }
+        if(vehiclePlanDto.getSubordinateBranch() != null) {
+            if(companyList.size() > 0) {
+                if(companyList.contains(vehiclePlanDto.getSubordinateBranch())) {
+                    companyList.clear();
+                    companyList.add(vehiclePlanDto.getSubordinateBranch());
+                } else {
+                    return ObjectRestResponse.succ();
+                }
+            }
+        }
+        vehiclePlanDto.setCompanyIds(companyList);
         //获取列表
         PageDataVO<VehicleAndModelInfoVo> pageDataVO = baseBiz.getAllVehicle(vehiclePlanDto);
         //获取警告信息

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

@@ -367,11 +367,9 @@
     </select>
     <select id="getByVehicleId" parameterType="java.lang.String"
             resultType="com.xxfc.platform.vehicle.pojo.VehicleBookRecordVo">
-       SELECT v1.*, conv(v2.booked_hour,10,2) startHour,conv(v3.booked_hour,10,2) endHour,bc2.name retCompanyName from vehicle_book_record v1
-        LEFT JOIN vehicle_book_hour_info v2 on v2.book_record_id = v1.id and YEAR(v2.year_month_day) = YEAR(v1.book_start_date) AND MONTH(v2.year_month_day) = MONTH(v1.book_start_date) AND DAY(v2.year_month_day) =DAY(v1.book_start_date)
-        LEFT JOIN vehicle_book_hour_info v3 on v3.book_record_id = v1.id and YEAR(v3.year_month_day) = YEAR(v1.book_end_date) AND MONTH(v3.year_month_day) = MONTH(v1.book_end_date) AND DAY(v3.year_month_day) =DAY(v1.book_end_date)
-        LEFT JOIN branch_company bc2 on v1.ret_company = bc2.id
-        where v1.vehicle_id = #{vehicleId} and v1.status BETWEEN 1 and 2  and v1.book_end_date
+       SELECT v1.*,bc2.name retCompanyName from vehicle_book_record v1
+               LEFT JOIN branch_company bc2 on v1.ret_company = bc2.id
+        where v1.vehicle_id = #{vehicleId} and v1.status BETWEEN 1 and 2
     </select>
     <select id="getByParam" parameterType="java.util.Map" resultMap="getVehicleMap">
         select v1.* from vehicle_book_record v1

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

@@ -380,16 +380,16 @@
             <if test="status != null">
                 and v1.status = #{status}
             </if>
-            <if test="subordinateBranch != null">
-                and v1.subordinate_branch = #{subordinateBranch}
-            </if>
-            <if test="parkBranchCompanyId != null">
-                and v1.park_branch_company_id = #{parkBranchCompanyId}
+            <if test="companyIds != null and companyIds.size > 0">
+                and v1.park_branch_company_id in
+                <foreach collection="companyIds" item="id" open="(" separator="," close=")">
+                    #{id}
+                </foreach>
             </if>
             <if test="zoneId !=null">
                 and bc2.zone_id = #{zoneId}
             </if>
-            and is_del != 1
+            and v1.is_del != 1
         </where>
     </select>
 
@@ -397,7 +397,7 @@
         select v1.*,bc3.name parkCompanyName  from vehicle v1
         LEFT JOIN branch_company bc3 ON v1.park_branch_company_id = bc3.id
        <where>
-           <if test="numberPlate != null">
+           <if test="numberPlate != null and numberPlate != ''">
                and v1.number_plate = #{numberPlate}
            </if>
            <if test="companyIds != null and companyIds.size > 0">
@@ -412,7 +412,7 @@
                    #{id}
                </foreach>
            </if>
-           and is_del != 1
+           and v1.is_del != 1
        </where>
         ORDER BY parkCompanyName
     </select>
@@ -455,21 +455,19 @@
             <if test="startTime != null">
                 and v1.create_time between #{startTime} and #{endTime}
             </if>
-            <if test="numberPlate != null">
+            <if test="numberPlate != null and numberPlate != ''">
                 and v1.number_plate = #{numberPlate}
             </if>
             <if test="status != null">
                 and v1.status = #{status}
             </if>
-            <if test="subordinateBranch != null">
-                and v1.subordinate_branch = #{subordinateBranch}
-            </if>
-            <if test="parkBranchCompanyId != null">
-                and v1.park_branch_company_id = #{parkBranchCompanyId}
-            </if>
-            <if test="zoneId !=null">
-                and bc1.zone_id = #{zoneId}
+            <if test="companyIds != null and companyIds.size > 0">
+                and v1.park_branch_company_id in
+                <foreach collection="companyIds" item="id" open="(" separator="," close=")">
+                    #{id}
+                </foreach>
             </if>
+            and v1.is_del != 1
         </where>
         GROUP BY v1.status
         union all
@@ -480,21 +478,19 @@
             <if test="startTime != null">
                 and v2.create_time between #{startTime} and #{endTime}
             </if>
-            <if test="numberPlate != null">
+            <if test="numberPlate != null and numberPlate != ''">
                 and v2.number_plate = #{numberPlate}
             </if>
             <if test="status != null">
                 and v2.status = #{status}
             </if>
-            <if test="subordinateBranch != null">
-                and v2.subordinate_branch = #{subordinateBranch}
-            </if>
-            <if test="parkBranchCompanyId != null">
-                and v2.park_branch_company_id = #{parkBranchCompanyId}
-            </if>
-            <if test="zoneId !=null">
-                and bc2.zone_id = #{zoneId}
+            <if test="companyIds != null and companyIds.size > 0">
+                and v2.park_branch_company_id in
+                <foreach collection="companyIds" item="id" open="(" separator="," close=")">
+                    #{id}
+                </foreach>
             </if>
+            and v2.is_del != 1
         </where>
     </select>
 

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

@@ -22,9 +22,17 @@
             and v.number_plate = #{numberPlate}
         </if>
         <if test="type != null">
-            and type = #{type}
+            and vwn.type = #{type}
+        </if>
+        <if test="colorType != null">
+            and vwn.color_type = #{colorType}
+        </if>
+        <if test="companyIds != null and companyIds.size > 0">
+            and v.park_branch_company_id in
+            <foreach collection="companyIds" item="id" open="(" separator="," close=")">
+                #{id}
+            </foreach>
         </if>
-
     </select>
 
     <select id="getMsgByVehicle" parameterType="java.util.Map" resultType="com.xxfc.platform.vehicle.entity.VehicleWarningMsg" >
@@ -44,20 +52,17 @@
             <if test="startTime != null">
                 and w.create_time between #{startTime} and #{endTime}
             </if>
-            <if test="numberPlate != null">
+            <if test="numberPlate != null and numberPlate != ''">
                 and v.number_plate = #{numberPlate}
             </if>
             <if test="status != null">
                 and v.status = #{status}
             </if>
-            <if test="subordinateBranch != null">
-                and v.subordinate_branch = #{subordinateBranch}
-            </if>
-            <if test="parkBranchCompanyId != null">
-                and v.park_branch_company_id = #{parkBranchCompanyId}
-            </if>
-            <if test="zoneId !=null">
-                and bc2.zone_id = #{zoneId}
+            <if test="companyIds != null and companyIds.size > 0">
+                and v.park_branch_company_id in
+                <foreach collection="companyIds" item="id" open="(" separator="," close=")">
+                    #{id}
+                </foreach>
             </if>
         </where>
     </select>