yangys
2025-09-20 fcee672452c02cc29e0e17ebc27a8c51698c6d0d
blade-service/blade-mdm/src/main/java/org/springblade/mdm/flow/service/TaskDispatchService.java
@@ -4,12 +4,15 @@
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
import com.baomidou.mybatisplus.extension.conditions.query.LambdaQueryChainWrapper;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.lang3.StringUtils;
import org.springblade.core.mp.base.BizServiceImpl;
import org.springblade.mdm.commons.service.ParamService;
import org.springblade.mdm.flow.entity.TaskDispatch;
import org.springblade.mdm.flow.mapper.TaskDispatchMapper;
import org.springblade.mdm.flow.vo.TaskAssignVO;
import org.springblade.mdm.program.entity.DrawingNos;
import org.springblade.mdm.program.entity.NcNode;
import org.springblade.mdm.program.entity.NcNodeHis;
import org.springblade.mdm.program.mapper.DrawingNosMapper;
import org.springframework.beans.BeanUtils;
import org.springframework.beans.factory.annotation.Autowired;
@@ -134,7 +137,30 @@
      return opt.orElse(null);
   }
   /**
    * 根据程序内部编号获取实体
    * @param programNo 内部编号
    * @return 实体
    */
    public TaskDispatch getByProgramNo(String programNo) {
      return lambdaQuery().eq(TaskDispatch::getProgramNo, programNo).one();
    }
   /**
    * 查询偏离单的序号
    * @param programNo 偏离单的程序包名节点
    * @return 序号
    */
   public long getDeviationSerial(String programNo) {
      TaskDispatch dispatch = this.getByProgramNo(programNo);
      return lambdaQuery()
         .eq(TaskDispatch::getDrawingNo,dispatch.getDrawingNo())
         .eq(TaskDispatch::getProcessNo,dispatch.getProcessNo())
         .eq(TaskDispatch::getProcessEdition,dispatch.getProcessEdition())
         .eq(TaskDispatch::getDeviation,dispatch.getDeviation())
         .le(TaskDispatch::getCreateTime,dispatch.getCreateTime())  //时间小于等于当前节点
         .count();
   }
}