Merge branch 'master' of github.com:easysoft/zentaopms
This commit is contained in:
+1
-1
@@ -94,4 +94,4 @@ CREATE TABLE `zt_score` (
|
||||
KEY `method` (`method`)
|
||||
) ENGINE=MyISAM DEFAULT CHARSET=utf8;
|
||||
|
||||
INSERT INTO `zt_cron` (`m`, `h`, `dom`, `mon`, `dow`, `command`, `remark`, `type`, `buildin`, `status`, `lastTime`) VALUES ('*/5', '*', '*', '*', '*', 'moduleName=webhook&methodName=asyncSend', '异步发送Webhook', 'zentao', 0, 'normal', '0000-00-00 00:00:00');
|
||||
INSERT INTO `zt_cron` (`m`, `h`, `dom`, `mon`, `dow`, `command`, `remark`, `type`, `buildin`, `status`, `lastTime`) VALUES ('*/5', '*', '*', '*', '*', 'moduleName=webhook&methodName=asyncSend', '异步发送Webhook', 'zentao', 1, 'normal', '0000-00-00 00:00:00');
|
||||
|
||||
@@ -280,10 +280,12 @@ $lang->block->typeList->story['closedBy'] = 'Closed by Me' ;
|
||||
$lang->block->typeList->product['noclosed'] = 'Open';
|
||||
$lang->block->typeList->product['closed'] = 'Closed';
|
||||
$lang->block->typeList->product['all'] = 'All';
|
||||
$lang->block->typeList->product['involved'] = 'Involved'
|
||||
|
||||
$lang->block->typeList->project['undone'] = 'Undone';
|
||||
$lang->block->typeList->project['isdoing'] = 'Doing';
|
||||
$lang->block->typeList->project['all'] = 'All';
|
||||
$lang->block->typeList->project['undone'] = 'Undone';
|
||||
$lang->block->typeList->project['isdoing'] = 'Doing';
|
||||
$lang->block->typeList->project['all'] = 'All';
|
||||
$lang->block->typeList->project['involved'] = 'Involved';
|
||||
|
||||
$lang->block->typeList->testtask['wait'] = 'Testing Pending';
|
||||
$lang->block->typeList->testtask['doing'] = 'Testing';
|
||||
|
||||
@@ -280,10 +280,12 @@ $lang->block->typeList->story['closedBy'] = '由我关闭';
|
||||
$lang->block->typeList->product['noclosed'] = '未关闭';
|
||||
$lang->block->typeList->product['closed'] = '已关闭';
|
||||
$lang->block->typeList->product['all'] = '全部';
|
||||
$lang->block->typeList->product['involved'] = '我参与的';
|
||||
|
||||
$lang->block->typeList->project['undone'] = '未完成';
|
||||
$lang->block->typeList->project['isdoing'] = '进行中';
|
||||
$lang->block->typeList->project['all'] = '全部';
|
||||
$lang->block->typeList->project['undone'] = '未完成';
|
||||
$lang->block->typeList->project['isdoing'] = '进行中';
|
||||
$lang->block->typeList->project['all'] = '全部';
|
||||
$lang->block->typeList->project['involved'] = '我参与的';
|
||||
|
||||
$lang->block->typeList->testtask['wait'] = '待测版本';
|
||||
$lang->block->typeList->testtask['doing'] = '测试中版本';
|
||||
|
||||
@@ -371,6 +371,7 @@ $lang->editor->menu = $lang->admin->menu;
|
||||
$lang->mail->menu = $lang->admin->menu;
|
||||
$lang->dev->menu = $lang->admin->menu;
|
||||
$lang->score->menu = $lang->admin->menu;
|
||||
$lang->entry->menu = $lang->admin->menu;
|
||||
$lang->webhook->menu = $lang->admin->menu;
|
||||
|
||||
/* 菜单分组。*/
|
||||
@@ -421,6 +422,7 @@ $lang->error->int = array("『%s』has to be numbers", "『%s』shou
|
||||
$lang->error->float = "『%s』should be numbers, decimals included.";
|
||||
$lang->error->email = "『%s』should be valid EMAIL.";
|
||||
$lang->error->date = "『%s』should be valid date.";
|
||||
$lang->error->code = "『%s』should be english or numbers.";
|
||||
$lang->error->account = "『%s』should be valid account.";
|
||||
$lang->error->passwordsame = "Two passwords should be consistent.";
|
||||
$lang->error->passwordrule = "Password should meet requirements. It should be 6 characters at least.";
|
||||
@@ -430,6 +432,16 @@ $lang->error->noData = 'No Data';
|
||||
$lang->error->editedByOther = 'This record might have been changed. Please refresh and try to edit again!';
|
||||
$lang->error->tutorialData = 'No data can be imported in tutorial mode. Please exit tutorial first!';
|
||||
|
||||
$lang->error->entry = array();
|
||||
$lang->error->entry['300001'] = 'Param code not set.';
|
||||
$lang->error->entry['300002'] = 'Param token not set.';
|
||||
$lang->error->entry['310001'] = 'Entry not exist.';
|
||||
$lang->error->entry['310002'] = 'Key of entry not set.';
|
||||
$lang->error->entry['320001'] = 'IP denied.';
|
||||
$lang->error->entry['330001'] = 'Invalid token.';
|
||||
$lang->error->entry['340001'] = 'Session code not set.';
|
||||
$lang->error->entry['340002'] = 'Session verify failed.';
|
||||
|
||||
/* 分页信息。*/
|
||||
$lang->pager = new stdclass();
|
||||
$lang->pager->noRecord = "No History";
|
||||
|
||||
@@ -432,6 +432,16 @@ $lang->error->noData = '没有数据';
|
||||
$lang->error->editedByOther = '该记录可能已经被改动。请刷新页面重新编辑!';
|
||||
$lang->error->tutorialData = '新手模式下不会插入数据,请退出新手模式操作';
|
||||
|
||||
$lang->error->entry = array();
|
||||
$lang->error->entry['300001'] = '缺少code参数';
|
||||
$lang->error->entry['300002'] = '缺少token参数';
|
||||
$lang->error->entry['310001'] = '应用不存在';
|
||||
$lang->error->entry['310002'] = '应用未设置密钥';
|
||||
$lang->error->entry['320001'] = '该IP访问被限制访问';
|
||||
$lang->error->entry['330001'] = '不合法的token参数';
|
||||
$lang->error->entry['340001'] = '缺少session code';
|
||||
$lang->error->entry['340002'] = 'session验证失败';
|
||||
|
||||
/* 分页信息。*/
|
||||
$lang->pager = new stdclass();
|
||||
$lang->pager->noRecord = "暂时没有记录";
|
||||
|
||||
@@ -1353,6 +1353,83 @@ class commonModel extends model
|
||||
|
||||
return $convertedItems;
|
||||
}
|
||||
|
||||
/**
|
||||
* Check an entry.
|
||||
*
|
||||
* @access public
|
||||
* @return void
|
||||
*/
|
||||
public function checkEntry()
|
||||
{
|
||||
if(!$this->session->valid_entry)
|
||||
{
|
||||
if(!$this->session->entry_code) $this->response(340001);
|
||||
if($this->session->valid_entry != md5(md5($this->get->code) . $this->server->remote_addr)) $this->response(340002);
|
||||
return true;
|
||||
}
|
||||
|
||||
if(!$this->get->code) $this->response(300001);
|
||||
if(!$this->get->token) $this->response(300002);
|
||||
|
||||
$entry = $this->loadModel('entry')->getByCode($this->get->code);
|
||||
if(!$entry) $this->response(310001);
|
||||
if(!$entry->key) $this->response(310002);
|
||||
|
||||
$this->checkEntryIP($entry->ip);
|
||||
$this->checkEntryToken($entry->key);
|
||||
|
||||
$this->session->set('ENTRY_CODE', $this->get->code);
|
||||
$this->session->set('VALID_ENTRY', md5(md5($this->get->code) . $this->server->remote_addr));
|
||||
$this->loadModel('entry')->saveLog($entry->id, $this->server->request_uri);
|
||||
}
|
||||
|
||||
/**
|
||||
* Check ip of an entry.
|
||||
*
|
||||
* @param string $ip
|
||||
* @access public
|
||||
* @return void
|
||||
*/
|
||||
public function checkEntryIP($ip)
|
||||
{
|
||||
$ipWhiteList = $this->config->ipWhiteList;
|
||||
$this->config->ipWhiteList = $ip;
|
||||
$result = $this->checkIP();
|
||||
$this->config->ipWhiteList = $ipWhiteList;
|
||||
if(!$result) $this->response(320001);
|
||||
}
|
||||
|
||||
/**
|
||||
* Check token of an entry.
|
||||
*
|
||||
* @param string $key
|
||||
* @access public
|
||||
* @return void
|
||||
*/
|
||||
public function checkEntryToken($key)
|
||||
{
|
||||
parse_str($this->server->query_String, $queryString);
|
||||
unset($queryString['token']);
|
||||
$queryString = http_build_query($queryString);
|
||||
if($_GET['token'] != md5(md5($queryString) . $key)) $this->response(330001);
|
||||
}
|
||||
|
||||
/**
|
||||
* Response.
|
||||
*
|
||||
* @param int $code
|
||||
* @access public
|
||||
* @return void
|
||||
*/
|
||||
public function response($code)
|
||||
{
|
||||
$response = new stdclass();
|
||||
$response->errcode = $code;
|
||||
$response->errmsg = $this->lang->error->entry[$code];
|
||||
|
||||
die(helper::jsonEncode($response));
|
||||
}
|
||||
}
|
||||
|
||||
class common extends commonModel
|
||||
|
||||
+25
-15
@@ -43,10 +43,10 @@ class entry extends control
|
||||
{
|
||||
if($_POST)
|
||||
{
|
||||
$entryID = $this->entry->create();
|
||||
$id = $this->entry->create();
|
||||
if(dao::isError()) $this->send(array('result' => 'fail', 'message' => dao::getError()));
|
||||
|
||||
$this->loadModel('action')->create('entry', $entryID, 'created');
|
||||
$this->loadModel('action')->create('entry', $id, 'created');
|
||||
$this->send(array('result' => 'success', 'message' => $this->lang->entry->saveSuccess, 'locate' => inlink('browse')));
|
||||
}
|
||||
|
||||
@@ -57,26 +57,26 @@ class entry extends control
|
||||
/**
|
||||
* Edit an entry.
|
||||
*
|
||||
* @param int $entryID
|
||||
* @param int $id
|
||||
* @access public
|
||||
* @return void
|
||||
*/
|
||||
public function edit($entryID)
|
||||
public function edit($id)
|
||||
{
|
||||
if($_POST)
|
||||
{
|
||||
$changes = $this->entry->update($entryID);
|
||||
$changes = $this->entry->update($id);
|
||||
if(dao::isError()) $this->send(array('result' => 'fail', 'message' => dao::getError()));
|
||||
|
||||
if($changes)
|
||||
{
|
||||
$actionID = $this->loadModel('action')->create('entry', $entryID, 'edited');
|
||||
$actionID = $this->loadModel('action')->create('entry', $id, 'edited');
|
||||
$this->action->logHistory($actionID, $changes);
|
||||
}
|
||||
$this->send(array('result' => 'success', 'message' => $this->lang->entry->saveSuccess, 'locate' => inlink('browse')));
|
||||
}
|
||||
|
||||
$entry = $this->entry->getById($entryID);
|
||||
$entry = $this->entry->getById($id);
|
||||
$this->view->title = $this->lang->entry->edit . $this->lang->colon . $entry->name;
|
||||
$this->view->entry = $entry;
|
||||
$this->display();
|
||||
@@ -85,30 +85,40 @@ class entry extends control
|
||||
/**
|
||||
* Delete an entry.
|
||||
*
|
||||
* @param int $entryID
|
||||
* @param int $id
|
||||
* @access public
|
||||
* @return void
|
||||
*/
|
||||
public function delete($entryID)
|
||||
public function delete($id)
|
||||
{
|
||||
$this->entry->delete(TABLE_ENTRY, $entryID);
|
||||
$this->entry->delete(TABLE_ENTRY, $id);
|
||||
if(dao::isError()) $this->send(array('result' => 'fail', 'message' => dao::getError()));
|
||||
|
||||
$this->send(array('result' => 'success'));
|
||||
}
|
||||
|
||||
/**
|
||||
* Show access logs of entry.
|
||||
* Browse logs of an entry.
|
||||
*
|
||||
* @param int $entryID
|
||||
* @param int $id
|
||||
* @param string $orderBy
|
||||
* @param int $recTotal
|
||||
* @param int $recPerPage
|
||||
* @param int $pageID
|
||||
* @access public
|
||||
* @return void
|
||||
*/
|
||||
public function log($entryID)
|
||||
public function log($id, $orderBy = 'id_desc', $recTotal = 0, $recPerPage = 20, $pageID = 1)
|
||||
{
|
||||
$entry = $this->entry->getById($entryID);
|
||||
$this->app->loadClass('pager', $static = true);
|
||||
$pager = new pager($recTotal, $recPerPage, $pageID);
|
||||
|
||||
$entry = $this->entry->getByID($id);
|
||||
$this->view->title = $this->lang->entry->log . $this->lang->colon . $entry->name;
|
||||
$this->view->actions = $this->loadModel('action')->getList('entry', $entryID);
|
||||
$this->view->logs = $this->entry->getLogList($id, $orderBy, $pager);
|
||||
$this->view->entry = $entry;
|
||||
$this->view->orderBy = $orderBy;
|
||||
$this->view->pager = $pager;
|
||||
$this->display();
|
||||
}
|
||||
}
|
||||
|
||||
@@ -22,6 +22,8 @@ $lang->entry->createdBy = '由谁创建';
|
||||
$lang->entry->createdDate = '创建时间';
|
||||
$lang->entry->editedby = '最后编辑';
|
||||
$lang->entry->editedDate = '编辑时间';
|
||||
$lang->entry->date = '请求时间';
|
||||
$lang->entry->url = '请求地址';
|
||||
|
||||
$lang->entry->apiIndex = '应用入口';
|
||||
$lang->entry->saveSuccess = '保存成功';
|
||||
@@ -30,6 +32,6 @@ $lang->entry->confirmDelete = '您确认要删除该应用吗?';
|
||||
$lang->entry->note = new stdClass();
|
||||
$lang->entry->note->name = '授权应用名称';
|
||||
$lang->entry->note->code = '授权应用代号,必须为字母或数字的组合';
|
||||
$lang->entry->note->ip = "允许访问应用的ip,多个ip用逗号隔开。支持IP段,如192.168.1.*";
|
||||
$lang->entry->note->ip = "允许访问API的应用ip,多个ip用逗号隔开。支持IP段,如192.168.1.*";
|
||||
$lang->entry->note->allIP = '无限制';
|
||||
$lang->entry->note->api = 'moduleName、methodName以及参数列表替换成实际的值';
|
||||
|
||||
@@ -48,6 +48,25 @@ class entryModel extends model
|
||||
return $this->dao->select('*')->from(TABLE_ENTRY)->where('deleted')->eq('0')->orderBy($orderBy)->page($pager)->fetchAll('id');
|
||||
}
|
||||
|
||||
/**
|
||||
* Get log list of an entry .
|
||||
*
|
||||
* @param int $id
|
||||
* @param string $orderBy
|
||||
* @param object $pager
|
||||
* @access public
|
||||
* @return array
|
||||
*/
|
||||
public function getLogList($id, $orderBy = 'date_desc', $pager = null)
|
||||
{
|
||||
return $this->dao->select('*')->from(TABLE_LOG)
|
||||
->where('objectType')->eq('entry')
|
||||
->andWhere('objectID')->eq($id)
|
||||
->orderBy($orderBy)
|
||||
->page($pager)
|
||||
->fetchAll('id');
|
||||
}
|
||||
|
||||
/**
|
||||
* Create an entry.
|
||||
*
|
||||
|
||||
@@ -1,32 +1,45 @@
|
||||
<?php
|
||||
/**
|
||||
* The log view file of entry module of RanZhi.
|
||||
* The log view file of log 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 entry
|
||||
* @package log
|
||||
* @version $Id$
|
||||
* @link http://www.ranzhico.com
|
||||
* @link http://www.zentao.net
|
||||
*/
|
||||
?>
|
||||
<?php include 'header.html.php';?>
|
||||
<table class='table table-condensed table-hover table-striped'>
|
||||
<?php include '../../common/view/header.html.php';?>
|
||||
<div id="titlebar">
|
||||
<div class="heading">
|
||||
<strong><?php echo html::a(inlink('browse'), $lang->entry->common);?></strong>
|
||||
<small class="text-muted"> <?php echo $entry->name;?> </small>
|
||||
<small class="text-muted"> <?php echo $lang->entry->log;?> <i class="icon-file-text-o"></i></small>
|
||||
</div>
|
||||
</div>
|
||||
<table id='logList' class='table table-condensed table-hover table-striped tablesorter table-fixed'>
|
||||
<thead>
|
||||
<tr>
|
||||
<th class='w-120px'><?php echo $lang->action->date;?></th>
|
||||
<th class='w-100px'><?php echo $lang->action->actor;?></th>
|
||||
<th><?php echo $lang->entry->desc;?></th>
|
||||
<?php $vars = "id={$entry->id}&orderBy=%s&recTotal={$pager->recTotal}&recPerPage={$pager->recPerPage}&pageID={$pager->pageID}";?>
|
||||
<th class='w-60px'><?php common::printOrderLink('id', $orderBy, $vars, $lang->entry->id);?></th>
|
||||
<th class='w-160px'><?php common::printOrderLink('date', $orderBy, $vars, $lang->entry->date);?></th>
|
||||
<th><?php common::printOrderLink('url', $orderBy, $vars, $lang->entry->url);?></th>
|
||||
</tr>
|
||||
</thead>
|
||||
<tbody>
|
||||
<?php foreach($actions as $action);?>
|
||||
<?php foreach($logs as $id => $log):?>
|
||||
<tr>
|
||||
<td><?php echo $action->date;?></td>
|
||||
<td><?php echo zget($users, $action->actor);?></td>
|
||||
<td><?php echo $action->extra;?></td>
|
||||
<td class='text-center'><?php echo $id;?></td>
|
||||
<td><?php echo $log->date;?></td>
|
||||
<td class='text' title='<?php echo $log->url;?>'><?php echo $log->url;?></td>
|
||||
</tr>
|
||||
<?php endforeach;?>
|
||||
</tbody>
|
||||
<tfoot>
|
||||
<tr>
|
||||
<td colspan='3'><?php $pager->show();?></td>
|
||||
</tr>
|
||||
</tfoot>
|
||||
</table>
|
||||
<?php include '../../common/view/footer.html.php';?>
|
||||
|
||||
@@ -209,7 +209,14 @@ class productModel extends model
|
||||
return $this->dao->select('*')->from(TABLE_PRODUCT)
|
||||
->where('deleted')->eq(0)
|
||||
->beginIF($status == 'noclosed')->andWhere('status')->ne('closed')->fi()
|
||||
->beginIF($status != 'all' and $status != 'noclosed')->andWhere('status')->in($status)->fi()
|
||||
->beginIF($status != 'all' and $status != 'noclosed' and $status != 'involved')->andWhere('status')->in($status)->fi()
|
||||
->beginIF($status == 'involved')
|
||||
->andWhere('PO', true)->eq($this->app->user->account)
|
||||
->orWhere('QD')->eq($this->app->user->account)
|
||||
->orWhere('RD')->eq($this->app->user->account)
|
||||
->orWhere('createdBy')->eq($this->app->user->account)
|
||||
->markRight(1)
|
||||
->fi()
|
||||
->beginIF($limit > 0)->limit($limit)->fi()
|
||||
->orderBy('`order` desc')
|
||||
->fetchAll('id');
|
||||
|
||||
@@ -601,6 +601,8 @@ class projectModel extends model
|
||||
*/
|
||||
public function getList($status = 'all', $limit = 0, $productID = 0, $branch = 0)
|
||||
{
|
||||
if($status == 'involved') return $this->getInvolvedList($status, $limit, $productID, $branch);
|
||||
|
||||
if($productID != 0)
|
||||
{
|
||||
return $this->dao->select('t2.*')->from(TABLE_PROJECTPRODUCT)->alias('t1')
|
||||
@@ -629,6 +631,49 @@ class projectModel extends model
|
||||
}
|
||||
}
|
||||
|
||||
/**
|
||||
* Get project lists.
|
||||
*
|
||||
* @param string $status involved
|
||||
* @param int $limit
|
||||
* @param int $productID
|
||||
* @param int $branch
|
||||
* @access public
|
||||
* @return array
|
||||
*/
|
||||
public function getInvolvedList($status = 'involved', $limit = 0, $productID = 0, $branch = 0)
|
||||
{
|
||||
if($productID != 0)
|
||||
{
|
||||
return $this->dao->select('t2.*')->from(TABLE_PROJECTPRODUCT)->alias('t1')
|
||||
->leftJoin(TABLE_PROJECT)->alias('t2')->on('t1.project = t2.id')
|
||||
->leftJoin(TABLE_TEAM)->alias('t3')->on('t3.project=t2.id')
|
||||
->where('t1.product')->eq($productID)
|
||||
->andWhere('t2.deleted')->eq(0)
|
||||
->andWhere('t2.iscat')->eq(0)
|
||||
->beginIF($branch)->andWhere('t1.branch')->eq($branch)->fi()
|
||||
->andWhere('t2.openedBy', true)->eq($this->app->user->account)
|
||||
->orWhere('t3.account')->eq($this->app->user->account)
|
||||
->markRight(1)
|
||||
->orderBy('order_desc')
|
||||
->beginIF($limit)->limit($limit)->fi()
|
||||
->fetchAll('id');
|
||||
}
|
||||
else
|
||||
{
|
||||
return $this->dao->select('t1.*, IF(INSTR(" done", t1.status) < 2, 0, 1) AS isDone')->from(TABLE_PROJECT)->alias('t1')
|
||||
->leftJoin(TABLE_TEAM)->alias('t2')->on('t2.project=t1.id')
|
||||
->where('t1.iscat')->eq(0)
|
||||
->andWhere('t1.openedBy', true)->eq($this->app->user->account)
|
||||
->orWhere('t2.account')->eq($this->app->user->account)
|
||||
->markRight(1)
|
||||
->andWhere('t1.deleted')->eq(0)
|
||||
->orderBy('t1.order_desc')
|
||||
->beginIF($limit)->limit($limit)->fi()
|
||||
->fetchAll('id');
|
||||
}
|
||||
}
|
||||
|
||||
/**
|
||||
* Get projects lists grouped by product.
|
||||
*
|
||||
@@ -680,7 +725,7 @@ class projectModel extends model
|
||||
public function getProjectStats($status = 'undone', $productID = 0, $branch = 0, $itemCounts = 30, $orderBy = 'order_desc', $pager = null)
|
||||
{
|
||||
/* Init vars. */
|
||||
$projects = $this->getList($status, 0, $productID, $branch);
|
||||
$projects = $this->getList($status, 0, $productID, $branch);
|
||||
foreach($projects as $projectID => $project)
|
||||
{
|
||||
if(!$this->checkPriv($project)) unset($projects[$projectID]);
|
||||
|
||||
@@ -126,7 +126,7 @@
|
||||
{
|
||||
if($product->type !== 'normal')
|
||||
{
|
||||
$branchName = isset($branchGroups[$productID][$product->branch]) ? '/' . $branchGroups[$productID][$product->branch] : ''
|
||||
$branchName = isset($branchGroups[$productID][$product->branch]) ? '/' . $branchGroups[$productID][$product->branch] : '';
|
||||
echo html::a($this->createLink('product', 'browse', "productID=$productID&branch=$product->branch"), $product->name . $branchName);
|
||||
}
|
||||
else
|
||||
|
||||
@@ -136,27 +136,36 @@ class webhook extends control
|
||||
*/
|
||||
public function asyncSend()
|
||||
{
|
||||
$webhooks = $this->webhook->getList();
|
||||
if(empty($hooks)) return false;
|
||||
$webhooks = $this->webhook->getList($type = '', $orderBy = 'id_desc', $pager = null, $decode = false);
|
||||
if(empty($webhooks))
|
||||
{
|
||||
echo "NO WEBHOOK EXIST.\n";
|
||||
return false;
|
||||
}
|
||||
|
||||
$dataList = $this->webhook->getDataList();
|
||||
if(empty($dataList)) return true;
|
||||
if(empty($dataList))
|
||||
{
|
||||
echo "OK\n";
|
||||
return true;
|
||||
}
|
||||
|
||||
$snoopy = $this->app->loadClass('snoopy');
|
||||
foreach($dataList as $data)
|
||||
{
|
||||
$webhook = zget($webhooks, $data->webhook, '');
|
||||
$httpCode = 0;
|
||||
$webhook = zget($webhooks, $data->webhook, '');
|
||||
if($webhook)
|
||||
{
|
||||
$contentType = zget($this->config->webhook->contentTypes, $webhook->contentType, 'application/json');
|
||||
$result = $this->webhook->fetchHook($contentType, $webhook->url, $data->data);
|
||||
$this->saveLog($data->webhook, $data->action, $webhook->url, $contentType, $data->data, $result);
|
||||
$this->webhook->saveLog($data->webhook, $data->action, $webhook->url, $contentType, $data->data, $result);
|
||||
}
|
||||
|
||||
if($httpCode == 200) $this->dao->update(TABLE_WEBHOOKDATA)->set('status')->eq('sended')->where('id')->eq($data->id)->exec();
|
||||
$this->dao->update(TABLE_WEBHOOKDATAS)->set('status')->eq('sended')->where('id')->eq($data->id)->exec();
|
||||
}
|
||||
|
||||
$this->dao->delete()->from(TABLE_WEBHOOKDATA)->where('status')->eq('sended')->exec();
|
||||
$this->dao->delete()->from(TABLE_WEBHOOKDATAS)->where('status')->eq('sended')->exec();
|
||||
|
||||
echo "OK\n";
|
||||
return true;
|
||||
}
|
||||
}
|
||||
|
||||
@@ -13,5 +13,5 @@ $(function()
|
||||
});
|
||||
|
||||
$('#name').focus();
|
||||
$('#paramsmessage').attr('disabled', 'disabled');
|
||||
$('#paramstext').attr('disabled', 'disabled');
|
||||
});
|
||||
|
||||
@@ -13,5 +13,5 @@ $(function()
|
||||
});
|
||||
|
||||
$('#name').focus();
|
||||
$('#paramsmessage').attr('disabled', 'disabled');
|
||||
$('#paramstext').attr('disabled', 'disabled');
|
||||
});
|
||||
|
||||
@@ -22,8 +22,13 @@ $lang->webhook->product = '关联产品';
|
||||
$lang->webhook->project = '关联项目';
|
||||
$lang->webhook->action = '触发动作';
|
||||
$lang->webhook->desc = '描述';
|
||||
$lang->webhook->createdBy = '由谁创建';
|
||||
$lang->webhook->createdDate = '创建时间';
|
||||
$lang->webhook->editedby = '最后编辑';
|
||||
$lang->webhook->editedDate = '编辑时间';
|
||||
$lang->webhook->date = '发送时间';
|
||||
$lang->webhook->data = '数据';
|
||||
$lang->webhook->status = '状态';
|
||||
$lang->webhook->result = '结果';
|
||||
|
||||
$lang->webhook->sendTypeList['sync'] = '同步';
|
||||
$lang->webhook->sendTypeList['async'] = '异步';
|
||||
@@ -36,7 +41,7 @@ $lang->webhook->paramsList['action'] = '动作';
|
||||
$lang->webhook->paramsList['actor'] = '操作者';
|
||||
$lang->webhook->paramsList['date'] = '操作日期';
|
||||
$lang->webhook->paramsList['comment'] = '备注';
|
||||
$lang->webhook->paramsList['message'] = '操作内容';
|
||||
$lang->webhook->paramsList['text'] = '操作内容';
|
||||
|
||||
$lang->webhook->saveSuccess = '保存成功';
|
||||
$lang->webhook->confirmDelete = '您确认要删除该webhook吗?';
|
||||
|
||||
+41
-13
@@ -31,10 +31,11 @@ class webhookModel extends model
|
||||
* @param string $type
|
||||
* @param string $orderBy
|
||||
* @param object $pager
|
||||
* @param bool $decode
|
||||
* @access public
|
||||
* @return array
|
||||
*/
|
||||
public function getList($type = '', $orderBy = 'id_desc', $pager = null)
|
||||
public function getList($type = '', $orderBy = 'id_desc', $pager = null, $decode = true)
|
||||
{
|
||||
$webhooks = $this->dao->select('*')->from(TABLE_WEBHOOK)
|
||||
->where('deleted')->eq('0')
|
||||
@@ -42,7 +43,7 @@ class webhookModel extends model
|
||||
->orderBy($orderBy)
|
||||
->page($pager)
|
||||
->fetchAll('id');
|
||||
foreach($webhooks as $webhook) $webhook->actions = json_decode($webhook->actions);
|
||||
if($decode) foreach($webhooks as $webhook) $webhook->actions = json_decode($webhook->actions);
|
||||
return $webhooks;
|
||||
}
|
||||
|
||||
@@ -208,7 +209,6 @@ class webhookModel extends model
|
||||
if(!$webhooks) $webhooks = $this->getList();
|
||||
if(!$webhooks) return true;
|
||||
|
||||
$snoopy = $this->app->loadClass('snoopy');
|
||||
foreach($webhooks as $id => $webhook)
|
||||
{
|
||||
if(!isset($webhook->actions->$objectType) or !in_array($actionType, $webhook->actions->$objectType)) continue;
|
||||
@@ -258,7 +258,7 @@ class webhookModel extends model
|
||||
}
|
||||
|
||||
static $users = array();
|
||||
if(empty($users)) $users = $this->loadModel('user')->getPairs('noletter');
|
||||
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];
|
||||
@@ -269,17 +269,45 @@ class webhookModel extends model
|
||||
$data = new stdclass();
|
||||
if($webhook->type == 'dingding')
|
||||
{
|
||||
$title = $this->app->user->realname . $this->lang->action->label->$actionType . $this->lang->action->objectTypes[$objectType];
|
||||
if($actionType == 'assigned') $title .= ' ' . $this->lang->webhook->assigned . ' ' . zget($users, $object->assignedTo);
|
||||
$title = $this->app->user->realname . $this->lang->action->label->$actionType . $this->lang->action->objectTypes[$objectType];
|
||||
$mobile = '';
|
||||
if($actionType == 'assigned')
|
||||
{
|
||||
$assignedTo = $object->assignedTo;
|
||||
foreach($users as $user)
|
||||
{
|
||||
if($user->account == $object->assignedTo)
|
||||
{
|
||||
$assignedTo = $user->realname;
|
||||
$mobile = $user->mobile;
|
||||
break;
|
||||
}
|
||||
}
|
||||
if($mobile) $title .= ' ' . "[#{$objectID}::{$title}](" . $host . $viewLink . ")";
|
||||
$title .= ' ' . $this->lang->webhook->assigned . ' ' . $assignedTo;
|
||||
}
|
||||
|
||||
$link = new stdclass();
|
||||
$link->text = "[#{$objectID}::{$text}]";
|
||||
$link->title = $title;
|
||||
$link->picUrl = '';
|
||||
$link->messageUrl = $host . $viewLink;
|
||||
if($mobile)
|
||||
{
|
||||
$at = new stdclass();
|
||||
$at->atMobiles = array($mobile);
|
||||
$at->isAtAll = false;
|
||||
|
||||
$data->msgtype = 'link';
|
||||
$data->link = $link;
|
||||
$data->msgtype = 'text';
|
||||
$data->text = array('content' => $title);
|
||||
$data->at = $at;
|
||||
}
|
||||
else
|
||||
{
|
||||
$link = new stdclass();
|
||||
$link->text = "[#{$objectID}::{$text}]";
|
||||
$link->title = $title;
|
||||
$link->picUrl = '';
|
||||
$link->messageUrl = $host . $viewLink;
|
||||
|
||||
$data->msgtype = 'link';
|
||||
$data->link = $link;
|
||||
}
|
||||
|
||||
return helper::jsonEncode($data);
|
||||
}
|
||||
|
||||
@@ -56,7 +56,7 @@
|
||||
<?php if($type != 'dingding'):?>
|
||||
<tr>
|
||||
<th><?php echo $lang->webhook->params;?></th>
|
||||
<td class='labelWidth' colspan='2'><?php echo html::checkbox('params', $lang->webhook->paramsList, 'message');?></td>
|
||||
<td class='labelWidth' colspan='2'><?php echo html::checkbox('params', $lang->webhook->paramsList, 'text');?></td>
|
||||
</tr>
|
||||
<?php endif;?>
|
||||
<tr>
|
||||
|
||||
@@ -13,7 +13,7 @@
|
||||
<?php include '../../common/view/header.html.php';?>
|
||||
<div id="titlebar">
|
||||
<div class="heading">
|
||||
<strong><?php echo html::a(inlink('browse', "type={$webhook->type}"), $webhook->type ? $lang->webhook->dingding : $lang->webhook->common);?></strong>
|
||||
<strong><?php echo html::a(inlink('browse', "type={$webhook->type}"), $webhook->type == 'dingding' ? $lang->webhook->dingding : $lang->webhook->common);?></strong>
|
||||
<small class="text-muted"> <?php echo $webhook->name;?> </small>
|
||||
<small class="text-muted"> <?php echo $lang->webhook->log;?> <i class="icon-file-text-o"></i></small>
|
||||
</div>
|
||||
@@ -23,16 +23,18 @@
|
||||
<tr>
|
||||
<?php $vars = "id={$webhook->id}&orderBy=%s&recTotal={$pager->recTotal}&recPerPage={$pager->recPerPage}&pageID={$pager->pageID}";?>
|
||||
<th class='w-60px'><?php common::printOrderLink('id', $orderBy, $vars, $lang->webhook->id);?></th>
|
||||
<th class='w-160px'><?php common::printOrderLink('date', $orderBy, $vars, $lang->webhook->date);?></th>
|
||||
<th><?php common::printOrderLink('url', $orderBy, $vars, $lang->webhook->url);?></th>
|
||||
<th class='w-300px'><?php common::printOrderLink('action', $orderBy, $vars, $lang->webhook->action);?></th>
|
||||
<th class='w-200px'><?php common::printOrderLink('contentType', $orderBy, $vars, $lang->webhook->contentType);?></th>
|
||||
<th class='w-200px'><?php common::printOrderLink('status', $orderBy, $vars, $lang->webhook->status);?></th>
|
||||
<th class='w-200px'><?php common::printOrderLink('result', $orderBy, $vars, $lang->webhook->result);?></th>
|
||||
</tr>
|
||||
</thead>
|
||||
<tbody>
|
||||
<?php foreach($logs as $id => $log):?>
|
||||
<tr>
|
||||
<td class='text-center'><?php echo $id;?></td>
|
||||
<td><?php echo $log->date;?></td>
|
||||
<td class='text' title='<?php echo $log->url;?>'><?php echo $log->url;?></td>
|
||||
<td class='text' title='<?php echo $log->action;?>'><?php echo html::a($log->actionURL, $log->action);?></td>
|
||||
<td class='text-center'><?php echo $log->contentType;?></td>
|
||||
|
||||
+53
@@ -0,0 +1,53 @@
|
||||
<?php
|
||||
/**
|
||||
* The api router file of ZenTaoPMS.
|
||||
*
|
||||
* All request of entries should be routed by this router.
|
||||
*
|
||||
* @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 ZenTaoPMS
|
||||
* @version $Id: index.php 5036 2013-07-06 05:26:44Z wyd621@gmail.com $
|
||||
* @link http://www.zentao.net
|
||||
*/
|
||||
/* Set the error reporting. */
|
||||
error_reporting(0);
|
||||
|
||||
/* Start output buffer. */
|
||||
ob_start();
|
||||
|
||||
/* Load the framework. */
|
||||
include '../framework/router.class.php';
|
||||
include '../framework/control.class.php';
|
||||
include '../framework/model.class.php';
|
||||
include '../framework/helper.class.php';
|
||||
|
||||
/* Log the time and define the run mode. */
|
||||
$startTime = getTime();
|
||||
|
||||
/* Instance the app. */
|
||||
$app = router::createApp('pms', dirname(dirname(__FILE__)), 'router');
|
||||
|
||||
/* Run the app. */
|
||||
$common = $app->loadCommon();
|
||||
|
||||
/* Check entry. */
|
||||
$common->checkEntry();
|
||||
|
||||
/* Set default params. */
|
||||
$config->requestType = 'GET';
|
||||
$config->default->view = 'json';
|
||||
|
||||
$app->parseRequest();
|
||||
$common->checkPriv();
|
||||
$app->loadModule();
|
||||
|
||||
$output = json_decode(ob_get_clean());
|
||||
$output = json_encode($output->data);
|
||||
|
||||
unset($_SESSION['ENTRY_CODE']);
|
||||
unset($_SESSION['VALID_ENTRY']);
|
||||
|
||||
/* Flush the buffer. */
|
||||
echo helper::removeUTF8Bom($output);
|
||||
Reference in New Issue
Block a user