120 lines
4.7 KiB
PHP
120 lines
4.7 KiB
PHP
|
<?php
|
|||
|
|
|
|||
|
|
namespace app\event;
|
|||
|
|
|
|||
|
|
use Exception;
|
|||
|
|
use Throwable;
|
|||
|
|
use libs\db\Db;
|
|||
|
|
use libs\listener\Event;
|
|||
|
|
use \Workerman\Connection\AsyncTcpConnection;
|
|||
|
|
|
|||
|
|
class SendProcessResultParamsToScadaEvent extends Event
|
|||
|
|
{
|
|||
|
|
|
|||
|
|
/*
|
|||
|
|
{
|
|||
|
|
"action": "set_node_data",
|
|||
|
|
"param": {
|
|||
|
|
"working_subclass":"ROUGHING",
|
|||
|
|
"data": [
|
|||
|
|
{
|
|||
|
|
"code": "temperature",
|
|||
|
|
"value": 1250.4,
|
|||
|
|
"device_code": "",
|
|||
|
|
"batch": ""
|
|||
|
|
},
|
|||
|
|
{
|
|||
|
|
"code": "width",
|
|||
|
|
"value": 29.45,
|
|||
|
|
"device_code": "",
|
|||
|
|
"batch": ""
|
|||
|
|
}
|
|||
|
|
]
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
*/
|
|||
|
|
public function handle($data)
|
|||
|
|
{
|
|||
|
|
//检查env的转发ip是否已经配置
|
|||
|
|
if(!envs("SCADA_IP") || !envs("SCADA_IP")){
|
|||
|
|
echo 'ENV文件配置缺少SendProcessResultParamsToScadaEvent需要使用的SCADA_IP和SCADA_PORT配置，请先配置！';
|
|||
|
|
return $data;
|
|||
|
|
}
|
|||
|
|
try{
|
|||
|
|
|
|||
|
|
list($workingsubclass,$params,$device_code,$batch) = [$data['workingsubclass'], $data['param'], $data['device_code'], $data['batch']];
|
|||
|
|
//先查绑定表获取所有工序的绑定数据
|
|||
|
|
$sql = "SELECT result_param_code,scada_node_code,scada_node_type FROM hf_mes_result_param_binding_scada_node WHERE working_subclass='".$workingsubclass."'";
|
|||
|
|
$ret = Db::fetchAll($sql);
|
|||
|
|
if(empty($ret)){
|
|||
|
|
return $data;
|
|||
|
|
}
|
|||
|
|
//获取上传的所有结果参数取交集
|
|||
|
|
$result_param_code = array_column($ret,null,'result_param_code');
|
|||
|
|
$send_result_param_code = array_intersect_key($result_param_code, $params);
|
|||
|
|
var_dump($params,$send_result_param_code);
|
|||
|
|
//拼接发送SCADA接口的数据
|
|||
|
|
$post_data = [];
|
|||
|
|
foreach($send_result_param_code as $key=>$val){
|
|||
|
|
if(is_array($params[array_keys($send_result_param_code)[0]]) ){
|
|||
|
|
foreach($params[$val['result_param_code']] as $k => $v){
|
|||
|
|
// 如果上传了时间，以上传时间为准
|
|||
|
|
$collect_time_arr = [];
|
|||
|
|
if(isset($params["FINISH_TIME"]) && !empty($params["FINISH_TIME"][$k])){
|
|||
|
|
$collect_time_arr["collect_time"] = $params["FINISH_TIME"][$k];
|
|||
|
|
}
|
|||
|
|
$post_data[] = array_merge([
|
|||
|
|
'code' => $val['scada_node_code'],
|
|||
|
|
"value" =>$v,
|
|||
|
|
"parent_device_code"=> $device_code,
|
|||
|
|
"device_code"=>$device_code,
|
|||
|
|
"batch"=> $batch
|
|||
|
|
],$collect_time_arr);
|
|||
|
|
}
|
|||
|
|
}else{
|
|||
|
|
// 如果上传了时间，以上传时间为准
|
|||
|
|
$collect_time_arr = [];
|
|||
|
|
if(isset($params["FINISH_TIME"]) && !empty($params["FINISH_TIME"])){
|
|||
|
|
$collect_time_arr["collect_time"] = $params["FINISH_TIME"];
|
|||
|
|
}
|
|||
|
|
$post_data[] = array_merge([
|
|||
|
|
'code' => $val['scada_node_code'],
|
|||
|
|
"value" => $params[$val['result_param_code']],
|
|||
|
|
"parent_device_code"=> $device_code,
|
|||
|
|
"device_code"=>$device_code,
|
|||
|
|
"batch"=> $batch
|
|||
|
|
|
|||
|
|
],$collect_time_arr);
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
$post_action_data = json_encode([
|
|||
|
|
"action"=>"set_node_data",
|
|||
|
|
"param"=>[
|
|||
|
|
"working_subclass"=>$workingsubclass,
|
|||
|
|
"data"=>$post_data
|
|||
|
|
]
|
|||
|
|
]);
|
|||
|
|
$ip = envs("SCADA_IP");
|
|||
|
|
$port = envs("SCADA_PORT");
|
|||
|
|
//发送异步http post 请求
|
|||
|
|
$connection = new AsyncTcpConnection("tcp://{$ip}:{$port}");
|
|||
|
|
$headers = "POST / HTTP/1.1\r\n";
|
|||
|
|
$headers .= "Host: {$ip}\r\n";
|
|||
|
|
$headers .= "Content-Type: application/json\r\n";
|
|||
|
|
$headers .= "Connection: close\r\n";
|
|||
|
|
$headers .= "Content-Length: " . strlen($post_action_data) . "\r\n\r\n";
|
|||
|
|
$connection->send($headers.$post_action_data);
|
|||
|
|
$connection -> onMessage = function(AsyncTcpConnection $connection, $task_result){
|
|||
|
|
$connection -> close();
|
|||
|
|
};
|
|||
|
|
// 执行异步连接
|
|||
|
|
$connection->connect();
|
|||
|
|
}catch(Throwable $t){
|
|||
|
|
//捕获Exception和Throwable的异常，防止命令行报错导致接口无任何返回
|
|||
|
|
return $data;
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
return $data;
|
|||
|
|
}
|
|||
|
|
}
|