| | |
|---|
| | | if (!taskService.updateById(task)) {
|
|---|
| | | throw new CoolException("库存更新失败");
|
|---|
| | | } else {
|
|---|
| | | //CacheSite 释放已被占用的通道
|
|---|
| | | //CacheSite 释放已被占用的通道 //fixme 播种功能完成后，需要将这里注释掉
|
|---|
| | | List<TaskDetl> detls = taskDetlService.list(new LambdaQueryWrapper<TaskDetl>().eq(TaskDetl::getTaskId, task.getId()));
|
|---|
| | | if (!Collections.isEmpty(detls)) {
|
|---|
| | | List<Long> waveIds = detls.stream().map(TaskDetl::getWaveId).collect(Collectors.toList());
|
|---|
| | |
|---|
| | | private void executeTask1(Task task) {
|
|---|
| | | Long hostId = task.getHostId();
|
|---|
| | | //fixme 暂时关闭HOSTID
|
|---|
| | | // Loc loc = locService.getOne(new LambdaQueryWrapper<Loc>().eq(Loc::getLocNo, task.getTargetLoc()).eq(Loc::getHostId, hostId));
|
|---|
| | | Loc loc = locService.getOne(new LambdaQueryWrapper<Loc>().eq(Loc::getLocNo, task.getTargetLoc()));
|
|---|
| | | Loc loc = locService.getOne(new LambdaQueryWrapper<Loc>().eq(Loc::getLocNo, task.getTargetLoc()).eq(Loc::getHostId, hostId));
|
|---|
| | | // Loc loc = locService.getOne(new LambdaQueryWrapper<Loc>().eq(Loc::getLocNo, task.getTargetLoc()));
|
|---|
| | | if (loc == null) {
|
|---|
| | | log.info("库位不存在" + "=======>" + task.getTargetLoc());
|
|---|
| | | throw new CoolException("库位不存在");
|
|---|
| | | }
|
|---|
| | |
|
|---|
| | |
|---|
| | | for (WaitPakin waitPakin : waitPakins) {
|
|---|
| | | WaitPakinLog waitPakinLog = new WaitPakinLog();
|
|---|
| | | waitPakinLog.sync(waitPakin);
|
|---|
| | | waitPakinLog.setId(null);
|
|---|
| | | if (!waitPakinLogService.save(waitPakinLog)) {
|
|---|
| | | throw new CoolException("组托通知档转历史档失败");
|
|---|
| | | }
|
|---|
