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

#import "DHNetSDKSearchManager.h"
#import "DHNetSDKInterface.h"
#import "DHDeviceNetInfo.h"
#import <LCBaseModule/UIDevice+LeChange.h>
#import <LCBaseModule/DHNetWorkHelper.h>
#import <LCBaseModule/DHModuleConfig.h>
#import <LCBaseModule/DHFileManager.h>
#import <LCBaseModule/DHMobileInfo.h>
#import <LCAddDeviceModule/LCAddDeviceModule-Swift.h>

@interface DHNetSDKSearchManager()

@property (nonatomic, strong) NSMutableDictionary<NSString *, DHDeviceNetInfo*> *netInfoDic;
@property (nonatomic, assign) long searchHandle;
@property (nonatomic, copy) dispatch_queue_t queue;
@property (nonatomic, copy) dispatch_queue_t searchQueue;
@property (nonatomic, strong) NSTimer *timer;
@property (nonatomic, assign) NSInteger tickCount;
@property (nonatomic, assign) NSTimeInterval lastFindTime; /**< 记录上次NETSDK回调结果的时间 */
@property (nonatomic, assign) NSInteger searchSequence; /**< 搜索的序号 */
@property (nonatomic, copy) NSString *lastSSID;//上次连接的wifi的ssid，用于网络环境变化重新搜索设备

@end

@implementation DHNetSDKSearchManager

#pragma mark - circle life

- (instancetype)init
{
    if(self = [super init])
    {
        [self initNetSdk];
        _netInfoDic = @{}.mutableCopy;
		_queue = dispatch_queue_create("syncOperation", DISPATCH_QUEUE_CONCURRENT);
		_searchQueue = dispatch_queue_create("searchQueue", DISPATCH_QUEUE_SERIAL);
		_tickCount = 0;
		
#if DEBUG
		_showDebugLog = NO;
#else
		_showDebugLog = YES;
#endif
    }
    return self;
}

- (void)dealloc {
	[[NSNotificationCenter defaultCenter] removeObserver:self];
}

#pragma mark - Notification
- (void)addObservers {
	//防止重复添加
	[self removeObservers];
	
	[[NSNotificationCenter defaultCenter] addObserver:self selector:@selector(applicationWillResignActive:)
												 name:UIApplicationWillResignActiveNotification object:nil]; //监听是否触发home键挂起程序，（把程序放在后台执行其他操作）
	
	[[NSNotificationCenter defaultCenter] addObserver:self selector:@selector(applicationDidBecomeActive:)
												 name:UIApplicationDidBecomeActiveNotification object:nil]; //监听是否重新进入程序程序.（回到程序)
	[[NSNotificationCenter defaultCenter] addObserver:self selector:@selector(networkDidChanged:)
												 name:@"LCNotificationWifiNetWorkDidSwitch" object:nil];//从一个wifi网络切换到另外一个wifi网络也要重新获取设备列表
}

- (void)removeObservers {
	[[NSNotificationCenter defaultCenter] removeObserver:self];
}

- (void)applicationWillResignActive:(NSNotification *)notification
{
	if(self.timer != nil) {
		[self.timer fire];
		[self.timer invalidate];
		self.timer = nil;
	}
	
	DH_LOG_FUN
	
	dispatch_async(self.searchQueue, ^{
		if(self.searchHandle) {
			NSLog(@"DHNetSDKSearchManager::Stop search in resign active:%ld, sequence:%ld", self.searchHandle, (long)self.searchSequence);
			[[DHNetSDKInterface sharedInstance] stopSearchDevices:self.searchHandle];
			self.searchHandle = 0;
		}
	});
}

- (void)applicationDidBecomeActive:(NSNotification *)notification
{
	if(self.isSearching)
	{
		[self startSearch];
	}
}

- (void)networkDidChanged:(NSNotificationCenter *)notification {
	// DTS000583328 偶现崩溃 [DHMobileInfo sharedInstance].WIFISSID
	if (!self.isSearching) {
		return;
	}
	
    //针对软ap添加的bug
    NSString *wifiSSID = [[DHMobileInfo sharedInstance].WIFISSID uppercaseString];
    if (![wifiSSID isEqualToString:self.lastSSID] && wifiSSID.length) {
        self.lastSSID = wifiSSID;
        [self.netInfoDic removeAllObjects];
        if(self.isSearching) {
            [self startSearch];
        }
    }
}

#pragma mark - interface

- (void)startSearch
{
	if(self.timer != nil) {
		[self.timer fire];
		[self.timer invalidate];
		self.timer = nil;
	}
	
	DH_LOG_FUN
	
	NSInteger tick = 2;
	self.timer = [NSTimer scheduledTimerWithTimeInterval:tick target:self selector:@selector(timeTick) userInfo:nil repeats:YES];
	self.isSearching = YES;
	[self timeTick];
	
	//添加通知
	[self addObservers];
}

- (void)timeTick
{
	//wifi连接连接过程中，可能会出现无法识别的情况，不能加此判断
	//只处理ios13以下系统，不是WiFi状态时，不进行检测
	if (DH_IOS_VERSION < 13 &&
		[DHNetWorkHelper sharedInstance].emNetworkStatus != AFNetworkReachabilityStatusReachableViaWiFi) {
		return;
	}
	
	//【*】打印当前的WIFI信息、定位软AP相关问题
	if (self.tickCount % 10 == 0) {
		NSLog(@"DHNetSDKSearchManager::当前WIFI信息 %@, Mask:%@, Router:%@, IP:%@",
			  DHMobileInfo.sharedInstance.WIFISSID,
			  UIDevice.lc_getMaskAddress,
			  [UIDevice lc_getRouterAddress],
			  UIDevice.lc_getIPAddress);
	}
	
	//计时不中断
	self.tickCount++;
	
	NSInteger intervalCheck = 10;
	if(self.tickCount % intervalCheck == 0) {
		[self clearnUnReceiveDevice];
	}
	
	if (self.tickCount % 5 == 0) {
		if (_showDebugLog) {
			dispatch_barrier_async(self.queue, ^{
				NSLog(@"当前搜索到的设备:\n%@",self.netInfoDic.allKeys);
			});
		}
	}
	
	// 距离上次回调时间大于3s，才重新开始重新搜索
	NSTimeInterval currentTime = NSDate.date.timeIntervalSince1970;
	if (fabs(currentTime - self.lastFindTime) < 3) {
		NSLog(@"DHNetSDKSearchManager:: Ignore tick process...");
		return;
	}
	
	// 已经停止了，不需要再重新搜索
	if (self.isSearching == false) {
		NSLog(@"DHNetSDKSearchManager:: Search is stopped, return...");
		return;
	}
	
	dispatch_async(self.searchQueue, ^{
		if(self.searchHandle) {
			NSLog(@"DHNetSDKSearchManager::Stop search in timetick:%ld, sequence:%ld", self.searchHandle, (long)self.searchSequence);
			[[DHNetSDKInterface sharedInstance] stopSearchDevices:self.searchHandle];
			self.searchHandle = 0;
		}
		
		//【*】记录下当前搜索的序号
		//【*】优化：采用传IP+不传IP交替搜索
		NSString *localIp = (self.searchSequence % 2) == 0 ? UIDevice.lc_getIPAddress : nil;
		
		self.searchSequence++;
		NSInteger sequence = self.searchSequence;
		
		self.searchHandle = [[DHNetSDKInterface sharedInstance] startSearchDevices:^(DHDeviceNetInfo *netInfo) {
			dispatch_barrier_async(self.queue, ^{
				netInfo.searchSequence = sequence;
				if (self.showDebugLog) {
					NSLog(@"DHNetSDKSearchManager::-find device: %@ - %@，搜索序号：%ld, Init type:%lu, status: %lu",
						  netInfo.deviceType, netInfo.serialNo, (long)netInfo.searchSequence, (unsigned long)netInfo.deviceInitType, (unsigned long)netInfo.deviceInitStatus);
				}
	
				//避免找到deviceId为空的情况
				if (netInfo.serialNo.length > 0) {
					DHNetSDKSearchManager.sharedInstance.netInfoDic[netInfo.serialNo] = netInfo;
				}
				
				self.lastFindTime = NSDate.date.timeIntervalSince1970;
			});
		} byLocalIp: localIp];
		
		NSLog(@"DHNetSDKSearchManager:: Start search with handle:%ld, search sequence:%ld", self.searchHandle, (long)self.searchSequence);
		
		if(self.searchHandle == 0) {
			unsigned int errorCode = [DHNetSDKInterface getLastError];
			NSLog(@"NetSDKInteface:: Load wifilist failed with errorCode:...0x%x", errorCode);
			NSLog(@"DHNetSDKSearchManager::CLIENT_StartSearchDevices-fail");
			
            DHAddDeviceLogModel *model = [[DHAddDeviceLogModel alloc] init];
            model.method = @"startSearchDevices";
            model.res = model.resFail;
            model.errCode = errorCode;
            [[DHAddDeviceLogManager shareInstance] addDeviceNetSDKLogWithModel:model];
		}
	});
}

- (void)stopSearch {
	//停止通知
	[self removeObservers];
	
	dispatch_barrier_async(self.queue, ^{
		[self.netInfoDic removeAllObjects];
	});
	
	if(self.timer != nil) {
		[self.timer fire];
		[self.timer invalidate];
		self.timer = nil;
	}
	
	dispatch_async(self.searchQueue, ^{
		if(self.searchHandle) {
			NSLog(@"DHNetSDKSearchManager::Stop search in stop:%ld, sequence:%ld", self.searchHandle, (long)self.searchSequence);
			[[DHNetSDKInterface sharedInstance] stopSearchDevices:self.searchHandle];
			self.searchHandle = 0;
		}
	});
	
	self.searchSequence = 0;
	self.lastFindTime = 0;
	self.isSearching = NO;
}

- (id<ISearchDeviceNetInfo>)getNetInfoByID:(NSString *)deviceID;
{
	__block id<ISearchDeviceNetInfo> device;
	dispatch_barrier_sync(self.queue, ^{
		device = self.netInfoDic[deviceID];
	});

    return device;
}

#pragma mark - Custom
- (void)clearnUnReceiveDevice
{
	dispatch_barrier_async(self.queue, ^{
		//把所有未标记的从dic中一出  已标记的变成未标记 等待下一次的搜索
		NSArray<NSString *> *allKeys = [self.netInfoDic allKeys].copy;
		
		for (NSString *key in allKeys)
		{
			DHDeviceNetInfo *device = self.netInfoDic[key];
			if(!device.isVaild)
			{
				NSLog(@"%@ 在这次搜索中被移除", key);
				[self.netInfoDic removeObjectForKey:key];
			}
			else if (device.searchSequence != self.searchSequence)
			{
				//【*】21589：只有当前的搜索结束了，才将缓存中未搜索到的设备有效状态重置
				NSLog(@"DHNetSDKSearchManager:: 重置设备有效状态,设备 %@, 搜索序号： %ld, 当前序号：%ld", device.deviceSN, (long)device.searchSequence, (long)self.searchSequence);
				self.netInfoDic[key].isVaild = NO;
			}
		}
	});
}

#pragma mark - private method


-(void)initNetSdk
{
	[DHNetSDKInterface initSDK];
	
#if DEBUG
	NSString *path = [[DHFileManager supportFolder] stringByAppendingPathComponent:@"cache"];
	[DHNetSDKInterface logOpen: path];
#endif
}

#pragma mark - singleton
static DHNetSDKSearchManager *_instance = nil;
+ (instancetype)sharedInstance
{
    static dispatch_once_t onceToken;
    dispatch_once(&onceToken, ^{
        _instance = [[self alloc] init];
    });
    return _instance;
}

+ (id)allocWithZone:(struct _NSZone *)zone
{
    static dispatch_once_t onceToken;
    dispatch_once(&onceToken, ^{
        _instance = [super allocWithZone:zone];
    });
    return _instance;
}

- (id)copyWithZone:(NSZone *)zone{
    return _instance;
}
@end