PrivateBoxiOS/创维盒子/code/cloudPhone/websocket/webSocketManager.m

//
//  webSocketManager.m
//  双子星云手机
//
//  Created by xd h on 2024/6/20.
//

#import "webSocketManager.h"

#import "webSocketManager+baseDownload.h"
#import "webSocketManager+downloadFile.h"
#import "webSocketManager+downloadThumbnailImage.h"
#import "webSocketManager+upLoadFile.h"
#import "webSocketManager+backupsFile.h"
#import "errorAlertTool.h"
//#import "RcGameWQKeyChain.h"
#import "USBInsertPopView.h"
#import "nasMixUploadManager.h"


@interface webSocketManager ()
{
    NSMutableArray *commandSendCheckArr;//需要检测任务是否发出的的指令
    ComontAlretViewController *logoutAlertVC;
    USBInsertPopView *curUSBInsertPopV;
}

@property(copy,nonatomic)NSString *curIp;
/**定时器计数*/
@property (nonatomic, assign) NSInteger      webSocketTime;
/**定时器计数 任务检测*/
@property (nonatomic, assign) NSInteger          webSocketTaskTime;
@property (nonatomic, copy)   NSTimer            *webSocketCheckTimer; // 定时器-控制按钮
//第一次链接设备 要发送指令信息 实现单点登录
@property (nonatomic, assign)BOOL didSendfristMsg;

@end


@implementation webSocketManager
static webSocketManager *webSocketManagerInstance = nil;
+(webSocketManager *)shareInstance;
{
    static dispatch_once_t onceToken;
    
    dispatch_once(&onceToken, ^{
        webSocketManagerInstance = [[webSocketManager alloc] init];
    });
    
    return webSocketManagerInstance;
}

- (void)initOtherFun
{
    if(_webSocketCheckTimer){
        //[_timer invalidate];
        return;
    }
    
    _webSocketCheckTimer = [NSTimer scheduledTimerWithTimeInterval:5.0 target:self selector:@selector(webScoketTimerChange) userInfo:nil repeats:YES];
    [[NSRunLoop currentRunLoop] addTimer:_webSocketCheckTimer forMode:NSRunLoopCommonModes];
    
    commandSendCheckArr = [NSMutableArray new];
}

- (void)opencommandChannelManagerrc_openURL
{
    if(self.commandChannelManager){
        
        RCSocketCloudPhoneStatus status = [self.commandChannelManager rc_socketStatus];
        //HLog(@"rc_socketStatus:%ld",status)
        if(status == RCSocketCloudPhoneStatusFailed
           ||status == RCSocketCloudPhoneStatusClosedByServer
           ||status == RCSocketCloudPhoneStatusClosedByUser
           ||!ksharedAppDelegate.isWebSockLinkOKAginType//断开了
           )
        {
            HLog(@"WebSocket 链接时已经存在并且链接失效:%ld",status);
            [self.commandChannelManager rc_close];
             self.commandChannelManager = nil;
        }
        else{
            HLog(@"WebSocket 链接时已经存在并且链接中:%ld",status);
            return;
        }
        
    }
    
    KWeakSelf
    NSString *wsPort = @"";
    if([connectDeviceManager shareInstance].isPingOk
       && [AFNetworkReachabilityManager sharedManager].networkReachabilityStatus == AFNetworkReachabilityStatusReachableViaWiFi){
        _curIp = ksharedAppDelegate.DeviceThirdIdMod.data.ip;
        wsPort = @"9300";
    }
    else if([connectDeviceManager shareInstance].tcpPortStr
            &&[connectDeviceManager shareInstance].tcpPortStr.length > 0) {
        _curIp = ruiyunlinkIp;
        wsPort = [[connectDeviceManager shareInstance] tcpPortStr];
    }
    else{
        //
        HLog(@"非内网而且瑞云未链接完成");
        dispatch_after(dispatch_time(DISPATCH_TIME_NOW, (int64_t)(3 * NSEC_PER_SEC)), dispatch_get_main_queue(), ^{
            [weakSelf opencommandChannelManagerrc_openURL];
        });
        return;
    }
    
    //初始化指令通道
    self.commandChannelManager = [[RCCommandChannelManager alloc] init];
    [self initOtherFun];//timer 检测链接情况
    
    NSString *instructionsChannelUrl = [NSString stringWithFormat:@"ws://%@:%@/businessChannel",_curIp,wsPort];
    
    if (instructionsChannelUrl && instructionsChannelUrl.length > 0) { //当都有值才可连接
        //HLog(@"WebSocket11111指令通道连接开始11111 url = %@ ",instructionsChannelUrl);
        [self.commandChannelManager rc_openURL:instructionsChannelUrl connected:^{
            //HLog(@"WebSocket11111指令通道连接成功11111 url = %@ ",instructionsChannelUrl);
            if (weakSelf.commandChannelManager.rc_socketStatus == RCSocketCloudPhoneStatusConnected){
                dispatch_after(dispatch_time(DISPATCH_TIME_NOW, (int64_t)(0.01 * NSEC_PER_SEC)), dispatch_get_main_queue(), ^{
                    [weakSelf handlAllMsgAfterDidLinkFun];
                    
                });
            }
        } receive:^(id message, FLSocketCloudPhoneReceiveType type) {
            
            if([message isKindOfClass:[NSData class]] && [message length] == 0){
                if(type == RCSocketCloudPhoneReceiveTypeForPong)
                {
                    [weakSelf keepWebSocketOKFun];
                }
                return;
            }
          
            HLog(@"webSocket指令通道接收消息:------------------\n%@",message);
            
            if([message isKindOfClass:[NSMutableString class]] || [message isKindOfClass:[NSString class]])
            {
                message = [(NSString *)message dataUsingEncoding:(NSUTF8StringEncoding)];
            }
            
            NSError *error = nil;
            NSDictionary *dataDict = [NSJSONSerialization JSONObjectWithData:message options:NSJSONReadingMutableContainers error:&error];
            
            if(!dataDict){
                [weakSelf handleDownloadResponseFunBy:message];
                return;
            }
            
            if(![dataDict isKindOfClass:[NSDictionary class]]){
                //[__NSCFString allKeys] unrecognized selector sent to ins
                return;
            }
            
            NSString *messageType = dataDict[@"type"];
            
            if ([messageType isEqualToString:@"cutting"]) {
                //[[iToast makeText:@"复制成功"] show];
            }
            else if ([messageType isEqualToString:@"forwardMsgRep"]){/*转发的回复*/
                
                cloudPhoneCommonModel *model = [[cloudPhoneCommonModel alloc] initWithDictionary:dataDict error:nil];
                if(!model){
                    return;
                }
                
                if([model.data.msg isEqualToString:@"only one socket"]||
                   [model.data.msg isEqualToString:@"only one socket2"]){
                    [weakSelf deleteCommandSendTaskFunWith:@"offline_notification"];
                }
            }
            else if ([messageType isEqualToString:@"forwardMsg"]){/*转发*/
                /*获取指令类型*/
                NSString *code = nil;
                if ([[dataDict allKeys] containsObject:@"data"]) {
                    NSDictionary *data = dataDict[@"data"];
                    
                     if([data isKindOfClass:[NSString class]]){
                         //暂时屏蔽
//                        NSString * dataStr = (NSString*)data;
//                        if([dataStr isEqualToString:@"offline_notification"]){
//                            HLog(@"被别人挤下线了");
//                            [weakSelf LogoutByOtherFun];
//                        }
                         
                         return;
                    }
                    else if ([data isKindOfClass:[NSDictionary class]] && [[data allKeys] containsObject:@"code"]) {
                        code = [data objectForKey:@"code"];
                        
                        if (![code isKindOfClass:[NSString class]]) {
                            code = [NSString stringWithFormat:@"%ld",[code integerValue]];
                        }
                    }
                }
                
                /*获取用户名*/
                NSString *useName = nil;
                if ([[dataDict allKeys] containsObject:@"data"]) {
                    NSDictionary *data = dataDict[@"data"];
                    if ([[data allKeys] containsObject:@"userName"]) {
                        //useName = [data objectForKey:@"userName"];
                    }
                }
                
                
                    if ([code isEqualToString:@"phoneSizeChange"]){/*分辨率改变*/
                    if ([[dataDict allKeys] containsObject:@"data"]) {
                        NSDictionary *data = dataDict[@"data"];
                        if ([[data allKeys] containsObject:@"width"]) {
                            ksharedAppDelegate.couldPhone_W_PHONE = [[data objectForKey:@"width"] integerValue];
                        }
                        if ([[data allKeys] containsObject:@"height"]) {
                            ksharedAppDelegate.couldPhone_H_PHONE = [[data objectForKey:@"height"] integerValue];
                        }
                        
                        if (ksharedAppDelegate.couldPhone_W_PHONE > ksharedAppDelegate.couldPhone_H_PHONE) {
                            CGFloat temp = ksharedAppDelegate.couldPhone_W_PHONE;
                            ksharedAppDelegate.couldPhone_W_PHONE = ksharedAppDelegate.couldPhone_H_PHONE;
                            ksharedAppDelegate.couldPhone_H_PHONE = temp;
                        }
                    }
                }
            }
            else if ([messageType isEqualToString:@"getPhoneSize"] || [messageType isEqualToString:@"setPhoneSize"]){
                //NSString *sn = nil;
                
                if([messageType isEqualToString:@"setPhoneSize"]){
                    weakSelf.isDiDChangePhoneSizeType = YES;
                }
                
                if ([[dataDict allKeys] containsObject:@"data"]) {
                    NSDictionary *data = dataDict[@"data"];
                    
                    if ([[data allKeys] containsObject:@"status"]) {
                        NSInteger  status = [[data objectForKey:@"status"] integerValue];
                        
                        if (status == 0) {/*不是当前设备直接返回*/
                            if ([[data allKeys] containsObject:@"width"]) {
                                ksharedAppDelegate.couldPhone_W_PHONE = [[data objectForKey:@"width"] integerValue];
                            }
                            if ([[data allKeys] containsObject:@"height"]) {
                                ksharedAppDelegate.couldPhone_H_PHONE = [[data objectForKey:@"height"] integerValue];
                            }
                            
                            if (ksharedAppDelegate.couldPhone_W_PHONE > ksharedAppDelegate.couldPhone_H_PHONE) {
                                CGFloat temp = ksharedAppDelegate.couldPhone_W_PHONE;
                                ksharedAppDelegate.couldPhone_W_PHONE = ksharedAppDelegate.couldPhone_H_PHONE;
                                ksharedAppDelegate.couldPhone_H_PHONE = temp;
                            }
                        }
                    }
                }
            }
            else if ([messageType isEqualToString:@"sync_wifi"]){
                [weakSelf sync_wifiBackHandleFun];
            }
            else if ([messageType isEqualToString:@"reProduceText"]){
                if ([[dataDict allKeys] containsObject:@"data"]) {
                    NSDictionary *data = dataDict[@"data"];

                    if ([[data allKeys] containsObject:@"text"]) {
                        NSString  *pasteboardStr = [data objectForKey:@"text"];
                        UIPasteboard* pasteboard = [UIPasteboard generalPasteboard];
                        pasteboard.string = pasteboardStr;
                    }
                }
            }
            else if ([messageType isEqualToString:@"downAdnInstallRep"]){
                if ([[dataDict allKeys] containsObject:@"data"]) {
                    NSDictionary *data = dataDict[@"data"];

                    if ([[data allKeys] containsObject:@"status"]) {
                        NSString  *status = [data objectForKey:@"status"];
                        if ([status isEqualToString:@"1"]) {
                            mainBlock(^{
                               // [[iToast makeText:@"App下载完成"] show];
                            });
                        }else if ([status isEqualToString:@"0"]){
                            mainBlock(^{
                                //[[iToast makeText:@"App下载中"] show];
                            });
                        }
                    }
                }
            }
            else if ([messageType isEqualToString:@"shakeit"]){
                HLog(@"\n-----摇一摇成功------");
            }else if ([messageType isEqualToString:@"keyboardFeedbackBean"]){/*调起键盘*/
                HLog(@"\n-----待处理 调起键盘------");
               // [weakSelf keyboardFeedbackBeanFun];
            }else if ([messageType isEqualToString:@"FileRandomReady"]
                      ||[messageType isEqualToString:@"FilePartReady"]
                      ){/*申请文件上传得到答复*/
                [weakSelf applyUploadFileServiceResponseFun:dataDict];
            }
            else if ([messageType isEqualToString:@"uploadFileRandomRet"]
                     ||[messageType isEqualToString:@"uploadFilePartRet"]
                     ){/*文件上传得到答复*/
                [weakSelf upLoadFileFunServiceResponseFun:dataDict];
            }
            else if ([messageType isEqualToString:@"backUpFileRandomReady"]
                     ||[messageType isEqualToString:@"backUpPartReady"]
                     ){/*文件备份得到答复*/
                [weakSelf applyBackupsFileServiceResponseFun:dataDict];
            }
            else if ([messageType isEqualToString:@"backUpFileRandomRet"]
                     ||[messageType isEqualToString:@"backUpFilePartRet"]){/*文件备份得到答复*/
                [weakSelf backupsFileFunServiceResponseFun:dataDict];
            }
            else if ([messageType isEqualToString:@"getBaseInfo"]){/*获取云机的基本信息*/
                [weakSelf getCouldPhoneBaseInfoResponseFun:dataDict];
            }
            else if ([messageType isEqualToString:@"getSysInfo"]){/*获取云机的系统信息*/
                [weakSelf getCouldPhoneSysInfoResponseFun:dataDict];
            }
            else if ([messageType isEqualToString:@"TvStatus"]){/*获取TV投屏信息*/
                [weakSelf getCouldPhoneTvStatusResponseFun:dataDict];
            }
            else if ([messageType isEqualToString:@"TvOff"]){/*关闭TV投屏*/
                dispatch_after(dispatch_time(DISPATCH_TIME_NOW, (int64_t)(2 * NSEC_PER_SEC)), dispatch_get_main_queue(), ^{
                    [weakSelf getTvStatusFun];
                });
            }
            else if ([messageType isEqualToString:@"wakeupTV"]){/*开启TV投屏*/
                dispatch_after(dispatch_time(DISPATCH_TIME_NOW, (int64_t)(2 * NSEC_PER_SEC)), dispatch_get_main_queue(), ^{
                    [weakSelf getTvStatusFun];
                });
            }
            else if ([messageType isEqualToString:@"reboot"]){/*重启*/
                //[weakSelf stopForceStartTimerFun];
            }
            else if ([messageType isEqualToString:@"mkdir"]){/*创建文件夹*/
                [weakSelf createFolderResponseFun:dataDict];
            }
            else if ([messageType isEqualToString:@"getBackupPath"]){/*创建文件夹*/
                [weakSelf getFolderListResponseFun:dataDict];
            }
            else if ([messageType isEqualToString:@"search"]){/*创建文件夹*/
                [weakSelf searchFileListResponseFun:dataDict];
            }
            else if ([messageType isEqualToString:@"getExtraFiles"]){/*创建文件夹*/
                [weakSelf getExtraFilesResponseFun:dataDict];
            }
            else if ([messageType isEqualToString:@"extraMediaEvent"]){/*磁盘插拔*/
                [weakSelf getExtraMediaEventResponseFun:dataDict];
                [weakSelf getExtraFilesListFun];
            }
            else if ([messageType isEqualToString:@"reset"]){/**/
                [weakSelf deleteCommandSendTaskFunWith:@"reset"];
            }
            
        } failure:^(NSError *error) {
            ksharedAppDelegate.isWebSockLinkOKAginType = NO;
            
            [[errorAlertTool shareInstance] showNetErrorAlertFun:2 didClickBut:^(NSInteger tag) {
                
            }];
            
            [self WebSocketNeedRelinkFun];
        }];
    }
}

- (void)keepWebSocketOKFun
{
    self.webSocketTime = 0;
}

- (void)WebSocketNeedRelinkFun
{
    self.webSocketTime = 0;
    
    if(self.commandChannelManager){
        [self opencommandChannelManagerrc_openURL];
    }
}

- (void)webScoketTimerChange {
    
    //处理websockt是否断开
    self.webSocketTime += 5;
    
    //处理其他任务
    self.webSocketTaskTime += 5;
    
    if(self.webSocketTime >= 10)
    {
        [self WebSocketNeedRelinkFun];
    }
    
    if(self.webSocketTaskTime >= 10)
    {
        self.webSocketTaskTime = 0;
        [self checkAllTaskFun];
        
    }
}

- (void)checkAllTaskFun
{
    RCSocketCloudPhoneStatus status = [self.commandChannelManager rc_socketStatus];
    //HLog(@"rc_socketStatus:%ld",status)
    if(status == RCSocketCloudPhoneStatusFailed
       ||status == RCSocketCloudPhoneStatusClosedByServer
       ||status == RCSocketCloudPhoneStatusClosedByUser
       ||!ksharedAppDelegate.isWebSockLinkOKAginType//断开了
       )
    {
        HLog(@"WebSocket 链接异常:%ld",status);
        return;
    }
    else{
        HLog(@"WebSocket 链接正常:%ld",status);
    }
    
    
    //处理相册备份
    //[[backupsFileManager shareInstance] checkReBackupsFileFun];
    [[nasBackupsManager shareInstance] checkReBackupsFileFun];
    
    //[[uploadFileManager shareInstance] checkReUploadFileFun];
    //[[downloadManager shareInstance] checkReDownloadFileFun];
    
    //[[downloadThumbnailManager shareInstance] checkReDownloadThumbnailFileFun];
    
    [self checkCommandSendTaskFun];
    
    //if([AudioSessionObject shareManager].isBackgroundType)
    {
        [self checkFileTransfeTaskFun];
    }
    
    HLog(@"checkAllTaskFun");
}

//检测是否正在进行的文件传输任务
- (void)checkFileTransfeTaskFun
{
    
   //BOOL isBackupsingType = [[backupsFileManager shareInstance] checkBackupsingFun];
    BOOL isBackupsingType = [[nasBackupsManager shareInstance] checkBackupsingFun];
   //BOOL isUploadingType = [[uploadFileManager shareInstance] checkUploadingFun];
    BOOL isUploadingType = [[nasMixUploadManager shareManager] checkUploadTaskDoingFun];
   //BOOL isDownloadingType = [[downloadManager shareInstance] checkDownloadingFun];
    BOOL isDownloadingType = [[nasDownloadManager shareManager] isDownLoadIngType];
   BOOL isNasDownloadingType = [customDownloadManager shareManager].isDownLoadIngType;
    
   BOOL isBackground = [HWDataManager getBoolWithKey:stringKeyAddSn(Const_file_Transfe_working_background)];
    
    if ((isBackupsingType || isUploadingType || isDownloadingType ||isNasDownloadingType) && isBackground) {
        HLog(@"后台保活中");
        [cachesFileManager writeLogsWithMsg:@"Background working"];
    }
    else{
        HLog(@"停止后台保活");
        [cachesFileManager writeLogsWithMsg:@"stop Background working"];
        //[[AudioSessionObject shareManager] stopBackgroundActiveFun];
    }
    
}

-(void)checkCommandSendTaskFun
{
    if(commandSendCheckArr && commandSendCheckArr.count >0){
        for (commandSendCheckModel *model in commandSendCheckArr) {
            if(model.reSendNum < 2){
                model.reSendNum ++;
                if(model.commandStr){
                    [self send_data:model.commandStr];
                    
                    HLog(@"\n\n\n任务重发 重发次数:%ld 指令:%@\n\n\n",model.reSendNum,model.commandStr);
                }
                
//                if([model.type isEqualToString:@"offline_notification"]){
//                    model.reSendNum = 1;//只要不收到
//                }
            }
        }
    }
}

- (void)send_data:(NSString *)dataStr
{
    [self.commandChannelManager rc_sendData:dataStr];
}

#pragma mark 盒子链接成功后需要处理的各种各样事情
- (void)handlAllMsgAfterDidLinkFun
{
    _isRebootIngType = NO;
    _isResetingType = NO;
    _isChangeBoxType = NO;
    
    ksharedAppDelegate.isWebSockLinkOKAginType = YES;
    
    //获取云机尺寸 兼容 720*1080 &1080*1920 不同分辨率的展示和触控
    NSString *getPhoneSizeStr = [RCCommandHelp getPhoneSizecommand];
    [self send_data:getPhoneSizeStr];
    
    //判断是否为需要改机
    BOOL isNeedRandomChangeParams = [HWDataManager getBoolWithKey:Const_need_random_Change_Params];
    if(isNeedRandomChangeParams)
    {
        NSString *commondStr  = @"{\"type\":\"randomChangeParams\"}";
        [self send_data:commondStr];
        
        [HWDataManager setBoolWithKey:Const_need_random_Change_Params value:NO];
    }
    
    [self fristConnectNeedGiveAMsgFun];
    
    [self updateCopydata];
    
    //  报链接失败 后面又连接上了
    [[errorAlertTool shareInstance] dismissErrorAlertFun];
    
    //处理相册备份
    //[[backupsFileManager shareInstance] AutohandlePhotosBackupsFun];
    [[nasBackupsManager shareInstance] AutohandlePhotosBackupsFun];
    
    //获取磁盘外挂
    [self getExtraFilesListFun];
    
    [self getBaseInfoFun];
    
    [self getTvStatusFun];
}

#pragma mark 盒子第一次连接成功  给ws发送信息 单点登录 把其他账号挤下去
- (void)fristConnectNeedGiveAMsgFun{
    
    if(!_didSendfristMsg )
    {
        [self getSysInfoFun];
        
        //NSString *curOaidStr = [RcGameWQKeyChain getOaidStringFun];
        NSString *curOaidStr = [iPhone phoneDeviceUuid];

        if(!curOaidStr){
            curOaidStr = @"";
        }
        
        //暂时屏蔽
//        NSString *commondStr = [[NSString alloc] initWithFormat:@"{\"type\":\"forwardMsg\",\"data\":\"offline_notification\",\"sign\":\"%@\"}",curOaidStr];
//        //NSString *commondStr  = @"{\"type\":\"forwardMsg\",\"data\":\"offline_notification\"}";
//        [self send_data:commondStr];
//        [self addCommandSendTaskFunWithType:@"offline_notification" WithCommandStr:commondStr];
        
        _didSendfristMsg = YES;
        
        [self getPreferredLanguage];
        
        NSString *commondStr2  = @"{\"type\":\"TvStatus\"}";
        [self send_data:commondStr2];
    }
}

#pragma mark 语言和市区 同步云机
-(void)getPreferredLanguage
{//{"data":{"language":"zh-CN","timeZone":"Etc/GMT+8"},"type":"setLanguages"}
    // iOS 获取设备当前语言的代码
    NSString *preferredLanguage = [[[NSBundle mainBundle] preferredLocalizations] firstObject];
    HLog(@"当前语言:%@", preferredLanguage);

    //en-US 英文 ja-JP 日文
    
    NSArray *arLanguages = [[NSUserDefaults standardUserDefaults] objectForKey:@"AppleLanguages"];
    NSLog(@"arLanguages:%@",arLanguages);
    ///获取设备当前地区的代码和APP语言环境
    NSString *languageCode = [NSLocale preferredLanguages][0];
  
   
    //目前支持 中文（简体 繁体） 英文 日语
    if([languageCode rangeOfString:@"zh-Hans"].location != NSNotFound)
    {
        preferredLanguage = @"zh-CN";
    }
    else if([languageCode rangeOfString:@"zh-Hant"].location != NSNotFound)
    {
        preferredLanguage = @"zh-HK";
    }
    else if([languageCode rangeOfString:@"ja-"].location != NSNotFound)
    {
        preferredLanguage = @"ja-JP";
    }
    else{
        preferredLanguage = @"en-US";
    }
    
//    if([languageCode  rangeOfString:preferredLanguage].location != NSNotFound){
//        preferredLanguage = languageCode;
//    }
//    else{
//        preferredLanguage = @"en-US";
//    }
    
    NSString*gmtStr = [self UTCOffset];
    HLog(@"%@",gmtStr);
//    //获取名字，如“GMT+08:00
    
    NSString *commondStr = [NSString stringWithFormat:@"{\"type\":\"setLanguages\",\"data\":{\"language\":\"%@\",\"timeZone\":\"%@\"}}",preferredLanguage,gmtStr];
    
    [self send_data:commondStr];
    
}

-(NSString *)UTCOffset {
    NSTimeZone *localTZ = [NSTimeZone localTimeZone];
    float offset = localTZ.secondsFromGMT/3600.0;
    if(offset > 0){
        return [NSString stringWithFormat:@"Etc/GMT+%g",offset];
    }
    return [NSString stringWithFormat:@"Etc/GMT%g",offset];
}

#pragma mark 重启云机
- (void)needToRebootFun
{
    NSString *commondStr  = @"{\"type\":\"reboot\"}";
    [self send_data:commondStr];
    
    //添加到任务监听
    [self addCommandSendTaskFunWithType:@"reboot" WithCommandStr:commondStr];
    
    //数据埋点
    [[netWorkManager shareInstance] DataEmbeddingPointBy:3 withEventValue:@"Cloud_restart"];
    
    _isRebootIngType = YES;
}

- (void)needToResetFun
{
    NSString *commondStr  = @"{\"type\":\"reset\"}";
    [self send_data:commondStr];
    
    //添加到任务监听
    [self addCommandSendTaskFunWithType:@"reset" WithCommandStr:commondStr];
    
    //数据埋点
    [[netWorkManager shareInstance] DataEmbeddingPointBy:3 withEventValue:@"Cloud_restore_factory"];
    _isResetingType = YES;
}

- (void)updateCopydata{
    UIPasteboard* pasteboard = [UIPasteboard generalPasteboard];
    NSString *str = [pasteboard string];
    
    HLog(@"__________%s______%@____",__func__,str);
    
    if ([str rangeOfString:@"CVLUSTERS_NOUSE_"].location != NSNotFound)
    {
        str = nil;
    }
    
    if (str && str.length >0)
    {
        //HLog(@"hxd111 cutting  %@",str);
        /*发送数据*/
        NSString *dataStr = [RCCommandHelp commandCuttingWithContent:str];
        [self.commandChannelManager rc_sendData:dataStr];
        //pasteboard.string = @"";
    }
    
}

#pragma mark 获取云机以及外挂磁盘
- (void)getExtraFilesListFun
{
    NSString *ExtraCommondStr  = [RCCommandHelp getExtraFilesList];
    [self send_data:ExtraCommondStr];
}

-(void)addCommandSendTaskFunWithType:(NSString*)type WithCommandStr:(NSString*)commandStr
{
    if(!commandSendCheckArr){
        commandSendCheckArr = [NSMutableArray new];
    }
    
    BOOL didAddType = NO;
        
    for (commandSendCheckModel *model in commandSendCheckArr) {
        if([model.type isEqualToString:type]){
            didAddType = YES;
            model.reSendNum = 0;
            model.sendTimerStamp = [iTools getNowTimeStamp];
            break;
        }
    }
        
    if(!didAddType){
        commandSendCheckModel *model = [commandSendCheckModel new];
        model.commandStr = commandStr;
        model.type = type;
        model.reSendNum = 0;
        model.sendTimerStamp = [iTools getNowTimeStamp];
        [commandSendCheckArr addObject:model];
    }
    
}


-(void)deleteCommandSendTaskFunWith:(NSString*)type
{
    if(commandSendCheckArr && commandSendCheckArr.count >0){
        
        NSArray *taskArr = [NSArray arrayWithArray:commandSendCheckArr];
        
        for (commandSendCheckModel *model in taskArr) {
            if([type isEqualToString:model.type]){
                [commandSendCheckArr removeObject:model];
            }
        }
    }
}

#pragma mark wifi handle
- (void)sync_wifiBackHandleFun
{
    [self.commandChannelManager rc_sendData:[RCCommandHelp noSyncWifiBack]];
    [[iToast makeText:NSLocalizedString(@"player_Tip_ios_no_wifi_Sync",nil)] show];
}

- (void)getCouldPhoneBaseInfoResponseFun:(NSDictionary *)dataDict
{
    couldPhoneBaseInfoModel *model = [[couldPhoneBaseInfoModel alloc] initWithDictionary:dataDict error:nil];
    [[NSNotificationCenter defaultCenter] postNotificationName:getCouldPhoneBaseInfoNotification object:model];
}

- (void)getCouldPhoneSysInfoResponseFun:(NSDictionary *)dataDict{
    couldphoneSysInfoModel *model = [[couldphoneSysInfoModel alloc] initWithDictionary:dataDict error:nil];
    //[[NSNotificationCenter defaultCenter] postNotificationName:getCouldPhoneSysInfoNotification object:model];
        
//    NSString *hostImgVer = model.data.data.hostImgVer;
//    NSString *MyNewVersion = model.data.data.MyNewVersion;
    
    NSString *hostImgVer = model.data.hostImgVer;
    NSString *MyNewVersion = model.data.MyNewVersion;

    //test code
//    hostImgVer = @"1.2.3";
//    MyNewVersion = @"1.2.0";
    
    //判断当前版本号 待更新版本
    if (!hostImgVer || hostImgVer.length < 3
        ||!MyNewVersion || MyNewVersion.length < 3) {
        return;
    }
    
    NSArray *versionArr = [hostImgVer componentsSeparatedByString:@"."];
    NSArray *MyNewVersionArr = [MyNewVersion componentsSeparatedByString:@"."];
    
    NSInteger versionArrCount = versionArr.count;
    NSInteger MyNewVersionArrCount = MyNewVersionArr.count;
    NSInteger maxCount =  versionArrCount < MyNewVersionArrCount ? versionArrCount:MyNewVersionArrCount;
    
    BOOL isNeedShowType = NO;
    //判断是否要更新镜像框
    if(maxCount > 0){
        for (int i=0; i<maxCount; i++) {
            NSString * numberStr1 = versionArr[i];
            NSString * numberStr2 = MyNewVersionArr[i];
            
            if(numberStr2.intValue > numberStr1.intValue){
                isNeedShowType =YES;
                break;
            }
        }
    }
    
    
    if(isNeedShowType){
        ksharedAppDelegate.isNeedShowImageNewType = YES;
    }
    
    //是否禁用文件传输 （1.3以及以上的镜像可以使用文件传输）
    if(versionArr.count >= 3)
    {
        NSString * oneStr = versionArr[0];
        NSString * twoStr = versionArr[1];
        NSString * threeStr = versionArr[2];

        if(oneStr.integerValue <=1 && twoStr.integerValue <=3 && threeStr.integerValue <=0){//禁用
            ksharedAppDelegate.DisabledFileTransferType = YES;
            
            if(MyNewVersionArr.count >= 3)
            {
                NSString * newOneStr = MyNewVersionArr[0];
                NSString * newTwoStr = MyNewVersionArr[1];
                NSString * newThreeStr = MyNewVersionArr[2];
                
                if(newOneStr.integerValue >=1 && newTwoStr.integerValue >=3 && newThreeStr.integerValue >= 1){
                    ksharedAppDelegate.isImageNewFor130 = YES;
                }
                else{
                    ksharedAppDelegate.isImageNewFor130 = NO;
                }
            }
        }
        else{
            ksharedAppDelegate.DisabledFileTransferType = NO;
        }
    }
    
    [[NSNotificationCenter defaultCenter] postNotificationName:getCouldPhoneSysInfoNotification object:model];
}

- (void)getCouldPhoneTvStatusResponseFun:(NSDictionary *)dataDict
{
    TvStatusModel *model = [[TvStatusModel alloc] initWithDictionary:dataDict error:nil];
    ksharedAppDelegate.TvStatusMod = model;
    
    [[NSNotificationCenter defaultCenter] postNotificationName:getCouldPhoneTvStatusNotification object:model];
    
//    if(![model.msg containsString:@"PushStreamBActivity"])
//    {
//        return;
//    }
//    
//    UIViewController*topVc = self.navigationController.viewControllers.lastObject;
//    if([topVc isKindOfClass:[PlayerViewController class]]){
//        [[iToast makeText:NSLocalizedString(@"tv_p2p_ing",nil)] show];
//    }
}


- (void)createFolderResponseFun:(NSDictionary *)dataDict
{
    couldPhoneCommonModel *model = [[couldPhoneCommonModel alloc] initWithDictionary:dataDict error:nil];
    
    if(model){
        NSNumber *curNum = [NSNumber numberWithInteger:model.status];
        [[NSNotificationCenter defaultCenter] postNotificationName:createFolderDoneNotification object:curNum];/*发送通知*/
    }
}

- (void)getFolderListResponseFun:(NSDictionary *)dataDict
{
    [[NSNotificationCenter defaultCenter] postNotificationName:getFolderListDoneNotification object:dataDict];/*发送通知*/
}

- (void)searchFileListResponseFun:(NSDictionary *)dataDict
{
    [[NSNotificationCenter defaultCenter] postNotificationName:searchFileListDoneNotification object:dataDict];/*发送通知*/
}

#pragma mark 获取云机已经外挂产品
- (void)getExtraFilesResponseFun:(NSDictionary *)dataDict
{
    cloudPhoneExtraFileListModel *model = [[cloudPhoneExtraFileListModel alloc] initWithDictionary:dataDict error:nil];
    ksharedAppDelegate.cloudPhoneExtraFileListMod = model;
    
    [[NSNotificationCenter defaultCenter] postNotificationName:getExtraFilesDoneNotification object:dataDict];/*发送通知*/
}

- (void)getExtraMediaEventResponseFun:(NSDictionary *)dataDict
{
    extraMediaEventModel *model = [[extraMediaEventModel alloc] initWithDictionary:dataDict error:nil];
    
    NSString *tip = nil;
    if(model.data.event == 0){
        tip = NSLocalizedString(@"disk_insertion_tip",nil);
        [self showInsertPopViewFun:model.data.name];
    }
    else if(model.data.event == 1){
        tip = NSLocalizedString(@"disk_extract_tip",nil);
    }
    else if(model.data.event == 2){
        tip = NSLocalizedString(@"disk_save_extract_tip",nil);
    }
    
    NSString *totalTips = [[NSString alloc] initWithFormat:@"%@%@",model.data.name,tip];
    
    mainBlock(^{
        [[iToast makeText:totalTips] show];
    });
}

#pragma mark 显示插入UI弹框
- (void)showInsertPopViewFun:(NSString*)name
{
    if(self->curUSBInsertPopV){
        [self->curUSBInsertPopV removeFromSuperview];
        self->curUSBInsertPopV = nil;
    }
    
    self->curUSBInsertPopV = [[USBInsertPopView alloc] initWithFrame:CGRectMake(0, 0, SCREEN_W, SCREEN_H) withName:name];
    
    [[iTools getKeyWindow] addSubview:self->curUSBInsertPopV];
}

- (void)createBackupsFolderBy:(NSString*)backupsDefaultPath
{
    NSString *folderName = backupsDefaultPath;
    
    if(folderName && folderName.length >0){
        NSString * commandStr = [RCCommandHelp applyForCreateFolderwithFolderName:folderName];
        [self.commandChannelManager rc_sendData:commandStr];
    }
}

- (void)getBackupFolderListFun
{
    NSString * commandStr = [RCCommandHelp getCreateFolderList];
    [self.commandChannelManager rc_sendData:commandStr];
}

- (void)searchFileListBeginFun:(NSMutableDictionary *)dict
{
    NSMutableDictionary *objectDict = dict;
    NSNumber *curNum = @1;
    
    if ([[objectDict allKeys] containsObject:@"type"]) {
        curNum = [objectDict objectForKey:@"type"];
    }
    
    NSString *pathStr = @"";
    
    if ([[objectDict allKeys] containsObject:@"path"]) {
        pathStr = [objectDict objectForKey:@"path"];
    }
    
    NSString *fileType = @"video";
    
    if(curNum.boolValue)
    {
        fileType = @"jpg";
    }
    
    NSString * commandStr = [RCCommandHelp searchCouldPhoneFilewithType:fileType withPath:pathStr];
    [self.commandChannelManager rc_sendData:commandStr];
}


#pragma mark 获取云机基本信息
- (void)getBaseInfoFun
{
    NSString *commondStr  = @"{\"type\":\"getBaseInfo\"}";
    [self send_data:commondStr];
}

#pragma mark 获取云机系统镜像等信息
- (void)getSysInfoFun
{
    NSString *commondStr  = @"{\"type\":\"getSysInfo\"}";
    [self send_data:commondStr];
}

#pragma mark 云机截图保存到云机图库
- (void)screenshotInCloudPhoneFun{
    NSString*taskUid = [iTools getTaskUidStr];
    NSString *commondStr  = [RCCommandHelp commandCloudPhoneScreenshotWithTaskUid:taskUid];
    [self send_data:commondStr];
}

#pragma mark 获取TV投屏状态
- (void)getTvStatusFun
{
    NSString *commondStr  = @"{\"type\":\"TvStatus\"}";
    [self send_data:commondStr];
}

#pragma mark 关闭TV投屏状态
- (void)offTvFun
{
    NSString *commondStr  = @"{\"type\":\"TvOff\"}";
    [self send_data:commondStr];
}

#pragma mark 开启TV投屏状态
- (void)onTvFun
{
    NSString *commondStr  = @"{\"type\":\"wakeupTV\"}";
    [self send_data:commondStr];
}

#pragma mark 告诉别的ws收到的挤下线消息
- (void)didReceiveLogoutMsgFun
{
    //NSString *curOaidStr = [RcGameWQKeyChain getOaidStringFun];
    NSString *curOaidStr = [iPhone phoneDeviceUuid];

    if(!curOaidStr){
        curOaidStr = @"";
    }
    NSString *commondStr = [[NSString alloc] initWithFormat:@"{\"type\":\"forwardMsg\",\"data\":\"only one socket2\",\"sign\":\"%@\"}",curOaidStr];
    //NSString *commondStr  = @"{\"type\":\"forwardMsg\",\"data\":\"offline_notification\"}";
    [self send_data:commondStr];
}

#pragma mark 单点登录被挤下线弹框
- (void)LogoutByOtherFun
{
    
    if(logoutAlertVC){
        return;
    }
    
    [self didReceiveLogoutMsgFun];
    
    //通知音视频断开链接
    [[NSNotificationCenter defaultCenter] postNotificationName:logoutByOtherNotification object:nil];
    
    //yyyy-MM-dd HH:mm:ss
    NSString*dateStr = [iTools getNowTimeString2];
    if(dateStr && dateStr.length == 19){
        dateStr = [dateStr substringWithRange:NSMakeRange(11, 5)];
    }
    
    NSString *LogoutTimerStr = [[NSString alloc] initWithFormat:@"%@%@%@",NSLocalizedString(@"single_sign_on_Tips_one",nil),dateStr,NSLocalizedString(@"single_sign_on_Tips_two",nil)];
    
    
    NSString * loginAgainStr = NSLocalizedString(@"single_sign_on_login_again",nil);
    BOOL isOkBtnHighlight = YES;
    if(!ksharedAppDelegate.DeviceThirdIdMod.data.isPrivacyMode){
        loginAgainStr = @"";
        isOkBtnHighlight = NO;
    }
    
    _isLogoutByOtherType = YES;
    _didSendfristMsg = NO;
    _isWaitShowLogoutAlert = YES;
    
    //被挤下线 ws断开
    [self.commandChannelManager rc_close];
    self.commandChannelManager = nil;
    
    if([DFPlayer sharedPlayer].currentAudioModel
       &&([DFPlayer sharedPlayer].state == DFPlayerStateBuffering
          || [DFPlayer sharedPlayer].state == DFPlayerStatePlaying)
       ){
        [[DFPlayer sharedPlayer] df_pause];
        [[audioPlayingView sharedInstance] setAudioPlayingStateFunBy:NO];
    }
    
    
    if(ksharedAppDelegate.isDidShowPwdType){
        
        KWeakSelf
        dispatch_after(dispatch_time(DISPATCH_TIME_NOW, (int64_t)(3 * NSEC_PER_SEC)), dispatch_get_main_queue(), ^{
            [weakSelf LogoutByOtherFun];
            HLog(@"weakSelf LogoutByOtherFun")
        });
        return;
    }
    
    _isWaitShowLogoutAlert = NO;;
    
    /*弹窗提示重启*/
    //KWeakSelf
    logoutAlertVC = [[ComontAlretViewController alloc] initWithTiTle:NSLocalizedString(@"single_sign_on_Tips_logout",nil)
                                                                                     msg:LogoutTimerStr
                                                                                imageStr:@""
                                                                             cancelTitle:NSLocalizedString(@"single_sign_on_exit",nil)
                                                                                 okTitle:loginAgainStr isOkBtnHighlight:isOkBtnHighlight
                                                                             didClickOk:^{
        //[weakSelf tryAgain];
        //[[webSocketManager shareInstance] WebSocketNeedRelinkFun];
        
        self->_isLogoutByOtherType = NO;
        self->logoutAlertVC = nil;
        [[NSNotificationCenter defaultCenter] postNotificationName:lockBypwdNotification object:nil];
        
    } didClickCancel:^{
        exit(0);/*强制退出app*/
    }];
    logoutAlertVC.modalPresentationStyle = UIModalPresentationCustom;

    [[iTools appRootViewController] presentViewController:logoutAlertVC animated:YES completion:^{
        self->logoutAlertVC.view.superview.backgroundColor = [UIColor clearColor];
    }];
    
}
@end