//
//  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"
#import "NSString+HexToBytes.h"
//#import "DeviceModel.h"

@interface Socket ()<GCDAsyncSocketDelegate>
{
    VoidBlock _block;
    NSTimer *_connectTimer; // 计时器,用于心跳连接
    NSInteger _dataTag;
    //DeviceModel * currentModel;
}
@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];
    
    //currentModel = [[DeviceModel alloc] init];
    
    // 每隔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;
    // mac 地址
    
    //NSData* bytes = [_selectedDevice.mac hexToBytes];
    //Byte * myByte = (Byte *)[bytes bytes];
    //NSLog(@"myByte = %s",myByte);
    //memcpy(data+6, [bytes bytes], [bytes length]);
    
//    NSUInteger len = [_currentData length];
//    Byte *byteData = (Byte*)malloc(len);
//    memcpy(byteData, [_currentData bytes], len);
//    data[6] = 0xf0;
//    data[7] = 0xfe;
//    data[8] = 0x6b;
//    data[9] = 0x15;
//    data[10] = 0x6e;
//    data[11] = 0xb7;

//    for( NSUInteger i = 0; i < 12; i++ )
//    {
//        NSLog(@"第%ld个数字:%x",i,data[i]);
//    }
    
    
    NSData *dataStream = [NSData dataWithBytes: data length: 12];
    
    [self writeData:dataStream];
    
    free(data);
    data = nil;
}


/**
 收到服务器的数据，读取数据成功后通过SocketDataControl处理，防止粘包
 */
-(void)socket:(GCDAsyncSocket *)sock didReadData:(NSData *)data withTag:(long)tag
{
    [self readData];
    NSLog(@"读取成功");
    //__block DeviceModel *arr = [DeviceModel new];
    
    NSUInteger len = [data length];
    Byte *byteData = (Byte*)malloc(len);
    memcpy(byteData, [data bytes], len);
    
    //currentModel.x6 = [NSString stringWithFormat:@"%d",byteData[22]];
   // currentModel.x7 = [NSString stringWithFormat:@"%d",byteData[23]];
   // currentModel.x8 = [NSString stringWithFormat:@"%d",byteData[24]];
  //  currentModel.x5 = [NSString stringWithFormat:@"%d",byteData[21]];
  //  currentModel.x1 = [NSString stringWithFormat:@"%d",byteData[14]*256+byteData[15]];
    
  //  currentModel.x9 = [NSString stringWithFormat:@"%d",byteData[25]];
  //  currentModel.x10 = [NSString stringWithFormat:@"%d",byteData[26]];
  //  currentModel.x11 = [NSString stringWithFormat:@"%d",byteData[27]];
  //  currentModel.x12 = [NSString stringWithFormat:@"%d",byteData[28]];
  //  currentModel.x13 = [NSString stringWithFormat:@"%d",byteData[29]];

    //[self performSelector:@selector(sendMessage:) withObject:currentModel];
    
    free(byteData);
    byteData = nil;
//    [[DataControl shareControl] appendingData:data newData:^(DeviceModel *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:(DeviceModel*)messages
//{
//    [[NSNotificationCenter defaultCenter] postNotificationName:SocketNewMessageNotification object:messages];
//}

@end