| | |
| | | package com.zy.acs.conveyor.scheduler; |
| | | |
| | | import com.zy.acs.conveyor.core.enums.ConveyorStateType; |
| | | import com.zy.acs.conveyor.core.properties.CtuOperationConfig; |
| | | import com.zy.acs.conveyor.core.properties.CtuServiceProperties; |
| | | import com.zy.acs.conveyor.entity.Job; |
| | | import com.zy.acs.conveyor.mapper.JobMapper; |
| | |
| | | for (Job job : jobs) { |
| | | jobService.saveJobLog(job); |
| | | } |
| | | Boolean flag = true; |
| | | List<CtuOperationConfig> operations = properties.getOperations(); |
| | | for (CtuOperationConfig config : operations) { |
| | | if (config.getType().equals(ConveyorStateType.FAKEUSER)) { |
| | | flag = false; |
| | | } |
| | | } |
| | | if (flag) { |
| | | jobs = jobMapper.listJobToLog(ConveyorStateType.OUTBOUND.getStatus(), 1); |
| | | for (Job job : jobs) { |
| | | jobService.saveJobLog(job); |
| | | } |
| | | } else { |
| | | jobs = jobMapper.listJobToLog(ConveyorStateType.FAKEUSER.getStatus(), 1); |
| | | for (Job job : jobs) { |
| | | jobService.saveJobLog(job); |
| | | } |
| | | } |
| | | } |
| | | |
| | | |
| | | } |