package com.northglass.service.cutmachinetask;
|
|
import java.util.List;
|
|
import org.slf4j.Logger;
|
import org.slf4j.LoggerFactory;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.stereotype.Component;
|
import org.springframework.transaction.annotation.Transactional;
|
|
import com.northglass.entity.CutMachineTask;
|
import com.northglass.repository.CutMachineTaskDao;
|
|
@Component
|
@Transactional
|
public class CutMachineTaskService {
|
|
private static final Logger LOGGER = LoggerFactory.getLogger(CutMachineTaskService.class);
|
|
@Autowired
|
private CutMachineTaskDao cutMachineTaskDao;
|
|
public CutMachineTask save(CutMachineTask cutMachineTask) {
|
return cutMachineTaskDao.save(cutMachineTask);
|
}
|
|
/**
|
* 获取需要执行的任务；
|
*
|
* @param cutMachine
|
* @return
|
*/
|
public CutMachineTask getWorkingCutMachineTask(Long cutMachineId) {
|
LOGGER.debug(">开始执行切割任务");
|
|
CutMachineTask workingTask = cutMachineTaskDao.findInWorkTaskByCutMachineId(cutMachineId);
|
|
if (workingTask != null) {
|
workingTask.setMessage("");
|
workingTask = cutMachineTaskDao.save(workingTask);
|
|
return workingTask;
|
}
|
|
List<CutMachineTask> waitingTasks = cutMachineTaskDao.findWaitingTasksByCutMachineId(cutMachineId);
|
LOGGER.debug("waitingTasks size: " + waitingTasks.size());
|
|
if (waitingTasks.size() > 0) {
|
CutMachineTask task = waitingTasks.get(0);
|
// task.setState(CutMachineTaskState.IN_WORK);
|
// task = cutMachineTaskDao.save(task);
|
|
return task;
|
}
|
|
LOGGER.debug(">结束切割任务");
|
return null;
|
}
|
}
|
