代码拉取完成,页面将自动刷新
将服务/闭包组合为工作流
composer require jesusslim/cain
Class Test{
protected $sid;
public function __construct($sid)
{
$this->sid = $sid;
}
public function getNickname(){
return 'foo'.$this->sid;
}
public function getInfo(){
$id = $this->sid;
$nickname = $this->getNickname();
return compact('id','nickname');
}
}
/*********************************************/
/* 工作流定义,[类名,方法名] 或 闭包 */
$flows = [
'test_info' => [Test::class,'getInfo'],
'test_closure' => function($foo){
return ++$foo;
}
];
/*********************************************/
/* result_injs 会将工作流任意一步的结果中的某字段(或整个结果)注入到容器中,便于后续的工作流使用它们 */
/* 键名为结果集中的键名,值为注入到容器中的命名 */
$result_injs = [
'test_info' => [
'id' => 'foo', //means container.foo = result.id
// \Cain\Flow::PARAMS_NAME_SELF => 'whole'
]
];
/*********************************************/
/* result_checkers 会检查工作流每一步的结果,接收一个闭包function($result){}.*/
/* 检查ok则返回true 工作流会继续往下执行.*/
/* 如果不返回true 工作流会停止,使用 isFinished/isError 来获取当前状态,使用getError获取闭包中返回的错误信息. */
$result_checkers = [
'test_closure' => function($result){
if ($result != 100) return 'bar';
return true;
}
];
$fl = new \Cain\Flow($flows,$result_checkers,$result_injs);
var_dump($fl->run(['sid' => 12345]));
var_dump($fl->isFinished());
var_dump($fl->isError());
var_dump($fl->getError());
/*********************************************/
/* 使用flush方法清除状态和错误 */
$fl->flush();
/*********************************************/
/* 使用InjectorInterface获取注入容器本身 */
$fl->flow('test_get_container',function(\Inject\InjectorInterface $injector){
return $injector->produce('nick');
});
var_dump($fl->run(['sid' => 99]));
带路由的工作流
/*********************************************/
/* 工作流定义,[类名,方法名] 或 闭包 */
$flows = [
'test_info' => [Test::class,'getInfo'],
'test_closure' => function($foo){
return ++$foo;
},
'math_foo' => function($foo,$bar = 100){
return $foo * $bar;
},
'math_bar' => function($foo,$bar = 100){
return $foo / $bar;
},
];
/*********************************************/
/* 路由 逻辑 */
/* 键名为 from的工作流key */
/* 值为 to的工作流key 或 闭包 返回下一个工作流步骤的key */
$routes = [
'test_info' => 'test_closure',
'test_closure' => function($foo){
return $foo % 2 == 1 ? 'math_foo' : 'math_bar';
}
];
/*********************************************/
/* checkers & injs , 与basic flow中一致 */
$result_checkers = [
'test_closure' => function($result){
//if ($result != 100) return 'bar';
var_dump("result is $result");
return true;
}
];
$result_injs = [
'test_info' => [
'id' => 'foo',
'nickname' => 'nick',
// \Cain\Flow::PARAMS_NAME_SELF => 'whole'
]
];
/*********************************************/
/* RouterFlow 继承于 Flow,需要定义 routes(路由逻辑) & root_key(初始工作流步骤的key,即声明第一步) */
/* 当checkers检查导致工作流停止 或者 找不到下一步时 RouterFlow会返回当前的结果 */
$fl = new \Cain\RouterFlow($flows,$result_checkers,$result_injs,null,$routes,'test_info');
var_dump($fl->run(['sid' => 99]));
$fl->flush();
var_dump($fl->run(['sid' => 100]));
此处可能存在不合适展示的内容,页面不予展示。您可通过相关编辑功能自查并修改。
如您确认内容无涉及 不当用语 / 纯广告导流 / 暴力 / 低俗色情 / 侵权 / 盗版 / 虚假 / 无价值内容或违法国家有关法律法规的内容,可点击提交进行申诉,我们将尽快为您处理。