| File was renamed from hangzhoumesParent/common/servicebase/src/main/java/com/mes/engineering/service/impl/EngineeringServiceImpl.java |
| | |
|---|
| | | package com.mes.engineering.service.impl; |
|---|
| | | |
|---|
| | | import com.baomidou.dynamic.datasource.annotation.DS; |
|---|
| | | import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; |
|---|
| | | import com.baomidou.mybatisplus.extension.conditions.update.LambdaUpdateChainWrapper; |
|---|
| | | import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; |
|---|
| | | import com.mes.engineering.entity.Engineering; |
|---|
| | | import com.mes.engineering.mapper.EngineeringMapper; |
|---|
| | | import com.mes.engineering.service.EngineeringService; |
|---|
| | | import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; |
|---|
| | | import com.mes.pp.entity.OptimizeProject; |
|---|
| | | import com.mes.pp.mapper.OptimizeProjectMapper; |
|---|
| | | import lombok.extern.slf4j.Slf4j; |
|---|
| | |
|---|
| | | |
|---|
| | | @Autowired |
|---|
| | | OptimizeProjectMapper optimizeProjectMapper; |
|---|
| | | @Autowired |
|---|
| | | private EngineeringMapper engineeringMapper; |
|---|
| | | |
|---|
| | | //开始/暂停任务 |
|---|
| | | @Override |
|---|
| | | public boolean changeTask(String projectId, Integer state) { |
|---|
| | | //使用projectId作为条件修改state字段 |
|---|
| | | //暂停正在进行工程 |
|---|
| | | LambdaUpdateChainWrapper<Engineering> pauseWrapper = new LambdaUpdateChainWrapper<>(this.getBaseMapper()); |
|---|
| | | pauseWrapper.set(Engineering::getState,0); |
|---|
| | | pauseWrapper.eq(Engineering::getState,1); |
|---|
| | | pauseWrapper.update(); |
|---|
| | | //使用projectId作为条件开始工程 |
|---|
| | | LambdaUpdateChainWrapper<Engineering> wrapper = new LambdaUpdateChainWrapper<>(this.getBaseMapper()); |
|---|
| | | wrapper.set(Engineering::getState,state); |
|---|
| | | wrapper.eq(Engineering::getEngineerId,projectId); |
|---|
| | |
|---|
| | | } |
|---|
| | | |
|---|
| | | @Override |
|---|
| | | public void saveEngineering(List<Engineering> engineerings) { |
|---|
| | | this.saveBatch(engineerings); |
|---|
| | | public void saveEngineering(List<Engineering> engineering) { |
|---|
| | | this.saveBatch(engineering); |
|---|
| | | //保存钢化工程信息 |
|---|
| | | } |
|---|
| | | |
|---|
| | | @Override |
|---|
| | | public Engineering selectInitiate(Integer state) { |
|---|
| | | //查询是否有开始上片的工程任务 |
|---|
| | | QueryWrapper<Engineering> wrapper = new QueryWrapper<>(); |
|---|
| | | wrapper.eq("state", state); |
|---|
| | | return this.getOne(wrapper); |
|---|
| | | } |
|---|
| | | |
|---|
| | | @Override |
|---|
| | | public List<Engineering> selectTask() { |
|---|
| | | //查询可开始任务的工程 |
|---|
| | | QueryWrapper<Engineering> wrapper = new QueryWrapper<>(); |
|---|
| | | wrapper.eq("state", 0); |
|---|
| | | return engineeringMapper.selectList(wrapper); |
|---|
| | | } |
|---|
| | | |
|---|
| | | } |
|---|
