fanjc/tcpserver-flow
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

ai-refactor(flow): 调整抽象流程节点实现和依赖路径

Browse Source 
- 修改 AbstractProcessNode 中 ProcessContext 的命名空间引用为 app\flow\context\ProcessContext
- 引入 app\flow\vo\CanHandleResult 用于节点处理结果表示
- 更新前置策略执行后对成功状态的判断，改为调用 isSuccess() 方法
- 增加日志记录细节，便于调试策略执行中断时的错误信息
- 优化代码注释，提升代码可读性和维护性
This commit is contained in:
zimoyin
2026-03-11 00:48:10 +08:00
parent d303f3501f
commit e040fccba6
45 changed files with 819 additions and 2718 deletions
Download Patch File Download Diff File Expand all files Collapse all files
app/repository/EctActionsRepository.php
+27 -27
View File
@@ -2,8 +2,8 @@
namespace app\repository;
use app\flow\ProcessContext;
use app\flow\DbOperationType;
use app\flow\context\ProcessContext;
use app\flow\enum\DbOperationType;
use app\model\EctActions;
use app\utils\Logger;
@@ -228,41 +228,41 @@ class EctActionsRepository extends BaseRepository
{
$op_endtime = null;
$process_order = 1;
if ($context->currentStep === '结束') {
if ($context->getCurrentStep() === '结束') {
$op_endtime = date('Y-m-d H:i:s');
}
if (!empty($context->previousAction)) {
$process_order = (int)($context->previousAction->process_order ?? 1);
if (!empty($context->getPreviousAction())) {
$process_order = (int)($context->getPreviousAction()->process_order ?? 1);
}
if (in_array(DbOperationType::INSERT, $context->dbOperation)) {
if (in_array(DbOperationType::INSERT, $context->getDbOperations())) {
return $this->insert([
'op_batchno' => $context->batchNo,
'action_type' => $this->mapActionType($context->processType),
'action_type_name' => $context->processType,
'process_name' => $context->currentStep,
'op_batchno' => $context->getBatchNo(),
'action_type' => $this->mapActionType($context->getProcessType()),
'action_type_name' => $context->getProcessType(),
'process_name' => $context->getCurrentStep(),
'process_order' => $process_order + 1,
'op_morning' => $context->needMorningWash ? 1 : 0,
'op_enhance' => $context->needEnhanceWash ? 1 : 0,
'reader_id' => (int)$context->readerId ?: null,
'reader_no' => $context->readerNo ?: null,
'op_morning' => $context->getMorningWash()->needMorningWash ? 1 : 0,
'op_enhance' => $context->needEnhanceWash() ? 1 : 0,
'reader_id' => (int)$context->getReader()->id ?: null,
'reader_no' => $context->getReader()->no ?: null,
'opuser_type' => $opuserType,
'opuser_id' => (int)$context->operatorId ?: null,
'opuser_rfid' => $context->operatorRfid ?: null,
'opuser_name' => $context->operatorName ?: null,
'endoscope_id' => (int)$context->endoscopeId ?: null,
'endoscope_rfid' => $context->cardNo ?: null,
'endoscope_name' => $context->endoscopeName ?: null,
'op_starttime' => $context->actionStartTime ?: date('Y-m-d H:i:s'),
'opuser_id' => (int)$context->getOperator()->id ?: null,
'opuser_rfid' => $context->getOperator()->rfid ?: null,
'opuser_name' => $context->getOperator()->name ?: null,
'endoscope_id' => (int)$context->getEndoscope()->id ?: null,
'endoscope_rfid' => $context->getEndoscope()->cardNo ?: null,
'endoscope_name' => $context->getEndoscope()->name ?: null,
'op_starttime' => $context->getActionStartTime() ?: date('Y-m-d H:i:s'),
'op_endtime' => $op_endtime,
'op_duration' => $context->duration ?: null,
'op_duration' => $context->getDuration() ?: null,
'created_at' => date('Y-m-d H:i:s'),
]);
} elseif (in_array(DbOperationType::UPDATE, $context->dbOperation)) {
EctActions::where('op_batchno', $context->batchNo)
->where('endoscope_id', $context->endoscopeId)
} elseif (in_array(DbOperationType::UPDATE, $context->getDbOperations())) {
EctActions::where('op_batchno', $context->getBatchNo())
->where('endoscope_id', $context->getEndoscope()->id)
->update([
'action_type' => $this->mapActionType($context->processType),
'action_type_name' => $context->processType,
'action_type' => $this->mapActionType($context->getProcessType()),
'action_type_name' => $context->getProcessType(),
]);
}
return null;