| | |
| | | import cn.hutool.core.collection.ListUtil; |
| | | |
| | | @Service |
| | | /* loaded from: blade-api.jar:BOOT-INF/classes/org/springblade/modules/mdc/service/impl/WorkstationFeedbackServiceImpl.class */ |
| | | public class WorkstationFeedbackServiceImpl extends ServiceImpl<WorkstationFeedbackMapper, WorkstationFeedback> implements IWorkstationFeedbackService { |
| | | static final String GROUP_FEEDBACK_CACHE_KEY = "group:feedback:list:"; |
| | | @Resource |
| | |
| | | private IEmployeeService employeeService; |
| | | |
| | | /* JADX WARN: Type inference failed for: r0v11, types: [org.springblade.modules.mdc.service.impl.WorkstationFeedbackServiceImpl$1] */ |
| | | @Override // org.springblade.modules.mdc.service.IWorkstationFeedbackService |
| | | @Override |
| | | public IPage<WorkstationFeedbackInfoVO> workstationPage(Query query, boolean excludeImmediate) { |
| | | final List<WorkstationFeedback> immediateFeedback = this.selfService.getImmediateFeedback(); |
| | | final List<Long> workstationList = immediateFeedback.stream().map((v0) -> { |
| | |
| | | }.pageVO(page); |
| | | } |
| | | |
| | | @Override // org.springblade.modules.mdc.service.IWorkstationFeedbackService |
| | | @Override |
| | | public List<WorkstationFeedback> getImmediateFeedback() { |
| | | return list(Lambda.eq(WorkstationFeedback::getFeedbackType, Integer.valueOf(FeedbackType.IMMEDIATE.getValue())) |
| | | .isNull(WorkstationFeedback::getEndTime)); |
| | |
| | | }));*/ |
| | | } |
| | | |
| | | @Override // org.springblade.modules.mdc.service.IWorkstationFeedbackService |
| | | @Override |
| | | public WorkstationFeedback getImmediateFeedback(Serializable workstationId) { |
| | | return getOne(Lambda.eq(WorkstationFeedback::getWorkstationId, workstationId) |
| | | .eq(WorkstationFeedback::getFeedbackType, Integer.valueOf(FeedbackType.IMMEDIATE.getValue())) |
| | |
| | | }));*/ |
| | | } |
| | | |
| | | @Override // org.springblade.modules.mdc.service.IWorkstationFeedbackService |
| | | @Override |
| | | @Transactional |
| | | public boolean startFeedbackByImmediate(WorkstationImmediateFeedBackDTO dto) { |
| | | Date now = new Date(); |
| | |
| | | return true; |
| | | } |
| | | |
| | | @Override // org.springblade.modules.mdc.service.IWorkstationFeedbackService |
| | | @Override |
| | | @Transactional |
| | | public boolean startFeedbackByNoImmediate(final WorkstationNoImmediateFeedBackDTO dto) { |
| | | if (dto.getEndTime().compareTo(new Date()) > 0) { |
| | |
| | | return employee; |
| | | } |
| | | |
| | | @Override // org.springblade.modules.mdc.service.IWorkstationFeedbackService |
| | | @Override |
| | | @Transactional |
| | | public boolean endFeedback(WorkstationEndImmediateFeedBackDTO dto) { |
| | | WorkstationFeedback feedback = this.selfService.cachedById(dto.getFeedbackId()); |
| | |
| | | return updateById(feedback); |
| | | } |
| | | |
| | | @Override // org.springblade.modules.mdc.service.IWorkstationFeedbackService |
| | | @Override |
| | | @Transactional |
| | | public boolean endAndStartAgainFeedback(WorkstationEndAndStartImmediateFeedBackDTO dto) { |
| | | WorkstationEndImmediateFeedBackDTO endImmediateFeedBackDTO = new WorkstationEndImmediateFeedBackDTO(); |
| | |
| | | })).collect(Collectors.toList());*/ |
| | | } |
| | | |
| | | @Override // org.springblade.modules.mdc.service.IWorkstationFeedbackService |
| | | @Override |
| | | public List<StatusRecordVO> groupStatusRecordWithFeedbackCache(final LocalDate statusTime, final Long workstationId, final List<StatusRecordVO> recordList) { |
| | | List<StatusRecordVO> statusRecordList = recordList == null ? new ArrayList<>() : recordList; |
| | | List<StatusRecordVO> cancelList = this.feedbackDetailService.cancelFeedback(statusTime, workstationId).stream().map(feedback -> { |