| | |
|---|
| | | |
|---|
| | | @Override |
|---|
| | | public Boolean hasRunningMotion(String uuid, Long hostId) { |
|---|
| | | return null != this.selectOfTop1(uuid, MotionStsType.EXECUTING.val(), hostId) |
|---|
| | | || null != this.selectOfTop1(uuid, MotionStsType.ERROR.val(), hostId); |
|---|
| | | Motion executeMotion = this.selectOfTop1(uuid, MotionStsType.EXECUTING.val(), hostId); |
|---|
| | | Motion errorMotion = this.selectOfTop1(uuid, MotionStsType.ERROR.val(), hostId); |
|---|
| | | if(errorMotion != null) { |
|---|
| | | return true; |
|---|
| | | } |
|---|
| | | |
|---|
| | | if(executeMotion != null) { |
|---|
| | | if (executeMotion.getSync() == 0) { |
|---|
| | | //检测是否有同步动作 |
|---|
| | | List<Motion> syncMotion = this.list(new LambdaQueryWrapper<Motion>() |
|---|
| | | .eq(Motion::getUuid, uuid) |
|---|
| | | .eq(Motion::getMotionSts, MotionStsType.EXECUTING.val()) |
|---|
| | | .eq(Motion::getHostId, hostId) |
|---|
| | | .eq(Motion::getSync, 1)); |
|---|
| | | if (!syncMotion.isEmpty()) { |
|---|
| | | return true;//存在同步动作 |
|---|
| | | } |
|---|
| | | return false;//当前动作为异步操作 |
|---|
| | | } |
|---|
| | | return true; |
|---|
| | | } |
|---|
| | | |
|---|
| | | return false; |
|---|
| | | } |
|---|
| | | |
|---|
| | | @Override |
|---|
