bug修改

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

@@ -54,8 +54,9 @@ public class TrackDataJob implements BaseJob {
 
         System.out.println("TrackData Job执行时间: " + new Date());
         //查询track表增量，track表djsj>当前任务执行时间-1小时的数据，减一小时是为了避免丢失数据。
+        System.out.println("lallalalalalalalalImportdate:"+importdate);
        List<Track> trackList= trackService.selectTrackList(importdate);
-        System.out.println("增量总数："+trackList.size());
+        System.out.println("1:增量总数："+trackList.size());
         Properties properties = propertiesUtil.propertiesUtil("solr.properties");
         String url= properties.getProperty("sourcesolrdata");
         HttpSolrClient client = new HttpSolrClient(url);
@@ -68,31 +69,40 @@ public class TrackDataJob implements BaseJob {
             params.set("q", "ID:"+trackList.get(i).getId());
             //执行搜索
             QueryResponse queryResponse = null;
+            int solrflag=0;
+            int solrSize=0;
             try {
                 queryResponse = client.query(core, params);
-            } catch (SolrServerException e) {
+            } catch(Exception e){
+                solrflag=1;
                 e.printStackTrace();
-            } catch (IOException e) {
-                e.printStackTrace();
-            }
-            //搜索结果
-            SolrDocumentList    resultsize = queryResponse.getResults();
-            if(resultsize.size()==0){//0表示数据源里没有
-                //再去基站信息表里查询一次，确保确定没有这条数据
-                List<TbStJzxx> list = tbStJzxxService.selectJzxxByAddressJW(trackList.get(i).getAddress(),trackList.get(i).getJ(),trackList.get(i).getW());
-                if(list.size()==0){
-                    this.saveJzxx(trackList.get(i),core, client);//25则入库oracle，把数据写入数据源，确保每次任务结束之后，数据源与比对源的数据一致
-                    jzxxcount++;
+            }finally {
+                //搜索结果
+                //System.out.println("2:solrflag:"+solrflag);
+                if(solrflag==0){
+                    SolrDocumentList    resultsize = queryResponse.getResults();
+                    solrSize=resultsize.size();
+                }else if(solrflag==1){
+                    solrSize=0;
+                }
+                if(solrSize==0){//0表示数据源里没有
+                    //再去基站信息表里查询一次，确保确定没有这条数据
+                    List<TbStJzxx> list = tbStJzxxService.selectJzxxByAddressJW(trackList.get(i).getAddress(),trackList.get(i).getJ(),trackList.get(i).getW());
+                    if(list.size()==0){
+                        this.saveJzxx(trackList.get(i),core, client);//25则入库oracle，把数据写入数据源，确保每次任务结束之后，数据源与比对源的数据一致
+                        jzxxcount++;
+                    }
+                    savecount++;
                 }
-                savecount++;
             }
+
             //String str=trackList.get(i).toString();
             //JSONObject jsonStr = JSONObject.parseObject(str);
            // String json = HttpClientUtil.doPost(url+core+"/update?commitWithin=1000&overwrite=true&wt="+jsonStr);
           //  System.out.println(json);
         }
-        System.out.println("solr保存条数:"+savecount);
-        System.out.println("基站信息保存条数:"+jzxxcount);
+        System.out.println("3:solr保存条数:"+savecount);
+        System.out.println("4:基站信息保存条数:"+jzxxcount);
     }
 
     //保存基站信息