109 lines
3.6 KiB
PHP
109 lines
3.6 KiB
PHP
<?php
|
||
|
||
namespace app\action;
|
||
|
||
use Exception;
|
||
use Throwable;
|
||
use stdClass;
|
||
use libs\db\Db;
|
||
use Workerman\Connection\AsyncTcpConnection;
|
||
|
||
|
||
class SetDeviceProcess
|
||
{
|
||
/*
|
||
{
|
||
"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 execute($post)
|
||
{
|
||
try{
|
||
// 验证数据
|
||
$param = $post['param'];
|
||
|
||
$batch = $param['batch'];
|
||
$data = $param['data'];
|
||
$workingsubclass = $param['workingsubclass'];
|
||
// 判断批次是否存在
|
||
$sql = "SELECT b.subbatch FROM hf_mes_production_planning_management_batch a
|
||
INNER JOIN hf_mes_production_planning_management_subbatch b ON a.id = b.batch_id
|
||
WHERE batch='".$batch."' ORDER BY b.id DESC LIMIT 1";
|
||
$ret = Db::fetch($sql);
|
||
if(empty($ret)){
|
||
throw new Exception("批次[".$batch."]不存在子批次信息,请检查批次是否已创建");
|
||
}
|
||
foreach($data as $key=>$val){
|
||
$device_code = $val["DEVICE_CODE"];
|
||
unset($val["DEVICE_CODE"]);
|
||
foreach($val as $k=>$v){
|
||
$post_data[] = [
|
||
'code' => $k,
|
||
"value" =>$v,
|
||
"parent_device_code"=> $device_code,
|
||
"device_code"=>$device_code,
|
||
"batch"=> $batch
|
||
];
|
||
}
|
||
}
|
||
// 直接拼接转发数据
|
||
$post_action_data = json_encode([
|
||
"action"=>"set_node_data",
|
||
"param"=>[
|
||
"working_subclass"=>$workingsubclass,
|
||
"data"=>$post_data
|
||
]
|
||
]);
|
||
//检查env的转发ip是否已经配置
|
||
if(!envs("SCADA_IP") || !envs("SCADA_IP")){
|
||
echo 'ENV文件配置缺少SetDeviceProcess需要使用的SCADA_IP和SCADA_PORT配置，请先配置！';
|
||
return '';
|
||
}
|
||
$ip = envs("SCADA_IP");
|
||
$port = envs("SCADA_PORT");
|
||
|
||
$ch = curl_init();
|
||
curl_setopt($ch, CURLOPT_URL, $ip.':'.$port);
|
||
curl_setopt($ch, CURLOPT_POST, 1);
|
||
curl_setopt($ch, CURLOPT_HEADER, 1);
|
||
curl_setopt($ch, CURLOPT_HTTPHEADER, array('Content-Type: application/json'));
|
||
curl_setopt($ch, CURLOPT_POSTFIELDS, $post_action_data );
|
||
curl_setopt($ch, CURLOPT_TIMEOUT, 200);
|
||
curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);
|
||
curl_setopt($ch, CURLOPT_HEADER, false);
|
||
$return = curl_exec($ch);
|
||
if (curl_errno($ch)) {
|
||
curl_close($ch);
|
||
throw new Exception('数据请求写入失败！');
|
||
}
|
||
curl_close($ch);
|
||
$resutl = json_decode($return,true);
|
||
if($resutl['errcode'] > 0 ){
|
||
throw new Exception($resutl['errmsg']);
|
||
}
|
||
}catch(Throwable $t){
|
||
//捕获Exception和Throwable的异常，防止命令行报错导致接口无任何返回
|
||
throw new Exception($t->getMessage());
|
||
}
|
||
|
||
}
|
||
}
|