|
@@ -800,6 +800,7 @@ class CollectorService implements CollectorServiceInterface
|
|
|
//查找此规则任务下的文章是否已经有导入的文章
|
|
//查找此规则任务下的文章是否已经有导入的文章
|
|
|
$article = Article::where('rule_id',$id)->where('state',1)->select('id')->get();
|
|
$article = Article::where('rule_id',$id)->where('state',1)->select('id')->get();
|
|
|
if(!empty($article->toArray())){
|
|
if(!empty($article->toArray())){
|
|
|
|
|
+
|
|
|
//查询已导入的文章的导航id
|
|
//查询已导入的文章的导航id
|
|
|
$catid = Article::whereIn('id',$article)->select('catid')->first();
|
|
$catid = Article::whereIn('id',$article)->select('catid')->first();
|
|
|
//查询未导入的文章id
|
|
//查询未导入的文章id
|
|
@@ -807,7 +808,7 @@ class CollectorService implements CollectorServiceInterface
|
|
|
if($art_catid>0){
|
|
if($art_catid>0){
|
|
|
$catid = (int)$catid['catid'];
|
|
$catid = (int)$catid['catid'];
|
|
|
$cat_arr_id = json_encode([$catid]);
|
|
$cat_arr_id = json_encode([$catid]);
|
|
|
- $result = Article::whereIn('id',$info)->update(['catid'=>$catid['catid'],'cat_arr_id'=>$cat_arr_id]);
|
|
|
|
|
|
|
+ $result = Article::whereIn('id',$info)->update(['catid'=>$catid,'cat_arr_id'=>$cat_arr_id]);
|
|
|
}else{
|
|
}else{
|
|
|
$result = ['已全部关联导航，无需再次关联！'];
|
|
$result = ['已全部关联导航，无需再次关联！'];
|
|
|
}
|
|
}
|
|
@@ -838,7 +839,6 @@ class CollectorService implements CollectorServiceInterface
|
|
|
}
|
|
}
|
|
|
// return Result::success($result);
|
|
// return Result::success($result);
|
|
|
|
|
|
|
|
-
|
|
|
|
|
}
|
|
}
|
|
|
/**
|
|
/**
|
|
|
* 导入文章（生产者）
|
|
* 导入文章（生产者）
|
15313670163