| | |
| | | @Override |
| | | public boolean changeTask(String projectId, Integer state) { |
| | | //暂停正在进行工程 |
| | | LambdaUpdateChainWrapper<Engineering> pauseWrapper = new LambdaUpdateChainWrapper<>(this.getBaseMapper()); |
| | | pauseWrapper.set(Engineering::getState,0); |
| | | pauseWrapper.eq(Engineering::getState,1); |
| | | boolean pause = pauseWrapper.update(); |
| | | // LambdaUpdateChainWrapper<Engineering> pauseWrapper = new LambdaUpdateChainWrapper<>(this.getBaseMapper()); |
| | | // pauseWrapper.set(Engineering::getState,0); |
| | | // pauseWrapper.eq(Engineering::getState,1); |
| | | // boolean pause = pauseWrapper.update(); |
| | | //使用projectId作为条件开始工程 |
| | | LambdaUpdateChainWrapper<Engineering> wrapper = new LambdaUpdateChainWrapper<>(this.getBaseMapper()); |
| | | wrapper.set(Engineering::getState,state); |
| | | wrapper.eq(Engineering::getEngineerId,projectId); |
| | | wrapper.update(); |
| | | boolean pause = wrapper.update(); |
| | | return pause; |
| | | } |
| | | |
| | |
| | | } |
| | | |
| | | @Override |
| | | public Engineering selectInitiate(Integer state) { |
| | | public Engineering selectInitiate(Integer state) { |
| | | //查询是否有开始上片的工程任务 |
| | | QueryWrapper<Engineering> wrapper = new QueryWrapper<>(); |
| | | wrapper.eq("state", state); |
| | | wrapper.eq("state", state) |
| | | .last("limit 1"); |
| | | return engineeringMapper.selectOne(wrapper); |
| | | } |
| | | @Override |
| | | public Engineering selectInitiates(Integer state,Integer cell) { |
| | | //查询是否有开始上片的工程任务 |
| | | QueryWrapper<Engineering> wrapper = new QueryWrapper<>(); |
| | | wrapper.eq("state", state) |
| | | .eq("station_cell", cell) |
| | | .last("limit 1"); |
| | | return engineeringMapper.selectOne(wrapper); |
| | | } |
| | | |
| | | @Override |
| | | public Engineering selectUpInitiate(Integer state, Integer equipmentId) { |
| | | return null; |
| | | } |
| | | |
| | | @Override |
| | |
| | | public boolean pauseTask(String engineerId, Integer state) { |
| | | //暂停正在进行工程 |
| | | LambdaUpdateChainWrapper<Engineering> pauseWrapper = new LambdaUpdateChainWrapper<>(this.getBaseMapper()); |
| | | pauseWrapper.set(Engineering::getState, state); |
| | | pauseWrapper.eq(Engineering::getEngineerId, engineerId); |
| | | return pauseWrapper.update(); |
| | | } |
| | | |
| | | @Override |
| | | public boolean deleteTask(String engineerId) { |
| | | //删除工程表 |
| | | QueryWrapper<Engineering> wrapper = new QueryWrapper<>(); |
| | | wrapper.eq("engineer_id", engineerId); |
| | | return this.remove(wrapper); |
| | | } |
| | | |
| | | @Override |
| | | public boolean changeTasks(Engineering engineering) { |
| | | //暂停正在进行工程 |
| | | LambdaUpdateChainWrapper<Engineering> pauseWrapper = new LambdaUpdateChainWrapper<>(this.getBaseMapper()); |
| | | pauseWrapper.set(Engineering::getState,0); |
| | | pauseWrapper.eq(Engineering::getState,1); |
| | | return pauseWrapper.update(); |
| | | pauseWrapper.eq(Engineering::getStationCell,engineering.getStationCell()); |
| | | pauseWrapper.update(); |
| | | |
| | | LambdaUpdateChainWrapper<Engineering> wrapper = new LambdaUpdateChainWrapper<>(this.getBaseMapper()); |
| | | wrapper.set(Engineering::getState,engineering.getState()); |
| | | wrapper.set(Engineering::getStationCell,engineering.getStationCell()); |
| | | wrapper.eq(Engineering::getEngineerId,engineering.getEngineerId()); |
| | | return wrapper.update(); |
| | | } |
| | | |
| | | |
| | | } |