fix:修复添加行程导致同步的问题,修复因缓存导致无法查询可同步行程的问题
This commit is contained in:
parent
c2e172aff3
commit
8ad0807067
|
@ -101,7 +101,7 @@ public class OrderApplicationService {
|
||||||
routeRepository.save(routeOrder); // 仅在所有操作完成后保存一次
|
routeRepository.save(routeOrder); // 仅在所有操作完成后保存一次
|
||||||
}
|
}
|
||||||
//如果行程变更成功,自动执行同步功能
|
//如果行程变更成功,自动执行同步功能
|
||||||
Command.of(RouteAutoSyncCommand.class).route(routeOrder).async().sendToQueue();
|
// Command.of(RouteAutoSyncCommand.class).route(routeOrder).async().sendToQueue();
|
||||||
}
|
}
|
||||||
|
|
||||||
@Transactional
|
@Transactional
|
||||||
|
|
|
@ -20,7 +20,6 @@ public class UserDepartmentInfo implements Serializable {
|
||||||
@Id
|
@Id
|
||||||
private Long id;
|
private Long id;
|
||||||
private Long userId;
|
private Long userId;
|
||||||
private Integer userKey;
|
|
||||||
private String companyCode;
|
private String companyCode;
|
||||||
private String companyName;
|
private String companyName;
|
||||||
private String departmentCodeOne;
|
private String departmentCodeOne;
|
||||||
|
|
|
@ -199,6 +199,7 @@ public class LegDomainService {
|
||||||
// 过滤Leg items
|
// 过滤Leg items
|
||||||
List<Leg> filteredLegItems = legItems.stream()
|
List<Leg> filteredLegItems = legItems.stream()
|
||||||
.filter(it -> !it.getLegType().equals(LEG_TYPE_OTHER) && it.legIsInternal())
|
.filter(it -> !it.getLegType().equals(LEG_TYPE_OTHER) && it.legIsInternal())
|
||||||
|
.peek(Leg::reloadStatus)
|
||||||
.filter(it -> it.getLegApprovalStatus().equals(LEG_APPROVAL_STATUS_NOT))
|
.filter(it -> it.getLegApprovalStatus().equals(LEG_APPROVAL_STATUS_NOT))
|
||||||
.toList();
|
.toList();
|
||||||
|
|
||||||
|
|
Loading…
Reference in New Issue