| | |
|---|
| | | @Mapper |
|---|
| | | public interface MesProTaskMapper extends BaseMapperX<MesProTaskDO> { |
|---|
| | | |
|---|
| | | /** 所有排产写入口以相同顺序锁定工作站；事务提交后释放，跨进程防止资源竞态。 */ |
|---|
| | | @org.apache.ibatis.annotations.Select("SELECT id FROM mes_md_workstation WHERE deleted = 0 ORDER BY id FOR UPDATE") |
|---|
| | | List<Long> lockSchedulingResources(); |
|---|
| | | |
|---|
| | | default List<MesProTaskDO> selectSchedulingTasks() { |
|---|
| | | return selectList(new LambdaQueryWrapperX<MesProTaskDO>() |
|---|
| | | .and(query -> query.isNull(MesProTaskDO::getStatus).or() |
|---|
| | | .notIn(MesProTaskDO::getStatus, MesProTaskStatusEnum.CANCELED.getStatus(), MesProTaskStatusEnum.FINISHED.getStatus())) |
|---|
| | | .orderByAsc(MesProTaskDO::getId)); |
|---|
| | | } |
|---|
| | | |
|---|
| | | default PageResult<MesProTaskDO> selectPage(MesProTaskPageReqVO reqVO) { |
|---|
| | | MPJLambdaWrapperX<MesProTaskDO> query = new MPJLambdaWrapperX<>(); |
|---|
| | | query.selectAll(MesProTaskDO.class); |
|---|
