| | |
|---|
| | | @ServiceActivator(inputChannel = ChannelName.INBOUND_EVENTS_FLIGHT_TASK_PROGRESS, outputChannel = ChannelName.OUTBOUND_EVENTS) |
|---|
| | | public CommonTopicReceiver handleProgress(CommonTopicReceiver receiver, MessageHeaders headers) { |
|---|
| | | log.info("上报航线任务进度: {}", receiver.toString()); |
|---|
| | | EventsReceiver<WaylineTaskProgressReceiver> eventsReceiver = mapper.convertValue(receiver.getData(), |
|---|
| | | EventsReceiver<WaylineTaskProgressReceiver> eventsReceiver = mapper.convertValue(receiver.getData(), |
|---|
| | | new TypeReference<EventsReceiver<WaylineTaskProgressReceiver>>(){}); |
|---|
| | | eventsReceiver.setBid(receiver.getBid()); |
|---|
| | | eventsReceiver.setSn(receiver.getGateway()); |
|---|
| | |
|---|
| | | try { |
|---|
| | | Boolean isAddBp = waylineJobBreakPointService.addWaylineJobBreakPoint(WaylineJobBreakPointEntity.builder() |
|---|
| | | .jobId(receiver.getBid()) |
|---|
| | | .index(breakPoint.getIndex()) |
|---|
| | | .bpIndex(breakPoint.getIndex()) |
|---|
| | | .state(breakPoint.getState()) |
|---|
| | | .progress(breakPoint.getProgress()) |
|---|
| | | .waylineId(breakPoint.getWaylineId()) |
|---|
