|
|
@@ -83,7 +83,6 @@ import java.math.RoundingMode;
|
|
|
import java.time.LocalDateTime;
|
|
|
import java.time.ZoneId;
|
|
|
import java.util.*;
|
|
|
-import java.util.concurrent.TimeUnit;
|
|
|
import java.util.concurrent.atomic.AtomicReference;
|
|
|
import java.util.function.Function;
|
|
|
import java.util.stream.Collectors;
|
|
|
@@ -3358,7 +3357,7 @@ public class KwtWaybillOrderV1Service {
|
|
|
}
|
|
|
|
|
|
waybillOrderResp.setUnloadingTime(DateUtils.format(unloadTrack.getOperateTime(),DateUtils.DATE_TIME_PATTERN));
|
|
|
- if (Objects.equals(record.getStatus(), CarWaybillV1Enum.WAIT_UNLOADING.getCode())){
|
|
|
+ if (Objects.equals(record.getStatus(), CarWaybillV1Enum.COMPLETED.getCode())){
|
|
|
waybillOrderResp.setCompleteTime(DateUtils.format(record.getUpdateTime(),DateUtils.DATE_TIME_PATTERN));
|
|
|
}
|
|
|
|
|
|
@@ -3630,7 +3629,7 @@ public class KwtWaybillOrderV1Service {
|
|
|
updateSubtask.setId(subtask.getId());
|
|
|
//KwtWaybillOrderTicket kwtWaybillOrderTicket = new KwtWaybillOrderTicket();
|
|
|
//单证审核 运单当前状态是已卸货,传入的订单是已完成
|
|
|
- List<Integer> statusList = Arrays.asList(CarWaybillV1Enum.WAIT_UNLOADING.getCode(), CarWaybillV1Enum.COMPLETION_UNLOADING.getCode());
|
|
|
+ List<Integer> statusList = Arrays.asList(CarWaybillV1Enum.COMPLETED.getCode(), CarWaybillV1Enum.REVIEW_REJECTION.getCode());
|
|
|
if (statusList.contains( status) && Objects.equals(billOrder.getStatus(), CarWaybillV1Enum.COMPLETION_LOADING.getCode())){
|
|
|
updateOrder.setStatus( status);
|
|
|
updateOrder.setRemark(req.getRemark());
|
|
|
@@ -3657,7 +3656,7 @@ public class KwtWaybillOrderV1Service {
|
|
|
|
|
|
// 存储记录
|
|
|
String remark = null;
|
|
|
- if (Objects.equals(status, CarWaybillV1Enum.COMPLETION_UNLOADING.getCode())){
|
|
|
+ if (Objects.equals(status, CarWaybillV1Enum.REVIEW_REJECTION.getCode())){
|
|
|
remark = "审核驳回,运单【"+ billOrder.getWOrderNo() + "】已驳回";
|
|
|
}else {
|
|
|
remark = "审核通过,运单【"+ billOrder.getWOrderNo() + "】已完成";
|
|
|
@@ -3671,8 +3670,8 @@ public class KwtWaybillOrderV1Service {
|
|
|
return Boolean.TRUE;
|
|
|
}
|
|
|
// 驳回的订单可以通过完善单证变成已完成
|
|
|
- if (Objects.equals(billOrder.getStatus(), CarWaybillV1Enum.COMPLETION_UNLOADING.getCode()) && Objects.equals(status,
|
|
|
- CarWaybillV1Enum.WAIT_UNLOADING.getCode())){
|
|
|
+ if (Objects.equals(billOrder.getStatus(), CarWaybillV1Enum.REVIEW_REJECTION.getCode()) && Objects.equals(status,
|
|
|
+ CarWaybillV1Enum.COMPLETED.getCode())){
|
|
|
updateOrder.setStatus(status);
|
|
|
updateOrder.setRemark(req.getRemark());
|
|
|
updateSubtask.setStatus(status);
|
|
|
@@ -3741,7 +3740,7 @@ public class KwtWaybillOrderV1Service {
|
|
|
checkRefuseScore(billOrder, status, driverRulesVO);
|
|
|
|
|
|
//运单没通过,不执行以下逻辑
|
|
|
- if (!Objects.equals(status, CarWaybillV1Enum.WAIT_UNLOADING.getCode())) {
|
|
|
+ if (!Objects.equals(status, CarWaybillV1Enum.COMPLETED.getCode())) {
|
|
|
return;
|
|
|
}
|
|
|
|
|
|
@@ -3762,7 +3761,7 @@ public class KwtWaybillOrderV1Service {
|
|
|
*/
|
|
|
private void checkRefuseScore(KwtWaybillOrder waybillOrder, Integer status, DriverConductRulesVO driverRulesVO) {
|
|
|
//运单驳回
|
|
|
- if (!Objects.equals(status, CarWaybillV1Enum.COMPLETION_UNLOADING.getCode())) {
|
|
|
+ if (!Objects.equals(status, CarWaybillV1Enum.REVIEW_REJECTION.getCode())) {
|
|
|
return;
|
|
|
}
|
|
|
//单据错误驳回分数
|
|
|
@@ -3845,7 +3844,7 @@ public class KwtWaybillOrderV1Service {
|
|
|
}
|
|
|
Date takingOrderTime = takingOrderNodes.getCreateTime() != null ? takingOrderNodes.getCreateTime() : null;
|
|
|
//司机完成运单时间
|
|
|
- KwtWaybillOrderNode overOrderNodes = kwtWaybillOrderNodeRepository.queryNodesByOrderId(waybillOrder.getId(), CarWaybillV1Enum.WAIT_UNLOADING.getCode());
|
|
|
+ KwtWaybillOrderNode overOrderNodes = kwtWaybillOrderNodeRepository.queryNodesByOrderId(waybillOrder.getId(), CarWaybillV1Enum.COMPLETED.getCode());
|
|
|
if (overOrderNodes == null) {
|
|
|
throw new BusinessPlatfromException(ErrorCodeEnum.WAYBILL_NODE_NOT_EXIST, "未找到关联的运单节点数据!");
|
|
|
}
|
|
|
@@ -3928,7 +3927,7 @@ public class KwtWaybillOrderV1Service {
|
|
|
}
|
|
|
|
|
|
//查询该司机连续审核通过节点数据
|
|
|
- List<KwtWaybillOrderNode> waybillOrderNodeList = getWaybillOrderNodesByStatus(waybillOrder, continuousOnTimes, CarWaybillV1Enum.WAIT_UNLOADING);
|
|
|
+ List<KwtWaybillOrderNode> waybillOrderNodeList = getWaybillOrderNodesByStatus(waybillOrder, continuousOnTimes, CarWaybillV1Enum.COMPLETED);
|
|
|
if (waybillOrderNodeList == null) {
|
|
|
return;
|
|
|
}
|
|
|
@@ -3988,7 +3987,7 @@ public class KwtWaybillOrderV1Service {
|
|
|
}
|
|
|
|
|
|
//查询该司机连续审核通过节点数据
|
|
|
- List<KwtWaybillOrderNode> waybillOrderNodeList = getWaybillOrderNodesByStatus(waybillOrder, continuousUnloadTimes, CarWaybillV1Enum.WAIT_UNLOADING);
|
|
|
+ List<KwtWaybillOrderNode> waybillOrderNodeList = getWaybillOrderNodesByStatus(waybillOrder, continuousUnloadTimes, CarWaybillV1Enum.COMPLETED);
|
|
|
if (waybillOrderNodeList == null) {
|
|
|
return;
|
|
|
}
|
|
|
@@ -4106,7 +4105,7 @@ public class KwtWaybillOrderV1Service {
|
|
|
|
|
|
private void noticeTraderOrder(KwtLogisticsOrder kwtLogisticsOrder, KwtLogisticsOrder kwtLogistics) {
|
|
|
|
|
|
- if (!Objects.equals(kwtLogisticsOrder.getStatus(),LogisticsOrderV1Enum.HAVE_RECONCILED.getCode())){
|
|
|
+ if (!Objects.equals(kwtLogisticsOrder.getStatus(),LogisticsOrderV1Enum.COMPLETED.getCode())){
|
|
|
return;
|
|
|
}
|
|
|
// 根据贸易订单id查询物理订单
|
|
|
@@ -4116,7 +4115,7 @@ public class KwtWaybillOrderV1Service {
|
|
|
}
|
|
|
//判断所有的物流订单都都已经完成
|
|
|
boolean b = kwtLogisticsOrders.stream()
|
|
|
- .allMatch(x -> Arrays.asList(LogisticsOrderV1Enum.HAVE_RECONCILED.getCode(), LogisticsOrderV1Enum.REJECT_ORDER.getCode()).contains(x.getStatus()));
|
|
|
+ .allMatch(x -> Arrays.asList(LogisticsOrderV1Enum.COMPLETED.getCode(), LogisticsOrderV1Enum.REJECT_ORDER.getCode()).contains(x.getStatus()));
|
|
|
if (!b){
|
|
|
return;
|
|
|
}
|
|
|
@@ -4315,7 +4314,7 @@ public class KwtWaybillOrderV1Service {
|
|
|
@NotNull
|
|
|
private static List<WaybillOrderNodeVo.WaybillOrderNode> getWaybillOrderNodes(List<WaybillOrderNodeVo.Timeline> voList) {
|
|
|
Map<Integer, List<WaybillOrderNodeVo.Timeline>> statusAndTimelineMap = voList.stream()
|
|
|
- .filter(t ->!Arrays.asList(CarWaybillV1Enum.WEIGHT_TRAFFIC.getCode(),CarWaybillV1Enum.WAIT_UNLOADING.getCode(),CarWaybillV1Enum.APPROVAL_TREAT.getCode(), CarWaybillV1Enum.COMPLETION_UNLOADING.getCode()).contains(t.getOrderStatus()))
|
|
|
+ .filter(t ->!Arrays.asList(CarWaybillV1Enum.WEIGHT_TRAFFIC.getCode(),CarWaybillV1Enum.COMPLETED.getCode(),CarWaybillV1Enum.CANCELLED.getCode(), CarWaybillV1Enum.REVIEW_REJECTION.getCode()).contains(t.getOrderStatus()))
|
|
|
.sorted(Comparator.comparing(WaybillOrderNodeVo.Timeline::getCreateTime))
|
|
|
.collect(Collectors.groupingBy(WaybillOrderNodeVo.Timeline::getOrderStatus));
|
|
|
List<WaybillOrderNodeVo.WaybillOrderNode> nodeList = Lists.newArrayList();
|