yangys
2025-09-13 3ffe33aaa24386337e3638558eca731c62f25521
blade-service/blade-mdm/src/main/java/org/springblade/mdm/flow/service/TaskDispatchService.java
@@ -3,10 +3,8 @@
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;
@@ -20,6 +18,7 @@
import java.time.LocalDateTime;
import java.util.List;
import java.util.Optional;
/**
 * 任务派工数据 处理服务
@@ -28,12 +27,13 @@
 */
@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();
@@ -51,7 +51,7 @@
    * 加u人下拉数据
    * @param drawingNo
    */
   void addDrawingNos(String drawingNo){
   public void addDrawingNos(String drawingNo){
      DrawingNos data = drawingNosMapper.selectById(drawingNo);
      if(data == null){
         data = new DrawingNos();
@@ -85,7 +85,7 @@
         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())
@@ -113,4 +113,28 @@
      }
   }
   /**
    * 清理过期的异常任务计划
    */
   @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();
    }
}