//
//  Socketxxxx.m
//  HeBeiFM
//
//  Created by Apple on 16/9/22.
//  Copyright © 2016年 Apple. All rights reserved.
//

#import "Socket.h"
/**
 用于处理socket接收的数据
 */
#import "DataControl.h"

/**
 socket掉线重连处理
 */
#import "ReconnectControl.h"

@interface Socket ()<GCDAsyncSocketDelegate>
{
    VoidBlock _block;
    NSTimer *_connectTimer; // 计时器,用于心跳连接
    NSInteger _dataTag;
}
@end

@implementation Socket

/**
 单利模式
 */
+(Socket *) sharedInstance
{
    static Socket *sharedInstace = nil;
    static dispatch_once_t onceToken;
    dispatch_once(&onceToken, ^{
        sharedInstace = [[self alloc] init];
    });
    return sharedInstace;
}


// socket连接
-(void)socketConnectHost:(VoidBlock)block
{
    //数据处理类清楚历史数据
    [[DataControl shareControl] clearData];
    //回调方法
    _block = block;
    //连接socket
    self.socket = [[GCDAsyncSocket alloc] initWithDelegate:self delegateQueue:dispatch_get_main_queue()];
    NSError *error = nil;
    [self.socket connectToHost:self.socketHost onPort:self.socketPort withTimeout:3 error:&error];
}

/**
 连接成功
 */
-(void)socket:(GCDAsyncSocket *)sock didConnectToHost:(NSString *)host port:(uint16_t)port
{
    if (_block) {
        _block();
    }
    //读取socket中的数据
    [self readData];
    // 每隔30s像服务器发送心跳包
    _connectTimer = [NSTimer scheduledTimerWithTimeInterval:30 target:self selector:@selector(longConnectToSocket) userInfo:nil repeats:YES];// 在longConnectToSocket方法中进行长连接需要向服务器发送的讯息
    [_connectTimer fire];
}

// 切断socket
-(void)cutOffSocket{
    
    self.socket.userData = SocketOfflineByUser;// 声明是由用户主动切断
    
    self.socket.delegate = nil;
    
    [_connectTimer invalidate];
    
    [self.socket disconnect];
    
    self.socket.userData = SocketOfflineByUser;// 声明是由用户主动切断
    
    [[DataControl shareControl] clearData];
}

//socket掉线,掉线后进行掉线重新连接流程，由SocketReconnectControl类处理
-(void)socketDidDisconnect:(GCDAsyncSocket *)sock withError:(NSError *)err
{
    NSLog(@"服务器断开连接 socket.userData = %@",sock.userData);
    if ([sock.userData isEqualToString:SocketOfflineByUser]) {
        return;
    }else if([sock.userData isEqualToString:SocketOfflineByServer]){
        [self reconnectSocket];
    }
}
-(void)reconnectSocket
{
    [[ReconnectControl shareControl] startReconnectBlock:^{
        [[NSNotificationCenter defaultCenter] postNotificationName:SocketConnectErrorNotification object:nil];
    } success:^{
        [[NSNotificationCenter defaultCenter] postNotificationName:SocketConnectSuccessNotification object:nil];
    }];
}

// 心跳连接
-(void)longConnectToSocket{
    
    // 根据服务器要求发送固定格式的数据，假设为指令@"."，但是一般不会是这么简单的指令
    NSString *longConnect = @".\n";
    //NSData   *dataStream  = [longConnect dataUsingEncoding:NSUTF8StringEncoding];
    
//    byte[] data = new byte[12];
//    data[0] = (byte) 0x9c;
//    data[1] = (byte) 0x00;
//    data[2] = (byte) 0x00;
//    data[3] = (byte) 0x01;
//    data[4] = (byte) 0x00;
//    data[5] = (byte) 0x01;
//    data[6] = (byte) 0xf0;
//    data[7] = (byte) 0xfe;
//    data[8] = (byte) 0x6b;
//    data[9] = (byte) 0x15;
//    data[10] = (byte) 0x6e;
//    data[11] = (byte) 0xb7;
    
    Byte *data = (Byte*)malloc(12);
    data[0] = 0x9c;
    data[1] = 0x00;
    data[2] = 0x00;
    data[3] = 0x01;
    data[4] = 0x00;
    data[5] = 0x01;
    data[6] = 0xf0;
    data[7] = 0xfe;
    data[8] = 0x6b;
    data[9] = 0x15;
    data[10] = 0x6e;
    data[11] = 0xb7;

     NSData *dataStream = [NSData dataWithBytes: data length: 12];
    
    [self writeData:dataStream];
}


/**
 收到服务器的数据，读取数据成功后通过SocketDataControl处理，防止粘包
 */
-(void)socket:(GCDAsyncSocket *)sock didReadData:(NSData *)data withTag:(long)tag
{
    [self readData];
    NSLog(@"读取成功");
    __block NSMutableArray *arr = [NSMutableArray new];
    [[DataControl shareControl] appendingData:data newData:^(NSMutableArray *models)
    {
        [self performSelector:@selector(sendMessage:) withObject:models];
        arr = models;
    }];
}

/**
 读取数据方法
 */
-(void)readData
{
    _dataTag +=1;
    [self.socket readDataWithTimeout:-1 tag:_dataTag];
}
/**
 写入数据方法
 */
-(void)writeData:(NSData*)data
{
    _dataTag += 1;
    [_socket writeData:data withTimeout:-1 tag:_dataTag];
}

-(void)socket:(GCDAsyncSocket *)sock didWriteDataWithTag:(long)tag
{
    NSLog(@"Socket写入成功");
}

/**
 获取网络状态,网络状态由AFN获取，当网路断开时直接通知UI断网
 */
-(void)setNetStatus:(AFNetworkReachabilityStatus)netStatus
{
    _netStatus = netStatus;
    if (netStatus == AFNetworkReachabilityStatusNotReachable) {
        [[NSNotificationCenter defaultCenter] postNotificationName:SocketConnectErrorNotification object:nil];
    }else{
        if ([ReconnectControl shareControl].status == Reconnecting) {
            [[ReconnectControl shareControl] reconnect];
        }
    }
}

-(void)sendMessage:(NSMutableArray*)messages
{
    [[NSNotificationCenter defaultCenter] postNotificationName:SocketNewMessageNotification object:messages];
}

@end