//
//  Copyright © 2020 dahua. All rights reserved.
//

#import "LCDeviceVideotapePlayManager.h"
#import <LCOpenSDKDynamic/LCOpenSDK/LCOpenSDK_Download.h>
#import "PHAsset+Lechange.h"
#import <LCOpenSDKDynamic/LCOpenSDK/LCOpenSDK_DownloadListener.h>
#import "LCUIKit.h"

static LCDeviceVideotapePlayManager *manager = nil;

@interface LCDeviceVideotapePlayManager ()<LCOpenSDK_DownloadListener>

@property (nonatomic, strong) NSDate *recordTime;

@property (nonatomic, assign) NSInteger recordReceive;

@end

@implementation LCDeviceVideotapePlayManager

+ (instancetype)manager {
    static dispatch_once_t onceToken;
    dispatch_once(&onceToken, ^{
        manager = [LCDeviceVideotapePlayManager new];
        manager.isPlay = NO;
        manager.pausePlay = NO;
        manager.isSD = YES;
        manager.isSoundOn = YES;
        manager.isFullScreen = NO;
        manager.isOpenCloudStage = NO;
        manager.isOpenAudioTalk = NO;
        manager.isOpenRecoding = NO;
        manager.isLockFullScreen = NO;
        manager.playSpeed = 1;
    });
    return manager;
}

- (NSMutableDictionary *)downloadQueue {
    if (!_downloadQueue) {
        _downloadQueue = [NSMutableDictionary dictionary];
    }
    return _downloadQueue;
}

- (LCDeviceInfo *)currentDevice {
    return [LCDeviceVideoManager manager].currentDevice;
}

- (NSInteger)currentChannelIndex {
    return [LCDeviceVideoManager manager].currentChannelIndex;
}

- (void)setCloudVideotapeInfo:(LCCloudVideotapeInfo *)cloudVideotapeInfo {
    _cloudVideotapeInfo = cloudVideotapeInfo;
    _localVideotapeInfo = nil;
}

- (void)setLocalVideotapeInfo:(LCLocalVideotapeInfo *)localVideotapeInfo {
    _localVideotapeInfo = localVideotapeInfo;
    _cloudVideotapeInfo = nil;
}

- (void)startDeviceDownload {
    LCVideotapeDownloadInfo *info = [LCVideotapeDownloadInfo new];
    info.recordId = self.cloudVideotapeInfo ? self.cloudVideotapeInfo.recordRegionId : self.localVideotapeInfo.recordId;
    info.deviceId = self.currentDevice.deviceId;
    info.channelId = self.currentChannelInfo.channelId;
    info.localPath = [self _getCloudDownloadPath:info.recordId];
    [self.downloadQueue setObject:info forKey:[NSString stringWithFormat:@"%ld", (long)info.index]];
    [[LCOpenSDK_Download shareMyInstance] setListener:self];
    //开始下载进程
    if (self.cloudVideotapeInfo) {
        //开始下载云
        NSInteger result = [[LCOpenSDK_Download shareMyInstance] startDownload:info.index filepath:info.localPath token:[LCApplicationDataManager token] devID:info.deviceId channelID:[info.channelId integerValue] psk:info.deviceId recordRegionId:info.recordId Type:self.cloudVideotapeInfo.type Timeout:60];
        if (result != 0) {
            NSLog(@"下载云录像返回码：%ld",(long)result);
        }

    } else {
        //开始下载设备录像
        NSInteger result = [[LCOpenSDK_Download shareMyInstance] startDownload:info.index filepath:info.localPath token:[LCApplicationDataManager token] devID:info.deviceId decryptKey:info.deviceId fileID:info.recordId speed:1];
        if (result != 0) {
            NSLog(@"下载设备录像返回码：%ld",(long)result);
        }
    }
}

- (NSString *)currentVideotapeId {
    if (self.cloudVideotapeInfo) {
        return self.cloudVideotapeInfo.recordRegionId;
    }
    if (self.localVideotapeInfo) {
        return self.localVideotapeInfo.recordId;
    }
    return @"";
}

- (LCVideotapeDownloadInfo *)currentDownloadInfo {
    LCVideotapeDownloadInfo *result = nil;
    NSString *recordId = self.cloudVideotapeInfo ? self.cloudVideotapeInfo.recordRegionId : self.localVideotapeInfo.recordId;
    for (NSString *key in self.downloadQueue) {
        LCVideotapeDownloadInfo *info = [self.downloadQueue objectForKey:key];
        if ([info.recordId isEqualToString:recordId]) {
            result = info;
            break;
        }
    }
    return result;
}

- (void)updateDownload:(NSInteger)index Recieve:(NSInteger)recieve Status:(LCVideotapeDownloadState)status {
    if (status != -1) {
        NSLog(@"画面当前状态D:%ld", status);
    }
    if (![self.downloadQueue valueForKey:[NSString stringWithFormat:@"%ld", index]]) {
        return;//如果没有下载池中未保存该状态
    }
    [self willChangeValueForKey:@"downloadQueue"];
    //recieve为-1表示更新下载状态，status为-1表示更新接受到的数据
    LCVideotapeDownloadInfo *info = [self currentDownloadInfo];
    if (recieve != -1) {
        info.recieve = recieve;
    }
    if (status != -1) {
        info.donwloadStatus = status;
        if (status == LCVideotapeDownloadStatusEnd) {
            //下载正常结束时，保存到相册
            [self _saveToAlbumWithPath:info.localPath];
        }
    }
    NSLog(@"dddddddd%@", info);
    [self didChangeValueForKey:@"downloadQueue"];
}

- (void)_saveToAlbumWithPath:(NSString *)path {
    /* 延时保存相册，因为下载成功之后stopDownload方法在另一个线程，所以转码可能还不成功*/
    dispatch_after(dispatch_time(DISPATCH_TIME_NOW, (int64_t)(0.5 * NSEC_PER_SEC)), dispatch_get_main_queue(), ^{
        NSURL *dowmloadRUL = [NSURL fileURLWithPath:path];
        [PHAsset deleteFormCameraRoll:dowmloadRUL success:^{
        } failure:^(NSError *error) {
            NSLog(@"删除失败:%@", error.description);
        }];
        [PHAsset saveVideoAtURL:dowmloadRUL success:^(void) {
            dispatch_async(dispatch_get_main_queue(), ^{
                               NSLog(@"保存成功");
                               [LCProgressHUD showMsg:@"mobile_common_data_download_success".lc_T];
                           });
        } failure:^(NSError *error) {
            dispatch_async(dispatch_get_main_queue(), ^{
                               NSLog(@"保存失败:%@", error.description);
                               [LCProgressHUD showMsg:@"mobile_common_data_download_fail".lc_T];
                           });
        }];
    });
}

- (void)cancleDownload:(NSString *)recordId {
    LCVideotapeDownloadInfo *info = [self currentDownloadInfo];
    info.donwloadStatus = LCVideotapeDownloadStatusCancle;
    [[LCOpenSDK_Download shareMyInstance] stopDownload:info.index];
}

- (NSString *)_getCloudDownloadPath:(NSString *)recordId {
    NSArray *paths = NSSearchPathForDirectoriesInDomains(NSLibraryDirectory, NSUserDomainMask, YES);
    NSString *libraryDirectory = [paths objectAtIndex:0];

    NSString *myDirectory = [libraryDirectory stringByAppendingPathComponent:@"lechange"];
    NSString *downloadDirectory = [myDirectory stringByAppendingPathComponent:@"download"];

    NSString *infoPath = [downloadDirectory stringByAppendingPathComponent:[NSString stringWithFormat:@"%f_download", [[NSDate new]timeIntervalSince1970]]];
    NSString *downPath = [infoPath stringByAppendingString:@".mp4"];
    NSFileManager *fileManage = [NSFileManager defaultManager];
    NSError *pErr;
    NSLog(@"下载地址 = %@", downPath);
    BOOL isDir;
    if (NO == [fileManage fileExistsAtPath:myDirectory isDirectory:&isDir]) {
        [fileManage createDirectoryAtPath:myDirectory withIntermediateDirectories:YES attributes:nil error:&pErr];
    }
    if (NO == [fileManage fileExistsAtPath:downloadDirectory isDirectory:&isDir]) {
        [fileManage createDirectoryAtPath:downloadDirectory withIntermediateDirectories:YES attributes:nil error:&pErr];
    }
    return downPath;
}

#pragma mark - 下载回调
- (void)onDownloadReceiveData:(NSInteger)index datalen:(NSInteger)datalen {
    NSLog(@"REVIEVE_DOWN===%ld", datalen);
    self.recordReceive += datalen;
    //每隔0.5加载数据，避免过快加载导致UI卡顿
    if (self.recordTime == nil || [[NSDate date] timeIntervalSinceDate:self.recordTime] >= 0.5) {
        self.recordTime = [NSDate date];
        [self updateDownload:index Recieve:self.recordReceive Status:-1];
        self.recordReceive = 0;
    }
}

- (void)onDownloadState:(NSInteger)index code:(NSString *)code type:(NSInteger)type {
    NSInteger codeInteger = [code integerValue];
            NSLog(@"录像下载回调INDEX:%ld******TYEP:%ld*******CODE:%@", index, type, code);
    //        [LCProgressHUD showMsg:[NSString stringWithFormat:@"录像下载回调INDEX:%ld******TYEP:%ld*******CODE:%@",index,type,code]];
            //    对SDK回调的数据进行转换
            if (type == 0) {
                //设备录像下载
                switch (codeInteger) {
                    case 1: {
                        [self updateDownload:index Recieve:-1 Status:LCVideotapeDownloadStatusFail];
                    }
                    break;
                        break;
                    case 4: {
                        [self updateDownload:index Recieve:-1 Status:LCVideotapeDownloadStatusBegin];
                    }
                    break;
                    case 5: {
                        [self updateDownload:index Recieve:-1 Status:LCVideotapeDownloadStatusEnd];
                    }
                    break;
                    case 7: {
                        [self updateDownload:index Recieve:-1 Status:LCVideotapeDownloadStatusTimeout];
                    }
                    break;
                    default:
                        break;
                }
            } else if (type == 1) {
                //云录像下载
                switch (codeInteger) {
                    case 0: {
                        [self updateDownload:index Recieve:-1 Status:LCVideotapeDownloadStatusFail];
                    }
                    break;
                    case 1: {
                        [self updateDownload:index Recieve:-1 Status:LCVideotapeDownloadStatusBegin];
                    }
                    break;
                    case 2: {
                        [self updateDownload:index Recieve:-1 Status:LCVideotapeDownloadStatusEnd];
                    }
                    break;
                    case 5: {
                        [self updateDownload:index Recieve:-1 Status:LCVideotapeDownloadStatusCancle];
                    }
                    break;
                    case 6: {
                        [self updateDownload:index Recieve:-1 Status:LCVideotapeDownloadStatusSuspend];
                    }
                    break;
                    case 7: {
                        [self updateDownload:index Recieve:-1 Status:LCVideotapeDownloadStatusTimeout];
                    }
                    break;
                    case 9: {
                        LCVideotapeDownloadInfo *info = [self currentDownloadInfo];
                        if (info.donwloadStatus != LCVideotapeDownloadStatusPartDownload) {
                            [self updateDownload:index Recieve:-1 Status:LCVideotapeDownloadStatusPartDownload];
                        }
                    }
                    break;
                    case 11: {
                        [self updateDownload:index Recieve:-1 Status:LCVideotapeDownloadStatusKeyError];
                    }
                    break;
                    default:
                        break;
                }
            } else {
                //其他错误暂不处理
            }
}

@end

@implementation LCVideotapeDownloadInfo

- (instancetype)init {
    if (self = [super init]) {
//取当前时间戳作为索引
        self.index = [[NSDate new] timeIntervalSince1970];
    }
    return self;
}

@end