//数据格式
public class SubtitleMsgData {
    public boolean definite;
    public String language;
    public int mode;
    public boolean paragraph;
    public int sequence;
    public String text;
    public String userId;

    @Override
    public String toString() {
        return "SubtitleMsgData{" +
                "definite=" + definite +
                ", language='" + language + ''' +
                ", mode=" + mode +
                ", paragraph=" + paragraph +
                ", sequence=" + sequence +
                ", text='" + text + ''' +
                ", userId='" + userId + ''' +
                '}';
    }
}

//回调
public void onRoomBinaryMessageReceived(String uid, ByteBuffer buffer) {
    StringBuilder subtitles = new StringBuilder();
    buffer.flip(); // 切换到读取模式
    boolean ret = unpack(buffer, subtitles); 
    if (ret) {
        parseData(subtitles.toString());
    }
}

// 拆包校验
public static boolean unpack(ByteBuffer message, StringBuilder subtitles) {
    final int kSubtitleHeaderSize = 8;
    if (message.remaining() < kSubtitleHeaderSize) {
        return false;
    }

    // 魔法数字 "subv"
    int magicNumber = (message.get() << 24) | (message.get() << 16) | (message.get() << 8) | (message.get());
    if (magicNumber != 0x73756276) {
        return false;
    }

    int length = Integer.reverseBytes(message.getInt());

    if (message.remaining() != length) {
        return false;
    }

    // 读取字幕内容
    byte[] subtitleBytes = new byte[length];
    message.get(subtitleBytes);
    subtitles.append(new String(subtitleBytes, StandardCharsets.UTF_8));

    return true;
}

// 解析字幕消息
public static void parseData(String msg) {
    try {
        // 解析 JSON 字符串
        ObjectMapper objectMapper = new ObjectMapper();
        JsonNode jsonData = objectMapper.readTree(msg);

        // 存储解析后的数据
        List<SubtitleMsgData> subtitles = new ArrayList<>();

        // 遍历 JSON 数据并填充结构体
        for (JsonNode item : jsonData.get("data")) {
            SubtitleMsgData subData = new SubtitleMsgData();
            subData.definite = item.get("definite").asBoolean();
            subData.language = item.get("language").asText();
            subData.mode = item.get("mode").asInt();
            subData.paragraph = item.get("paragraph").asBoolean();
            subData.sequence = item.get("sequence").asInt();
            subData.text = item.get("text").asText();
            subData.userId = item.get("userId").asText();
            subtitles.add(subData);
        }
    } catch (Exception e) {
        e.printStackTrace();
    }
}

//数据格式
@interface SubtitleMsgData : NSObject

@property (nonatomic, assign) BOOL definite;
@property (nonatomic, copy) NSString *language;
@property (nonatomic, assign) NSInteger mode;
@property (nonatomic, assign) BOOL paragraph;
@property (nonatomic, assign) NSInteger sequence;
@property (nonatomic, copy) NSString *text;
@property (nonatomic, copy) NSString *userId;

@end

@implementation SubtitleMsgData
@end

//回调
- (void)rtcRoom:( ByteRTCRoom *_Nonnull)rtcRoom onRoomBinaryMessageReceived:(NSString *_Nonnull)uid message:(NSData *_Nonnull)message {
    NSString *subtitles = unpack(buffer);
    if (subtitles) {
        parseData(subtitles);
    }
}


// 大端序转换
uint32_t swapUInt32(uint32_t value) {
    return ((value & 0x000000FF) << 24) |
           ((value & 0x0000FF00) << 8) |
           ((value & 0x00FF0000) >> 8) |
           ((value & 0xFF000000) >> 24);
}

//拆包校验
NSString *unpack(NSData *data) {
    const int kSubtitleHeaderSize = 8;
    NSUInteger size = data.length;
    if (size < kSubtitleHeaderSize) {
        return nil;
    }
    const uint8_t *message = data.bytes;
    // Check magic number "subv"
    uint32_t magic = (message[0] << 24) | (message[1] << 16) | (message[2] << 8) | message[3];
    if (magic != 0x73756276) {
        return nil;
    }
    
    // Get length
    uint32_t length = (message[4] << 24) | (message[5] << 16) | (message[6] << 8) | message[7];
    if (size - kSubtitleHeaderSize != length) {
        return nil;
    }
    
    // Get subtitles
    NSString *subtitles = nil;
    if (length > 0) {
        subtitles = [[NSString alloc] initWithBytes:message + kSubtitleHeaderSize length:length encoding:NSUTF8StringEncoding];
    } else {
        subtitles = @"";
    }
    
    return subtitles;
}
//解析
void parseData(NSString *msg) {
    NSError *error = nil;
    NSDictionary *json_data = [NSJSONSerialization JSONObjectWithData:[msg dataUsingEncoding:NSUTF8StringEncoding] options:0 error:&error];
    
    if (error) {
        NSLog(@"JSON Parse Error: %@", error);
        return;
    }
    
    NSMutableArray<SubtitleMsgData *> *subtitles = [NSMutableArray array];
    
    for (NSDictionary *item in json_data[@"data"]) {
        SubtitleMsgData *subData = [[SubtitleMsgData alloc] init];
        subData.definite = [item[@"definite"] boolValue];
        subData.language = item[@"language"];
        subData.mode = [item[@"mode"] integerValue];
        subData.paragraph = [item[@"paragraph"] boolValue];
        subData.sequence = [item[@"sequence"] integerValue];
        subData.text = item[@"text"];
        subData.userId = item[@"userId"];
        
        [subtitles addObject:subData];
    }
}