提交 1342d06d authored 作者: liuhaiquan's avatar liuhaiquan

修改实时计算保存的实体为对象

上级 85f08d16
...@@ -6,7 +6,6 @@ import lombok.Setter; ...@@ -6,7 +6,6 @@ import lombok.Setter;
import lombok.ToString; import lombok.ToString;
import java.io.Serializable; import java.io.Serializable;
import java.time.LocalDateTime;
@Getter @Getter
@Setter @Setter
...@@ -17,9 +16,9 @@ public class OrderChildExpectDTO implements Serializable { ...@@ -17,9 +16,9 @@ public class OrderChildExpectDTO implements Serializable {
private String childNo;//子订单编号 private String childNo;//子订单编号
private LocalDateTime expectArriveTime;//预计到达货源地时间 private String expectArriveTime;//预计到达货源地时间
private Integer expectArriveTimeSecond;//预计到达货源地时间 private Integer expectArriveTimeSecond;//预计到达货源地时间
private LocalDateTime expectReceiveTime;//预计到达目的地时间 private String expectReceiveTime;//预计到达目的地时间
private Integer expectReceiveTimeSecond;//预计到达目的地时间 private Integer expectReceiveTimeSecond;//预计到达目的地时间
private Integer expectTransportTimeSecond;//预计运输时间 private Integer expectTransportTimeSecond;//预计运输时间
private String expectTransportTime;//预计运输时间(转化秒 为几小时几分钟) private String expectTransportTime;//预计运输时间(转化秒 为几小时几分钟)
......
package com.clx.performance.service.impl; package com.clx.performance.service.impl;
import com.alibaba.fastjson.JSON;
import com.baomidou.mybatisplus.core.metadata.IPage; import com.baomidou.mybatisplus.core.metadata.IPage;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page; import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.clx.order.enums.OrderEnum; import com.clx.order.enums.OrderEnum;
...@@ -42,6 +41,7 @@ import com.msl.user.utils.TokenUtil; ...@@ -42,6 +41,7 @@ import com.msl.user.utils.TokenUtil;
import lombok.AllArgsConstructor; import lombok.AllArgsConstructor;
import lombok.extern.slf4j.Slf4j; import lombok.extern.slf4j.Slf4j;
import org.apache.commons.collections4.CollectionUtils; import org.apache.commons.collections4.CollectionUtils;
import org.apache.commons.lang3.StringUtils;
import org.redisson.api.RLock; import org.redisson.api.RLock;
import org.redisson.api.RedissonClient; import org.redisson.api.RedissonClient;
import org.springframework.amqp.core.AmqpTemplate; import org.springframework.amqp.core.AmqpTemplate;
...@@ -1562,8 +1562,8 @@ public class OrderChildServiceImpl implements OrderChildService { ...@@ -1562,8 +1562,8 @@ public class OrderChildServiceImpl implements OrderChildService {
} }
} }
if(Objects.nonNull(oneExpect.getExpectArriveTime())){ if(StringUtils.isNotBlank(oneExpect.getExpectArriveTime())){
LocalDateTime expectArriveTime = oneExpect.getExpectArriveTime(); LocalDateTime expectArriveTime = DateUtils.parseDateTime(oneExpect.getExpectArriveTime()).get();
monitorOrderChild.setExpectArriveTimeRealTime(DateUtils.formatDateTime(expectArriveTime).get()); monitorOrderChild.setExpectArriveTimeRealTime(DateUtils.formatDateTime(expectArriveTime).get());
LocalDateTime expectArriveWarringTime = expectArriveTime.plusMinutes(arriveWarningTime); LocalDateTime expectArriveWarringTime = expectArriveTime.plusMinutes(arriveWarningTime);
if(expectArriveWarringTime.isBefore(now) && child.getStatus() < OrderChildEnum.Status.ARRIVE_SEND.getCode()){ if(expectArriveWarringTime.isBefore(now) && child.getStatus() < OrderChildEnum.Status.ARRIVE_SEND.getCode()){
...@@ -1573,8 +1573,8 @@ public class OrderChildServiceImpl implements OrderChildService { ...@@ -1573,8 +1573,8 @@ public class OrderChildServiceImpl implements OrderChildService {
} }
} }
if(Objects.nonNull(oneExpect.getExpectReceiveTime())){ if(StringUtils.isNotBlank(oneExpect.getExpectReceiveTime())){
LocalDateTime expectReceiveTime = oneExpect.getExpectReceiveTime(); LocalDateTime expectReceiveTime = DateUtils.parseDateTime(oneExpect.getExpectReceiveTime()).get();
monitorOrderChild.setExpectReceiveTimeRealTime(DateUtils.formatDateTime(expectReceiveTime).get()); monitorOrderChild.setExpectReceiveTimeRealTime(DateUtils.formatDateTime(expectReceiveTime).get());
LocalDateTime expectReceiveWarringTime = expectReceiveTime.plusMinutes(receiveWarningTime); LocalDateTime expectReceiveWarringTime = expectReceiveTime.plusMinutes(receiveWarningTime);
if(expectReceiveWarringTime.isBefore(now) if(expectReceiveWarringTime.isBefore(now)
...@@ -1674,10 +1674,10 @@ public class OrderChildServiceImpl implements OrderChildService { ...@@ -1674,10 +1674,10 @@ public class OrderChildServiceImpl implements OrderChildService {
LocalDateTime expectTime = now.plusSeconds(plusTime); LocalDateTime expectTime = now.plusSeconds(plusTime);
if (childStatus < OrderChildEnum.Status.ARRIVE_SEND.getCode()) { if (childStatus < OrderChildEnum.Status.ARRIVE_SEND.getCode()) {
expect.setExpectArriveTime(expectTime); expect.setExpectArriveTime(DateUtils.formatDateTime(expectTime).get());
expect.setExpectArriveTimeSecond(plusTime); expect.setExpectArriveTimeSecond(plusTime);
} else { } else {
expect.setExpectReceiveTime(expectTime); expect.setExpectReceiveTime(DateUtils.formatDateTime(expectTime).get());
expect.setExpectReceiveTimeSecond(plusTime); expect.setExpectReceiveTimeSecond(plusTime);
} }
cacheOrderChildExpectData(childNo,expect); cacheOrderChildExpectData(childNo,expect);
......
Markdown 格式
0%
您添加了 0 到此讨论。请谨慎行事。
请先完成此评论的编辑!
注册 或者 后发表评论