2026-04-01 优化机场视频推流顺序，先入库再推流。

zhaowenyu

2026-04-01 342236a5694a22c544a217c9f1503e5ac790b609

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
package com.ard.sample.annotation.util;
 
import com.ard.sample.annotation.model.dto.AnnotationDTO;
import com.ard.sample.annotation.model.dto.AnnotationDirectoryDTO;
import com.ard.sample.annotation.model.dto.AnnotationPointsDTO;
import com.ard.sample.annotation.model.entity.AnnotationDirectoryEntity;
import com.ard.sample.annotation.model.entity.AnnotationEntity;
import org.springframework.beans.BeanUtils;
 
import java.util.List;
import java.util.stream.Collectors;
 
public class ConvertUtil {
    // 目录DTO → 目录Entity
    public static AnnotationDirectoryEntity directoryDtoToEntity(AnnotationDirectoryDTO dto) {
        AnnotationDirectoryEntity entity = new AnnotationDirectoryEntity();
        BeanUtils.copyProperties(dto, entity);
        return entity;
    }
 
    // 目录Entity → 目录DTO
    public static AnnotationDirectoryDTO directoryEntityToDto(AnnotationDirectoryEntity entity) {
        AnnotationDirectoryDTO dto = new AnnotationDirectoryDTO();
        BeanUtils.copyProperties(entity, dto);
        return dto;
    }
 
    // 标记DTO → 标记Entity（含坐标序列化）
    public static AnnotationEntity annotationDtoToEntity(AnnotationDTO dto) throws Exception {
        AnnotationEntity entity = new AnnotationEntity();
        BeanUtils.copyProperties(dto, entity);
        // 序列化坐标数据
        entity.setCoordinateInfo(JsonSerializeUtil.serialize(dto.getCoordinateInfo()));
        return entity;
    }
 
    // 标记Entity → 标记DTO（含坐标反序列化）
    public static AnnotationDTO annotationEntityToDto(AnnotationEntity entity) throws Exception {
        AnnotationDTO dto = new AnnotationDTO();
        BeanUtils.copyProperties(entity, dto);
        // 反序列化坐标数据
        List<AnnotationPointsDTO> points = JsonSerializeUtil.deserialize(entity.getCoordinateInfo());
        dto.setCoordinateInfo(points);
        return dto;
    }
 
    // 标记Entity列表 → 标记DTO列表
    public static List<AnnotationDTO> annotationEntityListToDtoList(List<AnnotationEntity> entityList) {
        return entityList.stream().map(entity -> {
            try {
                return annotationEntityToDto(entity);
            } catch (Exception e) {
                throw new RuntimeException("标记Entity转DTO失败", e);
            }
        }).collect(Collectors.toList());
    }
}