逻辑调整

src/main/java/com/cc/solr/job/TrackDataJob.java

@@ -9,6 +9,7 @@ import org.apache.solr.client.solrj.SolrQuery;
 import org.apache.solr.client.solrj.SolrServerException;
 import org.apache.solr.client.solrj.impl.HttpSolrClient;
 import org.apache.solr.client.solrj.response.QueryResponse;
+import org.apache.solr.client.solrj.response.UpdateResponse;
 import org.apache.solr.common.SolrDocumentList;
 import org.apache.solr.common.SolrInputDocument;
 import org.quartz.*;
@@ -52,6 +53,7 @@ public class TrackDataJob implements BaseJob {
         Date date = new Date();//创建时间
         String importdate = bf.format(date);//格式化 bf.format(date);
 
+        System.out.println("TrackData Job执行时间: " + new Date());
        List<Track> trackList= trackService.selectTrackList(importdate);
         System.out.println("增量总数："+trackList.size());
         Properties properties = propertiesUtil.propertiesUtil("solr.properties");
@@ -77,6 +79,12 @@ public class TrackDataJob implements BaseJob {
             //搜索结果
             SolrDocumentList    resultsize = queryResponse.getResults();
             if(resultsize.size()==0){//25 0表示数据源里没有
+                //再去基站信息表里查询一次，确保确定没有这条数据
+
+
+
+
+
                 this.saveJzxx(trackList.get(i),core, client);//25则入库oracle，把数据写入数据源，确保每次任务结束之后，数据源与比对源的数据一致
                 savecount++;
             }
@@ -86,27 +94,11 @@ public class TrackDataJob implements BaseJob {
           //  System.out.println(json);
         }
         System.out.println("保存条数:"+savecount);
-
-
-
-         //2.
-        //3.
-
-
     }
 
     //保存基站信息
     public void saveJzxx(Track track,String core, HttpSolrClient client){
         try {
-            TbStJzxx jzxx=new TbStJzxx();
-            jzxx.setXxzjbh(track.getXxzjbh());
-            jzxx.setAddress(track.getAddress());
-            jzxx.setLon(track.getJ());
-            jzxx.setLat(track.getW());
-            jzxx.setLrsj(new Date());
-            tbStJzxxService.saveJzxx(jzxx);
-            //手动add数据到数据源里
-
             SolrInputDocument doc = new SolrInputDocument();
             doc.setField("ID", track.getId());
             doc.setField("XXZJBH", track.getXxzjbh());
@@ -121,7 +113,19 @@ public class TrackDataJob implements BaseJob {
              */
 
             client.add(core, doc);
-            client.commit(core);
+            UpdateResponse response=client.commit(core);
+            int status = response.getStatus();
+
+            if (status  == 0) {//0表示成功
+                TbStJzxx jzxx=new TbStJzxx();
+                jzxx.setXxzjbh(track.getXxzjbh());
+                jzxx.setAddress(track.getAddress());
+                jzxx.setLon(track.getJ());
+                jzxx.setLat(track.getW());
+                jzxx.setLrsj(new Date());
+                tbStJzxxService.saveJzxx(jzxx);
+                //手动add数据到数据源里
+            }
         }catch(Exception e){
             e.printStackTrace();