diff --git a/logistics/src/main/java/com/ccsens/logistics/Netty/NettyClient.java b/logistics/src/main/java/com/ccsens/logistics/Netty/NettyClient.java index 0d3db04f..35a2685b 100644 --- a/logistics/src/main/java/com/ccsens/logistics/Netty/NettyClient.java +++ b/logistics/src/main/java/com/ccsens/logistics/Netty/NettyClient.java @@ -12,6 +12,7 @@ import io.netty.channel.socket.nio.NioSocketChannel; import io.netty.handler.codec.DelimiterBasedFrameDecoder; import io.netty.handler.codec.Delimiters; import io.netty.handler.codec.string.StringEncoder; +import lombok.extern.slf4j.Slf4j; import org.springframework.stereotype.Component; import javax.annotation.PostConstruct; @@ -19,7 +20,7 @@ import javax.annotation.Resource; import java.util.concurrent.Executors; import java.util.concurrent.ScheduledExecutorService; import java.util.concurrent.TimeUnit; - +@Slf4j @Component public class NettyClient { @Resource @@ -63,6 +64,7 @@ public class NettyClient { @Override public void run() { // thermalImageryService.getImagery(); + log.info("请求热成像图片"); future.channel().writeAndFlush("{\"service_id\":\"123\",\"type\":\"READSN4\",\"thing_id\":\"050005A2\",\"data\":{\"GetType\":\"Auto\",\"Highest\":70,\"Lowest\":30}}"+"\r\n"); future.channel().writeAndFlush("{\"service_id\":\"123\",\"type\":\"READSN4\",\"thing_id\":\"050005BD\",\"data\":{\"GetType\":\"Auto\",\"Highest\":70,\"Lowest\":30}}"+"\r\n"); } 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 23fecb5f..4ef11c44 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 @@ -27,10 +27,6 @@ public class MbpsDto { private Byte queryType; @ApiModelProperty("查询的天数") private Integer queryOfDay = 10; - @ApiModelProperty("开始时间") - private Long startTime; - @ApiModelProperty("结束时间") - private Long endTime; } @Data @@ -42,10 +38,6 @@ public class MbpsDto { @NotNull(message = "请选择要查询的仓库") @ApiModelProperty("仓库id") private Long warehouseId; - @ApiModelProperty("开始时间") - private Long startTime; - @ApiModelProperty("结束时间") - private Long endTime; @ApiModelProperty("查询的几个小时的数据") private Integer queryOfDay = 5; } 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 405f86c7..ec125d42 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 @@ -46,44 +46,36 @@ public interface LogisticsCarRecordDao extends LogisticsCarRecordMapper { /** * 根据时间查询车辆吞进量 * @param queryType 查询类型 - * @param startTime 开始时间 - * @param endTime 结束时间 * @param nowDate 现在的时间 * @param countArr 查询的天数 * @return 该时间车辆吞进量 */ - List selCarOfInByTime(@Param("queryType") Byte queryType, @Param("startTime") Long startTime, @Param("endTime") Long endTime,@Param("countArr") String[] countArr,@Param("nowDate") String nowDate); + List selCarOfInByTime(@Param("queryType") Byte queryType,@Param("countArr") String[] countArr,@Param("nowDate") String nowDate); /** * 根据时间查询车辆吐出量 *@param queryType 查询类型 - * @param startTime 开始时间 - * @param endTime 结束时间 * @param nowDate 现在的时间 * @param countArr 查询的天数 * @return 该时间车辆吐出量 */ - List selCarOfOutByTime(@Param("queryType") Byte queryType,@Param("startTime") Long startTime,@Param("endTime") Long endTime,@Param("countArr") String[] countArr,@Param("nowDate") String nowDate); + List selCarOfOutByTime(@Param("queryType") Byte queryType,@Param("countArr") String[] countArr,@Param("nowDate") String nowDate); /** * 根据时间查询入货量 * @param queryType 查询类型 - * @param startTime 开始时间 - * @param endTime 结束时间 * @param nowDate 现在的时间 * @param countArr 查询的天数 * @return 该时间入货量 */ - List selWeightOfInByTime(@Param("queryType") Byte queryType,@Param("startTime") Long startTime,@Param("endTime") Long endTime,@Param("countArr") String[] countArr,@Param("nowDate") String nowDate); + List selWeightOfInByTime(@Param("queryType") Byte queryType,@Param("countArr") String[] countArr,@Param("nowDate") String nowDate); /** * 根据时间查询出货量 * @param queryType 查询类型 - * @param startTime 开始时间 - * @param endTime 结束时间 * @param nowDate 现在的时间 * @param countArr 查询的天数 * @return 该时间车辆出货量 */ - List selWeightOfOutByTime(@Param("queryType") Byte queryType,@Param("startTime") Long startTime,@Param("endTime") Long endTime,@Param("countArr") String[] countArr,@Param("nowDate") String nowDate); + List selWeightOfOutByTime(@Param("queryType") Byte queryType,@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 2012538d..c74b1f88 100644 --- a/logistics/src/main/java/com/ccsens/logistics/service/MbpsService.java +++ b/logistics/src/main/java/com/ccsens/logistics/service/MbpsService.java @@ -74,7 +74,13 @@ public class MbpsService implements IMbpsService { @Override public MbpsVo.SelMbpsByTime selMbpsByTime(MbpsDto.SelMbpsByTime param) { - String[] countArr = new String[param.getQueryOfDay()]; + String[] countArr; + if (ObjectUtil.isNotNull(param.getQueryOfDay())){ + countArr = new String[param.getQueryOfDay()]; + }else{ + countArr = new String[10]; + } + //查找当前时间 Date date = new Date(); SimpleDateFormat format = new SimpleDateFormat("yyyy-MM-dd"); @@ -82,13 +88,13 @@ public class MbpsService implements IMbpsService { MbpsVo.SelMbpsByTime selMbpsByTime = new MbpsVo.SelMbpsByTime(); //查询吞进量 - List carOfInByTimeList = carRecordDao.selCarOfInByTime(param.getQueryType(),param.getStartTime(),param.getEndTime(),countArr,nowDate); + List carOfInByTimeList = carRecordDao.selCarOfInByTime(param.getQueryType(),countArr,nowDate); selMbpsByTime.getCarOfInsByTime().addAll(carOfInByTimeList); //查询吐出量 - List carOfOutByTimeList = carRecordDao.selCarOfOutByTime(param.getQueryType(),param.getStartTime(),param.getEndTime(),countArr,nowDate); + List carOfOutByTimeList = carRecordDao.selCarOfOutByTime(param.getQueryType(),countArr,nowDate); selMbpsByTime.getCarOfOutsByTime().addAll(carOfOutByTimeList); //查询入库吨数 - List weightOfInByTimeList = carRecordDao.selWeightOfInByTime(param.getQueryType(),param.getStartTime(),param.getEndTime(),countArr,nowDate); + List weightOfInByTimeList = carRecordDao.selWeightOfInByTime(param.getQueryType(),countArr,nowDate); for (MbpsVo.WeightOfInByTime weightOfInByTime : weightOfInByTimeList) { if (ObjectUtil.isNull(weightOfInByTime.getWeightOfIn())){ weightOfInByTime.setWeightOfIn(0L); @@ -96,7 +102,7 @@ public class MbpsService implements IMbpsService { } selMbpsByTime.getWeightOfInsByTime().addAll(weightOfInByTimeList); //查询出货吨数 - List weightOfOutByTimeList =carRecordDao.selWeightOfOutByTime(param.getQueryType(),param.getStartTime(),param.getEndTime(),countArr,nowDate); + List weightOfOutByTimeList =carRecordDao.selWeightOfOutByTime(param.getQueryType(),countArr,nowDate); for (MbpsVo.WeightOfOutByTime weightOfOutByTime : weightOfOutByTimeList) { if (ObjectUtil.isNull(weightOfOutByTime.getWeightOfOut())){ weightOfOutByTime.setWeightOfOut(0L); diff --git a/logistics/src/main/resources/application.yml b/logistics/src/main/resources/application.yml index 0e768cd1..ea3545e5 100644 --- a/logistics/src/main/resources/application.yml +++ b/logistics/src/main/resources/application.yml @@ -1,6 +1,6 @@ spring: profiles: - active: test - include: common,util-test + active: prod + include: common,util-prod diff --git a/logistics/src/main/resources/mapper_dao/LogisticsCarRecordDao.xml b/logistics/src/main/resources/mapper_dao/LogisticsCarRecordDao.xml index c0daee4e..a23b27ec 100644 --- a/logistics/src/main/resources/mapper_dao/LogisticsCarRecordDao.xml +++ b/logistics/src/main/resources/mapper_dao/LogisticsCarRecordDao.xml @@ -4,28 +4,28 @@ diff --git a/logistics/src/main/resources/mapper_dao/LogisticsEnvironmentRecordDao.xml b/logistics/src/main/resources/mapper_dao/LogisticsEnvironmentRecordDao.xml index 9987e4d3..800b6b2a 100644 --- a/logistics/src/main/resources/mapper_dao/LogisticsEnvironmentRecordDao.xml +++ b/logistics/src/main/resources/mapper_dao/LogisticsEnvironmentRecordDao.xml @@ -4,7 +4,7 @@