connectDeviceManager.m 22 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656
  1. //
  2. // connectDeviceManager.m
  3. // 隐私保护
  4. //
  5. // Created by xd h on 2023/10/9.
  6. //
  7. //第三方 瑞云 的链接服务
  8. #import "connectDeviceManager.h"
  9. #import <RayProxy/RaylinkProxy.h>
  10. #import <CocoaAsyncSocket/GCDAsyncSocket.h>
  11. #import "WHPingTester.h"
  12. #import "RSATool.h"
  13. #import "errorAlertTool.h"
  14. @interface connectDeviceManager ()<
  15. GCDAsyncSocketDelegate,
  16. RaylinkProxyDelegate,
  17. WHPingDelegate
  18. >
  19. {
  20. dispatch_queue_t initProxyQueue;
  21. WHPingTester *whPingTester;
  22. BOOL didRuiYunInitOkType;
  23. BOOL disconnected_cb_type;//瑞云回调链接断开了
  24. BOOL didPingType;//是否ping过
  25. BOOL didRuiyunLinkType;//是否瑞云链接通过
  26. NSInteger RuiyunLinkSecond;//瑞云链接描述
  27. }
  28. @property (nonatomic, strong) NSTimer *connectCheckTimer;//这个应该是检查初始化是否完成的
  29. //@property (nonatomic, strong) GCDAsyncSocket *socket;
  30. //
  31. //@property (nonatomic, strong) GCDAsyncSocket *serverSocket;
  32. @property (nonatomic, assign) BOOL sdnConnected;
  33. @property (nonatomic, assign) BOOL peerConnected;
  34. @property (nonatomic, assign) NSInteger tcpPort;
  35. @property (nonatomic, copy) NSString *Pre_sdnId;//上一个sdn好
  36. @property (nonatomic, assign) BOOL isGetThridMsgType;
  37. @end
  38. @implementation connectDeviceManager
  39. static connectDeviceManager *connectDeviceManagerInstance = nil;
  40. +(connectDeviceManager *)shareInstance;
  41. {
  42. static dispatch_once_t onceToken;
  43. dispatch_once(&onceToken, ^{
  44. connectDeviceManagerInstance = [[connectDeviceManager alloc] init];
  45. connectDeviceManagerInstance.curConnectDeviceState = DeviceConnectUnknown;
  46. });
  47. return connectDeviceManagerInstance;
  48. }
  49. #pragma mark 根据扫码的sn获取第三方信息
  50. -(void)getThridMsgBySN:(NSString*)snStr needReconnect:(BOOL)needReconnect didNetEnd:(netWork_DidEndByOK)didNetEndIsOK
  51. {
  52. if(_isGetThridMsgType){
  53. didNetEndIsOK(-1);
  54. return;
  55. }
  56. if(needReconnect){
  57. _curConnectDeviceState = DeviceConnectGetThridMsging;
  58. //更换设备
  59. // NSString *curSdnId = self.DeviceThirdIdMod.data.sdnId;
  60. // if(curSdnId){
  61. // _Pre_sdnId = curSdnId;
  62. // }
  63. }
  64. NSMutableDictionary *paraDict = [NSMutableDictionary new];
  65. [paraDict setValue:snStr forKey:@"sn"];
  66. _isGetThridMsgType = YES;
  67. KWeakSelf
  68. [[netWorkManager shareInstance] CommonGetWithCallBackCode:getThirdIdBySn Parameters:paraDict success:^(id _Nonnull responseObject) {
  69. if(!needReconnect){
  70. NSError *parseError;
  71. NSData *jsonData = [NSJSONSerialization dataWithJSONObject:responseObject options:NSJSONWritingPrettyPrinted error:&parseError];
  72. if (parseError) {
  73. //解析出错
  74. }
  75. NSString * str = [[NSString alloc] initWithData:jsonData encoding:NSUTF8StringEncoding];
  76. [cachesFileManager writeLogsWithMsg:str];
  77. }
  78. self->_isGetThridMsgType = NO;
  79. DeviceThirdIdModel *model = [[DeviceThirdIdModel alloc] initWithDictionary:responseObject error:nil];
  80. if(model.status == 0
  81. && model.data)
  82. {
  83. weakSelf.DeviceThirdIdMod = model;
  84. NSString*desPwdstr = [RSATool AES128Decrypt:weakSelf.DeviceThirdIdMod.data.password key:AESCODEKEEYY];
  85. didNetEndIsOK(YES);
  86. /*密码保持在本地*/
  87. NSDictionary *deviceDict = [HWDataManager getObjectWithKey:Const_Have_Add_Device];
  88. NSMutableDictionary *dict = [[NSMutableDictionary alloc] initWithDictionary:deviceDict];
  89. [dict setObject:desPwdstr forKey:Const_Have_Add_Device_PWD];
  90. NSString *sdnid = model.data.sdnId;
  91. if(sdnid){
  92. [dict setObject:sdnid forKey:Const_Have_Add_Device_sdnid];
  93. }
  94. [HWDataManager setObjectWithKey:Const_Have_Add_Device_Privacy_Mode value:[NSNumber numberWithBool:model.data.isPrivacyMode]];
  95. [HWDataManager setObjectWithKey:Const_Have_Add_Device value:dict];
  96. //
  97. bool connected = [RaylinkProxy.sharedManager isSdnConnected];
  98. if(!connected || needReconnect){
  99. self->didPingType = NO;
  100. self->didRuiyunLinkType = NO;
  101. self->_isPingOk = NO;
  102. weakSelf.curConnectDeviceState = DeviceConnectGetThridOK;
  103. NSString *ipStr = weakSelf.DeviceThirdIdMod.data.ip;
  104. [weakSelf startPingDeviceIp:ipStr];
  105. [weakSelf initRuiyunSDKFun];
  106. }
  107. }
  108. else{
  109. if(model.status == 201||model.status == 202){
  110. didNetEndIsOK(model.status);
  111. }
  112. else{
  113. didNetEndIsOK(2);
  114. }
  115. }
  116. } failure:^(NSError * _Nonnull error) {
  117. HLog("网络报错");
  118. self->_isGetThridMsgType = NO;
  119. didNetEndIsOK(NO);
  120. }];
  121. }
  122. #pragma mark 刷新扫码的sn获取第三方信息 是否需要重连
  123. -(void)RefreshThridMsg
  124. {
  125. /*先判断本地有无设备 无设备时需要先扫码添加设备*/
  126. NSDictionary *deviceDict = [HWDataManager getObjectWithKey:Const_Have_Add_Device];
  127. if (deviceDict && [[deviceDict allKeys] containsObject:Const_Have_Add_Device_SN]){
  128. //有设备了先去做链接准备 // 80bec9c5
  129. NSString *SNStr = deviceDict[@"Const_Have_Add_Device_SN"];
  130. if(SNStr){
  131. [[connectDeviceManager shareInstance] getThridMsgBySN:SNStr needReconnect:NO didNetEnd:^(NSInteger didSuc) {
  132. }];
  133. }
  134. }
  135. }
  136. #pragma mark 初始化瑞云的SDK等
  137. - (void)initRuiyunSDKFun{
  138. if(didRuiYunInitOkType){
  139. [self onConnectFun];
  140. return;
  141. }
  142. HLog(@"initRuiyunSDKFun");
  143. self.sdnConnected = NO;
  144. self.peerConnected = NO;
  145. //self.sendBtn.enabled = NO;
  146. //self.sdnConnectStateLab.text = @"SDN state: Connectting";
  147. //self.sdnIDLab.text = @"My SDN ID:";
  148. RaylinkProxy.sharedManager.delegate = self;
  149. initProxyQueue = dispatch_queue_create("init_proxy", 0);
  150. NSURL *logUrl = [[NSFileManager.defaultManager URLsForDirectory:NSDocumentDirectory inDomains:NSUserDomainMask].firstObject URLByAppendingPathComponent:@"logs"];
  151. if (![NSFileManager.defaultManager fileExistsAtPath:logUrl.path]) {
  152. [NSFileManager.defaultManager createDirectoryAtURL:logUrl withIntermediateDirectories:YES attributes:NULL error:NULL];
  153. }
  154. KWeakSelf
  155. dispatch_async(initProxyQueue, ^{
  156. NSData *sdnInfo = [NSData dataWithContentsOfURL:[[NSBundle.mainBundle bundleURL] URLByAppendingPathComponent:@"planet.1ali_3ry_peer"]];
  157. /// 1. 初始化代理库
  158. [RaylinkProxy.sharedManager initProxy:logUrl.path rootSdnInfo:sdnInfo];
  159. self->didRuiYunInitOkType = YES;
  160. /// 启动定时器监听 SND 连接状态
  161. self.connectCheckTimer = [NSTimer scheduledTimerWithTimeInterval:0.5 repeats:YES block:^(NSTimer * _Nonnull timer) {
  162. /// 2. 监听SDN 连接状态
  163. bool connected = [RaylinkProxy.sharedManager isSdnConnected];
  164. if (self.sdnConnected == connected) {
  165. return;
  166. }
  167. self.sdnConnected = connected;
  168. if (self.sdnConnected) {
  169. [weakSelf onConnectFun];
  170. [self->_connectCheckTimer invalidate];
  171. //self.sdnConnectStateLab.text = @"SDN state: Connected";
  172. //self.sdnIDLab.text = [@"My SDN ID: " stringByAppendingString:[RaylinkProxy.sharedManager getSdnId]];
  173. } else {
  174. //self.sdnConnectStateLab.text = @"SDN state: Connectting";
  175. }
  176. }];
  177. [[NSRunLoop currentRunLoop] addTimer:self.connectCheckTimer forMode:NSRunLoopCommonModes];
  178. [[NSRunLoop currentRunLoop] run];
  179. });
  180. /// 作为服务端时,启动端口监听
  181. // self.serverSocket = [[GCDAsyncSocket alloc] initWithDelegate:self delegateQueue:dispatch_get_main_queue()];
  182. //
  183. // if ([self.serverSocket acceptOnPort:0 error:NULL]) {
  184. // //self.serverPortLab.text = [NSString stringWithFormat: @"server port: %d", self.serverSocket.localPort];
  185. // NSLog(@"accept ok %d",self.serverSocket.localPort);
  186. // }
  187. }
  188. - (void)onConnectFun{
  189. if (self.peerConnected == YES
  190. && _Pre_sdnId
  191. && ![_Pre_sdnId isEqualToString:self.DeviceThirdIdMod.data.sdnId]) {
  192. //[self disconnect];
  193. //return;
  194. }
  195. RuiyunLinkSecond = 0;
  196. _curConnectDeviceState = DeviceConnectDeciceing;
  197. NSString *curSdnId = self.DeviceThirdIdMod.data.sdnId; //@"3dfe7c1f";
  198. if(!curSdnId){
  199. NSDictionary *deviceDict = [HWDataManager getObjectWithKey:Const_Have_Add_Device];
  200. if(deviceDict && [[deviceDict allKeys] containsObject:Const_Have_Add_Device_sdnid])
  201. {
  202. curSdnId = deviceDict[Const_Have_Add_Device_sdnid];
  203. }
  204. }
  205. /// 3. 根据对端的 SDN ID 创建连接
  206. [RaylinkProxy.sharedManager createNewConnection:curSdnId];
  207. //self.socket = [[GCDAsyncSocket alloc] initWithDelegate:self delegateQueue:dispatch_get_main_queue()];
  208. //[self.connectBtn setEnabled:NO];
  209. //[self.connectBtn setTitle:@"连接中..." forState:UIControlStateDisabled];
  210. //KWeakSelf
  211. dispatch_after(dispatch_time(DISPATCH_TIME_NOW, (int64_t)(30 * NSEC_PER_SEC)), dispatch_get_main_queue(), ^{
  212. if(!self->didRuiyunLinkType){
  213. //弹框瑞云链接失败
  214. [[errorAlertTool shareInstance] showNetErrorAlertFun:11 didClickBut:^(NSInteger tag) {
  215. }];
  216. }
  217. });
  218. }
  219. - (void)disconnect {
  220. NSString *curSdnId = self.DeviceThirdIdMod.data.sdnId;
  221. if(_Pre_sdnId){
  222. curSdnId = _Pre_sdnId;
  223. }
  224. if(curSdnId){
  225. [RaylinkProxy.sharedManager closeConnection:curSdnId];
  226. [RaylinkProxy.sharedManager closeHttpService:curSdnId];
  227. //[self.connectBtn setTitle:@"连接" forState:UIControlStateNormal];
  228. self.peerConnected = NO;
  229. }
  230. }
  231. - (IBAction)onClickSend:(id)sender {
  232. // if (self.messageTF.text.length <= 0) {
  233. // return;
  234. // }
  235. //[self.socket writeData:[@"111" dataUsingEncoding:NSUTF8StringEncoding] withTimeout:-1 tag:0];
  236. }
  237. //- (void)socket:(GCDAsyncSocket *)sock didAcceptNewSocket:(GCDAsyncSocket *)newSocket {
  238. //
  239. // NSLog(@"didAcceptNewSocket");
  240. //
  241. //
  242. // [newSocket setDelegate:self delegateQueue:dispatch_get_main_queue()];
  243. //
  244. // NSThread *revcThread = [[NSThread alloc] initWithBlock:^{
  245. //
  246. // while (true) {
  247. // [newSocket readDataWithTimeout:-1 tag:0];
  248. // [NSThread sleepForTimeInterval:0.1];
  249. // }
  250. // }];
  251. //
  252. // [revcThread start];
  253. //
  254. //}
  255. - (void)onProxyConnected:(NSString *)sdnId status:(int)status {
  256. if (status == 0) {
  257. /// 4. 创建 HttpService
  258. self.tcpPort = [RaylinkProxy.sharedManager createHttpService:sdnId];
  259. self.tcpPortStr = [[NSString alloc] initWithFormat:@"%ld",self.tcpPort];
  260. [[netWorkManager shareInstance] setAFHTTPSessionManagerFunBy:self.tcpPort];
  261. /// 5. 添加端口防火墙
  262. [RaylinkProxy.sharedManager addSdnId:sdnId ip:ruiyunlinkIp allowPort:9300];
  263. [RaylinkProxy.sharedManager addSdnId:sdnId ip:ruiyunlinkIp allowPort:9100];
  264. [RaylinkProxy.sharedManager addSdnId:sdnId ip:ruiyunlinkIp allowPort:9888];
  265. [cachesFileManager writeLogsWithMsg:@"onProxyConnected connectToHost"];
  266. /// 6. 等待连接成功回调,创建 TCP socket 连接 HttpService 的端口
  267. // NSError *error;
  268. //
  269. // NSString*log1 = [[NSString alloc] initWithFormat:@"onProxyConnected connectToHost begin %ld", (long)self.tcpPort];
  270. // [cachesFileManager writeLogsWithMsg:log1];
  271. //
  272. // [self.socket connectToHost:@"127.0.0.1" onPort:self.tcpPort error:&error];
  273. //
  274. // NSString*log2 = [[NSString alloc] initWithFormat:@"onProxyConnected connectToHost end %ld, self.socket = %@ error = %@", (long)self.tcpPort, self.socket, error];
  275. // [cachesFileManager writeLogsWithMsg:log2];
  276. _curConnectDeviceState = DeviceConnectDeciceOk;
  277. _Pre_sdnId = self.DeviceThirdIdMod.data.sdnId;
  278. disconnected_cb_type = NO;
  279. didRuiyunLinkType = YES;
  280. [self beginLinkWebSocketFun];
  281. } else {
  282. HLog(@"瑞云链接断开");
  283. }
  284. }
  285. - (void)OnProxyDisconnected_cb:(NSString *)sdnId {
  286. //[RaylinkProxy.sharedManager closeHttpService:sdnId];
  287. [cachesFileManager writeLogsWithMsg:@"OnProxyDisconnected_cb"];
  288. disconnected_cb_type = YES;
  289. }
  290. //瑞云sock 断开了 需要重连
  291. - (void)tryReconnectFun{
  292. [cachesFileManager writeLogsWithMsg:@"tryReconnect"];
  293. [cachesFileManager writeLogsWithMsg:@"click again try Net Work"];
  294. [self getThridMsgBySN:self.DeviceThirdIdMod.data.changeSn needReconnect:NO didNetEnd:^(NSInteger didSuc) {
  295. NSString *tip = [[NSString alloc] initWithFormat:@"Net Work state:%ld",didSuc];
  296. [cachesFileManager writeLogsWithMsg:tip];
  297. }];
  298. if(!disconnected_cb_type){
  299. [cachesFileManager writeLogsWithMsg:@"tryReconnect return"];
  300. return;
  301. }
  302. NSURL *logUrl = [[NSFileManager.defaultManager URLsForDirectory:NSDocumentDirectory inDomains:NSUserDomainMask].firstObject URLByAppendingPathComponent:@"logs"];
  303. if (![NSFileManager.defaultManager fileExistsAtPath:logUrl.path]) {
  304. [NSFileManager.defaultManager createDirectoryAtURL:logUrl withIntermediateDirectories:YES attributes:NULL error:NULL];
  305. }
  306. // dispatch_queue_t reinitProxyQueue = dispatch_queue_create("reinit_proxy", 0);
  307. //
  308. //
  309. // [cachesFileManager writeLogsWithMsg:@"tryReconnect initProxy 0"];
  310. // dispatch_async(reinitProxyQueue, ^{
  311. // NSData *sdnInfo = [NSData dataWithContentsOfURL:[[NSBundle.mainBundle bundleURL] URLByAppendingPathComponent:@"planet.1ali_3ry_peer"]];
  312. //
  313. // /// 1. 初始化代理库
  314. // [cachesFileManager writeLogsWithMsg:@"tryReconnect initProxy 1"];
  315. // self->disconnected_cb_type = NO;
  316. // self->_isReInitType = YES;
  317. // [RaylinkProxy.sharedManager initProxy:logUrl.path rootSdnInfo:sdnInfo];
  318. // self->_isReInitType = NO;
  319. // [cachesFileManager writeLogsWithMsg:@"tryReconnect initProxy 2"];
  320. // });
  321. // //KWeakSelf
  322. // NSMutableDictionary *paraDict = [NSMutableDictionary new];
  323. // if(self.DeviceThirdIdMod.data.sn){
  324. // [paraDict setValue:self.DeviceThirdIdMod.data.sn forKey:@"sn"];
  325. // }
  326. //
  327. // [cachesFileManager writeLogsWithMsg:@"tryReconnect CommonGetWithCallBackCode"];
  328. // [[netWorkManager shareInstance] CommonGetWithCallBackCode:getThirdIdBySn Parameters:paraDict success:^(id _Nonnull responseObject) {
  329. //
  330. // dispatch_async(self->initProxyQueue, ^{
  331. // NSData *sdnInfo = [NSData dataWithContentsOfURL:[[NSBundle.mainBundle bundleURL] URLByAppendingPathComponent:@"planet.1ali_3ry_peer"]];
  332. //
  333. // /// 1. 初始化代理库
  334. // [RaylinkProxy.sharedManager initProxy:logUrl.path rootSdnInfo:sdnInfo];
  335. // [cachesFileManager writeLogsWithMsg:@"tryReconnect initProxy"];
  336. // });
  337. //
  338. //
  339. // } failure:^(NSError * _Nonnull error) {
  340. // HLog("网络报错");
  341. // }];
  342. }
  343. //音视频 链接返回-5的时候调用
  344. - (void)recreateHttpServiceFun{
  345. [cachesFileManager writeLogsWithMsg:@"recreateHttpServiceFun"];
  346. NSString *sdnId = self.DeviceThirdIdMod.data.sdnId;
  347. self.tcpPort = [RaylinkProxy.sharedManager createHttpService:sdnId];
  348. self.tcpPortStr = [[NSString alloc] initWithFormat:@"%ld",self.tcpPort];
  349. [[netWorkManager shareInstance] setAFHTTPSessionManagerFunBy:self.tcpPort];
  350. [RaylinkProxy.sharedManager addSdnId:sdnId ip:ruiyunlinkIp allowPort:9300];
  351. [RaylinkProxy.sharedManager addSdnId:sdnId ip:ruiyunlinkIp allowPort:9100];
  352. [RaylinkProxy.sharedManager addSdnId:sdnId ip:ruiyunlinkIp allowPort:9888];
  353. }
  354. //- (void)socket:(GCDAsyncSocket *)sock didConnectToHost:(NSString *)host port:(uint16_t)port {
  355. //
  356. // NSLog(@"didConnectToHost %d", port);
  357. //
  358. // NSThread *thread = [[NSThread alloc] initWithBlock:^{
  359. // while (true) {
  360. //
  361. // [self.socket readDataWithTimeout:-1 tag:0];
  362. // [NSThread sleepForTimeInterval:0.1];
  363. //
  364. // }
  365. // }];
  366. //
  367. // [thread start];
  368. //
  369. // /// 7. Socket 连接成功后,通过 socket 发送, self.peerPortTF 为对端服务端口
  370. // //[sock writeData:[[NSString stringWithFormat:@"CONNECT 127.0.0.1:%@ HTTP/1.0\r\n\r\n", @"9100"] dataUsingEncoding:NSUTF8StringEncoding] withTimeout:-1 tag:0];
  371. //
  372. // NSLog(@"readDataToData");
  373. //
  374. // [cachesFileManager writeLogsWithMsg:@"didConnectToHost writeData"];
  375. //}
  376. //
  377. //- (void)socket:(GCDAsyncSocket *)sock didWriteDataWithTag:(long)tag
  378. //{
  379. // NSLog(@"socket:%p didWriteDataWithTag:%ld", sock, tag);
  380. //}
  381. //
  382. //- (void)socket:(GCDAsyncSocket *)sock didReadData:(NSData *)data withTag:(long)tag {
  383. //
  384. //
  385. // if (tag == 0) {
  386. //
  387. // NSString *str = [[NSString alloc] initWithData:data encoding:NSUTF8StringEncoding];
  388. //
  389. // /// 8. 收到包含 `HTTP/1.0 200`的字符串,则认为连接成功。可以正常给对端发消息了
  390. // if ([str containsString:@"HTTP/1.0 200"]) {
  391. // NSLog(@"Connected");
  392. // self.peerConnected = YES;
  393. //// self.connectBtn.enabled = YES;
  394. //// [self.connectBtn setTitle:@"断开连接" forState:UIControlStateNormal];
  395. // }
  396. //
  397. // }
  398. //
  399. // //self.revcLab.text = [NSString stringWithFormat:@"接收:%@", [[NSString alloc] initWithData:data encoding:NSUTF8StringEncoding]];
  400. //}
  401. #pragma mark 保持卡密码
  402. -(void)updateCardInfoBySN:(NSString*)snStr withPwdStr:(NSString*)pwd didNetEnd:(netWork_DidEndByOK)didNetEndIsOK
  403. {
  404. NSMutableDictionary *paraDict = [NSMutableDictionary new];
  405. [paraDict setValue:snStr forKey:@"sn"];
  406. NSString* enPwdStr = [RSATool AES128Encrypt:pwd key:AESCODEKEEYY];
  407. if(enPwdStr){
  408. [paraDict setValue:enPwdStr forKey:@"password"];
  409. }
  410. KWeakSelf
  411. [[netWorkManager shareInstance] CommonPostCallBackCode:updateCardInfo Parameters:paraDict success:^(id _Nonnull responseObject) {
  412. SuperModel*model = [[SuperModel alloc] initWithDictionary:responseObject error:nil];
  413. if(model && model.status == 0)
  414. {
  415. didNetEndIsOK(YES);
  416. [connectDeviceManager shareInstance].DeviceThirdIdMod.data.password = enPwdStr;
  417. /*密码保持在本地*/
  418. NSDictionary *deviceDict = [HWDataManager getObjectWithKey:Const_Have_Add_Device];
  419. NSMutableDictionary *dict = [[NSMutableDictionary alloc] initWithDictionary:deviceDict];
  420. [dict setObject:pwd forKey:Const_Have_Add_Device_PWD];
  421. [HWDataManager setObjectWithKey:Const_Have_Add_Device value:dict];
  422. }
  423. else{
  424. didNetEndIsOK(NO);
  425. }
  426. } failure:^(NSError * _Nonnull error) {
  427. HLog("网络报错");
  428. didNetEndIsOK(NO);
  429. }];
  430. }
  431. #pragma mark ---ping-----站点 判断是否是局域网
  432. - (void)startPingDeviceIp:(NSString *)roomInternetIp
  433. {
  434. //roomInternetIp = @"www.baidu.com";
  435. if(!roomInternetIp || roomInternetIp.length < 7){
  436. self.isPingOk = NO;
  437. return;
  438. }
  439. if (self->whPingTester)
  440. {
  441. [self->whPingTester stopPing];
  442. self->whPingTester = nil;
  443. }
  444. self->whPingTester = [[WHPingTester alloc] initWithHostName:roomInternetIp];
  445. self->whPingTester.delegate = self;
  446. //self->whPingTester.countdownTime = 1; //1秒ping一次
  447. [self->whPingTester startPing];
  448. /// 启动定时器监听 10秒后 whPingTester的状态
  449. KWeakSelf
  450. dispatch_after(dispatch_time(DISPATCH_TIME_NOW, (int64_t)(5 * NSEC_PER_SEC)), dispatch_get_main_queue(), ^{
  451. if(self->whPingTester){
  452. [weakSelf didGetPingStateIsOK:NO];
  453. }
  454. });
  455. }
  456. #pragma mark ---ping---- 代理回调
  457. - (void) didPingSucccessWithTime:(float)time withError:(NSError*) error
  458. {
  459. HLog(@"time:%f \n error: %@",time,error)
  460. //if(error.code == 111 || time > 1000) //超时或者延时超过100ms,就要记录数据
  461. if(error != nil)
  462. {
  463. [self didGetPingStateIsOK:NO];
  464. }
  465. else if(time > 0){
  466. [self didGetPingStateIsOK:YES];
  467. //test code
  468. //[self didGetPingStateIsOK:NO];
  469. }
  470. }
  471. - (void) didPingfialewithError:(NSError*)error
  472. {
  473. HLog(@" error error: %@",error)
  474. [self didGetPingStateIsOK:NO];
  475. }
  476. -(void)didGetPingStateIsOK:(BOOL)isOk
  477. {
  478. self.isPingOk = isOk;
  479. [self->whPingTester stopPing];
  480. self->whPingTester = nil;
  481. didPingType = YES;
  482. [self beginLinkWebSocketFun];
  483. }
  484. - (void)beginLinkWebSocketFun
  485. {
  486. if(!didPingType){
  487. return;
  488. }
  489. //局域网不通 瑞云还没连接好
  490. if(!self.isPingOk && !didRuiyunLinkType){
  491. return;
  492. }
  493. //切换设备
  494. if([webSocketManager shareInstance].commandChannelManager){
  495. // [[webSocketManager shareInstance].commandChannelManager rc_close];
  496. // [webSocketManager shareInstance].commandChannelManager = nil;
  497. ksharedAppDelegate.isWebSockLinkOKAginType = NO;
  498. dispatch_after(dispatch_time(DISPATCH_TIME_NOW, (int64_t)(1.0 * NSEC_PER_SEC)), dispatch_get_global_queue(DISPATCH_QUEUE_PRIORITY_DEFAULT, 0), ^{
  499. if([connectDeviceManager shareInstance].isFirstInputPwdDone){
  500. [[webSocketManager shareInstance] opencommandChannelManagerrc_openURL];
  501. }
  502. });
  503. }
  504. else{//第一次启动
  505. if([connectDeviceManager shareInstance].isFirstInputPwdDone){
  506. [[webSocketManager shareInstance] opencommandChannelManagerrc_openURL];
  507. }
  508. }
  509. }
  510. @end