//
//  Copyright © 2018年 dahua. All rights reserved.
//

#import "DHNetSDKInitialManager.h"
#import "DHDeviceNetInfo.h"
#import "DHNetSDKInterface.h"
#import <LCAddDeviceModule/LCAddDeviceModule-Swift.h>

@interface DHNetSDKInitialManager()

@property (nonatomic,copy) NSString *pwdString;

@end

@implementation DHNetSDKInitialManager

#pragma mark - circle life

- (instancetype)init {
    if(self = [super init]) {

    }
    return self;
}

#pragma mark - singleton

static DHNetSDKInitialManager *_instance = nil;
+ (instancetype)sharedInstance {
    static dispatch_once_t onceToken;
    dispatch_once(&onceToken, ^{
        _instance = [[self alloc] init];
    });
    return _instance;
}

#pragma mark - interface

- (void)initialDeviceWithPassWord:(NSString *)pwdString
						 isSoftAp:(BOOL)isSoftAp
				  withInitialType:(DHDeviceInitType)initialType
				 withSuccessBlock:(InitialSuccessHandle)success
				 withFailureBlock:(InitialFailHandle)fail {
	if (isSoftAp) {
		[self initialApDeviceWithPassword:pwdString withInitialType:initialType withSuccessBlock:success withFailureBlock:fail];
	} else {
		[self initialCommonDeviceWithPassWord:pwdString withInitialType:initialType withSuccessBlock:success withFailureBlock:fail];
	}
}

-(void)initialCommonDeviceWithPassWord:(NSString *)pwdString
					   withInitialType:(DHDeviceInitType)initialType
					  withSuccessBlock:(InitialSuccessHandle)success
					  withFailureBlock:(InitialFailHandle)fail {
	/*
	 **初始化逻辑**
	 新设备程序在配网成功的情况下，可以根据搜索得到的设备信息中的specialAbility的bit2-3位判断IP是否有效(老设备程序无此能力，但可以根据此字段确定是否新老程序)，所以初始化逻辑重要有以下三种：
	 1、老设备程序：specialAbility的bit2-3位为0，此时走老的组播单播初始化逻辑
	 2、IP有效：直接走单播初始化逻辑，节省了组播初始化时间
	 3、IP无效：则需要等待DHCP分配IP成功才可以进行初始化。SearchManager在后台持续搜索，当DHCP分配成功，设备会重新发广播上报，SearchManager能够更新搜索到的设备信息，因此在IP无效的情况下，InitialManager(本类)只需要每隔0.5秒从SearchManager更新一次搜索结果，等待DHCP分配成功，根据获取到的有效IP进行单播初始化，20次以后DHCP未分配成功则初始化失败。
	 */
	
	NSLog(@"DHNetSDKInitialManager::Initial common device with type:%lu", (unsigned long)initialType);
	self.pwdString = pwdString;
	
	switch (initialType) {
			//老设备程序
		case DHDeviceInitTypeOldDevice:
			[self multicastWithPassWord:pwdString withInitialType:initialType withSuccessBlock:success withFailureBlock:fail];
			break;
			
			//IP有效初始化
		case DHDeviceInitTypeIPEnable:
			[self unicastWithPassWord:pwdString withInitialType:initialType withSuccessBlock:success withFailureBlock:fail];
			break;
			
			//IP无效
		case DHDeviceInitTypeIPUnable:
		{
			//计数器
			__block int count = 0;
			//计数最大值
			int maxCount = 20;
			//定时器对象
			__block dispatch_source_t timer = dispatch_source_create(DISPATCH_SOURCE_TYPE_TIMER, 0, 0, dispatch_get_global_queue(0, 0));
			//从现在开始，每0.5秒执行一次
			dispatch_source_set_timer(timer, DISPATCH_TIME_NOW, (int64_t)(0.5 * NSEC_PER_SEC), 0);
			//定时器回调
			dispatch_source_set_event_handler(timer, ^{
				
				NSLog(@"CGD定时器-----%@",[NSThread currentThread]);
				count++;
				if (count == maxCount) { // 执行20次(10秒后),释放定时器
					dispatch_async(dispatch_get_main_queue(), ^{
						//fail();
						
						//超时失败后，走老的初始化
						[self initialCommonDeviceWithPassWord:pwdString withInitialType:DHDeviceInitTypeOldDevice withSuccessBlock:success withFailureBlock:fail];
					});

					dispatch_cancel(timer);
					timer = nil;
				}else{
					//更新设备信息，获取IP
					DHDeviceNetInfo *deviceNetInfo = [self updateDeviceSearchInfo];
					if (deviceNetInfo.deviceInitType == DHDeviceInitTypeIPEnable){
						//最新IP有效
						if ([self unicastIpWithDeviceInfo:deviceNetInfo isMulticast:NO]) {
							//单播初始化成功
							dispatch_async(dispatch_get_main_queue(), ^{
								success();
							});
						}else{
							//单播初始化失败
							dispatch_async(dispatch_get_main_queue(), ^{
								fail();
							});
						}
						dispatch_cancel(timer);
						timer = nil;
					}
					
				}
			});
			//启动定时器
			dispatch_resume(timer);
		}
			break;
			
		default:
			break;
	}
}

- (void)initialApDeviceWithPassword:(NSString *)pwdString
					withInitialType:(DHDeviceInitType)initialType
				   withSuccessBlock:(InitialSuccessHandle)success
				   withFailureBlock:(InitialFailHandle)fail {
	NSLog(@"DHNetSDKInitialManager::Initial ap device with type:%lu", (unsigned long)initialType);
	self.pwdString = pwdString;
	
	switch (initialType) {
			//老设备程序或者IP效，均走老流程
		case DHDeviceInitTypeOldDevice:
		case DHDeviceInitTypeIPUnable:
			[self multicastWithPassWord:pwdString withInitialType:initialType withSuccessBlock:success withFailureBlock:fail];
			break;
			
			//IP有效初始化
		case DHDeviceInitTypeIPEnable:
			[self unicastWithPassWord:pwdString withInitialType:initialType withSuccessBlock:success withFailureBlock:fail];
			break;
			
		default:
			break;
	}
}

- (void)multicastWithPassWord:(NSString *)pwdString
			  withInitialType:(DHDeviceInitType)initialType
			 withSuccessBlock:(InitialSuccessHandle)success
			 withFailureBlock:(InitialFailHandle)fail {
	dispatch_async(dispatch_get_global_queue(DISPATCH_QUEUE_PRIORITY_DEFAULT, 0), ^{
		//组播 前三次发组播包 每次五秒
		DHDeviceNetInfo *deviceNetInfo = [self updateDeviceSearchInfo];
		if(deviceNetInfo==nil)
		{
			dispatch_async(dispatch_get_main_queue(), ^{
				fail();
			});
		}else if ([self multicastWithDeviceInfo:deviceNetInfo isMulticast:YES]) {
			//组播初始化成功
			dispatch_async(dispatch_get_main_queue(), ^{
				success();
			});
		}else{
			//组播初始化失败，获取最新的设备信息进行单播初始化
            deviceNetInfo = [self updateDeviceSearchInfo];
            if(deviceNetInfo==nil)
            {
                dispatch_async(dispatch_get_main_queue(), ^{
                    fail();
                });
            }
			else if ([self unicastIpWithDeviceInfo:deviceNetInfo isMulticast:NO]) {
				//单播初始化成功
				dispatch_async(dispatch_get_main_queue(), ^{
					success();
				});
			}
			else {
				//单播初始化失败
				dispatch_async(dispatch_get_main_queue(), ^{
					fail();
				});
			}
		}
	});
}

- (void)unicastWithPassWord:(NSString *)pwdString
			withInitialType:(DHDeviceInitType)initialType
		   withSuccessBlock:(InitialSuccessHandle)success
		   withFailureBlock:(InitialFailHandle)fail {
	dispatch_async(dispatch_get_global_queue(DISPATCH_QUEUE_PRIORITY_DEFAULT, 0), ^{
		
		DHDeviceNetInfo *deviceNetInfo = [self updateDeviceSearchInfo];
		if ([self unicastIpWithDeviceInfo:deviceNetInfo isMulticast:NO]) {
			dispatch_async(dispatch_get_main_queue(), ^{
				success();
			});
		}
		else {
			dispatch_async(dispatch_get_main_queue(), ^{
				fail();
			});
		}
	});
}

#pragma mark - private

- (BOOL)unicastIpWithDeviceInfo:(DHDeviceNetInfo *)deviceNetInfo isMulticast:(BOOL)isMulticast {
    DHDeviceInfoLogModel *model = [DHNetSDKInterface initDevAccount:self.pwdString device:deviceNetInfo useIp:YES];
    [self addDeviceNetSDKLog:model.isSuccess];
    [self addDeviceInitLog:deviceNetInfo info:model isMulticast:isMulticast];
    return model.isSuccess;
}

- (BOOL)multicastWithDeviceInfo:(DHDeviceNetInfo *)deviceNetInfo isMulticast:(BOOL)isMulticast {
    DHDeviceInfoLogModel *model = [DHNetSDKInterface initDevAccount:self.pwdString device:deviceNetInfo useIp:NO];
    [self addDeviceNetSDKLog:model.isSuccess];
    [self addDeviceInitLog:deviceNetInfo info:model isMulticast:isMulticast];
    return model.isSuccess;
}

//从DHNetSDKSearchManager获取最新的设备搜索信息
- (DHDeviceNetInfo*)updateDeviceSearchInfo {
    
    NSString *deviceID = [DHAddDeviceManager sharedInstance].deviceId;
    DHDeviceNetInfo *deviceNetInfo = [[DHNetSDKSearchManager sharedInstance] getNetInfoByID:deviceID];
    return deviceNetInfo;
}

- (void)addDeviceNetSDKLog:(BOOL)isSuccess
{
    DHAddDeviceLogModel *model = [[DHAddDeviceLogModel alloc] init];
    model.method = @"initDevAccount";
    model.res = isSuccess ? model.res : model.resFail;
    model.errCode = isSuccess ? model.errCode : [DHNetSDKInterface getLastError];
    [[DHAddDeviceLogManager shareInstance] addDeviceNetSDKLogWithModel:model];
}

- (void)addDeviceInitLog:(DHDeviceNetInfo *)deviceNetInfo info:(DHDeviceInfoLogModel *)info isMulticast:(BOOL)isMulticast
{
    DHAddDeviceLogModel *model = [[DHAddDeviceLogModel alloc] init];
    model.deviceInfo = info;
    model.type = isMulticast ? model.initDev : model.initDev;
    model.res = info.isSuccess ? model.res : model.resFail;
    model.errCode = info.isSuccess ? model.errCode : [DHNetSDKInterface getLastError];
    [[DHAddDeviceLogManager shareInstance] addDeviceInitLogWithModel:model];
}


@end