作者 邓超

优化 sync to es

@@ -44,7 +44,14 @@ class SyncToEsCmd { @@ -44,7 +44,14 @@ class SyncToEsCmd {
44 $code = 500; 44 $code = 500;
45 if($id){ 45 if($id){
46 $doc_id = ''; 46 $doc_id = '';
47 - $data = $db->first(\Model\listsSql::first('`id` = '.$id)); 47 + try {
  48 + $data = $db->throw()->first(\Model\listsSql::first('`id` = '.$id));
  49 + }catch (Throwable $e){
  50 + redis()->rPush('sync_to_es',$id);
  51 + _echo('sync to es '.$e->getMessage());
  52 + break;
  53 + }
  54 +
48 if($data){ 55 if($data){
49 // 设置 进程 是否在运行 56 // 设置 进程 是否在运行
50 $data['is_auto']=$db->count('select count(*) from `lists_auto` where `list_id` = '.$data['id']) ? 1 : 0; 57 $data['is_auto']=$db->count('select count(*) from `lists_auto` where `list_id` = '.$data['id']) ? 1 : 0;
@@ -88,6 +95,7 @@ class SyncToEsCmd { @@ -88,6 +95,7 @@ class SyncToEsCmd {
88 $v['name'] = ''; 95 $v['name'] = '';
89 return $v; 96 return $v;
90 },$data['to_name']); 97 },$data['to_name']);
  98 + $data['to_name'] = array_slice($data['to_name'],0,100);
91 $data['to_name'] = json_encode($data['to_name']); 99 $data['to_name'] = json_encode($data['to_name']);
92 }else{ 100 }else{
93 $data['to_name'] = ''; 101 $data['to_name'] = '';