|  |  |  | 
|---|
|  |  |  | import com.zy.asrs.wcs.core.entity.TaskCtg; | 
|---|
|  |  |  | import com.zy.asrs.wcs.core.kernel.AnalyzeService; | 
|---|
|  |  |  | import com.zy.asrs.wcs.core.model.enums.DeviceCtgType; | 
|---|
|  |  |  | import com.zy.asrs.wcs.core.model.enums.TaskCtgType; | 
|---|
|  |  |  | import com.zy.asrs.wcs.core.model.enums.TaskStsType; | 
|---|
|  |  |  | import com.zy.asrs.wcs.core.service.BasShuttleService; | 
|---|
|  |  |  | import com.zy.asrs.wcs.core.service.MotionService; | 
|---|
|  |  |  | 
|---|
|  |  |  |  | 
|---|
|  |  |  | //获取手动任务类型 | 
|---|
|  |  |  | TaskCtg taskCtg = taskCtgService.getOne(new LambdaQueryWrapper<TaskCtg>() | 
|---|
|  |  |  | .eq(TaskCtg::getFlag, "MANUAL") | 
|---|
|  |  |  | .eq(TaskCtg::getFlag, String.valueOf(TaskCtgType.MANUAL)) | 
|---|
|  |  |  | .eq(TaskCtg::getStatus, 1)); | 
|---|
|  |  |  | if (taskCtg == null) { | 
|---|
|  |  |  | return R.error(); | 
|---|
|  |  |  | 
|---|
|  |  |  |  | 
|---|
|  |  |  | shuttleThread.reset(null); | 
|---|
|  |  |  | return R.ok(); | 
|---|
|  |  |  | } else if (param.getShuttleTaskMode().equals("requestWaiting")) { | 
|---|
|  |  |  | //申请确认 | 
|---|
|  |  |  | Device device = deviceService.getOne(new LambdaQueryWrapper<Device>() | 
|---|
|  |  |  | .eq(Device::getDeviceType, DeviceCtgType.SHUTTLE.val()) | 
|---|
|  |  |  | .eq(Device::getStatus, 1) | 
|---|
|  |  |  | .eq(Device::getDeviceNo, shuttleNo)); | 
|---|
|  |  |  | if (device == null) { | 
|---|
|  |  |  | return R.error("设备不存在"); | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|
|  |  |  | ShuttleThread shuttleThread = (ShuttleThread) SlaveConnection.get(SlaveType.Shuttle, device.getId().intValue()); | 
|---|
|  |  |  | if (shuttleThread == null) { | 
|---|
|  |  |  | return R.error("设备离线"); | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|
|  |  |  | shuttleThread.requestWaiting(); | 
|---|
|  |  |  | return R.ok(); | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|
|  |  |  | Task task = new Task(); | 
|---|
|  |  |  | 
|---|
|  |  |  | task.setPriority(10); | 
|---|
|  |  |  | task.setOriginSite(null); | 
|---|
|  |  |  | task.setOriginLoc(sourceLoc); | 
|---|
|  |  |  | task.setDestSite(targetSite); | 
|---|
|  |  |  | task.setDestSite(null); | 
|---|
|  |  |  | task.setDestLoc(targetLoc); | 
|---|
|  |  |  | task.setIoTime(new Date()); | 
|---|
|  |  |  | task.setStartTime(new Date()); | 
|---|
|  |  |  | task.setStatus(1); | 
|---|
|  |  |  | task.setMemo("manual"); | 
|---|
|  |  |  | task.setMemo(targetSite); | 
|---|
|  |  |  | task.setShuttleNo(param.getShuttleNo()); | 
|---|
|  |  |  |  | 
|---|
|  |  |  | if (param.getShuttleTaskMode().equals("takeMove")) { | 
|---|