es

@@ -265,7 +265,12 @@ class SyncToEsCmd {
         $this->es->setIndex($index);
         $this->es->setIndex($index);
         // 检查数据库是否存在
         // 检查数据库是否存在
         if(empty($this->checkEsIndex[$index])){
         if(empty($this->checkEsIndex[$index])){
-            _echo("{$index} 创建索引 ".$this->setEsMap($index));
+            $m = $this->setEsMap($index);
+            _echo("{$index} 创建索引 ".$m);
+            if(!$m){
+                $this->log($data_id,$index);
+                return;
+            }
         }
         }
         // 下次不在检查
         // 下次不在检查
         $this->checkEsIndex[$index] = 1;
         $this->checkEsIndex[$index] = 1;