* @package product * @version $Id: $ * @link http://www.zentao.net */ class pipelineModel extends model { /** * Get a pipeline by id. * * @param int $id * @access public * @return object */ public function getByID($id) { $pipeline = $this->dao->select('*')->from(TABLE_PIPELINE)->where('id')->eq($id)->fetch(); if($pipeline) { $pipeline->password = base64_decode($pipeline->password); } return $pipeline; } /** * Get pipeline list. * * @param string $type jenkins|gitlab * @param string $orderBy * @param object $pager * @access public * @return array */ public function getList($type = 'jenkins', $orderBy = 'id_desc', $pager = null) { return $this->dao->select('*')->from(TABLE_PIPELINE) ->where('deleted')->eq('0') ->AndWhere('type')->in($type) ->orderBy($orderBy) ->page($pager) ->fetchAll('id'); } /** * Get pipeline pairs * * @return array */ public function getPairs($type) { $pipeline = $this->dao->select('id,name')->from(TABLE_PIPELINE) ->where('deleted')->eq('0') ->AndWhere('type')->eq($type) ->orderBy('id')->fetchPairs('id', 'name'); return $pipeline; } /** * Create a pipeline. * * @access public * @return bool */ public function create($type) { $pipeline = fixer::input('post') ->add('type', $type) ->add('private',md5(rand(10,113450))) ->add('createdBy', $this->app->user->account) ->add('createdDate', helper::now()) ->trim('url,token,account,password') ->skipSpecial('url,token,account,password') ->get(); if($type == 'gitlab') $pipeline->url = rtrim($pipeline->url, '/'); if(isset($pipeline->password)) $pipeline->password = base64_encode($pipeline->password); $this->dao->insert(TABLE_PIPELINE)->data($pipeline) ->batchCheck($this->config->pipeline->create->requiredFields, 'notempty') ->batchCheck("url", 'URL') ->check('name', 'unique', "`type` = '$type'") ->checkIF($type == 'jenkins', 'account', 'notempty') ->checkIF($type == 'jenkins' and !$pipeline->token, 'password', 'notempty') ->checkIF($type == 'jenkins' and !$pipeline->password, 'token', 'notempty') ->autoCheck() ->exec(); if(dao::isError()) return false; return $this->dao->lastInsertId(); } /** * Update a pipeline. * * @param int $id * @access public * @return bool */ public function update($id) { $pipeline = fixer::input('post') ->add('editedBy', $this->app->user->account) ->add('editedDate', helper::now()) ->trim('url,token,account,password') ->skipSpecial('url,token,account,password') ->get(); $type = $this->dao->select('type')->from(TABLE_PIPELINE)->where('id')->eq($id)->fetch('type'); if($type == 'gitlab') $pipeline->url = rtrim($pipeline->url, '/'); if(isset($pipeline->password)) $pipeline->password = base64_encode($pipeline->password); $this->dao->update(TABLE_PIPELINE)->data($pipeline) ->batchCheck($this->config->pipeline->edit->requiredFields, 'notempty') ->batchCheck("url", 'URL') ->check('name', 'unique', "`type` = '$type' and id <> $id") ->checkIF($type == 'jenkins', 'account', 'notempty') ->checkIF($type == 'jenkins' and !$pipeline->token, 'password', 'notempty') ->checkIF($type == 'jenkins' and !$pipeline->password, 'token', 'notempty') ->autoCheck() ->where('id')->eq($id) ->exec(); return !dao::isError(); } /** * Delete one record. * * @param string $id the id to be deleted * @param string $object the action object * @access public * @return int|bool */ public function delete($id, $object = 'gitlab') { if(in_array($object, array('gitlab', 'gitea', 'gogs'))) { $repo = $this->dao->select('*')->from(TABLE_REPO) ->where('deleted')->eq('0') ->andWhere('SCM')->eq(ucfirst($object)) ->andWhere('serviceHost')->eq($id) ->fetch(); if($repo) return false; } elseif($object == 'sonarqube') { $job = $this->dao->select('id,name,repo,deleted')->from(TABLE_JOB) ->where('frame')->eq('sonarqube') ->andWhere('server')->eq($id) ->andWhere('deleted')->eq('0') ->fetch(); if($job) return false; } $this->dao->update(TABLE_PIPELINE)->set('deleted')->eq(1)->where('id')->eq($id)->exec(); $this->loadModel('action')->create($object, $id, 'deleted', '', ACTIONMODEL::CAN_UNDELETED); $actionID = $this->dao->lastInsertID(); return $actionID; } }