436 lines
14 KiB
PHP
436 lines
14 KiB
PHP
<?php
|
|
/**
|
|
* The model file of webhook module of ZenTaoPMS.
|
|
*
|
|
* @copyright Copyright 2009-2017 青岛易软天创网络科技有限公司(QingDao Nature Easy Soft Network Technology Co,LTD, www.cnezsoft.com)
|
|
* @license ZPL (http://zpl.pub/page/zplv12.html)
|
|
* @author Gang Liu <liugang@cnezsoft.com>
|
|
* @package webhook
|
|
* @version $Id$
|
|
* @link http://www.zentao.net
|
|
*/
|
|
class webhookModel extends model
|
|
{
|
|
/**
|
|
* Get a webhook by id.
|
|
*
|
|
* @param int $id
|
|
* @access public
|
|
* @return object
|
|
*/
|
|
public function getByID($id)
|
|
{
|
|
$webhook = $this->dao->select('*')->from(TABLE_WEBHOOK)->where('id')->eq($id)->fetch();
|
|
return $webhook;
|
|
}
|
|
|
|
/**
|
|
* Get webhook list.
|
|
*
|
|
* @param string $orderBy
|
|
* @param object $pager
|
|
* @param bool $decode
|
|
* @access public
|
|
* @return array
|
|
*/
|
|
public function getList($orderBy = 'id_desc', $pager = null, $decode = true)
|
|
{
|
|
$webhooks = $this->dao->select('*')->from(TABLE_WEBHOOK)
|
|
->where('deleted')->eq('0')
|
|
->orderBy($orderBy)
|
|
->page($pager)
|
|
->fetchAll('id');
|
|
return $webhooks;
|
|
}
|
|
|
|
/**
|
|
* Get log list of a webhook.
|
|
*
|
|
* @param int $id
|
|
* @param string $orderBy
|
|
* @param object $pager
|
|
* @access public
|
|
* @return array
|
|
*/
|
|
public function getLogList($id, $orderBy = 'date_desc', $pager = null)
|
|
{
|
|
$logs = $this->dao->select('*')->from(TABLE_LOG)
|
|
->where('objectType')->eq('webhook')
|
|
->andWhere('objectID')->eq($id)
|
|
->orderBy($orderBy)
|
|
->page($pager)
|
|
->fetchAll('id');
|
|
|
|
$actions = array();
|
|
foreach($logs as $log) $actions[] = $log->action;
|
|
|
|
$this->loadModel('action');
|
|
$actions = $this->dao->select('*')->from(TABLE_ACTION)->where('id')->in($actions)->fetchAll('id');
|
|
$users = $this->loadModel('user')->getPairs('noletter');
|
|
foreach($logs as $log)
|
|
{
|
|
if(!isset($actions[$log->action]))
|
|
{
|
|
$log->action = '';
|
|
continue;
|
|
}
|
|
|
|
$action = $actions[$log->action];
|
|
$object = $this->dao->select('*')->from($this->config->objectTables[$action->objectType])->where('id')->eq($action->objectID)->fetch();
|
|
$field = $this->config->action->objectNameFields[$action->objectType];
|
|
$text = $this->app->user->realname . $this->lang->action->label->{$action->action} . $this->lang->action->objectTypes[$action->objectType] . "[#{$action->objectID}::{$object->$field}]";
|
|
|
|
$log->action = $text;
|
|
$log->actionURL = $this->getViewLink($action->objectType, $action->objectID);
|
|
}
|
|
return $logs;
|
|
}
|
|
|
|
/**
|
|
* Get saved data list.
|
|
*
|
|
* @access public
|
|
* @return array
|
|
*/
|
|
public function getDataList()
|
|
{
|
|
return $this->dao->select('*')->from(TABLE_NOTIFY)->where('status')->eq('wait')->andWhere('objectType')->eq('webhook')->orderBy('id')->fetchAll('id');
|
|
}
|
|
|
|
/**
|
|
* Create a webhook.
|
|
*
|
|
* @access public
|
|
* @return bool
|
|
*/
|
|
public function create()
|
|
{
|
|
$webhook = fixer::input('post')
|
|
->add('createdBy', $this->app->user->account)
|
|
->add('createdDate', helper::now())
|
|
->join('products', ',')
|
|
->join('projects', ',')
|
|
->skipSpecial('url')
|
|
->remove('allParams, allActions')
|
|
->get();
|
|
$webhook->params = $this->post->params ? implode(',', $this->post->params) . ',text' : 'text';
|
|
|
|
$this->dao->insert(TABLE_WEBHOOK)->data($webhook)
|
|
->batchCheck($this->config->webhook->create->requiredFields, 'notempty')
|
|
->autoCheck()
|
|
->exec();
|
|
return !dao::isError();
|
|
}
|
|
|
|
/**
|
|
* Update a webhook.
|
|
*
|
|
* @param int $id
|
|
* @access public
|
|
* @return bool
|
|
*/
|
|
public function update($id)
|
|
{
|
|
$webhook = fixer::input('post')
|
|
->add('editedBy', $this->app->user->account)
|
|
->add('editedDate', helper::now())
|
|
->setDefault('products', '')
|
|
->setDefault('projects', '')
|
|
->join('products', ',')
|
|
->join('projects', ',')
|
|
->skipSpecial('url')
|
|
->remove('allParams, allActions')
|
|
->get();
|
|
$webhook->params = $this->post->params ? implode(',', $this->post->params) . ',text' : 'text';
|
|
|
|
$this->dao->update(TABLE_WEBHOOK)->data($webhook)
|
|
->batchCheck($this->config->webhook->edit->requiredFields, 'notempty')
|
|
->autoCheck()
|
|
->where('id')->eq($id)
|
|
->exec();
|
|
return !dao::isError();
|
|
}
|
|
|
|
/**
|
|
* Send data.
|
|
*
|
|
* @param string $objectType
|
|
* @param int $objectID
|
|
* @param string $actionType
|
|
* @param int $actionID
|
|
* @access public
|
|
* @return bool
|
|
*/
|
|
public function send($objectType, $objectID, $actionType, $actionID)
|
|
{
|
|
static $webhooks = array();
|
|
if(!$webhooks) $webhooks = $this->getList();
|
|
if(!$webhooks) return true;
|
|
|
|
foreach($webhooks as $id => $webhook)
|
|
{
|
|
$postData = $this->buildData($objectType, $objectID, $actionType, $actionID, $webhook);
|
|
if(!$postData) continue;
|
|
|
|
if($webhook->sendType == 'async')
|
|
{
|
|
$this->saveData($id, $actionID, $postData);
|
|
continue;
|
|
}
|
|
|
|
$result = $this->fetchHook($webhook, $postData);
|
|
$this->saveLog($webhook, $actionID, $postData, $result);
|
|
}
|
|
return !dao::isError();
|
|
}
|
|
|
|
/**
|
|
* Build data.
|
|
*
|
|
* @param string $objectType
|
|
* @param int $objectID
|
|
* @param string $actionType
|
|
* @param int $actionID
|
|
* @param object $webhook
|
|
* @access public
|
|
* @return string
|
|
*/
|
|
public function buildData($objectType, $objectID, $actionType, $actionID, $webhook)
|
|
{
|
|
/* Validate data. */
|
|
if(!isset($this->lang->action->label)) $this->loadModel('action');
|
|
if(!isset($this->lang->action->label->$actionType)) return false;
|
|
if(empty($this->config->objectTables[$objectType])) return false;
|
|
$action = $this->dao->select('*')->from(TABLE_ACTION)->where('id')->eq($actionID)->fetch();
|
|
|
|
if($webhook->products)
|
|
{
|
|
$webhookProducts = explode(',', trim($webhook->products, ','));
|
|
$actionProduct = explode(',', trim($action->product, ','));
|
|
$intersect = array_intersect($webhookProducts, $actionProduct);
|
|
if(!$intersect) return false;
|
|
}
|
|
if($webhook->projects)
|
|
{
|
|
if(strpos(",$webhook->projects,", ",$action->project,") === false) return false;
|
|
}
|
|
|
|
static $users = array();
|
|
if(empty($users)) $users = $this->loadModel('user')->getList();
|
|
|
|
$object = $this->dao->select('*')->from($this->config->objectTables[$objectType])->where('id')->eq($objectID)->fetch();
|
|
$field = $this->config->action->objectNameFields[$objectType];
|
|
$host = common::getSysURL();
|
|
$viewLink = $this->getViewLink($objectType, $objectID);
|
|
$title = $this->app->user->realname . $this->lang->action->label->$actionType . $this->lang->action->objectTypes[$objectType];
|
|
$text = $title . ' ' . "[#{$objectID}::{$object->$field}](" . $host . $viewLink . ")";
|
|
|
|
$mobile = '';
|
|
$email = '';
|
|
if(in_array($actionType, array('assigned', 'resolved', 'bugconfirmed')))
|
|
{
|
|
foreach($users as $user)
|
|
{
|
|
if($user->account == $object->assignedTo)
|
|
{
|
|
$mobile = $user->mobile;
|
|
$email = $user->email;
|
|
break;
|
|
}
|
|
}
|
|
}
|
|
$action->text = $text;
|
|
|
|
if($webhook->type == 'dingding')
|
|
{
|
|
$data = $this->getDingdingData($title, $text, $mobile);
|
|
}
|
|
elseif($webhook->type == 'bearychat')
|
|
{
|
|
$data = $this->getBearychatData($text, $mobile, $email, $objectType, $objectID);
|
|
}
|
|
else
|
|
{
|
|
$data = new stdclass();
|
|
foreach(explode(',', $webhook->params) as $param) $data->$param = $action->$param;
|
|
}
|
|
|
|
return helper::jsonEncode($data);
|
|
}
|
|
|
|
/**
|
|
* Get view link.
|
|
*
|
|
* @param string $objectType
|
|
* @param int $objectID
|
|
* @access public
|
|
* @return string
|
|
*/
|
|
public function getViewLink($objectType, $objectID)
|
|
{
|
|
$oldOnlyBody = '';
|
|
if(isset($_GET['onlybody']) and $_GET['onlybody'] == 'yes')
|
|
{
|
|
$oldOnlyBody = 'yes';
|
|
unset($_GET['onlybody']);
|
|
}
|
|
if($objectType == 'case') $objectType = 'testcase';
|
|
$viewLink = helper::createLink($objectType, 'view', "id=$objectID");
|
|
if($oldOnlyBody) $_GET['onlybody'] = $oldOnlyBody;
|
|
|
|
return $viewLink;
|
|
}
|
|
|
|
/**
|
|
* Get hook data for dingding.
|
|
*
|
|
* @param string $title
|
|
* @param string $text
|
|
* @param string $mobile
|
|
* @access public
|
|
* @return object
|
|
*/
|
|
public function getDingdingData($title, $text, $mobile)
|
|
{
|
|
if($mobile) $text .= " @{$mobile}";
|
|
|
|
$markdown = new stdclass();
|
|
$markdown->title = $title;
|
|
$markdown->text = $text;
|
|
|
|
$data = new stdclass();
|
|
$data->msgtype = 'markdown';
|
|
$data->markdown = $markdown;
|
|
|
|
if($mobile)
|
|
{
|
|
$at = new stdclass();
|
|
$at->atMobiles = array($mobile);
|
|
$at->isAtAll = false;
|
|
|
|
$data->at = $at;
|
|
}
|
|
|
|
return $data;
|
|
}
|
|
|
|
/**
|
|
* Get hook data for bearychat.
|
|
*
|
|
* @param string $text
|
|
* @param string $mobile
|
|
* @param string $email
|
|
* @param string $objectType
|
|
* @param int $objectID
|
|
* @access public
|
|
* @return object
|
|
*/
|
|
public function getBearychatData($text, $mobile, $email, $objectType, $objectID)
|
|
{
|
|
$data = new stdclass();
|
|
$data->text = $text;
|
|
$data->markdown = 'true';
|
|
$data->user = $mobile ? $mobile : ($email ? $email : $this->app->user->account);
|
|
|
|
if(!empty($_FILES['files']['name'][0]))
|
|
{
|
|
$this->loadModel('file');
|
|
$files = $this->dao->select('*')->from(TABLE_FILE)->where('objectType')->eq($objectType)->andWhere('objectID')->eq($objectID)->orderBy('addedDate_desc,id_desc')->limit(count($_FILES['files']['name']))->fetchAll();
|
|
if($files)
|
|
{
|
|
foreach($files as $file)
|
|
{
|
|
$attachment = array();
|
|
$attachment['title'] = $file->title;
|
|
$attachment['images'][]['url'] = $data->host . $this->file->webPath . $file->pathname;
|
|
$data->attachments[] = $attachment;
|
|
}
|
|
}
|
|
}
|
|
|
|
return $data;
|
|
}
|
|
|
|
/**
|
|
* Post hook data.
|
|
*
|
|
* @param object $webhook
|
|
* @param string $sendData
|
|
* @access public
|
|
* @return int
|
|
*/
|
|
public function fetchHook($webhook, $sendData)
|
|
{
|
|
if(!extension_loaded('curl')) die(helper::jsonEncode($this->lang->webhook->error->curl));
|
|
|
|
$header[] = "Content-Type: {$webhook->contentType};charset=utf-8";
|
|
|
|
$ch = curl_init();
|
|
curl_setopt($ch, CURLOPT_URL, $webhook->url);
|
|
curl_setopt($ch, CURLOPT_POST, 1);
|
|
curl_setopt($ch, CURLOPT_HTTPHEADER, $header);
|
|
curl_setopt($ch, CURLOPT_POSTFIELDS, $sendData);
|
|
curl_setopt($ch, CURLOPT_RETURNTRANSFER, 1);
|
|
curl_setopt($ch, CURLOPT_SSL_VERIFYHOST, 0);
|
|
curl_setopt($ch, CURLOPT_SSL_VERIFYPEER, 0);
|
|
$result = curl_exec($ch);
|
|
$httpCode = curl_getinfo($ch, CURLINFO_HTTP_CODE);
|
|
$error = curl_error($ch);
|
|
curl_close($ch);
|
|
|
|
if($error) return $error;
|
|
if($result) return $result;
|
|
return $httpCode;
|
|
}
|
|
|
|
/**
|
|
* Save datas.
|
|
*
|
|
* @param int $webhookID
|
|
* @param int $actionID
|
|
* @param string $data
|
|
* @access public
|
|
* @return bool
|
|
*/
|
|
public function saveData($webhookID, $actionID, $data)
|
|
{
|
|
$webhookData = new stdclass();
|
|
$webhookData->objectType = 'webhook';
|
|
$webhookData->objectID = $webhookID;
|
|
$webhookData->action = $actionID;
|
|
$webhookData->data = $data;
|
|
$webhookData->createdBy = $this->app->user->account;
|
|
$webhookData->createdDate = helper::now();
|
|
|
|
$this->dao->insert(TABLE_NOTIFY)->data($webhookData)->exec();
|
|
return !dao::isError();
|
|
}
|
|
|
|
/**
|
|
* Save log.
|
|
*
|
|
* @param int $webhookID
|
|
* @param int $actionID
|
|
* @param object $webhook
|
|
* @param string $data
|
|
* @param string $result
|
|
* @access public
|
|
* @return bool
|
|
*/
|
|
public function saveLog($webhook, $actionID, $data, $result)
|
|
{
|
|
$log = new stdclass();
|
|
$log->objectType = 'webhook';
|
|
$log->objectID = $webhook->id;
|
|
$log->action = $actionID;
|
|
$log->date = helper::now();
|
|
$log->url = $webhook->url;
|
|
$log->contentType = $webhook->contentType;
|
|
$log->data = $data;
|
|
$log->result = $result;
|
|
|
|
$this->dao->insert(TABLE_LOG)->data($log)->exec();
|
|
return !dao::isError();
|
|
}
|
|
}
|