diff --git a/logistics/src/main/java/com/ccsens/logistics/bean/dto/MbpsDto.java b/logistics/src/main/java/com/ccsens/logistics/bean/dto/MbpsDto.java
index 38de4c70..23fecb5f 100644
--- a/logistics/src/main/java/com/ccsens/logistics/bean/dto/MbpsDto.java
+++ b/logistics/src/main/java/com/ccsens/logistics/bean/dto/MbpsDto.java
@@ -36,6 +36,7 @@ public class MbpsDto {
     @Data
     @ApiModel(value = "查看温度和湿度")
     public static class SelTeamAndHumidity{
+        @NotNull(message = "请选择要查询的园区")
         @ApiModelProperty("园区id")
         private Long parkId;
         @NotNull(message = "请选择要查询的仓库")
diff --git a/logistics/src/main/java/com/ccsens/logistics/bean/dto/WarehouseDto.java b/logistics/src/main/java/com/ccsens/logistics/bean/dto/WarehouseDto.java
index 9249e96c..64f8e8bd 100644
--- a/logistics/src/main/java/com/ccsens/logistics/bean/dto/WarehouseDto.java
+++ b/logistics/src/main/java/com/ccsens/logistics/bean/dto/WarehouseDto.java
@@ -4,6 +4,8 @@ import io.swagger.annotations.ApiModel;
 import io.swagger.annotations.ApiModelProperty;
 import lombok.Data;
 
+import javax.validation.constraints.NotNull;
+
 /**
  * @author 马
  */
@@ -13,6 +15,7 @@ public class WarehouseDto {
     @Data
     @ApiModel("查询仓库")
     public static class SelWarehouse{
+        @NotNull(message = "请选择要查询的园区")
         @ApiModelProperty("园区id")
         private Long parkId;
         @ApiModelProperty("仓库id")
diff --git a/logistics/src/main/java/com/ccsens/logistics/persist/dao/LogisticsCarRecordDao.java b/logistics/src/main/java/com/ccsens/logistics/persist/dao/LogisticsCarRecordDao.java
index 8c4af509..405f86c7 100644
--- a/logistics/src/main/java/com/ccsens/logistics/persist/dao/LogisticsCarRecordDao.java
+++ b/logistics/src/main/java/com/ccsens/logistics/persist/dao/LogisticsCarRecordDao.java
@@ -20,34 +20,36 @@ public interface LogisticsCarRecordDao extends LogisticsCarRecordMapper {
      * @param warehouseId 仓库id
      * @return 车辆吞进量
      */
-    Long selCarOfIn(Long warehouseId);
+    Long selCarOfIn(@Param("warehouseId") Long warehouseId);
 
     /**
      * 查询车辆吐出量
      * @param warehouseId 仓库id
      * @return 车辆吐出量
      */
-    Long selCarOfOut(Long warehouseId);
+    Long selCarOfOut(@Param("warehouseId") Long warehouseId);
 
     /**
      * 查询入库吨数
      * @param warehouseId 仓库id
      * @return 入库吨数
      */
-    Long selWeightOfIn(Long warehouseId);
+    Long selWeightOfIn(@Param("warehouseId") Long warehouseId);
 
     /**
      * 查询出货吨数
      * @param warehouseId 仓库id
      * @return 出货吨数
      */
-    Long selWeightOfOut(Long warehouseId);
+    Long selWeightOfOut(@Param("warehouseId") Long warehouseId);
 
     /**
      * 根据时间查询车辆吞进量
      * @param queryType 查询类型
      * @param startTime 开始时间
      * @param endTime   结束时间
+     * @param nowDate 现在的时间
+     * @param  countArr 查询的天数
      * @return 该时间车辆吞进量
      */
     List<MbpsVo.CarOfInByTime> selCarOfInByTime(@Param("queryType") Byte queryType, @Param("startTime") Long startTime, @Param("endTime") Long endTime,@Param("countArr") String[] countArr,@Param("nowDate") String nowDate);
@@ -57,6 +59,8 @@ public interface LogisticsCarRecordDao extends LogisticsCarRecordMapper {
      *@param queryType 查询类型
      * @param startTime 开始时间
      * @param endTime   结束时间
+     * @param nowDate 现在的时间
+     * @param  countArr 查询的天数
      * @return 该时间车辆吐出量
      */
     List<MbpsVo.CarOfOutByTime> selCarOfOutByTime(@Param("queryType") Byte queryType,@Param("startTime") Long startTime,@Param("endTime") Long endTime,@Param("countArr") String[] countArr,@Param("nowDate") String nowDate);
@@ -66,6 +70,8 @@ public interface LogisticsCarRecordDao extends LogisticsCarRecordMapper {
      * @param queryType 查询类型
      * @param startTime 开始时间
      * @param endTime   结束时间
+     * @param nowDate 现在的时间
+     * @param  countArr 查询的天数
      * @return 该时间入货量
      */
     List<MbpsVo.WeightOfInByTime> selWeightOfInByTime(@Param("queryType") Byte queryType,@Param("startTime") Long startTime,@Param("endTime") Long endTime,@Param("countArr") String[] countArr,@Param("nowDate") String nowDate);
@@ -75,6 +81,8 @@ public interface LogisticsCarRecordDao extends LogisticsCarRecordMapper {
      * @param queryType 查询类型
      * @param startTime 开始时间
      * @param endTime   结束时间
+     * @param nowDate 现在的时间
+     * @param  countArr 查询的天数
      * @return 该时间车辆出货量
      */
     List<MbpsVo.WeightOfOutByTime> selWeightOfOutByTime(@Param("queryType") Byte queryType,@Param("startTime") Long startTime,@Param("endTime") Long endTime,@Param("countArr") String[] countArr,@Param("nowDate") String nowDate);
diff --git a/logistics/src/main/java/com/ccsens/logistics/service/MbpsService.java b/logistics/src/main/java/com/ccsens/logistics/service/MbpsService.java
index 6de679b8..2012538d 100644
--- a/logistics/src/main/java/com/ccsens/logistics/service/MbpsService.java
+++ b/logistics/src/main/java/com/ccsens/logistics/service/MbpsService.java
@@ -43,16 +43,32 @@ public class MbpsService implements IMbpsService {
         MbpsVo.AllMbps allMbps = new MbpsVo.AllMbps();
         //查询吞进量
         Long carOfIn = carRecordDao.selCarOfIn(param.getWarehouseId());
-        allMbps.setCarOfIn(carOfIn);
+        if (null == carOfIn){
+            allMbps.setCarOfIn(0L);
+        }else{
+            allMbps.setCarOfIn(carOfIn);
+        }
         //查询吐出量
         Long carOfOut = carRecordDao.selCarOfOut(param.getWarehouseId());
-        allMbps.setCarOfOut(carOfOut);
+        if (null == carOfOut){
+            allMbps.setCarOfOut(0L);
+        }else {
+            allMbps.setCarOfOut(carOfOut);
+        }
         //查询入库吨数
         Long weightOfIn = carRecordDao.selWeightOfIn(param.getWarehouseId());
-        allMbps.setWeightOfIn(weightOfIn);
+        if (null == weightOfIn){
+            allMbps.setWeightOfIn(0L);
+        }else {
+            allMbps.setWeightOfIn(weightOfIn);
+        }
         //查询出货吨数
         Long weightOfOut = carRecordDao.selWeightOfOut(param.getWarehouseId());
-        allMbps.setWeightOfOut(weightOfOut);
+        if (null == weightOfOut){
+            allMbps.setWeightOfOut(0L);
+        }else {
+            allMbps.setWeightOfOut(weightOfOut);
+        }
         return allMbps;
     }
 
diff --git a/logistics/src/main/resources/mapper_dao/LogisticsCarRecordDao.xml b/logistics/src/main/resources/mapper_dao/LogisticsCarRecordDao.xml
index 0ea8c920..c0daee4e 100644
--- a/logistics/src/main/resources/mapper_dao/LogisticsCarRecordDao.xml
+++ b/logistics/src/main/resources/mapper_dao/LogisticsCarRecordDao.xml
@@ -4,28 +4,28 @@
 
     <select id="selCarOfIn" resultType="java.lang.Long">
         SELECT COUNT(cr.id) FROM t_logistics_car_record AS cr WHERE cr.in_out = 0 AND cr.rec_status = 0
-        <if test="warehouseId!=null and warehouseId!=''">
+        <if test="warehouseId!=null or warehouseId!=''">
             AND cr.warehouse_id = #{warehouseId}
         </if>
     </select>
 
     <select id="selCarOfOut" resultType="java.lang.Long">
         SELECT COUNT(cr.id) FROM t_logistics_car_record AS cr WHERE cr.in_out = 1 AND cr.rec_status = 0
-        <if test="warehouseId!=null and warehouseId!=''">
+        <if test="warehouseId!=null or warehouseId!=''">
             AND cr.warehouse_id = #{warehouseId}
         </if>
     </select>
 
     <select id="selWeightOfIn" resultType="java.lang.Long">
         SELECT SUM(cr.car_weight) FROM t_logistics_car_record AS cr WHERE cr.in_out = 0 AND cr.rec_status = 0
-        <if test="warehouseId!=null and warehouseId!=''">
+        <if test="warehouseId!=null or warehouseId!=''">
             AND cr.warehouse_id = #{warehouseId}
         </if>
     </select>
 
     <select id="selWeightOfOut" resultType="java.lang.Long">
         SELECT SUM(cr.car_weight) FROM t_logistics_car_record AS cr WHERE cr.in_out = 1 AND cr.rec_status = 0
-        <if test="warehouseId!=null and warehouseId!=''">
+        <if test="warehouseId!=null or warehouseId!=''">
             AND cr.warehouse_id = #{warehouseId}
         </if>
     </select>