connectDeviceManager.m 18 KB

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