| | |
|---|
| | | @Async |
|---|
| | | public void asyncOutboundExecutionWcs(List<OutStockToTaskParams> param, Long orderId, Long loginUserId) { |
|---|
| | | try { |
|---|
| | | int i = 0; |
|---|
| | | List<OutStockToTaskParams> tasks = new ArrayList<>(); |
|---|
| | | while (true) { |
|---|
| | | tasks = new ArrayList<>(); |
|---|
| | | i++; |
|---|
| | | if (i > 5) return; |
|---|
| | | Thread.sleep(3000); |
|---|
| | | for (OutStockToTaskParams taskParam : new OutStockToTaskParams[param.size()]) { |
|---|
| | | if (StringUtils.isNotBlank(taskParam.getLocCode())) { |
|---|
| | | tasks.add(taskParam); |
|---|
| | | } |
|---|
| | | } |
|---|
| | | break; |
|---|
| | | } |
|---|
| | | if (tasks.isEmpty()){ |
|---|
| | | // int i = 0; |
|---|
| | | // List<OutStockToTaskParams> tasks = new ArrayList<>(); |
|---|
| | | // while (true) { |
|---|
| | | // tasks = new ArrayList<>(); |
|---|
| | | // i++; |
|---|
| | | // if (i > 5) return; |
|---|
| | | // Thread.sleep(3000); |
|---|
| | | // for (OutStockToTaskParams taskParam : new OutStockToTaskParams[param.size()]) { |
|---|
| | | // if (StringUtils.isNotBlank(taskParam.getLocCode())) { |
|---|
| | | // tasks.add(taskParam); |
|---|
| | | // } |
|---|
| | | // } |
|---|
| | | // break; |
|---|
| | | // } |
|---|
| | | if (param.isEmpty()){ |
|---|
| | | log.warn("订单ID {} 没有找到可出库明细，跳过自动出库", orderId); |
|---|
| | | return; |
|---|
| | | } |
|---|
| | | outStockService.genOutStockTask(tasks, loginUserId, orderId); |
|---|
| | | outStockService.genOutStockTask(param, loginUserId, orderId); |
|---|
| | | |
|---|
| | | log.info("订单ID {} 自动出库，共处理 {} 个明细", orderId, param.size()); |
|---|
| | | } catch (Exception e) { |
|---|
