<?php
namespace cn\gz53\framework\service\server;
use cn\gz53\framework\dao\env\EnvCacheDao;
use cn\gz53\framework\service\Service;
use cn\gz53\framework\dao\runner\RunnerDao;
use cn\gz53\framework\dao\process\ProcessPoolWorkerConfigDao;
use cn\gz53\framework\dao\process\ProcessPoolWorkerDao;
use cn\gz53\framework\model\bo\process\ProcessPoolWorkerRunnerSetBo;
use cn\gz53\framework\model\bo\process\ProcessPoolWorkerConfigSetBo;
use cn\gz53\framework\model\bo\process\ProcessPoolWorkerConfigLoadBo;
class ProcessPoolWorkerService extends Service
{
public function loadConfig(){
$bo = ProcessPoolWorkerConfigLoadBo::getInstance($this->_context);
$envCacheDao = EnvCacheDao::getInstance($this->_context);
$processPoolWorkerConfigDao = ProcessPoolWorkerConfigDao::getInstance($this->_context);
if(!$envCacheDao->getAbsoluteMainDeployPath($bo)){
return false;
}
if(!$processPoolWorkerConfigDao->loadFromFile($bo)){
return false;
}
if(!$processPoolWorkerConfigDao->storeToCache($bo)){
return false;
}
return true;
}
public function setConfig(){
$bo = ProcessPoolWorkerConfigSetBo::getInstance($this->_context);
$processPoolWorkerConfigDao = ProcessPoolWorkerConfigDao::getInstance($this->_context);
$processPoolWorkerDao = ProcessPoolWorkerDao::getInstance($this->_context);
if(!$processPoolWorkerConfigDao->getFromCache($bo)){
return false;
}
if(!$processPoolWorkerDao->setConfig($bo)){
return false;
}
return true;
}
public function setRunner(){
$bo = ProcessPoolWorkerRunnerSetBo::getInstance($this->_context);
$runnerRunDao = RunnerDao::getInstance($this->_context);
$processWorkerDao = ProcessPoolWorkerDao::getInstance($this->_context);
if(!$runnerRunDao->getInitCallback($bo)){
return false;
}
if(!$runnerRunDao->getRunCallback($bo)){
return false;
}
if(!$processWorkerDao->setInitCallback($bo)){
return false;
}
return true;
}
}