|
@ -35,6 +35,7 @@ import org.nl.wms.sch.task_manage.task.tasks.mapper.PointMapper; |
|
|
import org.nl.wms.util.PointUtils; |
|
|
import org.nl.wms.util.PointUtils; |
|
|
import org.nl.wms.util.TaskUtils; |
|
|
import org.nl.wms.util.TaskUtils; |
|
|
import org.springframework.beans.factory.annotation.Autowired; |
|
|
import org.springframework.beans.factory.annotation.Autowired; |
|
|
|
|
|
import org.springframework.context.annotation.Lazy; |
|
|
import org.springframework.stereotype.Service; |
|
|
import org.springframework.stereotype.Service; |
|
|
import org.springframework.transaction.annotation.Transactional; |
|
|
import org.springframework.transaction.annotation.Transactional; |
|
|
|
|
|
|
|
@ -54,6 +55,7 @@ import java.util.concurrent.TimeUnit; |
|
|
*/ |
|
|
*/ |
|
|
@Slf4j |
|
|
@Slf4j |
|
|
@Service |
|
|
@Service |
|
|
|
|
|
@Lazy |
|
|
public class AcsToWmsServiceImpl implements AcsToWmsService { |
|
|
public class AcsToWmsServiceImpl implements AcsToWmsService { |
|
|
|
|
|
|
|
|
// 反射类方法的缓存
|
|
|
// 反射类方法的缓存
|
|
@ -150,9 +152,9 @@ public class AcsToWmsServiceImpl implements AcsToWmsService { |
|
|
AbstractTask abstractTask = taskFactory.getTask(processingClass); |
|
|
AbstractTask abstractTask = taskFactory.getTask(processingClass); |
|
|
// 更新任务
|
|
|
// 更新任务
|
|
|
try { |
|
|
try { |
|
|
abstractTask.updateTaskStatus(taskId, status); |
|
|
abstractTask.updateTaskStatus(taskObj.getTask_id(), status); |
|
|
} catch (Exception e) { |
|
|
} catch (Exception e) { |
|
|
log.error("任务状态更新失败: {}", message); |
|
|
log.error("任务状态更新失败: {}{}", e,e.getMessage()); |
|
|
return BaseResponse.responseError(requestNo, "任务:[" + taskId + "]状态更新失败," + message); |
|
|
return BaseResponse.responseError(requestNo, "任务:[" + taskId + "]状态更新失败," + message); |
|
|
} |
|
|
} |
|
|
return BaseResponse.responseOk(requestNo, "任务状态反馈成功!"); |
|
|
return BaseResponse.responseOk(requestNo, "任务状态反馈成功!"); |
|
|