定时任务修改

This commit is contained in:
chengxl
2025-04-18 15:22:45 +08:00
parent 2512cdf56d
commit e9520a6c9d

View File

@@ -26,6 +26,7 @@ class Crontask extends Controller
//数据处理 //数据处理
$aUpdate = []; $aUpdate = [];
for ($iPage=1; $iPage <= $iDealNum; $iPage++) { for ($iPage=1; $iPage <= $iDealNum; $iPage++) {
$iStart = ($iPage - 1) * $iSize; $iStart = ($iPage - 1) * $iSize;
$aArticleState = Db::name('article')->where($aParam)->limit($iStart,$iSize)->column('article_id,state'); $aArticleState = Db::name('article')->where($aParam)->limit($iStart,$iSize)->column('article_id,state');
if(empty($aArticleState)){ if(empty($aArticleState)){
@@ -34,7 +35,7 @@ class Crontask extends Controller
//获取该文章审核人的信息 //获取该文章审核人的信息
$aWhere = [ $aWhere = [
'article_id'=>['in',array_keys($aArticleState)], 'article_id'=>['in',array_keys($aArticleState)],
'state'=>['in',[1,2,3]] 'state'=>['in',[1,2,3]],
]; ];
$aReviewer = Db::name('article_reviewer')->field('article_id,reviewer_id,state')->where($aWhere)->order('article_id asc,reviewer_id asc')->select(); $aReviewer = Db::name('article_reviewer')->field('article_id,reviewer_id,state')->where($aWhere)->order('article_id asc,reviewer_id asc')->select();
if(empty($aReviewer)){ if(empty($aReviewer)){
@@ -52,6 +53,7 @@ class Crontask extends Controller
$aCase = ['right_times' => '', 'right_rate' => '','error_times' => '', 'error_rate' => '']; $aCase = ['right_times' => '', 'right_rate' => '','error_times' => '', 'error_rate' => ''];
$aToState = [2 => 3,3 => 5];//文章3拒稿5录用 审稿人2拒稿3通过 $aToState = [2 => 3,3 => 5];//文章3拒稿5录用 审稿人2拒稿3通过
$aId = []; $aId = [];
// echo '<pre>';var_dump($aReviewer);
foreach ($aReviewer as $key => $item) { foreach ($aReviewer as $key => $item) {
//审核次数+1 //审核次数+1
$aUpdate[$item['reviewer_id']]['reviewer_id'] = $item['reviewer_id'] ; $aUpdate[$item['reviewer_id']]['reviewer_id'] = $item['reviewer_id'] ;
@@ -66,10 +68,11 @@ class Crontask extends Controller
} }
if($iArticleState == $aToState[$item['state']]){ if($iArticleState == $aToState[$item['state']]){
$aUpdate[$item['reviewer_id']]['right_times'] = empty($aUpdate[$item['reviewer_id']]['right_times']) ? 1 : $aUpdate[$item['reviewer_id']]['right_times']+1 ; $aUpdate[$item['reviewer_id']]['right_times'] = empty($aUpdate[$item['reviewer_id']]['right_times']) ? 1 : $aUpdate[$item['reviewer_id']]['right_times']+1 ;
} }
if($iArticleState != $item['state']){ if($iArticleState != $aToState[$item['state']]){
$aUpdate[$item['reviewer_id']]['error_times'] = empty($aUpdate[$item['reviewer_id']]['error_times']) ? 1 : $aUpdate[$item['reviewer_id']]['error_times']+1 ; $aUpdate[$item['reviewer_id']]['error_times'] = empty($aUpdate[$item['reviewer_id']]['error_times']) ? 1 : $aUpdate[$item['reviewer_id']]['error_times']+1 ;
} }