YiWuProject.git

File was renamed from hangzhoumesParent/common/servicebase/src/main/java/com/mes/engineering/service/impl/EngineeringServiceImpl.java
			@@ -1,11 +1,12 @@
			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;
			@@ -29,14 +30,23 @@

			@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);
			boolean pause = pauseWrapper.update();
			//使用projectId作为条件开始工程
			LambdaUpdateChainWrapper<Engineering> wrapper = new LambdaUpdateChainWrapper<>(this.getBaseMapper());
			wrapper.set(Engineering::getState,state);
			wrapper.eq(Engineering::getEngineerId,projectId);
			return wrapper.update();
			wrapper.update();
			return pause;
			}

			@Override
			@@ -79,8 +89,34 @@
			}

			@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 engineeringMapper.selectOne(wrapper);
			}

			@Override
			public List<Engineering> selectTask() {
			//查询可开始任务的工程
			QueryWrapper<Engineering> wrapper = new QueryWrapper<>();
			wrapper.eq("state", 0);
			return engineeringMapper.selectList(wrapper);
			}

			@Override
			public boolean pauseTask(String engineerId, Integer state) {
			//暂停正在进行工程
			LambdaUpdateChainWrapper<Engineering> pauseWrapper = new LambdaUpdateChainWrapper<>(this.getBaseMapper());
			pauseWrapper.set(Engineering::getState,0);
			pauseWrapper.eq(Engineering::getState,1);
			return pauseWrapper.update();
			}

			}