|  |  |  | 
|---|
|  |  |  | import com.zy.acs.manager.manager.entity.AgvDetail; | 
|---|
|  |  |  | import com.zy.acs.manager.manager.entity.Task; | 
|---|
|  |  |  | import com.zy.acs.manager.manager.enums.TaskStsType; | 
|---|
|  |  |  | import com.zy.acs.manager.manager.service.AgvService; | 
|---|
|  |  |  | import com.zy.acs.manager.manager.service.CodeService; | 
|---|
|  |  |  | import com.zy.acs.manager.manager.service.TaskService; | 
|---|
|  |  |  | import lombok.Data; | 
|---|
|  |  |  | 
|---|
|  |  |  |  | 
|---|
|  |  |  | private String code = "-"; | 
|---|
|  |  |  |  | 
|---|
|  |  |  | private Boolean online = Boolean.FALSE; | 
|---|
|  |  |  |  | 
|---|
|  |  |  | private List<Long> taskIds = new ArrayList<>(); | 
|---|
|  |  |  |  | 
|---|
|  |  |  | public void sync(Object obj, CodeService codeService, TaskService taskService) { | 
|---|
|  |  |  | public void sync(Object obj, CodeService codeService, TaskService taskService, AgvService agvService) { | 
|---|
|  |  |  | if (null == obj) return; | 
|---|
|  |  |  | if (obj instanceof AgvDetail) { | 
|---|
|  |  |  | AgvDetail agvDetail = (AgvDetail) obj; | 
|---|
|  |  |  | this.setOnline(agvService.judgeOnline(agvDetail.getAgvId())); | 
|---|
|  |  |  | this.setAgvStatus(agvDetail.getStatusDesc()); | 
|---|
|  |  |  | if (null != agvDetail.getPos()) { | 
|---|
|  |  |  | this.setPos(String.valueOf(agvDetail.getPos())); | 
|---|
|  |  |  | 
|---|
|  |  |  | List<Task> tasks = taskService.selectInSts(agvDetail.getAgvId(), TaskStsType.WAITING, TaskStsType.ASSIGN, TaskStsType.PROGRESS); | 
|---|
|  |  |  | if (!Cools.isEmpty(tasks)) { | 
|---|
|  |  |  | this.setTaskIds(tasks.stream().map(Task::getId).collect(Collectors.toList())); | 
|---|
|  |  |  | this.getTaskIds().add(6441L); | 
|---|
|  |  |  | this.getTaskIds().add(6442L); | 
|---|
|  |  |  | this.getTaskIds().add(6443L); | 
|---|
|  |  |  | } | 
|---|
|  |  |  | } | 
|---|
|  |  |  | } | 
|---|