| | |
| | | .selectAs(PlatformWmsJob::getIoCreatedate,PlatformJob::getIoCreatedate) |
| | | .selectAs(SystemUser::getRealname,PlatformJob::getOutUserName) |
| | | .selectAs(PlatformBooks::getId,PlatformJob::getBookId) |
| | | .select("s.REALNAME",PlatformJob::getEditUserName) |
| | | .leftJoin(Platform.class,Platform::getId,PlatformJob::getPlatformId) |
| | | .leftJoin(PlatformGroup.class,PlatformGroup::getId,Platform::getGroupId) |
| | | .leftJoin(PlatformWmsJob.class,PlatformWmsJob::getCarryBillCode,PlatformJob::getBillCode) |
| | | .leftJoin(SystemUser.class,SystemUser::getId,PlatformJob::getOutUserId) |
| | | .leftJoin(PlatformBooks.class,PlatformBooks::getJobId,PlatformJob::getId) |
| | | .leftJoin(" system_user s on t.EDITOR = s.id ") |
| | | .eq(PlatformJob::getIsdeleted,Constants.ZERO) |
| | | .eq(pageWrap.getModel().getId() != null, PlatformJob::getId, pageWrap.getModel().getId()) |
| | | .eq(pageWrap.getModel().getCreator() != null, PlatformJob::getCreator, pageWrap.getModel().getCreator()) |
| | |
| | | |
| | | if(com.github.xiaoymin.knife4j.core.util.CollectionUtils.isNotEmpty(platformWmsDetailList)){ |
| | | platformJob.setTotalNum( |
| | | platformWmsDetailList.stream().map(m->m.getIoQty()).reduce(BigDecimal.ZERO,BigDecimal::add) |
| | | platformWmsDetailList.stream().filter(i->Objects.nonNull(i.getIoQty())).map(m->m.getIoQty()).reduce(BigDecimal.ZERO,BigDecimal::add) |
| | | ); |
| | | platformWmsJob.setPlatformWmsDetailList(platformWmsDetailList); |
| | | platformJob.setPlatformWmsJob(platformWmsJob); |
| | |
| | | * @param jobIdList |
| | | */ |
| | | @Override |
| | | public void dealJobFinish(List<Integer> jobIdList){ |
| | | public void dealJobFinish(List<Integer> jobIdList,LoginUserInfo loginUserInfo){ |
| | | if(com.github.xiaoymin.knife4j.core.util.CollectionUtils.isNotEmpty(jobIdList)){ |
| | | List<PlatformJob> platformJobList = platformJobMapper.selectList(new QueryWrapper<PlatformJob>().lambda() |
| | | .eq(PlatformJob::getIsdeleted,Constants.ZERO) |
| | |
| | | platformJobMapper.update(null,new UpdateWrapper<PlatformJob>().lambda() |
| | | .set(PlatformJob::getStatus,Constants.PlatformJobStatus.DONE.getKey()) |
| | | .set(PlatformJob::getDoneDate,new Date()) |
| | | .set(PlatformJob::getEditor,loginUserInfo.getId()) |
| | | .in(PlatformJob::getStatus,Constants.PlatformJobStatus.WAIT_CONFIRM.getKey(),Constants.PlatformJobStatus.WART_SIGN_IN.getKey(),Constants.PlatformJobStatus.WAIT_CALL.getKey()) |
| | | .eq(PlatformJob::getIsdeleted,Constants.ZERO) |
| | | .in(PlatformJob::getId,platformJobList.stream().map(i->i.getId()).collect(Collectors.toList()))); |