115 lines
3.6 KiB
PHP
115 lines
3.6 KiB
PHP
<?php
|
||
|
||
namespace app\event;
|
||
|
||
use Exception;
|
||
use libs\db\Db;
|
||
use libs\listener\Event;
|
||
|
||
class SetProcessLogEvent extends Event
|
||
{
|
||
|
||
public function handle($data)
|
||
{
|
||
if (count($data) <= 0) {
|
||
throw new Exception('写入process_log新增数据为空，请检查！');
|
||
}
|
||
|
||
$insert_keys = [];
|
||
$insert_vals = [];
|
||
|
||
foreach ($data as $item) {
|
||
// 判断是否已经存在process_log数据
|
||
$sql = sprintf(
|
||
"SELECT id
|
||
FROM hf_mes_bkv_batch_process_log
|
||
WHERE item_id='%s' AND batch='%s' AND subbatch='%s' AND tray='%s' AND lot='%s' AND process_code='%s' LIMIT 1;",
|
||
$item['item_id'],
|
||
$item['batch'],
|
||
$item['subbatch'],
|
||
$item['tray'],
|
||
$item['lot'],
|
||
$item['process_code']
|
||
);
|
||
$ret = Db::fetch($sql);
|
||
if (!empty($ret)) {
|
||
// 去掉不必须update的字段
|
||
$keys = array_diff(array_keys($item), ['item_id', 'batch', 'subbatch', 'finish_time', 'tray', 'lot', 'process_code', 'workingsubclass']);
|
||
$val_str = '';
|
||
foreach ($keys as $k_val) {
|
||
if (is_int($item[$k_val]) || is_float($item[$k_val])) {
|
||
$val_str .= "{$k_val}={$item[$k_val]},";
|
||
} else {
|
||
$val_str .= "{$k_val}='{$item[$k_val]}',";
|
||
}
|
||
}
|
||
$sql = sprintf(
|
||
"UPDATE hf_mes_bkv_batch_process_log SET %s WHERE item_id='%s' AND batch='%s' AND subbatch='%s' AND tray='%s' AND lot='%s' AND process_code='%s';",
|
||
rtrim($val_str, ','),
|
||
$item['item_id'],
|
||
$item['batch'],
|
||
$item['subbatch'],
|
||
$item['tray'],
|
||
$item['lot'],
|
||
$item['process_code']
|
||
);
|
||
$row = Db::query($sql);
|
||
if ($row === NULL) {
|
||
throw new Exception('修改process_log数据失败');
|
||
}
|
||
} else {
|
||
$insert_keys = array_keys($item);
|
||
|
||
$vals = array_values($item);
|
||
foreach ($vals as $k => $v) {
|
||
if (is_int($v) || is_float($v)) {
|
||
$vals[$k] = $v;
|
||
} else {
|
||
$vals[$k] = "'{$v}'";
|
||
}
|
||
}
|
||
array_push($insert_vals, '(' . implode(',', $vals) . ')');
|
||
}
|
||
}
|
||
|
||
if (!empty($insert_vals)) {
|
||
$sql = sprintf(
|
||
"INSERT INTO hf_mes_bkv_batch_process_log %s VALUES %s;",
|
||
"(" . implode(',', $insert_keys) . ")",
|
||
implode(',', $insert_vals)
|
||
);
|
||
$row = Db::query($sql);
|
||
if ($row === NULL) {
|
||
throw new Exception("写入process_log数据失败");
|
||
}
|
||
}
|
||
|
||
return $data;
|
||
}
|
||
|
||
/**
|
||
* 标记最后一条数据的状态
|
||
* @param $data
|
||
*/
|
||
public function updateLastStatus($data)
|
||
{
|
||
if (count($data) <= 0) {
|
||
throw new Exception('电池数据为空，请检查！');
|
||
}
|
||
|
||
foreach ($data as $battery_id) {
|
||
if ($battery_id == '0') {
|
||
continue;
|
||
}
|
||
|
||
$sql = sprintf(
|
||
"UPDATE hf_mes_bkv_batch_process_log SET last_status=0 WHERE item_id='%s' AND (pid != '-1' OR status = 1);",
|
||
$battery_id
|
||
);
|
||
Db::query($sql);
|
||
}
|
||
|
||
return true;
|
||
}
|
||
}
|