| | |
| | | task.setTaskType(taskType);
|
| | | task.setIoPri(workService.generateIoPri(taskType));
|
| | | task.setOriginLoc(loc.getLocNo());
|
| | | task.setTargetSite(operationPort.getMemo());
|
| | | task.setTargetSite(operationPort.getFlag());
|
| | | task.setBarcode(loc.getBarcode());
|
| | | boolean res = taskService.save(task);
|
| | | if (!res) {
|
| | |
| | | throw new CoolException("当前波次订单不存在!!");
|
| | | }
|
| | |
|
| | | List<CacheSite> cacheSites = cacheSiteService.list(new LambdaQueryWrapper<CacheSite>().eq(CacheSite::getSiteStatus, CacheSiteStatusType.O.id).orderByAsc(CacheSite::getChannel));
|
| | | List<CacheSite> cacheSites = cacheSiteService.list(new LambdaQueryWrapper<CacheSite>()
|
| | | .eq(CacheSite::getSiteStatus, CacheSiteStatusType.O.id).eq(CacheSite::getChannel,task.getTargetSite()));
|
| | |
|
| | | if (cacheSites.isEmpty()) {
|
| | | throw new CoolException("缓存站空间不足,请稍后再试");
|
| | |
| | | cacheSite.setOrderId(orders.get(i).getId());
|
| | | cacheSite.setOrderNo(orders.get(i).getOrderNo());
|
| | | cacheSite.setSiteStatus(CacheSiteStatusType.R.id);
|
| | | cacheSite.setBarcode(loc.getBarcode());
|
| | | cacheSite.setUpdateTime(new Date());
|
| | | if (!cacheSiteService.updateById(cacheSite)) {
|
| | | throw new CoolException("缓存站更新失败");
|