| | |
| | | |
| | | import com.baomidou.mybatisplus.core.toolkit.Wrappers; |
| | | import com.baomidou.mybatisplus.extension.conditions.query.LambdaQueryChainWrapper; |
| | | import lombok.AllArgsConstructor; |
| | | import lombok.extern.slf4j.Slf4j; |
| | | import org.springblade.core.mp.base.BizServiceImpl; |
| | | import org.springblade.core.tool.utils.Func; |
| | | import org.springblade.mdm.commons.service.ParamService; |
| | | import org.springblade.mdm.flow.entity.TaskDispatch; |
| | | import org.springblade.mdm.flow.mapper.TaskDispatchMapper; |
| | |
| | | |
| | | import java.time.LocalDateTime; |
| | | import java.util.List; |
| | | import java.util.Optional; |
| | | |
| | | /** |
| | | * 任务派工数据 处理服务 |
| | |
| | | */ |
| | | @Slf4j |
| | | @Service |
| | | @AllArgsConstructor |
| | | public class TaskDispatchService extends BizServiceImpl<TaskDispatchMapper, TaskDispatch> { |
| | | @Autowired |
| | | private ParamService paramService; |
| | | @Autowired |
| | | private DrawingNosMapper drawingNosMapper; |
| | | |
| | | |
| | | @Transactional(rollbackFor = Exception.class) |
| | | public TaskDispatch saveTask(TaskAssignVO startVO,boolean isDup) { |
| | | TaskDispatch taskDispatch = new TaskDispatch(); |
| | |
| | | * 加u人下拉数据 |
| | | * @param drawingNo |
| | | */ |
| | | void addDrawingNos(String drawingNo){ |
| | | public void addDrawingNos(String drawingNo){ |
| | | DrawingNos data = drawingNosMapper.selectById(drawingNo); |
| | | if(data == null){ |
| | | data = new DrawingNos(); |
| | |
| | | return false; |
| | | } |
| | | |
| | | int taskDupDays = Func.toInt(paramService.taskDuplicateCheckDays()); |
| | | int taskDupDays = paramService.taskDuplicateCheckDays(); |
| | | LocalDateTime checkStartDate = LocalDateTime.now().minusDays(taskDupDays); |
| | | LambdaQueryChainWrapper<TaskDispatch> q = lambdaQuery().eq(TaskDispatch::getDrawingNo,startVO.getDrawingNo()) |
| | | .eq(TaskDispatch::getProcessNo,startVO.getProcessNo()) |
| | |
| | | } |
| | | |
| | | } |
| | | |
| | | /** |
| | | * 清理过期的异常任务计划 |
| | | */ |
| | | @Transactional |
| | | public void cleanExpiredExceptionTask() { |
| | | int expireDays = paramService.getTaskExpireDays(); |
| | | LocalDateTime expiredTime = LocalDateTime.now().minusDays(expireDays); |
| | | baseMapper.deleteExpiredExceptionTasks(expiredTime); |
| | | } |
| | | |
| | | /** |
| | | * 根据工序唯一码获取派工数据 |
| | | * @param operationId 工序唯一码 |
| | | * @return |
| | | */ |
| | | public TaskDispatch getByOperationId(String operationId) { |
| | | Optional<TaskDispatch> opt = lambdaQuery().eq(TaskDispatch::getOperationId, operationId).oneOpt(); |
| | | return opt.orElse(null); |
| | | } |
| | | |
| | | public TaskDispatch getByProgramNo(String programNo) { |
| | | return lambdaQuery().eq(TaskDispatch::getProgramNo, programNo).one(); |
| | | } |
| | | } |