|  |  | 
 |  |  | import com.vincent.rsf.server.common.domain.KeyValVo; | 
 |  |  | import com.vincent.rsf.server.common.domain.PageParam; | 
 |  |  | import com.vincent.rsf.server.manager.entity.TaskItem; | 
 |  |  | import com.vincent.rsf.server.manager.entity.TaskItemLog; | 
 |  |  | import com.vincent.rsf.server.manager.entity.Wave; | 
 |  |  | import com.vincent.rsf.server.manager.entity.WaveItem; | 
 |  |  | import com.vincent.rsf.server.manager.enums.WaveExceStatus; | 
 |  |  | import com.vincent.rsf.server.manager.enums.WaveItemExceStatus; | 
 |  |  | import com.vincent.rsf.server.manager.service.OutStockService; | 
 |  |  | import com.vincent.rsf.server.manager.service.TaskItemLogService; | 
 |  |  | import com.vincent.rsf.server.manager.service.TaskItemService; | 
 |  |  | import com.vincent.rsf.server.manager.service.WaveService; | 
 |  |  | import com.vincent.rsf.server.manager.service.impl.TaskItemLogServiceImpl; | 
 |  |  | import com.vincent.rsf.server.manager.service.impl.WaveItemServiceImpl; | 
 |  |  | import com.vincent.rsf.server.system.controller.BaseController; | 
 |  |  | import io.swagger.annotations.ApiOperation; | 
 |  |  | import org.apache.commons.lang3.StringUtils; | 
 |  |  | 
 |  |  |     private WaveService waveService; | 
 |  |  |     @Autowired | 
 |  |  |     private TaskItemService taskItemService; | 
 |  |  |     @Autowired | 
 |  |  |     private OutStockService outStockService; | 
 |  |  |     @Autowired | 
 |  |  |     private TaskItemLogService taskItemLogService; | 
 |  |  |     @Autowired | 
 |  |  |     private WaveItemServiceImpl waveItemService; | 
 |  |  |  | 
 |  |  |     @PreAuthorize("hasAuthority('manager:wave:list')") | 
 |  |  |     @PostMapping("/wave/page") | 
 |  |  | 
 |  |  |         if (Objects.isNull(id)) { | 
 |  |  |             return R.error("参数不能为空!!"); | 
 |  |  |         } | 
 |  |  |         Wave wave = waveService.getById(id); | 
 |  |  |         if (Objects.isNull(wave)) { | 
 |  |  |             throw new CoolException("波次单不存在!!"); | 
 |  |  |         } | 
 |  |  |         waveService.update(new LambdaUpdateWrapper<Wave>() | 
 |  |  |                 .eq(Wave::getId, id) | 
 |  |  |                 .set(Wave::getExceStatus, WaveExceStatus.WAVE_EXCE_STATUS_TASK.val)); | 
 |  |  |         return R.ok(); | 
 |  |  |                 .set(Wave::getExceStatus, WaveExceStatus.WAVE_EXCE_STATUS_PAUSE.val)); | 
 |  |  |  | 
 |  |  |         return waveService.stopPubTask(id); | 
 |  |  |     } | 
 |  |  |  | 
 |  |  | } |