| | |
|---|
| | | private CacheSiteService cacheSiteService;
|
|---|
| | |
|
|---|
| | |
|
|---|
| | | /**
|
|---|
| | | * 入库执行任务
|
|---|
| | | */
|
|---|
| | | @Scheduled(cron = "0/3 * * * * ? ")
|
|---|
| | | @Transactional(rollbackFor = Exception.class)
|
|---|
| | | public void inExecute() {
|
|---|
| | |
|---|
| | | Long hostId = task.getHostId();
|
|---|
| | | //fixme 将任务当前
|
|---|
| | | 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) {
|
|---|
| | | throw new CoolException("库位不存在");
|
|---|
| | | }
|
|---|
| | |
|---|
| | | loc.setLocStsId(LocStsType.F.val());
|
|---|
| | | loc.setUpdateTime(new Date());
|
|---|
| | | loc.setBarcode(task.getBarcode());
|
|---|
| | |
|
|---|
| | | if (!locService.updateById(loc)) {
|
|---|
| | | throw new CoolException("库位状态更新失败");
|
|---|
| | | }
|
|---|
