作者 lyh

变更数据

@@ -76,12 +76,16 @@ class GeoLinkLogic extends BaseLogic @@ -76,12 +76,16 @@ class GeoLinkLogic extends BaseLogic
76 if(!empty($this->param['data'])){ 76 if(!empty($this->param['data'])){
77 $data = []; 77 $data = [];
78 foreach ($this->param['data'] as $item){ 78 foreach ($this->param['data'] as $item){
79 - $data[] = [  
80 - 'project_id'=>$this->param['project_id'],  
81 - 'da'=>$item['da'] ?? 0,  
82 - 'url'=>$item['url'],  
83 - 'send_time'=>$item['send_time']  
84 - ]; 79 + //查看当前Url是否存在
  80 + $info = $this->model->read(['url'=>$item['url'],'type'=>$this->model::TYPE_NEWS,'project_id'=>$this->param['project_id']]);
  81 + if($info === false){
  82 + $data[] = [
  83 + 'project_id'=>$this->param['project_id'],
  84 + 'da'=>$item['da'] ?? 0,
  85 + 'url'=>$item['url'],
  86 + 'send_time'=>$item['send_time']
  87 + ];
  88 + }
85 } 89 }
86 $this->model->insertAll($data); 90 $this->model->insertAll($data);
87 } 91 }
@@ -44,6 +44,7 @@ class LinkDataLogic extends BaseLogic @@ -44,6 +44,7 @@ class LinkDataLogic extends BaseLogic
44 public function batchSave(){ 44 public function batchSave(){
45 $data = []; 45 $data = [];
46 foreach ($this->param['data'] as $v){ 46 foreach ($this->param['data'] as $v){
  47 + //todo::数据去重
47 $data[] = [ 48 $data[] = [
48 'url'=>$v['url'], 49 'url'=>$v['url'],
49 'da'=>$v['da_values'], 50 'da'=>$v['da_values'],