|
|
|
|
@@ -94,7 +94,7 @@ $worker -> onMessage = function(TcpConnection $connection, Request $request) {
|
|
|
|
|
// 执行异步连接
|
|
|
|
|
$task_connection->connect();
|
|
|
|
|
} else {
|
|
|
|
|
$enode_configure = new ENodeConfigure($dbconn, post: $post);
|
|
|
|
|
$enode_configure = new ENodeConfigure($dbconn, no_dup_code: $options['no_dup_code'] ?? true, post: $post);
|
|
|
|
|
$res = $enode_configure -> $action();
|
|
|
|
|
|
|
|
|
|
if ($res === true)
|
|
|
|
|
@@ -110,7 +110,7 @@ $worker -> onMessage = function(TcpConnection $connection, Request $request) {
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
} else if ($post -> action === 'set_node_data') {
|
|
|
|
|
$data_capture = new EDataCapture($dbconn, post: $post, no_dup_code: $options['no_dup_code'] ?? true);
|
|
|
|
|
$data_capture = new EDataCapture($dbconn, no_dup_code: $options['no_dup_code'] ?? true, post: $post);
|
|
|
|
|
if ($data_capture -> check_res === 'WRONG_WORKING_SUBCLASS') {
|
|
|
|
|
$response = new Response(200, [
|
|
|
|
|
'Content-Type' => 'application/json;charset=utf-8',
|
|
|
|
|
@@ -171,7 +171,7 @@ $worker -> onMessage = function(TcpConnection $connection, Request $request) {
|
|
|
|
|
$get = $request -> get();
|
|
|
|
|
if (isset($get['query'])) {
|
|
|
|
|
if ($get['query'] == 'nodes') {
|
|
|
|
|
$enode_configure = new ENodeConfigure($dbconn, get: $get);
|
|
|
|
|
$enode_configure = new ENodeConfigure($dbconn, no_dup_code: $options['no_dup_code'] ?? true, get: $get);
|
|
|
|
|
$nodes = $enode_configure -> get_nodes();
|
|
|
|
|
if (is_null($nodes))
|
|
|
|
|
$connection -> send(json_encode(array(
|
|
|
|
|
@@ -184,7 +184,7 @@ $worker -> onMessage = function(TcpConnection $connection, Request $request) {
|
|
|
|
|
'data' => $nodes
|
|
|
|
|
)));
|
|
|
|
|
} else if ($get['query'] == 'working_subclasses') {
|
|
|
|
|
$enode_configure = new ENodeConfigure($dbconn, get: $get);
|
|
|
|
|
$enode_configure = new ENodeConfigure($dbconn, no_dup_code: $options['no_dup_code'] ?? true, get: $get);
|
|
|
|
|
$working_subclasses = $enode_configure -> get_working_subclasses($dbconn);
|
|
|
|
|
if (is_null($working_subclasses))
|
|
|
|
|
$connection -> send(json_encode(array(
|
|
|
|
|
@@ -197,7 +197,7 @@ $worker -> onMessage = function(TcpConnection $connection, Request $request) {
|
|
|
|
|
'data' => $working_subclasses
|
|
|
|
|
)));
|
|
|
|
|
} else if ($get['query'] == 'codes') {
|
|
|
|
|
$enode_configure = new ENodeConfigure($dbconn, get: $get);
|
|
|
|
|
$enode_configure = new ENodeConfigure($dbconn, no_dup_code: $options['no_dup_code'] ?? true, get: $get);
|
|
|
|
|
$codes = $enode_configure -> get_codes_by_working_subclasses();
|
|
|
|
|
if (is_null($codes))
|
|
|
|
|
$connection -> send(json_encode(array(
|
|
|
|
|
@@ -210,7 +210,7 @@ $worker -> onMessage = function(TcpConnection $connection, Request $request) {
|
|
|
|
|
'data' => $codes
|
|
|
|
|
)));
|
|
|
|
|
} else if ($get['query'] == 'node_data') {
|
|
|
|
|
$data_capture = new EDataCapture($dbconn, get: $get);
|
|
|
|
|
$data_capture = new EDataCapture($dbconn, no_dup_code: $options['no_dup_code'] ?? true, get: $get);
|
|
|
|
|
$data = $data_capture -> get_node_data();
|
|
|
|
|
if (is_null($data))
|
|
|
|
|
$connection -> send(json_encode(array(
|
|
|
|
|
@@ -254,7 +254,7 @@ $consumer -> onMessage = function(TcpConnection $connection, $task_data) {
|
|
|
|
|
$task_data = json_decode($task_data);
|
|
|
|
|
|
|
|
|
|
if ($task_data -> action === 'add_node') {
|
|
|
|
|
$enode_configure = new ENodeConfigure($consumer_dbconn, post: $task_data -> data, no_dup_code: $options['no_dup_code'] ?? true);
|
|
|
|
|
$enode_configure = new ENodeConfigure($consumer_dbconn, no_dup_code: $options['no_dup_code'] ?? true, post: $task_data -> data);
|
|
|
|
|
$res = $enode_configure -> add_node();
|
|
|
|
|
|
|
|
|
|
if ($res === true)
|
|
|
|
|
|