392 lines
17 KiB
PHP
392 lines
17 KiB
PHP
<?php
|
||
|
||
namespace app\action;
|
||
|
||
use Exception;
|
||
use libs\db\Db;
|
||
use libs\listener\Event;
|
||
|
||
class SetBatteryProcessResult
|
||
{
|
||
public function execute($post)
|
||
{
|
||
// 验证数据
|
||
$param = check_valid($post['action'], [
|
||
['battery_ids', 'array', '电池条码数据'],
|
||
['workingsubclass', 'string', '工序单元'],
|
||
['device_code', 'string', '设备编码']
|
||
], $post['param']);
|
||
|
||
$date = date('Y-m-d H:i:s');
|
||
$param['DEVICE_CODE'] = [];
|
||
$param['FINISH_TIME'] = [];
|
||
|
||
list($battery_ids, $workingsubclass, $device_code) = [
|
||
$param['battery_ids'],
|
||
$param['workingsubclass'],
|
||
$param['device_code'],
|
||
|
||
];
|
||
|
||
try {
|
||
// 判断上传上来的device_code是否存在
|
||
$sql = sprintf(
|
||
"SELECT device_category_id,code,name
|
||
FROM hf_mes_device
|
||
WHERE code='%s' LIMIT 1;",
|
||
$device_code
|
||
);
|
||
|
||
$ret = Db::fetch($sql);
|
||
if (empty($ret)) {
|
||
throw new Exception("设备编码[{$device_code}]不存在，请检查");
|
||
}
|
||
$device_category_id = $ret['device_category_id'];
|
||
list($first_batch, $check_battery_ids) = ['', array()];
|
||
|
||
foreach ($battery_ids as $key => $battery_id) {
|
||
// 判断电池是否为空
|
||
if (empty($battery_id)) {
|
||
throw new Exception("电池条码数组第[{$key}]位置的电池条码不能是：[0, '0', '', null, NAN]等，请上传电池条码", 4006);
|
||
}
|
||
// 判断如果查询不到battery_map的数据，pid赋予-2，uuid赋予空数组
|
||
$pid = '-2';
|
||
$uuid = json_encode([]);
|
||
|
||
// 判断是否存在battery_map中
|
||
$sql = sprintf(
|
||
"SELECT batch,tray,lot,subbatch,pid,uuid
|
||
FROM hf_mes_production_battery_map
|
||
WHERE battery_id='%s' ORDER BY id DESC LIMIT 1;",
|
||
$battery_id
|
||
);
|
||
$ret = Db::fetch($sql);
|
||
if (empty($ret)) {
|
||
$key += 1;
|
||
throw new Exception("电池数组[battery_ids]第[{$key}]位置的电池[{$battery_id}]数据不存在系统中，请检查");
|
||
}
|
||
$pid = !empty($ret['pid']) ? $ret['pid'] : $pid;
|
||
$uuid = !empty($ret['uuid']) ? $ret['uuid'] : $uuid;
|
||
|
||
list($old_batch, $old_tray, $old_lot, $old_subbatch) = [
|
||
$ret['batch'],
|
||
$ret['tray'],
|
||
$ret['lot'],
|
||
$ret['subbatch']
|
||
];
|
||
if ($key == 0) {
|
||
$first_batch = $old_subbatch;
|
||
}
|
||
|
||
// 确认电池在之前托盘是激活状态
|
||
$sql = sprintf(
|
||
"SELECT next_process_code
|
||
FROM \"%s\"
|
||
WHERE battery_id='%s' AND tray='%s' AND lot='%s' AND active=1 LIMIT 1;",
|
||
'hf_mes_tmp_bkv_' . $old_subbatch,
|
||
$battery_id,
|
||
$old_tray,
|
||
$old_lot
|
||
);
|
||
$ret = Db::fetch($sql);
|
||
if (empty($ret)) {
|
||
$key += 1;
|
||
throw new Exception("电池数组[battery_ids]第[{$key}]位置的电池[{$battery_id}]在原托盘[{$old_tray}]中不是激活状态，请检查");
|
||
}
|
||
$next_process_code = $ret['next_process_code'];
|
||
|
||
// 所有录入的电池的批次必须是一样的
|
||
if ($first_batch != $old_subbatch) {
|
||
$key += 1;
|
||
throw new Exception("电池数组[battery_ids]第[{$key}]位置的电池[{$battery_id}]与第一个电池的批次不一致，请检查");
|
||
}
|
||
|
||
array_push($check_battery_ids, [
|
||
'battery_id' => $battery_id,
|
||
'tray' => $old_tray,
|
||
'lot' => $old_lot,
|
||
'next_process_code' => $next_process_code,
|
||
'pid' => $pid,
|
||
'uuid' => $uuid,
|
||
]);
|
||
}
|
||
|
||
// 判断所有电池的工序是否一致
|
||
$sql = sprintf(
|
||
"SELECT flow_id
|
||
FROM hf_mes_production_planning_management_subbatch
|
||
WHERE subbatch='%s' LIMIT 1;",
|
||
$first_batch
|
||
);
|
||
$ret = Db::fetch($sql);
|
||
|
||
$flow_id = $ret['flow_id'];
|
||
$current_process_code = "{$flow_id}_{$workingsubclass}";
|
||
|
||
// 验证所有电池的当前工序编码是否与当前的工序一致
|
||
foreach ($check_battery_ids as $item) {
|
||
if ($item['next_process_code'] != $current_process_code) {
|
||
throw new Exception("电池[{$item['battery_id']}]当前工序编码[{$item['next_process_code']}]与当前上传数据要求的设备工序编码[{$current_process_code}]不一致，请检查！");
|
||
}
|
||
}
|
||
|
||
// 判断结果参数是否都上传了
|
||
$sql = sprintf(
|
||
"SELECT a.id,b.process
|
||
FROM hf_mes_technology_process AS a
|
||
INNER JOIN hf_mes_technology_flow b ON b.id = a.flow_id
|
||
WHERE a.code='%s' LIMIT 1;",
|
||
$current_process_code
|
||
);
|
||
$ret = Db::fetch($sql);
|
||
|
||
list($flow_process, $process_id) = [
|
||
json_decode($ret['process'], true),
|
||
$ret['id']
|
||
];
|
||
|
||
// 根据电池数组赋予通道数据
|
||
$param['CHANNEL'] = array_map(function ($value) {
|
||
return $value + 1;
|
||
}, array_keys($battery_ids));
|
||
// 赋予设备结果参数数组
|
||
$param['DEVICE_CODE'] = array_pad($param['DEVICE_CODE'], count($battery_ids), $device_code);
|
||
// 赋予完成时间结果参数数组
|
||
$param['FINISH_TIME'] = array_pad($param['FINISH_TIME'], count($battery_ids), $date);
|
||
|
||
// 刷选出需要设备上传的结果参数
|
||
$sql = sprintf(
|
||
"SELECT code,field_type,is_upload
|
||
FROM hf_mes_technology_process_result_param
|
||
WHERE process_id=%s AND is_upload=1;",
|
||
$process_id
|
||
);
|
||
$result_param_need = Db::fetchAll($sql);
|
||
|
||
if (!empty($result_param_need)) {
|
||
$result_param_need_params = array_column($result_param_need, 'code');
|
||
|
||
// 验证提交的结果数据
|
||
// 1、验证是否上传了结果参数
|
||
$diff = array_diff($result_param_need_params, array_keys($param));
|
||
if (!empty($diff)) {
|
||
throw new Exception("结果参数：[{" . implode(',', $diff) . "}]没有上传");
|
||
}
|
||
// 1、验证结果参数是否是数组格式
|
||
// 2、验证结果参数的数组长度是否与电池数量一致
|
||
// 3、验证具体的结果数据有没有上传与数据的类型
|
||
foreach ($result_param_need as $item) {
|
||
// 1、验证结果参数是否是数组格式
|
||
if (!is_array($param[$item['code']])) {
|
||
throw new Exception("上传的结果参数[{$item['code']}] 需要是数组！结果数据均为数组格式，请检查！");
|
||
}
|
||
// 1、验证结果参数的数组长度是否与电池数量一致
|
||
if (count($param[$item['code']]) != count($battery_ids)) {
|
||
$count = count($battery_ids);
|
||
throw new Exception("结果参数[{$item['code']}]的数组长度与电池数量不相等，电池数量为：[{$count}]，请检查");
|
||
}
|
||
|
||
// 结果参数数组
|
||
$p_vals = $param[$item['code']];
|
||
// 结果参数类型
|
||
$p_class = $item['field_type'];
|
||
|
||
// 2、验证具体的结果数据有没有上传与数据的类型
|
||
foreach ($p_vals as $p_key => $p_val) {
|
||
if ($p_class == 'TIMESTAMP') {
|
||
if ($p_val != "" && date('Y-m-d H:i:s', strtotime($p_val)) != $p_val) {
|
||
throw new Exception(sprintf(
|
||
"结果数据[%s]第[%s]位置的数据类型与系统[%s]类型要求不相符，请检查！【要求数据类型格式比如为：'2022-11-11 09:00:00'】",
|
||
$item['code'],
|
||
$p_key + 1,
|
||
$p_class
|
||
));
|
||
}
|
||
} elseif ($p_class == 'FLOAT') {
|
||
if ($p_val != "" && !is_numeric($p_val)) {
|
||
throw new Exception(sprintf(
|
||
"结果数据[%s]第[%s]位置的数据类型与系统[%s]类型要求不相符，请检查！【要求数据类型格式比如为： 12.8】",
|
||
$item['code'],
|
||
$p_key + 1,
|
||
$p_class
|
||
));
|
||
}
|
||
} elseif ($p_class == 'INT') {
|
||
if ($p_val != "" && !is_int($p_val)) {
|
||
throw new Exception(sprintf(
|
||
"结果数据[%s]第[%s]位置的数据类型与系统[%s]类型要求不相符，请检查！【要求数据类型格式比如为： 12】",
|
||
$item['code'],
|
||
$p_key + 1,
|
||
$p_class
|
||
));
|
||
}
|
||
}
|
||
}
|
||
}
|
||
} else {
|
||
$result_param_need = [];
|
||
}
|
||
|
||
// 把完成时间加入到结果参数上传之中
|
||
array_push(
|
||
$result_param_need,
|
||
['code' => 'FINISH_TIME', 'field_type' => 'TIMESTAMP', 'is_upload' => 0],
|
||
['code' => 'DEVICE_CODE', 'field_type' => 'VARCHAR', 'is_upload' => 0]
|
||
);
|
||
|
||
// 判断是否有下一工序
|
||
$current_process_idx = -1;
|
||
$next_next_process_code = '-1';
|
||
$flow_process_column = array_column($flow_process, null, '2');
|
||
if ($flow_process_column[$current_process_code][0] < (count($flow_process) - 1)) {
|
||
$next_next_process_code = $flow_process[$flow_process_column[$current_process_code][0] + 1][2];
|
||
} elseif ($flow_process_column[$current_process_code][0] == (count($flow_process) - 1)) {
|
||
$next_next_process_code = '-1';
|
||
} else {
|
||
$next_next_process_code = '-1';
|
||
}
|
||
$current_process_idx = $flow_process_column[$current_process_code][0];
|
||
|
||
} catch (Exception $e) {
|
||
throw new Exception($e->getMessage());
|
||
}
|
||
|
||
// 开启事务
|
||
Db::beginTrans();
|
||
|
||
try {
|
||
// 标记最后一条数据的状态
|
||
Event::emit('SetProcessLogEvent.updateLastStatus', $battery_ids);
|
||
|
||
// 更新BKV数据
|
||
$common_update_str = sprintf(
|
||
"process_code='%s',process_idx=%s,next_process_code='%s'",
|
||
$current_process_code,
|
||
$current_process_idx,
|
||
$next_next_process_code
|
||
);
|
||
|
||
// 判断如果是最后一个工序，拼接取消激活的状态修改
|
||
if ($next_next_process_code == -1) {
|
||
$common_update_str = $common_update_str . ',active=0';
|
||
}
|
||
|
||
// process_log数据
|
||
$insert_process_log_data = [];
|
||
|
||
foreach ($check_battery_ids as $battery_index => $val) {
|
||
// 过滤0的数据
|
||
if ($val['battery_id'] === '0') {
|
||
continue;
|
||
}
|
||
|
||
$bkv_update_str = '';
|
||
$ng_code = '';
|
||
foreach ($result_param_need as $p_val) {
|
||
// 结果参数
|
||
$p_param = $p_val['code'];
|
||
// 结果参数类型
|
||
$p_class = $p_val['field_type'];
|
||
// 结果参数值
|
||
$p_param_val = trim($param[$p_param][$battery_index]);
|
||
if (in_array($p_class, ['FLOAT', 'INT'])) {
|
||
$bkv_update_str .= "\"{$current_process_code}.{$p_param}\"={$p_param_val},";
|
||
} else {
|
||
$bkv_update_str .= "\"{$current_process_code}.{$p_param}\"='{$p_param_val}',";
|
||
}
|
||
|
||
// 判断NG是否存在
|
||
if ($p_param == 'NG') {
|
||
if ($p_param_val != '') {
|
||
$ng_code = $p_param_val;
|
||
} else {
|
||
$ng_code = 0;
|
||
}
|
||
}
|
||
}
|
||
|
||
if (!empty($bkv_update_str)) {
|
||
$bkv_update_str = $bkv_update_str . $common_update_str;
|
||
} else {
|
||
$bkv_update_str = $common_update_str;
|
||
}
|
||
|
||
$sql = sprintf(
|
||
"UPDATE \"%s\" SET %s WHERE battery_id='%s' AND tray='%s' AND lot='%s'",
|
||
config('app.bkv_prefix') . $first_batch,
|
||
$bkv_update_str,
|
||
$val['battery_id'],
|
||
$val['tray'],
|
||
$val['lot']
|
||
);
|
||
$row = Db::query($sql);
|
||
if ($row === NULL) {
|
||
throw new Exception("PROCESS update failed:[tmp_bkv]");
|
||
}
|
||
$forward_tracing_uuid = [];
|
||
//读取这个电池在process_log表中最新一条记录的forward_tracing_uuid，如果有的话没有的话则赋值uuid
|
||
$sql = "SELECT forward_tracing_uuid
|
||
FROM hf_mes_bkv_batch_process_log
|
||
WHERE item_id = '" . $val['battery_id'] . "'
|
||
ORDER BY id DESC
|
||
LIMIT 1";
|
||
$ret = Db::fetch($sql);
|
||
if (!empty($ret)) {
|
||
$forward_tracing_uuid = $ret['forward_tracing_uuid'];
|
||
}
|
||
// 组装process_log新增数据
|
||
array_push($insert_process_log_data, [
|
||
'item_id' => $val['battery_id'],
|
||
'batch' => $old_batch,
|
||
'subbatch' => $first_batch,
|
||
'tray' => $val['tray'],
|
||
'lot' => $val['lot'],
|
||
'process_code' => $current_process_code,
|
||
'workingsubclass' => $workingsubclass,
|
||
'device_code' => $device_code,
|
||
'device_category_id' => $device_category_id,
|
||
'channel' => $param['CHANNEL'][$battery_index],
|
||
'finish_time' => $param['FINISH_TIME'][$battery_index],
|
||
'input_finish_time' => $param['FINISH_TIME'][$battery_index],
|
||
'status' => -1,
|
||
'pid' => $val['pid'],
|
||
'uuid' => $val['uuid'],
|
||
'last_status' => 1,
|
||
'ng_code' => $ng_code ? $ng_code : 0,
|
||
'class' => $ng_code ? 'NG' : null,
|
||
'forward_tracing_uuid' => $forward_tracing_uuid ?: $val['uuid']
|
||
]);
|
||
}
|
||
|
||
|
||
// 写入process_log的数据(同步)
|
||
Event::emit('SetProcessLogEvent.handle', $insert_process_log_data);
|
||
|
||
// 写入曲线数据(同步)
|
||
Event::emit('CurveDataPathEvent.handle', ["end_time" => isset($param["end_time"]) ? $param["end_time"] : "", "workingsubclass" => $workingsubclass, "data" => $insert_process_log_data]);
|
||
|
||
// 结果参数转发到scada(异步)
|
||
Event::emit('SendProcessResultParamsToScadaEvent.handle', ["workingsubclass" => $workingsubclass, "device_code" => $device_code, "param" => $post['param'], "batch" => $old_batch]);
|
||
|
||
} catch (Exception $e) {
|
||
Db::rollBackTrans();
|
||
throw new Exception($e->getMessage());
|
||
}
|
||
Db::commitTrans();
|
||
$data['process_code'] = $current_process_code;
|
||
$data['class_name'] = get_class($this);
|
||
$data['log_data'] = $insert_process_log_data;
|
||
try {
|
||
// 写入process_log的数据(同步)
|
||
$response = Event::emit('ExtScriptEvent.extScriptEnd', $data);
|
||
if ($response['ext_script_code'] != 0) {
|
||
throw new Exception($response['ext_script_msg']);
|
||
}
|
||
|
||
} catch (Exception $e) {
|
||
throw new Exception($e->getMessage());
|
||
}
|
||
return '';
|
||
}
|
||
}
|