Design/EasySoft-ZenTaoPMS
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases 30 Wiki Activity

retrive jenkins build status and logs via remote api, then save to db

Browse Source
This commit is contained in:
aaronchen2k
2020-01-14 16:13:33 +08:00
parent 9e6cc72834
commit 0b2e26085f
2 changed files with 58 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files
module/ci/control.php
+2 -2
View File
@@ -353,9 +353,9 @@ class ci extends control
* @access public
* @return void
*/
public function checkCibuild($buildID)
public function checkCibuild()
{
$this->ci->checkCibuild($buildID);
$this->ci->checkCibuild();
if(dao::isError()) $this->send(array('result' => 'fail', 'message' => dao::getError()));
$this->send(array('result' => 'success'));
module/ci/model.php
+56 -6
View File
@@ -308,6 +308,18 @@ class ciModel extends model
$this->dao->insert(TABLE_CI_BUILD)->data($build)->exec();
}
/**
* Update ci build status.
*
* @param object $task
* @access public
* @return bool
*/
public function updateCibuildStatus($buildId, $status)
{
$this->dao->update(TABLE_CI_BUILD)->set('status')->eq($status)->where('id')->eq($buildId)->exec();
}
/**
* Send a request to jenkins to check build status.
*
@@ -317,11 +329,12 @@ class ciModel extends model
*/
public function checkCibuild()
{
$pos = $this->dao->select('build.*, jenkins.name jenkinsName,jenkins.serviceUrl,jenkins.credential')
$pos = $this->dao->select('build.*, task.jenkinsTask, jenkins.name jenkinsName,jenkins.serviceUrl,jenkins.credential')
->from(TABLE_CI_BUILD)->alias('build')
->leftJoin(TABLE_TASK)->alias('task')->on('build.citask=task.id')
->leftJoin(TABLE_CI_TASK)->alias('task')->on('build.citask=task.id')
->leftJoin(TABLE_JENKINS)->alias('jenkins')->on('task.jenkins=jenkins.id')
->where('build.status')->ne('completed')
->where('build.status')->ne('success')
->andWhere('build.status')->ne('fail')
->fetchAll();
foreach($pos as $po) {
@@ -336,10 +349,47 @@ class ciModel extends model
$r = '://' . $jenkinsUser . ':' . $jenkinsTokenOrPassword . '@';
$jenkinsServer = str_replace('://', $r, $jenkinsServer);
$buildUrl = sprintf('%s/queue/item/%/api/json', $jenkinsServer, $po->queueItem);
$queueUrl = sprintf('%s/queue/item/%s/api/json', $jenkinsServer, $po->queueItem);
$response = common::http($buildUrl, new stdClass());
$buildNumb = 0;
$response = common::http($queueUrl);
if (strripos($response,"404") > -1) { // queue已过期
$infoUrl = sprintf('%s/job/%s/%s/api/json', $jenkinsServer, $po->jenkinsTask, $po->queueItem);
$response = common::http($infoUrl);
$buildInfo = json_decode($response);
$result = strtolower($buildInfo->result);
$this->updateCibuildStatus($po->id, $result);
$logUrl = sprintf('%s/job/%s/%s/consoleText', $jenkinsServer, $po->jenkinsTask, $po->queueItem);
$response = common::http($logUrl);
$logs = json_decode($response);
$this->dao->update(TABLE_CI_BUILD)->set('logs')->eq($response)->where('id')->eq($po->id)->exec();
} else {
$queueInfo = json_decode($response);
if (!empty($queueInfo->executable)) {
$buildUrl = $queueInfo->executable->url . 'api/json?pretty=true';
$buildUrl = str_replace('://', $r, $buildUrl);
$response = common::http($buildUrl);
$buildInfo = json_decode($response);
if ($buildInfo->building) {
$this->updateCibuildStatus($po->id, 'building');
} else {
$result = strtolower($buildInfo->result);
$this->updateCibuildStatus($po->id, $result);
$logUrl = $buildInfo->url . 'logText/progressiveText/api/json';
$logUrl = str_replace('://', $r, $logUrl);
$response = common::http($logUrl);
$logs = json_decode($response);
$this->dao->update(TABLE_CI_BUILD)->set('logs')->eq($response)->where('id')->eq($po->id)->exec();
}
}
}
}
}