/**  
 * Project Name:padwebcollector  
 * File Name:DiscussService.java  
 * Package Name:com.pad.service  
 * Date:2018年7月25日下午4:59:44  
 * Copyright (c) 2018 All Rights Reserved.  
 *  
*/   
   
package com.pad.service;   
 
import java.util.ArrayList; 
import java.util.List; 
import org.openqa.selenium.By; 
import org.openqa.selenium.WebDriver; 
import org.openqa.selenium.WebElement; 
import org.openqa.selenium.phantomjs.PhantomJSDriver; 
import cn.edu.hfut.dmic.webcollector.crawler.DeepCrawler; 
import cn.edu.hfut.dmic.webcollector.model.Links; 
import cn.edu.hfut.dmic.webcollector.model.Page; 
import com.pad.entity.DiscussInfo; 
import com.pad.impl.DiscussInfoImpl; 
 
public class DiscussService extends DeepCrawler { 
     
    public DiscussService(String crawlPath) { 
        super(crawlPath); 
        // TODO Auto-generated constructor stub 
    } 
     
    @Override 
    public Links visitAndGetNextLinks(Page page) { 
        // TODO Auto-generated method stub 
        WebDriver driver = getWebDriver(page); 
        Analysis analysis = new Analysis(); 
        List<DiscussInfo> discusslist = new ArrayList(); 
        List<WebElement> list = driver.findElements(By.className("content")); 
        int i = 1; 
        String r_msg = "观望"; 
        for(WebElement el : list) { 
            if(!"".equals(el.getText().trim())){ 
                r_msg = analysis.analysis(el.getText()); 
            } 
             
            DiscussInfo info = new DiscussInfo(); 
            info.setLine_no(String.valueOf(i)); 
            info.setResult_msg(r_msg); 
            info.setContent_msg(el.getText()); 
            discusslist.add(info); 
            System.out.println(i+" "+el.getText()); 
            i++; 
        } 
        driver.close(); 
        driver.quit(); 
         
        DiscussInfoImpl impl = new DiscussInfoImpl(); 
        impl.saveData(discusslist); 
        return null; 
    } 
     
    public static WebDriver getWebDriver(Page page) { 
        System.setProperty("phantomjs.binary.path", "D://******//phantomjs.exe"); 
        WebDriver driver = new PhantomJSDriver(); 
        driver.get(page.getUrl()); 
        return driver; 
    } 
 
    public static void main(String[] args) { 
        DiscussService dis=new DiscussService("discuss");   
　　　　 dis.addSeed("https://*******/index/0000012"); 
        try { 
        dis.start(1); 
    } catch (Exception e) { 
        e.printStackTrace(); 
    } 
    } 
}