<?php
/**
 * Created by PhpStorm.
 * User: Joinsen
 * Date: 2017/9/9
 * Time: 1:09
 */

use Workerman\Worker;
use Workerman\Lib\Timer;
use Workerman\Connection\AsyncTcpConnection;
require_once __DIR__ . '/../Workerman/Autoloader.php';
require_once __DIR__ . '/../auto_loader.php';

//http只能本机访问
$worker = new Worker('Http://0.0.0.0:88');

$worker->name='TackPre'; //前置

$worker->count=4;
$worker->onWorkerStart = function ($worker){
//    if ($worker->id===0) {
//        global $task_connection;
//        $task_connection = new AsyncTcpConnection('Text://127.0.0.1:8731');
//        $task_data=array(
//            'type'=>'record_redis_data',
//        );
//        $time_interval = 5*60; //5分钟执行一次
//        Timer::add($time_interval,function ()use($task_connection,$task_data){
//            $json = json_encode($task_data,JSON_UNESCAPED_UNICODE);
//            $task_connection->send($json);
//            lg('redis_log',"请求服务端:".$json);
//            $task_connection->onMessage = function($task_connection, $task_result)
//            {
//                // 结果
//                var_dump($task_result);
////                if($task_result){
////                    // 获得结果后记得关闭异步链接
//////                    $task_connection->close();
////                }
//            };
//            //执行异步链接
//            $task_connection->connect();
//        });
//    }
};

$worker->onMessage = function($ws_connection, $message)
{
    $input_data = $GLOBALS['HTTP_RAW_POST_DATA'];
    dump($input_data);
    $task_data = json_decode($input_data,1);
    // 与远程task服务建立异步链接，ip为远程task服务的ip，如果是本机就是127.0.0.1，如果是集群就是lvs的ip
    $task_connection = new AsyncTcpConnection('Text://127.0.0.1:8731');
    $task_connection->send($input_data);
    $task_connection->onMessage = function($task_connection, $task_result)
    {
        // 结果
        var_dump($task_result);
//                if($task_result){
//                    // 获得结果后记得关闭异步链接
////                    $task_connection->close();
//                }
    };
    //执行异步链接
    $task_connection->connect();
//
//    var_dump($message);
//    $task_data = $message;
//    $data  = $_GET;
//    var_dump($data);

    // 任务及参数数据
//    $doname = $_GET['doname'];
//    $s = $_GET['s'];
//    if($s==1){
//        $type = 'https';
//    }else{
//        $type = 'http';
//    }
//    var_dump($task_data);
//    $task_data = array(
//        'function' => 'send_mail',
//        'args'       => array('from'=>'xxx', 'to'=>'xxx', 'contents'=>'xxx'),
//    );
    // 与远程task服务建立异步链接，ip为远程task服务的ip，如果是本机就是127.0.0.1，如果是集群就是lvs的ip
//    $task_connection = new AsyncTcpConnection('Text://127.0.0.1:8731');
//
////    $url_arr=array(
////        'https://www.kirin88.com/index.php?m=api&c=initCache&a=index&pass=un123456&action=all&param=all',
//////            'http://www.chat.top/index.php?m=api&c=initCache&a=index&pass=un123456&action=all&param=all',
////        'http://www.chat.top/index.php?m=api&c=initCache&a=index&pass=un123456&action=all&param=all',
////    );
//    $task_fdb_data=array(
//        'type'=>'flush_db',
//        'limit'=>'all',
//        'url'=>$type.'://'.$doname.'/index.php?m=api&c=initCache&a=index&pass=un123456&action=all&param=all',
//    );
//    $json = json_encode($task_fdb_data,JSON_UNESCAPED_UNICODE);
//    lg('flush_db',"请求服务端:".$json);
//    $task_connection->send($json);
//    $task_connection->onMessage = function($task_connection, $task_result)
//    {
//        // 结果
//        var_dump($task_result);
////                if($task_result){
////                    // 获得结果后记得关闭异步链接
//////                    $task_connection->close();
////                }
//    };
//    //执行异步链接
//    $task_connection->connect();
//    foreach ($url_arr as $v){
//        $task_fdb_data['url']=$v;
//        $json = json_encode($task_fdb_data,JSON_UNESCAPED_UNICODE);
//        lg('flush_db',"请求服务端:".$json);
//        $task_connection->send($json);
//        $task_connection->onMessage = function($task_connection, $task_result)
//        {
//            // 结果
//            var_dump($task_result);
////                if($task_result){
////                    // 获得结果后记得关闭异步链接
//////                    $task_connection->close();
////                }
//        };
//        //执行异步链接
//        $task_connection->connect();
//    }
//
//    // 发送数据
//    $task_connection->send(json_encode($task_data));
//    // 异步获得结果
//    $task_connection->onMessage = function($task_connection, $task_result)use($ws_connection)
//    {
//        // 结果
//        var_dump($task_result);
//        // 获得结果后记得关闭异步链接
//        $task_connection->close();
//        // 通知对应的websocket客户端任务完成
//        $ws_connection->send('task complete');
//    };
//    // 执行异步链接
//    $task_connection->connect();
};

Worker::runAll();