var net = require('net'),
    redis = require('redis'),
    _ = require('lodash'),
    async = require('async'),
    index = require('../src/index.js'),
    readerConfig = require('./readerConfig.js');

var r = redis.createClient();
// 清除redis内存数据库数据
r.keys('*', function(err, keys){
    keys.forEach(function (key, pos)
    {
        r.del(key, function(err, o)
        {
            if (err)
            {
                console.error('没有' + key);
            }
            if (pos === (keys.length - 1))
            {
                console.log('redis内存数据清理成功');
            }
        });
    });
});
r.on('error', function(err)
{
    console.log('Redis连接错误：'+err);
    process.exit(1);
});

/**
 * socket服务创建模块
 */
function main()
{
    // 读取配置文件
    var host = '172.16.13.59',
        port = 12345;


    var xml = '<?xml version="1.0"?>\n<!DOCTYPE cross-domain-policy SYSTEM \n"http://www.adobe.com/xml/dtds/cross-domain-policy.dtd">\n<cross-domain-policy>\n';
    xml += '<site-control permitted-cross-domain-policies="master-only"/>\n';
    xml += '<allow-access-from domain="*" to-ports="*"/>\n';
    xml += '</cross-domain-policy>\n';

    connectAllReaders();

    // 建立socket服务端
    net.createServer(function(conn)
    {
        conn.setEncoding("utf8");
        var remoteIp = conn.remoteAddress;
        console.log('远程主机%s连接成功', remoteIp);

        // 连接web客户端需要发送的数据
        conn.write(xml+'\0');

        var isStart = false;

        conn.on('data', function(data)
        {
            if(data == '<policy-file-request/>\0')
                conn.write(xml+'\0');
            else
            {

                data = data.replace('\0', '');

                var tags = [];
                // 处理传过来的数据
                var params = getCommand(data);
                r.hget(params.groupId, params.state, function(err, epcs)
                {
                    if (err) {
                        console.error(err);
                    } else {
                        try
                        {
                            epcs = JSON.parse(epcs);
                            _.forEach(epcs, function(tagData){
                                if(tagData && getMillTimeDiffNow(tagData.updateTime) < 30000)
                                {
                                    console.log('groupId:%s ------- %s', tagData.group, tagData.EPC);
                                    tags.push(tagData);
                                }
                            });
                        }
                        catch(er)
                        {
                            console.error('标签数据JSON格式错误：'+er);
                        }
                    }

                    // 有离架标签则记录日志
                    if(tags.length)
                    {
                        console.log(tags);
                    }

                    conn.write(output(params.commandType, 100, tags)+"\0");
                });
            }
        });

        conn.on('end', function()
        {
            console.log('远程主机断开');
            conn.end();
        });

    }).listen(port, host, function()
    {
        console.log('Socket创建成功在%s:%d', host, port);
    });
}


/**
 * 连接所有读写器
 */
function connectAllReaders()
{
    var readers = readerConfig.getReaderConfig();
    for(var ip in readers)
    {
        var reader = readers[ip];
        var filter = {
            'on': '1',
            rssi: reader.rssi*10
        };
        var frequencys = [{
            ant: 0,
            freq: 10
        },{
            ant: 1,
            freq: 10
        },{
            ant: 2,
            freq: 10
        },{
            ant: 3,
            freq: 10
        }];

        // 初次连接最多连接5次
        async.retry(5, function(cb, results){
            connectReader(ip, 9761, filter, frequencys, reader.inventory_time, reader.ants, reader.group, cb);

        }, function(err, results){
            if(err){
                console.error(err);
            }
        });
    }
}

/**
 * 连接并获取读写器的数据，然后传递到客户端
 *
 * @param host 读写器的的IP
 * @param port 读写器的的端口
 * @param filter 读写器的RSSI过滤有关数据
 * @param frequencys 读写器的定频有关数据
 * @param inventoryTime 盘点时间
 * @param power 各天线的功率
 * @param group 读写器所在组
 * @param callback 回调函数
 */
function connectReader(host, port, filter, frequencys, inventoryTime, power, group, callback)
{
    index.start({
        host: host,
        port: port,
        filter: filter,
        frequencys: frequencys,
        inventoryTime: inventoryTime,
        power: power,
        group: group
    }, function (connected, dat) {
        var onEpcs = [],
            offEpcs = [],
            redisEpcs = [];

        // 获取redis中指定组在架标签数据
        r.hget(group, 'on', function(err, epcs)
        {
            if (err)
            {
                console.error(err);
            }
            else
            {
                try
                {
                    redisEpcs = JSON.parse(epcs);
                }
                catch(er)
                {
                    console.error('标签数据JSON格式错误：'+er);
                }
            }
        });

        _.forEach(dat, function(item){

            if(item.state == 'on' && !_.findWhere(redisEpcs, {EPC: item.epc}))
            {
                onEpcs.push({
                    EPC: item.epc,
                    GroupID: group,
                    updateTime: item.updateTime
                });
            }

            if(item.state == 'off' && item.speed > 1 && !_.findWhere(redisEpcs, {EPC: item.epc}))
            {
                offEpcs.push({
                    EPC: item.epc,
                    GroupID: group,
                    updateTime: item.updateTime
                });
            }
        });

        r.hset(group, 'on', JSON.stringify(onEpcs.concat(redisEpcs)), function(){});
        r.hset(group, 'off', JSON.stringify(offEpcs), function(){});

        if(connected){
            callback(null, connected);
        }else{
            callback(new Error('连接读写器'+host+'错误'), connected);
        }

    });
}

/**
 * 获取指定时间和当前时间的差异
 * @param val 指定的时间
 * @returns int 时间差（单位：毫秒）
 */
function getMillTimeDiffNow(val)
{
    var end = new Date();
    return end.getTime() - val;
}

/**
 * 读取命令结果
 * @param data 传入的数据
 * @returns 解析出来的数据对象
 */
function getCommand(data)
{
    try
    {
        data = JSON.parse(data);
    }
    catch(er)
    {
        console.log('JSON格式错误：'+er);
    }
    var params = {};

    if(data.Key != 12345)
    {
        params.commandType = 'error';
        return params;
    }

    params.commandType = data.CommandType;
    if('GroupID' in data)
    {
        params.groupId = data.GroupID;
    }

    if('State' in data)
    {
        var state = data.State;
        if(state == 'ShelfOn')
        {
            state = 'on'
        }
        else if(state == 'ShelfOff')
        {
            state = 'off'
        }
        else
        {
            state = 'off'
        }
        params.state = state
    }

    return params;
}

/**
 * 格式化输出内容
 * @param commandType 命令类型
 * @param code 状态码
 * @param data 数据
 * @returns string
 */
function output (commandType, code, data)
{
    var res = {
        CommandType: commandType,
        Code: code,
        Data: data
    };

    return JSON.stringify(res);
}

main();